YangHuCost/modules/glj/models/glj_list_model.js

/**
 * 项目工料机列表数据模型
 *
 * @author CaiAoLin
 * @date 2017/6/22
 * @version
 */
const mongoose = require("mongoose");
const BaseModel = require("../../common/base/base_model");
const CounterModel = require("./counter_model");
const UnitPriceModel = require("./unit_price_model");
const UnitPriceFileModel = require("./unit_price_file_model");
const GLJTypeConst = require("../../common/const/glj_type_const");
const STDGLJLibGLJListModel = require("../../common/std/std_glj_lib_glj_list_model");
const MixRatioModel = require("./mix_ratio_model");
const GljModel = require("../../complementary_glj_lib/models/gljModel");
const scMathUtil = require('../../../public/scMathUtil').getUtil();
let gljUtil = require('../../../public/gljUtil');
const commonFacade = require("../../main/facade/common_facade");
let gljCollectionName = 'glj_list';
let GLJSchemas = mongoose.model(gljCollectionName);
let _ = require("lodash");
let  vvTaxModel =  mongoose.model("std_vehicleVesselTax_items");

class GLJListModel extends BaseModel {

    /**
     * 材料、主材、设备类型id
     *
     * @var {Array}
     */
    materialIdList = [GLJTypeConst.GENERAL_MATERIAL, GLJTypeConst.CONCRETE, GLJTypeConst.MORTAR, GLJTypeConst.MIX_RATIO,
        GLJTypeConst.COMMERCIAL_CONCRETE, GLJTypeConst.COMMERCIAL_MORTAR, GLJTypeConst.MAIN_MATERIAL,
        GLJTypeConst.EQUIPMENT];

    /**
     * 拥有组成物的工料机类型id
     *
     * @var {Array}
     */
    ownCompositionTypes = [GLJTypeConst.CONCRETE, GLJTypeConst.MORTAR, GLJTypeConst.MIX_RATIO,
        GLJTypeConst.GENERAL_MACHINE,GLJTypeConst.MAIN_MATERIAL,GLJTypeConst.INSTRUMENT];

    /**
     * 构造函数
     *
     * @return {void}
     */
    constructor() {
        let parent = super();
        parent.model = GLJSchemas;
        parent.init();
    }

    /**
     * 设置场景
     *
     * @param {string} scene
     * @return {void}
     */
    setScene(scene = '') {
        switch (scene) {
            // 新增数据的验证规则
            case 'add':
                this.model.schema.path('glj_id').required(true);
                this.model.schema.path('project_id').required(true);
                this.model.schema.path('code').required(true);
                // this.model.schema.path('name').required(true);
                break;
        }
    }

