From 58eaf5e73359f7164525d9c50f6e5bf82b247e32 Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期四, 24 四月 2025 09:10:58 +0800
Subject: [PATCH] 初步调试

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  196 +++++++++++++++++++++++++++++++++++-------------
 1 files changed, 141 insertions(+), 55 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 7dd60f7..42bebb2 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -40,6 +40,7 @@
 import com.zy.system.service.ConfigService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import java.util.*;
@@ -98,6 +99,8 @@
     private LiftAction liftAction;
     @Autowired
     private BasWrkStatusService wrkStatusService;
+    @Value("${asrs.wmsUrl}")
+    private String wmsUrl;
 
 
     public boolean isInEnable(DevpThread devpThread, Integer staNo) {
@@ -184,8 +187,8 @@
                     if (staProtocol.isAutoing() && staProtocol.isLoading() && isInEnable(devpThread, inSta.getStaNo()) && !staProtocol.isEmptyMk() && (workNo == 0 || (workNo >= 9990 && workNo <= 9999)) && staProtocol.isPakMk()) {
                         String barcode = staProtocol.getBarcode();
                         // 鍒ゆ柇閲嶅宸ヤ綔妗�
-                        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_sta_no", inSta.getStaNo()).eq("wrk_sts", WrkStsType.NEW_INBOUND.sts).eq("barcode", barcode));
-                        if (wrkMast != null) {
+                        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_sta_no", inSta.getStaNo()).eq("barcode", barcode));
+                        if (wrkMast != null && wrkMast.getWrkSts() == WrkStsType.NEW_INBOUND.sts) {
                             News.error("宸ヤ綔妗e凡瀛樺湪,宸ヤ綔鍙�={}", wrkMast.getWrkNo());
                             //鍒ゆ柇鏃舵彁鍗囨満渚э紝杩樻槸鏃犳彁鍗囨満娴�
                             staProtocol.setWorkNo(Short.parseShort(String.valueOf(wrkMast.getWrkNo())));
@@ -195,14 +198,15 @@
                             wrkMast.setWrkSts(WrkStsType.INBOUND_DEVICE_RUN.sts);
                             wrkMast.setModiTime(new Date());
                             wrkMastService.updateById(wrkMast);
+                        } else if (wrkMast != null && wrkMast.getWrkSts() != WrkStsType.NEW_INBOUND.sts) {
+                            continue;
                         }
                         try {
-                            String wmsUrl = "192.168.10.201:8080/fyxcwms";
                             SearchLocParam param = new SearchLocParam();
                             param.setBarcode(barcode);
                             param.setIoType(1);
                             param.setSourceStaNo(inSta.getStaNo());
-                            param.setLocType1(staProtocol.getLocType1().shortValue());
+                            param.setLocType1((short) 1);
                             String response = new HttpHandler.Builder()
                                     .setUri(wmsUrl)
                                     .setPath("/rpc/pakin/loc/v1")
@@ -257,10 +261,58 @@
                                 News.error("鍏ュ簱鐢宠澶辫触锛屼换鍔℃暟鎹�={}锛岃姹傚搷搴�={}", JSON.toJSON(param), JSON.toJSON(jsonObject));
                             }
                         } catch (Exception e) {
-                            e.printStackTrace();
+                            log.error("璋冪敤wms鎶ラ敊1锛寋}", e.getMessage());
                         }
                     }
+                } else if (inSta.getStaNo() == 1012 || inSta.getStaNo() == 1022) {
+                    // 鑾峰彇鍏ュ簱绔欎俊鎭�
+                    DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
+                    StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
+                    if (staProtocol == null) {
+                        continue;
+                    } else {
+                        staProtocol = staProtocol.clone();
+                    }
+                    Short workNo = staProtocol.getWorkNo();
+                    if (staProtocol.isAutoing() && staProtocol.isLoading() && isInEnable(devpThread, inSta.getStaNo()) && !staProtocol.isEmptyMk() && (workNo == 0 || (workNo >= 9990 && workNo <= 9999)) && staProtocol.isPakMk()) {
+                        String barcode = staProtocol.getBarcode();
+                        // 鍒ゆ柇閲嶅宸ヤ綔妗�
+                        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_sta_no", inSta.getStaNo()).eq("barcode", barcode));
+                        if (wrkMast == null) {
+                            try {
+                                SearchLocParam param = new SearchLocParam();
+                                param.setBarcode(barcode);
+                                param.setIoType(1);
+                                param.setSourceStaNo(inSta.getStaNo());
+                                param.setLocType1((short) 1);
+                                String response = new HttpHandler.Builder()
+                                        .setUri(wmsUrl)
+                                        .setPath("/rpc/pakin/loc/v1")
+                                        .setJson(JSON.toJSONString(param))
+                                        .build()
+                                        .doPost();
+                                JSONObject jsonObject = JSON.parseObject(response);
+                                Integer code = jsonObject.getInteger("code");
+                                if (code.equals(200)) {
 
+                                } else {
+                                    String msg = jsonObject.getString("msg");
+                                    HashMap<String, String> hashMap = new HashMap<>();
+                                    hashMap.put("msg", msg);
+                                    hashMap.put("sta", inSta.getStaNo().toString());
+                                    new HttpHandler.Builder()
+                                            .setUri(wmsUrl)
+                                            .setPath("/rpc/led/getError")
+                                            .setJson(JSON.toJSONString(hashMap))
+                                            .build()
+                                            .doPost();
+                                    News.error("鍏ュ簱鐢宠澶辫触锛屼换鍔℃暟鎹�={}锛岃姹傚搷搴�={}", JSON.toJSON(param), JSON.toJSON(jsonObject));
+                                }
+                            } catch (Exception e) {
+                                log.error("璋冪敤wms鎶ラ敊2锛寋}", e.getMessage());
+                            }
+                        }
+                    }
                 }
             }
         } catch (Exception e) {
@@ -300,7 +352,7 @@
                 if (wrkMast.getStaNo() == 1026) {
                     locNo = "1200305";
                 }
-                boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleS(wrkMast.getWrkNo(), locNo, wrkMast.getLocNo(), "TRANSPORT_DEVP");
+                boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleNoLift(wrkMast.getWrkNo(), locNo, wrkMast.getLocNo(), "TRANSPORT_DEVP");
                 if (!dispatchShuttle) {
                     News.info("{}浠诲姟锛岃皟搴﹀皬杞﹀け璐�", wrkMast.getWrkNo());
                     continue;
@@ -347,18 +399,10 @@
             if (wrkMast.getStaNo() == 1024) {
                 locNo = "1200305";
             }
-            boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleS(wrkMast.getWrkNo(), wrkMast.getSourceLocNo(), locNo, "TRANSPORT_DEVP");
+            boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleNoLift(wrkMast.getWrkNo(), wrkMast.getSourceLocNo(), locNo, "TRANSPORT_DEVP");
             if (!dispatchShuttle) {
                 News.info("{}浠诲姟锛岃皟搴﹀皬杞﹀け璐�", wrkMast.getWrkNo());
                 continue;
-            } else {
-                WrkMast wrkMast1 = wrkMastService.selectByMainWrkNo(wrkMast.getWrkNo());
-                if (wrkMast1 == null) {
-                    News.info("{}浠诲姟锛岃皟搴﹀皬杞﹀け璐�,缁堜簬鍙戠幇浜�", wrkMast.getWrkNo());
-                    continue;
-                } else {
-                    News.info("{}浠诲姟锛屾棤鎻愬崌鏈哄璋冨害灏忚溅鎴愬姛", wrkMast.getWrkNo());
-                }
             }
 
             wrkMast.setWrkSts(WrkStsType.OUTBOUND_SHUTTLE_RUN.sts);
@@ -769,7 +813,7 @@
 //    }
     public synchronized void liftInExecute() {
         try {
-            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", WrkStsType.NEW_INBOUND.sts, WrkStsType.INBOUND_DEVICE_RUN.sts, WrkStsType.INBOUND_LIFT_RUN_COMPLETE.sts).in("source_sta_no", 1012, 1022));
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", WrkStsType.NEW_INBOUND.sts, WrkStsType.INBOUND_DEVICE_RUN.sts, WrkStsType.INBOUND_LIFT_RUN_COMPLETE.sts).in("source_sta_no", 1012, 1022, 1031));
             for (WrkMast wrkMast : wrkMasts) {
                 boolean step0 = this.liftInExecuteStep0(wrkMast);//璁惧涓婅蛋
                 if (!step0) {
@@ -814,11 +858,13 @@
                 News.info("{}浠诲姟锛寋}绔欑偣锛屾棤鎵樼洏", wrkMast.getWrkNo(), staProtocol.getSiteId());
                 return false;
             }
-
-            if (!staProtocol.getBarcode().equals(wrkMast.getBarcode())) {
-                News.info("{}浠诲姟锛寋}绔欑偣锛屾墭鐩樼爜涓嶅尮閰嶏紝绔欑偣鎵樼洏鐮侊細{}锛屼换鍔℃墭鐩樼爜锛歿}", wrkMast.getWrkNo(), staProtocol.getSiteId(), staProtocol.getBarcode(), wrkMast.getBarcode());
-                return false;
+            if (wrkMast.getSourceStaNo() != 1031) {
+                if (!staProtocol.getBarcode().equals(wrkMast.getBarcode())) {
+                    News.info("{}浠诲姟锛寋}绔欑偣锛屾墭鐩樼爜涓嶅尮閰嶏紝绔欑偣鎵樼洏鐮侊細{}锛屼换鍔℃墭鐩樼爜锛歿}", wrkMast.getWrkNo(), staProtocol.getSiteId(), staProtocol.getBarcode(), wrkMast.getBarcode());
+                    return false;
+                }
             }
+
             //鍒ゆ柇鎻愬崌鏈烘槸鍚︽湁鍏朵粬浠诲姟
             WrkMast liftWrkMast = wrkMastService.selectLiftWrkMastAndWrkNo(1, wrkMast.getWrkNo(), wrkMast.getMainWrkNo());
             if (liftWrkMast != null) {
@@ -831,6 +877,8 @@
             short staNo = 1012;
             if (wrkMast.getSourceStaNo() == 1022) {
                 staNo = 1023;
+            } else if (wrkMast.getSourceStaNo() == 1031) {
+                staNo = 1032;
             }
 
             staProtocol = staProtocol.clone();
@@ -897,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);
@@ -918,17 +968,14 @@
                     News.info("{}浠诲姟锛寋}绔欑偣锛屼换鍔″彿涓嶄竴鑷�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
-                if (!station.get(1022).getBarcode().equals(wrkMast.getBarcode())) {
-                    News.info("{}浠诲姟锛寋}绔欑偣锛屾墭鐩樼爜涓嶅尮閰嶏紝绔欑偣鎵樼洏鐮侊細{}锛屼换鍔℃墭鐩樼爜锛歿}", wrkMast.getWrkNo(), staProtocol.getSiteId(), staProtocol.getBarcode(), wrkMast.getBarcode());
-                    return false;
-                }
-            } else {
+            } else if (sourceStaNo == 1012) {
                 if (staProtocol.getWorkNo().intValue() != wrkMast.getWrkNo()) {
                     News.info("{}浠诲姟锛寋}绔欑偣锛屼换鍔″彿涓嶄竴鑷�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
-                if (!staProtocol.getBarcode().equals(wrkMast.getBarcode())) {
-                    News.info("{}浠诲姟锛寋}绔欑偣锛屾墭鐩樼爜涓嶅尮閰嶏紝绔欑偣鎵樼洏鐮侊細{}锛屼换鍔℃墭鐩樼爜锛歿}", wrkMast.getWrkNo(), staProtocol.getSiteId(), staProtocol.getBarcode(), wrkMast.getBarcode());
+            } else if (sourceStaNo == 1032) {
+                if (staProtocol.getFinishWorkNo().intValue() != wrkMast.getWrkNo()) {
+                    News.info("{}浠诲姟锛寋}绔欑偣锛屼换鍔″彿涓嶄竴鑷�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
             }
@@ -936,6 +983,8 @@
             String locNo = "0200305";
             if (wrkMast.getSourceStaNo() == 1012) {
                 locNo = "0200301";
+            } else if (wrkMast.getSourceStaNo() == 1032) {
+                locNo = "0200308";
             }
             boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleS(wrkMast.getWrkNo(), locNo, wrkMast.getLocNo(), "TRANSPORT_LIFT");
             if (!dispatchShuttle) {
@@ -943,9 +992,11 @@
                 return false;
             }
 
-            int lev = 105;
-            if (wrkMast.getSourceStaNo() == 1012) {
-                lev = 101;
+            int lev = 101;
+            if (wrkMast.getSourceStaNo() == 1021) {
+                lev = 100 + Utils.getLev(wrkMast.getLocNo());
+            } else if (wrkMast.getSourceStaNo() == 1031) {
+                lev = 100 + Utils.getLev(wrkMast.getLocNo());
             }
             //鑾峰彇鎻愬崌鏈哄懡浠�
             List<LiftCommand> liftCommands = liftThread.getPalletInCommand(wrkMast.getWrkNo(), sourceStaNo, lev);
@@ -1034,7 +1085,7 @@
 
     public synchronized void liftOutExecute() {
         try {
-            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", WrkStsType.NEW_OUTBOUND.sts, WrkStsType.OUTBOUND_SHUTTLE_RUN_COMPLETE.sts).in("sta_no", 1011, 1021));
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", WrkStsType.NEW_OUTBOUND.sts, WrkStsType.OUTBOUND_SHUTTLE_RUN_COMPLETE.sts).in("sta_no", 1011, 1021, 1031));
             for (WrkMast wrkMast : wrkMasts) {
                 boolean step1 = this.liftOutExecuteStep1(wrkMast);//瑙﹀彂鎼繍浠诲姟
                 if (!step1) {
@@ -1069,15 +1120,23 @@
                 News.info("{}浠诲姟锛寋}绔欑偣锛屼笉鍦ㄨ嚜鍔ㄧ姸鎬�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                 return false;
             }
-
-            if (!isOutEnable(devpThread, wrkMast.getStaNo())) {
-                News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
-                return false;
+            if (wrkMast.getStaNo() == 1031) {
+//                if (staProtocol.getOutInModel() != 1) {
+//                    News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
+//                    return false;
+//                }
+            } else {
+                if (!isOutEnable(devpThread, wrkMast.getStaNo())) {
+                    News.info("{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
+                    return false;
+                }
             }
 
             String locNo = "0200305";
             if (wrkMast.getStaNo() == 1011) {
                 locNo = "0200301";
+            } else if (wrkMast.getStaNo() == 1031) {
+                locNo = "0200308";
             }
             boolean dispatchShuttle = shuttleDispatchUtils.searchDispatchShuttleS(wrkMast.getWrkNo(), wrkMast.getSourceLocNo(), locNo, "TRANSPORT_LIFT");
             if (!dispatchShuttle) {
@@ -1156,9 +1215,12 @@
             //鑾峰彇鎻愬崌鏈哄懡浠�
             List<LiftCommand> liftCommands = liftThread.getPalletOutCommand(wrkMast.getWrkNo(), sourceLev, wrkMast.getStaNo());
             LiftCommand liftCommand = liftCommands.get(0);
-
-            int deviceWrk = commonService.getWorkNo(8);//鐢熸垚鎻愬崌鏈鸿澶囧伐浣滃彿
-            liftCommand.setTaskNo(deviceWrk);//鏇存崲闅忔満浠诲姟鍙�
+            if ( wrkMast.getStaNo()==1031){
+                liftCommand.setTaskNo(wrkMast.getWrkNo());
+            }else {
+                int deviceWrk = commonService.getWorkNo(8);//鐢熸垚鎻愬崌鏈鸿澶囧伐浣滃彿
+                liftCommand.setTaskNo(deviceWrk);//鏇存崲闅忔満浠诲姟鍙�
+            }
 
             ArrayList<LiftCommand> commands = new ArrayList<>();
             commands.add(liftCommand);
@@ -1174,6 +1236,7 @@
             wrkMast.setLiftNo(liftProtocol.getLiftNo());//鎻愬墠閿佸畾鎻愬崌鏈�
             wrkMast.setSystemMsg("");//娓呯┖娑堟伅
             wrkMast.setModiTime(now);
+
             if (wrkMastService.updateById(wrkMast)) {
                 //涓嬪彂浠诲姟
                 liftAction.assignWork(wrkMast.getLiftNo(), assignCommand);
@@ -1515,7 +1578,11 @@
                             wrkMast.setWrkSts(WrkStsType.INBOUND_LIFT_RUN_COMPLETE.sts);
                         } else if (wrkMast.getWrkSts() == WrkStsType.OUTBOUND_LIFT_RUN.sts) {
                             //104.鎻愬崌鏈烘惉杩愪腑 ==> 109.鍑哄簱瀹屾垚
-                            wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
+                            if (wrkMast.getStaNo() == 1031) {
+                                wrkMast.setWrkSts(WrkStsType.OUTBOUND_DEVP_RUN_2.sts);
+                            } else {
+                                wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
+                            }
                             wrkMast.setLiftNo(null);//閲婃斁鎻愬崌鏈�
                         } else if (wrkMast.getWrkSts() == WrkStsType.MOVE_LIFT_RUN.sts) {
                             //306.鎻愬崌鏈烘惉杩愪腑 ==> 307.鎻愬崌鏈烘惉杩愬畬鎴�
@@ -1542,7 +1609,6 @@
                             //鎻愬崌鏈鸿嚦灏忚溅灞� ==> 鎻愬崌鏈鸿嚦灏忚溅灞傚畬鎴�
                             wrkMast.setWrkSts(WrkStsType.MOVE_OUT_NO_LIFT_5.sts);
                         }
-
                         wrkMast.setModiTime(new Date());
                         if (wrkMastService.updateById(wrkMast)) {
                             liftThread.setSyncTaskNo(0);
@@ -1568,9 +1634,24 @@
             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);
+                        wrkMast.setModiTime(new Date());
+                        if (wrkMastService.updateById(wrkMast)) {
+                            News.info("杈撻�佺嚎宸茬‘璁や笖浠诲姟瀹屾垚鐘舵�併�傝緭閫佺嚎鍙�={},瀹岀粨宸ヤ綔鍙�={}", staProtocol.getSiteId(), staProtocol.getFinishWorkNo());
+                        } else {
+                            News.error("杈撻�佺嚎宸茬‘璁や笖浠诲姟瀹屾垚鐘舵��,澶嶄綅澶辫触锛屼絾鏈壘鍒板伐浣滄。銆傝緭閫佺嚎鍙�={}锛屽畬缁撳伐浣滃彿={}", staProtocol.getSiteId(), staProtocol.getFinishWorkNo());
+                        }
+                    }
+                } 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)) {
@@ -2079,11 +2160,17 @@
     }
 
     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()));
         if (Utils.getRow(liftLocNo) == Utils.getRow(wrkMast.getSourceLocNo()) && Utils.getBay(liftLocNo) == Utils.getBay(wrkMast.getSourceLocNo())) {
             //鍙栬揣浣嶇疆鏄彁鍗囨満
@@ -2095,12 +2182,13 @@
     }
 
     private void shuttleMoveExecuteTransportNoLift(WrkMast wrkMast) {
-        if (12 == Utils.getRow(wrkMast.getSourceLocNo()) && 3 == Utils.getBay(wrkMast.getSourceLocNo())) {
+        WrkMast mainWrk = wrkMastService.selectByWorkNo(wrkMast.getMainWrkNo());
+        if (mainWrk != null && mainWrk.getIoType() == 1) {
             //鍏ュ簱
-            noLiftInService.shuttleMoveExecute(wrkMast);
-        } else {
+            noLiftInService.shuttleMoveExecute(wrkMast, mainWrk.getStaNo(), Utils.getLev(mainWrk.getLocNo()));
+        } else if (mainWrk != null && mainWrk.getIoType() == 101) {
             //鍑哄簱
-            noLiftOutService.shuttleMoveExecute(wrkMast);
+            noLiftOutService.shuttleMoveExecute(wrkMast, mainWrk.getStaNo(), Utils.getLev(mainWrk.getSourceLocNo()));
         }
     }
 
@@ -2112,15 +2200,13 @@
         try {
             // 鏍规嵁杈撻�佺嚎plc閬嶅巻
             FyDevpThread devpThread = (FyDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
-            WrkMast pakout = wrkMastMapper.selectWorkingPakout(1032);
+            WrkMast pakout = wrkMastService.selectWorkingPakout(1031);
             if (pakout != null) {
                 if (devpThread.ioModeOf2_5 != IoModeType.PAKOUT_MODE) {
                     // 鍑哄簱鍒囨崲涓�
-                    devpThread.ioModeOf2_5 = IoModeType.PAKOUT_BOOTING;
-                    WrkMast pakin = wrkMastMapper.selectWorkingPakin(1032);
-                    if (pakin == null && !devpThread.getStation().get(inSta.getStaNo()).isLoading()
-                            && !devpThread.getStation().get(inSta.getBackSta()).isLoading()
-                            && devpThread.getStation().get(inSta.getBackSta()).getWorkNo() == 0) {
+                    WrkMast pakin = wrkMastService.selectWorkingPakin(1032);
+                    if (pakin == null && !devpThread.getStation().get(1031).isLoading()
+                            && !devpThread.getStation().get(1032).isLoading()) {
                         // 鍑哄簱妯″紡
                         devpThread.ioModeOf2_5 = IoModeType.PAKOUT_MODE;
                     }

--
Gitblit v1.9.1