From 175c7b88ae930b70daed62f8e7e7a6aea80486d7 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期五, 12 四月 2024 16:32:48 +0800
Subject: [PATCH] 取消任务时调用任务取消接口

---
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java |   43 ++++++++++++++++++++++---------------------
 1 files changed, 22 insertions(+), 21 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 fd7dd8e..1cf3101 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java
@@ -592,29 +592,31 @@
             }
         }
 
-        //璁㈠崟鍥炴粴
-        //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
-        List<AgvWrkDetl> agvWrkDetlList1 = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
-        agvWrkDetlList1.forEach(agvWrkDetl -> {
+        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 -> {
 
-            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());
+                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);
+                        }
+
+                    }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);
@@ -625,9 +627,8 @@
             throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�");
         }
 
-        if(wrkMast.getIoType() == 1 || wrkMast.getIoType() == 10){
-            return;
-        }
+        //璋冪敤agv鍙栨秷浠诲姟鎺ュ彛
+        agvWrkMastService.callCancelTask(wrkMast.getWrkNo());
 
     }
 

--
Gitblit v1.9.1