最近,在写机器人的时候遇到了一个问题,合并转发实现不了,这里记录一下。
使用合并转发主要是为了缩短消息,不然发一长串消息在群里严重影响群里聊天吹水。
然鹅,按照官方文档折腾了半天,最后还是报错,消息发不出去:
(这里本来应该有图片的,但是之前报错的时候没来得及写博客,于是没存,现在代码改了,找不到了)
最终经过各方查找,发现了一个关键点:
于是,经过启发,也许是版本问题,原先用的是0.9X
的版本,可能这个接口支持得不是很好。
于是最终解决方案如下:
升级go-cqhttp到最新版(1.0.0.4 beta)
-
正确书写代码
原文档的代码属实有点混乱,可以看到,涉及该接口的文档有这么两个部分:发送合并转发API、合并转发CQCode
而在CQCode的介绍后面还有三种类型的示例代码,每种看起来都不太简单的样子。
因此,正确书写代码也是一种挑战。
这里,给出第二种示例代码的简化版本:
[
{
"type": "node",
"data": {
"name": "消息发送者A",
"uin": "10086",
"content": "hello world"
}
},
{
"type": "node",
"data": {
"name": "消息发送者B",
"uin": "10087",
"content": "[CQ:image,file=xxxxx]测试消息2"
}
}
]
其发送合并转发消息的代码也就为:
msg = [
{
"type": "node",
"data": {
"name": "消息发送者A",
"uin": "10086",
"content": "hello world"
}
},
{
"type": "node",
"data": {
"name": "消息发送者B",
"uin": "10087",
"content": "[CQ:image,file=xxxxx]测试消息2"
}
}
]
data = {
'group_id':123456787, # '消息发送的QQ群号'
'messages':msg
}
# cq_url = "http://127.0.0.1:5700/send_group_forward_msg"
# rev3 = requests.post(cq_url,data=data)
# logging.info(rev3.json())
action = "send_group_forward_msg"
post_data = json.dumps({"action": action, "params": data})
rev = ws.send(post_data)
考虑到合并转发消息的消息发送者一般为同一人,略微简化一下,发送多条消息的代码为:
msg = ['测试消息1', '测试消息2', '测试消息3']
group_msg = []
for item in msg:
each_msg = {
"type": "node",
"data": {
"name": "QQ昵称",
"uin": "自己的QQ号",
"content": item
}
}
group_msg.append(each_msg)
data = {
'group_id':123456787, # '消息发送的QQ群号'
'messages':group_msg
}
# cq_url = "http://127.0.0.1:5700/send_group_forward_msg"
# rev3 = requests.post(cq_url,data=data)
# logging.info(rev3.json())
action = "send_group_forward_msg"
post_data = json.dumps({"action": action, "params": data})
rev = ws.send(post_data)
在此基础上,封装为函数:
def send_forward(msg, group_id, ws, sender):
group_msg = []
for item in msg:
each_msg = {
"type": "node",
"data": {
"name": "QQ昵称",
"uin": "自己的QQ号",
"content": item
}
}
group_msg.append(each_msg)
data = {
'group_id':group_id,
'messages':group_msg
}
# cq_url = "http://127.0.0.1:5700/send_group_forward_msg"
# rev3 = requests.post(cq_url,data=data)
# logging.info(rev3.json())
action = "send_group_forward_msg"
post_data = json.dumps({"action": action, "params": data})
rev = ws.send(post_data)
returnStr = "[CQ:at,qq={sender}]".format(sender=sender)
return returnStr
调用函数示例:
send_forward(["hello world", "test2", "test3"], "123456789", ws, '987654321')
该函数的功能为,给定一个消息列表和群号,发送合并转发消息到特定群,并返回艾特发送者的信息,其中字段说明如下:
-
msg
为待发送的消息列表,例如:msg=["hello world", "test2", "test3"]
-
group_id
为发送消息的群号 -
ws
为websocket
的应用,因为这里采用的是正向ws连接
,因此使用该参数,若使用http连接
可不用该字段,使用注释的语句发送消息即可 -
sender
为需要回复的人的QQ号,即触发该消息的群成员QQ -
name
为合并转发消息的人的昵称,可以随便填 -
uin
为合并转发的消息的人的qq,这里填机器人的qq
注意:原代码为正向ws通信的代码,注释部分为http通信方式的代码
最终实现效果: