Calculation/app/service/rpt_archive.js

'use strict';

/**
 * Created by Tony on 2021/3/30.
 */

const BaseService = require('../base/base_service');
const rptArchiveConst = require('../const/rpt_archive');

module.exports = app => {

    class RptArchive extends BaseService {

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'rpt_archive';
            this.dataId = 'id';
        }

        async getArchiveById(id) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('id', {
                value: id,
                operate: '=',
            });
            this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const list = await this.db.query(sql, sqlParam);
            return list;
        }

        async getArchiveByBzId(prjId, stgId, bzId) {
            if (stgId > 0) {
                return await this.getPrjStgArchive(prjId, stgId);
            }
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('prj_id', {
                value: prjId,
                operate: '=',
            });
            this.sqlBuilder.setAndWhere('stage_id', {
                value: stgId,
                operate: '=',
            });
            this.sqlBuilder.setAndWhere('business_id', {
                value: `"${bzId}"`,
                operate: '=',
            });
            this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const rstList = await this.db.query(sql, sqlParam);
            return rstList;
        }

        async getPrjStgArchive(prjId, stgId) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('prj_id', {
                value: prjId,
                operate: '=',
            });
            this.sqlBuilder.setAndWhere('stage_id', {
                value: stgId,
                operate: '=',
            });
            this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const rstList = await this.db.query(sql, sqlParam);
            return rstList;
        }

        async createArchive(prj_id, stage_id, tender_id, business_id, archiveArr) {
            let rst = null;
            this.transaction = await this.db.beginTransaction();
            try {
                const data = {
                    prj_id,
                    stage_id,
                    business_id,
                    tender_id,
                    business_type: rptArchiveConst.getBusinessType(stage_id),
                    content: JSON.stringify(archiveArr),
                };
                // console.log(data);
                rst = await this.transaction.insert(this.tableName, data);
                await this.transaction.commit();
            } catch (ex) {
                console.log(ex);
                // 回滚
                await this.transaction.rollback();
            }
            return rst;
        }

        async updateArchive(id, prj_id, stage_id, tender_id, business_id, archiveArr) {
            let rst = null;
            this.transaction = await this.db.beginTransaction();
            try {
                const data = {
                    id,
                    prj_id,
                    stage_id,
                    business_id,
                    tender_id,
                    business_type: rptArchiveConst.getBusinessType(stage_id),
                    content: JSON.stringify(archiveArr),
                };
                // console.log(data);
                rst = await this.transaction.update(this.tableName, data);
                await this.transaction.commit();
            } catch (ex) {
                console.log(ex);
                // 回滚
                await this.transaction.rollback();
            }
            return rst;
        }

        // async addInitialStageData(tender_id, stage, preStage) {
        //     // 在加stage的时候需要挂上这个，copy之前的签名人
        //     const rst = [];
        //     const preRoleRelList = await this.getRoleRptRelByTenderId(tender_id, preStage.id);
        //     for (const rptRoleRel of preRoleRelList) {
        //         const relList = JSON.parse(rptRoleRel.rel_content);
        //         // const newRptRoleRel = {tender_id: tender_id, rpt_id: rptRoleRel.rpt_id, sid: stage.id, rel_content: ''};
        //         const newRelList = [];
        //         for (const role of relList) {
        //             const newRole = {};
        //             newRelList.push(newRole);
        //             for (const key in role) {
        //                 if (key !== 'sign_date') {
        //                     newRole[key] = role[key];
        //                 } else {
        //                     newRole[key] = '';
        //                 }
        //             }
        //         }
        //         // rst.push(await this.createRoleRelationship(tender_id, rptRoleRel.rpt_id, stage.id, newRelList));
        //         await this.createRoleRelationship(tender_id, rptRoleRel.rpt_id, stage.id, newRelList); // 暂时用不到，就先不返回结果
        //     }
        //     return rst;
        // }

        // async updateRoleRelationship(id, tender_id, rpt_id, sid, relArr) {
        //     let rst = null;
        //     if (id < 0) {
        //         rst = await this.createRoleRelationship(tender_id, rpt_id, sid, relArr);
        //     } else {
        //         this.transaction = await this.db.beginTransaction();
        //         try {
        //             const data = { id, tender_id, rpt_id, sid, rel_content: JSON.stringify(relArr) };
        //             rst = await this.transaction.update(this.tableName, data);
        //             await this.transaction.commit();
        //         } catch (ex) {
        //             console.log(ex);
        //             // 回滚
        //             await this.transaction.rollback();
        //         }
        //     }
        //     return rst;
        // }
        //
        // async updateMultiRoleRelationship(orgParams, newRelArr) {
        //     for (let idx = 0; idx < orgParams.length; idx++) {
        //         const param = orgParams[idx];
        //         const data = { tender_id: param[0], sid: param[1], rpt_id: param[2] };
        //         this.transaction = await this.db.beginTransaction();
        //         try {
        //             await this.transaction.delete(this.tableName, data);
        //             this.transaction.commit();
        //             await this.createRoleRelationship(param[0], param[2], param[1], newRelArr);
        //         } catch (ex) {
        //             console.log(ex.toString());
        //             // 回滚
        //             await this.transaction.rollback();
        //         }
        //     }
        //     return true;
        // }
    }
    return RptArchive;
};