From 6d6d85bb7a7108f20fcb13993b5248ec7d079fad Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期三, 10 四月 2024 09:57:35 +0800
Subject: [PATCH] 库位修改

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   84 ++++++++++++++++++++++++-----------------
 1 files changed, 49 insertions(+), 35 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
index feacc9d..0d94bdf 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -134,7 +134,7 @@
             //鍒ゆ柇鏄惁鍏ㄦ澘鍑哄簱
             int ioType = isPakOut(sourceLocNo,taskDto) ?  101 : 103;
             //鐢熸垚宸ヤ綔妗�
-            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,containerCode,now,userId,0);
+            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,containerCode,now,userId,Short.valueOf(containerCode.substring(0,2)));
             //鐢熸垚宸ヤ綔妗f槑缁�
             taskDto.getLocDtos().forEach(locDto -> {
                 if (!BaseController.isJSON(locDto.getOrderNo())) {
@@ -316,38 +316,35 @@
     鍏ュ簱
      */
     @Transactional
-    public String emptyPlateIn(String station,String containerCode,Short containerType, Long userId) {
+    public String emptyPlateIn(String station,String containerCode,Short containerType, Long userId, boolean emptyAutoIn) {
 
         Date now = new Date();
-        // 婧愮珯鐐圭姸鎬佹娴�
-        //AgvBasDevp agvBasDevp = agvBasDevpService.selectByDevNo(station);
+
         AgvBasDevp agvBasDevp = agvBasDevpService.selectById(station);
 
-        //鍒濆瀹氫箟涓虹┖鏉垮叆搴撶被鍨�
-        int ioType = 10;
-
-//        if(Cools.isEmpty(agvBasDevp.getBarcode())){
-//            agvBasDevp.setBarcode(containerCode);
-//        }
-
-        if(!Cools.eq(agvBasDevp.getBarcode(),containerCode) && !agvBasDevp.getLocSts().equals("O")){
+        if(!Cools.eq(agvBasDevp.getBarcode(),containerCode) && !agvBasDevp.getLocSts().equals("O") && !emptyAutoIn){
             throw new CoolException("褰撳墠宸ヤ綔浣嶇姸鎬佷负" + agvBasDevp.getLocSts()+",鏃犳硶杩涜绌烘澘鍏ュ簱");
         }
 
         //鏌ヨ宸ヤ綔妗�
         AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(containerCode);
-        if(!Cools.isEmpty(agvWrkMast)){
+        if(!Cools.isEmpty(agvWrkMast) && !emptyAutoIn){
             throw new CoolException("褰撳墠瀹瑰櫒宸叉湁鍏ュ簱浠诲姟锛屾棤娉曡繘琛屽叆搴�");
         }
 
         //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
-        AgvLocMast agvLocMast = agvLocMast = agvCommonService.getLocNo(agvBasDevp.getLocType1());
+        AgvLocMast agvLocMast = agvCommonService.getLocNo(agvBasDevp.getLocType1());
 
         //鏌ヨ鍏ュ簱閫氱煡妗�
         List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectByContainerCode(containerCode);
         if(!Cools.isEmpty(agvWaitPakinList)){
+
+
+            String devNo = agvBasDevp.getDevNo();
+            String locNo = agvLocMast.getLocNo();
+
             //鐢熸垚宸ヤ綔妗�
-            AgvWrkMast wrkMast = createWrkMast(1,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),containerCode,now,userId, agvBasDevp.getLocType2());
+            AgvWrkMast wrkMast = createWrkMast(1,201L,devNo,locNo,containerCode,now,userId, containerType);
             //鐢熸垚宸ヤ綔妗f槑缁�
             agvWaitPakinList.forEach(wp -> {
                 createWrkDetlReWrite(wp.getMatnr(),wrkMast.getWrkNo(),wp.getOrderNo(),wp.getBatch(),wp.getAnfme(),wp.getSuppCode(),now,userId,wp.getThreeCode(),wp.getDeadTime());
@@ -355,12 +352,12 @@
             //淇敼鍏ュ簱閫氱煡妗g姸鎬�
             agvWaitPakinService.updateIoStatus(containerCode,"Y");
             //鏇存柊婧愮珯鐐圭姸鎬�
-            updateAgvBasDevp(agvBasDevp,"R");
+            updateAgvBasDevp(agvBasDevp,"R",containerType);
         }else {
             // 鐢熸垚宸ヤ綔妗� 10.绌烘澘鍏ュ簱
             createWrkMast(10,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),containerCode,now,userId,containerType);
             //鏇存柊婧愮珯鐐圭姸鎬�
-            updateAgvBasDevp(agvBasDevp,"R",containerType);
+            updateAgvBasDevp(agvBasDevp,"R",containerType,containerCode);
         }
 
         //鏇存柊鐩爣搴撲綅鐘舵�佸拰淇℃伅
@@ -383,6 +380,12 @@
 
         //瀵绘壘鐩稿簲绫诲瀷鐨勭┖鎵樼洏
         AgvLocMast agvLocMast = agvLocMastService.selectEmptyZpallet(containerType);
+        if(containerType == 0){
+            //绌烘澘鑷姩鍑哄簱锛屾牴鎹珯鐐圭被鍨嬮�夋嫨
+            agvLocMastService.selectEmptyZpalletByLocType1(agvBasDevp.getLocType1());
+
+        }
+
         if (Cools.isEmpty(agvLocMast)) {
             throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖鎵樼洏锛�");
         }
@@ -393,7 +396,7 @@
         updateAgvLocMast(agvLocMast,"R");
 
         //淇敼绔欑偣鐘舵��
-        updateAgvBasDevp(agvBasDevp,"S");
+        updateAgvBasDevp(agvBasDevp,"S",(short)containerType,agvLocMast.getBarcode());
 
     }
 
@@ -539,20 +542,20 @@
         if (Cools.isEmpty(wrkMast)){
             throw new CoolException(workNo+"宸ヤ綔妗d笉瀛樺湪");
         }
-        if(!wrkMast.getLocNo().contains("@") || !wrkMast.getSourceLocNo().contains("@")){
-            throw new CoolException("鐩爣搴撲綅鎴栬�呮簮搴撲綅鏆傛湭鍒嗛厤锛屾棤娉曞彇娑�");
-        }
+//        if(!wrkMast.getLocNo().contains("@") || !wrkMast.getSourceLocNo().contains("@")){
+//            throw new CoolException("鐩爣搴撲綅鎴栬�呮簮搴撲綅鏆傛湭鍒嗛厤锛屾棤娉曞彇娑�");
+//        }
         //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负205.宸ヤ綔瀹屾垚
         agvWrkMastService.updateWrkStsByWrkNo(wrkMast.getWrkNo(),205);
 
         //鍑哄簱浠诲姟 101.鍑哄簱 || 103.鎷f枡鍑哄簱 || 107.鐩樼偣鍑哄簱
         if(wrkMast.getIoType() == 101 || wrkMast.getIoType() == 103 || wrkMast.getIoType() == 107){
             //淇敼鍑哄簱绔欑偣鐘舵��
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(wrkMast.getLocNo(),"F",wrkMast.getBarcode());
+            agvBasDevpService.updateLocStsAndBarcodeByDevNo(wrkMast.getLocNo(),"F",wrkMast.getBarcode(),wrkMast.getWhsType().shortValue());
         }
         //鍑哄簱浠诲姟 110.绌烘澘鍑哄簱
         if(wrkMast.getIoType() == 110){
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(wrkMast.getLocNo(),"F",wrkMast.getBarcode());
+            agvBasDevpService.updateLocStsAndBarcodeByDevNo(wrkMast.getLocNo(),"F",wrkMast.getBarcode(),wrkMast.getWhsType().shortValue());
         }
 
     }
@@ -575,7 +578,7 @@
             //鐩爣搴撲綅
             String locNo = wrkMast.getLocNo();
             agvLocMastService.updateLocStsByLocNo(locNo,"O","",null);
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"F",wrkMast.getBarcode());
+            agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"F",wrkMast.getBarcode(),wrkMast.getWhsType().shortValue());
 
             //鍑哄簱鍙栨秷
         }else {
@@ -585,10 +588,22 @@
             String devNo = wrkMast.getLocNo();
             agvLocMastService.updateLocStsByLocNo(locNo,"F",wrkMast.getBarcode(),(short)getContainerTypeByloc(locNo));
             if(devNo.contains("@")){
-                agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"O","");
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"O","",null);
             }
         }
 
