bills_lib_interfaces.js 118 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219
  1. /**
  2. * Created by vian on 2017/3/20.
  3. */
  4. let mongoose = require('mongoose');
  5. let counter = require("../../../public/counter/counter");
  6. let async = require("async");
  7. let _ = require("lodash");
  8. let StdBillsLib = mongoose.model('std_bills_lib_list');
  9. let Bills = mongoose.model('std_bills_lib_bills');
  10. let JobContent = mongoose.model('std_bills_lib_jobContent');
  11. let ItemCharacter = mongoose.model('std_bills_lib_itemCharacter');
  12. let moment = require("moment");
  13. let billsLibDao = function(){};
  14. billsLibDao.prototype.getMaxNumber = function(gData, callback){
  15. let billsLibId = gData.billsLibId;
  16. let field = gData.field;
  17. if(field === 'jobs'){
  18. JobContent.find({billsLibId: billsLibId, deleted: false}).sort({code: -1}).limit(1).exec(function(err, result){
  19. if(err){
  20. callback(1, 'Error', null);
  21. }
  22. else {
  23. callback(0, '', result);
  24. }
  25. });
  26. }
  27. else if(field === 'items'){
  28. ItemCharacter.find({billsLibId: billsLibId, deleted: false}).sort({code: -1}).limit(1).exec(function(err, result){
  29. if(err){
  30. callback(1, 'Error', null);
  31. }
  32. else {
  33. callback(0, '', result);
  34. }
  35. });
  36. }
  37. };
  38. //----------StdBillsLib-------------------
  39. billsLibDao.prototype.getABillsLib = function(data, callback){
  40. let billsLibId = data.billsLibId;
  41. StdBillsLib.find({billsLibId: billsLibId, deleted: false}, function(err, data){
  42. if(err){
  43. callback(1, 'Error', null);
  44. }
  45. else {
  46. callback(0, '', data);
  47. }
  48. });
  49. };
  50. billsLibDao.prototype.getStdBillsLib = function(callback){
  51. // let userId = data.userId;
  52. StdBillsLib.find({deleted: false}, "-_id", function(err, data){
  53. if(err){
  54. callback(1, "Error", null);
  55. }
  56. else{
  57. callback(0, "", data);
  58. }
  59. });
  60. };
  61. billsLibDao.prototype.createStdBillsLib = function(clibData, callback){
  62. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib, 1, function(err, result){
  63. let billsLibId = result.sequence_value;
  64. let userAccount = clibData.userAccount;
  65. let billsLibName = clibData.name;
  66. let compilationId = clibData.compilationId;
  67. let compilationName = clibData.compilationName;
  68. let dateStr = moment().format('YYYY-MM-DD HH:mm:ss');
  69. let newStdBillsLib = {
  70. creator: userAccount,
  71. createDate: dateStr,
  72. recentOpr: [{operator: userAccount, operateDate: dateStr}],
  73. billsLibId: billsLibId,
  74. billsLibName: billsLibName,
  75. compilationId: compilationId,
  76. compilationName: compilationName,
  77. deleted: false
  78. };
  79. StdBillsLib.create(newStdBillsLib, function(err){
  80. if(err){
  81. callback(1, "Error", null);
  82. }
  83. else {
  84. StdBillsLib.find({billsLibId: billsLibId}, function(err, data){
  85. if(err){
  86. callback(1, "Error", null)
  87. }
  88. else {
  89. callback(0, "", data);
  90. }
  91. });
  92. }
  93. });
  94. });
  95. };
  96. function getNewOprArr(recentOprArr, oprtor, oprDate){
  97. let isExist = false;
  98. for(let i =0 ; i<recentOprArr.length; i++){
  99. if(recentOprArr[i].operator === oprtor){
  100. recentOprArr[i].operateDate = oprDate;
  101. isExist = true;
  102. }
  103. }
  104. if(!isExist){
  105. if(recentOprArr.length < 5){
  106. recentOprArr.push({operator: oprtor, operateDate: oprDate});
  107. }
  108. else if(recentOprArr.length === 5){
  109. recentOprArr.sort(function (a, b) {
  110. if(a.operateDate > b.operateDate){
  111. return -1;
  112. }else {
  113. return 1;
  114. }
  115. return 0;
  116. });
  117. recentOprArr.splice(recentOprArr.length -1, 1);
  118. recentOprArr.splice(0, 1, {operator: oprtor, operateDate: oprDate});
  119. }
  120. }
  121. return recentOprArr;
  122. }
  123. billsLibDao.prototype.deleteStdBillsLib = function(data, callback){
  124. let billsLibId = data.billsLibId, lastOperator = data.lastOperator,
  125. lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  126. async.parallel([
  127. function(cb){
  128. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  129. if(err){
  130. cb(err);
  131. }
  132. else{
  133. if(result.length > 0 ){
  134. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  135. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr, deleted: true}}, function(err){
  136. if(err){
  137. cb(err);
  138. }
  139. else{
  140. cb(null);
  141. }
  142. });
  143. }
  144. }
  145. });
  146. },
  147. function(cb){
  148. Bills.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){
  149. cb(null);
  150. });
  151. },
  152. function(cb){
  153. JobContent.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err, result){
  154. cb(null);
  155. });
  156. },
  157. function(cb){
  158. ItemCharacter.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){
  159. cb(null);
  160. })
  161. }
  162. ], function(err){
  163. if(err){
  164. callback(1, 'Error');
  165. }
  166. else {
  167. callback(0, '');
  168. }
  169. });
  170. };
  171. billsLibDao.prototype.renameStdBillsLib = function(renameData, callback){
  172. let billsLibId = renameData.id;
  173. let renameVal = renameData.value;
  174. let lastOperator = renameData.lastOperator;
  175. let lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  176. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  177. if(err){
  178. callback(0, '');
  179. }
  180. else{
  181. if(result.length > 0){
  182. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  183. StdBillsLib.update({billsLibId: billsLibId}, {$set:{billsLibName: renameVal, recentOpr: newRecentOpr}}, function(err){
  184. if(err){
  185. callback(1, "Error");
  186. }
  187. else{
  188. callback(0, "");
  189. }
  190. });
  191. }
  192. }
  193. })
  194. };
  195. billsLibDao.prototype.getStdBillsLibName = function(billsLibId, callback){
  196. StdBillsLib.find({billsLibId: billsLibId, deleted: false}, "-_id", function(err, data){
  197. if(err){
  198. callback(1, "Error", null);
  199. }
  200. else {
  201. callback(0, "", data);
  202. }
  203. });
  204. };
  205. billsLibDao.prototype.getCurrentUniqId = function(callback){
  206. counter.counterDAO.getCurrentID(counter.moduleName.billsLib, function(result, err){
  207. let id = result.sequence_value;
  208. if(err){
  209. callback(1, 'Error', null);
  210. }
  211. else{
  212. callback(0, '', id);
  213. }
  214. });
  215. }
  216. //----------------------------Bills---------------------
  217. billsLibDao.prototype.getBills = function (billsLibId, callback) {
  218. Bills.find({billsLibId: billsLibId}, "-_id -ruleText -recharge", function(err, billsData){
  219. if(err){
  220. callback(1, "Error", null);
  221. }
  222. else{
  223. callback(0, "", billsData);
  224. }
  225. });
  226. }
  227. billsLibDao.prototype.createBills = function(cbillsData, callback){
  228. let newId = cbillsData.newId;
  229. let pid = cbillsData.ParentID;
  230. let nid = cbillsData.NextSiblingID;
  231. let billsLibId = cbillsData.billsLibId;
  232. let updatePreData = cbillsData.updatePreData;
  233. let lastOperator = cbillsData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  234. let newBills = {
  235. ID: newId,
  236. ParentID: pid,
  237. NextSiblingID: nid,
  238. billsLibId: billsLibId,
  239. code: '',
  240. name: '',
  241. unit: '',
  242. ruleText: '',
  243. Expression: '',
  244. recharge:'',
  245. deleted: false
  246. };
  247. async.parallel([
  248. function(cb){
  249. Bills.create(newBills, function(err){
  250. if(err){
  251. cb(err);
  252. }
  253. else {
  254. cb(null);
  255. }
  256. });
  257. },
  258. function(cb){
  259. if(updatePreData){
  260. Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updatePreData.ID, deleted: false}, {$set: {NextSiblingID: updatePreData.NextSiblingID}}, function(err, result){
  261. if(err){
  262. cb(err);
  263. }
  264. else {
  265. cb(null)
  266. }
  267. });
  268. }
  269. else {
  270. cb(null);
  271. }
  272. },
  273. function (cb) {
  274. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  275. if(err){
  276. cb(err);
  277. }
  278. else{
  279. if(result.length > 0 ){
  280. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  281. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  282. if(err){
  283. cb(err);
  284. }
  285. else{
  286. cb(null);
  287. }
  288. });
  289. }
  290. }
  291. });
  292. }
  293. ], function(err){
  294. if(err){
  295. callback(1, 'Error');
  296. }
  297. else {
  298. callback(0, '');
  299. }
  300. });
  301. };
  302. billsLibDao.prototype.upMove = function(data, callback){
  303. let billsLibId = data.billsLibId,
  304. updateDatas = data.updateDatas,
  305. lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  306. async.parallel([
  307. function (cb) {
  308. async.each(updateDatas, function(updateData, ecb){
  309. Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updateData.ID, deleted: false}, {$set: {NextSiblingID: updateData.NextSiblingID}}, function(err){
  310. if(err){
  311. ecb(err);
  312. }
  313. else {
  314. ecb(null);
  315. }
  316. });
  317. }, function(err){
  318. if(err){
  319. cb(err);
  320. }
  321. else{
  322. cb(null);
  323. }
  324. });
  325. },
  326. function (cb) {
  327. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  328. if(err){
  329. cb(err);
  330. }
  331. else{
  332. if(result.length > 0 ){
  333. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  334. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  335. if(err){
  336. cb(err);
  337. }
  338. else{
  339. cb(null);
  340. }
  341. });
  342. }
  343. }
  344. });
  345. }
  346. ], function (err) {
  347. if(err){
  348. callback(1, 'Error');
  349. }
  350. else{
  351. callback(0, '');
  352. }
  353. });
  354. };
  355. billsLibDao.prototype.downMove = function (data, callbck) {
  356. let billsLibId = data.billsLibId,
  357. updateDatas = data.updateDatas,
  358. functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  359. let parallelFucs = {
  360. updateLastOpr: function () {
  361. return function (cb) {
  362. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  363. if(err){
  364. cb(err);
  365. }
  366. else{
  367. if(result.length > 0 ){
  368. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  369. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  370. if(err){
  371. cb(err);
  372. }
  373. else{
  374. cb(null);
  375. }
  376. });
  377. }
  378. }
  379. });
  380. }
  381. },
  382. nextSiblingNode: function (data) {
  383. return function (cb) {
  384. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  385. if(err){
  386. cb(err);
  387. }
  388. else{
  389. cb(null);
  390. }
  391. });
  392. };
  393. },
  394. oprNode: function (data) {
  395. return function (cb) {
  396. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  397. if(err){
  398. cb(err);
  399. }
  400. else {
  401. cb(null);
  402. }
  403. })
  404. }
  405. },
  406. preSiblingNode: function (data) {
  407. return function (cb) {
  408. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  409. if(err){
  410. cb(err);
  411. }
  412. else{
  413. cb(null);
  414. }
  415. });
  416. };
  417. }
  418. };
  419. for(let i =0; i< updateDatas.length; i++){
  420. if(updateDatas[i].type === 'nextSiblingNode'){
  421. functions.push(parallelFucs.nextSiblingNode(updateDatas[i]));
  422. }
  423. else if(updateDatas[i].type === 'oprNode'){
  424. functions.push(parallelFucs.oprNode(updateDatas[i]));
  425. }
  426. else {
  427. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  428. }
  429. }
  430. functions.push(parallelFucs.updateLastOpr());
  431. async.parallel(functions, function (err) {
  432. if(err){
  433. callbck(1, 'Error');
  434. }
  435. else{
  436. callbck(0, '');
  437. }
  438. })
  439. }
  440. billsLibDao.prototype.upLevel = function(data, callback){
  441. let billsLibId = data.billsLibId,
  442. updateDatas = data.updateDatas, functions = [],
  443. lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  444. let parallelFucs = {
  445. updateLastOpr: function () {
  446. return function (cb) {
  447. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  448. if(err){
  449. cb(err);
  450. }
  451. else{
  452. if(result.length > 0 ){
  453. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  454. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  455. if(err){
  456. cb(err);
  457. }
  458. else{
  459. cb(null);
  460. }
  461. });
  462. }
  463. }
  464. });
  465. }
  466. },
  467. oprNode: function (data) {
  468. return function (cb){
  469. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){
  470. if(err){
  471. cb(err);
  472. }
  473. else {
  474. cb(null);
  475. }
  476. });
  477. };
  478. },
  479. parentNode: function (data) {
  480. return function(cb){
  481. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  482. if(err){
  483. cb(err);
  484. }
  485. else {
  486. cb(null);
  487. }
  488. })
  489. };
  490. },
  491. nextSiblingNode: function (data) {
  492. return function (cb) {
  493. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID}}, function (err) {
  494. if(err){
  495. cb(err);
  496. }
  497. else{
  498. cb(null);
  499. }
  500. });
  501. };
  502. },
  503. preSiblingNode: function(data){
  504. return function (cb) {
  505. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  506. if(err){
  507. cb(err);
  508. }
  509. else {
  510. cb(null);
  511. }
  512. });
  513. };
  514. }
  515. }
  516. for(let i=0; i< updateDatas.length; i++){
  517. if(updateDatas[i].type === 'oprNode'){
  518. functions.push(parallelFucs.oprNode(updateDatas[i]));
  519. }
  520. else if(updateDatas[i].type === 'parentNode'){
  521. functions.push(parallelFucs.parentNode(updateDatas[i]));
  522. }
  523. else if(updateDatas[i].type === 'nextSiblingNode'){
  524. updateDatas[i].ID.forEach(function (id) {
  525. let obj = {ID: id, ParentID: updateDatas[i].ParentID};
  526. functions.push(parallelFucs.nextSiblingNode(obj));
  527. });
  528. }
  529. else {
  530. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  531. }
  532. }
  533. functions.push(parallelFucs.updateLastOpr());
  534. async.parallel(functions, function(err){
  535. if(err){
  536. callback(1, 'Error');
  537. }
  538. else{
  539. callback(0, '');
  540. }
  541. });
  542. };
  543. billsLibDao.prototype.downLevel = function (data, callback) {
  544. let billsLibId = data.billsLibId,
  545. updateDatas = data.updateDatas,
  546. functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  547. let parallelFucs = {
  548. updateLastOpr: function () {
  549. return function (cb) {
  550. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  551. if(err){
  552. cb(err);
  553. }
  554. else{
  555. if(result.length > 0 ){
  556. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  557. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  558. if(err){
  559. cb(err);
  560. }
  561. else{
  562. cb(null);
  563. }
  564. });
  565. }
  566. }
  567. });
  568. }
  569. },
  570. preSiblingNode: function (data) {
  571. return function (cb) {
  572. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  573. if(err){
  574. cb(err);
  575. }
  576. else {
  577. cb(null);
  578. }
  579. });
  580. };
  581. },
  582. oprNode: function (data) {
  583. return function (cb) {
  584. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function (err) {
  585. if(err){
  586. cb(err);
  587. }
  588. else{
  589. cb(null);
  590. }
  591. });
  592. };
  593. },
  594. preChildren: function (data) {
  595. return function (cb) {
  596. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  597. if(err){
  598. cb(err);
  599. }
  600. else{
  601. cb(null);
  602. }
  603. });
  604. };
  605. }
  606. }
  607. for(let i=0; i<updateDatas.length; i++){
  608. if(updateDatas[i].type === 'preSiblingNode'){
  609. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  610. }
  611. else if(updateDatas[i].type === 'oprNode'){
  612. functions.push(parallelFucs.oprNode(updateDatas[i]));
  613. }
  614. else {
  615. functions.push(parallelFucs.preChildren(updateDatas[i]));
  616. }
  617. }
  618. functions.push(parallelFucs.updateLastOpr());
  619. async.parallel(functions, function (err) {
  620. if(err){
  621. callback(1, 'Error');
  622. }
  623. else{
  624. callback(0, '');
  625. }
  626. })
  627. };
  628. billsLibDao.prototype.updatePNId= function(upData, callback){
  629. let billsLibId = upData.billsLibId;
  630. let updateDatas = upData.updateData;
  631. let eachDatas = [];
  632. for(let i=0; i< updateDatas.length; i++){
  633. if(updateDatas[i].ID.length > 1){
  634. let ids = updateDatas[i].ID;
  635. for(let j=0; j<ids.length; j++){
  636. let eachObj = {
  637. id: ids[j],
  638. data: updateDatas[i]
  639. }
  640. eachDatas.push(eachObj);
  641. }
  642. }
  643. else {
  644. eachDatas.push({id: updateDatas[i].ID, data: updateDatas[i]});
  645. }
  646. }
  647. async.each(eachDatas, function(eachObj, cb){
  648. let id = eachObj.id, data = eachObj.data;
  649. if(data.ParentID && data.NextSiblingID){
  650. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){
  651. if(err){
  652. cb(err);
  653. }else {
  654. cb(null);
  655. }
  656. });
  657. }
  658. else if(data.ParentID && !data.NextSiblingID){
  659. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID}}, function(err){
  660. if(err){
  661. if(err){
  662. cb(err);
  663. }else {
  664. cb(null);
  665. }
  666. }
  667. });
  668. }
  669. else if(!data.ParentID && data.NextSiblingID){
  670. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function(err){
  671. if(err){
  672. cb(err);
  673. }else {
  674. cb(null);
  675. }
  676. });
  677. }
  678. }, function(err){
  679. if(err){
  680. callback(1, 'Error');
  681. }
  682. else {
  683. callback(0, '');
  684. }
  685. });
  686. }
  687. billsLibDao.prototype.updateBills = function(ubillsData, callback){
  688. let billsLibId = ubillsData.billsLibId;
  689. let updateId = ubillsData.updateId;
  690. let updateField = ubillsData.field;
  691. let updateData = ubillsData.data, lastOperator = ubillsData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  692. let needSet = {};
  693. needSet[updateField] = updateData;
  694. async.parallel([
  695. function (cb) {
  696. if(updateField !== 'jobs' && updateField !== 'items'){
  697. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: needSet}, function (err) {
  698. if(err){
  699. cb(err);
  700. }
  701. else{
  702. cb(null);
  703. }
  704. })
  705. }
  706. else{
  707. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$addToSet: needSet}, function (err) {
  708. if(err){
  709. cb(err);
  710. }
  711. else{
  712. cb(null);
  713. }
  714. });
  715. }
  716. },
  717. function (cb) {
  718. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  719. if(err){
  720. cb(err);
  721. }
  722. else{
  723. if(result.length > 0 ){
  724. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  725. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  726. if(err){
  727. cb(err);
  728. }
  729. else{
  730. cb(null);
  731. }
  732. });
  733. }
  734. }
  735. });
  736. }
  737. ], function (err) {
  738. if(err){
  739. callback(1, 'Error');
  740. }
  741. else{
  742. callback(0, '');
  743. }
  744. });
  745. }
  746. billsLibDao.prototype.removeTotal = function (data, callback) {
  747. let billsLibId = data.billsLibId, billsIds = data.billsIds,
  748. delIds = data.delIds, field = data.field, functions = [], delArr = [],
  749. lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  750. if(billsIds.length > 0){
  751. billsIds.forEach(function (updateId) {
  752. delIds.forEach(function (delId) {
  753. delArr.push({updateID: updateId, delId: delId});
  754. });
  755. });
  756. }
  757. let parallelFucs = {
  758. updateLastOpr: function () {
  759. return function (cb) {
  760. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  761. if(err){
  762. cb(err);
  763. }
  764. else{
  765. if(result.length > 0 ){
  766. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  767. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  768. if(err){
  769. cb(err);
  770. }
  771. else{
  772. cb(null);
  773. }
  774. });
  775. }
  776. }
  777. });
  778. }
  779. },
  780. delJobs: function () {
  781. return function (cb) {
  782. async.each(delIds, function (delJobId, ecb) {
  783. JobContent.update({billsLibId: billsLibId, id: delJobId, deleted: false}, {$set: {deleted: true}}, function (err, result) {
  784. if(err){
  785. ecb(err);
  786. }
  787. else {
  788. ecb(null);
  789. }
  790. });
  791. }, function (err) {
  792. if(err){
  793. cb(err);
  794. }
  795. else{
  796. cb(null);
  797. }
  798. });
  799. };
  800. },
  801. delJobsArr: function () {
  802. return function (cb) {
  803. async.each(delArr, function (delObj, ecb) {
  804. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {jobs: {id: delObj.delId}}}, function (err) {
  805. if(err){
  806. ecb(err);
  807. }else{
  808. ecb(null);
  809. }
  810. });
  811. }, function (err) {
  812. if(err){
  813. cb(err);
  814. }
  815. else{
  816. cb(null);
  817. }
  818. })
  819. };
  820. },
  821. delItems: function () {
  822. return function (cb) {
  823. async.each(delIds, function (delItemId, ecb) {
  824. ItemCharacter.update({billsLibId: billsLibId, id: delItemId, deleted: false}, {$set: {deleted: true}}, function (err) {
  825. if(err){
  826. ecb(err);
  827. }
  828. else{
  829. ecb(null);
  830. }
  831. }, function (err) {
  832. if(err){
  833. cb(err);
  834. }
  835. else{
  836. cb(null);
  837. }
  838. });
  839. });
  840. }
  841. },
  842. delItemsArr: function () {
  843. return function (cb) {
  844. async.each(delArr, function (delObj, ecb) {
  845. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted:false}, {$pull: {items: {id: delObj.delId}}}, function(err){
  846. if(err){
  847. ecb(err);
  848. }
  849. else{
  850. ecb(null);
  851. }
  852. });
  853. }, function (err) {
  854. if(err){
  855. cb(err);
  856. }
  857. else{
  858. cb(null);
  859. }
  860. });
  861. }
  862. }
  863. };
  864. if(field === 'jobs'){
  865. functions.push(parallelFucs.delJobs());
  866. functions.push(parallelFucs.delJobsArr());
  867. }
  868. else{
  869. functions.push(parallelFucs.delItems());
  870. functions.push(parallelFucs.delItemsArr());
  871. }
  872. functions.push(parallelFucs.updateLastOpr());
  873. async.parallel(functions, function (err) {
  874. if(err){
  875. callback(1, 'Error');
  876. }
  877. else{
  878. callback(0, '');
  879. }
  880. });
  881. };
  882. billsLibDao.prototype.updateSerialNo = function (data, callback) {
  883. let billsLibId = data.billsLibId, billsId = data.billsId,
  884. updateArr = data.updateArr, field = data.field,
  885. lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  886. if(field === 'jobs'){
  887. async.parallel([
  888. function (cb) {
  889. async.each(updateArr, function (updateObj, ecb) {
  890. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'jobs.id': updateObj.id}, {$set: {'jobs.$.serialNo': updateObj.serialNo}}, function (err) {
  891. if(err){
  892. ecb(err);
  893. }
  894. else{
  895. ecb(null);
  896. }
  897. });
  898. }, function (err) {
  899. if(err){
  900. cb(err);
  901. }
  902. else{
  903. cb(null);
  904. }
  905. });
  906. },
  907. function (cb) {
  908. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  909. if(err){
  910. cb(err);
  911. }
  912. else{
  913. if(result.length > 0 ){
  914. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  915. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  916. if(err){
  917. cb(err);
  918. }
  919. else{
  920. cb(null);
  921. }
  922. });
  923. }
  924. }
  925. });
  926. }
  927. ], function (err) {
  928. if(err){
  929. callback(1, 'Error');
  930. }
  931. else{
  932. callback(0, '');
  933. }
  934. });
  935. }
  936. else{
  937. async.parallel([
  938. function (cb) {
  939. async.each(updateArr, function (updateObj, ecb) {
  940. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'items.id': updateObj.id}, {$set: {'items.$.serialNo': updateObj.serialNo}}, function (err) {
  941. if(err){
  942. ecb(err);
  943. }
  944. else{
  945. ecb(null);
  946. }
  947. });
  948. }, function (err) {
  949. if(err){
  950. cb(err);
  951. }
  952. else{
  953. cb(null);
  954. }
  955. });
  956. },
  957. function (cb) {
  958. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  959. if(err){
  960. cb(err);
  961. }
  962. else{
  963. if(result.length > 0 ){
  964. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  965. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  966. if(err){
  967. cb(err);
  968. }
  969. else{
  970. cb(null);
  971. }
  972. });
  973. }
  974. }
  975. });
  976. }
  977. ], function (err) {
  978. if(err){
  979. callback(1, 'Error');
  980. }
  981. else{
  982. callback(0, '');
  983. }
  984. });
  985. }
  986. };
  987. billsLibDao.prototype.updateBillsArr = function(updateData, callback){
  988. let billsLibId = updateData.billsLibId;
  989. let updateId = updateData.updateId;
  990. let orgId = updateData.orgId;
  991. let newId = updateData.newId;
  992. let classify = updateData.classify;
  993. let type = updateData.type;
  994. let lastOperator = updateData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  995. if(classify === 'jobs'){
  996. if(orgId && newId && type === 'update'){
  997. async.parallel([
  998. function (cb) {
  999. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'jobs.id': orgId}, {$set: {'jobs.$.id': newId}}, function(err){
  1000. if(err){
  1001. cb(err);
  1002. }
  1003. else {
  1004. cb(null);
  1005. }
  1006. });
  1007. },
  1008. function (cb) {
  1009. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1010. if(err){
  1011. cb(err);
  1012. }
  1013. else{
  1014. if(result.length > 0 ){
  1015. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1016. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1017. if(err){
  1018. cb(err);
  1019. }
  1020. else{
  1021. cb(null);
  1022. }
  1023. });
  1024. }
  1025. }
  1026. });
  1027. }
  1028. ], function (err) {
  1029. if(err){
  1030. callback(1, 'Error');
  1031. }
  1032. else{
  1033. callback(0, '');
  1034. }
  1035. });
  1036. }
  1037. if(orgId && !newId && type === 'delete'){
  1038. async.parallel([
  1039. function (cb) {
  1040. async.each(orgId, function(oid, ecb){
  1041. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {jobs: {id: oid}}}, function(err){
  1042. if(err){
  1043. ecb(err);
  1044. }else {
  1045. ecb(null);
  1046. }
  1047. });
  1048. }, function(err){
  1049. if(err){
  1050. cb(err);
  1051. }
  1052. else{
  1053. cb(null);
  1054. }
  1055. });
  1056. },
  1057. function (cb) {
  1058. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1059. if(err){
  1060. cb(err);
  1061. }
  1062. else{
  1063. if(result.length > 0 ){
  1064. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1065. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1066. if(err){
  1067. cb(err);
  1068. }
  1069. else{
  1070. cb(null);
  1071. }
  1072. });
  1073. }
  1074. }
  1075. });
  1076. }
  1077. ], function (err) {
  1078. if(err){
  1079. callback(1, 'Error');
  1080. }
  1081. else{
  1082. callback(0, '');
  1083. }
  1084. })
  1085. }
  1086. if(orgId && !newId && type === 'deleteAll'){
  1087. let delArr = [];
  1088. updateId.forEach(function(uid){
  1089. orgId.forEach(function(oid){
  1090. delArr.push({updateId: uid, delId: oid});
  1091. });
  1092. });
  1093. async.parallel([
  1094. function (cb) {
  1095. async.each(delArr, function(delObj, ecb){
  1096. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {jobs: {id: delObj.delId}}}, function(err){
  1097. if(err){
  1098. ecb(err);
  1099. }else {
  1100. ecb(null);
  1101. }
  1102. });
  1103. }, function(err){
  1104. if(err){
  1105. cb(err);
  1106. }else {
  1107. cb(null);
  1108. }
  1109. });
  1110. },
  1111. function (cb) {
  1112. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1113. if(err){
  1114. cb(err);
  1115. }
  1116. else{
  1117. if(result.length > 0 ){
  1118. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1119. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1120. if(err){
  1121. cb(err);
  1122. }
  1123. else{
  1124. cb(null);
  1125. }
  1126. });
  1127. }
  1128. }
  1129. });
  1130. }
  1131. ], function (err) {
  1132. if(err){
  1133. callback(1, 'Error');
  1134. }
  1135. else{
  1136. callback(0, '');
  1137. }
  1138. });
  1139. }
  1140. }
  1141. else if(classify === 'items'){
  1142. if(orgId && newId && type === 'update'){
  1143. async.parallel([
  1144. function (cb) {
  1145. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'items.id': orgId}, {$set: {'items.$.id': newId}}, function(err){
  1146. if(err){
  1147. cb(err);
  1148. }
  1149. else {
  1150. cb(null);
  1151. }
  1152. });
  1153. },
  1154. function (cb) {
  1155. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1156. if(err){
  1157. cb(err);
  1158. }
  1159. else{
  1160. if(result.length > 0 ){
  1161. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1162. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1163. if(err){
  1164. cb(err);
  1165. }
  1166. else{
  1167. cb(null);
  1168. }
  1169. });
  1170. }
  1171. }
  1172. });
  1173. }
  1174. ], function (err) {
  1175. if(err){
  1176. callback(1, 'Error');
  1177. }
  1178. else{
  1179. callback(0, '');
  1180. }
  1181. });
  1182. }
  1183. if(orgId && !newId && type === 'delete'){
  1184. async.parallel([
  1185. function (cb) {
  1186. async.each(orgId, function(oid, ecb){
  1187. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {items: {id: oid}}}, function(err){
  1188. if(err){
  1189. ecb(err);
  1190. }else {
  1191. ecb(null);
  1192. }
  1193. });
  1194. }, function(err){
  1195. if(err){
  1196. cb(err);
  1197. }else {
  1198. cb(null);
  1199. }
  1200. });
  1201. },
  1202. function (cb) {
  1203. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1204. if(err){
  1205. cb(err);
  1206. }
  1207. else{
  1208. if(result.length > 0 ){
  1209. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1210. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1211. if(err){
  1212. cb(err);
  1213. }
  1214. else{
  1215. cb(null);
  1216. }
  1217. });
  1218. }
  1219. }
  1220. });
  1221. }
  1222. ], function (err) {
  1223. if(err){
  1224. callback(1, 'Error');
  1225. }
  1226. else{
  1227. callback(0, '');
  1228. }
  1229. })
  1230. }
  1231. if(orgId && !newId && type === 'deleteAll'){
  1232. let delArr = [];
  1233. updateId.forEach(function(uid){
  1234. orgId.forEach(function(oid){
  1235. delArr.push({updateId: uid, delId: oid});
  1236. });
  1237. });
  1238. async.parallel([
  1239. function (cb) {
  1240. async.each(delArr, function(delObj, ecb){
  1241. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {items: {id: delObj.delId}}}, function(err){
  1242. if(err){
  1243. ecb(err);
  1244. }else {
  1245. ecb(null);
  1246. }
  1247. });
  1248. }, function(err){
  1249. if(err){
  1250. cb(err);
  1251. }else {
  1252. cb(err);
  1253. }
  1254. });
  1255. },
  1256. function (cb) {
  1257. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1258. if(err){
  1259. cb(err);
  1260. }
  1261. else{
  1262. if(result.length > 0 ){
  1263. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1264. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1265. if(err){
  1266. cb(err);
  1267. }
  1268. else{
  1269. cb(null);
  1270. }
  1271. });
  1272. }
  1273. }
  1274. });
  1275. }
  1276. ], function (err) {
  1277. if(err){
  1278. callback(1, 'Error');
  1279. }
  1280. else{
  1281. callback(0, '');
  1282. }
  1283. });
  1284. }
  1285. }
  1286. };
  1287. billsLibDao.prototype.pasteBills = function(pData, callback){
  1288. let datas = pData.datas,
  1289. billsLibId = pData.billsLibId, lastOperator = pData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1290. async.parallel([
  1291. function (cb) {
  1292. async.each(datas, function(data, ecb){
  1293. let needSet = {};
  1294. for(let i in data){
  1295. needSet[i] = data[i];
  1296. }
  1297. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: needSet}, function (err) {
  1298. if(err){
  1299. ecb(err);
  1300. }
  1301. else {
  1302. ecb(null);
  1303. }
  1304. });
  1305. }, function(err){
  1306. if(err){
  1307. cb(err);
  1308. }else {
  1309. cb(null);
  1310. }
  1311. });
  1312. },
  1313. function (cb) {
  1314. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1315. if(err){
  1316. cb(err);
  1317. }
  1318. else{
  1319. if(result.length > 0 ){
  1320. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1321. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1322. if(err){
  1323. cb(err);
  1324. }
  1325. else{
  1326. cb(null);
  1327. }
  1328. });
  1329. }
  1330. }
  1331. });
  1332. }
  1333. ], function (err) {
  1334. if(err){
  1335. callback(1, 'Error');
  1336. }
  1337. else{
  1338. callback(0, '');
  1339. }
  1340. });
  1341. }
  1342. billsLibDao.prototype.updateRecharge = function(uData, callback){
  1343. let billsLibId = uData.billsLibId;
  1344. let updateId = uData.updateId;
  1345. let data = uData.data, lastOperator = uData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1346. async.parallel([
  1347. function (cb) {
  1348. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {recharge: data}}, function(err){
  1349. if(err){
  1350. cb(err);
  1351. }
  1352. else {
  1353. cb(null);
  1354. }
  1355. });
  1356. },
  1357. function (cb) {
  1358. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1359. if(err){
  1360. cb(err);
  1361. }
  1362. else{
  1363. if(result.length > 0 ){
  1364. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1365. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1366. if(err){
  1367. cb(err);
  1368. }
  1369. else{
  1370. cb(null);
  1371. }
  1372. });
  1373. }
  1374. }
  1375. });
  1376. }
  1377. ], function (err) {
  1378. if(err){
  1379. callback(1, 'Error');
  1380. }
  1381. else{
  1382. callback(0, '');
  1383. }
  1384. });
  1385. };
  1386. billsLibDao.prototype.pasteRel = function (data, callback) {
  1387. const UpdateExist = 'updateExist', UpdateNew = 'updateNew', CreateExist = 'createExist', CreateNew = 'createNew';
  1388. const Jobs = 'jobs', Items = 'items';
  1389. let field = data.field;
  1390. let updateDatas = data.updateDatas;
  1391. let createDatas = data.createDatas;
  1392. let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1393. let parallelFucs = {
  1394. updateLastOpr: function () {
  1395. return function (cb) {
  1396. StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
  1397. if(err){
  1398. cb(err);
  1399. }
  1400. else{
  1401. if(result.length > 0 ){
  1402. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1403. StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1404. if(err){
  1405. cb(err);
  1406. }
  1407. else{
  1408. cb(null);
  1409. }
  1410. });
  1411. }
  1412. }
  1413. });
  1414. }
  1415. },
  1416. updateExJobs: function(data){
  1417. let orgJobId = data.orgJobId, newJobId = data.newJobId,
  1418. nodeId = data.nodeId, billsLibId = data.billsLibId;
  1419. return function (cb){
  1420. if(orgJobId && newJobId && nodeId && billsLibId){
  1421. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  1422. if(err){
  1423. cb(err);
  1424. }
  1425. else{
  1426. cb(null, data)
  1427. }
  1428. });
  1429. }
  1430. }
  1431. },
  1432. updateNeJobs: function(data){
  1433. let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
  1434. orgJobId = data.orgJobId, code = data.code;
  1435. return function (cb){
  1436. if(billsLibId && nodeId && newData && orgJobId && code){
  1437. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1438. if(err){
  1439. cb(err);
  1440. }
  1441. else {
  1442. let newJobId = result.sequence_value;
  1443. let newJobContent = {
  1444. id: newJobId,
  1445. billsLibId: billsLibId,
  1446. code: code,
  1447. content: newData,
  1448. deleted: false
  1449. };
  1450. JobContent.create(newJobContent, function(err){
  1451. if(err){
  1452. cb(err);
  1453. }
  1454. else{
  1455. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  1456. if(err){
  1457. cb(err);
  1458. }
  1459. else{
  1460. data.newJobId = newJobId;
  1461. cb(null, data);
  1462. }
  1463. });
  1464. }
  1465. });
  1466. }
  1467. });
  1468. }
  1469. }
  1470. },
  1471. createExJobs: function(data){
  1472. let billsLibId = data.billsLibId, newData = data.newData,
  1473. nodeId = data.nodeId, jobId = data.jobId, serialNo = data.serialNo;
  1474. return function (cb){
  1475. if(billsLibId && newData && nodeId && jobId){
  1476. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: jobId, serialNo: serialNo}}}, function(err){
  1477. if(err){
  1478. cb(err);
  1479. }
  1480. else {
  1481. cb(null, data);
  1482. }
  1483. });
  1484. }
  1485. }
  1486. },
  1487. createNeJobs: function(data){
  1488. let billsLibId = data.billsLibId, newData = data.newData,
  1489. code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
  1490. return function (cb){
  1491. if(billsLibId && newData && code){
  1492. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1493. if(err){
  1494. cb(err);
  1495. }
  1496. else {
  1497. let newJobId = result.sequence_value;
  1498. let newJobContent = {
  1499. id: newJobId,
  1500. billsLibId: billsLibId,
  1501. code: code,
  1502. content: newData,
  1503. deleted: false
  1504. };
  1505. JobContent.create(newJobContent, function(err){
  1506. if(err){
  1507. cb(err);
  1508. }
  1509. else{
  1510. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
  1511. if(err){
  1512. cb(err);
  1513. }
  1514. else {
  1515. data.newJobId = newJobId;
  1516. cb(null, data);
  1517. }
  1518. });
  1519. }
  1520. });
  1521. }
  1522. });
  1523. }
  1524. }
  1525. },
  1526. updateExItems: function(data){
  1527. let orgItemId = data.orgItemId, newItemId = data.newItemId,
  1528. nodeId = data.nodeId, billsLibId = data.billsLibId;
  1529. return function (cb){
  1530. if(orgItemId && newItemId && nodeId && billsLibId){
  1531. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  1532. if(err){
  1533. cb(err);
  1534. }
  1535. else{
  1536. cb(null, data);
  1537. }
  1538. });
  1539. }
  1540. }
  1541. },
  1542. updateNeItems: function(data){
  1543. let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
  1544. orgItemId = data.orgItemId, code = data.code;
  1545. return function (cb){
  1546. if(billsLibId && nodeId && newData && orgItemId && code){
  1547. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  1548. if(err){
  1549. cb(err);
  1550. }
  1551. else {
  1552. let newItemId = result.sequence_value;
  1553. let newItemContent = {
  1554. id: newItemId,
  1555. billsLibId: billsLibId,
  1556. code: code,
  1557. content: newData,
  1558. deleted: false
  1559. };
  1560. ItemCharacter.create(newItemContent, function(err){
  1561. if(err){
  1562. cb(err);
  1563. }
  1564. else{
  1565. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  1566. if(err){
  1567. cb(err);
  1568. }
  1569. else{
  1570. data.newItemId = newItemId;
  1571. cb(null, data);
  1572. }
  1573. });
  1574. }
  1575. });
  1576. }
  1577. });
  1578. }
  1579. }
  1580. },
  1581. createExItems: function(data){
  1582. let billsLibId = data.billsLibId, newData = data.newData,
  1583. nodeId = data.nodeId, itemId = data.itemId, serialNo = data.serialNo;
  1584. return function (cb){
  1585. if(billsLibId && newData && nodeId && itemId){
  1586. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: itemId, serialNo: serialNo}}}, function(err){
  1587. if(err){
  1588. cb(err);
  1589. }
  1590. else {
  1591. cb(null, data);
  1592. }
  1593. });
  1594. }
  1595. }
  1596. },
  1597. createNeItems: function(data){
  1598. let billsLibId = data.billsLibId, newData = data.newData,
  1599. code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
  1600. return function (cb){
  1601. if(billsLibId && newData && code){
  1602. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  1603. if(err){
  1604. cb(err);
  1605. }
  1606. else {
  1607. let newItemId = result.sequence_value;
  1608. let newItemContent = {
  1609. id: newItemId,
  1610. billsLibId: billsLibId,
  1611. code: code,
  1612. content: newData,
  1613. deleted: false
  1614. };
  1615. ItemCharacter.create(newItemContent, function(err){
  1616. if(err){
  1617. cb(err);
  1618. }
  1619. else{
  1620. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){
  1621. if(err){
  1622. cb(err);
  1623. }
  1624. else {
  1625. data.newItemId = newItemId;
  1626. cb(null, data);
  1627. }
  1628. });
  1629. }
  1630. });
  1631. }
  1632. });
  1633. }
  1634. }
  1635. }
  1636. };
  1637. if(field === Jobs){
  1638. if(updateDatas.length > 0){
  1639. for(let i=0; i<updateDatas.length; i++){
  1640. if(updateDatas[i].type === UpdateExist){
  1641. functions.push(parallelFucs.updateExJobs(updateDatas[i]));
  1642. }
  1643. if(updateDatas[i].type === UpdateNew){
  1644. functions.push(parallelFucs.updateNeJobs(updateDatas[i]));
  1645. }
  1646. }
  1647. }
  1648. if(createDatas.length > 0){
  1649. for(let i=0; i<createDatas.length; i++){
  1650. if(createDatas[i].type === CreateExist){
  1651. functions.push(parallelFucs.createExJobs(createDatas[i]));
  1652. }
  1653. if(createDatas[i].type === CreateNew){
  1654. functions.push(parallelFucs.createNeJobs(createDatas[i]));
  1655. }
  1656. }
  1657. }
  1658. }
  1659. else {
  1660. if(updateDatas.length > 0){
  1661. for(let i=0; i<updateDatas.length; i++){
  1662. if(updateDatas[i].type === UpdateExist){
  1663. functions.push(parallelFucs.updateExItems(updateDatas[i]));
  1664. }
  1665. if(updateDatas[i].type === UpdateNew){
  1666. functions.push(parallelFucs.updateNeItems(updateDatas[i]));
  1667. }
  1668. }
  1669. }
  1670. if(createDatas.length > 0){
  1671. for(let i=0; i<createDatas.length; i++){
  1672. if(createDatas[i].type === CreateExist){
  1673. functions.push(parallelFucs.createExItems(createDatas[i]));
  1674. }
  1675. if(createDatas[i].type === CreateNew){
  1676. functions.push(parallelFucs.createNeItems(createDatas[i]));
  1677. }
  1678. }
  1679. }
  1680. }
  1681. functions.push(parallelFucs.updateLastOpr());
  1682. async.parallel(functions, function(err, datas){
  1683. if(err){
  1684. callback(1, 'Error', null);
  1685. }else {
  1686. callback(0, '', datas);
  1687. }
  1688. });
  1689. };
  1690. billsLibDao.prototype.deleteBills = function(delData, callback){
  1691. let deleteIds = delData.deleteIds;
  1692. let billsLibId = delData.billsLibId;
  1693. let updateNode = delData.updateNode,
  1694. lastOperator = delData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1695. if(deleteIds){
  1696. async.parallel([
  1697. function(cb){
  1698. async.each(deleteIds, function(delId, ecb){
  1699. Bills.update({billsLibId: billsLibId, ID: delId, deleted: false}, {$set: {deleted: true}}, function(err){
  1700. if(err){
  1701. ecb(err);
  1702. }
  1703. else {
  1704. ecb(null);
  1705. }
  1706. });
  1707. }, function(err){
  1708. if(err){
  1709. cb(err);
  1710. }
  1711. else {
  1712. cb(null);
  1713. }
  1714. });
  1715. },
  1716. function(cb){
  1717. if(updateNode){
  1718. Bills.update({billsLibId: billsLibId, ID: updateNode.ID, deleted: false}, {$set: {NextSiblingID: updateNode.NextSiblingID}}, function(err){
  1719. if(err){
  1720. cb(err);
  1721. }
  1722. else {
  1723. cb(null);
  1724. }
  1725. });
  1726. }else {
  1727. cb(null);
  1728. }
  1729. },
  1730. function (cb) {
  1731. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1732. if(err){
  1733. cb(err);
  1734. }
  1735. else{
  1736. if(result.length > 0 ){
  1737. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1738. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1739. if(err){
  1740. cb(err);
  1741. }
  1742. else{
  1743. cb(null);
  1744. }
  1745. });
  1746. }
  1747. }
  1748. });
  1749. }
  1750. ], function(err){
  1751. if(err){
  1752. callback(1, 'Error');
  1753. }else {
  1754. callback(0, '');
  1755. }
  1756. });
  1757. }
  1758. }
  1759. //--------------JobContent------------------
  1760. billsLibDao.prototype.getJobContent = function(gJobData, callback){
  1761. let billsLibId = gJobData.billsLibId;
  1762. JobContent.find({billsLibId: billsLibId, deleted: false}, '-_id').lean().sort({code: 1}).exec(function(err, result){
  1763. if(err){
  1764. callback(1, 'Error', null);
  1765. }
  1766. else {
  1767. callback(0, '', result);
  1768. }
  1769. });
  1770. }
  1771. billsLibDao.prototype.createJobContent = function(cJobData, callback){
  1772. let data = cJobData.data;
  1773. let billsLibId = cJobData.billsLibId;
  1774. let serialNo = cJobData.serialNo;
  1775. let newJobContent, lastOperator = cJobData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1776. async.parallel([
  1777. function (cb) {
  1778. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1779. if(err){
  1780. cb(err)
  1781. }
  1782. else {
  1783. let newJobId = result.sequence_value;
  1784. newJobContent = {
  1785. id: newJobId,
  1786. billsLibId: billsLibId,
  1787. code: serialNo,
  1788. content: data,
  1789. deleted: false
  1790. };
  1791. JobContent.create(newJobContent, function(err){
  1792. if(err){
  1793. cb(err);
  1794. }
  1795. else{
  1796. cb(null, newJobId);
  1797. }
  1798. });
  1799. }
  1800. });
  1801. },
  1802. function (cb) {
  1803. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1804. if(err){
  1805. cb(err);
  1806. }
  1807. else{
  1808. if(result.length > 0 ){
  1809. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1810. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1811. if(err){
  1812. cb(err);
  1813. }
  1814. else{
  1815. cb(null);
  1816. }
  1817. });
  1818. }
  1819. }
  1820. });
  1821. }
  1822. ], function (err, result) {
  1823. if(err){
  1824. callback(1, 'Error', null);
  1825. }
  1826. else{
  1827. callback(0, '', result[0])
  1828. }
  1829. })
  1830. };
  1831. billsLibDao.prototype.updateJobContent = function(uJobData, callback){
  1832. let billsLibId = uJobData.billsLibId;
  1833. let field = uJobData.field;
  1834. let updateData = uJobData.data;
  1835. let updateid = uJobData.updateId, lastOperator = uJobData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss'),
  1836. needSet = {};
  1837. needSet[field] = updateData;
  1838. async.parallel([
  1839. function (cb) {
  1840. JobContent.update({billsLibId: billsLibId, id: updateid}, {$set: needSet}, function (err) {
  1841. if(err){
  1842. cb(err);
  1843. }
  1844. else{
  1845. cb(null);
  1846. }
  1847. });
  1848. },
  1849. function (cb) {
  1850. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1851. if(err){
  1852. cb(err);
  1853. }
  1854. else{
  1855. if(result.length > 0 ){
  1856. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1857. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1858. if(err){
  1859. cb(err);
  1860. }
  1861. else{
  1862. cb(null);
  1863. }
  1864. });
  1865. }
  1866. }
  1867. });
  1868. }
  1869. ], function (err) {
  1870. if(err){
  1871. callback(1, 'Error');
  1872. }
  1873. else{
  1874. callback(0, '');
  1875. }
  1876. });
  1877. };
  1878. billsLibDao.prototype.deleteJobContent = function(data, callback){
  1879. let delIds = data.ids;
  1880. let billsLibId = data.billsLibId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1881. if(delIds){
  1882. async.parallel([
  1883. function (cb) {
  1884. async.each(delIds, function(id, ecb){
  1885. JobContent.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
  1886. if(err){
  1887. ecb(err);
  1888. }
  1889. else {
  1890. ecb(null);
  1891. }
  1892. });
  1893. }, function(err){
  1894. if(err){
  1895. cb(err);
  1896. }else {
  1897. cb(null);
  1898. }
  1899. });
  1900. },
  1901. function (cb) {
  1902. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  1903. if(err){
  1904. cb(err);
  1905. }
  1906. else{
  1907. if(result.length > 0 ){
  1908. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1909. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1910. if(err){
  1911. cb(err);
  1912. }
  1913. else{
  1914. cb(null);
  1915. }
  1916. });
  1917. }
  1918. }
  1919. });
  1920. }
  1921. ], function (err) {
  1922. if(err){
  1923. callback(1, 'Error');
  1924. }
  1925. else{
  1926. callback(0, '');
  1927. }
  1928. })
  1929. }
  1930. }
  1931. billsLibDao.prototype.pasteJobs = function (data, callback) {
  1932. let pasteDatas = data.pasteDatas;
  1933. let updateDatas = pasteDatas.updateDatas,
  1934. createDatas = pasteDatas.createDatas;
  1935. let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  1936. let parallelFucs = {
  1937. updateLastOpr: function () {
  1938. return function (cb) {
  1939. StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
  1940. if(err){
  1941. cb(err);
  1942. }
  1943. else{
  1944. if(result.length > 0 ){
  1945. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  1946. StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  1947. if(err){
  1948. cb(err);
  1949. }
  1950. else{
  1951. cb(null);
  1952. }
  1953. });
  1954. }
  1955. }
  1956. });
  1957. }
  1958. },
  1959. updateFuc: function(data){
  1960. let updateId = data.orgId,
  1961. field = data.field,
  1962. updateData = data.data, billsLibId = data.billsLibId;
  1963. if(field === 'code'){
  1964. return function (cb){
  1965. JobContent.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){
  1966. if(err){
  1967. cb(err);
  1968. }else {
  1969. cb(null, data);
  1970. }
  1971. });
  1972. };
  1973. }else {
  1974. return function (cb){
  1975. JobContent.update({billsLibId: billsLibId, id: updateId}, {$set: {content: updateData}}, function(err){
  1976. if(err){
  1977. cb(err);
  1978. }else {
  1979. cb(null, data);
  1980. }
  1981. });
  1982. }
  1983. }
  1984. },
  1985. createFuc: function(data){
  1986. let billsLibId = data.billsLibId,
  1987. code;
  1988. let jobObj;
  1989. if(data.type === 'CreateT'){
  1990. jobObj = {
  1991. billsLibId: billsLibId,
  1992. code: data.code,
  1993. content: data.content,
  1994. deleted: false
  1995. }
  1996. }
  1997. else{
  1998. if(data.field === 'code'){
  1999. jobObj = {
  2000. billsLibId: billsLibId,
  2001. code: data.data,
  2002. content: '',
  2003. deleted: false
  2004. }
  2005. }
  2006. else {
  2007. jobObj = {
  2008. billsLibId: billsLibId,
  2009. code: data.code,
  2010. content: data.data,
  2011. deleted: false
  2012. }
  2013. }
  2014. }
  2015. return function (cb){
  2016. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  2017. if(err){
  2018. cb(err);
  2019. }
  2020. else {
  2021. let newJobId = result.sequence_value;
  2022. jobObj.id = newJobId;
  2023. data.newJobId = newJobId
  2024. JobContent.create(jobObj, function(err){
  2025. if(err){
  2026. cb(err);
  2027. }else {
  2028. cb(null, data);
  2029. }
  2030. });
  2031. }
  2032. });
  2033. }
  2034. }
  2035. };
  2036. if(updateDatas.length > 0){
  2037. for(let i=0; i<updateDatas.length; i++){
  2038. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  2039. }
  2040. }
  2041. if(createDatas.length > 0){
  2042. for(let i =0; i<createDatas.length; i++){
  2043. functions.push(parallelFucs.createFuc(createDatas[i]));
  2044. }
  2045. }
  2046. functions.push(parallelFucs.updateLastOpr());
  2047. async.parallel(functions, function(err, datas){
  2048. if(err){
  2049. callback(1, 'Error', null);
  2050. }else {
  2051. callback(0, '', datas);
  2052. }
  2053. });
  2054. };
  2055. billsLibDao.prototype.edCreateJob = function(data, callback){
  2056. let billsLibId = data.billsLibId,
  2057. code = data.code,
  2058. billsId = data.billsId,
  2059. content = data.data,
  2060. serialNo = data.serialNo, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2061. async.waterfall([
  2062. function(cb){
  2063. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  2064. if(err){
  2065. cb(err, null);
  2066. }
  2067. else {
  2068. let newJobId = result.sequence_value;
  2069. cb(null, newJobId);
  2070. }
  2071. })
  2072. },
  2073. function(newJobId, cb){
  2074. async.parallel([
  2075. function(pcb){
  2076. JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  2077. if(err){
  2078. pcb(err, null);
  2079. }
  2080. else {
  2081. pcb(null, newJobId);
  2082. }
  2083. });
  2084. },
  2085. function(pcb){
  2086. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
  2087. if(err){
  2088. pcb(err, null);
  2089. }
  2090. else {
  2091. pcb(null, newJobId);
  2092. }
  2093. });
  2094. },
  2095. function (pcb) {
  2096. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2097. if(err){
  2098. pcb(err);
  2099. }
  2100. else{
  2101. if(result.length > 0 ){
  2102. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2103. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2104. if(err){
  2105. pcb(err);
  2106. }
  2107. else{
  2108. pcb(null);
  2109. }
  2110. });
  2111. }
  2112. }
  2113. });
  2114. }
  2115. ], function(err, result){
  2116. if(err){
  2117. cb(err, null);
  2118. }
  2119. else {
  2120. cb(null, result[0]);
  2121. }
  2122. });
  2123. }
  2124. ], function(err, reslut){
  2125. if(err){
  2126. callback(1, "Error", null);
  2127. }
  2128. else {
  2129. callback(0, '', reslut);
  2130. }
  2131. });
  2132. };
  2133. billsLibDao.prototype.edUpdateJob = function(data, callback){
  2134. let billsLibId = data.billsLibId,
  2135. billsId = data.billsId,
  2136. content = data.content,
  2137. code = data.code,
  2138. orgJobId = data.orgJobId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2139. async.waterfall([
  2140. function(cb){
  2141. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  2142. if(err){
  2143. cb(err, null);
  2144. }
  2145. else {
  2146. let newJobId = result.sequence_value;
  2147. cb(null, newJobId);
  2148. }
  2149. })
  2150. },
  2151. function(newJobId, cb){
  2152. async.parallel([
  2153. function(pcb){
  2154. JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  2155. if(err){
  2156. pcb(err, null);
  2157. }
  2158. else {
  2159. pcb(null, newJobId);
  2160. }
  2161. });
  2162. },
  2163. function(pcb){
  2164. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  2165. if(err){
  2166. pcb(err, null);
  2167. }
  2168. else {
  2169. pcb(null, newJobId);
  2170. }
  2171. });
  2172. },
  2173. function (pcb) {
  2174. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2175. if(err){
  2176. pcb(err);
  2177. }
  2178. else{
  2179. if(result.length > 0 ){
  2180. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2181. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2182. if(err){
  2183. pcb(err);
  2184. }
  2185. else{
  2186. pcb(null);
  2187. }
  2188. });
  2189. }
  2190. }
  2191. });
  2192. }
  2193. ], function(err, result){
  2194. if(err){
  2195. cb(err, null);
  2196. }
  2197. else {
  2198. cb(null, result[0]);
  2199. }
  2200. });
  2201. }
  2202. ], function(err, reslut){
  2203. if(err){
  2204. callback(1, "Error", null);
  2205. }
  2206. else {
  2207. callback(0, '', reslut);
  2208. }
  2209. });
  2210. };
  2211. //----------------------ItemCharacter---------------------
  2212. billsLibDao.prototype.getItemCharacter = function(gdata, callback){
  2213. let billsLibId = gdata.billsLibId;
  2214. ItemCharacter.find({billsLibId: billsLibId}, '-_id').lean().sort({code: 1}).exec(function(err, result){
  2215. if(err){
  2216. callback(1, 'Error', null);
  2217. }
  2218. else {
  2219. callback(0, '', result);
  2220. }
  2221. });
  2222. }
  2223. billsLibDao.prototype.createItemCharacter = function(cItemData, callback){
  2224. let data = cItemData.data;
  2225. let billsLibId = cItemData.billsLibId;
  2226. let code = cItemData.code;
  2227. let newItemCharacter, lastOperator = cItemData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2228. async.parallel([
  2229. function (cb) {
  2230. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function (err, result) {
  2231. if(err){
  2232. cb(err);
  2233. }
  2234. else{
  2235. let newItemId = result.sequence_value;
  2236. newItemCharacter = {
  2237. id: newItemId,
  2238. billsLibId: billsLibId,
  2239. content: data,
  2240. code: code,
  2241. deleted: false
  2242. }
  2243. ItemCharacter.create(newItemCharacter, function(err){
  2244. if(err){
  2245. cb(err);
  2246. }
  2247. else{
  2248. cb(null, newItemId);
  2249. }
  2250. });
  2251. }
  2252. });
  2253. },
  2254. function (cb) {
  2255. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2256. if(err){
  2257. cb(err);
  2258. }
  2259. else{
  2260. if(result.length > 0 ){
  2261. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2262. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2263. if(err){
  2264. cb(err);
  2265. }
  2266. else{
  2267. cb(null);
  2268. }
  2269. });
  2270. }
  2271. }
  2272. });
  2273. }
  2274. ], function (err, result) {
  2275. if(err){
  2276. callback(1, 'Error', null);
  2277. }
  2278. else{
  2279. callback(0, '', result[0]);
  2280. }
  2281. });
  2282. };
  2283. billsLibDao.prototype.updateItemCharacter = function(uItemData, callback){
  2284. let field = uItemData.field;
  2285. let updateData = uItemData.data;
  2286. let id = uItemData.updateId;
  2287. let billsLibId = uItemData.billsLibId, needSet = {},
  2288. lastOperator = uItemData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2289. needSet[field] = updateData;
  2290. async.parallel([
  2291. function (cb) {
  2292. ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: needSet}, function(err){
  2293. if(err){
  2294. cb(err);
  2295. }
  2296. else{
  2297. cb(null);
  2298. }
  2299. });
  2300. },
  2301. function (cb) {
  2302. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2303. if(err){
  2304. cb(err);
  2305. }
  2306. else{
  2307. if(result.length > 0 ){
  2308. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2309. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2310. if(err){
  2311. cb(err);
  2312. }
  2313. else{
  2314. cb(null);
  2315. }
  2316. });
  2317. }
  2318. }
  2319. });
  2320. }
  2321. ], function (err) {
  2322. if(err){
  2323. callback(1, 'Error');
  2324. }
  2325. else{
  2326. callback(0, '');
  2327. }
  2328. });
  2329. };
  2330. billsLibDao.prototype.updateValue = function(uData, callback){
  2331. let type = uData.type;
  2332. let updateId = uData.updateId;
  2333. let data = uData.data;
  2334. let deleteCodes = uData.deleteCodes;
  2335. let billsLibId = uData.billsLibId, lastOperator = uData.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2336. if(type === 'create'){
  2337. async.parallel([
  2338. function (cb) {
  2339. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$addToSet: {itemValue: data}}, function(err){
  2340. if(err){
  2341. cb(err);
  2342. }
  2343. else{
  2344. cb(null);
  2345. }
  2346. });
  2347. },
  2348. function (cb) {
  2349. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2350. if(err){
  2351. cb(err);
  2352. }
  2353. else{
  2354. if(result.length > 0 ){
  2355. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2356. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2357. if(err){
  2358. cb(err);
  2359. }
  2360. else{
  2361. cb(null);
  2362. }
  2363. });
  2364. }
  2365. }
  2366. });
  2367. }
  2368. ], function (err) {
  2369. if(err){
  2370. callback(1, 'Error');
  2371. }
  2372. else{
  2373. callback(0, '');
  2374. }
  2375. })
  2376. }
  2377. else if(type === 'update'){
  2378. if(data.field === 'code'){
  2379. async.parallel([
  2380. function (cb) {
  2381. ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.code': data.newData}}, function(err){
  2382. if(err){
  2383. cb(err);
  2384. }
  2385. else{
  2386. cb(null);
  2387. }
  2388. });
  2389. },
  2390. function (cb) {
  2391. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2392. if(err){
  2393. cb(err);
  2394. }
  2395. else{
  2396. if(result.length > 0 ){
  2397. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2398. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2399. if(err){
  2400. cb(err);
  2401. }
  2402. else{
  2403. cb(null);
  2404. }
  2405. });
  2406. }
  2407. }
  2408. });
  2409. }
  2410. ], function (err) {
  2411. if(err){
  2412. callback(1, 'Error');
  2413. }
  2414. else{
  2415. callback(0, '');
  2416. }
  2417. });
  2418. }
  2419. else {
  2420. async.parallel([
  2421. function (cb) {
  2422. ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.value': data.newData}}, function(err,result){
  2423. if(err){
  2424. cb(err);
  2425. }
  2426. else{
  2427. cb(null);
  2428. }
  2429. });
  2430. },
  2431. function (cb) {
  2432. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2433. if(err){
  2434. cb(err);
  2435. }
  2436. else{
  2437. if(result.length > 0 ){
  2438. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2439. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2440. if(err){
  2441. cb(err);
  2442. }
  2443. else{
  2444. cb(null);
  2445. }
  2446. });
  2447. }
  2448. }
  2449. });
  2450. }
  2451. ], function (err) {
  2452. if(err){
  2453. callback(1, 'Error');
  2454. }
  2455. else{
  2456. callback(0, '');
  2457. }
  2458. })
  2459. }
  2460. }
  2461. //delete
  2462. else {
  2463. if(deleteCodes.length > 0){
  2464. async.parallel([
  2465. function (cb) {
  2466. async.each(deleteCodes, function(code, ecb){
  2467. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$pull: {itemValue: {code: code}}}, function(err){
  2468. if(err){
  2469. ecb(err);
  2470. }else {
  2471. ecb(null);
  2472. }
  2473. });
  2474. }, function(err){
  2475. if(err){
  2476. cb(err);
  2477. }else {
  2478. cb(null);
  2479. }
  2480. });
  2481. },
  2482. function (cb) {
  2483. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2484. if(err){
  2485. cb(err);
  2486. }
  2487. else{
  2488. if(result.length > 0 ){
  2489. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2490. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2491. if(err){
  2492. cb(err);
  2493. }
  2494. else{
  2495. cb(null);
  2496. }
  2497. });
  2498. }
  2499. }
  2500. });
  2501. }
  2502. ], function (err) {
  2503. if(err){
  2504. callback(1, 'Error');
  2505. }
  2506. else{
  2507. callback(0, '');
  2508. }
  2509. });
  2510. }
  2511. }
  2512. };
  2513. billsLibDao.prototype.deleteItemCharacter = function(data, callback){
  2514. let delIds = data.ids;
  2515. let billsLibId = data.billsLibId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2516. if(delIds){
  2517. async.parallel([
  2518. function (cb) {
  2519. async.each(delIds, function(id, ecb){
  2520. ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
  2521. if(err){
  2522. ecb(err);
  2523. }else {
  2524. ecb(null);
  2525. }
  2526. }, function(err){
  2527. if(err){
  2528. cb(err);
  2529. }else {
  2530. cb(null);
  2531. }
  2532. });
  2533. });
  2534. },
  2535. function (cb) {
  2536. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2537. if(err){
  2538. cb(err);
  2539. }
  2540. else{
  2541. if(result.length > 0 ){
  2542. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2543. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2544. if(err){
  2545. cb(err);
  2546. }
  2547. else{
  2548. cb(null);
  2549. }
  2550. });
  2551. }
  2552. }
  2553. });
  2554. }
  2555. ], function (err) {
  2556. if(err){
  2557. callback(1, 'Error');
  2558. }
  2559. else{
  2560. callback(0, '');
  2561. }
  2562. });
  2563. }
  2564. };
  2565. billsLibDao.prototype.pasteItems = function (data, callback) {
  2566. let pasteDatas = data.pasteDatas;
  2567. let updateDatas = pasteDatas.updateDatas,
  2568. createDatas = pasteDatas.createDatas;
  2569. let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2570. let parallelFucs = {
  2571. updateLastOpr: function () {
  2572. return function (cb) {
  2573. StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
  2574. if(err){
  2575. cb(err);
  2576. }
  2577. else{
  2578. if(result.length > 0 ){
  2579. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2580. StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2581. if(err){
  2582. cb(err);
  2583. }
  2584. else{
  2585. cb(null);
  2586. }
  2587. });
  2588. }
  2589. }
  2590. });
  2591. }
  2592. },
  2593. updateFuc: function(data){
  2594. let updateId = data.orgId,
  2595. field = data.field,
  2596. updateData = data.data, billsLibId = data.billsLibId;
  2597. if(field === 'code'){
  2598. return function (cb){
  2599. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){
  2600. if(err){
  2601. cb(err);
  2602. }else {
  2603. cb(null, data);
  2604. }
  2605. });
  2606. };
  2607. }
  2608. else{
  2609. return function(cb){
  2610. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {content: updateData}}, function(err){
  2611. if(err){
  2612. cb(err);
  2613. }else {
  2614. cb(null, data);
  2615. }
  2616. });
  2617. }
  2618. }
  2619. },
  2620. createFuc: function(data){
  2621. let billsLibId = data.billsLibId,
  2622. code;
  2623. let itemObj;
  2624. if(data.type === 'CreateT'){
  2625. itemObj = {
  2626. billsLibId: billsLibId,
  2627. code: data.code,
  2628. content: data.content,
  2629. deleted: false
  2630. }
  2631. }
  2632. else{
  2633. if(data.field === 'code'){
  2634. itemObj = {
  2635. billsLibId: billsLibId,
  2636. code: data.data,
  2637. content: '',
  2638. deleted: false
  2639. }
  2640. }
  2641. else {
  2642. itemObj = {
  2643. billsLibId: billsLibId,
  2644. code: data.code,
  2645. content: data.data,
  2646. deleted: false
  2647. }
  2648. }
  2649. }
  2650. return function (cb){
  2651. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  2652. if(err){
  2653. cb(err);
  2654. }
  2655. else{
  2656. let newItemId = result.sequence_value;
  2657. itemObj.id = newItemId;
  2658. data.newItemId = newItemId;
  2659. ItemCharacter.create(itemObj, function(err){
  2660. if(err){
  2661. cb(err);
  2662. }else {
  2663. cb(null, data);
  2664. }
  2665. });
  2666. }
  2667. });
  2668. }
  2669. }
  2670. };
  2671. if(updateDatas.length > 0){
  2672. for(let i=0; i<updateDatas.length; i++){
  2673. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  2674. }
  2675. }
  2676. if(createDatas.length > 0){
  2677. for(let i =0; i<createDatas.length; i++){
  2678. functions.push(parallelFucs.createFuc(createDatas[i]));
  2679. }
  2680. }
  2681. functions.push(parallelFucs.updateLastOpr());
  2682. async.parallel(functions, function(err, datas){
  2683. if(err){
  2684. callback(1, 'Error', null);
  2685. }else {
  2686. callback(0, '', datas);
  2687. }
  2688. });
  2689. };
  2690. billsLibDao.prototype.pasteValues = function(data, callback) {
  2691. let pasteDatas = data.pasteDatas;
  2692. let updateDatas = pasteDatas.updateDatas, createDatas = pasteDatas.createDatas;
  2693. let functions = [], lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2694. let parallelFucs = {
  2695. updateLastOpr: function () {
  2696. return function (cb) {
  2697. StdBillsLib.find({billsLibId: data.billsLibId}, function (err, result) {
  2698. if(err){
  2699. cb(err);
  2700. }
  2701. else{
  2702. if(result.length > 0 ){
  2703. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2704. StdBillsLib.update({billsLibId: data.billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2705. if(err){
  2706. cb(err);
  2707. }
  2708. else{
  2709. cb(null);
  2710. }
  2711. });
  2712. }
  2713. }
  2714. });
  2715. }
  2716. },
  2717. updateFuc: function(data){
  2718. let billsLibId = data.billsLibId, itemId = data.itemId, orgCode = data.orgId;
  2719. if (data.type === 'UpdateT') {
  2720. let valueObj = {code: data.code, value: data.content};
  2721. return function (cb){
  2722. ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$pull: {itemValue: {code: orgCode}}}, function (err) {
  2723. if (err) {
  2724. cb(err);
  2725. }
  2726. else {
  2727. ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  2728. if (err) {
  2729. cb(err);
  2730. }
  2731. else {
  2732. cb(null, data);
  2733. }
  2734. });
  2735. }
  2736. });
  2737. };
  2738. }
  2739. else if (data.type === 'Update' && data.field === 'code') {
  2740. return function (cb) {
  2741. ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode},
  2742. {$set: {'itemValue.$.code': data.data}}, function (err) {
  2743. if(err){
  2744. cb(err);
  2745. }
  2746. else {
  2747. cb(null, data);
  2748. }
  2749. });
  2750. }
  2751. }
  2752. else if(data.type === 'Update' && data.field === 'value') {
  2753. return function (cb){
  2754. ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode}, {$set: {'itemValue.$.value': data.data}}, function(err){
  2755. if(err){
  2756. cb(err);
  2757. }
  2758. else {
  2759. cb(null, data);
  2760. }
  2761. });
  2762. };
  2763. }
  2764. },
  2765. createFuc: function(data){
  2766. let valueObj;
  2767. if(data.type === 'CreateT'){
  2768. valueObj = {code: data.code, value: data.content};
  2769. return function (cb){
  2770. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  2771. if (err) {
  2772. cb(err);
  2773. }
  2774. else {
  2775. cb(null, data);
  2776. }
  2777. });
  2778. };
  2779. }
  2780. else if(data.type === 'Create' && data.field === 'code'){
  2781. valueObj = {code: data.data, value: ''};
  2782. return function (cb){
  2783. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  2784. if (err) {
  2785. cb(err);
  2786. }
  2787. else {
  2788. cb(null, data);
  2789. }
  2790. });
  2791. };
  2792. }
  2793. else {
  2794. valueObj = {code: data.code, value: data.data};
  2795. return function(cb){
  2796. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  2797. if (err) {
  2798. cb(err);
  2799. }
  2800. else {
  2801. cb(null, data);
  2802. }
  2803. });
  2804. };
  2805. }
  2806. }
  2807. };
  2808. if (updateDatas.length > 0) {
  2809. for (let i = 0; i < updateDatas.length; i++) {
  2810. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  2811. }
  2812. }
  2813. if(createDatas.length >0){
  2814. for(let i=0; i< createDatas.length; i++){
  2815. functions.push(parallelFucs.createFuc(createDatas[i]));
  2816. }
  2817. }
  2818. functions.push(parallelFucs.updateLastOpr());
  2819. async.parallel(functions, function(err, datas){
  2820. if(err){
  2821. callback(1, 'Error', null);
  2822. }
  2823. else {
  2824. callback(0, '', datas);
  2825. }
  2826. });
  2827. };
  2828. billsLibDao.prototype.edCreateItem = function(data, callback){
  2829. let billsLibId = data.billsLibId,
  2830. code = data.code,
  2831. billsId = data.billsId,
  2832. content = data.data,
  2833. serialNo = data.serialNo, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2834. async.waterfall([
  2835. function(cb){
  2836. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  2837. if(err){
  2838. cb(err, null);
  2839. }
  2840. else {
  2841. let newItemId = result.sequence_value;
  2842. cb(null, newItemId);
  2843. }
  2844. })
  2845. },
  2846. function(newItemId, cb){
  2847. async.parallel([
  2848. function(pcb){
  2849. ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  2850. if(err){
  2851. pcb(err, null);
  2852. }
  2853. else {
  2854. pcb(null, newItemId);
  2855. }
  2856. });
  2857. },
  2858. function(pcb){
  2859. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){
  2860. if(err){
  2861. pcb(err, null);
  2862. }
  2863. else {
  2864. pcb(null, newItemId);
  2865. }
  2866. });
  2867. },
  2868. function (pcb) {
  2869. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2870. if(err){
  2871. pcb(err);
  2872. }
  2873. else{
  2874. if(result.length > 0 ){
  2875. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2876. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2877. if(err){
  2878. pcb(err);
  2879. }
  2880. else{
  2881. pcb(null);
  2882. }
  2883. });
  2884. }
  2885. }
  2886. });
  2887. }
  2888. ], function(err, result){
  2889. if(err){
  2890. cb(err, null);
  2891. }
  2892. else {
  2893. cb(null, result[0]);
  2894. }
  2895. });
  2896. }
  2897. ], function(err, reslut){
  2898. if(err){
  2899. callback(1, "Error", null);
  2900. }
  2901. else {
  2902. callback(0, '', reslut);
  2903. }
  2904. });
  2905. };
  2906. billsLibDao.prototype.edUpdateItem = function(data, callback){
  2907. let billsLibId = data.billsLibId,
  2908. billsId = data.billsId,
  2909. content = data.content,
  2910. code = data.code,
  2911. orgItemId = data.orgItemId, lastOperator = data.lastOperator, lastOperateDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  2912. async.waterfall([
  2913. function(cb){
  2914. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  2915. if(err){
  2916. cb(err, null);
  2917. }
  2918. else {
  2919. let newItemId = result.sequence_value;
  2920. cb(null, newItemId);
  2921. }
  2922. })
  2923. },
  2924. function(newItemId, cb){
  2925. async.parallel([
  2926. function(pcb){
  2927. ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  2928. if(err){
  2929. pcb(err, null);
  2930. }
  2931. else {
  2932. pcb(null, newItemId);
  2933. }
  2934. });
  2935. },
  2936. function(pcb){
  2937. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  2938. if(err){
  2939. pcb(err, null);
  2940. }
  2941. else {
  2942. pcb(null, newItemId);
  2943. }
  2944. });
  2945. },
  2946. function (pcb) {
  2947. StdBillsLib.find({billsLibId: billsLibId}, function (err, result) {
  2948. if(err){
  2949. pcb(err);
  2950. }
  2951. else{
  2952. if(result.length > 0 ){
  2953. let newRecentOpr = getNewOprArr(result[0].recentOpr, lastOperator, lastOperateDate);
  2954. StdBillsLib.update({billsLibId: billsLibId}, {$set: {recentOpr: newRecentOpr}}, function(err){
  2955. if(err){
  2956. pcb(err);
  2957. }
  2958. else{
  2959. pcb(null);
  2960. }
  2961. });
  2962. }
  2963. }
  2964. });
  2965. }
  2966. ], function(err, result){
  2967. if(err){
  2968. cb(err, null);
  2969. }
  2970. else {
  2971. cb(null, result[0]);
  2972. }
  2973. });
  2974. }
  2975. ], function(err, reslut){
  2976. if(err){
  2977. callback(1, "Error", null);
  2978. }
  2979. else {
  2980. callback(0, '', reslut);
  2981. }
  2982. });
  2983. };
  2984. // 将标准清单的某些属性转换为项目清单的数据
  2985. billsLibDao.prototype.getDataToProjectBills = function (stdBills) {
  2986. // 处理工作内容和项目特征
  2987. const jobContent = stdBills.jobContent
  2988. .map(({ serialNo, content }) => ({ serialNo, content, isChecked: true }));
  2989. const itemCharacter = stdBills
  2990. .itemCharacter.map(({ serialNo, content }) => ({ serialNo, character: content, eigenvalue: [], isChecked: false }));
  2991. const itemCharacterText = "[项目特征]\n[工作内容]\n" + stdBills.jobContentText;
  2992. const jobContentText = '';
  2993. return {
  2994. jobContent,
  2995. itemCharacter,
  2996. itemCharacterText,
  2997. jobContentText,
  2998. programID: stdBills.engineering, // 取费专业
  2999. comments: stdBills.recharge, // 说明
  3000. name: stdBills.name,
  3001. unit: stdBills.unit,
  3002. ruleText: stdBills.ruleText,
  3003. };
  3004. }
  3005. billsLibDao.prototype.getStdBillsByCode = async function (data, callback) {
  3006. let findData = function (value, field, Array) {
  3007. let i = 0;
  3008. for (i = 0; i < Array.length; i++) {
  3009. if (value[field] === Array[i][field]) {
  3010. return Array[i];
  3011. }
  3012. }
  3013. return null;
  3014. };
  3015. let MergeData = function (arr) {
  3016. let result = "", count = 0;
  3017. for(let i = 0; i < arr.length; i++){
  3018. if(arr[i].isChecked === true){
  3019. count += 1;
  3020. if (count === 1) {
  3021. result += count + ". " + arr[i].content;
  3022. } else {
  3023. result += "\n" + count + ". " + arr[i].content;
  3024. }
  3025. }
  3026. }
  3027. return result;
  3028. }
  3029. try{
  3030. let bills = await Bills.findOne({billsLibId: data.billsLibId, code: data.code, deleted: false}, '-_id');
  3031. if(bills){
  3032. //设置清单备注(父项清单补注)
  3033. if(bills.ParentID != -1){
  3034. let parentBills = await Bills.findOne({billsLibId: data.billsLibId, ID: bills.ParentID, deleted: false});
  3035. if(parentBills && parentBills.recharge){
  3036. bills.recharge = parentBills.recharge;
  3037. }
  3038. }
  3039. //设置项目特征
  3040. let itemCharacters = await ItemCharacter.find({billsLibId: data.billsLibId, deleted: false}, '-_id');
  3041. bills._doc.itemCharacter = [];
  3042. bills.items = _.sortBy(bills.items,"serialNo");//排序
  3043. if(itemCharacters && bills.items){
  3044. for(let item of bills.items){
  3045. let itemData = findData(item, 'id', itemCharacters);
  3046. if(itemData){
  3047. itemData._doc.serialNo = item.serialNo;
  3048. bills._doc.itemCharacter.push(itemData);
  3049. }
  3050. }
  3051. }
  3052. bills._doc.itemCharacterText = MergeData(bills._doc.itemCharacter);
  3053. //设置工作内容
  3054. let jobContents = await JobContent.find({billsLibId: data.billsLibId, deleted: false}, '-_id');
  3055. bills._doc.jobContent = [];
  3056. bills.jobs = _.sortBy(bills.jobs,"serialNo");//排序
  3057. if(jobContents && bills.jobs){
  3058. for(let job of bills.jobs){
  3059. let jobData = findData(job, 'id', jobContents);
  3060. jobData.isChecked = true;
  3061. jobData._doc.serialNo = job.serialNo;
  3062. bills._doc.jobContent.push(jobData);
  3063. }
  3064. }
  3065. bills._doc.jobContentText = MergeData(bills._doc.jobContent);
  3066. }
  3067. if(callback){
  3068. callback(0, '', bills);
  3069. }else {
  3070. return bills;
  3071. }
  3072. }
  3073. catch(err){
  3074. callback(1, err, null);
  3075. return null;
  3076. }
  3077. };
  3078. billsLibDao.prototype.getStdBillsByCodet = function (data, callback) {
  3079. let findData = function (value, field, Array) {
  3080. let i = 0;
  3081. for (i = 0; i < Array.length; i++) {
  3082. if (value[field] === Array[i][field]) {
  3083. return Array[i];
  3084. }
  3085. }
  3086. return null;
  3087. };
  3088. let MergeData = function (arr) {
  3089. let result = "", count = 0;
  3090. for(let i = 0; i < arr.length; i++){
  3091. if(arr[i].isChecked === true){
  3092. count += 1;
  3093. if (count === 1) {
  3094. result += count + ". " + arr[i].content;
  3095. } else {
  3096. result += "\n" + count + ". " + arr[i].content;
  3097. }
  3098. }
  3099. }
  3100. return result;
  3101. }
  3102. async.waterfall([
  3103. function (callback) {
  3104. Bills.findOne({'billsLibId': data.billsLibId, 'code': data.code, 'deleted': false}, "-_id", function (err, result) {
  3105. callback(err, JSON.parse(JSON.stringify(result)));
  3106. });
  3107. },
  3108. function (bills, callback) {
  3109. if (bills) {
  3110. ItemCharacter.find({'billsLibId': data.billsLibId, 'deleted': false}, '-_id', function (err, result) {
  3111. if (err) {
  3112. callback(err, bills);
  3113. } else {
  3114. bills._doc.itemCharacter = [];
  3115. if (result && bills && bills.items) {
  3116. for (let item of bills.items) {
  3117. let itemData = findData(item, 'id', result);
  3118. if (itemData) {
  3119. bills._doc.itemCharacter.push(JSON.parse(JSON.stringify(itemData)));
  3120. }
  3121. }
  3122. }
  3123. bills._doc.itemCharacterText = MergeData(bills.itemCharacter);
  3124. callback(err, bills);
  3125. }
  3126. });
  3127. } else {
  3128. callback(null, bills);
  3129. }
  3130. },
  3131. function (bills, callback) {
  3132. if (bills) {
  3133. JobContent.find({'billsLibId': data.billsLibId, 'deleted': false}, '-_id', function (err, result) {
  3134. if (err) {
  3135. callback(err, bills);
  3136. } else {
  3137. bills.jobContent = [];
  3138. if (result && bills && bills.jobs) {
  3139. for (let job of bills.jobs) {
  3140. let jobData = findData(job, 'id', result);;
  3141. if (jobData) {
  3142. jobData = JSON.parse(JSON.stringify(jobData));
  3143. jobData.isChecked = true;
  3144. bills.jobContent.push(jobData);
  3145. }
  3146. }
  3147. }
  3148. bills.jobContentText = MergeData(bills.jobContent);
  3149. callback(err, bills);
  3150. }
  3151. });
  3152. } else {
  3153. callback(null, bills);
  3154. }
  3155. }
  3156. ], function (err, result) {
  3157. if (err) {
  3158. callback(1, err, null);
  3159. } else {
  3160. callback(0, err, result);
  3161. }
  3162. });
  3163. };
  3164. module.exports = new billsLibDao();