From 23a2e30f0f70c1f526a04bffda38fd124ed47630 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期五, 18 四月 2025 14:51:52 +0800
Subject: [PATCH] 999

---
 src/main/java/com/zy/core/dispatcher/ShuttleDispatchUtils.java |   75 ++++++++++++++++++-------------------
 1 files changed, 37 insertions(+), 38 deletions(-)

diff --git a/src/main/java/com/zy/core/dispatcher/ShuttleDispatchUtils.java b/src/main/java/com/zy/core/dispatcher/ShuttleDispatchUtils.java
index a52bde3..a87747e 100644
--- a/src/main/java/com/zy/core/dispatcher/ShuttleDispatchUtils.java
+++ b/src/main/java/com/zy/core/dispatcher/ShuttleDispatchUtils.java
@@ -177,16 +177,20 @@
                     //褰撳墠绌挎杞﹀簱浣嶅彿
                     String currentLocNo = shuttleProtocol.getCurrentLocNo();
                     int currentLev = Utils.getLev(currentLocNo);
-                    List<WrkMast> wrkMasts1 = wrkMastService.selectNoShuttleWrkByLev(currentLev);//鍒ゆ柇褰撳墠绌挎杞︽ゼ灞傛槸鍚︽湁寰呭垎閰嶈溅杈嗙殑浠诲姟锛屽鏋滄湁鍒欎笉鍒嗛厤杩欒締杞�
-                    int shuttleCount = this.getShuttleCountByLev(currentLev);//鑾峰彇绌挎杞︽ゼ灞傝溅杈嗘暟閲�
-                    if (!wrkMasts1.isEmpty() && shuttleCount <= 1) {
-                        //瀛樺湪鍏朵粬浠诲姟涓斿彲鐢ㄥ皬杞︽暟閲忓皬浜庣瓑浜�1锛岃烦杩囪繖杈嗚溅
-                        continue;
-                    }
+//                    List<WrkMast> wrkMasts1 = wrkMastService.selectNoShuttleWrkByLev(currentLev);//鍒ゆ柇褰撳墠绌挎杞︽ゼ灞傛槸鍚︽湁寰呭垎閰嶈溅杈嗙殑浠诲姟锛屽鏋滄湁鍒欎笉鍒嗛厤杩欒締杞�
+//                    int shuttleCount = this.getShuttleCountByLev(currentLev);//鑾峰彇绌挎杞︽ゼ灞傝溅杈嗘暟閲�
+//                    if (!wrkMasts1.isEmpty() && shuttleCount <= 1) {
+//                        //瀛樺湪鍏朵粬浠诲姟涓斿彲鐢ㄥ皬杞︽暟閲忓皬浜庣瓑浜�1锛岃烦杩囪繖杈嗚溅
+//                        continue;
+//                    }
 
                     //ABS(鐩爣妤煎眰 - 褰撳墠妤煎眰) 寰楀埌宸窛锛屽彇鏈�灏忓樊鍊�
                     int currentValue = Math.abs(lev - currentLev);
-                    diffShuttles.put(currentValue, shuttleThread);
+                    if (diffShuttles.get(currentValue) != null) {
+                        diffShuttles.put(currentValue + 1, shuttleThread);
+                    } else {
+                        diffShuttles.put(currentValue, shuttleThread);
+                    }
                 }
 
                 //灏濊瘯璋冨害璺ㄦゼ灞傚皬杞�
@@ -210,7 +214,7 @@
     /**
      * 璋冨害杞﹁締
      */
-    public boolean searchDispatchShuttleIn(Integer wrkNo, String sourceLocNo, String locNo, String flag, boolean in) {
+    public boolean searchDispatchShuttleS(Integer wrkNo, String sourceLocNo, String locNo, String flag) {
         ArrayList<ShuttleThread> sameLev = new ArrayList<>();//鐩稿悓妤煎眰鐨勭┛姊溅
         ArrayList<ShuttleThread> diffLev = new ArrayList<>();//涓嶅悓妤煎眰鐨勭┛姊溅
 
@@ -251,23 +255,13 @@
                 }
                 break;
             }
-//            if (in) {
-                if (currentLev == Utils.getLev(sourceLocNo)) {
-                    //宸ヤ綔妗fゼ灞傜浉鍚岀殑绌挎杞�
-                    sameLev.add(shuttleThread);
-                } else {
-                    //宸ヤ綔妗d笉鍚屾ゼ灞傜殑绌挎杞�
-                    diffLev.add(shuttleThread);
-                }
-//            } else {
-//                if (currentLev == Utils.getLev(locNo)) {
-//                    //宸ヤ綔妗fゼ灞傜浉鍚岀殑绌挎杞�
-//                    sameLev.add(shuttleThread);
-//                } else {
-//                    //宸ヤ綔妗d笉鍚屾ゼ灞傜殑绌挎杞�
-//                    diffLev.add(shuttleThread);
-//                }
-//            }
+            if (currentLev == Utils.getLev(sourceLocNo)) {
+                //宸ヤ綔妗fゼ灞傜浉鍚岀殑绌挎杞�
+                sameLev.add(shuttleThread);
+            } else {
+                //宸ヤ綔妗d笉鍚屾ゼ灞傜殑绌挎杞�
+                diffLev.add(shuttleThread);
+            }
 
 
         }
