動態建立管理定時任務-已完成
阿新 • • 發佈：2019-10-29
設計思路：
1：通過任務名稱結合反射動態拼接組成任務（jobdetail）,並注入引數，實現真正的動態建立定時任務
2：可以修改時間在不重啟服務的基礎上
3：可以立即執行某個任務
4：重啟服務後要掃描所有有效任務並啟動
5：支援再不重啟服務的基礎上 暫停，恢復，刪除任務
6: 只需要一張表
7: 程式碼不能上傳，只能硬貼啦，對於伸手黨抱歉，程式碼均已執行保證正確，若有錯誤可以給我留言
定時任務的表
--定時任務 oracle版的sql
--job_status 是任務的狀態 0啟用1暫停
--task_parameter代表任務的方法引數 用逗號分割，按照順序
CREATE TABLE quartz_config (
job_name VARCHAR2(50 BYTE),
job_group VARCHAR2(50 BYTE),
job_description VARCHAR2(500 BYTE),
cron_expression VARCHAR2(500 BYTE),
job_status NUMBER(10, 0),
create_time DATE,
update_time DATE,
create_user VARCHAR2(255 BYTE),
task_parameter VARCHAR2(4000 BYTE),
PRIMARY KEY ( job_name, job_group )
)這個是定時任務的目錄
TaskRunner.java
package com.itstyle.quartz.config;
import java.util.List;
import javax.annotation.Resource;
import org.quartz.Scheduler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import com.itstyle.quartz.dynamicquery.Service.QuartzConfigService;
import com.itstyle.quartz.entity.QuartzConfigModel;
import com.itstyle.quartz.web.JobService;
/**
* 啟動時掃描所有的有效定時任務並啟動
*/
@Component
public class TaskRunner implements ApplicationRunner {
private final static Logger LOGGER = LoggerFactory.getLogger(TaskRunner.class);
private final Integer VALID = 0;
@Resource
Scheduler scheduler;
@Resource
QuartzConfigService quartzConfigService;
@Resource
JobService jobService;
@Override
public void run(ApplicationArguments var) throws Exception {
LOGGER.info("初始化任務");
List<QuartzConfigModel> quartzs = quartzConfigService.findByCondition(null, null, VALID);
if (!CollectionUtils.isEmpty(quartzs)) {
quartzs.forEach(n -> {
try {
jobService.startJob(n.getId().getJobName(), n.getId().getJobGroup(), n.getJobDescription(),
n.getTaskParameter(), n.getCronExpression());
} catch (Exception e) {
LOGGER.error("初始化任務失敗");
}
});
}
}
}GenericRepository.java
package com.itstyle.quartz.dynamicquery.Repository;
import java.io.Serializable;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.repository.NoRepositoryBean;
/**
*
*
* @param <T>
* @param <ID>
*/
@NoRepositoryBean
public interface GenericRepository<T, ID extends Serializable>
extends JpaRepository<T, ID>, JpaSpecificationExecutor<T> {
}QuartzConfigRepository.java
package com.itstyle.quartz.dynamicquery.Repository;
import org.springframework.stereotype.Repository;
import com.itstyle.quartz.entity.QuartzConfigModel;
import com.itstyle.quartz.entity.identity.QuartzConfigIdentity;
@Repository
public interface QuartzConfigRepository extends GenericRepository<QuartzConfigModel, QuartzConfigIdentity> {
}
QuartzConfigServiceImpl.java
package com.itstyle.quartz.dynamicquery.Service.Impl;
import java.util.ArrayList;
import java.util.List;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import com.itstyle.quartz.dynamicquery.Repository.QuartzConfigRepository;
import com.itstyle.quartz.dynamicquery.Service.GenericRepositoryServiceImpl;
import com.itstyle.quartz.dynamicquery.Service.QuartzConfigService;
import com.itstyle.quartz.entity.QuartzConfigModel;
import com.itstyle.quartz.entity.identity.QuartzConfigIdentity;
@SuppressWarnings("all")
@Service
public class QuartzConfigServiceImpl
extends GenericRepositoryServiceImpl<QuartzConfigModel, QuartzConfigIdentity, QuartzConfigRepository>
implements QuartzConfigService {
@Autowired
QuartzConfigRepository repository;
@Override
public List<QuartzConfigModel> findByCondition(String jobName, String jobGroup, Integer jobStatus) {
return findAll(findByConditionSpec(jobName, jobGroup, jobStatus));
}
private Specification<QuartzConfigModel> findByConditionSpec(String jobName, String jobGroup, Integer jobStatus) {
return new Specification<QuartzConfigModel>() {
@Override
public Predicate toPredicate(Root<QuartzConfigModel> root, CriteriaQuery<?> query,
CriteriaBuilder criteriaBuilder) {
List<Predicate> predicates = new ArrayList<Predicate>();
if (!StringUtils.isEmpty(jobName)) {
predicates.add(criteriaBuilder.and(criteriaBuilder.equal(root.get("id").get("jobName"), jobName)));
}
if (!StringUtils.isEmpty(jobGroup)) {
predicates
.add(criteriaBuilder.and(criteriaBuilder.equal(root.get("id").get("jobGroup"), jobGroup)));
}
if (jobStatus != null) {
predicates.add(criteriaBuilder.and(criteriaBuilder.equal(root.get("jobStatus"), jobStatus)));
}
query.where(predicates.toArray(new Predicate[predicates.size()]));
return query.getRestriction();
}
};
}
}
GenericRepositoryService.java
package com.itstyle.quartz.dynamicquery.Service;
import java.io.Serializable;
import java.util.HashMap;
import java.util.List;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;
import com.itstyle.quartz.dynamicquery.Repository.GenericRepository;
/**
*
*
* @param <CT>
* @param <KT>
* @param <RT>
*/
public interface GenericRepositoryService<CT, KT extends Serializable, RT extends GenericRepository<CT, KT>> {
List<CT> findAll();
Page<CT> findAll(Pageable pageable);
Page<CT> findAll(String searchTerm, Pageable pageable);
Page<CT> findAll(Specification<CT> spec, Pageable pageable);
List<CT> findAll(Specification<CT> spec);
CT findOne(KT id);
CT save(CT entity);
List<CT> save(List<CT> entities);
long count();
long count(Specification<CT> spec);
void delete(CT entity);
void delete(KT id);
void deleteAll();
void deleteInBatch(List<CT> entities);
CT saveAndFlush(CT entity);
boolean exists(KT id);
void executeQuery(String sqlString);
CT findOneByPrimaryKeyValue(String fieldName, Object value);
void executeNamedQuery(String sqlString);
void executeNamedQuery(String sqlString, HashMap<String, String> map);
CT findOne(Specification<CT> spec);
}
GenericRepositoryServiceImpl.java
package com.itstyle.quartz.dynamicquery.Service;
import java.io.Serializable;
import java.util.HashMap;
import java.util.List;
import java.util.Optional;
import javax.persistence.LockModeType;
import org.hibernate.exception.ConstraintViolationException;
import org.hibernate.id.IdentifierGenerationException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.data.jpa.repository.Lock;
import org.springframework.transaction.annotation.Transactional;
import com.itstyle.quartz.dynamicquery.Repository.GenericRepository;
public abstract class GenericRepositoryServiceImpl<CT, KT extends Serializable, RT extends GenericRepository<CT, KT>>
implements GenericRepositoryService<CT, KT, RT> {
private final Logger LOGGER = LoggerFactory.getLogger(getClass());
@Autowired
private GenericRepository<CT, KT> repository;
@Override
public List<CT> findAll() {
LOGGER.debug("findAll");
return repository.findAll();
}
@Override
public Page<CT> findAll(Pageable pageable) {
LOGGER.debug("findAll");
return repository.findAll(pageable);
}
@Override
public Page<CT> findAll(String searchTerm, Pageable pageable) {
return null;
}
@Override
public Page<CT> findAll(Specification<CT> spec, Pageable pageable) {
LOGGER.debug("findAll->Specification:{}, Pageable:{}", spec, pageable);
return repository.findAll(spec, pageable);
}
@Override
public List<CT> findAll(Specification<CT> spec) {
LOGGER.debug("findAll->Specification:{}", spec);
return repository.findAll(spec);
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public CT save(CT entity) {
LOGGER.debug("GenericRepositoryService#save");
try {
return repository.save(entity);
} catch (IdentifierGenerationException e) {
// 未定義資料主鍵值
} catch (ConstraintViolationException e) {
// 外來鍵關聯資料不存在
}
return null;
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public List<CT> save(List<CT> entities) {
LOGGER.debug("GenericRepositoryService#save");
try {
return repository.saveAll(entities);
} catch (IdentifierGenerationException e) {
// 未定義資料主鍵值
} catch (ConstraintViolationException e) {
// 外來鍵關聯資料不存在
} catch (IllegalArgumentException e) {
// 非法引數異常
}
return null;
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public CT saveAndFlush(CT entity) {
LOGGER.debug("saveAndFlush");
return repository.saveAndFlush(entity);
}
@Override
// @Transactional(readOnly = true)
public long count() {
LOGGER.debug("count");
return repository.count();
}
@Override
// @Transactional(readOnly = true)
public long count(Specification<CT> spec) {
LOGGER.debug("count");
return repository.count(spec);
}
@Override
// @Transactional(readOnly = true)
public boolean exists(KT id) {
LOGGER.debug("exists");
return repository.existsById(id);
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public void delete(CT entity) {
LOGGER.debug("delete# Parameter:{}", entity);
if (entity != null) {
repository.delete(entity);
}
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public void delete(KT id) {
LOGGER.debug("delete# Parameter:{}", id);
repository.deleteById(id);
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public void deleteAll() {
LOGGER.debug("deleteAll");
repository.deleteAll();
}
@Override
@Transactional
@Lock(LockModeType.WRITE)
public void deleteInBatch(List<CT> entities) {
LOGGER.debug("deleteInBatch");
repository.deleteInBatch(entities);
}
@Override
public void executeQuery(String sqlString) {
}
@Override
public void executeNamedQuery(String sqlString) {
}
@Override
public void executeNamedQuery(String sqlString, HashMap<String, String> map) {
}
@Override
public CT findOne(KT id) {
LOGGER.debug("GenericRepositoryService#findOne(KT)");
Optional<CT> bean = repository.findById(id);
if (bean.isPresent()) {
return bean.get();
} else {
return null;
}
// return repository.findById(id).get();
}
@Override
public CT findOneByPrimaryKeyValue(String fieldName, Object value) {
return null;
}
@Override
public CT findOne(Specification<CT> spec) {
Optional<CT> option = repository.findOne(spec);
if (option.isPresent()) {
return option.get();
} else {
return null;
}
}
}
QuartzConfigService.java
package com.itstyle.quartz.dynamicquery.Service;
import java.util.List;
import com.itstyle.quartz.dynamicquery.Repository.QuartzConfigRepository;
import com.itstyle.quartz.entity.QuartzConfigModel;
import com.itstyle.quartz.entity.identity.QuartzConfigIdentity;
public interface QuartzConfigService
extends GenericRepositoryService<QuartzConfigModel, QuartzConfigIdentity, QuartzConfigRepository> {
List<QuartzConfigModel> findByCondition(String jobName, String jobGroup, Integer jobStatus);
}
QuartzConfigIdentity.java
package com.itstyle.quartz.entity.identity;
import java.io.Serializable;
import javax.persistence.Column;
import javax.persistence.Embeddable;
@Embeddable
public class QuartzConfigIdentity implements Serializable {
/**
*
*/
private static final long serialVersionUID = -6107873034694904498L;
@Column(name = "JOB_NAME")
private String jobName;// 任務名稱
@Column(name = "JOB_GROUP")
private String jobGroup;// 任務分組
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
public QuartzConfigIdentity(String jobName, String jobGroup) {
super();
this.jobName = jobName;
this.jobGroup = jobGroup;
}
public QuartzConfigIdentity() {
super();
// TODO Auto-generated constructor stub
}
}
QuartzConfigModel.java
package com.itstyle.quartz.entity;
import java.io.Serializable;
import java.util.Date;
import javax.persistence.Column;
import javax.persistence.EmbeddedId;
import javax.persistence.Entity;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
import javax.persistence.Table;
import com.itstyle.quartz.entity.identity.QuartzConfigIdentity;
/**
* 任務類 建立者
*/
@Entity
@Table(name = "QUARTZ_CONFIG")
public class QuartzConfigModel implements Serializable {
/**
*
*/
private static final long serialVersionUID = 2001992304078127000L;
@EmbeddedId
private QuartzConfigIdentity id;
@Column(name = "JOB_DESCRIPTION")
private String jobDescription;// 任務描述
@Column(name = "CRON_EXPRESSION")
private String cronExpression;// 執行時間
@Column(name = "JOB_STATUS")
private Integer jobStatus;// 任務狀態
@Column(name = "CREATE_TIME")
private Date createTime;// 建立時間
@Column(name = "UPDATE_TIME")
private Date updateTime;// 更新時間
@Column(name = "CREATE_USER")
private String createUser;// 建立者
@Column(name = "TASK_PARAMETER")
private String taskParameter;
public String getTaskParameter() {
return taskParameter;
}
public void setTaskParameter(String taskParameter) {
this.taskParameter = taskParameter;
}
public String getJobDescription() {
return jobDescription;
}
public void setJobDescription(String jobDescription) {
this.jobDescription = jobDescription;
}
public String getCronExpression() {
return cronExpression;
}
public void setCronExpression(String cronExpression) {
this.cronExpression = cronExpression;
}
public Integer getJobStatus() {
return jobStatus;
}
public void setJobStatus(Integer jobStatus) {
this.jobStatus = jobStatus;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
public String getCreateUser() {
return createUser;
}
public void setCreateUser(String createUser) {
this.createUser = createUser;
}
public QuartzConfigIdentity getId() {
return id;
}
public void setId(QuartzConfigIdentity id) {
this.id = id;
}
@PrePersist
public void save() {
createTime = new Date();
jobStatus = 0;
}
@PreUpdate
public void update() {
updateTime = new Date();
}
}
ResponseData.java
package com.itstyle.quartz.entity;
import org.springframework.http.ResponseEntity;
public class ResponseData<T> {
public int code;
public Boolean success;
public T data;
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public Boolean getSuccess() {
return success;
}
public void setSuccess(Boolean success) {
this.success = success;
}
public ResponseData() {
super();
this.code = 0;
this.success = Boolean.TRUE;
}
public ResponseData(T data) {
super();
this.code = 0;
this.success = Boolean.TRUE;
this.data = data;
}
public ResponseData(int code, Boolean success, T data) {
super();
this.code = code;
this.success = success;
this.data = data;
}
public static <T> ResponseEntity<?> ok() {
return ResponseEntity.ok(new ResponseData());
}
public static <T> ResponseEntity<?> ok(T data) {
return ResponseEntity.ok(new ResponseData(data));
}
public static ResponseEntity<?> error() {
return ResponseEntity.ok(new ResponseData(-1, false, null));
}
public static ResponseEntity<?> error(String errorCode) {
return ResponseEntity.ok(new ResponseData(-1, false, errorCode));
}
public static ResponseEntity<?> error(Throwable t) {
return ResponseEntity.ok(new ResponseData(-1, false, t));
}
}
DynamicQuartzJob.java
package com.itstyle.quartz.job;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.PersistJobDataAfterExecution;
import org.quartz.impl.JobDetailImpl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.util.StringUtils;
/**
* 動態定時任務Job
*
* @author linrx1
*
*/
@PersistJobDataAfterExecution
@DisallowConcurrentExecution // 不允許併發執行
public class DynamicQuartzJob extends QuartzJobBean {
private static final Logger logger = LoggerFactory.getLogger(DynamicQuartzJob.class);
@Autowired
private ApplicationContext applicationContext;
@Override
protected void executeInternal(JobExecutionContext jobexecutioncontext) throws JobExecutionException {
// use JobDetailImpl replace JobDetail for get jobName
JobDetailImpl jobDetail = (JobDetailImpl) jobexecutioncontext.getJobDetail();
String name = jobDetail.getName();
if (StringUtils.isEmpty(name)) {
throw new JobExecutionException("can not find service info, because desription is empty");
}
String[] serviceInfo = name.split("\\.");
// serviceInfo[0] is JOB_NAME_PREFIX
String beanName = serviceInfo[1];
String methodName = serviceInfo[2];
Object serviceImpl = applicationContext.getBean(beanName);
JobDataMap dataMap = jobDetail.getJobDataMap();
Method method;
try {
Class<?> clazz = serviceImpl.getClass();
Method[] methods = clazz.getDeclaredMethods();
Class<?>[] parameterTypes = null;
for (Method n : methods) {
if (methodName.equals(n.getName())) {
parameterTypes = n.getParameterTypes();
}
}
Object[] array = parameterTypeConvert(parameterTypes, dataMap.get("data"));
method = serviceImpl.getClass().getMethod(methodName, parameterTypes);
logger.info("dynamic invoke {}.{}()", serviceImpl.getClass().getName(), methodName);
System.out.println(parameterTypes[0]);
method.invoke(serviceImpl, array);
} catch (NoSuchMethodException | SecurityException | IllegalAccessException | IllegalArgumentException
| InvocationTargetException e) {
logger.error("reflect invoke service method error", e);
}
}
private Object[] parameterTypeConvert(Class<?>[] parameterTypes, Object obj) {
Object[] temp = new Object[parameterTypes.length];
String[] array = (String[]) obj;
for (int i = 0; i < parameterTypes.length; i++) {
if (parameterTypes[i].toString().equals("class java.lang.String")) {
System.out.println("String");
temp[i] = String.valueOf(array[i]);
}
if (parameterTypes[i].toString().equals("class java.lang.Integer")) {
System.out.println("Integer");
temp[i] = Integer.valueOf(array[i]);
}
if (parameterTypes[i].toString().equals("class java.lang.Double")) {
System.out.println("Double");
temp[i] = Double.valueOf(array[i]);
}
}
return temp;
}
}
AddJobRequest.java
package com.itstyle.quartz.request;
public class AddJobRequest {
private String jobName;// 任務名稱
private String jobGroup;// 任務分組
private String jobDescription;// 任務描述
private String cronExpression;// 執行時間
private String taskParameter;
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
public String getJobDescription() {
return jobDescription;
}
public void setJobDescription(String jobDescription) {
this.jobDescription = jobDescription;
}
public String getCronExpression() {
return cronExpression;
}
public void setCronExpression(String cronExpression) {
this.cronExpression = cronExpression;
}
public String getTaskParameter() {
return taskParameter;
}
public void setTaskParameter(String taskParameter) {
this.taskParameter = taskParameter;
}
}
FindAllJobRequest.java
package com.itstyle.quartz.request;
public class FindAllJobRequest {
private Integer pageSize;
private Integer pageNo;
public Integer getPageSize() {
return pageSize;
}
public void setPageSize(Integer pageSize) {
this.pageSize = pageSize;
}
public Integer getPageNo() {
return pageNo;
}
public void setPageNo(Integer pageNo) {
this.pageNo = pageNo;
}
}
PauseAndResumeRequest.java
package com.itstyle.quartz.request;
public class PauseAndResumeRequest {
private String jobName;// 任務名稱
private String jobGroup;// 任務分組
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
}
RemoveJobRequest.java
package com.itstyle.quartz.request;
public class RemoveJobRequest {
private String jobName;
private String jobGroup;
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
}
TriggerRequest.java
package com.itstyle.quartz.request;
public class TriggerRequest {
private String jobName;
private String jobGroup;
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
}
HelloService.java
package com.itstyle.quartz.service;
import org.springframework.stereotype.Service;
@Service
public class HelloService {
public void sayHello(String aa, Integer bb) {
System.out.format("%s %d", aa, bb);
}
}
JobController.java
package com.itstyle.quartz.web;
import javax.annotation.Resource;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import com.itstyle.quartz.dynamicquery.Service.QuartzConfigService;
import com.itstyle.quartz.entity.ResponseData;
import com.itstyle.quartz.request.AddJobRequest;
import com.itstyle.quartz.request.FindAllJobRequest;
import com.itstyle.quartz.request.PauseAndResumeRequest;
import com.itstyle.quartz.request.RemoveJobRequest;
import com.itstyle.quartz.request.TriggerRequest;
@RestController
public class JobController {
private final static Logger LOGGER = LoggerFactory.getLogger(JobController.class);
@Resource
Scheduler scheduler;
@Resource
QuartzConfigService quartzConfigService;
@Resource
JobService jobService;
@PostMapping("/add")
public ResponseEntity<?> addJob(@RequestBody AddJobRequest req) throws Exception {
LOGGER.info("add quartz job");
String result = jobService.addjob(req.getJobName(), req.getJobGroup(), req.getCronExpression(),
req.getJobDescription(), req.getTaskParameter());
return ResponseData.ok(result);
}
@PostMapping("/list")
public ResponseEntity<?> findAllJob(@RequestBody FindAllJobRequest req) {
LOGGER.info("任務列表");
Page page = quartzConfigService.findAll(PageRequest.of(req.getPageNo(), req.getPageSize()));
return ResponseData.ok(page);
}
@PostMapping("/trigger")
public ResponseEntity<?> trigger(@RequestBody TriggerRequest req) throws Exception {
LOGGER.info("觸發任務");
String result = jobService.triggerJob(req.getJobName(), req.getJobGroup());
return ResponseData.ok(result);
}
@PostMapping("/remove")
public ResponseEntity<?> remove(@RequestBody RemoveJobRequest req) throws SchedulerException {
LOGGER.info("移除任務");
String result = jobService.deleteJob(req.getJobName(), req.getJobGroup());
return ResponseData.ok(result);
}
@PostMapping("/pause")
public ResponseEntity<?> pause(@RequestBody PauseAndResumeRequest req) throws SchedulerException {
LOGGER.info("停止任務");
String result = jobService.pause(req.getJobName(), req.getJobGroup());
return ResponseData.ok(result);
}
@PostMapping("/resume")
public ResponseEntity<?> resume(@RequestBody PauseAndResumeRequest req) throws SchedulerException {
LOGGER.info("恢復任務");
String result = jobService.resume(req.getJobName(), req.getJobGroup());
return ResponseData.ok(result);
}
}
JobService.java
package com.itstyle.quartz.web;
import java.security.Principal;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.transaction.Transactional;
import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import com.itstyle.quartz.dynamicquery.Service.QuartzConfigService;
import com.itstyle.quartz.entity.QuartzConfigModel;
import com.itstyle.quartz.entity.identity.QuartzConfigIdentity;
@Service
@SuppressWarnings("all")
public class JobService {
private final Logger logger = LoggerFactory.getLogger(getClass());
private final String JOBCLASSNAME = "com.itstyle.quartz.job.DynamicQuartzJob";
private final Integer VALID = 0;
private final Integer INVALID = 1;
@Resource
ApplicationContext applicationContext;
@Resource
Scheduler scheduler;
@Resource
QuartzConfigService quartzConfigService;
@Transactional
public String pause(String jobName, String jobGroup) throws SchedulerException {
JobKey key = new JobKey(jobName, jobGroup);
if (scheduler.checkExists(key)) {
scheduler.pauseJob(key);
QuartzConfigModel quartzConfigModel = quartzConfigService
.findOne(new QuartzConfigIdentity(jobName, jobGroup));
quartzConfigModel.setJobStatus(INVALID);
quartzConfigService.save(quartzConfigModel);
return "ok";
} else {
return "任務不存在";
}
}
@Transactional
public String resume(String jobName, String jobGroup) throws SchedulerException {
JobKey key = new JobKey(jobName, jobGroup);
if (scheduler.checkExists(key)) {
scheduler.resumeJob(key);
QuartzConfigModel quartzConfigModel = quartzConfigService
.findOne(new QuartzConfigIdentity(jobName, jobGroup));
quartzConfigModel.setJobStatus(VALID);
quartzConfigService.save(quartzConfigModel);
return "ok";
} else {
return "任務不存在";
}
}
public String triggerJob(String jobName, String jobGroup) throws Exception {
JobKey jobKey = new JobKey(jobName, jobGroup);
if (scheduler.checkExists(jobKey)) {
scheduler.triggerJob(jobKey);
return "ok";
} else {
return "任務不存在";
}
}
@Transactional
public String addjob(String jobName, String jobGroup, String cronExpression, String jobDescription,
String taskParameter) throws Exception {
JobKey jobKey = new JobKey(jobName, jobGroup);
boolean isExists = scheduler.checkExists(jobKey);
if (isExists) {
return "已存在";
}
startJob(jobName, jobGroup, jobDescription, taskParameter, cronExpression);
saveQuartzConfigMoel(jobName, jobGroup, cronExpression, jobDescription, taskParameter);
return null;
}
@Transactional
public String deleteJob(String jobName, String jobGroup) throws SchedulerException {
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
// ‘停止觸發器
if (scheduler.checkExists(triggerKey)) {
scheduler.pauseTrigger(triggerKey);
// ’ 移除觸發器
scheduler.unscheduleJob(triggerKey);
}
JobKey jobKey = new JobKey(jobName, jobGroup);
if (scheduler.checkExists(jobKey)) {
// ‘刪除任務
scheduler.deleteJob(jobKey);
quartzConfigService.delete(new QuartzConfigIdentity(jobName, jobGroup));
return "ok";
} else {
return "任務不存在";
}
}
public void startJob(String jobName, String jobGroup, String description, String taskParameter,
String cronExpression) throws Exception {
Class cls = Class.forName(JOBCLASSNAME);
cls.newInstance();
JobDetail jobDetail = JobBuilder.newJob(cls).withIdentity(jobName, jobGroup).withDescription(description)
.build();
jobDetail.getJobDataMap().put("data", taskParameter.split(","));
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroup).startNow()
.withSchedule(cronScheduleBuilder).build();
scheduler.scheduleJob(jobDetail, trigger);
}
private void saveQuartzConfigMoel(String jobName, String jobGroup, String cronExpression, String jobDescription,
String taskParameter) {
QuartzConfigModel quartzConfigModel = new QuartzConfigModel();
QuartzConfigIdentity id = new QuartzConfigIdentity(jobName, jobGroup);
quartzConfigModel.setId(id);
quartzConfigModel.setCronExpression(cronExpression);
quartzConfigModel.setJobDescription(jobDescription);
quartzConfigModel.setTaskParameter(taskParameter);
HttpServletRequest req = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
quartzConfigModel.setCreateUser(getHttpRequestUserGid(req));
quartzConfigService.save(quartzConfigModel);
}
/**
* 獲取token中的使用者
*
* @param request HttpServletRequest情報
* @return
*/
private String getHttpRequestUserGid(HttpServletRequest request) {
Principal principal = request.getUserPrincipal();
if (principal == null) {
return "";
} else {
String userName = principal.getName();
if (userName != null && userName.indexOf("@") > 0) {
return userName.split("@")[0];
} else {
return userName;
}
}
}
}
DateToCronUtil.java
//轉化date到cron package com.itstyle.quartz; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import org.quartz.CronExpression; public class DateToCronUtil { private static final String DATEFORMAT = "ss mm HH dd MM ? yyyy"; /*** * * @param date * @param dateFormat : e.g:yyyy-MM-dd HH:mm:ss * @return * @throws ParseException */ public static String formatDateByPattern(Date date, String dateFormat) throws ParseException { SimpleDateFormat sdf = new SimpleDateFormat(dateFormat); String formatTimeStr = null; if (date != null) { formatTimeStr = sdf.format(date); } if (checkCronValid(formatTimeStr, date)) { return formatTimeStr; } else { return "輸入有效日期"; } } /*** * convert Date to cron ,eg. "0 06 10 15 1 ? 2014" * * @param date : 時間點 * @return * @throws ParseException */ public static String getCron(Date date) throws ParseException { return formatDateByPattern(date, DATEFORMAT); } /** * 驗證是否有效的cron表示式 * * @param cron * @param date * @throws ParseException */ private static boolean checkCronValid(String cron, Date date) throws ParseException { CronExpression cronExpression = new CronExpression(cron); return cronExpression.isSatisfiedBy(date); } // public static void main(String[] args) throws ParseException { // System.out.println(getCron(new Date())); // } }
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數====================================================================
========================================部落格園對於程式碼塊中的文字不算字數================================================================