123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219 |
- /**
- * Created by vian on 2017/3/20.
- */
- let mongoose = require('mongoose');
- let counter = require("../../../public/counter/counter");
- let async = require("async");
- let _ = require("lodash");
- let StdBillsLib = mongoose.model('std_bills_lib_list');
- let Bills = mongoose.model('std_bills_lib_bills');
- let JobContent = mongoose.model('std_bills_lib_jobContent');
- let ItemCharacter = mongoose.model('std_bills_lib_itemCharacter');
- let moment = require("moment");
- 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(callback){
- // let userId = data.userId;
- StdBillsLib.find({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.sequence_value;
- let userAccount = clibData.userAccount;
- let billsLibName = clibData.name;
- let compilationId = clibData.compilationId;
- let compilationName = clibData.compilationName;
- let dateStr = moment().format('YYYY-MM-DD HH:mm:ss');
- let newStdBillsLib = {
- creator: userAccount,
- createDate: dateStr,
- recentOpr: [{operator: userAccount, operateDate: dateStr}],
- billsLibId: billsLibId,
- billsLibName: billsLibName,
- compilationId: compilationId,
- compilationName: compilationName,
- 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);
- }
- });
- }
- });
- });
- };
- function getNewOprArr(recentOprArr, oprtor, oprDate){
- 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});
- }
- }
- return recentOprArr;
- }
- billsLibDao.prototype.deleteStdBillsLib = function(data, callback){
- let billsLibId = data.billsLibId, lastOperator = data.lastOperator,
- lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function(cb){
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr, 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;
- let lastOperator = renameData.lastOperator;
- let lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- callback(0, '');
- }
- else{
- if(result.length > 0){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set:{billsLibName: renameVal, recentOpr: newRecentOpr}}, 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}, "-_id -ruleText -recharge", 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 lastOperator = cbillsData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- 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 (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- 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,
- lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function (cb) {
- async.each(updateDatas, function(updateData, ecb){
- Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updateData.ID, deleted: false}, {$set: {NextSiblingID: updateData.NextSiblingID}}, function(err){
- if(err){
- ecb(err);
- }
- else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, 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 = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- 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]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- 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 = [],
- lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, 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);
- }
- });
- };
- },
- parentNode: 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);
- }
- })
- };
- },
- nextSiblingNode: function (data) {
- return function (cb) {
- Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID}}, 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 === '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]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function(err){
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- };
- billsLibDao.prototype.downLevel = function (data, callback) {
- let billsLibId = data.billsLibId,
- updateDatas = data.updateDatas,
- functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, 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);
- }
- });
- };
- },
- 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<updateDatas.length; i++){
- if(updateDatas[i].type === 'preSiblingNode'){
- functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
- }
- else if(updateDatas[i].type === 'oprNode'){
- functions.push(parallelFucs.oprNode(updateDatas[i]));
- }
- else {
- functions.push(parallelFucs.preChildren(updateDatas[i]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, 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 eachDatas = [];
- for(let i=0; i< updateDatas.length; i++){
- if(updateDatas[i].ID.length > 1){
- let ids = updateDatas[i].ID;
- for(let j=0; j<ids.length; j++){
- let eachObj = {
- id: ids[j],
- data: updateDatas[i]
- }
- eachDatas.push(eachObj);
- }
- }
- else {
- eachDatas.push({id: updateDatas[i].ID, data: updateDatas[i]});
- }
- }
- async.each(eachDatas, function(eachObj, cb){
- let id = eachObj.id, data = eachObj.data;
- if(data.ParentID && data.NextSiblingID){
- Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- }
- else if(data.ParentID && !data.NextSiblingID){
- Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID}}, function(err){
- if(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- }
- });
- }
- else if(!data.ParentID && data.NextSiblingID){
- Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- }
- }, function(err){
- if(err){
- callback(1, 'Error');
- }
- else {
- callback(0, '');
- }
- });
- }
- billsLibDao.prototype.updateBills = function(ubillsData, callback){
- let billsLibId = ubillsData.billsLibId;
- let updateId = ubillsData.updateId;
- let updateField = ubillsData.field;
- let updateData = ubillsData.data, lastOperator = ubillsData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let needSet = {};
- needSet[updateField] = updateData;
- async.parallel([
- function (cb) {
- if(updateField !== 'jobs' && updateField !== 'items'){
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: needSet}, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- })
- }
- else{
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$addToSet: needSet}, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- billsLibDao.prototype.removeTotal = function (data, callback) {
- let billsLibId = data.billsLibId, billsIds = data.billsIds,
- delIds = data.delIds, field = data.field, functions = [], delArr = [],
- lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(billsIds.length > 0){
- billsIds.forEach(function (updateId) {
- delIds.forEach(function (delId) {
- delArr.push({updateID: updateId, delId: delId});
- });
- });
- }
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- delJobs: function () {
- return function (cb) {
- async.each(delIds, function (delJobId, ecb) {
- JobContent.update({billsLibId: billsLibId, id: delJobId, deleted: false}, {$set: {deleted: true}}, function (err, result) {
- if(err){
- ecb(err);
- }
- else {
- ecb(null);
- }
- });
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- };
- },
- delJobsArr: function () {
- return function (cb) {
- async.each(delArr, function (delObj, ecb) {
- Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {jobs: {id: delObj.delId}}}, function (err) {
- if(err){
- ecb(err);
- }else{
- ecb(null);
- }
- });
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- })
- };
- },
- delItems: function () {
- return function (cb) {
- async.each(delIds, function (delItemId, ecb) {
- ItemCharacter.update({billsLibId: billsLibId, id: delItemId, deleted: false}, {$set: {deleted: true}}, function (err) {
- if(err){
- ecb(err);
- }
- else{
- ecb(null);
- }
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- });
- }
- },
- delItemsArr: function () {
- return function (cb) {
- async.each(delArr, function (delObj, ecb) {
- Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted:false}, {$pull: {items: {id: delObj.delId}}}, function(err){
- if(err){
- ecb(err);
- }
- else{
- ecb(null);
- }
- });
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- };
- if(field === 'jobs'){
- functions.push(parallelFucs.delJobs());
- functions.push(parallelFucs.delJobsArr());
- }
- else{
- functions.push(parallelFucs.delItems());
- functions.push(parallelFucs.delItemsArr());
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- };
- billsLibDao.prototype.updateSerialNo = function (data, callback) {
- let billsLibId = data.billsLibId, billsId = data.billsId,
- updateArr = data.updateArr, field = data.field,
- lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(field === 'jobs'){
- async.parallel([
- function (cb) {
- async.each(updateArr, function (updateObj, ecb) {
- Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'jobs.id': updateObj.id}, {$set: {'jobs.$.serialNo': updateObj.serialNo}}, function (err) {
- if(err){
- ecb(err);
- }
- else{
- ecb(null);
- }
- });
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- else{
- async.parallel([
- function (cb) {
- async.each(updateArr, function (updateObj, ecb) {
- Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'items.id': updateObj.id}, {$set: {'items.$.serialNo': updateObj.serialNo}}, function (err) {
- if(err){
- ecb(err);
- }
- else{
- ecb(null);
- }
- });
- }, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], 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 lastOperator = updateData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(classify === 'jobs'){
- if(orgId && newId && type === 'update'){
- async.parallel([
- function (cb) {
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'jobs.id': orgId}, {$set: {'jobs.$.id': newId}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- if(orgId && !newId && type === 'delete'){
- async.parallel([
- function (cb) {
- async.each(orgId, function(oid, ecb){
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {jobs: {id: oid}}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- })
- }
- if(orgId && !newId && type === 'deleteAll'){
- let delArr = [];
- updateId.forEach(function(uid){
- orgId.forEach(function(oid){
- delArr.push({updateId: uid, delId: oid});
- });
- });
- async.parallel([
- function (cb) {
- async.each(delArr, function(delObj, ecb){
- Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {jobs: {id: delObj.delId}}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- }
- else if(classify === 'items'){
- if(orgId && newId && type === 'update'){
- async.parallel([
- function (cb) {
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'items.id': orgId}, {$set: {'items.$.id': newId}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- if(orgId && !newId && type === 'delete'){
- async.parallel([
- function (cb) {
- async.each(orgId, function(oid, ecb){
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {items: {id: oid}}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- })
- }
- if(orgId && !newId && type === 'deleteAll'){
- let delArr = [];
- updateId.forEach(function(uid){
- orgId.forEach(function(oid){
- delArr.push({updateId: uid, delId: oid});
- });
- });
- async.parallel([
- function (cb) {
- async.each(delArr, function(delObj, ecb){
- Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {items: {id: delObj.delId}}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(err);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- }
- };
- billsLibDao.prototype.pasteBills = function(pData, callback){
- let datas = pData.datas,
- billsLibId = pData.billsLibId, lastOperator = pData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function (cb) {
- async.each(datas, function(data, ecb){
- let needSet = {};
- for(let i in data){
- needSet[i] = data[i];
- }
- Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: needSet}, function (err) {
- if(err){
- ecb(err);
- }
- else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- billsLibDao.prototype.updateRecharge = function(uData, callback){
- let billsLibId = uData.billsLibId;
- let updateId = uData.updateId;
- let data = uData.data, lastOperator = uData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function (cb) {
- Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {recharge: data}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- };
- billsLibDao.prototype.pasteRel = function (data, callback) {
- const UpdateExist = 'updateExist', UpdateNew = 'updateNew', CreateExist = 'createExist', CreateNew = 'createNew';
- const Jobs = 'jobs', Items = 'items';
- let field = data.field;
- let updateDatas = data.updateDatas;
- let createDatas = data.createDatas;
- let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- updateExJobs: function(data){
- let orgJobId = data.orgJobId, newJobId = data.newJobId,
- nodeId = data.nodeId, billsLibId = data.billsLibId;
- return function (cb){
- if(orgJobId && newJobId && nodeId && billsLibId){
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null, data)
- }
- });
- }
- }
- },
- updateNeJobs: function(data){
- let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
- orgJobId = data.orgJobId, code = data.code;
- return function (cb){
- if(billsLibId && nodeId && newData && orgJobId && code){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err);
- }
- else {
- let newJobId = result.sequence_value;
- let newJobContent = {
- id: newJobId,
- billsLibId: billsLibId,
- code: code,
- content: newData,
- deleted: false
- };
- JobContent.create(newJobContent, function(err){
- if(err){
- cb(err);
- }
- else{
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
- if(err){
- cb(err);
- }
- else{
- data.newJobId = newJobId;
- cb(null, data);
- }
- });
- }
- });
- }
- });
- }
- }
- },
- createExJobs: function(data){
- let billsLibId = data.billsLibId, newData = data.newData,
- nodeId = data.nodeId, jobId = data.jobId, serialNo = data.serialNo;
- return function (cb){
- if(billsLibId && newData && nodeId && jobId){
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: jobId, serialNo: serialNo}}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- }
- }
- },
- createNeJobs: function(data){
- let billsLibId = data.billsLibId, newData = data.newData,
- code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
- return function (cb){
- if(billsLibId && newData && code){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err);
- }
- else {
- let newJobId = result.sequence_value;
- let newJobContent = {
- id: newJobId,
- billsLibId: billsLibId,
- code: code,
- content: newData,
- deleted: false
- };
- JobContent.create(newJobContent, function(err){
- if(err){
- cb(err);
- }
- else{
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
- if(err){
- cb(err);
- }
- else {
- data.newJobId = newJobId;
- cb(null, data);
- }
- });
- }
- });
- }
- });
- }
- }
- },
- updateExItems: function(data){
- let orgItemId = data.orgItemId, newItemId = data.newItemId,
- nodeId = data.nodeId, billsLibId = data.billsLibId;
- return function (cb){
- if(orgItemId && newItemId && nodeId && billsLibId){
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null, data);
- }
- });
- }
- }
- },
- updateNeItems: function(data){
- let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
- orgItemId = data.orgItemId, code = data.code;
- return function (cb){
- if(billsLibId && nodeId && newData && orgItemId && code){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
- if(err){
- cb(err);
- }
- else {
- let newItemId = result.sequence_value;
- let newItemContent = {
- id: newItemId,
- billsLibId: billsLibId,
- code: code,
- content: newData,
- deleted: false
- };
- ItemCharacter.create(newItemContent, function(err){
- if(err){
- cb(err);
- }
- else{
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
- if(err){
- cb(err);
- }
- else{
- data.newItemId = newItemId;
- cb(null, data);
- }
- });
- }
- });
- }
- });
- }
- }
- },
- createExItems: function(data){
- let billsLibId = data.billsLibId, newData = data.newData,
- nodeId = data.nodeId, itemId = data.itemId, serialNo = data.serialNo;
- return function (cb){
- if(billsLibId && newData && nodeId && itemId){
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: itemId, serialNo: serialNo}}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- }
- }
- },
- createNeItems: function(data){
- let billsLibId = data.billsLibId, newData = data.newData,
- code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
- return function (cb){
- if(billsLibId && newData && code){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
- if(err){
- cb(err);
- }
- else {
- let newItemId = result.sequence_value;
- let newItemContent = {
- id: newItemId,
- billsLibId: billsLibId,
- code: code,
- content: newData,
- deleted: false
- };
- ItemCharacter.create(newItemContent, function(err){
- if(err){
- cb(err);
- }
- else{
- Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){
- if(err){
- cb(err);
- }
- else {
- data.newItemId = newItemId;
- cb(null, data);
- }
- });
- }
- });
- }
- });
- }
- }
- }
- };
- if(field === Jobs){
- if(updateDatas.length > 0){
- for(let i=0; i<updateDatas.length; i++){
- if(updateDatas[i].type === UpdateExist){
- functions.push(parallelFucs.updateExJobs(updateDatas[i]));
- }
- if(updateDatas[i].type === UpdateNew){
- functions.push(parallelFucs.updateNeJobs(updateDatas[i]));
- }
- }
- }
- if(createDatas.length > 0){
- for(let i=0; i<createDatas.length; i++){
- if(createDatas[i].type === CreateExist){
- functions.push(parallelFucs.createExJobs(createDatas[i]));
- }
- if(createDatas[i].type === CreateNew){
- functions.push(parallelFucs.createNeJobs(createDatas[i]));
- }
- }
- }
- }
- else {
- if(updateDatas.length > 0){
- for(let i=0; i<updateDatas.length; i++){
- if(updateDatas[i].type === UpdateExist){
- functions.push(parallelFucs.updateExItems(updateDatas[i]));
- }
- if(updateDatas[i].type === UpdateNew){
- functions.push(parallelFucs.updateNeItems(updateDatas[i]));
- }
- }
- }
- if(createDatas.length > 0){
- for(let i=0; i<createDatas.length; i++){
- if(createDatas[i].type === CreateExist){
- functions.push(parallelFucs.createExItems(createDatas[i]));
- }
- if(createDatas[i].type === CreateNew){
- functions.push(parallelFucs.createNeItems(createDatas[i]));
- }
- }
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function(err, datas){
- if(err){
- callback(1, 'Error', null);
- }else {
- callback(0, '', datas);
- }
- });
- };
- billsLibDao.prototype.deleteBills = function(delData, callback){
- let deleteIds = delData.deleteIds;
- let billsLibId = delData.billsLibId;
- let updateNode = delData.updateNode,
- lastOperator = delData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(deleteIds){
- async.parallel([
- function(cb){
- async.each(deleteIds, function(delId, ecb){
- Bills.update({billsLibId: billsLibId, ID: delId, deleted: false}, {$set: {deleted: true}}, function(err){
- if(err){
- ecb(err);
- }
- else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null);
- }
- });
- },
- function(cb){
- if(updateNode){
- Bills.update({billsLibId: billsLibId, ID: updateNode.ID, deleted: false}, {$set: {NextSiblingID: updateNode.NextSiblingID}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null);
- }
- });
- }else {
- cb(null);
- }
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function(err){
- if(err){
- callback(1, 'Error');
- }else {
- callback(0, '');
- }
- });
- }
- }
- //--------------JobContent------------------
- billsLibDao.prototype.getJobContent = function(gJobData, callback){
- let billsLibId = gJobData.billsLibId;
- JobContent.find({billsLibId: billsLibId, deleted: false}, '-_id').lean().sort({code: 1}).exec(function(err, result){
- if(err){
- callback(1, 'Error', null);
- }
- else {
- callback(0, '', result);
- }
- });
- }
- billsLibDao.prototype.createJobContent = function(cJobData, callback){
- let data = cJobData.data;
- let billsLibId = cJobData.billsLibId;
- let serialNo = cJobData.serialNo;
- let newJobContent, lastOperator = cJobData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function (cb) {
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err)
- }
- else {
- let newJobId = result.sequence_value;
- newJobContent = {
- id: newJobId,
- billsLibId: billsLibId,
- code: serialNo,
- content: data,
- deleted: false
- };
- JobContent.create(newJobContent, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null, newJobId);
- }
- });
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err, result) {
- if(err){
- callback(1, 'Error', null);
- }
- else{
- callback(0, '', result[0])
- }
- })
- };
- billsLibDao.prototype.updateJobContent = function(uJobData, callback){
- let billsLibId = uJobData.billsLibId;
- let field = uJobData.field;
- let updateData = uJobData.data;
- let updateid = uJobData.updateId, lastOperator = uJobData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss'),
- needSet = {};
- needSet[field] = updateData;
- async.parallel([
- function (cb) {
- JobContent.update({billsLibId: billsLibId, id: updateid}, {$set: needSet}, function (err) {
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- };
- billsLibDao.prototype.deleteJobContent = function(data, callback){
- let delIds = data.ids;
- let billsLibId = data.billsLibId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(delIds){
- async.parallel([
- function (cb) {
- async.each(delIds, function(id, ecb){
- JobContent.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
- if(err){
- ecb(err);
- }
- else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- })
- }
- }
- billsLibDao.prototype.pasteJobs = function (data, callback) {
- let pasteDatas = data.pasteDatas;
- let updateDatas = pasteDatas.updateDatas,
- createDatas = pasteDatas.createDatas;
- let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- updateFuc: function(data){
- let updateId = data.orgId,
- field = data.field,
- updateData = data.data, billsLibId = data.billsLibId;
- if(field === 'code'){
- return function (cb){
- JobContent.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){
- if(err){
- cb(err);
- }else {
- cb(null, data);
- }
- });
- };
- }else {
- return function (cb){
- JobContent.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 jobObj;
- if(data.type === 'CreateT'){
- jobObj = {
- billsLibId: billsLibId,
- code: data.code,
- content: data.content,
- deleted: false
- }
- }
- else{
- if(data.field === 'code'){
- jobObj = {
- billsLibId: billsLibId,
- code: data.data,
- content: '',
- deleted: false
- }
- }
- else {
- jobObj = {
- billsLibId: billsLibId,
- code: data.code,
- content: data.data,
- deleted: false
- }
- }
- }
- return function (cb){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err);
- }
- else {
- let newJobId = result.sequence_value;
- jobObj.id = newJobId;
- data.newJobId = newJobId
- JobContent.create(jobObj, function(err){
- if(err){
- cb(err);
- }else {
- cb(null, data);
- }
- });
- }
- });
- }
- }
- };
- if(updateDatas.length > 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]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function(err, datas){
- if(err){
- callback(1, 'Error', null);
- }else {
- callback(0, '', datas);
- }
- });
- };
- billsLibDao.prototype.edCreateJob = function(data, callback){
- let billsLibId = data.billsLibId,
- code = data.code,
- billsId = data.billsId,
- content = data.data,
- serialNo = data.serialNo, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.waterfall([
- function(cb){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err, null);
- }
- else {
- let newJobId = result.sequence_value;
- cb(null, newJobId);
- }
- })
- },
- function(newJobId, cb){
- async.parallel([
- function(pcb){
- JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
- if(err){
- pcb(err, null);
- }
- else {
- pcb(null, newJobId);
- }
- });
- },
- function(pcb){
- Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
- if(err){
- pcb(err, null);
- }
- else {
- pcb(null, newJobId);
- }
- });
- },
- function (pcb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- pcb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- pcb(err);
- }
- else{
- pcb(null);
- }
- });
- }
- }
- });
- }
- ], 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.edUpdateJob = function(data, callback){
- let billsLibId = data.billsLibId,
- billsId = data.billsId,
- content = data.content,
- code = data.code,
- orgJobId = data.orgJobId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.waterfall([
- function(cb){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
- if(err){
- cb(err, null);
- }
- else {
- let newJobId = result.sequence_value;
- cb(null, newJobId);
- }
- })
- },
- function(newJobId, cb){
- async.parallel([
- function(pcb){
- JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
- if(err){
- pcb(err, null);
- }
- else {
- pcb(null, newJobId);
- }
- });
- },
- function(pcb){
- Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
- if(err){
- pcb(err, null);
- }
- else {
- pcb(null, newJobId);
- }
- });
- },
- function (pcb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- pcb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- pcb(err);
- }
- else{
- pcb(null);
- }
- });
- }
- }
- });
- }
- ], 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);
- }
- });
- };
- //----------------------ItemCharacter---------------------
- billsLibDao.prototype.getItemCharacter = function(gdata, callback){
- let billsLibId = gdata.billsLibId;
- ItemCharacter.find({billsLibId: billsLibId}, '-_id').lean().sort({code: 1}).exec(function(err, result){
- if(err){
- callback(1, 'Error', null);
- }
- else {
- callback(0, '', result);
- }
- });
- }
- billsLibDao.prototype.createItemCharacter = function(cItemData, callback){
- let data = cItemData.data;
- let billsLibId = cItemData.billsLibId;
- let code = cItemData.code;
- let newItemCharacter, lastOperator = cItemData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.parallel([
- function (cb) {
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- let newItemId = result.sequence_value;
- newItemCharacter = {
- id: newItemId,
- billsLibId: billsLibId,
- content: data,
- code: code,
- deleted: false
- }
- ItemCharacter.create(newItemCharacter, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null, newItemId);
- }
- });
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err, result) {
- if(err){
- callback(1, 'Error', null);
- }
- else{
- callback(0, '', result[0]);
- }
- });
- };
- billsLibDao.prototype.updateItemCharacter = function(uItemData, callback){
- let field = uItemData.field;
- let updateData = uItemData.data;
- let id = uItemData.updateId;
- let billsLibId = uItemData.billsLibId, needSet = {},
- lastOperator = uItemData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- needSet[field] = updateData;
- async.parallel([
- function (cb) {
- ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: needSet}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- };
- billsLibDao.prototype.updateValue = function(uData, callback){
- let type = uData.type;
- let updateId = uData.updateId;
- let data = uData.data;
- let deleteCodes = uData.deleteCodes;
- let billsLibId = uData.billsLibId, lastOperator = uData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(type === 'create'){
- async.parallel([
- function (cb) {
- ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$addToSet: {itemValue: data}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- })
- }
- else if(type === 'update'){
- if(data.field === 'code'){
- async.parallel([
- function (cb) {
- ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.code': data.newData}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- });
- }
- else {
- async.parallel([
- function (cb) {
- ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.value': data.newData}}, function(err,result){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- ], function (err) {
- if(err){
- callback(1, 'Error');
- }
- else{
- callback(0, '');
- }
- })
- }
- }
- //delete
- else {
- if(deleteCodes.length > 0){
- async.parallel([
- function (cb) {
- async.each(deleteCodes, function(code, ecb){
- ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$pull: {itemValue: {code: code}}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- });
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, 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, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- if(delIds){
- async.parallel([
- function (cb) {
- async.each(delIds, function(id, ecb){
- ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
- if(err){
- ecb(err);
- }else {
- ecb(null);
- }
- }, function(err){
- if(err){
- cb(err);
- }else {
- cb(null);
- }
- });
- });
- },
- function (cb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, 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 = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- 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.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<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]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function(err, datas){
- if(err){
- callback(1, 'Error', null);
- }else {
- callback(0, '', datas);
- }
- });
- };
- billsLibDao.prototype.pasteValues = function(data, callback) {
- let pasteDatas = data.pasteDatas;
- let updateDatas = pasteDatas.updateDatas, createDatas = pasteDatas.createDatas;
- let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- let parallelFucs = {
- updateLastOpr: function () {
- return function (cb) {
- StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
- if(err){
- cb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- cb(err);
- }
- else{
- cb(null);
- }
- });
- }
- }
- });
- }
- },
- updateFuc: function(data){
- let billsLibId = data.billsLibId, itemId = data.itemId, orgCode = data.orgId;
- if (data.type === 'UpdateT') {
- let valueObj = {code: data.code, value: data.content};
- return function (cb){
- ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$pull: {itemValue: {code: orgCode}}}, function (err) {
- if (err) {
- cb(err);
- }
- else {
- ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
- if (err) {
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- }
- });
- };
- }
- else if (data.type === 'Update' && data.field === 'code') {
- return function (cb) {
- ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode},
- {$set: {'itemValue.$.code': data.data}}, function (err) {
- if(err){
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- }
- }
- else if(data.type === 'Update' && data.field === 'value') {
- return function (cb){
- ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode}, {$set: {'itemValue.$.value': data.data}}, function(err){
- if(err){
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- };
- }
- },
- createFuc: function(data){
- let valueObj;
- if(data.type === 'CreateT'){
- valueObj = {code: data.code, value: data.content};
- return function (cb){
- ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
- if (err) {
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- };
- }
- else if(data.type === 'Create' && data.field === 'code'){
- valueObj = {code: data.data, value: ''};
- return function (cb){
- ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
- if (err) {
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- };
- }
- else {
- valueObj = {code: data.code, value: data.data};
- return function(cb){
- ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
- if (err) {
- cb(err);
- }
- else {
- cb(null, data);
- }
- });
- };
- }
- }
- };
- if (updateDatas.length > 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]));
- }
- }
- functions.push(parallelFucs.updateLastOpr());
- async.parallel(functions, function(err, datas){
- if(err){
- callback(1, 'Error', null);
- }
- else {
- 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, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.waterfall([
- function(cb){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
- if(err){
- cb(err, null);
- }
- else {
- let newItemId = result.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 (pcb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- pcb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- pcb(err);
- }
- else{
- pcb(null);
- }
- });
- }
- }
- });
- }
- ], 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, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- async.waterfall([
- function(cb){
- counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
- if(err){
- cb(err, null);
- }
- else {
- let newItemId = result.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 (pcb) {
- StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
- if(err){
- pcb(err);
- }
- else{
- if(result.length > 0 ){
- let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
- StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
- if(err){
- pcb(err);
- }
- else{
- pcb(null);
- }
- });
- }
- }
- });
- }
- ], 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.getDataToProjectBills = function (stdBills) {
- // 处理工作内容和项目特征
- const jobContent = stdBills.jobContent
- .map(({ serialNo, content }) => ({ serialNo, content, isChecked: true }));
- const itemCharacter = stdBills
- .itemCharacter.map(({ serialNo, content }) => ({ serialNo, character: content, eigenvalue: [], isChecked: false }));
- const itemCharacterText = "[项目特征]\n[工作内容]\n" + stdBills.jobContentText;
- const jobContentText = '';
- return {
- jobContent,
- itemCharacter,
- itemCharacterText,
- jobContentText,
- programID: stdBills.engineering, // 取费专业
- comments: stdBills.recharge, // 说明
- name: stdBills.name,
- unit: stdBills.unit,
- ruleText: stdBills.ruleText,
- };
- }
- billsLibDao.prototype.getStdBillsByCode = async function (data, callback) {
- let findData = function (value, field, Array) {
- let i = 0;
- for (i = 0; i < Array.length; i++) {
- if (value[field] === Array[i][field]) {
- return Array[i];
- }
- }
- return null;
- };
- let MergeData = function (arr) {
- let result = "", count = 0;
- for(let i = 0; i < arr.length; i++){
- if(arr[i].isChecked === true){
- count += 1;
- if (count === 1) {
- result += count + ". " + arr[i].content;
- } else {
- result += "\n" + count + ". " + arr[i].content;
- }
- }
- }
- return result;
- }
- try{
- let bills = await Bills.findOne({billsLibId: data.billsLibId, code: data.code, deleted: false}, '-_id');
- if(bills){
- //设置清单备注(父项清单补注)
- if(bills.ParentID != -1){
- let parentBills = await Bills.findOne({billsLibId: data.billsLibId, ID: bills.ParentID, deleted: false});
- if(parentBills && parentBills.recharge){
- bills.recharge = parentBills.recharge;
- }
- }
- //设置项目特征
- let itemCharacters = await ItemCharacter.find({billsLibId: data.billsLibId, deleted: false}, '-_id');
- bills._doc.itemCharacter = [];
- bills.items = _.sortBy(bills.items,"serialNo");//排序
- if(itemCharacters && bills.items){
- for(let item of bills.items){
- let itemData = findData(item, 'id', itemCharacters);
- if(itemData){
- itemData._doc.serialNo = item.serialNo;
- bills._doc.itemCharacter.push(itemData);
- }
- }
- }
- bills._doc.itemCharacterText = MergeData(bills._doc.itemCharacter);
- //设置工作内容
- let jobContents = await JobContent.find({billsLibId: data.billsLibId, deleted: false}, '-_id');
- bills._doc.jobContent = [];
- bills.jobs = _.sortBy(bills.jobs,"serialNo");//排序
- if(jobContents && bills.jobs){
- for(let job of bills.jobs){
- let jobData = findData(job, 'id', jobContents);
- jobData.isChecked = true;
- jobData._doc.serialNo = job.serialNo;
- bills._doc.jobContent.push(jobData);
- }
- }
- bills._doc.jobContentText = MergeData(bills._doc.jobContent);
- }
- if(callback){
- callback(0, '', bills);
- }else {
- return bills;
- }
- }
- catch(err){
- callback(1, err, null);
- return null;
- }
- };
- billsLibDao.prototype.getStdBillsByCodet = function (data, callback) {
- let findData = function (value, field, Array) {
- let i = 0;
- for (i = 0; i < Array.length; i++) {
- if (value[field] === Array[i][field]) {
- return Array[i];
- }
- }
- return null;
- };
- let MergeData = function (arr) {
- let result = "", count = 0;
- for(let i = 0; i < arr.length; i++){
- if(arr[i].isChecked === true){
- count += 1;
- if (count === 1) {
- result += count + ". " + arr[i].content;
- } else {
- result += "\n" + count + ". " + arr[i].content;
- }
- }
- }
- return result;
- }
- async.waterfall([
- function (callback) {
- Bills.findOne({'billsLibId': data.billsLibId, 'code': data.code, 'deleted': false}, "-_id", function (err, result) {
- callback(err, JSON.parse(JSON.stringify(result)));
- });
- },
- function (bills, callback) {
- if (bills) {
- ItemCharacter.find({'billsLibId': data.billsLibId, 'deleted': false}, '-_id', function (err, result) {
- if (err) {
- callback(err, bills);
- } else {
- bills._doc.itemCharacter = [];
- if (result && bills && bills.items) {
- for (let item of bills.items) {
- let itemData = findData(item, 'id', result);
- if (itemData) {
- bills._doc.itemCharacter.push(JSON.parse(JSON.stringify(itemData)));
- }
- }
- }
- bills._doc.itemCharacterText = MergeData(bills.itemCharacter);
- callback(err, bills);
- }
- });
- } else {
- callback(null, bills);
- }
- },
- function (bills, callback) {
- if (bills) {
- JobContent.find({'billsLibId': data.billsLibId, 'deleted': false}, '-_id', function (err, result) {
- if (err) {
- callback(err, bills);
- } else {
- bills.jobContent = [];
- if (result && bills && bills.jobs) {
- for (let job of bills.jobs) {
- let jobData = findData(job, 'id', result);;
- if (jobData) {
- jobData = JSON.parse(JSON.stringify(jobData));
- jobData.isChecked = true;
- bills.jobContent.push(jobData);
- }
- }
- }
- bills.jobContentText = MergeData(bills.jobContent);
- callback(err, bills);
- }
- });
- } else {
- callback(null, bills);
- }
- }
- ], function (err, result) {
- if (err) {
- callback(1, err, null);
- } else {
- callback(0, err, result);
- }
- });
- };
- module.exports = new billsLibDao();
|