Calculation/app/service/ledger_history.js

'use strict';

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

module.exports = app => {

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

        /** 获取最新数据
         *
         * @param {Number}tid - 标段id
         * @return {Promise<*>} 最新数据
         */
        async getLatestHistory(tid) {
            const his = await this.db.select(this.tableName, {
                where: { tid, valid: 1 },
                orders: [['in_time', 'desc']],
                limit: 1, offset: 0,
            });
            return his[0];
        }

        /**
         * 备份
         * @param {Object} tender - 标段
         * @return {Promise<void>} - 新增备份id
         * @private
         */
        async backupLedgerHistory(tender) {
            const now = new Date();
            const timestamp = (now).getTime();

            const billsHis = `${this.ctx.session.sessionProject.id}/${tender.id}/ledger/bills${timestamp}.json`;
            const bills = await this.ctx.service.ledger.getData(tender.id);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + billsHis, Buffer.from(JSON.stringify(bills), 'utf8'));

            const posHis = `${this.ctx.session.sessionProject.id}/${tender.id}/ledger/pos${timestamp}.json`;
            const pos = await this.ctx.service.pos.getPosData({ tid: tender.id });
            await this.ctx.hisOss.put(this.ctx.hisOssPath + posHis, Buffer.from(JSON.stringify(pos), 'utf8'));

            const result = await this.db.insert(this.tableName, {
                pid: this.ctx.session.sessionProject.id, tid: tender.id,
                in_time: now,
                bills_file: billsHis, pos_file: posHis,
                bills_count: bills.length, pos_count: pos.length,
            });

            return result.insertId;
        }

        /**
         * 备份
         * @param {Object} tender - 标段
         * @return {Promise<void>} - 新增备份id
         * @private
         */
        async backupStageLedgerHistory(stage) {
            const sbCount = await this.ctx.service.ledger.count({ tender_id: this.ctx.stage.tid });
            const spCount = await this.ctx.service.pos.count({ tid: this.ctx.stage.tid });
            const ledgerHis = await this.ctx.service.ledgerHistory.getLatestHistory(this.ctx.tender.id);
            if (sbCount === ledgerHis.bills_count && spCount === ledgerHis.pos_count) return ledgerHis.id;

            const now = new Date();
            const timestamp = (now).getTime();

            const billsHis = `${this.ctx.session.sessionProject.id}/${stage.tid}/ledger/bills${timestamp}-s.json`;
            const bills = await this.ctx.service.ledger.getData(stage.tid);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + billsHis, Buffer.from(JSON.stringify(bills), 'utf8'));

            const posHis = `${this.ctx.session.sessionProject.id}/${stage.tid}/ledger/pos${timestamp}-s.json`;
            const pos = await this.ctx.service.pos.getPosData({ tid: stage.tid });
            await this.ctx.hisOss.put(this.ctx.hisOssPath + posHis, Buffer.from(JSON.stringify(pos), 'utf8'));

            const result = await this.db.insert(this.tableName, {
                pid: this.ctx.session.sessionProject.id, tid: stage.tid, sid: stage.id,
                in_time: now,
                bills_file: billsHis, pos_file: posHis,
                bills_count: bills.length, pos_count: pos.length,
            });

            return result.insertId;
        }

        /**
         * 备份
         * @param {Object} revise - 修订
         * @return {Promise<void>} - 新增备份id
         * @private
         */
        async backupReviseLedgerHistory(revise) {
            const now = new Date();
            const timestamp = (now).getTime();

            const billsHis = `${this.ctx.session.sessionProject.id}/${revise.tid}/ledger/bills${timestamp}-r.json`;
            const bills = await this.ctx.service.reviseBills.getData(revise.tid);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + billsHis, Buffer.from(JSON.stringify(bills), 'utf8'));

            const posHis = `${this.ctx.session.sessionProject.id}/${revise.tid}/ledger/pos${timestamp}-r.json`;
            const pos = await this.ctx.service.revisePos.getData(revise.tid);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + posHis, Buffer.from(JSON.stringify(pos), 'utf8'));

            const result = await this.db.insert(this.tableName, {
                pid: this.ctx.session.sessionProject.id, tid: revise.tid,
                rid: revise.id, rorder: revise.corder,
                in_time: now,
                bills_file: billsHis, pos_file: posHis,
                bills_count: bills.length, pos_count: pos.length,
            });

            return result.insertId;
        }

        /**
         * 备份 （预留功能）
         * @param {Object} transaction - 事务
         * @param {Object} change - 工程变更
         * @param {Array} newBillsNode - 新增项目节节点
         * @param {Array} newPosNode - 新增计量单元节点
         * @return {Promise<void>} - 新增备份id
         * @private
         */
        async backupChangeHistory(transaction, change, newBillsNodes, newPosNodes) {
            if ((newBillsNodes || newBillsNodes === 0) && (newPosNodes || newPosNodes.length === 0)) return;
            const now = new Date();
            const timestamp = (now).getTime();

            const billsHis = `${this.ctx.session.sessionProject.id}/${change.tid}/ledger/bills${timestamp}-c.json`;
            const bills = await this.ctx.service.ledger.getData(change.tid);
            if (newBillsNodes.length > 0) bills.push(...newBillsNodes);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + billsHis, Buffer.from(JSON.stringify(bills), 'utf8'));

            const posHis = `${this.ctx.session.sessionProject.id}/${change.tid}/ledger/pos${timestamp}-c.json`;
            const pos = await this.ctx.service.pos.getPosData({ tid: change.tid });
            if (newPosNodes.length > 0) pos.push(...newPosNodes);
            await this.ctx.hisOss.put(this.ctx.hisOssPath + posHis, Buffer.from(JSON.stringify(pos), 'utf8'));

            const result = await transaction.insert(this.tableName, {
                pid: this.ctx.session.sessionProject.id, tid: change.tid,
                cid: change.cid,
                in_time: now,
                bills_file: billsHis, pos_file: posHis,
                bills_count: bills.length, pos_count: pos.length,
            });

            return result.insertId;
        }
    }

    return LedgerTag;
};