fix

mec-biz/src/main/java/com/ym/mec/biz/service/impl/VipGroupServiceImpl.java

@@ -5049,6 +5049,11 @@ public class VipGroupServiceImpl extends BaseServiceImpl<Long, VipGroup> impleme
                 continue;
             }
 
+            ImLiveBroadcastRoomVo imLiveBroadcastRoomVo = imLiveBroadcastRoomService.queryRoomInfo(courseSchedule.getLiveRoomId());
+            if (Objects.isNull(imLiveBroadcastRoomVo)) {
+                continue;
+            }
+
             // 通知老师
             Integer actualTeacherId = courseSchedule.getActualTeacherId();
             if (actualTeacherId != null) {
@@ -5070,20 +5075,15 @@ public class VipGroupServiceImpl extends BaseServiceImpl<Long, VipGroup> impleme
                 sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_LIVE_COURSE_START_STUDENT,
                         userMap, null, 0, studentUrl, "STUDENT", classGroup.getName());
             }
-            ImLiveBroadcastRoomVo imLiveBroadcastRoomVo = imLiveBroadcastRoomService.queryRoomInfo(courseSchedule.getLiveRoomId());
-
             // im消息
             imUrl = MessageFormatter.arrayFormat(imUrl,courseSchedule.getId(), imLiveBroadcastRoomVo.getSubjectId());
             sysMessageService.batchSendImGroupMessage(MessageTypeEnum.IM_LIVE_COURSE_START_GROUP, courseSchedule.getActualTeacherId().toString(), imUrl,
                     new String[]{classGroup.getId().toString()},null, classGroup.getName());
 
+            // 更新通知状态
+            courseScheduleDao.updateRemindStatus(Lists.newArrayList(courseSchedule.getId()));
         }
 
-        // id 集合
-        List<Long> ids = courseSchedules.stream().map(CourseSchedule::getId).collect(Collectors.toList());
-
-        // 更新通知状态
-        courseScheduleDao.updateRemindStatus(ids);
         CompletableFuture.runAsync(() -> {
             for (CourseSchedule courseSchedule : courseSchedules) {
                 vipGroupService.createVipGroupLiveRoom(courseSchedule.getId().toString(), courseSchedule);