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
]></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') {
