From 1ef3f540c2f4b5c32e3611f9d456fe14dbfe2209 Mon Sep 17 00:00:00 2001
From: CityFun <31820853+zhengkunwang223@users.noreply.github.com>
Date: Fri, 12 Dec 2025 16:07:12 +0800
Subject: [PATCH] feat: Task center supports switching nodes (#11315)

---
 frontend/src/api/modules/log.ts               |  5 +-
 frontend/src/components/node-select/index.vue | 48 +++++++++++++++++++
 frontend/src/components/task-list/index.vue   | 19 ++++----
 3 files changed, 61 insertions(+), 11 deletions(-)
 create mode 100644 frontend/src/components/node-select/index.vue

diff --git a/frontend/src/api/modules/log.ts b/frontend/src/api/modules/log.ts
index 22e2adf4f..de01f26b0 100644
--- a/frontend/src/api/modules/log.ts
+++ b/frontend/src/api/modules/log.ts
@@ -18,8 +18,9 @@ export const cleanLogs = (param: Log.CleanLog) => {
     return http.post(`/core/logs/clean`, param);
 };
 
-export const searchTasks = (req: Log.SearchTaskReq) => {
-    return http.post<ResPage<Log.Task>>(`/logs/tasks/search`, req);
+export const searchTasks = (req: Log.SearchTaskReq, node?: string) => {
+    const params = node ? `?operateNode=${node}` : '';
+    return http.post<ResPage<Log.Task>>(`/logs/tasks/search${params}`, req);
 };
 
 export const countExecutingTask = () => {
diff --git a/frontend/src/components/node-select/index.vue b/frontend/src/components/node-select/index.vue
new file mode 100644
index 000000000..eef73e52f
--- /dev/null
+++ b/frontend/src/components/node-select/index.vue
@@ -0,0 +1,48 @@
+<template>
+    <el-select
+        :model-value="modelValue"
+        @update:model-value="handleChange"
+        class="p-w-200"
+        :placeholder="$t('setting.selectNode')"
+    >
+        <el-option
+            v-for="item in nodes"
+            :key="item.id"
+            :label="item.name === 'local' ? globalStore.getMasterAlias() : item.name"
+            :value="item.name"
+        ></el-option>
+    </el-select>
+</template>
+
+<script setup>
+import { defineProps, defineEmits } from 'vue';
+import { listAllNodes } from '@/api/modules/setting';
+import { useGlobalStore } from '@/composables/useGlobalStore';
+const { globalStore } = useGlobalStore();
+
+defineProps({
+    modelValue: {
+        type: String,
+        default: '',
+    },
+});
+
+const nodes = ref([]);
+const emit = defineEmits(['update:modelValue', 'change']);
+
+const handleChange = (value) => {
+    emit('update:modelValue', value);
+    emit('change', value);
+};
+
+const listNodes = async () => {
+    try {
+        const res = await listAllNodes();
+        nodes.value = res.data || [];
+    } catch (error) {}
+};
+
+onMounted(() => {
+    listNodes();
+});
+</script>
diff --git a/frontend/src/components/task-list/index.vue b/frontend/src/components/task-list/index.vue
index e1c0ea482..6fd8cd93d 100644
--- a/frontend/src/components/task-list/index.vue
+++ b/frontend/src/components/task-list/index.vue
@@ -1,13 +1,10 @@
 <template>
-    <DrawerPro
-        v-model="open"
-        size="large"
-        :header="$t('menu.msgCenter')"
-        :resource="globalStore.currentNode"
-        @close="handleClose"
-    >
+    <DrawerPro v-model="open" size="large" :header="$t('menu.msgCenter')" @close="handleClose">
         <template #content>
             <LayoutContent v-loading="loading" :title="$t('logs.task')">
+                <template #leftToolBar>
+                    <NodeSelect v-model="targeNode" @change="search()" />
+                </template>
                 <template #rightToolBar>
                     <el-select v-model="req.status" @change="search()" clearable class="p-w-200">
                         <template #prefix>{{ $t('commons.table.status') }}</template>
@@ -50,11 +47,13 @@
 </template>
 
 <script setup lang="ts">
+import TaskLog from '@/components/log/task/index.vue';
+import NodeSelect from '@/components/node-select/index.vue';
+
 import { dateFormat } from '@/utils/util';
 import { searchTasks } from '@/api/modules/log';
 import { reactive, ref } from 'vue';
 import { Log } from '@/api/interface/log';
-import TaskLog from '@/components/log/task/index.vue';
 import bus from '@/global/bus';
 import { GlobalStore } from '@/store';
 const globalStore = GlobalStore();
@@ -79,6 +78,7 @@ const req = reactive({
     page: 1,
     pageSize: 10,
 });
+const targeNode = ref('local');
 
 const search = async () => {
     bus.emit('refreshTask', true);
@@ -86,7 +86,7 @@ const search = async () => {
     req.pageSize = paginationConfig.pageSize;
     loading.value = true;
     try {
-        const res = await searchTasks(req);
+        const res = await searchTasks(req, targeNode.value);
         loading.value = false;
         data.value = res.data.items;
         paginationConfig.total = res.data.total;
@@ -101,6 +101,7 @@ const openTaskLog = (row: Log.Task) => {
 };
 
 const acceptParams = () => {
+    targeNode.value = globalStore.currentNode;
     search();
     open.value = true;
 };