安宁mapper dao 批量新增、批量删除接口

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

@@ -0,0 +1,36 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 安宁-社区-项目概况（数量、颜色）
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-10-09
+ */
+@Data
+public class AnCommunityProjectProfileFormDTO implements Serializable {
+    private static final long serialVersionUID = 1466172677051250092L;
+
+    /**
+     * 数据更新至: yyyy|yyyyMM|yyyyMMdd，项目根据实际情况赋值
+     */
+    private String dataEndTime;
+
+    /**
+     * 社区id
+     */
+    private String orgId;
+
+    /**
+     * 项目数
+     */
+    private Integer projectTotal;
+
+    /**
+     * 等级
+     */
+    private String level;
+}

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

@@ -0,0 +1,62 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 安宁-基层治理-各类数
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-10-09
+ */
+@Data
+public class AnGrassRootsGovernMonthlyFormDTO  implements Serializable {
+    private static final long serialVersionUID = -6947401956711903753L;
+
+    /**
+     * 网格，街道或社区id
+     */
+    private String orgId;
+
+    /**
+     * 网格，街道名称或者社区名称
+     */
+    private String orgName;
+
+    /**
+     * 网格：grid;组织：agency
+     */
+    private String orgType;
+
+    /**
+     * org_id的上一级id
+     */
+    private String pid;
+
+    /**
+     * 参与项目数
+     */
+    private Integer partiProjectTotal;
+
+    /**
+     * 办结项目数
+     */
+    private Integer closedProjectTotal;
+
+    /**
+     * 项目响应度 存储的是%前面的数
+     */
+    private BigDecimal projectResponseRatio;
+
+    /**
+     * 项目满意率，存储的是%前面的数
+     */
+    private BigDecimal projectSatisRatio;
+
+    /**
+     * 办结率 for  社区
+     */
+    private BigDecimal closedProjectRatio;
+}

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

@@ -0,0 +1,51 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 安宁-基层组织(党群数|议题数|项目数)-按月
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-10-09
+ */
+@Data
+public class AnGrassRootsOrgMonthlyFormDTO implements Serializable {
+    private static final long serialVersionUID = -7389300512268641307L;
+    /**
+     * 网格id或者组织(街道或社区)id
+     */
+    private String orgId;
+
+    /**
+     * 组织名称OR网格名称
+     */
+    private String orgName;
+
+    /**
+     * 网格：grid; 组织：agency
+     */
+    private String orgType;
+
+    /**
+     * org_id的上一级id
+     */
+    private String pid;
+
+    /**
+     * 党群数
+     */
+    private Integer groupTotal;
+
+    /**
+     * 议题数
+     */
+    private Integer issueTotal;
+
+    /**
+     * 项目数
+     */
+    private Integer projectTotal;
+
+}

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

@@ -0,0 +1,71 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 安宁-基层党员-排行榜单
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-10-09
+ */
+@Data
+public class AnGrassRootsPmRankFormDTO implements Serializable {
+    private static final long serialVersionUID = 3642729389245262928L;
+
+    /**
+     * 用户id
+     */
+    private String userId;
+
+    /**
+     * 姓名
+     */
+    private String userName;
+
+    /**
+     * 所属支部id
+     */
+    private String branchId;
+
+    /**
+     * 所属支部名称
+     */
+    private String branchName;
+
+    /**
+     * 所属社区id
+     */
+    private String communityId;
+
+    /**
+     * 所属社区名称
+     */
+    private String communityName;
+
+    /**
+     * 群成员数
+     */
+    private Integer groupMemberTotal;
+
+    /**
+     * 话题数
+     */
+    private Integer topicTotal;
+
+    /**
+     * 参与人次
+     */
+    private Integer partiUserTotal;
+
+    /**
+     * 议题数
+     */
+    private Integer issueTotal;
+
+    /**
+     * 所有上级ID，用英文逗号分开
+     */
+    private String allParentIds;
+}

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

