小组统计【网格-日】删除，插入分页

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/stats/FactGroupGridDailyDao.java

@@ -48,7 +48,7 @@ public interface FactGroupGridDailyDao extends BaseDao<FactGroupGridDailyEntity>
      * @param dateId
      * @author zxc
      */
-    void deleteInsertDateId(@Param("dateId")String dateId,@Param("customerId")String customerId);
+    Integer deleteInsertDateId(@Param("dateId")String dateId,@Param("customerId")String customerId);
 
     /**
      * @Description 根据机关级别查询小组数据

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

@@ -32,10 +32,12 @@ import com.epmet.dto.stats.FactGroupGridDailyDTO;
 import com.epmet.entity.stats.FactGroupGridDailyEntity;
 import com.epmet.service.StatsGroupService;
 import com.epmet.service.stats.FactGroupGridDailyService;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
 
 import java.util.Arrays;
 import java.util.List;
@@ -114,12 +116,18 @@ public class FactGroupGridDailyServiceImpl extends BaseServiceImpl<FactGroupGrid
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void statisticsGroupGridDaily(List<GroupGridDailyResultDTO> formDto,String customerId) {
-        if (formDto.size() == NumConstant.ZERO){
+        if (CollectionUtils.isEmpty(formDto)){
             return;
         }
         String dateId = formDto.get(NumConstant.ZERO).getDateId();
-        baseDao.deleteInsertDateId(dateId,customerId);
-        baseDao.insertGroupGridDaily(formDto);
+        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);
+        });
     }
 
 }

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/stats/FactGroupGridDailyDao.xml

@@ -74,6 +74,7 @@
         WHERE
             date_id = #{dateId}
             AND customer_id = #{customerId}
+            limit 1000
     </delete>
 
     <!-- 根据机关级别查询小组数据 -->