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

添加实体类

master
陈思豪 2024-09-01 14:53:27 +08:00
parent 5f5c46d8f4
commit 87b6929cea
2 changed files with 1 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-task-common/src/main/java/com/muyu/domain/TaskInputInfo.java
View File

@ -73,11 +73,6 @@ public class TaskInputInfo extends BaseEntity {
*/ */
private String fieldAsEngineId; private String fieldAsEngineId;
/**
* 选中字段列表
*/
@TableField(exist = false)
private List<Structure> columnList;

9
cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java
View File

@ -43,13 +43,6 @@ public class TaskInputInfoServiceImpl extends ServiceImpl<TaskInputInfoMapper, T
public TaskInputInfo findByNodeId(String nodeId) { public TaskInputInfo findByNodeId(String nodeId) {
LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(TaskInputInfo::getNodeId, nodeId); queryWrapper.eq(TaskInputInfo::getNodeId, nodeId);
TaskInputInfo taskInputInfo = taskInputInfoMapper.selectOne(queryWrapper); return taskInputInfoMapper.selectOne(queryWrapper);
if(taskInputInfo==null){
return new TaskInputInfo();
}
String tableField = taskInputInfo.getTableField();
List<Structure> structures = JSON.parseArray(tableField, Structure.class);
taskInputInfo.setColumnList(structures);
return taskInputInfo;
} }
} }