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

时间  2020-07-09
标签 python 调用 图灵 机器人 实现 微信 公众号 自动 回复 功能 栏目 Python 繁體版
原文   原文链接

​图灵机器人接口调用限制的解决

昨天咱们的文章中说到：使用图灵机器人做为应答机器人能够知足要求，可是天天的回复条数在不花钱的状况下只能有100条。对于我这样贫困线人口怎么可能每月花费99元就为了自动回复呢。因而我就在想还有没有其它的方式可以快速作一个请求和应答表呢？ 结合我以前工做上的经验，那我理解就是直接将请求语句的关键词和须要的回复放在一个Excel表格中，而后直接经过查询Excel表格这样也能作到自动回复，说干就干。整个流程以下图： python

在这里插入图片描述

从流程图上看咱们仍是在昨天的总体框架上新增后续的容错处理，一旦检测到图灵机器人API请求已用完以后，咱们便启动咱们的容错机制，在咱们的Excel表格中去查找咱们须要返回的内容，若没有找到的话，咱们就直接返回一个固定语句告诉粉丝朋友，咱们如今可能没有听懂。flask

总体已经说完了，接下来咱们就开始实干了。首先咱们须要去读取一个Excel表格，我使用的是xlrd这个库（同样啊，安装方法参考以前的python学习三——库安装），因为以前咱们已经整理了一个Excel表格的读写模块——ReadAndWriteExcel.py，因此在这里我直接将这个模块拿过来调用就行了，具体代码见下：服务器

# _*_coding=utf-8_*_
import xlwt
import xlrd

class WriteExcel:
    def __init__(self, sheet_name=None):
        """初始化写表格对象 ​ :param sheet_name: 写表格的sheet名，默认为1 """
        if sheet_name:
            self.sheetname = sheet_name
        else:
            self.sheetname = "1"
        self.workbook = xlwt.Workbook()
        self.worksheet = self.workbook.add_sheet(sheetname=self.sheetname)
​
    def write_values(self, row, col, values):
        """向目标sheet的某个行列写入值​ :param row: 目标行 :param col: 目标列 :param values: 想要写入的值 """
        self.worksheet.write(row, col, values)
​
    def save_file(self, filename=None):
        """保存表格 :param filename: 保存的文件名 """
        if filename:
            self.filename = filename
        else:
            self.filename = "test.xls"
        self.workbook.save(self.filename)
class OpenExcel:
    def __init__(self, file_name=None, sheet_id=None):
        """初始化读取Excel表格 ​ :param file_name: 须要读取的表格名 :param sheet_id: 须要读取的表格sheet """
        if file_name:
            self.file_name = file_name
            self.sheet_id = sheet_id
        else:
            self.file_name = 'example.xlsx'
            self.sheet_id = 0
        self.data = self.get_data()
    def get_data(self):
        """读取表格数据 ​ :return: 返回读取的表格数据 """
        data = xlrd.open_workbook(self.file_name)
        tables = data.sheets()[self.sheet_id]
        return tables
​
    def get_lines(self):
        """读取表格总行数 ​ :return: 返回表格总行数 """
        tables = self.data
        return tables.nrows
​
    def get_cols(self):
        """读取表格总行数 ​ :return: 返回表格总列数 """
        tables = self.data
        return tables.ncols
​
    def get_value(self, row, col):
        """读取表格中具体的行、列对应的值 ​ :param row: 目标行 :param col: 目标列 :return: 返回目标行、列的值 """
        return self.data.cell_value(row, col)

if __name__ == '__main__':
    openexcel = OpenExcel(file_name="work.xls",sheet_id=0)
    print (openexcel.get_lines())
    write_excel = WriteExcel()
    for j in range(0,openexcel.get_cols()):
        for i in range(0,openexcel.get_lines()):
            write_excel.write_values(i,j,openexcel.get_value(i,j))
    write_excel.write_values(100,100,"我是谁")
    write_excel.save_file()
复制代码

接下来咱们以下弄一个调用程序来调用ReadAndWriteExcel.py，实现咱们根据第一列的关键词返回第二列的回复内容。代码以下：微信

