From 03ec49bc7e42616f9ffe0d12cb5a9b0cffb68c84 Mon Sep 17 00:00:00 2001
From: digua <i@digua.me>
Date: Sun, 30 Nov 2025 02:13:33 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E6=80=BB=E8=A7=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 electron/main/ipcMain.ts                |  15 ++++
 electron/main/worker/dbWorker.ts        |   2 +
 electron/main/worker/index.ts           |   1 +
 electron/main/worker/queryBasic.ts      |  52 ++++++++---
 electron/main/worker/workerManager.ts   |   4 +
 electron/preload/index.ts               |  11 +++
 src/components/analysis/OverviewTab.vue | 115 ++++++++++++++++--------
 src/types/chat.ts                       |   8 ++
 8 files changed, 158 insertions(+), 50 deletions(-)

diff --git a/electron/main/ipcMain.ts b/electron/main/ipcMain.ts
index 5709900c..f7037bf9 100644
--- a/electron/main/ipcMain.ts
+++ b/electron/main/ipcMain.ts
@@ -344,6 +344,21 @@ const mainIpcMain = (win: BrowserWindow) => {
     }
   )
 
+  /**
+   * 获取月份活跃度分布
+   */
+  ipcMain.handle(
+    'chat:getMonthlyActivity',
+    async (_, sessionId: string, filter?: { startTs?: number; endTs?: number }) => {
+      try {
+        return await worker.getMonthlyActivity(sessionId, filter)
+      } catch (error) {
+        console.error('获取月份活跃度失败：', error)
+        return []
+      }
+    }
+  )
+
   /**
    * 获取消息类型分布
    */
