etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加字段和表

master
Cui YongXing 2024-08-31 19:08:25 +08:00
parent 230b90c5c2
commit 823631867d
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInputServiceImpl.java
View File

@ -6,9 +6,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.domian.NodeJoint;
import com.muyu.common.domian.TaskInput;
import com.muyu.common.domian.req.TaskInputListReq;
import com.muyu.task.server.mapper.TaskInputMapper;
import com.muyu.task.server.service.NodeJointService;
import com.muyu.task.server.service.NodeTableService;
import com.muyu.task.server.service.TaskInputService;
import org.springframework.beans.factory.annotation.Autowired;
@ -25,6 +27,8 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
@Autowired
private NodeTableService tableService;
@Autowired
private NodeJointService nodeJointService;
@Override
public Page<TaskInput> findList(TaskInputListReq req) {
@ -35,6 +39,9 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
return this.page(page, wrapper);
}
@Override
public String findByFieName(Long taskId) {
QueryWrapper<TaskInput> wrapper = new QueryWrapper<>();
@ -47,8 +54,16 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
for (int i = 0; i < list.size(); i++) {
fieName+= ","+list.get(i).getTableAsFieId();
}
QueryWrapper<NodeJoint> jointQueryWrapper = new QueryWrapper<>();
jointQueryWrapper.eq("task_id",taskId);
List<NodeJoint> jointList = nodeJointService.list(jointQueryWrapper);
for (NodeJoint nodeJoint : jointList) {
}
fieName = fieName.substring(1);
// tableService.selectTableName(taskId);
// tableService.selectTableName(taskId);
return null;
}
}