From 6047f24edc72a13b71813c3fb6cc0d087c0f6cd7 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期一, 29 十二月 2025 12:46:35 +0800
Subject: [PATCH] yys 巡检定时任务持久化
---
ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java | 24 +++++++++++++++++++-----
1 files changed, 19 insertions(+), 5 deletions(-)
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java
index 78ebef8..09834b4 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java
@@ -1,6 +1,10 @@
package com.ruoyi.quartz.service.impl;
import java.util.List;
+
+import com.ruoyi.business.entity.TimingTask;
+import com.ruoyi.business.mapper.TimingTaskMapper;
+import com.ruoyi.business.service.impl.TimingTaskScheduler;
import jakarta.annotation.PostConstruct;
import org.quartz.JobDataMap;
import org.quartz.JobKey;
@@ -31,17 +35,27 @@
@Autowired
private SysJobMapper jobMapper;
+ @Autowired
+ private TimingTaskMapper timingTaskMapper;
+
+ @Autowired
+ private TimingTaskScheduler timingTaskScheduler;
+
/**
* 椤圭洰鍚姩鏃讹紝鍒濆鍖栧畾鏃跺櫒 涓昏鏄槻姝㈡墜鍔ㄤ慨鏀规暟鎹簱瀵艰嚧鏈悓姝ュ埌瀹氭椂浠诲姟澶勭悊锛堟敞锛氫笉鑳芥墜鍔ㄤ慨鏀规暟鎹簱ID鍜屼换鍔＄粍鍚嶏紝鍚﹀垯浼氬鑷磋剰鏁版嵁锛�
*/
@PostConstruct
public void init() throws SchedulerException, TaskException
{
- scheduler.clear();
- List<SysJob> jobList = jobMapper.selectJobAll();
- for (SysJob job : jobList)
- {
- ScheduleUtils.createScheduleJob(scheduler, job);
+// scheduler.clear();
+// List<SysJob> jobList = jobMapper.selectJobAll();
+// for (SysJob job : jobList)
+// {
+// ScheduleUtils.createScheduleJob(scheduler, job);
+// }
+ List<TimingTask> timingTasks = timingTaskMapper.selectList(null);
+ for (TimingTask timingTask : timingTasks) {
+ timingTaskScheduler.scheduleTimingTask(timingTask);
}
}
--
Gitblit v1.9.3