|
@@ -1592,8 +1592,9 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
// 游客直播间信息校验
|
|
|
ImLiveBroadcastRoomVo roomVo = getVisitorLiveBroadcastRoomVo(roomUid);
|
|
|
|
|
|
+ String today = DateTime.now().toString("yyyyMMdd");
|
|
|
// 为当前游客生成惟一用户ID
|
|
|
- String cacheKey = MessageFormat.format("fingerprint:{0}:{1}", roomUid, fingerprint);
|
|
|
+ String cacheKey = MessageFormat.format("fingerprint:{0}:{1}", today, fingerprint);
|
|
|
RBucket<Object> bucket = redissonClient.getBucket(cacheKey);
|
|
|
|
|
|
Integer userId;
|
|
@@ -1603,14 +1604,13 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
userId = Optional.ofNullable(bucket.get()).map(x -> (int) x).orElse(-1);
|
|
|
} else {
|
|
|
|
|
|
- String today = DateTime.now().toString("yyMMdd");
|
|
|
// 用户Id缓存key
|
|
|
String userIdKey = MessageFormat.format("fingerprint:userId:{0}", today);
|
|
|
|
|
|
RAtomicLong atomicLong = redissonClient.getAtomicLong(userIdKey);
|
|
|
if (!atomicLong.isExists()) {
|
|
|
// 设置默认初始化值
|
|
|
- atomicLong.set(10000);
|
|
|
+ atomicLong.set(1000);
|
|
|
// 设置缓存失效时间
|
|
|
atomicLong.expire(1L, TimeUnit.DAYS);
|
|
|
}
|