From 3cba497c498c3833fdc266d99e07bc3c2d16e658 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期五, 11 四月 2025 09:02:28 +0800
Subject: [PATCH] 1

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   90 ++++++++++++++++++++++++++++++++++----------
 1 files changed, 69 insertions(+), 21 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 162bc07..efe8350 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -91,24 +91,6 @@
     @Autowired
     private LiftAction liftAction;
 
-    //鍏ュ簱绔欑偣
-    public static final ArrayList<Integer> inSta = new ArrayList<Integer>() {{
-        add(1012);
-        add(1014);
-        add(1022);
-        add(1025);
-        add(1032);
-    }};
-
-    //鍑哄簱绔欑偣
-    public static final ArrayList<Integer> outSta = new ArrayList<Integer>() {{
-        add(1012);
-        add(1014);
-        add(1022);
-        add(1025);
-        add(1032);
-    }};
-
 
     private boolean isInEnable(DevpThread devpThread, Integer staNo) {
         if (staNo == null) {
@@ -180,7 +162,7 @@
      */
     public synchronized void generateInboundWrk() {
         try {
-            DevpSlave devpSlave = slaveProperties.getDevpSlave().get(0);
+            DevpSlave devpSlave = slaveProperties.getDevp().get(0);
             // 閬嶅巻鍏ュ簱鍙�
             for (DevpSlave.Sta inSta : devpSlave.getInSta()) {
                 // 鑾峰彇鍏ュ簱绔欎俊鎭�
@@ -232,7 +214,6 @@
                     }
                     continue;
                 }
-
                 // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                 if (staProtocol.isAutoing() && staProtocol.isLoading()
                         && isInEnable(devpThread, inSta.getStaNo())
@@ -243,7 +224,6 @@
                     if (!Cools.isEmpty(barcode)) {
                         News.info("鏉$爜鎵弿鍣ㄦ娴嬫潯鐮佷俊鎭細{}", barcode);
                     }
-
                     // 鍒ゆ柇閲嶅宸ヤ綔妗�
                     WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
                             .eq("source_sta_no", inSta.getStaNo())
@@ -336,6 +316,74 @@
 
 
     /**
+     * 鍑哄簱鍒板嚭搴撳彛
+     */
+    public synchronized void stnToOutStn() {
+        DevpSlave devpSlave = slaveProperties.getDevp().get(0);
+        // 閬嶅巻鍫嗗灈鏈哄嚭搴撶珯
+        for (DevpSlave.Sta outSta : devpSlave.getOutSta()) {
+            // 鑾峰彇鍫嗗灈鏈哄嚭搴撶珯淇℃伅
+            DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devpSlave.getId());
+            StaProtocol staProtocol = devpThread.getStation().get(outSta.getStaNo());
+            if (staProtocol == null) {
+                continue;
+            } else {
+                staProtocol = staProtocol.clone();
+            }
+            if (staProtocol.isAutoing() && staProtocol.isLoading() && (staProtocol.getWorkNo() == 0 || staProtocol.getStaNo() == null)) {
+                // 鏌ヨ宸ヤ綔妗�
+//                WrkMast wrkMast = wrkMastMapper.selectPakOutStep2(staProtocol.getSiteId());
+//                if (wrkMast == null) {
+//                    continue;
+//                }
+//                // 鍒ゆ柇宸ヤ綔妗f潯浠�
+//                if (wrkMast.getIoType() < 100 || wrkMast.getStaNo() == null || wrkMast.getSourceStaNo() == null) {
+//
+//                }
+
+                //  鍒ゆ柇杈撻�佺嚎鍜屽皬杞︾姸鎬佺姸鎬佺瓑寰呯‘璁�
+//                if (crnProtocol.modeType == CrnModeType.AUTO && crnProtocol.getTaskNo().equals(wrkMast.getWrkNo().shortValue())
+//                        && crnProtocol.statusType == CrnStatusType.WAITING
+//                        && crnProtocol.forkPosType == CrnForkPosType.HOME) {
+//                    log.info("鍫嗗灈鏈哄嚭搴撳畬鎴� - 寮�濮嬫墽琛�");
+//
+//                    // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
+//
+//                    // 涓嬪彂绔欑偣淇℃伅
+//                    staProtocol.setWorkNo(wrkMast.getWrkNo());
+//                    staProtocol.setStaNo(RouteUtils.CrnStaEnd(wrkMast.getStaNo(), wrkMast.getSourceStaNo()));
+//                    if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) {
+//                        log.info(staProtocol.getWorkNo() + "," + staProtocol.getStaNo() + "杈撻�佺嚎鍑哄簱鍛戒护涓嬪彂澶辫触");
+//                        continue;
+//                    } else {
+//                        log.info(staProtocol.getWorkNo() + "," + staProtocol.getStaNo() + "杈撻�佺嚎鍑哄簱鍛戒护涓嬪彂鎴愬姛");
+//                    }
+//
+//                    // 鏇存柊宸ヤ綔妗g姸鎬佷负14澶辫触
+//                    wrkMast.setWrkSts(14L);
+//                    wrkMast.setCrnEndTime(new Date());
+//                    if (wrkMastMapper.updateById(wrkMast) != 0) {
+//                        // 澶嶄綅鍫嗗灈鏈�
+//                        log.error("鍑哄簱浠诲姟瀹屾垚涓嬪彂鍫嗗灈鏈哄浣�,{}", wrkMast.getWrkNo());
+//                        crnThread.setResetFlag(true);
+//                    } else {
+//                        News.error("" + mark + " - 1" + " - 鏇存柊宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负14澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", wrkMast.getWrkNo());
+//                    }
+//
+//                } else {
+//                    News.errorNoLog("" + mark + " - 6" + " - 鍫嗗灈鏈轰俊鎭笉绗﹀悎鍏ュ簱鏉′欢锛侊紒锛�"
+//                            + " 鍫嗗灈鏈虹姸鎬侊細" + crnProtocol.modeType + "==鑷姩AUTO锛�" + CrnModeType.AUTO
+//                            + "銆佸爢鍨涙満浠诲姟鍙凤細" + crnProtocol.getTaskNo() + "==宸ヤ綔妗d换鍔″彿锛�" + wrkMast.getWrkNo().shortValue()
+//                            + "銆佺姸鎬佹灇涓撅細" + crnProtocol.statusType + "==WAITING锛�90 //浠诲姟瀹屾垚绛夊緟WCS纭)锛�" + CrnStatusType.WAITING
+//                            + "銆佽揣鍙変綅缃細" + crnProtocol.forkPosType + "==HOME锛�0  // 璐у弶鍘熶綅锛�" + CrnForkPosType.HOME);
+//                }
+
+            }
+        }
+    }
+
+
+    /**
      * 鍒濆鍖栧疄鏃跺湴鍥�
      */
     public synchronized void initRealtimeBasMap() {

--
Gitblit v1.9.1