From 83449fef571c247a2d73194b8063638349d0076a Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 20 十一月 2023 10:04:52 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java |   87 ++++++++++++++++++++++++++++++-------------
 1 files changed, 60 insertions(+), 27 deletions(-)

diff --git a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
index da8a2ab..c753b9d 100644
--- a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
+++ b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
@@ -4,13 +4,11 @@
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.SpringUtils;
 import com.core.exception.CoolException;
-import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.BasShuttle;
 import com.zy.asrs.entity.WrkCharge;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.mapper.WrkChargeMapper;
 import com.zy.asrs.mapper.WrkMastMapper;
-import com.zy.asrs.service.BasDevpService;
 import com.zy.asrs.service.BasShuttleService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.utils.Utils;
@@ -55,13 +53,15 @@
     private WrkChargeMapper wrkChargeMapper;
     @Autowired
     private CommonService commonService;
-    @Autowired
-    private BasDevpService basDevpService;
 
     /**
      * 璋冨害杞﹁締-璋冨害鎸囧畾绌挎杞�
      */
     public boolean dispatchShuttle(Integer wrkNo, String locNo, Integer shuttleNo) {
+        if (!checkCharge(shuttleNo, locNo)) {
+            News.info("{}鍙峰皬杞︼紝瀛樺湪鍏呯數浠诲姟绂佹灏忚溅绉诲姩浠诲姟璋冨害", shuttleNo);
+            return false;//瀛樺湪鍏呯數浠诲姟鏆傚仠璋冨害
+        }
         return shuttleMoveGenerate(wrkNo, locNo, shuttleNo);
     }
 
@@ -92,8 +92,12 @@
                 continue;
             }
 
+            if (!checkChargeWrk(shuttle.getId())) {
+                continue;//瀛樺湪鍏呯數浠诲姟锛岃繃婊ゅ皬杞�
+            }
+
             if (!shuttleProtocol.isIdle()) {
-                continue;
+                continue;//灏忚溅蹇欑涓�
             }
 
             if (shuttleProtocol.getSuspendState() == 1) {
@@ -160,6 +164,7 @@
                 //妫�娴嬬洰鏍囨ゼ灞傝溅鏁伴噺鏄惁灏忎簬鍏佽鐨勬渶澶ф暟閲�
                 boolean checkDispatchMaxNum = checkDispatchMaxNum(lev);
                 if (!checkDispatchMaxNum) {
+                    News.info("{}浠诲姟锛寋}灞傦紝宸茬粡杈惧埌褰撳墠妤煎眰璋冨害杞﹁締鏈�澶у��", wrkMast1.getWrkNo(), lev);
                     return false;
                 }
 
@@ -186,6 +191,7 @@
         }
 
         if (recentShuttle == null) {//娌℃湁鎼滅储鍒板彲鐢ㄧ┛姊溅
+            News.info("{}鐩爣搴撲綅娌℃湁鎼滅储鍒板彲鐢ㄧ┛姊溅", locNo);
             return false;
         }
 
@@ -202,50 +208,33 @@
         //鑾峰彇鍥涘悜绌挎杞︾嚎绋�
         NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleNo);
         if (shuttleThread == null) {
+            News.info("{}鍙峰皬杞︼紝绾跨▼涓嶅瓨鍦�", shuttleNo);
             return false;
         }
         NyShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
         if (shuttleProtocol == null) {
+            News.info("{}鍙峰皬杞︼紝绾跨▼涓嶅瓨鍦�", shuttleNo);
             return false;
         }
 
         //灏忚溅澶勪簬绌洪棽鐘舵��
         if (!shuttleProtocol.isIdleNoCharge()) {
+            News.info("{}鍙峰皬杞︼紝蹇欑涓�", shuttleNo);
             return false;
         }
 
         //鍒ゆ柇绌挎杞︽槸鍚﹀瓨鍦ㄦ湭瀹屾垚鐨勫皬杞︾Щ搴撲换鍔�
         WrkMast hasMoveWorking = wrkMastMapper.selectShuttleHasMoveWorking(shuttleNo);
         if (hasMoveWorking != null) {//灏忚溅瀛樺湪绉诲簱浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�
+            News.info("{}鍙峰皬杞︼紝瀛樺湪绉诲姩浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�", shuttleNo);
             return false;
         }
 
         //鍒ゆ柇鏄惁鏈夊叾浠栦换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
         WrkMast wrkMast2 = wrkMastMapper.selectShuttleWorking(shuttleNo);
         if (wrkMast2 != null) {//灏忚溅瀛樺湪鍏朵粬宸ヤ綔妗d换鍔★紝绛夊緟鎵ц瀹屾垚鍚庡啀鐢熸垚鏂扮殑浠诲姟
+            News.info("{}鍙峰皬杞︼紝瀛樺湪鍏朵粬宸ヤ綔妗d换鍔★紝绛夊緟鎵ц瀹屾垚鍐嶇敓鎴愭柊鐨勪换鍔�", shuttleNo);
             return false;
-        }
-
-        //鍒ゆ柇鏄惁鏈夊厖鐢典换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
-        WrkCharge wrkCharge = wrkChargeMapper.selectWorking(shuttleNo);
-        if (wrkCharge != null) {//灏忚溅瀛樺湪鍏呯數浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�
-            //鍒ゆ柇鐩爣鐐规槸鍚︿负鍏呯數妗╋紝濡傛灉鏄幓鍏呯數鍒欐斁琛�
-            boolean toCharge = false;//鍘诲厖鐢电洰鏍�
-            for (ShuttleChargeType chargeType : ShuttleChargeType.values()) {
-                if (chargeType.locNo.equals(locNo)) {
-                    toCharge = true;//鍘诲厖鐢垫々
-                    break;
-                }
-            }
-
-            if (wrkCharge.getWrkSts() == 53) {
-                toCharge = true;//鍏呯數缁撴潫锛屽厑璁哥敓鎴愮Щ搴撲换鍔�
-            }
-
-            if (!toCharge) {
-                //涓嶆槸鍘诲厖鐢垫々涓斿瓨鍦ㄥ厖鐢典换鍔★紝绂佹鐢熸垚鏂扮殑绉诲姩浠诲姟
-                return false;
-            }
         }
 
         Integer sourceStaNo = null;//灏忚溅鎹㈠眰婧愮珯鐐�
