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

Merge pull request #1 from Hongten/optimize/migration_task_name

Browse Source 
optimize the migration task name
This commit is contained in:
Hongten
2021-05-07 19:26:54 +08:00
committed by GitHub
parent f1627b214c 736d5a00b7
commit 25c3aeaa5f
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();
vo.setTaskName(String.format("%s 数据迁移任务", DateUtils.getFormattedDate(taskId)));
vo.setTaskId(taskId);
vo.setTotalTopicNum(doList.size());
vo.setBeginTime(0L);
vo.setEndTime(0L);
Integer completedTopicNum = 0;
StringBuilder clusterAndTopicName = new StringBuilder();
Set<Integer> statusSet = new HashSet<>();
for (ReassignTaskDO elem: doList) {
vo.setGmtCreate(elem.getGmtCreate().getTime());
vo.setOperator(elem.getOperator());
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())) {
completedTopicNum += 1;
statusSet.add(elem.getStatus());
@@ -113,6 +115,7 @@ public class ReassignModelConverter {
// 任务计划开始时间
vo.setBeginTime(elem.getBeginTime().getTime());
}
vo.setTaskName(String.format("%s 数据迁移任务%s", DateUtils.getFormattedDate(taskId), clusterAndTopicName.toString()));
// 任务整体状态
if (statusSet.contains(TaskStatusReassignEnum.RUNNING.getCode())) {