fix: enhance content validation in Message model to allow None for assistant role with tool_calls

增加升级所有插件按钮

.github/workflows/auto_release.yml

@@ -13,7 +13,7 @@ jobs:
       contents: write
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
 
       - name: Dashboard Build
         run: |
@@ -70,7 +70,7 @@ jobs:
     needs: build-and-publish-to-github-release
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
 
       - name: Set up Python
         uses: actions/setup-python@v6

.github/workflows/code-format.yml

@@ -12,7 +12,7 @@ jobs:
     
     steps:
     - name: Checkout code
-      uses: actions/checkout@v5
+      uses: actions/checkout@v6
       
     - name: Set up Python
       uses: actions/setup-python@v6

.github/workflows/codeql.yml

@@ -56,7 +56,7 @@ jobs:
         # your codebase is analyzed, see https://docs.github.com/en/code-security/code-scanning/creating-an-advanced-setup-for-code-scanning/codeql-code-scanning-for-compiled-languages
     steps:
     - name: Checkout repository
-      uses: actions/checkout@v5
+      uses: actions/checkout@v6
 
     # Initializes the CodeQL tools for scanning.
     - name: Initialize CodeQL

.github/workflows/coverage_test.yml

@@ -17,7 +17,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
         with:
           fetch-depth: 0
 

.github/workflows/dashboard_ci.yml

@@ -11,7 +11,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
 
       - name: Setup Node.js
         uses: actions/setup-node@v6

.github/workflows/docker-image.yml

@@ -20,7 +20,7 @@ jobs:
 
     steps:
       - name: Checkout
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
         with:
           fetch-depth: 1
           fetch-tag: true
@@ -118,7 +118,7 @@ jobs:
 
     steps:
       - name: Checkout
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
         with:
           fetch-depth: 1
           fetch-tag: true

.gitignore

@@ -34,6 +34,7 @@ dashboard/node_modules/
 dashboard/dist/
 package-lock.json
 package.json
+yarn.lock
 
 # Operating System
 **/.DS_Store

astrbot/cli/__init__.py

@@ -1 +1 @@
-__version__ = "3.5.23"
+__version__ = "4.7.3"

astrbot/core/agent/mcp_client.py

@@ -345,9 +345,6 @@ class MCPClient:
 
     async def cleanup(self):
         """Clean up resources including old exit stacks from reconnections"""
-        # Set running_event first to unblock any waiting tasks
-        self.running_event.set()
-
         # Close current exit stack
         try:
             await self.exit_stack.aclose()
@@ -359,6 +356,9 @@ class MCPClient:
         # Just clear the list to release references
         self._old_exit_stacks.clear()
 
+        # Set running_event first to unblock any waiting tasks
+        self.running_event.set()
+
 
 class MCPTool(FunctionTool, Generic[TContext]):
     """A function tool that calls an MCP service."""

astrbot/core/agent/message.py

@@ -3,7 +3,7 @@
 
 from typing import Any, ClassVar, Literal, cast
 
-from pydantic import BaseModel, GetCoreSchemaHandler
+from pydantic import BaseModel, GetCoreSchemaHandler, model_validator
 from pydantic_core import core_schema
 
 
@@ -145,22 +145,39 @@ class Message(BaseModel):
         "tool",
     ]
 
-    content: str | list[ContentPart]
+    content: str | list[ContentPart] | None = None
     """The content of the message."""
 
+    tool_calls: list[ToolCall] | list[dict] | None = None
+    """The tool calls of the message."""
+
+    tool_call_id: str | None = None
+    """The ID of the tool call."""
+
+    @model_validator(mode="after")
+    def check_content_required(self):
+        # assistant + tool_calls is not None: allow content to be None
+        if self.role == "assistant" and self.tool_calls is not None:
+            return self
+
+        # other all cases: content is required
+        if self.content is None:
+            raise ValueError(
+                "content is required unless role='assistant' and tool_calls is not None"
+            )
+        return self
+
 
 class AssistantMessageSegment(Message):
     """A message segment from the assistant."""
 
     role: Literal["assistant"] = "assistant"
-    tool_calls: list[ToolCall] | list[dict] | None = None
 
 
 class ToolCallMessageSegment(Message):
     """A message segment representing a tool call."""
 
     role: Literal["tool"] = "tool"
-    tool_call_id: str
 
 
 class UserMessageSegment(Message):

astrbot/core/config/default.py

@@ -4,7 +4,7 @@ import os
 
 from astrbot.core.utils.astrbot_path import get_astrbot_data_path
 
-VERSION = "4.6.1"
+VERSION = "4.7.3"
 DB_PATH = os.path.join(get_astrbot_data_path(), "data_v4.db")
 
 # 默认配置
