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

名称修改

master
Cui YongXing 2024-08-26 19:01:06 +08:00
parent 15a60886d2
commit a0d771dbf9
2 changed files with 5 additions and 5 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

@ -31,7 +31,6 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
queryWrapper.eq(StringUtils.isNotEmpty(req.getProcessStatus()), TaskInfo::getProcessStatus, req.getProcessStatus());
Page<TaskInfo> page = new Page<>(req.getPageNum(), req.getPageSize());
Page<TaskInfo> taskInfoPage = taskInfoMapper.selectPage(page, queryWrapper);
long total = taskInfoPage.getTotal();
long pages = taskInfoPage.getPages();
long size = taskInfoPage.getSize();
long current = taskInfoPage.getCurrent();
@ -40,7 +39,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
respPage.setRecords(list);
respPage.setCurrent(current);
respPage.setSize(size);
respPage.setTotal(total);
respPage.setTotal(this.count(queryWrapper));
respPage.setPages(pages);
return respPage;
}

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

@ -6,17 +6,18 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.domian.TaskInput;
import com.muyu.common.domian.req.TaskInputListReq;
import com.muyu.task.server.mapper.NodeMapper;
import com.muyu.task.server.service.NodeService;
import com.muyu.task.server.mapper.TaskInputMapper;
import com.muyu.task.server.service.TaskInputService;
import org.springframework.stereotype.Service;
@Service
public class NodeServiceImpl extends ServiceImpl<NodeMapper, TaskInput> implements NodeService {
public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput> implements TaskInputService {
@Override
public Page<TaskInput> findList(TaskInputListReq req) {
LambdaQueryWrapper<TaskInput> wrapper = new LambdaQueryWrapper<>();
wrapper.like(StringUtils.isNotEmpty(req.getNodeName()), TaskInput::getNodeName, req.getNodeName());
Page<TaskInput> page = new Page<>(req.getPageNum(), req.getPageSize());
page.setTotal(this.count(wrapper));
return this.page(page, wrapper);
}
}