|
@@ -5054,31 +5054,35 @@ public class VipGroupServiceImpl extends BaseServiceImpl<Long, VipGroup> impleme
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
- // 通知老师
|
|
|
- Integer actualTeacherId = courseSchedule.getActualTeacherId();
|
|
|
- if (actualTeacherId != null) {
|
|
|
- Map<Integer, String> userMap = new HashMap<>();
|
|
|
- userMap.put(actualTeacherId, actualTeacherId.toString());
|
|
|
-
|
|
|
- sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_LIVE_COURSE_START,
|
|
|
- userMap, null, 0,teacherUrl , "TEACHER", classGroup.getName());
|
|
|
- }
|
|
|
-
|
|
|
- // 通知学生
|
|
|
- List<SimpleUserDto> courseStudents = courseScheduleStudentPaymentService.getCourseStudents(Lists.newArrayList(courseSchedule.getId()));
|
|
|
- if (!CollectionUtils.isEmpty(courseStudents)) {
|
|
|
- Map<Integer, String> userMap = new HashMap<>();
|
|
|
- courseStudents.forEach(data -> {
|
|
|
- userMap.put(data.getUserId(), data.getUserId().toString());
|
|
|
- });
|
|
|
+ try {
|
|
|
+ // 通知老师
|
|
|
+ Integer actualTeacherId = courseSchedule.getActualTeacherId();
|
|
|
+ if (actualTeacherId != null) {
|
|
|
+ Map<Integer, String> userMap = new HashMap<>();
|
|
|
+ userMap.put(actualTeacherId, actualTeacherId.toString());
|
|
|
+
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_LIVE_COURSE_START,
|
|
|
+ userMap, null, 0,teacherUrl , "TEACHER", classGroup.getName());
|
|
|
+ }
|
|
|
|
|
|
- sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_LIVE_COURSE_START_STUDENT,
|
|
|
- userMap, null, 0, studentUrl, "STUDENT", classGroup.getName());
|
|
|
+ // 通知学生
|
|
|
+ List<SimpleUserDto> courseStudents = courseScheduleStudentPaymentService.getCourseStudents(Lists.newArrayList(courseSchedule.getId()));
|
|
|
+ if (!CollectionUtils.isEmpty(courseStudents)) {
|
|
|
+ Map<Integer, String> userMap = new HashMap<>();
|
|
|
+ courseStudents.forEach(data -> {
|
|
|
+ userMap.put(data.getUserId(), data.getUserId().toString());
|
|
|
+ });
|
|
|
+
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_LIVE_COURSE_START_STUDENT,
|
|
|
+ userMap, null, 0, studentUrl, "STUDENT", classGroup.getName());
|
|
|
+ }
|
|
|
+ // 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());
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("直播课程提醒失败", e);
|
|
|
}
|
|
|
- // 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()));
|