|
@@ -1729,10 +1729,22 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
}
|
|
}
|
|
roomVo.setLikeNum((int) like);
|
|
roomVo.setLikeNum((int) like);
|
|
//累计总用户数量
|
|
//累计总用户数量
|
|
- roomVo.setTotalLookNum(getNum.apply(this::getTotalUserCache, roomVo.getRoomUid()));
|
|
|
|
- //在房间观看用户数量
|
|
|
|
- roomVo.setLookNum(getNum.apply(this::getOnlineUserCache, roomVo.getRoomUid()));
|
|
|
|
|
|
+ // roomVo.setTotalLookNum(getNum.apply(this::getTotalUserCache, roomVo.getRoomUid()));
|
|
|
|
+ // //在房间观看用户数量
|
|
|
|
+ // roomVo.setLookNum(getNum.apply(this::getOnlineUserCache, roomVo.getRoomUid()));
|
|
|
|
|
|
|
|
+ // 不在从缓存中获取观看人数,改为从数据库中获取
|
|
|
|
+ Map<String, Object> params = new HashMap<>();
|
|
|
|
+ params.put("roomUid", roomVo.getRoomUid());
|
|
|
|
+ params.put("page", 1);
|
|
|
|
+ params.put("rows", 1);
|
|
|
|
+ PageInfo<ImLiveBroadcastRoomMemberVo> roomMember = liveBroadcastRoomMemberService.queryRoomMember(
|
|
|
|
+ params);
|
|
|
|
+ roomVo.setTotalLookNum(roomMember.getTotal());
|
|
|
|
+ params.put("onlineStatus", 1);
|
|
|
|
+ roomMember = liveBroadcastRoomMemberService.queryRoomMember(
|
|
|
|
+ params);
|
|
|
|
+ roomVo.setLookNum(roomMember.getTotal());
|
|
|
|
|
|
// 直播视频数
|
|
// 直播视频数
|
|
List<ImLiveRoomVideoVo> imLiveRoomVideoVos = imLiveRoomVideoService.queryList(roomVo.getRoomUid());
|
|
List<ImLiveRoomVideoVo> imLiveRoomVideoVos = imLiveRoomVideoService.queryList(roomVo.getRoomUid());
|