兑现微信自动还原,python达成微信自动还原成效

作者: 韦德国际1946手机版  发布:2019-05-28

近些日子大家上看出有很好的朋友总是利用软件抢沙发,便决定用Python也写三个游乐

本文实例为大家分享了python完结微信自动还原的具体代码,供我们参照他事他说加以考查,具体内容如下

原稿地址(自身):

1 实先自动恢复功效的逻辑步骤

  一 拍卖POST类型的垄断逻辑,接收XML的数目包;

  二 深入分析XML数据包(获得数据包的消息类型恐怕是事件类型);

  3 拼装大家定义好的新闻;

  4 包装成XML格式;

  5 在五秒内回到回去

一、状态上涨表单POST

新春到了,不想让1早晨给您发送祝福的群情里1阵寒风,能够秒回复对方的话,试试下边包车型地铁python程序能够帮您化解那些标题。

介绍

微信自动回复其实主要正是登入,接收音信,回复新闻八个成效,微信未有提供公开的API,可是足以深入分析网页版微信通讯原理,通过模拟浏览器来实现要求的法力。

上边将送交微信网页版通讯原理以及Python代码。

2 代码实际操作--达成关怀群众号自行回复效率

兑现微信自动还原,python达成微信自动还原成效。  本节代码参照上节课继续修改和健全,目录结构跟此前同壹,新引进的模块raw-body使用npm install安装一下就可以,app.js运营文件和util.js不做改造,首要修改一下generator.js文件,以及在generator.js同级目录下新建wechat.js文件和tools.js文件。

  wechat.js文件是将前一节generator.js文件中票据部分的代码抽离出来单独放在1个文本中,具体代码如下:

'use strict';
// 引入模块
var Promise = require('bluebird');
var request = Promise.promisify(require('request'));

//增加url配置项
var prefix = 'https://api.weixin.qq.com/cgi-bin/';
var api = {
    accessToken: prefix   'token?grant_type=client_credential'
};

//利用构造函数生成实例 完成票据存储逻辑
function weChat(opts) {
    var that = this;
    this.appID = opts.appID;
    this.appSecret = opts.appSecret;
    this.getAccessToken = opts.getAccessToken;
    this.saveAccessToken = opts.saveAccessToken;
    //获取票据的方法
    this.getAccessToken()
        .then(function(data) {
            //从静态文件获取票据,JSON化数据,如果有异常,则尝试更新票据
            try {
                data = JSON.parse(data);
            } catch (e) {
                return that.updateAccessToken();
            }
            //判断票据是否在有效期内,如果合法,向下传递票据,如果不合法,更新票据
            if (that.isValidAccessToken(data)) {
                Promise.resolve(data);
            } else {
                return that.updateAccessToken();
            }
        })
        //将拿到的票据信息和有效期信息存储起来
        .then(function(data) {
            //console.log(data);
            that.access_token = data.access_token;
            that.expires_in = data.expires_in;

            that.saveAccessToken(data);
        })
};

//在weChat的原型链上增加验证有效期的方法
weChat.prototype.isValidAccessToken = function(data) {
    //进行判断,如果票据不合法,返回false
    if (!data || !data.access_token || !data.expires_in) {
        return false;
    }
    //拿到票据和过期时间的数据
    var access_token = data.access_token;
    var expires_in = data.expires_in;
    //获取当前时间
    var now = (new Date().getTime());
    //如果当前时间小于票据过期时间,返回true,否则返回false
    if (now < expires_in) {
        return true;
    } else {
        return false;
    };
};

//在weChat的原型链上增加更新票据的方法
weChat.prototype.updateAccessToken = function() {
    var appID = this.appID;
    var appSecret = this.appSecret;
    var url = api.accessToken   '&appid='   appID   '&secret='   appSecret;

    return new Promise(function(resolve, reject) {
        //使用request发起请求
        request({
            url: url,
            json: true
        }).then(function(response) {
            var data = response.body;
            var now = (new Date().getTime());
            var expires_in = now   (data.expires_in - 20) * 1000;
            //把新票据的有效时间赋值给data
            data.expires_in = expires_in;
            resolve(data);
        })
    })
};

//向外暴露weChat
module.exports = weChat;

韦德国际1946手机版 ,  generator.js文件进行轻便后,增多决断对xml数据的格式化方法以及决断事件,增添关怀事件测试音信,具体代码如下:

'use strict';
// 引入模块
var sha1 = require('sha1');
var getRawBody = require('raw-body');
var weChat = require('./wechat');
var tools = require('./tools');

