From b187814d7cfa5ace1ed9c203372524c69fe56553 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期三, 31 十二月 2025 08:11:44 +0800
Subject: [PATCH] 1.完善AGV任务任务下发 2.拣料回库数据更新维护

---
 src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java |  103 ++++++++++++++++-----------------------------------
 1 files changed, 33 insertions(+), 70 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
index 4ca46f5..1bfc8b4 100644
--- a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
@@ -239,7 +239,6 @@
             newMemo.put("itemdata", list);
 
 
-
             // 鐢熸垚璁㈠崟
             OrderPakin orderPakin = new OrderPakin();
             orderPakin.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
@@ -260,8 +259,8 @@
 
                     // 鐢熸垚鏄庣粏
                     Mat mat = matService.selectByMatnr(mesMatInfo.getItemNo());
-                    if(Cools.isEmpty(mat)){
-                        log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�="+mesMatInfo.getItemNo());
+                    if (Cools.isEmpty(mat)) {
+                        log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�=" + mesMatInfo.getItemNo());
                         continue;
                     }
                     OrderDetlPakin orderDetlPakin = new OrderDetlPakin();
@@ -1004,9 +1003,9 @@
             }
 
             //鏈夊灏戠涓嶅悓鐨勯厤鐩樺彿   鍙湁閰嶇洏鍑哄簱鍗曢渶瑕佺煡閬�
-            if (mesCallOutApply.getTransType().equals("閰嶇洏鍑哄簱鍗�")){
+            if (mesCallOutApply.getTransType().equals("閰嶇洏鍑哄簱鍗�")) {
                 orderPakout.setPayType(set.size());
-                String shipCode =mesCallOutApply.getItemdata().get(0).getTrayid().split("-")[2];
+                String shipCode = mesCallOutApply.getItemdata().get(0).getTrayid().split("-")[2];
                 orderPakout.setShipCode(shipCode);//鍖哄煙  鏄惁鏄壒娈婃墭鐩�
                 orderPakoutService.updateById(orderPakout);
             }
@@ -1040,11 +1039,11 @@
             orderPakin.setPakinPakoutStatus(1);
             orderPakinService.insert(orderPakin);
             if (mesCallOutApply.getItemdata() != null && !mesCallOutApply.getItemdata().isEmpty()) {
-                for (MesCallOutApply.MesOutApplyItem mesOutApplyItem : mesCallOutApply.getItemdata()){
+                for (MesCallOutApply.MesOutApplyItem mesOutApplyItem : mesCallOutApply.getItemdata()) {
                     // 鐢熸垚鏄庣粏
                     Mat mat = matService.selectByMatnr(mesOutApplyItem.getItemno());
-                    if(Cools.isEmpty(mat)){
-                        log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�="+mesOutApplyItem.getItemno());
+                    if (Cools.isEmpty(mat)) {
+                        log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�=" + mesOutApplyItem.getItemno());
                         continue;
                     }
                     OrderDetlPakin orderDetlPakin = new OrderDetlPakin();
@@ -1105,73 +1104,37 @@
             return result;
         }
 
-        // 涓嬪彂缁橰CS
-        RcsTaskSubmit rcsTaskSubmit = new RcsTaskSubmit();
-        rcsTaskSubmit.setRobotTaskCode(transTask.getTaskno());
-        rcsTaskSubmit.setInitPriority(10);  //榛樿10
-        List<RcsTaskTargetRoute> targetRouteList = new ArrayList<>();
-        RcsTaskTargetRoute startRoute = new RcsTaskTargetRoute();
-        startRoute.setSeq(0);
-        startRoute.setCode(transTask.getCurStationId());
-        startRoute.setOperation("COLLECT");
-        targetRouteList.add(startRoute);
-        RcsTaskTargetRoute endRoute = new RcsTaskTargetRoute();
-        endRoute.setSeq(1);
-        endRoute.setCode(transTask.getNextStationId());
-        endRoute.setOperation("DELIVERY");
-        targetRouteList.add(endRoute);
-        rcsTaskSubmit.setTargetRoute(targetRouteList);
+        int workNo = commonService.getWorkNo(WorkNoType.OTHER.type);
+        Date now = new Date();
+        Task task = new Task();
+        task.setWrkNo(workNo);
+        task.setTaskType("ZX-AGV");
+        task.setWrkSts(301L);//301.AGV浠诲姟鍒涘缓
+        task.setIoType(3);//3.绔欏埌绔�
+        task.setIoPri(10.00);
+        task.setWrkDate(now);
+        task.setBarcode(transTask.getBarcode());
+        task.setSourceStaNo(transTask.getCurStationId());
+        task.setStaNo(transTask.getNextStationId());
+        task.setBarcode(transTask.getTuoPanId());
+        task.setModiUser(defaultUserId);
+        task.setModiTime(now);
+        task.setAppeUser(defaultUserId);
+        task.setAppeTime(now);
+        task.setTaskNo(transTask.getTaskno());
+        task.setMemo(JSONObject.toJSONString(transTask));
+        task.setPltType(transTask.getAgvFactory());//鍗庢檽AGV
+        task.setPacked(transTask.getRackNumber());//鏂欐灦鍙�
+        task.setCtnType(1);
 
-        // 杞彂缁欐捣搴锋垨鍗庢檽RCS
-        int success = rcsService.submitTask(rcsTaskSubmit, transTask.getAgvFactory());
-        if (success == 1) {
-            int workNo = commonService.getWorkNo(WorkNoType.OTHER.type);
-            Date now = new Date();
-            Task task = new Task();
-            task.setWrkNo(workNo);
-            task.setTaskType("ZX-AGV");
-            task.setWrkSts(302L);//302.AGV浠诲姟鎵ц涓�
-            task.setIoType(3);//3.绔欏埌绔�
-            task.setIoPri(10.00);
-            task.setWrkDate(now);
-            task.setBarcode(transTask.getBarcode());
-            task.setSourceStaNo(transTask.getCurStationId());
-            task.setStaNo(transTask.getNextStationId());
-            task.setBarcode(transTask.getTuoPanId());
-            task.setModiUser(defaultUserId);
-            task.setModiTime(now);
-            task.setAppeUser(defaultUserId);
-            task.setAppeTime(now);
-            task.setTaskNo(transTask.getTaskno());
-            task.setMemo(JSONObject.toJSONString(transTask));
-            task.setPltType(transTask.getAgvFactory());//鍗庢檽AGV
-            task.setPacked(transTask.getRackNumber());//鏂欐灦鍙�
+        if (taskService.insert(task)) {
+                result.put("Success", "1");
+                result.put("Message", "浠诲姟鎺ユ敹鎴愬姛");
 
-            taskService.insert(task);
-//            Mat mat = matService.selectByMatnr(transTask.getItemno());
-//            TaskDetl taskDetl = new TaskDetl();
-//            taskDetl.setWrkNo(task.getWrkNo());
-//            taskDetl.setIoTime(task.getIoTime());
-//            taskDetl.setMatnr(transTask.getItemno());
-//            taskDetl.setAnfme(0.0);
-//            taskDetl.setStandby1(String.valueOf(transTask.getQty()));
-//            taskDetl.setMaktx(mat.getMaktx());
-//            taskDetl.setSpecs(mat.getSpecs());
-//            taskDetl.setOrderNo(transTask.getOrderNo());
-//            taskDetl.setZpallet(transTask.getTuoPanId());
-//            taskDetl.setMemo(JSONObject.toJSONString(transTask.getItemBarcode()));
-//            taskDetl.setModiUser(defaultUserId);
-//            taskDetl.setModiTime(now);
-//            taskDetl.setAppeUser(defaultUserId);
-//            taskDetl.setAppeTime(now);
-//            taskDetlService.insert(taskDetl);
-            result.put("Success", "1");
-            result.put("Message", "浠诲姟鎺ユ敹鎴愬姛");
-        } else {
+        }else {
             result.put("Success", "2");
             result.put("Message", "浠诲姟涓嬪彂缁橰CS澶辫触");
         }
-
         return result;
     }
 

--
Gitblit v1.9.1