@@ -255,6 +244,7 @@
             //鑾峰彇绌挎杞︽渶杩戜笖绌洪棽鐨勬彁鍗囨満杈撻�佺珯鐐�
             LiftStaProtocol liftSta = this.getRecentLiftSta(shuttleNo, Utils.getLev(locNo));
             if (liftSta == null) {
+                News.info("{}鍙峰皬杞︼紝{}鐩爣搴撲綅锛屾病鏈夊彲鐢ㄧ┖闂茶緭閫佺珯鐐�", shuttleNo, locNo);
                 return false;//娌℃湁鍙敤涓旂┖闂茬殑杈撻�佺珯鐐�
             }
             sourceStaNo = liftSta.getStaNo();//婧愮珯鐐�
@@ -434,4 +424,47 @@
         return recentSta;
     }
 
+    /**
+     * 妫�娴嬫槸鍚︾┛姊溅鏄惁鏈夊厖鐢典换鍔�
+     */
+    public boolean checkChargeWrk(int shuttleNo) {
+        //鍒ゆ柇鏄惁鏈夊厖鐢典换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
+        WrkCharge wrkCharge = wrkChargeMapper.selectWorking(shuttleNo);
+        if (wrkCharge != null) {
+            return true;//鏈夊厖鐢典换鍔�
+        }
+        return false;//鏃犲厖鐢典换鍔�
+    }
+
+    /**
+     * 妫�娴嬬┛姊溅鏄惁鏈夊厖鐢典换鍔★紝鐩爣鐐规槸鍚︿负鍏呯數妗╀綅缃�
+     * @param shuttleNo 灏忚溅鍙�
+     * @param locNo 鐩爣浣嶇疆
+     */
+    public boolean checkCharge(int shuttleNo, String locNo) {
+        //鍒ゆ柇鏄惁鏈夊厖鐢典换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
+        WrkCharge wrkCharge = wrkChargeMapper.selectWorking(shuttleNo);
+        if (wrkCharge != null) {//灏忚溅瀛樺湪鍏呯數浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�
+            //鍒ゆ柇鐩爣鐐规槸鍚︿负鍏呯數妗╋紝濡傛灉鏄幓鍏呯數鍒欐斁琛�
+            boolean toCharge = false;//鍘诲厖鐢电洰鏍�
+            for (ShuttleChargeType chargeType : ShuttleChargeType.values()) {
+                if (chargeType.locNo.equals(locNo)) {
+                    toCharge = true;//鍘诲厖鐢垫々
+                    break;
+                }
+            }
+
+            if (wrkCharge.getWrkSts() == 53) {
+                toCharge = true;//鍏呯數缁撴潫锛屽厑璁哥敓鎴愮Щ搴撲换鍔�
+            }
+
+            if (!toCharge) {
+                //涓嶆槸鍘诲厖鐢垫々涓斿瓨鍦ㄥ厖鐢典换鍔★紝绂佹鐢熸垚鏂扮殑绉诲姩浠诲姟
+                return false;
+            }
+        }
+
+        return true;//鏃犲厖鐢典换鍔℃斁琛� || 鍘诲厖鐢垫々涓斁琛�
+    }
+
 }

--
Gitblit v1.9.1