|
@@ -1249,6 +1249,18 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
log.info("opsRoom>>>> joinRoom error roomUid: {}", roomUid);
|
|
|
return;
|
|
|
}
|
|
|
+
|
|
|
+ // 判断用户机构是否有权限进入该直播间
|
|
|
+ SysUser sysUser = sysUserFeignService.queryUserById(userId);
|
|
|
+ if (Objects.isNull(sysUser)) {
|
|
|
+ log.info("opsRoom>>>> joinRoom user null error userId: {}", userId);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if (!sysUser.getTenantId().equals(imLiveBroadcastRoomVo.getTenantId())) {
|
|
|
+ log.info("opsRoom>>>> joinRoom error tenant diff userId: {}, tenantId: {}", userId, sysUser.getTenantId());
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
//记录用户当前房间uid
|
|
|
redissonClient.getBucket(LIVE_USER_ROOM.replace(USER_ID, userId.toString())).set(roomUid, 12L, TimeUnit.HOURS);
|
|
|
//房间累计用户信息-指只要进入到该房间的用户都要记录
|
|
@@ -1947,6 +1959,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
imLiveBroadcastRoom.setSpeakerStatus(liveRoom.getSpeakerStatus());
|
|
|
imLiveBroadcastRoom.setPushStatus(liveRoom.getPushStatus());
|
|
|
imLiveBroadcastRoom.setBanStatus(liveRoom.getBanStatus());
|
|
|
+ whetherChat(room.getId(), liveRoom.getBanStatus());
|
|
|
// 不用前端传时间
|
|
|
// imLiveBroadcastRoom.setLiveTotalTime(liveRoom.getLiveTotalTime());
|
|
|
|