From 3ffb9d7eb237831b294ff199d551a0d3c4610e0e Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期一, 20 十月 2025 10:32:42 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   47 +++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 39 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 944e371..e597b25 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -197,14 +197,14 @@
                         continue;
                     }
 
-                    if (inSta.getStaNo() == 1005) {
+                    if (inSta.getStaNo() == 1002 || inSta.getStaNo() == 1007) {
                         //妫�娴嬫槸鍚︽湁鍑哄簱浠诲姟
                         List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
                                 .in("io_type", 101, 103, 107)
-                                .in("sta_no", 1003, 1007)
+                                .in("sta_no", 1003, 1004)
                         );
                         if (!wrkMasts.isEmpty()) {
-                            News.error("" + mark + " - 4" + " - 1003绔欏叆搴擄紝妫�娴嬪瓨鍦ㄥ嚭搴撲换鍔★紝绛夊緟鍑哄簱浠诲姟鎵ц瀹屾垚,鎵樼洏鐮�={}", barcode);
+                            News.error("" + mark + " - 4" + " - 鍏ュ簱锛屾娴嬪瓨鍦ㄥ嚭搴撲换鍔★紝绛夊緟鍑哄簱浠诲姟鎵ц瀹屾垚,鎵樼洏鐮�={}", barcode);
                             continue;
                         }
                     }
@@ -708,9 +708,14 @@
                     LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
                             .eq("loc_no", wrkMast.getSourceLocNo()));
 
+                    short staNo = wrkMast.getStaNo().shortValue();
+                    if (wrkMast.getStaNo() == 1004) {
+                        staNo = 2003;
+                    }
+
                     // 涓嬪彂绔欑偣淇℃伅
                     staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue());
-                    staProtocol.setStaNo(wrkMast.getStaNo().shortValue());
+                    staProtocol.setStaNo(staNo);
                     staProtocol.setPalletSize(locMast.getLocType2());
                     if (!MessageQueue.offer(SlaveType.Devp, devpId, new Task(2, staProtocol))) {
                         continue;
@@ -1132,6 +1137,13 @@
             devpCheckTaskStackOver = Integer.parseInt(config2.getValue());
         }
 
+        int outNumber = 13;
+        Config config3 = configService.selectOne(new EntityWrapper<Config>()
+                .eq("code", "fullBoardOutboundNumber"));
+        if (config3 != null) {
+            outNumber = Integer.parseInt(config3.getValue());
+        }
+
 
         Integer devpWorkingCount = commonService.queryDevpWorkingCount();
         if (devpWorkingCount > devpTaskStackOver) {
@@ -1169,11 +1181,12 @@
                     staProtocol = staProtocol.clone();
                 }
 
-                if (wrkMast.getStaNo() == 1003 || wrkMast.getStaNo() == 1007) {
+                if (wrkMast.getStaNo() == 1003 || wrkMast.getStaNo() == 1007 || wrkMast.getStaNo() == 1004) {
                     //妫�娴嬫槸鍚︽湁鍏ュ簱浠诲姟
                     List<WrkMast> inWrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
                             .in("io_type", 1, 53, 57)
-                            .in("source_sta_no", 1005)
+                            .notIn("wrk_sts", 3, 4, 5)
+                            .in("source_sta_no", 1002, 1007)
                     );
                     if (!inWrkMasts.isEmpty()) {
                         News.error("" + mark + " - 2" + " - 妫�娴嬪瓨鍦ㄥ叆搴撲换鍔★紝绛夊緟鍏ュ簱浠诲姟鎵ц瀹屾垚鍐嶅嚭搴擄紝宸ヤ綔鍙�={}" + wrkMast.getWrkNo());
@@ -1201,6 +1214,14 @@
                             News.error("" + mark + " - 2" + " - 妫�娴嬪瓨鍦�1062绔欑偣锛屽瓨鍦ㄤ袱绗斿伐浣滀腑鐨勪换鍔★紝宸ヤ綔鍙�={}" + wrkMast.getWrkNo());
                             continue;
                         }
+                    }
+                }else if (wrkMast.getIoType() == 101) {
+                    List<WrkMast> inWrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                            .in("wrk_sts", 12, 14)
+                    );
+                    if (!Cools.isEmpty(inWrkMasts) && inWrkMasts.size() >= outNumber) {
+                        News.error("" + mark + " - 4" + " - 妫�娴嬪埌鍏ㄦ澘鍑哄簱鐨勪换鍔″凡缁忓埌杈句笂绾匡紝宸ヤ綔鍙�={}" + wrkMast.getWrkNo());
+                        continue;
                     }
                 }
 
@@ -2017,6 +2038,16 @@
                         continue;
                     }
 
+                    //妫�娴嬫槸鍚︽湁鍏ュ簱浠诲姟
+                    List<WrkMast> inWrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>()
+                            .in("io_type", 1, 53, 57)
+                            .in("source_sta_no", 1002, 1007)
+                    );
+                    if (!inWrkMasts.isEmpty()) {
+                        News.error("" + mark + " - 2" + " - 妫�娴嬪瓨鍦ㄥ叆搴撲换鍔★紝绛夊緟鍏ュ簱浠诲姟鎵ц瀹屾垚鍐嶅叆绌烘墭锛屽伐浣滃彿={}");
+                        continue;
+                    }
+
                     int workNo = commonService.getWorkNo(3);
                     // 鐢熸垚宸ヤ綔妗�
                     WrkMast wrkMast1 = new WrkMast();
@@ -2202,7 +2233,7 @@
                         ));
 
                     }else {
-                        List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectTodayByWrkNo(wrkMast.getWrkNo());
+                        List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectTodayByWrkNo(wrkNo);
                         if(!wrkDetlLogs.isEmpty()) {
                             WrkDetlLog wrkDetlLog = wrkDetlLogs.get(0);
 
@@ -2216,7 +2247,7 @@
                             }
 
                             List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>()
-                                    .eq("loc_no", wrkMast.getSourceLocNo()));
+                                    .eq("loc_no", sourceLocNo));
                             double totalAnfme = 0D;
                             double totalWeight = 0D;
                             for (LocDetl locDetl : locDetls) {

--
Gitblit v1.9.1