指标采集、大屏数据采集，所有接口，入参修改；

表数据删除，方式修改

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/DeptGovrnAbilityDataFormDTO.java

@@ -0,0 +1,30 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 8、治理能力-部门相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class DeptGovrnAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<DeptGovrnAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/GridGovrnAbilityDataFormDTO.java

@@ -0,0 +1,30 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 6、治理能力-网格相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class GridGovrnAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<GridGovrnAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/GridPartyAbilityDataFormDTO.java

@@ -0,0 +1,30 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 2、党建能力-网格相关指标上报(按照月份) 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class GridPartyAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<GridPartyAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/GridPartyMemberDataFormDTO.java

@@ -29,5 +29,5 @@ public class GridPartyMemberDataFormDTO implements Serializable {
      */
     private String monthId;
 
-    private List<GridPartyMemberDataDetailFormDTO>  partyMemberDataList;
+    private List<GridPartyMemberDataDetailFormDTO> dataList;
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/GridServiceAbilityDataFormDTO.java

@@ -0,0 +1,28 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 4、服务能力-网格相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class GridServiceAbilityDataFormDTO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<GridServiceAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/OrgGovrnAbilityDataFormDTO.java

@@ -0,0 +1,30 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 7、治理能力-街道及社区相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class OrgGovrnAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<OrgGovrnAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/OrgPartyAbilityDataFormDTO.java

@@ -0,0 +1,30 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 3、党建能力-街道及社区相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class OrgPartyAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<OrgPartyAbilityFormDTO> dataList;
+
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/indexcollect/form/OrgServiceAbilityDataFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.indexcollect.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 5、服务能力-组织（街道|社区|全区）相关指标 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class OrgServiceAbilityDataFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<OrgServiceAbilityFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/CpcBaseDataListFormDTO.java

@@ -0,0 +1,25 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 2、党员基本情况 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class CpcBaseDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+
+    private List<CpcBaseDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/CustomerAgencyListFormDTO.java

@@ -0,0 +1,25 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 14、组织层级 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class CustomerAgencyListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+
+    private List<CustomerAgencyFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/CustomerDeptListFormDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 16、部门信息上传 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class CustomerDeptListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<CustomerDeptFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/CustomerGridListFormDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 15、网格信息上传 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class CustomerGridListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<CustomerGridFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/DifficultyDataFormDTO.java

@@ -21,6 +21,6 @@ public class DifficultyDataFormDTO implements Serializable {
     /**
      * 难点堵点数据
      */
-    private List<DifficultyDataDetailFormDTO> diffcultyDataList;
+    private List<DifficultyDataDetailFormDTO> dataList;
 
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/EventDataListFormDTO.java

@@ -0,0 +1,28 @@
+package com.epmet.dto.screencoll.form;
+
+import com.epmet.dto.indexcollect.form.GridPartyAbilityFormDTO;
+import com.epmet.dto.screencoll.ImgDataListDTO;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 4、事件数据(中央区-事件数据) 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class EventDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<EventDataFormDTO> dataList;
+
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/GovernRankDataListFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 5、基层治理-治理能力数据 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class GovernRankDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<GovernRankDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/IndexDataListMonthlyFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 1、指数_按月统计 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class IndexDataListMonthlyFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<IndexDataMonthlyFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/IndexDataListYearlyFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 17、指数_按年统计 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class IndexDataListYearlyFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyy
+     */
+    private String yearId;
+
+    private List<IndexDataYearlyFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/OrgRankDataListFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 6、党建引领-组织排行 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class OrgRankDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<OrgRankDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PartyBranchDataListFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 7、基层党建-建设情况数据（支部、联建、志愿） 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class PartyBranchDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<PartyBranchDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PartyLinkMassesDataListFormDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 8、党建引领-党员联系群众数据 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class PartyLinkMassesDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<PartyLinkMassesDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PartyUserRankDataListFormDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 9、党建引领|基层治理-居民（党员）积分排行榜 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-21 09:59
+ */
+@Data
+public class PartyUserRankDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<PartyUserRankDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PioneerDataListFormDTO.java

@@ -0,0 +1,25 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 10、党建引领-先锋模范数据
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class PioneerDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<PioneerDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PublicPartiTotalDataListFormDTO.java

@@ -0,0 +1,25 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 18、公众参与各类总数 入参
+ * 公众参与-各类(用户|党员|党群|话题|议题|项目|注册人数|参与人数)总数
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class PublicPartiTotalDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<PublicPartiTotalDataFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/UserJoinListFormDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 11、基层治理-公众参与 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class UserJoinListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    /**
+     * yyyyMM
+     */
+    private String monthId;
+
+    private List<UserJoinFormDTO> dataList;
+}

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/UserTotalDataListFormDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 12、中央区各类总数 入参
+ * @Auther: zhangyong
+ * @Date: 2020-08-18 09:59
+ */
+@Data
+public class UserTotalDataListFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 当为true时后台将删除本月数据
+     */
+    private Boolean isFirst;
+
+    private List<UserTotalDataFormDTO> dataList;
+}

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

@@ -4,12 +4,12 @@ import com.epmet.commons.extappauth.annotation.ExternalAppRequestAuth;
 import com.epmet.commons.extappauth.bean.ExternalAppRequestParam;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dto.indexcollect.form.*;
-import com.epmet.dto.screencoll.form.IndexDataMonthlyFormDTO;
 import com.epmet.service.evaluationindex.indexcoll.FactIndexCollectService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.List;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 /**
  * 指标采集相关api
@@ -51,7 +51,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("gridpartyability")
-    public Result gridPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridPartyAbilityFormDTO> formDTO) {
+    public Result gridPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody GridPartyAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertGridPartyAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -67,7 +67,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("orgpartyability")
-    public Result orgPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgPartyAbilityFormDTO> formDTO) {
+    public Result orgPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody OrgPartyAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertOrgPartyAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -83,7 +83,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("gridserviceability")
-    public Result gridServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridServiceAbilityFormDTO> formDTO) {
+    public Result gridServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody GridServiceAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertGridServiceAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -99,7 +99,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("orgserviceability")
-    public Result orgServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgServiceAbilityFormDTO> formDTO) {
+    public Result orgServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody OrgServiceAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertOrgServiceAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -115,7 +115,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("gridgovrnability")
-    public Result gridGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridGovrnAbilityFormDTO> formDTO) {
+    public Result gridGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody GridGovrnAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertGridGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -131,7 +131,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("orggovrnability")
-    public Result orgGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgGovrnAbilityFormDTO> formDTO) {
+    public Result orgGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody OrgGovrnAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertOrgGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -147,7 +147,7 @@ public class FactIndexCollectController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("deptgovrnability")
-    public Result deptGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<DeptGovrnAbilityFormDTO> formDTO) {
+    public Result deptGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody DeptGovrnAbilityDataFormDTO formDTO) {
         factIndexCollectService.insertDeptGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }

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

@@ -37,7 +37,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("partyuserrankdata")
-    public Result partyUserRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<PartyUserRankDataFormDTO> formDTO) {
+    public Result partyUserRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody PartyUserRankDataListFormDTO formDTO) {
         screenCollService.insertPartyUserRankData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -53,7 +53,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("partylinkmassesdata")
-    public Result partyLinkMassesData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<PartyLinkMassesDataFormDTO> formDTO) {
+    public Result partyLinkMassesData(ExternalAppRequestParam externalAppRequestParam, @RequestBody PartyLinkMassesDataListFormDTO formDTO) {
         screenCollService.insertPartyLinkMassesData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -69,7 +69,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("meetdata")
-    public Result meetData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<PartyBranchDataFormDTO> formDTO) {
+    public Result meetData(ExternalAppRequestParam externalAppRequestParam, @RequestBody PartyBranchDataListFormDTO formDTO) {
         screenCollService.insertPartyBranchData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -85,7 +85,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("orgrankdata")
-    public Result orgRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgRankDataFormDTO> formDTO) {
+    public Result orgRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody OrgRankDataListFormDTO formDTO) {
         screenCollService.insertOrgRankData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -101,7 +101,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("governrankdata")
-    public Result governRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GovernRankDataFormDTO> formDTO) {
+    public Result governRankData(ExternalAppRequestParam externalAppRequestParam, @RequestBody GovernRankDataListFormDTO formDTO) {
         screenCollService.insertGovernRankData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -117,7 +117,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("eventdata")
-    public Result eventData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<EventDataFormDTO> formDTO) {
+    public Result eventData(ExternalAppRequestParam externalAppRequestParam, @RequestBody EventDataListFormDTO formDTO) {
         screenCollService.insertEventData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -149,7 +149,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("cpcbasedata")
-    public Result cpcbaseData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<CpcBaseDataFormDTO> formDTO) {
+    public Result cpcbaseData(ExternalAppRequestParam externalAppRequestParam, @RequestBody CpcBaseDataListFormDTO formDTO) {
         screenCollService.insertCpcbaseData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -165,7 +165,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("indexdatamonthly")
-    public Result indexDataMonthly(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<IndexDataMonthlyFormDTO> formDTO) {
+    public Result indexDataMonthly(ExternalAppRequestParam externalAppRequestParam, @RequestBody IndexDataListMonthlyFormDTO formDTO) {
         screenCollService.insertIndexDataMonthly(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -183,7 +183,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("indexdatayearly")
-    public Result indexDataYearly(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<IndexDataYearlyFormDTO> formDTO) {
+    public Result indexDataYearly(ExternalAppRequestParam externalAppRequestParam, @RequestBody IndexDataListYearlyFormDTO formDTO) {
         screenCollService.insertIndexDataYearly(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -199,7 +199,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("customerdept")
-    public Result customerDept(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<CustomerDeptFormDTO> formDTO) {
+    public Result customerDept(ExternalAppRequestParam externalAppRequestParam, @RequestBody CustomerDeptListFormDTO formDTO) {
         screenCollService.insertCustomerDept(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -215,7 +215,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("customergrid")
-    public Result customerGrid(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<CustomerGridFormDTO> formDTO) {
+    public Result customerGrid(ExternalAppRequestParam externalAppRequestParam, @RequestBody CustomerGridListFormDTO formDTO) {
         screenCollService.insertCustomerGrid(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -231,7 +231,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("customeragency")
-    public Result customerAgency(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<CustomerAgencyFormDTO> formDTO) {
+    public Result customerAgency(ExternalAppRequestParam externalAppRequestParam, @RequestBody CustomerAgencyListFormDTO formDTO) {
         screenCollService.insertCustomerAgency(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -247,7 +247,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("usertotaldata")
-    public Result userTotalData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<UserTotalDataFormDTO> formDTO) {
+    public Result userTotalData(ExternalAppRequestParam externalAppRequestParam, @RequestBody UserTotalDataListFormDTO formDTO) {
         screenCollService.insertUserTotalData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -263,7 +263,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("userjoin")
-    public Result userJoin(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<UserJoinFormDTO> formDTO) {
+    public Result userJoin(ExternalAppRequestParam externalAppRequestParam, @RequestBody UserJoinListFormDTO formDTO) {
         screenCollService.insertUserJoin(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -279,7 +279,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("pioneerdata")
-    public Result pioneerData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<PioneerDataFormDTO> formDTO) {
+    public Result pioneerData(ExternalAppRequestParam externalAppRequestParam, @RequestBody PioneerDataListFormDTO formDTO) {
         screenCollService.insertPioneerData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }
@@ -296,7 +296,7 @@ public class ScreenCollController {
      **/
     @ExternalAppRequestAuth
     @PostMapping("publicpartitotaldata")
