From c5a900b6606e24021907e41e26156ea07c3d8c1a Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Wed, 22 Jan 2025 16:31:43 +0800
Subject: [PATCH] =?UTF-8?q?1.bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TrunklineCarsLoadServiceImpl.java       | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
index eb1e41373..9e9e1844b 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java
@@ -7767,7 +7767,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			});
 
 			//直接新增的包件
-			distributionParcelListClient.addBatch(newParcelListEntities);
+
+			//把newParcelListEntities每200个分一组
+			List<List<DistributionParcelListEntity>> newParcelListEntitiesList = CollUtil.split(newParcelListEntities, 200);
+			newParcelListEntitiesList.forEach(p -> {
+				distributionParcelListClient.addBatch(p);
+			});
+
+//			distributionParcelListClient.addBatch(newParcelListEntities);
 			if (CollUtil.isNotEmpty(newParcelListEntities)) {
 				for (DistributionParcelListEntity entity : newParcelListEntities) {
 					try {