members = new ArrayList();
+}
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/FactOriginProjectOrgPeriodDailyDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/FactOriginProjectOrgPeriodDailyDTO.java
new file mode 100644
index 0000000000..e9bb3e944e
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/FactOriginProjectOrgPeriodDailyDTO.java
@@ -0,0 +1,128 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.extract;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+
+/**
+ * 业务数据抽取-机关项目响应时间
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-09-16
+ */
+@Data
+public class FactOriginProjectOrgPeriodDailyDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ *
+ */
+ private String id;
+
+ private String customerId;
+
+ /**
+ * 项目ID
+ */
+ private String projectId;
+
+ /**
+ *
+ */
+ private String orgId;
+
+ /**
+ * grid agenct dept
+ */
+ private String orgType;
+
+ /**
+ * 如果是机关,则为父级机关(若已是顶级机关则为0);如果是网格和部门,则为所属机关
+ */
+ private String pid;
+
+ /**
+ * 最后一个节点是PID,若无则为空
+ */
+ private String pids;
+
+ /**
+ * 流转到的日期
+ */
+ private Date informedDate;
+
+ /**
+ * 流转走或结案的日期
+ */
+ private Date handledDate;
+
+ /**
+ * 响应时长,从流转到自己到流转走共耗时/小时(不算法定节假日和周末)
+ */
+ private Integer totalPeriod;
+
+ /**
+ * 截至第一次响应时长,从流转到第一次处理(响应、结案、流转)耗时,大于等于上一项值
+ */
+ private Integer periodTillReplyFirstly;
+
+ /**
+ * resloved 、 unresolved
+ */
+ private String isResolved;
+
+ /**
+ * 办结的操作,return(回退)、transfer(流转)、closed(结案),但是不包括response(响应)!
+ * */
+ private String operation;
+
+ /**
+ * 删除标识
+ */
+ private String delFlag;
+
+ /**
+ * 乐观锁
+ */
+ private Integer revision;
+
+ /**
+ *
+ */
+ private Date createdTime;
+
+ /**
+ *
+ */
+ private String createdBy;
+
+ /**
+ *
+ */
+ private Date updatedTime;
+
+ /**
+ *
+ */
+ private String updatedBy;
+
+}
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractFormDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractFormDTO.java
index 50b3a91f5c..0b392c0053 100644
--- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractFormDTO.java
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractFormDTO.java
@@ -15,11 +15,21 @@ public class ExtractFormDTO implements Serializable {
private static final long serialVersionUID = -6180252151765854242L;
- public interface ExtractForm extends CustomerClientShowGroup{}
+ public interface ExtractForm extends CustomerClientShowGroup {
+ }
- @NotBlank(message = "客户ID不能为空",groups = ExtractForm.class)
+ @NotBlank(message = "客户ID不能为空", groups = ExtractForm.class)
private String customerId;
- @NotBlank(message = "dateId不能为空",groups = ExtractForm.class)
+ @NotBlank(message = "dateId不能为空", groups = ExtractForm.class)
private String dateId;
+
+ /**
+ * 开始时间
+ */
+ private String startDate;
+ /**
+ * 结束时间
+ */
+ private String endDate;
}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractIndexFormDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractIndexFormDTO.java
new file mode 100644
index 0000000000..c188b64a57
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/ExtractIndexFormDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.extract.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * desc:抽取指标数据 参数dto
+ */
+@Data
+public class ExtractIndexFormDTO implements Serializable {
+
+
+ private static final long serialVersionUID = 1248641210655148366L;
+
+ private String customerId;
+
+ private String monthId;
+
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GovernAbilityGridMonthlyFormDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GovernAbilityGridMonthlyFormDTO.java
new file mode 100644
index 0000000000..890e663083
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GovernAbilityGridMonthlyFormDTO.java
@@ -0,0 +1,148 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.extract.form;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 治理能力-网格相关事实表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-09-18
+ */
+@Data
+public class GovernAbilityGridMonthlyFormDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * ID 主键
+ */
+ private String id;
+
+ /**
+ * 客户Id
+ */
+ private String customerId;
+
+ /**
+ * 网格所属机关Id
+ */
+ private String agencyId;
+
+ /**
+ * 网格Id
+ */
+ private String gridId;
+
+ /**
+ * 月维度Id:yyyyMM
+ */
+ private String monthId;
+
+ /**
+ * 季度Id:yyyyQ1,yyyyQ2,yyyyQ3,yyyyQ4
+ */
+ private String quarterId;
+
+ /**
+ * 年Id:yyyy
+ */
+ private String yearId;
+
+ /**
+ * 网格总议题数
+ */
+ private Integer issueTotal;
+
+ /**
+ * 网格人均议题数目
+ */
+ private Integer avgIssueCount;
+
+ /**
+ * 网格议题转项目率
+ */
+ private BigDecimal issueToProjectRatio;
+
+ /**
+ * 网格总项目数
+ */
+ private Integer projectTotal;
+
+ /**
+ * 网格自治项目数 统计期网格自身内办结的项目数目
+ */
+ private Integer selfSolveProjectCount;
+
+ /**
+ * 网格办结项目数 统计期内办结的项目数目
+ */
+ private Integer resolveProjectCount;
+
+ /**
+ * 网格吹哨部门准确率
+ */
+ private BigDecimal transferRightRatio;
+
+ /**
+ * 网格内解决的项目的满意度
+ */
+ private BigDecimal satisfactionRatio;
+
+ /**
+ * 删除标识 0未删除;1已删除
+ */
+ private String delFlag;
+
+ /**
+ * 乐观锁
+ */
+ private Integer revision;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ public GovernAbilityGridMonthlyFormDTO() {
+ this.issueTotal = NumConstant.ZERO;
+ this.avgIssueCount = NumConstant.ZERO;
+ this.issueToProjectRatio = new BigDecimal(NumConstant.ZERO);
+ this.projectTotal = NumConstant.ZERO;
+ this.selfSolveProjectCount = NumConstant.ZERO;
+ this.resolveProjectCount = NumConstant.ZERO;
+ this.transferRightRatio = new BigDecimal(NumConstant.ZERO);
+ this.satisfactionRatio = new BigDecimal(NumConstant.ZERO);
+ this.delFlag = NumConstant.ZERO_STR;
+ this.revision = NumConstant.ZERO;
+ this.createdBy = "APP_USER";
+ this.updatedBy = "APP_USER";
+ }
+}
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridHeartedFormDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridHeartedFormDTO.java
new file mode 100644
index 0000000000..f570700d01
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridHeartedFormDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.extract.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description
+ * @ClassName GridHeartedFormDTO
+ * @Auth wangc
+ * @Date 2020-09-20 12:42
+ */
+@Data
+public class GridHeartedFormDTO implements Serializable {
+ private static final long serialVersionUID = 9069263069122734316L;
+
+ private String userId;
+
+ private String gridId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridIssueCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridIssueCountResultDTO.java
new file mode 100644
index 0000000000..207cd8e8df
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/GridIssueCountResultDTO.java
@@ -0,0 +1,30 @@
+package com.epmet.dto.extract.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 10:12 上午
+ */
+@Data
+public class GridIssueCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -1222149631076688225L;
+
+ /**
+ * 网格总议题数目
+ */
+ private Integer issueTotal;
+
+ /**
+ * 网格人均议题数目
+ */
+ private Integer avgIssueCount;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/PartyAbilityGridMonthlyFormDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/PartyAbilityGridMonthlyFormDTO.java
new file mode 100644
index 0000000000..de69be568b
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/form/PartyAbilityGridMonthlyFormDTO.java
@@ -0,0 +1,178 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dto.extract.form;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 党建能力-网格相关事实表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-09-19
+ */
+@Data
+public class PartyAbilityGridMonthlyFormDTO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * ID 主键
+ */
+ private String id;
+
+ /**
+ * 客户Id
+ */
+ private String customerId;
+
+ /**
+ * 机关Id
+ */
+ private String agencyId;
+
+ /**
+ * 网格Id
+ */
+ private String gridId;
+
+ /**
+ * 月维度Id:yyyyMM
+ */
+ private String monthId;
+
+ /**
+ * 季度Id yyyyQ1,yyyyQ2,yyyyQ3,yyyyQ4
+ */
+ private String quarterId;
+
+ /**
+ * 年Idyyyy
+ */
+ private String yearId;
+
+ /**
+ * 网格群众用户数
+ */
+ private Integer userCount;
+
+ /**
+ * 网格党员用户数
+ */
+ private Integer partyCount;
+
+ /**
+ * 网格活跃群众用户数
+ */
+ private Integer activeUserCount;
+
+ /**
+ * 网格活跃党员用户数
+ */
+ private Integer activePartyCount;
+
+ /**
+ * 网格党员人均提出话题数
+ */
+ private Integer partyAvgTopicCount;
+
+ /**
+ * 网格群众人均提出话题数
+ */
+ private Integer userAvgTopicCount;
+
+ /**
+ * 网格党员人均提出的议题转项目数
+ */
+ private Integer partyAvgShiftProjectCount;
+
+ /**
+ * 网格群众人均提出的议题转项目数
+ */
+ private Integer userAvgShiftProjectCount;
+
+ /**
+ * 建群党员数(累计值) 去重
+ */
+ private Integer createGroupPartyCount;
+
+ /**
+ * 网格发文数
+ */
+ private Integer publishArticleCount;
+
+ /**
+ * 网格议题转项目率
+ */
+ private BigDecimal issueToProjectRatio;
+
+ /**
+ * 组织三会一课次数
+ */
+ private Integer createThreeMeetsCount;
+
+ /**
+ * 党员参加三会一课人次
+ */
+ private Integer joinThreeMeetsCount;
+
+ /**
+ * 删除标识 0未删除;1已删除
+ */
+ private String delFlag;
+
+ /**
+ * 乐观锁
+ */
+ private Integer revision;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ public PartyAbilityGridMonthlyFormDTO() {
+ this.userCount = NumConstant.ZERO;
+ this.partyCount = NumConstant.ZERO;
+ this.activeUserCount = NumConstant.ZERO;
+ this.activePartyCount = NumConstant.ZERO;
+ this.partyAvgTopicCount = NumConstant.ZERO;
+ this.userAvgTopicCount = NumConstant.ZERO;
+ this.partyAvgShiftProjectCount = NumConstant.ZERO;
+ this.userAvgShiftProjectCount = NumConstant.ZERO;
+ this.createGroupPartyCount = NumConstant.ZERO;
+ this.publishArticleCount = NumConstant.ZERO;
+ this.issueToProjectRatio = new BigDecimal(NumConstant.ZERO);
+ this.createThreeMeetsCount = NumConstant.ZERO;
+ this.joinThreeMeetsCount = NumConstant.ZERO;
+ this.delFlag = NumConstant.ZERO_STR;
+ this.revision = NumConstant.ZERO;
+ this.createdBy = "APP_USER";
+ this.updatedBy = "APP_USER";
+ }
+}
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/AutoNoMyResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/AutoNoMyResultDTO.java
new file mode 100644
index 0000000000..234142eb80
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/AutoNoMyResultDTO.java
@@ -0,0 +1,30 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 5:22 下午
+ */
+@Data
+public class AutoNoMyResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 5812052000386418907L;
+
+ /**
+ * 动作code
+ */
+ private String actionCode;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 项目ID
+ */
+ private String projectId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CalSatisfactionResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CalSatisfactionResultDTO.java
new file mode 100644
index 0000000000..811f33c30b
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CalSatisfactionResultDTO.java
@@ -0,0 +1,16 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 4:01 下午
+ */
+@Data
+public class CalSatisfactionResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -7514945819312915670L;
+
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CreateTopicCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CreateTopicCountResultDTO.java
new file mode 100644
index 0000000000..1aa548f014
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/CreateTopicCountResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/19 1:55 下午
+ */
+@Data
+public class CreateTopicCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 500844515980125608L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 网格 党员/群众 人均提出话题数
+ */
+ private Integer createTopicCount;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectClosedTotalResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectClosedTotalResultDTO.java
new file mode 100644
index 0000000000..512e594ad2
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectClosedTotalResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 2:02 下午
+ */
+@Data
+public class GridProjectClosedTotalResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 5144371528837124674L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 网格办结项目数
+ */
+ private Integer resolveProjectCount;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectCountResultDTO.java
new file mode 100644
index 0000000000..6d0a8cf1d7
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridProjectCountResultDTO.java
@@ -0,0 +1,31 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 1:22 下午
+ */
+@Data
+public class GridProjectCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -1348707512443965601L;
+
+ /**
+ * 网格总项目数
+ */
+ private Integer projectTotal;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 网格议题转项目率
+ */
+ private BigDecimal issueToProjectRatio;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridUserCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridUserCountResultDTO.java
new file mode 100644
index 0000000000..8b97bdc505
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/GridUserCountResultDTO.java
@@ -0,0 +1,30 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/19 10:59 上午
+ */
+@Data
+public class GridUserCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -2912049598149499392L;
+
+ /**
+ * 注册居民本月增量
+ */
+ private Integer userCount;
+
+ /**
+ * 注册党员本月增量
+ */
+ private Integer partyCount;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/NotReturnProjectResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/NotReturnProjectResultDTO.java
new file mode 100644
index 0000000000..70f0efd484
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/NotReturnProjectResultDTO.java
@@ -0,0 +1,32 @@
+package com.epmet.dto.extract.result;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 2:46 下午
+ */
+@Data
+public class NotReturnProjectResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -2931817313224740122L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 未被退回的项目
+ */
+ private Integer notReturnProject = NumConstant.ZERO;
+
+ /**
+ * 网格吹哨部门准确率
+ */
+ private BigDecimal transferRightRatio = new BigDecimal(NumConstant.ZERO);
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgResponseTimeResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgResponseTimeResultDTO.java
new file mode 100644
index 0000000000..88735859d3
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgResponseTimeResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @Description 各机关响应时间
+ * @ClassName OrgResponseTimeResultDTO
+ * @Auth wangc
+ * @Date 2020-09-21 02:03
+ */
+@Data
+public class OrgResponseTimeResultDTO implements Serializable {
+ private static final long serialVersionUID = 6017440139236985959L;
+
+ private String agencyId;
+
+ private BigDecimal responseTime;
+
+ private BigDecimal projectTotal;
+
+ private BigDecimal distinctProjectTotal;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgStatisticsResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgStatisticsResultDTO.java
new file mode 100644
index 0000000000..ad170c5b96
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/OrgStatisticsResultDTO.java
@@ -0,0 +1,21 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/9/18 14:39
+ */
+@Data
+public class OrgStatisticsResultDTO implements Serializable {
+ private static final long serialVersionUID = 9221060553279124719L;
+ private String customerId;
+ private String agencyId;
+ private String orgId;
+ private Integer count;
+ private Integer sum;
+ private String ratio;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyActiveResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyActiveResultDTO.java
new file mode 100644
index 0000000000..53bc3f2658
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyActiveResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/21 9:35 上午
+ */
+@Data
+public class PartyActiveResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 4694666116463447613L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 动作操作用户ID
+ */
+ private String userId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyCreateGroupCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyCreateGroupCountResultDTO.java
new file mode 100644
index 0000000000..c95ae4bad3
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PartyCreateGroupCountResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/19 3:30 下午
+ */
+@Data
+public class PartyCreateGroupCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -4193777575465275095L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 建群党员数
+ */
+ private Integer partyCreateGroupCount;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectEvaluateResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectEvaluateResultDTO.java
new file mode 100644
index 0000000000..1e9c927663
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectEvaluateResultDTO.java
@@ -0,0 +1,37 @@
+package com.epmet.dto.extract.result;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/18 3:23 下午
+ */
+@Data
+public class ProjectEvaluateResultDTO implements Serializable {
+
+ private static final long serialVersionUID = 6042094904405338630L;
+
+ /**
+ * 动作code
+ */
+ private String actionCode;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 满意度评价对应的分数
+ */
+ private Integer score = NumConstant.ZERO;
+
+ /**
+ * 项目ID
+ */
+ private String projectId;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectParticipatedAgencyResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectParticipatedAgencyResultDTO.java
new file mode 100644
index 0000000000..1cd9de713b
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ProjectParticipatedAgencyResultDTO.java
@@ -0,0 +1,24 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description 参与过项目的agencyDTO
+ * @ClassName ProjectParticipatedAgencyResultDTO
+ * @Auth wangc
+ * @Date 2020-09-20 23:40
+ */
+@Data
+public class ProjectParticipatedAgencyResultDTO implements Serializable {
+ private static final long serialVersionUID = 1071619125612033138L;
+
+ private String projectId;
+
+ private String agencyId;
+
+ private String level;
+
+ private int score;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PublishCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PublishCountResultDTO.java
new file mode 100644
index 0000000000..2044dcd8fa
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/PublishCountResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/19 2:41 下午
+ */
+@Data
+public class PublishCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -955208044108055887L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 发文数量
+ */
+ private Integer publishCount;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ShiftProjectCountResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ShiftProjectCountResultDTO.java
new file mode 100644
index 0000000000..7519e32c48
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/extract/result/ShiftProjectCountResultDTO.java
@@ -0,0 +1,25 @@
+package com.epmet.dto.extract.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2020/9/19 2:23 下午
+ */
+@Data
+public class ShiftProjectCountResultDTO implements Serializable {
+
+ private static final long serialVersionUID = -262809191405218048L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 网格 党员/群众 人均提出的议题转项目数
+ */
+ private Integer shiftProjectCount;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/group/result/ExtractGroupMemberActionRecordResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/group/result/ExtractGroupMemberActionRecordResultDTO.java
new file mode 100644
index 0000000000..47aa8e8783
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/group/result/ExtractGroupMemberActionRecordResultDTO.java
@@ -0,0 +1,41 @@
+package com.epmet.dto.group.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description
+ * @ClassName ExtractGroupMemberActionRecordResultDTO
+ * @Auth wangc
+ * @Date 2020-09-18 21:18
+ */
+@Data
+public class ExtractGroupMemberActionRecordResultDTO implements Serializable {
+ private static final long serialVersionUID = -74883228267461785L;
+ private String customerId;
+
+ private String groupId;
+
+ private String memberId;
+
+ private String leaderFlag;
+
+ private String dateId;
+
+ private String weekId;
+
+ private String monthId;
+
+ private String quarterId;
+
+ private String yearId;
+
+ private Date joinDate;
+
+ /**
+ * 目前只有join leader也是join
+ * */
+ private String actionCode;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/FinishOrgDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/FinishOrgDTO.java
new file mode 100644
index 0000000000..ab5c9ef2ce
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/FinishOrgDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.project;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/9/20 21:08
+ */
+@Data
+public class FinishOrgDTO implements Serializable {
+
+ private static final long serialVersionUID = -5684606755705833962L;
+ private String projectId;
+ private String orgIdPath;
+ private String pIdPath;
+
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/ProcessInfoDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/ProcessInfoDTO.java
index 070f1ceb0b..845c943aa9 100644
--- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/ProcessInfoDTO.java
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/ProcessInfoDTO.java
@@ -14,6 +14,8 @@ import java.util.Date;
public class ProcessInfoDTO implements Serializable {
private static final long serialVersionUID = 4586424046147127143L;
private String agencyId;
+ private String departmentId;
+ private String gridId;
private String projectId;
/**
* 处理:结案close,退回return,部门流转transfer,创建项目created
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgPeriodResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgPeriodResultDTO.java
new file mode 100644
index 0000000000..b3e101295d
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgPeriodResultDTO.java
@@ -0,0 +1,95 @@
+package com.epmet.dto.project.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 从数据库中查询出的 项目 - 机关(网格、部门、机关)的响应时长
+ * FIXME 注:查询的全都是已经结案的项目!!!!!!!!!!!!如果查询流转中的项目,需要修改逻辑(较为复杂)
+ * @ClassName ProjectOrgPeriodResultDTO
+ * @Auth wangc
+ * @Date 2020-09-16 15:28
+ */
+@Data
+public class ProjectOrgPeriodResultDTO implements Serializable {
+ private static final long serialVersionUID = 6216112710806237600L;
+
+ /**
+ * 节点Id
+ * */
+ private String processId;
+
+ /**
+ * 项目Id
+ * */
+ private String projectId;
+
+
+ /**
+ * 对这个节点的处理,如果未处理则为null
+ * created transfer close return response(查不出response,因为response类型的节点不会与process_staff产生关联,需要另取)
+ * */
+ private String operation;
+
+ /**
+ * 是这个节点的操作,相当于上一个人的操作,而不是对于这个节点的处理
+ * created transfer close return response
+ * */
+ private String lastAction;
+
+ /**
+ * 节点所属的机关,即上个节点推到这个节点的负责部门
+ * */
+ private String departmentName;
+
+ /**
+ * 当前节点所属的Agency,如果负责的是部门或者网格则是其所属的机关
+ * */
+ private String orgId;
+
+ /**
+ * 如果是部门处理,则有值,否则null
+ * */
+ private String departmentId;
+
+ /**
+ * 如果是网格处理,则有值,否则null
+ * */
+ private String gridId;
+
+ /**
+ * 当前所属的机关的所有Pid集合以及当前的机关Id,所以此项不会未null,至少也是它的所属Agency
+ * */
+ private String orgIdPath;
+
+ /**
+ * 从节点流入到节点流出,且当前负责单位确实解决(包括退回)了的情况下,所耗费的时间(以分钟为单位)
+ * 如果未当前负责单位一直停留在unresolved状态,即使做出response、或者项目被其他单位结案,该项依旧是0,不参与办结的计时
+ * 如果负责单位只是做出回应,但未处理(即没有让节点流走),需要查出其相应的第一次响应时间,另取
+ * */
+ private Integer totalPeriod;
+
+ /**
+ * 节点流入时间
+ * */
+ private Date informedDate;
+
+ /**
+ * 节点流出时间,如果未解决则未null
+ * */
+ private Date handledDate;
+
+ /**
+ * 第一次响应时间
+ * */
+ private Date periodTillReplyFirstly;
+
+ private String customerId;
+
+ private String staffId;
+
+ private String isResolved;
+
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgRelationWhenResponseResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgRelationWhenResponseResultDTO.java
new file mode 100644
index 0000000000..892e173491
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/project/result/ProjectOrgRelationWhenResponseResultDTO.java
@@ -0,0 +1,49 @@
+package com.epmet.dto.project.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 查询机关在项目节点上响应的结果
+ * 查询的是存在“响应”的所有相关工作人员节点,如果同一个人对同一个项目已经做过一次处理(并未做出响应)而在第二次流转到自己时
+ * 做出了响应,也会连带查询出其第一次未响应过的数据
+ * @ClassName ProjectOrgRelationWhenResponseResultDTO
+ * @Auth wangc
+ * @Date 2020-09-16 17:27
+ */
+@Data
+public class ProjectOrgRelationWhenResponseResultDTO implements Serializable {
+ private static final long serialVersionUID = 1962332392048752037L;
+
+ /**
+ * 项目Id
+ * */
+ private String projectId;
+
+ /**
+ * 节点Id
+ * */
+ private String processId;
+
+ /**
+ * 节点动作的发起人
+ * */
+ private String staffId;
+
+ /**
+ * 负责人所属的单位名称:xx机关-xx部门 、 xx机关-xx网格 、 xx机关
+ * */
+ private String departmentName;
+
+ /**
+ * 动作分类
+ * */
+ private String operation;
+
+ /**
+ * 节点创建时间,动作发起时间
+ * */
+ private Date createdTime;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/stats/result/GridAttributesResultDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/stats/result/GridAttributesResultDTO.java
new file mode 100644
index 0000000000..17fd652a8c
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/stats/result/GridAttributesResultDTO.java
@@ -0,0 +1,36 @@
+package com.epmet.dto.stats.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description
+ * @ClassName GridAttributesResultDTO
+ * @Auth wangc
+ * @Date 2020-09-20 12:50
+ */
+@Data
+public class GridAttributesResultDTO implements Serializable {
+ private static final long serialVersionUID = 466974582608407121L;
+
+ /**
+ * 网格ID
+ */
+ private String gridId;
+
+ /**
+ * 网格所属机关ID
+ */
+ private String agencyId;
+
+ /**
+ * 机关的上级ID
+ */
+ private String parentId;
+
+ /**
+ * 所有上级Id
+ * */
+ private String pids;
+}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java
index 5abd41f58b..4430b7295e 100644
--- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java
@@ -3,6 +3,8 @@ package com.epmet.feign;
import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.StatsFormDTO;
+import com.epmet.dto.extract.form.ExtractFormDTO;
+import com.epmet.dto.extract.form.ExtractIndexFormDTO;
import com.epmet.dto.group.form.GroupStatsFormDTO;
import com.epmet.dto.issue.form.IssueJobFromDTO;
import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
@@ -175,8 +177,8 @@ public interface DataStatisticalOpenFeignClient {
Result execTopicStatistical(@RequestParam(value = "date", required = false) String date);
/**
+ * @Description 统计党员
* @param customerIdAndDateIdFormDTO
- * @Description 统计党员
* @author zxc
* @date 2020/9/17 3:10 下午
*/
@@ -190,4 +192,23 @@ public interface DataStatisticalOpenFeignClient {
*/
@PostMapping("/data/stats/indexcalculate/process-pendding-cals")
Result processPenddingCalculate();
+
+ /**
+ * desc: 【日】抽取业务数据到统计库 小组 话题 议题 项目
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @PostMapping(value = "data/stats/factorigin/extractall")
+ Result factOriginExtractAll(@RequestBody(required = false) ExtractFormDTO formDTO);
+
+ /**
+ * desc: 【月】抽取统计数据到指标库
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @PostMapping(value = "data/stats/indexorigin/extractall")
+ Result indexOriginExtractAll(@RequestBody(required = false) ExtractIndexFormDTO formDTO);
+
}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java
index 85a0737f0b..b672d53351 100644
--- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java
@@ -4,6 +4,8 @@ import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.utils.ModuleUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.StatsFormDTO;
+import com.epmet.dto.extract.form.ExtractFormDTO;
+import com.epmet.dto.extract.form.ExtractIndexFormDTO;
import com.epmet.dto.group.form.GroupStatsFormDTO;
import com.epmet.dto.issue.form.IssueJobFromDTO;
import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
@@ -181,4 +183,28 @@ public class DataStatisticalOpenFeignClientFallBack implements DataStatisticalOp
public Result processPenddingCalculate() {
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "processPenddingCalculate");
}
+
+ /**
+ * desc: 【日】抽取业务数据到统计库 小组 话题 议题 项目
+ *
+ * @param formDTO
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result factOriginExtractAll(ExtractFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "factOriginExtractAll", formDTO);
+ }
+
+ /**
+ * desc: 【月】抽取统计数据到指标库
+ *
+ * @param formDTO
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result indexOriginExtractAll(ExtractIndexFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "indexOriginExtractAll", formDTO);
+ }
}
diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/FactExtractOpenFeignClientFallBack.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/FactExtractOpenFeignClientFallBack.java
new file mode 100644
index 0000000000..b06cc18485
--- /dev/null
+++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/FactExtractOpenFeignClientFallBack.java
@@ -0,0 +1,210 @@
+package com.epmet.feign.impl;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.utils.ModuleUtils;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.StatsFormDTO;
+import com.epmet.dto.extract.form.ExtractFormDTO;
+import com.epmet.dto.extract.form.ExtractIndexFormDTO;
+import com.epmet.dto.group.form.GroupStatsFormDTO;
+import com.epmet.dto.issue.form.IssueJobFromDTO;
+import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
+import com.epmet.feign.DataStatisticalOpenFeignClient;
+import org.springframework.stereotype.Component;
+
+/**
+ * desc:
+ *
+ * @return:
+ * @date: 2020/6/22 9:38
+ * @author: jianjun liu
+ * email:liujianjun@git.elinkit.com.cn
+ */
+@Component
+public class FactExtractOpenFeignClientFallBack implements DataStatisticalOpenFeignClient {
+
+ /**
+ * desc: 【日】统计文章总数及在线文章总数 包含 机关 部门 网格
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result articleSummaryDailyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "articleSummaryDailyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 定时任务 【日】统计文章总数及在线文章总数 包含 机关 部门 网格
+ *
+ * @return:
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagUsedDailyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedDailyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 【月】 统计发表文章最多的分类 包含 机关 部门 网格
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagUsedMonthlyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedMonthlyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 【季,年】 统计发表文章最多的分类 包含 机关 部门 网格
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagUsedQuarterlyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedQuarterlyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 【日】 统计阅读最多的标签 包含 机关 网格
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagViewedDailyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedDailyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 【月】 统计阅读最多的标签 包含 机关 网格
+ *
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagViewedMonthlyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedMonthlyStatsjob", formDTO);
+ }
+
+ /**
+ * desc: 【季,年】 统计阅读最多的标签 包含 机关 网格
+ *
+ * @param formDTO
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result tagViewedQuarterlyStatsjob(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedQuarterlyStatsjob", formDTO);
+ }
+
+ @Override
+ public Result groupGridDaily(GroupStatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupGridDaily", formDTO);
+ }
+
+ @Override
+ public Result groupAgencyDaily(GroupStatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupAgencyDaily", formDTO);
+ }
+
+ @Override
+ public Result groupAgencyMonthly(GroupStatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupAgencyMonthly", formDTO);
+ }
+
+ @Override
+ public Result agencyGridIssueStats() {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStats");
+ }
+
+ @Override
+ public Result agencyGridIssueStatsOfDate(IssueJobFromDTO fromDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStatsOfDate");
+ }
+
+ /**
+ * @Description 数据统计-项目-机关日月统计
+ * @Author sun
+ */
+ @Override
+ public Result agencyProjectStats(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyProjectStats", formDTO);
+ }
+
+ /**
+ * @Description 数据统计-项目-网格日月统计
+ * @Author sun
+ */
+ @Override
+ public Result gridProjectStats(StatsFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "gridProjectStats", formDTO);
+ }
+
+ @Override
+ public Result initAllDims() {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "initAllDims");
+ }
+
+ /**
+ * @param
+ * @return
+ * @Description 执行用户统计
+ * @author wangc
+ * @date 2020.06.29 09:26
+ **/
+ @Override
+ public Result execUserStatistical(String date) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "execUserStatistical", date);
+ }
+
+ /**
+ * @param
+ * @return
+ * @Description 执行话题统计
+ * @author wangc
+ * @date 2020.06.29 09:27
+ **/
+ @Override
+ public Result execTopicStatistical(String date) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "execTopicStatistical", date);
+ }
+
+ @Override
+ public Result getPartyInfo(CustomerIdAndDateIdFormDTO customerIdAndDateIdFormDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "getPartyInfo", customerIdAndDateIdFormDTO);
+ }
+
+ @Override
+ public Result processPenddingCalculate() {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "processPenddingCalculate");
+ }
+
+ /**
+ * desc: 【日】抽取业务数据到统计库 小组 话题 议题 项目
+ *
+ * @param formDTO
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result factOriginExtractAll(ExtractFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "factOriginExtractAll", formDTO);
+ }
+
+ /**
+ * desc: 【月】抽取统计数据到指标库
+ *
+ * @param formDTO
+ * @date: 2020/6/22 9:09
+ * @author: jianjun liu
+ */
+ @Override
+ public Result indexOriginExtractAll(ExtractIndexFormDTO formDTO) {
+ return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "indexOriginExtractAll", formDTO);
+ }
+}
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
index 6db7fd4245..92611df2cf 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
@@ -15,6 +15,7 @@ import com.epmet.dao.evaluationindex.screen.ScreenCustomerGridDao;
import com.epmet.dao.stats.DimCustomerDao;
import com.epmet.dao.stats.DimDateDao;
import com.epmet.dto.AgencySubTreeDto;
+import com.epmet.dto.extract.form.ExtractFormDTO;
import com.epmet.dto.indexcal.CalculateCommonFormDTO;
import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
import com.epmet.entity.evaluationindex.indexcoll.FactIndexGovrnAblityGridMonthlyEntity;
@@ -25,6 +26,8 @@ import com.epmet.entity.stats.DimAgencyEntity;
import com.epmet.entity.stats.DimCustomerEntity;
import com.epmet.entity.stats.DimDateEntity;
import com.epmet.service.StatsDemoService;
+import com.epmet.service.evaluationindex.extract.CalGridIndexService;
+import com.epmet.service.evaluationindex.extract.FactOriginProjectLogDailyService;
import com.epmet.service.evaluationindex.extract.FactOriginTopicMainDailyService;
import com.epmet.service.evaluationindex.indexcal.*;
import com.epmet.service.stats.DimAgencyService;
@@ -37,6 +40,7 @@ import org.springframework.web.bind.annotation.*;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.List;
+import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
@@ -81,6 +85,8 @@ public class DemoController {
private DimCustomerDao dimCustomerDao;
@Autowired
private FactOriginTopicMainDailyService factOriginTopicMainDailyService;
+ @Autowired
+ private FactOriginProjectLogDailyService factOriginProjectLogDailyService;
@GetMapping("testAlarm")
public void testAlarm() {
@@ -503,15 +509,21 @@ public class DemoController {
@PostMapping("inserttopicorigin")
public Result topicDataCleaning(@RequestParam("customerId") String customerId, @RequestParam("dateId")String dateId) {
if (StringUtils.isNotBlank(customerId) && StringUtils.isNotBlank(dateId)) {
- factOriginTopicMainDailyService.topicCleaning(customerId,dateId);
+ ExtractFormDTO param = new ExtractFormDTO();
+ param.setDateId(dateId);
+ param.setCustomerId(customerId);
+ Boolean aBoolean = factOriginTopicMainDailyService.topicCleaning(param);
}else{
QueryWrapper customerEntityQueryWrapper = new QueryWrapper<>();
List customerEntityList=dimCustomerDao.selectList(customerEntityQueryWrapper);
QueryWrapper wrapper = new QueryWrapper<>();
List dimDateEntityList= dimDateDao.selectList(wrapper);
for(DimCustomerEntity customerEntity:customerEntityList){
- for(DimDateEntity dateEntity:dimDateEntityList){
- factOriginTopicMainDailyService.topicCleaning(customerEntity.getId(),dateEntity.getId());
+ for(DimDateEntity dateEntity:dimDateEntityList) {
+ ExtractFormDTO param = new ExtractFormDTO();
+ param.setDateId(dateEntity.getId());
+ param.setCustomerId(customerEntity.getId());
+ factOriginTopicMainDailyService.topicCleaning(param);
}
}
}
@@ -526,4 +538,38 @@ public class DemoController {
partymemberService.statsPartyMember(customerIdAndDateIdFormDTO);
return new Result();
}
+
+ @Autowired
+ private CalGridIndexService calGridIndexService;
+
+ @PostMapping("gridparty")
+ public void gridParty(){
+// String customerId = "3ef7e4bb195eb9e622d68b52509aa940";
+ String customerId = "epmettest";
+ String monthId = "202008";
+ calGridIndexService.calGridIndexPartyAbility(customerId,monthId);
+ }
+
+ @PostMapping("gridgovern")
+ public void gridGovern(){
+// String customerId = "3ef7e4bb195eb9e622d68b52509aa940";
+ String customerId = "epmettest";
+ String monthId = "202008";
+ calGridIndexService.calGridIndexGovernAbility(customerId,monthId);
+ }
+
+ @PostMapping("handlemap")
+ public Result