improvement(chat): 完善会话置顶与消息卡片解析展示

- 后端：会话列表支持置顶识别(isTop)并按置顶优先排序 - 后端：修正群聊 XML 发送者提取，避免 refermsg 嵌套误识别 - 后端：完善转账状态后处理与视频缩略图 MD5 回填(packed_info_data) - 后端：补充 quoteThumbUrl/linkType/linkStyle 字段链路 - 前端：新增置顶会话背景态、引用链接缩略图预览与 LinkCard cover 样式 - 测试：新增转账、置顶、引用解析与视频缩略图相关回归用例
refactor(chat-ui): 抽离侧边栏并统一账号/实时/隐私状态
2026-06-18 15:54:08 +08:00 · 2026-02-11 21:57:43 +08:00 · 2026-02-11 12:14:21 +08:00 · 2026-02-11 12:14:08 +08:00 · 2026-02-09 18:31:47 +08:00 · 2026-02-09 18:31:22 +08:00
33 changed files with 3703 additions and 1160 deletions
@@ -1,13 +1,22 @@
 <template>
  <div :class="rootClass">
-    <DesktopTitleBar v-if="isDesktop && !isChatRoute" />
-    <div :class="contentClass">
-      <NuxtPage />
+    <SidebarRail v-if="showSidebar" />
+    <div class="flex-1 flex flex-col min-h-0">
+      <!-- Desktop titlebar lives above the page content (right column) -->
+      <DesktopTitleBar />
+      <div :class="contentClass">
+        <NuxtPage />
+      </div>
    </div>
  </div>
 </template>

 <script setup>
+import { useChatAccountsStore } from '~/stores/chatAccounts'
+import { usePrivacyStore } from '~/stores/privacy'
+
+const route = useRoute()
+
 // In Electron the server/pre-render doesn't know about `window.wechatDesktop`.
 // If we render different DOM on server vs client, Vue hydration will keep the
 // server HTML (no patch) and the layout/CSS fixes won't apply reliably.
@@ -23,25 +32,32 @@ onMounted(() => {
  isDesktop.value = !!window?.wechatDesktop
  updateDprVar()
  window.addEventListener('resize', updateDprVar)
+
+  // Init global UI state.
+  const chatAccounts = useChatAccountsStore()
+  const privacy = usePrivacyStore()
+  void chatAccounts.ensureLoaded()
+  privacy.init()
 })

 onBeforeUnmount(() => {
  window.removeEventListener('resize', updateDprVar)
 })

-const route = useRoute()
-const isChatRoute = computed(() => route.path?.startsWith('/chat') || route.path?.startsWith('/sns') || route.path?.startsWith('/contacts'))
-
 const rootClass = computed(() => {
  const base = 'bg-gradient-to-br from-green-50 via-emerald-50 to-green-100'
  return isDesktop.value
-    ? `wechat-desktop h-screen flex flex-col overflow-hidden ${base}`
-    : `min-h-screen ${base}`
+    ? `wechat-desktop h-screen flex overflow-hidden ${base}`
+    : `h-screen flex overflow-hidden ${base}`
 })

 const contentClass = computed(() =>
-  isDesktop.value ? 'wechat-desktop-content flex-1 overflow-auto min-h-0' : ''
+  isDesktop.value
+    ? 'wechat-desktop-content flex-1 overflow-auto min-h-0'
+    : 'flex-1 overflow-auto min-h-0'
 )
+
+const showSidebar = computed(() => !String(route.path || '').startsWith('/wrapped'))
 </script>

 <style>
@@ -70,15 +86,4 @@ const contentClass = computed(() =>
 .wechat-desktop .wechat-desktop-content > .min-h-screen {
  min-height: 100%;
 }
-
-/* 页面过渡动画 - 渐显渐隐效果 */
-.page-enter-active,
-.page-leave-active {
-  transition: opacity 0.3s ease;
-}
-
-.page-enter-from,
-.page-leave-to {
-  opacity: 0;
-}
 </style>
@@ -0,0 +1,240 @@
+<template>
+  <div
+    class="border-r border-gray-200 flex flex-col"
+    :style="{ backgroundColor: '#e8e7e7', width: '60px', minWidth: '60px', maxWidth: '60px' }"
+  >
+    <div class="flex-1 flex flex-col justify-start pt-0 gap-0">
+      <!-- Avatar -->
+      <div class="w-full h-[60px] flex items-center justify-center">
+        <div class="w-[40px] h-[40px] rounded-md overflow-hidden bg-gray-300 flex-shrink-0">
+          <img v-if="selfAvatarUrl" :src="selfAvatarUrl" alt="avatar" class="w-full h-full object-cover" />
+          <div
+            v-else
+            class="w-full h-full flex items-center justify-center text-white text-xs font-bold"
+            :style="{ backgroundColor: '#4B5563' }"
+          >
+            我
+          </div>
+        </div>
+      </div>
+
+      <!-- Chat -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        title="聊天"
+        @click="goChat"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isChatRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
+            <svg class="w-full h-full" viewBox="0 0 24 24" fill="currentColor" aria-hidden="true">
+              <path d="M12 19.8C17.52 19.8 22 15.99 22 11.3C22 6.6 17.52 2.8 12 2.8C6.48 2.8 2 6.6 2 11.3C2 13.29 2.8 15.12 4.15 16.57C4.6 17.05 4.82 17.29 4.92 17.44C5.14 17.79 5.21 17.99 5.23 18.4C5.24 18.59 5.22 18.81 5.16 19.26C5.1 19.75 5.07 19.99 5.13 20.16C5.23 20.49 5.53 20.71 5.87 20.72C6.04 20.72 6.27 20.63 6.72 20.43L8.07 19.86C8.43 19.71 8.61 19.63 8.77 19.59C8.95 19.55 9.04 19.54 9.22 19.54C9.39 19.53 9.64 19.57 10.14 19.65C10.74 19.75 11.37 19.8 12 19.8Z" />
+            </svg>
+          </div>
+        </div>
+      </div>
+
+      <!-- Moments -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        title="朋友圈"
+        @click="goSns"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isSnsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
+            <svg
+              class="w-full h-full"
+              viewBox="0 0 24 24"
+              fill="none"
+              stroke="currentColor"
+              stroke-width="1.5"
+              stroke-linecap="round"
+              stroke-linejoin="round"
+              aria-hidden="true"
+            >
+              <circle cx="12" cy="12" r="10" />
+              <line x1="14.31" y1="8" x2="20.05" y2="17.94" />
+              <line x1="9.69" y1="8" x2="21.17" y2="8" />
+              <line x1="7.38" y1="12" x2="13.12" y2="2.06" />
+              <line x1="9.69" y1="16" x2="3.95" y2="6.06" />
+              <line x1="14.31" y1="16" x2="2.83" y2="16" />
+              <line x1="16.62" y1="12" x2="10.88" y2="21.94" />
+            </svg>
+          </div>
+        </div>
+      </div>
+
+      <!-- Contacts -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        title="联系人"
+        @click="goContacts"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isContactsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
+            <svg class="w-full h-full" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.8" stroke-linecap="round" stroke-linejoin="round" aria-hidden="true">
+              <path d="M17 21v-2a4 4 0 0 0-4-4H7a4 4 0 0 0-4 4v2" />
+              <circle cx="10" cy="7" r="4" />
+              <path d="M23 21v-2a4 4 0 0 0-3-3.87" />
+              <path d="M16 3.13a4 4 0 0 1 0 7.75" />
+            </svg>
+          </div>
+        </div>
+      </div>
+
+      <!-- Wrapped -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        title="年度总结"
+        @click="goWrapped"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isWrappedRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
+            <svg
+              class="w-full h-full"
+              viewBox="0 0 24 24"
+              fill="none"
+              stroke="currentColor"
+              stroke-width="1.5"
+              stroke-linecap="round"
+              stroke-linejoin="round"
+              aria-hidden="true"
+            >
+              <rect x="4" y="5" width="16" height="15" rx="2" />
+              <path d="M8 3v4" />
+              <path d="M16 3v4" />
+              <path d="M4 9h16" />
+              <path d="M8.5 15l2-2 1.5 1.5 3-3" />
+            </svg>
+          </div>
+        </div>
+      </div>
+
+      <!-- Realtime -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center group"
+        :class="realtimeBusy ? 'opacity-60 cursor-not-allowed' : 'cursor-pointer'"
+        :title="realtimeTitle"
+        @click="toggleRealtime"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <svg
+            class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]"
+            :class="realtimeEnabled ? 'text-[#07b75b]' : 'text-[#5d5d5d]'"
+            viewBox="0 0 24 24"
+            fill="none"
+            stroke="currentColor"
+            stroke-width="1.7"
+            stroke-linecap="round"
+            stroke-linejoin="round"
+            aria-hidden="true"
+          >
+            <path d="M13 2L4 14h7l-1 8 9-12h-7z" />
+          </svg>
+        </div>
+      </div>
+
+      <!-- Privacy -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        @click="privacyStore.toggle"
+        :title="privacyMode ? '关闭隐私模式' : '开启隐私模式'"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <svg class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="privacyMode ? 'text-[#07b75b]' : 'text-[#5d5d5d]'" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5">
+            <path v-if="privacyMode" stroke-linecap="round" stroke-linejoin="round" d="M3.98 8.223A10.477 10.477 0 001.934 12C3.226 16.338 7.244 19.5 12 19.5c.993 0 1.953-.138 2.863-.395M6.228 6.228A10.45 10.45 0 0112 4.5c4.756 0 8.773 3.162 10.065 7.498a10.523 10.523 0 01-4.293 5.774M6.228 6.228L3 3m3.228 3.228l3.65 3.65m7.894 7.894L21 21m-3.228-3.228l-3.65-3.65m0 0a3 3 0 10-4.243-4.243m4.242 4.242L9.88 9.88" />
+            <path v-else stroke-linecap="round" stroke-linejoin="round" d="M2.036 12.322a1.012 1.012 0 010-.639C3.423 7.51 7.36 4.5 12 4.5c4.638 0 8.573 3.007 9.963 7.178.07.207.07.431 0 .639C20.577 16.49 16.64 19.5 12 19.5c-4.638 0-8.573-3.007-9.963-7.178z" />
+            <circle v-if="!privacyMode" cx="12" cy="12" r="3" />
+          </svg>
+        </div>
+      </div>
+
+      <!-- Settings -->
+      <div
+        class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
+        @click="goSettings"
+        title="设置"
+      >
+        <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
+          <svg class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isSettingsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5">
+            <path
+              stroke-linecap="round"
+              stroke-linejoin="round"
+              d="M10.325 4.317c.426-1.756 2.924-1.756 3.35 0a1.724 1.724 0 002.573 1.066c1.543-.94 3.31.826 2.37 2.37a1.724 1.724 0 001.065 2.572c1.756.426 1.756 2.924 0 3.35a1.724 1.724 0 00-1.066 2.573c.94 1.543-.826 3.31-2.37 2.37a1.724 1.724 0 00-2.572 1.065c-.426 1.756-2.924 1.756-3.35 0a1.724 1.724 0 00-2.573-1.066c-1.543.94-3.31-.826-2.37-2.37a1.724 1.724 0 00-1.065-2.572c-1.756-.426-1.756-2.924 0-3.35a1.724 1.724 0 001.066-2.573c-.94-1.543.826-3.31 2.37-2.37.996.608 2.296.07 2.572-1.065z"
+            />
+            <path stroke-linecap="round" stroke-linejoin="round" d="M15 12a3 3 0 11-6 0 3 3 0 016 0z" />
+          </svg>
+        </div>
+      </div>
+    </div>
+  </div>
+</template>
+
+<script setup>
+import { storeToRefs } from 'pinia'
+import { useChatAccountsStore } from '~/stores/chatAccounts'
+import { useChatRealtimeStore } from '~/stores/chatRealtime'
+import { usePrivacyStore } from '~/stores/privacy'
+
+const route = useRoute()
+
+const chatAccounts = useChatAccountsStore()
+const { selectedAccount } = storeToRefs(chatAccounts)
+
+const privacyStore = usePrivacyStore()
+const { privacyMode } = storeToRefs(privacyStore)
+
+const realtimeStore = useChatRealtimeStore()
+const { enabled: realtimeEnabled, available: realtimeAvailable, checking: realtimeChecking, statusError: realtimeStatusError, toggling: realtimeToggling } = storeToRefs(realtimeStore)
+
+onMounted(async () => {
+  await chatAccounts.ensureLoaded()
+})
+
+const sidebarMediaBase = process.client ? 'http://localhost:8000' : ''
+
+const selfAvatarUrl = computed(() => {
+  const acc = String(selectedAccount.value || '').trim()
+  if (!acc) return ''
+  return `${sidebarMediaBase}/api/chat/avatar?account=${encodeURIComponent(acc)}&username=${encodeURIComponent(acc)}`
+})
+
+const isChatRoute = computed(() => route.path?.startsWith('/chat'))
+const isSnsRoute = computed(() => route.path?.startsWith('/sns'))
+const isContactsRoute = computed(() => route.path?.startsWith('/contacts'))
+const isWrappedRoute = computed(() => route.path?.startsWith('/wrapped'))
+const isSettingsRoute = computed(() => route.path?.startsWith('/settings'))
+
+const goChat = async () => {
+  await navigateTo('/chat')
+}
+
+const goSns = async () => {
+  await navigateTo('/sns')
+}
+
+const goContacts = async () => {
+  await navigateTo('/contacts')
+}
+
+const goWrapped = async () => {
+  await navigateTo('/wrapped')
+}
+
+const goSettings = async () => {
+  await navigateTo('/settings')
+}
+
+const realtimeBusy = computed(() => !!realtimeChecking.value || !!realtimeToggling.value)
+
+const realtimeTitle = computed(() => {
+  if (realtimeEnabled.value) return '关闭实时更新（全局）'
+  if (realtimeAvailable.value) return '开启实时更新（全局）'
+  return realtimeStatusError.value || '实时模式不可用'
+})
+
+const toggleRealtime = async () => {
+  if (realtimeBusy.value) return
+  await realtimeStore.toggle({ silent: false })
+}
+</script>
+
@@ -31,8 +31,7 @@ export default defineNuxtConfig({
        { rel: 'icon', type: 'image/png', href: '/logo.png' },
        { rel: 'stylesheet', href: 'https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css' }
      ]
-    },
-    pageTransition: { name: 'page', mode: 'out-in' }
+    }
  },
  
  // 模块配置
@@ -1,80 +1,6 @@
 <template>
  <div class="h-screen flex overflow-hidden" style="background-color: #EDEDED">