+        //淇濆瓨宸ヤ綔妗d互鍙婃槑缁�
+        agvWrkMastLogService.save(wrkMast);
+        agvWrkDetlLogService.save(wrkMast.getWrkNo());
+
+        //鍒犻櫎宸ヤ綔妗d互鍙婃槑缁�
+        if(!agvWrkMastService.deleteByWrkNo(wrkMast.getWrkNo()) || !agvWrkDetlService.deleteByWrkNo(wrkMast.getWrkNo())){
+            throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+
+        if(wrkMast.getIoType() == 1 || wrkMast.getIoType() == 10){
+            return;
+        }
 
         //璁㈠崟鍥炴粴
         //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
@@ -613,16 +628,6 @@
                 }
             }
         });
-
-
-        //淇濆瓨宸ヤ綔妗d互鍙婃槑缁�
-        agvWrkMastLogService.save(wrkMast);
-        agvWrkDetlLogService.save(wrkMast.getWrkNo());
-
-        //鍒犻櫎宸ヤ綔妗d互鍙婃槑缁�
-        if(!agvWrkMastService.deleteByWrkNo(wrkMast.getWrkNo()) || !agvWrkDetlService.deleteByWrkNo(wrkMast.getWrkNo())){
-            throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
-        }
 
     }
 
@@ -664,6 +669,15 @@
         }
     }
 
+    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType, String containerCode){
+        if(!Cools.isEmpty(agvBasDevp)){
+            agvBasDevp.setLocSts(locSts);
+            agvBasDevp.setLocType2(continerType);
+            agvBasDevp.setBarcode(containerCode);
+            agvBasDevpService.updateById(agvBasDevp);
+        }
+    }
+
     /*
     鐢熸垚宸ヤ綔妗f槑缁�
      */

--
Gitblit v1.9.1