Calculation/app/service/tender.js

'use strict';

/**
 * 标段数据模型
 *
 * @author CaiAoLin
 * @date 2017/11/30
 * @version
 */

const tenderConst = require('../const/tender');
const auditConst = require('../const/audit');
const projectLogConst = require('../const/project_log');
const fs = require('fs');
const path = require('path');
const commonQueryColumns = [
    'id', 'project_id', 'name', 'status', 'category', 'ledger_times', 'ledger_status', 'measure_type', 'user_id', 'valuation',
    'total_price', 'deal_tp', 'copy_id', 's2b_gxby_check', 's2b_gxby_limit', 's2b_dagl_check', 's2b_dagl_limit', 'has_rela', 'his_id',
];

module.exports = app => {

    class Tender extends app.BaseService {

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

            // 状态相关
            this.status = {
                TRY: 1,
                NORMAL: 2,
                DISABLE: 3,
            };
            this.displayStatus = [];
            this.displayStatus[this.status.TRY] = '试用';
            this.displayStatus[this.status.NORMAL] = '正常';
            this.displayStatus[this.status.DISABLE] = '禁用';

            this.statusClass = [];
            this.statusClass[this.status.TRY] = 'warning';
            this.statusClass[this.status.NORMAL] = 'success';
            this.statusClass[this.status.DISABLE] = 'danger';
        }

        /**
         * 数据规则
         *
         * @param {String} scene - 场景
         * @return {Object} - 返回数据规则
         */
        rule(scene) {
            let rule = {};
            switch (scene) {
                case 'add':
                    rule = {
                        name: { type: 'string', required: true, min: 2 },
                        type: { type: 'string', required: true, min: 1 },
                    };
                    break;
                case 'save':
                    rule = {
                        name: { type: 'string', required: true, min: 2 },
                        type: { type: 'string', required: true, min: 1 },
                    };
                default:
                    break;
            }

            return rule;
        }

        /**
         * 获取你所参与的标段的列表
         *
         * @param {String} listStatus - 取列表状态，如果是管理页要传
         * @param {String} permission - 根据权限取值
         * @param {Number} getAll - 是否取所有标段
         * @return {Array} - 返回标段数据
         */
        async getList(listStatus = '', permission = null, getAll = 0) {
            // 获取当前项目信息
            const session = this.ctx.session;
            let sql = '';
            let sqlParam = [];
            if (listStatus === 'manage') {
                // 管理页面只取属于自己创建的标段
                sql = 'SELECT t.`id`, t.`project_id`, t.`name`, t.`status`, t.`category`, t.`ledger_times`, t.`ledger_status`, t.`measure_type`, t.`user_id`, t.`create_time`, t.`total_price`, t.`deal_tp`,' +
                    '    pa.`name` As `user_name`, pa.`role` As `user_role`, pa.`company` As `user_company` ' +
                    '  FROM ?? As t ' +
                    '  Left Join ?? As pa ' +
                    '  ON t.`user_id` = pa.`id` ' +
                    '  WHERE t.`project_id` = ? AND t.`user_id` = ? ORDER BY CONVERT(t.`name` USING GBK) ASC';
                sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, session.sessionProject.id, session.sessionUser.accountId];
            } else if (getAll === 1 || (permission !== null && permission.tender !== undefined && permission.tender.indexOf('2') !== -1)) {
                // 具有查看所有标段权限的用户查阅标段
                sql = 'SELECT t.`id`, t.`project_id`, t.`name`, t.`status`, t.`category`, t.`ledger_times`, t.`ledger_status`, t.`measure_type`, t.`user_id`, t.`create_time`, t.`total_price`, t.`deal_tp`,' +
                    '    pa.`name` As `user_name`, pa.`role` As `user_role`, pa.`company` As `user_company` ' +
                    '  FROM ?? As t ' +
                    '  Left Join ?? As pa ' +
                    '  ON t.`user_id` = pa.`id` ' +
                    '  WHERE t.`project_id` = ? ORDER BY CONVERT(t.`name` USING GBK) ASC';
                sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, session.sessionProject.id];
            } else {
                // 根据用户权限查阅标段
                // tender 163条数据，project_account 68条数据测试
                // 查询两张表耗时0.003s，查询tender左连接project_account耗时0.002s
                const changeProjectSql = this.ctx.session.sessionProject.page_show.openChangeProject ? '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT cpa.`tid` FROM ' + this.ctx.service.changeProjectAudit.tableName + ' AS cpa WHERE cpa.`aid` = ' + session.sessionUser.accountId + ' GROUP BY cpa.`tid`))' : '';
                const changeApplySql = this.ctx.session.sessionProject.page_show.openChangeApply ? '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT caa.`tid` FROM ' + this.ctx.service.changeApplyAudit.tableName + ' AS caa WHERE caa.`aid` = ' + session.sessionUser.accountId + ' GROUP BY caa.`tid`))' : '';
                // 协审sql
                const changeProjectXsSql = this.ctx.session.sessionProject.page_show.openChangeProject ? '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT cpxa.`tid` FROM ' + this.ctx.service.changeProjectXsAudit.tableName + ' AS cpxa WHERE cpxa.`aid` = ' + session.sessionUser.accountId + ' GROUP BY cpxa.`tid`))' : '';
                sql = 'SELECT t.`id`, t.`project_id`, t.`name`, t.`status`, t.`category`, t.`ledger_times`, t.`ledger_status`, t.`measure_type`, t.`user_id`, t.`create_time`, t.`total_price`, t.`deal_tp`,' +
                    '    pa.`name` As `user_name`, pa.`role` As `user_role`, pa.`company` As `user_company` ' +
                    // '  FROM ?? As t, ?? As pa ' +
                    // '  WHERE t.`project_id` = ? AND t.`user_id` = pa.`id` AND (' +
                    '  FROM ?? As t ' +
                    '  Left Join ?? As pa ' +
                    '  ON t.`user_id` = pa.`id` ' +
                    '  WHERE t.`project_id` = ? AND (' +
                    // 创建的标段
                    '    t.`user_id` = ?' +
                    // 参与审批 台账 的标段
                    '    OR (t.`ledger_status` != ' + auditConst.ledger.status.uncheck + ' AND ' +
                    '        t.id IN ( SELECT la.`tender_id` FROM ?? As la WHERE la.`audit_id` = ? GROUP BY la.`tender_id`))' +
                    // 参与审批 计量期 的标段
                    '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT sa.`tid` FROM ?? As sa WHERE sa.`aid` = ? GROUP BY sa.`tid`))' +
                    // 参与审批 变更令 的标段
                    '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT ca.`tid` FROM ?? AS ca WHERE ca.`uid` = ? GROUP BY ca.`tid`))' +
                    // 参与审批 台账修订 的标段
                    '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT ra.`tender_id` FROM ?? AS ra WHERE ra.`audit_id` = ? GROUP BY ra.`tender_id`))' +
                    // 参与审批 材料调差 的标段
                    '    OR (t.`ledger_status` = ' + auditConst.ledger.status.checked + ' AND ' +
                    '        t.id IN ( SELECT ma.`tid` FROM ?? AS ma WHERE ma.`aid` = ? GROUP BY ma.`tid`))' +
                    // 参与审批 预付款 的标段
                    '    OR (t.id IN ( SELECT ad.`tid` FROM ?? AS ad WHERE ad.`audit_id` = ? GROUP BY ad.`tid`))' +
                    // 参与审批 变更立项书及变更申请 的标段
                    changeProjectSql + changeApplySql + changeProjectXsSql +
                    // 游客权限的标段
                    '    OR (t.id IN ( SELECT tt.`tid` FROM ?? AS tt WHERE tt.`user_id` = ?))' +
                    // 未参与，但可见的标段
                    ') ORDER BY CONVERT(t.`name` USING GBK) ASC';
                sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, session.sessionProject.id, session.sessionUser.accountId,
                    this.ctx.service.ledgerAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.stageAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.changeAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.reviseAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.materialAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.advanceAudit.tableName, session.sessionUser.accountId,
                    this.ctx.service.tenderTourist.tableName, session.sessionUser.accountId,
                ];
            }
            const list = await this.db.query(sql, sqlParam);
            for (const l of list) {
                l.category = l.category && l.category !== '' ? JSON.parse(l.category) : null;
            }

            return list;
        }

        async getList4Select(selectType) {
            const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
            const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
            const tenderList = await this.ctx.service.tender.getList('', userPermission);
            for (const t of tenderList) {
                if (t.ledger_status === auditConst.ledger.status.checked) {
                    t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
                    t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
                }
            }
            switch (selectType) {
                case 'ledger': return tenderList.filter(x => {
                    return x.ledger_status === auditConst.ledger.status.checked;
                });
                case 'revise': tenderList.filter(x => {
                    return x.ledger_status === auditConst.ledger.status.checked;
                });
                case 'stage': return tenderList.filter(x => {
                    return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
                });
                case 'stage-checked': return tenderList.filter(x => {
                    return !!x.completeStage;
                });
                default: return tenderList;
            }
        }

        async getTender(id) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('id', {
                value: id,
                operate: '=',
            });
            this.sqlBuilder.columns = commonQueryColumns;
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);

            const tender = await this.db.queryOne(sql, sqlParam);
            if (tender) {
                tender.category = tender.category && tender.category !== '' ? JSON.parse(tender.category) : null;
            }
            return tender;
        }

        /**
         * 新增标段
         *
         * @param {Object} data - 提交的数据
         * @return {Boolean} - 返回新增结果
         */
        async add(data) {
            let result = false;
            this.transaction = await this.db.beginTransaction();
            try {
                // 获取当前用户信息
                const sessionUser = this.ctx.session.sessionUser;
                // 获取当前项目信息
                const sessionProject = this.ctx.session.sessionProject;

                const insertData = {
                    name: data.name,
                    status: tenderConst.status.APPROVAL,
                    project_id: sessionProject.id,
                    user_id: sessionUser.accountId,
                    create_time: new Date(),
                    category: JSON.stringify(data.category),
                    valuation: data.valuation,
                };
                const operate = await this.transaction.insert(this.tableName, insertData);

                result = operate.insertId > 0;
                if (!result) {
                    throw '新增标段数据失败';
                }


                // 获取合同支付模板 并添加到标段
                result = await this.ctx.service.pay.addDefaultPayData(operate.insertId, this.transaction);
                if (!result) {
                    throw '新增合同支付数据失败';
                }
                await this.ctx.service.tenderTag.addTenderTag(operate.insertId, sessionProject.id, this.transaction);
                await this.transaction.commit();
                const sql = 'SELECT t.`id`, t.`project_id`, t.`name`, t.`status`, t.`category`, t.`ledger_times`, t.`ledger_status`, t.`measure_type`, t.`user_id`, t.`create_time`, t.`total_price`, t.`deal_tp`,' +
                    '    pa.`name` As `user_name`, pa.`role` As `user_role`, pa.`company` As `user_company` ' +
                    '  FROM ?? As t ' +
                    '  Left Join ?? As pa ' +
                    '  ON t.`user_id` = pa.`id` ' +
                    '  WHERE t.`id` = ?';
                const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, operate.insertId];
                const tender = await this.db.queryOne(sql, sqlParam);
                if (tender) {
                    tender.category = tender.category && tender.category !== '' ? JSON.parse(tender.category) : null;
                }

                // 是否加入到决策大屏中
                if (sessionProject.page_show.addDataCollect === 0) {
                    await this.ctx.service.datacollectTender.add(sessionProject.id, operate.insertId);
                }
                return tender;
            } catch (error) {
                await this.transaction.rollback();
                throw error;
            }
        }

        /**
         * 保存标段
         *
         * @param {Object} postData - 表单post过来的数据
         * @param {Number} id - 用于判断修改还是新增的id
         * @return {Boolean} - 返回执行结果
         */
        async save(postData, id = 0) {
            id = parseInt(id);

            const rowData = {
                id,
                name: postData.name,
                type: postData.type,
                category: JSON.stringify(postData.category),
            };
            const result = await this.db.update(this.tableName, rowData);
            return result.affectedRows > 0;
        }

        /**
         * 假删除
         *
         * @param {Number} id - 删除的id
         * @return {Boolean} - 删除结果
         */
        async deleteTenderById(id) {
            const updateData = {
                status: this.status.DISABLE,
                id,
            };
            const result = await this.db.update(this.tableName, updateData);

            return result.affectedRows > 0;
        }

        /**
         * 真删除
         * @param {Number} id - 删除的标段id
         * @return {Promise<boolean>} - 结果
         */
        async deleteTenderNoBackup(id) {
            const transaction = await this.db.beginTransaction();
            try {
                const tenderMsg = await this.getDataById(id);
                // 先删除附件文件
                const attList = await this.ctx.service.changeAtt.getAllDataByCondition({ where: { tid: id } });
                const newAttList = await this.ctx.service.materialFile.getAllMaterialFiles(id);
                attList.concat(newAttList);
                await this.ctx.helper.delFiles(attList);
                await transaction.delete(this.tableName, { id });
                await transaction.delete(this.ctx.service.tenderInfo.tableName, { tid: id });
                await transaction.delete(this.ctx.service.ledger.departTableName(id), { tender_id: id });
                await transaction.delete(this.ctx.service.ledgerAudit.tableName, { tender_id: id });
                await transaction.delete(this.ctx.service.pos.departTableName(id), { tid: id });
                await transaction.delete(this.ctx.service.pay.tableName, { tid: id });

                await transaction.delete(this.ctx.service.stage.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageAudit.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageBills.departTableName(id), { tid: id });
                await transaction.delete(this.ctx.service.stagePos.departTableName(id), { tid: id });
                await transaction.delete(this.ctx.service.stageBillsDgn.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageBillsFinal.departTableName(id), { tid: id });
                await transaction.delete(this.ctx.service.stagePosFinal.departTableName(id), { tid: id });
                await transaction.delete(this.ctx.service.stageDetail.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stagePay.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageChange.tableName, { tid: id });

                await transaction.delete(this.ctx.service.stageJgcl.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageBonus.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageOther.tableName, { tid: id });

                await transaction.delete(this.ctx.service.stageRela.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageRelaBills.tableName, { tid: id });
                await transaction.delete(this.ctx.service.stageRelaBillsFinal.tableName, { tid: id });

                await transaction.delete(this.ctx.service.change.tableName, { tid: id });
                await transaction.delete(this.ctx.service.changeAudit.tableName, { tid: id });
                await transaction.delete(this.ctx.service.changeAuditList.tableName, { tid: id });
                await transaction.delete(this.ctx.service.changeCompany.tableName, { tid: id });

                await transaction.delete(this.ctx.service.ledgerRevise.tableName, { tid: id });
                await transaction.delete(this.ctx.service.reviseAudit.tableName, { tender_id: id });
                await transaction.delete(this.ctx.service.reviseBills.departTableName(id), { tender_id: id });
                await transaction.delete(this.ctx.service.revisePos.departTableName(id), { tid: id });

                await transaction.delete(this.ctx.service.material.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialAudit.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialBills.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialBillsHistory.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialList.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialListNotjoin.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialExponent.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialExponentHistory.tableName, { tid: id });


                await transaction.delete(this.ctx.service.materialFile.tableName, { tid: id });
                await transaction.delete(this.ctx.service.signatureUsed.tableName, { tender_id: id });
                await transaction.delete(this.ctx.service.signatureRole.tableName, { tender_id: id });

                await transaction.delete(this.ctx.service.changeAtt.tableName, { tid: id });
                await transaction.delete(this.ctx.service.materialFile.tableName, { tid: id });

                await transaction.delete(this.ctx.service.advanceFile.tableName, { tid: id });

                await transaction.delete(this.ctx.service.datacollectTender.tableName, { pid: this.ctx.session.sessionProject.id, tid: id });

                // 记录删除日志
                await this.ctx.service.projectLog.addProjectLog(transaction, projectLogConst.type.tender, projectLogConst.status.delete, tenderMsg.name, id);
                await transaction.commit();
                return true;
            } catch (err) {
                this.ctx.helper.log(err);
                await transaction.rollback();
                return false;
            }
        }

        async getCheckTender(tid) {
            const tender = await this.ctx.service.tender.getTender(tid);
            tender.info = await this.ctx.service.tenderInfo.getTenderInfo(tid);
            return tender;
        }

        async checkTender(tid) {
            if (this.ctx.tender) return;
            this.ctx.tender = await this.getCheckTender(tid);
        }

        async setTenderType(tender, type) {
            const templateId = await this.ctx.service.valuation.getValuationTemplate(tender.valuation, type);
            if (templateId === -1) throw '该模式下，台账模板不存在';

            // 获取标段项目节点模板
            const tenderNodeTemplateData = await this.ctx.service.tenderNodeTemplate.getData(templateId);
            const conn = await this.db.beginTransaction();
            try {
                await conn.update(this.tableName, { id: tender.id, measure_type: type });

                // 复制模板数据到标段数据表
                const result = await this.ctx.service.ledger.innerAdd(tenderNodeTemplateData, tender.id, conn);
                if (!result) {
                    throw '初始化台账失败';
                }
                await conn.commit();
            } catch (err) {
                await conn.rollback();
                throw err;
            }
        }

        async saveApiRela(tid, updateData) {
            await this.db.update(this.tableName, updateData, {where: { id: tid } });
        }

        async saveTenderData(tid, updateData) {
            return await this.db.update(this.tableName, updateData, { where: { id: tid } });
        }
    }

    return Tender;
};