From f34c402757a09ba5bd07db1ce4fb142a2dcfe9da Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9B=B7=E6=AC=A7=EF=BC=88=E6=9E=97=E5=B9=B3=E5=87=A1?=
 =?UTF-8?q?=EF=BC=89?= <leo@qi-cloud.com>
Date: Fri, 29 Nov 2024 11:28:09 +0800
Subject: [PATCH] 1

---
 src/main/java/cn/van/business/util/JDUtils.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/cn/van/business/util/JDUtils.java b/src/main/java/cn/van/business/util/JDUtils.java
index 8458cfe..0d7067b 100644
--- a/src/main/java/cn/van/business/util/JDUtils.java
+++ b/src/main/java/cn/van/business/util/JDUtils.java
@@ -36,6 +36,8 @@ import java.util.Comparator;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
@@ -71,6 +73,8 @@ public class JDUtils {
     private OrderRowRepository orderRowRepository;
     @Resource
     private WXUtil wxUtil;
+    // 创建一个固定大小的线程池
+    private ExecutorService jdExecutorService = Executors.newFixedThreadPool(64);  // 线程池大小根据需求调整
 
     /**
      * 将 响应参数转化为 OrderRow，并返回
@@ -214,7 +218,9 @@ public class JDUtils {
         List<OrderRow> orderRows = orderRowRepository.findByValidCodeNotInOrderByOrderTimeDesc(parm);
 
         for (OrderRow orderRow : orderRows) {
-            orderToWx(orderRow, true);
+            jdExecutorService.submit(() -> {
+                orderToWx(orderRow, true);
+            });
         }
 
         logger.info("扫描订单发送到微信耗时：{} ms, 订单数：{} ", System.currentTimeMillis() - start, orderRows.size());