From c422d0d7da0d26f39cd40f9070311ffbb2f9c009 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <xltys1995> Date: 星期四, 27 八月 2020 18:32:03 +0800 Subject: [PATCH] #v2.0 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 13 +++++++++---- 1 files changed, 9 insertions(+), 4 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 5487306..240840c 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -543,6 +543,8 @@ // 鍑哄簱 + 鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓細12.鍚婅溅鍑哄簱涓� ==> 14.鍑哄簱瀹屾垚 } else if (wrkMast.getWrkSts() == 12) { wrkMast.setWrkSts(14L); + } else { + continue; } Date now = new Date(); wrkMast.setCrnEndTime(now); @@ -550,9 +552,11 @@ // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 if (wrkMastMapper.updateById(wrkMast) > 0) { // 鍛戒护涓嬪彂鍖� ------------------------------------------------------------------------- - // 鍫嗗灈鏈哄浣� - if (!MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(3, new CrnCommand()))) { - log.error("鍫嗗灈鏈哄浣嶅懡浠や笅鍙戝け璐ワ紝宸ヤ綔鍙�={}", wrkMast.getWrkNo()); + if (crnProtocol.getStatusType().equals(CrnStatusType.WAITING)) { + // 鍫嗗灈鏈哄浣� + if (!MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(3, new CrnCommand()))) { + log.error("鍫嗗灈鏈哄浣嶅懡浠や笅鍙戝け璐ワ紝宸ヤ綔鍙�={}", wrkMast.getWrkNo()); + } } } @@ -587,7 +591,7 @@ DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); StaProtocol staProtocol = devpThread.getStation().get(emptyInSta.getStaNo()); // 绔欑偣鏉′欢鍒ゆ柇 - if (staProtocol.isAutoing() && staProtocol.isLoading() && !staProtocol.isInreq1() + if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 0 && staProtocol.isPakMk()) { // 宸ヤ綔鍙� int workNo = commonService.getWorkNo(0); @@ -637,6 +641,7 @@ throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触"); } + staProtocol.setPakMk(false); } -- Gitblit v1.9.1