feat: Remote->Many 支持多源文件传输

支持多选源文件并按源文件×目标连接生成任务队列；增加 Directory/Exact Path 目标模式与重名覆盖提示，同时修复传输/上传 SSE 订阅未及时关闭导致的连接堆积。

frontend/src/components/SftpFilePickerModal.vue

@@ -3,16 +3,19 @@ import { computed, onBeforeUnmount, onMounted, ref, watch } from 'vue'
 
 import * as sftpApi from '../api/sftp'
 import type { SftpFileInfo } from '../api/sftp'
-import { X, FolderOpen, File, ChevronRight, RefreshCw, Eye, EyeOff } from 'lucide-vue-next'
+import { X, FolderOpen, File, ChevronRight, RefreshCw, Eye, EyeOff, Check } from 'lucide-vue-next'
 
-const props = defineProps<{ open: boolean; connectionId: number | null }>()
+const props = withDefaults(defineProps<{ open: boolean; connectionId: number | null; multiple?: boolean }>(), {
+  multiple: false
+})
 const emit = defineEmits<{
   (e: 'close'): void
   (e: 'select', path: string): void
+  (e: 'select-many', paths: string[]): void
 }>()
 
-const currentPath = ref('.')
+const currentPath = ref('/')
-const pathParts = ref<string[]>([])
+const pathParts = computed(() => (currentPath.value === '/' ? [] : currentPath.value.split('/').filter(Boolean)))
 const files = ref<SftpFileInfo[]>([])
 const loading = ref(false)
 const error = ref('')
@@ -20,34 +23,62 @@ const error = ref('')
 const showHiddenFiles = ref(false)
 const searchQuery = ref('')
 let searchDebounceTimer = 0
+let suppressNextSearchDebounce = false
 const filteredFiles = ref<SftpFileInfo[]>([])
 
+const selectedPaths = ref<string[]>([])
+const selectedPathSet = computed(() => new Set(selectedPaths.value))
+const selectedCount = computed(() => selectedPaths.value.length)
+
 const canInteract = computed(() => props.open && props.connectionId != null)
 
 function applyFileFilters() {
   const q = searchQuery.value.trim().toLowerCase()
-  const base = showHiddenFiles.value ? files.value : files.value.filter((f) => !f.name.startsWith('.'))
+  const sanitized = files.value.filter((f) => f.name !== '.' && f.name !== '..')
+  const base = showHiddenFiles.value ? sanitized : sanitized.filter((f) => !f.name.startsWith('.'))
   filteredFiles.value = q ? base.filter((f) => f.name.toLowerCase().includes(q)) : base
 }
 
