/** * Created by vian on 2017/3/20. */ let model = require("./bills_lib_model"); let counter = require("../../../public/counter/counter"); let StdBillsLib = model.stdBillsLibMod; let Bills = model.billsMod; let JobContent = model.jobContentMod; let ItemCharacter = model.itemCharacterMod; /*var fieldArr = ["code", "name", "unit", "ruleText", "Expression"];*/ let billsLibDao = function(){}; billsLibDao.prototype.getMaxNumber = function(gData, callback){ let billsLibId = gData.billsLibId; let field = gData.field; if(field === 'jobs'){ JobContent.find({billsLibId: billsLibId}).sort({code: -1}).limit(1).exec(function(err, result){ if(err){ callback(1, 'Error', null); } else { callback(0, '', result); } }); } else if(field === 'items'){ ItemCharacter.find({billsLibId: billsLibId}).sort({code: -1}).limit(1).exec(function(err, result){ if(err){ callback(1, 'Error', null); } else { callback(0, '', result); } }); } }; //----------StdBillsLib------------------- billsLibDao.prototype.getABillsLib = function(data, callback){ let billsLibId = data.billsLibId; StdBillsLib.find({billsLibId: billsLibId, deleted: false}, function(err, data){ if(err){ callback(1, 'Error', null); } else { callback(0, '', data); } }); }; billsLibDao.prototype.getStdBillsLib = function(data, callback){ let userId = data.userId; StdBillsLib.find({userId: userId, deleted: false}, "-_id", function(err, data){ if(err){ callback(1, "Error", null); } else{ callback(0, "", data); } }) }; billsLibDao.prototype.createStdBillsLib = function(clibData, callback){ counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib, 1, function(err, result){ let billsLibId = result.value.sequence_value; let userId = clibData.userId; let billsLibName = clibData.name; let createDate = Date.now(); let newStdBillsLib = { userId: userId, billsLibId: billsLibId, billsLibName: billsLibName, createDate: createDate, deleted: false }; StdBillsLib.create(newStdBillsLib, function(err){ if(err){ callback(1, "Error", null); } else { StdBillsLib.find({billsLibId: billsLibId}, function(err, data){ if(err){ callback(1, "Error", null) } else { callback(0, "", data); } }); } }); }); }; billsLibDao.prototype.deleteStdBillsLib = function(billsLibId, callback){ StdBillsLib.update({billsLibId: billsLibId}, {$set: {deleted: true}}, function(err){ if(err){ callback(1, 'Error'); } else{ callback(0, ''); } }); }; billsLibDao.prototype.renameStdBillsLib = function(renameData, callback){ let billsLibId = renameData.id; let renameVal = renameData.value; StdBillsLib.update({billsLibId: billsLibId}, {$set:{billsLibName: renameVal}}, function(err){ if(err){ callback(1, "Error"); } else{ callback(0, ""); } }); }; billsLibDao.prototype.getStdBillsLibName = function(billsLibId, callback){ StdBillsLib.find({billsLibId: billsLibId, deleted: false}, "-_id", function(err, data){ if(err){ callback(1, "Error", null); } else { callback(0, "", data); } }); }; billsLibDao.prototype.getCurrentUniqId = function(callback){ counter.counterDAO.getCurrentID(counter.moduleName.billsLib, function(result, err){ let id = result.sequence_value; if(err){ console.log(`enter1`); callback(1, 'Error', null); } else{ console.log(`enter2: ${result}`); console.log(`enter2-id: ${id}`); callback(0, '', id); } }); } //----------------------------Bills--------------------- billsLibDao.prototype.getBills = function (billsLibId, callback) { Bills.find({billsLibId: billsLibId, deleted: false}, "-_id", function(err, billsData){ if(err){ callback(1, "Error", null); } else{ callback(0, "", billsData); } }); } billsLibDao.prototype.createBills = function(cbillsData, callback){ let newId = cbillsData.newId; let pid = cbillsData.ParentID; let nid = cbillsData.NextSiblingID; let billsLibId = cbillsData.billsLibId; let newBills = { ID: newId, ParentID: pid, NextSiblingID: nid, billsLibId: billsLibId, code: '', name: '', unit: '', ruleText: '', Expression: '', recharge:'', deleted: false }; Bills.create(newBills, function(err){ if(err){ callback(1, "Error"); } else{ callback(0, ""); } }); }; billsLibDao.prototype.updatePNId= function(upData, callback){ let billsLibId = upData.billsLibId; let updateDatas = upData.updateData; let success = true; if(updateDatas.length > 0){ updateDatas.forEach(function(data){ if(data.ID.length >1){ data.ID.forEach(function(id){ if(data.ParentID && data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: id}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){ if(err){ callback(1, "Error") success = false; } }); } else if(data.ParentID && !data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: id}, {$set: {ParentID: data.ParentID}}, function(err){ if(err){ callback(1, 'Error'); success = false; } }); } else if(!data.ParentID && data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: id}, {$set: {NextSiblingID: data.NextSiblingID}}, function(err){ if(err){ callback(1, 'Error'); success = false; } }); } }); } else { if(data.ParentID && data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: data.ID}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){ if(err){ callback(1, "Error") success = false; } }); } else if(data.ParentID && !data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: data.ID}, {$set: {ParentID: data.ParentID}}, function(err){ if(err){ callback(1, 'Error'); success = false; } }); } else if(!data.ParentID && data.NextSiblingID){ Bills.update({billsLibId: billsLibId, ID: data.ID}, {$set: {NextSiblingID: data.NextSiblingID}}, function(err){ if(err){ callback(1, 'Error'); success = false; } }); } } }); } if(success){ callback(0, ''); } } billsLibDao.prototype.updateBills = function(ubillsData, callback){ let billsLibId = ubillsData.billsLibId; let updateId = ubillsData.updateId; let updateField = ubillsData.field; let updateData = ubillsData.data; if(updateField === "code"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {code: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } else if(updateField === "name"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {name: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } else if(updateField === "unit"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {unit: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } else if(updateField === "ruleText"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {ruleText: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } else if(updateField === "jobs"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$addToSet: {jobs: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } else if(updateField === "items"){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$addToSet: {items: updateData}}, function(err){ if(err){ callback(1, "Error"); } else { callback(0, ""); } }); } } billsLibDao.prototype.updateBillsArr = function(updateData, callback){ let billsLibId = updateData.billsLibId; let updateId = updateData.updateId; let orgId = updateData.orgId; let newId = updateData.newId; let classify = updateData.classify; let type = updateData.type; let success = true; if(classify === 'jobs'){ if(orgId && newId && type === 'update'){ Bills.update({billsLibId: billsLibId, ID: updateId, jobs: orgId}, {$set: {'jobs.$': newId}}, function(err){ if(err){ callback(1, 'Error'); } else { callback(0, ''); } }); } if(orgId && !newId && type === 'delete'){ orgId.forEach(function(oid){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$pull: {jobs: oid}}, function(err){ if(err){ callback(1, 'Error'); } }); }); } //todo: test if(orgId && !newId && type === 'deleteAll'){ updateId.forEach(function(uid){ orgId.forEach(function(oid){ Bills.update({billsLibId: billsLibId, ID: uid}, {$pull: {jobs: oid}}, function(err){ if(err){ callback(1, 'Error'); } }); }); }); } } else if(classify === 'items'){ if(orgId && newId && type === 'update'){ Bills.update({billsLibId: billsLibId, ID: updateId, items: orgId}, {$set: {'items.$': newId}}, function(err){ if(err){ callback(1, 'Error'); } else { callback(0, ''); } }); } if(orgId && !newId && type === 'delete'){ orgId.forEach(function(oid){ Bills.update({billsLibId: billsLibId, ID: updateId}, {$pull: {items: oid}}, function(err){ if(err){ callback(1, 'Error'); } }); }); } if(orgId && !newId && type === 'deleteAll'){ updateId.forEach(function(uid){ orgId.forEach(function(oid){ Bills.update({billsLibId: billsLibId, ID: uid}, {$pull: {items: oid}}, function(err){ if(err){ callback(1, 'Error'); } }); }); }); } } }; billsLibDao.prototype.pasteBills = function(pData, callback){ let datas = pData.datas; datas.forEach(function(data){ Bills.update({billsLibId: data.billsLibId, ID: data.ID}, {$set: {code: data.code, name: data.name, unit: data.unit, ruleText: data.ruleText}}, function(err){ if(err){ callback(1, 'Error'); } }); }); } billsLibDao.prototype.updateRecharge = function(uData, callback){ let billsLibId = uData.billsLibId; let updateIds = uData.updateIds; let data = uData.data; let success = true; updateIds.forEach(function(id){ Bills.update({billsLibId: billsLibId, ID: id}, {$set: {recharge: data}}, function(err){ if(err){ callback(1, 'Error'); success = false; } }); }); if(success){ callback(0, ''); } }; billsLibDao.prototype.pasteRel = function (data, callback) { const UpdateExist = 'updateExist', UpdateNew = 'updateNew', CreateExist = 'createExist', CreateNew = 'createNew'; let success = true; let ueDatas = [], unDatas = [], ceDatas = [], cnDatas = []; let frontDatas ; //let pasteDatas = data.pasteDatas; let field = data.field; let updateDatas = data.updateDatas; let createDatas = data.createDatas; const Jobs = 'jobs', Items = 'items'; if(field === Jobs){ if(updateDatas.length > 0){ for(let i=0; i 0){ for(let i=0; i 0){ for(let i=0; i 0){ for(let i=0; i 0){ for(let i=0; i 0){ for(let i =0; i 0){ deleteCodes.forEach(function(code){ ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$pull: {itemValue: {code: code}}}, function(err){ if(err){ callback(1, 'Error'); } }); }); } } }; billsLibDao.prototype.deleteItemCharacter = function(data, callback){ let delIds = data.ids; let success = true; let billsLibId = data.billsLibId; delIds.forEach(function(id){ /*ItemCharacter.remove({id: id}, function(err){ if(err){ callback(1, "Error"); } });*/ ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){ if(err){ success = false; callback(1, 'Error'); } }); }); } billsLibDao.prototype.pasteItems = function (data, callback) { let pasteDatas = data.pasteDatas; let updateDatas = pasteDatas.updateDatas, createDatas = pasteDatas.createDatas; if(updateDatas.length > 0){ for(let i=0; i 0){ for(let i =0; i 0) { for (let i = 0; i < updateDatas.length; i++) { let billsLibId = updateDatas[i].billsLibId, itemId = updateDatas[i].itemId, orgCode = updateDatas[i].orgId; console.log(`i = ${i}`); if (updateDatas[i].type === 'UpdateT') { console.log(`UpdateT`); let valueObj = {code: updateDatas[i].code, value: updateDatas[i].content}; ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$pull: {itemValue: {code: orgCode}}}, function (err) { if (err) { } else { ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$addToSet: {itemValue: valueObj}}, function (err) { if (err) { } }); } }); } else if (updateDatas[i].type === 'Update' && updateDatas[i].field === 'code') { console.log(`UpdateCode`); ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode}, {$set: {'itemValue.$.code': updateDatas[i].data}}, function (err) { if(err){ } }); } else { console.log(`UpdateValue`); console.log(`billsLibId: ${updateDatas[i].billsLibId} itemId: ${updateDatas[i].itemId} updateCode: ${updateDatas[i].orgId} value: ${updateDatas[i].data}`); ItemCharacter.update({billsLIbId: billsLibId, id: itemId, 'itemValue.code': orgCode}, {$set: {'itemValue.$.value': updateDatas[i].data}}, function(err, result){ if(err){ console.log(`Error`); } else { console.log(`success`); console.log(result); } }); } } } if(createDatas.length >0){ for(let i=0; i< createDatas.length; i++){ let valueObj if(createDatas[i].type === 'CreateT'){ console.log(`CreateT`); valueObj = {code: createDatas[i].code, value: createDatas[i].content}; ItemCharacter.update({billsLibId: createDatas[i].billsLibId, id: createDatas[i].itemId}, {$addToSet: {itemValue: valueObj}}, function (err) { if (err) { } }); } else if(createDatas[i].type === 'Create' && createDatas[i].field === 'code'){ console.log(`Create code`); valueObj = {code: createDatas[i].data, value: ''}; ItemCharacter.update({billsLibId: createDatas[i].billsLibId, id: createDatas[i].itemId}, {$addToSet: {itemValue: valueObj}}, function (err) { if (err) { } }); } else { console.log(`Create value`); valueObj = {code: createDatas[i].code, value: createDatas[i].data}; ItemCharacter.update({billsLibId: createDatas[i].billsLibId, id: createDatas[i].itemId}, {$addToSet: {itemValue: valueObj}}, function (err) { if (err) { } }); } } } callback(0, ''); }; // module.exports = new billsLibDao();