From 806fff37959ded1d6d72ef1e8fa55144c8972146 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Sat, 23 May 2020 14:33:00 +0800
Subject: [PATCH 1/6] =?UTF-8?q?=E8=BF=9B=E5=85=A5=E7=BD=91=E6=A0=BC?=
 =?UTF-8?q?=E6=97=B6=E6=9F=A5=E8=AF=A2=E5=BD=93=E5=89=8D=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E7=9A=84=E8=BA=AB=E4=BB=BD=EF=BC=8C=E7=83=AD=E5=BF=83=E5=B1=85?=
 =?UTF-8?q?=E6=B0=91=E6=98=AF=E7=BD=91=E6=A0=BC=E7=BA=A7=E5=88=AB=E7=9A=84?=
 =?UTF-8?q?=EF=BC=8C=E5=85=9A=E5=91=98=E4=B8=8E=E8=AE=A4=E8=AF=81=E5=B1=85?=
 =?UTF-8?q?=E6=B0=91=E6=98=AF=E6=97=A0=E7=BA=A7=E5=88=AB=E7=9A=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/feign/ResiGroupFeignClient.java |  2 +-
 .../epmet/service/impl/UserServiceImpl.java   |  2 --
 .../src/main/resources/mapper/UserRoleDao.xml | 36 +++++--------------
 3 files changed, 10 insertions(+), 30 deletions(-)

diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/feign/ResiGroupFeignClient.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/feign/ResiGroupFeignClient.java
index d42dd3804f..e58bb4eb81 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/feign/ResiGroupFeignClient.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/feign/ResiGroupFeignClient.java
@@ -25,7 +25,7 @@ import java.util.List;
  * @Author sun
  * , url = "localhost:8095"
  */
-@FeignClient(name = ServiceConstant.RESI_GROUP_SERVER, fallback = ResiGroupFeignClientFallBack.class, url = "http://localhost:8095")
+@FeignClient(name = ServiceConstant.RESI_GROUP_SERVER, fallback = ResiGroupFeignClientFallBack.class)
 public interface ResiGroupFeignClient {
 
     /**
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java
index c6da2a677e..c23afa09a6 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java
@@ -168,8 +168,6 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
             userRoleFormDTO.setCustomerId(myResiUserInfoFormDTO.getCustomerId());
             userRoleFormDTO.setGridId(myResiUserInfoFormDTO.getGridId());
             result.setRoleList(userRoleDao.getUserRoleList(userRoleFormDTO));
-            userRoleDao.getUserRoleList(userRoleFormDTO);
-            userRoleDao.getUserRoleList(userRoleFormDTO);
             return result;
         }
 
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/UserRoleDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/UserRoleDao.xml
index c8392d4c32..815198bed5 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/UserRoleDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/UserRoleDao.xml
@@ -17,6 +17,7 @@
         <result property="updatedTime" column="UPDATED_TIME"/>
     </resultMap>
 
+    <!-- 如果没有传gridId只查用户的非网格级别的身份 -->
     <select id="getUserRoleInfo" parameterType="com.epmet.dto.form.UserRoleFormDTO"
             resultType="com.epmet.dto.result.UserRoleResultDTO">
 
@@ -33,33 +34,24 @@
             ur.DEL_FLAG = 0
             AND
             ur.USER_ID = #{userId}
-            <if test='null != app and "" != app'>
-                AND
-                er.APP = #{app}
-            </if>
-            <if test='null != customerId and "" != customerId'>
-                AND
-                ur.CUSTOMER_ID = #{customerId}
-            </if>
             <if test='null != gridId and "" != gridId'>
-                AND
-                ( ur.GRID_ID = #{gridId} OR ur.GRID_ID = 'all' )
+                AND( ur.GRID_ID = #{gridId} OR ur.GRID_ID = 'all' )
             </if>
-            <if test='null == gridId or "" == gridId'>
-                AND
-                ur.GRID_ID = 'all'
+            <if test='gridId == null or gridId = ""'>
+                AND ur.GRID_ID = 'all'
             </if>
         </where>
 
     </select>
 
+    <!-- 如果没有传gridId只查用户的非网格级别的身份 -->
     <select id="getUserRoleList" parameterType="com.epmet.dto.form.UserRoleFormDTO"
             resultType="string">
 
         SELECT
         DISTINCT
 
-        er.ROLE_KEY
+        er.ROLE_NAME
         FROM
         USER_ROLE ur
         JOIN EPMET_ROLE er ON ur.ROLE_ID = er.ID
@@ -69,21 +61,11 @@
             ur.DEL_FLAG = 0
             AND
             ur.USER_ID = #{userId}
-            <if test='null != app and "" != app'>
-                AND
-                er.APP = #{app}
-            </if>
-            <if test='null != customerId and "" != customerId'>
-                AND
-                ur.CUSTOMER_ID = #{customerId}
-            </if>
             <if test='null != gridId and "" != gridId'>
-                AND
-                ( ur.GRID_ID = #{gridId} OR ur.GRID_ID = 'all' )
+                AND( ur.GRID_ID = #{gridId} OR ur.GRID_ID = 'all' )
             </if>
-            <if test='null == gridId or "" == gridId'>
-                AND
-                ur.GRID_ID = 'all'
+            <if test='gridId == null or gridId = ""'>
+                AND ur.GRID_ID = 'all'
             </if>
         </where>
 

From be78c58310ba6a8486c67524935bd9dc0d12805e Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Sun, 24 May 2020 00:21:06 +0800
Subject: [PATCH 2/6] =?UTF-8?q?=E7=BE=A4=E7=BB=84=E7=BB=9F=E8=AE=A1?=
 =?UTF-8?q?=E8=A1=A8=E5=AD=97=E6=AE=B5=E5=A2=9E=E5=8A=A0=E9=BB=98=E8=AE=A4?=
 =?UTF-8?q?=E5=80=BC=EF=BC=8C=E6=96=B0=E5=A2=9E=E8=AE=AE=E9=A2=98=E6=97=B6?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E7=BC=93=E5=AD=98=EF=BC=8C=E5=8F=97=E9=82=80?=
 =?UTF-8?q?=E5=85=A5=E7=BE=A4=E6=97=B6=E6=9B=B4=E6=96=B0=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../group/dao/ResiGroupStatisticalDao.java    |  9 ++++++++
 .../modules/group/redis/ResiGroupRedis.java   |  5 ++++-
 .../impl/GroupInvitationServiceImpl.java      | 21 +++++++++++++++++++
 .../member/redis/ResiGroupMemberRedis.java    |  2 +-
 .../service/impl/ResiTopicServiceImpl.java    | 11 +++++++++-
 .../src/main/resources/db/migration/db.sql    | 10 +++++++++
 .../mapper/group/ResiGroupStatisticalDao.xml  |  9 ++++++++
 7 files changed, 64 insertions(+), 3 deletions(-)

diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/dao/ResiGroupStatisticalDao.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/dao/ResiGroupStatisticalDao.java
index f323ce4168..589cfaeb27 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/dao/ResiGroupStatisticalDao.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/dao/ResiGroupStatisticalDao.java
@@ -38,4 +38,13 @@ public interface ResiGroupStatisticalDao extends BaseDao<ResiGroupStatisticalEnt
      * @author sun
      */
     ResiGroupStatisticalEntity selectByResiGroupId(@Param("resiGroupId") String resiGroupId);
+
+    /**
+     * @Description 总议题数+1
+     * @param groupId
+     * @return
+     * @author wangc
+     * @date 2020.05.24 00:03
+    **/
+    void incryTotalIssues(@Param("groupId") String groupId);
 }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/redis/ResiGroupRedis.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/redis/ResiGroupRedis.java
