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 noticeList = await ctx.service.noticePush.getNoticeByDataCollect(ctx.session.sessionProject.id, tenderidList);
                // 获取分类
                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(',') : [];
                if (ctx.params.index) {
                    ctx.subProject.data_collect = parseInt(ctx.params.index);
                }
                const is_dz2 = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'GYJJ1', 'P1103'].indexOf(ctx.session.sessionProject.code) !== -1
                    && ctx.subProject.data_collect_pages.includes('6') && ctx.subProject.data_collect === 6;
                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),
                };
                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 {
                    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 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;
                });
                const thisMonth = new Date();
                const [startMonth, endMonth] = ctx.helper.getStartEndMonth(thisMonth);
                // 统计方法总时长
                // let sumStageByDataCollectTime = 0;
                for (const t of tenderList) {
                    // const tenderInfo = await ctx.service.tenderInfo.getTenderInfo(t.id);
                    // t.contract_price = tenderInfo.deal_param.contractPrice;
                    // let bCalcTp = t.ledger_status === auditConst.ledger.status.checkNo || t.ledger_status === auditConst.ledger.status.uncheck;
                    // t.advance_tp = await ctx.service.advance.getSumAdvance(t.id);
                    //
                    // if (t.ledger_status === auditConst.ledger.status.checked) {
                    //     t.lastStage = await ctx.service.stage.getLastestStage(t.id);
                    //     if (t.lastStage) await ctx.service.stage.checkStageGatherDataByDataCollect(t.lastStage, true);
                    //     t.completeStage = await ctx.service.stage.getLastestCompleteStage(t.id);
                    //     if ((!bCalcTp) && t.measure_type === measureType.gcl.value) {
                    //         bCalcTp = t.lastStage && t.lastStage.status !== auditConst.stage.status.checked && !t.lastStage.readOnly;
                    //     }
                    // }
                    // if (bCalcTp) {
                    //     const sum = await this.ctx.service.ledger.addUp({ tender_id: t.id/* , is_leaf: true*/ });
                    //     t.total_price = sum.total_price;
                    //     t.deal_tp = sum.deal_tp;
                    // }
                    // 用标段管理的方法获取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;
                }
                // const tenderMapList = await ctx.service.tenderMap.getAllDataByCondition({ where: { tid: tender.id } });
                responseData.data.tenderList = tenderList;
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }
    }

    return DatacollectController;
};