From ae1b1eefcfcaae12753466e6b8a77944cc96a688 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期五, 20 三月 2026 11:29:06 +0800
Subject: [PATCH] 有组托阻止出库

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   28 +++++++++++++++++++++++-----
 1 files changed, 23 insertions(+), 5 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 87c7e52..783bca5 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -8,6 +8,7 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.mapper.BasCrnErrorMapper;
+import com.zy.asrs.mapper.WaitPakinMapper;
 import com.zy.asrs.mapper.WrkMastMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.Utils;
@@ -84,6 +85,8 @@
     private BasCrnErrorMapper basCrnErrorMapper;
     @Autowired
     private WrkMastService wrkMastService;
+    @Autowired
+    private WaitPakinMapper waitPakinMapper;
     @Autowired
     private ConfigService configService;
     @Autowired
@@ -310,8 +313,12 @@
                                 wrkMastService.updateById(wrkMast);
                                 Thread.sleep(3000); // 寤舵椂3S
                             }else {
+                                // 鏈粍鎵樻墭鐩橀��鍥� 鐢佃鏈烘樉绀鸿鍏堢粍鎵�
                                 Integer back = 999;
-
+                                if (ledThread != null) {
+                                    String errorMsg = jsonObject.getString("msg");
+                                    MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                                }
                                 barcodeThread.setBarcode("");
                                 boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(4, back));
                                 if (result) {
@@ -548,10 +555,21 @@
 //        if (!staProtocol.isOutEnable()) {
 //            return;
 //        }
-
-        //妫�鏌ユ槸鍚︽湁姝e湪鎵ц鐨勪换鍔�
-        List<WrkMast> workingWrkMast = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", 3, 12));
-        if (!workingWrkMast.isEmpty()) {
+        // 缁勬墭妗e瓨鍦ㄥ凡缁勬墭鏈叆搴撳垯绛夊緟锛屼笉涓嬪彂鍑哄簱
+        int waitPakinNotIn = waitPakinMapper.selectCount(new EntityWrapper<WaitPakin>()
+                .eq("status", "Y"));
+        if (waitPakinNotIn > 0) {
+            return;
+        }
+        // 瀛樺湪杩涜涓�/鍦ㄩ�斾换鍔�(2,3,12,13,14)鍒欎笉涓嬪彂鍑哄簱锛岄伩鍏嶅啿绐�
+        // 2 寰呮墽琛岋紙鍏ュ簱锛�
+        //3 璁惧鎵ц涓紙鍏ュ簱锛�
+        //12 璁惧鎵ц涓紙鍑哄簱锛�
+        //13 鍑哄簱鍒扮珯鐐逛笂
+        //14 鍑哄簱绛夊緟纭
+        int activeCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
+                .in("wrk_sts", 2, 3, 12, 13, 14));
+        if (activeCount > 0) {
             return;
         }
 

--
Gitblit v1.9.1