From 60201c8530488c402b8b44b215b8d48c60d6679a Mon Sep 17 00:00:00 2001 From: cpT <1@123> Date: 星期四, 19 六月 2025 19:43:21 +0800 Subject: [PATCH] #改造 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 27 +++------------------------ 1 files changed, 3 insertions(+), 24 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 ff462b8..bf37cde 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -516,7 +516,7 @@ log.error("{}鍙稲GV灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", rgvSlave.getId()); continue; } - if (rgvProtocol.getStatusType() == RgvStatusType.WAITING || rgvProtocol.getStatusType() == RgvStatusType.WAITING101) { + if (rgvProtocol.getStatusType() == RgvStatusType.WAITING) { log.info("{}鍙峰皬杞︾瓑寰厀cs纭锛岀姸鎬亄}锛屽弬鏁皗}", rgvProtocol.getRgvNo(), rgvProtocol.getStatusType(), rgvProtocol); } // 鍙湁褰揜GV绛夊緟WCS纭銆佽嚜鍔� @@ -577,15 +577,6 @@ } } catch (Exception e){} wrkMastService.updateById(wrkMast); - } else if (rgvProtocol.getStatusType() == RgvStatusType.WAITING101 - && rgvProtocol.getModeType() == RgvModeType.AUTO - && rgvProtocol.getTaskNo1() != 0 - ){ - boolean rgvComplete = rgvComplete(rgvProtocol.getRgvNo()); - if (!rgvComplete) { - log.error("灏忚溅澶嶄綅澶辫触锛屽皬杞﹀彿{}锛�", rgvProtocol.getRgvNo()); - break; - } } } catch (Exception e) { log.error("灏忚溅澶嶄綅绾跨▼鎶ラ敊锛�" + e); @@ -610,20 +601,9 @@ ) { RgvCommand rgvCommand = new RgvCommand(); - rgvCommand.setRgvNo(rgvProtocol.getRgvNo()); - rgvCommand.setAckFinish1((short) 0); // 宸ヤ綅1浠诲姟瀹屾垚纭浣� - rgvCommand.setTaskNo1(rgvProtocol.getTaskNo1()); - rgvCommand.setTaskMode1(RgvTaskModeType.CANCEL); // 宸ヤ綅1浠诲姟妯″紡: 鍙栨秷 - rgvCommand.setSourceStaNo1((short)-1); //宸ヤ綅1璧风偣 - rgvCommand.setDestinationStaNo1((short)-1); //宸ヤ綅1鐩爣绔欑偣 - rgvCommand.setCommand((short) 1); //宸ヤ綅1浠诲姟纭 - rgvCommand.setRgvSome((short) 1); - if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(4, rgvCommand))) { + if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(6, rgvCommand))) { // log.error("RGV鍙栨秷鍛戒护涓嬪彂澶辫触锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvProtocol.getRgvNo(), JSON.toJSON(rgvCommand)); -// wrkMast.setLogErrTime(new Date()); -// wrkMast.setLogErrMemo("RGV鍙栨秷鍛戒护涓嬪彂澶辫触锛孯GV鍙�={"+rgvProtocol.getRgvNo()+"}===>璺宠繃"); -// wrkMastService.updateById(wrkMast); continue; } log.info("RGV鍙栨秷鍛戒护涓嬪彂鎴愬姛锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvProtocol.getRgvNo(), JSON.toJSON(rgvCommand)); @@ -636,10 +616,9 @@ Date now = new Date(); wrkMast.setWrkSts(1L); - wrkMast.setRgvNo(null); + wrkMast.setRgvNo(0); wrkMast.setAppeTime(now); wrkMast.setLogErrTime(now); - wrkMast.setRgvNo(null); wrkMast.setLogErrMemo("RGV鐢宠鍙栨秷浠诲姟锛孯GV鍙�={"+rgvProtocol.getRgvNo()+"}锛屽彇娑堟椂闂达細"+now); -- Gitblit v1.9.1