优化代码

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImLiveBroadcastRoomServiceImpl.java

@@ -248,11 +248,10 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
     private void insertLiveAllData(String roomUid, Integer userId) {
         //获取直播间所有人数据写入 im_live_broadcast_room_member
         RMap<Integer, RoomUserInfoVo> roomTotalUser = redissonClient.getMap(LIVE_ROOM_TOTAL_USER_LIST.replace(ROOM_UID, roomUid));
-        Integer tenantId = roomTotalUser.get(0).getTenantId();
         List<ImLiveBroadcastRoomMember> memberList = new ArrayList<>();
         roomTotalUser.forEach((k, v) -> {
             ImLiveBroadcastRoomMember member = new ImLiveBroadcastRoomMember();
-            member.setTenantId(tenantId);
+            member.setTenantId(v.getTenantId());
             member.setRoomUid(roomUid);
             member.setUserId(userId);
             member.setJoinTime(v.getFirstJoinTime());
@@ -268,7 +267,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
         RoomSpeakerInfo speakerInfo = speakerCache.get();
         //获取直播间数据写入im_live_broadcast_room_data
         ImLiveBroadcastRoomData liveData = new ImLiveBroadcastRoomData();
-        liveData.setTenantId(tenantId);
+        liveData.setTenantId(speakerInfo.getTenantId());
         liveData.setRoomUid(roomUid);
         liveData.setLikeNum(roomVo.getLikeNum());
         liveData.setTotalUserNum(roomVo.getTotalLookNum());