支持自实现Quartz任务类

2026-01-31 22:11:57 +08:00 · 2024-02-20 16:47:32 +08:00
parent e4a49e6b1c
commit bba1c8465d
48 changed files with 4005 additions and 884 deletions
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/domain/SysJob.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/domain/SysJob.java
@@ -1,12 +1,5 @@
 package com.ruoyi.job.domain;

-import java.io.Serial;
-import java.util.Date;
-
-import jakarta.validation.constraints.NotBlank;
-import jakarta.validation.constraints.Size;
-import org.apache.commons.lang3.builder.ToStringBuilder;
-import org.apache.commons.lang3.builder.ToStringStyle;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.ruoyi.common.core.annotation.Excel;
 import com.ruoyi.common.core.annotation.Excel.ColumnType;
@@ -14,6 +7,13 @@ import com.ruoyi.common.core.constant.ScheduleConstants;
 import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.common.core.web.domain.BaseEntity;
 import com.ruoyi.job.util.CronUtils;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.io.Serial;
+import java.util.Date;

 /**
 * 定时任务调度表 sys_job
@@ -51,7 +51,7 @@ public class SysJob extends BaseEntity {
    /**
     * cron执行表达式
     */
-    @Excel(name = "执行表达式 ")
+    @Excel(name = "执行表达式")
    private String cronExpression;

    /**
@@ -72,6 +72,12 @@ public class SysJob extends BaseEntity {
    @Excel(name = "任务状态", readConverterExp = "0=正常,1=暂停")
    private String status;

+    /**
+     * 自定义QuartzJob类
+     */
+    @Excel(name = "自定义QuartzJob类")
+    private String customJobClass;
+
    public Long getJobId() {
        return jobId;
    }
@@ -150,6 +156,14 @@ public class SysJob extends BaseEntity {
        this.status = status;
    }

