WeChat 공식 계정을 팔로우한 후 NodeJS를 사용하여 자동 응답 기능을 구현하는 방법에 대한 자세한 소개
- 黄舟원래의
- 2017-05-31 10:16:451841검색
이 글에서는 주로 WeChat 공개 계정을 팔로우한 후 자동 응답 기능을 구현하는 NodeJS를 소개합니다. 관심 있는 친구는 먼저 자동 응답 기능의 논리를 참조할 수 있습니다.
1 POST 유형 제어 로직을 처리하고
2 XML 데이터 패킷을 구문 분석합니다(데이터 패킷의 메시지 유형 또는event 유형을 얻음).
3 메시지를 정의합니다. 5 5초 이내에 반환두 번째 코드 연습
이 섹션의 코드는 이전 강의를 기반으로 계속 수정되고 개선됩니다. 이전과 마찬가지로 가져온 모듈 raw-body는 npm install을 사용하여 설치할 수 있습니다. app.js 시작 파일과 util.js는 변경되지 않습니다. Generator.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);
})
})
};
//向外暴露weChat
module.exports = weChat; 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) {
//实例化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; 이 섹션의 코드는 WeChat 테스트 공개 계정을 팔로우할 때 자동으로 "안녕하세요, 동창님!"이라고 응답합니다. 』 프롬프트 메시지.
위 내용은 WeChat 공식 계정을 팔로우한 후 NodeJS를 사용하여 자동 응답 기능을 구현하는 방법에 대한 자세한 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!