|
@@ -356,7 +356,11 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
return;
|
|
|
}
|
|
|
//避免重复创建直播间
|
|
|
- if (StringUtils.isNotBlank(c.getRoomUid())) {
|
|
|
+
|
|
|
+ // 如果是同时在管乐迷和酷乐秀直播的老师
|
|
|
+
|
|
|
+ String teacherIds = sysConfigService.findConfigValue(SysConfigConstant.LIVE_TEACHER_IDS);
|
|
|
+ if (StringUtils.isNotBlank(c.getRoomUid()) && (StringUtils.isBlank(teacherIds) || !Arrays.asList(teacherIds.split(",")).contains(c.getTeacherId().toString()))) {
|
|
|
log.info("createCourseLiveRoom>>>roomUid:{} 已存在", c.getRoomUid());
|
|
|
return;
|
|
|
}
|
|
@@ -385,9 +389,6 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
//开课提醒
|
|
|
this.pushLiveCreateRoom(room);
|
|
|
|
|
|
- // 如果是同时在管乐迷和酷乐秀直播的老师
|
|
|
-
|
|
|
- String teacherIds = sysConfigService.findConfigValue(SysConfigConstant.LIVE_TEACHER_IDS);
|
|
|
if (StringUtils.isNotBlank(teacherIds) && Arrays.asList(teacherIds.split(",")).contains(room.getSpeakerId().toString())) {
|
|
|
speakCache(room, room.getSpeakerId());
|
|
|
}
|