From 0d686bf09f1ea8a03995a5ec2d7512ee8226276f Mon Sep 17 00:00:00 2001
From: "autumn.g@foxmail.com" <autumn.g@foxmail.com>
Date: Wed, 29 Mar 2023 15:31:47 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96=E6=89=B9=E9=87=8F?=
 =?UTF-8?q?=E7=94=9F=E6=88=90=E5=85=85=E7=94=B5=E6=A1=A9=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/TransactionService.java           | 33 ++++++++++++++++---
 1 file changed, 29 insertions(+), 4 deletions(-)

diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/transaction/service/TransactionService.java b/jsowell-pile/src/main/java/com/jsowell/pile/transaction/service/TransactionService.java
index b93648f1d..2ba02ef3e 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/transaction/service/TransactionService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/transaction/service/TransactionService.java
@@ -4,6 +4,8 @@ import com.google.common.collect.Lists;
 import com.jsowell.common.constant.CacheConstants;
 import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.util.StringUtils;
+import com.jsowell.pile.domain.PileBasicInfo;
+import com.jsowell.pile.domain.PileConnectorInfo;
 import com.jsowell.pile.mapper.MemberBasicInfoMapper;
 import com.jsowell.pile.mapper.MemberWalletInfoMapper;
 import com.jsowell.pile.mapper.OrderBasicInfoMapper;
@@ -22,6 +24,7 @@ import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.util.List;
 import java.util.Objects;
 
 /**
@@ -58,16 +61,38 @@ public class TransactionService {
 	 */
 	@Transactional(readOnly = false, propagation = Propagation.REQUIRED)
 	public int doCreatePileTransaction(PileTransactionDTO dto) {
+		int maxNum = 100;
 		int result = 0;
-		if (CollectionUtils.isNotEmpty(dto.getPileBasicInfoList())) {
-			result = pileBasicInfoMapper.batchInsertPileBasicInfo(dto.getPileBasicInfoList());
+		List<PileBasicInfo> pileBasicInfoList = dto.getPileBasicInfoList();
+		if (CollectionUtils.isNotEmpty(pileBasicInfoList)) {
+			List<List<PileBasicInfo>> partition = Lists.partition(pileBasicInfoList, maxNum);
+			for (List<PileBasicInfo> basicInfoList : partition) {
+				result += pileBasicInfoMapper.batchInsertPileBasicInfo(basicInfoList);
+			}
 		}
-		if (CollectionUtils.isNotEmpty(dto.getPileConnectorInfoList())) {
-			pileConnectorInfoMapper.batchInsertConnectorInfo(dto.getPileConnectorInfoList());
+		List<PileConnectorInfo> pileConnectorInfoList = dto.getPileConnectorInfoList();
+		if (CollectionUtils.isNotEmpty(pileConnectorInfoList)) {
+			List<List<PileConnectorInfo>> partition = Lists.partition(pileConnectorInfoList, maxNum);
+			for (List<PileConnectorInfo> connectorInfoList : partition) {
+				pileConnectorInfoMapper.batchInsertConnectorInfo(connectorInfoList);
+			}
 		}
 		return result;
 	}
 
+	public static void main(String[] args) {
+		List<String> list = Lists.newArrayList();
+		for (int i = 0; i < 555; i++) {
+			list.add(String.valueOf(i + 1));
+		}
+		System.out.println("原list：" + list);
+		int maxNum = 100;
+		List<List<String>> partition = Lists.partition(list, maxNum);
+		for (int i = 0; i < partition.size(); i++) {
+			System.out.println("第" + (i + 1) +"批次：" + partition.get(i));
+		}
+	}
+
 	/**
 	 * 新增计费模板和详情
 	 */