mirror of
https://github.com/snowy-yang/qqbotsdk.git
synced 2026-10-21 16:14:49 +00:00
snowy-yang
7e7dcbaa94
删除 Event 的 user_id/group_id/content/message_id 四个属性：它们是 "兼容群（openid）与频道两套字段名"的映射层，其中 user_id 还带着 旧版群消息 payload 顶层 from_user_id 的回退（现行格式发言人标识在 author 里，该回退永远轮不到）。Event 只保留信封语义： .raw/.data/.typed/.type/.event_id，事件体字段一律标注 payload dataclass（如 msg: GroupAtMessage）获取解析结果。 破坏性变更：event.group_id → msg.group_openid、event.message_id → msg.id，以此类推；被动回复凭据分工不变——消息事件用事件体 d.id （msg_id），其余事件用信封顶层 event_id。 迁移：examples/group_bot 入群欢迎改标注 GroupAddRobot（已确认 MusicBot 未使用被删属性）；GUIDE/API 同步删除对应属性行；测试 重写为信封语义断言 + typed 解析断言。 107 测试全绿，ruff/pyright 干净。
107 lines
3.8 KiB
Python
107 lines
3.8 KiB
Python
"""群机器人示例：@消息回复、富媒体图片、按钮卡片与点击回调、入群欢迎、单聊回复。
|
||
|
||
运行前提：
|
||
1. 项目根目录 .env 配好 APPID/APPSECRET（CONNECTER 用默认 websocket）；
|
||
2. intents.toml 订阅 GROUP_AND_C2C_EVENT 与 INTERACTION 两个分组（仓库默认已开启）；
|
||
3. 机器人已在开放平台开通群聊能力，并被拉入测试群。
|
||
|
||
运行：uv run python examples/group_bot/main.py
|
||
"""
|
||
|
||
from loguru import logger
|
||
|
||
from qqbotsdk import EventEmitter, main
|
||
from qqbotsdk.api import BotApi, button, keyboard
|
||
from qqbotsdk.events import Event
|
||
from qqbotsdk.payloads import C2CMessage, GroupAddRobot, GroupAtMessage, Interaction
|
||
|
||
ee = EventEmitter()
|
||
|
||
|
||
@ee.on("GROUP_AT_MESSAGE_CREATE")
|
||
async def on_group_message(msg: GroupAtMessage, api: BotApi) -> None:
|
||
if not (msg.group_openid and msg.id):
|
||
return
|
||
|
||
# "/img <图片url>"：上传富媒体后随消息发出（msg_type 自动置为 7）
|
||
if (msg.content or "").startswith("/img "):
|
||
url = (msg.content or "").removeprefix("/img ").strip()
|
||
if not url:
|
||
return
|
||
upload = await api.upload_group_file(msg.group_openid, file_type=1, url=url)
|
||
await api.post_group_message(
|
||
msg.group_openid,
|
||
content="图来了",
|
||
msg_id=msg.id,
|
||
media=upload,
|
||
)
|
||
return
|
||
|
||
# "/btn"：发一张带回调按钮的 Markdown 卡片
|
||
if (msg.content or "").strip() == "/btn":
|
||
await api.post_group_message(
|
||
msg.group_openid,
|
||
markdown="## 按钮示例\n点下面的按钮试试：",
|
||
keyboard=keyboard(
|
||
button("打个招呼", data="btn|hello"),
|
||
[button("赞", data="btn|like"), button("踩", data="btn|dislike")],
|
||
),
|
||
msg_id=msg.id,
|
||
)
|
||
return
|
||
|
||
# 普通文本：带 msg_id 被动回复（5 分钟内有效，同一条消息多次回复递增 msg_seq）
|
||
await api.post_group_message(
|
||
msg.group_openid,
|
||
content=f"你说：{msg.content}",
|
||
msg_id=msg.id,
|
||
)
|
||
|
||
|
||
@ee.on("INTERACTION_CREATE")
|
||
async def on_button_click(inter: Interaction, event: Event, api: BotApi) -> None:
|
||
if inter.chat_type != 1 or not inter.group_openid:
|
||
return # 本示例只处理群聊的按钮回调
|
||
# 必须应答，否则用户端按钮一直 loading（这里的 id 是事件体里的互动 id）
|
||
await api.respond_interaction(inter.id)
|
||
# 被动回复的 event_id 是网关帧最外层的 id（形如 INTERACTION_CREATE:uuid），
|
||
# 不是事件体里的裸 UUID——官方文档点名的常见坑
|
||
await api.post_group_message(
|
||
inter.group_openid,
|
||
content=f"你点了：{inter.button_data}",
|
||
event_id=event.event_id,
|
||
)
|
||
|
||
|
||
@ee.on("GROUP_ADD_ROBOT")
|
||
async def on_robot_added(added: GroupAddRobot, event: Event, api: BotApi) -> None:
|
||
# 入群是事件而非消息：用信封顶层的事件 id 作 event_id 被动回复（拿不到则跳过）
|
||
if not (added.group_openid and event.event_id):
|
||
logger.info(f"机器人加入群聊 {added.group_openid}（无事件 ID，跳过欢迎语）")
|
||
return
|
||
await api.post_group_message(
|
||
added.group_openid,
|
||
content="大家好，我是本群机器人，@我即可体验～",
|
||
event_id=event.event_id,
|
||
)
|
||
|
||
|
||
@ee.on("C2C_MESSAGE_CREATE")
|
||
async def on_c2c_message(msg: C2CMessage, api: BotApi) -> None:
|
||
user_openid = msg.user_openid
|
||
if not (user_openid and msg.id):
|
||
return
|
||
# 单聊被动回复 60 分钟内有效，同一 msg_id 最多回复 4 次
|
||
await api.post_c2c_message(
|
||
user_openid, content=f"你说：{msg.content}", msg_id=msg.id
|
||
)
|
||
|
||
|
||
@ee.on("FRIEND_ADD")
|
||
async def on_friend_add(d: dict) -> None:
|
||
logger.info(f"新增用户：{d.get('user_openid')}")
|
||
|
||
|
||
if __name__ == "__main__":
|
||
main(ee)
|