From b51eadaa66a5c0ee6da0e418a3ba193dfc878fca Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期四, 03 七月 2025 13:21:56 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/asrs/task/OrderSyncScheduler.java | 32 ++++++++++++++++++++++++++++++-- 1 files changed, 30 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 1619b74..693f11b 100644 --- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java +++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java @@ -1,8 +1,13 @@ package com.zy.asrs.task; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.zy.asrs.entity.Order; +import com.zy.asrs.entity.OrderDetlReport; +import com.zy.asrs.entity.OrderDetlReportLog; import com.zy.asrs.service.ApiLogService; +import com.zy.asrs.service.OrderDetlReportLogService; +import com.zy.asrs.service.OrderDetlReportService; import com.zy.asrs.service.OrderService; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.OrderSyncHandler; @@ -28,9 +33,13 @@ private OrderService orderService; @Autowired private ApiLogService apiLogService; + @Autowired + private OrderDetlReportService orderDetlReportService; + @Autowired + private OrderDetlReportLogService orderDetlReportLogService; @Scheduled(cron = "0 0 1 * * ? ") - public void clearApiLog(){ + public void clearApiLog() { try { apiLogService.clearWeekBefore(); } catch (Exception e) { @@ -38,9 +47,28 @@ } } + @Scheduled(cron = "0/30 * * * * ? ") + public void clearReportLog() { + try { + List<OrderDetlReport> orderDetls = orderDetlReportService.selectList(new EntityWrapper<OrderDetlReport>()); + for (OrderDetlReport orderDetl : orderDetls) { + Order order = orderService.selectByNo(orderDetl.getOrderNo()); + if (order == null) { + OrderDetlReportLog orderDetlReportLog = new OrderDetlReportLog(); + orderDetlReportLog.sync(orderDetl); + orderDetlReportLog.setId(null); + orderDetlReportLogService.insert(orderDetlReportLog); + orderDetlReportService.deleteById(orderDetl.getId()); + } + } + } catch (Exception e) { + log.error("涓婃姤鏃ュ織鍒犻櫎", e); + } + } + @Scheduled(cron = "0/5 * * * * ? ") @Async("orderThreadPool") - public void completeAndReport(){ + public void completeAndReport() { String erpReport = Parameter.get().getErpReport(); if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { List<Order> orders = orderService.selectComplete(); -- Gitblit v1.9.1