@@ -0,0 +1,57 @@
+package com.epmet.dto.screencoll.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 安宁-基层党员-各类总数
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-10-09
+ */
+@Data
+public class AnGrassRootsPmTotalMonthlyFormDTO implements Serializable {
+    private static final long serialVersionUID = 8675347783888892404L;
+
+    /**
+     * 网格id或者组织(街道或社区)id
+     */
+    private String orgId;
+
+    /**
+     * 组织名称OR网格名称
+     */
+    private String orgName;
+
+    /**
+     * 网格：grid;组织：agency
+     */
+    private String orgType;
+
+    /**
+     * org_id的上一级id
+     */
+    private String pid;
+
+    /**
+     * 群成员数
+     */
+    private Integer groupMemberTotal;
+
+    /**
+     * 话题数
+     */
+    private Integer topicTotal;
+
+    /**
+     * 话题参与人次
+     */
+    private Integer topicPartiUserTotal;
+
+    /**
+     * 议题数
+     */
+    private Integer issueTotal;
+
+}

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

@@ -18,8 +18,12 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.screencoll.form.AnCommunityProjectProfileFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenAnCommunityProjectProfileEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 安宁-社区-项目概况（数量、颜色）
@@ -29,5 +33,23 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface ScreenAnCommunityProjectProfileDao extends BaseDao<ScreenAnCommunityProjectProfileEntity> {
-	
+
+    /**
+     * @Description 批量删除
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 15:30
+    */
+    int deleteBatch(@Param("customerId") String customerId);
+
+    /**
+     * @Description 批量写入
+     * @param list
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 15:30
+    */
+    int insertBatch(@Param("list") List<AnCommunityProjectProfileFormDTO> list,@Param("customerId") String customerId);
 }

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

@@ -18,8 +18,12 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.screencoll.form.AnGrassRootsGovernMonthlyFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenAnGrassRootsGovernMonthlyEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 安宁-基层治理-各类数
@@ -29,5 +33,28 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface ScreenAnGrassRootsGovernMonthlyDao extends BaseDao<ScreenAnGrassRootsGovernMonthlyEntity> {
-	
+
+    /**
+     * @Description 批量删除
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 15:30
+     */
+    int deleteBatch(@Param("customerId") String customerId, @Param("monthId") String monthId);
+
+    /**
+     * @Description 批量新增
+     * @param list
+     * @param customerId
+     * @param monthId
+     * @param quarterId
+     * @param yearId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:08
+    */
+    int insertBatch(@Param("list") List<AnGrassRootsGovernMonthlyFormDTO> list,
+                    @Param("customerId") String customerId, @Param("monthId") String monthId,
+                    @Param("quarterId")String quarterId,@Param("yearId")String yearId);
 }

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

@@ -18,8 +18,12 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.screencoll.form.AnGrassRootsOrgMonthlyFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenAnGrassRootsOrgMonthlyEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 安宁-基层组织(党群数|议题数|项目数)-按月
@@ -29,5 +33,29 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface ScreenAnGrassRootsOrgMonthlyDao extends BaseDao<ScreenAnGrassRootsOrgMonthlyEntity> {
-	
+
+    /**
+     * @Description 批量删除
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 15:30
+     */
+    int deleteBatch(@Param("customerId") String customerId, @Param("monthId") String monthId);
+
+    /**
+     * @Description 批量新增
+     * @param list
+     * @param customerId
+     * @param monthId
+     * @param quarterId
+     * @param yearId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:07
+    */
+    int insertBatch(@Param("list") List<AnGrassRootsOrgMonthlyFormDTO> list,
+                    @Param("customerId") String customerId, @Param("monthId") String monthId,
+                    @Param("quarterId")String quarterId,@Param("yearId")String yearId);
+
 }

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

@@ -18,8 +18,12 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.screencoll.form.AnGrassRootsPmRankFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenAnGrassRootsPmRankEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 安宁-基层党员-排行榜单
@@ -29,5 +33,24 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface ScreenAnGrassRootsPmRankDao extends BaseDao<ScreenAnGrassRootsPmRankEntity> {
-	
+
+    /***
+     * @Description 批量删除
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:07
+    */
+    int deleteBatch(@Param("customerId") String customerId);
+    
+    /**
+     * @Description 批量新增
+     * @param list
+     * @param customerId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:10
+    */
+    int insertBatch(@Param("list") List<AnGrassRootsPmRankFormDTO> list,@Param("customerId") String customerId);
+
 }

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

