8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

optimize the migration task name

Browse Source
This commit is contained in:
Xiang Hong Wei
2021-05-07 19:06:47 +08:00
parent f1627b214c
commit 736d5a00b7
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/converters/ReassignModelConverter.java
View File

@@ -89,18 +89,20 @@ public class ReassignModelConverter {
} }
ReassignTaskVO vo = new ReassignTaskVO(); ReassignTaskVO vo = new ReassignTaskVO();
vo.setTaskName(String.format("%s 数据迁移任务", DateUtils.getFormattedDate(taskId)));
vo.setTaskId(taskId); vo.setTaskId(taskId);
vo.setTotalTopicNum(doList.size()); vo.setTotalTopicNum(doList.size());
vo.setBeginTime(0L); vo.setBeginTime(0L);
vo.setEndTime(0L); vo.setEndTime(0L);
Integer completedTopicNum = 0; Integer completedTopicNum = 0;
StringBuilder clusterAndTopicName = new StringBuilder();
Set<Integer> statusSet = new HashSet<>(); Set<Integer> statusSet = new HashSet<>();
for (ReassignTaskDO elem: doList) { for (ReassignTaskDO elem: doList) {
vo.setGmtCreate(elem.getGmtCreate().getTime()); vo.setGmtCreate(elem.getGmtCreate().getTime());
vo.setOperator(elem.getOperator()); vo.setOperator(elem.getOperator());
vo.setDescription(elem.getDescription()); vo.setDescription(elem.getDescription());
// There is only one `ReassignTaskDO` in the `doList`
clusterAndTopicName.append("-").append(elem.getClusterId()).append("-").append(elem.getTopicName());
if (TaskStatusReassignEnum.isFinished(elem.getStatus())) { if (TaskStatusReassignEnum.isFinished(elem.getStatus())) {
completedTopicNum += 1; completedTopicNum += 1;
statusSet.add(elem.getStatus()); statusSet.add(elem.getStatus());
@@ -113,6 +115,7 @@ public class ReassignModelConverter {
// 任务计划开始时间 // 任务计划开始时间
vo.setBeginTime(elem.getBeginTime().getTime()); vo.setBeginTime(elem.getBeginTime().getTime());
} }
vo.setTaskName(String.format("%s 数据迁移任务%s", DateUtils.getFormattedDate(taskId), clusterAndTopicName.toString()));
// 任务整体状态 // 任务整体状态
if (statusSet.contains(TaskStatusReassignEnum.RUNNING.getCode())) { if (statusSet.contains(TaskStatusReassignEnum.RUNNING.getCode())) {