odboy/cutejava
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style(task)

Browse Source
This commit is contained in:
odboy
2026-01-12 15:55:51 +08:00
parent a55fbe0f06
commit b88254084d
2 changed files with 8 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskJobBean.java
+7 -14
View File
@@ -55,8 +55,7 @@ public class TaskJobBean extends QuartzJobBean {
public void executeInternal(JobExecutionContext context) { public void executeInternal(JobExecutionContext context) {
// ========================== 获取代理类 ========================== // ========================== 获取代理类 ==========================
TaskInstanceInfoService taskInstanceInfoService = KitSpringBeanHolder.getBean(TaskInstanceInfoService.class); TaskInstanceInfoService taskInstanceInfoService = KitSpringBeanHolder.getBean(TaskInstanceInfoService.class);
TaskInstanceDetailService taskInstanceDetailService = TaskInstanceDetailService taskInstanceDetailService = KitSpringBeanHolder.getBean(TaskInstanceDetailService.class);
KitSpringBeanHolder.getBean(TaskInstanceDetailService.class);
// ========================== 获取参数 ========================== // ========================== 获取参数 ==========================
JobDataMap dataMap = context.getMergedJobDataMap(); JobDataMap dataMap = context.getMergedJobDataMap();
long id = dataMap.getLong(TaskJobKeys.ID); long id = dataMap.getLong(TaskJobKeys.ID);
@@ -69,8 +68,7 @@ public class TaskJobBean extends QuartzJobBean {
if (StrUtil.isBlank(retryNodeCode)) { if (StrUtil.isBlank(retryNodeCode)) {
executeNormalTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos); executeNormalTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos);
} else { } else {
executeRetryTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, executeRetryTask(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, retryNodeCode);
retryNodeCode);
} }
} }
@@ -83,19 +81,14 @@ public class TaskJobBean extends QuartzJobBean {
* @param dataMap 数据映射 * @param dataMap 数据映射
* @param taskTemplateNodeVos 模板节点列表 * @param taskTemplateNodeVos 模板节点列表
*/ */
private void executeNormalTask(TaskInstanceInfoService taskInstanceInfoService, private void executeNormalTask(TaskInstanceInfoService taskInstanceInfoService, TaskInstanceDetailService taskInstanceDetailService, long id, JobDataMap dataMap, List<TaskTemplateNodeVo> taskTemplateNodeVos) {
TaskInstanceDetailService taskInstanceDetailService, long id, JobDataMap dataMap,
List<TaskTemplateNodeVo> taskTemplateNodeVos) {
// ========================== 初始化执行明细 ========================== // ========================== 初始化执行明细 ==========================
List<TaskInstanceDetailTb> taskInstanceDetails = List<TaskInstanceDetailTb> taskInstanceDetails = taskTemplateNodeVos.stream().map(taskTemplateNodeVo -> buildTaskInstanceDetail(id, taskTemplateNodeVo))
taskTemplateNodeVos.stream().map(taskTemplateNodeVo -> buildTaskInstanceDetail(id, taskTemplateNodeVo)) .collect(Collectors.toList());
.collect(Collectors.toList());
taskInstanceDetailService.saveBatch(taskInstanceDetails); taskInstanceDetailService.saveBatch(taskInstanceDetails);
Map<String, Long> codeIdMap = taskInstanceDetails.stream() Map<String, Long> codeIdMap = taskInstanceDetails.stream().collect(Collectors.toMap(TaskInstanceDetailTb::getBizCode, TaskInstanceDetailTb::getId));
.collect(Collectors.toMap(TaskInstanceDetailTb::getBizCode, TaskInstanceDetailTb::getId));
// ========================== 顺序执行 ========================== // ========================== 顺序执行 ==========================
executeTaskSteps(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, executeTaskSteps(taskInstanceInfoService, taskInstanceDetailService, id, dataMap, taskTemplateNodeVos, codeIdMap);
codeIdMap);
} }
/** /**
cutejava/cutejava-module-task-v2/src/main/java/cn/odboy/task/core/TaskStepExecutor.java
+1 -2
View File
@@ -26,6 +26,5 @@ public interface TaskStepExecutor {
* @param jobDataMap 执行参数 * @param jobDataMap 执行参数
* @param taskTemplateNode 任务节点信息 * @param taskTemplateNode 任务节点信息
*/ */
void execute(Long instanceDetailId, JobDataMap jobDataMap, TaskTemplateNodeVo taskTemplateNode) void execute(Long instanceDetailId, JobDataMap jobDataMap, TaskTemplateNodeVo taskTemplateNode) throws BadRequestException;
throws BadRequestException;
} }