'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'};//利用構(gòu)造函數(shù)生成實例 完成票據(jù)存儲邏輯function weChat(opts) {  var that = this;  this.appID = opts.appID;  this.appSecret = opts.appSecret;  this.getAccessToken = opts.getAccessToken;  this.saveAccessToken = opts.saveAccessToken;  //獲取票據(jù)的方法  this.getAccessToken()    .then(function(data) {      //從靜態(tài)文件獲取票據(jù)，JSON化數(shù)據(jù)，如果有異常，則嘗試更新票據(jù)      try {        data = JSON.parse(data);      } catch (e) {        return that.updateAccessToken();      }      //判斷票據(jù)是否在有效期內(nèi)，如果合法，向下傳遞票據(jù)，如果不合法，更新票據(jù)      if (that.isValidAccessToken(data)) {        Promise.resolve(data);      } else {        return that.updateAccessToken();      }    })    //將拿到的票據(jù)信息和有效期信息存儲起來    .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) {  //進行判斷，如果票據(jù)不合法，返回false  if (!data || !data.access_token || !data.expires_in) {    return false;  }  //拿到票據(jù)和過期時間的數(shù)據(jù)  var access_token = data.access_token;  var expires_in = data.expires_in;  //獲取當前時間  var now = (new Date().getTime());  //如果當前時間小于票據(jù)過期時間，返回true，否則返回false  if (now < expires_in) {    return true;  } else {    return false;  };};//在weChat的原型鏈上增加更新票據(jù)的方法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發(fā)起請求    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;      //把新票據(jù)的有效時間賦值給data      data.expires_in = expires_in;      resolve(data);    })  })};//向外暴露weChatmodule.exports = weChat;

'use strict';// 引入模塊var sha1 = require('sha1');var getRawBody = require('raw-body');var weChat = require('./wechat');var tools = require('./tools');// 建立中間件函數(shù)并暴露出去module.exports = function(opts) {  //實例化weChat()函數(shù)  //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對象 去拼裝它的數(shù)據(jù) 最終拿到一個buffer的xml數(shù)據(jù)      //通過yield關(guān)鍵字 獲取到post過來的原始的XML數(shù)據(jù)      var data = yield getRawBody(this.req, {        length: this.length,        limit: '1mb',        encoding: this.charset      });      //console.log(data.toString());打印XML數(shù)據(jù)（當微信公眾號有操作的時候 終端可以看到返回的XML數(shù)據(jù)）      //tools為處理XML數(shù)據(jù)的工具包 使用tools工具包的parseXMLAsync方法 把XML數(shù)據(jù)轉(zhuǎn)化成數(shù)組對象      var content = yield tools.parseXMLAsync(data);      //console.log(content);打印轉(zhuǎn)化后的數(shù)組對象      //格式化content數(shù)據(jù)為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();          //設(shè)置回復狀態(tài)是200          that.status = 200;          //設(shè)置回復的類型是xml格式          that.type = 'application/xml';          //設(shè)置回復的主體          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;        }      }    }  }};

'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進行循環(huán)遍歷    for (var i = 0; i < keys.length; i++) {      //拿到每個key對應(yīng)的value值      var item = result[keys[i]];      //拿到key      var key = keys[i];      //判斷item是否為數(shù)組或者長度是否為0      if (!(item instanceof Array) || item.length === 0) {        //如果item不是數(shù)組或者長度為0 則跳過繼續(xù)向下解析        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 則說明它是一個數(shù)組      else {        //把message的key設(shè)置為空數(shù)組        message[key] = [];        //對數(shù)組進行遍歷        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;