-    <div class="border-r border-gray-200 flex flex-col" style="background-color: #e8e7e7; width: 60px; min-width: 60px; max-width: 60px">
-      <div class="flex-1 flex flex-col justify-start pt-0 gap-0">
-        <div class="w-full h-[60px] flex items-center justify-center">
-          <div class="w-[40px] h-[40px] rounded-md overflow-hidden bg-gray-300 flex-shrink-0">
-            <img v-if="selfAvatarUrl" :src="selfAvatarUrl" alt="avatar" class="w-full h-full object-cover" />
-            <div v-else class="w-full h-full flex items-center justify-center text-white text-xs font-bold" style="background-color: #4B5563">我</div>
-          </div>
-        </div>
-
-        <div class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group" title="聊天" @click="goChat">
-          <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isChatRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="currentColor" aria-hidden="true">
-                <path d="M12 19.8C17.52 19.8 22 15.99 22 11.3C22 6.6 17.52 2.8 12 2.8C6.48 2.8 2 6.6 2 11.3C2 13.29 2.8 15.12 4.15 16.57C4.6 17.05 4.82 17.29 4.92 17.44C5.14 17.79 5.21 17.99 5.23 18.4C5.24 18.59 5.22 18.81 5.16 19.26C5.1 19.75 5.07 19.99 5.13 20.16C5.23 20.49 5.53 20.71 5.87 20.72C6.04 20.72 6.27 20.63 6.72 20.43L8.07 19.86C8.43 19.71 8.61 19.63 8.77 19.59C8.95 19.55 9.04 19.54 9.22 19.54C9.39 19.53 9.64 19.57 10.14 19.65C10.74 19.75 11.37 19.8 12 19.8Z" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <div class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group" title="朋友圈" @click="goSns">
-          <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isSnsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round" aria-hidden="true">
-                <circle cx="12" cy="12" r="10" />
-                <line x1="14.31" y1="8" x2="20.05" y2="17.94" />
-                <line x1="9.69" y1="8" x2="21.17" y2="8" />
-                <line x1="7.38" y1="12" x2="13.12" y2="2.06" />
-                <line x1="9.69" y1="16" x2="3.95" y2="6.06" />
-                <line x1="14.31" y1="16" x2="2.83" y2="16" />
-                <line x1="16.62" y1="12" x2="10.88" y2="21.94" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <div class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group" title="联系人">
-          <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)] text-[#07b75b]">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.8" stroke-linecap="round" stroke-linejoin="round" aria-hidden="true">
-                <path d="M17 21v-2a4 4 0 0 0-4-4H7a4 4 0 0 0-4 4v2" />
-                <circle cx="10" cy="7" r="4" />
-                <path d="M23 21v-2a4 4 0 0 0-3-3.87" />
-                <path d="M16 3.13a4 4 0 0 1 0 7.75" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <div class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group" title="年度总结" @click="goWrapped">
-          <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isWrappedRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" stroke-linejoin="round" aria-hidden="true">
-                <rect x="4" y="4" width="16" height="16" rx="2" />
-                <path d="M8 16v-5" />
-                <path d="M12 16v-8" />
-                <path d="M16 16v-3" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <div class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group" @click="privacyMode = !privacyMode" :title="privacyMode ? '关闭隐私模式' : '开启隐私模式'">
-          <div class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]">
-            <svg class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="privacyMode ? 'text-[#07b75b]' : 'text-[#5d5d5d]'" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5">
-              <path v-if="privacyMode" stroke-linecap="round" stroke-linejoin="round" d="M3.98 8.223A10.477 10.477 0 001.934 12C3.226 16.338 7.244 19.5 12 19.5c.993 0 1.953-.138 2.863-.395M6.228 6.228A10.45 10.45 0 0112 4.5c4.756 0 8.773 3.162 10.065 7.498a10.523 10.523 0 01-4.293 5.774M6.228 6.228L3 3m3.228 3.228l3.65 3.65m7.894 7.894L21 21m-3.228-3.228l-3.65-3.65m0 0a3 3 0 10-4.243-4.243m4.242 4.242L9.88 9.88" />
-              <path v-else stroke-linecap="round" stroke-linejoin="round" d="M2.036 12.322a1.012 1.012 0 010-.639C3.423 7.51 7.36 4.5 12 4.5c4.638 0 8.573 3.007 9.963 7.178.07.207.07.431 0 .639C20.577 16.49 16.64 19.5 12 19.5c-4.638 0-8.573-3.007-9.963-7.178z" />
-              <circle v-if="!privacyMode" cx="12" cy="12" r="3" />
-            </svg>
-          </div>
-        </div>
-      </div>
-    </div>
-
    <div class="flex-1 flex flex-col min-h-0" style="background-color: #EDEDED">
-      <DesktopTitleBar />
      <div class="flex-1 min-h-0 overflow-hidden p-4">
        <div class="h-full grid grid-cols-1 lg:grid-cols-[400px_minmax(0,1fr)] gap-4">
          <div class="bg-white border border-gray-200 rounded-lg flex flex-col min-h-0 overflow-hidden">
@@ -198,34 +124,20 @@
 </template>

 <script setup>
+import { storeToRefs } from 'pinia'
+import { useChatAccountsStore } from '~/stores/chatAccounts'
+import { usePrivacyStore } from '~/stores/privacy'
+
 useHead({ title: '联系人 - 微信数据分析助手' })

-const route = useRoute()
 const api = useApi()

-const isChatRoute = computed(() => route.path?.startsWith('/chat'))
-const isSnsRoute = computed(() => route.path?.startsWith('/sns'))
-const isWrappedRoute = computed(() => route.path?.startsWith('/wrapped'))
+const chatAccounts = useChatAccountsStore()
+const { accounts: availableAccounts, selectedAccount } = storeToRefs(chatAccounts)

-const PRIVACY_MODE_KEY = 'ui.privacy_mode'
-const privacyMode = ref(false)
-onMounted(() => {
-  if (!process.client) return
-  try {
-    privacyMode.value = localStorage.getItem(PRIVACY_MODE_KEY) === '1'
-  } catch {}
-})
-watch(() => privacyMode.value, (v) => {
-  if (!process.client) return
-  try {
-    localStorage.setItem(PRIVACY_MODE_KEY, v ? '1' : '0')
-  } catch {}
-})
+const privacyStore = usePrivacyStore()
+const { privacyMode } = storeToRefs(privacyStore)

