From 8a0fd387f5986e66400d9756a9678a4982ae837c Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期三, 07 五月 2025 14:35:56 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   14 ++++++++------
 1 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 775d5fc..09ccf85 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -510,6 +510,7 @@
                                         } else {
                                             staProtocol.setWorkNo(taskWrk1.getWrkNo());
                                             staProtocol.setStaNo(staDesc.getCrnStn());
+                                            devpThread.setPakMkWalk(staProtocol.getSiteId(), false);
                                             MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                         }
                                     }
@@ -517,7 +518,7 @@
                                 }
                             }
                         } else {
-                            TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>());
+                            TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("IO_TYPE",1).eq("WRK_STS",1).eq("START_POINT",staProtocol.getSiteId().toString()));
 
                             if (!Cools.isEmpty(taskWrk1)) {
                                 if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) {
@@ -529,6 +530,7 @@
                                     } else {
                                         staProtocol.setWorkNo(taskWrk1.getWrkNo());
                                         staProtocol.setStaNo(staDesc.getCrnStn());
+                                        devpThread.setPakMkWalk(staProtocol.getSiteId(), false);
                                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                     }
                                 }
@@ -605,7 +607,7 @@
                             if (offer) {
                                 log.info("涓嬪彂杈撻�佺嚎浠诲姟鎴愬姛锛歵askWrk:" + JSON.toJSONString(taskWrk));
                                 Date now = new Date();
-                                taskWrk.setStatus(5);
+                                taskWrk.setStatus(9);
                                 taskWrk.setWrkSts(14);
                                 taskWrk.setModiTime(now);
                                 taskWrk.setCompleteTime(now);
@@ -797,7 +799,7 @@
                         HashMap<String, Object> headParam = new HashMap<>();
                         headParam.put("taskNo", taskWrk.getTaskNo());
                         headParam.put("status", taskWrk.getStatus());
-                        headParam.put("ioType", taskWrk.getIoType());
+                        headParam.put("ioType", taskWrk.getIoTypeWms());
                         headParam.put("barcode", taskWrk.getBarcode());
                         String response;
                         response = new HttpHandler.Builder()
@@ -917,7 +919,7 @@
                                 HashMap<String, Object> headParam = new HashMap<>();
                                 headParam.put("taskNo", taskWrk.getTaskNo());
                                 headParam.put("status", taskWrk.getStatus());
-                                headParam.put("ioType", taskWrk.getIoType());
+                                headParam.put("ioType", taskWrk.getIoTypeWms());
                                 headParam.put("barcode", taskWrk.getBarcode());
                                 String response;
                                 response = new HttpHandler.Builder()
@@ -1021,7 +1023,7 @@
                         HashMap<String, Object> headParam = new HashMap<>();
                         headParam.put("taskNo", taskWrk.getTaskNo());
                         headParam.put("status", taskWrk.getStatus());
-                        headParam.put("ioType", taskWrk.getIoType());
+                        headParam.put("ioType", taskWrk.getIoTypeWms());
                         headParam.put("barcode", taskWrk.getBarcode());
                         String response;
                         response = new HttpHandler.Builder()
@@ -1135,7 +1137,7 @@
                         HashMap<String, Object> headParam = new HashMap<>();
                         headParam.put("taskNo", taskWrk.getTaskNo());
                         headParam.put("status", taskWrk.getStatus());
-                        headParam.put("ioType", taskWrk.getIoType());
+                        headParam.put("ioType", taskWrk.getIoTypeWms());
                         headParam.put("barcode", taskWrk.getBarcode());
                         String response;
                         log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", headParam);

--
Gitblit v1.9.1