浏览代码

修复群组加入问题

Eric 2 年之前
父节点
当前提交
a167158d75

+ 3 - 2
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -271,7 +271,8 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
 
                         String imIdentity = MessageFormat.format("{0}:{1}", String.valueOf(userId), ClientEnum.STUDENT.name());
                         // 缓存用户重新入群标识
-                        RBucket<Object> bucket = redissonClient.getBucket(imIdentity);
+                        String userKey = MessageFormat.format("{0}:{1}", groupId, imIdentity);
+                        RBucket<Object> bucket = redissonClient.getBucket(userKey);
                         if (bucket.isExists()) {
                             return;
                         }
@@ -289,7 +290,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
                         }
 
                         // 缓存重新入群标识, 默认有效期为120天
-                        bucket.set(imIdentity, 120, TimeUnit.DAYS);
+                        bucket.set(userKey, 120, TimeUnit.DAYS);
                     }
                 }