Calculation/test/app/service/report_memory.test.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date
 * @version
 */

const { app, assert } = require('egg-mock/bootstrap');
const path = require('path');
let savePath;
const mockData = {};
const dataType = {
    int: 'int',
    str: 'string',
    double: 'double',
    currency: 'currency',
};
const addFields = function(table, name, field, type) {
    const data = {};
    data.ID = table.ID * 100 + table.items.length + 1;
    data.Name = name + '(' + field + ')';
    data.DataType = type;
    data.TableName = table.key;
    data.descr = '';
    data.mapExpression = "$PROJECT.REPORT.getProperty('" + table.key + "', '" + field + "')";
    table.items.push(data);
};
const saveTableDefine = async function (ctx, tableDefine, file) {
    delete tableDefine.ID;
    delete tableDefine.key;
    let defineStr = JSON.stringify(tableDefine, "", "\t");
    const replaceStr = [
        {match: '"Name"', str: 'Name'},
        {match: '"remark"', str: 'remark'},
        {match: '"items"', str: 'items'},
        {match: '"ID"', str: 'ID'},
        {match: '"DataType"', str: 'DataType'},
        {match: '"TableName"', str: 'TableName'},
        {match: '"descr"', str: 'descr'},
        {match: '"mapExpression"', str: 'mapExpression'},
    ];
    for (const rs of replaceStr) {
        const reg = new RegExp(rs.match, 'gm');
        defineStr = defineStr.replace(reg, rs.str);
    }
    await ctx.helper.saveBufferFile(defineStr, file);
};

