From 4bf0426314e8eb19b632861603206c4c288647bf Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期一, 02 二月 2026 13:18:29 +0800
Subject: [PATCH] Merge branch 'master' of http://47.97.1.152:5880/r/zy-wcs-master

---
 src/main/java/com/zy/core/plugin/XiaosongProcess.java |   29 +++++++++++++++++------------
 1 files changed, 17 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/zy/core/plugin/XiaosongProcess.java b/src/main/java/com/zy/core/plugin/XiaosongProcess.java
index f018866..c2a18d6 100644
--- a/src/main/java/com/zy/core/plugin/XiaosongProcess.java
+++ b/src/main/java/com/zy/core/plugin/XiaosongProcess.java
@@ -67,7 +67,7 @@
 
         //鎵ц鍫嗗灈鏈轰换鍔�
         crnOperateUtils.crnIoExecute();
-        //鍫嗗灈鏈轰换鍔℃墽琛屽畬鎴�-鍏峰浠跨湡鑳藉姏
+        //鍫嗗灈鏈轰换鍔℃墽琛屽畬鎴�
         crnOperateUtils.crnIoExecuteFinish();
         //鎵ц杈撻�佺珯鐐瑰叆搴撲换鍔�
         stationOperateProcessUtils.stationInExecute();
@@ -131,12 +131,23 @@
                         continue;
                     }
 
-                    // 婊¤冻鑷姩銆佹湁鐗┿�佹湁宸ヤ綔鍙凤紝鐢熸垚鍏ュ簱鏁版嵁
                     if (stationProtocol.isAutoing()
                             && stationProtocol.isLoading()
+                            && stationProtocol.isInEnable()
                             && stationProtocol.getTaskNo() > 0) {
                         if (Cools.isEmpty(stationProtocol.getBarcode())) {
                             continue;
+                        }
+
+                        if (stationProtocol.getError() > 0) {
+                            StationObjModel backStation = entity.getBackStation();
+                            StationCommand command = stationThread.getCommand(StationCommandType.MOVE, 9998, stationId, backStation.getStationId(), 0);
+                            if (command == null) {
+                                News.taskInfo(stationProtocol.getTaskNo(), "{}宸ヤ綔,鑾峰彇杈撻�佺嚎鍛戒护澶辫触", stationProtocol.getTaskNo());
+                                continue;
+                            }
+                            MessageQueue.offer(SlaveType.Devp, basDevp.getDevpNo(), new Task(2, command));
+                            News.taskInfo(stationProtocol.getTaskNo(), "{}鎵爜寮傚父锛屽凡閫�鍥炶嚦{}", backStation.getStationId());
                         }
 
                         // 妫�娴嬩换鍔℃槸鍚︾敓鎴�
@@ -166,6 +177,7 @@
                                 wmsOperateUtils.applyInTaskAsync(barcode, stationIdVal,
                                         stationProtocol.getPalletHeight());
                                 redisUtil.set(RedisKeyType.GENERATE_IN_TASK_LIMIT.key + stationId, "lock", 2);
+                                stationProtocol.setSystemWarning("璇锋眰鍏ュ簱澶辫触锛學MS杩斿洖=" + response);
                                 continue;
                             }
 
@@ -180,14 +192,7 @@
                                 taskParam.setTaskPri(dto.getTaskPri());
                                 taskParam.setBarcode(barcode);
                                 WrkMast wrkMast = commonService.createInTask(taskParam);
-
-                                StationCommand command = stationThread.getCommand(StationCommandType.WRITE_INFO,
-                                        wrkMast.getWrkNo(), stationId, stationId, 0);
-                                if (command == null) {
-                                    News.taskInfo(wrkMast.getWrkNo(), "鑾峰彇杈撻�佺嚎鍛戒护澶辫触");
-                                    continue;
-                                }
-                                MessageQueue.offer(SlaveType.Devp, basDevp.getDevpNo(), new Task(2, command));
+                                stationProtocol.setSystemWarning("");
                             } else {
                                 // 鎺ュ彛杩斿洖闈�200锛岄噸鏂板彂璧疯姹�
                                 News.error("WMS鍏ュ簱鎺ュ彛杩斿洖闈�200锛岄噸鏂板彂璧疯姹傦紝barcode={}锛宻tationId={}锛宺esponse={}", barcode,
@@ -195,6 +200,7 @@
                                 wmsOperateUtils.applyInTaskAsync(barcode, stationIdVal,
                                         stationProtocol.getPalletHeight());
                                 redisUtil.set(RedisKeyType.GENERATE_IN_TASK_LIMIT.key + stationId, "lock", 2);
+                                stationProtocol.setSystemWarning("璇锋眰鍏ュ簱澶辫触锛學MS杩斿洖=" + response);
                             }
                         } else {
                             // 3. 娌℃湁鍝嶅簲缁撴灉锛屾鏌ユ槸鍚︽湁璇锋眰姝e湪杩涜涓�
@@ -204,8 +210,8 @@
                                 wmsOperateUtils.applyInTaskAsync(barcode, stationIdVal,
                                         stationProtocol.getPalletHeight());
                                 redisUtil.set(RedisKeyType.GENERATE_IN_TASK_LIMIT.key + stationId, "lock", 2);
+                                stationProtocol.setSystemWarning("璇锋眰鍏ュ簱澶辫触锛學MS鏃犺繑鍥�");
                             }
-                            // 濡傛灉鏈夎姹傝繘琛屼腑锛岀瓑寰呬笅娆″惊鐜啀妫�鏌�
                         }
                     }
                 }
@@ -243,7 +249,6 @@
                     continue;
                 }
 
-                //婊¤冻鑷姩銆佹棤鐗┿�佸伐浣滃彿0锛岀敓鎴愬叆搴撴暟鎹�
                 if (stationProtocol.isAutoing()
                         && stationProtocol.isLoading()
                         && stationProtocol.getTaskNo() == 0

--
Gitblit v1.9.1