    /**
     * 根据标段对应项目工料机列表
     *
     * @param {Number} projectId
     * @param {Number} unitPriceFileId
     * @return {Promise}
     */
    async getListByProjectId(projectId, unitPriceFileId,freightList,originalList,com_electrovalence) {
        let gljData = null;
        /*let decimal =await decimal_facade.getProjectDecimal(projectId);
        let quantity_decimal = decimal&&decimal.glj.quantity?decimal.glj.quantity:6;//取消耗量保留小数据位，默认6位*/
        let mixRatioConnectData = {};
        let mixRationMap={};
        let keyMap={};
        let ekeyMap={};
        let unitPriceList={};
        try {
            // 首先获取对应标段下所有的项目工料机数据
            let condition = {project_id: projectId};
            let fields = {_id: 0};
            gljData = await this.model.find(condition, fields).lean();
            // 整理获取有组成物的项目工料机的数据
            let connect_keys = [];
            for(let tmp of gljData) {
                let c_key = this.getIndex(tmp,['code','name','specs','unit','type']);
                //把有组成物类型的连接字段挑出来
                if(this.ownCompositionTypes.indexOf(tmp.type)!=-1){
                    connect_keys.push(c_key);
                }
                keyMap[c_key] = tmp; //项目工料机连接key和工料机的对照表;
            }

            //检查自采材料和综合电价功能在共享单价文件时，项目文件中可能会缺少项目工料机的情况，如果缺少，则自动插入
            if(freightList && freightList.length > 0)  await this.materialCalcProjectGLJChecking(freightList,keyMap,gljData,connect_keys,projectId,unitPriceFileId);
            if(originalList && originalList.length > 0) await this.materialCalcProjectGLJChecking(originalList,keyMap,gljData,connect_keys,projectId,unitPriceFileId);
            if(com_electrovalence) await this.materialCalcProjectGLJChecking([com_electrovalence],keyMap,gljData,connect_keys,projectId,unitPriceFileId,"gljList");

            // 没有数据则直接返回空
            if (gljData.length <= 0) {
                throw '无数据';
            }
            // 获取标段设置的单价文件数据
            let unitPriceModel = new UnitPriceModel();
            unitPriceList = await unitPriceModel.getDataByFileId(unitPriceFileId);

            //为了提高性成计算消耗量功能改成了在前端计算

            // 查找组成物的消耗量
            let totalComposition = {};
            let mixRatioData = {};

            let missMaxRatio = [];//由于共享单价文件,单价文件编辑器造成的，存在组成物和对应的单价，但是项目工料机不存的情况
            if (connect_keys.length > 0) {
                let mixRatioModel = new MixRatioModel();
                condition = {connect_key: {"$in": connect_keys}, unit_price_file_id: unitPriceFileId};
                let mixRatioList = await mixRatioModel.findDataByCondition(condition, null, false);
                for (let tmp of mixRatioList) {
                   let t_index = tmp.connect_key;
                   let m_index = this.getIndex(tmp,['code','name','specs','unit','type']);

                    if (mixRatioData[t_index] !== undefined) {
                        mixRatioData[t_index].push(tmp);
                    } else {
                        mixRatioData[t_index] = [tmp];
                    }
                    if(mixRationMap[t_index]!=undefined){
                        mixRationMap[t_index].push(tmp);
                    }else {
                        mixRationMap[t_index]=[tmp];
                    }
                    if (mixRatioConnectData[m_index] !== undefined) {
                        mixRatioConnectData[m_index].push(tmp.connect_key);
                    } else {
                        mixRatioConnectData[m_index] = [tmp.connect_key];
                    }
                    //检查该组成物对应的项目工料机是否存在  
                    if(!keyMap[m_index]) missMaxRatio.push(tmp);//这里可能会有重复，但是后面的添加操作中会去重 
                }
            }
            if(missMaxRatio.length > 0){
              let newList =  await commonFacade.getNewProjectGLJFromMissMixratio(projectId,missMaxRatio,keyMap,[]);
              await commonFacade.setIDfromCounter("glj_list",newList);
              await this.model.insertMany(newList);
              gljData=gljData.concat(newList);         
            }

            // 组合单价数据
            gljData = this.combineData(gljData, unitPriceList, {}, mixRatioData, totalComposition);
            // 排序
            gljData.sort(function (a, b) {
                a.unit_price = a.unit_price === null ? 0 : a.unit_price;
                b.unit_price = b.unit_price === null ? 0 : b.unit_price;
                return a.unit_price.type - b.unit_price.type;
            });

        } catch (error) {
            console.log("glj_list_model:" + error);
            gljData = [];
        }

        return [gljData, mixRatioConnectData,mixRationMap,unitPriceList];
    }

    async materialCalcProjectGLJChecking(materialList,keyMap,gljData,connect_keys,projectId,unitPriceFileId,listKey){
        let missGLJs = [];
        let pkey = listKey?listKey:"ration_gljs";
        for(let m of materialList){
            if(m[pkey]){
                for(let rg of m[pkey]){
                    let key = this.getIndex(rg);
                    if(keyMap[key])  continue; //如果已经存在，则跳过，不用添加
                    missGLJs.push(rg)
                }
            }
        }
        if(missGLJs.length > 0)   await this.handleMissGLJs(missGLJs,keyMap,gljData,connect_keys,projectId,unitPriceFileId)
    }

    //处理综合电价或材料计算共享的时候项目工料机缺少的情况
    async handleMissGLJs(missGLJs,keyMap,gljData,connect_keys,projectId,unitPriceFileId){
        let new_connect_keys = [];
        let oldProjectIDMap = {};//记录来源的项目工料机对应的项目编号
        let projectGLJIDList = [];
        let key_to_projectIDMap={};//记录5大项key对应来源的项目工料机ID
        for(let rg of missGLJs){
            projectGLJIDList.push(rg.projectGLJID);
           if(this.ownCompositionTypes.indexOf(rg.type)!=-1){//有工料机的类型还要检查组成物是否存在
               let newkey = this.getIndex(rg);
                new_connect_keys.push(newkey);
                connect_keys.push(newkey);
                key_to_projectIDMap[newkey] = rg.projectGLJID;
           }
        }
        let oldProjectGLJs =  await this.model.find({'id':{'$in':projectGLJIDList}},'-_id').lean();
        let counterModel = new CounterModel();

        //处理缺少的项目工料机
        for(let g of oldProjectGLJs){
            oldProjectIDMap[g.id] = g.project_id;
            g.id = await counterModel.getId(gljCollectionName);
            g.project_id = projectId;
            keyMap[this.getIndex(g)] = g;
        }

        //处理缺少的项目工料机中的组成物
        if(new_connect_keys.length > 0){
            let mixRatioModel = new MixRatioModel();
            let e_mList = await mixRatioModel.model.find({unit_price_file_id: unitPriceFileId,connect_key: {'$in':new_connect_keys}}).lean();
            let p_m = {};//以项目工料机来分组
            for(let m of e_mList) {
                let mkey = this.getIndex(m);
                if (keyMap[mkey]) continue; //如果已经存在了，不用再增加
                let oldPID = key_to_projectIDMap[m.connect_key];
                if (p_m[oldPID]) {
                    p_m[oldPID].push(m);
                } else {
                    p_m[oldPID] = [m];
                }
                keyMap[mkey] = m;//处理过了就添加，避免重复
            }
            //按组来处理组成物信息
            for(let t_pid in p_m){
                let codeList = [];
                let mkeyMap = [];
                for(let m of p_m[t_pid]){
                    codeList.push(m.code);
                    mkeyMap[this.getIndex(m)] = m;
                }
                let projectID = oldProjectIDMap[t_pid];
                let m_projectGLJs =  await this.model.find({'project_id':projectID,'code':{'$in':codeList}},'-_id').lean();
                for(let mg of m_projectGLJs){
                    if(mkeyMap[this.getIndex(mg)]){//过滤掉单按编号不准确的工料机
                        mg.id = await counterModel.getId(gljCollectionName);
                        mg.project_id = projectId;
                        oldProjectGLJs.push(mg);
                    }
                }
            }
        }

        if(oldProjectGLJs.length > 0){
            await this.db.create(oldProjectGLJs);
            for(let o of oldProjectGLJs){
                gljData.push(o);
            }
        }
    }


