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