diff --git a/README.md b/README.md
index a1206d93..1c0a9731 100644
--- a/README.md
+++ b/README.md
@@ -31,7 +31,7 @@
 
 ## 前言
 
-Web 版 **统一管理操作平台**，集成了对 Linux 系统的全面操作支持（包括终端管理[终端回放、命令过滤]、文件管理、脚本执行、进程监控及计划任务设置），同时提供了多种数据库（如 MySQL、PostgreSQL、Oracle、SQL Server、达梦、高斯、SQLite 等）的数据操作、数据同步与数据迁移功能。此外，还支持 Redis（单机、哨兵、集群模式）、 MongoDB 、Es 的操作管理，并结合工单流程审批功能，为企业提供一站式的运维与管理解决方案。
+Web 版 **统一管理操作平台**，集成了对 Linux 系统的全面操作支持（包括终端管理[终端回放、命令过滤]、文件管理、脚本执行、进程监控及计划任务设置），同时提供了多种数据库（如 MySQL、PostgreSQL、Oracle、SQL Server、达梦、高斯、SQLite 等）的数据操作、数据同步与数据迁移功能。此外，还支持 Redis（单机、哨兵、集群模式）、 MongoDB 、Es 、Kafka的操作管理，并结合工单流程审批功能，为企业提供一站式的运维与管理解决方案。
 
 ## 开发语言与主要框架
 
