Calculation/app/service/role_rpt_rel.js

'use strict';

/**
 * Created by Tony on 2019/9/26.
 */

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

module.exports = app => {

    class RoleRptRel extends BaseService {

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

        async getRoleRptRelById(id) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('id', {
                value: id,
                operate: '=',
            });
            this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'rel_content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const list = await this.db.query(sql, sqlParam);
            return list;
        }

        async getRoleRptRelByTenderId(tenderId, stageId) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('tender_id', {
                value: tenderId,
                operate: '=',
            });
            if (stageId) {
                this.sqlBuilder.setAndWhere('sid', {
                    value: stageId,
                    operate: '=',
                });
            }
            this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'sid', 'rel_content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const list = await this.db.query(sql, sqlParam);
            // console.log(list);
            return list;
        }

        async getRoleRptRelByDetailIds(tenderId, rptId, sid) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('tender_id', {
                value: tenderId,
                operate: '=',
            });
            if (rptId instanceof Array) {
                this.sqlBuilder.setAndWhere('rpt_id', {
                    value: rptId,
                    operate: 'in',
                });
            } else {
                this.sqlBuilder.setAndWhere('rpt_id', {
                    value: rptId,
                    operate: '=',
                });
            }
            this.sqlBuilder.setAndWhere('sid', {
                value: sid,
                operate: '=',
            });
            this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'sid', 'rel_content'];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const list = await this.db.query(sql, sqlParam);
            // console.log(list);
            return list;
        }

        async createRoleRelationship(tender_id, rpt_id, sid, relArr) {
            let rst = null;
            this.transaction = await this.db.beginTransaction();
            try {
                const data = {
                    tender_id: tender_id,
                    rpt_id: rpt_id,
                    sid: sid,
                    rel_content: JSON.stringify(relArr),
                };
                rst = await this.transaction.insert(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 = this.createRoleRelationship(tender_id, rpt_id, sid, relArr);
            } else {
                this.transaction = await this.db.beginTransaction();
                try {
                    const data = { id: id, tender_id: tender_id, rpt_id: rpt_id, sid: sid, rel_content: JSON.stringify(relArr) };
                    rst = await this.transaction.update(this.tableName, data);
                    this.transaction.commit();
                } catch (ex) {
                    console.log(ex);
                    // 回滚
                    await this.transaction.rollback();
                }
            }
            return rst;
        }
    }
    return RoleRptRel;
};