From 6e64596aec723071c690edf9c878b0945fd0e37a Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期三, 19 二月 2025 10:31:58 +0800
Subject: [PATCH] 兼容四期

---
 src/main/java/com/zy/asrs/task/AutoMoveScheduler.java |   72 +++++++++++++++++++++++++++++++----
 1 files changed, 63 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
index 2182cb5..0df018b 100644
--- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
+++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
@@ -213,12 +213,12 @@
      * 浼樺厛閫夋嫨鍏堝埌鎺ラ┏浣嶏紙鎺ラ┏浣嶅彲鍏ワ級 鍚庨�夋嫨鐩存帴鍥炲簱
      * 2妤兼垨3妤肩珯鐐瑰彲鍏ヤ俊鍙峰叏閮ㄦ病鏈夛紝浠h〃璧扮數姊嚜鍔ㄦ惉杩愭ā寮�
      */
-    @Scheduled(cron = "0/2 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     private void autoEmptyBack4() {
         // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋�
         List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>()
                 // TODO 鍥涙湡
-                .eq("loc_sts", "D").eq("loc_type1", 3).ne("floor", 1).ne("lev1", 1));
+                .eq("loc_sts", "D").eq("loc_type1", 3).andNew().ne("floor", 1).or().ne("lev1", 1));
         if (agvLocMasts.isEmpty()) {
             return;
         }
@@ -236,7 +236,7 @@
      * 灏嗕簩鍘傜殑6绫诲瀷鐨勭┖璐ф灦璋冩嫧鍥炲惛濉戜簩妤�
      */
     // TODO 鍥涙湡
-    @Scheduled(cron = "0/2 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     private void autoEmptyBackSiqi() {
         // 鏌ヨ6绫诲瀷绌鸿揣鏋惰繑鍥炵殑鎵ц鏃堕棿鐐�
         Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_TIME"));
@@ -245,7 +245,7 @@
             try {
                 // 鍒ゆ柇鏄惁鍦ㄦ墽琛屾椂闂村唴
                 ProcesTimeData procesTimeData = JSONObject.parseObject(config.getValue(), ProcesTimeData.class);
-                if (procesTimeData != null && TimeUtils.between(procesTimeData)) {
+                if (procesTimeData != null && config.getStatus() == 1 && TimeUtils.between(procesTimeData)) {
                     flag = true;
                 }
             } catch (Exception e) {
@@ -255,9 +255,10 @@
             if (flag) {
                 executeLocType6();
             }
-        } else {
-            executeLocType6();
         }
+//        else {
+//            executeLocType6();
+//        }
     }
 
 
@@ -298,7 +299,6 @@
      * 鑷姩锛� 鐢熸垚 109 鑷姩鍥炴祦
      * 鎵嬪姩锛� 鐢熸垚 113 鎵嬪姩鍥炴祦
      * 浼樺厛閫夋嫨鍏堝埌鎺ラ┏浣嶏紙鎺ラ┏浣嶅彲鍏ワ級 鍚庨�夋嫨鐩存帴鍥炲簱
-     *
      */
     @Scheduled(cron = "0/2 * * * * ? ")
     private void autoEmptyBack5() {
@@ -335,8 +335,7 @@
     }
 
     /**
-     * 鑷姩绉诲簱
-     *
+     * 璺ㄥ眰鑷姩绉诲簱
      */
     @Scheduled(cron = "0/2 * * * * ? ")
     private void autoEmptyBack7() throws ParseException {
@@ -382,4 +381,59 @@
     }
 
 
+    /**
+     * 鎵撴爣璁扮殑搴撲綅杩涜鑷姩绉诲簱锛屽洓鏈�
+     * 鍦ㄥ簱浣嶄笉澶熺殑鎯呭喌涓嬶紝绠卞3鍏ュ簱鍒殑妤煎眰搴撲綅鐨勬椂鍊欙紝鏅氫笂杩涜璺ㄥ眰绉诲簱
+     */
+    @Scheduled(cron = "0/2 * * * * ? ")
+    private void autoEmptyBack8() throws ParseException {
+        Date now = new Date();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        String currentDay = sdf.format(now);
+        Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "autoTime2"));
+        if (Cools.isEmpty(config)) {
+
+        } else {
+            if (config.getStatus().intValue() == 0) {
+                return;
+            }
+            JSONObject jsonObject = JSON.parseObject(config.getValue().toString());
+            Integer maxTansk = jsonObject.getInteger("maxTansk");
+            //Integer startTime = jsonObject.getInteger("startTime");
+            String startTime = jsonObject.getString("startTime");
+            long time1 = new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(currentDay + " " + startTime).getTime();
+            long time = now.getTime();
+            long time3 = time - time1;
+
+
+            if (time3 > 0) {
+
+                List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 12));
+                if (agvWrkMasts != null && maxTansk <= agvWrkMasts.size()) {
+                    return;
+                }
+
+                List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("floor", 1).eq("loc_sts", "F").eq("loc_type1", 3).isNotNull("ctn_no"));
+                if (agvLocMasts.isEmpty()) {
+                    return;
+                }
+                for (AgvLocMast agvLocMast : agvLocMasts) {
+                    if (agvLocMast.getLev1() == 1 && agvLocMast.getFloor() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("2")) {
+                        try {
+                            autoMoveHandler.autoTransfersV2(agvLocMast, maxTansk);
+                        } catch (Exception e) {
+                            log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "鍥涙湡瀹氭椂绉诲簱浠诲姟 鍚稿 --> 鍚稿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+                        }
+                    } else if (agvLocMast.getLev1() == 2 && agvLocMast.getFloor() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("1")) {
+                        try {
+                            autoMoveHandler.autoTransfersV2(agvLocMast, maxTansk);
+                        } catch (Exception e) {
+                            log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "鍥涙湡瀹氭椂绉诲簱浠诲姟 鍚稿 --> 鍚稿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+                        }
+                    }
+
+                }
+            }
+        }
+    }
 }

--
Gitblit v1.9.1