python调用图灵机器人实现微信公众号的自动回复功能（上）

时间 2020-07-09

标签 python 调用图灵机器人实现微信公众号自动回复功能栏目 Python 繁體版

原文原文链接

刚刚建立这个公众号的时候，个人一个同事就找个人公众号聊天，可是那个时候个人公众号仍是仅支持根据关键词，若是要作到支持智能回复，那基本上就是不可能。而后我结合我以前作的微信自动回复机器人的经历，我首先就想到了图灵机器人。是否是能够把图灵机器人和微信公众号进行链接呢？因而我开始查看html

图灵机器人的接口文档python

微信公众号web

发现其实只要咱们拥有一个公网的web服务器地址，微信公众号和web服务器进行通讯，咱们对接收的微信公众号消息进行解析转发给图灵机器人，图灵机器人根据咱们请求的内容返回对应的回复，咱们再将回复返回给微信公众号便可。整个流程以下： json

微信公众号服务器的配置

首先咱们须要搭建一个web服务器用于接收微信公众号的请求，咱们能够经过flask进行搭建。flask

在pycharm中中新建一个工程和main.py文件，输入以下内容：api

from flask import Flask
from flask import request

app = Flask(__name__)

@app.route("/")
def index():
    return "Hello World!"

if __name__ == "__main__":
    app.run(host='0.0.0.0')
复制代码

运行成功后，你能够在浏览器上访问本身的服务器浏览器

接下来咱们须要将这个服务器映射到公网上获取一个公网url，我这边使用的ngrok，将下载的exe文件打开后，输入“ngrok http 80”，就出现一个公网映射地址以下图：服务器

将红色框标注的地址拷贝到微信公众号的开发-基本配置-服务器配置的服务器地址（此时不要点击保存，由于咱们须要对字段信息进行处理，否者是不会校验经过的）微信

查看微信公众号的开发手册，能够了解到信息处理流程。app

# -*- coding:utf-8 -*-
from flask import Flask
from flask import request
import hashlib

app = Flask(__name__)

@app.route("/")
def index():
    return "Hello World!"

@app.route("/wechat", methods=["GET","POST"])
def weixin():
    if request.method == "GET":     # 判断请求方式是GET请求
        my_signature = request.args.get('signature')     # 获取携带的signature参数
        my_timestamp = request.args.get('timestamp')     # 获取携带的timestamp参数
        my_nonce = request.args.get('nonce')        # 获取携带的nonce参数
        my_echostr = request.args.get('echostr')         # 获取携带的echostr参数

        token = 'Your token'     # 必定要跟刚刚填写的token一致
        # 进行字典排序
        data = [token,my_timestamp ,my_nonce ]
        data.sort()
        # 拼接成字符串，进行hash加密时须要为字符串类型
        temp = ''.join(data)
        #建立一个hash对象
        s = hashlib.sha1()
        #对建立的hash对象更新须要加密的字符串
        s.update(data.encode("utf-8"))
        #加密处理
        mysignature = s.hexdigest()

        # 加密后的字符串可与signature对比，标识该请求来源于微信
        if my_signature == mysignature:
            return my_echostr
        else:
            return ""
            
if __name__ == "__main__":
    app.run(host='0.0.0.0', port=80)
复制代码

再次运行程序，此时再在微信公众号的配置页面点击提交能够看到提交成功的提示信息。而后再咱们的ngrok上能够看到200 OK的GET链接信息

这样咱们的完成了一步——服务器的配置，将微信公众号和咱们搭建的web服务器进行通讯。

接入图灵机器人

刚刚咱们在程序中判断了一个GET的链接信息就是进行通讯认证的程序，若链接信息是一个POST请求那即是咱们公众号的转发信息了。接下来咱们须要对这个POST信息进行处理，提取出消息内容转发给图灵机器人便可。

# -*- coding:utf-8 -*-
from flask import Flask
from flask import request
import hashlib
import tyuling_replay
import time
import re
import ReplayFromExcel
import xml.etree.ElementTree as ET


app = Flask(__name__)

@app.route("/")
def index():
    return "Hello World!"

