From 9d38f2354b3a7267a2486d937bb7d256fcb949c1 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期五, 13 六月 2025 08:15:48 +0800
Subject: [PATCH] #增加生产日期,到期日期字段,增加库存明细超期库存检索

---
 src/main/java/com/zy/common/web/WcsController.java |   87 +++++++++++++++++++++++++++++++++++--------
 1 files changed, 70 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index 2b2ab28..2b79a7f 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -9,6 +9,7 @@
 import com.zy.asrs.mapper.WrkMastMapper;
 import com.zy.asrs.service.*;
 import com.zy.common.CodeRes;
+import com.zy.common.model.AgvBasDevpDto;
 import com.zy.common.model.LocTypeDto;
 import com.zy.common.model.StartupDto;
 import com.zy.common.service.CommonService;
@@ -26,6 +27,8 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
+
+import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
 
 /**
  * Created by vincent on 2020/10/30
@@ -67,6 +70,8 @@
     private WrkMastLogService wrkMastLogService;
     @Autowired
     private AgvWrkDetlService agvWrkDetlService;
+    @Autowired
+    private AgvLocDetlService agvLocDetlService;
 //    @Autowired
 //    private ErpService erpService;
 
@@ -275,6 +280,8 @@
             WrkDetl wrkDetl = new WrkDetl();
             BeanUtils.copyProperties(waitPakin, wrkDetl);
             wrkDetl.setZpallet(barcode);
+            wrkDetl.setProddate(waitPakin.getProddate());
+            wrkDetl.setDeadline(waitPakin.getDeadline());
             wrkDetl.setWrkNo(wrkMast.getWrkNo());
             wrkDetl.setIoTime(wrkMast.getIoTime());
             wrkDetl.setAppeTime(now);
@@ -630,7 +637,8 @@
             currentContainerMap = new HashMap<>();
         }
 
-        String containerCode = param.getContainerCode();
+        String containerCode = param.getContainerCode().split(";")[0];
+
         if(Cools.isEmpty(containerCode)){
             throw new CoolException("鏂欑鐮佷负绌�");
         }
@@ -648,19 +656,22 @@
             //鏌ヨ鏃у鍣ㄧ殑宸ヤ綔妗�
             AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(currentContainerCode);
             if(!Cools.isEmpty(agvWrkMast) && agvWrkMast.getIoType() == 101){
-                //鍙戦�佸鍣ㄧ珛鍦鸿姹傦紝瀹屾垚宸ヤ綔妗�
-                List<AgvWrkMast> agvWrkMastList = new ArrayList<>();
-                agvWrkMastList.add(agvWrkMast);
-                try {
-                    int code = agvWrkMastService.containerMoveOut(agvWrkMastList);
-                    if(code == 0){
-                        //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦�
-                        agvWrkMast.setWrkSts(206L);
-                        agvWrkMastService.updateById(agvWrkMast);
-                    }
-                } catch (IOException e) {
-                    log.error(e.getMessage());
-                }
+                //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦�
+                agvWrkMast.setWrkSts(206L);
+                agvWrkMastService.updateById(agvWrkMast);
+//                //鍙戦�佸鍣ㄧ珛鍦鸿姹傦紝瀹屾垚宸ヤ綔妗�
+//                List<AgvWrkMast> agvWrkMastList = new ArrayList<>();
+//                agvWrkMastList.add(agvWrkMast);
+//                try {
+//                    int code = agvWrkMastService.containerMoveOut(agvWrkMastList);
+//                    if(code == 0){
+//                        //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦�
+//                        agvWrkMast.setWrkSts(206L);
+//                        agvWrkMastService.updateById(agvWrkMast);
+//                    }
+//                } catch (IOException e) {
+//                    log.error(e.getMessage());
+//                }
             }
         }
 
@@ -679,18 +690,60 @@
         String devNo = param.getDevNo();
         String containerCode = currentContainerMap.get(devNo);
 
+        AgvBasDevpDto agvBasDevpDto = new AgvBasDevpDto();
+
         //鏌ユ壘璇ュ鍣ㄧ殑宸ヤ綔妗�
         AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(containerCode);
         if(!Cools.isEmpty(agvWrkMast)){
-            return R.ok(agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",agvWrkMast.getWrkNo())));
+            List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo()));
+
+            for (AgvWrkDetl agvWrkDetl : agvWrkDetlList){
+                agvWrkDetl.setVolume(agvWrkDetl.getAnfme());
+                if(agvWrkMast.getIoType() == 103){
+                    //瀵绘壘鏄惁鏈夌浉鍚岀墿鏂欑殑宸ヤ綔妗f槑缁嗭紝骞惰繑鍥炴暟閲忎箣鍜�
+                    double anfme = getAllAnfmeInAgvWrkDetlList(agvWrkDetlList,agvWrkDetl);
+                    AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getSourceLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
+                    //鐢ㄤ簬缁撲綑鏁伴噺鏄剧ず
+                    agvWrkDetl.setVolume(agvLocDetl.getAnfme() - anfme);
+                }
+                if(agvWrkMast.getIoType() == 53){
+                    AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
+                    if(Cools.isEmpty(agvLocDetl)){
+                        agvWrkDetl.setVolume(0.0);
+                    }else {
+                        agvWrkDetl.setVolume(agvLocDetl.getAnfme());
+                    }
+                }
+            };
+
+            agvBasDevpDto.setAgvWrkDetls(agvWrkDetlList);
+            agvBasDevpDto.setAgvWrkMast(agvWrkMast);
         }
         //鏌ユ壘璇ュ鍣ㄧ殑鍏ュ簱閫氱煡妗�
         List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code", containerCode));
         if(!Cools.isEmpty(agvWaitPakinList)){
-            return R.ok(agvWaitPakinList);
+            agvBasDevpDto.setAgvWaitPakins(agvWaitPakinList);
         }
 
-        return R.error("娌℃湁璇ュ鍣ㄧ殑鍑哄簱銆佹嫞鏂欍�佸叆搴撲俊鎭瓑");
+        System.out.println("currentContainerMap: " + currentContainerMap);
+
+
+        System.out.println("agvBasDevpDto: " + agvBasDevpDto);
+
+        return R.ok(agvBasDevpDto);
+    }
+
+    private double getAllAnfmeInAgvWrkDetlList(List<AgvWrkDetl> agvWrkDetlList, AgvWrkDetl wd0) {
+        double allAnfme = 0;
+        for (AgvWrkDetl wd1 : agvWrkDetlList){
+            if(Cools.eq(wd0.getMatnr(),wd1.getMatnr())
+                    && Cools.eq(wd0.getBatch(),wd1.getBatch())
+                    && Cools.eq(wd0.getThreeCode(),wd1.getThreeCode())
+                    && Cools.eq(wd0.getDeadTime(),wd1.getDeadTime())){
+                allAnfme += wd1.getAnfme();
+            }
+        }
+        return allAnfme;
     }
 
 

--
Gitblit v1.9.1