|
@@ -1050,31 +1050,20 @@ public class CourseGroupServiceImpl extends ServiceImpl<CourseGroupDao, CourseGr
|
|
|
} else {
|
|
|
//人数未达标则修改课程组为取消状态
|
|
|
courseGroup.setStatus(CourseGroupEnum.CANCEL.getCode());
|
|
|
- courseGroup.setUpdatedTime(new Date());
|
|
|
//更新课程组下课程状态为取消
|
|
|
courseScheduleService.update(Wrappers.<CourseSchedule>lambdaUpdate()
|
|
|
.eq(CourseSchedule::getCourseGroupId, courseGroup.getId())
|
|
|
.set(CourseSchedule::getStatus, CourseScheduleEnum.CANCEL.getCode())
|
|
|
);
|
|
|
- // 直播课成课失败通知
|
|
|
- // 发短信
|
|
|
- try {
|
|
|
- SysUser user = sysUserFeignService.queryUserById(courseGroup.getTeacherId());
|
|
|
- Map<Long, String> receivers = new HashMap<>();
|
|
|
- receivers.put(user.getId(), user.getPhone());
|
|
|
- sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.AWSMS, MessageTypeEnum.SMS_LIVE_COMPLETION_FAIL,
|
|
|
- receivers, null, 0, null, null,
|
|
|
- courseGroup.getName());
|
|
|
- } catch (Exception e) {
|
|
|
- log.warn("直播课成课失败短信发送失败,{}", e.getMessage());
|
|
|
- }
|
|
|
//直播课成课失败发送消息
|
|
|
this.sendMessage(courseGroup);
|
|
|
//退款
|
|
|
this.refund(courseGroup);
|
|
|
}
|
|
|
+ courseGroup.setUpdatedTime(new Date());
|
|
|
this.updateById(courseGroup);
|
|
|
- } catch (Exception ignored) {
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("closeCourseGroup error >>> ", e.getCause());
|
|
|
}
|
|
|
});
|
|
|
}
|