Calculation/app/service/notice_push.js

'use strict'

/**
 * 推送表模型
 *
 * @author LanJianRong
 * @date 2017/11/16
 * @version
 */
const auditConst = require('../const/audit');
module.exports = app => {
    class NoticePush extends app.BaseService {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx)
            this.tableName = 'notice'
        }

        /**
         * 将未读记录设置成已读
         * @param {Number} id 推送记录id
         */
        async set(id) {
            await this.update({ is_read: 1 }, { id })
        }

        /**
         * 查询所有推送记录(取每个审批类型的前20条再拼接)
         * @param {Integer} pid - 项目id
         * @param {Integer} uid - 查询人id
         */
        async getNotice(pid, uid = 0, spid = '') {
            // const noticeList = [];
            // for (const type in auditConst.pushType) {
            //     const wheres = { pid, type: auditConst.pushType[type] };
            //     if (uid !== 0) {
            //         wheres.uid = uid;
            //     }
            //     let notice = await this.db.select(this.tableName, {
            //         where: wheres,
            //         orders: [['create_time', 'desc']],
            //         limit: 20,
            //         offset: 0
            //     });
            //     notice = notice.map(v => {
            //         const extra = JSON.parse(v.content);
            //         delete v.content;
            //         return { ...v, ...extra };
            //     });
            //     noticeList.push(...notice);
            // }
            // return this._.orderBy(noticeList, ['create_time'], ['desc']);
            // const wheres = { pid };
            // if (uid !== 0) {
            //     wheres.uid = uid;
            // }
            // let notice = await this.db.select(this.tableName, {
            //     where: wheres,
            //     orders: [['create_time', 'desc']],
            //     limit: 30,
            //     offset: 0
            // });
            const uidSql = uid ? ' AND a.`uid` = ' + uid : '';
            const spidSql = spid ? ' AND (a.`spid` = "' + spid + '" OR t.`spid` = "' + spid + '")': '';
            const sql = 'SELECT a.* FROM ?? AS a LEFT JOIN ?? AS t ON a.`tid` = t.`id` WHERE a.`pid` = ?' + uidSql + spidSql + ' ORDER BY a.`create_time` DESC LIMIT 0,30';
            const params = [this.tableName, this.ctx.service.tender.tableName, pid];
            let notice = await this.db.query(sql, params);
            notice = notice.map(v => {
                const extra = JSON.parse(v.content);
                delete v.content;
                return { ...v, ...extra };
            });
            return notice;
        }

        /**
         * 查询所有推送记录,不重复数据
         * @param {Integer} pid - 项目id
         * @param {Integer} uid - 查询人id
         */
        async getNoticeByDataCollect(pid, tenderIds = []) {
            const wheres = { pid };
            if (tenderIds.length > 0) {
                wheres.tid = tenderIds;
            }
            let notice = await this.db.select(this.tableName, {
                where: wheres,
                orders: [['create_time', 'desc']],
                limit: 40,
                offset: 0
            });
            notice = this._.uniqBy(notice, 'content');
            notice = notice.map(v => {
                const extra = JSON.parse(v.content);
                delete v.content;
                return { ...v, ...extra }
            });
            return notice
        }
    }
    return NoticePush
}