解密厨来了2

Dockerfile

@@ -1,22 +1,32 @@
-# copied from https://www.martinrichards.me/post/python_poetry_docker/
 FROM python:3.13-slim AS base
 
 ENV VIRTUAL_ENV=/app/.venv \
-    PATH="/app/.venv/bin:$PATH"
+    PATH="/app/.venv/bin:$PATH" \
+    PLAYWRIGHT_BROWSERS_PATH=0
 
+# 安装所有都需要的底层依赖
 RUN apt-get update && \
     apt-get install -y --no-install-recommends \
-    libfontconfig1 \
-    libgl1 \
-    libegl1 \
-    libglvnd0 \
-    mesa-vulkan-drivers \
+    libfontconfig1 libgl1 libegl1 libglvnd0 mesa-vulkan-drivers at-spi2-common fontconfig \
+    libasound2-data libavahi-client3 libavahi-common-data libavahi-common3 libdatrie1 \
+    libfontenc1 libfribidi0 libgraphite2-3 libharfbuzz0b libice6 libpixman-1-0 \
+    libsm6 libthai-data libthai0 libunwind8 libxaw7 libxcb-render0 libxfont2 libxi6 \
+    libxkbfile1 libxmu6 libxpm4 libxrender1 libxt6t64 x11-common x11-xkb-utils \
+    xfonts-encodings xfonts-utils xkb-data xserver-common libnspr4 libatk1.0-0t64 \
+    libatk-bridge2.0-0t64 libatspi2.0-0t64 libxcomposite1 libxdamage1 libxfixes3 \
+    libxkbcommon0 libasound2t64 libnss3 fonts-noto-cjk fonts-noto-cjk-extra \
+    fonts-noto-color-emoji \
     && rm -rf /var/lib/apt/lists/*
 
 
 
 FROM base AS builder
 
+# 安装构建依赖
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    build-essential cmake git \
+    && rm -rf /var/lib/apt/lists/*
+
 ENV POETRY_NO_INTERACTION=1 \
     POETRY_VIRTUALENVS_IN_PROJECT=1 \
     POETRY_VIRTUALENVS_CREATE=1 \
@@ -24,7 +34,7 @@ ENV POETRY_NO_INTERACTION=1 \
 
 WORKDIR /app
 
-RUN pip install poetry
+RUN pip install --no-cache-dir poetry
 
 COPY pyproject.toml poetry.lock ./
 RUN python -m poetry install --no-root && rm -rf $POETRY_CACHE_DIR
@@ -37,6 +47,8 @@ COPY --from=builder ${VIRTUAL_ENV} ${VIRTUAL_ENV}
 
 WORKDIR /app
 
+RUN python -m playwright install chromium
+
 COPY bot.py pyproject.toml .env.prod .env.test ./
 COPY assets ./assets
 COPY scripts ./scripts

konabot/common/longtask.py

@@ -51,13 +51,16 @@ class LongTaskTarget(BaseModel):
     target_id: str
     "沟通对象的 ID"
 
-    async def send_message(self, msg: UniMessage, at: bool = True) -> bool:
+    async def send_message(self, msg: UniMessage | str, at: bool = True) -> bool:
         try:
             bot = nonebot.get_bot(self.self_id)
         except KeyError:
             logger.warning(f"试图访问了不存在的 Bot。ID={self.self_id}")
             return False
 
+        if isinstance(msg, str):
+            msg = UniMessage.text(msg)
+
         if self.platform == "qq":
             if not isinstance(bot, OBBot):
                 logger.warning(
@@ -66,7 +69,7 @@ class LongTaskTarget(BaseModel):
                     } BOT_CLASS={bot.__class__.__name__}"
                 )
                 return False
-            if self.channel_id.startswith(QQ_PRIVATE_CHAT_CHANNEL_PREFIX):
+            if self.channel_id.startswith(QQ_PRIVATE_CHAT_CHANNEL_PREFIX) or not self.channel_id.strip():
                 # 私聊模式
                 await bot.send_private_msg(
                     user_id=int(self.target_id),
@@ -119,18 +122,18 @@ class LongTask(BaseModel):
     target: LongTaskTarget
     callback: str
     deadline: datetime.datetime
-    canceled: bool = False
 
     _aio_task: asynkio.Task | None = None
 
     async def run(self):
         now = datetime.datetime.now()
-        if self.deadline < now and not self.canceled:
+        if self.deadline < now:
             await self._run_task()
             return
         await asynkio.sleep((self.deadline - now).total_seconds())
-        if self.canceled:
-            return
+        async with longtask_data() as data:
+            if self.uuid not in data.to_handle[self.callback]:
+                return
         await self._run_task()
 
     async def _run_task(self):
@@ -140,11 +143,7 @@ class LongTask(BaseModel):
                 f"Callback {self.callback} 未曾被注册，但是被期待调用，已忽略"
             )
             async with longtask_data() as datafile:
-                datafile.to_handle[self.callback] = [
-                    t
-                    for t in datafile.to_handle.get(self.callback, [])
-                    if t.uuid != self.uuid
-                ]
+                del datafile.to_handle[self.callback][self.uuid]
                 datafile.unhandled.setdefault(self.callback, []).append(self)
 
             return
@@ -155,9 +154,7 @@ class LongTask(BaseModel):
         except Exception as e:
             logger.exception(e)
         async with longtask_data() as datafile:
-            datafile.to_handle[self.callback] = [
-                t for t in datafile.to_handle[self.callback] if t.uuid != self.uuid
-            ]
+            del datafile.to_handle[self.callback][self.uuid]
             if not success:
                 datafile.unhandled.setdefault(self.callback, []).append(self)
                 logger.info(
@@ -181,7 +178,7 @@ class LongTask(BaseModel):
 
 
 class LongTaskModuleData(BaseModel):
-    to_handle: dict[str, list[LongTask]]
+    to_handle: dict[str, dict[str, LongTask]]
     unhandled: dict[str, list[LongTask]]
 
 
@@ -279,7 +276,7 @@ async def create_longtask(
     await task.start()
 
     async with longtask_data() as d:
-        d.to_handle.setdefault(handler, []).append(task)
+        d.to_handle.setdefault(handler, {})[task.uuid] = task
 
     return task
 
@@ -290,7 +287,7 @@ async def init_longtask():
 
     async with longtask_data() as data:
         for v in data.to_handle.values():
-            for t in v:
+            for t in v.values():
                 await t.start()
                 counter += 1
                 req.add(t.callback)

konabot/common/nb/extract_image.py

@@ -16,8 +16,6 @@ from nonebot_plugin_alconna import Image, RefNode, Reply, UniMessage
 from PIL import UnidentifiedImageError
 from returns.result import Failure, Result, Success
 
-from konabot.common.nb.exc import BotExceptionMessage
-
 
 async def download_image_bytes(url: str) -> Result[bytes, str]:
     # if "/matcha/cache/" in url:

konabot/common/nb/qq_broadcast.py

@@ -0,0 +1,30 @@
+from typing import Any, cast
+import nonebot
+from nonebot_plugin_alconna import UniMessage
+from nonebot.adapters.onebot.v11 import Bot as OBBot
+
+
+async def qq_broadcast(groups: list[str], msg: UniMessage[Any]):
+    bots: dict[str, OBBot] = {}
+
+    # group_id -> bot_id
+    availabilities: dict[str, str] = {}
+
+    for bot_id, bot in nonebot.get_bots().items():
+        if not isinstance(bot, OBBot):
+            continue
+        bots[bot_id] = bot
+        gl = await bot.get_group_list()
+        for g in gl:
+            gid = str(g.get("group_id", -1))
+            if gid in groups:
+                availabilities[gid] = bot_id
+
+    for group in groups:
+        if group in availabilities:
+            bot = bots[availabilities[group]]
+            await bot.send_group_msg(
+                group_id=int(group),
+                message=cast(Any, await msg.export(bot)),
+                auto_escape=False,
+            )

konabot/common/web_render/__init__.py

@@ -0,0 +1,183 @@
+import asyncio
+import queue
+from typing import Any, Callable, Coroutine
+from loguru import logger
+from playwright.async_api import Page, Playwright, async_playwright, Browser, Page, BrowserContext
+
+
+PageFunction = Callable[[Page], Coroutine[Any, Any, Any]]
+
+
+class WebRenderer:
+    browser_pool: queue.Queue["WebRendererInstance"] = queue.Queue()
+    context_pool: dict[int, BrowserContext] = {} # 长期挂载的浏览器上下文池
+    page_pool: dict[str, Page] = {} # 长期挂载的页面池
+
+    @classmethod
+    async def get_browser_instance(cls) -> "WebRendererInstance":
+        if cls.browser_pool.empty():
+            instance = await WebRendererInstance.create()
+            cls.browser_pool.put(instance)
+        instance = cls.browser_pool.get()
+        cls.browser_pool.put(instance)
+        return instance
+    
+    @classmethod
+    async def get_browser_context(cls) -> BrowserContext:
+        instance = await cls.get_browser_instance()
+        if id(instance) not in cls.context_pool:
+            context = await instance.browser.new_context()
+            cls.context_pool[id(instance)] = context
+            logger.debug(f"Created new persistent browser context for WebRendererInstance {id(instance)}")
+        return cls.context_pool[id(instance)]
+
+    @classmethod
+    async def render(
+        cls,
+        url: str,
+        target: str,
+        params: dict = {},
+        other_function: PageFunction | None = None,
+        timeout: int = 30,
+    ) -> bytes:
+        '''
+        访问指定URL并返回截图
+
+        :param url: 目标URL
+        :param target: 渲染目标，如 ".box"、"#main" 等CSS选择器
+        :param timeout: 页面加载超时时间，单位秒
+        :param params: URL键值对参数
+        :param other_function: 其他自定义操作函数，接受page参数
+        :return: 截图的字节数据
+
+        '''
+        instance = await cls.get_browser_instance()
+        logger.debug(f"Using WebRendererInstance {id(instance)} to render {url} targeting {target}")
+        return await instance.render(url, target, params=params, other_function=other_function, timeout=timeout)
+
+
+    @classmethod
+    async def render_persistent_page(cls, page_id: str, url: str, target: str, params: dict = {}, other_function: callable = None, timeout: int = 30) -> bytes:
+        '''
+        使用长期挂载的页面访问指定URL并返回截图
+
+        :param page_id: 页面唯一标识符
+        :param url: 目标URL
+        :param target: 渲染目标，如 ".box"、"#main" 等CSS选择器
+        :param timeout: 页面加载超时时间，单位秒
+        :param params: URL键值对参数
+        :param other_function: 其他自定义操作函数，接受page参数
+        :return: 截图的字节数据
+
+        '''
+        logger.debug(f"Requesting persistent render for page_id {page_id} at {url} targeting {target} with timeout {timeout}")
+        instance = await cls.get_browser_instance()
+        if page_id not in cls.page_pool:
+            context = await cls.get_browser_context()
+            page = await context.new_page()
+            cls.page_pool[page_id] = page
+            logger.debug(f"Created new persistent page for page_id {page_id} using WebRendererInstance {id(instance)}")
+        page = cls.page_pool[page_id]
+        return await instance.render_with_page(page, url, target, params=params, other_function=other_function, timeout=timeout)
+    
+    @classmethod
+    async def close_persistent_page(cls, page_id: str) -> None:
+        '''
+        关闭并移除长期挂载的页面
+
+        :param page_id: 页面唯一标识符
+        '''
+        if page_id in cls.page_pool:
+            page = cls.page_pool[page_id]
+            await page.close()
+            del cls.page_pool[page_id]
+            logger.debug(f"Closed and removed persistent page for page_id {page_id}")
+
+
+
+class WebRendererInstance:
+    def __init__(self):
+        self._playwright: Playwright | None = None
+        self._browser: Browser | None = None
+        self.lock = asyncio.Lock()
+
+    @property
+    def playwright(self) -> Playwright:
+        assert self._playwright is not None
+        return self._playwright
+
+    @property
+    def browser(self) -> Browser:
+        assert self._browser is not None
+        return self._browser
+
+    async def init(self):
+        self._playwright = await async_playwright().start()
+        self._browser = await self.playwright.chromium.launch(headless=True)
+
+    @classmethod
+    async def create(cls) -> "WebRendererInstance":
+        instance = cls()
+        await instance.init()
+        return instance
+
+    async def render(
+        self,
+        url: str,
+        target: str,
+        index: int = 0,
+        params: dict = {},
+        other_function: PageFunction | None = None,
+        timeout: int = 30
+    ) -> bytes:
+        '''
+        访问指定URL并返回截图
+
+        :param url: 目标URL
+        :param target: 渲染目标，如 ".box"、"#main" 等CSS选择器
+        :param timeout: 页面加载超时时间，单位秒
+        :param index: 如果目标是一个列表，指定要截图的元素索引
+        :param params: URL键值对参数
+        :param other_function: 其他自定义操作函数，接受page参数
+        :return: 截图的字节数据
+
+        '''
+        async with self.lock:
+            context = await self.browser.new_context()
+            page = await context.new_page()
+            screenshot = await self.inner_render(page, url, target, index, params, other_function, timeout)
+            await page.close()
+            await context.close()
+            return screenshot
+
+    async def render_with_page(self, page: Page, url: str, target: str, index: int = 0, params: dict = {}, other_function: callable = None, timeout: int = 30) -> bytes:
+        async with self.lock:
+            screenshot = await self.inner_render(page, url, target, index, params, other_function, timeout)
+            return screenshot
+
+    async def inner_render(self, page: Page, url: str, target: str, index: int = 0, params: dict = {}, other_function: callable = None, timeout: int = 30) -> bytes:
+        logger.debug(f"Navigating to {url} with timeout {timeout}")
+        url_with_params = url + ("?" + "&".join(f"{k}={v}" for k, v in params.items()) if params else "")
+        await page.goto(url_with_params, timeout=timeout * 1000, wait_until="load")
+        logger.debug("Page loaded successfully")
+        # 等待目标元素出现
+        await page.wait_for_selector(target, timeout=timeout * 1000)
+        logger.debug(f"Target element '{target}' found, taking screenshot")
+        if other_function:
+            await other_function(page)
+        elements = await page.query_selector_all(target)
+        if not elements:
+            logger.error(f"Target element '{target}' not found on the page.")
+            return None
+        if index >= len(elements):
+            logger.error(f"Index {index} out of range for elements matching '{target}'")
+            return None
+        element = elements[index]
+        screenshot = await element.screenshot()
+        logger.debug(f"Screenshot taken successfully")
+        return screenshot
+
+    async def close(self):
+        await self.browser.close()
+        await self.playwright.stop()
+

konabot/docs/concepts/罗文.txt

@@ -0,0 +1,2 @@
+关于罗文和洛温：
+    AdoreLowen 希望和洛温阿特金森区分，所以最好就不要叫他洛温了！此方 BOT 会在一些群提醒叫错了的人。

konabot/docs/sys/怪话过滤.txt

@@ -1,9 +0,0 @@
-指令介绍
-    怪话过滤 - 去除含有关键词的怪话
-
-使用方法
-    `怪话过滤 说的道理`
-        去除所有含有“说的道理”的怪话
-
-另见
-    怪话(1)

konabot/docs/user/ntfy.txt

@@ -0,0 +1,15 @@
+指令介绍
+    ntfy - 配置使用 ntfy 来更好地为你通知此方 BOT 代办
+
+指令示例
+    `ntfy 创建`
+        创建一个随机的 ntfy 订阅主题来提醒代办，此方 Bot 将会给你使用指引。你可以前往 https://ntfy.sh/ 官网下载 ntfy APP，或者使用网页版 ntfy。
+
+    `ntfy 创建 kagami-notice`
+        创建一个名字含有 kagami-notice 的 ntfy 订阅主题
+
+    `ntfy 删除`
+        清除并不再使用 ntfy 向你通知
+
+另见
+    提醒我(1) 查询提醒(1) 删除提醒(1)

konabot/docs/user/删除提醒.txt

@@ -0,0 +1,8 @@
+指令介绍
+    删除提醒 - 删除在`查询提醒(1)`中查到的提醒
+
+指令示例
+    `删除提醒 1` 在查询提醒后，删除编号为 1 的提醒
+
+另见
+    提醒我(1) 查询提醒(1) ntfy(1)

konabot/docs/user/怪话.txt

@@ -1,12 +0,0 @@
-指令介绍
-    说点怪话/说些怪话 - 让 BOT 学群友胡言乱语
-
-适用范围
-    为保证安全，只有少数授权的群聊可以使用该指令
-
-使用方法
-    `说点怪话 今天吃什么`
-        期待 Bot 会回答你什么吧
-
-    `说些怪话 明天不想上体育课`
-        Bot 会回复你三句怪话

konabot/docs/user/提醒我.txt

@@ -0,0 +1,15 @@
+指令介绍
+    提醒我 - 在指定的时间提醒人事项的工具
+
+使用示例
+    `下午五点提醒我吃饭`
+        创建一个下午五点的提醒，提醒你吃饭
+
+    `两分钟后提醒我睡觉`
+        创建一个相对于现在推迟 2 分钟的提醒，提醒你睡觉
+
+    `2026年4月25日20点整提醒我生日快乐`
+        创建一个指定日期和时间的提醒
+
+另见
+    查询提醒(1) 删除提醒(1) ntfy(1)

konabot/docs/user/查询提醒.txt

@@ -0,0 +1,9 @@
+指令介绍
+    查询提醒 - 查询已经创建的提醒
+
+指令格式
+    `查询提醒` 查询提醒
+    `查询提醒 2` 查询第二页提醒
+
+另见
+    提醒我(1) 删除提醒(1) ntfy(1)

konabot/plugins/air_conditioner/__init__.py

@@ -0,0 +1,120 @@
+from io import BytesIO
+from typing import Optional, Union
+from nonebot.adapters import Event as BaseEvent
+from nonebot.adapters.console.event import MessageEvent as ConsoleMessageEvent
+from nonebot.adapters.discord.event import MessageEvent as DiscordMessageEvent
+from nonebot_plugin_alconna import Alconna, AlconnaMatcher, Args, UniMessage, on_alconna
+from PIL import Image
+from konabot.common.longtask import DepLongTaskTarget
+from konabot.common.path import ASSETS_PATH
+from konabot.plugins.air_conditioner.ac import AirConditioner, generate_ac_image
+
+def get_ac(id: str) -> AirConditioner:
+    ac = AirConditioner.air_conditioners.get(id)
+    if ac is None:
+        ac = AirConditioner(id)
+    return ac
+
+async def send_ac_image(event: type[AlconnaMatcher], ac: AirConditioner):
+    if(ac.burnt == True):
+        # 打开坏掉的空调图片
+        with open(ASSETS_PATH / "img" / "ac" / "broken_ac.png", "rb") as f:
+            # 将其转为 GIF 格式发送
+            output = BytesIO()
+            Image.open(f).save(output, format="GIF")
+            output.seek(0)
+            await event.send(await UniMessage().image(raw=output).export())
+        return
+    if(ac.frozen == True):
+        # 打开坏掉的空调图片
+        with open(ASSETS_PATH / "img" / "ac" / "frozen_ac.png", "rb") as f:
+            # 将其转为 GIF 格式发送
+            output = BytesIO()
+            Image.open(f).save(output, format="GIF")
+            output.seek(0)
+            await event.send(await UniMessage().image(raw=output).export())
+        return
+    ac_image = await generate_ac_image(ac)
+    await event.send(await UniMessage().image(raw=ac_image).export())
+
+evt = on_alconna(Alconna(
+    "群空调"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    await send_ac_image(evt, ac)
+
+evt = on_alconna(Alconna(
+    "开空调"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    ac.on = True
+    await send_ac_image(evt, ac)
+
+evt = on_alconna(Alconna(
+    "关空调"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    ac.on = False
+    await send_ac_image(evt, ac)
+
+evt = on_alconna(Alconna(
+    "空调升温"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    if not ac.on or ac.burnt == True or ac.frozen == True:
+        await send_ac_image(evt, ac)
+        return
+    ac.temperature += 1
+    if ac.temperature > 40:
+        # 打开爆炸图片
+        with open(ASSETS_PATH / "img" / "other" / "boom.jpg", "rb") as f:
+            output = BytesIO()
+            Image.open(f).save(output, format="GIF")
+            await evt.send(await UniMessage().image(raw=output).export())
+        ac.burnt = True
+        await evt.send("太热啦，空调炸了！")
+        return
+    await send_ac_image(evt, ac)
+
+evt = on_alconna(Alconna(
+    "空调降温"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    if not ac.on or ac.burnt == True or ac.frozen == True:
+        await send_ac_image(evt, ac)
+        return
+    ac.temperature -= 1
+    if ac.temperature < 0:
+        ac.frozen = True
+    await send_ac_image(evt, ac)
+
+evt = on_alconna(Alconna(
+    "换空调"
+), use_cmd_start=True, use_cmd_sep=False, skip_for_unmatch=True)
+
+@evt.handle()
+async def _(event: BaseEvent, target: DepLongTaskTarget):
+    id = target.channel_id
+    ac = get_ac(id)
+    ac.change_ac()
+    await send_ac_image(evt, ac)

konabot/plugins/air_conditioner/ac.py

@@ -0,0 +1,225 @@
+from io import BytesIO
+
+import cv2
+import numpy as np
+from PIL import Image, ImageDraw, ImageFont
+
+from konabot.common.path import ASSETS_PATH, FONTS_PATH
+
+class AirConditioner:
+    air_conditioners: dict[str, "AirConditioner"] = {}
+
+    def __init__(self, id: str) -> None:
+        self.id = id
+        self.on = False
+        self.temperature = 24  # 默认温度
+        self.burnt = False
+        self.frozen = False
+        AirConditioner.air_conditioners[id] = self
+
+    def change_ac(self):
+        self.burnt = False
+        self.frozen = False
+        self.on = False
+        self.temperature = 24  # 重置为默认温度
+
+def text_to_transparent_image(text, font_size=40, padding=0, text_color=(0, 0, 0)):
+    """
+    将文本转换为带透明背景的图像，图像大小刚好包含文本
+    """
+    # 创建临时图像来计算文本尺寸
+    temp_image = Image.new('RGB', (1, 1), (255, 255, 255))
+    temp_draw = ImageDraw.Draw(temp_image)
+    
+    font = ImageFont.truetype(FONTS_PATH / "montserrat.otf", font_size)
+    
+    # 获取文本边界框
+    bbox = temp_draw.textbbox((0, 0), text, font=font)
+    text_width = bbox[2] - bbox[0]
+    text_height = bbox[3] - bbox[1]
+    
+    # 计算图像大小（文本大小 + 内边距）
+    image_width = int(text_width + 2 * padding)
+    image_height = int(text_height + 2 * padding)
+    
+    # 创建RGBA模式的空白图像（带透明通道）
+    image = Image.new('RGBA', (image_width, image_height), (0, 0, 0, 0))
+    draw = ImageDraw.Draw(image)
+    
+    # 绘制文本（考虑内边距）
+    x = padding - bbox[0]  # 调整起始位置
+    y = padding - bbox[1]
+    
+    # 设置文本颜色（带透明度）
+    if len(text_color) == 3:
+        text_color = text_color + (255,)  # 添加完全不透明的alpha值
+    
+    draw.text((x, y), text, fill=text_color, font=font)
+    
+    # 转换为OpenCV格式（BGRA）
+    image_cv = cv2.cvtColor(np.array(image), cv2.COLOR_RGBA2BGRA)
+    return image_cv
+
+def perspective_transform(image, target, corners):
+    """
+    对图像进行透视变换（保持透明通道）
+    target: 画布
+    corners: 四个角点的坐标，顺序为 [左上, 右上, 右下, 左下]
+    """
+    height, width = image.shape[:2]
+    
+    # 源点（原始图像的四个角）
+    src_points = np.array([
+        [0, 0],           # 左上
+        [width-1, 0],     # 右上
+        [width-1, height-1], # 右下
+        [0, height-1]     # 左下
+    ], dtype=np.float32)
+    
+    # 目标点（变换后的四个角）
+    dst_points = np.array(corners, dtype=np.float32)
+    
+    # 计算透视变换矩阵
+    matrix = cv2.getPerspectiveTransform(src_points, dst_points)
+    
+    # 获取画布大小
+    target_height, target_width = target.shape[:2]
+
+    # 应用透视变换（保持所有通道，包括alpha）
+    transformed = cv2.warpPerspective(image, matrix, (target_width, target_height), flags=cv2.INTER_LINEAR)
+
+    return transformed, matrix
+
+def blend_with_transparency(background, foreground, position):
+    """
+    将带透明通道的前景图像合成到背景图像上
+    position: 前景图像在背景图像上的位置 (x, y)
+    """
+    bg = background.copy()
+    
+    # 如果背景没有alpha通道，添加一个
+    if bg.shape[2] == 3:
+        bg = cv2.cvtColor(bg, cv2.COLOR_BGR2BGRA)
+        bg[:, :, 3] = 255  # 完全不透明
+    
+    x, y = position
+    fg_height, fg_width = foreground.shape[:2]
+    bg_height, bg_width = bg.shape[:2]
+    
+    # 确保位置在图像范围内
+    x = max(0, min(x, bg_width - fg_width))
+    y = max(0, min(y, bg_height - fg_height))
+    
+    # 提取前景的alpha通道并归一化
+    alpha_foreground = foreground[:, :, 3] / 255.0
+    
+    # 对于每个颜色通道进行合成
+    for c in range(3):
+        bg_region = bg[y:y+fg_height, x:x+fg_width, c]
+        fg_region = foreground[:, :, c]
+        
+        # alpha混合公式
+        bg[y:y+fg_height, x:x+fg_width, c] = (
+            alpha_foreground * fg_region + 
+            (1 - alpha_foreground) * bg_region
+        )
+    
+    # 更新背景的alpha通道（如果需要）
+    bg_alpha_region = bg[y:y+fg_height, x:x+fg_width, 3]
+    bg[y:y+fg_height, x:x+fg_width, 3] = np.maximum(bg_alpha_region, foreground[:, :, 3])
+    
+    return bg
+
+def precise_blend_with_perspective(background, foreground, corners):
+    """
+    精确合成：根据四个角点将前景图像透视合成到背景上
+    """
+    # 创建与背景相同大小的空白图像
+    bg_height, bg_width = background.shape[:2]
+    
+    # 如果背景没有alpha通道，转换为BGRA
+    if background.shape[2] == 3:
+        background_bgra = cv2.cvtColor(background, cv2.COLOR_BGR2BGRA)
+    else:
+        background_bgra = background.copy()
+    
+    # 创建与背景相同大小的前景图层
+    foreground_layer = np.zeros((bg_height, bg_width, 4), dtype=np.uint8)
+    
+    # 计算前景图像在背景中的边界框
+    min_x = int(min(corners[:, 0]))
+    max_x = int(max(corners[:, 0]))
+    min_y = int(min(corners[:, 1]))
+    max_y = int(max(corners[:, 1]))
+    
+    # 将变换后的前景图像放置到对应位置
+    fg_height, fg_width = foreground.shape[:2]
+    if min_y + fg_height <= bg_height and min_x + fg_width <= bg_width:
+        foreground_layer[min_y:min_y+fg_height, min_x:min_x+fg_width] = foreground
+    
+    # 创建掩码（只在前景有内容的地方合成）
+    mask = (foreground_layer[:, :, 3] > 0)
+    
+    # 合成图像
+    result = background_bgra.copy()
+    for c in range(3):
+        result[:, :, c][mask] = foreground_layer[:, :, c][mask]
+    result[:, :, 3][mask] = foreground_layer[:, :, 3][mask]
+    
+    return result
+
+def wiggle_transform(image) -> list[np.ndarray]:
+    '''
+    返回一组图像振动的帧组，模拟空调运作时的抖动效果
+    '''
+    frames = []
+    height, width = image.shape[:2]
+    shifts = [(-2, 0), (2, 0), (0, -2), (0, 2), (0, 0)]
+    for dx, dy in shifts:
+        M = np.float32([[1, 0, dx], [0, 1, dy]])
+        shifted = cv2.warpAffine(image, M, (width, height))
+        frames.append(shifted)
+    return frames
+
+async def generate_ac_image(ac: AirConditioner) -> BytesIO:
+    # 找到空调底图
+    ac_image = cv2.imread(str(ASSETS_PATH / "img" / "ac" / "ac.png"), cv2.IMREAD_UNCHANGED)
+
+    if not ac.on:
+        # 空调关闭状态，直接返回底图
+        pil_final = Image.fromarray(ac_image)
+        output = BytesIO()
+        pil_final.save(output, format="GIF")
+        return output
+
+    # 根据生成温度文本图像
+    text = f"{ac.temperature}°C"
+    text_image = text_to_transparent_image(
+        text, 
+        font_size=60, 
+        text_color=(0, 0, 0)  # 黑色文字
+    )
+
+    # 获取长宽比
+    height, width = text_image.shape[:2]
+    aspect_ratio = width / height
+
+    # 定义3D变换的四个角点（透视效果）
+    # 顺序: [左上, 右上, 右下, 左下]
+    corners = np.array([
+        [123, 45],    # 左上
+        [284, 101],   # 右上
+        [290, 140],   # 右下
+        [119, 100]    # 左下
+    ], dtype=np.float32)
+    
+    # 对文本图像进行3D变换（保持透明通道）
+    transformed_text, transform_matrix = perspective_transform(text_image, ac_image, corners)
+
+    final_image_simple = blend_with_transparency(ac_image, transformed_text, (0, 0))
+
+    frames = wiggle_transform(final_image_simple)
+    pil_frames = [Image.fromarray(frame) for frame in frames]
+    output = BytesIO()
+    pil_frames[0].save(output, format="GIF", save_all=True, append_images=pil_frames[1:], loop=0, duration=50)
+    return output

konabot/plugins/fortune/__init__.py

@@ -1,68 +0,0 @@
-import asyncio
-from nonebot import get_plugin_config, on_command, on_message
-from nonebot.adapters import Bot
-from nonebot.adapters.onebot.v11.event import GroupMessageEvent
-from nonebot_plugin_alconna import Alconna, Args, UniMessage, UniMsg, on_alconna
-from pydantic import BaseModel
-
-from konabot.common.nb.is_admin import is_admin
-from konabot.common.path import DATA_PATH
-
-from .random_text_record import RandomTextManager
-
-
-class FortuneConfig(BaseModel):
-    plugin_fortune_collect_groups: list[int] = []
-
-
-fortune_wtf = RandomTextManager(DATA_PATH / "fortune_wtf.txt")
-fortune_insert_lock = asyncio.Lock()
-fortune_config = get_plugin_config(FortuneConfig)
-
-
-async def is_collect_target(evt: GroupMessageEvent) -> bool:
-    if evt.group_id not in fortune_config.plugin_fortune_collect_groups:
-        return False
-    return True
-
-
-evt_collector = on_message(rule=is_collect_target)
-
-@evt_collector.handle()
-async def _(msg: UniMsg):
-    txt = msg.extract_plain_text()
-    if len(txt) > 50 or not txt.strip():
-        return
-    if txt.startswith("说点怪话") or txt.startswith("说些怪话") or txt.startswith("怪话过滤"):
-        return
-    async with fortune_insert_lock:
-        fortune_wtf.insert(txt)
-
-
-cmd_guaihua = on_command("说点怪话", rule=is_collect_target)
-
-@cmd_guaihua.handle()
-async def _(bot: Bot):
-    await cmd_guaihua.send(await UniMessage().text(fortune_wtf.choice()).export(bot))
-
-
-cmd_guaihuas = on_command("说些怪话", rule=is_collect_target)
-
-@cmd_guaihuas.handle()
-async def _(bot: Bot):
-    for _ in range(3):
-        await cmd_guaihuas.send(await UniMessage().text(fortune_wtf.choice()).export(bot))
-        await asyncio.sleep(1)
-
-
-cmd_filter_guaihua = on_alconna(Alconna(
-    "怪话过滤",
-    Args["keyword", str],
-), rule=is_admin)
-
-@cmd_filter_guaihua.handle()
-async def _(keyword: str, bot: Bot):
-    async with fortune_insert_lock:
-        c = fortune_wtf.filter_out(keyword)
-    await cmd_filter_guaihua.send(await UniMessage().text(f"删除了 {c} 条怪话").export(bot))
-

konabot/plugins/fortune/random_text_record.py

@@ -1,70 +0,0 @@
-import base64
-import random
-import time
-
-from pathlib import Path
-
-
-class RandomTextManager:
-    _cache: list[tuple[float, str]]
-
-    def __init__(self, fp: Path) -> None:
-        self.fp = fp
-        self._cache = []
-        if not self.fp.exists():
-            self.fp.touch()
-        else:
-            self.load()
-
-    def load(self):
-        self._cache = []
-        with self.fp.open("r") as f:
-            for line in f.readlines():
-                if not line.strip():
-                    continue
-                if "|" not in line:
-                    continue
-                ts, cn = line.split("|")
-                try:
-                    ts = float(ts)
-                except Exception:
-                    continue
-                self._cache.append((ts, base64.b64decode(cn).decode("utf-8")))
-
-    def save(self):
-        lines = [
-            str(ts) + "|" + base64.b64encode(cn.encode("utf-8")).decode()
-            for ts, cn in self._cache
-        ]
-        with self.fp.open("w") as f:
-            f.writelines(lines)
-
-    def insert(self, text: str, timestamp: float | None = None):
-        if timestamp is None:
-            timestamp = time.time()
-        with self.fp.open("a") as f:
-            f.write(str(timestamp) + "|" + base64.b64encode(text.encode("utf-8")).decode() + "\n")
-        self._cache.append((timestamp, text))
-
-    def choice(self, now: float | None = None):
-        contents: list[str] = []
-        weights: list[float] = []
-
-        if now is None:
-            now = time.time()
-
-        for ts, cn in self._cache:
-            contents.append(cn)
-            weights.append((abs(now - ts) + 0.01) ** (-1))
-
-        return random.choices(contents, weights)[0]
-
-    def filter_out(self, keyword: str):
-        len1 = len(self._cache)
-        self._cache = [
-            (ts, cn) for ts, cn in self._cache
-            if keyword not in cn
-        ]
-        self.save()
-        return len1 - len(self._cache)
-

konabot/plugins/hanzi/__init__.py

@@ -0,0 +1,217 @@
+import random
+from typing import Optional
+import opencc
+
+from nonebot import on_message
+from nonebot.adapters import Event as BaseEvent
+from nonebot.adapters.discord.event import MessageEvent as DiscordMessageEvent
+from nonebot_plugin_alconna import (
+    Alconna,
+    Args,
+    UniMessage,
+    UniMsg,
+    on_alconna,
+)
+
+convert_type = ["简","簡","繁","正","港","日"]
+
+compiled_str = "|".join([f"{a}{mid}{b}" for mid in ["转","轉","転"] for a in convert_type for b in convert_type if a != b])
+
+def hanzi_to_abbr(hanzi: str) -> str:
+    mapping = {
+        "简": "s",
+        "簡": "s",
+        "繁": "t",
+        "正": "t",
+        "港": "hk",
+        "日": "jp",
+    }
+    return mapping.get(hanzi, "")
+
+def check_valid_convert_type(convert_type: str) -> bool:
+    avaliable_set = ["s2t","t2s","s2tw","tw2s","s2hk","hk2s","s2twp","tw2sp","t2tw","hk2t","t2hk","t2jp","jp2t","tw2t"]
+    if convert_type in avaliable_set:
+        return True
+    return False
+
+def convert(source, src_abbr, dst_abbr):
+    convert_type_key = f"{src_abbr}2{dst_abbr}"
+    if not check_valid_convert_type(convert_type_key):
+        # 先转为繁体，再转为目标
+        converter = opencc.OpenCC(f"{src_abbr}2t.json")
+        source = converter.convert(source)
+        src_abbr = "t"
+    converter = opencc.OpenCC(f"{src_abbr}2{dst_abbr}.json")
+    converted = converter.convert(source)
+    return converted
+
+evt = on_alconna(
+    Alconna(
+        f"re:({compiled_str})",
+        Args["source?", str],
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, source: Optional[str] = None):
+    if isinstance(event, DiscordMessageEvent):
+        content = event.get_message().extract_plain_text()
+    else:
+        content = event.get_message().extract_plain_text()
+
+    prefix = content.split()[0]
+    to_convert = ""
+    # 如果回复了消息，则转换回复的内容
+    if(source is None):
+        if event.reply:
+            to_convert = event.reply.message.extract_plain_text()
+            if not to_convert:
+                return
+        else:
+            return
+    else:
+        to_convert = source
+    parts = []
+    if "转" in prefix:
+        parts = prefix.split("转")
+    elif "轉" in prefix:
+        parts = prefix.split("轉")
+    elif "転" in prefix:
+        parts = prefix.split("転")
+    if len(parts) != 2:
+        notice = "转换格式错误，请使用“简转繁”、“繁转简”等格式。"
+        await evt.send(await UniMessage().text(notice).export())
+        return
+    src, dst = parts
+    src_abbr = hanzi_to_abbr(src)
+    dst_abbr = hanzi_to_abbr(dst)
+    if not src_abbr or not dst_abbr:
+        notice = "不支持的转换类型，请使用“简”、“繁”、“正”、“港”、“日”等。"
+        if src_abbr:
+            notice = convert(notice, "s", src_abbr)
+        await evt.send(await UniMessage().text(notice).export())
+        return
+    
+    converted = convert(to_convert, src_abbr, dst_abbr)
+
+    converted_prefix = convert("转换结果", "s", dst_abbr)
+
+    await evt.send(await UniMessage().text(f"{converted_prefix}：{converted}").export())
+
+shuo = ["说","說"]
+
+full_name_type = ["简体","簡體","繁體","繁体","正體","正体","港話","港话","日文"]
+
+combined_list = [f"{a}{b}" for a in shuo for b in full_name_type]
+
+compiled_str_2 = "|".join(combined_list)
+
+evt = on_alconna(
+    Alconna(
+        f"re:({compiled_str_2})",
+        Args["source?", str]
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, source: Optional[str] = None):
+    if isinstance(event, DiscordMessageEvent):
+        content = event.get_message().extract_plain_text()
+    else:
+        content = event.get_message().extract_plain_text()
+
+    prefix = content.split()[0]
+    to_convert = ""
+    # 如果回复了消息，则转换回复的内容
+    if(source is None):
+        if event.reply:
+            to_convert = event.reply.message.extract_plain_text()
+            if not to_convert:
+                return
+        else:
+            return
+    else:
+        to_convert = source
+    # 获取目标转换类型
+    dst = ""
+    match prefix:
+        case "说简体" | "說簡體" | "说簡體" | "說简体":
+            dst = "简"
+        case "說繁體" | "说繁体" | "說繁体" | "说繁體":
+            dst = "繁"
+        case "說正體" | "说正体" | "說正体" | "说正體":
+            dst = "正"
+        case "說港話" | "说港话" | "說港话" | "说港話":
+            dst = "港"
+        case "說日文" | "说日文":
+            dst = "日"
+    dst_abbr = hanzi_to_abbr(dst)
+    if not dst_abbr:
+        notice = "不支持的转换类型，请使用“简体”、“繁體”、“正體”、“港話”、“日文”等。"
+        await evt.send(await UniMessage().text(notice).export())
+        return
+    # 循环，将源语言一次次转换为目标语言
+    current_text = to_convert
+    for src_abbr in ["s","hk","jp","tw","t"]:
+        if src_abbr != dst_abbr:
+            current_text = convert(current_text, src_abbr, dst_abbr)
+
+    converted_prefix = convert("转换结果", "s", dst_abbr)
+
+    await evt.send(await UniMessage().text(f"{converted_prefix}：{current_text}").export())
+
+def random_char(char: str) -> str:
+    dst_abbr = random.choice(["s","t","hk","jp","tw"])
+    for src_abbr in ["s","hk","jp","tw","t"]:
+        if src_abbr != dst_abbr:
+            char = convert(char, src_abbr, dst_abbr)
+    return char
+
+def random_string(text: str) -> str:
+    final_text = ""
+    for char in text:
+        final_text += random_char(char)
+    return final_text
+
+random_match = ["混乱字形","混亂字形","乱数字形","亂數字形","ランダム字形"]
+
+evt = on_alconna(
+    Alconna(
+        f"re:({'|'.join(random_match)})",
+        Args["source?", str]
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, source: Optional[str] = None):
+    if isinstance(event, DiscordMessageEvent):
+        content = event.get_message().extract_plain_text()
+    else:
+        content = event.get_message().extract_plain_text()
+
+    prefix = content.split()[0]
+    to_convert = ""
+    # 如果回复了消息，则转换回复的内容
+    if(source is None):
+        if event.reply:
+            to_convert = event.reply.message.extract_plain_text()
+            if not to_convert:
+                return
+        else:
+            return
+    else:
+        to_convert = source
+
+    final_text = ""
+    final_text = random_string(to_convert)
+    converted_prefix = convert(random_string("转换结果"), "s", "s")
+
+    await evt.send(await UniMessage().text(f"{converted_prefix}：{final_text}").export())

konabot/plugins/idiomgame/__init__.py

@@ -69,10 +69,11 @@ class TryStopState(Enum):
 class TryVerifyState(Enum):
     VERIFIED = 0
     VERIFIED_AND_REAL = 1
-    NOT_IDIOM = 2
-    WRONG_FIRST_CHAR = 3
-    VERIFIED_BUT_NO_NEXT = 4
-    VERIFIED_GAME_END = 5
+    ALREADY_USED = 2
+    NOT_IDIOM = 3
+    WRONG_FIRST_CHAR = 4
+    BUT_NO_NEXT = 5
+    GAME_END = 6
 
 
 class IdiomGame:
@@ -96,12 +97,14 @@ class IdiomGame:
         self.all_buff_score = 0
         self.lock = asynkio.Lock()
         self.remain_rounds = 0  # 剩余回合数
+        self.already_idioms: dict[str, int] = {} # 已经使用过的成语和使用过的次数
+        self.idiom_history: list[list[str]] = [] # 成语使用历史记录，多个数组以存储不同成语链
         IdiomGame.INSTANCE_LIST[group_id] = self
 
     def be_able_to_play(self) -> bool:
         if self.last_play_date != datetime.date.today():
             self.last_play_date = datetime.date.today()
-            self.remain_playing_times = 1
+            self.remain_playing_times = 3
         if self.remain_playing_times > 0:
             self.remain_playing_times -= 1
             return True
@@ -115,6 +118,8 @@ class IdiomGame:
         self.last_char = self.last_idiom[-1]
         if not self.is_nextable(self.last_char):
             self.choose_start_idiom()
+        else:
+            self.add_history_idiom(self.last_idiom, new_chain=True)
         return self.last_idiom
 
     @classmethod
@@ -148,6 +153,9 @@ class IdiomGame:
     def clear_score_board(self):
         self.score_board = {}
         self.last_char = ""
+        self.all_buff_score = 0
+        self.already_idioms = {}
+        self.idiom_history = []
 
     def get_score_board(self) -> dict:
         return self.score_board
@@ -169,6 +177,8 @@ class IdiomGame:
         self.last_char = self.last_idiom[-1]
         if not self.is_nextable(self.last_char):
             self._skip_idiom_async()
+        else:
+            self.add_history_idiom(self.last_idiom, new_chain=True)
         return self.last_idiom
 
     async def try_verify_idiom(self, idiom: str, user_id: str) -> TryVerifyState:
@@ -184,36 +194,69 @@ class IdiomGame:
         判断是否有成语可以接
         """
         return last_char in IdiomGame.AVALIABLE_IDIOM_FIRST_CHAR
+    
+    def add_already_idiom(self, idiom: str):
+        if idiom in self.already_idioms:
+            self.already_idioms[idiom] += 1
+        else:
+            self.already_idioms[idiom] = 1
 
-    def _verify_idiom(self, idiom: str, user_id: str) -> TryVerifyState:
+    def get_already_used_num(self, idiom: str) -> int:
+        if idiom in self.already_idioms:
+            return self.already_idioms[idiom]
+        return 0
+        
+    def add_history_idiom(self, idiom: str, new_chain: bool = False):
+        if new_chain or len(self.idiom_history) == 0:
+            self.idiom_history.append([idiom])
+        else:
+            self.idiom_history[-1].append(idiom)
+
+    def display_history(self) -> list[str]:
+        result = []
+        for chain in self.idiom_history:
+            result.append(" -> ".join(chain))
+        return result
+
+    def _verify_idiom(self, idiom: str, user_id: str) -> list[TryVerifyState]:
+        state = []
         # 新成语的首字应与上一条成语的尾字相同
         if idiom[0] != self.last_char:
-            return TryVerifyState.WRONG_FIRST_CHAR
+            state.append(TryVerifyState.WRONG_FIRST_CHAR)
+            return state
         if idiom not in IdiomGame.ALL_IDIOMS and idiom not in IdiomGame.ALL_WORDS:
             self.add_score(user_id, -0.1)
-            return TryVerifyState.NOT_IDIOM
+            state.append(TryVerifyState.NOT_IDIOM)
+            return state
+        # 成语合法，更新状态
+        self.add_history_idiom(idiom)
+        score_k = 0.5 ** self.get_already_used_num(idiom) # 每被使用过一次，得分减半
+        if(score_k != 1):
+            state.append(TryVerifyState.ALREADY_USED)
+        self.add_already_idiom(idiom)
+        state.append(TryVerifyState.VERIFIED)
         self.last_idiom = idiom
         self.last_char = idiom[-1]
-        self.add_score(user_id, 1)
+        self.add_score(user_id, 1 * score_k) # 先加 1 分
         if idiom in IdiomGame.ALL_IDIOMS:
-            self.add_score(user_id, 4) # 再加 4 分
+            state.append(TryVerifyState.VERIFIED_AND_REAL)
+            self.add_score(user_id, 4 * score_k) # 再加 4 分
         self.remain_rounds -= 1
         if self.remain_rounds <= 0:
             self.now_playing = False
-            return TryVerifyState.VERIFIED_GAME_END
+            state.append(TryVerifyState.GAME_END)
         if not self.is_nextable(self.last_char):
             # 没有成语可以接了，自动跳过
             self._skip_idiom_async()
-            return TryVerifyState.VERIFIED_BUT_NO_NEXT
-        if idiom in IdiomGame.ALL_IDIOMS:
-            return TryVerifyState.VERIFIED_AND_REAL # 真实成语
-        return TryVerifyState.VERIFIED
+            self.add_buff_score(-100)
+            state.append(TryVerifyState.BUT_NO_NEXT)
+        return state
 
     def get_user_score(self, user_id: str) -> float:
         if user_id not in self.score_board:
             return 0
         # 避免浮点数精度问题导致过长
-        handled_score = round(self.score_board[user_id]["score"], 1)
+        handled_score = round(self.score_board[user_id]["score"] + self.all_buff_score, 1)
         return handled_score
 
     def add_score(self, user_id: str, score: int):
@@ -233,9 +276,9 @@ class IdiomGame:
     @classmethod
     def random_idiom_starting_with(cls, first_char: str) -> Optional[str]:
         cls.init_lexicon()
-        if first_char not in cls.IDIOM_FIRST_CHAR:
+        if first_char not in cls.AVALIABLE_IDIOM_FIRST_CHAR:
             return None
-        return secrets.choice(cls.IDIOM_FIRST_CHAR[first_char])
+        return secrets.choice(cls.AVALIABLE_IDIOM_FIRST_CHAR[first_char])
 
     @classmethod
     def init_lexicon(cls):
@@ -249,7 +292,10 @@ class IdiomGame:
 
         # 词语大表
         with open(ASSETS_PATH / "lexicon" / "ci.json", "r", encoding="utf-8") as f:
-            cls.ALL_WORDS = json.load(f)
+            jsonData = json.load(f)
+            cls.ALL_WORDS = [item["ci"] for item in jsonData]
+            logger.debug(f"Loaded {len(cls.ALL_WORDS)} words from ci.json")
+            logger.debug(f"Sample words: {cls.ALL_WORDS[:5]}")
 
         COMMON_WORDS = []
         # 读取 COMMON 词语大表
@@ -258,6 +304,8 @@ class IdiomGame:
                 word = line.strip()
                 if len(word) == 4:
                     COMMON_WORDS.append(word)
+        logger.debug(f"Loaded {len(COMMON_WORDS)} common words from common.txt")
+        logger.debug(f"Sample common words: {COMMON_WORDS[:5]}")
 
         # 读取 THUOCL 成语库
         with open(
@@ -265,7 +313,9 @@ class IdiomGame:
             "r",
             encoding="utf-8",
         ) as f:
-            THUOCL_IDIOMS = [line.split(" ")[0].strip() for line in f]
+            THUOCL_IDIOMS = [line.split(" ")[0].split("\t")[0].strip() for line in f]
+            logger.debug(f"Loaded {len(THUOCL_IDIOMS)} idioms from THUOCL_chengyu.txt")
+            logger.debug(f"Sample idioms: {THUOCL_IDIOMS[:5]}")
 
         # 读取 THUOCL 剩下的所有 txt 文件，只保留四字词
         THUOCL_WORDS = []
@@ -279,9 +329,11 @@ class IdiomGame:
                     encoding="utf-8",
                 ) as f:
                     for line in f:
-                        word = line.lstrip().split(" ")[0].strip()
+                        word = line.lstrip().split(" ")[0].split("\t")[0].strip()
                         if len(word) == 4:
                             THUOCL_WORDS.append(word)
+        logger.debug(f"Loaded {len(THUOCL_WORDS)} words from THUOCL txt files")
+        logger.debug(f"Sample words: {THUOCL_WORDS[:5]}")
 
         # 只有成语的大表
         cls.ALL_IDIOMS = [idiom["word"] for idiom in ALL_IDIOMS_INFOS] + THUOCL_IDIOMS
@@ -388,7 +440,7 @@ async def end_game(event: BaseEvent, group_id: str):
     result_text = UniMessage().text("游戏结束！\n最终得分榜：\n")
     score_board = instance.get_score_board()
     if len(score_board) == 0:
-        result_text += "无人得分！"
+        result_text += "无人得分！\n"
     else:
         # 按分数排序，名字用 at 的方式
         sorted_score = sorted(
@@ -400,6 +452,13 @@ async def end_game(event: BaseEvent, group_id: str):
                 + UniMessage().at(user_id)
                 + f": {round(info['score'] + instance.get_all_buff_score(), 1)} 分\n"
             )
+    if len(instance.idiom_history) == 0:
+        result_text += "\n本局没有任何接龙记录。"
+    else:
+        result_text += "\n你们的接龙记录是：\n"
+        history_lines = instance.display_history()
+        for line in history_lines:
+            result_text += line + "\n"
     await evt.send(await result_text.export())
     instance.clear_score_board()
 
@@ -441,6 +500,10 @@ async def _(target: DepLongTaskTarget):
     if not instance or not instance.get_playing_state():
         return
     avaliable_idiom = IdiomGame.random_idiom_starting_with(instance.get_last_char())
+    # 发送哈哈狗图片
+    with open(ASSETS_PATH / "img" / "dog" / "haha_dog.jpg", "rb") as f:
+        img_data = f.read()
+    await evt.send(await UniMessage().image(raw=img_data).export())
     await evt.send(await UniMessage().text(f"你们太菜了，全部扣100分！明明还可以接「{avaliable_idiom}」的！").export())
     idiom = await instance.skip_idiom(-100)
     await evt.send(
@@ -472,9 +535,9 @@ async def _(event: BaseEvent, msg: UniMsg, target: DepLongTaskTarget):
     user_idiom = msg.extract_plain_text().strip()
     user_id, user_name = get_user_info(event)
     state = await instance.try_verify_idiom(user_idiom, user_id)
-    if state == TryVerifyState.WRONG_FIRST_CHAR:
+    if TryVerifyState.WRONG_FIRST_CHAR in state:
         return
-    if state == TryVerifyState.NOT_IDIOM:
+    if TryVerifyState.NOT_IDIOM in state:
         await evt.send(
             await UniMessage()
             .at(user_id)
@@ -482,25 +545,44 @@ async def _(event: BaseEvent, msg: UniMsg, target: DepLongTaskTarget):
             .export()
         )
         return
-    if state == TryVerifyState.VERIFIED:
-        await evt.send(
-            await UniMessage()
-            .at(user_id)
-            .text(f" 接上了，喜提 1 分！你有 {instance.get_user_score(user_id)} 分！")
-            .export()
-        )
-    elif state == TryVerifyState.VERIFIED_AND_REAL:
-        await evt.send(
-            await UniMessage()
-            .at(user_id)
-            .text(f" 接上了，这是个真实成语，喜提 5 分！你有 {instance.get_user_score(user_id)} 分！")
-            .export()
-        )
-    if state == TryVerifyState.VERIFIED_GAME_END:
+    already_used_num = instance.get_already_used_num(user_idiom)
+    if TryVerifyState.VERIFIED_AND_REAL in state:
+        score = 5 * (0.5 ** (already_used_num - 1))
+        if already_used_num > 1:
+            await evt.send(
+                await UniMessage()
+                .at(user_id)
+                .text(f" 接上了，这是个被重复用过的成语，喜提 {score} 分！你有 {instance.get_user_score(user_id)} 分！")
+                .export()
+            )
+        else:
+            await evt.send(
+                await UniMessage()
+                .at(user_id)
+                .text(f" 接上了，这是个真实成语，喜提 5 分！你有 {instance.get_user_score(user_id)} 分！")
+                .export()
+            )
+    elif TryVerifyState.VERIFIED in state:
+        score = 1 * (0.5 ** (already_used_num - 1))
+        if already_used_num > 1:
+            await evt.send(
+                await UniMessage()
+                .at(user_id)
+                .text(f" 接上了，但重复了，喜提 {score} 分！你有 {instance.get_user_score(user_id)} 分！")
+                .export()
+            )
+        else:
+            await evt.send(
+                await UniMessage()
+                .at(user_id)
+                .text(f" 接上了，喜提 1 分！你有 {instance.get_user_score(user_id)} 分！")
+                .export()
+            )
+    if TryVerifyState.GAME_END in state:
         await evt.send(await UniMessage().text("全部回合结束！").export())
         await end_game(event, group_id)
         return
-    if state == TryVerifyState.VERIFIED_BUT_NO_NEXT:
+    if TryVerifyState.BUT_NO_NEXT in state:
         await evt.send(
             await UniMessage()
             .text("但是，这是条死路！你们全部都要扣 100 分！")

konabot/plugins/kona_ph/__init__.py

@@ -0,0 +1,101 @@
+from math import ceil
+from loguru import logger
+from nonebot_plugin_alconna import Alconna, Args, UniMessage, on_alconna
+from konabot.common.nb.qq_broadcast import qq_broadcast
+from konabot.plugins.kona_ph.core.storage import get_today_date
+from konabot.plugins.kona_ph.manager import PUZZLE_PAGE_SIZE, create_admin_commands, config, puzzle_manager
+from konabot.common.longtask import DepLongTaskTarget
+
+from nonebot_plugin_apscheduler import scheduler
+
+
+create_admin_commands()
+
+
+async def is_play_group(target: DepLongTaskTarget):
+    if target.channel_id in config.plugin_puzzle_playgroup:
+        return True
+    if target.target_id in target.channel_id:
+        return True
+    return False
+
+
+cmd_submit = on_alconna(Alconna(
+    "提交答案",
+    Args["flag", str],
+), rule=is_play_group)
+
+@cmd_submit.handle()
+async def _(flag: str, target: DepLongTaskTarget):
+    async with puzzle_manager() as manager:
+        result = manager.submit(target.target_id, flag)
+        await target.send_message(result.get_unimessage())
+
+
+cmd_query = on_alconna(Alconna(
+    r"re:(?:(?:所以|话)说?)?今天的题目是什么[啊呀哇呢]?(?:\?？)?"
+), rule=is_play_group)
+
+@cmd_query.handle()
+async def _(target: DepLongTaskTarget):
+    async with puzzle_manager() as manager:
+        p = manager.get_today_puzzle()
+        if p is None:
+            return await target.send_message("今天无题，改日再来吧！")
+        await target.send_message(p.get_unimessage())
+
+
+cmd_history = on_alconna(Alconna(
+    "历史题目",
+    Args["page?", int],
+    Args["index_id?", str],
+), rule=is_play_group)
+
+@cmd_history.handle()
+async def _(target: DepLongTaskTarget, index_id: str = "", page: int = 1):
+    async with puzzle_manager() as manager:
+        today = get_today_date()
+        if index_id:
+            index_id = index_id.removeprefix("#")
+            if index_id == manager.daily_puzzle_of_date.get(today, ""):
+                puzzle = manager.puzzle_data[manager.daily_puzzle[index_id].raw_id]
+                return await target.send_message(puzzle.get_unimessage())
+            if index_id in manager.daily_puzzle:
+                puzzle = manager.puzzle_data[manager.daily_puzzle[index_id].raw_id]
+                msg = puzzle.get_unimessage()
+                msg = msg.text(f"\n\n------\n\n题解：{puzzle.flag}")
+                return await target.send_message(msg)
+            return await target.send_message("没有这道题哦")
+        msg = UniMessage.text("====== 历史题目清单 ======\n\n")
+        puzzles = [
+            (manager.puzzle_data[manager.daily_puzzle[i].raw_id], d)
+            for d, i in manager.daily_puzzle_of_date.items()
+        ]
+        puzzles = sorted(puzzles, key=lambda u: u[1], reverse=True)
+        count_pages = ceil(len(puzzles) / PUZZLE_PAGE_SIZE)
+        if page <= 0 or page > count_pages:
+            return await target.send_message(UniMessage.text(
+                f"页数只有 1 ~ {count_pages} 啦！"
+            ))
+        puzzles = puzzles[(page - 1) * PUZZLE_PAGE_SIZE: page * PUZZLE_PAGE_SIZE]
+        for p, d in puzzles:
+            info = manager.daily_puzzle[manager.daily_puzzle_of_date[d]]
+            msg = msg.text(
+                f"- [#{p.index_id}: {len(info.success_users)}/{len(info.tried_users)}]"
+                f" {p.title} ({d})"
+            )
+            msg = msg.text("\n")
+        msg = msg.text(f"\n==== 第 {page} 页，共 {count_pages} 页 ====")
+        await target.send_message(msg)
+
+
+@scheduler.scheduled_job("cron", hour="8")
+async def _():
+    async with puzzle_manager() as manager:
+        puzzle = manager.get_today_puzzle()
+        if puzzle is not None:
+            logger.info(f"找到了题目 {puzzle.raw_id}，发送")
+            await qq_broadcast(config.plugin_puzzle_playgroup, puzzle.get_unimessage())
+        else:
+            logger.info("自动任务：没有找到题目，跳过")
+

konabot/plugins/kona_ph/core/storage.py

@@ -0,0 +1,314 @@
+import asyncio
+import datetime
+import random
+
+from contextlib import asynccontextmanager
+from pathlib import Path
+from typing import Any
+
+import nanoid
+
+from nonebot_plugin_alconna import UniMessage
+from pydantic import BaseModel, Field, ValidationError
+
+from konabot.common.path import DATA_PATH
+
+
+KONAPH_BASE = DATA_PATH / "KonaPH"
+KONAPH_DATA_JSON = KONAPH_BASE / "data.json"
+KONAPH_IMAGE_BASE = KONAPH_BASE / "imgs"
+
+# 保证所有文件夹存在
+KONAPH_BASE.mkdir(exist_ok=True)
+KONAPH_IMAGE_BASE.mkdir(exist_ok=True)
+
+
+class Puzzle(BaseModel):
+    raw_id: str
+    "用于给出题者管理的 ID"
+
+    index_id: str
+    "展出的 ID，以展出顺序为准"
+
+    title: str
+    content: str
+    img_name: str
+    author_id: str
+    flag: str
+
+    ready: bool = False
+    published: bool = False
+    pinned: bool = False
+
+    created_at: datetime.datetime = Field(default_factory=datetime.datetime.now)
+
+    def get_image_path(self) -> Path:
+        return KONAPH_IMAGE_BASE / self.img_name
+
+    def get_unimessage(self) -> UniMessage[Any]:
+        result = UniMessage.text(f"[KonaPH#{self.index_id}] {self.title}")
+        result = result.text(f"\n\n{self.content}")
+
+        if self.img_name:
+            result = result.text("\n\n").image(raw=self.get_image_path().read_bytes())
+
+        result = result.text("\n\n出题者：").at(self.author_id)
+
+        return result
+
+    def add_image(self, img: bytes, suffix: str = ".png"):
+        if self.img_name:
+            self.get_image_path().unlink(True)
+        img_id = nanoid.generate(
+            "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz",
+            21,
+        )
+        self.img_name = f"{img_id}{suffix}"
+        self.get_image_path().write_bytes(img)
+
+    def remove_image(self):
+        if self.img_name:
+            self.get_image_path().unlink(True)
+            self.img_name = ""
+
+
+class PuzzleSubmission(BaseModel):
+    success: bool
+    flag: str
+    time: datetime.datetime
+
+
+class DailyPuzzleInfo(BaseModel):
+    raw_id: str
+    time: datetime.date
+    tried_users: set[str] = set()
+    success_users: dict[str, datetime.datetime] = {}
+
+
+class PuzzleSubmissionResultMessage(BaseModel):
+    success: bool
+    rank: int = -1
+    message: str = ""
+
+    def get_unimessage(self) -> UniMessage[Any]:
+        if self.success:
+            return UniMessage.text(f"🎉 恭喜你答对了！你是今天第 {self.rank} 个解出来的！")
+        return UniMessage.text(self.message)
+
+
+def get_today_date() -> datetime.date:
+    now = datetime.datetime.now()
+    if now.hour < 8:
+        now -= datetime.timedelta(days=1)
+    return now.date()
+
+
+class PuzzleManager(BaseModel):
+    puzzle_data: dict[str, Puzzle] = {}
+
+    daily_puzzle: dict[str, DailyPuzzleInfo] = {}
+    daily_puzzle_of_date: dict[datetime.date, str] = {}
+
+    puzzle_pinned: str = ""
+    unpublished_puzzles: set[str] = set()
+    unready_puzzles: set[str] = set()
+    published_puzzles: set[str] = set()
+
+    index_id_counter: int = 1
+    submissions: dict[str, dict[str, list[PuzzleSubmission]]] = {}
+    last_pubish_date: datetime.date = Field(
+        default_factory=lambda: get_today_date() - datetime.timedelta(days=1)
+    )
+    last_checked_date: datetime.date = Field(
+        default_factory=lambda: get_today_date() - datetime.timedelta(days=1)
+    )
+
+    def publish_puzzle(self, raw_id: str):
+        assert raw_id in self.puzzle_data
+
+        self.unpublished_puzzles -= set(raw_id)
+        self.unready_puzzles -= set(raw_id)
+        p = self.puzzle_data[raw_id]
+        p.index_id = str(self.index_id_counter)
+        p.ready = True
+        p.published = True
+        p.pinned = False
+        self.puzzle_pinned = ""
+        self.last_pubish_date = get_today_date()
+        self.last_checked_date = self.last_pubish_date
+        self.daily_puzzle[p.index_id] = DailyPuzzleInfo(
+            raw_id=raw_id,
+            time=self.last_pubish_date,
+        )
+        self.daily_puzzle_of_date[self.last_pubish_date] = p.index_id
+        self.published_puzzles.add(raw_id)
+
+        self.index_id_counter += 1
+
+    def admin_mark_ready(self, raw_id: str, ready: bool = True):
+        if raw_id not in self.puzzle_data:
+            return
+        if ready:
+            self.unready_puzzles -= set(raw_id)
+            if raw_id not in self.published_puzzles:
+                self.unpublished_puzzles.add(raw_id)
+            p = self.puzzle_data[raw_id]
+            p.ready = True
+            p.published = raw_id in self.published_puzzles
+        else:
+            self.unready_puzzles.add(raw_id)
+            self.unpublished_puzzles -= set(raw_id)
+            p = self.puzzle_data[raw_id]
+            p.ready = False
+            p.published = False
+            # if p.raw_id == self.puzzle_pinned:
+            #     self.puzzle_pinned = ""
+
+    def admin_pin_puzzle(self, raw_id: str):
+        if self.puzzle_pinned:
+            p = self.puzzle_data.get(self.puzzle_pinned)
+            if p is not None:
+                p.pinned = False
+        if raw_id in self.puzzle_data:
+            p = self.puzzle_data[raw_id]
+            p.pinned = True
+            self.puzzle_pinned = raw_id
+        else:
+            self.puzzle_pinned = ""
+
+    def get_today_puzzle(self, strong: bool = False) -> Puzzle | None:
+        today = get_today_date()
+        if today in self.daily_puzzle_of_date:
+            index_id = self.daily_puzzle_of_date[today]
+            info = self.daily_puzzle[index_id]
+            return self.puzzle_data[info.raw_id]
+        if today == self.last_checked_date and not strong:
+            return
+        self.last_checked_date = today
+        if self.puzzle_pinned and self.puzzle_pinned in self.puzzle_data:
+            d = self.puzzle_pinned
+            self.publish_puzzle(d)
+            self.puzzle_pinned = ""
+            return self.puzzle_data[d]
+        elif len(self.unpublished_puzzles) > 0:
+            d = random.choice(list(self.unpublished_puzzles))
+            self.publish_puzzle(d)
+            return self.puzzle_data[d]
+
+    def get_today_info(self) -> DailyPuzzleInfo | None:
+        p = self.get_today_puzzle()
+        if p is None:
+            return
+        return self.daily_puzzle[p.index_id]
+
+    def submit(self, user: str, flag: str) -> PuzzleSubmissionResultMessage:
+        p = self.get_today_puzzle()
+        d = self.get_today_info()
+        now = datetime.datetime.now()
+        if p is None or d is None:
+            return PuzzleSubmissionResultMessage(
+                success=False,
+                message="今天没有题哦，改天再来吧！",
+            )
+        if user in d.success_users:
+            return PuzzleSubmissionResultMessage(
+                success=False,
+                message="你今天已经答对过啦！不用重复提交哦！",
+            )
+        if flag != p.flag:
+            d.tried_users.add(user)
+            self.submissions.setdefault(p.raw_id, {}).setdefault(user, []).append(PuzzleSubmission(
+                success=False,
+                flag=flag,
+                time=now,
+            ))
+            return PuzzleSubmissionResultMessage(
+                success=False,
+                message="❌ 答错了，请检查你的答案哦",
+            )
+        d.tried_users.add(user)
+        d.success_users[user] = now
+        self.submissions.setdefault(p.raw_id, {}).setdefault(user, []).append(PuzzleSubmission(
+            success=True,
+            flag=flag,
+            time=now,
+        ))
+        return PuzzleSubmissionResultMessage(
+            success=True,
+            rank=len(d.success_users),
+        )
+
+    def admin_create_puzzle(self, user: str):
+        p = Puzzle(
+            raw_id=nanoid.generate(
+                "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz",
+                12,
+            ),
+            index_id="",
+            title="示例标题",
+            content="题目的内容填写内容",
+            img_name="",
+            author_id=user,
+            flag="konaph{this_is_a_flag}",
+            ready=False,
+            published=False,
+        )
+        self.unready_puzzles.add(p.raw_id)
+        self.puzzle_data[p.raw_id] = p
+        return p
+
+    def get_puzzles_of_user(self, user: str):
+        return sorted([
+            p for p in self.puzzle_data.values()
+            if p.author_id == user
+        ], key=lambda p: p.created_at, reverse=True)
+
+    def get_report_yesterday(self):
+        yesterday = get_today_date() - datetime.timedelta(days=1)
+        index_id = self.daily_puzzle_of_date.get(yesterday)
+        if index_id is None:
+            return None
+        info = self.daily_puzzle[index_id]
+        puzzle = self.puzzle_data[info.raw_id]
+        message = UniMessage.text(f"[KonaPH#{index_id}] 「{puzzle.title}」解答报告")
+
+        if len(info.success_users) == 0:
+            message = message.text(
+                "\n\n昨日，竟无人解出此题！"
+            )
+        else:
+            message = message.text(
+                f"\n\n昨日，共有 {len(info.success_users)} 人解出此题。\n\n前五名的解答者："
+            )
+            us = [(u, d) for u, d in info.success_users.items()]
+            us = sorted(us, key=lambda t: t[1])
+            us = us[:5]
+            for u, _ in us:
+                m = self.submissions[puzzle.raw_id][u][-1]
+                message = message.text("- ").at(u).text(f" 于 {m.time.strftime('%H:%M')}")
+
+        message = message.text("\n\n出题者：").at(puzzle.author_id)
+        return message
+
+
+lock = asyncio.Lock()
+
+
+def read_data():
+    try:
+        data_raw = KONAPH_DATA_JSON.read_text()
+        return PuzzleManager.model_validate_json(data_raw)
+    except (FileNotFoundError, ValidationError):
+        return PuzzleManager()
+
+
+def write_data(data: PuzzleManager):
+    KONAPH_DATA_JSON.write_text(data.model_dump_json())
+
+
+@asynccontextmanager
+async def puzzle_manager():
+    async with lock:
+        data = read_data()
+        yield data
+        write_data(data)

konabot/plugins/kona_ph/manager.py

@@ -0,0 +1,329 @@
+import datetime
+from math import ceil
+from typing import Any
+from nonebot import get_plugin_config
+from nonebot_plugin_alconna import Alconna, Args, Image, Option, Query, Subcommand, UniMessage, on_alconna
+from pydantic import BaseModel
+
+from konabot.common.longtask import DepLongTaskTarget
+from konabot.common.nb.extract_image import download_image_bytes
+from konabot.common.nb.qq_broadcast import qq_broadcast
+from konabot.plugins.kona_ph.core.storage import Puzzle, get_today_date, puzzle_manager
+
+PUZZLE_PAGE_SIZE = 10
+
+
+class PuzzleConfig(BaseModel):
+    plugin_puzzle_manager: list[str] = []
+    plugin_puzzle_admin: list[str] = []
+    plugin_puzzle_playgroup: list[str] = []
+
+
+config = get_plugin_config(PuzzleConfig)
+
+
+def is_puzzle_manager(target: DepLongTaskTarget):
+    return target.target_id in config.plugin_puzzle_manager or is_puzzle_admin(target)
+
+
+def is_puzzle_admin(target: DepLongTaskTarget):
+    return target.target_id in config.plugin_puzzle_admin
+
+
+def get_puzzle_info_message(puzzle: Puzzle) -> UniMessage[Any]:
+    status = "✅ 已准备，待发布" if puzzle.ready and not puzzle.published else \
+    (f"🟢 已发布: #{puzzle.index_id}" if puzzle.published else "⚙️ 未准备")
+
+    status_suffix = ""
+    if puzzle.pinned:
+        status_suffix += " | 📌 已被管理员置顶"
+
+    msg = UniMessage.text(
+        f"--- 谜题信息 ---\n"
+        f"Raw ID: {puzzle.raw_id}\n"
+        f"标题: {puzzle.title}\n"
+        f"出题者 ID: {puzzle.author_id}\n"
+        f"创建时间: {puzzle.created_at.strftime('%Y-%m-%d %H:%M:%S')}\n"
+        f"Flag: {puzzle.flag}\n"
+        f"状态: {status}{status_suffix}\n\n"
+        f"{puzzle.content}"
+    )
+
+    if puzzle.img_name:
+        msg = msg.image(raw=puzzle.get_image_path().read_bytes())
+
+    msg = msg.text(f"\n---------\n使用 `konaph ready {puzzle.raw_id}` 完成编辑")
+
+    return msg
+
+
+def create_admin_commands():
+    cmd_admin = on_alconna(
+        Alconna(
+            "konaph",
+            Subcommand("create", dest="create"),
+            Subcommand("ready", Args["raw_id", str], dest="ready"),
+            Subcommand("unready", Args["raw_id", str], dest="unready"),
+            Subcommand("info", Args["raw_id", str], dest="info"),
+            Subcommand("my", Args["page?", int], dest="my"),
+            Subcommand("all", Option("--ready", alias=["-r"]), Args["page?", int], dest="all"),
+            Subcommand("pin", Args["raw_id?", str], dest="pin"),
+            Subcommand("unpin", dest="unpin"),
+            Subcommand(
+                "modify",
+                Args["raw_id?", str],
+                Option("--title", Args["title", str], alias=["-t"]),
+                Option("--description", Args["description", str], alias=["-d"]),
+                Option("--image", Args["image?", Image], alias=["-i"]),
+                Option("--flag", Args["flag", str], alias=["-f"]),
+                Option("--remove-image"),
+                dest="modify",
+            ),
+            Subcommand("publish", Args["raw_id?", str], dest="publish"),
+        ),
+        rule=is_puzzle_manager,
+    )
+
+    @cmd_admin.assign("$main")
+    async def _(target: DepLongTaskTarget):
+        msg = UniMessage.text("==== [KonaPH] 指令一览 ====\n\n")
+        msg = msg.text("konaph create - 创建一个新的谜题\n")
+        msg = msg.text("konaph ready <id> - 准备好一道谜题\n")
+        msg = msg.text("konaph unready <id> - 取消准备一道谜题\n")
+        msg = msg.text("konaph info <id> - 查看谜题\n")
+        msg = msg.text("konaph my <page?> - 查看我的谜题列表\n")
+        msg = msg.text("konaph modify - 查看如何修改谜题信息\n")
+
+        if is_puzzle_admin(target):
+            msg = msg.text("konaph all [--ready] <page?> - 查看所有谜题\n")
+            msg = msg.text("konaph pin - 查看当前置顶谜题\n")
+            msg = msg.text("konaph pin <id> - 置顶一个谜题\n")
+            msg = msg.text("konaph unpin - 取消置顶所有谜题\n")
+            msg = msg.text("konaph publish <id?> - 强制发题")
+
+        await target.send_message(msg)
+
+    @cmd_admin.assign("create")
+    async def _(target: DepLongTaskTarget):
+        async with puzzle_manager() as manager:
+            puzzle = manager.admin_create_puzzle(target.target_id)
+        await target.send_message(UniMessage.text(
+            f"✨ 创建好啦！谜题 ID 为 {puzzle.raw_id}\n\n"
+            f"- 输入 `konaph info {puzzle.raw_id}` 获得谜题的信息\n"
+            f"- 输入 `konaph my` 查看你创建的谜题\n"
+            f"- 输入 `konaph modify` 查看更改谜题的方法"
+        ))
+
+    @cmd_admin.assign("ready")
+    async def _(raw_id: str, target: DepLongTaskTarget):
+        async with puzzle_manager() as manager:
+            if raw_id not in manager.puzzle_data:
+                return await target.send_message(UniMessage.text(
+                    "你输入的谜题不存在！输入 `konaph my` 查看你创建的谜题"
+                ))
+            p = manager.puzzle_data[raw_id]
+            if p.author_id != target.target_id and not is_puzzle_admin(target):
+                return await target.send_message(UniMessage.text(
+                    "这不是你的题，你没有权限编辑！输入 `konaph my` 查看你创建的谜题"
+                ))
+            if p.ready:
+                return await target.send_message(UniMessage.text(
+                    "题目早就准备好啦！"
+                ))
+            manager.admin_mark_ready(raw_id, True)
+            await target.send_message(UniMessage.text(
+                f"谜题「{p.title}」已经准备就绪！"
+            ))
+
+    @cmd_admin.assign("unready")
+    async def _(raw_id: str, target: DepLongTaskTarget):
+        async with puzzle_manager() as manager:
+            if raw_id not in manager.puzzle_data:
+                return await target.send_message(UniMessage.text(
+                    "你输入的谜题不存在！输入 `konaph my` 查看你创建的谜题"
+                ))
+            p = manager.puzzle_data[raw_id]
+            if p.author_id != target.target_id and not is_puzzle_admin(target):
+                return await target.send_message(UniMessage.text(
+                    "这不是你的题，你没有权限编辑！输入 `konaph my` 查看你创建的谜题"
+                ))
+            if not p.ready:
+                return await target.send_message(UniMessage.text(
+                    f"谜题「{p.title}」已经是未取消状态了！"
+                ))
+            if p.published:
+                return await target.send_message(UniMessage.text(
+                    "已发布的谜题不能取消准备状态！"
+                ))
+
+            manager.admin_mark_ready(raw_id, False)
+            await target.send_message(UniMessage.text(
+                f"谜题「{p.title}」已经取消准备！"
+            ))
+
+    @cmd_admin.assign("info")
+    async def _(raw_id: str, target: DepLongTaskTarget):
+        async with puzzle_manager() as manager:
+            if raw_id not in manager.puzzle_data:
+                return await target.send_message(UniMessage.text(
+                    "你输入的谜题不存在！输入 `konaph my` 查看你创建的谜题"
+                ))
+            p = manager.puzzle_data[raw_id]
+            if p.author_id != target.target_id and not is_puzzle_admin(target):
+                return await target.send_message(UniMessage.text(
+                    "这不是你的题，你没有权限查看详细信息！"
+                ))
+
+            await target.send_message(get_puzzle_info_message(p))
+
+    @cmd_admin.assign("my")
+    async def _(target: DepLongTaskTarget, page: int = 1):
+        async with puzzle_manager() as manager:
+            puzzles = manager.get_puzzles_of_user(target.target_id)
+            if len(puzzles) == 0:
+                return await target.send_message(UniMessage.text(
+                    "你没有谜题哦，使用 `konaph create` 创建一个吧！"
+                ))
+            count_pages = ceil(len(puzzles) / PUZZLE_PAGE_SIZE)
+            if page <= 0 or page > count_pages:
+                return await target.send_message(UniMessage.text(
+                    f"页数只有 1 ~ {count_pages} 啦！"
+                ))
+            puzzles = puzzles[(page - 1) * PUZZLE_PAGE_SIZE: page * PUZZLE_PAGE_SIZE]
+            message = UniMessage.text("==== 我的谜题 ====\n\n")
+            for p in puzzles:
+                message = message.text("- ")
+                if p.pinned:
+                    message = message.text("[📌]")
+                if p.published:
+                    message = message.text(f"[#{p.index_id}] ")
+                elif p.ready:
+                    message = message.text("[✅] ")
+                else:
+                    message = message.text("[⚙️] ")
+                message = message.text(f"{p.title} ({p.raw_id})")
+                message = message.text("\n")
+            message = message.text(f"\n==== 第 {page} 页，共 {count_pages} 页 ====")
+            await target.send_message(message)
+
+    @cmd_admin.assign("all")
+    async def _(target: DepLongTaskTarget, ready: Query[bool] = Query("ready"), page: int = 1):
+        if not is_puzzle_admin(target):
+            return await target.send_message(UniMessage.text("你没有权限查看所有的哦"))
+        async with puzzle_manager() as manager:
+            puzzles = [*manager.puzzle_data.values()]
+            if ready.available:
+                puzzles = [p for p in puzzles if p.ready]
+            puzzles = sorted(puzzles, key=lambda p: p.created_at, reverse=True)
+            count_pages = ceil(len(puzzles) / PUZZLE_PAGE_SIZE)
+            if page <= 0 or page > count_pages:
+                return await target.send_message(UniMessage.text(
+                    f"页数只有 1 ~ {count_pages} 啦！"
+                ))
+            puzzles = puzzles[(page - 1) * PUZZLE_PAGE_SIZE: page * PUZZLE_PAGE_SIZE]
+            message = UniMessage.text("==== 所有谜题 ====\n\n")
+            for p in puzzles:
+                message = message.text("- ")
+                if p.pinned:
+                    message = message.text("[📌]")
+                if p.published:
+                    message = message.text(f"[#{p.index_id}] ")
+                elif p.ready:
+                    message = message.text("[✅] ")
+                else:
+                    message = message.text("[⚙️] ")
+                message = message.text(f"{p.title} ({p.raw_id} by {p.author_id})")
+                message = message.text("\n")
+            message = message.text(f"\n==== 第 {page} 页，共 {count_pages} 页 ====")
+            await target.send_message(message)
+
+    @cmd_admin.assign("pin")
+    async def _(target: DepLongTaskTarget, raw_id: str = ""):
+        if not is_puzzle_admin(target):
+            return await target.send_message(UniMessage.text(
+                "你没有权限使用该指令"
+            ))
+
+        async with puzzle_manager() as manager:
+            if raw_id == "":
+                if manager.puzzle_pinned:
+                    return await target.send_message(UniMessage.text(
+                        f"被 Pin 的谜题 ID = {manager.puzzle_pinned}"
+                    ))
+                return await target.send_message("没有置顶谜题")
+            if raw_id not in manager.unpublished_puzzles:
+                return await target.send_message(UniMessage.text(
+                    "这个谜题已经发布了，或者还没准备好，或者不存在"
+                ))
+            manager.admin_pin_puzzle(raw_id)
+            return await target.send_message(f"已置顶谜题 {raw_id}")
+
+    @cmd_admin.assign("unpin")
+    async def _(target: DepLongTaskTarget):
+        if not is_puzzle_admin(target):
+            return await target.send_message(UniMessage.text(
+                "你没有权限使用该指令"
+            ))
+        async with puzzle_manager() as manager:
+            manager.admin_pin_puzzle("")
+            return await target.send_message("已取消所有置顶")
+
+    @cmd_admin.assign("modify")
+    async def _(
+        target: DepLongTaskTarget,
+        raw_id: str = "",
+        title: str | None = None,
+        description: str | None = None,
+        flag: str | None = None,
+        image: Image | None = None,
+        remove_image: Query[bool] = Query("--remove-image"),
+    ):
+        if raw_id == "":
+            return await target.send_message(
+                "konaph modify <raw_id> - 修改一个谜题\n\n"
+                "支持的参数：\n"
+                "  --title <str> 标题\n"
+                "  --description <str> 题目详情描述（用直引号包裹以支持多行）\n"
+                "  --flag <str> flag\n"
+                "  --image <图片> 图片\n"
+                "  --remove-image 删除图片"
+            )
+
+        async with puzzle_manager() as manager:
+            if raw_id not in manager.puzzle_data:
+                return await target.send_message("没有这个谜题")
+            p = manager.puzzle_data[raw_id]
+            if not is_puzzle_admin(target) and target.target_id != p.author_id:
+                return await target.send_message("你没有权限编辑这个谜题")
+            if title is not None:
+                p.title = title
+            if description is not None:
+                p.content = description
+            if flag is not None:
+                p.flag = flag
+            if image is not None and image.url is not None:
+                b = await download_image_bytes(image.url)
+                p.add_image(b.unwrap())
+            elif remove_image.available:
+                p.remove_image()
+
+            info2 = get_puzzle_info_message(p)
+
+            return await target.send_message("修改好啦！看看效果：\n\n" + info2)
+
+    @cmd_admin.assign("publish")
+    async def _(target: DepLongTaskTarget, raw_id: str | None = None):
+        today = get_today_date()
+        async with puzzle_manager() as manager:
+            if today in manager.daily_puzzle_of_date:
+                return await target.send_message("今日已经有题了哦")
+            manager.last_checked_date = today - datetime.timedelta(days=-1)
+            if raw_id is not None:
+                manager.admin_pin_puzzle(raw_id)
+            p = manager.get_today_puzzle(strong=True)
+            if p is None:
+                return await target.send_message("上架失败了orz，可能是没题了")
+            await qq_broadcast(config.plugin_puzzle_playgroup, p.get_unimessage())
+            return await target.send_message("Ok!")
+
+    return cmd_admin

konabot/plugins/man/__init__.py

@@ -53,7 +53,7 @@ async def _(
     if doc is None:
         # 检索模式
         if section is None:
-            section_set = {1}
+            section_set = {1, 7}
         else:
             section_set = {section}
         if 1 in section_set and is_admin(event):
@@ -75,7 +75,7 @@ async def _(
     else:
         # 查阅模式
         if section is None:
-            section_set = {1}
+            section_set = {1, 7}
         else:
             section_set = {section}
         if 1 in section_set and is_admin(event):

konabot/plugins/simple_notify/__init__.py

@@ -1,25 +1,20 @@
+import aiohttp
 import asyncio as asynkio
-import datetime
+from math import ceil
 from pathlib import Path
-from typing import Any, Literal, cast
+from typing import Any
 
+import nanoid
 import nonebot
 import ptimeparse
 from loguru import logger
-from nonebot import on_message
+from nonebot import get_plugin_config, on_message
 from nonebot.adapters import Event
-from nonebot.adapters.console import Bot as ConsoleBot
-from nonebot.adapters.console.event import MessageEvent as ConsoleMessageEvent
-from nonebot.adapters.discord import Bot as DiscordBot
-from nonebot.adapters.discord.event import MessageEvent as DiscordMessageEvent
-from nonebot.adapters.onebot.v11 import Bot as OnebotV11Bot
-from nonebot.adapters.onebot.v11.event import (
-    GroupMessageEvent as OnebotV11GroupMessageEvent,
-)
-from nonebot.adapters.onebot.v11.event import MessageEvent as OnebotV11MessageEvent
-from nonebot_plugin_alconna import UniMessage, UniMsg
+from nonebot_plugin_alconna import Alconna, Args, Subcommand, UniMessage, UniMsg, on_alconna
 from pydantic import BaseModel
 
+from konabot.common.longtask import DepLongTaskTarget, LongTask, create_longtask, handle_long_task, longtask_data
+
 evt = on_message()
 
 (Path(__file__).parent.parent.parent.parent / "data").mkdir(exist_ok=True)
@@ -27,28 +22,37 @@ DATA_FILE_PATH = Path(__file__).parent.parent.parent.parent / "data" / "notify.j
 DATA_FILE_LOCK = asynkio.Lock()
 
 ASYNK_TASKS: set[asynkio.Task[Any]] = set()
+LONG_TASK_NAME = "TASK_SIMPLE_NOTIFY"
+PAGE_SIZE = 6
 
-
-class Notify(BaseModel):
-    platform: Literal["console", "qq", "discord"]
-
-    target: str
-    "需要接受通知的个体"
-
-    target_env: str | None
-    "在哪里进行通知，如果是 None 代表私聊通知"
-
-    notify_time: datetime.datetime
-    notify_msg: str
-
-    def get_str(self):
-        return f"{self.target}-{self.target_env}-{self.platform}-{self.notify_time}"
+FMT_STRING = "%Y年%m月%d日 %H:%M:%S"
 
 
 class NotifyConfigFile(BaseModel):
     version: int = 2
-    notifies: list[Notify] = []
-    unsent: list[Notify] = []
+    notify_channels: dict[str, str] = {}
+
+
+class NotifyPluginConfig(BaseModel):
+    plugin_notify_enable_ntfy: bool = False
+    plugin_notify_base_url: str = ""
+    plugin_notify_access_token: str = ""
+    plugin_notify_prefix: str = "kona-notice-"
+
+
+config = get_plugin_config(NotifyPluginConfig)
+
+
+async def send_notify_to_ntfy_instance(msg: str, channel: str):
+    if not config.plugin_notify_enable_ntfy:
+        return
+    url = f"{config.plugin_notify_base_url}/{channel}"
+
+    async with aiohttp.ClientSession() as session:
+        session.headers["Authorization"] = f"Bearer {config.plugin_notify_access_token}"
+        session.headers["Title"] = "🔔 此方 BOT 提醒"
+        async with session.post(url, data=msg) as response:
+            logger.info(f"访问 {url} 的结果是 {response.status}")
 
 
 def load_notify_config() -> NotifyConfigFile:
@@ -65,89 +69,8 @@ def save_notify_config(config: NotifyConfigFile):
     DATA_FILE_PATH.write_text(config.model_dump_json(indent=4))
 
 
-async def notify_now(notify: Notify):
-    if notify.platform == "console":
-        bot = [b for b in nonebot.get_bots().values() if isinstance(b, ConsoleBot)]
-        if len(bot) != 1:
-            logger.warning(f"提醒未成功发送出去：{nonebot.get_bots()} {notify}")
-            return False
-        bot = bot[0]
-        await bot.send_private_message(notify.target, f"代办通知：{notify.notify_msg}")
-    elif notify.platform == "discord":
-        bot = [b for b in nonebot.get_bots().values() if isinstance(b, DiscordBot)]
-        if len(bot) != 1:
-            logger.warning(f"提醒未成功发送出去：{nonebot.get_bots()} {notify}")
-            return False
-        bot = bot[0]
-        channel = await bot.create_DM(recipient_id=int(notify.target))
-        await bot.send_to(channel.id, f"代办通知：{notify.notify_msg}")
-    elif notify.platform == "qq":
-        bot = [b for b in nonebot.get_bots().values() if isinstance(b, OnebotV11Bot)]
-        if len(bot) != 1:
-            logger.warning(f"提醒未成功发送出去：{nonebot.get_bots()} {notify}")
-            return False
-        bot = bot[0]
-        if notify.target_env is None:
-            await bot.send_private_msg(
-                user_id=int(notify.target),
-                message=cast(
-                    Any,
-                    await UniMessage.text(f"代办通知：{notify.notify_msg}").export(
-                        bot=bot,
-                    ),
-                ),
-            )
-        else:
-            await bot.send_group_msg(
-                group_id=int(notify.target_env),
-                message=cast(
-                    Any,
-                    await UniMessage()
-                    .at(notify.target)
-                    .text(f" 代办通知：{notify.notify_msg}")
-                    .export(bot=bot),
-                ),
-            )
-    else:
-        logger.warning(f"提醒未成功发送出去：{notify}")
-        return False
-    return True
-
-
-def create_notify_task(notify: Notify, fail2remove: bool = True):
-    async def mission():
-        begin_time = datetime.datetime.now()
-        if begin_time < notify.notify_time:
-            try:
-                await asynkio.sleep((notify.notify_time - begin_time).total_seconds())
-            except asynkio.CancelledError:
-                logger.debug(
-                    f"代办提醒被信号中止，任务退出 NOTIFY={notify.notify_msg} TIME={notify.notify_time}"
-                )
-                return
-        else:
-            logger.warning(
-                f"期望在 {notify.notify_time} 在平台 {notify.platform} {notify.target_env}"
-                f" {notify.target} 的代办通知 {notify.notify_msg} 已经超时，将会直接通知！"
-            )
-        res = await notify_now(notify)
-        if fail2remove or res:
-            async with DATA_FILE_LOCK:
-                cfg = load_notify_config()
-                cfg.notifies = [
-                    n for n in cfg.notifies if n.get_str() != notify.get_str()
-                ]
-                if not res:
-                    cfg.unsent.append(notify)
-                save_notify_config(cfg)
-        else:
-            pass
-
-    return asynkio.create_task(mission())
-
-
 @evt.handle()
-async def _(msg: UniMsg, mEvt: Event):
+async def _(msg: UniMsg, mEvt: Event, target: DepLongTaskTarget):
     if mEvt.get_user_id() in nonebot.get_bots():
         return
 
@@ -160,97 +83,170 @@ async def _(msg: UniMsg, mEvt: Event):
         return
 
     notify_time, notify_text = segments
-    # target_time = get_target_time(notify_time)
     try:
-        # target_time = ptimeparse.parse(notify_time)
         target_time = ptimeparse.Parser().parse(notify_time)
         logger.info(f"从 {notify_time} 解析出了时间：{target_time}")
     except Exception:
         logger.info(f"无法从 {notify_time} 中解析出时间")
         return
-    # if target_time is None:
-    #     logger.info(f"无法从 {notify_time} 中解析出时间")
-    #     return
     if not notify_text:
         return
 
-    await DATA_FILE_LOCK.acquire()
-    cfg = load_notify_config()
-
-    if isinstance(mEvt, ConsoleMessageEvent):
-        platform = "console"
-        target = mEvt.get_user_id()
-        target_env = None
-    elif isinstance(mEvt, OnebotV11MessageEvent):
-        platform = "qq"
-        target = mEvt.get_user_id()
-        if isinstance(mEvt, OnebotV11GroupMessageEvent):
-            target_env = str(mEvt.group_id)
-        else:
-            target_env = None
-    elif isinstance(mEvt, DiscordMessageEvent):
-        platform = "discord"
-        target = mEvt.get_user_id()
-        target_env = None
-    else:
-        logger.warning(f"Notify 遇到不支持的平台：{type(mEvt).__name__}")
-        return
-
-    notify = Notify(
-        platform=platform,
-        target=target,
-        target_env=target_env,
-        notify_time=target_time,
-        notify_msg=notify_text,
+    await create_longtask(
+        LONG_TASK_NAME,
+        { "message": notify_text },
+        target,
+        target_time,
     )
-    create_notify_task(notify)
 
-    cfg.notifies.append(notify)
-    save_notify_config(cfg)
-    DATA_FILE_LOCK.release()
-
-    await evt.send(
-        await UniMessage()
-        .at(mEvt.get_user_id())
-        .text(f" 了解啦！将会在 {notify.notify_time} 提醒你哦~")
-        .export()
+    await target.send_message(
+        UniMessage().text(f"了解啦！将会在 {target_time.strftime(FMT_STRING)} 提醒你哦~")
     )
-    logger.info(f"创建了一条于 {notify.notify_time} 的代办提醒")
+    logger.info(f"创建了一条于 {target_time} 的代办提醒")
 
 
 driver = nonebot.get_driver()
 
-NOTIFIED_FLAG = {
-    "task_added": False,
-}
+
+@handle_long_task("TASK_SIMPLE_NOTIFY")
+async def _(task: LongTask):
+    message = task.data["message"]
+    await task.target.send_message(
+        UniMessage().text(f"代办提醒：{message}")
+    )
+    async with DATA_FILE_LOCK:
+        data = load_notify_config()
+        if (chan := data.notify_channels.get(task.target.target_id)) is not None:
+            await send_notify_to_ntfy_instance(message, chan)
+        save_notify_config(data)
 
 
-@driver.on_bot_connect
-async def _():
-    if NOTIFIED_FLAG["task_added"]:
+USER_CHECKOUT_TASK_CACHE: dict[str, dict[str, str]] = {}
+
+
+cmd_check_notify_list = on_alconna(Alconna(
+    "re:(?:我有哪些|查询)(?:提醒|代办)",
+    Args["page", int, 1]
+))
+
+@cmd_check_notify_list.handle()
+async def _(page: int, target: DepLongTaskTarget):
+    if page <= 0:
+        await target.send_message(UniMessage().text("页数应该大于 0 吧"))
         return
+    async with longtask_data() as data:
+        tasks = data.to_handle.get(LONG_TASK_NAME, {}).values()
+        tasks = [t for t in tasks if t.target.target_id == target.target_id]
+        tasks = sorted(tasks, key=lambda t: t.deadline)
+        pages = ceil(len(tasks) / PAGE_SIZE)
+        if page > pages:
+            await target.send_message(UniMessage().text(f"最多也就 {pages} 页啦！"))
+        tasks = tasks[(page - 1) * PAGE_SIZE: page * PAGE_SIZE]
 
-    NOTIFIED_FLAG["task_added"] = True
+        message = "你可以输入「删除提醒 序号」来删除一个提醒\n====== 代办清单 ======\n\n"
 
-    DELTA = 2
-    logger.info(f"第一次探测到 Bot 连接，等待 {DELTA} 秒后开始通知")
-    await asynkio.sleep(DELTA)
+        to_cache = {}
+        if len(tasks) == 0:
+            message += "空空如也\n"
+        else:
+            for i, task in enumerate(tasks):
+                to_cache[str(i + 1)] = task.uuid
+                message += f"{i + 1}) {task.data['message']}（{task.deadline.strftime(FMT_STRING)}）\n"
 
-    await DATA_FILE_LOCK.acquire()
+        message += f"\n==== 第 {page} 页，共 {pages} 页 ===="
+        USER_CHECKOUT_TASK_CACHE[target.target_id] = to_cache
 
-    # tasks: set[asynkio.Task[Any]] = set()
-    cfg = load_notify_config()
-    if cfg.version == 1:
-        logger.info("将配置文件的版本升级为 2")
-        cfg.version = 2
+        await target.send_message(UniMessage().text(message))
+
+
+cmd_remove_task = on_alconna(Alconna(
+    "re:删除(?:提醒|代办)",
+    Args["checker", str],
+))
+
+@cmd_remove_task.handle()
+async def _(checker: str, target: DepLongTaskTarget):
+    if target.target_id not in USER_CHECKOUT_TASK_CACHE:
+        await target.send_message(UniMessage().text(
+            "先用「查询提醒」来查询你有哪些提醒吧"
+        ))
+        return
+    if checker not in USER_CHECKOUT_TASK_CACHE[target.target_id]:
+        await target.send_message(UniMessage().text(
+            "没有这个任务哦，请检查一下吧"
+        ))
+    uuid = USER_CHECKOUT_TASK_CACHE[target.target_id][checker]
+    async with longtask_data() as data:
+        if uuid not in data.to_handle[LONG_TASK_NAME]:
+            await target.send_message(UniMessage().text(
+                "似乎这个提醒已经发出去了，或者已经被删除"
+            ))
+            return
+        _msg = data.to_handle[LONG_TASK_NAME][uuid].data["message"]
+        del data.to_handle[LONG_TASK_NAME][uuid]
+        await target.send_message(UniMessage().text(
+            f"成功取消了提醒：{_msg}"
+        ))
+
+
+cmd_notify_channel = on_alconna(Alconna(
+    "ntfy",
+    Subcommand("删除", dest="delete"),
+    Subcommand("创建", Args["notify_id?", str], dest="create"),
+), rule=lambda: config.plugin_notify_enable_ntfy)
+
+@cmd_notify_channel.assign("$main")
+async def _(target: DepLongTaskTarget):
+    async with DATA_FILE_LOCK:
+        data = load_notify_config()
+        target_channel = data.notify_channels.get(target.target_id)
+
+    if target_channel is None:
+        channel_msg = "目前还没有配置 ntfy 地址"
     else:
-        counter = 0
-        for notify in [*cfg.notifies]:
-            task = create_notify_task(notify, fail2remove=False)
-            ASYNK_TASKS.add(task)
-            task.add_done_callback(lambda self: ASYNK_TASKS.remove(self))
-            counter += 1
-        logger.info(f"成功创建了 {counter} 条代办事项")
-    save_notify_config(cfg)
-    DATA_FILE_LOCK.release()
+        channel_msg = f"配置的 ntfy Channel 为：{target_channel}\n\n服务器地址：{config.plugin_notify_base_url}"
+
+    await target.send_message(UniMessage.text(
+        f"{channel_msg}\n\n"
+        "配置 ntfy 通知：\n\n"
+        "- ntfy 创建: 启用 ntfy 通知，并为你随机生成一个通知渠道\n"
+        "- ntfy 删除：禁用 ntfy 通知\n"
+    ))
+
+@cmd_notify_channel.assign("create")
+async def _(target: DepLongTaskTarget, notify_id: str = ""):
+    if notify_id == "":
+        notify_id = nanoid.generate(
+            alphabet="0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz-",
+            size=16,
+        )
+
+    channel_name = f"{config.plugin_notify_prefix}{notify_id}"
+
+    async with DATA_FILE_LOCK:
+        data = load_notify_config()
+        data.notify_channels[target.target_id] = channel_name
+        save_notify_config(data)
+
+    await target.send_message(UniMessage.text(
+        f"了解！将会在 {channel_name} 为你提醒！\n"
+        "\n"
+        "食用教程：在你的手机端 / 网页端 ntfy 点击「订阅主题」，选择「使用其他服务器」，"
+        f"服务器填写 {config.plugin_notify_base_url} ，主题名填写 {channel_name}\n"
+        f"最后点击订阅，就能看到我给你发的消息啦！"
+    ))
+
+    await send_notify_to_ntfy_instance(
+        "如果你看到这条消息，说明你已经成功订阅主题！此方 BOT 将会在这里提醒你你的代办！",
+        channel_name,
+    )
+
+
+@cmd_notify_channel.assign("delete")
+async def _(target: DepLongTaskTarget):
+    async with DATA_FILE_LOCK:
+        data = load_notify_config()
+        del data.notify_channels[target.target_id]
+        save_notify_config(data)
+    await target.send_message(UniMessage.text("ok."))
 

konabot/plugins/xibao_generate/__init__.py

@@ -0,0 +1,118 @@
+from typing import Optional
+from nonebot_plugin_alconna import Alconna, Args, UniMessage, UniMsg, on_alconna
+from konabot.common.web_render import WebRenderer
+from nonebot.adapters import Event as BaseEvent
+from playwright.async_api import Page
+
+async def continue_handle(page: Page, content: str) -> None:
+    # 这里可以添加一些预处理逻辑
+    # 找到 id 为 input 的 textarea 元素
+    textarea = await page.query_selector("#input")
+    if textarea:
+        # 在 textarea 中输入内容
+        await textarea.fill(content)
+    # 找到 id 为 submit-btn 的按钮元素
+    submit_button = await page.query_selector("#submit-btn")
+    if submit_button:
+        # 点击按钮提交
+        await submit_button.click()
+
+evt = on_alconna(
+    Alconna(
+        f"生成喜报",
+        Args["content?", str]
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, content: Optional[str] = ""):
+
+    screenshot = await WebRenderer.render(
+        url="https://witnessbot.mxowl.com/services/congratulations/",
+        target="#main-canvas",
+        other_function=lambda page: continue_handle(page, content),
+        timeout=30
+    )
+    await evt.send(
+        await UniMessage().image(raw=screenshot).export()
+    )
+
+async def beibao_continue_handle(page: Page, content: str) -> None:
+    # 这里可以添加一些预处理逻辑
+    # 找到 id 为 input 的 textarea 元素
+    textarea = await page.query_selector("#input")
+    if textarea:
+        # 在 textarea 中输入内容
+        await textarea.fill(content)
+    # 找到 class 为 btn btn-outline-primary，for属性为 mode-2 的标签元素
+    mode_radio = await page.query_selector("label.btn.btn-outline-primary[for='mode-2']")
+    if mode_radio:
+        # 点击选择悲报模式
+        await mode_radio.click()
+    # 找到 id 为 submit-btn 的按钮元素
+    submit_button = await page.query_selector("#submit-btn")
+    if submit_button:
+        # 点击按钮提交
+        await submit_button.click()
+
+evt = on_alconna(
+    Alconna(
+        f"生成悲报",
+        Args["content?", str]
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, content: Optional[str] = ""):
+
+    screenshot = await WebRenderer.render(
+        url="https://witnessbot.mxowl.com/services/congratulations/",
+        target="#main-canvas",
+        other_function=lambda page: beibao_continue_handle(page, content),
+        timeout=30
+    )
+    await evt.send(
+        await UniMessage().image(raw=screenshot).export()
+    )
+
+async def continue_handle_3(page: Page, arg1: str, arg2: str) -> None:
+    # 这里可以添加一些预处理逻辑
+    # 找到 id 为 textL 的 input，id 为 textR 的 input
+    input1 = await page.query_selector("#textL")
+    input2 = await page.query_selector("#textR")
+    if input1:
+        await input1.fill(arg1)
+    if input2:
+        await input2.fill(arg2)
+    # 等待 0.3 秒钟
+    await page.wait_for_timeout(300)
+    # 等待 id 为 loading 的元素不可见
+    loading = await page.query_selector("#loading")
+    if loading:
+        await loading.wait_for_element_state("hidden")
+
+evt = on_alconna(
+    Alconna(
+        f"BA生成",
+        Args["arg1", str],
+        Args["arg2", str]
+    ),
+    use_cmd_start=True,
+    use_cmd_sep=False,
+    skip_for_unmatch=True,
+)
+@evt.handle()
+async def _(msg: UniMsg, event: BaseEvent, arg1: str, arg2: str):
+    screenshot = await WebRenderer.render(
+        url="https://tmp.nulla.top/ba-logo/",
+        target="#canvas",
+        other_function=lambda page: continue_handle_3(page, arg1, arg2),
+        timeout=30
+    )
+    await evt.send(
+        await UniMessage().image(raw=screenshot).export()
+    )

poetry.lock

@@ -989,6 +989,79 @@ type = "legacy"
 url = "https://pypi.tuna.tsinghua.edu.cn/simple"
 reference = "mirrors"
 
+[[package]]
+name = "greenlet"
+version = "3.2.4"
+description = "Lightweight in-process concurrent programming"
+optional = false
+python-versions = ">=3.9"
+groups = ["main"]
+files = [
+    {file = "greenlet-3.2.4-cp310-cp310-macosx_11_0_universal2.whl", hash = "sha256:8c68325b0d0acf8d91dde4e6f930967dd52a5302cd4062932a6b2e7c2969f47c"},
+    {file = "greenlet-3.2.4-cp310-cp310-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:94385f101946790ae13da500603491f04a76b6e4c059dab271b3ce2e283b2590"},
+    {file = "greenlet-3.2.4-cp310-cp310-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:f10fd42b5ee276335863712fa3da6608e93f70629c631bf77145021600abc23c"},
+    {file = "greenlet-3.2.4-cp310-cp310-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:c8c9e331e58180d0d83c5b7999255721b725913ff6bc6cf39fa2a45841a4fd4b"},
+    {file = "greenlet-3.2.4-cp310-cp310-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:58b97143c9cc7b86fc458f215bd0932f1757ce649e05b640fea2e79b54cedb31"},
+    {file = "greenlet-3.2.4-cp310-cp310-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:c2ca18a03a8cfb5b25bc1cbe20f3d9a4c80d8c3b13ba3df49ac3961af0b1018d"},
+    {file = "greenlet-3.2.4-cp310-cp310-musllinux_1_1_aarch64.whl", hash = "sha256:9fe0a28a7b952a21e2c062cd5756d34354117796c6d9215a87f55e38d15402c5"},
+    {file = "greenlet-3.2.4-cp310-cp310-musllinux_1_1_x86_64.whl", hash = "sha256:8854167e06950ca75b898b104b63cc646573aa5fef1353d4508ecdd1ee76254f"},
+    {file = "greenlet-3.2.4-cp310-cp310-win_amd64.whl", hash = "sha256:73f49b5368b5359d04e18d15828eecc1806033db5233397748f4ca813ff1056c"},
+    {file = "greenlet-3.2.4-cp311-cp311-macosx_11_0_universal2.whl", hash = "sha256:96378df1de302bc38e99c3a9aa311967b7dc80ced1dcc6f171e99842987882a2"},
+    {file = "greenlet-3.2.4-cp311-cp311-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:1ee8fae0519a337f2329cb78bd7a8e128ec0f881073d43f023c7b8d4831d5246"},
+    {file = "greenlet-3.2.4-cp311-cp311-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:94abf90142c2a18151632371140b3dba4dee031633fe614cb592dbb6c9e17bc3"},
+    {file = "greenlet-3.2.4-cp311-cp311-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:4d1378601b85e2e5171b99be8d2dc85f594c79967599328f95c1dc1a40f1c633"},
+    {file = "greenlet-3.2.4-cp311-cp311-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:0db5594dce18db94f7d1650d7489909b57afde4c580806b8d9203b6e79cdc079"},
+    {file = "greenlet-3.2.4-cp311-cp311-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:2523e5246274f54fdadbce8494458a2ebdcdbc7b802318466ac5606d3cded1f8"},
+    {file = "greenlet-3.2.4-cp311-cp311-musllinux_1_1_aarch64.whl", hash = "sha256:1987de92fec508535687fb807a5cea1560f6196285a4cde35c100b8cd632cc52"},
+    {file = "greenlet-3.2.4-cp311-cp311-musllinux_1_1_x86_64.whl", hash = "sha256:55e9c5affaa6775e2c6b67659f3a71684de4c549b3dd9afca3bc773533d284fa"},
+    {file = "greenlet-3.2.4-cp311-cp311-win_amd64.whl", hash = "sha256:9c40adce87eaa9ddb593ccb0fa6a07caf34015a29bf8d344811665b573138db9"},
+    {file = "greenlet-3.2.4-cp312-cp312-macosx_11_0_universal2.whl", hash = "sha256:3b67ca49f54cede0186854a008109d6ee71f66bd57bb36abd6d0a0267b540cdd"},
+    {file = "greenlet-3.2.4-cp312-cp312-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:ddf9164e7a5b08e9d22511526865780a576f19ddd00d62f8a665949327fde8bb"},
+    {file = "greenlet-3.2.4-cp312-cp312-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:f28588772bb5fb869a8eb331374ec06f24a83a9c25bfa1f38b6993afe9c1e968"},
+    {file = "greenlet-3.2.4-cp312-cp312-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:5c9320971821a7cb77cfab8d956fa8e39cd07ca44b6070db358ceb7f8797c8c9"},
+    {file = "greenlet-3.2.4-cp312-cp312-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:c60a6d84229b271d44b70fb6e5fa23781abb5d742af7b808ae3f6efd7c9c60f6"},
+    {file = "greenlet-3.2.4-cp312-cp312-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:3b3812d8d0c9579967815af437d96623f45c0f2ae5f04e366de62a12d83a8fb0"},
+    {file = "greenlet-3.2.4-cp312-cp312-musllinux_1_1_aarch64.whl", hash = "sha256:abbf57b5a870d30c4675928c37278493044d7c14378350b3aa5d484fa65575f0"},
+    {file = "greenlet-3.2.4-cp312-cp312-musllinux_1_1_x86_64.whl", hash = "sha256:20fb936b4652b6e307b8f347665e2c615540d4b42b3b4c8a321d8286da7e520f"},
+    {file = "greenlet-3.2.4-cp312-cp312-win_amd64.whl", hash = "sha256:a7d4e128405eea3814a12cc2605e0e6aedb4035bf32697f72deca74de4105e02"},
+    {file = "greenlet-3.2.4-cp313-cp313-macosx_11_0_universal2.whl", hash = "sha256:1a921e542453fe531144e91e1feedf12e07351b1cf6c9e8a3325ea600a715a31"},
+    {file = "greenlet-3.2.4-cp313-cp313-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:cd3c8e693bff0fff6ba55f140bf390fa92c994083f838fece0f63be121334945"},
+    {file = "greenlet-3.2.4-cp313-cp313-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:710638eb93b1fa52823aa91bf75326f9ecdfd5e0466f00789246a5280f4ba0fc"},
+    {file = "greenlet-3.2.4-cp313-cp313-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:c5111ccdc9c88f423426df3fd1811bfc40ed66264d35aa373420a34377efc98a"},
+    {file = "greenlet-3.2.4-cp313-cp313-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:d76383238584e9711e20ebe14db6c88ddcedc1829a9ad31a584389463b5aa504"},
+    {file = "greenlet-3.2.4-cp313-cp313-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:23768528f2911bcd7e475210822ffb5254ed10d71f4028387e5a99b4c6699671"},
+    {file = "greenlet-3.2.4-cp313-cp313-musllinux_1_1_aarch64.whl", hash = "sha256:00fadb3fedccc447f517ee0d3fd8fe49eae949e1cd0f6a611818f4f6fb7dc83b"},
+    {file = "greenlet-3.2.4-cp313-cp313-musllinux_1_1_x86_64.whl", hash = "sha256:d25c5091190f2dc0eaa3f950252122edbbadbb682aa7b1ef2f8af0f8c0afefae"},
+    {file = "greenlet-3.2.4-cp313-cp313-win_amd64.whl", hash = "sha256:554b03b6e73aaabec3745364d6239e9e012d64c68ccd0b8430c64ccc14939a8b"},
+    {file = "greenlet-3.2.4-cp314-cp314-macosx_11_0_universal2.whl", hash = "sha256:49a30d5fda2507ae77be16479bdb62a660fa51b1eb4928b524975b3bde77b3c0"},
+    {file = "greenlet-3.2.4-cp314-cp314-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:299fd615cd8fc86267b47597123e3f43ad79c9d8a22bebdce535e53550763e2f"},
+    {file = "greenlet-3.2.4-cp314-cp314-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:c17b6b34111ea72fc5a4e4beec9711d2226285f0386ea83477cbb97c30a3f3a5"},
+    {file = "greenlet-3.2.4-cp314-cp314-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:b4a1870c51720687af7fa3e7cda6d08d801dae660f75a76f3845b642b4da6ee1"},
+    {file = "greenlet-3.2.4-cp314-cp314-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:061dc4cf2c34852b052a8620d40f36324554bc192be474b9e9770e8c042fd735"},
+    {file = "greenlet-3.2.4-cp314-cp314-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:44358b9bf66c8576a9f57a590d5f5d6e72fa4228b763d0e43fee6d3b06d3a337"},
+    {file = "greenlet-3.2.4-cp314-cp314-win_amd64.whl", hash = "sha256:e37ab26028f12dbb0ff65f29a8d3d44a765c61e729647bf2ddfbbed621726f01"},
+    {file = "greenlet-3.2.4-cp39-cp39-macosx_11_0_universal2.whl", hash = "sha256:b6a7c19cf0d2742d0809a4c05975db036fdff50cd294a93632d6a310bf9ac02c"},
+    {file = "greenlet-3.2.4-cp39-cp39-manylinux2014_aarch64.manylinux_2_17_aarch64.whl", hash = "sha256:27890167f55d2387576d1f41d9487ef171849ea0359ce1510ca6e06c8bece11d"},
+    {file = "greenlet-3.2.4-cp39-cp39-manylinux2014_ppc64le.manylinux_2_17_ppc64le.whl", hash = "sha256:18d9260df2b5fbf41ae5139e1be4e796d99655f023a636cd0e11e6406cca7d58"},
+    {file = "greenlet-3.2.4-cp39-cp39-manylinux2014_s390x.manylinux_2_17_s390x.whl", hash = "sha256:671df96c1f23c4a0d4077a325483c1503c96a1b7d9db26592ae770daa41233d4"},
+    {file = "greenlet-3.2.4-cp39-cp39-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:16458c245a38991aa19676900d48bd1a6f2ce3e16595051a4db9d012154e8433"},
+    {file = "greenlet-3.2.4-cp39-cp39-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:c9913f1a30e4526f432991f89ae263459b1c64d1608c0d22a5c79c287b3c70df"},
+    {file = "greenlet-3.2.4-cp39-cp39-musllinux_1_1_aarch64.whl", hash = "sha256:b90654e092f928f110e0007f572007c9727b5265f7632c2fa7415b4689351594"},
+    {file = "greenlet-3.2.4-cp39-cp39-musllinux_1_1_x86_64.whl", hash = "sha256:81701fd84f26330f0d5f4944d4e92e61afe6319dcd9775e39396e39d7c3e5f98"},
+    {file = "greenlet-3.2.4-cp39-cp39-win32.whl", hash = "sha256:65458b409c1ed459ea899e939f0e1cdb14f58dbc803f2f93c5eab5694d32671b"},
+    {file = "greenlet-3.2.4-cp39-cp39-win_amd64.whl", hash = "sha256:d2e685ade4dafd447ede19c31277a224a239a0a1a4eca4e6390efedf20260cfb"},
+    {file = "greenlet-3.2.4.tar.gz", hash = "sha256:0dca0d95ff849f9a364385f36ab49f50065d76964944638be9691e1832e9f86d"},
+]
+
+[package.extras]
+docs = ["Sphinx", "furo"]
+test = ["objgraph", "psutil", "setuptools"]
+
+[package.source]
+type = "legacy"
+url = "https://pypi.tuna.tsinghua.edu.cn/simple"
+reference = "mirrors"
+
 [[package]]
 name = "h11"
 version = "0.16.0"
@@ -1743,6 +1816,23 @@ type = "legacy"
 url = "https://pypi.tuna.tsinghua.edu.cn/simple"
 reference = "mirrors"
 
+[[package]]
+name = "nanoid"
+version = "2.0.0"
+description = "A tiny, secure, URL-friendly, unique string ID generator for Python"
+optional = false
+python-versions = "*"
+groups = ["main"]
+files = [
+    {file = "nanoid-2.0.0-py3-none-any.whl", hash = "sha256:90aefa650e328cffb0893bbd4c236cfd44c48bc1f2d0b525ecc53c3187b653bb"},
+    {file = "nanoid-2.0.0.tar.gz", hash = "sha256:5a80cad5e9c6e9ae3a41fa2fb34ae189f7cb420b2a5d8f82bd9d23466e4efa68"},
+]
+
+[package.source]
+type = "legacy"
+url = "https://pypi.tuna.tsinghua.edu.cn/simple"
+reference = "mirrors"
+
 [[package]]
 name = "nepattern"
 version = "0.7.7"
@@ -2110,6 +2200,37 @@ type = "legacy"
 url = "https://pypi.tuna.tsinghua.edu.cn/simple"
 reference = "mirrors"
 
+[[package]]
+name = "opencc"
+version = "1.1.9"
+description = "Conversion between Traditional and Simplified Chinese"
+optional = false
+python-versions = "*"
+groups = ["main"]
+files = [
+    {file = "OpenCC-1.1.9-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:a33941dd4cb67457e6f44dfe36dddc30a602363a4f6a29b41d79b062b332c094"},
+    {file = "OpenCC-1.1.9-cp310-cp310-manylinux2014_x86_64.whl", hash = "sha256:92769f9a60301574c73096f9ab8a9060fe0d13a9f8266735d82a2a3a92adbd26"},
+    {file = "OpenCC-1.1.9-cp310-cp310-win_amd64.whl", hash = "sha256:84e35e5ecfad445a64c0dcd6567d9e9f3a6aed9a6ffd89cdbc071f36cb9e089e"},
+    {file = "OpenCC-1.1.9-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:3fb7c84f7c182cb5208e7bc1c104b817a3ca1a8fe111d4d19816be0d6e1ab396"},
+    {file = "OpenCC-1.1.9-cp311-cp311-manylinux2014_x86_64.whl", hash = "sha256:64994c68796d93cdba42f37e0c073fb8ed6f9d6707232be0ba84f24dc5a36bbb"},
+    {file = "OpenCC-1.1.9-cp311-cp311-win_amd64.whl", hash = "sha256:9f6a1413ca2ff490e65a55822e4cae8c3f104bfab46355288de4893a14470fbb"},
+    {file = "OpenCC-1.1.9-cp312-cp312-macosx_10_9_x86_64.whl", hash = "sha256:48bc3e37942b91a9cf51f525631792f79378e5332bdba9e10c05f6e7fe9036ca"},
+    {file = "OpenCC-1.1.9-cp312-cp312-manylinux2014_x86_64.whl", hash = "sha256:1c5d1489bdaf9dc2865f0ea30eb565093253e73c1868d9c19554c8a044b545d4"},
+    {file = "OpenCC-1.1.9-cp312-cp312-win_amd64.whl", hash = "sha256:64f8d22c8505b65e8ee2d6e73241cbc92785d38b3c93885b423d7c4fcd31c679"},
+    {file = "OpenCC-1.1.9-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:f4267b66ed6e656b5d8199f94e9673950ac39d49ebaf0e7927330801f06f038f"},
+    {file = "OpenCC-1.1.9-cp38-cp38-manylinux2014_x86_64.whl", hash = "sha256:c6d5f9756ed08e67de36c53dc4d8f0bdc72889d6f57a8fc4d8b073d99c58d4dc"},
+    {file = "OpenCC-1.1.9-cp38-cp38-win_amd64.whl", hash = "sha256:a6c2650bd3d6a9e3c31fc2057e0f36122c9507af1661627542f618c97d420293"},
+    {file = "OpenCC-1.1.9-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:4d66473405c2e360ef346fe1625f201f3f3c4adbb16d5c1c7749a150ae42d875"},
+    {file = "OpenCC-1.1.9-cp39-cp39-manylinux2014_x86_64.whl", hash = "sha256:436c43e0855b4f9c9e4fd1191e8ac638e9d9f2c7e2d5753952e6e31aa231d36c"},
+    {file = "OpenCC-1.1.9-cp39-cp39-win_amd64.whl", hash = "sha256:b4c36d6974afd94b444ad5ad17364f40d228092ce89b86e46653f7ff38075201"},
+    {file = "opencc-1.1.9.tar.gz", hash = "sha256:8ad72283732951303390fae33a1ceda98ac9b03368a8f2912edc934d74077e4a"},
+]
+
+[package.source]
+type = "legacy"
+url = "https://pypi.tuna.tsinghua.edu.cn/simple"
+reference = "mirrors"
+
 [[package]]
 name = "opencv-python-headless"
 version = "4.12.0.88"
@@ -2287,6 +2408,33 @@ type = "legacy"
 url = "https://pypi.tuna.tsinghua.edu.cn/simple"
 reference = "mirrors"
 
+[[package]]
+name = "playwright"
+version = "1.55.0"
+description = "A high-level API to automate web browsers"
+optional = false
+python-versions = ">=3.9"
+groups = ["main"]
+files = [
+    {file = "playwright-1.55.0-py3-none-macosx_10_13_x86_64.whl", hash = "sha256:d7da108a95001e412effca4f7610de79da1637ccdf670b1ae3fdc08b9694c034"},
+    {file = "playwright-1.55.0-py3-none-macosx_11_0_arm64.whl", hash = "sha256:8290cf27a5d542e2682ac274da423941f879d07b001f6575a5a3a257b1d4ba1c"},
+    {file = "playwright-1.55.0-py3-none-macosx_11_0_universal2.whl", hash = "sha256:25b0d6b3fd991c315cca33c802cf617d52980108ab8431e3e1d37b5de755c10e"},
+    {file = "playwright-1.55.0-py3-none-manylinux1_x86_64.whl", hash = "sha256:c6d4d8f6f8c66c483b0835569c7f0caa03230820af8e500c181c93509c92d831"},
+    {file = "playwright-1.55.0-py3-none-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:29a0777c4ce1273acf90c87e4ae2fe0130182100d99bcd2ae5bf486093044838"},
+    {file = "playwright-1.55.0-py3-none-win32.whl", hash = "sha256:29e6d1558ad9d5b5c19cbec0a72f6a2e35e6353cd9f262e22148685b86759f90"},
+    {file = "playwright-1.55.0-py3-none-win_amd64.whl", hash = "sha256:7eb5956473ca1951abb51537e6a0da55257bb2e25fc37c2b75af094a5c93736c"},
+    {file = "playwright-1.55.0-py3-none-win_arm64.whl", hash = "sha256:012dc89ccdcbd774cdde8aeee14c08e0dd52ddb9135bf10e9db040527386bd76"},
+]
+
+[package.dependencies]
+greenlet = ">=3.1.1,<4.0.0"
+pyee = ">=13,<14"
+
+[package.source]
+type = "legacy"
+url = "https://pypi.tuna.tsinghua.edu.cn/simple"
+reference = "mirrors"
+
 [[package]]
 name = "propcache"
 version = "0.3.2"
@@ -2715,6 +2863,29 @@ type = "legacy"
 url = "https://pypi.tuna.tsinghua.edu.cn/simple"
 reference = "mirrors"
 
+[[package]]
+name = "pyee"
+version = "13.0.0"
+description = "A rough port of Node.js's EventEmitter to Python with a few tricks of its own"
+optional = false
+python-versions = ">=3.8"
+groups = ["main"]
+files = [
+    {file = "pyee-13.0.0-py3-none-any.whl", hash = "sha256:48195a3cddb3b1515ce0695ed76036b5ccc2ef3a9f963ff9f77aec0139845498"},
+    {file = "pyee-13.0.0.tar.gz", hash = "sha256:b391e3c5a434d1f5118a25615001dbc8f669cf410ab67d04c4d4e07c55481c37"},
+]
+
+[package.dependencies]
+typing-extensions = "*"
+
+[package.extras]
+dev = ["black", "build", "flake8", "flake8-black", "isort", "jupyter-console", "mkdocs", "mkdocs-include-markdown-plugin", "mkdocstrings[python]", "mypy", "pytest", "pytest-asyncio ; python_version >= \"3.4\"", "pytest-trio ; python_version >= \"3.7\"", "sphinx", "toml", "tox", "trio", "trio ; python_version > \"3.6\"", "trio-typing ; python_version > \"3.6\"", "twine", "twisted", "validate-pyproject[all]"]
+
+[package.source]
+type = "legacy"
+url = "https://pypi.tuna.tsinghua.edu.cn/simple"
+reference = "mirrors"
+
 [[package]]
 name = "pygments"
 version = "2.19.2"
@@ -3807,4 +3978,4 @@ reference = "mirrors"
 [metadata]
 lock-version = "2.1"
 python-versions = ">=3.12,<4.0"
-content-hash = "78a299c64ba07999fae807300b10a1c622d45b8b387aded5a34d17cf5550e777"
+content-hash = "ec73430f70658a303c47e6f536ccb0863a475f7f25d5334c8766e6149075648c"

pyproject.toml

@@ -24,6 +24,9 @@ dependencies = [
   "nonebot-plugin-analysis-bilibili (>=2.8.1,<3.0.0)",
   "qrcode (>=8.2,<9.0)",
   "ptimeparse (>=0.2.1,<0.3.0)",
+  "nanoid (>=2.0.0,<3.0.0)",
+  "opencc (>=1.1.9,<2.0.0)",
+  "playwright (>=1.55.0,<2.0.0)",
 ]
 
 [build-system]