Calculation/app/controller/datacollect_controller.js

'use strict';

/**
 *
 *
 * @author EllisRan
 * @date 2021/9/26
 * @version
 */

const tenderConst = require('../const/tender');
const codeRuleConst = require('../const/code_rule');
const settingConst = require('../const/setting.js');
const tenderMenu = require('../../config/menu').tenderMenu;
const auditConst = require('../const/audit');
const shenpiConst = require('../const/shenpi');
const accountGroup = require('../const/account_group').group;
const accountPermission = require('../const/account_permission');
const measureType = require('../const/tender').measureType;
const billsPosConvert = require('../lib/bills_pos_convert');
const path = require('path');
const sendToWormhole = require('stream-wormhole');
const scheduleConst = require('../const/schedule');
const changeConst = require('../const/change');
const tenderInfoModel = require('../lib/tender_info');
const projectSettingConst = require('../const/project_setting');
const mapConst = require('../const/map');

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

        /**
         * 期列表(Get)
         * @param ctx
         * @return {Promise<void>}
         */
        async index(ctx) {
            try {
                if (!ctx.subProject.showDataCollect) {
                    throw '该功能已关闭或无法查看';
                }
                // 获取标段审批信息
                const dcTenders = await ctx.service.datacollectTender.getList(ctx.session.sessionProject.id, ctx.subProject.id);
                const noTids = ctx.app._.map(dcTenders, 'tid');
                let tenderList = await ctx.service.tender.getList('', null, 1);
                tenderList = ctx.app._.filter(tenderList, function(item) {
                    return ctx.app._.indexOf(noTids, item.id) === -1;
                });
                const tenderidList = ctx.helper._.map(tenderList, 'id');
                // 获取分类
                const categoryData = await this.ctx.service.category.getListByCategoryLevel(ctx.subProject.id);
                // 默认坐标，否则则取办事处坐标
                const projectData = await ctx.service.project.getDataById(ctx.session.sessionProject.id);
                ctx.subProject.data_collect_pages = ctx.subProject.data_collect_pages ? ctx.subProject.data_collect_pages.split(',') : [];
                // 判断ctx.subProject.data_collect_pages如果只有7或者只有8或者只有7，8，则不用获取其它数据
                const pages = ctx.subProject.data_collect_pages;
                const only_cost =
                    (pages.length === 1 && (pages[0] === '7' || pages[0] === '8')) ||
                    (pages.length === 2 &&
                        pages.includes('7') &&
                        pages.includes('8'));
                let noticeList = [];
                if (!only_cost) {
                    noticeList = await ctx.service.noticePush.getNoticeByDataCollect(ctx.session.sessionProject.id, tenderidList);
                }
                if (ctx.params.index) {
                    ctx.subProject.data_collect = parseInt(ctx.params.index);
                    ctx.session.sessionSubProj = {
                        data_collect: ctx.subProject.data_collect,
                    };
                } else {
                    ctx.session.sessionSubProj = {
                        data_collect: ctx.subProject.data_collect,
                    };
                }
                // const is_cost = ctx.subProject.data_collect_pages.includes('7') && ctx.subProject.data_collect === 7;
                const is_dz2 = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'GYJJ1', 'P1103', 'KLG25', 'I2U5B', 'SEN48'].indexOf(ctx.session.sessionProject.code) !== -1
                    && ctx.subProject.data_collect_pages.includes('6') && ctx.subProject.data_collect === 6;
                const is_dzcb = ['P0505', 'P0506', 'P1201', 'P1202', 'P1002', 'GY18Y', 'Y3T2Q'].indexOf(ctx.session.sessionProject.code) !== -1 && ctx.subProject.data_collect_pages.includes('7') && ctx.subProject.data_collect === 7;// 成本管理定制大屏
                const is_dztz = ['P0505', 'P0506', 'P1201', 'P1202', 'P1002', 'Y3T2Q'].indexOf(ctx.session.sessionProject.code) !== -1 && ctx.subProject.data_collect_pages.includes('8') && ctx.subProject.data_collect === 8;// 投资总控定制大屏
                // const shj_url = 'http://112.74.42.187:3300/#/project/viewer?projectId=b03i54j0j8ai';
                const renderData = {
                    projectData,
                    noticeList,
                    categoryData,
                    // map_json,
                    acLedger: auditConst.ledger,
                    acStage: auditConst.stage,
                    acChange: auditConst.flow,
                    acRevise: auditConst.revise,
                    acMaterial: auditConst.material,
                    acAdvance: auditConst.advance,
                    pushType: auditConst.pushType,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.datacollect.index),
                    // shj_url,
                };
                if (is_dzcb) {
                    await this.layout('datacollect/index_cost.ejs', renderData);
                } else if (is_dztz) {
                    await this.layout('datacollect/index_tz.ejs', renderData);
                } else if (is_dz2) {
                    // 判断并更新common_json
                    if (!ctx.subProject.common_json) {
                        ctx.subProject.common_json = await ctx.service.subProject.updateCommonJsonDaping06(ctx.subProject, projectData);
                    }
                    const commonJson = ctx.subProject.common_json ? JSON.parse(ctx.subProject.common_json) : null;
                    renderData.daping06Set = commonJson && commonJson.daPing06_set ? commonJson.daPing06_set : ctx.helper._.cloneDeep(projectSettingConst.daPing06Set);
                    const glCategory = categoryData.find(item => item.name === '管理类别');
                    const dpCategory = [];
                    for (const d of renderData.daping06Set.cb_show) {
                        if (glCategory && glCategory.value) dpCategory.push(glCategory.value.find(item => item.id === d));
                    }
                    renderData.dpCategory = dpCategory;
                    await this.layout('datacollect/index4GY18Y.ejs', renderData);
                // } else if (is_dz3) {
                //     ctx.redirect(shj_url);
                } else {
                    await this.layout('datacollect/index.ejs', renderData);
                }
            } catch (err) {
                console.log(err);
                this.log(err);
                ctx.redirect(this.menu.menu.dashboard.url);
            }
        }

        async loadData(ctx) {
            try {
                const responseData = { err: 0, msg: '', data: {} };
                // const tenderidList = [];
                // const noticeList = await ctx.service.noticePush.getNoticeByDataCollect(ctx.session.sessionProject.id, tenderidList);
                const have_cost = ctx.session.sessionSubProj.data_collect === 7 || ctx.session.sessionSubProj.data_collect === 8;
                const thisMonth = new Date();
                const [startMonth, endMonth] = ctx.helper.getStartEndMonth(thisMonth);
                // 统计方法总时长
                // let sumStageByDataCollectTime = 0;
                const only_tz = ctx.session.sessionSubProj.data_collect === 8;
                if (!only_tz) {
                    const dcTenders = await ctx.service.datacollectTender.getList(ctx.session.sessionProject.id, ctx.subProject.id);
                    const noTids = ctx.app._.map(dcTenders, 'tid');
                    let tenderList = await ctx.service.tender.getList('', null, 1);
                    // let tenderList = await this.ctx.service.tender.getBuildList('', null, 1);
                    tenderList = ctx.app._.filter(tenderList, function(item) {
                        return ctx.app._.indexOf(noTids, item.id) === -1;
                    });
                    for (const t of tenderList) {
                        // 用标段管理的方法获取t数据
                        await this.ctx.service.tenderCache.loadTenderCache(t, '');
                        t.total_price = t.ledger_tp && t.ledger_tp.total_price ? t.ledger_tp.total_price : 0;
                        [t.change_tp, t.change_p_tp, t.change_n_tp, t.change_valuation_tp, t.change_unvaluation_tp] = await ctx.service.change.getChangeTp(t.id);
                        // t.material_tp = await ctx.service.material.getSumMaterial(t.id);
                        // 获取本标段 本月计量期审批通过数目，变更令审批通过数目，台账修订通过数目，材料调差通过数目
                        t.month_stage_num = await ctx.service.stageAudit.getNumByMonth(t.id, startMonth, endMonth);
                        t.month_change_num = await ctx.service.changeAudit.getNumByMonth(t.id, startMonth, endMonth);
                        t.month_revise_num = await ctx.service.reviseAudit.getNumByMonth(t.id, startMonth, endMonth);
                        t.month_material_num = await ctx.service.materialAudit.getNumByMonth(t.id, startMonth, endMonth);
                        // 获取标段计量月统计及截止月累计计量
                        // 这个慢，统计下面这个方法时长
                        const stageList = await ctx.service.stage.getStageByDataCollect(t.id, t.stage_tp);
                        // const stageList = [];
                        const month_stage = [];
                        for (const s of stageList) {
                            const monthOneStage = ctx.app._.find(month_stage, { yearmonth: s.s_time });
                            if (monthOneStage) {
                                monthOneStage.tp = ctx.helper.add(monthOneStage.tp, s.tp);
                                monthOneStage.end_yf_tp = ctx.helper.add(monthOneStage.end_yf_tp, s.yf_tp);
                                monthOneStage.end_sf_tp = ctx.helper.add(monthOneStage.end_sf_tp, s.sf_tp);
                            } else {
                                const data = {
                                    yearmonth: s.s_time,
                                    tp: s.tp,
                                    end_tp: s.end_tp,
                                    end_yf_tp: s.yf_tp,
                                    end_sf_tp: s.sf_tp,
                                };
                                month_stage.push(data);
                            }
                        }
                        t.month_stage = month_stage;
                        if (have_cost) {
                            // 取最新已审批完成的成本管理-成本分析期数据
                            t.cost_analysis = await ctx.service.costStage.getLastCheckedStage(t.id, 'analysis');
                            t.cost_duty = await ctx.service.costStage.getStageByOrder(t.id, 'duty', 1);
                            t.stage_num = await ctx.service.stage.getNumByChecked(t.id);
                            t.cost_ledger_num = await ctx.service.costStage.getNumByChecked(t.id, 'ledger');
                            t.cost_analysis_num = await ctx.service.costStage.getNumByChecked(t.id, 'analysis');
                            t.cost_book_num = await ctx.service.costStage.getNumByChecked(t.id, 'book');
                        }
                    }
                    responseData.data.tenderList = tenderList;
                }
                if (have_cost) {
                    const data = {};
                    const budget = await ctx.service.budget.getCurBudget(ctx.subProject.budget_id);
                    budget.name = ctx.subProject.name || '';
                    if (!budget) throw '未设置概预算标准';
                    if (budget.final_id) {
                        data.final = await ctx.service.budgetFinal.getAllDataByCondition({ where: { final_id: budget.final_id } });
                        data.finalInfo = await ctx.service.budgetFinalList.getFinal(budget.final_id);
                    } else {
                        data.gu = await ctx.service.budgetGu.getData(budget.id);
                        data.gai = await ctx.service.budgetGai.getData(budget.id);
                        data.yu = await ctx.service.budgetYu.getData(budget.id);
                        data.zb = await ctx.service.budgetZb.getData(budget.id);
                        data.ctrl = await ctx.service.budgetCtrl.getData(budget.id);
                        data.real = await ctx.service.budgetReal.getData(budget.id);
                    }
                    data.info = budget;
                    responseData.data.budget = data;
                }
                if (only_tz) {
                    const commonJson = ctx.subProject.common_json ? JSON.parse(ctx.subProject.common_json) : null;
                    const daping08Set = commonJson && commonJson.daPing08_set ? commonJson.daPing08_set : ctx.helper._.cloneDeep(projectSettingConst.daPing08Set);
                    const tenderList = {
                        1: {
                            a: null,
                            b: null,
                            // name: '',
                            // contract_price: 0,
                            // end_gather_tp: 0,
                            // end_profit: 0,
                        },
                        2: {
                            a: null,
                            b: null,
                        },
                        3: {
                            a: null,
                            b: null,
                        },
                        4: {
                            a: null,
                            b: null,
                        },
                    };
                    for (const t of daping08Set.tenders) {
                        tenderList[t.id] = {};
                        const tendera = t.a ? await ctx.service.tender.getDataById(t.a) : null;
                        if (tendera) {
                            await this.ctx.service.tenderCache.loadTenderCache(tendera, '');
                            tenderList[t.id].a = tendera;
                            const tenderb = t.b ? await ctx.service.tender.getDataById(t.b) : null;
                            if (tenderb) {
                                await this.ctx.service.tenderCache.loadTenderCache(tenderb, '');
                                tenderList[t.id].b = tenderb;
                            }
                        }
                    }
                    responseData.data.tenderList = tenderList;
                }
                // const tenderMapList = await ctx.service.tenderMap.getAllDataByCondition({ where: { tid: tender.id } });
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }
    }

    return DatacollectController;
};