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