批量插入

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryGridDailyServiceImpl.java

@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.constant.DataSourceConstant;
@@ -30,6 +31,7 @@ import com.epmet.dto.screen.ScreenProjectCategoryGridDailyDTO;
 import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectCategoryGridDailyEntity;
 import com.epmet.service.evaluationindex.screen.ScreenProjectCategoryGridDailyService;
+import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -117,7 +119,9 @@ public class ScreenProjectCategoryGridDailyServiceImpl extends BaseServiceImpl<S
                affectedRows = baseDao.deleteByDateIdAndCustomerId(customerId,data.getDateId());
            }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getDateId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getDateId());
+        });
     }
 
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java

@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.constant.DataSourceConstant;
@@ -30,6 +31,7 @@ import com.epmet.dto.screen.ScreenProjectCategoryOrgDailyDTO;
 import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectCategoryOrgDailyEntity;
 import com.epmet.service.evaluationindex.screen.ScreenProjectCategoryOrgDailyService;
+import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -117,7 +119,9 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
                 affectedRows = baseDao.deleteByDateIdAndCustomerId(customerId,data.getDateId());
             }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getDateId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getDateId());
+        });
     }
 
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectGridDailyServiceImpl.java

@@ -38,6 +38,7 @@ import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectGridDailyEntity;
 import com.epmet.service.evaluationindex.extract.todata.FactOriginProjectMainDailyService;
 import com.epmet.service.evaluationindex.screen.ScreenProjectGridDailyService;
+import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -138,7 +139,9 @@ public class ScreenProjectGridDailyServiceImpl extends BaseServiceImpl<ScreenPro
                 affectedRows = baseDao.deleteByDateIdAndCustomerId(customerId,data.getDateId());
             }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getDateId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getDateId());
+        });
     }
 
     /**

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectOrgDailyServiceImpl.java

@@ -35,6 +35,7 @@ import com.epmet.dto.screen.ScreenProjectOrgDailyDTO;
 import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectOrgDailyEntity;
 import com.epmet.service.evaluationindex.screen.ScreenProjectOrgDailyService;
+import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -133,7 +134,9 @@ public class ScreenProjectOrgDailyServiceImpl extends BaseServiceImpl<ScreenProj
                 affectedRows = baseDao.deleteByDateIdAndCustomerId(customerId,data.getDateId());
             }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getDateId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getDateId());
+        });
     }
 
     /**

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectQuantityGridMonthlyServiceImpl.java

@@ -40,6 +40,7 @@ import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectQuantityGridMonthlyEntity;
 import com.epmet.service.evaluationindex.extract.todata.FactOriginProjectMainDailyService;
 import com.epmet.service.evaluationindex.screen.ScreenProjectQuantityGridMonthlyService;
+import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -139,7 +140,9 @@ public class ScreenProjectQuantityGridMonthlyServiceImpl extends BaseServiceImpl
                 affectedRows = baseDao.deleteByMonthIdAndCustomerId(customerId,data.getMonthId());
             }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getMonthId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getMonthId());
+        });
     }
 
     /**

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectQuantityOrgMonthlyServiceImpl.java

@@ -35,8 +35,8 @@ import com.epmet.dto.screen.ScreenProjectOrgDailyDTO;
 import com.epmet.dto.screen.ScreenProjectQuantityOrgMonthlyDTO;
 import com.epmet.dto.screencoll.ScreenCollFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectQuantityOrgMonthlyEntity;
-import com.epmet.service.evaluationindex.screen.ScreenCustomerAgencyService;
 import com.epmet.service.evaluationindex.screen.ScreenProjectQuantityOrgMonthlyService;
+import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -133,7 +133,9 @@ public class ScreenProjectQuantityOrgMonthlyServiceImpl extends BaseServiceImpl<
                 affectedRows = baseDao.deleteByMonthIdAndCustomerId(customerId,data.getMonthId());
             }
         }
-        baseDao.insertBatch(data.getDataList(),customerId,"APP_USER",data.getMonthId());
+        Lists.partition(data.getDataList(), NumConstant.ONE_HUNDRED).forEach(list -> {
+            baseDao.insertBatch(list,customerId,"APP_USER",data.getMonthId());
+        });
     }
 
     /**