| | |
|---|
| | | package com.doumee.config.quartz; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|---|
| | | import com.doumee.core.constants.Constants; |
|---|
| | | import com.doumee.core.job.SchedulerProxy; |
|---|
| | |
|---|
| | | */ |
|---|
| | | @PostConstruct |
|---|
| | | public void initJobs () { |
|---|
| | | |
|---|
| | | log.debug("Initializing jobs"); |
|---|
| | | // 修复JOB |
|---|
| | | this.repairJobs(); |
|---|
| | |
|---|
| | | queryJobDto.setDeleted(Boolean.FALSE); |
|---|
| | | List<SystemJob> jobs = systemJobService.findList(queryJobDto); |
|---|
| | | for (SystemJob job : jobs) { |
|---|
| | | try { |
|---|
| | | schedulerProxy.createJob(new SchedulerProxy.Job(job.getId(), job.getHandler(), job.getCronExpression(), job.getDisallowConcurrent())); |
|---|
| | | log.debug("job '{}' initialized.", job.getJobName()); |
|---|
| | | log.info("job '{}' initialized.", job.getJobName()); |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | log.error("Jobs initialization failed: '{}''{}' ", JSONObject.toJSONString(job),e.getStackTrace()); |
|---|
| | | } |
|---|
| | | log.debug("Jobs initialization completed in {} ms", System.currentTimeMillis() - startTime); |
|---|
| | | } |
|---|
| | | log.info("Jobs initialization completed in {} ms", System.currentTimeMillis() - startTime); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
