|
|
@@ -51,6 +51,13 @@ public class ScheduleUtils {
|
|
|
*/
|
|
|
public static void createScheduleJob(Scheduler scheduler, ScheduleJobEntity scheduleJob) {
|
|
|
try {
|
|
|
+ JobKey jobKey = getJobKey(scheduleJob.getJobId());
|
|
|
+
|
|
|
+ // 关键修复:先删除已存在的任务和触发器
|
|
|
+ if (scheduler.checkExists(jobKey)) {
|
|
|
+ scheduler.deleteJob(jobKey); // 删除任务及关联触发器
|
|
|
+ }
|
|
|
+
|
|
|
//构建job信息
|
|
|
JobDetail jobDetail = JobBuilder.newJob(ScheduleJob.class).withIdentity(getJobKey(scheduleJob.getJobId())).build();
|
|
|
|