3.0计划中

[ChenXu233]

由于alembic带来的历史遗留问题（

于是决定将插件重构，删除数据库缓存部分（这部分算法烂的要死而且还很愚蠢）

在3.0推出前本插件可能预计都将不可使用。

如果需要使用可以将alembic生成的文件删除，就可以使用了。

3.0预计实现以下功能：

• 更好的数据查询模式
• 更多自定义的排行榜图片渲染样式
• 添加更多查询方式
• 如果可行，尝试适官方bot的markdown（待定）

最近的精神状态不太好，这个插件的更新很可能随缘了，如果快的话应该是一周内，慢的话也许要年末了。

[LoCCai]

已经实际测试了，删除迁移之后，还需要添加env配置项：ALEMBIC_STARTUP_CHECK=false不进行数据库检查，否则第一次成功启动后第二次扔会出现报错。目前把模板修修补补用上了。希望佬重构可以考虑一下以文件夹名称为主的多模板模式，可以通过规范化传递渲染的数据格式来进行，可以自由分享第三方模板或者其他等等。还有就是现在的插件中是没有定时推送的，仅导入了定时插件，希望这部分可以加回来，同样希望可以添加多种推送方式，可以考虑使用宇宙第一数据格式（json）或yaml等配置格式以方便热重载，可以使用指令打开/关闭/修改某个群的配置，设置推送条件（如群人数>20，当日消息>100等等），简单贴一下昨晚手搓的函数，可以参考一下，因为模板部分我还没改完，等写完新的样式，到时候再把时间函数和其他的加上，甚至我觉得可以引入词云然后调用当日词云然后加载在卡片下面，hiahiahia。
`# 添加定时任务
@scheduler.scheduled_job("cron", hour=0, minute=7, id="daily_b_rank")
async def daily_b_rank_report():
"""每天0点21分发送昨天的发言榜单"""
logger.info("开始执行每日B话榜报告任务")

bot = get_bot()
now = get_datetime_now_with_timezone()
yesterday = now - timedelta(days=1)
start = yesterday.replace(hour=0, minute=0, second=0, microsecond=0)
stop = yesterday.replace(hour=23, minute=59, second=59, microsecond=999999)

# 10人以上群自动发送
# 获取所有符合人数条件的群聊
groups = await filter_groups_by_member_count(
    bot=bot,
    min_numbers=10,
    max_numbers=9999
)
if not groups:
    logger.warning("未 获取到 需要 发送 的 群")
    return

# 获取 所有 群 的 所有 消息 数
try:
    t0 = t.time()
    messages = await get_message_records(
        scene_ids=[group['group_id'] for group in groups],
        types=['message'],
        time_start=start,
        time_stop=stop,
        exclude_user_ids=plugin_config.excluded_people,
    )
    all_messages = len(messages)
    get_all_messages_time = f"{t.time() - t0:.5f}s"
except Exception as e:
    t0 = t.time()
    logger.error(f"获取消息记录失败: {str(e)}")
    all_messages = 0
    get_all_messages_time = f"{t.time() - t0:.5f}s"
logger.debug(f"获取消息记录耗时: {get_all_messages_time}")

for group in groups:
    try:
        t1 = t.time()
        messages = await get_message_records(
            scene_ids=[group['group_id']],
            types=['message'],
            time_start=start,
            time_stop=stop,
            exclude_user_ids=plugin_config.excluded_people,
        )
        get_message_records_time = f"{t.time() - t1:.5f}s"
        logger.debug(f"获取消息记录耗时: {get_message_records_time}")
        
        if not messages:
            logger.info(f"群 {group['group_id']} 昨日无消息记录，跳过")
            continue
            
        # 计算消息总数
        total_messages = len(messages)
        
        # 统计各用户发言量
        t2 = t.time()
        raw_rank = msg_counter(messages,"")

        if not raw_rank:
            logger.info(f"群 {group['group_id']} 无 raw_rank 数据，跳过")
            continue
        
        rank = got_rank(raw_rank)
        get_rank_time = f"{t.time() - t2:.5f}s"
        logger.debug(f"统计消息记录耗时: {get_rank_time}")
        
        # 获取用户信息
        t3 = t.time()
        ids = await persist_id2user_id([int(i[0]) for i in rank])
        for i in range(len(rank)):
            rank[i][0] = str(ids[i])
        
        # 创建模拟事件对象
        fake_event = GroupMessageEvent(
            time=int(t.time()),
            self_id=bot.self_id,
            post_type="message",
            sub_type="normal",
            user_id=bot.self_id,  # 使用机器人自己的ID
            message_type="group",
            message_id=0,  # 使用0作为消息ID
            message=Message(""),  # 空消息
            raw_message="",
            font=0,
            sender=Sender(
                user_id=bot.self_id,
                nickname="系统定时任务",
                card="系统定时任务",
                role="owner",
            ),
            group_id=int(group['group_id']),
        )

        rank2 = await get_user_infos(bot, fake_event, rank)
        get_user_infos_time = f"{t.time() - t3:.5f}s"
        logger.debug(f"获取用户信息耗时: {get_user_infos_time}")

        # 生成排行榜文本
        report_text = "又到了每天的最后时刻，下面公布发言Top榜\n"
        report_text += "=====qiqi-bot|发言Top榜=====\n"
        report_text += f"七七 世界 总发言数 为：{all_messages}条\n"
        report_text += f"本群 总发言数 为：{total_messages}条\n"
        
        # 是否 取前10名
        
        # 添加耗时信息
        report_text += f"七七 统计世界发言 耗时：{get_all_messages_time}\n"
        report_text += f"七七 获取消息数据 耗时：{get_message_records_time}\n"
        report_text += f"七七 统计消息数据 耗时：{get_rank_time}\n"
        report_text += f"七七 获取用户信息 耗时：{get_user_infos_time}\n"
        
        # 生成排行榜图片
        t4 = t.time()
        image = await get_rank_image(rank2)
        report_text += f"七七 渲染卡片模板 耗时：{t.time() - t4:.5f}s\n"
        report_text += "=====================\n"
        
        # 发送消息
        await bot.send_group_msg(
            group_id=int(group['group_id']),
            message=report_text + MessageSegment.image(image)
        )
        
        logger.info(f"已向群 {group['group_id']} 发送昨日B话榜")
        
    except Exception as e:
        logger.error(f"向群 {group['group_id']} 发送B话榜失败: {str(e)}")`