From ac6bb34756815cceea18ae27dbec3e404bcdf69b Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 13 九月 2024 14:01:35 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   22 +++++++++++-----------
 1 files changed, 11 insertions(+), 11 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 cef8ccb..06c933d 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -4045,16 +4045,16 @@
                             if (jsonObject.getInteger("code").equals(200)) {
                                 basDevp.setReportSign(1);
                                 basDevpService.updateById(basDevp);
-                                StartupDto dto = jsonObject.getObject("data", StartupDto.class);
-
-                                // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
-                                staProtocol.setWorkNo(dto.getWorkNo());
-                                staProtocol.setStaNo(607);
-                                devpThread.setPakMk(staProtocol.getSiteId(), false);
-                                boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol));
-                                if (!result) {
-                                    throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
-                                }
+//                                StartupDto dto = jsonObject.getObject("data", StartupDto.class);
+//
+//                                // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
+//                                staProtocol.setWorkNo(dto.getWorkNo());
+//                                staProtocol.setStaNo(607);
+//                                devpThread.setPakMk(staProtocol.getSiteId(), false);
+//                                boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol));
+//                                if (!result) {
+//                                    throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
+//                                }
                             } else {
                                 log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response);
                             }
@@ -8568,7 +8568,7 @@
                 if (!Cools.isEmpty(wrkMast)){
                     staProtocol607.setWorkNo(wrkMast.getWrkNo());
                     staProtocol607.setStaNo(staNo1);
-                    boolean result2 = MessageQueue.offer(SlaveType.Devp, 2, new Task(5, staProtocol607));
+                    boolean result2 = MessageQueue.offer(SlaveType.Devp, 2, new Task(2, staProtocol607));
                 }
             }
         } else {

--
Gitblit v1.9.1