From d0fbc6e5b35ff2972b2223f4dfa78b9792bc64d3 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Wed, 15 Apr 2020 09:23:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B8=83=E8=AF=9D=E9=A2=98=E6=97=B6?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E7=BB=84=E4=BF=A1=E6=81=AF=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/ResiGroupServiceImpl.java    |  2 +-
 .../impl/ResiGroupMemberServiceImpl.java      | 22 ++++++-
 .../service/impl/ResiTopicServiceImpl.java    | 64 ++++++++++++++++---
 .../epmet/modules/utils/ModuleConstant.java   | 10 +++
 4 files changed, 85 insertions(+), 13 deletions(-)

diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java
index 4998d0fedd..5d1a0ac277 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java
@@ -574,7 +574,7 @@ public class ResiGroupServiceImpl extends BaseServiceImpl<ResiGroupDao, ResiGrou
 		targetObject.setGroupId(groupDTO.getId());
 		targetObject.setGroupState(groupDTO.getState());
 		SimpleDateFormat format = new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN);
-		if(null!=groupDTO.getLatestTopicPublishDate()){
+		if(null != groupDTO.getLatestTopicPublishDate()){
 			targetObject.setLatestTopicPublishDate(format.format(groupDTO.getLatestTopicPublishDate()));
 		}
 		targetObject.setGroupStatisticalInfo(statisticalObjct);
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
index 368a02d517..dbd18ca126 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
@@ -36,7 +36,6 @@ import com.epmet.dto.result.UserResiInfoResultDTO;
 import com.epmet.feign.MessageFeignClient;
 import com.epmet.modules.constant.GroupMemberConstant;
 import com.epmet.modules.constant.UserMessageConstant;
-import com.epmet.modules.exception.ModuleErrorCode;
 import com.epmet.modules.feign.EpmetUserFeignClient;
 import com.epmet.modules.group.entity.ResiGroupEntity;
 import com.epmet.modules.group.redis.ResiGroupRedis;
@@ -52,8 +51,12 @@ import com.epmet.modules.utils.ModuleConstant;
 import com.epmet.resi.group.constant.EnterGroupTypeConstant;
 import com.epmet.resi.group.constant.LeaderFlagConstant;
 import com.epmet.resi.group.constant.MemberStateConstant;
+import com.epmet.resi.group.constant.TopicConstant;
 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.group.ResiGroupStatisticalDTO;
+import com.epmet.resi.group.dto.group.ResiGroupStatisticalInfoRedisDTO;
 import com.epmet.resi.group.dto.member.GroupMemeberOperationDTO;
 import com.epmet.resi.group.dto.member.ResiGroupMemberDTO;
 import com.epmet.resi.group.dto.member.ResiGroupMemberInfoRedisDTO;
@@ -348,7 +351,22 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl<ResiGroupMemberD
 		ResiGroupMemberInfoRedisDTO memberRedis = transferToMemberInfoRedis(resiGroupMemberDTO);
 		resiGroupMemberRedis.set(memberRedis);
 		//8、修改群组缓存信息
-
+		ResiGroupInfoRedisDTO groupCache =
+				resiGroupRedis.get(groupMemeberOperationDTO.getGroupId());
+		if(groupCache != null && StringUtils.isNotBlank(groupCache.getGroupId())){
+			//ResiGroupStatisticalInfoRedisDTO statisticalCache =  groupCache.getGroupStatisticalInfo();
+			Map<String,Object> paramsMap = new HashMap<>();
+			paramsMap.put(TopicConstant.RESI_GROUP_ID,groupMemeberOperationDTO.getGroupId());
+			List<ResiGroupStatisticalDTO> statisticalDTO = resiGroupStatisticalService.list(paramsMap);
+			if(null != statisticalDTO && statisticalDTO.size() > 0){
+				ResiGroupStatisticalInfoRedisDTO statisticalObjct =
+						ConvertUtils.sourceToTarget(statisticalDTO.get(0),ResiGroupStatisticalInfoRedisDTO.class);
+				statisticalObjct.setTotalEarnestMembers(statisticalDTO.get(0).getTotalEarnestMemebers());
+				statisticalObjct.setTotalNormalMembers(statisticalDTO.get(0).getTotalNormalMemebers());
+				groupCache.setGroupStatisticalInfo(statisticalObjct);
+			}
+			resiGroupRedis.set(groupCache);
+		}
 		return new Result();
 	}
 
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 1c43e81890..1925d2b28b 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
@@ -38,6 +38,7 @@ import com.epmet.modules.group.dao.ResiGroupDao;
 import com.epmet.modules.group.dao.ResiGroupStatisticalDao;
 import com.epmet.modules.group.entity.ResiGroupEntity;
 import com.epmet.modules.group.entity.ResiGroupStatisticalEntity;
+import com.epmet.modules.group.redis.ResiGroupRedis;
 import com.epmet.modules.member.dao.ResiGroupMemberDao;
 import com.epmet.modules.member.entity.ResiGroupMemberEntity;
 import com.epmet.modules.member.redis.ResiGroupMemberRedis;
