@@ -23,9 +23,8 @@ public class CourseEventListener {
@Async
@EventListener
- public void courseStatusChangeEvent(CourseStatusChangeEvent courseStatusChangeEvent){
+ public void courseStatusChangeMonitor(CourseStatusChangeEvent courseStatusChangeEvent){
logger.info("课程状态变更:{}", courseStatusChangeEvent.getCourseIds());
courseScheduleStudentPaymentService.updateCourseActualPrice();
}
-
@@ -3980,6 +3980,9 @@ public class CourseScheduleServiceImpl extends BaseServiceImpl<Long, CourseSched
if (updateList.size() > 0) {
courseScheduleDao.batchUpdate(updateList);
+
+ Set<Long> courseIds = updateList.stream().map(CourseSchedule::getId).collect(Collectors.toSet());
+ courseEventSource.courseStatusChange(courseIds);
// 更新班级已上课次