|
@@ -1891,6 +1891,16 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
roomMember.setLiveRoomStatus(1);
|
|
|
roomMember.setMicrophoneFlag(microphoneFlag);
|
|
|
|
|
|
+ ImLiveBroadcastRoomMember liveRoomMember = liveBroadcastRoomMemberService.lambdaQuery()
|
|
|
+ .eq(ImLiveBroadcastRoomMember::getTenantId, userInfo.getTenantId())
|
|
|
+ .eq(ImLiveBroadcastRoomMember::getRoomUid, imLiveBroadcastRoomVo.getRoomUid())
|
|
|
+ .eq(ImLiveBroadcastRoomMember::getUserId, userInfo.getUserId())
|
|
|
+ .list().stream().findFirst().orElse(null);
|
|
|
+ if (Objects.nonNull(liveRoomMember)) {
|
|
|
+ return userInfo;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
// 保存直播间用户信息
|
|
|
liveBroadcastRoomMemberService.save(roomMember);
|
|
|
|