ConstructionOperation/modules/std_glj_lib/models/gljMapModel.js

/**
 * Created by Zhong on 2017/8/11.
 */
const mongoose = require('mongoose');
const gljMapModel = mongoose.model('std_glj_lib_map');
const gljModel = mongoose.model('std_glj_lib_gljList');
const gljClassModel = mongoose.model('std_glj_lib_gljClass');
const rationRepository = mongoose.model('std_ration_lib_map');
const engLibModel = mongoose.model('engineering_lib');
const compleGljClassTemp = mongoose.model('complementary_glj_section_templates');
import moment from "moment";
import counter from "../../../public/counter/counter";
import async from "async";
let rationRepositoryDao = require("../../ration_repository/models/repository_map");

class OprDao {
    static updateOprArr(findSet, oprtor, date, cb) {
        let oprDate = moment(date).format('YYYY-MM-DD HH:mm:ss');
        gljMapModel.find(findSet, function (err, result) {
            if (err) {
                cb(err);
            }
            else {
                if (result.length === 1) {
                    let recentOprArr = result[0].recentOpr;
                    let isExist = false;
                    for (let i = 0; i < recentOprArr.length; i++) {
                        if (recentOprArr[i].operator === oprtor) {
                            recentOprArr[i].operateDate = oprDate;
                            isExist = true;
                        }
                    }
                    if (!isExist) {
                        if (recentOprArr.length < 5) {
                            recentOprArr.push({ operator: oprtor, operateDate: oprDate });
                        }
                        else if (recentOprArr.length === 5) {
                            recentOprArr.sort(function (a, b) {
                                if (a.operateDate > b.operateDate) {
                                    return -1;
                                } else {
                                    return 1;
                                }
                                return 0;
                            });
                            recentOprArr.splice(recentOprArr.length - 1, 1);
                            recentOprArr.splice(0, 1, { operator: oprtor, operateDate: oprDate });
                        }
                    }
                    gljMapModel.update(findSet, { $set: { recentOpr: recentOprArr } }, function (err) {
                        if (err) {
                            cb(err);
                        }
                        else {
                            cb(null);
                        }
                    });
                }
                else {
                    cb(err);
                }
            }
        });
    };
}


class GljMapDao extends OprDao {
    static createNewLibModel(gljLibObj) {
        var rst = {};
        rst.dispName = gljLibObj.dispName;
        rst.appType = gljLibObj.appType ? gljLibObj.appType : 'construct';
        rst.compilationId = gljLibObj.compilationId ? gljLibObj.compilationId : -1;
        rst.compilationName = gljLibObj.compilationName ? gljLibObj.compilationName : '';
        rst.creator = gljLibObj.creator;
        rst.createDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
        rst.recentOpr = [{ operator: gljLibObj.creator, operateDate: rst.createDate }];
        rst.deleted = false;
        return rst;
    }

