|
@@ -555,7 +555,8 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
RoomSpeakerInfo speakerInfo = speakerCache.get();
|
|
|
//查询用户是否在线
|
|
|
LiveRoomUser liveRoomUser = livePluginContext.getPluginService(room.getServiceProvider()).chatRoomUserExist(room.getId().toString(),speakerInfo.getSpeakerId().toString());
|
|
|
- if (Objects.nonNull(liveRoomUser) && StringUtils.equals(liveRoomUser.getStatus(),"1")) {
|
|
|
+ if (Objects.nonNull(liveRoomUser) && liveRoomUser.getExist() &&
|
|
|
+ "1".equals(liveRoomUser.getStatus()) && StringUtils.equals(liveRoomUser.getStatus(), "1")) {
|
|
|
log.info("roomDestroy destroyExpiredLiveRoom is online >>>> roomId:{} speakerId:{}", room.getId(), speakerInfo.getSpeakerId());
|
|
|
return;
|
|
|
}
|