package frame.schedule;
|
|
|
import java.util.Date;
|
|
import org.apache.log4j.Logger;
|
import org.quartz.Job;
|
import org.quartz.JobDataMap;
|
import org.quartz.JobDetail;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
|
import frame.util.Util;
|
|
|
|
|
public class ScheduleJob implements Job{
|
|
protected static Logger logger;
|
|
private Object lock = new Object();
|
private int tryTimes;
|
private int tryCycles;
|
private Date beginTime;
|
private Date endTime;
|
private boolean success;
|
|
|
static {
|
logger = Logger.getLogger(ScheduleJob.class);
|
}
|
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
JobDetail jobDetail = context.getJobDetail();
|
JobDataMap dataMap = jobDetail.getJobDataMap();
|
|
IJob job = (IJob)dataMap.get(IJob.Key_Job);
|
|
synchronized (lock) {
|
JobStatus status = job.getStatus();
|
|
if (JobStatus.Idle == status) {
|
String taskId = Util.newShortGUID();
|
|
beforeExecute(job, taskId);
|
try {
|
executeJob(job, taskId);
|
}
|
finally {
|
afterExecute(job, taskId);
|
}
|
}
|
}
|
}
|
|
private void beforeExecute(IJob job, String taskId) {
|
success = false;
|
beginTime = new Date();
|
tryTimes = 0;
|
tryCycles = 0;
|
|
job.begin(taskId, beginTime);
|
}
|
private void afterExecute(IJob job, String taskId) {
|
if (success) {
|
job.succeed(taskId, tryTimes, tryCycles, endTime);
|
}
|
else {
|
job.fail(taskId, tryTimes, tryCycles, endTime);
|
}
|
}
|
|
private void executeJob(IJob job, String taskId) {
|
int cnt = 0;
|
String name = job.getName();
|
|
for (int j = 0; j < IJob.Max_TryCycles; j++) {
|
tryCycles++;
|
|
for (int i = 0; i < IJob.Max_TryTimes; i++) {
|
if (Schedule.Terminated) {
|
break;
|
}
|
|
tryTimes++;
|
|
try {
|
cnt = cnt + 1;
|
logger.info(name + "尝试第" + cnt + "次运行...");
|
|
job.execute();
|
|
success = true;
|
break;
|
}
|
catch (Exception e) {
|
}
|
}
|
|
if (success) {
|
break;
|
}
|
|
try {
|
int waitfor = 60 * IJob.Minutes_IntervalCycle;
|
|
for (int w = 0; w < waitfor; w++) {
|
Thread.sleep(1000);
|
|
if (Schedule.Terminated) {
|
break;
|
}
|
}
|
} catch (InterruptedException e) {
|
}
|
}
|
}
|
}
|
