Calculation/app/service/project_log.js

'use strict';

/**
 * 项目操作日志-数据模型
 *
 * @author ellisran
 * @date 2021/01/12
 * @version
 */

module.exports = app => {
    class projectLog extends app.BaseService {
        constructor(ctx) {
            super(ctx);
            this.tableName = 'project_log';
        }

        /**
         * 创建登录日志
         * @return {Boolean} 日志是否创建成功
         * @param {Number} type - 登录类型
         * @param {Number} status - 是否显示记录
         */
        async addProjectLog(transaction, type, status, msg, tid = 0) {
            const { ctx } = this;
            const ipMsg = await this.ctx.helper.getUserIPMsg();
            tid = ctx.tender && ctx.tender.id ? ctx.tender.id : tid;
            let subProjectId = ctx.subProject && ctx.subProject.id ? ctx.subProject.id : (ctx.tender && ctx.tender.data.spid ? ctx.tender.data.spid : 0);
            if (!subProjectId) {
                const tender = await this.ctx.service.tender.getDataById(tid);
                if (tender && tender.spid) subProjectId = tender.spid;
            }
            const payload = {
                uid: ctx.session.sessionUser.accountId,
                pid: ctx.session.sessionProject.id,
                spid: subProjectId,
                tid,
                type,
                status,
                msg,
            };
            this._.assign(payload, ipMsg);
            return await transaction.insert(this.tableName, payload);
        }

        /**
         * 获取操作日志
         * @param {Number} pid - 项目id
         * @param {Number} type - 类型
         * @return {Promise<Array>} 日志数组
         */
        async getLogs(spid, type = 0) {
            const typeSql = parseInt(type) !== 0 ? ' AND A.`type` = ' + type : '';
            const sql = 'SELECT A.*, B.`name` as `username`, B.`mobile` FROM ?? as A LEFT JOIN ?? as B ON A.`uid` = B.`id` WHERE A.`spid` = ?' + typeSql + ' AND TO_DAYS(NOW()) - TO_DAYS(A.`create_time`) <= 30  ORDER BY A.`id` DESC';
            const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, spid];
            return await this.db.query(sql, sqlParam);
        }
    }
    return projectLog;
};