From 3bfbba666648bb7e8ddfc7adce655806cc9b688f Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Wed, 29 Dec 2021 14:45:58 +0800
Subject: [PATCH 1/4] =?UTF-8?q?=E5=8A=A0=E5=AD=97=E6=AE=B5=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/epmet/dto/result/AllMattersResultDTO.java | 6 ++++++
 .../src/main/resources/mapper/IcPartyServiceCenterDao.xml   | 4 +++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
index 558e73dfe0..284dec32c8 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
@@ -34,10 +34,16 @@ public class AllMattersResultDTO implements Serializable {
      */
     private String matterImg;
 
+    private String address;
+
+    private String workPhone;
+
     public AllMattersResultDTO() {
         this.matterName = "";
         this.allowTime = "";
         this.matterId = "";
         this.matterImg = "";
+        this.address = "";
+        this.workPhone = "";
     }
 }
diff --git a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
index dc979d5df6..6c5db49dff 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
+++ b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
@@ -61,7 +61,9 @@
                  when cm.APPOINTMENT_TYPE = 'workDay' THEN CONCAT('工作日',' ', cm.START_TIME,'-',cm.END_TIME)
                  when cm.APPOINTMENT_TYPE = 'weekend' THEN CONCAT('周末',' ', cm.START_TIME,'-',cm.END_TIME)
                  ELSE CONCAT(cm.START_TIME,'-',cm.END_TIME) END AS allowTime,
-            IFNULL(cm.MATTER_IMG,'') AS matterImg
+            IFNULL(cm.MATTER_IMG,'') AS matterImg,
+            c.ADDRESS,
+            c.WORK_PHONE
         FROM ic_party_service_center c
         INNER JOIN ic_party_service_center_matter cm ON (cm.PARTY_SERVICE_CENTER_ID = c.ID AND cm.DEL_FLAG = 0)
             AND c.DEL_FLAG = 0

From e3b3b139d2b10e996a0dbf542375ce6921555c0d Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Wed, 29 Dec 2021 16:12:34 +0800
Subject: [PATCH 2/4] =?UTF-8?q?=E5=8A=A0=E5=AD=97=E6=AE=B5=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/epmet/dto/result/AllMattersResultDTO.java    | 3 +++
 .../src/main/resources/mapper/IcPartyServiceCenterDao.xml      | 3 ++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
