From 28e0b9b18b07ab2a331a8f3b1eda5afabc280725 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期五, 28 二月 2025 09:58:45 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/OrderSyncScheduler.java | 21 +++++++++++++++++++-- 1 files changed, 19 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 d223b49..70a7f46 100644 --- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java +++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java @@ -41,6 +41,23 @@ @Scheduled(cron = "0/5 * * * * ? ") @Async("orderThreadPool") + public void completeAndReportOrderIssuedOnceMore() { + List<Order> orderList = orderService.selectComplete99(); + for (Order order : orderList) { + try { + ReturnT<String> result = orderSyncHandler.startOrderIssuedOnceMore(order); + if (!result.isSuccess()) { + log.error("鍗曟嵁[orderNo={}]鍐嶆杞墽琛岃〃澶辫触", order.getOrderNo()); + } + } catch (Exception e){ + log.error(e.getMessage()); + log.error("鍗曟嵁[orderNo={}]鍐嶆杞墽琛岃〃澶辫触", order.getOrderNo()); + } + } + } + + @Scheduled(cron = "0/5 * * * * ? ") + @Async("orderThreadPool") public void completeAndReportOrderIssued() { // String erpReport = Parameter.get().getErpReport(); // if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { @@ -50,11 +67,11 @@ try { ReturnT<String> result = orderSyncHandler.startOrderIssued(order); if (!result.isSuccess()) { - log.error("鍗曟嵁[orderNo={}]涓婃姤erp澶辫触", order.getOrderNo()); + log.error("鍗曟嵁[orderNo={}]杞墽琛岃〃澶辫触", order.getOrderNo()); } } catch (Exception e){ log.error(e.getMessage()); - log.error("鍗曟嵁[orderNo={}]涓婃姤erp澶辫触", order.getOrderNo()); + log.error("鍗曟嵁[orderNo={}]杞墽琛岃〃澶辫触", order.getOrderNo()); } } // } -- Gitblit v1.9.1