From 80d97d40c44165674ee0168be5f08c8ca52d3c06 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 09 六月 2025 09:36:43 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jxgtwcs' into jxgtwcs

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java |   33 ++++++++++++++++-----------------
 1 files changed, 16 insertions(+), 17 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
index 0582f3e..e29ee8c 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
@@ -23,10 +23,7 @@
 import com.zy.asrs.wcs.core.model.command.LiftCommand;
 import com.zy.asrs.wcs.core.model.enums.*;
 import com.zy.asrs.wcs.core.service.*;
-import com.zy.asrs.wcs.core.utils.OpenUtils;
-import com.zy.asrs.wcs.core.utils.RedisUtil;
-import com.zy.asrs.wcs.core.utils.ShuttleDispatcher;
-import com.zy.asrs.wcs.core.utils.Utils;
+import com.zy.asrs.wcs.core.utils.*;
 import com.zy.asrs.wcs.rcs.News;
 import com.zy.asrs.wcs.rcs.cache.SlaveConnection;
 import com.zy.asrs.wcs.rcs.constant.DeviceRedisConstant;
@@ -95,6 +92,8 @@
     private OpenUtils openUtils;
     @Autowired
     private LiftAction liftAction;
+    @Autowired
+    private NavigateUtils navigateUtils;
 
     /**
      * 缁勬墭
@@ -780,10 +779,6 @@
      * 鍑哄簱 ====>> 鍚屼竴鏃堕棿涓�鍙扮┛姊溅鍙兘鏈変竴涓嚭搴撲换鍔�
      */
     public synchronized void analyzeOutBoundTask() {
-        List<Task> moveTask = taskService.selectWaitAnalyzeMoveTask();
-        if (!moveTask.isEmpty()) {
-            return;
-        }
         List<Task> tasks = taskService.selectPakOut();
         if (tasks.isEmpty()) {
             return;
@@ -816,15 +811,13 @@
 //                    continue;
 //                }
 
-//                //鍚屽簱浣嶇粍鏍¢獙
-//                List<String> outerLoc = Utils.getGroupOuterLoc(wrkMast.getSourceLocNo());
-//                List<LocMast> outerLocMasts = locMastService.selectNotEmptyLocNos(outerLoc);
-//                if (!outerLocMasts.isEmpty()) {
-//                    News.info("{}浠诲姟锛屾祬搴撲綅瀛樺湪璐х墿锛岀郴缁熺瓑寰呬腑", wrkMast.getWrkNo());
-//                    continue;//娴呭簱浣嶅瓨鍦ㄦ湭鎵ц浠诲姟
-//                }
+                //妫�娴嬭揣鐗╂槸鍚﹀彲鍑�
+                boolean checkLocPathIsAvailable = navigateUtils.checkLocPathIsAvailable(task.getOriginLoc(), task.getHostId());
+                if(!checkLocPathIsAvailable) {
+                    continue;
+                }
 
-                if (Cools.isEmpty(task.getShuttleNo())) {
+                if (Cools.isEmpty(task.getShuttleNo()) || task.getShuttleNo() ==0) {
                     //鍒嗛厤灏忚溅
                     //鎼滅储绌洪棽杞�
                     ShuttleThread shuttleThread = shuttleDispatcher.searchIdleShuttle(task);
@@ -844,7 +837,7 @@
                 // generate motion list
                 List<Motion> motionList = analyzeService.generateMotion(task);
                 if (Cools.isEmpty(motionList)) {
-                    task.setShuttleNo(null);//淇濆瓨绌挎杞﹀彿
+                    task.setShuttleNo(0);//淇濆瓨绌挎杞﹀彿
                     task.setUpdateTime(new Date());
                     if (!taskService.updateById(task)) {
                         News.info("{}浠诲姟鏇存柊绌挎杞﹀彿澶辫触", task.getTaskNo());
@@ -1313,6 +1306,12 @@
     // 瑙f瀽灏忚溅杞借揣绉诲姩宸ヤ綔妗�
     public synchronized void analyzeLadenMoveTask() {
         for (Task task : taskService.selectWaitAnalyzeLadenMoveTask()) {
+            //妫�娴嬭揣鐗╂槸鍚﹀彲鍑�
+            boolean checkLocPathIsAvailable = navigateUtils.checkLocPathIsAvailable(task.getOriginLoc(), task.getHostId());
+            if(!checkLocPathIsAvailable) {
+                continue;
+            }
+
             if (Cools.isEmpty(task.getShuttleNo())) {
                 //鍒嗛厤灏忚溅
                 //鎼滅储绌洪棽杞�

--
Gitblit v1.9.1