From 5883555b99f76edd948c4072f60ff4696042772f Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期五, 20 九月 2024 15:42:22 +0800
Subject: [PATCH] 组托入库过滤拣料再入库任务

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   23 +++++++++++------------
 1 files changed, 11 insertions(+), 12 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 e5a7768..273834f 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -205,7 +205,7 @@
                     //杩囨护鍒ゆ柇锛岄槻姝㈡嫞鏂欏啀鍏ュ簱璐х墿锛岀粡杩囧叆搴撶珯鍐嶅叆搴撴椂锛岃閫�鍥炲埌閫�搴撶珯
                     WrkMast wrkMast1 = wrkMastMapper.selectPakInStepBarcode(barcode);
                     if (wrkMast1 !=null){
-                        if (wrkMast1.getIoType()==103 || wrkMast1.getIoType()==107 || wrkMast1.getIoType()==104){
+                        if (wrkMast1.getIoType()==103 || wrkMast1.getIoType() == 53 || wrkMast1.getIoType()==107 || wrkMast1.getIoType()==104){
                             continue;
                         }
                     }
@@ -226,7 +226,7 @@
                         // led 寮傚父鏄剧ず
                         if (ledThread != null) {
                             String errorMsg = "宸ヤ綔妗e凡瀛樺湪璇ユ潯鐮佸彿===>>" + barcode;
-                            MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+//                            MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                         }
                         continue;
                     }
@@ -277,9 +277,9 @@
                                 ledCommand.setBarcode(barcode);
                                 commands.add(ledCommand);
                                 if (devp.getId() == 1) {
-                                     if (MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(1, commands))){
-                                         ledThread.setLedMk(false);
-                                     }
+//                                     if (MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(1, commands))){
+//                                         ledThread.setLedMk(false);
+//                                     }
                                 } else {
                                     if (MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, commands))){
                                         ledThread.setLedMk(false);
@@ -538,9 +538,9 @@
                     ledCommand.setMatDtos(matDtos);
                     commands.add(ledCommand);
                     if (devp.getId() == 1) {
-                        if (MessageQueue.offer(SlaveType.Led, pickSta.getLed(), new Task(1, commands))) {
-                            ledThread.setLedMk(false);
-                        }
+//                        if (MessageQueue.offer(SlaveType.Led, pickSta.getLed(), new Task(1, commands))) {
+//                            ledThread.setLedMk(false);
+//                        }
                     } else {
                         if (MessageQueue.offer(SlaveType.Led, pickSta.getLed(), new Task(3, commands))){
                             ledThread.setLedMk(false);
@@ -1585,7 +1585,6 @@
                                 News.errorNoLog(""+mark+" - 1"+" - 鏇存柊plc绔欑偣淇℃伅澶辫触");
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
                             }
-
                             if (ledThread != null) {
                                 // 鍛戒护闆嗗悎
                                 List<LedCommand> commands = new ArrayList<>();
@@ -1604,16 +1603,16 @@
                                 ledCommand.setMatDtos(matDtos);
                                 commands.add(ledCommand);
                                 if (devp.getId() == 1) {
-                                    MessageQueue.offer(SlaveType.Led, emptyInSta.getLed(), new Task(1, commands));
+//                                    MessageQueue.offer(SlaveType.Led, emptyInSta.getLed(), new Task(1, commands));
                                 } else {
                                     MessageQueue.offer(SlaveType.Led, emptyInSta.getLed(), new Task(3, commands));
                                 }
 //                                ledThread.errorReset();
                             }
-                            Thread.sleep(500);
+                            Thread.sleep(1000);
                         } else {
                             staProtocol.setWorkNo((short)9991);
-                            staProtocol.setStaNo((short)100);
+                            staProtocol.setStaNo(emptyInSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             if (!result) {

--
Gitblit v1.9.1