    /**
     * 组合工料机数据和单价文件数据
     *
     * @param {object} gljList
     * @param {object} unitPriceList
     * @param {object} quantityList
     * @param {object} mixRatioData 组合物明细数据
     * @param {object} totalComposition 组合物父工料机统计数据
     * @return {Array}
     */
    combineData(gljList, unitPriceList, quantityList = {}, mixRatioData = {}, totalComposition = {}) {
        // 整理组成物消耗量(只有在总列表显示的时候才需用到,获取单项项目工料机内容则忽略)
        let compositionConsumption = {};
        if (Object.keys(mixRatioData).length > 0 && Object.keys(totalComposition).length > 0) {
            for(let index in mixRatioData) {
                for(let tmp of mixRatioData[index]) {
                    let t_index = this.getIndex(tmp,['code','name','specs','unit','type']);//取做为组成物的工料机的总消耗量
                    compositionConsumption[t_index] = compositionConsumption[t_index] === undefined ? tmp.consumption :
                        compositionConsumption[t_index] + tmp.consumption;
                }

            }
        }
        let result = [];
        // 循环组合数据
        for(let index in gljList) {
            let glj = gljList[index];
            if (glj.code === undefined) {
                continue;
            }
            let g_index = this.getIndex(glj,['code','name','specs','unit','type']);
            glj.unit_price = unitPriceList !== null && unitPriceList[g_index] !== undefined ? unitPriceList[g_index] : null;

            if (glj.unit_price === null) {
                continue;
            }
            let gljId = glj.glj_id + '';
            let projectGljId = glj.id + '';

            glj.quantity = quantityList[g_index]?quantityList[g_index]:0;
            // 组成物数据
            gljList[index].ratio_data = mixRatioData[g_index] !== undefined ? mixRatioData[g_index] : [];
            //因为schema中设置base_price 为string 类型，所以要通过中间变量转换为数字再做计算，不然会自动变成字符串类型
            this.getGLJPrice(glj);
            result.push(glj);
        }
        return result;
    }
    getGLJPrice(glj){
        let glj_basePrice = parseFloat(glj.unit_price.base_price);
        glj.unit_price.base_price = glj_basePrice;
        glj.unit_price.market_price = parseFloat(glj.unit_price.market_price);
    }

    /**
     * 新增项目工料机数据(包括新增单价文件) 定额工料机新增时调用
     *
     * @param {object} data
     * @return {Promise} 返回插入成功的数据id
     */
    async addList(data,unitFileId,ext) {
        let result = null;
        try {
            if (Object.keys(data).length <= 0) {
                throw '新增数据为空';
            }
            let condition={
                code: data.code,
                project_id: data.project_id
               /*  name:data.name,
                specs:data.specs,
                type:data.type,
                unit:data.unit */
            };
            let projectGljData = null;
            let pList = await this.findDataByCondition(condition,null,false);
            //规格 型号 null undefind "" 问题
            for(let p of pList){
                if(this.getIndex(data) == this.getIndex(p)){
                  projectGljData = p;
                  break;
                }
            }
            let isAddProjectGLJ = false;

            // 获取标段对应的单价文件id
            let unitPriceFileId = unitFileId?unitFileId:await commonFacade.getUnitPriceFileId(data.project_id);
            if (unitPriceFileId <= 0) {
                throw '没有对应的单价文件';
            }

            let unitPriceModel = new UnitPriceModel();

            // 新增单条记录 （两个操作本来应该是事务操作，然而mongodb事务支持比较弱，就当作是都可以顺利执行）

            // 如果找不到数据则新增
            if (!projectGljData) {
                let gljInsertData = await this.add(data);
                if (!gljInsertData) {
                    throw '新增项目工料机失败!';
                }
                isAddProjectGLJ = true;
                projectGljData = gljInsertData;
            }

            let CompositionGLJ=[];
            // 判断类型，如果是混凝土、砂浆、配合比或者主材则查找对应的组成物(前提是没有对应的项目工料机数据)
            if(this.ownCompositionTypes.indexOf(data.type)!=-1) {
                //如果是新增
                if(isAddProjectGLJ ){
                    await this.compositionInit(data, unitPriceFileId,ext);
                }
                CompositionGLJ=await this.getCompositionGLJByData(data,unitPriceFileId);
                if(isAddProjectGLJ==false&&CompositionGLJ.length==0){//如果不是新增，并且是有组成物的类型但又没有发现组成物的情况下，有可能是错误数据，重新在库中查找一下组成物，有则插入
                    await this.compositionInit(data, unitPriceFileId,ext);
                    CompositionGLJ=await this.getCompositionGLJByData(data,unitPriceFileId);

                    if(CompositionGLJ.length>0){//如果这次发现又有组成物了，则把旧的单价数据删除，在后面的操作中会重新增加
                        let de_condition ={unit_price_file_id: unitPriceFileId,code:data.code,name:data.name,unit:data.unit,type:data.type};
                        data.specs!=null&&data.specs!=undefined&&data.specs!=""?de_condition.specs = data.specs:de_condition;
                        await unitPriceModel.db.delete(de_condition);
                    }
                }
            }
            projectGljData._doc.subList=CompositionGLJ;
            // 新增单价文件
            let [unitPriceInsertData, isAdd] = await unitPriceModel.addUnitPrice(data, unitPriceFileId);

            if (!unitPriceInsertData) {
                throw '新增单价失败!';
            }

            projectGljData.unit_price = unitPriceInsertData;
            result = projectGljData;
        } catch (error) {
            console.log(error);
            result = null;
        }

        return result;
    }

