From 071f3021f4ba872c572a4c59dd8ce9ea2d3c9106 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期二, 23 四月 2024 18:50:37 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   79 ++++++++++++++++++++++-----------------
 1 files changed, 45 insertions(+), 34 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 f49c996..2d5de68 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -316,27 +316,19 @@
     鍏ュ簱
      */
     @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("褰撳墠瀹瑰櫒宸叉湁鍏ュ簱浠诲姟锛屾棤娉曡繘琛屽叆搴�");
         }
 
@@ -360,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);
         }
 
         //鏇存柊鐩爣搴撲綅鐘舵�佸拰淇℃伅
@@ -388,6 +380,12 @@
 
         //瀵绘壘鐩稿簲绫诲瀷鐨勭┖鎵樼洏
         AgvLocMast agvLocMast = agvLocMastService.selectEmptyZpallet(containerType);
+        if(containerType == 0){
+            //绌烘澘鑷姩鍑哄簱锛屾牴鎹珯鐐圭被鍨嬮�夋嫨
+            agvLocMastService.selectEmptyZpalletByLocType1(agvBasDevp.getLocType1());
+
+        }
+
         if (Cools.isEmpty(agvLocMast)) {
             throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖鎵樼洏锛�");
         }
@@ -398,7 +396,7 @@
         updateAgvLocMast(agvLocMast,"R");
 
         //淇敼绔欑偣鐘舵��
-        updateAgvBasDevp(agvBasDevp,"S");
+        updateAgvBasDevp(agvBasDevp,"S",(short)containerType,agvLocMast.getBarcode());
 
     }
 
@@ -494,6 +492,7 @@
             locDetl.setModiTime(now);
             locDetl.setAppeUser(userId);
             locDetl.setAppeTime(now);
+            locDetl.setOrderNo(adjust.getOrderNo());
             locDetl.setThreeCode(adjust.getThreeCode());
             locDetl.setDeadTime(adjust.getDeadTime());
             locDetl.setSuppCode(adjust.getSuppCode());
@@ -594,31 +593,31 @@
             }
         }
 
+        if(wrkMast.getIoType() != 1 && wrkMast.getIoType() != 10){
+            //璁㈠崟鍥炴粴
+            //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
+            List<AgvWrkDetl> agvWrkDetlList1 = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
+            agvWrkDetlList1.forEach(agvWrkDetl -> {
 
-        //璁㈠崟鍥炴粴
-        //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
-        List<AgvWrkDetl> agvWrkDetlList1 = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
-        agvWrkDetlList1.forEach(agvWrkDetl -> {
+                if(!Cools.isEmpty(agvWrkDetl.getOrderNo())){
+                    String orderNo = agvWrkDetl.getOrderNo();
+                    if(orderNo.contains("{")){
+                        JSONArray orderArray = JSON.parseArray(orderNo);
+                        for (Object o : orderArray){
+                            JSONObject jsonobject = (JSONObject) o;
+                            OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(jsonobject.get("orderNo").toString(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime());
+                            orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme());
+                            orderDetlService.updateById(orderDetl);
+                        }
 
-            if(!Cools.isEmpty(agvWrkDetl.getOrderNo())){
-                String orderNo = agvWrkDetl.getOrderNo();
-                if(orderNo.contains("{")){
-                    JSONArray orderArray = JSON.parseArray(orderNo);
-                    for (Object o : orderArray){
-                        JSONObject jsonobject = (JSONObject) o;
-                        OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(jsonobject.get("orderNo").toString(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime());
+                    }else {
+                        OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(agvWrkDetl.getOrderNo(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime());
                         orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme());
                         orderDetlService.updateById(orderDetl);
                     }
-
-                }else {
-                    OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(agvWrkDetl.getOrderNo(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime());
-                    orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme());
-                    orderDetlService.updateById(orderDetl);
                 }
-            }
-        });
-
+            });
+        }
 
         //淇濆瓨宸ヤ綔妗d互鍙婃槑缁�
         agvWrkMastLogService.save(wrkMast);
@@ -628,6 +627,9 @@
         if(!agvWrkMastService.deleteByWrkNo(wrkMast.getWrkNo()) || !agvWrkDetlService.deleteByWrkNo(wrkMast.getWrkNo())){
             throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
         }
+
+        //璋冪敤agv鍙栨秷浠诲姟鎺ュ彛
+        agvWrkMastService.callCancelTask(wrkMast.getWrkNo());
 
     }
 
@@ -669,6 +671,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