-const sidebarMediaBase = process.client ? 'http://localhost:8000' : ''
-
-const availableAccounts = ref([])
-const selectedAccount = ref(null)
 const searchKeyword = ref('')

 const contactTypes = reactive({
@@ -258,12 +170,6 @@ const exporting = ref(false)
 const exportMsg = ref('')
 const exportOk = ref(false)

-const selfAvatarUrl = computed(() => {
-  const acc = String(selectedAccount.value || '').trim()
-  if (!acc) return ''
-  return `${sidebarMediaBase}/api/chat/avatar?account=${encodeURIComponent(acc)}&username=${encodeURIComponent(acc)}`
-})
-
 const typeLabel = (type) => {
  if (type === 'friend') return '好友'
  if (type === 'group') return '群聊'
@@ -278,18 +184,6 @@ const typeBadgeClass = (type) => {
  return 'bg-gray-100 text-gray-600'
 }

-const goChat = async () => {
-  await navigateTo('/chat')
-}
-
-const goSns = async () => {
-  await navigateTo('/sns')
-}
-
-const goWrapped = async () => {
-  await navigateTo('/wrapped')
-}
-
 const isDesktopExportRuntime = () => {
  return !!(process.client && window?.wechatDesktop?.chooseDirectory)
 }
@@ -430,15 +324,7 @@ const exportContactsInWeb = async () => {
 }

 const loadAccounts = async () => {
-  try {
-    const resp = await api.listChatAccounts()
-    const accounts = resp?.accounts || []
-    availableAccounts.value = accounts
-    selectedAccount.value = selectedAccount.value || resp?.default_account || accounts[0] || null
-  } catch (e) {
-    availableAccounts.value = []
-    selectedAccount.value = null
-  }
+  await chatAccounts.ensureLoaded({ force: true })
 }

 const loadContacts = async () => {
@@ -555,18 +441,8 @@ const startExport = async () => {
 }

 onMounted(async () => {
+  privacyStore.init()
  await loadAccounts()
  await loadContacts()
 })
 </script>
-
-<style scoped>
-.privacy-blur {
-  filter: blur(9px);
-  transition: filter 0.2s ease;
-}
-
-.privacy-blur:hover {
-  filter: none;
-}
-</style>
@@ -68,17 +68,12 @@
 <script setup>
 import { onMounted } from 'vue'
 import { useApi } from '~/composables/useApi'
-
-const DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY = 'desktop.settings.defaultToChatWhenData'
+import { DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY, readLocalBoolSetting } from '~/utils/desktop-settings'

 onMounted(async () => {
  if (!process.client || typeof window === 'undefined') return
-  if (!window.wechatDesktop) return

-  let enabled = false
-  try {
-    enabled = localStorage.getItem(DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY) === 'true'
-  } catch {}
+  const enabled = readLocalBoolSetting(DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY, false)
  if (!enabled) return

  try {
@@ -0,0 +1,214 @@
+<template>
+  <div class="h-screen flex overflow-hidden" style="background-color: #EDEDED">
+    <div class="flex-1 flex flex-col min-h-0" style="background-color: #EDEDED">
+      <div class="flex-1 min-h-0 overflow-auto p-6">
+        <div class="max-w-3xl mx-auto">
+          <div class="bg-white border border-gray-200 rounded-lg overflow-hidden">
+            <div class="px-5 py-4 border-b border-gray-200 bg-[#F7F7F7]">
+              <div class="text-lg font-semibold text-gray-900">设置</div>
+              <div class="text-sm text-gray-500 mt-1">桌面端相关行为与启动偏好</div>
+            </div>
+
+            <div class="p-5 space-y-5">
+              <div v-if="!isDesktopEnv" class="rounded-md border border-amber-200 bg-amber-50 text-amber-900 px-3 py-2 text-xs leading-5">
+                当前为浏览器环境：“桌面行为”分组仅桌面端可用；“启动偏好”分组可正常使用。
+              </div>
+
+              <div class="rounded-lg border border-gray-200">
+                <div class="px-4 py-3 border-b border-gray-200 bg-gray-50">
+                  <div class="text-sm font-medium text-gray-900">桌面行为</div>
+                </div>
+                <div class="px-4 py-3 space-y-4">
+                  <div class="flex items-center justify-between gap-4">
+                    <div class="min-w-0">
+                      <div class="text-sm font-medium text-gray-900">开机自启动</div>
+                      <div class="text-xs text-gray-500">系统登录后自动启动桌面端</div>
+                    </div>
+                    <input
+                      type="checkbox"
+                      class="h-4 w-4"
+                      :checked="desktopAutoLaunch"
+                      :disabled="!isDesktopEnv || desktopAutoLaunchLoading"
+                      @change="onDesktopAutoLaunchToggle"
+                    />
+                  </div>
+                  <div v-if="desktopAutoLaunchError" class="text-xs text-red-600 whitespace-pre-wrap">
+                    {{ desktopAutoLaunchError }}
+                  </div>
+
+                  <div class="flex items-center justify-between gap-4">
+                    <div class="min-w-0">
+                      <div class="text-sm font-medium text-gray-900">关闭窗口行为</div>
+                      <div class="text-xs text-gray-500">点击关闭按钮时：默认最小化到托盘</div>
+                    </div>
+                    <select
+                      class="text-sm px-2 py-1 rounded-md border border-gray-200 bg-white"
+                      :disabled="!isDesktopEnv || desktopCloseBehaviorLoading"
+                      :value="desktopCloseBehavior"
+                      @change="onDesktopCloseBehaviorChange"
+                    >
+                      <option value="tray">最小化到托盘</option>
+                      <option value="exit">直接退出</option>
+                    </select>
+                  </div>
+                  <div v-if="desktopCloseBehaviorError" class="text-xs text-red-600 whitespace-pre-wrap">
+                    {{ desktopCloseBehaviorError }}
+                  </div>
+                </div>
+              </div>
+
+              <div class="rounded-lg border border-gray-200">
+                <div class="px-4 py-3 border-b border-gray-200 bg-gray-50">
+                  <div class="text-sm font-medium text-gray-900">启动偏好</div>
+                </div>
+                <div class="px-4 py-3 space-y-4">
+                  <div class="flex items-center justify-between gap-4">
+                    <div class="min-w-0">
+                      <div class="text-sm font-medium text-gray-900">启动后自动开启实时获取</div>
+                      <div class="text-xs text-gray-500">进入聊天页后自动打开“实时开关”（默认关闭）</div>
+                    </div>
+                    <input
+                      type="checkbox"
+                      class="h-4 w-4"
+                      :checked="desktopAutoRealtime"
+                      @change="onDesktopAutoRealtimeToggle"
+                    />
+                  </div>
+
+                  <div class="flex items-center justify-between gap-4">
+                    <div class="min-w-0">
+                      <div class="text-sm font-medium text-gray-900">有数据时默认进入聊天页</div>
+                      <div class="text-xs text-gray-500">有已解密账号时，打开应用默认跳转到 /chat（默认关闭）</div>
+                    </div>
+                    <input
+                      type="checkbox"
+                      class="h-4 w-4"
+                      :checked="desktopDefaultToChatWhenData"
+                      @change="onDesktopDefaultToChatToggle"
+                    />
+                  </div>
+                </div>
+              </div>
+            </div>
+          </div>
+        </div>
+      </div>
+    </div>
+  </div>
+</template>
+
+<script setup>
+import { DESKTOP_SETTING_AUTO_REALTIME_KEY, DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY, readLocalBoolSetting, writeLocalBoolSetting } from '~/utils/desktop-settings'
+
+useHead({ title: '设置 - 微信数据分析助手' })
+
+const isDesktopEnv = ref(false)
+
+const desktopAutoRealtime = ref(false)
+const desktopDefaultToChatWhenData = ref(false)
+
+const desktopAutoLaunch = ref(false)
+const desktopAutoLaunchLoading = ref(false)
+const desktopAutoLaunchError = ref('')
+
+const desktopCloseBehavior = ref('tray')
+const desktopCloseBehaviorLoading = ref(false)
+const desktopCloseBehaviorError = ref('')
+
+const refreshDesktopAutoLaunch = async () => {
+  if (!process.client || typeof window === 'undefined') return
+  if (!window.wechatDesktop?.getAutoLaunch) return
+  desktopAutoLaunchLoading.value = true
+  desktopAutoLaunchError.value = ''
+  try {
+    desktopAutoLaunch.value = !!(await window.wechatDesktop.getAutoLaunch())
+  } catch (e) {
+    desktopAutoLaunchError.value = e?.message || '读取开机自启动状态失败'
+  } finally {
+    desktopAutoLaunchLoading.value = false
+  }
+}
+
+const setDesktopAutoLaunch = async (enabled) => {
+  if (!process.client || typeof window === 'undefined') return
+  if (!window.wechatDesktop?.setAutoLaunch) return
+  desktopAutoLaunchLoading.value = true
+  desktopAutoLaunchError.value = ''
+  try {
+    desktopAutoLaunch.value = !!(await window.wechatDesktop.setAutoLaunch(!!enabled))
+  } catch (e) {
+    desktopAutoLaunchError.value = e?.message || '设置开机自启动失败'
+    await refreshDesktopAutoLaunch()
+  } finally {
+    desktopAutoLaunchLoading.value = false
+  }
+}
+
+const refreshDesktopCloseBehavior = async () => {
+  if (!process.client || typeof window === 'undefined') return
+  if (!window.wechatDesktop?.getCloseBehavior) return
+  desktopCloseBehaviorLoading.value = true
+  desktopCloseBehaviorError.value = ''
+  try {
+    const v = await window.wechatDesktop.getCloseBehavior()
+    desktopCloseBehavior.value = String(v || '').toLowerCase() === 'exit' ? 'exit' : 'tray'
+  } catch (e) {
+    desktopCloseBehaviorError.value = e?.message || '读取关闭窗口行为失败'
+  } finally {
+    desktopCloseBehaviorLoading.value = false
+  }
+}
+
+const setDesktopCloseBehavior = async (behavior) => {
+  if (!process.client || typeof window === 'undefined') return
+  if (!window.wechatDesktop?.setCloseBehavior) return
+  const desired = String(behavior || '').toLowerCase() === 'exit' ? 'exit' : 'tray'
+  desktopCloseBehaviorLoading.value = true
+  desktopCloseBehaviorError.value = ''
+  try {
+    const v = await window.wechatDesktop.setCloseBehavior(desired)
+    desktopCloseBehavior.value = String(v || '').toLowerCase() === 'exit' ? 'exit' : 'tray'
+  } catch (e) {
+    desktopCloseBehaviorError.value = e?.message || '设置关闭窗口行为失败'
+    await refreshDesktopCloseBehavior()
+  } finally {
+    desktopCloseBehaviorLoading.value = false
+  }
+}
+
+const onDesktopAutoLaunchToggle = async (ev) => {
+  const checked = !!ev?.target?.checked
+  await setDesktopAutoLaunch(checked)
+}
+
+const onDesktopCloseBehaviorChange = async (ev) => {
+  const v = String(ev?.target?.value || '').trim()
+  await setDesktopCloseBehavior(v)
+}
+
+const onDesktopAutoRealtimeToggle = (ev) => {
+  const checked = !!ev?.target?.checked
+  desktopAutoRealtime.value = checked
+  writeLocalBoolSetting(DESKTOP_SETTING_AUTO_REALTIME_KEY, checked)
+}
+
+const onDesktopDefaultToChatToggle = (ev) => {
+  const checked = !!ev?.target?.checked
+  desktopDefaultToChatWhenData.value = checked
+  writeLocalBoolSetting(DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY, checked)
+}
+
+onMounted(async () => {
+  if (process.client && typeof window !== 'undefined') {
+    isDesktopEnv.value = !!window.wechatDesktop
+  }
+
+  desktopAutoRealtime.value = readLocalBoolSetting(DESKTOP_SETTING_AUTO_REALTIME_KEY, false)
+  desktopDefaultToChatWhenData.value = readLocalBoolSetting(DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY, false)
+
+  if (isDesktopEnv.value) {
+    await refreshDesktopAutoLaunch()
+    await refreshDesktopCloseBehavior()
+  }
+})
+</script>
@@ -1,146 +1,7 @@
 <template>
  <div class="h-screen flex overflow-hidden" style="background-color: #EDEDED">
-    <!-- 左侧边栏 -->
-    <div class="border-r border-gray-200 flex flex-col" style="background-color: #e8e7e7; width: 60px; min-width: 60px; max-width: 60px">
-      <div class="flex-1 flex flex-col justify-start pt-0 gap-0">
-        <!-- 头像（类似微信侧边栏） -->
-        <div class="w-full h-[60px] flex items-center justify-center">
-          <div class="w-[40px] h-[40px] rounded-md overflow-hidden bg-gray-300 flex-shrink-0">
-            <img v-if="selfAvatarUrl" :src="selfAvatarUrl" alt="avatar" class="w-full h-full object-cover" />
-            <div
-              v-else
-              class="w-full h-full flex items-center justify-center text-white text-xs font-bold"
-              style="background-color: #4B5563"
-            >
-              我
-            </div>
-          </div>
-        </div>
-
-        <!-- 聊天图标 -->
-        <div
-          class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
-          title="聊天"
-          @click="goChat"
-        >
-          <div
-            class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]"
-          >
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isChatRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="currentColor" aria-hidden="true">
-                <path
-                  d="M12 19.8C17.52 19.8 22 15.99 22 11.3C22 6.6 17.52 2.8 12 2.8C6.48 2.8 2 6.6 2 11.3C2 13.29 2.8 15.12 4.15 16.57C4.6 17.05 4.82 17.29 4.92 17.44C5.14 17.79 5.21 17.99 5.23 18.4C5.24 18.59 5.22 18.81 5.16 19.26C5.1 19.75 5.07 19.99 5.13 20.16C5.23 20.49 5.53 20.71 5.87 20.72C6.04 20.72 6.27 20.63 6.72 20.43L8.07 19.86C8.43 19.71 8.61 19.63 8.77 19.59C8.95 19.55 9.04 19.54 9.22 19.54C9.39 19.53 9.64 19.57 10.14 19.65C10.74 19.75 11.37 19.8 12 19.8Z"
-                />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <!-- 朋友圈图标（Aperture 风格） -->
-        <div
-          class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
-          title="朋友圈"
-          @click="goSns"
-        >
-          <div
-            class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]"
-          >
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isSnsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg
-                class="w-full h-full"
-                viewBox="0 0 24 24"
-                fill="none"
-                stroke="currentColor"
-                stroke-width="1.5"
-                stroke-linecap="round"
-                stroke-linejoin="round"
-                aria-hidden="true"
-              >
-                <circle cx="12" cy="12" r="10" />
-                <line x1="14.31" y1="8" x2="20.05" y2="17.94" />
-                <line x1="9.69" y1="8" x2="21.17" y2="8" />
-                <line x1="7.38" y1="12" x2="13.12" y2="2.06" />
-                <line x1="9.69" y1="16" x2="3.95" y2="6.06" />
-                <line x1="14.31" y1="16" x2="2.83" y2="16" />
-                <line x1="16.62" y1="12" x2="10.88" y2="21.94" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <!-- 联系人图标 -->
-        <div
-          class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
-          title="联系人"
-          @click="goContacts"
-        >
-          <div
-            class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]"
-          >
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isContactsRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg class="w-full h-full" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.8" stroke-linecap="round" stroke-linejoin="round" aria-hidden="true">
-                <path d="M17 21v-2a4 4 0 0 0-4-4H7a4 4 0 0 0-4 4v2" />
-                <circle cx="10" cy="7" r="4" />
-                <path d="M23 21v-2a4 4 0 0 0-3-3.87" />
-                <path d="M16 3.13a4 4 0 0 1 0 7.75" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <!-- 年度总结图标 -->
-        <div
-          class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
-          title="年度总结"
-          @click="goWrapped"
-        >
-          <div
-            class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]"
-          >
-            <div class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="isWrappedRoute ? 'text-[#07b75b]' : 'text-[#5d5d5d]'">
-              <svg
-                class="w-full h-full"
-                viewBox="0 0 24 24"
-                fill="none"
-                stroke="currentColor"
-                stroke-width="1.5"
-                stroke-linecap="round"
-                stroke-linejoin="round"
-                aria-hidden="true"
-              >
-                <rect x="4" y="4" width="16" height="16" rx="2" />
-                <path d="M8 16v-5" />
-                <path d="M12 16v-8" />
-                <path d="M16 16v-3" />
-              </svg>
-            </div>
-          </div>
-        </div>
-
-        <!-- 隐私模式按钮 -->
-        <div
-          class="w-full h-[var(--sidebar-rail-step)] flex items-center justify-center cursor-pointer group"
-          @click="privacyMode = !privacyMode"
-          :title="privacyMode ? '关闭隐私模式' : '开启隐私模式'"
-        >
-          <div
-            class="w-[var(--sidebar-rail-btn)] h-[var(--sidebar-rail-btn)] rounded-md flex items-center justify-center transition-colors bg-transparent group-hover:bg-[#E1E1E1]"
-          >
-            <svg class="w-[var(--sidebar-rail-icon)] h-[var(--sidebar-rail-icon)]" :class="privacyMode ? 'text-[#07b75b]' : 'text-[#5d5d5d]'" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.5">
-              <path v-if="privacyMode" stroke-linecap="round" stroke-linejoin="round" d="M3.98 8.223A10.477 10.477 0 001.934 12C3.226 16.338 7.244 19.5 12 19.5c.993 0 1.953-.138 2.863-.395M6.228 6.228A10.45 10.45 0 0112 4.5c4.756 0 8.773 3.162 10.065 7.498a10.523 10.523 0 01-4.293 5.774M6.228 6.228L3 3m3.228 3.228l3.65 3.65m7.894 7.894L21 21m-3.228-3.228l-3.65-3.65m0 0a3 3 0 10-4.243-4.243m4.242 4.242L9.88 9.88" />
-              <path v-else stroke-linecap="round" stroke-linejoin="round" d="M2.036 12.322a1.012 1.012 0 010-.639C3.423 7.51 7.36 4.5 12 4.5c4.638 0 8.573 3.007 9.963 7.178.07.207.07.431 0 .639C20.577 16.49 16.64 19.5 12 19.5c-4.638 0-8.573-3.007-9.963-7.178z" />
-              <circle v-if="!privacyMode" cx="12" cy="12" r="3" />
-            </svg>
-          </div>
-        </div>
-      </div>
-    </div>
-
    <!-- 右侧朋友圈区域 -->
    <div class="flex-1 flex flex-col min-h-0" style="background-color: #EDEDED">
-      <!-- 桌面端标题栏放在内容区（与聊天页一致） -->
-      <DesktopTitleBar />
-
 	      <div class="flex-1 overflow-auto min-h-0">
 	        <div class="max-w-2xl mx-auto px-4 py-4">
 	          <div v-if="error" class="text-sm text-red-500 whitespace-pre-wrap py-2">{{ error }}</div>
@@ -425,39 +286,19 @@
 	</template>

 <script setup>
+import { storeToRefs } from 'pinia'
+import { useChatAccountsStore } from '~/stores/chatAccounts'
+import { usePrivacyStore } from '~/stores/privacy'
+
 useHead({ title: '朋友圈 - 微信数据分析助手' })

-const route = useRoute()
-
-const isChatRoute = computed(() => route.path?.startsWith('/chat'))
-const isSnsRoute = computed(() => route.path?.startsWith('/sns'))
-const isContactsRoute = computed(() => route.path?.startsWith('/contacts'))
-const isWrappedRoute = computed(() => route.path?.startsWith('/wrapped'))
-
-// 隐私模式（聊天/朋友圈共用本地开关）
-const PRIVACY_MODE_KEY = 'ui.privacy_mode'
-const privacyMode = ref(false)
-
-onMounted(() => {
-  if (!process.client) return
-  try {
-    privacyMode.value = localStorage.getItem(PRIVACY_MODE_KEY) === '1'
-  } catch {}
-})
-
-watch(
-  () => privacyMode.value,
-  (v) => {
-    if (!process.client) return
-    try {
-      localStorage.setItem(PRIVACY_MODE_KEY, v ? '1' : '0')
-    } catch {}
-  }
-)
-
 const api = useApi()
-const selectedAccount = ref(null)
-const availableAccounts = ref([])
+
+const chatAccounts = useChatAccountsStore()
+const { selectedAccount, accounts: availableAccounts } = storeToRefs(chatAccounts)
+
+const privacyStore = usePrivacyStore()
+const { privacyMode } = storeToRefs(privacyStore)

 const posts = ref([])
 const hasMore = ref(true)
@@ -665,12 +506,6 @@ const onCopyPostJsonClick = async () => {
  }
 }

-const selfAvatarUrl = computed(() => {
-  const acc = String(selectedAccount.value || '').trim()
-  if (!acc) return ''
-  return `${mediaBase}/api/chat/avatar?account=${encodeURIComponent(acc)}&username=${encodeURIComponent(acc)}`
-})
-
 const postAvatarUrl = (username) => {
  const acc = String(selectedAccount.value || '').trim()
  const u = String(username || '').trim()
@@ -1026,15 +861,9 @@ const formatRelativeTime = (tsSeconds) => {

 const loadAccounts = async () => {
  error.value = ''
-  try {
-    const resp = await api.listChatAccounts()
-    const accounts = resp?.accounts || []
-    availableAccounts.value = accounts
-    selectedAccount.value = selectedAccount.value || resp?.default_account || accounts[0] || null
-  } catch (e) {
-    error.value = e?.message || '加载账号失败'
-    availableAccounts.value = []
-    selectedAccount.value = null
+  await chatAccounts.ensureLoaded({ force: true })
+  if (!selectedAccount.value) {
+    error.value = chatAccounts.error || '未检测到已解密账号，请先解密数据库。'
  }
 }

@@ -1064,22 +893,6 @@ const loadPosts = async ({ reset }) => {
  }
 }

-const goChat = async () => {
-  await navigateTo('/chat')
-}
-
-const goSns = async () => {
-  await navigateTo('/sns')
-}
-
-const goContacts = async () => {
-  await navigateTo('/contacts')
-}
-
-const goWrapped = async () => {
-  await navigateTo('/wrapped')
-}
-
 watch(
  () => selectedAccount.value,
  async (v, oldV) => {
@@ -1104,6 +917,7 @@ watch(
 )

 onMounted(async () => {
+  privacyStore.init()
  await loadAccounts()
  loadSnsMediaOverrides()
  loadSnsSettings()
@@ -1134,15 +948,3 @@ onUnmounted(() => {
  document.removeEventListener('keydown', onGlobalKeyDown)
 })
 </script>
-
-<style scoped>
-/* 隐私模式模糊效果 */
-.privacy-blur {
-  filter: blur(9px);
-  transition: filter 0.2s ease;
-}
-
-.privacy-blur:hover {
-  filter: none;
-}
-</style>
@@ -0,0 +1,107 @@
+import { defineStore } from 'pinia'
+
+const SELECTED_ACCOUNT_KEY = 'ui.selected_account'
+
+export const useChatAccountsStore = defineStore('chatAccounts', () => {
+  const accounts = ref([])
+  const selectedAccount = ref(null)
+  const loading = ref(false)
+  const error = ref('')
+  const loaded = ref(false)
+
+  let loadPromise = null
+
+  const readSelectedAccount = () => {
+    if (!process.client) return null
+    try {
+      const raw = localStorage.getItem(SELECTED_ACCOUNT_KEY)
+      const v = String(raw || '').trim()
+      return v || null
+    } catch {
+      return null
+    }
+  }
+
+  const writeSelectedAccount = (value) => {
+    if (!process.client) return
+    try {
+      const v = String(value || '').trim()
+      if (!v) {
+        localStorage.removeItem(SELECTED_ACCOUNT_KEY)
+        return
+      }
+      localStorage.setItem(SELECTED_ACCOUNT_KEY, v)
+    } catch {}
+  }
+
+  const setSelectedAccount = (next) => {
+    selectedAccount.value = next ? String(next) : null
+    writeSelectedAccount(selectedAccount.value)
+  }
+
+  if (process.client) {
+    watch(selectedAccount, (next) => {
+      writeSelectedAccount(next)
+    })
+  }
+
+  const ensureLoaded = async ({ force = false } = {}) => {
+    if (!process.client) return
+    if (loaded.value && !force) return
+
+    if (loadPromise && !force) {
+      await loadPromise
+      return
+    }
+
+    loadPromise = (async () => {
+      loading.value = true
+      error.value = ''
+
+      if (!selectedAccount.value) {
+        const cached = readSelectedAccount()
+        if (cached) selectedAccount.value = cached
+      }
+
+      try {
+        const api = useApi()
+        const resp = await api.listChatAccounts()
+        const nextAccounts = Array.isArray(resp?.accounts) ? resp.accounts : []
+        accounts.value = nextAccounts
+
+        const preferred = String(selectedAccount.value || '').trim()
+        const defaultAccount = String(resp?.default_account || '').trim()
+        const fallback = defaultAccount || nextAccounts[0] || ''
+        const nextSelected = preferred && nextAccounts.includes(preferred) ? preferred : (fallback || null)
+
+        selectedAccount.value = nextSelected
+        writeSelectedAccount(nextSelected)
+        loaded.value = true
+      } catch (e) {
+        accounts.value = []
+        selectedAccount.value = null
+        writeSelectedAccount(null)
+        loaded.value = true
+        error.value = e?.message || '加载账号失败'
+      } finally {
+        loading.value = false
+      }
+    })()
+
+    try {
+      await loadPromise
+    } finally {
+      loadPromise = null
+    }
+  }
+
+  return {
+    accounts,
+    selectedAccount,
+    loading,
+    error,
+    loaded,
+    ensureLoaded,
+    setSelectedAccount,
+  }
+})
@@ -0,0 +1,226 @@
+import { defineStore } from 'pinia'
+
+import { useChatAccountsStore } from '~/stores/chatAccounts'
+
+export const useChatRealtimeStore = defineStore('chatRealtime', () => {
+  const chatAccounts = useChatAccountsStore()
+
+  const enabled = ref(false)
+  const available = ref(false)
+  const checking = ref(false)
+  const statusInfo = ref(null)
+  const statusError = ref('')
+  const toggling = ref(false)
+  const toggleSeq = ref(0)
+  const lastToggleAction = ref('')
+  const changeSeq = ref(0)
+  const priorityUsername = ref('')
+
+  let eventSource = null
+  let changeDebounceTimer = null
+
+  const getAccount = () => String(chatAccounts.selectedAccount || '').trim()
+
+  const setPriorityUsername = (username) => {
+    priorityUsername.value = String(username || '').trim()
+  }
+
+  const ensureReadyAccount = async () => {
+    if (!process.client) return false
+    await chatAccounts.ensureLoaded()
+    return !!getAccount()
+  }
+
+  const fetchStatus = async () => {
+    if (!process.client) return
+    const account = getAccount()
+    if (!account) {
+      available.value = false
+      statusInfo.value = null
+      statusError.value = '未检测到已解密账号，请先解密数据库。'
+      return
+    }
+
+    const api = useApi()
+    checking.value = true
+    statusError.value = ''
+    try {
+      const resp = await api.getChatRealtimeStatus({ account })
+      available.value = !!resp?.available
+      statusInfo.value = resp?.realtime || null
+      statusError.value = ''
+    } catch (e) {
+      available.value = false
+      statusInfo.value = null
+      statusError.value = e?.message || '实时状态获取失败'
+    } finally {
+      checking.value = false
+    }
+  }
+
+  const stopStream = () => {
+    if (eventSource) {
+      try {
+        eventSource.close()
+      } catch {}
+      eventSource = null
+    }
+    if (changeDebounceTimer) {
+      try {
+        clearTimeout(changeDebounceTimer)
+      } catch {}
+      changeDebounceTimer = null
+    }
+  }
+
+  const bumpChangeSeqDebounced = () => {
+    if (changeDebounceTimer) return
+    changeDebounceTimer = setTimeout(() => {
+      changeDebounceTimer = null
+      changeSeq.value += 1
+    }, 500)
+  }
+
+  const startStream = () => {
+    stopStream()
+    if (!process.client || typeof window === 'undefined') return
+    if (!enabled.value) return
+    const account = getAccount()
+    if (!account) return
+    if (typeof EventSource === 'undefined') return
+
+    const base = 'http://localhost:8000'
+    const url = `${base}/api/chat/realtime/stream?account=${encodeURIComponent(account)}`
+
+    try {
+      eventSource = new EventSource(url)
+    } catch {
+      eventSource = null
+      return
+    }
+
+    eventSource.onmessage = (ev) => {
+      try {
+        const data = JSON.parse(String(ev.data || '{}'))
+        if (String(data?.type || '') === 'change') {
+          bumpChangeSeqDebounced()
+        }
+      } catch {}
+    }
+
+    eventSource.onerror = () => {
+      // Keep `enabled` as-is; same behavior as the old in-page implementation.
+      stopStream()
+    }
+  }
+
+  const enable = async ({ silent = false } = {}) => {
+    if (toggling.value) return false
+    toggling.value = true
+    try {
+      const ok = await ensureReadyAccount()
+      if (!ok) {
+        if (!silent && process.client && typeof window !== 'undefined') {
+          window.alert('未检测到已解密账号，请先解密数据库。')
+        }
+        statusError.value = '未检测到已解密账号，请先解密数据库。'
+        return false
+      }
+
+      await fetchStatus()
+      if (!available.value) {
+        if (!silent && process.client && typeof window !== 'undefined') {
+          window.alert(statusError.value || '实时模式不可用：缺少密钥或 db_storage 路径。')
+        }
+        return false
+      }
+
+      enabled.value = true
+      startStream()
+      lastToggleAction.value = 'enabled'
+      toggleSeq.value += 1
+      return true
+    } finally {
+      toggling.value = false
+    }
+  }
+
+  const disable = async ({ silent = false } = {}) => {
+    if (toggling.value) return false
+    toggling.value = true
+    try {
+      const account = getAccount()
+      enabled.value = false
+      stopStream()
+
+      if (!account) {
+        lastToggleAction.value = 'disabled'
+        toggleSeq.value += 1
+        return true
+      }
+
+      try {
+        const api = useApi()
+        await api.syncChatRealtimeAll({
+          account,
+          max_scan: 200,
+          priority_username: priorityUsername.value || '',
+          priority_max_scan: 5000,
+          include_hidden: true,
+          include_official: true,
+        })
+      } catch (e) {
+        if (!silent && process.client && typeof window !== 'undefined') {
+          window.alert(e?.message || '关闭实时模式时同步失败')
+        }
+      }
+
+      lastToggleAction.value = 'disabled'
+      toggleSeq.value += 1
+      return true
+    } finally {
+      toggling.value = false
+    }
+  }
+
+  const toggle = async (opts = {}) => {
+    return enabled.value ? await disable(opts) : await enable(opts)
+  }
+
+  if (process.client) {
+    watch(
+      () => chatAccounts.selectedAccount,
+      async () => {
+        setPriorityUsername('')
+        await fetchStatus()
+        if (enabled.value) {
+          startStream()
+        }
+      },
+      { immediate: true }
+    )
+  }
+
+  return {
+    enabled,
+    available,
+    checking,
+    statusInfo,
+    statusError,
+    toggling,
+    toggleSeq,
+    lastToggleAction,
+    changeSeq,
+    priorityUsername,
+
+    setPriorityUsername,
+    ensureReadyAccount,
+    fetchStatus,
+    startStream,
+    stopStream,
+    enable,
+    disable,
+    toggle,
+  }
+})
+
@@ -0,0 +1,31 @@
+import { defineStore } from 'pinia'
+
+import { readPrivacyMode, writePrivacyMode } from '~/utils/privacy-mode'
+
+export const usePrivacyStore = defineStore('privacy', () => {
+  const privacyMode = ref(false)
+  const initialized = ref(false)
+
+  const init = () => {
+    if (initialized.value) return
+    initialized.value = true
+    privacyMode.value = readPrivacyMode(false)
+  }
+
+  const set = (enabled) => {
+    privacyMode.value = !!enabled
+    writePrivacyMode(privacyMode.value)
+  }
+
+  const toggle = () => {
+    set(!privacyMode.value)
+  }
+
+  return {
+    privacyMode,
+    init,
+    set,
+    toggle,
+  }
+})
+
@@ -0,0 +1,20 @@
+export const DESKTOP_SETTING_AUTO_REALTIME_KEY = 'desktop.settings.autoRealtime'
+export const DESKTOP_SETTING_DEFAULT_TO_CHAT_KEY = 'desktop.settings.defaultToChatWhenData'
+
+export const readLocalBoolSetting = (key, fallback = false) => {
+  if (!process.client) return !!fallback
+  try {
+    const raw = localStorage.getItem(String(key || ''))
+    if (raw == null) return !!fallback
+    return String(raw).toLowerCase() === 'true'
+  } catch {
+    return !!fallback
+  }
+}
+
+export const writeLocalBoolSetting = (key, value) => {
+  if (!process.client) return
+  try {
+    localStorage.setItem(String(key || ''), value ? 'true' : 'false')
+  } catch {}
+}
@@ -0,0 +1,20 @@
+export const PRIVACY_MODE_KEY = 'ui.privacy_mode'
+
+export const readPrivacyMode = (fallback = false) => {
+  if (!process.client) return !!fallback
+  try {
+    const raw = localStorage.getItem(PRIVACY_MODE_KEY)
+    if (raw == null) return !!fallback
+    const normalized = String(raw).trim().toLowerCase()
+    return normalized === '1' || normalized === 'true'
+  } catch {
+    return !!fallback
+  }
+}
+
+export const writePrivacyMode = (enabled) => {
+  if (!process.client) return
+  try {
+    localStorage.setItem(PRIVACY_MODE_KEY, enabled ? '1' : '0')
+  } catch {}
+}
@@ -28,6 +28,7 @@ from .chat_helpers import (
    _load_contact_rows,
    _lookup_resource_md5,
    _parse_app_message,
+    _parse_system_message_content,
    _parse_pat_message,
    _pick_display_name,
    _quote_ident,
@@ -954,13 +955,7 @@ def _parse_message_for_export(

    if local_type == 10000:
        render_type = "system"
-        if "revokemsg" in raw_text:
-            content_text = "撤回了一条消息"
-        else:
-            import re as _re
-
-            content_text = _re.sub(r"</?[_a-zA-Z0-9]+[^>]*>", "", raw_text)
-            content_text = _re.sub(r"\\s+", " ", content_text).strip() or "[系统消息]"
+        content_text = _parse_system_message_content(raw_text)
    elif local_type == 49:
        parsed = _parse_app_message(raw_text)
        render_type = str(parsed.get("renderType") or "text")
@@ -8,7 +8,7 @@ from collections import Counter
 from datetime import datetime
 from pathlib import Path
 from typing import Any, Optional
-from urllib.parse import quote
+from urllib.parse import quote, urlparse

 from fastapi import HTTPException

@@ -618,6 +618,39 @@ def _normalize_xml_url(url: str) -> str:
        return u.replace("&amp;", "&").strip()


+def _is_mp_weixin_article_url(url: str) -> bool:
+    u = str(url or "").strip()
+    if not u:
+        return False
+
+    try:
+        host = str(urlparse(u).hostname or "").strip().lower()
+        if host == "mp.weixin.qq.com" or host.endswith(".mp.weixin.qq.com"):
+            return True
+    except Exception:
+        pass
+
+    lu = u.lower()
+    return "mp.weixin.qq.com/" in lu
+
+
+def _classify_link_share(*, app_type: int, url: str, source_username: str, desc: str) -> tuple[str, str]:
+    src = str(source_username or "").strip().lower()
+    is_official_article = bool(
+        app_type in (5, 68)
+        and (_is_mp_weixin_article_url(url) or src.startswith("gh_"))
+    )
+
+    link_type = "official_article" if is_official_article else "web_link"
+
+    d = str(desc or "").strip()
+    hashtag_count = len(re.findall(r"#[^#\s]+", d))
+
+    # 公众号文章中「封面图 + 底栏标题」卡片特征：摘要以 #话题# 风格为主。
+    link_style = "cover" if (is_official_article and (d.startswith("#") or hashtag_count >= 2)) else "default"
+    return link_type, link_style
+
+
 def _extract_xml_tag_text(xml_text: str, tag: str) -> str:
    if not xml_text or not tag:
        return ""
@@ -645,6 +678,43 @@ def _extract_xml_tag_or_attr(xml_text: str, name: str) -> str:
    return _extract_xml_attr(xml_text, name)


+def _parse_system_message_content(raw_text: str) -> str:
+    text = str(raw_text or "").strip()
+    if not text:
+        return "[系统消息]"
+
+    def _clean_system_text(value: str) -> str:
+        candidate = str(value or "").strip()
+        if not candidate:
+            return ""
+
+        nested_content = _extract_xml_tag_text(candidate, "content")
+        if nested_content:
+            candidate = nested_content
+
+        candidate = re.sub(r"<!\[CDATA\[", "", candidate, flags=re.IGNORECASE)
+        candidate = re.sub(r"\]\]>", "", candidate)
+        candidate = re.sub(r"</?[_a-zA-Z0-9]+[^>]*>", "", candidate)
+        candidate = re.sub(r"\s+", " ", candidate).strip()
+        return candidate
+
+    if "revokemsg" in text.lower():
+        replace_msg = _extract_xml_tag_text(text, "replacemsg")
+        cleaned_replace_msg = _clean_system_text(replace_msg)
+        if cleaned_replace_msg:
+            return cleaned_replace_msg
+
+        revoke_msg = _extract_xml_tag_text(text, "revokemsg")
+        cleaned_revoke_msg = _clean_system_text(revoke_msg)
+        if cleaned_revoke_msg:
+            return cleaned_revoke_msg
+
+        return "撤回了一条消息"
+
+    content_text = _clean_system_text(text)
+    return content_text or "[系统消息]"
+
+
 def _extract_refermsg_block(xml_text: str) -> str:
    if not xml_text:
        return ""
@@ -652,6 +722,65 @@ def _extract_refermsg_block(xml_text: str) -> str:
    return (m.group(1) or "").strip() if m else ""


+def _extract_refermsg_content(refer_block: str) -> str:
+    if not refer_block:
+        return ""
+
+    cdata_match = re.search(
+        r"<content\b[^>]*>\s*<!\[CDATA\[(.*?)\]\]>\s*</content>",
+        refer_block,
+        flags=re.IGNORECASE | re.DOTALL,
+    )
+    if cdata_match:
+        return str(cdata_match.group(1) or "").strip()
+
+    return _extract_xml_tag_text(refer_block, "content")
+
+
+def _summarize_nested_quote_content(raw_content: str) -> str:
+    candidate = str(raw_content or "").strip()
+    if not candidate:
+        return ""
+
+    lower = candidate.lower()
+    if "<msg" not in lower and "<appmsg" not in lower:
+        return candidate
+
+    for tag in ("title", "des"):
+        value = _extract_xml_tag_text(candidate, tag)
+        if value:
+            return value
+
+    content_value = _extract_xml_tag_text(candidate, "content")
+    if content_value and (not str(content_value).lstrip().startswith("<")):
+        return content_value
+
+    return ""
+
+
+def _extract_nested_quote_thumb_url(raw_content: str) -> str:
+    candidate = str(raw_content or "").strip()
+    if not candidate:
+        return ""
+
+    probes = [candidate]
+
+    if candidate.startswith("wxid_"):
+        colon = candidate.find(":")
+        if 0 < colon <= 64:
+            rest = candidate[colon + 1 :].strip()
+            if rest:
+                probes.append(rest)
+
+    for probe in probes:
+        for key in ("thumburl", "cdnthumburl", "cdnthumurl", "coverurl", "cover"):
+            value = _normalize_xml_url(_extract_xml_tag_or_attr(probe, key))
+            if value:
+                return value
+
+    return ""
+
+
 def _infer_transfer_status_text(
    is_sent: bool,
    paysubtype: str,
@@ -665,7 +794,7 @@ def _infer_transfer_status_text(
    rs = str(receivestatus or "").strip()

    if rs == "1":
-        return "已收款"
+        return "已被接收" if is_sent else "已收款"
    if rs == "2":
        return "已退还"
    if rs == "3":
@@ -681,7 +810,7 @@ def _infer_transfer_status_text(
    if t == "8":
        return "发起转账"
    if t == "3":
-        return "已收款" if is_sent else "已被接收"
+        return "已被接收" if is_sent else "已收款"
    if t == "1":
        return "转账"

@@ -733,10 +862,22 @@ def _extract_sender_from_group_xml(xml_text: str) -> str:
    if not xml_text:
        return ""

-    v = _extract_xml_tag_text(xml_text, "fromusername")
+    probe_text = xml_text
+    try:
+        # Avoid picking nested quoted-message sender from <refermsg>.
+        probe_text = re.sub(
+            r"(<refermsg[^>]*>.*?</refermsg>)",
+            "",
+            xml_text,
+            flags=re.IGNORECASE | re.DOTALL,
+        )
+    except Exception:
+        probe_text = xml_text
+
+    v = _extract_xml_tag_text(probe_text, "fromusername")
    if v:
        return v
-    v = _extract_xml_attr(xml_text, "fromusername")
+    v = _extract_xml_attr(probe_text, "fromusername")
    if v:
        return v
    return ""
@@ -809,6 +950,12 @@ def _parse_app_message(text: str) -> dict[str, Any]:

    if app_type in (5, 68) and url:
        thumb_url = _normalize_xml_url(_extract_xml_tag_text(text, "thumburl"))
+        link_type, link_style = _classify_link_share(
+            app_type=app_type,
+            url=url,
+            source_username=str(source_username or "").strip(),
+            desc=str(des or "").strip(),
+        )
        return {
            "renderType": "link",
            "content": des or title or "[链接]",
@@ -817,6 +964,8 @@ def _parse_app_message(text: str) -> dict[str, Any]:
            "thumbUrl": thumb_url or "",
            "from": str(source_display_name or "").strip(),
            "fromUsername": str(source_username or "").strip(),
+            "linkType": link_type,
+            "linkStyle": link_style,
        }

    if app_type in (6, 74):
@@ -870,7 +1019,7 @@ def _parse_app_message(text: str) -> dict[str, Any]:
            or ""
        )
        refer_svrid = _extract_xml_tag_or_attr(refer_block, "svrid")
-        refer_content = _extract_xml_tag_text(refer_block, "content")
+        refer_content = _extract_refermsg_content(refer_block)
        refer_type = _extract_xml_tag_or_attr(refer_block, "type")

        rt = (reply_text or "").strip()
@@ -887,6 +1036,7 @@ def _parse_app_message(text: str) -> dict[str, Any]:
                    refer_content = rest

        t = str(refer_type or "").strip()
+        quote_thumb_url = ""
        quote_voice_length = ""
        if t == "3":
            refer_content = "[图片]"
@@ -907,8 +1057,29 @@ def _parse_app_message(text: str) -> dict[str, Any]:
            except Exception:
                quote_voice_length = ""
            refer_content = "[语音]"
-        elif t == "49" and refer_content:
-            refer_content = f"[链接] {refer_content}".strip()
+        elif t == "57":
+            summarized = _summarize_nested_quote_content(str(refer_content or ""))
+            if summarized:
+                refer_content = summarized
+            elif str(refer_content or "").lstrip().startswith("<"):
+                refer_content = "[引用消息]"
+        elif t in {"49", "5", "68"}:
+            raw_link_content = str(refer_content or "").strip()
+            summarized = _summarize_nested_quote_content(raw_link_content)
+            link_text = str(summarized or raw_link_content).strip()
+            quote_thumb_url = _extract_nested_quote_thumb_url(raw_link_content)
+
+            if link_text.startswith("wxid_"):
+                colon = link_text.find(":")
+                if 0 < colon <= 64:
+                    maybe_rest = link_text[colon + 1 :].strip()
+                    if maybe_rest:
+                        second_try = _summarize_nested_quote_content(maybe_rest)
+                        link_text = str(second_try or maybe_rest).strip()
+                    if not quote_thumb_url:
+                        quote_thumb_url = _extract_nested_quote_thumb_url(maybe_rest)
+
+            refer_content = f"[链接] {link_text}".strip() if link_text else "[链接]"

        return {
            "renderType": "quote",
@@ -917,6 +1088,7 @@ def _parse_app_message(text: str) -> dict[str, Any]:
            "quoteTitle": refer_displayname or "",
            "quoteContent": refer_content or "",
            "quoteType": t,
+            "quoteThumbUrl": quote_thumb_url,
            "quoteServerId": str(refer_svrid or "").strip(),
            "quoteVoiceLength": quote_voice_length,
        }
@@ -1053,11 +1225,7 @@ def _build_latest_message_preview(

    content_text = ""
    if local_type == 10000:
-        if "revokemsg" in raw_text:
-            content_text = "撤回了一条消息"
-        else:
-            content_text = re.sub(r"</?[_a-zA-Z0-9]+[^>]*>", "", raw_text)
-            content_text = re.sub(r"\s+", " ", content_text).strip() or "[系统消息]"
+        content_text = _parse_system_message_content(raw_text)
    elif local_type == 244813135921:
        parsed = _parse_app_message(raw_text)
        qt = str(parsed.get("quoteTitle") or "").strip()
@@ -1093,7 +1261,7 @@ def _build_latest_message_preview(
    elif local_type == 43 or local_type == 62:
        content_text = "[视频]"
    elif local_type == 47:
-        content_text = "[表情]"
+        content_text = "[动画表情]"
    else:
        if raw_text and (not raw_text.startswith("<")) and (not raw_text.startswith('"<')):
            content_text = raw_text
@@ -1107,6 +1275,101 @@ def _build_latest_message_preview(
    return content_text


+def _extract_group_preview_sender_username(preview_text: str) -> str:
+    text = str(preview_text or "").strip()
+    if not text:
+        return ""
+
+    match = re.match(r"^([^:\s]{1,128}):\s*.+$", text)
+    if not match:
+        return ""
+
+    sender = str(match.group(1) or "").strip()
+    if not sender:
+        return ""
+
+    if sender.startswith("wxid_") or sender.endswith("@chatroom") or ("@" in sender):
+        return sender
+    if re.fullmatch(r"[A-Za-z][A-Za-z0-9_-]{1,127}", sender):
+        return sender
+    return ""
+
+
+def _normalize_session_preview_text(
+    preview_text: str,
+    *,
+    is_group: bool,
+    sender_display_names: Optional[dict[str, str]] = None,
+) -> str:
+    text = re.sub(r"\s+", " ", str(preview_text or "").strip()).strip()
+    if not text:
+        return ""
+
+    text = text.replace("[表情]", "[动画表情]")
+    if (not is_group) or text.startswith("[草稿]"):
+        return text
+
+    match = re.match(r"^([^:\s]{1,128}):\s*(.+)$", text)
+    if not match:
+        return text
+
+    sender_username = str(match.group(1) or "").strip()
+    body = str(match.group(2) or "").strip()
+    if (not sender_username) or (not body):
+        return text
+
+    display_name = str((sender_display_names or {}).get(sender_username) or "").strip()
+    if display_name and display_name != sender_username:
+        return f"{display_name}: {body}"
+    return text
+
+
+def _replace_preview_sender_prefix(preview_text: str, sender_display_name: str) -> str:
+    text = re.sub(r"\s+", " ", str(preview_text or "").strip()).strip()
+    if not text:
+        return ""
+
+    display_name = str(sender_display_name or "").strip()
+    if (not display_name) or text.startswith("[草稿]"):
+        return text
+
+    match = re.match(r"^([^:\n]{1,128}):\s*(.+)$", text)
+    if not match:
+        return text
+
+    body = re.sub(r"\s+", " ", str(match.group(2) or "").strip()).strip()
+    if not body:
+        return text
+    return f"{display_name}: {body}"
+
+
+def _build_group_sender_display_name_map(
+    contact_db_path: Path,
+    previews: dict[str, str],
+) -> dict[str, str]:
+    group_sender_usernames: set[str] = set()
+    for conv_username, preview_text in previews.items():
+        if not str(conv_username or "").endswith("@chatroom"):
+            continue
+        sender_username = _extract_group_preview_sender_username(preview_text)
+        if sender_username:
+            group_sender_usernames.add(sender_username)
+
+    if not group_sender_usernames:
+        return {}
+
+    display_names: dict[str, str] = {}
+    sender_contact_rows = _load_contact_rows(contact_db_path, list(group_sender_usernames))
+    for sender_username in group_sender_usernames:
+        row = sender_contact_rows.get(sender_username)
+        if row is None:
+            continue
+        display_name = _pick_display_name(row, sender_username)
+        if display_name and display_name != sender_username:
+            display_names[sender_username] = display_name
+    return display_names
+
+
 def _load_latest_message_previews(account_dir: Path, usernames: list[str]) -> dict[str, str]:
    if not usernames:
        return {}
@@ -1338,6 +1601,208 @@ def _load_contact_rows(contact_db_path: Path, usernames: list[str]) -> dict[str,
        conn.close()


+def _load_group_nickname_map_from_contact_db(
+    contact_db_path: Path,
+    chatroom_id: str,
+    sender_usernames: list[str],
+) -> dict[str, str]:
+    """Best-effort mapping for group member nickname (aka group card) from contact.db.
+
+    WeChat stores per-chatroom member nicknames in `contact.db.chat_room.ext_buffer` as a protobuf-like blob.
+    This helper parses that blob and returns { sender_username -> group_nickname } for the requested senders.
+
+    Notes:
+    - Best-effort: never raises; returns {} on any failure.
+    - Only resolves usernames included in `sender_usernames` to keep parsing cheap.
+    """
+
+    chatroom = str(chatroom_id or "").strip()
+    if not chatroom.endswith("@chatroom"):
+        return {}
+
+    targets = list(dict.fromkeys([str(x or "").strip() for x in sender_usernames if str(x or "").strip()]))
+    if not targets:
+        return {}
+    target_set = set(targets)
+
+    def decode_varint(raw: bytes, offset: int) -> tuple[Optional[int], int]:
+        value = 0
+        shift = 0
+        pos = int(offset)
+        n = len(raw)
+        while pos < n:
+            byte = raw[pos]
+            pos += 1
+            value |= (byte & 0x7F) << shift
+            if (byte & 0x80) == 0:
+                return value, pos
+            shift += 7
+            if shift > 63:
+                return None, n
+        return None, n
+
+    def iter_fields(raw: bytes):
+        idx = 0
+        n = len(raw)
+        while idx < n:
+            tag, idx_next = decode_varint(raw, idx)
+            if tag is None or idx_next <= idx:
+                break
+            idx = idx_next
+            field_no = int(tag) >> 3
+            wire_type = int(tag) & 0x7
+
+            if wire_type == 0:
+                _, idx_next = decode_varint(raw, idx)
+                if idx_next <= idx:
+                    break
+                idx = idx_next
+                continue
+
+            if wire_type == 2:
+                size, idx_next = decode_varint(raw, idx)
+                if size is None or idx_next <= idx:
+                    break
+                idx = idx_next
+                end = idx + int(size)
+                if end > n:
+                    break
+                chunk = raw[idx:end]
+                idx = end
+                yield field_no, wire_type, chunk
+                continue
+
+            if wire_type == 1:
+                idx += 8
+                continue
+            if wire_type == 5:
+                idx += 4
+                continue
+            break
+
+    def is_strong_username_hint(s: str) -> bool:
+        v = str(s or "").strip()
+        return v.startswith("wxid_") or v.endswith("@chatroom") or v.startswith("gh_") or ("@" in v)
+
+    def looks_like_username(s: str) -> bool:
+        v = str(s or "").strip()
+        if not v:
+            return False
+        if is_strong_username_hint(v):
+            return True
+        # Common alias-style WeChat IDs are ASCII-ish and do not contain whitespace.
+        if len(v) < 6 or len(v) > 32:
+            return False
+        if re.search(r"\s", v):
+            return False
+        if not re.match(r"^[A-Za-z][A-Za-z0-9_-]+$", v):
+            return False
+        if v.isdigit():
+            return False
+        return True
+
+    def pick_display(strings: list[tuple[int, str]], target: str) -> str:
+        best_score = -1
+        best = ""
+        for i, (fno, value) in enumerate(strings):
+            v = str(value or "").strip()
+            if (not v) or v == target:
+                continue
+            if is_strong_username_hint(v):
+                continue
+            if "\n" in v or "\r" in v:
+                continue
+            if len(v) > 64:
+                continue
+
+            score = 0
+            if int(fno) == 2:
+                score += 100
+            if not looks_like_username(v):
+                score += 20
+            score += max(0, 32 - len(v))
+            # Stable tie-breaker: prefer earlier appearance.
+            score = score * 1000 - i
+            if score > best_score:
+                best_score = score
+                best = v
+        return best
+
+    try:
+        conn = sqlite3.connect(str(contact_db_path))
+    except Exception:
+        return {}
+
+    try:
+        row = conn.execute(
+            "SELECT ext_buffer FROM chat_room WHERE username = ? LIMIT 1",
+            (chatroom,),
+        ).fetchone()
+        if row is None:
+            return {}
+
+        ext = row[0]
+        if ext is None:
+            return {}
+        if isinstance(ext, memoryview):
+            ext_buf = ext.tobytes()
+        elif isinstance(ext, (bytes, bytearray)):
+            ext_buf = bytes(ext)
+        else:
+            return {}
+        if not ext_buf:
+            return {}
+
+        out: dict[str, str] = {}
+        for _, wire_type, chunk in iter_fields(ext_buf):
+            if wire_type != 2 or (not chunk):
+                continue
+
+            # Parse submessage and collect UTF-8 strings.
+            strings: list[tuple[int, str]] = []
+            try:
+                for sfno, swire, sval in iter_fields(chunk):
+                    if swire != 2:
+                        continue
+                    if not sval:
+                        continue
+                    if len(sval) > 256:
+                        continue
+                    try:
+                        txt = bytes(sval).decode("utf-8", errors="strict")
+                    except Exception:
+                        continue
+                    txt = txt.strip()
+                    if not txt:
+                        continue
+                    strings.append((int(sfno), txt))
+            except Exception:
+                continue
+
+            if not strings:
+                continue
+
+            present = [v for _, v in strings if v in target_set and v not in out]
+            if not present:
+                continue
+
+            for target in present:
+                disp = pick_display(strings, target)
+                if disp:
+                    out[target] = disp
+            if len(out) >= len(target_set):
+                break
+
+        return out
+    except Exception:
+        return {}
+    finally:
+        try:
+            conn.close()
+        except Exception:
+            pass
+
+
 def _load_usernames_by_display_names(contact_db_path: Path, names: list[str]) -> dict[str, str]:
    """Best-effort mapping from display name -> username using contact.db.

@@ -1488,10 +1953,10 @@ def _row_to_search_hit(
    if is_group and raw_text and (not raw_text.startswith("<")) and (not raw_text.startswith('"<')):
        sender_prefix, raw_text = _split_group_sender_prefix(raw_text, sender_username)

-    if is_group and sender_prefix:
+    if is_group and sender_prefix and (not sender_username):
        sender_username = sender_prefix

-    if is_group and raw_text and (raw_text.startswith("<") or raw_text.startswith('"<')):
+    if is_group and (not sender_username) and raw_text and (raw_text.startswith("<") or raw_text.startswith('"<')):
        xml_sender = _extract_sender_from_group_xml(raw_text)
        if xml_sender:
            sender_username = xml_sender
@@ -1508,6 +1973,9 @@ def _row_to_search_hit(
    quote_username = ""
    quote_title = ""
    quote_content = ""
+    quote_thumb_url = ""
+    link_type = ""
+    link_style = ""
    amount = ""
    pay_sub_type = ""
    transfer_status = ""
@@ -1515,11 +1983,7 @@ def _row_to_search_hit(

    if local_type == 10000:
        render_type = "system"
-        if "revokemsg" in raw_text:
-            content_text = "撤回了一条消息"
-        else:
-            content_text = re.sub(r"</?[_a-zA-Z0-9]+[^>]*>", "", raw_text)
-            content_text = re.sub(r"\s+", " ", content_text).strip() or "[系统消息]"
+        content_text = _parse_system_message_content(raw_text)
    elif local_type == 49:
        parsed = _parse_app_message(raw_text)
        render_type = str(parsed.get("renderType") or "text")
@@ -1528,6 +1992,9 @@ def _row_to_search_hit(
        url = str(parsed.get("url") or "")
        quote_title = str(parsed.get("quoteTitle") or "")
        quote_content = str(parsed.get("quoteContent") or "")
+        quote_thumb_url = str(parsed.get("quoteThumbUrl") or "")
+        link_type = str(parsed.get("linkType") or "")
+        link_style = str(parsed.get("linkStyle") or "")
        quote_username = str(parsed.get("quoteUsername") or "")
        amount = str(parsed.get("amount") or "")
        pay_sub_type = str(parsed.get("paySubType") or "")
@@ -1552,6 +2019,7 @@ def _row_to_search_hit(
        content_text = str(parsed.get("content") or "[引用消息]")
        quote_title = str(parsed.get("quoteTitle") or "")
        quote_content = str(parsed.get("quoteContent") or "")
+        quote_thumb_url = str(parsed.get("quoteThumbUrl") or "")
        quote_username = str(parsed.get("quoteUsername") or "")
    elif local_type == 3:
        render_type = "image"
@@ -1601,6 +2069,9 @@ def _row_to_search_hit(
                        url = str(parsed.get("url") or url)
                        quote_title = str(parsed.get("quoteTitle") or quote_title)
                        quote_content = str(parsed.get("quoteContent") or quote_content)
+                        quote_thumb_url = str(parsed.get("quoteThumbUrl") or quote_thumb_url)
+                        link_type = str(parsed.get("linkType") or link_type)
+                        link_style = str(parsed.get("linkStyle") or link_style)
                        amount = str(parsed.get("amount") or amount)
                        pay_sub_type = str(parsed.get("paySubType") or pay_sub_type)
                        quote_username = str(parsed.get("quoteUsername") or quote_username)
@@ -1640,9 +2111,12 @@ def _row_to_search_hit(
        "content": content_text,
        "title": title,
        "url": url,
+        "linkType": link_type,
+        "linkStyle": link_style,
        "quoteUsername": quote_username,
        "quoteTitle": quote_title,
        "quoteContent": quote_content,
+        "quoteThumbUrl": quote_thumb_url,
        "amount": amount,
        "paySubType": pay_sub_type,
        "transferStatus": transfer_status,
@@ -23,17 +23,17 @@ logger = get_logger(__name__)


 # 运行时输出目录（桌面端可通过 WECHAT_TOOL_DATA_DIR 指向可写目录）
-_OUTPUT_DATABASES_DIR = get_output_databases_dir()
 _PACKAGE_ROOT = Path(__file__).resolve().parent


 def _list_decrypted_accounts() -> list[str]:
    """列出已解密输出的账号目录名（仅保留包含 session.db + contact.db 的账号）"""
-    if not _OUTPUT_DATABASES_DIR.exists():
+    output_db_dir = get_output_databases_dir()
+    if not output_db_dir.exists():
        return []

    accounts: list[str] = []
-    for p in _OUTPUT_DATABASES_DIR.iterdir():
+    for p in output_db_dir.iterdir():
        if not p.is_dir():
            continue
        if (p / "session.db").exists() and (p / "contact.db").exists():
@@ -45,6 +45,7 @@ def _list_decrypted_accounts() -> list[str]:

 def _resolve_account_dir(account: Optional[str]) -> Path:
    """解析账号目录，并进行路径安全校验（防止路径穿越）"""
+    output_db_dir = get_output_databases_dir()
    accounts = _list_decrypted_accounts()
    if not accounts:
        raise HTTPException(
@@ -53,8 +54,8 @@ def _resolve_account_dir(account: Optional[str]) -> Path:
        )

    selected = account or accounts[0]
-    base = _OUTPUT_DATABASES_DIR.resolve()
-    candidate = (_OUTPUT_DATABASES_DIR / selected).resolve()
+    base = output_db_dir.resolve()
+    candidate = (output_db_dir / selected).resolve()

    if candidate != base and base not in candidate.parents:
        raise HTTPException(status_code=400, detail="Invalid account path.")
@@ -688,6 +688,83 @@ def _lookup_resource_md5_by_server_id(account_dir_str: str, server_id: int, want
            pass


+@lru_cache(maxsize=4096)
+def _lookup_image_md5_by_server_id_from_messages(account_dir_str: str, server_id: int, username: str) -> str:
+    account_dir_str = str(account_dir_str or "").strip()
+    username = str(username or "").strip()
+    if not account_dir_str or not username:
+        return ""
+
+    try:
+        sid = int(server_id or 0)
+    except Exception:
+        sid = 0
+    if not sid:
+        return ""
+
+    try:
+        chat_hash = hashlib.md5(username.encode()).hexdigest()
+    except Exception:
+        return ""
+    if not chat_hash:
+        return ""
+
+    table_name = f"Msg_{chat_hash}"
+    account_dir = Path(account_dir_str)
+
+    db_paths: list[Path] = []
+    try:
+        for p in account_dir.glob("message_*.db"):
+            try:
+                if p.is_file():
+                    db_paths.append(p)
+            except Exception:
+                continue
+    except Exception:
+        db_paths = []
+
+    if not db_paths:
+        return ""
+    db_paths.sort(key=lambda p: p.name)
+
+    for db_path in db_paths:
+        try:
+            conn = sqlite3.connect(str(db_path))
+        except Exception:
+            continue
+
+        try:
+            row = conn.execute(
+                f"SELECT local_type, packed_info_data FROM {table_name} "
+                "WHERE server_id = ? ORDER BY create_time DESC LIMIT 1",
+                (sid,),
+            ).fetchone()
+        except Exception:
+            row = None
+        finally:
+            try:
+                conn.close()
+            except Exception:
+                pass
+
+        if not row:
+            continue
+
+        try:
+            local_type = int(row[0] or 0)
+        except Exception:
+            local_type = 0
+        if local_type != 3:
+            continue
+
+        md5 = _extract_md5_from_packed_info(row[1])
+        md5_norm = str(md5 or "").strip().lower()
+        if _is_valid_md5(md5_norm):
+            return md5_norm
+
+    return ""
+
+
 def _is_safe_http_url(url: str) -> bool:
    u = str(url or "").strip()
    if not u:
@@ -1062,6 +1139,12 @@ async def get_chat_image(
        resource_md5 = _lookup_resource_md5_by_server_id(str(account_dir), int(server_id), want_local_type=3)
        if resource_md5:
            md5 = resource_md5
+        elif username:
+            md5_from_msg = _lookup_image_md5_by_server_id_from_messages(
+                str(account_dir), int(server_id), str(username)
+            )
+            if md5_from_msg:
+                md5 = md5_from_msg

    # md5 模式：优先从解密资源目录读取（更快）
    if md5:
@@ -102,6 +102,17 @@ def _load_wcdb_lib() -> ctypes.CDLL:
        lib.wcdb_get_group_members.argtypes = [ctypes.c_int64, ctypes.c_char_p, ctypes.POINTER(ctypes.c_char_p)]
        lib.wcdb_get_group_members.restype = ctypes.c_int

+        # Optional (newer DLLs): wcdb_get_group_nicknames(handle, chatroom_id, out_json)
+        try:
+            lib.wcdb_get_group_nicknames.argtypes = [
+                ctypes.c_int64,
+                ctypes.c_char_p,
+                ctypes.POINTER(ctypes.c_char_p),
+            ]
+            lib.wcdb_get_group_nicknames.restype = ctypes.c_int
+        except Exception:
+            pass
+
        # Optional: execute arbitrary SQL on a selected database kind/path.
        # Signature: wcdb_exec_query(handle, kind, path, sql, out_json)
        try:
@@ -355,6 +366,41 @@ def get_avatar_urls(handle: int, usernames: list[str]) -> dict[str, str]:
    return {}


+def get_group_members(handle: int, chatroom_id: str) -> list[dict[str, Any]]:
+    _ensure_initialized()
+    lib = _load_wcdb_lib()
+    cid = str(chatroom_id or "").strip()
+    if not cid:
+        return []
+    out_json = _call_out_json(lib.wcdb_get_group_members, ctypes.c_int64(int(handle)), cid.encode("utf-8"))
+    decoded = _safe_load_json(out_json)
+    if isinstance(decoded, list):
+        out: list[dict[str, Any]] = []
+        for x in decoded:
+            if isinstance(x, dict):
+                out.append(x)
+        return out
+    return []
+
+
+def get_group_nicknames(handle: int, chatroom_id: str) -> dict[str, str]:
+    _ensure_initialized()
+    lib = _load_wcdb_lib()
+    fn = getattr(lib, "wcdb_get_group_nicknames", None)
+    if not fn:
+        return {}
+
+    cid = str(chatroom_id or "").strip()
+    if not cid:
+        return {}
+
+    out_json = _call_out_json(fn, ctypes.c_int64(int(handle)), cid.encode("utf-8"))
+    decoded = _safe_load_json(out_json)
+    if isinstance(decoded, dict):
+        return {str(k): str(v) for k, v in decoded.items()}
+    return {}
+
+
 def exec_query(handle: int, *, kind: str, path: Optional[str], sql: str) -> list[dict[str, Any]]:
    """Execute raw SQL on a specific db kind/path via WCDB.

@@ -122,6 +122,16 @@ class TestChatExportMessageTypesSemantics(unittest.TestCase):
                (3, 1003, 49, 3, 2, 1735689603, '<msg><appmsg><type>2000</type><des>收到转账0.01元</des></appmsg></msg>', None),
                (4, 1004, 1, 4, 2, 1735689604, '普通文本消息', None),
                (5, 1005, 10000, 5, 2, 1735689605, '系统提示消息', None),
+                (
+                    6,
+                    1006,
+                    10000,
+                    6,
+                    2,
+                    1735689606,
+                    '<sysmsg type="revokemsg"><revokemsg><replacemsg><![CDATA[“测试好友”撤回了一条消息]]></replacemsg></revokemsg></sysmsg>',
+                    None,
+                ),
            ]
            conn.executemany(
                f"INSERT INTO {table_name} (local_id, server_id, local_type, sort_seq, real_sender_id, create_time, message_content, compress_content) VALUES (?, ?, ?, ?, ?, ?, ?, ?)",
@@ -413,6 +423,37 @@ class TestChatExportMessageTypesSemantics(unittest.TestCase):
                else:
                    os.environ["WECHAT_TOOL_DATA_DIR"] = prev_data

+    def test_system_revoke_exports_readable_revoker_content(self):
+        with TemporaryDirectory() as td:
+            root = Path(td)
+            account = "wxid_test"
+            username = "wxid_friend"
+            self._prepare_account(root, account=account, username=username)
+
+            prev_data = os.environ.get("WECHAT_TOOL_DATA_DIR")
+            try:
+                os.environ["WECHAT_TOOL_DATA_DIR"] = str(root)
+                svc = self._reload_export_modules()
+                job = self._create_job(
+                    svc.CHAT_EXPORT_MANAGER,
+                    account=account,
+                    username=username,
+                    message_types=["system"],
+                    include_media=False,
+                )
+                self.assertEqual(job.status, "done", msg=job.error)
+
+                payload, _, _ = self._load_export_payload(job.zip_path)
+                revoke_msg = next((m for m in payload.get("messages", []) if int(m.get("serverId") or 0) == 1006), None)
+                self.assertIsNotNone(revoke_msg)
+                self.assertEqual(str(revoke_msg.get("renderType") or ""), "system")
+                self.assertEqual(str(revoke_msg.get("content") or ""), "“测试好友”撤回了一条消息")
+            finally:
+                if prev_data is None:
+                    os.environ.pop("WECHAT_TOOL_DATA_DIR", None)
+                else:
+                    os.environ["WECHAT_TOOL_DATA_DIR"] = prev_data
+

 if __name__ == "__main__":
    unittest.main()
@@ -0,0 +1,111 @@
+import sqlite3
+import sys
+import threading
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+from unittest.mock import patch
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.routers import chat as chat_router
+
+
+class _DummyRequest:
+    base_url = "http://testserver/"
+
+
+class _DummyConn:
+    def __init__(self) -> None:
+        self.handle = 1
+        self.lock = threading.Lock()
+
+
+def _seed_session_db(session_db_path: Path) -> None:
+    conn = sqlite3.connect(str(session_db_path))
+    try:
+        conn.execute(
+            """
+            CREATE TABLE SessionTable (
+                username TEXT PRIMARY KEY,
+                unread_count INTEGER DEFAULT 0,
+                is_hidden INTEGER DEFAULT 0,
+                summary TEXT DEFAULT '',
+                draft TEXT DEFAULT '',
+                last_timestamp INTEGER DEFAULT 0,
+                sort_timestamp INTEGER DEFAULT 0,
+                last_msg_locald_id INTEGER DEFAULT 0,
+                last_msg_type INTEGER DEFAULT 0,
+                last_msg_sub_type INTEGER DEFAULT 0,
+                last_msg_sender TEXT DEFAULT '',
+                last_sender_display_name TEXT DEFAULT ''
+            )
+            """
+        )
+        conn.commit()
+    finally:
+        conn.close()
+
+
+class TestChatRealtimeSyncAllUpdatesSenderDisplayName(unittest.TestCase):
+    def test_sync_all_upserts_last_sender_display_name(self):
+        with TemporaryDirectory() as td:
+            account_dir = Path(td) / "acc"
+            account_dir.mkdir(parents=True, exist_ok=True)
+            _seed_session_db(account_dir / "session.db")
+
+            conn = _DummyConn()
+            sessions_rows = [
+                {
+                    "username": "demo@chatroom",
+                    "unread_count": 0,
+                    "is_hidden": 0,
+                    "summary": "hello",
+                    "draft": "",
+                    "last_timestamp": 123,
+                    "sort_timestamp": 123,
+                    "last_msg_type": 1,
+                    "last_msg_sub_type": 0,
+                    "last_msg_sender": "wxid_demo",
+                    "last_sender_display_name": "群名片A",
+                    "last_msg_locald_id": 777,
+                }
+            ]
+
+            with (
+                patch.object(chat_router, "_resolve_account_dir", return_value=account_dir),
+                patch.object(chat_router.WCDB_REALTIME, "ensure_connected", return_value=conn),
+                patch.object(chat_router, "_wcdb_get_sessions", return_value=sessions_rows),
+                patch.object(chat_router, "_ensure_decrypted_message_tables", return_value={}),
+                patch.object(chat_router, "_should_keep_session", return_value=True),
+            ):
+                resp = chat_router.sync_chat_realtime_messages_all(
+                    _DummyRequest(),
+                    account="acc",
+                    max_scan=20,
+                    include_hidden=True,
+                    include_official=True,
+                )
+
+            self.assertEqual(resp.get("status"), "success")
+
+            db = sqlite3.connect(str(account_dir / "session.db"))
+            try:
+                row = db.execute(
+                    "SELECT last_sender_display_name, last_msg_sender, last_msg_locald_id FROM SessionTable WHERE username = ? LIMIT 1",
+                    ("demo@chatroom",),
+                ).fetchone()
+            finally:
+                db.close()
+
+            self.assertIsNotNone(row)
+            self.assertEqual(str(row[0] or ""), "群名片A")
+            self.assertEqual(str(row[1] or ""), "wxid_demo")
+            self.assertEqual(int(row[2] or 0), 777)
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,93 @@
+import sys
+import threading
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+from unittest.mock import patch
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+
+from wechat_decrypt_tool.routers import chat as chat_router
+
+
+class _DummyRequest:
+    base_url = "http://testserver/"
+
+
+class _DummyConn:
+    def __init__(self) -> None:
+        self.handle = 1
+        self.lock = threading.Lock()
+
+
+class TestChatRealtimeVideoThumbMd5FromPackedInfo(unittest.TestCase):
+    def test_video_thumb_md5_filled_from_packed_info(self):
+        packed_md5 = "faff984641f9dd174e01c74f0796c9ae"
+        file_id = "3057020100044b3049020100020445eb9d5102032f54690204749999db0204698c336b0424deadbeef"
+        video_md5 = "22e6612411898b6d43b7e773e504d506"
+        xml = (
+            '<?xml version="1.0"?>\n'
+            "<msg>\n"
+            f'  <videomsg fromusername="wxid_sender" md5="{video_md5}" cdnthumburl="{file_id}" cdnvideourl="{file_id}" />\n'
+            "</msg>\n"
+        )
+
+        wcdb_rows = [
+            {
+                "localId": 1,
+                "serverId": 123,
+                "localType": 43,
+                "sortSeq": 1700000000000,
+                "realSenderId": 1,
+                "createTime": 1700000000,
+                "messageContent": xml,
+                "compressContent": None,
+                "packedInfoData": packed_md5.encode("ascii"),
+                "senderUsername": "wxid_sender",
+            }
+        ]
+
+        with TemporaryDirectory() as td:
+            account_dir = Path(td) / "acc"
+            account_dir.mkdir(parents=True, exist_ok=True)
+            conn = _DummyConn()
+
+            with (
+                patch.object(chat_router, "_resolve_account_dir", return_value=account_dir),
+                patch.object(chat_router.WCDB_REALTIME, "ensure_connected", return_value=conn),
+                patch.object(chat_router, "_wcdb_get_messages", return_value=wcdb_rows),
+                patch.object(chat_router, "_load_contact_rows", return_value={}),
+                patch.object(chat_router, "_query_head_image_usernames", return_value=set()),
+                patch.object(chat_router, "_wcdb_get_display_names", return_value={}),
+                patch.object(chat_router, "_wcdb_get_avatar_urls", return_value={}),
+                patch.object(chat_router, "_load_usernames_by_display_names", return_value={}),
+                patch.object(chat_router, "_load_group_nickname_map", return_value={}),
+            ):
+                resp = chat_router.list_chat_messages(
+                    _DummyRequest(),
+                    username="demo@chatroom",
+                    account="acc",
+                    limit=50,
+                    offset=0,
+                    order="asc",
+                    render_types=None,
+                    source="realtime",
+                )
+
+        self.assertEqual(resp.get("status"), "success")
+        messages = resp.get("messages") or []
+        self.assertEqual(len(messages), 1)
+        msg = messages[0]
+        self.assertEqual(msg.get("renderType"), "video")
+        self.assertEqual(msg.get("videoThumbMd5"), packed_md5)
+        thumb_url = str(msg.get("videoThumbUrl") or "")
+        self.assertIn(f"md5={packed_md5}", thumb_url)
+        self.assertNotIn("file_id=", thumb_url)
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,68 @@
+import sqlite3
+import sys
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import (
+    _build_group_sender_display_name_map,
+    _normalize_session_preview_text,
+    _replace_preview_sender_prefix,
+)
+
+
+class TestChatSessionPreviewFormatting(unittest.TestCase):
+    def test_normalize_session_preview_emoji_label(self):
+        out = _normalize_session_preview_text("[表情]", is_group=False, sender_display_names={})
+        self.assertEqual(out, "[动画表情]")
+
+    def test_normalize_group_preview_sender_display_name(self):
+        out = _normalize_session_preview_text(
+            "wxid_u3gwceqvne2m22: [表情]",
+            is_group=True,
+            sender_display_names={"wxid_u3gwceqvne2m22": "食神"},
+        )
+        self.assertEqual(out, "食神: [动画表情]")
+
+    def test_build_group_sender_display_name_map_from_contact_db(self):
+        with TemporaryDirectory() as td:
+            contact_db_path = Path(td) / "contact.db"
+            conn = sqlite3.connect(str(contact_db_path))
+            try:
+                conn.execute(
+                    """
+                    CREATE TABLE contact (
+                        username TEXT,
+                        remark TEXT,
+                        nick_name TEXT,
+                        alias TEXT,
+                        big_head_url TEXT,
+                        small_head_url TEXT
+                    )
+                    """
+                )
+                conn.execute(
+                    "INSERT INTO contact VALUES (?, ?, ?, ?, ?, ?)",
+                    ("wxid_u3gwceqvne2m22", "", "食神", "", "", ""),
+                )
+                conn.commit()
+            finally:
+                conn.close()
+
+            mapping = _build_group_sender_display_name_map(
+                contact_db_path,
+                {"demo@chatroom": "wxid_u3gwceqvne2m22: [动画表情]"},
+            )
+            self.assertEqual(mapping.get("wxid_u3gwceqvne2m22"), "食神")
+
+    def test_replace_preview_sender_prefix_uses_group_nickname(self):
+        out = _replace_preview_sender_prefix("去码头整点🍟: [动画表情]", "麻辣香锅")
+        self.assertEqual(out, "麻辣香锅: [动画表情]")
+
+
+if __name__ == "__main__":
+    unittest.main()
@@ -0,0 +1,211 @@
+import sqlite3
+import sys
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+from unittest.mock import patch
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+
+from wechat_decrypt_tool.routers import chat as chat_router
+
+
+class _DummyRequest:
+    base_url = "http://testserver/"
+
+
+def _seed_session_db(path: Path, rows: list[tuple[str, int, int, str]]) -> None:
+    conn = sqlite3.connect(str(path))
+    try:
+        conn.execute(
+            """
+            CREATE TABLE SessionTable(
+                username TEXT PRIMARY KEY,
+                unread_count INTEGER,
+                is_hidden INTEGER,
+                summary TEXT,
+                draft TEXT,
+                last_timestamp INTEGER,
+                sort_timestamp INTEGER,
+                last_msg_type INTEGER,
+                last_msg_sub_type INTEGER
+            )
+            """
+        )
+        for username, sort_timestamp, last_timestamp, summary in rows:
+            conn.execute(
+                """
+                INSERT INTO SessionTable(
+                    username, unread_count, is_hidden, summary, draft,
+                    last_timestamp, sort_timestamp, last_msg_type, last_msg_sub_type
+                ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
+                """,
+                (
+                    username,
+                    0,
+                    0,
+                    summary,
+                    "",
+                    int(last_timestamp),
+                    int(sort_timestamp),
+                    1,
+                    0,
+                ),
+            )
+        conn.commit()
+    finally:
+        conn.close()
+
+
+def _seed_contact_db_with_flag(path: Path, flags: dict[str, int]) -> None:
+    conn = sqlite3.connect(str(path))
+    try:
+        conn.execute(
+            """
+            CREATE TABLE contact(
+                username TEXT,
+                remark TEXT,
+                nick_name TEXT,
+                alias TEXT,
+                big_head_url TEXT,
+                small_head_url TEXT,
+                flag INTEGER
+            )
+            """
+        )
+        conn.execute(
+            """
+            CREATE TABLE stranger(
+                username TEXT,
+                remark TEXT,
+                nick_name TEXT,
+                alias TEXT,
+                big_head_url TEXT,
+                small_head_url TEXT,
+                flag INTEGER
+            )
+            """
+        )
+        for username, flag in flags.items():
+            conn.execute(
+                "INSERT INTO contact VALUES (?, ?, ?, ?, ?, ?, ?)",
+                (username, "", "", "", "", "", int(flag)),
+            )
+        conn.commit()
+    finally:
+        conn.close()
+
+
+def _seed_contact_db_without_flag(path: Path, usernames: list[str]) -> None:
+    conn = sqlite3.connect(str(path))
+    try:
+        conn.execute(
+            """
+            CREATE TABLE contact(
+                username TEXT,
+                remark TEXT,
+                nick_name TEXT,
+                alias TEXT,
+                big_head_url TEXT,
+                small_head_url TEXT
+            )
+            """
+        )
+        conn.execute(
+            """
+            CREATE TABLE stranger(
+                username TEXT,
+                remark TEXT,
+                nick_name TEXT,
+                alias TEXT,
+                big_head_url TEXT,
+                small_head_url TEXT
+            )
+            """
+        )
+        for username in usernames:
+            conn.execute(
+                "INSERT INTO contact VALUES (?, ?, ?, ?, ?, ?)",
+                (username, "", "", "", "", ""),
+            )
+        conn.commit()
+    finally:
+        conn.close()
+
+
+class TestChatSessionsPinning(unittest.TestCase):
+    def test_pinned_session_is_sorted_first_and_has_is_top(self):
+        with TemporaryDirectory() as td:
+            account_dir = Path(td) / "acc"
+            account_dir.mkdir(parents=True, exist_ok=True)
+
+            _seed_session_db(
+                account_dir / "session.db",
+                [
+                    ("wxid_new", 200, 200, "new message"),
+                    ("wxid_top", 100, 100, "top older message"),
+                ],
+            )
+            _seed_contact_db_with_flag(
+                account_dir / "contact.db",
+                {
+                    "wxid_new": 0,
+                    "wxid_top": 1 << 11,
+                },
+            )
+
+            with patch.object(chat_router, "_resolve_account_dir", return_value=account_dir):
+                resp = chat_router.list_chat_sessions(
+                    _DummyRequest(),
+                    account="acc",
+                    limit=50,
+                    include_hidden=True,
+                    include_official=True,
+                    preview="session",
+                    source="",
+                )
+
+            self.assertEqual(resp.get("status"), "success")
+            sessions = resp.get("sessions") or []
+            self.assertEqual(len(sessions), 2)
+            self.assertEqual(sessions[0].get("username"), "wxid_top")
+            self.assertTrue(bool(sessions[0].get("isTop")))
+            self.assertEqual(sessions[1].get("username"), "wxid_new")
+            self.assertFalse(bool(sessions[1].get("isTop")))
+
+    def test_missing_flag_column_does_not_error_and_defaults_false(self):
+        with TemporaryDirectory() as td:
+            account_dir = Path(td) / "acc"
+            account_dir.mkdir(parents=True, exist_ok=True)
+
+            _seed_session_db(
+                account_dir / "session.db",
+                [
+                    ("wxid_top", 100, 100, "hello"),
+                ],
+            )
+            _seed_contact_db_without_flag(account_dir / "contact.db", ["wxid_top"])
+
+            with patch.object(chat_router, "_resolve_account_dir", return_value=account_dir):
+                resp = chat_router.list_chat_sessions(
+                    _DummyRequest(),
+                    account="acc",
+                    limit=50,
+                    include_hidden=True,
+                    include_official=True,
+                    preview="session",
+                    source="",
+                )
+
+            self.assertEqual(resp.get("status"), "success")
+            sessions = resp.get("sessions") or []
+            self.assertEqual(len(sessions), 1)
+            self.assertFalse(bool(sessions[0].get("isTop")))
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,103 @@
+import sys
+import threading
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+from unittest.mock import patch
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+
+from wechat_decrypt_tool.routers import chat as chat_router
+
+
+class _DummyRequest:
+    base_url = "http://testserver/"
+
+
+class _DummyConn:
+    def __init__(self) -> None:
+        self.handle = 1
+        self.lock = threading.Lock()
+
+
+class TestChatSessionsRealtimeSenderPreview(unittest.TestCase):
+    def _run(self, sessions_rows: list[dict]) -> dict:
+        with TemporaryDirectory() as td:
+            account_dir = Path(td) / "acc"
+            account_dir.mkdir(parents=True, exist_ok=True)
+
+            conn = _DummyConn()
+            with (
+                patch.object(chat_router, "_resolve_account_dir", return_value=account_dir),
+                patch.object(chat_router.WCDB_REALTIME, "ensure_connected", return_value=conn),
+                patch.object(chat_router, "_wcdb_get_sessions", return_value=sessions_rows),
+                patch.object(chat_router, "_wcdb_get_display_names", return_value={}),
+                patch.object(chat_router, "_wcdb_get_avatar_urls", return_value={}),
+                patch.object(chat_router, "_load_contact_rows", return_value={}),
+                patch.object(chat_router, "_query_head_image_usernames", return_value=set()),
+                patch.object(chat_router, "_should_keep_session", return_value=True),
+                patch.object(chat_router, "_avatar_url_unified", return_value="/avatar"),
+            ):
+                return chat_router.list_chat_sessions(
+                    _DummyRequest(),
+                    account="acc",
+                    limit=50,
+                    include_hidden=True,
+                    include_official=True,
+                    preview="latest",
+                    source="realtime",
+                )
+
+    def test_realtime_sessions_group_summary_prefixed_by_sender_display_name(self):
+        resp = self._run(
+            [
+                {
+                    "username": "demo@chatroom",
+                    "summary": "hello",
+                    "draft": "",
+                    "unread_count": 0,
+                    "is_hidden": 0,
+                    "last_timestamp": 123,
+                    "sort_timestamp": 123,
+                    "last_msg_type": 1,
+                    "last_msg_sub_type": 0,
+                    "last_msg_sender": "wxid_demo",
+                    "last_sender_display_name": "群名片A",
+                }
+            ]
+        )
+        self.assertEqual(resp.get("status"), "success")
+        sessions = resp.get("sessions") or []
+        self.assertEqual(len(sessions), 1)
+        self.assertEqual(sessions[0].get("lastMessage"), "群名片A: hello")
+
+    def test_realtime_sessions_group_url_summary_keeps_scheme(self):
+        resp = self._run(
+            [
+                {
+                    "username": "url@chatroom",
+                    "summary": "https://example.com/x",
+                    "draft": "",
+                    "unread_count": 0,
+                    "is_hidden": 0,
+                    "last_timestamp": 123,
+                    "sort_timestamp": 123,
+                    "last_msg_type": 1,
+                    "last_msg_sub_type": 0,
+                    "last_msg_sender": "wxid_demo",
+                    "last_sender_display_name": "群名片B",
+                }
+            ]
+        )
+        self.assertEqual(resp.get("status"), "success")
+        sessions = resp.get("sessions") or []
+        self.assertEqual(len(sessions), 1)
+        self.assertEqual(sessions[0].get("lastMessage"), "群名片B: https://example.com/x")
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,42 @@
+import sys
+import unittest
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import _parse_system_message_content
+
+
+class TestChatSystemMessageParsing(unittest.TestCase):
+    def test_extract_replacemsg_for_revoke(self):
+        raw_text = (
+            '<sysmsg type="revokemsg"><revokemsg><replacemsg><![CDATA[“张三”撤回了一条消息]]>'
+            "</replacemsg></revokemsg></sysmsg>"
+        )
+        self.assertEqual(_parse_system_message_content(raw_text), "“张三”撤回了一条消息")
+
+    def test_extract_nested_content_in_replacemsg(self):
+        raw_text = (
+            '<sysmsg type="revokemsg"><revokemsg><replacemsg><![CDATA['
+            '<content>"黄智欢" 撤回了一条消息</content><revoketime>0</revoketime>'
+            ']]></replacemsg></revokemsg></sysmsg>'
+        )
+        self.assertEqual(_parse_system_message_content(raw_text), '"黄智欢" 撤回了一条消息')
+
+    def test_extract_revokemsg_text_when_replacemsg_missing(self):
+        raw_text = "<revokemsg>你撤回了一条消息</revokemsg>"
+        self.assertEqual(_parse_system_message_content(raw_text), "你撤回了一条消息")
+
+    def test_revoke_fallback_when_no_readable_text(self):
+        raw_text = '<sysmsg type="revokemsg"></sysmsg>'
+        self.assertEqual(_parse_system_message_content(raw_text), "撤回了一条消息")
+
+    def test_normal_system_message_still_cleaned(self):
+        raw_text = "<sysmsg><template><![CDATA[ 张三  加入了群聊 ]]></template></sysmsg>"
+        self.assertEqual(_parse_system_message_content(raw_text), "张三 加入了群聊")
+
+
+if __name__ == "__main__":
+    unittest.main()
@@ -0,0 +1,114 @@
+import sqlite3
+import sys
+import unittest
+from pathlib import Path
+from tempfile import TemporaryDirectory
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import _load_group_nickname_map_from_contact_db
+
+
+def _enc_varint(n: int) -> bytes:
+    v = int(n)
+    out = bytearray()
+    while True:
+        b = v & 0x7F
+        v >>= 7
+        if v:
+            out.append(b | 0x80)
+        else:
+            out.append(b)
+            break
+    return bytes(out)
+
+
+def _enc_tag(field_no: int, wire_type: int) -> bytes:
+    return _enc_varint((int(field_no) << 3) | int(wire_type))
+
+
+def _enc_len(field_no: int, data: bytes) -> bytes:
+    b = bytes(data or b"")
+    return _enc_tag(field_no, 2) + _enc_varint(len(b)) + b
+
+
+def _member_entry(*, inner: bytes) -> bytes:
+    # contact.db ext_buffer uses repeated length-delimited submessages; the top-level field number is not important
+    # for our best-effort parser, so we use field 1.
+    return _enc_len(1, inner)
+
+
+class TestGroupNicknameExtBufferParsing(unittest.TestCase):
+    def test_parse_pattern_a_field1_username_field2_display(self):
+        chatroom = "demo@chatroom"
+        username = "wxid_demo_123456"
+        display = "群名片A"
+
+        inner = _enc_len(1, username.encode("utf-8")) + _enc_len(2, display.encode("utf-8"))
+        ext_buffer = _member_entry(inner=inner)
+
+        with TemporaryDirectory() as td:
+            contact_db_path = Path(td) / "contact.db"
+            conn = sqlite3.connect(str(contact_db_path))
+            try:
+                conn.execute(
+                    "CREATE TABLE chat_room(id INTEGER PRIMARY KEY, username TEXT, owner TEXT, ext_buffer BLOB)"
+                )
+                conn.execute(
+                    "INSERT INTO chat_room(id, username, owner, ext_buffer) VALUES (?, ?, ?, ?)",
+                    (1, chatroom, "", ext_buffer),
+                )
+                conn.commit()
+            finally:
+                conn.close()
+
+            out = _load_group_nickname_map_from_contact_db(contact_db_path, chatroom, [username])
+            self.assertEqual(out.get(username), display)
+
+    def test_parse_pattern_b_field4_username_field1_display(self):
+        chatroom = "demo2@chatroom"
+        username = "wxid_demo_abcdef"
+        display = "hjlbingo"
+
+        inner = _enc_len(4, username.encode("utf-8")) + _enc_len(1, display.encode("utf-8"))
+        ext_buffer = _member_entry(inner=inner)
+
+        with TemporaryDirectory() as td:
+            contact_db_path = Path(td) / "contact.db"
+            conn = sqlite3.connect(str(contact_db_path))
+            try:
+                conn.execute(
+                    "CREATE TABLE chat_room(id INTEGER PRIMARY KEY, username TEXT, owner TEXT, ext_buffer BLOB)"
+                )
+                conn.execute(
+                    "INSERT INTO chat_room(id, username, owner, ext_buffer) VALUES (?, ?, ?, ?)",
+                    (1, chatroom, "", ext_buffer),
+                )
+                conn.commit()
+            finally:
+                conn.close()
+
+            out = _load_group_nickname_map_from_contact_db(contact_db_path, chatroom, [username])
+            self.assertEqual(out.get(username), display)
+
+    def test_non_chatroom_returns_empty(self):
+        with TemporaryDirectory() as td:
+            contact_db_path = Path(td) / "contact.db"
+            conn = sqlite3.connect(str(contact_db_path))
+            try:
+                conn.execute(
+                    "CREATE TABLE chat_room(id INTEGER PRIMARY KEY, username TEXT, owner TEXT, ext_buffer BLOB)"
+                )
+                conn.commit()
+            finally:
+                conn.close()
+
+            out = _load_group_nickname_map_from_contact_db(contact_db_path, "wxid_not_chatroom", ["wxid_xxx"])
+            self.assertEqual(out, {})
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,23 @@
+import sys
+import unittest
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import _extract_sender_from_group_xml
+
+
+class TestGroupXmlSenderExtraction(unittest.TestCase):
+    def test_prefers_outer_fromusername_over_nested_refermsg(self):
+        xml_text = (
+            '<msg><appmsg><type>57</type>'
+            '<refermsg><fromusername>quoted_user@chatroom</fromusername></refermsg>'
+            '</appmsg><fromusername>actual_sender@chatroom</fromusername></msg>'
+        )
+        self.assertEqual(_extract_sender_from_group_xml(xml_text), "actual_sender@chatroom")
+
+
+if __name__ == "__main__":
+    unittest.main()
@@ -0,0 +1,115 @@
+import sys
+import unittest
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import _parse_app_message
+
+
+class TestParseAppMessage(unittest.TestCase):
+    def test_quote_type_57_nested_refermsg_uses_inner_title(self):
+        raw_text = (
+            '<msg><appmsg appid="" sdkver="0">'
+            '<title>一松一紧</title><des></des><action></action><type>57</type>'
+            '<showtype>0</showtype><soundtype>0</soundtype><mediatagname></mediatagname>'
+            '<messageext></messageext><messageaction></messageaction><content></content>'
+            '<url></url><appattach><totallen>0</totallen><attachid></attachid><fileext></fileext></appattach>'
+            '<extinfo></extinfo><sourceusername></sourceusername><sourcedisplayname></sourcedisplayname>'
+            '<commenturl></commenturl><refermsg>'
+            '<type>57</type><svrid>1173057991425172913</svrid>'
+            '<fromusr>44372432598@chatroom</fromusr><chatusr>44372432598@chatroom</chatusr>'
+            '<displayname><![CDATA[ㅤ磁父]]></displayname>'
+            '<content><![CDATA[<msg><appmsg appid="" sdkver="0"><title>那里紧？哪里张？</title><des></des>'
+            '<action></action><type>57</type><showtype>0</showtype><soundtype>0</soundtype>'
+            '<mediatagname></mediatagname><messageext></messageext><messageaction></messageaction>'
+            '<content></content><url></url><appattach><totallen>0</totallen><attachid></attachid>'
+            '<fileext></fileext></appattach><extinfo></extinfo><sourceusername></sourceusername>'
+            '<sourcedisplayname></sourcedisplayname><commenturl></commenturl></appmsg></msg>]]></content>'
+            '</refermsg></appmsg></msg>'
+        )
+
+        parsed = _parse_app_message(raw_text)
+
+        self.assertEqual(parsed.get("renderType"), "quote")
+        self.assertEqual(parsed.get("content"), "一松一紧")
+        self.assertEqual(parsed.get("quoteType"), "57")
+        self.assertEqual(parsed.get("quoteContent"), "那里紧？哪里张？")
+
+    def test_quote_type_57_plain_text_refermsg_keeps_text(self):
+        raw_text = (
+            '<msg><appmsg appid="" sdkver="0">'
+            '<title>回复</title><type>57</type>'
+            '<refermsg><type>57</type><content><![CDATA[普通文本引用]]></content></refermsg>'
+            '</appmsg></msg>'
+        )
+
+        parsed = _parse_app_message(raw_text)
+
+        self.assertEqual(parsed.get("renderType"), "quote")
+        self.assertEqual(parsed.get("quoteContent"), "普通文本引用")
+
+    def test_quote_type_49_nested_xml_refermsg_uses_inner_title(self):
+        raw_text = (
+            '<msg><appmsg appid="" sdkver="0">'
+            '<title>这种傻逼公众号怎么还在看</title><type>57</type>'
+            '<refermsg><type>49</type><displayname><![CDATA[水豚喧喧]]></displayname>'
+            '<content><![CDATA[wxid_gryaI8aopjio22: <?xml version="1.0"?><msg><appmsg appid="" sdkver="0">'
+            '<title>为自己的美丽漂亮善良知性发声😊</title><des></des>'
+            '<type>5</type><url>https://mp.weixin.qq.com/s/example</url>'
+            '<thumburl>https://mmbiz.qpic.cn/some-thumb.jpg</thumburl>'
+            '</appmsg></msg>]]></content></refermsg></appmsg></msg>'
+        )
+
+        parsed = _parse_app_message(raw_text)
+
+        self.assertEqual(parsed.get("renderType"), "quote")
+        self.assertEqual(parsed.get("quoteType"), "49")
+        self.assertEqual(parsed.get("quoteTitle"), "水豚喧喧")
+        self.assertEqual(parsed.get("quoteContent"), "[链接] 为自己的美丽漂亮善良知性发声😊")
+        self.assertEqual(parsed.get("quoteThumbUrl"), "https://mmbiz.qpic.cn/some-thumb.jpg")
+
+    def test_public_account_link_exposes_link_type_and_style(self):
+        raw_text = (
+            '<msg><appmsg appid="" sdkver="0">'
+            '<title>为自己的美丽漂亮善良知性发声😊</title>'
+            '<des>#日常穿搭灵感 #白色蕾丝裙穿搭 #知性美女</des>'
+            '<type>5</type>'
+            '<url>http://mp.weixin.qq.com/s?__biz=xx&mid=1</url>'
+            '<thumburl>http://mmbiz.qpic.cn/abc/640?wx_fmt=jpeg</thumburl>'
+            '<sourceusername>gh_0cef8eaa987d</sourceusername>'
+            '<sourcedisplayname>草莓不甜芒果甜</sourcedisplayname>'
+            '</appmsg></msg>'
+        )
+
+        parsed = _parse_app_message(raw_text)
+
+        self.assertEqual(parsed.get("renderType"), "link")
+        self.assertEqual(parsed.get("linkType"), "official_article")
+        self.assertEqual(parsed.get("linkStyle"), "cover")
+
+    def test_quote_type_5_nested_xml_refermsg_uses_inner_title(self):
+        raw_text = (
+            '<msg><appmsg appid="" sdkver="0">'
+            '<title>这个年龄有点大啊</title><type>57</type>'
+            '<refermsg><type>5</type><displayname><![CDATA[水豚噜噜]]></displayname>'
+            '<content><![CDATA[wxid_qrval8aopiio22:\n<?xml version="1.0"?>\n<msg><appmsg appid="" sdkver="0">'
+            '<title>谁说冬天不能穿裙子？</title><des></des><type>5</type>'
+            '<thumburl>https://mmbiz.qpic.cn/some-thumb2.jpg</thumburl>'
+            '<url>https://mp.weixin.qq.com/s/example2</url>'
+            '</appmsg></msg>]]></content></refermsg></appmsg></msg>'
+        )
+
+        parsed = _parse_app_message(raw_text)
+
+        self.assertEqual(parsed.get("renderType"), "quote")
+        self.assertEqual(parsed.get("quoteType"), "5")
+        self.assertEqual(parsed.get("quoteTitle"), "水豚噜噜")
+        self.assertEqual(parsed.get("quoteContent"), "[链接] 谁说冬天不能穿裙子？")
+        self.assertEqual(parsed.get("quoteThumbUrl"), "https://mmbiz.qpic.cn/some-thumb2.jpg")
+
+
+if __name__ == "__main__":
+    unittest.main()
@@ -0,0 +1,68 @@
+import sys
+import unittest
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+
+from wechat_decrypt_tool.routers import chat as chat_router
+
+
+class TestTransferPostprocess(unittest.TestCase):
+    def test_backfilled_pending_and_received_confirmation_have_expected_titles(self):
+        transfer_id = "1000050001202601152035503031545"
+        merged = [
+            {
+                "id": "message_0:Msg_x:60",
+                "renderType": "transfer",
+                "paySubType": "1",
+                "transferId": transfer_id,
+                "amount": "￥100.00",
+                "createTime": 1768463200,
+                "isSent": False,
+                "transferStatus": "",
+            },
+            {
+                "id": "message_0:Msg_x:65",
+                "renderType": "transfer",
+                "paySubType": "3",
+                "transferId": transfer_id,
+                "amount": "￥100.00",
+                "createTime": 1768463246,
+                "isSent": True,
+                # Pre-inferred value (may be "已被接收") should be corrected by postprocess.
+                "transferStatus": "已被接收",
+            },
+        ]
+
+        chat_router._postprocess_transfer_messages(merged)
+
+        self.assertEqual(merged[0].get("paySubType"), "3")
+        self.assertEqual(merged[0].get("transferStatus"), "已被接收")
+        self.assertEqual(merged[1].get("paySubType"), "3")
+        self.assertEqual(merged[1].get("transferStatus"), "已收款")
+
+    def test_received_message_without_pending_is_left_unchanged(self):
+        merged = [
+            {
+                "id": "message_0:Msg_x:65",
+                "renderType": "transfer",
+                "paySubType": "3",
+                "transferId": "t1",
+                "amount": "￥100.00",
+                "createTime": 1,
+                "isSent": True,
+                "transferStatus": "已被接收",
+            }
+        ]
+
+        chat_router._postprocess_transfer_messages(merged)
+
+        self.assertEqual(merged[0].get("transferStatus"), "已被接收")
+
+
+if __name__ == "__main__":
+    unittest.main()
+
@@ -0,0 +1,63 @@
+import sys
+import unittest
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT / "src"))
+
+from wechat_decrypt_tool.chat_helpers import _infer_transfer_status_text
+
+
+class TestTransferStatusText(unittest.TestCase):
+    def test_paysubtype_3_sent_side(self):
+        status = _infer_transfer_status_text(
+            is_sent=True,
+            paysubtype="3",
+            receivestatus="",
+            sendertitle="",
+            receivertitle="",
+            senderdes="",
+            receiverdes="",
+        )
+        self.assertEqual(status, "已被接收")
+
+    def test_paysubtype_3_received_side(self):
+        status = _infer_transfer_status_text(
+            is_sent=False,
+            paysubtype="3",
+            receivestatus="",
+            sendertitle="",
+            receivertitle="",
+            senderdes="",
+            receiverdes="",
+        )
+        self.assertEqual(status, "已收款")
+
+    def test_receivestatus_1_sent_side(self):
+        status = _infer_transfer_status_text(
+            is_sent=True,
+            paysubtype="1",
+            receivestatus="1",
+            sendertitle="",
+            receivertitle="",
+            senderdes="",
+            receiverdes="",
+        )
+        self.assertEqual(status, "已被接收")
+
+    def test_receivestatus_1_received_side(self):
+        status = _infer_transfer_status_text(
+            is_sent=False,
+            paysubtype="1",
+            receivestatus="1",
+            sendertitle="",
+            receivertitle="",
+            senderdes="",
+            receiverdes="",
+        )
+        self.assertEqual(status, "已收款")
+
+
+if __name__ == "__main__":
+    unittest.main()