mirror of
https://github.com/ChenXu233/nonebot_plugin_dialectlist.git
synced 2026-01-26 13:42:00 +00:00
Compare commits
30 Commits
V2.4.3
...
0348a5d66c
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0348a5d66c | ||
|
|
aff02f2666 | ||
|
|
2f725e0808 | ||
|
|
3434a5352f | ||
|
|
0954eb4f3e | ||
|
|
5b94bc0fff | ||
|
|
e1a20922c4 | ||
|
|
5e00605dfb | ||
|
|
833cdb4a75 | ||
|
|
29b4598e5f | ||
|
|
10cc5cf278 | ||
|
|
ed167a56b5 | ||
|
|
b40c7be1f9 | ||
|
|
07f85be527 | ||
|
|
f2cdfe7f8a | ||
|
|
e0ca7907c0 | ||
|
|
53b2a33923 | ||
|
|
4e339bcdb1 | ||
|
|
0b85f6fb34 | ||
|
|
83d9cda2eb | ||
|
|
dfde832dba | ||
|
|
987b34e282 | ||
|
|
49ce2ffb7c | ||
|
|
fcce94250c | ||
|
|
53e52eabb5 | ||
|
|
633ffbde9a | ||
|
|
d7baa9b04b | ||
|
|
df2cd495c0 | ||
|
|
d2e185c189 | ||
|
|
d42140cc95 |
1
.vscode/settings.json
vendored
1
.vscode/settings.json
vendored
@@ -19,6 +19,7 @@
|
|||||||
"pygal",
|
"pygal",
|
||||||
"sqlalchemy",
|
"sqlalchemy",
|
||||||
"timecost",
|
"timecost",
|
||||||
|
"uninfo",
|
||||||
"userinfo",
|
"userinfo",
|
||||||
"whereclause",
|
"whereclause",
|
||||||
"xaxis",
|
"xaxis",
|
||||||
|
|||||||
117
README.md
117
README.md
@@ -26,15 +26,16 @@ nonebot-plugin-dialectlist
|
|||||||
|
|
||||||
## 💿 安装
|
## 💿 安装
|
||||||
|
|
||||||
通过`pip`或`nb`安装;
|
通过`pip`或`nb`安装:
|
||||||
|
- 通过 pip 安装
|
||||||
|
```bash
|
||||||
|
pip install nonebot-plugin-dialectlist
|
||||||
|
```
|
||||||
|
- 通过 nb-cli 安装
|
||||||
|
```bash
|
||||||
|
nb plugin install nonebot-plugin-dialectlist
|
||||||
|
```
|
||||||
|
|
||||||
>**通过 pip **安装
|
|
||||||
|
|
||||||
`pip install nonebot-plugin-dialectlist`
|
|
||||||
|
|
||||||
>**通过 nb **安装
|
|
||||||
|
|
||||||
`nb plugin install nonebot-plugin-dialectlist`
|
|
||||||
|
|
||||||
### ✅ 插件依赖于
|
### ✅ 插件依赖于
|
||||||
|
|
||||||
@@ -53,15 +54,20 @@ nonebot-plugin-dialectlist
|
|||||||
|
|
||||||
在 .env 中,可以添加以下配置项
|
在 .env 中,可以添加以下配置项
|
||||||
```python
|
```python
|
||||||
dialectlist__string_format = "第{index}名:\n{nickname},{chatdatanum}条消息、\n" #消息格式
|
dialectlist__get_num: int = 5 # 获取人数数量
|
||||||
dialectlist__get_num = 10 #获取人数数量
|
dialectlist__font: str = "SimHei" # 字体格式
|
||||||
dialectlist__visualization = True #是否可视化
|
dialectlist__suffix: bool = True # 是否显示后缀
|
||||||
# dialectlist__visualization_type = "圆环图" #可视化方案 (不再支持)
|
dialectlist__excluded_self: bool = True # 是否排除自己
|
||||||
dialectlist__font = "SimHei" #字体格式
|
dialectlist__visualization: bool = True # 是否可视化
|
||||||
dialectlist__excluded_people = [] #排除的人的 QQ 号(或频道号?(未经测试))
|
dialectlist__show_text_rank: bool = True # 是否显示文本排名
|
||||||
dialectlist__excluded_self = True #是否排除机器人自己 QQ
|
dialectlist__counting_cache: bool = False # 计数缓存(能够提高回复速度)
|
||||||
dialectlist__suffix: bool = False # 是否显示后缀
|
dialectlist__excluded_people: List[str] = [] # 排除的人的QQ号
|
||||||
dialectlist__string_suffix: str = "统计花费时间{timecost}" # 消息格式后缀
|
dialectlist__use_user_info_cache: bool = False # 是否使用用户信息缓存
|
||||||
|
dialectlist__aggregate_transmission: bool = False # 是否聚合转发消息
|
||||||
|
dialectlist__timezone: Optional[str] = "Asia/Shanghai" # 时区,影响统计时间
|
||||||
|
dialectlist__string_suffix: str = "统计花费时间:{timecost}秒" # 消息格式后缀
|
||||||
|
dialectlist__template_path: str = "./template/rank_template.j2" # 模板路径
|
||||||
|
dialectlist__string_format: str = "第{index}名:\n{nickname},{chatdatanum}条消息\n" # 消息格式
|
||||||
```
|
```
|
||||||
💭也可以不进行配置,这将会使插件按照默认配置运行
|
💭也可以不进行配置,这将会使插件按照默认配置运行
|
||||||
|
|
||||||
@@ -69,6 +75,8 @@ dialectlist__string_suffix: str = "统计花费时间{timecost}" # 消息格式
|
|||||||
|
|
||||||
> 在旧版插件(2.0.0 以下)中,dialectlist 与后面的配置项只隔了一个下划线,若更新到新版本以后需要俩个下划线。
|
> 在旧版插件(2.0.0 以下)中,dialectlist 与后面的配置项只隔了一个下划线,若更新到新版本以后需要俩个下划线。
|
||||||
|
|
||||||
|
> 由于插件依赖chatrecord多次引入爆炸性修改,建议在遇到问题后优先尝试降级chatrecord插件
|
||||||
|
|
||||||
## 🗨命令
|
## 🗨命令
|
||||||
__!!注意!!__
|
__!!注意!!__
|
||||||
新版本指令调用方式改变,改为更易理解也更好打的 B 话榜。
|
新版本指令调用方式改变,改为更易理解也更好打的 B 话榜。
|
||||||
@@ -76,6 +84,8 @@ __!!注意!!__
|
|||||||
|
|
||||||
### 🎨一般用法
|
### 🎨一般用法
|
||||||
|
|
||||||
|
#### B话榜
|
||||||
|
|
||||||
-`/B话榜` ————看看有史以来(机器人存在以来)群友们发了多少消息! (好像没写)
|
-`/B话榜` ————看看有史以来(机器人存在以来)群友们发了多少消息! (好像没写)
|
||||||
|
|
||||||
-`/今日B话榜` ————看看今天的群友发了多少消息!
|
-`/今日B话榜` ————看看今天的群友发了多少消息!
|
||||||
@@ -94,11 +104,37 @@ __!!注意!!__
|
|||||||
|
|
||||||
-`/历史B话榜` ————看看历史上(机器人存在以来)的群友发了多少消息!
|
-`/历史B话榜` ————看看历史上(机器人存在以来)的群友发了多少消息!
|
||||||
|
|
||||||
|
#### 看看B话(kkb)
|
||||||
|
|
||||||
|
-`/看看B话 [@某人|QQ号]` ————看看这个b人在这个b群发了多少b话!
|
||||||
|
|
||||||
### 🚀进阶用法
|
### 🚀进阶用法
|
||||||
|
|
||||||
`/{时间类型(今日|年度)?}{B话榜|废话榜} {时间类型?} {ISO8601 格式时间} {群号}`
|
#### B话榜
|
||||||
|
|
||||||
如:`/B话榜 历史 2024-01-01~2024-01-02 12345678`
|
`/{时间类型(今日|年度)?}{B话榜|废话榜} {时间类型?} {ISO8601 格式时间 ?} {群号} {关键词}`
|
||||||
|
|
||||||
|
如:`/B话榜 历史 2024-01-01~2024-01-02 12345678 女装`
|
||||||
|
|
||||||
|
也可以 `/{时间类型(今日|年度)?}{B话榜|废话榜} {时间类型?} {ISO8601 格式时间 ?} -g {群号} -k {关键词}`
|
||||||
|
|
||||||
|
以下调用方法均合法:
|
||||||
|
|
||||||
|
`/今日B话榜 -g 12345678 -k 女装`
|
||||||
|
`/昨日B话榜 -k 女装`
|
||||||
|
`/本周B话榜 -g 12345678`
|
||||||
|
|
||||||
|
#### 看看B话
|
||||||
|
|
||||||
|
`/看看B话 {@|QQ号} {群号?} {关键词?}`
|
||||||
|
|
||||||
|
以下调用方法均合法:
|
||||||
|
|
||||||
|
`/kkb 114514 1919810 ♂`
|
||||||
|
`/kkb @man -k ♂`
|
||||||
|
|
||||||
|
> [!IMPORTANT]
|
||||||
|
> 关键词支持正则表达式!
|
||||||
|
|
||||||
## 💪 目前支持的平台
|
## 💪 目前支持的平台
|
||||||
|
|
||||||
@@ -134,6 +170,9 @@ __!!注意!!__
|
|||||||
|
|
||||||
</details>
|
</details>
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
|
||||||
### 💕感谢
|
### 💕感谢
|
||||||
|
|
||||||
本插件的__init__.py 中的处理函数参考了词云中的方法 ~~(其实大部分都是 Ctrl+C Ctr+V)~~
|
本插件的__init__.py 中的处理函数参考了词云中的方法 ~~(其实大部分都是 Ctrl+C Ctr+V)~~
|
||||||
@@ -158,46 +197,14 @@ __!!注意!!__
|
|||||||
|
|
||||||
- [x] 私聊的查询(超级用户可以任意查询群聊的信息)一半完成
|
- [x] 私聊的查询(超级用户可以任意查询群聊的信息)一半完成
|
||||||
|
|
||||||
- [ ] 特殊的储存方案优化消息统计
|
- [x] 特殊的储存方案优化消息统计
|
||||||
|
|
||||||
- [ ] 查询带某关键词的消息量
|
- [x] 查询带某关键词的消息量
|
||||||
|
|
||||||
|
- [x] 合并转发
|
||||||
|
|
||||||
待补充。.....
|
待补充。.....
|
||||||
|
|
||||||
## 📖版本
|
|
||||||
|
|
||||||
### V1.0
|
|
||||||
|
|
||||||
- 看看群里群友能有多话痨
|
|
||||||
|
|
||||||
### V1.1
|
|
||||||
|
|
||||||
- 支持频道咯!(*^_^*)
|
|
||||||
|
|
||||||
### V1.2
|
|
||||||
|
|
||||||
- 排行榜可视化
|
|
||||||
|
|
||||||
### V1.3
|
|
||||||
|
|
||||||
- 添加了一些可配置项
|
|
||||||
|
|
||||||
### V1.4
|
|
||||||
|
|
||||||
- 适配新版本的 chatrecorder, 暂时停止频道支持
|
|
||||||
|
|
||||||
### V2.0
|
|
||||||
|
|
||||||
- 理论支持全平台!暂停图片支持。
|
|
||||||
|
|
||||||
|
|
||||||
### V2.1
|
|
||||||
|
|
||||||
- 恢复图片支持。
|
|
||||||
|
|
||||||
### V2.2
|
|
||||||
|
|
||||||
- 优化代码,添加一些新的可配置项。
|
|
||||||
|
|
||||||
### 👾题外话
|
### 👾题外话
|
||||||
~~整个项目快被我写成屎山了~~
|
~~整个项目快被我写成屎山了~~
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ require("nonebot_plugin_apscheduler")
|
|||||||
require("nonebot_plugin_htmlrender")
|
require("nonebot_plugin_htmlrender")
|
||||||
require("nonebot_plugin_userinfo")
|
require("nonebot_plugin_userinfo")
|
||||||
require("nonebot_plugin_alconna")
|
require("nonebot_plugin_alconna")
|
||||||
|
require("nonebot_plugin_uninfo")
|
||||||
require("nonebot_plugin_cesaa")
|
require("nonebot_plugin_cesaa")
|
||||||
|
|
||||||
import re
|
import re
|
||||||
@@ -23,13 +24,17 @@ from nonebot.params import Arg, Depends
|
|||||||
from nonebot.adapters import Bot, Event
|
from nonebot.adapters import Bot, Event
|
||||||
from nonebot.plugin import PluginMetadata, inherit_supported_adapters
|
from nonebot.plugin import PluginMetadata, inherit_supported_adapters
|
||||||
from nonebot_plugin_alconna import (
|
from nonebot_plugin_alconna import (
|
||||||
|
At,
|
||||||
Args,
|
Args,
|
||||||
|
Field,
|
||||||
|
Match,
|
||||||
Option,
|
Option,
|
||||||
Alconna,
|
Alconna,
|
||||||
on_alconna,
|
on_alconna,
|
||||||
)
|
)
|
||||||
from nonebot_plugin_chatrecorder import get_message_records
|
from nonebot_plugin_chatrecorder import get_message_records
|
||||||
from nonebot_plugin_session import Session, SessionIdType, extract_session
|
from nonebot_plugin_session import Session, SessionIdType, extract_session
|
||||||
|
from nonebot_plugin_uninfo import Uninfo
|
||||||
|
|
||||||
from .storage import get_cache, build_cache
|
from .storage import get_cache, build_cache
|
||||||
from .config import Config, plugin_config
|
from .config import Config, plugin_config
|
||||||
@@ -85,6 +90,63 @@ async def _build_cache(bot: Bot, event: Event):
|
|||||||
await saa.Text("重建缓存完成。").send(reply=True)
|
await saa.Text("重建缓存完成。").send(reply=True)
|
||||||
|
|
||||||
|
|
||||||
|
b_cmd = on_alconna(
|
||||||
|
Alconna(
|
||||||
|
"看看B话",
|
||||||
|
Args["at", [str, At], Field(completion=lambda: "请想要查询的人的QQ号")],
|
||||||
|
Option("-g|--group_id", Args["group_id?", str]),
|
||||||
|
Option("-k|--keyword", Args["keyword?", str]),
|
||||||
|
),
|
||||||
|
aliases={"kkb"},
|
||||||
|
use_cmd_start=True,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@b_cmd.handle()
|
||||||
|
async def handle_b_cmd(
|
||||||
|
at: Match[str | At],
|
||||||
|
group_id: Match[str],
|
||||||
|
keyword: Match[str],
|
||||||
|
uninfo: Uninfo,
|
||||||
|
session: Session = Depends(extract_session),
|
||||||
|
):
|
||||||
|
id = at.result
|
||||||
|
if isinstance(id, At):
|
||||||
|
id = id.target
|
||||||
|
if group_id.available:
|
||||||
|
gid = group_id.result
|
||||||
|
else:
|
||||||
|
gid = session.id2
|
||||||
|
|
||||||
|
if not gid:
|
||||||
|
await b_cmd.finish("请指定群号。")
|
||||||
|
|
||||||
|
if keyword.available:
|
||||||
|
keywords = keyword.result
|
||||||
|
else:
|
||||||
|
keywords = None
|
||||||
|
|
||||||
|
messages = await get_message_records(
|
||||||
|
id1s=[id],
|
||||||
|
id2s=[gid],
|
||||||
|
id_type=SessionIdType.GROUP,
|
||||||
|
include_bot_id=False,
|
||||||
|
include_bot_type=False,
|
||||||
|
types=["message"], # 排除机器人自己发的消息
|
||||||
|
exclude_id1s=plugin_config.excluded_people,
|
||||||
|
)
|
||||||
|
d = msg_counter(messages, keywords)
|
||||||
|
rank = got_rank(d)
|
||||||
|
if not rank:
|
||||||
|
await b_cmd.finish(
|
||||||
|
f"该用户在群“{uninfo.scene.name}”关于“{keyword}”的B话数量为0。"
|
||||||
|
)
|
||||||
|
|
||||||
|
await saa.Text(
|
||||||
|
f"该用户在群“{uninfo.scene.name}”关于“{keyword}”的B话数量为{rank[0][1]}。"
|
||||||
|
).send(reply=True)
|
||||||
|
|
||||||
|
|
||||||
rank_cmd = on_alconna(
|
rank_cmd = on_alconna(
|
||||||
Alconna(
|
Alconna(
|
||||||
"B话榜",
|
"B话榜",
|
||||||
@@ -93,6 +155,7 @@ rank_cmd = on_alconna(
|
|||||||
str,
|
str,
|
||||||
],
|
],
|
||||||
Option("-g|--group_id", Args["group_id?", str]),
|
Option("-g|--group_id", Args["group_id?", str]),
|
||||||
|
Option("-k|--keyword", Args["keyword?", str]),
|
||||||
behaviors=[SameTime()],
|
behaviors=[SameTime()],
|
||||||
),
|
),
|
||||||
aliases={"废话榜"},
|
aliases={"废话榜"},
|
||||||
@@ -129,6 +192,7 @@ async def _group_message(
|
|||||||
type: Optional[str] = None,
|
type: Optional[str] = None,
|
||||||
time: Optional[str] = None,
|
time: Optional[str] = None,
|
||||||
group_id: Optional[str] = None,
|
group_id: Optional[str] = None,
|
||||||
|
keyword: Optional[str] = None,
|
||||||
):
|
):
|
||||||
t1 = t.time()
|
t1 = t.time()
|
||||||
state["t1"] = t1
|
state["t1"] = t1
|
||||||
@@ -140,6 +204,8 @@ async def _group_message(
|
|||||||
if group_id:
|
if group_id:
|
||||||
state["group_id"] = group_id
|
state["group_id"] = group_id
|
||||||
|
|
||||||
|
state["keyword"] = keyword
|
||||||
|
|
||||||
if not type:
|
if not type:
|
||||||
await rank_cmd.finish(__plugin_meta__.usage)
|
await rank_cmd.finish(__plugin_meta__.usage)
|
||||||
|
|
||||||
@@ -226,7 +292,11 @@ async def handle_rank(
|
|||||||
if not id:
|
if not id:
|
||||||
await saa.Text("没有指定群哦").finish()
|
await saa.Text("没有指定群哦").finish()
|
||||||
|
|
||||||
|
keyword = state["keyword"]
|
||||||
|
|
||||||
if plugin_config.counting_cache:
|
if plugin_config.counting_cache:
|
||||||
|
if keyword:
|
||||||
|
await saa.Text("已开启缓存~缓存不支持关键词查询哦").finish()
|
||||||
t1 = t.time()
|
t1 = t.time()
|
||||||
raw_rank = await get_cache(start, stop, id)
|
raw_rank = await get_cache(start, stop, id)
|
||||||
logger.debug(f"获取计数消息花费时间:{t.time() - t1}")
|
logger.debug(f"获取计数消息花费时间:{t.time() - t1}")
|
||||||
@@ -242,11 +312,13 @@ async def handle_rank(
|
|||||||
time_stop=stop,
|
time_stop=stop,
|
||||||
exclude_id1s=plugin_config.excluded_people,
|
exclude_id1s=plugin_config.excluded_people,
|
||||||
)
|
)
|
||||||
raw_rank = msg_counter(messages)
|
raw_rank = msg_counter(messages, keyword)
|
||||||
logger.debug(f"获取计数消息花费时间:{t.time() - t1}")
|
logger.debug(f"获取计数消息花费时间:{t.time() - t1}")
|
||||||
|
|
||||||
if not raw_rank:
|
if not raw_rank:
|
||||||
await saa.Text("明明这个时间段都没有人说话怎么会有话痨榜呢?").finish()
|
await saa.Text(
|
||||||
|
"没有获取到排行榜数据哦,请确认时间范围和群号是否正确或者关键词是否存在~"
|
||||||
|
).finish()
|
||||||
|
|
||||||
rank = got_rank(raw_rank)
|
rank = got_rank(raw_rank)
|
||||||
ids = await persist_id2user_id([int(i[0]) for i in rank])
|
ids = await persist_id2user_id([int(i[0]) for i in rank])
|
||||||
@@ -259,6 +331,13 @@ async def handle_rank(
|
|||||||
logger.debug(f"获取用户信息花费时间:{t.time() - t1}")
|
logger.debug(f"获取用户信息花费时间:{t.time() - t1}")
|
||||||
|
|
||||||
string: str = ""
|
string: str = ""
|
||||||
|
if plugin_config.show_text_rank:
|
||||||
|
|
||||||
|
if keyword:
|
||||||
|
string += f"关于{keyword}的话痨榜结果:\n"
|
||||||
|
else:
|
||||||
|
string += "话痨榜:\n"
|
||||||
|
|
||||||
for i in rank2:
|
for i in rank2:
|
||||||
logger.debug(i.user_name)
|
logger.debug(i.user_name)
|
||||||
for i in range(len(rank2)):
|
for i in range(len(rank2)):
|
||||||
@@ -270,17 +349,21 @@ async def handle_rank(
|
|||||||
string += str_example
|
string += str_example
|
||||||
|
|
||||||
msg = saa.Text(string)
|
msg = saa.Text(string)
|
||||||
t1 = t.time()
|
|
||||||
|
|
||||||
if plugin_config.visualization:
|
if plugin_config.visualization:
|
||||||
|
t1 = t.time()
|
||||||
image = await get_rank_image(rank2)
|
image = await get_rank_image(rank2)
|
||||||
msg += saa.Image(image)
|
msg += saa.Image(image)
|
||||||
|
logger.debug(f"群聊消息渲染图片花费时间:{t.time() - t1}")
|
||||||
|
|
||||||
if plugin_config.suffix:
|
if plugin_config.suffix:
|
||||||
timecost = t.time() - state["t1"]
|
timecost = t.time() - state["t1"]
|
||||||
suffix = saa.Text(plugin_config.string_suffix.format(timecost=timecost))
|
suffix = saa.Text(plugin_config.string_suffix.format(timecost=timecost))
|
||||||
msg += suffix
|
msg += suffix
|
||||||
|
if not msg:
|
||||||
|
await saa.Text("你把可视化都关了哪来的排行榜?").finish()
|
||||||
|
|
||||||
logger.debug(f"群聊消息渲染图片花费时间:{t.time() - t1}")
|
if plugin_config.aggregate_transmission:
|
||||||
|
await saa.AggregatedMessageFactory([msg]).finish()
|
||||||
|
else:
|
||||||
await msg.finish(reply=True)
|
await msg.finish(reply=True)
|
||||||
|
|||||||
@@ -9,9 +9,11 @@ class ScopedConfig(BaseModel):
|
|||||||
suffix: bool = True # 是否显示后缀
|
suffix: bool = True # 是否显示后缀
|
||||||
excluded_self: bool = True # 是否排除自己
|
excluded_self: bool = True # 是否排除自己
|
||||||
visualization: bool = True # 是否可视化
|
visualization: bool = True # 是否可视化
|
||||||
|
show_text_rank: bool = True # 是否显示文本排名
|
||||||
counting_cache: bool = False # 计数缓存(能够提高回复速度)
|
counting_cache: bool = False # 计数缓存(能够提高回复速度)
|
||||||
excluded_people: List[str] = [] # 排除的人的QQ号
|
excluded_people: List[str] = [] # 排除的人的QQ号
|
||||||
use_user_info_cache: bool = False # 是否使用用户信息缓存
|
use_user_info_cache: bool = False # 是否使用用户信息缓存
|
||||||
|
aggregate_transmission: bool = False # 是否聚合转发消息
|
||||||
timezone: Optional[str] = "Asia/Shanghai" # 时区,影响统计时间
|
timezone: Optional[str] = "Asia/Shanghai" # 时区,影响统计时间
|
||||||
string_suffix: str = "统计花费时间:{timecost}秒" # 消息格式后缀
|
string_suffix: str = "统计花费时间:{timecost}秒" # 消息格式后缀
|
||||||
template_path: str = "./template/rank_template.j2" # 模板路径
|
template_path: str = "./template/rank_template.j2" # 模板路径
|
||||||
|
|||||||
61
nonebot_plugin_dialectlist/migrations/873ad3421460_.py
Normal file
61
nonebot_plugin_dialectlist/migrations/873ad3421460_.py
Normal file
@@ -0,0 +1,61 @@
|
|||||||
|
"""empty message
|
||||||
|
|
||||||
|
迁移 ID: 873ad3421460
|
||||||
|
父迁移:
|
||||||
|
创建时间: 2025-03-29 14:30:11.910461
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
from collections.abc import Sequence
|
||||||
|
|
||||||
|
import sqlalchemy as sa
|
||||||
|
from alembic import op
|
||||||
|
|
||||||
|
revision: str = "873ad3421460"
|
||||||
|
down_revision: str | Sequence[str] | None = None
|
||||||
|
branch_labels: str | Sequence[str] | None = ("nonebot_plugin_dialectlist",)
|
||||||
|
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(
|
||||||
|
"nonebot_plugin_dialectlist_messagecountcache",
|
||||||
|
sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column("time", sa.DateTime(), nullable=False),
|
||||||
|
sa.Column("session_id", sa.Integer(), nullable=False),
|
||||||
|
sa.Column("session_bnum", sa.Integer(), nullable=False),
|
||||||
|
sa.PrimaryKeyConstraint(
|
||||||
|
"id", name=op.f("pk_nonebot_plugin_dialectlist_messagecountcache")
|
||||||
|
),
|
||||||
|
info={"bind_key": "nonebot_plugin_dialectlist"},
|
||||||
|
)
|
||||||
|
with op.batch_alter_table(
|
||||||
|
"nonebot_plugin_dialectlist_messagecountcache", schema=None
|
||||||
|
) as batch_op:
|
||||||
|
batch_op.create_index(
|
||||||
|
batch_op.f("ix_nonebot_plugin_dialectlist_messagecountcache_session_id"),
|
||||||
|
["session_id"],
|
||||||
|
unique=False,
|
||||||
|
)
|
||||||
|
|
||||||
|
# ### end Alembic commands ###
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade(name: str = "") -> None:
|
||||||
|
if name:
|
||||||
|
return
|
||||||
|
# ### commands auto generated by Alembic - please adjust! ###
|
||||||
|
with op.batch_alter_table(
|
||||||
|
"nonebot_plugin_dialectlist_messagecountcache", schema=None
|
||||||
|
) as batch_op:
|
||||||
|
batch_op.drop_index(
|
||||||
|
batch_op.f("ix_nonebot_plugin_dialectlist_messagecountcache_session_id")
|
||||||
|
)
|
||||||
|
|
||||||
|
op.drop_table("nonebot_plugin_dialectlist_messagecountcache")
|
||||||
|
# ### end Alembic commands ###
|
||||||
@@ -2,8 +2,59 @@ from inspect import cleandoc
|
|||||||
|
|
||||||
__usage__ = cleandoc(
|
__usage__ = cleandoc(
|
||||||
"""
|
"""
|
||||||
/今日B话榜 查看今天群里谁B话最多。
|
快速调用:
|
||||||
/昨日B话榜 顾名思义。
|
/今日B话榜 ————看看今天群友发了多少消息。
|
||||||
以此类推,有本周,本月,上周,上月,年度排行榜。
|
|
||||||
|
### 🎨一般用法
|
||||||
|
|
||||||
|
#### B话榜
|
||||||
|
|
||||||
|
-`/B话榜` ————看看有史以来(机器人存在以来)群友们发了多少消息! (好像没写)
|
||||||
|
|
||||||
|
-`/今日B话榜` ————看看今天的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/昨日B话榜` ————看看昨天的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/前日B话榜` ————看看前天的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/本周B话榜` ————看看本周的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/上周B话榜` ————看看上周的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/本月B话榜` ————看看这个月的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/年度B话榜` ————看看今年的群友发了多少消息!
|
||||||
|
|
||||||
|
-`/历史B话榜` ————看看历史上(机器人存在以来)的群友发了多少消息!
|
||||||
|
|
||||||
|
#### 看看B话(kkb)
|
||||||
|
|
||||||
|
-`/看看B话 [@某人|QQ号]` ————看看这个b人在这个b群发了多少b话!
|
||||||
|
|
||||||
|
### 🚀进阶用法
|
||||||
|
|
||||||
|
#### B话榜
|
||||||
|
|
||||||
|
`/{时间类型(今日|年度)?}{B话榜|废话榜} {时间类型?} {ISO8601 格式时间 ?} {群号} {关键词}`
|
||||||
|
|
||||||
|
如:`/B话榜 历史 2024-01-01~2024-01-02 12345678 女装`
|
||||||
|
|
||||||
|
也可以 `/{时间类型(今日|年度)?}{B话榜|废话榜} {时间类型?} {ISO8601 格式时间 ?} -g {群号} -k {关键词}`
|
||||||
|
|
||||||
|
以下调用方法均合法:
|
||||||
|
|
||||||
|
`/今日B话榜 -g 12345678 -k 女装`
|
||||||
|
`/昨日B话榜 -k 女装`
|
||||||
|
`/本周B话榜 -g 12345678`
|
||||||
|
|
||||||
|
#### 看看B话
|
||||||
|
|
||||||
|
`/看看B话 {@|QQ号} {群号?} {关键词?}`
|
||||||
|
|
||||||
|
以下调用方法均合法:
|
||||||
|
|
||||||
|
`/kkb 114514 1919810 ♂`
|
||||||
|
`/kkb @man -k ♂`
|
||||||
|
|
||||||
"""
|
"""
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1,9 +1,10 @@
|
|||||||
import os
|
import os
|
||||||
|
import re
|
||||||
import httpx
|
import httpx
|
||||||
import asyncio
|
import asyncio
|
||||||
import unicodedata
|
import unicodedata
|
||||||
|
|
||||||
from typing import Dict, List
|
from typing import Dict, List, Optional
|
||||||
from sqlalchemy import or_, select
|
from sqlalchemy import or_, select
|
||||||
from sqlalchemy.sql import ColumnElement
|
from sqlalchemy.sql import ColumnElement
|
||||||
|
|
||||||
@@ -77,7 +78,9 @@ async def persist_id2group_id(ids: List[str]) -> List[str]:
|
|||||||
return [i.id2 for i in records]
|
return [i.id2 for i in records]
|
||||||
|
|
||||||
|
|
||||||
def msg_counter(msg_list: List[MessageRecord]) -> Dict[str, int]:
|
def msg_counter(
|
||||||
|
msg_list: List[MessageRecord], keyword: Optional[str]
|
||||||
|
) -> Dict[str, int]:
|
||||||
"""### 计算每个人的消息量
|
"""### 计算每个人的消息量
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
@@ -92,6 +95,11 @@ def msg_counter(msg_list: List[MessageRecord]) -> Dict[str, int]:
|
|||||||
logger.info("wow , there are {} msgs to count !!!".format(msg_len))
|
logger.info("wow , there are {} msgs to count !!!".format(msg_len))
|
||||||
|
|
||||||
for i in msg_list:
|
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:
|
try:
|
||||||
lst[str(i.session_persist_id)] += 1
|
lst[str(i.session_persist_id)] += 1
|
||||||
except KeyError:
|
except KeyError:
|
||||||
|
|||||||
8
pdm.lock
generated
8
pdm.lock
generated
@@ -5,7 +5,7 @@
|
|||||||
groups = ["default", "Test", "dev"]
|
groups = ["default", "Test", "dev"]
|
||||||
strategy = ["inherit_metadata"]
|
strategy = ["inherit_metadata"]
|
||||||
lock_version = "4.5.0"
|
lock_version = "4.5.0"
|
||||||
content_hash = "sha256:882dfc18d7454ced6bb1f46e04172b14b83f90157475153bf0fff7b13e4d41a2"
|
content_hash = "sha256:41c1ac2ec7d9ce3eb477f442e6ccbeda65fb25eb4f22cd696d361dae97cb065c"
|
||||||
|
|
||||||
[[metadata.targets]]
|
[[metadata.targets]]
|
||||||
requires_python = ">=3.9,<3.13"
|
requires_python = ">=3.9,<3.13"
|
||||||
@@ -267,7 +267,7 @@ name = "charset-normalizer"
|
|||||||
version = "3.3.2"
|
version = "3.3.2"
|
||||||
requires_python = ">=3.7.0"
|
requires_python = ">=3.7.0"
|
||||||
summary = "The Real First Universal Charset Detector. Open, modern and actively maintained alternative to Chardet."
|
summary = "The Real First Universal Charset Detector. Open, modern and actively maintained alternative to Chardet."
|
||||||
groups = ["default", "dev"]
|
groups = ["dev"]
|
||||||
files = [
|
files = [
|
||||||
{file = "charset-normalizer-3.3.2.tar.gz", hash = "sha256:f30c3cb33b24454a82faecaf01b19c18562b1e89558fb6c56de4d9118a032fd5"},
|
{file = "charset-normalizer-3.3.2.tar.gz", hash = "sha256:f30c3cb33b24454a82faecaf01b19c18562b1e89558fb6c56de4d9118a032fd5"},
|
||||||
{file = "charset_normalizer-3.3.2-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:25baf083bf6f6b341f4121c2f3c548875ee6f5339300e08be3f2b2ba1721cdd3"},
|
{file = "charset_normalizer-3.3.2-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:25baf083bf6f6b341f4121c2f3c548875ee6f5339300e08be3f2b2ba1721cdd3"},
|
||||||
@@ -1876,7 +1876,7 @@ name = "requests"
|
|||||||
version = "2.32.3"
|
version = "2.32.3"
|
||||||
requires_python = ">=3.8"
|
requires_python = ">=3.8"
|
||||||
summary = "Python HTTP for Humans."
|
summary = "Python HTTP for Humans."
|
||||||
groups = ["default", "dev"]
|
groups = ["dev"]
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"certifi>=2017.4.17",
|
"certifi>=2017.4.17",
|
||||||
"charset-normalizer<4,>=2",
|
"charset-normalizer<4,>=2",
|
||||||
@@ -2383,7 +2383,7 @@ name = "urllib3"
|
|||||||
version = "2.2.1"
|
version = "2.2.1"
|
||||||
requires_python = ">=3.8"
|
requires_python = ">=3.8"
|
||||||
summary = "HTTP library with thread-safe connection pooling, file post, and more."
|
summary = "HTTP library with thread-safe connection pooling, file post, and more."
|
||||||
groups = ["default", "dev"]
|
groups = ["dev"]
|
||||||
files = [
|
files = [
|
||||||
{file = "urllib3-2.2.1-py3-none-any.whl", hash = "sha256:450b20ec296a467077128bff42b73080516e71b56ff59a60a02bef2232c4fa9d"},
|
{file = "urllib3-2.2.1-py3-none-any.whl", hash = "sha256:450b20ec296a467077128bff42b73080516e71b56ff59a60a02bef2232c4fa9d"},
|
||||||
{file = "urllib3-2.2.1.tar.gz", hash = "sha256:d0570876c61ab9e520d776c38acbbb5b05a776d3f9ff98a5c8fd5162a444cf19"},
|
{file = "urllib3-2.2.1.tar.gz", hash = "sha256:d0570876c61ab9e520d776c38acbbb5b05a776d3f9ff98a5c8fd5162a444cf19"},
|
||||||
|
|||||||
@@ -1,13 +1,12 @@
|
|||||||
[project]
|
[project]
|
||||||
name = "nonebot-plugin-dialectlist"
|
name = "nonebot-plugin-dialectlist"
|
||||||
version = "2.4.3"
|
version = "2.6.2"
|
||||||
description = "看看你群群友有多能说"
|
description = "看看你群群友有多能说"
|
||||||
authors = [
|
authors = [
|
||||||
{name = "Chen_Xu233", email = "woyerpa@outlook.com"},
|
{name = "Chen_Xu233", email = "woyerpa@outlook.com"},
|
||||||
]
|
]
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"nonebot-plugin-chatrecorder>=0.6.0",
|
"nonebot-plugin-chatrecorder>=0.6.0,<0.7.0",
|
||||||
"requests>=2.32.3",
|
|
||||||
"nonebot-plugin-orm[default]",
|
"nonebot-plugin-orm[default]",
|
||||||
"nonebot-plugin-apscheduler>=0.4.0",
|
"nonebot-plugin-apscheduler>=0.4.0",
|
||||||
"nonebot-plugin-alconna>=0.50.2",
|
"nonebot-plugin-alconna>=0.50.2",
|
||||||
@@ -18,7 +17,7 @@ dependencies = [
|
|||||||
"pillow>=10.4.0",
|
"pillow>=10.4.0",
|
||||||
"nonebot-plugin-uninfo>=0.1.1",
|
"nonebot-plugin-uninfo>=0.1.1",
|
||||||
]
|
]
|
||||||
requires-python = ">=3.9,<3.13"
|
requires-python = ">=3.9,<4.0"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
license = {text = "MIT"}
|
license = {text = "MIT"}
|
||||||
|
|
||||||
|
|||||||
112
tests/render.py
112
tests/render.py
@@ -1,112 +0,0 @@
|
|||||||
import PIL
|
|
||||||
import abc
|
|
||||||
from typing import List, Tuple, Union, Iterable
|
|
||||||
from PIL import Image, ImageDraw, ImageFont
|
|
||||||
|
|
||||||
class BaseElement(abc.ABC):
|
|
||||||
def __init__(self, box:Union[Iterable[int],Iterable[float]] = (0, 0, 0, 0)):
|
|
||||||
self.box = [float(i) for i in box]
|
|
||||||
self.ux = None
|
|
||||||
self.ly = None
|
|
||||||
self.dx = None
|
|
||||||
self.ry = None
|
|
||||||
self.hight = None
|
|
||||||
self.width = None
|
|
||||||
self.image = None
|
|
||||||
self.position = (self.ux, self.ly)
|
|
||||||
self.size = (self.width, self.hight)
|
|
||||||
|
|
||||||
@abc.abstractmethod
|
|
||||||
def render(self):
|
|
||||||
raise NotImplementedError
|
|
||||||
|
|
||||||
def get_box(self):
|
|
||||||
return self.box
|
|
||||||
|
|
||||||
def set_box(self, box:Tuple[float, float, float, float]):
|
|
||||||
self.box = box
|
|
||||||
|
|
||||||
def get_size(self):
|
|
||||||
self.size = (self.width, self.hight)
|
|
||||||
return self.size
|
|
||||||
|
|
||||||
def get_position(self):
|
|
||||||
self.position = (self.ux, self.ly)
|
|
||||||
return self.position
|
|
||||||
|
|
||||||
class Board(BaseElement):
|
|
||||||
def __init__(self, width, hight):
|
|
||||||
self.width = width
|
|
||||||
self.hight = hight
|
|
||||||
self.image = Image.new('RGBA', (self.width, self.hight), (255, 255, 255, 0))
|
|
||||||
self.elements = []
|
|
||||||
|
|
||||||
def render(self):
|
|
||||||
for i in self.elements:
|
|
||||||
i.ux = self.width * i.box[0]
|
|
||||||
i.ly = self.hight * i.box[1]
|
|
||||||
i.dx = self.width * i.box[2]
|
|
||||||
i.ry = self.hight * i.box[3]
|
|
||||||
i.hight = i.dx - i.ux
|
|
||||||
i.width = i.ry - i.ly
|
|
||||||
i.position = (i.ux, i.ly)
|
|
||||||
image = i.render()
|
|
||||||
self.image.paste(image, i.get_position())
|
|
||||||
|
|
||||||
def add_element(self, element:BaseElement):
|
|
||||||
self.elements.append(element)
|
|
||||||
|
|
||||||
|
|
||||||
class Container(BaseElement):
|
|
||||||
def __init__(self, box:Union[Iterable[int],Iterable[float]] = (0, 0, 0, 0)):
|
|
||||||
super().__init__(box)
|
|
||||||
self.elements:List[BaseElement] = []
|
|
||||||
|
|
||||||
def render(self,size:Tuple[int, int] = (100, 100)):
|
|
||||||
if not self.width and self.hight:
|
|
||||||
self.width = size[0]
|
|
||||||
self.hight = size[1]
|
|
||||||
if not self.image:
|
|
||||||
self.image = Image.new('RGBA', (self.width, self.hight), (255, 255, 255, 0))
|
|
||||||
for i in self.elements:
|
|
||||||
image = i.render()
|
|
||||||
self.image.paste(image, i.get_position())
|
|
||||||
|
|
||||||
class Element(BaseElement):
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# class BaseContainer(abc.ABC):
|
|
||||||
# def __init__(self, width:int, height:int):
|
|
||||||
# self.width = width
|
|
||||||
# self.height = height
|
|
||||||
# self.image = Image.new('RGBA', (self.width, self.height), (255, 255, 255, 0))
|
|
||||||
|
|
||||||
# @abc.abstractmethod
|
|
||||||
# def render(self):
|
|
||||||
# raise NotImplementedError
|
|
||||||
|
|
||||||
# def set_image(self,image):
|
|
||||||
# self.image = image
|
|
||||||
|
|
||||||
# class Elements():
|
|
||||||
# def __init__(self, width:int, height:int):
|
|
||||||
# self.width = width
|
|
||||||
# self.height = height
|
|
||||||
# self.image = Image.new('RGBA', (self.width, self.height), (255, 255, 255, 0))
|
|
||||||
|
|
||||||
# def render(self):
|
|
||||||
# return self.image
|
|
||||||
|
|
||||||
# class Container(BaseContainer):
|
|
||||||
# def __init__(self, width:int, height:int,elements:List[Union['Container',Elements]] = []):
|
|
||||||
# super().__init__(width, height)
|
|
||||||
# self.elements = elements
|
|
||||||
|
|
||||||
# def render(self):
|
|
||||||
# for i in self.elements:
|
|
||||||
# image = i.render()
|
|
||||||
# self.image.paste(image, i.position)
|
|
||||||
# return self.image
|
|
||||||
|
|
||||||
Reference in New Issue
Block a user