Une introduction détaillée sur la façon d'utiliser NodeJS pour implémenter la fonction de réponse automatique après avoir suivi le compte officiel WeChat

Cet article présente principalement NodeJS en détail pour implémenter la fonction de réponse automatique après avoir suivi le compte public WeChat. Il a une certaine valeur de référence. Les amis intéressés peuvent s'y référer

Étapes logiques de la vraie première fonction de réponse automatique

　1 Traiter la logique de contrôle de type POST et recevoir des paquets de données

XML

　2 Analyse du paquet de données XML ; (obtenir le type de message du paquet de données ou le type

événement) ;

　3 Assemblez le message que nous avons défini

　4 Emballez-le au format XML ;

　5 Retour dans les 5 secondes

Opération pratique du deuxième code

　Le code de cette section continuera d'être modifié et amélioré en fonction de la leçon précédente,

Structure des répertoires

Comme avant, le module raw-body nouvellement introduit peut être installé à l'aide de npm install Le fichier de démarrage app.js et util.js ne le seront pas. modifié. Les principales modifications sont de cliquer sur le fichier Generator.js et de créer un nouveau fichier wechat.js et un fichier tools.js dans le même répertoire que Generator.js. Le fichier wechat.js extrait le code de la partie ticket du fichier generator.js de la section précédente et le place dans un fichier séparé. Le code spécifique est le suivant :

<.>generator.js Une fois le fichier rationalisé, ajoutez la méthode de formatage et l'événement de jugement pour les données XML, et ajoutez les informations de test d'événement qui vous intéressent. Le code spécifique est le suivant :

'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 + &#39;&appid=&#39; + appID + &#39;&secret=&#39; + 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;

outils. js est un fichier outil de traitement des données XML :

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

// 建立中间件函数并暴露出去
module.exports = function(opts) {
  //实例化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 = &#39;<xml>&#39; +
            &#39;<ToUserName><![CDATA[&#39; + message.FromUserName + &#39;]]></ToUserName>&#39; +
            &#39;<FromUserName><![CDATA[&#39; + message.ToUserName + &#39;]]></FromUserName>&#39; +
            &#39;<CreateTime>&#39; + now + &#39;</CreateTime>&#39; +
            &#39;<MsgType><![CDATA[text]]></MsgType>&#39; +
            &#39;<Content><![CDATA[你好，同学！]]></Content>&#39; +
            &#39;</xml>&#39;;
          return;
        }
      }
    }

  }
};

Après avoir terminé le code dans cette section, lorsque vous suivez le compte officiel du test WeChat, il répondra automatiquement "Bonjour, camarade de classe !" 』 message d'invite.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!