From c115722130eb11af68ab639835a266ca9e2b4c9c Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 22 五月 2025 16:26:06 +0800
Subject: [PATCH] 最新版本541200007
---
server/system_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java | 28 +++++++++++++++++-----------
1 files changed, 17 insertions(+), 11 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 e0191a9..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;
}
/**
@@ -68,9 +70,10 @@
jobDetail.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY,quartzJob);
scheduler.scheduleJob(jobDetail,trigger) ;
// 鐘舵�佹牎楠�
-// checkStop(quartzJob) ;
- } catch (SchedulerException e){
- throw new RuntimeException("createJob Fail",e) ;
+ checkStop(quartzJob) ;
+ } catch (Exception e){
+ e.printStackTrace();
+// throw new RuntimeException("createJob Fail",e) ;
}
}
@@ -93,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) ;
}
}
@@ -128,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) ;
}
}
@@ -141,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