From a35cc87447118c64dd3ad6c778069275d0653189 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期三, 18 九月 2024 14:38:32 +0800
Subject: [PATCH] 将定时任务统一使用线程池，线程数2*N
---
src/main/java/com/zy/asrs/task/OrderSyncScheduler.java | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 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..495e380 100644
--- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
@@ -1,5 +1,6 @@
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.service.ApiLogService;
@@ -39,7 +40,7 @@
}
@Scheduled(cron = "0/5 * * * * ? ")
- @Async("orderThreadPool")
+ //@Async("orderThreadPool")
public void completeAndReport(){
String erpReport = Parameter.get().getErpReport();
if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
@@ -53,4 +54,15 @@
}
}
+ /*
+ 瀹氭椂鏌ヨ鐘舵�佷负2.浣滀笟涓殑鍗曟嵁锛屾鏌ユ槸鍚﹀畬鎴�
+ */
+ @Scheduled(cron = "0 */1 * * * ? ")
+ public void completeOrder(){
+ List<Order> orderList = orderService.selectList(new EntityWrapper<Order>().eq("settle", 2));
+ orderList.forEach(order -> {
+ orderService.checkComplete(order.getOrderNo());
+ });
+ }
+
}
--
Gitblit v1.9.1