/** * Created by vian on 2017/3/20. */ let model = require("./bills_lib_model"); let counter = require("../../../public/counter/counter"); let async = require("async"); let StdBillsLib = model.stdBillsLibMod; let Bills = model.billsMod; let JobContent = model.jobContentMod; let ItemCharacter = model.itemCharacterMod; let billsLibDao = function(){}; billsLibDao.prototype.getMaxNumber = function(gData, callback){ let billsLibId = gData.billsLibId; let field = gData.field; if(field === 'jobs'){ JobContent.find({billsLibId: billsLibId, deleted: false}).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, deleted: false}).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){ async.parallel([ function(cb){ StdBillsLib.update({billsLibId: billsLibId}, {$set: {deleted: true}}, function(err){ if(err){ cb(err); } else{ cb(null); } }); }, function(cb){ Bills.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){ cb(null); }); }, function(cb){ JobContent.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err, result){ cb(null); }); }, function(cb){ ItemCharacter.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){ cb(null); }) } ], 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){ callback(1, 'Error', null); } else{ 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 updatePreData = cbillsData.updatePreData; let newBills = { ID: newId, ParentID: pid, NextSiblingID: nid, billsLibId: billsLibId, code: '', name: '', unit: '', ruleText: '', Expression: '', recharge:'', deleted: false }; async.parallel([ function(cb){ Bills.create(newBills, function(err){ if(err){ cb(err); } else { cb(null); } }); }, function(cb){ if(updatePreData){ Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updatePreData.ID, deleted: false}, {$set: {NextSiblingID: updatePreData.NextSiblingID}}, function(err, result){ if(err){ cb(err); } else { cb(null) } }); } else { cb(null); } } ], function(err){ if(err){ callback(1, 'Error'); } else { callback(0, ''); } }); }; billsLibDao.prototype.upMove = function(data, callback){ let billsLibId = data.billsLibId, updateDatas = data.updateDatas; async.each(updateDatas, function(updateData, cb){ Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updateData.ID, deleted: false}, {$set: {NextSiblingID: updateData.NextSiblingID}}, function(err){ if(err){ cb(err); } else { cb(null); } }); }, function(err){ if(err){ callback(1, 'Error'); } else{ callback(0, ''); } }); }; billsLibDao.prototype.downMove = function (data, callbck) { let billsLibId = data.billsLibId, updateDatas = data.updateDatas, functions = []; let parallelFucs = { nextSiblingNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else{ cb(null); } }); }; }, oprNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else { cb(null); } }) } }, preSiblingNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else{ cb(null); } }); }; } }; for(let i =0; i< updateDatas.length; i++){ if(updateDatas[i].type === 'nextSiblingNode'){ functions.push(parallelFucs.nextSiblingNode(updateDatas[i])); } else if(updateDatas[i].type === 'oprNode'){ functions.push(parallelFucs.oprNode(updateDatas[i])); } else { functions.push(parallelFucs.preSiblingNode(updateDatas[i])); } } async.parallel(functions, function (err) { if(err){ callbck(1, 'Error'); } else{ callbck(0, ''); } }) } billsLibDao.prototype.upLevel = function(data, callback){ let billsLibId = data.billsLibId, updateDatas = data.updateDatas, functions = []; let parallelFucs = { oprNode: function (data) { return function (cb){ Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){ if(err){ console.log(`err1`); cb(err); } else { cb(null); } }); }; }, parentNode: function (data) { return function(cb){ Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ console.log(`err2`); cb(err); } else { cb(null); } }) }; }, nextSiblingNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID}}, function (err) { if(err){ console.log(`err3`); cb(err); } else{ cb(null); } }); }; }, preSiblingNode: function(data){ console.log(`billsLIbId: ${billsLibId} ID: ${data.ID} NextS: ${data.NextSiblingID}`); return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ console.log(`err4`); cb(err); } else { cb(null); } }); }; } } for(let i=0; i< updateDatas.length; i++){ if(updateDatas[i].type === 'oprNode'){ functions.push(parallelFucs.oprNode(updateDatas[i])); } else if(updateDatas[i].type === 'parentNode'){ functions.push(parallelFucs.parentNode(updateDatas[i])); } else if(updateDatas[i].type === 'nextSiblingNode'){ updateDatas[i].ID.forEach(function (id) { let obj = {ID: id, ParentID: updateDatas[i].ParentID}; functions.push(parallelFucs.nextSiblingNode(obj)); }); } else { functions.push(parallelFucs.preSiblingNode(updateDatas[i])); } } async.parallel(functions, function(err){ if(err){ console.log(`errfinal`); callback(1, 'Error'); } else{ callback(0, ''); } }); }; billsLibDao.prototype.downLevel = function (data, callback) { let billsLibId = data.billsLibId, updateDatas = data.updateDatas, functions = []; let parallelFucs = { preSiblingNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else { cb(null); } }); }; }, oprNode: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else{ cb(null); } }); }; }, preChildren: function (data) { return function (cb) { Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) { if(err){ cb(err); } else{ cb(null); } }); }; } } for(let i=0; i 1){ let ids = updateDatas[i].ID; for(let j=0; j 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){ async.each(deleteCodes, function(code, cb){ ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$pull: {itemValue: {code: code}}}, function(err){ if(err){ cb(err); }else { cb(null); } }); }, function(err){ if(err){ callback(1, 'Error'); }else { callback(0, ''); } }); } } }; billsLibDao.prototype.deleteItemCharacter = function(data, callback){ let delIds = data.ids; let billsLibId = data.billsLibId; if(delIds){ async.each(delIds, function(id, cb){ ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){ if(err){ cb(err); }else { cb(null); } }, function(err){ if(err){ callback(1, 'Error'); }else { callback(0, ''); } }); }); } }; billsLibDao.prototype.pasteItems = function (data, callback) { let pasteDatas = data.pasteDatas; let updateDatas = pasteDatas.updateDatas, createDatas = pasteDatas.createDatas; let functions = []; let parallelFucs = { updateFuc: function(data){ let updateId = data.orgId, field = data.field, updateData = data.data, billsLibId = data.billsLibId; if(field === 'code'){ return function (cb){ ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){ if(err){ cb(err); }else { cb(null, data); } }); }; } else{ return function(cb){ ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {content: updateData}}, function(err){ if(err){ cb(err); }else { cb(null, data); } }); } } }, createFuc: function(data){ let billsLibId = data.billsLibId, code; let itemObj; if(data.type === 'CreateT'){ itemObj = { billsLibId: billsLibId, code: data.code, content: data.content, deleted: false } } else{ if(data.field === 'code'){ itemObj = { billsLibId: billsLibId, code: data.data, content: '', deleted: false } } else { itemObj = { billsLibId: billsLibId, code: data.code, content: data.data, deleted: false } } } return function (cb){ counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){ if(err){ cb(err); } else{ let newItemId = result.value.sequence_value; itemObj.id = newItemId; data.newItemId = newItemId; ItemCharacter.create(itemObj, function(err){ if(err){ cb(err); }else { cb(null, data); } }); } }); } } }; if(updateDatas.length > 0){ for(let i=0; i 0){ for(let i =0; i 0) { for (let i = 0; i < updateDatas.length; i++) { functions.push(parallelFucs.updateFuc(updateDatas[i])); } } if(createDatas.length >0){ for(let i=0; i< createDatas.length; i++){ functions.push(parallelFucs.createFuc(createDatas[i])); } } async.parallel(functions, function(err, datas){ if(err){ console.log(`errfinal`); callback(1, 'Error', null); } else { console.log('noerror'); callback(0, '', datas); } }); }; billsLibDao.prototype.edCreateItem = function(data, callback){ let billsLibId = data.billsLibId, code = data.code, billsId = data.billsId, content = data.data, serialNo = data.serialNo; async.waterfall([ function(cb){ counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){ if(err){ cb(err, null); } else { let newItemId = result.value.sequence_value; cb(null, newItemId); } }) }, function(newItemId, cb){ async.parallel([ function(pcb){ ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){ if(err){ pcb(err, null); } else { pcb(null, newItemId); } }); }, function(pcb){ Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){ if(err){ pcb(err, null); } else { pcb(null, newItemId); } }); } ], function(err, result){ if(err){ cb(err, null); } else { cb(null, result[0]); } }); } ], function(err, reslut){ if(err){ callback(1, "Error", null); } else { callback(0, '', reslut); } }); }; billsLibDao.prototype.edUpdateItem = function(data, callback){ let billsLibId = data.billsLibId, billsId = data.billsId, content = data.content, code = data.code, orgItemId = data.orgItemId; async.waterfall([ function(cb){ counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){ if(err){ cb(err, null); } else { let newItemId = result.value.sequence_value; cb(null, newItemId); } }) }, function(newItemId, cb){ async.parallel([ function(pcb){ ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){ if(err){ pcb(err, null); } else { pcb(null, newItemId); } }); }, function(pcb){ Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){ if(err){ pcb(err, null); } else { pcb(null, newItemId); } }); } ], function(err, result){ if(err){ cb(err, null); } else { cb(null, result[0]); } }); } ], function(err, reslut){ if(err){ callback(1, "Error", null); } else { callback(0, '', reslut); } }); }; // module.exports = new billsLibDao();