From 591810899f40fa6717ffa1349c6cb695feba4674 Mon Sep 17 00:00:00 2001
From: Odboy <tianjun@odboy.cn>
Date: Sun, 26 Oct 2025 11:00:00 +0800
Subject: [PATCH] =?UTF-8?q?fix(task):=20=E6=A0=A1=E9=AA=8C=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E8=8A=82=E7=82=B9=E6=89=A7=E8=A1=8C=E5=8F=82=E6=95=B0?=
 =?UTF-8?q?=E5=B9=B6=E8=AE=B0=E5=BD=95=E5=BC=82=E5=B8=B8=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=20-=20=E6=B7=BB=E5=8A=A0=E5=AF=B9=E4=BB=BB=E5=8A=A1=E4=BB=A3?=
 =?UTF-8?q?=E7=A0=81=E5=8F=82=E6=95=B0=E7=9A=84=E9=9D=9E=E7=A9=BA=E6=A0=A1?=
 =?UTF-8?q?=E9=AA=8C=EF=BC=8C=E9=81=BF=E5=85=8D=E7=A9=BA=E6=8C=87=E9=92=88?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8=20-=20=E5=9C=A8=E4=BB=BB=E5=8A=A1=E8=8A=82?=
 =?UTF-8?q?=E7=82=B9=E6=89=A7=E8=A1=8C=E5=A4=B1=E8=B4=A5=E6=97=B6=E8=AE=B0?=
 =?UTF-8?q?=E5=BD=95=E8=AF=A6=E7=BB=86=E7=9A=84=E9=94=99=E8=AF=AF=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=20-=20=E4=BC=98=E5=8C=96=E5=BC=82=E5=B8=B8=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E6=B5=81=E7=A8=8B=EF=BC=8C=E7=A1=AE=E4=BF=9D=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E4=BF=A1=E6=81=AF=E5=87=86=E7=A1=AE=E4=BC=A0=E9=80=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/cn/odboy/task/core/TaskJobBean.java         | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cutejava/cutejava-module-task/src/main/java/cn/odboy/task/core/TaskJobBean.java b/cutejava/cutejava-module-task/src/main/java/cn/odboy/task/core/TaskJobBean.java
index ba812633..7e1175a9 100644
--- a/cutejava/cutejava-module-task/src/main/java/cn/odboy/task/core/TaskJobBean.java
+++ b/cutejava/cutejava-module-task/src/main/java/cn/odboy/task/core/TaskJobBean.java
@@ -45,6 +45,9 @@ public class TaskJobBean extends QuartzJobBean implements InterruptableJob {
     private Thread workThread = null;
 
     private String getBeanAlias(String code) {
+        if (StrUtil.isBlank(code)) {
+            throw new ServerException("参数code必填");
+        }
         // node_init
         String[] s = code.split("_");
         return Arrays.stream(s).map(StrUtil::upperFirst).collect(Collectors.joining());
@@ -172,6 +175,7 @@ public class TaskJobBean extends QuartzJobBean implements InterruptableJob {
                     executor.execute(codeIdMap.getOrDefault(code, null), dataMap, taskTemplateNodeVo);
                     taskInstanceDetailService.fastSuccessWithInfo(id, code, null);
                 } catch (Exception e) {
+                    log.error("任务节点执行失败", e);
                     taskInstanceDetailService.fastFailWithInfo(id, code, e.getMessage());
                     throw new ServerException(e);
                 }