From d8c9e84465c960df673d1208c882921e0114913d Mon Sep 17 00:00:00 2001
From: Odboy <tianjun@odboy.cn>
Date: Thu, 27 Mar 2025 18:57:31 +0800
Subject: [PATCH] =?UTF-8?q?upd:=20=E7=BC=96=E7=A0=81=E8=A7=84=E8=8C=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/odboy/application/job/util/ExecutionJob.java    | 10 +++++-----
 .../cn/odboy/application/job/util/QuartzRunnable.java  |  5 ++---
 2 files changed, 7 insertions(+), 8 deletions(-)

diff --git a/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/ExecutionJob.java b/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/ExecutionJob.java
index 648a20dd..09936b4d 100644
--- a/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/ExecutionJob.java
+++ b/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/ExecutionJob.java
@@ -14,9 +14,8 @@ import cn.odboy.model.job.domain.QuartzLog;
 import cn.odboy.model.tools.dto.EmailDto;
 import cn.odboy.util.RedisUtil;
 import cn.odboy.util.StringUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.quartz.JobExecutionContext;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.scheduling.quartz.QuartzJobBean;
 
@@ -26,8 +25,8 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.Future;
 
+@Slf4j
 public class ExecutionJob extends QuartzJobBean {
-    private final Logger logger = LoggerFactory.getLogger(this.getClass());
     /**
      * 此处仅供参考，可根据任务执行情况自定义线程池参数
      */
@@ -55,6 +54,7 @@ public class ExecutionJob extends QuartzJobBean {
             // 执行任务
             QuartzRunnable task = new QuartzRunnable(quartzJob.getBeanName(), quartzJob.getMethodName(), quartzJob.getParams());
             Future<?> future = executor.submit(task);
+            // 忽略任务执行结果
             future.get();
             long times = System.currentTimeMillis() - startTime;
             quartzLog.setTime(times);
@@ -63,7 +63,7 @@ public class ExecutionJob extends QuartzJobBean {
             }
             // 任务状态
             quartzLog.setIsSuccess(true);
-            logger.info("任务执行成功，任务名称：{}, 执行时间：{}毫秒", quartzJob.getJobName(), times);
+            log.info("任务执行成功，任务名称：{}, 执行时间：{}毫秒", quartzJob.getJobName(), times);
             // 判断是否存在子任务
             if (StringUtil.isNotBlank(quartzJob.getSubTask())) {
                 String[] tasks = quartzJob.getSubTask().split("[,，]");
@@ -74,7 +74,7 @@ public class ExecutionJob extends QuartzJobBean {
             if (StringUtil.isNotBlank(uuid)) {
                 redisUtil.set(uuid, false);
             }
-            logger.error("任务执行失败，任务名称：{}", quartzJob.getJobName());
+            log.error("任务执行失败，任务名称：{}", quartzJob.getJobName(), e);
             long times = System.currentTimeMillis() - startTime;
             quartzLog.setTime(times);
             // 任务状态 0：成功 1：失败
diff --git a/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/QuartzRunnable.java b/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/QuartzRunnable.java
index fd246662..38225741 100644
--- a/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/QuartzRunnable.java
+++ b/cutejava/cutejava-job/src/main/java/cn/odboy/application/job/util/QuartzRunnable.java
@@ -32,10 +32,9 @@ public class QuartzRunnable implements Callable<Object> {
     public Object call() throws Exception {
         ReflectionUtils.makeAccessible(method);
         if (StringUtils.isNotBlank(params)) {
-            method.invoke(target, params);
+            return method.invoke(target, params);
         } else {
-            method.invoke(target);
+            return method.invoke(target);
         }
-        return null;
     }
 }