diff --git a/electron/main/worker/dbWorker.ts b/electron/main/worker/dbWorker.ts
index 07adf8f2..080e0f36 100644
--- a/electron/main/worker/dbWorker.ts
+++ b/electron/main/worker/dbWorker.ts
@@ -17,6 +17,7 @@ import {
   getHourlyActivity,
   getDailyActivity,
   getWeekdayActivity,
+  getMonthlyActivity,
   getMessageTypeDistribution,
   getTimeRange,
   getMemberNameHistory,
@@ -53,6 +54,7 @@ const handlers: Record<string, (payload: any) => any> = {
   getHourlyActivity: (p) => getHourlyActivity(p.sessionId, p.filter),
   getDailyActivity: (p) => getDailyActivity(p.sessionId, p.filter),
   getWeekdayActivity: (p) => getWeekdayActivity(p.sessionId, p.filter),
+  getMonthlyActivity: (p) => getMonthlyActivity(p.sessionId, p.filter),
   getMessageTypeDistribution: (p) => getMessageTypeDistribution(p.sessionId, p.filter),
   getTimeRange: (p) => getTimeRange(p.sessionId),
   getMemberNameHistory: (p) => getMemberNameHistory(p.sessionId, p.memberId),
diff --git a/electron/main/worker/index.ts b/electron/main/worker/index.ts
index bdd0a6e6..2c286d24 100644
--- a/electron/main/worker/index.ts
+++ b/electron/main/worker/index.ts
@@ -13,6 +13,7 @@ export {
   getHourlyActivity,
   getDailyActivity,
   getWeekdayActivity,
+  getMonthlyActivity,
   getMessageTypeDistribution,
   getTimeRange,
   getMemberNameHistory,
diff --git a/electron/main/worker/queryBasic.ts b/electron/main/worker/queryBasic.ts
index 5212fa29..9433ca51 100644
--- a/electron/main/worker/queryBasic.ts
+++ b/electron/main/worker/queryBasic.ts
@@ -6,14 +6,7 @@
 import Database from 'better-sqlite3'
 import * as fs from 'fs'
 import * as path from 'path'
-import {
-  openDatabase,
-  getDbDir,
-  getDbPath,
-  buildTimeFilter,
-  buildSystemMessageFilter,
-  type TimeFilter,
-} from './dbCore'
+import { openDatabase, getDbDir, getDbPath, buildTimeFilter, buildSystemMessageFilter, type TimeFilter } from './dbCore'
 
 // ==================== 基础查询 ====================
 
@@ -198,6 +191,43 @@ export function getWeekdayActivity(sessionId: string, filter?: TimeFilter): any[
   return result
 }
 
+/**
+ * 获取月份活跃度分布
+ */
+export function getMonthlyActivity(sessionId: string, filter?: TimeFilter): any[] {
+  const db = openDatabase(sessionId)
+  if (!db) return []
+
+  const { clause, params } = buildTimeFilter(filter)
+  const clauseWithSystem = buildSystemMessageFilter(clause)
+
+  const rows = db
+    .prepare(
+      `
+      SELECT
+        CAST(strftime('%m', msg.ts, 'unixepoch', 'localtime') AS INTEGER) as month,
+        COUNT(*) as messageCount
+      FROM message msg
+      JOIN member m ON msg.sender_id = m.id
+      ${clauseWithSystem}
+      GROUP BY month
+      ORDER BY month
+    `
+    )
+    .all(...params) as Array<{ month: number; messageCount: number }>
+
+  const result: any[] = []
+  for (let m = 1; m <= 12; m++) {
+    const found = rows.find((r) => r.month === m)
+    result.push({
+      month: m,
+      messageCount: found ? found.messageCount : 0,
+    })
+  }
+
+  return result
+}
+
 /**
  * 获取消息类型分布
  */
@@ -250,10 +280,7 @@ export function getTimeRange(sessionId: string): { start: number; end: number }
 /**
  * 获取成员的历史昵称记录
  */
-export function getMemberNameHistory(
-  sessionId: string,
-  memberId: number
-): any[] {
+export function getMemberNameHistory(sessionId: string, memberId: number): any[] {
   const db = openDatabase(sessionId)
   if (!db) return []
 
@@ -386,4 +413,3 @@ export function getSession(sessionId: string): any | null {
     dbPath: getDbPath(sessionId),
   }
 }
-
diff --git a/electron/main/worker/workerManager.ts b/electron/main/worker/workerManager.ts
index 5fd68af8..be49d9ef 100644
--- a/electron/main/worker/workerManager.ts
+++ b/electron/main/worker/workerManager.ts
@@ -191,6 +191,10 @@ export async function getWeekdayActivity(sessionId: string, filter?: any): Promi
   return sendToWorker('getWeekdayActivity', { sessionId, filter })
 }
 
+export async function getMonthlyActivity(sessionId: string, filter?: any): Promise<any[]> {
+  return sendToWorker('getMonthlyActivity', { sessionId, filter })
+}
+
 export async function getMessageTypeDistribution(sessionId: string, filter?: any): Promise<any[]> {
   return sendToWorker('getMessageTypeDistribution', { sessionId, filter })
 }
diff --git a/electron/preload/index.ts b/electron/preload/index.ts
index 300bf5bc..21cff8d8 100644
--- a/electron/preload/index.ts
+++ b/electron/preload/index.ts
@@ -7,6 +7,7 @@ import type {
   HourlyActivity,
   DailyActivity,
   WeekdayActivity,
+  MonthlyActivity,
   MessageType,
   ImportProgress,
   RepeatAnalysis,
@@ -128,6 +129,16 @@ const chatApi = {
     return ipcRenderer.invoke('chat:getWeekdayActivity', sessionId, filter)
   },
 
+  /**
+   * 获取月份活跃度分布
+   */
+  getMonthlyActivity: (
+    sessionId: string,
+    filter?: { startTs?: number; endTs?: number }
+  ): Promise<MonthlyActivity[]> => {
+    return ipcRenderer.invoke('chat:getMonthlyActivity', sessionId, filter)
+  },
+
   /**
    * 获取消息类型分布
    */
diff --git a/src/components/analysis/OverviewTab.vue b/src/components/analysis/OverviewTab.vue
index 15a3daa6..3d2b19c7 100644
--- a/src/components/analysis/OverviewTab.vue
+++ b/src/components/analysis/OverviewTab.vue
@@ -1,6 +1,13 @@
 <script setup lang="ts">
 import { computed, ref, watch } from 'vue'
-import type { AnalysisSession, MemberActivity, HourlyActivity, MessageType, WeekdayActivity } from '@/types/chat'
+import type {
+  AnalysisSession,
+  MemberActivity,
+  HourlyActivity,
+  MessageType,
+  WeekdayActivity,
+  MonthlyActivity,
+} from '@/types/chat'
 import { getMessageTypeName } from '@/types/chat'
 import { DoughnutChart, ProgressBar, BarChart } from '@/components/charts'
 import type { DoughnutChartData, BarChartData } from '@/components/charts'
@@ -48,6 +55,26 @@ const typeChartData = computed<DoughnutChartData>(() => {
   }
 })
 
+// 成员水群分布图表数据
+const memberChartData = computed<DoughnutChartData>(() => {
+  const sortedMembers = [...props.memberActivity].sort((a, b) => b.messageCount - a.messageCount)
+  const top10 = sortedMembers.slice(0, 10)
+  const othersCount = sortedMembers.slice(10).reduce((sum, m) => sum + m.messageCount, 0)
+
+  const labels = top10.map((m) => m.name)
+  const values = top10.map((m) => m.messageCount)
+
+  if (othersCount > 0) {
+    labels.push('其他人')
+    values.push(othersCount)
+  }
+
+  return {
+    labels,
+    values,
+  }
+})
+
 // 最活跃时段
 const peakHour = computed(() => {
   if (!props.hourlyActivity.length) return null
@@ -74,6 +101,10 @@ const dailyAvgMessages = computed(() => {
 const weekdayActivity = ref<WeekdayActivity[]>([])
 const isLoadingWeekday = ref(false)
 
+// 月份活跃度数据
+const monthlyActivity = ref<MonthlyActivity[]>([])
+const isLoadingMonthly = ref(false)
+
 // 星期名称映射（周一开始）
 const weekdayNames = ['周一', '周二', '周三', '周四', '周五', '周六', '周日']
 
@@ -90,11 +121,25 @@ async function loadWeekdayActivity() {
   }
 }
 
+// 加载月份活跃度数据
+async function loadMonthlyActivity() {
+  if (!props.session.id) return
+  isLoadingMonthly.value = true
+  try {
+    monthlyActivity.value = await window.chatApi.getMonthlyActivity(props.session.id, props.timeFilter)
+  } catch (error) {
+    console.error('加载月份活跃度失败:', error)
+  } finally {
+    isLoadingMonthly.value = false
+  }
+}
+
 // 监听 session.id 和 timeFilter 变化
 watch(
   () => [props.session.id, props.timeFilter],
   () => {
     loadWeekdayActivity()
+    loadMonthlyActivity()
   },
   { immediate: true, deep: true }
 )
@@ -115,6 +160,14 @@ const weekdayChartData = computed<BarChartData>(() => {
   }
 })
 
+// 月份分布图数据
+const monthlyChartData = computed<BarChartData>(() => {
+  return {
+    labels: monthlyActivity.value.map((m) => `${m.month}月`),
+    values: monthlyActivity.value.map((m) => m.messageCount),
+  }
+})
+
 // 最活跃星期
 const peakWeekday = computed(() => {
   if (!weekdayActivity.value.length) return null
@@ -210,16 +263,7 @@ function getRankBadge(index: number): string {
     </div>
 
     <!-- 关键指标卡片 -->
-    <div class="grid grid-cols-1 gap-4 sm:grid-cols-3">
-      <!-- 龙王 -->
-      <StatCard label="龙王" :value="topMembers[0]?.name || '-'" icon="🏆" icon-bg="amber">
-        <template #subtext>
-          <span class="text-2xl font-bold text-amber-500">{{ topMembers[0]?.messageCount || 0 }}</span>
-          <span class="text-sm text-gray-500">条</span>
-          <span class="ml-2 text-sm text-gray-400">({{ topMembers[0]?.percentage || 0 }}%)</span>
-        </template>
-      </StatCard>
-
+    <div class="grid grid-cols-1 gap-4 sm:grid-cols-2 lg:grid-cols-4">
       <!-- 日均消息 -->
       <StatCard label="日均消息" :value="`${dailyAvgMessages} 条`" icon="📊" icon-bg="blue">
         <template #subtext>
@@ -255,8 +299,25 @@ function getRankBadge(index: number): string {
       </StatCard>
     </div>
 
-    <!-- 24小时 & 星期分布 -->
+    <!-- 图表区域：消息类型 & 成员分布 -->
     <div class="grid grid-cols-1 gap-6 lg:grid-cols-2">
+      <!-- 消息类型分布 -->
+      <SectionCard title="消息类型分布" :show-divider="false">
+        <div class="p-5">
+          <DoughnutChart :data="typeChartData" :height="256" />
+        </div>
+      </SectionCard>
+
+      <!-- 成员水群分布 -->
+      <SectionCard title="成员水群分布" :show-divider="false">
+        <div class="p-5">
+          <DoughnutChart :data="memberChartData" :height="256" />
+        </div>
+      </SectionCard>
+    </div>
+
+    <!-- 24小时 & 星期分布 & 月份分布 -->
+    <div class="grid grid-cols-1 gap-6 lg:grid-cols-2 2xl:grid-cols-3">
       <!-- 24小时分布 -->
       <SectionCard title="24小时活跃分布" :show-divider="false">
         <div class="p-5">
@@ -335,34 +396,14 @@ function getRankBadge(index: number): string {
           </div>
         </div>
       </SectionCard>
-    </div>
 
-    <!-- 图表区域 -->
-    <div class="grid grid-cols-1 gap-6 lg:grid-cols-2">
-      <!-- 消息类型分布 -->
-      <SectionCard title="消息类型分布" :show-divider="false">
+      <!-- 月份活跃分布 -->
+      <SectionCard title="月份活跃分布" :show-divider="false">
         <div class="p-5">
-          <DoughnutChart :data="typeChartData" :height="256" />
-        </div>
-      </SectionCard>
-
-      <!-- Top 成员预览 -->
-      <SectionCard title="活跃榜 Top 5" :show-divider="false">
-        <div class="space-y-3 p-5">
-          <div
-            v-for="(member, index) in memberActivity.slice(0, 5)"
-            :key="member.memberId"
-            class="flex items-center gap-3"
-          >
-            <span class="w-6 text-center text-lg">{{ getRankBadge(index) }}</span>
-            <div class="flex-1">
-              <div class="flex items-center justify-between">
-                <span class="font-medium text-gray-900 dark:text-white">{{ member.name }}</span>
-                <span class="text-sm text-gray-500">{{ member.messageCount }}</span>
-              </div>
-              <ProgressBar :percentage="member.percentage" color="from-pink-400 to-pink-600" />
-            </div>
+          <div v-if="isLoadingMonthly" class="flex h-64 items-center justify-center">
+            <UIcon name="i-heroicons-arrow-path" class="h-6 w-6 animate-spin text-pink-500" />
           </div>
+          <BarChart v-else :data="monthlyChartData" :height="256" />
         </div>
       </SectionCard>
     </div>
diff --git a/src/types/chat.ts b/src/types/chat.ts
index d18a1cf9..18b64f25 100644
--- a/src/types/chat.ts
+++ b/src/types/chat.ts
@@ -163,6 +163,14 @@ export interface WeekdayActivity {
   messageCount: number
 }
 
+/**
+ * 月份活跃度统计
+ */
+export interface MonthlyActivity {
+  month: number // 1-12
+  messageCount: number
+}
+
 // ==================== 夜猫分析类型 ====================
 
 /**