代码初始化

jiangping

2025-06-17 64fa2c33cd645e86d4e2a8c34c7881ea4aa678cf

 server/src/main/java/com/doumee/config/quartz/JobInitializer.java

@@ -1,5 +1,6 @@
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;
@@ -41,6 +42,7 @@
     */
    @PostConstruct
    public void initJobs () {

        log.debug("Initializing jobs");
        // 修复JOB
        this.repairJobs();
@@ -52,10 +54,15 @@
        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);
    }

    /**