    /**
     * 新增单条工料机数据
     *
     * @param {object} data
     * @return {Promise}
     */
    async add(data) {
        if (Object.keys(data).length <= 0) {
            throw '新增数据为空';
        }

        let counterModel = new CounterModel();
        if (data instanceof Array) {
            // 如果是批量新增
            for(let tmp in data) {
                data[tmp].id = await counterModel.getId(gljCollectionName);
            }
        } else {
            data.id = await counterModel.getId(gljCollectionName);
        }

        let result = await this.db.create(data);
        return result;
    }

    /**
     * 修改名称、规格型号、单位、市场单价等
     * @param data
     * @returns {Promise.<void>}
     */
    async modifyGLJ(data,ration_glj){
        let unitPriceFileModel = new UnitPriceFileModel();
        let unitPriceFile = await unitPriceFileModel.getDataByProject(data.project_id);
        if (!unitPriceFile) {
            throw '没有对应的单价文件';
        }
        //查找单价信息，有则返回，没有则新增并返回
        let unitPriceFileId = unitPriceFile.id;
        let unitPriceModel = new UnitPriceModel();
        let [unitPriceData, isAdd] = await unitPriceModel.addUnitPrice(data, unitPriceFileId,"modify");
        let gljData=null;
        if(isAdd){ //如果是新增，则新增一条新的项目工料机
            data.code = unitPriceData.code;
            gljData  = await this.insertGLJWhenIsAdd(data,ration_glj,unitPriceFileId);
        }else { //如果不是新增，则查找是否有对应的项目工料机，有则返回，没有则新增
            let condition = {
                project_id:data.project_id,
                original_code: data.original_code,
                name:data.name,
                specs:data.specs,
                type:data.type,
                unit:data.unit
            }
            let gljList = await this.findDataByCondition(condition,{_id: 0},false);
            if(gljList&&gljList.length>0){
                for(let tem of gljList){
                    if(tem.code == unitPriceData.code){
                        gljData = tem;
                    }
                }
            }
            if(gljData==null){
                data.code = unitPriceData.code;
                gljData  = await this.insertGLJWhenIsAdd(data,ration_glj,unitPriceFileId);
            }
        }
        gljData.unit_price = unitPriceData;
        return gljData
    }

