From 6df223494ce9156312da90eeda465c90e565931e Mon Sep 17 00:00:00 2001
From: "zhenghaiyang@ele-cloud.com" <zhenghaiyang@ele-cloud.com>
Date: Mon, 17 Apr 2023 09:29:04 +0800
Subject: [PATCH] =?UTF-8?q?feature=201.=E4=BC=98=E5=8C=96=E5=A4=9A?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../GroupCommodityCodeController.java         | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/commodity/controller/GroupCommodityCodeController.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/commodity/controller/GroupCommodityCodeController.java
index cc8ac59a..a486a7f4 100644
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/commodity/controller/GroupCommodityCodeController.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/commodity/controller/GroupCommodityCodeController.java
@@ -166,15 +166,18 @@ public class GroupCommodityCodeController {
             }
 
             int index = 0;
-            List<CompletableFuture<String>> completableFutureList = Lists.newArrayList();
-            for (MdmGmfxxtbReqBO reqBO : reqBOList) {
-                CompletableFuture<String> voidCompletableFuture = CompletableFuture.supplyAsync(()->{
-                    String str = buyerMessageService(reqBO);
-                    return str;
-                }, voucherTaskExecutor);
-                completableFutureList.add(voidCompletableFuture);
+            List<List<MdmGmfxxtbReqBO>> partition = Lists.partition(reqBOList, 200);
+            for (List<MdmGmfxxtbReqBO> mdmGmfxxtbReqBOS : partition) {
+                List<CompletableFuture<String>> completableFutureList = Lists.newArrayList();
+                for (MdmGmfxxtbReqBO reqBO : mdmGmfxxtbReqBOS) {
+                    CompletableFuture<String> voidCompletableFuture = CompletableFuture.supplyAsync(()->{
+                        String str = buyerMessageService(reqBO);
+                        return str;
+                    }, voucherTaskExecutor);
+                    completableFutureList.add(voidCompletableFuture);
+                }
+                CompletableFuture.allOf(completableFutureList.toArray(new CompletableFuture[0])).join();
             }
-            CompletableFuture.allOf(completableFutureList.toArray(new CompletableFuture[0])).join();
             return R.ok().put("data","");
         } catch (IOException e) {
             throw new RuntimeException(e);