// 建立中间件函数并暴露出去
module.exports = function(opts, handler) {
    //实例化weChat()函数
    //var wechat = new weChat(opts);
    return function*(next) {
        //console.log(this.query);
        var that = this;
        var token = opts.token;
        var signature = this.query.signature;
        var nonce = this.query.nonce;
        var timestamp = this.query.timestamp;
        var echostr = this.query.echostr;
        // 进行字典排序
        var str = [token, timestamp, nonce].sort().join('');
        // 进行加密
        var sha = sha1(str);
        //使用this.method对请求方法进行判断
        if (this.method === 'GET') {
            // 如果是get请求 判断加密后的值是否等于签名值
            if (sha === signature) {
                this.body = echostr   '';
            } else {
                this.body = 'wrong';
            };
        } else if (this.method === 'POST') {
            //如果是post请求 也是先判断签名是否合法 如果不合法 直接返回wrong
            if (sha !== signature) {
                this.body = 'wrong';
                return false;
            };
            //通过raw-body模块 可以把把this上的request对象 也就是http模块中的request对象 去拼装它的数据 最终拿到一个buffer的xml数据
            //通过yield关键字 获取到post过来的原始的XML数据
            var data = yield getRawBody(this.req, {
                length: this.length,
                limit: '1mb',
                encoding: this.charset
            });
            //console.log(data.toString());打印XML数据(当微信公众号有操作的时候 终端可以看到返回的XML数据)
            //tools为处理XML数据的工具包 使用tools工具包的parseXMLAsync方法 把XML数据转化成数组对象
            var content = yield tools.parseXMLAsync(data);
            //console.log(content);打印转化后的数组对象
            //格式化content数据为json对象
            var message = tools.formatMessage(content.xml);
            console.log(message);
            //打印message
            //判断message的MsgType 如果是event 则是一个事件
            if (message.MsgType === 'event') {
                //如果是订阅事件
                if (message.Event === 'subscribe') {
                    //获取当前时间戳
                    var now = new Date().getTime();
                    //设置回复状态是200
                    that.status = 200;
                    //设置回复的类型是xml格式
                    that.type = 'application/xml';
                    //设置回复的主体
                    that.body = '<xml>'  
                        '<ToUserName><![CDATA['   message.FromUserName   ']]></ToUserName>'  
                        '<FromUserName><![CDATA['   message.ToUserName   ']]></FromUserName>'  
                        '<CreateTime>'   now   '</CreateTime>'  
                        '<MsgType><![CDATA[text]]></MsgType>'  
                        '<Content><![CDATA[你好,同学!]]></Content>'  
                        '</xml>';
                    return;
                }
            }
        }

    }
};

  tools.js是管理XML数据的工具文件:

'use strict';
//引入模块
var xml2js = require('xml2js');
var Promise = require('bluebird');
//导出解析XML的方法
exports.parseXMLAsync = function(xml) {
    return new Promise(function(resolve, reject) {
        xml2js.parseString(xml, { trim: true }, function(err, content) {
            if (err) {
                reject(err);
            } else {
                resolve(content);
            };
        });
    });
};
//因为value值可能是嵌套多层的 所以先对value值进行遍历
function formatMessage(result) {
    //声明空对象message
    var message = {};
    //对result类型进行判断
    if (typeof result === 'object') {
        //如果是object类型 通过Object.keys()方法拿到result所有的key 并存入keys变量中
        var keys = Object.keys(result);
        //对keys进行循环遍历
        for (var i = 0; i < keys.length; i  ) {
            //拿到每个key对应的value值
            var item = result[keys[i]];
            //拿到key
            var key = keys[i];
            //判断item是否为数组或者长度是否为0
            if (!(item instanceof Array) || item.length === 0) {
                //如果item不是数组或者长度为0 则跳过继续向下解析
                continue;
            }
            //如果长度为1
            if (item.length === 1) {
                //拿到value值存入val变量
                var val = item[0];
                //判断val是否为对象
                if (typeof val === 'object') {
                    //如果val为对象 则进一步进行遍历
                    message[key] = formatMessage(val);
                } else {
                    //如果不是对象 就把值赋给当前的key放入message里 并去除收尾空格
                    message[key] = (val || '').trim();
                }
            }
            //如果item的长度既不是0也不是1 则说明它是一个数组
            else {
                //把message的key设置为空数组
                message[key] = [];
                //对数组进行遍历
                for (var j = 0, k = item.length; j < k; j  ) {
                    message[key].push(formatMessage(item[j]));
                }
            }
        }
    }
    return message;
}

