Merge pull request #851 from hicccc77/main

Dev
Merge pull request #850 from hicccc77/dev
2026-04-26 07:26:46 +00:00 · 2026-04-26 14:55:18 +08:00 · 2026-04-26 14:54:36 +08:00 · 2026-04-26 14:53:53 +08:00 · 2026-04-26 14:48:48 +08:00 · 2026-04-26 12:11:12 +08:00
37 changed files with 2556 additions and 847 deletions
--- a/.github/scripts/release-utils.sh
+++ b/.github/scripts/release-utils.sh
@@ -58,12 +58,26 @@ wait_for_release_id() {

  local i
  local release_id
+  local release_api_url
  for ((i = 1; i <= attempts; i++)); do
    release_id="$(gh api "repos/$repo/releases/tags/$tag" --jq '.id' 2>/dev/null || true)"
    if [[ "$release_id" =~ ^[0-9]+$ ]]; then
      echo "$release_id"
      return 0
    fi
+
+    release_id="$(gh release view "$tag" --repo "$repo" --json databaseId --jq '.databaseId // empty' 2>/dev/null || true)"
+    if [[ "$release_id" =~ ^[0-9]+$ ]]; then
+      echo "$release_id"
+      return 0
+    fi
+
+    release_api_url="$(gh release view "$tag" --repo "$repo" --json apiUrl --jq '.apiUrl // empty' 2>/dev/null || true)"
+    if [[ "$release_api_url" =~ /releases/([0-9]+)$ ]]; then
+      echo "${BASH_REMATCH[1]}"
+      return 0
+    fi
+
    if [ "$i" -lt "$attempts" ]; then
      echo "Release id for tag '$tag' is not ready yet (attempt $i/$attempts), retrying in ${delay_seconds}s..." >&2
      sleep "$delay_seconds"
@@ -71,6 +85,7 @@ wait_for_release_id() {
  done

  echo "Unable to fetch release id for tag '$tag' after $attempts attempts." >&2
+  gh release view "$tag" --repo "$repo" --json databaseId,id,isDraft,isPrerelease,url 2>/dev/null || true
  gh api "repos/$repo/releases/tags/$tag" --jq '{draft: .draft, prerelease: .prerelease, url: .html_url}' 2>/dev/null || true
  return 1
 }
@@ -87,9 +102,10 @@ settle_release_state() {
  local draft_state
  local prerelease_state
  for ((i = 1; i <= attempts; i++)); do
+    gh release edit "$tag" --repo "$repo" --draft=false --prerelease >/dev/null 2>&1 || true
    gh api --method PATCH "repos/$repo/releases/$release_id" -F draft=false -F prerelease=true >/dev/null 2>&1 || true
-    draft_state="$(gh api "$endpoint" --jq '.draft' 2>/dev/null || echo true)"
-    prerelease_state="$(gh api "$endpoint" --jq '.prerelease' 2>/dev/null || echo false)"
+    draft_state="$(gh api "$endpoint" --jq '.draft' 2>/dev/null || gh release view "$tag" --repo "$repo" --json isDraft --jq '.isDraft' 2>/dev/null || echo true)"
+    prerelease_state="$(gh api "$endpoint" --jq '.prerelease' 2>/dev/null || gh release view "$tag" --repo "$repo" --json isPrerelease --jq '.isPrerelease' 2>/dev/null || echo false)"
    if [ "$draft_state" = "false" ] && [ "$prerelease_state" = "true" ]; then
      return 0
    fi
@@ -100,10 +116,19 @@ settle_release_state() {
  done

  echo "Failed to settle release state for tag '$tag'." >&2
+  gh release view "$tag" --repo "$repo" --json isDraft,isPrerelease,url 2>/dev/null || true
  gh api "$endpoint" --jq '{draft: .draft, prerelease: .prerelease, url: .html_url}' 2>/dev/null || true
  return 1
 }

+print_release_state() {
+  local repo="$1"
+  local tag="$2"
+
+  gh api "repos/$repo/releases/tags/$tag" --jq '{isDraft: .draft, isPrerelease: .prerelease, url: .html_url}' 2>/dev/null \
+    || gh release view "$tag" --repo "$repo" --json isDraft,isPrerelease,url --jq '{isDraft: .isDraft, isPrerelease: .isPrerelease, url: .url}'
+}
+
 wait_for_release_absent() {
  local repo="$1"
  local tag="$2"
--- a/.github/workflows/dev-daily-fixed.yml
+++ b/.github/workflows/dev-daily-fixed.yml
@@ -386,4 +386,4 @@ jobs:
          source .github/scripts/release-utils.sh
          RELEASE_REST_ID="$(wait_for_release_id "$REPO" "$TAG" 12 2)"
          settle_release_state "$REPO" "$RELEASE_REST_ID" "$TAG" 12 2
-          gh api "repos/$REPO/releases/tags/$TAG" --jq '{isDraft: .draft, isPrerelease: .prerelease, url: .html_url}'
+          print_release_state "$REPO" "$TAG"
--- a/.github/workflows/preview-nightly-main.yml
+++ b/.github/workflows/preview-nightly-main.yml
@@ -429,4 +429,4 @@ jobs:
          source .github/scripts/release-utils.sh
          RELEASE_REST_ID="$(wait_for_release_id "$REPO" "$TAG" 12 2)"
          settle_release_state "$REPO" "$RELEASE_REST_ID" "$TAG" 12 2
-          gh api "repos/$REPO/releases/tags/$TAG" --jq '{isDraft: .draft, isPrerelease: .prerelease, url: .html_url}'
+          print_release_state "$REPO" "$TAG"
--- a/README.md
+++ b/README.md
@@ -3,17 +3,15 @@
 WeFlow 是一个**完全本地**的微信**实时**聊天记录查看、分析与导出工具。它可以实时获取你的微信聊天记录并将其导出，还可以根据你的聊天记录为你生成独一无二的分析报告。

 <p align="center">
-  <img src="app.png" alt="WeFlow 应用预览" width="90%">
+  <img src="app.jpg" alt="WeFlow 应用预览" width="90%">
 </p>

 <p align="center">
-  <!-- 第一行修复样式 -->
  <a href="https://github.com/hicccc77/WeFlow/stargazers"><img src="https://img.shields.io/github/stars/hicccc77/WeFlow?style=flat&label=Stars&labelColor=1F2937&color=2563EB" alt="Stargazers"></a>
  <a href="https://github.com/hicccc77/WeFlow/network/members"><img src="https://img.shields.io/github/forks/hicccc77/WeFlow?style=flat&label=Forks&labelColor=1F2937&color=7C3AED" alt="Forks"></a>
  <a href="https://github.com/hicccc77/WeFlow/issues"><img src="https://img.shields.io/github/issues/hicccc77/WeFlow?style=flat&label=Issues&labelColor=1F2937&color=D97706" alt="Issues"></a>
  <a href="https://github.com/hicccc77/WeFlow/releases"><img src="https://img.shields.io/github/downloads/hicccc77/WeFlow/total?style=flat&label=Downloads&labelColor=1F2937&color=059669" alt="Downloads"></a>
  <br><br>
-  <!-- 第二行：电报矮一点(22px)，排名高一点(32px)，使用 vertical-align: middle 居中对齐 -->
  <a href="https://t.me/weflow_cc"><img src="https://img.shields.io/badge/Telegram-频道-1D9BF0?style=flat&logo=telegram&logoColor=white&labelColor=1F2937&color=1D9BF0" alt="Telegram Channel" style="height: 22px; vertical-align: middle;"></a>
  <a href="https://www.star-history.com/hicccc77/weflow"><img src="https://api.star-history.com/badge?repo=hicccc77/WeFlow&theme=dark" alt="Star History Rank" style="height: 32px; vertical-align: middle;"></a>
 </p>
--- a/app.jpg
+++ b/app.jpg
--- a/app.png
+++ b/app.png
--- a/docs/MAC-KEY-FAQ.md
+++ b/docs/MAC-KEY-FAQ.md
@@ -20,9 +20,10 @@
 1. **降级微信版本**。找一个经过大家验证、兼容性更好的老版本，目前最推荐先退回到 4.1.7.57 或者 4.1.8.100。
 2. **彻底退出微信**。请使用快捷键 Command + Q 或在活动监视器中结束进程，而不仅仅是关闭窗口。
 3. **重启你的 Mac**。这一步极其关键，必须是真正的重新启动。注销或睡眠唤醒无法清除系统底层的拦截状态。
-4. **重新打开微信**。随便点击几下保持它在最前台，并且确保它是可以正常交互的状态。
+4. **重新打开微信**。随便点击几下保持它在最前台，并且确保它是未登录的状态。
 5. **回到 WeFlow**。仅仅尝试一次“自动获取密钥”。
-6. **恢复日常使用**。只要成功拿到了密钥，你就可以放心地把微信更新回你平时爱用的最新版本。
+6. **输入密码并登录**。先在弹窗中输入你的系统密码后，确认页面弹出允许登录了再登录微信
+7. **恢复日常使用**。只要成功拿到了密钥，你就可以放心地把微信更新回你平时爱用的最新版本。

 ### 常见报错与应对方法

--- a/electron/exportWorker.ts
+++ b/electron/exportWorker.ts
@@ -5,6 +5,7 @@ interface ExportWorkerConfig {
  sessionIds: string[]
  outputDir: string
  options: ExportOptions
+  taskId?: string
  dbPath?: string
  decryptKey?: string
  myWxid?: string
@@ -14,6 +15,27 @@ interface ExportWorkerConfig {
 }

 const config = workerData as ExportWorkerConfig
+const controlState = {
+  pauseRequested: false,
+  stopRequested: false
+}
+
+parentPort?.on('message', (message: any) => {
+  if (!message || typeof message.type !== 'string') return
+  if (message.type === 'export:pause') {
+    controlState.pauseRequested = true
+    return
+  }
+  if (message.type === 'export:resume') {
+    controlState.pauseRequested = false
+    return
+  }
+  if (message.type === 'export:cancel') {
+    controlState.stopRequested = true
+    controlState.pauseRequested = false
+  }
+})
+
 process.env.WEFLOW_WORKER = '1'
 if (config.resourcesPath) {
  process.env.WCDB_RESOURCES_PATH = config.resourcesPath
@@ -47,7 +69,19 @@ async function run() {
        type: 'export:progress',
        data: progress
      })
+    },
+    config.taskId
+      ? {
+          shouldPause: () => controlState.pauseRequested,
+          shouldStop: () => controlState.stopRequested,
+          recordCreatedFile: (filePath: string) => {
+            parentPort?.postMessage({ type: 'export:createdFile', filePath })
+          },
+          recordCreatedDir: (dirPath: string) => {
+            parentPort?.postMessage({ type: 'export:createdDir', dirPath })
          }
+        }
+      : undefined
  )

  parentPort?.postMessage({
--- a/electron/main.ts
+++ b/electron/main.ts
@@ -16,6 +16,7 @@ import { analyticsService } from './services/analyticsService'
 import { groupAnalyticsService } from './services/groupAnalyticsService'
 import { annualReportService } from './services/annualReportService'
 import { exportService, ExportOptions, ExportProgress } from './services/exportService'
+import { exportTaskControlService } from './services/exportTaskControlService'
 import { KeyService } from './services/keyService'
 import { KeyServiceLinux } from './services/keyServiceLinux'
 import { KeyServiceMac } from './services/keyServiceMac'
@@ -64,6 +65,42 @@ const defaultUpdateTrack: 'stable' | 'preview' | 'dev' = (() => {
  return 'stable'
 })()
 let configService: ConfigService | null = null
+const activeExportWorkers = new Map<string, Worker>()
+const activeExportTasks = new Set<string>()
+
+const normalizeExportTaskId = (taskId: unknown): string => String(taskId || '').trim()
+
+const postExportWorkerControl = (taskId: string, action: 'pause' | 'resume' | 'cancel') => {
+  const worker = activeExportWorkers.get(taskId)
+  if (!worker) return
+  try {
+    worker.postMessage({ type: `export:${action}` })
+  } catch (error) {
+    console.warn(`[export-task-control] failed to post ${action} to worker:`, error)
+  }
+}
+
+const finalizeExportTaskControlResult = async (taskId: string, result: any) => {
+  if (!taskId) return result
+  if (result?.stopped) {
+    const cleanup = await exportTaskControlService.cleanupTask(taskId)
+    if (!cleanup.success) {
+      return {
+        ...result,
+        success: false,
+        error: `导出已停止，但清理已导出文件失败：${cleanup.error || '未知错误'}`
+      }
+    }
+    return {
+      ...result,
+      cleanup
+    }
+  }
+  if (!result?.paused) {
+    exportTaskControlService.releaseTask(taskId)
+  }
+  return result
+}

 const normalizeUpdateTrack = (raw: unknown): 'stable' | 'preview' | 'dev' | null => {
  if (raw === 'stable' || raw === 'preview' || raw === 'dev') return raw
@@ -748,6 +785,10 @@ const getWindowCloseBehavior = (): WindowCloseBehavior => {
  return behavior === 'tray' || behavior === 'quit' ? behavior : 'ask'
 }

+const isSilentStartupEnabled = (): boolean => {
+  return configService?.get('silentStartup') === true
+}
+
 const requestMainWindowCloseConfirmation = (win: BrowserWindow): void => {
  if (isClosePromptVisible) return
  isClosePromptVisible = true
@@ -2237,6 +2278,10 @@ function registerIpcHandlers() {
    return chatService.getNewMessages(sessionId, minTime, limit)
  })

+  ipcMain.handle('chat:getAntiRevokeSessions', async () => {
+    return chatService.getAntiRevokeSessions()
+  })
+
  ipcMain.handle('chat:updateMessage', async (_, sessionId: string, localId: number, createTime: number, newContent: string) => {
    return chatService.updateMessage(sessionId, localId, createTime, newContent)
  })
@@ -2628,16 +2673,25 @@ function registerIpcHandlers() {

  ipcMain.handle('sns:exportTimeline', async (event, options: any) => {
    const exportOptions = { ...(options || {}) }
+    const taskId = normalizeExportTaskId(exportOptions.taskId)
    delete exportOptions.taskId
+    const taskControl = taskId ? exportTaskControlService.createControl(taskId, String(exportOptions.outputDir || '')) : undefined
+    if (taskId) activeExportTasks.add(taskId)

-    return snsService.exportTimeline(
+    try {
+      const result = await snsService.exportTimeline(
        exportOptions,
        (progress) => {
          if (!event.sender.isDestroyed()) {
            event.sender.send('sns:exportProgress', progress)
          }
-      }
+        },
+        taskControl
      )
+      return finalizeExportTaskControlResult(taskId, result)
+    } finally {
+      if (taskId) activeExportTasks.delete(taskId)
+    }
  })

  ipcMain.handle('sns:selectExportDir', async () => {
@@ -2960,7 +3014,40 @@ function registerIpcHandlers() {
    return exportService.getExportStats(sessionIds, options)
  })

-  ipcMain.handle('export:exportSessions', async (event, sessionIds: string[], outputDir: string, options: ExportOptions) => {
+  ipcMain.handle('export:pauseTask', async (_, taskId: string) => {
+    const normalizedTaskId = normalizeExportTaskId(taskId)
+    if (!normalizedTaskId) return { success: false, error: '缺少导出任务 ID' }
+    const success = exportTaskControlService.pauseTask(normalizedTaskId)
+    if (success) postExportWorkerControl(normalizedTaskId, 'pause')
+    return { success }
+  })
+
+  ipcMain.handle('export:resumeTask', async (_, taskId: string) => {
+    const normalizedTaskId = normalizeExportTaskId(taskId)
+    if (!normalizedTaskId) return { success: false, error: '缺少导出任务 ID' }
+    const success = exportTaskControlService.resumeTask(normalizedTaskId)
+    if (success) postExportWorkerControl(normalizedTaskId, 'resume')
+    return { success }
+  })
+
+  ipcMain.handle('export:cancelTask', async (_, taskId: string) => {
+    const normalizedTaskId = normalizeExportTaskId(taskId)
+    if (!normalizedTaskId) return { success: false, error: '缺少导出任务 ID' }
+    const success = exportTaskControlService.cancelTask(normalizedTaskId)
+    if (success) postExportWorkerControl(normalizedTaskId, 'cancel')
+    if (success && !activeExportTasks.has(normalizedTaskId)) {
+      const cleanup = await exportTaskControlService.cleanupTask(normalizedTaskId)
+      return cleanup.success
+        ? { success: true, cleanup }
+        : { success: false, error: cleanup.error || '清理已导出文件失败' }
+    }
+    return { success }
+  })
+
+  ipcMain.handle('export:exportSessions', async (event, sessionIds: string[], outputDir: string, options: ExportOptions, controlOptions?: { taskId?: string }) => {
+    const taskId = normalizeExportTaskId(controlOptions?.taskId)
+    const taskControl = taskId ? exportTaskControlService.createControl(taskId, outputDir) : undefined
+    if (taskId) activeExportTasks.add(taskId)
    const PROGRESS_FORWARD_INTERVAL_MS = 180
    let pendingProgress: ExportProgress | null = null
    let progressTimer: NodeJS.Timeout | null = null
@@ -3006,7 +3093,7 @@ function registerIpcHandlers() {

    const runMainFallback = async (reason: string) => {
      console.warn(`[fallback-export-main] ${reason}`)
-      return exportService.exportSessions(sessionIds, outputDir, options, onProgress)
+      return exportService.exportSessions(sessionIds, outputDir, options, onProgress, taskControl)
    }

    const cfg = configService || new ConfigService()
@@ -3028,6 +3115,7 @@ function registerIpcHandlers() {
            sessionIds,
            outputDir,
            options,
+            taskId,
            dbPath,
            decryptKey,
            myWxid,
@@ -3038,9 +3126,15 @@ function registerIpcHandlers() {
        })

        let settled = false
+        if (taskId) {
+          activeExportWorkers.set(taskId, worker)
+        }
        const finalizeResolve = (value: any) => {
          if (settled) return
          settled = true
+          if (taskId && activeExportWorkers.get(taskId) === worker) {
+            activeExportWorkers.delete(taskId)
+          }
          worker.removeAllListeners()
          void worker.terminate()
          resolve(value)
@@ -3048,6 +3142,9 @@ function registerIpcHandlers() {
        const finalizeReject = (error: Error) => {
          if (settled) return
          settled = true
+          if (taskId && activeExportWorkers.get(taskId) === worker) {
+            activeExportWorkers.delete(taskId)
+          }
          worker.removeAllListeners()
          void worker.terminate()
          reject(error)
@@ -3058,6 +3155,14 @@ function registerIpcHandlers() {
            onProgress(msg.data as ExportProgress)
            return
          }
+          if (msg && msg.type === 'export:createdFile' && taskId) {
+            exportTaskControlService.recordCreatedFile(taskId, String(msg.filePath || ''))
+            return
+          }
+          if (msg && msg.type === 'export:createdDir' && taskId) {
+            exportTaskControlService.recordCreatedDir(taskId, String(msg.dirPath || ''))
+            return
+          }
          if (msg && msg.type === 'export:result') {
            finalizeResolve(msg.data)
            return
@@ -3083,10 +3188,13 @@ function registerIpcHandlers() {
    }

    try {
-      return await runWorker()
+      const result = await runWorker()
+      return await finalizeExportTaskControlResult(taskId, result)
    } catch (error) {
-      return runMainFallback(error instanceof Error ? error.message : String(error))
+      const result = await runMainFallback(error instanceof Error ? error.message : String(error))
+      return await finalizeExportTaskControlResult(taskId, result)
    } finally {
+      if (taskId) activeExportTasks.delete(taskId)
      flushProgress()
      if (progressTimer) {
        clearTimeout(progressTimer)
@@ -3740,7 +3848,16 @@ function checkForUpdatesOnStartup() {
 }

 app.whenReady().then(async () => {
-  // 立即创建 Splash 窗口，确保用户尽快看到反馈
+  // 先初始化配置，以便在启动早期判定是否需要静默启动
+  configService = new ConfigService()
+  applyAutoUpdateChannel('startup')
+  syncLaunchAtStartupPreference()
+  const onboardingDone = configService.get('onboardingDone') === true
+  const startInBackground = onboardingDone && isSilentStartupEnabled()
+  shouldShowMain = onboardingDone
+
+  if (!startInBackground) {
+    // 非静默模式下显示 Splash，提供启动反馈
    createSplashWindow()

    // 等待 Splash 页面加载完成后再推送进度
@@ -3756,6 +3873,7 @@ app.whenReady().then(async () => {
        .executeJavaScript(`setVersion(${JSON.stringify(app.getVersion())})`)
        .catch(() => {})
    }
+  }

  const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))
  const withTimeout = <T>(task: () => Promise<T>, timeoutMs: number): Promise<{ timedOut: boolean; value?: T; error?: string }> => {
@@ -3783,13 +3901,7 @@ app.whenReady().then(async () => {
    })
  }

-  // 初始化配置服务
  updateSplashProgress(5, '正在加载配置...')
-  configService = new ConfigService()
-  applyAutoUpdateChannel('startup')
-  syncLaunchAtStartupPreference()
-  const onboardingDone = configService.get('onboardingDone') === true
-  shouldShowMain = onboardingDone

  // 将用户主题配置推送给 Splash 窗口
  if (splashWindow && !splashWindow.isDestroyed()) {
@@ -3956,6 +4068,8 @@ app.whenReady().then(async () => {

  if (!onboardingDone) {
    createOnboardingWindow()
+  } else if (startInBackground && tray) {
+    mainWindow?.hide()
  } else {
    mainWindow?.show()
  }
--- a/electron/preload.ts
+++ b/electron/preload.ts
@@ -185,6 +185,7 @@ contextBridge.exposeInMainWorld('electronAPI', {
  chat: {
    connect: () => ipcRenderer.invoke('chat:connect'),
    getSessions: () => ipcRenderer.invoke('chat:getSessions'),
+    getAntiRevokeSessions: () => ipcRenderer.invoke('chat:getAntiRevokeSessions'),
    getSessionStatuses: (usernames: string[]) => ipcRenderer.invoke('chat:getSessionStatuses', usernames),
    getExportTabCounts: () => ipcRenderer.invoke('chat:getExportTabCounts'),
    getContactTypeCounts: () => ipcRenderer.invoke('chat:getContactTypeCounts'),
@@ -462,8 +463,14 @@ contextBridge.exposeInMainWorld('electronAPI', {
  export: {
    getExportStats: (sessionIds: string[], options: any) =>
      ipcRenderer.invoke('export:getExportStats', sessionIds, options),
-    exportSessions: (sessionIds: string[], outputDir: string, options: any) =>
-      ipcRenderer.invoke('export:exportSessions', sessionIds, outputDir, options),
+    exportSessions: (sessionIds: string[], outputDir: string, options: any, controlOptions?: { taskId?: string }) =>
+      ipcRenderer.invoke('export:exportSessions', sessionIds, outputDir, options, controlOptions),
+    pauseTask: (taskId: string) =>
+      ipcRenderer.invoke('export:pauseTask', taskId),
+    resumeTask: (taskId: string) =>
+      ipcRenderer.invoke('export:resumeTask', taskId),
+    cancelTask: (taskId: string) =>
+      ipcRenderer.invoke('export:cancelTask', taskId),
    exportSession: (sessionId: string, outputPath: string, options: any) =>
      ipcRenderer.invoke('export:exportSession', sessionId, outputPath, options),
    exportContacts: (outputDir: string, options: any) =>
--- a/electron/services/backupService.ts
+++ b/electron/services/backupService.ts
@@ -1,5 +1,5 @@
 import { BrowserWindow, app } from 'electron'
-import { existsSync, mkdirSync, readdirSync, rmSync, statSync } from 'fs'
+import { createWriteStream, existsSync, mkdirSync, readdirSync, rmSync, statSync } from 'fs'
 import { copyFile, link, readFile as readFileAsync, mkdtemp, writeFile } from 'fs/promises'
 import { basename, dirname, join, relative, resolve, sep } from 'path'
 import { tmpdir } from 'os'
@@ -7,11 +7,12 @@ import * as tar from 'tar'
 import { ConfigService } from './config'
 import { wcdbService } from './wcdbService'
 import { expandHomePath } from '../utils/pathUtils'
-import { decryptDatViaNative, encryptDatViaNative } from './nativeImageDecrypt'

-type BackupDbKind = 'session' | 'contact' | 'emoticon' | 'message' | 'media' | 'sns'
+type BackupDbKind = 'session' | 'contact' | 'emoticon' | 'message' | 'media' | 'sns' | 'hardlink'
 type BackupPhase = 'preparing' | 'scanning' | 'exporting' | 'packing' | 'inspecting' | 'restoring' | 'done' | 'failed'
 type BackupResourceKind = 'image' | 'video' | 'file'
+const TEMP_MARKER = '.weflow-backup-temp'
+const TEMP_TTL_MS = 24 * 60 * 60 * 1000

 export interface BackupOptions {
  includeImages?: boolean
@@ -140,8 +141,42 @@ function hasResourceOptions(options: BackupOptions): boolean {
  return options.includeImages === true || options.includeVideos === true || options.includeFiles === true
 }

+function normalizeArchivePath(value: string): string {
+  return String(value || '').replace(/\\/g, '/')
+}
+
 export class BackupService {
  private configService = new ConfigService()
+  private cleanedTempDirs = false
+
+  private cleanupStaleTempDirs(): void {
+    if (this.cleanedTempDirs) return
+    this.cleanedTempDirs = true
+    const root = tmpdir()
+    const now = Date.now()
+    try {
+      for (const entry of readdirSync(root)) {
+        if (!entry.startsWith('weflow-backup-')) continue
+        const dir = join(root, entry)
+        const marker = join(dir, TEMP_MARKER)
+        try {
+          const stat = statSync(dir)
+          if (!stat.isDirectory()) continue
+          if (!existsSync(marker)) continue
+          const age = now - stat.mtimeMs
+          if (age < TEMP_TTL_MS) continue
+          rmSync(dir, { recursive: true, force: true })
+        } catch {}
+      }
+    } catch {}
+  }
+
+  private async createTempDir(prefix: string): Promise<string> {
+    this.cleanupStaleTempDirs()
+    const dir = await mkdtemp(join(tmpdir(), prefix))
+    await writeFile(join(dir, TEMP_MARKER), String(Date.now()), 'utf8')
+    return dir
+  }

  private buildWxidCandidates(wxid: string): string[] {
    const wxidCandidates = Array.from(new Set([
@@ -253,27 +288,6 @@ export class BackupService {
    return suffixMatch ? suffixMatch[1] : trimmed
  }

-  private parseImageXorKey(value: unknown): number {
-    if (typeof value === 'number') return value
-    const text = String(value ?? '').trim()
-    if (!text) return Number.NaN
-    return text.toLowerCase().startsWith('0x') ? parseInt(text, 16) : parseInt(text, 10)
-  }
-
-  private getImageKeysForWxid(wxid: string): { xorKey: number; aesKey?: string } | null {
-    const wxidConfigs = this.configService.get('wxidConfigs') || {}
-    const candidates = this.buildWxidCandidates(wxid)
-    const matchedKey = Object.keys(wxidConfigs).find((key) => {
-      const cleanKey = this.cleanAccountDirName(key).toLowerCase()
-      return candidates.some(candidate => cleanKey === candidate.toLowerCase())
-    })
-    const cfg = matchedKey ? wxidConfigs[matchedKey] : undefined
-    const xorKey = this.parseImageXorKey(cfg?.imageXorKey ?? this.configService.get('imageXorKey'))
-    if (!Number.isFinite(xorKey)) return null
-    const aesKey = String(cfg?.imageAesKey ?? this.configService.get('imageAesKey') ?? '').trim()
-    return { xorKey, aesKey: aesKey || undefined }
-  }
-
  private async listFilesForArchive(root: string, rel = '', state = { visited: 0 }): Promise<string[]> {
    const dir = join(root, rel)
    const files: string[] = []
@@ -295,7 +309,7 @@ export class BackupService {
  }

  private resolveExtractedPath(extractDir: string, archivePath: string): string | null {
-    const normalized = String(archivePath || '').replace(/\\/g, '/')
+    const normalized = normalizeArchivePath(archivePath)
    if (!normalized || normalized.startsWith('/') || normalized.split('/').includes('..')) return null
    const root = resolve(extractDir)
    const target = resolve(join(extractDir, normalized))
@@ -303,8 +317,12 @@ export class BackupService {
    return target
  }

+  private resolveStagingPath(stagingDir: string, archivePath: string): string | null {
+    return this.resolveExtractedPath(stagingDir, archivePath)
+  }
+
  private resolveTargetResourcePath(accountDir: string, relativePath: string): string | null {
-    const normalized = String(relativePath || '').replace(/\\/g, '/')
+    const normalized = normalizeArchivePath(relativePath)
    if (!normalized || normalized.startsWith('/') || normalized.split('/').includes('..')) return null
    const root = resolve(accountDir)
    const target = resolve(join(accountDir, normalized))
@@ -351,6 +369,18 @@ export class BackupService {
    }
  }

+  private async writeTarEntryToFile(entry: any, outputPath: string): Promise<void> {
+    mkdirSync(dirname(outputPath), { recursive: true })
+    await new Promise<void>((resolvePromise, rejectPromise) => {
+      const out = createWriteStream(outputPath)
+      const fail = (error: unknown) => rejectPromise(error instanceof Error ? error : new Error(String(error)))
+      out.on('finish', resolvePromise)
+      out.on('error', fail)
+      entry.on('error', fail)
+      entry.pipe(out)
+    })
+  }
+
  private async listChatImageDatFiles(accountDir: string): Promise<string[]> {
    const attachRoot = join(accountDir, 'msg', 'attach')
    const result: string[] = []
@@ -444,7 +474,7 @@ export class BackupService {
  }

  private buildDbId(kind: BackupDbKind, index: number, dbPath: string): string {
-    if (kind === 'session' || kind === 'contact' || kind === 'emoticon' || kind === 'sns') return kind
+    if (kind === 'session' || kind === 'contact' || kind === 'emoticon' || kind === 'sns' || kind === 'hardlink') return kind
    return `${kind}-${index}-${safeName(basename(dbPath)).slice(0, 80)}`
  }

@@ -468,6 +498,7 @@ export class BackupService {
    if (kind === 'contact') return 'contact/contact.db'
    if (kind === 'emoticon') return 'emoticon/emoticon.db'
    if (kind === 'sns') return 'sns/sns.db'
+    if (kind === 'hardlink') return 'hardlink/hardlink.db'
    return null
  }

@@ -517,12 +548,19 @@ export class BackupService {
        join(dirname(dbStorage), 'sns', 'sns.db')
      ])
    }
+    if (kind === 'hardlink') {
+      return this.findFirstExisting([
+        join(dbStorage, 'hardlink', 'hardlink.db'),
+        join(dbStorage, 'hardlink.db'),
+        join(dirname(dbStorage), 'hardlink.db')
+      ])
+    }
    return ''
  }

  private async collectDatabases(dbStorage: string): Promise<Array<Omit<BackupDbEntry, 'tables'>>> {
    const result: Array<Omit<BackupDbEntry, 'tables'>> = []
-    for (const kind of ['session', 'contact', 'emoticon', 'sns'] as const) {
+    for (const kind of ['session', 'contact', 'emoticon', 'sns', 'hardlink'] as const) {
      const dbPath = this.resolveKnownDbPath(kind, dbStorage)
      result.push({
        id: kind,
@@ -565,11 +603,9 @@ export class BackupService {
    manifest: BackupManifest
  ): Promise<void> {
    const accountDir = dirname(connected.dbStorage)
-    const keys = this.getImageKeysForWxid(connected.wxid)
    const imagesDir = join(stagingDir, 'resources', 'images')
    const imagePaths = await this.listChatImageDatFiles(accountDir)
    if (imagePaths.length === 0) return
-    if (!keys) throw new Error('存在图片资源，但未配置图片解密密钥')

    mkdirSync(imagesDir, { recursive: true })
    const resources: BackupResourceEntry[] = []
@@ -580,18 +616,16 @@ export class BackupService {
      if (!relativeTarget) continue
      emitImageProgress({
        phase: 'exporting',
-        message: '正在解密图片资源',
+        message: '正在打包图片资源',
        current: index + 1,
        total: imagePaths.length,
        detail: relativeTarget
      })
-      const decrypted = decryptDatViaNative(sourcePath, keys.xorKey, keys.aesKey)
-      if (!decrypted) continue
-      const archivePath = toArchivePath(join('resources', 'images', `${relativeTarget}${decrypted.ext || '.bin'}`))
+      const archivePath = toArchivePath(join('resources', 'images', relativeTarget))
      const outputPath = join(stagingDir, archivePath)
-      mkdirSync(dirname(outputPath), { recursive: true })
-      await writeFile(outputPath, decrypted.data)
+      await this.stagePlainResource(sourcePath, outputPath)
      const stem = basename(sourcePath).replace(/\.dat$/i, '').toLowerCase()
+      const stat = statSync(sourcePath)
      resources.push({
        kind: 'image',
        id: relativeTarget,
@@ -599,8 +633,7 @@ export class BackupService {
        sourceFileName: basename(sourcePath),
        archivePath,
        targetRelativePath: relativeTarget,
-        ext: decrypted.ext || undefined,
-        size: decrypted.data.length
+        size: stat.size
      })
      if (index % 20 === 0) await delay()
    }
@@ -676,7 +709,7 @@ export class BackupService {
        return { success: false, error: connected.error || '数据库未连接' }
      }

-      stagingDir = await mkdtemp(join(tmpdir(), 'weflow-backup-'))
+      stagingDir = await this.createTempDir('weflow-backup-')
      const snapshotsDir = join(stagingDir, 'snapshots')
      mkdirSync(snapshotsDir, { recursive: true })

@@ -814,7 +847,7 @@ export class BackupService {
    let extractDir = ''
    try {
      emitBackupProgress({ phase: 'inspecting', message: '正在读取备份包' })
-      extractDir = await mkdtemp(join(tmpdir(), 'weflow-backup-inspect-'))
+      extractDir = await this.createTempDir('weflow-backup-inspect-')
      await tar.x({
        file: archivePath,
        cwd: extractDir,
@@ -836,12 +869,119 @@ export class BackupService {
    }
  }

+  private async streamRestoreArchive(
+    archivePath: string,
+    extractDir: string,
+    manifest: BackupManifest,
+    connected: { dbStorage: string; wxid?: string },
+    startCurrent: number,
+    total: number
+  ): Promise<{ current: number; skipped: number }> {
+    const snapshotPaths = new Set<string>()
+    for (const db of manifest.databases || []) {
+      for (const table of db.tables || []) {
+        const path = normalizeArchivePath(table.snapshotPath)
+        if (path) snapshotPaths.add(path)
+      }
+    }
+
+    const imageByPath = new Map<string, BackupResourceEntry>()
+    for (const image of manifest.resources?.images || []) {
+      const path = normalizeArchivePath(image.archivePath)
+      if (path) imageByPath.set(path, image)
+    }
+
+    const plainByPath = new Map<string, BackupResourceEntry>()
+    for (const resource of [
+      ...(manifest.resources?.videos || []),
+      ...(manifest.resources?.files || [])
+    ]) {
+      const path = normalizeArchivePath(resource.archivePath)
+      if (path) plainByPath.set(path, resource)
+    }
+
+    const accountDir = dirname(connected.dbStorage)
+    let current = startCurrent
+    let skipped = 0
+    const pending: Promise<void>[] = []
+    const emitRestoreProgress = createThrottledProgressEmitter(160)
+    await tar.t({
+      file: archivePath,
+      onReadEntry: (entry: any) => {
+        const entryPath = normalizeArchivePath(entry.path)
+        if (snapshotPaths.has(entryPath)) {
+          const outputPath = this.resolveStagingPath(extractDir, entryPath)
+          if (!outputPath) {
+            entry.resume()
+            return
+          }
+          pending.push(this.writeTarEntryToFile(entry, outputPath))
+          return
+        }
+
+        const image = imageByPath.get(entryPath)
+        if (image) {
+          const targetPath = this.resolveTargetResourcePath(accountDir, image.targetRelativePath)
+          if (!targetPath) {
+            skipped += 1
+            entry.resume()
+            return
+          }
+          current += 1
+          emitRestoreProgress({
+            phase: 'restoring',
+            message: '正在写回图片资源',
+            current,
+            total,
+            detail: image.md5 || image.targetRelativePath
+          })
+          if (existsSync(targetPath)) {
+            skipped += 1
+            entry.resume()
+            return
+          }
+          pending.push(this.writeTarEntryToFile(entry, targetPath))
+          return
+        }
+
+        const resource = plainByPath.get(entryPath)
+        if (resource) {
+          const targetPath = this.resolveTargetResourcePath(accountDir, resource.targetRelativePath)
+          current += 1
+          emitRestoreProgress({
+            phase: 'restoring',
+            message: resource.kind === 'video' ? '正在写回视频资源' : '正在写回文件资源',
+            current,
+            total,
+            detail: resource.targetRelativePath
+          })
+          if (!targetPath || existsSync(targetPath)) {
+            skipped += 1
+            entry.resume()
+            return
+          }
+          pending.push(this.writeTarEntryToFile(entry, targetPath))
+          return
+        }
+
+        entry.resume()
+      }
+    } as any)
+
+    await Promise.all(pending)
+    return { current, skipped }
+  }
+
  async restoreBackup(archivePath: string): Promise<{ success: boolean; inserted?: number; ignored?: number; skipped?: number; error?: string }> {
    let extractDir = ''
    try {
-      emitBackupProgress({ phase: 'inspecting', message: '正在解包备份' })
-      extractDir = await mkdtemp(join(tmpdir(), 'weflow-backup-restore-'))
-      await tar.x({ file: archivePath, cwd: extractDir })
+      emitBackupProgress({ phase: 'inspecting', message: '正在读取备份信息' })
+      extractDir = await this.createTempDir('weflow-backup-restore-')
+      await tar.x({
+        file: archivePath,
+        cwd: extractDir,
+        filter: (entryPath: string) => normalizeArchivePath(entryPath) === 'manifest.json'
+      } as any)
      const manifestPath = join(extractDir, 'manifest.json')
      if (!existsSync(manifestPath)) return { success: false, error: '备份包缺少 manifest.json' }
      const manifest = JSON.parse(await readFileAsync(manifestPath, 'utf8')) as BackupManifest
@@ -866,6 +1006,26 @@ export class BackupService {
      let ignored = 0
      let skipped = 0
      let current = 0
+      if (imageJobs.length > 0 || plainResourceJobs.length > 0 || tableJobs.length > 0) {
+        emitBackupProgress({
+          phase: 'inspecting',
+          message: '正在按需读取备份包',
+          current: 0,
+          total: totalRestoreJobs,
+          detail: archivePath
+        })
+        const streamed = await this.streamRestoreArchive(
+          archivePath,
+          extractDir,
+          manifest,
+          { dbStorage: connected.dbStorage, wxid: connected.wxid },
+          0,
+          totalRestoreJobs
+        )
+        current = streamed.current
+        skipped += streamed.skipped
+      }
+
      for (const job of tableJobs) {
        current++
        const targetDbPath = this.resolveRestoreTargetDbPath(connected.dbStorage, job.db)
@@ -907,68 +1067,6 @@ export class BackupService {
        if (current % 4 === 0) await delay()
      }

-      if (imageJobs.length > 0) {
-        const targetWxid = connected.wxid || String(manifest.source?.wxid || '').trim()
-        const imageKeys = this.getImageKeysForWxid(targetWxid)
-        if (!imageKeys) throw new Error('备份包包含图片资源，但目标账号未配置图片加密密钥')
-        const accountDir = dirname(connected.dbStorage)
-        for (const image of imageJobs) {
-          current += 1
-          emitBackupProgress({
-            phase: 'restoring',
-            message: '正在加密并写回图片资源',
-            current,
-            total: totalRestoreJobs,
-            detail: image.md5 || image.targetRelativePath
-          })
-          const inputPath = this.resolveExtractedPath(extractDir, image.archivePath)
-          const targetPath = this.resolveTargetResourcePath(accountDir, image.targetRelativePath)
-          if (!inputPath || !targetPath || !existsSync(inputPath)) {
-            skipped += 1
-            continue
-          }
-          if (existsSync(targetPath)) {
-            skipped += 1
-            continue
-          }
-          const encrypted = encryptDatViaNative(inputPath, imageKeys.xorKey, imageKeys.aesKey)
-          if (!encrypted) {
-            skipped += 1
-            continue
-          }
-          mkdirSync(dirname(targetPath), { recursive: true })
-          await writeFile(targetPath, encrypted)
-          if (current % 16 === 0) await delay()
-        }
-      }
-
-      if (plainResourceJobs.length > 0) {
-        const accountDir = dirname(connected.dbStorage)
-        for (const resource of plainResourceJobs) {
-          current += 1
-          emitBackupProgress({
-            phase: 'restoring',
-            message: resource.kind === 'video' ? '正在写回视频资源' : '正在写回文件资源',
-            current,
-            total: totalRestoreJobs,
-            detail: resource.targetRelativePath
-          })
-          const inputPath = this.resolveExtractedPath(extractDir, resource.archivePath)
-          const targetPath = this.resolveTargetResourcePath(accountDir, resource.targetRelativePath)
-          if (!inputPath || !targetPath || !existsSync(inputPath)) {
-            skipped += 1
-            continue
-          }
-          if (existsSync(targetPath)) {
-            skipped += 1
-            continue
-          }
-          mkdirSync(dirname(targetPath), { recursive: true })
-          await copyFile(inputPath, targetPath)
-          if (current % 30 === 0) await delay()
-        }
-      }
-
      emitBackupProgress({ phase: 'done', message: '载入完成', current: totalRestoreJobs, total: totalRestoreJobs })
      return { success: true, inserted, ignored, skipped }
    } catch (e) {
--- a/electron/services/chatService.ts
+++ b/electron/services/chatService.ts
@@ -666,6 +666,9 @@ class ChatService {
    if (this.connected && wcdbService.isReady()) {
      return { success: true }
    }
+    if (!wcdbService.isReady()) {
+      this.monitorSetup = false
+    }
    const result = await this.connect()
    if (!result.success) {
      this.connected = false
@@ -709,6 +712,7 @@ class ChatService {
      console.error('ChatService: 关闭数据库失败:', e)
    }
    this.connected = false
+    this.monitorSetup = false
  }

  /**
@@ -745,8 +749,12 @@ class ChatService {
    try {
      const connectResult = await this.ensureConnected()
      if (!connectResult.success) return { success: false, error: connectResult.error }
-      const normalizedIds = Array.from(new Set((sessionIds || []).map((id) => String(id || '').trim()).filter(Boolean)))
-      return await wcdbService.checkMessageAntiRevokeTriggers(normalizedIds)
+      const { validIds, invalidRows } = await this.filterAntiRevokeSessionIds(sessionIds)
+      const result = validIds.length > 0
+        ? await wcdbService.checkMessageAntiRevokeTriggers(validIds)
+        : { success: true, rows: [] }
+      if (!result.success) return result
+      return { success: true, rows: [...(result.rows || []), ...invalidRows] }
    } catch (e) {
      return { success: false, error: String(e) }
    }
@@ -760,8 +768,12 @@ class ChatService {
    try {
      const connectResult = await this.ensureConnected()
      if (!connectResult.success) return { success: false, error: connectResult.error }
-      const normalizedIds = Array.from(new Set((sessionIds || []).map((id) => String(id || '').trim()).filter(Boolean)))
-      return await wcdbService.installMessageAntiRevokeTriggers(normalizedIds)
+      const { validIds, invalidRows } = await this.filterAntiRevokeSessionIds(sessionIds)
+      const result = validIds.length > 0
+        ? await wcdbService.installMessageAntiRevokeTriggers(validIds)
+        : { success: true, rows: [] }
+      if (!result.success) return result
+      return { success: true, rows: [...(result.rows || []), ...invalidRows] }
    } catch (e) {
      return { success: false, error: String(e) }
    }
@@ -775,8 +787,12 @@ class ChatService {
    try {
      const connectResult = await this.ensureConnected()
      if (!connectResult.success) return { success: false, error: connectResult.error }
-      const normalizedIds = Array.from(new Set((sessionIds || []).map((id) => String(id || '').trim()).filter(Boolean)))
-      return await wcdbService.uninstallMessageAntiRevokeTriggers(normalizedIds)
+      const { validIds, invalidRows } = await this.filterAntiRevokeSessionIds(sessionIds)
+      const result = validIds.length > 0
+        ? await wcdbService.uninstallMessageAntiRevokeTriggers(validIds)
+        : { success: true, rows: [] }
+      if (!result.success) return result
+      return { success: true, rows: [...(result.rows || []), ...invalidRows] }
    } catch (e) {
      return { success: false, error: String(e) }
    }
@@ -934,6 +950,191 @@ class ChatService {
    }
  }

+  async getAntiRevokeSessions(): Promise<{ success: boolean; sessions?: ChatSession[]; error?: string }> {
+    try {
+      const result = await this.getSessions()
+      if (!result.success || !Array.isArray(result.sessions)) {
+        return { success: false, error: result.error || '获取会话失败' }
+      }
+
+      return {
+        success: true,
+        sessions: result.sessions.filter((session) => !String(session.username || '').startsWith('gh_'))
+      }
+    } catch (e) {
+      console.error('ChatService: 获取防撤回会话列表失败:', e)
+      return { success: false, error: String(e) }
+    }
+  }
+
+  private getSessionUsername(row: Record<string, any>): string {
+    return String(
+      row.username ||
+      row.user_name ||
+      row.userName ||
+      row.usrName ||
+      row.UsrName ||
+      row.talker ||
+      row.talker_id ||
+      row.talkerId ||
+      ''
+    ).trim()
+  }
+
+  private isAntiRevokeContactRow(username: string, row: Record<string, any>): boolean {
+    if (!username) return false
+    if (username.endsWith('@chatroom')) return true
+    if (username.startsWith('gh_')) return false
+
+    const localType = this.getRowInt(row, ['local_type', 'localType', 'WCDB_CT_local_type'], Number.NaN)
+    const lowered = username.toLowerCase()
+    if (this.isEnterpriseOpenimUsername(username)) {
+      return this.isAllowedEnterpriseOpenimByLocalType(username, localType)
+    }
+    if (lowered.startsWith('weixin') && lowered !== 'weixin') return true
+    return localType === 1 && !FRIEND_EXCLUDE_USERNAMES.has(username)
+  }
+
+  private async loadAntiRevokeContactMap(usernames: string[]): Promise<Map<string, { displayName?: string }>> {
+    const targets = Array.from(new Set((usernames || []).map((value) => String(value || '').trim()).filter(Boolean)))
+    const map = new Map<string, { displayName?: string }>()
+    if (targets.length === 0) return map
+
+    try {
+      const contactResult = await wcdbService.getContactsCompact(targets)
+      if (!contactResult.success || !Array.isArray(contactResult.contacts)) return map
+
+      for (const row of contactResult.contacts as Record<string, any>[]) {
+        const username = String(row.username || '').trim()
+        if (!username || !this.isAntiRevokeContactRow(username, row)) continue
+        map.set(username, {
+          displayName: String(row.remark || row.nick_name || row.nickName || row.alias || username).trim()
+        })
+      }
+    } catch {
+      return map
+    }
+
+    return map
+  }
+
+  private async hasAntiRevokeMessageTables(sessionId: string): Promise<boolean> {
+    try {
+      const tableStatsResult = await wcdbService.getMessageTableStats(sessionId)
+      if (!tableStatsResult.success || !Array.isArray(tableStatsResult.tables)) return false
+      return tableStatsResult.tables.some((row: Record<string, any>) => {
+        const tableName = String(row.table_name || row.tableName || '').trim()
+        return tableName.length > 0
+      })
+    } catch {
+      return false
+    }
+  }
+
+  private async buildAntiRevokeSessionsFromRows(rows: Record<string, any>[]): Promise<ChatSession[]> {
+    if (rows.length > 0 && (rows[0]._error || rows[0]._info)) return []
+
+    const candidateRows: Array<{ username: string; row: Record<string, any> }> = []
+    const privateCandidateIds: string[] = []
+    const openimLocalTypeMap = await this.loadContactLocalTypeMapForEnterpriseOpenim(rows.map((row) => this.getSessionUsername(row)))
+
+    for (const row of rows) {
+      const username = this.getSessionUsername(row)
+      if (!username) continue
+
+      let sessionLocalType = this.getSessionLocalType(row)
+      if (!Number.isFinite(sessionLocalType) && this.isEnterpriseOpenimUsername(username)) {
+        sessionLocalType = openimLocalTypeMap.get(username)
+      }
+      if (!this.shouldKeepSession(username, sessionLocalType)) continue
+
+      if (username.endsWith('@chatroom')) {
+        candidateRows.push({ username, row })
+      } else {
+        privateCandidateIds.push(username)
+        candidateRows.push({ username, row })
+      }
+    }
+
+    const contactMap = await this.loadAntiRevokeContactMap(privateCandidateIds)
+    const sessions: ChatSession[] = []
+    const myWxid = this.configService.get('myWxid')
+    const now = Date.now()
+
+    for (const { username, row } of candidateRows) {
+      const isGroup = username.endsWith('@chatroom')
+      if (!isGroup && !contactMap.has(username)) continue
+      if (!await this.hasAntiRevokeMessageTables(username)) continue
+
+      const sortTs = parseInt(
+        row.sort_timestamp ||
+        row.sortTimestamp ||
+        row.sort_time ||
+        row.sortTime ||
+        '0',
+        10
+      )
+      const lastTs = parseInt(
+        row.last_timestamp ||
+        row.lastTimestamp ||
+        row.last_msg_time ||
+        row.lastMsgTime ||
+        String(sortTs),
+        10
+      )
+      const summary = this.cleanString(row.summary || row.digest || row.last_msg || row.lastMsg || '')
+      const lastMsgType = parseInt(row.last_msg_type || row.lastMsgType || '0', 10)
+      const cached = this.avatarCache.get(username)
+      const contact = contactMap.get(username)
+
+      const session: ChatSession = {
+        username,
+        type: parseInt(row.type || '0', 10),
+        unreadCount: parseInt(row.unread_count || row.unreadCount || row.unreadcount || '0', 10),
+        summary: summary || this.getMessageTypeLabel(lastMsgType),
+        sortTimestamp: sortTs,
+        lastTimestamp: lastTs,
+        lastMsgType,
+        displayName: contact?.displayName || cached?.displayName || username,
+        avatarUrl: cached?.avatarUrl,
+        lastMsgSender: row.last_msg_sender,
+        lastSenderDisplayName: row.last_sender_display_name,
+        selfWxid: myWxid
+      }
+
+      const cachedStatus = this.sessionStatusCache.get(username)
+      if (cachedStatus && now - cachedStatus.updatedAt <= this.sessionStatusCacheTtlMs) {
+        session.isFolded = cachedStatus.isFolded
+        session.isMuted = cachedStatus.isMuted
+      }
+
+      sessions.push(session)
+    }
+
+    return sessions
+  }
+
+  private async filterAntiRevokeSessionIds(sessionIds: string[]): Promise<{
+    validIds: string[]
+    invalidRows: Array<{ sessionId: string; success: false; error: string }>
+  }> {
+    const normalizedIds = Array.from(new Set((sessionIds || []).map((id) => String(id || '').trim()).filter(Boolean)))
+    if (normalizedIds.length === 0) return { validIds: [], invalidRows: [] }
+
+    const sessionsResult = await this.getAntiRevokeSessions()
+    const allowedIds = new Set((sessionsResult.sessions || []).map((session) => session.username))
+    const validIds = normalizedIds.filter((sessionId) => allowedIds.has(sessionId))
+    const invalidRows = normalizedIds
+      .filter((sessionId) => !allowedIds.has(sessionId))
+      .map((sessionId) => ({
+        sessionId,
+        success: false as const,
+        error: '该会话不是联系人或群聊，或不存在可安装防撤回的消息表'
+      }))
+
+    return { validIds, invalidRows }
+  }
+
  private async addMissingOfficialSessions(sessions: ChatSession[], myWxid?: string): Promise<void> {
    const existing = new Set(sessions.map((session) => String(session.username || '').trim()).filter(Boolean))
    try {
--- a/electron/services/config.ts
+++ b/electron/services/config.ts
@@ -36,6 +36,7 @@ interface ConfigSchema {
  language: string
  logEnabled: boolean
  launchAtStartup?: boolean
+  silentStartup?: boolean
  llmModelPath: string
  whisperModelName: string
  whisperModelDir: string
@@ -163,6 +164,7 @@ export class ConfigService {
      themeId: 'cloud-dancer',
      language: 'zh-CN',
      logEnabled: false,
+      silentStartup: false,
      llmModelPath: '',
      whisperModelName: 'base',
      whisperModelDir: '',
--- a/electron/services/exportService.ts
+++ b/electron/services/exportService.ts
@@ -200,6 +200,8 @@ interface MediaSourceResolution {
 interface ExportTaskControl {
  shouldPause?: () => boolean
  shouldStop?: () => boolean
+  recordCreatedFile?: (filePath: string) => void
+  recordCreatedDir?: (dirPath: string) => void
 }

 interface ExportStatsResult {
@@ -279,6 +281,7 @@ class ExportService {
  private readonly exportAggregatedSessionStatsCacheTtlMs = 60 * 1000
  private readonly exportStatsCacheMaxEntries = 16
  private readonly STOP_ERROR_CODE = 'WEFLOW_EXPORT_STOP_REQUESTED'
+  private readonly PAUSE_ERROR_CODE = 'WEFLOW_EXPORT_PAUSE_REQUESTED'
  private mediaFileCachePopulatePending = new Map<string, Promise<string | null>>()
  private mediaFileCacheReadyDirs = new Set<string>()
  private mediaExportTelemetry: MediaExportTelemetry | null = null
@@ -311,6 +314,12 @@ class ExportService {
    return error
  }

+  private createPauseError(): Error {
+    const error = new Error('导出任务已暂停')
+    ;(error as Error & { code?: string }).code = this.PAUSE_ERROR_CODE
+    return error
+  }
+
  setRuntimeConfig(config: { dbPath?: string; decryptKey?: string; myWxid?: string } | null): void {
    this.runtimeConfig = config
  }
@@ -453,10 +462,42 @@ class ExportService {
    return false
  }

+  private isPauseError(error: unknown): boolean {
+    if (!error) return false
+    if (typeof error === 'string') {
+      return error.includes(this.PAUSE_ERROR_CODE) || error.includes('导出任务已暂停')
+    }
+    if (error instanceof Error) {
+      const code = (error as Error & { code?: string }).code
+      return code === this.PAUSE_ERROR_CODE || error.message.includes(this.PAUSE_ERROR_CODE) || error.message.includes('导出任务已暂停')
+    }
+    return false
+  }
+
  private throwIfStopRequested(control?: ExportTaskControl): void {
    if (control?.shouldStop?.()) {
      throw this.createStopError()
    }
+    if (control?.shouldPause?.()) {
+      throw this.createPauseError()
+    }
+  }
+
+  private async ensureExportDir(dirPath: string, control?: ExportTaskControl, dirCache?: Set<string>): Promise<void> {
+    if (dirCache?.has(dirPath)) return
+    const existed = await this.pathExists(dirPath)
+    await fs.promises.mkdir(dirPath, { recursive: true })
+    dirCache?.add(dirPath)
+    if (!existed) {
+      control?.recordCreatedDir?.(dirPath)
+    }
+  }
+
+  private async recordCreatedFileBeforeWrite(filePath: string, control?: ExportTaskControl): Promise<void> {
+    if (!control?.recordCreatedFile) return
+    if (!await this.pathExists(filePath)) {
+      control.recordCreatedFile(filePath)
+    }
  }

  private getClampedConcurrency(value: number | undefined, fallback = 2, max = 6): number {
@@ -850,8 +891,10 @@ class ExportService {
  private async copyMediaWithCacheAndDedup(
    kind: 'image' | 'video' | 'emoji',
    sourcePath: string,
-    destPath: string
+    destPath: string,
+    control?: ExportTaskControl
  ): Promise<{ success: boolean; code?: string }> {
+    const existedBeforeCopy = await this.pathExists(destPath)
    const resolved = await this.resolvePreferredMediaSource(kind, sourcePath)
    if (resolved.cacheHit) {
      this.noteMediaTelemetry({ cacheHitFiles: 1 })
@@ -870,6 +913,9 @@ class ExportService {
          dedupReuseFiles: 1,
          bytesWritten: resolved.fileStat?.size || 0
        })
+        if (!existedBeforeCopy) {
+          control?.recordCreatedFile?.(destPath)
+        }
        return { success: true }
      }
    }
@@ -886,6 +932,9 @@ class ExportService {
      doneFiles: 1,
      bytesWritten: resolved.fileStat?.size || 0
    })
+    if (!existedBeforeCopy) {
+      control?.recordCreatedFile?.(destPath)
+    }
    return { success: true }
  }

@@ -3962,6 +4011,7 @@ class ExportService {
      includeVideoPoster?: boolean
      includeVoiceWithTranscript?: boolean
      dirCache?: Set<string>
+      control?: ExportTaskControl
    }
  ): Promise<MediaExportItem | null> {
    const localType = msg.localType
@@ -3973,7 +4023,8 @@ class ExportService {
        sessionId,
        mediaRootDir,
        mediaRelativePrefix,
-        options.dirCache
+        options.dirCache,
+        options.control
      )
      if (result) {
      }
@@ -3983,7 +4034,7 @@ class ExportService {
    // 语音消息
    if (localType === 34) {
      if (options.exportVoices) {
-        return this.exportVoice(msg, sessionId, mediaRootDir, mediaRelativePrefix, options.dirCache)
+        return this.exportVoice(msg, sessionId, mediaRootDir, mediaRelativePrefix, options.dirCache, options.control)
      }
      if (options.exportVoiceAsText) {
        return null
@@ -3992,7 +4043,7 @@ class ExportService {

    // 动画表情
    if (localType === 47 && options.exportEmojis) {
-      const result = await this.exportEmoji(msg, sessionId, mediaRootDir, mediaRelativePrefix, options.dirCache)
+      const result = await this.exportEmoji(msg, sessionId, mediaRootDir, mediaRelativePrefix, options.dirCache, options.control)
      if (result) {
      }
      return result
@@ -4005,7 +4056,8 @@ class ExportService {
        mediaRootDir,
        mediaRelativePrefix,
        options.dirCache,
-        options.includeVideoPoster === true
+        options.includeVideoPoster === true,
+        options.control
      )
    }

@@ -4015,7 +4067,8 @@ class ExportService {
        mediaRootDir,
        mediaRelativePrefix,
        options.maxFileSizeMb,
-        options.dirCache
+        options.dirCache,
+        options.control
      )
    }

@@ -4030,14 +4083,12 @@ class ExportService {
    sessionId: string,
    mediaRootDir: string,
    mediaRelativePrefix: string,
-    dirCache?: Set<string>
+    dirCache?: Set<string>,
+    control?: ExportTaskControl
  ): Promise<MediaExportItem | null> {
    try {
      const imagesDir = path.join(mediaRootDir, mediaRelativePrefix, 'images')
-      if (!dirCache?.has(imagesDir)) {
-        await fs.promises.mkdir(imagesDir, { recursive: true })
-        dirCache?.add(imagesDir)
-      }
+      await this.ensureExportDir(imagesDir, control, dirCache)

      const tryResolveImagePath = async (imageMd5?: string, imageDatName?: string): Promise<string | null> => {
        if (!imageMd5 && !imageDatName) return null
@@ -4123,6 +4174,7 @@ class ExportService {
        const destPath = path.join(imagesDir, fileName)

        const buffer = Buffer.from(base64Data, 'base64')
+        await this.recordCreatedFileBeforeWrite(destPath, control)
        await fs.promises.writeFile(destPath, buffer)
        this.noteMediaTelemetry({
          doneFiles: 1,
@@ -4142,7 +4194,7 @@ class ExportService {
      const ext = path.extname(sourcePath) || '.jpg'
      const fileName = `${messageId}_${imageKey}${ext}`
      const destPath = path.join(imagesDir, fileName)
-      const copied = await this.copyMediaWithCacheAndDedup('image', sourcePath, destPath)
+      const copied = await this.copyMediaWithCacheAndDedup('image', sourcePath, destPath, control)
      if (!copied.success) {
        if (copied.code === 'ENOENT') {
          console.log(`[Export] 源图片文件不存在 (localId=${msg.localId}): ${sourcePath} → 将显示 [图片] 占位符`)
@@ -4261,14 +4313,12 @@ class ExportService {
    sessionId: string,
    mediaRootDir: string,
    mediaRelativePrefix: string,
-    dirCache?: Set<string>
+    dirCache?: Set<string>,
+    control?: ExportTaskControl
  ): Promise<MediaExportItem | null> {
    try {
      const voicesDir = path.join(mediaRootDir, mediaRelativePrefix, 'voices')
-      if (!dirCache?.has(voicesDir)) {
-        await fs.promises.mkdir(voicesDir, { recursive: true })
-        dirCache?.add(voicesDir)
-      }
+      await this.ensureExportDir(voicesDir, control, dirCache)

      const msgId = String(msg.localId)
      const safeSession = this.cleanAccountDirName(sessionId)
@@ -4300,6 +4350,7 @@ class ExportService {

      // voiceResult.data 是 base64 编码的 wav 数据
      const wavBuffer = Buffer.from(voiceResult.data, 'base64')
+      await this.recordCreatedFileBeforeWrite(destPath, control)
      await fs.promises.writeFile(destPath, wavBuffer)
      this.noteMediaTelemetry({
        doneFiles: 1,
@@ -4338,14 +4389,12 @@ class ExportService {
    sessionId: string,
    mediaRootDir: string,
    mediaRelativePrefix: string,
-    dirCache?: Set<string>
+    dirCache?: Set<string>,
+    control?: ExportTaskControl
  ): Promise<MediaExportItem | null> {
    try {
      const emojisDir = path.join(mediaRootDir, mediaRelativePrefix, 'emojis')
-      if (!dirCache?.has(emojisDir)) {
-        await fs.promises.mkdir(emojisDir, { recursive: true })
-        dirCache?.add(emojisDir)
-      }
+      await this.ensureExportDir(emojisDir, control, dirCache)

      // 使用 chatService 下载表情包 (利用其重试和 fallback 逻辑)
      const localPath = await chatService.downloadEmojiFile(msg)
@@ -4359,7 +4408,7 @@ class ExportService {
      const key = msg.emojiMd5 || String(msg.localId)
      const fileName = `${key}${ext}`
      const destPath = path.join(emojisDir, fileName)
-      const copied = await this.copyMediaWithCacheAndDedup('emoji', localPath, destPath)
+      const copied = await this.copyMediaWithCacheAndDedup('emoji', localPath, destPath, control)
      if (!copied.success) return null

      return {
@@ -4381,7 +4430,8 @@ class ExportService {
    mediaRootDir: string,
    mediaRelativePrefix: string,
    dirCache?: Set<string>,
-    includePoster = false
+    includePoster = false,
+    control?: ExportTaskControl
  ): Promise<MediaExportItem | null> {
    try {
      let videoMd5 = String(msg.videoMd5 || '').trim().toLowerCase()
@@ -4404,16 +4454,13 @@ class ExportService {
      if (!videoInfo) return null

      const videosDir = path.join(mediaRootDir, mediaRelativePrefix, 'videos')
-      if (!dirCache?.has(videosDir)) {
-        await fs.promises.mkdir(videosDir, { recursive: true })
-        dirCache?.add(videosDir)
-      }
+      await this.ensureExportDir(videosDir, control, dirCache)

      const sourcePath = videoInfo.videoUrl
      const fileName = path.basename(sourcePath)
      const destPath = path.join(videosDir, fileName)

-      const copied = await this.copyMediaWithCacheAndDedup('video', sourcePath, destPath)
+      const copied = await this.copyMediaWithCacheAndDedup('video', sourcePath, destPath, control)
      if (!copied.success) return null

      return {
@@ -4864,7 +4911,8 @@ class ExportService {
    mediaRootDir: string,
    mediaRelativePrefix: string,
    maxFileSizeMb?: number,
-    dirCache?: Set<string>
+    dirCache?: Set<string>,
+    control?: ExportTaskControl
  ): Promise<MediaExportItem | null> {
    try {
      const fileNameRaw = String(msg?.fileName || '').trim()
@@ -4872,10 +4920,7 @@ class ExportService {

      const fileExtDir = this.resolveFileAttachmentExtensionDir(msg, fileNameRaw)
      const fileDir = path.join(mediaRootDir, mediaRelativePrefix, 'file', fileExtDir)
-      if (!dirCache?.has(fileDir)) {
-        await fs.promises.mkdir(fileDir, { recursive: true })
-        dirCache?.add(fileDir)
-      }
+      await this.ensureExportDir(fileDir, control, dirCache)

      const candidates = await this.resolveFileAttachmentCandidates(msg)
      if (candidates.length === 0) {
@@ -4919,6 +4964,7 @@ class ExportService {
      const messageId = String(msg?.localId || Date.now())
      const destFileName = `${messageId}_${safeBaseName}`
      const destPath = path.join(fileDir, destFileName)
+      const existedBeforeCopy = await this.pathExists(destPath)
      const copied = await this.copyFileOptimized(selected.sourcePath, destPath)
      if (!copied.success) {
        this.recordFileAttachmentMiss(msg, '附件复制失败', {
@@ -4929,6 +4975,9 @@ class ExportService {
        return null
      }

+      if (!existedBeforeCopy) {
+        control?.recordCreatedFile?.(destPath)
+      }
      this.noteMediaTelemetry({ doneFiles: 1, bytesWritten: stat.size })
      return {
        relativePath: path.posix.join(mediaRelativePrefix, 'file', fileExtDir, destFileName),
@@ -5884,16 +5933,15 @@ class ExportService {
   */
  private async exportAvatarsToFiles(
    members: Array<{ username: string; avatarUrl?: string }>,
-    outputDir: string
+    outputDir: string,
+    control?: ExportTaskControl
  ): Promise<Map<string, string>> {
    const result = new Map<string, string>()
    if (members.length === 0) return result

    // 创建 avatars 子目录
    const avatarsDir = path.join(outputDir, 'avatars')
-    if (!fs.existsSync(avatarsDir)) {
-      fs.mkdirSync(avatarsDir, { recursive: true })
-    }
+    await this.ensureExportDir(avatarsDir, control)

    const AVATAR_CONCURRENCY = 8
    await parallelLimit(members, AVATAR_CONCURRENCY, async (member) => {
@@ -5934,6 +5982,7 @@ class ExportService {
        try {
          await fs.promises.access(avatarPath)
        } catch {
+          await this.recordCreatedFileBeforeWrite(avatarPath, control)
          await fs.promises.writeFile(avatarPath, data)
        }

@@ -6202,7 +6251,8 @@ class ExportService {
              maxFileSizeMb: options.maxFileSizeMb,
              exportVoiceAsText: options.exportVoiceAsText,
              includeVideoPoster: options.format === 'html',
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -6551,9 +6601,11 @@ class ExportService {
          lines.push(JSON.stringify({ _type: 'message', ...message }))
        }
        this.throwIfStopRequested(control)
+        await this.recordCreatedFileBeforeWrite(outputPath, control)
        await fs.promises.writeFile(outputPath, lines.join('\n'), 'utf-8')
      } else {
        this.throwIfStopRequested(control)
+        await this.recordCreatedFileBeforeWrite(outputPath, control)
        await fs.promises.writeFile(outputPath, JSON.stringify(chatLabExport, null, 2), 'utf-8')
      }

@@ -6573,6 +6625,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      return { success: false, error: String(e) }
    }
  }
@@ -6706,7 +6761,8 @@ class ExportService {
              maxFileSizeMb: options.maxFileSizeMb,
              exportVoiceAsText: options.exportVoiceAsText,
              includeVideoPoster: options.format === 'html',
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -7256,6 +7312,7 @@ class ExportService {
        }

        this.throwIfStopRequested(control)
+        await this.recordCreatedFileBeforeWrite(outputPath, control)
        await fs.promises.writeFile(outputPath, JSON.stringify(arkmeExport, null, 2), 'utf-8')
      } else {
        const detailedExport: any = {
@@ -7279,6 +7336,7 @@ class ExportService {
        }

        this.throwIfStopRequested(control)
+        await this.recordCreatedFileBeforeWrite(outputPath, control)
        await fs.promises.writeFile(outputPath, JSON.stringify(detailedExport, null, 2), 'utf-8')
      }

@@ -7298,6 +7356,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      return { success: false, error: String(e) }
    }
  }
@@ -7571,7 +7632,8 @@ class ExportService {
              maxFileSizeMb: options.maxFileSizeMb,
              exportVoiceAsText: options.exportVoiceAsText,
              includeVideoPoster: options.format === 'html',
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -7835,6 +7897,7 @@ class ExportService {

      // 写入文件
      this.throwIfStopRequested(control)
+      await this.recordCreatedFileBeforeWrite(outputPath, control)
      await workbook.xlsx.writeFile(outputPath)

      onProgress?.({
@@ -7853,6 +7916,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      // 处理文件被占用的错误
      if (e instanceof Error) {
        if (e.message.includes('EBUSY') || e.message.includes('resource busy') || e.message.includes('locked')) {
@@ -8134,6 +8200,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      if (e instanceof Error) {
        if (e.message.includes('EBUSY') || e.message.includes('resource busy') || e.message.includes('locked')) {
          return { success: false, error: '文件已经打开，请关闭后再导出' }
@@ -8315,7 +8384,8 @@ class ExportService {
              maxFileSizeMb: options.maxFileSizeMb,
              exportVoiceAsText: options.exportVoiceAsText,
              includeVideoPoster: options.format === 'html',
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -8382,6 +8452,7 @@ class ExportService {
        exportedMessages: 0
      })

+      await this.recordCreatedFileBeforeWrite(outputPath, control)
      const stream = fs.createWriteStream(outputPath, { encoding: 'utf-8' })
      const writeChunk = async (chunk: string): Promise<void> => {
        await new Promise<void>((resolve, _reject) => {
@@ -8567,6 +8638,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      return { success: false, error: String(e) }
    }
  }
@@ -8710,7 +8784,8 @@ class ExportService {
              maxFileSizeMb: options.maxFileSizeMb,
              exportVoiceAsText: options.exportVoiceAsText,
              includeVideoPoster: options.format === 'html',
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -8777,6 +8852,7 @@ class ExportService {
        exportedMessages: 0
      })

+      await this.recordCreatedFileBeforeWrite(outputPath, control)
      const stream = fs.createWriteStream(outputPath, { encoding: 'utf-8' })
      const writeChunk = async (chunk: string): Promise<void> => {
        await new Promise<void>((resolve, _reject) => {
@@ -8929,6 +9005,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      return { success: false, error: String(e) }
    }
  }
@@ -9153,7 +9232,8 @@ class ExportService {
              includeVideoPoster: options.format === 'html',
              includeVoiceWithTranscript: true,
              exportVideos: options.exportVideos,
-              dirCache: mediaDirCache
+              dirCache: mediaDirCache,
+              control
            })
            mediaCache.set(mediaKey, mediaItem)
          }
@@ -9224,7 +9304,8 @@ class ExportService {
            { username: sessionId, avatarUrl: sessionInfo.avatarUrl },
            { username: cleanedMyWxid, avatarUrl: myInfo.avatarUrl }
          ],
-          path.dirname(outputPath)
+          path.dirname(outputPath),
+          control
        )
        : new Map<string, string>()

@@ -9241,6 +9322,7 @@ class ExportService {
      // ================= BEGIN STREAM WRITING =================
      const exportMeta = this.getExportMeta(sessionId, sessionInfo, isGroup)
      const htmlStyles = this.loadExportHtmlStyles()
+      await this.recordCreatedFileBeforeWrite(outputPath, control)
      const stream = fs.createWriteStream(outputPath, { encoding: 'utf-8' })

      const writePromise = (str: string) => {
@@ -9605,6 +9687,9 @@ class ExportService {
      if (this.isStopError(e)) {
        return { success: false, error: '导出任务已停止' }
      }
+      if (this.isPauseError(e)) {
+        return { success: false, error: '导出任务已暂停' }
+      }
      return { success: false, error: String(e) }
    }
  }
@@ -9908,7 +9993,7 @@ class ExportService {
      const reservedOutputPaths = new Set<string>()
      const ensureTaskDir = async (dirPath: string) => {
        if (createdTaskDirs.has(dirPath)) return
-        await fs.promises.mkdir(dirPath, { recursive: true })
+        await this.ensureExportDir(dirPath, control)
        createdTaskDirs.add(dirPath)
      }
      await ensureTaskDir(exportBaseDir)
@@ -10085,7 +10170,7 @@ class ExportService {
        }
      }

-      const runOne = async (sessionId: string): Promise<'done' | 'stopped'> => {
+      const runOne = async (sessionId: string): Promise<'done' | 'stopped' | 'paused'> => {
        try {
          this.throwIfStopRequested(control)
          const sessionInfo = await this.getContactInfo(sessionId)
@@ -10234,6 +10319,10 @@ class ExportService {
            activeSessionRatios.delete(sessionId)
            return 'stopped'
          }
+          if (!result.success && this.isPauseError(result.error)) {
+            activeSessionRatios.delete(sessionId)
+            return 'paused'
+          }

          if (result.success) {
            successCount++
@@ -10269,6 +10358,10 @@ class ExportService {
            activeSessionRatios.delete(sessionId)
            return 'stopped'
          }
+          if (this.isPauseError(error)) {
+            activeSessionRatios.delete(sessionId)
+            return 'paused'
+          }
          throw error
        }
      }
@@ -10294,6 +10387,11 @@ class ExportService {
            queue.unshift(sessionId)
            break
          }
+          if (runState === 'paused') {
+            pauseRequested = true
+            queue.unshift(sessionId)
+            break
+          }
        }
      } else {
        const workers = Array.from({ length: Math.min(sessionConcurrency, queue.length) }, async () => {
@@ -10315,6 +10413,11 @@ class ExportService {
              queue.unshift(sessionId)
              break
            }
+            if (runState === 'paused') {
+              pauseRequested = true
+              queue.unshift(sessionId)
+              break
+            }
          }
        })
        await Promise.all(workers)
@@ -10333,7 +10436,7 @@ class ExportService {
          sessionOutputPaths
        }
      }
-      if (pauseRequested && pendingSessionIds.length > 0) {
+      if (pauseRequested) {
        return {
          success: true,
          successCount,
--- a/electron/services/exportTaskControlService.ts
+++ b/electron/services/exportTaskControlService.ts
@@ -0,0 +1,210 @@
+import * as path from 'path'
+import { rm, rmdir } from 'fs/promises'
+
+export type ExportTaskControlState = 'running' | 'pause_requested' | 'cancel_requested'
+
+export interface ExportTaskControlHooks {
+  shouldPause: () => boolean
+  shouldStop: () => boolean
+  recordCreatedFile: (filePath: string) => void
+  recordCreatedDir: (dirPath: string) => void
+}
+
+interface ExportTaskManifest {
+  outputDir: string
+  files: Set<string>
+  dirs: Set<string>
+}
+
+interface ExportTaskControlRecord {
+  state: ExportTaskControlState
+  manifest: ExportTaskManifest
+  createdAt: number
+  updatedAt: number
+}
+
+export interface ExportTaskCleanupResult {
+  success: boolean
+  filesDeleted: number
+  dirsDeleted: number
+  error?: string
+}
+
+class ExportTaskControlService {
+  private tasks = new Map<string, ExportTaskControlRecord>()
+
+  createControl(taskId: string, outputDir: string): ExportTaskControlHooks {
+    this.registerTask(taskId, outputDir)
+    return {
+      shouldPause: () => this.getState(taskId) === 'pause_requested',
+      shouldStop: () => this.getState(taskId) === 'cancel_requested',
+      recordCreatedFile: (filePath: string) => this.recordCreatedFile(taskId, filePath),
+      recordCreatedDir: (dirPath: string) => this.recordCreatedDir(taskId, dirPath)
+    }
+  }
+
+  registerTask(taskId: string, outputDir: string): void {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    if (!normalizedTaskId) return
+
+    const normalizedOutputDir = path.resolve(String(outputDir || '').trim() || '.')
+    const existing = this.tasks.get(normalizedTaskId)
+    if (existing) {
+      existing.state = 'running'
+      existing.updatedAt = Date.now()
+      if (!existing.manifest.outputDir) {
+        existing.manifest.outputDir = normalizedOutputDir
+      }
+      return
+    }
+
+    this.tasks.set(normalizedTaskId, {
+      state: 'running',
+      manifest: {
+        outputDir: normalizedOutputDir,
+        files: new Set<string>(),
+        dirs: new Set<string>()
+      },
+      createdAt: Date.now(),
+      updatedAt: Date.now()
+    })
+  }
+
+  pauseTask(taskId: string): boolean {
+    return this.setState(taskId, 'pause_requested')
+  }
+
+  resumeTask(taskId: string): boolean {
+    return this.setState(taskId, 'running')
+  }
+
+  cancelTask(taskId: string): boolean {
+    return this.setState(taskId, 'cancel_requested')
+  }
+
+  getState(taskId: string): ExportTaskControlState | null {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    if (!normalizedTaskId) return null
+    return this.tasks.get(normalizedTaskId)?.state || null
+  }
+
+  releaseTask(taskId: string): void {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    if (!normalizedTaskId) return
+    this.tasks.delete(normalizedTaskId)
+  }
+
+  recordCreatedFile(taskId: string, filePath: string): void {
+    const task = this.getTaskForManifestWrite(taskId, filePath)
+    if (!task) return
+    task.manifest.files.add(path.resolve(filePath))
+    task.updatedAt = Date.now()
+  }
+
+  recordCreatedDir(taskId: string, dirPath: string): void {
+    const task = this.getTaskForManifestWrite(taskId, dirPath)
+    if (!task) return
+    task.manifest.dirs.add(path.resolve(dirPath))
+    task.updatedAt = Date.now()
+  }
+
+  async cleanupTask(taskId: string): Promise<ExportTaskCleanupResult> {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    const task = normalizedTaskId ? this.tasks.get(normalizedTaskId) : undefined
+    if (!task) {
+      return { success: true, filesDeleted: 0, dirsDeleted: 0 }
+    }
+
+    const outputDir = task.manifest.outputDir
+    let filesDeleted = 0
+    let dirsDeleted = 0
+    const errors: string[] = []
+
+    const files = Array.from(task.manifest.files)
+      .filter(filePath => this.isInsideOutputDir(filePath, outputDir))
+      .sort((a, b) => b.length - a.length)
+
+    for (const filePath of files) {
+      try {
+        await rm(filePath, { force: true, recursive: false })
+        filesDeleted++
+      } catch (error) {
+        const code = (error as NodeJS.ErrnoException | undefined)?.code
+        if (code !== 'ENOENT') {
+          errors.push(`${filePath}: ${error instanceof Error ? error.message : String(error)}`)
+        }
+      }
+    }
+
+    const dirs = Array.from(task.manifest.dirs)
+      .filter(dirPath => this.isInsideOutputDir(dirPath, outputDir) || this.isSamePath(dirPath, outputDir))
+      .sort((a, b) => b.length - a.length)
+
+    for (const dirPath of dirs) {
+      try {
+        await rmdir(dirPath)
+        dirsDeleted++
+      } catch (error) {
+        const code = (error as NodeJS.ErrnoException | undefined)?.code
+        if (code !== 'ENOENT' && code !== 'ENOTEMPTY' && code !== 'EEXIST') {
+          errors.push(`${dirPath}: ${error instanceof Error ? error.message : String(error)}`)
+        }
+      }
+    }
+
+    if (errors.length === 0) {
+      this.releaseTask(normalizedTaskId)
+      return { success: true, filesDeleted, dirsDeleted }
+    }
+
+    return {
+      success: false,
+      filesDeleted,
+      dirsDeleted,
+      error: errors.slice(0, 3).join('; ')
+    }
+  }
+
+  private setState(taskId: string, state: ExportTaskControlState): boolean {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    if (!normalizedTaskId) return false
+    const task = this.tasks.get(normalizedTaskId)
+    if (!task) return false
+    task.state = state
+    task.updatedAt = Date.now()
+    return true
+  }
+
+  private getTaskForManifestWrite(taskId: string, targetPath: string): ExportTaskControlRecord | null {
+    const normalizedTaskId = this.normalizeTaskId(taskId)
+    if (!normalizedTaskId) return null
+    const task = this.tasks.get(normalizedTaskId)
+    if (!task) return null
+    if (!this.isInsideOutputDir(targetPath, task.manifest.outputDir) && !this.isSamePath(targetPath, task.manifest.outputDir)) {
+      return null
+    }
+    return task
+  }
+
+  private isInsideOutputDir(targetPath: string, outputDir: string): boolean {
+    const resolvedTarget = path.resolve(targetPath)
+    const resolvedOutputDir = path.resolve(outputDir)
+    const relativePath = path.relative(resolvedOutputDir, resolvedTarget)
+    return Boolean(relativePath) && !relativePath.startsWith('..') && !path.isAbsolute(relativePath)
+  }
+
+  private isSamePath(left: string, right: string): boolean {
+    const resolvedLeft = path.resolve(left)
+    const resolvedRight = path.resolve(right)
+    if (process.platform === 'win32') {
+      return resolvedLeft.toLowerCase() === resolvedRight.toLowerCase()
+    }
+    return resolvedLeft === resolvedRight
+  }
+
+  private normalizeTaskId(taskId: string): string {
+    return String(taskId || '').trim()
+  }
+}
+
+export const exportTaskControlService = new ExportTaskControlService()
--- a/electron/services/keyServiceLinux.ts
+++ b/electron/services/keyServiceLinux.ts
@@ -167,7 +167,7 @@ export class KeyServiceLinux {

      await new Promise(r => setTimeout(r, 2000))

-      return await this.getDbKey(pid, onStatus)
+      return await this.getDbKey(pid, onStatus, timeoutMs)
    } catch (err: any) {
      console.error('[Debug] 自动获取流程彻底崩溃:', err);
      const errMsg = '自动获取微信 PID 失败: ' + err.message
@@ -176,7 +176,7 @@ export class KeyServiceLinux {
    }
  }

-  public async getDbKey(pid: number, onStatus?: (message: string, level: number) => void): Promise<DbKeyResult> {
+  public async getDbKey(pid: number, onStatus?: (message: string, level: number) => void, timeoutMs = 180_000): Promise<DbKeyResult> {
    try {
      const helperPath = this.getHelperPath()

@@ -200,28 +200,56 @@ export class KeyServiceLinux {
      }

      return await new Promise((resolve) => {
-        const options = { name: 'WeFlow' }
-        const command = `"${helperPath}" db_hook ${pid} ${targetAddr}`
+        const options = {
+          name: 'WeFlow',
+          env: {
+            PATH: `${process.env.PATH || ''}:/bin:/usr/bin:/sbin:/usr/sbin:/usr/local/bin`
+          }
+        }
+        const timeoutSec = Math.ceil((timeoutMs + 15_000) / 1000)
+        const command = `timeout -k 5s ${timeoutSec}s "${helperPath}" db_hook ${pid} ${targetAddr} ${timeoutMs}`
+        let settled = false
+        const finish = (result: DbKeyResult) => {
+          if (settled) return
+          settled = true
+          clearTimeout(watchdog)
+          resolve(result)
+        }
+        const watchdog = setTimeout(() => {
+          execAsync(`kill -CONT ${pid}`).catch(() => {})
+          const err = `Hook 等待超时（${Math.round(timeoutMs / 1000)} 秒）。请确认微信登录确认已完成，或重启微信后重试。`
+          onStatus?.(err, 2)
+          finish({ success: false, error: err })
+        }, timeoutMs + 30_000)

-        this.sudo.exec(command, options, (error, stdout) => {
+        onStatus?.('授权通过后请在手机上确认登录微信，正在等待密钥回调...', 0)
+
+        this.sudo.exec(command, options, (error, stdout, stderr) => {
          execAsync(`kill -CONT ${pid}`).catch(() => {})
          if (error) {
-            onStatus?.('授权失败或被取消', 2)
-            resolve({ success: false, error: `授权失败或被取消: ${error.message}` })
+            const detail = String(stderr || '').trim()
+            const message = detail ? `${error.message}: ${detail}` : error.message
+            onStatus?.('授权失败或 Hook 执行失败', 2)
+            finish({ success: false, error: `授权失败或 Hook 执行失败: ${message}` })
            return
          }
          try {
-            const hookRes = JSON.parse((stdout as string).trim())
+            const output = String(stdout || '').trim()
+            if (!output) {
+              const detail = String(stderr || '').trim()
+              throw new Error(detail ? `Hook 无输出: ${detail}` : 'Hook 无输出')
+            }
+            const hookRes = JSON.parse(output)
            if (hookRes.success) {
              onStatus?.('密钥获取成功', 1)
-              resolve({ success: true, key: hookRes.key })
+              finish({ success: true, key: hookRes.key })
            } else {
              onStatus?.(hookRes.result, 2)
-              resolve({ success: false, error: hookRes.result })
+              finish({ success: false, error: hookRes.result })
            }
-          } catch (e) {
+          } catch (e: any) {
            onStatus?.('解析 Hook 结果失败', 2)
-            resolve({ success: false, error: '解析 Hook 结果失败' })
+            finish({ success: false, error: e?.message || '解析 Hook 结果失败' })
          }
        })
      })
--- a/electron/services/keyServiceMac.ts
+++ b/electron/services/keyServiceMac.ts
@@ -707,7 +707,7 @@ export class KeyServiceMac {
    }
    if (code === 'HOOK_FAILED') {
      if (normalizedDetail.includes('HOOK_TIMEOUT')) {
-        return 'Hook 已安装，但在等待时间内未触发目标函数。请保持微信前台并执行一次会话/数据库访问后重试。'
+        return 'Hook 已安装，但在等待时间内未触发登录流程。请退出微信账号后重新登录，或在未登录状态下直接登录微信，完成一次登录流程后重试。'
      }
      if (normalizedDetail.includes('attach_wait_timeout')) {
        return '附加调试器超时，未能进入 Hook 阶段。请确认微信处于可交互状态并重试。'
--- a/electron/services/nativeImageDecrypt.ts
+++ b/electron/services/nativeImageDecrypt.ts
@@ -6,11 +6,30 @@ type NativeDecryptResult = {
  ext: string
  isWxgf?: boolean
  is_wxgf?: boolean
+  version?: number
+  aesSize?: number
+  aes_size?: number
+  xorSize?: number
+  xor_size?: number
+  rawSize?: number
+  raw_size?: number
+  flag?: number
+}
+
+export type NativeDatMeta = {
+  version?: number
+  aesSize?: number
+  aes_size?: number
+  xorSize?: number
+  xor_size?: number
+  rawSize?: number
+  raw_size?: number
+  flag?: number
 }

 type NativeAddon = {
  decryptDatNative: (inputPath: string, xorKey: number, aesKey?: string) => NativeDecryptResult
-  encryptDatNative?: (inputPath: string, xorKey: number, aesKey?: string) => Buffer
+  encryptDatNative?: (inputPath: string, xorKey: number, aesKey?: string, meta?: NativeDatMeta) => Buffer
 }

 let cachedAddon: NativeAddon | null | undefined
@@ -92,7 +111,7 @@ export function decryptDatViaNative(
  inputPath: string,
  xorKey: number,
  aesKey?: string
-): { data: Buffer; ext: string; isWxgf: boolean } | null {
+): { data: Buffer; ext: string; isWxgf: boolean; meta: NativeDatMeta } | null {
  const addon = loadAddon()
  if (!addon) return null

@@ -104,7 +123,14 @@ export function decryptDatViaNative(
      ? result.ext.trim().toLowerCase()
      : ''
    const ext = rawExt ? (rawExt.startsWith('.') ? rawExt : `.${rawExt}`) : ''
-    return { data: result.data, ext, isWxgf }
+    const meta: NativeDatMeta = {
+      version: result.version,
+      aes_size: result.aes_size ?? result.aesSize,
+      xor_size: result.xor_size ?? result.xorSize,
+      raw_size: result.raw_size ?? result.rawSize,
+      flag: result.flag
+    }
+    return { data: result.data, ext, isWxgf, meta }
  } catch {
    return null
  }
@@ -113,13 +139,14 @@ export function decryptDatViaNative(
 export function encryptDatViaNative(
  inputPath: string,
  xorKey: number,
-  aesKey?: string
+  aesKey?: string,
+  meta?: NativeDatMeta
 ): Buffer | null {
  const addon = loadAddon()
  if (!addon || typeof addon.encryptDatNative !== 'function') return null

  try {
-    const result = addon.encryptDatNative(inputPath, xorKey, aesKey)
+    const result = addon.encryptDatNative(inputPath, xorKey, aesKey, meta)
    return Buffer.isBuffer(result) ? result : null
  } catch {
    return null
--- a/electron/services/snsService.ts
+++ b/electron/services/snsService.ts
@@ -1340,6 +1340,8 @@ class SnsService {
    }, progressCallback?: (progress: { current: number; total: number; status: string }) => void, control?: {
        shouldPause?: () => boolean
        shouldStop?: () => boolean
+        recordCreatedFile?: (filePath: string) => void
+        recordCreatedDir?: (dirPath: string) => void
    }): Promise<{ success: boolean; filePath?: string; postCount?: number; mediaCount?: number; paused?: boolean; stopped?: boolean; error?: string }> {
        const { outputDir, format, usernames, keyword, startTime, endTime } = options
        const hasExplicitMediaSelection =
@@ -1361,6 +1363,18 @@ class SnsService {
            if (control?.shouldPause?.()) return 'paused'
            return null
        }
+        const ensureExportDir = (dirPath: string) => {
+            const existed = existsSync(dirPath)
+            if (!existed) {
+                mkdirSync(dirPath, { recursive: true })
+                control?.recordCreatedDir?.(dirPath)
+            }
+        }
+        const recordCreatedFileBeforeWrite = (filePath: string) => {
+            if (!existsSync(filePath)) {
+                control?.recordCreatedFile?.(filePath)
+            }
+        }
        const buildInterruptedResult = (state: 'paused' | 'stopped', postCount: number, mediaCount: number) => (
            state === 'stopped'
                ? { success: true, stopped: true, filePath: '', postCount, mediaCount }
@@ -1369,9 +1383,7 @@ class SnsService {

        try {
            // 确保输出目录存在
-            if (!existsSync(outputDir)) {
-                mkdirSync(outputDir, { recursive: true })
-            }
+            ensureExportDir(outputDir)

            // 1. 分页加载全部帖子
            const allPosts: SnsPost[] = []
@@ -1414,9 +1426,7 @@ class SnsService {
            const mediaDir = join(outputDir, 'media')

            if (shouldExportMedia) {
-                if (!existsSync(mediaDir)) {
-                    mkdirSync(mediaDir, { recursive: true })
-                }
+                ensureExportDir(mediaDir)

                // 收集所有媒体下载任务
                const mediaTasks: Array<{
@@ -1485,6 +1495,7 @@ class SnsService {
                        } else {
                            const result = await this.fetchAndDecryptImage(task.url, task.key)
                            if (result.success && result.data) {
+                                recordCreatedFileBeforeWrite(filePath)
                                await writeFile(filePath, result.data)
                                if (task.kind === 'livephoto') {
                                    if (media.livePhoto) (media.livePhoto as any).localPath = `media/${fileName}`
@@ -1494,6 +1505,7 @@ class SnsService {
                                mediaCount++
                            } else if (result.success && result.cachePath) {
                                const cachedData = await readFile(result.cachePath)
+                                recordCreatedFileBeforeWrite(filePath)
                                await writeFile(filePath, cachedData)
                                if (task.kind === 'livephoto') {
                                    if (media.livePhoto) (media.livePhoto as any).localPath = `media/${fileName}`
@@ -1531,7 +1543,7 @@ class SnsService {
            // 2.5 下载头像
            const avatarMap = new Map<string, string>()
            if (format === 'html') {
-                if (!existsSync(mediaDir)) mkdirSync(mediaDir, { recursive: true })
+                ensureExportDir(mediaDir)
                const uniqueUsers = [...new Map(allPosts.filter(p => p.avatarUrl).map(p => [p.username, p])).values()]
                let avatarDone = 0
                const avatarQueue = [...uniqueUsers]
@@ -1548,6 +1560,7 @@ class SnsService {
                            } else {
                                const result = await this.fetchAndDecryptImage(post.avatarUrl!)
                                if (result.success && result.data) {
+                                    recordCreatedFileBeforeWrite(filePath)
                                    await writeFile(filePath, result.data)
                                    avatarMap.set(post.username, `media/${fileName}`)
                                }
@@ -1602,6 +1615,7 @@ class SnsService {
                        linkUrl: (p as any).linkUrl
                    }))
                }
+                recordCreatedFileBeforeWrite(outputFilePath)
                await writeFile(outputFilePath, JSON.stringify(exportData, null, 2), 'utf-8')
            } else if (format === 'arkmejson') {
                outputFilePath = join(outputDir, `朋友圈导出_${timestamp}.json`)
@@ -1689,11 +1703,13 @@ class SnsService {
                    },
                    posts
                }
+                recordCreatedFileBeforeWrite(outputFilePath)
                await writeFile(outputFilePath, JSON.stringify(exportData, null, 2), 'utf-8')
            } else {
                // HTML 格式
                outputFilePath = join(outputDir, `朋友圈导出_${timestamp}.html`)
                const html = this.generateHtml(allPosts, { usernames, keyword }, avatarMap)
+                recordCreatedFileBeforeWrite(outputFilePath)
                await writeFile(outputFilePath, html, 'utf-8')
            }

--- a/electron/services/wcdbService.ts
+++ b/electron/services/wcdbService.ts
@@ -92,6 +92,9 @@ export class WcdbService {
        this.setPaths(this.resourcesPath, this.userDataPath)
      }
      this.setLogEnabled(this.logEnabled)
+      if (this.monitorListener) {
+        this.callWorker<{ success?: boolean }>('setMonitor').catch(() => { })
+      }

    } catch (e) {
      // Failed to create worker
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@@ -57,7 +57,7 @@
    "sass": "^1.98.0",
    "sharp": "^0.34.5",
    "typescript": "^6.0.2",
-    "vite": "^8.0.10",
+    "vite": "^7.0.0",
    "vite-plugin-electron": "^0.28.8",
    "vite-plugin-electron-renderer": "^0.14.6"
  },
--- a/resources/key/linux/x64/xkey_helper_linux
+++ b/resources/key/linux/x64/xkey_helper_linux
--- a/resources/wcdb/linux/x64/libwcdb_api.so
+++ b/resources/wcdb/linux/x64/libwcdb_api.so
--- a/resources/wcdb/macos/universal/libwcdb_api.dylib
+++ b/resources/wcdb/macos/universal/libwcdb_api.dylib
--- a/resources/wcdb/win32/arm64/wcdb_api.dll
+++ b/resources/wcdb/win32/arm64/wcdb_api.dll
--- a/resources/wcdb/win32/x64/wcdb_api.dll
+++ b/resources/wcdb/win32/x64/wcdb_api.dll
--- a/resources/wedecrypt/linux/x64/weflow-image-native-linux-x64.node
+++ b/resources/wedecrypt/linux/x64/weflow-image-native-linux-x64.node
--- a/resources/wedecrypt/macos/arm64/weflow-image-native-macos-arm64.node
+++ b/resources/wedecrypt/macos/arm64/weflow-image-native-macos-arm64.node
--- a/resources/wedecrypt/win32/arm64/weflow-image-native-win32-arm64.node
+++ b/resources/wedecrypt/win32/arm64/weflow-image-native-win32-arm64.node
--- a/resources/wedecrypt/win32/x64/weflow-image-native-win32-x64.node
+++ b/resources/wedecrypt/win32/x64/weflow-image-native-win32-x64.node
--- a/src/pages/ExportPage.tsx
+++ b/src/pages/ExportPage.tsx
@@ -80,7 +80,7 @@ import {
 import './ExportPage.scss'

 type ConversationTab = 'private' | 'group' | 'official' | 'former_friend'
-type TaskStatus = 'queued' | 'running' | 'success' | 'error'
+type TaskStatus = 'queued' | 'running' | 'pause_requested' | 'paused' | 'cancel_requested' | 'success' | 'error'
 type TaskScope = 'single' | 'multi' | 'content' | 'sns'
 type ContentType = 'text' | 'voice' | 'image' | 'video' | 'emoji' | 'file'
 type ContentCardType = ContentType | 'sns'
@@ -578,10 +578,27 @@ const formatDurationMs = (ms: number): string => {
 const getTaskStatusLabel = (task: ExportTask): string => {
  if (task.status === 'queued') return '排队中'
  if (task.status === 'running') return '进行中'
+  if (task.status === 'pause_requested') return '暂停中'
+  if (task.status === 'paused') return '已暂停'
+  if (task.status === 'cancel_requested') return '取消中'
  if (task.status === 'success') return '已完成'
  return '失败'
 }

+const resolveExportTaskCardClass = (status: TaskStatus): 'queued' | 'running' | 'paused' | 'stopped' | 'success' | 'error' => {
+  if (status === 'pause_requested' || status === 'paused') return 'paused'
+  if (status === 'cancel_requested') return 'stopped'
+  return status
+}
+
+const isExportTaskActiveStatus = (status: TaskStatus): boolean => (
+  status === 'queued' ||
+  status === 'running' ||
+  status === 'pause_requested' ||
+  status === 'paused' ||
+  status === 'cancel_requested'
+)
+
 const resolveBackgroundTaskCardClass = (status: BackgroundTaskRecord['status']): 'running' | 'paused' | 'stopped' | 'success' | 'error' => {
  if (status === 'running') return 'running'
  if (status === 'pause_requested' || status === 'paused') return 'paused'
@@ -1809,6 +1826,9 @@ interface TaskCenterModalProps {
  nowTick: number
  onClose: () => void
  onTogglePerfTask: (taskId: string) => void
+  onPauseExportTask: (taskId: string) => void
+  onResumeExportTask: (taskId: string) => void
+  onCancelExportTask: (taskId: string) => void
  onPauseBackgroundTask: (taskId: string) => void
  onResumeBackgroundTask: (taskId: string) => void
  onCancelBackgroundTask: (taskId: string) => void
@@ -1824,6 +1844,9 @@ const TaskCenterModal = memo(function TaskCenterModal({
  nowTick,
  onClose,
  onTogglePerfTask,
+  onPauseExportTask,
+  onResumeExportTask,
+  onCancelExportTask,
  onPauseBackgroundTask,
  onResumeBackgroundTask,
  onCancelBackgroundTask
@@ -1954,15 +1977,31 @@ const TaskCenterModal = memo(function TaskCenterModal({
                      : `图片耗时 ${formatDurationMs(imageTimingElapsedMs)}`
                  )
                  : ''
+                const taskCardClass = resolveExportTaskCardClass(task.status)
+                const canShowProgress = (
+                  task.status === 'running' ||
+                  task.status === 'pause_requested' ||
+                  task.status === 'paused' ||
+                  task.status === 'cancel_requested'
+                )
+                const canPause = task.status === 'running'
+                const canResume = task.status === 'paused' || task.status === 'pause_requested'
+                const canCancel = (
+                  task.status === 'queued' ||
+                  task.status === 'running' ||
+                  task.status === 'pause_requested' ||
+                  task.status === 'paused' ||
+                  task.status === 'cancel_requested'
+                )
                return (
-                  <div key={task.id} className={`task-card ${task.status}`}>
+                  <div key={task.id} className={`task-card ${taskCardClass}`}>
                    <div className="task-main">
                      <div className="task-title">{task.title}</div>
                      <div className="task-meta">
-                        <span className={`task-status ${task.status}`}>{getTaskStatusLabel(task)}</span>
+                        <span className={`task-status ${taskCardClass}`}>{getTaskStatusLabel(task)}</span>
                        <span>{new Date(task.createdAt).toLocaleString('zh-CN')}</span>
                      </div>
-                      {task.status === 'running' && (
+                      {canShowProgress && (
                        <>
                          <div className="task-progress-bar">
                            <div
@@ -2050,6 +2089,34 @@ const TaskCenterModal = memo(function TaskCenterModal({
                          {isPerfExpanded ? '收起详情' : '性能详情'}
                        </button>
                      )}
+                      {canPause && (
+                        <button
+                          className="task-action-btn"
+                          type="button"
+                          onClick={() => onPauseExportTask(task.id)}
+                        >
+                          <Pause size={14} /> 暂停
+                        </button>
+                      )}
+                      {canResume && (
+                        <button
+                          className="task-action-btn primary"
+                          type="button"
+                          onClick={() => onResumeExportTask(task.id)}
+                        >
+                          <Play size={14} /> 继续
+                        </button>
+                      )}
+                      {canCancel && (
+                        <button
+                          className="task-action-btn danger"
+                          type="button"
+                          onClick={() => onCancelExportTask(task.id)}
+                          disabled={task.status === 'cancel_requested'}
+                        >
+                          <Square size={14} /> {task.status === 'cancel_requested' ? '取消中' : '取消'}
+                        </button>
+                      )}
                      <button
                        className="task-action-btn"
                        onClick={() => {
@@ -5586,7 +5653,7 @@ function ExportPage() {
      const now = Date.now()
      const currentSessionId = String(payload.currentSessionId || '').trim()
      updateTask(next.id, task => {
-        if (task.status !== 'running') return task
+        if (task.status !== 'running' && task.status !== 'pause_requested' && task.status !== 'cancel_requested') return task
        const performance = applyProgressToTaskPerformance(task, payload, now)
        const settledSessionIds = task.settledSessionIds || []
        const nextSettledSessionIds = (
@@ -5740,7 +5807,8 @@ function ExportPage() {
          exportLivePhotos: snsOptions.exportLivePhotos,
          exportVideos: snsOptions.exportVideos,
          startTime: snsOptions.startTime,
-          endTime: snsOptions.endTime
+          endTime: snsOptions.endTime,
+          taskId: next.id
        })

        if (!result.success) {
@@ -5751,6 +5819,19 @@ function ExportPage() {
            error: result.error || '朋友圈导出失败',
            performance: finalizeTaskPerformance(task, Date.now())
          }))
+        } else if (result.stopped) {
+          setTasks(prev => prev.filter(task => task.id !== next.id))
+        } else if (result.paused) {
+          updateTask(next.id, task => ({
+            ...task,
+            status: 'paused',
+            progress: {
+              ...task.progress,
+              phaseLabel: '已暂停，可继续或取消',
+              current: Math.max(task.progress.current, result.postCount || 0),
+              total: Math.max(task.progress.total, result.postCount || 0)
+            }
+          }))
        } else {
          const doneAt = Date.now()
          const exportedPosts = Math.max(0, result.postCount || 0)
@@ -5782,7 +5863,8 @@ function ExportPage() {
        const result = await window.electronAPI.export.exportSessions(
          next.payload.sessionIds,
          next.payload.outputDir,
-          next.payload.options
+          next.payload.options,
+          { taskId: next.id }
        )

        if (!result.success) {
@@ -5793,6 +5875,33 @@ function ExportPage() {
            error: result.error || '导出失败',
            performance: finalizeTaskPerformance(task, Date.now())
          }))
+        } else if (result.stopped) {
+          setTasks(prev => prev.filter(task => task.id !== next.id))
+        } else if (result.paused) {
+          const pendingSessionIds = Array.isArray(result.pendingSessionIds)
+            ? result.pendingSessionIds
+            : []
+          updateTask(next.id, task => ({
+            ...task,
+            status: 'paused',
+            payload: {
+              ...task.payload,
+              sessionIds: pendingSessionIds.length > 0 ? pendingSessionIds : task.payload.sessionIds
+            },
+            settledSessionIds: Array.isArray(result.successSessionIds)
+              ? Array.from(new Set([...(task.settledSessionIds || []), ...result.successSessionIds]))
+              : task.settledSessionIds,
+            sessionOutputPaths: {
+              ...(task.sessionOutputPaths || {}),
+              ...((result.sessionOutputPaths && typeof result.sessionOutputPaths === 'object')
+                ? result.sessionOutputPaths
+                : {})
+            },
+            progress: {
+              ...task.progress,
+              phaseLabel: '已暂停，可继续或取消'
+            }
+          }))
        } else {
          const doneAt = Date.now()
          const contentTypes = next.payload.contentType
@@ -5913,7 +6022,13 @@ function ExportPage() {
    }

    const hasConflict = tasksRef.current.some((item) => {
-      if (item.status !== 'running' && item.status !== 'queued') return false
+      if (
+        item.status !== 'running' &&
+        item.status !== 'queued' &&
+        item.status !== 'pause_requested' &&
+        item.status !== 'paused' &&
+        item.status !== 'cancel_requested'
+      ) return false
      return item.payload.automationTaskId === task.id
    })
    if (hasConflict) {
@@ -6200,7 +6315,7 @@ function ExportPage() {
  const runningSessionIds = useMemo(() => {
    const set = new Set<string>()
    for (const task of tasks) {
-      if (task.status !== 'running') continue
+      if (task.status !== 'running' && task.status !== 'pause_requested' && task.status !== 'cancel_requested') continue
      const settled = new Set(task.settledSessionIds || [])
      for (const id of task.payload.sessionIds) {
        if (settled.has(id)) continue
@@ -6213,7 +6328,7 @@ function ExportPage() {
  const queuedSessionIds = useMemo(() => {
    const set = new Set<string>()
    for (const task of tasks) {
-      if (task.status !== 'queued') continue
+      if (task.status !== 'queued' && task.status !== 'paused') continue
      for (const id of task.payload.sessionIds) {
        set.add(id)
      }
@@ -6224,7 +6339,7 @@ function ExportPage() {
  const inProgressSessionIds = useMemo(() => {
    const set = new Set<string>()
    for (const task of tasks) {
-      if (task.status !== 'running' && task.status !== 'queued') continue
+      if (!isExportTaskActiveStatus(task.status)) continue
      for (const id of task.payload.sessionIds) {
        set.add(id)
      }
@@ -6232,7 +6347,7 @@ function ExportPage() {
    return Array.from(set).sort()
  }, [tasks])
  const activeTaskCount = useMemo(
-    () => tasks.filter(task => task.status === 'running' || task.status === 'queued').length,
+    () => tasks.filter(task => isExportTaskActiveStatus(task.status)).length,
    [tasks]
  )

@@ -6247,7 +6362,7 @@ function ExportPage() {
      if (previousStatus === task.status) continue

      const now = Date.now()
-      if (task.status === 'running') {
+      if (task.status === 'running' || task.status === 'pause_requested' || task.status === 'paused' || task.status === 'cancel_requested') {
        patchAutomationTask(automationTaskId, (current) => ({
          ...current,
          updatedAt: now,
@@ -6338,7 +6453,13 @@ function ExportPage() {
        if (task.runState?.lastScheduleKey === scheduleKey) continue

        const hasConflict = tasksRef.current.some((item) => {
-          if (item.status !== 'running' && item.status !== 'queued') return false
+          if (
+            item.status !== 'running' &&
+            item.status !== 'queued' &&
+            item.status !== 'pause_requested' &&
+            item.status !== 'paused' &&
+            item.status !== 'cancel_requested'
+          ) return false
          return item.payload.automationTaskId === task.id
        })
        if (hasConflict) {
@@ -6448,7 +6569,7 @@ function ExportPage() {
  const runningCardTypes = useMemo(() => {
    const set = new Set<ContentCardType>()
    for (const task of tasks) {
-      if (task.status !== 'running') continue
+      if (!isExportTaskActiveStatus(task.status)) continue
      if (task.payload.scope === 'sns') {
        set.add('sns')
        continue
@@ -7891,7 +8012,12 @@ function ExportPage() {
  )
  const isTabCountComputing = isSharedTabCountsLoading && !isSharedTabCountsReady
  const isSnsCardStatsLoading = !hasSeededSnsStats
-  const taskRunningCount = tasks.filter(task => task.status === 'running').length
+  const taskRunningCount = tasks.filter(task => (
+    task.status === 'running' ||
+    task.status === 'pause_requested' ||
+    task.status === 'paused' ||
+    task.status === 'cancel_requested'
+  )).length
  const taskQueuedCount = tasks.filter(task => task.status === 'queued').length
  const chatBackgroundTasks = useMemo(() => (
    backgroundTasks.filter(task => task.sourcePage === 'chat')
@@ -8105,6 +8231,112 @@ function ExportPage() {
  const toggleTaskPerfDetail = useCallback((taskId: string) => {
    setExpandedPerfTaskId(prev => (prev === taskId ? null : taskId))
  }, [])
+  const handlePauseExportTask = useCallback((taskId: string) => {
+    const task = tasksRef.current.find(item => item.id === taskId)
+    if (!task || task.status !== 'running') return
+    updateTask(taskId, current => ({
+      ...current,
+      status: 'pause_requested',
+      progress: {
+        ...current.progress,
+        phaseLabel: current.progress.phaseLabel || '暂停请求已发送'
+      }
+    }))
+    window.electronAPI.export.pauseTask(taskId).then(result => {
+      if (result.success) return
+      updateTask(taskId, current => ({
+        ...current,
+        status: current.status === 'pause_requested' ? 'running' : current.status,
+        error: result.error || '暂停请求失败'
+      }))
+    }).catch(error => {
+      updateTask(taskId, current => ({
+        ...current,
+        status: current.status === 'pause_requested' ? 'running' : current.status,
+        error: String(error)
+      }))
+    })
+  }, [updateTask])
+  const handleResumeExportTask = useCallback((taskId: string) => {
+    const task = tasksRef.current.find(item => item.id === taskId)
+    if (!task || (task.status !== 'paused' && task.status !== 'pause_requested')) return
+    window.electronAPI.export.resumeTask(taskId).then(result => {
+      const doneAt = Date.now()
+      if (!result.success) {
+        updateTask(taskId, current => ({
+          ...current,
+          status: 'error',
+          finishedAt: doneAt,
+          error: result.error || '继续任务失败',
+          performance: finalizeTaskPerformance(current, doneAt)
+        }))
+        return
+      }
+      updateTask(taskId, current => ({
+        ...current,
+        status: current.status === 'pause_requested' ? 'running' : 'queued',
+        finishedAt: undefined,
+        error: undefined,
+        progress: {
+          ...current.progress,
+          phaseLabel: current.status === 'pause_requested' ? '继续中' : '等待继续'
+        }
+      }))
+    }).catch(error => {
+      const doneAt = Date.now()
+      updateTask(taskId, current => ({
+        ...current,
+        status: 'error',
+        finishedAt: doneAt,
+        error: String(error),
+        performance: finalizeTaskPerformance(current, doneAt)
+      }))
+    })
+  }, [updateTask])
+  const handleCancelExportTask = useCallback((taskId: string) => {
+    const task = tasksRef.current.find(item => item.id === taskId)
+    if (!task) return
+    if (task.status === 'queued') {
+      setTasks(prev => prev.filter(item => item.id !== taskId))
+      return
+    }
+    if (task.status !== 'running' && task.status !== 'pause_requested' && task.status !== 'paused' && task.status !== 'cancel_requested') {
+      return
+    }
+    updateTask(taskId, current => ({
+      ...current,
+      status: 'cancel_requested',
+      progress: {
+        ...current.progress,
+        phaseLabel: '取消请求已发送，正在安全停止'
+      }
+    }))
+    window.electronAPI.export.cancelTask(taskId).then(result => {
+      if (result.success && task.status === 'paused') {
+        setTasks(prev => prev.filter(item => item.id !== taskId))
+        return
+      }
+      if (!result.success) {
+        const doneAt = Date.now()
+        updateTask(taskId, current => ({
+          ...current,
+          status: 'error',
+          finishedAt: doneAt,
+          error: result.error || '取消任务失败',
+          performance: finalizeTaskPerformance(current, doneAt)
+        }))
+      }
+    }).catch(error => {
+      const doneAt = Date.now()
+      updateTask(taskId, current => ({
+        ...current,
+        status: 'error',
+        finishedAt: doneAt,
+        error: String(error),
+        performance: finalizeTaskPerformance(current, doneAt)
+      }))
+    })
+  }, [updateTask])

  const toggleAutomationTaskEnabled = useCallback((taskId: string, enabled: boolean) => {
    const now = Date.now()
@@ -8564,6 +8796,9 @@ function ExportPage() {
        nowTick={nowTick}
        onClose={closeTaskCenter}
        onTogglePerfTask={toggleTaskPerfDetail}
+        onPauseExportTask={handlePauseExportTask}
+        onResumeExportTask={handleResumeExportTask}
+        onCancelExportTask={handleCancelExportTask}
        onPauseBackgroundTask={handlePauseBackgroundTask}
        onResumeBackgroundTask={handleResumeBackgroundTask}
        onCancelBackgroundTask={handleCancelBackgroundTask}
@@ -8622,12 +8857,12 @@ function ExportPage() {
                <div className="automation-task-list">
                  {sortedAutomationTasks.map((task) => {
                    const linkedQueueTask = tasks.find((item) => (
-                      (item.status === 'running' || item.status === 'queued') &&
+                      isExportTaskActiveStatus(item.status) &&
                      item.payload.automationTaskId === task.id
                    ))
                    const queueState: 'queued' | 'running' | null = linkedQueueTask?.status === 'running'
                      ? 'running'
-                      : linkedQueueTask?.status === 'queued'
+                      : linkedQueueTask && isExportTaskActiveStatus(linkedQueueTask.status)
                        ? 'queued'
                        : null
                    return (
--- a/src/pages/SettingsPage.tsx
+++ b/src/pages/SettingsPage.tsx
@@ -6,7 +6,7 @@ import { useThemeStore, themes } from '../stores/themeStore'
 import { useAnalyticsStore } from '../stores/analyticsStore'
 import { dialog } from '../services/ipc'
 import * as configService from '../services/config'
-import type { ContactInfo } from '../types/models'
+import type { ChatSession, ContactInfo } from '../types/models'
 import {
  Eye, EyeOff, FolderSearch, FolderOpen, Search, Copy,
  RotateCcw, Trash2, Plug, Check, Sun, Moon, Monitor,
@@ -195,6 +195,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
  const [launchAtStartup, setLaunchAtStartup] = useState(false)
  const [launchAtStartupSupported, setLaunchAtStartupSupported] = useState(isWindows || isMac)
  const [launchAtStartupReason, setLaunchAtStartupReason] = useState('')
+  const [silentStartup, setSilentStartup] = useState(false)
  const [windowCloseBehavior, setWindowCloseBehavior] = useState<configService.WindowCloseBehavior>('ask')
  const [quoteLayout, setQuoteLayout] = useState<configService.QuoteLayout>('quote-top')
  const [updateChannel, setUpdateChannel] = useState<configService.UpdateChannel>('stable')
@@ -222,6 +223,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
  const [isFetchingImageKey, setIsFetchingImageKey] = useState(false)
  const [isCheckingUpdate, setIsCheckingUpdate] = useState(false)
  const [isUpdatingLaunchAtStartup, setIsUpdatingLaunchAtStartup] = useState(false)
+  const [isUpdatingSilentStartup, setIsUpdatingSilentStartup] = useState(false)
  const [appVersion, setAppVersion] = useState('')
  const [message, setMessage] = useState<{ text: string; success: boolean } | null>(null)
  const [showDecryptKey, setShowDecryptKey] = useState(false)
@@ -263,6 +265,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
  const [messagePushFilterSearchKeyword, setMessagePushFilterSearchKeyword] = useState('')
  const [messagePushTypeFilter, setMessagePushTypeFilter] = useState<SessionFilterTypeValue>('all')
  const [messagePushContactOptions, setMessagePushContactOptions] = useState<ContactInfo[]>([])
+  const [antiRevokeSessions, setAntiRevokeSessions] = useState<ChatSession[]>([])
  const [antiRevokeSearchKeyword, setAntiRevokeSearchKeyword] = useState('')
  const [antiRevokeSelectedIds, setAntiRevokeSelectedIds] = useState<Set<string>>(new Set())
  const [antiRevokeStatusMap, setAntiRevokeStatusMap] = useState<Record<string, { installed?: boolean; loading?: boolean; error?: string }>>({})
@@ -445,6 +448,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
      const savedMessagePushFilterList = await configService.getMessagePushFilterList()
      const contactsResult = await window.electronAPI.chat.getContacts({ lite: true })
      const savedLaunchAtStartupStatus = await window.electronAPI.app.getLaunchAtStartupStatus()
+      const savedSilentStartup = await configService.getSilentStartup()
      const savedWindowCloseBehavior = await configService.getWindowCloseBehavior()
      const savedQuoteLayout = await configService.getQuoteLayout()
      const savedUpdateChannel = await configService.getUpdateChannel()
@@ -502,6 +506,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
      setLaunchAtStartup(savedLaunchAtStartupStatus.enabled)
      setLaunchAtStartupSupported(savedLaunchAtStartupStatus.supported)
      setLaunchAtStartupReason(savedLaunchAtStartupStatus.reason || '')
+      setSilentStartup(savedSilentStartup)
      setWindowCloseBehavior(savedWindowCloseBehavior)
      setQuoteLayout(savedQuoteLayout)
      if (savedUpdateChannel) {
@@ -615,6 +620,21 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
    }
  }

+  const handleSilentStartupChange = async (enabled: boolean) => {
+    if (isUpdatingSilentStartup) return
+
+    try {
+      setIsUpdatingSilentStartup(true)
+      await configService.setSilentStartup(enabled)
+      setSilentStartup(enabled)
+      showMessage(enabled ? '已开启静默启动' : '已关闭静默启动', true)
+    } catch (e: any) {
+      showMessage(`设置静默启动失败: ${e?.message || String(e)}`, false)
+    } finally {
+      setIsUpdatingSilentStartup(false)
+    }
+  }
+
  const refreshWhisperStatus = async (modelDirValue = whisperModelDir) => {
    try {
      const result = await window.electronAPI.whisper?.getModelStatus()
@@ -752,10 +772,10 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
    Array.from(new Set((sessionIds || []).map((id) => String(id || '').trim()).filter(Boolean)))

  const getCurrentAntiRevokeSessionIds = (): string[] =>
-    normalizeSessionIds(chatSessions.map((session) => session.username))
+    normalizeSessionIds(antiRevokeSessions.map((session) => session.username))

-  const ensureAntiRevokeSessionsLoaded = async (): Promise<string[]> => {
-    const current = getCurrentAntiRevokeSessionIds()
+  const ensureChatSessionsLoaded = async (): Promise<string[]> => {
+    const current = normalizeSessionIds(chatSessions.map((session) => session.username))
    if (current.length > 0) return current
    const sessionsResult = await window.electronAPI.chat.getSessions()
    if (!sessionsResult.success || !sessionsResult.sessions) {
@@ -765,6 +785,27 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
    return normalizeSessionIds(sessionsResult.sessions.map((session) => session.username))
  }

+  const ensureAntiRevokeSessionsLoaded = async (): Promise<string[]> => {
+    const current = getCurrentAntiRevokeSessionIds()
+    if (current.length > 0) return current
+    const sessionsResult = await window.electronAPI.chat.getAntiRevokeSessions()
+    if (!sessionsResult.success || !sessionsResult.sessions) {
+      throw new Error(sessionsResult.error || '加载会话失败')
+    }
+    const nextSessions = sessionsResult.sessions
+    const nextIds = normalizeSessionIds(nextSessions.map((session) => session.username))
+    setAntiRevokeSessions(nextSessions)
+    setAntiRevokeSelectedIds((prev) => {
+      const allowed = new Set(nextIds)
+      return new Set(Array.from(prev).filter((sessionId) => allowed.has(sessionId)))
+    })
+    setAntiRevokeStatusMap((prev) => {
+      const allowed = new Set(nextIds)
+      return Object.fromEntries(Object.entries(prev).filter(([sessionId]) => allowed.has(sessionId)))
+    })
+    return nextIds
+  }
+
  const markAntiRevokeRowsLoading = (sessionIds: string[]) => {
    setAntiRevokeStatusMap((prev) => {
      const next = { ...prev }
@@ -976,11 +1017,10 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
    let canceled = false
    ;(async () => {
      try {
-        // 两个 Tab 都需要会话列表；antiRevoke 还需要额外检查防撤回状态
-        const sessionIds = await ensureAntiRevokeSessionsLoaded()
-        if (canceled) return
        if (activeTab === 'antiRevoke') {
-          await handleRefreshAntiRevokeStatus(sessionIds)
+          await ensureAntiRevokeSessionsLoaded()
+        } else {
+          await ensureChatSessionsLoaded()
        }
      } catch (e: any) {
        if (!canceled) {
@@ -1684,6 +1724,35 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {

      <div className="divider" />

+      <div className="form-group">
+        <label>静默启动</label>
+        <span className="form-hint">
+          开启后，无论手动启动还是开机自启动，都会先驻留到系统托盘，不主动显示主窗口。
+        </span>
+        <div className="log-toggle-line">
+          <span className="log-status">
+            {isUpdatingSilentStartup
+              ? '保存中...'
+              : (silentStartup ? '已开启' : '已关闭')}
+          </span>
+          <label className="switch" htmlFor="silent-startup-toggle">
+            <input
+              id="silent-startup-toggle"
+              className="switch-input"
+              type="checkbox"
+              checked={silentStartup}
+              disabled={isUpdatingSilentStartup}
+              onChange={(e) => {
+                void handleSilentStartupChange(e.target.checked)
+              }}
+            />
+            <span className="switch-slider" />
+          </label>
+        </div>
+      </div>
+
+      <div className="divider" />
+
      <div className="form-group">
        <label>关闭主窗口时</label>
        <span className="form-hint">设置点击关闭按钮后的默认行为；选择“每次询问”时会弹出关闭确认。</span>
@@ -1982,7 +2051,7 @@ function SettingsPage({ onClose }: SettingsPageProps = {}) {
  }

  const renderAntiRevokeTab = () => {
-    const sortedSessions = [...chatSessions].sort((a, b) => (b.sortTimestamp || 0) - (a.sortTimestamp || 0))
+    const sortedSessions = [...antiRevokeSessions].sort((a, b) => (b.sortTimestamp || 0) - (a.sortTimestamp || 0))
    const keyword = antiRevokeSearchKeyword.trim().toLowerCase()
    const filteredSessions = sortedSessions.filter((session) => {
      if (!keyword) return true
@@ -4761,4 +4830,3 @@ export default SettingsPage



-
--- a/src/pages/SnsPage.scss
+++ b/src/pages/SnsPage.scss
@@ -2729,6 +2729,54 @@
        color: var(--text-tertiary);
        text-align: center;
    }
+
+    .export-progress-actions {
+        display: flex;
+        justify-content: center;
+        gap: 8px;
+        flex-wrap: wrap;
+        margin-top: 4px;
+    }
+
+    .export-progress-btn {
+        display: inline-flex;
+        align-items: center;
+        justify-content: center;
+        gap: 6px;
+        min-width: 82px;
+        height: 32px;
+        padding: 0 12px;
+        border-radius: 8px;
+        border: 1px solid var(--border-color);
+        background: var(--bg-secondary);
+        color: var(--text-secondary);
+        font-size: 13px;
+        font-weight: 600;
+        cursor: pointer;
+        transition: background 0.2s ease, color 0.2s ease, border-color 0.2s ease;
+
+        &:hover:not(:disabled) {
+            background: var(--hover-bg);
+            color: var(--text-primary);
+        }
+
+        &.primary {
+            border-color: color-mix(in srgb, var(--primary) 36%, var(--border-color));
+            background: rgba(var(--primary-rgb), 0.1);
+            color: var(--primary);
+        }
+
+        &.danger {
+            border-color: color-mix(in srgb, #ff4d4f 36%, var(--border-color));
+            background: color-mix(in srgb, #ff4d4f 10%, var(--bg-secondary));
+            color: #d9363e;
+        }
+
+        &:disabled {
+            opacity: 0.55;
+            cursor: not-allowed;
+        }
+    }
 }

 .export-result {
--- a/src/pages/SnsPage.tsx
+++ b/src/pages/SnsPage.tsx
@@ -1,5 +1,5 @@
 import { useEffect, useLayoutEffect, useState, useRef, useCallback, useMemo } from 'react'
-import { RefreshCw, Search, X, Download, FolderOpen, FileJson, FileText, Image, CheckCircle, AlertCircle, Calendar, Info, Shield, ShieldOff, Loader2 } from 'lucide-react'
+import { RefreshCw, Search, X, Download, FolderOpen, FileJson, FileText, Image, CheckCircle, AlertCircle, Calendar, Info, Shield, ShieldOff, Loader2, Pause, Play, Square } from 'lucide-react'
 import './SnsPage.scss'
 import { SnsPost } from '../types/sns'
 import { SnsPostItem } from '../components/Sns/SnsPostItem'
@@ -64,10 +64,42 @@ interface SnsOverviewStats {

 type OverviewStatsStatus = 'loading' | 'ready' | 'error'
 type SnsExportScope = { kind: 'all' } | { kind: 'selected'; usernames: string[] }
+type SnsExportTaskStatus = 'idle' | 'running' | 'pause_requested' | 'paused' | 'cancel_requested'
+
+interface SnsExportProgress {
+    current: number
+    total: number
+    status: string
+}
+
+interface SnsExportResult {
+    success: boolean
+    filePath?: string
+    postCount?: number
+    mediaCount?: number
+    paused?: boolean
+    stopped?: boolean
+    error?: string
+}
+
+interface SnsExportRequest {
+    taskId: string
+    outputDir: string
+    format: 'json' | 'html' | 'arkmejson'
+    usernames?: string[]
+    keyword?: string
+    exportImages: boolean
+    exportLivePhotos: boolean
+    exportVideos: boolean
+    startTime?: number
+    endTime?: number
+}

 const SIDEBAR_USER_PROFILE_CACHE_KEY = 'sidebar_user_profile_cache_v1'
 const SNS_CACHE_MIGRATION_PROMPT_SESSION_KEY = 'sns_cache_migration_prompted_v1'

+const createSnsExportTaskId = (): string => `sns-export-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`
+
 interface SnsCacheMigrationItem {
    label: string
    sourceDir: string
@@ -179,8 +211,9 @@ export default function SnsPage() {
        () => createExportDateRangeSelectionFromPreset('all')
    )
    const [isExporting, setIsExporting] = useState(false)
-    const [exportProgress, setExportProgress] = useState<{ current: number; total: number; status: string } | null>(null)
-    const [exportResult, setExportResult] = useState<{ success: boolean; filePath?: string; postCount?: number; mediaCount?: number; error?: string } | null>(null)
+    const [exportTaskStatus, setExportTaskStatus] = useState<SnsExportTaskStatus>('idle')
+    const [exportProgress, setExportProgress] = useState<SnsExportProgress | null>(null)
+    const [exportResult, setExportResult] = useState<SnsExportResult | null>(null)
    const [refreshSpin, setRefreshSpin] = useState(false)
    const [isExportDateRangeDialogOpen, setIsExportDateRangeDialogOpen] = useState(false)

@@ -211,6 +244,8 @@ export default function SnsPage() {
    const snsUserPostCountsCacheScopeKeyRef = useRef('')
    const activeContactsLoadTaskIdRef = useRef<string | null>(null)
    const activeContactsCountTaskIdRef = useRef<string | null>(null)
+    const activeExportTaskIdRef = useRef<string | null>(null)
+    const activeExportRequestRef = useRef<SnsExportRequest | null>(null)
    const scrollAdjustmentRef = useRef<{ scrollHeight: number; scrollTop: number } | null>(null)
    const pendingResetFeedRef = useRef(false)
    const contactsLoadTokenRef = useRef(0)
@@ -465,7 +500,11 @@ export default function SnsPage() {
            : overviewStatsStatus === 'loading' || contactsLoading
    )

-    const canStartExport = Boolean(exportFolder) && !isExporting && (
+    const isExportLocked = isExporting || exportTaskStatus !== 'idle'
+    const canPauseExport = exportTaskStatus === 'running'
+    const canResumeExport = exportTaskStatus === 'paused' || exportTaskStatus === 'pause_requested'
+    const canCancelExport = exportTaskStatus !== 'idle'
+    const canStartExport = Boolean(exportFolder) && !isExportLocked && (
        exportScope.kind === 'all' || exportScope.usernames.length > 0
    )

@@ -772,14 +811,205 @@ export default function SnsPage() {

    const exportDateRangeLabel = useMemo(() => getExportDateRangeLabel(exportDateRangeSelection), [exportDateRangeSelection])

+    const clearActiveExportTask = useCallback(() => {
+        activeExportTaskIdRef.current = null
+        activeExportRequestRef.current = null
+        setExportTaskStatus('idle')
+        setIsExporting(false)
+    }, [])
+
+    const buildSnsExportRequest = useCallback((taskId: string): SnsExportRequest => ({
+        taskId,
+        outputDir: exportFolder,
+        format: exportFormat,
+        usernames: exportScope.kind === 'selected' ? [...exportScope.usernames] : undefined,
+        keyword: searchKeyword || undefined,
+        exportImages,
+        exportLivePhotos,
+        exportVideos,
+        startTime: exportDateRangeSelection.useAllTime
+            ? undefined
+            : Math.floor(exportDateRangeSelection.dateRange.start.getTime() / 1000),
+        endTime: exportDateRangeSelection.useAllTime
+            ? undefined
+            : Math.floor(exportDateRangeSelection.dateRange.end.getTime() / 1000)
+    }), [
+        exportDateRangeSelection,
+        exportFolder,
+        exportFormat,
+        exportImages,
+        exportLivePhotos,
+        exportScope,
+        exportVideos,
+        searchKeyword
+    ])
+
+    const runSnsExport = useCallback(async (request: SnsExportRequest, statusText = '准备导出...') => {
+        activeExportTaskIdRef.current = request.taskId
+        activeExportRequestRef.current = request
+        setIsExporting(true)
+        setExportTaskStatus('running')
+        setExportResult(null)
+        setExportProgress(prev => prev || { current: 0, total: 0, status: statusText })
+
+        let keepTaskActive = false
+        const removeProgress = window.electronAPI.sns.onExportProgress((progress: SnsExportProgress) => {
+            setExportProgress(progress)
+        })
+
+        try {
+            const result = await window.electronAPI.sns.exportTimeline(request)
+            if (!result.success) {
+                setExportResult(result)
+                return
+            }
+
+            if (result.paused) {
+                keepTaskActive = true
+                setExportTaskStatus('paused')
+                setExportProgress(prev => ({
+                    current: Math.max(prev?.current || 0, result.postCount || 0),
+                    total: Math.max(prev?.total || 0, result.postCount || 0),
+                    status: '已暂停，可继续或取消'
+                }))
+                return
+            }
+
+            if (result.stopped) {
+                setExportResult(null)
+                setExportProgress(null)
+                setShowExportDialog(false)
+                return
+            }
+
+            setExportResult(result)
+        } catch (e: any) {
+            setExportResult({ success: false, error: e.message || String(e) })
+        } finally {
+            removeProgress()
+            setIsExporting(false)
+            if (!keepTaskActive) {
+                activeExportTaskIdRef.current = null
+                activeExportRequestRef.current = null
+                setExportTaskStatus('idle')
+            }
+        }
+    }, [])
+
+    const handleStartSnsExport = useCallback(() => {
+        if (!canStartExport) return
+        const request = buildSnsExportRequest(createSnsExportTaskId())
+        setExportProgress({ current: 0, total: 0, status: '准备导出...' })
+        void runSnsExport(request)
+    }, [buildSnsExportRequest, canStartExport, runSnsExport])
+
+    const handlePauseSnsExport = useCallback(() => {
+        const taskId = activeExportTaskIdRef.current
+        if (!taskId || exportTaskStatus !== 'running') return
+        setExportTaskStatus('pause_requested')
+        setExportProgress(prev => ({
+            current: prev?.current || 0,
+            total: prev?.total || 0,
+            status: '暂停请求已发送，正在等待安全检查点'
+        }))
+        window.electronAPI.export.pauseTask(taskId).then(result => {
+            if (result.success) return
+            setExportTaskStatus(current => current === 'pause_requested' ? 'running' : current)
+            setExportProgress(prev => ({
+                current: prev?.current || 0,
+                total: prev?.total || 0,
+                status: result.error || '暂停请求失败'
+            }))
+        }).catch(error => {
+            setExportTaskStatus(current => current === 'pause_requested' ? 'running' : current)
+            setExportProgress(prev => ({
+                current: prev?.current || 0,
+                total: prev?.total || 0,
+                status: String(error)
+            }))
+        })
+    }, [exportTaskStatus])
+
+    const handleResumeSnsExport = useCallback(() => {
+        const taskId = activeExportTaskIdRef.current
+        const request = activeExportRequestRef.current
+        if (!taskId || !request || (exportTaskStatus !== 'paused' && exportTaskStatus !== 'pause_requested')) return
+        setExportTaskStatus('running')
+        setExportProgress(prev => ({
+            current: prev?.current || 0,
+            total: prev?.total || 0,
+            status: '正在继续导出...'
+        }))
+        window.electronAPI.export.resumeTask(taskId).then(result => {
+            if (!result.success) {
+                setExportTaskStatus('paused')
+                setExportProgress(prev => ({
+                    current: prev?.current || 0,
+                    total: prev?.total || 0,
+                    status: result.error || '继续任务失败'
+                }))
+                return
+            }
+            void runSnsExport(request, '正在继续导出...')
+        }).catch(error => {
+            setExportTaskStatus('paused')
+            setExportProgress(prev => ({
+                current: prev?.current || 0,
+                total: prev?.total || 0,
+                status: String(error)
+            }))
+        })
+    }, [exportTaskStatus, runSnsExport])
+
+    const handleCancelSnsExport = useCallback(() => {
+        const taskId = activeExportTaskIdRef.current
+        if (!taskId || exportTaskStatus === 'idle' || exportTaskStatus === 'cancel_requested') return
+        const shouldCloseAfterAck = exportTaskStatus === 'paused' || !isExporting
+        setExportTaskStatus('cancel_requested')
+        setExportProgress(prev => ({
+            current: prev?.current || 0,
+            total: prev?.total || 0,
+            status: '取消请求已发送，正在安全停止并清理'
+        }))
+        window.electronAPI.export.cancelTask(taskId).then(result => {
+            if (!result.success) {
+                setExportTaskStatus(shouldCloseAfterAck ? 'paused' : 'running')
+                setExportProgress(prev => ({
+                    current: prev?.current || 0,
+                    total: prev?.total || 0,
+                    status: result.error || '取消任务失败'
+                }))
+                return
+            }
+            if (shouldCloseAfterAck) {
+                clearActiveExportTask()
+                setExportResult(null)
+                setExportProgress(null)
+                setShowExportDialog(false)
+            }
+        }).catch(error => {
+            setExportTaskStatus(shouldCloseAfterAck ? 'paused' : 'running')
+            setExportProgress(prev => ({
+                current: prev?.current || 0,
+                total: prev?.total || 0,
+                status: String(error)
+            }))
+        })
+    }, [clearActiveExportTask, exportTaskStatus, isExporting])
+
    const openExportDialog = useCallback((scope: SnsExportScope) => {
+        if (isExportLocked) {
+            setShowExportDialog(true)
+            return
+        }
        setExportScope(scope)
        setExportResult(null)
        setExportProgress(null)
+        clearActiveExportTask()
        setExportDateRangeSelection(createExportDateRangeSelectionFromPreset('all'))
        setIsExportDateRangeDialogOpen(false)
        setShowExportDialog(true)
-    }, [])
+    }, [clearActiveExportTask, isExportLocked])

    const loadPosts = useCallback(async (options: { reset?: boolean, direction?: 'older' | 'newer' } = {}) => {
        const { reset = false, direction = 'older' } = options
@@ -2048,11 +2278,11 @@ export default function SnsPage() {

            {/* 导出对话框 */}
            {showExportDialog && (
-                <div className="modal-overlay" onClick={() => !isExporting && setShowExportDialog(false)}>
+                <div className="modal-overlay" onClick={() => !isExportLocked && setShowExportDialog(false)}>
                    <div className="export-dialog" onClick={(e) => e.stopPropagation()}>
                        <div className="export-dialog-header">
                            <h3>导出朋友圈</h3>
-                            <button className="close-btn" onClick={() => !isExporting && setShowExportDialog(false)} disabled={isExporting}>
+                            <button className="close-btn" onClick={() => !isExportLocked && setShowExportDialog(false)} disabled={isExportLocked}>
                                <X size={20} />
                            </button>
                        </div>
@@ -2078,7 +2308,7 @@ export default function SnsPage() {
                                            <button
                                                className={`format-option ${exportFormat === 'html' ? 'active' : ''}`}
                                                onClick={() => setExportFormat('html')}
-                                                disabled={isExporting}
+                                                disabled={isExportLocked}
                                            >
                                                <FileText size={20} />
                                                <span>HTML</span>
@@ -2087,7 +2317,7 @@ export default function SnsPage() {
                                            <button
                                                className={`format-option ${exportFormat === 'json' ? 'active' : ''}`}
                                                onClick={() => setExportFormat('json')}
-                                                disabled={isExporting}
+                                                disabled={isExportLocked}
                                            >
                                                <FileJson size={20} />
                                                <span>JSON</span>
@@ -2096,7 +2326,7 @@ export default function SnsPage() {
                                            <button
                                                className={`format-option ${exportFormat === 'arkmejson' ? 'active' : ''}`}
                                                onClick={() => setExportFormat('arkmejson')}
-                                                disabled={isExporting}
+                                                disabled={isExportLocked}
                                            >
                                                <FileJson size={20} />
                                                <span>ArkmeJSON</span>
@@ -2124,7 +2354,7 @@ export default function SnsPage() {
                                                        setExportFolder(result.filePath)
                                                    }
                                                }}
-                                                disabled={isExporting}
+                                                disabled={isExportLocked}
                                            >
                                                <FolderOpen size={16} />
                                            </button>
@@ -2139,9 +2369,9 @@ export default function SnsPage() {
                                                type="button"
                                                className="time-range-trigger sns-export-time-range-trigger"
                                                onClick={() => {
-                                                    if (!isExporting) setIsExportDateRangeDialogOpen(true)
+                                                    if (!isExportLocked) setIsExportDateRangeDialogOpen(true)
                                                }}
-                                                disabled={isExporting}
+                                                disabled={isExportLocked}
                                            >
                                                <span>{exportDateRangeLabel}</span>
                                                <span className="time-range-arrow">&gt;</span>
@@ -2161,7 +2391,7 @@ export default function SnsPage() {
                                                    type="checkbox"
                                                    checked={exportImages}
                                                    onChange={(e) => setExportImages(e.target.checked)}
-                                                    disabled={isExporting}
+                                                    disabled={isExportLocked}
                                                />
                                                图片
                                            </label>
@@ -2170,7 +2400,7 @@ export default function SnsPage() {
                                                    type="checkbox"
                                                    checked={exportLivePhotos}
                                                    onChange={(e) => setExportLivePhotos(e.target.checked)}
-                                                    disabled={isExporting}
+                                                    disabled={isExportLocked}
                                                />
                                                实况图
                                            </label>
@@ -2179,7 +2409,7 @@ export default function SnsPage() {
                                                    type="checkbox"
                                                    checked={exportVideos}
                                                    onChange={(e) => setExportVideos(e.target.checked)}
-                                                    disabled={isExporting}
+                                                    disabled={isExportLocked}
                                                />
                                                视频
                                            </label>
@@ -2194,7 +2424,7 @@ export default function SnsPage() {
                                    </div>

                                    {/* 进度条 */}
-                                    {isExporting && exportProgress && (
+                                    {isExportLocked && exportProgress && (
                                        <div className="export-progress">
                                            <div className="export-progress-bar">
                                                <div
@@ -2203,6 +2433,39 @@ export default function SnsPage() {
                                                />
                                            </div>
                                            <span className="export-progress-text">{exportProgress.status}</span>
+                                            <div className="export-progress-actions">
+                                                {canPauseExport && (
+                                                    <button
+                                                        type="button"
+                                                        className="export-progress-btn"
+                                                        onClick={handlePauseSnsExport}
+                                                    >
+                                                        <Pause size={14} />
+                                                        暂停
+                                                    </button>
+                                                )}
+                                                {canResumeExport && (
+                                                    <button
+                                                        type="button"
+                                                        className="export-progress-btn primary"
+                                                        onClick={handleResumeSnsExport}
+                                                    >
+                                                        <Play size={14} />
+                                                        继续
+                                                    </button>
+                                                )}
+                                                {canCancelExport && (
+                                                    <button
+                                                        type="button"
+                                                        className="export-progress-btn danger"
+                                                        onClick={handleCancelSnsExport}
+                                                        disabled={exportTaskStatus === 'cancel_requested'}
+                                                    >
+                                                        <Square size={14} />
+                                                        {exportTaskStatus === 'cancel_requested' ? '取消中' : '取消'}
+                                                    </button>
+                                                )}
+                                            </div>
                                        </div>
                                    )}

@@ -2211,47 +2474,14 @@ export default function SnsPage() {
                                        <button
                                            className="export-cancel-btn"
                                            onClick={() => setShowExportDialog(false)}
-                                            disabled={isExporting}
+                                            disabled={isExportLocked}
                                        >
                                            取消
                                        </button>
                                        <button
                                            className="export-start-btn"
                                            disabled={!canStartExport}
-                                            onClick={async () => {
-                                                setIsExporting(true)
-                                                setExportProgress({ current: 0, total: 0, status: '准备导出...' })
-                                                setExportResult(null)
-
-                                                // 监听进度
-                                                const removeProgress = window.electronAPI.sns.onExportProgress((progress: any) => {
-                                                    setExportProgress(progress)
-                                                })
-
-                                                try {
-                                                    const result = await window.electronAPI.sns.exportTimeline({
-                                                        outputDir: exportFolder,
-                                                        format: exportFormat,
-                                                        usernames: exportScope.kind === 'selected' ? exportScope.usernames : undefined,
-                                                        keyword: searchKeyword || undefined,
-                                                        exportImages,
-                                                        exportLivePhotos,
-                                                        exportVideos,
-                                                        startTime: exportDateRangeSelection.useAllTime
-                                                            ? undefined
-                                                            : Math.floor(exportDateRangeSelection.dateRange.start.getTime() / 1000),
-                                                        endTime: exportDateRangeSelection.useAllTime
-                                                            ? undefined
-                                                            : Math.floor(exportDateRangeSelection.dateRange.end.getTime() / 1000)
-                                                    })
-                                                    setExportResult(result)
-                                                } catch (e: any) {
-                                                    setExportResult({ success: false, error: e.message || String(e) })
-                                                } finally {
-                                                    setIsExporting(false)
-                                                    removeProgress()
-                                                }
-                                            }}
+                                            onClick={handleStartSnsExport}
                                        >
                                            {isExporting ? '导出中...' : '开始导出'}
                                        </button>
--- a/src/services/config.ts
+++ b/src/services/config.ts
@@ -15,6 +15,7 @@ export const CONFIG_KEYS = {
  WINDOW_BOUNDS: 'windowBounds',
  CACHE_PATH: 'cachePath',
  LAUNCH_AT_STARTUP: 'launchAtStartup',
+  SILENT_STARTUP: 'silentStartup',

  EXPORT_PATH: 'exportPath',
  AGREEMENT_ACCEPTED: 'agreementAccepted',
@@ -321,6 +322,17 @@ export async function setLaunchAtStartup(enabled: boolean): Promise<void> {
  await config.set(CONFIG_KEYS.LAUNCH_AT_STARTUP, enabled)
 }

+// 获取静默启动偏好
+export async function getSilentStartup(): Promise<boolean> {
+  const value = await config.get(CONFIG_KEYS.SILENT_STARTUP)
+  return value === true
+}
+
+// 设置静默启动偏好
+export async function setSilentStartup(enabled: boolean): Promise<void> {
+  await config.set(CONFIG_KEYS.SILENT_STARTUP, enabled)
+}
+
 // 获取 LLM 模型路径
 export async function getLlmModelPath(): Promise<string | null> {
  const value = await config.get(CONFIG_KEYS.LLM_MODEL_PATH)
--- a/src/types/electron.d.ts
+++ b/src/types/electron.d.ts
@@ -35,6 +35,17 @@ export interface BackupOptions {
  includeFiles?: boolean
 }

+export interface BackupImageDatMeta {
+  version?: number
+  aesSize?: number
+  aes_size?: number
+  xorSize?: number
+  xor_size?: number
+  rawSize?: number
+  raw_size?: number
+  flag?: number
+}
+
 export interface BackupManifest {
  version: 1
  type: 'weflow-db-snapshots'
@@ -47,7 +58,7 @@ export interface BackupManifest {
  options?: BackupOptions
  databases: Array<{
    id: string
-    kind: 'session' | 'contact' | 'emoticon' | 'message' | 'media' | 'sns'
+    kind: 'session' | 'contact' | 'emoticon' | 'message' | 'media' | 'sns' | 'hardlink'
    dbPath: string
    relativePath: string
    tables: Array<{
@@ -70,6 +81,7 @@ export interface BackupManifest {
      targetRelativePath: string
      ext?: string
      size?: number
+      datMeta?: BackupImageDatMeta
    }>
    videos?: Array<{
      kind: 'image' | 'video' | 'file'
@@ -259,6 +271,7 @@ export interface ElectronAPI {
  chat: {
    connect: () => Promise<{ success: boolean; error?: string }>
    getSessions: () => Promise<{ success: boolean; sessions?: ChatSession[]; error?: string }>
+    getAntiRevokeSessions: () => Promise<{ success: boolean; sessions?: ChatSession[]; error?: string }>
    getSessionStatuses: (usernames: string[]) => Promise<{
      success: boolean
      map?: Record<string, { isFolded?: boolean; isMuted?: boolean }>
@@ -1079,16 +1092,21 @@ export interface ElectronAPI {
      estimatedSeconds: number
      sessions: Array<{ sessionId: string; displayName: string; totalCount: number; voiceCount: number }>
    }>
-    exportSessions: (sessionIds: string[], outputDir: string, options: ExportOptions) => Promise<{
+    exportSessions: (sessionIds: string[], outputDir: string, options: ExportOptions, controlOptions?: { taskId?: string }) => Promise<{
      success: boolean
      successCount?: number
      failCount?: number
+      paused?: boolean
+      stopped?: boolean
      pendingSessionIds?: string[]
      successSessionIds?: string[]
      failedSessionIds?: string[]
      sessionOutputPaths?: Record<string, string>
      error?: string
    }>
+    pauseTask: (taskId: string) => Promise<{ success: boolean; error?: string }>
+    resumeTask: (taskId: string) => Promise<{ success: boolean; error?: string }>
+    cancelTask: (taskId: string) => Promise<{ success: boolean; error?: string }>
    exportSession: (sessionId: string, outputPath: string, options: ExportOptions) => Promise<{
      success: boolean
      error?: string
@@ -1161,7 +1179,8 @@ export interface ElectronAPI {
      exportVideos?: boolean
      startTime?: number
      endTime?: number
-    }) => Promise<{ success: boolean; filePath?: string; postCount?: number; mediaCount?: number; error?: string }>
+      taskId?: string
+    }) => Promise<{ success: boolean; filePath?: string; postCount?: number; mediaCount?: number; paused?: boolean; stopped?: boolean; error?: string }>
    onExportProgress: (callback: (payload: { current: number; total: number; status: string }) => void) => () => void
    selectExportDir: () => Promise<{ canceled: boolean; filePath?: string }>
    getSnsUsernames: () => Promise<{ success: boolean; usernames?: string[]; error?: string }>
Author	SHA1	Message	Date
cc	043332d297	Merge pull request #851 from hicccc77/main Dev	2026-04-26 14:55:18 +08:00
cc	608f74a3f9	Merge pull request #850 from hicccc77/dev Dev	2026-04-26 14:54:36 +08:00
cc	551d05fe2e	Update MAC-KEY-FAQ with login instructions	2026-04-26 14:53:53 +08:00
cc	c9317f76a3	Merge pull request #846 from BeiChen-CN/codex/export-pause-cancel fix(export): 添加朋友圈导出控制按钮	2026-04-26 14:48:48 +08:00
cc	ffd533d865	Merge pull request #848 from hicccc77/dev 更新封面图	2026-04-26 12:11:12 +08:00
cc	1976edc483	更新封面图	2026-04-26 12:09:56 +08:00
cc	27690ee7fa	Merge pull request #847 from hicccc77/dev Dev	2026-04-26 11:13:55 +08:00
cc	81ade84a77	fix actions fixed prerelease sync	2026-04-26 11:13:04 +08:00
姜北尘	bb42a7c0b2	fix(export): 修复朋友圈导出控制按钮	2026-04-25 23:54:32 +08:00
cc	87d894b1f9	Merge pull request #845 from BeiChen-CN/codex/export-pause-cancel feat(export): 添加导出暂停取消控制	2026-04-25 23:32:53 +08:00
姜北尘	1b75986987	feat(export): 添加导出暂停取消控制	2026-04-25 23:24:27 +08:00
cc	32aab8d490	fix: 迁移图片资源保留原始dat	2026-04-25 22:55:28 +08:00
cc	8e2a6ec933	优化防撤回会话列表	2026-04-25 19:22:35 +08:00
cc	fc3356ece2	Merge branch 'dev' of https://github.com/hicccc77/WeFlow into dev	2026-04-25 18:38:15 +08:00
cc	cd1ecf0ef6	修复文案描述与添加hardlink备份支持	2026-04-25 18:38:12 +08:00
cc	9e6bf0f21a	Merge pull request #842 from Jasonzhu1207/main feat: add silent startup	2026-04-25 18:37:51 +08:00
Jason	9ea34d74c2	Merge pull request #34 from Jasonzhu1207/feat/silent-startup-tray feat: add silent startup to tray background	2026-04-25 17:49:10 +08:00
Jason	42d4982728	feat(settings): add silent startup to tray	2026-04-25 17:42:13 +08:00
cc	f07e23b144	完善数据迁移	2026-04-25 17:41:14 +08:00
cc	6cf67828a2	修复Linux密钥问题	2026-04-25 15:50:45 +08:00