Calculation/app/service/sub_project.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date
 * @version
 */
const rootId = '-1';
const imType = require('../const/tender').imType;
const defaultFunRela = {
    banOver: true,
    hintOver: true,
    banMinusChangeBills: true,
    minusNoValue: true,
    lockPayExpr: false,
    showMinusCol: true,
    imType: imType.zl.value,
    needGcl: false,
    budgetZb: true,
    budgetCtrl: true,
};
const funSet = require('../const/fun_set');
const defaultFunSet = funSet.defaultInfo;
const pageShowConst = require('../const/sp_page_show').defaultSetting;
const shenpiConst = require('../const/sp_shenpi');
const defaultShenpi = shenpiConst.defaultInfo.shenpi;
const arrayInfo = ['shenpi'];

class DragTree {
    /**
     * 构造函数
     */
    constructor(setting) {
        // 无索引
        this.datas = [];
        // 以key为索引indexedDB
        this.items = {};
        // 以排序为索引
        this.nodes = [];
        // 根节点
        this.children = [];
        // 树设置
        this.setting = setting;
        if (!this.setting.itemsPre) this.setting.itemsPre = 'id_';
    }
    /**
     * 树结构根据显示排序
     */
    sortTreeNode(isResort) {
        const self = this;
        const addSortNodes = function (nodes) {
            if (!nodes) { return }
            for (let i = 0; i < nodes.length; i++) {
                self.nodes.push(nodes[i]);
                nodes[i].index = self.nodes.length - 1;
                if (!isResort) {
                    nodes[i].children = self.getChildren(nodes[i]);
                } else {
                    nodes[i].children.sort((a, b) => { return a[self.setting.order] - b[self.setting.order]; })
                }
                addSortNodes(nodes[i].children);
            }
        };
        this.nodes = [];
        if (!isResort) {
            this.children = this.getChildren();
        } else {
            this.children.sort((a, b) => { return a[self.setting.order] - b[self.setting.order]; });
        }
        addSortNodes(this.children);
    }
    /**
     * 加载数据(初始化), 并给数据添加部分树结构必须数据
     * @param datas
     */
    loadDatas(datas) {
        const self = this;
        // 清空旧数据
        this.items = {};
        this.nodes = [];
        this.datas = [];
        this.children = [];
        // 加载全部数据
        datas.sort(function (a, b) {
            return a[self.setting.level] - b[self.setting.level];
        });
        for (const data of datas) {
            const keyName = this.setting.itemsPre + data[this.setting.id];
            if (this.items[keyName]) continue;

            const item = JSON.parse(JSON.stringify(data));
            item.children = [];
            item.expanded = true;
            item.visible = true;
            if (item[this.setting.pid] === this.setting.rootId) {
                this.children.push(item);
            } else {
                const parent = this.getParent(item);
                if (!parent) continue;
                parent.children.push(item);
            }
            this.items[keyName] = item;
            this.datas.push(item);
        }
        this.children.sort((a, b) => { return a[self.setting.order] - b[self.setting.order]; });
        this.sortTreeNode(true);
    }

    getItemsByIndex(index) {
        return this.nodes[index];
    }
    getItems(id) {
        return this.items[this.setting.itemsPre + id];
    };

    getParent(node) {
        return this.getItems(node[this.setting.pid]);
    };
    getChildren(node) {
        const setting = this.setting;
        const pid = node ? node[setting.id] : setting.rootId;
        const children = this.datas.filter(function (x) {
            return x[setting.pid] === pid;
        });
        children.sort((a, b) => { return a[setting.order] - b[setting.order]; });
        return children;
    };
    isLastSibling(node) {
        const siblings = this.getChildren(this.getParent(node));
        return (siblings && siblings.length > 0) ? node[this.setting.order] === siblings[siblings.length - 1][this.setting.order] : false;
    };

    recursiveFun(children, fun) {
        if (!fun) return;
        if (!children || children.length === 0) return;

        for (const c of children) {
            this.recursiveFun(c.children, fun);
            fun(c);
        }
    }
}

