From 0641b66a7724bda815e667feeb832e2f755d18cb Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期二, 22 四月 2025 21:07:06 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/fyxc_shuttle_wcs' into fyxc_shuttle_wcs

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   35 +++++++++++++++++++++++------------
 1 files changed, 23 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index fcb7843..3a111cd 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -877,7 +877,7 @@
             short staNo = 1012;
             if (wrkMast.getSourceStaNo() == 1022) {
                 staNo = 1023;
-            } else if (wrkMast.getSourceStaNo() == 1032) {
+            } else if (wrkMast.getSourceStaNo() == 1031) {
                 staNo = 1032;
             }
 
@@ -945,6 +945,8 @@
             Integer sourceStaNo = wrkMast.getSourceStaNo();
             if (wrkMast.getSourceStaNo() == 1022) {
                 sourceStaNo = 1023;
+            } else if (wrkMast.getSourceStaNo() == 1031) {
+                sourceStaNo = 1032;
             }
 
             StaProtocol staProtocol = station.get(sourceStaNo);
@@ -972,7 +974,7 @@
                     return false;
                 }
             } else if (sourceStaNo == 1032) {
-                if (staProtocol.getWorkNo().intValue() != wrkMast.getWrkNo()) {
+                if (staProtocol.getFinishWorkNo().intValue() != wrkMast.getWrkNo()) {
                     News.info("{}浠诲姟锛寋}绔欑偣锛屼换鍔″彿涓嶄竴鑷�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
@@ -1121,11 +1123,10 @@
                 return false;
             }
             if (wrkMast.getStaNo() == 1031) {
-                //TODO
-                if (staProtocol.getOutInModel() != 1) {
-                    News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
-                    return false;
-                }
+//                if (staProtocol.getOutInModel() != 1) {
+//                    News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
+//                    return false;
+//                }
             } else {
                 if (!isOutEnable(devpThread, wrkMast.getStaNo())) {
                     News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
@@ -1628,7 +1629,7 @@
             Map<Integer, StaProtocol> station = devpThread.getStation();
             WrkMast wrkMast = null;
             for (StaProtocol staProtocol : station.values()) {
-                if (staProtocol.getSiteId() == 1013 || staProtocol.getSiteId() == 1024) {
+                if ((staProtocol.getSiteId() == 1013 || staProtocol.getSiteId() == 1024) && staProtocol.isLoading()) {
                     wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", staProtocol.getFinishWorkNo()).eq("wrk_sts", WrkStsType.OUTBOUND_DEVP_RUN.sts));
                     if (wrkMast != null) {
                         wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
@@ -1639,9 +1640,13 @@
                             News.error("杈撻�佺嚎宸茬‘璁や笖浠诲姟瀹屾垚鐘舵��,澶嶄綅澶辫触锛屼絾鏈壘鍒板伐浣滄。銆傝緭閫佺嚎鍙�={}锛屽畬缁撳伐浣滃彿={}", staProtocol.getSiteId(), staProtocol.getFinishWorkNo());
                         }
                     }
-                } else if (staProtocol.getSiteId() == 1031) {
+                } else if (staProtocol.getSiteId() == 1031 && staProtocol.isLoading()) {
                     wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", staProtocol.getFinishWorkNo()).eq("wrk_sts", WrkStsType.OUTBOUND_DEVP_RUN_2.sts));
                     if (wrkMast != null) {
+                        staProtocol.setWorkNo(Short.parseShort(String.valueOf(wrkMast.getWrkNo())));
+                        staProtocol.setStaNo(Short.parseShort(String.valueOf(1135)));
+                        MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
+                        News.info("杈撻�佺嚎鍏ュ簱鍛戒护涓嬪彂锛屼换鍔℃暟鎹�={}", JSON.toJSON(wrkMast));
                         wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
                         wrkMast.setModiTime(new Date());
                         if (wrkMastService.updateById(wrkMast)) {
@@ -2150,9 +2155,15 @@
     }
 
     private void shuttleMoveExecuteTransportLift(WrkMast wrkMast) {
-        LiftThread liftThread = LiftUtils.getRecentLift(wrkMast.getLocNo());
-        if (liftThread == null) {
-            return;
+        WrkMast wrkMast1 = wrkMastService.selectByWorkNo(wrkMast.getMainWrkNo());
+        LiftThread liftThread;
+        if (wrkMast1 != null && wrkMast1.getLiftNo() != null) {
+            liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, 1);
+        } else {
+            liftThread = LiftUtils.getRecentLift(wrkMast.getLocNo());
+            if (liftThread == null) {
+                return;
+            }
         }
         //liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, wrkMast1.getLiftNo());
         String liftLocNo = liftThread.getLiftLocNo(Utils.getLev(wrkMast.getLocNo()));

--
Gitblit v1.9.1