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

添加实体类

master
陈思豪 2024-08-30 22:16:26 +08:00
parent 417c1d6add
commit f3ad332d4b
5 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,5 +1,6 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.muyu.common.core.web.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
@ -72,6 +73,12 @@ public class TaskInputInfo extends BaseEntity {
*/
private String fieldAsEngineId;
/**
* 选中字段列表
*/
@TableField(exist = false)
private List<Structure> columnList;

2
cloud-task-common/src/main/java/com/muyu/domain/resp/TaskInputInfoResp.java
View File

@ -20,6 +20,6 @@ import java.util.List;
@NoArgsConstructor
@Data
public class TaskInputInfoResp extends TaskInputInfo {
private List<Structure> structureList;
private List<Structure> columnList;
}

1
cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java
View File

@ -2,6 +2,7 @@ package com.muyu.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.TaskInputInfo;
import com.muyu.domain.resp.TaskInputInfoResp;
import com.muyu.service.TaskInputService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

1
cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java
View File

@ -3,6 +3,7 @@ package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.TaskInputInfo;
import com.muyu.domain.resp.TaskInputInfoResp;
import java.util.List;

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

@ -1,15 +1,19 @@
package com.muyu.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.Structure;
import com.muyu.domain.TaskInputInfo;
import com.muyu.domain.resp.TaskInputInfoResp;
import com.muyu.mapper.TaskInputInfoMapper;
import com.muyu.service.TaskInputService;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
@ -39,6 +43,10 @@ public class TaskInputInfoServiceImpl extends ServiceImpl<TaskInputInfoMapper, T
public TaskInputInfo findByNodeId(String nodeId) {
LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(TaskInputInfo::getNodeId, nodeId);
return taskInputInfoMapper.selectOne(queryWrapper);
TaskInputInfo taskInputInfo = taskInputInfoMapper.selectOne(queryWrapper);
String tableField = taskInputInfo.getTableField();
List<Structure> structures = JSON.parseArray(tableField, Structure.class);
taskInputInfo.setColumnList(structures);
return taskInputInfo;
}
}