|
@@ -126,27 +126,29 @@ public class CourseWatchLogScheduler {
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 创建完课消息
|
|
* 创建完课消息
|
|
|
|
|
+ * 注释原因:与checkWatchStatus()中的创建完课消息逻辑重复,导致生成两条相同记录
|
|
|
|
|
+ * 已改为在checkWatchStatus()方法中每5分钟触发一次
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(fixedRate = 300000) // 每五分钟执行一次
|
|
|
|
|
- public void createCourseFinishMsg() {
|
|
|
|
|
- // 尝试设置标志为 true,表示任务开始执行
|
|
|
|
|
- if (!isRunning3.compareAndSet(false, true)) {
|
|
|
|
|
- log.warn("创建完课消息 - 上一个任务尚未完成,跳过此次执行");
|
|
|
|
|
- return;
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- try {
|
|
|
|
|
- log.info("创建完课消息 - 定时任务开始");
|
|
|
|
|
- sopLogsTaskService.createCourseFinishMsg();
|
|
|
|
|
- log.info("创建完课消息 - 定时任务成功完成");
|
|
|
|
|
- } catch (Exception e) {
|
|
|
|
|
- log.error("创建完课消息 - 定时任务执行失败", e);
|
|
|
|
|
- } finally {
|
|
|
|
|
- // 重置标志为 false,表示任务已完成
|
|
|
|
|
- isRunning3.set(false);
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- }
|
|
|
|
|
|
|
+// @Scheduled(fixedRate = 300000) // 每五分钟执行一次
|
|
|
|
|
+// public void createCourseFinishMsg() {
|
|
|
|
|
+// // 尝试设置标志为 true,表示任务开始执行
|
|
|
|
|
+// if (!isRunning3.compareAndSet(false, true)) {
|
|
|
|
|
+// log.warn("创建完课消息 - 上一个任务尚未完成,跳过此次执行");
|
|
|
|
|
+// return;
|
|
|
|
|
+// }
|
|
|
|
|
+//
|
|
|
|
|
+// try {
|
|
|
|
|
+// log.info("创建完课消息 - 定时任务开始");
|
|
|
|
|
+// sopLogsTaskService.createCourseFinishMsg();
|
|
|
|
|
+// log.info("创建完课消息 - 定时任务成功完成");
|
|
|
|
|
+// } catch (Exception e) {
|
|
|
|
|
+// log.error("创建完课消息 - 定时任务执行失败", e);
|
|
|
|
|
+// } finally {
|
|
|
|
|
+// // 重置标志为 false,表示任务已完成
|
|
|
|
|
+// isRunning3.set(false);
|
|
|
|
|
+// }
|
|
|
|
|
+//
|
|
|
|
|
+// }
|
|
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private IFsCourseLinkService courseLinkService;
|
|
private IFsCourseLinkService courseLinkService;
|