🔖 Version 3.0.1

🔖 Version 3.0.0
⚡ 超级性能提升
2026-01-25 21:22:16 +00:00 · 2025-09-22 21:45:54 +08:00 · 2025-09-22 21:40:56 +08:00 · 2025-09-22 21:26:19 +08:00
11 changed files with 180 additions and 385 deletions
--- a/README.md
+++ b/README.md
@@ -6,7 +6,8 @@

 <div align="center">

-# 📃话痨排行榜
+# 📃 话痨排行榜
+
 nonebot-plugin-dialectlist

 <p align="center">
@@ -24,21 +25,25 @@ nonebot-plugin-dialectlist
 [![wakatime](https://wakatime.com/badge/user/114aee90-a5f9-49aa-b441-9eca7eebfda3/project/68aaa2a1-fb8a-4b00-bb66-ee67e8a3f3b0.svg)](https://wakatime.com/badge/user/114aee90-a5f9-49aa-b441-9eca7eebfda3/project/68aaa2a1-fb8a-4b00-bb66-ee67e8a3f3b0)

 \>💬**看看群友们这些天在群里水了多少话**💬<
+
 </div>

 ## 💿 安装

 通过`pip`或`nb`安装：
+
 - 通过 pip 安装
+
 ```bash
 pip install nonebot-plugin-dialectlist
 ```
+
 - 通过 nb-cli 安装
+
 ```bash
 nb plugin install nonebot-plugin-dialectlist
 ```

-
 ### ✅ 插件依赖于

 1. [nonebot-plugin-datastore](https://github.com/he0119/nonebot-plugin-datastore) ————本地化储存
@@ -48,13 +53,14 @@ nb plugin install nonebot-plugin-dialectlist
 5. [nonebot-plugin-chatrecorder](https://github.com/noneplugin/nonebot-plugin-chatrecorder) ————实现消息储存
 6. [nonebot-plugin-cesaa](https://github.com/MountainDash/nonebot-plugin-send-anything-anywhere) ————实现多平台

- **⚠注意** 若先前没有安装过```nonebot-plugin-chatrecorder```或者```nonebot-plugin-orm```，则会在启动时报错，请按报错的提示安装数据库！
- 
+**⚠ 注意** 若先前没有安装过`nonebot-plugin-chatrecorder`或者`nonebot-plugin-orm`，则会在启动时报错，请按报错的提示安装数据库！
+
 ## ⚙ 配置

 需要**提前配置**本插件所**依赖的插件**！

 在 .env 中，可以添加以下配置项
+
 ```python
 dialectlist__get_num: int = 5  # 获取人数数量
 dialectlist__font: str = "SimHei"  # 字体格式
@@ -62,73 +68,74 @@ dialectlist__suffix: bool = True  # 是否显示后缀
 dialectlist__excluded_self: bool = True  # 是否排除自己
 dialectlist__visualization: bool = True  # 是否可视化
 dialectlist__show_text_rank: bool = True  # 是否显示文本排名
-dialectlist__counting_cache: bool = False  # 计数缓存(能够提高回复速度)
-dialectlist__excluded_people: List[str] = []  # 排除的人的QQ号
+dialectlist__excluded_people: List[str] = []  # 排除的人的 QQ 号
 dialectlist__use_user_info_cache: bool = False  # 是否使用用户信息缓存
 dialectlist__aggregate_transmission: bool = False  # 是否聚合转发消息
 dialectlist__timezone: Optional[str] = "Asia/Shanghai"  # 时区，影响统计时间
-dialectlist__string_suffix: str = "统计花费时间:{timecost}秒"  # 消息格式后缀
+dialectlist__string_suffix: str = "统计花费时间：{timecost}秒"  # 消息格式后缀
 dialectlist__template_path: str = "./template/rank_template.j2"  # 模板路径
-dialectlist__string_format: str = "第{index}名：\n{nickname},{chatdatanum}条消息\n"  # 消息格式
+dialectlist__string_format: str = "第{index}名：\n{nickname},{chatdatanum}条消息、n"  # 消息格式
 ```
-💭也可以不进行配置，这将会使插件按照默认配置运行

- ### ⚠ 注意！！
+💭 也可以不进行配置，这将会使插件按照默认配置运行
+
+### ⚠ 注意！！

 > 在旧版插件（2.0.0 以下）中，dialectlist 与后面的配置项只隔了一个下划线，若更新到新版本以后需要俩个下划线。

-> 由于插件依赖chatrecord多次引入爆炸性修改，建议在遇到问题后优先尝试降级chatrecord插件
+> 由于插件依赖 chatrecord 多次引入爆炸性修改，建议在遇到问题后优先尝试降级 chatrecord 插件

-## 🗨命令
-__！！注意！！__
+## 🗨 命令
+
+**！！注意！！**
 新版本指令调用方式改变，改为更易理解也更好打的 B 话榜。
 同时也可以用类似 `/今日废话榜` 的方式（只要改前面的就好了）（算是给 [盘古之白](https://github.com/vinta/pangu.js) 风格爱好者的福利吧？）

-### 🎨一般用法
+### 🎨 一般用法

-#### B话榜
+#### B 话榜

-`/B话榜` ————看看有史以来（机器人存在以来）群友们发了多少消息！ （好像没写）
+-`/B 话榜` ————看看有史以来（机器人存在以来）群友们发了多少消息！ （好像没写）

-`/今日B话榜` ————看看今天的群友发了多少消息！
+-`/今日 B 话榜` ————看看今天的群友发了多少消息！

-`/昨日B话榜` ————看看昨天的群友发了多少消息！
+-`/昨日 B 话榜` ————看看昨天的群友发了多少消息！

-`/前日B话榜` ————看看前天的群友发了多少消息！
+-`/前日 B 话榜` ————看看前天的群友发了多少消息！

-`/本周B话榜` ————看看本周的群友发了多少消息！
-  
-`/上周B话榜` ————看看上周的群友发了多少消息！
+-`/本周 B 话榜` ————看看本周的群友发了多少消息！

-`/本月B话榜` ————看看这个月的群友发了多少消息！
+-`/上周 B 话榜` ————看看上周的群友发了多少消息！

-`/年度B话榜` ————看看今年的群友发了多少消息！
+-`/本月 B 话榜` ————看看这个月的群友发了多少消息！

-`/历史B话榜` ————看看历史上（机器人存在以来）的群友发了多少消息！
+-`/年度 B 话榜` ————看看今年的群友发了多少消息！

-#### 看看B话（kkb）
+-`/历史 B 话榜` ————看看历史上（机器人存在以来）的群友发了多少消息！

-`/看看B话 [@某人|QQ号]` ————看看这个b人在这个b群发了多少b话！
+#### 看看 B 话（kkb）

-### 🚀进阶用法
+-`/看看 B 话 [@某人|QQ 号]` ————看看这个 b 人在这个 b 群发了多少 b 话！

-#### B话榜
+### 🚀 进阶用法

-`/{时间类型（今日|年度）?}{B话榜|废话榜} {时间类型？} {ISO8601 格式时间 ?} {群号} {关键词}`
+#### B 话榜

-如：`/B话榜 历史 2024-01-01~2024-01-02 12345678 女装`
+`/{时间类型（今日|年度）?}{B 话榜|废话榜} {时间类型？} {ISO8601 格式时间 ?} {群号} {关键词}`

-也可以 `/{时间类型（今日|年度）?}{B话榜|废话榜} {时间类型？} {ISO8601 格式时间 ?} -g {群号} -k {关键词}`
+如：`/B 话榜 历史 2024-01-01~2024-01-02 12345678 女装`
+
+也可以 `/{时间类型（今日|年度）?}{B 话榜|废话榜} {时间类型？} {ISO8601 格式时间 ?} -g {群号} -k {关键词}`

 以下调用方法均合法：

-`/今日B话榜 -g 12345678 -k 女装`
-`/昨日B话榜 -k 女装`
-`/本周B话榜 -g 12345678`
+`/今日 B 话榜 -g 12345678 -k 女装`
+`/昨日 B 话榜 -k 女装`
+`/本周 B 话榜 -g 12345678`

-#### 看看B话
+#### 看看 B 话

-`/看看B话 {@|QQ号} {群号？} {关键词？}`
+`/看看 B 话 {@|QQ 号} {群号？} {关键词？}`

 以下调用方法均合法：

@@ -140,28 +147,28 @@ __！！注意！！__

 ## 💪 目前支持的平台

-| 平台 | 是否经过测试 | 是否能够正常工作 | 测试环境 |
-|:-----:|:----:|:----:| :----: |
-| Onebot | ✅ | ✅ | NapCat + Window11|
-| 飞书  | ❌ | ❓ | 🤔 |
-| Red  | ❌ | ❓ | 🤔 |
-| DoDo  | ❌ | ❓ | 🤔 |
-| Mirai  | ❌ | ❓ | 🤔 |
-| 开黑啦  | ❌ | ❓ | 🤔 |
-| Kritor  | ❌ | ❓ | 🤔 |
-| Ntchat  | ❌ | ❓ | 🤔 |
-| Satori  | ❌ | ❓ | 🤔 |
-| Telegram | ❌ | ❓ | 🤔  |
-| Discord  | ❌ | ❓ | 🤔 |
-| Tailchat  | ❌ | ❓ | 🤔 |
-| QQ 官方接口  | ❌ | ❓ | 🤔 |
-| Rocket.Chat  | ❌ | ❓ | 🤔 |
+|    平台     | 是否经过测试 | 是否能够正常工作 |     测试环境      |
+| :---------: | :----------: | :--------------: | :---------------: |
+|   Onebot    |      ✅      |        ✅        | NapCat + Window11 |
+|    飞书     |      ❌      |        ❓        |        🤔         |
+|     Red     |      ❌      |        ❓        |        🤔         |
+|    DoDo     |      ❌      |        ❓        |        🤔         |
+|    Mirai    |      ❌      |        ❓        |        🤔         |
+|   开黑啦    |      ❌      |        ❓        |        🤔         |
+|   Kritor    |      ❌      |        ❓        |        🤔         |
+|   Ntchat    |      ❌      |        ❓        |        🤔         |
+|   Satori    |      ❌      |        ❓        |        🤔         |
+|  Telegram   |      ❌      |        ❓        |        🤔         |
+|   Discord   |      ❌      |        ❓        |        🤔         |
+|  Tailchat   |      ❌      |        ❓        |        🤔         |
+| QQ 官方接口 |      ❌      |        ❓        |        🤔         |
+| Rocket.Chat |      ❌      |        ❓        |        🤔         |

 - 如果你测试过能够使用，请在 Issue 中指出

-## 📦另外
+## 📦 另外

-### 😳加入作者的 BUG 反馈群 ~~（🥵女装粉丝群）~~
+### 😳 加入作者的 BUG 反馈群 ~~（🥵 女装粉丝群）~~

 [群连接](https://qm.qq.com/q/Yty2yc9Bee)

@@ -174,10 +181,9 @@ __！！注意！！__

 ![9c149e99ca747c13892be3f9fbeedf31](https://github.com/user-attachments/assets/d02d108c-1ab3-4ad1-9123-c1a98862e627)

+### 💕 感谢

-### 💕感谢
-
-本插件的__init__.py 中的处理函数参考了词云中的方法 ~~（其实大部分都是 Ctrl+C Ctr+V）~~
+本插件的**init**.py 中的处理函数参考了词云中的方法 ~~（其实大部分都是 Ctrl+C Ctr+V）~~

 [nonebot-plugin-wordcloud](https://github.com/he0119/nonebot-plugin-wordcloud)

@@ -194,7 +200,6 @@ __！！注意！！__
 - [x] 更好看的图片渲染

 - [x] 添加一些全新的可配置项
-      
 - [x] 尝试利用 jinja2 模板引擎制作可视化图片

 - [x] 私聊的查询（超级用户可以任意查询群聊的信息）一半完成
@@ -204,9 +209,9 @@ __！！注意！！__
 - [x] 查询带某关键词的消息量

 - [x] 合并转发
-  
- 待补充。.....

+待补充。.....
+
+### 👾 题外话

-### 👾题外话
 ~~整个项目快被我写成屎山了~~
--- a/nonebot_plugin_dialectlist/init.py
+++ b/nonebot_plugin_dialectlist/init.py
@@ -16,7 +16,6 @@ from typing import Optional, Union
 import nonebot_plugin_saa as saa
 from arclet.alconna import ArparmaBehavior
 from arclet.alconna.arparma import Arparma
-from nonebot import on_command
 from nonebot.adapters import Bot, Event
 from nonebot.log import logger
 from nonebot.params import Arg, Depends
@@ -31,10 +30,10 @@ from nonebot_plugin_alconna import (
 	Option,
 	on_alconna,
 )
-from nonebot_plugin_chatrecorder import get_message_records
 from nonebot_plugin_uninfo import Session, Uninfo, get_session

 from .config import Config, plugin_config
+
 # from .storage import build_cache, get_cache
 from .time import (
 	get_datetime_fromisoformat_with_timezone,
@@ -46,8 +45,8 @@ from .utils import (
 	get_rank_image,
 	get_user_infos,
 	got_rank,
-	msg_counter,
 	persist_id2user_id,
+	get_user_message_counts,
 )

 __plugin_meta__ = PluginMetadata(
@@ -80,17 +79,6 @@ def wrapper(slot: Union[int, str], content: Optional[str], context) -> str:
 	return ''  # pragma: no cover


-build_cache_cmd = on_command('build_cache', aliases={'重建缓存'}, block=True)
-
-
-@build_cache_cmd.handle()
-async def _build_cache(bot: Bot, event: Event):
-    return 
-	await saa.Text('正在重建缓存，请稍等。').send(reply=True) # type: ignore
-	await build_cache()
-	await saa.Text('重建缓存完成。').send(reply=True)
-
-
 b_cmd = on_alconna(
 	Alconna(
 		'看看B话',
@@ -122,18 +110,16 @@ async def handle_b_cmd(
 	if not gid:
 		await b_cmd.finish('请指定群号。')

-	if keyword.available:
-		keywords = keyword.result
-	else:
-		keywords = None
+	_keyword = keyword.result

-	messages = await get_message_records(
+	d = await get_user_message_counts(
+		keyword=_keyword,
 		scene_ids=[gid],
 		user_ids=[id],
 		types=['message'],  # 排除机器人自己发的消息
 		exclude_user_ids=plugin_config.excluded_people,
 	)
-	d = msg_counter(messages, keywords)
+
 	rank = got_rank(d)
 	if not rank:
 		await b_cmd.finish(
@@ -302,24 +288,16 @@ async def handle_rank(

 	keyword = state['keyword']

-	if plugin_config.counting_cache:
-		await saa.Text("缓存暂不支持").finish()
-		# if keyword:
-		# 	await saa.Text('已开启缓存~缓存不支持关键词查询哦').finish()
-		# t1 = t.time()
-		# raw_rank = await get_cache(start, stop, id)
-		# logger.debug(f'获取计数消息花费时间:{t.time() - t1}')
-	else:
-		t1 = t.time()
-		messages = await get_message_records(
-			scene_ids=[id],
-			types=['message'],  # 排除机器人自己发的消息
-			time_start=start,
-			time_stop=stop,
-			exclude_user_ids=plugin_config.excluded_people,
-		)
-		raw_rank = msg_counter(messages, keyword)
-		logger.debug(f'获取计数消息花费时间:{t.time() - t1}')
+	t1 = t.time()
+	raw_rank = await get_user_message_counts(
+		keyword=keyword,
+		scene_ids=[id],
+		types=['message'],  # 排除机器人自己发的消息
+		time_start=start,
+		time_stop=stop,
+		exclude_user_ids=plugin_config.excluded_people,
+	)
+	logger.debug(f'获取计数消息花费时间:{t.time() - t1}')

 	if not raw_rank:
 		await saa.Text(
--- a/nonebot_plugin_dialectlist/config.py
+++ b/nonebot_plugin_dialectlist/config.py
@@ -5,24 +5,25 @@ from pydantic import BaseModel


 class ScopedConfig(BaseModel):
-    get_num: int = 5  # 获取人数数量
-    font: str = "SimHei"  # 字体格式
-    suffix: bool = True  # 是否显示后缀
-    excluded_self: bool = True  # 是否排除自己
-    visualization: bool = True  # 是否可视化
-    show_text_rank: bool = True  # 是否显示文本排名
-    counting_cache: bool = False  # 计数缓存(能够提高回复速度)
-    excluded_people: List[str] = []  # 排除的人的QQ号
-    use_user_info_cache: bool = False  # 是否使用用户信息缓存
-    aggregate_transmission: bool = False  # 是否聚合转发消息
-    timezone: Optional[str] = "Asia/Shanghai"  # 时区，影响统计时间
-    string_suffix: str = "统计花费时间:{timecost}秒"  # 消息格式后缀
-    template_path: str = "./template/rank_template.j2"  # 模板路径
-    string_format: str = "第{index}名：\n{nickname},{chatdatanum}条消息\n"  # 消息格式
+	get_num: int = 5  # 获取人数数量
+	font: str = 'SimHei'  # 字体格式
+	suffix: bool = True  # 是否显示后缀
+	excluded_self: bool = True  # 是否排除自己
+	visualization: bool = True  # 是否可视化
+	show_text_rank: bool = True  # 是否显示文本排名
+	excluded_people: List[str] = []  # 排除的人的QQ号
+	use_user_info_cache: bool = False  # 是否使用用户信息缓存
+	aggregate_transmission: bool = False  # 是否聚合转发消息
+	timezone: Optional[str] = 'Asia/Shanghai'  # 时区，影响统计时间
+	string_suffix: str = '统计花费时间:{timecost}秒'  # 消息格式后缀
+	template_path: str = './template/rank_template.j2'  # 模板路径
+	string_format: str = (
+		'第{index}名：\n{nickname},{chatdatanum}条消息\n'  # 消息格式
+	)


 class Config(BaseModel):
-    dialectlist: ScopedConfig = ScopedConfig()
+	dialectlist: ScopedConfig = ScopedConfig()


 global_config = get_driver().config
--- a/nonebot_plugin_dialectlist/migrations/fb88e4d27eb8_update_dialectlist.py
+++ b/nonebot_plugin_dialectlist/migrations/fb88e4d27eb8_update_dialectlist.py
@@ -1,47 +0,0 @@
-"""update dialectlist
-
-迁移 ID: fb88e4d27eb8
-父迁移: 60daff81fcdc
-创建时间: 2025-04-20 11:00:50.931679
-
-"""
-from __future__ import annotations
-
-from collections.abc import Sequence
-
-from alembic import op
-import sqlalchemy as sa
-
-
-revision: str = 'fb88e4d27eb8'
-down_revision: str | Sequence[str] | None = '60daff81fcdc'
-branch_labels: str | Sequence[str] | None = None
-depends_on: str | Sequence[str] | None = None
-
-
-def upgrade(name: str = "") -> None:
-    if name:
-        return
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.create_table('sessionmodel',
-    sa.Column('id', sa.Integer(), nullable=False),
-    sa.Column('bot_id', sa.String(length=64), nullable=False),
-    sa.Column('bot_type', sa.String(length=32), nullable=False),
-    sa.Column('platform', sa.String(length=32), nullable=False),
-    sa.Column('level', sa.Integer(), nullable=False),
-    sa.Column('id1', sa.String(length=64), nullable=False),
-    sa.Column('id2', sa.String(length=64), nullable=False),
-    sa.Column('id3', sa.String(length=64), nullable=False),
-    sa.PrimaryKeyConstraint('id', name=op.f('pk_sessionmodel')),
-    sa.UniqueConstraint('bot_id', 'bot_type', 'platform', 'level', 'id1', 'id2', 'id3', name='unique_session'),
-    info={'bind_key': ''}
-    )
-    # ### end Alembic commands ###
-
-
-def downgrade(name: str = "") -> None:
-    if name:
-        return
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_table('sessionmodel')
-    # ### end Alembic commands ###
--- a/nonebot_plugin_dialectlist/model.py
+++ b/nonebot_plugin_dialectlist/model.py
@@ -1,23 +0,0 @@
-from datetime import datetime
-from typing import Union
-
-from nonebot_plugin_orm import Model
-from nonebot_plugin_userinfo import UserInfo
-from sqlalchemy import Integer
-from sqlalchemy.orm import Mapped, mapped_column
-
-
-class UserRankInfo(UserInfo):
-    user_bnum: int
-    user_proportion: float
-    user_nickname: str
-    user_index: Union[int, str]
-    user_avatar_bytes: bytes
-
-
-class MessageCountCache(Model):
-    __table_args__ = {"extend_existing": True}
-    id: Mapped[int] = mapped_column(primary_key=True, autoincrement=True)
-    time: Mapped[datetime]
-    session_id: Mapped[int] = mapped_column(Integer, index=True)
-    session_bnum: Mapped[int] = mapped_column(Integer)
--- a/nonebot_plugin_dialectlist/schema.py
+++ b/nonebot_plugin_dialectlist/schema.py
@@ -0,0 +1,11 @@
+from typing import Union
+
+from nonebot_plugin_userinfo import UserInfo
+
+
+class UserRankInfo(UserInfo):
+	user_bnum: int
+	user_proportion: float
+	user_nickname: str
+	user_index: Union[int, str]
+	user_avatar_bytes: bytes
--- a/nonebot_plugin_dialectlist/storage.py
+++ b/nonebot_plugin_dialectlist/storage.py
@@ -1,136 +0,0 @@
-import json
-import os
-from datetime import datetime
-
-from nonebot import get_driver
-from nonebot.adapters import Bot, Event
-from nonebot.log import logger
-from nonebot.message import event_postprocessor
-from nonebot.params import Depends
-from nonebot_plugin_chatrecorder import get_message_records
-from nonebot_plugin_chatrecorder.utils import remove_timezone
-from nonebot_plugin_uninfo import Session, get_session
-from nonebot_plugin_uninfo.orm import SessionModel,get_session_persist_id
-from nonebot_plugin_localstore import get_data_file
-from nonebot_plugin_orm import get_session
-from sqlalchemy import delete, or_, select
-
-from .config import plugin_config
-from .model import MessageCountCache
-
-
-async def get_cache(time_start: datetime, time_stop: datetime, group_id: str):
-    async with get_session() as db_session:
-        where = [or_(SessionModel.id2 == group_id)]
-        statement = select(SessionModel).where(*where)
-
-        sessions = (await db_session.scalars(statement)).all()
-
-        where = [
-            or_(*[MessageCountCache.session_id == session.id for session in sessions])
-        ]
-        statement = select(MessageCountCache).where(*where)
-        where.append(or_(MessageCountCache.time >= remove_timezone(time_start)))
-        where.append(or_(MessageCountCache.time <= remove_timezone(time_stop)))
-        statement = select(MessageCountCache).where(*where)
-
-        user_caches = (await db_session.scalars(statement)).all()
-        raw_rank = {}
-        for i in user_caches:
-            raw_rank[i.session_id] = raw_rank.get(i.session_id, 0) + i.session_bnum
-        return raw_rank
-
-
-async def build_cache():
-    async with get_session() as db_session:
-        await db_session.execute(delete(MessageCountCache))
-        await db_session.commit()
-    logger.info("先前可能存在的缓存已清空")
-    messages = await get_message_records(types=["message"])
-    async with get_session() as db_session:
-        for msg in messages:
-            msg_session_id = msg.session_persist_id
-
-            where = [or_(MessageCountCache.session_id == msg_session_id)]
-            where.append(
-                or_(
-                    MessageCountCache.time
-                    == remove_timezone(
-                        msg.time.replace(hour=1, minute=0, second=0, microsecond=0)
-                    )
-                )
-            )
-            statement = select(MessageCountCache).where(*where)
-
-            user_cache = (await db_session.scalars(statement)).all()
-
-            if user_cache:
-                user_cache[0].session_bnum += 1
-            else:
-                user_cache = MessageCountCache(
-                    session_id=msg.session_persist_id,
-                    time=remove_timezone(
-                        msg.time.replace(hour=1, minute=0, second=0, microsecond=0)
-                    ),
-                    session_bnum=1,
-                )
-                db_session.add(user_cache)
-            await db_session.commit()
-
-    logger.info("缓存构建完成")
-
-
-driver = get_driver()
-
-
-@driver.on_startup
-async def _():
-    if not plugin_config.counting_cache:
-        return
-    f_name = get_data_file("nonebot-plugin-dialectlist", "is-pre-cached.json")
-    if not os.path.exists(f_name):
-        with open(f_name, "w", encoding="utf-8") as f:
-            s = json.dumps({"is-pre-cached": False}, ensure_ascii=False, indent=4)
-            f.write(s)
-
-    with open(f_name, "r", encoding="utf-8") as f:
-        if json.load(f)["is-pre-cached"]:
-            return
-    logger.info("未检查到缓存，开始构建缓存")
-    with open(f_name, "w", encoding="utf-8") as f:
-        await build_cache()
-        json.dump({"is-pre-cached": True}, f, ensure_ascii=False, indent=4)
-
-
-@event_postprocessor
-async def _(bot: Bot, event: Event, session: Session = Depends(extract_session)):
-    if not plugin_config.counting_cache:
-        return
-    if not session.id2:
-        return
-    if event.get_type() != "message":
-        return
-    now = datetime.now()
-    now = now.replace(hour=1, minute=0, second=0, microsecond=0)
-
-    async with get_session() as db_session:
-        session_id = await get_session_persist_id(session)
-        logger.debug("session_id:" + str(session_id))
-        where = [or_(MessageCountCache.session_id == session_id)]
-        where.append(or_(MessageCountCache.time == remove_timezone(now)))
-        statement = select(MessageCountCache).where(*where)
-        user_cache = (await db_session.scalars(statement)).first()
-        if user_cache:
-            user_cache.session_bnum += 1
-        else:
-            user_cache = MessageCountCache(
-                session_id=session_id,
-                time=remove_timezone(now),
-                session_bnum=1,
-            )
-            db_session.add(user_cache)
-        await db_session.commit()
-    logger.debug("已计入缓存")
-
-
-# TODO: 修复缓存储存
--- a/nonebot_plugin_dialectlist/usage.py
+++ b/nonebot_plugin_dialectlist/usage.py
@@ -1,7 +1,7 @@
 from inspect import cleandoc

 __usage__ = cleandoc(
-    """
+	"""
 快速调用：
 /今日B话榜 ————看看今天群友发了多少消息。

@@ -18,7 +18,7 @@ __usage__ = cleandoc(
 -`/前日B话榜` ————看看前天的群友发了多少消息！

 -`/本周B话榜` ————看看本周的群友发了多少消息！
-  
+
 -`/上周B话榜` ————看看上周的群友发了多少消息！

 -`/本月B话榜` ————看看这个月的群友发了多少消息！
--- a/nonebot_plugin_dialectlist/utils.py
+++ b/nonebot_plugin_dialectlist/utils.py
@@ -2,9 +2,11 @@ import asyncio
 import os
 import re
 import unicodedata
-from typing import Dict, List, Optional
+from typing import Dict, List, Optional, Any

 import httpx
+from sqlalchemy import select, func
+
 from nonebot.adapters import Bot, Event
 from nonebot.compat import model_dump
 from nonebot.log import logger
@@ -20,10 +22,11 @@ from nonebot_plugin_uninfo.model import SceneType
 from nonebot_plugin_uninfo.orm import SessionModel, UserModel
 from nonebot_plugin_uninfo import get_session as extract_session
 from nonebot_plugin_userinfo.exception import NetworkError
-from sqlalchemy import or_, select
+from nonebot_plugin_chatrecorder.record import filter_statement
+

 from .config import plugin_config
-from .model import UserRankInfo
+from .schema import UserRankInfo

 cache_path = get_cache_dir('nonebot_plugin_dialectlist')

@@ -38,65 +41,29 @@ async def ensure_group(

 async def persist_id2user_id(ids: List) -> List[str]:
 	user_ids = []
-	user_persist_ids = []
+	if not ids:
+		return user_ids
+
 	async with get_session() as db_session:
-		for i in ids:
-			session = await db_session.scalar(
-				select(SessionModel).where(or_(*[SessionModel.id == i]))
-			)
-			if session is not None:
-				user_persist_id = session.user_persist_id
-				user_persist_ids.append(user_persist_id)
-		for i in user_persist_ids:
-			user = await db_session.scalar(
-				select(UserModel).where(UserModel.id == i)
-			)
-			if user is not None:
-				user_ids.append(user.user_id)
+		statement = (
+			select(UserModel.user_id)
+			.join(SessionModel, UserModel.id == SessionModel.user_persist_id)
+			.where(SessionModel.id.in_(ids))
+		)
+		result = await db_session.scalars(statement)
+		user_ids = result.all()

-	return user_ids
+	return list(user_ids)


-def msg_counter(
-	msg_list: List[MessageRecord], keyword: Optional[str]
-) -> Dict[str, int]:
-	"""### 计算每个人的消息量
-
-	Args:
-	    msg_list (list[MessageRecord]): 需要处理的消息列表
-
-	Returns:
-	    (dict[str,int]): 处理后的消息数量字典,键为用户,值为消息数量
-	"""
-
-	lst: Dict[str, int] = {}
-	msg_len = len(msg_list)
-	logger.info('wow , there are {} msgs to count !!!'.format(msg_len))
-
-	for i in msg_list:
-		# logger.debug(f"processing msg {i.plain_text}")
-		if keyword:
-			match = re.search(keyword, i.plain_text)
-			if not match:
-				continue
-		try:
-			lst[str(i.session_persist_id)] += 1
-		except KeyError:
-			lst[str(i.session_persist_id)] = 1
-
-	logger.debug(f'finish counting, result is {lst}')
-
-	return lst
-
-
-def got_rank(msg_dict: Dict[str, int]) -> List:
+def got_rank(msg_dict: Dict[int, int]) -> List[List[Any]]:
 	"""### 获得排行榜

 	Args:
-	    msg_dict (Dict[str,int]): 要处理的字典
+	    msg_dict (Dict[int,int]): 要处理的字典

 	Returns:
-	    List[Tuple[str,int]]: 排行榜列表(已排序)
+	    List[Tuple[int,int]]: 排行榜列表(已排序)
 	"""
 	rank = []
 	while len(rank) < plugin_config.get_num:
@@ -261,3 +228,42 @@ async def get_user_infos(
 		rank2.append(user)

 	return rank2
+
+
+async def get_user_message_counts(
+	keyword: Optional[str] = None, **kwargs
+) -> Dict[int, int]:
+	"""获取每个用户的消息数量（直接在数据库层面统计）
+
+	参数:
+	  * ``keyword``: 可选，关键词，只统计包含该关键词的消息
+	  * ``**kwargs``: 筛选参数，具体查看 `filter_statement` 中的定义
+
+	返回值:
+	  * ``Dict[str, int]``: 键为user_persist_id，值为该用户的消息数量
+	"""
+	whereclause = filter_statement(**kwargs)
+
+	# 如果提供了关键词，添加关键词过滤条件
+	if keyword:
+		# 构造LIKE条件，类似于msg_counter函数中的正则匹配
+		# 根据数据库类型不同，可能需要调整LIKE的语法
+		keyword_condition = MessageRecord.plain_text.ilike(f'%{keyword}%')
+		whereclause.append(keyword_condition)
+
+	# 使用SQL的GROUP BY和COUNT进行分组统计
+	statement = (
+		select(
+			SessionModel.user_persist_id,
+			func.count(MessageRecord.id).label('message_count'),
+		)
+		.select_from(MessageRecord)
+		.join(SessionModel, SessionModel.id == MessageRecord.session_persist_id)
+		.where(*whereclause)
+		.group_by(SessionModel.user_persist_id)
+	)
+
+	async with get_session() as db_session:
+		result = await db_session.execute(statement)
+		# 转换为字典格式返回
+		return {user_id: count for user_id, count in result.all()}
--- a/pdm.lock
+++ b/pdm.lock
@@ -5,7 +5,7 @@
 groups = ["default", "dev"]
 strategy = []
 lock_version = "4.5.0"
-content_hash = "sha256:42cf686b0618c9e80b1aae28a90a3d694e17da96b6a208ff2720f11d88ef4e4f"
+content_hash = "sha256:1e8f0e2bc32d8cf861a8342b7d90d683f0efc9cd94ac461dc65363788a365902"

 [[metadata.targets]]
 requires_python = ">=3.9,<3.13"
@@ -1805,7 +1805,7 @@ files = [

 [[package]]
 name = "twine"
-version = "6.1.0"
+version = "6.2.0"
 summary = ""
 dependencies = [
    "id",
@@ -1820,8 +1820,8 @@ dependencies = [
    "urllib3",
 ]
 files = [
-    {file = "twine-6.1.0-py3-none-any.whl", hash = "sha256:a47f973caf122930bf0fbbf17f80b83bc1602c9ce393c7845f289a3001dc5384"},
-    {file = "twine-6.1.0.tar.gz", hash = "sha256:be324f6272eff91d07ee93f251edf232fc647935dd585ac003539b42404a8dbd"},
+    {file = "twine-6.2.0-py3-none-any.whl", hash = "sha256:418ebf08ccda9a8caaebe414433b0ba5e25eb5e4a927667122fbe8f829f985d8"},
+    {file = "twine-6.2.0.tar.gz", hash = "sha256:e5ed0d2fd70c9959770dce51c8f39c8945c574e18173a7b81802dab51b4b75cf"},
 ]

 [[package]]
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "nonebot-plugin-dialectlist"
-version = "2.7.1"
+version = "3.0.1"
 description = "看看你群群友有多能说"
 authors = [{ name = "Chen_Xu233", email = "woyerpa@outlook.com" }]
 dependencies = [
@@ -12,7 +12,7 @@ dependencies = [
    "nonebot-plugin-userinfo>=0.2.6",
    "nonebot-plugin-htmlrender>=0.3.3",
    "nonebot2>=2.3.2",
-    "pillow>=10.4.0",
+    "pillow>=11.3.0",
    "nonebot-plugin-uninfo>=0.1.1",
 ]
 requires-python = ">=3.9,<4.0"
@@ -23,9 +23,9 @@ license = { text = "MIT" }
 [project.optional-dependencies]
 dev = [
    "ruff>=0.5.5",
-    "setuptools>=71.1.0",
-    "twine>=5.1.0",
-    "nb-cli>=0.7.6",
+    "setuptools>=80.9.0",
+    "twine>=6.2.0",
+    "nb-cli>=1.4.2",
    "py-spy>=0.3.14",
 ]
 Test = ["nonebot-adapter-onebot>=2.4.4"]
Author	SHA1	Message	Date
XuChenXu	b36e32fe19	🔖 Version 3.0.1	2025-09-22 21:45:54 +08:00
XuChenXu	bd195ac87a	🔖 Version 3.0.0	2025-09-22 21:40:56 +08:00
XuChenXu	152128391c	⚡ 超级性能提升	2025-09-22 21:26:19 +08:00