/**
 * Created by Tony on 2017/4/28.
 */
var mongoose = require("mongoose");
var dbm = require("../../../config/db/db_manager");
var db = dbm.getCfgConnection("rationRepository")
//var async = require("async");
var Schema = mongoose.Schema;

var rationItemSchema = mongoose.Schema({
    ID:Number,
    //以下是基于已有access库
    code: String,
    name: String,
    unit: String,
    basePrice: Number,
    sectionId: Number,
    caption: String,
    feeType: Number
});
var rationItemModel = db.model("rationItems",rationItemSchema, "rationItems")
var counter = require('../../../public/counter/counter');

var rationItemDAO = function(){};

rationItemDAO.prototype.getRationItemsBySection = function(sectionId,callback){
    rationItemModel.find({"sectionId": sectionId, "$or": [{"isDeleted": null}, {"isDeleted": false} ]},function(err,data){
        if(err) callback(true, "获取定额错误！", "")
        else callback(false,"获取定额", data);
    })
};
rationItemDAO.prototype.updateRationItems = function(updateItems, addItems, callback){
    var me = this;
    if (!(updateItems) || updateItems.length == 0) {
        me.addRationItems(addItems, callback);
    }
};

rationItemDAO.prototype.getRationItemsByCode = function(code,callback){
    //
};

rationItemDAO.prototype.addRationItems = function(items,callback){
    if (items && items.length > 0) {
        counter.counterDAO.getIDAfterCount(counter.moduleName.ration, items.length, function(err, result){
            var maxId = result.value.sequence_value;
            var arr = [];
            for (var i = 0; i < items.length; i++) {
                var obj = new rationItemModel(items[i]);
                obj.ID = (maxId - (items.length - 1) + i);
                arr.push(obj);
            }
            rationItemModel.collection.insert(arr, null, function(err, docs){
                if (err) {
                    callback(true, "保存定额错误！", false);
                } else {
                    callback(false, "保存定额成功！", docs);
                }
            })
        });
    } else {
        callback(true, "定额数据源错误！", false);
    }
};

rationItemDAO.prototype.updateRationItems = function(items,callback){
    //
};

module.exports = new rationItemDAO()