ConstructionCost/modules/ration_glj/facade/ration_coe_facade.js

/**
 * Created by chen on 2017/7/6.
 */

let mongoose = require('mongoose');
const uuidV1 = require('uuid/v1')
let consts = require('../../main/models/project_consts');
let commonConsts = consts.commonConst;
let _=require("lodash");
let async_n = require("async");
let coeMolde = mongoose.model('std_ration_lib_coe_list');
let ration_coe = mongoose.model('ration_coe');

module.exports={
    save:save,
    getData:getData,
    delete_ration_coe:delete_ration_coe
}
let operationMap={
    'ut_create':create_ration_coe,
    'ut_update':update_ration_coe,
    'ut_delete':delete_ration_coe
};

function create_ration_coe(user_id,datas) {
    return function (callback) {
        let ration_coe_list=datas.ration_coe_list;
        var tasks=[];
        for(let i=0;i<ration_coe_list.length;i++){
            ration_coe_list[i].ID = uuidV1();
            ration_coe_list[i].seq = i;
            tasks.push(get_lib_coe_info(ration_coe_list[i]));
        }
        async_n.parallel(tasks,(err,results)=>{
            if(err){
                callback(err,results)
            }else {
                ration_coe.insertMany(results,(err,doc)=>{
                    if(err){
                        callback(err,null);
                    }else {
                        let returndata ={
                            updateTpye:commonConsts.UT_CREATE,
                            moduleName:'ration_coe',
                            data:results
                        }
                        callback(null,returndata)
                    }
                });
            }
        })

    }
}
function update_ration_coe(user_id,datas) {
    return function(callback) {
        ration_coe.update(datas.query,datas.doc,(err,result)=>{
            if(err){
                callback(err,'');
            }else {
                let returndata ={
                    moduleName:'ration_coe',
                    data:{
                        updateTpye:commonConsts.UT_UPDATE,
                        query:datas.query,
                        doc:datas.doc
                    }
                }
                callback(null,returndata)
            }
        })
    }
}
function delete_ration_coe(data) {
    return function (callback) {
        ration_coe.deleteMany({projectID: data.projectID, rationID: data.ID},(err,result)=>{
            commonCallback(callback,result,err)
        });
    }
}


function get_lib_coe_info(ration_coe) {
    return function (cb) {
        if(ration_coe.coeID == -1){//自定义系数
            cb(null,ration_coe);
        }else {
           let query ={
                "libID": ration_coe.libID,
                "ID": ration_coe.coeID,
                "$or": [{"isDeleted": null}, {"isDeleted": false}]
            };
            coeMolde.findOne(query,(err,coe)=>{
                if(err){
                    cb(err,'')
                }else {
                    ration_coe.name = coe.name;
                    ration_coe.content = coe.content;
                    ration_coe.isAdjust=0;
                    ration_coe.coes = coe.coes;
                    cb(null,ration_coe);
                }
            })
        }
    }
}



function getData(projectID, callback) {
    ration_coe.find({'projectID':projectID}).sort('seq').exec((err,datas)=>{
        if(err){
            callback(1, '', null);
        }else {
            callback(0, consts.projectConst.RATION_COE, datas);
        }
    })
}

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)
            }
        }
    })
}

function commonCallback(callback,result,err) {
    if(err){
        callback(err,'');
    }else {
        callback(null,result);
    }
}