import ReadAndWriteExcel
​
def excel_reply(msg):
    """关键字回复"""
    keyword_read = ReadAndWriteExcel.OpenExcel(file_name="KeyWord.xlsx",sheet_id=0)
    for i in range(0,keyword_read.get_lines()):
        if msg in keyword_read.get_value(i,0):
            return keyword_read.get_value(i,1)
    if '你叫啥' in msg or '你叫啥名字' in msg:
        return '沃德天·维森莫·拉莫帅·帅德布耀'
    elif '我爱你' in msg:
        return  "我也爱你"
    elif '早安'in msg:
        return "早安啊，朋友"
    else:
        return '我没有听懂你在说什么，\n或许我休息一天，\n明天就能智商上线了~'
    pass
复制代码

这里咱们不只仅是经过读取Excel，也将一些固定的回复放在代码中进行调试了。接下来咱们来看看主程序的代码。app

# -*- 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)
                #将图灵机器人返回的内容发送给粉丝
                if '4003' in tuling_replay_text:
                    return reply_text(fromUser, toUser,ReplayFromExcel.excel_reply(content))
                else:
                    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)
复制代码

咱们在查看图灵机器人的API文档发现返回码为4003时为API接口调用次数已用完，因此咱们以前判断4003是否在API接口的返回信息中，若存在，则图灵机器人API调用已用完，须要使用Excel备选方案进行答复。 框架

在这里插入图片描述
这样咱们的微信公众号就不再会出现服务器异常的报错了。

图片和关注的自动回复

这样配置了以后，咱们还发现了一些问题，如：因为使用了API开发接口，致使公众号默认的自动化回复没法使用了。1、一样的关注的自动回复也不能同时使用了；2、上面咱们的回复也一直都是针对的文字，对于图片消息没法进行应答。针对这两个问题，咱们再次对咱们的程序进行了优化，新增了关注自动回复和图片回复原图的状况。先上代码：学习

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)
                #将图灵机器人返回的内容发送给粉丝
                if '4003' in tuling_replay_text:
                    return reply_text(fromUser, toUser,ReplayFromExcel.excel_reply(content))
                else:
                    return reply_text(fromUser, toUser, tuling_replay_text)
            #关注公众号的自动答复
            elif msgType == "event":
                Event = xml.find('Event').text
                if Event == "subscribe":
                    subscribe_reply = "菜鸟小白终于等到你~\n" \
                                      "咱们能够一块儿学习打卡，\n" \
                                      "一块儿努力成长。\n" \
                                      "你烦闷时，我还能够陪你聊天解闷哦~"
                    return reply_text(fromUser, toUser, subscribe_reply)
            elif msgType == "image":
                mediaId = xml.find('MediaId').text
                return reply_image(fromUser, toUser, mediaId)
            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)
def reply_image(to_user, from_user, mediaId):
复制代码

以图片类型的方式回复请求，返回原图片加密

return """ <xml> <ToUserName><![CDATA[{}]]></ToUserName> <FromUserName><![CDATA[{}]]></FromUserName> <CreateTime>{}</CreateTime> <MsgType><![CDATA[image]]></MsgType> <Image> <MediaId><![CDATA[{}]]></MediaId> </Image> </xml> """.format(to_user, from_user, int(time.time() * 1000), mediaId)
复制代码

经过对微信公众号开发文档的阅读，咱们发现文字类消息和图片类消息的区分在于msgType，文字类型消息为text，图片类消息为image。对于图片类的消息图片是保存在MediaId字段中，咱们只须要将这个在返回给粉丝就行了，就是原图返给粉丝。spa

咱们也发现新增粉丝关注时，咱们收到的是一个msgType是event，当event中的包含的内容是subscribe时为粉丝关注，咱们判断收到这样的消息，就返回须要回复粉丝的内容便可。

固然这样还会有一些其余的问题，如怎么回复音频、视频。这个方法都是相似的，大家能够参考微信公众号的开发手册，本身想一想该如何解决。 关注微信公众号“菜鸟小白的学习分享”回复“101”获取微信公众号自动回复机器人源码哦。 关注微信公众号“菜鸟小白的学习分享”回复“100”获取微信公众号自动回复机器人可执行程序哦。 关注微信公众号——菜鸟小白的学习分享 妈妈不再用担忧我找不到路了

在这里插入图片描述
一我的的学习——孤单 一群人的学习——幸福
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程