From 16a3dbbf28606a90dd6dadeffe843f53f72d3955 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期五, 29 三月 2024 16:28:57 +0800
Subject: [PATCH] 初始化库位和站点

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   74 ++++++++++++++++++++++++++-----------
 1 files changed, 52 insertions(+), 22 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 2437e26..490ab06 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -91,7 +91,7 @@
             //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
             AgvLocMast agvLocMast = agvCommonService.getLocNo(agvBasDevp.getLocType1());
             //鐢熸垚宸ヤ綔妗�
-            AgvWrkMast wrkMast = createWrkMast(1,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),agvBasDevp.getBarcode(),now,userId, isConveyor);
+            AgvWrkMast wrkMast = createWrkMast(1,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),agvBasDevp.getBarcode(),now,userId, agvBasDevp.getLocType2());
             //鏍囪鏄惁涓鸿緭閫佺嚎鍏ュ簱
             wrkMast.setMk(isConveyor ? "Y" : "N");
             //鐢熸垚宸ヤ綔妗f槑缁�
@@ -134,7 +134,7 @@
             //鍒ゆ柇鏄惁鍏ㄦ澘鍑哄簱
             int ioType = isPakOut(sourceLocNo,taskDto) ?  101 : 103;
             //鐢熸垚宸ヤ綔妗�
-            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,containerCode,now,userId,false);
+            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,containerCode,now,userId,0);
             //鐢熸垚宸ヤ綔妗f槑缁�
             taskDto.getLocDtos().forEach(locDto -> {
                 if (!BaseController.isJSON(locDto.getOrderNo())) {
@@ -258,8 +258,10 @@
                 return;
             }
 
+            int containerType = getContainerTypeByloc(taskDto.getLocNo());
+
             //鐢熸垚宸ヤ綔妗�
-            AgvWrkMast wrkMast = createWrkMast(107, 21L,taskDto.getLocNo(),taskDto.getAgvStaNo(),taskDto.getLocDtos().get(0).getContainerCode(),now,userId,false);
+            AgvWrkMast wrkMast = createWrkMast(107, 21L,taskDto.getLocNo(),taskDto.getAgvStaNo(),taskDto.getLocDtos().get(0).getContainerCode(),now,userId,containerType);
             //鐢熸垚宸ヤ綔妗f槑缁�
             taskDto.getLocDtos().forEach(locDto -> {
                 //鏄庣粏妗f墍闇�鍙傛暟
@@ -299,8 +301,9 @@
         }
 
         Date now = new Date();
+
         //鐢熸垚绉诲簱宸ヤ綔妗�
-        AgvWrkMast wrkMast = createWrkMast(11, 21L, sourceLocNo, targetLocNo, sourceLocDetl.getSuppCode(), now, userId,false);
+        AgvWrkMast wrkMast = createWrkMast(11, 21L, sourceLocNo, targetLocNo, sourceLocDetl.getSuppCode(), now, userId,getContainerTypeByloc(sourceLocNo));
         //鐢熸垚宸ヤ綔鍏氭槑缁�
         createWrkDetlReWrite(sourceLocDetl.getMatnr(),wrkMast.getWrkNo(),null,sourceLocDetl.getBatch(),sourceLocDetl.getAnfme(),sourceLocDetl.getZpallet(),now,userId,sourceLocDetl.getThreeCode(),sourceLocDetl.getDeadTime());
         //淇敼鐩爣搴撲綅鐘舵��
@@ -313,7 +316,7 @@
     鍏ュ簱
      */
     @Transactional
-    public String emptyPlateIn(String station,String containerCode,int containerType, Long userId) {
+    public String emptyPlateIn(String station,String containerCode,Short containerType, Long userId) {
 
         Date now = new Date();
         // 婧愮珯鐐圭姸鎬佹娴�
@@ -338,28 +341,35 @@
         }
 
         //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
-        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, false);
+            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());
             });
             //淇敼鍏ュ簱閫氱煡妗g姸鎬�
             agvWaitPakinService.updateIoStatus(containerCode,"Y");
+            //鏇存柊婧愮珯鐐圭姸鎬�
+            updateAgvBasDevp(agvBasDevp,"R");
         }else {
             // 鐢熸垚宸ヤ綔妗� 10.绌烘澘鍏ュ簱
-            createWrkMast(10,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),containerCode,now,userId,false);
+            createWrkMast(10,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),containerCode,now,userId,containerType);
+            //鏇存柊婧愮珯鐐圭姸鎬�
+            updateAgvBasDevp(agvBasDevp,"R",containerType);
         }
 
