/**
 * Created by zhang on 2018/1/26.
 */
let  projectsModel = require("../../pm/models/project_schema");

module.exports = {
    markUpdateProject:markUpdateProject,
    removeProjectMark:removeProjectMark
};

//data = {feeRateID:111111,projectID:1245}; type = feeRate
async function markUpdateProject(data,type) {
    let tasks=[];
    let query = {deleteInfo:null};
    let result = null;
    if(type=="feeRate"){//更改了费率
        query['property.feeFile.id'] = data.feeRateID;
    }
    if(type=="unitFile"){//更改了单价文件
        query['property.unitPriceFile.id'] = data.unitFileID;//unitPriceFile
    }
    let projects =await projectsModel.find(query);
    for(let p of projects){
        if(p.ID!=data.projectID){//当前项目不用更新
            tasks.push(generateMarkTask(type,p.ID));
        }
    }
    if(tasks.length>0){
        result = await projectsModel.bulkWrite(tasks);
    }
    return result;
}

async function removeProjectMark(projectID) {
    return await projectsModel.findOneAndUpdate({ID:projectID},{"$unset":{"changeMark":1}});
}

function generateMarkTask(value,projectID) {
    let task = {
        updateOne:{
            filter:{
                ID:projectID
            },
            update:{
                changeMark:value
            }
        }
    };
    return task
}