/**
 * Created by chen on 2017/7/10.
 */
let mongoose = require('mongoose');
let consts = require('../../main/models/project_consts');
let commonConsts = consts.commonConst;
let _=require("lodash");
let async_n = require("async");
let std_ration_lib_ration_items = mongoose.model('std_ration_lib_ration_items');
let rationModel = mongoose.model('ration');
let ration_glj = mongoose.model('ration_glj');

module.exports={
    save:save,
    getData:getData
}

let operationMap={
    'ut_create':create_ration_ass,
    'ut_update':update_ration_ass,
    'ut_delete':delete_ration_ass
};

function create_ration_ass(user_id,datas) {

};

function update_ration_ass(user_id,datas) {
    return function (callback) {
        let editAss = datas.query.editAss;
        let times =calculateTimes(editAss);
        doRationAssAdjust(datas.query.ration,editAss,times,datas.doc).then(function (result) {
            console.log(result);
            if(result.err){
                callback(result.err,'')
            }else {
                let newObject = {
                    moduleName:consts.projectConst.RATION_ASS,
                    data:{
                        updateTpye:commonConsts.UT_UPDATE,
                        doc:datas.doc,
                        ration_glj_list:result.ration_glj_list,
                        rationID:datas.query.ration.ID,
                        editIndex:datas.query.editIndex,
                        actualValue:editAss.actualValue
                    }
                };
                callback(null,newObject);
            }
        })

    }

};

async function doRationAssAdjust(ration,ass,times,doc) {
    let result ={
        err:null,
        ration_glj_list:[]
    }
    try{
        let assRation =await std_ration_lib_ration_items.findOne({rationRepId:ration.libID,code:ass.assistCode});
        let gljList = assRation.rationGljList;
        for(let i=0;i<gljList.length;i++){
            let glj = gljList[i];
            let calQuantity = glj.consumeAmt*times;
            let update_ration_glj = await ration_glj.findOne({rationID:ration.ID,projectID:ration.projectID,GLJID:glj.gljId});
            let newQuantity = update_ration_glj.rationItemQuantity+calQuantity;
            await ration_glj.update({rationID:ration.ID,projectID:ration.projectID,GLJID:glj.gljId},{quantity:newQuantity});
            result.ration_glj_list.push({ID:update_ration_glj.ID,quantity:newQuantity,rationID:ration.ID});
        }
        await rationModel.update({projectID:ration.projectID,ID:ration.ID},doc);
        return result;
    }catch (err){
        result.err = err;
        return result;
    }
}




function delete_ration_ass(user_id,datas) {

};

function calculateTimes(ass){
    let times =(ass.actualValue-ass.stdValue)/ass.stepValue;

    if(ass.carryBit=='四舍五入'){
        times = _.round(times,ass.decimal);
    }else if (ass.carryBit=='进一'){
        times =_.ceil(times,ass.decimal);
    }
    return times;
}





function getData(projectID, callback) {
    callback(0, consts.projectConst.RATION_ASS, []);
}

function save (user_id, datas, callback) {
    let operations=[];
    if(_.isArray(datas)){
        for(let i=0;i<datas.length;i++){
            operations.push(operationMap[datas[i].updateType](user_id,datas[i]));
        }
    }else {
        operations.push(operationMap[datas.updateType](user_id,datas));
    }
    async_n.parallel(operations,function (err,results) {
        if(err){
            callback(err,'');
        }else {
            if(results.length==1){
                callback(null,results[0])
            }else {
                callback(null,results)
            }
        }
    })
}