@app.route("/wechat", methods=["GET","POST"])
def weixin():
    if request.method == "GET":     # 判断请求方式是GET请求
        my_signature = request.args.get('signature')     # 获取携带的signature参数
        my_timestamp = request.args.get('timestamp')     # 获取携带的timestamp参数
        my_nonce = request.args.get('nonce')        # 获取携带的nonce参数
        my_echostr = request.args.get('echostr')         # 获取携带的echostr参数
        # my_token = request.args.get('token')
        print(my_signature)
        print(my_timestamp)
        print(my_nonce)
        print(my_echostr)
        # print(my_token)
        token = '123456'     # 必定要跟刚刚填写的token一致

        # 进行字典排序
        data = [token,my_timestamp ,my_nonce ]
        data.sort()
        # 拼接成字符串,进行hash加密时需为字符串
        data = ''.join(data)
        #建立一个hash对象
        s = hashlib.sha1()
        #对建立的hash对象更新须要加密的字符串
        s.update(data.encode("utf-8"))
        #加密处理
        mysignature = s.hexdigest()

        print("handle/GET func: mysignature, my_signature: ", mysignature, my_signature)

        # 加密后的字符串可与signature对比，标识该请求来源于微信
        if my_signature == mysignature:
            return my_echostr
        else:
            return ""
    else:
            # 解析xml
            xml = ET.fromstring(request.data)
            toUser = xml.find('ToUserName').text
            fromUser = xml.find('FromUserName').text
            msgType = xml.find("MsgType").text
            createTime = xml.find("CreateTime")
            # 判断类型并回复
            if msgType == "text":
                content = xml.find('Content').text
                #根据公众号粉丝的ID生成符合要求的图灵机器人userid
                if len(fromUser)>31:
                    tuling_userid = str(fromUser[0:30])
                else:
                    tuling_userid = str(fromUser)
                tuling_userid=re.sub(r'[^A-Za-z0-9]+', '', tuling_userid)
                #调用图灵机器人API返回图灵机器人返回的结果
                tuling_replay_text = tyuling_replay.get_message(content,tuling_userid)
                return reply_text(fromUser, toUser, tuling_replay_text)

            else:
                return reply_text(fromUser, toUser, "我只懂文字")

def reply_text(to_user, from_user, content):
    """ 以文本类型的方式回复请求 """
    return """ <xml> <ToUserName><![CDATA[{}]]></ToUserName> <FromUserName><![CDATA[{}]]></FromUserName> <CreateTime>{}</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[{}]]></Content> </xml> """.format(to_user, from_user, int(time.time() * 1000), content)

if __name__ == "__main__":
    app.run(host='0.0.0.0', port=80)
复制代码

咱们将图灵机器人的调用封装在一个tyuling_replay模块中，具体内容以下：

import json
import urllib.request
tuling_key='图灵机器人的APIkey'
api_url = "http://openapi.tuling123.com/openapi/api/v2"
def get_message(message,userid):
    req = {
    "perception":
    {
        "inputText":
        {
            "text": message
        },

        "selfInfo":
        {
            "location":
            {
                "city": "",
                "province": "",
                "street": ""
            }
        }
    },
    "userInfo":
    {
        "apiKey": tuling_key,
        "userId": userid
    }
    }
    req = json.dumps(req).encode('utf8')
    http_post = urllib.request.Request(api_url, data=req, headers={'content-type': 'application/json'})
    response = urllib.request.urlopen(http_post)
    response_str = response.read().decode('utf8')
    response_dic = json.loads(response_str)
    results_code = response_dic['intent']['code']
    print(results_code)
    if results_code == 4003:
        results_text = "4003:%s"%response_dic['results'][0]['values']['text']
    else:
        results_text = response_dic['results'][0]['values']['text']
    return results_text
复制代码

详细的内容能够参考图灵机器人的API接入文档。

至此，咱们的微信公众号自动回复机器人就作好了，可是免费版的图灵机器人天天的调用次数也是有限，如何完全解决这个问题呢？咱们后续再讲咱们的方法。

关注微信公众号“菜鸟小白的学习分享”回复“101”获取微信公众号自动回复机器人源码哦。

关注微信公众号——菜鸟小白的学习分享妈妈不再用担忧我找不到路了

一我的的学习——孤单一群人的学习——幸福