Calculation/app/controller/report_controller.js

'use strict';

/**
 * Created by Tony on 2019/7/5.
 */

const tenderMenu = require('../../config/menu').tenderMenu;
const measureType = require('../const/tender').measureType;
const auditConst = require('../const/audit');
const shenpiConst = require('../const/shenpi');
const accountGroup = require('../const/account_group').group;
const JpcEx = require('../reports/rpt_component/jpc_ex');
const JV = require('../reports/rpt_component/jpc_value_define');
const rpt_xl_util = require('../reports/util/rpt_excel_util');
const rptDataExtractor = require('../reports/util/rpt_calculation_data_util');
const fsUtil = require('../public/js/fsUtil');
const fs = require('fs');
const rptCronJob = require('../reports/util/rpt_tmp_file_sweep');
const RPT_DEF_PROPERTIES = require('../const/report_defined_properties');
const reportConst = require('../const/report');
const advanceConst = require('../const/advance');
// const stringUtil = require('../public/js/string_util_light');
const needCustomTables = [
    'mem_custom_select',
    'mem_gather_stage_bills', 'mem_gather_deal_bills', 'mem_gather_stage_pay', 'mem_gather_tender_info',
    'mem_stage_sum_bills', 'mem_stage_sum_pay',
    'mem_jh_gather_im_change', 'mem_jh_im_change', 'mem_jh_gather_stage_bills_compare',
    'mem_material_sum_gl',
];
const PermissionCheck = require('../const/account_permission').PermissionCheck;

const STD_COMP_STAMP_SIZE_WIDTH = Math.round(5 * 96 / 2.54); // 公章标准尺寸(宽4.2厘米)转成像素
const STD_COMP_STAMP_SIZE_HEIGHT = STD_COMP_STAMP_SIZE_WIDTH; // 公章标准尺寸(高4.2厘米)转成像素
const NORMAL_SIGN_STR = 'normal_sign';
const COMPANY_SIGN_STR = 'company_stamp';
const PRIVATE_SIGN_STR = 'private_stamp';
const sourceTypeConst = require('../const/source_type');

