|
@@ -23,6 +23,9 @@ public class CourseWatchLogScheduler {
|
|
|
private final AtomicBoolean isRunning2 = new AtomicBoolean(false);
|
|
|
|
|
|
private final AtomicBoolean isRunning3 = new AtomicBoolean(false);
|
|
|
+
|
|
|
+ private final AtomicBoolean isRunning4 = new AtomicBoolean(false);
|
|
|
+
|
|
|
@Autowired
|
|
|
private FsCourseWatchLogMapper courseWatchLogMapper;
|
|
|
|
|
@@ -126,7 +129,7 @@ public class CourseWatchLogScheduler {
|
|
|
@Scheduled(fixedRate = 60000) // 每分钟执行一次
|
|
|
public void checkFsUserWatchStatus() {
|
|
|
// 尝试设置标志为 true,表示任务开始执行
|
|
|
- if (!isRunning1.compareAndSet(false, true)) {
|
|
|
+ if (!isRunning4.compareAndSet(false, true)) {
|
|
|
log.warn("WXH5-检查会员看课中任务执行 - 上一个任务尚未完成,跳过此次执行");
|
|
|
return;
|
|
|
}
|
|
@@ -139,7 +142,7 @@ public class CourseWatchLogScheduler {
|
|
|
log.error("WXH5-检查会员看课中任务执行完成 - 定时任务执行失败", e);
|
|
|
} finally {
|
|
|
// 重置标志为 false,表示任务已完成
|
|
|
- isRunning1.set(false);
|
|
|
+ isRunning4.set(false);
|
|
|
}
|
|
|
|
|
|
}
|