    //修改属性后插入项目工料机
    async insertGLJWhenIsAdd(glj,ration_glj,unitPriceFileId){
        //新增项目工料机
        let gljData = await this.add(glj);
        //查看是否是有配合比的工料机类型
        if(this.ownCompositionTypes.indexOf(glj.type)!=-1){
            // 配合比数据插入
            let key_array = [];
            if(ration_glj.subType){//定额类型的工料机和定额工料机的key有点不同subType
                key_array=  ['code','name','specs','unit','subType'];
            }else {
                key_array=  ['code','name','specs','unit','type'];
            }
            let connect_key =this.getIndex(ration_glj,key_array);
            let connect_key_n =this.getIndex(glj,['code','name','specs','unit','type']);
            //先查找配合比数据是否已经存在
            let mixRatioModel = new MixRatioModel();
            let mixRatios_o = await mixRatioModel.findDataByCondition({connect_key: connect_key_n, unit_price_file_id: unitPriceFileId}, {_id: 0}, false);
            if(mixRatios_o&&mixRatios_o.length>0){//已经存在，不用再插入配合比数据，直接返回
                return gljData;
            }
            //不存在，则查找原始的配合比数据，并为新工料机增加配合比数据
            let mixRatios = await mixRatioModel.findDataByCondition({connect_key: connect_key, unit_price_file_id: unitPriceFileId}, {_id: 0}, false);
            let mixInsertResult ={};
            if(mixRatios&&mixRatios.length>0){
                let newMixRatioData = [];
                for(let m of mixRatios){
                    if(m.code == '80CCS') continue; //忽略原来的组成物信息，重新查看有没有匹配的
                    let tem ={
                        consumption: m.consumption,
                        glj_id: m.glj_id,
                        unit_price_file_id: m.unit_price_file_id,
                        connect_key: connect_key_n,
                        type: m.type,
                        code: m.code,
                        specs:m.specs,
                        name:m.name,
                        unit:m.unit
                    };
                    newMixRatioData.push(tem);
                }
                if(glj.type == 301){//机械台班添加车船税
                    let newM = await this.getCCSData(glj,unitPriceFileId);
                    if(newM) newMixRatioData.push(newM);
                }
                mixInsertResult= await mixRatioModel.add(newMixRatioData);
            }
        }
        return gljData;

    }


    /**
     * 根据工料机id修改市场单价
     *
     * @param {Object} updateData
     * @return {Promise}
     */
    async modifyMarketPrice(updateData) {
        let result = {};
        try {
            if (updateData.code === undefined || updateData.market_price === undefined ||
                updateData.name === undefined || updateData.project_id === undefined) {
                throw '参数有误!';
            }

            // 先查是否有对应code的数据
            let gljListData = await this.findDataByCondition({code: updateData.code,
                project_id: updateData.project_id}, {_id: 0}, false);
            if (!gljListData) {
                throw '不存在对应code数据';
            }

            // 获取标段对应的单价文件id
            let unitPriceFileModel = new UnitPriceFileModel();
            let unitPriceFile = await unitPriceFileModel.getDataByProject(updateData.project_id);
            if (!unitPriceFile) {
                throw '没有对应的单价文件';
            }
            let unitPriceFileId = unitPriceFile.id;
            let unitPriceModel = new UnitPriceModel();

            let gljCount = gljListData.length;
            let [unitPriceData, isAdd] = await unitPriceModel.addUnitPrice(updateData, unitPriceFileId,"modify", gljCount);

            // 判断是否已存在对应数据
            let includeField = [
                {field: 'name', value: unitPriceData.name}
            ];
            let gljIndex = this.isIncluded(gljListData, includeField);
            let gljData = isAdd ? {} : gljListData[gljIndex];

            // 如果单价数据新增则工料机也需要新增
            if (isAdd) {
                // 如果没有对应的记录则新增一条工料机数据，并更改name
                let regular = /\(\d+\)/;
                let changeString = '(' + gljCount + ')';
                updateData.name = regular.test(updateData.name) ? updateData.name.replace(regular, changeString) :
                    updateData.name + changeString;

                // 获取第一条数据作为数据源
                let originalData = gljListData[0];

                // 更改名称
                originalData.name = updateData.name;
                originalData = JSON.stringify(originalData);
                gljData = await this.add(JSON.parse(originalData));
                if (!gljData) {
                    throw '新增工料机数据失败!';
                }
            }

            gljData.unit_price = unitPriceData;

            result = gljData;
        } catch (error) {
            console.log(error);
            result = {};
        }

        return result;
    }

    /**
     * 判断数据中是否包含某个数据
     *
     * @param {Array} data
     * @param {Array} includeField
     * @return {Number}
     */
    isIncluded(data, includeField) {
        let index = -1;
        if (data.length <= 0) {
            return index;
        }
        for(let tmp in data) {
            let counter = 0;
            for (let includeTmp of includeField) {
                if (data[tmp][includeTmp.field] === includeTmp.value) {
                    counter++;
                }
            }
            if (counter === includeField.length) {
                index = tmp;
                break;
            }
        }

        return index;
    }
    //
    async getCCSData(data,unitFileId){
        let unitPriceFileModel = new UnitPriceFileModel();
        let unitFileInfo =  await unitPriceFileModel.findDataByCondition({id: unitFileId});
        if(unitFileInfo.vvTaxFileID && unitFileInfo.vvTaxFileID!=""){
             let condition = {libID:unitFileInfo.vvTaxFileID,code:data.code,name:data.name,type:data.type,unit:data.unit,specs:data.specs};
             let item =  await vvTaxModel.findOne(condition);
             if(item){
                 return gljUtil.getBaseCCSMixRatio(unitFileId,item.vehicleVesselTax,gljUtil.getIndex(data))
             }
        }
        return null;
    }


