Merge pull request #247 from hicccc77/dev

Dev
2026-03-24 23:06:51 +00:00 · 2026-02-11 20:00:26 +08:00
parent e3c17010c1 8fee96d0e1
commit fff1a1c177
26 changed files with 2488 additions and 704 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -60,3 +60,4 @@ wcdb/
 概述.md
 chatlab-format.md
 *.bak
+AGENTS.md
--- a/electron/main.ts
+++ b/electron/main.ts
@@ -985,8 +985,8 @@ function registerIpcHandlers() {
    return analyticsService.getOverallStatistics(force)
  })

-  ipcMain.handle('analytics:getContactRankings', async (_, limit?: number) => {
-    return analyticsService.getContactRankings(limit)
+  ipcMain.handle('analytics:getContactRankings', async (_, limit?: number, beginTimestamp?: number, endTimestamp?: number) => {
+    return analyticsService.getContactRankings(limit, beginTimestamp, endTimestamp)
  })

  ipcMain.handle('analytics:getTimeDistribution', async () => {
--- a/electron/preload.ts
+++ b/electron/preload.ts
@@ -189,7 +189,8 @@ contextBridge.exposeInMainWorld('electronAPI', {
  // 数据分析
  analytics: {
    getOverallStatistics: (force?: boolean) => ipcRenderer.invoke('analytics:getOverallStatistics', force),
-    getContactRankings: (limit?: number) => ipcRenderer.invoke('analytics:getContactRankings', limit),
+    getContactRankings: (limit?: number, beginTimestamp?: number, endTimestamp?: number) =>
+      ipcRenderer.invoke('analytics:getContactRankings', limit, beginTimestamp, endTimestamp),
    getTimeDistribution: () => ipcRenderer.invoke('analytics:getTimeDistribution'),
    getExcludedUsernames: () => ipcRenderer.invoke('analytics:getExcludedUsernames'),
    setExcludedUsernames: (usernames: string[]) => ipcRenderer.invoke('analytics:setExcludedUsernames', usernames),
--- a/electron/services/analyticsService.ts
+++ b/electron/services/analyticsService.ts
@@ -31,6 +31,7 @@ export interface ContactRanking {
  username: string
  displayName: string
  avatarUrl?: string
+  wechatId?: string
  messageCount: number
  sentCount: number
  receivedCount: number
@@ -576,7 +577,11 @@ class AnalyticsService {
    }
  }

-  async getContactRankings(limit: number = 20): Promise<{ success: boolean; data?: ContactRanking[]; error?: string }> {
+  async getContactRankings(
+    limit: number = 20,
+    beginTimestamp: number = 0,
+    endTimestamp: number = 0
+  ): Promise<{ success: boolean; data?: ContactRanking[]; error?: string }> {
    try {
      const conn = await this.ensureConnected()
      if (!conn.success || !conn.cleanedWxid) return { success: false, error: conn.error }
@@ -586,7 +591,7 @@ class AnalyticsService {
        return { success: false, error: '未找到消息会话' }
      }

-      const result = await this.getAggregateWithFallback(sessionInfo.usernames, 0, 0)
+      const result = await this.getAggregateWithFallback(sessionInfo.usernames, beginTimestamp, endTimestamp)
      if (!result.success || !result.data) {
        return { success: false, error: result.error || '聚合统计失败' }
      }
@@ -594,9 +599,10 @@ class AnalyticsService {
      const d = result.data
      const sessions = this.normalizeAggregateSessions(d.sessions, d.idMap)
      const usernames = Object.keys(sessions)
-      const [displayNames, avatarUrls] = await Promise.all([
+      const [displayNames, avatarUrls, aliasMap] = await Promise.all([
        wcdbService.getDisplayNames(usernames),
-        wcdbService.getAvatarUrls(usernames)
+        wcdbService.getAvatarUrls(usernames),
+        this.getAliasMap(usernames)
      ])

      const rankings: ContactRanking[] = usernames
@@ -608,10 +614,13 @@ class AnalyticsService {
          const avatarUrl = avatarUrls.success && avatarUrls.map
            ? avatarUrls.map[username]
            : undefined
+          const alias = aliasMap[username] || ''
+          const wechatId = alias || (!username.startsWith('wxid_') ? username : '')
          return {
            username,
            displayName,
            avatarUrl,
+            wechatId,
            messageCount: stat.total,
            sentCount: stat.sent,
            receivedCount: stat.received,
--- a/electron/services/dualReportService.ts
+++ b/electron/services/dualReportService.ts
@@ -6,6 +6,9 @@ export interface DualReportMessage {
  isSentByMe: boolean
  createTime: number
  createTimeStr: string
+  localType?: number
+  emojiMd5?: string
+  emojiCdnUrl?: string
 }

 export interface DualReportFirstChat {
@@ -14,6 +17,9 @@ export interface DualReportFirstChat {
  content: string
  isSentByMe: boolean
  senderUsername?: string
+  localType?: number
+  emojiMd5?: string
+  emojiCdnUrl?: string
 }

 export interface DualReportStats {
@@ -26,13 +32,17 @@ export interface DualReportStats {
  friendTopEmojiMd5?: string
  myTopEmojiUrl?: string
  friendTopEmojiUrl?: string
+  myTopEmojiCount?: number
+  friendTopEmojiCount?: number
 }

 export interface DualReportData {
  year: number
  selfName: string
+  selfAvatarUrl?: string
  friendUsername: string
  friendName: string
+  friendAvatarUrl?: string
  firstChat: DualReportFirstChat | null
  firstChatMessages?: DualReportMessage[]
  yearFirstChat?: {
@@ -42,9 +52,17 @@ export interface DualReportData {
    isSentByMe: boolean
    friendName: string
    firstThreeMessages: DualReportMessage[]
+    localType?: number
+    emojiMd5?: string
+    emojiCdnUrl?: string
  } | null
  stats: DualReportStats
  topPhrases: Array<{ phrase: string; count: number }>
+  heatmap?: number[][]
+  initiative?: { initiated: number; received: number }
+  response?: { avg: number; fastest: number; count: number }
+  monthly?: Record<string, number>
+  streak?: { days: number; startDate: string; endDate: string }
 }

 class DualReportService {
@@ -168,26 +186,258 @@ class DualReportService {
    return `${month}/${day} ${hour}:${minute}`
  }

-  private extractEmojiUrl(content: string): string | undefined {
-    if (!content) return undefined
-    const attrMatch = /cdnurl\s*=\s*['"]([^'"]+)['"]/i.exec(content)
-    if (attrMatch) {
-      let url = attrMatch[1].replace(/&amp;/g, '&')
-      try {
-        if (url.includes('%')) {
-          url = decodeURIComponent(url)
-        }
-      } catch { }
-      return url
+  private getRecordField(record: Record<string, any> | undefined | null, keys: string[]): any {
+    if (!record) return undefined
+    for (const key of keys) {
+      if (Object.prototype.hasOwnProperty.call(record, key) && record[key] !== undefined && record[key] !== null) {
+        return record[key]
+      }
    }
-    const tagMatch = /cdnurl[^>]*>([^<]+)/i.exec(content)
-    return tagMatch?.[1]
+    return undefined
  }

-  private extractEmojiMd5(content: string): string | undefined {
+  private coerceNumber(raw: any): number {
+    if (raw === undefined || raw === null || raw === '') return NaN
+    if (typeof raw === 'number') return raw
+    if (typeof raw === 'bigint') return Number(raw)
+    if (Buffer.isBuffer(raw)) return parseInt(raw.toString('utf-8'), 10)
+    if (raw instanceof Uint8Array) return parseInt(Buffer.from(raw).toString('utf-8'), 10)
+    const parsed = parseInt(String(raw), 10)
+    return Number.isFinite(parsed) ? parsed : NaN
+  }
+
+  private coerceString(raw: any): string {
+    if (raw === undefined || raw === null) return ''
+    if (typeof raw === 'string') return raw
+    if (Buffer.isBuffer(raw)) return this.decodeBinaryContent(raw)
+    if (raw instanceof Uint8Array) return this.decodeBinaryContent(Buffer.from(raw))
+    return String(raw)
+  }
+
+  private coerceBoolean(raw: any): boolean | undefined {
+    if (raw === undefined || raw === null || raw === '') return undefined
+    if (typeof raw === 'boolean') return raw
+    if (typeof raw === 'number') return raw !== 0
+
+    const normalized = String(raw).trim().toLowerCase()
+    if (!normalized) return undefined
+
+    if (['1', 'true', 'yes', 'me', 'self', 'mine', 'sent', 'out', 'outgoing'].includes(normalized)) return true
+    if (['0', 'false', 'no', 'friend', 'peer', 'other', 'recv', 'received', 'in', 'incoming'].includes(normalized)) return false
+    return undefined
+  }
+
+  private normalizeEmojiMd5(raw: string): string | undefined {
+    if (!raw) return undefined
+    const trimmed = raw.trim()
+    if (!trimmed) return undefined
+    const match = /([a-fA-F0-9]{16,64})/.exec(trimmed)
+    return match ? match[1].toLowerCase() : undefined
+  }
+
+  private normalizeEmojiUrl(raw: string): string | undefined {
+    if (!raw) return undefined
+    let url = raw.trim().replace(/&amp;/g, '&')
+    if (!url) return undefined
+    try {
+      if (url.includes('%')) {
+        url = decodeURIComponent(url)
+      }
+    } catch { }
+    return url || undefined
+  }
+
+  private extractEmojiUrl(content: string | undefined): string | undefined {
    if (!content) return undefined
-    const match = /md5="([^"]+)"/i.exec(content) || /<md5>([^<]+)<\/md5>/i.exec(content)
-    return match?.[1]
+    const direct = this.normalizeEmojiUrl(content)
+    if (direct && /^https?:\/\//i.test(direct)) return direct
+
+    const attrMatch = /(?:cdnurl|thumburl)\s*=\s*['"]([^'"]+)['"]/i.exec(content)
+      || /(?:cdnurl|thumburl)\s*=\s*([^'"\s>]+)/i.exec(content)
+    if (attrMatch) return this.normalizeEmojiUrl(attrMatch[1])
+
+    const tagMatch = /<(?:cdnurl|thumburl)>([^<]+)<\/(?:cdnurl|thumburl)>/i.exec(content)
+      || /(?:cdnurl|thumburl)[^>]*>([^<]+)/i.exec(content)
+    return this.normalizeEmojiUrl(tagMatch?.[1] || '')
+  }
+
+  private extractEmojiMd5(content: string | undefined): string | undefined {
+    if (!content) return undefined
+    const direct = this.normalizeEmojiMd5(content)
+    if (direct && direct.length >= 24) return direct
+
+    const match = /md5\s*=\s*['"]([a-fA-F0-9]{16,64})['"]/i.exec(content)
+      || /md5\s*=\s*([a-fA-F0-9]{16,64})/i.exec(content)
+      || /<md5>([a-fA-F0-9]{16,64})<\/md5>/i.exec(content)
+    return this.normalizeEmojiMd5(match?.[1] || '')
+  }
+
+  private resolveEmojiOwner(item: any, content: string): boolean | undefined {
+    const sentFlag = this.coerceBoolean(this.getRecordField(item, [
+      'isMe',
+      'is_me',
+      'isSent',
+      'is_sent',
+      'isSend',
+      'is_send',
+      'fromMe',
+      'from_me'
+    ]))
+    if (sentFlag !== undefined) return sentFlag
+
+    const sideRaw = this.coerceString(this.getRecordField(item, ['side', 'sender', 'from', 'owner', 'role', 'direction'])).trim().toLowerCase()
+    if (sideRaw) {
+      if (['me', 'self', 'mine', 'out', 'outgoing', 'sent'].includes(sideRaw)) return true
+      if (['friend', 'peer', 'other', 'in', 'incoming', 'received', 'recv'].includes(sideRaw)) return false
+    }
+
+    const prefixMatch = /^\s*([01])\s*:\s*/.exec(content)
+    if (prefixMatch) return prefixMatch[1] === '1'
+    return undefined
+  }
+
+  private stripEmojiOwnerPrefix(content: string): string {
+    if (!content) return ''
+    return content.replace(/^\s*[01]\s*:\s*/, '')
+  }
+
+  private parseEmojiCandidate(item: any): { isMe?: boolean; md5?: string; url?: string; count: number } {
+    const rawContent = this.coerceString(this.getRecordField(item, [
+      'content',
+      'xml',
+      'message_content',
+      'messageContent',
+      'msg',
+      'payload',
+      'raw'
+    ]))
+    const content = this.stripEmojiOwnerPrefix(rawContent)
+
+    const countRaw = this.getRecordField(item, ['count', 'cnt', 'times', 'total', 'num'])
+    const parsedCount = this.coerceNumber(countRaw)
+    const count = Number.isFinite(parsedCount) && parsedCount > 0 ? parsedCount : 0
+
+    const directMd5 = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(item, [
+      'md5',
+      'emojiMd5',
+      'emoji_md5',
+      'emd5'
+    ])))
+    const md5 = directMd5 || this.extractEmojiMd5(content)
+
+    const directUrl = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(item, [
+      'cdnUrl',
+      'cdnurl',
+      'emojiUrl',
+      'emoji_url',
+      'url',
+      'thumbUrl',
+      'thumburl'
+    ])))
+    const url = directUrl || this.extractEmojiUrl(content)
+
+    return {
+      isMe: this.resolveEmojiOwner(item, rawContent),
+      md5,
+      url,
+      count
+    }
+  }
+
+  private getRowInt(row: Record<string, any>, keys: string[], fallback = 0): number {
+    const raw = this.getRecordField(row, keys)
+    const parsed = this.coerceNumber(raw)
+    return Number.isFinite(parsed) ? parsed : fallback
+  }
+
+  private decodeRowMessageContent(row: Record<string, any>): string {
+    const messageContent = this.getRecordField(row, [
+      'message_content',
+      'messageContent',
+      'content',
+      'msg_content',
+      'msgContent',
+      'WCDB_CT_message_content',
+      'WCDB_CT_messageContent'
+    ])
+    const compressContent = this.getRecordField(row, [
+      'compress_content',
+      'compressContent',
+      'compressed_content',
+      'WCDB_CT_compress_content',
+      'WCDB_CT_compressContent'
+    ])
+    return this.decodeMessageContent(messageContent, compressContent)
+  }
+
+  private async scanEmojiTopFallback(
+    sessionId: string,
+    beginTimestamp: number,
+    endTimestamp: number,
+    rawWxid: string,
+    cleanedWxid: string
+  ): Promise<{ my?: { md5: string; url?: string; count: number }; friend?: { md5: string; url?: string; count: number } }> {
+    const cursorResult = await wcdbService.openMessageCursor(sessionId, 500, true, beginTimestamp, endTimestamp)
+    if (!cursorResult.success || !cursorResult.cursor) return {}
+
+    const tallyMap = new Map<string, { isMe: boolean; md5: string; url?: string; count: number }>()
+    try {
+      let hasMore = true
+      while (hasMore) {
+        const batch = await wcdbService.fetchMessageBatch(cursorResult.cursor)
+        if (!batch.success || !Array.isArray(batch.rows)) break
+
+        for (const row of batch.rows) {
+          const localType = this.getRowInt(row, ['local_type', 'localType', 'type', 'msg_type', 'msgType', 'WCDB_CT_local_type'], 0)
+          if (localType !== 47) continue
+
+          const rawContent = this.decodeRowMessageContent(row)
+          const content = this.stripEmojiOwnerPrefix(rawContent)
+          const directMd5 = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(row, ['emoji_md5', 'emojiMd5', 'md5'])))
+          const md5 = directMd5 || this.extractEmojiMd5(content)
+          if (!md5) continue
+
+          const directUrl = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(row, [
+            'emoji_cdn_url',
+            'emojiCdnUrl',
+            'cdnurl',
+            'cdn_url',
+            'emoji_url',
+            'emojiUrl',
+            'url',
+            'thumburl',
+            'thumb_url'
+          ])))
+          const url = directUrl || this.extractEmojiUrl(content)
+          const isMe = this.resolveIsSent(row, rawWxid, cleanedWxid)
+          const mapKey = `${isMe ? '1' : '0'}:${md5}`
+          const existing = tallyMap.get(mapKey)
+          if (existing) {
+            existing.count += 1
+            if (!existing.url && url) existing.url = url
+          } else {
+            tallyMap.set(mapKey, { isMe, md5, url, count: 1 })
+          }
+        }
+        hasMore = batch.hasMore === true
+      }
+    } finally {
+      await wcdbService.closeMessageCursor(cursorResult.cursor)
+    }
+
+    let myTop: { md5: string; url?: string; count: number } | undefined
+    let friendTop: { md5: string; url?: string; count: number } | undefined
+    for (const entry of tallyMap.values()) {
+      if (entry.isMe) {
+        if (!myTop || entry.count > myTop.count) {
+          myTop = { md5: entry.md5, url: entry.url, count: entry.count }
+        }
+      } else if (!friendTop || entry.count > friendTop.count) {
+        friendTop = { md5: entry.md5, url: entry.url, count: entry.count }
+      }
+    }
+
+    return { my: myTop, friend: friendTop }
  }

  private async getDisplayName(username: string, fallback: string): Promise<string> {
@@ -271,189 +521,222 @@ class DualReportService {
      if (myName === rawWxid && cleanedWxid && cleanedWxid !== rawWxid) {
        myName = await this.getDisplayName(cleanedWxid, rawWxid)
      }
+      const avatarCandidates = Array.from(new Set([
+        friendUsername,
+        rawWxid,
+        cleanedWxid
+      ].filter(Boolean) as string[]))
+      let selfAvatarUrl: string | undefined
+      let friendAvatarUrl: string | undefined
+      const avatarResult = await wcdbService.getAvatarUrls(avatarCandidates)
+      if (avatarResult.success && avatarResult.map) {
+        selfAvatarUrl = avatarResult.map[rawWxid] || avatarResult.map[cleanedWxid]
+        friendAvatarUrl = avatarResult.map[friendUsername]
+      }

      this.reportProgress('获取首条聊天记录...', 15, onProgress)
-      const firstRows = await this.getFirstMessages(friendUsername, 3, 0, 0)
+      const firstRows = await this.getFirstMessages(friendUsername, 10, 0, 0)
      let firstChat: DualReportFirstChat | null = null
      if (firstRows.length > 0) {
        const row = firstRows[0]
        const createTime = parseInt(row.create_time || '0', 10) * 1000
-        const content = this.decodeMessageContent(row.message_content, row.compress_content)
+        const rawContent = this.decodeMessageContent(row.message_content, row.compress_content)
+        const localType = this.getRowInt(row, ['local_type', 'localType', 'type', 'msg_type', 'msgType'], 0)
+        let emojiMd5: string | undefined
+        let emojiCdnUrl: string | undefined
+        if (localType === 47) {
+          const stripped = this.stripEmojiOwnerPrefix(rawContent)
+          emojiMd5 = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(row, ['emoji_md5', 'emojiMd5', 'md5']))) || this.extractEmojiMd5(stripped)
+          emojiCdnUrl = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(row, ['emoji_cdn_url', 'emojiCdnUrl', 'cdnurl']))) || this.extractEmojiUrl(stripped)
+        }
+
        firstChat = {
          createTime,
          createTimeStr: this.formatDateTime(createTime),
-          content: String(content || ''),
+          content: String(rawContent || ''),
          isSentByMe: this.resolveIsSent(row, rawWxid, cleanedWxid),
-          senderUsername: row.sender_username || row.sender
+          senderUsername: row.sender_username || row.sender,
+          localType,
+          emojiMd5,
+          emojiCdnUrl
        }
      }
      const firstChatMessages: DualReportMessage[] = firstRows.map((row) => {
        const msgTime = parseInt(row.create_time || '0', 10) * 1000
-        const msgContent = this.decodeMessageContent(row.message_content, row.compress_content)
+        const rawContent = this.decodeMessageContent(row.message_content, row.compress_content)
+        const localType = this.getRowInt(row, ['local_type', 'localType', 'type', 'msg_type', 'msgType'], 0)
+        let emojiMd5: string | undefined
+        let emojiCdnUrl: string | undefined
+        if (localType === 47) {
+          const stripped = this.stripEmojiOwnerPrefix(rawContent)
+          emojiMd5 = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(row, ['emoji_md5', 'emojiMd5', 'md5']))) || this.extractEmojiMd5(stripped)
+          emojiCdnUrl = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(row, ['emoji_cdn_url', 'emojiCdnUrl', 'cdnurl']))) || this.extractEmojiUrl(stripped)
+        }
+
        return {
-          content: String(msgContent || ''),
+          content: String(rawContent || ''),
          isSentByMe: this.resolveIsSent(row, rawWxid, cleanedWxid),
          createTime: msgTime,
-          createTimeStr: this.formatDateTime(msgTime)
+          createTimeStr: this.formatDateTime(msgTime),
+          localType,
+          emojiMd5,
+          emojiCdnUrl
        }
      })

      let yearFirstChat: DualReportData['yearFirstChat'] = null
      if (!isAllTime) {
        this.reportProgress('获取今年首次聊天...', 20, onProgress)
-        const firstYearRows = await this.getFirstMessages(friendUsername, 3, startTime, endTime)
+        const firstYearRows = await this.getFirstMessages(friendUsername, 10, startTime, endTime)
        if (firstYearRows.length > 0) {
          const firstRow = firstYearRows[0]
          const createTime = parseInt(firstRow.create_time || '0', 10) * 1000
          const firstThreeMessages: DualReportMessage[] = firstYearRows.map((row) => {
            const msgTime = parseInt(row.create_time || '0', 10) * 1000
-            const msgContent = this.decodeMessageContent(row.message_content, row.compress_content)
+            const rawContent = this.decodeMessageContent(row.message_content, row.compress_content)
+            const localType = this.getRowInt(row, ['local_type', 'localType', 'type', 'msg_type', 'msgType'], 0)
+            let emojiMd5: string | undefined
+            let emojiCdnUrl: string | undefined
+            if (localType === 47) {
+              const stripped = this.stripEmojiOwnerPrefix(rawContent)
+              emojiMd5 = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(row, ['emoji_md5', 'emojiMd5', 'md5']))) || this.extractEmojiMd5(stripped)
+              emojiCdnUrl = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(row, ['emoji_cdn_url', 'emojiCdnUrl', 'cdnurl']))) || this.extractEmojiUrl(stripped)
+            }
+
            return {
-              content: String(msgContent || ''),
+              content: String(rawContent || ''),
              isSentByMe: this.resolveIsSent(row, rawWxid, cleanedWxid),
              createTime: msgTime,
-              createTimeStr: this.formatDateTime(msgTime)
+              createTimeStr: this.formatDateTime(msgTime),
+              localType,
+              emojiMd5,
+              emojiCdnUrl
            }
          })
+          const firstRowYear = firstYearRows[0]
+          const rawContentYear = this.decodeMessageContent(firstRowYear.message_content, firstRowYear.compress_content)
+          const localTypeYear = this.getRowInt(firstRowYear, ['local_type', 'localType', 'type', 'msg_type', 'msgType'], 0)
+          let emojiMd5Year: string | undefined
+          let emojiCdnUrlYear: string | undefined
+          if (localTypeYear === 47) {
+            const stripped = this.stripEmojiOwnerPrefix(rawContentYear)
+            emojiMd5Year = this.normalizeEmojiMd5(this.coerceString(this.getRecordField(firstRowYear, ['emoji_md5', 'emojiMd5', 'md5']))) || this.extractEmojiMd5(stripped)
+            emojiCdnUrlYear = this.normalizeEmojiUrl(this.coerceString(this.getRecordField(firstRowYear, ['emoji_cdn_url', 'emojiCdnUrl', 'cdnurl']))) || this.extractEmojiUrl(stripped)
+          }
+
          yearFirstChat = {
            createTime,
            createTimeStr: this.formatDateTime(createTime),
-            content: String(this.decodeMessageContent(firstRow.message_content, firstRow.compress_content) || ''),
-            isSentByMe: this.resolveIsSent(firstRow, rawWxid, cleanedWxid),
+            content: String(rawContentYear || ''),
+            isSentByMe: this.resolveIsSent(firstRowYear, rawWxid, cleanedWxid),
            friendName,
-            firstThreeMessages
+            firstThreeMessages,
+            localType: localTypeYear,
+            emojiMd5: emojiMd5Year,
+            emojiCdnUrl: emojiCdnUrlYear
          }
        }
      }

      this.reportProgress('统计聊天数据...', 30, onProgress)
+
+      const statsResult = await wcdbService.getDualReportStats(friendUsername, startTime, endTime)
+      if (!statsResult.success || !statsResult.data) {
+        return { success: false, error: statsResult.error || '获取双人报告统计失败' }
+      }
+
+      const cppData = statsResult.data
+      const counts = cppData.counts || {}
+
      const stats: DualReportStats = {
-        totalMessages: 0,
-        totalWords: 0,
-        imageCount: 0,
-        voiceCount: 0,
-        emojiCount: 0
-      }
-      const wordCountMap = new Map<string, number>()
-      const myEmojiCounts = new Map<string, number>()
-      const friendEmojiCounts = new Map<string, number>()
-      const myEmojiUrlMap = new Map<string, string>()
-      const friendEmojiUrlMap = new Map<string, string>()
-
-      const messageCountResult = await wcdbService.getMessageCount(friendUsername)
-      const totalForProgress = messageCountResult.success && messageCountResult.count
-        ? messageCountResult.count
-        : 0
-      let processed = 0
-      let lastProgressAt = 0
-
-      const cursorResult = await wcdbService.openMessageCursor(friendUsername, 1000, true, startTime, endTime)
-      if (!cursorResult.success || !cursorResult.cursor) {
-        return { success: false, error: cursorResult.error || '打开消息游标失败' }
+        totalMessages: counts.total || 0,
+        totalWords: counts.words || 0,
+        imageCount: counts.image || 0,
+        voiceCount: counts.voice || 0,
+        emojiCount: counts.emoji || 0
      }

-      try {
-        let hasMore = true
-        while (hasMore) {
-          const batch = await wcdbService.fetchMessageBatch(cursorResult.cursor)
-          if (!batch.success || !batch.rows) break
-          for (const row of batch.rows) {
-            const localType = parseInt(row.local_type || row.type || '1', 10)
-            const isSent = this.resolveIsSent(row, rawWxid, cleanedWxid)
-            stats.totalMessages += 1
+      // Process Emojis to find top for me and friend
+      let myTopEmojiMd5: string | undefined
+      let myTopEmojiUrl: string | undefined
+      let myTopCount = -1

-            if (localType === 3) stats.imageCount += 1
-            if (localType === 34) stats.voiceCount += 1
-            if (localType === 47) {
-              stats.emojiCount += 1
-              const content = this.decodeMessageContent(row.message_content, row.compress_content)
-              const md5 = this.extractEmojiMd5(content)
-              const url = this.extractEmojiUrl(content)
-              if (md5) {
-                const targetMap = isSent ? myEmojiCounts : friendEmojiCounts
-                targetMap.set(md5, (targetMap.get(md5) || 0) + 1)
-                if (url) {
-                  const urlMap = isSent ? myEmojiUrlMap : friendEmojiUrlMap
-                  if (!urlMap.has(md5)) urlMap.set(md5, url)
-                }
-              }
-            }
+      let friendTopEmojiMd5: string | undefined
+      let friendTopEmojiUrl: string | undefined
+      let friendTopCount = -1

-            if (localType === 1 || localType === 244813135921) {
-              const content = this.decodeMessageContent(row.message_content, row.compress_content)
-              const text = String(content || '').trim()
-              if (text.length > 0) {
-                stats.totalWords += text.replace(/\s+/g, '').length
-                const normalized = text.replace(/\s+/g, ' ').trim()
-                if (normalized.length >= 2 &&
-                  normalized.length <= 50 &&
-                  !normalized.includes('http') &&
-                  !normalized.includes('<') &&
-                  !normalized.startsWith('[') &&
-                  !normalized.startsWith('<?xml')) {
-                  wordCountMap.set(normalized, (wordCountMap.get(normalized) || 0) + 1)
-                }
-              }
-            }
+      if (cppData.emojis && Array.isArray(cppData.emojis)) {
+        for (const item of cppData.emojis) {
+          const candidate = this.parseEmojiCandidate(item)
+          if (!candidate.md5 || candidate.isMe === undefined || candidate.count <= 0) continue

-            if (totalForProgress > 0) {
-              processed++
+          if (candidate.isMe) {
+            if (candidate.count > myTopCount) {
+              myTopCount = candidate.count
+              myTopEmojiMd5 = candidate.md5
+              myTopEmojiUrl = candidate.url
            }
-          }
-          hasMore = batch.hasMore === true
-
-          const now = Date.now()
-          if (now - lastProgressAt > 200) {
-            if (totalForProgress > 0) {
-              const ratio = Math.min(1, processed / totalForProgress)
-              const progress = 30 + Math.floor(ratio * 50)
-              this.reportProgress('统计聊天数据...', progress, onProgress)
-            }
-            lastProgressAt = now
+          } else if (candidate.count > friendTopCount) {
+            friendTopCount = candidate.count
+            friendTopEmojiMd5 = candidate.md5
+            friendTopEmojiUrl = candidate.url
          }
        }
-      } finally {
-        await wcdbService.closeMessageCursor(cursorResult.cursor)
      }

-      const pickTop = (map: Map<string, number>): string | undefined => {
-        let topKey: string | undefined
-        let topCount = -1
-        for (const [key, count] of map.entries()) {
-          if (count > topCount) {
-            topCount = count
-            topKey = key
-          }
+      const needsEmojiFallback = stats.emojiCount > 0 && (!myTopEmojiMd5 || !friendTopEmojiMd5)
+      if (needsEmojiFallback) {
+        const fallback = await this.scanEmojiTopFallback(friendUsername, startTime, endTime, rawWxid, cleanedWxid)
+
+        if (!myTopEmojiMd5 && fallback.my?.md5) {
+          myTopEmojiMd5 = fallback.my.md5
+          myTopEmojiUrl = myTopEmojiUrl || fallback.my.url
+          myTopCount = fallback.my.count
+        }
+        if (!friendTopEmojiMd5 && fallback.friend?.md5) {
+          friendTopEmojiMd5 = fallback.friend.md5
+          friendTopEmojiUrl = friendTopEmojiUrl || fallback.friend.url
+          friendTopCount = fallback.friend.count
        }
-        return topKey
      }

-      const myTopEmojiMd5 = pickTop(myEmojiCounts)
-      const friendTopEmojiMd5 = pickTop(friendEmojiCounts)
+      const [myEmojiUrlResult, friendEmojiUrlResult] = await Promise.all([
+        myTopEmojiMd5 && !myTopEmojiUrl ? wcdbService.getEmoticonCdnUrl(dbPath, myTopEmojiMd5) : Promise.resolve(null),
+        friendTopEmojiMd5 && !friendTopEmojiUrl ? wcdbService.getEmoticonCdnUrl(dbPath, friendTopEmojiMd5) : Promise.resolve(null)
+      ])
+      if (myEmojiUrlResult?.success && myEmojiUrlResult.url) myTopEmojiUrl = myEmojiUrlResult.url
+      if (friendEmojiUrlResult?.success && friendEmojiUrlResult.url) friendTopEmojiUrl = friendEmojiUrlResult.url

      stats.myTopEmojiMd5 = myTopEmojiMd5
+      stats.myTopEmojiUrl = myTopEmojiUrl
      stats.friendTopEmojiMd5 = friendTopEmojiMd5
-      stats.myTopEmojiUrl = myTopEmojiMd5 ? myEmojiUrlMap.get(myTopEmojiMd5) : undefined
-      stats.friendTopEmojiUrl = friendTopEmojiMd5 ? friendEmojiUrlMap.get(friendTopEmojiMd5) : undefined
+      stats.friendTopEmojiUrl = friendTopEmojiUrl
+      if (myTopCount >= 0) stats.myTopEmojiCount = myTopCount
+      if (friendTopCount >= 0) stats.friendTopEmojiCount = friendTopCount

-      this.reportProgress('生成常用语词云...', 85, onProgress)
-      const topPhrases = Array.from(wordCountMap.entries())
-        .filter(([_, count]) => count >= 2)
-        .sort((a, b) => b[1] - a[1])
-        .slice(0, 50)
-        .map(([phrase, count]) => ({ phrase, count }))
+      const topPhrases = (cppData.phrases || []).map((p: any) => ({
+        phrase: p.phrase,
+        count: p.count
+      }))

      const reportData: DualReportData = {
        year: reportYear,
        selfName: myName,
+        selfAvatarUrl,
        friendUsername,
        friendName,
+        friendAvatarUrl,
        firstChat,
        firstChatMessages,
        yearFirstChat,
        stats,
-        topPhrases
-      }
+        topPhrases,
+        heatmap: cppData.heatmap,
+        initiative: cppData.initiative,
+        response: cppData.response,
+        monthly: cppData.monthly,
+        streak: cppData.streak
+      } as any

      this.reportProgress('双人报告生成完成', 100, onProgress)
      return { success: true, data: reportData }
--- a/electron/services/exportService.ts
+++ b/electron/services/exportService.ts
@@ -68,7 +68,7 @@ const MESSAGE_TYPE_MAP: Record<number, number> = {
 }

 export interface ExportOptions {
-  format: 'chatlab' | 'chatlab-jsonl' | 'json' | 'html' | 'txt' | 'excel' | 'sql'
+  format: 'chatlab' | 'chatlab-jsonl' | 'json' | 'html' | 'txt' | 'excel' | 'weclone' | 'sql'
  dateRange?: { start: number; end: number } | null
  exportMedia?: boolean
  exportAvatars?: boolean
@@ -811,6 +811,55 @@ class ExportService {
    return content.replace(/^[\s]*([a-zA-Z0-9_-]+):(?!\/\/)/, '')
  }

+  private getWeCloneTypeName(localType: number, content: string): string {
+    if (localType === 1) return 'text'
+    if (localType === 3) return 'image'
+    if (localType === 47) return 'sticker'
+    if (localType === 43) return 'video'
+    if (localType === 34) return 'voice'
+    if (localType === 48) return 'location'
+    if (localType === 49) {
+      const xmlType = this.extractXmlValue(content || '', 'type')
+      if (xmlType === '6') return 'file'
+      return 'text'
+    }
+    return 'text'
+  }
+
+  private getWeCloneSource(msg: any, typeName: string, mediaItem: MediaExportItem | null): string {
+    if (mediaItem?.relativePath) {
+      return mediaItem.relativePath
+    }
+
+    if (typeName === 'image') {
+      return msg.imageDatName || ''
+    }
+    if (typeName === 'sticker') {
+      return msg.emojiCdnUrl || ''
+    }
+    if (typeName === 'video') {
+      return ''
+    }
+    if (typeName === 'file') {
+      const xml = msg.content || ''
+      return this.extractXmlValue(xml, 'filename') || this.extractXmlValue(xml, 'title') || ''
+    }
+    return ''
+  }
+
+  private escapeCsvCell(value: unknown): string {
+    if (value === null || value === undefined) return ''
+    const text = String(value)
+    if (/[",\r\n]/.test(text)) {
+      return `"${text.replace(/"/g, '""')}"`
+    }
+    return text
+  }
+
+  private formatIsoTimestamp(timestamp: number): string {
+    return new Date(timestamp * 1000).toISOString()
+  }
+
  /**
   * 从撤回消息内容中提取撤回者的 wxid
   * 撤回消息 XML 格式通常包含 <session> 或 <newmsgid> 等字段
@@ -3577,6 +3626,253 @@ class ExportService {
    }
  }

+  /**
+   * 导出单个会话为 WeClone CSV 格式
+   */
+  async exportSessionToWeCloneCsv(
+    sessionId: string,
+    outputPath: string,
+    options: ExportOptions,
+    onProgress?: (progress: ExportProgress) => void
+  ): Promise<{ success: boolean; error?: string }> {
+    try {
+      const conn = await this.ensureConnected()
+      if (!conn.success || !conn.cleanedWxid) return { success: false, error: conn.error }
+
+      const cleanedMyWxid = conn.cleanedWxid
+      const isGroup = sessionId.includes('@chatroom')
+      const sessionInfo = await this.getContactInfo(sessionId)
+      const myInfo = await this.getContactInfo(cleanedMyWxid)
+
+      const contactCache = new Map<string, { success: boolean; contact?: any; error?: string }>()
+      const getContactCached = async (username: string) => {
+        if (contactCache.has(username)) {
+          return contactCache.get(username)!
+        }
+        const result = await wcdbService.getContact(username)
+        contactCache.set(username, result)
+        return result
+      }
+
+      onProgress?.({
+        current: 0,
+        total: 100,
+        currentSession: sessionInfo.displayName,
+        phase: 'preparing'
+      })
+
+      const collected = await this.collectMessages(sessionId, cleanedMyWxid, options.dateRange)
+      if (collected.rows.length === 0) {
+        return { success: false, error: '该会话在指定时间范围内没有消息' }
+      }
+
+      const senderUsernames = new Set<string>()
+      for (const msg of collected.rows) {
+        if (msg.senderUsername) senderUsernames.add(msg.senderUsername)
+      }
+      senderUsernames.add(sessionId)
+      await this.preloadContacts(senderUsernames, contactCache)
+
+      const groupNicknameCandidates = isGroup
+        ? this.buildGroupNicknameIdCandidates([
+          ...Array.from(senderUsernames.values()),
+          ...collected.rows.map(msg => msg.senderUsername),
+          cleanedMyWxid
+        ])
+        : []
+      const groupNicknamesMap = isGroup
+        ? await this.getGroupNicknamesForRoom(sessionId, groupNicknameCandidates)
+        : new Map<string, string>()
+
+      const sortedMessages = collected.rows.sort((a, b) => a.createTime - b.createTime)
+
+      const voiceMessages = options.exportVoiceAsText
+        ? sortedMessages.filter(msg => msg.localType === 34)
+        : []
+
+      if (options.exportVoiceAsText && voiceMessages.length > 0) {
+        await this.ensureVoiceModel(onProgress)
+      }
+
+      const { exportMediaEnabled, mediaRootDir, mediaRelativePrefix } = this.getMediaLayout(outputPath, options)
+      const mediaMessages = exportMediaEnabled
+        ? sortedMessages.filter(msg => {
+          const t = msg.localType
+          return (t === 3 && options.exportImages) ||
+            (t === 47 && options.exportEmojis) ||
+            (t === 43 && options.exportVideos) ||
+            (t === 34 && options.exportVoices)
+        })
+        : []
+
+      const mediaCache = new Map<string, MediaExportItem | null>()
+
+      if (mediaMessages.length > 0) {
+        onProgress?.({
+          current: 25,
+          total: 100,
+          currentSession: sessionInfo.displayName,
+          phase: 'exporting-media',
+          phaseProgress: 0,
+          phaseTotal: mediaMessages.length,
+          phaseLabel: `导出媒体 0/${mediaMessages.length}`
+        })
+
+        const mediaConcurrency = this.getClampedConcurrency(options.exportConcurrency)
+        let mediaExported = 0
+        await parallelLimit(mediaMessages, mediaConcurrency, async (msg) => {
+          const mediaKey = `${msg.localType}_${msg.localId}`
+          if (!mediaCache.has(mediaKey)) {
+            const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, {
+              exportImages: options.exportImages,
+              exportVoices: options.exportVoices,
+              exportVideos: options.exportVideos,
+              exportEmojis: options.exportEmojis,
+              exportVoiceAsText: options.exportVoiceAsText
+            })
+            mediaCache.set(mediaKey, mediaItem)
+          }
+          mediaExported++
+          if (mediaExported % 5 === 0 || mediaExported === mediaMessages.length) {
+            onProgress?.({
+              current: 25,
+              total: 100,
+              currentSession: sessionInfo.displayName,
+              phase: 'exporting-media',
+              phaseProgress: mediaExported,
+              phaseTotal: mediaMessages.length,
+              phaseLabel: `导出媒体 ${mediaExported}/${mediaMessages.length}`
+            })
+          }
+        })
+      }
+
+      const voiceTranscriptMap = new Map<number, string>()
+
+      if (voiceMessages.length > 0) {
+        onProgress?.({
+          current: 45,
+          total: 100,
+          currentSession: sessionInfo.displayName,
+          phase: 'exporting-voice',
+          phaseProgress: 0,
+          phaseTotal: voiceMessages.length,
+          phaseLabel: `语音转文字 0/${voiceMessages.length}`
+        })
+
+        const VOICE_CONCURRENCY = 4
+        let voiceTranscribed = 0
+        await parallelLimit(voiceMessages, VOICE_CONCURRENCY, async (msg) => {
+          const transcript = await this.transcribeVoice(sessionId, String(msg.localId), msg.createTime, msg.senderUsername)
+          voiceTranscriptMap.set(msg.localId, transcript)
+          voiceTranscribed++
+          onProgress?.({
+            current: 45,
+            total: 100,
+            currentSession: sessionInfo.displayName,
+            phase: 'exporting-voice',
+            phaseProgress: voiceTranscribed,
+            phaseTotal: voiceMessages.length,
+            phaseLabel: `语音转文字 ${voiceTranscribed}/${voiceMessages.length}`
+          })
+        })
+      }
+
+      onProgress?.({
+        current: 60,
+        total: 100,
+        currentSession: sessionInfo.displayName,
+        phase: 'exporting'
+      })
+
+      const lines: string[] = []
+      lines.push('id,MsgSvrID,type_name,is_sender,talker,msg,src,CreateTime')
+
+      for (let i = 0; i < sortedMessages.length; i++) {
+        const msg = sortedMessages[i]
+        const mediaKey = `${msg.localType}_${msg.localId}`
+        const mediaItem = mediaCache.get(mediaKey) || null
+
+        const typeName = this.getWeCloneTypeName(msg.localType, msg.content || '')
+        let senderWxid = cleanedMyWxid
+        if (!msg.isSend) {
+          senderWxid = isGroup && msg.senderUsername
+            ? msg.senderUsername
+            : sessionId
+        }
+
+        let talker = myInfo.displayName || '我'
+        if (!msg.isSend) {
+          const contactDetail = await getContactCached(senderWxid)
+          const senderNickname = contactDetail.success && contactDetail.contact
+            ? (contactDetail.contact.nickName || senderWxid)
+            : senderWxid
+          const senderRemark = contactDetail.success && contactDetail.contact
+            ? (contactDetail.contact.remark || '')
+            : ''
+          const senderGroupNickname = isGroup
+            ? this.resolveGroupNicknameByCandidates(groupNicknamesMap, [senderWxid])
+            : ''
+          talker = this.getPreferredDisplayName(
+            senderWxid,
+            senderNickname,
+            senderRemark,
+            senderGroupNickname,
+            options.displayNamePreference || 'remark'
+          )
+        }
+
+        const msgText = msg.localType === 34 && options.exportVoiceAsText
+          ? (voiceTranscriptMap.get(msg.localId) || '[语音消息 - 转文字失败]')
+          : (this.parseMessageContent(msg.content, msg.localType, sessionId, msg.createTime) || '')
+        const src = this.getWeCloneSource(msg, typeName, mediaItem)
+
+        const row = [
+          i + 1,
+          i + 1,
+          typeName,
+          msg.isSend ? 1 : 0,
+          talker,
+          msgText,
+          src,
+          this.formatIsoTimestamp(msg.createTime)
+        ]
+
+        lines.push(row.map((value) => this.escapeCsvCell(value)).join(','))
+
+        if ((i + 1) % 200 === 0) {
+          const progress = 60 + Math.floor((i + 1) / sortedMessages.length * 30)
+          onProgress?.({
+            current: progress,
+            total: 100,
+            currentSession: sessionInfo.displayName,
+            phase: 'exporting'
+          })
+        }
+      }
+
+      onProgress?.({
+        current: 92,
+        total: 100,
+        currentSession: sessionInfo.displayName,
+        phase: 'writing'
+      })
+
+      fs.writeFileSync(outputPath, `\uFEFF${lines.join('\r\n')}`, 'utf-8')
+
+      onProgress?.({
+        current: 100,
+        total: 100,
+        currentSession: sessionInfo.displayName,
+        phase: 'complete'
+      })
+
+      return { success: true }
+    } catch (e) {
+      return { success: false, error: String(e) }
+    }
+  }
+
  private getVirtualScrollScript(): string {
    return `
      class ChunkedRenderer {
@@ -4228,6 +4524,7 @@ class ExportService {
        if (options.format === 'chatlab-jsonl') ext = '.jsonl'
        else if (options.format === 'excel') ext = '.xlsx'
        else if (options.format === 'txt') ext = '.txt'
+        else if (options.format === 'weclone') ext = '.csv'
        else if (options.format === 'html') ext = '.html'
        const outputPath = path.join(sessionDir, `${safeName}${ext}`)

@@ -4240,6 +4537,8 @@ class ExportService {
          result = await this.exportSessionToExcel(sessionId, outputPath, options, sessionProgress)
        } else if (options.format === 'txt') {
          result = await this.exportSessionToTxt(sessionId, outputPath, options, sessionProgress)
+        } else if (options.format === 'weclone') {
+          result = await this.exportSessionToWeCloneCsv(sessionId, outputPath, options, sessionProgress)
        } else if (options.format === 'html') {
          result = await this.exportSessionToHtml(sessionId, outputPath, options, sessionProgress)
        } else {
--- a/electron/services/wcdbCore.ts
+++ b/electron/services/wcdbCore.ts
@@ -44,6 +44,7 @@ export class WcdbCore {
  private wcdbGetAvailableYears: any = null
  private wcdbGetAnnualReportStats: any = null
  private wcdbGetAnnualReportExtras: any = null
+  private wcdbGetDualReportStats: any = null
  private wcdbGetGroupStats: any = null
  private wcdbOpenMessageCursor: any = null
  private wcdbOpenMessageCursorLite: any = null
@@ -456,6 +457,13 @@ export class WcdbCore {
        this.wcdbGetAnnualReportExtras = null
      }

+      // wcdb_status wcdb_get_dual_report_stats(wcdb_handle handle, const char* session_id, int32_t begin_timestamp, int32_t end_timestamp, char** out_json)
+      try {
+        this.wcdbGetDualReportStats = this.lib.func('int32 wcdb_get_dual_report_stats(int64 handle, const char* sessionId, int32 begin, int32 end, _Out_ void** outJson)')
+      } catch {
+        this.wcdbGetDualReportStats = null
+      }
+
      // wcdb_status wcdb_get_logs(char** out_json)
      try {
        this.wcdbGetLogs = this.lib.func('int32 wcdb_get_logs(_Out_ void** outJson)')
@@ -1710,4 +1718,26 @@ export class WcdbCore {
      return { success: false, error: String(e) }
    }
  }
+  async getDualReportStats(sessionId: string, beginTimestamp: number = 0, endTimestamp: number = 0): Promise<{ success: boolean; data?: any; error?: string }> {
+    if (!this.ensureReady()) {
+      return { success: false, error: 'WCDB 未连接' }
+    }
+    if (!this.wcdbGetDualReportStats) {
+      return { success: false, error: '未支持双人报告统计' }
+    }
+    try {
+      const { begin, end } = this.normalizeRange(beginTimestamp, endTimestamp)
+      const outPtr = [null as any]
+      const result = this.wcdbGetDualReportStats(this.handle, sessionId, begin, end, outPtr)
+      if (result !== 0 || !outPtr[0]) {
+        return { success: false, error: `获取双人报告统计失败: ${result}` }
+      }
+      const jsonStr = this.decodeJsonPtr(outPtr[0])
+      if (!jsonStr) return { success: false, error: '解析双人报告统计失败' }
+      const data = JSON.parse(jsonStr)
+      return { success: true, data }
+    } catch (e) {
+      return { success: false, error: String(e) }
+    }
+  }
 }
--- a/electron/services/wcdbService.ts
+++ b/electron/services/wcdbService.ts
@@ -315,6 +315,13 @@ export class WcdbService {
    return this.callWorker('getAnnualReportExtras', { sessionIds, beginTimestamp, endTimestamp, peakDayBegin, peakDayEnd })
  }

+  /**
+   * 获取双人报告统计数据
+   */
+  async getDualReportStats(sessionId: string, beginTimestamp: number, endTimestamp: number): Promise<{ success: boolean; data?: any; error?: string }> {
+    return this.callWorker('getDualReportStats', { sessionId, beginTimestamp, endTimestamp })
+  }
+
  /**
   * 获取群聊统计
   */
--- a/electron/wcdbWorker.ts
+++ b/electron/wcdbWorker.ts
@@ -96,6 +96,9 @@ if (parentPort) {
                case 'getAnnualReportExtras':
                    result = await core.getAnnualReportExtras(payload.sessionIds, payload.beginTimestamp, payload.endTimestamp, payload.peakDayBegin, payload.peakDayEnd)
                    break
+                case 'getDualReportStats':
+                    result = await core.getDualReportStats(payload.sessionId, payload.beginTimestamp, payload.endTimestamp)
+                    break
                case 'getGroupStats':
                    result = await core.getGroupStats(payload.chatroomId, payload.beginTimestamp, payload.endTimestamp)
                    break
--- a/resources/wcdb_api.dll
+++ b/resources/wcdb_api.dll
--- a/src/components/BatchTranscribeGlobal.tsx
+++ b/src/components/BatchTranscribeGlobal.tsx
@@ -1,6 +1,6 @@
-import React from 'react'
+import React, { useEffect, useState } from 'react'
 import { createPortal } from 'react-dom'
-import { Loader2, X, CheckCircle, XCircle, AlertCircle } from 'lucide-react'
+import { Loader2, X, CheckCircle, XCircle, AlertCircle, Clock } from 'lucide-react'
 import { useBatchTranscribeStore } from '../stores/batchTranscribeStore'
 import '../styles/batchTranscribe.scss'

@@ -16,10 +16,46 @@ export const BatchTranscribeGlobal: React.FC = () => {
    showResult,
    result,
    sessionName,
+    startTime,
    setShowToast,
    setShowResult
  } = useBatchTranscribeStore()

+  const [eta, setEta] = useState<string>('')
+
+  // 计算剩余时间
+  useEffect(() => {
+    if (!isBatchTranscribing || !startTime || progress.current === 0) {
+      setEta('')
+      return
+    }
+
+    const timer = setInterval(() => {
+      const now = Date.now()
+      const elapsed = now - startTime
+      const rate = progress.current / elapsed // ms per item
+      const remainingItems = progress.total - progress.current
+
+      if (remainingItems <= 0) {
+        setEta('')
+        return
+      }
+
+      const remainingTimeMs = remainingItems / rate
+      const remainingSeconds = Math.ceil(remainingTimeMs / 1000)
+
+      if (remainingSeconds < 60) {
+        setEta(`${remainingSeconds}秒`)
+      } else {
+        const minutes = Math.floor(remainingSeconds / 60)
+        const seconds = remainingSeconds % 60
+        setEta(`${minutes}分${seconds}秒`)
+      }
+    }, 1000)
+
+    return () => clearInterval(timer)
+  }, [isBatchTranscribing, startTime, progress.current, progress.total])
+
  return (
    <>
      {/* 批量转写进度浮窗（非阻塞） */}
@@ -35,14 +71,23 @@ export const BatchTranscribeGlobal: React.FC = () => {
            </button>
          </div>
          <div className="batch-progress-toast-body">
-            <div className="progress-text">
-              <span>{progress.current} / {progress.total}</span>
-              <span className="progress-percent">
-                {progress.total > 0
-                  ? Math.round((progress.current / progress.total) * 100)
-                  : 0}%
-              </span>
+            <div className="progress-info-row">
+              <div className="progress-text">
+                <span>{progress.current} / {progress.total}</span>
+                <span className="progress-percent">
+                  {progress.total > 0
+                    ? Math.round((progress.current / progress.total) * 100)
+                    : 0}%
+                </span>
+              </div>
+              {eta && (
+                <div className="progress-eta">
+                  <Clock size={12} />
+                  <span>剩余 {eta}</span>
+                </div>
+              )}
            </div>
+
            <div className="progress-bar">
              <div
                className="progress-fill"
--- a/src/components/ReportComponents.scss
+++ b/src/components/ReportComponents.scss
@@ -0,0 +1,142 @@
+// Shared styles for Report components (Heatmap, WordCloud)
+
+// --- Heatmap ---
+.heatmap-wrapper {
+    margin-top: 24px;
+    width: 100%;
+}
+
+.heatmap-header {
+    display: grid;
+    grid-template-columns: 28px 1fr;
+    gap: 3px;
+    margin-bottom: 6px;
+    color: var(--ar-text-sub); // Assumes --ar-text-sub is defined in parent context or globally
+    font-size: 10px;
+}
+
+.time-labels {
+    display: grid;
+    grid-template-columns: repeat(24, 1fr);
+    gap: 3px;
+
+    span {
+        text-align: center;
+    }
+}
+
+.heatmap {
+    display: grid;
+    grid-template-columns: 28px 1fr;
+    gap: 3px;
+}
+
+.heatmap-week-col {
+    display: grid;
+    grid-template-rows: repeat(7, 1fr);
+    gap: 3px;
+    font-size: 10px;
+    color: var(--ar-text-sub);
+}
+
+.week-label {
+    display: flex;
+    align-items: center;
+}
+
+.heatmap-grid {
+    display: grid;
+    grid-template-columns: repeat(24, 1fr);
+    gap: 3px;
+}
+
+.h-cell {
+    aspect-ratio: 1;
+    border-radius: 2px;
+    min-height: 10px;
+    transition: transform 0.15s;
+
+    &:hover {
+        transform: scale(1.3);
+        z-index: 1;
+    }
+}
+
+
+// --- Word Cloud ---
+.word-cloud-wrapper {
+    margin: 24px auto 0;
+    padding: 0;
+    max-width: 520px;
+    display: flex;
+    justify-content: center;
+    --cloud-scale: clamp(0.72, 80vw / 520, 1);
+}
+
+.word-cloud-inner {
+    position: relative;
+    width: 520px;
+    height: 520px;
+    margin: 0;
+    border-radius: 50%;
+    transform: scale(var(--cloud-scale));
+    transform-origin: center;
+
+    &::before {
+        content: "";
+        position: absolute;
+        inset: -6%;
+        background:
+            radial-gradient(circle at 35% 45%, color-mix(in srgb, var(--primary, #07C160) 12%, transparent), transparent 55%),
+            radial-gradient(circle at 65% 50%, color-mix(in srgb, var(--accent, #F2AA00) 10%, transparent), transparent 58%),
+            radial-gradient(circle at 50% 65%, var(--bg-tertiary, rgba(0, 0, 0, 0.04)), transparent 60%);
+        filter: blur(18px);
+        border-radius: 50%;
+        pointer-events: none;
+        z-index: 0;
+    }
+}
+
+.word-tag {
+    display: inline-block;
+    padding: 0;
+    background: transparent;
+    border-radius: 0;
+    border: none;
+    line-height: 1.2;
+    white-space: nowrap;
+    transition: transform 0.2s ease, color 0.2s ease;
+    cursor: default;
+    color: var(--ar-text-main);
+    font-weight: 600;
+    opacity: 0;
+    animation: wordPopIn 0.55s ease forwards;
+    position: absolute;
+    z-index: 1;
+    transform: translate(-50%, -50%) scale(0.8);
+
+    &:hover {
+        transform: translate(-50%, -50%) scale(1.08);
+        color: var(--ar-primary);
+        z-index: 2;
+    }
+}
+
+@keyframes wordPopIn {
+    0% {
+        opacity: 0;
+        transform: translate(-50%, -50%) scale(0.6);
+    }
+
+    100% {
+        opacity: var(--final-opacity, 1);
+        transform: translate(-50%, -50%) scale(1);
+    }
+}
+
+.word-cloud-note {
+    margin-top: 24px;
+    font-size: 14px !important;
+    color: var(--ar-text-sub) !important;
+    text-align: center;
+}
--- a/src/components/ReportHeatmap.tsx
+++ b/src/components/ReportHeatmap.tsx
@@ -0,0 +1,51 @@
+import React from 'react'
+import './ReportComponents.scss'
+
+interface ReportHeatmapProps {
+    data: number[][]
+}
+
+const ReportHeatmap: React.FC<ReportHeatmapProps> = ({ data }) => {
+    if (!data || data.length === 0) return null
+
+    const maxHeat = Math.max(...data.flat())
+    const weekLabels = ['周一', '周二', '周三', '周四', '周五', '周六', '周日']
+
+    return (
+        <div className="heatmap-wrapper">
+            <div className="heatmap-header">
+                <div></div>
+                <div className="time-labels">
+                    {[0, 6, 12, 18].map(h => (
+                        <span key={h} style={{ gridColumn: h + 1 }}>{h}</span>
+                    ))}
+                </div>
+            </div>
+            <div className="heatmap">
+                <div className="heatmap-week-col">
+                    {weekLabels.map(w => <div key={w} className="week-label">{w}</div>)}
+                </div>
+                <div className="heatmap-grid">
+                    {data.map((row, wi) =>
+                        row.map((val, hi) => {
+                            const alpha = maxHeat > 0 ? (val / maxHeat * 0.85 + 0.1).toFixed(2) : '0.1'
+                            return (
+                                <div
+                                    key={`${wi}-${hi}`}
+                                    className="h-cell"
+                                    style={{
+                                        backgroundColor: 'var(--primary)',
+                                        opacity: alpha
+                                    }}
+                                    title={`${weekLabels[wi]} ${hi}:00 - ${val}条`}
+                                />
+                            )
+                        })
+                    )}
+                </div>
+            </div>
+        </div>
+    )
+}
+
+export default ReportHeatmap
--- a/src/components/ReportWordCloud.tsx
+++ b/src/components/ReportWordCloud.tsx
@@ -0,0 +1,113 @@
+import React from 'react'
+import './ReportComponents.scss'
+
+interface ReportWordCloudProps {
+    words: { phrase: string; count: number }[]
+}
+
+const ReportWordCloud: React.FC<ReportWordCloudProps> = ({ words }) => {
+    if (!words || words.length === 0) return null
+
+    const maxCount = words.length > 0 ? words[0].count : 1
+    const topWords = words.slice(0, 32)
+    const baseSize = 520
+
+    // 使用确定性随机数生成器
+    const seededRandom = (seed: number) => {
+        const x = Math.sin(seed) * 10000
+        return x - Math.floor(x)
+    }
+
+    // 计算词云位置
+    const placedItems: { x: number; y: number; w: number; h: number }[] = []
+
+    const canPlace = (x: number, y: number, w: number, h: number): boolean => {
+        const halfW = w / 2
+        const halfH = h / 2
+        const dx = x - 50
+        const dy = y - 50
+        const dist = Math.sqrt(dx * dx + dy * dy)
+        const maxR = 49 - Math.max(halfW, halfH)
+        if (dist > maxR) return false
+
+        const pad = 1.8
+        for (const p of placedItems) {
+            if ((x - halfW - pad) < (p.x + p.w / 2) &&
+                (x + halfW + pad) > (p.x - p.w / 2) &&
+                (y - halfH - pad) < (p.y + p.h / 2) &&
+                (y + halfH + pad) > (p.y - p.h / 2)) {
+                return false
+            }
+        }
+        return true
+    }
+
+    const wordItems = topWords.map((item, i) => {
+        const ratio = item.count / maxCount
+        const fontSize = Math.round(12 + Math.pow(ratio, 0.65) * 20)
+        const opacity = Math.min(1, Math.max(0.35, 0.35 + ratio * 0.65))
+        const delay = (i * 0.04).toFixed(2)
+
+        // 计算词语宽度
+        const charCount = Math.max(1, item.phrase.length)
+        const hasCjk = /[\u4e00-\u9fff]/.test(item.phrase)
+        const hasLatin = /[A-Za-z0-9]/.test(item.phrase)
+        const widthFactor = hasCjk && hasLatin ? 0.85 : hasCjk ? 0.98 : 0.6
+        const widthPx = fontSize * (charCount * widthFactor)
+        const heightPx = fontSize * 1.1
+        const widthPct = (widthPx / baseSize) * 100
+        const heightPct = (heightPx / baseSize) * 100
+
+        // 寻找位置
+        let x = 50, y = 50
+        let placedOk = false
+        const tries = i === 0 ? 1 : 420
+
+        for (let t = 0; t < tries; t++) {
+            if (i === 0) {
+                x = 50
+                y = 50
+            } else {
+                const idx = i + t * 0.28
+                const radius = Math.sqrt(idx) * 7.6 + (seededRandom(i * 1000 + t) * 1.2 - 0.6)
+                const angle = idx * 2.399963 + seededRandom(i * 2000 + t) * 0.35
+                x = 50 + radius * Math.cos(angle)
+                y = 50 + radius * Math.sin(angle)
+            }
+            if (canPlace(x, y, widthPct, heightPct)) {
+                placedOk = true
+                break
+            }
+        }
+
+        if (!placedOk) return null
+        placedItems.push({ x, y, w: widthPct, h: heightPct })
+
+        return (
+            <span
+                key={i}
+                className="word-tag"
+                style={{
+                    '--final-opacity': opacity,
+                    left: `${x.toFixed(2)}%`,
+                    top: `${y.toFixed(2)}%`,
+                    fontSize: `${fontSize}px`,
+                    animationDelay: `${delay}s`,
+                } as React.CSSProperties}
+                title={`${item.phrase} (出现 ${item.count} 次)`}
+            >
+                {item.phrase}
+            </span>
+        )
+    }).filter(Boolean)
+
+    return (
+        <div className="word-cloud-wrapper">
+            <div className="word-cloud-inner">
+                {wordItems}
+            </div>
+        </div>
+    )
+}
+
+export default ReportWordCloud
--- a/src/pages/AnnualReportWindow.scss
+++ b/src/pages/AnnualReportWindow.scss
@@ -43,7 +43,7 @@

 // 背景装饰圆点 - 毛玻璃效果
 .bg-decoration {
-  position: absolute; // Changed from fixed
+  position: absolute;
  inset: 0;
  pointer-events: none;
  z-index: 0;
@@ -53,10 +53,10 @@
 .deco-circle {
  position: absolute;
  border-radius: 50%;
-  background: rgba(0, 0, 0, 0.03);
+  background: color-mix(in srgb, var(--primary) 3%, transparent);
  backdrop-filter: blur(40px);
  -webkit-backdrop-filter: blur(40px);
-  border: 1px solid rgba(0, 0, 0, 0.05);
+  border: 1px solid var(--border-color);

  &.c1 {
    width: 280px;
@@ -243,6 +243,7 @@
 }

 .exporting-snapshot {
+
  .hero-title,
  .label-text,
  .hero-desc,
@@ -1279,134 +1280,135 @@
  color: var(--ar-text-sub) !important;
  text-align: center;
 }
+
 // 曾经的好朋友 视觉效果
 .lost-friend-visual {
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  gap: 32px;
+  margin: 64px auto 48px;
+  position: relative;
+  max-width: 480px;
+
+  .avatar-group {
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    gap: 12px;
+    z-index: 2;
+
+    .avatar-label {
+      font-size: 13px;
+      color: var(--ar-text-sub);
+      font-weight: 500;
+      opacity: 0.6;
+    }
+
+    &.sender {
+      animation: fadeInRight 1s ease-out backwards;
+    }
+
+    &.receiver {
+      animation: fadeInLeft 1s ease-out backwards;
+    }
+  }
+
+  .fading-line {
+    position: relative;
+    flex: 1;
+    height: 2px;
+    min-width: 120px;
    display: flex;
    align-items: center;
    justify-content: center;
-    gap: 32px;
-    margin: 64px auto 48px;
-    position: relative;
-    max-width: 480px;

-    .avatar-group {
-        display: flex;
-        flex-direction: column;
-        align-items: center;
-        gap: 12px;
-        z-index: 2;
-
-        .avatar-label {
-            font-size: 13px;
-            color: var(--ar-text-sub);
-            font-weight: 500;
-            opacity: 0.6;
-        }
-
-        &.sender {
-            animation: fadeInRight 1s ease-out backwards;
-        }
-
-        &.receiver {
-            animation: fadeInLeft 1s ease-out backwards;
-        }
+    .line-path {
+      width: 100%;
+      height: 100%;
+      background: linear-gradient(to right,
+          var(--ar-primary) 0%,
+          rgba(var(--ar-primary-rgb), 0.4) 50%,
+          rgba(var(--ar-primary-rgb), 0.05) 100%);
+      border-radius: 2px;
    }

-    .fading-line {
-        position: relative;
-        flex: 1;
-        height: 2px;
-        min-width: 120px;
-        display: flex;
-        align-items: center;
-        justify-content: center;
-
-        .line-path {
-            width: 100%;
-            height: 100%;
-            background: linear-gradient(to right,
-                    var(--ar-primary) 0%,
-                    rgba(var(--ar-primary-rgb), 0.4) 50%,
-                    rgba(var(--ar-primary-rgb), 0.05) 100%);
-            border-radius: 2px;
-        }
-
-        .line-glow {
-            position: absolute;
-            inset: -4px 0;
-            background: linear-gradient(to right,
-                    rgba(var(--ar-primary-rgb), 0.2) 0%,
-                    transparent 100%);
-            filter: blur(8px);
-            pointer-events: none;
-        }
-
-        .flow-particle {
-            position: absolute;
-            width: 40px;
-            height: 2px;
-            background: linear-gradient(to right, transparent, var(--ar-primary), transparent);
-            border-radius: 2px;
-            opacity: 0;
-            animation: flowAcross 4s infinite linear;
-        }
+    .line-glow {
+      position: absolute;
+      inset: -4px 0;
+      background: linear-gradient(to right,
+          rgba(var(--ar-primary-rgb), 0.2) 0%,
+          transparent 100%);
+      filter: blur(8px);
+      pointer-events: none;
    }
+
+    .flow-particle {
+      position: absolute;
+      width: 40px;
+      height: 2px;
+      background: linear-gradient(to right, transparent, var(--ar-primary), transparent);
+      border-radius: 2px;
+      opacity: 0;
+      animation: flowAcross 4s infinite linear;
+    }
+  }
 }

 .hero-desc.fading {
-    opacity: 0.7;
-    font-style: italic;
-    font-size: 16px;
-    margin-top: 32px;
-    line-height: 1.8;
-    letter-spacing: 0.05em;
-    animation: fadeIn 1.5s ease-out 0.5s backwards;
+  opacity: 0.7;
+  font-style: italic;
+  font-size: 16px;
+  margin-top: 32px;
+  line-height: 1.8;
+  letter-spacing: 0.05em;
+  animation: fadeIn 1.5s ease-out 0.5s backwards;
 }

@keyframes flowAcross {
-    0% {
-        left: -20%;
-        opacity: 0;
-    }
+  0% {
+    left: -20%;
+    opacity: 0;
+  }

-    10% {
-        opacity: 0.8;
-    }
+  10% {
+    opacity: 0.8;
+  }

-    50% {
-        opacity: 0.4;
-    }
+  50% {
+    opacity: 0.4;
+  }

-    90% {
-        opacity: 0.1;
-    }
+  90% {
+    opacity: 0.1;
+  }

-    100% {
-        left: 120%;
-        opacity: 0;
-    }
+  100% {
+    left: 120%;
+    opacity: 0;
+  }
 }

@keyframes fadeInRight {
-    from {
-        opacity: 0;
-        transform: translateX(-20px);
-    }
+  from {
+    opacity: 0;
+    transform: translateX(-20px);
+  }

-    to {
-        opacity: 1;
-        transform: translateX(0);
-    }
+  to {
+    opacity: 1;
+    transform: translateX(0);
+  }
 }

@keyframes fadeInLeft {
-    from {
-        opacity: 0;
-        transform: translateX(20px);
-    }
+  from {
+    opacity: 0;
+    transform: translateX(20px);
+  }

-    to {
-        opacity: 1;
-        transform: translateX(0);
-    }
+  to {
+    opacity: 1;
+    transform: translateX(0);
+  }
 }
--- a/src/pages/AnnualReportWindow.tsx
+++ b/src/pages/AnnualReportWindow.tsx
@@ -109,148 +109,8 @@ const Avatar = ({ url, name, size = 'md' }: { url?: string; name: string; size?:
  )
 }

-// 热力图组件
-const Heatmap = ({ data }: { data: number[][] }) => {
-  const maxHeat = Math.max(...data.flat())
-  const weekLabels = ['周一', '周二', '周三', '周四', '周五', '周六', '周日']
-
-  return (
-    <div className="heatmap-wrapper">
-      <div className="heatmap-header">
-        <div></div>
-        <div className="time-labels">
-          {[0, 6, 12, 18].map(h => (
-            <span key={h} style={{ gridColumn: h + 1 }}>{h}</span>
-          ))}
-        </div>
-      </div>
-      <div className="heatmap">
-        <div className="heatmap-week-col">
-          {weekLabels.map(w => <div key={w} className="week-label">{w}</div>)}
-        </div>
-        <div className="heatmap-grid">
-          {data.map((row, wi) =>
-            row.map((val, hi) => {
-              const alpha = maxHeat > 0 ? (val / maxHeat * 0.85 + 0.1).toFixed(2) : '0.1'
-              return (
-                <div
-                  key={`${wi}-${hi}`}
-                  className="h-cell"
-                  style={{ background: `rgba(7, 193, 96, ${alpha})` }}
-                  title={`${weekLabels[wi]} ${hi}:00 - ${val}条`}
-                />
-              )
-            })
-          )}
-        </div>
-      </div>
-    </div>
-  )
-}
-
-// 词云组件
-const WordCloud = ({ words }: { words: { phrase: string; count: number }[] }) => {
-  const maxCount = words.length > 0 ? words[0].count : 1
-  const topWords = words.slice(0, 32)
-  const baseSize = 520
-
-  // 使用确定性随机数生成器
-  const seededRandom = (seed: number) => {
-    const x = Math.sin(seed) * 10000
-    return x - Math.floor(x)
-  }
-
-  // 计算词云位置
-  const placedItems: { x: number; y: number; w: number; h: number }[] = []
-
-  const canPlace = (x: number, y: number, w: number, h: number): boolean => {
-    const halfW = w / 2
-    const halfH = h / 2
-    const dx = x - 50
-    const dy = y - 50
-    const dist = Math.sqrt(dx * dx + dy * dy)
-    const maxR = 49 - Math.max(halfW, halfH)
-    if (dist > maxR) return false
-
-    const pad = 1.8
-    for (const p of placedItems) {
-      if ((x - halfW - pad) < (p.x + p.w / 2) &&
-        (x + halfW + pad) > (p.x - p.w / 2) &&
-        (y - halfH - pad) < (p.y + p.h / 2) &&
-        (y + halfH + pad) > (p.y - p.h / 2)) {
-        return false
-      }
-    }
-    return true
-  }
-
-  const wordItems = topWords.map((item, i) => {
-    const ratio = item.count / maxCount
-    const fontSize = Math.round(12 + Math.pow(ratio, 0.65) * 20)
-    const opacity = Math.min(1, Math.max(0.35, 0.35 + ratio * 0.65))
-    const delay = (i * 0.04).toFixed(2)
-
-    // 计算词语宽度
-    const charCount = Math.max(1, item.phrase.length)
-    const hasCjk = /[\u4e00-\u9fff]/.test(item.phrase)
-    const hasLatin = /[A-Za-z0-9]/.test(item.phrase)
-    const widthFactor = hasCjk && hasLatin ? 0.85 : hasCjk ? 0.98 : 0.6
-    const widthPx = fontSize * (charCount * widthFactor)
-    const heightPx = fontSize * 1.1
-    const widthPct = (widthPx / baseSize) * 100
-    const heightPct = (heightPx / baseSize) * 100
-
-    // 寻找位置
-    let x = 50, y = 50
-    let placedOk = false
-    const tries = i === 0 ? 1 : 420
-
-    for (let t = 0; t < tries; t++) {
-      if (i === 0) {
-        x = 50
-        y = 50
-      } else {
-        const idx = i + t * 0.28
-        const radius = Math.sqrt(idx) * 7.6 + (seededRandom(i * 1000 + t) * 1.2 - 0.6)
-        const angle = idx * 2.399963 + seededRandom(i * 2000 + t) * 0.35
-        x = 50 + radius * Math.cos(angle)
-        y = 50 + radius * Math.sin(angle)
-      }
-      if (canPlace(x, y, widthPct, heightPct)) {
-        placedOk = true
-        break
-      }
-    }
-
-    if (!placedOk) return null
-    placedItems.push({ x, y, w: widthPct, h: heightPct })
-
-    return (
-      <span
-        key={i}
-        className="word-tag"
-        style={{
-          '--final-opacity': opacity,
-          left: `${x.toFixed(2)}%`,
-          top: `${y.toFixed(2)}%`,
-          fontSize: `${fontSize}px`,
-          animationDelay: `${delay}s`,
-        } as React.CSSProperties}
-        title={`${item.phrase} (出现 ${item.count} 次)`}
-      >
-        {item.phrase}
-      </span>
-    )
-  }).filter(Boolean)
-
-  return (
-    <div className="word-cloud-wrapper">
-      <div className="word-cloud-inner">
-        {wordItems}
-      </div>
-    </div>
-  )
-}
+import Heatmap from '../components/ReportHeatmap'
+import WordCloud from '../components/ReportWordCloud'

 function AnnualReportWindow() {
  const [reportData, setReportData] = useState<AnnualReportData | null>(null)
--- a/src/pages/ChatPage.tsx
+++ b/src/pages/ChatPage.tsx
@@ -1311,7 +1311,7 @@ function ChatPage(_props: ChatPageProps) {
    let successCount = 0
    let failCount = 0
    let completedCount = 0
-    const concurrency = 3
+    const concurrency = 10

    const transcribeOne = async (msg: Message) => {
      try {
--- a/src/pages/DualReportPage.scss
+++ b/src/pages/DualReportPage.scss
@@ -132,26 +132,43 @@
 .info {
  display: flex;
  flex-direction: column;
-  gap: 4px;
+  gap: 2px;
+  min-width: 0; // 允许 flex 子项缩小，配合 ellipsis

  .name {
+    font-size: 15px;
    font-weight: 600;
+    color: var(--text-primary);
+    white-space: nowrap;
+    overflow: hidden;
+    text-overflow: ellipsis;
  }

  .sub {
    font-size: 12px;
-    color: var(--text-tertiary);
+    color: var(--text-secondary); // 从 tertiary 改为 secondary 以增强对比度
+    white-space: nowrap;
+    overflow: hidden;
+    text-overflow: ellipsis;
+    opacity: 0.8;
  }
 }

 .meta {
  text-align: right;
  font-size: 12px;
-  color: var(--text-tertiary);
+  color: var(--text-secondary); // 改为 secondary
+  flex-shrink: 0;

  .count {
-    font-weight: 600;
-    color: var(--text-primary);
+    font-size: 14px;
+    font-weight: 700;
+    color: var(--primary); // 使用主题色更醒目
+    margin-bottom: 2px;
+  }
+
+  .hint {
+    opacity: 0.7;
  }
 }

@@ -166,6 +183,11 @@
 }

@keyframes spin {
-  from { transform: rotate(0deg); }
-  to { transform: rotate(360deg); }
+  from {
+    transform: rotate(0deg);
+  }
+
+  to {
+    transform: rotate(360deg);
+  }
 }
--- a/src/pages/DualReportPage.tsx
+++ b/src/pages/DualReportPage.tsx
@@ -7,6 +7,7 @@ interface ContactRanking {
  username: string
  displayName: string
  avatarUrl?: string
+  wechatId?: string
  messageCount: number
  sentCount: number
  receivedCount: number
@@ -15,28 +16,29 @@ interface ContactRanking {

 function DualReportPage() {
  const navigate = useNavigate()
-  const [year, setYear] = useState<number>(0)
+  const [year] = useState<number>(() => {
+    const params = new URLSearchParams(window.location.hash.split('?')[1] || '')
+    const yearParam = params.get('year')
+    const parsedYear = yearParam ? parseInt(yearParam, 10) : 0
+    return Number.isNaN(parsedYear) ? 0 : parsedYear
+  })
  const [rankings, setRankings] = useState<ContactRanking[]>([])
  const [isLoading, setIsLoading] = useState(true)
  const [loadError, setLoadError] = useState<string | null>(null)
  const [keyword, setKeyword] = useState('')

  useEffect(() => {
-    const params = new URLSearchParams(window.location.hash.split('?')[1] || '')
-    const yearParam = params.get('year')
-    const parsedYear = yearParam ? parseInt(yearParam, 10) : 0
-    setYear(Number.isNaN(parsedYear) ? 0 : parsedYear)
-  }, [])
+    void loadRankings(year)
+  }, [year])

-  useEffect(() => {
-    loadRankings()
-  }, [])
-
-  const loadRankings = async () => {
+  const loadRankings = async (reportYear: number) => {
    setIsLoading(true)
    setLoadError(null)
    try {
-      const result = await window.electronAPI.analytics.getContactRankings(200)
+      const isAllTime = reportYear <= 0
+      const beginTimestamp = isAllTime ? 0 : Math.floor(new Date(reportYear, 0, 1).getTime() / 1000)
+      const endTimestamp = isAllTime ? 0 : Math.floor(new Date(reportYear, 11, 31, 23, 59, 59).getTime() / 1000)
+      const result = await window.electronAPI.analytics.getContactRankings(200, beginTimestamp, endTimestamp)
      if (result.success && result.data) {
        setRankings(result.data)
      } else {
@@ -55,7 +57,8 @@ function DualReportPage() {
    if (!keyword.trim()) return rankings
    const q = keyword.trim().toLowerCase()
    return rankings.filter((item) => {
-      return item.displayName.toLowerCase().includes(q) || item.username.toLowerCase().includes(q)
+      const wechatId = (item.wechatId || '').toLowerCase()
+      return item.displayName.toLowerCase().includes(q) || wechatId.includes(q)
    })
  }, [rankings, keyword])

@@ -99,7 +102,7 @@ function DualReportPage() {
        <input
          value={keyword}
          onChange={(e) => setKeyword(e.target.value)}
-          placeholder="搜索好友（昵称/备注/wxid）"
+          placeholder="搜索好友（昵称/微信号）"
        />
      </div>

@@ -119,7 +122,7 @@ function DualReportPage() {
            </div>
            <div className="info">
              <div className="name">{item.displayName}</div>
-              <div className="sub">{item.username}</div>
+              <div className="sub">{item.wechatId || '\u672A\u8bbe\u7f6e\u5fae\u4fe1\u53f7'}</div>
            </div>
            <div className="meta">
              <div className="count">{item.messageCount.toLocaleString()} 条</div>
--- a/src/pages/DualReportWindow.scss
+++ b/src/pages/DualReportWindow.scss
@@ -8,6 +8,7 @@
    font-size: clamp(26px, 5vw, 44px);
    white-space: normal;
  }
+
  .dual-names {
    font-size: clamp(24px, 4vw, 40px);
    font-weight: 700;
@@ -30,9 +31,6 @@
  }

  .dual-info-card {
-    background: var(--ar-card-bg);
-    border: 1px solid var(--bg-tertiary, rgba(0, 0, 0, 0.05));
-    border-radius: 14px;
    padding: 16px;

    &.full {
@@ -60,14 +58,8 @@
  }

  .dual-message {
-    background: var(--ar-card-bg);
-    border-radius: 14px;
    padding: 14px;

-    &.received {
-      background: var(--ar-card-bg-hover);
-    }
-
    .message-meta {
      font-size: 12px;
      color: var(--ar-text-sub);
@@ -81,25 +73,15 @@
  }

  .first-chat-scene {
-    background: linear-gradient(180deg, #8f5b85 0%, #e38aa0 50%, #f6d0c8 100%);
-    border-radius: 20px;
-    padding: 28px 24px 24px;
-    color: #fff;
+    padding: 18px 16px 16px;
+    color: var(--ar-text-main);
    position: relative;
    overflow: hidden;
    margin-top: 16px;
  }

  .first-chat-scene::before {
-    content: "";
-    position: absolute;
-    inset: 0;
-    background-image:
-      radial-gradient(circle at 20% 20%, rgba(255, 255, 255, 0.2), transparent 40%),
-      radial-gradient(circle at 80% 10%, rgba(255, 255, 255, 0.15), transparent 35%),
-      radial-gradient(circle at 50% 80%, rgba(255, 255, 255, 0.12), transparent 45%);
-    opacity: 0.6;
-    pointer-events: none;
+    display: none;
  }

  .scene-title {
@@ -107,6 +89,7 @@
    font-weight: 700;
    text-align: center;
    margin-bottom: 8px;
+    color: var(--ar-text-main);
  }

  .scene-subtitle {
@@ -114,92 +97,192 @@
    font-weight: 500;
    text-align: center;
    margin-bottom: 20px;
-    opacity: 0.95;
+    opacity: 0.9;
+    color: var(--ar-text-sub);
  }

  .scene-messages {
    display: flex;
    flex-direction: column;
-    gap: 14px;
+    gap: 16px;
  }

  .scene-message {
    display: flex;
-    align-items: flex-end;
-    gap: 12px;
+    flex-direction: column;
+    align-items: center;
+    margin-bottom: 32px;
+    width: 100%;

-    &.sent {
+    &.system {
+      margin: 16px 0;
+
+      .system-msg-content {
+        background: rgba(255, 255, 255, 0.05);
+        padding: 4px 12px;
+        border-radius: 12px;
+        font-size: 12px;
+        color: rgba(255, 255, 255, 0.4);
+        text-align: center;
+        max-width: 80%;
+      }
+    }
+
+    .scene-meta {
+      font-size: 10px;
+      opacity: 0.65;
+      margin-bottom: 12px;
+      color: var(--text-tertiary);
+      text-align: center;
+      width: 100%;
+    }
+
+    .scene-body {
+      display: flex;
+      align-items: center;
+      gap: 12px;
+      width: 100%;
+      max-width: 100%;
+    }
+
+    &.sent .scene-body {
      flex-direction: row-reverse;
+      justify-content: flex-start;
+    }
+
+    &.received .scene-body {
+      flex-direction: row;
+      justify-content: flex-start;
    }
  }

  .scene-avatar {
-    width: 40px;
-    height: 40px;
-    border-radius: 12px;
-    background: rgba(255, 255, 255, 0.25);
+    width: 42px;
+    height: 42px;
+    border-radius: 50%;
+    background: var(--ar-card-bg);
    display: flex;
    align-items: center;
    justify-content: center;
    font-weight: 700;
-    color: #fff;
+    color: var(--ar-text-sub);
+    border: 1px solid var(--bg-tertiary, rgba(0, 0, 0, 0.08));
+    overflow: hidden;
+    flex-shrink: 0;
+
+    img {
+      width: 100%;
+      height: 100%;
+      object-fit: cover;
+      display: block;
+    }
+  }
+
+  .scene-content-wrapper {
+    display: flex;
+    flex-direction: column;
+    width: 100%;
+    max-width: min(78%, 720px);
+  }
+
+  .scene-message.sent .scene-content-wrapper {
+    align-items: flex-end;
  }

  .scene-bubble {
-    background: rgba(255, 255, 255, 0.85);
-    color: #5a4d5e;
+    color: var(--ar-text-main);
    padding: 10px 14px;
-    border-radius: 14px;
-    max-width: 60%;
-    box-shadow: 0 10px 24px rgba(0, 0, 0, 0.12);
-  }
+    width: fit-content;
+    min-width: 40px;
+    max-width: 100%;
+    background: var(--ar-card-bg);
+    border-radius: 12px;
+    position: relative;

-  .scene-message.sent .scene-bubble {
-    background: rgba(255, 224, 168, 0.9);
-    color: #4a3a2f;
-  }
-
-  .scene-meta {
-    font-size: 11px;
-    opacity: 0.7;
-    margin-bottom: 4px;
+    &.no-bubble {
+      background: transparent;
+      padding: 0;
+      box-shadow: none;
+    }
  }

  .scene-content {
+    line-height: 1.5;
+    font-size: clamp(14px, 1.8vw, 16px);
+    word-break: break-all;
+    white-space: pre-wrap;
+    overflow-wrap: break-word;
+    line-break: auto;
+
+    .report-emoji-container {
+      display: inline-block;
+      vertical-align: middle;
+      margin: 2px 0;
+
+      .report-emoji-img {
+        max-width: 120px;
+        max-height: 120px;
+        border-radius: 4px;
+        display: block;
+      }
+    }
+  }
+
+  .scene-avatar.fallback {
    font-size: 14px;
-    line-height: 1.4;
-    word-break: break-word;
+  }
+
+  .scene-avatar.with-image {
+    background: transparent;
+    color: transparent;
  }

  .scene-message.sent .scene-avatar {
-    background: rgba(255, 224, 168, 0.9);
-    color: #4a3a2f;
+    border-color: color-mix(in srgb, var(--primary) 30%, var(--bg-tertiary, rgba(0, 0, 0, 0.08)));
  }

  .dual-stat-grid {
-    display: grid;
-    grid-template-columns: repeat(5, minmax(140px, 1fr));
-    gap: 14px;
-    margin: 20px -28px 24px;
-    padding: 0 28px;
-    overflow: visible;
+    display: flex;
+    flex-wrap: nowrap;
+    gap: clamp(60px, 10vw, 120px);
+    margin: 48px 0 32px;
+    padding: 0;
+    justify-content: center;
+    align-items: flex-start;
+
+    &.bottom {
+      margin-top: 0;
+      margin-bottom: 48px;
+      gap: clamp(40px, 6vw, 80px);
+    }
  }

  .dual-stat-card {
-    background: var(--ar-card-bg);
-    border-radius: 14px;
-    padding: 14px 12px;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
    text-align: center;
+    min-width: 140px;
+    max-width: 280px;
  }

  .stat-num {
-    font-size: clamp(20px, 2.8vw, 30px);
+    font-size: clamp(36px, 6vw, 64px);
+    font-weight: 800;
    font-variant-numeric: tabular-nums;
+    color: var(--ar-primary);
+    line-height: 1;
    white-space: nowrap;
+
+    &.small {
+      font-size: clamp(24px, 4vw, 40px);
+    }
  }

  .stat-unit {
-    font-size: 12px;
+    font-size: 14px;
+    margin-top: 4px;
+    opacity: 0.8;
  }

  .dual-stat-card.long .stat-num {
@@ -215,15 +298,12 @@
  }

  .emoji-card {
-    border: 1px solid var(--bg-tertiary, rgba(0, 0, 0, 0.08));
-    border-radius: 16px;
    padding: 18px 16px;
    display: flex;
    flex-direction: column;
    gap: 10px;
    align-items: center;
    justify-content: center;
-    background: var(--ar-card-bg);

    img {
      width: 64px;
@@ -250,4 +330,580 @@
    text-align: center;
    padding: 24px 0;
  }
+
+  .initiative-container {
+    padding: 32px 0;
+    width: 100%;
+    background: transparent;
+    border: none;
+  }
+
+  .initiative-bar-wrapper {
+    display: flex;
+    align-items: center;
+    gap: 32px;
+    width: 100%;
+    padding: 24px 0;
+    margin-bottom: 24px;
+    position: relative;
+  }
+
+  .initiative-side {
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    gap: 12px;
+    min-width: 80px;
+    z-index: 2;
+
+    .avatar-placeholder {
+      width: 54px;
+      height: 54px;
+      border-radius: 18px;
+      background: var(--bg-tertiary);
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      font-weight: 700;
+      color: var(--ar-text-sub);
+      font-size: 16px;
+      border: 1.5px solid rgba(255, 255, 255, 0.15);
+      box-shadow: 0 4px 20px rgba(0, 0, 0, 0.3);
+      overflow: hidden;
+
+      img {
+        width: 100%;
+        height: 100%;
+        object-fit: cover;
+      }
+    }
+
+    .count {
+      font-size: 11px;
+      font-weight: 500;
+      opacity: 0.4;
+      color: var(--ar-text-sub);
+    }
+
+    .percent {
+      font-size: 14px;
+      color: var(--ar-text-main);
+      font-weight: 800;
+      opacity: 0.9;
+    }
+  }
+
+  .initiative-progress {
+    flex: 1;
+    height: 1px; // 线条样式
+    position: relative;
+    display: flex;
+    align-items: center;
+
+    .line-bg {
+      position: absolute;
+      left: 0;
+      right: 0;
+      height: 1px;
+      background: linear-gradient(90deg,
+          transparent 0%,
+          rgba(255, 255, 255, 0.1) 20%,
+          rgba(255, 255, 255, 0.1) 80%,
+          transparent 100%);
+    }
+
+    .initiative-indicator {
+      position: absolute;
+      width: 8px;
+      height: 8px;
+      background: #fff;
+      border-radius: 50%;
+      transform: translateX(-50%);
+      transition: left 1.5s cubic-bezier(0.16, 1, 0.3, 1);
+      box-shadow:
+        0 0 10px #fff,
+        0 0 20px rgba(255, 255, 255, 0.5),
+        0 0 30px var(--ar-primary);
+      z-index: 3;
+
+      &::before {
+        content: '';
+        position: absolute;
+        top: -4px;
+        left: -4px;
+        right: -4px;
+        bottom: -4px;
+        border: 1px solid rgba(255, 255, 255, 0.2);
+        border-radius: 50%;
+        animation: pulse 2s infinite;
+      }
+    }
+  }
+
+  .initiative-desc {
+    text-align: center;
+    font-size: 14px;
+    color: var(--ar-text-sub);
+    letter-spacing: 1px;
+    opacity: 0.6;
+    background: transparent;
+    padding: 0;
+    margin: 0 auto;
+    font-style: italic;
+  }
+
+  @keyframes pulse {
+    0% {
+      transform: scale(1);
+      opacity: 0.8;
+    }
+
+    100% {
+      transform: scale(2);
+      opacity: 0;
+    }
+  }
+
+
+  .response-pulse-container {
+    width: 100%;
+    padding: 80px 0;
+    display: flex;
+    justify-content: center;
+  }
+
+  .pulse-visual {
+    position: relative;
+    width: 420px;
+    height: 240px;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+  }
+
+  .pulse-hub {
+    position: relative;
+    z-index: 5;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    justify-content: center;
+    width: 160px;
+    height: 160px;
+    background: radial-gradient(circle at center, rgba(255, 255, 255, 0.12) 0%, transparent 75%);
+    border-radius: 50%;
+    box-shadow: 0 0 40px rgba(255, 255, 255, 0.1);
+
+    .label {
+      font-size: 13px;
+      color: var(--ar-text-sub);
+      opacity: 0.6;
+      margin-bottom: 6px;
+      letter-spacing: 2px;
+    }
+
+    .value {
+      font-size: 54px;
+      font-weight: 950;
+      color: #fff;
+      line-height: 1;
+      text-shadow: 0 0 30px rgba(255, 255, 255, 0.5);
+
+      span {
+        font-size: 18px;
+        font-weight: 500;
+        margin-left: 4px;
+        opacity: 0.7;
+      }
+    }
+  }
+
+  .pulse-node {
+    position: absolute;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    z-index: 4;
+    animation: floatNode 4s ease-in-out infinite;
+
+    &.left {
+      left: 0;
+      transform: translateX(-15%);
+    }
+
+    &.right {
+      right: 0;
+      transform: translateX(15%);
+      animation-delay: -2s;
+    }
+
+    .label {
+      font-size: 12px;
+      color: var(--ar-text-sub);
+      opacity: 0.5;
+      margin-bottom: 4px;
+    }
+
+    .value {
+      font-size: 24px;
+      font-weight: 800;
+      color: var(--ar-text-main);
+      opacity: 0.95;
+
+      span {
+        font-size: 13px;
+        margin-left: 2px;
+        opacity: 0.6;
+      }
+    }
+  }
+
+  .pulse-ripple {
+    position: absolute;
+    top: 50%;
+    left: 50%;
+    transform: translate(-50%, -50%);
+    border: 1.5px solid rgba(255, 255, 255, 0.08);
+    border-radius: 50%;
+    animation: ripplePulse 8s linear infinite;
+    pointer-events: none;
+
+    &.one {
+      animation-delay: 0s;
+    }
+
+    &.two {
+      animation-delay: 2.5s;
+    }
+
+    &.three {
+      animation-delay: 5s;
+    }
+  }
+
+  @keyframes ripplePulse {
+    0% {
+      width: 140px;
+      height: 140px;
+      opacity: 0.5;
+    }
+
+    100% {
+      width: 700px;
+      height: 700px;
+      opacity: 0;
+    }
+  }
+
+  @keyframes floatNode {
+
+    0%,
+    100% {
+      transform: translateY(0);
+    }
+
+    50% {
+      transform: translateY(-16px);
+    }
+  }
+
+  .response-note {
+    text-align: center;
+    font-size: 14px;
+    color: var(--ar-text-sub);
+    opacity: 0.5;
+    margin-top: 32px;
+    font-style: italic;
+    max-width: none;
+    line-height: 1.6;
+  }
+
+  .streak-spark-visual.premium {
+    width: 100%;
+    height: 400px;
+    position: relative;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    justify-content: center;
+    margin: 20px 0;
+    overflow: visible;
+
+    .spark-ambient-glow {
+      position: absolute;
+      top: 40%;
+      left: 50%;
+      transform: translate(-50%, -50%);
+      width: 600px;
+      height: 480px;
+      background: radial-gradient(circle at center, rgba(242, 170, 0, 0.04) 0%, transparent 70%);
+      filter: blur(60px);
+      z-index: 1;
+      pointer-events: none;
+    }
+  }
+
+  .spark-core-wrapper {
+    position: relative;
+    width: 220px;
+    height: 280px;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    z-index: 5;
+    animation: flameSway 6s ease-in-out infinite;
+    transform-origin: bottom center;
+  }
+
+  .spark-flame-outer {
+    position: absolute;
+    width: 100%;
+    height: 100%;
+    background: radial-gradient(ellipse at 50% 85%, rgba(242, 170, 0, 0.15) 0%, transparent 75%);
+    border-radius: 50% 50% 20% 20% / 80% 80% 30% 30%;
+    filter: blur(25px);
+    animation: flickerOuter 4s infinite alternate;
+  }
+
+  .spark-flame-inner {
+    position: absolute;
+    bottom: 20%;
+    width: 140px;
+    height: 180px;
+    background: radial-gradient(ellipse at 50% 90%, rgba(255, 215, 0, 0.2) 0%, transparent 80%);
+    border-radius: 50% 50% 30% 30% / 85% 85% 25% 25%;
+    filter: blur(12px);
+    animation: flickerInner 3s infinite alternate-reverse;
+  }
+
+  .spark-core {
+    position: relative;
+    z-index: 10;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    justify-content: center;
+    padding-bottom: 20px;
+
+    .spark-days {
+      font-size: 84px;
+      font-weight: 800;
+      color: rgba(255, 255, 255, 0.9);
+      line-height: 1;
+      letter-spacing: -1px;
+      text-shadow:
+        0 0 15px rgba(255, 255, 255, 0.4),
+        0 8px 30px rgba(0, 0, 0, 0.3);
+    }
+
+    .spark-label {
+      font-size: 14px;
+      font-weight: 800;
+      color: rgba(255, 255, 255, 0.4);
+      letter-spacing: 6px;
+      margin-top: 12px;
+      text-indent: 6px;
+    }
+  }
+
+  .streak-bridge.premium {
+    width: 100%;
+    max-width: 500px;
+    display: flex;
+    align-items: center;
+    gap: 0;
+    margin-top: -20px;
+    z-index: 20;
+
+    .bridge-date {
+      display: flex;
+      flex-direction: column;
+      align-items: center;
+      position: relative;
+      width: 100px;
+
+      span {
+        font-size: 13px;
+        color: var(--ar-text-sub);
+        opacity: 0.6;
+        font-weight: 500;
+        letter-spacing: 0.2px;
+        position: absolute;
+        top: 24px;
+        white-space: nowrap;
+      }
+
+      .date-orb {
+        width: 6px;
+        height: 6px;
+        background: #fff;
+        border-radius: 50%;
+        box-shadow: 0 0 12px var(--ar-accent);
+        border: 1px solid rgba(252, 170, 0, 0.5);
+      }
+    }
+
+    .bridge-line {
+      flex: 1;
+      height: 40px;
+      position: relative;
+      display: flex;
+      align-items: center;
+
+      .line-string {
+        width: 100%;
+        height: 1.5px;
+        background: linear-gradient(90deg,
+            rgba(242, 170, 0, 0) 0%,
+            rgba(242, 170, 0, 0.6) 20%,
+            rgba(242, 170, 0, 0.6) 80%,
+            rgba(242, 170, 0, 0) 100%);
+        mask-image: radial-gradient(ellipse at center, black 60%, transparent 100%);
+      }
+
+      .line-glow {
+        position: absolute;
+        width: 100%;
+        height: 8px;
+        background: radial-gradient(ellipse at center, rgba(242, 170, 0, 0.2) 0%, transparent 80%);
+        filter: blur(4px);
+        animation: sparkFlicker 2s infinite alternate;
+      }
+    }
+  }
+
+  .spark-ember {
+    position: absolute;
+    background: #FFD700;
+    border-radius: 50%;
+    filter: blur(0.5px);
+    box-shadow: 0 0 6px #F2AA00;
+    opacity: 0;
+    z-index: 4;
+
+    &.one {
+      width: 3px;
+      height: 3px;
+      left: 46%;
+      animation: emberRise 5s infinite 0s;
+    }
+
+    &.two {
+      width: 2px;
+      height: 2px;
+      left: 53%;
+      animation: emberRise 4s infinite 1.2s;
+    }
+
+    &.three {
+      width: 4px;
+      height: 4px;
+      left: 50%;
+      animation: emberRise 6s infinite 2.5s;
+    }
+
+    &.four {
+      width: 2.5px;
+      height: 2.5px;
+      left: 48%;
+      animation: emberRise 5.5s infinite 3.8s;
+    }
+  }
+
+  @keyframes flameSway {
+
+    0%,
+    100% {
+      transform: rotate(-1deg) skewX(-1deg);
+    }
+
+    50% {
+      transform: rotate(1.5deg) skewX(1deg);
+    }
+  }
+
+  @keyframes flickerOuter {
+
+    0%,
+    100% {
+      opacity: 0.15;
+      filter: blur(25px);
+    }
+
+    50% {
+      opacity: 0.25;
+      filter: blur(30px);
+    }
+  }
+
+  @keyframes flickerInner {
+
+    0%,
+    100% {
+      transform: scale(1);
+      opacity: 0.2;
+    }
+
+    50% {
+      transform: scale(1.08);
+      opacity: 0.3;
+    }
+  }
+
+  @keyframes emberRise {
+    0% {
+      transform: translateY(100px) scale(1);
+      opacity: 0;
+    }
+
+    20% {
+      opacity: 0.8;
+    }
+
+    80% {
+      opacity: 0.3;
+    }
+
+    100% {
+      transform: translateY(-260px) scale(0.4);
+      opacity: 0;
+    }
+  }
+
+  @keyframes sparkFlicker {
+
+    0%,
+    100% {
+      transform: scale(1);
+      opacity: 0.9;
+      filter: brightness(1);
+    }
+
+    50% {
+      transform: scale(1.03);
+      opacity: 1;
+      filter: brightness(1.2);
+    }
+  }
+
+  @media (max-width: 960px) {
+    .pulse-visual {
+      transform: scale(0.85);
+    }
+
+    .scene-avatar {
+      width: 36px;
+      height: 36px;
+      font-size: 13px;
+    }
+
+    .scene-content-wrapper {
+      max-width: min(86%, 500px);
+    }
+
+    .scene-bubble {
+      max-width: 100%;
+      min-width: 56px;
+    }
+  }
 }
--- a/src/pages/DualReportWindow.tsx
+++ b/src/pages/DualReportWindow.tsx
@@ -1,4 +1,6 @@
-import { useEffect, useState, type CSSProperties } from 'react'
+import { useEffect, useState } from 'react'
+import ReportHeatmap from '../components/ReportHeatmap'
+import ReportWordCloud from '../components/ReportWordCloud'
 import './AnnualReportWindow.scss'
 import './DualReportWindow.scss'

@@ -7,19 +9,27 @@ interface DualReportMessage {
  isSentByMe: boolean
  createTime: number
  createTimeStr: string
+  localType?: number
+  emojiMd5?: string
+  emojiCdnUrl?: string
 }

 interface DualReportData {
  year: number
  selfName: string
+  selfAvatarUrl?: string
  friendUsername: string
  friendName: string
+  friendAvatarUrl?: string
  firstChat: {
    createTime: number
    createTimeStr: string
    content: string
    isSentByMe: boolean
    senderUsername?: string
+    localType?: number
+    emojiMd5?: string
+    emojiCdnUrl?: string
  } | null
  firstChatMessages?: DualReportMessage[]
  yearFirstChat?: {
@@ -29,6 +39,9 @@ interface DualReportData {
    isSentByMe: boolean
    friendName: string
    firstThreeMessages: DualReportMessage[]
+    localType?: number
+    emojiMd5?: string
+    emojiCdnUrl?: string
  } | null
  stats: {
    totalMessages: number
@@ -40,111 +53,15 @@ interface DualReportData {
    friendTopEmojiMd5?: string
    myTopEmojiUrl?: string
    friendTopEmojiUrl?: string
+    myTopEmojiCount?: number
+    friendTopEmojiCount?: number
  }
  topPhrases: Array<{ phrase: string; count: number }>
-}
-
-const WordCloud = ({ words }: { words: { phrase: string; count: number }[] }) => {
-  if (!words || words.length === 0) {
-    return <div className="word-cloud-empty">暂无高频语句</div>
-  }
-  const sortedWords = [...words].sort((a, b) => b.count - a.count)
-  const maxCount = sortedWords.length > 0 ? sortedWords[0].count : 1
-  const topWords = sortedWords.slice(0, 32)
-  const baseSize = 520
-
-  const seededRandom = (seed: number) => {
-    const x = Math.sin(seed) * 10000
-    return x - Math.floor(x)
-  }
-
-  const placedItems: { x: number; y: number; w: number; h: number }[] = []
-
-  const canPlace = (x: number, y: number, w: number, h: number): boolean => {
-    const halfW = w / 2
-    const halfH = h / 2
-    const dx = x - 50
-    const dy = y - 50
-    const dist = Math.sqrt(dx * dx + dy * dy)
-    const maxR = 49 - Math.max(halfW, halfH)
-    if (dist > maxR) return false
-
-    const pad = 1.8
-    for (const p of placedItems) {
-      if ((x - halfW - pad) < (p.x + p.w / 2) &&
-        (x + halfW + pad) > (p.x - p.w / 2) &&
-        (y - halfH - pad) < (p.y + p.h / 2) &&
-        (y + halfH + pad) > (p.y - p.h / 2)) {
-        return false
-      }
-    }
-    return true
-  }
-
-  const wordItems = topWords.map((item, i) => {
-    const ratio = item.count / maxCount
-    const fontSize = Math.round(12 + Math.pow(ratio, 0.65) * 20)
-    const opacity = Math.min(1, Math.max(0.35, 0.35 + ratio * 0.65))
-    const delay = (i * 0.04).toFixed(2)
-
-    const charCount = Math.max(1, item.phrase.length)
-    const hasCjk = /[\u4e00-\u9fff]/.test(item.phrase)
-    const hasLatin = /[A-Za-z0-9]/.test(item.phrase)
-    const widthFactor = hasCjk && hasLatin ? 0.85 : hasCjk ? 0.98 : 0.6
-    const widthPx = fontSize * (charCount * widthFactor)
-    const heightPx = fontSize * 1.1
-    const widthPct = (widthPx / baseSize) * 100
-    const heightPct = (heightPx / baseSize) * 100
-
-    let x = 50, y = 50
-    let placedOk = false
-    const tries = i === 0 ? 1 : 420
-
-    for (let t = 0; t < tries; t++) {
-      if (i === 0) {
-        x = 50
-        y = 50
-      } else {
-        const idx = i + t * 0.28
-        const radius = Math.sqrt(idx) * 7.6 + (seededRandom(i * 1000 + t) * 1.2 - 0.6)
-        const angle = idx * 2.399963 + seededRandom(i * 2000 + t) * 0.35
-        x = 50 + radius * Math.cos(angle)
-        y = 50 + radius * Math.sin(angle)
-      }
-      if (canPlace(x, y, widthPct, heightPct)) {
-        placedOk = true
-        break
-      }
-    }
-
-    if (!placedOk) return null
-    placedItems.push({ x, y, w: widthPct, h: heightPct })
-
-    return (
-      <span
-        key={i}
-        className="word-tag"
-        style={{
-          '--final-opacity': opacity,
-          left: `${x.toFixed(2)}%`,
-          top: `${y.toFixed(2)}%`,
-          fontSize: `${fontSize}px`,
-          animationDelay: `${delay}s`,
-        } as CSSProperties}
-        title={`${item.phrase} (出现 ${item.count} 次)`}
-      >
-        {item.phrase}
-      </span>
-    )
-  }).filter(Boolean)
-
-  return (
-    <div className="word-cloud-wrapper">
-      <div className="word-cloud-inner">
-        {wordItems}
-      </div>
-    </div>
-  )
+  heatmap?: number[][]
+  initiative?: { initiated: number; received: number }
+  response?: { avg: number; fastest: number; slowest: number; count: number }
+  monthly?: Record<string, number>
+  streak?: { days: number; startDate: string; endDate: string }
 }

 function DualReportWindow() {
@@ -203,6 +120,8 @@ function DualReportWindow() {
  useEffect(() => {
    const loadEmojis = async () => {
      if (!reportData) return
+      setMyEmojiUrl(null)
+      setFriendEmojiUrl(null)
      const stats = reportData.stats
      if (stats.myTopEmojiUrl) {
        const res = await window.electronAPI.chat.downloadEmoji(stats.myTopEmojiUrl, stats.myTopEmojiMd5)
@@ -273,12 +192,15 @@ function DualReportWindow() {
    : null
  const yearFirstChat = reportData.yearFirstChat
  const stats = reportData.stats
+  const initiativeTotal = (reportData.initiative?.initiated || 0) + (reportData.initiative?.received || 0)
+  const initiatedPercent = initiativeTotal > 0 ? (reportData.initiative!.initiated / initiativeTotal) * 100 : 0
+  const receivedPercent = initiativeTotal > 0 ? (reportData.initiative!.received / initiativeTotal) * 100 : 0
  const statItems = [
-    { label: '总消息数', value: stats.totalMessages },
-    { label: '总字数', value: stats.totalWords },
-    { label: '图片', value: stats.imageCount },
-    { label: '语音', value: stats.voiceCount },
-    { label: '表情', value: stats.emojiCount },
+    { label: '总消息数', value: stats.totalMessages, color: '#07C160' },
+    { label: '总字数', value: stats.totalWords, color: '#10AEFF' },
+    { label: '图片', value: stats.imageCount, color: '#FFC300' },
+    { label: '语音', value: stats.voiceCount, color: '#FA5151' },
+    { label: '表情', value: stats.emojiCount, color: '#FA9D3B' },
  ]

  const decodeEntities = (text: string) => (
@@ -290,7 +212,28 @@ function DualReportWindow() {
      .replace(/&apos;/g, "'")
  )

+  const filterDisplayMessages = (messages: DualReportMessage[], maxActual: number = 3) => {
+    let actualCount = 0
+    const result: DualReportMessage[] = []
+    for (const msg of messages) {
+      const isSystem = msg.localType === 10000 || msg.localType === 10002
+      if (!isSystem) {
+        if (actualCount >= maxActual) break
+        actualCount++
+      }
+      result.push(msg)
+    }
+    return result
+  }
+
  const stripCdata = (text: string) => text.replace(/<!\[CDATA\[([\s\S]*?)\]\]>/g, '$1')
+  const compactMessageText = (text: string) => (
+    text
+      .replace(/\r\n/g, '\n')
+      .replace(/\s*\n+\s*/g, ' ')
+      .replace(/\s{2,}/g, ' ')
+      .trim()
+  )

  const extractXmlText = (content: string) => {
    const titleMatch = content.match(/<title>([\s\S]*?)<\/title>/i)
@@ -304,16 +247,62 @@ function DualReportWindow() {
    return ''
  }

-  const formatMessageContent = (content?: string) => {
-    const raw = String(content || '').trim()
+  const formatMessageContent = (content?: string, localType?: number) => {
+    const isSystemMsg = localType === 10000 || localType === 10002
+    if (!isSystemMsg) {
+      if (localType === 3) return '[图片]'
+      if (localType === 34) return '[语音]'
+      if (localType === 43) return '[视频]'
+      if (localType === 47) return '[表情]'
+      if (localType === 42) return '[名片]'
+      if (localType === 48) return '[位置]'
+      if (localType === 49) return '[链接/文件]'
+    }
+
+    const raw = compactMessageText(String(content || '').trim())
    if (!raw) return '（空）'
+
+    // 1. 尝试提取 XML 关键字段
+    const titleMatch = raw.match(/<title>([\s\S]*?)<\/title>/i)
+    if (titleMatch?.[1]) return compactMessageText(decodeEntities(stripCdata(titleMatch[1]).trim()))
+
+    const descMatch = raw.match(/<des>([\s\S]*?)<\/des>/i)
+    if (descMatch?.[1]) return compactMessageText(decodeEntities(stripCdata(descMatch[1]).trim()))
+
+    const summaryMatch = raw.match(/<summary>([\s\S]*?)<\/summary>/i)
+    if (summaryMatch?.[1]) return compactMessageText(decodeEntities(stripCdata(summaryMatch[1]).trim()))
+
+    // 2. 检查是否是 XML 结构
    const hasXmlTag = /<\s*[a-zA-Z]+[^>]*>/.test(raw)
-    const looksLikeXml = /<\?xml|<msg\b|<appmsg\b|<sysmsg\b|<appattach\b|<emoji\b|<img\b|<voip\b/i.test(raw)
-      || hasXmlTag
+    const looksLikeXml = /<\?xml|<msg\b|<appmsg\b|<sysmsg\b|<appattach\b|<emoji\b|<img\b|<voip\b/i.test(raw) || hasXmlTag
+
    if (!looksLikeXml) return raw
-    const extracted = extractXmlText(raw)
-    if (!extracted) return '（XML消息）'
-    return decodeEntities(stripCdata(extracted).trim()) || '（XML消息）'
+
+    // 3. 最后的尝试：移除所有 XML 标签，看是否还有有意义的文本
+    const stripped = raw.replace(/<[^>]+>/g, '').trim()
+    if (stripped && stripped.length > 0 && stripped.length < 50) {
+      return compactMessageText(decodeEntities(stripped))
+    }
+
+    return '[多媒体消息]'
+  }
+
+  const ReportMessageItem = ({ msg }: { msg: DualReportMessage }) => {
+    if (msg.localType === 47 && (msg.emojiMd5 || msg.emojiCdnUrl)) {
+      const emojiUrl = msg.emojiCdnUrl || (msg.emojiMd5 ? `https://emoji.qpic.cn/wx_emoji/${msg.emojiMd5}/0` : '')
+      if (emojiUrl) {
+        return (
+          <div className="report-emoji-container">
+            <img src={emojiUrl} alt="表情" className="report-emoji-img" onError={(e) => {
+              (e.target as HTMLImageElement).style.display = 'none';
+              (e.target as HTMLImageElement).nextElementSibling?.removeAttribute('style');
+            }} />
+            <span style={{ display: 'none' }}>[表情]</span>
+          </div>
+        )
+      }
+    }
+    return <span>{formatMessageContent(msg.content, msg.localType)}</span>
  }
  const formatFullDate = (timestamp: number) => {
    const d = new Date(timestamp)
@@ -325,6 +314,87 @@ function DualReportWindow() {
    return `${year}/${month}/${day} ${hour}:${minute}`
  }

+  const getMostActiveTime = (data: number[][]) => {
+    let maxHour = 0
+    let maxWeekday = 0
+    let maxVal = -1
+    data.forEach((row, weekday) => {
+      row.forEach((value, hour) => {
+        if (value > maxVal) {
+          maxVal = value
+          maxHour = hour
+          maxWeekday = weekday
+        }
+      })
+    })
+    const weekdayNames = ['周一', '周二', '周三', '周四', '周五', '周六', '周日']
+    return {
+      weekday: weekdayNames[maxWeekday] || '周一',
+      hour: maxHour,
+      value: Math.max(0, maxVal)
+    }
+  }
+
+  const mostActive = reportData.heatmap ? getMostActiveTime(reportData.heatmap) : null
+  const responseAvgMinutes = reportData.response ? Math.max(0, Math.round(reportData.response.avg / 60)) : 0
+  const getSceneAvatarUrl = (isSentByMe: boolean) => (isSentByMe ? reportData.selfAvatarUrl : reportData.friendAvatarUrl)
+  const getSceneAvatarFallback = (isSentByMe: boolean) => (isSentByMe ? '我' : reportData.friendName.substring(0, 1))
+  const renderSceneAvatar = (isSentByMe: boolean) => {
+    const avatarUrl = getSceneAvatarUrl(isSentByMe)
+    if (avatarUrl) {
+      return (
+        <div className="scene-avatar with-image">
+          <img src={avatarUrl} alt={isSentByMe ? 'me-avatar' : 'friend-avatar'} />
+        </div>
+      )
+    }
+    return <div className="scene-avatar fallback">{getSceneAvatarFallback(isSentByMe)}</div>
+  }
+
+  const renderMessageList = (messages: DualReportMessage[]) => {
+    const displayMsgs = filterDisplayMessages(messages)
+    let lastTime = 0
+    const TIME_THRESHOLD = 5 * 60 * 1000 // 5 分钟
+
+    return displayMsgs.map((msg, idx) => {
+      const isSystem = msg.localType === 10000 || msg.localType === 10002
+      const showTime = idx === 0 || (msg.createTime - lastTime > TIME_THRESHOLD)
+      lastTime = msg.createTime
+
+      if (isSystem) {
+        return (
+          <div key={idx} className="scene-message system">
+            {showTime && (
+              <div className="scene-meta">
+                {formatFullDate(msg.createTime).split(' ')[1]}
+              </div>
+            )}
+            <div className="system-msg-content">
+              <ReportMessageItem msg={msg} />
+            </div>
+          </div>
+        )
+      }
+      return (
+        <div key={idx} className={`scene-message ${msg.isSentByMe ? 'sent' : 'received'}`}>
+          {showTime && (
+            <div className="scene-meta">
+              {formatFullDate(msg.createTime).split(' ')[1]}
+            </div>
+          )}
+          <div className="scene-body">
+            {renderSceneAvatar(msg.isSentByMe)}
+            <div className="scene-content-wrapper">
+              <div className={`scene-bubble ${msg.localType === 47 ? 'no-bubble' : ''}`}>
+                <div className="scene-content"><ReportMessageItem msg={msg} /></div>
+              </div>
+            </div>
+          </div>
+        </div>
+      )
+    })
+  }
+
  return (
    <div className="annual-report-window dual-report-window">
      <div className="drag-region" />
@@ -344,7 +414,7 @@ function DualReportWindow() {
            <h1 className="hero-title dual-cover-title">{yearTitle}<br />双人聊天报告</h1>
            <hr className="divider" />
            <div className="dual-names">
-              <span>{reportData.selfName}</span>
+              <span>我</span>
              <span className="amp">&amp;</span>
              <span>{reportData.friendName}</span>
            </div>
@@ -355,105 +425,217 @@ function DualReportWindow() {
            <div className="label-text">首次聊天</div>
            <h2 className="hero-title">故事的开始</h2>
            {firstChat ? (
-              <>
-                <div className="dual-info-grid">
-                  <div className="dual-info-card">
-                    <div className="info-label">第一次聊天时间</div>
-                    <div className="info-value">{formatFullDate(firstChat.createTime)}</div>
-                  </div>
-                  <div className="dual-info-card">
-                    <div className="info-label">距今天数</div>
-                    <div className="info-value">{daysSince} 天</div>
-                  </div>
-                </div>
+              <div className="first-chat-scene">
+                <div className="scene-title">第一次遇见</div>
+                <div className="scene-subtitle">{formatFullDate(firstChat.createTime).split(' ')[0]}</div>
                {firstChatMessages.length > 0 ? (
-                  <div className="dual-message-list">
-                    {firstChatMessages.map((msg, idx) => (
-                      <div
-                        key={idx}
-                        className={`dual-message ${msg.isSentByMe ? 'sent' : 'received'}`}
-                      >
-                        <div className="message-meta">
-                          {msg.isSentByMe ? reportData.selfName : reportData.friendName} · {formatFullDate(msg.createTime)}
-                        </div>
-                        <div className="message-content">{formatMessageContent(msg.content)}</div>
-                      </div>
-                    ))}
+                  <div className="scene-messages">
+                    {renderMessageList(firstChatMessages)}
                  </div>
-                ) : null}
-              </>
+                ) : (
+                  <div className="hero-desc" style={{ textAlign: 'center' }}>暂无消息详情</div>
+                )}
+                <div className="scene-footer" style={{ marginTop: '20px', textAlign: 'center', fontSize: '14px', opacity: 0.6 }}>
+                  距离今天已经 {daysSince} 天
+                </div>
+              </div>
            ) : (
              <p className="hero-desc">暂无首条消息</p>
            )}
          </section>

-          {yearFirstChat ? (
+          {yearFirstChat && (!firstChat || yearFirstChat.createTime !== firstChat.createTime) ? (
            <section className="section">
              <div className="label-text">第一段对话</div>
              <h2 className="hero-title">
                {reportData.year === 0 ? '你们的第一段对话' : `${reportData.year}年的第一段对话`}
              </h2>
-              <div className="dual-info-grid">
-                <div className="dual-info-card">
-                  <div className="info-label">第一段对话时间</div>
-                  <div className="info-value">{formatFullDate(yearFirstChat.createTime)}</div>
+              <div className="first-chat-scene">
+                <div className="scene-title">久别重逢</div>
+                <div className="scene-subtitle">{formatFullDate(yearFirstChat.createTime).split(' ')[0]}</div>
+                <div className="scene-messages">
+                  {renderMessageList(yearFirstChat.firstThreeMessages)}
                </div>
-                <div className="dual-info-card">
-                  <div className="info-label">发起者</div>
-                  <div className="info-value">{yearFirstChat.isSentByMe ? reportData.selfName : reportData.friendName}</div>
-                </div>
-              </div>
-              <div className="dual-message-list">
-                {yearFirstChat.firstThreeMessages.map((msg, idx) => (
-                  <div key={idx} className={`dual-message ${msg.isSentByMe ? 'sent' : 'received'}`}>
-                    <div className="message-meta">
-                      {msg.isSentByMe ? reportData.selfName : reportData.friendName} · {formatFullDate(msg.createTime)}
-                    </div>
-                    <div className="message-content">{formatMessageContent(msg.content)}</div>
-                  </div>
-                ))}
              </div>
            </section>
          ) : null}

+          {reportData.heatmap && (
+            <section className="section">
+              <div className="label-text">聊天习惯</div>
+              <h2 className="hero-title">作息规律</h2>
+              {mostActive && (
+                <p className="hero-desc active-time dual-active-time">
+                  在 <span className="hl">{mostActive.weekday} {String(mostActive.hour).padStart(2, '0')}:00</span> 最活跃（{mostActive.value}条）
+                </p>
+              )}
+              <ReportHeatmap data={reportData.heatmap} />
+            </section>
+          )}
+
+          {reportData.initiative && (
+            <section className="section">
+              <div className="label-text">主动性</div>
+              <h2 className="hero-title">情感的天平</h2>
+              <div className="initiative-container">
+                <div className="initiative-bar-wrapper">
+                  <div className="initiative-side">
+                    <div className="avatar-placeholder">
+                      {reportData.selfAvatarUrl ? <img src={reportData.selfAvatarUrl} alt="me-avatar" /> : '我'}
+                    </div>
+                    <div className="count">{reportData.initiative.initiated}次</div>
+                    <div className="percent">{initiatedPercent.toFixed(1)}%</div>
+                  </div>
+                  <div className="initiative-progress">
+                    <div className="line-bg" />
+                    <div
+                      className="initiative-indicator"
+                      style={{ left: `${initiatedPercent}%` }}
+                    />
+                  </div>
+                  <div className="initiative-side">
+                    <div className="avatar-placeholder">
+                      {reportData.friendAvatarUrl ? <img src={reportData.friendAvatarUrl} alt="friend-avatar" /> : reportData.friendName.substring(0, 1)}
+                    </div>
+                    <div className="count">{reportData.initiative.received}次</div>
+                    <div className="percent">{receivedPercent.toFixed(1)}%</div>
+                  </div>
+                </div>
+                <div className="initiative-desc">
+                  {reportData.initiative.initiated > reportData.initiative.received ? '每一个话题都是你对TA的在意' : 'TA总是那个率先打破沉默的人'}
+                </div>
+              </div>
+            </section>
+          )}
+
+          {reportData.response && (
+            <section className="section">
+              <div className="label-text">回应速度</div>
+              <h2 className="hero-title">你说，我在</h2>
+              <div className="response-pulse-container">
+                <div className="pulse-visual">
+                  <div className="pulse-ripple one" />
+                  <div className="pulse-ripple two" />
+                  <div className="pulse-ripple three" />
+
+                  <div className="pulse-node left">
+                    <div className="label">最快回复</div>
+                    <div className="value">{reportData.response.fastest}<span>秒</span></div>
+                  </div>
+
+                  <div className="pulse-hub">
+                    <div className="label">平均回复</div>
+                    <div className="value">{Math.round(reportData.response.avg / 60)}<span>分</span></div>
+                  </div>
+
+                  <div className="pulse-node right">
+                    <div className="label">最慢回复</div>
+                    <div className="value">
+                      {reportData.response.slowest > 3600
+                        ? (reportData.response.slowest / 3600).toFixed(1)
+                        : Math.round(reportData.response.slowest / 60)}
+                      <span>{reportData.response.slowest > 3600 ? '时' : '分'}</span>
+                    </div>
+                  </div>
+                </div>
+              </div>
+              <p className="hero-desc response-note">
+                {`在 ${reportData.response.count} 次互动中，平均约 ${responseAvgMinutes} 分钟，最快 ${reportData.response.fastest} 秒。`}
+              </p>
+            </section>
+          )}
+
+          {reportData.streak && (
+            <section className="section">
+              <div className="label-text">聊天火花</div>
+              <h2 className="hero-title">最长连续聊天</h2>
+              <div className="streak-spark-visual premium">
+                <div className="spark-ambient-glow" />
+
+                <div className="spark-ember one" />
+                <div className="spark-ember two" />
+                <div className="spark-ember three" />
+                <div className="spark-ember four" />
+
+                <div className="spark-core-wrapper">
+                  <div className="spark-flame-outer" />
+                  <div className="spark-flame-inner" />
+                  <div className="spark-core">
+                    <div className="spark-days">{reportData.streak.days}</div>
+                    <div className="spark-label">DAYS</div>
+                  </div>
+                </div>
+
+                <div className="streak-bridge premium">
+                  <div className="bridge-date start">
+                    <div className="date-orb" />
+                    <span>{reportData.streak.startDate}</span>
+                  </div>
+                  <div className="bridge-line">
+                    <div className="line-glow" />
+                    <div className="line-string" />
+                  </div>
+                  <div className="bridge-date end">
+                    <span>{reportData.streak.endDate}</span>
+                    <div className="date-orb" />
+                  </div>
+                </div>
+              </div>
+            </section>
+          )}
+
          <section className="section">
            <div className="label-text">常用语</div>
            <h2 className="hero-title">{yearTitle}常用语</h2>
-            <WordCloud words={reportData.topPhrases} />
+            <ReportWordCloud words={reportData.topPhrases} />
          </section>

          <section className="section">
            <div className="label-text">年度统计</div>
            <h2 className="hero-title">{yearTitle}数据概览</h2>
            <div className="dual-stat-grid">
-              {statItems.map((item) => {
-                const valueText = item.value.toLocaleString()
-                const isLong = valueText.length > 7
-                return (
-                  <div key={item.label} className={`dual-stat-card ${isLong ? 'long' : ''}`}>
-                    <div className="stat-num">{valueText}</div>
-                    <div className="stat-unit">{item.label}</div>
-                  </div>
-                )
-              })}
+              {statItems.slice(0, 2).map((item) => (
+                <div key={item.label} className="dual-stat-card">
+                  <div className="stat-num">{item.value.toLocaleString()}</div>
+                  <div className="stat-unit">{item.label}</div>
+                </div>
+              ))}
+            </div>
+            <div className="dual-stat-grid bottom">
+              {statItems.slice(2).map((item) => (
+                <div key={item.label} className="dual-stat-card">
+                  <div className="stat-num small">{item.value.toLocaleString()}</div>
+                  <div className="stat-unit">{item.label}</div>
+                </div>
+              ))}
            </div>

            <div className="emoji-row">
              <div className="emoji-card">
                <div className="emoji-title">我常用的表情</div>
                {myEmojiUrl ? (
-                  <img src={myEmojiUrl} alt="my-emoji" />
-                ) : (
-                  <div className="emoji-placeholder">{stats.myTopEmojiMd5 || '暂无'}</div>
-                )}
+                  <img src={myEmojiUrl} alt="my-emoji" onError={(e) => {
+                    (e.target as HTMLImageElement).nextElementSibling?.removeAttribute('style');
+                    (e.target as HTMLImageElement).style.display = 'none';
+                  }} />
+                ) : null}
+                <div className="emoji-placeholder" style={myEmojiUrl ? { display: 'none' } : undefined}>
+                  {stats.myTopEmojiMd5 || '暂无'}
+                </div>
+                <div className="emoji-count">{stats.myTopEmojiCount ? `${stats.myTopEmojiCount}次` : '暂无统计'}</div>
              </div>
              <div className="emoji-card">
                <div className="emoji-title">{reportData.friendName}常用的表情</div>
                {friendEmojiUrl ? (
-                  <img src={friendEmojiUrl} alt="friend-emoji" />
-                ) : (
-                  <div className="emoji-placeholder">{stats.friendTopEmojiMd5 || '暂无'}</div>
-                )}
+                  <img src={friendEmojiUrl} alt="friend-emoji" onError={(e) => {
+                    (e.target as HTMLImageElement).nextElementSibling?.removeAttribute('style');
+                    (e.target as HTMLImageElement).style.display = 'none';
+                  }} />
+                ) : null}
+                <div className="emoji-placeholder" style={friendEmojiUrl ? { display: 'none' } : undefined}>
+                  {stats.friendTopEmojiMd5 || '暂无'}
+                </div>
+                <div className="emoji-count">{stats.friendTopEmojiCount ? `${stats.friendTopEmojiCount}次` : '暂无统计'}</div>
              </div>
            </div>
          </section>
--- a/src/pages/ExportPage.tsx
+++ b/src/pages/ExportPage.tsx
@@ -13,7 +13,7 @@ interface ChatSession {
 }

 interface ExportOptions {
-  format: 'chatlab' | 'chatlab-jsonl' | 'json' | 'html' | 'txt' | 'excel' | 'sql'
+  format: 'chatlab' | 'chatlab-jsonl' | 'json' | 'html' | 'txt' | 'excel' | 'weclone' | 'sql'
  dateRange: { start: Date; end: Date } | null
  useAllTime: boolean
  exportAvatars: boolean
@@ -360,7 +360,7 @@ function ExportPage() {
        } : null
      }

-      if (options.format === 'chatlab' || options.format === 'chatlab-jsonl' || options.format === 'json' || options.format === 'excel' || options.format === 'txt' || options.format === 'html') {
+      if (options.format === 'chatlab' || options.format === 'chatlab-jsonl' || options.format === 'json' || options.format === 'excel' || options.format === 'txt' || options.format === 'html' || options.format === 'weclone') {
        const result = await window.electronAPI.export.exportSessions(
          sessionList,
          exportFolder,
@@ -513,6 +513,7 @@ function ExportPage() {
    { value: 'html', label: 'HTML', icon: FileText, desc: '网页格式，可直接浏览' },
    { value: 'txt', label: 'TXT', icon: Table, desc: '纯文本，通用格式' },
    { value: 'excel', label: 'Excel', icon: FileSpreadsheet, desc: '电子表格，适合统计分析' },
+    { value: 'weclone', label: 'WeClone CSV', icon: Table, desc: 'WeClone 兼容字段格式（CSV）' },
    { value: 'sql', label: 'PostgreSQL', icon: Database, desc: '数据库脚本，便于导入到数据库' }
  ]
  const displayNameOptions = [
--- a/src/pages/SettingsPage.tsx
+++ b/src/pages/SettingsPage.tsx
@@ -1565,6 +1565,7 @@ function SettingsPage() {
    { value: 'json', label: 'JSON', desc: '详细格式，包含完整消息信息' },
    { value: 'html', label: 'HTML', desc: '网页格式，可直接浏览' },
    { value: 'txt', label: 'TXT', desc: '纯文本，通用格式' },
+    { value: 'weclone', label: 'WeClone CSV', desc: 'WeClone 兼容字段格式（CSV）' },
    { value: 'sql', label: 'PostgreSQL', desc: '数据库脚本，便于导入到数据库' }
  ]
  const exportDateRangeOptions = [
--- a/src/stores/batchTranscribeStore.ts
+++ b/src/stores/batchTranscribeStore.ts
@@ -12,6 +12,7 @@ export interface BatchTranscribeState {
  /** 转写结果 */
  result: { success: number; fail: number }
  /** 当前转写的会话名 */
+  startTime: number
  sessionName: string

  // Actions
@@ -30,6 +31,7 @@ export const useBatchTranscribeStore = create<BatchTranscribeState>((set) => ({
  showResult: false,
  result: { success: 0, fail: 0 },
  sessionName: '',
+  startTime: 0,

  startTranscribe: (total, sessionName) => set({
    isBatchTranscribing: true,
@@ -37,7 +39,8 @@ export const useBatchTranscribeStore = create<BatchTranscribeState>((set) => ({
    progress: { current: 0, total },
    showResult: false,
    result: { success: 0, fail: 0 },
-    sessionName
+    sessionName,
+    startTime: Date.now()
  }),

  updateProgress: (current, total) => set({
@@ -48,7 +51,8 @@ export const useBatchTranscribeStore = create<BatchTranscribeState>((set) => ({
    isBatchTranscribing: false,
    showToast: false,
    showResult: true,
-    result: { success, fail }
+    result: { success, fail },
+    startTime: 0
  }),

  setShowToast: (show) => set({ showToast: show }),
@@ -60,6 +64,7 @@ export const useBatchTranscribeStore = create<BatchTranscribeState>((set) => ({
    showToast: false,
    showResult: false,
    result: { success: 0, fail: 0 },
-    sessionName: ''
+    sessionName: '',
+    startTime: 0
  })
 }))
--- a/src/styles/batchTranscribe.scss
+++ b/src/styles/batchTranscribe.scss
@@ -26,13 +26,25 @@
 }

@keyframes batchFadeIn {
-  from { opacity: 0; }
-  to { opacity: 1; }
+  from {
+    opacity: 0;
+  }
+
+  to {
+    opacity: 1;
+  }
 }

@keyframes batchSlideUp {
-  from { opacity: 0; transform: translateY(20px); }
-  to { opacity: 1; transform: translateY(0); }
+  from {
+    opacity: 0;
+    transform: translateY(20px);
+  }
+
+  to {
+    opacity: 1;
+    transform: translateY(0);
+  }
 }

 // 批量转写进度浮窗（非阻塞 toast）
@@ -64,7 +76,9 @@
      font-weight: 600;
      color: var(--text-primary);

-      svg { color: var(--primary-color); }
+      svg {
+        color: var(--primary);
+      }
    }
  }

@@ -90,18 +104,38 @@
  .batch-progress-toast-body {
    padding: 12px 14px;

-    .progress-text {
+    .progress-info-row {
      display: flex;
-      justify-content: space-between;
-      align-items: center;
+      flex-direction: column;
+      gap: 4px;
      margin-bottom: 8px;
-      font-size: 12px;
-      color: var(--text-secondary);

-      .progress-percent {
-        font-weight: 600;
-        color: var(--primary-color);
-        font-size: 13px;
+      .progress-text {
+        display: flex;
+        justify-content: space-between;
+        align-items: center;
+        font-size: 12px;
+        color: var(--text-secondary);
+
+        .progress-percent {
+          font-weight: 600;
+          color: var(--primary);
+          font-size: 13px;
+        }
+      }
+
+      .progress-eta {
+        display: flex;
+        align-items: center;
+        gap: 4px;
+        font-size: 11px; // 稍微小一点
+        color: var(--text-tertiary, #999); // 使用更淡的颜色
+
+        svg {
+          width: 12px;
+          height: 12px;
+          opacity: 0.8;
+        }
      }
    }

@@ -113,7 +147,7 @@

      .progress-fill {
        height: 100%;
-        background: linear-gradient(90deg, var(--primary-color), var(--primary-color));
+        background: linear-gradient(90deg, var(--primary), var(--primary));
        border-radius: 3px;
        transition: width 0.3s ease;
      }
@@ -122,8 +156,15 @@
 }

@keyframes batchToastSlideIn {
-  from { opacity: 0; transform: translateY(16px) scale(0.96); }
-  to { opacity: 1; transform: translateY(0) scale(1); }
+  from {
+    opacity: 0;
+    transform: translateY(16px) scale(0.96);
+  }
+
+  to {
+    opacity: 1;
+    transform: translateY(0) scale(1);
+  }
 }

 // 批量转写结果对话框
@@ -138,7 +179,9 @@
    padding: 1.5rem;
    border-bottom: 1px solid var(--border-color);

-    svg { color: #4caf50; }
+    svg {
+      color: #4caf50;
+    }

    h3 {
      margin: 0;
@@ -165,7 +208,9 @@
        border-radius: 8px;
        background: var(--bg-tertiary);

-        svg { flex-shrink: 0; }
+        svg {
+          flex-shrink: 0;
+        }

        .label {
          font-size: 14px;
@@ -179,13 +224,23 @@
        }

        &.success {
-          svg { color: #4caf50; }
-          .value { color: #4caf50; }
+          svg {
+            color: #4caf50;
+          }
+
+          .value {
+            color: #4caf50;
+          }
        }

        &.fail {
-          svg { color: #f44336; }
-          .value { color: #f44336; }
+          svg {
+            color: #f44336;
+          }
+
+          .value {
+            color: #f44336;
+          }
        }
      }
    }
@@ -229,9 +284,12 @@
      border: none;

      &.btn-primary {
-        background: var(--primary-color);
+        background: var(--primary);
        color: white;
-        &:hover { opacity: 0.9; }
+
+        &:hover {
+          opacity: 0.9;
+        }
      }
    }
  }
--- a/src/types/electron.d.ts
+++ b/src/types/electron.d.ts
@@ -163,12 +163,13 @@ export interface ElectronAPI {
      }
      error?: string
    }>
-    getContactRankings: (limit?: number) => Promise<{
+    getContactRankings: (limit?: number, beginTimestamp?: number, endTimestamp?: number) => Promise<{
      success: boolean
      data?: Array<{
        username: string
        displayName: string
        avatarUrl?: string
+        wechatId?: string
        messageCount: number
        sentCount: number
        receivedCount: number
@@ -357,8 +358,10 @@ export interface ElectronAPI {
      data?: {
        year: number
        selfName: string
+        selfAvatarUrl?: string
        friendUsername: string
        friendName: string
+        friendAvatarUrl?: string
        firstChat: {
          createTime: number
          createTimeStr: string
@@ -395,8 +398,15 @@ export interface ElectronAPI {
          friendTopEmojiMd5?: string
          myTopEmojiUrl?: string
          friendTopEmojiUrl?: string
+          myTopEmojiCount?: number
+          friendTopEmojiCount?: number
        }
        topPhrases: Array<{ phrase: string; count: number }>
+        heatmap?: number[][]
+        initiative?: { initiated: number; received: number }
+        response?: { avg: number; fastest: number; count: number }
+        monthly?: Record<string, number>
+        streak?: { days: number; startDate: string; endDate: string }
      }
      error?: string
    }>