优化插入 分批一次1000

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/ShiBeiICJobController.java

@@ -76,7 +76,7 @@ public class ShiBeiICJobController {
      * @Author sun
      * @Description 数据-项目-机关日(月)统计
      **/
-    private Result agencyProjectStats(String customerId, String dateId) {
+    private void agencyProjectStats(String customerId, String dateId) {
         try {
             if (StringUtils.isNotBlank(dateId)) {
                 dateId = DateUtils.format(DateUtils.parseDate(dateId, DateUtils.DATE_PATTERN_YYYYMMDD));
@@ -89,7 +89,7 @@ public class ShiBeiICJobController {
         } catch (Exception e) {
             log.error("市北-项目状态数据写入失败，参数为：{}" + customerId + StrConstant.HYPHEN + dateId, e);
         }
-        return new Result();
+        new Result();
     }
 
     private void extractUserPointData(String customerId, String dateId) {

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

@@ -25,6 +25,7 @@ import com.epmet.constant.DataSourceConstant;
 import com.epmet.dao.evaluationindex.screen.ScreenPartyUserRankDataDao;
 import com.epmet.entity.evaluationindex.screen.ScreenPartyUserRankDataEntity;
 import com.epmet.service.evaluationindex.screen.ScreenPartyUserRankDataService;
+import org.apache.commons.collections4.ListUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -61,7 +62,7 @@ public class ScreenPartyUserRankDataServiceImpl extends BaseServiceImpl<ScreenPa
             do {
                 affectedRows = baseDao.deletePartyUserRankData(customerId);
             } while (affectedRows > NumConstant.ZERO);
-            baseDao.insertBatch(dataList);
+            ListUtils.partition(dataList,NumConstant.ONE_THOUSAND).forEach(part->baseDao.insertBatch(part));
         }
     }
 }