@@ -90,6 +90,7 @@ DEFAULT_CONFIG = {
         "group_icl_enable": False,
         "group_message_max_cnt": 300,
         "image_caption": False,
+        "image_caption_provider_id": "",
         "active_reply": {
             "enable": False,
             "method": "possibility_reply",
@@ -647,7 +648,7 @@ CONFIG_METADATA_2 = {
                             },
                             "words_count_threshold": {
                                 "type": "int",
-                                "hint": "超过这个字数的消息不会被分段回复。默认为 150",
+                                "hint": "分段回复的字数上限。只有字数小于此值的消息才会被分段，超过此值的长消息将直接发送（不分段）。默认为 150",
                             },
                             "regex": {
                                 "type": "string",
@@ -2109,6 +2110,9 @@ CONFIG_METADATA_2 = {
                     "image_caption": {
                         "type": "bool",
                     },
+                    "image_caption_provider_id": {
+                        "type": "string",
+                    },
                     "image_caption_prompt": {
                         "type": "string",
                     },
@@ -2785,7 +2789,16 @@ CONFIG_METADATA_3 = {
                     "provider_ltm_settings.image_caption": {
                         "description": "自动理解图片",
                         "type": "bool",
-                        "hint": "需要设置默认图片转述模型。",
+                        "hint": "需要设置群聊图片转述模型。",
+                    },
+                    "provider_ltm_settings.image_caption_provider_id": {
+                        "description": "群聊图片转述模型",
+                        "type": "string",
+                        "_special": "select_provider",
+                        "hint": "用于群聊上下文感知的图片理解，与默认图片转述模型分开配置。",
+                        "condition": {
+                            "provider_ltm_settings.image_caption": True,
+                        },
                     },
                     "provider_ltm_settings.active_reply.enable": {
                         "description": "主动回复",

astrbot/core/pipeline/process_stage/method/agent_sub_stages/third_party.py

@@ -2,7 +2,7 @@ import asyncio
 from collections.abc import AsyncGenerator
 from typing import TYPE_CHECKING
 
-from astrbot.core import logger
+from astrbot.core import astrbot_config, logger
 from astrbot.core.agent.runners.coze.coze_agent_runner import CozeAgentRunner
 from astrbot.core.agent.runners.dashscope.dashscope_agent_runner import (
     DashscopeAgentRunner,
@@ -88,12 +88,15 @@ class ThirdPartyAgentSubStage(Stage):
             return
 
         self.prov_cfg: dict = next(
-            (p for p in self.conf["provider"] if p["id"] == self.prov_id),
+            (p for p in astrbot_config["provider"] if p["id"] == self.prov_id),
             {},
         )
-        if not self.prov_id or not self.prov_cfg:
+        if not self.prov_id:
+            logger.error("没有填写 Agent Runner 提供商 ID，请前往配置页面配置。")
+            return
+        if not self.prov_cfg:
             logger.error(
-                "Third Party Agent Runner provider ID is not configured properly."
+                f"Agent Runner 提供商 {self.prov_id} 配置不存在，请前往配置页面修改配置。"
             )
             return
 

astrbot/core/pipeline/process_stage/stage.py

@@ -1,6 +1,5 @@
 from collections.abc import AsyncGenerator
 
-from astrbot.core import logger
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
 from astrbot.core.provider.entities import ProviderRequest
 from astrbot.core.star.star_handler import StarHandlerMetadata
@@ -63,12 +62,5 @@ class ProcessStage(Stage):
             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:
-                    logger.info("未找到可用的 LLM 提供商，请先前往配置服务提供商。")
-                    return
-
                 async for _ in self.agent_sub_stage.process(event):
                     yield

astrbot/core/pipeline/result_decorate/stage.py

@@ -161,11 +161,21 @@ class ResultDecorateStage(Stage):
                                 # 不分段回复
                                 new_chain.append(comp)
                                 continue
+                            try:
                                 split_response = re.findall(
                                     self.regex,
                                     comp.text,
                                     re.DOTALL | re.MULTILINE,
                                 )
+                            except re.error:
+                                logger.error(
+                                    f"分段回复正则表达式错误，使用默认分段方式: {traceback.format_exc()}",
+                                )
+                                split_response = re.findall(
+                                    r".*?[。？！~…]+|.+$",
+                                    comp.text,
+                                    re.DOTALL | re.MULTILINE,
+                                )
                             if not split_response:
                                 new_chain.append(comp)
                                 continue

astrbot/core/platform/sources/dingtalk/dingtalk_adapter.py

@@ -250,7 +250,7 @@ class DingtalkPlatformAdapter(Platform):
 
     async def terminate(self):
         def monkey_patch_close():
-            raise Exception("Graceful shutdown")
+            raise KeyboardInterrupt("Graceful shutdown")
 
         self.client_.open_connection = monkey_patch_close
         await self.client_.websocket.close(code=1000, reason="Graceful shutdown")

astrbot/core/provider/manager.py

@@ -1,7 +1,7 @@
 import asyncio
 import traceback
 
-from astrbot.core import logger, sp
+from astrbot.core import astrbot_config, logger, sp
 from astrbot.core.astrbot_config_mgr import AstrBotConfigManager
 from astrbot.core.db import BaseDatabase
 
@@ -24,6 +24,7 @@ class ProviderManager:
         db_helper: BaseDatabase,
         persona_mgr: PersonaManager,
     ):
+        self.reload_lock = asyncio.Lock()
         self.persona_mgr = persona_mgr
         self.acm = acm
         config = acm.confs["default"]
@@ -226,6 +227,7 @@ class ProviderManager:
 
     async def load_provider(self, provider_config: dict):
         if not provider_config["enable"]:
+            logger.info(f"Provider {provider_config['id']} is disabled, skipping")
             return
         if provider_config.get("provider_type", "") == "agent_runner":
             return
@@ -434,13 +436,15 @@ class ProviderManager:
             )
 
     async def reload(self, provider_config: dict):
+        async with self.reload_lock:
             await self.terminate_provider(provider_config["id"])
             if provider_config["enable"]:
                 await self.load_provider(provider_config)
 
             # 和配置文件保持同步
+            self.providers_config = astrbot_config["provider"]
             config_ids = [provider["id"] for provider in self.providers_config]
-        logger.debug(f"providers in user's config: {config_ids}")
+            logger.info(f"providers in user's config: {config_ids}")
             for key in list(self.inst_map.keys()):
                 if key not in config_ids:
                     await self.terminate_provider(key)
@@ -455,7 +459,9 @@ class ProviderManager:
 
             if len(self.stt_provider_insts) == 0:
                 self.curr_stt_provider_inst = None
-        elif self.curr_stt_provider_inst is None and len(self.stt_provider_insts) > 0:
+            elif (
+                self.curr_stt_provider_inst is None and len(self.stt_provider_insts) > 0
+            ):
                 self.curr_stt_provider_inst = self.stt_provider_insts[0]
                 logger.info(
                     f"自动选择 {self.curr_stt_provider_inst.meta().id} 作为当前语音转文本提供商适配器。",
@@ -463,7 +469,9 @@ class ProviderManager:
 
             if len(self.tts_provider_insts) == 0:
                 self.curr_tts_provider_inst = None
-        elif self.curr_tts_provider_inst is None and len(self.tts_provider_insts) > 0:
+            elif (
+                self.curr_tts_provider_inst is None and len(self.tts_provider_insts) > 0
+            ):
                 self.curr_tts_provider_inst = self.tts_provider_insts[0]
                 logger.info(
                     f"自动选择 {self.curr_tts_provider_inst.meta().id} 作为当前文本转语音提供商适配器。",

astrbot/core/provider/sources/anthropic_source.py

@@ -290,7 +290,7 @@ class ProviderAnthropic(Provider):
         try:
             llm_response = await self._query(payloads, func_tool)
         except Exception as e:
-            logger.error(f"发生了错误。Provider 配置如下: {model_config}")
+            # logger.error(f"发生了错误。Provider 配置如下: {model_config}")
             raise e
 
         return llm_response

astrbot/core/provider/sources/gemini_source.py

@@ -111,9 +111,9 @@ class ProviderGoogleGenAI(Provider):
                 f"检测到 Key 异常({e.message})，且已没有可用的 Key。 当前 Key: {self.chosen_api_key[:12]}...",
             )
             raise Exception("达到了 Gemini 速率限制, 请稍后再试...")
-        logger.error(
-            f"发生了错误(gemini_source)。Provider 配置如下: {self.provider_config}",
-        )
+        # logger.error(
+        #     f"发生了错误(gemini_source)。Provider 配置如下: {self.provider_config}",
+        # )
         raise e
 
     async def _prepare_query_config(

astrbot/core/provider/sources/openai_source.py

@@ -433,7 +433,7 @@ class ProviderOpenAIOfficial(Provider):
             )
             payloads.pop("tools", None)
             return False, chosen_key, available_api_keys, payloads, context_query, None
-        logger.error(f"发生了错误。Provider 配置如下: {self.provider_config}")
+        # logger.error(f"发生了错误。Provider 配置如下: {self.provider_config}")
 
         if "tool" in str(e).lower() and "support" in str(e).lower():
             logger.error("疑似该模型不支持函数调用工具调用。请输入 /tool off_all")

astrbot/core/star/session_llm_manager.py

@@ -171,110 +171,3 @@ class SessionServiceManager:
 
         # 如果没有配置，默认为启用（兼容性考虑）
         return True
-
-    @staticmethod
-    def set_session_status(session_id: str, enabled: bool) -> None:
-        """设置会话的整体启停状态
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-            enabled: True表示启用，False表示禁用
-
-        """
-        session_config = (
-            sp.get("session_service_config", {}, scope="umo", scope_id=session_id) or {}
-        )
-        session_config["session_enabled"] = enabled
-        sp.put(
-            "session_service_config",
-            session_config,
-            scope="umo",
-            scope_id=session_id,
-        )
-
-        logger.info(
-            f"会话 {session_id} 的整体状态已更新为: {'启用' if enabled else '禁用'}",
-        )
-
-    @staticmethod
-    def should_process_session_request(event: AstrMessageEvent) -> bool:
-        """检查是否应该处理会话请求（会话整体启停检查）
-
-        Args:
-            event: 消息事件
-
-        Returns:
-            bool: True表示应该处理，False表示跳过
-
-        """
-        session_id = event.unified_msg_origin
-        return SessionServiceManager.is_session_enabled(session_id)
-
-    # =============================================================================
-    # 会话命名相关方法
-    # =============================================================================
-
-    @staticmethod
-    def get_session_custom_name(session_id: str) -> str | None:
-        """获取会话的自定义名称
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-
-        Returns:
-            str: 自定义名称，如果没有设置则返回None
-
-        """
-        session_services = sp.get(
-            "session_service_config",
-            {},
-            scope="umo",
-            scope_id=session_id,
-        )
-        return session_services.get("custom_name")
-
-    @staticmethod
-    def set_session_custom_name(session_id: str, custom_name: str) -> None:
-        """设置会话的自定义名称
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-            custom_name: 自定义名称，可以为空字符串来清除名称
-
-        """
-        session_config = (
-            sp.get("session_service_config", {}, scope="umo", scope_id=session_id) or {}
-        )
-        if custom_name and custom_name.strip():
-            session_config["custom_name"] = custom_name.strip()
-        else:
-            # 如果传入空名称，则删除自定义名称
-            session_config.pop("custom_name", None)
-        sp.put(
-            "session_service_config",
-            session_config,
-            scope="umo",
-            scope_id=session_id,
-        )
-
-        logger.info(
-            f"会话 {session_id} 的自定义名称已更新为: {custom_name.strip() if custom_name and custom_name.strip() else '已清除'}",
-        )
-
-    @staticmethod
-    def get_session_display_name(session_id: str) -> str:
-        """获取会话的显示名称（优先显示自定义名称，否则显示原始session_id的最后一段）
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-
-        Returns:
-            str: 显示名称
-
-        """
-        custom_name = SessionServiceManager.get_session_custom_name(session_id)
-        if custom_name:
-            return custom_name
-
-        # 如果没有自定义名称，返回session_id的最后一段
-        return session_id.split(":")[2] if session_id.count(":") >= 2 else session_id

astrbot/core/star/session_plugin_manager.py

@@ -42,87 +42,6 @@ class SessionPluginManager:
         # 如果都没有配置，默认为启用（兼容性考虑）
         return True
 
-    @staticmethod
-    def set_plugin_status_for_session(
-        session_id: str,
-        plugin_name: str,
-        enabled: bool,
-    ) -> None:
-        """设置插件在指定会话中的启停状态
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-            plugin_name: 插件名称
-            enabled: True表示启用，False表示禁用
-
-        """
-        # 获取当前配置
-        session_plugin_config = sp.get(
-            "session_plugin_config",
-            {},
-            scope="umo",
-            scope_id=session_id,
-        )
-        if session_id not in session_plugin_config:
-            session_plugin_config[session_id] = {
-                "enabled_plugins": [],
-                "disabled_plugins": [],
-            }
-
-        session_config = session_plugin_config[session_id]
-        enabled_plugins = session_config.get("enabled_plugins", [])
-        disabled_plugins = session_config.get("disabled_plugins", [])
-
-        if enabled:
-            # 启用插件
-            if plugin_name in disabled_plugins:
-                disabled_plugins.remove(plugin_name)
-            if plugin_name not in enabled_plugins:
-                enabled_plugins.append(plugin_name)
-        else:
-            # 禁用插件
-            if plugin_name in enabled_plugins:
-                enabled_plugins.remove(plugin_name)
-            if plugin_name not in disabled_plugins:
-                disabled_plugins.append(plugin_name)
-
-        # 保存配置
-        session_config["enabled_plugins"] = enabled_plugins
-        session_config["disabled_plugins"] = disabled_plugins
-        session_plugin_config[session_id] = session_config
-        sp.put(
-            "session_plugin_config",
-            session_plugin_config,
-            scope="umo",
-            scope_id=session_id,
-        )
-
-        logger.info(
-            f"会话 {session_id} 的插件 {plugin_name} 状态已更新为: {'启用' if enabled else '禁用'}",
-        )
-
-    @staticmethod
-    def get_session_plugin_config(session_id: str) -> dict[str, list[str]]:
-        """获取指定会话的插件配置
-
-        Args:
-            session_id: 会话ID (unified_msg_origin)
-
-        Returns:
-            Dict[str, List[str]]: 包含enabled_plugins和disabled_plugins的字典
-
-        """
-        session_plugin_config = sp.get(
-            "session_plugin_config",
-            {},
-            scope="umo",
-            scope_id=session_id,
-        )
-        return session_plugin_config.get(
-            session_id,
-            {"enabled_plugins": [], "disabled_plugins": []},
-        )
-
     @staticmethod
     def filter_handlers_by_session(event: AstrMessageEvent, handlers: list) -> list:
         """根据会话配置过滤处理器列表

astrbot/dashboard/routes/knowledge_base.py

@@ -60,10 +60,6 @@ class KnowledgeBaseRoute(Route):
             # "/kb/media/delete": ("POST", self.delete_media),
             # 检索
             "/kb/retrieve": ("POST", self.retrieve),
-            # 会话知识库配置
-            "/kb/session/config/get": ("GET", self.get_session_kb_config),
-            "/kb/session/config/set": ("POST", self.set_session_kb_config),
-            "/kb/session/config/delete": ("POST", self.delete_session_kb_config),
         }
         self.register_routes()
 
@@ -920,158 +916,6 @@ class KnowledgeBaseRoute(Route):
             logger.error(traceback.format_exc())
             return Response().error(f"检索失败: {e!s}").__dict__
 
-    # ===== 会话知识库配置 API =====
-
-    async def get_session_kb_config(self):
-        """获取会话的知识库配置
-
-        Query 参数:
-        - session_id: 会话 ID (必填)
-
-        返回:
-        - kb_ids: 知识库 ID 列表
-        - top_k: 返回结果数量
-        - enable_rerank: 是否启用重排序
-        """
-        try:
-            from astrbot.core import sp
-
-            session_id = request.args.get("session_id")
-
-            if not session_id:
-                return Response().error("缺少参数 session_id").__dict__
-
-            # 从 SharedPreferences 获取配置
-            config = await sp.session_get(session_id, "kb_config", default={})
-
-            logger.debug(f"[KB配置] 读取到配置: session_id={session_id}")
-
-            # 如果没有配置，返回默认值
-            if not config:
-                config = {"kb_ids": [], "top_k": 5, "enable_rerank": True}
-
-            return Response().ok(config).__dict__
-
-        except Exception as e:
-            logger.error(f"[KB配置] 获取配置时出错: {e}", exc_info=True)
-            return Response().error(f"获取会话知识库配置失败: {e!s}").__dict__
-
-    async def set_session_kb_config(self):
-        """设置会话的知识库配置
-
-        Body:
-        - scope: 配置范围 (目前只支持 "session")
-        - scope_id: 会话 ID (必填)
-        - kb_ids: 知识库 ID 列表 (必填)
-        - top_k: 返回结果数量 (可选, 默认 5)
-        - enable_rerank: 是否启用重排序 (可选, 默认 true)
-        """
-        try:
-            from astrbot.core import sp
-
-            data = await request.json
-
-            scope = data.get("scope")
-            scope_id = data.get("scope_id")
-            kb_ids = data.get("kb_ids", [])
-            top_k = data.get("top_k", 5)
-            enable_rerank = data.get("enable_rerank", True)
-
-            # 验证参数
-            if scope != "session":
-                return Response().error("目前仅支持 session 范围的配置").__dict__
-
-            if not scope_id:
-                return Response().error("缺少参数 scope_id").__dict__
-
-            if not isinstance(kb_ids, list):
-                return Response().error("kb_ids 必须是列表").__dict__
-
-            # 验证知识库是否存在
-            kb_mgr = self._get_kb_manager()
-            invalid_ids = []
-            valid_ids = []
-            for kb_id in kb_ids:
-                kb_helper = await kb_mgr.get_kb(kb_id)
-                if kb_helper:
-                    valid_ids.append(kb_id)
-                else:
-                    invalid_ids.append(kb_id)
-                    logger.warning(f"[KB配置] 知识库不存在: {kb_id}")
-
-            if invalid_ids:
-                logger.warning(f"[KB配置] 以下知识库ID无效: {invalid_ids}")
-
-            # 允许保存空列表，表示明确不使用任何知识库
-            if kb_ids and not valid_ids:
-                # 只有当用户提供了 kb_ids 但全部无效时才报错
-                return Response().error(f"所有提供的知识库ID都无效: {kb_ids}").__dict__
-
-            # 如果 kb_ids 为空列表，表示用户想清空配置
-            if not kb_ids:
-                valid_ids = []
-
-            # 构建配置对象（只保存有效的ID）
-            config = {
-                "kb_ids": valid_ids,
-                "top_k": top_k,
-                "enable_rerank": enable_rerank,
-            }
-
-            # 保存到 SharedPreferences
-            await sp.session_put(scope_id, "kb_config", config)
-
-            # 立即验证是否保存成功
-            verify_config = await sp.session_get(scope_id, "kb_config", default={})
-
-            if verify_config == config:
-                return (
-                    Response()
-                    .ok(
-                        {"valid_ids": valid_ids, "invalid_ids": invalid_ids},
-                        "保存知识库配置成功",
-                    )
-                    .__dict__
-                )
-            logger.error("[KB配置] 配置保存失败，验证不匹配")
-            return Response().error("配置保存失败").__dict__
-
-        except Exception as e:
-            logger.error(f"[KB配置] 设置配置时出错: {e}", exc_info=True)
-            return Response().error(f"设置会话知识库配置失败: {e!s}").__dict__
-
-    async def delete_session_kb_config(self):
-        """删除会话的知识库配置
-
-        Body:
-        - scope: 配置范围 (目前只支持 "session")
-        - scope_id: 会话 ID (必填)
-        """
-        try:
-            from astrbot.core import sp
-
-            data = await request.json
-
-            scope = data.get("scope")
-            scope_id = data.get("scope_id")
-
-            # 验证参数
-            if scope != "session":
-                return Response().error("目前仅支持 session 范围的配置").__dict__
-
-            if not scope_id:
-                return Response().error("缺少参数 scope_id").__dict__
-
-            # 从 SharedPreferences 删除配置
-            await sp.session_remove(scope_id, "kb_config")
-
-            return Response().ok(message="删除知识库配置成功").__dict__
-
-        except Exception as e:
-            logger.error(f"删除会话知识库配置失败: {e}")
-            logger.error(traceback.format_exc())
-            return Response().error(f"删除会话知识库配置失败: {e!s}").__dict__
-
     async def upload_document_from_url(self):
         """从 URL 上传文档
 

astrbot/dashboard/routes/plugin.py

@@ -1,3 +1,4 @@
+import asyncio
 import json
 import os
 import ssl
@@ -19,6 +20,10 @@ from astrbot.core.star.star_manager import PluginManager
 
 from .route import Response, Route, RouteContext
 
+PLUGIN_UPDATE_CONCURRENCY = (
+    3  # limit concurrent updates to avoid overwhelming plugin sources
+)
+
 
 class PluginRoute(Route):
     def __init__(
@@ -33,6 +38,7 @@ class PluginRoute(Route):
             "/plugin/install": ("POST", self.install_plugin),
             "/plugin/install-upload": ("POST", self.install_plugin_upload),
             "/plugin/update": ("POST", self.update_plugin),
+            "/plugin/update-all": ("POST", self.update_all_plugins),
             "/plugin/uninstall": ("POST", self.uninstall_plugin),
             "/plugin/market_list": ("GET", self.get_online_plugins),
             "/plugin/off": ("POST", self.off_plugin),
@@ -63,7 +69,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        data = await request.json
+        data = await request.get_json()
         plugin_name = data.get("name", None)
         try:
             success, message = await self.plugin_manager.reload(plugin_name)
@@ -346,7 +352,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        post_data = await request.json
+        post_data = await request.get_json()
         repo_url = post_data["url"]
 
         proxy: str = post_data.get("proxy", None)
@@ -393,7 +399,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        post_data = await request.json
+        post_data = await request.get_json()
         plugin_name = post_data["name"]
         delete_config = post_data.get("delete_config", False)
         delete_data = post_data.get("delete_data", False)
@@ -418,7 +424,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        post_data = await request.json
+        post_data = await request.get_json()
         plugin_name = post_data["name"]
         proxy: str = post_data.get("proxy", None)
         try:
@@ -432,6 +438,59 @@ class PluginRoute(Route):
             logger.error(f"/api/plugin/update: {traceback.format_exc()}")
             return Response().error(str(e)).__dict__
 
+    async def update_all_plugins(self):
+        if DEMO_MODE:
+            return (
+                Response()
+                .error("You are not permitted to do this operation in demo mode")
+                .__dict__
+            )
+
+        post_data = await request.get_json()
+        plugin_names: list[str] = post_data.get("names") or []
+        proxy: str = post_data.get("proxy", "")
+
+        if not isinstance(plugin_names, list) or not plugin_names:
+            return Response().error("插件列表不能为空").__dict__
+
+        results = []
+        sem = asyncio.Semaphore(PLUGIN_UPDATE_CONCURRENCY)
+
+        async def _update_one(name: str):
+            async with sem:
+                try:
+                    logger.info(f"批量更新插件 {name}")
+                    await self.plugin_manager.update_plugin(name, proxy)
+                    return {"name": name, "status": "ok", "message": "更新成功"}
+                except Exception as e:
+                    logger.error(
+                        f"/api/plugin/update-all: 更新插件 {name} 失败: {traceback.format_exc()}",
+                    )
+                    return {"name": name, "status": "error", "message": str(e)}
+
+        raw_results = await asyncio.gather(
+            *(_update_one(name) for name in plugin_names),
+            return_exceptions=True,
+        )
+        for name, result in zip(plugin_names, raw_results):
+            if isinstance(result, asyncio.CancelledError):
+                raise result
+            if isinstance(result, BaseException):
+                results.append(
+                    {"name": name, "status": "error", "message": str(result)}
+                )
+            else:
+                results.append(result)
+
+        failed = [r for r in results if r["status"] == "error"]
+        message = (
+            "批量更新完成，全部成功。"
+            if not failed
+            else f"批量更新完成，其中 {len(failed)}/{len(results)} 个插件失败。"
+        )
+
+        return Response().ok({"results": results}, message).__dict__
+
     async def off_plugin(self):
         if DEMO_MODE:
             return (
@@ -440,7 +499,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        post_data = await request.json
+        post_data = await request.get_json()
         plugin_name = post_data["name"]
         try:
             await self.plugin_manager.turn_off_plugin(plugin_name)
@@ -458,7 +517,7 @@ class PluginRoute(Route):
                 .__dict__
             )
 
-        post_data = await request.json
+        post_data = await request.get_json()
         plugin_name = post_data["name"]
         try:
             await self.plugin_manager.turn_on_plugin(plugin_name)

astrbot/dashboard/routes/session_management.py

@@ -1,16 +1,24 @@
-import traceback
-
 from quart import request
+from sqlalchemy.ext.asyncio import AsyncSession
+from sqlmodel import col, select
 
 from astrbot.core import logger, sp
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
 from astrbot.core.db import BaseDatabase
+from astrbot.core.db.po import ConversationV2, Preference
 from astrbot.core.provider.entities import ProviderType
-from astrbot.core.star.session_llm_manager import SessionServiceManager
-from astrbot.core.star.session_plugin_manager import SessionPluginManager
 
 from .route import Response, Route, RouteContext
 
+AVAILABLE_SESSION_RULE_KEYS = [
+    "session_service_config",
+    "session_plugin_config",
+    "kb_config",
+    f"provider_perf_{ProviderType.CHAT_COMPLETION.value}",
+    f"provider_perf_{ProviderType.SPEECH_TO_TEXT.value}",
+    f"provider_perf_{ProviderType.TEXT_TO_SPEECH.value}",
+]
+
 
 class SessionManagementRoute(Route):
     def __init__(
@@ -22,667 +30,364 @@ class SessionManagementRoute(Route):
         super().__init__(context)
         self.db_helper = db_helper
         self.routes = {
-            "/session/list": ("GET", self.list_sessions),
-            "/session/update_persona": ("POST", self.update_session_persona),
-            "/session/update_provider": ("POST", self.update_session_provider),
-            "/session/plugins": ("GET", self.get_session_plugins),
-            "/session/update_plugin": ("POST", self.update_session_plugin),
-            "/session/update_llm": ("POST", self.update_session_llm),
-            "/session/update_tts": ("POST", self.update_session_tts),
-            "/session/update_name": ("POST", self.update_session_name),
-            "/session/update_status": ("POST", self.update_session_status),
-            "/session/delete": ("POST", self.delete_session),
+            "/session/list-rule": ("GET", self.list_session_rule),
+            "/session/update-rule": ("POST", self.update_session_rule),
+            "/session/delete-rule": ("POST", self.delete_session_rule),
+            "/session/batch-delete-rule": ("POST", self.batch_delete_session_rule),
+            "/session/active-umos": ("GET", self.list_umos),
         }
         self.conv_mgr = core_lifecycle.conversation_manager
         self.core_lifecycle = core_lifecycle
         self.register_routes()
 
-    async def list_sessions(self):
-        """获取所有会话的列表，包括 persona 和 provider 信息"""
-        try:
-            page = int(request.args.get("page", 1))
-            page_size = int(request.args.get("page_size", 20))
-            search_query = request.args.get("search", "")
-            platform = request.args.get("platform", "")
+    async def _get_umo_rules(
+        self, page: int = 1, page_size: int = 10, search: str = ""
+    ) -> tuple[dict, int]:
+        """获取所有带有自定义规则的 umo 及其规则内容（支持分页和搜索）。
 
-            # 获取活跃的会话数据（处于对话内的会话）
-            sessions_data, total = await self.db_helper.get_session_conversations(
-                page,
-                page_size,
-                search_query,
-                platform,
+        如果某个 umo 在 preference 中有以下字段，则表示有自定义规则：
+
+        1. session_service_config (包含了 是否启用这个umo, 这个umo是否启用 llm, 这个umo是否启用tts, umo自定义名称。)
+        2. session_plugin_config (包含了 这个 umo 的 plugin set)
+        3. provider_perf_{ProviderType.value} (包含了这个 umo 所选择使用的 provider 信息)
+        4. kb_config (包含了这个 umo 的知识库相关配置)
+
+        Args:
+            page: 页码，从 1 开始
+            page_size: 每页数量
+            search: 搜索关键词，匹配 umo 或 custom_name
+
+        Returns:
+            tuple[dict, int]: (umo_rules, total) - 分页后的 umo 规则和总数
+        """
+        umo_rules = {}
+        async with self.db_helper.get_db() as session:
+            session: AsyncSession
+            result = await session.execute(
+                select(Preference).where(
+                    col(Preference.scope) == "umo",
+                    col(Preference.key).in_(AVAILABLE_SESSION_RULE_KEYS),
+                )
+            )
+            prefs = result.scalars().all()
+            for pref in prefs:
+                umo_id = pref.scope_id
+                if umo_id not in umo_rules:
+                    umo_rules[umo_id] = {}
+                if pref.key == "session_plugin_config" and umo_id in pref.value["val"]:
+                    umo_rules[umo_id][pref.key] = pref.value["val"][umo_id]
+                else:
+                    umo_rules[umo_id][pref.key] = pref.value["val"]
+
+        # 搜索过滤
+        if search:
+            search_lower = search.lower()
+            filtered_rules = {}
+            for umo_id, rules in umo_rules.items():
+                # 匹配 umo
+                if search_lower in umo_id.lower():
+                    filtered_rules[umo_id] = rules
+                    continue
+                # 匹配 custom_name
+                svc_config = rules.get("session_service_config", {})
+                custom_name = svc_config.get("custom_name", "") if svc_config else ""
+                if custom_name and search_lower in custom_name.lower():
+                    filtered_rules[umo_id] = rules
+            umo_rules = filtered_rules
+
+        # 获取总数
+        total = len(umo_rules)
+
+        # 分页处理
+        all_umo_ids = list(umo_rules.keys())
+        start_idx = (page - 1) * page_size
+        end_idx = start_idx + page_size
+        paginated_umo_ids = all_umo_ids[start_idx:end_idx]
+
+        # 只返回分页后的数据
+        paginated_rules = {umo_id: umo_rules[umo_id] for umo_id in paginated_umo_ids}
+
+        return paginated_rules, total
+
+    async def list_session_rule(self):
+        """获取所有自定义的规则（支持分页和搜索）
+
+        返回已配置规则的 umo 列表及其规则内容，以及可用的 personas 和 providers
+
+        Query 参数:
+            page: 页码，默认为 1
+            page_size: 每页数量，默认为 10
+            search: 搜索关键词，匹配 umo 或 custom_name
+        """
+        try:
+            # 获取分页和搜索参数
+            page = request.args.get("page", 1, type=int)
+            page_size = request.args.get("page_size", 10, type=int)
+            search = request.args.get("search", "", type=str).strip()
+
+            # 参数校验
+            if page < 1:
+                page = 1
+            if page_size < 1:
+                page_size = 10
+            if page_size > 100:
+                page_size = 100
+
+            umo_rules, total = await self._get_umo_rules(
+                page=page, page_size=page_size, search=search
             )
 
+            # 构建规则列表
+            rules_list = []
+            for umo, rules in umo_rules.items():
+                rule_info = {
+                    "umo": umo,
+                    "rules": rules,
+                }
+                # 解析 umo 格式: 平台:消息类型:会话ID
+                parts = umo.split(":")
+                if len(parts) >= 3:
+                    rule_info["platform"] = parts[0]
+                    rule_info["message_type"] = parts[1]
+                    rule_info["session_id"] = parts[2]
+                rules_list.append(rule_info)
+
+            # 获取可用的 providers 和 personas
             provider_manager = self.core_lifecycle.provider_manager
             persona_mgr = self.core_lifecycle.persona_mgr
-            personas = persona_mgr.personas_v3
 
-            sessions = []
-
-            # 循环补充非数据库信息，如 provider 和 session 状态
-            for data in sessions_data:
-                session_id = data["session_id"]
-                conversation_id = data["conversation_id"]
-                conv_persona_id = data["persona_id"]
-                title = data["title"]
-                persona_name = data["persona_name"]
-
-                # 处理 persona 显示
-                if persona_name is None:
-                    if conv_persona_id is None:
-                        if default_persona := persona_mgr.selected_default_persona_v3:
-                            persona_name = default_persona["name"]
-                    else:
-                        persona_name = "[%None]"
-
-                session_info = {
-                    "session_id": session_id,
-                    "conversation_id": conversation_id,
-                    "persona_id": persona_name,
-                    "chat_provider_id": None,
-                    "stt_provider_id": None,
-                    "tts_provider_id": None,
-                    "session_enabled": SessionServiceManager.is_session_enabled(
-                        session_id,
-                    ),
-                    "llm_enabled": SessionServiceManager.is_llm_enabled_for_session(
-                        session_id,
-                    ),
-                    "tts_enabled": SessionServiceManager.is_tts_enabled_for_session(
-                        session_id,
-                    ),
-                    "platform": session_id.split(":")[0]
-                    if ":" in session_id
-                    else "unknown",
-                    "message_type": session_id.split(":")[1]
-                    if session_id.count(":") >= 1
-                    else "unknown",
-                    "session_name": SessionServiceManager.get_session_display_name(
-                        session_id,
-                    ),
-                    "session_raw_name": session_id.split(":")[2]
-                    if session_id.count(":") >= 2
-                    else session_id,
-                    "title": title,
-                }
-
-                # 获取 provider 信息
-                chat_provider = provider_manager.get_using_provider(
-                    provider_type=ProviderType.CHAT_COMPLETION,
-                    umo=session_id,
-                )
-                tts_provider = provider_manager.get_using_provider(
-                    provider_type=ProviderType.TEXT_TO_SPEECH,
-                    umo=session_id,
-                )
-                stt_provider = provider_manager.get_using_provider(
-                    provider_type=ProviderType.SPEECH_TO_TEXT,
-                    umo=session_id,
-                )
-                if chat_provider:
-                    meta = chat_provider.meta()
-                    session_info["chat_provider_id"] = meta.id
-                if tts_provider:
-                    meta = tts_provider.meta()
-                    session_info["tts_provider_id"] = meta.id
-                if stt_provider:
-                    meta = stt_provider.meta()
-                    session_info["stt_provider_id"] = meta.id
-
-                sessions.append(session_info)
-
-            # 获取可用的 personas 和 providers 列表
             available_personas = [
-                {"name": p["name"], "prompt": p.get("prompt", "")} for p in personas
+                {"name": p["name"], "prompt": p.get("prompt", "")}
+                for p in persona_mgr.personas_v3
             ]
 
-            available_chat_providers = []
-            for provider in provider_manager.provider_insts:
-                meta = provider.meta()
-                available_chat_providers.append(
+            available_chat_providers = [
                 {
-                        "id": meta.id,
-                        "name": meta.id,
-                        "model": meta.model,
-                        "type": meta.type,
-                    },
-                )
+                    "id": p.meta().id,
+                    "name": p.meta().id,
+                    "model": p.meta().model,
+                }
+                for p in provider_manager.provider_insts
+            ]
 
-            available_stt_providers = []
-            for provider in provider_manager.stt_provider_insts:
-                meta = provider.meta()
-                available_stt_providers.append(
+            available_stt_providers = [
                 {
-                        "id": meta.id,
-                        "name": meta.id,
-                        "model": meta.model,
-                        "type": meta.type,
-                    },
-                )
+                    "id": p.meta().id,
+                    "name": p.meta().id,
+                    "model": p.meta().model,
+                }
+                for p in provider_manager.stt_provider_insts
+            ]
 
-            available_tts_providers = []
-            for provider in provider_manager.tts_provider_insts:
-                meta = provider.meta()
-                available_tts_providers.append(
+            available_tts_providers = [
                 {
-                        "id": meta.id,
-                        "name": meta.id,
-                        "model": meta.model,
-                        "type": meta.type,
-                    },
-                )
+                    "id": p.meta().id,
+                    "name": p.meta().id,
+                    "model": p.meta().model,
+                }
+                for p in provider_manager.tts_provider_insts
+            ]
 
-            result = {
-                "sessions": sessions,
+            # 获取可用的插件列表（排除 reserved 的系统插件）
+            plugin_manager = self.core_lifecycle.plugin_manager
+            available_plugins = [
+                {
+                    "name": p.name,
+                    "display_name": p.display_name or p.name,
+                    "desc": p.desc,
+                }
+                for p in plugin_manager.context.get_all_stars()
+                if not p.reserved and p.name
+            ]
+
+            # 获取可用的知识库列表
+            available_kbs = []
+            kb_manager = self.core_lifecycle.kb_manager
+            if kb_manager:
+                try:
+                    kbs = await kb_manager.list_kbs()
+                    available_kbs = [
+                        {
+                            "kb_id": kb.kb_id,
+                            "kb_name": kb.kb_name,
+                            "emoji": kb.emoji,
+                        }
+                        for kb in kbs
+                    ]
+                except Exception as e:
+                    logger.warning(f"获取知识库列表失败: {e!s}")
+
+            return (
+                Response()
+                .ok(
+                    {
+                        "rules": rules_list,
+                        "total": total,
+                        "page": page,
+                        "page_size": page_size,
                         "available_personas": available_personas,
                         "available_chat_providers": available_chat_providers,
                         "available_stt_providers": available_stt_providers,
                         "available_tts_providers": available_tts_providers,
-                "pagination": {
-                    "page": page,
-                    "page_size": page_size,
-                    "total": total,
-                    "total_pages": (total + page_size - 1) // page_size
-                    if page_size > 0
-                    else 0,
-                },
+                        "available_plugins": available_plugins,
+                        "available_kbs": available_kbs,
+                        "available_rule_keys": AVAILABLE_SESSION_RULE_KEYS,
+                    }
+                )
+                .__dict__
+            )
+        except Exception as e:
+            logger.error(f"获取规则列表失败: {e!s}")
+            return Response().error(f"获取规则列表失败: {e!s}").__dict__
+
+    async def update_session_rule(self):
+        """更新某个 umo 的自定义规则
+
+        请求体:
+        {
+            "umo": "平台:消息类型:会话ID",
+            "rule_key": "session_service_config" | "session_plugin_config" | "kb_config" | "provider_perf_xxx",
+            "rule_value": {...}  // 规则值，具体结构根据 rule_key 不同而不同
+        }
+        """
+        try:
+            data = await request.get_json()
+            umo = data.get("umo")
+            rule_key = data.get("rule_key")
+            rule_value = data.get("rule_value")
+
+            if not umo:
+                return Response().error("缺少必要参数: umo").__dict__
+            if not rule_key:
+                return Response().error("缺少必要参数: rule_key").__dict__
+            if rule_key not in AVAILABLE_SESSION_RULE_KEYS:
+                return Response().error(f"不支持的规则键: {rule_key}").__dict__
+
+            if rule_key == "session_plugin_config":
+                rule_value = {
+                    umo: rule_value,
                 }
 
-            return Response().ok(result).__dict__
+            # 使用 shared preferences 更新规则
+            await sp.session_put(umo, rule_key, rule_value)
 
-        except Exception as e:
-            error_msg = f"获取会话列表失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"获取会话列表失败: {e!s}").__dict__
-
-    async def _update_single_session_persona(self, session_id: str, persona_name: str):
-        """更新单个会话的 persona 的内部方法"""
-        conversation_manager = self.core_lifecycle.star_context.conversation_manager
-        conversation_id = await conversation_manager.get_curr_conversation_id(
-            session_id,
-        )
-
-        conv = None
-        if conversation_id:
-            conv = await conversation_manager.get_conversation(
-                unified_msg_origin=session_id,
-                conversation_id=conversation_id,
-            )
-        if not conv or not conversation_id:
-            conversation_id = await conversation_manager.new_conversation(session_id)
-
-        # 更新 persona
-        await conversation_manager.update_conversation_persona_id(
-            session_id,
-            persona_name,
-        )
-
-    async def _handle_batch_operation(
-        self,
-        session_ids: list,
-        operation_func,
-        operation_name: str,
-        **kwargs,
-    ):
-        """通用的批量操作处理方法"""
-        success_count = 0
-        error_sessions = []
-
-        for session_id in session_ids:
-            try:
-                await operation_func(session_id, **kwargs)
-                success_count += 1
-            except Exception as e:
-                logger.error(f"批量{operation_name} 会话 {session_id} 失败: {e!s}")
-                error_sessions.append(session_id)
-
-        if error_sessions:
             return (
                 Response()
-                .ok(
-                    {
-                        "message": f"批量更新完成，成功: {success_count}，失败: {len(error_sessions)}",
-                        "success_count": success_count,
-                        "error_count": len(error_sessions),
-                        "error_sessions": error_sessions,
-                    },
-                )
-                .__dict__
-            )
-        return (
-            Response()
-            .ok(
-                {
-                    "message": f"成功批量{operation_name} {success_count} 个会话",
-                    "success_count": success_count,
-                },
-            )
+                .ok({"message": f"规则 {rule_key} 已更新", "umo": umo})
                 .__dict__
             )
+        except Exception as e:
+            logger.error(f"更新会话规则失败: {e!s}")
+            return Response().error(f"更新会话规则失败: {e!s}").__dict__
 
-    async def update_session_persona(self):
-        """更新指定会话的 persona，支持批量操作"""
+    async def delete_session_rule(self):
+        """删除某个 umo 的自定义规则
+
+        请求体:
+        {
+            "umo": "平台:消息类型:会话ID",
+            "rule_key": "session_service_config" | "session_plugin_config" | ... (可选，不传则删除所有规则)
+        }
+        """
         try:
             data = await request.get_json()
-            is_batch = data.get("is_batch", False)
-            persona_name = data.get("persona_name")
+            umo = data.get("umo")
+            rule_key = data.get("rule_key")
 
-            if persona_name is None:
-                return Response().error("缺少必要参数: persona_name").__dict__
+            if not umo:
+                return Response().error("缺少必要参数: umo").__dict__
 
-            if is_batch:
-                session_ids = data.get("session_ids", [])
-                if not session_ids:
-                    return Response().error("缺少必要参数: session_ids").__dict__
-
-                return await self._handle_batch_operation(
-                    session_ids,
-                    self._update_single_session_persona,
-                    "更新人格",
-                    persona_name=persona_name,
+            if rule_key:
+                # 删除单个规则
+                if rule_key not in AVAILABLE_SESSION_RULE_KEYS:
+                    return Response().error(f"不支持的规则键: {rule_key}").__dict__
+                await sp.session_remove(umo, rule_key)
+                return (
+                    Response()
+                    .ok({"message": f"规则 {rule_key} 已删除", "umo": umo})
+                    .__dict__
                 )
-            session_id = data.get("session_id")
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
+            else:
+                # 删除该 umo 的所有规则
+                await sp.clear_async("umo", umo)
+                return Response().ok({"message": "所有规则已删除", "umo": umo}).__dict__
+        except Exception as e:
+            logger.error(f"删除会话规则失败: {e!s}")
+            return Response().error(f"删除会话规则失败: {e!s}").__dict__
 
-            await self._update_single_session_persona(session_id, persona_name)
+    async def batch_delete_session_rule(self):
+        """批量删除多个 umo 的自定义规则
+
+        请求体:
+        {
+            "umos": ["平台:消息类型:会话ID", ...]  // umo 列表
+        }
+        """
+        try:
+            data = await request.get_json()
+            umos = data.get("umos", [])
+
+            if not umos:
+                return Response().error("缺少必要参数: umos").__dict__
+
+            if not isinstance(umos, list):
+                return Response().error("参数 umos 必须是数组").__dict__
+
+            # 批量删除
+            deleted_count = 0
+            failed_umos = []
+            for umo in umos:
+                try:
+                    await sp.clear_async("umo", umo)
+                    deleted_count += 1
+                except Exception as e:
+                    logger.error(f"删除 umo {umo} 的规则失败: {e!s}")
+                    failed_umos.append(umo)
+
+            if failed_umos:
                 return (
                     Response()
                     .ok(
                         {
-                        "message": f"成功更新会话 {session_id} 的人格为 {persona_name}",
-                    },
+                            "message": f"已删除 {deleted_count} 条规则，{len(failed_umos)} 条删除失败",
+                            "deleted_count": deleted_count,
+                            "failed_umos": failed_umos,
+                        }
                     )
                     .__dict__
                 )
-
-        except Exception as e:
-            error_msg = f"更新会话人格失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话人格失败: {e!s}").__dict__
-
-    async def _update_single_session_provider(
-        self,
-        session_id: str,
-        provider_id: str,
-        provider_type_enum,
-    ):
-        """更新单个会话的 provider 的内部方法"""
-        provider_manager = self.core_lifecycle.star_context.provider_manager
-        await provider_manager.set_provider(
-            provider_id=provider_id,
-            provider_type=provider_type_enum,
-            umo=session_id,
-        )
-
-    async def update_session_provider(self):
-        """更新指定会话的 provider，支持批量操作"""
-        try:
-            data = await request.get_json()
-            is_batch = data.get("is_batch", False)
-            provider_id = data.get("provider_id")
-            provider_type = data.get("provider_type")
-
-            if not provider_id or not provider_type:
-                return (
-                    Response()
-                    .error("缺少必要参数: provider_id, provider_type")
-                    .__dict__
-                )
-
-            # 转换 provider_type 字符串为枚举
-            if provider_type == "chat_completion":
-                provider_type_enum = ProviderType.CHAT_COMPLETION
-            elif provider_type == "speech_to_text":
-                provider_type_enum = ProviderType.SPEECH_TO_TEXT
-            elif provider_type == "text_to_speech":
-                provider_type_enum = ProviderType.TEXT_TO_SPEECH
             else:
-                return (
-                    Response()
-                    .error(f"不支持的 provider_type: {provider_type}")
-                    .__dict__
-                )
-
-            if is_batch:
-                session_ids = data.get("session_ids", [])
-                if not session_ids:
-                    return Response().error("缺少必要参数: session_ids").__dict__
-
-                return await self._handle_batch_operation(
-                    session_ids,
-                    self._update_single_session_provider,
-                    f"更新 {provider_type} 提供商",
-                    provider_id=provider_id,
-                    provider_type_enum=provider_type_enum,
-                )
-            session_id = data.get("session_id")
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            await self._update_single_session_provider(
-                session_id,
-                provider_id,
-                provider_type_enum,
-            )
                 return (
                     Response()
                     .ok(
                         {
-                        "message": f"成功更新会话 {session_id} 的 {provider_type} 提供商为 {provider_id}",
-                    },
+                            "message": f"已删除 {deleted_count} 条规则",
+                            "deleted_count": deleted_count,
+                        }
                     )
                     .__dict__
                 )
-
         except Exception as e:
-            error_msg = f"更新会话提供商失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话提供商失败: {e!s}").__dict__
+            logger.error(f"批量删除会话规则失败: {e!s}")
+            return Response().error(f"批量删除会话规则失败: {e!s}").__dict__
 
-    async def get_session_plugins(self):
-        """获取指定会话的插件配置信息"""
+    async def list_umos(self):
+        """列出所有有对话记录的 umo，从 Conversations 表中找
+
+        仅返回 umo 字符串列表，用于用户在创建规则时选择 umo
+        """
         try:
-            session_id = request.args.get("session_id")
-
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            # 获取所有已激活的插件
-            all_plugins = []
-            plugin_manager = self.core_lifecycle.plugin_manager
-
-            for plugin in plugin_manager.context.get_all_stars():
-                # 只显示已激活的插件，不包括保留插件
-                if plugin.activated and not plugin.reserved:
-                    plugin_name = plugin.name or ""
-                    plugin_enabled = SessionPluginManager.is_plugin_enabled_for_session(
-                        session_id,
-                        plugin_name,
-                    )
-
-                    all_plugins.append(
-                        {
-                            "name": plugin_name,
-                            "author": plugin.author,
-                            "desc": plugin.desc,
-                            "enabled": plugin_enabled,
-                        },
-                    )
-
-            return (
-                Response()
-                .ok(
-                    {
-                        "session_id": session_id,
-                        "plugins": all_plugins,
-                    },
-                )
-                .__dict__
+            # 从 Conversation 表获取所有 distinct user_id (即 umo)
+            async with self.db_helper.get_db() as session:
+                session: AsyncSession
+                result = await session.execute(
+                    select(ConversationV2.user_id)
+                    .distinct()
+                    .order_by(ConversationV2.user_id)
                 )
+                umos = [row[0] for row in result.fetchall()]
 
+            return Response().ok({"umos": umos}).__dict__
         except Exception as e:
-            error_msg = f"获取会话插件配置失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"获取会话插件配置失败: {e!s}").__dict__
-
-    async def update_session_plugin(self):
-        """更新指定会话的插件启停状态"""
-        try:
-            data = await request.get_json()
-            session_id = data.get("session_id")
-            plugin_name = data.get("plugin_name")
-            enabled = data.get("enabled")
-
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            if not plugin_name:
-                return Response().error("缺少必要参数: plugin_name").__dict__
-
-            if enabled is None:
-                return Response().error("缺少必要参数: enabled").__dict__
-
-            # 验证插件是否存在且已激活
-            plugin_manager = self.core_lifecycle.plugin_manager
-            plugin = plugin_manager.context.get_registered_star(plugin_name)
-
-            if not plugin:
-                return Response().error(f"插件 {plugin_name} 不存在").__dict__
-
-            if not plugin.activated:
-                return Response().error(f"插件 {plugin_name} 未激活").__dict__
-
-            if plugin.reserved:
-                return (
-                    Response()
-                    .error(f"插件 {plugin_name} 是系统保留插件，无法管理")
-                    .__dict__
-                )
-
-            # 使用 SessionPluginManager 更新插件状态
-            SessionPluginManager.set_plugin_status_for_session(
-                session_id,
-                plugin_name,
-                enabled,
-            )
-
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"插件 {plugin_name} 已{'启用' if enabled else '禁用'}",
-                        "session_id": session_id,
-                        "plugin_name": plugin_name,
-                        "enabled": enabled,
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"更新会话插件状态失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话插件状态失败: {e!s}").__dict__
-
-    async def _update_single_session_llm(self, session_id: str, enabled: bool):
-        """更新单个会话的LLM状态的内部方法"""
-        SessionServiceManager.set_llm_status_for_session(session_id, enabled)
-
-    async def update_session_llm(self):
-        """更新指定会话的LLM启停状态，支持批量操作"""
-        try:
-            data = await request.get_json()
-            is_batch = data.get("is_batch", False)
-            enabled = data.get("enabled")
-
-            if enabled is None:
-                return Response().error("缺少必要参数: enabled").__dict__
-
-            if is_batch:
-                session_ids = data.get("session_ids", [])
-                if not session_ids:
-                    return Response().error("缺少必要参数: session_ids").__dict__
-
-                result = await self._handle_batch_operation(
-                    session_ids,
-                    self._update_single_session_llm,
-                    f"{'启用' if enabled else '禁用'}LLM",
-                    enabled=enabled,
-                )
-                return result
-            session_id = data.get("session_id")
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            await self._update_single_session_llm(session_id, enabled)
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"LLM已{'启用' if enabled else '禁用'}",
-                        "session_id": session_id,
-                        "llm_enabled": enabled,
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"更新会话LLM状态失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话LLM状态失败: {e!s}").__dict__
-
-    async def _update_single_session_tts(self, session_id: str, enabled: bool):
-        """更新单个会话的TTS状态的内部方法"""
-        SessionServiceManager.set_tts_status_for_session(session_id, enabled)
-
-    async def update_session_tts(self):
-        """更新指定会话的TTS启停状态，支持批量操作"""
-        try:
-            data = await request.get_json()
-            is_batch = data.get("is_batch", False)
-            enabled = data.get("enabled")
-
-            if enabled is None:
-                return Response().error("缺少必要参数: enabled").__dict__
-
-            if is_batch:
-                session_ids = data.get("session_ids", [])
-                if not session_ids:
-                    return Response().error("缺少必要参数: session_ids").__dict__
-
-                result = await self._handle_batch_operation(
-                    session_ids,
-                    self._update_single_session_tts,
-                    f"{'启用' if enabled else '禁用'}TTS",
-                    enabled=enabled,
-                )
-                return result
-            session_id = data.get("session_id")
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            await self._update_single_session_tts(session_id, enabled)
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"TTS已{'启用' if enabled else '禁用'}",
-                        "session_id": session_id,
-                        "tts_enabled": enabled,
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"更新会话TTS状态失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话TTS状态失败: {e!s}").__dict__
-
-    async def update_session_name(self):
-        """更新指定会话的自定义名称"""
-        try:
-            data = await request.get_json()
-            session_id = data.get("session_id")
-            custom_name = data.get("custom_name", "")
-
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            # 使用 SessionServiceManager 更新会话名称
-            SessionServiceManager.set_session_custom_name(session_id, custom_name)
-
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"会话名称已更新为: {custom_name if custom_name.strip() else '已清除自定义名称'}",
-                        "session_id": session_id,
-                        "custom_name": custom_name,
-                        "display_name": SessionServiceManager.get_session_display_name(
-                            session_id,
-                        ),
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"更新会话名称失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话名称失败: {e!s}").__dict__
-
-    async def update_session_status(self):
-        """更新指定会话的整体启停状态"""
-        try:
-            data = await request.get_json()
-            session_id = data.get("session_id")
-            session_enabled = data.get("session_enabled")
-
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            if session_enabled is None:
-                return Response().error("缺少必要参数: session_enabled").__dict__
-
-            # 使用 SessionServiceManager 更新会话整体状态
-            SessionServiceManager.set_session_status(session_id, session_enabled)
-
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"会话整体状态已更新为: {'启用' if session_enabled else '禁用'}",
-                        "session_id": session_id,
-                        "session_enabled": session_enabled,
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"更新会话整体状态失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"更新会话整体状态失败: {e!s}").__dict__
-
-    async def delete_session(self):
-        """删除指定会话及其所有相关数据"""
-        try:
-            data = await request.get_json()
-            session_id = data.get("session_id")
-
-            if not session_id:
-                return Response().error("缺少必要参数: session_id").__dict__
-
-            # 删除会话的所有相关数据
-            conversation_manager = self.core_lifecycle.conversation_manager
-
-            # 1. 删除会话的所有对话
-            try:
-                await conversation_manager.delete_conversations_by_user_id(session_id)
-            except Exception as e:
-                logger.warning(f"删除会话 {session_id} 的对话失败: {e!s}")
-
-            # 2. 清除会话的偏好设置数据（清空该会话的所有配置）
-            try:
-                await sp.clear_async("umo", session_id)
-            except Exception as e:
-                logger.warning(f"清除会话 {session_id} 的偏好设置失败: {e!s}")
-
-            return (
-                Response()
-                .ok(
-                    {
-                        "message": f"会话 {session_id} 及其相关所有对话数据已成功删除",
-                        "session_id": session_id,
-                    },
-                )
-                .__dict__
-            )
-
-        except Exception as e:
-            error_msg = f"删除会话失败: {e!s}\n{traceback.format_exc()}"
-            logger.error(error_msg)
-            return Response().error(f"删除会话失败: {e!s}").__dict__
+            logger.error(f"获取 UMO 列表失败: {e!s}")
+            return Response().error(f"获取 UMO 列表失败: {e!s}").__dict__