exports.formatMessage = function(xml) {
    return new Promise(function(resolve, reject) {
        xml2js.parseString(xml, { trim: true }, function(err, content) {
            if (err) {
                reject(err);
            } else {
                resolve(content);
            };
        });
    });
};

exports.formatMessage = formatMessage;

  以上代码完结后,当关心微信测试公众号的时候,会自行恢复『你好,同学!』的提示音信。

同1使用chrome开采者工具抓包

预装:

分析

三 封装音信响应模块

  上边,大家已经完成了关心微信测试公众号自动恢复生机的功效。不过,在generator.js的代码中回复主体部分,使用的是字符串拼接的点子,而且是写死的只能针对「关切事件」响应回复音讯,明显那并不是大家想要的功能,从微信公众平台的付出文书档案,大家得以观望,有如下如所示的这样各样消息回复类型:

韦德国际1946手机版 1

  这么多样新闻回复类型,假使大家像在此之前代码中写的那样,使用字符串拼接的主意来实现,很明显,那并不精确:

韦德国际1946手机版 2

  一方面,以这种字符串拼接的格局来安装消息回复繁琐易出错,另一方面,将音信回复的代码放在generator.js里也不是壹种科学的书写方式,我们最好把新闻回复的那些代码封装成多少个独自的消息响应模块,然后给集成到weChat()那些构造函数上,让变化的实例帮我们做到别的专门的学问。

  在音信响应模块中,大家接纳了EJS和heredoc那多少个模块,用于拍卖模板数据格式,一样是使用npm install命令安装模块就足以了。

  新建立模型板文件template.js,用于存放回复新闻模板以及一些管理函数:

'use strict';

//引入ejs模块 EJS是一个JavaScript模板库 用来从JSON数据中生成HTML字符串
var ejs = require('ejs');
//引入heredoc模块 heredoc是一个简易的模版 用来组织复杂文本串 简化的代码难度 是用来引用字符串的一种方式
var heredoc = require('heredoc');
//针对不同的消息类型获取不同的模板
var template = heredoc(function() {
    /*
        <xml>
        <ToUserName><![CDATA[<%= toUserName %>]]></ToUserName>
        <FromUserName><![CDATA[<%= fromUserName %>]]></FromUserName>
        <CreateTime> <%= createTime %></CreateTime>
        <MsgType><![CDATA[<%= msgType %>]]></MsgType>
        <% if (msgType === 'text'){ %>
            <Content><![CDATA[<%= content %>]]></Content>
        <% } else if (msgType === 'image'){ %>
            <Image>
                <MediaId><![CDATA[<%= content.media_id %>]]></MediaId>
            </Image>
        <% } else if (msgType === 'voice'){ %>
            <Voice>
                <MediaId><![CDATA[<%= content.media_id %>]]></MediaId>
            </Voice>
        <% } else if (msgType === 'video'){ %>
            <Video>
                <MediaId><![CDATA[<%= content.media_id %>]]></MediaId>
                <Title><![CDATA[<%= content.title %>]]></Title>
                <Description><![CDATA[<%= content.description %>]]></Description>
            </Video> 
        <% } else if (msgType === 'music'){ %>
            <Music>
                <Title><![CDATA[<%= content.TITLE %>]]></Title>
                <Description><![CDATA[<%= content.DESCRIPTION %>]]></Description>
                <MusicUrl><![CDATA[<%= content.musicUrl %>]]></MusicUrl>
                <HQMusicUrl><![CDATA[<%= content.hqMusicUrl %>]]></HQMusicUrl>
                <ThumbMediaId><![CDATA[<%= content.thumbMediaId %>]]></ThumbMediaId>
            </Music>
        <% } else if (msgType === 'news'){ %>
            <ArticleCount><%= content.length %></ArticleCount>
            <Articles>
            <%= content.forEach(function(item){ %>
                <item>
                    <Title><![CDATA[<%= item.title %>]]></Title> 
                    <Description><![CDATA[<%= item.description %>]]></Description>
                    <PicUrl><![CDATA[<%= item.picUrl %>]]></PicUrl>
                    <Url><![CDATA[<%= item.url %>]]></Url>
                </item>
            <% }) %>
            </Articles>    
        <% } %>
        </xml>
    */
});

//编译template模板
var compiled = ejs.compile(template);
//向外暴露模板
exports = module.exports = {
    compiled:compiled
};

  音信响应模块已经到位,今后,能够把generator.js里事件剖断和音信回复部分的代码实行重新调解:

            //格式化content数据为json对象
            var message = tools.formatMessage(content.xml);
            console.log(message);//打印message
            //将message挂载到this.weixin上
            this.weixin = message;
            //使用yield next将控制权交出去 交给业务层 让业务层决定如何对解析后的微信消息做分析和回复
            yield handler.call(this, next);
            //进行回复
            wechat.reply.call(this);

  可以阅览,在此之前截图的不正确部分的代码,已经删掉了,而音信回复的有的指向了reply的措施,而以此点子,大家还尚未增进,今后开发wechat.js文件:

//在weChat的原型链上增加reply方法
weChat.prototype.reply = function() {
    var content = this.body;
    var message = this.weixin;
    //调用工具函数
    var xml = tools.template(content, message);
    //设置回复状态是200
    this.status = 200;
    //设置回复的类型是xml格式
    this.type = 'application/xml';
    //设置回复主体
    this.body = xml;
};
//向外暴露weChat
module.exports = weChat;

  在reply方法中,调用了工具函数tools里的template方法,处理音讯模板,张开tools.js文件,记得要先引进大家中间写好的template.js文件:

var template = require('./template');

  然后宣称创设template方法:

//暴露消息模板工具
exports.template = function(content, message){
    //声明info对象临时存储回复的内容
    var info = {}
    //设置默认类型为text
    var type = 'text';
    //设置获取的基本信息
    var fromUserName = message.FromUserName;
    var toUserName = message.ToUserName;
    //如果content是一个数组 那么content即为图文消息
    if(Array.isArray(content)){
        type = 'news';
    };
    //或者通过content的type进行覆盖 或者使用默认类型
    type = content.type || type;
    //把content赋给info
    info.content = content;
    //获取时间戳
    info.createTime = new Date().getTime();
    //将type值给msgType
    info.msgType = type;
    //回复回去的用户
    info.toUserName = fromUserName;
    info.fromUserName = toUserName;
    //返回
    return template.compiled(info);
};

  今后,新闻响应模块那部分的代码,我们曾经修改完了。

新民主主义革命选用选中部分为必须交给的片段 

python2.x或3.x

-获取uuid:

GET

Param     _   (一几个人时间戳)

Response   window.QRLogin.code = 200; window.QRLogin.uuid = "4YyQFP2Daw=="; 

四 达成新闻自动复苏的效果

  那有个别,咱们将成功音讯自动回复的法力,为了尽大概的选代替码,大家把计划相关的代码单独拿出来,放在config.js文件中,在model下新建配置文件config.js,将进口运转文件app.js里的布置音信拿出去放到config.js里:

'use strict';
//引入第三方模块
var path = require('path');
var util = require('../libs/util');
//引入文本文件
var wechat_file = path.join(__dirname, '../accesstokendata/wechat.txt');
// 声明对象字面量config 用于存储配置信息、读取写入票据的方法
var config = {
    wechat: {
        appID: 'wx044125d0a173dd15',
        appSecret: '21295f049b49fe324d7302186c294fe7',
        token: 'beijingjiangweiwechatlearntokenvalueabcdefg',
        getAccessToken:function(){
            return util.readFileAsync(wechat_file);
        },
        saveAccessToken:function(data){
            data = JSON.stringify(data);
            return util.writeFileAsync(wechat_file, data);
        }
    }
};
//将config暴露出去
module.exports = config;

  然后,修改入口运营文件app.js:

'use strict';
// 引入模块
var Koa = require('koa');
var path = require('path');
//引入中间件
var generator = require('./model/generator');
var util = require('./libs/util');
//引入配置文件config
var config = require('./model/config');
//引入回复文件
var weixin = require('./model/weixin');
//引入文本文件
var wechat_file = path.join(__dirname, './accesstokendata/wechat.txt');
// 实例化Koa的web服务器
var app = new Koa();
//传入配置参数和回复内容
app.use(generator(config.wechat, weixin.reply));
//监听3100端口
app.listen(3100);
console.log('listening:3100');

  在开行文件里,大家将config.js文件引进了,并且,新引进了weixin那些文件(在那么些文件中,我们得以存放回复、支付等情势,这里只增添了过来的措施),并在app.use里加多了weixin.reply方法,新建文件weixin.js文件,写入如下内容:

