From 7896e6e42007b3d23f97b0d260dd68a18f49ba3b Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 18 七月 2025 15:25:18 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
index e7bc899..81d5769 100644
--- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
@@ -71,7 +71,7 @@
         }
     }
 
-    @Scheduled(cron = "0/3 * * * * ? ")
+    @Scheduled(cron = "0/30 * * * * ? ")
     @Async("orderThreadPool")
     public void completeAndReportOrderIssued() {
 //        String erpReport = Parameter.get().getErpReport();
@@ -94,8 +94,26 @@
 
     @Scheduled(cron = "0/5 * * * * ? ")
     @Async("orderThreadPool")
-    //@Scheduled(cron = "0/5 * * * * ? ")
-    //@Async("orderThreadPool")
+    public void completeAndReportOrderInAndOutUtil3() {
+//        String erpReport = Parameter.get().getErpReport();
+//        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
+        List<Order> orders = OrderInAndOutUtil.selectComplete(null);
+        for (Order order : orders) {
+            try {
+                ReturnT<String> result = orderSyncHandler.checkDBDD(order);
+                if (!result.isSuccess()) {
+                    log.error("闆嗗洟鍐呴儴璋冩嫧鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                log.error("闆嗗洟鍐呴儴璋冩嫧鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
+            }
+        }
+//        }
+    }
+
+    @Scheduled(cron = "0/5 * * * * ? ")
+    @Async("orderThreadPool")
     public void completeAndReportOrderInAndOutUtil2() {
 //        String erpReport = Parameter.get().getErpReport();
 //        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
@@ -104,11 +122,11 @@
             try {
                 ReturnT<String> result = orderSyncHandler.checkXSFH(order);
                 if (!result.isSuccess()) {
-                    log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
+                    log.error("閿�鍞彂璐у崟鎹甗orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
                 }
             } catch (Exception e) {
-                log.error(e.getMessage());
-                log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
+                e.printStackTrace();
+                log.error("閿�鍞彂璐у崟鎹甗orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
             }
         }
 //        }
@@ -127,7 +145,7 @@
                     log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
                 }
             } catch (Exception e) {
-                log.error(e.getMessage());
+                e.printStackTrace();
                 log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo());
             }
         }

--
Gitblit v1.9.1