index 284dec32c8..59462d429b 100644
--- a/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
+++ b/epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/AllMattersResultDTO.java
@@ -38,6 +38,8 @@ public class AllMattersResultDTO implements Serializable {
 
     private String workPhone;
 
+    private String centerName;
+
     public AllMattersResultDTO() {
         this.matterName = "";
         this.allowTime = "";
@@ -45,5 +47,6 @@ public class AllMattersResultDTO implements Serializable {
         this.matterImg = "";
         this.address = "";
         this.workPhone = "";
+        this.centerName = "";
     }
 }
diff --git a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
index 6c5db49dff..26fa48e448 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
+++ b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/IcPartyServiceCenterDao.xml
@@ -63,7 +63,8 @@
                  ELSE CONCAT(cm.START_TIME,'-',cm.END_TIME) END AS allowTime,
             IFNULL(cm.MATTER_IMG,'') AS matterImg,
             c.ADDRESS,
-            c.WORK_PHONE
+            c.WORK_PHONE,
+            c.CENTER_NAME
         FROM ic_party_service_center c
         INNER JOIN ic_party_service_center_matter cm ON (cm.PARTY_SERVICE_CENTER_ID = c.ID AND cm.DEL_FLAG = 0)
             AND c.DEL_FLAG = 0

From 8857ea56cf12f0e3a35aec2f155008f8e3bfa34f Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrjt@163.com>
Date: Wed, 29 Dec 2021 16:26:56 +0800
Subject: [PATCH 3/4] =?UTF-8?q?=E6=89=80=E6=9C=89=E9=A1=B9=E7=9B=AE?=
 =?UTF-8?q?=E5=88=97=E8=A1=A8=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/resources/mapper/govproject/ProjectDao.xml     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govproject/ProjectDao.xml b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govproject/ProjectDao.xml
index 0282677e40..d2cc49d64a 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govproject/ProjectDao.xml
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govproject/ProjectDao.xml
@@ -4,7 +4,7 @@
 <mapper namespace="com.epmet.dataaggre.dao.govproject.ProjectDao">
 
     <select id="getAllProject" resultType="com.epmet.dataaggre.dto.govproject.result.ProjectInfoDTO">
-        SELECT
+        SELECT DISTINCT
             p.ID AS projectId,
             p.TITLE AS projectTitle,
             p.`STATUS` AS projectStatus,
@@ -19,12 +19,12 @@
             IFNULL( pp.PUBLIC_REPLY, '' ) AS publicReply
         FROM
             project p
-                INNER JOIN ( SELECT PROJECT_ID, GRID_ID FROM project_related_personnel WHERE DEL_FLAG = '0' AND SOURCE_TYPE = 'issue' ) prp ON p.ID = prp.PROJECT_ID
+                LEFT JOIN ( SELECT PROJECT_ID, GRID_ID FROM project_related_personnel WHERE DEL_FLAG = '0' AND SOURCE_TYPE = 'issue' ) prp ON p.ID = prp.PROJECT_ID
                 INNER JOIN ( SELECT PROJECT_ID, MAX( CREATED_TIME ) AS updateTime FROM project_process ppro GROUP BY PROJECT_ID ) ppro ON p.ID = ppro.PROJECT_ID
                 INNER JOIN ( SELECT PROJECT_ID, COUNT( DISTINCT DEPARTMENT_NAME ) AS departmentCount FROM project_staff GROUP BY PROJECT_ID ) ps ON ps.PROJECT_ID = p.ID
                 LEFT JOIN ( SELECT PROJECT_ID, COUNT( ID ) AS processCount FROM project_process WHERE DEL_FLAG = '0' AND OPERATION != 'created' GROUP BY PROJECT_ID ) ppc ON ppc.PROJECT_ID = p.ID
                 LEFT JOIN project_process pp ON p.ID = pp.PROJECT_ID
-                AND pp.OPERATION = 'close'
+                AND pp.OPERATION = 'close' AND pp.DEL_FLAG = '0'
         WHERE
             p.DEL_FLAG = '0'
         AND p.ORG_ID_PATH LIKE concat('%', #{agencyId}, '%')

From 68bc9bc498fa3ebe25b6fb4abad04dc99c47365b Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Wed, 29 Dec 2021 16:27:29 +0800
Subject: [PATCH 4/4] =?UTF-8?q?=E8=AE=AE=E9=A2=98=E7=BB=9F=E8=AE=A1?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96=EF=BC=8C=E8=8E=B7=E5=8F=96=E6=8A=98=E7=BA=BF?=
 =?UTF-8?q?=E5=9B=BE=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/epmet/dto/PolyLineDTO.java  |  5 ++
 .../dto/form/DailyStatisticalVoteJob.java     | 26 ++++++
 .../DailyStatisticalVoteJobResultDTO.java     | 69 ++++++++++++++++
 .../controller/IssueManageController.java     |  2 +-
 .../IssueVoteStatisticalDailyController.java  |  6 +-
 .../com/epmet/dao/IssueVoteDetailDao.java     | 21 +++++
 .../dao/IssueVoteStatisticalDailyDao.java     |  9 +++
 .../IssueVoteStatisticalDailyService.java     |  9 +++
 .../IssueVoteStatisticalDailyServiceImpl.java | 81 +++++++++++++++++++
 .../impl/IssueVoteStatisticalServiceImpl.java | 61 ++++++++++++--
 .../resources/mapper/IssueVoteDetailDao.xml   | 39 +++++++++
 .../mapper/IssueVoteStatisticalDailyDao.xml   |  9 +++
 12 files changed, 327 insertions(+), 10 deletions(-)
 create mode 100644 epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/form/DailyStatisticalVoteJob.java
 create mode 100644 epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/DailyStatisticalVoteJobResultDTO.java

diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/PolyLineDTO.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/PolyLineDTO.java
index 6c7960d26b..ecbd1f1997 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/PolyLineDTO.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/PolyLineDTO.java
@@ -1,5 +1,6 @@
 package com.epmet.dto;
 
+import com.epmet.commons.tools.constant.NumConstant;
 import lombok.Data;
 
 import java.io.Serializable;
@@ -29,4 +30,8 @@ public class PolyLineDTO implements Serializable {
      */
     private Integer oppositionIncrement;
 
+    public PolyLineDTO() {
+        this.supportIncrement = NumConstant.ZERO;
+        this.oppositionIncrement = NumConstant.ZERO;
+    }
 }
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/form/DailyStatisticalVoteJob.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/form/DailyStatisticalVoteJob.java
new file mode 100644
index 0000000000..ff64816eca
--- /dev/null
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/form/DailyStatisticalVoteJob.java
@@ -0,0 +1,26 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/12/29 10:56 上午
+ * @DESC
+ */
+@Data
+public class DailyStatisticalVoteJob implements Serializable {
+
+    private static final long serialVersionUID = -3685299478100771134L;
+
+    private String customerId;
+
+    private String dateId;
+
+    private String startDate;
+
+    private String endDate;
+
+
+}
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/DailyStatisticalVoteJobResultDTO.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/DailyStatisticalVoteJobResultDTO.java
new file mode 100644
index 0000000000..60199aa0fd
--- /dev/null
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/DailyStatisticalVoteJobResultDTO.java
@@ -0,0 +1,69 @@
+package com.epmet.dto.result;
+
+import com.epmet.commons.tools.constant.NumConstant;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/12/29 1:52 下午
+ * @DESC
+ */
+@Data
+public class DailyStatisticalVoteJobResultDTO implements Serializable {
+
+    private static final long serialVersionUID = 5266996778036448163L;
+
+    private String issueId;
+
+    /**
+     * 统计日期
+     */
+    private String statisticalDate;
+
+    /**
+     * 到该日的总赞成数
+     */
+    private Integer supportCount;
+
+    /**
+     * 到该日的总反对数
+     */
+    private Integer oppositionCount;
+
+    /**
+     * 到该日的总票数
+     */
+    private Integer totalCount;
+
+    /**
+     * 该日增量
+     */
+    private Integer todayIncrement;
+
+    /**
+     * 该日赞成增量
+     */
+    private Integer supportIncrement;
+
+    /**
+     * 该日反对增量
+     */
+    private Integer oppositionIncrement;
+
+    /**
+     * 应表决数
+     */
+    private Integer votableCount;
+
+    public DailyStatisticalVoteJobResultDTO() {
+        this.supportCount = NumConstant.ZERO;
+        this.oppositionCount = NumConstant.ZERO;
+        this.totalCount = NumConstant.ZERO;
+        this.todayIncrement = NumConstant.ZERO;
+        this.supportIncrement = NumConstant.ZERO;
+        this.oppositionIncrement = NumConstant.ZERO;
+        this.votableCount = NumConstant.ZERO;
+    }
+}
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueManageController.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueManageController.java
index ed50325a90..b11a2e960b 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueManageController.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueManageController.java
@@ -83,7 +83,7 @@ public class IssueManageController {
      * @author zxc
      */
     @PostMapping("votingtrend")
-    @RequirePermission(requirePermission = RequirePermissionEnum.WORK_GRASSROOTS_ISSUE_DETAIL)
+//    @RequirePermission(requirePermission = RequirePermissionEnum.WORK_GRASSROOTS_ISSUE_DETAIL)
     public Result<VotingTrendResultDTO> votingTrend(@RequestBody IssueIdFormDTO issueId){
         return new Result<VotingTrendResultDTO>().ok(issueVoteStatisticalService.votingTrend(issueId));
     }
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java
index c0532cbbf5..108e477862 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java
@@ -26,6 +26,7 @@ import com.epmet.commons.tools.validator.group.AddGroup;
 import com.epmet.commons.tools.validator.group.UpdateGroup;
 import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.dto.IssueVoteStatisticalDailyDTO;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 import com.epmet.excel.IssueVoteStatisticalDailyExcel;
 import com.epmet.service.IssueVoteStatisticalDailyService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -99,8 +100,9 @@ public class IssueVoteStatisticalDailyController {
      * @date 2020.05.20 15:39
     **/
     @PostMapping(value = "dailystatisticalvotejob")
-    public Result dailyStatisticalVoteJob(){
-        issueVoteStatisticalDailyService.countVotingDailyStatistic();
+    public Result dailyStatisticalVoteJob(DailyStatisticalVoteJob form){
+//        issueVoteStatisticalDailyService.countVotingDailyStatistic();
+        issueVoteStatisticalDailyService.countVotingDailyStatisticNew(form);
         return new Result();
     }
 }
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java
index 65d2d35904..a83bba6689 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java
@@ -19,8 +19,10 @@ package com.epmet.dao;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.dto.IssueVoteDetailDTO;
+import com.epmet.dto.PolyLineDTO;
 import com.epmet.dto.form.VoteFormDTO;
 import com.epmet.dto.form.VoteRedisFormDTO;
+import com.epmet.dto.result.DailyStatisticalVoteJobResultDTO;
 import com.epmet.dto.result.IssueAttitudeCountResultDTO;
 import com.epmet.dto.result.IssueVoteResultDTO;
 import com.epmet.dto.result.MyPartIssuesResultDTO;
@@ -130,4 +132,23 @@ public interface IssueVoteDetailDao extends BaseDao<IssueVoteDetailEntity> {
      * @date 2021/5/12 1:48 下午
      */
     List<IssueVoteResultDTO> selectIssueVoteCountBatch(@Param("issueIds")List<String> issueIds);
+
+    /**
+     * @Description  查询客户下的议题表决日增
+     * @param customerId
+     * @param dateId  当dateId为空时，查询的是累计值
+     * @author zxc
+     * @date 2021/12/29 2:02 下午
+     */
+    List<DailyStatisticalVoteJobResultDTO> statisticVote(@Param("customerId")String customerId,@Param("dateId")String dateId);
+
+    /**
+     * @Description  根据议题ID查询折线图一天的数据
+     * @param issueId
+     * @param dateId
+     * @author zxc
+     * @date 2021/12/29 4:19 下午
+     */
+    PolyLineDTO polyLineData(@Param("issueId")String issueId,@Param("dateId")String dateId);;
+
 }
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java
index 6b500ad3fd..ce47a20ff6 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java
@@ -78,4 +78,13 @@ public interface IssueVoteStatisticalDailyDao extends BaseDao<IssueVoteStatistic
      * @date 2020.05.20 14:54
      **/
     void updateBatch(@Param("list") List<IssueVoteStatisticalDailyEntity> list);
+
+    /**
+     * @Description  删除历史数据
+     * @param customerId
+     * @param dateId
+     * @author zxc
+     * @date 2021/12/29 2:51 下午
+     */
+    Integer delHistoryData(@Param("customerId")String customerId,@Param("dateId")String dateId);
 }
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/IssueVoteStatisticalDailyService.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/IssueVoteStatisticalDailyService.java
index cf94b37242..42d3beac71 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/IssueVoteStatisticalDailyService.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/IssueVoteStatisticalDailyService.java
@@ -20,6 +20,7 @@ package com.epmet.service;
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.dto.IssueVoteStatisticalDailyDTO;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 import com.epmet.entity.IssueVoteStatisticalDailyEntity;
 
 import java.util.List;
@@ -101,4 +102,12 @@ public interface IssueVoteStatisticalDailyService extends BaseService<IssueVoteS
      * @date 2020.05.19 09:23
     **/
     void countVotingDailyStatistic();
+
+    /**
+     * @Description  统计前一天所有有表决动作的议题
+     * @param
+     * @author zxc
+     * @date 2021/12/29 10:31 上午
+     */
+    void countVotingDailyStatisticNew(DailyStatisticalVoteJob form);
 }
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java
index 31e445c149..d42489fb48 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java
@@ -21,18 +21,27 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.exception.EpmetException;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.utils.DateUtils;
+import com.epmet.commons.tools.utils.Result;
 import com.epmet.dao.IssueVoteDetailDao;
 import com.epmet.dao.IssueVoteStatisticalDailyDao;
+import com.epmet.dto.CustomerDTO;
 import com.epmet.dto.IssueVoteStatisticalDailyDTO;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
+import com.epmet.dto.result.DailyStatisticalVoteJobResultDTO;
 import com.epmet.dto.result.IssuesToBeCountedResultDTO;
 import com.epmet.entity.IssueVoteStatisticalDailyEntity;
+import com.epmet.feign.OperCrmOpenFeignClient;
 import com.epmet.redis.IssueVoteStatisticalDailyRedis;
 import com.epmet.service.IssueVoteStatisticalDailyService;
 import com.epmet.utils.ModuleConstants;
 import oracle.sql.NUMBER;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -40,6 +49,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDate;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -58,6 +68,9 @@ public class IssueVoteStatisticalDailyServiceImpl extends BaseServiceImpl<IssueV
     @Autowired
     private IssueVoteDetailDao issueVoteDetailDao;
 
+    @Autowired
+    private OperCrmOpenFeignClient operCrmOpenFeignClient;
+
     protected static final Logger logger = LoggerFactory.getLogger(IssueVoteStatisticalDailyServiceImpl.class);
 
     @Override
@@ -303,4 +316,72 @@ public class IssueVoteStatisticalDailyServiceImpl extends BaseServiceImpl<IssueV
 
     }
 
+    /**
+     * @Description  统计前一天所有有表决动作的议题
+     * @param
+     * @author zxc
+     * @date 2021/12/29 10:31 上午
+     */
+    @Override
+    public void countVotingDailyStatisticNew(DailyStatisticalVoteJob form) {
+        // 先处理下纬度
+        List<String> customerIds = new ArrayList<>();
+        if (StringUtils.isBlank(form.getCustomerId())){
+            Result<List<CustomerDTO>> allCustomerList = operCrmOpenFeignClient.getAllCustomerList();
+            if (!allCustomerList.success() || CollectionUtils.isEmpty(allCustomerList.getData())){
+                throw new EpmetException("查询所有客户失败...");
+            }
+            customerIds = allCustomerList.getData().stream().map(m -> m.getId()).collect(Collectors.toList());
+        }else {
+            customerIds.add(form.getCustomerId());
+        }
+        if (StringUtils.isNotBlank(form.getStartDate()) && StringUtils.isNotBlank(form.getEndDate())){
+            List<String> daysBetween = DateUtils.getDaysBetween(form.getStartDate(), form.getEndDate());
+            customerIds.forEach(customerId -> {
+                daysBetween.forEach(dateId -> {
+                    statisticVote(customerId,dateId);
+                });
+            });
+        }else {
+            if (StringUtils.isBlank(form.getDateId())){
+                form.setDateId(LocalDate.now().minusDays(NumConstant.ONE).toString().replace("-", ""));
+            }
+            customerIds.forEach(customerId -> {
+                statisticVote(customerId, form.getDateId());
+            });
+        }
+    }
+
+    /**
+     * @Description  统计 issue_vote_statistical_daily 表
+     *               只统计表决日增存在的，不存在的不写入，查询程序补全
+     * @param customerId
+     * @param dateId 格式：YYYY-MM-DD
+     * @author zxc
+     * @date 2021/12/29 1:46 下午
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void statisticVote(String customerId,String dateId){
+        // 日增
+        List<DailyStatisticalVoteJobResultDTO> dayAdd = issueVoteDetailDao.statisticVote(customerId, dateId);
+        if (CollectionUtils.isNotEmpty(dayAdd)){
+            //累计
+            List<DailyStatisticalVoteJobResultDTO> allDayAdd = issueVoteDetailDao.statisticVote(customerId, null);
+            dayAdd.forEach(d -> allDayAdd.stream().filter(a -> a.getIssueId().equals(d.getIssueId())).forEach(a -> {
+                d.setOppositionCount(a.getOppositionCount());
+                d.setSupportCount(a.getSupportCount());
+                d.setTotalCount(a.getTotalCount());
+            }));
+            List<IssueVoteStatisticalDailyEntity> needInsert = ConvertUtils.sourceToTarget(dayAdd, IssueVoteStatisticalDailyEntity.class);
+            Integer delNum;
+            do {
+                delNum = baseDao.delHistoryData(customerId, dateId);
+            } while (delNum != null && delNum > NumConstant.ZERO);
+            List<List<IssueVoteStatisticalDailyEntity>> partition = ListUtils.partition(needInsert, NumConstant.ONE_HUNDRED);
+            partition.forEach(p -> {
+                baseDao.insertBatch(p);
+            });
+        }
+    }
+
 }
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java
index 4c90eb6981..36caece989 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java
@@ -27,6 +27,7 @@ import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constant.IssueConstant;
 import com.epmet.dao.IssueDao;
@@ -66,6 +67,9 @@ import java.time.ZoneOffset;
 import java.util.*;
 import java.util.stream.Collectors;
 
+import static com.epmet.commons.tools.utils.DateUtils.DATE_PATTERN;
+import static com.epmet.commons.tools.utils.DateUtils.DATE_PATTERN_YYYYMMDD;
+
 /**
  * 议题表决统计表
  *
@@ -205,12 +209,36 @@ public class IssueVoteStatisticalServiceImpl extends BaseServiceImpl<IssueVoteSt
         votingTrendResultDTO.setRealityVoteCount(voteRedisFormDTO.getSupportAmount() + voteRedisFormDTO.getOppositionAmount());
         //DB获取表决 日统计详情
         List<PolyLineDTO> polyLineDTOS = issueVoteStatisticalDao.polyLineData(issueId);
-        PolyLineDTO polyLineDTO = new PolyLineDTO();
-        polyLineDTO.setVoteDate(LocalDateTime.now().toEpochSecond(ZoneOffset.of(IssueConstant.BEIJING_TIME_ZONE)));
+//        PolyLineDTO polyLineDTO = new PolyLineDTO();
+//        polyLineDTO.setVoteDate(LocalDateTime.now().toEpochSecond(ZoneOffset.of(IssueConstant.BEIJING_TIME_ZONE)));
         //议题 已转项目 或 已结案 的时间
-        String date = issueDao.operateTime(issueId.getIssueId());
+//        String date = issueDao.operateTime(issueId.getIssueId());
+        IssueEntity issueEntity = issueDao.selectById(issueId.getIssueId());
+        String startDate = DateUtils.format(issueEntity.getDecidedTime(),DATE_PATTERN);
+        String endDate = null == issueEntity.getVotingDeadline() ?
+                DateUtils.format(new Date(),DATE_PATTERN) :
+                DateUtils.format(issueEntity.getVotingDeadline(),DATE_PATTERN);
+        List<PolyLineDTO> polyLine = getPolyLine(startDate, endDate);
+        if (CollectionUtils.isEmpty(polyLineDTOS)){
+            votingTrendResultDTO.setPolyLine(polyLine);
+            return votingTrendResultDTO;
+        }
+        polyLineDTOS.forEach(pd -> {
+            polyLine.forEach(p -> {
+                if (pd.getVoteDate().equals(p.getVoteDate())){
+                    p.setOppositionIncrement(pd.getOppositionIncrement());
+                    p.setSupportIncrement(pd.getSupportIncrement());
+                }
+            });
+        });
+        String today = LocalDate.now().toString();
+        if (today.equals(endDate)){
+            PolyLineDTO polyLineDTO = issueVoteDetailDao.polyLineData(issueId.getIssueId(), endDate);
+            polyLine.get(polyLine.size() - NumConstant.ONE).setSupportIncrement(polyLineDTO.getSupportIncrement());
+            polyLine.get(polyLine.size() - NumConstant.ONE).setOppositionIncrement(polyLineDTO.getOppositionIncrement());
+        }
         //今天刚转项目或刚刚关闭，当天数据DB没有，直接从缓存拿
-        if (polyLineDTOS.size() == NumConstant.ZERO && date.equals(LocalDate.now().toString())) {
+        /*if (polyLineDTOS.size() == NumConstant.ZERO && date.equals(LocalDate.now().toString())) {
             polyLineDTO.setSupportIncrement(voteRedisFormDTO.getSupportAmount());
             polyLineDTO.setOppositionIncrement(voteRedisFormDTO.getOppositionAmount());
             polyLineDTOS.add(polyLineDTO);
@@ -222,18 +250,37 @@ public class IssueVoteStatisticalServiceImpl extends BaseServiceImpl<IssueVoteSt
                 polyLineDTOS.add(polyLineDTO);
             }
             //从古至今一直在表决中
-            IssueEntity issueEntity = issueDao.selectById(issueId.getIssueId());
             if (issueEntity.getIssueStatus().equals(IssueConstant.ISSUE_VOTING)){
                 polyLineDTO.setSupportIncrement(voteRedisFormDTO.getSupportAmount());
                 polyLineDTO.setOppositionIncrement(voteRedisFormDTO.getOppositionAmount());
                 polyLineDTOS.add(polyLineDTO);
             }
-        }
+        }*/
         //今天之前 “已转项目”或“已关闭”
-        votingTrendResultDTO.setPolyLine(polyLineDTOS);
+
+        votingTrendResultDTO.setPolyLine(polyLine);
         return votingTrendResultDTO;
     }
 