-    public Result publicPartiTotalData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<PublicPartiTotalDataFormDTO> formDTO) {
+    public Result publicPartiTotalData(ExternalAppRequestParam externalAppRequestParam, @RequestBody PublicPartiTotalDataListFormDTO formDTO) {
         screenCollService.insertPublicPartiTotalData(formDTO, externalAppRequestParam.getCustomerId());
         return new Result();
     }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.java

@@ -37,24 +37,16 @@ import java.util.Map;
 public interface FactIndexGovrnAblityDeptMonthlyDao extends BaseDao<FactIndexGovrnAblityDeptMonthlyEntity> {
     /**
      * 8、治理能力-部门相关指标
-     *    据CUSTOMER_ID、AGENCY_ID、DEPT_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param agencyId
-     * @param deptId
-     * @param yearId
      * @param monthId
-     * @param quarterId
-     * @param customerId
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexGovrnAblityDeptMonthly(@Param("customerId") String customerId,
-                                               @Param("agencyId") String agencyId,
-                                               @Param("deptId") String deptId,
-                                               @Param("yearId") String yearId,
-                                               @Param("monthId") String monthId,
-                                               @Param("quarterId") String quarterId);
+    Integer deleteFactIndexGovrnAblityDeptMonthly(@Param("customerId") String customerId,
+                                               @Param("monthId") String monthId);
 
     /**
      * 8、治理能力-部门相关指标

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexGovrnAblityGridMonthlyDao.java

@@ -47,15 +47,12 @@ public interface FactIndexGovrnAblityGridMonthlyDao extends BaseDao<FactIndexGov
      * @param yearId
      * @param monthId
      * @param quarterId
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexGovrnAblityGridMonthly(@Param("customerId") String customerId,
-                                               @Param("agencyId") String agencyId,
-                                               @Param("gridId") String gridId,
-                                               @Param("yearId") String yearId,
-                                               @Param("monthId") String monthId,
-                                               @Param("quarterId") String quarterId);
+    Integer deleteFactIndexGovrnAblityGridMonthly(@Param("customerId") String customerId,
+                                               @Param("monthId") String monthId);
 
     /**
      * 6、治理能力-网格相关指标
@@ -92,7 +89,7 @@ public interface FactIndexGovrnAblityGridMonthlyDao extends BaseDao<FactIndexGov
      * @param formDTO
      * @author yinzuomei
      * @description 查询（治理能力-网格相关事实表）当前月共上传了多少条记录
-     * @Date 2020/8/31 14:31 
+     * @Date 2020/8/31 14:31
      **/
     int selectCount(CalculateCommonFormDTO formDTO);
 

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.java

@@ -36,21 +36,16 @@ import java.util.Map;
 public interface FactIndexGovrnAblityOrgMonthlyDao extends BaseDao<FactIndexGovrnAblityOrgMonthlyEntity> {
     /**
      * 7、治理能力-街道及社区相关指标
-     *   据CUSTOMER_ID、AGENCY_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *   根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param quarterId
-     * @param agencyIds
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexGovrnAblityOrgMonthly(@Param("customerId") String customerId,
-                                              @Param("yearId") String yearId,
-                                              @Param("monthId") String monthId,
-                                              @Param("quarterId") String quarterId,
-                                              @Param("agencyIds") String[] agencyIds);
+    Integer deleteFactIndexGovrnAblityOrgMonthly(@Param("customerId") String customerId,
+                                              @Param("monthId") String monthId);
 
     /**
      * 7、治理能力-街道及社区相关指标

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexPartyAblityGridMonthlyDao.java

@@ -39,23 +39,16 @@ public interface FactIndexPartyAblityGridMonthlyDao extends BaseDao<FactIndexPar
 
     /**
      * 2、党建能力-网格相关指标上报(按照月份)
-     *    1) 根据CUSTOMER_ID、AGENCY_ID、GRID_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param agencyId
-     * @param gridId
-     * @param yearId
      * @param monthId
-     * @param quarterId
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexPartyAblityGridMonthly(@Param("customerId") String customerId,
-                                               @Param("agencyId") String agencyId,
-                                               @Param("gridId") String gridId,
-                                               @Param("yearId") String yearId,
-                                               @Param("monthId") String monthId,
-                                               @Param("quarterId") String quarterId);
+    Integer deleteFactIndexPartyAblityGridMonthly(@Param("customerId") String customerId,
+                                               @Param("monthId") String monthId);
 
     /**
      * 2、党建能力-网格相关指标上报(按照月份)

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexPartyAblityOrgMonthlyDao.java

@@ -38,21 +38,16 @@ public interface FactIndexPartyAblityOrgMonthlyDao extends BaseDao<FactIndexPart
 
     /**
      * 3、党建能力-街道及社区相关指标
-     *    根据CUSTOMER_ID、AGENCY_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param quarterId
-     * @param agencyIds
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexPartyAblityOrgMonthly(@Param("customerId") String customerId,
-                                              @Param("yearId") String yearId,
-                                              @Param("monthId") String monthId,
-                                              @Param("quarterId") String quarterId,
-                                              @Param("agencyIds") String[] agencyIds);
+    Integer deleteFactIndexPartyAblityOrgMonthly(@Param("customerId") String customerId,
+                                              @Param("monthId") String monthId);
 
     /**
      * 3、党建能力-街道及社区相关指标

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexServiceAblityGridMonthlyDao.java

@@ -38,23 +38,16 @@ import java.util.Map;
 public interface FactIndexServiceAblityGridMonthlyDao extends BaseDao<FactIndexServiceAblityGridMonthlyEntity> {
     /**
      * 4、服务能力-网格相关指标
-     *   根据CUSTOMER_ID、AGENCY_ID、GRID_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *   根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param agencyId
-     * @param gridId
-     * @param yearId
      * @param monthId
-     * @param quarterId
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexServiceAblityGridMonthly(@Param("customerId") String customerId,
-                                                 @Param("agencyId") String agencyId,
-                                                 @Param("gridId") String gridId,
-                                                 @Param("yearId") String yearId,
-                                                 @Param("monthId") String monthId,
-                                                 @Param("quarterId") String quarterId);
+    Integer deleteFactIndexServiceAblityGridMonthly(@Param("customerId") String customerId,
+                                                 @Param("monthId") String monthId);
 
     /**
      * 4、服务能力-网格相关指标
@@ -91,7 +84,7 @@ public interface FactIndexServiceAblityGridMonthlyDao extends BaseDao<FactIndexS
      * @param formDTO
      * @author yinzuomei
      * @description 查询（服务能力-网格相关事实表）共上传记录数
-     * @Date 2020/9/2 14:28 
+     * @Date 2020/9/2 14:28
      **/
     int selectCount(CalculateCommonFormDTO formDTO);
 

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/indexcoll/FactIndexServiceAblityOrgMonthlyDao.java

@@ -38,21 +38,16 @@ public interface FactIndexServiceAblityOrgMonthlyDao extends BaseDao<FactIndexSe
 
     /**
      * 5、服务能力-组织（街道|社区|全区）相关指标
-     *    根据CUSTOMER_ID、AGENCY_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param quarterId
-     * @param agencyIds
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void deleteFactIndexServiceAblityOrgMonthly(@Param("customerId") String customerId,
-                                              @Param("yearId") String yearId,
-                                              @Param("monthId") String monthId,
-                                              @Param("quarterId") String quarterId,
-                                              @Param("agencyIds") String[] agencyIds);
+    Integer deleteFactIndexServiceAblityOrgMonthly(@Param("customerId") String customerId,
+                                              @Param("monthId") String monthId);
 
     /**
      * 5、服务能力-组织（街道|社区|全区）相关指标

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenCpcBaseDataDao.java

@@ -36,15 +36,14 @@ public interface ScreenCpcBaseDataDao extends BaseDao<ScreenCpcBaseDataEntity> {
 
     /**
      *  2、党员基本情况
-     *    1) 根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteCpcBaseData(@Param("customerId") String customerId,
-                              @Param("orgIds") String[] orgIds);
+    Integer deleteCpcBaseData(@Param("customerId") String customerId);
 
     /**
      *  2、党员基本情况

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenCustomerAgencyDao.java

@@ -35,15 +35,14 @@ import java.util.List;
 public interface ScreenCustomerAgencyDao extends BaseDao<ScreenCustomerAgencyEntity> {
     /**
      *14、组织层级
-     *   1)  根据CUSTOMER_ID、AGENCY_ID进行查询，如果有数据，则先进行物理删除
+     *   1)  根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param agencyIds  组织id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteCustomerAgency(@Param("customerId") String customerId,
-                            @Param("agencyIds") String[] agencyIds);
+    Integer deleteCustomerAgency(@Param("customerId") String customerId);
 
     /**
      * 14、组织层级

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenCustomerDeptDao.java

@@ -36,15 +36,14 @@ public interface ScreenCustomerDeptDao extends BaseDao<ScreenCustomerDeptEntity>
 
     /**
      *16、部门信息上传
-     *   1)  根据CUSTOMER_ID、DEPT_ID进行查询，如果有数据，则先进行物理删除
+     *   1)  根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param deptIds  部门Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteCustomerDept(@Param("customerId") String customerId,
-                         @Param("deptIds") String[] deptIds);
+    Integer deleteCustomerDept(@Param("customerId") String customerId);
 
     /**
      * 16、部门信息上传

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenCustomerGridDao.java

@@ -37,15 +37,14 @@ import java.util.List;
 public interface ScreenCustomerGridDao extends BaseDao<ScreenCustomerGridEntity> {
     /**
      *15、网格信息上传
-     *   1)  根据CUSTOMER_ID、GRID_ID进行查询，如果有数据，则先进行物理删除
+     *   1)  根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param gridIds  网格Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteCustomerGrid(@Param("customerId") String customerId,
-                            @Param("gridIds") String[] gridIds);
+    Integer deleteCustomerGrid(@Param("customerId") String customerId);
 
     /**
      * 15、网格信息上传

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenDifficultyDataDao.java

@@ -36,7 +36,7 @@ import java.util.List;
 public interface ScreenDifficultyDataDao extends BaseDao<ScreenDifficultyDataEntity> {
     /**
      * 3、难点赌点
-     *    1) 根据CUSTOMER_ID、EVENT_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除
 
      * @param customerId  一
      * @Author zhangyong

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenEventDataDao.java

@@ -35,17 +35,14 @@ import java.util.List;
 public interface ScreenEventDataDao extends BaseDao<ScreenEventDataEntity> {
     /**
      * 4、事件数据
-     *    1) 根据CUSTOMER_ID、EVENT_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId  一
-     * @param eventId     多
-     * @param orgId       多
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteEventData(@Param("customerId")String customerId,
-                         @Param("eventId")String eventId,
-                         @Param("orgId")String orgId);
+    Integer deleteEventData(@Param("customerId")String customerId);
 
     /**
      * 4、事件数据

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenGovernRankDataDao.java

@@ -35,19 +35,16 @@ import java.util.List;
 public interface ScreenGovernRankDataDao extends BaseDao<ScreenGovernRankDataEntity> {
     /**
      * 5、基层治理-治理能力数据
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteGovernRankData(@Param("customerId") String customerId,
-                           @Param("yearId") String yearId,
-                           @Param("monthId") String monthId,
-                           @Param("orgIds") String[] orgIds);
+    Integer deleteGovernRankData(@Param("customerId") String customerId,
+                           @Param("monthId") String monthId);
 
     /**
      * 5、基层治理-治理能力数据

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenIndexDataMonthlyDao.java

@@ -36,19 +36,16 @@ public interface ScreenIndexDataMonthlyDao extends BaseDao<ScreenIndexDataMonthl
 
     /**
      *1、指数相关
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteIndexDataMonthly(@Param("customerId") String customerId,
-                           @Param("yearId") String yearId,
-                           @Param("monthId") String monthId,
-                           @Param("orgIds") String[] orgIds);
+    Integer deleteIndexDataMonthly(@Param("customerId") String customerId,
+                           @Param("monthId") String monthId);
 
     /**
      * 1、指数相关

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenIndexDataYearlyDao.java

@@ -36,17 +36,16 @@ public interface ScreenIndexDataYearlyDao extends BaseDao<ScreenIndexDataYearlyE
 
     /**
      * 17、指数_按年统计
-     *    1) 根据CUSTOMER_ID、YEAR_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、YEAR_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
      * @param yearId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteIndexDataYearly(@Param("customerId") String customerId,
-                                @Param("yearId") String yearId,
-                                @Param("orgIds") String[] orgIds);
+    Integer deleteIndexDataYearly(@Param("customerId") String customerId,
+                                @Param("yearId") String yearId);
 
     /**
      * 17、指数_按年统计

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenOrgRankDataDao.java

@@ -35,19 +35,16 @@ import java.util.List;
 public interface ScreenOrgRankDataDao extends BaseDao<ScreenOrgRankDataEntity> {
     /**
      * 6、党建引领-组织排行
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteOrgRankData(@Param("customerId") String customerId,
-                               @Param("yearId") String yearId,
-                               @Param("monthId") String monthId,
-                               @Param("orgIds") String[] orgIds);
+    Integer deleteOrgRankData(@Param("customerId") String customerId,
+                               @Param("monthId") String monthId);
 
     /**
      * 6、党建引领-组织排行

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyBranchDataDao.java

@@ -35,19 +35,16 @@ import java.util.List;
 public interface ScreenPartyBranchDataDao extends BaseDao<ScreenPartyBranchDataEntity> {
     /**
      * 7、基层党建-建设情况数据（支部、联建、志愿）
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deletePartyBranchData(@Param("customerId") String customerId,
-                               @Param("yearId") String yearId,
-                               @Param("monthId") String monthId,
-                               @Param("orgIds") String[] orgIds);
+    Integer deletePartyBranchData(@Param("customerId") String customerId,
+                                  @Param("monthId") String monthId);
 
     /**
      * 7、基层党建-建设情况数据（支部、联建、志愿）

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyLinkMassesDataDao.java

@@ -36,15 +36,14 @@ public interface ScreenPartyLinkMassesDataDao extends BaseDao<ScreenPartyLinkMas
 
     /**
      * 8、党建引领-党员联系群众数据
-     *    1) 根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param orgIds     组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deletePartyLinkMassesData(@Param("customerId") String customerId,
-                                   @Param("orgIds") String[] orgIds);
+    Integer deletePartyLinkMassesData(@Param("customerId") String customerId);
 
     /**
      * 8、党建引领-党员联系群众数据

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyUserRankDataDao.java

@@ -36,17 +36,14 @@ public interface ScreenPartyUserRankDataDao extends BaseDao<ScreenPartyUserRankD
 
     /**
      * 9、党建引领|基层治理-居民（党员）积分排行榜
-     *    1) 根据CUSTOMER_ID、GRID_ID、USER_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param gridId
-     * @param userId
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deletePartyUserRankData(@Param("customerId") String customerId,
-                                 @Param("gridId") String gridId,
-                                 @Param("userId") String userId);
+    Integer deletePartyUserRankData(@Param("customerId") String customerId);
 
     /**
      * 9、党建引领|基层治理-居民（党员）积分排行榜

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPioneerDataDao.java

@@ -36,15 +36,14 @@ public interface ScreenPioneerDataDao extends BaseDao<ScreenPioneerDataEntity> {
 
     /**
      * 10、党建引领-先锋模范数据
-     *    1)  根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deletePioneerData(@Param("customerId") String customerId,
-                        @Param("orgIds") String[] orgIds);
+    Integer deletePioneerData(@Param("customerId") String customerId);
 
     /**
      * 10、党建引领-先锋模范数据

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPublicPartiTotalDataDao.java

@@ -37,15 +37,14 @@ public interface ScreenPublicPartiTotalDataDao extends BaseDao<ScreenPublicParti
     /**
      * 18、公众参与各类总数
      *     公众参与-各类(用户|党员|党群|话题|议题|项目|注册人数|参与人数)总数
-     *     1)  根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *     1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-25
      **/
-    void deletePublicPartiTotalData(@Param("customerId") String customerId,
-                           @Param("orgIds") String[] orgIds);
+    Integer deletePublicPartiTotalData(@Param("customerId") String customerId);
 
     /**
      * 18、公众参与各类总数

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenUserJoinDao.java

@@ -51,19 +51,16 @@ public interface ScreenUserJoinDao extends BaseDao<ScreenUserJoinEntity> {
 
     /**
      * 11、基层治理-公众参与
-     *    1)  根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param yearId
      * @param monthId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteUserJoin(@Param("customerId") String customerId,
-                        @Param("yearId") String yearId,
-                        @Param("monthId") String monthId,
-                        @Param("orgIds") String[] orgIds);
+    Integer deleteUserJoin(@Param("customerId") String customerId,
+                        @Param("monthId") String monthId);
 
     /**
      * 11、基层治理-公众参与

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenUserTotalDataDao.java

@@ -36,15 +36,14 @@ public interface ScreenUserTotalDataDao extends BaseDao<ScreenUserTotalDataEntit
 
     /**
      * 12、中央区各类总数
-     *    1)  根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param customerId
-     * @param orgIds  组织Id集合
+     * @return java.util.Integer
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void deleteUserTotalData(@Param("customerId") String customerId,
-                                     @Param("orgIds") String[] orgIds);
+    Integer deleteUserTotalData(@Param("customerId") String customerId);
 
     /**
      * 12、中央区各类总数

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/indexcoll/FactIndexCollectService.java

@@ -26,7 +26,7 @@ public interface FactIndexCollectService {
 
     /**
      *  2、党建能力-网格相关指标上报(按照月份)
-     *    根据CUSTOMER_ID、AGENCY_ID、GRID_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param formDTO
      * @param customerId
@@ -34,11 +34,11 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertGridPartyAbility(List<GridPartyAbilityFormDTO> formDTO, String customerId);
+    void insertGridPartyAbility(GridPartyAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 3、党建能力-街道及社区相关指标
-     *    根据CUSTOMER_ID、AGENCY_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param formDTO
      * @param customerId
@@ -46,11 +46,11 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertOrgPartyAbility(List<OrgPartyAbilityFormDTO> formDTO, String customerId);
+    void insertOrgPartyAbility(OrgPartyAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 4、服务能力-网格相关指标
-     *    据CUSTOMER_ID、AGENCY_ID、GRID_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param formDTO
      * @param customerId
@@ -58,11 +58,11 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertGridServiceAbility(List<GridServiceAbilityFormDTO> formDTO, String customerId);
+    void insertGridServiceAbility(GridServiceAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 5、服务能力-组织（街道|社区|全区）相关指标
-     *    据CUSTOMER_ID、AGENCY_ID、GRID_ID、YEAR_ID、MONTH_ID、QUARTER_ID进行查询，如果有数据，则先进行物理删除
+     *    根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *
      * @param formDTO
      * @param customerId
@@ -70,7 +70,7 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertOrgServiceAbility(List<OrgServiceAbilityFormDTO> formDTO, String customerId);
+    void insertOrgServiceAbility(OrgServiceAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 6、治理能力-网格相关指标
@@ -82,7 +82,7 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertGridGovrnAbility(List<GridGovrnAbilityFormDTO> formDTO, String customerId);
+    void insertGridGovrnAbility(GridGovrnAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 7、治理能力-街道及社区相关指标
@@ -94,7 +94,7 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertOrgGovrnAbility(List<OrgGovrnAbilityFormDTO> formDTO, String customerId);
+    void insertOrgGovrnAbility(OrgGovrnAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 8、治理能力-部门相关指标
@@ -106,7 +106,7 @@ public interface FactIndexCollectService {
      * @Author zhangyong
      * @Date 10:52 2020-08-20
      **/
-    void insertDeptGovrnAbility(List<DeptGovrnAbilityFormDTO> formDTO, String customerId);
+    void insertDeptGovrnAbility(DeptGovrnAbilityDataFormDTO formDTO, String customerId);
 
     /**
      * 将网格、社区、区直部门、区/街道分支记录表中的数据，抽取到 指数-指数数据(每月数值)  指数-指数数据(按年统计)

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/indexcoll/impl/FactIndexCollectServiceImpl.java

@@ -1,7 +1,6 @@
 package com.epmet.service.evaluationindex.indexcoll.impl;
 
 import com.epmet.commons.dynamic.datasource.annotation.DataSource;
-import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.DateUtils;
@@ -27,8 +26,6 @@ import com.epmet.entity.evaluationindex.screen.ScreenCustomerDeptEntity;
 import com.epmet.eum.IndexCodeEnum;
 import com.epmet.service.evaluationindex.indexcoll.FactIndexCollectService;
 import lombok.extern.slf4j.Slf4j;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -48,7 +45,6 @@ import java.util.stream.Collectors;
 @Service
 @DataSource(DataSourceConstant.EVALUATION_INDEX)
 public class FactIndexCollectServiceImpl implements FactIndexCollectService {
-    private static final Logger log = LoggerFactory.getLogger(FactIndexCollectServiceImpl.class);
 
     @Autowired
     private FactIndexPartyAblityCpcMonthlyDao factIndexPartyAblityCpcMonthlyDao;
@@ -96,118 +92,113 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
                 deleteNum = factIndexPartyAblityCpcMonthlyDao.deleteFactIndexPartyAblityCpcMonthly(customerId, formDTO.getMonthId());
             } while (deleteNum != NumConstant.ZERO);
         }
-        if (null != formDTO && !CollectionUtils.isEmpty(formDTO.getPartyMemberDataList())) {
-            factIndexPartyAblityCpcMonthlyDao.batchInsertFactIndexPartyAblityCpcMonthly(formDTO.getPartyMemberDataList(), customerId);
+        if (null != formDTO && !CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexPartyAblityCpcMonthlyDao.batchInsertFactIndexPartyAblityCpcMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertGridPartyAbility(List<GridPartyAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                factIndexPartyAblityGridMonthlyDao.deleteFactIndexPartyAblityGridMonthly(customerId,
-                        formDTO.get(i).getAgencyId(), formDTO.get(i).getGridId(), formDTO.get(i).getYearId(),
-                        formDTO.get(i).getMonthId(), formDTO.get(i).getQuarterId());
-            }
-            factIndexPartyAblityGridMonthlyDao.batchInsertFactIndexPartyAblityGridMonthly(formDTO, customerId);
+    public void insertGridPartyAbility(GridPartyAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexPartyAblityGridMonthlyDao.deleteFactIndexPartyAblityGridMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if ( !CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexPartyAblityGridMonthlyDao.batchInsertFactIndexPartyAblityGridMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertOrgPartyAbility(List<OrgPartyAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] agencyIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                agencyIds[i] = formDTO.get(i).getAgencyId();
-            }
-            factIndexPartyAblityOrgMonthlyDao.deleteFactIndexPartyAblityOrgMonthly(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    formDTO.get(NumConstant.ZERO).getQuarterId(),
-                    agencyIds);
-            factIndexPartyAblityOrgMonthlyDao.batchInsertFactIndexPartyAblityOrgMonthly(formDTO, customerId);
+    public void insertOrgPartyAbility(OrgPartyAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexPartyAblityOrgMonthlyDao.deleteFactIndexPartyAblityOrgMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexPartyAblityOrgMonthlyDao.batchInsertFactIndexPartyAblityOrgMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertGridServiceAbility(List<GridServiceAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                factIndexServiceAblityGridMonthlyDao.deleteFactIndexServiceAblityGridMonthly(customerId,
-                        formDTO.get(i).getAgencyId(), formDTO.get(i).getGridId(), formDTO.get(i).getYearId(),
-                        formDTO.get(i).getMonthId(), formDTO.get(i).getQuarterId());
-            }
-            factIndexServiceAblityGridMonthlyDao.batchInsertFactIndexServiceAblityGridMonthly(formDTO, customerId);
+    public void insertGridServiceAbility(GridServiceAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexServiceAblityGridMonthlyDao.deleteFactIndexServiceAblityGridMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexServiceAblityGridMonthlyDao.batchInsertFactIndexServiceAblityGridMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertOrgServiceAbility(List<OrgServiceAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] agencyIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                agencyIds[i] = formDTO.get(i).getAgencyId();
-            }
-            factIndexServiceAblityOrgMonthlyDao.deleteFactIndexServiceAblityOrgMonthly(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    formDTO.get(NumConstant.ZERO).getQuarterId(),
-                    agencyIds);
-            factIndexServiceAblityOrgMonthlyDao.batchInsertFactIndexServiceAblityOrgMonthly(formDTO, customerId);
+    public void insertOrgServiceAbility(OrgServiceAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexServiceAblityOrgMonthlyDao.deleteFactIndexServiceAblityOrgMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexServiceAblityOrgMonthlyDao.batchInsertFactIndexServiceAblityOrgMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertGridGovrnAbility(List<GridGovrnAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                factIndexGovrnAblityGridMonthlyDao.deleteFactIndexGovrnAblityGridMonthly(customerId,
-                        formDTO.get(i).getAgencyId(), formDTO.get(i).getGridId(), formDTO.get(i).getYearId(),
-                        formDTO.get(i).getMonthId(), formDTO.get(i).getQuarterId());
-            }
-            factIndexGovrnAblityGridMonthlyDao.batchInsertFactIndexGovrnAblityGridMonthly(formDTO, customerId);
+    public void insertGridGovrnAbility(GridGovrnAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexGovrnAblityGridMonthlyDao.deleteFactIndexGovrnAblityGridMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexGovrnAblityGridMonthlyDao.batchInsertFactIndexGovrnAblityGridMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertOrgGovrnAbility(List<OrgGovrnAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] agencyIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                agencyIds[i] = formDTO.get(i).getAgencyId();
-            }
-            factIndexGovrnAblityOrgMonthlyDao.deleteFactIndexGovrnAblityOrgMonthly(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    formDTO.get(NumConstant.ZERO).getQuarterId(),
-                    agencyIds);
-            factIndexGovrnAblityOrgMonthlyDao.batchInsertFactIndexGovrnAblityOrgMonthly(formDTO, customerId);
+    public void insertOrgGovrnAbility(OrgGovrnAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexGovrnAblityOrgMonthlyDao.deleteFactIndexGovrnAblityOrgMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexGovrnAblityOrgMonthlyDao.batchInsertFactIndexGovrnAblityOrgMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertDeptGovrnAbility(List<DeptGovrnAbilityFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                factIndexGovrnAblityDeptMonthlyDao.deleteFactIndexGovrnAblityDeptMonthly(customerId,
-                        formDTO.get(i).getAgencyId(), formDTO.get(i).getDeptId(), formDTO.get(i).getYearId(),
-                        formDTO.get(i).getMonthId(), formDTO.get(i).getQuarterId());
-            }
-            factIndexGovrnAblityDeptMonthlyDao.batchInsertFactIndexGovrnAblityDeptMonthly(formDTO, customerId);
+    public void insertDeptGovrnAbility(DeptGovrnAbilityDataFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = factIndexGovrnAblityDeptMonthlyDao.deleteFactIndexGovrnAblityDeptMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            factIndexGovrnAblityDeptMonthlyDao.batchInsertFactIndexGovrnAblityDeptMonthly(formDTO.getDataList(), customerId);
         }
     }
 
@@ -283,13 +274,9 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         Map<String, List<FactIndexGridScoreDTO>> collect = gridScoreDTOS.stream().collect(Collectors.groupingBy(FactIndexGridScoreDTO::getGridId));
         // 查询网格的 上级组织id 和 组织名称
         List<ScreenCustomerGridDTO> parentGridList = screenCustomerGridDao.selectListGridInfo(customerId);
-        String[] orgIds = new String[collect.size()];
-        int j = 0;
         for(Map.Entry<String,List<FactIndexGridScoreDTO>> gridScore : collect.entrySet()){
             IndexDataMonthlyFormDTO monthlyFormDTO = new IndexDataMonthlyFormDTO();
-            // 网格id
-            orgIds[j] = gridScore.getKey();
-            j++;
+
             // 给4个指数 赋默认值
             monthlyFormDTO = this.setIndexDefaultValueFor(monthlyFormDTO);
             for ( int i = 0; i < gridScore.getValue().size(); i++){
@@ -324,7 +311,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
             monthlyFormDTOList.add(monthlyFormDTO);
         }
         if (monthlyFormDTOList.size() > NumConstant.ZERO){
-            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, getYearStr(monthId), monthId, orgIds);
+            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, monthId);
             screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(monthlyFormDTOList, customerId);
         }
     }
@@ -382,13 +369,8 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         Map<String, List<FactIndexCommunityScoreDTO>> collect = communityScoreDTOS.stream().collect(Collectors.groupingBy(FactIndexCommunityScoreDTO::getAgencyId));
         // 根据客户id，查询区/街道  组织名称、id
         List<ScreenCustomerAgencyEntity> parentAgencyList = screenCustomerAgencyDao.selectListAgencyInfo(customerId);
-        String[] orgIds = new String[collect.size()];
-        int j = 0;
         for(Map.Entry<String,List<FactIndexCommunityScoreDTO>> communityScore : collect.entrySet()){
             IndexDataMonthlyFormDTO monthlyFormDTO = new IndexDataMonthlyFormDTO();
-            // 组织id
-            orgIds[j] = communityScore.getKey();
-            j++;
             // 给4个指数 赋默认值
             monthlyFormDTO = this.setIndexDefaultValueFor(monthlyFormDTO);
             for ( int i = 0; i < communityScore.getValue().size(); i++){
@@ -425,7 +407,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
             monthlyFormDTOList.add(monthlyFormDTO);
         }
         if (monthlyFormDTOList.size() > NumConstant.ZERO){
-            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, getYearStr(monthId), monthId, orgIds);
+            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, monthId);
             screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(monthlyFormDTOList, customerId);
         }
     }
@@ -478,13 +460,8 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         // 根据部门id 进行分组，最后组装一条数据   一个部门id 对应 4条数据
         Map<String, List<DeptScoreDTO>> collect = deptScoreDTOS.stream().collect(Collectors.groupingBy(DeptScoreDTO::getDeptId));
         List<ScreenCustomerDeptEntity> parentDeptList = screenCustomerDeptDao.selectListDeptInfo(customerId);
-        String[] orgIds = new String[collect.size()];
-        int j = 0;
         for(Map.Entry<String,List<DeptScoreDTO>> deptScore : collect.entrySet()){
             IndexDataMonthlyFormDTO monthlyFormDTO = new IndexDataMonthlyFormDTO();
-            // 部门id
-            orgIds[j] = deptScore.getKey();
-            j++;
             // 给4个指数 赋默认值
             monthlyFormDTO = this.setIndexDefaultValueFor(monthlyFormDTO);
             for ( int i = 0; i < deptScore.getValue().size(); i++){
@@ -513,7 +490,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
             monthlyFormDTOList.add(monthlyFormDTO);
         }
         if (monthlyFormDTOList.size() > NumConstant.ZERO){
-            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, getYearStr(monthId), monthId, orgIds);
+            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, monthId);
             screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(monthlyFormDTOList, customerId);
         }
     }
@@ -564,13 +541,9 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         // 根据组织id(eg：社区或者街道id) 进行分组，最后组装一条数据   一个组织id 对应 4条数据
         Map<String, List<AgencyScoreDTO>> collect = agencyScoreDTOS.stream().collect(Collectors.groupingBy(AgencyScoreDTO::getAgencyId));
         List<ScreenCustomerAgencyEntity> parentAgencyList = screenCustomerAgencyDao.selectListAgencyInfo(customerId);
-        String[] orgIds = new String[collect.size()];
         int j = 0;
         for(Map.Entry<String,List<AgencyScoreDTO>> agencyScore : collect.entrySet()){
             IndexDataMonthlyFormDTO monthlyFormDTO = new IndexDataMonthlyFormDTO();
-            // 组织id(eg：社区或者街道id)
-            orgIds[j] = agencyScore.getKey();
-            j++;
             // 给4个指数 赋默认值
             monthlyFormDTO = this.setIndexDefaultValueFor(monthlyFormDTO);
             for ( int i = 0; i < agencyScore.getValue().size(); i++){
@@ -602,7 +575,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
             monthlyFormDTOList.add(monthlyFormDTO);
         }
         if (monthlyFormDTOList.size() > NumConstant.ZERO){
-            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, getYearStr(monthId), monthId, orgIds);
+            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, monthId);
             screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(monthlyFormDTOList, customerId);
         }
     }
@@ -872,12 +845,8 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
      **/
     private void insertIndexDataYear(String monthId, String customerId){
         List<IndexDataMonthlyFormDTO> monthlyFormList = screenIndexDataMonthlyDao.selectListIndexDataMonthlyByYear(customerId, getYearStr(monthId), getMonthStr(monthId));
-        String[] orgIds = new String[monthlyFormList.size()];
-        for (int i = NumConstant.ZERO; i < monthlyFormList.size(); i++){
-            orgIds[i] = monthlyFormList.get(i).getOrgId();
-        }
         if (monthlyFormList.size() > NumConstant.ZERO){
-            screenIndexDataYearlyDao.deleteIndexDataYearly(customerId, getYearStr(monthId), orgIds);
+            screenIndexDataYearlyDao.deleteIndexDataYearly(customerId, getYearStr(monthId));
             List<IndexDataYearlyFormDTO> entity = ConvertUtils.sourceToTarget(monthlyFormList, IndexDataYearlyFormDTO.class);
             screenIndexDataYearlyDao.batchInsertIndexDataYearly(entity, customerId);
         }

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

@@ -13,7 +13,7 @@ public interface ScreenCollService {
 
     /**
      * 9、党建引领|基层治理-居民（党员）积分排行榜
-     *    1) 根据CUSTOMER_ID、GRID_ID、USER_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -22,11 +22,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertPartyUserRankData(List<PartyUserRankDataFormDTO> formDTO, String customerId);
+    void insertPartyUserRankData(PartyUserRankDataListFormDTO formDTO, String customerId);
 
     /**
      * 8、党建引领-党员联系群众数据
-     *    1) 根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -35,11 +35,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertPartyLinkMassesData(List<PartyLinkMassesDataFormDTO> formDTO, String customerId);
+    void insertPartyLinkMassesData(PartyLinkMassesDataListFormDTO formDTO, String customerId);
 
     /**
      * 7、基层党建-建设情况数据（支部、联建、志愿）
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -48,11 +48,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertPartyBranchData(List<PartyBranchDataFormDTO> formDTO, String customerId);
+    void insertPartyBranchData(PartyBranchDataListFormDTO formDTO, String customerId);
 
     /**
      * 6、党建引领-组织排行
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -61,11 +61,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertOrgRankData(List<OrgRankDataFormDTO> formDTO, String customerId);
+    void insertOrgRankData(OrgRankDataListFormDTO formDTO, String customerId);
 
     /**
      * 5、基层治理-治理能力数据
-     *    1) 根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -74,11 +74,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertGovernRankData(List<GovernRankDataFormDTO> formDTO, String customerId);
+    void insertGovernRankData(GovernRankDataListFormDTO formDTO, String customerId);
 
     /**
      * 4、事件数据
-     *    1) 根据CUSTOMER_ID、EVENT_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -87,11 +87,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertEventData(List<EventDataFormDTO> formDTO, String customerId);
+    void insertEventData(EventDataListFormDTO formDTO, String customerId);
 
     /**
      * 3、难点赌点
-     *    1) 根据CUSTOMER_ID、EVENT_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除
      *    2) 在新增
      *
      * @param formDTO
@@ -104,7 +104,7 @@ public interface ScreenCollService {
 
     /**
      * 2、党员基本情况
-     *    1) 根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -113,11 +113,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertCpcbaseData(List<CpcBaseDataFormDTO> formDTO, String customerId);
+    void insertCpcbaseData(CpcBaseDataListFormDTO formDTO, String customerId);
 
     /**
      * 1、指数_按月统计
-     *    1)  根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -126,11 +126,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertIndexDataMonthly(List<IndexDataMonthlyFormDTO> formDTO, String customerId);
+    void insertIndexDataMonthly(IndexDataListMonthlyFormDTO formDTO, String customerId);
 
     /**
      * 17、指数_按年统计
-     *    1)  根据CUSTOMER_ID、YEAR_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID、YEAR_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -139,11 +139,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertIndexDataYearly(List<IndexDataYearlyFormDTO> formDTO, String customerId);
+    void insertIndexDataYearly(IndexDataListYearlyFormDTO formDTO, String customerId);
 
     /**
      * 16、部门信息上传
-     *    1)  根据CUSTOMER_ID、DEPT_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -152,11 +152,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertCustomerDept(List<CustomerDeptFormDTO> formDTO, String customerId);
+    void insertCustomerDept(CustomerDeptListFormDTO formDTO, String customerId);
 
     /**
      * 15、网格信息上传
-     *    1)  根据CUSTOMER_ID、GRID_ID进行查询，如果有数据，则先进行物理删除
+     *    1) 根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -165,11 +165,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertCustomerGrid(List<CustomerGridFormDTO> formDTO, String customerId);
+    void insertCustomerGrid(CustomerGridListFormDTO formDTO, String customerId);
 
     /**
      * 14、组织层级
-     *    1)  根据CUSTOMER_ID、AGENCY_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID 进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -178,7 +178,7 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertCustomerAgency(List<CustomerAgencyFormDTO> formDTO, String customerId);
+    void insertCustomerAgency(CustomerAgencyListFormDTO formDTO, String customerId);
 
     /**
      * 12、中央区各类总数
@@ -191,11 +191,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertUserTotalData(List<UserTotalDataFormDTO> formDTO, String customerId);
+    void insertUserTotalData(UserTotalDataListFormDTO formDTO, String customerId);
 
     /**
      * 11、基层治理-公众参与
-     *    1)  根据CUSTOMER_ID、YEAR_ID、MONTH_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID、MONTH_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -204,11 +204,11 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertUserJoin(List<UserJoinFormDTO> formDTO, String customerId);
+    void insertUserJoin(UserJoinListFormDTO formDTO, String customerId);
 
     /**
      * 10、党建引领-先锋模范数据
-     *    1)  根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *    1)  根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *    2) 在新增
      *
      * @param formDTO
@@ -217,12 +217,12 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 10:52 2020-08-18
      **/
-    void insertPioneerData(List<PioneerDataFormDTO> formDTO, String customerId);
+    void insertPioneerData(PioneerDataListFormDTO formDTO, String customerId);
 
     /**
      * 18、公众参与各类总数
      * 公众参与-各类(用户|党员|党群|话题|议题|项目|注册人数|参与人数)总数
-     *   1)  根据CUSTOMER_ID、ORG_ID进行查询，如果有数据，则先进行物理删除
+     *   1) 根据CUSTOMER_ID进行查询，如果有数据，则先进行物理删除, 一次删除1000条
      *   2) 在新增
      * @param formDTO
      * @param formDTO
@@ -230,5 +230,5 @@ public interface ScreenCollService {
      * @Author zhangyong
      * @Date 09:44 2020-08-25
      **/
-    void insertPublicPartiTotalData(List<PublicPartiTotalDataFormDTO> formDTO, String customerId);
+    void insertPublicPartiTotalData(PublicPartiTotalDataListFormDTO formDTO, String customerId);
 }

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

@@ -87,110 +87,104 @@ public class ScreenCollServiceImpl implements ScreenCollService {
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertPartyUserRankData(List<PartyUserRankDataFormDTO> formDTO,String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                screenPartyUserRankDataDao.deletePartyUserRankData(customerId,
-                        formDTO.get(NumConstant.ZERO).getGridId(),
-                        formDTO.get(NumConstant.ZERO).getUserId());
-            }
-
-            screenPartyUserRankDataDao.batchInsertPartyUserRankData(formDTO,customerId);
+    public void insertPartyUserRankData(PartyUserRankDataListFormDTO formDTO,String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenPartyUserRankDataDao.deletePartyUserRankData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenPartyUserRankDataDao.batchInsertPartyUserRankData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertPartyLinkMassesData(List<PartyLinkMassesDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenPartyLinkMassesDataDao.deletePartyLinkMassesData(customerId, orgIds);
-
-            screenPartyLinkMassesDataDao.batchInsertPartyLinkMassesData(formDTO, customerId);
+    public void insertPartyLinkMassesData(PartyLinkMassesDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenPartyLinkMassesDataDao.deletePartyLinkMassesData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenPartyLinkMassesDataDao.batchInsertPartyLinkMassesData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertPartyBranchData(List<PartyBranchDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenPartyBranchDataDao.deletePartyBranchData(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    orgIds);
-
-            screenPartyBranchDataDao.batchInsertPartyBranchData(formDTO, customerId);
+    public void insertPartyBranchData(PartyBranchDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenPartyBranchDataDao.deletePartyBranchData(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenPartyBranchDataDao.batchInsertPartyBranchData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertOrgRankData(List<OrgRankDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenOrgRankDataDao.deleteOrgRankData(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    orgIds);
-
-            screenOrgRankDataDao.batchInsertOrgRankData(formDTO, customerId);
+    public void insertOrgRankData(OrgRankDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenOrgRankDataDao.deleteOrgRankData(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenOrgRankDataDao.batchInsertOrgRankData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertGovernRankData(List<GovernRankDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenGovernRankDataDao.deleteGovernRankData(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    orgIds);
-
-            screenGovernRankDataDao.batchInsertGovernRankData(formDTO, customerId);
+    public void insertGovernRankData(GovernRankDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenGovernRankDataDao.deleteGovernRankData(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenGovernRankDataDao.batchInsertGovernRankData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertEventData(List<EventDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                screenEventDataDao.deleteEventData(customerId, formDTO.get(i).getEventId(), formDTO.get(i).getOrgId());
-            }
-
-            screenEventDataDao.batchInsertEventData(formDTO, customerId);
+    public void insertEventData(EventDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenEventDataDao.deleteEventData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenEventDataDao.batchInsertEventData(formDTO.getDataList(), customerId);
+        }
 
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++) {
-                if (null != formDTO.get(i).getImgDataList() && formDTO.get(i).getImgDataList().size() > NumConstant.ZERO) {
-                    // 根据原始事件ID，物理删除 - 事件数据图片数据
-                    screenEventImgDataDao.delEventImgDataByEventId(formDTO.get(i).getEventId());
-                    for (int j = NumConstant.ZERO; j < formDTO.get(i).getImgDataList().size(); j++){
-                        // 新增 中央区-事件数据图片数据 表
-                        ScreenEventImgDataEntity imgDataEntity = new ScreenEventImgDataEntity();
-                        imgDataEntity.setEventId(formDTO.get(i).getImgDataList().get(j).getEventId());
-                        imgDataEntity.setEventImgUrl(formDTO.get(i).getImgDataList().get(j).getImgUrl());
-                        imgDataEntity.setSort(formDTO.get(i).getImgDataList().get(j).getSort());
-                        screenEventImgDataDao.insert(imgDataEntity);
-                    }
+        // 处理图片
+        for (int i = NumConstant.ZERO; i < formDTO.getDataList().size(); i++) {
+            if (null != formDTO.getDataList().get(i).getImgDataList() && formDTO.getDataList().get(i).getImgDataList().size() > NumConstant.ZERO) {
+                // 根据原始事件ID，物理删除 - 事件数据图片数据
+                screenEventImgDataDao.delEventImgDataByEventId(formDTO.getDataList().get(i).getEventId());
+                for (int j = NumConstant.ZERO; j < formDTO.getDataList().get(i).getImgDataList().size(); j++){
+                    // 新增 中央区-事件数据图片数据 表
+                    ScreenEventImgDataEntity imgDataEntity = new ScreenEventImgDataEntity();
+                    imgDataEntity.setEventId(formDTO.getDataList().get(i).getImgDataList().get(j).getEventId());
+                    imgDataEntity.setEventImgUrl(formDTO.getDataList().get(i).getImgDataList().get(j).getImgUrl());
+                    imgDataEntity.setSort(formDTO.getDataList().get(i).getImgDataList().get(j).getSort());
+                    screenEventImgDataDao.insert(imgDataEntity);
                 }
             }
         }
@@ -204,178 +198,177 @@ public class ScreenCollServiceImpl implements ScreenCollService {
             //直接删除当前客户下所有的数据
             screenDifficultyDataDao.deleteDifficultyData(customerId);
         }
-        if (null != formDTO && !CollectionUtils.isEmpty(formDTO.getDiffcultyDataList())){
-            screenDifficultyDataDao.batchInsertDifficultyData(formDTO.getDiffcultyDataList(), customerId);
+        if (null != formDTO && !CollectionUtils.isEmpty(formDTO.getDataList())){
+            screenDifficultyDataDao.batchInsertDifficultyData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertCpcbaseData(List<CpcBaseDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenCpcBaseDataDao.deleteCpcBaseData(customerId, orgIds);
-
-            screenCpcBaseDataDao.batchInsertCpcBaseData(formDTO, customerId);
+    public void insertCpcbaseData(CpcBaseDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenCpcBaseDataDao.deleteCpcBaseData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenCpcBaseDataDao.batchInsertCpcBaseData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertIndexDataMonthly(List<IndexDataMonthlyFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    orgIds);
-
-            screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(formDTO, customerId);
+    public void insertIndexDataMonthly(IndexDataListMonthlyFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenIndexDataMonthlyDao.deleteIndexDataMonthly(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenIndexDataMonthlyDao.batchInsertIndexDataMonthly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertIndexDataYearly(List<IndexDataYearlyFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenIndexDataYearlyDao.deleteIndexDataYearly(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    orgIds);
-
-            screenIndexDataYearlyDao.batchInsertIndexDataYearly(formDTO, customerId);
+    public void insertIndexDataYearly(IndexDataListYearlyFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenIndexDataYearlyDao.deleteIndexDataYearly(customerId, formDTO.getYearId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenIndexDataYearlyDao.batchInsertIndexDataYearly(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertCustomerDept(List<CustomerDeptFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] deptIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                deptIds[i] = formDTO.get(i).getDeptId();
-            }
-            screenCustomerDeptDao.deleteCustomerDept(customerId, deptIds);
-
-            screenCustomerDeptDao.batchInsertCustomerDept(formDTO, customerId);
+    public void insertCustomerDept(CustomerDeptListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenCustomerDeptDao.deleteCustomerDept(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenCustomerDeptDao.batchInsertCustomerDept(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertCustomerGrid(List<CustomerGridFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] gridIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                gridIds[i] = formDTO.get(i).getGridId();
-            }
-            screenCustomerGridDao.deleteCustomerGrid(customerId,  gridIds);
-
-            screenCustomerGridDao.batchInsertCustomerGrid(formDTO, customerId);
+    public void insertCustomerGrid(CustomerGridListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenCustomerGridDao.deleteCustomerGrid(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenCustomerGridDao.batchInsertCustomerGrid(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertCustomerAgency(List<CustomerAgencyFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] agencyIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                agencyIds[i] = formDTO.get(i).getAgencyId();
-            }
-            screenCustomerAgencyDao.deleteCustomerAgency(customerId, agencyIds);
-
-            screenCustomerAgencyDao.batchInsertCustomerAgency(formDTO, customerId);
+    public void insertCustomerAgency(CustomerAgencyListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenCustomerAgencyDao.deleteCustomerAgency(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenCustomerAgencyDao.batchInsertCustomerAgency(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertUserTotalData(List<UserTotalDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenUserTotalDataDao.deleteUserTotalData(customerId, orgIds);
-
-            screenUserTotalDataDao.batchInsertUserTotalData(formDTO, customerId);
+    public void insertUserTotalData(UserTotalDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenUserTotalDataDao.deleteUserTotalData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenUserTotalDataDao.batchInsertUserTotalData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertUserJoin(List<UserJoinFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenUserJoinDao.deleteUserJoin(customerId,
-                    formDTO.get(NumConstant.ZERO).getYearId(),
-                    formDTO.get(NumConstant.ZERO).getMonthId(),
-                    orgIds);
-
-            String[] lastMonth = this.lastMonthDate();
-            // 获取上个月的基本数据
-            String moneth = lastMonth[NumConstant.ZERO] + lastMonth[NumConstant.ONE];
-            List<ScreenUserJoinEntity> lastMonthJoinList = screenUserJoinDao.selectLastMonthScreenUserJoinList(customerId,
-                    lastMonth[NumConstant.ZERO],
-                    moneth,
-                    orgIds);
+    public void insertUserJoin(UserJoinListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenUserJoinDao.deleteUserJoin(customerId, formDTO.getMonthId());
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            if (formDTO.getDataList().size() > NumConstant.ZERO){
+                String[] orgIds = new String[formDTO.getDataList().size()];
+                for (int i = NumConstant.ZERO; i < formDTO.getDataList().size(); i++){
+                    orgIds[i] = formDTO.getDataList().get(i).getOrgId();
+                }
 
-            // 定义本月待添加数据的集合
-            List<ScreenUserJoinEntity> curMonthJoinEntityList = new ArrayList<>();
-            // 增加率计算
-            if (null != lastMonthJoinList && lastMonthJoinList.size() > NumConstant.ZERO){
-                // 存在上个月的数据 （本月-上月）/上月  *100
-                for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                    for (int j = NumConstant.ZERO; j < lastMonthJoinList.size(); j++){
-                        if (formDTO.get(i).getOrgId().equals(lastMonthJoinList.get(j).getOrgId())){
-                            ScreenUserJoinEntity entity = ConvertUtils.sourceToTarget(formDTO.get(i), ScreenUserJoinEntity.class);
-                            entity.setJoinTotalUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getJoinTotal(), formDTO.get(j).getJoinTotal()));
-                            entity.setJoinTotalUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getJoinTotal(), formDTO.get(j).getJoinTotal()));
-                            entity.setAvgIssueUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getAvgIssue(), formDTO.get(j).getAvgIssue()));
-                            entity.setAvgIssueUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getAvgIssue(), formDTO.get(j).getAvgIssue()));
-                            entity.setAgvgJoinUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getAvgJoin(), formDTO.get(j).getAvgJoin()));
-                            entity.setAgvgJoinUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getAvgJoin(), formDTO.get(j).getAvgJoin()));
-                            curMonthJoinEntityList.add(entity);
+                String[] lastMonth = this.lastMonthDate();
+                // 获取上个月的基本数据
+                String moneth = lastMonth[NumConstant.ZERO] + lastMonth[NumConstant.ONE];
+                List<ScreenUserJoinEntity> lastMonthJoinList = screenUserJoinDao.selectLastMonthScreenUserJoinList(customerId,
+                        lastMonth[NumConstant.ZERO],
+                        moneth,
+                        orgIds);
+
+                // 定义本月待添加数据的集合
+                List<ScreenUserJoinEntity> curMonthJoinEntityList = new ArrayList<>();
+                // 增加率计算
+                if (null != lastMonthJoinList && lastMonthJoinList.size() > NumConstant.ZERO){
+                    // 存在上个月的数据 （本月-上月）/上月  *100
+                    for (int i = NumConstant.ZERO; i < formDTO.getDataList().size(); i++){
+                        for (int j = NumConstant.ZERO; j < lastMonthJoinList.size(); j++){
+                            if (formDTO.getDataList().get(i).getOrgId().equals(lastMonthJoinList.get(j).getOrgId())){
+                                ScreenUserJoinEntity entity = ConvertUtils.sourceToTarget(formDTO.getDataList().get(i), ScreenUserJoinEntity.class);
+                                entity.setJoinTotalUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getJoinTotal(), formDTO.getDataList().get(j).getJoinTotal()));
+                                entity.setJoinTotalUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getJoinTotal(), formDTO.getDataList().get(j).getJoinTotal()));
+                                entity.setAvgIssueUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getAvgIssue(), formDTO.getDataList().get(j).getAvgIssue()));
+                                entity.setAvgIssueUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getAvgIssue(), formDTO.getDataList().get(j).getAvgIssue()));
+                                entity.setAgvgJoinUpRate(this.calculateGrowthRateNumber(lastMonthJoinList.get(i).getAvgJoin(), formDTO.getDataList().get(j).getAvgJoin()));
+                                entity.setAgvgJoinUpFlag(this.calculateGrowthRateFlag(lastMonthJoinList.get(i).getAvgJoin(), formDTO.getDataList().get(j).getAvgJoin()));
+                                curMonthJoinEntityList.add(entity);
+                            }
                         }
                     }
+                } else {
+                    // 计算增长率后的 待新增数据
+                    BigDecimal zero = new BigDecimal(NumConstant.ZERO);
+                    // 不存在上个月的数据
+                    for (int i = NumConstant.ZERO; i < formDTO.getDataList().size(); i++){
+                        ScreenUserJoinEntity entity =  ConvertUtils.sourceToTarget(formDTO.getDataList().get(i), ScreenUserJoinEntity.class);
+                        entity.setJoinTotalUpRate(zero);
+                        entity.setJoinTotalUpFlag("");
+                        entity.setAvgIssueUpRate(zero);
+                        entity.setAvgIssueUpFlag("");
+                        entity.setAgvgJoinUpRate(zero);
+                        entity.setAgvgJoinUpFlag("");
+                        curMonthJoinEntityList.add(entity);
+                    }
                 }
-            } else {
-                // 计算增长率后的 待新增数据
-                BigDecimal zero = new BigDecimal(NumConstant.ZERO);
-                // 不存在上个月的数据
-                for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                    ScreenUserJoinEntity entity =  ConvertUtils.sourceToTarget(formDTO.get(i), ScreenUserJoinEntity.class);
-                    entity.setJoinTotalUpRate(zero);
-                    entity.setJoinTotalUpFlag("");
-                    entity.setAvgIssueUpRate(zero);
-                    entity.setAvgIssueUpFlag("");
-                    entity.setAgvgJoinUpRate(zero);
-                    entity.setAgvgJoinUpFlag("");
-                    curMonthJoinEntityList.add(entity);
-                }
+                screenUserJoinDao.batchInsertUserJoin(curMonthJoinEntityList, customerId);
             }
-            screenUserJoinDao.batchInsertUserJoin(curMonthJoinEntityList, customerId);
         }
     }
 
@@ -441,30 +434,30 @@ public class ScreenCollServiceImpl implements ScreenCollService {
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertPioneerData(List<PioneerDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenPioneerDataDao.deletePioneerData(customerId, orgIds);
-
-            screenPioneerDataDao.batchInsertPioneerData(formDTO, customerId);
+    public void insertPioneerData(PioneerDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenPioneerDataDao.deletePioneerData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenPioneerDataDao.batchInsertPioneerData(formDTO.getDataList(), customerId);
         }
     }
 
     @DataSource(value = DataSourceConstant.EVALUATION_INDEX, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void insertPublicPartiTotalData(List<PublicPartiTotalDataFormDTO> formDTO, String customerId) {
-        if (null != formDTO && formDTO.size() > NumConstant.ZERO){
-            String[] orgIds = new String[formDTO.size()];
-            for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
-                orgIds[i] = formDTO.get(i).getOrgId();
-            }
-            screenPublicPartiTotalDataDao.deletePublicPartiTotalData(customerId, orgIds);
-
-            screenPublicPartiTotalDataDao.batchInsertPublicPartiTotalData(formDTO, customerId);
+    public void insertPublicPartiTotalData(PublicPartiTotalDataListFormDTO formDTO, String customerId) {
+        if (formDTO.getIsFirst()) {
+            int deleteNum;
+            do {
+                deleteNum = screenPublicPartiTotalDataDao.deletePublicPartiTotalData(customerId);
+            } while (deleteNum != NumConstant.ZERO);
+        }
+        if (!CollectionUtils.isEmpty(formDTO.getDataList())) {
+            screenPublicPartiTotalDataDao.batchInsertPublicPartiTotalData(formDTO.getDataList(), customerId);
         }
     }
 }

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.xml

@@ -27,8 +27,7 @@
 
     <delete id="deleteFactIndexGovrnAblityDeptMonthly">
         delete from fact_index_govrn_ablity_dept_monthly
-        where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND DEPT_ID = #{deptId}
-        AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId}
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
     </delete>
 
     <insert id="batchInsertFactIndexGovrnAblityDeptMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexGovrnAblityGridMonthlyDao.xml

@@ -29,8 +29,8 @@
 
     <delete id="deleteFactIndexGovrnAblityGridMonthly">
         delete from fact_index_govrn_ablity_grid_monthly
-        where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId}
-        AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId}
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexGovrnAblityGridMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.xml

@@ -30,11 +30,8 @@
     <delete id="deleteFactIndexGovrnAblityOrgMonthly">
         delete from fact_index_govrn_ablity_org_monthly
         where CUSTOMER_ID = #{customerId}
-        AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
-        AND AGENCY_ID IN
-        <foreach item="item" collection="agencyIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexGovrnAblityOrgMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexPartyAblityGridMonthlyDao.xml

@@ -34,8 +34,8 @@
 
     <delete id="deleteFactIndexPartyAblityGridMonthly">
         delete from fact_index_party_ablity_grid_monthly
-        where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId}
-        AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexPartyAblityGridMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexPartyAblityOrgMonthlyDao.xml

@@ -24,11 +24,8 @@
     <delete id="deleteFactIndexPartyAblityOrgMonthly">
         delete from fact_index_party_ablity_org_monthly
         where CUSTOMER_ID = #{customerId}
-        AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
-        AND AGENCY_ID IN
-        <foreach item="item" collection="agencyIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexPartyAblityOrgMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexServiceAblityGridMonthlyDao.xml

@@ -24,8 +24,8 @@
 
     <delete id="deleteFactIndexServiceAblityGridMonthly">
         delete from fact_index_service_ablity_grid_monthly
-        where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId}
-        AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexServiceAblityGridMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/indexcoll/FactIndexServiceAblityOrgMonthlyDao.xml

@@ -24,11 +24,8 @@
     <delete id="deleteFactIndexServiceAblityOrgMonthly">
         delete from fact_index_service_ablity_org_monthly
         where CUSTOMER_ID = #{customerId}
-        AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
-        AND AGENCY_ID IN
-        <foreach item="item" collection="agencyIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertFactIndexServiceAblityOrgMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenCpcBaseDataDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteCpcBaseData">
         delete from screen_cpc_base_data
         where CUSTOMER_ID = #{customerId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertCpcBaseData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenCustomerAgencyDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteCustomerAgency">
         delete from screen_customer_agency
         where CUSTOMER_ID = #{customerId}
-        AND AGENCY_ID IN
-        <foreach item="item" collection="agencyIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertCustomerAgency" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenCustomerDeptDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteCustomerDept">
         delete from screen_customer_dept
         where CUSTOMER_ID = #{customerId}
-        AND DEPT_ID IN
-        <foreach item="item" collection="deptIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertCustomerDept" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenCustomerGridDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteCustomerGrid">
         delete from screen_customer_grid
         where CUSTOMER_ID = #{customerId}
-        AND GRID_ID IN
-        <foreach item="item" collection="gridIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertCustomerGrid" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenEventDataDao.xml

@@ -5,7 +5,8 @@
 
     <delete id="deleteEventData">
         delete from screen_event_data
-        where CUSTOMER_ID = #{customerId} AND EVENT_ID = #{eventId} AND ORG_ID = #{orgId}
+        where CUSTOMER_ID = #{customerId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertEventData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenGovernRankDataDao.xml

@@ -5,11 +5,8 @@
 
     <delete id="deleteGovernRankData">
         delete from screen_govern_rank_data
-        where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertGovernRankData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenIndexDataMonthlyDao.xml

@@ -5,11 +5,8 @@
 
     <delete id="deleteIndexDataMonthly">
         delete from screen_index_data_monthly
-        where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertIndexDataMonthly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenIndexDataYearlyDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteIndexDataYearly">
         delete from screen_index_data_yearly
         where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertIndexDataYearly" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenOrgRankDataDao.xml

@@ -5,11 +5,8 @@
 
     <delete id="deleteOrgRankData">
         delete from screen_org_rank_data
-        where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertOrgRankData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyBranchDataDao.xml

@@ -5,11 +5,8 @@
 
     <delete id="deletePartyBranchData">
         delete from screen_party_branch_data
-        where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertPartyBranchData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyLinkMassesDataDao.xml

@@ -6,10 +6,7 @@
     <delete id="deletePartyLinkMassesData">
         delete from screen_party_link_masses_data
         where CUSTOMER_ID = #{customerId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertPartyLinkMassesData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyUserRankDataDao.xml

@@ -5,7 +5,8 @@
 
     <delete id="deletePartyUserRankData">
         delete from screen_party_user_rank_data
-        where CUSTOMER_ID = #{customerId} AND GRID_ID = #{gridId} AND USER_ID = #{userId}
+        where CUSTOMER_ID = #{customerId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertPartyUserRankData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPioneerDataDao.xml

@@ -6,10 +6,7 @@
     <delete id="deletePioneerData">
         delete from screen_pioneer_data
         where CUSTOMER_ID = #{customerId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertPioneerData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPublicPartiTotalDataDao.xml

@@ -27,10 +27,7 @@
     <delete id="deletePublicPartiTotalData">
         delete from screen_public_parti_total_data
         where CUSTOMER_ID = #{customerId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertPublicPartiTotalData" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenUserJoinDao.xml

@@ -22,11 +22,8 @@
 
     <delete id="deleteUserJoin">
         delete from screen_user_join
-        where CUSTOMER_ID = #{customerId} AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        where CUSTOMER_ID = #{customerId} AND MONTH_ID = #{monthId}
+        limit 1000;
     </delete>
 
     <insert id="batchInsertUserJoin" parameterType="map">

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenUserTotalDataDao.xml

@@ -6,10 +6,7 @@
     <delete id="deleteUserTotalData">
         delete from screen_user_total_data
         where CUSTOMER_ID = #{customerId}
-        AND ORG_ID IN
-        <foreach item="item" collection="orgIds" open="(" separator="," close=")">
-            #{item}
-        </foreach>
+        limit 1000;
     </delete>
 
     <insert id="batchInsertUserTotalData" parameterType="map">

epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java

@@ -50,7 +50,7 @@ public interface EpmetUserOpenFeignClient {
      * @date 2020/6/2 16:11
      */
     @PostMapping("/epmetuser/staffrole/staffroles/{staffId}")
-    Result<List<CustomerStaffRoleResultDTO>> getStaffRoles(@PathVariable String staffId);
+    Result<List<CustomerStaffRoleResultDTO>> getStaffRoles(@PathVariable("staffId") String staffId);
 
     /**
      * @param staffId
@@ -300,7 +300,7 @@ public interface EpmetUserOpenFeignClient {
     /**
      * 更改角色所属组织
      * @author zhaoqifeng
-     * @date 2020/8/31 10:36 
+     * @date 2020/8/31 10:36
      * @param formDTO
      * @return com.epmet.commons.tools.utils.Result
      */