+    public String getCustomJobClass() {
+        return customJobClass;
+    }
+
+    public void setCustomJobClass(String customJobClass) {
+        this.customJobClass = customJobClass;
+    }
+
    @Override
    public String toString() {
        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
@@ -161,6 +175,7 @@ public class SysJob extends BaseEntity {
                .append("misfirePolicy", getMisfirePolicy())
                .append("concurrent", getConcurrent())
                .append("status", getStatus())
+                .append("customJobClass", getCustomJobClass())
                .append("createBy", getCreateBy())
                .append("createTime", getCreateTime())
                .append("updateBy", getUpdateBy())
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/mapper/SysJobLogMapper.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/mapper/SysJobLogMapper.java
@@ -1,64 +1,64 @@
 package com.ruoyi.job.mapper;

-import java.util.List;
 import com.ruoyi.job.domain.SysJobLog;

+import java.util.List;
+
 /**
 * 调度任务日志信息 数据层
- * 
+ *
 * @author ruoyi
 */
-public interface SysJobLogMapper
-{
+public interface SysJobLogMapper {
    /**
     * 获取quartz调度器日志的计划任务
-     * 
+     *
     * @param jobLog 调度日志信息
     * @return 调度任务日志集合
     */
-    public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
+    List<SysJobLog> selectJobLogList(SysJobLog jobLog);

    /**
     * 查询所有调度任务日志
     *
     * @return 调度任务日志列表
     */
-    public List<SysJobLog> selectJobLogAll();
+    List<SysJobLog> selectJobLogAll();

    /**
     * 通过调度任务日志ID查询调度信息
-     * 
+     *
     * @param jobLogId 调度任务日志ID
     * @return 调度任务日志对象信息
     */
-    public SysJobLog selectJobLogById(Long jobLogId);
+    SysJobLog selectJobLogById(Long jobLogId);

    /**
     * 新增任务日志
-     * 
+     *
     * @param jobLog 调度日志信息
     * @return 结果
     */
-    public int insertJobLog(SysJobLog jobLog);
+    int insertJobLog(SysJobLog jobLog);

    /**
     * 批量删除调度日志信息
-     * 
+     *
     * @param logIds 需要删除的数据ID
     * @return 结果
     */
-    public int deleteJobLogByIds(Long[] logIds);
+    int deleteJobLogByIds(Long[] logIds);

    /**
     * 删除任务日志
-     * 
+     *
     * @param jobId 调度日志ID
     * @return 结果
     */
-    public int deleteJobLogById(Long jobId);
+    int deleteJobLogById(Long jobId);

    /**
     * 清空任务日志
     */
-    public void cleanJobLog();
+    void cleanJobLog();
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/mapper/SysJobMapper.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/mapper/SysJobMapper.java
@@ -1,67 +1,67 @@
 package com.ruoyi.job.mapper;

-import java.util.List;
 import com.ruoyi.job.domain.SysJob;

+import java.util.List;
+
 /**
 * 调度任务信息 数据层
- * 
+ *
 * @author ruoyi
 */
-public interface SysJobMapper
-{
+public interface SysJobMapper {
    /**
     * 查询调度任务日志集合
-     * 
+     *
     * @param job 调度信息
     * @return 操作日志集合
     */
-    public List<SysJob> selectJobList(SysJob job);
+    List<SysJob> selectJobList(SysJob job);

    /**
     * 查询所有调度任务
-     * 
+     *
     * @return 调度任务列表
     */
-    public List<SysJob> selectJobAll();
+    List<SysJob> selectJobAll();

    /**
     * 通过调度ID查询调度任务信息
-     * 
+     *
     * @param jobId 调度ID
     * @return 角色对象信息
     */
-    public SysJob selectJobById(Long jobId);
+    SysJob selectJobById(Long jobId);

    /**
     * 通过调度ID删除调度任务信息
-     * 
+     *
     * @param jobId 调度ID
     * @return 结果
     */
-    public int deleteJobById(Long jobId);
+    int deleteJobById(Long jobId);

    /**
     * 批量删除调度任务信息
-     * 
+     *
     * @param ids 需要删除的数据ID
     * @return 结果
     */
-    public int deleteJobByIds(Long[] ids);
+    int deleteJobByIds(Long[] ids);

    /**
     * 修改调度任务信息
-     * 
+     *
     * @param job 调度任务信息
     * @return 结果
     */
-    public int updateJob(SysJob job);
+    int updateJob(SysJob job);

    /**
     * 新增调度任务信息
-     * 
+     *
     * @param job 调度任务信息
     * @return 结果
     */
-    public int insertJob(SysJob job);
+    int insertJob(SysJob job);
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/ISysJobLogService.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/ISysJobLogService.java
@@ -1,56 +1,56 @@
 package com.ruoyi.job.service;

-import java.util.List;
 import com.ruoyi.job.domain.SysJobLog;

+import java.util.List;
+
 /**
 * 定时任务调度日志信息信息 服务层
- * 
+ *
 * @author ruoyi
 */
-public interface ISysJobLogService
-{
+public interface ISysJobLogService {
    /**
     * 获取quartz调度器日志的计划任务
-     * 
+     *
     * @param jobLog 调度日志信息
     * @return 调度任务日志集合
     */
-    public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
+    List<SysJobLog> selectJobLogList(SysJobLog jobLog);

    /**
     * 通过调度任务日志ID查询调度信息
-     * 
+     *
     * @param jobLogId 调度任务日志ID
     * @return 调度任务日志对象信息
     */
-    public SysJobLog selectJobLogById(Long jobLogId);
+    SysJobLog selectJobLogById(Long jobLogId);

    /**
     * 新增任务日志
-     * 
+     *
     * @param jobLog 调度日志信息
     */
-    public void addJobLog(SysJobLog jobLog);
+    void addJobLog(SysJobLog jobLog);

    /**
     * 批量删除调度日志信息
-     * 
+     *
     * @param logIds 需要删除的日志ID
     * @return 结果
     */
-    public int deleteJobLogByIds(Long[] logIds);
+    int deleteJobLogByIds(Long[] logIds);

    /**
     * 删除任务日志
-     * 
+     *
     * @param jobId 调度日志ID
     * @return 结果
     */
-    public int deleteJobLogById(Long jobId);
+    int deleteJobLogById(Long jobId);

    /**
     * 清空任务日志
     */
-    public void cleanJobLog();
+    void cleanJobLog();
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/SysJobLogServiceImpl.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/SysJobLogServiceImpl.java
@@ -1,77 +1,72 @@
 package com.ruoyi.job.service;

-import java.util.List;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
 import com.ruoyi.job.domain.SysJobLog;
 import com.ruoyi.job.mapper.SysJobLogMapper;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+
+import java.util.List;

 /**
 * 定时任务调度日志信息 服务层
- * 
+ *
 * @author ruoyi
 */
@Service
-public class SysJobLogServiceImpl implements ISysJobLogService
-{
-    @Autowired
+public class SysJobLogServiceImpl implements ISysJobLogService {
+    @Resource
    private SysJobLogMapper jobLogMapper;

    /**
     * 获取quartz调度器日志的计划任务
-     * 
+     *
     * @param jobLog 调度日志信息
     * @return 调度任务日志集合
     */
    @Override
-    public List<SysJobLog> selectJobLogList(SysJobLog jobLog)
-    {
+    public List<SysJobLog> selectJobLogList(SysJobLog jobLog) {
        return jobLogMapper.selectJobLogList(jobLog);
    }

    /**
     * 通过调度任务日志ID查询调度信息
-     * 
+     *
     * @param jobLogId 调度任务日志ID
     * @return 调度任务日志对象信息
     */
    @Override
-    public SysJobLog selectJobLogById(Long jobLogId)
-    {
+    public SysJobLog selectJobLogById(Long jobLogId) {
        return jobLogMapper.selectJobLogById(jobLogId);
    }

    /**
     * 新增任务日志
-     * 
+     *
     * @param jobLog 调度日志信息
     */
    @Override
-    public void addJobLog(SysJobLog jobLog)
-    {
+    public void addJobLog(SysJobLog jobLog) {
        jobLogMapper.insertJobLog(jobLog);
    }

    /**
     * 批量删除调度日志信息
-     * 
+     *
     * @param logIds 需要删除的数据ID
     * @return 结果
     */
    @Override
-    public int deleteJobLogByIds(Long[] logIds)
-    {
+    public int deleteJobLogByIds(Long[] logIds) {
        return jobLogMapper.deleteJobLogByIds(logIds);
    }

    /**
     * 删除任务日志
-     * 
+     *
     * @param jobId 调度日志ID
     */
    @Override
-    public int deleteJobLogById(Long jobId)
-    {
+    public int deleteJobLogById(Long jobId) {
        return jobLogMapper.deleteJobLogById(jobId);
    }

@@ -79,8 +74,7 @@ public class SysJobLogServiceImpl implements ISysJobLogService
     * 清空任务日志
     */
    @Override
-    public void cleanJobLog()
-    {
+    public void cleanJobLog() {
        jobLogMapper.cleanJobLog();
    }
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/SysJobServiceImpl.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/service/SysJobServiceImpl.java
@@ -1,21 +1,21 @@
 package com.ruoyi.job.service;

-import java.util.List;
-
-import jakarta.annotation.PostConstruct;
-import org.quartz.JobDataMap;
-import org.quartz.JobKey;
-import org.quartz.Scheduler;
-import org.quartz.SchedulerException;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 import com.ruoyi.common.core.constant.ScheduleConstants;
 import com.ruoyi.common.core.exception.job.TaskException;
 import com.ruoyi.job.domain.SysJob;
 import com.ruoyi.job.mapper.SysJobMapper;
 import com.ruoyi.job.util.CronUtils;
 import com.ruoyi.job.util.ScheduleUtils;
+import jakarta.annotation.PostConstruct;
+import jakarta.annotation.Resource;
+import org.quartz.JobDataMap;
+import org.quartz.JobKey;
+import org.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;

 /**
 * 定时任务调度信息 服务层
@@ -24,10 +24,10 @@ import com.ruoyi.job.util.ScheduleUtils;
 */
@Service
 public class SysJobServiceImpl implements ISysJobService {
-    @Autowired
+    @Resource
    private Scheduler scheduler;

-    @Autowired
+    @Resource
    private SysJobMapper jobMapper;

    /**
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/task/RyTask.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/task/RyTask.java
@@ -5,24 +5,20 @@ import com.ruoyi.common.core.utils.StringUtils;

 /**
 * 定时任务调度测试
- * 
+ *
 * @author ruoyi
 */
@Component("ryTask")
-public class RyTask
-{
-    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
-    {
+public class RyTask {
+    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
        System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
    }

-    public void ryParams(String params)
-    {
+    public void ryParams(String params) {
        System.out.println("执行有参方法：" + params);
    }

-    public void ryNoParams()
-    {
+    public void ryNoParams() {
        System.out.println("执行无参方法");
    }
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/AbstractQuartzJob.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/AbstractQuartzJob.java
@@ -1,11 +1,5 @@
 package com.ruoyi.job.util;

-import java.util.Date;
-import org.quartz.Job;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import com.ruoyi.common.core.constant.ScheduleConstants;
 import com.ruoyi.common.core.utils.ExceptionUtil;
 import com.ruoyi.common.core.utils.SpringUtils;
@@ -14,38 +8,36 @@ import com.ruoyi.common.core.utils.bean.BeanUtils;
 import com.ruoyi.job.domain.SysJob;
 import com.ruoyi.job.domain.SysJobLog;
 import com.ruoyi.job.service.ISysJobLogService;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Date;

 /**
 * 抽象quartz调用
 *
 * @author ruoyi
 */
-public abstract class AbstractQuartzJob implements Job
-{
+public abstract class AbstractQuartzJob implements Job {
    private static final Logger log = LoggerFactory.getLogger(AbstractQuartzJob.class);

    /**
     * 线程本地变量
     */
-    private static ThreadLocal<Date> threadLocal = new ThreadLocal<>();
+    private static final ThreadLocal<Date> threadLocal = new ThreadLocal<>();

    @Override
-    public void execute(JobExecutionContext context) throws JobExecutionException
-    {
+    public void execute(JobExecutionContext context) {
        SysJob sysJob = new SysJob();
        BeanUtils.copyBeanProp(sysJob, context.getMergedJobDataMap().get(ScheduleConstants.TASK_PROPERTIES));
-        try
-        {
+        try {
            before(context, sysJob);
-            if (sysJob != null)
-            {
-                doExecute(context, sysJob);
-            }
+            doExecute(context, sysJob);
            after(context, sysJob, null);
-        }
-        catch (Exception e)
-        {
-            log.error("任务执行异常  - ：", e);
+        } catch (Exception e) {
+            log.error("任务执行异常 - ：", e);
            after(context, sysJob, e);
        }
    }
@@ -54,10 +46,9 @@ public abstract class AbstractQuartzJob implements Job
     * 执行前
     *
     * @param context 工作执行上下文对象
-     * @param sysJob 系统计划任务
+     * @param sysJob  系统计划任务
     */
-    protected void before(JobExecutionContext context, SysJob sysJob)
-    {
+    protected void before(JobExecutionContext context, SysJob sysJob) {
        threadLocal.set(new Date());
    }

@@ -65,10 +56,9 @@ public abstract class AbstractQuartzJob implements Job
     * 执行后
     *
     * @param context 工作执行上下文对象
-     * @param sysJob 系统计划任务
+     * @param sysJob  系统计划任务
     */
-    protected void after(JobExecutionContext context, SysJob sysJob, Exception e)
-    {
+    protected void after(JobExecutionContext context, SysJob sysJob, Exception e) {
        Date startTime = threadLocal.get();
        threadLocal.remove();

@@ -80,14 +70,11 @@ public abstract class AbstractQuartzJob implements Job
        sysJobLog.setStopTime(new Date());
        long runMs = sysJobLog.getStopTime().getTime() - sysJobLog.getStartTime().getTime();
        sysJobLog.setJobMessage(sysJobLog.getJobName() + " 总共耗时：" + runMs + "毫秒");
-        if (e != null)
-        {
+        if (e != null) {
            sysJobLog.setStatus("1");
            String errorMsg = StringUtils.substring(ExceptionUtil.getExceptionMessage(e), 0, 2000);
            sysJobLog.setExceptionInfo(errorMsg);
-        }
-        else
-        {
+        } else {
            sysJobLog.setStatus("0");
        }

@@ -99,7 +86,7 @@ public abstract class AbstractQuartzJob implements Job
     * 执行方法，由子类重载
     *
     * @param context 工作执行上下文对象
-     * @param sysJob 系统计划任务
+     * @param sysJob  系统计划任务
     * @throws Exception 执行过程中的异常
     */
    protected abstract void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception;
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/CronUtils.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/CronUtils.java
@@ -1,25 +1,23 @@
 package com.ruoyi.job.util;

+import org.quartz.CronExpression;
+
 import java.text.ParseException;
 import java.util.Date;
-import org.quartz.CronExpression;

 /**
 * cron表达式工具类
- * 
- * @author ruoyi
 *
+ * @author ruoyi
 */
-public class CronUtils
-{
+public class CronUtils {
    /**
     * 返回一个布尔值代表一个给定的Cron表达式的有效性
     *
     * @param cronExpression Cron表达式
     * @return boolean 表达式是否有效
     */
-    public static boolean isValid(String cronExpression)
-    {
+    public static boolean isValid(String cronExpression) {
        return CronExpression.isValidExpression(cronExpression);
    }

@@ -29,15 +27,11 @@ public class CronUtils
     * @param cronExpression Cron表达式
     * @return String 无效时返回表达式错误描述,如果有效返回null
     */
-    public static String getInvalidMessage(String cronExpression)
-    {
-        try
-        {
+    public static String getInvalidMessage(String cronExpression) {
+        try {
            new CronExpression(cronExpression);
            return null;
-        }
-        catch (ParseException pe)
-        {
+        } catch (ParseException pe) {
            return pe.getMessage();
        }
    }
@@ -48,15 +42,11 @@ public class CronUtils
     * @param cronExpression Cron表达式
     * @return Date 下次Cron表达式执行时间
     */
-    public static Date getNextExecution(String cronExpression)
-    {
-        try
-        {
+    public static Date getNextExecution(String cronExpression) {
+        try {
            CronExpression cron = new CronExpression(cronExpression);
            return cron.getNextValidTimeAfter(new Date(System.currentTimeMillis()));
-        }
-        catch (ParseException e)
-        {
+        } catch (ParseException e) {
            throw new IllegalArgumentException(e.getMessage());
        }
    }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/JobInvokeUtil.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/JobInvokeUtil.java
@@ -1,39 +1,36 @@
 package com.ruoyi.job.util;

+import com.ruoyi.common.core.utils.SpringUtils;
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.job.domain.SysJob;
+
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.util.LinkedList;
 import java.util.List;
-import com.ruoyi.common.core.utils.SpringUtils;
-import com.ruoyi.common.core.utils.StringUtils;
-import com.ruoyi.job.domain.SysJob;

 /**
 * 任务执行工具
 *
 * @author ruoyi
 */
-public class JobInvokeUtil
-{
+public class JobInvokeUtil {
+
    /**
     * 执行方法
     *
     * @param sysJob 系统任务
     */
-    public static void invokeMethod(SysJob sysJob) throws Exception
-    {
+    public static void invokeMethod(SysJob sysJob) throws Exception {
        String invokeTarget = sysJob.getInvokeTarget();
        String beanName = getBeanName(invokeTarget);
        String methodName = getMethodName(invokeTarget);
        List<Object[]> methodParams = getMethodParams(invokeTarget);

-        if (!isValidClassName(beanName))
-        {
+        if (!isValidClassName(beanName)) {
            Object bean = SpringUtils.getBean(beanName);
            invokeMethod(bean, methodName, methodParams);
-        }
-        else
-        {
+        } else {
            Object bean = Class.forName(beanName).getDeclaredConstructor().newInstance();
            invokeMethod(bean, methodName, methodParams);
        }
@@ -42,21 +39,17 @@ public class JobInvokeUtil
    /**
     * 调用任务方法
     *
-     * @param bean 目标对象
-     * @param methodName 方法名称
+     * @param bean         目标对象
+     * @param methodName   方法名称
     * @param methodParams 方法参数
     */
    private static void invokeMethod(Object bean, String methodName, List<Object[]> methodParams)
            throws NoSuchMethodException, SecurityException, IllegalAccessException, IllegalArgumentException,
-            InvocationTargetException
-    {
-        if (StringUtils.isNotNull(methodParams) && methodParams.size() > 0)
-        {
+            InvocationTargetException {
+        if (StringUtils.isNotNull(methodParams) && !methodParams.isEmpty()) {
            Method method = bean.getClass().getMethod(methodName, getMethodParamsType(methodParams));
            method.invoke(bean, getMethodParamsValue(methodParams));
-        }
-        else
-        {
+        } else {
            Method method = bean.getClass().getMethod(methodName);
            method.invoke(bean);
        }
@@ -64,81 +57,70 @@ public class JobInvokeUtil

    /**
     * 校验是否为为class包名
-     * 
+     *
     * @param invokeTarget 名称
     * @return true是 false否
     */
-    public static boolean isValidClassName(String invokeTarget)
-    {
+    public static boolean isValidClassName(String invokeTarget) {
        return StringUtils.countMatches(invokeTarget, ".") > 1;
    }

    /**
     * 获取bean名称
-     * 
+     *
     * @param invokeTarget 目标字符串
     * @return bean名称
     */
-    public static String getBeanName(String invokeTarget)
-    {
+    public static String getBeanName(String invokeTarget) {
        String beanName = StringUtils.substringBefore(invokeTarget, "(");
        return StringUtils.substringBeforeLast(beanName, ".");
    }

    /**
     * 获取bean方法
-     * 
+     *
     * @param invokeTarget 目标字符串
     * @return method方法
     */
-    public static String getMethodName(String invokeTarget)
-    {
+    public static String getMethodName(String invokeTarget) {
        String methodName = StringUtils.substringBefore(invokeTarget, "(");
        return StringUtils.substringAfterLast(methodName, ".");
    }

    /**
     * 获取method方法参数相关列表
-     * 
+     *
     * @param invokeTarget 目标字符串
     * @return method方法相关参数列表
     */
-    public static List<Object[]> getMethodParams(String invokeTarget)
-    {
+    public static List<Object[]> getMethodParams(String invokeTarget) {
        String methodStr = StringUtils.substringBetween(invokeTarget, "(", ")");
-        if (StringUtils.isEmpty(methodStr))
-        {
+        if (StringUtils.isEmpty(methodStr)) {
            return null;
        }
        String[] methodParams = methodStr.split(",(?=([^\"']*[\"'][^\"']*[\"'])*[^\"']*$)");
        List<Object[]> classs = new LinkedList<>();
-        for (int i = 0; i < methodParams.length; i++)
-        {
-            String str = StringUtils.trimToEmpty(methodParams[i]);
+        for (String methodParam : methodParams) {
+            String str = StringUtils.trimToEmpty(methodParam);
            // String字符串类型，以'或"开头
-            if (StringUtils.startsWithAny(str, "'", "\""))
-            {
-                classs.add(new Object[] { StringUtils.substring(str, 1, str.length() - 1), String.class });
+            if (StringUtils.startsWithAny(str, "'", "\"")) {
+                classs.add(new Object[]{StringUtils.substring(str, 1, str.length() - 1), String.class});
            }
            // boolean布尔类型，等于true或者false
-            else if ("true".equalsIgnoreCase(str) || "false".equalsIgnoreCase(str))
-            {
-                classs.add(new Object[] { Boolean.valueOf(str), Boolean.class });
+            else if ("true".equalsIgnoreCase(str) || "false".equalsIgnoreCase(str)) {
+                classs.add(new Object[]{Boolean.valueOf(str), Boolean.class});
            }
            // long长整形，以L结尾
-            else if (StringUtils.endsWith(str, "L"))
-            {
-                classs.add(new Object[] { Long.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Long.class });
+            else if (StringUtils.endsWith(str, "L")) {
+                classs.add(new Object[]{Long.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Long.class});
            }
            // double浮点类型，以D结尾
-            else if (StringUtils.endsWith(str, "D"))
-            {
-                classs.add(new Object[] { Double.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Double.class });
+            else if (StringUtils.endsWith(str, "D")) {
+                classs.add(new Object[]{Double.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Double.class});
            }
            // 其他类型归类为整形
-            else
-            {
-                classs.add(new Object[] { Integer.valueOf(str), Integer.class });
+            else {
+                classs.add(new Object[]{Integer.valueOf(str), Integer.class});
            }
        }
        return classs;
@@ -146,16 +128,14 @@ public class JobInvokeUtil

    /**
     * 获取参数类型
-     * 
+     *
     * @param methodParams 参数相关列表
     * @return 参数类型列表
     */
-    public static Class<?>[] getMethodParamsType(List<Object[]> methodParams)
-    {
+    public static Class<?>[] getMethodParamsType(List<Object[]> methodParams) {
        Class<?>[] classs = new Class<?>[methodParams.size()];
        int index = 0;
-        for (Object[] os : methodParams)
-        {
+        for (Object[] os : methodParams) {
            classs[index] = (Class<?>) os[1];
            index++;
        }
@@ -164,16 +144,14 @@ public class JobInvokeUtil

    /**
     * 获取参数值
-     * 
+     *
     * @param methodParams 参数相关列表
     * @return 参数值列表
     */
-    public static Object[] getMethodParamsValue(List<Object[]> methodParams)
-    {
+    public static Object[] getMethodParamsValue(List<Object[]> methodParams) {
        Object[] classs = new Object[methodParams.size()];
        int index = 0;
-        for (Object[] os : methodParams)
-        {
+        for (Object[] os : methodParams) {
            classs[index] = (Object) os[0];
            index++;
        }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/QuartzDisallowConcurrentExecution.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/QuartzDisallowConcurrentExecution.java
@@ -7,16 +7,13 @@ import com.ruoyi.job.domain.SysJob;

 /**
 * 定时任务处理（禁止并发执行）
- * 
- * @author ruoyi
 *
+ * @author ruoyi
 */
@DisallowConcurrentExecution
-public class QuartzDisallowConcurrentExecution extends AbstractQuartzJob
-{
+public class QuartzDisallowConcurrentExecution extends AbstractQuartzJob {
    @Override
-    protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception
-    {
+    protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception {
        JobInvokeUtil.invokeMethod(sysJob);
    }
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/QuartzJobExecution.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/QuartzJobExecution.java
@@ -6,15 +6,12 @@ import com.ruoyi.job.domain.SysJob;

 /**
 * 定时任务处理（允许并发执行）
- * 
- * @author ruoyi
 *
+ * @author ruoyi
 */
-public class QuartzJobExecution extends AbstractQuartzJob
-{
+public class QuartzJobExecution extends AbstractQuartzJob {
    @Override
-    protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception
-    {
+    protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception {
        JobInvokeUtil.invokeMethod(sysJob);
    }
 }
--- a/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/ScheduleUtils.java
+++ b/ruoyi-modules/ruoyi-job/src/main/java/com/ruoyi/job/util/ScheduleUtils.java
@@ -30,9 +30,21 @@ public class ScheduleUtils {
     * @param sysJob 执行计划
     * @return 具体执行任务类
     */
-    private static Class<? extends Job> getQuartzJobClass(SysJob sysJob) {
-        boolean isConcurrent = "0".equals(sysJob.getConcurrent());
-        return isConcurrent ? QuartzJobExecution.class : QuartzDisallowConcurrentExecution.class;
+    @SuppressWarnings("unchecked")
+    private static Class<? extends Job> getQuartzJobClass(SysJob sysJob) throws TaskException {
+        String customJobClass = sysJob.getCustomJobClass();
+        if (StringUtils.isNotBlank(customJobClass)) {
+            // 使用自定义任务类
+            try {
+                return (Class<? extends Job>) Class.forName(customJobClass);
+            } catch (Exception e) {
+                throw new TaskException("Custom job class [" + customJobClass + "] not exists", Code.CONFIG_ERROR);
+            }
+        } else {
+            // 使用系统任务类
+            boolean isConcurrent = "0".equals(sysJob.getConcurrent());
+            return isConcurrent ? QuartzJobExecution.class : QuartzDisallowConcurrentExecution.class;
+        }
    }

    /**
--- a/ruoyi-modules/ruoyi-job/src/main/resources/com/ruoyi/job/mapper/SysJobMapper.xml
+++ b/ruoyi-modules/ruoyi-job/src/main/resources/com/ruoyi/job/mapper/SysJobMapper.xml
@@ -1,111 +1,128 @@
 <?xml version="1.0" encoding="UTF-8" ?>
 <!DOCTYPE mapper
-PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
-"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.ruoyi.job.mapper.SysJobMapper">

-	<resultMap type="SysJob" id="SysJobResult">
-		<id     property="jobId"          column="job_id"          />
-		<result property="jobName"        column="job_name"        />
-		<result property="jobGroup"       column="job_group"       />
-		<result property="invokeTarget"   column="invoke_target"   />
-		<result property="cronExpression" column="cron_expression" />
-		<result property="misfirePolicy"  column="misfire_policy"  />
-		<result property="concurrent"     column="concurrent"      />
-		<result property="status"         column="status"          />
-		<result property="createBy"       column="create_by"       />
-		<result property="createTime"     column="create_time"     />
-		<result property="updateBy"       column="update_by"       />
-		<result property="updateTime"     column="update_time"     />
-		<result property="remark"         column="remark"          />
-	</resultMap>
-	
-	<sql id="selectJobVo">
-        select job_id, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark 
-		from sys_job
+    <resultMap type="com.ruoyi.job.domain.SysJob" id="SysJobResult">
+        <id property="jobId" column="job_id"/>
+        <result property="jobName" column="job_name"/>
+        <result property="jobGroup" column="job_group"/>
+        <result property="invokeTarget" column="invoke_target"/>
+        <result property="cronExpression" column="cron_expression"/>
+        <result property="misfirePolicy" column="misfire_policy"/>
+        <result property="concurrent" column="concurrent"/>
+        <result property="status" column="status"/>
+        <result property="customJobClass" column="custom_job_class"/>
+        <result property="createBy" column="create_by"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateBy" column="update_by"/>
+        <result property="updateTime" column="update_time"/>
+        <result property="remark" column="remark"/>
+    </resultMap>
+
+    <sql id="selectJobVo">
+        select job_id,
+               job_name,
+               job_group,
+               invoke_target,
+               cron_expression,
+               misfire_policy,
+               concurrent,
+               status,
+               custom_job_class,
+               create_by,
+               create_time,
+               remark
+        from sys_job
    </sql>
-	
-	<select id="selectJobList" parameterType="SysJob" resultMap="SysJobResult">
-		<include refid="selectJobVo"/>
-		<where>
-			<if test="jobName != null and jobName != ''">
-				AND job_name like concat('%', #{jobName}, '%')
-			</if>
-			<if test="jobGroup != null and jobGroup != ''">
-				AND job_group = #{jobGroup}
-			</if>
-			<if test="status != null and status != ''">
-				AND status = #{status}
-			</if>
-			<if test="invokeTarget != null and invokeTarget != ''">
-				AND invoke_target like concat('%', #{invokeTarget}, '%')
-			</if>
-		</where>
-	</select>
-	
-	<select id="selectJobAll" resultMap="SysJobResult">
-		<include refid="selectJobVo"/>
-	</select>
-	
-	<select id="selectJobById" parameterType="Long" resultMap="SysJobResult">
-		<include refid="selectJobVo"/>
-		where job_id = #{jobId}
-	</select>
-	
-	<delete id="deleteJobById" parameterType="Long">
- 		delete from sys_job where job_id = #{jobId}
- 	</delete>
- 	
- 	<delete id="deleteJobByIds" parameterType="Long">
- 		delete from sys_job where job_id in
- 		<foreach collection="array" item="jobId" open="(" separator="," close=")">
- 			#{jobId}
-        </foreach> 
- 	</delete>
- 	
- 	<update id="updateJob" parameterType="SysJob">
- 		update sys_job
- 		<set>
- 			<if test="jobName != null and jobName != ''">job_name = #{jobName},</if>
- 			<if test="jobGroup != null and jobGroup != ''">job_group = #{jobGroup},</if>
- 			<if test="invokeTarget != null and invokeTarget != ''">invoke_target = #{invokeTarget},</if>
- 			<if test="cronExpression != null and cronExpression != ''">cron_expression = #{cronExpression},</if>
- 			<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy = #{misfirePolicy},</if>
- 			<if test="concurrent != null and concurrent != ''">concurrent = #{concurrent},</if>
- 			<if test="status !=null">status = #{status},</if>
- 			<if test="remark != null and remark != ''">remark = #{remark},</if>
- 			<if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
- 			update_time = sysdate()
- 		</set>
- 		where job_id = #{jobId}
-	</update>
- 	
- 	<insert id="insertJob" parameterType="SysJob" useGeneratedKeys="true" keyProperty="jobId">
- 		insert into sys_job(
- 			<if test="jobId != null and jobId != 0">job_id,</if>
- 			<if test="jobName != null and jobName != ''">job_name,</if>
- 			<if test="jobGroup != null and jobGroup != ''">job_group,</if>
- 			<if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
- 			<if test="cronExpression != null and cronExpression != ''">cron_expression,</if>
- 			<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy,</if>
- 			<if test="concurrent != null and concurrent != ''">concurrent,</if>
- 			<if test="status != null and status != ''">status,</if>
- 			<if test="remark != null and remark != ''">remark,</if>
- 			<if test="createBy != null and createBy != ''">create_by,</if>
- 			create_time
- 		)values(
- 			<if test="jobId != null and jobId != 0">#{jobId},</if>
- 			<if test="jobName != null and jobName != ''">#{jobName},</if>
- 			<if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
- 			<if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
- 			<if test="cronExpression != null and cronExpression != ''">#{cronExpression},</if>
- 			<if test="misfirePolicy != null and misfirePolicy != ''">#{misfirePolicy},</if>
- 			<if test="concurrent != null and concurrent != ''">#{concurrent},</if>
- 			<if test="status != null and status != ''">#{status},</if>
- 			<if test="remark != null and remark != ''">#{remark},</if>
- 			<if test="createBy != null and createBy != ''">#{createBy},</if>
- 			sysdate()
- 		)
-	</insert>
+
+    <select id="selectJobList" parameterType="com.ruoyi.job.domain.SysJob" resultMap="SysJobResult">
+        <include refid="selectJobVo"/>
+        <where>
+            <if test="jobName != null and jobName != ''">
+                AND job_name like concat('%', #{jobName}, '%')
+            </if>
+            <if test="jobGroup != null and jobGroup != ''">
+                AND job_group = #{jobGroup}
+            </if>
+            <if test="status != null and status != ''">
+                AND status = #{status}
+            </if>
+            <if test="invokeTarget != null and invokeTarget != ''">
+                AND invoke_target like concat('%', #{invokeTarget}, '%')
+            </if>
+        </where>
+    </select>
+
+    <select id="selectJobAll" resultMap="SysJobResult">
+        <include refid="selectJobVo"/>
+    </select>
+
+    <select id="selectJobById" parameterType="Long" resultMap="SysJobResult">
+        <include refid="selectJobVo"/>
+        where job_id = #{jobId}
+    </select>
+
+    <delete id="deleteJobById" parameterType="Long">
+        delete
+        from sys_job
+        where job_id = #{jobId}
+    </delete>
+
+    <delete id="deleteJobByIds" parameterType="Long">
+        delete from sys_job where job_id in
+        <foreach collection="array" item="jobId" open="(" separator="," close=")">
+            #{jobId}
+        </foreach>
+    </delete>
+
+    <update id="updateJob" parameterType="com.ruoyi.job.domain.SysJob">
+        update sys_job
+        <set>
+            <if test="jobName != null and jobName != ''">job_name = #{jobName},</if>
+            <if test="jobGroup != null and jobGroup != ''">job_group = #{jobGroup},</if>
+            <if test="invokeTarget != null and invokeTarget != ''">invoke_target = #{invokeTarget},</if>
+            <if test="cronExpression != null and cronExpression != ''">cron_expression = #{cronExpression},</if>
+            <if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy = #{misfirePolicy},</if>
+            <if test="concurrent != null and concurrent != ''">concurrent = #{concurrent},</if>
+            <if test="status !=null">status = #{status},</if>
+            <if test="customJobClass !=null and customJobClass != ''">custom_job_class = #{customJobClass},</if>
+            <if test="remark != null and remark != ''">remark = #{remark},</if>
+            <if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
+            update_time = sysdate()
+        </set>
+        where job_id = #{jobId}
+    </update>
+
+    <insert id="insertJob" parameterType="com.ruoyi.job.domain.SysJob" useGeneratedKeys="true" keyProperty="jobId">
+        insert into sys_job(
+        <if test="jobId != null and jobId != 0">job_id,</if>
+        <if test="jobName != null and jobName != ''">job_name,</if>
+        <if test="jobGroup != null and jobGroup != ''">job_group,</if>
+        <if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
+        <if test="cronExpression != null and cronExpression != ''">cron_expression,</if>
+        <if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy,</if>
+        <if test="concurrent != null and concurrent != ''">concurrent,</if>
+        <if test="status != null and status != ''">status,</if>
+        <if test="customJobClass != null and customJobClass != ''">custom_job_class,</if>
+        <if test="remark != null and remark != ''">remark,</if>
+        <if test="createBy != null and createBy != ''">create_by,</if>
+        create_time
+        )values(
+        <if test="jobId != null and jobId != 0">#{jobId},</if>
+        <if test="jobName != null and jobName != ''">#{jobName},</if>
+        <if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
+        <if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
+        <if test="cronExpression != null and cronExpression != ''">#{cronExpression},</if>
+        <if test="misfirePolicy != null and misfirePolicy != ''">#{misfirePolicy},</if>
+        <if test="concurrent != null and concurrent != ''">#{concurrent},</if>
+        <if test="status != null and status != ''">#{status},</if>
+        <if test="customJobClass != null and customJobClass != ''">#{customJobClass},</if>
+        <if test="remark != null and remark != ''">#{remark},</if>
+        <if test="createBy != null and createBy != ''">#{createBy},</if>
+        sysdate()
+        )
+    </insert>

 </mapper>