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();