Calculation/app/controller/change_controller.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2018/8/14
 * @version
 */

const moment = require('moment');
const sendToWormhole = require('stream-wormhole');
const fs = require('fs');
const path = require('path');
const audit = require('../const/audit');
const codeRuleConst = require('../const/code_rule');
const changeConst = require('../const/change');
const accountGroup = require('../const/account_group').group;
const shenpiConst = require('../const/shenpi');
// const tenderMenu = require('../../config/menu').tenderMenu;

module.exports = app => {
    class ChangeController extends app.BaseController {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            ctx.showProject = true;
            ctx.showTender = true;
            ctx.showTitle = true;
        }

        async _filterChanges(ctx, status = 0) {
            const tenderId = ctx.params.id;
            ctx.session.sessionUser.tenderId = tenderId;
            const tender = await this.service.tender.getDataById(tenderId);
            // const tenderList = await this.service.tender.getList();

            const page = ctx.page;
            const sorts = ctx.query.sort ? ctx.query.sort : 0;
            const orders = ctx.query.order ? ctx.query.order : 0;
            const changes = await ctx.service.change.getListByStatus(tender.id, status, 1, sorts, orders);
            const total = await ctx.service.change.getCountByStatus(tender.id, status);
            if (changes !== null) {
                let i = 0;
                for (const c of changes) {
                    const status = c.status === audit.flow.status.uncheck ? 0 : 1;
                    // 根据审批人对当前变更令的状态取不同的展示方式。
                    let changeAudit = '';
                    let auditStatus = 0;
                    switch (c.status) {
                        case 1:
                            auditStatus = 1;
                            break;
                        case 2:
                            changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
                            auditStatus = changeAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
                            break;
                        case 3:
                        case 4:
                            auditStatus = 0;
                            changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
                            break;
                        case 5:
                            changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times - 1, status);
                            auditStatus = c.uid === ctx.session.sessionUser.accountId ? 1 : 0;
                            const back_changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, c.cid);
                            c.stageChangeNum = this.ctx.helper.sum(back_changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                            break;
                        case 6:
                            changeAudit = await ctx.service.changeAudit.getLastBackUser(c.cid, c.times);
                            const checkingAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
                            auditStatus = checkingAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
                            break;
                        case 9:
                            auditStatus = 9;
                            const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, c.cid);
                            c.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                            break;
                        default:
                            break;
                    }
                    changes[i].changeAudit = changeAudit;
                    changes[i].auditStatus = auditStatus;
                    i++;
                }
            }

            // 分页相关
            const pageInfo = {
                page,
                total: Math.ceil(total / app.config.pageSize),
                queryData: JSON.stringify(ctx.urlInfo.query),
            };

            const filter = JSON.parse(JSON.stringify(audit.filter));
            filter.count = [];
            filter.count[filter.status.pending] = await ctx.service.change.getCountByStatus(tender.id, filter.status.pending);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.uncheck] = await ctx.service.change.getCountByStatus(tender.id, filter.status.uncheck);// await ctx.service.change.checkingDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.checking] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checking);// await ctx.service.change.checkedDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.checked] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checked);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.checkNo] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checkNo);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);

            const codeRule = tender.c_rule ? JSON.parse(tender.c_rule) : [];
            for (const rule of codeRule) {
                switch (rule.rule_type) {
                    case codeRuleConst.measure.ruleType.dealCode:
                        rule.preview = ctx.tender.info.deal_info.dealCode;
                        break;
                    case codeRuleConst.measure.ruleType.tenderName:
                        rule.preview = tender.name;
                        break;
                    case codeRuleConst.measure.ruleType.inDate:
                        rule.preview = moment().format('YYYY');
                        break;
                    case codeRuleConst.measure.ruleType.text:
                        rule.preview = rule.text;
                        break;
                    case codeRuleConst.measure.ruleType.addNo:
                        const s = '0000000000';
                        rule.preview = s.substr(s.length - rule.format);
                        break;
                    default: break;
                }
            }

            const renderData = {
                uid: ctx.session.sessionUser.accountId,
                moment,
                tender,
                // tenderList,
                pageInfo,
                changes,
                filter,
                status,
                codeRule,
                dealCode: ctx.tender.info.deal_info.dealCode,
                auditConst: audit.flow,
                changeConst,
                ruleType: codeRuleConst.ruleType.change,
                ruleConst: codeRuleConst.measure,
                tenderMenu: this.menu.tenderMenu,
                preUrl: '/tender/' + tenderId,
                tpUnit: ctx.tender.info.decimal.tp,
            };
            await this.layout('change/index.ejs', renderData, 'change/modal.ejs');
        }

        /**
         * 变更管理 页面 (Get)
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async index(ctx) {
            try {
                await this._filterChanges(ctx);
            } catch (err) {
                this.log(err);
                ctx.redirect('/dashboard');
            }
        }

        /**
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async newCode(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {
                const tenderId = ctx.params.id;
                if (!tenderId) {
                    throw '当前未打开标段';
                }
                const tenderData = await ctx.service.tender.getDataById(tenderId);
                const cCodeRule = tenderData.c_rule !== null ? JSON.parse(tenderData.c_rule) : [];

                const code = [];
                for (const rule of cCodeRule) {
                    switch (rule.rule_type) {
                        case codeRuleConst.measure.ruleType.dealCode:
                            code.push(ctx.tender.info.deal_info.dealCode);
                            break;
                        case codeRuleConst.measure.ruleType.tenderName:
                            code.push(tenderData.name);
                            break;
                        case codeRuleConst.measure.ruleType.text:
                            code.push(rule.text);
                            break;
                        case codeRuleConst.measure.ruleType.inDate:
                            code.push(moment().format('YYYY'));
                            break;
                        case codeRuleConst.measure.ruleType.addNo:
                            let s = '0000000000';
                            const count = rule.start + await ctx.service.change.count({ tid: tenderId });
                            s = s + count;
                            code.push(s.substr(s.length - rule.format));
                            break;
                        default: break;
                    }
                }
                responseData.data = code.join(tenderData.c_connector !== null && tenderData.c_connector !== 3 ? codeRuleConst.measure.connectorString[tenderData.c_connector] : '');
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 新增变更 (Post)
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async add(ctx) {
            try {
                const tenderId = ctx.params.id;
                if (!tenderId) {
                    throw '当前未打开标段';
                }
                const data = JSON.parse(ctx.request.body.data);
                if (!data.code || data.code === '' || !data.name || data.name === '') {
                    throw '变更令号不能为空';
                }

                const change = await ctx.service.change.add(tenderId, ctx.session.sessionUser.accountId, data.code, data.name);

                ctx.body = { err: 0, msg: '', data: change };
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString() };
            }
        }

        /**
         * 变更管理 状态筛选 页面 (Get)
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async status(ctx) {
            try {
                const status = parseInt(ctx.params.status);
                await this._filterChanges(ctx, status);
            } catch (err) {
                this.logger.error(err);
                ctx.redirect('/tender/' + ctx.params.id + '/change');
            }
        }

        /**
         * 变更信息 页面 (Get)
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async info(ctx) {
            try {
                const whiteList = this.ctx.app.config.multipart.whitelist;
                const tenderid = ctx.params.id !== undefined ? ctx.params.id : ctx.session.sessionUser.tenderId;
                ctx.session.sessionUser.tenderId = tenderid;
                const tender = await ctx.service.tender.getDataById(tenderid);
                const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });

                // 后台判断当前人查看info状态
                const auditStatus = await ctx.service.changeAudit.getStatusByChange(change);

                // 获取附件列表
                const attList = await ctx.service.changeAtt.getChangeAttachment(ctx.params.cid);

                // 获取其他变更令数据
                const othersChange = await ctx.service.change.getOthersChange(ctx.params.id, ctx.params.cid);

                // 根据auditStatus获取审批人列表
                const auditList = await ctx.service.changeAudit.getListByStatus(change, auditStatus);
                // 获取已选清单
                let changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.params.cid } });

                // 获取用户人验证手机号
                const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                const auth_mobile = pa.auth_mobile;
                const renderData = {
                    uid: ctx.session.sessionUser.accountId,
                    tender,
                    change,
                    othersChange,
                    changeConst,
                    auditStatus,
                    auditConst: audit.flow,
                    ledgerConsts: audit.ledger.status,
                    attList,
                    whiteList,
                    auditList,
                    changeList,
                    tpUnit: change.tp_decimal ? change.tp_decimal : ctx.tender.info.decimal.tp,
                    upUnit: ctx.tender.info.decimal.up,
                    authMobile: auth_mobile,
                    shenpiConst,
                };
                // 根据auditStatus状态获取的不同的数据
                if (auditStatus === 1 || auditStatus === 2 || auditStatus === 9) {
                    renderData.changeUnits = changeConst.units;
                    renderData.precision = ctx.tender.info.precision;
                    // renderData.accountGroup = accountGroup;
                    // 获取所有项目参与者
                    const accountList = await ctx.service.projectAccount.getAllDataByCondition({
                        where: { project_id: ctx.session.sessionProject.id, enable: 1 },
                        columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
                    });
                    renderData.accountList = accountList;
                    renderData.accountGroup = accountGroup.map((item, idx) => {
                        const groupList = accountList.filter(item => item.account_group === idx);
                        return { groupName: item, groupList };
                    });
                    // 重新上报获取审批流程
                    if (auditStatus === 2 || auditStatus === 9) {
                        const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
                        // 展示页右侧审批流程列表
                        const auditList3 = [];
                        for (let time = 1; time <= change.times - 1; time++) {
                            const auditTimeList = [];
                            let max_sort = 1;
                            for (const al of auditList2) {
                                if (al.times === time) {
                                    auditTimeList.push(al);
                                    if (al.usite > max_sort) {
                                        max_sort = al.usite;
                                    }
                                }
                            }
                            for (const i in auditTimeList) {
                                auditTimeList[i].max_sort = max_sort;
                            }
                            auditList3.push(auditTimeList);
                        }
                        renderData.auditList3 = auditList3;
                    }

                    // 根据清单获取提交数据和计算总金额
                    const changeListData = [];
                    const changeWhiteListData = [];
                    let ototalCost = 0;
                    let ctotalCost = 0;
                    for (const cl of changeList) {
                        const cLArray = [
                            cl.code,
                            cl.name,
                            cl.bwmx,
                            cl.unit,
                            cl.unit_price,
                            cl.oamount,
                            cl.camount,
                            cl.detail,
                            cl.lid,
                            cl.xmj_code,
                            cl.xmj_jldy,
                            cl.gcl_id,
                        ];
                        ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, ctx.tender.info.decimal.tp);
                        ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, ctx.tender.info.decimal.tp);
                        if (cl.lid !== '0') {
                            changeListData.push(cLArray.join('*;*'));
                        } else {
                            changeWhiteListData.push(cLArray.join('*;*'));
                        }
                    }
                    renderData.changeListData = changeListData.join('^_^');
                    renderData.changeWhiteListData = changeWhiteListData.join('^_^');
                    renderData.ototalCost = ototalCost;
                    renderData.ctotalCost = ctotalCost;

                    // 获取公司列表
                    const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: tenderid } });
                    renderData.companyList = companyList;
                } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7) {
                    // 展示页左侧审批流程列表和清单审批列表数据
                    const times = change.status === audit.flow.status.back ?
                        change.times - 1 : change.times;
                    const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);

                    // 展示页右侧审批流程列表
                    const auditList3 = [];
                    for (let time = 1; time <= times; time++) {
                        const auditTimeList = [];
                        let max_sort = 1;
                        for (const al of auditList) {
                            if (al.times === time) {
                                auditTimeList.push(al);
                                if (al.usite > max_sort) {
                                    max_sort = al.usite;
                                }
                            }
                        }
                        for (const i in auditTimeList) {
                            auditTimeList[i].max_sort = max_sort;
                        }
                        auditList3.push(auditTimeList);
                    }
                    renderData.auditList3 = auditList3;

                    changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
                    renderData.changeList = changeList;
                    let ototalCost = 0;
                    let ctotalCost = 0;
                    let stotalCost = 0;
                    const auditTotalCost = [];
                    for (const cl of changeList) {
                        // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
                        ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
                        // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
                        ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
                        // stotalCost += cl.samount !== '' && cl.unit_price !== null ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.samount), renderData.tpUnit)) : 0;
                        stotalCost += cl.samount !== '' && cl.unit_price !== null ? ctx.helper.mul(cl.unit_price, cl.samount, renderData.tpUnit) : 0;
                        const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
                        auditTotalCost.push(audit_amount);
                    }
                    renderData.ototalCost = ototalCost;
                    renderData.ctotalCost = ctotalCost;
                    renderData.stotalCost = stotalCost;

                    // 清单表页赋值
                    for (const [index, au] of auditList2.entries()) {
                        if (au.usite !== 0) {
                            au.list_amount = [];
                            au.totalCost = 0;
                            for (const [auindex, at] of auditTotalCost.entries()) {
                                au.list_amount.push(at[index - 1]);
                                // au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 1]), renderData.tpUnit)) : 0;
                                au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
                            }
                        }
                    }
                    renderData.auditList2 = auditList2;
                } else if (auditStatus === 6) {
                    // 展示页左侧审批流程列表和清单审批列表数据
                    const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
                    renderData.auditList2 = auditList2;
                    const auditList3 = await ctx.service.changeAudit.getListOrderByTimes(change.cid, change.times);
                    for (const i in auditList3) {
                        auditList3[i].max_sort = auditList2.length - 1;
                    }
                    renderData.auditList3 = auditList3;

                    // 展示页右侧审批流程列表
                    const auditList5 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
                    const auditList4 = [];
                    for (let time = 1; time <= change.times; time++) {
                        const auditTimeList = [];
                        let max_sort = 1;
                        for (const al of auditList5) {
                            if (al.times === time) {
                                auditTimeList.push(al);
                                if (al.usite > max_sort) {
                                    max_sort = al.usite;
                                }
                            }
                        }
                        for (const i in auditTimeList) {
                            auditTimeList[i].max_sort = max_sort;
                        }
                        if (auditTimeList.length > 0) {
                            auditList4.push(auditTimeList);
                        }
                    }
                    renderData.auditList4 = auditList4;

                    changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
                    renderData.changeList = changeList;
                    let ototalCost = 0;
                    let ctotalCost = 0;
                    const auditTotalCost = [];
                    const auditUnit = [];
                    for (const cl of changeList) {
                        // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
                        ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
                        // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
                        ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
                        const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
                        auditTotalCost.push(audit_amount);
                    }
                    renderData.ototalCost = ototalCost;
                    renderData.ctotalCost = ctotalCost;

                    // 清单表页赋值
                    for (const [index, au] of auditList.entries()) {
                        if (au.usite !== 0) {
                            au.list_amount = [];
                            au.totalCost = 0;
                            if (au.uid === renderData.uid) {
                                for (const [auindex, at] of auditTotalCost.entries()) {
                                    // if (at[index - 2] !== undefined) {
                                    //     au.list_amount.push(at[index - 2]);
                                    //     au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 2]), renderData.tpUnit));
                                    // } else if (at[index - 2] === undefined) {
                                    //     au.list_amount.push(changeList[auindex].camount);
                                    //     au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].camount), renderData.tpUnit));
                                    // }
                                    au.list_amount.push(changeList[auindex].spamount);
                                    // au.totalCost += changeList[auindex].unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].spamount), renderData.tpUnit));
                                    au.totalCost += changeList[auindex].unit_price === null ? 0 : ctx.helper.mul(changeList[auindex].unit_price, changeList[auindex].spamount, renderData.tpUnit);
                                }
                            } else {
                                for (const [auindex, at] of auditTotalCost.entries()) {
                                    au.list_amount.push(at[index - 1]);
                                    // au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 1]), renderData.tpUnit)) : 0;
                                    au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
                                }
                            }
                        }
                    }
                }
                renderData.auditList = auditList;

                // 获取是否已存在调用变更令
                const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, change.cid);
                renderData.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                await this.layout('change/info.ejs', renderData, 'change/info_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect('/tender/' + ctx.params.id + '/change');
            }
        }

        /**
         * 变更信息 新版本页面 (Get)
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async information(ctx) {
            try {
                const whiteList = this.ctx.app.config.multipart.whitelist;
                const tender = await ctx.service.tender.getDataById(ctx.tender.id);
                const change = ctx.change;
                // 后台判断当前人查看info状态
                const auditStatus = await ctx.service.changeAudit.getStatusByChange(change);

                // 获取附件列表
                const attList = await ctx.service.changeAtt.getChangeAttachment(change.cid, 'desc');

                // 获取其他变更令数据
                const othersChange = await ctx.service.change.getOthersChange(ctx.tender.id, change.cid);

                // 根据auditStatus获取审批人列表
                const auditList = await ctx.service.changeAudit.getListByStatus(change, auditStatus);

                // 获取用户人验证手机号
                const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                const auth_mobile = pa.auth_mobile;
                const renderData = {
                    tender,
                    change,
                    othersChange,
                    changeConst,
                    auditStatus,
                    auditConst: audit.flow,
                    ledgerConsts: audit.ledger.status,
                    attList,
                    whiteList,
                    auditList,
                    tpUnit: change.tp_decimal ? change.tp_decimal : ctx.tender.info.decimal.tp,
                    upUnit: ctx.tender.info.decimal.up,
                    authMobile: auth_mobile,
                    shenpiConst,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.change.information),
                    preUrl: '/tender/' + ctx.tender.id + '/change/' + ctx.change.cid + '/information',
                    precision: ctx.tender.info.precision,
                };
                // 根据auditStatus状态获取的不同的数据
                if (auditStatus === 1 || auditStatus === 2 || auditStatus === 9) {
                    renderData.changeUnits = changeConst.units;
                    // renderData.accountGroup = accountGroup;
                    // 获取所有项目参与者
                    const accountList = await ctx.service.projectAccount.getAllDataByCondition({
                        where: { project_id: ctx.session.sessionProject.id, enable: 1 },
                        columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
                    });
                    renderData.accountList = accountList;
                    renderData.accountGroup = accountGroup.map((item, idx) => {
                        const groupList = accountList.filter(item => item.account_group === idx);
                        return { groupName: item, groupList };
                    });
                    // 重新上报获取审批流程
                    if (auditStatus === 2 || auditStatus === 9) {
                        const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
                        // 展示页右侧审批流程列表
                        const auditList3 = [];
                        for (let time = 1; time <= change.times - 1; time++) {
                            const auditTimeList = [];
                            let max_sort = 1;
                            for (const al of auditList2) {
                                if (al.times === time) {
                                    auditTimeList.push(al);
                                    if (al.usite > max_sort) {
                                        max_sort = al.usite;
                                    }
                                }
                            }
                            for (const i in auditTimeList) {
                                auditTimeList[i].max_sort = max_sort;
                            }
                            auditList3.push(auditTimeList);
                        }
                        renderData.auditList3 = auditList3;
                    }

                    // 获取公司列表
                    const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: ctx.tender.id } });
                    renderData.companyList = companyList;
                    // 获取已选清单
                    const changeList = await ctx.service.changeAuditList.getList(change.cid);
                    renderData.changeList = changeList;
                } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7 || auditStatus === 8) {
                    // 展示页左侧审批流程列表和清单审批列表数据
                    const times = change.status === audit.flow.status.back ?
                        change.times - 1 : change.times;
                    const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);

                    // 展示页右侧审批流程列表
                    const auditList3 = [];
                    for (let time = 1; time <= times; time++) {
                        const auditTimeList = [];
                        let max_sort = 1;
                        for (const al of auditList) {
                            if (al.times === time) {
                                auditTimeList.push(al);
                                if (al.usite > max_sort) {
                                    max_sort = al.usite;
                                }
                            }
                        }
                        for (const i in auditTimeList) {
                            auditTimeList[i].max_sort = max_sort;
                        }
                        auditList3.push(auditTimeList);
                    }
                    renderData.auditList3 = auditList3;

                    // 获取已选清单
                    // let changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.params.cid } });
                    const changeList = await ctx.service.changeAuditList.getList(change.cid);

                    // changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
                    for (const cl of changeList) {
                        const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
                        // 清单表页赋值
                        for (const [index, au] of auditList2.entries()) {
                            if (au.usite !== 0) {
                                cl['audit_amount_' + au.uid] = audit_amount[index - 1] ? audit_amount[index - 1] : null;
                            }
                        }
                    }
                    renderData.changeList = changeList;
                    renderData.auditList2 = auditList2;
                } else if (auditStatus === 6) {
                    // 展示页左侧审批流程列表和清单审批列表数据
                    const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
                    renderData.auditList2 = auditList2;
                    const auditList3 = await ctx.service.changeAudit.getListOrderByTimes(change.cid, change.times);
                    for (const i in auditList3) {
                        auditList3[i].max_sort = auditList2.length - 1;
                    }
                    renderData.auditList3 = auditList3;

                    // 展示页右侧审批流程列表
                    const auditList5 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
                    const auditList4 = [];
                    for (let time = 1; time <= change.times; time++) {
                        const auditTimeList = [];
                        let max_sort = 1;
                        for (const al of auditList5) {
                            if (al.times === time) {
                                auditTimeList.push(al);
                                if (al.usite > max_sort) {
                                    max_sort = al.usite;
                                }
                            }
                        }
                        for (const i in auditTimeList) {
                            auditTimeList[i].max_sort = max_sort;
                        }
                        if (auditTimeList.length > 0) {
                            auditList4.push(auditTimeList);
                        }
                    }
                    renderData.auditList4 = auditList4;

                    // 获取已选清单
                    // let changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.params.cid } });
                    const changeList = await ctx.service.changeAuditList.getList(change.cid);

                    // changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
                    for (const cl of changeList) {
                        const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
                        // 清单表页赋值
                        for (const [index, au] of auditList2.entries()) {
                            if (au.usite !== 0) {
                                cl['audit_amount_' + au.uid] = au.uid === ctx.session.sessionUser.accountId ? cl.spamount : (audit_amount[index - 1] ? audit_amount[index - 1] : null);
                            }
                        }
                    }
                    renderData.changeList = changeList;
                }
                renderData.auditList = auditList;

                // 获取是否已存在调用变更令
                const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, change.cid);
                renderData.changeUsedData = changeUsedData;
                renderData.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                await this.layout('change/information.ejs', renderData, 'change/information_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect('/tender/' + ctx.params.id + '/change');
            }
        }

        /**
         * 变更清单 - 操作 (Ajax)
         * @param ctx
         * @return {Promise<void>}
         */
        async saveListsData(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const responseData = {
                    err: 0,
                    msg: '',
                    data: {},
                };
                switch (data.type) {
                    case 'add':
                        responseData.data = await ctx.service.changeAuditList.add(data.postData);
                        break;
                    case 'batchadd':
                        responseData.data = await ctx.service.changeAuditList.batchAdd(data);
                        break;
                    case 'del':
                        await ctx.service.changeAuditList.del(data.id);
                        break;
                    case 'update':
                        await ctx.service.changeAuditList.save(data.updateData);
                        break;
                    case 'paste':
                        await ctx.service.changeAuditList.saveDatas(data.updateData);
                        // 取所有工料表
                        responseData.data = await ctx.service.changeAuditList.getList(ctx.change.cid);
                        break;
                    case 'ledger_list':
                        await ctx.service.changeAuditList.saveLedgerListDatas(data.updateData);
                        // 取所有工料表
                        responseData.data = { changeList: await ctx.service.changeAuditList.getList(ctx.change.cid),
                            usedList: await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, ctx.change.cid) };
                        break;
                    case 'remove_list':
                        await ctx.service.changeAuditList.removeLedgerListDatas(data.updateData);
                        // 取所有工料表
                        responseData.data = await ctx.service.changeAuditList.getList(ctx.change.cid);
                        break;
                    case 'info':
                        await ctx.service.change.saveInfo(data.updateData);
                        // 取所有工料表
                        responseData.data = '保存成功';
                        break;
                    case 'paste_amount_rows':
                        await ctx.service.changeAuditList.saveDatas(data.updateData);
                        let changeList = await ctx.service.changeAuditList.getList(ctx.change.cid);
                        const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(ctx.change.cid, ctx.change.times);
                        changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
                        for (const cl of changeList) {
                            const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
                            // 清单表页赋值
                            for (const [index, au] of auditList2.entries()) {
                                if (au.usite !== 0) {
                                    cl['audit_amount_' + au.uid] = au.uid === ctx.session.sessionUser.accountId ? cl.spamount : (audit_amount[index - 1] ? audit_amount[index - 1] : null);
                                }
                            }
                        }
                        // 取所有工料表
                        responseData.data = changeList;
                        break;
                    default: throw '参数有误';
                }

                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 上报和重新上报
         * @param ctx
         * @return {Promise<void>}
         */
        async startAudit(ctx) {
            try {
                // 检查权限等
                if (!ctx.change) {
                    throw '数据错误';
                }
                if (ctx.change.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权上报该变更令数据';
                }
                if (!(ctx.change.status === audit.flow.status.uncheck || ctx.change.status === audit.flow.status.back || ctx.change.status === audit.flow.status.revise)) {
                    throw '该变更令当前无法上报';
                }
                // 判断是否是修订，判断有无审批人员作弊
                if (ctx.change.status === audit.flow.status.revise && ctx.tender.info.shenpi.change === shenpiConst.sp_status.sqspr) {
                    // 获取上一次的审批人流程
                    const lastUserList = await ctx.service.changeAudit.getListGroupByTimes(ctx.change.cid, ctx.change.times - 1);
                    const lastUidList = ctx.helper._.map(lastUserList, 'uid');
                    // 判断上一次审批是否为非原报为审批人
                    const nowUidList = ctx.helper._.map(ctx.change.auditors, 'uid');
                    // 上一次审批人列表包含原报且不止只有原报并且新的审批人只有原报审批时
                    if (!ctx.helper._.isEqual(lastUidList, nowUidList) && ctx.helper._.includes(ctx.helper._.tail(lastUidList), lastUidList[0]) && nowUidList.length === 2 && nowUidList[0] === nowUidList[1]) {
                        throw '该变更令不能指定原报人为单独审批人';
                    }
                }
                await ctx.service.changeAudit.start(ctx.change.cid, ctx.change.times);
                ctx.redirect(ctx.request.header.referer);
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(ctx.request.header.referer);
            }
        }

        // 审批相关
        /**
         * 添加审批人
         * @param ctx
         * @return {Promise<void>}
         */
        async addAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const id = this.app._.toInteger(data.auditorId);
                if (isNaN(id) || id <= 0) {
                    throw '参数错误';
                }
                // 检查权限等
                if (ctx.change.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权添加审核人';
                }
                if (ctx.change.status === audit.flow.status.checking || ctx.change.status === audit.flow.status.checked) {
                    throw '当前不允许添加审核人';
                }

                const auditorList = await ctx.service.changeAudit.getAuditors(ctx.change.cid, ctx.change.times);
                // 检查审核人是否已存在
                const exist = this.app._.find(auditorList, { uid: id });
                if (exist) {
                    throw '该审核人已存在，请勿重复添加';
                }
                const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.change, sp_status: shenpiConst.sp_status.gdzs });
                const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.change === shenpiConst.sp_status.gdzs ? 1 : 0;
                const result = await ctx.service.changeAudit.addAuditor(ctx.change.cid, id, ctx.change.times, is_gdzs);
                if (!result) {
                    throw '添加审核人失败';
                }

                // const auditors = await ctx.service.changeAudit.getAuditorsWithOwner(ctx.change.id, ctx.change.times);
                const auditors = null;
                ctx.body = { err: 0, msg: '', data: auditors };
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }
        /**
         * 移除审批人
         * @param ctx
         * @return {Promise<void>}
         */
        async deleteAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
                if (isNaN(id) || id <= 0) {
                    throw '参数错误';
                }

                const result = await ctx.service.changeAudit.deleteAuditor(ctx.change.cid, id, ctx.change.times);
                if (!result) {
                    throw '移除审核人失败';
                }

                const auditors = null;
                ctx.body = { err: 0, msg: '', data: auditors };
            } catch (err) {
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async defaultBills(ctx) {
            try {
                const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
                const posData = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
                const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
                ctx.body = { err: 0, msg: '', data: { bills: ledgerData, pos: posData, dealBills } };
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: [] };
            }
        }

        /**
         * 变更令上报和保存
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async save(ctx) {
            // 变更令信息
            const changeInfo = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
            try {
                const result = await ctx.service.change.save(ctx.request.body, changeInfo.tid);
                if (!result) {
                    throw '上报失败';
                }
                if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
                    ctx.body = { err: 0, msg: '保存成功' };
                } else {
                    ctx.redirect('/tender/' + changeInfo.tid + '/change');
                }
            } catch (err) {
                this.log(err);
                if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
                    ctx.body = { err: 1, msg: err.toString() };
                } else {
                    ctx.redirect('/tender/' + changeInfo.tid + '/change/' + ctx.request.body.cid + '/info');
                }
            }
        }

        /**
         * 变更令审批
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async approval(ctx) {
            try {
                const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.change_id });
                if (!changeData) {
                    throw '变更令数据错误';
                }
                const status = parseInt(ctx.request.body.status);
                let result = false;
                const pid = this.ctx.session.sessionProject.id;
                switch (status) {
                    case 3:// 审批通过
                        result = await ctx.service.change.approvalSuccess(pid, ctx.request.body, changeData);
                        break;
                    case 4:// 审批终止
                        result = await ctx.service.change.approvalStop(ctx.request.body);
                        break;
                    case 5:// 审批退回到原报人
                        result = await ctx.service.change.approvalBack(pid, ctx.request.body, changeData);
                        break;
                    case 6:// 审批退回到上一个审批人
                        result = await ctx.service.change.approvalBackNew(pid, ctx.request.body, changeData);
                        break;
                    default:break;
                }
                if (!result) {
                    throw '审批失败';
                }
                ctx.redirect(ctx.request.header.referer);
            } catch (err) {
                console.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 变更公司管理
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async updateCompany(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {
                const data = JSON.parse(ctx.request.body.data);
                if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
                    throw '参数有误';
                }
                const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
                responseData.data = { add: addCompany, select: selectCompany };
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 上传附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async uploadFile(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: [],
            };
            let stream;
            try {
                const parts = ctx.multipart({ autoFields: true });
                const files = [];
                let index = 0;
                const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
                const extra_upload = change.status === audit.flow.status.checked;
                while ((stream = await parts()) !== undefined) {
                    // 判断用户是否选择上传文件
                    if (!stream.filename) {
                        throw '请选择上传的文件!';
                    }
                    // const create_time = Date.parse(new Date()) / 1000;
                    // const fileInfo = path.parse(stream.filename);
                    // const dirName = 'app/public/upload/changes/' + moment().format('YYYYMMDD');
                    // const fileName = 'changes' + create_time + '_' + index + fileInfo.ext;
                    // // 判断文件夹是否存在，不存在则直接创建文件夹
                    // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
                    //     await fs.mkdirSync(path.join(this.app.baseDir, dirName));
                    // }
                    // // 保存文件
                    // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
                    const fileInfo = path.parse(stream.filename);
                    const create_time = Date.parse(new Date()) / 1000;
                    const filepath = `app/public/upload/change/fujian_${create_time + index.toString() + fileInfo.ext}`;
                    await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
                    await sendToWormhole(stream);
                    // 保存数据到att表
                    const fileData = {
                        in_time: create_time,
                        filename: fileInfo.name,
                        fileext: fileInfo.ext,
                        filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
                        filepath,
                        extra_upload,
                    };
                    const result = await ctx.service.changeAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
                    if (!result) {
                        throw '导入数据库保存失败';
                    }
                    // fileData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
                    // fileData.filesize = await ctx.helper.bytesToSize(fileData.filesize);
                    fileData.uid = ctx.session.sessionUser.accountId;
                    fileData.id = result.insertId;
                    delete fileData.filepath;
                    files.push(fileData);
                    ++index;
                }
                responseData.data = files;
            } catch (err) {
                this.log(err);
                // 失败需要消耗掉stream 以防卡死
                if (stream) {
                    await sendToWormhole(stream);
                }
                this.setMessage(err.toString(), this.messageType.ERROR);
            }
            ctx.body = responseData;
        }

        /**
         * 下载附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async downloadFile(ctx) {
            const id = ctx.params.id;
            if (id) {
                try {
                    const fileInfo = await ctx.service.changeAtt.getDataById(id);
                    if (fileInfo !== undefined && fileInfo !== '') {
                        const fileName = path.join(this.app.baseDir, fileInfo.filepath);
                        // 解决中文无法下载问题
                        const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
                        let disposition = '';
                        if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
                            disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
                        } else if (userAgent.indexOf('firefox') >= 0) {
                            disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
                        } else {
                            /* safari等其他非主流浏览器只能自求多福了 */
                            disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
                        }
                        ctx.response.set({
                            'Content-Type': 'application/octet-stream',
                            'Content-Disposition': disposition,
                            'Content-Length': fileInfo.filesize,
                        });
                        ctx.body = await fs.createReadStream(fileName);
                    } else {
                        throw '不存在该文件';
                    }
                } catch (err) {
                    this.log(err);
                    this.setMessage(err.toString(), this.messageType.ERROR);
                }
            }
        }

        /**
         * 批量下载 - 压缩成zip文件返回
         * @param {Oject} ctx - 全局上下文
         */
        async downloadZip(ctx) {
            try {
                const fileIds = JSON.parse(ctx.request.query.fileIds);
                // const { fileIds } = JSON.parse(ctx.request.body.data);
                // console.log('fileIds', fileIds);
                const { name: changeName } = await ctx.service.changeAtt.getChangeName(ctx.params.cid);
                const zipFilename = `${ctx.tender.data.name}-工程变更-${changeName}-附件.zip`;
                const time = Date.now();
                const zipPath = `app/public/upload/change/fu_jian_zip${time}.zip`;
                const size = await ctx.service.changeAtt.compressedFile(fileIds, zipPath);

                // 解决中文无法下载问题
                const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
                let disposition = '';
                if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
                    disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
                } else if (userAgent.indexOf('firefox') >= 0) {
                    disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
                } else {
                    /* safari等其他非主流浏览器只能自求多福了 */
                    disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
                }
                ctx.response.set({
                    'Content-Type': 'application/octet-stream',
                    'Content-Disposition': disposition,
                    'Content-Length': size,
                });
                const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));

                ctx.body = readStream;
                // ctx.body = fs.readFileSync(path.resolve(this.app.baseDir, zipPath));
                readStream.on('close', () => {
                    if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
                        fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
                    }
                });
            } catch (error) {
                this.log(error);
            }
        }
        /**
         * 删除附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async deleteFile(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {
                const data = JSON.parse(ctx.request.body.data);
                const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
                const fileInfo = await ctx.service.changeAtt.getDataById(data.id);
                if (!fileInfo || !Object.keys(fileInfo).length) {
                    throw '该文件不存在';
                }
                if (!fileInfo.extra_upload && change.status === audit.flow.status.checked) {
                    throw '无权限删除';
                }
                if (fileInfo !== undefined && fileInfo !== '') {
                    // 先删除文件
                    await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
                    // 再删除数据库
                    await ctx.service.changeAtt.deleteById(data.id);
                    responseData.data = '';
                } else {
                    throw '不存在该文件';
                }

                // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
                //     throw '参数有误';
                // }
                // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
                // responseData.data = { add: addCompany, select: selectCompany };
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 查看附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async checkFile(ctx) {
            const responseData = { err: 0, msg: '' };
            const id = parseInt(ctx.params.id);
            if (id) {
                try {
                    const fileInfo = await ctx.service.changeAtt.getDataById(id);
                    if (fileInfo && Object.keys(fileInfo).length) {
                        let filepath = fileInfo.filepath;
                        if (!ctx.helper.canPreview(fileInfo.fileext)) {
                            filepath = `/change/download/file/${fileInfo.id}`;
                        } else {
                            filepath = filepath.replace(/^app|\/app/, '');
                        }
                        fileInfo.filepath && (responseData.data = { filepath });
                    }
                } catch (error) {
                    this.log(error);
                    this.setMessage(error.toString(), this.messageType.ERROR);
                    responseData.err = 1;
                    responseData.msg = error.toString();
                }
            }
            ctx.body = responseData;
        }

        /**
         * 删除变更令
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async delete(ctx) {
            try {
                const result = await ctx.service.change.delete(ctx.request.body.cid);
                if (!result) {
                    throw '删除变更令失败';
                }
                ctx.redirect(ctx.request.header.referer);
            } catch (err) {
                console.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 变更令重新审批
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async checkAgain(ctx) {
            try {
                const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
                if (!changeData) {
                    throw '变更令数据错误';
                }
                // 获取终审
                const auditInfo = (await this.ctx.service.changeAudit.getAllDataByCondition({ where: { cid: changeData.cid }, orders: [['usort', 'desc']], limit: 1, offset: 0 }))[0];
                if (changeData.status !== audit.flow.status.checked || ctx.session.sessionUser.accountId !== auditInfo.uid) {
                    throw '您无权进行该操作';
                }
                if (ctx.session.sessionUser.loginStatus === 0) {
                    const code = ctx.request.body.code;
                    const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                    if (!pa.auth_mobile) {
                        throw '未绑定手机号';
                    }
                    const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
                    const cacheCode = await app.redis.get(cacheKey);
                    // console.log(cacheCode);
                    if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
                        throw '验证码不正确！';
                    }
                }

                // 获取是否已存在调用变更令
                const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, changeData.cid);
                const stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                if (stageChangeNum !== 0) {
                    throw '该变更令已被调用，无法重新审批';
                }
                // 重新审批
                const result = await ctx.service.change.checkAgain(changeData.cid);
                if (!result) {
                    throw '重新审批失败';
                }
                // ctx.redirect('/tender/' + changeData.tid + '/change/' + changeData.cid + '/info');
                ctx.body = {
                    err: 0,
                    url: ctx.request.header.referer,
                    msg: '',
                };
            } catch (err) {
                console.log(err);
                // ctx.redirect(ctx.request.header.referer);
                ctx.body = {
                    err: 1,
                    // url: ctx.request.header.referer,
                    msg: err,
                };
            }
        }

        /**
         * 变更令修订重新上报
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async checkRevise(ctx) {
            try {
                const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
                if (!changeData) {
                    throw '变更令数据错误';
                }
                if (changeData.status !== audit.flow.status.checked || ctx.session.sessionUser.accountId !== changeData.uid) {
                    throw '您无权进行该操作';
                }
                if (ctx.session.sessionUser.loginStatus === 0) {
                    const code = ctx.request.body.code;
                    const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                    if (!pa.auth_mobile) {
                        throw '未绑定手机号';
                    }
                    const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
                    const cacheCode = await app.redis.get(cacheKey);
                    // console.log(cacheCode);
                    if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
                        throw '验证码不正确！';
                    }
                }

                // 获取是否已存在调用变更令
                // const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, changeData.cid);
                // const stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
                // if (stageChangeNum !== 0) {
                //     throw '该变更令已被调用，无法重新审批';
                // }
                // 重新审批
                const result = await ctx.service.change.checkRevise(changeData.cid);
                if (!result) {
                    throw '修订发起失败';
                }
                // ctx.redirect('/tender/' + changeData.tid + '/change/' + changeData.cid + '/info');
                ctx.body = {
                    err: 0,
                    url: ctx.request.header.referer,
                    msg: '',
                };
            } catch (err) {
                console.log(err);
                // ctx.redirect(ctx.request.header.referer);
                ctx.body = {
                    err: 1,
                    // url: ctx.request.header.referer,
                    msg: err,
                };
            }
        }

        /**
         * 获取变更清单
         * @param ctx
         * @return {Promise<void>}
         */
        async bills(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const responseData = { err: 0, msg: '', data: [] };
                switch (data.type) {
                    case 'gather':
                        responseData.data = await ctx.service.changeAuditList.gatherBgBills(ctx.tender.id);
                        break;
                    default:
                        throw '查询的数据不存在';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                this.ajaxErrorBody(err, '获取变更清单失败');
            }
        }

        /**
         * 最后审批人审批成功检查批复编号和其它变更令是否出现重名情况
         * @param ctx
         * @return {Promise<void>}
         */
        async checkCodeRepeat(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {
                const tenderId = ctx.params.id;
                const cid = ctx.params.cid;
                const data = JSON.parse(ctx.request.body.data);
                const result = await ctx.service.change.isRepeat(cid, data.p_code, tenderId);
                if (result) {
                    throw '该变更令号（批复编号）已使用';
                }
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 拷贝其他变更令
         * @param {object} ctx - 全局上下文
         */
        async copyChange(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {
                const cid = ctx.params.cid;
                const copy_cid = JSON.parse(ctx.request.body.data);
                const result = await ctx.service.change.handleCopyChange(cid, copy_cid);
                if (!result) {
                    responseData.err = 1;
                    responseData.msg = '拷贝失败!';
                }
            } catch (error) {
                responseData.err = 1;
                responseData.msg = error;
            }
            ctx.body = responseData;
        }
    }

    return ChangeController;
};