@@ -53,6 +54,8 @@ import com.epmet.modules.topic.service.ResiTopicService;
 import com.epmet.modules.utils.ModuleConstant;
 import com.epmet.resi.group.constant.MemberStateConstant;
 import com.epmet.resi.group.constant.TopicConstant;
+import com.epmet.resi.group.dto.group.ResiGroupInfoRedisDTO;
+import com.epmet.resi.group.dto.group.ResiGroupStatisticalInfoRedisDTO;
 import com.epmet.resi.group.dto.member.ResiGroupMemberDTO;
 import com.epmet.resi.group.dto.member.ResiGroupMemberInfoRedisDTO;
 import com.epmet.resi.group.dto.member.form.RemoveMemberFormDTO;
@@ -110,6 +113,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
     @Autowired
     private ResiTopicOperationService resiTopicOperationService;
 
+    @Autowired
+    private ResiGroupRedis resiGroupRedis;
+
     private final Log logger = LogFactory.getLog(getClass());
 
     @Override
@@ -247,9 +253,10 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             logger.error(ModuleConstant.NO_SUCH_GROUP_STASTICAL_INFO);
             throw new RenException(ModuleConstant.NO_SUCH_GROUP_STASTICAL_INFO);
         }
+        //5.更新群缓存信息，话题数量+1
+        updCacheGroupStatisticalInfo(resiTopicPublishFormDTO.getGroupId(),ModuleConstant.PLUS_OPERATION,NumConstant.ONE);
 
-
-        //5.群组信息，更新latestTopicPublishDate字段
+        //6.群组信息，更新latestTopicPublishDate字段
         ResiGroupEntity group2Update = new ResiGroupEntity();
         group2Update.setId(resiTopicPublishFormDTO.getGroupId());
         group2Update.setLatestTopicPublishDate(currentTime);
@@ -395,6 +402,8 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             resiGroupStatisticalDao.updateById(statistical2Update);
         }
 
+        // 5.更新组缓存信息，话题数量-1
+        updCacheGroupStatisticalInfo(topic.getGroupId(),ModuleConstant.MINUS_OPERATION,NumConstant.ONE);
         return new Result();
     }
 
@@ -447,6 +456,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             );
             resiGroupStatisticalDao.updateById(statistical2Update);
         }
+        //4.更新组缓存信息，总话题数
+
+        updCacheGroupStatisticalInfo(topic.getGroupId(),ModuleConstant.PLUS_OPERATION,topicIds.size());
 
         return new Result();
     }
@@ -523,8 +535,6 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
         resultDTO.setTopicImgs(attachmentUrls);
 
         //3.拿取用户信息
-
-
         ResiTopicDTO topic = get(topicId);
         ResiGroupEntity group = resiGroupDao.selectById(topic.getGroupId());
         ResiGroupMemberInfoRedisDTO memberRedis =
@@ -564,12 +574,6 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             }
         }
 
-
-
-
-
-
-
         return new Result<ResiTopicDetailResultDTO>().ok(resultDTO);
     }
 
@@ -803,4 +807,44 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
     }
 
     }
+
+    /**
+     * @Description 更新组统计缓存信息
+     * @Param groupId
+     * @Param operation "+":plus    "-":minus
+     * @return
+     * @Author wangc
+     * @Date 2020.04.14 23:31
+     **/
+    private void updCacheGroupStatisticalInfo(String groupId,String operation,Integer quantity){
+
+        ResiGroupInfoRedisDTO groupCache =
+                resiGroupRedis.get(groupId);
+        if(groupCache != null && StringUtils.isNotBlank(groupCache.getGroupId())){
+            ResiGroupStatisticalInfoRedisDTO statisticalCache =  groupCache.getGroupStatisticalInfo();
+            if(null != statisticalCache){
+                if(StringUtils.equals(ModuleConstant.PLUS_OPERATION,operation)){
+                    statisticalCache.setTotalTopics(
+                            null == statisticalCache.getTotalTopics() ? quantity : statisticalCache.getTotalTopics() + quantity
+                    );
+                }else if(StringUtils.equals(ModuleConstant.MINUS_OPERATION,operation)){
+                    statisticalCache.setTotalTopics(
+                            null == statisticalCache.getTotalTopics() ? quantity : statisticalCache.getTotalTopics() - quantity
+                    );
+                }
+
+                groupCache.setGroupStatisticalInfo(statisticalCache);
+            }else{
+                //没有相应的群组缓存信息   TODO 从数据库查找存进缓存
+
+            }
+            resiGroupRedis.set(groupCache);
+        }else{
+            //没有相应的群组缓存信息   TODO 从数据库查找存进缓存
+
+        }
+
+    }
 }
+
+
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/utils/ModuleConstant.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/utils/ModuleConstant.java
index 957c9857bc..5e01d6b413 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/utils/ModuleConstant.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/utils/ModuleConstant.java
@@ -163,4 +163,14 @@ public interface ModuleConstant extends Constant {
 	 * 缺失组成员缓存信息
 	 * */
 	String GROUP_MEMBER_NOT_EXISTS_IN_CACHE = "缺失组成员缓存信息";
+
+	/**
+	 * 加号
+	 *  */
+	String PLUS_OPERATION = "+";
+
+	/**
+	 * 减号
+	 * */
+	String MINUS_OPERATION = "-";
 }