| | |
|---|
| | | private QuartzManage quartzManage; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 初始化加载定时任务 |
|---|
| | | */ |
|---|
| | | @PostConstruct |
|---|
| | | public void init () { |
|---|
| | | LambdaQueryWrapper<QuartzJob> queryWrapper = new LambdaQueryWrapper<>() ; |
|---|
| | | queryWrapper.in(QuartzJob::getState, JobState.JOB_RUN.getStatus(),JobState.JOB_STOP.getStatus()); |
|---|
| | | List<QuartzJob> jobList = quartzJobMapper.selectList(queryWrapper); |
|---|
| | | jobList.forEach(quartzJob -> { |
|---|
| | | CronTrigger cronTrigger = quartzManage.getCronTrigger(quartzJob.getId()) ; |
|---|
| | | if (Objects.isNull(cronTrigger)){ |
|---|
| | | quartzManage.createJob(quartzJob); |
|---|
| | | } else { |
|---|
| | | quartzManage.updateJob(quartzJob); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 任务主键查询 |
|---|
| | | */ |
|---|
| | | public QuartzJob getById(Integer id) { |
|---|
