Calculation/app/controller/weapp_tender_controller.js

'use strict';
const auditConst = require('../const/audit');
const measureType = require('../const/tender').measureType;
const advanceConst = require('../const/advance');
const status = require('../const/audit').advance.status;
const shenpiConst = require('../const/shenpi');
const stdConst = require('../const/standard');
const _ = require('lodash');

module.exports = app => {
    class WeappTenderController extends app.BaseController {
        async listManage(ctx) {
            try {
                const projectId = ctx.query.projectId;
                if (!projectId) {
                    ctx.body = { err: 1, msg: '缺少projectId参数', data: null };
                    return;
                }
                const accountInfo = ctx.session.sessionUser;
                const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
                if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
                    const subProject = await this.ctx.service.subProject.getDataById(projectId);
                    const tenderList = await this.ctx.service.tender.getList('', userPermission, ctx.session.sessionUser.is_admin, '', subProject);
                    for (const tender of tenderList) {
                        // 查询当前审批期以及状态
                        const stage = await this.ctx.service.stage.getLastestStage(tender.id, true);
                        tender.stage_order = stage && stage.order ? stage.order : null;
                        tender.stage_status = stage && stage.status ? stage.status : null;
                    }
                    const categoryData = await this.ctx.service.category.getAllCategory(subProject);
                    const renderData = {
                        categoryData,
                        tenderList,
                    };
                    ctx.body = { err: 0, msg: '', data: renderData };
                } else {
                    ctx.body = { err: 1, msg: '您没有管理权限', data: null };
                }
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async detail(ctx) {
            try {
                const tender = ctx.tender.data;

                let bCalcTp = ctx.tender.data.user_id === ctx.session.sessionUser.accountId && (
                    ctx.tender.ledger_status === auditConst.ledger.status.checkNo || ctx.tender.ledger_status === auditConst.ledger.status.uncheck);
                const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
                const lastStage = stages.length > 0 ? stages[0] : null; // await ctx.service.stage.getLastestStage(ctx.tender.id);
                const [change_tp, change_p_tp, change_n_tp, change_valuation_tp, change_unvaluation_tp] = await ctx.service.change.getChangeTp(ctx.tender.id);
                tender.change_tp = change_tp;
                tender.change_p_tp = change_p_tp;
                tender.change_n_tp = change_n_tp;
                tender.change_valuation_tp = change_valuation_tp;
                tender.change_unvaluation_tp = change_unvaluation_tp;
                if (lastStage) {
                    await this.ctx.service.stage.checkStageGatherData(lastStage, ctx.session.sessionUser.is_admin);
                    if ((!bCalcTp) && tender.measure_type === measureType.gcl.value) {
                        bCalcTp = lastStage.status !== auditConst.stage.status.checked && !lastStage.readOnly;
                    }
                    if (bCalcTp) {
                        const sum = await this.ctx.service.ledger.addUp({ tender_id: ctx.tender.id/* , is_leaf: true*/ });
                        tender.total_price = sum.total_price;
                        tender.deal_tp = sum.deal_tp;
                    }
                    tender.sum = ctx.tender.info.calc_type === 'tp' ? ctx.helper.add(tender.total_price, tender.change_valuation_tp) : ctx.helper.add(tender.total_price, tender.change_tp);
                    tender.gather_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.qc_tp, lastStage.pc_tp]);
                    tender.end_contract_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.pre_contract_tp, lastStage.contract_pc_tp]);
                    tender.end_qc_tp = ctx.helper.sum([lastStage.qc_tp, lastStage.pre_qc_tp, lastStage.qc_pc_tp]);
                    tender.end_positive_qc_tp = ctx.helper.sum([lastStage.positive_qc_tp, lastStage.pre_positive_qc_tp, lastStage.positive_qc_pc_tp]);
                    tender.end_negative_qc_tp = ctx.helper.sum([lastStage.negative_qc_tp, lastStage.pre_negative_qc_tp, lastStage.negative_qc_pc_tp]);
                    tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
                    tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
                    tender.yf_tp = lastStage.yf_tp;
                    tender.sf_tp = lastStage.sf_tp;
                    tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
                    tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
                    tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
                    tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
                    tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
                    tender.end_yf_tp = ctx.helper.add(lastStage.yf_tp, lastStage.pre_yf_tp);
                    tender.end_sf_tp = ctx.helper.add(lastStage.sf_tp, lastStage.pre_sf_tp);
                    tender.undone_tp = ctx.helper.sub(ctx.helper.sub(ctx.helper.add(tender.total_price, change_tp), tender.end_contract_tp), tender.end_qc_tp);
                } else {
                    if (bCalcTp) {
                        const sum = await this.ctx.service.ledger.addUp({ tender_id: ctx.tender.id/* , is_leaf: true*/ });
                        tender.total_price = sum.total_price;
                        tender.deal_tp = sum.deal_tp;
                    }
                    tender.sum = ctx.helper.add(tender.total_price, tender.change_tp);
                }

                // const monthProgress = [];
                // for (const s of stages) {
                //     if (s.s_time) {
                //         let progress = monthProgress.find(function(x) {
                //             return x.month === s.s_time;
                //         });
                //         if (!progress) {
                //             progress = { month: s.s_time };
                //             monthProgress.push(progress);
                //         }
                //         progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
                //     }
                // }
                // monthProgress.sort(function(x, y) {
                //     return Date.parse(x.month) - Date.parse(y.month);
                // });
                // let sum = 0;
                // for (const p of monthProgress) {
                //     p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
                //     sum = ctx.helper.add(sum, p.tp);
                //     p.end_tp = sum;
                //     p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
                // }

                ctx.body = {
                    code: 0, msg: '', data: {
                        tender,
                        // monthProgress,
                        // stagesEcharts: JSON.parse(JSON.stringify(stages)).reverse(),
                    },
                };
            } catch (error) {
                this.log(error);
                ctx.body = { code: -1, msg: error.toString(), data: null };
            }

        }

        async advanceList(ctx) {
            try {
                const { advanceType } = ctx.query;
                const typeCol = advanceConst.typeCol.find(x => x.type === Number(advanceType));
                if (!typeCol) {
                    ctx.body = { code: -1, msg: '预付款类型错误', data: null };
                    return;
                }
                const { decimal } = ctx.tender.info;
                const advancePayTotal = ctx.tender.info.deal_param[typeCol.key + 'Advance'];
                const advances = await ctx.service.advance.getAdvanceList(ctx.tender.id, typeCol.type, decimal.pay ? decimal.payTp : decimal.tp, advancePayTotal);
                ctx.body = { code: 0, msg: '', data: advances };
            } catch (error) {
                this.log(error);
                ctx.body = { code: -1, msg: error.toString(), data: null };
            }
        }

        async advanceDetail(ctx) {
            try {
                const { id } = ctx.query;
                const advance = await this.service.advance.getDataById(id);
                if (!advance) {
                    throw '预付款数据错误';
                }

                advance.user = await this.service.projectAccount.getAccountInfoById(advance.uid);
                // 读取审核人列表数据
                advance.auditors = await this.service.advanceAudit.getAuditors(advance.id, advance.times);
                advance.curAuditor = await this.service.advanceAudit.getCurAuditor(advance.id, advance.times);
                // 根据状态判断是否需要更新审批人列表
                if ((advance.status === status.uncheck || advance.status === status.checkNo) && ctx.tender.info.shenpi.advance !== shenpiConst.sp_status.sqspr) {
                    const shenpi_status = this.ctx.tender.info.shenpi.advance;
                    // 进一步比较审批流是否与审批流程设置的相同，不同则替换为固定审批流或固定的终审
                    const auditList = await this.service.advanceAudit.getAllDataByCondition({ where: { vid: advance.id, times: advance.times }, orders: [['order', 'asc']] });
                    const auditIdList = _.map(auditList, 'audit_id');
                    if (shenpi_status === shenpiConst.sp_status.gdspl) {
                        const shenpiList = await this.service.shenpiAudit.getAllDataByCondition({ where: { tid: advance.tid, sp_type: shenpiConst.sp_type.advance, sp_status: shenpi_status } });
                        const shenpiIdList = _.map(shenpiList, 'audit_id');
                        // 判断2个id数组是否相同，不同则删除原审批流，切换成固定的审批流
                        if (!_.isEqual(auditIdList, shenpiIdList)) {
                            await this.service.advanceAudit.updateNewAuditList(advance, shenpiIdList);
                        }
                    } else if (shenpi_status === shenpiConst.sp_status.gdzs) {
                        const shenpiInfo = await this.service.shenpiAudit.getDataByCondition({ tid: advance.tid, sp_type: shenpiConst.sp_type.advance, sp_status: shenpi_status });
                        // 判断最后一个id是否与固定终审id相同，不同则删除原审批流中如果存在的id和添加终审
                        if (shenpiInfo && shenpiInfo.audit_id !== _.last(auditIdList)) {
                            await this.service.advanceAudit.updateLastAudit(advance, auditList, shenpiInfo.audit_id);
                        } else if (!shenpiInfo) {
                            // 不存在终审人的状态下这里恢复为授权审批人
                            this.ctx.tender.info.shenpi.advance = shenpiConst.sp_status.sqspr;
                        }
                    }
                }

                advance.advancePayTotal = ctx.tender.info.deal_param[ advanceConst.typeCol[advance.type].key + 'Advance'];
                const times = advance.status === auditConst.advance.status.checkNo ? advance.times - 1 : advance.times;
                if (advance.status === auditConst.advance.status.checkNo) {
                    advance.curAuditor = await ctx.service.advanceAudit.getAuditorByStatus(advance.id, advance.status, times);
                    advance.auditors = await ctx.service.advanceAudit.getAuditors(advance.id, times);
                }
                // 因为上报人不在审核列表里面单独添加进去
                // advance.auditors.unshirt({
                //   audit_id: advance.uid,
                //   name: advance.user.name,
                //   company: advance.user.company,
                //   create_time: advance.pay_time,
                //   end_time: advance.auditors.length ? advance.auditors[0].create_time : null,
                //   mobile: '',

                // })
                ctx.body = { code: 0, msg: '', data: { advance } };
            } catch (error) {
                this.log(error);
                ctx.body = { code: -1, msg: error.toString(), data: null };
            }
        }

        async reviseDetail(ctx) {
            try {
                const { rid } = ctx.query;
                const revise = rid
                    ? await ctx.service.ledgerRevise.getRevise(ctx.tender.id, rid)
                    : ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                revise.preHis = revise.pre_his_id ? await ctx.service.ledgerHistory.getDataById(revise.pre_his_id) : null;
                revise.curHis = revise.his_id ? await ctx.service.ledgerHistory.getDataById(revise.his_id) : null;
                await ctx.service.reviseAudit.loadReviseUser(revise);
                await ctx.service.reviseAudit.loadReviseAuditViewData(revise);

                const GclGather = require('../lib/gcl_gather');
                const gclGatherModal = new GclGather.gclCompareGather(this.ctx);
                const spec = {zlj: stdConst.zlj, jrg: stdConst.jrg};
                spec.zlj.deal_bills_tp = ctx.tender.info.deal_param.zanLiePrice;
                gclGatherModal.init(ctx.tender.info.chapter, spec);
                const reviseBillsData = revise.readOnly && revise.curHis
                    ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.bills_file)
                    : await ctx.service.reviseBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
                const revisePosData = revise.readOnly && revise.curHis
                    ? await this.ctx.helper.loadLedgerDataFromOss(revise.curHis.pos_file)
                    : await ctx.service.revisePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
                const price = await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: revise.id } });
                gclGatherModal.gatherReviseLedgerData(reviseBillsData, revisePosData, { prefix: 'new_' }, price, ctx.tender.info.decimal);
                const billsData = revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(revise.preHis.bills_file) : [];
                const posData = revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(revise.preHis.pos_file) : [];
                gclGatherModal.gatherLedgerData(billsData, posData, { prefix: 'org_' });
                revise.chapterList = gclGatherModal.chapterData();
                revise.new_tp = gclGatherModal.otherChapter.hj.new_total_price || 0;
                revise.org_tp = gclGatherModal.otherChapter.hj.org_total_price || 0;

                ctx.body = { code: 0, msg: '', data: { revise } };
            } catch(error) {
                ctx.log(error);
                ctx.body = { code: -1, msg: error.toString(), data: null };
            }
        }
    }

    return WeappTenderController;
};