From 015303e141693d588e646ee5dbd1a84ac1868642 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Wed, 31 Mar 2021 10:10:23 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BD=AC=E8=AE=A9=E7=BB=84=E6=8E=A5=E5=8F=A3?=
 =?UTF-8?q?=EF=BC=8C=E4=BF=AE=E6=94=B9=E7=BB=84=E6=88=90=E5=91=98=E7=BC=93?=
 =?UTF-8?q?=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../member/redis/ResiGroupMemberRedis.java    | 13 +++++++++++-
 .../GroupLeaderTransferRecordServiceImpl.java | 21 +++++++++++++++++++
 2 files changed, 33 insertions(+), 1 deletion(-)

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 fcb7cb7b4a..6786ea2e81 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
@@ -21,7 +21,6 @@ package com.epmet.modules.member.redis;
 import cn.hutool.core.bean.BeanUtil;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.constant.NumConstant;
-import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
@@ -204,4 +203,16 @@ public class ResiGroupMemberRedis {
         return null;
     }
 
+    /**
+     * @return void
+     * @param groupId
+     * @param userId
+     * @author yinzuomei
+     * @description 删除某个小组成员的缓存信息
+     * @Date 2021/3/31 10:08
+     **/
+    public void deleteMemberCatche(String groupId, String userId) {
+        String key=ResiGroupRedisKeys.getResiGroupMemberInfoKey(groupId,userId);
+        redisUtils.delete(key);
+    }
 }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupLeaderTransferRecordServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupLeaderTransferRecordServiceImpl.java
index bf557430a9..492047cf9b 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupLeaderTransferRecordServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupLeaderTransferRecordServiceImpl.java
@@ -31,6 +31,7 @@ import com.epmet.modules.constant.UserMessageConstant;
 import com.epmet.modules.group.service.ResiGroupService;
 import com.epmet.modules.member.dao.GroupLeaderTransferRecordDao;
 import com.epmet.modules.member.entity.GroupLeaderTransferRecordEntity;
+import com.epmet.modules.member.redis.ResiGroupMemberRedis;
 import com.epmet.modules.member.service.GroupLeaderTransferRecordService;
 import com.epmet.modules.member.service.ResiGroupMemberService;
 import com.epmet.modules.utils.ModuleConstant;
@@ -65,6 +66,8 @@ public class GroupLeaderTransferRecordServiceImpl extends BaseServiceImpl<GroupL
     private EpmetMessageOpenFeignClient epmetMessageOpenFeignClient;
     @Autowired
     private ResiGroupService resiGroupService;
+    @Autowired
+    private ResiGroupMemberRedis resiGroupMemberRedis;
 
     @Override
     public PageData<GroupLeaderTransferRecordDTO> page(Map<String, Object> params) {
@@ -161,6 +164,24 @@ public class GroupLeaderTransferRecordServiceImpl extends BaseServiceImpl<GroupL
         insert(entity);
         //发送站内信
         saveUserMessage(formDTO,originalLeader.getCustomerUserId());
+        //新组长、原组长成员缓存更新
+        this.updateGroupMemberInfo(originalLeader.getCustomerUserId(),formDTO.getNewLeaderUserId(),formDTO.getGroupId());
+    }
+
+    /**
+     * @return void
+     * @param originalLeaderUserId
+     * @param newLeaderUserId
+     * @param groupId
+     * @author yinzuomei
+     * @description 先删缓存，后查（没有会查数据库同时放进缓存）
+     * @Date 2021/3/31 10:09
+     **/
+    private void updateGroupMemberInfo(String originalLeaderUserId, String newLeaderUserId, String groupId) {
+        resiGroupMemberRedis.deleteMemberCatche(groupId,originalLeaderUserId);
+        resiGroupMemberRedis.deleteMemberCatche(groupId,newLeaderUserId);
+        resiGroupMemberRedis.get(groupId,originalLeaderUserId);
+        resiGroupMemberRedis.get(groupId,newLeaderUserId);
     }
 
     private void saveUserMessage(ConfirmTransferFormDTO formDTO,String originalLeaderUserId) {