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');
const wxWork = require('./wx_work');
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;
    }

    /**
     * 发送微信审批通知模板
     *
     * @param {Array} corps - 发送的微信账号
     * @param {String} template - 模板id
     * @param {Object} data - 一些模板展示数据
     * @return {Boolean} - 发送结果
     */
    async Send4Work(corps, template, data) {
        let flag = false;
        try {
            // const sck = 'https://scn.ink/';
            const sck = '';
            const qywx = new wxWork(this.ctx);
            for (const c in corps) {
                let url = '';
                let title = '';
                let desc = '';
                let content = '';
                let msgData = '';
                let remark = '';
                let btntxt = '';
                const userids = corps[c];
                switch (template) {
                    case wxConst.template.stage:
                        title = '计量申请审批通知';
                        desc = `您好, 本期计量${data.tips}`;
                        remark = '查看审批详情';
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '状态',
                                value: data.status,
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, 本期计量${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">计量期: 第${data.qi}期</div>
<div class="normal">状态: ${data.status}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = this.ctx.protocol + '://' + this.ctx.host + `/wx/work/${c}/url2wap?project=` + data.code + '&url=' + sck + data.wap_url;
                        break;
                    case wxConst.template.change:
                        title = '工程变更申请审批通知';
                        desc = `您好, ${data.type ? wxConst.changeType[data.type] : '工程变更申请'}${data.tips}`;
                        remark = data.status === wxConst.status.check ? (data.type && _.indexOf(['apply', 'project'], data.type) !== -1 ? '暂无法在线审批' : '可快速审批，如需进行详细审批') :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' :
                                (data.status === wxConst.status.back ? '审批被退回，查看退回结果' : '审批已终止，查看终止结果'));
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '变更名称',
                                value: data.c_name,
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, ${data.type ? wxConst.changeType[data.type] : '工程变更申请'}${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">变更名称: ${data.c_name}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = data.wap_url ? this.ctx.protocol + '://' + this.ctx.host + `/wx/work/${c}/url2wap?project=` + data.code + '&url=' + sck + data.wap_url : '';
                        btntxt = '详情';
                        break;
                    case wxConst.template.ledger:
                        title = '台帐申请审批通知';
                        desc = `您好, 台账${data.tips}`;
                        remark = data.status === wxConst.status.check ? '暂无法在线审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '上报时间',
                                value: moment(new Date(data.begin_time)).format('YYYY-MM-DD'),
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, 台账${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">上报时间: ${moment(new Date(data.begin_time)).format('YYYY-MM-DD')}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = this.ctx.protocol + '://' + this.ctx.host + `/wx/tips?msg=${remark}，请登录PC端系统。`;
                        break;
                    case wxConst.template.revise:
                        title = '台帐修订申请审批通知';
                        desc = `您好, 台账修订${data.tips}`;
                        remark = data.status === wxConst.status.check ? '可快速审批，如需进行详细审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' :
                                (data.status === wxConst.status.back ? '审批被退回，查看退回结果' : '审批已上报，查看审批结果'));
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '上报时间',
                                value: moment(new Date(data.begin_time)).format('YYYY-MM-DD'),
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, 台账修订${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">上报时间: ${moment(new Date(data.begin_time)).format('YYYY-MM-DD')}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = this.ctx.protocol + '://' + this.ctx.host + `/wx/work/${c}/url2wap?project=` + data.code + '&url=' + sck + data.wap_url;
                        btntxt = '详情';
                        break;
                    case wxConst.template.material:
                        title = '材料调差申请审批通知';
                        desc = `您好, 第${data.qi}期材料调差申请${data.tips}`;
                        remark = data.status === wxConst.status.check ? '暂无法在线审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '价差费用',
                                value: data.m_tp ? data.m_tp.toString() : null,
                            },
                            {
                                keyname: '价差费用含税',
                                value: data.hs_m_tp ? data.hs_m_tp.toString() : null,
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, 第${data.qi}期材料调差申请${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">上报时间: ${moment(new Date(data.begin_time)).format('YYYY-MM-DD')}</div>
<div class="normal">价差费用： ${data.m_tp ? data.m_tp.toString() : null}</div>
<div class="normal">价差费用含税： ${data.hs_m_tp ? data.hs_m_tp.toString() : null}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = this.ctx.protocol + '://' + this.ctx.host + `/wx/tips?msg=${remark}，请登录PC端系统。`;
                        break;
                    case wxConst.template.advance:
                        title = '预付款申请审批通知';
                        desc = `您好, 预付款申请${data.tips}`;
                        remark = data.status === wxConst.status.check ? '可快速审批，如需进行详细审批' :
                            (data.status === wxConst.status.success ? '审批已通过，查看审批结果' : '审批被退回，查看退回结果');
                        content = [
                            {
                                keyname: '建设项目',
                                value: data.projectName,
                            },
                            {
                                keyname: '标段',
                                value: data.tenderName,
                            },
                            {
                                keyname: '期数',
                                value: data.qi,
                            },
                            {
                                keyname: '本期支付金额',
                                value: data.tp ? data.tp.toString() : null,
                            },
                            {
                                keyname: '备注',
                                value: `${remark}，请登录PC端系统。`,
                            },
                        ];
                        msgData = `<div class="gray">您好, 预付款申请${data.tips}</div>
<div class="normal">建设项目: ${data.projectName}</div>
<div class="normal">标段: ${data.tenderName}</div>
<div class="normal">期数: ${data.qi}</div>
<div class="normal">本期支付金额: ${data.tp ? data.tp.toString() : null}</div>
<div class="normal">备注: ${remark}，请登录PC端系统。</div>`;
                        url = this.ctx.protocol + '://' + this.ctx.host + `/wx/work/${c}/url2wap?project=` + data.code + '&url=' + sck + data.wap_url;
                        btntxt = '详情';
                        break;
                    default:
                        break;
                }
                if (title !== '') {
                    // console.log(userids, c, title, desc, content, url, btntxt);
                    // await qywx.sendTextCard(userids, c, title, msgData, url, btntxt);
                    await qywx.sendTemplateCard(userids, c, title, desc, content, url, btntxt);
                }
            }
            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;