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 | 46 ++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 44 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java index 04026e3..81d5769 100644 --- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java +++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java @@ -85,8 +85,48 @@ log.error("鍗曟嵁[orderNo={}]杞墽琛岃〃澶辫触", order.getOrderNo()); } } catch (Exception e) { - log.error(e.getMessage()); + e.printStackTrace(); log.error("鍗曟嵁[orderNo={}]杞墽琛岃〃澶辫触", order.getOrderNo()); + } + } +// } + } + + @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")) { + List<Order> orders = OrderInAndOutUtil.selectComplete(null); + for (Order order : orders) { + try { + ReturnT<String> result = orderSyncHandler.checkXSFH(order); + if (!result.isSuccess()) { + log.error("閿�鍞彂璐у崟鎹甗orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo()); + } + } catch (Exception e) { + e.printStackTrace(); + log.error("閿�鍞彂璐у崟鎹甗orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo()); } } // } @@ -105,13 +145,15 @@ log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo()); } } catch (Exception e) { - log.error(e.getMessage()); + e.printStackTrace(); log.error("鍗曟嵁[orderNo={}]杞笂鎶ヨ〃澶辫触", order.getOrderNo()); } } // } } + + @Scheduled(cron = "0/30 * * * * ? ") @Async("orderThreadPool") public void completeAndReportOrderReport() { -- Gitblit v1.9.1