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