From 9bc7d5848d188e228fc1b01a51b9207c38b1e264 Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期一, 21 十月 2024 08:51:02 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   32 ++++++++++++++++----------------
 1 files changed, 16 insertions(+), 16 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 63c57cb..2c4ee46 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -235,7 +235,7 @@
                         staProtocol.setWorkNo(wrkMast.getWrkNo());
                         staProtocol.setStaNo(wrkMast.getStaNo());
 
-                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        devpThread.setPakMk(staProtocol.getSiteId(), false,238);
                         boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         if (!result) {
                             throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -280,7 +280,7 @@
                                 staProtocol.setStaNo(dto.getRgvSstaNo());
                             }
 
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,283);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -419,7 +419,7 @@
                         staProtocol.setWorkNo(wrkMast.getWrkNo());
                         staProtocol.setStaNo(wrkMast.getStaNo());
 
-                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        devpThread.setPakMk(staProtocol.getSiteId(), false,422);
                         boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         if (!result) {
                             throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -464,7 +464,7 @@
                                 staProtocol.setStaNo(dto.getRgvSstaNo());
                             }
 
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,467);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -634,7 +634,7 @@
                         staProtocol.setWorkNo(wrkMast111.getWrkNo());
                         staProtocol.setStaNo(wrkMast111.getStaNo());
 
-                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        devpThread.setPakMk(staProtocol.getSiteId(), false,637);
                         boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         if (!result) {
                             if (ledThread != null) {
@@ -692,7 +692,7 @@
                                 staProtocol.setStaNo(dto.getRgvSstaNo());
                             }
 
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,695);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 if (ledThread != null) {
@@ -840,8 +840,8 @@
                         staProtocol.setWorkNo(wrkMast.getWrkNo());
                         staProtocol.setStaNo(wrkMast.getStaNo());
 
-                        devpThread.setPakMk(staProtocol.getSiteId(), false);
-                        log.info("閿佸畾鏍囪flase===銆婲===銆嬬珯鐐瑰彿锛歿}锛屽伐浣滃彿锛歿}锛屾潯鐮�:{}",staProtocol.getStaNo(),staProtocol.getWorkNo(),barcode);
+                        devpThread.setPakMk(staProtocol.getSiteId(), false,843);
+                        log.info("閿佸畾鏍囪flase===銆婲===銆嬬珯鐐瑰彿锛歿}锛屽伐浣滃彿锛歿}锛屾潯鐮�:{}",staProtocol.getSiteId(),staProtocol.getWorkNo(),barcode);
                         boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         if (!result) {
                             if (ledThread != null) {
@@ -889,7 +889,7 @@
                                 staProtocol.setStaNo(dto.getRgvSstaNo());
                             }
 
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,892);
                             log.info("閿佸畾鏍囪flase===銆婲===銆嬬珯鐐瑰彿锛歿}锛屽伐浣滃彿锛歿}锛屾潯鐮�:{}",staProtocol.getStaNo(),staProtocol.getWorkNo(),barcode);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
@@ -985,7 +985,7 @@
                         staNo = 147;
                     }
                     staProtocol.setStaNo(staNo);
-                    devpThread.setPakMk(staProtocol.getSiteId(), false);
+                    devpThread.setPakMk(staProtocol.getSiteId(), false,988);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (result) {
                         // 鏇存柊宸ヤ綔涓绘。
@@ -1093,7 +1093,7 @@
                                     // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
                                     staProtocol.setWorkNo(wrkMast.getWrkNo());
                                     staProtocol.setStaNo(dto.getStaNo());
-                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                    devpThread.setPakMk(staProtocol.getSiteId(), false,1096);
 //                                    ledThread.errorReset();
                                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                     if (!result) {
@@ -1208,7 +1208,7 @@
                                     // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
                                     staProtocol.setWorkNo(wrkMast.getWrkNo());
                                     staProtocol.setStaNo(dto.getStaNo());
-                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                    devpThread.setPakMk(staProtocol.getSiteId(), false,1211);
 //                                    ledThread.errorReset();
                                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                     if (!result) {
@@ -2322,7 +2322,7 @@
             staProtocol.setWorkNo(wrkMast.getWrkNo());
             staProtocol.setStaNo(wrkMast.getStaNo());
 
-            devpThread.setPakMk(staProtocol.getSiteId(), false);
+            devpThread.setPakMk(staProtocol.getSiteId(), false,2325);
 
             if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(99, crnCommand.getCrnNo()-2))) {
                 log.error("杈撻�佺嚎閿佸畾鍛戒护涓嬪彂澶辫触锛屽爢鍨涙満鍙�={}锛屼换鍔℃暟鎹�={}", wrkMast.getCrnNo(), crnCommand.getCrnNo()-2);
@@ -4084,7 +4084,7 @@
                             // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
                             staProtocol.setWorkNo(dto.getWorkNo());
                             staProtocol.setStaNo(dto.getStaNo());
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,4087);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -4147,7 +4147,7 @@
                             // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
                             staProtocol.setWorkNo(dto.getWorkNo());
                             staProtocol.setStaNo(dto.getStaNo());
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,4150);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
@@ -4210,7 +4210,7 @@
                             // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护
                             staProtocol.setWorkNo(dto.getWorkNo());
                             staProtocol.setStaNo(dto.getStaNo());
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            devpThread.setPakMk(staProtocol.getSiteId(), false,4213);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");

--
Gitblit v1.9.1