diff --git a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java index 836890c7..4b4d23cf 100644 --- a/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java +++ b/esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java @@ -323,4 +323,75 @@ public interface EpmetConstant { */ String EPMET_SCREEN_COLL_USER_TOTAL = "/data/stats/screencoll/usertotaldata"; + + /** + * 网格状态话题数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_STATUS = "/data/stats/basereport/gridtopicstatus"; + + /** + * 组织状态话题数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_TOPIC_STATUS = "/data/stats/basereport/agencytopicstatus"; + + /** + * 网格话题转议题数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_ISSUE = "/data/stats/basereport/gridtopicissue"; + + /** + * 组织话题转议题数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGNENCY_TOPIC_ISSUE = "/data/stats/basereport/agencytopicissue"; + + /** + * 网格项目数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_PROJECT = "/data/stats/basereport/gridproject"; + + /** + * 组织项目数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_PROJECT = "/data/stats/basereport/agencyproject"; + + /** + * 网格群组总数 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_GROUP_TOTAL = "/data/stats/basereport/gridgrouptotal"; + + /** + * 组织群组总数 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_GROUP_TOTAL = "/data/stats/basereport/agencygrouptotal"; + + /** + * 网格热议话题数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_HOT_TOPIC = "/data/stats/basereport/gridhottopic"; + + /** + * 组织热议话题数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_HOT_TOPIC = "/data/stats/basereport/agencyhottopic"; + + /** + * 网格议题数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_ISSUE = "/data/stats/basereport/gridissue"; + + /** + * 组织议题数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_ISSUE = "/data/stats/basereport/agencyissue"; + + /** + * 网格注册用户数据 + */ + String EPMET_SCREEN_BASE_REPORT_GRID_REGISTER_USER = "/data/stats/basereport/gridreguser"; + + /** + * 组织注册用户数据 + */ + String EPMET_SCREEN_BASE_REPORT_AGENCY_REGISTER_USER = "/data/stats/basereport/agencyreguser"; + } diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/ScreenBaseReportDataFormDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/ScreenBaseReportDataFormDTO.java new file mode 100644 index 00000000..e82a6d7e --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/ScreenBaseReportDataFormDTO.java @@ -0,0 +1,15 @@ +package com.elink.esua.epdc.dto.screen.form; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @Author：syp + * @Date：2021/6/25 17:56 + */ +@Data +public class ScreenBaseReportDataFormDTO implements Serializable { + private static final long serialVersionUID = 8275259571095325022L; + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityGroupTotalResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityGroupTotalResultDTO.java new file mode 100644 index 00000000..5c9b12a6 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityGroupTotalResultDTO.java @@ -0,0 +1,75 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格群组总数 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityGroupTotalResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * + */ + private String pid; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 小组总数 + */ + private Integer groupTotal; + + /** + * 楼院小组总数 + */ + private Integer ordinaryTotal ; + + /** + * 支部小组总数 + */ + private Integer branchTotal ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityHotTopicResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityHotTopicResultDTO.java new file mode 100644 index 00000000..acc19803 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityHotTopicResultDTO.java @@ -0,0 +1,73 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 组织热议话题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityHotTopicResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 父级机关ID + */ + private String pid; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 话题状态【热议中:hot_discuss】 + */ + private String status; + + /** + * 话题总数 + */ + private Integer topicTotal; + + /** + * 状态话题数量 + */ + private Integer topicCount; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityIssueResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityIssueResultDTO.java new file mode 100644 index 00000000..126b0ad3 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityIssueResultDTO.java @@ -0,0 +1,185 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 社区议题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityIssueResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 父ID + */ + private String pid; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 当日议题增量 + */ + private Integer issueIncr; + + /** + * 议题总数 + */ + private Integer issueTotal ; + + /** + * 当日已转项目的议题数增量 + */ + private Integer shiftProjectIncr ; + + /** + * 已转项目的议题总数 + */ + private Integer shiftProjectTotal ; + + /** + * 已转项目所占百分比 + */ + private Integer shiftProjectPercent ; + + /** + * 当日表决中议题数增量 + */ + private Integer votingIncr ; + + /** + * 表决中议题总数 + */ + private Integer votingTotal ; + + /** + * 表决中议题所占百分比 + */ + private Integer votingPercent ; + + /** + * 当日已关闭议题数增量 + */ + private Integer closedIncr ; + + /** + * 当日已关闭议题中已解决数量 + */ + private Integer closedResolvedIncr ; + + /** + * 当日已关闭议题中无需解决数量 + */ + private Integer closedUnresolvedIncr ; + + /** + * 已关闭议题总数 + */ + private Integer closedTotal ; + + /** + * 已关闭议题中已解决总数 + */ + private Integer closedResolvedTotal ; + + /** + * 已关闭议题中未解决总数 + */ + private Integer closedUnresolvedTotal ; + + /** + * 已关闭议题所占百分比 + */ + private Integer closedPercent ; + + /** + * 已关闭议题中已解决百分比 + */ + private Integer closedResolvedPercent ; + + /** + * 已关闭议题中未解决百分比 + */ + private Integer closedUnresolvedPercent ; + + /** + * 当日已结案议题数 + */ + private Integer closedCaseIncr ; + + /** + * 当日已结案议题中已解决数 + */ + private Integer closedCaseResolvedIncr ; + + /** + * 当日已结案议题中未解决数 + */ + private Integer closedCaseUnresolvedIncr ; + + /** + * 已结案议题总数 + */ + private Integer closedCaseTotal ; + + /** + * 已结案议题中已解决总数 + */ + private Integer closedCaseResolvedTotal ; + + /** + * 已结案议题中未解决总数 + */ + private Integer closedCaseUnresolvedTotal ; + + /** + * 已结案议题中已解决百分比 + */ + private Integer closedCaseResolvedPercent ; + + /** + * 已结案议题中已解决百分比 + */ + private Integer closedCaseUnresolvedPercent ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityProjectResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityProjectResultDTO.java new file mode 100644 index 00000000..99f9a7a0 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityProjectResultDTO.java @@ -0,0 +1,130 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 社区项目数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityProjectResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 上级组织ID + */ + private String parentId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 截止当日网格下项目总数 【当前组织及下级项目总数】 + */ + private Integer projectTotal; + + /** + * 截止当日网格下处理中项目数 【当前组织及下级所有未结案项目总数】 + */ + private Integer pendingTotal ; + + /** + * 截止当日网格下处理中项目占比 【当前组织及下级未结案项目百分比（存百分比数，小数点后两位）】 + */ + private Integer pendingRatio ; + + /** + * 截止当日网格下已结案项目数 【当前组织及下级已结案项目总数】 + */ + private Integer closedTotal ; + + /** + * 截止当日网格下已结案项目占比 【当前组织及下级已结案项目百分比（存百分比数，小数点后两位）】 + */ + private Integer closedRatio ; + + /** + * 截止当日已结案中已解决项目数 【当前组织及下级已结案项目中已解决总数】 + */ + private Integer resolvedTotal ; + + /** + * 截止当日已结案中已解决项目占比 【当前组织及下级已结案项目中已解决占比】 + */ + private Integer resolvedRatio ; + + /** + * 截止当日已结案中未解决项目数 【当前组织及下级已结案项目中未解决总数】 + */ + private Integer unresolvedTotal ; + + /** + * 截止当日已结案中未解决项目占比 【当前组织及下级已结案项目中未解决占比】 + */ + private Integer unresolvedRatio ; + + /** + * 当日已结案项目中已解决数 【当前组织及下级前一日新增结案中已解决项目数】 + */ + private Integer resolvedIncr ; + + /** + * 当日已结案项目组未解决数 【当前组织及下级前一日新增结案中未解决项目数】 + */ + private Integer unresolvedIncr ; + + /** + * 当日网格下项目总数 【该网格下项目总数】 + */ + private Integer projectIncr ; + + /** + * 当日网格下处理中项目数 【该网格下未结案项目总数】 + */ + private Integer pendingIncr ; + + /** + * 当日网格下已结案项目数 【该网格下已结案项目总数】 + */ + private Integer closedIncr ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicIssueResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicIssueResultDTO.java new file mode 100644 index 00000000..c8fb13c3 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicIssueResultDTO.java @@ -0,0 +1,68 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 社区话题转议题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityTopicIssueResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 父级机关ID + */ + private String pid; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + /** + * 当日新增转议题数 + */ + private Integer issueIncr; + /** + * 转议题总数 + */ + private Integer issueTotal ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicStatusResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicStatusResultDTO.java new file mode 100644 index 00000000..85555855 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityTopicStatusResultDTO.java @@ -0,0 +1,80 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 组织状态话题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityTopicStatusResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 父级机关ID + */ + private String pid; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 话题状态ID [讨论中: discussi ;已屏蔽 : hidden ;已关闭:closed] + */ + private String topicStatusId; + + /** + * 话题数量 + */ + private Integer topicCount; + + /** + * 话题状态占比 指定状态话题数/话题总数 + */ + private String topicProportion; + + /** + * 话题增量 + */ + private Integer topicIncrement; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityUserResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityUserResultDTO.java new file mode 100644 index 00000000..5d611e40 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/CommunityUserResultDTO.java @@ -0,0 +1,105 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 社区注册用户数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class CommunityUserResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 注册用户总数 + */ + private Integer regTotal; + + /** + * 居民总数【居民总数=注册用户数】 + */ + private Integer resiTotal ; + + /** + * 热心居民总数 + */ + private Integer warmHeartedTotal ; + + /** + * 党员总数 + */ + private Integer partymemberTotal ; + + /** + * 本日注册居民日增量 + */ + private Integer regIncr ; + + /** + * 本日热心居民日增量 + */ + private Integer warmIncr ; + + /** + * 本日党员认证日增量 + */ + private Integer partymemberIncr ; + + /** + * 居民总数占比【居民总数/居民总数】 + */ + private Integer resiProportion ; + + /** + * 党员总数占比【党员总数/居民总数】 + */ + private Integer partymemberProportion ; + + /** + * 热心居民占比【热心居民数/居民总数】 + */ + private Integer warmHeartedProportion ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGridProjectResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGridProjectResultDTO.java new file mode 100644 index 00000000..61b290bb --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGridProjectResultDTO.java @@ -0,0 +1,130 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格项目数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridGridProjectResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 截止当日网格下项目总数 【当前组织及下级项目总数】 + */ + private Integer projectTotal; + + /** + * 截止当日网格下处理中项目数 【当前组织及下级所有未结案项目总数】 + */ + private Integer pendingTotal ; + + /** + * 截止当日网格下处理中项目占比 【当前组织及下级未结案项目百分比（存百分比数，小数点后两位）】 + */ + private Integer pendingRatio ; + + /** + * 截止当日网格下已结案项目数 【当前组织及下级已结案项目总数】 + */ + private Integer closedTotal ; + + /** + * 截止当日网格下已结案项目占比 【当前组织及下级已结案项目百分比（存百分比数，小数点后两位）】 + */ + private Integer closedRatio ; + + /** + * 截止当日已结案中已解决项目数 【当前组织及下级已结案项目中已解决总数】 + */ + private Integer resolvedTotal ; + + /** + * 截止当日已结案中已解决项目占比 【当前组织及下级已结案项目中已解决占比】 + */ + private Integer resolvedRatio ; + + /** + * 截止当日已结案中未解决项目数 【当前组织及下级已结案项目中未解决总数】 + */ + private Integer unresolvedTotal ; + + /** + * 截止当日已结案中未解决项目占比 【当前组织及下级已结案项目中未解决占比】 + */ + private Integer unresolvedRatio ; + + /** + * 当日已结案项目中已解决数 【当前组织及下级前一日新增结案中已解决项目数】 + */ + private Integer resolvedIncr ; + + /** + * 当日已结案项目组未解决数 【当前组织及下级前一日新增结案中未解决项目数】 + */ + private Integer unresolvedIncr ; + + /** + * 当日网格下项目总数 【该网格下项目总数】 + */ + private Integer projectIncr ; + + /** + * 当日网格下处理中项目数 【该网格下未结案项目总数】 + */ + private Integer pendingIncr ; + + /** + * 当日网格下已结案项目数 【该网格下已结案项目总数】 + */ + private Integer closedIncr ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGroupTotalResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGroupTotalResultDTO.java new file mode 100644 index 00000000..fc883b88 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridGroupTotalResultDTO.java @@ -0,0 +1,75 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格群组总数 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridGroupTotalResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 小组总数 + */ + private Integer groupTotal; + + /** + * 楼院小组总数 + */ + private Integer ordinaryTotal ; + + /** + * 支部小组总数 + */ + private Integer branchTotal ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridHotTopicResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridHotTopicResultDTO.java new file mode 100644 index 00000000..3fb0ebe7 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridHotTopicResultDTO.java @@ -0,0 +1,75 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格热议话题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridHotTopicResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 话题状态【热议中:hot_discuss】 + */ + private String status; + + /** + * 话题总数 + */ + private Integer topicTotal; + + /** + * 状态话题数量 + */ + private Integer topicCount; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridIssueResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridIssueResultDTO.java new file mode 100644 index 00000000..5863d8ef --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridIssueResultDTO.java @@ -0,0 +1,185 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格议题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridIssueResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 当日议题增量 + */ + private Integer issueIncr; + + /** + * 议题总数 + */ + private Integer issueTotal ; + + /** + * 当日已转项目的议题数增量 + */ + private Integer shiftProjectIncr ; + + /** + * 已转项目的议题总数 + */ + private Integer shiftProjectTotal ; + + /** + * 已转项目所占百分比 + */ + private Integer shiftProjectPercent ; + + /** + * 当日表决中议题数增量 + */ + private Integer votingIncr ; + + /** + * 表决中议题总数 + */ + private Integer votingTotal ; + + /** + * 表决中议题所占百分比 + */ + private Integer votingPercent ; + + /** + * 当日已关闭议题数增量 + */ + private Integer closedIncr ; + + /** + * 当日已关闭议题中已解决数量 + */ + private Integer closedResolvedIncr ; + + /** + * 当日已关闭议题中无需解决数量 + */ + private Integer closedUnresolvedIncr ; + + /** + * 已关闭议题总数 + */ + private Integer closedTotal ; + + /** + * 已关闭议题中已解决总数 + */ + private Integer closedResolvedTotal ; + + /** + * 已关闭议题中未解决总数 + */ + private Integer closedUnresolvedTotal ; + + /** + * 已关闭议题所占百分比 + */ + private Integer closedPercent ; + + /** + * 已关闭议题中已解决百分比 + */ + private Integer closedResolvedPercent ; + + /** + * 已关闭议题中未解决百分比 + */ + private Integer closedUnresolvedPercent ; + + /** + * 当日已结案议题数 + */ + private Integer closedCaseIncr ; + + /** + * 当日已结案议题中已解决数 + */ + private Integer closedCaseResolvedIncr ; + + /** + * 当日已结案议题中未解决数 + */ + private Integer closedCaseUnresolvedIncr ; + + /** + * 已结案议题总数 + */ + private Integer closedCaseTotal ; + + /** + * 已结案议题中已解决总数 + */ + private Integer closedCaseResolvedTotal ; + + /** + * 已结案议题中未解决总数 + */ + private Integer closedCaseUnresolvedTotal ; + + /** + * 已结案议题中已解决百分比 + */ + private Integer closedCaseResolvedPercent ; + + /** + * 已结案议题中已解决百分比 + */ + private Integer 已结案议题中未解决百分比 ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicIssueResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicIssueResultDTO.java new file mode 100644 index 00000000..f82a6e1c --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicIssueResultDTO.java @@ -0,0 +1,68 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格话题转议题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridTopicIssueResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + /** + * 当日新增转议题数 + */ + private Integer issueIncr; + /** + * 转议题总数 + */ + private Integer issueTotal ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicStatusResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicStatusResultDTO.java new file mode 100644 index 00000000..ba6b81eb --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridTopicStatusResultDTO.java @@ -0,0 +1,80 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格状态话题数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridTopicStatusResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格id + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 话题状态ID [讨论中: discussi ;已屏蔽 : hidden ;已关闭:closed] + */ + private String topicStatusId; + + /** + * 话题数量 + */ + private Integer topicCount; + + /** + * 话题状态占比 指定状态话题数/话题总数 + */ + private String topicProportion; + + /** + * 话题增量 + */ + private Integer topicIncrement; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridUserResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridUserResultDTO.java new file mode 100644 index 00000000..87384d1f --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/GridUserResultDTO.java @@ -0,0 +1,110 @@ +package com.elink.esua.epdc.dto.screen.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 网格注册用户数据 + * @Auther: songyunpeng + * @Date: 2021-06-25 09:59 + */ +@Data +public class GridUserResultDTO implements Serializable { + + private static final long serialVersionUID = 1L; + + + + /** + * 客户Id + */ + private String customerId; + + /** + * 机关id:网格所属的组织id + */ + private String agencyId; + + /** + * 网格ID + */ + private String gridId; + + /** + * 日期ID + */ + private String dateId; + + /** + * 周ID + */ + private String weekId; + + /** + * 月ID + */ + private String monthId; + + /** + * 季度ID + */ + private String quarterId; + + /** + * 年ID + */ + private String yearId; + + /** + * 注册用户总数 + */ + private Integer regTotal; + + /** + * 居民总数【居民总数=注册用户数】 + */ + private Integer resiTotal ; + + /** + * 热心居民总数 + */ + private Integer warmHeartedTotal ; + + /** + * 党员总数 + */ + private Integer partymemberTotal ; + + /** + * 本日注册居民日增量 + */ + private Integer regIncr ; + + /** + * 本日热心居民日增量 + */ + private Integer warmIncr ; + + /** + * 本日党员认证日增量 + */ + private Integer partymemberIncr ; + + /** + * 居民总数占比【居民总数/居民总数】 + */ + private Integer resiProportion ; + + /** + * 党员总数占比【党员总数/居民总数】 + */ + private Integer partymemberProportion ; + + /** + * 热心居民占比【热心居民数/居民总数】 + */ + private Integer warmHeartedProportion ; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UploadProjectInfoDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UploadProjectInfoDTO.java index 8e43180b..f235c1fc 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UploadProjectInfoDTO.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UploadProjectInfoDTO.java @@ -108,4 +108,11 @@ public class UploadProjectInfoDTO implements Serializable { */ private String projectLevel; + /** + * 满意度得分 + */ + private Integer satisfactionScore; + + + } diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UserjoinResultDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UserjoinResultDTO.java index b5002e84..add1cbb0 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UserjoinResultDTO.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/UserjoinResultDTO.java @@ -51,12 +51,12 @@ public class UserjoinResultDTO implements Serializable { /** * 平均参与度 */ - private Integer avgJoin; + private Double avgJoin; /** * 人均议题 */ - private Integer avgIssue; + private Double avgIssue; private String areaCode; private Integer avgIssueFz; private Integer avgIssueFm; diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportDataController.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportDataController.java new file mode 100644 index 00000000..2a399e95 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportDataController.java @@ -0,0 +1,190 @@ +package com.elink.esua.epdc.modules.screen.controller; + +import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.modules.screen.service.ScreenBaseReportDataService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author songyunpeng + * @Description 平阴-大屏基础信息上报 + * @create 2021-06-25 + */ + +@RestController +@RequestMapping("screenBaseReport") +public class ScreenBaseReportDataController { + + @Autowired + private ScreenBaseReportDataService screenBaseReportDataService; + + /** + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("gridtopicstatus") + Result gridTopicStatus(){ + return screenBaseReportDataService.gridTopicStatus(); + }; + + /** + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("agencytopicstatus") + Result agencyTopicStatus(){ + return screenBaseReportDataService.agencyTopicStatus(); + }; + + /** + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("gridtopicissue") + Result gridTopicIssue(){ + return screenBaseReportDataService.gridTopicIssue(); + }; + + /** + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("agencytopicissue") + Result agencyTopicIssue(){ + return screenBaseReportDataService.agencyTopicIssue(); + }; + + + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridproject") + Result selectGridProjectList(){ + return screenBaseReportDataService.selectGridProjectList(); + }; + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencyproject") + Result selectCommunityProjectList(){ + return screenBaseReportDataService.selectCommunityProjectList(); + }; + + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridgrouptotal") + Result selectGridGroupTotalList(){ + return screenBaseReportDataService.selectGridGroupTotalList(); + }; + + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencygrouptotal") + Result selectCommunityGroupTotalList(){ + return screenBaseReportDataService.selectCommunityGroupTotalList(); + }; + + + /** + * @Description 网格热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridhottopic") + Result selectGridHotTopic(){ + return screenBaseReportDataService.selectGridHotTopic(); + }; + + + /** + * @Description 组织热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencyhottopic") + Result selectAgencyHotTopic(){ + return screenBaseReportDataService.selectAgencyHotTopic(); + }; + + + /** + * @Description 网格议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridissue") + Result selectGridIssue(){ + return screenBaseReportDataService.selectGridIssue(); + }; + + + /** + * @Description 组织议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencyissue") + Result selectAgencyIssue(){ + return screenBaseReportDataService.selectAgencyIssue(); + }; + + + /** + * @Description 网格注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridreguser") + Result selectGridRegUser(){ + return screenBaseReportDataService.selectGridRegUser(); + }; + + + /** + * @Description 组织注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencyreguser") + Result selectAgencyRegUser(){ + return screenBaseReportDataService.selectAgencyRegUser(); + }; +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDataDao.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDataDao.java new file mode 100644 index 00000000..438a02ec --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDataDao.java @@ -0,0 +1,172 @@ +package com.elink.esua.epdc.modules.screen.dao; + +import com.elink.esua.epdc.commons.mybatis.dao.BaseDao; +import com.elink.esua.epdc.dto.screen.form.ScreenBaseReportDataFormDTO; +import com.elink.esua.epdc.dto.screen.result.*; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * @Description 平阴-大屏基础信息上报 + * @Author songyunpeng + * @Date 2021/6/25 + **/ +@Mapper +public interface ScreenBaseReportDataDao extends BaseDao { + /** + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridTopicStatusList(@Param("customId")String customId); + + /** + * @Description 社区状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectCommunityTopicStatusList(@Param("customId")String customId); + + /** + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridTopicIssueList(@Param("customId")String customId); + + + /** + * @Description 社区话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectCommunityTopicIssueList(@Param("customId")String customId); + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridProjectList(@Param("customId")String customId); + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectCommunityProjectList(@Param("customId")String customId); + + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridGroupTotalList(@Param("customId")String customId); + + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectCommunityGroupTotalList(@Param("customId")String customId); + + + /** + * @Description 网格热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridHotTopic(@Param("customId")String customId); + + + /** + * @Description 组织热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectAgencyHotTopic(@Param("customId")String customId); + + + /** + * @Description 网格议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridIssue(@Param("customId")String customId); + +/** + * @Description 网格议题数据 - 当日新增议题转项目数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridIssueShiftProjectIncr(); + + + /** + * @Description 组织议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectAgencyIssue(@Param("customId")String customId); + + /** + * @Description 组织议题数据 - 当日新增议题转项目数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectAgencyIssueShiftProjectIncr(); + + + /** + * @Description 网格注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectGridRegUser(@Param("customId")String customId); + + + /** + * @Description 组织注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + * @return java.util.List + **/ + List selectAgencyRegUser(@Param("customId")String customId); + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenPublicDataDao.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenPublicDataDao.java index b778f578..a52b50e6 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenPublicDataDao.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenPublicDataDao.java @@ -101,7 +101,7 @@ public interface ScreenPublicDataDao extends BaseDao List getDifficultydata(); /** - * 007、基层治理-公众参与 + * 007、基层治理-公众参与 -平均议题 * @Params: * @Return: UserjoinResultDTO * @Author: wanggongfeng @@ -109,6 +109,15 @@ public interface ScreenPublicDataDao extends BaseDao */ List getUserjoin(@Param("yearMonth")String yearMonth); + /** + * 007、基层治理-公众参与 - 平均参与度 + * @Params: + * @Return: UserjoinResultDTO + * @Author: wanggongfeng + * @Date: 2020/08/20 + */ + List getUserJoinList(@Param("yearMonth")String yearMonth); + /** * @describe: 008、公众参与各类总数 - grid * @author wangtong diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportDataService.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportDataService.java new file mode 100644 index 00000000..b75682b3 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportDataService.java @@ -0,0 +1,138 @@ +package com.elink.esua.epdc.modules.screen.service; + +import com.elink.esua.epdc.commons.tools.utils.Result; + +/** + * 平阴-大屏基础信息上报 + * + * @Author：syp + * @Date：2021/6/25 18:04 + */ +public interface ScreenBaseReportDataService { + /** + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + Result gridTopicStatus(); + + /** + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + Result agencyTopicStatus(); + + /** + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + Result gridTopicIssue(); + + /** + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + Result agencyTopicIssue(); + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridProjectList(); + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectCommunityProjectList(); + + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridGroupTotalList(); + + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectCommunityGroupTotalList(); + + + + + /** + * @Description 网格热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridHotTopic(); + + + /** + * @Description 组织热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectAgencyHotTopic(); + + + /** + * @Description 网格议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridIssue(); + + + /** + * @Description 组织议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectAgencyIssue(); + + + /** + * @Description 网格注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridRegUser(); + + + /** + * @Description 组织注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectAgencyRegUser(); + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportDataServiceImpl.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportDataServiceImpl.java new file mode 100644 index 00000000..5a7722e8 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportDataServiceImpl.java @@ -0,0 +1,164 @@ +package com.elink.esua.epdc.modules.screen.service.impl; + +import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; +import com.elink.esua.epdc.commons.tools.constant.EpmetConstant; +import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.screen.form.ScreenBaseReportDataFormDTO; +import com.elink.esua.epdc.dto.screen.result.*; +import com.elink.esua.epdc.modules.screen.dao.ScreenBaseReportDataDao; +import com.elink.esua.epdc.modules.screen.service.ScreenBaseReportDataService; +import com.elink.esua.epdc.utils.EpmetUtils; +import com.elink.esua.epdc.utils.ScreenDataUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @Author：liuchuang + * @Date：2020/9/9 18:05 + */ +@Service +public class ScreenBaseReportDataServiceImpl extends BaseServiceImpl implements ScreenBaseReportDataService { + @Autowired + private EpmetUtils epmetUtils; + + @Value("${epmet.config.customerId}") + private String customerId; + + @Override + public Result gridTopicStatus() { + List gridTopicStatusResultDTOS = baseDao.selectGridTopicStatusList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridTopicStatusResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_STATUS, dataJson); + return new Result(); + } + + @Override + public Result agencyTopicStatus() { + List communityTopicStatusResultDTOS = baseDao.selectCommunityTopicStatusList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityTopicStatusResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_TOPIC_STATUS, dataJson); + return new Result(); } + + @Override + public Result gridTopicIssue() { + List gridTopicIssueResultDTOS = baseDao.selectGridTopicIssueList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridTopicIssueResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_ISSUE, dataJson); + return new Result(); } + + @Override + public Result agencyTopicIssue() { + List communityTopicIssueResultDTOS = baseDao.selectCommunityTopicIssueList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityTopicIssueResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGNENCY_TOPIC_ISSUE, dataJson); + return new Result(); } + + @Override + public Result selectGridProjectList() { + List gridGridProjectResultDTOS = baseDao.selectGridProjectList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridGridProjectResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_PROJECT, dataJson); + return new Result(); + } + + @Override + public Result selectCommunityProjectList() { + List communityProjectResultDTOS = baseDao.selectCommunityProjectList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityProjectResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_PROJECT, dataJson); + return new Result(); + } + + @Override + public Result selectGridGroupTotalList() { + List gridGroupTotalResultDTOS = baseDao.selectGridGroupTotalList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridGroupTotalResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_GROUP_TOTAL, dataJson); + return new Result(); + } + + @Override + public Result selectCommunityGroupTotalList() { + List communityGroupTotalResultDTOS = baseDao.selectCommunityGroupTotalList(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityGroupTotalResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_GROUP_TOTAL, dataJson); + return new Result(); + } + + @Override + public Result selectGridHotTopic() { + List gridHotTopicResultDTOS = baseDao.selectGridHotTopic(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridHotTopicResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_HOT_TOPIC, dataJson); + return new Result(); } + + @Override + public Result selectAgencyHotTopic() { + List communityHotTopicResultDTOS = baseDao.selectAgencyHotTopic(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityHotTopicResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_HOT_TOPIC, dataJson); + return new Result(); } + + @Override + public Result selectGridIssue() { + List gridIssueResultDTOS = baseDao.selectGridIssue(customerId); + //由于数据量大，字段单独处理 + List shiftProjectIncrs = baseDao.selectGridIssueShiftProjectIncr(); + for (GridIssueResultDTO gridIssueResultDTO : gridIssueResultDTOS) { + for (GridIssueResultDTO shiftProjectIncr : shiftProjectIncrs) { + if(gridIssueResultDTO.getGridId().equals(shiftProjectIncr.getGridId()) ){ + gridIssueResultDTO.setShiftProjectIncr(shiftProjectIncr.getShiftProjectIncr()); + } + } + } + String dataJson = ScreenDataUtils.getScreenDateJson(gridIssueResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_ISSUE, dataJson); + return new Result(); } + + @Override + public Result selectAgencyIssue() { + List communityIssueResultDTOS = baseDao.selectAgencyIssue(customerId); + //由于数据量大，字段单独处理 + List shiftProjectIncrs = baseDao.selectAgencyIssueShiftProjectIncr(); + for (CommunityIssueResultDTO gridIssueResultDTO : communityIssueResultDTOS) { + for (CommunityIssueResultDTO shiftProjectIncr : shiftProjectIncrs) { + if(gridIssueResultDTO.getAgencyId().equals(shiftProjectIncr.getAgencyId()) ){ + gridIssueResultDTO.setShiftProjectIncr(shiftProjectIncr.getShiftProjectIncr()); + } + } + } + String dataJson = ScreenDataUtils.getScreenDateJson(communityIssueResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_ISSUE, dataJson); + return new Result(); } + + @Override + public Result selectGridRegUser() { + List gridUserResultDTOS = baseDao.selectGridRegUser(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(gridUserResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_REGISTER_USER, dataJson); + return new Result(); } + + @Override + public Result selectAgencyRegUser() { + List communityUserResultDTOS = baseDao.selectAgencyRegUser(customerId); + String dataJson = ScreenDataUtils.getScreenDateJson(communityUserResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_REGISTER_USER, dataJson); + return new Result(); } +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenPublicDataServiceImpl.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenPublicDataServiceImpl.java index 23840c1e..0d0682a6 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenPublicDataServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenPublicDataServiceImpl.java @@ -232,7 +232,20 @@ public class ScreenPublicDataServiceImpl extends BaseServiceImpl list = baseDao.getUserjoin(yearMonth); + //获取平均参与度 + List joinList = baseDao.getUserJoinList(yearMonth); + for (UserjoinResultDTO userjoinResultDTO : joinList) { + for (UserjoinResultDTO resultDTO : list) { + if(resultDTO.getOrgId().equals(userjoinResultDTO.getOrgId())){ + resultDTO.setAvgJoin(userjoinResultDTO.getAvgJoin()); + resultDTO.setAvgJoinFz(userjoinResultDTO.getAvgJoinFz()); + resultDTO.setAvgJoinFm(userjoinResultDTO.getAvgJoinFm()); + } + } + } + // 将list转换为json格式 if(list != null && list.size()>0) { UserjoinDTO result = new UserjoinDTO(); diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/application.yml b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/application.yml index 34c4a1a5..b7873fa8 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/application.yml +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/application.yml @@ -62,8 +62,6 @@ mybatis-plus: map-underscore-to-camel-case: true cache-enabled: false call-setters-on-nulls: true - log-impl: org.apache.ibatis.logging.stdout.StdOutImpl - epmet: config: diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenBaseReportDataDao.xml b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenBaseReportDataDao.xml new file mode 100644 index 00000000..1ffc0a79 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenBaseReportDataDao.xml @@ -0,0 +1,793 @@ + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenProjectDataDao.xml b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenProjectDataDao.xml index 4154cb47..05036025 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenProjectDataDao.xml +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenProjectDataDao.xml @@ -21,6 +21,7 @@ + @@ -49,8 +50,12 @@ when t1.ITEM_STATE = 10 then 3 when t1.ITEM_STATE = 0 and (select COUNT(1) from esua_epdc_events.epdc_item_handle_process where DEL_FLAG ='0' and ITEM_ID = t1.ID) = 1 then 1 when (t1.ITEM_STATE = 0 or t1.ITEM_STATE = 5) and (select COUNT(1) from esua_epdc_events.epdc_item_handle_process where DEL_FLAG ='0' and ITEM_ID = t1.ID) > 1 then 2 - else '' end as projectLevel - from (select * from(select * from esua_epdc_events.epdc_item where DEL_FLAG = '0' + else '' end as projectLevel, + case t1.EVALUATION_SCORE + when 0 then 60 + when 2 then 100 + else 80 end as satisfactionScore + from (select * from(select * from esua_epdc_events.epdc_item where DEL_FLAG = '0' and GRID_ID not in ( SELECT t.`dept_id` FROM `esua_epdc_admin`.`sys_dept_config` t WHERE t.`del_flag`= 0) diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenPublicDataDao.xml b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenPublicDataDao.xml index a344c10c..9b33a9a8 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenPublicDataDao.xml +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenPublicDataDao.xml @@ -1425,13 +1425,12 @@ select gr.id as orgId, st.name as orgName, st.pid as parentId, 'agency' as orgType, - (IFNULL(dg.createGroupTotal,0)) AS createGroupTotal, - (IFNULL(dg.groupUserTotal,0)) AS groupUserTotal, + (IFNULL(sum(dg.createGroupTotal),0)) AS createGroupTotal, + (IFNULL(sum(dg.groupUserTotal),0)) AS groupUserTotal, DATE_FORMAT(date_add( now( ), INTERVAL - 1 day),'%Y%m%d') as dataEndTime, st.area_code AS areaCode from esua_epdc_admin.sys_dept st left join esua_epdc_admin.sys_dept co on st.id=co.pid - left join esua_epdc_admin.sys_dept gr on co.id=gr.pid left join (select eg.DEPT_ID as GRID_ID, count(eg.id) as createGroupTotal, @@ -1444,11 +1443,11 @@ select gr.id as orgId, group by PARTY_GROUP_ID)group_user on group_user.PARTY_GROUP_ID = eg.id where eg.DEL_FLAG=0 and eg.STATE=0 group by eg.DEPT_ID)dg on dg.GRID_ID=co.id - where gr.del_flag=0 - and co.del_flag=0 + where co.del_flag=0 and st.del_flag=0 and st.type_key='street_party' - group by st.id + GROUP BY st.ID + union all @@ -1980,365 +1979,86 @@ select gr.id as orgId, + + diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java index c1ee468e..d2ad2abc 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java @@ -328,4 +328,145 @@ public interface AnalysisFeignClient { **/ @PostMapping("analysis/category/uploadCategoryCode") Result uploadCategoryCode(); + + + + /** + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("analysis/screenBaseReport/gridtopicstatus") + Result gridTopicStatus(); + /** + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("analysis/screenBaseReport/agencytopicstatus") + Result agencyTopicStatus(); + + /** + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("analysis/screenBaseReport/gridtopicissue") + Result gridTopicIssue(); + + /** + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return com.elink.esua.epdc.commons.tools.utils.Result + **/ + @PostMapping("analysis/screenBaseReport/agencytopicissue") + Result agencyTopicIssue(); + + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/gridproject") + Result selectGridProjectList(); + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/agencyproject") + Result selectCommunityProjectList(); + + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/gridgrouptotal") + Result selectGridGroupTotalList(); + + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/agencygrouptotal") + Result selectCommunityGroupTotalList(); + + + + /** + * @Description 网格热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/gridhottopic") + Result selectGridHotTopic(); + + + /** + * @Description 组织热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/agencyhottopic") + Result selectAgencyHotTopic(); + + + /** + * @Description 网格议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/gridissue") + Result selectGridIssue(); + + + /** + * @Description 组织议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/agencyissue") + Result selectAgencyIssue(); + + + /** + * @Description 网格注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/gridreguser") + Result selectGridRegUser(); + + + /** + * @Description 组织注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("analysis/screenBaseReport/agencyreguser") + Result selectAgencyRegUser(); } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java index e17331a6..04e2ec0c 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java @@ -159,6 +159,77 @@ public class AnalysisFeignClientFallback implements AnalysisFeignClient { public Result uploadCategoryCode() { return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "uploadCategoryCode"); } + + @Override + public Result gridTopicStatus() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridTopicStatus"); + } + + @Override + public Result agencyTopicStatus() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencyTopicStatus"); + } + + @Override + public Result gridTopicIssue() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridTopicIssue"); + } + + @Override + public Result agencyTopicIssue() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencyTopicIssue"); + } + + @Override + public Result selectGridProjectList() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridProjectList"); + } + + @Override + public Result selectCommunityProjectList() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectCommunityProjectList"); + } + + @Override + public Result selectGridGroupTotalList() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridGroupTotalList"); + } + + @Override + public Result selectCommunityGroupTotalList() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectCommunityGroupTotalList"); + } + + @Override + public Result selectGridHotTopic() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridHotTopic"); + } + + @Override + public Result selectAgencyHotTopic() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectAgencyHotTopic"); + } + + @Override + public Result selectGridIssue() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridIssue"); + } + + @Override + public Result selectAgencyIssue() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectAgencyIssue"); + } + + @Override + public Result selectGridRegUser() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridRegUser"); + } + + @Override + public Result selectAgencyRegUser() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectAgencyRegUser"); + } + @Override public Result getCategoryGridDaily(String date) { return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "getCategoryGridDaily",date); diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTask.java new file mode 100644 index 00000000..c33c43ef --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTask.java @@ -0,0 +1,18 @@ +package com.elink.esua.epdc.task.screen; + +/** + * 大屏基础信息上报 + * + * @Author：songyunpeng + * @Date：2021/6/25 + */ +public interface ScreenBaseReportDataPushTask { + /** + * @Description 大屏基础信息上报 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [param] + * @return void + **/ + void run(String param); +} diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTaskImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTaskImpl.java new file mode 100644 index 00000000..2df46ac3 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportDataPushTaskImpl.java @@ -0,0 +1,261 @@ +package com.elink.esua.epdc.task.screen; + +import com.elink.esua.epdc.feign.AnalysisFeignClient; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 大屏指标信息统计上报 + * + * @Author：syp + * @Date：2021/6/25 15:19 + */ +@Component("screenBaseReportDataPushTask") +public class ScreenBaseReportDataPushTaskImpl implements ScreenIndexDataPushTask { + + private final Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private AnalysisFeignClient analysisFeignClient; + + @Override + public void run(String param) { + + // 01、网格状态话题数据 + gridTopicStatus(); + // 02、组织状态话题数据 + agencyTopicStatus(); + // 03、网格话题转议题数据 + gridTopicIssue(); + // 04、组织话题转议题数据 + agencyTopicIssue(); + // 05、网格项目数据 + selectGridProjectList(); + // 组织项目数据 + selectCommunityProjectList(); + // 网格群组总数 + selectGridGroupTotalList(); + // 组织群组总数 + selectCommunityGroupTotalList(); + // 网格热议话题数据 + selectGridHotTopic(); + // 组织热议话题数据 + selectAgencyHotTopic(); + // 网格议题数据 + selectGridIssue(); + // 组织议题数据 + selectAgencyIssue(); + // 网格注册用户数据 + selectGridRegUser(); + // 组织注册用户数据 + selectAgencyRegUser(); + } + + /** + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void gridTopicStatus() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格状态话题数据>定时任务开始执行"); + analysisFeignClient.gridTopicStatus(); + logger.info("<" + methodName + "|大屏基础信息上报-网格状态话题数据>定时任务执行结束"); + } + /** + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void agencyTopicStatus() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织状态话题数据>定时任务开始执行"); + analysisFeignClient.agencyTopicStatus(); + logger.info("<" + methodName + "|大屏基础信息上报-组织状态话题数据>定时任务执行结束"); + } + /** + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void gridTopicIssue() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格话题转议题数据>定时任务开始执行"); + analysisFeignClient.gridTopicIssue(); + logger.info("<" + methodName + "|大屏基础信息上报-网格话题转议题数据>定时任务执行结束"); + } + /** + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void agencyTopicIssue() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织话题转议题数据>定时任务开始执行"); + analysisFeignClient.agencyTopicIssue(); + logger.info("<" + methodName + "|大屏基础信息上报-组织话题转议题数据>定时任务执行结束"); + } + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectGridProjectList() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格项目数据>定时任务开始执行"); + analysisFeignClient.selectGridProjectList(); + logger.info("<" + methodName + "|大屏基础信息上报-网格项目数据>定时任务执行结束"); + } + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectCommunityProjectList() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织项目数据>定时任务开始执行"); + analysisFeignClient.selectCommunityProjectList(); + logger.info("<" + methodName + "|大屏基础信息上报-组织项目数据>定时任务执行结束"); + } + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectGridGroupTotalList() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格群组总数>定时任务开始执行"); + analysisFeignClient.selectGridGroupTotalList(); + logger.info("<" + methodName + "|大屏基础信息上报-网格群组总数>定时任务执行结束"); + } + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectCommunityGroupTotalList() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织群组总数>定时任务开始执行"); + analysisFeignClient.selectCommunityGroupTotalList(); + logger.info("<" + methodName + "|大屏基础信息上报-组织群组总数>定时任务执行结束"); + } + + /** + * @Description 网格热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectGridHotTopic() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格热议话题数据>定时任务开始执行"); + analysisFeignClient.selectGridHotTopic(); + logger.info("<" + methodName + "|大屏基础信息上报-网格热议话题数据>定时任务执行结束"); + } + + /** + * @Description 组织热议话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectAgencyHotTopic() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织热议话题数据>定时任务开始执行"); + analysisFeignClient.selectAgencyHotTopic(); + logger.info("<" + methodName + "|大屏基础信息上报-组织热议话题数据>定时任务执行结束"); + } + + /** + * @Description 网格议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectGridIssue() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格议题数据>定时任务开始执行"); + analysisFeignClient.selectGridIssue(); + logger.info("<" + methodName + "|大屏基础信息上报-网格议题数据>定时任务执行结束"); + } + + /** + * @Description 组织议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectAgencyIssue() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织议题数据>定时任务开始执行"); + analysisFeignClient.selectAgencyIssue(); + logger.info("<" + methodName + "|大屏基础信息上报-组织议题数据>定时任务执行结束"); + } + + /** + * @Description 网格注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectGridRegUser() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-网格注册用户数据>定时任务开始执行"); + analysisFeignClient.selectGridRegUser(); + logger.info("<" + methodName + "|大屏基础信息上报-网格注册用户数据>定时任务执行结束"); + } + + /** + * @Description 组织注册用户数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + * @return void + **/ + public void selectAgencyRegUser() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|大屏基础信息上报-组织注册用户数据>定时任务开始执行"); + analysisFeignClient.selectAgencyRegUser(); + logger.info("<" + methodName + "|大屏基础信息上报-组织注册用户数据>定时任务执行结束"); + } + + + +} diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/VolunteerInfoDao.xml b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/VolunteerInfoDao.xml index 7960e61a..ce922dff 100644 --- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/VolunteerInfoDao.xml +++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/resources/mapper/VolunteerInfoDao.xml @@ -221,16 +221,16 @@