From 64fa2c33cd645e86d4e2a8c34c7881ea4aa678cf Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 17 六月 2025 18:33:37 +0800
Subject: [PATCH] 代码初始化
---
server/src/main/java/com/doumee/config/quartz/JobInitializer.java | 13 ++++++++++---
1 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/com/doumee/config/quartz/JobInitializer.java b/server/src/main/java/com/doumee/config/quartz/JobInitializer.java
index 0e3e870..ac44eb8 100644
--- a/server/src/main/java/com/doumee/config/quartz/JobInitializer.java
+++ b/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) {
- schedulerProxy.createJob(new SchedulerProxy.Job(job.getId(), job.getHandler(), job.getCronExpression(), job.getDisallowConcurrent()));
- log.debug("job '{}' initialized.", job.getJobName());
+ try {
+ schedulerProxy.createJob(new SchedulerProxy.Job(job.getId(), job.getHandler(), job.getCronExpression(), job.getDisallowConcurrent()));
+ 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);
}
/**
--
Gitblit v1.9.3