From 3dfc6f0b3d756445d8522da0611f8e7824315c15 Mon Sep 17 00:00:00 2001
From: cc <van666666@foxmail.com>
Date: Fri, 29 Nov 2024 14:11:49 +0800
Subject: [PATCH] 1

---
 src/main/java/cn/van/business/config/AsyncConfig.java | 3 ++-
 src/main/java/cn/van/business/util/OrderUtil.java     | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cn/van/business/config/AsyncConfig.java b/src/main/java/cn/van/business/config/AsyncConfig.java
index 5429179..3d36047 100644
--- a/src/main/java/cn/van/business/config/AsyncConfig.java
+++ b/src/main/java/cn/van/business/config/AsyncConfig.java
@@ -2,6 +2,7 @@ package cn.van.business.config;
 
 import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
 import org.springframework.aop.interceptor.SimpleAsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.AsyncConfigurer;
 import org.springframework.scheduling.annotation.EnableAsync;
@@ -20,7 +21,7 @@ import java.util.concurrent.ThreadPoolExecutor;
 @EnableAsync
 public class AsyncConfig implements AsyncConfigurer {
 
-    @Override
+    @Bean(name = "threadPoolTaskExecutor")
     public Executor getAsyncExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(10); // 核心线程数
diff --git a/src/main/java/cn/van/business/util/OrderUtil.java b/src/main/java/cn/van/business/util/OrderUtil.java
index 71d0034..3cc95ca 100644
--- a/src/main/java/cn/van/business/util/OrderUtil.java
+++ b/src/main/java/cn/van/business/util/OrderUtil.java
@@ -32,7 +32,7 @@ public class OrderUtil {
     /**
      * 手动调用 将订单发送到微信
      */
-    @Async
+    @Async("threadPoolTaskExecutor")
     public void orderToWx(OrderRow orderRow, Boolean isAutoFlush) {
         // 获取订单当前状态
         Integer newValidCode = orderRow.getValidCode();