module.exports = app => {
    class ReportController extends app.BaseController {

        /**
         * 获取审批界面所需的 原报、审批人数据等
         * @param {Object} ctx - egg全局context
         * @return {void}
         * @private
         */
        async _getStageAuditViewData(ctx) {
            if (!ctx.stage) return;
            await ctx.service.stage.loadStageAuditViewData(ctx.stage);
        }

        async _chkIfStageAuditor(ctx, stage) {
            //
        }

        async _filterStageList(ctx, stageList) {
            //
            // throw
        }

        async _createNodes(ctx, source_type, pid) {
            const treeNodes = await ctx.service.rptTreeNode.getNodesBySourceType([pid], source_type); // 这个查定制的
            const commonTreeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1]); // 这个查通用的
            const allTreeNodes = await ctx.service.rptTreeNode.getAllNodes([-1]); // 这个得到所有通用的(新业务需求)
            const allTreeItems = JSON.parse(allTreeNodes[0].items);
            const allIndivTreeNodes = await ctx.service.rptTreeNode.getAllNodes([pid]); // 这个得到所有定制的(新业务需求)
            const allIndivTreeItems = JSON.parse(allIndivTreeNodes[0].items);
            const nodeItems = JSON.parse(commonTreeNodes[0].items);
            const commonArrs = [];
            nodeItems.forEach(nodeItem => {
                const srcType = nodeItem.source_type ? nodeItem.source_type : 1;
                if (srcType === source_type) {
                    commonArrs.push(nodeItem);
                }
            });
            // 加一个dummy的通用报表
            const dummyCommonRptNode = { id: 1, name: '通用报表', pid: -1, rpt_type: 0, items: JSON.stringify(commonArrs) };
            treeNodes.push(dummyCommonRptNode);
            const custCfg = await ctx.service.rptCustomizeCfg.getCustomizeCfgByUserId('Administrator');
            return { treeNodes, commonArrs, custCfg, allTreeItems, allIndivTreeItems };
        }

        async _getInvolveAcc(ctx, tId) {
            // 获取所有项目参与者
            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', 'mobile'],
            });
            const newAccountGroup = accountGroup.map((item, idx) => {
                const groupList = accountList.filter(item => item.account_group === idx);
                return { groupName: item, groupList };
            });
            const where = { tid: tId };
            const advance = await ctx.service.advance.getAllDataByCondition({
                columns: ['id', 'order', 'status', 'selected', 'type'],
                where,
                orders: [['type', 'asc'], ['create_time', 'desc']],
            });
            advance.forEach(x => {
                x.statusStr = auditConst.advance.statusString[x.status];
                x.typeStr = advanceConst.typeColMap[x.type].text;
            });
            return { accountList, newAccountGroup, advance };
        }

        /**
         * 报表显示页面
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        async index(ctx) {
            // 普通情况(计量期入口)
            try {
                await this._getStageAuditViewData(ctx);
                const pageShow = ctx.session.sessionProject.page_show;
                pageShow.showArchive = 1;
                const tender = ctx.tender;
                const stage = ctx.stage;
                let stage_id = -1;
                let stage_order = -1;
                let sorder = -1;
                let stage_times = -1;
                let stage_status = -1;

                const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
                const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
                const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: tender.data.project_id } }); // 找公司章用的
                const isAdmin = ctx.session.sessionUser.is_admin;
                // console.log('this.ctx.session.sessionUser.accountId: ' + this.ctx.session.sessionUser.accountId);
                if (stage && stage.status === auditConst.stage.status.uncheck) {
                    // 得判断账号是否在审核人列表中(不含原报)
                    if (stage.auditorList === undefined || stage.auditorList === null) {
                        stage.auditorList = await ctx.service.stageAudit.getAuditors(ctx.stage.id, ctx.stage.times);
                    }
                    let isAudit = false;
                    for (const audit of stage.auditorList) {
                        if (audit.aid === this.ctx.session.sessionUser.accountId) {
                            isAudit = true;
                            break;
                        }
                    }
                    if (isAudit) {
                        throw '未上报！';
                    }
                } else {
                    // 剔除未上报期(审核人（非原报人）才需要判断)
                    for (let idx = stageList.length - 1; idx >= 0; idx--) {
                        if (stageList[idx].status === auditConst.stage.status.uncheck) {
                            if (stageList[idx].auditorList === undefined || stageList[idx].auditorList === null) {
                                stageList[idx].auditorList = await ctx.service.stageAudit.getAuditors(stageList[idx].id, stageList[idx].times);
                            }
                            let isAudit = false;
                            for (const audit of stageList[idx].auditorList) {
                                if (audit.aid === this.ctx.session.sessionUser.accountId) {
                                    isAudit = true;
                                    break;
                                }
                            }
                            if (isAudit) {
                                stageList.splice(idx, 1);
                            }
                        }
                    }
                }
                let lastAuditor = null;
                if (stage) {
                    lastAuditor = await ctx.service.stageAudit.getLastestAuditor(ctx.stage.id, ctx.stage.times, auditConst.stage.status.checked);
                } else {
                    lastAuditor = stageList.length > 0 ? await ctx.service.stageAudit.getLastestAuditor(stageList[stageList.length - 1].id, stageList[stageList.length - 1].times, auditConst.stage.status.checked) : null;
                }
                let archiveList = [];
                if (stage) {
                    const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
                    if (archives.length > 0) {
                        archiveList = JSON.parse(archives[0].content);
                    }
                } else {
                    const archives = stageList.length > 0 ? await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id) : [];
                    // console.log(archives);
                    if (archives && archives.length > 0) {
                        archiveList = JSON.parse(archives[0].content);
                    }
                }
                let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.data.project_id);
                prjAccList = prjAccList.filter(pa => pa.enable !== 0);
                const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
                const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tender.id);

                // ctx.session.sessionUser.is_admin
                // const pageShow = ctx.session.sessionProject.page_show;
                // 根据需求，如果开启了‘开启个人「签字」’功能，则只能是本身用户签名，管理员例外
                if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
                    // 削减其他account
                    const newAccList = [];
                    for (const acc of prjAccList) {
                        if (acc.id === this.ctx.session.sessionUser.accountId) {
                            newAccList.push(acc);
                        }
                    }
                    prjAccList = newAccList;
                }

                // 分类列表
                const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                // 获取用户权限
                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, true);
                        // if (t.lastStage) {
                        //     await this.ctx.service.stage.checkStageGatherData(t.lastStage, this.ctx.session.sessionUser.is_admin);
                        // }
                    }
                }

                // 获取汇总表，历史选择
                const cid = this.ctx.helper._.map(treeNodes, 'id');
                const customSelects = {};
                if (ctx.stage) {
                    customSelects.audit_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
                        reportConst.rptCustomType[JV.NODE_CUS_AUDIT_SELECT], ctx.tender.id, ctx.stage.id);
                    customSelects.stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(
                        ctx.stage.stage_id, ctx.stage.stage_times);
                    customSelects.stageFlow.forEach(x => {
                        if (!x) return;
                        x.visible = (!ctx.session.sessionUser.is_admin && ctx.session.sessionProject.page_show.individualSign === 1)
                            ? x.aid === ctx.session.sessionUser.accountId : true;
                    });
                } else {
                    customSelects.audit_select = [];
                }
                customSelects.gather_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
                    reportConst.rptCustomType[JV.NODE_CUS_GATHER_SELECT], ctx.tender.id, -1);
                customSelects.stage_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
                    reportConst.rptCustomType[JV.NODE_CUS_STAGE_SELECT], ctx.tender.id, -1);
                customSelects.change_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
                    reportConst.rptCustomType[JV.NODE_CUS_CHANGE_SELECT], ctx.tender.id, -1);
                customSelects.material_sum_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
                    reportConst.rptCustomType[JV.NODE_CUS_MATERIAL_SUM_SELECT], ctx.tender.id, -1);
                const dataSelects = {};
                dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
                    reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);

                const materialList = await ctx.service.material.getValidMaterials(ctx.tender.id);


                if (stage !== null && stage !== undefined) {
                    stage_id = stage.id;
                    stage_order = stage.order;
                    sorder = stage.curOrder;
                    stage_times = stage.times;
                    stage_status = stage.status;
                }
                for (const prjAcc of prjAccList) {
                    prjAcc.account_group = prjAcc.company;
                }
                const cust_select_keys = JSON.stringify(['common', 'customize']); // 因其他地方也有可能保存用户报表的显示选择项，因当初设计问题，不好改数据库结构了，但可以调节内部json来满足需求
                const rpt_tpl_items = { customize: [], common: [] };
                if (custTreeNodes.length > 0) {
                    const cust_select_item = JSON.parse(custTreeNodes[0].rpt_tpl_items);
                    if (cust_select_item.common) rpt_tpl_items.common = cust_select_item.common;
                    if (cust_select_item.customize) rpt_tpl_items.customize = cust_select_item.customize;
                }

                // 获取所有项目参与者
                const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, this.ctx.tender.id);

                const renderData = {
                    accountGroup: newAccountGroup,
                    accountList,
                    unitList: JSON.stringify(unitList),
                    tender: tender.data,
                    tenderInfo: tender.info,
                    rpt_tpl_data: JSON.stringify(treeNodes),
                    cust_tpl_data: JSON.stringify(rpt_tpl_items),
                    all_common_tpl_data: JSON.stringify(allTreeItems),
                    all_indivi_tpl_data: JSON.stringify(allIndivTreeItems),
                    cust_select_keys,
                    cust_cfg: JSON.stringify(custCfg),
                    project_id: tender.data.project_id,
                    tender_id: tender.id,
                    tender_name: tender.data.name,
                    budget_id: -1,
                    sp_id: -1,
                    detail_id: -1,
                    stg_id: stage_id,
                    stg_order: stage_order,
                    cur_order: sorder,
                    stg_times: stage_times,
                    stg_status: stage_status,
                    stage_list: JSON.stringify(stageList),
                    prj_account_list: JSON.stringify(prjAccList),
                    role_list: JSON.stringify(roleList),
                    used_list: JSON.stringify(usedList),
                    tenderMenu,
                    preUrl: '/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order,
                    measureType,
                    categoryData,
                    tenderList,
                    auditConst: auditConst.stage,
                    ledgerAuditConst: auditConst.ledger,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                    customSelects,
                    rptCustomType: reportConst.rptCustomType,
                    materialList,
                    stages: stageList,
                    dataSelects,
                    // pageShow: JSON.stringify(pageShow),
                    pageShow,
                    authMobile: accountInfo.auth_mobile,
                    shenpiConst,
                    archiveList,
                    lastAuditor,
                    rpt_id: ctx.query.rpt_id,
                    isAdmin,
                    prePay: JSON.stringify(advance),
                    OSS_PATH: ctx.app.config.fujianOssPath,
                    viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
                    auditType: auditConst.auditType,
                    source_type: 1,
                    bglObj: 'null',
                    changes: 'null',

                };
                await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
                // await this.layout('report/index.ejs', renderData);

                // 在这里启动一个cron job，删除临时创建的excel文件
                if (!rptCronJob.started) {
                    try {
                        // console.log('rptCronJob.started: ' + rptCronJob.started);
                        rptCronJob.started = true;
                        // console.log('this.app.baseDir: ' + this.app.baseDir);
                        rptCronJob.createJob(null, this.app.baseDir + '/app/public/download');
                    } catch (ex) {
                        rptCronJob.started = false;
                    }
                }
            } catch (err) {
                this.log(err);
                ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
            }
        }

        async indexForPaymentSafe(ctx) {
            // 安全生产费入口
            try {
                await this._getStageAuditViewData(ctx);
                const pageShow = ctx.session.sessionProject.page_show;
                // pageShow.showArchive = 1;
                pageShow.showArchive = 0;
                // pageShow.closeWatermark = 1;
                const tenderId = ctx.params.id;
                const paymentDetail_id = ctx.params.did;
                // 支付审批: ctx.params.did 是 zh_payment_detail表的id, 通过这个did在 zh_payment_detail_audit表里找审核信息(td_id = ctx.params.did)
                //          没有计量期的概念！！！
                // const paymentAuditorList = await ctx.service.paymentDetailAudit.getAuditors(paymentDetail_id);
                const tender = ctx.paymentTender;
                const { treeNodes, commonArrs, custCfg } = await this._createNodes(ctx, sourceTypeConst.sourceType.payment_safe, tender.pid);
                // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
                const stageList = [];
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: tender.pid } }); // 找公司章用的
                const isAdmin = ctx.session.sessionUser.is_admin;
                const lastAuditor = null;
                const archiveList = [];
                let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.pid);
                prjAccList = prjAccList.filter(pa => pa.enable !== 0);
                const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
                const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tender.id);
                // 根据需求，如果开启了‘开启个人「签字」’功能，则只能是本身用户签名，管理员例外
                if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
                    // 削减其他account
                    const newAccList = [];
                    for (const acc of prjAccList) {
                        if (acc.id === this.ctx.session.sessionUser.accountId) {
                            newAccList.push(acc);
                        }
                    }
                    prjAccList = newAccList;
                }
                // 分类列表
                const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                // 获取用户权限
                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 = [];
                const cid = this.ctx.helper._.map(treeNodes, 'id');
                const customSelects = null;
                const dataSelects = {};
                dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
                    reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);

                const materialList = await ctx.service.material.getValidMaterials();

                const stage_id = -100;
                let stage_order = -1;
                let sorder = -1;
                let stage_times = -1;
                let stage_status = -1;

                const paymentDetailList = await ctx.service.paymentDetail.getDetail(paymentDetail_id);
                if (paymentDetailList && paymentDetailList.length > 0) {
                    const payment = paymentDetailList[0];
                    stage_status = payment.status;
                    stage_order = payment.order;
                    sorder = stage_order;
                    stage_times = payment.times;
                    stageList.push({ id: stage_id, user_id: payment.uid, status: payment.status });
                }

                for (const prjAcc of prjAccList) {
                    prjAcc.account_group = prjAcc.company;
                }
                const cust_select_keys = JSON.stringify(['common_safe', 'customize_safe']); // 因其他地方也有可能保存用户报表的显示选择项，因当初设计问题，不好改数据库结构了，但可以调节内部json来满足需求，安全生产费没有这个，就过了
                const rpt_tpl_items = { customize: [], common: [] };
                commonArrs.forEach(item => {
                    rpt_tpl_items.common.push(item.name);
                });

                // 获取所有项目参与者
                const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);

                const renderData = {
                    accountGroup: newAccountGroup,
                    accountList,
                    unitList: JSON.stringify(unitList),
                    tender: null,
                    tenderInfo: null,
                    rpt_tpl_data: JSON.stringify(treeNodes),
                    cust_tpl_data: JSON.stringify(rpt_tpl_items),
                    all_common_tpl_data: JSON.stringify([]),
                    all_indivi_tpl_data: JSON.stringify([]),
                    cust_select_keys,
                    cust_cfg: JSON.stringify(custCfg),
                    project_id: tender.pid,
                    tender_id: tenderId,
                    tender_name: tender.name,
                    detail_id: paymentDetail_id,
                    stg_id: stage_id,
                    budget_id: -1,
                    sp_id: -1,
                    stg_order: stage_order,
                    cur_order: sorder,
                    stg_times: stage_times,
                    stg_status: stage_status,
                    stage_list: JSON.stringify(stageList),
                    prj_account_list: JSON.stringify(prjAccList),
                    role_list: JSON.stringify(roleList),
                    used_list: JSON.stringify(usedList),
                    tenderMenu,
                    preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
                    measureType,
                    categoryData,
                    tenderList,
                    auditConst: auditConst.stage,
                    ledgerAuditConst: auditConst.ledger,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                    customSelects,
                    rptCustomType: reportConst.rptCustomType,
                    materialList,
                    stages: stageList,
                    dataSelects,
                    pageShow,
                    authMobile: accountInfo.auth_mobile,
                    shenpiConst,
                    archiveList,
                    lastAuditor,
                    rpt_id: ctx.query.rpt_id,
                    isAdmin,
                    prePay: JSON.stringify(advance),
                    OSS_PATH: ctx.app.config.fujianOssPath,
                    viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
                    source_type: 101,
                    bglObj: 'null',
                    changes: 'null',
                };
                /*
                //*/
                await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
            } catch (err) {
                this.log(err);
                // ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
            }
        }

        async indexForDynamicGrandTotal(ctx) {
            // 动态决算(动态投资)入口 (以独立报表为蓝本(index入口))
            try {
                await this._getStageAuditViewData(ctx);
                const pageShow = ctx.session.sessionProject.page_show;
                // pageShow.closeWatermark = 1;
                pageShow.showArchive = 0;
                pageShow.closeShowAllCustomized = 0;
                const tenderId = -1;
                const paymentDetail_id = -1;
                // const tender = ctx.paymentTender;
                const pid = ctx.budget.pid;
                const budget_id = ctx.budget.id;
                const subProj = await ctx.service.subProject.getDataByCondition({ budget_id });
                const sp_id = subProj.id;
                const { treeNodes, commonArrs, custCfg } = await this._createNodes(ctx, sourceTypeConst.sourceType.budget, pid);
                // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
                const stageList = [];
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid } }); // 找公司章用的
                const isAdmin = ctx.session.sessionUser.is_admin;
                const lastAuditor = null;
                const archiveList = [];
                let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(pid);
                prjAccList = prjAccList.filter(pa => pa.enable !== 0);
                const roleList = [];
                const usedList = [];
                // 根据需求，如果开启了‘开启个人「签字」’功能，则只能是本身用户签名，管理员例外
                if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
                    // 削减其他account
                    const newAccList = [];
                    for (const acc of prjAccList) {
                        if (acc.id === this.ctx.session.sessionUser.accountId) {
                            newAccList.push(acc);
                        }
                    }
                    prjAccList = newAccList;
                }
                // 分类列表
                const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                // 获取用户权限
                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 = [];
                const cid = this.ctx.helper._.map(treeNodes, 'id');
                const customSelects = null;
                const dataSelects = {};
                dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
                    reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);

                const materialList = await ctx.service.material.getValidMaterials();

                const stage_id = -200;
                const stage_order = -1;
                const sorder = -1;
                const stage_times = -1;
                const stage_status = -1;

                for (const prjAcc of prjAccList) {
                    prjAcc.account_group = prjAcc.company;
                }
                const cust_select_keys = JSON.stringify(['common_dynamic', 'customize_dynamic']); // 因其他地方也有可能保存用户报表的显示选择项，因当初设计问题，不好改数据库结构了，但可以调节内部json来满足需求
                const rpt_tpl_items = { customize: [], common: [] };
                const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
                if (custTreeNodes.length > 0) {
                    const cust_select_item = JSON.parse(custTreeNodes[0].rpt_tpl_items);
                    if (cust_select_item.common_dynamic) rpt_tpl_items.common = cust_select_item.common_dynamic;
                    if (cust_select_item.customize_dynamic) rpt_tpl_items.customize = cust_select_item.customize_dynamic;
                    if (!cust_select_item.hasOwnProperty('common_dynamic') && !cust_select_item.hasOwnProperty('customize_dynamic')) {
                        commonArrs.forEach(item => {
                            rpt_tpl_items.common.push(item.name);
                        });
                    }
                } else {
                    commonArrs.forEach(item => {
                        rpt_tpl_items.common.push(item.name);
                    });
                }

                // 获取所有项目参与者
                const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);

                const renderData = {
                    accountGroup: newAccountGroup,
                    accountList,
                    unitList: JSON.stringify(unitList),
                    tender: null,
                    tenderInfo: null,
                    rpt_tpl_data: JSON.stringify(treeNodes),
                    cust_tpl_data: JSON.stringify(rpt_tpl_items),
                    all_common_tpl_data: JSON.stringify([]),
                    all_indivi_tpl_data: JSON.stringify([]),
                    cust_select_keys,
                    cust_cfg: JSON.stringify(custCfg),
                    project_id: pid,
                    tender_id: tenderId,
                    budget_id,
                    sp_id,
                    tender_name: ctx.budget.name,
                    detail_id: paymentDetail_id,
                    stg_id: stage_id,
                    stg_order: stage_order,
                    cur_order: sorder,
                    stg_times: stage_times,
                    stg_status: stage_status,
                    stage_list: JSON.stringify(stageList),
                    prj_account_list: JSON.stringify(prjAccList),
                    role_list: JSON.stringify(roleList),
                    used_list: JSON.stringify(usedList),
                    tenderMenu,
                    preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
                    measureType,
                    categoryData,
                    tenderList,
                    auditConst: auditConst.stage,
                    ledgerAuditConst: auditConst.ledger,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                    customSelects,
                    rptCustomType: reportConst.rptCustomType,
                    materialList,
                    stages: stageList,
                    dataSelects,
                    pageShow,
                    authMobile: accountInfo.auth_mobile,
                    shenpiConst,
                    archiveList,
                    lastAuditor,
                    rpt_id: ctx.query.rpt_id,
                    isAdmin,
                    prePay: JSON.stringify(advance),
                    OSS_PATH: ctx.app.config.fujianOssPath,
                    viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
                    source_type: 200,
                    bglObj: 'null',
                    changes: 'null',
                };
                await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');

            } catch (err) {
                this.log(err);
            }
        }

        async _indexForBGL(ctx, source_type, stage_id) {
            // 变更令、变更方案、变更立项、变更申请 报表入口
            try {
                await this._getStageAuditViewData(ctx);
                const pageShow = ctx.session.sessionProject.page_show;
                pageShow.closeWatermark = 1;
                pageShow.showArchive = 1;
                pageShow.closeShowAllCustomized = 0;
                const tenderId = ctx.params.id;
                const bglObj = {};
                if (stage_id === -300) {
                    bglObj.BUSINESS_ID = ctx.params.cid;
                    bglObj.change = await ctx.service.change.getChangeByCid(ctx.params.cid);
                    bglObj.currentBz = bglObj.change;
                    bglObj.status = bglObj.change.status;
                    // const audit = await ctx.service.changeAudit.getChangeByCid(ctx.params.cid);
                }
                if (stage_id === -301) {
                    bglObj.BUSINESS_ID = ctx.params.cplnid;
                    bglObj.change_plan = await ctx.service.changePlan.getDataById(ctx.params.cplnid);
                    bglObj.currentBz = bglObj.change_plan;
                    bglObj.status = bglObj.change_plan.status;
                }
                if (stage_id === -302) {
                    bglObj.BUSINESS_ID = ctx.params.cprjid;
                    bglObj.change_project = await ctx.service.changeProject.getDataById(ctx.params.cprjid);
                    bglObj.currentBz = bglObj.change_project;
                    bglObj.status = bglObj.change_project.status;
                }
                if (stage_id === -303) {
                    bglObj.BUSINESS_ID = ctx.params.caid;
                    bglObj.change_apply = await ctx.service.changeApply.getDataById(ctx.params.caid);
                    bglObj.currentBz = bglObj.change_apply;
                    bglObj.status = bglObj.change_apply.status;
                }
                const changeId = ctx.params.cid;
                const paymentDetail_id = -1;
                const pid = ctx.session.sessionProject.id;
                const budget_id = -1;
                const sp_id = -1;
                const { treeNodes, custCfg } = await this._createNodes(ctx, source_type, pid);
                // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
                const state = ctx.session.sessionProject.page_show.openChangeState && ctx.query.state ? parseInt(ctx.query.state) : 0;
                const changes = await ctx.service.change.getListByStatus(tenderId, 0, 0, 0, 0, state);
                let change_times = 1;
                const stageList = [];
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid } }); // 找公司章用的
                const isAdmin = ctx.session.sessionUser.is_admin;
                let lastAuditor = null;
                for (let cIdx = 0; cIdx < changes.length; cIdx++) {
                    if (changes[cIdx].cid === changeId) {
                        if (changes[cIdx].times > change_times) change_times = changes[cIdx].times;
                        if (changes[cIdx].status === 3) {
                            const changeAudit = await ctx.service.changeAudit.getLastUser(changeId, changes[cIdx].times, 3);
                            if (changeAudit) {
                                lastAuditor = { end_time: changeAudit.sin_time, sdesc: changeAudit.sdesc };
                            }
                        }
                        break;
                    }
                }
                let archiveList = [];
                const archives = await ctx.service.rptArchive.getArchiveByBzId(pid, stage_id, bglObj.BUSINESS_ID);
                if (archives.length > 0) {
                    archiveList = JSON.parse(archives[0].content);
                }

                let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(pid);
                prjAccList = prjAccList.filter(pa => pa.enable !== 0);
                const roleList = [];
                const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tenderId);
                // 根据需求，如果开启了‘开启个人「签字」’功能，则只能是本身用户签名，管理员例外
                if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
                    // 削减其他account
                    const newAccList = [];
                    for (const acc of prjAccList) {
                        if (acc.id === this.ctx.session.sessionUser.accountId) {
                            newAccList.push(acc);
                        }
                    }
                    prjAccList = newAccList;
                }
                // 分类列表
                const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                // 获取用户权限
                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 = [];
                const cid = this.ctx.helper._.map(treeNodes, 'id');
                const customSelects = null;
                const dataSelects = {};
                dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
                    reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);

                const materialList = await ctx.service.material.getValidMaterials();

                const stage_order = -1;
                const sorder = -1;
                const stage_times = -1;
                const stage_status = -1;

                for (const prjAcc of prjAccList) {
                    // prjAcc.account_group = accountGroup[prjAcc.account_group];
                    prjAcc.account_group = prjAcc.company;
                }
                const cust_select_keys = JSON.stringify(['common', 'customize']); // 因其他地方也有可能保存用户报表的显示选择项，因当初设计问题，不好改数据库结构了，但可以调节内部json来满足需求
                const rpt_tpl_items = { customize: [], common: [] };
                if (treeNodes && treeNodes.length > 0) {
                    for (let tIdx = treeNodes.length - 1; tIdx >= 0; tIdx--) {
                        if (treeNodes[tIdx].name === '通用报表') {
                            const items = JSON.parse(treeNodes[tIdx].items);
                            for (let itemIdx = items.length - 1; itemIdx >= 0; itemIdx--) {
                                rpt_tpl_items.common.push(items[itemIdx].name);
                            }
                        } else {
                            rpt_tpl_items.customize.push(treeNodes[tIdx].name);
                        }
                    }
                }

                // 获取所有项目参与者
                const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);

                const renderData = {
                    accountGroup: newAccountGroup,
                    accountList,
                    unitList: JSON.stringify(unitList),
                    tender: null,
                    tenderInfo: null,
                    rpt_tpl_data: JSON.stringify(treeNodes),
                    cust_tpl_data: JSON.stringify(rpt_tpl_items),
                    all_common_tpl_data: JSON.stringify([]),
                    all_indivi_tpl_data: JSON.stringify([]),
                    cust_select_keys,
                    cust_cfg: JSON.stringify(custCfg),
                    project_id: pid,
                    tender_id: tenderId,
                    budget_id,
                    sp_id,
                    tender_name: ctx.tender.data.name,
                    detail_id: paymentDetail_id,
                    stg_id: stage_id,
                    stg_order: stage_order,
                    cur_order: sorder,
                    stg_times: stage_times,
                    stg_status: stage_status,
                    stage_list: JSON.stringify(stageList),
                    prj_account_list: JSON.stringify(prjAccList),
                    role_list: JSON.stringify(roleList),
                    used_list: JSON.stringify(usedList),
                    tenderMenu,
                    preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
                    measureType,
                    categoryData,
                    tenderList,
                    auditConst: auditConst.stage,
                    ledgerAuditConst: auditConst.ledger,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                    customSelects,
                    rptCustomType: reportConst.rptCustomType,
                    materialList,
                    stages: stageList,
                    dataSelects,
                    pageShow,
                    authMobile: accountInfo.auth_mobile,
                    shenpiConst,
                    archiveList,
                    lastAuditor,
                    rpt_id: ctx.query.rpt_id,
                    isAdmin,
                    prePay: JSON.stringify(advance),
                    OSS_PATH: ctx.app.config.fujianOssPath,
                    viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
                    source_type,
                    bglObj: JSON.stringify(bglObj),
                    changes: JSON.stringify(changes),
                    bizId: bglObj.BUSINESS_ID,
                };
                await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
            } catch (err) {
                this.log(err);
            }
        }

        async indexForChange(ctx) {
            // 变更令报表入口
            await this._indexForBGL(ctx, sourceTypeConst.sourceType.change, -300);
        }

        async indexForChangePlan(ctx) {
            // 变更方案报表入口
            await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_plan, -301);
        }

        async indexForChangeProject(ctx) {
            // 变更立项报表入口
            await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_project, -302);
        }

        async indexForChangeApply(ctx) {
            // 变更申请报表入口
            await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_apply, -303);
        }

        /**
         * 报表打印页面
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        async showPrintPage(ctx) {
            try {
                // const params = JSON.parse(ctx.request.body.params);
                const pageSize = ctx.params.size;
                // console.log('pageSize: ' + pageSize);
                const renderData = {
                    size: pageSize,
                    // orientation: params.orientation,
                };
                await ctx.render('report/rpt_print.ejs', renderData);
            } catch (err) {
                this.log(err);
                console.log(err);
            }
        }

        async showIndividualPage(ctx) {
            try {
                // const params = JSON.parse(ctx.request.body.params);
                const pageSize = ctx.params.size;
                // console.log('pageSize: ' + pageSize);
                const renderData = {
                    size: pageSize,
                    OSS_PATH: ctx.app.config.fujianOssPath,
                    // orientation: params.orientation,
                };
                await ctx.render('report/rpt_individual.ejs', renderData);
            } catch (err) {
                this.log(err);
                console.log(err);
            }
        }

        _mergeBlankRoleSignDate(roleRel, auditors) {
            // 有些签名信息的sign_date是空白的(从前一业务copy过来并清理)，需要根据审核信息来自动填写上审核时间
            // 1. 用户ID 2. sign_date为空白
            if (roleRel && auditors) {
                roleRel.forEach(record => {
                    const contents = JSON.parse(record.rel_content);
                    let hasMerge = false;
                    contents.forEach(role => {
                        if (!role.sign_date || role.sign_date === '') {
                            auditors.forEach(audit => {
                                if (audit.aid === role.acc_id) {
                                    role.sign_date = audit.end_time;
                                    hasMerge = true;
                                }
                            });
                        }
                    });
                    if (hasMerge) {
                        record.rel_content = JSON.stringify(contents);
                    }
                });
            }
        }

        async _commonGetAudit(ctx, params, stgAudit) {
            switch (params.stage_id) {
                case -300: // 变更令
                    const changeAudit = await ctx.service.changeAudit.getAuditors(params.change_id, params.change_times, 'asc', true);
                    const change = await ctx.service.change.getChangeByCid(params.change_id);
                    let orgChangeStatus = 3;
                    if ([1, 9].includes(change.status)) orgChangeStatus = 1; // 原报只要已上报(非1、9)，status都是3
                    stgAudit.push({ aid: change.uid, status: orgChangeStatus, opinion: '', end_time: change.in_time, order: 0 }); // 加上原报
                    changeAudit.forEach(audit => {
                        stgAudit.push({ aid: audit.uid, status: audit.status, opinion: audit.sdesc, end_time: audit.sin_time, order: audit.usite });
                    });
                    break;
                case -301: // 变更方案
                    const changePlanAudit = await ctx.service.changePlanAudit.getAuditors(params.business_id, params.change_plan_times, 'asc', true);
                    const change_plan = await ctx.service.changePlan.getDataById(params.business_id);
                    let orgChangePlanStatus = 3;
                    if ([1, 9].includes(change_plan.status)) orgChangePlanStatus = 1; // 原报只要已上报(非1、9)，status都是3
                    stgAudit.push({ aid: change_plan.uid, status: orgChangePlanStatus, opinion: '', end_time: change_plan.in_time, order: 0 }); // 加上原报
                    changePlanAudit.forEach(audit => {
                        stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
                    });
                    break;
                case -302: // 变更立项
                    const changeProjectAudit = await ctx.service.changeProjectAudit.getAuditors(params.business_id, params.change_project_times, 'asc', true);
                    const change_project = await ctx.service.changeProject.getDataById(params.business_id);
                    let orgChangePrjStatus = 3;
                    if ([1, 9].includes(change_project.status)) orgChangePrjStatus = 1; // 原报只要已上报(非1、9)，status都是3
                    stgAudit.push({ aid: change_project.uid, status: orgChangePrjStatus, opinion: '', end_time: change_project.in_time, order: 0 }); // 加上原报
                    changeProjectAudit.forEach(audit => {
                        stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
                    });
                    break;
                case -303: // 变更申请
                    const changeApplyAudit = await ctx.service.changeApplyAudit.getAuditors(params.business_id, params.change_apply_times, 'asc', true);
                    const change_apply = await ctx.service.changeApply.getDataById(params.business_id);
                    let orgChangeApplyStatus = 3;
                    if ([1, 9].includes(change_apply.status)) orgChangeApplyStatus = 1; // 原报只要已上报(非1、9)，status都是3
                    stgAudit.push({ aid: change_apply.uid, status: orgChangeApplyStatus, opinion: '', end_time: change_apply.in_time, order: 0 }); // 加上原报
                    changeApplyAudit.forEach(audit => {
                        stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
                    });
                    break;
                default:
                    break;
            }
        }

        async _getReport(ctx, params) {
            // console.log('in getReport');
            // console.log(params);
            let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
            if (!rptTpl || rptTpl.length !== 1) {
                throw '获取模板失败';
            }
            const source_type = params.source_type ? params.source_type : rptTpl[0].source_type;
            rptTpl = JSON.parse(rptTpl[0].rpt_content);
            rptTpl.source_type = source_type || sourceTypeConst.defaultSourceType;
            rptTpl.id = params.rpt_tpl_id;
            // console.log('get the template!');
            const customSelect = rptTpl[JV.NODE_CUSTOM_DEFINE] && rptTpl[JV.NODE_CUSTOM_DEFINE][JV.NODE_CUS_AUDIT_SELECT].enable
                ? await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, params.stage_id, params.rpt_tpl_id)
                : await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, -1, params.rpt_tpl_id);

            let copyCustomSelect = this.ctx.helper.clone(customSelect);
            if (!params.gather_select && copyCustomSelect) delete copyCustomSelect.gather_select;
            if (!params.stage_select && copyCustomSelect) delete copyCustomSelect.stage_select;
            if (!params.material_sum_select && copyCustomSelect) delete copyCustomSelect.material_sum_select;
            if (params.change_select) {
                copyCustomSelect = { tid: params.tender_id, rid: params.rpt_tpl_id, sid: -1, change_select: params.change_select };
            }

            const pageRst = await ctx.service.jpcReport.getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir, copyCustomSelect);
            for (const page of pageRst.items) {
                page[JV.PROP_WATERMARK_CELLS] = [];
            }
            let waterMarkStr = null;
            if (params.stage_status !== 3 && params.closeWatermark === 0) {
                // 加水印
                fillWaterMark([pageRst]);
                if (params.needWaterMark) {
                    waterMarkStr = await getWatermarkPicData(pageRst, this.app.baseDir);
                }
            }
            // console.log(pageRst);
            const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id, params.stage_id, params.business_id); // 新需求中，允许在非审核状态下设置签名

            let stgAudit = null,
                stgAuditForOrg = null,
                stageFlow = null,
                stageList = [];
            if (params.stage_id > 0) {
                stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
                stgAuditForOrg = await ctx.service.stageAudit.getStageAudit(params.stage_id, 1);
                stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
                stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(params.stage_id, params.stage_times);
            } else if ([-100, -200].includes(params.stage_id)) {
                stgAudit = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id, params.stage_times);
                stgAuditForOrg = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id, 1);
                stageFlow = await ctx.service.paymentDetailAudit.getAuditorsWithOwner(params.detail_id);
                const paymentDetailList = await ctx.service.paymentDetail.getDetail(params.detail_id);
                if (paymentDetailList && paymentDetailList.length > 0) {
                    const payment = paymentDetailList[0];
                    stageList.push({ id: params.stage_id, user_id: payment.uid, status: payment.status });
                }
            } else if ([-300, -301, -302, -303].includes(params.stage_id)) {
                // 变更令相关的
                stgAudit = [];
                stgAuditForOrg = [];
                stageFlow = [];
                await this._commonGetAudit(ctx, params, stgAudit);
                stgAudit.sort(function(stg1, stg2) {
                    return stg1.order - stg2.order;
                });
                this._mergeBlankRoleSignDate(roleRel, stgAudit);
            }

            if (stageFlow) {
                stageFlow.forEach(x => {
                    if (!x) return;
                    x.visible = (!ctx.session.sessionUser.is_admin && ctx.session.sessionProject.page_show.individualSign === 1)
                        ? x.aid === ctx.session.sessionUser.accountId : true;
                });
            }
            mergeStampSignature(ctx, params.stage_status, pageRst, roleRel[0], null, stgAudit, stageList);
            mergeTextSignature(params.isTextSignature, params.stage_status, pageRst, roleRel[0], [], stgAudit, stageList);
            await encodeSignatureDataUri(roleRel, this.app.baseDir);
            if (params.getPicFlag) {
                await encodeDummySignatureDataUri(pageRst, this.app.baseDir); // 注意草图数据量问题！
            }

            // console.log('encodeSignatureDataUri!');
            // fsUtil.writeObjToFile(pageRst, 'D:/GitHome/Temp/testBuiltPageResult2.js');
            return {
                data: pageRst,
                signatureRelInfo: roleRel,
                stageAudit: stgAudit,
                stageAuditOrg: stgAuditForOrg,
                debugInfo: ctx.session.sessionUser.loginStatus ? ctx.debugInfo : null,
                customDefine: rptTpl[JV.NODE_CUSTOM_DEFINE],
                stageFlow,
                customSelect,
                waterMarkStr,
            };
        }

        /**
         * 获取报表数据
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        async getReport(ctx) {
            try {
                // console.log('in getReport');
                const params = JSON.parse(ctx.request.body.params);
                ctx.body = await this._getReport(ctx, params);
                ctx.status = 201;
            } catch (ex) {
                console.log(ex);
                this.setMessage(ex.toString(), this.messageType.ERROR);
            }
        }

        async getTestReport(ctx) {
            try {
                const file = 'D:/GitHome/Temp/导出PDF_格式样本1.js';
                const tplObj = JSON.parse(fs.readFileSync(file, 'utf-8'));
                ctx.body = { data: tplObj };
                ctx.status = 201;
            } catch (ex) {
                this.setMessage(ex.toString(), this.messageType.ERROR);
            }
        }

        /**
         * 获取多批次报表数据
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        async getMultiReportsEx(ctx) {
            // 原则说明：把所有报表模板集中获取，统一filter，只读一次数据！
            const params = JSON.parse(ctx.request.body.params);
            const pageShow = ctx.session.sessionProject.page_show;
            if (pageShow !== null
                && pageShow !== undefined
                && params.outputType
                && ((params.outputType === 'PDF' && parseInt(pageShow.closeExportPdf) === 1)
                    || (params.outputType === 'Excel' && parseInt(pageShow.closeExportExcel) === 1)
                )
            ) {
                ctx.body = { data: [], signatureRelInfo: [], stageAudit: [] };
                ctx.status = 201;
                return;
            }
            if (params.stage_id > 0) {
                await this._saveCustomSelects(params);
            }
            // const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir) || [];
            const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir) || [];
            for (const pageRst of pageRstArr) {
                for (const page of pageRst.items) {
                    page[JV.PROP_WATERMARK_CELLS] = [];
                }
            }
            let waterMarkStr = null;
            if (params.stage_status !== 3 && params.closeWatermark === 0) {
                // 加水印
                fillWaterMark(pageRstArr);
                if (params.needWaterMark) {
                    waterMarkStr = await getWatermarkPicData(pageRstArr[0], this.app.baseDir);
                }
            }

            const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id, params.business_id); // 新需求：在审批流程中的签名需要显示
            roleRel.sort(function(rr1, rr2) {
                return params.rpt_ids.indexOf(parseInt(rr1.rpt_id)) - params.rpt_ids.indexOf(parseInt(rr2.rpt_id));
            });

            let stgAudit = null,
                stageList = [];
            if (params.stage_id > 0) {
                stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
                stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
            } else if ([-100, -200].includes(params.stage_id)) {
                stgAudit = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id);
                const paymentDetailList = await ctx.service.paymentDetail.getDetail(params.detail_id);
                if (paymentDetailList && paymentDetailList.length > 0) {
                    const payment = paymentDetailList[0];
                    stageList.push({ id: params.stage_id, user_id: payment.uid, status: payment.status });
                }
            } else if ([-300, -301, -302, -303].includes(params.stage_id)) {
                stgAudit = [];
                await this._commonGetAudit(ctx, params, stgAudit);
                this._mergeBlankRoleSignDate(roleRel, stgAudit);
            }

            mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRel, params.rpt_ids, stgAudit, stageList);
            mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRel, params.rpt_ids, stgAudit, stageList, !!params.closeArchiveSignature, !!params.isArchive);

            await encodeSignatureDataUri(roleRel, this.app.baseDir);
            if (params.getPicFlag) {
                for (const pageRst of pageRstArr) {
                    await encodeDummySignatureDataUri(pageRst, this.app.baseDir); // 注意草图数据量问题！
                }
            }
            // console.log(pageRstArr);
            ctx.body = { data: pageRstArr, signatureRelInfo: roleRel, stageAudit: stgAudit, waterMarkStr };
            ctx.status = 201;
        }

        async _saveCustomSelects(params) {
            for (const [i, cs] of params.customSelect.entries()) {
                if (!cs) continue;
                cs.tender_id = params.tender_id;
                cs.stage_id = params.stage_id;
                cs.rpt_tpl_id = params.rpt_ids[i];
                await this.ctx.service.rptCustomDefine.saveCustomSelect(cs);
            }
        }

        async createExcelFilesEx(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            const pageShow = ctx.session.sessionProject.page_show;
            if (pageShow !== null && pageShow !== undefined && parseInt(pageShow.closeExportExcel) === 1) {
                ctx.body = { data: [] };
                ctx.status = 201;
                return;
            }
            await this._saveCustomSelects(params);
            const baseDir = this.app.baseDir;
            function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
                return new Promise(function(resolve, reject) {
                    rpt_xl_util.exportExcel(pageRst, params.pageSize, rpt_name, params.isOneSheet, null, null, baseDir, innerRoleRel,
                        (err, uuidName) => {
                            if (err) return reject(err);
                            const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
                            resolve(fileRst);
                        }
                    );
                });
            }
            // const stgAudit = (params.stage_status === 3) ? (await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times)) : [];
            const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
            const stgAuditForOrg = (params.stage_status === 3) ? (await ctx.service.stageAudit.getStageAudit(params.stage_id, 1)) : [];
            // const stageList = (params.stage_status === 3) ? (await ctx.service.stage.getValidStagesShort(params.tender_id)) : [];
            const stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);

            const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id, params.business_id)) : [];
            const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, baseDir);
            // console.log('params.stage_status: ' + params.stage_status);
            // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/testBuiltPageResult1.js');
            for (const pageRst of pageRstArr) {
                for (const page of pageRst.items) {
                    page[JV.PROP_WATERMARK_CELLS] = [];
                }
            }
            let waterMarkStr = null;
            if (params.stage_status !== 3 && params.closeWatermark === 0) {
            // if (params.stage_status !== 3 && params.closeWatermark === 0 && params.option === JV.PAGING_OPTION_NORMAL) {
                // 加水印（注意：还得看用户设置是否需要加水印）
                fillWaterMark(pageRstArr);
                if (params.needWaterMark) {
                    waterMarkStr = await getWatermarkPicData(pageRstArr[0], baseDir);
                }
            }

            mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
            mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);

            await this.ctx.helper.recursiveMkdirSync(baseDir + '/app/public/download');

            const runnableRst = [];
            // 1. merge签名相关信息
            const pageBrkSize = 62914560; // 60M, 1024*1024*6*10
            for (let idx = 0; idx < pageRstArr.length; idx++) {
                let roleRel = null;
                for (const roleR of roleRelArr) {
                    if (roleR.rpt_id === params.rpt_ids[idx]) {
                        roleRel = JSON.parse(roleR.rel_content);
                        break;
                    }
                }
                if (params.stage_status === 3) {
                    mergeSignAudit(pageRstArr[idx], roleRel, stgAudit);
                    mergeSignDate(pageRstArr[idx], params.stage_id, roleRel, stgAudit, stgAuditForOrg, stageList);
                }

                // 2. 判断草图大小是否需要分页
                const picSize = await _chkRawPicSize(pageRstArr[idx], baseDir);
                // const picSize = 262914560; // 测试用，强制分页
                if (picSize > pageBrkSize) {
                    // let pageBrkAmt = Math.ceil(picSize / pageBrkSize);
                    let pageBrkAmt = Math.floor(pageRstArr[idx].items.length / Math.ceil(picSize / pageBrkSize));
                    if (pageBrkAmt < 10) {
                        // 不用管
                    } else if (pageBrkAmt < 100) {
                        pageBrkAmt = Math.floor(pageBrkAmt / 10) * 10;
                    } else if (pageBrkAmt < 1000) {
                        pageBrkAmt = Math.floor(pageBrkAmt / 100) * 100;
                    } else {
                        // 暂时不管
                    }
                    const newRptNames = []; // 这个为导出控制分页用
                    const newPageDataRst = _resetPageDataByBreaks([pageRstArr[idx]], pageBrkAmt, [params.rpt_names[idx]], newRptNames);
                    for (let dtlIdx = 0; dtlIdx < newPageDataRst.length; dtlIdx++) {
                        runnableRst.push(getExcelByPageData(newPageDataRst[dtlIdx], newRptNames[dtlIdx], roleRel));
                    }
                } else {
                    runnableRst.push(getExcelByPageData(pageRstArr[idx], params.rpt_names[idx], roleRel));
                }
            }
            // */
            // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/计量导出pageArr.js');
            const uuidRst = await Promise.all(runnableRst);
            ctx.body = { data: uuidRst, waterMarkStr };
            ctx.status = 201;
        }

        _getExcelByPageData(pageRst, rpt_name, pageSize, baseDir, innerRoleRel) {
            return new Promise(function(resolve, reject) {
                rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, true, null, null, baseDir, innerRoleRel,
                    (err, uuidName) => {
                        if (err) return reject(err);
                        const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
                        resolve(fileRst);
                    }
                );
            });
        }

        async createExcelFilesFromDirectData(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            const names = params.rptNames;
            const pageDataArr = params.pageData;
            const runnableRst = [];
            for (let idx = 0; idx < names.length; idx++) {
                runnableRst.push(this._getExcelByPageData(pageDataArr[idx], names[idx], 'A4', this.app.baseDir, null));
            }
            const uuidRst = await Promise.all(runnableRst);
            ctx.body = { data: uuidRst, waterMarkStr: null };
            ctx.status = 201;
        }

        async createExcelFilesFromLocal(ctx) {
            const baseDir = this.app.baseDir;
            function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
                return new Promise(function(resolve, reject) {
                    rpt_xl_util.exportExcel(pageRst, 'A4', rpt_name, true, null, null, baseDir, innerRoleRel,
                        (err, uuidName) => {
                            if (err) return reject(err);
                            const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
                            resolve(fileRst);
                        }
                    );
                });
            }
            try {
                console.log('start:');
                const pageRst = JSON.parse(fs.readFileSync('D:/GitHome/temp/计量excel原始数据_A3BZ6_5384_112表(清单).js', 'utf-8'));
                console.log('read it');
                const runnableRst = [];

                const pageBrkSize = 6291456; // 6M, 1024*1024*6
                // const pageBrkSize = 1048576; // 1M, 1024*1024*1
                console.log('pageBrkSize:' + pageBrkSize);
                const picSize = await _chkRawPicSize(pageRst, baseDir);
                console.log('picSize:' + picSize);
                if (picSize > pageBrkSize) {
                    let pageBrkAmt = Math.floor(pageRst.items.length / Math.ceil(picSize / pageBrkSize));
                    console.log('pageBrkAmt:' + pageBrkAmt);
                    if (pageBrkAmt < 10) {
                        // 不用管
                    } else if (pageBrkAmt < 100) {
                        pageBrkAmt = Math.floor(pageBrkAmt / 10) * 10;
                    } else if (pageBrkAmt < 1000) {
                        pageBrkAmt = Math.floor(pageBrkAmt / 100) * 100;
                    } else {
                        // 暂时不管
                    }
                    const newRptNames = []; // 这个为导出控制分页用
                    const newPageDataRst = _resetPageDataByBreaks([pageRst], pageBrkAmt, ['工程计量表(计量单元-清单)'], newRptNames);
                    for (let dtlIdx = 0; dtlIdx < newPageDataRst.length; dtlIdx++) {
                        runnableRst.push(getExcelByPageData(newPageDataRst[dtlIdx], newRptNames[dtlIdx], null));
                    }
                } else {
                    runnableRst.push(getExcelByPageData(pageRst, '工程计量表(计量单元-清单)', null));
                }


                const uuidRst = await Promise.all(runnableRst);
                ctx.body = { data: uuidRst, waterMarkStr: null };
                ctx.status = 201;
            } catch (ex) {
                console.log(ex.toString());
                ctx.status = 500;
            }
        }

        async createExcelFilesInOneBookEx(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            const baseDir = this.app.baseDir;
            function getExcelByPageData(pageRstArr, rpt_name, innerRoleRel) {
                return new Promise(function(resolve, reject) {
                    rpt_xl_util.exportExcelInOneBook(pageRstArr, params.pageSize, rpt_name, baseDir, innerRoleRel,
                        (err, uuidName) => {
                            if (err) return reject(err);
                            const fileRst = { uuid: uuidName, reportName: rpt_name };
                            resolve(fileRst);
                        }
                    );
                });
            }
            const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id)) : [];
            // console.log(`baseDir: ${baseDir}`);
            // fsUtil.writeObjToFile(roleRelArr, 'D:/GitHome/temp/签名信息.js');
            const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
            const stgAuditForOrg = await ctx.service.stageAudit.getStageAudit(params.stage_id, 1);
            const stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);

            // const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
            const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
            // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/pageRstArrForExcel.js');
            for (const pageRst of pageRstArr) {
                for (const page of pageRst.items) {
                    page[JV.PROP_WATERMARK_CELLS] = [];
                }
            }
            let waterMarkStr = null;
            if (params.stage_status !== 3 && params.closeWatermark === 0) {
            // if (params.stage_status !== 3 && params.closeWatermark === 0 && params.option === JV.PAGING_OPTION_NORMAL) {
                // 加水印
                fillWaterMark(pageRstArr);
                if (params.needWaterMark) {
                    waterMarkStr = await getWatermarkPicData(pageRstArr[0], this.app.baseDir);
                }
            }
            mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
            mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
            await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
            const runnableRst = [];
            let rptRoleRelArr = [];
            const reAssignSignatureName = function(pageData, roleRel, rpt_name_key) {
                const keyMap = {};
                for (const pageItem of pageData.items) {
                    for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
                        if (!keyMap.hasOwnProperty(signCell.signature_name)) {
                            keyMap[signCell.signature_name] = rpt_name_key + '_' + signCell.signature_name;
                        }
                    }
                }
                for (const pageItem of pageData.items) {
                    for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
                        if (keyMap.hasOwnProperty(signCell.signature_name)) {
                            signCell.signature_name = keyMap[signCell.signature_name];
                        }
                    }
                }
                for (const roleSign of roleRel) {
                    if (keyMap.hasOwnProperty(roleSign.signature_name)) {
                        roleSign.signature_name = keyMap[roleSign.signature_name];
                    }
                }
                // console.log('keyMap of : ' + rpt_name_key);
                // console.log(keyMap);
            };
            for (let idx = 0; idx < pageRstArr.length; idx++) {
                let roleRel = null;
                for (const roleR of roleRelArr) {
                    if (roleR.rpt_id === params.rpt_ids[idx]) {
                        roleRel = JSON.parse(roleR.rel_content);
                        if (params.stage_status === 3) {
                            mergeSignAudit(pageRstArr[idx], roleRel, stgAudit);
                            mergeSignDate(pageRstArr[idx], params.stage_id, roleRel, stgAudit, stgAuditForOrg, stageList);
                        }
                        // 这里要做些电子签名的signature_name转换，以防重名
                        reAssignSignatureName(pageRstArr[idx], roleRel, params.rpt_names[idx]);
                        rptRoleRelArr = rptRoleRelArr.concat(roleRel);
                        break;
                    }
                }
            }
            // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/pageRstArrForExcelAfterReAssign.js');
            // fsUtil.writeObjToFile(rptRoleRelArr, 'D:/GitHome/temp/签名信息_新.js');
            runnableRst.push(getExcelByPageData(pageRstArr, params.rptName, rptRoleRelArr));
            const uuidRst = await Promise.all(runnableRst);
            ctx.body = { data: uuidRst, waterMarkStr };
            ctx.status = 201;
        }

        async getFileByUUID(ctx) {
            // console.log('downloading : ' + ctx.params.uuid);
            const uuid = ctx.params.uuid;
            const rptName = ctx.params.rptName;
            const suffix = '.' + ctx.params.suffix;
            try {
                const rptNameURI = encodeURI(rptName);
                const filePath = this.app.baseDir + '/app/public/download/';
                // console.log('filePath: ' + filePath);
                // await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
                ctx.set({
                    'Content-Type': 'application/vnd.openxmlformats',
                    'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
                });
                ctx.body = await fs.readFileSync(filePath + uuid + suffix);
            } catch (e) {
                console.log(e);
            }
        }

        /**
         * 更新用户通用报表显示配置
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        async updateCustNode(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            // console.log(params);
            const custId = this.ctx.session.sessionUser.accountId;
            const newNodeItems = params.nodeItems;
            const custSelectKeys = params.custSelectKeys;
            const rst = await ctx.service.rptTreeNodeCust.updateCustNode(custId, newNodeItems, custSelectKeys);
            // console.log(rst);
            ctx.body = { data: rst };
            // ctx.body = { data: { msg: 'test the network' } };
            ctx.status = 201;
        }

        async setCustomDefine(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                await this.ctx.service.rptCustomDefine.saveCustomSelect(data);
                const result = await this._getReport(ctx, data);
                ctx.body = { err: 0, msg: '', data: result };
            } catch (err) {
                ctx.helper.log(err);
                ctx.body = this.ajaxErrorBody(err, '保存数据出错');
            }
        }
    }
    return ReportController;
};

function isFileExisted(file) {
    return new Promise(function(resolve, reject) {
        fs.access(file, err => {
            if (err) {
                reject(false);
            } else {
                resolve(true);
            }
        });
    });
}

function fillWaterMark(pageRstArray) {
    const orgWaterMarkWidth = 600;
    const orgWaterMarkHeight = 288;
    const createWaterCell = function(area) {
        const w = area[JV.PROP_RIGHT] - area[JV.PROP_LEFT];
        const h = area[JV.PROP_BOTTOM] - area[JV.PROP_TOP];
        const left = Math.round(area[JV.PROP_LEFT] + w / 2 - orgWaterMarkWidth / 2);
        const right = left + orgWaterMarkWidth;
        const top = Math.round(area[JV.PROP_TOP] + h / 2 - orgWaterMarkHeight / 2);
        const bottom = top + orgWaterMarkHeight;
        return {
            signature_name: JV.SIGNATURE_NAME_DUMMY_WATER_MARK,
            path: '/public/images/not_Approve.png',
            sign_path: '/public/images/not_Approve.png',
            pic: null,
            control: 'Title',
            style: 'Default_None',
            area: {
                Left: left,
                Right: right,
                Top: top,
                Bottom: bottom,
            },
        };
    };
    for (const pageRst of pageRstArray) {
        for (const page of pageRst.items) {
            page[JV.PROP_WATERMARK_CELLS] = [];
            if (page[JV.PROP_PAGE_MERGE_BORDER]) {
                const wmCell = createWaterCell(page[JV.PROP_PAGE_MERGE_BORDER]);
                page[JV.PROP_WATERMARK_CELLS].push(wmCell);
            } else if (page[JV.PAGE_SPECIAL_MERGE_POS]) {
                if (page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT]) {
                    for (let i = 0; i < page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT].length; i++) {
                        const area = {};
                        area[JV.PROP_LEFT] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT][i];
                        area[JV.PROP_RIGHT] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_RIGHT][i];
                        area[JV.PROP_TOP] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_TOP][i];
                        area[JV.PROP_BOTTOM] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_BOTTOM][i];
                        const wmCell = createWaterCell(area);
                        page[JV.PROP_WATERMARK_CELLS].push(wmCell);
                    }
                }
            }
        }
    }
}

async function encodeSignatureDataUri(roleRel, baseDir) {
    if (roleRel) {
        for (const singleRoleRel of roleRel) {
            if (singleRoleRel.rel_content !== null && singleRoleRel.rel_content !== undefined && singleRoleRel.rel_content !== '') {
                const roleRelContent = JSON.parse(singleRoleRel.rel_content);
                for (const role of roleRelContent) {
                    // console.log(role);
                    if (role.sign_path !== '') {
                        const filePath = baseDir + '/app' + role.sign_path;
                        try {
                            const res = await isFileExisted(filePath);
                            if (res) {
                                const bData = fs.readFileSync(filePath);
                                const base64Str = bData.toString('base64');
                                const datauri = 'data:image/png;base64,' + base64Str;
                                role.sign_pic = datauri;
                            } else {
                                console.log('文件不存在：' + filePath);
                            }
                        } catch (err) {
                            console.error(err);
                        }
                    }
                }
                singleRoleRel.rel_content = JSON.stringify(roleRelContent);
            } else {
                singleRoleRel.rel_content = [];
            }
        }
    }
}

async function encodeDummySignatureDataUri(pageRst, baseDir) {
    if (pageRst) {
        for (const page of pageRst.items) {
            for (const signature of page[JV.PROP_SIGNATURE_CELLS]) {
                if (signature.signature_name === JV.SIGNATURE_NAME_DUMMY) {
                    if (signature.path !== '') {
                        const filePath = baseDir + '/app' + signature.path;
                        try {
                            const res = await isFileExisted(filePath);
                            if (res) {
                                const bData = fs.readFileSync(filePath);
                                const base64Str = bData.toString('base64');
                                const datauri = 'data:image/png;base64,' + base64Str;
                                signature.pic = datauri;
                                signature.path = '';
                            } else {
                                console.log('文件不存在：' + filePath);
                            }
                        } catch (err) {
                            console.error(err);
                        }
                    }
                }
            }
            // 考虑优化，水印只需要一张即可，不需要每页都设置
            // for (const signature of page[JV.PROP_WATERMARK_CELLS]) {
            //     if (signature.path !== '') {
            //         const filePath = baseDir + '/app' + signature.path;
            //         try {
            //             const res = await isFileExisted(filePath);
            //             if (res) {
            //                 const bData = fs.readFileSync(filePath);
            //                 const base64Str = bData.toString('base64');
            //                 const datauri = 'data:image/png;base64,' + base64Str;
            //                 signature.pic = datauri;
            //                 signature.path = '';
            //             } else {
            //                 console.log('文件不存在：' + filePath);
            //             }
            //         } catch (err) {
            //             console.error(err);
            //         }
            //     }
            // }
        }
    }
}

async function getWatermarkPicData(pageRst, baseDir) {
    if (pageRst) {
        for (const page of pageRst.items) {
            for (const signature of page[JV.PROP_WATERMARK_CELLS]) {
                if (signature.path !== '') {
                    const filePath = baseDir + '/app' + signature.path;
                    try {
                        const res = await isFileExisted(filePath);
                        if (res) {
                            const bData = fs.readFileSync(filePath);
                            const base64Str = bData.toString('base64');
                            return 'data:image/png;base64,' + base64Str;
                        }
                    } catch (err) {
                        console.error(err);
                    }
                }
            }
        }
    }
    return '';
}

function mergeTextSignature(isTxtSignature, status, pageData, singleRoleRel, rpt_ids, stgAudit, stageList, closeArchiveSignature = false, isArchive = false) {
    // 依据需求，有些用户不需要签名图片，那么从源头上把签名从signature_cells转移到cells下，省得后续 预览、打印、导出PDF、导出EXCEL每个地方都改动
    const _mergeSingle = function(_page, _roleRelList, isDeleteSignCell, checkAudit = false) {
        // console.log(_roleRelList);
        let roleRelContent = [];
        if (_roleRelList && _roleRelList.rel_content !== null && _roleRelList.rel_content !== undefined && _roleRelList.rel_content !== '') {
            roleRelContent = JSON.parse(_roleRelList.rel_content);
        }
        for (const page of _page.items) {
            if (page.signature_cells) {
                const deleteSCellsIdx = [];
                for (let scIdx = 0; scIdx < page.signature_cells.length; scIdx++) {
                    const sCell = page.signature_cells[scIdx];
                    if (sCell.signature_name !== JV.SIGNATURE_NAME_DUMMY) {
                        sCell.Value = ''; // 这里要先清除原有信息
                        sCell.path = '';
                        sCell.pic = '';
                        let needTransferText = true;
                        for (const role_rel of roleRelContent) {
                            if (sCell.signature_name === role_rel.signature_name) {
                                if (!checkAudit || _chkIfAudit(role_rel, stgAudit || [], stageList || [])) {
                                    sCell.Value = role_rel.user_name; // 只有审核通过了才需要文本签名内容
                                    if (role_rel.sign_output && role_rel.sign_output.indexOf(NORMAL_SIGN_STR) < 0) {
                                        // 用户选择不签名，则不迁移
                                        needTransferText = false;
                                    }
                                    break;
                                }
                            }
                        }

                        if (needTransferText) {
                            const newCell = {
                                font: 'Footer',
                                control: sCell.control,
                                style: sCell.style,
                                Value: sCell.Value,
                                area: { Left: sCell.area.Left, Right: sCell.area.Right, Top: sCell.area.Top, Bottom: sCell.area.Bottom },
                            };
                            if (isArchive && closeArchiveSignature) {
                                // 如果正在归档 且 归档不显示签名标记为true时，不输出文本签名，但要有这个空格子(边框用)
                                newCell.Value = '';
                            }
                            page.cells.push(newCell); // 迁移
                            deleteSCellsIdx.push(scIdx);
                        }
                    }
                }
                // 删除 page.signature_cells 签名(草图不能删);
                // console.log('isDeleteSignCell: ' + isDeleteSignCell);
                // console.log(deleteSCellsIdx);
                if (isDeleteSignCell) {
                    for (let dIdx = deleteSCellsIdx.length - 1; dIdx >= 0; dIdx--) {
                        page.signature_cells.splice(deleteSCellsIdx[dIdx], 1);
                    }
                }
            }
        }
    };
    if (isTxtSignature) {
        if (pageData instanceof Array) {
            pageData.forEach((dtlPage, index) => {
                let dftRolRel = [];
                const rpt_id = rpt_ids[index];
                for (const roleRel of singleRoleRel) {
                    if (roleRel.rpt_id === rpt_id) {
                        dftRolRel = roleRel;
                    }
                }
                // _mergeSingle(dtlPage, dftRolRel, true, status !== 3);
                _mergeSingle(dtlPage, dftRolRel, false, status !== 3); // 因加了个标记(归档不输出签名)，前端做了大量的签名处理工作，导致现在不能删除，否则还会出现遗漏
            });
        } else {
            _mergeSingle(pageData, singleRoleRel, false, status !== 3);
        }
    }
}

function _chkIfAudit(role_rel, STAGE_AUDIT = [], STAGE_LIST = []) {
    let rst = false;
    for (const stg_audit of STAGE_AUDIT) {
        if (role_rel.acc_id === stg_audit.aid) {
            if (stg_audit.status === 3) {
                rst = true;
            } else {
                rst = false;
            }
            // break; //因为实际业务中会有反复，所以就不break了，一直判断，以最后一个为准
        }
    }
    if (!rst) {
        // 还有原报需要检测
        for (const stg_ort_rpt of STAGE_LIST) {
            if (role_rel.acc_id === stg_ort_rpt.user_id) {
                if (stg_ort_rpt.status !== 1 && stg_ort_rpt.status !== 4) {
                    // 只要不是待上报(1)、退回审批(4) 状态,都需要显示
                    rst = true;
                } else {
                    rst = false;
                }
                // break; //因为实际业务中会有反复，所以就不break了，一直判断，以最后一个为准
            }
        }
    }
    // rst = true; //测试，未来将屏蔽
    return rst;
}

// 因机制问题，此方法必须在mergeTextSignature之前调用
async function mergeStampSignature(ctx, status, pageData, singleRoleRel, rpt_ids, stgAudit, stageList) {
    const dupPicPaths = [];
    const _getMaxRect = function(page) {
        const rect = [100000000, 100000000, 0, 0];
        for (const cell of page.cells) {
            rect[0] = rect[0] > cell.area.Left ? cell.area.Left : rect[0];
            rect[1] = rect[1] > cell.area.Top ? cell.area.Top : rect[1];
            rect[2] = rect[2] < cell.area.Right ? cell.area.Right : rect[2];
            rect[3] = rect[3] < cell.area.Bottom ? cell.area.Bottom : rect[3];
        }
        for (const sCell of page.signature_cells) {
            rect[0] = rect[0] > sCell.area.Left ? sCell.area.Left : rect[0];
            rect[1] = rect[1] > sCell.area.Top ? sCell.area.Top : rect[1];
            rect[2] = rect[2] < sCell.area.Right ? sCell.area.Right : rect[2];
            rect[3] = rect[3] < sCell.area.Bottom ? sCell.area.Bottom : rect[3];
        }
        return rect;
    };
    const createStampArea = function(orgCell, controls, maxRect) {
        const ctrl = controls[orgCell.control];
        const rst = { Left: orgCell.area.Left, Right: orgCell.area.Right, Top: orgCell.area.Top, Bottom: orgCell.area.Bottom };
        let pLeft = orgCell.area.Left,
            pTop = orgCell.area.Top;
        switch (ctrl[JV.CONTROL_PROPS[JV.CONTROL_PROP_IDX_HORIZON]]) {
            case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_LEFT]:
                pLeft = orgCell.area.Left;
                break;
            case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_CENTER]:
                pLeft = (orgCell.area.Left + orgCell.area.Right - STD_COMP_STAMP_SIZE_WIDTH) / 2;
                break;
            case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_RIGHT]:
                pLeft = orgCell.area.Right - STD_COMP_STAMP_SIZE_WIDTH;
                break;
            default:break;
        }
        switch (ctrl[JV.CONTROL_PROPS[JV.CONTROL_PROP_IDX_VERTICAL]]) {
            case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_TOP]:
                pTop = orgCell.area.Top;
                break;
            case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_CENTER]:
                pTop = (orgCell.area.Top + orgCell.area.Bottom - STD_COMP_STAMP_SIZE_HEIGHT) / 2;
                break;
            case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_BOTTOM]:
                pTop = orgCell.area.Bottom - STD_COMP_STAMP_SIZE_HEIGHT;
                break;
            default:break;
        }
        rst.Left = pLeft;
        rst.Top = pTop;
        rst.Right = pLeft + STD_COMP_STAMP_SIZE_WIDTH;
        rst.Bottom = pTop + STD_COMP_STAMP_SIZE_WIDTH;
        // 最后一步，如超过报表范围，则要调整坐标
        // if (rst.Left < maxRect[0]) {
        //     const width = maxRect[0] - rst.Left;
        //     rst.Left += width;
        //     rst.Right += width;
        // }
        // if (rst.Top < maxRect[1]) {
        //     const height = maxRect[1] - rst.Top;
        //     rst.Top += height;
        //     rst.Bottom += height;
        // }
        // if (rst.Right > maxRect[2]) {
        //     const width = maxRect[2] - rst.Right; // 负
        //     rst.Left += width;
        //     rst.Right += width;
        // }
        // if (rst.Bottom > maxRect[3]) {
        //     const height = maxRect[3] - rst.Bottom;
        //     rst.Top += height;
        //     rst.Bottom += height;
        // }
        return rst;

    };
    const _mergeSingleStamp = async function(_page, _roleRelList, checkAudit = false) {
        let roleRelContent = [];
        if (_roleRelList && _roleRelList.rel_content !== null && _roleRelList.rel_content !== undefined && _roleRelList.rel_content !== '') {
            roleRelContent = JSON.parse(_roleRelList.rel_content);
        }
        for (const page of _page.items) {
            const maxRect = _getMaxRect(page);
            if (page.signature_cells) {
                const newStampCells = [];
                for (let scIdx = 0; scIdx < page.signature_cells.length; scIdx++) {
                    const sCell = page.signature_cells[scIdx];
                    for (const role_rel of roleRelContent) {
                        if (sCell.signature_name === role_rel.signature_name) {
                            if (!checkAudit || _chkIfAudit(role_rel, stgAudit || [], stageList || [])) {
                                if (Array.isArray(role_rel.sign_output) && role_rel.sign_output.length > 0) {
                                    for (const signType of role_rel.sign_output) {
                                        switch (signType) {
                                            case COMPANY_SIGN_STR:
                                            case PRIVATE_SIGN_STR:
                                                // 创建一个新的cell
                                                let stampPath = (signType === COMPANY_SIGN_STR) ? role_rel.company_stamp_path : role_rel.private_stamp_path;
                                                stampPath = ctx.app.config.fujianOssPath + stampPath;
                                                if (dupPicPaths.indexOf(stampPath) < 0) {
                                                    dupPicPaths.push(stampPath);
                                                    // await _chkRawPicSizeOSS(ctx, stampPath);
                                                }
                                                // 保存在签字信息中的签章信息
                                                let signatureArea;
                                                if (role_rel.areaData && role_rel.areaData[signType]) {
                                                    signatureArea = role_rel.areaData[signType];
                                                }

                                                const newStampCell = {
                                                    signature_name: JV.SIGNATURE_NAME_DUMMY,
                                                    control: sCell.control,
                                                    style: sCell.style,
                                                    path: stampPath,
                                                    isStamp: true,
                                                    maxRect,
                                                    orgArea: sCell.area,
                                                    area: signatureArea || createStampArea(sCell, _page[JV.NODE_CONTROL_COLLECTION], maxRect), // 有签章信息就直接取，没有的话就走原来的逻辑
                                                    signatureName: role_rel.signature_name, // 节点名称
                                                    signType, // 签章信息
                                                    isSaveSignature: !!signatureArea, // 是否有签章位置信息
                                                };
                                                newStampCells.push(newStampCell);
                                                break;
                                            default: break;
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
                if (newStampCells.length > 0) {
                    if (page.liftUpInfo) {
                        const tmpStampCells = [];
                        newStampCells.forEach(newStampCell => {
                            const tmpCell = JSON.parse(JSON.stringify(newStampCell));
                            tmpStampCells.push(tmpCell);
                            let adjustHeight = page.liftUpInfo.liftUpHeight;
                            const tmpTop = tmpCell.area.Top - adjustHeight;
                            if (tmpTop < 10) {
                                adjustHeight = adjustHeight - (10 - tmpTop);
                            }
                            tmpCell.area.Top = tmpCell.area.Top - adjustHeight;
                            tmpCell.area.Bottom = tmpCell.area.Bottom - adjustHeight;
                        });
                        page.signature_cells = page.signature_cells.concat(tmpStampCells);
                    } else {
                        page.signature_cells = page.signature_cells.concat(newStampCells);
                    }
                }
            }
        }
    };
    if (pageData instanceof Array) {
        pageData.forEach((dtlPage, index) => {
            let dftRolRel = [];
            const rpt_id = rpt_ids[index];
            for (const roleRel of singleRoleRel) {
                if (roleRel.rpt_id === rpt_id) {
                    dftRolRel = roleRel;
                }
            }
            _mergeSingleStamp(dtlPage, dftRolRel, status !== 3);
        });
    } else {
        _mergeSingleStamp(pageData, singleRoleRel, status !== 3);
    }
}

function mergeSignAudit(pageData, currRoleRelList, currAuditList) {
    for (const page of pageData.items) {
        if (page.signature_audit_cells) {
            for (const sCell of page.signature_audit_cells) {
                sCell.Value = ''; // 这里要先清除原有信息
                if (currRoleRelList && currRoleRelList.length > 0) {
                    for (const role_rel of currRoleRelList) {
                        if (sCell.signature_name === role_rel.signature_name + '_审核意见') {
                            let preDate = '';
                            sCell.Value = '同意'; // 只有选择了签名的，才需要初始化一个默认的意见(之前的逻辑在有多个签名，哪怕只选择了一个，其他的意见都会有默认意见)
                            if (currAuditList && currAuditList.length > 0) {
                                for (const audit_rel of currAuditList) {
                                    if (role_rel.acc_id === audit_rel.aid) {
                                        if (audit_rel.end_time > preDate && audit_rel.status === 3) {
                                            sCell.Value = audit_rel.opinion;
                                            preDate = audit_rel.end_time;
                                        }
                                        // 不能break，实际会有多个审核意见，以最后一个为准
                                    }
                                }
                            }
                            break;
                        }
                    }
                }
            }
        }
    }
}

function mergeSignDate(pageData, current_stage_id, currRoleRelList, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST) {
    if (currRoleRelList && currRoleRelList.length > 0 && STAGE_AUDIT && STAGE_AUDIT.length > 0) {
        for (let rridx = 0; rridx < currRoleRelList.length; rridx++) {
            const role_rel = currRoleRelList[rridx];
            if (role_rel.sign_date === undefined || role_rel.sign_date === null || role_rel.sign_date === '') {
                const dftDate = _getSignDateByAllScenarios(role_rel.acc_id, current_stage_id, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST);
                role_rel.sign_date = dftDate;
            }
        }
    }
    if (currRoleRelList && currRoleRelList.length > 0) {
        for (const page of pageData.items) {
            if (page.signature_date_cells) {
                for (const sCell of page.signature_date_cells) {
                    sCell.Value = _getSignDateDftName();
                    for (const role_rel of currRoleRelList) {
                        if (sCell.signature_name === role_rel.signature_name + '_签字日期') {
                            if (role_rel.sign_date !== '') {
                                if (typeof role_rel.sign_date === 'string') {
                                    role_rel.sign_date = new Date(role_rel.sign_date);
                                }
                                sCell.Value = role_rel.sign_date.Format(role_rel.sign_date_format);
                            }
                            break;
                        }
                    }
                }
            }
        }
    }
}

function _getSignDateByAllScenarios(userAccId, current_stage_id, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST) {
    let rst = '';
    let hasAudit = false;
    for (const stg_audit of STAGE_AUDIT) {
        if (stg_audit.aid === userAccId) {
            hasAudit = true;
            if (stg_audit.status === 3) {
                rst = stg_audit.end_time;
            } else {
                rst = '';
            }
            // break; //因为实际业务中会有反复，所以就不break了，一直判断，以最后一个为准
        }
    }
    let isOrgRpt = false;
    for (const stg of STAGE_LIST) {
        if (stg.id === current_stage_id) {
            if (stg.user_id === userAccId) {
                isOrgRpt = true;
            }
            break;
        }
    }
    if (isOrgRpt && !hasAudit && STAGE_AUDIT_ORG && STAGE_AUDIT_ORG.length > 0) {
        if (STAGE_AUDIT_ORG[0].begin_time && STAGE_AUDIT_ORG[0].begin_time !== '' && STAGE_AUDIT_ORG[0].begin_time.length > 20) {
            rst = STAGE_AUDIT_ORG[0].begin_time;
        }
    }
    if (!isOrgRpt && !hasAudit) {
        // 非审批流程人员以及非原报，则显示期截至时间
        for (const stg of STAGE_LIST) {
            if (stg.id === current_stage_id && stg.period) {
                const period = stg.period.split(' ~ ');
                if (period.length === 2) {
                    rst = period[1];
                }
            }
        }
    }
    return rst;
}

function _getSignDateDftName() {
    return '    年  月  日';
}

async function _chkRawPicSize(pageData, baseDir) {
    let rst = 0;
    const picKeys = [];
    for (let pi = 0; pi < pageData.items.length; pi++) {
        // 每页判断
        for (let ci = 0; ci < pageData.items[pi][JV.PROP_SIGNATURE_CELLS].length; ci++) {
            const picPath = pageData.items[pi][JV.PROP_SIGNATURE_CELLS][ci].path;
            // if (picPath && picPath.indexOf('/sign') < 0 && picKeys.indexOf(picPath) < 0) {
            if (picPath && picPath !== '' && picKeys.indexOf(picPath) < 0) {
                // 签名图片也要计算在内，反正不重复
                picKeys.push(picPath);
            }
            // signature_cells PROP_SIGNATURE_CELLS
        }
    }
    // console.log(picKeys);
    for (const pKey of picKeys) {
        const filePath = `${baseDir}/app${pKey}`;
        console.log('filePath: ' + filePath);
        let isExist = false;
        try {
            isExist = await isFileExisted(filePath);
        } catch (ex) {
            isExist = false;
        }
        console.log('isExist: ' + isExist);
        if (isExist) {
            const obj = fs.statSync(filePath);
            if (obj) {
                rst += obj.size;
            } else {
                console.log('no statSync resutl: ' + filePath);
            }
            // rst += fs.statSync(filePath).size;
        } else {
            console.log(`${pKey} not exists!`);
        }
    }
    return rst;
}

async function _chkRawPicSizeOSS(ctx, picPath) {
    // 计量的草图、签章都放在OSS服务器上，需要另外的方式来获取，考虑到效率问题，机制上得有所变化
    const rst = [0, 0];
    try {
        const pf = await ctx.app.signPdfOss.get(picPath);
        console.log('get pic successfully!');
        console.log(pf);
    } catch (ex) {
        console.log(ex);
    } finally {
        console.log('finally!');
    }
    return rst;
}

function _resetPageDataByBreaks(pageDataArr, breakAmt, rpt_names, newRptNames) {
    const rst = [];
    for (let pi = 0; pi < pageDataArr.length; pi++) {
        const pageItem = pageDataArr[pi];
        const currentRptName = rpt_names[pi];
        if (pageItem.items.length > breakAmt) {
            let pa = Math.floor(pageItem.items.length / breakAmt);
            if (pageItem.items.length % breakAmt > 0) {
                pa++;
            }
            for (let idx = 0; idx < pa; idx++) {
                const newPageDataObj = { items: [] };
                // newPageDataObj[JV.NODE_PAGE_INFO] = JSON.parse(JSON.stringify(pageItem[JV.NODE_PAGE_INFO]));
                newPageDataObj[JV.NODE_PAGE_INFO] = pageItem[JV.NODE_PAGE_INFO];
                // newPageDataObj[JV.BAND_PROP_MERGE_BAND] = JSON.parse(JSON.stringify(pageItem[JV.BAND_PROP_MERGE_BAND]));
                newPageDataObj[JV.BAND_PROP_MERGE_BAND] = pageItem[JV.BAND_PROP_MERGE_BAND];

                newPageDataObj[JV.NODE_FONT_COLLECTION] = pageItem[JV.NODE_FONT_COLLECTION];
                newPageDataObj[JV.NODE_STYLE_COLLECTION] = pageItem[JV.NODE_STYLE_COLLECTION];
                newPageDataObj[JV.NODE_CONTROL_COLLECTION] = pageItem[JV.NODE_CONTROL_COLLECTION];

                for (let dIdx = idx * breakAmt; dIdx < (Math.min((idx + 1) * breakAmt, pageItem.items.length)); dIdx++) {
                    newPageDataObj.items.push(pageItem.items[dIdx]);
                }
                rst.push(newPageDataObj);
                newRptNames.push(currentRptName + '_' + (idx + 1));
            }
        } else {
            rst.push(pageItem);
            newRptNames.push(currentRptName);
        }
    }
    return rst;
}