一 实先自动回复功能的逻辑步骤
1 处理POST类型的控制逻辑,接收XML的数据包;
2 解析XML数据包(获得数据包的消息类型或者是事件类型);
3 拼装我们定义好的消息;
4 包装成XML格式;
5 在5秒内返回回去
二 代码实操
本节代码参照上节课继续修改和完善,目录结构跟之前相同,新引入的模块raw-body使用npm install安装一下即可,app.js启动文件和util.js不做变动,主要修改一下generator.js文件,以及在generator.js同级目录下新建wechat.js文件和tools.js文件。
wechat.js文件是将前一节generator.js文件中票据部分的代码抽离出来单独放在一个文件中,具体代码如下:
<div class="jb51code">
<pre class="brush:js;">
'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;