'use strict'; /** * 短信发送相关接口 * * @author CaiAoLin * @date 2018/1/25 * @version */ const xmlReader = require('xmlreader'); class SMS { /** * 构造函数 * * @param {Object} ctx - egg全局变量 * @return {void} */ constructor(ctx) { this.ctx = ctx; this.url = 'http://sms.haotingyun.com/v2/sms/single_send.json'; // this.url = 'http://101.132.42.40:7862/sms'; } /** * 发送信息 * * @param {String|Array} mobile - 发送的电话号码 * @param {String} content - 发送的内容 * @return {Boolean} - 发送结果 */ async send(mobile, content) { if (mobile instanceof Array) { mobile = mobile.join(','); } let result = false; const config = this.ctx.app.config.sms; const postData = { // action: 'send', // account: config.account, // password: config.password, apikey: config.authKey, mobile, text: content, // extno: config.extno, }; try { const response = await this.ctx.helper.sendRequest(this.url, postData, 'POST'); // const xmlData = await this.xmlParse(response); // if (xmlData === undefined || xmlData.returnstatus.text() !== 'Success') { // throw '短信发送失败!'; // } if (response === undefined && response.code !== 0) { throw '短信发送失败!'; } result = true; } catch (error) { console.log(error); result = false; } return result; } /** * xml解析 * * @param {String} xml - xml数据 * @return {Object} - 解析结果 */ xmlParse(xml) { return new Promise(function(resolve, reject) { xmlReader.read(xml, function(errors, xmlData) { if (errors) { reject(''); } else { resolve(xmlData.returnsms); } }); }); } } module.exports = SMS;