From 13bdad370f0b35b68f79a75f8183a23135e45225 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期二, 15 七月 2025 17:03:10 +0800
Subject: [PATCH] 1

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   47 ++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 40 insertions(+), 7 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 281169d..614b63a 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -495,6 +495,10 @@
         if (Cools.isEmpty(agvBasDevp)) {
             throw new CoolException("鏆傛棤" + station + "绔欑偣");
         }
+        AgvBasDevp agvBasDevp2 = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>().eq("barcode", containerCode).ne("dev_no", agvBasDevp.getDevNo()));
+        if (!Cools.isEmpty(agvBasDevp2)) {
+            throw new CoolException(station + "绔欑偣缁戝畾璇ヨ揣鏋讹紝鏃犳硶鍏ュ簱");
+        }
         int br = 0;
         if (containerType == 21 && agvBasDevp.getFloor() == 2) {
             containerType = 20;
@@ -645,6 +649,15 @@
         if (Cools.isEmpty(agvBasDevp)) {
             throw new CoolException("鏆傛棤" + station + "绔欑偣");
         }
+
+        AgvBasDevp agvBasDevp2 = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>().eq("barcode", containerCode).ne("dev_no", agvBasDevp.getDevNo()));
+        if (!Cools.isEmpty(agvBasDevp2)) {
+            throw new CoolException(station + "绔欑偣缁戝畾璇ヨ揣鏋讹紝鏃犳硶鍏ュ簱");
+        }
+        if (Cools.isEmpty(agvBasDevp)) {
+            throw new CoolException("鏆傛棤" + station + "绔欑偣");
+        }
+
         int br = 0;
         if (containerType == 21 && agvBasDevp.getFloor() == 2) {
             containerType = 20;
@@ -800,6 +813,10 @@
         AgvBasDevp agvBasDevp = agvBasDevpService.selectById(station);
         if (Cools.isEmpty(agvBasDevp)) {
             throw new CoolException("鏆傛棤" + station + "绔欑偣");
+        }
+        AgvBasDevp agvBasDevp2 = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>().eq("barcode", containerCode).ne("dev_no", agvBasDevp.getDevNo()));
+        if (!Cools.isEmpty(agvBasDevp2)) {
+            throw new CoolException(station + "绔欑偣缁戝畾璇ヨ揣鏋讹紝鏃犳硶鍏ュ簱");
         }
         int br = 0;
         if (containerType == 21 && agvBasDevp.getFloor() == 2) {
@@ -982,6 +999,17 @@
         if (Cools.isEmpty(agvLocMast)) {
             throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖璐ф灦锛�");
         }
+        if (!Cools.isEmpty(agvBasDevp.getArea())) {
+            if (!Cools.isEmpty(agvLocMast.getBarcode())) {
+                if (!agvBasDevp.getArea().contains(agvLocMast.getBarcode().substring(0, 2))) {
+                    throw new CoolException("1褰撳墠鍑哄簱绔欑偣涓嶅厑璁稿彨璇ョ被鍨嬬殑璐ф灦锛�" + agvLocMast.getBarcode());
+                }
+            }else {
+                if (!agvBasDevp.getArea().contains(agvLocMast.getLocType1$().toString())) {
+                    throw new CoolException("2褰撳墠鍑哄簱绔欑偣涓嶅厑璁稿彨璇ョ被鍨嬬殑璐ф灦锛�" + agvLocMast.getBarcode());
+                }
+            }
+        }
         //鐢熸垚宸ヤ綔妗�
         createWrkMast(110, 21L, agvLocMast.getLocNo(), agvBasDevp.getDevNo(), agvLocMast.getBarcode(), now, userId, containerType, agvLocMast.getPltType());
 
@@ -992,6 +1020,7 @@
         updateAgvBasDevp(agvBasDevp, "S", (short) containerType, agvLocMast.getBarcode());
 
     }
+
 
     @Transactional
     public void adjustLocDetl(LocDetlAdjustParam param, Long userId) {
@@ -1390,12 +1419,12 @@
                         if (!orderDetlService.update(orderDetl, new EntityWrapper<OrderDetl>().eq("order_no", "DB" + agvLocDetl.getOrderNo()).eq("matnr", agvLocDetl.getMatnr()).eq("three_code", agvLocDetl.getThreeCode()))) {
                             throw new CoolException("淇敼璁㈠崟鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�" + agvLocDetl.getOrderNo() + agvLocDetl.getMatnr());
                         }
-                    }else {
-                        orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("matnr", agvLocDetl.getMatnr()).eq("three_code", agvLocDetl.getThreeCode()).ge("qty",agvLocDetl.getAnfme()));
+                    } else {
+                        orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("matnr", agvLocDetl.getMatnr()).eq("three_code", agvLocDetl.getThreeCode()).eq("source", 33).ge("qty", agvLocDetl.getAnfme()));
                         if (orderDetl != null) {
                             orderDetl.setQty(orderDetl.getQty() - agvLocDetl.getAnfme());
-                            if (!orderDetlService.update(orderDetl, new EntityWrapper<OrderDetl>().eq("order_no", "DB" + agvLocDetl.getOrderNo()).eq("matnr", agvLocDetl.getMatnr()).eq("three_code", agvLocDetl.getThreeCode()))) {
-                                throw new CoolException("淇敼璁㈠崟鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�" + agvLocDetl.getOrderNo() + agvLocDetl.getMatnr());
+                            if (!orderDetlService.update(orderDetl, new EntityWrapper<OrderDetl>().eq("order_no", orderDetl.getOrderNo()).eq("matnr", agvLocDetl.getMatnr()).eq("three_code", agvLocDetl.getThreeCode()))) {
+                                //throw new CoolException("淇敼璁㈠崟鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�" + agvLocDetl.getOrderNo() + agvLocDetl.getMatnr());
                             }
                         }
                     }
@@ -1538,9 +1567,13 @@
                 throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
 
-            if (type == 2) {
-                //璋冪敤agv鍙栨秷浠诲姟鎺ュ彛
-                agvWrkMastService.callCancelTask(wrkMast.getWrkNo());
+            if (type == 2 || type == 5) {
+                try {
+                    //璋冪敤agv鍙栨秷浠诲姟鎺ュ彛
+                    agvWrkMastService.callCancelTask(wrkMast.getWrkNo());
+                } catch (Exception e) {
+                    log.info("璋冪敤agv鍙栨秷浠诲姟鎺ュ彛澶辫触");
+                }
             }
         }
     }

--
Gitblit v1.9.1