index 10b581ca2e..f5d0541ba8 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/redis/ResiGroupRedis.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/redis/ResiGroupRedis.java
@@ -84,7 +84,7 @@ public class ResiGroupRedis {
         if(StringUtils.isNotBlank(groupId)){
             ResiGroupInfoRedisDTO groupCache = (ResiGroupInfoRedisDTO)
             redisUtils.get(ResiGroupRedisKeys.getResiGroupInfoKey(groupId));
-            if(null == groupCache || StringUtils.isBlank(groupCache.getGroupId())){
+            if(null == groupCache || StringUtils.isBlank(groupCache.getGroupId()) || null == groupCache.getGroupStatisticalInfo()){
                 //如果缓存中没有该组信息，从数据库中查询并放入缓存
                 ResiGroupDTO groupMySql = groupService.get(groupId);
                 if(null != groupMySql && StringUtils.isNotBlank(groupMySql.getId())){
@@ -134,6 +134,9 @@ public class ResiGroupRedis {
                         statisticalRedis.setTotalEarnestMembers(statistical.getTotalEarnestMemebers());
                         statisticalRedis.setTotalNormalMembers(statistical.getTotalNormalMemebers());
                         groupRedis.setGroupStatisticalInfo(statisticalRedis);
+                    }else{
+                        //数据库中没有该组的统计数据
+                        logger.warn(String.format("数据库中没有组统计信息，组Id:【%s】",groupId));
                     }
                     //将从数据库中查询出的数据放入缓存
                     set(groupRedis);
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java
index c9650ec3e5..610dfe3edb 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java
@@ -40,6 +40,7 @@ import com.epmet.modules.feign.EpmetUserFeignClient;
 import com.epmet.modules.feign.ResiGuideFeignClient;
 import com.epmet.modules.group.dao.ResiGroupDao;
 import com.epmet.modules.group.entity.ResiGroupEntity;
+import com.epmet.modules.group.redis.ResiGroupRedis;
 import com.epmet.modules.group.service.ResiGroupService;
 import com.epmet.modules.invitation.dao.GroupInvitationDao;
 import com.epmet.modules.invitation.entity.GroupInvitationEntity;
@@ -54,6 +55,7 @@ import com.epmet.resi.group.constant.LeaderFlagConstant;
 import com.epmet.resi.group.constant.MemberStateConstant;
 import com.epmet.resi.group.dto.UserRoleDTO;
 import com.epmet.resi.group.dto.group.ResiGroupDTO;
+import com.epmet.resi.group.dto.group.ResiGroupInfoRedisDTO;
 import com.epmet.resi.group.dto.invitation.GroupInvitationDTO;
 import com.epmet.resi.group.dto.invitation.form.AccetInvitationFormDTO;
 import com.epmet.resi.group.dto.invitation.form.CreateGroupInvitationFormDTO;
@@ -102,6 +104,8 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
 	private EpmetUserFeignClient epmetUserFeignClient;
 	@Autowired
 	private ResiGuideFeignClient resiGuideFeignClient;
+	@Autowired
+	private ResiGroupRedis resiGroupRedis;
 
 	@Override
 	public PageData<GroupInvitationDTO> page(Map<String, Object> params) {
@@ -366,6 +370,23 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
 		resiGroupMemberService.saveOrUpdate(resiGroupMemberDTO);
 		//5、修改群统计值
 		resiGroupMemberDao.updateResiGroupStatistical(groupMemeberOperation.getGroupId(), userRoleDTO);
+		ResiGroupInfoRedisDTO groupCache =
+		resiGroupRedis.get(groupInvitationDTO.getResiGroupId());
+		if(null != groupCache && null != groupCache.getGroupStatisticalInfo()){
+			groupCache.getGroupStatisticalInfo().setTotalMembers(
+					null == groupCache.getGroupStatisticalInfo().getTotalMembers() ? NumConstant.TWO : groupCache.getGroupStatisticalInfo().getTotalMembers() +NumConstant.ONE
+			);
+			if(StringUtils.equals(userRoleDTO.getPartymemberFlag(),NumConstant.ONE_STR)) groupCache.getGroupStatisticalInfo().setTotalPartyMembers(
+					null == groupCache.getGroupStatisticalInfo().getTotalPartyMembers() ? NumConstant.ONE : groupCache.getGroupStatisticalInfo().getTotalPartyMembers()+NumConstant.ONE
+			);
+			if(StringUtils.equals(userRoleDTO.getRegisteredResiFlag(),NumConstant.ONE_STR)) groupCache.getGroupStatisticalInfo().setTotalNormalMembers(
+					null == groupCache.getGroupStatisticalInfo().getTotalNormalMembers() ? NumConstant.TWO : groupCache.getGroupStatisticalInfo().getTotalNormalMembers()+NumConstant.ONE
+			);
+			if(StringUtils.equals(userRoleDTO.getWarmHeartedFlag(),NumConstant.ONE_STR)) groupCache.getGroupStatisticalInfo().setTotalEarnestMembers(
+					null == groupCache.getGroupStatisticalInfo().getTotalEarnestMembers() ? NumConstant.ONE : groupCache.getGroupStatisticalInfo().getTotalEarnestMembers()+NumConstant.ONE
+			);
+			resiGroupRedis.set(groupCache);
+		}
 		//6、发送消息
 		this.sendMessageToLeader(formDTO, resiGroupDTO,groupInvitationDTO);
 	}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/redis/ResiGroupMemberRedis.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/redis/ResiGroupMemberRedis.java
index 2e53b4bf6f..d635bd1dea 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/redis/ResiGroupMemberRedis.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/redis/ResiGroupMemberRedis.java
@@ -140,7 +140,7 @@ public class ResiGroupMemberRedis {
                         .concat(userId));
             }
         }
-
+        memberCache.setGroupId(groupId);
         return memberCache;
 
     }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
index 0eec7530f8..ebcabd61cb 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
@@ -132,6 +132,7 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
     @Autowired
     private GovIssueFeignClient govIssueFeignClient;
 
+
     private final Log logger = LogFactory.getLog(getClass());
 
     @Override
@@ -1068,7 +1069,15 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                         if(operationResult != NumConstant.ONE){
                             logger.warn(ModuleConstant.FAILURE_TO_ADD_TOPIC_OPERATION);
                         }
-                        return;
+                    }
+                    //7.更新组统计信息 议题数量+1
+                    resiGroupStatisticalDao.incryTotalIssues(group.getGroupId());
+                    if(null != groupCache && null != groupCache.getGroupStatisticalInfo()){
+                        groupCache.getGroupStatisticalInfo().setTotalIssues(
+                                null == groupCache.getGroupStatisticalInfo().getTotalIssues() ? NumConstant.ONE
+                                        : groupCache.getGroupStatisticalInfo().getTotalIssues() + NumConstant.ONE
+                        );
+                        resiGroupRedis.set(groupCache);
                     }
                     logger.warn(ModuleConstant.FAILURE_TO_UPDATE_TOPIC);
 
diff --git a/epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/db.sql b/epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/db.sql
index a966031574..25f29ef107 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/db.sql
+++ b/epmet-module/resi-group/resi-group-server/src/main/resources/db/migration/db.sql
@@ -30,4 +30,14 @@ ALTER TABLE RESI_TOPIC ADD (
   ISSUE_ID VARCHAR (64) DEFAULT NULL COMMENT '议题ID，可为空'
   );
 
+-- @Date       2020-05-23 23:56
+-- @Author     wangc
+-- @Description 数据库epmet_resi_group中的resi_group_statistica(组统计表)字段增加默认值
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_TOPICS` `TOTAL_TOPICS` INT(255) NULL DEFAULT '0' COMMENT '话题总数';
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_MEMBERS` `TOTAL_MEMBERS` INT(255) NOT NULL DEFAULT '1' COMMENT '成员总数';
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_NORMAL_MEMEBERS` `TOTAL_NORMAL_MEMEBERS` INT(11) NULL DEFAULT '1' COMMENT '普通居民总数=群人数';
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_EARNEST_MEMEBERS` `TOTAL_EARNEST_MEMEBERS` INT(255) NULL DEFAULT '0' COMMENT '热心居民总数';
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_PARTY_MEMBERS` `TOTAL_PARTY_MEMBERS` INT(255) NULL DEFAULT '0' COMMENT '党员总数';
+ALTER TABLE `resi_group_statistical` CHANGE `TOTAL_ISSUES` `TOTAL_ISSUES` INT(255) NULL DEFAULT '0' COMMENT '已转议题总数';
+
 
diff --git a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/group/ResiGroupStatisticalDao.xml b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/group/ResiGroupStatisticalDao.xml
index 82b67e2a34..995c637bb1 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/group/ResiGroupStatisticalDao.xml
+++ b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/group/ResiGroupStatisticalDao.xml
@@ -28,4 +28,13 @@
         AND rgs.resi_group_id = #{resiGroupId}
     </select>
 
+    <!-- 总议题数+1 -->
+    <update id="incryTotalIssues" parameterType="string">
+        UPDATE resi_group_statistical
+        SET TOTAL_ISSUES = TOTAL_ISSUES + 1
+        WHERE
+        RESI_GROUP_ID = #{groupId}
+        AND DEL_FLAG = '0'
+    </update>
+
 </mapper>

From a7a3572caf5610b099aba54bf8428ddbbcc64fc1 Mon Sep 17 00:00:00 2001
From: sunyuchao <syc_ls@163.com>
Date: Mon, 25 May 2020 09:40:21 +0800
Subject: [PATCH 3/6] =?UTF-8?q?=E5=85=9A=E5=BB=BA=E5=9B=AD=E5=9C=B0-?=
 =?UTF-8?q?=E6=9C=80=E6=96=B0=E8=AE=AE=E9=A2=98=E3=80=81=E7=BB=93=E6=A1=88?=
 =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E4=B8=9A=E5=8A=A1=E8=B0=83=E6=95=B4=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3=E5=8F=98=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dto/result/LatestIssueListResultDTO.java  | 17 +++++----
 .../src/main/java/com/epmet/dao/IssueDao.java |  4 ---
 .../epmet/dao/IssueVoteStatisticalDao.java    |  7 ----
 .../epmet/service/impl/IssueServiceImpl.java  | 36 ++++++++-----------
 .../mapper/IssueVoteStatisticalDao.xml        | 11 ------
 .../epmet/dto/result/LatestListResultDTO.java |  8 ++---
 .../com/epmet/constant/ProjectConstant.java   |  4 +--
 .../com/epmet/feign/EpmetUserFeignClient.java | 11 ------
 .../EpmetUserFeignClientFallBack.java         |  5 ---
 .../service/impl/ProjectServiceImpl.java      | 24 ++-----------
 .../src/main/resources/mapper/ProjectDao.xml  |  3 +-
 .../controller/CustomerStaffController.java   | 18 ----------
 .../epmet/service/CustomerStaffService.java   | 16 +--------
 .../impl/CustomerStaffServiceImpl.java        | 27 --------------
 14 files changed, 37 insertions(+), 154 deletions(-)

diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/LatestIssueListResultDTO.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/LatestIssueListResultDTO.java
index 1c4fe33e19..13826f91e2 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/LatestIssueListResultDTO.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/LatestIssueListResultDTO.java
@@ -21,16 +21,21 @@ public class LatestIssueListResultDTO implements Serializable {
      * 议题标题
      */
     private String issueTitle = "";
-    /**
-     * 议题发起人：XX路-XX先生
-     */
-    private String issuePublisherName = "";
     /**
      * 话题内容
      */
     private String topicContent = "";
     /**
-     * 表达态度总人数
+     * 用户头像
+     */
+    private String staffHeadPhoto = "";
+    /**
+     * 议题发起人：XX路-XX先生/女士
+     *
+     */
+    private String issuePublisherName = "";
+    /**
+     * 议题创建时间
      */
-    private Integer votedCount = 0;
+    private Long createIssueTime;
 }
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueDao.java
index 8fc76e1b85..377c731120 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueDao.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueDao.java
@@ -20,10 +20,6 @@ package com.epmet.dao;
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.dto.IssueDTO;
 import com.epmet.dto.form.*;
-import com.epmet.dto.result.ClosedIssueListGovResultDTO;
-import com.epmet.dto.result.ClosedIssueListResultDTO;
-import com.epmet.dto.result.IssueResultDTO;
-import com.epmet.dto.result.VotingIssueListResultDTO;
 import com.epmet.dto.result.*;
 import com.epmet.entity.IssueEntity;
 import org.apache.ibatis.annotations.Mapper;
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDao.java
index 949d0c14fa..134ec32bb1 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDao.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDao.java
@@ -68,13 +68,6 @@ public interface IssueVoteStatisticalDao extends BaseDao<IssueVoteStatisticalEnt
      */
     List<PolyLineDTO> polyLineData(IssueIdFormDTO issueId);
 
-    /**
-     * @param issueIdList
-     * @return
-     * @Author sun
-     * @Description 根据议题Id查询议题投票情况
-     **/
-    List<IssueVoteStatisticalEntity> selectListByissueId(@Param("issueIdList") List<String> issueIdList);
     /**
      * @Description 得到表决中的议题 来进行缓存与数据库的同步
      * @param
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
index 632017e990..b310d78e48 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
@@ -605,22 +605,24 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
         }
         //1:根据已结案项目列表查询议题项目关系表数据
         List<IssueProjectRelationEntity> listRelation = issueProjectRelationDao.selectRelationList(projectIdList);
-        if(null==listRelation||listRelation.size()<NumConstant.ONE){
+        if (null == listRelation || listRelation.size() < NumConstant.ONE) {
             throw new RenException(IssueConstant.SELECT_ISSUEPROJECTRELATION_EXCEPTION);
         }
         List<String> issueIdList = listRelation.stream().map(IssueProjectRelationEntity::getIssueId).collect(Collectors.toList());
 
         //2:根据查询条件筛选出客户网格下已结案项目对应的议题详情列表
         LatestListFormDTO latestListForm = formDTO.getLatestListForm();
-        latestListForm.setPageNo((latestListForm.getPageNo()-NumConstant.ONE)*latestListForm.getPageSize());
+        latestListForm.setPageNo((latestListForm.getPageNo() - NumConstant.ONE) * latestListForm.getPageSize());
         List<IssueEntity> entityList = baseDao.selectIssueList(issueIdList, latestListForm);
-
+        if (null == entityList || entityList.size() < NumConstant.ONE) {
+            throw new RenException(IssueConstant.SELECT_EXCEPTION);
+        }
         //3:遍历封装数据
-        entityList.forEach(issue->{
-            listRelation.forEach(relation->{
-                if(relation.getIssueId().equals(issue.getId())){
-                    formDTO.getLatestListResult().forEach(project->{
-                        if(relation.getProjectId().equals(project.getProjectId())){
+        entityList.forEach(issue -> {
+            listRelation.forEach(relation -> {
+                if (relation.getIssueId().equals(issue.getId())) {
+                    formDTO.getLatestListResult().forEach(project -> {
+                        if (relation.getProjectId().equals(project.getProjectId())) {
                             LatestListResultDTO latest = ConvertUtils.sourceToTarget(project, LatestListResultDTO.class);
                             latest.setIssueId(issue.getId());
                             latest.setIssueTitle(issue.getIssueTitle());
@@ -649,11 +651,7 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
             return returnList;
         }
 
-        //2:根据议题Id查询议题投票情况
-        List<String> issueIdList = entityList.stream().map(IssueEntity::getId).collect(Collectors.toList());
-        List<IssueVoteStatisticalEntity> StatisticalList = issueVoteStatisticalDao.selectListByissueId(issueIdList);
-
-        //3:调用epmet-user服务，查询议题发起人基本信息
+        //2:调用epmet-user服务，查询议题发起人基本信息
         List<String> userIdList = entityList.stream().map(IssueEntity::getCreatedBy).collect(Collectors.toList());
         UserResiInfoListFormDTO userResiInfoListFormDTO = new UserResiInfoListFormDTO();
         userResiInfoListFormDTO.setUserIdList(userIdList);
@@ -663,7 +661,7 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
         }
         List<UserResiInfoResultDTO> userInfoList = listResult.getData();
 
-        //4:调用resi-group服务，批量查询话题内容
+        //3:调用resi-group服务，批量查询话题内容
         List<String> topicIdList = entityList.stream().map(IssueEntity::getSourceId).collect(Collectors.toList());
         Result<List<ResiTopicDTO>> resultTopicList = resiGroupFeignClient.getTopicList(topicIdList);
         if (!resultTopicList.success() || null == resultTopicList.getData()) {
@@ -671,19 +669,15 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
         }
         List<ResiTopicDTO> topicList = resultTopicList.getData();
 
-        //5:遍历组装对象
+        //4:遍历组装对象
         entityList.forEach(issue -> {
             LatestIssueListResultDTO resultDTO = new LatestIssueListResultDTO();
             resultDTO.setIssueId(issue.getId());
             resultDTO.setIssueTitle(issue.getIssueTitle());
-            StatisticalList.forEach(sta -> {
-                if (issue.getId().equals(sta.getIssueId())) {
-                    //表达态度总人数
-                    resultDTO.setVotedCount(sta.getSupportCount() + sta.getOppositionCount());
-                }
-            });
+            resultDTO.setCreateIssueTime(issue.getCreatedTime().getTime()/1000);
             userInfoList.forEach(user -> {
                 if (issue.getCreatedBy().equals(user.getUserId())) {
+                    resultDTO.setStaffHeadPhoto(user.getHeadPhoto());
                     //话题发起人昵称
                     resultDTO.setIssuePublisherName(user.getShowName());
                 }
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDao.xml
index 5d48526dfd..ac039d7cd0 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDao.xml
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDao.xml
@@ -69,17 +69,6 @@
             ORDER BY statistical_date ASC
     </select>
 
-    <select id="selectListByissueId" resultType="com.epmet.entity.IssueVoteStatisticalEntity">
-        SELECT
-            *
-        FROM
-            issue_vote_statistical
-        WHERE del_flag = '0'
-        <foreach item="issueId" collection="issueIdList" separator="OR" open="AND (" close=")" index="">
-            issue_id = #{issueId}
-        </foreach>
-    </select>
-
     <!-- 得到表决中的议题 来进行缓存与数据库的同步 -->
     <select id="getVotingIssuesStatisticalForSync" resultType="com.epmet.dto.IssueVoteStatisticalDTO" >
         SELECT
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/LatestListResultDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/LatestListResultDTO.java
index c649df3498..ceae957676 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/LatestListResultDTO.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/LatestListResultDTO.java
@@ -31,12 +31,12 @@ public class LatestListResultDTO implements Serializable {
 	 */
 	private String publicReply = "";
 	/**
-	 * 结案人名称、实名显示
+	 * 结案的处理部门
 	 */
-	private String closeUserName = "";
+	private String departmentName = "";
 	/**
-	 * 结案人Id
+	 * 项目结案时间
 	 */
-	private String closeUserId = "";
+	private Long closeProjectTime;
 
 }
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
index cd3369e41e..a2d77e8446 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/constant/ProjectConstant.java
@@ -110,7 +110,7 @@ public interface ProjectConstant {
 	 */
 	String GOV = "gov";
 	/**
-	 * 调用epmet-user服务获取工作人员信息失败
+	 * 获取项目节点数据失败
 	 */
-	String SELECT_STAFF_EXCEPTION = "获取工作人员信息失败";
+	String SELECT_process_EXCEPTION = "获取项目节点数据失败";
 }
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
index c9d448b532..60509eb2ae 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/EpmetUserFeignClient.java
@@ -5,13 +5,10 @@ import com.epmet.commons.tools.utils.Result;
 import com.epmet.dto.CustomerStaffDTO;
 import com.epmet.dto.form.StaffsInAgencyFromDTO;
 import com.epmet.dto.form.UserResiInfoListFormDTO;
-import com.epmet.dto.result.CustomerStaffListResultDTO;
 import com.epmet.dto.result.StaffInfoResultDTO;
-import com.epmet.dto.result.StaffListResultDTO;
 import com.epmet.dto.result.UserResiInfoResultDTO;
 import com.epmet.feign.fallback.EpmetUserFeignClientFallBack;
 import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 
@@ -52,12 +49,4 @@ public interface EpmetUserFeignClient {
     @PostMapping(value = "epmetuser/customerstaff/getstaffinfobyuserid")
     Result<CustomerStaffDTO> getCustomerStaffInfoByUserId(@RequestBody CustomerStaffDTO formDTO);
 
-    /**
-     * @param staffIdList
-     * @return
-     * @Author sun
-     * @Description 批量查询工作人员基础信息
-     **/
-    @PostMapping(value = "epmetuser/customerstaff/getstafflistbyids", consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
-    Result<List<StaffListResultDTO>> getStaffListByIds(@RequestBody List<String> staffIdList);
 }
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/EpmetUserFeignClientFallBack.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/EpmetUserFeignClientFallBack.java
index 83b8781780..0e36af3db9 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/EpmetUserFeignClientFallBack.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/feign/fallback/EpmetUserFeignClientFallBack.java
@@ -7,7 +7,6 @@ import com.epmet.dto.CustomerStaffDTO;
 import com.epmet.dto.form.StaffsInAgencyFromDTO;
 import com.epmet.dto.form.UserResiInfoListFormDTO;
 import com.epmet.dto.result.StaffInfoResultDTO;
-import com.epmet.dto.result.StaffListResultDTO;
 import com.epmet.dto.result.UserResiInfoResultDTO;
 import com.epmet.feign.EpmetUserFeignClient;
 import org.springframework.stereotype.Component;
@@ -36,8 +35,4 @@ public class EpmetUserFeignClientFallBack implements EpmetUserFeignClient {
         return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "CustomerStaffDTO", formDTO);
     }
 
-    @Override
-    public Result<List<StaffListResultDTO>> getStaffListByIds(List<String> staffIdList) {
-        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getStaffListByIds", staffIdList);
-    }
 }
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
index 7d0ab4a6a0..2b55312a72 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
@@ -574,32 +574,12 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 	 * @param formDTO
 	 * @return
 	 * @Author sun
-	 * @Description 获取客户下已结案项目列表，按结案时间倒序
+	 * @Description 获取客户下已结案项目列表，按结案时间倒序(结案时间、结案说明、处理部门)
 	 **/
 	@Override
 	public List<LatestListResultDTO> getClosedProjectList(LatestListFormDTO formDTO) {
-		List<LatestListResultDTO> resultList = new ArrayList<>();
-		//1:查询客户下已结案项目列表
-		List<LatestListResultDTO> listProject = baseDao.selectClosedProjectList(formDTO);
-		if(null==listProject||listProject.size()<NumConstant.ONE){
-			return resultList;
-		}
-		List<String> staffIdList = listProject.stream().map(LatestListResultDTO::getCloseUserId).collect(Collectors.toList());
-		//2:调用epmet-user服务，查询结案人员真实姓名
-		Result<List<StaffListResultDTO>> listResult = epmetUserFeignClient.getStaffListByIds(staffIdList);
-		if (!listResult.success() || null == listResult.getData()) {
-			throw new RenException(ProjectConstant.SELECT_STAFF_EXCEPTION);
-		}
-		List<StaffListResultDTO> staffList = listResult.getData();
-		resultList = listProject.stream().flatMap(project ->
-				staffList.stream().filter(staff ->
-						project.getCloseUserId().equals(staff.getStaffId())).map(latest -> {
-					LatestListResultDTO resultDTO = ConvertUtils.sourceToTarget(project, LatestListResultDTO.class);
-					resultDTO.setCloseUserName(latest.getStaffName());
-					return resultDTO;
-				})).collect(Collectors.toList());
 
-		return resultList;
+		return baseDao.selectClosedProjectList(formDTO);
 	}
 
 }
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml b/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
index 8341e62e49..0dad21111b 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
+++ b/epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml
@@ -153,7 +153,8 @@
         SELECT
             p.id AS "projectId",
             pro.public_reply AS "publicReply",
-            pro.created_by AS "closeUserId"
+            pro.department_name AS "departmentName",
+            UNIX_TIMESTAMP(pro.created_time) AS "closeProjectTime"
         FROM project p
         INNER JOIN project_process pro ON p.id = pro.project_id
         WHERE p.del_flag = '0'
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/CustomerStaffController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/CustomerStaffController.java
index 547d18ca46..f77e5deb4d 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/CustomerStaffController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/CustomerStaffController.java
@@ -27,15 +27,7 @@ import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.commons.tools.validator.group.UpdateGroup;
 import com.epmet.dto.*;
 import com.epmet.dto.form.*;
-import com.epmet.dto.CustomerStaffDTO;
-import com.epmet.dto.CustomerStaffGridDTO;
-import com.epmet.dto.StaffGridListDTO;
-import com.epmet.dto.form.*;
 import com.epmet.dto.result.*;
-import com.epmet.dto.CustomerStaffDTO;
-import com.epmet.dto.CustomerStaffGridDTO;
-import com.epmet.dto.StaffGridListDTO;
-import com.epmet.dto.form.CustomerStaffFormDTO;
 import com.epmet.excel.CustomerStaffExcel;
 import com.epmet.service.CustomerStaffService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -281,14 +273,4 @@ public class CustomerStaffController {
         return new Result<CustomerStaffListResultDTO>().ok(customerStaffService.getCustomerStaffList(staffIdList));
     }
 
-    /**
-     * @param staffIdList
-     * @return
-     * @Author sun
-     * @Description 批量查询工作人员基础信息
-     **/
-    @PostMapping(value = "getstafflistbyids")
-    public Result<List<StaffListResultDTO>> getStaffListByIds(@RequestBody List<String> staffIdList){
-        return new Result<List<StaffListResultDTO>>().ok(customerStaffService.getStaffListByIds(staffIdList));
-    }
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/CustomerStaffService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/CustomerStaffService.java
index ec3a7ea554..4f4908cf32 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/CustomerStaffService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/CustomerStaffService.java
@@ -21,14 +21,7 @@ import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dto.*;
-import com.epmet.dto.CustomerStaffDTO;
-import com.epmet.dto.StaffGridListDTO;
-import com.epmet.dto.form.CommonUserIdListFormDTO;
-import com.epmet.dto.form.CustomerStaffFormDTO;
-import com.epmet.dto.form.StaffInfoFromDTO;
-import com.epmet.dto.form.StaffSubmitFromDTO;
-import com.epmet.dto.form.DepartmentInStaffFormDTO;
-import com.epmet.dto.form.StaffsInAgencyFromDTO;
+import com.epmet.dto.form.*;
 import com.epmet.dto.result.*;
 import com.epmet.entity.CustomerStaffEntity;
 
@@ -232,11 +225,4 @@ public interface CustomerStaffService extends BaseService<CustomerStaffEntity> {
 	 **/
 	CustomerStaffListResultDTO getCustomerStaffList(List<String> staffIdList);
 
-	/**
-	 * @param staffIdList
-	 * @return
-	 * @Author sun
-	 * @Description 批量查询工作人员基础信息
-	 **/
-	List<StaffListResultDTO> getStaffListByIds(List<String> staffIdList);
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/CustomerStaffServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/CustomerStaffServiceImpl.java
index c46254d83f..ba47befa3f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/CustomerStaffServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/CustomerStaffServiceImpl.java
@@ -35,22 +35,6 @@ import com.epmet.dao.StaffRoleDao;
 import com.epmet.dto.*;
 import com.epmet.dto.form.*;
 import com.epmet.dto.result.*;
-import com.epmet.dto.form.*;
-import com.epmet.dto.CustomerStaffDTO;
-import com.epmet.dto.CustomerStaffGridDTO;
-import com.epmet.dto.GovStaffRoleDTO;
-import com.epmet.dto.StaffGridListDTO;
-import com.epmet.dto.StaffRoleDTO;
-import com.epmet.dto.result.StaffDetailResultDTO;
-import com.epmet.dto.result.DepartInStaffListResultDTO;
-import com.epmet.dto.result.StaffInfoResultDTO;
-import com.epmet.dto.result.StaffInitResultDTO;
-import com.epmet.dto.result.StaffRoleResultDTO;
-import com.epmet.dto.CustomerStaffDTO;
-import com.epmet.dto.CustomerStaffGridDTO;
-import com.epmet.dto.StaffGridListDTO;
-import com.epmet.dto.form.CustomerStaffFormDTO;
-import com.epmet.dto.result.CommonStaffInfoResultDTO;
 import com.epmet.entity.CustomerStaffEntity;
 import com.epmet.entity.GovStaffRoleEntity;
 import com.epmet.entity.StaffRoleEntity;
@@ -440,15 +424,4 @@ public class CustomerStaffServiceImpl extends BaseServiceImpl<CustomerStaffDao,
 		return list;
 	}
 
-	/**
-	 * @param staffIdList
-	 * @return
-	 * @Author sun
-	 * @Description 批量查询工作人员基础信息
-	 **/
-	@Override
-	public List<StaffListResultDTO> getStaffListByIds(List<String> staffIdList) {
-		return baseDao.selectStaffByIds(staffIdList);
-	}
-
 }
\ No newline at end of file

From 9e872756a1acdeadea993587e4c5bf9f157466dc Mon Sep 17 00:00:00 2001
From: zxc <954985706@qq.com>
Date: Mon, 25 May 2020 10:27:15 +0800
Subject: [PATCH 4/6] =?UTF-8?q?Vote=E7=BC=93=E5=AD=98=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/epmet/redis/IssueVoteDetailRedis.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/redis/IssueVoteDetailRedis.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/redis/IssueVoteDetailRedis.java
index 3692ef87b8..74a93deb8b 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/redis/IssueVoteDetailRedis.java
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/redis/IssueVoteDetailRedis.java
@@ -40,6 +40,8 @@ import org.springframework.stereotype.Component;
 import java.lang.reflect.Field;
 import java.util.Map;
 
+import static com.epmet.commons.tools.redis.RedisUtils.NOT_EXPIRE;
+
 /**
  * 议题表决记录表
  *
@@ -75,7 +77,7 @@ public class IssueVoteDetailRedis {
         String key = IssueConstant.REDIS_KEY +vote.getIssueId();
         //bean to map
         Map<String, Object> map = BeanUtil.beanToMap(vote, false, true);
-        redisUtils.hMSet(key, map);
+        redisUtils.hMSet(key, map,NOT_EXPIRE);
     }
 
     public VoteRedisFormDTO get(String issueId){

From 7f0f021fe0cda32f71312c506312e08421ab0f2f Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Mon, 25 May 2020 11:07:42 +0800
Subject: [PATCH 5/6] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E9=85=8D=E7=BD=AE=EF=BC=8C=E7=BC=93=E5=AD=98=E6=96=B9=E6=B3=95?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/commons/tools/redis/RedisUtils.java | 14 ++++---
 .../com/epmet/feign/GovIssueFeignClient.java  | 37 +++++++++++++++++++
 .../impl/GovIssueFeignClientFallBack.java     | 26 +++++++++++++
 .../service/SyncVotingCacheAndDbService.java  | 13 +++++++
 ...VotingDailyStatisticalTaskServiceImpl.java | 24 ++++++++++++
 .../impl/SyncVotingCacheAndDbServiceImpl.java | 24 ++++++++++++
 .../epmet/task/DailyStatisticalVoteTask.java  | 34 +++++++++++++++++
 .../epmet/task/SyncVotingCacheAndDbTask.java  | 33 +++++++++++++++++
 .../IssueVoteStatisticalDailyController.java  |  4 +-
 .../mapper/member/ResiGroupMemberDao.xml      |  2 +-
 10 files changed, 202 insertions(+), 9 deletions(-)
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/impl/GovIssueFeignClientFallBack.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/SyncVotingCacheAndDbService.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/IssueVotingDailyStatisticalTaskServiceImpl.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/SyncVotingCacheAndDbServiceImpl.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/DailyStatisticalVoteTask.java
 create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/SyncVotingCacheAndDbTask.java

diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
index 9d4fb263cb..2e45203dc0 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
@@ -8,6 +8,7 @@
 
 package com.epmet.commons.tools.redis;
 
+import com.epmet.commons.tools.constant.NumConstant;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.HashOperations;
@@ -252,12 +253,13 @@ public class RedisUtils {
      * @date 2020.05.21 15:42
     **/
     public Map<String, Object> hincrby(String key,String field,Long delta){
+        Map<String,Object> existed = hGetAll(key);
+        if(null == existed || existed.size() < NumConstant.ONE) return null;
+
         //hincrby
-        Long count = redisTemplate.opsForHash().increment(key,field,delta);
-        if(count == -1){
-            return null;
-        }else{
-            return hGetAll(key);
-        }
+        redisTemplate.opsForHash().increment(key,field,delta);
+
+        return hGetAll(key);
+
     }
 }
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
new file mode 100644
index 0000000000..4c091c1c6a
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java
@@ -0,0 +1,37 @@
+package com.epmet.feign;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.feign.impl.GovIssueFeignClientFallBack;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+/**
+ * @Description 议题定时任务
+ * @Author wangc
+ * @Date 2020/5/23 13:42
+ */
+@FeignClient(name = ServiceConstant.GOV_ISSUE_SERVER, fallback = GovIssueFeignClientFallBack.class)
+public interface GovIssueFeignClient {
+
+    /**
+     * @Description 定时任务 每天生成生成昨日的议题表决日统计数
+     * @param
+     * @return
+     * @author wangc
+     * @date 2020.05.20 15:39
+     **/
+    @PostMapping(value = "gov/issue/issuevotestatisticaldaily/dailystatisticalvotejob")
+    Result dailyStatisticalVoteJob();
+
+    /**
+     * @Description 将所有表决中的投票数从缓存同步到数据库，要进行数据对比，若数据一致无需更新
+     * @param
+     * @return
+     * @author wangc
+     * @date 2020.05.21 09:07
+     **/
+    @PostMapping(value = "gov/issue/issuevotestatistical/syncvotingcacheanddb")
+    Result syncVotingCacheAndDb();
+
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/impl/GovIssueFeignClientFallBack.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/impl/GovIssueFeignClientFallBack.java
new file mode 100644
index 0000000000..0267ca347f
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/impl/GovIssueFeignClientFallBack.java
@@ -0,0 +1,26 @@
+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.feign.GovIssueFeignClient;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description
+ * @ClassName GovIssueFeignClientFallBack
+ * @Auth wangc
+ * @Date 2020-05-25 09:02
+ */
+@Component
+public class GovIssueFeignClientFallBack implements GovIssueFeignClient {
+    @Override
+    public Result dailyStatisticalVoteJob() {
+        return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "dailyStatisticalVoteJob");
+    }
+
+    @Override
+    public Result syncVotingCacheAndDb() {
+        return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "syncVotingCacheAndDb");
+    }
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/SyncVotingCacheAndDbService.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/SyncVotingCacheAndDbService.java
new file mode 100644
index 0000000000..e6ae8d55ac
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/SyncVotingCacheAndDbService.java
@@ -0,0 +1,13 @@
+package com.epmet.service;
+
+import com.epmet.commons.tools.utils.Result;
+
+/**
+ * @Description 同步缓存与数据库定时任务 -> 议题表决统计
+ * @Author wangc
+ * @Date 2020/5/20 17:39
+ */
+public interface SyncVotingCacheAndDbService {
+
+    Result syncVotingCacheAndDb();
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/IssueVotingDailyStatisticalTaskServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/IssueVotingDailyStatisticalTaskServiceImpl.java
new file mode 100644
index 0000000000..eb31c97810
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/IssueVotingDailyStatisticalTaskServiceImpl.java
@@ -0,0 +1,24 @@
+package com.epmet.service.impl;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.feign.GovIssueFeignClient;
+import com.epmet.service.IssueVotingDailyStatisticalTaskService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Description
+ * @ClassName IssueVotingDailyStatisticalTaskServiceImpl
+ * @Auth wangc
+ * @Date 2020-05-25 09:24
+ */
+@Service
+public class IssueVotingDailyStatisticalTaskServiceImpl implements IssueVotingDailyStatisticalTaskService {
+    @Autowired
+    private GovIssueFeignClient govIssueFeignClient;
+
+    @Override
+    public Result issueVotingDailyStatistical() {
+        return govIssueFeignClient.dailyStatisticalVoteJob();
+    }
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/SyncVotingCacheAndDbServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/SyncVotingCacheAndDbServiceImpl.java
new file mode 100644
index 0000000000..83a1ad37d9
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/SyncVotingCacheAndDbServiceImpl.java
@@ -0,0 +1,24 @@
+package com.epmet.service.impl;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.feign.GovIssueFeignClient;
+import com.epmet.service.SyncVotingCacheAndDbService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Description
+ * @ClassName SyncVotingCacheAndDbServiceImpl
+ * @Auth wangc
+ * @Date 2020-05-25 09:45
+ */
+@Service
+public class SyncVotingCacheAndDbServiceImpl implements SyncVotingCacheAndDbService {
+    @Autowired
+    private GovIssueFeignClient govIssueFeignClient;
+
+    @Override
+    public Result syncVotingCacheAndDb() {
+        return govIssueFeignClient.syncVotingCacheAndDb();
+    }
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/DailyStatisticalVoteTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/DailyStatisticalVoteTask.java
new file mode 100644
index 0000000000..1c33869895
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/DailyStatisticalVoteTask.java
@@ -0,0 +1,34 @@
+package com.epmet.task;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.service.IssueVotingDailyStatisticalTaskService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description
+ * @ClassName dailyStatisticalVoteTask
+ * @Auth wangc
+ * @Date 2020-05-25 09:22
+ */
+@Component("dailyStatisticalVoteTask")
+public class DailyStatisticalVoteTask implements ITask{
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Autowired
+    private IssueVotingDailyStatisticalTaskService issueVotingDailyStatisticalTaskService;
+
+
+    @Override
+    public void run(String params) {
+        logger.debug("dailyStatisticalVoteTask定时任务正在执行，参数为：{}", params);
+        Result result=issueVotingDailyStatisticalTaskService.issueVotingDailyStatistical();
+        if(result.success()){
+            logger.debug("dailyStatisticalVoteTask定时任务正在执行定时任务执行成功");
+        }else{
+            logger.debug("dailyStatisticalVoteTask定时任务正在执行定时任务执行失败:"+result.getMsg());
+        }
+    }
+}
diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/SyncVotingCacheAndDbTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/SyncVotingCacheAndDbTask.java
new file mode 100644
index 0000000000..9eed75bb68
--- /dev/null
+++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/SyncVotingCacheAndDbTask.java
@@ -0,0 +1,33 @@
+package com.epmet.task;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.service.SyncVotingCacheAndDbService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description
+ * @ClassName SyncVotingCacheAndDbTask
+ * @Auth wangc
+ * @Date 2020-05-25 09:47
+ */
+@Component("syncVotingCacheAndDbTask")
+public class SyncVotingCacheAndDbTask implements ITask {
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Autowired
+    private SyncVotingCacheAndDbService syncVotingCacheAndDbService;
+
+    @Override
+    public void run(String params) {
+        logger.debug("syncVotingCacheAndDbTask定时任务正在执行，参数为：{}", params);
+        Result result = syncVotingCacheAndDbService.syncVotingCacheAndDb();
+        if(result.success()){
+            logger.debug("syncVotingCacheAndDbTask定时任务正在执行定时任务执行成功");
+        }else{
+            logger.debug("syncVotingCacheAndDbTask定时任务正在执行定时任务执行失败:"+result.getMsg());
+        }
+    }
+}
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 6ff8f2e89b..c0532cbbf5 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
@@ -98,8 +98,8 @@ public class IssueVoteStatisticalDailyController {
      * @author wangc
      * @date 2020.05.20 15:39
     **/
-    @PostMapping(value = "dailystasticalvotejob")
-    public Result dailyStasticalVoteJob(){
+    @PostMapping(value = "dailystatisticalvotejob")
+    public Result dailyStatisticalVoteJob(){
         issueVoteStatisticalDailyService.countVotingDailyStatistic();
         return new Result();
     }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/member/ResiGroupMemberDao.xml b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/member/ResiGroupMemberDao.xml
index 5791303423..ae8b7d8f14 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/member/ResiGroupMemberDao.xml
+++ b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/member/ResiGroupMemberDao.xml
@@ -127,7 +127,7 @@
         groupp.DEL_FLAG = '0'
         AND
         <foreach collection="gridIds" index="index" item="item" open="( " separator=" or " close=" )">
-            groupp.GRID_ID = #{item.gridId}
+            groupp.GRID_ID = #{item}
         </foreach>
         AND
         groupp.STATE = 'approved'

From d0d6bd13149d759e3f28cb633270656e9f5d0d52 Mon Sep 17 00:00:00 2001
From: sunyuchao <syc_ls@163.com>
Date: Mon, 25 May 2020 13:54:17 +0800
Subject: [PATCH 6/6] =?UTF-8?q?=E7=89=88=E6=9C=AC=E5=8D=87=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet-job/epmet-job-server/deploy/docker-compose-dev.yml    | 2 +-
 epmet-module/epmet-job/epmet-job-server/pom.xml                 | 2 +-
 .../gov-issue/gov-issue-server/deploy/docker-compose-dev.yml    | 2 +-
 epmet-module/gov-issue/gov-issue-server/pom.xml                 | 2 +-
 .../gov-project-server/deploy/docker-compose-dev.yml            | 2 +-
 epmet-module/gov-project/gov-project-server/pom.xml             | 2 +-
 .../resi-group/resi-group-server/deploy/docker-compose-dev.yml  | 2 +-
 epmet-module/resi-group/resi-group-server/pom.xml               | 2 +-
 .../resi-home/resi-home-server/deploy/docker-compose-dev.yml    | 2 +-
 epmet-module/resi-home/resi-home-server/pom.xml                 | 2 +-
 10 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/epmet-module/epmet-job/epmet-job-server/deploy/docker-compose-dev.yml b/epmet-module/epmet-job/epmet-job-server/deploy/docker-compose-dev.yml
index 97c609d056..36820f68f4 100644
--- a/epmet-module/epmet-job/epmet-job-server/deploy/docker-compose-dev.yml
+++ b/epmet-module/epmet-job/epmet-job-server/deploy/docker-compose-dev.yml
@@ -2,7 +2,7 @@ version: "3.7"
 services:
   epmet-job-server:
     container_name: epmet-job-server-dev
-    image: 192.168.1.130:10080/epmet-cloud-dev/epmet-job-server:0.3.2
+    image: 192.168.1.130:10080/epmet-cloud-dev/epmet-job-server:0.3.3
     ports:
       - "8084:8084"
     network_mode: host # 使用现有网络
diff --git a/epmet-module/epmet-job/epmet-job-server/pom.xml b/epmet-module/epmet-job/epmet-job-server/pom.xml
index 9af9e3e1b5..920f3f9635 100644
--- a/epmet-module/epmet-job/epmet-job-server/pom.xml
+++ b/epmet-module/epmet-job/epmet-job-server/pom.xml
@@ -2,7 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <version>0.3.2</version>
+    <version>0.3.3</version>
     <parent>
         <groupId>com.epmet</groupId>
         <artifactId>epmet-job</artifactId>
diff --git a/epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml b/epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml
index 735235df5f..72f753f87e 100644
--- a/epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml
+++ b/epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml
@@ -2,7 +2,7 @@ version: "3.7"
 services:
   gov-issue-server:
     container_name: gov-issue-server-dev
-    image: 192.168.1.130:10080/epmet-cloud-dev/gov-issue-server:0.3.26
+    image: 192.168.1.130:10080/epmet-cloud-dev/gov-issue-server:0.3.27
     ports:
       - "8101:8101"
     network_mode: host # 使用现有网络
diff --git a/epmet-module/gov-issue/gov-issue-server/pom.xml b/epmet-module/gov-issue/gov-issue-server/pom.xml
index 57ccdb8f54..01723c912a 100644
--- a/epmet-module/gov-issue/gov-issue-server/pom.xml
+++ b/epmet-module/gov-issue/gov-issue-server/pom.xml
@@ -2,7 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <version>0.3.26</version>
+    <version>0.3.27</version>
     <parent>
         <artifactId>gov-issue</artifactId>
         <groupId>com.epmet</groupId>
diff --git a/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
index 2095bc48cb..91a669aae7 100644
--- a/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
+++ b/epmet-module/gov-project/gov-project-server/deploy/docker-compose-dev.yml
@@ -2,7 +2,7 @@ version: "3.7"
 services:
   gov-project-server:
     container_name: gov-project-server-dev
-    image: 192.168.1.130:10080/epmet-cloud-dev/gov-project-server:0.3.17
+    image: 192.168.1.130:10080/epmet-cloud-dev/gov-project-server:0.3.18
     ports:
       - "8102:8102"
     network_mode: host # 使用现有网络
diff --git a/epmet-module/gov-project/gov-project-server/pom.xml b/epmet-module/gov-project/gov-project-server/pom.xml
index 1bca572db5..10028b03ff 100644
--- a/epmet-module/gov-project/gov-project-server/pom.xml
+++ b/epmet-module/gov-project/gov-project-server/pom.xml
@@ -2,7 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <version>0.3.17</version>
+    <version>0.3.18</version>
     <parent>
         <artifactId>gov-project</artifactId>
         <groupId>com.epmet</groupId>
diff --git a/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
index e1fbfcdba5..17bfed279e 100644
--- a/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
+++ b/epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
@@ -2,7 +2,7 @@ version: "3.7"
 services:
   resi-group-server:
     container_name: resi-group-server-dev
-    image: 192.168.1.130:10080/epmet-cloud-dev/resi-group-server:0.3.36
+    image: 192.168.1.130:10080/epmet-cloud-dev/resi-group-server:0.3.37
     ports:
       - "8095:8095"
     network_mode: host # 使用现有网络
diff --git a/epmet-module/resi-group/resi-group-server/pom.xml b/epmet-module/resi-group/resi-group-server/pom.xml
index 550c189c3c..98a4fd290c 100644
--- a/epmet-module/resi-group/resi-group-server/pom.xml
+++ b/epmet-module/resi-group/resi-group-server/pom.xml
@@ -2,7 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <version>0.3.36</version>
+    <version>0.3.37</version>
     <parent>
         <groupId>com.epmet</groupId>
         <artifactId>resi-group</artifactId>
diff --git a/epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml b/epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml
index 183083aad6..c1efe4046a 100644
--- a/epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml
+++ b/epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml
@@ -2,7 +2,7 @@ version: "3.7"
 services:
   resi-home-server:
     container_name: resi-home-server-dev
-    image: 192.168.1.130:10080/epmet-cloud-dev/resi-home-server:0.3.4
+    image: 192.168.1.130:10080/epmet-cloud-dev/resi-home-server:0.3.5
     ports:
       - "8104:8104"
     network_mode: host # 使用现有网络
diff --git a/epmet-module/resi-home/resi-home-server/pom.xml b/epmet-module/resi-home/resi-home-server/pom.xml
index 1b30322866..71c700a5d3 100644
--- a/epmet-module/resi-home/resi-home-server/pom.xml
+++ b/epmet-module/resi-home/resi-home-server/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <version>0.3.4</version>
+    <version>0.3.5</version>
 
     <parent>
         <artifactId>resi-home</artifactId>