ConstructionCost/modules/main/models/project.js

/**
 * Created by jimiz on 2017/4/16.
 */
var billsData = require('./bills');
var rationData = require('./ration');
var GLJData = require('./glj');
let projCounter = require('./proj_counter');
var consts = require('./project_consts');
var projectConsts = consts.projectConst;
var async = require("async");

var moduleMap = {};

moduleMap[projectConsts.BILLS] = billsData;
moduleMap[projectConsts.RATION] = rationData;
moduleMap[projectConsts.GLJ] = GLJData;
moduleMap[projCounter.collectionName] = projCounter;

var Project = function (){};

Project.prototype.datas = [];

Project.prototype.prepare = function(data, callback){
    var me = this;
    data.update_data.forEach(function(item){
        item.user_id = data.user_id;
        me.datas.push(item);
        /*
        to do
        moduleMap[item.moduleName].prepare(item.data, jobCallback);
        */
    });
};

Project.prototype.save = function(datas, callback){
    var job, savePoint;
    var functions = [];
    var item;
    var me = this;

    me.prepare(datas, function(job, savePoint){});

    function saveModule(data) {
        return function (cb) {
            moduleMap[data.moduleName].save(data.user_id, data.data, cb);
        }
    }
    for (var i = 0; i < me.datas.length; i++){
        item = me.datas[i];
        functions.push(saveModule(item));
    }

    async.parallel(functions, function(err, results) {
        if (!err){
            callback(null, '', results)
        }
        else{
            callback(1, 'save project failed', null)
        }
    });
    me.datas = [];
};

Project.prototype.getData = function(projectID, callback){
    var functions = [];
    var itemName;

    for (itemName in moduleMap){
        functions.push((function(itemName){
            return function (cb) {
                moduleMap[itemName].getData(projectID, function(err, moduleName, data){
                    cb(err, {moduleName: moduleName, data: data})
                })
            }
        })(itemName))
    }

    async.parallel(functions, function(err, results) {
        if (!err){
            callback(null, '', results)
        }
        else{
            callback(1, 'load project failed', null)
        }
    });

};

module.exports = new Project();