From f4a0f2acc63d7785eab108419a4e16f5f688cb95 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期六, 18 一月 2020 12:06:27 +0800
Subject: [PATCH] 用户注册信息
---
fanli/src/main/java/com/yeshi/fanli/job/QuartzManager.java | 33 ++++++++++-----------------------
1 files changed, 10 insertions(+), 23 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/QuartzManager.java b/fanli/src/main/java/com/yeshi/fanli/job/QuartzManager.java
index 80d4d03..dc1901b 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/QuartzManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/QuartzManager.java
@@ -1,10 +1,8 @@
package com.yeshi.fanli.job;
-import java.util.Iterator;
-import java.util.Map;
-
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
+import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
@@ -29,8 +27,8 @@
* @param params
* @param cls
*/
- public static void addJob(Scheduler sched, @SuppressWarnings("rawtypes") Class cls, String jobName,
- String time, Map<String, String> params) {
+ public static void addJob(Scheduler sched, Class <? extends Job> jobClass, String jobName,
+ String time, Object obj) {
try {
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, TRIGGER_GROUP_NAME);
@@ -38,13 +36,9 @@
if (trigger == null) {
LogHelper.test("------addJob---浠诲姟鍒涘缓-----" + jobName + "------- ");
- JobDetail jobDetail = JobBuilder.newJob(cls).withIdentity(jobName, JOB_GROUP_NAME).build();
- if (params != null) {
- Iterator<String> its = params.keySet().iterator();
- while (its.hasNext()) {
- String key = its.next();
- jobDetail.getJobDataMap().put(key, params.get(key));
- }
+ JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, JOB_GROUP_NAME).build();
+ if (obj != null) {
+ jobDetail.getJobDataMap().put("key", obj);
}
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time);
trigger = TriggerBuilder.newTrigger().withIdentity(jobName, TRIGGER_GROUP_NAME)
@@ -72,27 +66,20 @@
* @param params
* @param cls
*/
- @SuppressWarnings("rawtypes")
- public static void modifyJob(Scheduler sched, Class cls, String jobName,
- String time, Map<String, String> params ) {
-
+ public static void modifyJob(Scheduler sched, Class <? extends Job> jobClass, String jobName,
+ String time, Object obj) {
try {
-
LogHelper.test("------modifyJob---浠诲姟淇敼-----" + jobName + "------- ");
-
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, TRIGGER_GROUP_NAME);
CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerKey);
- if (trigger == null) {
+ if (trigger == null)
return;
- }
// 鍒犻櫎鍘熶换鍔�
removeJob(sched, jobName);
-
// 鏂板缓浠诲姟
- addJob(sched, QualityFactoryJob.class, jobName, time, params);
-
+ addJob(sched, jobClass, jobName, time, obj);
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
--
Gitblit v1.8.0