8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-05 21:12:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

optimize reeassign task-name

Browse Source
This commit is contained in:
zengqiao
2022-01-11 16:57:24 +08:00
parent 725c59eab0
commit 37585f760d
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -95,12 +95,21 @@ public class ReassignModelConverter {
vo.setBeginTime(0L); vo.setBeginTime(0L);
vo.setEndTime(0L); vo.setEndTime(0L);
StringBuilder clusterAndTopicName = new StringBuilder();
Integer completedTopicNum = 0; Integer completedTopicNum = 0;
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());
if (clusterAndTopicName.length() == 0) {
clusterAndTopicName.append("-").append(elem.getClusterId()).append("-").append(elem.getTopicName());
} else {
clusterAndTopicName.append("等");
}
if (TaskStatusReassignEnum.isFinished(elem.getStatus())) { if (TaskStatusReassignEnum.isFinished(elem.getStatus())) {
completedTopicNum += 1; completedTopicNum += 1;
statusSet.add(elem.getStatus()); statusSet.add(elem.getStatus());
@@ -114,6 +123,9 @@ public class ReassignModelConverter {
vo.setBeginTime(elem.getBeginTime().getTime()); vo.setBeginTime(elem.getBeginTime().getTime());
} }
// 任务名称上，增加展示集群ID和Topic名称，多个时，仅展示第一个. PR from Hongten
vo.setTaskName(String.format("%s 数据迁移任务%s", DateUtils.getFormattedDate(taskId), clusterAndTopicName.toString()));
// 任务整体状态 // 任务整体状态
if (statusSet.contains(TaskStatusReassignEnum.RUNNING.getCode())) { if (statusSet.contains(TaskStatusReassignEnum.RUNNING.getCode())) {
vo.setStatus(TaskStatusReassignEnum.RUNNING.getCode()); vo.setStatus(TaskStatusReassignEnum.RUNNING.getCode());