From f5fb2c4f88da967d945b36a68292fdca60406f98 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AE=B8=E6=99=93=E4=B8=9C?= <763795151@qq.com> Date: Wed, 5 Jan 2022 21:19:46 +0800 Subject: [PATCH] =?UTF-8?q?=E9=9B=86=E7=BE=A4=E5=88=87=E6=8D=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../console/KafkaConsoleUiApplication.java | 2 + .../console/controller/ClusterController.java | 21 +++++- .../console/interceptor/ContextSetFilter.java | 75 +++++++++++++++++++ .../kafka/console/service/ClusterService.java | 6 ++ .../service/impl/ClusterServiceImpl.java | 40 ++++++++-- .../scala/kafka/console/KafkaConsole.scala | 7 +- ui/src/App.vue | 42 ++++++++++- ui/src/store/index.js | 17 ++++- ui/src/store/mutation-types.js | 3 + ui/src/utils/api.js | 16 +++- ui/src/utils/constants.js | 4 + ui/src/utils/local-cache.js | 10 +++ ui/src/utils/request.js | 13 +++- ui/src/views/Home.vue | 10 ++- ui/src/views/cluster/Cluster.vue | 12 ++- ui/src/views/group/Group.vue | 9 ++- ui/src/views/op/AddClusterInfo.vue | 47 +++++++++--- ui/src/views/op/ClusterInfo.vue | 61 ++++++++++++++- ui/src/views/op/Operation.vue | 4 +- ui/src/views/topic/Topic.vue | 11 ++- 20 files changed, 373 insertions(+), 37 deletions(-) create mode 100644 src/main/java/com/xuxd/kafka/console/interceptor/ContextSetFilter.java create mode 100644 ui/src/store/mutation-types.js create mode 100644 ui/src/utils/local-cache.js diff --git a/src/main/java/com/xuxd/kafka/console/KafkaConsoleUiApplication.java b/src/main/java/com/xuxd/kafka/console/KafkaConsoleUiApplication.java index 953d031..aa36b29 100644 --- a/src/main/java/com/xuxd/kafka/console/KafkaConsoleUiApplication.java +++ b/src/main/java/com/xuxd/kafka/console/KafkaConsoleUiApplication.java @@ -3,11 +3,13 @@ package com.xuxd.kafka.console; import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.boot.web.servlet.ServletComponentScan; import org.springframework.scheduling.annotation.EnableScheduling; @MapperScan("com.xuxd.kafka.console.dao") @SpringBootApplication @EnableScheduling +@ServletComponentScan public class KafkaConsoleUiApplication { public static void main(String[] args) { diff --git a/src/main/java/com/xuxd/kafka/console/controller/ClusterController.java b/src/main/java/com/xuxd/kafka/console/controller/ClusterController.java index c5e0a82..990e863 100644 --- a/src/main/java/com/xuxd/kafka/console/controller/ClusterController.java +++ b/src/main/java/com/xuxd/kafka/console/controller/ClusterController.java @@ -3,8 +3,10 @@ package com.xuxd.kafka.console.controller; import com.xuxd.kafka.console.beans.dto.ClusterInfoDTO; import com.xuxd.kafka.console.service.ClusterService; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -27,13 +29,28 @@ public class ClusterController { return clusterService.getClusterInfo(); } - @GetMapping("/list") + @GetMapping("/info") public Object getClusterInfoList() { return clusterService.getClusterInfoList(); } - @PostMapping + @PostMapping("/info") public Object addClusterInfo(@RequestBody ClusterInfoDTO dto) { return clusterService.addClusterInfo(dto.to()); } + + @DeleteMapping("/info") + public Object deleteClusterInfo(@RequestBody ClusterInfoDTO dto) { + return clusterService.deleteClusterInfo(dto.getId()); + } + + @PutMapping("/info") + public Object updateClusterInfo(@RequestBody ClusterInfoDTO dto) { + return clusterService.updateClusterInfo(dto.to()); + } + + @GetMapping("/info/peek") + public Object peekClusterInfo() { + return clusterService.peekClusterInfo(); + } } diff --git a/src/main/java/com/xuxd/kafka/console/interceptor/ContextSetFilter.java b/src/main/java/com/xuxd/kafka/console/interceptor/ContextSetFilter.java new file mode 100644 index 0000000..ab3809e --- /dev/null +++ b/src/main/java/com/xuxd/kafka/console/interceptor/ContextSetFilter.java @@ -0,0 +1,75 @@ +package com.xuxd.kafka.console.interceptor; + +import com.xuxd.kafka.console.beans.ResponseData; +import com.xuxd.kafka.console.beans.dos.ClusterInfoDO; +import com.xuxd.kafka.console.config.ContextConfig; +import com.xuxd.kafka.console.config.ContextConfigHolder; +import com.xuxd.kafka.console.dao.ClusterInfoMapper; +import com.xuxd.kafka.console.utils.ConvertUtil; +import java.io.IOException; +import java.util.HashSet; +import java.util.Set; +import javax.servlet.Filter; +import javax.servlet.FilterChain; +import javax.servlet.ServletException; +import javax.servlet.ServletRequest; +import javax.servlet.ServletResponse; +import javax.servlet.annotation.WebFilter; +import javax.servlet.http.HttpServletRequest; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.MediaType; + +/** + * kafka-console-ui. + * + * @author xuxd + * @date 2022-01-05 19:56:25 + **/ +@WebFilter(filterName = "context-set-filter", urlPatterns = {"/*"}) +@Slf4j +public class ContextSetFilter implements Filter { + + private Set excludes = new HashSet<>(); + + { + excludes.add("/cluster/info/peek"); + excludes.add("/cluster/info"); + } + + @Autowired + private ClusterInfoMapper clusterInfoMapper; + + @Override public void doFilter(ServletRequest req, ServletResponse response, + FilterChain chain) throws IOException, ServletException { + try { + HttpServletRequest request = (HttpServletRequest) req; + String uri = request.getRequestURI(); + if (!excludes.contains(uri)) { + String headerId = request.getHeader(Header.ID); + if (StringUtils.isBlank(headerId)) { + ResponseData failed = ResponseData.create().failed("Cluster id is null."); + response.setContentType(MediaType.APPLICATION_JSON_VALUE); + response.getOutputStream().println(ConvertUtil.toJsonString(failed)); + return; + } else { + ClusterInfoDO infoDO = clusterInfoMapper.selectById(Long.valueOf(headerId)); + ContextConfig config = new ContextConfig(); + + config.setBootstrapServer(infoDO.getAddress()); + config.setProperties(ConvertUtil.toProperties(infoDO.getProperties())); + ContextConfigHolder.CONTEXT_CONFIG.set(config); + } + } + chain.doFilter(req, response); + } finally { + ContextConfigHolder.CONTEXT_CONFIG.remove(); + } + } + + interface Header { + String ID = "X-Cluster-Info-Id"; + String NAME = "X-Cluster-Info-Name"; + } +} diff --git a/src/main/java/com/xuxd/kafka/console/service/ClusterService.java b/src/main/java/com/xuxd/kafka/console/service/ClusterService.java index 8a1e024..af113d2 100644 --- a/src/main/java/com/xuxd/kafka/console/service/ClusterService.java +++ b/src/main/java/com/xuxd/kafka/console/service/ClusterService.java @@ -15,4 +15,10 @@ public interface ClusterService { ResponseData getClusterInfoList(); ResponseData addClusterInfo(ClusterInfoDO infoDO); + + ResponseData deleteClusterInfo(Long id); + + ResponseData updateClusterInfo(ClusterInfoDO infoDO); + + ResponseData peekClusterInfo(); } diff --git a/src/main/java/com/xuxd/kafka/console/service/impl/ClusterServiceImpl.java b/src/main/java/com/xuxd/kafka/console/service/impl/ClusterServiceImpl.java index f339667..9b70555 100644 --- a/src/main/java/com/xuxd/kafka/console/service/impl/ClusterServiceImpl.java +++ b/src/main/java/com/xuxd/kafka/console/service/impl/ClusterServiceImpl.java @@ -1,13 +1,16 @@ package com.xuxd.kafka.console.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.xuxd.kafka.console.beans.ResponseData; import com.xuxd.kafka.console.beans.dos.ClusterInfoDO; import com.xuxd.kafka.console.beans.vo.ClusterInfoVO; import com.xuxd.kafka.console.dao.ClusterInfoMapper; import com.xuxd.kafka.console.service.ClusterService; +import java.util.List; import java.util.stream.Collectors; import kafka.console.ClusterConsole; -import org.springframework.beans.factory.annotation.Autowired; +import org.apache.commons.collections.CollectionUtils; +import org.springframework.beans.factory.ObjectProvider; import org.springframework.stereotype.Service; /** @@ -19,11 +22,15 @@ import org.springframework.stereotype.Service; @Service public class ClusterServiceImpl implements ClusterService { - @Autowired - private ClusterConsole clusterConsole; + private final ClusterConsole clusterConsole; - @Autowired - private ClusterInfoMapper clusterInfoMapper; + private final ClusterInfoMapper clusterInfoMapper; + + public ClusterServiceImpl(ObjectProvider clusterConsole, + ObjectProvider clusterInfoMapper) { + this.clusterConsole = clusterConsole.getIfAvailable(); + this.clusterInfoMapper = clusterInfoMapper.getIfAvailable(); + } @Override public ResponseData getClusterInfo() { return ResponseData.create().data(clusterConsole.clusterInfo()).success(); @@ -35,8 +42,31 @@ public class ClusterServiceImpl implements ClusterService { } @Override public ResponseData addClusterInfo(ClusterInfoDO infoDO) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("cluster_name", infoDO.getClusterName()); + if (clusterInfoMapper.selectCount(queryWrapper) > 0) { + return ResponseData.create().failed("cluster name exist."); + } clusterInfoMapper.insert(infoDO); return ResponseData.create().success(); } + @Override public ResponseData deleteClusterInfo(Long id) { + clusterInfoMapper.deleteById(id); + return ResponseData.create().success(); + } + + @Override public ResponseData updateClusterInfo(ClusterInfoDO infoDO) { + clusterInfoMapper.updateById(infoDO); + return ResponseData.create().success(); + } + + @Override public ResponseData peekClusterInfo() { + List dos = clusterInfoMapper.selectList(null); + if (CollectionUtils.isEmpty(dos)) { + return ResponseData.create().failed("No Cluster Info."); + } + return ResponseData.create().data(dos.stream().findFirst().map(ClusterInfoVO::from)).success(); + } + } diff --git a/src/main/scala/kafka/console/KafkaConsole.scala b/src/main/scala/kafka/console/KafkaConsole.scala index fe8ae40..dac21c5 100644 --- a/src/main/scala/kafka/console/KafkaConsole.scala +++ b/src/main/scala/kafka/console/KafkaConsole.scala @@ -1,6 +1,6 @@ package kafka.console -import com.xuxd.kafka.console.config.KafkaConfig +import com.xuxd.kafka.console.config.{ContextConfigHolder, KafkaConfig} import kafka.zk.{AdminZkClient, KafkaZkClient} import org.apache.kafka.clients.CommonClientConfigs import org.apache.kafka.clients.admin._ @@ -117,8 +117,9 @@ class KafkaConsole(config: KafkaConfig) { private def getProps(): Properties = { val props: Properties = new Properties(); - props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, config.getBootstrapServer) - props.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, config.getRequestTimeoutMs()) + props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, ContextConfigHolder.CONTEXT_CONFIG.get().getBootstrapServer()) + props.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, ContextConfigHolder.CONTEXT_CONFIG.get().getRequestTimeoutMs()) + props.putAll(ContextConfigHolder.CONTEXT_CONFIG.get().getProperties()) if (config.isEnableAcl) { props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, config.getSecurityProtocol()) props.put(SaslConfigs.SASL_MECHANISM, config.getSaslMechanism()) diff --git a/ui/src/App.vue b/ui/src/App.vue index 23d88fb..b82662f 100644 --- a/ui/src/App.vue +++ b/ui/src/App.vue @@ -17,13 +17,18 @@ > |运维 + 集群：{{ clusterName }} @@ -90,4 +124,10 @@ export default { top: 1%; position: absolute; } +.right { + float: right; + right: 1%; + top: 2%; + position: absolute; +} diff --git a/ui/src/store/index.js b/ui/src/store/index.js index ba2f84a..a60a24f 100644 --- a/ui/src/store/index.js +++ b/ui/src/store/index.js @@ -1,11 +1,24 @@ import Vue from "vue"; import Vuex from "vuex"; +import { CLUSTER } from "@/store/mutation-types"; +import { setClusterInfo } from "@/utils/local-cache"; Vue.use(Vuex); export default new Vuex.Store({ - state: {}, - mutations: {}, + state: { + clusterInfo: { + id: undefined, + clusterName: undefined, + }, + }, + mutations: { + [CLUSTER.SWITCH](state, clusterInfo) { + state.clusterInfo.id = clusterInfo.id; + state.clusterInfo.clusterName = clusterInfo.clusterName; + setClusterInfo(clusterInfo); + }, + }, actions: {}, modules: {}, }); diff --git a/ui/src/store/mutation-types.js b/ui/src/store/mutation-types.js new file mode 100644 index 0000000..f5ec573 --- /dev/null +++ b/ui/src/store/mutation-types.js @@ -0,0 +1,3 @@ +export const CLUSTER = { + SWITCH: "switchCluster", +}; diff --git a/ui/src/utils/api.js b/ui/src/utils/api.js index 4a65075..221911a 100644 --- a/ui/src/utils/api.js +++ b/ui/src/utils/api.js @@ -184,13 +184,25 @@ export const KafkaClusterApi = { method: "get", }, getClusterInfoList: { - url: "/cluster/list", + url: "/cluster/info", method: "get", }, addClusterInfo: { - url: "/cluster", + url: "/cluster/info", method: "post", }, + deleteClusterInfo: { + url: "/cluster/info", + method: "delete", + }, + updateClusterInfo: { + url: "/cluster/info", + method: "put", + }, + peekClusterInfo: { + url: "/cluster/info/peek", + method: "get", + }, }; export const KafkaOpApi = { diff --git a/ui/src/utils/constants.js b/ui/src/utils/constants.js index 63b747a..bd15f7a 100644 --- a/ui/src/utils/constants.js +++ b/ui/src/utils/constants.js @@ -1,3 +1,7 @@ export const ConstantEvent = { updateUserDialogData: "updateUserDialogData", }; + +export const Cache = { + clusterInfo: "clusterInfo", +}; diff --git a/ui/src/utils/local-cache.js b/ui/src/utils/local-cache.js new file mode 100644 index 0000000..23ebeb9 --- /dev/null +++ b/ui/src/utils/local-cache.js @@ -0,0 +1,10 @@ +import { Cache } from "@/utils/constants"; + +export function setClusterInfo(clusterInfo) { + localStorage.setItem(Cache.clusterInfo, JSON.stringify(clusterInfo)); +} + +export function getClusterInfo() { + const str = localStorage.getItem(Cache.clusterInfo); + return str ? JSON.parse(str) : undefined; +} diff --git a/ui/src/utils/request.js b/ui/src/utils/request.js index 0af83fa..02f3ebd 100644 --- a/ui/src/utils/request.js +++ b/ui/src/utils/request.js @@ -1,6 +1,7 @@ import axios from "axios"; import notification from "ant-design-vue/es/notification"; import { VueAxios } from "./axios"; +import { getClusterInfo } from "@/utils/local-cache"; // 创建 axios 实例 const request = axios.create({ @@ -22,10 +23,14 @@ const errorHandler = (error) => { }; // request interceptor -// request.interceptors.request.use(config => { -// -// return config -// }, errorHandler) +request.interceptors.request.use((config) => { + const clusterInfo = getClusterInfo(); + if (clusterInfo) { + config.headers["X-Cluster-Info-Id"] = clusterInfo.id; + config.headers["X-Cluster-Info-Name"] = clusterInfo.clusterName; + } + return config; +}, errorHandler); // response interceptor request.interceptors.response.use((response) => { diff --git a/ui/src/views/Home.vue b/ui/src/views/Home.vue index a58377a..1cf3543 100644 --- a/ui/src/views/Home.vue +++ b/ui/src/views/Home.vue @@ -11,6 +11,7 @@ // @ is an alias to /src import request from "@/utils/request"; import { KafkaConfigApi } from "@/utils/api"; +import notification from "ant-design-vue/lib/notification"; export default { name: "Home", components: {}, @@ -25,7 +26,14 @@ export default { url: KafkaConfigApi.getConfig.url, method: KafkaConfigApi.getConfig.method, }).then((res) => { - this.config = res.data; + if (res.code == 0) { + this.config = res.data; + } else { + notification.error({ + message: "error", + description: res.msg, + }); + } }); }, }; diff --git a/ui/src/views/cluster/Cluster.vue b/ui/src/views/cluster/Cluster.vue index eeb6cb9..6f022ba 100644 --- a/ui/src/views/cluster/Cluster.vue +++ b/ui/src/views/cluster/Cluster.vue @@ -45,6 +45,7 @@ import request from "@/utils/request"; import { KafkaClusterApi } from "@/utils/api"; import BrokerConfig from "@/views/cluster/BrokerConfig"; +import notification from "ant-design-vue/lib/notification"; export default { name: "Topic", @@ -68,8 +69,15 @@ export default { method: KafkaClusterApi.getClusterInfo.method, }).then((res) => { this.loading = false; - this.data = res.data.nodes; - this.clusterId = res.data.clusterId; + if (res.code == 0) { + this.data = res.data.nodes; + this.clusterId = res.data.clusterId; + } else { + notification.error({ + message: "error", + description: res.msg, + }); + } }); }, openBrokerConfigDialog(record, isLoggerConfig) { diff --git a/ui/src/views/group/Group.vue b/ui/src/views/group/Group.vue index df25b91..d1c6c6b 100644 --- a/ui/src/views/group/Group.vue +++ b/ui/src/views/group/Group.vue @@ -196,7 +196,14 @@ export default { data: this.queryParam, }).then((res) => { this.loading = false; - this.data = res.data.list; + if (res.code == 0) { + this.data = res.data.list; + } else { + notification.error({ + message: "error", + description: res.msg, + }); + } }); }, deleteGroup(group) { diff --git a/ui/src/views/op/AddClusterInfo.vue b/ui/src/views/op/AddClusterInfo.vue index 942180c..f4eba1a 100644 --- a/ui/src/views/op/AddClusterInfo.vue +++ b/ui/src/views/op/AddClusterInfo.vue @@ -21,7 +21,10 @@ @@ -30,7 +33,10 @@ @@ -44,11 +50,14 @@ security-protocol=SASL_PLAINTEXT sasl-mechanism=SCRAM-SHA-256 sasl-jaas-config=org.apache.kafka.common.security.scram.ScramLoginModule required username="name" password="password"; ' - v-decorator="['properties']" + v-decorator="[ + 'properties', + { initialValue: clusterInfo.properties }, + ]" /> - 提交 + 提交 @@ -60,6 +69,7 @@ sasl-jaas-config=org.apache.kafka.common.security.scram.ScramLoginModule require import request from "@/utils/request"; import { KafkaClusterApi } from "@/utils/api"; import notification from "ant-design-vue/es/notification"; + export default { name: "AddClusterInfo", props: { @@ -67,6 +77,18 @@ export default { type: Boolean, default: false, }, + isModify: { + type: Boolean, + default: false, + }, + clusterInfo: { + type: Object, + default: () => defaultInfo, + }, + closeDialogEvent: { + type: String, + default: "closeAddClusterInfoDialog", + }, }, data() { return { @@ -87,15 +109,21 @@ export default { this.form.validateFields((err, values) => { if (!err) { this.loading = true; + const api = this.isModify + ? KafkaClusterApi.updateClusterInfo + : KafkaClusterApi.addClusterInfo; + const data = this.isModify + ? Object.assign({}, this.clusterInfo, values) + : Object.assign({}, values); request({ - url: KafkaClusterApi.addClusterInfo.url, - method: KafkaClusterApi.addClusterInfo.method, - data: values, + url: api.url, + method: api.method, + data: data, }).then((res) => { this.loading = false; if (res.code == 0) { this.$message.success(res.msg); - this.$emit("closeAddClusterInfoDialog", { refresh: true }); + this.$emit(this.closeDialogEvent, { refresh: true }); } else { notification.error({ message: "error", @@ -108,10 +136,11 @@ export default { }, handleCancel() { this.data = []; - this.$emit("closeAddClusterInfoDialog", { refresh: false }); + this.$emit(this.closeDialogEvent, { refresh: false }); }, }, }; +const defaultInfo = { clusterName: "", address: "", properties: "" }; diff --git a/ui/src/views/op/ClusterInfo.vue b/ui/src/views/op/ClusterInfo.vue index 172a655..d149934 100644 --- a/ui/src/views/op/ClusterInfo.vue +++ b/ui/src/views/op/ClusterInfo.vue @@ -37,9 +37,14 @@ size="small" href="javascript:;" class="operation-btn" + @click="switchCluster(record)" >切换 - 编辑 + + + @@ -72,6 +86,9 @@ import request from "@/utils/request"; import { KafkaClusterApi } from "@/utils/api"; import AddClusterInfo from "@/views/op/AddClusterInfo"; +import notification from "ant-design-vue/lib/notification"; +import { mapMutations } from "vuex"; +import { CLUSTER } from "@/store/mutation-types"; export default { name: "Cluster", @@ -89,6 +106,8 @@ export default { data: [], loading: false, showAddClusterInfoDialog: false, + showUpdateClusterInfoDialog: false, + select: {}, }; }, watch: { @@ -110,7 +129,24 @@ export default { this.data = res.data; }); }, - deleteClusterInfo() {}, + deleteClusterInfo(record) { + request({ + url: KafkaClusterApi.deleteClusterInfo.url, + method: KafkaClusterApi.deleteClusterInfo.method, + data: Object.assign({}, { id: record.id }), + }).then((res) => { + this.loading = false; + if (res.code == 0) { + this.$message.success(res.msg); + this.getClusterInfoList(); + } else { + notification.error({ + message: "error", + description: res.msg, + }); + } + }); + }, handleCancel() { this.data = []; this.$emit("closeClusterInfoDialog", {}); @@ -124,6 +160,27 @@ export default { this.getClusterInfoList(); } }, + openUpdateClusterInfoDialog(record) { + this.showUpdateClusterInfoDialog = true; + const r = Object.assign({}, record); + if (r.properties) { + let str = ""; + r.properties.forEach((e) => { + str = str + e + "\r\n"; + }); + r.properties = str; + } + this.select = r; + }, + closeUpdateClusterInfoDialog(res) { + this.showUpdateClusterInfoDialog = false; + if (res.refresh) { + this.getClusterInfoList(); + } + }, + ...mapMutations({ + switchCluster: CLUSTER.SWITCH, + }), }, }; diff --git a/ui/src/views/op/Operation.vue b/ui/src/views/op/Operation.vue index 23998cb..847ffac 100644 --- a/ui/src/views/op/Operation.vue +++ b/ui/src/views/op/Operation.vue @@ -7,7 +7,9 @@ 集群切换 - 多集群管理：增加、删除集群配置，切换集群 + 多集群管理：增加、删除集群配置，切换选中集群为当前操作集群。

diff --git a/ui/src/views/topic/Topic.vue b/ui/src/views/topic/Topic.vue index 9703acd..d004d2a 100644 --- a/ui/src/views/topic/Topic.vue +++ b/ui/src/views/topic/Topic.vue @@ -245,8 +245,15 @@ export default { params: this.queryParam, }).then((res) => { this.loading = false; - this.data = res.data; - this.filter(); + if (res.code == 0) { + this.data = res.data; + this.filter(); + } else { + notification.error({ + message: "error", + description: res.msg, + }); + } }); }, deleteTopic(topic) {