    /**
     * 工料机中组成物操作
     * 该方法只在确保没有对应项目工料机的时候才会调用
     *
     * @param {Object} data
     * @param {Number} projectId
     * @return {void}
     */
    async compositionInit(data, unitPriceFileId,ext) {
        let gljId = data.glj_id === undefined ? 0 : data.glj_id;
        let projectId = data.project_id === undefined ? 0 : data.project_id;
        let mixRatioModel = new MixRatioModel();
        if (gljId === 0 || projectId === 0) {
            throw '参数错误';
        }
        let fromTable = data.from === undefined ? 'std' : data.from;
        var connect_key =this.getIndex(data,['code','name','specs','unit','type']);
        let e_mList = await this.getCompositionGLJListFromMixRatio(projectId,unitPriceFileId,connect_key,fromTable);
        //如果组成物数据已经存在，则以单价文件中组成物的数据为准，不用再往下做判断了（项目工料机中需要插入的已经在上一步中生成插入）
        if(e_mList.length > 0) return;

        // 查找对应组成物的项目工料机数据
        let indexs=['code','name','specs','unit','type'];
        let [projectGljList, compositionGljList] = await this.getCompositionGLJList(gljId, projectId, indexs, fromTable);
        // 整理配合比待插入数据，单价文件中配合比没有数据，则以库中的组成物信息为准
        let mixRatioInsertData = [];
        for (let tmp of compositionGljList) {
            let consumpiton = tmp.consumption;
            //只有标准的工料机的组成物才会有多单价、多组成物消耗量的情况 fromTable
            if(fromTable == 'std' && ext && ext.quantityField &&( tmp.consumption[ext.quantityField]!= undefined && tmp.consumption[ext.quantityField]!=null)){
                consumpiton = tmp.consumption[ext.quantityField];
            }
            // 配合比数据插入
            let mixRatioData = {
                consumption: consumpiton,
                glj_id: tmp.ID,
                unit_price_file_id: unitPriceFileId,
                connect_key: connect_key,
                type: tmp.gljType,
                code: tmp.code,
                specs:tmp.specs?tmp.specs:"",
                name:tmp.name,
                from:tmp.from,
                unit:tmp.unit?tmp.unit:''
            };
            mixRatioInsertData.push(mixRatioData);
        }
        //如果有车船税则加入到配合比表中 -- 先判断机械类型吧，所有都插入影响性能
        if(data.type == 301){//如果是机械台班，看有没有车船税 - modifyGLJ方法里也会有添加组成物，修改这里逻辑时记得同步修改。
            let newM = await this.getCCSData(data,unitPriceFileId);
            if(newM) mixRatioInsertData.push(newM);
        }
        let unitPriceModel = new UnitPriceModel();
        let unitPriceList = await unitPriceModel.model.find({unit_price_file_id:unitPriceFileId});//查找按文件id查找单价文件数据，用来判断单价文件信息是否已存在

        // 整理插入的数据
        let gljInsertData = [];
        let unitPriceInsertData = [];
        for(let tmp of compositionGljList) {
            let key = this.getIndex(tmp,['code','name','specs','unit','gljType']);
            if (projectGljList[key] === undefined) {
                // 项目工料机插入的数据
                let gljData = this.getProjectGLJNewData(tmp,projectId);
                gljInsertData.push(gljData);
            }
            let basePrice = tmp.basePrice;
            //只有标准的工料机的组成物才会有多单价、多组成物消耗量的情况 fromTable
            if(fromTable == 'std' && ext && ext.priceField &&(tmp.priceProperty && tmp.priceProperty[ext.priceField]!= undefined && tmp.priceProperty[ext.priceField]!=null)){
                basePrice = tmp.priceProperty[ext.priceField];
            }
            basePrice = scMathUtil.roundTo(basePrice,-6);

            // 单价文件插入的数据
            let unitPriceData = {
                base_price: basePrice,
                // 初始市场价=基价
                market_price: basePrice,
                code: tmp.code,
                name: tmp.name,
                unit_price_file_id: unitPriceFileId,
                type: tmp.gljType,
                short_name: tmp.shortName === undefined ? '' : tmp.shortName,
                glj_id: tmp.ID,
                specs: tmp.specs?tmp.specs:'',
                unit: tmp.unit === undefined ? '' : tmp.unit,
                original_code:tmp.code,
                grossWeightCoe:tmp.grossWeightCoe,
                purchaseStorageRate:tmp.purchaseStorageRate,
                offSiteTransportLossRate:tmp.offSiteTransportLossRate,
                handlingLossRate:tmp.handlingLossRate
            };
            if(tmp.from=='cpt'){
                unitPriceData.is_add = 1;
            }
           if(!unitPriceModel.isPropertyInclude(unitPriceList,['code','name','specs','unit','type'],unitPriceData)){
               unitPriceInsertData.push(unitPriceData);
           }
        }
        // 整理完后开始插入数据

        // 插入单价数据表
        if(unitPriceInsertData.length >0) await unitPriceModel.add(unitPriceInsertData);

        //插入配合比数据
        if(mixRatioInsertData.length>0){
            let addMixRatioResult = await mixRatioModel.add(mixRatioInsertData);
            if (!addMixRatioResult) {
                throw '组成物插入单价数据失败!';
            }
        }

       //插入项目工料机
        if(gljInsertData.length > 0) await this.add(gljInsertData);
        return
    }

