From 7225bce9f6e79f4c6ac4ea592b644a6447f81c2e Mon Sep 17 00:00:00 2001
From: zhangchao <zc857179121@qq.com>
Date: 星期一, 02 九月 2024 22:04:04 +0800
Subject: [PATCH] 对照协议调整

---
 src/main/java/com/zy/core/thread/SiemensCrnThread.java      |    7 +++----
 src/main/java/com/zy/core/enums/CrnStatusType.java          |    4 +++-
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   37 +++++++++++++++++++++++--------------
 src/main/java/com/zy/core/thread/MelsecCrnThread.java       |    2 +-
 4 files changed, 30 insertions(+), 20 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 88f77ec..ed10d1a 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -189,9 +189,8 @@
                 if (!staProtocol.isLoading()) {
                     continue;
                 }
-                System.out.println(staProtocol);
                 if (staProtocol.isAutoing() && staProtocol.isInEnable()
-                        && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() > 0 && staProtocol.getWorkNo() < 6001)
+                        && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() > 9990)
                         && staProtocol.isPakMk() && staProtocol.getStamp() >= 2 && staProtocol.getStamp() != 3) {// && !Cools.isEmpty(barcode)) {
                     News.warn("" + mark + " - 0" + " - 寮�濮嬫墽琛�");
 
@@ -636,10 +635,17 @@
                         // 绉诲姩涓�
                         continue;
                     }
+                    CrnStatusType statusType = crnProtocol.getStatusType();
+                    CrnStatusType statusTypeTwo = crnProtocol.getStatusTypeTwo();
+                    Boolean wait = false;
+                    if (statusType == CrnStatusType.WAITING_ONE || statusTypeTwo == CrnStatusType.WAITING_TWO || (statusType == CrnStatusType.WAITING_All && statusTypeTwo == CrnStatusType.WAITING_All)) {
+                        wait = true;
+                    }
                     //  鍒ゆ柇鍫嗗灈鏈虹姸鎬佺瓑寰呯‘璁�
                     if (crnProtocol.modeType == CrnModeType.AUTO && crnProtocol.getTaskNo().equals(wrkMast.getWrkNo().shortValue())
-                            && crnProtocol.statusType == CrnStatusType.WAITING
+                            && wait
                             && crnProtocol.forkPosType == CrnForkPosType.HOME) {
+
                         News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�");
 
                         // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
@@ -650,18 +656,16 @@
                         if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) {
                             continue;
                         }