    getGljLib(libId, callback) {
        gljMapModel.find({ ID: libId }, function (err, result) {
            if (err) {
                callback(err, '没有数据！', null);
            }
            else {
                callback(null, '成功', result);
            }
        })
    }
    async getAllGljLib(callback, compilationPermission) {
        try {
            let gljLibs = await gljMapModel.find({ deleted: false });
            gljLibs = gljLibs.filter(lib => compilationPermission.includes(lib.compilationId));
            for (let gljLib of gljLibs) {
                let tempRationLibs = [];
                for (let rationLib of gljLib.rationLibs) {
                    let rLib = await rationRepository.findOne({ ID: rationLib.ID, deleted: false });
                    if (rLib !== undefined && rLib !== null) {
                        tempRationLibs.push({ ID: rationLib.ID, dispName: rLib.dispName });
                    }
                }
                gljLib._doc.rationLibs = tempRationLibs;
            }
            callback(null, '成功', gljLibs);
        }
        catch (err) {
            callback(err, '没有定额库数据！', null);
        }
    }
    createGljLib(gljLibObj, callback) {
        counter.counterDAO.getIDAfterCount(counter.moduleName.stdGljLib, 1, function (err, result) {
            if (err) {
                callback(err, '获取新ID失败！');
            }
            else {
                let newGljLib = GljMapDao.createNewLibModel(gljLibObj);
                newGljLib.ID = result.sequence_value;
                gljMapModel.create(newGljLib, function (err, result) {
                    if (err) {
                        callback(err, '创建新工料机库失败！', null);
                    }
                    else {
                        callback(null, '创建成功', result);
                    }
                });
            }
        })
    }
    renameGljLib(oprtor, renameObj, callback) {
        gljMapModel.update({ ID: renameObj.ID, deleted: false }, { $set: { dispName: renameObj.newName } }, function (err) {
            if (err) {
                callback(err, '重命名失败！');
            }
            else {
                GljMapDao.updateOprArr({ ID: renameObj.ID, deleted: false }, oprtor, Date.now(), function (err) {
                    if (err) {
                        callback(err, '更新最近操作者失败！');
                    }
                    else {
                        engLibModel.update({ 'glj_lib.id': renameObj.ID }, { $set: { 'glj_lib.$.name': renameObj.newName } }, { multi: true }, function (err) {
                            if (err) {
                                callback(err, '更新工程专业引用失败！');
                            }
                            else {
                                callback(null, '成功！');
                            }
                        });
                    }
                });
            }
        });
    }
    removeGljLib(oprtor, libId, callback) {
        GljMapDao.updateOprArr({ ID: libId, deleted: false }, oprtor, Date.now(), function (err) {
            if (err) {
                callback(err, '失败!')
            }
            else {
                gljMapModel.find({ ID: libId, deleted: false }, function (err, result) {
                    if (err) {
                        callback(err, '数据不存在！');
                    }
                    else {
                        if (result[0].rationLibs.length > 0) {//已被引用
                            callback(null, '此人材机库已被引用！');
                        }
                        else {
                            async.parallel([
                                function (cb) {
                                    gljMapModel.remove({ ID: libId }, function (err) {
                                        if (err) {
                                            cb(err);
                                        }
                                        else {
                                            cb(null);
                                        }
                                    });
                                },
                                function (cb) {
                                    gljModel.remove({ repositoryId: libId }, function (err) {
                                        if (err) {
                                            cb(err);
                                        }
                                        else {
                                            cb(null);
                                        }
                                    });
                                },
                                function (cb) {
                                    gljClassModel.remove({ repositoryId: libId }, function (err) {
                                        if (err) {
                                            cb(err);
                                        }
                                        else {
                                            cb(null);
                                        }
                                    })
                                }
                            ], function (err) {
                                if (err) {
                                    callback(err, '移除工料机库失败！');
                                }
                                else {
                                    callback(null, '删除成功');
                                }
                            });
                            /* gljMapModel.update({ID: libId, deleted: false}, {$set: {deleted: true}}, function (err) {
                                 if(err){
                                     callback(err, '移除工料机库失败！');
                                 }
                                 else{
                                    callback(null, '删除成功');
                                 }
                             });*/
                        }
                    }
                });
            }
        });
    }
    async classTemplateCount(compilationId) {
        return await compleGljClassTemp.find({ compilationId }).count();
    }
    async initClassTemplate(gljLibId, compilationId) {
        let classTempCount = await compleGljClassTemp.find({ compilationId }).count();
        if (classTempCount > 0) {
            await compleGljClassTemp.remove({ compilationId });
        }
        let bulks = [];
        let stdGljClass = await gljClassModel.find({ repositoryId: gljLibId });
        for (let data of stdGljClass) {
            delete data._doc._id;
            data._doc.compilationId = compilationId;
            bulks.push({ insertOne: { document: data } });
        }
        if (bulks.length > 0) {
            await compleGljClassTemp.bulkWrite(bulks);
        }
    }
}

export { OprDao, GljMapDao };