提交 c41049cb 作者: 王峰

研究中心定时任务关闭

上级 20b0c8d1
...@@ -147,7 +147,7 @@ public class AnalysisTask { ...@@ -147,7 +147,7 @@ public class AnalysisTask {
* 每天凌晨0点20分执行一次 * 每天凌晨0点20分执行一次
* 发送 伪事件脉络 所需信息到kafka对应的topic * 发送 伪事件脉络 所需信息到kafka对应的topic
*/ */
@Scheduled(cron = "0 20 0 * * ?") //@Scheduled(cron = "0 20 0 * * ?")
public void eventContext_fake() { public void eventContext_fake() {
Date today = new Date(); Date today = new Date();
Date disableDate = DateUtil.addDate(today, -1); Date disableDate = DateUtil.addDate(today, -1);
......
...@@ -31,7 +31,7 @@ import java.util.concurrent.CompletableFuture; ...@@ -31,7 +31,7 @@ import java.util.concurrent.CompletableFuture;
* @date 2024/8/30 * @date 2024/8/30
*/ */
@Slf4j @Slf4j
@Component //@Component
public class EventDigTask { public class EventDigTask {
@Autowired @Autowired
...@@ -45,7 +45,7 @@ public class EventDigTask { ...@@ -45,7 +45,7 @@ public class EventDigTask {
private final static String EVENT_DIG_TIME_KEY = "EVENT_DIG_HANDLER_TIME::"; private final static String EVENT_DIG_TIME_KEY = "EVENT_DIG_HANDLER_TIME::";
@Scheduled(cron = "0 0/5 * * * ?") //@Scheduled(cron = "0 0/5 * * * ?")
public void sendData() { public void sendData() {
List<EventExtractTask> extractTaskList = eventExtractTaskService.list(Wrappers.<EventExtractTask>lambdaQuery().eq(EventExtractTask::getDeleteStatus, 0) List<EventExtractTask> extractTaskList = eventExtractTaskService.list(Wrappers.<EventExtractTask>lambdaQuery().eq(EventExtractTask::getDeleteStatus, 0)
.eq(EventExtractTask::getTaskStatus, 1)); .eq(EventExtractTask::getTaskStatus, 1));
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论