|
@@ -166,7 +166,7 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
//查询课时表生成直播间
|
|
|
List<CourseSchedule> courseScheduleList = courseScheduleService.list(Wrappers.<CourseSchedule>lambdaQuery()
|
|
|
.eq(CourseSchedule::getType, CourseScheduleEnum.LIVE.getCode())
|
|
|
- .eq(CourseSchedule::getStatus, CourseScheduleEnum.NOT_START.getCode())
|
|
|
+ .in(CourseSchedule::getStatus, CourseScheduleEnum.NOT_START.getCode(), CourseScheduleEnum.ING.getCode())
|
|
|
.eq(CourseSchedule::getLock, 0)
|
|
|
.eq(CourseSchedule::getClassDate, LocalDate.now().toString()));
|
|
|
if (CollectionUtils.isEmpty(courseScheduleList)) {
|
|
@@ -194,6 +194,11 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
if (now.getTime() < createRoomTime.getTime()) {
|
|
|
return;
|
|
|
}
|
|
|
+ //避免重复创建直播间
|
|
|
+ int count = this.count(Wrappers.<LiveRoom>lambdaQuery().eq(LiveRoom::getCourseId, c.getId()));
|
|
|
+ if (count > 0) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
LiveRoom room = new LiveRoom();
|
|
|
room.setCourseGroupId(c.getCourseGroupId());
|
|
|
room.setCourseId(c.getId());
|