+    public List<PolyLineDTO> getPolyLine(String startTime, String endTime){
+        List<PolyLineDTO> result = new ArrayList<>();
+        Date start = DateUtils.parse(startTime, DATE_PATTERN);
+        Date end = DateUtils.parse(endTime, DATE_PATTERN);
+        Calendar tempStart = Calendar.getInstance();
+        tempStart.setTime(start);
+        Calendar tempEnd = Calendar.getInstance();
+        tempEnd.setTime(end);
+        // 日期加1(包含结束)
+        tempEnd.add(Calendar.DATE, +1);
+        while (tempStart.before(tempEnd)) {
+            PolyLineDTO dto = new PolyLineDTO();
+            dto.setVoteDate(tempStart.getTimeInMillis()/1000);
+            result.add(dto);
+            tempStart.add(Calendar.DAY_OF_YEAR, 1);
+        }
+        return result;
+    }
+
     /**
      * @param formDTO
      * @Description 满意度评价列表——已关闭
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml
index 3b5b4be83a..d501921aa5 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml
@@ -181,4 +181,43 @@
               </foreach>
             )
     </select>
+
+    <!-- 查询客户下的议题表决日增 -->
+    <select id="statisticVote" resultType="com.epmet.dto.result.DailyStatisticalVoteJobResultDTO">
+        SELECT
+               vs.votable_count,
+               <if test="dateId == null">
+                   (t.oppositionCount + t.supportCount) AS totalCount,
+               </if>
+               <if test="dateId != null">
+                    (t.oppositionIncrement + t.supportIncrement) AS todayIncrement,
+               </if>
+               t.* FROM
+        (SELECT
+            vd.ISSUE_ID,
+            COUNT(CASE WHEN vd.ATTITUDE = 'opposition' THEN 1 END) AS oppositionCount,
+            COUNT(CASE WHEN vd.ATTITUDE = 'opposition' THEN 1 END) AS oppositionIncrement,
+            COUNT(CASE WHEN vd.ATTITUDE = 'support' THEN 1 END) AS supportCount,
+            COUNT(CASE WHEN vd.ATTITUDE = 'support' THEN 1 END) AS supportIncrement,
+            #{dateId} AS statisticalDate
+        FROM issue_vote_detail vd
+        WHERE vd.DEL_FLAG = '0'
+          AND vd.CUSTOMER_ID = #{customerId}
+          <if test="dateId != null">
+              AND DATE_FORMAT(vd.CREATED_TIME,'%Y-%m-%d') = #{dateId}
+          </if>
+        GROUP BY vd.ISSUE_ID)t
+        INNER JOIN issue_vote_statistical vs ON (vs.ISSUE_ID = t.ISSUE_ID AND vs.DEL_FLAG = '0')
+    </select>
+
+    <!-- 根据议题ID查询折线图一天的数据 -->
+    <select id="polyLineData" resultType="com.epmet.dto.PolyLineDTO">
+        SELECT
+            COUNT(CASE WHEN vd.ATTITUDE = 'opposition' THEN 1 END) AS oppositionIncrement,
+            COUNT(CASE WHEN vd.ATTITUDE = 'support' THEN 1 END) AS supportIncrement
+        FROM issue_vote_detail vd
+        WHERE vd.DEL_FLAG = '0'
+          AND DATE_FORMAT(vd.CREATED_TIME,'%Y-%m-%d') = #{dateId}
+          AND ISSUE_ID = #{issueId}
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml
index dcad30689c..bcbe6a5a4d 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml
@@ -280,4 +280,13 @@
                 id = #{item.id}
             </foreach>
     </update>
+
+    <!-- 删除历史数据 -->
+    <delete id="delHistoryData">
+        DELETE FROM issue_vote_statistical_daily
+        WHERE CUSTOMER_ID = #{customerId}
+          AND STATISTICAL_DATE = #{dateId}
+        LIMIT 1000
+    </delete>
+
 </mapper>
\ No newline at end of file