钉钉单聊/群聊机器人实现思路
Posted 亦非我所愿丶
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了钉钉单聊/群聊机器人实现思路相关的知识,希望对你有一定的参考价值。
钉钉官网文档:https://open.dingtalk.com/document/group/robot-overview
一、钉钉开发平台
1.申请机器人
应用开发-企业内部开发-基础信息-机器人-创建机器人
2.开发管理
设置开发服务器出口IP列表
3.回调接口
设置钉钉扫码后的回调后端接口 (用于消息接收)
4.权限设置
企业内机器人发送消息权限
二、消息接收
获取post后的消息数据及各字段
1.通用字段
conversationType = req_data['conversationType'] # 消息类型,1单聊,2群聊
conversationId = req_data['conversationId'] # 加密的会话id
msgId = req_data['msgId'] # 加密的消息id
senderNick = req_data['senderNick'] # 发送消息的人昵称
isAdmin = req_data['isAdmin'] # 是否为管理员
sessionWebhookExpiredTime = req_data['sessionWebhookExpiredTime'] # 当前会话的Webhook地址过期时间
createAt = req_data['createAt'] # 消息的时间戳
senderId = req_data['senderId'] # 加密的发送者id
chatbotUserId = req_data['chatbotUserId'] # 加密的机器人id
msgtype = req_data['msgtype'] # 消息类型,目前只支持text
text = req_data['text']['content'] # 消息的关键字
sessionWebhook = req_data['sessionWebhook'] # 当前会话的webhook地址
robotCode = req_data['robotCode'] # 消息机器人代码
post_timestamp = request.headers.get('Timestamp') # 消息timestamp
post_sign = request.headers.get('Sign') # 消息sign
2.单聊字段
chatbotCorpId = req_data['chatbotCorpId'] # 加密的机器人所在的企业corpId
senderStaffId = req_data['senderStaffId'] # 企业内部群中@该机器人的成员userid
senderCorpId = req_data['senderCorpId'] # 企业内部群有的发送者当前群的企业corpId。
3.群聊字段
atUsers = req_data['atUsers'] # 被@人的信息
conversationTitle = req_data['conversationTitle'] # 群聊时的群名称
isInAtList = req_data['isInAtList'] # 是否在@列表中
三、后端认证
四、发送消息
1.单聊
msg =
"text":
"content": "单聊: ".format(text)
,
"msgtype": "text"
return json.dumps(msg)
五、实现代码
import json
import hmac
import hashlib
import base64
import time
api_blueprint = Blueprint(__name__ + '_api', __name__)
logger = get_logger(logger_type='run')
def check_sign_result(post_timestamp, post_sign):
timestamp = round(time.time() * 1000)
app_secret = 'ASAO7-nwDBzT1ObEo1PC6htvjHwlIBeu-4sZ7oVDQjf86EOA0DASgylZg-LIKmcL'
app_secret_enc = app_secret.encode('utf-8')
string_to_sign = '\\n'.format(post_timestamp, app_secret)
string_to_sign_enc = string_to_sign.encode('utf-8')
hmac_code = hmac.new(app_secret_enc, string_to_sign_enc, digestmod=hashlib.sha256).digest()
sign = base64.b64encode(hmac_code).decode('utf-8')
# 校验时间戳/sign
if (timestamp - int(post_timestamp) < 36000000 or (int(post_timestamp) - timestamp) < 3600000) and sign == post_sign:
return True
else:
return False
@api_blueprint.route('/wanglei/robot', methods=["GET", "POST"])
def wanglei_robot():
if request.method == 'GET':
return 'get'
elif request.method == 'POST':
req_data = json.loads(request.data.decode())
post_timestamp = request.headers.get('Timestamp')
post_sign = request.headers.get('Sign')
result = check_sign_result(post_timestamp, post_sign)
if result:
conversationType = req_data['conversationType'] # 消息类型,1单聊,2群聊
conversationId = req_data['conversationId'] # 加密的会话id
msgId = req_data['msgId'] # 加密的消息id
senderNick = req_data['senderNick'] # 发送消息的人昵称
isAdmin = req_data['isAdmin'] # 是否为管理员
sessionWebhookExpiredTime = req_data['sessionWebhookExpiredTime'] # 当前会话的Webhook地址过期时间
createAt = req_data['createAt'] # 消息的时间戳
senderId = req_data['senderId'] # 加密的发送者id
chatbotUserId = req_data['chatbotUserId'] # 加密的机器人id
msgtype = req_data['msgtype'] # 消息类型,目前只支持text
text = req_data['text']['content'] # 消息的关键字
sessionWebhook = req_data['sessionWebhook'] # 当前会话的webhook地址
robotCode = req_data['robotCode'] # 消息机器人代码
if conversationType == '1':
# 单聊
chatbotCorpId = req_data['chatbotCorpId'] # 加密的机器人所在的企业corpId
senderStaffId = req_data['senderStaffId'] # 企业内部群中@该机器人的成员userid
senderCorpId = req_data['senderCorpId'] # 企业内部群有的发送者当前群的企业corpId。
msg =
"text":
"content": "单聊: ".format(text)
,
"msgtype": "text"
return json.dumps(msg)
else:
# 群聊
atUsers = req_data['atUsers'] # 被@人的信息
conversationTitle = req_data['conversationTitle'] # 群聊时的群名称
isInAtList = req_data['isInAtList'] # 是否在@列表中
# 如果回复的消息需要@用户,则通过senderNick获取userid,在atUserIds中列出userid即可
msg =
"at":
"atUserIds": [
'manager8575'
],
"isAtAll": False
,
"text":
"content": '群聊: '.format(text)
,
"msgtype": "text"
return json.dumps(msg)
以上是关于钉钉单聊/群聊机器人实现思路的主要内容,如果未能解决你的问题,请参考以下文章
spring websocket 和socketjs实现单聊群聊,广播的消息推送详解