项目升级到 Spring Boot 4

RuoYi

2026-03-11 33694fe08298e0b2ba5bbafbdc3a23570cc391cf

 ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/SysJobServiceImpl.java

@@ -1,7 +1,7 @@
package com.ruoyi.job.service;



import java.util.List;

import javax.annotation.PostConstruct;

import jakarta.annotation.PostConstruct;

import org.quartz.JobDataMap;

import org.quartz.JobKey;

import org.quartz.Scheduler;

@@ -74,7 +74,7 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int pauseJob(SysJob job) throws SchedulerException

    {

        Long jobId = job.getJobId();

@@ -94,7 +94,7 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int resumeJob(SysJob job) throws SchedulerException

    {

        Long jobId = job.getJobId();

@@ -114,7 +114,7 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int deleteJob(SysJob job) throws SchedulerException

    {

        Long jobId = job.getJobId();

@@ -134,7 +134,7 @@
     * @return 结果

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public void deleteJobByIds(Long[] jobIds) throws SchedulerException

    {

        for (Long jobId : jobIds)

@@ -150,7 +150,7 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int changeStatus(SysJob job) throws SchedulerException

    {

        int rows = 0;

@@ -172,16 +172,23 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    public void run(SysJob job) throws SchedulerException

    @Transactional(rollbackFor = Exception.class)

    public boolean run(SysJob job) throws SchedulerException

    {

        boolean result = false;

        Long jobId = job.getJobId();

        String jobGroup = job.getJobGroup();

        SysJob properties = selectJobById(job.getJobId());

        // 参数

        JobDataMap dataMap = new JobDataMap();

        dataMap.put(ScheduleConstants.TASK_PROPERTIES, properties);

        scheduler.triggerJob(ScheduleUtils.getJobKey(jobId, jobGroup), dataMap);

        JobKey jobKey = ScheduleUtils.getJobKey(jobId, jobGroup);

        if (scheduler.checkExists(jobKey))

        {

            result = true;

            scheduler.triggerJob(jobKey, dataMap);

        }

        return result;

    }



    /**

@@ -190,7 +197,7 @@
     * @param job 调度信息 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int insertJob(SysJob job) throws SchedulerException, TaskException

    {

        job.setStatus(ScheduleConstants.Status.PAUSE.getValue());

@@ -208,7 +215,7 @@
     * @param job 调度信息

     */

    @Override

    @Transactional

    @Transactional(rollbackFor = Exception.class)

    public int updateJob(SysJob job) throws SchedulerException, TaskException

    {

        SysJob properties = selectJobById(job.getJobId());