v3.4.30

fix: 修复 dify 无法使用事件钩子的问题以及出现 GeneratorExit 的问题 #533 #264
🐛 fix: 修复某些情况下导致插件报错 AttributeError 的问题 #549
2025-02-21 01:31:36 +08:00 · 2025-02-21 01:14:13 +08:00 · 2025-02-21 00:38:08 +08:00 · 2025-02-20 16:34:32 +08:00 · 2025-02-19 20:05:33 +08:00 · 2025-02-19 19:56:31 +08:00
48 changed files with 1154 additions and 428 deletions
--- a/README.md
+++ b/README.md
@@ -18,6 +18,7 @@ _✨ 易上手的多平台 LLM 聊天机器人及开发框架 ✨_
 ![Dynamic JSON Badge](https://img.shields.io/badge/dynamic/json?url=https%3A%2F%2Fapi.soulter.top%2Fastrbot%2Fstats&query=v&label=7%E6%97%A5%E6%B6%88%E6%81%AF%E4%B8%8A%E8%A1%8C%E9%87%8F&cacheSeconds=3600)
 [![codecov](https://codecov.io/gh/Soulter/AstrBot/graph/badge.svg?token=FF3P5967B8)](https://codecov.io/gh/Soulter/AstrBot)

+<a href="https://github.com/Soulter/AstrBot/blob/master/README_ja.md">日本語</a> ｜
 <a href="https://astrbot.app/">查看文档</a> ｜
 <a href="https://github.com/Soulter/AstrBot/issues">问题提交</a>
 </div>
--- a/README_ja.md
+++ b/README_ja.md
@@ -0,0 +1,170 @@
+<p align="center">
+    
+![6e1279651f16d7fdf4727558b72bbaf1](https://github.com/user-attachments/assets/ead4c551-fc3c-48f7-a6f7-afbfdb820512)
+
+</p>
+
+<div align="center">
+
+_✨ 簡単に使えるマルチプラットフォーム LLM チャットボットおよび開発フレームワーク ✨_
+
+<a href="https://trendshift.io/repositories/12875" target="_blank"><img src="https://trendshift.io/api/badge/repositories/12875" alt="Soulter%2FAstrBot | Trendshift" style="width: 250px; height: 55px;" width="250" height="55"/></a>
+
+[![GitHub release (latest by date)](https://img.shields.io/github/v/release/Soulter/AstrBot)](https://github.com/Soulter/AstrBot/releases/latest)
+<img src="https://img.shields.io/badge/python-3.10+-blue.svg" alt="python">
+<a href="https://hub.docker.com/r/soulter/astrbot"><img alt="Docker pull" src="https://img.shields.io/docker/pulls/soulter/astrbot.svg"/></a>
+<img alt="Static Badge" src="https://img.shields.io/badge/QQ群-630166526-purple">
+[![wakatime](https://wakatime.com/badge/user/915e5316-99c6-4563-a483-ef186cf000c9/project/018e705a-a1a7-409a-a849-3013485e6c8e.svg)](https://wakatime.com/badge/user/915e5316-99c6-4563-a483-ef186cf000c9/project/018e705a-a1a7-409a-a849-3013485e6c8e)
+![Dynamic JSON Badge](https://img.shields.io/badge/dynamic/json?url=https%3A%2F%2Fapi.soulter.top%2Fastrbot%2Fstats&query=v&label=7%E6%97%A5%E6%B6%88%E6%81%AF%E4%B8%8A%E8%A1%8C%E9%87%8F&cacheSeconds=3600)
+[![codecov](https://codecov.io/gh/Soulter/AstrBot/graph/badge.svg?token=FF3P5967B8)](https://codecov.io/gh/Soulter/AstrBot)
+
+<a href="https://astrbot.app/">ドキュメントを見る</a> ｜
+<a href="https://github.com/Soulter/AstrBot/issues">問題を報告する</a>
+</div>
+
+AstrBot は、疎結合、非同期、複数のメッセージプラットフォームに対応したデプロイ、使いやすいプラグインシステム、および包括的な大規模言語モデル（LLM）接続機能を備えたチャットボットおよび開発フレームワークです。
+
+## ✨ 主な機能
+
+1. **大規模言語モデルの対話**。OpenAI API、Google Gemini、Llama、Deepseek、ChatGLM など、さまざまな大規模言語モデルをサポートし、Ollama、LLMTuner を介してローカルにデプロイされた大規模モデルをサポートします。多輪対話、人格シナリオ、多モーダル機能を備え、画像理解、音声からテキストへの変換（Whisper）をサポートします。
+2. **複数のメッセージプラットフォームの接続**。QQ（OneBot）、QQ チャンネル、WeChat（Gewechat）、Feishu、Telegram への接続をサポートします。今後、DingTalk、Discord、WhatsApp、Xiaoai 音響をサポートする予定です。レート制限、ホワイトリスト、キーワードフィルタリング、Baidu コンテンツ監査をサポートします。
+3. **エージェント**。一部のエージェント機能をネイティブにサポートし、コードエグゼキューター、自然言語タスク、ウェブ検索などを提供します。[Dify プラットフォーム](https://astrbot.app/others/dify.html)と連携し、Dify スマートアシスタント、ナレッジベース、Dify ワークフローを簡単に接続できます。
+4. **プラグインの拡張**。深く最適化されたプラグインメカニズムを備え、[プラグインの開発](https://astrbot.app/dev/plugin.html)をサポートし、機能を拡張できます。複数のプラグインのインストールをサポートします。
+5. **ビジュアル管理パネル**。設定の視覚的な変更、プラグイン管理、ログの表示などをサポートし、設定の難易度を低減します。WebChat を統合し、パネル上で大規模モデルと対話できます。
+6. **高い安定性と高いモジュール性**。イベントバスとパイプラインに基づくアーキテクチャ設計により、高度にモジュール化され、低結合です。
+
+> [!TIP]
+> 管理パネルのオンラインデモを体験する: [https://demo.astrbot.app/](https://demo.astrbot.app/)
+> 
+> ユーザー名: `astrbot`, パスワード: `astrbot`。LLM が設定されていないため、チャットページで大規模モデルを使用することはできません。（デモのログインパスワードを変更しないでください 😭）
+
+## ✨ 使用方法
+
+#### Docker デプロイ
+
+公式ドキュメント [Docker を使用して AstrBot をデプロイする](https://astrbot.app/deploy/astrbot/docker.html#%E4%BD%BF%E7%94%A8-docker-%E9%83%A8%E7%BD%B2-astrbot) を参照してください。
+
+#### Windows ワンクリックインストーラーのデプロイ
+
+コンピュータに Python（>3.10）がインストールされている必要があります。公式ドキュメント [Windows ワンクリックインストーラーを使用して AstrBot をデプロイする](https://astrbot.app/deploy/astrbot/windows.html) を参照してください。
+
+#### Replit デプロイ
+
+[![Run on Repl.it](https://repl.it/badge/github/Soulter/AstrBot)](https://repl.it/github/Soulter/AstrBot)
+
+#### CasaOS デプロイ
+
+コミュニティが提供するデプロイ方法です。
+
+公式ドキュメント [ソースコードを使用して AstrBot をデプロイする](https://astrbot.app/deploy/astrbot/casaos.html) を参照してください。
+
+#### 手動デプロイ
+
+公式ドキュメント [ソースコードを使用して AstrBot をデプロイする](https://astrbot.app/deploy/astrbot/cli.html) を参照してください。
+
+## ⚡ メッセージプラットフォームのサポート状況
+
+| プラットフォーム    | サポート状況 | 詳細 | メッセージタイプ |
+| -------- | ------- | ------- | ------ |
+| QQ(公式ロボットインターフェース) | ✔    | プライベートチャット、グループチャット、QQ チャンネルプライベートチャット、グループチャット | テキスト、画像 |
+| QQ(OneBot)      | ✔    | プライベートチャット、グループチャット | テキスト、画像、音声 |
+| WeChat(個人アカウント)    | ✔    | WeChat 個人アカウントのプライベートチャット、グループチャット | テキスト、画像、音声 |
+| [Telegram](https://github.com/Soulter/astrbot_plugin_telegram)   | ✔    | プライベートチャット、グループチャット | テキスト、画像 |
+| [WeChat(企業 WeChat)](https://github.com/Soulter/astrbot_plugin_wecom)    | ✔    | プライベートチャット | テキスト、画像、音声 |
+| Feishu   | ✔    | グループチャット | テキスト、画像 |
+| WeChat 対話オープンプラットフォーム | 🚧    | 計画中 | - |
+| Discord   | 🚧    | 計画中 | - |
+| WhatsApp   | 🚧    | 計画中 | - |
+| Xiaoai 音響   | 🚧    | 計画中 | - |
+
+# 🦌 今後のロードマップ
+
+> [!TIP]
+> Issue でさらに多くの提案を歓迎します <3
+
+- [ ] 現在のすべてのプラットフォームアダプターの機能の一貫性を確保し、改善する
+- [ ] プラグインインターフェースの最適化
+- [ ] GPT-Sovits などの TTS サービスをデフォルトでサポート
+- [ ] "チャット強化" 部分を完成させ、永続的な記憶をサポート
+- [ ] i18n の計画
+
+## ❤️ 貢献
+
+Issue や Pull Request を歓迎します！このプロジェクトに変更を加えるだけです :)
+
+新機能の追加については、まず Issue で議論してください。
+
+## 🌟 サポート
+
+- このプロジェクトに Star を付けてください！
+- [愛発電](https://afdian.com/a/soulter)で私をサポートしてください！
+- [WeChat](https://drive.soulter.top/f/pYfA/d903f4fa49a496fda3f16d2be9e023b5.png)で私をサポートしてください~
+
+## ✨ デモ
+
+> [!NOTE]
+> コードエグゼキューターのファイル入力/出力は現在 Napcat(QQ)、Lagrange(QQ) でのみテストされています
+
+<div align='center'>
+
+<img src="https://github.com/user-attachments/assets/4ee688d9-467d-45c8-99d6-368f9a8a92d8" width="600">
+
+_✨ Docker ベースのサンドボックス化されたコードエグゼキューター（ベータテスト中）✨_
+
+<img src="https://github.com/user-attachments/assets/0378f407-6079-4f64-ae4c-e97ab20611d2" height=500>
+
+_✨ 多モーダル、ウェブ検索、長文の画像変換（設定可能）✨_
+
+<img src="https://github.com/user-attachments/assets/8ec12797-e70f-460a-959e-48eca39ca2bb" height=100>
+
+_✨ 自然言語タスク ✨_
+
+<img src="https://github.com/user-attachments/assets/e137a9e1-340a-4bf2-bb2b-771132780735" height=150>
+<img src="https://github.com/user-attachments/assets/480f5e82-cf6a-4955-a869-0d73137aa6e1" height=150>
+
+_✨ プラグインシステム - 一部のプラグインの展示 ✨_
+
+<img src="https://github.com/user-attachments/assets/592a8630-14c7-4e06-b496-9c0386e4f36c" width="600">
+
+_✨ 管理パネル ✨_
+
+![webchat](https://drive.soulter.top/f/vlsA/ezgif-5-fb044b2542.gif)
+
+_✨ 内蔵 Web Chat、オンラインでボットと対話 ✨_
+
+</div>
+
+## ⭐ Star History
+
+> [!TIP] 
+> このプロジェクトがあなたの生活や仕事に役立った場合、またはこのプロジェクトの将来の発展に関心がある場合は、プロジェクトに Star を付けてください。これはこのオープンソースプロジェクトを維持するためのモチベーションです <3
+
+<div align="center">
+    
+[![Star History Chart](https://api.star-history.com/svg?repos=soulter/astrbot&type=Date)](https://star-history.com/#soulter/astrbot&Date)
+
+</div>
+
+## スポンサー
+
+[<img src="https://api.gitsponsors.com/api/badge/img?id=575865240" height="20">](https://api.gitsponsors.com/api/badge/link?p=XEpbdGxlitw/RbcwiTX93UMzNK/jgDYC8NiSzamIPMoKvG2lBFmyXhSS/b0hFoWlBBMX2L5X5CxTDsUdyvcIEHTOfnkXz47UNOZvMwyt5CzbYpq0SEzsSV1OJF1cCo90qC/ZyYKYOWedal3MhZ3ikw==)
+
+## 免責事項
+
+1. このプロジェクトは `AGPL-v3` オープンソースライセンスの下で保護されています。
+2. WeChat（個人アカウント）のデプロイメントには [Gewechat](https://github.com/Devo919/Gewechat) サービスを利用しています。AstrBot は Gewechat との接続を保証するだけであり、アカウントのリスク管理に関しては、このプロジェクトの著者は一切の責任を負いません。
+3. このプロジェクトを使用する際は、現地の法律および規制を遵守してください。
+
+<!-- ## ✨ ATRI [ベータテスト]
+
+この機能はプラグインとしてロードされます。プラグインリポジトリのアドレス：[astrbot_plugin_atri](https://github.com/Soulter/astrbot_plugin_atri)
+
+1. 《ATRI ~ My Dear Moments》の主人公 ATRI のキャラクターセリフを微調整データセットとして使用した `Qwen1.5-7B-Chat Lora` 微調整モデル。
+2. 長期記憶
+3. ミームの理解と返信
+4. TTS
+    -->
+
+
+_私は、高性能ですから!_
+
--- a/astrbot/api/event/filter/init.py
+++ b/astrbot/api/event/filter/init.py
@@ -5,6 +5,7 @@ from astrbot.core.star.register import (
    register_regex as regex,
    register_platform_adapter_type as platform_adapter_type,
    register_permission_type as permission_type,
+    register_custom_filter as custom_filter,
    register_on_llm_request as on_llm_request,
    register_on_llm_response as on_llm_response,
    register_llm_tool as llm_tool,
@@ -15,6 +16,7 @@ from astrbot.core.star.register import (
 from astrbot.core.star.filter.event_message_type import EventMessageTypeFilter, EventMessageType
 from astrbot.core.star.filter.platform_adapter_type import PlatformAdapterTypeFilter, PlatformAdapterType
 from astrbot.core.star.filter.permission import PermissionTypeFilter, PermissionType
+from astrbot.core.star.filter.custom_filter import CustomFilter

 __all__ = [
    'command',
@@ -28,6 +30,8 @@ __all__ = [
    'PlatformAdapterTypeFilter',
    'PlatformAdapterType',
    'PermissionTypeFilter',
+    'CustomFilter',
+    'custom_filter',
    'PermissionType',
    'on_llm_request',
    'llm_tool',
--- a/astrbot/core/config/default.py
+++ b/astrbot/core/config/default.py
@@ -2,7 +2,7 @@
 如需修改配置，请在 `data/cmd_config.json` 中修改或者在管理面板中可视化修改。
 """

-VERSION = "3.4.26"
+VERSION = "3.4.30"
 DB_PATH = "data/data_v3.db"

 # 默认配置
@@ -32,7 +32,8 @@ DEFAULT_CONFIG = {
            "interval": "1.5,3.5",
            "log_base": 2.6,
            "words_count_threshold": 150,
-            "regex": ".*?[。？！~…]+|.+$"
+            "regex": ".*?[。？！~…]+|.+$",
+            "content_cleanup_rule": "",
        },
        "no_permission_reply": True,
    },
@@ -66,6 +67,7 @@ DEFAULT_CONFIG = {
            "method": "possibility_reply",
            "possibility_reply": 0.1,
            "prompt": "",
+            "whitelist": []
        }
    },
    "content_safety": {
@@ -270,6 +272,12 @@ CONFIG_METADATA_2 = {
                                "obvious_hint": True,
                                "hint": "用于分隔一段消息。默认情况下会根据句号、问号等标点符号分隔。re.findall(r'<regex>', text)",
                            },
+                            "content_cleanup_rule": {
+                                "description": "过滤分段后的内容",
+                                "type": "string",
+                                "obvious_hint": True,
+                                "hint": "移除分段后的内容中的指定的内容。支持正则表达式。如填写 `[。？！]` 将移除所有的句号、问号、感叹号。re.sub(r'<regex>', '', text)",
+                            },
                        },
                    },
                    "reply_prefix": {
@@ -401,6 +409,17 @@ CONFIG_METADATA_2 = {
                            "model": "gpt-4o-mini",
                        },
                    },
+                    "xAI": {
+                        "id": "xai",
+                        "type": "openai_chat_completion",
+                        "enable": True,
+                        "key": [],
+                        "api_base": "https://api.x.ai/v1",
+                        "timeout": 120,
+                        "model_config": {
+                            "model": "grok-2-latest",
+                        },
+                    },
                    "ollama": {
                        "id": "ollama_default",
                        "type": "openai_chat_completion",
@@ -495,6 +514,7 @@ CONFIG_METADATA_2 = {
                        "dify_api_key": "",
                        "dify_api_base": "https://api.dify.ai/v1",
                        "dify_workflow_output_key": "",
+                        "dify_query_input_key": "astrbot_text_query",
                        "timeout": 60,
                    },
                    "whisper(API)": {
@@ -646,6 +666,12 @@ CONFIG_METADATA_2 = {
                        "type": "string",
                        "hint": "Dify Workflow 输出变量名。当应用类型为 workflow 时才使用。默认为 astrbot_wf_output。",
                    },
+                    "dify_query_input_key": {
+                        "description": "Prompt 输入变量名",
+                        "type": "string",   
+                        "hint": "发送的消息文本内容对应的输入变量名。默认为 astrbot_text_query。",
+                        "obvious": True,
+                    }
                },
            },
            "provider_settings": {
@@ -815,6 +841,13 @@ CONFIG_METADATA_2 = {
                                "obvious_hint": True,
                                "hint": "启用后，会根据触发概率主动回复群聊内的对话。QQ官方API(qq_official)不可用",
                            },
+                            "whitelist": {
+                                "description": "主动回复白名单",
+                                "type": "list",
+                                "items": {"type": "string"},
+                                "obvious_hint": True,
+                                "hint": "启用后，只有在白名单内的群聊会被主动回复。为空时不启用白名单过滤。需要通过 /sid 获取 SID 添加到这里。",
+                            },
                            "method": {
                                "description": "回复方法",
                                "type": "string",
--- a/astrbot/core/conversation_mgr.py
+++ b/astrbot/core/conversation_mgr.py
@@ -50,6 +50,7 @@ class ConversationManager():
                cid=conversation_id
            )
            del self.session_conversations[unified_msg_origin]
+            sp.put("session_conversation", self.session_conversations)
            
    async def get_curr_conversation_id(self, unified_msg_origin: str) -> str:
        '''获取会话当前的对话 ID'''
--- a/astrbot/core/core_lifecycle.py
+++ b/astrbot/core/core_lifecycle.py
@@ -27,7 +27,8 @@ class AstrBotCoreLifecycle:
        
        os.environ['https_proxy'] = self.astrbot_config['http_proxy']
        os.environ['http_proxy'] = self.astrbot_config['http_proxy']
-    
+        os.environ['no_proxy'] = 'localhost,127.0.0.1'
+        
    async def initialize(self):
        logger.info("AstrBot v"+ VERSION)
        if os.environ.get("TESTING", ""):
--- a/astrbot/core/db/sqlite.py
+++ b/astrbot/core/db/sqlite.py
@@ -247,6 +247,10 @@ class SQLiteDatabase(BaseDatabase):
        
        res = c.fetchone()
        c.close()
+        
+        if not res:
+            return
+        
        return Conversation(*res)
    
    def new_conversation(self, user_id: str, cid: str):
--- a/astrbot/core/pipeline/content_safety_check/stage.py
+++ b/astrbot/core/pipeline/content_safety_check/stage.py
@@ -22,8 +22,9 @@ class ContentSafetyCheckStage(Stage):
        text = check_text if check_text else event.get_message_str()
        ok, info = self.strategy_selector.check(text)
        if not ok:
-            event.set_result(MessageEventResult().message("你的消息或者大模型的响应中包含不适当的内容，已被屏蔽。"))
-            yield 
+            if event.is_at_or_wake_command:
+                event.set_result(MessageEventResult().message("你的消息或者大模型的响应中包含不适当的内容，已被屏蔽。"))
+                yield 
            event.stop_event()
            logger.info(f"内容安全检查不通过，原因：{info}")
            return
--- a/astrbot/core/pipeline/process_stage/method/dify_request.py
+++ b/astrbot/core/pipeline/process_stage/method/dify_request.py
@@ -11,6 +11,7 @@ from astrbot.core.message.components import Image
 from astrbot.core import logger
 from astrbot.core.utils.metrics import Metric
 from astrbot.core.provider.entites import ProviderRequest
+from astrbot.core.star.star_handler import star_handlers_registry, EventType

 class DifyRequestSubStage(Stage):
    
@@ -48,17 +49,40 @@ class DifyRequestSubStage(Stage):
            return
        
        req.session_id = event.unified_msg_origin
+        
+        # 执行请求 LLM 前事件钩子。
+        # 装饰 system_prompt 等功能
+        handlers = star_handlers_registry.get_handlers_by_event_type(EventType.OnLLMRequestEvent)
+        for handler in handlers:
+            try:
+                await handler.handler(event, req)
+            except BaseException:
+                logger.error(traceback.format_exc())
            
        try:
            logger.debug(f"Dify 请求 Payload: {req.__dict__}")
            llm_response = await provider.text_chat(**req.__dict__) # 请求 LLM
            await Metric.upload(llm_tick=1, model_name=provider.get_model(), provider_type=provider.meta().type)
+            
+            # 执行 LLM 响应后的事件。
+            handlers = star_handlers_registry.get_handlers_by_event_type(EventType.OnLLMResponseEvent)
+            for handler in handlers:
+                try:
+                    await handler.handler(event, llm_response)
+                except BaseException:
+                    logger.error(traceback.format_exc())

            if llm_response.role == 'assistant':
                # text completion
                event.set_result(MessageEventResult().message(llm_response.completion_text)
                                 .set_result_content_type(ResultContentType.LLM_RESULT))
-                yield # rick roll
+                return
+            elif llm_response.role == 'err':
+                event.set_result(MessageEventResult().message(f"AstrBot 请求失败。\n错误信息: {llm_response.completion_text}"))
+                return
+            elif llm_response.role == 'tool':
+                event.set_result(MessageEventResult().message(f"Dify 暂不支持工具调用。"))
+                yield

        except BaseException as e:
            logger.error(traceback.format_exc())
--- a/astrbot/core/pipeline/process_stage/method/llm_request.py
+++ b/astrbot/core/pipeline/process_stage/method/llm_request.py
@@ -64,7 +64,7 @@ class LLMRequestSubStage(Stage):
        if not req.prompt and not req.image_urls:
            return
            
-        # 执行请求 LLM 前事件。
+        # 执行请求 LLM 前事件钩子。
        # 装饰 system_prompt 等功能
        handlers = star_handlers_registry.get_handlers_by_event_type(EventType.OnLLMRequestEvent)
        for handler in handlers:
--- a/astrbot/core/pipeline/process_stage/stage.py
+++ b/astrbot/core/pipeline/process_stage/stage.py
@@ -35,7 +35,6 @@ class ProcessStage(Stage):
                # 生成器返回值处理
                if isinstance(resp, ProviderRequest):
                    # Handler 的 LLM 请求
-                    logger.debug(f"llm request -> {resp.prompt}")
                    event.set_extra("provider_request", resp)
                    _t = False
                    async for _ in self.llm_request_sub_stage.process(event):
@@ -46,12 +45,14 @@ class ProcessStage(Stage):
                else:
                    yield
        
-        # 调用提供商相关请求
+        # 调用 LLM 相关请求
        if not self.ctx.astrbot_config['provider_settings'].get('enable', True):
            return
        
        if not event._has_send_oper and event.is_at_or_wake_command:
+            # 是否有过发送操作 and 是否是被 @ 或者通过唤醒前缀
            if (event.get_result() and not event.get_result().is_stopped()) or not event.get_result():
+                # 事件没有终止传播
                provider = self.ctx.plugin_manager.context.get_using_provider()
                
                if not provider:
--- a/astrbot/core/pipeline/respond/stage.py
+++ b/astrbot/core/pipeline/respond/stage.py
@@ -1,20 +1,24 @@
 import random
 import asyncio
 import math
+import traceback
 from typing import Union, AsyncGenerator
 from ..stage import register_stage, Stage
 from ..context import PipelineContext
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.message.message_event_result import MessageChain
 from astrbot.core import logger
-from astrbot.core.message.message_event_result import BaseMessageComponent, Plain
+from astrbot.core.message.message_event_result import BaseMessageComponent
 from astrbot.core.star.star_handler import star_handlers_registry, EventType
-
+from astrbot.core.message.components import Plain, Reply, At
@register_stage
 class RespondStage(Stage):
    async def initialize(self, ctx: PipelineContext):
        self.ctx = ctx
        
+        self.reply_with_mention = ctx.astrbot_config['platform_settings']['reply_with_mention']
+        self.reply_with_quote = ctx.astrbot_config['platform_settings']['reply_with_quote']
+        
        # 分段回复
        self.enable_seg: bool = ctx.astrbot_config['platform_settings']['segmented_reply']['enable']
        self.only_llm_result = ctx.astrbot_config['platform_settings']['segmented_reply']['only_llm_result']
@@ -60,11 +64,24 @@ class RespondStage(Stage):
            await event._pre_send()
            
            if self.enable_seg and ((self.only_llm_result and result.is_llm_result()) or not self.only_llm_result):
+                decorated_comps = []
+                if self.reply_with_mention:
+                    for comp in result.chain:
+                        if isinstance(comp, At):
+                            decorated_comps.append(comp)
+                            result.chain.remove(comp)
+                            break
+                if self.reply_with_quote:
+                    for comp in result.chain:
+                        if isinstance(comp, Reply):
+                            decorated_comps.append(comp)
+                            result.chain.remove(comp)
+                            break
                # 分段回复
                for comp in result.chain:
                    i = await self._calc_comp_interval(comp)
                    await asyncio.sleep(i)
-                    await event.send(MessageChain([comp]))
+                    await event.send(MessageChain([*decorated_comps, comp]))
            else:
                await event.send(result)
            await event._post_send()
@@ -72,7 +89,9 @@ class RespondStage(Stage):
        
        handlers = star_handlers_registry.get_handlers_by_event_type(EventType.OnAfterMessageSentEvent)
        for handler in handlers:
-            # TODO: 如何让这里的 handler 也能使用 LLM 能力。也许需要将 LLMRequestSubStage 提取出来。
-            await handler.handler(event)
+            try:
+                await handler.handler(event)
+            except BaseException:
+                logger.error(traceback.format_exc())
            
        event.clear_result()
--- a/astrbot/core/pipeline/result_decorate/stage.py
+++ b/astrbot/core/pipeline/result_decorate/stage.py
@@ -7,7 +7,7 @@ from ..context import PipelineContext
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.platform.message_type import MessageType
 from astrbot.core import logger
-from astrbot.core.message.components import Plain, Image, At, Reply, Record
+from astrbot.core.message.components import Plain, Image, At, Reply, Record, File, Node
 from astrbot.core import html_renderer
 from astrbot.core.star.star_handler import star_handlers_registry, EventType

@@ -25,12 +25,16 @@ class ResultDecorateStage(Stage):
                self.t2i_word_threshold = 50
        except BaseException:
            self.t2i_word_threshold = 150
+            
+        self.forward_threshold = ctx.astrbot_config['platform_settings']['forward_threshold']
        
        # 分段回复
        self.words_count_threshold = int(ctx.astrbot_config['platform_settings']['segmented_reply']['words_count_threshold'])
        self.enable_segmented_reply = ctx.astrbot_config['platform_settings']['segmented_reply']['enable']
        self.only_llm_result = ctx.astrbot_config['platform_settings']['segmented_reply']['only_llm_result']
        self.regex = ctx.astrbot_config['platform_settings']['segmented_reply']['regex']
+        self.content_cleanup_rule = ctx.astrbot_config['platform_settings']['segmented_reply']['content_cleanup_rule']
+
        
        # exception
        self.content_safe_check_reply = ctx.astrbot_config['content_safety']['also_use_in_response']
@@ -55,10 +59,14 @@ class ResultDecorateStage(Stage):
            async for _ in self.content_safe_check_stage.process(event, check_text=text):
                yield
        
+        # 发送消息前事件钩子
        handlers = star_handlers_registry.get_handlers_by_event_type(EventType.OnDecoratingResultEvent)
        for handler in handlers:
-            await handler.handler(event)
-        
+            try:
+                await handler.handler(event)
+            except BaseException:
+                logger.error(traceback.format_exc())
+            
        # 需要再获取一次。插件可能直接对 chain 进行了替换。
        result = event.get_result()
        if result is None:
@@ -82,12 +90,16 @@ class ResultDecorateStage(Stage):
                                # 不分段回复
                                new_chain.append(comp)
                                continue
-                            split_response = re.findall(self.regex, comp.text)
+                            split_response = []
+                            for line in comp.text.split("\n"):
+                                split_response.extend(re.findall(self.regex, line))
                            if not split_response:
                                new_chain.append(comp)
                                continue
                            for seg in split_response:
-                                if seg:
+                                if self.content_cleanup_rule:
+                                    seg = re.sub(self.content_cleanup_rule, "", seg)
+                                if seg.strip():
                                    new_chain.append(Plain(seg))
                        else:
                            # 非 Plain 类型的消息段不分段
@@ -137,12 +149,32 @@ class ResultDecorateStage(Stage):
                    if url:
                        result.chain = [Image.fromURL(url)]
            
-            # at 回复
-            if self.reply_with_mention and event.get_message_type() != MessageType.FRIEND_MESSAGE:
-                result.chain.insert(0, At(qq=event.get_sender_id(), name=event.get_sender_name()))
-                if len(result.chain) > 1 and isinstance(result.chain[1], Plain):
-                    result.chain[1].text = "\n" + result.chain[1].text
+            # 触发转发消息
+            has_forwarded = False
+            if event.get_platform_name() == 'aiocqhttp':
+                word_cnt = 0
+                for comp in result.chain:
+                    if isinstance(comp, Plain):
+                        word_cnt += len(comp.text)
+                if word_cnt > self.forward_threshold:
+                    node = Node(
+                        uin=event.get_self_id(),
+                        name="AstrBot",
+                        content=[
+                            *result.chain
+                        ]
+                    )
+                    result.chain = [node]
+                    has_forwarded = True
            
-            # 引用回复
-            if self.reply_with_quote:
-                result.chain.insert(0, Reply(id=event.message_obj.message_id))
+            if not has_forwarded:
+                # at 回复
+                if self.reply_with_mention and event.get_message_type() != MessageType.FRIEND_MESSAGE:
+                    result.chain.insert(0, At(qq=event.get_sender_id(), name=event.get_sender_name()))
+                    if len(result.chain) > 1 and isinstance(result.chain[1], Plain):
+                        result.chain[1].text = "\n" + result.chain[1].text
+                
+                # 引用回复
+                if self.reply_with_quote:
+                    if not any(isinstance(item, File) for item in result.chain):
+                        result.chain.insert(0, Reply(id=event.message_obj.message_id))
--- a/astrbot/core/pipeline/scheduler.py
+++ b/astrbot/core/pipeline/scheduler.py
@@ -12,14 +12,14 @@ class PipelineScheduler():
        
    async def initialize(self):
        for stage in registered_stages:
-            logger.debug(f"初始化阶段 {stage.__class__ .__name__}")
+            # logger.debug(f"初始化阶段 {stage.__class__ .__name__}")
            
            await stage.initialize(self.ctx)
            
    async def _process_stages(self, event: AstrMessageEvent, from_stage=0):
        for i in range(from_stage, len(registered_stages)):
            stage = registered_stages[i]
-            logger.debug(f"执行阶段 {stage.__class__ .__name__}")
+            # logger.debug(f"执行阶段 {stage.__class__ .__name__}")
            coro = stage.process(event)
            if isinstance(coro, AsyncGenerator):
                async for _ in coro:
--- a/astrbot/core/pipeline/stage.py
+++ b/astrbot/core/pipeline/stage.py
@@ -1,6 +1,7 @@
 from __future__ import annotations
 import abc
 import inspect
+from astrbot.api import logger
 from typing import List, AsyncGenerator, Union, Awaitable
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from .context import PipelineContext
@@ -36,16 +37,18 @@ class Stage(abc.ABC):
        ctx: PipelineContext,
        event: AstrMessageEvent, 
        handler: Awaitable,
-        **params
+        *args,
+        **kwargs,
    ) -> AsyncGenerator[None, None]:
        '''调用 Handler。'''
        # 判断 handler 是否是类方法（通过装饰器注册的没有 __self__ 属性）
        ready_to_call = None
        try:
-            ready_to_call = handler(event, **params)
+            ready_to_call = handler(event, *args, **kwargs)
        except TypeError as e:
            # 向下兼容
-            ready_to_call = handler(event, ctx.plugin_manager.context, **params)
+            logger.debug(str(e))
+            ready_to_call = handler(event, ctx.plugin_manager.context, *args, **kwargs)
        
        if isinstance(ready_to_call, AsyncGenerator):
            async for ret in ready_to_call:
--- a/astrbot/core/pipeline/waking_check/stage.py
+++ b/astrbot/core/pipeline/waking_check/stage.py
@@ -5,6 +5,7 @@ from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.message.message_event_result import MessageEventResult, MessageChain
 from astrbot.core.message.components import At, Reply
 from astrbot.core.star.star_handler import star_handlers_registry, EventType
+from astrbot.core.star.star import star_map
 from astrbot.core.star.filter.command_group import CommandGroupFilter
 from astrbot.core.star.filter.permission import PermissionTypeFilter

@@ -76,34 +77,17 @@ class WakingCheckStage(Stage):
        # 检查插件的 handler filter
        activated_handlers = []
        handlers_parsed_params = {}  # 注册了指令的 handler
+        
        for handler in star_handlers_registry.get_handlers_by_event_type(EventType.AdapterMessageEvent):
-            # filter 需要满足 AND 的逻辑关系
-            passed = True
-            child_command_handler_md = None
-            
+            # filter 需满足 AND 逻辑关系
+            passed = True            
            permission_not_pass = False
-            
            if len(handler.event_filters) == 0:
-                # 不可能有这种情况, 也不允许有这种情况
-                continue
-            
-            if 'sub_command' in handler.extras_configs:
-                # 如果是子指令
                continue

            for filter in handler.event_filters:
                try:
-                    if isinstance(filter, CommandGroupFilter):
-                        """如果指令组过滤成功, 会返回叶子指令的 StarHandlerMetadata"""
-                        ok, child_command_handler_md = filter.filter(
-                            event, self.ctx.astrbot_config
-                        )
-                        if not ok:
-                            passed = False
-                        else:
-                            handler = child_command_handler_md  # handler 覆盖
-                            break
-                    elif isinstance(filter, PermissionTypeFilter):
+                    if isinstance(filter, PermissionTypeFilter):
                        if not filter.filter(event, self.ctx.astrbot_config):
                            permission_not_pass = True
                    else:
@@ -111,19 +95,15 @@ class WakingCheckStage(Stage):
                            passed = False
                            break
                except Exception as e:
-                    # event.set_result(MessageEventResult().message(f"插件 {handler.handler_full_name} 报错：{e}"))
-                    # yield
                    await event.send(
                        MessageEventResult().message(
-                            f"插件 {handler.handler_full_name} 报错：{e}"
+                            f"插件 {star_map[handler.handler_module_path].name}: {e}"
                        )
                    )
                    event.stop_event()
                    passed = False
                    break
-
            if passed:
-                
                if permission_not_pass:
                    if self.no_permission_reply:
                        await event.send(MessageChain().message(f"ID {event.get_sender_id()} 权限不足。通过 /sid 获取 ID 并请管理员添加。"))
@@ -138,6 +118,7 @@ class WakingCheckStage(Stage):
                    handlers_parsed_params[handler.handler_full_name] = event.get_extra(
                        "parsed_params"
                    )
+                    
            event.clear_extra()

        event.set_extra("activated_handlers", activated_handlers)
--- a/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py
+++ b/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py
@@ -2,6 +2,7 @@ import os
 import time
 import asyncio
 import logging
+import uuid
 from typing import Awaitable, Any
 from aiocqhttp import CQHttp, Event
 from astrbot.api.platform import Platform, AstrBotMessage, MessageMember, MessageType, PlatformMetadata
@@ -46,19 +47,82 @@ class AiocqhttpAdapter(Platform):
        await super().send_by_session(session, message_chain)
        
    async def convert_message(self, event: Event) -> AstrBotMessage:
+        logger.debug(f"[aiocqhttp] RawMessage {event}")
+        
+        if event['post_type'] == 'message':
+            abm = await self._convert_handle_message_event(event)
+        elif event['post_type'] == 'notice':
+            abm = await self._convert_handle_notice_event(event)
+        elif event['post_type'] == 'request':
+            abm = await self._convert_handle_request_event(event)
+        
+        return abm
+    
+    async def _convert_handle_request_event(self, event: Event) -> AstrBotMessage:
+        '''OneBot V11 请求类事件'''
        abm = AstrBotMessage()
        abm.self_id = str(event.self_id)
-        abm.tag = "aiocqhttp"
+        abm.sender = MessageMember(
+            user_id=event.user_id,
+            nickname=event.user_id
+        )
+        abm.type = MessageType.OTHER_MESSAGE
+        if 'group_id' in event and event['group_id']:
+            abm.type = MessageType.GROUP_MESSAGE
+            abm.group_id = str(event.group_id)
+        else:
+            abm.type = MessageType.FRIEND_MESSAGE
+        if self.unique_session and abm.type == MessageType.GROUP_MESSAGE:
+            abm.session_id = abm.sender.user_id + "_" + str(event.group_id)
+        abm.message_str = ''
+        abm.message = []
+        abm.timestamp = int(time.time())
+        abm.message_id = uuid.uuid4().hex
+        abm.raw_message = event
+        return abm
+    
+    async def _convert_handle_notice_event(self, event: Event) -> AstrBotMessage:
+        '''OneBot V11 通知类事件'''
+        abm = AstrBotMessage()
+        abm.self_id = str(event.self_id)
+        abm.sender = MessageMember(
+            user_id=event.user_id,
+            nickname=event.user_id
+        )
+        abm.type = MessageType.OTHER_MESSAGE
+        if 'group_id' in event and event['group_id']:
+            abm.group_id = str(event.group_id)
+            abm.type = MessageType.GROUP_MESSAGE
+        else:
+            abm.type = MessageType.FRIEND_MESSAGE    
+        if self.unique_session and abm.type == MessageType.GROUP_MESSAGE:
+            abm.session_id = abm.sender.user_id + "_" + str(event.group_id) # 也保留群组 id
+        else:
+            abm.session_id = str(event.group_id) if abm.type == MessageType.GROUP_MESSAGE else abm.sender.user_id
+        abm.message_str = ""
+        abm.message = []
+        abm.raw_message = event
+        abm.timestamp = int(time.time())
+        abm.message_id = uuid.uuid4().hex
        
-        abm.sender = MessageMember(str(event.sender['user_id']), event.sender['nickname'])        
-
+        if 'sub_type' in event:
+            if event['sub_type'] == 'poke' and 'target_id' in event:
+                abm.message.append(Poke(qq=str(event['target_id']), type='poke')) # noqa: F405
+                
+        return abm
+    
+    
+    async def _convert_handle_message_event(self, event: Event) -> AstrBotMessage:
+        '''OneBot V11 消息类事件'''
+        abm = AstrBotMessage()
+        abm.self_id = str(event.self_id)
+        abm.sender = MessageMember(str(event.sender['user_id']), event.sender['nickname'])      
        if event['message_type'] == 'group':
            abm.type = MessageType.GROUP_MESSAGE
            abm.group_id = str(event.group_id)
        elif event['message_type'] == 'private':
            abm.type = MessageType.FRIEND_MESSAGE
-        
-        if self.unique_session:
+        if self.unique_session and abm.type == MessageType.GROUP_MESSAGE:
            abm.session_id = abm.sender.user_id + "_" + str(event.group_id) # 也保留群组 id
        else:
            abm.session_id = str(event.group_id) if abm.type == MessageType.GROUP_MESSAGE else abm.sender.user_id
@@ -75,7 +139,8 @@ class AiocqhttpAdapter(Platform):
            except BaseException as e:
                logger.error(f"回复消息失败: {e}")
            return
-        logger.debug(f"aiocqhttp: 收到消息: {event.message}")
+        
+        # 按消息段类型类型适配
        for m in event.message:
            t = m['type']
            a = None
@@ -118,6 +183,7 @@ class AiocqhttpAdapter(Platform):
        abm.timestamp = int(time.time())
        abm.message_str = message_str
        abm.raw_message = event
+        
        return abm
    
    def run(self) -> Awaitable[Any]:
@@ -127,6 +193,19 @@ class AiocqhttpAdapter(Platform):
            self.port = 6199
            
        self.bot = CQHttp(use_ws_reverse=True, import_name='aiocqhttp', api_timeout_sec=180)
+        
+        @self.bot.on_request()
+        async def request(event: Event):
+            abm = await self.convert_message(event)
+            if abm:
+                await self.handle_msg(abm)
+        
+        @self.bot.on_notice()
+        async def notice(event: Event):
+            abm = await self.convert_message(event)
+            if abm:
+                await self.handle_msg(abm)
+        
        @self.bot.on_message('group')
        async def group(event: Event):
            abm = await self.convert_message(event)
--- a/astrbot/core/platform/sources/gewechat/client.py
+++ b/astrbot/core/platform/sources/gewechat/client.py
@@ -4,7 +4,7 @@ import aiohttp
 import quart
 import base64
 import datetime
-
+import re
 from astrbot.api.platform import AstrBotMessage, MessageMember, MessageType
 from astrbot.api.message_components import Plain, Image, At, Record
 from astrbot.api import logger, sp
@@ -51,6 +51,8 @@ class SimpleGewechatClient():
        self.event_queue = event_queue
        
        self.multimedia_downloader = None
+        
+        self.userrealnames = {}
    
    async def get_token_id(self):
        async with aiohttp.ClientSession() as session:
@@ -100,7 +102,8 @@ class SimpleGewechatClient():
            content = _t[1]
            if '\u2005' in content: 
                # at
-                content = content.split('\u2005')[1]
+                # content = content.split('\u2005')[1]
+                content = re.sub(r'@[^\u2005]*\u2005', '', content)
            abm.group_id = from_user_name
            # at
            msg_source = d['MsgSource']
@@ -117,10 +120,25 @@ class SimpleGewechatClient():
        if at_me:
            abm.message.insert(0, At(qq=abm.self_id))
        
-        user_real_name = d.get('PushContent', 'unknown : ').split(' : ')[0] \
-            .replace('在群聊中@了你', '') \
-            .replace('在群聊中发了一段语音', '') \
-            .replace('在群聊中发了一张图片', '') # 真实昵称
+        # 解析用户真实名字
+        user_real_name = "unknown"
+        if abm.group_id:
+            if abm.group_id not in self.userrealnames or user_id not in self.userrealnames[abm.group_id]:
+                # 获取群成员列表，并且缓存
+                if abm.group_id not in self.userrealnames:
+                    self.userrealnames[abm.group_id] = {}
+                member_list = await self.get_chatroom_member_list(abm.group_id)
+                logger.debug(f"获取到 {abm.group_id} 的群成员列表。")
+                if member_list and 'memberList' in member_list:
+                    for member in member_list['memberList']:
+                        self.userrealnames[abm.group_id][member['wxid']] = member['nickName']
+                if user_id in self.userrealnames[abm.group_id]:
+                    user_real_name = self.userrealnames[abm.group_id][user_id]
+            else:
+                user_real_name = self.userrealnames[abm.group_id][user_id]
+        else:
+            user_real_name = d.get('PushContent', 'unknown : ').split(' : ')[0]
+
        abm.sender = MessageMember(user_id, user_real_name)
        abm.raw_message = d
        abm.message_str = ""
@@ -312,6 +330,23 @@ class SimpleGewechatClient():
            self.appid = appid
            logger.info(f"已保存 APPID: {appid}")
    
+    '''API'''
+    
+    async def get_chatroom_member_list(self, chatroom_wxid: str):
+        payload = {
+            "appId": self.appid,
+            "chatroomId": chatroom_wxid
+        }
+        
+        async with aiohttp.ClientSession() as session:
+            async with session.post(
+                f"{self.base_url}/group/getChatroomMemberList",
+                headers=self.headers,
+                json=payload
+            ) as resp:
+                json_blob = await resp.json()
+                return json_blob['data']
+    
    async def post_text(self, to_wxid, content: str, ats: str = ""):
        payload = {
            "appId": self.appid,
--- a/astrbot/core/platform/sources/gewechat/gewechat_event.py
+++ b/astrbot/core/platform/sources/gewechat/gewechat_event.py
@@ -134,6 +134,6 @@ class GewechatPlatformEvent(AstrMessageEvent):
            elif isinstance(comp, At):
                pass
            else:
-                logger.error(f"gewechat 暂不支持发送消息类型: {comp.type}")   
+                logger.debug(f"gewechat 忽略: {comp.type}")   
        
        await super().send(message)
--- a/astrbot/core/platform/sources/qqofficial/qqofficial_message_event.py
+++ b/astrbot/core/platform/sources/qqofficial/qqofficial_message_event.py
@@ -5,7 +5,7 @@ import botpy.types.message
 from astrbot.core.utils.io import file_to_base64, download_image_by_url
 from astrbot.api.event import AstrMessageEvent, MessageChain
 from astrbot.api.platform import AstrBotMessage, PlatformMetadata
-from astrbot.api.message_components import Plain, Image, Reply
+from astrbot.api.message_components import Plain, Image
 from botpy import Client
 from botpy.http import Route
 from astrbot.api import logger
@@ -33,19 +33,6 @@ class QQOfficialMessageEvent(AstrMessageEvent):
        if not plain_text and not image_base64 and not image_path:
            return
        
-        ref = None
-        for i in self.send_buffer.chain:
-            if isinstance(i, Reply):
-                try:
-                    ref = self.message_obj.raw_message.message_reference
-                    ref = botpy.types.message.Reference(
-                        message_id=ref.message_id,
-                        ignore_get_message_error=False
-                    )
-                except BaseException as _:
-                    pass
-                break
-        
        payload = {
            'content': plain_text,
            'msg_id': self.message_obj.message_id,
@@ -53,30 +40,22 @@ class QQOfficialMessageEvent(AstrMessageEvent):
        
        match type(source):
            case botpy.message.GroupMessage:
-                if ref:
-                    payload['message_reference'] = ref
                if image_base64:
                    media = await self.upload_group_and_c2c_image(image_base64, 1, group_openid=source.group_openid)
                    payload['media'] = media
                    payload['msg_type'] = 7
                await self.bot.api.post_group_message(group_openid=source.group_openid, **payload)
            case botpy.message.C2CMessage:
-                if ref:
-                    payload['message_reference'] = ref
                if image_base64:
                    media = await self.upload_group_and_c2c_image(image_base64, 1, openid=source.author.user_openid)
                    payload['media'] = media
                    payload['msg_type'] = 7
                await self.bot.api.post_c2c_message(openid=source.author.user_openid, **payload)
            case botpy.message.Message:
-                if ref:
-                    payload['message_reference'] = ref
                if image_path:
                    payload['file_image'] = image_path
                await self.bot.api.post_message(channel_id=source.channel_id, **payload)
            case botpy.message.DirectMessage:
-                if ref:
-                    payload['message_reference'] = ref
                if image_path:
                    payload['file_image'] = image_path
                await self.bot.api.post_dms(guild_id=source.guild_id, **payload)
@@ -119,5 +98,5 @@ class QQOfficialMessageEvent(AstrMessageEvent):
                    image_base64 = file_to_base64(i.file).replace("base64://", "")
                    image_file_path = i.file
            else:
-                logger.error(f"qq_official 暂不支持发送消息类型 {i.type}")
+                logger.debug(f"qq_official 忽略 {i.type}")
        return plain_text, image_base64, image_file_path
--- a/astrbot/core/platform/sources/qqofficial_webhook/qo_webhook_adapter.py
+++ b/astrbot/core/platform/sources/qqofficial_webhook/qo_webhook_adapter.py
@@ -43,7 +43,7 @@ class botClient(Client):
        
    # 收到 C2C 消息
    async def on_c2c_message_create(self, message: botpy.message.C2CMessage):
-        abm = self.platform._parse_from_qqofficial(message, MessageType.FRIEND_MESSAGE)
+        abm = QQOfficialPlatformAdapter._parse_from_qqofficial(message, MessageType.FRIEND_MESSAGE)
        abm.session_id = abm.sender.user_id
        self._commit(abm)
        
--- a/astrbot/core/platform/sources/webchat/webchat_event.py
+++ b/astrbot/core/platform/sources/webchat/webchat_event.py
@@ -39,6 +39,6 @@ class WebChatMessageEvent(AstrMessageEvent):
                            f.write(f2.read())
                web_chat_back_queue.put_nowait((f"[IMAGE]{filename}", cid))
            else:
-                logger.error(f"webchat 暂不支持发送消息类型: {comp.type}")
+                logger.debug(f"webchat 忽略: {comp.type}")
        web_chat_back_queue.put_nowait(None)
        await super().send(message)
--- a/astrbot/core/provider/sources/dify_source.py
+++ b/astrbot/core/provider/sources/dify_source.py
@@ -31,6 +31,9 @@ class ProviderDify(Provider):
            raise Exception("Dify API 类型不能为空。")
        self.model_name = "dify"
        self.workflow_output_key = provider_config.get("dify_workflow_output_key", "astrbot_wf_output")
+        self.dify_query_input_key = provider_config.get("dify_query_input_key", "astrbot_text_query")
+        if not self.dify_query_input_key:
+            self.dify_query_input_key = "astrbot_text_query"
        self.timeout = provider_config.get("timeout", 120)
        if isinstance(self.timeout, str):
            self.timeout = int(self.timeout)
@@ -72,56 +75,61 @@ class ProviderDify(Provider):
        session_vars = sp.get("session_variables", {})
        session_var = session_vars.get(session_id, {})
        
-        match self.api_type:
-            case "chat" | "agent":
-                async for chunk in self.api_client.chat_messages(
-                    inputs={
-                        **session_var
-                    },
-                    query=prompt,
-                    user=session_id,
-                    conversation_id=conversation_id,
-                    files=files_payload,
-                    timeout=self.timeout
-                ):
-                    logger.debug(f"dify resp chunk: {chunk}")
-                    if chunk['event'] == "message" or \
-                        chunk['event'] == "agent_message":
-                        result += chunk['answer']
-                        if not conversation_id:
-                            self.conversation_ids[session_id] = chunk['conversation_id']
-                            conversation_id = chunk['conversation_id']
-            
-            case "workflow":
-                async for chunk in self.api_client.workflow_run(
-                    inputs={
-                        "astrbot_text_query": prompt,
-                        "astrbot_session_id": session_id,
-                        **session_var
-                    },
-                    user=session_id,
-                    files=files_payload,
-                    timeout=self.timeout
-                ):
-                    match chunk['event']:
-                        case "workflow_started":
-                            logger.info(f"Dify 工作流(ID: {chunk['workflow_run_id']})开始运行。")
-                        case "node_finished":
-                            logger.debug(f"Dify 工作流节点(ID: {chunk['data']['node_id']} Title: {chunk['data'].get('title', '')})运行结束。")
-                        case "workflow_finished":
-                            logger.info(f"Dify 工作流(ID: {chunk['workflow_run_id']})运行结束。")
-                            if chunk['data']['error']:
-                                logger.error(f"Dify 工作流出现错误：{chunk['data']['error']}")
-                                raise Exception(f"Dify 工作流出现错误：{chunk['data']['error']}")
-                            if self.workflow_output_key not in chunk['data']['outputs']:
-                                raise Exception(f"Dify 工作流的输出不包含指定的键名：{self.workflow_output_key}")
-                            result = chunk['data']['outputs'][self.workflow_output_key]
-            case _:
-                raise Exception(f"未知的 Dify API 类型：{self.api_type}")
+        try:
+            match self.api_type:
+                case "chat" | "agent":
+                    async for chunk in self.api_client.chat_messages(
+                        inputs={
+                            **session_var
+                        },
+                        query=prompt,
+                        user=session_id,
+                        conversation_id=conversation_id,
+                        files=files_payload,
+                        timeout=self.timeout
+                    ):
+                        logger.debug(f"dify resp chunk: {chunk}")
+                        if chunk['event'] == "message" or \
+                            chunk['event'] == "agent_message":
+                            result += chunk['answer']
+                            if not conversation_id:
+                                self.conversation_ids[session_id] = chunk['conversation_id']
+                                conversation_id = chunk['conversation_id']
+                
+                case "workflow":
+                    async for chunk in self.api_client.workflow_run(
+                        inputs={
+                            self.dify_query_input_key: prompt,
+                            "astrbot_session_id": session_id,
+                            **session_var
+                        },
+                        user=session_id,
+                        files=files_payload,
+                        timeout=self.timeout
+                    ):
+                        match chunk['event']:
+                            case "workflow_started":
+                                logger.info(f"Dify 工作流(ID: {chunk['workflow_run_id']})开始运行。")
+                            case "node_finished":
+                                logger.debug(f"Dify 工作流节点(ID: {chunk['data']['node_id']} Title: {chunk['data'].get('title', '')})运行结束。")
+                            case "workflow_finished":
+                                logger.info(f"Dify 工作流(ID: {chunk['workflow_run_id']})运行结束。")
+                                if chunk['data']['error']:
+                                    logger.error(f"Dify 工作流出现错误：{chunk['data']['error']}")
+                                    raise Exception(f"Dify 工作流出现错误：{chunk['data']['error']}")
+                                if self.workflow_output_key not in chunk['data']['outputs']:
+                                    raise Exception(f"Dify 工作流的输出不包含指定的键名：{self.workflow_output_key}")
+                                result = chunk['data']['outputs'][self.workflow_output_key]
+                case _:
+                    raise Exception(f"未知的 Dify API 类型：{self.api_type}")
+        except Exception as e:
+            logger.error(f"Dify 请求失败：{str(e)}")
+            return LLMResponse(role="err", completion_text=f"Dify 请求失败：{str(e)}")
+        
        return LLMResponse(role="assistant", completion_text=result)

    async def forget(self, session_id):
-        self.conversation_ids.pop(session_id, None)
+        self.conversation_ids[session_id] = ""
        return True

    async def get_current_key(self):
--- a/astrbot/core/provider/sources/gemini_source.py
+++ b/astrbot/core/provider/sources/gemini_source.py
@@ -1,5 +1,6 @@
 import base64
 import aiohttp
+import random
 from astrbot.core.utils.io import download_image_by_url
 from astrbot.core.db import BaseDatabase
 from astrbot.api.provider import Provider, Personality
@@ -106,6 +107,9 @@ class ProviderGoogleGenAI(Provider):
        for message in payloads["messages"]:
            if message["role"] == "user":
                if isinstance(message["content"], str):
+                    if not message['content']:
+                        message['content'] = "<empty_content>"
+                    
                    google_genai_conversation.append({
                        "role": "user",
                        "parts": [{"text": message["content"]}]
@@ -115,6 +119,8 @@ class ProviderGoogleGenAI(Provider):
                    parts = []
                    for part in message["content"]:
                        if part["type"] == "text":
+                            if not part["text"]:
+                                part["text"] = "<empty_content>"
                            parts.append({"text": part["text"]})
                        elif part["type"] == "image_url":
                            parts.append({"inline_data": {
@@ -127,12 +133,13 @@ class ProviderGoogleGenAI(Provider):
                    })
                        
            elif message["role"] == "assistant":
+                if not message["content"]:
+                    message["content"] = "<empty_content>"
                google_genai_conversation.append({
                    "role": "model",
                    "parts": [{"text": message["content"]}]
                })
-                
-        
+
        logger.debug(f"google_genai_conversation: {google_genai_conversation}")
        
        result = await self.client.generate_content(
@@ -187,33 +194,49 @@ class ProviderGoogleGenAI(Provider):
            **model_config
        }
        llm_response = None
-        try:
-            llm_response = await self._query(payloads, func_tool)
-        except Exception as e:
-            if "maximum context length" in str(e):
-                retry_cnt = 20
-                while retry_cnt > 0:
-                    logger.warning(f"请求失败：{e}。上下文长度超过限制。尝试弹出最早的记录然后重试。当前记录条数: {len(context_query)}")
-                    try:
-                        await self.pop_record(context_query)
-                        llm_response = await self._query(payloads, func_tool)
-                        break
-                    except Exception as e:
-                        if "maximum context length" in str(e):
-                            retry_cnt -= 1
-                        else:
-                            raise e
-                if retry_cnt == 0:
-                    llm_response = LLMResponse("err", "err: 请尝试  /reset 重置会话")
-            elif "Function calling is not enabled" in str(e):
-                logger.info(f"{self.get_model()} 不支持函数工具调用，已自动去除，不影响使用。")
-                if 'tools' in payloads:
-                    del payloads['tools']
-                llm_response = await self._query(payloads, None)
-            else:
-                logger.error(f"发生了错误(gemini_source)。Provider 配置如下: {self.provider_config}")
-                
-                raise e
+        
+        retry = 10
+        keys = self.api_keys.copy()
+        chosen_key = random.choice(keys)
+        
+        for i in range(retry):
+            try:
+                self.client.api_key = chosen_key 
+                llm_response = await self._query(payloads, func_tool)
+                break
+            except Exception as e:
+                if "maximum context length" in str(e):
+                    retry_cnt = 20
+                    while retry_cnt > 0:
+                        logger.warning(f"请求失败：{e}。上下文长度超过限制。尝试弹出最早的记录然后重试。当前记录条数: {len(context_query)}")
+                        try:
+                            await self.pop_record(context_query)
+                            llm_response = await self._query(payloads, func_tool)
+                            break
+                        except Exception as e:
+                            if "maximum context length" in str(e):
+                                retry_cnt -= 1
+                            else:
+                                raise e
+                    if retry_cnt == 0:
+                        llm_response = LLMResponse("err", "err: 请尝试  /reset 重置会话")
+                elif "Function calling is not enabled" in str(e):
+                    logger.info(f"{self.get_model()} 不支持函数工具调用，已自动去除，不影响使用。")
+                    if 'tools' in payloads:
+                        del payloads['tools']
+                    llm_response = await self._query(payloads, None)
+                elif "429" in str(e) or "API key not valid" in str(e):
+                    keys.remove(chosen_key)
+                    if len(keys) > 0:
+                        chosen_key = random.choice(keys)
+                        logger.info(f"检测到 Key 异常({str(e)})，正在尝试更换 API Key 重试... 当前 Key: {chosen_key[:12]}...")
+                        continue
+                    else:
+                        logger.error(f"A检测到 Key 异常({str(e)})，且已没有可用的 Key。 当前 Key: {chosen_key[:12]}...")
+                        raise Exception("API 资源已耗尽，且没有可用的 Key 重试...")
+                else:
+                    logger.error(f"发生了错误(gemini_source)。Provider 配置如下: {self.provider_config}")
+                    raise e

        return llm_response

--- a/astrbot/core/provider/sources/openai_source.py
+++ b/astrbot/core/provider/sources/openai_source.py
@@ -55,7 +55,7 @@ class ProviderOpenAIOfficial(Provider):
        try:
            models_str = []
            models = await self.client.models.list()
-            models = models.data
+            models = sorted(models.data, key=lambda x: x.id)
            for model in models:
                models_str.append(model.id)
            return models_str
--- a/astrbot/core/star/filter/command.py
+++ b/astrbot/core/star/filter/command.py
@@ -1,19 +1,23 @@

 import re
 import inspect
+from typing import List, Any, Type, Dict
 from . import HandlerFilter
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.config import AstrBotConfig
-from astrbot.core.utils.param_validation_mixin import ParameterValidationMixin
+from .custom_filter import CustomFilter
 from ..star_handler import StarHandlerMetadata

 # 标准指令受到 wake_prefix 的制约。
-class CommandFilter(HandlerFilter, ParameterValidationMixin):
+class CommandFilter(HandlerFilter):
    '''标准指令过滤器'''
-    def __init__(self, command_name: str, handler_md: StarHandlerMetadata = None):
+    def __init__(self, command_name: str, alias: set = None, handler_md: StarHandlerMetadata = None, parent_command_names: List[str] = [""]):
        self.command_name = command_name
+        self.alias = alias if alias else set()
+        self.parent_command_names = parent_command_names
        if handler_md:
            self.init_handler_md(handler_md)
+        self.custom_filter_list: List[CustomFilter] = []
            
    def print_types(self):
        result = ""
@@ -22,6 +26,7 @@ class CommandFilter(HandlerFilter, ParameterValidationMixin):
                result += f"{k}({v.__name__}),"
            else:
                result += f"{k}({type(v).__name__})={v},"
+        result = result.rstrip(",")
        return result
                
    def init_handler_md(self, handle_md: StarHandlerMetadata):
@@ -42,30 +47,79 @@ class CommandFilter(HandlerFilter, ParameterValidationMixin):
    def get_handler_md(self) -> StarHandlerMetadata:
        return self.handler_md

+    def add_custom_filter(self, custom_filter: CustomFilter):
+        self.custom_filter_list.append(custom_filter)
+
+    def custom_filter_ok(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
+        for custom_filter in self.custom_filter_list:
+            if not custom_filter.filter(event, cfg):
+                return False
+        return True
+    
+    def validate_and_convert_params(self, params: List[Any], param_type: Dict[str, Type]) -> Dict[str, Any]:
+        '''将参数列表 params 根据 param_type 转换为参数字典。
+        '''
+        result = {}
+        for i, (param_name, param_type_or_default_val) in enumerate(param_type.items()):
+            if i >= len(params):
+                if isinstance(param_type_or_default_val, Type) or param_type_or_default_val is inspect.Parameter.empty:
+                    # 是类型
+                    raise ValueError(f"必要参数缺失。该指令完整参数: {self.print_types()}")
+                else:
+                    # 是默认值
+                    result[param_name] = param_type_or_default_val
+            else:
+                # 尝试强制转换
+                try:
+                    if param_type_or_default_val is None:
+                        if params[i].isdigit():
+                            result[param_name] = int(params[i])
+                        else:
+                            result[param_name] = params[i]
+                    elif isinstance(param_type_or_default_val, str):
+                        # 如果 param_type_or_default_val 是字符串，直接赋值
+                        result[param_name] = params[i]
+                    elif isinstance(param_type_or_default_val, int):
+                        result[param_name] = int(params[i])
+                    elif isinstance(param_type_or_default_val, float):
+                        result[param_name] = float(params[i])
+                    else:
+                        result[param_name] = param_type_or_default_val(params[i])
+                except ValueError:
+                    raise ValueError(f"参数 {param_name} 类型错误。完整参数: {self.print_types()}")
+        return result
+
    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
        if not event.is_at_or_wake_command:
            return False
-        
-        if event.get_extra("parsing_command"):
-            message_str = event.get_extra("parsing_command").strip()
-        else:
-            message_str = event.get_message_str().strip()
-            
-        # 分割为列表（每个参数之间可能会有多个空格）
-        ls = re.split(r"\s+", message_str)
-        if self.command_name != ls[0]:
+
+        if not self.custom_filter_ok(event, cfg):
            return False
-        # if len(self.handler_params) == 0 and len(ls) > 1:
-        #     # 一定程度避免 LLM 聊天时误判为指令
-        #     return False
-        # params_str = message_str[len(self.command_name):].strip()
-        ls = ls[1:]
+        
+        # 检查是否以指令开头
+        message_str = re.sub(r"\s+", " ", event.get_message_str().strip())
+        candidates = [self.command_name] + list(self.alias)
+        ok = False
+        for candidate in candidates:
+            for parent_command_name in self.parent_command_names:
+                if parent_command_name:
+                    _full = f"{parent_command_name} {candidate}"
+                else:
+                    _full = candidate
+                if message_str.startswith(f"{_full} ") or message_str == _full:
+                    message_str = message_str[len(_full):].strip()
+                    ok = True
+                    break
+        if not ok:
+            return False
+
+        # 分割为列表
+        ls = message_str.split(" ")
        # 去除空字符串
        ls = [param for param in ls if param]
        params = {}
        try:
            params = self.validate_and_convert_params(ls, self.handler_params)
-            
        except ValueError as e:
            raise e
        
--- a/astrbot/core/star/filter/command_group.py
+++ b/astrbot/core/star/filter/command_group.py
@@ -6,72 +6,97 @@ from . import HandlerFilter
 from .command import CommandFilter
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.config import AstrBotConfig
+from .custom_filter import CustomFilter
 from ..star_handler import StarHandlerMetadata

 # 指令组受到 wake_prefix 的制约。
 class CommandGroupFilter(HandlerFilter):
-    def __init__(self, group_name: str):
+    def __init__(self, group_name: str, alias: set = None, parent_group: CommandGroupFilter = None):
        self.group_name = group_name
+        self.alias = alias if alias else set()
        self.sub_command_filters: List[Union[CommandFilter, CommandGroupFilter]] = []
+        self.custom_filter_list: List[CustomFilter] = []
+        self.parent_group = parent_group
    
    def add_sub_command_filter(self, sub_command_filter: Union[CommandFilter, CommandGroupFilter]):
        self.sub_command_filters.append(sub_command_filter)
-    
+
+    def add_custom_filter(self, custom_filter: CustomFilter):
+        self.custom_filter_list.append(custom_filter)
+
+    def get_complete_command_names(self) -> List[str]:
+        '''遍历父节点获取完整的指令名。
+        
+        新版本 v3.4.29 采用预编译指令，不再从指令组递归遍历子指令，因此这个方法是返回包括别名在内的整个指令名列表。'''
+        parent_cmd_names = self.parent_group.get_complete_command_names() if self.parent_group else []
+        
+        if not parent_cmd_names:
+            # 根节点
+            return [self.group_name] + list(self.alias)
+        
+        result = []
+        candidates = [self.group_name] + list(self.alias)
+        for parent_cmd_name in parent_cmd_names:
+            for candidate in candidates:
+                result.append(parent_cmd_name + " " + candidate)
+        return result
+        
+
    # 以树的形式打印出来
-    def print_cmd_tree(self, sub_command_filters: List[Union[CommandFilter, CommandGroupFilter]], prefix: str = "") -> str:
+    def print_cmd_tree(self,
+        sub_command_filters: List[Union[CommandFilter, CommandGroupFilter]],
+        prefix: str = "",
+        event: AstrMessageEvent = None,
+        cfg: AstrBotConfig = None,
+    ) -> str:
        result = ""
        for sub_filter in sub_command_filters:
            if isinstance(sub_filter, CommandFilter):
-                cmd_th = sub_filter.print_types()
-                result += f"{prefix}├── {sub_filter.command_name}"
-                if cmd_th:
-                    result += f" ({cmd_th})"
-                else:
-                    result += " (无参数指令)"
-                
-                result += "\n"
+                custom_filter_pass = True
+                if event and cfg:
+                    custom_filter_pass = sub_filter.custom_filter_ok(event, cfg)
+                if custom_filter_pass:
+                    cmd_th = sub_filter.print_types()
+                    result += f"{prefix}├── {sub_filter.command_name}"
+                    if cmd_th:
+                        result += f" ({cmd_th})"
+                    else:
+                        result += " (无参数指令)"
+                    
+                    if sub_filter.handler_md and sub_filter.handler_md.desc:
+                        result += f": {sub_filter.handler_md.desc}"
+
+                    result += "\n"
            elif isinstance(sub_filter, CommandGroupFilter):
-                result += f"{prefix}├── {sub_filter.group_name}"
-                result += "\n"
-                result += sub_filter.print_cmd_tree(sub_filter.sub_command_filters, prefix+"│   ")
+                custom_filter_pass = True
+                if event and cfg:
+                    custom_filter_pass = sub_filter.custom_filter_ok(event, cfg)
+                if custom_filter_pass:
+                    result += f"{prefix}├── {sub_filter.group_name}"
+                    result += "\n"
+                    result += sub_filter.print_cmd_tree(sub_filter.sub_command_filters, prefix+"│   ", event=event, cfg=cfg)
+
        return result
-        
-    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> Tuple[bool, StarHandlerMetadata]:
+
+    def custom_filter_ok(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
+        for custom_filter in self.custom_filter_list:
+            if not custom_filter.filter(event, cfg):
+                return False
+        return True
+
+    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
        if not event.is_at_or_wake_command:
-            return False, None
-        
-        if event.get_extra("parsing_command"):
-            message_str = event.get_extra("parsing_command").strip()
-        else:
-            message_str = event.get_message_str().strip()
-        
-        ls = re.split(r"\s+", message_str)
-        
-        if ls[0] != self.group_name:
-            return False, None
-        # 改写 message_str
-        ls = ls[1:]
-        # event.message_str = " ".join(ls)
-        # event.message_str = event.message_str.strip()
-        parsing_command = " ".join(ls)
-        parsing_command = parsing_command.strip()
-        event.set_extra("parsing_command", parsing_command)
-        
-        if parsing_command == "":
-            # 当前还是指令组
-            tree = self.group_name + "\n" + self.print_cmd_tree(self.sub_command_filters)
+            return False
+
+        # 判断当前指令组的自定义过滤器
+        if not self.custom_filter_ok(event, cfg):
+            return False
+
+        complete_command_names = self.get_complete_command_names()
+        if event.message_str.strip() in complete_command_names:
+            tree = self.group_name + "\n" + self.print_cmd_tree(self.sub_command_filters, event=event, cfg=cfg)
            raise ValueError(f"指令组 {self.group_name} 未填写完全。这个指令组下有如下指令：\n"+tree)
        
-        child_command_handler_md = None
-        for sub_filter in self.sub_command_filters:
-            if isinstance(sub_filter, CommandFilter):
-                if sub_filter.filter(event, cfg):
-                    child_command_handler_md = sub_filter.get_handler_md()
-                    return True, child_command_handler_md
-            elif isinstance(sub_filter, CommandGroupFilter):
-                ok, handler = sub_filter.filter(event, cfg)
-                if ok:
-                    child_command_handler_md = handler
-                    return True, child_command_handler_md
-        tree = self.group_name + "\n" + self.print_cmd_tree(self.sub_command_filters)
-        raise ValueError(f"指令组 {self.group_name} 下没有找到对应的指令。这个指令组下有如下指令：\n"+tree)
+        # complete_command_names = [name + " " for name in complete_command_names]
+        # return event.message_str.startswith(tuple(complete_command_names))
+        return False
--- a/astrbot/core/star/filter/custom_filter.py
+++ b/astrbot/core/star/filter/custom_filter.py
@@ -0,0 +1,53 @@
+from abc import abstractmethod, ABCMeta
+
+from . import HandlerFilter
+from astrbot.core.platform.astr_message_event import AstrMessageEvent
+from astrbot.core.config import AstrBotConfig
+
+class CustomFilterMeta(ABCMeta):
+    def __and__(cls, other):
+        if not issubclass(other, CustomFilter):
+            raise TypeError("Operands must be subclasses of CustomFilter.")
+        return CustomFilterAnd(cls(), other())
+
+    def __or__(cls, other):
+        if not issubclass(other, CustomFilter):
+            raise TypeError("Operands must be subclasses of CustomFilter.")
+        return CustomFilterOr(cls(), other())
+
+class CustomFilter(HandlerFilter, metaclass=CustomFilterMeta):
+    def __init__(self,  raise_error: bool = True, **kwargs):
+        self.raise_error = raise_error
+
+    @abstractmethod
+    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
+        ''' 一个用于重写的自定义Filter '''
+        raise NotImplementedError
+
+    def __or__(self, other):
+        return CustomFilterOr(self, other)
+
+    def __and__(self, other):
+        return CustomFilterAnd(self, other)
+
+class CustomFilterOr(CustomFilter):
+    def __init__(self, filter1: CustomFilter, filter2: CustomFilter):
+        super().__init__()
+        if not isinstance(filter1, (CustomFilter, CustomFilterAnd, CustomFilterOr)):
+            raise ValueError("CustomFilter lass can only operate with other CustomFilter.")
+        self.filter1 = filter1
+        self.filter2 = filter2
+
+    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
+        return self.filter1.filter(event, cfg) or self.filter2.filter(event, cfg)
+
+class CustomFilterAnd(CustomFilter):
+    def __init__(self, filter1: CustomFilter, filter2: CustomFilter):
+        super().__init__()
+        if not isinstance(filter1, (CustomFilter, CustomFilterAnd, CustomFilterOr)):
+            raise ValueError("CustomFilter lass can only operate with other CustomFilter.")
+        self.filter1 = filter1
+        self.filter2 = filter2
+
+    def filter(self, event: AstrMessageEvent, cfg: AstrBotConfig) -> bool:
+        return self.filter1.filter(event, cfg) and self.filter2.filter(event, cfg)
--- a/astrbot/core/star/register/init.py
+++ b/astrbot/core/star/register/init.py
@@ -6,6 +6,7 @@ from .star_handler import (
    register_platform_adapter_type,
    register_regex,
    register_permission_type,
+    register_custom_filter,
    register_on_llm_request,
    register_on_llm_response,
    register_llm_tool,
@@ -21,6 +22,7 @@ __all__ = [
    'register_platform_adapter_type',
    'register_regex',
    'register_permission_type',
+    'register_custom_filter',
    'register_on_llm_request',
    'register_on_llm_response',
    'register_llm_tool',
--- a/astrbot/core/star/register/star_handler.py
+++ b/astrbot/core/star/register/star_handler.py
@@ -7,6 +7,7 @@ from ..filter.command_group import CommandGroupFilter
 from ..filter.event_message_type import EventMessageTypeFilter, EventMessageType
 from ..filter.platform_adapter_type import PlatformAdapterTypeFilter, PlatformAdapterType
 from ..filter.permission import PermissionTypeFilter, PermissionType
+from ..filter.custom_filter import CustomFilterAnd, CustomFilterOr
 from ..filter.regex import RegexFilter
 from typing import Awaitable
 from astrbot.core.provider.func_tool_manager import SUPPORTED_TYPES
@@ -50,21 +51,20 @@ def get_handler_or_create(
            star_handlers_registry.append(md)
        return md

-def register_command(command_name: str = None, *args, **kwargs):
+def register_command(command_name: str = None, sub_command: str = None, alias: set = None, **kwargs):
    '''注册一个 Command.
    '''
-    
-    # print("command: ", command_name, args, kwargs)
-    
    new_command = None
    add_to_event_filters = False
    if isinstance(command_name, RegisteringCommandable):
        # 子指令
-        new_command = CommandFilter(args[0], None)
+        parent_command_names = command_name.parent_group.get_complete_command_names()
+        logger.debug(f"parent_command_names: {parent_command_names}")
+        new_command = CommandFilter(sub_command, alias, None, parent_command_names=parent_command_names)
        command_name.parent_group.add_sub_command_filter(new_command)
    else:
        # 裸指令
-        new_command = CommandFilter(command_name, None)
+        new_command = CommandFilter(command_name, alias, None)
        add_to_event_filters = True
    
    def decorator(awaitable):
@@ -72,46 +72,96 @@ def register_command(command_name: str = None, *args, **kwargs):
            kwargs['sub_command'] = True # 打一个标记，表示这是一个子指令，再 wakingstage 阶段这个 handler 将会直接被跳过（其父指令会接管）
        handler_md = get_handler_or_create(awaitable, EventType.AdapterMessageEvent, **kwargs)
        new_command.init_handler_md(handler_md)
-        if add_to_event_filters:
-            # 裸指令
-            handler_md.event_filters.append(new_command)
-             
+        handler_md.event_filters.append(new_command)
        return awaitable

    return decorator

-def register_command_group(command_group_name: str = None, *args, **kwargs):
+
+def register_custom_filter(custom_type_filter, *args, **kwargs):
+    '''注册一个自定义的 CustomFilter
+
+    Args:
+        custom_type_filter: 在裸指令时为CustomFilter对象
+                                        在指令组时为父指令的RegisteringCommandable对象，即self或者command_group的返回
+        raise_error: 如果没有权限，是否抛出错误到消息平台，并且停止事件传播。默认为 True
+    '''
+    add_to_event_filters = False
+    raise_error = True
+
+    # 判断是否是指令组，指令组则添加到指令组的CommandGroupFilter对象中在waking_check的时候一起判断
+    if isinstance(custom_type_filter, RegisteringCommandable):
+        # 子指令, 此时函数为RegisteringCommandable对象的方法，首位参数为RegisteringCommandable对象的self。
+        parent_register_commandable = custom_type_filter
+        custom_filter = args[0]
+        if len(args) > 1:
+            raise_error = args[1]
+    else:
+        # 裸指令
+        add_to_event_filters = True
+        custom_filter = custom_type_filter
+        if args:
+            raise_error = args[0]
+
+    if not isinstance(custom_filter, (CustomFilterAnd, CustomFilterOr)):
+        custom_filter = custom_filter(raise_error)
+
+    def decorator(awaitable):
+        # 裸指令，子指令与指令组的区分，指令组会因为标记跳过wake。
+        if not add_to_event_filters and isinstance(awaitable, RegisteringCommandable) or \
+            (add_to_event_filters and isinstance(awaitable, RegisteringCommandable)):
+            # 指令组 与 根指令组，添加到本层的grouphandle中一起判断
+            awaitable.parent_group.add_custom_filter(custom_filter)
+        else:
+            handler_md = get_handler_or_create(awaitable, EventType.AdapterMessageEvent, **kwargs)
+
+            if not add_to_event_filters and not isinstance(awaitable, RegisteringCommandable):
+                # 底层子指令
+                handle_full_name = get_handler_full_name(awaitable)
+                for sub_handle in parent_register_commandable.parent_group.sub_command_filters:
+                    # 所有符合fullname一致的子指令handle添加自定义过滤器。
+                    # 不确定是否会有多个子指令有一样的fullname，比如一个方法添加多个command装饰器？
+                    sub_handle_md = sub_handle.get_handler_md()
+                    if sub_handle_md and sub_handle_md.handler_full_name == handle_full_name:
+                        sub_handle.add_custom_filter(custom_filter)
+
+            else:
+                # 裸指令
+                handler_md = get_handler_or_create(awaitable, EventType.AdapterMessageEvent, **kwargs)
+                handler_md.event_filters.append(custom_filter)
+
+        return awaitable
+    return decorator
+
+def register_command_group(
+    command_group_name: str = None, sub_command: str = None, alias: set = None, **kwargs
+):
    '''注册一个 CommandGroup
    '''
-    
-    # print("commandgroup: ", command_group_name,args,  kwargs)
-    
    new_group = None
-    add_to_event_filters = False
    if isinstance(command_group_name, RegisteringCommandable):
        # 子指令组
-        new_group = CommandGroupFilter(args[0])
+        new_group = CommandGroupFilter(sub_command, alias, parent_group=command_group_name.parent_group)
        command_group_name.parent_group.add_sub_command_filter(new_group)
    else:
        # 根指令组
-        new_group = CommandGroupFilter(command_group_name)
-        add_to_event_filters = True
+        new_group = CommandGroupFilter(command_group_name, alias)
    
    def decorator(obj):
-        if add_to_event_filters:
-            # 根指令组
-            handler_md = get_handler_or_create(obj, EventType.AdapterMessageEvent, **kwargs)
-            handler_md.event_filters.append(new_group)
-        
+        # 根指令组
+        handler_md = get_handler_or_create(obj, EventType.AdapterMessageEvent, **kwargs)
+        handler_md.event_filters.append(new_group)
+            
        return RegisteringCommandable(new_group)

    return decorator

 class RegisteringCommandable():
    '''用于指令组级联注册'''
-    group = register_command_group
-    command = register_command
-    
+    group: CommandGroupFilter = register_command_group
+    command: CommandFilter = register_command
+    custom_filter = register_custom_filter
+
    def __init__(self, parent_group: CommandGroupFilter):
        self.parent_group = parent_group

--- a/astrbot/core/utils/param_validation_mixin.py
+++ b/astrbot/core/utils/param_validation_mixin.py
@@ -1,36 +0,0 @@
-import inspect
-from typing import List, Dict, Any, Type
-
-class ParameterValidationMixin:
-    def validate_and_convert_params(self, params: List[Any], param_type: Dict[str, Type]) -> Dict[str, Any]:
-        '''将参数列表 params 根据 param_type 转换为参数字典。
-        '''
-        result = {}
-        for i, (param_name, param_type_or_default_val) in enumerate(param_type.items()):
-            if i >= len(params):
-                if isinstance(param_type_or_default_val, Type) or param_type_or_default_val is inspect.Parameter.empty:
-                    # 是类型
-                    raise ValueError(f"参数 {param_name} 缺失")
-                else:
-                    # 是默认值
-                    result[param_name] = param_type_or_default_val
-            else:
-                # 尝试强制转换
-                try:
-                    if param_type_or_default_val is None:
-                        if params[i].isdigit():
-                            result[param_name] = int(params[i])
-                        else:
-                            result[param_name] = params[i]
-                    elif isinstance(param_type_or_default_val, str):
-                        # 如果 param_type_or_default_val 是字符串，直接赋值
-                        result[param_name] = params[i]
-                    elif isinstance(param_type_or_default_val, int):
-                        result[param_name] = int(params[i])
-                    elif isinstance(param_type_or_default_val, float):
-                        result[param_name] = float(params[i])
-                    else:
-                        result[param_name] = param_type_or_default_val(params[i])
-                except ValueError:
-                    raise ValueError(f"参数 {param_name} 类型错误")
-        return result
--- a/astrbot/core/utils/t2i/renderer.py
+++ b/astrbot/core/utils/t2i/renderer.py
@@ -22,7 +22,7 @@ class HtmlRenderer:

        @return: 图片 URL 或者文件路径，取决于 return_url 参数。

-        @example: 参见 https://astrbot.soulter.top 插件开发部分。
+        @example: 参见 https://astrbot.app 插件开发部分。
        '''
        local = locals()
        local.pop('self')
--- a/astrbot/dashboard/routes/config.py
+++ b/astrbot/dashboard/routes/config.py
@@ -1,3 +1,4 @@
+import typing
 from .route import Route, Response, RouteContext
 from quart import request
 from astrbot.core.config.default import CONFIG_METADATA_2, DEFAULT_VALUE_MAP
@@ -17,7 +18,7 @@ def try_cast(value: str, type_: str):
    elif type_ == "float" and isinstance(value, int):
        return float(value)

-def validate_config(data, schema: dict, is_core: bool):
+def validate_config(data, schema: dict, is_core: bool) -> typing.Tuple[typing.List[str], typing.Dict]:
    errors = []
    def validate(data, metadata=schema, path=""):
        for key, meta in metadata.items():
@@ -65,16 +66,16 @@ def validate_config(data, schema: dict, is_core: bool):
    else:
        validate(data, schema)
    
-    return errors
+    return errors, data

 def save_config(post_config: dict, config: AstrBotConfig, is_core: bool = False):
    '''验证并保存配置'''
    errors = None
    try:
        if is_core:
-            errors = validate_config(post_config, CONFIG_METADATA_2, is_core)
+            errors, post_config = validate_config(post_config, CONFIG_METADATA_2, is_core)
        else:
-            errors = validate_config(post_config, config.schema, is_core)
+            errors, post_config = validate_config(post_config, config.schema, is_core)
    except BaseException as e:
        logger.warning(f"验证配置时出现异常: {e}")
    if errors:
--- a/astrbot/dashboard/routes/plugin.py
+++ b/astrbot/dashboard/routes/plugin.py
@@ -113,11 +113,17 @@ class PluginRoute(Route):
                for filter in handler.event_filters: # 正常handler就只有 1~2 个 filter，因此这里时间复杂度不会太高
                    if isinstance(filter, CommandFilter):
                        info["type"] = "指令"
-                        info["cmd"] = filter.command_name
+                        info["cmd"] = f"{filter.parent_command_names[0]} {filter.command_name}"
+                        info["cmd"] = info["cmd"].strip()
+                        if self.core_lifecycle.astrbot_config['wake_prefix'] and len(self.core_lifecycle.astrbot_config['wake_prefix']) > 0:
+                            info["cmd"] = f"{self.core_lifecycle.astrbot_config['wake_prefix'][0]}{info['cmd']}"
                    elif isinstance(filter, CommandGroupFilter):
                        info["type"] = "指令组"
-                        info["cmd"] = filter.group_name
+                        info["cmd"] = filter.get_complete_command_names()[0]
+                        info["cmd"] = info["cmd"].strip()
                        info["sub_command"] = filter.print_cmd_tree(filter.sub_command_filters)
+                        if self.core_lifecycle.astrbot_config['wake_prefix'] and len(self.core_lifecycle.astrbot_config['wake_prefix']) > 0:
+                            info["cmd"] = f"{self.core_lifecycle.astrbot_config['wake_prefix'][0]}{info['cmd']}"
                    elif isinstance(filter, RegexFilter):
                        info["type"] = "正则匹配"
                        info["cmd"] = filter.regex_str
--- a/changelogs/v3.4.27.md
+++ b/changelogs/v3.4.27.md
@@ -0,0 +1,14 @@
+# What's Changed
+
+1. ✨ 新增: 支持日语版本的 Readme by @eltociear
+2. ✨ 新增: 主动回复支持白名单 #488
+3. ⚡ 优化: 面板数据展示图表的时区问题 #460
+4. ⚡ 优化: 针对 id 对模型号进行排序以适配 OneAPI 乱序情况 #384
+5. ✨ 新增: 支持对大模型的响应进行内容审查 #474
+6. 🐛 修复: 修复保存插件配置时没有检查类型合法性的问题
+7. 🐛 修复: 尝试修复 Gemini empty text 相关报错
+8. 🐛 修复: dify 不能正常使用 set/unset 指令定义动态变量 #482
+9. 🐛 修复: 不能在 Webhook 模式下的 QQ 官方 API 私聊 #484
+10. 🐛 修复: 在没有触发并且没通过安全审查的情况下仍然发送了未通过消息
+11. 🐛 修复: /del 指令导致的相关异常
+12. 🐛 修复: 在 Gewechat 中不能先写内容后 @ 机器人 #492
--- a/changelogs/v3.4.28.md
+++ b/changelogs/v3.4.28.md
@@ -0,0 +1,12 @@
+# What's Changed
+
+1. ✨ 新增: 管理面板支持搜索插件
+2. ✨ 新增: 支持传递 OneBot 的 notice, request 事件类型，如戳一戳，进退群请求等
+3. ✨ 新增: 插件支持自定义过滤算子 by @AraragiEro
+4. ✨ 新增: 添加命令和命令组的别名支持 by @Cvandia
+4. ✨ 新增: 提供了一个方法以删除分段回复后的某些字符，如末尾的标点符号。 by @Soulter and @Nothingness-Void
+5. ⚡ 优化: 优化了分段回复和回复时at,引用都打开时的一些体验性问题
+7. 🐛 修复: 分段回复导致了不完全的非 LLM 输出 #503
+8. 🐛 修复: 添加 no_proxy 环境变量以支持本地请求, 修复在代理状态下时的 502 错误当通过 LMStudio, Ollama 本地部署 LLM 时 #504 #514
+9. 💡🐛 修复: 修复转发消息的字数阈值功能 #510
+10. 💡🐛 修复: 修复 Dify 下无法主动回复的问题 #494
--- a/changelogs/v3.4.29.md
+++ b/changelogs/v3.4.29.md
@@ -0,0 +1,14 @@
+# What's Changed
+
+1. ✨ 新增: gemini source 初步支持对 API Key 进行负载均衡请求 #534
+2. ✨ 新增: 开启对话隔离的群聊以及私聊下，非 op 可以可以使用 /del 和 /reset #519
+3. ✨ 新增: 事件钩子支持 yield 方式发送消息
+4. ⚡ 优化: 查询模型列表时，可以显示当前使用的模型名称 #523
+5. ⚡ 优化: 更换为预编译指令的方式处理指令组指令
+6. 🐛 修复: resolve KeyError when current conversation is not in paginated list
+7. 🐛 修复: 修复指令组的情况下，Permission Filter 对子指令失效的问题
+8.  🐛 修复: 🐛 fix: 修复 reminder rm失败 #529
+9.  🐛 修复: 🐛 fix: reminder 时区问题 #529
+10. 🐛 修复: 修复 Dify 下无法主动回复的问题 #494
+11. 🐛 修复: 添加代码执行器 Docker 宿主机绝对路径配置及相关功能以修复 Docker 下无法使用代码执行器的问题 #525
+12. 🐛 修复: gewechat 微信群聊情况下可能导致 unknown 的问题 #537
--- a/changelogs/v3.4.30.md
+++ b/changelogs/v3.4.30.md
@@ -0,0 +1,5 @@
+# What's Changed
+
+1. ‼️🐛 修复: 修复某些情况下导致插件报错 AttributeError 的问题 #549
+2. ✨ 新增: add xAI template
+3.  🐛 修复: 修复 dify 无法使用事件钩子的问题以及出现 GeneratorExit 的问题 #533 #264
--- a/dashboard/src/components/shared/ExtensionCard.vue
+++ b/dashboard/src/components/shared/ExtensionCard.vue
@@ -4,6 +4,7 @@ const props = defineProps({
  link: String,
  logo: String,
  has_update: Boolean,
+  activated: Boolean,
 });

 const open = (link: string | undefined) => {
@@ -16,8 +17,9 @@ const open = (link: string | undefined) => {
    <v-card-item style="padding: 10px 12px">
      <div class="d-sm-flex align-center justify-space-between">
        <img v-if="logo" :src="logo" alt="logo" style="width: 40px; height: 40px; margin-right: 8px;">
-        <v-card-title style="font-size: 16px;">{{ props.title }}</v-card-title>
+        <v-card-title style="font-size: 15px; max-width: 70%">{{ props.title }}</v-card-title>
        <v-spacer></v-spacer>
+        <v-icon color="success" v-if="!activated">mdi-cancel</v-icon>
        <v-icon color="success" v-if="has_update">mdi-arrow-up-bold</v-icon>
        <v-btn size="small" text="Read" variant="flat" border  @click="open(props.link)">帮助</v-btn>
      </div>
--- a/dashboard/src/layouts/full/vertical-sidebar/VerticalSidebar.vue
+++ b/dashboard/src/layouts/full/vertical-sidebar/VerticalSidebar.vue
@@ -21,7 +21,7 @@ const sidebarMenu = shallowRef(sidebarItems);
    </div>

    <div style="position: absolute; bottom: 32px; width: 100%" class="text-center">
-      <v-list-item v-if="!customizer.mini_sidebar" href="https://astrbot.soulter.top/">
+      <v-list-item v-if="!customizer.mini_sidebar" href="https://astrbot.app/">
        <v-btn variant="plain" size="small">
          🤔 初次使用？点击查看文档！
        </v-btn>
--- a/dashboard/src/views/ConfigPage.vue
+++ b/dashboard/src/views/ConfigPage.vue
@@ -91,7 +91,7 @@ import config from '@/config';

      <div style="margin-left: 16px; padding-bottom: 16px">
        <small>不了解配置？请见 <a
-            href="https://astrbot.soulter.top/">官方文档</a>
+            href="https://astrbot.app/">官方文档</a>
          或 <a
            href="https://qm.qq.com/cgi-bin/qm/qr?k=EYGsuUTfe00_iOu9JTXS7_TEpMkXOvwv&jump_from=webapi&authKey=uUEMKCROfsseS+8IzqPjzV3y1tzy4AkykwTib2jNkOFdzezF9s9XknqnIaf3CDft">加群询问</a>。</small>
      </div>
--- a/dashboard/src/views/ExtensionPage.vue
+++ b/dashboard/src/views/ExtensionPage.vue
@@ -10,8 +10,8 @@ import { max } from 'date-fns';

 <template>
  <v-row>
-    <v-alert style="margin: 16px" text="1. 如果因为网络问题安装失败，点击设置页选择 GitHub 加速地址。或前往仓库下载压缩包然后本地上传。" title="💡提示"
-      type="info" color="primary" variant="tonal">
+    <v-alert style="margin: 16px" text="1. 如果因为网络问题安装失败，点击设置页选择 GitHub 加速地址。或前往仓库下载压缩包然后本地上传。" title="💡提示" type="info"
+      color="primary" variant="tonal">
    </v-alert>
    <v-col cols="12" md="12">
      <div style="background-color: white; width: 100%; padding: 16px; border-radius: 10px;">
@@ -44,14 +44,14 @@ import { max } from 'date-fns';
          </v-dialog>
        </div>
      </div>
-    </v-col>  
+    </v-col>
    <v-col cols="12" md="6" lg="3" v-for="extension in extension_data.data">
      <ExtensionCard :key="extension.name" :title="extension.name" :link="extension.repo" :logo="extension?.logo"
-        :has_update="extension.has_update" style="margin-bottom: 4px;">
+        :has_update="extension.has_update" style="margin-bottom: 4px;" :activated="extension.activated">
        <div style="min-height: 140px; max-height: 140px; overflow: auto;">
          <div>
            <span style="font-weight: bold  ;">By @{{ extension.author }}</span>
-            <span> | 插件有 {{ extension.handlers.length }} 个行为</span>
+            <span> | {{ extension.handlers.length }} 个行为</span>
          </div>
          <span> 当前: <v-chip size="small" color="primary">{{ extension.version }}</v-chip>
            <span v-if="extension.online_version">
@@ -82,51 +82,88 @@ import { max } from 'date-fns';
        </div>
      </ExtensionCard>
    </v-col>
-    <v-col cols="12" md="12">
-      <div style="background-color: white; width: 100%; padding: 16px; border-radius: 10px;">
-        <div style="display: flex; align-items: center;">
-          <h3>🧩 插件市场</h3>
-          <small style="margin-left: 16px;">如无法显示，请打开 <a
-              href="https://soulter.github.io/AstrBot_Plugins_Collection/plugins.json">链接</a> 复制想安装插件对应的 `repo`
-            链接然后点击右下角 + 号安装，或打开链接下载压缩包安装。</small>
-          <v-btn icon @click="isListView = !isListView" size="small" style="margin-left: auto;" variant="plain">
-            <v-icon>{{ isListView ? 'mdi-view-grid' : 'mdi-view-list' }}</v-icon>
-          </v-btn>
-        </div>
-      </div>
-    </v-col>

    <v-col cols="12" md="12" v-if="announcement">
      <v-banner color="success" lines="one" :text="announcement" :stacked="false">
      </v-banner>
    </v-col>

-    <template v-if="isListView">
-      <v-col cols="12" md="12">
-        <v-data-table :headers="pluginMarketHeaders" :items="pluginMarketData" item-key="name">
-          <template v-slot:item.actions="{ item }">
-            <v-btn v-if="!item.installed" class="text-none mr-2" size="small" text="Read" variant="flat" border
-              @click="extension_url = item.repo; newExtension()">安装</v-btn>
-            <v-btn v-else class="text-none mr-2" size="small" text="Read" variant="flat" border disabled>已安装</v-btn>
-          </template>
-        </v-data-table>
-      </v-col>
-    </template>
-    <template v-else>
-      <v-col cols="12" md="6" lg="3" v-for="plugin in pluginMarketData">
-        <ExtensionCard :key="plugin.name" :title="plugin.name" :link="plugin.repo" style="margin-bottom: 4px;">
-          <div style="min-height: 130px; max-height: 130px; overflow: hidden;">
-            <p style="font-weight: bold;">By @{{ plugin.author }}</p>
-            {{ plugin.desc }}
-          </div>
-          <div class="d-flex align-center gap-2">
-            <v-btn v-if="!plugin.installed" class="text-none mr-2" size="small" text="Read" variant="flat" border
-              @click="extension_url = plugin.repo; newExtension()">安装</v-btn>
-            <v-btn v-else class="text-none mr-2" size="small" text="Read" variant="flat" border disabled>已安装</v-btn>
-          </div>
-        </ExtensionCard>
-      </v-col>
-    </template>
+    <v-col cols="12" md="12">
+      <v-card>
+        <v-card-title class="d-flex align-center pe-2">
+
+          🧩 插件市场
+
+          <v-btn icon size="small" style="margin-left: 8px" variant="plain">
+            <v-icon size="small">mdi-help</v-icon>
+            <v-tooltip activator="parent" location="start">
+              如无法显示，请打开 <a href="https://soulter.github.io/AstrBot_Plugins_Collection/plugins.json">链接</a> 复制想安装插件对应的
+              `repo`
+              链接然后点击右下角 + 号安装，或打开链接下载压缩包安装。
+            </v-tooltip>
+          </v-btn>
+
+          <v-btn icon @click="isListView = !isListView" size="small" style="margin-left: auto;" variant="plain">
+            <v-icon>{{ isListView ? 'mdi-view-grid' : 'mdi-view-list' }}</v-icon>
+          </v-btn>
+
+          <v-spacer></v-spacer>
+
+          <v-text-field v-model="marketSearch" density="compact" label="Search" prepend-inner-icon="mdi-magnify"
+            variant="solo-filled" flat hide-details single-line></v-text-field>
+        </v-card-title>
+
+        <v-divider></v-divider>
+
+        <template v-if="isListView">
+          <v-col cols="12" md="12">
+            <v-data-table :headers="pluginMarketHeaders" :items="pluginMarketData" item-key="name"
+              v-model:search="marketSearch" :filter-keys="['name']">
+              <template v-slot:item.name="{ item }">
+                <span v-if="item?.repo"><a :href="item?.repo" style="color: #000; text-decoration:none">{{ item.name }}</a></span>
+                <span v-else>{{ item.name}}</span>
+              </template>
+              <template v-slot:item.author="{ item }">
+                <span v-if="item?.social_link"><a :href="item?.social_link">{{ item.author}}</a></span>
+                <span v-else>{{ item.author}}</span>
+              </template>
+              <template v-slot:item.tags="{ item }">
+                <span v-if="item.tags.length === 0">无</span>
+                <v-chip v-for="tag in item.tags" :key="tag" color="primary" size="small">{{ tag }}</v-chip>
+              </template>
+              <template v-slot:item.actions="{ item }">
+                <v-btn v-if="!item.installed" class="text-none mr-2" size="small" text="Read" variant="flat" border
+                  @click="extension_url = item.repo; newExtension()">安装</v-btn>
+                <v-btn v-else class="text-none mr-2" size="small" text="Read" variant="flat" border disabled>已安装</v-btn>
+              </template>
+            </v-data-table>
+          </v-col>
+        </template>
+        <template v-else>
+          <v-row style="margin: 8px;">
+            <v-col cols="12" md="6" lg="3" v-for="plugin in pluginMarketData">
+              <ExtensionCard :key="plugin.name" :title="plugin.name" :link="plugin.repo" style="margin-bottom: 4px;">
+                <div style="min-height: 130px; max-height: 130px; overflow: hidden;">
+                  <p style="font-weight: bold;">By @{{ plugin.author }}</p>
+                  {{ plugin.desc }}
+                </div>
+
+                <div class="d-flex align-center gap-2">
+                  <v-btn v-if="!plugin.installed" class="text-none mr-2" size="small" text="Read" variant="flat"
+                    border @click="extension_url = plugin.repo; newExtension()">安装</v-btn>
+                  <v-btn v-else class="text-none mr-2" size="small" text="Read" variant="flat" border
+                    disabled>已安装</v-btn>
+                </div>
+              </ExtensionCard>
+            </v-col>
+          </v-row>
+
+        </template>
+
+      </v-card>
+
+    </v-col>
+

    <v-col style="margin-bottom: 16px;" cols="12" md="12">
      <small><a href="https://astrbot.app/dev/plugin.html">插件开发文档</a></small> |
@@ -314,7 +351,7 @@ export default {
        "config": {}
      },
      upload_file: null,
-      pluginMarketData: {},
+      pluginMarketData: [],
      loadingDialog: {
        show: false,
        title: "加载中...",
@@ -331,13 +368,15 @@ export default {
        { title: '具体类型', key: 'type' },
        { title: '触发方式', key: 'cmd' },
      ],
-      isListView: false,
+      isListView: true,
      pluginMarketHeaders: [
-        { title: '名称', value: 'name' },
-        { title: '描述', value: 'desc' },
-        { title: '作者', value: 'author' },
-        { title: '操作', value: 'actions', sortable: false }
+        { title: '名称', key: 'name', maxWidth: '150px' },
+        { title: '描述', key: 'desc', maxWidth: '250px' },
+        { title: '作者', key: 'author', maxWidth: '60px' },
+        { title: '标签', key: 'tags', maxWidth: '60px' },
+        { title: '操作', key: 'actions', sortable: false }
      ],
+      marketSearch: "",
      alreadyCheckUpdate: false
    }
  },
@@ -562,6 +601,8 @@ export default {
            "repo": res.data.data[key].repo,
            "installed": false,
            "version": res.data.data[key]?.version ? res.data.data[key].version : "未知",
+            "social_link": res.data.data[key]?.social_link,
+            "tags": res.data.data[key]?.tags ? res.data.data[key].tags : []
          })
        }
        this.pluginMarketData = data;
--- a/dashboard/src/views/dashboards/default/components/MessageStat.vue
+++ b/dashboard/src/views/dashboards/default/components/MessageStat.vue
@@ -72,6 +72,11 @@ export default {
        type: 'datetime',
        title: {
          text: '时间'
+        },
+        labels: {
+          formatter: function (value) {
+            return new Date(value).toLocaleString();
+          }
        }
      },
      yaxis: {
--- a/packages/astrbot/long_term_memory.py
+++ b/packages/astrbot/long_term_memory.py
@@ -32,6 +32,7 @@ class LongTermMemory:
        self.ar_method = self.active_reply["method"]
        self.ar_possibility = self.active_reply["possibility_reply"]
        self.ar_prompt = self.active_reply.get("prompt", "")
+        self.ar_whitelist = self.active_reply.get("whitelist", [])
        
        # self.put_history_to_prompt = self.config["put_history_to_prompt"]
        
@@ -67,6 +68,12 @@ class LongTermMemory:
        if event.is_at_or_wake_command:
            # if the message is a command, let it pass
            return False
+        
+        if self.ar_whitelist and (
+            event.unified_msg_origin not in self.ar_whitelist
+            and (event.get_group_id() and event.get_group_id() not in self.ar_whitelist)
+        ):
+            return False

        match self.ar_method:
            case "possibility_reply":
@@ -118,10 +125,6 @@ class LongTermMemory:
        else:
            req.system_prompt += "You are now in a chatroom. The chat history is as follows: \n"
            req.system_prompt += chats_str
-            if self.image_caption:
-                req.system_prompt += (
-                    "The images sent by the members are displayed in text form above."
-                )
            
    async def after_req_llm(self, event: AstrMessageEvent):
        if event.unified_msg_origin not in self.session_chats:
--- a/packages/astrbot/main.py
+++ b/packages/astrbot/main.py
@@ -6,8 +6,7 @@ import astrbot.api.star as star
 import astrbot.api.event.filter as filter
 from astrbot.api.event import AstrMessageEvent, MessageEventResult
 from astrbot.api import sp
-from astrbot.api.platform import MessageType
-from astrbot.api.provider import Personality, ProviderRequest, LLMResponse
+from astrbot.api.provider import ProviderRequest
 from astrbot.core.provider.sources.dify_source import ProviderDify
 from astrbot.core.utils.io import download_dashboard, get_dashboard_version
 from astrbot.core.star.star_handler import star_handlers_registry, StarHandlerMetadata
@@ -40,7 +39,7 @@ class Main(star.Star):
    async def _query_astrbot_notice(self):
        try:
            async with aiohttp.ClientSession(trust_env=True) as session:
-                async with session.get("https://astrbot.soulter.top/notice.json", timeout=2) as resp:
+                async with session.get("https://astrbot.app/notice.json", timeout=2) as resp:
                    return (await resp.json())["notice"]
        except BaseException:
            return ""
@@ -97,6 +96,7 @@ AstrBot 指令:
    
    @tool.command("ls")
    async def tool_ls(self, event: AstrMessageEvent):
+        '''查看函数工具列表'''
        tm = self.context.get_llm_tool_manager()
        msg = "函数工具：\n"
        for tool in tm.func_list:
@@ -108,6 +108,7 @@ AstrBot 指令:
        
    @tool.command("on")
    async def tool_on(self, event: AstrMessageEvent, tool_name: str):
+        '''启用一个函数工具'''
        if self.context.activate_llm_tool(tool_name):
            event.set_result(MessageEventResult().message(f"激活工具 {tool_name} 成功。"))
        else:
@@ -115,6 +116,7 @@ AstrBot 指令:
            
    @tool.command("off")
    async def tool_off(self, event: AstrMessageEvent, tool_name: str):
+        '''停用一个函数工具'''
        if self.context.deactivate_llm_tool(tool_name):
            event.set_result(MessageEventResult().message(f"停用工具 {tool_name} 成功。"))
        else:
@@ -122,6 +124,7 @@ AstrBot 指令:
            
    @tool.command("off_all")
    async def tool_all_off(self, event: AstrMessageEvent):
+        '''停用所有函数工具'''
        tm = self.context.get_llm_tool_manager()
        for tool in tm.func_list:
            self.context.deactivate_llm_tool(tool.name)
@@ -129,6 +132,7 @@ AstrBot 指令:

    @filter.command("plugin")
    async def plugin(self, event: AstrMessageEvent, oper1: str = None, oper2: str = None):
+        '''插件管理'''
        if oper1 is None:
            plugin_list_info = "已加载的插件：\n"
            for plugin in self.context.get_all_stars():
@@ -190,6 +194,7 @@ AstrBot 指令:

    @filter.command("t2i")
    async def t2i(self, event: AstrMessageEvent):
+        '''开关文本转图片'''
        config = self.context.get_config()
        if config['t2i']:
            config['t2i'] = False
@@ -202,6 +207,7 @@ AstrBot 指令:

    @filter.command("tts")
    async def tts(self, event: AstrMessageEvent):
+        '''开关文本转语音'''
        config = self.context.get_config()
        if config['provider_tts_settings']['enable']:
            config['provider_tts_settings']['enable'] = False
@@ -214,6 +220,7 @@ AstrBot 指令:
    
    @filter.command("sid")
    async def sid(self, event: AstrMessageEvent):
+        '''获取会话 ID 和 管理员 ID'''
        sid = event.unified_msg_origin
        user_id = str(event.get_sender_id())
        ret = f"""SID: {sid} 此 ID 可用于设置会话白名单。/wl <SID> 添加白名单, /dwl <SID> 删除白名单。
@@ -223,6 +230,7 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("op")
    async def op(self, event: AstrMessageEvent, admin_id: str):
+        '''授权管理员。op <admin_id>'''
        self.context.get_config()['admins_id'].append(admin_id)
        self.context.get_config().save_config()
        event.set_result(MessageEventResult().message("授权成功。"))
@@ -230,6 +238,7 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("deop")
    async def deop(self, event: AstrMessageEvent, admin_id: str):
+        '''取消授权管理员。deop <admin_id>'''
        try:
            self.context.get_config()['admins_id'].remove(admin_id)
            self.context.get_config().save_config()
@@ -341,16 +350,20 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
            else:
                event.set_result(MessageEventResult().message("无效的参数。"))

-    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("reset")
    async def reset(self, message: AstrMessageEvent):
        '''重置 LLM 会话'''
+        is_unique_session = self.context.get_config()['platform_settings']['unique_session']
+        if message.get_group_id() and not is_unique_session and message.role != "admin":
+            # 群聊，没开独立会话，发送人不是管理员
+            message.set_result(MessageEventResult().message(f"会话处于群聊，并且未开启独立会话，并且您 (ID {message.get_sender_id()}) 不是管理员，因此没有权限重置当前对话。"))    
+            return
+        
        if not self.context.get_using_provider():
            message.set_result(MessageEventResult().message("未找到任何 LLM 提供商。请先配置。"))
            return
        
        provider = self.context.get_using_provider()
-        print(provider.meta())
        if provider and provider.meta().type == 'dify':
            assert isinstance(provider, ProviderDify)
            await provider.forget(message.unified_msg_origin)
@@ -394,6 +407,10 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
            for model in models:
                ret += f"\n{i}. {model}"
                i += 1
+            
+            curr_model = self.context.get_using_provider().get_model() or "无"
+            ret += f"\n当前模型: [{curr_model}]"
+                
            ret += "\nTips: 使用 /model <模型名/编号>，即可实时更换模型。如目标模型不存在于上表，请输入模型名。"
            message.set_result(MessageEventResult().message(ret).use_t2i(False))
        else:
@@ -419,7 +436,6 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
                message.set_result(
                    MessageEventResult().message(f"切换模型到 {self.context.get_using_provider().get_model()}。"))
                
-
    @filter.command("history")
    async def his(self, message: AstrMessageEvent, page: int = 1):
        '''查看对话记录'''
@@ -459,6 +475,7 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
        
        provider = self.context.get_using_provider()
        if provider and provider.meta().type == 'dify':
+            """原有的Dify处理逻辑保持不变"""
            ret = "Dify 对话列表:\n"
            assert isinstance(provider, ProviderDify)
            data = await provider.api_client.get_chat_convs(message.unified_msg_origin)
@@ -475,32 +492,45 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
            return

        size_per_page = 6
-        conversations = await self.context.conversation_manager.get_conversations(message.unified_msg_origin)
-        total_pages = len(conversations) // size_per_page
-        if len(conversations) % size_per_page != 0:
-            total_pages += 1
-        conversations = conversations[(page-1)*size_per_page:page*size_per_page]
+        """获取所有对话列表"""
+        conversations_all = await self.context.conversation_manager.get_conversations(message.unified_msg_origin)
+        """计算总页数"""
+        total_pages = (len(conversations_all) + size_per_page - 1) // size_per_page
+        """确保页码有效"""
+        page = max(1, min(page, total_pages))
+        """分页处理"""
+        start_idx = (page - 1) * size_per_page
+        end_idx = start_idx + size_per_page
+        conversations_paged = conversations_all[start_idx:end_idx]
        
        ret = "对话列表：\n---\n"
-        global_index = (page - 1) * size_per_page + 1
+        """全局序号从当前页的第一个开始"""
+        global_index = start_idx + 1  
        
+        """生成所有对话的标题字典"""
        _titles = {}
-        for conv in conversations:
-            
+        for conv in conversations_all:
            persona_id = conv.persona_id
-            if not persona_id and not persona_id == "[%None]":
+            if not persona_id or persona_id == "[%None]":
                persona_id = self.context.provider_manager.selected_default_persona['name']
-            
            title = conv.title if conv.title else "新对话"
            _titles[conv.cid] = title
-            
+        
+        """遍历分页后的对话生成列表显示"""
+        for conv in conversations_paged:
+            persona_id = conv.persona_id
+            if not persona_id or persona_id == "[%None]":
+                persona_id = self.context.provider_manager.selected_default_persona['name']
+            title = _titles.get(conv.cid, "新对话")
            ret += f"{global_index}. {title}({conv.cid[:4]})\n  人格情景: {persona_id}\n  上次更新: {datetime.datetime.fromtimestamp(conv.updated_at).strftime('%m-%d %H:%M')}\n"
            global_index += 1
        
        ret += "---\n"
        curr_cid = await self.context.conversation_manager.get_curr_conversation_id(message.unified_msg_origin)
        if curr_cid:
-            ret += f"\n当前对话: {_titles[curr_cid]}({curr_cid[:4]})"
+            """从所有对话的标题字典中获取标题"""
+            title = _titles.get(curr_cid, "新对话")
+            ret += f"\n当前对话: {title}({curr_cid[:4]})"
        else:
            ret += "\n当前对话: 无"
        
@@ -509,11 +539,12 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
            ret += "\n会话隔离粒度: 个人"
        else:
            ret += "\n会话隔离粒度: 群聊"
-            
+        
        ret += f"\n第 {page} 页 | 共 {total_pages} 页"
        ret += "\n*输入 /ls 2 跳转到第 2 页"
        
        message.set_result(MessageEventResult().message(ret).use_t2i(False))
+        return
        
    @filter.command("new")
    async def new_conv(self, message: AstrMessageEvent):
@@ -583,10 +614,14 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
        await self.context.conversation_manager.update_conversation_title(message.unified_msg_origin, new_name)
        message.set_result(MessageEventResult().message("重命名对话成功。"))
    
-    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("del")
    async def del_conv(self, message: AstrMessageEvent):
        '''删除当前对话'''
+        is_unique_session = self.context.get_config()['platform_settings']['unique_session']
+        if message.get_group_id() and not is_unique_session and message.role != "admin":
+            # 群聊，没开独立会话，发送人不是管理员
+            message.set_result(MessageEventResult().message(f"会话处于群聊，并且未开启独立会话，并且您 (ID {message.get_sender_id()}) 不是管理员，因此没有权限删除当前对话。"))    
+            return
        
        provider = self.context.get_using_provider()
        if provider and provider.meta().type == 'dify':
@@ -605,7 +640,6 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
        await self.context.conversation_manager.delete_conversation(message.unified_msg_origin, session_curr_cid)
        message.set_result(MessageEventResult().message("删除当前对话成功。不再处于对话状态，使用 /switch 序号 切换到其他对话或 /new 创建。"))
        
-
    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("key")
    async def key(self, message: AstrMessageEvent, index: int=None):
@@ -717,31 +751,32 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo

    @filter.command("set")
    async def set_variable(self, event: AstrMessageEvent, key: str, value: str):
-        session_id = event.get_session_id()
+        # session_id = event.get_session_id()
+        uid = event.unified_msg_origin
        session_vars = sp.get("session_variables", {})
        
-        session_var = session_vars.get(session_id, {})
+        session_var = session_vars.get(uid, {})
        session_var[key] = value
        
-        session_vars[session_id] = session_var
+        session_vars[uid] = session_var
        
        sp.put("session_variables", session_vars)
        
-        yield event.plain_result(f"会话 {session_id} 变量 {key} 存储成功。使用 /unset 移除。")
+        yield event.plain_result(f"会话 {uid} 变量 {key} 存储成功。使用 /unset 移除。")
        
    @filter.command("unset")
    async def unset_variable(self, event: AstrMessageEvent, key: str):
-        session_id = event.get_session_id()
+        uid = event.unified_msg_origin
        session_vars = sp.get("session_variables", {})
        
-        session_var = session_vars.get(session_id, {})
+        session_var = session_vars.get(uid, {})
        
        if key not in session_var:
            yield event.plain_result("没有那个变量名。格式 /unset 变量名。")
        else:
            del session_var[key]
            sp.put("session_variables", session_vars)
-            yield event.plain_result(f"会话 {session_id} 变量 {key} 移除成功。")
+            yield event.plain_result(f"会话 {uid} 变量 {key} 移除成功。")
            
    @filter.command("gewe_logout")
    async def gewe_logout(self, event: AstrMessageEvent):
@@ -774,18 +809,30 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
                    logger.error("未找到任何 LLM 提供商。请先配置。无法主动回复")
                    return
                try:
-                    session_curr_cid = await self.context.conversation_manager.get_curr_conversation_id(event.unified_msg_origin)
-                    
-                    if not session_curr_cid:
-                        logger.error("当前未处于对话状态，无法主动回复，请确保 平台设置->会话隔离(unique_session) 未开启，并使用 /switch 序号 切换或者 /new 创建一个会话。")
-                        return
-                    
-                    conv = await self.context.conversation_manager.get_conversation(
-                        event.unified_msg_origin, 
-                        session_curr_cid
-                    )
-                    history = json.loads(conv.history)
-                    
+                    conv = None
+                    history = []
+                    if provider.meta().type != 'dify':
+                        # Dify 自己有维护对话，不需要 bot 端维护。
+                        session_curr_cid = await self.context.conversation_manager.get_curr_conversation_id(event.unified_msg_origin)
+                        
+                        if not session_curr_cid:
+                            logger.error("当前未处于对话状态，无法主动回复，请确保 平台设置->会话隔离(unique_session) 未开启，并使用 /switch 序号 切换或者 /new 创建一个会话。")
+                            return
+                        
+                        conv = await self.context.conversation_manager.get_conversation(
+                            event.unified_msg_origin, 
+                            session_curr_cid
+                        )
+                        history = []
+                        if conv:
+                            history = json.loads(conv.history)
+                    else:
+                        assert isinstance(provider, ProviderDify)
+                        cid = provider.conversation_ids.get(event.unified_msg_origin, None)
+                        if cid is None:
+                            logger.error("[Dify] 当前未处于对话状态，无法主动回复，请确保 平台设置->会话隔离(unique_session) 未开启，并使用 /switch 序号 切换或者 /new 创建一个会话。")
+                            return
+                        
                    prompt = self.ltm.ar_prompt
                    if not prompt:
                        prompt = event.message_str
@@ -915,16 +962,7 @@ UID: {user_id} 此 ID 可用于设置管理员。/op <UID> 授权管理员, /deo
    # @filter.command_group("kdb")
    # def kdb(self):
    #     pass
-        
-    # @kdb.command("on")
-    # async def on_kdb(self, event: AstrMessageEvent):
-    #     self.kdb_enabled = True
-    #     curr_kdb_name = self.context.provider_manager.curr_kdb_name
-    #     if not curr_kdb_name:
-    #         yield event.plain_result("未载入任何知识库")
-    #     else:
-    #         yield event.plain_result(f"知识库已打开。当前载入的知识库: {curr_kdb_name}")
-        
+
    # @kdb.command("off")
    # async def off_kdb(self, event: AstrMessageEvent):
    #     self.kdb_enabled = False
--- a/packages/python_interpreter/main.py
+++ b/packages/python_interpreter/main.py
@@ -85,7 +85,8 @@ DEFAULT_CONFIG = {
    "sandbox": {
        "image": "soulter/astrbot-code-interpreter-sandbox",
        "docker_mirror": "", # cjie.eu.org
-    }
+    },
+    "docker_host_astrbot_abs_path": ""
 }
 PATH = "data/config/python_interpreter.json"

@@ -95,8 +96,14 @@ class Main(star.Star):
    def __init__(self, context: star.Context) -> None:
        self.context = context
        self.curr_dir = os.path.dirname(os.path.abspath(__file__))
-        self.workplace_path = os.path.join(self.curr_dir, "workplace")
-        self.shared_path = os.path.join(self.curr_dir, "shared")
+        
+        self.shared_path = os.path.join("data", "py_interpreter_shared")
+        if not os.path.exists(self.shared_path):
+            # 复制 api.py 到 shared 目录
+            os.makedirs(self.shared_path, exist_ok=True)
+            shared_api_file = os.path.join(self.curr_dir, "shared", "api.py")
+            shutil.copy(shared_api_file, self.shared_path)
+        self.workplace_path = os.path.join("data", "py_interpreter_workplace")
        os.makedirs(self.workplace_path, exist_ok=True)
        
        self.user_file_msg_buffer = defaultdict(list)
@@ -195,7 +202,16 @@ class Main(star.Star):
    @filter.command_group("pi")
    def pi(self):
        pass
-
+    
+    @pi.command("absdir")
+    async def pi_absdir(self, event: AstrMessageEvent, path: str = ""):
+        '''设置 Docker 宿主机绝对路径'''
+        if not path:
+            yield event.plain_result(f"当前 Docker 宿主机绝对路径: {self.config.get('docker_host_astrbot_abs_path', '')}")
+        else:
+            self.config["docker_host_astrbot_abs_path"] = path
+            self._save_config()
+            yield event.plain_result(f"设置 Docker 宿主机绝对路径成功: {path}")

    @pi.command("mirror")
    async def pi_mirror(self, event: AstrMessageEvent, url: str = ""):
@@ -305,6 +321,20 @@ class Main(star.Star):
                
            yield event.plain_result(f"使用沙箱执行代码中，请稍等...(尝试次数: {i+1}/{n})")
            
+            
+            self.docker_host_astrbot_abs_path = self.config.get("docker_host_astrbot_abs_path", "")
+            if self.docker_host_astrbot_abs_path:
+                host_shared = os.path.join(self.docker_host_astrbot_abs_path, self.shared_path)
+                host_output = os.path.join(self.docker_host_astrbot_abs_path, output_path)
+                host_workplace = os.path.join(self.docker_host_astrbot_abs_path, workplace_path)
+                
+            else:
+                host_shared = os.path.abspath(self.shared_path)
+                host_output = os.path.abspath(output_path)
+                host_workplace = os.path.abspath(workplace_path)
+            
+            logger.debug(f"host_shared: {host_shared}, host_output: {host_output}, host_workplace: {host_workplace}")
+            
            container = await docker.containers.run({
                "Image": image_name,
                "Cmd": ["python", "exec.py"],
@@ -312,9 +342,9 @@ class Main(star.Star):
                "NanoCPUs": 1000000000,
                "HostConfig": {
                    "Binds": [
-                        f"{self.shared_path}:/astrbot_sandbox/shared:ro",
-                        f"{output_path}:/astrbot_sandbox/output:rw",
-                        f"{workplace_path}:/astrbot_sandbox:rw",
+                        f"{host_shared}:/astrbot_sandbox/shared:ro",
+                        f"{host_output}:/astrbot_sandbox/output:rw",
+                        f"{host_workplace}:/astrbot_sandbox:rw",
                    ]
                },
                "Env": [
--- a/packages/reminder/main.py
+++ b/packages/reminder/main.py
@@ -13,7 +13,7 @@ class Main(star.Star):
    '''使用 LLM 待办提醒。只需对 LLM 说想要提醒的事情和时间即可。比如：`之后每天这个时候都提醒我做多邻国`'''
    def __init__(self, context: star.Context) -> None:
        self.context = context
-        self.scheduler = AsyncIOScheduler()
+        self.scheduler = AsyncIOScheduler(timezone='Asia/Shanghai')
        
        # set and load config
        if not os.path.exists("data/astrbot-reminder.json"):
@@ -175,10 +175,18 @@ class Main(star.Star):
        else:
            reminder = reminders.pop(index - 1)
            job_id = reminder.get("id")
+            
+            # self.reminder_data[event.unified_msg_origin] = reminder
+            users_reminders = self.reminder_data.get(event.unified_msg_origin, [])
+            for i, r in enumerate(users_reminders):
+                if r.get("id") == job_id:
+                    users_reminders.pop(i)
+            
            try:
                self.scheduler.remove_job(job_id)
            except Exception as e:
                logger.error(f"Remove job error: {e}")
+                yield event.plain_result(f"成功移除对应的待办事项。删除定时任务失败: {str(e)} 可能需要重启 AstrBot 以取消该提醒任务。")
            await self._save_data()
            yield event.plain_result("成功删除待办事项：\n" + reminder["text"])
    
--- a/packages/web_searcher/main.py
+++ b/packages/web_searcher/main.py
@@ -75,10 +75,10 @@ class Main(star.Star):
            
    @llm_tool("web_search")
    async def search_from_search_engine(self, event: AstrMessageEvent, query: str) -> str:
-        '''Search the web for answers to the user's query
+        '''搜索网络以回答用户的问题。当用户需要搜索网络以获取即时性的信息时调用此工具。
        
        Args:
-            query(string): A search query which will be used to fetch the most relevant snippets regarding the user's query
+            query(string): 和用户的问题最相关的搜索关键词，用于在 Google 上搜索。
        '''
        logger.info("web_searcher - search_from_search_engine: " + query)
        results = []
Author	SHA1	Message	Date
Soulter	dba1ed1e19	v3.4.30	2025-02-21 01:31:36 +08:00
Soulter	a24514876b	fix: 修复 dify 无法使用事件钩子的问题以及出现 GeneratorExit 的问题 #533 #264	2025-02-21 01:14:13 +08:00
Soulter	466a1c1c41	🐛 fix: 修复某些情况下导致插件报错 AttributeError 的问题 #549	2025-02-21 00:38:08 +08:00
Soulter	a2d5e9f40f	feat: add xAI template	2025-02-20 16:34:32 +08:00
Soulter	1bbff1d161	v3.4.29	2025-02-19 20:05:33 +08:00
Soulter	0948bae99b	✨ feat: 添加代码执行器 Docker 宿主机绝对路径配置及相关功能 Co-authored-by: Bocity <haolovej@vip.qq.com>	2025-02-19 19:56:31 +08:00
Soulter	850db41596	✨ feat: gemini source 初步支持对 API Key 进行负载均衡请求 #534	2025-02-19 19:06:37 +08:00
Soulter	7bafc87e2b	🐛 fix: 修复部分单指令失效的问题	2025-02-19 19:04:23 +08:00
Soulter	1a0de02a15	fix: 尝试修复gewechat群聊用户名出现unknown	2025-02-19 17:07:11 +08:00
Soulter	6d5d278624	fix: 尝试修复 gewechat 微信群聊情况下可能导致 unknown 的问题 #537	2025-02-19 16:42:30 +08:00
Soulter	3b4cc48fa0	👌 perf: 开启对话隔离的群聊以及私聊下，非op可以可以使用 /del 和 /reset #519	2025-02-19 16:22:42 +08:00
Soulter	c908461088	Merge pull request #543 from Soulter/refactor-command-group 更换为预编译指令的方式处理指令组指令并且让事件钩子也支持 yield 的方式发送消息	2025-02-19 15:54:26 +08:00
Soulter	53d1398d30	fix: 修复子指令组不能被调用的问题	2025-02-19 15:53:01 +08:00
Soulter	782c0367d0	✨ feat: 事件钩子支持 yield 方式发送消息	2025-02-19 15:29:10 +08:00
Soulter	4678222e9b	👌 refactor: 更换为预编译指令的方式处理指令组指令	2025-02-19 14:55:14 +08:00
Soulter	f71dc3e4be	🐛 fix: reminder time zone issue	2025-02-19 00:15:14 +08:00
Soulter	f6233893bd	🐛 fix: 修复 reminder rm失败 #529	2025-02-19 00:10:18 +08:00
Soulter	6427bcf130	👌perf: 查询模型列表时，可以显示当前使用的模型名称 #523	2025-02-17 22:35:45 +08:00
Soulter	8fa41b706c	Merge pull request #522 from yuanxinlyx/fix-keyerror-ls-command fix: resolve KeyError when current conversation is not in paginated list	2025-02-17 21:45:40 +08:00
YuanxinLu	4706c4438d	fix: resolve KeyError when current conversation is not in paginated list	2025-02-17 03:15:59 +08:00
Soulter	0c8ebc2b06	chore: clean up	2025-02-16 16:52:13 +08:00
Soulter	b3b5ebc2ca	v3.4.28	2025-02-16 16:19:03 +08:00
Soulter	b8aa23ccc5	🐛fix: 修复转发消息的字数阈值功能#510	2025-02-16 15:54:29 +08:00
Soulter	364843db29	Merge pull request #389 from Nothingness-Void/新增过滤掉正则表达式内容新增过滤掉正则表达式内容	2025-02-16 15:28:51 +08:00
Soulter	aa56c8f7e6	Merge branch 'master' into 新增过滤掉正则表达式内容	2025-02-16 15:27:30 +08:00
Soulter	8e9fd27058	merge branch `master`	2025-02-16 15:17:44 +08:00
Soulter	b75908cb2a	Merge pull request #517 from Cvandia/master ✨ feat: 添加命令和命令组的别名支持	2025-02-16 14:51:47 +08:00
Soulter	af6df49ce1	✨ perf: 补充别名为可选参数以前向兼容	2025-02-16 14:50:49 +08:00
Cvandia	bd3bdb5769	✨ feat: 添加命令和命令组的别名支持	2025-02-16 14:44:17 +08:00
Soulter	98fe193b21	Merge pull request #477 from AraragiEro/master [Feature] 希望添加更为灵活的filter.permission_type使用方式，使用户能自定义权限类型	2025-02-16 13:53:07 +08:00
Soulter	26cbc9e8b1	chore: cleanup	2025-02-16 13:32:28 +08:00
Alero	ebb8c43fd0	bug: 尝试修复cleancode错误	2025-02-16 10:56:17 +08:00
Soulter	8c7344f1c4	👌perf(qq): supports to pass OneBot notice, request event	2025-02-16 01:04:08 +08:00
Soulter	5c32a17787	👌perf: 优化了分段回复和回复时at,引用都打开时的一些体验性问题	2025-02-15 19:29:34 +08:00
Soulter	aff520e69a	fix: 修复 Dify 下无法主动回复的问题 #494	2025-02-15 18:31:21 +08:00
Alero	45e627c33c	fix: a bug when add filter to root command group	2025-02-14 23:52:31 +08:00
Alero	7a1b158f83	fix: cleancode err	2025-02-14 22:46:22 +08:00
Alero	6374c5d49d	fix: add & \| operation to customfilter	2025-02-14 22:33:32 +08:00
Alero	fd460b19d4	fix: cleancode err	2025-02-14 20:43:54 +08:00
Alero	dff7cc4ca5	feat: when custom filter cant pass, won't raise error anymore. and when you use a command group and dont have custom filter access, the return group tree wont contain the command that you dont have permisson.	2025-02-14 20:34:31 +08:00
Alero	d013320bec	feat: more powerful CustomFilter	2025-02-14 19:15:19 +08:00
Soulter	fc6dcfaf21	🐛 fix: cannot search plugin	2025-02-14 18:45:56 +08:00
Soulter	a001270bd2	✨ feat: webui supports to search plugin via name	2025-02-14 18:43:04 +08:00
Soulter	9e67883fbd	🐛 fix: add no_proxy env vars to support localhost requests, fix 502 error when use ollama #504	2025-02-14 16:51:02 +08:00
Soulter	f1a448708c	🐛 fix: segmented reply caused incomplete non-llm-response #503	2025-02-14 16:19:09 +08:00
Soulter	a4bfa96502	✨ feat: 支持自定义 Dify 工作流文本输入变量名 #441	2025-02-14 15:41:02 +08:00
Soulter	595b83a256	🐛 FIX: cannot send file in private chat when turn on the reply with quote #262	2025-02-14 14:41:41 +08:00
Soulter	8d34f77321	v3.4.27	2025-02-14 01:53:26 +08:00
Soulter	67095f97b1	🐛 fix: delete conversation ✨ feat: supports active reply whitelist	2025-02-14 01:43:52 +08:00
Soulter	50740c94ab	🐛 fix: cannot input text before mention in gewechat #492	2025-02-14 01:09:48 +08:00
Soulter	4db4cfeda2	👌 perf: format datetime labels in MessageStat component #460	2025-02-14 00:30:34 +08:00
Soulter	ad13cef89c	👌perf: sort models by id when listing models #384	2025-02-14 00:08:12 +08:00
Soulter	855fc6fcd1	Display the Japanese translation entry	2025-02-13 23:36:50 +08:00
Soulter	8f12244e51	Merge pull request #491 from eltociear/add-japanese-readme docs: add Japanese README	2025-02-13 22:56:21 +08:00
Ikko Eltociear Ashimine	fe0213465c	docs: add Japanese README I created Japanese translated README.	2025-02-13 14:45:52 +09:00
Soulter	f984047004	fix: unable to send c2c message using webhook qqofficial platform #484	2025-02-13 00:01:16 +08:00
Soulter	19e9e2d090	fix: fix dify cannot set/unset variables #482	2025-02-12 23:58:04 +08:00
Soulter	7fe3b97d00	fix: improve content safety check handling for at or wake commands	2025-02-12 23:42:32 +08:00
Soulter	9cd243da47	fix: handle empty content in gemini context	2025-02-12 23:39:41 +08:00
Soulter	e43208c2e9	fix: update session_id assignment logic for group messages	2025-02-12 14:04:55 +08:00
Soulter	dc016fc22f	feat: update validate_config to return a tuple contains casted data	2025-02-12 13:50:24 +08:00
Alero	c6f037cae2	fix: a undefine mistake	2025-02-12 03:25:01 +08:00
Alero	f049830e28	Merge branch 'master' of github.com:AraragiEro/AstrBot	2025-02-12 03:06:23 +08:00
Alero	dd1995ae0b	feat: add a way to define custom permission filter.	2025-02-12 03:05:51 +08:00
Xu Void	7155b4f0ac	Update default.py	2025-02-08 10:16:31 +08:00
Xu Void	0021cfc4bc	新增过滤掉正则表达式内容 Fixes #338 新增过滤掉正则表达式内容 --- For more details, open the [Copilot Workspace session](https://copilot-workspace.githubnext.com/Soulter/AstrBot/issues/338?shareId=XXXX-XXXX-XXXX-XXXX).	2025-02-06 15:28:28 +08:00