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