Quartz带参数任务的创建与修改

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

需求背景：创建的quartz任务需要用到三个参数，根据参数去执行并将结果入库，并且参数可修改更新。

这里，有三个参数需要传入，分别是planId、target、officeId

定义Job类：

public class StatisticsTaskService implements Job { private Logger logger = LoggerFactory.getLogger(StatisticsTaskService.class); private StatusStatisticsService statusStatisticsService = ApplicationContextHelper.getBean(StatusStatisticsService.class); @Override
public void execute(JobExecutionContext context) throws JobExecutionException {

JobDataMap dataMap = context.getJobDetail().getJobDataMap();
JobParameter jobParam = (JobParameter)dataMap.get(JobParameter.JOB_PARAM); String planId = jobParam.getPlanId();
String target = jobParam.getTarget();
String officeId = jobParam.getOfficeId();
//System.out.println(jobParam.toString()); //根据传入的target参数执行不同操作
if(target.equals("1")){
//执行操作1
}else if(target.equals("2")){
//执行操作2
}else{
//执行其他操作
}
logger.info("Job:"+planId+" target:"+target);
}
}

定义参数类：

public class JobParameter implements Serializable{ private static final long serialVersionUID = 1L; public static final String JOB_PARAM = "jobParam"; private String planId;
private String target;
private String officeId; public String getPlanId() {
return planId;
}
public void setPlanId(String planId) {
this.planId = planId;
}
public String getTarget() {
return target;
}
public void setTarget(String target) {
this.target = target;
}
public String getOfficeId() {
return officeId;
}
public void setOfficeId(String officeId) {
this.officeId = officeId;
} @Override
public String toString() {
return "JobParameter [planId=" + planId + ", target=" + target + ", officeId=" + officeId + "]";
}
}

创建任务创建和修改方法：

1.创建任务：

public static void createScheduleJobWithParams(Scheduler scheduler, String jobName,
String jobGroup, String cronExpression, Class<? extends Job> jobClass,
String planId,String target,String officeId) {
// 构建job信息
JobDetail jobDetail = JobBuilder.newJob(jobClass)
.withIdentity(jobName, jobGroup)
.build();
//创建初始参数
JobParameter jobParam = new JobParameter();
jobParam.setPlanId(planId);
jobParam.setTarget(target);
jobParam.setOfficeId(officeId);
jobDetail.getJobDataMap().put(JobParameter.JOB_PARAM, jobParam); CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(cronExpression); CronTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity(jobName, jobGroup).withSchedule(scheduleBuilder)
.build();
try {
scheduler.scheduleJob(jobDetail, trigger);
if (!scheduler.isStarted()) {
scheduler.start();
}
} catch (SchedulerException e) {
e.printStackTrace();
}
}

2.修改任务:

public static void updateScheduleJobWithParams(Scheduler scheduler, String jobName, String jobGroup, String cronExpression,
String planId,String target) {
try {
TriggerKey triggerKey = getTriggerKey(jobName, jobGroup);
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
// 按新的cronExpression表达式重新构建trigger
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
//参数修改
JobKey jobKey = getJobKey(jobName, jobGroup);
JobParameter jobParam = (JobParameter) scheduler.getJobDetail(jobKey).getJobDataMap().get(JobParameter.JOB_PARAM);
jobParam.setPlanId(planId);
jobParam.setTarget(target);
// 按新的trigger重新设置job执行
scheduler.rescheduleJob(triggerKey, trigger); } catch (SchedulerException e) {
e.printStackTrace();
}
}