shangke 2 rokov pred
rodič
commit
c5bc86510d

+ 6 - 4
mec-biz/src/main/java/com/ym/mec/biz/service/impl/CourseScheduleServiceImpl.java

@@ -3559,12 +3559,14 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
 						continueCourseTime = "5";
 					}
 
+					// 查询最新课程信息
+					CourseSchedule courseSchedule = courseScheduleDao.get(item.getId());
 					// 直播课关联直播间编号
-					String liveRoomId = getCourseScheduleLiveRoomId(item, continueCourseTime, Lists.newArrayList(), Lists.newArrayList());
+					String liveRoomId = getCourseScheduleLiveRoomId(courseSchedule, continueCourseTime, Lists.newArrayList(), Lists.newArrayList());
 
 					ImLiveBroadcastRoom liveRoom = imLiveBroadcastRoomService.getByRoomUid(liveRoomId);
 					if (Objects.isNull(liveRoom)) {
-						log.warn("liveRoom is null, liveRoomId:{}", item.getLiveRoomId());
+						log.warn("liveRoom is null, liveRoomId:{}", liveRoomId);
 						return;
 					}
 
@@ -3573,8 +3575,8 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
 
 						LiveRoomMessage message = new LiveRoomMessage();
 						message.setIsIncludeSender(1);
-						message.setFromUserId(item.getActualTeacherId().toString());
-						message.setToChatRoomId(item.getLiveRoomId());
+						message.setFromUserId(courseSchedule.getActualTeacherId().toString());
+						message.setToChatRoomId(liveRoom.getRoomUid());
 						message.setObjectName(LiveRoomMessage.LIVE_STATUS_CHANGE);
 
 						// 发送用户信息