module.exports = app => {
    class SubProject extends app.BaseService {

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @param {String} tableName - 表名
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'sub_project';
            // const fileType = [{ key: 'file', value: 1, name: '资料归集'}, { key: 'info_progress', value: 2, name: '项目概况-阶段进度'}]
            this.FileReferenceType = { file: 1, info_progress: 2};
        }

        /**
         * 数据规则
         *
         * @param {String} scene - 场景
         * @return {Object} - 返回数据规则
         */
        rule(scene) {
            let rule = {};
            switch (scene) {
                case 'fun':
                    rule = {
                        imType: {type: 'enum', values: [imType.tz.value, imType.zl.value, imType.bb.value, imType.bw.value], required: true},
                        banOver: {type: 'bool', required: true,},
                        hintOver: {type: 'bool', required: true,},
                        banMinusChangeBills: {type: 'bool', required: true,},
                        minusNoValue: {type: 'bool', required: true,},
                        lockPayExpr: {type: 'bool', required: true,},
                        showMinusCol: {type: 'bool', required: true,},
                    };
                    break;
                default:
                    break;
            }
            return rule;
        }

        _filterEmptyFolder(data) {
            data.sort((a, b) => { return b.tree_level - a.tree_level});
            const result = [];
            for (const d of data) {
                if (!d.is_folder) result.push(d);
                if (result.find(x => { return x.tree_pid === d.id; })) result.push(d);
            }
            return result;
        }

        async getSubProject(pid, uid, admin, filterFolder = false) {
            let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });

            const permission = await this.ctx.service.subProjPermission.getUserPermission(pid, uid);
            result = result.filter(x => {
                if (x.is_folder) return !filterFolder;
                const pb = permission.find(y => { return x.id === y.spid});
                if (admin) {
                    x.tp_cache = pb && pb.tp_cache ? JSON.parse(pb.tp_cache) : {};
                    return true;
                }
                if (!pb) return false;
                x.user_permission = pb;
                x.tp_cache = pb.tp_cache ? JSON.parse(pb.tp_cache) : {};
                // 只要项目下添加了账号，就允许看到项目
                return true;
                // return x.user_permission.budget_permission.length > 0 || x.user_permission.file_permission.length > 0 || x.user_permission.manage_permission.length > 0;
            });
            return admin ? result : this._filterEmptyFolder(result);
        }

        async getSubProjectTreeNodes(pid, uid, admin, filterFolder = false) {
            const subProjects = await this.getSubProject(pid, uid, admin, filterFolder);
            const subProjectsTree = new DragTree({ id: 'id', pid: 'tree_pid', level: 'tree_level', order: 'tree_order', rootId: '-1' });
            subProjectsTree.loadDatas(subProjects);
            const result = subProjectsTree.nodes.map(x => {
                return {
                    id: x.id, tree_pid: x.tree_pid, tree_level: x.tree_level, is_folder: x.is_folder, name: x.name,
                    is_last_sibling: subProjectsTree.isLastSibling(x), has_children: x.children && x.children.length > 0,
                };
            });
            return result;
        }

        async getBudgetProject(pid, uid, admin) {
            let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });

            const adminPermission = this.ctx.service.subProjPermission.adminPermission;
            const permission = admin ? [] : await this.ctx.service.subProjPermission.getUserPermission(pid, uid);
            result = result.filter(x => {
                if (!x.is_folder && !x.budget_id) return false;
                if (x.is_folder) return true;
                if (admin) {
                    x.permission = adminPermission.budget_permission;
                    x.manage_permission = adminPermission.manage_permission;
                    return true;
                } else {
                    const pb = permission.find(y => { return x.id === y.spid});
                    if (!pb) return false;
                    x.permission = pb.budget_permission;
                    x.manage_permission = pb.manage_permission;
                    return x.permission.length > 0;
                }
            });
            return this._filterEmptyFolder(result);
        }

        async getFileProject(pid, uid, admin) {
            let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });

            const adminPermission = this.ctx.service.subProjPermission.adminPermission;
            const permission = await this.ctx.service.subProjPermission.getUserPermission(pid, uid);
            result = result.filter(x => {
                if (!x.is_folder && !x.management) return false;
                if (x.is_folder) return true;
                if (admin) {
                    x.permission = adminPermission.file_permission;
                    x.manage_permission = adminPermission.manage_permission;
                    return true;
                } else {
                    const pb = permission.find(y => { return x.id === y.spid});
                    if (!pb) return false;
                    x.permission = pb.file_permission;
                    x.manage_permission = pb.manage_permission;
                    return x.permission.length > 0;
                }
            });
            return this._filterEmptyFolder(result);
        }

        async getLastChild(tree_pid) {
            const result = await this.getAllDataByCondition({ where: { tree_pid, project_id: this.ctx.session.sessionProject.id }, orders: [['tree_order', 'desc']], limit: 1, offset: 0 });
            return result[0];
        }

        async getPosterityData(id){
            const result = [];
            let cur = await this.getAllDataByCondition({ where: { tree_pid: id, project_id: this.ctx.session.sessionProject.id } });
            let iLevel = 1;
            while (cur.length > 0 && iLevel < 6) {
                result.push(...cur);
                cur = await this.getAllDataByCondition({ where: { tree_pid: cur.map(x => { return x.id })} });
                iLevel += 1;
            }
            return result;
        }

        async getStepNode(node, step) {
            const tree_order = [];
            while(step) {
                tree_order.push(node.tree_order + step);
                if (step > 0) {
                    step = step - 1;
                } else {
                    step = step + 1;
                }
            }
            return await this.getAllDataByCondition({ where: { tree_pid: node.tree_pid, tree_order, project_id: this.ctx.session.sessionProject.id }, orders: [['tree_order', 'asc']]});
        }

        async addFolder(data) {
            const parent = await this.getDataById(data.tree_pid);
            if (parent && !parent.is_folder) throw '添加数据结构错误';
            const lastChild = await this.getLastChild(parent ? parent.id : rootId);

            const conn = await this.db.beginTransaction();
            try {
                // 获取当前用户信息
                const sessionUser = this.ctx.session.sessionUser;
                // 获取当前项目信息
                const sessionProject = this.ctx.session.sessionProject;

                const insertData = {
                    id: this.uuid.v4(), project_id: sessionProject.id, user_id: sessionUser.accountId,
                    tree_pid: data.tree_pid,
                    tree_level: parent ? parent.tree_level + 1 : 1,
                    tree_order: lastChild ? lastChild.tree_order + 1 : 1,
                    name: data.name, is_folder: 1,
                };
                const operate = await conn.insert(this.tableName, insertData);

                if (operate.affectedRows === 0) throw '新增文件夹失败';

                await conn.commit();
                return await this.getSubProject(sessionProject.id, sessionUser.accountId, sessionUser.is_admin);
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async addSubProject(data) {
            const parent = await this.getDataById(data.tree_pid);
            if (parent && !parent.is_folder) throw '添加数据结构错误';
            const lastChild = await this.getLastChild(parent ? parent.id : rootId);

            const conn = await this.db.beginTransaction();
            try {
                // 获取当前用户信息
                const sessionUser = this.ctx.session.sessionUser;
                // 获取当前项目信息
                const sessionProject = this.ctx.session.sessionProject;

                const insertData = {
                    id: this.uuid.v4(), project_id: sessionProject.id, user_id: sessionUser.accountId,
                    tree_pid: data.tree_pid,
                    tree_level: parent ? parent.tree_level + 1 : 1,
                    tree_order: lastChild ? lastChild.tree_order + 1 : 1,
                    name: data.name, is_folder: 0,
                };
                const operate = await conn.insert(this.tableName, insertData);
                // todo 根据节点新增时的其他操作

                if (operate.affectedRows === 0) throw '新增文件夹失败';

                await conn.commit();
                return await this.getSubProject(sessionProject.id, sessionUser.accountId, sessionUser.is_admin);
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async dragTo(data) {
            const dragNode = await this.getDataById(data.drag_id);
            const dropNode = await this.getDataById(data.drop_id);
            if (!dragNode || !dropNode || !dropNode.is_folder) throw '拖拽数据结构错误';
            const lastChild = await this.getLastChild(dropNode.id);
            const posterity = await this.getPosterityData(dragNode.id);

            const conn = await this.db.beginTransaction();
            try {
                const updateData = {
                    id: dragNode.id, tree_pid: dropNode.id, tree_level: dropNode.tree_level + 1,
                    tree_order: lastChild ? lastChild.tree_order + 1 : 1,
                };
                await conn.update(this.tableName, updateData);
                if (dragNode.tree_level !== dropNode.tree_level + 1 && posterity.length > 0) {
                    const posterityUpdateData = posterity.map(x => {
                        return { id: x.id, tree_level: dropNode.tree_level + 1 - dragNode.tree_level + x.tree_level }
                    });
                    await conn.updateRows(this.tableName, posterityUpdateData);
                }
                // 升级原来的后项的order
                await conn.query(`UPDATE ${this.tableName} SET tree_order = tree_order-1 WHERE tree_pid = ? AND tree_order > ?`, [dragNode.tree_pid, dragNode.tree_order]);
                await conn.commit();
            } catch (error) {
                await conn.rollback();
                throw error;
            }

            return await this.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin);
        }

        async _siblingMove(node, step) {
            const stepNode = await this.getStepNode(node, step);

            const conn = await this.db.beginTransaction();
            try {
                const updateData = [];
                updateData.push({ id: node.id, tree_order: node.tree_order + step });
                for (const sn of stepNode) {
                    updateData.push({ id: node.id, tree_order: step > 0 ? sn.tree_order - 1 : sn.tree_order + 1 });
                }
                await conn.updateRows(this.tableName, updateData);
                await conn.commit();
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async _siblingMoveForce(node, step) {
            const sibling = await this.getAllDataByCondition({ where: { tree_pid: node.tree_pid, project_id: this.ctx.session.sessionProject.id, is_delete: 0 }, orders: [['tree_order', 'asc']] });
            const nodeIndex = sibling.findIndex(x => { return x.id === node.id });
            if (nodeIndex + step < 0) throw '移动数据结构错误';
            if (nodeIndex + step > sibling.length - 1) throw '移动数据结构错误';

            const conn = await this.db.beginTransaction();
            try {
                const updateData = [];
                updateData.push({ id: node.id, tree_order: sibling[nodeIndex + step].tree_order });
                while(step) {
                    const stepNode = sibling[nodeIndex + step];
                    if (step > 0) {
                        updateData.push({ id: stepNode.id, tree_order: sibling[nodeIndex + step - 1].tree_order });
                        step = step - 1;
                    } else {
                        updateData.push({ id: stepNode.id, tree_order: sibling[nodeIndex + step + 1].tree_order});
                        step = step + 1;
                    }
                }
                await conn.updateRows(this.tableName, updateData);
                await conn.commit();
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async _topMove(node) {
            const lastChild = await this.getLastChild(rootId);
            const posterity = await this.getPosterityData(node.id);

            const conn = await this.db.beginTransaction();
            try {
                const updateData = { id: node.id, tree_pid: rootId, tree_level: 1, tree_order: lastChild ? lastChild.tree_order + 1 : 1 };
                await conn.update(this.tableName, updateData);
                if (node.tree_level !== 1 && posterity.length > 0) {
                    const posterityUpdateData = posterity.map(x => {
                        return { id: x.id, tree_level: x.tree_level - node.tree_level + 1 }
                    });
                    await conn.updateRows(this.tableName, posterityUpdateData);
                }
                // 升级原来的后项的order
                await conn.query(`UPDATE ${this.tableName} SET tree_order = tree_order-1 WHERE tree_pid = ? AND tree_order > ?`, [node.tree_pid, node.tree_order]);
                await conn.commit();
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async move(data) {
            const node = await this.getDataById(data.id);
            if (!node) throw '移动数据结构错误';

            switch(data.type) {
                case 'up': await this._siblingMoveForce(node, -1); break;
                case 'down': await this._siblingMoveForce(node, 1); break;
                case 'top': await this._topMove(node); break;
                default: throw '未知移动类型';
            }

            return await this.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin);
        }

        async del(id) {
            const node = await this.getDataById(id);
            if (!node) throw '删除的数据不存在';

            const posterity = await this.getPosterityData(node.id);
            const updateData = [
                { id: node.id, is_delete: 1 },
            ];
            posterity.forEach(x => {
                updateData.push({ id: x.id, is_delete: 1});
            });
            await this.db.updateRows(this.tableName, updateData);

            return await this.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin);
        }

        async save(data) {
            const result = await this.db.update(this.tableName, data);
            if (result.affectedRows > 0) {
                return data;
            } else {
                throw '更新数据失败';
            }
        }

        async setBudgetStd(data) {
            const subProject = await this.getDataById(data.id);
            const budgetStd = await this.ctx.service.budgetStd.getDataById(data.std_id);
            if (!budgetStd) throw '选择的概算标准不存在，请刷新页面重试';

            const conn = await this.db.beginTransaction();
            try {
                const budget_id = await this.ctx.service.budget.add(conn, {
                    pid: subProject.project_id, user_id: subProject.user_id, rela_tender: subProject.rela_tender
                }, budgetStd);
                const updateData = { id: data.id, std_id: budgetStd.id, std_name: budgetStd.name, budget_id };
                await conn.update(this.tableName, updateData);
                await conn.commit();
                return updateData;
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async setRelaTender(data) {
            const subProject = await this.getDataById(data.id);
            const orgRelaTenderId = subProject.rela_tender.split(',');
            const conn = await this.db.beginTransaction();
            try {
                await conn.update(this.tableName, data);
                await conn.update(this.ctx.service.budget.tableName, { id: subProject.budget_id, rela_tender: data.rela_tender });
                const relaTenderId = data.rela_tender.split(',');
                const removeTenderId = orgRelaTenderId.filter(x => { return relaTenderId.indexOf(x) < 0});
                const addTenderId = relaTenderId.filter(x => { return orgRelaTenderId.indexOf(x) < 0});
                if (removeTenderId.length > 0) await conn.update(this.ctx.service.tender.tableName, { spid: '' }, { where: { id: removeTenderId }});
                if (addTenderId.length > 0) await conn.update(this.ctx.service.tender.tableName, { spid: data.id }, { where: { id: addTenderId }});
                await conn.commit();
                return data;
            } catch (error) {
                await conn.rollback();
                throw error;
            }

        }

        async addRelaTender(transaction, spid, tid) {
            if (!transaction) throw '未定义事务';

            const subProject = await this.getDataById(spid);
            if (!subProject) throw '所属项目不存在';
            const rela = subProject.rela_tender.split(',');
            if (rela.indexOf(tid + '') >= 0) return;

            rela.push(tid + '');
            const rela_tender = rela.join(',');
            await transaction.update(this.tableName, { id: spid, rela_tender});
            await transaction.update(this.ctx.service.budget.tableName, { id: subProject.budget_id, rela_tender});
        }

        async removeRelaTender(transaction, spid, tid) {
            if (!transaction) throw '未定义事务';

            const subProject = await this.getDataById(spid);
            if (!subProject) throw '所属项目不存在';
            const rela = subProject.rela_tender.split(',');
            if (rela.indexOf(tid + '') < 0) return;

            const rela_tender = rela.filter(x => { return x === tid + ''}).join(',');
            await transaction.update(this.tableName, { id: spid, rela_tender});
            await transaction.update(this.ctx.service.budget.tableName, { id: subProject.budget_id, rela_tender});
        }

        async setManagement(data) {
            const subProject = await this.getDataById(data.id);
            if (subProject.management === data.management) return data;

            const users = await this.ctx.service.projectAccount.getAllDataByCondition({ where: { project_id: subProject.project_id, company: data.management }});
            const orgMember = await this.ctx.service.subProjPermission.getAllDataByCondition({ where: { spid: subProject.id } });
            const dm = [], um = [], im = [];

            const template = await this.ctx.service.filingTemplateList.getDataById(data.filingTemplate);
            if (!template) throw '选择的文件类别不存在';

            const templateFiling = await this.ctx.service.filingTemplate.getAllDataByCondition({
                where: { temp_id: template.id, is_fixed: 1 },
            });
            const filing_type = this.ctx.service.filing.analysisFilingType(templateFiling).map(x => { return x.value; }).join(','), file_permission = '1,2';
            for (const u of users) {
                const nm = orgMember.find(x => { return u.id === x.uid; });
                if (nm) {
                    if (!nm.file_permission) um.push({ id: nm.id, file_permission, filing_type });
                } else {
                    im.push({ id: this.uuid.v4(), spid: subProject.id, pid: subProject.project_id, uid: u.id, file_permission, filing_type });
                }
            }

            const conn = await this.db.beginTransaction();
            try {
                await conn.update(this.tableName, { id: subProject.id, management: data.management, filing_template_id: template.id, filing_template_name: template.name });
                await this.ctx.service.filing.initFiling(subProject.id, data.filingTemplate, conn);
                if (dm.length > 0) await conn.delete(this.ctx.service.subProjPermission.tableName, { id: dm });
                if (um.length > 0) await conn.updateRows(this.ctx.service.subProjPermission.tableName, um);
                if (im.length > 0) await conn.insert(this.ctx.service.subProjPermission.tableName, im);

                await conn.commit();
                return data;
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        async refreshManagementPermission(data) {
            const subProject = await this.getDataById(data.id);

            const users = await this.ctx.service.projectAccount.getAllDataByCondition({ where: { project_id: subProject.project_id, company: subProject.management }});
            const orgMember = await this.ctx.service.subProjPermission.getAllDataByCondition({ where: { spid: subProject.id } });
            const dm = [], um = [], im = [];
            const filing_type = this.ctx.service.filing.allFilingType.join(','), file_permission = '1,2';
            for (const u of users) {
                const nm = orgMember.find(x => { return u.id === x.uid; });
                if (nm) {
                    if (!nm.file_permission) um.push({ id: nm.id, file_permission, filing_type });
                } else {
                    im.push({ id: this.uuid.v4(), spid: subProject.id, pid: subProject.project_id, uid: u.id, file_permission, filing_type });
                }
            }
            const conn = await this.db.beginTransaction();
            try {
                if (dm.length > 0) await conn.delete(this.ctx.service.subProjPermission.tableName, { id: dm });
                if (um.length > 0) await conn.updateRows(this.ctx.service.subProjPermission.tableName, um);
                if (im.length > 0) await conn.insert(this.ctx.service.subProjPermission.tableName, im);

                await conn.commit();
                return { dm: dm.length, um: um.length, im: im.length };
            } catch (error) {
                await conn.rollback();
                throw error;
            }
        }

        // 合同管理获取项目列表
        async getSubProjectByContract(pid, uid, admin, filterFolder = false) {
            let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });
            if (admin) return this._filterEmptyFolder(result);

            const permission = await this.ctx.service.contractAudit.getAllDataByCondition({ where: { uid } });
            result = result.filter(x => {
                if (x.is_folder) return !filterFolder;
                const pb = permission.find(y => { return x.id === y.spid; });
                if (!pb) return false;
                return true;
            });
            return this._filterEmptyFolder(result);
        }

        async getSubProjectByTender(pid, tenders, filterFolder = false) {
            if (tenders.length === 0) return [];
            const spids = this._.uniq(this._.map(tenders, 'spid'));
            let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });
            result = result.filter(x => {
                if (x.is_folder) return !filterFolder;
                if (!x.rela_tender) return false;
                return this._.includes(spids, x.id);
            });
            return this._filterEmptyFolder(result);
        }

        // 合同管理获取项目列表
        // async getSubProjectByFinancial(pid, uid, admin, filterFolder = false) {
        //     let result = await this.getAllDataByCondition({ where: { project_id: pid, is_delete: 0 } });
        //     if (admin) return this._filterEmptyFolder(result);
        //
        //     const permission = await this.ctx.service.financialAudit.getAllDataByCondition({ where: { uid } });
        //     result = result.filter(x => {
        //         if (x.is_folder) return !filterFolder;
        //         const pb = permission.find(y => { return x.id === y.spid; });
        //         if (!pb) return false;
        //         return true;
        //     });
        //     return this._filterEmptyFolder(result);
        // }

        async getFileReference(subProject, file_type) {
            if (file_type) {
                return await this.db.query(`SELECT id, name FROM zh_file_reference_list WHERE file_type = ?`, [file_type]);
            } else {
                return await this.db.query(`SELECT id, name FROM zh_file_reference_list`);
            }
        };

        getPageShow(page_show) {
            const info = page_show ? JSON.parse(page_show) : {};
            for (const pi in pageShowConst) {
                info[pi] = info[pi] === undefined ? pageShowConst[pi] : parseInt(info[pi]);
                this.ctx.helper._.defaults(info[pi], pageShowConst[pi]);
            }
            return info;
        }

        getShenpi(shenpi) {
            const info = shenpi ? JSON.parse(shenpi) : {};
            for (const pi in defaultShenpi) {
                info[pi] = info[pi] === undefined ? defaultShenpi[pi] : parseInt(info[pi]);
                this.ctx.helper._.defaultsDeep(info[pi], defaultShenpi[pi]);
            }
            return info;
        }

        async updatePageshow(id, page_show = this.ctx.subProject.page_show, transaction = null) {
            const condition = { id, page_show: JSON.stringify(page_show) };
            const result = transaction ? await transaction.update(this.tableName, condition) : await this.db.update(this.tableName, condition);
            return result.affectedRows === 1;
        }

        /**
         * 功能设置
         * @param id
         * @returns {Promise<null>}
         */
        getFunRela(subProject) {
            const result = subProject.fun_rela ? JSON.parse(subProject.fun_rela) : {};
            this.ctx.helper._.defaults(result, defaultFunRela);
            return result;
        }

        async updateFunRela(id, data) {
            const result = await this.db.update(this.tableName, {
                id: id, fun_rela: JSON.stringify({
                    banOver: data.banOver, hintOver: data.hintOver, banMinusChangeBills: data.banMinusChangeBills,
                    imType: data.imType,
                    needGcl: data.needGcl, budgetCtrl: data.budgetCtrl, budgetZb: data.budgetZb,
                    minusNoValue: data.minusNoValue,
                    lockPayExpr: data.lockPayExpr, showMinusCol: data.showMinusCol, ledgerAss: data.ledgerAss,
                }),
            });
            return result.affectedRows === 1;
        }

        getFunSet(fun_set = null) {
            const result = fun_set ? JSON.parse(fun_set) : {};
            this.ctx.helper._.defaults(result, defaultFunSet);
            return result;
        }

        async updateFunSet(id, funSet) {
            const result = await this.db.update(this.tableName, {
                id, fun_set: JSON.stringify(funSet),
            });
            return result.affectedRows === 1;
        }

        async saveCommonJson(id, field, datas) {
            const subProject = await this.getDataById(id);
            subProject.common_json = subProject.common_json ? JSON.parse(subProject.common_json) : {};
            const updateData = {
                id,
            };
            subProject.common_json[field] = datas;
            updateData.common_json = JSON.stringify(subProject.common_json);
            const result = await this.db.update(this.tableName, updateData);
            return result.affectedRows === 1;
        }

        async saveCommonJsons(id, field, datas) {
            const subProject = await this.getDataById(id);
            subProject.common_json = subProject.common_json ? JSON.parse(subProject.common_json) : {};
            const updateData = {
                id,
            };
            const fields = field instanceof Array ? field : [field];
            for (const f of fields) {
                if (datas[f] !== undefined) subProject.common_json[f] = datas[f];
            }
            updateData.common_json = JSON.stringify(subProject.common_json);
            const result = await this.db.update(this.tableName, updateData);
            return result.affectedRows === 1;
        }

        async updateCommonJsonDaping06(subProject, projectData) {
            const categoryData = await this.ctx.service.category.getAllCategory(subProject);
            const projCommonJson = projectData.common_json ? JSON.parse(projectData.common_json) : null;
            const projDaping06Set = projCommonJson && projCommonJson.daPing06_set ? projCommonJson.daPing06_set : null;
            if (projDaping06Set) {
                const subProjDaping06Set = {};
                const orgCategoryData = await this.ctx.service.category.getOrgAllCategory(projectData.id);
                const orgCb = this._.find(orgCategoryData, { id: projDaping06Set.cb }) || null;
                const orgSr = this._.find(orgCategoryData, { id: projDaping06Set.sr }) || null;
                if (orgCb) {
                    const newCb = this._.find(categoryData, { name: orgCb.name });
                    if (newCb) {
                        subProjDaping06Set.cb = newCb.id;
                        const orgCbv = this._.find(orgCb.value, { id: projDaping06Set.cb_value }) || null;
                        if (orgCbv && orgCbv.value) {
                            const newCbv = this._.find(newCb.value, { value: orgCbv.value });
                            if (newCbv) {
                                subProjDaping06Set.cb_value = newCbv.id;
                            }
                        }
                    }
                }
                if (orgSr) {
                    const newSr = this._.find(categoryData, { name: orgSr.name });
                    if (newSr) {
                        subProjDaping06Set.sr = newSr.id;
                        const orgSrv = this._.find(orgSr.value, { id: projDaping06Set.sr_value }) || null;
                        if (orgSrv && orgSrv.value) {
                            const newSrv = this._.find(newSr.value, { value: orgSrv.value });
                            if (newSrv) {
                                subProjDaping06Set.sr_value = newSrv.id;
                            }
                        }
                    }
                }
                const newCbShow = [];
                const orgGlCategory = orgCategoryData.find(item => item.name === '管理类别');
                for (const d of projDaping06Set.cb_show) {
                    const org = orgGlCategory && orgGlCategory.value ? this._.find(orgGlCategory.value, { id: d }) || null : null;
                    if (org && org.value) {
                        const newGlCategory = categoryData.find(item => item.name === '管理类别');
                        const newOrg = newGlCategory && newGlCategory.value ? this._.find(newGlCategory.value, { value: org.value }) : '';
                        if (newOrg) {
                            newCbShow.push(newOrg.id);
                        }
                    }
                }
                subProjDaping06Set.cb_show = newCbShow;
                await this.saveCommonJson(subProject.id, 'daPing06_set', subProjDaping06Set);
                return JSON.stringify({ daPing06_set: subProjDaping06Set });
            }
        }

        async refreshTpCache(spid, user_id, is_admin) {
            const tp_cache = {};
            let permission = await this.ctx.service.subProjPermission.getDataByCondition({ spid: spid, uid: user_id });
            if (!permission && is_admin) {
                await this.db.insert(this.ctx.service.subProjPermission.tableName, {
                    id: this.uuid.v4(), spid, pid: this.ctx.session.sessionProject.id, uid: user_id
                });
                permission = await this.ctx.service.subProjPermission.getDataByCondition({ spid: spid, uid: user_id });
            }
            if (!permission) return tp_cache;


            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 subProject = await this.getDataById(spid);
            subProject.page_show = this.getPageShow(subProject.page_show);
            const tenders = await this.ctx.service.tender.getList('', userPermission, this.ctx.session.sessionUser.is_admin, '', subProject);
            for (const t of tenders) {
                await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
                tp_cache.contract_price = this.ctx.helper.add(tp_cache.contract_price, t.contract_price);
                if (t.ledger_tp) tp_cache.ledger_tp = this.ctx.helper.add(tp_cache.ledger_tp, t.ledger_tp.total_price);
                tp_cache.advance_tp = this.ctx.helper.add(tp_cache.advance_tp, t.advance_tp);
                tp_cache.change_tp = this.ctx.helper.add(tp_cache.change_tp, t.change_tp);

                if (!t.stage_tp) continue;
                tp_cache.contract_tp = this.ctx.helper.add(tp_cache.contract_tp, t.stage_tp.contract_tp);
                tp_cache.qc_tp = this.ctx.helper.add(tp_cache.qc_tp, t.stage_tp.qc_tp);
                tp_cache.positive_qc_tp = this.ctx.helper.add(tp_cache.positive_qc_tp, t.stage_tp.positive_qc_tp);
                tp_cache.negative_qc_tp = this.ctx.helper.add(tp_cache.negative_qc_tp, t.stage_tp.negative_qc_tp);
                tp_cache.yf_tp = this.ctx.helper.add(tp_cache.yf_tp, t.stage_tp.yf_tp);
                tp_cache.sf_tp = this.ctx.helper.add(tp_cache.sf_tp, t.stage_tp.sf_tp);
                tp_cache.pre_contract_tp = this.ctx.helper.add(tp_cache.pre_contract_tp, t.stage_tp.pre_contract_tp);
                tp_cache.pre_qc_tp = this.ctx.helper.add(tp_cache.pre_qc_tp, t.stage_tp.pre_qc_tp);
                tp_cache.pre_positive_qc_tp = this.ctx.helper.add(tp_cache.pre_positive_qc_tp, t.stage_tp.pre_positive_qc_tp);
                tp_cache.pre_positive_qc_tp = this.ctx.helper.add(tp_cache.pre_positive_qc_tp, t.stage_tp.pre_positive_qc_tp);
                tp_cache.pre_yf_tp = this.ctx.helper.add(tp_cache.pre_yf_tp, t.stage_tp.pre_yf_tp);
                tp_cache.pre_sf_tp = this.ctx.helper.add(tp_cache.pre_sf_tp, t.stage_tp.pre_sf_tp);
                tp_cache.contract_pc_tp = this.ctx.helper.add(tp_cache.contract_pc_tp, t.stage_tp.contract_pc_tp);
                tp_cache.qc_pc_tp = this.ctx.helper.add(tp_cache.qc_pc_tp, t.stage_tp.qc_pc_tp);
                tp_cache.pc_tp = this.ctx.helper.add(tp_cache.pc_tp, t.stage_tp.pc_tp);
            }
            await this.db.update(this.ctx.service.subProjPermission.tableName, { id: permission.id, tp_cache: JSON.stringify(tp_cache)});
            return tp_cache;
        }

        /**
         * 保存标段相关信息
         *
         * @param data
         * @return {Promise<void>}
         */
        async saveInfo(spid, data) {
            for (const di in data) {
                if (arrayInfo.indexOf(di) >= 0) {
                    data[di] = JSON.stringify(data[di]);
                }
            }
            await this.db.update(this.tableName, data, { where: { id: spid } });
        }
    }

    return SubProject;
};