增加获取群内的成员信息和机器人信息方法，具体可查阅开发文档或示例插件

Author: lengxi-root

PLUGIN_DEVELOPMENT.md

@@ -536,12 +536,19 @@ ok, result = await event.sender.force_wakeup(user_id, "强制召回")
 # 生成分享链接
 url = await event.sender.get_share_link(callback_data='my_data')
 
-# 获取图片尺寸 (URL 或 bytes)
-width, height = await event.sender.get_image_size("https://...")
+# 获取图片尺寸 (URL/bytes/本地路径, 返回 {'width', 'height', 'px'} 或 None)
+size = await event.sender.get_image_size("https://...")
 
 # 手动上传媒体文件 (返回 file_info)
 file_info = await event.sender.upload_media(event, file_bytes, file_type=1)
 # file_type: 1=图片, 2=视频, 3=语音, 4=文件
+
+# 查询单个群成员详情 (返回 dict 或 None, 含 member_openid/username/member_role 等)
+member = await event.sender.get_group_member(group_id, user_id)
+
+# 查询机器人自身在某群的成员信息 (返回 dict 或 None)
+bot_member = await event.sender.get_bot_member(group_id)
+is_admin = bot_member and bot_member.get('member_role') in ('admin', 'owner')
 ```
 
 ---

core/base/config.py

@@ -93,13 +93,7 @@ def config_dir(self):
     # ------ 读取 ------
 
     def get(self, name, key=None, default=None):
-        """获取配置值
-
-        Args:
-            name:    配置文件名(不含 .yaml), 如 'settings', 'bot', 'extension/redis'
-            key:     点号分隔路径, 如 'server.port', None 返回整个 dict
-            default: 默认值
-        """
+        """获取配置值: name=配置文件名, key=点号路径 (None 返回整个 dict)"""
         self._maybe_reload(name)
         with self._rw_lock:
             data = self._cache.get(name, {})
@@ -134,8 +128,7 @@ def get_bot_setting(self, appid, key, default=None):
         if val is not None:
             self._bot_setting_cache[cache_key] = val
             return val
-        # 负缓存: 命中内置默认值的键也缓存, 避免每条消息重复 key.split('.') + 字典遍历
-        # (默认值与传入 default 无关, 仅对 _BOT_DEFAULTS 中存在的键缓存)
+        # 负缓存: 仅对 _BOT_DEFAULTS 中存在的键缓存默认值
         dft = _BOT_DEFAULTS.get(key, _MISSING)
         if dft is not _MISSING:
             self._bot_setting_cache[cache_key] = dft
@@ -145,11 +138,7 @@ def get_bot_setting(self, appid, key, default=None):
     # ------ 热加载 ------
 
     def _resolve_path(self, name):
-        """解析配置文件名 -> 绝对路径 (带缓存)
-
-        查找顺序: name.yaml > name.yml > name.example.yaml(自动复制) > name.yaml(占位)
-        当实际配置文件不存在时, 自动从 .example.yaml 复制生成, 避免示例文件被本地修改污染版本控制.
-        """
+        """解析配置文件名为绝对路径 (带缓存): .yaml > .yml > .example.yaml 自动复制 > 占位"""
         cached = self._path_cache.get(name)
         if cached:
             return cached

core/base/pip_helper.py

@@ -1,12 +1,4 @@
-"""pip 依赖安装辅助 — 插件/模块共用
-
-设计目标 (对齐 nonebot 的"框架自装依赖", 且不挑环境):
-  · 用 `sys.executable -m pip` 安装 → 天然装进"当前跑 bot 的这个 Python", 虚拟环境里也对;
-  · site-packages 不可写时 (无 root / venv 属主为 root), 自动 `--target` 装到可写的
-    .pydeps 目录并注入 sys.path, 无需 root, venv 内外均适用;
-  · 多镜像兜底 (配置源失败自动换官方源重试);
-  · pip 跑在独立单线程池里, 与事件循环 / DNS / Web 隔离, 装依赖不阻塞收发消息。
-"""
+"""pip 依赖安装辅助 — 插件/模块共用, 自动适配环境并多镜像兜底"""
 
 import asyncio
 import contextlib
@@ -24,9 +16,7 @@
 
 log = get_logger(FRAMEWORK, '依赖安装')
 
-# 当运行 bot 的 Python 环境 site-packages 不可写时 (无 root / venv 属主为 root, pip 报
-# Errno 13 Permission denied), 依赖改装到这个可写目录并注入 sys.path: 免 root、
-# venv 内外都能让插件 import 到 (venv 里 --user 会被 pip 拒绝, 故用 --target)。
+# site-packages 不可写时, 依赖 --target 装到此可写目录并注入 sys.path
 _ROOT_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 _DEPS_DIR = os.path.join(_ROOT_DIR, '.pydeps')
 
@@ -40,8 +30,7 @@ def _ensure_deps_dir_on_path():
 if os.path.isdir(_DEPS_DIR):
     _ensure_deps_dir_on_path()
 
-# 独立单线程池: pip 是重 IO/CPU 的阻塞操作, 放这里跑绝不占用 asyncio 默认执行器
-# (默认执行器还兼着 DNS 解析、Web/统计查询等, 被 pip 占满会连带卡住整个面板)。
+# 独立单线程池: pip 阻塞操作不占用 asyncio 默认执行器
 _EXECUTOR = None
 _EXECUTOR_LOCK = threading.Lock()
 
@@ -153,11 +142,7 @@ def all_requirements_met(req_path):
 
 
 def _mirror_attempts():
-    """返回按优先级排列的镜像参数列表; '' 表示官方源 (不带 -i)。
-
-    支持 settings.pip.mirrors (列表) 做多镜像兜底; 否则用 settings.pip.mirror
-    (单个), 并追加官方源兜底。
-    """
+    """返回按优先级排列的镜像参数列表, '' 表示官方源"""
     mirrors = cfg.get('settings', 'pip.mirrors', None)
     if isinstance(mirrors, (list, tuple)) and mirrors:
         seq = [str(m).strip() for m in mirrors if str(m).strip()]

core/bot/event.py

@@ -238,8 +238,6 @@ async def _on_event(self, event):
 
         if et == GROUP_MESSAGE_CREATE and event.group_id:
             self._record_full_access_group(bot, event.group_id)
-            if event.is_at_self and event.bot_member_role in ('admin', 'owner'):
-                self._record_bot_admin(bot, event.group_id)
 
         # 全量群 @全体成员 跳过
         if et == GROUP_MESSAGE_CREATE and event.is_at_all:
@@ -275,14 +273,6 @@ def _record_full_access_group(self, bot, group_id):
             (group_id, ts),
         )
 
-    def _record_bot_admin(self, bot, group_id):
-        """记录机器人在该群为管理员"""
-        ts = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
-        bot.log_service.db_queue(
-            'INSERT OR REPLACE INTO group_bot_admin (group_id, updated_at) VALUES (?, ?)',
-            (group_id, ts),
-        )
-
     def get_full_access_groups(self):
         """从 data.db 拉取所有全量群记录"""
         bot = next(iter(self._bots.values()), None)

core/message/_http.py

@@ -82,6 +82,9 @@ async def _request(self, method, endpoint, **kwargs):
                 return False, {'message': str(e), 'code': -1}
         return False, {'message': 'max retries', 'code': -1}
 
+    async def get_json(self, endpoint, **kwargs):
+        return await self._request('GET', endpoint, **kwargs)
+
     async def post_json(self, endpoint, payload):
         return await self._request('POST', endpoint, json=payload)
 

core/message/bot_openid.py

@@ -1,8 +1,4 @@
-"""Bot OpenID 缓存 — 记录各 appid 机器人的艾特 id, 持久化到 JSON。
-
-全量环境下机器人真实 id (mentions[].id) 与 content 里 <@id> 的虚拟 id 可能不一致。
-首次「仅艾特机器人」时把两个来源的 id 都记下并标记 done; 之后直接按缓存移除, 不再判断。
-"""
+"""Bot OpenID 缓存 — 记录各 appid 机器人的艾特 id, 持久化到 JSON"""
 
 import json
 import os
@@ -65,6 +61,14 @@ def add(appid, openid):
         _save()
 
 
+def first_id(appid):
+    """取该 appid 的第一个 openid (按字典序), 用于请求群成员接口"""
+    e = _data.get(appid)
+    if not e or not e['ids']:
+        return ''
+    return sorted(e['ids'])[0]
+
+
 def is_done(appid):
     """该 appid 是否已记录齐全, 无需再判断"""
     e = _data.get(appid)

core/message/event.py

@@ -207,7 +207,6 @@ class Event:
         'sharer_id',
         'scene_param',
         'mentions',
-        'bot_member_role',
         'is_at_self',
         'is_at_other_bot',
         'is_at_other_user',
@@ -261,7 +260,6 @@ def __init__(self):
         self.sharer_id = None
         self.scene_param = None
         self.mentions = []
-        self.bot_member_role = ''
         self.is_at_self = False
         self.is_at_other_bot = False
         self.is_at_other_user = False
@@ -406,16 +404,10 @@ def needs_msg_id(self):
     def needs_event_id(self):
         return self.event_type in _EVENT_ID_TYPES
 
-    # ==================== 交互回调 (op12 ACK) ====================
-    # 插件可在处理 INTERACTION_CREATE 时调用 event.set_callback_code(n) 自定义
-    # 返回给客户端的状态码 (随 op12 ACK 一起发送, 不额外发 REST 请求)。
-    # 未设置则框架在分发结束 / 超时后用默认 code 兜底。
+    # ==================== 交互回调 (op12 ACK) — 插件可用 set_callback_code 自定义状态码 ====================
 
     def start_ack_countdown(self):
-        """交互事件开始处理: 创建 ACK future 并启动默认超时定时器。
-
-        由传输层 (webhook / websocket) 在分发插件前调用。
-        """
+        """创建 ACK future 并启动超时定时器 (由传输层在分发前调用)"""
         loop = asyncio.get_running_loop()
         if self._ack_future is None:
             self._ack_future = loop.create_future()
@@ -462,9 +454,7 @@ async def wait_ack_code(self):
             return _DEFAULT_CALLBACK_CODE
         return await self._ack_future
 
-    # ==================== 发送代理 ====================
-    # event.reply(...) → sender.reply(event, ...)
-    # event.send_to_group(...) → sender.send_to_group(...)
+    # ==================== 发送代理 (event.reply → sender.reply) ====================
 
     @property
     def sender(self):

core/message/event_router.py

@@ -5,15 +5,7 @@
 
 
 def build_keyboard(button_rows, appid=None, *, font_size=None, style=None):
-    """按钮行列表 → QQ InlineKeyboard 结构
-
-    小按钮: 通过键盘级样式 content.style.font_size 控制按钮大小 (对应官方
-    botgo CustomKeyboard.Style.FontSize), 取值 small / middle / large,
-    small 即「小按钮」。两种用法:
-      - 关键字: build_keyboard(rows, appid, font_size='small')
-        或 reply(buttons=rows, button_font_size='small')
-      - dict 包装: build_keyboard({'rows': rows, 'font_size': 'small'})
-    """
+    """按钮行列表 → QQ InlineKeyboard 结构, font_size 控制按钮大小 (small/middle/large)"""
     button_enter_to_send = cfg.get_bot_setting(appid, 'message.button_enter_to_send', False) if appid else False
 
     # 顶层 dict 包装: 携带键盘级样式, 同时兼容 rows/buttons/btns 取行