Calculation/app/lib/wechat.js

'use strict';

/**
 * 微信模板信息发送相关接口
 *
 * @author ellisran
 * @date 2018/1/25
 * @version
 */

// const xmlReader = require('xmlreader');
const _ = require('lodash');
const moment = require('moment');
const wxConst = require('../const/wechat_template.js');
class WX {

    /**
     * 构造函数
     *
     * @param {Object} ctx - egg全局变量
     * @return {void}
     */
    constructor(ctx) {
        this.ctx = ctx;
    }

    /**
     * 发送微信审批通知模板
     *
     * @param {Array} wx_openid - 发送的微信账号
     * @param {String} template - 模板id
     * @param {Object} data - 一些模板展示数据
     * @return {Boolean} - 发送结果
     */
    async Send(wx_openid, template, data) {
        let flag = false;
        try {
            // const templateId = template;
            let templateId = '';
            // const sck = 'https://scn.ink/';
            const sck = '';
            for (const openid of wx_openid) {
                let url = '';
                let msgData = '';
                let remark = '';
                switch (template) {
                    case wxConst.template.stage :
                        templateId = wxConst.templateId.stage;
                        url = this.ctx.protocol + '://' + this.ctx.host + '/wx/url2wap?project=' + data.code + '&url=' + sck + data.wap_url;
                        msgData = {
                            first: {
                                value: '您好，本期计量' + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: '第' + data.qi + '期',
                            },
                            keyword4: {
                                value: data.status,
                            },
                            remark: {
                                value: '查看审批详情，请登录PC端系统。',
                            },
                        };
                        break;
                    case wxConst.template.change:
                        templateId = wxConst.templateId.change;
                        url = data.wap_url ? this.ctx.protocol + '://' + this.ctx.host + '/wx/url2wap?project=' + data.code + '&url=' + sck + data.wap_url : '';
                        remark = data.status === wxConst.status.check ? (data.type && _.indexOf(['apply', 'project'], data.type) !== -1 ? '微信暂无法在线审批' : '微信可快速审批，如需进行详细审批') :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' :
                                (data.status === wxConst.status.back ? '审批被退回，查看退回结果' : '审批已终止，查看终止结果'));
                        msgData = {
                            first: {
                                value: '您好，' + (data.type ? wxConst.changeType[data.type] : '工程变更申请') + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: data.c_name,
                            },
                            remark: {
                                value: remark + '，请登录PC端系统。',
                            },
                        };
                        break;
                    case wxConst.template.ledger:
                        templateId = wxConst.templateId.ledger;
                        remark = data.status === wxConst.status.check ? '微信暂无法在线审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        msgData = {
                            first: {
                                value: '您好，台账' + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: moment(new Date(data.begin_time)).format('YYYY-MM-DD'),
                            },
                            remark: {
                                value: remark + '，请登录PC端系统。',
                            },
                        };
                        break;
                    case wxConst.template.revise:
                        templateId = wxConst.templateId.revise;
                        url = this.ctx.protocol + '://' + this.ctx.host + '/wx/url2wap?project=' + data.code + '&url=' + sck + data.wap_url;
                        remark = data.status === wxConst.status.check ? '微信可快速审批，如需进行详细审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' :
                                (data.status === wxConst.status.back ? '审批被退回，查看退回结果' : '审批已上报，查看审批结果'));
                        msgData = {
                            first: {
                                value: '您好，台账修订' + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: moment(new Date(data.begin_time)).format('YYYY-MM-DD'),
                            },
                            remark: {
                                value: remark + '，请登录PC端系统。',
                            },
                        };
                        break;
                    case wxConst.template.material:
                        templateId = wxConst.templateId.material;
                        // url = this.ctx.protocol + '://' + this.ctx.host + '/wx/url2wap?project=' + data.code + '&url=' + sck + data.wap_url;
                        remark = data.status === wxConst.status.check ? '微信暂无法在线审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        msgData = {
                            first: {
                                value: '您好，第' + data.qi + '期材料调差申请' + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: moment(new Date(data.begin_time)).format('YYYY-MM-DD'),
                            },
                            keyword4: {
                                value: data.m_tp ? data.m_tp.toString() : null,
                            },
                            keyword5: {
                                value: data.hs_m_tp ? data.hs_m_tp.toString() : null,
                            },
                            remark: {
                                value: remark + '，请登录PC端系统。',
                            },
                        };
                        break;
                    case wxConst.template.advance:
                        templateId = wxConst.templateId.advance;
                        url = this.ctx.protocol + '://' + this.ctx.host + '/wx/url2wap?project=' + data.code + '&url=' + sck + data.wap_url;
                        remark = data.status === wxConst.status.check ? '微信可快速审批，如需进行详细审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        msgData = {
                            first: {
                                value: '您好，预付款申请' + data.tips,
                            },
                            keyword1: {
                                value: data.projectName,
                            },
                            keyword2: {
                                value: data.tenderName,
                            },
                            keyword3: {
                                value: data.qi,
                            },
                            keyword4: {
                                value: data.tp ? data.tp.toString() : null,
                            },
                            remark: {
                                value: remark + '，请登录PC端系统。',
                            },
                        };
                        break;
                    default:break;
                }
                if (msgData !== '' && templateId) {
                    // console.log(openid, templateId, url, msgData);
                    await this.ctx.app.wechat.api.sendTemplate(openid, templateId, url, '', msgData);
                }
            }
            flag = true;
        } catch (e) {
            console.log(e);
            flag = false;
        }
        return flag;
    }

    /**
     * 关键字转换，并限制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 = WX;