-watch([searchQuery, showHiddenFiles, files], () => {
+watch(searchQuery, () => {
+  if (suppressNextSearchDebounce) {
+    suppressNextSearchDebounce = false
+    clearTimeout(searchDebounceTimer)
+    searchDebounceTimer = 0
+    return
+  }
   clearTimeout(searchDebounceTimer)
   searchDebounceTimer = window.setTimeout(() => {
     applyFileFilters()
   }, 300)
+})
+
+watch([files, showHiddenFiles], () => {
+  applyFileFilters()
 }, { immediate: true })
 
+function normalizeServerPath(input: string) {
+  const raw = (input || '').trim()
+  if (!raw || raw === '.') return '/'
+  if (raw === '/') return '/'
+  const abs = raw.startsWith('/') ? raw : '/' + raw
+  return abs.replace(/\/+$/, '') || '/'
+}
+
+function joinAbsolutePath(base: string, name: string) {
+  const safeBase = !base || base === '.' ? '/' : base
+  const baseClean = safeBase === '/' ? '' : safeBase.replace(/\/+$/, '')
+  const nameClean = (name || '').replace(/^\/+/, '')
+  return (baseClean ? baseClean + '/' : '/') + nameClean
+}
+
 async function initPath() {
   if (!canInteract.value || props.connectionId == null) return
   error.value = ''
   try {
     const res = await sftpApi.getPwd(props.connectionId)
-    const p = res.data.path || '/'
+    currentPath.value = normalizeServerPath(res.data.path || '/')
-    currentPath.value = p === '/' ? '/' : p
-    pathParts.value = p === '/' ? [''] : p.split('/').filter(Boolean)
   } catch (e: unknown) {
-    currentPath.value = '.'
+    currentPath.value = '/'
-    pathParts.value = []
   }
 }
 
@@ -55,10 +86,15 @@ async function load() {
   if (!canInteract.value || props.connectionId == null) return
   loading.value = true
   error.value = ''
+  clearTimeout(searchDebounceTimer)
+  searchDebounceTimer = 0
+  suppressNextSearchDebounce = true
   searchQuery.value = ''
+  applyFileFilters()
   try {
     const res = await sftpApi.listFiles(props.connectionId, currentPath.value)
     files.value = res.data
+      .filter((f) => f.name !== '.' && f.name !== '..')
       .slice()
       .sort((a, b) => {
         if (a.directory !== b.directory) return a.directory ? -1 : 1
@@ -74,26 +110,49 @@ async function load() {
 
 function navigateToDir(name: string) {
   if (loading.value) return
-  const base = currentPath.value === '.' || currentPath.value === '' ? '' : currentPath.value
+  currentPath.value = joinAbsolutePath(currentPath.value, name)
-  currentPath.value = base ? (base.endsWith('/') ? base + name : base + '/' + name) : name
-  pathParts.value = currentPath.value === '/' ? [''] : currentPath.value.split('/').filter(Boolean)
   load()
 }
 
 function navigateToIndex(i: number) {
   if (loading.value) return
   if (i < 0) {
-    currentPath.value = '.'
+    currentPath.value = '/'
   } else {
-    currentPath.value = pathParts.value.length ? '/' + pathParts.value.slice(0, i + 1).join('/') : '/'
+    const next = pathParts.value.slice(0, i + 1).join('/')
+    currentPath.value = next ? '/' + next : '/'
   }
-  pathParts.value = currentPath.value === '/' ? [''] : currentPath.value.split('/').filter(Boolean)
   load()
 }
 
 function filePath(file: SftpFileInfo) {
-  const base = currentPath.value === '.' || !currentPath.value ? '' : currentPath.value
+  return joinAbsolutePath(currentPath.value, file.name)
-  return base ? base.replace(/\/$/, '') + '/' + file.name : file.name
+}
+
+function isSelected(path: string) {
+  return selectedPathSet.value.has(path)
+}
+
+function toggleSelected(path: string) {
+  if (isSelected(path)) {
+    selectedPaths.value = selectedPaths.value.filter((p) => p !== path)
+    return
+  }
+  selectedPaths.value = [...selectedPaths.value, path]
+}
+
+function removeSelected(path: string) {
+  if (!isSelected(path)) return
+  selectedPaths.value = selectedPaths.value.filter((p) => p !== path)
+}
+
+function clearSelected() {
+  selectedPaths.value = []
+}
+
+function displayPathName(path: string) {
+  const parts = path.split('/').filter(Boolean)
+  return parts[parts.length - 1] || path
 }
 
 function handleClick(file: SftpFileInfo) {
@@ -101,7 +160,30 @@ function handleClick(file: SftpFileInfo) {
     navigateToDir(file.name)
     return
   }
-  emit('select', filePath(file))
+
+  const path = filePath(file)
+  if (props.multiple) {
+    toggleSelected(path)
+    return
+  }
+
+  emit('select', path)
+  emit('close')
+}
+
+function handleRowKeyDown(e: KeyboardEvent, file: SftpFileInfo) {
+  const isEnter = e.key === 'Enter'
+  const isSpace = e.key === ' ' || e.code === 'Space'
+  if (!isEnter && !isSpace) return
+  e.preventDefault()
+  if (isSpace && e.repeat) return
+  handleClick(file)
+}
+
+function confirmMany() {
+  if (!props.multiple) return
+  if (selectedPaths.value.length === 0) return
+  emit('select-many', selectedPaths.value)
   emit('close')
 }
 
@@ -109,6 +191,7 @@ watch(
   () => [props.open, props.connectionId] as const,
   async ([open]) => {
     if (!open) return
+    selectedPaths.value = []
     await initPath()
     await load()
   }
@@ -133,7 +216,8 @@ onBeforeUnmount(() => {
         <div class="flex items-center justify-between px-4 py-3 border-b border-slate-700">
           <div class="min-w-0">
             <h3 class="text-slate-100 font-semibold truncate">选择源文件</h3>
-            <p class="text-xs text-slate-400 truncate">双击文件不需要，单击即选择</p>
+            <p v-if="!props.multiple" class="text-xs text-slate-400 truncate">双击文件不需要，单击即选择</p>
+            <p v-else class="text-xs text-slate-400 truncate">单击文件切换选择；目录仅用于导航</p>
           </div>
           <div class="flex items-center gap-2">
             <button
@@ -141,6 +225,7 @@ onBeforeUnmount(() => {
               :disabled="loading || !canInteract"
               class="min-h-[44px] px-3 rounded-lg border border-slate-700 bg-slate-800/60 text-slate-200 hover:bg-slate-800 disabled:opacity-50 cursor-pointer transition-colors"
               aria-label="刷新"
+              type="button"
             >
               <span class="inline-flex items-center gap-2">
                 <RefreshCw class="w-4 h-4" :class="{ 'animate-spin': loading }" aria-hidden="true" />
@@ -151,6 +236,7 @@ onBeforeUnmount(() => {
               @click="emit('close')"
               class="min-h-[44px] w-11 grid place-items-center rounded-lg border border-slate-700 bg-slate-800/60 text-slate-200 hover:bg-slate-800 cursor-pointer transition-colors"
               aria-label="关闭"
+              type="button"
             >
               <X class="w-5 h-5" aria-hidden="true" />
             </button>
@@ -162,6 +248,7 @@ onBeforeUnmount(() => {
             <button
               @click="navigateToIndex(-1)"
               class="px-2 py-1 rounded hover:bg-slate-800 hover:text-slate-100 transition-colors cursor-pointer truncate"
+              type="button"
             >
               /
             </button>
@@ -170,6 +257,7 @@ onBeforeUnmount(() => {
               <button
                 @click="navigateToIndex(i)"
                 class="px-2 py-1 rounded hover:bg-slate-800 hover:text-slate-100 transition-colors cursor-pointer truncate max-w-[140px]"
+                type="button"
               >
                 {{ part || '/' }}
               </button>
@@ -179,6 +267,8 @@ onBeforeUnmount(() => {
             <input
               v-model="searchQuery"
               type="text"
+              name="sftp-file-search"
+              autocomplete="off"
               class="flex-1 rounded-lg border border-slate-600 bg-slate-900/30 px-3 py-2 text-sm text-slate-100 placeholder-slate-500 focus:border-cyan-500 focus:outline-none focus:ring-1 focus:ring-cyan-500"
               placeholder="搜索文件..."
               aria-label="搜索文件"
@@ -188,21 +278,71 @@ onBeforeUnmount(() => {
               class="min-h-[44px] p-2 rounded-lg text-slate-400 hover:bg-slate-700 hover:text-slate-100 transition-colors cursor-pointer"
               :aria-label="showHiddenFiles ? '隐藏隐藏文件' : '显示隐藏文件'"
               :title="showHiddenFiles ? '隐藏隐藏文件' : '显示隐藏文件'"
+              type="button"
             >
               <component :is="showHiddenFiles ? EyeOff : Eye" class="w-4 h-4" aria-hidden="true" />
             </button>
           </div>
           <p v-if="error" class="mt-2 text-sm text-red-400">{{ error }}</p>
+
+          <div v-if="props.multiple" class="mt-3 rounded-xl border border-slate-700 bg-slate-900/30 px-3 py-2">
+            <div class="flex items-center justify-between gap-3">
+              <div class="text-sm text-slate-200">Selected ({{ selectedCount }})</div>
+              <button
+                v-if="selectedCount > 0"
+                @click="clearSelected"
+                class="text-xs text-slate-400 hover:text-slate-100 transition-colors cursor-pointer"
+                type="button"
+              >
+                清空
+              </button>
+            </div>
+            <div v-if="selectedCount === 0" class="mt-1 text-xs text-slate-500">未选择任何文件</div>
+            <div v-else class="mt-2 flex flex-wrap gap-2">
+              <span
+                v-for="path in selectedPaths"
+                :key="path"
+                class="inline-flex items-center gap-1 rounded-lg border border-slate-700 bg-slate-800/40 px-2 py-1 text-xs text-slate-200"
+                :title="path"
+              >
+                <span class="max-w-[220px] truncate">{{ displayPathName(path) }}</span>
+                <button
+                  class="w-6 h-6 grid place-items-center rounded hover:bg-slate-700/60 text-slate-300 hover:text-slate-100 transition-colors cursor-pointer"
+                  type="button"
+                  :aria-label="'移除 ' + displayPathName(path)"
+                  @click="removeSelected(path)"
+                >
+                  <X class="w-3.5 h-3.5" aria-hidden="true" />
+                </button>
+              </span>
+            </div>
+          </div>
         </div>
 
         <div class="max-h-[60vh] overflow-auto divide-y divide-slate-800">
-          <button
+          <div
             v-for="file in filteredFiles"
             :key="file.name"
             @click="handleClick(file)"
-            class="w-full flex items-center gap-3 px-4 py-3 text-left hover:bg-slate-800/40 transition-colors cursor-pointer min-h-[44px]"
+            @keydown="handleRowKeyDown($event, file)"
-            :aria-label="file.directory ? '打开目录' : '选择文件'"
+            class="w-full flex items-center gap-3 px-4 py-3 text-left hover:bg-slate-800/40 transition-colors cursor-pointer min-h-[44px] focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-cyan-500/80"
+            :role="props.multiple && !file.directory ? 'checkbox' : 'button'"
+            :tabindex="0"
+            :aria-checked="props.multiple && !file.directory ? isSelected(filePath(file)) : undefined"
+            :aria-label="file.directory
+              ? '打开目录 ' + file.name
+              : (props.multiple
+                ? ((isSelected(filePath(file)) ? '取消选择文件 ' : '选择文件 ') + file.name)
+                : ('选择文件 ' + file.name))"
           >
+            <span v-if="props.multiple && !file.directory" class="flex-shrink-0" aria-hidden="true">
+              <span
+                class="h-4 w-4 rounded border grid place-items-center transition-colors"
+                :class="isSelected(filePath(file)) ? 'border-cyan-400 bg-cyan-500' : 'border-slate-500 bg-slate-900/40'"
+              >
+                <Check v-if="isSelected(filePath(file))" class="w-3 h-3 text-slate-950" aria-hidden="true" />
+              </span>
+            </span>
             <component
               :is="file.directory ? FolderOpen : File"
               class="w-5 h-5 flex-shrink-0"
@@ -211,12 +351,30 @@ onBeforeUnmount(() => {
             />
             <span class="flex-1 min-w-0 truncate text-slate-100">{{ file.name }}</span>
             <span v-if="!file.directory" class="text-xs text-slate-500">{{ Math.round(file.size / 1024) }} KB</span>
-          </button>
+          </div>
 
           <div v-if="filteredFiles.length === 0 && !loading" class="px-4 py-10 text-center text-slate-500">
             {{ files.length === 0 ? '空目录' : (searchQuery.trim() ? '未找到匹配文件' : '无可见文件（已隐藏文件）') }}
           </div>
         </div>
+
+        <div v-if="props.multiple" class="flex items-center justify-end gap-2 px-4 py-3 border-t border-slate-700 bg-slate-900/40">
+          <button
+            @click="emit('close')"
+            class="min-h-[44px] px-4 rounded-lg border border-slate-700 bg-slate-800/60 text-slate-200 hover:bg-slate-800 transition-colors cursor-pointer"
+            type="button"
+          >
+            Cancel
+          </button>
+          <button
+            @click="confirmMany"
+            :disabled="selectedCount === 0"
+            class="min-h-[44px] px-4 rounded-lg bg-cyan-600/90 text-slate-950 hover:bg-cyan-500 disabled:opacity-50 transition-colors cursor-pointer"
+            type="button"
+          >
+            Confirm ({{ selectedCount }})
+          </button>
+        </div>
       </div>
     </div>
   </Teleport>

frontend/src/stores/transfers.ts

@@ -73,9 +73,27 @@ async function runWithConcurrency<T>(
   await Promise.allSettled(workers)
 }
 
-async function waitForRemoteTransfer(taskId: string, onProgress: (progress: number) => void, unsubscribers: (() => void)[]) {
+async function waitForRemoteTransfer(
+  taskId: string,
+  onProgress: (progress: number) => void,
+  unsubscribers: (() => void)[]
+) {
   return new Promise<void>((resolve, reject) => {
     console.log('[waitForRemoteTransfer] Subscribing to task:', taskId)
+    let done = false
+
+    const finish = (err?: Error) => {
+      if (done) return
+      done = true
+      try {
+        unsubscribe()
+      } catch {
+        // ignore
+      }
+      if (err) reject(err)
+      else resolve()
+    }
+
     const unsubscribe = subscribeRemoteTransferProgress(taskId, (task) => {
       const progress = Math.max(0, Math.min(100, task.progress || 0))
       console.log('[waitForRemoteTransfer] Progress from SSE:', progress, 'status:', task.status)
@@ -83,25 +101,51 @@ async function waitForRemoteTransfer(taskId: string, onProgress: (progress: numb
 
       if (task.status === 'success') {
         console.log('[waitForRemoteTransfer] Task succeeded:', taskId)
-        resolve()
+        finish()
       } else if (task.status === 'error') {
         console.error('[waitForRemoteTransfer] Task errored:', taskId, task.error)
-        reject(new Error(task.error || 'Transfer failed'))
+        finish(new Error(task.error || 'Transfer failed'))
       } else if (task.status === 'cancelled') {
         console.log('[waitForRemoteTransfer] Task cancelled:', taskId)
-        reject(new Error('Cancelled'))
+        finish(new Error('Cancelled'))
       }
     })
 
-    unsubscribers.push(unsubscribe)
+    // cancelRun/clearRuns will call this; it must close SSE and release the waiter.
+    unsubscribers.push(() => {
+      finish(new Error('Cancelled'))
+    })
   })
 }
 
-function buildRemoteTransferPath(targetDir: string, filename: string) {
+function basename(p: string) {
-  let targetPath = targetDir.trim()
+  return p.split('/').filter(Boolean).pop() || p
-  if (!targetPath) targetPath = '/'
+}
-  if (!targetPath.endsWith('/')) targetPath = targetPath + '/'
+
-  return targetPath + filename
+function normalizeDir(p: string) {
+  let dir = p.trim()
+  if (!dir) dir = '/'
+  if (!dir.endsWith('/')) dir = dir + '/'
+  return dir
+}
+
+function resolveRemoteTargetPath(params: {
+  targetMode: 'dir' | 'path'
+  targetDirOrPath: string
+  sourcePath: string
+  sourceCount: number
+}) {
+  if (params.targetMode === 'path') {
+    if (params.sourceCount !== 1) {
+      throw new Error('Exact Path mode requires a single source file')
+    }
+    const t = params.targetDirOrPath.trim()
+    if (!t) throw new Error('target path is required')
+    return t
+  }
+
+  const dir = normalizeDir(params.targetDirOrPath)
+  return dir + basename(params.sourcePath)
 }
 
 export const useTransfersStore = defineStore('transfers', () => {
@@ -219,18 +263,35 @@ export const useTransfersStore = defineStore('transfers', () => {
 
             // 订阅上传任务进度，等待真正完成
             await new Promise<void>((resolve, reject) => {
+              let done = false
+              const finish = (err?: Error) => {
+                if (done) return
+                done = true
+                try {
+                  unsubscribe()
+                } catch {
+                  // ignore
+                }
+                if (err) reject(err)
+                else resolve()
+              }
+
               const unsubscribe = subscribeUploadProgress(taskId, (task) => {
                 const progress = Math.max(0, Math.min(100, task.progress || 0))
                 item.progress = progress
                 runs.value = [...runs.value]
 
                 if (task.status === 'success') {
-                  resolve()
+                  finish()
                 } else if (task.status === 'error') {
-                  reject(new Error(task.error || 'Upload failed'))
+                  finish(new Error(task.error || 'Upload failed'))
                 }
               })
-              unsubscribers.push(unsubscribe)
+
+              // cancelRun/clearRuns will call this; close SSE + release waiter.
+              unsubscribers.push(() => {
+                finish(new Error('Cancelled'))
+              })
             })
 
             item.status = 'success'
@@ -263,29 +324,33 @@ export const useTransfersStore = defineStore('transfers', () => {
 
   async function startRemoteToMany(params: {
     sourceConnectionId: number
-    sourcePath: string
+    sourcePaths: string[]
     targetConnectionIds: number[]
     targetDirOrPath: string
+    targetMode: 'dir' | 'path'
     concurrency?: number
   }) {
-    const { sourceConnectionId, sourcePath, targetConnectionIds, targetDirOrPath } = params
+    const { sourceConnectionId, sourcePaths, targetConnectionIds, targetDirOrPath, targetMode } = params
     const concurrency = params.concurrency ?? 3
 
     if (sourceConnectionId == null) return
 
+    const sources = sourcePaths.map((p) => p.trim()).filter(Boolean)
+    if (sources.length === 0) return
+
     const runId = uid('run')
-    const filename = sourcePath.split('/').filter(Boolean).pop() || sourcePath
+    const onlySource = sources[0]
-    const runItems: TransferItem[] = targetConnectionIds.map((targetId) => ({
+    const title = sources.length === 1 && onlySource
-      id: uid('item'),
+      ? `Remote ${basename(onlySource)} -> ${targetConnectionIds.length} targets`
-      label: `#${sourceConnectionId}:${sourcePath} -> #${targetId}:${targetDirOrPath}`,
+      : `Remote ${sources.length} files -> ${targetConnectionIds.length} targets`
-      status: 'queued' as const,
+
-      progress: 0,
+    const runItems: TransferItem[] = []
-    }))
+    const tasks: (() => Promise<void>)[] = []
 
     const run: TransferRun = {
       id: runId,
       mode: 'REMOTE_TO_MANY' as const,
-      title: `Remote ${filename} -> ${targetConnectionIds.length} targets`,
+      title,
       createdAt: now(),
       items: runItems,
       status: 'queued' as const,
@@ -302,66 +367,82 @@ export const useTransfersStore = defineStore('transfers', () => {
       unsubscribers,
     })
 
-    const tasks = runItems.map((item, index) => {
+    for (const sourcePath of sources) {
-      return async () => {
+      for (const targetId of targetConnectionIds) {
-        const targetId = targetConnectionIds[index]
+        const item: TransferItem = {
-        if (targetId == null) {
+          id: uid('item'),
-          item.status = 'error'
+          label: `#${sourceConnectionId}:${sourcePath} -> #${targetId}:${targetDirOrPath}`,
-          item.progress = 100
+          status: 'queued' as const,
-          item.message = 'Missing target connection'
+          progress: 0,
-          item.finishedAt = now()
-          runs.value = [...runs.value]
-          return
         }
-        if (cancelled) {
+        runItems.push(item)
-          item.status = 'cancelled'
-          item.progress = 100
-          item.finishedAt = now()
-          runs.value = [...runs.value]
-          return
-        }
-        item.status = 'running'
-        item.progress = 0
-        item.startedAt = now()
-        runs.value = [...runs.value]
-        console.log('[Remote->Many] Starting transfer:', item.label, 'targetId:', targetId)
-        try {
-          const targetPath = buildRemoteTransferPath(targetDirOrPath, filename)
-          console.log('[Remote->Many] Target path:', targetPath)
 
-          const task = await createRemoteTransferTask(sourceConnectionId, sourcePath, targetId, targetPath)
+        tasks.push(async () => {
-          const taskId = task.data.taskId
+          if (cancelled) {
-          console.log('[Remote->Many] Task created:', taskId)
-          await waitForRemoteTransfer(taskId, (progress) => {
-            console.log('[Remote->Many] Progress update:', progress, 'item:', item.label)
-            item.progress = Math.max(item.progress || 0, progress)
-            runs.value = [...runs.value]
-          }, unsubscribers)
-
-          item.status = 'success'
-          item.progress = 100
-          item.finishedAt = now()
-          console.log('[Remote->Many] Transfer completed:', item.label)
-          runs.value = [...runs.value]
-        } catch (e: unknown) {
-          const err = e as { response?: { data?: { error?: string } } }
-          const msg = err?.response?.data?.error || (e as Error)?.message || 'Transfer failed'
-          console.error('[Remote->Many] Transfer failed:', item.label, 'error:', msg)
-          if (msg === 'Cancelled') {
             item.status = 'cancelled'
             item.progress = 100
-          } else {
+            item.finishedAt = now()
+            runs.value = [...runs.value]
+            return
+          }
+
+          item.status = 'running'
+          item.progress = 0
+          item.startedAt = now()
+          runs.value = [...runs.value]
+          console.log('[Remote->Many] Starting transfer:', item.label, 'targetId:', targetId)
+
+          let targetPath = ''
+          try {
+            targetPath = resolveRemoteTargetPath({
+              targetMode,
+              targetDirOrPath,
+              sourcePath,
+              sourceCount: sources.length,
+            })
+          } catch (e: unknown) {
             item.status = 'error'
             item.progress = 100
-            item.message = msg
+            item.message = (e as Error)?.message || 'Invalid target path'
+            item.finishedAt = now()
+            runs.value = [...runs.value]
+            return
           }
-          item.finishedAt = now()
+
-          runs.value = [...runs.value]
+          console.log('[Remote->Many] Target path:', targetPath)
-        } finally {
+
-          runs.value = [...runs.value]
+          try {
-        }
+            const task = await createRemoteTransferTask(sourceConnectionId, sourcePath, targetId, targetPath)
+            const taskId = task.data.taskId
+            console.log('[Remote->Many] Task created:', taskId)
+            await waitForRemoteTransfer(taskId, (progress) => {
+              item.progress = Math.max(item.progress || 0, progress)
+              runs.value = [...runs.value]
+            }, unsubscribers)
+
+            item.status = 'success'
+            item.progress = 100
+            item.finishedAt = now()
+            runs.value = [...runs.value]
+          } catch (e: unknown) {
+            const err = e as { response?: { data?: { error?: string } } }
+            const msg = err?.response?.data?.error || (e as Error)?.message || 'Transfer failed'
+            if (msg === 'Cancelled') {
+              item.status = 'cancelled'
+              item.progress = 100
+            } else {
+              item.status = 'error'
+              item.progress = 100
+              item.message = msg
+            }
+            item.finishedAt = now()
+            runs.value = [...runs.value]
+          } finally {
+            runs.value = [...runs.value]
+          }
+        })
       }
-    })
+    }
 
     await runWithConcurrency(tasks, concurrency)
     runs.value = [...runs.value]

frontend/src/views/TransfersView.vue

@@ -1,5 +1,5 @@
 <script setup lang="ts">
-import { computed, onMounted, ref } from 'vue'
+import { computed, onMounted, ref, watch } from 'vue'
 
 import { useConnectionsStore } from '../stores/connections'
 import { useTransfersStore } from '../stores/transfers'
@@ -32,11 +32,15 @@ const localConcurrency = ref(3)
 
 // Remote -> many
 const remoteSourceConnectionId = ref<number | null>(null)
-const remoteSourcePath = ref('')
+const remoteSourceDraft = ref('')
+const remoteSourcePaths = ref<string[]>([])
 const remoteTargetDirOrPath = ref('/')
+const remoteTargetMode = ref<'dir' | 'path'>('dir')
 const remoteSelectedTargets = ref<number[]>([])
 const remoteConcurrency = ref(3)
 
+const remoteBasenameCollisionAck = ref(false)
+
 // Picker
 const pickerOpen = ref(false)
 
@@ -49,9 +53,77 @@ const remoteTargetConnectionOptions = computed(() =>
 )
 
 const canStartLocal = computed(() => localFiles.value.length > 0 && localSelectedTargets.value.length > 0)
-const canStartRemote = computed(
+
-  () => remoteSourceConnectionId.value != null && remoteSourcePath.value.trim() && remoteSelectedTargets.value.length > 0
+function basename(p: string) {
-)
+  return p.split('/').filter(Boolean).pop() || p
+}
+
+function mergeRemoteSourcePaths(paths: string[]) {
+  const merged = remoteSourcePaths.value.slice()
+  for (const raw of paths) {
+    const p = raw.trim()
+    if (!p) continue
+    if (!merged.includes(p)) merged.push(p)
+  }
+  remoteSourcePaths.value = merged
+}
+
+function addRemoteSourceDraft() {
+  if (!remoteSourceDraft.value.trim()) return
+  mergeRemoteSourcePaths([remoteSourceDraft.value])
+  remoteSourceDraft.value = ''
+}
+
+function removeRemoteSourcePath(path: string) {
+  remoteSourcePaths.value = remoteSourcePaths.value.filter((p) => p !== path)
+}
+
+function clearRemoteSources() {
+  remoteSourcePaths.value = []
+  remoteBasenameCollisionAck.value = false
+}
+
+const remoteHasBasenameCollision = computed(() => {
+  if (remoteTargetMode.value !== 'dir') return false
+  const counts = new Map<string, number>()
+  for (const p of remoteSourcePaths.value) {
+    const name = basename(p)
+    counts.set(name, (counts.get(name) || 0) + 1)
+  }
+  for (const n of counts.values()) {
+    if (n > 1) return true
+  }
+  return false
+})
+
+const remoteValidationError = computed(() => {
+  if (remoteSourceConnectionId.value == null) return ''
+
+  if (remoteSourcePaths.value.length === 0) return '请先选择至少 1 个源文件'
+
+  for (const p of remoteSourcePaths.value) {
+    const clean = p.trim()
+    if (!clean) return '源文件路径不能为空'
+    if (clean.endsWith('/')) return '源文件路径必须是文件（不能以 / 结尾）'
+  }
+
+  if (remoteTargetMode.value === 'path') {
+    if (remoteSourcePaths.value.length !== 1) return 'Exact Path 只支持单文件'
+    const t = remoteTargetDirOrPath.value.trim()
+    if (!t) return 'Exact Path 需要填写目标文件路径'
+    if (t.endsWith('/')) return 'Exact Path 不能以 / 结尾'
+  }
+
+  return ''
+})
+
+const canStartRemote = computed(() => {
+  if (remoteSourceConnectionId.value == null) return false
+  if (remoteSelectedTargets.value.length === 0) return false
+  if (remoteValidationError.value) return false
+  if (remoteHasBasenameCollision.value && !remoteBasenameCollisionAck.value) return false
+  return true
+})
 
 function onLocalFileChange(e: Event) {
   const input = e.target as HTMLInputElement
@@ -129,9 +201,10 @@ async function startRemote() {
   if (!canStartRemote.value || remoteSourceConnectionId.value == null) return
   await transfersStore.startRemoteToMany({
     sourceConnectionId: remoteSourceConnectionId.value,
-    sourcePath: remoteSourcePath.value.trim(),
+    sourcePaths: remoteSourcePaths.value,
     targetConnectionIds: remoteSelectedTargets.value,
     targetDirOrPath: remoteTargetDirOrPath.value,
+    targetMode: remoteTargetMode.value,
     concurrency: remoteConcurrency.value,
   })
 }
@@ -141,6 +214,27 @@ function openPicker() {
   pickerOpen.value = true
 }
 
+watch(remoteSourceConnectionId, (next, prev) => {
+  if (next === prev) return
+  remoteSourceDraft.value = ''
+  remoteSourcePaths.value = []
+  remoteBasenameCollisionAck.value = false
+  remoteTargetMode.value = 'dir'
+  if (next != null) {
+    remoteSelectedTargets.value = remoteSelectedTargets.value.filter((id) => id !== next)
+  }
+})
+
+watch(remoteSourcePaths, (paths) => {
+  if (paths.length > 1 && remoteTargetMode.value === 'path') {
+    remoteTargetMode.value = 'dir'
+  }
+})
+
+watch(remoteHasBasenameCollision, (hasCollision) => {
+  if (!hasCollision) remoteBasenameCollisionAck.value = false
+})
+
 onMounted(async () => {
   if (connectionsStore.connections.length === 0) {
     await connectionsStore.fetchConnections().catch(() => {})
@@ -326,39 +420,128 @@ onMounted(async () => {
             </div>
 
             <div class="grid gap-3">
-              <label for="remote-source-path" class="text-sm text-slate-300">源文件路径</label>
+              <label for="remote-source-draft" class="text-sm text-slate-300">源文件</label>
-              <div class="flex gap-2">
+
-                <input
+              <div class="flex flex-col gap-2">
-                  id="remote-source-path"
+                <div class="flex gap-2">
-                  v-model="remoteSourcePath"
+                  <input
-                  type="text"
+                    id="remote-source-draft"
-                  placeholder="/path/to/file"
+                    v-model="remoteSourceDraft"
-                  class="flex-1 rounded-xl border border-slate-700 bg-slate-950/30 px-3 py-2 text-sm text-slate-100 placeholder-slate-600 focus:outline-none focus:ring-2 focus:ring-cyan-500"
+                    type="text"
-                />
+                    placeholder="/path/to/file"
-                <button
+                    class="flex-1 rounded-xl border border-slate-700 bg-slate-950/30 px-3 py-2 text-sm text-slate-100 placeholder-slate-600 focus:outline-none focus:ring-2 focus:ring-cyan-500"
-                  @click="openPicker"
+                    @keydown.enter.prevent="addRemoteSourceDraft"
-                  :disabled="remoteSourceConnectionId == null"
+                  />
-                  class="min-h-[44px] px-3 rounded-xl border border-slate-700 bg-slate-900/30 text-slate-200 hover:bg-slate-800/50 disabled:opacity-50 cursor-pointer transition-colors"
+
-                  aria-label="浏览远程文件"
+                  <button
-                >
+                    @click="addRemoteSourceDraft"
-                  <span class="inline-flex items-center gap-2">
+                    :disabled="!remoteSourceDraft.trim()"
-                    <FolderOpen class="w-4 h-4" aria-hidden="true" />
+                    class="min-h-[44px] px-3 rounded-xl border border-slate-700 bg-slate-900/30 text-slate-200 hover:bg-slate-800/50 disabled:opacity-50 cursor-pointer transition-colors"
-                    浏览
+                    type="button"
+                    aria-label="添加源文件路径"
+                  >
+                    添加
+                  </button>
+
+                  <button
+                    @click="openPicker"
+                    :disabled="remoteSourceConnectionId == null"
+                    class="min-h-[44px] px-3 rounded-xl border border-slate-700 bg-slate-900/30 text-slate-200 hover:bg-slate-800/50 disabled:opacity-50 cursor-pointer transition-colors"
+                    type="button"
+                    aria-label="浏览远程文件"
+                  >
+                    <span class="inline-flex items-center gap-2">
+                      <FolderOpen class="w-4 h-4" aria-hidden="true" />
+                      浏览
+                    </span>
+                  </button>
+                </div>
+
+                <div class="flex items-center justify-between text-xs text-slate-500">
+                  <span>已选择 {{ remoteSourcePaths.length }} 个文件</span>
+                  <button
+                    v-if="remoteSourcePaths.length"
+                    @click="clearRemoteSources"
+                    class="hover:text-slate-200 transition-colors cursor-pointer"
+                    type="button"
+                    aria-label="清空已选择源文件"
+                  >
+                    清空
+                  </button>
+                </div>
+
+                <div v-if="remoteSourcePaths.length" class="flex flex-wrap gap-2">
+                  <span
+                    v-for="p in remoteSourcePaths"
+                    :key="p"
+                    class="inline-flex items-center gap-1 rounded-lg border border-slate-700 bg-slate-950/20 px-2 py-1 text-xs text-slate-200"
+                    :title="p"
+                  >
+                    <span class="max-w-[260px] truncate">{{ basename(p) }}</span>
+                    <button
+                      @click="removeRemoteSourcePath(p)"
+                      class="w-6 h-6 grid place-items-center rounded hover:bg-slate-800/60 text-slate-300 hover:text-slate-100 transition-colors cursor-pointer"
+                      type="button"
+                      :aria-label="'移除 ' + basename(p)"
+                    >
+                      <XCircle class="w-4 h-4" aria-hidden="true" />
+                    </button>
                   </span>
-                </button>
+                </div>
+
+                <p v-if="remoteValidationError" class="text-xs text-red-300">{{ remoteValidationError }}</p>
               </div>
             </div>
 
             <div class="grid gap-3">
-              <label for="remote-target-dir" class="text-sm text-slate-300">目标目录或路径</label>
+              <div class="flex items-center justify-between gap-3">
+                <label for="remote-target-dir" class="text-sm text-slate-300">目标目录或路径</label>
+                <div class="inline-flex rounded-lg border border-slate-700 bg-slate-950/20 p-1">
+                  <button
+                    @click="remoteTargetMode = 'dir'"
+                    class="px-3 py-1 rounded-md text-xs transition-colors"
+                    :class="remoteTargetMode === 'dir' ? 'bg-slate-800 text-slate-100' : 'text-slate-400 hover:text-slate-200'"
+                    type="button"
+                    aria-label="目标为目录"
+                  >
+                    Directory
+                  </button>
+                  <button
+                    @click="remoteTargetMode = 'path'"
+                    :disabled="remoteSourcePaths.length > 1"
+                    class="px-3 py-1 rounded-md text-xs transition-colors disabled:opacity-50 disabled:cursor-not-allowed"
+                    :class="remoteTargetMode === 'path' ? 'bg-slate-800 text-slate-100' : 'text-slate-400 hover:text-slate-200'"
+                    type="button"
+                    aria-label="目标为精确路径"
+                  >
+                    Exact Path
+                  </button>
+                </div>
+              </div>
+
               <input
                 id="remote-target-dir"
                 v-model="remoteTargetDirOrPath"
                 type="text"
-                placeholder="/target/dir/"
+                :placeholder="remoteTargetMode === 'dir' ? '/target/dir/' : '/target/file.txt'"
                 class="w-full rounded-xl border border-slate-700 bg-slate-950/30 px-3 py-2 text-sm text-slate-100 placeholder-slate-600 focus:outline-none focus:ring-2 focus:ring-cyan-500"
               />
-              <p class="text-xs text-slate-500">以 / 结尾视为目录，会自动拼接文件名。</p>
+              <p class="text-xs text-slate-500">
+                <span v-if="remoteTargetMode === 'dir'">Directory 模式会自动拼接文件名；输入可不以 / 结尾。</span>
+                <span v-else>Exact Path 仅支持单文件，且不能以 / 结尾。</span>
+              </p>
+            </div>
+
+            <div v-if="remoteHasBasenameCollision" class="rounded-xl border border-amber-500/20 bg-amber-500/10 px-3 py-2">
+              <p class="text-xs text-amber-200">检测到重名文件（同名但不同目录）。Directory 模式会覆盖目标目录下的同名文件。</p>
+              <label class="mt-2 flex items-center gap-2 text-xs text-amber-100 cursor-pointer">
+                <input
+                  v-model="remoteBasenameCollisionAck"
+                  type="checkbox"
+                  class="h-4 w-4 rounded border-amber-500/40 bg-slate-900 text-amber-400 focus:ring-amber-400"
+                />
+                我已知晓并继续
+              </label>
             </div>
 
             <div class="grid gap-3">
@@ -509,8 +692,9 @@ onMounted(async () => {
     <SftpFilePickerModal
       :open="pickerOpen"
       :connection-id="remoteSourceConnectionId"
+      :multiple="true"
       @close="pickerOpen = false"
-      @select="(p) => (remoteSourcePath = p)"
+      @select-many="(paths) => mergeRemoteSourcePaths(paths)"
     />
   </div>
 </template>