From ad835011afaf88624e5b5f27b248c6b1089b7d8a Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期一, 21 七月 2025 15:03:49 +0800
Subject: [PATCH] 判断是否有数据，和请求繁忙
---
src/main/java/com/linghu/timeTask/ScheduledTasks.java | 5 +----
1 files changed, 1 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/linghu/timeTask/ScheduledTasks.java b/src/main/java/com/linghu/timeTask/ScheduledTasks.java
index 701c2fd..9c5d31f 100644
--- a/src/main/java/com/linghu/timeTask/ScheduledTasks.java
+++ b/src/main/java/com/linghu/timeTask/ScheduledTasks.java
@@ -34,12 +34,10 @@
@Component
@Slf4j
public class ScheduledTasks {
-// private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class);
private static final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("HH:mm:ss");
@Autowired
private KeywordTaskService keywordTaskService;
-
@Autowired
private CollectController collectController;
@Autowired
@@ -47,7 +45,6 @@
@Autowired
private QuestionService questionService;
- private String baseUrl = "http://thirdparty-service"; // 第三方服务基础URL
private ScheduledFuture<?> scheduledTask; // 定时任务引用
// 健康检查专用调度器（单线程足够）
private final ScheduledExecutorService healthCheckScheduler = Executors.newSingleThreadScheduledExecutor();
@@ -211,7 +208,7 @@
log.error("处理任务 {} 状态时发生错误: {}", task.getTask_id(), e.getMessage());
task.setStatus("error");
- // 修改这里：将updateById的结果包装成Mono
+ // 将updateById的结果包装成Mono
return Mono.fromSupplier(() -> keywordTaskService.updateById(task))
.thenReturn(task);
});
--
Gitblit v1.7.1