|
@@ -244,11 +244,11 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
roomDestroy(room.getId());
|
|
|
}
|
|
|
};
|
|
|
- //如果直播状态=1(关闭直播),并且结束直播时间 +30分钟 大于等于 现在,则销毁
|
|
|
+ //如果直播状态=1(关闭直播),并且现在 大于等于 结束直播时间 +30分钟,则销毁
|
|
|
if (speakerInfo.getState() == 1) {
|
|
|
consumer.accept(speakerInfo.getEndLiveTime());
|
|
|
}
|
|
|
- //退出时间 +30分钟 大于等于 现在,则销毁
|
|
|
+ //现在 大于等于 退出时间 +30分钟,则销毁
|
|
|
if (Objects.nonNull(speakerInfo.getExitRoomTime())) {
|
|
|
consumer.accept(speakerInfo.getExitRoomTime());
|
|
|
}
|