From 9d8d5147ca480bd734b71106962cdf3816e59a16 Mon Sep 17 00:00:00 2001
From: tzsk <Administrator@qq.com>
Date: 星期三, 07 二月 2024 18:29:35 +0800
Subject: [PATCH] Changes

---
 src/main/java/com/zy/common/web/WcsController.java |   71 +++++++++++++++++++++++++++++++----
 1 files changed, 62 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index ad801a9..45f3aff 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;
@@ -65,6 +66,10 @@
     private WrkMastMapper wrkMastMapper;
     @Autowired
     private WrkMastLogService wrkMastLogService;
+    @Autowired
+    private AgvWrkDetlService agvWrkDetlService;
+    @Autowired
+    private AgvLocDetlService agvLocDetlService;
 //    @Autowired
 //    private ErpService erpService;
 
@@ -592,14 +597,16 @@
 
         //鎷f枡銆佺洏鐐瑰畬鎴愪换鍔�
         if(!Cools.isEmpty(agvWrkMast) && (agvWrkMast.getIoType() == 103 || agvWrkMast.getIoType() == 107) && agvWrkMast.getWrkSts() == 205){
+            //缁戝畾绔欑偣
+            agvBasDevpService.updateLocStsAndBarcodeByDevNo(param.getDevNo(),"F",containerCode);
+
             //鐢熸垚鎷f枡銆佺洏鐐瑰啀鍏ュ簱浠诲姟
             List<AgvWrkMast> agvWrkMastList = new ArrayList<>();
             agvWrkMast.setMk("Y");
             agvWrkMast.setLocNo(agvBasDevp.getDevNo());
             agvWrkMastList.add(agvWrkMast);
             agvWorkService.pickIn(agvWrkMastList);
-            //缁戝畾绔欑偣
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(param.getDevNo(),"F",containerCode);
+
             return R.ok();
         }
 
@@ -626,15 +633,24 @@
             currentContainerMap = new HashMap<>();
         }
 
-        String devNo = param.getDevNo();
         String containerCode = param.getContainerCode();
+        if(Cools.isEmpty(containerCode)){
+            throw new CoolException("鏂欑鐮佷负绌�");
+        }
+
+        if(!Character.isDigit(containerCode.charAt(0))){
+            containerCode = containerCode.substring(3,containerCode.length());
+        }
+
+
+        String devNo = param.getDevNo();
         String currentContainerCode = currentContainerMap.get(devNo);
 
         //鍒ゆ柇瀹瑰櫒鏄惁鍙戠敓鍙樺寲
-        if(!Cools.eq(containerCode,currentContainerCode)){
+        if(!Cools.isEmpty(currentContainerCode) && !Cools.eq(containerCode,currentContainerCode)){
             //鏌ヨ鏃у鍣ㄧ殑宸ヤ綔妗�
             AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(currentContainerCode);
-            if(agvWrkMast.getIoType() == 101){
+            if(!Cools.isEmpty(agvWrkMast) && agvWrkMast.getIoType() == 101){
                 //鍙戦�佸鍣ㄧ珛鍦鸿姹傦紝瀹屾垚宸ヤ綔妗�
                 List<AgvWrkMast> agvWrkMastList = new ArrayList<>();
                 agvWrkMastList.add(agvWrkMast);
@@ -666,19 +682,56 @@
         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(agvWrkMast);
+            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());
+                    }
+                }
+            };
+
+
+            return R.ok(agvWrkDetlList).add(agvWrkMast);
         }
         //鏌ユ壘璇ュ鍣ㄧ殑鍏ュ簱閫氱煡妗�
-        AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectByContainerCode(containerCode);
-        if(!Cools.isEmpty(agvWaitPakin)){
-            return R.ok(agvWaitPakin);
+        List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code", containerCode));
+        if(!Cools.isEmpty(agvWaitPakinList)){
+            return R.ok(agvWaitPakinList);
         }
 
         return R.error("娌℃湁璇ュ鍣ㄧ殑鍑哄簱銆佹嫞鏂欍�佸叆搴撲俊鎭瓑");
     }
 
+    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