基层治理-组织的治理指数，按天统计

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

@@ -38,10 +38,7 @@ import com.epmet.entity.stats.DimMonthEntity;
 import com.epmet.service.StatsDemoService;
 import com.epmet.service.StatsPartyMemberVanguardService;
 import com.epmet.service.evaluationindex.extract.dataToIndex.*;
-import com.epmet.service.evaluationindex.extract.todata.FactGridGovernDailyService;
-import com.epmet.service.evaluationindex.extract.todata.FactGroupActDailyService;
-import com.epmet.service.evaluationindex.extract.todata.FactOriginProjectCategoryDailyService;
-import com.epmet.service.evaluationindex.extract.todata.FactOriginTopicMainDailyService;
+import com.epmet.service.evaluationindex.extract.todata.*;
 import com.epmet.service.evaluationindex.extract.toscreen.*;
 import com.epmet.service.evaluationindex.indexcal.*;
 import com.epmet.service.evaluationindex.screen.*;
@@ -120,6 +117,8 @@ public class DemoController {
     private FactGroupActDailyService factGroupActDailyService;
     @Autowired
     private FactGridGovernDailyService factGridGovernDailyService;
+    @Autowired
+    private FactAgencyGovernDailyService factAgencyGovernDailyService;
 
     @GetMapping("testAlarm")
     public void testAlarm() {
@@ -924,4 +923,10 @@ public class DemoController {
         factGridGovernDailyService.extractFactGridGovernDaily(fromDTO);
         return new Result();
     }
+    @PostMapping("extractFactAgencyGovernDaily")
+    public Result extractFactAgencyGovernDaily(@RequestBody ExtractFactGridGovernDailyFromDTO fromDTO){
+        factAgencyGovernDailyService.extractFactAgencyGovernDaily(fromDTO.getCustomerId(), fromDTO.getDateId());
+        return new Result();
+    }
+
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/extract/FactAgencyGovernDailyDao.java

@@ -20,6 +20,7 @@ package com.epmet.dao.evaluationindex.extract;
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.entity.evaluationindex.extract.FactAgencyGovernDailyEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * 组织的治理指数，按天统计
@@ -29,5 +30,14 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface FactAgencyGovernDailyDao extends BaseDao<FactAgencyGovernDailyEntity> {
+	/**
+	 * 删除数据
+	 * @author zhaoqifeng
+	 * @date 2021/5/31 14:47
+	 * @param customerId
+	 * @param dateId
+	 * @return int
+	 */
+	int deleteAgencyGovernDailyData(@Param("customerId") String customerId, @Param("dateId") String dateId, @Param("deleteSize") Integer deleteSize);
 	
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactAgencyGovernDailyServiceImpl.java

@@ -291,6 +291,14 @@ public class FactAgencyGovernDailyServiceImpl extends BaseServiceImpl<FactAgency
 				}
 			});
 		}
+		if (CollectionUtils.isNotEmpty(agencyGovernDailyList)) {
+			int deleteNum;
+			do {
+				deleteNum = baseDao.deleteAgencyGovernDailyData(customerId, dateId, IndexCalConstant.DELETE_SIZE);
+			} while (deleteNum != NumConstant.ZERO);
+			//删除旧数据
+			insertBatch(agencyGovernDailyList);
+		}
 	}
 
 	private FactAgencyGovernDailyEntity initEntity(DimAgencyDTO agency, String dateId) {

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactAgencyGovernDailyDao.xml

@@ -4,5 +4,10 @@
 <mapper namespace="com.epmet.dao.evaluationindex.extract.FactAgencyGovernDailyDao">
 
 
-
+    <delete id="deleteAgencyGovernDailyData">
+        delete from fact_agency_govern_daily
+        where CUSTOMER_ID = #{customerId}
+        AND DATE_ID = #{dateId}
+        limit #{deleteSize}
+    </delete>
 </mapper>