@@ -18,8 +18,12 @@
 package com.epmet.dao.evaluationindex.screen;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.screencoll.form.AnGrassRootsPmTotalMonthlyFormDTO;
 import com.epmet.entity.evaluationindex.screen.ScreenAnGrassRootsPmTotalMonthlyEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 安宁-基层党员-各类总数
@@ -29,5 +33,32 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface ScreenAnGrassRootsPmTotalMonthlyDao extends BaseDao<ScreenAnGrassRootsPmTotalMonthlyEntity> {
-	
+
+    /**
+     * @Description 批量删除
+     * @param customerId
+     * @param monthId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:25
+    */
+    int deleteBatch(@Param("customerId")String customerId,@Param("monthId")String monthId);
+
+    /**
+     * @Description 批量新增
+     * @param list
+     * @param customerId
+     * @param monthId
+     * @param quarterId
+     * @param yearId
+     * @return int
+     * @author wangc
+     * @date 2020.10.09 16:35
+    */
+    int insertBatch(@Param("list") List<AnGrassRootsPmTotalMonthlyFormDTO> list,
+                    @Param("customerId")String customerId,
+                    @Param("monthId")String monthId,
+                    @Param("quarterId")String quarterId,
+                    @Param("yearId")String yearId);
+
 }

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

@@ -3,7 +3,44 @@
 
 <mapper namespace="com.epmet.dao.evaluationindex.screen.ScreenAnCommunityProjectProfileDao">
 
+    <delete id="deleteBatch">
+        DELETE
+        FROM
+        screen_an_community_project_profile
+        WHERE
+        CUSTOMER_ID = #{customerId}
+        LIMIT 1000
+    </delete>
 
+    <insert id="insertBatch">
+        INSERT INTO screen_an_community_project_profile
+        (       id,
+                customer_id,
+                data_end_time,
+                org_id,
+                project_total,
+                level,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+        )
+        values
+        <foreach collection="list" item="item" index="index" separator=",">
+        (
+            (SELECT REPLACE(UUID(), '-', '') AS id),
+            #{customerId},
+            #{item.dataEndTime},
+            #{item.orgId},
+            #{item.projectTotal},
+            #{item.level},
+            'APP_USER',
+            NOW(),
+            'APP_USER',
+            NOW()
+        )
+        </foreach>
+    </insert>
 
 
 </mapper>

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

@@ -3,7 +3,60 @@
 
 <mapper namespace="com.epmet.dao.evaluationindex.screen.ScreenAnGrassRootsGovernMonthlyDao">
 
-  
+  <delete id="deleteBatch">
+      DELETE
+      FROM
+      screen_an_grass_roots_govern_monthly
+      WHERE
+      CUSTOMER_ID = #{customerId}
+      AND
+      MONTH_ID = #{monthId}
+      LIMIT 1000
+  </delete>
 
+    <insert id="insertBatch">
+        INSERT INTO screen_an_grass_roots_govern_monthly
+        (
+                id,
+                customer_id,
+                month_id,
+                quarter_id,
+                year_id,
+                org_id,
+                org_name,
+                org_type,
+                pid,
+                parti_project_total,
+                closed_project_total,
+                project_response_ratio,
+                project_satis_ratio,
+                closed_project_ratio,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+        )values
+        <foreach collection="list" item="item" index="index" separator=",">
+        (
+            (SELECT REPLACE(UUID(), '-', '') AS id),
+            #{customerId},
+            #{monthId},
+            #{quarterId},
+            #{yearId},
+            #{item.orgId},
+            #{item.orgName},
+            #{item.orgType},
+            #{item.pid},
+            #{item.partiProjectTotal},
+            #{item.closedProjectTotal},
+            #{item.projectResponseRatio},
+            #{item.closedProjectRatio},
+            'APP_USER',
+            NOW(),
+            'APP_USER',
+            NOW()
+        )
+        </foreach>
+    </insert>
 
 </mapper>

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

@@ -3,7 +3,58 @@
 
 <mapper namespace="com.epmet.dao.evaluationindex.screen.ScreenAnGrassRootsOrgMonthlyDao">
 
