Calculation/app/lib/sms.js

'use strict';

/**
 * 短信发送相关接口
 *
 * @author CaiAoLin
 * @date 2018/1/25
 * @version
 */

// const xmlReader = require('xmlreader');
const Core = require('@alicloud/pop-core');
const smsAli = require('../const/sms_alitemplate.js');
class SMS {

    /**
     * 构造函数
     *
     * @param {Object} ctx - egg全局变量
     * @return {void}
     */
    constructor(ctx) {
        this.ctx = ctx;
        this.url = 'https://sms.yunpian.com/v2/sms/batch_send.json';
        // this.url = 'http://sms.haotingyun.com/v2/sms/single_send.json';
        this.url2 = 'http://sms.haotingyun.com/v2/sms/tpl_single_send.json';
        // this.url = 'http://101.132.42.40:7862/sms';
        this.client = new Core({
            accessKeyId: smsAli.accessKey,
            accessKeySecret: smsAli.accessKeySecret,
            endpoint: smsAli.endpoint,
            apiVersion: '2017-05-25',
        });

    }

    async aliSend(mobile, data, code) {
        if (mobile instanceof Array) {
            mobile = mobile.join(',');
        }
        let flag = false;
        // const flag = false;
        const params = {
            RegionId: smsAli.regionId,
            PhoneNumbers: mobile,
            SignName: smsAli.signName,
            TemplateCode: code,
            TemplateParam: JSON.stringify(data),
        };
        const requestOption = {
            method: 'POST',
        };
        // console.log(params);
        try {
            await this.client.request('SendSms', params, requestOption).then(result => {
                if (result.Code === 'OK') {
                    flag = true;
                } else {
                    throw '短信发送失败!';
                }
            }, ex => {
                console.log(ex);
                throw '短信发送失败!';
            });
        } catch (e) {
            console.log(e);
            flag = false;
        }
        return flag;
    }

    /**
     * 发送信息
     *
     * @param {String|Array} mobile - 发送的电话号码
     * @param {String} content - 发送的内容
     * @param {String} tplId - 补充的tpl_id(防止模板无法找到发送失败)
     * @return {Boolean} - 发送结果
     */
    async send(mobile, content, tplId = '') {
        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,
        };
        if (tplId !== '') {
            postData.tpl_id = tplId;
        }
        const url = tplId !== '' ? this.url2 : this.url;
        try {
            const response = await this.ctx.helper.sendRequest(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);
    //             }
    //         });
    //     });
    // }

    /**
     * 关键字转换，并限制20个字以内
     *
     * @param {String} content - 内容
     * @return {Object} - 解析结果
     */
    async contentChange(content) {
        let str = content.replace(/【/g, '（');
        str = str.replace(/】/g, '）');
        str = str.replace(/工程款/g, '***');
        str = str.length > 20 ? str.substring(0, 17) + '...' : str;
        return str;
    }
}

module.exports = SMS;