package cn.stylefeng.guns.modular.zsx.bs.job.quartz;
|
|
import cn.hutool.extra.spring.SpringUtil;
|
import cn.stylefeng.guns.modular.zsx.bs.job.constant.QuartzEnum;
|
import cn.stylefeng.guns.modular.zsx.bs.job.entity.SysJob;
|
import org.quartz.Job;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
|
import java.lang.reflect.Method;
|
|
/**
|
* @author fulin
|
* @since 2023/6/14 15:10
|
* <p>
|
* 1. 此类作为所有任务的执行入口,其他要执行的具体逻辑应该注入spring,然后通过此 通过反射调用到具体任务执行类 <br>
|
* 2. sysJob包含着要执行的具体逻辑类的信息,以及方法,参数等信息,此案例维护在数据库中<br>
|
* 3. 通过更改数据库数据,动态变更quartz中的任务<br>
|
* 4. 目前仅仅做了无参构造器的方法执行,后续补充<br>
|
* </p>
|
*/
|
public class QuartzJob implements Job {
|
|
@Override
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
// 获取任务执行参数
|
SysJob sysJob = (SysJob) context.getJobDetail().getJobDataMap().get(QuartzEnum.jobKey);
|
|
// invokeTarget 应该符合 类.方法名 例如 task.sout()
|
String invokeTarget = sysJob.getInvokeTarget();
|
String beanName = invokeTarget.split("\\.")[0];
|
String temp = invokeTarget.split("\\.")[1];
|
String methodName = temp.substring(0, temp.indexOf("("));
|
|
Object bean = SpringUtil.getBean(beanName);
|
Method method = null;
|
try {
|
method = bean.getClass().getMethod(methodName);
|
method.invoke(bean);
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new RuntimeException(e);
|
}
|
}
|
}
|
