From 25b2fab1323eab34e7ce38b8290d4d9ef87549bc Mon Sep 17 00:00:00 2001 From: huangfeng Date: Tue, 6 May 2025 14:37:34 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=AD=A3=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=B8=8D=E4=B8=80=E8=87=B4=E4=B8=8D=E8=BF=90?= =?UTF-8?q?=E8=A1=8C=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/chenxuan/base/entity/CustomQuartzJobBean.java | 5 +++-- .../com/chenxuan/service/impl/QuartzManagerServiceImpl.java | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/chenxuan/base/entity/CustomQuartzJobBean.java b/src/main/java/com/chenxuan/base/entity/CustomQuartzJobBean.java index 119d4c6..b8ea754 100644 --- a/src/main/java/com/chenxuan/base/entity/CustomQuartzJobBean.java +++ b/src/main/java/com/chenxuan/base/entity/CustomQuartzJobBean.java @@ -1,5 +1,6 @@ package com.chenxuan.base.entity; +import com.alibaba.fastjson.JSON; import com.chenxuan.entity.model.ScheduleJob; import com.chenxuan.utils.ScheduleRunnable; import lombok.extern.slf4j.Slf4j; @@ -28,8 +29,8 @@ public class CustomQuartzJobBean extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { //任务开始时间 - JobDataMap jobDataMap = context.getMergedJobDataMap(); - ScheduleJob scheduleJob = (ScheduleJob)jobDataMap.get( JobConstant.JOB_PARAM_KEY ); + String jsonJob = context.getMergedJobDataMap().getString(JobConstant.JOB_PARAM_KEY); + ScheduleJob scheduleJob = JSON.parseObject(jsonJob, ScheduleJob.class); //任务开始时间 long startTime = System.currentTimeMillis(); diff --git a/src/main/java/com/chenxuan/service/impl/QuartzManagerServiceImpl.java b/src/main/java/com/chenxuan/service/impl/QuartzManagerServiceImpl.java index 547a261..d984e1c 100644 --- a/src/main/java/com/chenxuan/service/impl/QuartzManagerServiceImpl.java +++ b/src/main/java/com/chenxuan/service/impl/QuartzManagerServiceImpl.java @@ -43,7 +43,7 @@ public class QuartzManagerServiceImpl implements QuartzManagerService { //传入调度的数据，在QuartzFactory中需要使用 JobDataMap jobDetailMap = jobDetail.getJobDataMap(); - jobDetailMap.put(JobConstant.JOB_PARAM_KEY, job); + jobDetailMap.put(JobConstant.JOB_PARAM_KEY, JSON.toJSONString(job)); //调度作业 scheduler.scheduleJob(jobDetail, trigger); String status = job.getStatus();