From 749570394745ae95ee65605eadb42800f42fa20a Mon Sep 17 00:00:00 2001
From: huliguo <2023611923@qq.com>
Date: 星期五, 08 八月 2025 12:09:26 +0800
Subject: [PATCH] 规范
---
src/main/java/com/linghu/timeTask/ScheduledTasks.java | 26 +-------------------------
1 files changed, 1 insertions(+), 25 deletions(-)
diff --git a/src/main/java/com/linghu/timeTask/ScheduledTasks.java b/src/main/java/com/linghu/timeTask/ScheduledTasks.java
index 9312445..413d277 100644
--- a/src/main/java/com/linghu/timeTask/ScheduledTasks.java
+++ b/src/main/java/com/linghu/timeTask/ScheduledTasks.java
@@ -40,8 +40,6 @@
@Autowired
private CollectController collectController;
@Autowired
- private WebClient webClient; // 假设已配置WebClient
- @Autowired
private QuestionService questionService;
@Autowired
private KeywordService keywordService;
@@ -197,30 +195,8 @@
}
}
/**
- * 实际的任务处理方法，替代原@Scheduled注解方法
+ * 实际的任务处理方法，
*/
-// public void executeTaskProcessing() {
-// if (!isHealthy) {
-// log.debug("系统不健康，跳过任务处理");
-// return;
-// }
-//
-// // 查询所有状态为pending的任务
-// LambdaQueryWrapper<KeywordTask> queryWrapper = new LambdaQueryWrapper<>();
-// queryWrapper.eq(KeywordTask::getStatus, "pending");
-//
-// keywordTaskService.list(queryWrapper)
-// .stream()
-// .filter(task -> task.getTask_id() != null)
-// .forEach(task -> processTaskStatus(task)
-// .subscribeOn(Schedulers.boundedElastic())
-// .subscribe(
-// updatedTask -> log.info("任务状态已更新: {}", updatedTask.getTask_id()),
-// error -> log.error("处理任务 {} 时发生错误: {}", task.getTask_id(), error.getMessage())
-// )
-// );
-// }
-
private Mono<KeywordTask> processTaskStatus(KeywordTask task) {
return collectController.getTaskStatus(task.getTask_id())
--
Gitblit v1.7.1