diff --git a/packages/api/src/core/task.ts b/packages/api/src/core/task.ts
index 4f36bada1..97888b3df 100644
--- a/packages/api/src/core/task.ts
+++ b/packages/api/src/core/task.ts
@@ -143,6 +143,10 @@ export function batchUpdateTaskListtags(params: any) {
   return requestClient.patch(`${BASE_URL}/batchUpdateListtags`, params)
 }
 
+export function batchApplyTaskListtags(params: any) {
+  return requestClient.patch(`${BASE_URL}/batchApplyListtags`, params)
+}
+
 export function saveTask(params: any, config?: any) {
   return requestClient.patch(
     `${BASE_URL}/confirm/${params.id || ''}`,
diff --git a/packages/business/src/components/BatchTagDialog.vue b/packages/business/src/components/BatchTagDialog.vue
new file mode 100644
index 000000000..b76717b10
--- /dev/null
+++ b/packages/business/src/components/BatchTagDialog.vue
@@ -0,0 +1,792 @@
+<script setup lang="ts">
+import {
+  createMetadataDefinition,
+  fetchMetadataDefinitionTags,
+} from '@tap/api/src/core/metadata-definitions'
+import { batchApplyTaskListtags } from '@tap/api/src/core/task'
+import { useI18n } from '@tap/i18n'
+import { ElMessage } from 'element-plus'
+import { computed, ref } from 'vue'
+
+type TagState = 'all' | 'some' | 'none'
+
+interface TagItem {
+  id: string
+  value: string
+  parent_id?: string
+}
+
+interface TaskTagItem {
+  id: string
+  value: string
+  name?: string
+}
+
+interface TaskItem {
+  id: string
+  name?: string
+  listtags?: TaskTagItem[]
+}
+
+interface SummaryItem {
+  type: 'add' | 'remove'
+  tag: TagItem
+  count: number
+}
+
+interface Props {
+  tagType?: string
+  viewPage?: string
+  submitTags?: (params: BatchTagSubmitParams) => Promise<any>
+}
+
+interface BatchTagSubmitParams {
+  ids: string[]
+  tags: Array<{
+    id: string
+    value: string
+    desired: TagState
+  }>
+}
+
+const props = withDefaults(defineProps<Props>(), {
+  tagType: 'dataflow',
+  viewPage: '',
+  submitTags: batchApplyTaskListtags,
+})
+
+const emit = defineEmits<{
+  saved: []
+  tagCreated: []
+  close: []
+}>()
+
+const { t } = useI18n()
+
+const visible = ref(false)
+const loading = ref(false)
+const saving = ref(false)
+const creating = ref(false)
+const searchValue = ref('')
+const selectedTasks = ref<TaskItem[]>([])
+const allTags = ref<TagItem[]>([])
+const desiredStates = ref<Record<string, TagState>>({})
+const currentTagType = ref('')
+
+const normalizeName = (value: string) => value.trim().toLowerCase()
+const getTagType = (type?: string) => type || props.viewPage || props.tagType
+
+const flattenTags = (items: any[] = []) => {
+  const result: TagItem[] = []
+
+  const walk = (list: any[] = []) => {
+    list.forEach((item) => {
+      if (!item) return
+
+      const { children, ...rest } = item
+      result.push({
+        id: rest.id,
+        value: rest.value || rest.name || '',
+        parent_id: rest.parent_id,
+      })
+
+      if (Array.isArray(children) && children.length) {
+        walk(children)
+      }
+    })
+  }
+
+  walk(items)
+  return result
+}
+
+const selectedTaskCount = computed(() => selectedTasks.value.length)
+
+const tagUsageMap = computed(() => {
+  const map = new Map<string, number>()
+
+  selectedTasks.value.forEach((task) => {
+    task.listtags?.forEach((tag) => {
+      map.set(tag.id, (map.get(tag.id) || 0) + 1)
+    })
+  })
+
+  return map
+})
+
+const initialState = (tagId: string): TagState => {
+  const count = tagUsageMap.value.get(tagId) || 0
+
+  if (!selectedTaskCount.value || !count) {
+    return 'none'
+  }
+
+  if (count === selectedTaskCount.value) {
+    return 'all'
+  }
+
+  return 'some'
+}
+
+const currentState = (tagId: string): TagState => {
+  return desiredStates.value[tagId] || initialState(tagId)
+}
+
+const isModified = (tagId: string) => {
+  return currentState(tagId) !== initialState(tagId)
+}
+
+const searchText = computed(() => searchValue.value.trim())
+const normalizedSearch = computed(() => normalizeName(searchValue.value))
+
+const filteredTags = computed(() => {
+  if (!normalizedSearch.value) {
+    return allTags.value
+  }
+
+  return allTags.value.filter((tag) =>
+    normalizeName(tag.value).includes(normalizedSearch.value),
+  )
+})
+
+const canCreateTag = computed(() => {
+  if (!searchText.value) {
+    return false
+  }
+
+  return !allTags.value.some(
+    (tag) => normalizeName(tag.value) === normalizedSearch.value,
+  )
+})
+
+const createTagName = computed(() => searchText.value)
+
+const summaryItems = computed<SummaryItem[]>(() => {
+  const items: SummaryItem[] = []
+
+  allTags.value.forEach((tag) => {
+    const state = currentState(tag.id)
+    const count = tagUsageMap.value.get(tag.id) || 0
+
+    if (state === 'all') {
+      const addCount = selectedTaskCount.value - count
+      if (addCount > 0) {
+        items.push({ type: 'add', tag, count: addCount })
+      }
+    } else if (state === 'none' && count > 0) {
+      items.push({ type: 'remove', tag, count })
+    }
+  })
+
+  return items
+})
+
+const hasChanges = computed(() => summaryItems.value.length > 0)
+
+const syncDesiredStates = () => {
+  const next: Record<string, TagState> = {}
+
+  allTags.value.forEach((tag) => {
+    next[tag.id] = initialState(tag.id)
+  })
+
+  desiredStates.value = next
+}
+
+const loadTags = async (type?: string) => {
+  loading.value = true
+
+  try {
+    const tagType = getTagType(type)
+    currentTagType.value = tagType
+    const data: any = await fetchMetadataDefinitionTags(tagType)
+    const items = Array.isArray(data) ? data : data?.items || []
+    allTags.value = flattenTags(items)
+    syncDesiredStates()
+  } catch (error) {
+    console.error(error)
+    ElMessage.error(t('public_message_operation_failed'))
+  } finally {
+    loading.value = false
+  }
+}
+
+const setDesiredState = (tagId: string, state: TagState) => {
+  desiredStates.value = {
+    ...desiredStates.value,
+    [tagId]: state,
+  }
+}
+
+const toggleTag = (tag: TagItem) => {
+  const initial = initialState(tag.id)
+  const current = currentState(tag.id)
+
+  if (initial === 'some') {
+    const order: TagState[] = ['some', 'all', 'none']
+    const nextState = order[(order.indexOf(current) + 1) % order.length]
+    setDesiredState(tag.id, nextState)
+    return
+  }
+
+  setDesiredState(tag.id, current === 'all' ? 'none' : 'all')
+}
+
+const getStateLabel = (tag: TagItem) => {
+  const state = currentState(tag.id)
+  const count = tagUsageMap.value.get(tag.id) || 0
+
+  if (state === 'some') {
+    return t('packages_business_batch_tag_dialog_state_some', {
+      count,
+      total: selectedTaskCount.value,
+    })
+  }
+
+  if (state === 'all') {
+    return isModified(tag.id)
+      ? t('packages_business_batch_tag_dialog_state_add_all')
+      : t('packages_business_batch_tag_dialog_state_all')
+  }
+
+  return isModified(tag.id)
+    ? t('packages_business_batch_tag_dialog_state_remove_all')
+    : ''
+}
+
+const exactTag = (value: string) => {
+  const normalized = normalizeName(value)
+  return allTags.value.find((tag) => normalizeName(tag.value) === normalized)
+}
+
+const createTag = async () => {
+  const name = searchText.value
+  if (!name || creating.value) return
+
+  const existed = exactTag(name)
+  if (existed) {
+    setDesiredState(existed.id, 'all')
+    searchValue.value = ''
+    return
+  }
+
+  creating.value = true
+  try {
+    const tagType = currentTagType.value || getTagType()
+    await createMetadataDefinition({
+      item_type: [tagType],
+      value: name,
+    })
+    await loadTags(tagType)
+    const created = exactTag(name)
+    if (created) {
+      setDesiredState(created.id, 'all')
+    }
+    searchValue.value = ''
+    emit('tagCreated')
+    ElMessage.success(t('public_message_operation_success'))
+  } catch (error) {
+    console.error(error)
+    ElMessage.error(t('public_message_save_fail'))
+  } finally {
+    creating.value = false
+  }
+}
+
+const handleSearchKeydown = (event: KeyboardEvent) => {
+  if ((event as any).isComposing || (event as any).keyCode === 229) return
+  if (event.key !== 'Enter') return
+
+  const name = searchText.value
+  if (!name) return
+
+  const existed = exactTag(name)
+  if (existed) {
+    setDesiredState(existed.id, 'all')
+    searchValue.value = ''
+    return
+  }
+
+  createTag()
+}
+
+const resetDialogState = () => {
+  loading.value = false
+  saving.value = false
+  creating.value = false
+  searchValue.value = ''
+  selectedTasks.value = []
+  allTags.value = []
+  desiredStates.value = {}
+  currentTagType.value = ''
+}
+
+const handleClosed = () => {
+  resetDialogState()
+  emit('close')
+}
+
+const closeDialog = () => {
+  visible.value = false
+}
+
+const handleSave = async () => {
+  if (!hasChanges.value || !selectedTasks.value.length) return
+
+  saving.value = true
+  try {
+    await props.submitTags({
+      ids: selectedTasks.value.map((task) => task.id),
+      tags: allTags.value
+        .filter((tag) => isModified(tag.id))
+        .map((tag) => ({
+          id: tag.id,
+          value: tag.value,
+          desired: currentState(tag.id),
+        })),
+    })
+    ElMessage.success(t('public_message_save_ok'))
+    emit('saved')
+    closeDialog()
+  } catch (error) {
+    console.error(error)
+    ElMessage.error(t('public_message_save_fail'))
+  } finally {
+    saving.value = false
+  }
+}
+
+const handleClose = () => {
+  closeDialog()
+}
+
+const open = async (tasks: TaskItem[], type?: string) => {
+  selectedTasks.value = tasks.map((task) => ({
+    ...task,
+    listtags: (task.listtags || []).map((tag) => ({
+      id: tag.id,
+      value: tag.value || tag.name || '',
+    })),
+  }))
+  searchValue.value = ''
+  visible.value = true
+  await loadTags(type)
+}
+
+defineExpose({
+  open,
+  close: handleClose,
+})
+</script>
+
+<template>
+  <el-dialog
+    v-model="visible"
+    class="batch-tag-dialog"
+    width="560px"
+    :show-close="false"
+    :close-on-click-modal="true"
+    :append-to-body="true"
+    :destroy-on-close="true"
+    @closed="handleClosed"
+  >
+    <template #header="{ titleClass }">
+      <div class="batch-tag-dialog__header">
+        <div class="flex justify-content-between">
+          <div :class="titleClass">
+            {{ t('packages_business_batch_tag_dialog_title') }}
+          </div>
+          <el-button text :disabled="loading || saving" @click="handleClose">
+            <template #icon>
+              <el-icon :size="18"><i-lucide-x /></el-icon>
+            </template>
+          </el-button>
+        </div>
+        <div class="batch-tag-dialog__subtitle">
+          {{
+            t('packages_business_batch_tag_dialog_subtitle', {
+              count: selectedTaskCount,
+            })
+          }}
+        </div>
+      </div>
+    </template>
+
+    <div v-loading="loading || saving" class="batch-tag-dialog__body">
+      <el-input
+        v-model="searchValue"
+        class="batch-tag-dialog__search"
+        :placeholder="
+          t('packages_business_batch_tag_dialog_search_placeholder')
+        "
+        clearable
+        @keydown="handleSearchKeydown"
+      >
+        <template #prefix>
+          <el-icon :size="16" class="batch-tag-dialog__search-icon">
+            <i-lucide-search />
+          </el-icon>
+        </template>
+      </el-input>
+
+      <div class="batch-tag-dialog__list">
+        <button
+          v-if="searchText && canCreateTag"
+          type="button"
+          class="batch-tag-dialog__create-row flex align-center"
+          :disabled="creating"
+          @click="createTag"
+        >
+          <span class="batch-tag-dialog__tri batch-tag-dialog__tri--create">
+            <el-icon :size="16"><i-lucide-plus /></el-icon>
+          </span>
+          <span class="batch-tag-dialog__create-text">
+            {{
+              t('packages_business_batch_tag_dialog_create_tag', {
+                name: createTagName,
+              })
+            }}
+          </span>
+        </button>
+
+        <button
+          v-for="tag in filteredTags"
+          :key="tag.id"
+          type="button"
+          class="batch-tag-dialog__row"
+          :class="{ 'is-active': isModified(tag.id) }"
+          @click="toggleTag(tag)"
+        >
+          <span
+            class="batch-tag-dialog__tri"
+            :class="`is-${currentState(tag.id)}`"
+            aria-hidden="true"
+          >
+            <el-icon v-if="currentState(tag.id) === 'all'" :size="16">
+              <i-lucide-check />
+            </el-icon>
+            <el-icon v-else-if="currentState(tag.id) === 'some'" :size="16">
+              <i-lucide-minus />
+            </el-icon>
+          </span>
+
+          <el-icon class="batch-tag-dialog__tag-icon" :size="16">
+            <i-lucide-tag />
+          </el-icon>
+
+          <span class="batch-tag-dialog__name">{{ tag.value }}</span>
+
+          <span
+            class="batch-tag-dialog__state"
+            :class="{ 'is-muted': !getStateLabel(tag) }"
+          >
+            {{ getStateLabel(tag) || ' ' }}
+          </span>
+        </button>
+
+        <div
+          v-if="!loading && !filteredTags.length && !canCreateTag"
+          class="batch-tag-dialog__empty"
+        >
+          {{ t('packages_business_batch_tag_dialog_empty') }}
+        </div>
+      </div>
+
+      <div class="batch-tag-dialog__summary p-3 rounded-xl">
+        <template v-if="summaryItems.length">
+          <div class="batch-tag-dialog__summary-title">
+            {{ t('packages_business_batch_tag_dialog_summary_title') }}
+          </div>
+          <div class="flex flex-column gap-1">
+            <div
+              v-for="item in summaryItems"
+              :key="`${item.type}-${item.tag.id}`"
+              class="batch-tag-dialog__summary-item"
+            >
+              <el-tag
+                size="small"
+                :type="item.type === 'add' ? 'success' : 'danger'"
+                effect="light"
+                round
+                class="batch-tag-dialog__summary-pill"
+              >
+                <el-icon :size="14" class="batch-tag-dialog__summary-pill-icon">
+                  <i-lucide-plus v-if="item.type === 'add'" />
+                  <i-lucide-minus v-else />
+                </el-icon>
+                {{
+                  item.type === 'add'
+                    ? t('packages_business_batch_tag_dialog_add')
+                    : t('packages_business_batch_tag_dialog_remove')
+                }}
+              </el-tag>
+              <span class="batch-tag-dialog__summary-name">{{
+                item.tag.value
+              }}</span>
+              <el-icon :size="14" class="batch-tag-dialog__summary-arrow">
+                <i-lucide-arrow-right />
+              </el-icon>
+              <span class="batch-tag-dialog__summary-count">
+                {{
+                  t('packages_business_batch_tag_dialog_task_count', {
+                    count: item.count,
+                  })
+                }}
+              </span>
+            </div>
+          </div>
+        </template>
+
+        <div v-else class="batch-tag-dialog__summary-empty">
+          {{ t('packages_business_batch_tag_dialog_no_changes') }}
+        </div>
+      </div>
+    </div>
+
+    <template #footer>
+      <el-button @click="handleClose">
+        {{ t('public_button_cancel') }}
+      </el-button>
+      <el-button
+        type="primary"
+        :disabled="!hasChanges"
+        :loading="saving"
+        @click="handleSave"
+      >
+        {{ t('packages_business_batch_tag_dialog_save') }}
+      </el-button>
+    </template>
+  </el-dialog>
+</template>
+
+<style scoped lang="scss">
+.batch-tag-dialog {
+  :deep(.el-dialog__body) {
+    padding-top: 0;
+    padding-bottom: 0;
+  }
+
+  :deep(.el-dialog__header) {
+    margin: 0;
+    padding: 24px 24px 0;
+  }
+
+  :deep(.el-dialog__footer) {
+    padding: 0;
+  }
+}
+
+.batch-tag-dialog__header {
+  width: 100%;
+}
+
+.batch-tag-dialog__subtitle {
+  margin-top: 4px;
+  font-size: 14px;
+  line-height: 22px;
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__close {
+  flex: none;
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__body {
+  display: flex;
+  flex-direction: column;
+  gap: 12px;
+}
+
+.batch-tag-dialog__search-icon {
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__list {
+  max-height: 18rem;
+  overflow: auto;
+  display: flex;
+  flex-direction: column;
+}
+
+.batch-tag-dialog__create-row,
+.batch-tag-dialog__row {
+  display: grid;
+  grid-template-columns: 20px 16px minmax(0, 1fr) auto;
+  align-items: center;
+  gap: 12px;
+  width: 100%;
+  min-height: 40px;
+  padding: 0 12px;
+  border: 0;
+  background: transparent;
+  border-radius: 14px;
+  text-align: left;
+  cursor: pointer;
+  transition:
+    background-color 0.2s ease,
+    color 0.2s ease;
+}
+
+.batch-tag-dialog__create-row:hover,
+.batch-tag-dialog__row:hover {
+  background: color-mix(in srgb, var(--el-fill-color-light) 72%, transparent);
+}
+
+.batch-tag-dialog__create-row:disabled {
+  cursor: default;
+  opacity: 0.75;
+}
+
+.batch-tag-dialog__row.is-active {
+  background: color-mix(in srgb, var(--el-color-primary) 6%, transparent);
+}
+
+.batch-tag-dialog__tri {
+  display: inline-flex;
+  align-items: center;
+  justify-content: center;
+  width: 20px;
+  height: 20px;
+  border-radius: 8px;
+  border: 1px solid var(--el-border-color);
+  background: var(--el-bg-color);
+  color: transparent;
+  transition:
+    background-color 0.2s ease,
+    border-color 0.2s ease,
+    color 0.2s ease;
+}
+
+.batch-tag-dialog__row:hover .batch-tag-dialog__tri {
+  border-color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__tri.is-all {
+  border-color: var(--el-color-primary);
+  background: var(--el-color-primary);
+  color: var(--el-color-white);
+}
+
+.batch-tag-dialog__tri.is-some {
+  border-color: color-mix(
+    in srgb,
+    var(--el-color-primary) 60%,
+    var(--el-border-color)
+  );
+  background: color-mix(
+    in srgb,
+    var(--el-color-primary) 15%,
+    var(--el-bg-color)
+  );
+  color: var(--el-color-primary);
+}
+
+.batch-tag-dialog__tri.is-none {
+  color: transparent;
+}
+
+.batch-tag-dialog__tri--create {
+  border-style: dashed;
+  border-color: color-mix(
+    in srgb,
+    var(--el-color-primary) 55%,
+    var(--el-border-color)
+  );
+  background: color-mix(
+    in srgb,
+    var(--el-color-primary) 6%,
+    var(--el-bg-color)
+  );
+  color: var(--el-color-primary);
+}
+
+.batch-tag-dialog__tag-icon {
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__name {
+  min-width: 0;
+  font-size: 14px;
+  line-height: 24px;
+  color: var(--el-text-color-primary);
+  overflow: hidden;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+}
+
+.batch-tag-dialog__state {
+  justify-self: end;
+  font-size: 12px;
+  line-height: 22px;
+  color: var(--el-text-color-secondary);
+  white-space: nowrap;
+}
+
+.batch-tag-dialog__state.is-muted {
+  color: transparent;
+}
+
+.batch-tag-dialog__create-text {
+  font-size: 14px;
+  line-height: 22px;
+  color: var(--el-color-primary);
+  font-weight: 500;
+}
+
+.batch-tag-dialog__empty {
+  padding: 24px 0 8px;
+  font-size: 14px;
+  line-height: 22px;
+  color: var(--el-text-color-secondary);
+  text-align: center;
+}
+
+.batch-tag-dialog__summary {
+  margin-top: 4px;
+  background: color-mix(in srgb, var(--el-fill-color-lighter) 80%, transparent);
+}
+
+.batch-tag-dialog__summary-title {
+  margin-bottom: 8px;
+  font-size: 12px;
+  line-height: 22px;
+  font-weight: 600;
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__summary-item {
+  display: flex;
+  align-items: center;
+  gap: 10px;
+}
+
+.batch-tag-dialog__summary-pill-icon,
+.batch-tag-dialog__summary-arrow {
+  margin-right: 4px;
+}
+
+.batch-tag-dialog__summary-name,
+.batch-tag-dialog__summary-count {
+  font-size: 12px;
+  line-height: 22px;
+  color: var(--el-text-color-primary);
+}
+
+.batch-tag-dialog__summary-count {
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__summary-empty {
+  font-size: 12px;
+  line-height: 22px;
+  color: var(--el-text-color-secondary);
+}
+
+.batch-tag-dialog__footer {
+  display: flex;
+  justify-content: flex-end;
+  gap: 12px;
+  padding: 20px 24px 24px;
+}
+</style>
diff --git a/packages/business/src/components/TablePage.vue b/packages/business/src/components/TablePage.vue
index 43cfe8948..b7ff3d95c 100644
--- a/packages/business/src/components/TablePage.vue
+++ b/packages/business/src/components/TablePage.vue
@@ -399,6 +399,10 @@ export default defineComponent({
       classifyRef.value?.show(tagList)
     }
 
+    const refreshClassifyTags = () => {
+      classification.value?.getData?.()
+    }
+
     const getData = () => {
       return list.value
     }
@@ -695,6 +699,7 @@ export default defineComponent({
       nodeChecked,
       handleSelectionChange,
       showClassify,
+      refreshClassifyTags,
       getData,
       clearSelection,
       toggleRowSelection,
diff --git a/packages/business/src/views/connections/List.vue b/packages/business/src/views/connections/List.vue
index 418984733..c3d39bc7b 100644
--- a/packages/business/src/views/connections/List.vue
+++ b/packages/business/src/views/connections/List.vue
@@ -36,6 +36,7 @@ import PermissionseSettingsCreate from '../../components/permissionse-settings/C
 import SchemaProgress from '../../components/SchemaProgress.vue'
 import TablePage from '../../components/TablePage.vue'
 import UploadDialog from '../../components/UploadDialog.vue'
+import BatchTagDialog from '../../components/BatchTagDialog.vue'
 import { useHas } from '../../composables'
 import { CONNECTION_STATUS_MAP, CONNECTION_TYPE_MAP } from '../../shared'
 import Preview from './Preview.vue'
@@ -88,6 +89,7 @@ const previewRef = ref()
 const test = ref()
 const dialog = ref()
 const permissionseSettingsCreate = ref()
+const batchTagDialog = ref<InstanceType<typeof BatchTagDialog> | null>(null)
 
 // State
 let timeout: NodeJS.Timeout | null = null
@@ -434,22 +436,6 @@ const remove = async (row: any) => {
   }
 }
 
-const handleSelectTag = () => {
-  const tagList = []
-  const tagMap: Record<string, boolean> = {}
-
-  multipleSelection.value.forEach((row: any) => {
-    row.listtags?.forEach((item: any) => {
-      if (!tagMap[item.id]) {
-        tagList.push(item)
-        tagMap[item.id] = true
-      }
-    })
-  })
-
-  return tagList
-}
-
 const handleOperationClassify = async (listtags: any[]) => {
   const attributes = {
     id: multipleSelection.value.map((r: any) => r.id),
@@ -464,6 +450,20 @@ const handleOperationClassify = async (listtags: any[]) => {
   }
 }
 
+const openBatchTagDialog = () => {
+  if (!multipleSelection.value.length) return
+  batchTagDialog.value?.open(multipleSelection.value as any)
+}
+
+const handleBatchTagSaved = () => {
+  table.value?.clearSelection?.()
+  table.value?.fetch()
+}
+
+const handleBatchTagCreated = () => {
+  table.value?.refreshClassifyTags?.()
+}
+
 const handleDialogDatabaseTypeVisible = () => {
   dialogDatabaseTypeVisible.value = false
 }
@@ -795,7 +795,7 @@ onUnmounted(() => {
         <ElButton
           v-readonlybtn="'datasource_category_application'"
           class="btn"
-          @click="$refs.table.showClassify(handleSelectTag())"
+          @click="openBatchTagDialog"
         >
           <span> {{ $t('public_button_bulk_tag') }}</span>
         </ElButton>
@@ -1006,6 +1006,13 @@ onUnmounted(() => {
         </template>
       </ElTableColumn>
     </TablePage>
+    <BatchTagDialog
+      ref="batchTagDialog"
+      view-page="database"
+      :submit-tags="batchUpdateConnectionTags"
+      @saved="handleBatchTagSaved"
+      @tag-created="handleBatchTagCreated"
+    />
     <Preview
       ref="previewRef"
       @test="testConnection"
diff --git a/packages/business/src/views/task/List.vue b/packages/business/src/views/task/List.vue
index b54108beb..0078ebd5c 100644
--- a/packages/business/src/views/task/List.vue
+++ b/packages/business/src/views/task/List.vue
@@ -6,7 +6,6 @@ import {
   batchRenewTasks,
   batchStartTasks,
   batchStopTasks,
-  batchUpdateTaskListtags,
   copyTask,
   exportTasks,
   fetchTasks,
@@ -24,6 +23,7 @@ import dayjs from 'dayjs'
 import { escapeRegExp, isNumber, uniqBy } from 'lodash-es'
 import { h } from 'vue'
 
+import BatchTagDialog from '../../components/BatchTagDialog.vue'
 import { DatabaseIcon } from '../../components/DatabaseIcon'
 import { showErrorMessage } from '../../components/error-message'
 import PermissionseSettingsCreate from '../../components/permissionse-settings/Create'
@@ -50,6 +50,7 @@ export default {
     TablePage,
     SkipError,
     Upload,
+    BatchTagDialog,
     TaskStatus,
     PermissionseSettingsCreate,
     UpgradeCharges,
@@ -82,7 +83,6 @@ export default {
       STATUS_MAP,
       isDaas: import.meta.env.VUE_APP_PLATFORM === 'DAAS',
       showInstanceInfo: import.meta.env.VUE_APP_LICENSE_TYPE === 'PIPELINE',
-      dataFlowId: '',
       isShowDetails: false,
       previewLoading: false,
       previewData: null,
@@ -234,8 +234,7 @@ export default {
     getData({ page, tags, isSelectedNoTag }) {
       const { current, size } = page
       const { syncType } = this
-      const { keyword, status, type, agentId, syncStatus, id } =
-        this.searchParams
+      const { keyword, status, type, agentId, syncStatus } = this.searchParams
       const fields = {
         id: true,
         name: true,
@@ -591,37 +590,18 @@ export default {
       this.changeStatus([id], { status: 'scheduled', errorEvents })
     },
 
-    handleOperationClassify(listtags) {
-      let ids = []
-      if (this.dataFlowId) {
-        ids = [this.dataFlowId]
-      } else {
-        ids = this.multipleSelection.map((r) => r.id)
-      }
-      const attributes = {
-        id: ids,
-        listtags,
-      }
-      batchUpdateTaskListtags(attributes).then(() => {
-        this.dataFlowId = ''
-        this.table.fetch()
-      })
+    openBatchTagDialog() {
+      if (!this.multipleSelection.length) return
+      this.$refs.batchTagDialog?.open(this.multipleSelection)
     },
 
-    handleSelectTag() {
-      const tagList = []
-      const tagMap = {}
-
-      this.multipleSelection.forEach((row) => {
-        row.listtags?.forEach((item) => {
-          if (!tagMap[item.id]) {
-            tagList.push(item)
-            tagMap[item.id] = true
-          }
-        })
-      })
+    handleBatchTagSaved() {
+      this.table.clearSelection()
+      this.table.fetch()
+    },
 
-      return tagList
+    handleBatchTagCreated() {
+      this.table.refreshClassifyTags()
     },
 
     create() {
@@ -1036,7 +1016,7 @@ export default {
               }),
             )}`,
           )
-          .then(async (data) => {
+          .then((data) => {
             const { items = [] } = data
 
             if (items.some((t) => t.status === 'Stopped')) {
@@ -1067,8 +1047,8 @@ export default {
       })
     },
 
-    handlePipelineSelectVisible(val) {
-      if (val) {
+    handlePipelineSelectVisible() {
+      if (this.pipelineSelected) {
         this.loadPipelineOptions()
       }
     },
@@ -1106,7 +1086,6 @@ export default {
           multipleSelection = val
         }
       "
-      @classify-submit="handleOperationClassify"
       @sort-change="handleSortTable"
     >
       <template #search>
@@ -1188,7 +1167,7 @@ export default {
         </ElButton>
         <ElButton
           v-readonlybtn="'SYNC_category_application'"
-          @click="$refs.table.showClassify(handleSelectTag())"
+          @click="openBatchTagDialog"
         >
           <span> {{ $t('public_button_bulk_tag') }}</span>
         </ElButton>
@@ -1489,6 +1468,12 @@ export default {
         </template>
       </el-table-column>
     </TablePage>
+    <BatchTagDialog
+      ref="batchTagDialog"
+      view-page="dataflow"
+      @saved="handleBatchTagSaved"
+      @tag-created="handleBatchTagCreated"
+    />
     <SkipError ref="skipError" @skip="handleSkipAndRun" />
     <!-- 导入 -->
     <Upload ref="upload" :type="uploadType" @success="table.fetch()" />
diff --git a/packages/business/src/views/verification/List.vue b/packages/business/src/views/verification/List.vue
index e70bcb451..05252de02 100644
--- a/packages/business/src/views/verification/List.vue
+++ b/packages/business/src/views/verification/List.vue
@@ -26,6 +26,7 @@ import { escapeRegExp } from 'lodash-es'
 import { computed, onBeforeMount, onUnmounted, ref, watch } from 'vue'
 import { useRoute, useRouter } from 'vue-router'
 import { ErrorMessage } from '../../components/error-message'
+import BatchTagDialog from '../../components/BatchTagDialog.vue'
 import PageContainer from '../../components/PageContainer.vue'
 import PermissionseSettingsCreate from '../../components/permissionse-settings/Create.vue'
 import TablePage from '../../components/TablePage.vue'
@@ -70,6 +71,11 @@ interface InspectItem {
   lastStartTime: string
   sourceTotal: string | number
   targetTotal: string | number
+  listtags?: Array<{
+    id: string
+    value: string
+    name?: string
+  }>
   InspectResult?: InspectResult
   errorMsg?: string
   difference_number?: number
@@ -142,6 +148,7 @@ const taskOptionsLoading = ref(false)
 
 // Computed
 const tableRef = computed(() => table.value)
+const batchTagDialog = ref<InstanceType<typeof BatchTagDialog> | null>(null)
 
 // Methods
 const inspectMethodChange = (val: string) => {
@@ -474,22 +481,6 @@ const onImportDialogClosed = () => {
   importForm.value.type = 'task'
 }
 
-const handleSelectTag = () => {
-  const tagList = []
-  const tagMap = {}
-
-  multipleSelection.value.forEach((row) => {
-    row.listtags?.forEach((item) => {
-      if (!tagMap[item.id]) {
-        tagList.push(item)
-        tagMap[item.id] = true
-      }
-    })
-  })
-
-  return tagList
-}
-
 const handleOperationClassify = async (listtags) => {
   if (!listtags.length || !multipleSelection.value.length) {
     return
@@ -508,6 +499,20 @@ const handleOperationClassify = async (listtags) => {
     console.error(error)
   }
 }
+
+const openBatchTagDialog = () => {
+  if (!multipleSelection.value.length) return
+  batchTagDialog.value?.open(multipleSelection.value as any)
+}
+
+const handleBatchTagSaved = () => {
+  table.value?.clearSelection?.()
+  table.value?.fetch()
+}
+
+const handleBatchTagCreated = () => {
+  table.value?.refreshClassifyTags?.()
+}
 // Watchers
 watch(
   () => route.query,
@@ -684,7 +689,7 @@ onUnmounted(() => {
         <ElButton @click="handlePermissionsSettings">{{
           $t('packages_business_permissionse_settings_create_quanxianshezhi')
         }}</ElButton>
-        <ElButton @click="$refs.table.showClassify(handleSelectTag())">
+        <ElButton @click="openBatchTagDialog">
           <span> {{ $t('public_button_bulk_tag') }}</span>
         </ElButton>
         <ElButton @click="handleExport">
@@ -976,6 +981,13 @@ onUnmounted(() => {
         </template>
       </el-table-column>
     </TablePage>
+    <BatchTagDialog
+      ref="batchTagDialog"
+      view-page="inspect"
+      :submit-tags="batchUpdateListtags"
+      @saved="handleBatchTagSaved"
+      @tag-created="handleBatchTagCreated"
+    />
     <PermissionseSettingsCreate ref="permissionseSettingsCreate" />
   </PageContainer>
 </template>
diff --git a/packages/i18n/src/locale/lang/en.js b/packages/i18n/src/locale/lang/en.js
index 6ceace288..e819b2ab6 100644
--- a/packages/i18n/src/locale/lang/en.js
+++ b/packages/i18n/src/locale/lang/en.js
@@ -625,6 +625,25 @@ export default {
   public_tag_priority: 'Priority Setting',
   public_tag_priority_desc:
     'Select label priority. Smaller numbers mean higher priority. Batch tasks run in priority order.',
+  packages_business_batch_tag_dialog_title: 'Batch Set Tags',
+  packages_business_batch_tag_dialog_subtitle:
+    '{count} tasks selected · Checked means add, unchecked means remove',
+  packages_business_batch_tag_dialog_search_placeholder:
+    'Search tags, or press Enter to create a name',
+  packages_business_batch_tag_dialog_create_tag: 'Create tag "{name}"',
+  packages_business_batch_tag_dialog_empty: 'No matching tags',
+  packages_business_batch_tag_dialog_state_some:
+    'Some tasks have it ({count}/{total})',
+  packages_business_batch_tag_dialog_state_add_all: 'Will add to all',
+  packages_business_batch_tag_dialog_state_all: 'All tasks have it',
+  packages_business_batch_tag_dialog_state_remove_all: 'Will remove from all',
+  packages_business_batch_tag_dialog_summary_title: 'Changes',
+  packages_business_batch_tag_dialog_add: 'Add',
+  packages_business_batch_tag_dialog_remove: 'Remove',
+  packages_business_batch_tag_dialog_task_count: '{count} tasks',
+  packages_business_batch_tag_dialog_no_changes:
+    'No changes · Partially selected tags will keep each task as-is',
+  packages_business_batch_tag_dialog_save: 'Save Changes',
   public_priority_highest: 'Highest',
   public_priority_high: 'High',
   public_priority_medium_high: 'Medium High',
diff --git a/packages/i18n/src/locale/lang/zh-CN.js b/packages/i18n/src/locale/lang/zh-CN.js
index 6e09a3099..fca8798c4 100644
--- a/packages/i18n/src/locale/lang/zh-CN.js
+++ b/packages/i18n/src/locale/lang/zh-CN.js
@@ -618,6 +618,25 @@ export default {
   public_tag_priority: '优先级设置',
   public_tag_priority_desc:
     '选择标签优先级，数字越小优先级越高，批量启动时会按优先级顺序执行',
+  packages_business_batch_tag_dialog_title: '批量设置标签',
+  packages_business_batch_tag_dialog_subtitle:
+    '已选择 {count} 个任务 · 勾选表示添加，取消勾选表示移除',
+  packages_business_batch_tag_dialog_search_placeholder:
+    '搜索标签，或输入名称回车新建',
+  packages_business_batch_tag_dialog_create_tag: '新建标签 “{name}”',
+  packages_business_batch_tag_dialog_empty: '没有匹配的标签',
+  packages_business_batch_tag_dialog_state_some:
+    '部分任务拥有（{count}/{total}）',
+  packages_business_batch_tag_dialog_state_add_all: '将添加到全部',
+  packages_business_batch_tag_dialog_state_all: '全部拥有',
+  packages_business_batch_tag_dialog_state_remove_all: '将从全部移除',
+  packages_business_batch_tag_dialog_summary_title: '本次改动',
+  packages_business_batch_tag_dialog_add: '添加',
+  packages_business_batch_tag_dialog_remove: '移除',
+  packages_business_batch_tag_dialog_task_count: '{count} 个任务',
+  packages_business_batch_tag_dialog_no_changes:
+    '尚无改动 · 半选标签将保持各任务原样',
+  packages_business_batch_tag_dialog_save: '保存改动',
   public_priority_highest: '最高',
   public_priority_high: '高',
   public_priority_medium_high: '中高',
diff --git a/packages/i18n/src/locale/lang/zh-TW.js b/packages/i18n/src/locale/lang/zh-TW.js
index 7f37e635a..9ff3286f2 100644
--- a/packages/i18n/src/locale/lang/zh-TW.js
+++ b/packages/i18n/src/locale/lang/zh-TW.js
@@ -615,6 +615,25 @@ export default {
   public_tag_priority: '優先級設置',
   public_tag_priority_desc:
     '選擇標籤優先級，數字越小優先級越高，批量啟動時會按優先級順序執行',
+  packages_business_batch_tag_dialog_title: '批量設置標籤',
+  packages_business_batch_tag_dialog_subtitle:
+    '已選擇 {count} 個任務 · 勾選表示添加，取消勾選表示移除',
+  packages_business_batch_tag_dialog_search_placeholder:
+    '搜索標籤，或輸入名稱回車新建',
+  packages_business_batch_tag_dialog_create_tag: '新建標籤 “{name}”',
+  packages_business_batch_tag_dialog_empty: '沒有匹配的標籤',
+  packages_business_batch_tag_dialog_state_some:
+    '部分任務擁有（{count}/{total}）',
+  packages_business_batch_tag_dialog_state_add_all: '將添加到全部',
+  packages_business_batch_tag_dialog_state_all: '全部擁有',
+  packages_business_batch_tag_dialog_state_remove_all: '將從全部移除',
+  packages_business_batch_tag_dialog_summary_title: '本次改動',
+  packages_business_batch_tag_dialog_add: '添加',
+  packages_business_batch_tag_dialog_remove: '移除',
+  packages_business_batch_tag_dialog_task_count: '{count} 個任務',
+  packages_business_batch_tag_dialog_no_changes:
+    '尚無改動 · 半選標籤將保持各任務原樣',
+  packages_business_batch_tag_dialog_save: '保存改動',
   public_priority_highest: '最高',
   public_priority_high: '高',
   public_priority_medium_high: '中高',