@@ -329,16 +323,20 @@
                     //褰撳墠绌挎杞﹀簱浣嶅彿
                     String currentLocNo = shuttleProtocol.getCurrentLocNo();
                     int currentLev = Utils.getLev(currentLocNo);
-                    List<WrkMast> wrkMasts1 = wrkMastService.selectNoShuttleWrkByLev(currentLev);//鍒ゆ柇褰撳墠绌挎杞︽ゼ灞傛槸鍚︽湁寰呭垎閰嶈溅杈嗙殑浠诲姟锛屽鏋滄湁鍒欎笉鍒嗛厤杩欒締杞�
-                    int shuttleCount = this.getShuttleCountByLev(currentLev);//鑾峰彇绌挎杞︽ゼ灞傝溅杈嗘暟閲�
-                    if (!wrkMasts1.isEmpty() && shuttleCount <= 1) {
-                        //瀛樺湪鍏朵粬浠诲姟涓斿彲鐢ㄥ皬杞︽暟閲忓皬浜庣瓑浜�1锛岃烦杩囪繖杈嗚溅
-                        continue;
-                    }
+//                    List<WrkMast> wrkMasts1 = wrkMastService.selectNoShuttleWrkByLev(currentLev);//鍒ゆ柇褰撳墠绌挎杞︽ゼ灞傛槸鍚︽湁寰呭垎閰嶈溅杈嗙殑浠诲姟锛屽鏋滄湁鍒欎笉鍒嗛厤杩欒締杞�
+//                    int shuttleCount = this.getShuttleCountByLev(currentLev);//鑾峰彇绌挎杞︽ゼ灞傝溅杈嗘暟閲�
+//                    if (!wrkMasts1.isEmpty() && shuttleCount <= 1) {
+//                        //瀛樺湪鍏朵粬浠诲姟涓斿彲鐢ㄥ皬杞︽暟閲忓皬浜庣瓑浜�1锛岃烦杩囪繖杈嗚溅
+//                        continue;
+//                    }
 
                     //ABS(鐩爣妤煎眰 - 褰撳墠妤煎眰) 寰楀埌宸窛锛屽彇鏈�灏忓樊鍊�
                     int currentValue = Math.abs(lev - currentLev);
-                    diffShuttles.put(currentValue, shuttleThread);
+                    if (diffShuttles.get(currentValue) != null) {
+                        diffShuttles.put(currentValue + 1, shuttleThread);
+                    } else {
+                        diffShuttles.put(currentValue, shuttleThread);
+                    }
                 }
 
                 //灏濊瘯璋冨害璺ㄦゼ灞傚皬杞�
@@ -397,18 +395,20 @@
             News.info("{}鍙峰皬杞︼紝瀛樺湪绉诲姩浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�", shuttleNo);
             return false;
         }
-
+        WrkMast mainWrkMast = null;
         //鑾峰彇涓诲伐浣滄。淇℃伅
-        WrkMast mainWrkMast = wrkMastService.selectByWorkNo(wrkNo);
+        if (wrkNo != null) {
+            mainWrkMast = wrkMastService.selectByWorkNo(wrkNo);
+        }
 
         //鍒ゆ柇鏄惁鏈夊叾浠栦换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
-        WrkMast wrkMast2 = wrkMastService.selectShuttleWorking(shuttleNo);
+        WrkMast wrkMast2 = wrkMastService.selectShuttleWorking2(shuttleNo, wrkNo, mainWrkMast != null ? mainWrkMast.getMainWrkNo() : null);
         if (wrkMast2 != null && !disableCheck) {//灏忚溅瀛樺湪鍏朵粬宸ヤ綔妗d换鍔★紝绛夊緟鎵ц瀹屾垚鍚庡啀鐢熸垚鏂扮殑浠诲姟
             if (mainWrkMast == null) {
                 News.info("{}鍙峰皬杞︼紝瀛樺湪鍏朵粬宸ヤ綔妗d换鍔★紝绛夊緟鎵ц瀹屾垚鍐嶇敓鎴愭柊鐨勪换鍔�", shuttleNo);
                 return false;
             } else {
-                if (!mainWrkMast.getShuttleNo().equals(shuttleNo)) {
+                if (mainWrkMast.getShuttleNo() != null && !mainWrkMast.getShuttleNo().equals(shuttleNo)) {
                     News.info("{}鍙峰皬杞︼紝瀛樺湪鍏朵粬宸ヤ綔妗d换鍔★紝绛夊緟鎵ц瀹屾垚鍐嶇敓鎴愭柊鐨勪换鍔�", shuttleNo);
                     return false;
                 }
@@ -435,9 +435,8 @@
         wrkMast.setLocNo(locNo); // 鐩爣搴撲綅
         wrkMast.setAppeTime(now);
         wrkMast.setModiTime(now);
-        wrkMast.setMainWrkNo(mainWrkMast.getWrkNo());
 
-        if ("TRANSPORT_LIFT".equals(flag)) {
+        if ("TRANSPORT_LIFT".equalsIgnoreCase(flag) || "TRANSPORT_DEVP".equalsIgnoreCase(flag)) {
             wrkMast.setMainWrkNo(wrkNo);
         }
 

--
Gitblit v1.9.1