From 46168fbb7c925b0ec04def176095e967720e684a Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期五, 16 一月 2026 15:22:07 +0800
Subject: [PATCH] agv查询修复

---
 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java |   38 +++++++++++++++++++++++++-------------
 1 files changed, 25 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
index 382c7fb..5e94d99 100644
--- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
@@ -8,6 +8,7 @@
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.task.handler.OrderPakinSyncHandler;
 import com.zy.asrs.task.handler.OrderPakoutSyncHandler;
+import com.zy.common.properties.SchedulerProperties;
 import com.zy.system.timer.LoadingConfigTimer;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -15,6 +16,7 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.List;
 
 /**
@@ -37,20 +39,15 @@
     @Autowired
     private LoadingConfigTimer loadingConfigTimer;
 
-
-    @Scheduled(cron = "0 0 1 * * ? ")
-    public void clearApiLog() {
-        try {
-            apiLogService.clearWeekBefore();
-        } catch (Exception e) {
-            log.error("绗笁鏂规帴鍙f棩蹇楄嚜鍔ㄦ竻闄ゅけ璐ワ紙鑼冨洿锛氫竴鍛ㄤ箣鍓�", e);
-        }
-    }
-
+    @Resource
+    private SchedulerProperties schedulerProperties;
 
     @Scheduled(cron = "0/30 * * * * ? ")
     @Async("orderThreadPool")
     public void completeOrderPakin() {
+        if (!schedulerProperties.isEnabled()) {
+            return;
+        }
         if (loadingConfigTimer.getErpReport()) {
             List<OrderPakin> orders = orderPakinService.selectComplete();
             for (OrderPakin order : orders) {
@@ -61,16 +58,18 @@
                     }
                 } catch (Exception e) {
                     log.error(e.getMessage());
-                    log.error("鍗曟嵁[orderNo={}]涓婃姤erp澶辫触", order.getOrderNo());
+                    log.error("鍗曟嵁[orderNo={}]涓婃姤erp寮傚父", order.getOrderNo());
                 }
             }
         }
     }
 
-
     @Scheduled(cron = "0/30 * * * * ? ")
     @Async("orderThreadPool")
     public void completeOrderPakout() {
+        if (!schedulerProperties.isEnabled()) {
+            return;
+        }
         if (loadingConfigTimer.getErpReport()) {
             List<OrderPakout> orders = orderPakoutService.selectComplete();
             for (OrderPakout order : orders) {
@@ -81,9 +80,22 @@
                     }
                 } catch (Exception e) {
                     log.error(e.getMessage());
-                    log.error("鍗曟嵁[orderNo={}]涓婃姤erp澶辫触", order.getOrderNo());
+                    log.error("鍗曟嵁[orderNo={}]涓婃姤erp寮傚父", order.getOrderNo());
                 }
             }
         }
     }
+
+    @Scheduled(cron = "0 0 1 * * ? ")
+    public void clearApiLog() {
+        if (!schedulerProperties.isEnabled()) {
+            return;
+        }
+        try {
+            apiLogService.clearWeekBefore();
+        } catch (Exception e) {
+            log.error("绗笁鏂规帴鍙f棩蹇楄嚜鍔ㄦ竻闄ゅけ璐ワ紙鑼冨洿锛氫竴鍛ㄤ箣鍓�", e);
+        }
+    }
+
 }

--
Gitblit v1.9.1