    getProjectGLJNewData(tmp,projectId){
        let gljData = {
            glj_id: tmp.ID,
            project_id: projectId,
            code: tmp.code,
            name: tmp.name,
            specs: tmp.specs?tmp.specs:'',
            unit: tmp.unit === undefined ? '' : tmp.unit,
            type: tmp.gljType,
            adjCoe:tmp.adjCoe,
            original_code:tmp.code,
            materialType: tmp.materialType,   //三材类别
            materialCoe: tmp.materialCoe,
            from:tmp.from?tmp.from:"std"
        };
        return gljData;
    }


    /**
     * 获取组成物具体数据
     *
     * @param {Number} projectGLJId
     * @param {Number} unitPriceFileId
     * @return {Promise}
     */
    async getCompositionList(projectGLJId, unitPriceFileId) {
        let result = [];
        try {
            // 查找对应的项目工料机数据
            let projectGLJData = await this.getDataById(projectGLJId,unitPriceFileId);

            let allowType = this.ownCompositionTypes;

            if (projectGLJData.unit_price === null || allowType.indexOf(projectGLJData.unit_price.type) < 0) {
                throw '找不到相关项目工料机';
            }
            // 查找对应的项目工料机数据配合比，单价数据
            let [gljData, mixRatioData,unitPriceData] = await this.getCompositionListByGLJ(projectGLJData, unitPriceFileId);

            if (gljData.length <= 0) {
                throw '没有对应的组成物项目工料机';
            }

            gljData = this.combineData(gljData, unitPriceData, [], mixRatioData);
            // 排序
            gljData.sort(function (a, b) {
                return parseInt(a.code) - parseInt(b.code);
            });
            result = gljData;
        } catch (error) {
            console.log(error);
            result = [];
        }

        return result;
    }

    //从配合比表中取组成物的信息以及对应的项目工料机信息，再从配合比数据中反查工料机库中的信息
    async getCompositionGLJListFromMixRatio (projectId,unitPriceFileId,connect_key,fromTable = 'std'){
        let mixRatioModel = new MixRatioModel();
        let e_mList = await mixRatioModel.model.find({unit_price_file_id: unitPriceFileId,connect_key: connect_key}).lean();
        if (e_mList.length <= 0) return [];
        let codeList = [];
        let ratioMap = {};
        for(let tmp of e_mList) {
            codeList.push(tmp.code);
            let ckey = this.getIndex(tmp);
            ratioMap[ckey] = tmp
        }
        // 查找对应的项目工料机数据
        let condition = {project_id: projectId,code: {"$in": codeList} };
        let gljData = await this.model.find(condition, {_id: 0}).lean();
        let matchGljs = {};
        for(let g of gljData){
            let gkey = this.getIndex(g);
            if(ratioMap[gkey]) matchGljs[gkey] = g;
        }

        //如果有组成物信息存在，但项目工料机信息不全的情况，应从数据库中查存询原始信息
        // （只有在父工料机是来自标准的情况下做这个操作，因为组成物表中没有存具体的工料机是来自补充的还是标准库，而父工料机是补充库的，组成物有可能来自两个库，而父来自标准，子只会来自标准）
        let lessIDList = [],lessMix=[];//lessMix只有在父工料机是来自补充工料机的时候才要用到
        let componentGljData = [];
        let gljInsertData = [];
        for(let mk in ratioMap){//找出缺少的工料机
            if(!matchGljs[mk]){
                lessMix.push(ratioMap[mk]);     
                lessIDList.push(ratioMap[mk].glj_id);
            }
        }
        if(lessIDList.length > 0){
            if(fromTable == "std"){
                let gljListModel = new STDGLJLibGLJListModel();
                let condition = {ID: {$in: lessIDList}};
                componentGljData = await gljListModel.model.find(condition).lean();
                for(let tmp of componentGljData){
                    let newProjctData = this.getProjectGLJNewData(tmp,projectId);
                    gljInsertData.push(newProjctData)
                }
            }else {
                for(let m of lessMix){
                  let mt = m;
                  if(m.from == "std"){
                    mt = await gljListModel.model.findOne({ID:m.glj_id}).lean();
                  }else{
                    mt.from = 'cpt';
                  }
                  let newProjctData =  this.getProjectGLJNewData(mt,projectId);
                  gljInsertData.push(newProjctData);
                }
            }

        }

        //这边只插入项目工料机数据，对于组成物文件中有的数据，理论上单价文件也是应该要有的，如果没有，那只能是mongodb数据库不支持事务的情况的问题
        if(gljInsertData.length > 0)  await this.add(gljInsertData);
        return e_mList;
    }