@@ -65,16 +65,12 @@ http://go.mayfly.run
 
 ![文件查看](https://foruda.gitee.com/images/1714378482611638688/7753faf6_1240250.png "屏幕截图")
 
-
 ![sql编辑器](https://foruda.gitee.com/images/1757164386318836686/c3b17a52_1240250.png)
 
-
 ![选表查数据](https://foruda.gitee.com/images/1757164281011401749/5109485f_1240250.png)
 
-
 ![redis操作](https://foruda.gitee.com/images/1757164442298752845/4af1b296_1240250.png)
 
-
 ![mongo操作](https://foruda.gitee.com/images/1714378916425714642/77fc0ed9_1240250.png "屏幕截图")
 
 ![es操作](https://foruda.gitee.com/images/1757164553845346963/b5b70381_1240250.png)
diff --git a/README_EN.md b/README_EN.md
index f3b5e407..8619f235 100644
--- a/README_EN.md
+++ b/README_EN.md
@@ -28,7 +28,7 @@
 
 ## Preface
 
-Web-based **Unified Management and Operation Platform**, integrating comprehensive operation support for Linux systems (including terminal management [terminal playback, command filtering], file management, script execution, process monitoring, and cronjob settings). It also provides data operation, data synchronization, and data migration for multiple databases (such as MySQL, PostgreSQL, Oracle, SQL Server, Dameng, Gauss, SQLite, etc.). Additionally, it supports Redis operations (standalone, sentinel, and cluster modes) and MongoDB、Es management, combined with work order process approval functionality to offer enterprises an all-in-one solution for operations and management.
+Web-based **Unified Management and Operation Platform**, integrating comprehensive operation support for Linux systems (including terminal management [terminal playback, command filtering], file management, script execution, process monitoring, and cronjob settings). It also provides data operation, data synchronization, and data migration for multiple databases (such as MySQL, PostgreSQL, Oracle, SQL Server, Dameng, Gauss, SQLite, etc.). Additionally, it supports Redis operations (standalone, sentinel, and cluster modes) and MongoDB、Es、Kafka management, combined with work order process approval functionality to offer enterprises an all-in-one solution for operations and management.
 
 ## Development languages and major frameworks
 
@@ -58,23 +58,18 @@ account/password：test/test123.
 
 ![文件查看](https://foruda.gitee.com/images/1714378482611638688/7753faf6_1240250.png "屏幕截图")
 
-
 ![sql编辑器](https://foruda.gitee.com/images/1757164386318836686/c3b17a52_1240250.png)
 
-
 ![选表查数据](https://foruda.gitee.com/images/1757164281011401749/5109485f_1240250.png)
 
-
 ![redis操作](https://foruda.gitee.com/images/1757164442298752845/4af1b296_1240250.png)
 
-
 ![mongo操作](https://foruda.gitee.com/images/1714378916425714642/77fc0ed9_1240250.png "屏幕截图")
 
 ![es操作](https://foruda.gitee.com/images/1757164553845346963/b5b70381_1240250.png)
 
 ![容器操作](https://foruda.gitee.com/images/1757164625186816754/2b195e25_1240250.png)
 
-
 #### Work order process approval
 
 ![流程审批](https://foruda.gitee.com/images/1714379057627690037/ad136862_1240250.png "屏幕截图")
diff --git a/frontend/package.json b/frontend/package.json
index bd9559fe..e0347210 100644
--- a/frontend/package.json
+++ b/frontend/package.json
@@ -24,34 +24,34 @@
         "crypto-js": "^4.2.0",
         "dayjs": "^1.11.19",
         "echarts": "^6.0.0",
-        "element-plus": "^2.13.3",
+        "element-plus": "^2.13.5",
         "js-base64": "^3.7.8",
         "jsencrypt": "^3.5.4",
         "monaco-editor": "^0.55.1",
-        "monaco-sql-languages": "^0.15.1",
+        "monaco-sql-languages": "^1.0.0",
         "nprogress": "^0.2.0",
         "pinia": "^3.0.4",
         "qrcode.vue": "^3.8.0",
         "screenfull": "^6.0.2",
         "sortablejs": "^1.15.7",
         "sql-formatter": "^15.7.2",
-        "trzsz": "^1.1.5",
+        "trzsz": "^1.1.6",
         "uuid": "^13.0.0",
-        "vue": "^v3.6.0-beta.6",
-        "vue-i18n": "^11.2.8",
+        "vue": "^v3.6.0-beta.8",
+        "vue-i18n": "^11.3.0",
         "vue-router": "^5.0.3",
         "vuedraggable": "^4.1.0",
         "xlsx": "^0.18.5"
     },
     "devDependencies": {
-        "@tailwindcss/vite": "^4.1.18",
+        "@tailwindcss/vite": "^4.2.1",
         "@types/crypto-js": "^4.2.2",
         "@types/node": "^22.13.14",
         "@types/nprogress": "^0.2.0",
         "@types/sortablejs": "^1.15.8",
         "@typescript-eslint/eslint-plugin": "^8.35.0",
         "@typescript-eslint/parser": "^8.35.0",
-        "@vitejs/plugin-vue": "^6.0.4",
+        "@vitejs/plugin-vue": "^6.0.5",
         "@vue/compiler-sfc": "^3.5.29",
         "autoprefixer": "^10.4.21",
         "code-inspector-plugin": "^1.4.2",
@@ -59,10 +59,10 @@
         "eslint-plugin-vue": "^10.8.0",
         "postcss": "^8.5.8",
         "prettier": "^3.8.1",
-        "sass": "^1.97.3",
+        "sass": "^1.98.0",
         "tailwindcss": "^4.2.1",
         "typescript": "^5.9.3",
-        "vite": "^8.0.0-beta.16",
+        "vite": "^8.0.0",
         "vite-plugin-progress": "0.0.7",
         "vue-eslint-parser": "^10.4.0"
     },
diff --git a/frontend/src/views/flow/ProcinstDetail.vue b/frontend/src/views/flow/ProcinstDetail.vue
index 7d746843..a12529e2 100755
--- a/frontend/src/views/flow/ProcinstDetail.vue
+++ b/frontend/src/views/flow/ProcinstDetail.vue
@@ -1,81 +1,113 @@
 <template>
-    <div>
-        <el-drawer
-            :title="props.title"
-            v-model="visible"
-            :before-close="cancel"
-            size="50%"
-            body-class="!p-2"
-            header-class="!mb-2"
-            :destroy-on-close="true"
-            :close-on-click-modal="!props.instTaskId"
-        >
-            <template #header>
-                <DrawerHeader :header="title" :back="cancel" />
-            </template>
+    <el-drawer
+        :title="props.title"
+        v-model="visible"
+        :before-close="cancel"
+        size="50%"
+        body-class="!p-2"
+        header-class="!mb-2"
+        :destroy-on-close="true"
+        :close-on-click-modal="!props.instTaskId"
+    >
+        <template #header>
+            <DrawerHeader :header="title" :back="cancel" />
+        </template>
 
-            <div>
-                <el-divider content-position="left">{{ $t('flow.proc') }}</el-divider>
-                <el-descriptions :column="3" border>
-                    <el-descriptions-item :span="1" :label="$t('flow.procdefName')">{{ procinst.procdefName }}</el-descriptions-item>
-                    <el-descriptions-item :span="1" :label="$t('flow.bizType')">
-                        <enum-tag :enums="FlowBizType" :value="procinst.bizType"></enum-tag>
-                    </el-descriptions-item>
-                    <el-descriptions-item :span="1" :label="$t('flow.initiator')">
-                        <AccountInfo :username="procinst.creator || ''" />
-                    </el-descriptions-item>
+        <el-tabs v-model="state.activeTab">
+            <el-tab-pane :label="$t('common.basic')" name="basic">
+                <div>
+                    <el-divider content-position="left">{{ $t('flow.proc') }}</el-divider>
+                    <el-descriptions :column="3" border>
+                        <el-descriptions-item :span="1" :label="$t('flow.procdefName')">{{ procinst.procdefName }}</el-descriptions-item>
+                        <el-descriptions-item :span="1" :label="$t('flow.bizType')">
+                            <enum-tag :enums="FlowBizType" :value="procinst.bizType"></enum-tag>
+                        </el-descriptions-item>
+                        <el-descriptions-item :span="1" :label="$t('flow.initiator')">
+                            <AccountInfo :username="procinst.creator || ''" />
+                        </el-descriptions-item>
 
-                    <el-descriptions-item :span="1" :label="$t('flow.procinstStatus')">
-                        <enum-tag :enums="ProcinstStatus" :value="procinst.status"></enum-tag>
-                    </el-descriptions-item>
-                    <el-descriptions-item :span="1" :label="$t('flow.bizStatus')">
-                        <enum-tag :enums="ProcinstBizStatus" :value="procinst.bizStatus"></enum-tag>
-                    </el-descriptions-item>
-                    <el-descriptions-item :span="1" :label="$t('flow.startingTime')">{{ formatDate(procinst.createTime) }}</el-descriptions-item>
+                        <el-descriptions-item :span="1" :label="$t('flow.procinstStatus')">
+                            <enum-tag :enums="ProcinstStatus" :value="procinst.status"></enum-tag>
+                        </el-descriptions-item>
+                        <el-descriptions-item :span="1" :label="$t('flow.bizStatus')">
+                            <enum-tag :enums="ProcinstBizStatus" :value="procinst.bizStatus"></enum-tag>
+                        </el-descriptions-item>
+                        <el-descriptions-item :span="1" :label="$t('flow.startingTime')">{{ formatDate(procinst.createTime) }}</el-descriptions-item>
 
-                    <div v-if="procinst.duration">
-                        <el-descriptions-item :span="1.5" :label="$t('flow.endTime')">{{ formatDate(procinst.endTime) }}</el-descriptions-item>
-                        <el-descriptions-item :span="1.5" :label="$t('flow.duration')">{{ formatTime(procinst.duration) }}</el-descriptions-item>
-                    </div>
+                        <div v-if="procinst.duration">
+                            <el-descriptions-item :span="1.5" :label="$t('flow.endTime')">{{ formatDate(procinst.endTime) }}</el-descriptions-item>
+                            <el-descriptions-item :span="1.5" :label="$t('flow.duration')">{{ formatTime(procinst.duration) }}</el-descriptions-item>
+                        </div>
 
-                    <el-descriptions-item :span="3" :label="$t('common.remark')">
-                        {{ procinst.remark }}
-                    </el-descriptions-item>
-                </el-descriptions>
-            </div>
+                        <el-descriptions-item :span="3" :label="$t('common.remark')">
+                            {{ procinst.remark }}
+                        </el-descriptions-item>
+                    </el-descriptions>
+                </div>
 
-            <div>
-                <el-divider content-position="left">{{ $t('flow.bizInfo') }}</el-divider>
-                <component v-if="procinst.bizType" ref="keyValueRef" :is="bizComponents[procinst.bizType]" :procinst="procinst"> </component>
-            </div>
+                <div>
+                    <el-divider content-position="left">{{ $t('flow.bizInfo') }}</el-divider>
+                    <component v-if="procinst.bizType" ref="keyValueRef" :is="bizComponents[procinst.bizType]" :procinst="procinst"> </component>
+                </div>
 
-            <div v-if="props.instTaskId">
-                <el-divider content-position="left">{{ $t('flow.approveForm') }}</el-divider>
-                <el-form :model="form" label-width="auto">
-                    <el-form-item prop="status" :label="$t('flow.approveResult')" required>
-                        <el-select v-model="form.status">
-                            <el-option :label="$t(ProcinstTaskStatus.Pass.label)" :value="ProcinstTaskStatus.Pass.value"> </el-option>
-                            <el-option :label="$t(ProcinstTaskStatus.Back.label)" :value="ProcinstTaskStatus.Back.value"> </el-option>
-                            <el-option :label="$t(ProcinstTaskStatus.Reject.label)" :value="ProcinstTaskStatus.Reject.value"> </el-option>
-                        </el-select>
-                    </el-form-item>
-                    <el-form-item prop="remark" :label="$t('common.remark')">
-                        <el-input v-model.trim="form.remark" :placeholder="$t('common.remark')" type="textarea" clearable></el-input>
-                    </el-form-item>
-                </el-form>
-            </div>
+                <div v-if="props.instTaskId">
+                    <el-divider content-position="left">{{ $t('flow.approveForm') }}</el-divider>
+                    <el-form :model="form" label-width="auto">
+                        <el-form-item prop="status" :label="$t('flow.approveResult')" required>
+                            <el-select v-model="form.status">
+                                <el-option :label="$t(ProcinstTaskStatus.Pass.label)" :value="ProcinstTaskStatus.Pass.value"> </el-option>
+                                <el-option :label="$t(ProcinstTaskStatus.Back.label)" :value="ProcinstTaskStatus.Back.value"> </el-option>
+                                <el-option :label="$t(ProcinstTaskStatus.Reject.label)" :value="ProcinstTaskStatus.Reject.value"> </el-option>
+                            </el-select>
+                        </el-form-item>
+                        <el-form-item prop="remark" :label="$t('common.remark')">
+                            <el-input v-model.trim="form.remark" :placeholder="$t('common.remark')" type="textarea" clearable></el-input>
+                        </el-form-item>
+                    </el-form>
+                </div>
 
-            <div v-if="flowDef">
-                <el-divider content-position="left">{{ $t('flow.approveNode') }}</el-divider>
-                <FlowDesign height="300px" disabled center :data="flowDef" />
-            </div>
+                <div v-if="flowDef" class="h-75">
+                    <el-divider content-position="left">{{ $t('flow.approveNode') }}</el-divider>
+                    <FlowDesign disabled center :data="flowDef" />
+                </div>
+            </el-tab-pane>
 
-            <template #footer v-if="props.instTaskId">
-                <el-button @click="cancel()">{{ $t('common.cancel') }}</el-button>
-                <el-button type="primary" :loading="saveBtnLoading" @click="btnOk">{{ $t('common.confirm') }}</el-button>
-            </template>
-        </el-drawer>
-    </div>
+            <el-tab-pane :label="$t('flow.approvalRecord')" name="approvalRecord">
+                <el-timeline>
+                    <el-timeline-item
+                        v-for="task in procinst.procinstTasks"
+                        :key="task.id"
+                        :timestamp="formatDate(task.createTime)"
+                        :type="getTaskStatusType(task.status)"
+                        :icon="getTaskStatusIcon(task.status)"
+                        size="large"
+                        placement="top"
+                    >
+                        <el-card shadow="hover" class="hover:shadow-md transition-shadow">
+                            <div>
+                                <div class="flex justify-between">
+                                    <div>
+                                        <el-text tag="b" size="large">{{ task.nodeName }}</el-text> -
+                                        <el-text tag="b" size="large" type="primary">{{ task.handler || '/' }}</el-text>
+                                    </div>
+                                    <enum-tag :enums="ProcinstTaskStatus" :value="task.status" />
+                                </div>
+
+                                <div class="mt-2">
+                                    <el-text class="ml-5" tag="b">{{ task.remark }}</el-text>
+                                </div>
+                            </div>
+                        </el-card>
+                    </el-timeline-item>
+                </el-timeline>
+            </el-tab-pane>
+        </el-tabs>
+
+        <template #footer v-if="props.instTaskId">
+            <el-button @click="cancel()">{{ $t('common.cancel') }}</el-button>
+            <el-button type="primary" :loading="saveBtnLoading" @click="btnOk">{{ $t('common.confirm') }}</el-button>
+        </template>
+    </el-drawer>
 </template>
 
 <script lang="ts" setup>
@@ -118,6 +150,7 @@ const bizComponents: any = shallowReactive({
 });
 
 const state = reactive({
+    activeTab: 'basic',
     procinst: {} as any,
     flowDef: null as any,
     tasks: [] as any,
@@ -207,7 +240,30 @@ const btnOk = async () => {
 
 const cancel = () => {
     visible.value = false;
+    state.activeTab = 'basic';
     emit('cancel');
 };
+
+const getTaskStatusIcon = (status: number) => {
+    if (status === ProcinstTaskStatus.Pass.value) {
+        return 'Check';
+    } else if (status === ProcinstTaskStatus.Back.value) {
+        return 'Close';
+    } else if (status === ProcinstTaskStatus.Reject.value) {
+        return 'Close';
+    }
+    return 'SemiSelect';
+};
+
+const getTaskStatusType = (status: number) => {
+    if (status === ProcinstTaskStatus.Pass.value) {
+        return 'success';
+    } else if (status === ProcinstTaskStatus.Back.value) {
+        return 'warning';
+    } else if (status === ProcinstTaskStatus.Reject.value) {
+        return 'danger';
+    }
+    return 'primary';
+};
 </script>
 <style lang="scss"></style>
diff --git a/frontend/src/views/flow/components/flowdesign/FlowDesign.vue b/frontend/src/views/flow/components/flowdesign/FlowDesign.vue
index d7d048a6..c4630316 100644
--- a/frontend/src/views/flow/components/flowdesign/FlowDesign.vue
+++ b/frontend/src/views/flow/components/flowdesign/FlowDesign.vue
@@ -1,6 +1,6 @@
 <template>
-    <div :style="{ height: props.height }" class="flex flex-col" v-loading="saveing">
-        <div class="h-screen" ref="flowContainerRef"></div>
+    <div :style="{ height: props.height }" class="flex flex-col w-full" v-loading="saveing">
+        <div class="flex-1 w-full" ref="flowContainerRef"></div>
     </div>
 
     <PropSettingDrawer
diff --git a/frontend/src/views/ops/redis/KeyValueString.vue b/frontend/src/views/ops/redis/KeyValueString.vue
index fc92431e..0c8f858d 100644
--- a/frontend/src/views/ops/redis/KeyValueString.vue
+++ b/frontend/src/views/ops/redis/KeyValueString.vue
@@ -3,7 +3,7 @@
         <el-form label-width="auto">
             <format-viewer ref="formatViewerRef" height="280px" :content="string.value"></format-viewer>
         </el-form>
-        <div class="mt-2 flex justify-end">
+        <div class="mt-1 flex justify-end">
             <el-button @click="saveValue" type="primary" v-auth="'redis:data:save'">{{ $t('common.save') }}</el-button>
         </div>
     </div>
diff --git a/frontend/src/views/ops/resource/ResourceOp.vue b/frontend/src/views/ops/resource/ResourceOp.vue
index 1ee92bcd..baaea7f2 100644
--- a/frontend/src/views/ops/resource/ResourceOp.vue
+++ b/frontend/src/views/ops/resource/ResourceOp.vue
@@ -48,7 +48,14 @@
                             :default-expanded-keys="state.defaultExpandedKeys"
                         >
                             <template #default="{ node, data }">
-                                <component v-if="data.nodeComponent" :is="data.nodeComponent" :node="node" :data="data" />
+                                <div v-if="data.type == TagResourceTypeEnum.Tag.value">
+                                    <span v-for="(value, i) in data.label.split('/')">
+                                        <el-text class="mr-[1.5px]! ml-[1.5px]!" v-if="i != 0" tag="b" type="primary" size="large">/</el-text>
+                                        <el-text>{{ value }}</el-text>
+                                    </span>
+                                </div>
+
+                                <component v-else-if="data.nodeComponent" :is="data.nodeComponent" :node="node" :data="data" />
                                 <BaseTreeNode v-else :node="node" :data="data" />
                             </template>
                         </el-tree>
@@ -86,6 +93,7 @@ import { TagTreeNode, ResourceComponentConfig, ResourceOpCtx } from '@/views/ops
 import { useI18n } from 'vue-i18n';
 import { useAutoOpenResource } from '@/store/autoOpenResource';
 import { storeToRefs } from 'pinia';
+import { LabelLayout } from 'echarts/features';
 
 const props = defineProps({
     load: {
@@ -371,10 +379,69 @@ const onResizeOpPanel = () => {
 const loadTags = async () => {
     const tags = await tagApi.getTagTrees.request({
         type: getResourceTypes().join(','),
-        flatten: '1',
+        flatten: '0',
     });
+
+    const result: any[] = [];
+    const flatten = (node: any, namePath: string[]) => {
+        const currentNamePath = [...namePath, node.name];
+
+        if (node.type !== TagResourceTypeEnum.Tag.value) {
+            return;
+        }
+
+        let hasNonMinus1Child = false;
+        for (const child of node.children || []) {
+            if (child.type !== TagResourceTypeEnum.Tag.value) {
+                hasNonMinus1Child = true;
+                break;
+            }
+        }
+
+        if (hasNonMinus1Child) {
+            const newNode = {
+                ...node,
+                children: [] as any[],
+            };
+            newNode.name = currentNamePath.join('/');
+
+            for (const child of node.children || []) {
+                if (child.type !== TagResourceTypeEnum.Tag.value) {
+                    const childCopy = {
+                        ...child,
+                        children: [] as any[],
+                    };
+                    childCopy.name = [...currentNamePath, child.name].join('/');
+
+                    for (const grandchild of child.children || []) {
+                        const grandchildCopy = {
+                            ...grandchild,
+                        };
+                        grandchildCopy.name = [...currentNamePath, child.name, grandchild.name].join('/');
+                        childCopy.children.push(grandchildCopy);
+                    }
+
+                    newNode.children.push(childCopy);
+                } else {
+                    flatten(child, currentNamePath);
+                }
+            }
+
+            result.push(newNode);
+            return;
+        }
+
+        for (const child of node.children || []) {
+            flatten(child, currentNamePath);
+        }
+    };
+
+    for (const tree of tags) {
+        flatten(tree, []);
+    }
+
     const tagNodes = [];
-    for (let tag of tags) {
+    for (let tag of result) {
         const tagNode = processTagNode(tag);
         tagNodes.push(tagNode);
     }
@@ -382,7 +449,7 @@ const loadTags = async () => {
 };
 
 const processTagNode = (tag: any): TagTreeNode => {
-    const tagNode = new TagTreeNode(tag.codePath, tag.namePath, tag.type);
+    const tagNode = new TagTreeNode(tag.codePath, tag.name, tag.type);
 
     if (!tag.children || !Array.isArray(tag.children) || tag.children.length == 0) {
         return tagNode;
diff --git a/server/go.mod b/server/go.mod
index 652ab414..5f603258 100644
--- a/server/go.mod
+++ b/server/go.mod
@@ -6,14 +6,14 @@ require (
 	gitee.com/chunanyong/dm v1.8.22
 	gitee.com/liuzongyang/libpq v1.10.11
 	github.com/antlr4-go/antlr/v4 v4.13.1
-	github.com/cloudwego/eino v0.7.37
-	github.com/cloudwego/eino-ext/components/model/openai v0.1.8
-	github.com/docker/docker v28.5.0+incompatible
+	github.com/cloudwego/eino v0.8.4
+	github.com/cloudwego/eino-ext/components/model/openai v0.1.10
+	github.com/docker/docker v28.5.2+incompatible
 	github.com/docker/go-connections v0.6.0
 	github.com/gin-gonic/gin v1.12.0
 	github.com/glebarez/sqlite v1.11.0
 	github.com/go-gormigrate/gormigrate/v2 v2.1.5
-	github.com/go-ldap/ldap/v3 v3.4.12
+	github.com/go-ldap/ldap/v3 v3.4.13
 	github.com/go-playground/locales v0.14.1
 	github.com/go-playground/universal-translator v0.18.1
 	github.com/go-playground/validator/v10 v10.30.1
@@ -38,10 +38,10 @@ require (
 	github.com/twmb/franz-go v1.20.7
 	github.com/twmb/franz-go/pkg/kadm v1.17.2
 	go.mongodb.org/mongo-driver/v2 v2.5.0 // mongo
-	golang.org/x/crypto v0.48.0
-	golang.org/x/oauth2 v0.35.0
-	golang.org/x/sync v0.19.0
-	golang.org/x/text v0.34.0
+	golang.org/x/crypto v0.49.0
+	golang.org/x/oauth2 v0.36.0
+	golang.org/x/sync v0.20.0
+	golang.org/x/text v0.35.0
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1
 	gopkg.in/yaml.v3 v3.0.1
 	gorm.io/driver/mysql v1.6.0
@@ -50,9 +50,10 @@ require (
 
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
-	github.com/Azure/go-ntlmssp v0.0.0-20221128193559-754e69321358 // indirect
+	github.com/Azure/go-ntlmssp v0.1.0 // indirect
 	github.com/Microsoft/go-winio v0.6.2 // indirect
 	github.com/bahlo/generic-list-go v0.2.0 // indirect
+	github.com/bmatcuk/doublestar/v4 v4.10.0 // indirect
 	github.com/boombuler/barcode v1.1.0 // indirect
 	github.com/buger/jsonparser v1.1.1 // indirect
 	github.com/bytedance/gopkg v0.1.3 // indirect
@@ -60,7 +61,7 @@ require (
 	github.com/bytedance/sonic/loader v0.5.0 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/cloudwego/base64x v0.1.6 // indirect
-	github.com/cloudwego/eino-ext/libs/acl/openai v0.1.13 // indirect
+	github.com/cloudwego/eino-ext/libs/acl/openai v0.1.14 // indirect
 	github.com/containerd/errdefs v1.0.0 // indirect
 	github.com/containerd/errdefs/pkg v0.3.0 // indirect
 	github.com/containerd/log v0.1.0 // indirect
@@ -135,7 +136,7 @@ require (
 	golang.org/x/exp v0.0.0-20251002181428-27f1f14c8bb9 // indirect
 	golang.org/x/image v0.31.0 // indirect
 	golang.org/x/net v0.51.0 // indirect
-	golang.org/x/sys v0.41.0 // indirect
+	golang.org/x/sys v0.42.0 // indirect
 	google.golang.org/protobuf v1.36.10 // indirect
 	modernc.org/libc v1.66.10 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
diff --git a/server/internal/ai/agent/agent.go b/server/internal/ai/agent/agent.go
index 5e758956..534f8c29 100644
--- a/server/internal/ai/agent/agent.go
+++ b/server/internal/ai/agent/agent.go
@@ -2,38 +2,32 @@ package agent
 
 import (
 	"context"
-	"mayfly-go/internal/ai/config"
-	"mayfly-go/internal/ai/protocol"
 	"mayfly-go/pkg/logx"
 
 	"github.com/cloudwego/eino/adk"
+	"github.com/cloudwego/eino/adk/prebuilt/deep"
 	"github.com/cloudwego/eino/components/tool"
+	"github.com/cloudwego/eino/compose"
 	"github.com/cloudwego/eino/schema"
 )
 
-// GetAgent 获取AI Agent
-func GetAgent(ctx context.Context, modelConfig *config.ModelConfig, tools ...tool.BaseTool) (adk.Agent, error) {
-	toolableChatModel, err := protocol.GetChatModel(ctx, modelConfig)
+// newOpsExpertAgent 创建一个新的运维专家Agent
+func newOpsExpertAgent(ctx context.Context, tools ...tool.BaseTool) (adk.Agent, error) {
+	toolableChatModel, err := GetChatModel(ctx)
 	if err != nil {
 		return nil, err
 	}
 
-	// 初始化所需的 tools
-	toolsConfig := adk.ToolsConfig{}
-	toolsConfig.Tools = tools
-
-	chatAgent, err := adk.NewChatModelAgent(ctx, &adk.ChatModelAgentConfig{
-		Name:        "ops_expert",
-		Description: "一位拥有20多年系统管理、数据库管理和基础设施优化经验的专业DevOps专家。",
-		Instruction: `你现在是一位专业的数据库管理员、Redis管理员和安全审核专家，请根据用户的问题给出最合适的答案。`,
+	return adk.NewChatModelAgent(ctx, &adk.ChatModelAgentConfig{
+		Name:        "OpsExpertAgent",
+		Description: "an agent for ops expert task",
 		Model:       toolableChatModel,
-		ToolsConfig: toolsConfig,
+		ToolsConfig: adk.ToolsConfig{
+			ToolsNodeConfig: compose.ToolsNodeConfig{
+				Tools: tools,
+			},
+		},
 	})
-	if err != nil {
-		return nil, err
-	}
-
-	return chatAgent, nil
 }
 
 // GetOpsExpertAgent 获取运维专家agent
@@ -45,7 +39,7 @@ func GetOpsExpertAgent(ctx context.Context, toolTypes ...ToolType) (*AiAgent, er
 		}
 	}
 
-	agent, err := GetAgent(ctx, config.GetModel(), tools...)
+	agent, err := newOpsExpertAgent(ctx, tools...)
 	if err != nil {
 		return nil, err
 	}
@@ -60,16 +54,14 @@ type AiAgent struct {
 
 // Run 运行，并返回最终结果
 func (aiAgent *AiAgent) Run(ctx context.Context, sysPrompt string, question string) (string, error) {
-	if sysPrompt == "" {
-		sysPrompt = "你现在是一位拥有20年实战经验的顶级系统运维专家，精通Linux操作系统、数据库管理（如MySQL、PostgreSQL）、NoSQL数据库（如Redis、MongoDB）以及搜索引擎（如Elasticsearch）。"
-	}
-
 	runner := adk.NewRunner(ctx, adk.RunnerConfig{
-		EnableStreaming: false,
+		EnableStreaming: true,
 		Agent:           aiAgent.Agent,
 		CheckPointStore: NewInMemoryStore(),
 	})
 
+	deep.New(ctx, &deep.Config{})
+
 	iter := runner.Run(ctx, []adk.Message{
 		{
 			Role:    schema.System,
@@ -81,7 +73,7 @@ func (aiAgent *AiAgent) Run(ctx context.Context, sysPrompt string, question stri
 		},
 	})
 
-	res := ""
+	var lastMessage adk.Message
 	for {
 		event, ok := iter.Next()
 		if !ok {
@@ -91,15 +83,38 @@ func (aiAgent *AiAgent) Run(ctx context.Context, sysPrompt string, question stri
 		err := event.Err
 		if err != nil {
 			logx.Error(err.Error())
-			return res, err
+			return "", err
+		}
+
+		if lastMessage, _, err = adk.GetMessage(event); err != nil {
+			return "", err
 		}
 
 		LogEvent(event)
-		msg := event.Output.MessageOutput.Message
-		if msg != nil {
-			res = msg.Content
-		}
 	}
 
-	return res, nil
+	if lastMessage != nil {
+		return lastMessage.Content, nil
+	}
+
+	return "finished without output message", nil
+}
+
+func NewDeepAgent(ctx context.Context, tools ...tool.BaseTool) (adk.Agent, error) {
+	toolableChatModel, err := GetChatModel(ctx)
+	if err != nil {
+		return nil, err
+	}
+	return deep.New(ctx, &deep.Config{
+		Name:        "OpsExpertAgent",
+		Description: "an agent for ops expert task",
+		ChatModel:   toolableChatModel,
+		// SubAgents:   []adk.Agent{ca, wa},
+		ToolsConfig: adk.ToolsConfig{
+			ToolsNodeConfig: compose.ToolsNodeConfig{
+				Tools: tools,
+			},
+		},
+		MaxIteration: 100,
+	})
 }
diff --git a/server/internal/ai/agent/model.go b/server/internal/ai/agent/model.go
new file mode 100644
index 00000000..85e50c60
--- /dev/null
+++ b/server/internal/ai/agent/model.go
@@ -0,0 +1,14 @@
+package agent
+
+import (
+	"context"
+	"mayfly-go/internal/ai/config"
+	"mayfly-go/internal/ai/protocol"
+
+	"github.com/cloudwego/eino/components/model"
+)
+
+// GetChatModel 获取Chat模型
+func GetChatModel(ctx context.Context) (model.ToolCallingChatModel, error) {
+	return protocol.GetChatModel(ctx, config.GetModel())
+}
diff --git a/server/internal/ai/agent/print.go b/server/internal/ai/agent/print.go
index 2073f272..81972bc4 100644
--- a/server/internal/ai/agent/print.go
+++ b/server/internal/ai/agent/print.go
@@ -2,120 +2,66 @@ package agent
 
 import (
 	"fmt"
-	"io"
-	"log"
 	"mayfly-go/pkg/logx"
-	"strings"
 
 	"github.com/cloudwego/eino/adk"
 	"github.com/cloudwego/eino/schema"
 )
 
 func LogEvent(event *adk.AgentEvent) {
-	logx.Debugf("agent name: %s, path: %s", event.AgentName, event.RunPath)
-	if event.Output != nil && event.Output.MessageOutput != nil {
-		if m := event.Output.MessageOutput.Message; m != nil {
-			if len(m.Content) > 0 {
-				if m.Role == schema.Tool {
-					logx.Debugf("agent tool response: %s", m.Content)
-				} else {
-					logx.Debugf("agent answer: %s", m.Content)
-				}
-			}
-			if len(m.ToolCalls) > 0 {
-				for _, tc := range m.ToolCalls {
-					logx.Debugf("agent tool name: %s", tc.Function.Name)
-					logx.Debugf("agent tool arguments: %s", tc.Function.Arguments)
-				}
-			}
-		} else if s := event.Output.MessageOutput.MessageStream; s != nil {
-			toolMap := map[int][]*schema.Message{}
-			var contentStart bool
-			charNumOfOneRow := 0
-			maxCharNumOfOneRow := 120
-			for {
-				chunk, err := s.Recv()
-				if err != nil {
-					if err == io.EOF {
-						break
-					}
-					logx.Debugf("agent error: %v", err)
-					return
-				}
-				if chunk.Content != "" {
-					if !contentStart {
-						contentStart = true
-						if chunk.Role == schema.Tool {
-							logx.Debugf("agent tool response: ")
-						} else {
-							logx.Debugf("agent answer: ")
-						}
-					}
+	agentTag := fmt.Sprintf("Agent - [%s|%s]", event.AgentName, event.RunPath)
 
-					charNumOfOneRow += len(chunk.Content)
-					if strings.Contains(chunk.Content, "\n") {
-						charNumOfOneRow = 0
-					} else if charNumOfOneRow >= maxCharNumOfOneRow {
-						logx.Debugf("\n")
-						charNumOfOneRow = 0
-					}
-					logx.Debugf("%v", chunk.Content)
-				}
+	msg, _, err := adk.GetMessage(event)
+	if err != nil {
+		logx.Debugf("%s error: get msg error: %v", agentTag, err)
+		return
+	}
 
-				if len(chunk.ToolCalls) > 0 {
-					for _, tc := range chunk.ToolCalls {
-						index := tc.Index
-						if index == nil {
-							logx.Error("index is nil")
-						}
-						toolMap[*index] = append(toolMap[*index], &schema.Message{
-							Role: chunk.Role,
-							ToolCalls: []schema.ToolCall{
-								{
-									ID:    tc.ID,
-									Type:  tc.Type,
-									Index: tc.Index,
-									Function: schema.FunctionCall{
-										Name:      tc.Function.Name,
-										Arguments: tc.Function.Arguments,
-									},
-								},
-							},
-						})
-					}
-				}
-			}
-
-			for _, msgs := range toolMap {
-				m, err := schema.ConcatMessages(msgs)
-				if err != nil {
-					log.Fatalf("ConcatMessage failed: %v", err)
-					return
-				}
-				logx.Debugf("agent tool name: %s", m.ToolCalls[0].Function.Name)
-				logx.Debugf("agent tool arguments: %s", m.ToolCalls[0].Function.Arguments)
-			}
+	// 消息内容
+	if len(msg.Content) > 0 {
+		content := msg.Content
+		if len(content) > 500 {
+			content = content[:500] + "..."
+		}
+		if msg.Role == schema.Tool {
+			logx.Infof("%s tool[%s] response: %s", agentTag, msg.ToolName, content)
+		} else {
+			logx.Infof("%s answer: %s", agentTag, content)
 		}
 	}
+
+	// 工具调用
+	if len(msg.ToolCalls) > 0 {
+		for _, tc := range msg.ToolCalls {
+			args := tc.Function.Arguments
+			if len(args) > 300 {
+				args = args[:300] + "..."
+			}
+			logx.Infof("%s call %s(%s)", agentTag, tc.Function.Name, args)
+		}
+	}
+
+	// 动作
 	if event.Action != nil {
 		if event.Action.TransferToAgent != nil {
-			logx.Debugf("agent action: transfer to %v", event.Action.TransferToAgent.DestAgentName)
+			logx.Debugf("%s ->  transfer: %s", agentTag, event.Action.TransferToAgent.DestAgentName)
 		}
 		if event.Action.Interrupted != nil {
 			for _, ic := range event.Action.Interrupted.InterruptContexts {
-				str, ok := ic.Info.(fmt.Stringer)
-				if ok {
-					logx.Debugf("\n%s", str.String())
+				if str, ok := ic.Info.(fmt.Stringer); ok {
+					logx.Infof("%s ⏸  %s", agentTag, str.String())
 				} else {
-					logx.Debugf("\n%v", ic.Info)
+					logx.Infof("%s ⏸  %v", agentTag, ic.Info)
 				}
 			}
 		}
 		if event.Action.Exit {
-			logx.Debugf("agent action: exit")
+			logx.Infof("%s done", agentTag)
 		}
 	}
+
+	// 错误
 	if event.Err != nil {
-		logx.Debugf("agent error: %v", event.Err)
+		logx.Errorf("%s error: %v", agentTag, event.Err)
 	}
 }
diff --git a/server/internal/ai/prompt/prompts/flow_biz_audit.md b/server/internal/ai/prompt/prompts/flow_biz_audit.md
index 8572c370..ea760cb6 100644
--- a/server/internal/ai/prompt/prompts/flow_biz_audit.md
+++ b/server/internal/ai/prompt/prompts/flow_biz_audit.md
@@ -54,31 +54,6 @@
 
 ---
 
-# 工具说明
-
-## 工具：QueryTableInfo
-
-### 功能说明
-
-用于查询指定数据库表的真实结构信息，包括：
-- 字段名称  
-- 字段类型  
-- 主键字段  
-- 索引信息（唯一索引 / 普通索引）  
-
-### 调用规则
-
-- 当审核规则要求校验 **表、字段或索引** 时：
-  - ✅ **必须调用该工具**
-  - ❌ **不得跳过、替代或基于经验判断**
-
-### 参数约束
-
-- 工具参数必须 **完全来源于 SQL 解析结果**
-- ❌ 禁止编造表名、字段名或数据库信息  
-
----
-
 # 输入说明
 
 每条业务操作请求包含以下内容：
diff --git a/server/internal/ai/protocol/registry.go b/server/internal/ai/protocol/registry.go
index 2d16a8a9..7fdde2d2 100644
--- a/server/internal/ai/protocol/registry.go
+++ b/server/internal/ai/protocol/registry.go
@@ -16,8 +16,8 @@ func init() {
 }
 
 var (
-	protocolMap = collx.SM[string, Protocol]{}
-	chatModels = collx.SM[string,model.ToolCallingChatModel]{}
+	protocolMap collx.SM[string, Protocol]
+	chatModels  collx.SM[string, model.ToolCallingChatModel]
 )
 
 // Register 注册协议
diff --git a/server/internal/db/ai/tools/query_data.go b/server/internal/db/ai/tools/query_data.go
new file mode 100644
index 00000000..c9e91afe
--- /dev/null
+++ b/server/internal/db/ai/tools/query_data.go
@@ -0,0 +1,49 @@
+package tools
+
+import (
+	"context"
+
+	"mayfly-go/internal/db/application"
+	"mayfly-go/internal/db/dbm/dbi"
+
+	"github.com/cloudwego/eino/components/tool"
+	"github.com/cloudwego/eino/components/tool/utils"
+)
+
+type QueryDataParam struct {
+	DbId   uint64 `json:"dbId" jsonschema_description:"数据库ID"`
+	DbName string `json:"dbName" jsonschema_description:"数据库名称"`
+	SQL    string `json:"sql" jsonschema_description:"SQL语句"`
+}
+
+type QueryDataOutput struct {
+	Columns []*dbi.QueryColumn `json:"columns" jsonschema_description:"查询结果列信息"`
+	Rows    []map[string]any   `json:"rows" jsonschema_description:"查询结果数据"`
+}
+
+func GetQueryData() (tool.InvokableTool, error) {
+	return utils.InferTool("DbQueryData",
+		"【数据库】SQL查询 - 执行只读类 SQL 语句（如 SELECT、SHOW、DESC、EXPLAIN 等）。适用于查询表数据、分析执行计划等场景。注意：仅限查询操作，禁止执行 INSERT、UPDATE、DELETE 等变更类 SQL。",
+		func(ctx context.Context, param *QueryDataParam) (*QueryDataOutput, error) {
+			conn, err := application.GetDbApp().GetDbConn(ctx, param.DbId, param.DbName)
+			if err != nil {
+				return nil, err
+			}
+
+			rows := make([]map[string]any, 0)
+			columns, err := conn.WalkQueryRows(ctx, param.SQL, func(row map[string]any, columns []*dbi.QueryColumn) error {
+				rows = append(rows, row)
+				if len(rows) > 1000 {
+					return dbi.NewStopWalkQueryError("The maximum number of query rows is exceeded: 1000")
+				}
+				return nil
+			})
+			if err != nil {
+				return nil, err
+			}
+
+			output := &QueryDataOutput{Columns: columns, Rows: rows}
+			return output, nil
+		},
+	)
+}
diff --git a/server/internal/db/ai/tools/query_table_info.go b/server/internal/db/ai/tools/query_table_info.go
index 9bbbddb1..594882c5 100644
--- a/server/internal/db/ai/tools/query_table_info.go
+++ b/server/internal/db/ai/tools/query_table_info.go
@@ -20,8 +20,8 @@ type QueryTableInfoOutput struct {
 }
 
 func GetQueryTableInfo() (tool.InvokableTool, error) {
-	return utils.InferTool("QueryTableInfo",
-		"当需要了解某个表结构时，请调用此工具。使用它来查询数据库表的DDL信息，包括表结构、字段定义、索引等。",
+	return utils.InferTool("DbQueryTableInfo",
+		"【数据库】表结构查询工具 - 获取指定数据表的 DDL 定义，包含字段名、数据类型、约束、索引等完整元数据。适用于编写 SQL 前了解表结构、排查数据问题时查看表定义等场景。",
 		func(ctx context.Context, param *QueryTableInfoParam) (*QueryTableInfoOutput, error) {
 			conn, err := application.GetDbApp().GetDbConn(ctx, param.DbId, param.DbName)
 			if err != nil {
diff --git a/server/internal/db/ai/tools/tools.go b/server/internal/db/ai/tools/tools.go
index 032991ce..cc8ef46e 100644
--- a/server/internal/db/ai/tools/tools.go
+++ b/server/internal/db/ai/tools/tools.go
@@ -11,4 +11,10 @@ func Init() {
 	} else {
 		agent.RegisterTool(agent.ToolTypeDb, queryTableTool)
 	}
+
+	if queryDataTool, err := GetQueryData(); err != nil {
+		logx.Errorf("agent tool - 获取QueryData工具失败: %v", err)
+	} else {
+		agent.RegisterTool(agent.ToolTypeDb, queryDataTool)
+	}
 }
diff --git a/server/internal/docker/api/container.go b/server/internal/docker/api/container.go
index 1277d3cc..d4628ed9 100644
--- a/server/internal/docker/api/container.go
+++ b/server/internal/docker/api/container.go
@@ -93,13 +93,11 @@ func (d *Container) GetContainersStats(rc *req.Ctx) {
 	biz.ErrIsNil(err)
 
 	var wg sync.WaitGroup
-	wg.Add(len(cs))
-
 	var mu sync.Mutex
 	allStats := make([]vo.ContainerStats, 0)
 	for _, c := range cs {
-		gox.Go(func() {
-			defer wg.Done()
+		wg.Go(func() {
+			defer gox.Recover()
 			if c.State != "running" {
 				return
 			}
diff --git a/server/internal/machine/api/machine_file.go b/server/internal/machine/api/machine_file.go
index 80cee091..098e54c7 100644
--- a/server/internal/machine/api/machine_file.go
+++ b/server/internal/machine/api/machine_file.go
@@ -15,8 +15,8 @@ import (
 	msgdto "mayfly-go/internal/msg/application/dto"
 	"mayfly-go/internal/pkg/event"
 	"mayfly-go/pkg/biz"
-	"mayfly-go/pkg/errorx"
 	"mayfly-go/pkg/global"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"mayfly-go/pkg/model"
 	"mayfly-go/pkg/req"
@@ -374,28 +374,15 @@ func (m *MachineFile) UploadFolder(rc *req.Ctx) {
 	chunks := collx.ArraySplit(folderFiles, groupNum)
 
 	var wg sync.WaitGroup
-	// 设置要等待的协程数量
-	wg.Add(len(chunks))
-
 	isSuccess := true
 	for _, chunk := range chunks {
 		wg.Go(func() {
-			defer func() {
-				// 协程执行完成后调用Done方法
-				wg.Done()
-				if err := recover(); err != nil {
-					isSuccess = false
-					logx.Errorf("upload file error: %s", err)
-					switch t := err.(type) {
-					case *errorx.BizError:
-						{
-							msgEvent.TmplChannel = msgdto.MsgTmplMachineFileUploadFail
-							msgEvent.Params["error"] = t.Error()
-							global.EventBus.Publish(ctx, event.EventTopicMsgTmplSend, msgEvent)
-						}
-					}
-				}
-			}()
+			defer gox.Recover(func(e error) {
+				isSuccess = false
+				msgEvent.TmplChannel = msgdto.MsgTmplMachineFileUploadFail
+				msgEvent.Params["error"] = e.Error()
+				global.EventBus.Publish(ctx, event.EventTopicMsgTmplSend, msgEvent)
+			})
 
 			for _, file := range chunk {
 				fileHeader := file.Fileheader
diff --git a/server/internal/msg/msgx/msgx.go b/server/internal/msg/msgx/msgx.go
index 1ee51c60..68aa7163 100644
--- a/server/internal/msg/msgx/msgx.go
+++ b/server/internal/msg/msgx/msgx.go
@@ -70,7 +70,7 @@ type MsgSender interface {
 	Send(ctx context.Context, channel *Channel, msg *Msg) error
 }
 
-var messageSenders *collx.SM[ChannelType, MsgSender] = collx.NewSM[ChannelType, MsgSender]()
+var messageSenders collx.SM[ChannelType, MsgSender]
 
 // RegisterMsgSender 注册消息发送器
 func RegisterMsgSender(channel ChannelType, sender MsgSender) {
diff --git a/server/internal/msg/msgx/sender/ding_bot.go b/server/internal/msg/msgx/sender/ding_bot.go
index 6698ee98..f4ba7850 100644
--- a/server/internal/msg/msgx/sender/ding_bot.go
+++ b/server/internal/msg/msgx/sender/ding_bot.go
@@ -41,6 +41,8 @@ type dingBotMsgResp struct {
 // DingBotSender 钉钉机器人消息发送
 type DingBotSender struct{}
 
+var _ msgx.MsgSender = DingBotSender{}
+
 func (d DingBotSender) Send(ctx context.Context, channel *msgx.Channel, msg *msgx.Msg) error {
 	// https://open.dingtalk.com/document/robots/custom-robot-access#title-72m-8ag-pqw
 	msgReq := dingBotMsgReq{}
diff --git a/server/internal/msg/msgx/sender/email.go b/server/internal/msg/msgx/sender/email.go
index dc9f7af7..83efef9b 100644
--- a/server/internal/msg/msgx/sender/email.go
+++ b/server/internal/msg/msgx/sender/email.go
@@ -17,6 +17,8 @@ import (
 
 type EmailSender struct{}
 
+var _ (msgx.MsgSender) = EmailSender{}
+
 func (e EmailSender) Send(ctx context.Context, channel *msgx.Channel, msg *msgx.Msg) error {
 	return e.SendEmail(channel, msg)
 }
diff --git a/server/internal/msg/msgx/sender/feishu_bot.go b/server/internal/msg/msgx/sender/feishu_bot.go
index abba03a0..e54c5178 100644
--- a/server/internal/msg/msgx/sender/feishu_bot.go
+++ b/server/internal/msg/msgx/sender/feishu_bot.go
@@ -35,6 +35,8 @@ type feishuBotMsgResp struct {
 // FeishuBotSender 发送飞书机器人消息
 type FeishuBotSender struct{}
 
+var _ msgx.MsgSender = FeishuBotSender{}
+
 func (f FeishuBotSender) Send(ctx context.Context, channel *msgx.Channel, msg *msgx.Msg) error {
 	// https://open.feishu.cn/document/client-docs/bot-v3/add-custom-bot
 	msgReq := feishuBotMsgReq{
diff --git a/server/internal/msg/msgx/sender/qywx_bot.go b/server/internal/msg/msgx/sender/qywx_bot.go
index cc8b0d1f..99d5f882 100644
--- a/server/internal/msg/msgx/sender/qywx_bot.go
+++ b/server/internal/msg/msgx/sender/qywx_bot.go
@@ -30,6 +30,8 @@ type qywxBotMsgResp struct {
 // QywxBotSender 企业微信机器人消息发送
 type QywxBotSender struct{}
 
+var _ msgx.MsgSender = QywxBotSender{}
+
 func (e QywxBotSender) Send(ctx context.Context, channel *msgx.Channel, msg *msgx.Msg) error {
 	// https://developer.work.weixin.qq.com/document/path/91770
 	msgReq := qywxBotMsgReq{}
diff --git a/server/internal/msg/msgx/sender/ws.go b/server/internal/msg/msgx/sender/ws.go
index 6e973944..eff2dbd1 100644
--- a/server/internal/msg/msgx/sender/ws.go
+++ b/server/internal/msg/msgx/sender/ws.go
@@ -13,6 +13,8 @@ import (
 
 type WsSender struct{}
 
+var _ msgx.MsgSender = WsSender{}
+
 func (e WsSender) Send(ctx context.Context, channel *msgx.Channel, msg *msgx.Msg) error {
 	var err error
 	content := msg.Content
diff --git a/server/internal/tag/api/tag_tree.go b/server/internal/tag/api/tag_tree.go
index 07a79396..aaa39ef6 100644
--- a/server/internal/tag/api/tag_tree.go
+++ b/server/internal/tag/api/tag_tree.go
@@ -1,7 +1,6 @@
 package api
 
 import (
-	"cmp"
 	"fmt"
 	"mayfly-go/internal/tag/api/form"
 	"mayfly-go/internal/tag/api/vo"
@@ -46,8 +45,6 @@ func (t *TagTree) ReqConfs() *req.Confs {
 
 func (p *TagTree) GetTagTree(rc *req.Ctx) {
 	tagTypesStr := rc.Query("type")
-	flatten := rc.Query("flatten") // 是否展开平铺树
-	flatten = cmp.Or(flatten, "0")
 
 	var typePaths []entity.TypePath
 	if tagTypesStr != "" {
@@ -68,14 +65,7 @@ func (p *TagTree) GetTagTree(rc *req.Ctx) {
 		tagTrees = append(tagTrees, tag)
 	}
 
-	var tree []*vo.TagTreeItem
-	if flatten != "0" {
-		tree = tagTrees.ToFlattenTrees(0)
-	} else {
-		tree = tagTrees.ToTrees(0)
-	}
-
-	rc.ResData = tree
+	rc.ResData = tagTrees.ToTrees(0)
 }
 
 // complteTags 补全标签信息，使其能构造为树结构
diff --git a/server/internal/tag/api/vo/tag_tree.go b/server/internal/tag/api/vo/tag_tree.go
index f047a4cc..a772e8b6 100644
--- a/server/internal/tag/api/vo/tag_tree.go
+++ b/server/internal/tag/api/vo/tag_tree.go
@@ -2,7 +2,6 @@ package vo
 
 import (
 	"mayfly-go/internal/tag/application/dto"
-	"strings"
 )
 
 type TagTreeVOS []*dto.SimpleTagTree
@@ -44,64 +43,3 @@ func (m *TagTreeVOS) ToTrees(pid uint64) []*TagTreeItem {
 
 	return roots
 }
-
-func (m *TagTreeVOS) ToFlattenTrees(pid uint64) []*TagTreeItem {
-	trees := m.ToTrees(pid)
-	result := make([]*TagTreeItem, 0)
-
-	var flatten func(node *TagTreeItem, namePath []string)
-	flatten = func(node *TagTreeItem, namePath []string) {
-		currentNamePath := append(namePath, node.Name)
-
-		if node.Type != -1 {
-			return
-		}
-
-		hasNonMinus1Child := false
-		for _, child := range node.Children {
-			if child.Type != -1 {
-				hasNonMinus1Child = true
-				break
-			}
-		}
-
-		if hasNonMinus1Child {
-			newNode := &TagTreeItem{
-				SimpleTagTree: node.SimpleTagTree,
-				Children:      make([]*TagTreeItem, 0),
-				NamePath:      strings.Join(currentNamePath, "/"),
-			}
-			for _, child := range node.Children {
-				if child.Type != -1 {
-					childCopy := &TagTreeItem{
-						SimpleTagTree: child.SimpleTagTree,
-						Children:      make([]*TagTreeItem, 0),
-						NamePath:      strings.Join(append(currentNamePath, child.Name), "/"),
-					}
-					for _, grandchild := range child.Children {
-						grandchildCopy := &TagTreeItem{
-							SimpleTagTree: grandchild.SimpleTagTree,
-							NamePath:      strings.Join(append(currentNamePath, child.Name, grandchild.Name), "/"),
-						}
-						childCopy.Children = append(childCopy.Children, grandchildCopy)
-					}
-					newNode.Children = append(newNode.Children, childCopy)
-				} else {
-					flatten(child, currentNamePath)
-				}
-			}
-			result = append(result, newNode)
-			return
-		}
-
-		for _, child := range node.Children {
-			flatten(child, currentNamePath)
-		}
-	}
-
-	for _, tree := range trees {
-		flatten(tree, []string{})
-	}
-
-	return result
-}
diff --git a/server/pkg/scheduler/scheduler.go b/server/pkg/scheduler/scheduler.go
index e9d459a6..5a417563 100644
--- a/server/pkg/scheduler/scheduler.go
+++ b/server/pkg/scheduler/scheduler.go
@@ -14,7 +14,7 @@ func init() {
 
 var (
 	cronService = cron.New(cron.WithSeconds())
-	key2IdMap  *collx.SM[string, cron.EntryID] = collx.NewSM[string, cron.EntryID]()
+	key2IdMap   collx.SM[string, cron.EntryID]
 )
 
 func Start() {
diff --git a/server/pkg/utils/collx/map.go b/server/pkg/utils/collx/map.go
index f66391ff..69ba8397 100644
--- a/server/pkg/utils/collx/map.go
+++ b/server/pkg/utils/collx/map.go
@@ -67,11 +67,6 @@ type SM[K comparable, V any] struct {
 	m sync.Map
 }
 
-// NewSM 创建一个新的线程安全 map 实例
-func NewSM[K comparable, V any]() *SM[K, V] {
-	return &SM[K, V]{}
-}
-
 // Load 方法返回存储在 map 中键为 k 的值，如果不存在则返回零值和 false
 func (sm *SM[K, V]) Load(k K) (V, bool) {
 	v, ok := sm.m.Load(k)
@@ -113,7 +108,6 @@ func (sm *SM[K, V]) Clear() {
 	sm.m.Clear()
 }
 
-
 // Range 遍历 map 中的所有键值对
 func (sm *SM[K, V]) Range(f func(k K, v V) bool) {
 	sm.m.Range(func(k, v any) bool {
diff --git a/server/pkg/ws/client_manager.go b/server/pkg/ws/client_manager.go
index e9997d67..020391b3 100644
--- a/server/pkg/ws/client_manager.go
+++ b/server/pkg/ws/client_manager.go
@@ -12,13 +12,11 @@ const heartbeatInterval = 25 * time.Second
 
 // UserClient 用户全部的连接
 type UserClient struct {
-	clients *collx.SM[string, *Client] // key->clientId, value->Client
+	clients collx.SM[string, *Client] // key->clientId, value->Client
 }
 
 func NewUserClient() *UserClient {
-	return &UserClient{
-		clients: collx.NewSM[string, *Client](),
-	}
+	return &UserClient{}
 }
 
 // AllClients 获取全部的连接
@@ -28,7 +26,7 @@ func (ucs *UserClient) AllClients() []*Client {
 
 // GetByCid 获取指定客户端ID的客户端
 func (ucs *UserClient) GetByCid(clientId string) *Client {
-	cli, _ :=  ucs.clients.Load(clientId)
+	cli, _ := ucs.clients.Load(clientId)
 	return cli
 }
 
@@ -49,7 +47,7 @@ func (ucs *UserClient) Count() int {
 
 // 连接管理
 type ClientManager struct {
-	UserClientMap *collx.SM[UserId, *UserClient] // 全部的用户连接, key->userid, value->*UserClient
+	UserClientMap collx.SM[UserId, *UserClient] // 全部的用户连接, key->userid, value->*UserClient
 
 	ConnectChan    chan *Client // 连接处理
 	DisConnectChan chan *Client // 断开连接处理
@@ -58,7 +56,6 @@ type ClientManager struct {
 
 func NewClientManager() (clientManager *ClientManager) {
 	return &ClientManager{
-		UserClientMap:  collx.NewSM[UserId, *UserClient](),
 		ConnectChan:    make(chan *Client, 10),
 		DisConnectChan: make(chan *Client, 10),
 		MsgChan:        make(chan *Msg, 100),