ScheduleJobFactory

/*
* file name:  ScheduleJobFactory.java
* copyright:  Unis Cloud Information Technology Co., Ltd. Copyright 2015,  All rights reserved
* description:  <description>
* mofidy staff:  zheng
* mofidy time:  2015年8月22日
*/
package com.quartz;

import java.util.List;

import net.sf.json.JSONObject;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;

/**
* To create scheduler job
*
* @author xpz
* @version [version, Jul 18, 2015]
* @see [about class/method]
* @since [product/module version]
*/
public class ScheduleJobFactory {
private static Log log = LogFactory.getLog(ScheduleJobFactory.class);

/***
* create a simpleScheduler job
*
* @param scheduler: the scheduler
* @param jobName: the job name
* @param jobGroup: the job group
* @param triggerName: the trigger name
* @param triggerGroup: the trigger group
* @param ssb: the schedBuilder (eg:SimpleScheduleBuilder ssb =
* SimpleScheduleBuilder.simpleSchedule() .withIntervalInMinutes(1)
* .repeatForever();)
* @param jobClass: the class which implement
* job/StatefulJob(@DisallowConcurrentExecution)
* @param params [explain parameter]
* @return void [explain return type]
* @exception throws [exception type] [explain exception]
* @see [class,class#method,class#member]
*/
public static void createSimpleJob(Scheduler scheduler, String jobName,
String jobGroup, String triggerName, String triggerGroup,
SimpleScheduleBuilder ssb, Class<? extends Job> jobClass,
JSONObject params) {
// build a schedule job
JobDetail jobDetail = JobBuilder.newJob(jobClass)
.withIdentity(jobName, jobGroup)
.build();
// set job name
jobDetail.getJobDataMap().put("name", jobName);
// set job params
if (params != null) {
jobDetail.getJobDataMap().put("params", params);
}
// build a schedule simpleTrigger
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity(triggerName, triggerGroup)
.startNow()
.withSchedule(ssb)
.build();
// create a new schedule job
try {
scheduler.scheduleJob(jobDetail, trigger);
}
catch (SchedulerException e) {
log.info("error with create a simple schedule job!", e);
}
}

/***
* create a cronScheduler job
*
* @param scheduler: the scheduler
* @param jobName: the job name
* @param jobGroup: the job group
* @param triggerName: the trigger name
* @param triggerGroup: the trigger group
* @param cronExpression: the cron expression
* @param jobClass: the class which implements
* job/StatefulJob(@DisallowConcurrentExecution)
* @param params: the param need to trransfer
* @return void [explain return type]
* @exception throws [exception type] [explain exception]
* @see [class,class#method,class#member]
*/
public static void createCronJob(Scheduler scheduler, String jobName,
String jobGroup, String triggerName, String triggerGroup,
String cronExpression, Class<? extends Job> jobClass,
JSONObject params) {
// build a schedule job
JobDetail jobDetail = JobBuilder.newJob(jobClass)
.withIdentity(jobName, jobGroup)
.build();
// set job name
jobDetail.getJobDataMap().put("name", jobName);
// set job params
if (params != null) {
jobDetail.getJobDataMap().put("params", params);
}
// build a schedule cronTrigger
CronTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity(triggerName, triggerGroup)
.withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
.build();
// create a new schedule job
try {
scheduler.scheduleJob(jobDetail, trigger);
}
catch (SchedulerException e) {
log.info("error with create a simple schedule job!", e);
}
}

/***
* delete job from scheduler
* @param scheduler
* @param job
* @param jobGroup [explain parameter]
*
* @return void [explain return type]
* @exception throws [exception type] [explain exception]
* @see [class,class#method,class#member]
*/
public static void deleteJob(Scheduler scheduler, String jobName, String jobGroup){
try {
JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
if(scheduler.checkExists(jobKey)){
scheduler.pauseJob(jobKey);
//Get all Triggers that are associated with the identified job
List<? extends Trigger>  triggers = scheduler.getTriggersOfJob(jobKey);
for(Trigger trigger : triggers){
scheduler.pauseTrigger(trigger.getKey());
boolean unscJobFlag = scheduler.unscheduleJob(trigger.getKey());
if(!unscJobFlag)
log.error("error with unschedule job");
}
}

//Interrupt all instances of the identified InterruptableJob executing in this Scheduler instance.
if(scheduler.checkExists(jobKey)){
boolean interruptFlag = scheduler.interrupt(jobKey);
if(!interruptFlag)
log.error("error with interrupt the job");
}

if(scheduler.checkExists(jobKey)){
boolean delJobFlag = scheduler.deleteJob(jobKey);
if(!delJobFlag)
log.error("error with delete the job");
}
}
catch (SchedulerException e) {
e.printStackTrace();
}
}
}