YangHuCost/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 = mongoose.model('projects');
let rationModel = mongoose.model('ration');
let rationGljModel = mongoose.model('ration_glj');
let rationCoeModel = mongoose.model('ration_coe');
let rationInstModel = mongoose.model('ration_installation');
let quantityDelModel = mongoose.model('quantity_detail');
const { fixedFlag } = require('../../../public/common_constants');

let bills = mongoose.model("bills");
let baseModel = require('./base_model');
const uuidV1 = require('uuid/v1');
const billType = {
    DXFY: 1,//大项费用
    FB: 2,//分部
    FX: 3,//分项
    BILL: 4,//清单
    BX: 5//补项
};

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

    getData(projectID, callback, isReport = false) {
        //已经改成真删除了 {'$or': [{projectID: projectID, deleteInfo: null}, {projectID: projectID, 'deleteInfo.deleted': {$in: [null, false]}}]}
        this.model.find({ projectID: projectID }, '-_id', function (err, datas) {
            if (!err) {
                if (isReport) {   // 调价中间件机制
                    for (let i = 0; i < datas.length; i++) {
                        let fees = datas[i]._doc.fees;
                        if (fees) {
                            for (let i = 0; i < fees.length; i++) {
                                let doc = fees[i]._doc;
                                if (doc) {
                                    if (doc.tenderTotalFee) doc.totalFee = doc.tenderTotalFee;
                                    if (doc.tenderUnitFee) doc.unitFee = doc.tenderUnitFee;
                                }
                            }
                        }
                    }
                };
                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);
                        bills.deleteOne({ projectID: doc.updateData.projectID, ID: doc.updateData.ID }, 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 updateBills(updateDatas) {
        let bulk = [];
        for (let updateData of updateDatas) {
            bulk.push({ updateOne: { filter: updateData.findSet, update: { $set: updateData.updateData } } });
        }
        await bills.bulkWrite(bulk);
    };
    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);
    };
    async importBills(bills) {
        let operations = [];
        for (let bill of bills) {
            operations.push({ insertOne: { document: bill } });
        }
        return await this.model.bulkWrite(operations);
    }
    //删除清单节点的所有子节点及其他附带数据
    async deepDeleteBill(bills, userID, projectID) {
        let bill_ids = [],
            ration_ids = [];
        let me = this;
        function getIDs(datas) {
            let ids = [];
            for (let data of datas) {
                ids.push(data.ID);
            }
            return ids;
        }
        /*
        async function findBillsChildren(bills){
            if(bills.length > 0){
                let ids = getIDs(bills);
                bill_ids = bill_ids.concat(ids);
                let findBills = await me.model.find({ParentID: {$in: ids}, deleteInfo: null});
                await findBillsChildren(findBills);
            }
        }
        await findBillsChildren(bills);
        /*/
        // 优化：一次性获取所有清单，再一个个剔除，剩下bills下所有的子清单，省的递归查询
        const allBills = await me.model.find({ projectID: projectID }, '-_id');
        function getAllSubIDs(topDatas) {
            bill_ids = bill_ids.concat(getIDs(topDatas));
            function _getSubs(datas, rstBills) {
                let subIDs = []
                for (let bill of allBills) {
                    for (let data of datas) {
                        if (data.ID === bill.ParentID) {
                            subIDs.push(bill.ID);
                            rstBills.push(bill);
                        }
                    }
                }
                return subIDs;
            }
            let chkBills = [];
            let chkIds = _getSubs(topDatas, chkBills);
            while (chkIds.length > 0) {
                bill_ids = bill_ids.concat(chkIds);
                let subBills = [];
                chkIds = _getSubs(chkBills, subBills);
                chkBills = subBills;
            }
        }
        getAllSubIDs(bills);
        //*/

        //剔除第一个节点
        bill_ids = bill_ids.slice(1);
        //获取删除清单下的所有定额
        let rations = await rationModel.find({ billsItemID: { $in: bill_ids }, deleteInfo: null }, 'ID');
        ration_ids = ration_ids.concat(getIDs(rations));
        //deep delete datas
        let deleteInfo = { deleted: true, deleteDateTime: new Date(), deleteBy: userID };
        if (bill_ids.length > 0) {
            //删除bills
            await me.model.deleteMany({ ID: { $in: bill_ids } });
            //删除bill-quantity_detail
            await quantityDelModel.deleteMany({ billID: { $in: bill_ids } });
        }
        if (ration_ids.length > 0) {
            //删除rations
            await rationModel.deleteMany({ ID: { $in: ration_ids } });
            //删除ration-glj
            await rationGljModel.deleteMany({ rationID: { $in: ration_ids } });
            //删除ration-coe
            await rationCoeModel.deleteMany({ rationID: { $in: ration_ids } });
            //删除ration-quantity_detail
            await quantityDelModel.deleteMany({ rationID: { $in: ration_ids } });
        }
        return { bill: bill_ids, ration: ration_ids };
    }

    async newDeepDeleteBill(bill_ids, ration_ids) {
        let me = this;
        //deep delete datas
        if (bill_ids.length > 0) {
            //删除bills
            await me.model.deleteMany({ ID: { $in: bill_ids } });
            //删除bill-quantity_detail
            await quantityDelModel.deleteMany({ billID: { $in: bill_ids } });
        }
        if (ration_ids.length > 0) {
            //删除rations
            await rationModel.deleteMany({ ID: { $in: ration_ids } });
            //删除ration-glj
            await rationGljModel.deleteMany({ rationID: { $in: ration_ids } });
            //删除ration-coe
            await rationCoeModel.deleteMany({ rationID: { $in: ration_ids } });
            //删除ration-installation
            await rationInstModel.deleteMany({ rationID: { $in: ration_ids } });
            //删除ration-quantity_detail
            await quantityDelModel.deleteMany({ rationID: { $in: ration_ids } });
        }
        return { bill: bill_ids, ration: ration_ids };
    }
}

module.exports = new billsModel();