Merge pull request #217 from hicccc77/dev

更新版本号

.gitignore

@@ -57,4 +57,6 @@ Thumbs.db
 
 wcdb/
 *info
-*.md
+概述.md
+chatlab-format.md
+*.bak

README.md

@@ -38,6 +38,22 @@ WeFlow 是一个**完全本地**的微信**实时**聊天记录查看、分析
 - 统计分析与群聊画像
 - 年度报告与可视化概览
 - 导出聊天记录为 HTML 等格式
+- HTTP API 接口（供开发者集成）
+
+
+## HTTP API
+
+> [!WARNING]
+> 此功能目前处于早期阶段，接口可能会有变动，请等待后续更新完善。
+
+WeFlow 提供本地 HTTP API 服务，支持通过接口查询消息数据，可用于与其他工具集成或二次开发。
+
+- **启用方式**：设置 → API 服务 → 启动服务
+- **默认端口**：5031
+- **访问地址**：`http://127.0.0.1:5031`
+- **支持格式**：原始 JSON 或 [ChatLab](https://chatlab.fun/) 标准格式
+
+📖 完整接口文档：[点击查看](docs/HTTP-API.md)
 
 
 ## 快速开始

docs/HTTP-API.md

@@ -0,0 +1,312 @@
+# WeFlow HTTP API 接口文档
+
+WeFlow 提供 HTTP API 服务，支持通过 HTTP 接口查询消息数据，支持 [ChatLab](https://github.com/nichuanfang/chatlab-format) 标准化格式输出。
+
+## 启用 API 服务
+
+在设置页面 → API 服务 → 点击「启动服务」按钮。
+
+默认端口：`5031`
+
+## 基础地址
+
+```
+http://127.0.0.1:5031
+```
+
+---
+
+## 接口列表
+
+### 1. 健康检查
+
+检查 API 服务是否正常运行。
+
+**请求**
+```
+GET /health
+```
+
+**响应**
+```json
+{
+  "status": "ok"
+}
+```
+
+---
+
+### 2. 获取消息列表
+
+获取指定会话的消息，支持 ChatLab 格式输出。
+
+**请求**
+```
+GET /api/v1/messages
+```
+
+**参数**
+
+| 参数名 | 类型 | 必填 | 说明 |
+|--------|------|------|------|
+| `talker` | string | ✅ | 会话 ID（wxid 或群 ID） |
+| `limit` | number | ❌ | 返回数量限制，默认 100 |
+| `offset` | number | ❌ | 偏移量，用于分页，默认 0 |
+| `start` | string | ❌ | 开始时间，格式 YYYYMMDD |
+| `end` | string | ❌ | 结束时间，格式 YYYYMMDD |
+| `chatlab` | string | ❌ | 设为 `1` 则输出 ChatLab 格式 |
+| `format` | string | ❌ | 输出格式：`json`（默认）或 `chatlab` |
+
+**示例请求**
+
+```bash
+# 获取消息（原始格式）
+GET http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&limit=50
+
+# 获取消息（ChatLab 格式）
+GET http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&chatlab=1
+
+# 带时间范围查询
+GET http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&start=20260101&end=20260205&limit=100
+```
+
+**响应（原始格式）**
+```json
+{
+  "success": true,
+  "talker": "wxid_xxx",
+  "count": 50,
+  "hasMore": true,
+  "messages": [
+    {
+      "localId": 123,
+      "talker": "wxid_xxx",
+      "type": 1,
+      "content": "消息内容",
+      "createTime": 1738713600000,
+      "isSelf": false,
+      "sender": "wxid_sender"
+    }
+  ]
+}
+```
+
+**响应（ChatLab 格式）**
+```json
+{
+  "chatlab": {
+    "version": "0.0.2",
+    "exportedAt": 1738713600000,
+    "generator": "WeFlow",
+    "description": "Exported from WeFlow"
+  },
+  "meta": {
+    "name": "会话名称",
+    "platform": "wechat",
+    "type": "private",
+    "ownerId": "wxid_me"
+  },
+  "members": [
+    {
+      "platformId": "wxid_xxx",
+      "accountName": "用户名",
+      "groupNickname": "群昵称"
+    }
+  ],
+  "messages": [
+    {
+      "sender": "wxid_xxx",
+      "accountName": "用户名",
+      "timestamp": 1738713600000,
+      "type": 0,
+      "content": "消息内容"
+    }
+  ]
+}
+```
+
+---
+
+### 3. 获取会话列表
+
+获取所有会话列表。
+
+**请求**
+```
+GET /api/v1/sessions
+```
+
+**参数**
+
+| 参数名 | 类型 | 必填 | 说明 |
+|--------|------|------|------|
+| `keyword` | string | ❌ | 搜索关键词，匹配会话名或 ID |
+| `limit` | number | ❌ | 返回数量限制，默认 100 |
+
+**示例请求**
+```bash
+GET http://127.0.0.1:5031/api/v1/sessions
+
+GET http://127.0.0.1:5031/api/v1/sessions?keyword=工作群&limit=20
+```
+
+**响应**
+```json
+{
+  "success": true,
+  "count": 50,
+  "total": 100,
+  "sessions": [
+    {
+      "username": "wxid_xxx",
+      "displayName": "用户名",
+      "lastMessage": "最后一条消息",
+      "lastTime": 1738713600000,
+      "unreadCount": 0
+    }
+  ]
+}
+```
+
+---
+
+### 4. 获取联系人列表
+
+获取所有联系人信息。
+
+**请求**
+```
+GET /api/v1/contacts
+```
+
+**参数**
+
+| 参数名 | 类型 | 必填 | 说明 |
+|--------|------|------|------|
+| `keyword` | string | ❌ | 搜索关键词 |
+| `limit` | number | ❌ | 返回数量限制，默认 100 |
+
+**示例请求**
+```bash
+GET http://127.0.0.1:5031/api/v1/contacts
+
+GET http://127.0.0.1:5031/api/v1/contacts?keyword=张三
+```
+
+**响应**
+```json
+{
+  "success": true,
+  "count": 50,
+  "contacts": [
+    {
+      "userName": "wxid_xxx",
+      "alias": "微信号",
+      "nickName": "昵称",
+      "remark": "备注名"
+    }
+  ]
+}
+```
+
+---
+
+## ChatLab 格式说明
+
+ChatLab 是一种标准化的聊天记录交换格式，版本 0.0.2。
+
+### 消息类型映射
+
+| ChatLab Type | 值 | 说明 |
+|--------------|-----|------|
+| TEXT | 0 | 文本消息 |
+| IMAGE | 1 | 图片 |
+| VOICE | 2 | 语音 |
+| VIDEO | 3 | 视频 |
+| FILE | 4 | 文件 |
+| EMOJI | 5 | 表情 |
+| LINK | 7 | 链接 |
+| LOCATION | 8 | 位置 |
+| RED_PACKET | 20 | 红包 |
+| TRANSFER | 21 | 转账 |
+| CALL | 23 | 通话 |
+| SYSTEM | 80 | 系统消息 |
+| RECALL | 81 | 撤回消息 |
+| OTHER | 99 | 其他 |
+
+---
+
+## 使用示例
+
+### PowerShell
+
+```powershell
+# 健康检查
+Invoke-RestMethod http://127.0.0.1:5031/health
+
+# 获取会话列表
+Invoke-RestMethod http://127.0.0.1:5031/api/v1/sessions
+
+# 获取消息
+Invoke-RestMethod "http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&limit=10"
+
+# 获取 ChatLab 格式
+Invoke-RestMethod "http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&chatlab=1" | ConvertTo-Json -Depth 10
+```
+
+### cURL
+
+```bash
+# 健康检查
+curl http://127.0.0.1:5031/health
+
+# 获取会话列表
+curl http://127.0.0.1:5031/api/v1/sessions
+
+# 获取消息（ChatLab 格式）
+curl "http://127.0.0.1:5031/api/v1/messages?talker=wxid_xxx&chatlab=1"
+```
+
+### Python
+
+```python
+import requests
+
+BASE_URL = "http://127.0.0.1:5031"
+
+# 获取会话列表
+sessions = requests.get(f"{BASE_URL}/api/v1/sessions").json()
+print(sessions)
+
+# 获取消息
+messages = requests.get(f"{BASE_URL}/api/v1/messages", params={
+    "talker": "wxid_xxx",
+    "limit": 100,
+    "chatlab": 1
+}).json()
+print(messages)
+```
+
+### JavaScript / Node.js
+
+```javascript
+const BASE_URL = "http://127.0.0.1:5031";
+
+// 获取会话列表
+const sessions = await fetch(`${BASE_URL}/api/v1/sessions`).then(r => r.json());
+console.log(sessions);
+
+// 获取消息（ChatLab 格式）
+const messages = await fetch(`${BASE_URL}/api/v1/messages?talker=wxid_xxx&chatlab=1`)
+  .then(r => r.json());
+console.log(messages);
+```
+
+---
+
+## 注意事项
+
+1. API 仅监听本地地址 `127.0.0.1`，不对外网开放
+2. 需要先连接数据库才能查询数据
+3. 时间参数格式为 `YYYYMMDD`（如 20260205）
+4. 支持 CORS，可从浏览器前端直接调用

electron/main.ts

@@ -23,6 +23,7 @@ import { contactExportService } from './services/contactExportService'
 import { windowsHelloService } from './services/windowsHelloService'
 import { llamaService } from './services/llamaService'
 import { registerNotificationHandlers, showNotification } from './windows/notificationWindow'
+import { httpService } from './services/httpService'
 
 
 // 配置自动更新
@@ -863,6 +864,10 @@ function registerIpcHandlers() {
     return await chatService.getContactAvatar(username)
   })
 
+  ipcMain.handle('chat:resolveTransferDisplayNames', async (_, chatroomId: string, payerUsername: string, receiverUsername: string) => {
+    return await chatService.resolveTransferDisplayNames(chatroomId, payerUsername, receiverUsername)
+  })
+
   ipcMain.handle('chat:getContacts', async () => {
     return await chatService.getContacts()
   })
@@ -895,6 +900,9 @@ function registerIpcHandlers() {
   ipcMain.handle('chat:getVoiceData', async (_, sessionId: string, msgId: string, createTime?: number, serverId?: string | number) => {
     return chatService.getVoiceData(sessionId, msgId, createTime, serverId)
   })
+  ipcMain.handle('chat:getAllVoiceMessages', async (_, sessionId: string) => {
+    return chatService.getAllVoiceMessages(sessionId)
+  })
   ipcMain.handle('chat:resolveVoiceCache', async (_, sessionId: string, msgId: string) => {
     return chatService.resolveVoiceCache(sessionId, msgId)
   })
@@ -1282,6 +1290,23 @@ function registerIpcHandlers() {
     })
   })
 
+  // HTTP API 服务
+  ipcMain.handle('http:start', async (_, port?: number) => {
+    return httpService.start(port || 5031)
+  })
+
+  ipcMain.handle('http:stop', async () => {
+    await httpService.stop()
+    return { success: true }
+  })
+
+  ipcMain.handle('http:status', async () => {
+    return {
+      running: httpService.isRunning(),
+      port: httpService.getPort()
+    }
+  })
+
 }
 
 // 主窗口引用

electron/preload.ts

