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> partition = ListUtils.partition(result, 5000); + for (List dataHarmRateVList : partition) { + List sublistAsOriginalListType = new ArrayList<>(dataHarmRateVList); + + dataHarmRateVMapper.insertBatch(sublistAsOriginalListType); + + } stopWatch.stop(); one.setRowCount(result.size()); one.setState(1);