    /**
     * 获取混凝土等有组成物相关工料机对应的组成物项目工料机数据
     *
     * @param {Number} gljId
     * @param {Number} projectId
     * @param {String} indexBy
     * @param {String} fromTable
     * @return {Promise} 返回组成物工料机数据和组成物列表数据
     */
    async getCompositionGLJList(gljId, projectId, indexBy = null, fromTable = 'std') {
        // 获取对应的组成物数据
        let gljListModel = fromTable === 'std' ? new STDGLJLibGLJListModel() : new GljModel();
        let componentGljList = await gljListModel.getComponent(gljId);
        if (componentGljList.length <= 0) {
            return [{},[]];
        }
        //2019-11-15 优化，用5个属性条件去查意义不大，用编号就能过滤得差不多了，最后再用5个属性去匹配。 同时可以提高查询效率
        let codeList = [];
        let componentMap = {};
        for(let tmp of componentGljList) {
            codeList.push(tmp.code);
            let ckey = this.getIndex(tmp,['code','name','specs','unit','gljType']);
            componentMap[ckey] = tmp
        }
        // 查找对应的项目工料机数据
        let condition = {project_id: projectId,code: {"$in": codeList} };
        let gljData = await this.model.find(condition, {_id: 0}).lean();
        let matchGljs = {};
        for(let g of gljData){
            let gkey = this.getIndex(g);
            if(componentMap[gkey]) matchGljs[gkey] = g;
        }
        return [matchGljs, componentGljList];
    }

    async getCompositionGLJByData(glj,unitPriceFileId){
        let [gljData,mixRatioData,unitPriceData] = await this.getCompositionListByGLJ(glj,unitPriceFileId);
        let priceNum = unitPriceData?Object.getOwnPropertyNames(unitPriceData).length:0;
        let mixNum = mixRatioData?Object.getOwnPropertyNames(mixRatioData).length:0;
        if(priceNum !==mixNum){//检查组成物数据是否一致
            console.log("组成物数据有误，组成物单价文件个数："+priceNum+",    组成物个数："+mixNum);
            return []
        }
        gljData = this.combineData(gljData, unitPriceData, [], mixRatioData);
        return gljData;
    }



    /**
     * 反回组成物工料机和配合比数据
     * @param glj
     * @param unitPriceFileId
     * @returns {Promise.<void>}
     */
    async getCompositionListByGLJ(glj,unitPriceFileId){
        let t_index = this.getIndex(glj,['code','name','specs','unit','type']);
        // 查找对应的配合比数据
        let mixRatioModel = new MixRatioModel();
        let condition = {connect_key: t_index, unit_price_file_id: unitPriceFileId};
        let mixRatios = await mixRatioModel.model.find(condition, {_id: 0}).lean();
        //2019-11-15 优化，用5个属性条件去查意义不大，用编号就能过滤得差不多了，最后再用5个属性去匹配。 同时可以提高查询效率
        let codeList = [];
        if(mixRatios.length<=0){
            return [[],[],[]];
        }
        let mixRatioData={};
        for(let tmp of mixRatios) {
            codeList.push(tmp.code);
            let m_index = this.getIndex(tmp,['code','name','specs','unit','type']);
            mixRatioData[m_index]=tmp;
        }
        //数组去重
        codeList = _.uniq(codeList);
        // 查找对应的项目工料机数据
        let gcondition = {project_id: glj.project_id?glj.project_id:glj.projectID,code: {"$in": codeList}};
        let gljData = await this.model.find(gcondition, {_id: 0}).lean();
        // 查找对应的单价数据
        let unitPriceModel = new UnitPriceModel();
        let ucondition = { unit_price_file_id: unitPriceFileId,code: {"$in": codeList}};
        let unitPriceList = await unitPriceModel.model.find(ucondition, {_id: 0}).lean();


        // 整理数据
        let unitPriceData = {};
        for(let tmp of unitPriceList) {
            let u_index = this.getIndex(tmp,['code','name','specs','unit','type']);
            if(mixRatioData[u_index]) unitPriceData[u_index] = tmp;//过滤掉不完全匹配的工料机单价
        }
        let c_gljData = [];
        for(let g of gljData){//过滤掉不是组成物的工料机
            let g_index =  this.getIndex(g,['code','name','specs','unit','type']);
            if(mixRatioData[g_index]) c_gljData.push(g);
        }
        return [c_gljData,mixRatioData,unitPriceData];

    }

    /**
     * 根据条件获取对应项目工料机数据
     *
     * @param {Number} id
     * @return {Promise}
     */
    async getDataById(id,unitPriceFileId) {

        // 查找对应的项目工料机数据
        let projectGLJData = await this.findDataByCondition({id: id});
        if (projectGLJData === null) {
            throw '没有找到对应数据';
        }

        // 查找对应的单价数据
        let unitPriceModel = new UnitPriceModel();
        let condition={
            unit_price_file_id:unitPriceFileId,
            code: projectGLJData.code,
            name:projectGLJData.name,
            specs:projectGLJData.specs,
            type:projectGLJData.type,
            unit:projectGLJData.unit
        }
        let unitPrice = await unitPriceModel.findDataByCondition(condition);

        projectGLJData.unit_price = unitPrice;

        return projectGLJData;
    }

}

module.exports = GLJListModel;