describe('test/app/service/report_memory.test.js', () => {
    // 准备测试数据
    before(function* () {
        const ctx = app.mockContext();
        savePath = path.join(ctx.app.baseDir,'report_temp');
        // 模拟登录session
        const postData = {
            account: '734406061@qq.com',
            project: 'T201711273363',
            project_password: 'mai654321',
        };
        // const postData = {
        //     account: 'chente',
        //     project: 'T201711273363',
        //     project_password: '123456',
        // };
        ctx.session = {};
        const loginResult = yield ctx.service.projectAccount.accountLogin(postData, 2);
        assert(loginResult);
        mockData.session = ctx.session;
    });
    // 中间计量表数据 - 台账
    it('test getStageImTzData & getStageImTzBillsData', function* () {
        const ctx = app.mockContext(mockData);

        // test12 - 第6期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 6});
        const mainData = yield ctx.service.reportMemory.getStageImTzData(12, stage.id);
        const billsData = yield ctx.service.reportMemory.getStageImTzBillsData(12, stage.id);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_stage_im_tz.json');
        }
        if (billsData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(billsData,"","\t"), ctx.app.baseDir + '/mem_stage_im_tz_bills.json');
        }
    });
    // 中间计量表数据 - 总量
    it('test getStageImZlData', function* () {
        const ctx = app.mockContext(mockData);

        // test12 - 第6期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 6});
        const mainData = yield ctx.service.reportMemory.getStageImZlData(12, stage.id);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_stage_im_zl.json');
        }
    });
    // 月进度数据
    it('test getMonthProgress', function* () {
        const ctx = app.mockContext(mockData);

        // test12
        const mainData = yield ctx.service.reportMemory.getMonthProgress(12);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_month_progress.json');
        }
    });
    // 期清单数据
    it('test getStageBills', function* () {
        const ctx = app.mockContext(mockData);

        // test12 - 第6期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 6});
        const mainData = yield ctx.service.reportMemory.getStageBillsData(12, stage.id, [
            'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
            'code', 'b_code', 'name', 'unit', 'unit_price',
            'deal_qty', 'deal_tp',
            'sgfh_qty', 'sgfh_tp', 'sjcl_qty', 'sjcl_tp', 'qtcl_qty', 'qtcl_tp', 'quantity', 'total_price',
            'dgn_qty1', 'dgn_qty2',
            'drawing_code', 'memo', 'node_type', 'is_tp',
            'contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'gather_qty', 'gather_tp', 'postil',
            'pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_gather_qty', 'pre_gather_tp',
            'end_contract_qty', 'end_contract_tp', 'end_qc_qty', 'end_qc_tp', 'end_gather_qty', 'end_gather_tp',
            'final_tp', 'final_ratio',
            'qc_bgl_code',
            'chapter',
        ]);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_stage_bills.json');
            const tableDefine = {};
            tableDefine.Name = '期 - 清单数据表(mem_stage_bills)';
            tableDefine.remark = '';
            tableDefine.ID = 25;
            tableDefine.key = 'mem_stage_bills';
            tableDefine.items = [];
            addFields(tableDefine, '台账ID', 'id', dataType.int);
            addFields(tableDefine, '标段ID', 'tender_id', dataType.int);
            addFields(tableDefine, '树结构-ID', 'ledger_id', dataType.int);
            addFields(tableDefine, '树结构-父项ID', 'ledger_pid', dataType.int);
            addFields(tableDefine, '树结构-层级', 'level', dataType.int);
            addFields(tableDefine, '树结构-同层排序', 'order', dataType.int);
            addFields(tableDefine, '树结构-完整路径', 'full_path', dataType.int);
            addFields(tableDefine, '树结构-是否子项', 'is_leaf', dataType.int);

            addFields(tableDefine, '项目节编号', 'code', dataType.str);
            addFields(tableDefine, '清单编号', 'b_code', dataType.str);
            addFields(tableDefine, '名称', 'name', dataType.str);
            addFields(tableDefine, '单位', 'unit', dataType.str);
            addFields(tableDefine, '单价', 'unit_price', dataType.currency);

            addFields(tableDefine, '签约-数量', 'deal_qty', dataType.currency);
            addFields(tableDefine, '签约-金额', 'deal_tp', dataType.currency);

            addFields(tableDefine, '施工复核-数量', 'sgfh_qty', dataType.currency);
            addFields(tableDefine, '施工复核-金额', 'sgfh_tp', dataType.currency);
            addFields(tableDefine, '设计错漏-数量', 'sjcl_qty', dataType.currency);
            addFields(tableDefine, '设计错漏-金额', 'sjcl_tp', dataType.currency);
            addFields(tableDefine, '其他错漏-数量', 'qtcl_qty', dataType.currency);
            addFields(tableDefine, '其他错漏-金额', 'qtcl_tp', dataType.currency);
            addFields(tableDefine, '台账-数量', 'quantity', dataType.currency);
            addFields(tableDefine, '台账-金额', 'total_price', dataType.currency);

            addFields(tableDefine, '项目节-数量1', 'dgn_qty1', dataType.currency);
            addFields(tableDefine, '项目节-金额2', 'dgn_qty2', dataType.currency);

            addFields(tableDefine, '图册号', 'drawing_code', dataType.str);
            addFields(tableDefine, '备注', 'memo', dataType.str);
            addFields(tableDefine, '节点类型', 'node_type', dataType.int);
            addFields(tableDefine, '总额计量', 'is_tp', dataType.int);

            addFields(tableDefine, '本期-合同-数量', 'contract_qty', dataType.currency);
            addFields(tableDefine, '本期-合同-金额', 'contract_tp', dataType.currency);
            addFields(tableDefine, '本期-数量变更-数量', 'qc_qty', dataType.currency);
            addFields(tableDefine, '本期-数量变更-金额', 'qc_tp', dataType.currency);
            addFields(tableDefine, '本期-完成-数量', 'gather_qty', dataType.currency);
            addFields(tableDefine, '本期-完成-金额', 'gather_tp', dataType.currency);
            addFields(tableDefine, '本期批注', 'postil', dataType.str);

            addFields(tableDefine, '截止上期-合同-数量', 'pre_contract_qty', dataType.currency);
            addFields(tableDefine, '截止上期-合同-金额', 'pre_contract_tp', dataType.currency);
            addFields(tableDefine, '截止上期-数量变更-数量', 'pre_qc_qty', dataType.currency);
            addFields(tableDefine, '截止上期-数量变更-金额', 'pre_qc_tp', dataType.currency);
            addFields(tableDefine, '截止上期-完成-数量', 'pre_gather_qty', dataType.currency);
            addFields(tableDefine, '截止上期-完成-金额', 'pre_gather_tp', dataType.currency);

            addFields(tableDefine, '截止本期-合同-数量', 'end_contract_qty', dataType.currency);
            addFields(tableDefine, '截止本期-合同-金额', 'end_contract_tp', dataType.currency);
            addFields(tableDefine, '截止本期-数量变更-数量', 'end_qc_qty', dataType.currency);
            addFields(tableDefine, '截止本期-数量变更-金额', 'end_qc_tp', dataType.currency);
            addFields(tableDefine, '截止本期-完成-数量', 'end_gather_qty', dataType.currency);
            addFields(tableDefine, '截止本期-完成-金额', 'end_gather_tp', dataType.currency);

            addFields(tableDefine, '(台账 + 截止本期变更)-金额', 'final_tp', dataType.currency);
            addFields(tableDefine, '截止本期完成率(%)', 'final_ratio', dataType.double);

            addFields(tableDefine, '本期-数量变更-变更令', 'qc_bgl_code', dataType.str);

            addFields(tableDefine, '章节编号', 'chapter', dataType.str);

            yield saveTableDefine(ctx, tableDefine, ctx.app.baseDir + '/mem_stage_bills_define.json');
        }
    });
    // 期部位明细数据
    it('test getStagePos', function* () {
        const ctx = app.mockContext(mockData);

        // test12 - 第6期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 6});
        const mainData = yield ctx.service.reportMemory.getStagePosData(12, stage.id);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_stage_pos.json');
            //yield saveTableDefine(ctx, tableDefine, ctx.app.baseDir + '/mem_stage_bills_compare_define.json');
        }
    });
    // 期 全审核人 数据
    it('test getStageBillsCompare', function* () {
        const ctx = app.mockContext(mockData);
        // test12 - 第4期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 4});
        const mainData = yield ctx.service.reportMemory.getStageBillsCompareData(12, stage.id, [
            'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
            'code', 'b_code', 'name', 'unit', 'unit_price',
            'deal_qty', 'deal_tp',
            'sgfh_qty', 'sgfh_tp', 'sjcl_qty', 'sjcl_tp', 'qtcl_qty', 'qtcl_tp', 'quantity', 'total_price',
            'dgn_qty1', 'dgn_qty2',
            'drawing_code', 'memo', 'node_type', 'is_tp',
            'r0_contract_qty', 'r0_contract_tp', 'r0_qc_qty', 'r0_qc_tp', 'r0_gather_qty', 'r0_gather_tp',
            'r1_contract_qty', 'r1_contract_tp', 'r1_qc_qty', 'r1_qc_tp', 'r1_gather_qty', 'r1_gather_tp',
            'pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_gather_qty', 'pre_gather_tp',
            'chapter',
        ]);
        if (mainData instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(mainData,"","\t"), ctx.app.baseDir + '/mem_stage_bills_compare.json');

            const tableDefine = {};
            tableDefine.Name = '期-清单-全参与人数据表(mem_stage_bills_compare)';
            tableDefine.remark = '';
            tableDefine.ID = 26;
            tableDefine.key = 'mem_stage_bills_compare';
            tableDefine.items = [];
            addFields(tableDefine, '台账ID', 'id', dataType.int);
            addFields(tableDefine, '标段ID', 'tender_id', dataType.int);
            addFields(tableDefine, '树结构-ID', 'ledger_id', dataType.int);
            addFields(tableDefine, '树结构-父项ID', 'ledger_pid', dataType.int);
            addFields(tableDefine, '树结构-层级', 'level', dataType.int);
            addFields(tableDefine, '树结构-同层排序', 'order', dataType.int);
            addFields(tableDefine, '树结构-完整路径', 'full_path', dataType.int);
            addFields(tableDefine, '树结构-是否子项', 'is_leaf', dataType.int);

            addFields(tableDefine, '项目节编号', 'code', dataType.str);
            addFields(tableDefine, '清单编号', 'b_code', dataType.str);
            addFields(tableDefine, '名称', 'name', dataType.str);
            addFields(tableDefine, '单位', 'unit', dataType.str);
            addFields(tableDefine, '单价', 'unit_price', dataType.currency);

            addFields(tableDefine, '签约-数量', 'deal_qty', dataType.currency);
            addFields(tableDefine, '签约-金额', 'deal_tp', dataType.currency);

            addFields(tableDefine, '施工复核-数量', 'sgfh_qty', dataType.currency);
            addFields(tableDefine, '施工复核-金额', 'sgfh_tp', dataType.currency);
            addFields(tableDefine, '设计错漏-数量', 'sjcl_qty', dataType.currency);
            addFields(tableDefine, '设计错漏-金额', 'sjcl_tp', dataType.currency);
            addFields(tableDefine, '其他错漏-数量', 'qtcl_qty', dataType.currency);
            addFields(tableDefine, '其他错漏-金额', 'qtcl_tp', dataType.currency);
            addFields(tableDefine, '台账-数量', 'quantity', dataType.currency);
            addFields(tableDefine, '台账-金额', 'total_price', dataType.currency);

            addFields(tableDefine, '项目节-数量1', 'dgn_qty1', dataType.currency);
            addFields(tableDefine, '项目节-金额2', 'dgn_qty2', dataType.currency);

            addFields(tableDefine, '图册号', 'drawing_code', dataType.str);
            addFields(tableDefine, '备注', 'memo', dataType.str);
            addFields(tableDefine, '节点类型', 'node_type', dataType.int);
            addFields(tableDefine, '总额计量', 'is_tp', dataType.int);

            addFields(tableDefine, '截止上期-合同-数量', 'pre_contract_qty', dataType.currency);
            addFields(tableDefine, '截止上期-合同-金额', 'pre_contract_tp', dataType.currency);
            addFields(tableDefine, '截止上期-数量变更-数量', 'pre_qc_qty', dataType.currency);
            addFields(tableDefine, '截止上期-数量变更-金额', 'pre_qc_tp', dataType.currency);
            addFields(tableDefine, '截止上期-完成-数量', 'pre_gather_qty', dataType.currency);
            addFields(tableDefine, '截止上期-完成-金额', 'pre_gather_tp', dataType.currency);

            for (let i = 0 ;i < 10; i++) {
                addFields(tableDefine, '本期-合同-数量' + '_' + i, 'r' + i +'_' + 'contract_qty', dataType.currency);
                addFields(tableDefine, '本期-合同-金额' + '_' + i, 'r' + i +'_' + 'contract_tp', dataType.currency);
                addFields(tableDefine, '本期-数量变更-数量' + '_' + i, 'r' + i +'_' + 'qc_qty', dataType.currency);
                addFields(tableDefine, '本期-数量变更-金额' + '_' + i, 'r' + i +'_' + 'qc_tp', dataType.currency);
                addFields(tableDefine, '本期-完成-数量' + '_' + i, 'r' + i +'_' + 'gather_qty', dataType.currency);
                addFields(tableDefine, '本期-完成-金额' + '_' + i, 'r' + i +'_' + 'gather_tp', dataType.currency);
            }

            addFields(tableDefine, '章节编号', 'chapter', dataType.str);

            yield saveTableDefine(ctx, tableDefine, ctx.app.baseDir + '/mem_stage_bills_compare_define.json');
        }
    });
    it('test getStagePay', function* () {
        const ctx = app.mockContext(mockData);
        // test12 - 第4期
        const stage = yield ctx.service.stage.getDataByCondition({tid: 12, order: 6});
        const data = yield ctx.service.reportMemory.getStagePayData(stage.tid, stage.id, []);
        if (data instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(data, '', '\t'), ctx.app.baseDir + '/mem_stage_pay.json');

            const tableDefine = {};
            tableDefine.Name = '期-合同支付-数据(mem_stage_pay)';
            tableDefine.remark = '';
            tableDefine.ID = 27;
            tableDefine.key = 'mem_stage_pay';
            tableDefine.items = [];
            const prefix = '期-合同支付-';

            addFields(tableDefine, prefix + '名称', 'name', dataType.str);
            addFields(tableDefine, prefix + '计算公式', 'expr', dataType.str);
            addFields(tableDefine, prefix + '金额', 'tp', dataType.currency);
            addFields(tableDefine, prefix + '截止上期-金额', 'pre_tp', dataType.currency);
            addFields(tableDefine, prefix + '截止本期-金额', 'end_tp', dataType.currency);
            addFields(tableDefine, prefix + '排序', 'order', dataType.int);
            addFields(tableDefine, prefix + '是否扣款项', 'minus', dataType.int);
            addFields(tableDefine, prefix + '支付类型', 'ptype', dataType.int);
            addFields(tableDefine, prefix + '起扣金额', 'sprice', dataType.currency);
            addFields(tableDefine, prefix + '扣款限额', 'rprice', dataType.currency);
            yield saveTableDefine(ctx, tableDefine, ctx.app.baseDir + '/mem_stage_pay_define.json');
        }
    });
    it('test mem_union_data', function* () {
        const ctx = app.mockContext(mockData);

        const tableDefine = {};
        tableDefine.Name = '预留扩展数据-合并(mem_union_data)';
        tableDefine.remark = '';
        tableDefine.ID = 28;
        tableDefine.key = 'mem_union_data';
        tableDefine.items = [];
        const prefix = '预留扩展数据-合并-';

        addFields(tableDefine, prefix + '字符串1', 'str1', dataType.str);
        addFields(tableDefine, prefix + '字符串2', 'str2', dataType.str);
        addFields(tableDefine, prefix + '字符串3', 'str3', dataType.str);
        addFields(tableDefine, prefix + '字符串4', 'str4', dataType.str);
        addFields(tableDefine, prefix + '字符串5', 'str5', dataType.str);
        addFields(tableDefine, prefix + '字符串6', 'str6', dataType.str);
        addFields(tableDefine, prefix + '字符串7', 'str7', dataType.str);
        addFields(tableDefine, prefix + '字符串8', 'str8', dataType.str);
        addFields(tableDefine, prefix + '字符串9', 'str9', dataType.str);
        addFields(tableDefine, prefix + '字符串10', 'str10', dataType.str);
        addFields(tableDefine, prefix + '整数1', 'int1', dataType.int);
        addFields(tableDefine, prefix + '整数2', 'int2', dataType.int);
        addFields(tableDefine, prefix + '整数3', 'int3', dataType.int);
        addFields(tableDefine, prefix + '整数4', 'int4', dataType.int);
        addFields(tableDefine, prefix + '整数5', 'int5', dataType.int);
        addFields(tableDefine, prefix + '整数6', 'int6', dataType.int);
        addFields(tableDefine, prefix + '数量1', 'qty1', dataType.currency);
        addFields(tableDefine, prefix + '数量2', 'qty2', dataType.currency);
        addFields(tableDefine, prefix + '数量3', 'qty3', dataType.currency);
        addFields(tableDefine, prefix + '数量4', 'qty4', dataType.currency);
        addFields(tableDefine, prefix + '数量5', 'qty5', dataType.currency);
        addFields(tableDefine, prefix + '数量6', 'qty6', dataType.currency);
        addFields(tableDefine, prefix + '数量7', 'qty7', dataType.currency);
        addFields(tableDefine, prefix + '数量8', 'qty8', dataType.currency);
        addFields(tableDefine, prefix + '数量9', 'qty9', dataType.currency);
        addFields(tableDefine, prefix + '数量10', 'qty10', dataType.currency);
        addFields(tableDefine, prefix + '金额1', 'tp1', dataType.currency);
        addFields(tableDefine, prefix + '金额2', 'tp2', dataType.currency);
        addFields(tableDefine, prefix + '金额3', 'tp3', dataType.currency);
        addFields(tableDefine, prefix + '金额4', 'tp4', dataType.currency);
        addFields(tableDefine, prefix + '金额5', 'tp5', dataType.currency);
        addFields(tableDefine, prefix + '金额6', 'tp6', dataType.currency);
        addFields(tableDefine, prefix + '金额7', 'tp7', dataType.currency);
        addFields(tableDefine, prefix + '金额8', 'tp8', dataType.currency);
        addFields(tableDefine, prefix + '金额9', 'tp9', dataType.currency);
        addFields(tableDefine, prefix + '金额10', 'tp10', dataType.currency);
        yield saveTableDefine(ctx, tableDefine, ctx.app.baseDir + '/mem_union_data.json');
    });
    it('test mem_change_bills', function* () {
        const ctx = app.mockContext(mockData);

        const data = yield ctx.service.reportMemory.getChangeBillsData(12);
        if (data instanceof Array) {
            yield ctx.helper.saveBufferFile(JSON.stringify(data, '', '\t'), path.join(savePath, 'mem_change_bills.json'));

            const tableDefine = {};
            tableDefine.Name = '变更清单-(mem_change_bills)';
            tableDefine.remark = '';
            tableDefine.ID = 29;
            tableDefine.key = 'mem_change_bills';
            tableDefine.items = [];
            const prefix = '变更清单-';

            addFields(tableDefine, prefix + '变更令id', 'cid', dataType.str);
            addFields(tableDefine, prefix + '签约清单id或台账id', 'lid', dataType.str);
            addFields(tableDefine, prefix + '清单编号', 'code', dataType.str);
            addFields(tableDefine, prefix + '名称', 'name', dataType.str);
            addFields(tableDefine, prefix + '单位', 'unit', dataType.str);
            addFields(tableDefine, prefix + '单价', 'unit_price', dataType.currency);
            addFields(tableDefine, prefix + '原数量', 'o_qty', dataType.currency);
            addFields(tableDefine, prefix + '变更数量', 'c_qty', dataType.currency);
            addFields(tableDefine, prefix + '审批变更后数量', 's_qty', dataType.currency);
            addFields(tableDefine, prefix + '原-金额', 'o_tp', dataType.currency);
            addFields(tableDefine, prefix + '变更-金额', 'c_tp', dataType.currency);
            addFields(tableDefine, prefix + '审批变更后-金额', 's_tp', dataType.currency);
            addFields(tableDefine, prefix + '部位明细', 'bwmx', dataType.str);
            addFields(tableDefine, prefix + '变更详情', 'detail', dataType.str);
            yield saveTableDefine(ctx, tableDefine, path.join(savePath, 'mem_change_bills_define.json'));
        }
    });
});