From 58365ea8a02e8adee1b56948085998107f9a80b3 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 26 九月 2023 20:46:10 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java |  116 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 113 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
index 041362d..bcaead1 100644
--- a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
+++ b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java
@@ -1,10 +1,12 @@
 package com.zy.common.utils;
 
 import com.core.exception.CoolException;
+import com.zy.asrs.entity.BasDevp;
 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.WrkMastService;
 import com.zy.asrs.utils.Utils;
 import com.zy.common.model.NavigateNode;
@@ -12,10 +14,15 @@
 import com.zy.common.service.CommonService;
 import com.zy.core.News;
 import com.zy.core.cache.SlaveConnection;
+import com.zy.core.enums.ShuttleChargeType;
 import com.zy.core.enums.SlaveType;
+import com.zy.core.model.LiftSlave;
 import com.zy.core.model.ShuttleSlave;
+import com.zy.core.model.protocol.LiftProtocol;
+import com.zy.core.model.protocol.LiftStaProtocol;
 import com.zy.core.model.protocol.NyShuttleProtocol;
 import com.zy.core.properties.SlaveProperties;
+import com.zy.core.thread.LiftThread;
 import com.zy.core.thread.NyShuttleThread;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -41,6 +48,8 @@
     private WrkChargeMapper wrkChargeMapper;
     @Autowired
     private CommonService commonService;
+    @Autowired
+    private BasDevpService basDevpService;
 
     /**
      * 璋冨害杞﹁締-璋冨害鎸囧畾绌挎杞�
@@ -73,7 +82,12 @@
 
             if (currentLocNo.equals(locNo)) {
                 //杞﹁締褰撳墠浣嶇疆宸茬粡鏄洰鏍囧簱浣嶏紝璋冨害璇ヨ溅
-                shuttleMoveGenerate(wrkNo, locNo, shuttleProtocol.getShuttleNo().intValue());
+                //缁欏伐浣滄。缁戝畾灏忚溅鍙�
+                WrkMast wrkMast1 = wrkMastMapper.selectByWorkNo(wrkNo);
+                if (wrkMast1 != null) {
+                    wrkMast1.setShuttleNo(shuttleProtocol.getShuttleNo().intValue());
+                    wrkMastMapper.updateById(wrkMast1);
+                }
                 break;
             }
 
@@ -104,6 +118,7 @@
                 if (currentAllDistance < recentAllDistance) {
                     //濡傛灉褰撳墠妤煎眰鐨勮溅璺緞鏇村皬锛屽垯鏇存柊鏈�杩戠┛姊溅
                     recentShuttle = shuttleThread;
+                    recentAllDistance = currentAllDistance;
                 }
             }
         }else {
@@ -130,6 +145,7 @@
                 if (currentAllDistance < recentAllDistance) {
                     //濡傛灉褰撳墠妤煎眰鐨勮溅璺緞鏇村皬锛屽垯鏇存柊鏈�杩戠┛姊溅
                     recentShuttle = shuttleThread;
+                    recentAllDistance = currentAllDistance;
                 }
             }
         }
@@ -146,7 +162,7 @@
      * 灏忚溅杩佺Щ浠诲姟鐢熸垚
      */
     @Transactional
-    private boolean shuttleMoveGenerate(Integer wrkNo, String locNo, Integer shuttleNo) {
+    public boolean shuttleMoveGenerate(Integer wrkNo, String locNo, Integer shuttleNo) {
         Date now = new Date();
         //鑾峰彇鍥涘悜绌挎杞︾嚎绋�
         NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleNo);
@@ -178,7 +194,33 @@
         //鍒ゆ柇鏄惁鏈夊厖鐢典换鍔℃鍦ㄤ娇鐢ㄧ┛姊溅
         WrkCharge wrkCharge = wrkChargeMapper.selectWorking(shuttleNo);
         if (wrkCharge != null) {//灏忚溅瀛樺湪鍏呯數浠诲姟锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶇敓鎴愭柊鐨勪换鍔�
-            return false;
+            //鍒ゆ柇鐩爣鐐规槸鍚︿负鍏呯數妗╋紝濡傛灉鏄幓鍏呯數鍒欐斁琛�
+            boolean toCharge = false;//鍘诲厖鐢电洰鏍�
+            for (ShuttleChargeType chargeType : ShuttleChargeType.values()) {
+                if (chargeType.locNo.equals(locNo)) {
+                    toCharge = true;//鍘诲厖鐢垫々
+                    break;
+                }
+            }
+
+            if (!toCharge) {
+                //涓嶆槸鍘诲厖鐢垫々涓斿瓨鍦ㄥ厖鐢典换鍔★紝绂佹鐢熸垚鏂扮殑绉诲姩浠诲姟
+                return false;
+            }
+        }
+
+        Integer sourceStaNo = null;//灏忚溅鎹㈠眰婧愮珯鐐�
+        Integer staNo = null;//灏忚溅鎹㈠眰鐩爣绔欑偣
+        if (Utils.getLev(locNo) != shuttleProtocol.getPoint().getZ()) {
+            //鐩爣搴撲綅鍜屽皬杞﹀簱浣嶅浜庝笉鍚屼竴妤煎眰锛岄渶瑕侀�氳繃鎻愬崌鏈鸿皟搴�
+            //鑾峰彇绌挎杞︽渶杩戜笖绌洪棽鐨勬彁鍗囨満杈撻�佺珯鐐�
+            LiftStaProtocol liftSta = this.getRecentLiftSta(shuttleNo);
+            if (liftSta == null) {
+                return false;//娌℃湁鍙敤涓旂┖闂茬殑杈撻�佺珯鐐�
+            }
+            sourceStaNo = liftSta.getStaNo();//婧愮珯鐐�
+            //鎻愬崌鏈哄彿*100+鐩爣妤煎眰=鐩爣绔欑偣
+            staNo = liftSta.getLiftNo() * 100 + Utils.getLev(locNo);//鐩爣绔�
         }
 
         // 鑾峰彇宸ヤ綔鍙�
@@ -193,6 +235,8 @@
         wrkMast.setShuttleNo(shuttleNo);//绌挎杞﹀彿
         wrkMast.setSourceLocNo(shuttleProtocol.getCurrentLocNo()); // 婧愬簱浣� => 灏忚溅褰撳墠搴撲綅鍙�
         wrkMast.setLocNo(locNo); // 鐩爣搴撲綅
+        wrkMast.setSourceStaNo(sourceStaNo);//婧愮珯
+        wrkMast.setStaNo(staNo);//鐩爣绔�
         wrkMast.setPicking("N"); // 鎷f枡
         wrkMast.setExitMk("N"); // 閫�鍑�
         wrkMast.setLinkMis("N");
@@ -214,4 +258,70 @@
         return true;
     }
 
