feat: Enhance context handling and notifications for sensitive messages

plugins/_ai/llm.py

@@ -2,6 +2,7 @@
 
 import asyncio
 import json
+import re
 import time
 import httpx
 from ncatbot.utils import get_log
@@ -270,9 +271,16 @@ async def judge_sensitive(self, message_text: str, context: str = "") -> tuple[b
             return is_sensitive, reason
         except json.JSONDecodeError:
             logger.warning(f"LLM 返回非 JSON，fallback 到旧规则: {reply[:100]}")
-            is_sensitive = reply.strip().startswith("是")
-            reason = reply.strip()
-            return is_sensitive, reason
+            cleaned = reply.strip()
+            # Match leading 「是」/「否」 anchored at start; handles brackets like（是）「否」
+            m = re.match(r'^\s*[「（(]?\s*([是否])\s*[」）)]?', cleaned)
+            if m:
+                is_sensitive = m.group(1) == "是"
+            else:
+                # Fallback: check first non-whitespace character
+                first_char = cleaned.lstrip()[:1] if cleaned else ""
+                is_sensitive = first_char == "是"
+            return is_sensitive, cleaned[:200]
 
     async def judge_question(self, project: str, message_text: str, context: str = "") -> bool:
         """判断消息是否在询问项目相关问题。返回 True/False。"""

plugins/arkrec/plugin.py

@@ -22,6 +22,7 @@
 from .api import (
     fetch_bundle_ext,
     fetch_exclusive_operators,
+    fetch_menu,
     fetch_menu_tree,
     fetch_open_episodes,
     fetch_operation_info,

plugins/mirrorchyan/plugin.py

@@ -5,6 +5,7 @@
 import json
 from pathlib import Path
 from dataclasses import asdict
+from typing import Optional
 
 from ncatbot.plugin_system import NcatBotPlugin, command_registry, param
 from ncatbot.core.event import GroupMessageEvent, PrivateMessageEvent
@@ -448,9 +449,9 @@ async def cmd_config(
         event: GroupMessageEvent,
         rid: str,
         type: int = 1,
-        interval: int = None,
-        auto: bool = None,
-        channel: str = None,
+        interval: Optional[int] = None,
+        auto: Optional[bool] = None,
+        channel: Optional[str] = None,
     ):
         """更新配置 用法: /mirror_config <资源ID> [类型0/1] [检查间隔秒] [自动上传]"""
         if not await self._is_group_admin(event.group_id, event.user_id):

plugins/qa_helper/plugin.py

@@ -353,8 +353,6 @@ async def _fetch_releases(self, project: str) -> str | None:
 
     @staticmethod
     def _looks_like_question(text: str) -> bool:
-        import re
-
         # 1. 含问号直接放行（由 LLM 层做精判）
         if "？" in text or "?" in text:
             return True

plugins/sensitive_monitor/config.py

@@ -14,3 +14,6 @@ class SensitiveGroupConfig:
     max_context_messages: int = 5
     # Maximum total characters for the appended context
     max_context_chars: int = 800
+    # Cooldown seconds: after a sensitive notification, suppress further
+    # notifications from this group for this duration to avoid cascade
+    notify_cooldown_seconds: int = 120

plugins/sensitive_monitor/plugin.py

@@ -1,6 +1,8 @@
 """敏感消息监听插件"""
 
+import asyncio
 import json
+import time
 
 from ncatbot.plugin_system import NcatBotPlugin, command_registry, param, on_message
 from ncatbot.core.event import GroupMessageEvent, PrivateMessageEvent
@@ -15,23 +17,10 @@
 RECENT_SENSITIVE: set[str] = set()
 MAX_RECENT = 500
 MIN_TEXT_LENGTH = 4
-
-
-def _build_clean_message(message) -> str:
-    """Convert a MessageArray to clean text, replacing non-text segments with summaries."""
-    parts = []
-    for seg in message:
-        if seg.msg_seg_type == "text":
-            parts.append(seg.text)
-        elif seg.msg_seg_type == "at":
-            parts.append(f"@{seg.qq}" if seg.qq != "all" else "@全体成员")
-        elif seg.msg_seg_type == "reply":
-            continue
-        else:
-            summary = seg.get_summary()
-            if summary and summary != "该消息不支持预览":
-                parts.append(summary)
-    return "".join(parts)
+# Per-group cooldown: tracks the last notification time for each group
+LAST_NOTIFY_TIME: dict[str, float] = {}
+# Prune LAST_NOTIFY_TIME entries older than this (seconds)
+NOTIFY_COOLDOWN_PRUNE_AGE = 3600  # 1 hour
 
 
 class SensitiveMonitorPlugin(NcatBotPlugin):
@@ -56,6 +45,7 @@ def _load_config(self) -> dict[str, SensitiveGroupConfig]:
                         append_context=g.get("append_context", False),
                         max_context_messages=g.get("max_context_messages", 5),
                         max_context_chars=g.get("max_context_chars", 800),
+                        notify_cooldown_seconds=g.get("notify_cooldown_seconds", 120),
                     )
                     for gid, g in data.items()
                 }