changelogs/v4.7.0.md

@@ -0,0 +1,18 @@
+## What's Changed
+
+重构：
+- 将 Dify、Coze、阿里云百炼应用等 LLMOps 提供商迁移到 Agent 执行器层，理清和本地 Agent 执行器的边界
+- 将「会话管理」功能重构为「自定义规则」功能，理清和多配置文件功能的边界。详见：[自定义规则](https://docs.astrbot.app/use/custom-rules.html)
+
+优化：
+- Dify、阿里云百炼应用支持流式输出
+- 防止分段回复正则表达式解析错误导致消息不发送
+- 群聊上下文感知记录 At 信息
+- 优化模型提供商页面的测试提供商功能
+
+新增：
+- 支持在配置文件页面快速测试对话
+- 为配置文件配置项内容添加国际化支持
+
+修复：
+- 在更新 MCP Server 配置后，MCP 无法正常重启的问题

changelogs/v4.7.1.md

@@ -0,0 +1,22 @@
+## What's Changed
+
+### 修复了自定义规则页面无法设置插件和知识库的规则的问题
+
+---
+
+重构：
+- 将 Dify、Coze、阿里云百炼应用等 LLMOps 提供商迁移到 Agent 执行器层，理清和本地 Agent 执行器的边界。详见：[Agent 执行器](https://docs.astrbot.app/use/agent-runner.html)
+- 将「会话管理」功能重构为「自定义规则」功能，理清和多配置文件功能的边界。详见：[自定义规则](https://docs.astrbot.app/use/custom-rules.html)
+
+优化：
+- Dify、阿里云百炼应用支持流式输出
+- 防止分段回复正则表达式解析错误导致消息不发送
+- 群聊上下文感知记录 At 信息
+- 优化模型提供商页面的测试提供商功能
+
+新增：
+- 支持在配置文件页面快速测试对话
+- 为配置文件配置项内容添加国际化支持
+
+修复：
+- 在更新 MCP Server 配置后，MCP 无法正常重启的问题

changelogs/v4.7.3.md

@@ -0,0 +1,25 @@
+## What's Changed
+
+1. 修复使用非默认配置文件情况下时，第三方 Agent Runner (Dify、Coze、阿里云百炼应用等)无法正常工作的问题
+2. 修复当“聊天模型”未设置，并且模型提供商中仅有 Agent Runner 时，无法正常使用 Agent Runner 的问题
+3. 修复部分情况下报错 `pydantic_core._pydantic_core.ValidationError: 1 validation error for Message content` 的问题
+4. 新增群聊模式下的专用图片转述模型配置 ([#3822](https://github.com/AstrBotDevs/AstrBot/issues/3822))
+
+---
+
+重构：
+- 将 Dify、Coze、阿里云百炼应用等 LLMOps 提供商迁移到 Agent 执行器层，理清和本地 Agent 执行器的边界。详见：[Agent 执行器](https://docs.astrbot.app/use/agent-runner.html)
+- 将「会话管理」功能重构为「自定义规则」功能，理清和多配置文件功能的边界。详见：[自定义规则](https://docs.astrbot.app/use/custom-rules.html)
+
+优化：
+- Dify、阿里云百炼应用支持流式输出
+- 防止分段回复正则表达式解析错误导致消息不发送
+- 群聊上下文感知记录 At 信息
+- 优化模型提供商页面的测试提供商功能
+
+新增：
+- 支持在配置文件页面快速测试对话
+- 为配置文件配置项内容添加国际化支持
+
+修复：
+- 在更新 MCP Server 配置后，MCP 无法正常重启的问题

dashboard/src/components/chat/Chat.vue

@@ -84,7 +84,7 @@
                         v-model:prompt="prompt"
                         :stagedImagesUrl="stagedImagesUrl"
                         :stagedAudioUrl="stagedAudioUrl"
-                        :disabled="isStreaming || isConvRunning"
+                        :disabled="isStreaming"
                         :enableStreaming="enableStreaming"
                         :isRecording="isRecording"
                         :session-id="currSessionId || null"

dashboard/src/components/chat/ChatInput.vue

@@ -15,6 +15,7 @@
                         :session-id="sessionId || null"
                         :platform-id="sessionPlatformId"
                         :is-group="sessionIsGroup"
+                        :initial-config-id="props.configId"
                         @config-changed="handleConfigChange"
                     />
                     <ProviderModelSelector v-if="showProviderSelector" ref="providerModelSelectorRef" />
@@ -79,11 +80,13 @@ interface Props {
     isRecording: boolean;
     sessionId?: string | null;
     currentSession?: Session | null;
+    configId?: string | null;
 }
 
 const props = withDefaults(defineProps<Props>(), {
     sessionId: null,
-    currentSession: null
+    currentSession: null,
+    configId: null
 });
 
 const emit = defineEmits<{

dashboard/src/components/chat/ConfigSelector.vue

@@ -90,10 +90,12 @@ const props = withDefaults(defineProps<{
     sessionId?: string | null;
     platformId?: string;
     isGroup?: boolean;
+    initialConfigId?: string | null;
 }>(), {
     sessionId: null,
     platformId: 'webchat',
-    isGroup: false
+    isGroup: false,
+    initialConfigId: null
 });
 
 const emit = defineEmits<{ 'config-changed': [ConfigChangedPayload] }>();
@@ -291,7 +293,7 @@ watch(
 
 onMounted(async () => {
     await fetchConfigList();
-    const stored = localStorage.getItem(STORAGE_KEY) || 'default';
+    const stored = props.initialConfigId || localStorage.getItem(STORAGE_KEY) || 'default';
     selectedConfigId.value = stored;
     await setSelection(stored);
     await syncSelectionForSession();

dashboard/src/components/chat/MessageList.vue

@@ -549,7 +549,7 @@ export default {
 }
 
 .bot-embedded-image {
-    max-width: 80%;
+    max-width: 40%;
     width: auto;
     height: auto;
     border-radius: 8px;
@@ -558,10 +558,6 @@ export default {
     transition: transform 0.2s ease;
 }
 
-.bot-embedded-image:hover {
-    transform: scale(1.02);
-}
-
 .embedded-audio {
     width: 300px;
     margin-top: 8px;

dashboard/src/components/chat/StandaloneChat.vue

@@ -0,0 +1,319 @@
+<template>
+    <v-card class="standalone-chat-card" elevation="0" rounded="0">
+        <v-card-text class="standalone-chat-container">
+            <div class="chat-layout">
+                <!-- 聊天内容区域 -->
+                <div class="chat-content-panel">
+                    <MessageList v-if="messages && messages.length > 0" :messages="messages" :isDark="isDark"
+                        :isStreaming="isStreaming || isConvRunning" @openImagePreview="openImagePreview"
+                        ref="messageList" />
+                    <div class="welcome-container fade-in" v-else>
+                        <div class="welcome-title">
+                            <span>Hello, I'm</span>
+                            <span class="bot-name">AstrBot ⭐</span>
+                        </div>
+                        <p class="text-caption text-medium-emphasis mt-2">
+                            测试配置: {{ configId || 'default' }}
+                        </p>
+                    </div>
+
+                    <!-- 输入区域 -->
+                    <ChatInput
+                        v-model:prompt="prompt"
+                        :stagedImagesUrl="stagedImagesUrl"
+                        :stagedAudioUrl="stagedAudioUrl"
+                        :disabled="isStreaming"
+                        :enableStreaming="enableStreaming"
+                        :isRecording="isRecording"
+                        :session-id="currSessionId || null"
+                        :current-session="getCurrentSession"
+                        :config-id="configId"
+                        @send="handleSendMessage"
+                        @toggleStreaming="toggleStreaming"
+                        @removeImage="removeImage"
+                        @removeAudio="removeAudio"
+                        @startRecording="handleStartRecording"
+                        @stopRecording="handleStopRecording"
+                        @pasteImage="handlePaste"
+                        @fileSelect="handleFileSelect"
+                        ref="chatInputRef"
+                    />
+                </div>
+            </div>
+        </v-card-text>
+    </v-card>
+
+    <!-- 图片预览对话框 -->
+    <v-dialog v-model="imagePreviewDialog" max-width="90vw" max-height="90vh">
+        <v-card class="image-preview-card" elevation="8">
+            <v-card-title class="d-flex justify-space-between align-center pa-4">
+                <span>{{ t('core.common.imagePreview') }}</span>
+                <v-btn icon="mdi-close" variant="text" @click="imagePreviewDialog = false" />
+            </v-card-title>
+            <v-card-text class="text-center pa-4">
+                <img :src="previewImageUrl" class="preview-image-large" />
+            </v-card-text>
+        </v-card>
+    </v-dialog>
+</template>
+
+<script setup lang="ts">
+import { ref, computed, onMounted, onBeforeUnmount, nextTick } from 'vue';
+import axios from 'axios';
+import { useCustomizerStore } from '@/stores/customizer';
+import { useI18n, useModuleI18n } from '@/i18n/composables';
+import { useTheme } from 'vuetify';
+import MessageList from '@/components/chat/MessageList.vue';
+import ChatInput from '@/components/chat/ChatInput.vue';
+import { useMessages } from '@/composables/useMessages';
+import { useMediaHandling } from '@/composables/useMediaHandling';
+import { useRecording } from '@/composables/useRecording';
+import { useToast } from '@/utils/toast';
+
+interface Props {
+    configId?: string | null;
+}
+
+const props = withDefaults(defineProps<Props>(), {
+    configId: null
+});
+
+const { t } = useI18n();
+const { error: showError } = useToast();
+
+// UI 状态
+const imagePreviewDialog = ref(false);
+const previewImageUrl = ref('');
+
+// 会话管理（不使用 useSessions 避免路由跳转）
+const currSessionId = ref('');
+const getCurrentSession = computed(() => null); // 独立测试模式不需要会话信息
+
+async function newSession() {
+    try {
+        const response = await axios.get('/api/chat/new_session');
+        const sessionId = response.data.data.session_id;
+        currSessionId.value = sessionId;
+        return sessionId;
+    } catch (err) {
+        console.error(err);
+        throw err;
+    }
+}
+
+function updateSessionTitle(sessionId: string, title: string) {
+    // 独立模式不需要更新会话标题
+}
+
+function getSessions() {
+    // 独立模式不需要加载会话列表
+}
+
+const {
+    stagedImagesName,
+    stagedImagesUrl,
+    stagedAudioUrl,
+    getMediaFile,
+    processAndUploadImage,
+    handlePaste,
+    removeImage,
+    removeAudio,
+    clearStaged,
+    cleanupMediaCache
+} = useMediaHandling();
+
+const { isRecording, startRecording: startRec, stopRecording: stopRec } = useRecording();
+
+const {
+    messages,
+    isStreaming,
+    isConvRunning,
+    enableStreaming,
+    getSessionMessages: getSessionMsg,
+    sendMessage: sendMsg,
+    toggleStreaming
+} = useMessages(currSessionId, getMediaFile, updateSessionTitle, getSessions);
+
+// 组件引用
+const messageList = ref<InstanceType<typeof MessageList> | null>(null);
+const chatInputRef = ref<InstanceType<typeof ChatInput> | null>(null);
+
+// 输入状态
+const prompt = ref('');
+
+const isDark = computed(() => useCustomizerStore().uiTheme === 'PurpleThemeDark');
+
+function openImagePreview(imageUrl: string) {
+    previewImageUrl.value = imageUrl;
+    imagePreviewDialog.value = true;
+}
+
+async function handleStartRecording() {
+    await startRec();
+}
+
+async function handleStopRecording() {
+    const audioFilename = await stopRec();
+    stagedAudioUrl.value = audioFilename;
+}
+
+async function handleFileSelect(files: FileList) {
+    for (const file of files) {
+        await processAndUploadImage(file);
+    }
+}
+
+async function handleSendMessage() {
+    if (!prompt.value.trim() && stagedImagesName.value.length === 0 && !stagedAudioUrl.value) {
+        return;
+    }
+
+    try {
+        if (!currSessionId.value) {
+            await newSession();
+        }
+
+        const promptToSend = prompt.value.trim();
+        const imageNamesToSend = [...stagedImagesName.value];
+        const audioNameToSend = stagedAudioUrl.value;
+
+        // 清空输入和附件
+        prompt.value = '';
+        clearStaged();
+
+        // 获取选择的提供商和模型
+        const selection = chatInputRef.value?.getCurrentSelection();
+        const selectedProviderId = selection?.providerId || '';
+        const selectedModelName = selection?.modelName || '';
+
+        await sendMsg(
+            promptToSend,
+            imageNamesToSend,
+            audioNameToSend,
+            selectedProviderId,
+            selectedModelName
+        );
+
+        // 滚动到底部
+        nextTick(() => {
+            messageList.value?.scrollToBottom();
+        });
+    } catch (err) {
+        console.error('Failed to send message:', err);
+        showError(t('features.chat.errors.sendMessageFailed'));
+        // 恢复输入内容，让用户可以重试
+        // 注意：附件已经上传到服务器，所以不恢复附件
+    }
+}
+
+onMounted(async () => {
+    // 独立模式在挂载时创建新会话
+    try {
+        await newSession();
+    } catch (err) {
+        console.error('Failed to create initial session:', err);
+        showError(t('features.chat.errors.createSessionFailed'));
+    }
+});
+
+onBeforeUnmount(() => {
+    cleanupMediaCache();
+});
+</script>
+
+<style scoped>
+/* 基础动画 */
+@keyframes fadeIn {
+    from {
+        opacity: 0;
+        transform: translateY(10px);
+    }
+    to {
+        opacity: 1;
+        transform: translateY(0);
+    }
+}
+
+.standalone-chat-card {
+    width: 100%;
+    height: 100%;
+    max-height: 100%;
+    overflow: hidden;
+}
+
+.standalone-chat-container {
+    width: 100%;
+    height: 100%;
+    max-height: 100%;
+    padding: 0;
+    overflow: hidden;
+}
+
+.chat-layout {
+    height: 100%;
+    max-height: 100%;
+    display: flex;
+    overflow: hidden;
+}
+
+.chat-content-panel {
+    height: 100%;
+    max-height: 100%;
+    width: 100%;
+    display: flex;
+    flex-direction: column;
+    overflow: hidden;
+}
+
+.conversation-header {
+    display: flex;
+    justify-content: space-between;
+    align-items: center;
+    padding: 8px;
+    padding-left: 16px;
+    border-bottom: 1px solid var(--v-theme-border);
+    width: 100%;
+    padding-right: 32px;
+    flex-shrink: 0;
+}
+
+.conversation-header-info h4 {
+    margin: 0;
+    font-weight: 500;
+}
+
+.conversation-header-actions {
+    display: flex;
+    gap: 8px;
+    align-items: center;
+}
+
+.welcome-container {
+    height: 100%;
+    display: flex;
+    justify-content: center;
+    align-items: center;
+    flex-direction: column;
+}
+
+.welcome-title {
+    font-size: 28px;
+    margin-bottom: 8px;
+}
+
+.bot-name {
+    font-weight: 700;
+    margin-left: 8px;
+    color: var(--v-theme-secondary);
+}
+
+.fade-in {
+    animation: fadeIn 0.3s ease-in-out;
+}
+
+.preview-image-large {
+    max-width: 100%;
+    max-height: 70vh;
+    object-fit: contain;
+}
+</style>

dashboard/src/components/shared/ConsoleDisplayer.vue

@@ -7,8 +7,8 @@ import { useCommonStore } from '@/stores/common';
     <!-- 添加筛选级别控件 -->
     <div class="filter-controls mb-2" v-if="showLevelBtns">
       <v-chip-group v-model="selectedLevels" column multiple>
-        <v-chip v-for="level in logLevels" :key="level" :color="getLevelColor(level)" filter
-          :text-color="level === 'DEBUG' || level === 'INFO' ? 'black' : 'white'">
+        <v-chip v-for="level in logLevels" :key="level" :color="getLevelColor(level)" filter variant="flat" size="small"
+          :text-color="level === 'DEBUG' || level === 'INFO' ? 'black' : 'white'" class="font-weight-medium">
           {{ level }}
         </v-chip>
       </v-chip-group>
@@ -168,6 +168,7 @@ export default {
   flex-wrap: wrap;
   gap: 8px;
   margin-bottom: 8px;
+  margin-left: 20px;
 }
 
 .fade-in {

dashboard/src/i18n/locales/en-US/core/navigation.json

@@ -8,7 +8,7 @@
   "chat": "Chat",
   "extension": "Extensions",
   "conversation": "Conversations",
-  "sessionManagement": "Session Management",
+  "sessionManagement": "Custom Rules",
   "console": "Console",
   "alkaid": "Alkaid Lab",
   "knowledgeBase": "Knowledge Base",

dashboard/src/i18n/locales/en-US/features/chat.json

@@ -85,5 +85,9 @@
       "reconnected": "Chat connection re-established",
       "failed": "Connection failed, please refresh the page"
     }
+  },
+  "errors": {
+    "sendMessageFailed": "Failed to send message, please try again",
+    "createSessionFailed": "Failed to create session, please refresh the page"
   }
 } 

dashboard/src/i18n/locales/en-US/features/config-metadata.json

@@ -379,7 +379,11 @@
         },
         "image_caption": {
           "description": "Auto-understand Images",
-          "hint": "Requires setting a default image caption model."
+          "hint": "Requires setting a group chat image caption model."
+        },
+        "image_caption_provider_id": {
+          "description": "Group Chat Image Caption Model",
+          "hint": "Used for image understanding in group chat context awareness, configured separately from the default image caption model."
         },
         "active_reply": {
           "enable": {

dashboard/src/i18n/locales/en-US/features/extension.json

@@ -32,7 +32,8 @@
     "actions": "Actions",
     "back": "Back",
     "selectFile": "Select File",
-    "refresh": "Refresh"
+    "refresh": "Refresh",
+    "updateAll": "Update All"
   },
   "status": {
     "enabled": "Enabled",
@@ -141,7 +142,9 @@
     "confirmDelete": "Are you sure you want to delete this extension?",
     "fillUrlOrFile": "Please fill in extension URL or upload extension file",
     "dontFillBoth": "Please don't fill in both extension URL and upload file",
-    "supportedFormats": "Supports .zip extension files"
+    "supportedFormats": "Supports .zip extension files",
+    "updateAllSuccess": "All upgradable extensions have been updated!",
+    "updateAllFailed": "{failed} of {total} extensions failed to update:"
   },
   "upload": {
     "fromFile": "Install from File",

dashboard/src/i18n/locales/en-US/features/session-management.json

@@ -1,124 +1,110 @@
 {
-  "title": "Session Management",
-  "subtitle": "Manage active sessions and configurations",
+  "title": "Custom Rules",
+  "subtitle": "Set custom rules for specific sessions, which take priority over global settings",
   "buttons": {
     "refresh": "Refresh",
     "edit": "Edit",
-    "apply": "Apply Batch Settings",
-    "editName": "Edit Session Name",
+    "editRule": "Edit Rules",
+    "deleteAllRules": "Delete All Rules",
+    "addRule": "Add Rule",
     "save": "Save",
     "cancel": "Cancel",
-    "delete": "Delete"
+    "delete": "Delete",
+    "clear": "Clear",
+    "next": "Next",
+    "editCustomName": "Edit Note",
+    "batchDelete": "Batch Delete"
   },
-  "sessions": {
-    "activeSessions": "Active Sessions",
-    "sessionCount": "sessions",
-    "noActiveSessions": "No active sessions",
-    "noActiveSessionsDesc": "Sessions will appear here when users interact with the bot"
+  "customRules": {
+    "title": "Custom Rules",
+    "rulesCount": "rules",
+    "hasRules": "Configured",
+    "noRules": "No Custom Rules",
+    "noRulesDesc": "Click 'Add Rule' to configure custom rules for specific sessions",
+    "serviceConfig": "Service Config",
+    "pluginConfig": "Plugin Config",
+    "kbConfig": "Knowledge Base",
+    "providerConfig": "Provider Config",
+    "configured": "Configured",
+    "noCustomName": "No note set"
+  },
+  "quickEditName": {
+    "title": "Edit Note"
   },
   "search": {
-    "placeholder": "Search sessions...",
-    "platformFilter": "Platform Filter"
+    "placeholder": "Search sessions..."
   },
   "table": {
     "headers": {
-      "sessionStatus": "Session Status",
-      "sessionInfo": "Session Info",
-      "persona": "Persona",
-      "chatProvider": "Chat Provider",
-      "sttProvider": "STT Provider",
-      "ttsProvider": "TTS Provider",
-      "llmStatus": "LLM Status",
-      "ttsStatus": "TTS Status",
-      "knowledgeBase": "Knowledge Base",
-      "pluginManagement": "Plugin Management",
+      "umoInfo": "Unified Message Origin",
+      "rulesOverview": "Rules Overview",
       "actions": "Actions"
     }
   },
-  "status": {
-    "enabled": "Enabled",
-    "disabled": "Disabled"
-  },
   "persona": {
-    "none": "No Persona"
+    "none": "Follow Config"
   },
-  "batchOperations": {
-    "title": "Batch Operations",
-    "setPersona": "Batch Set Persona",
-    "setChatProvider": "Batch Set Chat Provider",
-    "setSttProvider": "Batch Set STT Provider",
-    "setTtsProvider": "Batch Set TTS Provider",
-    "setLlmStatus": "Batch Set LLM Status",
-    "setTtsStatus": "Batch Set TTS Status",
-    "noSttProvider": "No STT Provider Available",
-    "noTtsProvider": "No TTS Provider Available"
+  "provider": {
+    "followConfig": "Follow Config"
   },
-  "pluginManagement": {
-    "title": "Plugin Management",
-    "noPlugins": "No available plugins",
-    "noPluginsDesc": "Currently no active plugins",
-    "loading": "Loading plugin list...",
-    "author": "Author"
+  "addRule": {
+    "title": "Add Custom Rule",
+    "description": "Select a session (UMO) to configure custom rules. Custom rules take priority over global settings.",
+    "selectUmo": "Select Session",
+    "noUmos": "No sessions available"
   },
-  "nameEditor": {
-    "title": "Edit Session Name",
-    "customName": "Custom Name",
-    "placeholder": "Enter custom session name (leave empty to use original name)",
-    "originalName": "Original Name",
-    "fullSessionId": "Full Session ID",
-    "hint": "Custom names help you easily identify sessions. The small information icon (!) will show the actual UMO when hovering."
+  "ruleEditor": {
+    "title": "Edit Custom Rules",
+    "description": "Configure custom rules for this session. These rules take priority over global settings.",
+    "serviceConfig": {
+      "title": "Service Configuration",
+      "sessionEnabled": "Enable Session",
+      "llmEnabled": "Enable LLM",
+      "ttsEnabled": "Enable TTS",
+      "customName": "Custom Name"
     },
-  "knowledgeBase": {
+    "providerConfig": {
+      "title": "Provider Configuration",
+      "chatProvider": "Chat Provider",
+      "sttProvider": "STT Provider",
+      "ttsProvider": "TTS Provider"
+    },
+    "personaConfig": {
+      "title": "Persona Configuration",
+      "selectPersona": "Select Persona",
+      "hint": "Persona settings affect the conversation style and behavior of the LLM"
+    },
+    "pluginConfig": {
+      "title": "Plugin Configuration",
+      "disabledPlugins": "Disabled Plugins",
+      "hint": "Select plugins to disable for this session. Unselected plugins will remain enabled."
+    },
+    "kbConfig": {
       "title": "Knowledge Base Configuration",
-    "configure": "Configure",
-    "selectKB": "Select Knowledge Bases",
-    "selectMultiple": "You can select multiple knowledge bases",
-    "noKBAvailable": "No knowledge bases available",
-    "noKBDesc": "No knowledge bases have been created yet",
-    "createKB": "Create Knowledge Base",
-    "advancedSettings": "Advanced Settings",
-    "topK": "Result Count",
-    "topKHint": "Number of results to retrieve from knowledge base",
-    "enableRerank": "Enable Reranking",
-    "enableRerankHint": "Use reranking model to improve retrieval quality",
-    "clearConfig": "Clear Configuration",
-    "save": "Save",
-    "cancel": "Cancel",
-    "loading": "Loading knowledge base configuration...",
-    "description": "Configure knowledge bases for this session. The session will use configured knowledge bases to enhance conversation context.",
-    "saveSuccess": "Knowledge base configuration saved successfully",
-    "saveFailed": "Failed to save knowledge base configuration",
-    "loadFailed": "Failed to load knowledge base configuration",
-    "clearSuccess": "Knowledge base configuration cleared",
-    "clearFailed": "Failed to clear knowledge base configuration",
-    "clearConfirm": "Are you sure you want to clear the knowledge base configuration for this session?"
-  },
-  "list": {
-    "documents": "documents"
+      "selectKbs": "Select Knowledge Bases",
+      "topK": "Top K Results",
+      "enableRerank": "Enable Reranking"
+    }
   },
   "deleteConfirm": {
-    "message": "Are you sure you want to delete session {sessionName}?",
-    "warning": "This action will permanently delete all chat history and preference settings for this session (except for data linked via plugins), and this cannot be undone. Continue?"
+    "title": "Confirm Delete",
+    "message": "Are you sure you want to delete all custom rules for this session? Global settings will be used after deletion."
+  },
+  "batchDeleteConfirm": {
+    "title": "Confirm Batch Delete",
+    "message": "Are you sure you want to delete {count} selected rules? Global settings will be used after deletion."
   },
   "messages": {
-    "refreshSuccess": "Session list refreshed",
-    "personaUpdateSuccess": "Persona updated successfully",
-    "personaUpdateError": "Failed to update persona",
-    "providerUpdateSuccess": "Provider updated successfully",
-    "providerUpdateError": "Failed to update provider",
-    "sessionStatusSuccess": "Session {status}",
-    "llmStatusSuccess": "LLM {status}",
-    "ttsStatusSuccess": "TTS {status}",
-    "statusUpdateError": "Failed to update status",
-    "loadSessionsError": "Failed to load session list",
-    "batchUpdateSuccess": "Successfully batch updated {count} settings",
-    "batchUpdatePartial": "Batch update completed, {success} successful, {error} failed",
-    "loadPluginsError": "Failed to load plugin list",
-    "pluginStatusSuccess": "Plugin {name} {status}",
-    "pluginStatusError": "Failed to update plugin status",
-    "nameUpdateSuccess": "Session name updated successfully",
-    "nameUpdateError": "Failed to update session name",
-    "deleteSuccess": "Session deleted successfully",
-    "deleteError": "Failed to delete session"
+    "refreshSuccess": "Data refreshed",
+    "loadError": "Failed to load data",
+    "saveSuccess": "Saved successfully",
+    "saveError": "Failed to save",
+    "clearSuccess": "Cleared successfully",
+    "clearError": "Failed to clear",
+    "deleteSuccess": "Deleted successfully",
+    "deleteError": "Failed to delete",
+    "noChanges": "No changes to save",
+    "batchDeleteSuccess": "Batch delete successful",
+    "batchDeleteError": "Batch delete failed"
   }
 }

dashboard/src/i18n/locales/zh-CN/core/navigation.json

@@ -8,7 +8,7 @@
   "config": "配置文件",
   "chat": "聊天",
   "conversation": "对话数据",
-  "sessionManagement": "会话管理",
+  "sessionManagement": "自定义规则",
   "console": "控制台",
   "alkaid": "Alkaid",
   "knowledgeBase": "知识库",

dashboard/src/i18n/locales/zh-CN/features/chat.json

@@ -85,5 +85,9 @@
       "reconnected": "聊天连接已重新建立",
       "failed": "连接失败，请刷新页面重试"
     }
+  },
+  "errors": {
+    "sendMessageFailed": "发送消息失败，请重试",
+    "createSessionFailed": "创建会话失败，请刷新页面重试"
   }
 } 

dashboard/src/i18n/locales/zh-CN/features/config-metadata.json

@@ -379,7 +379,11 @@
         },
         "image_caption": {
           "description": "自动理解图片",
-          "hint": "需要设置默认图片转述模型。"
+          "hint": "需要设置群聊图片转述模型。"
+        },
+        "image_caption_provider_id": {
+          "description": "群聊图片转述模型",
+          "hint": "用于群聊上下文感知的图片理解，与默认图片转述模型分开配置。"
         },
         "active_reply": {
           "enable": {

dashboard/src/i18n/locales/zh-CN/features/extension.json

@@ -32,7 +32,8 @@
     "actions": "操作",
     "back": "返回",
     "selectFile": "选择文件",
-    "refresh": "刷新"
+    "refresh": "刷新",
+    "updateAll": "更新全部插件"
   },
   "status": {
     "enabled": "启用",
@@ -141,7 +142,9 @@
     "confirmDelete": "确定要删除插件吗？",
     "fillUrlOrFile": "请填写插件链接或上传插件文件",
     "dontFillBoth": "请不要同时填写插件链接和上传文件",
-    "supportedFormats": "支持 .zip 格式的插件文件"
+    "supportedFormats": "支持 .zip 格式的插件文件",
+    "updateAllSuccess": "所有可更新的插件都已更新！",
+    "updateAllFailed": "有 {failed}/{total} 个插件更新失败:"
   },
   "upload": {
     "fromFile": "从文件安装",

dashboard/src/i18n/locales/zh-CN/features/session-management.json

@@ -1,124 +1,110 @@
 {
-  "title": "会话管理",
-  "subtitle": "管理活跃会话和配置",
+  "title": "自定义规则",
+  "subtitle": "为特定会话设置自定义规则，优先级高于全局配置",
   "buttons": {
     "refresh": "刷新",
     "edit": "编辑",
-    "apply": "应用批量设置",
-    "editName": "备注",
+    "editRule": "编辑规则",
+    "deleteAllRules": "删除所有规则",
+    "addRule": "添加规则",
     "save": "保存",
     "cancel": "取消",
-    "delete": "删除"
+    "delete": "删除",
+    "clear": "清除",
+    "next": "下一步",
+    "editCustomName": "编辑备注",
+    "batchDelete": "批量删除"
   },
-  "sessions": {
-    "activeSessions": "活跃会话",
-    "sessionCount": "个会话",
-    "noActiveSessions": "暂无活跃会话",
-    "noActiveSessionsDesc": "当有用户与机器人交互时，会话将会显示在这里"
+  "customRules": {
+    "title": "自定义规则",
+    "rulesCount": "条规则",
+    "hasRules": "已配置",
+    "noRules": "暂无自定义规则",
+    "noRulesDesc": "点击「添加规则」为特定会话配置自定义规则",
+    "serviceConfig": "服务配置",
+    "pluginConfig": "插件配置",
+    "kbConfig": "知识库配置",
+    "providerConfig": "模型配置",
+    "configured": "已配置",
+    "noCustomName": "未设置备注"
+  },
+  "quickEditName": {
+    "title": "编辑备注名"
   },
   "search": {
-    "placeholder": "搜索会话...",
-    "platformFilter": "平台筛选"
+    "placeholder": "搜索会话..."
   },
   "table": {
     "headers": {
-      "sessionStatus": "会话状态",
-      "sessionInfo": "消息会话来源",
-      "persona": "人格",
-      "chatProvider": "聊天模型",
-      "sttProvider": "语音识别模型",
-      "ttsProvider": "语音合成模型",
-      "llmStatus": "启用 LLM",
-      "ttsStatus": "启用 TTS",
-      "knowledgeBase": "知识库配置",
-      "pluginManagement": "插件管理",
+      "umoInfo": "消息会话来源",
+      "rulesOverview": "规则概览",
       "actions": "操作"
     }
   },
-  "status": {
-    "enabled": "已启用",
-    "disabled": "已禁用"
-  },
   "persona": {
-    "none": "无人格"
+    "none": "跟随配置文件"
   },
-  "batchOperations": {
-    "title": "批量操作",
-    "setPersona": "批量设置人格",
-    "setChatProvider": "批量设置 Chat Provider",
-    "setSttProvider": "批量设置 STT Provider",
-    "setTtsProvider": "批量设置 TTS Provider",
-    "setLlmStatus": "批量设置 LLM 状态",
-    "setTtsStatus": "批量设置 TTS 状态",
-    "noSttProvider": "暂无可用 STT Provider",
-    "noTtsProvider": "暂无可用 TTS Provider"
+  "provider": {
+    "followConfig": "跟随配置文件"
   },
-  "pluginManagement": {
-    "title": "插件管理",
-    "noPlugins": "暂无可用插件",
-    "noPluginsDesc": "目前没有激活的插件",
-    "loading": "加载插件列表中...",
-    "author": "作者"
+  "addRule": {
+    "title": "添加自定义规则",
+    "description": "选择一个消息会话来源 (UMO) 来配置自定义规则。自定义规则的优先级高于该来源所属的配置文件中的全局规则。可以使用 /sid 指令获取该来源的 UMO 信息。",
+    "selectUmo": "选择会话",
+    "noUmos": "暂无可用会话"
   },
-  "nameEditor": {
-    "title": "编辑会话名称",
-    "customName": "自定义名称",
-    "placeholder": "输入自定义会话名称（留空则使用原始名称）",
-    "originalName": "原始名称",
-    "fullSessionId": "完整会话ID",
-    "hint": "自定义名称帮助您轻松识别会话。当设置了自定义名称时，会显示一个小感叹号标识（！），鼠标悬停时会显示实际的UMO。"
+  "ruleEditor": {
+    "title": "编辑自定义规则",
+    "description": "为此会话配置自定义规则，这些规则将优先于全局配置生效。",
+    "serviceConfig": {
+      "title": "服务配置",
+      "sessionEnabled": "启用该消息会话来源的消息处理",
+      "llmEnabled": "启用 LLM",
+      "ttsEnabled": "启用 TTS",
+      "customName": "消息会话来源备注名称"
     },
-  "knowledgeBase": {
+    "providerConfig": {
+      "title": "模型配置",
+      "chatProvider": "聊天模型",
+      "sttProvider": "语音识别模型",
+      "ttsProvider": "语音合成模型"
+    },
+    "personaConfig": {
+      "title": "人格配置",
+      "selectPersona": "选择人格",
+      "hint": "应用人格配置后，将会强制该来源的所有对话使用该人格。"
+    },
+    "pluginConfig": {
+      "title": "插件配置",
+      "disabledPlugins": "禁用的插件",
+      "hint": "选择要在此会话中禁用的插件。未选择的插件将保持启用状态。"
+    },
+    "kbConfig": {
       "title": "知识库配置",
-    "configure": "配置",
-    "selectKB": "选择知识库",
-    "selectMultiple": "可以选择多个知识库",
-    "noKBAvailable": "暂无可用的知识库",
-    "noKBDesc": "目前没有创建任何知识库",
-    "createKB": "创建知识库",
-    "advancedSettings": "高级配置",
-    "topK": "返回结果数量",
-    "topKHint": "从知识库检索的结果数量",
-    "enableRerank": "启用重排序",
-    "enableRerankHint": "使用重排序模型提高检索质量",
-    "clearConfig": "清除配置",
-    "save": "保存",
-    "cancel": "取消",
-    "loading": "加载知识库配置中...",
-    "description": "为此会话配置使用的知识库。会话将使用配置的知识库来增强对话上下文。",
-    "saveSuccess": "知识库配置保存成功",
-    "saveFailed": "保存知识库配置失败",
-    "loadFailed": "加载知识库配置失败",
-    "clearSuccess": "知识库配置已清除",
-    "clearFailed": "清除知识库配置失败",
-    "clearConfirm": "确定要清除此会话的知识库配置吗?"
-  },
-  "list": {
-    "documents": "篇文档"
+      "selectKbs": "选择知识库",
+      "topK": "返回结果数量 (Top K)",
+      "enableRerank": "启用重排序"
+    }
   },
   "deleteConfirm": {
-    "message": "确定要删除会话 {sessionName} 吗？",
-    "warning": "此操作将永久删除本次会话的「全部对话记录」与「偏好设置」（插件对会话的关联数据除外），且无法恢复。确认继续？"
+    "title": "确认删除",
+    "message": "确定要删除此会话的所有自定义规则吗？删除后将恢复使用全局配置。"
+  },
+  "batchDeleteConfirm": {
+    "title": "确认批量删除",
+    "message": "确定要删除选中的 {count} 条规则吗？删除后将恢复使用全局配置。"
   },
   "messages": {
-    "refreshSuccess": "会话列表已刷新",
-    "personaUpdateSuccess": "人格更新成功",
-    "personaUpdateError": "人格更新失败",
-    "providerUpdateSuccess": "Provider 更新成功",
-    "providerUpdateError": "Provider 更新失败",
-    "sessionStatusSuccess": "会话 {status}",
-    "llmStatusSuccess": "LLM {status}",
-    "ttsStatusSuccess": "TTS {status}",
-    "statusUpdateError": "状态更新失败",
-    "loadSessionsError": "加载会话列表失败",
-    "batchUpdateSuccess": "成功批量更新 {count} 项设置",
-    "batchUpdatePartial": "批量更新完成，{success} 项成功，{error} 项失败",
-    "loadPluginsError": "加载插件列表失败",
-    "pluginStatusSuccess": "插件 {name} {status}",
-    "pluginStatusError": "插件状态更新失败",
-    "nameUpdateSuccess": "会话名称更新成功",
-    "nameUpdateError": "会话名称更新失败",
-    "deleteSuccess": "会话删除成功",
-    "deleteError": "会话删除失败"
+    "refreshSuccess": "数据已刷新",
+    "loadError": "加载数据失败",
+    "saveSuccess": "保存成功",
+    "saveError": "保存失败",
+    "clearSuccess": "已清除",
+    "clearError": "清除失败",
+    "deleteSuccess": "删除成功",
+    "deleteError": "删除失败",
+    "noChanges": "没有需要保存的更改",
+    "batchDeleteSuccess": "批量删除成功",
+    "batchDeleteError": "批量删除失败"
   }
 }

dashboard/src/layouts/full/vertical-sidebar/sidebarItem.ts

@@ -69,7 +69,7 @@ const sidebarItem: menu[] = [
       },
       {
         title: 'core.navigation.sessionManagement',
-        icon: 'mdi-account-group',
+        icon: 'mdi-pencil-ruler',
         to: '/session-management'
       },
       {

dashboard/src/views/ConfigPage.vue

@@ -45,6 +45,15 @@
             @click="configToString(); codeEditorDialog = true">
           </v-btn>
 
+          <v-tooltip text="测试当前配置" location="left" v-if="!isSystemConfig">
+            <template v-slot:activator="{ props }">
+              <v-btn v-bind="props" icon="mdi-chat-processing" size="x-large" 
+                style="position: fixed; right: 52px; bottom: 196px;" color="secondary"
+                @click="openTestChat">
+              </v-btn>
+            </template>
+          </v-tooltip>
+
         </div>
       </v-slide-y-transition>
 
@@ -135,6 +144,34 @@
   </v-snackbar>
 
   <WaitingForRestart ref="wfr"></WaitingForRestart>
+
+  <!-- 测试聊天抽屉 -->
+  <v-overlay
+    v-model="testChatDrawer"
+    class="test-chat-overlay"
+    location="right"
+    transition="slide-x-reverse-transition"
+    :scrim="true"
+    @click:outside="closeTestChat"
+  >
+    <v-card class="test-chat-card" elevation="12">
+      <div class="test-chat-header">
+        <div>
+          <span class="text-h6">测试配置</span>
+          <div v-if="selectedConfigInfo.name" class="text-caption text-grey">
+            {{ selectedConfigInfo.name }} ({{ testConfigId }})
+          </div>
+        </div>
+        <v-btn icon variant="text" @click="closeTestChat">
+          <v-icon>mdi-close</v-icon>
+        </v-btn>
+      </div>
+      <v-divider></v-divider>
+      <div class="test-chat-content">
+        <StandaloneChat v-if="testChatDrawer" :configId="testConfigId" />
+      </div>
+    </v-card>
+  </v-overlay>
 </template>
 
 
@@ -142,6 +179,7 @@
 import axios from 'axios';
 import AstrBotCoreConfigWrapper from '@/components/config/AstrBotCoreConfigWrapper.vue';
 import WaitingForRestart from '@/components/shared/WaitingForRestart.vue';
+import StandaloneChat from '@/components/chat/StandaloneChat.vue';
 import { VueMonacoEditor } from '@guolao/vue-monaco-editor'
 import { useI18n, useModuleI18n } from '@/i18n/composables';
 
@@ -150,7 +188,8 @@ export default {
   components: {
     AstrBotCoreConfigWrapper,
     VueMonacoEditor,
-    WaitingForRestart
+    WaitingForRestart,
+    StandaloneChat
   },
   props: {
     initialConfigId: {
@@ -238,6 +277,10 @@ export default {
         name: '',
       },
       editingConfigId: null,
+
+      // 测试聊天
+      testChatDrawer: false,
+      testConfigId: null,
     }
   },
   mounted() {
@@ -506,6 +549,20 @@ export default {
           this.getConfigInfoList("default");
         }
       }
+    },
+    openTestChat() {
+      if (!this.selectedConfigID) {
+        this.save_message = "请先选择一个配置文件";
+        this.save_message_snack = true;
+        this.save_message_success = "warning";
+        return;
+      }
+      this.testConfigId = this.selectedConfigID;
+      this.testChatDrawer = true;
+    },
+    closeTestChat() {
+      this.testChatDrawer = false;
+      this.testConfigId = null;
     }
   },
 }
@@ -565,4 +622,32 @@ export default {
     width: 100%;
   }
 }
+
+/* 测试聊天抽屉样式 */
+.test-chat-overlay {
+  align-items: stretch;
+  justify-content: flex-end;
+}
+
+.test-chat-card {
+  width: clamp(320px, 50vw, 720px);
+  height: calc(100vh - 32px);
+  display: flex;
+  flex-direction: column;
+  margin: 16px;
+}
+
+.test-chat-header {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  padding: 16px 20px 12px 20px;
+}
+
+.test-chat-content {
+  flex: 1;
+  overflow: hidden;
+  padding: 0;
+  border-radius: 0 0 16px 16px;
+}
 </style>

dashboard/src/views/ExtensionPage.vue

@@ -9,6 +9,7 @@ import axios from 'axios';
 import { pinyin } from 'pinyin-pro';
 import { useCommonStore } from '@/stores/common';
 import { useI18n, useModuleI18n } from '@/i18n/composables';
+import defaultPluginIcon from '@/assets/images/plugin_icon.png';
 
 import { ref, computed, onMounted, reactive, inject, watch } from 'vue';
 
@@ -41,6 +42,7 @@ const loadingDialog = reactive({
 const showPluginInfoDialog = ref(false);
 const selectedPlugin = ref({});
 const curr_namespace = ref("");
+const updatingAll = ref(false);
 
 const readmeDialog = reactive({
   show: false,
@@ -225,6 +227,10 @@ const paginatedPlugins = computed(() => {
   return sortedPlugins.value.slice(start, end);
 });
 
+const updatableExtensions = computed(() => {
+  return extension_data?.data?.filter(ext => ext.has_update) || [];
+});
+
 // 方法
 const toggleShowReserved = () => {
   showReserved.value = !showReserved.value;
@@ -371,6 +377,56 @@ const updateExtension = async (extension_name) => {
   }
 };
 
+const updateAllExtensions = async () => {
+  if (updatingAll.value || updatableExtensions.value.length === 0) return;
+  updatingAll.value = true;
+  loadingDialog.title = tm('status.loading');
+  loadingDialog.statusCode = 0;
+  loadingDialog.result = "";
+  loadingDialog.show = true;
+
+  const targets = updatableExtensions.value.map(ext => ext.name);
+  try {
+    const res = await axios.post('/api/plugin/update-all', {
+      names: targets,
+      proxy: localStorage.getItem('selectedGitHubProxy') || ""
+    });
+
+    if (res.data.status === "error") {
+      onLoadingDialogResult(2, res.data.message || tm('messages.updateAllFailed', {
+        failed: targets.length,
+        total: targets.length
+      }), -1);
+      return;
+    }
+
+    const results = res.data.data?.results || [];
+    const failures = results.filter(r => r.status !== 'ok');
+    try {
+      await getExtensions();
+    } catch (err) {
+      const errorMsg = err.response?.data?.message || err.message || String(err);
+      failures.push({ name: 'refresh', status: 'error', message: errorMsg });
+    }
+
+    if (failures.length === 0) {
+      onLoadingDialogResult(1, tm('messages.updateAllSuccess'));
+    } else {
+      const failureText = tm('messages.updateAllFailed', {
+        failed: failures.length,
+        total: targets.length
+      });
+      const detail = failures.map(f => `${f.name}: ${f.message}`).join('\n');
+      onLoadingDialogResult(2, `${failureText}\n${detail}`, -1);
+    }
+  } catch (err) {
+    const errorMsg = err.response?.data?.message || err.message || String(err);
+    onLoadingDialogResult(2, errorMsg, -1);
+  } finally {
+    updatingAll.value = false;
+  }
+};
+
 const pluginOn = async (extension) => {
   try {
     const res = await axios.post('/api/plugin/on', { name: extension.name });
@@ -719,6 +775,12 @@ watch(marketSearch, (newVal) => {
                   {{ showReserved ? tm('buttons.hideSystemPlugins') : tm('buttons.showSystemPlugins') }}
                 </v-btn>
 
+                <v-btn class="ml-2" color="warning" variant="tonal" :disabled="updatableExtensions.length === 0"
+                  :loading="updatingAll" @click="updateAllExtensions">
+                  <v-icon>mdi-update</v-icon>
+                  {{ tm('buttons.updateAll') }}
+                </v-btn>
+
                 <v-btn class="ml-2" color="primary" variant="tonal" @click="dialog = true">
                   <v-icon>mdi-plus</v-icon>
                   {{ tm('buttons.install') }}
@@ -939,7 +1001,7 @@ watch(marketSearch, (newVal) => {
 
               <v-row style="min-height: 26rem;">
                 <v-col v-for="plugin in paginatedPlugins" :key="plugin.name" cols="12" md="6" lg="4">
-                  <v-card class="rounded-lg d-flex flex-column" elevation="0"
+                  <v-card class="rounded-lg d-flex flex-column plugin-card" elevation="0"
                     style=" height: 12rem; position: relative;">
 
                     <!-- 推荐标记 -->
@@ -950,8 +1012,8 @@ watch(marketSearch, (newVal) => {
 
                     <v-card-text
                       style="padding: 12px; padding-bottom: 8px; display: flex; gap: 12px; width: 100%; flex: 1; overflow: hidden;">
-                      <div v-if="plugin?.logo" style="flex-shrink: 0;">
-                        <img :src="plugin.logo" :alt="plugin.name"
+                      <div style="flex-shrink: 0;">
+                        <img :src="plugin?.logo || defaultPluginIcon" :alt="plugin.name"
                           style="height: 75px; width: 75px; border-radius: 8px; object-fit: cover;" />
                       </div>
 
@@ -986,8 +1048,7 @@ watch(marketSearch, (newVal) => {
                         </div>
 
                         <!-- Description -->
-                        <div class="text-caption"
-                          style="overflow: scroll; color: rgba(var(--v-theme-on-surface), 0.6); line-height: 1.3; margin-bottom: 6px; flex: 1;">
+                        <div class="text-caption plugin-description">
                           {{ plugin.desc }}
                         </div>
 
@@ -1246,4 +1307,36 @@ watch(marketSearch, (newVal) => {
   border-radius: 5px;
   background-color: #f5f5f5;
 }
+
+.plugin-description {
+  color: rgba(var(--v-theme-on-surface), 0.6);
+  line-height: 1.3;
+  margin-bottom: 6px;
+  flex: 1;
+  overflow-y: hidden;
+}
+
+.plugin-card:hover .plugin-description {
+  overflow-y: auto;
+}
+
+.plugin-description::-webkit-scrollbar {
+  width: 8px;
+  height: 8px;
+}
+
+.plugin-description::-webkit-scrollbar-track {
+  background: transparent;
+}
+
+.plugin-description::-webkit-scrollbar-thumb {
+  background-color: rgba(var(--v-theme-primary-rgb), 0.4);
+  border-radius: 4px;
+  border: 2px solid transparent;
+  background-clip: content-box;
+}
+
+.plugin-description::-webkit-scrollbar-thumb:hover {
+  background-color: rgba(var(--v-theme-primary-rgb), 0.6);
+}
 </style>

dashboard/src/views/PlatformPage.vue

@@ -35,7 +35,7 @@
       </div>
 
       <!-- 日志部分 -->
-      <v-card elevation="0" class="mt-4">
+      <v-card elevation="0" class="mt-4 mb-10">
         <v-card-title class="d-flex align-center py-3 px-4">
           <v-icon class="me-2">mdi-console-line</v-icon>
           <span class="text-h4">{{ tm('logs.title') }}</span>
@@ -233,5 +233,6 @@ export default {
 .platform-page {
   padding: 20px;
   padding-top: 8px;
+  padding-bottom: 40px;
 }
 </style>

dashboard/src/views/ProviderPage.vue

@@ -69,6 +69,25 @@
                     :loading="isProviderTesting(provider.id)" @toggle-enabled="providerStatusChange"
                     :bglogo="getProviderIcon(provider.provider)" @delete="deleteProvider" @edit="configExistingProvider"
                     @copy="copyProvider" :show-copy-button="true">
+                    <template #item-details="{ item }">
+                      <!-- 测试状态 chip -->
+                      <v-tooltip v-if="getProviderStatus(item.id)" location="top" max-width="300">
+                        <template v-slot:activator="{ props }">
+                          <v-chip v-bind="props" :color="getStatusColor(getProviderStatus(item.id).status)" size="small">
+                            <v-icon start size="small">
+                              {{ getProviderStatus(item.id).status === 'available' ? 'mdi-check-circle' :
+                                getProviderStatus(item.id).status === 'unavailable' ? 'mdi-alert-circle' :
+                                  'mdi-clock-outline' }}
+                            </v-icon>
+                            {{ getStatusText(getProviderStatus(item.id).status) }}
+                          </v-chip>
+                        </template>
+                        <span v-if="getProviderStatus(item.id).status === 'unavailable'">
+                          {{ getProviderStatus(item.id).error }}
+                        </span>
+                        <span v-else>{{ getStatusText(getProviderStatus(item.id).status) }}</span>
+                      </v-tooltip>
+                    </template>
                     <template #actions="{ item }">
                       <v-btn style="z-index: 100000;" variant="tonal" color="info" rounded="xl" size="small"
                         :loading="isProviderTesting(item.id)" @click="testSingleProvider(item)">
@@ -96,75 +115,40 @@
                 :loading="isProviderTesting(provider.id)" @toggle-enabled="providerStatusChange"
                 :bglogo="getProviderIcon(provider.provider)" @delete="deleteProvider" @edit="configExistingProvider"
                 @copy="copyProvider" :show-copy-button="true">
+
+                <template #item-details="{ item }">
+                  <!-- 测试状态 chip -->
+                  <v-tooltip v-if="getProviderStatus(item.id)" location="top" max-width="300">
+                    <template v-slot:activator="{ props }">
+                      <v-chip v-bind="props" :color="getStatusColor(getProviderStatus(item.id).status)" size="small">
+                        <v-icon start size="small">
+                          {{ getProviderStatus(item.id).status === 'available' ? 'mdi-check-circle' :
+                            getProviderStatus(item.id).status === 'unavailable' ? 'mdi-alert-circle' :
+                              'mdi-clock-outline' }}
+                        </v-icon>
+                        {{ getStatusText(getProviderStatus(item.id).status) }}
+                      </v-chip>
+                    </template>
+                    <span v-if="getProviderStatus(item.id).status === 'unavailable'">
+                      {{ getProviderStatus(item.id).error }}
+                    </span>
+                    <span v-else>{{ getStatusText(getProviderStatus(item.id).status) }}</span>
+                  </v-tooltip>
+                </template>
                 <template #actions="{ item }">
                   <v-btn style="z-index: 100000;" variant="tonal" color="info" rounded="xl" size="small"
                     :loading="isProviderTesting(item.id)" @click="testSingleProvider(item)">
                     {{ tm('availability.test') }}
                   </v-btn>
                 </template>
-                <template v-slot:details="{ item }">
-                </template>
               </item-card>
             </v-col>
           </v-row>
         </template>
       </div>
 
-      <!-- 供应商状态部分 -->
-      <v-card elevation="0" class="mt-4">
-        <v-card-title class="d-flex align-center py-3 px-4">
-          <v-icon class="me-2">mdi-heart-pulse</v-icon>
-          <span class="text-h4">{{ tm('availability.title') }}</span>
-          <v-spacer></v-spacer>
-          <v-btn color="primary" variant="tonal" :loading="testingProviders.length > 0" @click="fetchProviderStatus">
-            <v-icon left>mdi-refresh</v-icon>
-            {{ tm('availability.refresh') }}
-          </v-btn>
-          <v-btn variant="text" color="primary" @click="showStatus = !showStatus" style="margin-left: 8px;">
-            {{ showStatus ? tm('logs.collapse') : tm('logs.expand') }}
-            <v-icon>{{ showStatus ? 'mdi-chevron-up' : 'mdi-chevron-down' }}</v-icon>
-          </v-btn>
-        </v-card-title>
-
-        <v-expand-transition>
-          <v-card-text class="pa-0" v-if="showStatus">
-            <v-card-text class="px-4 py-3">
-              <v-alert v-if="providerStatuses.length === 0" type="info" variant="tonal">
-                {{ tm('availability.noData') }}
-              </v-alert>
-
-              <v-container v-else class="pa-0">
-                <v-row>
-                  <v-col v-for="status in providerStatuses" :key="status.id" cols="12" sm="6" md="4">
-                    <v-card variant="outlined" class="status-card" :class="`status-${status.status}`">
-                      <v-card-item>
-                        <v-icon v-if="status.status === 'available'" color="success"
-                          class="me-2">mdi-check-circle</v-icon>
-                        <v-icon v-else-if="status.status === 'unavailable'" color="error"
-                          class="me-2">mdi-alert-circle</v-icon>
-                        <v-progress-circular v-else-if="status.status === 'pending'" indeterminate color="primary"
-                          size="20" width="2" class="me-2"></v-progress-circular>
-
-                        <span class="font-weight-bold">{{ status.id }}</span>
-
-                        <v-chip :color="getStatusColor(status.status)" size="small" class="ml-2">
-                          {{ getStatusText(status.status) }}
-                        </v-chip>
-                      </v-card-item>
-                      <v-card-text v-if="status.status === 'unavailable'" class="text-caption text-medium-emphasis">
-                        <span class="font-weight-bold">{{ tm('availability.errorMessage') }}:</span> {{ status.error }}
-                      </v-card-text>
-                    </v-card>
-                  </v-col>
-                </v-row>
-              </v-container>
-            </v-card-text>
-          </v-card-text>
-        </v-expand-transition>
-      </v-card>
-
       <!-- 日志部分 -->
-      <v-card elevation="0" class="mt-4">
+      <v-card elevation="0" class="mt-4 mb-10">
         <v-card-title class="d-flex align-center py-3 px-4">
           <v-icon class="me-2">mdi-console-line</v-icon>
           <span class="text-h4">{{ tm('logs.title') }}</span>
@@ -751,11 +735,14 @@ export default {
       return this.testingProviders.includes(providerId);
     },
 
+    getProviderStatus(providerId) {
+      return this.providerStatuses.find(s => s.id === providerId);
+    },
+
     async testSingleProvider(provider) {
       if (this.isProviderTesting(provider.id)) return;
 
       this.testingProviders.push(provider.id);
-      this.showStatus = true; // 自动展开状态部分
 
       // 更新UI为pending状态
       const statusIndex = this.providerStatuses.findIndex(s => s.id === provider.id);
@@ -862,6 +849,7 @@ export default {
 .provider-page {
   padding: 20px;
   padding-top: 8px;
+  padding-bottom: 40px;
 }
 
 .status-card {

packages/astrbot/commands/persona.py

@@ -1,6 +1,6 @@
 import builtins
 
-from astrbot.api import star
+from astrbot.api import sp, star
 from astrbot.api.event import AstrMessageEvent, MessageEventResult
 
 
@@ -17,6 +17,13 @@ class PersonaCommands:
         default_persona = await self.context.persona_manager.get_default_persona_v3(
             umo=umo,
         )
+
+        force_applied_persona_id = (
+            await sp.get_async(
+                scope="umo", scope_id=umo, key="session_service_config", default={}
+            )
+        ).get("persona_id")
+
         curr_cid_title = "无"
         if cid:
             conv = await self.context.conversation_manager.get_conversation(
@@ -36,6 +43,9 @@ class PersonaCommands:
             else:
                 curr_persona_name = conv.persona_id
 
+            if force_applied_persona_id:
+                curr_persona_name = f"{curr_persona_name} (自定义规则)"
+
             curr_cid_title = conv.title if conv.title else "新对话"
             curr_cid_title += f"({cid[:4]})"
 
@@ -113,9 +123,15 @@ class PersonaCommands:
                     message.unified_msg_origin,
                     ps,
                 )
+                force_warn_msg = ""
+                if force_applied_persona_id:
+                    force_warn_msg = (
+                        "提醒：由于自定义规则，您现在切换的人格将不会生效。"
+                    )
+
                 message.set_result(
                     MessageEventResult().message(
-                        "设置成功。如果您正在切换到不同的人格，请注意使用 /reset 来清空上下文，防止原人格对话影响现人格。",
+                        f"设置成功。如果您正在切换到不同的人格，请注意使用 /reset 来清空上下文，防止原人格对话影响现人格。{force_warn_msg}",
                     ),
                 )
             else:

packages/astrbot/long_term_memory.py

@@ -6,7 +6,7 @@ from collections import defaultdict
 from astrbot import logger
 from astrbot.api import star
 from astrbot.api.event import AstrMessageEvent
-from astrbot.api.message_components import Image, Plain
+from astrbot.api.message_components import At, Image, Plain
 from astrbot.api.platform import MessageType
 from astrbot.api.provider import Provider, ProviderRequest
 from astrbot.core.astrbot_config_mgr import AstrBotConfigManager
@@ -30,16 +30,13 @@ class LongTermMemory:
         except BaseException as e:
             logger.error(e)
             max_cnt = 300
-        image_caption = (
-            True
-            if cfg["provider_settings"]["default_image_caption_provider_id"]
-            and cfg["provider_ltm_settings"]["image_caption"]
-            else False
-        )
         image_caption_prompt = cfg["provider_settings"]["image_caption_prompt"]
-        image_caption_provider_id = cfg["provider_settings"][
-            "default_image_caption_provider_id"
-        ]
+        image_caption_provider_id = cfg["provider_ltm_settings"].get(
+            "image_caption_provider_id"
+        )
+        image_caption = cfg["provider_ltm_settings"]["image_caption"] and bool(
+            image_caption_provider_id
+        )
         active_reply = cfg["provider_ltm_settings"]["active_reply"]
         enable_active_reply = active_reply.get("enable", False)
         ar_method = active_reply["method"]
@@ -142,6 +139,8 @@ class LongTermMemory:
                             logger.error(f"获取图片描述失败: {e}")
                     else:
                         parts.append(" [Image]")
+                elif isinstance(comp, At):
+                    parts.append(f" [At: {comp.name}]")
 
             final_message = "".join(parts)
             logger.debug(f"ltm | {event.unified_msg_origin} | {final_message}")

packages/astrbot/process_llm_request.py

@@ -3,7 +3,7 @@ import copy
 import datetime
 import zoneinfo
 
-from astrbot.api import logger, star
+from astrbot.api import logger, sp, star
 from astrbot.api.event import AstrMessageEvent
 from astrbot.api.message_components import Image, Reply
 from astrbot.api.provider import Provider, ProviderRequest
@@ -21,16 +21,26 @@ class ProcessLLMRequest:
         else:
             logger.info(f"Timezone set to: {self.timezone}")
 
-    def _ensure_persona(self, req: ProviderRequest, cfg: dict):
+    async def _ensure_persona(self, req: ProviderRequest, cfg: dict, umo: str):
         """确保用户人格已加载"""
         if not req.conversation:
             return
         # persona inject
+
+        # custom rule is preferred
+        persona_id = (
+            await sp.get_async(
+                scope="umo", scope_id=umo, key="session_service_config", default={}
+            )
+        ).get("persona_id")
+
+        if not persona_id:
             persona_id = req.conversation.persona_id or cfg.get("default_personality")
             if not persona_id and persona_id != "[%None]":  # [%None] 为用户取消人格
                 default_persona = self.ctx.persona_manager.selected_default_persona_v3
                 if default_persona:
                     persona_id = default_persona["name"]
+
         persona = next(
             builtins.filter(
                 lambda persona: persona["name"] == persona_id,
@@ -152,7 +162,7 @@ class ProcessLLMRequest:
         img_cap_prov_id: str = cfg.get("default_image_caption_provider_id") or ""
         if req.conversation:
             # inject persona for this request
-            self._ensure_persona(req, cfg)
+            await self._ensure_persona(req, cfg, event.unified_msg_origin)
 
             # image caption
             if img_cap_prov_id and req.image_urls:

packages/session_controller/main.py

@@ -14,7 +14,7 @@ from astrbot.core.utils.session_waiter import (
 )
 
 
-class Waiter(Star):
+class Main(Star):
     """会话控制"""
 
     def __init__(self, context: Context):

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "AstrBot"
-version = "4.6.1"
+version = "4.7.3"
 description = "Easy-to-use multi-platform LLM chatbot and development framework"
 readme = "README.md"
 requires-python = ">=3.10"

tests/test_dashboard.py

@@ -21,7 +21,17 @@ async def core_lifecycle_td(tmp_path_factory):
     log_broker = LogBroker()
     core_lifecycle = AstrBotCoreLifecycle(log_broker, db)
     await core_lifecycle.initialize()
-    return core_lifecycle
+    try:
+        yield core_lifecycle
+    finally:
+        # 优先停止核心生命周期以释放资源（包括关闭 MCP 等后台任务）
+        try:
+            _stop_res = core_lifecycle.stop()
+            if asyncio.iscoroutine(_stop_res):
+                await _stop_res
+        except Exception:
+            # 停止过程中如有异常，不影响后续清理
+            pass
 
 
 @pytest.fixture(scope="module")

tests/test_plugin_manager.py

@@ -39,6 +39,7 @@ def plugin_manager_pm(tmp_path):
     message_history_manager = MagicMock()
     persona_manager = MagicMock()
     astrbot_config_mgr = MagicMock()
+    knowledge_base_manager = MagicMock()
 
     star_context = Context(
         event_queue,
@@ -50,6 +51,7 @@ def plugin_manager_pm(tmp_path):
         message_history_manager,
         persona_manager,
         astrbot_config_mgr,
+        knowledge_base_manager=knowledge_base_manager,
     )
 
     # Create the PluginManager instance