From ac542add19d10cd1a2d5efe36d762cec9c7df5b4 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期四, 04 九月 2025 17:58:35 +0800
Subject: [PATCH] update
---
ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java | 117 ----------------------------------------------------------
1 files changed, 0 insertions(+), 117 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java b/ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java
index 90a0017..9b8aa62 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java
@@ -7,122 +7,5 @@
import java.util.Map;
public class QuartzManager {
- private static SchedulerFactory factory = new StdSchedulerFactory();
- private static final String TRIGGER_NAME_PREFIX = "TRIGGER_PREFIX_";
- private static final String JOB_NAME_PREFIX = "JOB_PREFIX_";
-
- /**
- * 添加定时任务：具体某个时间点执行一次的任务，如：在某个2015-06-01 12:00发送一条消息
- *
- * @param jobName
- * 具体的任务名+ID标识唯一
- * @param jobType
- * @param date
- * @param jp
- */
- public synchronized static void addJob(Class<? extends Job> jobClass, String jobName, TimeJobType jobType, Date date,
- Map<String, ? extends Object> jp) {
- //logger.debug("ADD JOB {},jobName={},jobTyep={},jobDate={},",jobClass.getName(),jobName,jobType,date);
- try {
- Scheduler sched = factory.getScheduler();
- JobDetail job = JobBuilder.newJob(jobClass).withIdentity(JOB_NAME_PREFIX + jobName, jobType.getType())
- .setJobData(new JobDataMap(jp)).build();
-
- SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
- .withIdentity(TRIGGER_NAME_PREFIX + jobName, jobType.getType()).startAt(date).build();
- removeJob(jobName, jobType);
-
- sched.scheduleJob(job, trigger);
-
- if (!sched.isShutdown()) {
- sched.start();
- }
- } catch (Exception e) {
- //logger.error("ADD JOB exception {},jobName={},jobTyep={},jobDate={},",jobClass.getName(),jobName,jobType,date);
- }
- }
-
- /**
- * 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名)
- * @param jobName
- * @param time
- */
- public synchronized static void modifyJobTime(String jobName,TimeJobType jobType, Date time) {
- //logger.error("Update JOB exception,jobName={},jobTyep={},jobDate={}," ,jobName,jobType,time);
- try {
- JobKey jobKey = new JobKey(JOB_NAME_PREFIX + jobName, jobType.getType());
- TriggerKey key = new TriggerKey(TRIGGER_NAME_PREFIX + jobName, jobType.getType());
-
-
- Scheduler sched = factory.getScheduler();
- SimpleTrigger trigger = (SimpleTrigger) sched.getTrigger(key);
- if(trigger == null) {
- return;
- }
- Date oldTime = trigger.getStartTime();
-
- if (oldTime.getTime() != time.getTime()) {
- JobDetail jobDetail = sched.getJobDetail(jobKey);
- Class<? extends Job> objJobClass = jobDetail.getJobClass();
- removeJob(jobName,jobType);
- Map<String, Object> jp = jobDetail.getJobDataMap();
- addJob(objJobClass, jobName, jobType, time, jp);
- }
- } catch (Exception e) {
- // logger.error("Update JOB exception,jobName={},jobTyep={},jobDate={}," ,jobName,jobType,time);
- }
- }
-
- /**
- * 移除一个任务
- *
- * @param jobName
- */
- public synchronized static void removeJob(String jobName, TimeJobType jobType) {
- try {
- JobKey jobKey = new JobKey(JOB_NAME_PREFIX + jobName, jobType.getType());
- TriggerKey key = new TriggerKey(TRIGGER_NAME_PREFIX + jobName, jobType.getType());
- Scheduler sched = factory.getScheduler();
-
- JobDetail detail = sched.getJobDetail(jobKey);
- if (detail != null) {
- sched.pauseJob(jobKey);
- sched.pauseTrigger(key);// 停止触发器
- sched.unscheduleJob(key);// 移除触发器
- sched.deleteJob(jobKey);// 删除任务
- }
- } catch (Exception e) {
- e.printStackTrace();
- throw new RuntimeException(e);
- }
- }
-
- /**
- * 启动所有定时任务
- */
- public synchronized static void startJobs() {
- try {
- Scheduler sched = factory.getScheduler();
- sched.start();
- } catch (Exception e) {
- e.printStackTrace();
- throw new RuntimeException(e);
- }
- }
-
- /**
- * 关闭所有定时任务
- */
- public synchronized static void shutdownJobs() {
- try {
- Scheduler sched = factory.getScheduler();
- if (!sched.isShutdown()) {
- sched.shutdown();
- }
- } catch (Exception e) {
- e.printStackTrace();
- throw new RuntimeException(e);
- }
- }
}
--
Gitblit v1.7.1