From f76c68a87261cf2396a64c7125324c24483d4623 Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期二, 09 六月 2026 09:46:32 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/wuhuyancao' into wuhuyancao
---
server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java | 23 +++++++++++------------
1 files changed, 11 insertions(+), 12 deletions(-)
diff --git a/server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java b/server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java
index e19936c..bdcefd9 100644
--- a/server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java
+++ b/server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java
@@ -4,6 +4,8 @@
import com.doumee.dao.timer.entity.QuartzJob;
import org.quartz.*;
import org.quartz.CronTrigger;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -15,6 +17,8 @@
*/
@Component
public class QuartzManage {
+
+ private static final Logger log = LoggerFactory.getLogger(QuartzManage.class);
private static final String SCHEDULE_NAME = "BOOT_JOB_" ;
@@ -42,8 +46,7 @@
try {
return (CronTrigger) this.scheduler.getTrigger(getTriggerKey(jobId)) ;
}catch (Exception e){
- e.printStackTrace();
-// throw new RuntimeException("createJob Fail",e) ;
+ log.error("getCronTrigger澶辫触, jobId={}", jobId, e);
}
return null;
}
@@ -61,7 +64,7 @@
// 鏋勫缓Cron璋冨害鍣�
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(quartzJob.getCronExpres())
- .withMisfireHandlingInstructionDoNothing() ;
+ .withMisfireHandlingInstructionFireAndProceed() ;
// 浠诲姟瑙﹀彂鍣�
CronTrigger trigger = TriggerBuilder.newTrigger()
@@ -72,8 +75,7 @@
// 鐘舵�佹牎楠�
checkStop(quartzJob) ;
} catch (Exception e){
- e.printStackTrace();
-// throw new RuntimeException("createJob Fail",e) ;
+ log.error("createJob澶辫触, jobId={}", quartzJob.getId(), e);
}
}
@@ -87,7 +89,7 @@
// 鏋勫缓Cron璋冨害鍣�
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(quartzJob.getCronExpres())
- .withMisfireHandlingInstructionDoNothing();
+ .withMisfireHandlingInstructionFireAndProceed();
// 浠诲姟瑙﹀彂鍣�
CronTrigger trigger = getCronTrigger(quartzJob.getId())
.getTriggerBuilder().withIdentity(triggerKey)
@@ -97,8 +99,7 @@
// 鐘舵�佹牎楠�
checkStop(quartzJob) ;
}catch (Exception e){
- e.printStackTrace();
-// throw new RuntimeException("createJob Fail",e) ;
+ log.error("updateJob澶辫触, jobId={}", quartzJob.getId(), e);
}
}
@@ -133,8 +134,7 @@
dataMap.put(QuartzJob.JOB_PARAM_KEY,quartzJob);
this.scheduler.triggerJob(getJobKey(quartzJob.getId()),dataMap);
} catch (Exception e){
- e.printStackTrace();
-// throw new RuntimeException("createJob Fail",e) ;
+ log.error("run澶辫触, jobId={}", quartzJob.getId(), e);
}
}
@@ -147,8 +147,7 @@
this.scheduler.pauseJob(getJobKey(quartzJob.getId()));
}
} catch (Exception e){
- e.printStackTrace();
-// throw new RuntimeException("createJob Fail",e) ;
+ log.error("checkStop澶辫触, jobId={}", quartzJob.getId(), e);
}
}
--
Gitblit v1.9.3