-        //鏇存柊婧愮珯鐐圭姸鎬�
-        updateAgvBasDevp(agvBasDevp,"R");
         //鏇存柊鐩爣搴撲綅鐘舵�佸拰淇℃伅
-        updateAgvLocMast(agvLocMast,"S", (short) containerType);
+        updateAgvLocMast(agvLocMast,"S");
         return agvLocMast.getLocNo();
     }
 
@@ -378,9 +388,11 @@
 
         //瀵绘壘鐩稿簲绫诲瀷鐨勭┖鎵樼洏
         AgvLocMast agvLocMast = agvLocMastService.selectEmptyZpallet(containerType);
-
+        if (Cools.isEmpty(agvLocMast)) {
+            throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖鎵樼洏锛�");
+        }
         //鐢熸垚宸ヤ綔妗�
-        createWrkMast(110,21L,agvLocMast.getLocNo(),agvBasDevp.getDevNo(),agvLocMast.getBarcode(),now,userId,false);
+        createWrkMast(110,21L,agvLocMast.getLocNo(),agvBasDevp.getDevNo(),agvLocMast.getBarcode(),now,userId,containerType);
 
         //淇敼婧愬簱浣嶇姸鎬�
         updateAgvLocMast(agvLocMast,"R");
@@ -541,11 +553,11 @@
         //鍑哄簱浠诲姟 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());
         }
 
     }
@@ -567,8 +579,8 @@
             String devNo = wrkMast.getSourceLocNo();
             //鐩爣搴撲綅
             String locNo = wrkMast.getLocNo();
-            agvLocMastService.updateLocStsByLocNo(locNo,"O","");
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"F",wrkMast.getBarcode());
+            agvLocMastService.updateLocStsByLocNo(locNo,"O","",null);
+            agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"F",wrkMast.getBarcode(),wrkMast.getWhsType().shortValue());
 
             //鍑哄簱鍙栨秷
         }else {
@@ -576,9 +588,9 @@
             String locNo = wrkMast.getSourceLocNo();
             //鐩爣绔欑偣
             String devNo = wrkMast.getLocNo();
-            agvLocMastService.updateLocStsByLocNo(locNo,"F",wrkMast.getBarcode());
+            agvLocMastService.updateLocStsByLocNo(locNo,"F",wrkMast.getBarcode(),(short)getContainerTypeByloc(locNo));
             if(devNo.contains("@")){
-                agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"O","");
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(devNo,"O","",null);
             }
         }
 
@@ -647,6 +659,17 @@
     }
 
     /*
+    鏇存柊婧愮珯鐐逛俊鎭拰搴撲綅鎵樼洏绫诲瀷
+     */
+    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType){
+        if(!Cools.isEmpty(agvBasDevp)){
+            agvBasDevp.setLocSts(locSts);
+            agvBasDevp.setLocType2(continerType);
+            agvBasDevpService.updateById(agvBasDevp);
+        }
+    }
+
+    /*
     鐢熸垚宸ヤ綔妗f槑缁�
      */
     private void createWrkDetlReWrite(String matnr, int wrkNo, String orderNo,String batch, double anfme, String zpallet, Date now, Long userId, String csocode, String isoseq){
@@ -706,7 +729,7 @@
     /*
     鐢熸垚宸ヤ綔妗�
      */
-    private AgvWrkMast createWrkMast(int ioType, long wrkSts, String sourceLocNo, String locNo, String barcode,  Date now, Long userId, boolean isConveyor){
+    private AgvWrkMast createWrkMast(int ioType, long wrkSts, String sourceLocNo, String locNo, String barcode,  Date now, Long userId, int containerType){
         AgvWrkMast wrkMast = new AgvWrkMast();
         //宸ヤ綔鐘舵��
         wrkMast.setWrkSts(wrkSts);
@@ -721,8 +744,9 @@
         wrkMast.setLocNo(locNo);
         //瀹瑰櫒缂栫爜
         wrkMast.setBarcode(barcode);
-        //鏍囪鏄惁涓鸿緭閫佺嚎鍏ュ簱
-        wrkMast.setMk(isConveyor ? "Y" : "N");
+        //瀹瑰櫒绫诲瀷
+        wrkMast.setWhsType(containerType);
+
         wrkMast.setAppeUser(userId);
         wrkMast.setAppeTime(now);
         wrkMast.setModiUser(userId);
@@ -811,4 +835,10 @@
         }
     }
 
+    private int getContainerTypeByloc(String locNo){
+
+        return agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no",locNo)).getLocType2();
+
+    }
+
 }

--
Gitblit v1.9.1