From 1c20c8231980a8d4b91688ff8641a06d3b2f68ab Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期二, 14 十月 2025 16:34:22 +0800
Subject: [PATCH] 改bug
---
server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java | 28 ++++++++++++++++++----------
1 files changed, 18 insertions(+), 10 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 c7eb54c..e19936c 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
@@ -41,9 +41,11 @@
public CronTrigger getCronTrigger (Integer jobId){
try {
return (CronTrigger) this.scheduler.getTrigger(getTriggerKey(jobId)) ;
- } catch (SchedulerException e){
- throw new RuntimeException("getCronTrigger Fail",e) ;
+ }catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
+ return null;
}
/**
@@ -55,10 +57,12 @@
JobDetail jobDetail = JobBuilder.newJob(QuartzRecord.class)
.withIdentity(getJobKey(quartzJob.getId())).build() ;
+
// 鏋勫缓Cron璋冨害鍣�
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(quartzJob.getCronExpres())
.withMisfireHandlingInstructionDoNothing() ;
+
// 浠诲姟瑙﹀彂鍣�
CronTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity(getTriggerKey(quartzJob.getId()))
@@ -67,8 +71,9 @@
scheduler.scheduleJob(jobDetail,trigger) ;
// 鐘舵�佹牎楠�
checkStop(quartzJob) ;
- } catch (SchedulerException e){
- throw new RuntimeException("createJob Fail",e) ;
+ } catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
}
@@ -91,8 +96,9 @@
scheduler.rescheduleJob(triggerKey, trigger);
// 鐘舵�佹牎楠�
checkStop(quartzJob) ;
- } catch (SchedulerException e) {
- throw new RuntimeException("updateJob Fail",e) ;
+ }catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
}
@@ -126,8 +132,9 @@
JobDataMap dataMap = new JobDataMap() ;
dataMap.put(QuartzJob.JOB_PARAM_KEY,quartzJob);
this.scheduler.triggerJob(getJobKey(quartzJob.getId()),dataMap);
- } catch (SchedulerException e){
- throw new RuntimeException("run Fail",e) ;
+ } catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
}
@@ -139,8 +146,9 @@
if(quartzJob.getState() != JobState.JOB_RUN.getStatus()){
this.scheduler.pauseJob(getJobKey(quartzJob.getId()));
}
- } catch (SchedulerException e){
- throw new RuntimeException("pauseJob Fail",e) ;
+ } catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
}
--
Gitblit v1.9.3