From ec408a2aff2ae99453d333c56546645703f2f287 Mon Sep 17 00:00:00 2001
From: Soulter <905617992@qq.com>
Date: Thu, 11 Dec 2025 18:20:50 +0800
Subject: [PATCH 01/10] fix: lark message timestamp

---
 astrbot/core/platform/sources/lark/lark_adapter.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/astrbot/core/platform/sources/lark/lark_adapter.py b/astrbot/core/platform/sources/lark/lark_adapter.py
index 473be096f..e63972e1e 100644
--- a/astrbot/core/platform/sources/lark/lark_adapter.py
+++ b/astrbot/core/platform/sources/lark/lark_adapter.py
@@ -2,6 +2,7 @@ import asyncio
 import base64
 import json
 import re
+import time
 import uuid
 from typing import cast
 
@@ -137,7 +138,11 @@ class LarkPlatformAdapter(Platform):
             return
 
         abm = AstrBotMessage()
-        abm.timestamp = cast(int, message.create_time) // 1000
+
+        if message.create_time:
+            abm.timestamp = int(message.create_time) // 1000
+        else:
+            abm.timestamp = int(time.time())
         abm.message = []
         abm.type = (
             MessageType.GROUP_MESSAGE

From c09d57a8202aa49f27b8ea469c401f5912f1e19c Mon Sep 17 00:00:00 2001
From: Soulter <37870767+Soulter@users.noreply.github.com>
Date: Thu, 11 Dec 2025 18:55:56 +0800
Subject: [PATCH 02/10] refactor: improve UI layout and interaction for list
 item management (#4002)

* refactor: improve UI layout and interaction for list item management

* feat: enhance list configuration UI with batch import functionality

* feat: add internationalization support for list configuration UI
---
 .../src/components/shared/ListConfigItem.vue  | 159 +++++++++++++-----
 .../src/i18n/locales/en-US/core/common.json   |  13 +-
 .../src/i18n/locales/zh-CN/core/common.json   |  13 +-
 3 files changed, 142 insertions(+), 43 deletions(-)

diff --git a/dashboard/src/components/shared/ListConfigItem.vue b/dashboard/src/components/shared/ListConfigItem.vue
index 96c0ba372..626218223 100644
--- a/dashboard/src/components/shared/ListConfigItem.vue
+++ b/dashboard/src/components/shared/ListConfigItem.vue
@@ -2,7 +2,7 @@
   <div class="d-flex align-center justify-space-between">
     <div>
       <span v-if="!modelValue || modelValue.length === 0" style="color: rgb(var(--v-theme-primaryText));">
-        暂无项目
+        {{ t('core.common.list.noItems') }}
       </span>
       <div v-else class="d-flex flex-wrap ga-2">
         <v-chip v-for="item in displayItems" :key="item" size="x-small" label color="primary">
@@ -14,7 +14,7 @@
       </div>
     </div>
     <v-btn size="small" color="primary" variant="tonal" @click="openDialog">
-      {{ buttonText }}
+      {{ buttonText || t('core.common.list.modifyButton') }}
     </v-btn>
   </div>
 
@@ -22,17 +22,43 @@
   <v-dialog v-model="dialog" max-width="600px">
     <v-card>
       <v-card-title class="text-h3 py-4" style="font-weight: normal;">
-        {{ dialogTitle }}
+        {{ dialogTitle || t('core.common.list.editTitle') }}
       </v-card-title>
       
+      <!-- Add new item section - moved to top -->
+      <v-card-text class="pa-4 pb-2">
+        <div class="d-flex align-center ga-2">
+          <v-text-field 
+            v-model="newItem" 
+            :label="t('core.common.list.addItemPlaceholder')" 
+            @keyup.enter="addItem" 
+            clearable 
+            hide-details
+            variant="outlined" 
+            density="compact" 
+            :placeholder="t('core.common.list.inputPlaceholder')"
+            class="flex-grow-1">
+          </v-text-field>
+          <v-btn 
+            @click="showBatchImport = true" 
+            variant="tonal" 
+            color="primary"
+            size="small">
+            <v-icon size="small">mdi-import</v-icon>
+            {{ t('core.common.list.batchImport') }}
+          </v-btn>
+        </div>
+      </v-card-text>
+
       <v-card-text class="pa-0" style="max-height: 400px; overflow-y: auto;">
         <v-list v-if="localItems.length > 0" density="compact">
           <v-list-item
             v-for="(item, index) in localItems"
             :key="index"
             rounded="md"
-            class="ma-1">
-            <v-list-item-title v-if="editIndex !== index">
+            class="ma-1 list-item-clickable"
+            @click="startEdit(index, item)">
+            <v-list-item-title v-if="editIndex !== index" class="item-text">
               {{ item }}
             </v-list-item-title>
             <v-text-field 
@@ -43,23 +69,27 @@
               density="compact"
               @keyup.enter="saveEdit" 
               @keyup.esc="cancelEdit"
+              @click.stop
               autofocus
             ></v-text-field>
             
             <template v-slot:append>
-              <div v-if="editIndex !== index" class="d-flex">
-                <v-btn @click="startEdit(index, item)" variant="plain" icon size="small">
-                  <v-icon>mdi-pencil</v-icon>
-                </v-btn>
-                <v-btn @click="removeItem(index)" variant="plain" icon size="small">
-                  <v-icon>mdi-close</v-icon>
-                </v-btn>
-              </div>
-              <div v-else class="d-flex">
-                <v-btn @click="saveEdit" variant="plain" color="success" icon size="small">
+              <div class="d-flex">
+                <v-btn 
+                  v-if="editIndex === index"
+                  @click.stop="saveEdit" 
+                  variant="plain" 
+                  color="success" 
+                  icon 
+                  size="small">
                   <v-icon>mdi-check</v-icon>
                 </v-btn>
-                <v-btn @click="cancelEdit" variant="plain" color="error" icon size="small">
+                <v-btn 
+                  @click.stop="editIndex === index ? cancelEdit() : removeItem(index)" 
+                  variant="plain" 
+                  :color="editIndex === index ? 'error' : 'default'"
+                  icon 
+                  size="small">
                   <v-icon>mdi-close</v-icon>
                 </v-btn>
               </div>
@@ -69,34 +99,43 @@
         
         <div v-else class="text-center py-8">
           <v-icon size="64" color="grey-lighten-1">mdi-format-list-bulleted</v-icon>
-          <p class="text-grey mt-4">暂无项目</p>
-        </div>
-      </v-card-text>
-
-      <!-- Add new item section -->
-      <v-card-text class="pa-4">
-        <div class="d-flex align-center ga-2">
-          <v-text-field 
-            v-model="newItem" 
-            :label="t('core.common.list.addItemPlaceholder')" 
-            @keyup.enter="addItem" 
-            clearable 
-            hide-details
-            variant="outlined" 
-            density="compact"
-            class="flex-grow-1">
-          </v-text-field>
-          <v-btn @click="addItem" variant="tonal" color="primary">
-            <v-icon>mdi-plus</v-icon>
-            {{ t('core.common.list.addButton') }}
-          </v-btn>
+          <p class="text-grey mt-4">{{ t('core.common.list.noItemsHint') }}</p>
         </div>
       </v-card-text>
 
       <v-card-actions class="pa-4">
         <v-spacer></v-spacer>
-        <v-btn variant="text" @click="cancelDialog">取消</v-btn>
-        <v-btn color="primary" @click="confirmDialog">确认</v-btn>
+        <v-btn variant="text" @click="cancelDialog">{{ t('core.common.cancel') }}</v-btn>
+        <v-btn color="primary" @click="confirmDialog">{{ t('core.common.confirm') }}</v-btn>
+      </v-card-actions>
+    </v-card>
+  </v-dialog>
+
+  <!-- Batch Import Dialog -->
+  <v-dialog v-model="showBatchImport" max-width="600px">
+    <v-card>
+      <v-card-title class="text-h3 py-4" style="font-weight: normal;">
+        {{ t('core.common.list.batchImportTitle') }}
+      </v-card-title>
+      
+      <v-card-text>
+        <v-textarea
+          v-model="batchImportText"
+          :label="t('core.common.list.batchImportLabel')"
+          :placeholder="t('core.common.list.batchImportPlaceholder')"
+          rows="10"
+          variant="outlined"
+          :hint="t('core.common.list.batchImportHint')"
+          persistent-hint
+        ></v-textarea>
+      </v-card-text>
+
+      <v-card-actions class="pa-4">
+        <v-spacer></v-spacer>
+        <v-btn variant="text" @click="cancelBatchImport">{{ t('core.common.cancel') }}</v-btn>
+        <v-btn color="primary" @click="confirmBatchImport">
+          {{ t('core.common.list.batchImportButton', { count: batchImportPreviewCount }) }}
+        </v-btn>
       </v-card-actions>
     </v-card>
   </v-dialog>
@@ -139,12 +178,24 @@ const originalItems = ref([])
 const newItem = ref('')
 const editIndex = ref(-1)
 const editItem = ref('')
+const showBatchImport = ref(false)
+const batchImportText = ref('')
 
 // 计算要显示的项目
 const displayItems = computed(() => {
   return props.modelValue.slice(0, props.maxDisplayItems)
 })
 
+// 计算批量导入的项目数量
+const batchImportPreviewCount = computed(() => {
+  if (!batchImportText.value) return 0
+  return batchImportText.value
+    .split('\n')
+    .map(line => line.trim())
+    .filter(line => line.length > 0)
+    .length
+})
+
 // 监听 modelValue 变化，同步到 localItems
 watch(() => props.modelValue, (newValue) => {
   localItems.value = [...(newValue || [])]
@@ -199,6 +250,24 @@ function cancelDialog() {
   newItem.value = ''
   dialog.value = false
 }
+
+function confirmBatchImport() {
+  if (batchImportText.value.trim()) {
+    const newItems = batchImportText.value
+      .split('\n')
+      .map(line => line.trim())
+      .filter(line => line.length > 0)
+    
+    localItems.value.push(...newItems)
+    batchImportText.value = ''
+    showBatchImport.value = false
+  }
+}
+
+function cancelBatchImport() {
+  batchImportText.value = ''
+  showBatchImport.value = false
+}
 </script>
 
 <style scoped>
@@ -206,8 +275,16 @@ function cancelDialog() {
   transition: all 0.2s ease;
 }
 
-.v-list-item:hover {
-  background-color: rgba(var(--v-theme-primary), 0.04);
+.list-item-clickable {
+  cursor: pointer;
+}
+
+.list-item-clickable:hover {
+  background-color: rgba(var(--v-theme-primary), 0.08);
+}
+
+.item-text {
+  user-select: none;
 }
 
 .v-chip {
diff --git a/dashboard/src/i18n/locales/en-US/core/common.json b/dashboard/src/i18n/locales/en-US/core/common.json
index 931b62cfe..9259147ae 100644
--- a/dashboard/src/i18n/locales/en-US/core/common.json
+++ b/dashboard/src/i18n/locales/en-US/core/common.json
@@ -66,7 +66,18 @@
   },
   "list": {
     "addItemPlaceholder": "Add new item, press Enter to confirm",
-    "addButton": "Add"
+    "addButton": "Add",
+    "batchImport": "Batch Import",
+    "batchImportTitle": "Batch Import",
+    "batchImportLabel": "One item per line",
+    "batchImportPlaceholder": "Example:\nItem 1\nItem 2\nItem 3\nItem 4",
+    "batchImportHint": "Each line will be treated as a separate item, empty lines will be ignored",
+    "batchImportButton": "Import {count} items",
+    "noItems": "No items",
+    "noItemsHint": "No items yet, type in the input above and press Enter to add",
+    "inputPlaceholder": "Type and press Enter to add",
+    "editTitle": "Edit List Items",
+    "modifyButton": "Modify"
   },
   "itemCard": {
     "enabled": "Enabled",
diff --git a/dashboard/src/i18n/locales/zh-CN/core/common.json b/dashboard/src/i18n/locales/zh-CN/core/common.json
index 9a7f5eeaf..83e3924ba 100644
--- a/dashboard/src/i18n/locales/zh-CN/core/common.json
+++ b/dashboard/src/i18n/locales/zh-CN/core/common.json
@@ -66,7 +66,18 @@
   },
   "list": {
     "addItemPlaceholder": "添加新项，按回车确认添加",
-    "addButton": "添加"
+    "addButton": "添加",
+    "batchImport": "批量导入",
+    "batchImportTitle": "批量导入",
+    "batchImportLabel": "每行一个项目",
+    "batchImportPlaceholder": "例如：\n项目1\n项目2\n项目3\n项目4",
+    "batchImportHint": "每行将作为一个单独的项目，空行会被自动忽略",
+    "batchImportButton": "导入 {count} 项",
+    "noItems": "暂无项目",
+    "noItemsHint": "暂无项目，在上方输入框输入后按回车添加",
+    "inputPlaceholder": "输入后按回车添加",
+    "editTitle": "修改列表项",
+    "modifyButton": "修改"
   },
   "itemCard": {
     "enabled": "已启用",

From 3b81fb4985ffc8a53b719c82fd648162bd6cf9d7 Mon Sep 17 00:00:00 2001
From: Copilot <198982749+Copilot@users.noreply.github.com>
Date: Fri, 12 Dec 2025 16:02:24 +0800
Subject: [PATCH 03/10] fix: mobile dialog close button visibility (#4010)

* Initial plan

* Fix mobile dialog close button visibility by adding max-height and scrollable content

Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>
---
 dashboard/src/views/ExtensionPage.vue | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dashboard/src/views/ExtensionPage.vue b/dashboard/src/views/ExtensionPage.vue
index a83631c42..e1e60c435 100644
--- a/dashboard/src/views/ExtensionPage.vue
+++ b/dashboard/src/views/ExtensionPage.vue
@@ -1473,7 +1473,7 @@ watch(marketSearch, (newVal) => {
   <v-dialog v-model="loadingDialog.show" width="700" persistent>
     <v-card>
       <v-card-title class="text-h5">{{ loadingDialog.title }}</v-card-title>
-      <v-card-text>
+      <v-card-text style="max-height: calc(100vh - 200px); overflow-y: auto;">
         <v-progress-linear v-if="loadingDialog.statusCode === 0" indeterminate color="primary"
           class="mb-4"></v-progress-linear>
 

From 8a0b7717ccb39e6b8f9e2f310707bd32d013c1dc Mon Sep 17 00:00:00 2001
From: Soulter <37870767+Soulter@users.noreply.github.com>
Date: Fri, 12 Dec 2025 22:12:13 +0800
Subject: [PATCH 04/10] feat: supports webhook mode for Lark platform (#4016)

* feat: add Lark platform support with unified webhook configuration

* fix: update token verification logic in LarkWebhookServer

* feat: implement event deduplication and cleanup for Lark webhook events
---
 astrbot/core/config/default.py                |  27 +++
 astrbot/core/platform/manager.py              |   4 +
 astrbot/core/platform/platform.py             |   8 +
 .../aiocqhttp/aiocqhttp_platform_adapter.py   |   2 +-
 .../sources/dingtalk/dingtalk_adapter.py      |   2 +-
 .../platform/sources/lark/lark_adapter.py     | 100 ++++++++-
 astrbot/core/platform/sources/lark/server.py  | 206 ++++++++++++++++++
 .../platform/sources/slack/slack_adapter.py   |   9 +-
 .../platform/sources/telegram/tg_adapter.py   |   2 +-
 .../platform/sources/wecom/wecom_adapter.py   |   2 +-
 .../weixin_offacc_adapter.py                  |   2 +-
 astrbot/core/utils/webhook_utils.py           |  19 ++
 astrbot/dashboard/routes/config.py            |  19 +-
 astrbot/dashboard/routes/platform.py          |   2 +-
 dashboard/src/views/PlatformPage.vue          |   2 +-
 15 files changed, 378 insertions(+), 28 deletions(-)
 create mode 100644 astrbot/core/platform/sources/lark/server.py

diff --git a/astrbot/core/config/default.py b/astrbot/core/config/default.py
index e8778bfc6..daa2c4fac 100644
--- a/astrbot/core/config/default.py
+++ b/astrbot/core/config/default.py
@@ -13,6 +13,7 @@ WEBHOOK_SUPPORTED_PLATFORMS = [
     "wecom",
     "wecom_ai_bot",
     "slack",
+    "lark",
 ]
 
 # 默认配置
@@ -277,6 +278,10 @@ CONFIG_METADATA_2 = {
                         "app_id": "",
                         "app_secret": "",
                         "domain": "https://open.feishu.cn",
+                        "lark_connection_mode": "socket",  # webhook, socket
+                        "webhook_uuid": "",
+                        "lark_encrypt_key": "",
+                        "lark_verification_token": "",
                     },
                     "钉钉(DingTalk)": {
                         "id": "dingtalk",
@@ -370,6 +375,28 @@ CONFIG_METADATA_2 = {
                     #     "type": "string",
                     #     "options": ["fullscreen", "embedded"],
                     # },
+                    "lark_connection_mode": {
+                        "description": "订阅方式",
+                        "type": "string",
+                        "options": ["socket", "webhook"],
+                        "labels": ["长连接模式", "推送至服务器模式"],
+                    },
+                    "lark_encrypt_key": {
+                        "description": "Encrypt Key",
+                        "type": "string",
+                        "hint": "用于解密飞书回调数据的加密密钥",
+                        "condition": {
+                            "lark_connection_mode": "webhook",
+                        },
+                    },
+                    "lark_verification_token": {
+                        "description": "Verification Token",
+                        "type": "string",
+                        "hint": "用于验证飞书回调请求的令牌",
+                        "condition": {
+                            "lark_connection_mode": "webhook",
+                        },
+                    },
                     "is_sandbox": {
                         "description": "沙箱模式",
                         "type": "bool",
diff --git a/astrbot/core/platform/manager.py b/astrbot/core/platform/manager.py
index b941c8cbc..f4313f642 100644
--- a/astrbot/core/platform/manager.py
+++ b/astrbot/core/platform/manager.py
@@ -5,6 +5,7 @@ from asyncio import Queue
 from astrbot.core import logger
 from astrbot.core.config.astrbot_config import AstrBotConfig
 from astrbot.core.star.star_handler import EventType, star_handlers_registry, star_map
+from astrbot.core.utils.webhook_utils import ensure_platform_webhook_config
 
 from .platform import Platform, PlatformStatus
 from .register import platform_cls_map
@@ -18,6 +19,7 @@ class PlatformManager:
 
         self._inst_map: dict[str, dict] = {}
 
+        self.astrbot_config = config
         self.platforms_config = config["platform"]
         self.settings = config["platform_settings"]
         """NOTE: 这里是 default 的配置文件，以保证最大的兼容性；
@@ -29,6 +31,8 @@ class PlatformManager:
         """初始化所有平台适配器"""
         for platform in self.platforms_config:
             try:
+                if ensure_platform_webhook_config(platform):
+                    self.astrbot_config.save_config()
                 await self.load_platform(platform)
             except Exception as e:
                 logger.error(f"初始化 {platform} 平台适配器失败: {e}")
diff --git a/astrbot/core/platform/platform.py b/astrbot/core/platform/platform.py
index c139b8bd7..c2e55fb63 100644
--- a/astrbot/core/platform/platform.py
+++ b/astrbot/core/platform/platform.py
@@ -80,6 +80,13 @@ class Platform(abc.ABC):
         if self._status == PlatformStatus.ERROR:
             self._status = PlatformStatus.RUNNING
 
+    def unified_webhook(self) -> bool:
+        """是否正在使用统一 Webhook 模式"""
+        return bool(
+            self.config.get("unified_webhook_mode", False)
+            and self.config.get("webhook_uuid")
+        )
+
     def get_stats(self) -> dict:
         """获取平台统计信息"""
         meta = self.meta()
@@ -97,6 +104,7 @@ class Platform(abc.ABC):
             }
             if self.last_error
             else None,
+            "unified_webhook": self.unified_webhook(),
         }
 
     @abc.abstractmethod
diff --git a/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py b/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py
index b3c2229ab..52dd21d56 100644
--- a/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py
+++ b/astrbot/core/platform/sources/aiocqhttp/aiocqhttp_platform_adapter.py
@@ -421,7 +421,7 @@ class AiocqhttpAdapter(Platform):
 
     async def shutdown_trigger_placeholder(self):
         await self.shutdown_event.wait()
-        logger.info("aiocqhttp 适配器已被优雅地关闭")
+        logger.info("aiocqhttp 适配器已被关闭")
 
     def meta(self) -> PlatformMetadata:
         return self.metadata
diff --git a/astrbot/core/platform/sources/dingtalk/dingtalk_adapter.py b/astrbot/core/platform/sources/dingtalk/dingtalk_adapter.py
index 8905698a5..6f9e25df4 100644
--- a/astrbot/core/platform/sources/dingtalk/dingtalk_adapter.py
+++ b/astrbot/core/platform/sources/dingtalk/dingtalk_adapter.py
@@ -245,7 +245,7 @@ class DingtalkPlatformAdapter(Platform):
                     task.result()
             except Exception as e:
                 if "Graceful shutdown" in str(e):
-                    logger.info("钉钉适配器已被优雅地关闭")
+                    logger.info("钉钉适配器已被关闭")
                     return
                 logger.error(f"钉钉机器人启动失败: {e}")
 
diff --git a/astrbot/core/platform/sources/lark/lark_adapter.py b/astrbot/core/platform/sources/lark/lark_adapter.py
index e63972e1e..883d81217 100644
--- a/astrbot/core/platform/sources/lark/lark_adapter.py
+++ b/astrbot/core/platform/sources/lark/lark_adapter.py
@@ -4,7 +4,7 @@ import json
 import re
 import time
 import uuid
-from typing import cast
+from typing import Any, cast
 
 import lark_oapi as lark
 from lark_oapi.api.im.v1 import (
@@ -12,6 +12,7 @@ from lark_oapi.api.im.v1 import (
     CreateMessageRequestBody,
     GetMessageResourceRequest,
 )
+from lark_oapi.api.im.v1.processor import P2ImMessageReceiveV1Processor
 
 import astrbot.api.message_components as Comp
 from astrbot import logger
@@ -24,9 +25,11 @@ from astrbot.api.platform import (
     PlatformMetadata,
 )
 from astrbot.core.platform.astr_message_event import MessageSesion
+from astrbot.core.utils.webhook_utils import log_webhook_info
 
 from ...register import register_platform_adapter
 from .lark_event import LarkMessageEvent
+from .server import LarkWebhookServer
 
 
 @register_platform_adapter(
@@ -48,9 +51,13 @@ class LarkPlatformAdapter(Platform):
         self.domain = platform_config.get("domain", lark.FEISHU_DOMAIN)
         self.bot_name = platform_config.get("lark_bot_name", "astrbot")
 
+        # socket or webhook
+        self.connection_mode = platform_config.get("lark_connection_mode", "socket")
+
         if not self.bot_name:
             logger.warning("未设置飞书机器人名称，@ 机器人可能得不到回复。")
 
+        # 初始化 WebSocket 长连接相关配置
         async def on_msg_event_recv(event: lark.im.v1.P2ImMessageReceiveV1):
             await self.convert_msg(event)
 
@@ -63,6 +70,8 @@ class LarkPlatformAdapter(Platform):
             .build()
         )
 
+        self.do_v2_msg_event = do_v2_msg_event
+
         self.client = lark.ws.Client(
             app_id=self.appid,
             app_secret=self.appsecret,
@@ -75,6 +84,39 @@ class LarkPlatformAdapter(Platform):
             lark.Client.builder().app_id(self.appid).app_secret(self.appsecret).build()
         )
 
+        self.webhook_server = None
+        if self.connection_mode == "webhook":
+            self.webhook_server = LarkWebhookServer(platform_config, event_queue)
+            self.webhook_server.set_callback(self.handle_webhook_event)
+
+        self.event_id_timestamps: dict[str, float] = {}
+
+    def _clean_expired_events(self):
+        """清理超过 30 分钟的事件记录"""
+        current_time = time.time()
+        expired_keys = [
+            event_id
+            for event_id, timestamp in self.event_id_timestamps.items()
+            if current_time - timestamp > 1800
+        ]
+        for event_id in expired_keys:
+            del self.event_id_timestamps[event_id]
+
+    def _is_duplicate_event(self, event_id: str) -> bool:
+        """检查事件是否重复
+
+        Args:
+            event_id: 事件ID
+
+        Returns:
+            True 表示重复事件，False 表示新事件
+        """
+        self._clean_expired_events()
+        if event_id in self.event_id_timestamps:
+            return True
+        self.event_id_timestamps[event_id] = time.time()
+        return False
+
     async def send_by_session(
         self,
         session: MessageSesion,
@@ -295,13 +337,61 @@ class LarkPlatformAdapter(Platform):
 
         self._event_queue.put_nowait(event)
 
+    async def handle_webhook_event(self, event_data: dict):
+        """处理 Webhook 事件
+
+        Args:
+            event_data: Webhook 事件数据
+        """
+        try:
+            header = event_data.get("header", {})
+            event_id = header.get("event_id", "")
+            if event_id and self._is_duplicate_event(event_id):
+                logger.debug(f"[Lark Webhook] 跳过重复事件: {event_id}")
+                return
+            event_type = header.get("event_type", "")
+            if event_type == "im.message.receive_v1":
+                processor = P2ImMessageReceiveV1Processor(self.do_v2_msg_event)
+                data = (processor.type())(event_data)
+                processor.do(data)
+            else:
+                logger.debug(f"[Lark Webhook] 未处理的事件类型: {event_type}")
+        except Exception as e:
+            logger.error(f"[Lark Webhook] 处理事件失败: {e}", exc_info=True)
+
     async def run(self):
-        # self.client.start()
-        await self.client._connect()
+        if self.connection_mode == "webhook":
+            # Webhook 模式
+            if self.webhook_server is None:
+                logger.error("[Lark] Webhook 模式已启用，但 webhook_server 未初始化")
+                return
+
+            webhook_uuid = self.config.get("webhook_uuid")
+            if webhook_uuid:
+                log_webhook_info(f"{self.meta().id}(飞书 Webhook)", webhook_uuid)
+            else:
+                logger.warning("[Lark] Webhook 模式已启用，但未配置 webhook_uuid")
+        else:
+            # 长连接模式
+            await self.client._connect()
+
+    async def webhook_callback(self, request: Any) -> Any:
+        """统一 Webhook 回调入口"""
+        if not self.webhook_server:
+            return {"error": "Webhook server not initialized"}, 500
+
+        return await self.webhook_server.handle_callback(request)
 
     async def terminate(self):
-        await self.client._disconnect()
-        logger.info("飞书(Lark) 适配器已被优雅地关闭")
+        if self.connection_mode == "socket":
+            await self.client._disconnect()
+        logger.info("飞书(Lark) 适配器已关闭")
 
     def get_client(self) -> lark.ws.Client:
         return self.client
+
+    def unified_webhook(self) -> bool:
+        return bool(
+            self.config.get("lark_connection_mode", "") == "webhook"
+            and self.config.get("webhook_uuid")
+        )
diff --git a/astrbot/core/platform/sources/lark/server.py b/astrbot/core/platform/sources/lark/server.py
new file mode 100644
index 000000000..3921eb8be
--- /dev/null
+++ b/astrbot/core/platform/sources/lark/server.py
@@ -0,0 +1,206 @@
+"""飞书(Lark) Webhook 服务器实现
+
+实现飞书事件订阅的 Webhook 模式，支持:
+1. 请求 URL 验证 (challenge 验证)
+2. 事件加密/解密 (AES-256-CBC)
+3. 签名校验 (SHA256)
+4. 事件接收和处理
+"""
+
+import asyncio
+import base64
+import hashlib
+import json
+from collections.abc import Awaitable, Callable
+
+from Crypto.Cipher import AES
+
+from astrbot.api import logger
+
+
+class AESCipher:
+    """AES 加密/解密工具类"""
+
+    def __init__(self, key: str):
+        self.bs = AES.block_size
+        self.key = hashlib.sha256(self.str_to_bytes(key)).digest()
+
+    @staticmethod
+    def str_to_bytes(data):
+        u_type = type(b"".decode("utf8"))
+        if isinstance(data, u_type):
+            return data.encode("utf8")
+        return data
+
+    @staticmethod
+    def _unpad(s):
+        return s[: -ord(s[len(s) - 1 :])]
+
+    def decrypt(self, enc):
+        iv = enc[: AES.block_size]
+        cipher = AES.new(self.key, AES.MODE_CBC, iv)
+        return self._unpad(cipher.decrypt(enc[AES.block_size :]))
+
+    def decrypt_string(self, enc):
+        enc = base64.b64decode(enc)
+        return self.decrypt(enc).decode("utf8")
+
+
+class LarkWebhookServer:
+    """飞书 Webhook 服务器
+
+    仅支持统一 Webhook 模式
+    """
+
+    def __init__(self, config: dict, event_queue: asyncio.Queue):
+        """初始化 Webhook 服务器
+
+        Args:
+            config: 飞书配置
+            event_queue: 事件队列
+        """
+        self.app_id = config["app_id"]
+        self.app_secret = config["app_secret"]
+        self.encrypt_key = config.get("lark_encrypt_key", "")
+        self.verification_token = config.get("lark_verification_token", "")
+
+        self.event_queue = event_queue
+        self.callback: Callable[[dict], Awaitable[None]] | None = None
+
+        # 初始化加密工具
+        self.cipher = None
+        if self.encrypt_key:
+            self.cipher = AESCipher(self.encrypt_key)
+
+    def verify_signature(
+        self,
+        timestamp: str,
+        nonce: str,
+        encrypt_key: str,
+        body: bytes,
+        signature: str,
+    ) -> bool:
+        """验证签名
+
+        Args:
+            timestamp: 请求时间戳
+            nonce: 随机数
+            encrypt_key: 加密密钥
+            body: 请求体
+            signature: 签名
+
+        Returns:
+            签名是否有效
+        """
+        # 拼接字符串: timestamp + nonce + encrypt_key + body
+        bytes_b1 = (timestamp + nonce + encrypt_key).encode("utf-8")
+        bytes_b = bytes_b1 + body
+        h = hashlib.sha256(bytes_b)
+        calculated_signature = h.hexdigest()
+        return calculated_signature == signature
+
+    def decrypt_event(self, encrypted_data: str) -> dict:
+        """解密事件数据
+
+        Args:
+            encrypted_data: 加密的事件数据
+
+        Returns:
+            解密后的事件字典
+        """
+        if not self.cipher:
+            raise ValueError("未配置 encrypt_key，无法解密事件")
+
+        decrypted_str = self.cipher.decrypt_string(encrypted_data)
+        return json.loads(decrypted_str)
+
+    async def handle_challenge(self, event_data: dict) -> dict:
+        """处理 challenge 验证请求
+
+        Args:
+            event_data: 事件数据
+
+        Returns:
+            包含 challenge 的响应
+        """
+        challenge = event_data.get("challenge", "")
+        logger.info(f"[Lark Webhook] 收到 challenge 验证请求: {challenge}")
+
+        return {"challenge": challenge}
+
+    async def handle_callback(self, request) -> tuple[dict, int] | dict:
+        """处理 webhook 回调，可被统一 webhook 入口复用
+
+        Args:
+            request: Quart 请求对象
+
+        Returns:
+            响应数据
+        """
+        # 获取原始请求体
+        body = await request.get_data()
+
+        try:
+            event_data = await request.json
+        except Exception as e:
+            logger.error(f"[Lark Webhook] 解析请求体失败: {e}")
+            return {"error": "Invalid JSON"}, 400
+
+        if not event_data:
+            logger.error("[Lark Webhook] 请求体为空")
+            return {"error": "Empty request body"}, 400
+
+        # 如果配置了 encrypt_key，进行签名验证
+        if self.encrypt_key:
+            timestamp = request.headers.get("X-Lark-Request-Timestamp", "")
+            nonce = request.headers.get("X-Lark-Request-Nonce", "")
+            signature = request.headers.get("X-Lark-Signature", "")
+
+            if timestamp and nonce and signature:
+                if not self.verify_signature(
+                    timestamp, nonce, self.encrypt_key, body, signature
+                ):
+                    logger.error("[Lark Webhook] 签名验证失败")
+                    return {"error": "Invalid signature"}, 401
+
+        # 检查是否是加密事件
+        if "encrypt" in event_data:
+            try:
+                event_data = self.decrypt_event(event_data["encrypt"])
+                logger.debug(f"[Lark Webhook] 解密后的事件: {event_data}")
+            except Exception as e:
+                logger.error(f"[Lark Webhook] 解密事件失败: {e}")
+                return {"error": "Decryption failed"}, 400
+
+        # 验证 token
+        if self.verification_token:
+            header = event_data.get("header", {})
+            if header:
+                token = header.get("token", "")
+            else:
+                token = event_data.get("token", "")
+            if token != self.verification_token:
+                logger.error("[Lark Webhook] Verification Token 不匹配。")
+                return {"error": "Invalid verification token"}, 401
+
+        # 处理 URL 验证 (challenge)
+        if event_data.get("type") == "url_verification":
+            return await self.handle_challenge(event_data)
+
+        # 调用回调函数处理事件
+        if self.callback:
+            try:
+                await self.callback(event_data)
+            except Exception as e:
+                logger.error(f"[Lark Webhook] 处理事件回调失败: {e}", exc_info=True)
+                return {"error": "Event processing failed"}, 500
+
+        return {}
+
+    def set_callback(self, callback: Callable[[dict], Awaitable[None]]):
+        """设置事件回调函数
+
+        Args:
+            callback: 处理事件的异步函数
+        """
+        self.callback = callback
diff --git a/astrbot/core/platform/sources/slack/slack_adapter.py b/astrbot/core/platform/sources/slack/slack_adapter.py
index 4621f8494..ed838b0a9 100644
--- a/astrbot/core/platform/sources/slack/slack_adapter.py
+++ b/astrbot/core/platform/sources/slack/slack_adapter.py
@@ -409,7 +409,7 @@ class SlackAdapter(Platform):
             await self.socket_client.stop()
         if self.webhook_client:
             await self.webhook_client.stop()
-        logger.info("Slack 适配器已被优雅地关闭")
+        logger.info("Slack 适配器已被关闭")
 
     def meta(self) -> PlatformMetadata:
         return self.metadata
@@ -427,3 +427,10 @@ class SlackAdapter(Platform):
 
     def get_client(self):
         return self.web_client
+
+    def unified_webhook(self) -> bool:
+        return bool(
+            self.config.get("unified_webhook_mode", False)
+            and self.config.get("slack_connection_mode", "") == "webhook"
+            and self.config.get("webhook_uuid")
+        )
diff --git a/astrbot/core/platform/sources/telegram/tg_adapter.py b/astrbot/core/platform/sources/telegram/tg_adapter.py
index bca45ea8d..218d13bdc 100644
--- a/astrbot/core/platform/sources/telegram/tg_adapter.py
+++ b/astrbot/core/platform/sources/telegram/tg_adapter.py
@@ -424,6 +424,6 @@ class TelegramPlatformAdapter(Platform):
             if self.application.updater is not None:
                 await self.application.updater.stop()
 
-            logger.info("Telegram 适配器已被优雅地关闭")
+            logger.info("Telegram 适配器已被关闭")
         except Exception as e:
             logger.error(f"Telegram 适配器关闭时出错: {e}")
diff --git a/astrbot/core/platform/sources/wecom/wecom_adapter.py b/astrbot/core/platform/sources/wecom/wecom_adapter.py
index 8f3d091a4..44ed75117 100644
--- a/astrbot/core/platform/sources/wecom/wecom_adapter.py
+++ b/astrbot/core/platform/sources/wecom/wecom_adapter.py
@@ -422,4 +422,4 @@ class WecomPlatformAdapter(Platform):
             await self.server.server.shutdown()
         except Exception as _:
             pass
-        logger.info("企业微信 适配器已被优雅地关闭")
+        logger.info("企业微信 适配器已被关闭")
diff --git a/astrbot/core/platform/sources/weixin_official_account/weixin_offacc_adapter.py b/astrbot/core/platform/sources/weixin_official_account/weixin_offacc_adapter.py
index d0304a48e..d12285d68 100644
--- a/astrbot/core/platform/sources/weixin_official_account/weixin_offacc_adapter.py
+++ b/astrbot/core/platform/sources/weixin_official_account/weixin_offacc_adapter.py
@@ -349,4 +349,4 @@ class WeixinOfficialAccountPlatformAdapter(Platform):
             await self.server.server.shutdown()
         except Exception as _:
             pass
-        logger.info("微信公众平台 适配器已被优雅地关闭")
+        logger.info("微信公众平台 适配器已被关闭")
diff --git a/astrbot/core/utils/webhook_utils.py b/astrbot/core/utils/webhook_utils.py
index c56d00b37..0e1c3f9cd 100644
--- a/astrbot/core/utils/webhook_utils.py
+++ b/astrbot/core/utils/webhook_utils.py
@@ -1,4 +1,7 @@
+import uuid
+
 from astrbot.core import astrbot_config, logger
+from astrbot.core.config.default import WEBHOOK_SUPPORTED_PLATFORMS
 
 
 def _get_callback_api_base() -> str:
@@ -45,3 +48,19 @@ def log_webhook_info(platform_name: str, webhook_uuid: str):
         "====================\n"
     )
     logger.info(display_log)
+
+
+def ensure_platform_webhook_config(platform_cfg: dict) -> bool:
+    """为支持统一 webhook 的平台自动生成 webhook_uuid
+
+    Args:
+        platform_cfg (dict): 平台配置字典
+
+    Returns:
+        bool: 如果生成了 webhook_uuid 则返回 True，否则返回 False
+    """
+    pt = platform_cfg.get("type", "")
+    if pt in WEBHOOK_SUPPORTED_PLATFORMS and not platform_cfg.get("webhook_uuid"):
+        platform_cfg["webhook_uuid"] = uuid.uuid4().hex[:16]
+        return True
+    return False
diff --git a/astrbot/dashboard/routes/config.py b/astrbot/dashboard/routes/config.py
index e8f17cc99..0edbe8377 100644
--- a/astrbot/dashboard/routes/config.py
+++ b/astrbot/dashboard/routes/config.py
@@ -2,7 +2,6 @@ import asyncio
 import inspect
 import os
 import traceback
-import uuid
 from typing import Any
 
 from quart import request
@@ -15,7 +14,6 @@ from astrbot.core.config.default import (
     CONFIG_METADATA_3_SYSTEM,
     DEFAULT_CONFIG,
     DEFAULT_VALUE_MAP,
-    WEBHOOK_SUPPORTED_PLATFORMS,
 )
 from astrbot.core.config.i18n_utils import ConfigMetadataI18n
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
@@ -23,6 +21,7 @@ from astrbot.core.platform.register import platform_cls_map, platform_registry
 from astrbot.core.provider import Provider
 from astrbot.core.provider.register import provider_registry
 from astrbot.core.star.star import star_registry
+from astrbot.core.utils.webhook_utils import ensure_platform_webhook_config
 
 from .route import Response, Route, RouteContext
 
@@ -559,13 +558,8 @@ class ConfigRoute(Route):
     async def post_new_platform(self):
         new_platform_config = await request.json
 
-        # 如果是支持统一 webhook 模式的平台，且启用了统一 webhook 模式，自动生成 webhook_uuid
-        platform_type = new_platform_config.get("type", "")
-        if platform_type in WEBHOOK_SUPPORTED_PLATFORMS:
-            if new_platform_config.get("unified_webhook_mode", False):
-                # 如果没有 webhook_uuid 或为空，自动生成
-                if not new_platform_config.get("webhook_uuid"):
-                    new_platform_config["webhook_uuid"] = uuid.uuid4().hex[:16]
+        # 如果是支持统一 webhook 模式的平台，生成 webhook_uuid
+        ensure_platform_webhook_config(new_platform_config)
 
         self.config["platform"].append(new_platform_config)
         try:
@@ -597,12 +591,7 @@ class ConfigRoute(Route):
             return Response().error("参数错误").__dict__
 
         # 如果是支持统一 webhook 模式的平台，且启用了统一 webhook 模式，确保有 webhook_uuid
-        platform_type = new_config.get("type", "")
-        if platform_type in WEBHOOK_SUPPORTED_PLATFORMS:
-            if new_config.get("unified_webhook_mode", False):
-                # 如果没有 webhook_uuid 或为空，自动生成
-                if not new_config.get("webhook_uuid"):
-                    new_config["webhook_uuid"] = uuid.uuid4().hex
+        ensure_platform_webhook_config(new_config)
 
         for i, platform in enumerate(self.config["platform"]):
             if platform["id"] == platform_id:
diff --git a/astrbot/dashboard/routes/platform.py b/astrbot/dashboard/routes/platform.py
index 5b709a628..4d8fdddfe 100644
--- a/astrbot/dashboard/routes/platform.py
+++ b/astrbot/dashboard/routes/platform.py
@@ -82,7 +82,7 @@ class PlatformRoute(Route):
         """
         for platform in self.platform_manager.platform_insts:
             if platform.config.get("webhook_uuid") == webhook_uuid:
-                if platform.config.get("unified_webhook_mode", False):
+                if platform.unified_webhook():
                     return platform
         return None
 
diff --git a/dashboard/src/views/PlatformPage.vue b/dashboard/src/views/PlatformPage.vue
index c4beb40f1..56d23852d 100644
--- a/dashboard/src/views/PlatformPage.vue
+++ b/dashboard/src/views/PlatformPage.vue
@@ -57,7 +57,7 @@
                     {{ getPlatformStat(item.id)?.error_count }} {{ tm('runtimeStatus.errors') }}
                   </v-chip>
                 </div>
-                <div v-if="item.unified_webhook_mode && item.webhook_uuid" class="webhook-info">
+                <div v-if="getPlatformStat(item.id)?.unified_webhook && item.webhook_uuid" class="webhook-info">
                   <v-chip
                     size="small"
                     color="primary"

From 46528391c2229cc8d8fa038cb17c7d29d91aee38 Mon Sep 17 00:00:00 2001
From: RC-CHN <67079377+RC-CHN@users.noreply.github.com>
Date: Fri, 12 Dec 2025 23:15:11 +0800
Subject: [PATCH 05/10] feat: add pre-chunk import strategy for knowledge base
 (#3973)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

* feat: 添加文档导入功能及相关测试

* feat: 优化文档上传功能，支持从文件名推断文件类型，并增强文档切片验证

* feat: 添加文档导入功能的无效输入测试，验证 chunks 类型和内容的错误处理

* refactor: 重构文档上传和导入任务的状态管理，添加任务初始化、结果设置和进度更新方法
---
 astrbot/dashboard/routes/knowledge_base.py | 331 ++++++++++++++++-----
 tests/test_kb_import.py                    | 209 +++++++++++++
 2 files changed, 462 insertions(+), 78 deletions(-)
 create mode 100644 tests/test_kb_import.py

diff --git a/astrbot/dashboard/routes/knowledge_base.py b/astrbot/dashboard/routes/knowledge_base.py
index d7db42c40..537a81f0b 100644
--- a/astrbot/dashboard/routes/knowledge_base.py
+++ b/astrbot/dashboard/routes/knowledge_base.py
@@ -48,6 +48,7 @@ class KnowledgeBaseRoute(Route):
             # 文档管理
             "/kb/document/list": ("GET", self.list_documents),
             "/kb/document/upload": ("POST", self.upload_document),
+            "/kb/document/import": ("POST", self.import_documents),
             "/kb/document/upload/url": ("POST", self.upload_document_from_url),
             "/kb/document/upload/progress": ("GET", self.get_upload_progress),
             "/kb/document/get": ("GET", self.get_document),
@@ -66,6 +67,65 @@ class KnowledgeBaseRoute(Route):
     def _get_kb_manager(self):
         return self.core_lifecycle.kb_manager
 
+    def _init_task(self, task_id: str, status: str = "pending") -> None:
+        self.upload_tasks[task_id] = {
+            "status": status,
+            "result": None,
+            "error": None,
+        }
+
+    def _set_task_result(
+        self, task_id: str, status: str, result: any = None, error: str | None = None
+    ) -> None:
+        self.upload_tasks[task_id] = {
+            "status": status,
+            "result": result,
+            "error": error,
+        }
+        if task_id in self.upload_progress:
+            self.upload_progress[task_id]["status"] = status
+
+    def _update_progress(
+        self,
+        task_id: str,
+        *,
+        status: str | None = None,
+        file_index: int | None = None,
+        file_name: str | None = None,
+        stage: str | None = None,
+        current: int | None = None,
+        total: int | None = None,
+    ) -> None:
+        if task_id not in self.upload_progress:
+            return
+        p = self.upload_progress[task_id]
+        if status is not None:
+            p["status"] = status
+        if file_index is not None:
+            p["file_index"] = file_index
+        if file_name is not None:
+            p["file_name"] = file_name
+        if stage is not None:
+            p["stage"] = stage
+        if current is not None:
+            p["current"] = current
+        if total is not None:
+            p["total"] = total
+
+    def _make_progress_callback(self, task_id: str, file_idx: int, file_name: str):
+        async def _callback(stage: str, current: int, total: int):
+            self._update_progress(
+                task_id,
+                status="processing",
+                file_index=file_idx,
+                file_name=file_name,
+                stage=stage,
+                current=current,
+                total=total,
+            )
+
+        return _callback
+
     async def _background_upload_task(
         self,
         task_id: str,
@@ -80,11 +140,7 @@ class KnowledgeBaseRoute(Route):
         """后台上传任务"""
         try:
             # 初始化任务状态
-            self.upload_tasks[task_id] = {
-                "status": "processing",
-                "result": None,
-                "error": None,
-            }
+            self._init_task(task_id, status="processing")
             self.upload_progress[task_id] = {
                 "status": "processing",
                 "file_index": 0,
@@ -100,30 +156,20 @@ class KnowledgeBaseRoute(Route):
             for file_idx, file_info in enumerate(files_to_upload):
                 try:
                     # 更新整体进度
-                    self.upload_progress[task_id].update(
-                        {
-                            "status": "processing",
-                            "file_index": file_idx,
-                            "file_name": file_info["file_name"],
-                            "stage": "parsing",
-                            "current": 0,
-                            "total": 100,
-                        },
+                    self._update_progress(
+                        task_id,
+                        status="processing",
+                        file_index=file_idx,
+                        file_name=file_info["file_name"],
+                        stage="parsing",
+                        current=0,
+                        total=100,
                     )
 
                     # 创建进度回调函数
-                    async def progress_callback(stage, current, total):
-                        if task_id in self.upload_progress:
-                            self.upload_progress[task_id].update(
-                                {
-                                    "status": "processing",
-                                    "file_index": file_idx,
-                                    "file_name": file_info["file_name"],
-                                    "stage": stage,
-                                    "current": current,
-                                    "total": total,
-                                },
-                            )
+                    progress_callback = self._make_progress_callback(
+                        task_id, file_idx, file_info["file_name"]
+                    )
 
                     doc = await kb_helper.upload_document(
                         file_name=file_info["file_name"],
@@ -154,23 +200,99 @@ class KnowledgeBaseRoute(Route):
                 "failed_count": len(failed_docs),
             }
 
-            self.upload_tasks[task_id] = {
-                "status": "completed",
-                "result": result,
-                "error": None,
-            }
-            self.upload_progress[task_id]["status"] = "completed"
+            self._set_task_result(task_id, "completed", result=result)
 
         except Exception as e:
             logger.error(f"后台上传任务 {task_id} 失败: {e}")
             logger.error(traceback.format_exc())
-            self.upload_tasks[task_id] = {
-                "status": "failed",
-                "result": None,
-                "error": str(e),
+            self._set_task_result(task_id, "failed", error=str(e))
+
+    async def _background_import_task(
+        self,
+        task_id: str,
+        kb_helper,
+        documents: list,
+        batch_size: int,
+        tasks_limit: int,
+        max_retries: int,
+    ):
+        """后台导入预切片文档任务"""
+        try:
+            # 初始化任务状态
+            self._init_task(task_id, status="processing")
+            self.upload_progress[task_id] = {
+                "status": "processing",
+                "file_index": 0,
+                "file_total": len(documents),
+                "stage": "waiting",
+                "current": 0,
+                "total": 100,
             }
-            if task_id in self.upload_progress:
-                self.upload_progress[task_id]["status"] = "failed"
+
+            uploaded_docs = []
+            failed_docs = []
+
+            for file_idx, doc_info in enumerate(documents):
+                file_name = doc_info.get("file_name", f"imported_doc_{file_idx}")
+                chunks = doc_info.get("chunks", [])
+
+                try:
+                    # 更新整体进度
+                    self._update_progress(
+                        task_id,
+                        status="processing",
+                        file_index=file_idx,
+                        file_name=file_name,
+                        stage="importing",
+                        current=0,
+                        total=100,
+                    )
+
+                    # 创建进度回调函数
+                    progress_callback = self._make_progress_callback(
+                        task_id, file_idx, file_name
+                    )
+
+                    # 调用 upload_document，传入 pre_chunked_text
+                    doc = await kb_helper.upload_document(
+                        file_name=file_name,
+                        file_content=None,  # 预切片模式下不需要原始内容
+                        file_type=doc_info.get("file_type")
+                        or (
+                            file_name.rsplit(".", 1)[-1].lower()
+                            if "." in file_name
+                            else "txt"
+                        ),
+                        batch_size=batch_size,
+                        tasks_limit=tasks_limit,
+                        max_retries=max_retries,
+                        progress_callback=progress_callback,
+                        pre_chunked_text=chunks,
+                    )
+
+                    uploaded_docs.append(doc.model_dump())
+                except Exception as e:
+                    logger.error(f"导入文档 {file_name} 失败: {e}")
+                    failed_docs.append(
+                        {"file_name": file_name, "error": str(e)},
+                    )
+
+            # 更新任务完成状态
+            result = {
+                "task_id": task_id,
+                "uploaded": uploaded_docs,
+                "failed": failed_docs,
+                "total": len(documents),
+                "success_count": len(uploaded_docs),
+                "failed_count": len(failed_docs),
+            }
+
+            self._set_task_result(task_id, "completed", result=result)
+
+        except Exception as e:
+            logger.error(f"后台导入任务 {task_id} 失败: {e}")
+            logger.error(traceback.format_exc())
+            self._set_task_result(task_id, "failed", error=str(e))
 
     async def list_kbs(self):
         """获取知识库列表
@@ -614,11 +736,7 @@ class KnowledgeBaseRoute(Route):
             task_id = str(uuid.uuid4())
 
             # 初始化任务状态
-            self.upload_tasks[task_id] = {
-                "status": "pending",
-                "result": None,
-                "error": None,
-            }
+            self._init_task(task_id, status="pending")
 
             # 启动后台任务
             asyncio.create_task(
@@ -653,6 +771,93 @@ class KnowledgeBaseRoute(Route):
             logger.error(traceback.format_exc())
             return Response().error(f"上传文档失败: {e!s}").__dict__
 
+    def _validate_import_request(self, data: dict):
+        kb_id = data.get("kb_id")
+        if not kb_id:
+            raise ValueError("缺少参数 kb_id")
+
+        documents = data.get("documents")
+        if not documents or not isinstance(documents, list):
+            raise ValueError("缺少参数 documents 或格式错误")
+
+        for doc in documents:
+            if "file_name" not in doc or "chunks" not in doc:
+                raise ValueError("文档格式错误，必须包含 file_name 和 chunks")
+            if not isinstance(doc["chunks"], list):
+                raise ValueError("chunks 必须是列表")
+            if not all(
+                isinstance(chunk, str) and chunk.strip() for chunk in doc["chunks"]
+            ):
+                raise ValueError("chunks 必须是非空字符串列表")
+
+        batch_size = data.get("batch_size", 32)
+        tasks_limit = data.get("tasks_limit", 3)
+        max_retries = data.get("max_retries", 3)
+        return kb_id, documents, batch_size, tasks_limit, max_retries
+
+    async def import_documents(self):
+        """导入预切片文档
+
+        Body:
+        - kb_id: 知识库 ID (必填)
+        - documents: 文档列表 (必填)
+            - file_name: 文件名 (必填)
+            - chunks: 切片列表 (必填, list[str])
+            - file_type: 文件类型 (可选, 默认从文件名推断或为 txt)
+        - batch_size: 批处理大小 (可选, 默认32)
+        - tasks_limit: 并发任务限制 (可选, 默认3)
+        - max_retries: 最大重试次数 (可选, 默认3)
+        """
+        try:
+            kb_manager = self._get_kb_manager()
+            data = await request.json
+
+            kb_id, documents, batch_size, tasks_limit, max_retries = (
+                self._validate_import_request(data)
+            )
+
+            # 获取知识库
+            kb_helper = await kb_manager.get_kb(kb_id)
+            if not kb_helper:
+                return Response().error("知识库不存在").__dict__
+
+            # 生成任务ID
+            task_id = str(uuid.uuid4())
+
+            # 初始化任务状态
+            self._init_task(task_id, status="pending")
+
+            # 启动后台任务
+            asyncio.create_task(
+                self._background_import_task(
+                    task_id=task_id,
+                    kb_helper=kb_helper,
+                    documents=documents,
+                    batch_size=batch_size,
+                    tasks_limit=tasks_limit,
+                    max_retries=max_retries,
+                ),
+            )
+
+            return (
+                Response()
+                .ok(
+                    {
+                        "task_id": task_id,
+                        "doc_count": len(documents),
+                        "message": "import task created, processing in background",
+                    },
+                )
+                .__dict__
+            )
+
+        except ValueError as e:
+            return Response().error(str(e)).__dict__
+        except Exception as e:
+            logger.error(f"导入文档失败: {e}")
+            logger.error(traceback.format_exc())
+            return Response().error(f"导入文档失败: {e!s}").__dict__
+
     async def get_upload_progress(self):
         """获取上传进度和结果
 
@@ -960,11 +1165,7 @@ class KnowledgeBaseRoute(Route):
             task_id = str(uuid.uuid4())
 
             # 初始化任务状态
-            self.upload_tasks[task_id] = {
-                "status": "pending",
-                "result": None,
-                "error": None,
-            }
+            self._init_task(task_id, status="pending")
 
             # 启动后台任务
             asyncio.create_task(
@@ -1017,11 +1218,7 @@ class KnowledgeBaseRoute(Route):
         """后台上传URL任务"""
         try:
             # 初始化任务状态
-            self.upload_tasks[task_id] = {
-                "status": "processing",
-                "result": None,
-                "error": None,
-            }
+            self._init_task(task_id, status="processing")
             self.upload_progress[task_id] = {
                 "status": "processing",
                 "file_index": 0,
@@ -1033,18 +1230,7 @@ class KnowledgeBaseRoute(Route):
             }
 
             # 创建进度回调函数
-            async def progress_callback(stage, current, total):
-                if task_id in self.upload_progress:
-                    self.upload_progress[task_id].update(
-                        {
-                            "status": "processing",
-                            "file_index": 0,
-                            "file_name": f"URL: {url}",
-                            "stage": stage,
-                            "current": current,
-                            "total": total,
-                        },
-                    )
+            progress_callback = self._make_progress_callback(task_id, 0, f"URL: {url}")
 
             # 上传文档
             doc = await kb_helper.upload_from_url(
@@ -1069,20 +1255,9 @@ class KnowledgeBaseRoute(Route):
                 "failed_count": 0,
             }
 
-            self.upload_tasks[task_id] = {
-                "status": "completed",
-                "result": result,
-                "error": None,
-            }
-            self.upload_progress[task_id]["status"] = "completed"
+            self._set_task_result(task_id, "completed", result=result)
 
         except Exception as e:
             logger.error(f"后台上传URL任务 {task_id} 失败: {e}")
             logger.error(traceback.format_exc())
-            self.upload_tasks[task_id] = {
-                "status": "failed",
-                "result": None,
-                "error": str(e),
-            }
-            if task_id in self.upload_progress:
-                self.upload_progress[task_id]["status"] = "failed"
+            self._set_task_result(task_id, "failed", error=str(e))
diff --git a/tests/test_kb_import.py b/tests/test_kb_import.py
new file mode 100644
index 000000000..8ad40f540
--- /dev/null
+++ b/tests/test_kb_import.py
@@ -0,0 +1,209 @@
+import asyncio
+from unittest.mock import AsyncMock, MagicMock
+
+import pytest
+import pytest_asyncio
+from quart import Quart
+
+from astrbot.core import LogBroker
+from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
+from astrbot.core.db.sqlite import SQLiteDatabase
+from astrbot.core.knowledge_base.kb_helper import KBHelper
+from astrbot.core.knowledge_base.models import KBDocument
+from astrbot.dashboard.server import AstrBotDashboard
+
+
+@pytest_asyncio.fixture(scope="module")
+async def core_lifecycle_td(tmp_path_factory):
+    """Creates and initializes a core lifecycle instance with a temporary database."""
+    tmp_db_path = tmp_path_factory.mktemp("data") / "test_data_kb.db"
+    db = SQLiteDatabase(str(tmp_db_path))
+    log_broker = LogBroker()
+    core_lifecycle = AstrBotCoreLifecycle(log_broker, db)
+    await core_lifecycle.initialize()
+
+    # Mock kb_manager and kb_helper
+    kb_manager = MagicMock()
+    kb_helper = AsyncMock(spec=KBHelper)
+
+    # Configure get_kb to be an async mock that returns kb_helper
+    kb_manager.get_kb = AsyncMock(return_value=kb_helper)
+
+    # Mock upload_document return value
+    mock_doc = KBDocument(
+        doc_id="test_doc_id",
+        kb_id="test_kb_id",
+        doc_name="test_file.txt",
+        file_type="txt",
+        file_size=100,
+        file_path="",
+        chunk_count=2,
+        media_count=0,
+    )
+    kb_helper.upload_document.return_value = mock_doc
+
+    # kb_manager.get_kb.return_value = kb_helper # Removed this line as it's handled above
+    core_lifecycle.kb_manager = kb_manager
+
+    try:
+        yield core_lifecycle
+    finally:
+        try:
+            _stop_res = core_lifecycle.stop()
+            if asyncio.iscoroutine(_stop_res):
+                await _stop_res
+        except Exception:
+            pass
+
+
+@pytest.fixture(scope="module")
+def app(core_lifecycle_td: AstrBotCoreLifecycle):
+    """Creates a Quart app instance for testing."""
+    shutdown_event = asyncio.Event()
+    server = AstrBotDashboard(core_lifecycle_td, core_lifecycle_td.db, shutdown_event)
+    return server.app
+
+
+@pytest_asyncio.fixture(scope="module")
+async def authenticated_header(app: Quart, core_lifecycle_td: AstrBotCoreLifecycle):
+    """Handles login and returns an authenticated header."""
+    test_client = app.test_client()
+    response = await test_client.post(
+        "/api/auth/login",
+        json={
+            "username": core_lifecycle_td.astrbot_config["dashboard"]["username"],
+            "password": core_lifecycle_td.astrbot_config["dashboard"]["password"],
+        },
+    )
+    data = await response.get_json()
+    assert data["status"] == "ok"
+    token = data["data"]["token"]
+    return {"Authorization": f"Bearer {token}"}
+
+
+@pytest.mark.asyncio
+async def test_import_documents(
+    app: Quart, authenticated_header: dict, core_lifecycle_td: AstrBotCoreLifecycle
+):
+    """Tests the import documents functionality."""
+    test_client = app.test_client()
+
+    # Test data
+    import_data = {
+        "kb_id": "test_kb_id",
+        "documents": [
+            {"file_name": "test_file_1.txt", "chunks": ["chunk1", "chunk2"]},
+            {"file_name": "test_file_2.md", "chunks": ["chunk3", "chunk4", "chunk5"]},
+        ],
+    }
+
+    # Send request
+    response = await test_client.post(
+        "/api/kb/document/import", json=import_data, headers=authenticated_header
+    )
+
+    # Verify response
+    assert response.status_code == 200
+    data = await response.get_json()
+    assert data["status"] == "ok"
+    assert "task_id" in data["data"]
+    assert data["data"]["doc_count"] == 2
+
+    task_id = data["data"]["task_id"]
+
+    # Wait for background task to complete (mocked)
+    # Since we mocked upload_document, it should be fast, but we might need to poll progress
+    for _ in range(10):
+        progress_response = await test_client.get(
+            f"/api/kb/document/upload/progress?task_id={task_id}",
+            headers=authenticated_header,
+        )
+        progress_data = await progress_response.get_json()
+        if progress_data["data"]["status"] == "completed":
+            break
+        await asyncio.sleep(0.1)
+
+    assert progress_data["data"]["status"] == "completed"
+    result = progress_data["data"]["result"]
+    assert result["success_count"] == 2
+    assert result["failed_count"] == 0
+
+    # Verify kb_helper.upload_document was called correctly
+    kb_helper = await core_lifecycle_td.kb_manager.get_kb("test_kb_id")
+    assert kb_helper.upload_document.call_count == 2
+
+    # Check first call arguments
+    call_args_list = kb_helper.upload_document.call_args_list
+
+    # First document
+    args1, kwargs1 = call_args_list[0]
+    assert kwargs1["file_name"] == "test_file_1.txt"
+    assert kwargs1["pre_chunked_text"] == ["chunk1", "chunk2"]
+
+    # Second document
+    args2, kwargs2 = call_args_list[1]
+    assert kwargs2["file_name"] == "test_file_2.md"
+    assert kwargs2["pre_chunked_text"] == ["chunk3", "chunk4", "chunk5"]
+
+
+@pytest.mark.asyncio
+async def test_import_documents_invalid_input(app: Quart, authenticated_header: dict):
+    """Tests import documents with invalid input."""
+    test_client = app.test_client()
+
+    # Missing kb_id
+    response = await test_client.post(
+        "/api/kb/document/import", json={"documents": []}, headers=authenticated_header
+    )
+    data = await response.get_json()
+    assert data["status"] == "error"
+    assert "缺少参数 kb_id" in data["message"]
+
+    # Missing documents
+    response = await test_client.post(
+        "/api/kb/document/import",
+        json={"kb_id": "test_kb"},
+        headers=authenticated_header,
+    )
+    data = await response.get_json()
+    assert data["status"] == "error"
+    assert "缺少参数 documents" in data["message"]
+
+    # Invalid document format
+    response = await test_client.post(
+        "/api/kb/document/import",
+        json={
+            "kb_id": "test_kb",
+            "documents": [{"file_name": "test"}],  # Missing chunks
+        },
+        headers=authenticated_header,
+    )
+    data = await response.get_json()
+    assert data["status"] == "error"
+    assert "文档格式错误" in data["message"]
+
+    # Invalid chunks type
+    response = await test_client.post(
+        "/api/kb/document/import",
+        json={
+            "kb_id": "test_kb",
+            "documents": [{"file_name": "test", "chunks": "not-a-list"}],
+        },
+        headers=authenticated_header,
+    )
+    data = await response.get_json()
+    assert data["status"] == "error"
+    assert "chunks 必须是列表" in data["message"]
+
+    # Invalid chunks content
+    response = await test_client.post(
+        "/api/kb/document/import",
+        json={
+            "kb_id": "test_kb",
+            "documents": [{"file_name": "test", "chunks": ["valid", ""]}],
+        },
+        headers=authenticated_header,
+    )
+    data = await response.get_json()
+    assert data["status"] == "error"
+    assert "chunks 必须是非空字符串列表" in data["message"]

From 467ca1eb5cf929eeda02f8b5801c90bf89469cbd Mon Sep 17 00:00:00 2001
From: Soulter <37870767+Soulter@users.noreply.github.com>
Date: Sat, 13 Dec 2025 18:46:16 +0800
Subject: [PATCH 06/10] fix: webui log output incompletely (#4029)

* fix: webui log output incompletely

* fix: improve SSE log parsing to handle partial data chunks

* fix: enhance log handling by implementing local cache and fetching history

* fix: log time handling to use epoch time
---
 astrbot/core/log.py                           |   3 +-
 dashboard/src/assets/images/loading-seio.webp | Bin 0 -> 12412 bytes
 .../components/shared/ConsoleDisplayer.vue    | 129 ++++++++++++------
 dashboard/src/stores/common.js                |  94 ++++---------
 4 files changed, 118 insertions(+), 108 deletions(-)
 create mode 100644 dashboard/src/assets/images/loading-seio.webp

diff --git a/astrbot/core/log.py b/astrbot/core/log.py
index 376f5ffd6..806ebcebb 100644
--- a/astrbot/core/log.py
+++ b/astrbot/core/log.py
@@ -24,6 +24,7 @@ import asyncio
 import logging
 import os
 import sys
+import time
 from asyncio import Queue
 from collections import deque
 
@@ -148,7 +149,7 @@ class LogQueueHandler(logging.Handler):
         self.log_broker.publish(
             {
                 "level": record.levelname,
-                "time": record.asctime,
+                "time": time.time(),
                 "data": log_entry,
             },
         )
diff --git a/dashboard/src/assets/images/loading-seio.webp b/dashboard/src/assets/images/loading-seio.webp
new file mode 100644
index 0000000000000000000000000000000000000000..62e159f9874190b5ff311e4fec323e146bf72c10
GIT binary patch
literal 12412
zcmV-?FoVxhNk&F=FaQ8oMM6+kP&il$0000G000300093006|PpNN*1S00Hoa|DP(S
z{r^37lMsk4!8W+NJ5+EBTuX}vcNTZ|P{F;B5~P9`FN<q&3QI#ugT6{i4JZ~N4tf4@
zX6BqEXJ%iow?@PS;Q#&qKZpj@44bk3>z$XbM#a2(bobKHX@xx|TgxF|orrmzN&2UI
zKK2evx86u6<KG2%GWiB=I{l1{eD>`A&hK|doYj!71$jM$fOf0Sy(Zm>?#Qtn>zDO`
zw#A`L&06Ta+sp$f*!SC*G}8HK!|1Tuxgl78`=7*|YSs120mbucvppu0g#Xwx#ZfIc
z#H(+3OzhPaq5n3GQn-*W&L)uP%iTj7mVoZium2%-%90Qmd3PV}vnrWalW(4r=>0{V
zib8+s0VfiP>+T*5WA8Pp`=Ymk^*Z>9_(?y6zwZbA-o3ZpBmR@AHDLI|_pqjiYPHz&
ziuh4;LT%6=&}VZL3C7H51mgn&AHEO84w!h4xX&Uwg+PD#f!kx>k>KM|m5_x2(Ud{;
z)vD(9cw#@9Q5Aa2g?+j!Dw9N0_H+(G)<zH!)l;c@r!t8dJEkTCi#UcvZvOF)4AOaI
zOg%4Tc~>HOP(Yy;W|B5@X(MQTi-u0$bS~yC=}$O0tg#o++|hBtLD!)ZM>lkHIBM1k
zFaiz3$CidVk0kb<$ekz7y4`<gl9A~@&g@dg($KN!dIssg=ic1YPmf|Z;250o<mjpa
z&B|9Fx$RauW$A_Ryy}Kc#ymK(ZRAG{>{eLnw4ZZ}vgOe}zN&_{=S5O~-S_Fh*0pk3
zp>6T?FO;1h%~UnOr+CSdH7ons3qiDK_+`reF`xS?nvtz8q*Bhj*2miuC^+XC<=|8K
zl+S0?Ys%qk6mP;4%K1^%6t36}GRLXPHtP+U<$*j(W<O0Pdc~$-r5=;1##T|TdI@B*
z@wJtyP>^Qeb28oZCQ6jAkS(_b2)j#WoYqo(iU(U!46q-_By&#wP^{<ZMylag#uxeg
zfyU3swBu@sc)un3bGWQRb~s(Pz4hb@@dfe*1Jg3d#N!GGAa{eMZ)uIB+7l7w*WnWk
zAb(?E1DSh_j{tyranw#uVVX8#etrOEPw@>tPG-MbM-=Us({;@YA#WQ1YZ&Y|$^55?
zw8|i&W0hnSvV>?{sE9p3f-2`Lg^+)d44Vi<k~XfHgy4529Kz*MsH|TZ*#96YzAC`$
zLqsDc5w($!-Vj)dmkWaRE=lqP4=pD(1v*olU2=K6eS*ss0M3&%NAlRKX@lgdSbai@
z1M5hhZ))fWdO;yl3kHf-0S1vw;{wI-6?K(bdDy*zP%BX?v`@z{8Y(qwi69%i9+6~+
zi8;tAGe6{Rng`#KY~K|WYCz3_o_l0f+8*8*eMr7Xh2RgocZF^*mQ=_x@7&KMM1zC?
zyda|Sa`F!@iyb86)RH<vl8M^MDL5F7NzS)?#IUk?=O8&bfLoHHsXAodl%zdG74FL`
zzOov8OcMXwrUZ9oM$t9}_<-cTH<$dbN{-IiWLN5)?C6?Ja?42mkBZ9esRGcm_A={8
zYPd5<UON?m5@y?E^-vXv68DW7{7GbFWO2z<CG~t=LoTBfg!anigo?Q2;`aEGRAjwW
zT9JyjlS)4oSpd_o-NGucO+gk~%&y;KqAvu_sK){eOnxU3-DoawK{=*aVDg8F4pfEc
z6~(w(9cI6jXd%S^5lNKZ>ph_`{Tj)%(_2Tfz}bruJFs`IvsV)fB=|KwF9e;h1sq2u
z26?(^5%k{W{b}9m39WxxO;;3eHpX}|)gGUzKfnP)5AZ4@#FLpv+ChdyaN+^n@nB9e
zMjFzLa|pm<kHz;iF{_K6o^YiX0K8;<4j@!oKbYQlVow!&Ld00Y8UtXcw8oiUnZH@D
zgzT@0UfKa*yJo)^fRobdWP0!qXIu~p*pu+v7d8z#Ih|nuP$OAdFYA~d0*Ss4Ea)W!
z3~vUV7B|T|V~5@B&?B-Kvit(c-R*X}yO>!vw7W?K8%nJBAEbnPB^E(yct&FT6ydPM
z_AA0@iEU7WgaYy@)~t00hhubP<WV)~0x33Ix5IVuN4MLZM9Mh}G7Nh`>e>Y|oS#X`
z`m_aP*pt+CS^-G$f~q|3S^$!KsvdV-YX-j`40$TZ_mJ#a^&p!8wVX?5R5q<O3NlDn
zoojE2h$76Yw}RZ&(>5t%VWVo*`o|SEsY(h$4TS99Ceg*Z08kueovt9OL~6YxiYBTD
zGrz4M6v7MmBW)9nDEn@sseP*=D|q45H8?qLRQdr^o1!9AlXErN3qy#gjj2^vlKq^U
z+W-`PuN+L>OG&6P>(IxLVYHGw4`xX6ppwuLnT$~rnj#U0qEIV&SXJdk1!>@(qR_8F
z(m19nv{4#!m4%wi;v;p5vq>UQU1*M}1>1S}Q(dUGi49Al@w_t%bH%)hB>hc$d21Dh
z-Z!lYR4#KL5c;_dKo6C9Xfdmx3V3w{d6H-#0GrBC9kT*(BhBg{asoiC%B(f9&uBz<
zqPCioDnmug%l3pG(|v!<TBYe=UMRfnar#zh!<6Q{i2>-ll3`aGvX~nGzS7i{!fd4(
zBn7NfnfY=+<)M>zyZ%%Ymn67Be|vh!^z`bIr#HxxD?MS|xnI*%WSazvbX;=e=R{K0
ziRNZsxWS!5irdoEia#L*&TneRNrA7z)Du-`n5k7E6)tFM4i)+urrubA(kq%96sQ+W
z{)X}_gW0!NokhN;hl)csM=Qp)-$WKbjvdtEc?mZ!VF)DIKp=X?cW&vG#6HfUl8~l=
z3jiwC8!-8JtgMoo1OCS}f4vWh>S6m<YvEk`L!4}$wt)8i3Edm{Kz3aJx;=*NdMJ&n
zB_Zi7VN2ptH!sNgQ8pUbb?UCGrj&4UK{H4^nirLI^`I?L_v1?fJHqOA$a%>nAop9m
z)U2z^01zqQ1TN&bjAoF$n@5Hv@v0c~Jg2?=5VF6Xb*a4C#(YRQ{9!{#|HrKRiC4#%
z3)v@rWAB3o?8*=MU&}f-ud^W~DSO6m=ur{CCSAu`LIp2p-6h@-L!8;f3g$+kH=CTL
zpoY5)cyPOo!zQwuSC_Y1<bE~*+sTQoS+f+fu=8&_<Ps@hW%*<hQAd$|2CNm>O4+M7
z=Qgsk<RPLYi&T~f6kynsh=>Y^9Lkbx%NfbJnFR$mrqR+O)L1IB1?n<#?a{Os`QCuY
z?B~Vm%(-G%qeU-ie|6yA2&qic1)QV9t_C6pc;#|VCfK2zO@=*Bj;ICzyN^hvw*eo|
zhIk|oIfpn+I1>!JGZD-YnHHHi4A4D_b5kH93oaS-kkgnmz_4$QvYJt8rSQAO>Lf7F
zxUZfYbc54?<1lPwyvBa`XKE{xb^>LMLf~-Mk&_!6L2$BhTgc$+9B|qgR*s4RxI{!w
znFR74BKtZFJ8{&gA9&G>%mRktU1I=$5>XeK;4Ei~2~>zS>KLzehNcUQUUofm6aZ&J
z?1)@av3<!H@0%lr9v0e#e;Kuohw>9$V~WA()kL%!a<<j|puR7%vq&YBbe`ipErBSb
z>Ih_Q6cNppRQ4AM006(nL-xB|a|;3A8SsKAx)ri%1ku4jMXJMl3%$kSbZtVmE}s|5
z%!}8Bny+-k7R_EN9nZO@52!t4mTPnP;3o53cU`0W;i;bDd~Sq?TqTb2w7AEHkSQ*g
zD?C38Z@TaDfgUQAci`A@BP(VvgFF24?8W0fK0v<=BBC&b`kja<y?)NSN7{D49n!|A
zlZ}}DbKakfKENABhB_5u4a|9eGr9w@jC<;2V-3oADU7bbCybuz6kr;}>;_=!PcKe5
zq0aus)e7Hz_T;uXRfKYPUvuc{^&{VQw2IVTcJRoq`6W5s0k6qxKONdcQ-9##!Cis!
zpX@(#{M+|M%6+o`;+d`8td`DW#|{gXo}W=2qlkN<E~oC1G~(WG!6|)?*!u<6lGXu)
zz9S-v*q%YmWBFPBU!@WA@9U&(uO`dil3?b1#*7RSeK(O&{U6fX9XQUI4y+`-F@c(*
zzms04lB^<~Gc=7z=X(J1JSN@4fXj?2z&c&DRCAG3sKYxwne_owU?p>o0{D{j4+m~C
z<^hrV(h31%NICMb28zWH`_CsVx&gp??(N=g#eMSD8pWVM6iwtLrWmju*r<;>!4k{4
zd^uiW8WJ<AGVnn>gX#mY7PLZ}cLk#!W)btJ+LqkIQnMhYp|^b-%LzYXUMdX~JfH}E
ztN}tR8Og-~pgC(EgqJhk$6-cNK>(O3aE7r%pb!8&=QtQ|3Ic%7eWmCxbegda%xK0z
zR^fhIqi;tOvkTme_0amn>DkTu1KMboWj<pwn2VHRfRLLpnzfhV0#JCtLlPdynZiIc
z?;67eY+{^c++-n=v6wYZS#FB$<TU)A^bX)mW?kl;(Q}e<UdIa7Tr~(_4Hmk<*u#oq
ze1{{XeSUh<*fDn)JvsXsmS>Dnz)!qL#%abyPB`PGzs7P~DV#!)jEpLp=I<CoK-%Y}
z0N`6jFKlO|m)G<r!%pd_&7j@hfcIt+C_iCBaZRoP^TWI~Ri=(BA&Vf^g~++HW=@+j
zY5a(0Xv?7c)qxM55VJh1Hvss=Fv8HEK@S=LZQ_jhjB#2AVj1*c@76~oFg%SYc>qxM
zFCx0?2MkXqO6e|%K$dV{>s<zA-20u_H{r#&nh)?fP0T*<jbl*y!$-s&%{v4vF=hx$
z*on&NL_{g&@DpigqDC4KQBpoR1RJm(^;x1-fmjV4-n`&7u|t7LEa6eSt-u<_Nyd2|
zjvBF+n1evfD6A%CYgv5-EYLF)z+#4QW5CO;Z!B<u@fk3Oaf)$PAkQfSB3UCjPc5rh
zp>oJ&z#0IfGek0+761Vcbaez!^pP$naGWs<n8rBCIKdbX0M<!yti2hW_gJOyGh;rg
zFp`4hfFJbr1Av+*d3(x&nePB6=8`78BmmepaU%9;(kcQI8O?zzshX*b`Hc1&AfUB#
z`aEZy%EaspEYb`D>OUu<Yr()IBFgLnN&2+x)~#Fj?md`2d-iSucA3Fz4jx(6zZe87
zjM?hiII<Ef&AWwt90GQk5gT`Z*|!9&joY_tl@9=Ff7HHR82~8Wxofv376w}O>C>$`
z01UW(re7`qDE|+uG=PTVMppuWyuD|4_62~d!v>dvXX=wkMCsSRjlA@RnCC6<tXq@r
z7VxmA>xzJ<UHXlVwLTsfimgf(xZl|VPdrcaF>8)paxL#))q?-`|G%9909H^qAl@JV
z08n}WodGHU0RRC$okpEXC8NKgs+Jnd@Dqt<Zt{!$#c6ZP-oIRXK-Zr}K2z=U>OXhf
zRx{Sw|845G^^Wu}Ghex$v7h%pZhh(hk@W!n#niX^vFw@B>HX{fSEZ(EfA=4vzbn7k
z{y~1-`uFA6<UQN`8)Q$g{5tc+{NH>(H}wL!$79Cv<`Lg7H~+WuW9=WXCw_l|*W7>T
z`vU(l{|Eay?+5-j?dPD+uRVqOME>mm|Myb;v1q%5l4_|8+~T-NCX4@4+SYd0^U^J$
zVR|}Gv`M)F{b-x(e)1e{UkN1DQVV=|viK|S$_2%9?5wxFmD?i{z5KnU%^yV3-Znk@
z`o5(y<C)5>{s3@wIAd2|Q`%Bi;b`5$c7)xjYgPL;Ta7qz@io%se7w}UsG5CIN~tCT
zS^xzIP!9LPNjk&3;yw3EXrj3Xy0Pz#*Ii|pV#07`b`i;qoG2(~qKWcLCqz<D9qw#<
z(Er(`(G7jV5V(cJgnK1HYwxNn(qckG*%(Csv*vBbpHHCq%7Y^c-y!i_0W*a`eeXcB
zESRVyw#mw4g;FtPn%ul8+04X3sH&YDHpn1M?Bmiz0}U}t|5zI67#U6qs?9W^%<n~@
zB>ULt;>sd)tnY;S$0wMx53G)z^7RJYVh!ehbdk=ZX)-VAhvN(PEUV}lRP~}Zs|VY|
zcQ<vaanT(X<H?h(|9ePWz6hR=$-*{Ti5KBX9g^J;dy046xPQ}7TK7UjV&4|*DHf_B
zDhVBt)3NPc4J$+i@*b@s%#c1W|CA*L?Qn1<z&VU}Kn<3DI?*zS*bpZ;H3I*oOCBGN
z_sQh}5v=Q4QaeDxd^>lcaHpN|O?ja?YIeHBXVMV3K7gtR`AJULY&0}hkoKqmrZv=a
zENF@+knWfY9|ekZp9`vT(1KzU`{!e=ufYh^Ncwy~p<c<`Vgim!bQ~nG*s(d5(}*r=
zLJ&Iy_%J6m|2SMmWq;$Ec0nl&ueb-@V~3=+4pL-;&~}1*q_p_@M)xSWn1`)!AzjY^
z!Eq)dodv5LSwZtdyqthry3|tm_i9NN#d_SB2gpj@4#+N@iSpCe?JO#nX$27w8vizW
zKM4>G1NRFe0|dz7$*(O!iCb)3Iy?O9PDD*Rui8U4X`xsbYfHUb3RZv|F_IbLZTUA>
zmz15Q4|D3XCijln3A;)3n!{y_Qdo4NxsSD0ULyKs0y-<1*O{dgqfkyJeF&2=%W?hp
zsnP)biy02)A(V6$ZanLcWLmwQS;6TI*{MPwa>jo%j+|428Bg<!TrO%+GI3@P_rII~
z0RI0&`~U*wYhu^(zI$6X`ix<}Xt_Cxhv!N@0?V}yKb|CGTuRLQy7)~37S{x9f)+W_
z*Aa&Gdirg=&NluzeRpfZ%SZ_<9wCjs^J)DHu*=2Xcxln|!et6E@w6Y=UBe}3Ow!7<
zCvP-tl^5E&Dh`_udXXBUfBGDaE@sirg6fRtIySo_u#>$LU%|QO+u6G41?=pT-(93?
zV_uJx5EA+7Znhd5{ZK(Iu7i!@H9YoEKztJj7eWnC+2aiJ{6P>5q5^}?4{_sPioRxH
z^Bz{s^Id$_2>YU8nb*ZQS~1+UPGrZ66m{71)4Cc=6aG2rVuDjKKO%ZMGhGs5^z$EK
z;%ph_vWR4Si<}CHq7C93fn~;*5i+yfIsJLMf5|MCfZR>1YkyIHS7h;LpB%VSP{QOu
zJ~6{OysX&5>C6F{E@k5+<R7m0blzVz*8Y4J(r}eD+t`Jcw1S_yyEd%3hMV4?$67|P
ziXl8inO7%DUhna=R`RJIq)a!Gp~wqb+3-`~Guj|G#0kHS*7D6=O?@F_n0!(H_PDWU
zx5kZTlu$DA$9DM}+7`KKyMm)N=fA-orZdEY4rVrZUQlQ73c16?{*n5NW6JPXRv9vN
zy$wN4M0m78;$!V^UWR0WpaEY?>Ia2=g8`UVlVnhj_7phkG~d^+gi%30&UdNLoE;vl
zwcZ-4{eXAx6un>rgk|EezP!?<L@-aLno)+<PJ)Rtd&(ss1vfzYZKt5y_z!ic9dF5W
z9%cqZqSP=`a{qO=v{D4>B^q@aq0)WgxNq@nE+v`?uenB;#wW%|1h#*YD3ss=TGeG`
zm-Sp&AKi(XZ)h>(W7yxzcv!1VV{?a&La~?&=+Fm4DhH{HkoACS>C)%SA5Va>fGg~1
z<&l#5+na1Pv9CMn-A4KY>w`wD3n{YE>HR!8r0oBdEd}C#0LJHjc5FJ0B*d9EO0Qz+
z0%#cCW0i88%zW%S+;$^Q0lB|idTXTX0+1P%`l_{f{*IM0#A(`ozB2H#y;Vl?j50`Z
z$WJ%v%Nec`_~iBk7^C{HA*Jes3xESLsg4Rj@+&_q@*#3}_6v2k(WE`1cd_)hsj<xq
zyB%!|{vlrRt}7eDLMrAD{&(?9B~}!Z1iu5;I2<|W0y?tat*VyKeQDCGbbm#E$XI)!
zUqUHN>1@B15+RT3JpkK)=%nn(JGWZF{*P$&4~O36tkcoLV8a&1y)wsFBvI4*=cb^4
zca~xAkk@E)Vm#?t7C!j?G{y>t6z}$+v4S>S%ydUgi^8)&;w!J=`nYamkP0dIZ4fTX
zXa#V=IIf`PYnA*w;(C_V)vW_*AQNBb9+qqJstPQp)Q$~mP50%oo5@)_eqHI0cmRk`
z?Xg>c)r%m__$VpK_>!;~cdUy1RLIiQ4HT$j9`J=s6Sxe!Zo_;%bZt~OCV0&!VTZ-K
za8=PS?RKGt<lY*b5avoPA8@_wxYE3SZ)SF8NvO?1^ygJvmAhuwfT_M#Irtej7V@I*
z!E}2q>$Sv*IC3n_1mfbr*)@$kCJ*+va*p(Oa`v`5ql_xWMN*jyzAS>>yM|BI?XbuX
zlDZINrodPLdLDG{KWKRL<hC}0XYUJQj=?`jimB%|YmWJ`{`Q0lL^)IKU&UGa_!5T_
zE(e%T#@r_RbyX@oj_%z}4h1-I0i*Z8;^0Qd$HucmWK?2qG;uC{f(C5es!CbfT(aln
zZ{dcS#wUgMa~0Ev@dopMGm>G#tjkx@lg}y`C>0j+#`x}0Mz|UhgL<`@C7FwO$My7V
zsL%k5C5X|MeHaOxB@vI;eU9|-yIK{3LFQ+u7sM%33GOI}AsQFKBf=i#arO)o@C%FP
zVTGA4Orzz)2<dz=%pYSp?nk^b6088z`=-v%A3ige*eG61ks>Dry(Y@ge7nVTgKI@A
zQRbAkU0-a-M&*XHrsxv)adl?(&+59A)6YZq_NzD!86`7a2T-xEKk35;XlRLGXsP14
zN*BoJM!zo7Eyyk&7~t8)RD-A|LBx4XK4W~aJd~azNdO}rtmE<t@KiX?p~eJjC#LM|
z9p}u%uWWZP({LTac%H4)S>Yuc4#nDxg!xrl$}@$QJbGUqYag<b`B1w&c{lpgxyWb*
z+y#^%B`5gT1r{7SYNs1t7w{HuTW{Eg9l>h(5Hw?maVkXnjwsOSqm}eM`*uuEit3k|
zTmo?8264>ZjIWgLy{4;jiT{cDLVjK-2+f~<7%|OW^N*)sPPUtxB!n<1wZ#5k6zUt@
zUzD=^kIFE7c89J$P8yU`A?|45C=F$FXC<(j{_mfE6B)w>rJ$#{^(zgS-VEs&=q`BA
z$YaJ6b>g=EX(sh~hiqgG4`yzq0Xqd-j6xfBkK$9%+<EB4{kStxcMtcK#8Z??0et<^
zf1?B19<6e=lPkhR>SifL%$;;F_kgKOTi3;uZEO=UPD|=w<<V)&mU!V0$UV#WgH9kg
zTTP3}!MTM0x>1tmy-!G0y<Nb>PZkQzn4jFTFT}jRR4ooW+SK_HIL%(VaNt7G+iv)W
z>JZPZvL~5IExqk}<7zP7Fkvo*s&TFa<240&2o<z{6W3oo+<!`;X=lGMpAfoQyDkxe
zTk$Zfg`*|MP5W;?grl8Ni!(t?ovE=Q?=}{6e^S|0^39w-9G4{q8hQ4%?Aq7U33ZrP
z6eZK-fv7B4(E8co@|HC>p15zR?~azm_n~;~*fIj8v|zDe#$fa?W7#-A{-}EuWn@-p
zo=k%Wlm0UPR;QeY!PSb(Csg~TEQERII|Z+X>J-xVRA><jWT4FR&Z8EA80#Adl%-c-
z^WAx`3%Y7h<7w$k5lX&jigX_e4yZ}Z9+b|-MGZT;hC)U$ejnd?#$EO^9IGT5Bl1g>
z(KbA0yj8_IH53%N>-;(_s#W{Yi?iAJ@C@(2pe?!~Prx(m&0r8Y&6jEGsY|lOwS^fg
zxGYK*139o|6)L#BB`-Q2u^xV5Y7ivK=^1+vTsYEi1f50HBMe&FJ3qgVD_I8;Zm}^b
z%8B_L44m`$GZp>?=G&6irZdAL&ml373>tjJw#^=O#TBulqbmaF4A$b9up;O=mLJNh
zQ35eyWB?hC8P;>lV3p?Lkzrk~=X;R>mytYy%#ztjkJ9+h9)M}Tth#lyO)w5hVa)yk
zYqouH2dp}(^K5^*?g<;K(<z~KTcHlWxTl6Y4;KyI<C{@7@STUwlE6F%@RMtx1kbmT
z&w0*(lnAj)6<T6Z-aK^-0RO7~<F-ET<6^EzugnCAG_jc^<45~KJyz`bE3JTApJu8l
z-mzxXizpB*jI(TKmimjbH~e~o1gkP%Q9o4>2l%8NA@~Pi+?(0+qcD>Q^d8>$zl`L-
zWdW*635lLdmp2{u-|&xpl4bIut>u-K(4N)O1N@slQ`$@1VU?Q}bZ(Kl%&&zFz_ARO
zKZ56f4bQo1&P0YOEDlhdbM+MEgaJMAx($Rr$4&uUi|o+1{O-4=03(t{e%Tm$pre)5
zDT>W#!@!eq+aS)TL8dZB3%0Gt#^EaTw*%>UpHry)U3}|7B<qb6=ewK=pskN#o%Vb-
zEGJ0l+V)S?-u~S>g${$Xizg;gBPX;)wn&rP69XWGGMAx;l@|?!GkT@W7fhm_kVOv0
zUyJ%8!$}Qs5muWQ+?6lEnFLox%-tl$?ZCRpLsauIx1gdRC)|^sxg1xxB(%K^rGhI%
zacy*SAB<ow2@>;&(Gs1oUnHOE<@i9kYCtVS8DXUJpqwf;hpa88n&!lqeAQ!FzkJVA
zt~NKQn|!%0Bv$XOWPWo0nepfGKzoSiv2C^QRNQwBD?$fK)3VGgf#;AT7umauu2#+{
zP4#IJ;haOThI&NGVW?;V$iJJR91GW>rIR;THi|$ck)Z}Ps`3Scm^YAQ=Ih`;5I{HR
z-A!Prn*l}s=iu1nEt<)ef~yHC;X5q#P)eyW-WP}@bkPcT&`t!Pr+e;X{ksW@FJgNq
zwULPmhdAhWuTyiqpl#I(4oo9KyQyrDuGXM)d;Vpd!?h!j8`PNRtO`ICe*+K~VlP;g
zJcAupYS~@^KQ75X_JKJ~C8S6-Or;SKR`Wu1_L4>aQI1JY7QwZ$h;Y<k0NF6hoXye@
z94Qp-?7%-)NH*rO>1j~Yn;&a4=f@~-oK4sMyKtxrbA~j(%kEzUn1=>qP1Rx&n|w;x
z&FT`}JGUR1L2dm$CHp6Xe!rnUsF*E1Ob*NHN>=Tz#9f_ZeAx0|ZQo<j3X>N>-l59I
zlc^rOMx6xQx7xd@sB<5>Z`u}_i_Bo#ug&&hmeJi=i))`#;7`PVWGCbQ_q0#NyAM~0
zQxYC_3NhRTpswVRw|#|RD;z-Id%hu*F!uZiG)47SZnYWIPjs5&tJl5J?!S6aZb$?@
zyWoe@QITS(B3Wh|=t|xSN7Fxi#ZHnf9T!pWyMJ$C<O$lyJ8HS7M=PK|3?>>3*|lQ4
zfiuY9r_?L{=02|;52yfK>bB9&-_9u&7wO<&K%PS&^JJxXB%YMI&&8rbq|&{i;Cnv<
zWWjU{d(td&r>obM4GP{S63t==*j5wTre5SuCGBsXV@-Ht1`jj9X&Pe2#S0Hs-1qqB
z(Q>?E83&)jjqqMMVp6bsa(`~g8o<2^DVXw7w5XmGXLObOU3|^0U7G$h@5>fv6HOHT
zH}XhKi6;oDuc&Fc8uo<N%m)1Hy2qNfWmziaD&T@@Xmu>yN%p}3K-$U|C9PiV1nv9S
zCvc%PH1N?sqpU0db0_!j@`K44DpHcv`YL(G32W=uEf(#)1f-kM*p|iEyyxNy9%h*(
zY3mbL-D#5|Fx=DgL#C2%F0iq#)yVec6Y&=)2K(#os(Qrh@C8M$-0jHK8r@zbe6ZgW
z;FD|1B5NZid7g)z|Km$Iuc#L~YNYJ`#*kW2NmEPUb7WAVatSUx+zhW!!BPETu_f{4
zz#8QXccT2J$4;YbWa`Rwnx$gpcQqnoD=VSikrv;$pFTc5x0s|$Fjzl*U9BJc+e==_
zL;>MBD6cHr`^k9-SO9lwPtnBZXKkGDS+wd-5+dR;V9~5!e0TqrCVM2ji&Sy;vYW#)
z@QQ^Jky<C^714988aug*vyE8i+!X)b8U-ue%nTaxw`pz)ngKZqa?EvORMAa!MJ4h_
zzp&Yi)`Ql4;!xn~jWB?8S{BFAM))-%2*s|`63rAfpG6iQ@xZ71FtH1J!?V`(+h%a;
zbArIMPnYA0>Q^I?rcjir+m+RQT<CW?vDC#7Z~clFQl|2;O`=}ed>4vPrD0jRxYSGv
z5bD=rlf`X0U^UU>+(459q>Hzyhj};h@)x)~Bma;%2Bwl#un-griW5HJPTPA_C~MYU
z30NaP(po3tGX({NqD)7;=}}=k#u9Z{8Vx^6{C(rqX4d8n$1}3w#q$X<*d2%<rl5DP
zjBh7UO`Vj~nz>Z0Qq`gmS=vF=@)KaA6}}mIL{BnnFkyN@FA-yV>_(g-kcx`4{S&Wx
z;KSI-a$S<OC5}HCW^O=ZaVuD+p2~knIMViUs?M=_ZSTl3ZSi;z)5x19_%a;?U)bf}
ztFep5g`O0FJB(^(VJaHyIv?)4)L#?S3yfwzLGDo=X(3evAwWpEQckv!j&U)C{5?q>
z_QVdAale5F{~hW_iEp7Zbq3i6FyT!q8er^7f)hYN?jo(F9K+kz&wEr+Qzgt@X@kIM
z90{)|rQ81c?NSc@co6S-$et5pylD#@Ua){eY*u9W5ccMIWJCvwm3e2-4MsxRrdJNP
zO#G*MgB9z{d67{E7|qX-z5@gK9ZQtVcM({?Q-lX)egEi3QOIvaGj>$PO8L}8lIMth
z8k~hDv~0XpgUE`Y5FjIQMwo{EXyO3-pqnDfn=tTFbz7TO2o3CrA>8Ky_}!eqieYT1
zwqj=GMS#5;yabSvKt+lTwziACv-4l7zP4Uy$xyu21;qO~wl78h|9r3Z1^@XuDZViG
z-29F7+1uX&{~?mJ8hLckyA`tDB}MRaC&^eIP(1<F)wmf#iw*>6E0sNSuDbp6eWO+C
zHE*=H__wKaF)vTXwtj>a@BWC9LKajvRd7f=caE%^=4Imv?RmG^ajFFjnU=H1zLR0@
z;e7VJM*$Sut`oGqho!`vKZ`lS7;YH1GO1O2M#9-lnI4W0Bpvs2QLIjNU$p&7wE|nY
zy?+gnR%|(rpALHtZ||={5LUgeloz{w7Wazxc|n9NO^h|{)di6kF28OYoj@_ze-n2n
zi9%CI-S+{=+oMyzK5uO}?+77lxfoCNDW{KASXn)!bbukrngu*o>u?Rja+9OWs5j6t
z$2g-=k`~omK93imJAXW25hOmfXbkE?4pSD<y*`%g6^2x$A7#=;t1gZe<MhPe{(j3l
z2o6CfHW0sQKI{)GaC^m4v{m-*EuN|X0hu~ZC5)+ctKFF74|g8s?qrXr1z#q(%r%#-
zzLT<e;0j<+3NR4{_VNA_|3d9sB*^~B^oZ_C{WTJp+}?4lCu6p+pL*#z!oPNIox_d3
zhVi4b`UgGZJ5PCR%MTw@RadZl3uQFgt#eMk`!)a$DAqBZM5c7iFqs9CQgz(QY@!SZ
z-|XGg{TCG4V^p;Tx3H*HHF(>yUA1y3`ABOVP{I|Via}Oq)8jD1zX--ul!3Mew*|w*
z#5}1Eo?!mdHKaXf*TtkgQL$^VwMDu!iBI!~&D3Rcu2*8i%R$$i?oXVRW+9fLg~J1f
z4kUlcCqMQ-*m$W5sL?%Z$jE^HW%xfUYXu5<W(L9PGd#uUY<p3{_7^mt0D=G4_Z<P^
zhId|nL`Gx6)Q*apGPmN2A>tl4m_*Jd;`}om3~+alLBaSlw0L@Ru;d?OP9b{8Hhv+m
z)ZP<ODfz4AB!`0MxA^D!T~Aq-XXtR!53{?AJdN0fq$Vq!Hcl|1NKngxsY|z^td1G9
zoy5FnmX;H|F~?PSC|2*sF!~<hUzw<!gwWBC&K$_?KbYywhu9Lw1#q@10Y#zA(nS9>
z7Hiq&RL+W}Y{-OQzh=;=0b)okVso4SFs(l?mIe6L>&4QSrb?aMtaaT^{S$l`cd0y{
zqaVewnFcv7zjmRsp=pNdxBBW1!Pltzkb|a23`*jK7$S&v_J!t86*@Y2+}3|Gm0_)-
z_<(=f8@#xMnhG`Q|3SGQ&Kb6_bcw4rquxQpnT|=P7)kvaq$)&O?6ccIg(#*8to;j(
zx{TmL-Q!8%lDo(tv-#U(i;?GlCRV|hQ9)3BLQ-};0vTjm{(;0|O1)pKlx=VHn-v{u
zDL*X&3)tM>;B9nS&aet4s8RdGMX>y$c%u4`B;auHT`WEbq<b*xWg6B+QGs2)yfHg!
z)Rql{S@CuW!xZgPFxjTyyB;`ONgjzTLk8rDej4=g@9haLAKTDf34}UD)bYb!i4(>x
zFQ|-8tNyRy9r(f&H6>OY7(;|9{>C30Tdw$1*l}DTxAbCY#qA3EcRkELzQp1>MG*Tj
zIP_`|VePif7Tcg>I7t$xq}HC$%7{5YeMptRQ3F#TjW3Cbe*h23<c1`AQ3_yDZTLSH
zSL+H|n}5iF8b~O+D5_&DkdgImWuTlnjnL`038)r7Y>57DAp}iFKFIQLy@Oa+D11`T
zY`+`Q^w%5@E1NX4YssbxV#U%2tDGL}5VS8=Tsv8#-ziV(X}q|=tff;=+XS%4?6_bU
zOgH0ZS3v0uUo$P3cBRV7FtQl@Aq?xvWfGHO80;bP_^ValFtlmjgTM)PPKqS!z|e{z
zsODY$e#hM$dr<WSF!T;=nV;idDK-Ib3#8b8^A*miqHt09-x;<ly^Zg{Cite-(oSc3
zgs_%pmNyt5ZC%GBWJHY_FEroh+7Zc#;Rr#!>lV@I9+Mu|MCM@(A7tM#1jod-8GGd8
ziWNW#4*IUjvKPknLt%hUmUxR%uY)>?FGG51q#~c0+?E9DzF#{ARqdZ9Swc$RXKL3a
z36ytvIW>Spf{|19oH+2ZVCcLhfRglYBHdB^Ptx?dd(8vds}~g*8HD4u3?6OCKR`1N
z`;*dUx(z+Vev%!g**9y{x3=bDK};q)Df)*JAtz5plmiJ14Ie(pCTClruP|kHo~qq>
z3WD?@m)hlmh->N2FtkpCC%F(8)WRT<Z483341xOfHmPodLAjHnbx%{VHuO&=-&tO$
zK!8;9w{>HNUC~r;n99<iTkx6$*kcdmeMV3*Z}wTl@)2|_X}pBtIB5>skl~SK?3-l>
z+sWV&3;oGH>^AwKmKwc?brLmr!U~O!B6Ks*sA?;-v4yG+l6N3hSgG}aKNSms$D1Kw
zYxAGa7br+~JSFOObugv+2~uV~;(Apj1nlk1yRgSVv)+PELDI;D|3Py(lpJ|v{s#M!
z-4lXOnAxm3SQk%fj;S}WS()W#eP^3SWQ63sj!$d+B1-a4=wA?7$Ca~#MkOy3G+m?o
zJW0?VSeLfi4nn!jy;{7HyQu5*On)ZzpT^y2pb*HFzJL=+jw07CWrzdP2&l!yio#og
zdoL{=Y{O}k%(InRQ)RGx2k(e|Mds?C`)nBAlb+&R+6o}z3BGKwAQrXX9#NK!Ey8Ys
zhyn?sNi{>MZ^5~by!Z>>n$ppe;cpHR$dnez5Ko5YQ>fqolE2Tr*!;!;uray*;`uZi
z;AvG<jPfY(qHDV4)H{uGZ9`9Gwym-TB0E!t9z7Or{i)&EP`Z^XjbZ96xlaW61=j}#
zf*D%)`h$(1OPrTNTxpOak`97Gu!+223yJhxz&U200Y=Rh*VZp5eyPd2BeVz=#hT7b
z8L00M_@O-ndekvb*b9OHT)7_k1R+WOWVB<%AIVbTjx!sv3KLe*@a%0u1zjdWU=A7j
zoT8@WEl;KLoF=`Tz%S%{<}Kn$_36H+6WVV{R^idCT$GZo=2Fzhra?HnK~d17y+<eQ
za&^rikwNQh+c%XI+L#v%GkWsEzE;T=;-ZT9)%CR2ot4Ptf(JKzT8Ij>BO)~rr9j#$
zl(Ikpw!PJBhJQj=H|OJPfO;%)@<mSNSIOL){vApvy=y5ErxS=7wfR;Q4t&^}QXwDs
zRZ^^m>NP4Ljw9gnSWzk4Aq=Ua-iG|0;_$GtH9$q=#EBmxKbrq`EEGEzGvag>QS-_)
zS1(FG68Ws-y{QU0UhxTeVi&}VZ*e{~yq1F&NF$-6$^JIiLDXSX{_wQ@3ul5eFq(2N
zH>+*puoS0py!WTCXm7!`q1iF?KV?Dfmh>UuMIP186h!<%jz92th=s(Op{tllAfJSV
z$T!S-OF09eH8f^4wXIUm;zs>xJ9t>3Jtt~&$$-=R-jpV=(M4a&ex0m7c#>4}iGqbk
z{o$c%ew{ZT(N8?D!wjmAUcMDeCJ#z``J8pH$pn9V1Cry>&bmEAYBQAxrc2z^{`Enj
zkIxA-?qo?@_cz!W&-$L(tpM?9$uRB$;dKiQ$p_4AnB%+HJr7^M<Z|<@`O7|^__bBd
zoB!&`tI3>qp7#22eYtx*v{b6ljy*}oxz@WpVD@fBOzCNkz~UwKRVt7{h&^|I$fq%Y
z7eX}v&khBK!NiHL@(J2{5usNpd8l~1x?$J2SD25(Jb}R|Refy{04gO!xnr_8#Y#=z
zhj7PTM%s2eSx?(^DJ!bBEC<tf@<E_;`PO#br$^o*<xs6;m{YS_$RoUV*5_F%-B2?Q
zbg=+?vOX*C%W|tWJHR9kA8a)?a2L4le8uUZVro7mnuTmftYV{NE+OH`=bDaW)*7%t
uLp7pI)3O7GO9LGX5D2e5aRdTMB@1E3%^zRzG-%H#00000000000001W#}-!r

literal 0
HcmV?d00001

diff --git a/dashboard/src/components/shared/ConsoleDisplayer.vue b/dashboard/src/components/shared/ConsoleDisplayer.vue
index d3fa591e4..7d6759dfd 100644
--- a/dashboard/src/components/shared/ConsoleDisplayer.vue
+++ b/dashboard/src/components/shared/ConsoleDisplayer.vue
@@ -1,6 +1,7 @@
 <script setup>
 import { useCommonStore } from '@/stores/common';
 import { storeToRefs } from 'pinia';
+import axios from 'axios';
 </script>
 
 <template>
@@ -24,8 +25,6 @@ import { storeToRefs } from 'pinia';
 export default {
   name: 'ConsoleDisplayer',
   data() {
-    const commonStore = useCommonStore();
-    const { log_cache } = storeToRefs(commonStore);
     return {
       autoScroll: true,  // 默认开启自动滚动
       logColorAnsiMap: {
@@ -38,7 +37,6 @@ export default {
         '\u001b[32m': 'color: #00FF00;',  // green
         'default': 'color: #FFFFFF;'
       },
-      logCache: log_cache,
       historyNum_: -1,
       logLevels: ['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'],
       selectedLevels: [0, 1, 2, 3, 4], // 默认选中所有级别
@@ -48,7 +46,17 @@ export default {
         'WARNING': 'amber',
         'ERROR': 'red',
         'CRITICAL': 'purple'
-      }
+      },
+      lastProcessedTime: 0, // 记录最后处理的日志时间戳
+      localLogCache: [], // 本地日志缓存
+    }
+  },
+  computed: {
+    commonStore() {
+      return useCommonStore();
+    },
+    logCache() {
+      return this.commonStore.log_cache;
     }
   },
   props: {
@@ -63,13 +71,39 @@ export default {
   },
   watch: {
     logCache: {
-      handler(val) {
-        const lastLog = val[this.logCache.length - 1];
-        if (lastLog && this.isLevelSelected(lastLog.level)) {
-          this.printLog(lastLog.data);
+      handler(newVal) {
+        // 基于 timestamp 处理新增的日志
+        if (newVal && newVal.length > 0) {
+          // 确保 DOM 已经准备好
+          this.$nextTick(() => {
+            // 合并到本地缓存并按时间排序
+            const newLogs = newVal.filter(log => log.time > this.lastProcessedTime);
+            
+            if (newLogs.length > 0) {
+              this.localLogCache.push(...newLogs);
+              // 按时间戳排序
+              this.localLogCache.sort((a, b) => a.time - b.time);
+              
+              // 只保留最新的 log_cache_max_len 条
+              if (this.localLogCache.length > this.commonStore.log_cache_max_len) {
+                this.localLogCache.splice(0, this.localLogCache.length - this.commonStore.log_cache_max_len);
+              }
+              
+              // 显示新日志
+              newLogs.forEach(logItem => {
+                if (this.isLevelSelected(logItem.level)) {
+                  this.printLog(logItem.data);
+                }
+              });
+              
+              // 更新最后处理时间
+              this.lastProcessedTime = Math.max(...newLogs.map(log => log.time));
+            }
+          });
         }
       },
-      deep: true
+      deep: true,
+      immediate: false
     },
     selectedLevels: {
       handler() {
@@ -78,14 +112,37 @@ export default {
       deep: true
     }
   },
-  mounted() {
-    if (this.logCache.length === 0) {
-      this.delayInit()
-    } else {
-      this.init()
-    }
+  async mounted() {
+    // 请求历史日志
+    await this.fetchLogHistory();
+    
+    // 等待 DOM 准备好后，显示历史日志
+    this.$nextTick(() => {
+      if (this.localLogCache.length > 0) {
+        this.localLogCache.forEach(logItem => {
+          if (this.isLevelSelected(logItem.level)) {
+            this.printLog(logItem.data);
+          }
+        });
+        // 更新最后处理时间
+        this.lastProcessedTime = Math.max(...this.localLogCache.map(log => log.time));
+      }
+    });
   },
   methods: {
+    async fetchLogHistory() {
+      try {
+        const res = await axios.get('/api/log-history');
+        if (res.data.data.logs && res.data.data.logs.length > 0) {
+          this.localLogCache = [...res.data.data.logs];
+          // 按时间戳排序
+          this.localLogCache.sort((a, b) => a.time - b.time);
+        }
+      } catch (err) {
+        console.error('Failed to fetch log history:', err);
+      }
+    },
+    
     getLevelColor(level) {
       return this.levelColors[level] || 'grey';
     },
@@ -101,41 +158,22 @@ export default {
     },
 
     refreshDisplay() {
-      // 清空现有的显示
       const termElement = document.getElementById('term');
       if (termElement) {
         termElement.innerHTML = '';
-      }
-
-      // 重新显示符合筛选条件的日志
-      this.init();
-    },
-
-    delayInit() {
-      if (this.logCache.length === 0) {
-        setTimeout(() => {
-          this.delayInit()
-        }, 500)
-      } else {
-        this.init()
-      }
-    },
-
-    init() {
-      this.historyNum_ = parseInt(this.historyNum)
-      let i = 0
-      for (let log of this.logCache) {
-        if (this.isLevelSelected(log.level)) { // 只显示选中级别的日志
-          if (this.historyNum_ != -1 && i >= this.logCache.length - this.historyNum_) {
-            this.printLog(log.data)
-            ++i
-          } else if (this.historyNum_ == -1) {
-            this.printLog(log.data)
-          }
+        
+        // 重新显示所有符合筛选条件的日志
+        if (this.localLogCache && this.localLogCache.length > 0) {
+          this.localLogCache.forEach(logItem => {
+            if (this.isLevelSelected(logItem.level)) {
+              this.printLog(logItem.data);
+            }
+          });
         }
       }
     },
 
+
     toggleAutoScroll() {
       this.autoScroll = !this.autoScroll;
     },
@@ -143,6 +181,11 @@ export default {
     printLog(log) {
       // append 一个 span 标签到 term，block 的方式
       let ele = document.getElementById('term')
+      if (!ele) {
+        console.warn('term element not found, skipping log print');
+        return;
+      }
+      
       let span = document.createElement('pre')
       let style = this.logColorAnsiMap['default']
       for (let key in this.logColorAnsiMap) {
diff --git a/dashboard/src/stores/common.js b/dashboard/src/stores/common.js
index fa8dde58b..b8e905216 100644
--- a/dashboard/src/stores/common.js
+++ b/dashboard/src/stores/common.js
@@ -16,21 +16,6 @@ export const useCommonStore = defineStore({
   }),
   actions: {
     async createEventSource() {
-
-      const fetchLogHistory = async () => {
-        try {
-          const res = await axios.get('/api/log-history');
-          if (res.data.data.logs) {
-            this.log_cache.push(...res.data.data.logs);
-          } else {
-            this.log_cache = [];
-          }
-        } catch (err) {
-          console.error('Failed to fetch log history:', err);
-        }
-      };
-      await fetchLogHistory();
-
       if (this.eventSource) {
         return
       }
@@ -54,25 +39,9 @@ export const useCommonStore = defineStore({
 
         const reader = response.body.getReader();
         const decoder = new TextDecoder();
-
-        let incompleteLine = ""; // 用于存储不完整的行
-
-        const handleIncompleteLine = (line) => {
-          incompleteLine += line;
-          // if can parse as JSON, return it
-          try {
-            const data_json = JSON.parse(incompleteLine);
-            incompleteLine = ""; // 清空不完整行
-            return data_json;
-          } catch (e) {
-            return null;
-          }
-        }
+        let bufferedText = '';
 
         const processStream = ({ done, value }) => {
-          // get bytes length
-          const bytesLength = value ? value.byteLength : 0;
-          console.log(`Received ${bytesLength} bytes from live log`);
           if (done) {
             console.log('SSE stream closed');
             setTimeout(() => {
@@ -82,44 +51,41 @@ export const useCommonStore = defineStore({
             return;
           }
 
-          const text = decoder.decode(value);
-          const lines = text.split('\n\n');
-          lines.forEach(line => {
-            if (!line.trim()) {
+          // Accumulate partial chunks; SSE data may split JSON across reads.
+          const text = decoder.decode(value, { stream: true });
+          bufferedText += text;
+
+          // Split completed events; keep the trailing partial in buffer.
+          const segments = bufferedText.split('\n\n');
+          bufferedText = segments.pop() || '';
+
+          segments.forEach(segment => {
+            const line = segment.trim();
+            if (!line.startsWith('data: ')) {
               return;
             }
-            if (line.startsWith('data:')) {
-              const data = line.substring(5).trim();
-              // {"type":"log","data":"[2021-08-01 00:00:00] INFO: Hello, world!"}
-              let data_json = {}
-              try {
-                data_json = JSON.parse(data);
-              } catch (e) {
-                console.warn('Invalid JSON:', data);
-                // 尝试处理不完整的行
-                const parsedData = handleIncompleteLine(data);
-                if (parsedData) {
-                  data_json = parsedData;
-                } else {
-                  return; // 如果无法解析，跳过当前行
-                }
+
+            const logLine = line.replace('data: ', '').trim();
+            if (!logLine) {
+              return;
+            }
+
+            try {
+              const logObject = JSON.parse(logLine);
+              // give a uuid if not exists
+              if (!logObject.uuid) {
+                logObject.uuid = crypto.randomUUID();
               }
-              if (data_json.type === 'log') {
-                this.log_cache.push(data_json);
-                if (this.log_cache.length > this.log_cache_max_len) {
-                  this.log_cache.shift();
-                }
-              }
-            } else {
-              const parsedData = handleIncompleteLine(line);
-              if (parsedData && parsedData.type === 'log') {
-                this.log_cache.push(parsedData);
-                if (this.log_cache.length > this.log_cache_max_len) {
-                  this.log_cache.shift();
-                }
+              this.log_cache.push(logObject);
+              // Limit log cache size
+              if (this.log_cache.length > this.log_cache_max_len) {
+                this.log_cache.splice(0, this.log_cache.length - this.log_cache_max_len);
               }
+            } catch (err) {
+              console.warn('Failed to parse SSE log line, skipping:', err, logLine);
             }
           });
+          
           return reader.read().then(processStream);
         };
 

From e7e97730af6bdf69c7a25b97996e083aaf428ee6 Mon Sep 17 00:00:00 2001
From: Soulter <905617992@qq.com>
Date: Sat, 13 Dec 2025 18:49:07 +0800
Subject: [PATCH 07/10] chore: bump version to 4.9.0

---
 astrbot/cli/__init__.py        |  2 +-
 astrbot/core/config/default.py |  2 +-
 changelogs/v4.9.0.md           | 19 +++++++++++++++++++
 pyproject.toml                 |  2 +-
 4 files changed, 22 insertions(+), 3 deletions(-)
 create mode 100644 changelogs/v4.9.0.md

diff --git a/astrbot/cli/__init__.py b/astrbot/cli/__init__.py
index ea674c5c5..454a2edae 100644
--- a/astrbot/cli/__init__.py
+++ b/astrbot/cli/__init__.py
@@ -1 +1 @@
-__version__ = "4.8.0"
+__version__ = "4.9.0"
diff --git a/astrbot/core/config/default.py b/astrbot/core/config/default.py
index daa2c4fac..7f42aa88b 100644
--- a/astrbot/core/config/default.py
+++ b/astrbot/core/config/default.py
@@ -4,7 +4,7 @@ import os
 
 from astrbot.core.utils.astrbot_path import get_astrbot_data_path
 
-VERSION = "4.8.0"
+VERSION = "4.9.0"
 DB_PATH = os.path.join(get_astrbot_data_path(), "data_v4.db")
 
 WEBHOOK_SUPPORTED_PLATFORMS = [
diff --git a/changelogs/v4.9.0.md b/changelogs/v4.9.0.md
new file mode 100644
index 000000000..aeccdb006
--- /dev/null
+++ b/changelogs/v4.9.0.md
@@ -0,0 +1,19 @@
+## What's Changed
+
+### 新增
+
+- 支持自定义插件源。
+- 支持飞书（Lark）的 Webhook 模式（将事件推送至开发者服务器）。
+- 支持 “禁用自带指令” 快捷配置项，启用后将禁用所有 AstrBot 自带指令。入口： WebUI -> 配置文件 -> 平台配置。
+
+### 优化
+
+- 从 WebUI 移除了开发版本渠道。
+- 当试图测试"Agent Runner"时，提示前往配置文件页测试。
+- WebUI 列表项支持批量粘贴、回车创建项目。
+
+### 修复
+
+- Gemini API 部分调用失败的问题。
+- WebUI 插件安装加载 Dialog 关闭按钮在手机端下显示异常的问题。
+- 部分情况下，WebUI 日志显示不全的问题。
\ No newline at end of file
diff --git a/pyproject.toml b/pyproject.toml
index a260f55d2..6badf6d19 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "AstrBot"
-version = "4.8.0"
+version = "4.9.0"
 description = "Easy-to-use multi-platform LLM chatbot and development framework"
 readme = "README.md"
 requires-python = ">=3.10"

From 6b73b19e54d7e18c3edbb2206e458749c851d582 Mon Sep 17 00:00:00 2001
From: i0cLiceao <i@i0c.cc>
Date: Sun, 14 Dec 2025 18:23:29 +0800
Subject: [PATCH 08/10] fix: support using GitHub Raw content as plugin source
 (#3975)

* Update plugin.py

* Update plugin.py

* Update plugin.py

* Update plugin.py
---
 astrbot/dashboard/routes/plugin.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/astrbot/dashboard/routes/plugin.py b/astrbot/dashboard/routes/plugin.py
index c249b07b7..fd808c6c9 100644
--- a/astrbot/dashboard/routes/plugin.py
+++ b/astrbot/dashboard/routes/plugin.py
@@ -124,7 +124,11 @@ class PluginRoute(Route):
                     session.get(url) as response,
                 ):
                     if response.status == 200:
-                        remote_data = await response.json()
+                        try:
+                            remote_data = await response.json()
+                        except aiohttp.ContentTypeError:
+                            remote_text = await response.text()
+                            remote_data = json.loads(remote_text)
 
                         # 检查远程数据是否为空
                         if not remote_data or (

From 16df64c405b20b9bf60b978316357d39c63fbaf3 Mon Sep 17 00:00:00 2001
From: Soulter <37870767+Soulter@users.noreply.github.com>
Date: Sun, 14 Dec 2025 21:31:17 +0800
Subject: [PATCH 09/10] fix: lark domain and log_level of Lark API client
 (#4038)

fixes: #4035
---
 astrbot/core/platform/sources/lark/lark_adapter.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/astrbot/core/platform/sources/lark/lark_adapter.py b/astrbot/core/platform/sources/lark/lark_adapter.py
index 883d81217..08df1f359 100644
--- a/astrbot/core/platform/sources/lark/lark_adapter.py
+++ b/astrbot/core/platform/sources/lark/lark_adapter.py
@@ -81,7 +81,12 @@ class LarkPlatformAdapter(Platform):
         )
 
         self.lark_api = (
-            lark.Client.builder().app_id(self.appid).app_secret(self.appsecret).build()
+            lark.Client.builder()
+            .app_id(self.appid)
+            .app_secret(self.appsecret)
+            .log_level(lark.LogLevel.ERROR)
+            .domain(self.domain)
+            .build()
         )
 
         self.webhook_server = None

From 65da469debcaa10ae50eca34ed20b8a3e815ec33 Mon Sep 17 00:00:00 2001
From: Copilot <198982749+Copilot@users.noreply.github.com>
Date: Sun, 14 Dec 2025 21:44:12 +0800
Subject: [PATCH 10/10] feat: add conversation export feature to JSONL for AI
 training (#4037)

* Initial plan

* Add conversation export functionality (backend and frontend)

Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>

* Address code review feedback: move imports, simplify logic, improve i18n

Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>

* Simplify frontend download logic: remove redundant Blob wrapper and complex filename parsing

Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>

* fix: update conversation export filename format for consistency

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>
Co-authored-by: Soulter <905617992@qq.com>
---
 astrbot/dashboard/routes/conversation.py      | 92 ++++++++++++++++++-
 .../locales/en-US/features/conversation.json  | 11 ++-
 .../locales/zh-CN/features/conversation.json  | 11 ++-
 dashboard/src/views/ConversationPage.vue      | 58 ++++++++++++
 4 files changed, 165 insertions(+), 7 deletions(-)

diff --git a/astrbot/dashboard/routes/conversation.py b/astrbot/dashboard/routes/conversation.py
index d19fdf793..513d3603f 100644
--- a/astrbot/dashboard/routes/conversation.py
+++ b/astrbot/dashboard/routes/conversation.py
@@ -1,7 +1,9 @@
 import json
 import traceback
+from datetime import datetime
+from io import BytesIO
 
-from quart import request
+from quart import request, send_file
 
 from astrbot.core import logger
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
@@ -30,6 +32,7 @@ class ConversationRoute(Route):
                 "POST",
                 self.update_history,
             ),
+            "/conversation/export": ("POST", self.export_conversations),
         }
         self.db_helper = db_helper
         self.conv_mgr = core_lifecycle.conversation_manager
@@ -283,3 +286,90 @@ class ConversationRoute(Route):
         except Exception as e:
             logger.error(f"更新对话历史失败: {e!s}\n{traceback.format_exc()}")
             return Response().error(f"更新对话历史失败: {e!s}").__dict__
+
+    async def export_conversations(self):
+        """批量导出对话为 JSONL 格式"""
+        try:
+            data = await request.get_json()
+            conversations_to_export = data.get("conversations", [])
+
+            if not conversations_to_export:
+                return Response().error("导出列表不能为空").__dict__
+
+            # 收集所有对话的内容
+            jsonl_lines = []
+            exported_count = 0
+            failed_items = []
+
+            for conv_info in conversations_to_export:
+                user_id = conv_info.get("user_id")
+                cid = conv_info.get("cid")
+
+                if not user_id or not cid:
+                    failed_items.append(
+                        f"user_id:{user_id}, cid:{cid} - 缺少必要参数",
+                    )
+                    continue
+
+                try:
+                    conversation = await self.conv_mgr.get_conversation(
+                        unified_msg_origin=user_id,
+                        conversation_id=cid,
+                    )
+
+                    if not conversation:
+                        failed_items.append(
+                            f"user_id:{user_id}, cid:{cid} - 对话不存在"
+                        )
+                        continue
+
+                    # 解析对话内容 (history is always a JSON string from _convert_conv_from_v2_to_v1)
+                    content = json.loads(conversation.history)
+
+                    # 创建导出记录
+                    export_record = {
+                        "cid": cid,
+                        "user_id": user_id,
+                        "platform_id": conversation.platform_id,
+                        "title": conversation.title,
+                        "persona_id": conversation.persona_id,
+                        "created_at": conversation.created_at,
+                        "updated_at": conversation.updated_at,
+                        "content": content,
+                    }
+
+                    # 将记录转换为 JSON 字符串并添加到 JSONL
+                    jsonl_lines.append(json.dumps(export_record, ensure_ascii=False))
+                    exported_count += 1
+
+                except Exception as e:
+                    failed_items.append(f"user_id:{user_id}, cid:{cid} - {e!s}")
+                    logger.error(
+                        f"导出对话失败: user_id={user_id}, cid={cid}, error={e!s}"
+                    )
+
+            if exported_count == 0:
+                return Response().error("没有成功导出任何对话").__dict__
+
+            # 创建 JSONL 内容
+            jsonl_content = "\n".join(jsonl_lines)
+
+            # 创建一个内存文件对象
+            file_obj = BytesIO(jsonl_content.encode("utf-8"))
+            file_obj.seek(0)
+
+            # 生成文件名
+            timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
+            filename = f"astrbot_conversations_export_{timestamp}.jsonl"
+
+            # 返回文件流
+            return await send_file(
+                file_obj,
+                mimetype="application/jsonl",
+                as_attachment=True,
+                attachment_filename=filename,
+            )
+
+        except Exception as e:
+            logger.error(f"批量导出对话失败: {e!s}\n{traceback.format_exc()}")
+            return Response().error(f"批量导出对话失败: {e!s}").__dict__
diff --git a/dashboard/src/i18n/locales/en-US/features/conversation.json b/dashboard/src/i18n/locales/en-US/features/conversation.json
index 2c427274c..3e8cb7128 100644
--- a/dashboard/src/i18n/locales/en-US/features/conversation.json
+++ b/dashboard/src/i18n/locales/en-US/features/conversation.json
@@ -13,7 +13,8 @@
     "refresh": "Refresh"
   },
   "batch": {
-    "deleteSelected": "Delete Selected ({count})"
+    "deleteSelected": "Delete Selected ({count})",
+    "exportSelected": "Export Selected ({count})"
   },
   "pagination": {
     "itemsPerPage": "Items per page",
@@ -76,7 +77,8 @@
       "message": "Are you sure you want to delete the selected {count} conversations? This action cannot be undone, please proceed with caution!",
       "andMore": "and {count} more",
       "cancel": "Cancel",
-      "confirm": "Batch Delete"
+      "confirm": "Batch Delete",
+      "warning": "Warning: This action cannot be undone!"
     }
   },
   "messages": {
@@ -92,6 +94,9 @@
     "noItemSelected": "Please select conversations to delete first",
     "batchDeleteSuccess": "Successfully deleted {count} conversations",
     "batchDeleteError": "Batch delete failed",
-    "batchDeletePartial": "Delete completed: {deleted} successful, {failed} failed"
+    "batchDeletePartial": "Delete completed: {deleted} successful, {failed} failed",
+    "exportSuccess": "Export successful",
+    "exportError": "Export failed",
+    "noItemSelectedForExport": "Please select conversations to export first"
   }
 } 
\ No newline at end of file
diff --git a/dashboard/src/i18n/locales/zh-CN/features/conversation.json b/dashboard/src/i18n/locales/zh-CN/features/conversation.json
index cc20bf640..8a5ca6eb5 100644
--- a/dashboard/src/i18n/locales/zh-CN/features/conversation.json
+++ b/dashboard/src/i18n/locales/zh-CN/features/conversation.json
@@ -13,7 +13,8 @@
     "refresh": "刷新"
   },
   "batch": {
-    "deleteSelected": "删除选中 ({count})"
+    "deleteSelected": "删除选中 ({count})",
+    "exportSelected": "导出选中 ({count})"
   },
   "pagination": {
     "itemsPerPage": "每页",
@@ -76,7 +77,8 @@
       "message": "确定要删除选中的 {count} 个对话吗？此操作不可恢复，请谨慎操作！",
       "andMore": "等 {count} 个",
       "cancel": "取消",
-      "confirm": "批量删除"
+      "confirm": "批量删除",
+      "warning": "警告：此操作不可撤销！"
     }
   },
   "messages": {
@@ -92,6 +94,9 @@
     "noItemSelected": "请先选择要删除的对话",
     "batchDeleteSuccess": "成功删除 {count} 个对话",
     "batchDeleteError": "批量删除失败",
-    "batchDeletePartial": "删除完成：成功 {deleted} 个，失败 {failed} 个"
+    "batchDeletePartial": "删除完成：成功 {deleted} 个，失败 {failed} 个",
+    "exportSuccess": "导出成功",
+    "exportError": "导出失败",
+    "noItemSelectedForExport": "请先选择要导出的对话"
   }
 } 
\ No newline at end of file
diff --git a/dashboard/src/views/ConversationPage.vue b/dashboard/src/views/ConversationPage.vue
index d6ec28100..8a4debd5e 100644
--- a/dashboard/src/views/ConversationPage.vue
+++ b/dashboard/src/views/ConversationPage.vue
@@ -40,6 +40,17 @@
                         :loading="loading" size="small" class="mr-2">
                         {{ tm('history.refresh') }}
                     </v-btn>
+                    <v-btn 
+                        v-if="selectedItems.length > 0" 
+                        color="success" 
+                        prepend-icon="mdi-download"
+                        variant="tonal" 
+                        @click="exportConversations" 
+                        :disabled="loading"
+                        size="small"
+                        class="mr-2">
+                        {{ tm('batch.exportSelected', { count: selectedItems.length }) }}
+                    </v-btn>
                     <v-btn 
                         v-if="selectedItems.length > 0" 
                         color="error" 
@@ -910,6 +921,53 @@ export default {
             }
         },
 
+        // 导出选中的对话
+        async exportConversations() {
+            if (this.selectedItems.length === 0) {
+                this.showErrorMessage(this.tm('messages.noItemSelectedForExport'));
+                return;
+            }
+
+            this.loading = true;
+            try {
+                // 准备导出的数据
+                const conversations = this.selectedItems.map(item => ({
+                    user_id: item.user_id,
+                    cid: item.cid
+                }));
+
+                const response = await axios.post('/api/conversation/export', {
+                    conversations: conversations
+                }, {
+                    responseType: 'blob' // 重要：告诉 axios 响应是一个 blob
+                });
+
+                // 创建一个下载链接
+                const url = window.URL.createObjectURL(response.data);
+                const link = document.createElement('a');
+                link.href = url;
+                
+                // 生成文件名（使用时间戳）
+                const timestamp = new Date().toISOString().replace(/[:.]/g, '-').slice(0, -5);
+                const filename = `conversations_export_${timestamp}.jsonl`;
+                
+                link.setAttribute('download', filename);
+                document.body.appendChild(link);
+                link.click();
+                
+                // 清理
+                link.remove();
+                window.URL.revokeObjectURL(url);
+                
+                this.showSuccessMessage(this.tm('messages.exportSuccess'));
+            } catch (error) {
+                console.error(this.tm('messages.exportError'), error);
+                this.showErrorMessage(error.response?.data?.message || error.message || this.tm('messages.exportError'));
+            } finally {
+                this.loading = false;
+            }
+        },
+
         // 格式化时间戳
         formatTimestamp(timestamp) {
             if (!timestamp) return this.tm('status.unknown');