From 469d8ceb95ed82f09fd4c1bddbbe672689bc8d82 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期三, 09 四月 2025 19:52:22 +0800
Subject: [PATCH] 1

---
 src/main/java/com/zy/asrs/task/AutoMoveScheduler.java |   68 ++++++++++++++++++++++++++++------
 1 files changed, 56 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
index 0c9018b..e370d60 100644
--- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
+++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
@@ -66,7 +66,7 @@
      * ioType 108.鑷姩璋冩嫧
      * crnNo :2鐩爣妤煎眰
      */
-    @Scheduled(cron = "0/1 * * * * ? ")
+    @Scheduled(cron = "0/10 * * * * ? ")
     private synchronized void execute2() {
         List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("wrk_sts", 22).andNew().eq("io_type", 108).andNew().eq("crn_no", 2).or().eq("crn_no", 3).orderBy("io_pri", false).orderBy("appe_time", true));
         if (agvWrkMastList.isEmpty()) {
@@ -110,7 +110,7 @@
      * wrkSts 22.璋冩嫧寰呭垎閰�
      * ioType 111.鎵嬪姩璋冩嫧
      */
-    @Scheduled(cron = "0/2 * * * * ? ")
+    @Scheduled(cron = "0/10 * * * * ? ")
     private void execute3() {
         List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("wrk_sts", 22).andNew().eq("io_type", 111).orderBy("io_pri", false).orderBy("appe_time", true));
         if (agvWrkMastList.isEmpty()) {
@@ -215,20 +215,48 @@
      */
     @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).andNew().ne("floor", 1).or().ne("lev1", 1));
         if (agvLocMasts.isEmpty()) {
             return;
         }
+
+        Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_3_TIME"));
         for (AgvLocMast agvLocMast : agvLocMasts) {
-            try {
-                autoMoveHandler.autoEmptyBack4(agvLocMast);
-            } catch (Exception e) {
-                log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐�  搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+            if (agvLocMast.getLocNo().contains("02F1")) {
+                boolean flag = false;
+                if (config != null && !Cools.isEmpty(config.getValue())) {
+                    try {
+
+                        // 鍒ゆ柇鏄惁鍦ㄦ墽琛屾椂闂村唴
+                        ProcesTimeData procesTimeData = JSONObject.parseObject(config.getValue(), ProcesTimeData.class);
+                        if (procesTimeData != null && config.getStatus() == 1 && TimeUtils.between(procesTimeData)) {
+                            flag = true;
+                        }
+                    } catch (Exception e) {
+                        log.error("6绫诲瀷绌鸿揣鏋惰繑鍥炵殑鎵ц鏃堕棿鐐硅В鏋愬紓甯革細===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+                        flag = true;
+                    }
+                }
+                if (flag) {
+                    try {
+                        autoMoveHandler.autoEmptyBack4(agvLocMast);
+                    } catch (Exception e) {
+                        //log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐�  搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+                    }
+                }
+            } else {
+                try {
+                    autoMoveHandler.autoEmptyBack4(agvLocMast);
+                } catch (Exception e) {
+                    //log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐�  搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage());
+                }
             }
+
         }
+
+
     }
 
 
@@ -238,6 +266,22 @@
     // TODO 鍥涙湡
     @Scheduled(cron = "0/30 * * * * ? ")
     private void autoEmptyBackSiqi() {
+        Config config2 = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_EMPTY"));
+        //鍏堝垽鏂┖搴撲綅鏁颁簡
+        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_type1", 6).eq("floor", 1).eq("lev1", 2).eq("loc_sts", "O"));
+        int size = 0;
+        if (agvLocMasts != null) {
+            size = agvLocMasts.size();
+        }
+        if (config2 != null && config2.getStatus() == 1 && !Cools.isEmpty(config2.getValue())) {
+            if (size < Integer.parseInt(config2.getValue())) {
+                return;
+            }
+        } else {
+            if (size < 20) {
+                return;
+            }
+        }
         // 鏌ヨ6绫诲瀷绌鸿揣鏋惰繑鍥炵殑鎵ц鏃堕棿鐐�
         Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_TIME"));
         if (config != null && !Cools.isEmpty(config.getValue())) {
@@ -264,7 +308,7 @@
 
     private void executeLocType6() {
         // 鏌ヨ 浜屽巶鐨勭殑鍗婃垚鍝佺澹崇被鍨嬬殑绌鸿揣鏋�
-        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_sts", "D").eq("loc_type1", 6).eq("floor", 2));
+        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_sts", "D").eq("loc_type1", 6).eq("floor", 2).orderBy("bay1",false));
         if (agvLocMasts.isEmpty()) {
             return;
         }
@@ -319,7 +363,7 @@
      * 妫�娴�1妤兼帴椹崇偣
      * 鎵嬪姩锛� 鐢熸垚 113 鎵嬪姩鍥炴祦
      */
-    @Scheduled(cron = "0/2 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     private void autoEmptyBack6() {
         List<AgvBasDevp> agvBasDevps = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>().eq("floor", 1).eq("loc_sts", "F").like("dev_no", "DB"));
         if (agvBasDevps.isEmpty()) {
@@ -385,7 +429,7 @@
      * 鎵撴爣璁扮殑搴撲綅杩涜鑷姩绉诲簱锛屽洓鏈�
      * 鍦ㄥ簱浣嶄笉澶熺殑鎯呭喌涓嬶紝绠卞3鍏ュ簱鍒殑妤煎眰搴撲綅鐨勬椂鍊欙紝鏅氫笂杩涜璺ㄥ眰绉诲簱
      */
-    @Scheduled(cron = "0/2 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     private void autoEmptyBack8() throws ParseException {
         Date now = new Date();
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
@@ -418,13 +462,13 @@
                     return;
                 }
                 for (AgvLocMast agvLocMast : agvLocMasts) {
-                    if (agvLocMast.getLev1() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("2")) {
+                    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 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("1")) {
+                    } 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) {

--
Gitblit v1.9.1