gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix(sj_map_reduce): 修复获取任务项树接口

Browse Source
This commit is contained in:
xlsea 2024-06-21 17:32:36 +08:00
parent ac27041be6
commit 5343299ff3
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobTaskServiceImpl.java
View File

@ -2,6 +2,7 @@ package com.aizuda.snailjob.server.web.service.impl;
import cn.hutool.core.lang.tree.Tree; import cn.hutool.core.lang.tree.Tree;
import cn.hutool.core.lang.tree.TreeNode; import cn.hutool.core.lang.tree.TreeNode;
import cn.hutool.core.lang.tree.TreeNodeConfig;
import cn.hutool.core.lang.tree.TreeUtil; import cn.hutool.core.lang.tree.TreeUtil;
import com.aizuda.snailjob.common.core.util.JsonUtil; import com.aizuda.snailjob.common.core.util.JsonUtil;
import com.aizuda.snailjob.server.web.model.base.PageResult; import com.aizuda.snailjob.server.web.model.base.PageResult;
@ -62,15 +63,11 @@ public class JobTaskServiceImpl implements JobTaskService {
// SQLServer 分页必须 ORDER BY // SQLServer 分页必须 ORDER BY
.orderByAsc(JobTask::getJobId)); .orderByAsc(JobTask::getJobId));
List<TreeNode<Long>> treeNodes = new ArrayList<>(); return TreeUtil.build(jobTasks, 0L, (jobTask, tree) -> {
for (final JobTask jobTask : jobTasks) { tree.setId(jobTask.getId());
TreeNode<Long> treeNode = new TreeNode<>(); tree.setName(jobTask.getTaskName());
treeNode.setId(jobTask.getId()); tree.setParentId(jobTask.getParentId());
treeNode.setName(jobTask.getTaskName()); tree.putExtra("jobTask", jobTask);
treeNode.setExtra(JsonUtil.parseHashMap(JsonUtil.toJsonString(jobTask), Object.class)); });
treeNodes.add(treeNode);
}
return TreeUtil.build(treeNodes, 0L);
} }
} }