From b88254084d47fe4392553bcad573f29e0b778e51 Mon Sep 17 00:00:00 2001 From: Odboy Date: Sun, 11 Jan 2026 20:21:56 +0800 Subject: [PATCH] style(task) --- .../java/cn/odboy/task/core/TaskJobBean.java | 21 +++++++------------ .../cn/odboy/task/core/TaskStepExecutor.java | 3 +-- 2 files changed, 8 insertions(+), 16 deletions(-) diff --git a/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskJobBean.java b/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskJobBean.java index 1ee98091..2317be99 100644 --- a/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskJobBean.java +++ b/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskJobBean.java @@ -55,8 +55,7 @@ public class TaskJobBean extends QuartzJobBean { public void executeInternal(JobExecutionContext context) { // ========================== 获取代理类 ========================== TaskInstanceInfoService taskInstanceInfoService = KitSpringBeanHolder.getBean(TaskInstanceInfoService.class); - TaskInstanceDetailService taskInstanceDetailService = - KitSpringBeanHolder.getBean(TaskInstanceDetailService.class); + TaskInstanceDetailService taskInstanceDetailService = KitSpringBeanHolder.getBean(TaskInstanceDetailService.class); // ========================== 获取参数 ========================== JobDataMap dataMap = context.getMergedJobDataMap(); long id = dataMap.getLong(TaskJobKeys.ID); @@ -69,8 +68,7 @@ public class TaskJobBean extends QuartzJobBean { if (StrUtil.isBlank(retryNodeCode)) { executeNormalTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos); } else { - executeRetryTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, - retryNodeCode); + executeRetryTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, retryNodeCode); } } @@ -83,19 +81,14 @@ public class TaskJobBean extends QuartzJobBean { * @param dataMap 数据映射 * @param taskTemplateNodeVos 模板节点列表 */ - private void executeNormalTask(TaskInstanceInfoService taskInstanceInfoService, - TaskInstanceDetailService taskInstanceDetailService, long id, JobDataMap dataMap, - List taskTemplateNodeVos) { + private void executeNormalTask(TaskInstanceInfoService taskInstanceInfoService, TaskInstanceDetailService taskInstanceDetailService, long id, JobDataMap dataMap, List taskTemplateNodeVos) { // ========================== 初始化执行明细 ========================== - List taskInstanceDetails = - taskTemplateNodeVos.stream().map(taskTemplateNodeVo -> buildTaskInstanceDetail(id, taskTemplateNodeVo)) - .collect(Collectors.toList()); + List taskInstanceDetails = taskTemplateNodeVos.stream().map(taskTemplateNodeVo -> buildTaskInstanceDetail(id, taskTemplateNodeVo)) + .collect(Collectors.toList()); taskInstanceDetailService.saveBatch(taskInstanceDetails); - Map codeIdMap = taskInstanceDetails.stream() - .collect(Collectors.toMap(TaskInstanceDetailTb::getBizCode, TaskInstanceDetailTb::getId)); + Map codeIdMap = taskInstanceDetails.stream().collect(Collectors.toMap(TaskInstanceDetailTb::getBizCode, TaskInstanceDetailTb::getId)); // ========================== 顺序执行 ========================== - executeTaskSteps(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, - codeIdMap); + executeTaskSteps(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, codeIdMap); } /** diff --git a/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskStepExecutor.java b/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskStepExecutor.java index a56ec20f..21483e9b 100644 --- a/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskStepExecutor.java +++ b/cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskStepExecutor.java @@ -26,6 +26,5 @@ public interface TaskStepExecutor { * @param jobDataMap 执行参数 * @param taskTemplateNode 任务节点信息 */ - void execute(Long instanceDetailId, JobDataMap jobDataMap, TaskTemplateNodeVo taskTemplateNode) - throws BadRequestException; + void execute(Long instanceDetailId, JobDataMap jobDataMap, TaskTemplateNodeVo taskTemplateNode) throws BadRequestException; }