-
                         // 鏇存柊宸ヤ綔妗g姸鎬佷负14澶辫触
                         wrkMast.setWrkSts(14L);
                         wrkMast.setCrnEndTime(new Date());
                         if (wrkMastMapper.updateById(wrkMast) != 0) {
                             // 澶嶄綅鍫嗗灈鏈�
-                            Short mode = crnProtocol.getMode();
-                            if (mode == 1) {
+                            if (statusType == CrnStatusType.WAITING_ONE) {
                                 crnThread.setResetFlag(true);
-                            } else if (mode == 2) {
+                            } else if (statusTypeTwo == CrnStatusType.WAITING_TWO) {
                                 crnThread.setResetFlagTwo(true);
-                            } else if (mode == 3) {
+                            } else {
                                 crnThread.setResetFlag(true);
                                 crnThread.setResetFlagTwo(true);
                             }
@@ -673,7 +677,7 @@
                         News.errorNoLog("" + mark + " - 6" + " - 鍫嗗灈鏈轰俊鎭笉绗﹀悎鍏ュ簱鏉′欢锛侊紒锛�"
                                 + " 鍫嗗灈鏈虹姸鎬侊細" + crnProtocol.modeType + "==鑷姩AUTO锛�" + CrnModeType.AUTO
                                 + "銆佸爢鍨涙満浠诲姟鍙凤細" + crnProtocol.getTaskNo() + "==宸ヤ綔妗d换鍔″彿锛�" + wrkMast.getWrkNo().shortValue()
-                                + "銆佺姸鎬佹灇涓撅細" + crnProtocol.statusType + "==WAITING锛�90 //浠诲姟瀹屾垚绛夊緟WCS纭)锛�" + CrnStatusType.WAITING
+                                + "銆佺姸鎬佹灇涓撅細" + crnProtocol.statusType + "==WAITING锛�90 //浠诲姟瀹屾垚绛夊緟WCS纭)锛�" + CrnStatusType.WAITING_ONE
                                 + "銆佽揣鍙変綅缃細" + crnProtocol.forkPosType + "==HOME锛�0  // 璐у弶鍘熶綅锛�" + CrnForkPosType.HOME);
                     }
 
@@ -1353,17 +1357,22 @@
             if (crnProtocol == null) {
                 continue;
             }
+            CrnStatusType statusType = crnProtocol.getStatusType();
+            CrnStatusType statusTypeTwo = crnProtocol.getStatusTypeTwo();
+            boolean wait = false;
+            if (statusType == CrnStatusType.WAITING_ONE || statusTypeTwo == CrnStatusType.WAITING_TWO || (statusType == CrnStatusType.WAITING_All && statusTypeTwo == CrnStatusType.WAITING_All)) {
+                wait = true;
+            }
             //  鐘舵�侊細绛夊緟纭 骞朵笖  浠诲姟瀹屾垚浣� = 1
-            if (crnProtocol.statusType == CrnStatusType.WAITING && crnProtocol.getTaskNo() != 0) {
+            if (wait && crnProtocol.getTaskNo() != 0) {
                 News.warn("" + mark + " - 0" + " - 寮�濮嬫墽琛屽宸ヤ綔妗g殑瀹屾垚鎿嶄綔");
                 if (crnProtocol.getTaskNo() == 9999) {
                     // 鍫嗗灈鏈哄浣�
-                    Short mode = crnProtocol.getMode();
-                    if (mode == 1) {
+                    if (statusType == CrnStatusType.WAITING_ONE) {
                         crnThread.setResetFlag(true);
-                    } else if (mode == 2) {
+                    } else if (statusTypeTwo == CrnStatusType.WAITING_TWO) {
                         crnThread.setResetFlagTwo(true);
-                    } else if (mode == 3) {
+                    } else {
                         crnThread.setResetFlag(true);
                         crnThread.setResetFlagTwo(true);
                     }
diff --git a/src/main/java/com/zy/core/enums/CrnStatusType.java b/src/main/java/com/zy/core/enums/CrnStatusType.java
index f02ed99..3651dca 100644
--- a/src/main/java/com/zy/core/enums/CrnStatusType.java
+++ b/src/main/java/com/zy/core/enums/CrnStatusType.java
@@ -13,7 +13,9 @@
     ORIGIN_GO(7, "鍥炲師鐐�"),
     ORIGIN_BACK(8, "鍥炲弽鍘熺偣"),
     MOVING(9, "璧拌涓�"),
-    WAITING(10, "浠诲姟瀹屾垚绛夊緟WCS纭"),
+    WAITING_ONE(10, "浠诲姟瀹屾垚绛夊緟WCS纭"),
+    WAITING_TWO(20, "浠诲姟瀹屾垚绛夊緟WCS纭"),
+    WAITING_All(30, "浠诲姟瀹屾垚绛夊緟WCS纭"),
     PAUSE(11, "浠诲姟鏆傚仠"),
     SOS(99, "鎶ヨ"),
     UNKNOW(100, "鍏朵粬"),
diff --git a/src/main/java/com/zy/core/thread/MelsecCrnThread.java b/src/main/java/com/zy/core/thread/MelsecCrnThread.java
index 32e28df..3a26c91 100644
--- a/src/main/java/com/zy/core/thread/MelsecCrnThread.java
+++ b/src/main/java/com/zy/core/thread/MelsecCrnThread.java
@@ -194,7 +194,7 @@
                 OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
 
                 // 澶嶄綅淇″彿
-                if (crnProtocol.getStatusType().equals(CrnStatusType.WAITING)) {
+                if (crnProtocol.getStatusType().equals(CrnStatusType.WAITING_ONE)) {
                     News.error("MelsecCrn"+" - 3"+" ---------绗竴姝ャ�乕鍫嗗灈鏈哄彿锛歿}][宸ヤ綔鍙凤細{}]==>> 鐘舵�佷负90锛岀瓑寰呯‘璁わ紒锛�",slave.getId(),crnProtocol.getTaskNo());
                     if (resetFlag) {
                         if(crnProtocol.getTaskNo()==9999){
diff --git a/src/main/java/com/zy/core/thread/SiemensCrnThread.java b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
index daeec96..aad4505 100644
--- a/src/main/java/com/zy/core/thread/SiemensCrnThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensCrnThread.java
@@ -187,10 +187,9 @@
 
 
                 OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛", DateUtils.convert(new Date()), slave.getId()));
-                System.out.println(crnProtocol);
                 if (crnProtocol.getMode() == 1) {
                     // 澶嶄綅淇″彿
-                    if (!Cools.isEmpty(crnProtocol.getStatusType()) && crnProtocol.getStatusType().equals(CrnStatusType.WAITING)) {
+                    if (!Cools.isEmpty(crnProtocol.getStatusType()) && crnProtocol.getStatusType().equals(CrnStatusType.WAITING_ONE)) {
                         if (resetFlag) {
                             if (crnProtocol.getTaskNo() == 9999) {
                                 backHpFlag = false;
@@ -204,7 +203,7 @@
                     }
                 } else if (crnProtocol.getMode() == 2) {
                     // 澶嶄綅淇″彿
-                    if (!Cools.isEmpty(crnProtocol.getStatusTypeTwo()) && crnProtocol.getStatusTypeTwo().equals(CrnStatusType.WAITING)) {
+                    if (!Cools.isEmpty(crnProtocol.getStatusTypeTwo()) && crnProtocol.getStatusTypeTwo().equals(CrnStatusType.WAITING_TWO)) {
                         if (resetFlagTwo) {
                             if (crnProtocol.getTaskNo() == 9999) {
                                 backHpFlag = false;
@@ -218,7 +217,7 @@
                     }
                 } else if (crnProtocol.getMode() == 3) {
                     // 澶嶄綅淇″彿
-                    if (!Cools.isEmpty(crnProtocol.getStatusType()) && crnProtocol.getStatusType().equals(CrnStatusType.WAITING) && !Cools.isEmpty(crnProtocol.getStatusTypeTwo()) && crnProtocol.getStatusTypeTwo().equals(CrnStatusType.WAITING)) {
+                    if (!Cools.isEmpty(crnProtocol.getStatusType()) && crnProtocol.getStatusType().equals(CrnStatusType.WAITING_All)) {
                         if (resetFlag && resetFlagTwo) {
                             if (crnProtocol.getTaskNo() == 9999) {
                                 backHpFlag = false;

--
Gitblit v1.9.1