Calculation/app/service/budget_final_list.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date
 * @version
 */

const status = {
    cancel: 0,
    wait: 1,
    ext: 2,
    done: 3,
    error: 4,
};

module.exports = app => {

    class BudgetFinalList extends app.BaseService {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'budget_final_list';
        }

        _analysisFinal(data) {
            data.tender = data.tender ? data.tender.split(',') : [];
            data.tender_info = data.tender_info ? JSON.parse(data.tender_info) : [];
            data.contract = data.contract ? data.contract.split(',') : [];
        }

        async getFinal(id) {
            const data = await this.getDataById(id);
            this._analysisFinal(data);
            return data;
        }

        async addFinal(budget, tender) {
            const user = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
            const final = {
                bid: budget.id, uid: user.id,
                u_name: user.name, u_role: user.role, u_company: user.company, u_mobile: user.mobile,
                u_login: this.ctx.session.sessionUser.loginType + ';' + this.ctx.session.sessionUser.loginStatus,
                tender: tender ? tender.join(',') : '', status: status.ext,
            };
            const result = await this.db.insert(this.tableName, final);
            return await this.getFinal(result.insertId);
        }

        async clearExpiredFinal(budget) {
            const datas = await this.getAllDataByCondition({ where: { bid: budget.id }, orders: [['id', 'DESC']]});
            if (datas.length > 3) {
                datas.splice(0, 3);
                const conn = await this.db.beginTransaction();
                try {
                    const id = datas.map(x => { return x.id; });
                    await conn.delete(this.tableName, { id });
                    await conn.delete(this.ctx.service.budgetFinal.tableName, { final_id: id });
                    await conn.commit();
                } catch (err) {
                    await conn.rollback();
                    this.ctx.log(err);
                }
            }
        }
    }

    return BudgetFinalList;
};