statsGroupGridDailyTask优化

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsGroupServiceImpl.java

@@ -23,6 +23,7 @@ import com.epmet.service.stats.*;
 import com.epmet.util.DimIdGenerator;
 import com.epmet.util.ModuleConstant;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -89,10 +90,15 @@ public class StatsGroupServiceImpl implements StatsGroupService {
             DimIdGenerator.DimIdBean dimIdBean = this.getDimIdBean(formDTO);
             if (customerIds.size() != NumConstant.ZERO) {
                 customerIds.forEach(customerId -> {
+                    Boolean status = true;
                     try {
                         List<GridIdListByCustomerResultDTO> gridsInfo = customerGridService.getCustomerGridIdList(customerId, dimIdBean.getDateId());
-                        List<GroupGridDailyResultDTO> resultDTOS = groupDataService.groupGridDaily(customerId, dimIdBean, gridsInfo);
-                        factGroupGridDailyService.statisticsGroupGridDaily(resultDTOS, customerId);
+                        List<List<GridIdListByCustomerResultDTO>> partition = ListUtils.partition(gridsInfo, NumConstant.ONE_HUNDRED);
+                        for (List<GridIdListByCustomerResultDTO> p : partition) {
+                            List<GroupGridDailyResultDTO> resultDTOS = groupDataService.groupGridDaily(customerId, dimIdBean, p);
+                            factGroupGridDailyService.statisticsGroupGridDaily(resultDTOS, customerId,status);
+                            status = false;
+                        }
                     } catch (Exception e) {
                         log.error(String.format(GroupConstant.STATS_FAILED_GRID_DAILY, customerId, LocalDate.now(), e));
                     }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/FactGroupGridDailyService.java

@@ -99,5 +99,5 @@ public interface FactGroupGridDailyService extends BaseService<FactGroupGridDail
      * @param   formDto
      * @author zxc
      */
-    void statisticsGroupGridDaily(List<GroupGridDailyResultDTO> formDto,String customerId);
+    void statisticsGroupGridDaily(List<GroupGridDailyResultDTO> formDto,String customerId,Boolean status);
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/FactGroupGridDailyServiceImpl.java

@@ -115,15 +115,18 @@ public class FactGroupGridDailyServiceImpl extends BaseServiceImpl<FactGroupGrid
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void statisticsGroupGridDaily(List<GroupGridDailyResultDTO> formDto,String customerId) {
+    public void statisticsGroupGridDaily(List<GroupGridDailyResultDTO> formDto,String customerId,Boolean status) {
         if (CollectionUtils.isEmpty(formDto)){
             return;
         }
         String dateId = formDto.get(NumConstant.ZERO).getDateId();
+        // true 为当前客户第一回进入
+        if (!status){
             Integer delNum;
             do {
                 delNum = baseDao.deleteInsertDateId(dateId,customerId);
             }while (delNum > NumConstant.ZERO && delNum == NumConstant.ONE_THOUSAND);
+        }
         List<List<GroupGridDailyResultDTO>> partition = ListUtils.partition(formDto, NumConstant.ONE_HUNDRED);
         partition.forEach(p -> {
             baseDao.insertGroupGridDaily(p);