|
|
package com.os.quartz.util;
|
|
|
|
|
|
import java.util.Date;
|
|
|
|
|
|
import io.netty.util.concurrent.FastThreadLocal;
|
|
|
import org.quartz.Job;
|
|
|
import org.quartz.JobExecutionContext;
|
|
|
import org.quartz.JobExecutionException;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import com.os.common.constant.Constants;
|
|
|
import com.os.common.constant.ScheduleConstants;
|
|
|
import com.os.common.utils.ExceptionUtil;
|
|
|
import com.os.common.utils.StringUtils;
|
|
|
import com.os.common.utils.bean.BeanUtils;
|
|
|
import com.os.common.utils.spring.SpringUtils;
|
|
|
import com.os.quartz.domain.SysJob;
|
|
|
import com.os.quartz.domain.SysJobLog;
|
|
|
import com.os.quartz.service.ISysJobLogService;
|
|
|
|
|
|
/**
|
|
|
* 抽象quartz调用
|
|
|
*
|
|
|
* @author ruoyi
|
|
|
*/
|
|
|
public abstract class AbstractQuartzJob implements Job
|
|
|
{
|
|
|
private static final Logger log = LoggerFactory.getLogger(AbstractQuartzJob.class);
|
|
|
|
|
|
/**
|
|
|
* 线程本地变量
|
|
|
*/
|
|
|
private static final FastThreadLocal<Date> THREAD_LOCAL = new FastThreadLocal<>();
|
|
|
|
|
|
@Override
|
|
|
public void execute(JobExecutionContext context) throws JobExecutionException
|
|
|
{
|
|
|
SysJob sysJob = new SysJob();
|
|
|
BeanUtils.copyBeanProp(sysJob, context.getMergedJobDataMap().get(ScheduleConstants.TASK_PROPERTIES));
|
|
|
try
|
|
|
{
|
|
|
before(context, sysJob);
|
|
|
doExecute(context, sysJob);
|
|
|
after(context, sysJob, null);
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
log.error("任务执行异常 - ：", e);
|
|
|
after(context, sysJob, e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 执行前
|
|
|
*
|
|
|
* @param context 工作执行上下文对象
|
|
|
* @param sysJob 系统计划任务
|
|
|
*/
|
|
|
protected void before(JobExecutionContext context, SysJob sysJob)
|
|
|
{
|
|
|
THREAD_LOCAL.set(new Date());
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 执行后
|
|
|
*
|
|
|
* @param context 工作执行上下文对象
|
|
|
* @param sysJob 系统计划任务
|
|
|
*/
|
|
|
protected void after(JobExecutionContext context, SysJob sysJob, Exception e)
|
|
|
{
|
|
|
Date startTime = THREAD_LOCAL.get();
|
|
|
THREAD_LOCAL.remove();
|
|
|
|
|
|
final SysJobLog sysJobLog = new SysJobLog();
|
|
|
sysJobLog.setJobName(sysJob.getJobName());
|
|
|
sysJobLog.setJobGroup(sysJob.getJobGroup());
|
|
|
sysJobLog.setInvokeTarget(sysJob.getInvokeTarget());
|
|
|
sysJobLog.setStartTime(startTime);
|
|
|
sysJobLog.setStopTime(new Date());
|
|
|
long runMs = sysJobLog.getStopTime().getTime() - sysJobLog.getStartTime().getTime();
|
|
|
sysJobLog.setJobMessage(sysJobLog.getJobName() + " 总共耗时：" + runMs + "毫秒");
|
|
|
if (e != null)
|
|
|
{
|
|
|
sysJobLog.setStatus(Constants.FAIL);
|
|
|
String errorMsg = StringUtils.substring(ExceptionUtil.getExceptionMessage(e), 0, 2000);
|
|
|
sysJobLog.setExceptionInfo(errorMsg);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
sysJobLog.setStatus(Constants.SUCCESS);
|
|
|
}
|
|
|
|
|
|
// 写入数据库当中
|
|
|
SpringUtils.getBean(ISysJobLogService.class).addJobLog(sysJobLog);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 执行方法，由子类重载
|
|
|
*
|
|
|
* @param context 工作执行上下文对象
|
|
|
* @param sysJob 系统计划任务
|
|
|
* @throws Exception 执行过程中的异常
|
|
|
*/
|
|
|
protected abstract void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception;
|
|
|
}
|