From 21035dc71bbed79d49b817ea4a419706abd336f3 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Wed, 12 Mar 2025 11:31:05 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E6=89=B9=E6=AC=A1=E6=8F=92=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java      | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java
index a2bd2d23a..077ddfceb 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java
@@ -18,6 +18,7 @@ import com.njcn.prepare.harmonic.service.mysql.cvt.CvtJobLogService;
 import com.njcn.prepare.harmonic.service.mysql.cvt.IDataHarmRateVCvtService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Component;
@@ -111,7 +112,13 @@ public class DataHarmRateVCvtServiceImpl implements IDataHarmRateVCvtService {
 
                 result.addAll(dataVCvtDtoList);
             });
-            dataHarmRateVMapper.insertBatch(result);
+            List<List<DataHarmRateV>> partition = ListUtils.partition(result, 5000);
+            for (List<DataHarmRateV> dataHarmRateVList : partition) {
+                List<DataHarmRateV> sublistAsOriginalListType = new ArrayList<>(dataHarmRateVList);
+
+                dataHarmRateVMapper.insertBatch(sublistAsOriginalListType);
+
+            }
             stopWatch.stop();
             one.setRowCount(result.size());
             one.setState(1);