GO-CQHTTP合并转发消息无法发送

2021-07-07  本文已影响0人  走错说爱你

最近,在写机器人的时候遇到了一个问题,合并转发实现不了,这里记录一下。

使用合并转发主要是为了缩短消息,不然发一长串消息在群里严重影响群里聊天吹水。

然鹅,按照官方文档折腾了半天,最后还是报错,消息发不出去:
(这里本来应该有图片的,但是之前报错的时候没来得及写博客,于是没存,现在代码改了,找不到了)

最终经过各方查找,发现了一个关键点:


关键点

于是,经过启发,也许是版本问题,原先用的是0.9X的版本,可能这个接口支持得不是很好。

于是最终解决方案如下:

  1. 升级go-cqhttp到最新版(1.0.0.4 beta)

  2. 正确书写代码
    原文档的代码属实有点混乱,可以看到,涉及该接口的文档有这么两个部分:发送合并转发API合并转发CQCode

    发送合并转发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')

该函数的功能为,给定一个消息列表和群号,发送合并转发消息到特定群,并返回艾特发送者的信息,其中字段说明如下:

注意:原代码为正向ws通信的代码,注释部分为http通信方式的代码

最终实现效果:


实现效果
合并转发消息
上一篇下一篇

猜你喜欢

热点阅读