NodeJS实现微信公众号关注后自动回复功能

一 实先自动回复功能的逻辑步骤

　　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文件中票据部分的代码抽离出来单独放在一个文件中，具体代码如下：

'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);    })  })};//向外暴露weChatmodule.exports = weChat;