diff --git a/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java b/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java index 4b277a76..12b3cf3b 100644 --- a/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java +++ b/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java @@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.lz.modules.job.entity.ScheduleJobEntity; import org.apache.ibatis.annotations.Mapper; +import java.util.List; import java.util.Map; /** @@ -26,4 +27,6 @@ public interface ScheduleJobDao extends BaseMapper { * 批量更新状态 */ int updateBatch(Map map); + + List selectAll(); } diff --git a/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java b/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java index 6d33f1d1..c4c2487f 100644 --- a/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java +++ b/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java @@ -33,12 +33,18 @@ public class ScheduleJobServiceImpl extends ServiceImpl scheduleJobList = this.list(); + List scheduleJobList = scheduleJobMapper.selectAll(); for(ScheduleJobEntity scheduleJob : scheduleJobList){ CronTrigger cronTrigger = ScheduleUtils.getCronTrigger(scheduler, scheduleJob.getJobId()); //如果不存在,则创建 diff --git a/src/main/resources/mapper/job/ScheduleJobDao.xml b/src/main/resources/mapper/job/ScheduleJobDao.xml index 5c35544c..603ec916 100644 --- a/src/main/resources/mapper/job/ScheduleJobDao.xml +++ b/src/main/resources/mapper/job/ScheduleJobDao.xml @@ -11,4 +11,10 @@ + + + +