|
@@ -2161,6 +2161,9 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
Optional.ofNullable(roomUid).orElseThrow(() -> new BizException("房间编号不能为空!"));
|
|
|
Optional.ofNullable(userId).orElseThrow(() -> new BizException("人员编号不能为空!"));
|
|
|
|
|
|
+ // 设置进入时间
|
|
|
+ RBucket<Long> userStateTimeCache = redissonClient.getBucket(LIVE_USER_LAST_TIME.replace(USER_ID, userId.toString()));
|
|
|
+ userStateTimeCache.set(new Date().getTime(), 60L, TimeUnit.MINUTES);
|
|
|
LiveRoomWrapper.LiveRoomVo liveRoomVo = queryRoomInfo(roomUid);
|
|
|
|
|
|
//记录用户当前房间uid
|