+    <delete id="deleteBatch">
+        DELETE
+        FROM
+        screen_an_grass_roots_org_monthly
+        WHERE
+        CUSTOMER_ID = #{customerId}
+        AND
+        MONTH_ID = #{monthId}
+        LIMIT 1000
+    </delete>
 
 
+    <insert id="insertBatch">
+        INSERT INTO screen_an_grass_roots_org_monthly
+        (
+                id,
+                customer_id,
+                month_id,
+                quarter_id,
+                year_id,
+                org_id,
+                org_name,
+                org_type,
+                pid,
+                group_total,
+                issue_total,
+                project_total,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+        )values
+        <foreach collection="list" item="item" index="index" separator=",">
+        (
+            (SELECT REPLACE(UUID(), '-', '') AS id),
+            #{customerId},
+            #{monthId},
+            #{quarterId},
+            #{yearId},
+            #{item.orgId},
+            #{item.orgName},
+            #{item.orgType},
+            #{item.pid},
+            #{item.groupTotal},
+            #{item.issueTotal},
+            #{item.projectTotal},
+            'APP_USER',
+            NOW(),
+            'APP_USER',
+            NOW()
+        )
+        </foreach>
+    </insert>
 
 </mapper>

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

@@ -3,7 +3,57 @@
 
 <mapper namespace="com.epmet.dao.evaluationindex.screen.ScreenAnGrassRootsPmRankDao">
 
- 
+    <delete id="deleteBatch">
+        DELETE
+        FROM
+        screen_an_grass_roots_pm_rank
+        WHERE
+        CUSTOMER_ID = #{customerId}
+        LIMIT 1000
+    </delete>
 
+    <insert id="insertBatch">
+        INSERT INTO screen_an_grass_roots_pm_rank
+        (
+                id,
+                customer_id,
+                user_id,
+                user_name,
+                branch_id,
+                branch_name,
+                community_id,
+                community_name,
+                group_member_total,
+                topic_total,
+                parti_user_total,
+                issue_total,
+                all_parent_ids,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+        )values
+        <foreach collection="list" item="item" index="index" separator=",">
+        (
+                (SELECT REPLACE(UUID(), '-', '') AS id),
+                #{customerId},
+                #{item.userId},
+                #{item.userName},
+                #{item.branchId},
+                #{item.branchName},
+                #{item.communityId},
+                #{item.communityName},
+                #{item.groupMemberTotal},
+                #{item.topicTotal},
+                #{item.partiUserTotal},
+                #{item.issueTotal},
+                #{item.allParentIds},
+                'APP_USER',
+                NOW(),
+                'APP_USER',
+                NOW()
+        )
+        </foreach>
+    </insert>
 
 </mapper>

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

@@ -3,6 +3,59 @@
 
 <mapper namespace="com.epmet.dao.evaluationindex.screen.ScreenAnGrassRootsPmTotalMonthlyDao">
 
+    <delete id="deleteBatch">
+        DELETE
+        FROM
+        screen_an_grass_roots_pm_total_monthly
+        WHERE
+        CUSTOMER_ID = #{customerId}
+        AND
+        MONTH_ID = #{monthId}
+        LIMITE 1000
+    </delete>
 
+    <insert id="insertBatch">
+         INSERT INTO screen_an_grass_roots_pm_total_monthly
+         (
+                id,
+                customer_id,
+                month_id,
+                quarter_id,
+                year_id,
+                org_id,
+                org_name,
+                org_type,
+                pid,
+                group_member_total,
+                topic_total,
+                topic_parti_user_total,
+                issue_total,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+         )values
+        <foreach collection="list" item="item" index="index" separator=",">
+        (
+                (SELECT REPLACE(UUID(), '-', '') AS id),
+                #{customerId},
+                #{monthId},
+                #{quarterId},
+                #{yearId},
+                #{item.orgId},
+                #{item.orgName},
+                #{item.orgType},
+                #{item.pid},
+                #{item.groupMemberTotal},
+                #{item.topicTotal},
+                #{item.topicPartiUserTotal},
+                #{item.issueTotal},
+                'APP_USER',
+                NOW(),
+                'APP_USER',
+                NOW()
+        )
+        </foreach>
+    </insert>
 
 </mapper>