From 451eef22443e79cc78a20826b7d6ea21c359c7af Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期日, 29 六月 2025 13:14:34 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/ReportInventoryCheckOrdersScheduler.java | 26 +++++++++++++++++++++++++- 1 files changed, 25 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/ReportInventoryCheckOrdersScheduler.java b/src/main/java/com/zy/asrs/task/ReportInventoryCheckOrdersScheduler.java index f7c363c..889d8a7 100644 --- a/src/main/java/com/zy/asrs/task/ReportInventoryCheckOrdersScheduler.java +++ b/src/main/java/com/zy/asrs/task/ReportInventoryCheckOrdersScheduler.java @@ -7,7 +7,7 @@ import com.zy.asrs.service.InventoryCheckOrderDetlService; import com.zy.asrs.service.InventoryCheckOrderService; import com.zy.asrs.service.ReportToThirdService; -import com.zy.system.entity.Config; +import com.zy.common.entity.Parameter; import com.zy.system.service.ConfigService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -34,6 +34,11 @@ */ @Scheduled(cron = "0/3 * * * * ? ") public void execute() { + String erpReport = Parameter.get().getErpReport(); + if (Cools.isEmpty(erpReport) || !erpReport.equals("true")) { + return; + } + List<InventoryCheckOrder> inventoryCheckOrders = inventoryCheckOrderService.selectList(new EntityWrapper<InventoryCheckOrder>() .eq("status", 1)); if (inventoryCheckOrders.isEmpty()) { @@ -85,6 +90,25 @@ } } + /** + * 鑷姩鍒犻櫎瓒呰繃3澶╋紝宸插畬鎴愮洏鐐瑰崟 + */ + @Scheduled(cron = "0/3 * * * * ? ") + public void execute3() { + List<InventoryCheckOrder> inventoryCheckOrders = inventoryCheckOrderService.selectList(new EntityWrapper<InventoryCheckOrder>() + .eq("status", 2)); + for (InventoryCheckOrder checkOrder : inventoryCheckOrders) { + if (System.currentTimeMillis() - checkOrder.getCreateTime().getTime() >= 1000 * 60 * 60 * 24 * 3) { + inventoryCheckOrderDetlService.delete(new EntityWrapper<InventoryCheckOrderDetl>().eq("order_no", checkOrder.getOrderNo())); + if (!inventoryCheckOrderService.deleteById(checkOrder)) { + log.error("鐩樼偣鍗昜orderNo={}]鍒犻櫎澶辫触", checkOrder.getOrderNo()); + } else { + log.info("鐩樼偣鍗昜orderNo={}]鍒犻櫎鎴愬姛", checkOrder.getOrderNo()); + } + } + } + } + // /** // * 鑷姩瀹岀粨杈惧埌涓�瀹氭暟閲忕殑鐩樼偣鍗� // */ -- Gitblit v1.9.1