+    /**
+     * 鑾峰彇绌挎杞︽渶杩戜笖绌洪棽鐨勬彁鍗囨満杈撻�佺珯鐐�
+     */
+    public LiftStaProtocol getRecentLiftSta(Integer shuttleNo) {
+        //鑾峰彇鍥涘悜绌挎杞︾嚎绋�
+        NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleNo);
+        if (shuttleThread == null) {
+            return null;
+        }
+        NyShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
+        if (shuttleProtocol == null) {
+            return null;
+        }
+
+        //鑾峰彇灏忚溅鍚屼竴妤煎眰鐨勭珯鐐�
+        ArrayList<LiftStaProtocol> list = new ArrayList<>();
+        int lev = Utils.getLev(shuttleProtocol.getCurrentLocNo());//灏忚溅妤煎眰
+        for (LiftSlave slave : slaveProperties.getLift()) {
+            LiftThread liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, slave.getId());
+            if (liftThread == null) {
+                continue;
+            }
+            LiftProtocol liftProtocol = liftThread.getLiftProtocol();
+            if (liftProtocol == null) {
+                continue;
+            }
+            if (!liftProtocol.isIdle()) {
+                continue;
+            }
+
+            LiftStaProtocol liftStaProtocol = NyLiftUtils.getLiftStaByLev(slave.getId(), lev);
+            if (liftStaProtocol == null) {
+                continue;
+            }
+
+            list.add(liftStaProtocol);
+        }
+
+        if (list.isEmpty()) {
+            return null;
+        }
+
+        String currentLocNo = shuttleProtocol.getCurrentLocNo();//灏忚溅浣嶇疆
+        Integer recentAllDistance = 9999999;
+        LiftStaProtocol recentSta = null;//鏈�杩戠珯鐐�
+        //鎼滅储璺濈灏忚溅鏈�杩戠殑绔欑偣
+        for (LiftStaProtocol liftStaProtocol : list) {
+            Integer staNo = liftStaProtocol.getStaNo();//绔欑偣鍙�
+            String locNo = liftStaProtocol.getLocNo();//绔欑偣搴撲綅鍙�
+
+            //褰撳墠绌挎杞︾嚎绋嬪埌鐩爣鍦扮偣璺濈
+            List<NavigateNode> currentShuttlePath = NavigateUtils.calc(currentLocNo, locNo, NavigationMapType.NORMAL.id, Utils.getShuttlePoints(shuttleNo, Utils.getLev(currentLocNo)));//浣跨敤姝e父閫氶亾鍦板浘
+            if (currentShuttlePath == null) {
+                continue;
+            }
+            Integer currentAllDistance = NavigateUtils.getOriginPathAllDistance(currentShuttlePath);//璁$畻褰撳墠璺緞琛岃蛋鎬昏窛绂�
+            if (currentAllDistance < recentAllDistance) {
+                //濡傛灉褰撳墠妤煎眰鐨勮溅璺緞鏇村皬锛屽垯鏇存柊鏈�杩戠珯鐐�
+                recentSta = liftStaProtocol;
+                recentAllDistance = currentAllDistance;
+            }
+        }
+
+        return recentSta;
+    }
+
 }

--
Gitblit v1.9.1