@@ -74,6 +64,7 @@ def _save_config(self):
                         "append_context": g.append_context,
                         "max_context_messages": g.max_context_messages,
                         "max_context_chars": g.max_context_chars,
+                        "notify_cooldown_seconds": g.notify_cooldown_seconds,
                     }
                     for gid, g in self.groups.items()
                 },
@@ -113,8 +104,19 @@ async def _on_message(self, event):
             return
         RECENT_PROCESSED.add(str(event.message_id))
         if len(RECENT_PROCESSED) > MAX_RECENT:
-            RECENT_PROCESSED.clear()
-            RECENT_SENSITIVE.clear()
+            # Sliding window: discard oldest half, but keep RECENT_SENSITIVE intact
+            # to prevent re-detection of already-flagged messages
+            keep_count = MAX_RECENT // 2
+            RECENT_PROCESSED = set(list(RECENT_PROCESSED)[-keep_count:])
+            # Prune stale notification cooldown entries
+            now = time.time()
+            stale_keys = [
+                gid
+                for gid, last in LAST_NOTIFY_TIME.items()
+                if now - last > NOTIFY_COOLDOWN_PRUNE_AGE
+            ]
+            for gid in stale_keys:
+                del LAST_NOTIFY_TIME[gid]
 
         if not is_llm_configured():
             return
@@ -141,13 +143,30 @@ async def _on_message(self, event):
         except Exception as e:
             logger.error(f"获取消息上下文失败: {e}")
 
-        is_sensitive, reason = await get_llm().judge_sensitive(text, context)
+        try:
+            is_sensitive, reason = await asyncio.wait_for(
+                get_llm().judge_sensitive(text, context), timeout=15
+            )
+        except asyncio.TimeoutError:
+            logger.warning(f"LLM 敏感判断超时 (group={group_id})，跳过")
+            return
         if is_sensitive:
             RECENT_SENSITIVE.add(str(event.message_id))
             logger.info(
                 f"敏感消息: group={group_id}, user={event.user_id}, reason={reason}"
             )
-            await self._notify(cfg, group_id, str(event.user_id), text, reason, context)
+            # Cooldown check: suppress notification if we recently sent one in this group
+            now = time.time()
+            last = LAST_NOTIFY_TIME.get(group_id, 0)
+            if now - last < cfg.notify_cooldown_seconds:
+                logger.info(
+                    f"群 {group_id} 处于通知冷却中 (剩余 {int(cfg.notify_cooldown_seconds - (now - last))}s)，跳过通知"
+                )
+            else:
+                await self._notify(
+                    cfg, group_id, str(event.user_id), text, reason, context
+                )
+                LAST_NOTIFY_TIME[group_id] = time.time()
 
     async def _notify(
         self,
@@ -271,9 +290,35 @@ async def cmd_status(self, event: GroupMessageEvent):
             lines.append(f"  附加对话背景: {'是' if cfg.append_context else '否'}")
             lines.append(f"  对话消息数上限: {cfg.max_context_messages}")
             lines.append(f"  对话字符上限: {cfg.max_context_chars}")
+            lines.append(f"  通知冷却: {cfg.notify_cooldown_seconds}秒")
         llm_cfg = load_llm_config()
         lines.append(f"LLM: {'已配置' if llm_cfg.base_url else '未配置'}")
         await event.reply("\n".join(lines))
 
+    @command_registry.command(
+        "sensitive_cooldown", description="[管理员] 设置通知冷却秒数"
+    )
+    @param(name="seconds", default="120", help="冷却秒数，设为0禁用冷却")
+    async def cmd_cooldown(self, event: GroupMessageEvent, seconds: str = "120"):
+        if not await self._is_group_admin(event.group_id, event.user_id):
+            await event.reply("需要群主或管理员权限")
+            return
+        try:
+            val = int(seconds)
+            if val < 0:
+                await event.reply("冷却秒数不能为负数")
+                return
+        except ValueError:
+            await event.reply("请输入有效的数字")
+            return
+        group_id = str(event.group_id)
+        cfg = self._get_cfg(group_id)
+        cfg.notify_cooldown_seconds = val
+        self._save_config()
+        if val == 0:
+            await event.reply("通知冷却已禁用")
+        else:
+            await event.reply(f"通知冷却已设置为 {val} 秒")
+
 
 __all__ = ["SensitiveMonitorPlugin"]

plugins/skland/plugin.py

@@ -174,7 +174,6 @@ def _format_account_result(
         if error:
             lines.append(f"失败: {error}")
             return lines
-        assert results is not None
         if not results:
             lines.append("未找到绑定角色")
             return lines

pyproject.toml

@@ -8,6 +8,7 @@ dependencies = [
     "ncatbot",
     "markdown",
     "playwright",
+    "psutil",
 ]
 
 [[tool.uv.index]]