From 6d99081f3f6e0363b0bd28053e545a8e4589b979 Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期五, 09 一月 2026 08:50:11 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/utils/Utils.java |   25 ++++++++++++++++---------
 1 files changed, 16 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/asrs/utils/Utils.java b/src/main/java/com/zy/asrs/utils/Utils.java
index f2c7d43..cb1ee8b 100644
--- a/src/main/java/com/zy/asrs/utils/Utils.java
+++ b/src/main/java/com/zy/asrs/utils/Utils.java
@@ -193,10 +193,20 @@
                     .eq("in_enable", "Y")
                     .eq("status", 1);
 
+            if (hasConfig) {
+                wrapper.in("crn_no", allowedCrnNos);
+            }
+
             if (currentCircleTaskCrnNo != null) {
                 currentCircleTaskCrnNo = currentCircleTaskCrnNo + 1;
-                BasCrnp basCrnp = basCrnpService.selectOne(new EntityWrapper<BasCrnp>().eq("crn_no", currentCircleTaskCrnNo));
-                List<WrkMast> currentCrnTask = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no", currentCircleTaskCrnNo));
+                BasCrnp basCrnp = basCrnpService.selectOne(new EntityWrapper<BasCrnp>()
+                        .eq("crn_no", currentCircleTaskCrnNo)
+                        .eq("in_enable", "Y")
+                        .eq("status", 1)
+                );
+                List<WrkMast> currentCrnTask = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                        .eq("crn_no", currentCircleTaskCrnNo)
+                );
                 if (currentCrnTask.size() <= 1) {
                     if (basCrnp != null) {
                         List<List<Integer>> rowList = basCrnp.getControlRows$();
@@ -230,9 +240,6 @@
 
             List<BasCrnp> enabledCrnps = new ArrayList<>();
             for (BasCrnp basCrnp : baseList) {
-                if (hasConfig && !allowedCrnNos.contains(basCrnp.getCrnNo())) {
-                    continue;
-                }
                 CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, basCrnp.getCrnNo());
                 if (crnThread == null) {
                     continue;
@@ -311,6 +318,10 @@
                     .eq("in_enable", "Y")
                     .eq("status", 1);
 
+            if (hasConfig) {
+                wrapper.in("crn_no", allowedCrnNos);
+            }
+
             HashMap<Integer, Integer> map = new HashMap<>();
             List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<>());
             List<BasDualCrnp> basDualCrnps = basDualCrnpService.selectList(wrapper);
@@ -333,10 +344,6 @@
 
             List<BasDualCrnp> enabledCrnps = new ArrayList<>();
             for (BasDualCrnp basDualCrnp : baseList) {
-                if (hasConfig && !allowedCrnNos.contains(basDualCrnp.getCrnNo())) {
-                    continue;
-                }
-
                 DualCrnThread dualCrnThread = (DualCrnThread) SlaveConnection.get(SlaveType.DualCrn, basDualCrnp.getCrnNo());
                 if (dualCrnThread == null) {
                     continue;

--
Gitblit v1.9.1