From 0301e6673ac109b076f4feba47a9cee0ef033afa Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期二, 23 七月 2024 18:32:23 +0800
Subject: [PATCH] # 订单修改页面调整

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

diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
index 26a801d..0275339 100644
--- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
+++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
@@ -56,14 +56,14 @@
      * ioType 108.鑷姩璋冩嫧
      * crnNo :2鐩爣妤煎眰
      */
-    @Scheduled(cron = "0/2 * * * * ? ")
-    private void execute2(){
+    @Scheduled(cron = "0/3 * * * * ? ")
+    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("appe_time",true)
+                        .orderBy("io_pri",false).orderBy("appe_time",true)
                 );
         if (agvWrkMastList.isEmpty()) {
             return;
@@ -110,6 +110,7 @@
         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()) {
@@ -118,6 +119,27 @@
         for (AgvWrkMast agvWrkMast : agvWrkMastList) {
             try{
                 autoMoveHandler.start3(agvWrkMast);
+            } catch (Exception e){
+                log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"璋冩嫧鍑哄簱,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
+            }
+        }
+
+    }
+
+    @Scheduled(cron = "0/2 * * * * ? ")
+    private void execute4(){
+        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
+                .eq("wrk_sts", 22)
+                .andNew().eq("io_type",114)
+                .orderBy("io_pri",false)
+                .orderBy("appe_time",true)
+        );
+        if (agvWrkMastList.isEmpty()) {
+            return;
+        }
+        for (AgvWrkMast agvWrkMast : agvWrkMastList) {
+            try{
+                autoMoveHandler.start4(agvWrkMast);
             } catch (Exception e){
                 log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"璋冩嫧鍑哄簱,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
             }
@@ -158,7 +180,8 @@
         List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                 .eq("wrk_sts", 214)
                 .eq("loc_no","")
-                .eq("io_type",113));
+                .eq("io_type",113)
+                .orderBy("io_pri",false));
         if (agvWrkMastList.isEmpty()) {
             return;
         }
@@ -201,24 +224,22 @@
      */
     @Scheduled(cron = "0/2 * * * * ? ")
     private void autoEmptyBack4(){
-//        if (determineFloorConnection(2)){
-            // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋�
-            List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
-                    new EntityWrapper<AgvLocMast>()
-                            .ne("floor", 1)
-                            .eq("loc_sts","D")
-                            .eq("loc_type1",3));
-            if (agvLocMasts.isEmpty()) {
-                return;
+        // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋�
+        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
+                new EntityWrapper<AgvLocMast>()
+                        .ne("floor", 1)
+                        .eq("loc_sts","D")
+                        .eq("loc_type1",3));
+        if (agvLocMasts.isEmpty()) {
+            return;
+        }
+        for (AgvLocMast agvLocMast : agvLocMasts) {
+            try{
+                autoMoveHandler.autoEmptyBack4(agvLocMast);
+            } catch (Exception e){
+                log.error("搴撲綅鍙�"+agvLocMast.getLocNo()+"绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐�  搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
             }
-            for (AgvLocMast agvLocMast : agvLocMasts) {
-                try{
-                    autoMoveHandler.autoEmptyBack4(agvLocMast);
-                } catch (Exception e){
-                    log.error("搴撲綅鍙�"+agvLocMast.getLocNo()+"绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐�  搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
-                }
-            }
-//        }
+        }
     }
 
     private boolean determineFloorConnection(Integer floor){

--
Gitblit v1.9.1