ConstructionCost/modules/main/models/bills.js

/**
 * Created by jimiz on 2017/4/1.
 */
let mongoose = require("mongoose");
let async = require("async");
let counter = require("../../../public/counter/counter.js");
let consts = require('./project_consts');
let projectConsts = consts.projectConst;
let commonConsts = consts.commonConst;
let quantity_detial = require('../facade/quantity_detail_facade');
let projectModel = require('../../pm/models/project_schema');

let bills = mongoose.model("bills");
let baseModel = require('./base_model');

class billsModel extends baseModel {
    constructor () {
        super(bills);
    };

    getData (projectID, callback) {
        this.model.find({'$or': [{projectID: projectID, deleteInfo: null}, {projectID: projectID, 'deleteInfo.deleted': {$in: [null, false]}}]}, '-_id', function(err, datas){
            if (!err) {
                callback(0, projectConsts.BILLS, datas);
            } else {
                callback(1, projectConsts.BILLS, null);
            };
        });
    };

    save (user_id, datas, callback) {
        let functions = [];
        let data;

        function saveOne(doc) {
            return function (cb) {
                switch (doc.updateType) {
                    case commonConsts.UT_UPDATE:
                        async.parallel([      // CSL,2018.01.10 如果是总造价清单，要将4个汇总金额写到projects表中
                            function (asyncCB) {
                                bills.update({projectID: doc.updateData.projectID, ID: doc.updateData.ID,deleteInfo: null}, doc.updateData, asyncCB);
                            },
                            function (asyncCB) {
                                if (doc.updateData.summaryFees){
                                    // console.log('%%%%%%%%%%%%%%%%%%%  ' + doc.updateData.projectID + ' | ' + JSON.stringify(doc.updateData.summaryFees));
                                    projectModel.update({ID: doc.updateData.projectID}, {"summaryFees": doc.updateData.summaryFees}, asyncCB);
                                }else {
                                    asyncCB(null, {});
                                };
                            }
                        ], function(err,result){
                            cb(err, {});
                        });
                        break;
                    case commonConsts.UT_CREATE:
                        bills.create(doc.updateData, cb);
                        break;
                    case commonConsts.UT_DELETE:
                        doc.updateData.deleteInfo = {deleted: true, deleteDateTime: new Date(), deleteBy: user_id};
                        bills.update({projectID: doc.updateData.projectID, ID: doc.updateData.ID}, doc.updateData, cb);
                        break;
                }
            }
        }
        for (let i = 0; i < datas.length; i++){
            data = datas[i];
            functions.push(saveOne(data));
            quantity_detial.quantityEditChecking(data,'bills',functions);
        }
        async.parallel(functions, function(err,result){
            let returnData = {
                moduleName:'bills',
                data:result
            };
            callback(err, returnData);
        });
    };

    getItemTemplate (callback) {
        let data = new bills;
        /* to do: 需要根据标准配置库填充fees和flags字段，是否需要更多的参数？ */
        callback(0, '', data);
    };

    allocIDs (IDStep, callback) {
        counter.counterDAO.getIDAfterCount(counter.moduleName.bills, IDStep, function(err, highID){
            let lowID = highID - IDStep + 1;
            callback(0, '', {lowID: lowID, highID: highID});
        });
    };
    //zhong 2017-9-1
    updateCharacterContent(findSet, updateObj, txtObj, callback) {
        let updateSet = {};
        updateSet[updateObj.field] = updateObj.updateArr;
        if(txtObj && typeof txtObj !== 'undefined'){
            updateSet[txtObj.field] = txtObj.text;
        }
       bills.update(findSet, updateSet, function (err) {
           if(err){
               callback(1, '更新失败');
           }
           else{
               callback(0, '更新成功');
           }
       });
    };
    async updateBill(findSet, updateData) {
        let update = {};
        if (!updateData instanceof Array) {
            return false;
        }

        for (const tmp of updateData) {
            if (tmp === undefined) {
                continue;
            }
            update[tmp.field] = tmp.value;
        }

        if (Object.keys(update).length <= 0) {
            return false;
        }

        return bills.update(findSet, update);
    };
}

module.exports = new billsModel();