From 0ee358176fc31fdb03f968f4baf1df9bb2e1815f Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期一, 04 九月 2023 17:06:24 +0800
Subject: [PATCH] # 显示屏

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   21 +++++++++++++--------
 1 files changed, 13 insertions(+), 8 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 b159090..69bd66a 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -130,7 +130,7 @@
                 } else {
                     staProtocol = staProtocol.clone();
                 }
-                staProtocol.setPakMk(true);
+                //staProtocol.setPakMk(true);
 //                // 鍏ュ嚭搴撴ā寮忓垽鏂�
 //                if ( inSta.getStaNo()==180 && devpThread.ioMode != IoModeType.PAKIN_MODE) { continue; }
                 // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
@@ -208,7 +208,7 @@
                         } else if (jsonObject.getInteger("code").equals(700) && (!barcodeThread.getBarcode().equals("NG"))){
                             StartupDto dto = jsonObject.getObject("data", StartupDto.class);
                             barcodeThread.setBarcode("");
-                            staProtocol.setWorkNo((short)9998);
+                            staProtocol.setWorkNo((short)9999);
                             staProtocol.setStaNo((short)201);
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -216,7 +216,7 @@
                         }else {
                             StartupDto dto = jsonObject.getObject("data", StartupDto.class);
                             barcodeThread.setBarcode("");
-                            staProtocol.setWorkNo((short)9998);
+                            staProtocol.setWorkNo((short)9999);
                             staProtocol.setStaNo((short)201);
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -849,7 +849,7 @@
                 if (staProtocol.isAutoing() && !staProtocol.isLoading() && staDetl.getCanouting() !=null && staDetl.getCanouting().equals("Y")
                         && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable()) {
                     //娴嬭瘯搴撲綅鍑哄簱蹇呴』瑕佹寜鍚姩鎸夐挳鎵嶈兘鍑哄簱
-                    if(wrkMast.getStaNo()==206 && locMast.getCtnKind()==0){
+                    if((wrkMast.getStaNo()==206 || wrkMast.getStaNo()==1000)&& locMast.getCtnKind()==0){
                         log.error("鍑哄簱 ===>> 绛夊緟鍚姩鍑哄簱鎸夐挳",wrkMast);
                         continue;
                     }
@@ -2285,18 +2285,21 @@
     public void fierCrn() {
         try {
             for (CrnSlave crn :slaveProperties.getCrn()) {
+                if(crn.getId()!=1){
+                    continue;
+                }
                 // 鑾峰彇鍫嗗灈鏈轰俊鎭�
                 CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
                 CrnProtocol crnProtocol = crnThread.getCrnProtocol();
                 LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("fire_status", 1));
                 if (!Cools.isEmpty(locMast)){
                     //鎶ヨ淇″彿鍐欏叆1
-                    if (!MessageQueue.offer(SlaveType.Crn, 1, new Task(4, "1"))) {
+                    if (!MessageQueue.offer(SlaveType.Crn, 1, new Task(4, 1))) {
                         log.error("鐏  ===>> 缁欏爢鍨涙満鍙戦�佹姤璀︿俊鍙峰け璐�");
                     }
                 } else {
                     //鎶ヨ淇″彿娌℃湁鍚庯紝澶嶄綅鍦板潃
-                    if (!MessageQueue.offer(SlaveType.Crn, 1, new Task(4, "0"))) {
+                    if (!MessageQueue.offer(SlaveType.Crn, 1, new Task(4, 0))) {
                         log.error("鐏  ===>> 缁欏爢鍨涙満娓呴浂澶嶄綅鎶ヨ淇″彿澶辫触");
                     }
                 }
@@ -2371,14 +2374,16 @@
                             }else if(devpThread.startSignal[i][0]==3){
                                 locMast.setPackStatus(7);
                                 testMast.setModiTime(new Date());
-                            }else if(devpThread.startSignal[i][0]==4){
+                            }else if(devpThread.startSignal[i][0]==4 && testMast.getStatus()!=4){
                                 locMast.setPackStatus(3);
                                 testMast.setStatus(4);
                                 testMast.setModiTime(new Date());
-                            }else if(devpThread.startSignal[i][0]==5){
+                                testMastService.insertPackQualified(true,new Date());
+                            }else if(devpThread.startSignal[i][0]==5 && testMast.getStatus()!=4){
                                 locMast.setPackStatus(4);
                                 testMast.setStatus(4);
                                 testMast.setModiTime(new Date());
+                                testMastService.insertPackQualified(false,new Date());
                             }
 //                            else if(devpThread.startSignal[i][0]==6||devpThread.startSignal[i][0]==7||devpThread.startSignal[i][0]==8){
 //                                locMast.setPackStatus(devpThread.startSignal[i][0]+3);

--
Gitblit v1.9.1