'use strict';
//向外暴露reply接口 这里使用了生成器函数
exports.reply = function*(next) {
    var message = this.weixin;
    //判断用户行为 是普通消息还是事件推送
    if (message.MsgType === 'event') {
        //订阅事件 分为搜索订阅和二维码订阅
        if (message.Event === 'subscribe') {
            if (message.EventKey) {
                console.log('扫描二维码进来'   message.EventKey   ' '   message.ticket);
            }
            //通过this.body设置回复消息
            this.body = '欢迎订阅我的公众号';
        }
        //取消订阅事件
        else if (message.Event === 'unsubscribe') {
            console.log('用户取消了关注');
            this.body = '';
        }
    } else {

    }
    yield next;
};

  在weixin.js文件中,大家增添了针对性订阅/裁撤订阅进行新闻回复的事情逻辑。

  大家来测试一下关怀和注销关切的时候,逻辑是还是不是能跑通,依然在终极系列目录下,使用node app命令运转服务,然后另开1个极限窗口,运行法力隧道内网映射,在微信公众号支付文书档案里登六大家的测试号,裁撤关怀时,调整台会现身提示音讯:

韦德国际1946手机版 3

  重新关注后,微信公众号会有提醒音信『接待订阅作者的众生号』,如下图所示:

韦德国际1946手机版 4

  这几个进程,大概不会这么顺遂,大家能够依据调整台的报错消息,耐心细致调度代码,未有其它走后门可走......

  上面我们来增加一些任何的事件管理逻辑,照旧在weixin.js文件中:

'use strict';
//向外暴露reply接口 这里使用了生成器函数
exports.reply = function*(next) {
    var message = this.weixin;
    //判断用户行为 是事件推送还是普通消息 先判断的是事件推送
    if (message.MsgType === 'event') {
        //订阅事件 分为搜索订阅和二维码订阅
        if (message.Event === 'subscribe') {
            if (message.EventKey) {
                console.log('扫描二维码进来'   message.EventKey   ' '   message.ticket);
            }
            //通过this.body设置回复消息
            this.body = '欢迎订阅我的公众号';
        }
        //取消订阅事件
        else if (message.Event === 'unsubscribe') {
            console.log('用户取消了关注');
            this.body = '';
        }
        //地理位置事件
        else if (message.Event === 'LOCATION') {
            this.body = '您上报的位置是:'   message.Latitude   '/'   message.Longitude   '-'   message.Precision;
        }
        //点击事件 自定义菜单事件
        else if (message.Event === 'CLICK') {
            this.body = '您点击了菜单:'   message.EventKey;
        }
        //跳转链接事件 点击菜单跳转链接时的事件推送
        else if (message.Event === 'VIEW') {
            this.body = '您点击了菜单中的链接:'   message.EventKey;
        }
        //扫描事件
        else if (message.Event === 'SCAN') {
            console.log('关注后扫描二维码'   message.EventKey   ' '   message.Ticket);
            this.body = '看到你扫一下哦';
        }
    }
    //普通消息 文本消息
    else if (message.MsgType === 'text') {
        var content = message.Content;
        //除了回复策略里的内容就回复这句
        var reply = '额,你说的'   message.Content   '太复杂了,我理解不了';
        //回复策略--文本
        if (content === '1') {
            reply = '我是回复策略中的第一条';
        } else if (content === '2') {
            reply = '我是回复策略中的第二条';
        } else if (content === '3') {
            reply = '我是回复策略中的第三条';
        }
        //回复策略--图文
        else if(content === '4'){
            reply = [{
                title:'放开她,让我来!',
                description:'放开她,让我来!',
                picUrl:'http://ww2.sinaimg.cn/large/bd698b0fjw1eev97qkg05j20dw092dg3.jpg'
            },{
                title:'腿毛与秋裤',
                description:'腿毛与秋裤',
                picUrl:'http://upload.qqbody.com/allimg/1611/1203245I7-8.jpg'
            }]
        }
        //将回复reply交给body
        this.body = reply;
    }
    yield next;
};

  嘻嘻,下边是有的简易的过来类型推断以及回复的音信,作者测试了下,当回复壹、二、三时,会重整旗鼓文本新闻,四会东山复起图文音讯,输入任何内容会唤醒「你说的内容太复杂了,小编通晓不了」。

韦德国际1946手机版 5

韦德国际1946手机版 6

  到这边,简单的众生号自行回复的法力,大家就产生了。

 

韦德国际1946手机版 7

pycharm

-获取2维码:

GET  ==

Param 肆YyQFP贰Daw==  即上边的uuid

Response  二维码图片

本文由韦德国际1946发布于韦德国际1946手机版,转载请注明出处:兑现微信自动还原,python达成微信自动还原成效

关键词: