feat: 阉割quartz定时任务功能
This commit is contained in:
parent
e5f8128c08
commit
5f318c2942
|
|
@ -16,7 +16,6 @@
|
||||||
- 岗位管理：配置各个部门的职位
|
- 岗位管理：配置各个部门的职位
|
||||||
- 字典管理：可维护常用一些固定的数据，如：状态，性别等
|
- 字典管理：可维护常用一些固定的数据，如：状态，性别等
|
||||||
- SQL监控：采用druid 监控数据库访问性能，默认用户名admin，密码123456
|
- SQL监控：采用druid 监控数据库访问性能，默认用户名admin，密码123456
|
||||||
- 定时任务：整合Quartz做定时任务，加入任务日志，任务运行情况一目了然
|
|
||||||
- 邮件工具：配合富文本，发送html格式的邮件
|
- 邮件工具：配合富文本，发送html格式的邮件
|
||||||
- 服务监控：监控服务器的负载情况
|
- 服务监控：监控服务器的负载情况
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -49,12 +49,6 @@
|
||||||
<version>${jjwt.version}</version>
|
<version>${jjwt.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- quartz -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.quartz-scheduler</groupId>
|
|
||||||
<artifactId>quartz</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- linux的管理 -->
|
<!-- linux的管理 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>ch.ethz.ganymed</groupId>
|
<groupId>ch.ethz.ganymed</groupId>
|
||||||
|
|
|
||||||
|
|
@ -1,34 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.context;
|
|
||||||
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.mapper.QuartzJobMapper;
|
|
||||||
import cn.odboy.modules.quartz.util.QuartzManage;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
import org.springframework.boot.ApplicationArguments;
|
|
||||||
import org.springframework.boot.ApplicationRunner;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class JobRunner implements ApplicationRunner {
|
|
||||||
private static final Logger log = LoggerFactory.getLogger(JobRunner.class);
|
|
||||||
private final QuartzJobMapper quartzJobMapper;
|
|
||||||
private final QuartzManage quartzManage;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 项目启动时重新激活启用的定时任务
|
|
||||||
*
|
|
||||||
* @param applicationArguments /
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void run(ApplicationArguments applicationArguments) {
|
|
||||||
List<QuartzJob> quartzJobs = quartzJobMapper.findByIsPauseIsFalse();
|
|
||||||
quartzJobs.forEach(quartzManage::addJob);
|
|
||||||
log.info("Timing task injection complete");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,35 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.context;
|
|
||||||
|
|
||||||
import org.quartz.spi.TriggerFiredBundle;
|
|
||||||
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.scheduling.quartz.AdaptableJobFactory;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务配置
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
public class QuartzConfig {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 解决Job中注入Spring Bean为null的问题
|
|
||||||
*/
|
|
||||||
@Component("quartzJobFactory")
|
|
||||||
public static class QuartzJobFactory extends AdaptableJobFactory {
|
|
||||||
|
|
||||||
private final AutowireCapableBeanFactory capableBeanFactory;
|
|
||||||
|
|
||||||
public QuartzJobFactory(AutowireCapableBeanFactory capableBeanFactory) {
|
|
||||||
this.capableBeanFactory = capableBeanFactory;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
|
|
||||||
//调用父类的方法，把Job注入到spring中
|
|
||||||
Object jobInstance = super.createJobInstance(bundle);
|
|
||||||
capableBeanFactory.autowireBean(jobInstance);
|
|
||||||
return jobInstance;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,91 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.domain;
|
|
||||||
|
|
||||||
import cn.odboy.base.MyEntity;
|
|
||||||
import com.baomidou.mybatisplus.annotation.IdType;
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableField;
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableId;
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableName;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
import javax.validation.constraints.NotBlank;
|
|
||||||
import javax.validation.constraints.NotNull;
|
|
||||||
import java.sql.Timestamp;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Getter
|
|
||||||
@Setter
|
|
||||||
@TableName("system_quartz_job")
|
|
||||||
public class QuartzJob extends MyEntity {
|
|
||||||
public static final String JOB_KEY = "QUARTZ_JOB_KEY";
|
|
||||||
|
|
||||||
@TableId(value = "id", type = IdType.AUTO)
|
|
||||||
@NotNull(groups = {Update.class})
|
|
||||||
private Long id;
|
|
||||||
/**
|
|
||||||
* 所属模块
|
|
||||||
*/
|
|
||||||
private String moduleName;
|
|
||||||
/**
|
|
||||||
* 用于子任务唯一标识
|
|
||||||
*/
|
|
||||||
@TableField(exist = false)
|
|
||||||
private String uuid;
|
|
||||||
/**
|
|
||||||
* 定时器名称
|
|
||||||
*/
|
|
||||||
private String jobName;
|
|
||||||
/**
|
|
||||||
* Bean名称
|
|
||||||
*/
|
|
||||||
@NotBlank
|
|
||||||
private String beanName;
|
|
||||||
/**
|
|
||||||
* 方法名称
|
|
||||||
*/
|
|
||||||
@NotBlank
|
|
||||||
private String methodName;
|
|
||||||
/**
|
|
||||||
* 参数
|
|
||||||
*/
|
|
||||||
private String params;
|
|
||||||
/**
|
|
||||||
* cron表达式
|
|
||||||
*/
|
|
||||||
@NotBlank
|
|
||||||
private String cronExpression;
|
|
||||||
/**
|
|
||||||
* 状态，暂时或启动
|
|
||||||
*/
|
|
||||||
private Boolean isPause = false;
|
|
||||||
/**
|
|
||||||
* 负责人
|
|
||||||
*/
|
|
||||||
private String personInCharge;
|
|
||||||
/**
|
|
||||||
* 报警邮箱
|
|
||||||
*/
|
|
||||||
private String email;
|
|
||||||
/**
|
|
||||||
* 子任务
|
|
||||||
*/
|
|
||||||
private String subTask;
|
|
||||||
/**
|
|
||||||
* 失败后暂停
|
|
||||||
*/
|
|
||||||
private Boolean pauseAfterFailure;
|
|
||||||
/**
|
|
||||||
* 备注
|
|
||||||
*/
|
|
||||||
@NotBlank
|
|
||||||
private String description;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
public static class QueryArgs {
|
|
||||||
private String jobName;
|
|
||||||
private String moduleName;
|
|
||||||
private Boolean isSuccess;
|
|
||||||
private List<Timestamp> createTime;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,53 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.domain;
|
|
||||||
|
|
||||||
import cn.odboy.base.MyObject;
|
|
||||||
import com.baomidou.mybatisplus.annotation.*;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.EqualsAndHashCode;
|
|
||||||
|
|
||||||
import java.sql.Timestamp;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
@EqualsAndHashCode(callSuper = false)
|
|
||||||
@TableName("system_quartz_log")
|
|
||||||
public class QuartzLog extends MyObject {
|
|
||||||
@TableId(value = "id", type = IdType.AUTO)
|
|
||||||
private Long id;
|
|
||||||
/**
|
|
||||||
* 任务名称
|
|
||||||
*/
|
|
||||||
private String jobName;
|
|
||||||
/**
|
|
||||||
* bean名称
|
|
||||||
*/
|
|
||||||
private String beanName;
|
|
||||||
/**
|
|
||||||
* 方法名称
|
|
||||||
*/
|
|
||||||
private String methodName;
|
|
||||||
/**
|
|
||||||
* 参数
|
|
||||||
*/
|
|
||||||
private String params;
|
|
||||||
/**
|
|
||||||
* cron表达式
|
|
||||||
*/
|
|
||||||
private String cronExpression;
|
|
||||||
/**
|
|
||||||
* 状态
|
|
||||||
*/
|
|
||||||
private Boolean isSuccess;
|
|
||||||
/**
|
|
||||||
* 异常详情
|
|
||||||
*/
|
|
||||||
private String exceptionDetail;
|
|
||||||
/**
|
|
||||||
* 执行耗时
|
|
||||||
*/
|
|
||||||
private Long time;
|
|
||||||
/**
|
|
||||||
* 创建时间
|
|
||||||
*/
|
|
||||||
@TableField(fill = FieldFill.INSERT)
|
|
||||||
private Timestamp createTime;
|
|
||||||
}
|
|
||||||
|
|
@ -1,24 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.mapper;
|
|
||||||
|
|
||||||
import cn.odboy.base.model.SelectOption;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
|
||||||
import org.apache.ibatis.annotations.Param;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
|
|
||||||
@Mapper
|
|
||||||
public interface QuartzJobMapper extends BaseMapper<QuartzJob> {
|
|
||||||
|
|
||||||
IPage<QuartzJob> findAll(@Param("criteria") QuartzJob.QueryArgs criteria, Page<Object> page);
|
|
||||||
|
|
||||||
List<QuartzJob> findAll(@Param("criteria") QuartzJob.QueryArgs criteria);
|
|
||||||
|
|
||||||
List<QuartzJob> findByIsPauseIsFalse();
|
|
||||||
|
|
||||||
List<SelectOption> findQuartzJobModuleOptions();
|
|
||||||
}
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.mapper;
|
|
||||||
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzLog;
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
|
||||||
import org.apache.ibatis.annotations.Param;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
|
|
||||||
@Mapper
|
|
||||||
public interface QuartzLogMapper extends BaseMapper<QuartzLog> {
|
|
||||||
|
|
||||||
IPage<QuartzLog> findAll(@Param("criteria") QuartzJob.QueryArgs criteria, Page<Object> page);
|
|
||||||
|
|
||||||
List<QuartzLog> findAll(@Param("criteria") QuartzJob.QueryArgs criteria);
|
|
||||||
}
|
|
||||||
|
|
@ -1,132 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.rest;
|
|
||||||
|
|
||||||
import cn.odboy.infra.context.SpringContextHolder;
|
|
||||||
import cn.odboy.infra.exception.BadRequestException;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.service.QuartzJobService;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.http.HttpStatus;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.security.access.prepost.PreAuthorize;
|
|
||||||
import org.springframework.validation.annotation.Validated;
|
|
||||||
import org.springframework.web.bind.annotation.*;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 系统：定时任务管理
|
|
||||||
* @author odboy
|
|
||||||
* @date 2024-12-03
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@RestController
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
@RequestMapping("/api/jobs")
|
|
||||||
public class QuartzJobController {
|
|
||||||
private final QuartzJobService quartzJobService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询定时任务
|
|
||||||
*/
|
|
||||||
@GetMapping
|
|
||||||
@PreAuthorize("@el.check('timing:list')")
|
|
||||||
public ResponseEntity<Object> queryQuartzJob(QuartzJob.QueryArgs criteria, Page<Object> page) {
|
|
||||||
return new ResponseEntity<>(quartzJobService.queryAll(criteria, page), HttpStatus.OK);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 导出任务数据
|
|
||||||
*/
|
|
||||||
@GetMapping(value = "/download")
|
|
||||||
@PreAuthorize("@el.check('timing:list')")
|
|
||||||
public void exportQuartzJob(HttpServletResponse response, QuartzJob.QueryArgs criteria) throws IOException {
|
|
||||||
quartzJobService.download(quartzJobService.queryAll(criteria), response);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 导出日志数据
|
|
||||||
*/
|
|
||||||
@GetMapping(value = "/logs/download")
|
|
||||||
@PreAuthorize("@el.check('timing:list')")
|
|
||||||
public void exportQuartzJobLog(HttpServletResponse response, QuartzJob.QueryArgs criteria) throws IOException {
|
|
||||||
quartzJobService.downloadLog(quartzJobService.queryAllLog(criteria), response);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 查询任务执行日志
|
|
||||||
*/
|
|
||||||
@GetMapping(value = "/logs")
|
|
||||||
@PreAuthorize("@el.check('timing:list')")
|
|
||||||
public ResponseEntity<Object> queryQuartzJobLog(QuartzJob.QueryArgs criteria, Page<Object> page) {
|
|
||||||
return new ResponseEntity<>(quartzJobService.queryAllLog(criteria, page), HttpStatus.OK);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 查询任务模块类型
|
|
||||||
*/
|
|
||||||
@GetMapping(value = "/modules")
|
|
||||||
@PreAuthorize("@el.check('timing:list')")
|
|
||||||
public ResponseEntity<Object> queryQuartzJobModules() {
|
|
||||||
return new ResponseEntity<>(quartzJobService.queryQuartzJobModules(), HttpStatus.OK);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 新增定时任务
|
|
||||||
*/
|
|
||||||
@PostMapping
|
|
||||||
@PreAuthorize("@el.check('timing:add')")
|
|
||||||
public ResponseEntity<Object> createQuartzJob(@Validated @RequestBody QuartzJob resources) {
|
|
||||||
if (resources.getId() != null) {
|
|
||||||
throw new BadRequestException("A new " + QuartzJob.class.getSimpleName() + " cannot already have an ID");
|
|
||||||
}
|
|
||||||
// 验证Bean是不是合法的，合法的定时任务 Bean 需要用 @Service 定义
|
|
||||||
checkBean(resources.getBeanName());
|
|
||||||
quartzJobService.create(resources);
|
|
||||||
return new ResponseEntity<>(HttpStatus.CREATED);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 修改定时任务
|
|
||||||
*/
|
|
||||||
@PutMapping
|
|
||||||
@PreAuthorize("@el.check('timing:edit')")
|
|
||||||
public ResponseEntity<Object> updateQuartzJob(@Validated(QuartzJob.Update.class) @RequestBody QuartzJob resources) {
|
|
||||||
// 验证Bean是不是合法的，合法的定时任务 Bean 需要用 @Service 定义
|
|
||||||
checkBean(resources.getBeanName());
|
|
||||||
quartzJobService.update(resources);
|
|
||||||
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 更改定时任务状态
|
|
||||||
*/
|
|
||||||
@PutMapping(value = "/{id}")
|
|
||||||
@PreAuthorize("@el.check('timing:edit')")
|
|
||||||
public ResponseEntity<Object> updateQuartzJobStatus(@PathVariable Long id) {
|
|
||||||
quartzJobService.updateIsPause(quartzJobService.getById(id));
|
|
||||||
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 执行定时任务
|
|
||||||
*/
|
|
||||||
@PutMapping(value = "/exec/{id}")
|
|
||||||
@PreAuthorize("@el.check('timing:edit')")
|
|
||||||
public ResponseEntity<Object> executionQuartzJob(@PathVariable Long id) {
|
|
||||||
quartzJobService.execution(quartzJobService.getById(id));
|
|
||||||
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* 删除定时任务
|
|
||||||
*/
|
|
||||||
@DeleteMapping
|
|
||||||
@PreAuthorize("@el.check('timing:del')")
|
|
||||||
public ResponseEntity<Object> deleteQuartzJob(@RequestBody Set<Long> ids) {
|
|
||||||
quartzJobService.delete(ids);
|
|
||||||
return new ResponseEntity<>(HttpStatus.OK);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void checkBean(String beanName) {
|
|
||||||
// 避免调用攻击者可以从SpringContextHolder获得控制jdbcTemplate类
|
|
||||||
// 并使用getDeclaredMethod调用jdbcTemplate的queryForMap函数，执行任意sql命令。
|
|
||||||
if (!SpringContextHolder.getAllServiceBeanName().contains(beanName)) {
|
|
||||||
throw new BadRequestException("非法的 Bean，请重新输入！");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,114 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.service;
|
|
||||||
|
|
||||||
import cn.odboy.base.model.SelectOption;
|
|
||||||
import cn.odboy.infra.response.PageResult;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzLog;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
|
|
||||||
public interface QuartzJobService extends IService<QuartzJob> {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 分页查询
|
|
||||||
*
|
|
||||||
* @param criteria 条件
|
|
||||||
* @param page 分页参数
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
PageResult<QuartzJob> queryAll(QuartzJob.QueryArgs criteria, Page<Object> page);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询全部
|
|
||||||
*
|
|
||||||
* @param criteria 条件
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
List<QuartzJob> queryAll(QuartzJob.QueryArgs criteria);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 分页查询日志
|
|
||||||
*
|
|
||||||
* @param criteria 条件
|
|
||||||
* @param page 分页参数
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
PageResult<QuartzLog> queryAllLog(QuartzJob.QueryArgs criteria, Page<Object> page);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询全部
|
|
||||||
*
|
|
||||||
* @param criteria 条件
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
List<QuartzLog> queryAllLog(QuartzJob.QueryArgs criteria);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建
|
|
||||||
*
|
|
||||||
* @param resources /
|
|
||||||
*/
|
|
||||||
void create(QuartzJob resources);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 编辑
|
|
||||||
*
|
|
||||||
* @param resources /
|
|
||||||
*/
|
|
||||||
void update(QuartzJob resources);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务
|
|
||||||
*
|
|
||||||
* @param ids /
|
|
||||||
*/
|
|
||||||
void delete(Set<Long> ids);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更改定时任务状态
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
void updateIsPause(QuartzJob quartzJob);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 立即执行定时任务
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
void execution(QuartzJob quartzJob);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出定时任务
|
|
||||||
*
|
|
||||||
* @param queryAll 待导出的数据
|
|
||||||
* @param response /
|
|
||||||
* @throws IOException /
|
|
||||||
*/
|
|
||||||
void download(List<QuartzJob> queryAll, HttpServletResponse response) throws IOException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出定时任务日志
|
|
||||||
*
|
|
||||||
* @param queryAllLog 待导出的数据
|
|
||||||
* @param response /
|
|
||||||
* @throws IOException /
|
|
||||||
*/
|
|
||||||
void downloadLog(List<QuartzLog> queryAllLog, HttpServletResponse response) throws IOException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行子任务
|
|
||||||
*
|
|
||||||
* @param tasks /
|
|
||||||
* @throws InterruptedException /
|
|
||||||
*/
|
|
||||||
void executionSubJob(String[] tasks) throws InterruptedException;
|
|
||||||
|
|
||||||
List<SelectOption> queryQuartzJobModules();
|
|
||||||
}
|
|
||||||
|
|
@ -1,184 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.service.impl;
|
|
||||||
|
|
||||||
import cn.hutool.core.util.IdUtil;
|
|
||||||
import cn.hutool.core.util.StrUtil;
|
|
||||||
import cn.odboy.base.model.SelectOption;
|
|
||||||
import cn.odboy.infra.exception.BadRequestException;
|
|
||||||
import cn.odboy.infra.redis.RedisUtil;
|
|
||||||
import cn.odboy.infra.response.PageResult;
|
|
||||||
import cn.odboy.infra.response.PageUtil;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzLog;
|
|
||||||
import cn.odboy.modules.quartz.mapper.QuartzJobMapper;
|
|
||||||
import cn.odboy.modules.quartz.mapper.QuartzLogMapper;
|
|
||||||
import cn.odboy.modules.quartz.service.QuartzJobService;
|
|
||||||
import cn.odboy.modules.quartz.util.QuartzManage;
|
|
||||||
import cn.odboy.util.MyFileUtil;
|
|
||||||
import cn.odboy.util.StringUtil;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.quartz.CronExpression;
|
|
||||||
import org.springframework.scheduling.annotation.Async;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.*;
|
|
||||||
|
|
||||||
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
@Service(value = "quartzJobService")
|
|
||||||
public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob> implements QuartzJobService {
|
|
||||||
|
|
||||||
private final QuartzJobMapper quartzJobMapper;
|
|
||||||
private final QuartzLogMapper quartzLogMapper;
|
|
||||||
private final QuartzManage quartzManage;
|
|
||||||
private final RedisUtil redisUtil;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageResult<QuartzJob> queryAll(QuartzJob.QueryArgs criteria, Page<Object> page) {
|
|
||||||
return PageUtil.toPage(quartzJobMapper.findAll(criteria, page));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageResult<QuartzLog> queryAllLog(QuartzJob.QueryArgs criteria, Page<Object> page) {
|
|
||||||
return PageUtil.toPage(quartzLogMapper.findAll(criteria, page));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<QuartzJob> queryAll(QuartzJob.QueryArgs criteria) {
|
|
||||||
return quartzJobMapper.findAll(criteria);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<QuartzLog> queryAllLog(QuartzJob.QueryArgs criteria) {
|
|
||||||
return quartzLogMapper.findAll(criteria);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void create(QuartzJob resources) {
|
|
||||||
if (!CronExpression.isValidExpression(resources.getCronExpression())) {
|
|
||||||
throw new BadRequestException("cron表达式格式错误");
|
|
||||||
}
|
|
||||||
save(resources);
|
|
||||||
quartzManage.addJob(resources);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void update(QuartzJob resources) {
|
|
||||||
if (!CronExpression.isValidExpression(resources.getCronExpression())) {
|
|
||||||
throw new BadRequestException("cron表达式格式错误");
|
|
||||||
}
|
|
||||||
if (StringUtil.isNotBlank(resources.getSubTask())) {
|
|
||||||
List<String> tasks = Arrays.asList(resources.getSubTask().split("[,，]"));
|
|
||||||
if (tasks.contains(resources.getId().toString())) {
|
|
||||||
throw new BadRequestException("子任务中不能添加当前任务ID");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
saveOrUpdate(resources);
|
|
||||||
quartzManage.updateJobCron(resources);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void updateIsPause(QuartzJob quartzJob) {
|
|
||||||
if (quartzJob.getIsPause()) {
|
|
||||||
quartzManage.resumeJob(quartzJob);
|
|
||||||
quartzJob.setIsPause(false);
|
|
||||||
} else {
|
|
||||||
quartzManage.pauseJob(quartzJob);
|
|
||||||
quartzJob.setIsPause(true);
|
|
||||||
}
|
|
||||||
saveOrUpdate(quartzJob);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void execution(QuartzJob quartzJob) {
|
|
||||||
quartzManage.runJobNow(quartzJob);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void delete(Set<Long> ids) {
|
|
||||||
for (Long id : ids) {
|
|
||||||
QuartzJob quartzJob = getById(id);
|
|
||||||
quartzManage.deleteJob(quartzJob);
|
|
||||||
removeById(quartzJob);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Async
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void executionSubJob(String[] tasks) throws InterruptedException {
|
|
||||||
for (String id : tasks) {
|
|
||||||
if (StrUtil.isBlank(id)) {
|
|
||||||
// 如果是手动清除子任务id，会出现id为空字符串的问题
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
QuartzJob quartzJob = getById(Long.parseLong(id));
|
|
||||||
// 执行任务
|
|
||||||
String uuid = IdUtil.simpleUUID();
|
|
||||||
quartzJob.setUuid(uuid);
|
|
||||||
// 执行任务
|
|
||||||
execution(quartzJob);
|
|
||||||
// 获取执行状态，如果执行失败则停止后面的子任务执行
|
|
||||||
Boolean result = (Boolean) redisUtil.get(uuid);
|
|
||||||
while (result == null) {
|
|
||||||
// 休眠5秒，再次获取子任务执行情况
|
|
||||||
Thread.sleep(5000);
|
|
||||||
result = (Boolean) redisUtil.get(uuid);
|
|
||||||
}
|
|
||||||
if (!result) {
|
|
||||||
redisUtil.del(uuid);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<SelectOption> queryQuartzJobModules() {
|
|
||||||
return baseMapper.findQuartzJobModuleOptions();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void download(List<QuartzJob> quartzJobs, HttpServletResponse response) throws IOException {
|
|
||||||
List<Map<String, Object>> list = new ArrayList<>();
|
|
||||||
for (QuartzJob quartzJob : quartzJobs) {
|
|
||||||
Map<String, Object> map = new LinkedHashMap<>();
|
|
||||||
map.put("任务名称", quartzJob.getJobName());
|
|
||||||
map.put("Bean名称", quartzJob.getBeanName());
|
|
||||||
map.put("执行方法", quartzJob.getMethodName());
|
|
||||||
map.put("参数", quartzJob.getParams());
|
|
||||||
map.put("表达式", quartzJob.getCronExpression());
|
|
||||||
map.put("状态", quartzJob.getIsPause() ? "暂停中" : "运行中");
|
|
||||||
map.put("描述", quartzJob.getDescription());
|
|
||||||
map.put("创建日期", quartzJob.getCreateTime());
|
|
||||||
list.add(map);
|
|
||||||
}
|
|
||||||
MyFileUtil.downloadExcel(list, response);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void downloadLog(List<QuartzLog> queryAllLog, HttpServletResponse response) throws IOException {
|
|
||||||
List<Map<String, Object>> list = new ArrayList<>();
|
|
||||||
for (QuartzLog quartzLog : queryAllLog) {
|
|
||||||
Map<String, Object> map = new LinkedHashMap<>();
|
|
||||||
map.put("任务名称", quartzLog.getJobName());
|
|
||||||
map.put("Bean名称", quartzLog.getBeanName());
|
|
||||||
map.put("执行方法", quartzLog.getMethodName());
|
|
||||||
map.put("参数", quartzLog.getParams());
|
|
||||||
map.put("表达式", quartzLog.getCronExpression());
|
|
||||||
map.put("异常详情", quartzLog.getExceptionDetail());
|
|
||||||
map.put("耗时/毫秒", quartzLog.getTime());
|
|
||||||
map.put("状态", quartzLog.getIsSuccess() ? "成功" : "失败");
|
|
||||||
map.put("创建日期", quartzLog.getCreateTime());
|
|
||||||
list.add(map);
|
|
||||||
}
|
|
||||||
MyFileUtil.downloadExcel(list, response);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.task;
|
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 测试用
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@Service
|
|
||||||
public class TestTask {
|
|
||||||
|
|
||||||
public void run() {
|
|
||||||
log.info("run 执行成功");
|
|
||||||
}
|
|
||||||
|
|
||||||
public void run1(String str) {
|
|
||||||
log.info("run1 执行成功，参数为： {}", str);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void run2() {
|
|
||||||
log.info("run2 执行成功");
|
|
||||||
}
|
|
||||||
|
|
||||||
public void run3() {
|
|
||||||
log.info("run3 执行成功");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,123 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.util;
|
|
||||||
|
|
||||||
import cn.hutool.extra.template.Template;
|
|
||||||
import cn.hutool.extra.template.TemplateConfig;
|
|
||||||
import cn.hutool.extra.template.TemplateEngine;
|
|
||||||
import cn.hutool.extra.template.TemplateUtil;
|
|
||||||
import cn.odboy.constant.EmailTypeEnum;
|
|
||||||
import cn.odboy.domain.EmailLog;
|
|
||||||
import cn.odboy.infra.context.SpringContextHolder;
|
|
||||||
import cn.odboy.infra.redis.RedisUtil;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzLog;
|
|
||||||
import cn.odboy.modules.quartz.mapper.QuartzLogMapper;
|
|
||||||
import cn.odboy.modules.quartz.service.QuartzJobService;
|
|
||||||
import cn.odboy.service.EmailService;
|
|
||||||
import cn.odboy.util.StringUtil;
|
|
||||||
import cn.odboy.util.ThrowableUtil;
|
|
||||||
import org.quartz.JobExecutionContext;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
import org.springframework.scheduling.annotation.Async;
|
|
||||||
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
||||||
import org.springframework.scheduling.quartz.QuartzJobBean;
|
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.concurrent.Future;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 参考人人开源，<a href="https://gitee.com/renrenio/renren-security">...</a>
|
|
||||||
*/
|
|
||||||
@Async
|
|
||||||
public class ExecutionJob extends QuartzJobBean {
|
|
||||||
|
|
||||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 此处仅供参考，可根据任务执行情况自定义线程池参数
|
|
||||||
*/
|
|
||||||
private final ThreadPoolTaskExecutor executor = SpringContextHolder.getBean("elAsync");
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void executeInternal(JobExecutionContext context) {
|
|
||||||
// 获取任务
|
|
||||||
QuartzJob quartzJob = (QuartzJob) context.getMergedJobDataMap().get(QuartzJob.JOB_KEY);
|
|
||||||
// 获取spring bean
|
|
||||||
QuartzLogMapper quartzLogMapper = SpringContextHolder.getBean(QuartzLogMapper.class);
|
|
||||||
QuartzJobService quartzJobService = SpringContextHolder.getBean(QuartzJobService.class);
|
|
||||||
RedisUtil redisUtil = SpringContextHolder.getBean(RedisUtil.class);
|
|
||||||
|
|
||||||
String uuid = quartzJob.getUuid();
|
|
||||||
|
|
||||||
QuartzLog log = new QuartzLog();
|
|
||||||
log.setJobName(quartzJob.getJobName());
|
|
||||||
log.setBeanName(quartzJob.getBeanName());
|
|
||||||
log.setMethodName(quartzJob.getMethodName());
|
|
||||||
log.setParams(quartzJob.getParams());
|
|
||||||
long startTime = System.currentTimeMillis();
|
|
||||||
log.setCronExpression(quartzJob.getCronExpression());
|
|
||||||
try {
|
|
||||||
// 执行任务
|
|
||||||
QuartzRunnable task = new QuartzRunnable(quartzJob.getBeanName(), quartzJob.getMethodName(), quartzJob.getParams());
|
|
||||||
Future<?> future = executor.submit(task);
|
|
||||||
future.get();
|
|
||||||
long times = System.currentTimeMillis() - startTime;
|
|
||||||
log.setTime(times);
|
|
||||||
if (StringUtil.isNotBlank(uuid)) {
|
|
||||||
redisUtil.set(uuid, true);
|
|
||||||
}
|
|
||||||
// 任务状态
|
|
||||||
log.setIsSuccess(true);
|
|
||||||
logger.info("任务执行成功，任务名称：" + quartzJob.getJobName() + ", 执行时间：" + times + "毫秒");
|
|
||||||
// 判断是否存在子任务
|
|
||||||
if (StringUtil.isNotBlank(quartzJob.getSubTask())) {
|
|
||||||
String[] tasks = quartzJob.getSubTask().split("[,，]");
|
|
||||||
// 执行子任务
|
|
||||||
quartzJobService.executionSubJob(tasks);
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
if (StringUtil.isNotBlank(uuid)) {
|
|
||||||
redisUtil.set(uuid, false);
|
|
||||||
}
|
|
||||||
logger.error("任务执行失败，任务名称：" + quartzJob.getJobName());
|
|
||||||
long times = System.currentTimeMillis() - startTime;
|
|
||||||
log.setTime(times);
|
|
||||||
// 任务状态 0：成功 1：失败
|
|
||||||
log.setIsSuccess(false);
|
|
||||||
log.setExceptionDetail(ThrowableUtil.getStackTrace(e));
|
|
||||||
// 任务如果失败了则暂停
|
|
||||||
if (quartzJob.getPauseAfterFailure() != null && quartzJob.getPauseAfterFailure()) {
|
|
||||||
quartzJob.setIsPause(false);
|
|
||||||
//更新状态
|
|
||||||
quartzJobService.updateIsPause(quartzJob);
|
|
||||||
}
|
|
||||||
if (quartzJob.getEmail() != null) {
|
|
||||||
EmailService emailService = SpringContextHolder.getBean(EmailService.class);
|
|
||||||
// 邮箱报警
|
|
||||||
if (StringUtil.isNoneBlank(quartzJob.getEmail())) {
|
|
||||||
EmailLog.SendContent emailVo = renderTaskAlarm(quartzJob, ThrowableUtil.getStackTrace(e));
|
|
||||||
emailService.send(EmailTypeEnum.TASK_ALARM, emailVo);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
quartzLogMapper.insert(log);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private EmailLog.SendContent renderTaskAlarm(QuartzJob quartzJob, String msg) {
|
|
||||||
EmailLog.SendContent emailVo = new EmailLog.SendContent();
|
|
||||||
emailVo.setSubject("定时任务【" + quartzJob.getJobName() + "】执行失败，请尽快处理！");
|
|
||||||
Map<String, Object> data = new HashMap<>(16);
|
|
||||||
data.put("task", quartzJob);
|
|
||||||
data.put("msg", msg);
|
|
||||||
TemplateEngine engine = TemplateUtil.createEngine(new TemplateConfig("template", TemplateConfig.ResourceMode.CLASSPATH));
|
|
||||||
Template template = engine.getTemplate("TaskAlarmTemplate.ftl");
|
|
||||||
emailVo.setContent(template.render(data));
|
|
||||||
List<String> emails = Arrays.asList(quartzJob.getEmail().split("[,，]"));
|
|
||||||
emailVo.setTos(emails);
|
|
||||||
return emailVo;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,162 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.util;
|
|
||||||
|
|
||||||
import cn.odboy.infra.exception.BadRequestException;
|
|
||||||
import cn.odboy.modules.quartz.domain.QuartzJob;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.quartz.*;
|
|
||||||
import org.quartz.impl.triggers.CronTriggerImpl;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
import java.util.Date;
|
|
||||||
|
|
||||||
import static org.quartz.TriggerBuilder.newTrigger;
|
|
||||||
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
public class QuartzManage {
|
|
||||||
|
|
||||||
private static final String JOB_NAME = "TASK_";
|
|
||||||
|
|
||||||
@Resource
|
|
||||||
private Scheduler scheduler;
|
|
||||||
|
|
||||||
public void addJob(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
// 构建job信息
|
|
||||||
JobDetail jobDetail = JobBuilder.newJob(ExecutionJob.class).
|
|
||||||
withIdentity(JOB_NAME + quartzJob.getId()).build();
|
|
||||||
|
|
||||||
//通过触发器名和cron 表达式创建 Trigger
|
|
||||||
Trigger cronTrigger = newTrigger()
|
|
||||||
.withIdentity(JOB_NAME + quartzJob.getId())
|
|
||||||
.startNow()
|
|
||||||
.withSchedule(CronScheduleBuilder.cronSchedule(quartzJob.getCronExpression()))
|
|
||||||
.build();
|
|
||||||
|
|
||||||
cronTrigger.getJobDataMap().put(QuartzJob.JOB_KEY, quartzJob);
|
|
||||||
|
|
||||||
//重置启动时间
|
|
||||||
((CronTriggerImpl) cronTrigger).setStartTime(new Date());
|
|
||||||
|
|
||||||
//执行定时任务
|
|
||||||
scheduler.scheduleJob(jobDetail, cronTrigger);
|
|
||||||
|
|
||||||
// 暂停任务
|
|
||||||
if (quartzJob.getIsPause()) {
|
|
||||||
pauseJob(quartzJob);
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("创建定时任务失败", e);
|
|
||||||
throw new BadRequestException("创建定时任务失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新job cron表达式
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
public void updateJobCron(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getId());
|
|
||||||
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
|
|
||||||
// 如果不存在则创建一个定时任务
|
|
||||||
if (trigger == null) {
|
|
||||||
addJob(quartzJob);
|
|
||||||
trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
|
|
||||||
}
|
|
||||||
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzJob.getCronExpression());
|
|
||||||
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
|
|
||||||
//重置启动时间
|
|
||||||
((CronTriggerImpl) trigger).setStartTime(new Date());
|
|
||||||
trigger.getJobDataMap().put(QuartzJob.JOB_KEY, quartzJob);
|
|
||||||
|
|
||||||
scheduler.rescheduleJob(triggerKey, trigger);
|
|
||||||
// 暂停任务
|
|
||||||
if (quartzJob.getIsPause()) {
|
|
||||||
pauseJob(quartzJob);
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("更新定时任务失败", e);
|
|
||||||
throw new BadRequestException("更新定时任务失败");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除一个job
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
public void deleteJob(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
JobKey jobKey = JobKey.jobKey(JOB_NAME + quartzJob.getId());
|
|
||||||
scheduler.pauseJob(jobKey);
|
|
||||||
scheduler.deleteJob(jobKey);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("删除定时任务失败", e);
|
|
||||||
throw new BadRequestException("删除定时任务失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 恢复一个job
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
public void resumeJob(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getId());
|
|
||||||
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
|
|
||||||
// 如果不存在则创建一个定时任务
|
|
||||||
if (trigger == null) {
|
|
||||||
addJob(quartzJob);
|
|
||||||
}
|
|
||||||
JobKey jobKey = JobKey.jobKey(JOB_NAME + quartzJob.getId());
|
|
||||||
scheduler.resumeJob(jobKey);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("恢复定时任务失败", e);
|
|
||||||
throw new BadRequestException("恢复定时任务失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 立即执行job
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
public void runJobNow(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getId());
|
|
||||||
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
|
|
||||||
// 如果不存在则创建一个定时任务
|
|
||||||
if (trigger == null) {
|
|
||||||
addJob(quartzJob);
|
|
||||||
}
|
|
||||||
JobDataMap dataMap = new JobDataMap();
|
|
||||||
dataMap.put(QuartzJob.JOB_KEY, quartzJob);
|
|
||||||
JobKey jobKey = JobKey.jobKey(JOB_NAME + quartzJob.getId());
|
|
||||||
scheduler.triggerJob(jobKey, dataMap);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("定时任务执行失败", e);
|
|
||||||
throw new BadRequestException("定时任务执行失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 暂停一个job
|
|
||||||
*
|
|
||||||
* @param quartzJob /
|
|
||||||
*/
|
|
||||||
public void pauseJob(QuartzJob quartzJob) {
|
|
||||||
try {
|
|
||||||
JobKey jobKey = JobKey.jobKey(JOB_NAME + quartzJob.getId());
|
|
||||||
scheduler.pauseJob(jobKey);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("定时任务暂停失败", e);
|
|
||||||
throw new BadRequestException("定时任务暂停失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,43 +0,0 @@
|
||||||
package cn.odboy.modules.quartz.util;
|
|
||||||
|
|
||||||
import cn.odboy.infra.context.SpringContextHolder;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
import org.springframework.util.ReflectionUtils;
|
|
||||||
|
|
||||||
import java.lang.reflect.Method;
|
|
||||||
import java.util.concurrent.Callable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行定时任务
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
public class QuartzRunnable implements Callable<Object> {
|
|
||||||
|
|
||||||
private final Object target;
|
|
||||||
private final Method method;
|
|
||||||
private final String params;
|
|
||||||
|
|
||||||
QuartzRunnable(String beanName, String methodName, String params)
|
|
||||||
throws NoSuchMethodException, SecurityException {
|
|
||||||
this.target = SpringContextHolder.getBean(beanName);
|
|
||||||
this.params = params;
|
|
||||||
if (StringUtils.isNotBlank(params)) {
|
|
||||||
this.method = target.getClass().getDeclaredMethod(methodName, String.class);
|
|
||||||
} else {
|
|
||||||
this.method = target.getClass().getDeclaredMethod(methodName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@SuppressWarnings("all")
|
|
||||||
public Object call() throws Exception {
|
|
||||||
ReflectionUtils.makeAccessible(method);
|
|
||||||
if (StringUtils.isNotBlank(params)) {
|
|
||||||
method.invoke(target, params);
|
|
||||||
} else {
|
|
||||||
method.invoke(target);
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,32 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8" ?>
|
|
||||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
|
||||||
<mapper namespace="cn.odboy.modules.quartz.mapper.QuartzJobMapper">
|
|
||||||
<select id="findAll" resultType="cn.odboy.modules.quartz.domain.QuartzJob">
|
|
||||||
SELECT *
|
|
||||||
FROM system_quartz_job
|
|
||||||
<where>
|
|
||||||
<if test="criteria.jobName != null and criteria.jobName != ''">
|
|
||||||
AND job_name LIKE CONCAT('%',#{criteria.jobName},'%')
|
|
||||||
</if>
|
|
||||||
<if test="criteria.moduleName != null and criteria.moduleName != ''">
|
|
||||||
AND module_name = #{criteria.moduleName}
|
|
||||||
</if>
|
|
||||||
<if test="criteria.createTime != null and criteria.createTime.size() > 0">
|
|
||||||
AND update_time BETWEEN #{criteria.createTime[0]} AND #{criteria.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</where>
|
|
||||||
ORDER BY id DESC
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="findByIsPauseIsFalse" resultType="cn.odboy.modules.quartz.domain.QuartzJob">
|
|
||||||
SELECT *
|
|
||||||
FROM system_quartz_job
|
|
||||||
WHERE is_pause = 0
|
|
||||||
</select>
|
|
||||||
<select id="findQuartzJobModuleOptions" resultType="cn.odboy.base.model.SelectOption">
|
|
||||||
SELECT t1.module_name AS `label`,
|
|
||||||
t1.module_name AS `value`
|
|
||||||
FROM system_quartz_job t1
|
|
||||||
GROUP BY t1.module_name
|
|
||||||
</select>
|
|
||||||
</mapper>
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8" ?>
|
|
||||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
|
||||||
<mapper namespace="cn.odboy.modules.quartz.mapper.QuartzLogMapper">
|
|
||||||
<select id="findAll" resultType="cn.odboy.modules.quartz.domain.QuartzLog">
|
|
||||||
SELECT *
|
|
||||||
FROM system_quartz_log
|
|
||||||
<where>
|
|
||||||
<if test="criteria.jobName != null and criteria.jobName != ''">
|
|
||||||
AND job_name LIKE CONCAT('%',#{criteria.jobName},'%')
|
|
||||||
</if>
|
|
||||||
<if test="criteria.isSuccess != null">
|
|
||||||
AND is_success = #{criteria.isSuccess}
|
|
||||||
</if>
|
|
||||||
<if test="criteria.createTime != null and criteria.createTime.size() > 0">
|
|
||||||
AND create_time BETWEEN #{criteria.createTime[0]} AND #{criteria.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</where>
|
|
||||||
ORDER BY id DESC
|
|
||||||
</select>
|
|
||||||
</mapper>
|
|
||||||
|
|
@ -1,69 +0,0 @@
|
||||||
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
|
|
||||||
<html xmlns="http://www.w3.org/1999/xhtml">
|
|
||||||
<head>
|
|
||||||
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
|
|
||||||
<style>
|
|
||||||
@page {
|
|
||||||
margin: 0;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body style="margin: 0px;
|
|
||||||
padding: 0px;
|
|
||||||
font: 100% SimSun, Microsoft YaHei, Times New Roman, Verdana, Arial, Helvetica, sans-serif;
|
|
||||||
color: #000;">
|
|
||||||
<div style="height: auto;
|
|
||||||
margin: 0 auto;
|
|
||||||
margin-top: 20px;
|
|
||||||
padding: 20px;
|
|
||||||
border: 1px solid #eee;">
|
|
||||||
<div>
|
|
||||||
<p style="margin-bottom: 10px;">任务信息：</p>
|
|
||||||
<table style="border-collapse: collapse;">
|
|
||||||
<tr>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">任务名称</th>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">Bean名称</th>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">执行方法</th>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">参数内容</th>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">Cron表达式</th>
|
|
||||||
<th style="padding: .65em;background: #666;border: 1px solid #777;color: #fff;">描述内容</th>
|
|
||||||
</tr>
|
|
||||||
<tr>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${task.jobName}</td>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${task.beanName}</td>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${task.methodName}</td>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${(task.params)!""}</td>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${task.cronExpression}</td>
|
|
||||||
<td style="padding: .65em;border: 1px solid#777;">${(task.description)!""}</td>
|
|
||||||
</tr>
|
|
||||||
</table>
|
|
||||||
</div>
|
|
||||||
<div>
|
|
||||||
<p style="margin-bottom: 10px;">异常信息：</p>
|
|
||||||
<pre style="position: relative;
|
|
||||||
padding: 15px;
|
|
||||||
line-height: 20px;
|
|
||||||
border-left: 5px solid #ddd;
|
|
||||||
color: #333;
|
|
||||||
font-family: Courier New, serif;
|
|
||||||
font-size: 12px">
|
|
||||||
${msg}
|
|
||||||
</pre>
|
|
||||||
</div>
|
|
||||||
<div class="foot-hr hr" style="margin: 0 auto;
|
|
||||||
z-index: 111;
|
|
||||||
width: 800px;
|
|
||||||
margin-top: 30px;
|
|
||||||
border-top: 1px solid #DA251D;">
|
|
||||||
</div>
|
|
||||||
<div style="text-align: center;
|
|
||||||
font-size: 12px;
|
|
||||||
padding: 20px 0px;
|
|
||||||
font-family: Microsoft YaHei;">
|
|
||||||
Copyright ©${.now?string("yyyy")} Kenaito快速开发框架 All Rights Reserved.
|
|
||||||
</div>
|
|
||||||
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
Loading…
Reference in New Issue