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

添加字段和表

master
Cui YongXing 2024-09-02 21:24:29 +08:00
parent b1b7efd3e7
commit e8e9146a64
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -19,6 +19,7 @@ import com.muyu.task.server.service.NodeJointService;
import com.muyu.task.server.service.TaskInfoService; import com.muyu.task.server.service.TaskInfoService;
import com.muyu.task.server.service.TaskInputService; import com.muyu.task.server.service.TaskInputService;
import com.muyu.task.server.service.TaskOutputService; import com.muyu.task.server.service.TaskOutputService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@ -32,6 +33,7 @@ import java.util.List;
/** /**
* @author Administrator * @author Administrator
*/ */
@Log4j2
@Service @Service
public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> implements TaskInfoService { public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> implements TaskInfoService {
@ -227,6 +229,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String key = dataValue.getKey(); String key = dataValue.getKey();
String newKey = map.get(key); String newKey = map.get(key);
dataValue.setKey(newKey); dataValue.setKey(newKey);
log.info(dataValue);
} }
} }
return "执行成功"; return "执行成功";