From 16f1a5b3c7717d10f3d26c87a827339e7e9b8b0c Mon Sep 17 00:00:00 2001
From: lsh <lsh123456>
Date: 星期五, 07 十月 2022 15:12:34 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   39 ++++++++++++++++++++++++++++++++++++---
 1 files changed, 36 insertions(+), 3 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 7ca0561..8f0e4a6 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -2005,16 +2005,26 @@
                                 newSingle = 0;//娴嬭瘯瀹屾垚锛屽瘎瀛樺櫒鍦板潃娓呴浂锛�3===>>0
                                 break;
                             case 5://鏆傚仠淇″彿
-                                olsStatus = 5;//plc缁欏嚭鏆傚仠淇″彿
+                                olsStatus = 99;//plc缁欏嚭鏆傚仠淇″彿
                                 newStatus = 0;//WCS鏀跺埌鏆傚仠淇″彿鍚庯紝鏇存柊testMast
                                 newSingle = 6;//鏆傚仠娴嬭瘯锛屽瘎瀛樺櫒鍦板潃锛�5===>>6
+                                break;
+                            case 7://绱ф�ュ嚭搴撶‘璁ゅ厖鐢电嚎宸茬粡鎷斿嚭
+                                olsStatus = 99;//plc缁欏嚭鏆傚仠淇″彿
+                                newStatus = 0;//WCS鏀跺埌鏆傚仠淇″彿鍚庯紝鏇存柊testMast
+                                newSingle = 6;//鏆傚仠娴嬭瘯锛屽瘎瀛樺櫒鍦板潃锛�7===>>6
+                                break;
+                            case 8://瑙i櫎鏆傚仠
+                                olsStatus = 99;
+                                newStatus = 0;
+                                newSingle = 0;//娴嬭瘯澶嶆牳锛屽瘎瀛樺櫒鍦板潃锛�6===>>0
                                 break;
                         }
 
                         TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
                                 .eq("channel",(i+1)).eq("status",olsStatus));//鏌ユ壘鍘熸潵鐨勭姸鎬�
                         if(null != testMast &&
-                                (devpThread.startSignal[i] == 1 || devpThread.startSignal[i] == 3 || devpThread.startSignal[i] == 5)){
+                                (devpThread.startSignal[i] == 1 || devpThread.startSignal[i] == 3)){
                             testMast.setStatus(newStatus);
                             testMast.setModiTime(new Date());
                             if(!testMastService.update(testMast,new EntityWrapper<TestMast>()
@@ -2027,11 +2037,34 @@
                             staProtocol.setStaNo(newSingle);//淇敼PLC瀵勫瓨鍣ㄥ湴鍧�鍊�,1==>2鎴�3==>0,5==>6
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol));
                             if(!result){
-                                log.error("鏇存柊娴嬭瘯淇″彿澶辫触===>>[channel:{},locNo:{},barcode:{}]", i, testMast.getLocNo(), testMast.getBarcode());
+                                log.error("鏇存柊娴嬭瘯淇″彿澶辫触===>>[channel:{},locNo:{},barcode:{}]", i+1, testMast.getLocNo(), testMast.getBarcode());
 //                                throw new CoolException("鏇存柊娴嬭瘯淇″彿澶辫触===>>" + i);
                             } else {
                                 devpThread.startSignal[i] = newSingle;
                             }
+                        }else if (testMast == null && devpThread.startSignal[i] == 5){
+
+                        }else if (testMast == null && devpThread.startSignal[i] == 7){
+                            LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                                    .eq("channel",(i+1)));
+                            if (locMast.getLocSts().equals("F")){
+                                locMast.setPackStatus(7); //7.绱ф�ュ嚭搴�
+                                locMastService.update(locMast,new EntityWrapper<LocMast>()
+                                        .eq("channel",(i+1)));
+                            }
+                            //澶嶄綅PLC淇″彿锛屽�熺敤杈撻�佺珯鐐瑰疄浣撶被
+                            StaProtocol staProtocol = new StaProtocol();
+                            staProtocol.setSiteId(i*2);//瀵勫瓨鍣ㄥ湴鍧�
+                            staProtocol.setStaNo(newSingle);//淇敼PLC瀵勫瓨鍣ㄥ湴鍧�鍊�,7==>6
+                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol));
+                            if(!result){
+                                log.error("鏇存柊搴撲綅绱ф�ュ嚭搴撲俊鍙峰け璐�===>>[channel:{},locNo:{},barcode:{}]", i+1, locMast.getLocNo(), locMast.getBarcode());
+//                                throw new CoolException("鏇存柊娴嬭瘯淇″彿澶辫触===>>" + i);
+                            } else {
+                                devpThread.startSignal[i] = newSingle;
+                            }
+                        }else if (testMast == null && devpThread.startSignal[i] == 8){
+
                         }
 
                     }

--
Gitblit v1.9.1