@@ -131,6 +131,8 @@ contextBridge.exposeInMainWorld('electronAPI', {
       ipcRenderer.invoke('chat:getNewMessages', sessionId, minTime, limit),
     getContact: (username: string) => ipcRenderer.invoke('chat:getContact', username),
     getContactAvatar: (username: string) => ipcRenderer.invoke('chat:getContactAvatar', username),
+    resolveTransferDisplayNames: (chatroomId: string, payerUsername: string, receiverUsername: string) =>
+      ipcRenderer.invoke('chat:resolveTransferDisplayNames', chatroomId, payerUsername, receiverUsername),
     getMyAvatarUrl: () => ipcRenderer.invoke('chat:getMyAvatarUrl'),
     downloadEmoji: (cdnUrl: string, md5?: string) => ipcRenderer.invoke('chat:downloadEmoji', cdnUrl, md5),
     getCachedMessages: (sessionId: string) => ipcRenderer.invoke('chat:getCachedMessages', sessionId),
@@ -139,6 +141,7 @@ contextBridge.exposeInMainWorld('electronAPI', {
     getImageData: (sessionId: string, msgId: string) => ipcRenderer.invoke('chat:getImageData', sessionId, msgId),
     getVoiceData: (sessionId: string, msgId: string, createTime?: number, serverId?: string | number) =>
       ipcRenderer.invoke('chat:getVoiceData', sessionId, msgId, createTime, serverId),
+    getAllVoiceMessages: (sessionId: string) => ipcRenderer.invoke('chat:getAllVoiceMessages', sessionId),
     resolveVoiceCache: (sessionId: string, msgId: string) => ipcRenderer.invoke('chat:resolveVoiceCache', sessionId, msgId),
     getVoiceTranscript: (sessionId: string, msgId: string, createTime?: number) => ipcRenderer.invoke('chat:getVoiceTranscript', sessionId, msgId, createTime),
     onVoiceTranscriptPartial: (callback: (payload: { msgId: string; text: string }) => void) => {
@@ -286,5 +289,12 @@ contextBridge.exposeInMainWorld('electronAPI', {
       ipcRenderer.on('llama:downloadProgress', listener)
       return () => ipcRenderer.removeListener('llama:downloadProgress', listener)
     }
+  },
+
+  // HTTP API 服务
+  http: {
+    start: (port?: number) => ipcRenderer.invoke('http:start', port),
+    stop: () => ipcRenderer.invoke('http:stop'),
+    status: () => ipcRenderer.invoke('http:status')
   }
 })

electron/services/annualReportService.ts

@@ -193,11 +193,15 @@ class AnnualReportService {
     if (!raw) return ''
     if (typeof raw === 'string') {
       if (raw.length === 0) return ''
-      if (this.looksLikeHex(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 hex 时才尝试解码
+      // 短字符串（如 "123456" 等纯数字）容易被误判为 hex
+      if (raw.length > 16 && this.looksLikeHex(raw)) {
         const bytes = Buffer.from(raw, 'hex')
         if (bytes.length > 0) return this.decodeBinaryContent(bytes)
       }
-      if (this.looksLikeBase64(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 base64 时才尝试解码
+      // 短字符串（如 "test", "home" 等）容易被误判为 base64
+      if (raw.length > 16 && this.looksLikeBase64(raw)) {
         try {
           const bytes = Buffer.from(raw, 'base64')
           return this.decodeBinaryContent(bytes)

electron/services/chatService.ts

@@ -1120,6 +1120,9 @@ class ChatService {
       // 名片消息
       let cardUsername: string | undefined
       let cardNickname: string | undefined
+      // 转账消息
+      let transferPayerUsername: string | undefined
+      let transferReceiverUsername: string | undefined
       // 聊天记录
       let chatRecordTitle: string | undefined
       let chatRecordList: Array<{
@@ -1151,8 +1154,8 @@ class ChatService {
         const cardInfo = this.parseCardInfo(content)
         cardUsername = cardInfo.username
         cardNickname = cardInfo.nickname
-      } else if (localType === 49 && content) {
-        // Type 49 消息（链接、文件、小程序、转账等）
+      } else if ((localType === 49 || localType === 8589934592049) && content) {
+        // Type 49 消息（链接、文件、小程序、转账等），8589934592049 也是转账类型
         const type49Info = this.parseType49Message(content)
         xmlType = type49Info.xmlType
         linkTitle = type49Info.linkTitle
@@ -1163,6 +1166,8 @@ class ChatService {
         fileExt = type49Info.fileExt
         chatRecordTitle = type49Info.chatRecordTitle
         chatRecordList = type49Info.chatRecordList
+        transferPayerUsername = type49Info.transferPayerUsername
+        transferReceiverUsername = type49Info.transferReceiverUsername
       } else if (localType === 244813135921 || (content && content.includes('<type>57</type>'))) {
         const quoteInfo = this.parseQuoteMessage(content)
         quotedContent = quoteInfo.content
@@ -1199,6 +1204,8 @@ class ChatService {
         xmlType,
         cardUsername,
         cardNickname,
+        transferPayerUsername,
+        transferReceiverUsername,
         chatRecordTitle,
         chatRecordList
       })
@@ -1663,6 +1670,8 @@ class ChatService {
     fileName?: string
     fileSize?: number
     fileExt?: string
+    transferPayerUsername?: string
+    transferReceiverUsername?: string
     chatRecordTitle?: string
     chatRecordList?: Array<{
       datatype: number
@@ -1786,6 +1795,16 @@ class ChatService {
           } else if (feedesc) {
             result.linkTitle = feedesc
           }
+
+          // 提取转账双方 wxid
+          const payerUsername = this.extractXmlValue(content, 'payer_username')
+          const receiverUsername = this.extractXmlValue(content, 'receiver_username')
+          if (payerUsername) {
+            result.transferPayerUsername = payerUsername
+          }
+          if (receiverUsername) {
+            result.transferReceiverUsername = receiverUsername
+          }
           break
         }
 
@@ -2227,7 +2246,9 @@ class ChatService {
       if (raw.length === 0) return ''
 
       // 检查是否是 hex 编码
-      if (this.looksLikeHex(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 hex 时才尝试解码
+      // 短字符串（如 "123456" 等纯数字）容易被误判为 hex
+      if (raw.length > 16 && this.looksLikeHex(raw)) {
         const bytes = Buffer.from(raw, 'hex')
         if (bytes.length > 0) {
           const result = this.decodeBinaryContent(bytes, raw)
@@ -2237,7 +2258,9 @@ class ChatService {
       }
 
       // 检查是否是 base64 编码
-      if (this.looksLikeBase64(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 base64 时才尝试解码
+      // 短字符串（如 "test", "home" 等）容易被误判为 base64
+      if (raw.length > 16 && this.looksLikeBase64(raw)) {
         try {
           const bytes = Buffer.from(raw, 'base64')
           return this.decodeBinaryContent(bytes, raw)
@@ -2384,6 +2407,75 @@ class ChatService {
     }
   }
 
+  /**
+   * 解析转账消息中的付款方和收款方显示名称
+   * 优先使用群昵称，群昵称为空时回退到微信昵称/备注
+   */
+  async resolveTransferDisplayNames(
+    chatroomId: string,
+    payerUsername: string,
+    receiverUsername: string
+  ): Promise<{ payerName: string; receiverName: string }> {
+    try {
+      const connectResult = await this.ensureConnected()
+      if (!connectResult.success) {
+        return { payerName: payerUsername, receiverName: receiverUsername }
+      }
+
+      // 如果是群聊，尝试获取群昵称
+      let groupNicknames: Record<string, string> = {}
+      if (chatroomId.endsWith('@chatroom')) {
+        const nickResult = await wcdbService.getGroupNicknames(chatroomId)
+        if (nickResult.success && nickResult.nicknames) {
+          groupNicknames = nickResult.nicknames
+        }
+      }
+
+      // 获取当前用户 wxid，用于识别"自己"
+      const myWxid = this.configService.get('myWxid')
+      const cleanedMyWxid = myWxid ? this.cleanAccountDirName(myWxid) : ''
+
+      // 解析付款方名称：自己 > 群昵称 > 备注 > 昵称 > alias > wxid
+      const resolveName = async (username: string): Promise<string> => {
+        // 特判：如果是当前用户自己（contact 表通常不包含自己）
+        if (myWxid && (username === myWxid || username === cleanedMyWxid)) {
+          // 先查群昵称中是否有自己
+          const myGroupNick = groupNicknames[username]
+          if (myGroupNick) return myGroupNick
+          // 尝试从缓存获取自己的昵称
+          const cached = this.avatarCache.get(username) || this.avatarCache.get(myWxid)
+          if (cached?.displayName) return cached.displayName
+          return '我'
+        }
+
+        // 先查群昵称
+        const groupNick = groupNicknames[username]
+        if (groupNick) return groupNick
+
+        // 再查联系人信息
+        const contact = await this.getContact(username)
+        if (contact) {
+          return contact.remark || contact.nickName || contact.alias || username
+        }
+
+        // 兜底：查缓存
+        const cached = this.avatarCache.get(username)
+        if (cached?.displayName) return cached.displayName
+
+        return username
+      }
+
+      const [payerName, receiverName] = await Promise.all([
+        resolveName(payerUsername),
+        resolveName(receiverUsername)
+      ])
+
+      return { payerName, receiverName }
+    } catch {
+      return { payerName: payerUsername, receiverName: receiverUsername }
+    }
+  }
+
   /**
    * 获取当前用户的头像 URL
    */
@@ -3547,6 +3639,67 @@ class ChatService {
     }
   }
 
+  /**
+   * 获取某会话的所有语音消息（localType=34），用于批量转写
+   */
+  async getAllVoiceMessages(sessionId: string): Promise<{ success: boolean; messages?: Message[]; error?: string }> {
+    try {
+      const connectResult = await this.ensureConnected()
+      if (!connectResult.success) {
+        return { success: false, error: connectResult.error || '数据库未连接' }
+      }
+
+      // 获取会话表信息
+      let tables = this.sessionTablesCache.get(sessionId)
+      if (!tables) {
+        const tableStats = await wcdbService.getMessageTableStats(sessionId)
+        if (!tableStats.success || !tableStats.tables || tableStats.tables.length === 0) {
+          return { success: false, error: '未找到会话消息表' }
+        }
+        tables = tableStats.tables
+          .map(t => ({ tableName: t.table_name || t.name, dbPath: t.db_path }))
+          .filter(t => t.tableName && t.dbPath) as Array<{ tableName: string; dbPath: string }>
+        if (tables.length > 0) {
+          this.sessionTablesCache.set(sessionId, tables)
+          setTimeout(() => { this.sessionTablesCache.delete(sessionId) }, this.sessionTablesCacheTtl)
+        }
+      }
+
+      let allVoiceMessages: Message[] = []
+
+      for (const { tableName, dbPath } of tables) {
+        try {
+          const sql = `SELECT * FROM ${tableName} WHERE local_type = 34 ORDER BY create_time DESC`
+          const result = await wcdbService.execQuery('message', dbPath, sql)
+          if (result.success && result.rows && result.rows.length > 0) {
+            const mapped = this.mapRowsToMessages(result.rows as Record<string, any>[])
+            allVoiceMessages.push(...mapped)
+          }
+        } catch (e) {
+          console.error(`[ChatService] 查询语音消息失败 (${dbPath}):`, e)
+        }
+      }
+
+      // 按 createTime 降序排序
+      allVoiceMessages.sort((a, b) => b.createTime - a.createTime)
+
+      // 去重
+      const seen = new Set<string>()
+      allVoiceMessages = allVoiceMessages.filter(msg => {
+        const key = `${msg.serverId}-${msg.localId}-${msg.createTime}-${msg.sortSeq}`
+        if (seen.has(key)) return false
+        seen.add(key)
+        return true
+      })
+
+      console.log(`[ChatService] 共找到 ${allVoiceMessages.length} 条语音消息（去重后）`)
+      return { success: true, messages: allVoiceMessages }
+    } catch (e) {
+      console.error('[ChatService] 获取所有语音消息失败:', e)
+      return { success: false, error: String(e) }
+    }
+  }
+
   async getMessageById(sessionId: string, localId: number): Promise<{ success: boolean; message?: Message; error?: string }> {
     try {
       // 1. 尝试从缓存获取会话表信息

electron/services/dualReportService.ts

@@ -106,11 +106,15 @@ class DualReportService {
     if (!raw) return ''
     if (typeof raw === 'string') {
       if (raw.length === 0) return ''
-      if (this.looksLikeHex(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 hex 时才尝试解码
+      // 短字符串（如 "123456" 等纯数字）容易被误判为 hex
+      if (raw.length > 16 && this.looksLikeHex(raw)) {
         const bytes = Buffer.from(raw, 'hex')
         if (bytes.length > 0) return this.decodeBinaryContent(bytes)
       }
-      if (this.looksLikeBase64(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 base64 时才尝试解码
+      // 短字符串（如 "test", "home" 等）容易被误判为 base64
+      if (raw.length > 16 && this.looksLikeBase64(raw)) {
         try {
           const bytes = Buffer.from(raw, 'base64')
           return this.decodeBinaryContent(bytes)

electron/services/exportService.ts

@@ -270,11 +270,14 @@ class ExportService {
       if (/^[0-9]+$/.test(raw)) {
         return raw
       }
-      if (this.looksLikeHex(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 hex 时才尝试解码
+      if (raw.length > 16 && this.looksLikeHex(raw)) {
         const bytes = Buffer.from(raw, 'hex')
         if (bytes.length > 0) return this.decodeBinaryContent(bytes)
       }
-      if (this.looksLikeBase64(raw)) {
+      // 只有当字符串足够长（超过16字符）且看起来像 base64 时才尝试解码
+      // 短字符串（如 "test", "home" 等）容易被误判为 base64
+      if (raw.length > 16 && this.looksLikeBase64(raw)) {
         try {
           const bytes = Buffer.from(raw, 'base64')
           return this.decodeBinaryContent(bytes)
@@ -345,6 +348,51 @@ class ExportService {
     }
   }
 
+  /**
+   * 从转账消息 XML 中提取并解析 "谁转账给谁" 描述
+   * @param content 原始消息内容 XML
+   * @param myWxid 当前用户 wxid
+   * @param groupNicknamesMap 群昵称映射
+   * @param getContactName 联系人名称解析函数
+   * @returns "A 转账给 B" 或 null
+   */
+  private async resolveTransferDesc(
+    content: string,
+    myWxid: string,
+    groupNicknamesMap: Map<string, string>,
+    getContactName: (username: string) => Promise<string>
+  ): Promise<string | null> {
+    const xmlType = this.extractXmlValue(content, 'type')
+    if (xmlType !== '2000') return null
+
+    const payerUsername = this.extractXmlValue(content, 'payer_username')
+    const receiverUsername = this.extractXmlValue(content, 'receiver_username')
+    if (!payerUsername || !receiverUsername) return null
+
+    const cleanedMyWxid = myWxid ? this.cleanAccountDirName(myWxid) : ''
+
+    const resolveName = async (username: string): Promise<string> => {
+      // 当前用户自己
+      if (myWxid && (username === myWxid || username === cleanedMyWxid)) {
+        const groupNick = groupNicknamesMap.get(username) || groupNicknamesMap.get(username.toLowerCase())
+        if (groupNick) return groupNick
+        return '我'
+      }
+      // 群昵称
+      const groupNick = groupNicknamesMap.get(username) || groupNicknamesMap.get(username.toLowerCase())
+      if (groupNick) return groupNick
+      // 联系人名称
+      return getContactName(username)
+    }
+
+    const [payerName, receiverName] = await Promise.all([
+      resolveName(payerUsername),
+      resolveName(receiverUsername)
+    ])
+
+    return `${payerName} 转账给 ${receiverName}`
+  }
+
   private looksLikeBase64(s: string): boolean {
     if (s.length % 4 !== 0) return false
     return /^[A-Za-z0-9+/=]+$/.test(s)
@@ -587,6 +635,47 @@ class ExportService {
     return content.replace(/^[\s]*([a-zA-Z0-9_-]+):(?!\/\/)/, '')
   }
 
+  /**
+   * 从撤回消息内容中提取撤回者的 wxid
+   * 撤回消息 XML 格式通常包含 <session> 或 <newmsgid> 等字段
+   * 以及撤回者的 wxid 在某些字段中
+   * @returns { isRevoke: true, isSelfRevoke: true } - 是自己撤回的消息
+   * @returns { isRevoke: true, revokerWxid: string } - 是别人撤回的消息，提取到撤回者
+   * @returns { isRevoke: false } - 不是撤回消息
+   */
+  private extractRevokerInfo(content: string): { isRevoke: boolean; isSelfRevoke?: boolean; revokerWxid?: string } {
+    if (!content) return { isRevoke: false }
+    
+    // 检查是否是撤回消息
+    if (!content.includes('revokemsg') && !content.includes('撤回')) {
+      return { isRevoke: false }
+    }
+    
+    // 检查是否是 "你撤回了" - 自己撤回
+    if (content.includes('你撤回')) {
+      return { isRevoke: true, isSelfRevoke: true }
+    }
+    
+    // 尝试从 <session> 标签提取（格式: wxid_xxx）
+    const sessionMatch = /<session>([^<]+)<\/session>/i.exec(content)
+    if (sessionMatch) {
+      const session = sessionMatch[1].trim()
+      // 如果 session 是 wxid 格式，返回它
+      if (session.startsWith('wxid_') || /^[a-zA-Z][a-zA-Z0-9_-]+$/.test(session)) {
+        return { isRevoke: true, revokerWxid: session }
+      }
+    }
+    
+    // 尝试从 <fromusername> 提取
+    const fromUserMatch = /<fromusername>([^<]+)<\/fromusername>/i.exec(content)
+    if (fromUserMatch) {
+      return { isRevoke: true, revokerWxid: fromUserMatch[1].trim() }
+    }
+    
+    // 是撤回消息但无法提取撤回者
+    return { isRevoke: true }
+  }
+
   private extractXmlValue(xml: string, tagName: string): string {
     const regex = new RegExp(`<${tagName}>([\\s\\S]*?)<\/${tagName}>`, 'i')
     const match = regex.exec(xml)
@@ -1405,7 +1494,30 @@ class ExportService {
           const isSend = parseInt(isSendRaw, 10) === 1
           const localId = parseInt(row.local_id || row.localId || '0', 10)
 
-          const actualSender = isSend ? cleanedMyWxid : (senderUsername || sessionId)
+          // 确定实际发送者
+          let actualSender: string
+          if (localType === 10000 || localType === 266287972401) {
+            // 系统消息特殊处理
+            const revokeInfo = this.extractRevokerInfo(content)
+            if (revokeInfo.isRevoke) {
+              // 撤回消息
+              if (revokeInfo.isSelfRevoke) {
+                // "你撤回了" - 发送者是当前用户
+                actualSender = cleanedMyWxid
+              } else if (revokeInfo.revokerWxid) {
+                // 提取到了撤回者的 wxid
+                actualSender = revokeInfo.revokerWxid
+              } else {
+                // 无法确定撤回者，使用 sessionId
+                actualSender = sessionId
+              }
+            } else {
+              // 普通系统消息（如"xxx加入群聊"），发送者是群聊ID
+              actualSender = sessionId
+            }
+          } else {
+            actualSender = isSend ? cleanedMyWxid : (senderUsername || sessionId)
+          }
           senderSet.add(actualSender)
 
           // 提取媒体相关字段
@@ -1849,6 +1961,24 @@ class ExportService {
         await this.mergeGroupMembers(sessionId, collected.memberSet, options.exportAvatars === true)
       }
 
+      // ========== 获取群昵称并更新到 memberSet ==========
+      const groupNicknamesMap = isGroup
+        ? await this.getGroupNicknamesForRoom(sessionId)
+        : new Map<string, string>()
+
+      // 将群昵称更新到 memberSet 中
+      if (isGroup && groupNicknamesMap.size > 0) {
+        for (const [username, info] of collected.memberSet) {
+          // 尝试多种方式查找群昵称（支持大小写）
+          const groupNickname = groupNicknamesMap.get(username) 
+            || groupNicknamesMap.get(username.toLowerCase())
+            || ''
+          if (groupNickname) {
+            info.member.groupNickname = groupNickname
+          }
+        }
+      }
+
       allMessages.sort((a, b) => a.createTime - b.createTime)
 
       const { exportMediaEnabled, mediaRootDir, mediaRelativePrefix } = this.getMediaLayout(outputPath, options)
@@ -1918,13 +2048,19 @@ class ExportService {
         phase: 'exporting'
       })
 
-      const chatLabMessages: ChatLabMessage[] = allMessages.map(msg => {
+      const chatLabMessages: ChatLabMessage[] = []
+      for (const msg of allMessages) {
         const memberInfo = collected.memberSet.get(msg.senderUsername)?.member || {
           platformId: msg.senderUsername,
           accountName: msg.senderUsername,
           groupNickname: undefined
         }
 
+        // 如果 memberInfo 中没有群昵称，尝试从 groupNicknamesMap 获取
+        const groupNickname = memberInfo.groupNickname 
+          || (isGroup ? (groupNicknamesMap.get(msg.senderUsername) || groupNicknamesMap.get(msg.senderUsername?.toLowerCase()) || '') : '')
+          || ''
+
         // 确定消息内容
         let content: string | null
         if (msg.localType === 34 && options.exportVoiceAsText) {
@@ -1934,10 +2070,26 @@ class ExportService {
           content = this.parseMessageContent(msg.content, msg.localType, sessionId, msg.createTime)
         }
 
+        // 转账消息：追加 "谁转账给谁" 信息
+        if (content && content.startsWith('[转账]') && msg.content) {
+          const transferDesc = await this.resolveTransferDesc(
+            msg.content,
+            cleanedMyWxid,
+            groupNicknamesMap,
+            async (username) => {
+              const info = await this.getContactInfo(username)
+              return info.displayName || username
+            }
+          )
+          if (transferDesc) {
+            content = content.replace('[转账]', `[转账] (${transferDesc})`)
+          }
+        }
+
         const message: ChatLabMessage = {
           sender: msg.senderUsername,
           accountName: memberInfo.accountName,
-          groupNickname: memberInfo.groupNickname,
+          groupNickname: groupNickname || undefined,
           timestamp: msg.createTime,
           type: this.convertMessageType(msg.localType, msg.content),
           content: content
@@ -2037,8 +2189,8 @@ class ExportService {
           message.chatRecords = chatRecords
         }
 
-        return message
-      })
+        chatLabMessages.push(message)
+      }
 
       const avatarMap = options.exportAvatars
         ? await this.exportAvatars(
@@ -2251,6 +2403,25 @@ class ExportService {
           content = this.parseMessageContent(msg.content, msg.localType)
         }
 
+        // 转账消息：追加 "谁转账给谁" 信息
+        if (content && content.startsWith('[转账]') && msg.content) {
+          const transferDesc = await this.resolveTransferDesc(
+            msg.content,
+            cleanedMyWxid,
+            groupNicknamesMap,
+            async (username) => {
+              const c = await getContactCached(username)
+              if (c.success && c.contact) {
+                return c.contact.remark || c.contact.nickName || c.contact.alias || username
+              }
+              return username
+            }
+          )
+          if (transferDesc) {
+            content = content.replace('[转账]', `[转账] (${transferDesc})`)
+          }
+        }
+
         // 获取发送者信息用于名称显示
         const senderWxid = msg.senderUsername
         const contact = await getContactCached(senderWxid)
@@ -2694,6 +2865,26 @@ class ExportService {
               voiceTranscriptMap.get(msg.localId)
             ))
 
+        // 转账消息：追加 "谁转账给谁" 信息
+        let enrichedContentValue = contentValue
+        if (contentValue.startsWith('[转账]') && msg.content) {
+          const transferDesc = await this.resolveTransferDesc(
+            msg.content,
+            cleanedMyWxid,
+            groupNicknamesMap,
+            async (username) => {
+              const c = await getContactCached(username)
+              if (c.success && c.contact) {
+                return c.contact.remark || c.contact.nickName || c.contact.alias || username
+              }
+              return username
+            }
+          )
+          if (transferDesc) {
+            enrichedContentValue = contentValue.replace('[转账]', `[转账] (${transferDesc})`)
+          }
+        }
+
         // 调试日志
         if (msg.localType === 3 || msg.localType === 47) {
         }
@@ -2703,7 +2894,7 @@ class ExportService {
         if (useCompactColumns) {
           worksheet.getCell(currentRow, 3).value = senderRole
           worksheet.getCell(currentRow, 4).value = this.getMessageTypeName(msg.localType)
-          worksheet.getCell(currentRow, 5).value = contentValue
+          worksheet.getCell(currentRow, 5).value = enrichedContentValue
         } else {
           worksheet.getCell(currentRow, 3).value = senderNickname
           worksheet.getCell(currentRow, 4).value = senderWxid
@@ -2711,7 +2902,7 @@ class ExportService {
           worksheet.getCell(currentRow, 6).value = senderGroupNickname
           worksheet.getCell(currentRow, 7).value = senderRole
           worksheet.getCell(currentRow, 8).value = this.getMessageTypeName(msg.localType)
-          worksheet.getCell(currentRow, 9).value = contentValue
+          worksheet.getCell(currentRow, 9).value = enrichedContentValue
         }
 
         // 设置每个单元格的样式
@@ -2858,6 +3049,11 @@ class ExportService {
       senderUsernames.add(sessionId)
       await this.preloadContacts(senderUsernames, contactCache)
 
+      // 获取群昵称（用于转账描述等）
+      const groupNicknamesMap = isGroup
+        ? await this.getGroupNicknamesForRoom(sessionId)
+        : new Map<string, string>()
+
       const sortedMessages = collected.rows.sort((a, b) => a.createTime - b.createTime)
 
       const { exportMediaEnabled, mediaRootDir, mediaRelativePrefix } = this.getMediaLayout(outputPath, options)
@@ -2943,6 +3139,26 @@ class ExportService {
               voiceTranscriptMap.get(msg.localId)
             ))
 
+        // 转账消息：追加 "谁转账给谁" 信息
+        let enrichedContentValue = contentValue
+        if (contentValue.startsWith('[转账]') && msg.content) {
+          const transferDesc = await this.resolveTransferDesc(
+            msg.content,
+            cleanedMyWxid,
+            groupNicknamesMap,
+            async (username) => {
+              const c = await getContactCached(username)
+              if (c.success && c.contact) {
+                return c.contact.remark || c.contact.nickName || c.contact.alias || username
+              }
+              return username
+            }
+          )
+          if (transferDesc) {
+            enrichedContentValue = contentValue.replace('[转账]', `[转账] (${transferDesc})`)
+          }
+        }
+
         let senderRole: string
         let senderWxid: string
         let senderNickname: string
@@ -2977,7 +3193,7 @@ class ExportService {
         }
 
         lines.push(`${this.formatTimestamp(msg.createTime)} '${senderRole}'`)
-        lines.push(contentValue)
+        lines.push(enrichedContentValue)
         lines.push('')
 
         if ((i + 1) % 200 === 0) {

electron/services/httpService.ts

@@ -0,0 +1,745 @@
+/**
+ * HTTP API 服务
+ * 提供 ChatLab 标准化格式的消息查询 API
+ */
+import * as http from 'http'
+import { URL } from 'url'
+import { chatService, Message } from './chatService'
+import { wcdbService } from './wcdbService'
+import { ConfigService } from './config'
+
+// ChatLab 格式定义
+interface ChatLabHeader {
+  version: string
+  exportedAt: number
+  generator: string
+  description?: string
+}
+
+interface ChatLabMeta {
+  name: string
+  platform: string
+  type: 'group' | 'private'
+  groupId?: string
+  groupAvatar?: string
+  ownerId?: string
+}
+
+interface ChatLabMember {
+  platformId: string
+  accountName: string
+  groupNickname?: string
+  aliases?: string[]
+  avatar?: string
+}
+
+interface ChatLabMessage {
+  sender: string
+  accountName: string
+  groupNickname?: string
+  timestamp: number
+  type: number
+  content: string | null
+  platformMessageId?: string
+  replyToMessageId?: string
+}
+
+interface ChatLabData {
+  chatlab: ChatLabHeader
+  meta: ChatLabMeta
+  members: ChatLabMember[]
+  messages: ChatLabMessage[]
+}
+
+// ChatLab 消息类型映射
+const ChatLabType = {
+  TEXT: 0,
+  IMAGE: 1,
+  VOICE: 2,
+  VIDEO: 3,
+  FILE: 4,
+  EMOJI: 5,
+  LINK: 7,
+  LOCATION: 8,
+  RED_PACKET: 20,
+  TRANSFER: 21,
+  POKE: 22,
+  CALL: 23,
+  SHARE: 24,
+  REPLY: 25,
+  FORWARD: 26,
+  CONTACT: 27,
+  SYSTEM: 80,
+  RECALL: 81,
+  OTHER: 99
+} as const
+
+class HttpService {
+  private server: http.Server | null = null
+  private configService: ConfigService
+  private port: number = 5031
+  private running: boolean = false
+  private connections: Set<import('net').Socket> = new Set()
+
+  constructor() {
+    this.configService = ConfigService.getInstance()
+  }
+
+  /**
+   * 启动 HTTP 服务
+   */
+  async start(port: number = 5031): Promise<{ success: boolean; port?: number; error?: string }> {
+    if (this.running && this.server) {
+      return { success: true, port: this.port }
+    }
+
+    this.port = port
+
+    return new Promise((resolve) => {
+      this.server = http.createServer((req, res) => this.handleRequest(req, res))
+
+      // 跟踪所有连接，以便关闭时能强制断开
+      this.server.on('connection', (socket) => {
+        this.connections.add(socket)
+        socket.on('close', () => {
+          this.connections.delete(socket)
+        })
+      })
+
+      this.server.on('error', (err: NodeJS.ErrnoException) => {
+        if (err.code === 'EADDRINUSE') {
+          console.error(`[HttpService] Port ${this.port} is already in use`)
+          resolve({ success: false, error: `Port ${this.port} is already in use` })
+        } else {
+          console.error('[HttpService] Server error:', err)
+          resolve({ success: false, error: err.message })
+        }
+      })
+
+      this.server.listen(this.port, '127.0.0.1', () => {
+        this.running = true
+        console.log(`[HttpService] HTTP API server started on http://127.0.0.1:${this.port}`)
+        resolve({ success: true, port: this.port })
+      })
+    })
+  }
+
+  /**
+   * 停止 HTTP 服务
+   */
+  async stop(): Promise<void> {
+    return new Promise((resolve) => {
+      if (this.server) {
+        // 强制关闭所有活动连接
+        for (const socket of this.connections) {
+          socket.destroy()
+        }
+        this.connections.clear()
+
+        this.server.close(() => {
+          this.running = false
+          this.server = null
+          console.log('[HttpService] HTTP API server stopped')
+          resolve()
+        })
+      } else {
+        this.running = false
+        resolve()
+      }
+    })
+  }
+
+  /**
+   * 检查服务是否运行
+   */
+  isRunning(): boolean {
+    return this.running
+  }
+
+  /**
+   * 获取当前端口
+   */
+  getPort(): number {
+    return this.port
+  }
+
+  /**
+   * 处理 HTTP 请求
+   */
+  private async handleRequest(req: http.IncomingMessage, res: http.ServerResponse): Promise<void> {
+    // 设置 CORS 头
+    res.setHeader('Access-Control-Allow-Origin', '*')
+    res.setHeader('Access-Control-Allow-Methods', 'GET, OPTIONS')
+    res.setHeader('Access-Control-Allow-Headers', 'Content-Type')
+
+    if (req.method === 'OPTIONS') {
+      res.writeHead(204)
+      res.end()
+      return
+    }
+
+    const url = new URL(req.url || '/', `http://127.0.0.1:${this.port}`)
+    const pathname = url.pathname
+
+    try {
+      // 路由处理
+      if (pathname === '/health' || pathname === '/api/v1/health') {
+        this.sendJson(res, { status: 'ok' })
+      } else if (pathname === '/api/v1/messages') {
+        await this.handleMessages(url, res)
+      } else if (pathname === '/api/v1/sessions') {
+        await this.handleSessions(url, res)
+      } else if (pathname === '/api/v1/contacts') {
+        await this.handleContacts(url, res)
+      } else {
+        this.sendError(res, 404, 'Not Found')
+      }
+    } catch (error) {
+      console.error('[HttpService] Request error:', error)
+      this.sendError(res, 500, String(error))
+    }
+  }
+
+  /**
+   * 批量获取消息（循环游标直到满足 limit）
+   * 绕过 chatService 的单 batch 限制，直接操作 wcdbService 游标
+   */
+  private async fetchMessagesBatch(
+    talker: string,
+    offset: number,
+    limit: number,
+    startTime: number,
+    endTime: number,
+    ascending: boolean
+  ): Promise<{ success: boolean; messages?: Message[]; hasMore?: boolean; error?: string }> {
+    try {
+      // 使用固定 batch 大小（与 limit 相同或最大 500）来减少循环次数
+      const batchSize = Math.min(limit, 500)
+      const beginTimestamp = startTime > 10000000000 ? Math.floor(startTime / 1000) : startTime
+      const endTimestamp = endTime > 10000000000 ? Math.floor(endTime / 1000) : endTime
+
+      const cursorResult = await wcdbService.openMessageCursor(talker, batchSize, ascending, beginTimestamp, endTimestamp)
+      if (!cursorResult.success || !cursorResult.cursor) {
+        return { success: false, error: cursorResult.error || '打开消息游标失败' }
+      }
+
+      const cursor = cursorResult.cursor
+      try {
+        const allRows: Record<string, any>[] = []
+        let hasMore = true
+        let skipped = 0
+
+        // 循环获取消息，处理 offset 跳过 + limit 累积
+        while (allRows.length < limit && hasMore) {
+          const batch = await wcdbService.fetchMessageBatch(cursor)
+          if (!batch.success || !batch.rows || batch.rows.length === 0) {
+            hasMore = false
+            break
+          }
+
+          let rows = batch.rows
+          hasMore = batch.hasMore === true
+
+          // 处理 offset: 跳过前 N 条
+          if (skipped < offset) {
+            const remaining = offset - skipped
+            if (remaining >= rows.length) {
+              skipped += rows.length
+              continue
+            }
+            rows = rows.slice(remaining)
+            skipped = offset
+          }
+
+          allRows.push(...rows)
+        }
+
+        const trimmedRows = allRows.slice(0, limit)
+        const finalHasMore = hasMore || allRows.length > limit
+        const messages = this.mapRowsToMessagesSimple(trimmedRows)
+        return { success: true, messages, hasMore: finalHasMore }
+      } finally {
+        await wcdbService.closeMessageCursor(cursor)
+      }
+    } catch (e) {
+      console.error('[HttpService] fetchMessagesBatch error:', e)
+      return { success: false, error: String(e) }
+    }
+  }
+
+  /**
+   * 简单的行数据到 Message 映射（用于 API 输出）
+   */
+  private mapRowsToMessagesSimple(rows: Record<string, any>[]): Message[] {
+    const myWxid = this.configService.get('myWxid') || ''
+    const messages: Message[] = []
+
+    for (const row of rows) {
+      const content = this.getField(row, ['message_content', 'messageContent', 'content', 'msg_content', 'WCDB_CT_message_content']) || ''
+      const localType = parseInt(this.getField(row, ['local_type', 'localType', 'type', 'msg_type', 'WCDB_CT_local_type']) || '1', 10)
+      const isSendRaw = this.getField(row, ['computed_is_send', 'computedIsSend', 'is_send', 'isSend', 'WCDB_CT_is_send'])
+      const senderUsername = this.getField(row, ['sender_username', 'senderUsername', 'sender', 'WCDB_CT_sender_username']) || ''
+      const createTime = parseInt(this.getField(row, ['create_time', 'createTime', 'msg_create_time', 'WCDB_CT_create_time']) || '0', 10)
+      const localId = parseInt(this.getField(row, ['local_id', 'localId', 'WCDB_CT_local_id', 'rowid']) || '0', 10)
+      const serverId = this.getField(row, ['server_id', 'serverId', 'WCDB_CT_server_id']) || ''
+
+      let isSend: number
+      if (isSendRaw !== null && isSendRaw !== undefined) {
+        isSend = parseInt(isSendRaw, 10)
+      } else if (senderUsername && myWxid) {
+        isSend = senderUsername.toLowerCase() === myWxid.toLowerCase() ? 1 : 0
+      } else {
+        isSend = 0
+      }
+
+      // 解析消息内容中的特殊字段
+      let parsedContent = content
+      let xmlType: string | undefined
+      let linkTitle: string | undefined
+      let fileName: string | undefined
+      let emojiCdnUrl: string | undefined
+      let emojiMd5: string | undefined
+      let imageMd5: string | undefined
+      let videoMd5: string | undefined
+      let cardNickname: string | undefined
+
+      if (localType === 49 && content) {
+        // 提取 type 子标签
+        const typeMatch = /<type>(\d+)<\/type>/i.exec(content)
+        if (typeMatch) xmlType = typeMatch[1]
+        // 提取 title
+        const titleMatch = /<title>([^<]*)<\/title>/i.exec(content)
+        if (titleMatch) linkTitle = titleMatch[1]
+        // 提取文件名
+        const fnMatch = /<title>([^<]*)<\/title>/i.exec(content)
+        if (fnMatch) fileName = fnMatch[1]
+      }
+
+      if (localType === 47 && content) {
+        const cdnMatch = /cdnurl\s*=\s*"([^"]+)"/i.exec(content)
+        if (cdnMatch) emojiCdnUrl = cdnMatch[1]
+        const md5Match = /md5\s*=\s*"([^"]+)"/i.exec(content)
+        if (md5Match) emojiMd5 = md5Match[1]
+      }
+
+      messages.push({
+        localId,
+        talker: '',
+        localType,
+        createTime,
+        sortSeq: createTime,
+        content: parsedContent,
+        isSend,
+        senderUsername,
+        serverId: serverId ? parseInt(serverId, 10) || 0 : 0,
+        rawContent: content,
+        parsedContent: content,
+        emojiCdnUrl,
+        emojiMd5,
+        imageMd5,
+        videoMd5,
+        xmlType,
+        linkTitle,
+        fileName,
+        cardNickname
+      } as Message)
+    }
+
+    return messages
+  }
+
+  /**
+   * 从行数据中获取字段值（兼容多种字段名）
+   */
+  private getField(row: Record<string, any>, keys: string[]): string | null {
+    for (const key of keys) {
+      if (row[key] !== undefined && row[key] !== null) {
+        return String(row[key])
+      }
+    }
+    return null
+  }
+
+  /**
+   * 处理消息查询
+   * GET /api/v1/messages?talker=xxx&limit=100&start=20260101&chatlab=1
+   */
+  private async handleMessages(url: URL, res: http.ServerResponse): Promise<void> {
+    const talker = url.searchParams.get('talker')
+    const limit = Math.min(parseInt(url.searchParams.get('limit') || '100', 10), 10000)
+    const offset = parseInt(url.searchParams.get('offset') || '0', 10)
+    const startParam = url.searchParams.get('start')
+    const endParam = url.searchParams.get('end')
+    const chatlab = url.searchParams.get('chatlab') === '1'
+    const formatParam = url.searchParams.get('format')
+    const format = formatParam || (chatlab ? 'chatlab' : 'json')
+
+    if (!talker) {
+      this.sendError(res, 400, 'Missing required parameter: talker')
+      return
+    }
+
+    // 解析时间参数 (支持 YYYYMMDD 格式)
+    const startTime = this.parseTimeParam(startParam)
+    const endTime = this.parseTimeParam(endParam, true)
+
+    // 使用批量获取方法，绕过 chatService 的单 batch 限制
+    const result = await this.fetchMessagesBatch(talker, offset, limit, startTime, endTime, true)
+    if (!result.success || !result.messages) {
+      this.sendError(res, 500, result.error || 'Failed to get messages')
+      return
+    }
+
+    if (format === 'chatlab') {
+      // 获取会话显示名
+      const displayNames = await this.getDisplayNames([talker])
+      const talkerName = displayNames[talker] || talker
+
+      const chatLabData = await this.convertToChatLab(result.messages, talker, talkerName)
+      this.sendJson(res, chatLabData)
+    } else {
+      // 返回原始消息格式
+      this.sendJson(res, {
+        success: true,
+        talker,
+        count: result.messages.length,
+        hasMore: result.hasMore,
+        messages: result.messages
+      })
+    }
+  }
+
+  /**
+   * 处理会话列表查询
+   * GET /api/v1/sessions?keyword=xxx&limit=100
+   */
+  private async handleSessions(url: URL, res: http.ServerResponse): Promise<void> {
+    const keyword = url.searchParams.get('keyword') || ''
+    const limit = parseInt(url.searchParams.get('limit') || '100', 10)
+
+    try {
+      const sessions = await chatService.getSessions()
+      if (!sessions.success || !sessions.sessions) {
+        this.sendError(res, 500, sessions.error || 'Failed to get sessions')
+        return
+      }
+
+      let filteredSessions = sessions.sessions
+      if (keyword) {
+        const lowerKeyword = keyword.toLowerCase()
+        filteredSessions = sessions.sessions.filter(s => 
+          s.username.toLowerCase().includes(lowerKeyword) ||
+          (s.displayName && s.displayName.toLowerCase().includes(lowerKeyword))
+        )
+      }
+
+      // 应用 limit
+      const limitedSessions = filteredSessions.slice(0, limit)
+
+      this.sendJson(res, {
+        success: true,
+        count: limitedSessions.length,
+        sessions: limitedSessions.map(s => ({
+          username: s.username,
+          displayName: s.displayName,
+          type: s.type,
+          lastTimestamp: s.lastTimestamp,
+          unreadCount: s.unreadCount
+        }))
+      })
+    } catch (error) {
+      this.sendError(res, 500, String(error))
+    }
+  }
+
+  /**
+   * 处理联系人查询
+   * GET /api/v1/contacts?keyword=xxx&limit=100
+   */
+  private async handleContacts(url: URL, res: http.ServerResponse): Promise<void> {
+    const keyword = url.searchParams.get('keyword') || ''
+    const limit = parseInt(url.searchParams.get('limit') || '100', 10)
+
+    try {
+      const contacts = await chatService.getContacts()
+      if (!contacts.success || !contacts.contacts) {
+        this.sendError(res, 500, contacts.error || 'Failed to get contacts')
+        return
+      }
+
+      let filteredContacts = contacts.contacts
+      if (keyword) {
+        const lowerKeyword = keyword.toLowerCase()
+        filteredContacts = contacts.contacts.filter(c =>
+          c.username.toLowerCase().includes(lowerKeyword) ||
+          (c.nickname && c.nickname.toLowerCase().includes(lowerKeyword)) ||
+          (c.remark && c.remark.toLowerCase().includes(lowerKeyword)) ||
+          (c.displayName && c.displayName.toLowerCase().includes(lowerKeyword))
+        )
+      }
+
+      const limited = filteredContacts.slice(0, limit)
+
+      this.sendJson(res, {
+        success: true,
+        count: limited.length,
+        contacts: limited
+      })
+    } catch (error) {
+      this.sendError(res, 500, String(error))
+    }
+  }
+
+  /**
+   * 解析时间参数
+   * 支持 YYYYMMDD 格式，返回秒级时间戳
+   */
+  private parseTimeParam(param: string | null, isEnd: boolean = false): number {
+    if (!param) return 0
+
+    // 纯数字且长度为8，视为 YYYYMMDD
+    if (/^\d{8}$/.test(param)) {
+      const year = parseInt(param.slice(0, 4), 10)
+      const month = parseInt(param.slice(4, 6), 10) - 1
+      const day = parseInt(param.slice(6, 8), 10)
+      const date = new Date(year, month, day)
+      if (isEnd) {
+        // 结束时间设为当天 23:59:59
+        date.setHours(23, 59, 59, 999)
+      }
+      return Math.floor(date.getTime() / 1000)
+    }
+
+    // 纯数字，视为时间戳
+    if (/^\d+$/.test(param)) {
+      const ts = parseInt(param, 10)
+      // 如果是毫秒级时间戳，转为秒级
+      return ts > 10000000000 ? Math.floor(ts / 1000) : ts
+    }
+
+    return 0
+  }
+
+  /**
+   * 获取显示名称
+   */
+  private async getDisplayNames(usernames: string[]): Promise<Record<string, string>> {
+    try {
+      const result = await wcdbService.getDisplayNames(usernames)
+      if (result.success && result.map) {
+        return result.map
+      }
+    } catch (e) {
+      console.error('[HttpService] Failed to get display names:', e)
+    }
+    // 返回空对象，调用方会使用 username 作为备用
+    return {}
+  }
+
+  /**
+   * 转换为 ChatLab 格式
+   */
+  private async convertToChatLab(messages: Message[], talkerId: string, talkerName: string): Promise<ChatLabData> {
+    const isGroup = talkerId.endsWith('@chatroom')
+    const myWxid = this.configService.get('myWxid') || ''
+
+    // 收集所有发送者
+    const senderSet = new Set<string>()
+    for (const msg of messages) {
+      if (msg.senderUsername) {
+        senderSet.add(msg.senderUsername)
+      }
+    }
+
+    // 获取发送者显示名
+    const senderNames = await this.getDisplayNames(Array.from(senderSet))
+
+    // 获取群昵称（如果是群聊）
+    let groupNicknamesMap = new Map<string, string>()
+    if (isGroup) {
+      try {
+        const result = await wcdbService.getGroupNicknames(talkerId)
+        if (result.success && result.nicknames) {
+          groupNicknamesMap = new Map(Object.entries(result.nicknames))
+        }
+      } catch (e) {
+        console.error('[HttpService] Failed to get group nicknames:', e)
+      }
+    }
+
+    // 构建成员列表
+    const memberMap = new Map<string, ChatLabMember>()
+    for (const msg of messages) {
+      const sender = msg.senderUsername || ''
+      if (sender && !memberMap.has(sender)) {
+        const displayName = senderNames[sender] || sender
+        const isSelf = sender === myWxid || sender.toLowerCase() === myWxid.toLowerCase()
+        // 获取群昵称（尝试多种方式）
+        const groupNickname = isGroup 
+          ? (groupNicknamesMap.get(sender) || groupNicknamesMap.get(sender.toLowerCase()) || '')
+          : ''
+        memberMap.set(sender, {
+          platformId: sender,
+          accountName: isSelf ? '我' : displayName,
+          groupNickname: groupNickname || undefined
+        })
+      }
+    }
+
+    // 转换消息
+    const chatLabMessages: ChatLabMessage[] = messages.map(msg => {
+      const sender = msg.senderUsername || ''
+      const isSelf = msg.isSend === 1 || sender === myWxid
+      const accountName = isSelf ? '我' : (senderNames[sender] || sender)
+      // 获取该发送者的群昵称
+      const groupNickname = isGroup 
+        ? (groupNicknamesMap.get(sender) || groupNicknamesMap.get(sender.toLowerCase()) || '')
+        : ''
+
+      return {
+        sender,
+        accountName,
+        groupNickname: groupNickname || undefined,
+        timestamp: msg.createTime,
+        type: this.mapMessageType(msg.localType, msg),
+        content: this.getMessageContent(msg),
+        platformMessageId: msg.serverId ? String(msg.serverId) : undefined
+      }
+    })
+
+    return {
+      chatlab: {
+        version: '0.0.2',
+        exportedAt: Math.floor(Date.now() / 1000),
+        generator: 'WeFlow'
+      },
+      meta: {
+        name: talkerName,
+        platform: 'wechat',
+        type: isGroup ? 'group' : 'private',
+        groupId: isGroup ? talkerId : undefined,
+        ownerId: myWxid || undefined
+      },
+      members: Array.from(memberMap.values()),
+      messages: chatLabMessages
+    }
+  }
+
+  /**
+   * 映射 WeChat 消息类型到 ChatLab 类型
+   */
+  private mapMessageType(localType: number, msg: Message): number {
+    switch (localType) {
+      case 1: // 文本
+        return ChatLabType.TEXT
+      case 3: // 图片
+        return ChatLabType.IMAGE
+      case 34: // 语音
+        return ChatLabType.VOICE
+      case 43: // 视频
+        return ChatLabType.VIDEO
+      case 47: // 动画表情
+        return ChatLabType.EMOJI
+      case 48: // 位置
+        return ChatLabType.LOCATION
+      case 42: // 名片
+        return ChatLabType.CONTACT
+      case 50: // 语音/视频通话
+        return ChatLabType.CALL
+      case 10000: // 系统消息
+        return ChatLabType.SYSTEM
+      case 49: // 复合消息
+        return this.mapType49(msg)
+      case 244813135921: // 引用消息
+        return ChatLabType.REPLY
+      case 266287972401: // 拍一拍
+        return ChatLabType.POKE
+      case 8594229559345: // 红包
+        return ChatLabType.RED_PACKET
+      case 8589934592049: // 转账
+        return ChatLabType.TRANSFER
+      default:
+        return ChatLabType.OTHER
+    }
+  }
+
+  /**
+   * 映射 Type 49 子类型
+   */
+  private mapType49(msg: Message): number {
+    const xmlType = msg.xmlType
+
+    switch (xmlType) {
+      case '5': // 链接
+      case '49':
+        return ChatLabType.LINK
+      case '6': // 文件
+        return ChatLabType.FILE
+      case '19': // 聊天记录
+        return ChatLabType.FORWARD
+      case '33': // 小程序
+      case '36':
+        return ChatLabType.SHARE
+      case '57': // 引用消息
+        return ChatLabType.REPLY
+      case '2000': // 转账
+        return ChatLabType.TRANSFER
+      case '2001': // 红包
+        return ChatLabType.RED_PACKET
+      default:
+        return ChatLabType.OTHER
+    }
+  }
+
+  /**
+   * 获取消息内容
+   */
+  private getMessageContent(msg: Message): string | null {
+    // 优先使用已解析的内容
+    if (msg.parsedContent) {
+      return msg.parsedContent
+    }
+
+    // 根据类型返回占位符
+    switch (msg.localType) {
+      case 1:
+        return msg.rawContent || null
+      case 3:
+        return msg.imageMd5 || '[图片]'
+      case 34:
+        return '[语音]'
+      case 43:
+        return msg.videoMd5 || '[视频]'
+      case 47:
+        return msg.emojiCdnUrl || msg.emojiMd5 || '[表情]'
+      case 42:
+        return msg.cardNickname || '[名片]'
+      case 48:
+        return '[位置]'
+      case 49:
+        return msg.linkTitle || msg.fileName || '[消息]'
+      default:
+        return msg.rawContent || null
+    }
+  }
+
+  /**
+   * 发送 JSON 响应
+   */
+  private sendJson(res: http.ServerResponse, data: any): void {
+    res.setHeader('Content-Type', 'application/json; charset=utf-8')
+    res.writeHead(200)
+    res.end(JSON.stringify(data, null, 2))
+  }
+
+  /**
+   * 发送错误响应
+   */
+  private sendError(res: http.ServerResponse, code: number, message: string): void {
+    res.setHeader('Content-Type', 'application/json; charset=utf-8')
+    res.writeHead(code)
+    res.end(JSON.stringify({ error: message }))
+  }
+}
+
+export const httpService = new HttpService()

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "weflow",
-  "version": "1.5.2",
+  "version": "1.5.4",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "weflow",
-      "version": "1.5.2",
+      "version": "1.5.4",
       "hasInstallScript": true,
       "dependencies": {
         "better-sqlite3": "^12.5.0",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "weflow",
-  "version": "1.5.2",
+  "version": "1.5.4",
   "description": "WeFlow",
   "main": "dist-electron/main.js",
   "author": "cc",

src/components/GlobalSessionMonitor.tsx

@@ -81,6 +81,11 @@ export function GlobalSessionMonitor() {
     }
 
     const checkForNewMessages = async (oldSessions: ChatSession[], newSessions: ChatSession[]) => {
+        if (!oldSessions || oldSessions.length === 0) {
+            console.log('[NotificationFilter] Skipping check on initial load (empty baseline)')
+            return
+        }
+
         const oldMap = new Map(oldSessions.map(s => [s.username, s]))
 
         for (const newSession of newSessions) {
@@ -140,6 +145,14 @@ export function GlobalSessionMonitor() {
                     }
                 }
 
+                // 新增：如果未读数量没有增加，说明可能是自己在其他设备回复（或者已读），不弹通知
+                const oldUnread = oldSession ? oldSession.unreadCount : 0
+                const newUnread = newSession.unreadCount
+                if (newUnread <= oldUnread) {
+                    // 仅仅是状态同步（如自己在手机上发消息 or 已读），跳过通知
+                    continue
+                }
+
                 let title = newSession.displayName || newSession.username
                 let avatarUrl = newSession.avatarUrl
                 let content = newSession.summary || '[新消息]'

src/pages/ChatPage.scss

@@ -2016,12 +2016,43 @@
       text-align: right;
       color: var(--text-primary);
       word-break: break-all;
+      user-select: text;
 
       &.highlight {
         color: var(--primary);
         font-weight: 600;
       }
     }
+
+    .copy-btn {
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      width: 22px;
+      height: 22px;
+      padding: 0;
+      border: none;
+      border-radius: 4px;
+      background: transparent;
+      color: var(--text-tertiary);
+      cursor: pointer;
+      flex-shrink: 0;
+      opacity: 0;
+      transition: opacity 0.15s, color 0.15s, background 0.15s;
+
+      &:hover {
+        background: var(--bg-secondary);
+        color: var(--text-primary);
+      }
+
+      svg {
+        color: inherit;
+      }
+    }
+
+    &:hover .copy-btn {
+      opacity: 1;
+    }
   }
 
   .table-list {
@@ -2458,6 +2489,13 @@
       text-shadow: 0 1px 2px rgba(0, 0, 0, 0.1);
     }
 
+    .transfer-desc {
+      font-size: 12px;
+      margin-bottom: 4px;
+      opacity: 0.9;
+      line-height: 1.4;
+    }
+
     .transfer-memo {
       font-size: 13px;
       margin-bottom: 8px;
@@ -2572,3 +2610,422 @@
     }
   }
 }
+
+// 批量转写按钮
+.batch-transcribe-btn {
+  &:hover:not(:disabled) {
+    color: var(--primary-color);
+  }
+}
+
+// 批量转写模态框基础样式
+.batch-modal-overlay {
+  position: fixed;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: rgba(0, 0, 0, 0.5);
+  backdrop-filter: blur(4px);
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  z-index: 10000;
+  animation: batchFadeIn 0.2s ease-out;
+}
+
+.batch-modal-content {
+  background: var(--bg-primary);
+  border-radius: 12px;
+  box-shadow: 0 20px 60px rgba(0, 0, 0, 0.3);
+  max-height: 90vh;
+  overflow-y: auto;
+  animation: batchSlideUp 0.3s cubic-bezier(0.16, 1, 0.3, 1);
+}
+
+@keyframes batchFadeIn {
+  from { opacity: 0; }
+  to { opacity: 1; }
+}
+
+@keyframes batchSlideUp {
+  from { opacity: 0; transform: translateY(20px); }
+  to { opacity: 1; transform: translateY(0); }
+}
+
+// 批量转写确认对话框
+.batch-confirm-modal {
+  width: 480px;
+  max-width: 90vw;
+
+  .batch-modal-header {
+    display: flex;
+    align-items: center;
+    gap: 0.75rem;
+    padding: 1.5rem;
+    border-bottom: 1px solid var(--border-color);
+
+    svg { color: var(--primary-color); }
+
+    h3 {
+      margin: 0;
+      font-size: 18px;
+      font-weight: 600;
+      color: var(--text-primary);
+    }
+  }
+
+  .batch-modal-body {
+    padding: 1.5rem;
+
+    p {
+      margin: 0 0 1rem 0;
+      font-size: 14px;
+      color: var(--text-secondary);
+      line-height: 1.6;
+    }
+
+    .batch-dates-list-wrap {
+      margin-bottom: 1rem;
+      background: var(--bg-tertiary);
+      border: 1px solid var(--border-color);
+      border-radius: 8px;
+      overflow: hidden;
+
+      .batch-dates-actions {
+        display: flex;
+        gap: 0.5rem;
+        padding: 0.5rem 0.75rem;
+        border-bottom: 1px solid var(--border-color);
+        background: var(--bg-secondary);
+
+        .batch-dates-btn {
+          padding: 0.35rem 0.75rem;
+          font-size: 12px;
+          color: var(--primary-color);
+          background: transparent;
+          border: 1px solid var(--border-color);
+          border-radius: 6px;
+          cursor: pointer;
+          transition: all 0.2s;
+
+          &:hover {
+            background: var(--bg-hover);
+            border-color: var(--primary-color);
+          }
+        }
+      }
+
+      .batch-dates-list {
+        list-style: none;
+        margin: 0;
+        padding: 0;
+        max-height: 160px;
+        overflow-y: auto;
+
+        li {
+          border-bottom: 1px solid var(--border-color);
+          &:last-child { border-bottom: none; }
+        }
+
+        .batch-date-row {
+          display: flex;
+          align-items: center;
+          gap: 0.75rem;
+          padding: 0.6rem 0.75rem;
+          cursor: pointer;
+          transition: background 0.15s;
+
+          &:hover { background: var(--bg-hover); }
+
+          input[type="checkbox"] {
+            accent-color: var(--primary-color);
+            cursor: pointer;
+            flex-shrink: 0;
+          }
+
+          .batch-date-label {
+            flex: 1;
+            font-size: 14px;
+            color: var(--text-primary);
+            font-weight: 500;
+          }
+
+          .batch-date-count {
+            font-size: 12px;
+            color: var(--text-tertiary);
+            flex-shrink: 0;
+          }
+        }
+      }
+    }
+
+    .batch-info {
+      background: var(--bg-tertiary);
+      border-radius: 8px;
+      padding: 1rem;
+      margin-bottom: 1rem;
+
+      .info-item {
+        display: flex;
+        justify-content: space-between;
+        align-items: center;
+        padding: 0.5rem 0;
+
+        &:not(:last-child) {
+          border-bottom: 1px solid var(--border-color);
+        }
+
+        .label {
+          font-size: 13px;
+          color: var(--text-secondary);
+        }
+
+        .value {
+          font-size: 14px;
+          font-weight: 600;
+          color: var(--primary-color);
+        }
+      }
+    }
+
+    .batch-warning {
+      display: flex;
+      align-items: flex-start;
+      gap: 0.5rem;
+      padding: 0.75rem;
+      background: rgba(255, 152, 0, 0.1);
+      border-radius: 8px;
+      border: 1px solid rgba(255, 152, 0, 0.3);
+
+      svg {
+        flex-shrink: 0;
+        margin-top: 2px;
+        color: #ff9800;
+      }
+
+      span {
+        font-size: 13px;
+        color: var(--text-secondary);
+        line-height: 1.5;
+      }
+    }
+  }
+
+  .batch-modal-footer {
+    display: flex;
+    justify-content: flex-end;
+    gap: 0.75rem;
+    padding: 1rem 1.5rem;
+    border-top: 1px solid var(--border-color);
+
+    button {
+      padding: 0.5rem 1.25rem;
+      border-radius: 8px;
+      font-size: 14px;
+      font-weight: 500;
+      cursor: pointer;
+      transition: all 0.2s;
+      display: flex;
+      align-items: center;
+      gap: 0.5rem;
+      border: none;
+
+      &.btn-secondary {
+        background: var(--bg-tertiary);
+        color: var(--text-primary);
+        &:hover { background: var(--border-color); }
+      }
+
+      &.btn-primary, &.batch-transcribe-start-btn {
+        background: var(--primary-color);
+        color: white;
+        &:hover { opacity: 0.9; }
+      }
+    }
+  }
+}
+
+// 批量转写进度对话框
+.batch-progress-modal {
+  width: 420px;
+  max-width: 90vw;
+
+  .batch-modal-header {
+    display: flex;
+    align-items: center;
+    gap: 0.75rem;
+    padding: 1.5rem;
+    border-bottom: 1px solid var(--border-color);
+
+    svg { color: var(--primary-color); }
+
+    h3 {
+      margin: 0;
+      font-size: 18px;
+      font-weight: 600;
+      color: var(--text-primary);
+    }
+  }
+
+  .batch-modal-body {
+    padding: 1.5rem;
+
+    .progress-info {
+      .progress-text {
+        display: flex;
+        justify-content: space-between;
+        align-items: center;
+        margin-bottom: 0.75rem;
+        font-size: 14px;
+        color: var(--text-secondary);
+
+        .progress-percent {
+          font-weight: 600;
+          color: var(--primary-color);
+          font-size: 16px;
+        }
+      }
+
+      .progress-bar {
+        height: 8px;
+        background: var(--bg-tertiary);
+        border-radius: 4px;
+        overflow: hidden;
+        margin-bottom: 1rem;
+
+        .progress-fill {
+          height: 100%;
+          background: linear-gradient(90deg, var(--primary-color), var(--primary-color));
+          border-radius: 4px;
+          transition: width 0.3s ease;
+        }
+      }
+    }
+
+    .batch-tip {
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      padding: 0.75rem;
+      background: var(--bg-tertiary);
+      border-radius: 8px;
+
+      span {
+        font-size: 13px;
+        color: var(--text-secondary);
+      }
+    }
+  }
+}
+
+// 批量转写结果对话框
+.batch-result-modal {
+  width: 420px;
+  max-width: 90vw;
+
+  .batch-modal-header {
+    display: flex;
+    align-items: center;
+    gap: 0.75rem;
+    padding: 1.5rem;
+    border-bottom: 1px solid var(--border-color);
+
+    svg { color: #4caf50; }
+
+    h3 {
+      margin: 0;
+      font-size: 18px;
+      font-weight: 600;
+      color: var(--text-primary);
+    }
+  }
+
+  .batch-modal-body {
+    padding: 1.5rem;
+
+    .result-summary {
+      display: flex;
+      flex-direction: column;
+      gap: 0.75rem;
+      margin-bottom: 1rem;
+
+      .result-item {
+        display: flex;
+        align-items: center;
+        gap: 0.75rem;
+        padding: 1rem;
+        border-radius: 8px;
+        background: var(--bg-tertiary);
+
+        svg { flex-shrink: 0; }
+
+        .label {
+          font-size: 14px;
+          color: var(--text-secondary);
+        }
+
+        .value {
+          margin-left: auto;
+          font-size: 18px;
+          font-weight: 600;
+        }
+
+        &.success {
+          svg { color: #4caf50; }
+          .value { color: #4caf50; }
+        }
+
+        &.fail {
+          svg { color: #f44336; }
+          .value { color: #f44336; }
+        }
+      }
+    }
+
+    .result-tip {
+      display: flex;
+      align-items: flex-start;
+      gap: 0.5rem;
+      padding: 0.75rem;
+      background: rgba(255, 152, 0, 0.1);
+      border-radius: 8px;
+      border: 1px solid rgba(255, 152, 0, 0.3);
+
+      svg {
+        flex-shrink: 0;
+        margin-top: 2px;
+        color: #ff9800;
+      }
+
+      span {
+        font-size: 13px;
+        color: var(--text-secondary);
+        line-height: 1.5;
+      }
+    }
+  }
+
+  .batch-modal-footer {
+    display: flex;
+    justify-content: flex-end;
+    padding: 1rem 1.5rem;
+    border-top: 1px solid var(--border-color);
+
+    button {
+      padding: 0.5rem 1.5rem;
+      border-radius: 8px;
+      font-size: 14px;
+      font-weight: 500;
+      cursor: pointer;
+      transition: all 0.2s;
+      border: none;
+
+      &.btn-primary {
+        background: var(--primary-color);
+        color: white;
+        &:hover { opacity: 0.9; }
+      }
+    }
+  }
+}

src/pages/ChatPage.tsx

@@ -1,5 +1,5 @@
 import React, { useState, useEffect, useRef, useCallback, useMemo } from 'react'
-import { Search, MessageSquare, AlertCircle, Loader2, RefreshCw, X, ChevronDown, Info, Calendar, Database, Hash, Play, Pause, Image as ImageIcon, Link } from 'lucide-react'
+import { Search, MessageSquare, AlertCircle, Loader2, RefreshCw, X, ChevronDown, Info, Calendar, Database, Hash, Play, Pause, Image as ImageIcon, Link, Mic, CheckCircle, XCircle, Copy, Check } from 'lucide-react'
 import { createPortal } from 'react-dom'
 import { useChatStore } from '../stores/chatStore'
 import type { ChatSession, Message } from '../types/models'
@@ -168,12 +168,25 @@ function ChatPage(_props: ChatPageProps) {
   const [showDetailPanel, setShowDetailPanel] = useState(false)
   const [sessionDetail, setSessionDetail] = useState<SessionDetail | null>(null)
   const [isLoadingDetail, setIsLoadingDetail] = useState(false)
+  const [copiedField, setCopiedField] = useState<string | null>(null)
   const [highlightedMessageKeys, setHighlightedMessageKeys] = useState<string[]>([])
   const [isRefreshingSessions, setIsRefreshingSessions] = useState(false)
   const [hasInitialMessages, setHasInitialMessages] = useState(false)
   const [showVoiceTranscribeDialog, setShowVoiceTranscribeDialog] = useState(false)
   const [pendingVoiceTranscriptRequest, setPendingVoiceTranscriptRequest] = useState<{ sessionId: string; messageId: string } | null>(null)
 
+  // 批量语音转文字相关状态
+  const [isBatchTranscribing, setIsBatchTranscribing] = useState(false)
+  const [batchTranscribeProgress, setBatchTranscribeProgress] = useState({ current: 0, total: 0 })
+  const [showBatchConfirm, setShowBatchConfirm] = useState(false)
+  const [batchVoiceCount, setBatchVoiceCount] = useState(0)
+  const [batchVoiceMessages, setBatchVoiceMessages] = useState<Message[] | null>(null)
+  const [batchVoiceDates, setBatchVoiceDates] = useState<string[]>([])
+  const [batchSelectedDates, setBatchSelectedDates] = useState<Set<string>>(new Set())
+  const [showBatchProgress, setShowBatchProgress] = useState(false)
+  const [showBatchResult, setShowBatchResult] = useState(false)
+  const [batchResult, setBatchResult] = useState({ success: 0, fail: 0 })
+
   // 联系人信息加载控制
   const isEnrichingRef = useRef(false)
   const enrichCancelledRef = useRef(false)
@@ -231,6 +244,25 @@ function ChatPage(_props: ChatPageProps) {
     setShowDetailPanel(!showDetailPanel)
   }, [showDetailPanel, currentSessionId, loadSessionDetail])
 
+  // 复制字段值到剪贴板
+  const handleCopyField = useCallback(async (text: string, field: string) => {
+    try {
+      await navigator.clipboard.writeText(text)
+      setCopiedField(field)
+      setTimeout(() => setCopiedField(null), 1500)
+    } catch {
+      // fallback
+      const textarea = document.createElement('textarea')
+      textarea.value = text
+      document.body.appendChild(textarea)
+      textarea.select()
+      document.execCommand('copy')
+      document.body.removeChild(textarea)
+      setCopiedField(field)
+      setTimeout(() => setCopiedField(null), 1500)
+    }
+  }, [])
+
   // 连接数据库
   const connect = useCallback(async () => {
     setConnecting(true)
@@ -1183,6 +1215,155 @@ function ChatPage(_props: ChatPageProps) {
     setShowVoiceTranscribeDialog(true)
   }, [])
 
+  // 批量语音转文字
+  const handleBatchTranscribe = useCallback(async () => {
+    if (!currentSessionId) return
+    const session = sessions.find(s => s.username === currentSessionId)
+    if (!session) {
+      alert('未找到当前会话')
+      return
+    }
+    if (isBatchTranscribing) return
+
+    const result = await window.electronAPI.chat.getAllVoiceMessages(currentSessionId)
+    if (!result.success || !result.messages) {
+      alert(`获取语音消息失败: ${result.error || '未知错误'}`)
+      return
+    }
+
+    const voiceMessages = result.messages
+    if (voiceMessages.length === 0) {
+      alert('当前会话没有语音消息')
+      return
+    }
+
+    const dateSet = new Set<string>()
+    voiceMessages.forEach(m => dateSet.add(new Date(m.createTime * 1000).toISOString().slice(0, 10)))
+    const sortedDates = Array.from(dateSet).sort((a, b) => b.localeCompare(a))
+
+    setBatchVoiceMessages(voiceMessages)
+    setBatchVoiceCount(voiceMessages.length)
+    setBatchVoiceDates(sortedDates)
+    setBatchSelectedDates(new Set(sortedDates))
+    setShowBatchConfirm(true)
+  }, [sessions, currentSessionId, isBatchTranscribing])
+
+  // 确认批量转写
+  const confirmBatchTranscribe = useCallback(async () => {
+    if (!currentSessionId) return
+
+    const selected = batchSelectedDates
+    if (selected.size === 0) {
+      alert('请至少选择一个日期')
+      return
+    }
+
+    const messages = batchVoiceMessages
+    if (!messages || messages.length === 0) {
+      setShowBatchConfirm(false)
+      return
+    }
+
+    const voiceMessages = messages.filter(m =>
+      selected.has(new Date(m.createTime * 1000).toISOString().slice(0, 10))
+    )
+    if (voiceMessages.length === 0) {
+      alert('所选日期下没有语音消息')
+      return
+    }
+
+    setShowBatchConfirm(false)
+    setBatchVoiceMessages(null)
+    setBatchVoiceDates([])
+    setBatchSelectedDates(new Set())
+
+    const session = sessions.find(s => s.username === currentSessionId)
+    if (!session) return
+
+    setIsBatchTranscribing(true)
+    setShowBatchProgress(true)
+    setBatchTranscribeProgress({ current: 0, total: voiceMessages.length })
+
+    // 检查模型状态
+    const modelStatus = await window.electronAPI.whisper.getModelStatus()
+    if (!modelStatus?.exists) {
+      alert('SenseVoice 模型未下载，请先在设置中下载模型')
+      setIsBatchTranscribing(false)
+      setShowBatchProgress(false)
+      return
+    }
+
+    let successCount = 0
+    let failCount = 0
+    let completedCount = 0
+    const concurrency = 3
+
+    const transcribeOne = async (msg: Message) => {
+      try {
+        const result = await window.electronAPI.chat.getVoiceTranscript(
+          session.username,
+          String(msg.localId),
+          msg.createTime
+        )
+        return { success: result.success }
+      } catch {
+        return { success: false }
+      }
+    }
+
+    for (let i = 0; i < voiceMessages.length; i += concurrency) {
+      const batch = voiceMessages.slice(i, i + concurrency)
+      const results = await Promise.all(batch.map(msg => transcribeOne(msg)))
+
+      results.forEach(result => {
+        if (result.success) successCount++
+        else failCount++
+        completedCount++
+        setBatchTranscribeProgress({ current: completedCount, total: voiceMessages.length })
+      })
+    }
+
+    setIsBatchTranscribing(false)
+    setShowBatchProgress(false)
+    setBatchResult({ success: successCount, fail: failCount })
+    setShowBatchResult(true)
+  }, [sessions, currentSessionId, batchSelectedDates, batchVoiceMessages])
+
+  // 批量转写：按日期的消息数量
+  const batchCountByDate = useMemo(() => {
+    const map = new Map<string, number>()
+    if (!batchVoiceMessages) return map
+    batchVoiceMessages.forEach(m => {
+      const d = new Date(m.createTime * 1000).toISOString().slice(0, 10)
+      map.set(d, (map.get(d) || 0) + 1)
+    })
+    return map
+  }, [batchVoiceMessages])
+
+  // 批量转写：选中日期对应的语音条数
+  const batchSelectedMessageCount = useMemo(() => {
+    if (!batchVoiceMessages) return 0
+    return batchVoiceMessages.filter(m =>
+      batchSelectedDates.has(new Date(m.createTime * 1000).toISOString().slice(0, 10))
+    ).length
+  }, [batchVoiceMessages, batchSelectedDates])
+
+  const toggleBatchDate = useCallback((date: string) => {
+    setBatchSelectedDates(prev => {
+      const next = new Set(prev)
+      if (next.has(date)) next.delete(date)
+      else next.add(date)
+      return next
+    })
+  }, [])
+  const selectAllBatchDates = useCallback(() => setBatchSelectedDates(new Set(batchVoiceDates)), [batchVoiceDates])
+  const clearAllBatchDates = useCallback(() => setBatchSelectedDates(new Set()), [])
+
+  const formatBatchDateLabel = useCallback((dateStr: string) => {
+    const [y, m, d] = dateStr.split('-').map(Number)
+    return `${y}年${m}月${d}日`
+  }, [])
+
   return (
     <div className={`chat-page ${isResizing ? 'resizing' : ''}`}>
       {/* 左侧会话列表 */}
@@ -1293,6 +1474,18 @@ function ChatPage(_props: ChatPageProps) {
                 )}
               </div>
               <div className="header-actions">
+                <button
+                  className="icon-btn batch-transcribe-btn"
+                  onClick={handleBatchTranscribe}
+                  disabled={isBatchTranscribing || !currentSessionId}
+                  title={isBatchTranscribing ? `批量转写中 (${batchTranscribeProgress.current}/${batchTranscribeProgress.total})` : '批量语音转文字'}
+                >
+                  {isBatchTranscribing ? (
+                    <Loader2 size={18} className="spin" />
+                  ) : (
+                    <Mic size={18} />
+                  )}
+                </button>
                 <button
                   className="icon-btn jump-to-time-btn"
                   onClick={() => setShowJumpDialog(true)}
@@ -1428,23 +1621,35 @@ function ChatPage(_props: ChatPageProps) {
                           <Hash size={14} />
                           <span className="label">微信ID</span>
                           <span className="value">{sessionDetail.wxid}</span>
+                          <button className="copy-btn" title="复制" onClick={() => handleCopyField(sessionDetail.wxid, 'wxid')}>
+                            {copiedField === 'wxid' ? <Check size={12} /> : <Copy size={12} />}
+                          </button>
                         </div>
                         {sessionDetail.remark && (
                           <div className="detail-item">
                             <span className="label">备注</span>
                             <span className="value">{sessionDetail.remark}</span>
+                            <button className="copy-btn" title="复制" onClick={() => handleCopyField(sessionDetail.remark!, 'remark')}>
+                              {copiedField === 'remark' ? <Check size={12} /> : <Copy size={12} />}
+                            </button>
                           </div>
                         )}
                         {sessionDetail.nickName && (
                           <div className="detail-item">
                             <span className="label">昵称</span>
                             <span className="value">{sessionDetail.nickName}</span>
+                            <button className="copy-btn" title="复制" onClick={() => handleCopyField(sessionDetail.nickName!, 'nickName')}>
+                              {copiedField === 'nickName' ? <Check size={12} /> : <Copy size={12} />}
+                            </button>
                           </div>
                         )}
                         {sessionDetail.alias && (
                           <div className="detail-item">
                             <span className="label">微信号</span>
                             <span className="value">{sessionDetail.alias}</span>
+                            <button className="copy-btn" title="复制" onClick={() => handleCopyField(sessionDetail.alias!, 'alias')}>
+                              {copiedField === 'alias' ? <Check size={12} /> : <Copy size={12} />}
+                            </button>
                           </div>
                         )}
                       </div>
@@ -1542,10 +1747,176 @@ function ChatPage(_props: ChatPageProps) {
           }}
         />
       )}
+
+      {/* 批量转写确认对话框 */}
+      {showBatchConfirm && createPortal(
+        <div className="batch-modal-overlay" onClick={() => setShowBatchConfirm(false)}>
+          <div className="batch-modal-content batch-confirm-modal" onClick={(e) => e.stopPropagation()}>
+            <div className="batch-modal-header">
+              <Mic size={20} />
+              <h3>批量语音转文字</h3>
+            </div>
+            <div className="batch-modal-body">
+              <p>选择要转写的日期（仅显示有语音的日期），然后开始转写。</p>
+              {batchVoiceDates.length > 0 && (
+                <div className="batch-dates-list-wrap">
+                  <div className="batch-dates-actions">
+                    <button type="button" className="batch-dates-btn" onClick={selectAllBatchDates}>全选</button>
+                    <button type="button" className="batch-dates-btn" onClick={clearAllBatchDates}>取消全选</button>
+                  </div>
+                  <ul className="batch-dates-list">
+                    {batchVoiceDates.map(dateStr => {
+                      const count = batchCountByDate.get(dateStr) ?? 0
+                      const checked = batchSelectedDates.has(dateStr)
+                      return (
+                        <li key={dateStr}>
+                          <label className="batch-date-row">
+                            <input
+                              type="checkbox"
+                              checked={checked}
+                              onChange={() => toggleBatchDate(dateStr)}
+                            />
+                            <span className="batch-date-label">{formatBatchDateLabel(dateStr)}</span>
+                            <span className="batch-date-count">{count} 条语音</span>
+                          </label>
+                        </li>
+                      )
+                    })}
+                  </ul>
+                </div>
+              )}
+              <div className="batch-info">
+                <div className="info-item">
+                  <span className="label">已选:</span>
+                  <span className="value">{batchSelectedDates.size} 天有语音，共 {batchSelectedMessageCount} 条语音</span>
+                </div>
+                <div className="info-item">
+                  <span className="label">预计耗时:</span>
+                  <span className="value">约 {Math.ceil(batchSelectedMessageCount * 2 / 60)} 分钟</span>
+                </div>
+              </div>
+              <div className="batch-warning">
+                <AlertCircle size={16} />
+                <span>批量转写可能需要较长时间，转写过程中可以继续使用其他功能。已转写过的语音会自动跳过。</span>
+              </div>
+            </div>
+            <div className="batch-modal-footer">
+              <button className="btn-secondary" onClick={() => setShowBatchConfirm(false)}>
+                取消
+              </button>
+              <button className="btn-primary batch-transcribe-start-btn" onClick={confirmBatchTranscribe}>
+                <Mic size={16} />
+                开始转写
+              </button>
+            </div>
+          </div>
+        </div>,
+        document.body
+      )}
+
+      {/* 批量转写进度对话框 */}
+      {showBatchProgress && createPortal(
+        <div className="batch-modal-overlay">
+          <div className="batch-modal-content batch-progress-modal" onClick={(e) => e.stopPropagation()}>
+            <div className="batch-modal-header">
+              <Loader2 size={20} className="spin" />
+              <h3>正在转写...</h3>
+            </div>
+            <div className="batch-modal-body">
+              <div className="progress-info">
+                <div className="progress-text">
+                  <span>已完成 {batchTranscribeProgress.current} / {batchTranscribeProgress.total} 条</span>
+                  <span className="progress-percent">
+                    {batchTranscribeProgress.total > 0
+                      ? Math.round((batchTranscribeProgress.current / batchTranscribeProgress.total) * 100)
+                      : 0}%
+                  </span>
+                </div>
+                <div className="progress-bar">
+                  <div
+                    className="progress-fill"
+                    style={{
+                      width: `${batchTranscribeProgress.total > 0
+                        ? (batchTranscribeProgress.current / batchTranscribeProgress.total) * 100
+                        : 0}%`
+                    }}
+                  />
+                </div>
+              </div>
+              <div className="batch-tip">
+                <span>转写过程中可以继续使用其他功能</span>
+              </div>
+            </div>
+          </div>
+        </div>,
+        document.body
+      )}
+
+      {/* 批量转写结果对话框 */}
+      {showBatchResult && createPortal(
+        <div className="batch-modal-overlay" onClick={() => setShowBatchResult(false)}>
+          <div className="batch-modal-content batch-result-modal" onClick={(e) => e.stopPropagation()}>
+            <div className="batch-modal-header">
+              <CheckCircle size={20} />
+              <h3>转写完成</h3>
+            </div>
+            <div className="batch-modal-body">
+              <div className="result-summary">
+                <div className="result-item success">
+                  <CheckCircle size={18} />
+                  <span className="label">成功:</span>
+                  <span className="value">{batchResult.success} 条</span>
+                </div>
+                {batchResult.fail > 0 && (
+                  <div className="result-item fail">
+                    <XCircle size={18} />
+                    <span className="label">失败:</span>
+                    <span className="value">{batchResult.fail} 条</span>
+                  </div>
+                )}
+              </div>
+              {batchResult.fail > 0 && (
+                <div className="result-tip">
+                  <AlertCircle size={16} />
+                  <span>部分语音转写失败，可能是语音文件损坏或网络问题</span>
+                </div>
+              )}
+            </div>
+            <div className="batch-modal-footer">
+              <button className="btn-primary" onClick={() => setShowBatchResult(false)}>
+                确定
+              </button>
+            </div>
+          </div>
+        </div>,
+        document.body
+      )}
     </div>
   )
 }
 
+// 全局语音播放管理器：同一时间只能播放一条语音
+const globalVoiceManager = {
+  currentAudio: null as HTMLAudioElement | null,
+  currentStopCallback: null as (() => void) | null,
+  play(audio: HTMLAudioElement, onStop: () => void) {
+    // 停止当前正在播放的语音
+    if (this.currentAudio && this.currentAudio !== audio) {
+      this.currentAudio.pause()
+      this.currentAudio.currentTime = 0
+      this.currentStopCallback?.()
+    }
+    this.currentAudio = audio
+    this.currentStopCallback = onStop
+  },
+  stop(audio: HTMLAudioElement) {
+    if (this.currentAudio === audio) {
+      this.currentAudio = null
+      this.currentStopCallback = null
+    }
+  },
+}
+
 // 前端表情包缓存
 const emojiDataUrlCache = new Map<string, string>()
 const imageDataUrlCache = new Map<string, string>()
@@ -1601,6 +1972,10 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
   const [voiceWaveform, setVoiceWaveform] = useState<number[]>([])
   const voiceAutoDecryptTriggered = useRef(false)
 
+  // 转账消息双方名称
+  const [transferPayerName, setTransferPayerName] = useState<string | undefined>(undefined)
+  const [transferReceiverName, setTransferReceiverName] = useState<string | undefined>(undefined)
+
   // 视频相关状态
   const [videoLoading, setVideoLoading] = useState(false)
   const [videoInfo, setVideoInfo] = useState<{ videoUrl?: string; coverUrl?: string; thumbUrl?: string; exists: boolean } | null>(null)
@@ -1765,6 +2140,26 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
     }
   }, [isGroupChat, isSent, message.senderUsername, myAvatarUrl])
 
+  // 解析转账消息的付款方和收款方显示名称
+  useEffect(() => {
+    const payerWxid = (message as any).transferPayerUsername
+    const receiverWxid = (message as any).transferReceiverUsername
+    if (!payerWxid && !receiverWxid) return
+    // 仅对转账消息类型处理
+    if (message.localType !== 49 && message.localType !== 8589934592049) return
+
+    window.electronAPI.chat.resolveTransferDisplayNames(
+      session.username,
+      payerWxid || '',
+      receiverWxid || ''
+    ).then((result: { payerName: string; receiverName: string }) => {
+      if (result) {
+        setTransferPayerName(result.payerName)
+        setTransferReceiverName(result.receiverName)
+      }
+    }).catch(() => { })
+  }, [(message as any).transferPayerUsername, (message as any).transferReceiverUsername, session.username])
+
   // 自动下载表情包
   useEffect(() => {
     if (emojiLocalPath) return
@@ -1985,6 +2380,7 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
     const handleEnded = () => {
       setIsVoicePlaying(false)
       setVoiceCurrentTime(0)
+      globalVoiceManager.stop(audio)
     }
     const handleTimeUpdate = () => {
       setVoiceCurrentTime(audio.currentTime)
@@ -1999,6 +2395,7 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
     audio.addEventListener('loadedmetadata', handleLoadedMetadata)
     return () => {
       audio.pause()
+      globalVoiceManager.stop(audio)
       audio.removeEventListener('play', handlePlay)
       audio.removeEventListener('pause', handlePause)
       audio.removeEventListener('ended', handleEnded)
@@ -2433,6 +2830,7 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
         if (isVoicePlaying) {
           audio.pause()
           audio.currentTime = 0
+          globalVoiceManager.stop(audio)
           return
         }
         if (!voiceDataUrl) {
@@ -2467,6 +2865,11 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
         }
         audio.src = source
         try {
+          // 停止其他正在播放的语音，确保同一时间只播放一条
+          globalVoiceManager.play(audio, () => {
+            audio.pause()
+            audio.currentTime = 0
+          })
           await audio.play()
         } catch {
           setVoiceError(true)
@@ -2623,6 +3026,7 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
       let url = ''
       let appMsgType = ''
       let textAnnouncement = ''
+      let parsedDoc: Document | null = null
 
       try {
         const content = message.rawContent || message.parsedContent || ''
@@ -2630,13 +3034,13 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
         const xmlContent = content.substring(content.indexOf('<msg>'))
 
         const parser = new DOMParser()
-        const doc = parser.parseFromString(xmlContent, 'text/xml')
+        parsedDoc = parser.parseFromString(xmlContent, 'text/xml')
 
-        title = doc.querySelector('title')?.textContent || '链接'
-        desc = doc.querySelector('des')?.textContent || ''
-        url = doc.querySelector('url')?.textContent || ''
-        appMsgType = doc.querySelector('appmsg > type')?.textContent || doc.querySelector('type')?.textContent || ''
-        textAnnouncement = doc.querySelector('textannouncement')?.textContent || ''
+        title = parsedDoc.querySelector('title')?.textContent || '链接'
+        desc = parsedDoc.querySelector('des')?.textContent || ''
+        url = parsedDoc.querySelector('url')?.textContent || ''
+        appMsgType = parsedDoc.querySelector('appmsg > type')?.textContent || parsedDoc.querySelector('type')?.textContent || ''
+        textAnnouncement = parsedDoc.querySelector('textannouncement')?.textContent || ''
       } catch (e) {
         console.error('解析 AppMsg 失败:', e)
       }
@@ -2764,19 +3168,10 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
       // 转账消息 (type=2000)
       if (appMsgType === '2000') {
         try {
-          const content = message.rawContent || message.content || message.parsedContent || ''
-
-          // 添加调试日志
-
-
-          const parser = new DOMParser()
-          const doc = parser.parseFromString(content, 'text/xml')
-
-          const feedesc = doc.querySelector('feedesc')?.textContent || ''
-          const payMemo = doc.querySelector('pay_memo')?.textContent || ''
-          const paysubtype = doc.querySelector('paysubtype')?.textContent || '1'
-
-
+          // 使用外层已解析好的 parsedDoc（已去除 wxid 前缀）
+          const feedesc = parsedDoc?.querySelector('feedesc')?.textContent || ''
+          const payMemo = parsedDoc?.querySelector('pay_memo')?.textContent || ''
+          const paysubtype = parsedDoc?.querySelector('paysubtype')?.textContent || '1'
 
           // paysubtype: 1=待收款, 3=已收款
           const isReceived = paysubtype === '3'
@@ -2784,16 +3179,29 @@ function MessageBubble({ message, session, showTime, myAvatarUrl, isGroupChat, o
           // 如果 feedesc 为空，使用 title 作为降级
           const displayAmount = feedesc || title || '微信转账'
 
+          // 构建转账描述：A 转账给 B
+          const transferDesc = transferPayerName && transferReceiverName
+            ? `${transferPayerName} 转账给 ${transferReceiverName}`
+            : undefined
+
           return (
             <div className={`transfer-message ${isReceived ? 'received' : ''}`}>
               <div className="transfer-icon">
-                <svg width="32" height="32" viewBox="0 0 40 40" fill="none">
-                  <circle cx="20" cy="20" r="18" stroke="white" strokeWidth="2" />
-                  <path d="M12 20h16M20 12l8 8-8 8" stroke="white" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round" />
-                </svg>
+                {isReceived ? (
+                  <svg width="32" height="32" viewBox="0 0 40 40" fill="none">
+                    <circle cx="20" cy="20" r="18" stroke="white" strokeWidth="2" />
+                    <path d="M12 20l6 6 10-12" stroke="white" strokeWidth="2.5" strokeLinecap="round" strokeLinejoin="round" />
+                  </svg>
+                ) : (
+                  <svg width="32" height="32" viewBox="0 0 40 40" fill="none">
+                    <circle cx="20" cy="20" r="18" stroke="white" strokeWidth="2" />
+                    <path d="M12 20h16M20 12l8 8-8 8" stroke="white" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round" />
+                  </svg>
+                )}
               </div>
               <div className="transfer-info">
                 <div className="transfer-amount">{displayAmount}</div>
+                {transferDesc && <div className="transfer-desc">{transferDesc}</div>}
                 {payMemo && <div className="transfer-memo">{payMemo}</div>}
                 <div className="transfer-label">{isReceived ? '已收款' : '微信转账'}</div>
               </div>

src/pages/SettingsPage.scss

@@ -1191,6 +1191,109 @@
   }
 }
 
+// 通用弹窗覆盖层
+.modal-overlay {
+  position: fixed;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: rgba(0, 0, 0, 0.5);
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  z-index: 1000;
+  animation: fadeIn 0.2s ease;
+}
+
+// API 警告弹窗
+.api-warning-modal {
+  width: 420px;
+  background: var(--bg-primary);
+  border-radius: 16px;
+  overflow: hidden;
+  box-shadow: 0 16px 48px rgba(0, 0, 0, 0.2);
+  animation: slideUp 0.25s ease;
+
+  .modal-header {
+    display: flex;
+    align-items: center;
+    gap: 10px;
+    padding: 20px 24px;
+    border-bottom: 1px solid var(--border-color);
+
+    svg {
+      color: var(--warning, #f59e0b);
+    }
+
+    h3 {
+      margin: 0;
+      font-size: 16px;
+      font-weight: 600;
+      color: var(--text-primary);
+    }
+  }
+
+  .modal-body {
+    padding: 20px 24px;
+
+    .warning-text {
+      margin: 0 0 16px;
+      font-size: 14px;
+      color: var(--text-secondary);
+      line-height: 1.6;
+    }
+
+    .warning-list {
+      display: flex;
+      flex-direction: column;
+      gap: 10px;
+
+      .warning-item {
+        display: flex;
+        align-items: flex-start;
+        gap: 8px;
+        font-size: 13px;
+        color: var(--text-secondary);
+        line-height: 1.5;
+
+        .bullet {
+          color: var(--warning, #f59e0b);
+          font-weight: bold;
+        }
+      }
+    }
+  }
+
+  .modal-footer {
+    display: flex;
+    justify-content: flex-end;
+    gap: 10px;
+    padding: 16px 24px;
+    border-top: 1px solid var(--border-color);
+    background: var(--bg-secondary);
+  }
+}
+
+@keyframes fadeIn {
+  from {
+    opacity: 0;
+  }
+  to {
+    opacity: 1;
+  }
+}
+
+@keyframes slideUp {
+  from {
+    opacity: 0;
+    transform: translateY(10px);
+  }
+  to {
+    opacity: 1;
+    transform: translateY(0);
+  }
+}
 
 // 协议弹窗
 .agreement-overlay {
@@ -1855,4 +1958,148 @@
   to {
     transform: rotate(360deg);
   }
+}
+
+// API 地址显示样式
+.api-url-display {
+  display: flex;
+  gap: 8px;
+  margin-top: 8px;
+
+  input {
+    flex: 1;
+    font-family: 'SF Mono', 'Consolas', monospace;
+    font-size: 13px;
+  }
+
+  .btn {
+    flex-shrink: 0;
+  }
+}
+
+// API 服务设置样式
+.status-badge {
+  display: inline-flex;
+  align-items: center;
+  padding: 4px 10px;
+  border-radius: 12px;
+  font-size: 12px;
+  font-weight: 500;
+
+  &.running {
+    background: rgba(34, 197, 94, 0.15);
+    color: #22c55e;
+  }
+
+  &.stopped {
+    background: rgba(156, 163, 175, 0.15);
+    color: var(--text-tertiary);
+  }
+}
+
+.api-url {
+  display: inline-block;
+  padding: 8px 14px;
+  background: var(--bg-tertiary);
+  border-radius: 6px;
+  font-family: 'SF Mono', 'Consolas', monospace;
+  font-size: 13px;
+  color: var(--text-primary);
+  border: 1px solid var(--border-color);
+}
+
+.api-docs {
+  display: flex;
+  flex-direction: column;
+  gap: 12px;
+}
+
+.api-item {
+  padding: 12px 16px;
+  background: var(--bg-tertiary);
+  border-radius: 8px;
+  border: 1px solid var(--border-color);
+
+  .api-endpoint {
+    display: flex;
+    align-items: center;
+    gap: 10px;
+    margin-bottom: 6px;
+
+    .method {
+      display: inline-block;
+      padding: 2px 8px;
+      border-radius: 4px;
+      font-size: 11px;
+      font-weight: 600;
+      text-transform: uppercase;
+
+      &.get {
+        background: rgba(34, 197, 94, 0.15);
+        color: #22c55e;
+      }
+
+      &.post {
+        background: rgba(59, 130, 246, 0.15);
+        color: #3b82f6;
+      }
+    }
+
+    code {
+      font-family: 'SF Mono', 'Consolas', monospace;
+      font-size: 13px;
+      color: var(--text-primary);
+    }
+  }
+
+  .api-desc {
+    font-size: 12px;
+    color: var(--text-secondary);
+    margin: 0 0 8px 0;
+  }
+
+  .api-params {
+    display: flex;
+    flex-wrap: wrap;
+    gap: 6px;
+
+    .param {
+      display: inline-block;
+      padding: 2px 8px;
+      background: var(--bg-secondary);
+      border-radius: 4px;
+      font-size: 11px;
+      color: var(--text-tertiary);
+
+      code {
+        color: var(--primary);
+        font-family: 'SF Mono', 'Consolas', monospace;
+      }
+    }
+  }
+}
+
+.code-block {
+  padding: 12px 16px;
+  background: var(--bg-tertiary);
+  border-radius: 8px;
+  border: 1px solid var(--border-color);
+  overflow-x: auto;
+
+  code {
+    font-family: 'SF Mono', 'Consolas', monospace;
+    font-size: 12px;
+    color: var(--text-primary);
+    white-space: nowrap;
+  }
+}
+
+.btn-sm {
+  padding: 4px 10px !important;
+  font-size: 12px !important;
+  
+  svg {
+    width: 14px;
+    height: 14px;
+  }
 }

src/pages/SettingsPage.tsx

@@ -9,12 +9,12 @@ import {
   Eye, EyeOff, FolderSearch, FolderOpen, Search, Copy,
   RotateCcw, Trash2, Plug, Check, Sun, Moon,
   Palette, Database, Download, HardDrive, Info, RefreshCw, ChevronDown, Mic,
-  ShieldCheck, Fingerprint, Lock, KeyRound, Bell
+  ShieldCheck, Fingerprint, Lock, KeyRound, Bell, Globe
 } from 'lucide-react'
 import { Avatar } from '../components/Avatar'
 import './SettingsPage.scss'
 
-type SettingsTab = 'appearance' | 'notification' | 'database' | 'models' | 'export' | 'cache' | 'security' | 'about'
+type SettingsTab = 'appearance' | 'notification' | 'database' | 'models' | 'export' | 'cache' | 'api' | 'security' | 'about'
 
 const tabs: { id: SettingsTab; label: string; icon: React.ElementType }[] = [
   { id: 'appearance', label: '外观', icon: Palette },
@@ -23,6 +23,7 @@ const tabs: { id: SettingsTab; label: string; icon: React.ElementType }[] = [
   { id: 'models', label: '模型管理', icon: Mic },
   { id: 'export', label: '导出', icon: Download },
   { id: 'cache', label: '缓存', icon: HardDrive },
+  { id: 'api', label: 'API 服务', icon: Globe },
   { id: 'security', label: '安全', icon: ShieldCheck },
   { id: 'about', label: '关于', icon: Info }
 ]
@@ -137,6 +138,13 @@ function SettingsPage() {
   const [confirmPassword, setConfirmPassword] = useState('')
   const [isSettingHello, setIsSettingHello] = useState(false)
 
+  // HTTP API 设置 state
+  const [httpApiEnabled, setHttpApiEnabled] = useState(false)
+  const [httpApiPort, setHttpApiPort] = useState(5031)
+  const [httpApiRunning, setHttpApiRunning] = useState(false)
+  const [isTogglingApi, setIsTogglingApi] = useState(false)
+  const [showApiWarning, setShowApiWarning] = useState(false)
+
   const isClearingCache = isClearingAnalyticsCache || isClearingImageCache || isClearingAllCache
 
   // 检查 Hello 可用性
@@ -146,6 +154,22 @@ function SettingsPage() {
     }
   }, [])
 
+  // 检查 HTTP API 服务状态
+  useEffect(() => {
+    const checkApiStatus = async () => {
+      try {
+        const status = await window.electronAPI.http.status()
+        setHttpApiRunning(status.running)
+        if (status.port) {
+          setHttpApiPort(status.port)
+        }
+      } catch (e) {
+        console.error('检查 API 状态失败:', e)
+      }
+    }
+    checkApiStatus()
+  }, [])
+
   async function sha256(message: string) {
     const msgBuffer = new TextEncoder().encode(message)
     const hashBuffer = await crypto.subtle.digest('SHA-256', msgBuffer)
@@ -1835,6 +1859,147 @@ function SettingsPage() {
     </div>
   )
 
+  // HTTP API 服务控制
+  const handleToggleApi = async () => {
+    if (isTogglingApi) return
+    
+    // 启动时显示警告弹窗
+    if (!httpApiRunning) {
+      setShowApiWarning(true)
+      return
+    }
+    
+    setIsTogglingApi(true)
+    try {
+      await window.electronAPI.http.stop()
+      setHttpApiRunning(false)
+      showMessage('API 服务已停止', true)
+    } catch (e: any) {
+      showMessage(`操作失败: ${e}`, false)
+    } finally {
+      setIsTogglingApi(false)
+    }
+  }
+
+  // 确认启动 API 服务
+  const confirmStartApi = async () => {
+    setShowApiWarning(false)
+    setIsTogglingApi(true)
+    try {
+      const result = await window.electronAPI.http.start(httpApiPort)
+      if (result.success) {
+        setHttpApiRunning(true)
+        if (result.port) setHttpApiPort(result.port)
+        showMessage(`API 服务已启动，端口 ${result.port}`, true)
+      } else {
+        showMessage(`启动失败: ${result.error}`, false)
+      }
+    } catch (e: any) {
+      showMessage(`操作失败: ${e}`, false)
+    } finally {
+      setIsTogglingApi(false)
+    }
+  }
+
+  const handleCopyApiUrl = () => {
+    const url = `http://127.0.0.1:${httpApiPort}`
+    navigator.clipboard.writeText(url)
+    showMessage('已复制 API 地址', true)
+  }
+
+  const renderApiTab = () => (
+    <div className="tab-content">
+      <div className="form-group">
+        <label>HTTP API 服务</label>
+        <span className="form-hint">启用后可通过 HTTP 接口查询消息数据（仅限本机访问）</span>
+        <div className="log-toggle-line">
+          <span className="log-status">
+            {httpApiRunning ? '运行中' : '已停止'}
+          </span>
+          <label className="switch">
+            <input
+              type="checkbox"
+              checked={httpApiRunning}
+              onChange={handleToggleApi}
+              disabled={isTogglingApi}
+            />
+            <span className="switch-slider" />
+          </label>
+        </div>
+      </div>
+
+      <div className="form-group">
+        <label>服务端口</label>
+        <span className="form-hint">API 服务监听的端口号（1024-65535）</span>
+        <input
+          type="number"
+          className="field-input"
+          value={httpApiPort}
+          onChange={(e) => setHttpApiPort(parseInt(e.target.value, 10) || 5031)}
+          disabled={httpApiRunning}
+          style={{ width: 120 }}
+          min={1024}
+          max={65535}
+        />
+      </div>
+
+      {httpApiRunning && (
+        <div className="form-group">
+          <label>API 地址</label>
+          <span className="form-hint">使用以下地址访问 API</span>
+          <div className="api-url-display">
+            <input
+              type="text"
+              className="field-input"
+              value={`http://127.0.0.1:${httpApiPort}`}
+              readOnly
+            />
+            <button className="btn btn-secondary" onClick={handleCopyApiUrl} title="复制">
+              <Copy size={16} />
+            </button>
+          </div>
+        </div>
+      )}
+
+      {/* API 安全警告弹窗 */}
+      {showApiWarning && (
+        <div className="modal-overlay" onClick={() => setShowApiWarning(false)}>
+          <div className="api-warning-modal" onClick={(e) => e.stopPropagation()}>
+            <div className="modal-header">
+              <ShieldCheck size={20} />
+              <h3>安全提示</h3>
+            </div>
+            <div className="modal-body">
+              <p className="warning-text">启用 HTTP API 服务后，本机上的其他程序可通过接口访问您的聊天记录数据。</p>
+              <div className="warning-list">
+                <div className="warning-item">
+                  <span className="bullet">•</span>
+                  <span>请确保您了解此功能的用途</span>
+                </div>
+                <div className="warning-item">
+                  <span className="bullet">•</span>
+                  <span>不要在公共或不信任的网络环境下使用</span>
+                </div>
+                <div className="warning-item">
+                  <span className="bullet">•</span>
+                  <span>此功能仅供高级用户或开发者使用</span>
+                </div>
+              </div>
+            </div>
+            <div className="modal-footer">
+              <button className="btn btn-secondary" onClick={() => setShowApiWarning(false)}>
+                取消
+              </button>
+              <button className="btn btn-primary" onClick={confirmStartApi}>
+                确认启动
+              </button>
+            </div>
+          </div>
+        </div>
+      )}
+    </div>
+  )
+
   const handleSetupHello = async () => {
     setIsSettingHello(true)
     try {
@@ -2075,6 +2240,7 @@ function SettingsPage() {
         {activeTab === 'models' && renderModelsTab()}
         {activeTab === 'export' && renderExportTab()}
         {activeTab === 'cache' && renderCacheTab()}
+        {activeTab === 'api' && renderApiTab()}
         {activeTab === 'security' && renderSecurityTab()}
         {activeTab === 'about' && renderAboutTab()}
       </div>

src/types/electron.d.ts

@@ -85,6 +85,7 @@ export interface ElectronAPI {
     }>
     getContact: (username: string) => Promise<Contact | null>
     getContactAvatar: (username: string) => Promise<{ avatarUrl?: string; displayName?: string } | null>
+    resolveTransferDisplayNames: (chatroomId: string, payerUsername: string, receiverUsername: string) => Promise<{ payerName: string; receiverName: string }>
     getContacts: () => Promise<{
       success: boolean
       contacts?: ContactInfo[]
@@ -111,6 +112,7 @@ export interface ElectronAPI {
     }>
     getImageData: (sessionId: string, msgId: string) => Promise<{ success: boolean; data?: string; error?: string }>
     getVoiceData: (sessionId: string, msgId: string, createTime?: number, serverId?: string | number) => Promise<{ success: boolean; data?: string; error?: string }>
+    getAllVoiceMessages: (sessionId: string) => Promise<{ success: boolean; messages?: Message[]; error?: string }>
     resolveVoiceCache: (sessionId: string, msgId: string) => Promise<{ success: boolean; hasCache: boolean; data?: string }>
     getVoiceTranscript: (sessionId: string, msgId: string, createTime?: number) => Promise<{ success: boolean; transcript?: string; error?: string }>
     onVoiceTranscriptPartial: (callback: (payload: { msgId: string; text: string }) => void) => () => void

src/types/models.ts

@@ -64,6 +64,9 @@ export interface Message {
   fileSize?: number         // 文件大小
   fileExt?: string          // 文件扩展名
   xmlType?: string          // XML 中的 type 字段
+  // 转账消息
+  transferPayerUsername?: string    // 转账付款方 wxid
+  transferReceiverUsername?: string // 转账收款方 wxid
   // 名片消息
   cardUsername?: string     // 名片的微信ID
   cardNickname?: string     // 名片的昵称