|
@@ -42,18 +42,18 @@ public class CourseEventListener {
|
|
|
@Async
|
|
|
@EventListener
|
|
|
public void courseStatusChangeMonitor(CourseStatusChangeEvent courseStatusChangeEvent){
|
|
|
- if(redisCache.getRedisTemplate().opsForValue().size(KEY)>0){
|
|
|
- logger.info("课程状态变更(未执行,任务执行中):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- Boolean success = redisCache.getRedisTemplate().opsForValue().setIfAbsent(KEY, Thread.currentThread().getId(), 1, TimeUnit.HOURS);
|
|
|
- if(!success){
|
|
|
- logger.info("课程状态变更(未执行,任务执行中):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- logger.info("课程状态变更(执行开始):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
+// if(redisCache.getRedisTemplate().opsForValue().size(KEY)>0){
|
|
|
+// logger.info("课程状态变更(未执行,任务执行中):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
+// return;
|
|
|
+// }
|
|
|
+//
|
|
|
+// Boolean success = redisCache.getRedisTemplate().opsForValue().setIfAbsent(KEY, Thread.currentThread().getId(), 1, TimeUnit.HOURS);
|
|
|
+// if(!success){
|
|
|
+// logger.info("课程状态变更(未执行,任务执行中):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
+// return;
|
|
|
+// }
|
|
|
+//
|
|
|
+// logger.info("课程状态变更(执行开始):{}", courseStatusChangeEvent.getCourseIds());
|
|
|
|
|
|
try{
|
|
|
courseScheduleStudentPaymentService.updateCourseActualPrice(null, null, null);
|