bills_lib_interfaces.js 64 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904
  1. /**
  2. * Created by vian on 2017/3/20.
  3. */
  4. let model = require("./bills_lib_model");
  5. let counter = require("../../../public/counter/counter");
  6. let async = require("async");
  7. let StdBillsLib = model.stdBillsLibMod;
  8. let Bills = model.billsMod;
  9. let JobContent = model.jobContentMod;
  10. let ItemCharacter = model.itemCharacterMod;
  11. let billsLibDao = function(){};
  12. billsLibDao.prototype.getMaxNumber = function(gData, callback){
  13. let billsLibId = gData.billsLibId;
  14. let field = gData.field;
  15. if(field === 'jobs'){
  16. JobContent.find({billsLibId: billsLibId, deleted: false}).sort({code: -1}).limit(1).exec(function(err, result){
  17. if(err){
  18. callback(1, 'Error', null);
  19. }
  20. else {
  21. callback(0, '', result);
  22. }
  23. });
  24. }
  25. else if(field === 'items'){
  26. ItemCharacter.find({billsLibId: billsLibId, deleted: false}).sort({code: -1}).limit(1).exec(function(err, result){
  27. if(err){
  28. callback(1, 'Error', null);
  29. }
  30. else {
  31. callback(0, '', result);
  32. }
  33. });
  34. }
  35. };
  36. //----------StdBillsLib-------------------
  37. billsLibDao.prototype.getABillsLib = function(data, callback){
  38. let billsLibId = data.billsLibId;
  39. StdBillsLib.find({billsLibId: billsLibId, deleted: false}, function(err, data){
  40. if(err){
  41. callback(1, 'Error', null);
  42. }
  43. else {
  44. callback(0, '', data);
  45. }
  46. });
  47. };
  48. billsLibDao.prototype.getStdBillsLib = function(data, callback){
  49. let userId = data.userId;
  50. StdBillsLib.find({userId: userId, deleted: false}, "-_id", function(err, data){
  51. if(err){
  52. callback(1, "Error", null);
  53. }
  54. else{
  55. callback(0, "", data);
  56. }
  57. })
  58. };
  59. billsLibDao.prototype.createStdBillsLib = function(clibData, callback){
  60. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib, 1, function(err, result){
  61. let billsLibId = result.value.sequence_value;
  62. let userId = clibData.userId;
  63. let billsLibName = clibData.name;
  64. let createDate = Date.now();
  65. let newStdBillsLib = {
  66. userId: userId,
  67. billsLibId: billsLibId,
  68. billsLibName: billsLibName,
  69. createDate: createDate,
  70. deleted: false
  71. };
  72. StdBillsLib.create(newStdBillsLib, function(err){
  73. if(err){
  74. callback(1, "Error", null);
  75. }
  76. else {
  77. StdBillsLib.find({billsLibId: billsLibId}, function(err, data){
  78. if(err){
  79. callback(1, "Error", null)
  80. }
  81. else {
  82. callback(0, "", data);
  83. }
  84. });
  85. }
  86. });
  87. });
  88. };
  89. billsLibDao.prototype.deleteStdBillsLib = function(billsLibId, callback){
  90. async.parallel([
  91. function(cb){
  92. StdBillsLib.update({billsLibId: billsLibId}, {$set: {deleted: true}}, function(err){
  93. if(err){
  94. cb(err);
  95. }
  96. else{
  97. cb(null);
  98. }
  99. });
  100. },
  101. function(cb){
  102. Bills.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){
  103. cb(null);
  104. });
  105. },
  106. function(cb){
  107. JobContent.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err, result){
  108. cb(null);
  109. });
  110. },
  111. function(cb){
  112. ItemCharacter.update({billsLibId: billsLibId, deleted: false}, {$set: {deleted: true}}, {upsert: false, multi: true}, function(err){
  113. cb(null);
  114. })
  115. }
  116. ], function(err){
  117. if(err){
  118. callback(1, 'Error');
  119. }
  120. else {
  121. callback(0, '');
  122. }
  123. });
  124. };
  125. billsLibDao.prototype.renameStdBillsLib = function(renameData, callback){
  126. let billsLibId = renameData.id;
  127. let renameVal = renameData.value;
  128. StdBillsLib.update({billsLibId: billsLibId}, {$set:{billsLibName: renameVal}}, function(err){
  129. if(err){
  130. callback(1, "Error");
  131. }
  132. else{
  133. callback(0, "");
  134. }
  135. });
  136. };
  137. billsLibDao.prototype.getStdBillsLibName = function(billsLibId, callback){
  138. StdBillsLib.find({billsLibId: billsLibId, deleted: false}, "-_id", function(err, data){
  139. if(err){
  140. callback(1, "Error", null);
  141. }
  142. else {
  143. callback(0, "", data);
  144. }
  145. });
  146. };
  147. billsLibDao.prototype.getCurrentUniqId = function(callback){
  148. counter.counterDAO.getCurrentID(counter.moduleName.billsLib, function(result, err){
  149. let id = result.sequence_value;
  150. if(err){
  151. callback(1, 'Error', null);
  152. }
  153. else{
  154. callback(0, '', id);
  155. }
  156. });
  157. }
  158. //----------------------------Bills---------------------
  159. billsLibDao.prototype.getBills = function (billsLibId, callback) {
  160. Bills.find({billsLibId: billsLibId, deleted: false}, "-_id", function(err, billsData){
  161. if(err){
  162. callback(1, "Error", null);
  163. }
  164. else{
  165. callback(0, "", billsData);
  166. }
  167. });
  168. }
  169. billsLibDao.prototype.createBills = function(cbillsData, callback){
  170. let newId = cbillsData.newId;
  171. let pid = cbillsData.ParentID;
  172. let nid = cbillsData.NextSiblingID;
  173. let billsLibId = cbillsData.billsLibId;
  174. let updatePreData = cbillsData.updatePreData;
  175. let newBills = {
  176. ID: newId,
  177. ParentID: pid,
  178. NextSiblingID: nid,
  179. billsLibId: billsLibId,
  180. code: '',
  181. name: '',
  182. unit: '',
  183. ruleText: '',
  184. Expression: '',
  185. recharge:'',
  186. deleted: false
  187. };
  188. async.parallel([
  189. function(cb){
  190. Bills.create(newBills, function(err){
  191. if(err){
  192. cb(err);
  193. }
  194. else {
  195. cb(null);
  196. }
  197. });
  198. },
  199. function(cb){
  200. if(updatePreData){
  201. Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updatePreData.ID, deleted: false}, {$set: {NextSiblingID: updatePreData.NextSiblingID}}, function(err, result){
  202. if(err){
  203. cb(err);
  204. }
  205. else {
  206. cb(null)
  207. }
  208. });
  209. }
  210. else {
  211. cb(null);
  212. }
  213. }
  214. ], function(err){
  215. if(err){
  216. callback(1, 'Error');
  217. }
  218. else {
  219. callback(0, '');
  220. }
  221. });
  222. };
  223. billsLibDao.prototype.upMove = function(data, callback){
  224. let billsLibId = data.billsLibId,
  225. updateDatas = data.updateDatas;
  226. async.each(updateDatas, function(updateData, cb){
  227. Bills.findOneAndUpdate({billsLibId: billsLibId, ID: updateData.ID, deleted: false}, {$set: {NextSiblingID: updateData.NextSiblingID}}, function(err){
  228. if(err){
  229. cb(err);
  230. }
  231. else {
  232. cb(null);
  233. }
  234. });
  235. }, function(err){
  236. if(err){
  237. callback(1, 'Error');
  238. }
  239. else{
  240. callback(0, '');
  241. }
  242. });
  243. };
  244. billsLibDao.prototype.downMove = function (data, callbck) {
  245. let billsLibId = data.billsLibId,
  246. updateDatas = data.updateDatas,
  247. functions = [];
  248. let parallelFucs = {
  249. nextSiblingNode: function (data) {
  250. return function (cb) {
  251. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  252. if(err){
  253. cb(err);
  254. }
  255. else{
  256. cb(null);
  257. }
  258. });
  259. };
  260. },
  261. oprNode: function (data) {
  262. return function (cb) {
  263. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  264. if(err){
  265. cb(err);
  266. }
  267. else {
  268. cb(null);
  269. }
  270. })
  271. }
  272. },
  273. preSiblingNode: function (data) {
  274. return function (cb) {
  275. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  276. if(err){
  277. cb(err);
  278. }
  279. else{
  280. cb(null);
  281. }
  282. });
  283. };
  284. }
  285. };
  286. for(let i =0; i< updateDatas.length; i++){
  287. if(updateDatas[i].type === 'nextSiblingNode'){
  288. functions.push(parallelFucs.nextSiblingNode(updateDatas[i]));
  289. }
  290. else if(updateDatas[i].type === 'oprNode'){
  291. functions.push(parallelFucs.oprNode(updateDatas[i]));
  292. }
  293. else {
  294. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  295. }
  296. }
  297. async.parallel(functions, function (err) {
  298. if(err){
  299. callbck(1, 'Error');
  300. }
  301. else{
  302. callbck(0, '');
  303. }
  304. })
  305. }
  306. billsLibDao.prototype.upLevel = function(data, callback){
  307. let billsLibId = data.billsLibId,
  308. updateDatas = data.updateDatas, functions = [];
  309. let parallelFucs = {
  310. oprNode: function (data) {
  311. return function (cb){
  312. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){
  313. if(err){
  314. console.log(`err1`);
  315. cb(err);
  316. }
  317. else {
  318. cb(null);
  319. }
  320. });
  321. };
  322. },
  323. parentNode: function (data) {
  324. return function(cb){
  325. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  326. if(err){
  327. console.log(`err2`);
  328. cb(err);
  329. }
  330. else {
  331. cb(null);
  332. }
  333. })
  334. };
  335. },
  336. nextSiblingNode: function (data) {
  337. return function (cb) {
  338. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID}}, function (err) {
  339. if(err){
  340. console.log(`err3`);
  341. cb(err);
  342. }
  343. else{
  344. cb(null);
  345. }
  346. });
  347. };
  348. },
  349. preSiblingNode: function(data){
  350. console.log(`billsLIbId: ${billsLibId} ID: ${data.ID} NextS: ${data.NextSiblingID}`);
  351. return function (cb) {
  352. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  353. if(err){
  354. console.log(`err4`);
  355. cb(err);
  356. }
  357. else {
  358. cb(null);
  359. }
  360. });
  361. };
  362. }
  363. }
  364. for(let i=0; i< updateDatas.length; i++){
  365. if(updateDatas[i].type === 'oprNode'){
  366. functions.push(parallelFucs.oprNode(updateDatas[i]));
  367. }
  368. else if(updateDatas[i].type === 'parentNode'){
  369. functions.push(parallelFucs.parentNode(updateDatas[i]));
  370. }
  371. else if(updateDatas[i].type === 'nextSiblingNode'){
  372. updateDatas[i].ID.forEach(function (id) {
  373. let obj = {ID: id, ParentID: updateDatas[i].ParentID};
  374. functions.push(parallelFucs.nextSiblingNode(obj));
  375. });
  376. }
  377. else {
  378. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  379. }
  380. }
  381. async.parallel(functions, function(err){
  382. if(err){
  383. console.log(`errfinal`);
  384. callback(1, 'Error');
  385. }
  386. else{
  387. callback(0, '');
  388. }
  389. });
  390. };
  391. billsLibDao.prototype.downLevel = function (data, callback) {
  392. let billsLibId = data.billsLibId,
  393. updateDatas = data.updateDatas,
  394. functions = [];
  395. let parallelFucs = {
  396. preSiblingNode: function (data) {
  397. return function (cb) {
  398. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  399. if(err){
  400. cb(err);
  401. }
  402. else {
  403. cb(null);
  404. }
  405. });
  406. };
  407. },
  408. oprNode: function (data) {
  409. return function (cb) {
  410. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function (err) {
  411. if(err){
  412. cb(err);
  413. }
  414. else{
  415. cb(null);
  416. }
  417. });
  418. };
  419. },
  420. preChildren: function (data) {
  421. return function (cb) {
  422. Bills.update({billsLibId: billsLibId, ID: data.ID, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function (err) {
  423. if(err){
  424. cb(err);
  425. }
  426. else{
  427. cb(null);
  428. }
  429. });
  430. };
  431. }
  432. }
  433. for(let i=0; i<updateDatas.length; i++){
  434. if(updateDatas[i].type === 'preSiblingNode'){
  435. functions.push(parallelFucs.preSiblingNode(updateDatas[i]));
  436. }
  437. else if(updateDatas[i].type === 'oprNode'){
  438. functions.push(parallelFucs.oprNode(updateDatas[i]));
  439. }
  440. else {
  441. functions.push(parallelFucs.preChildren(updateDatas[i]));
  442. }
  443. }
  444. async.parallel(functions, function (err) {
  445. if(err){
  446. callback(1, 'Error');
  447. }
  448. else{
  449. callback(0, '');
  450. }
  451. })
  452. };
  453. billsLibDao.prototype.updatePNId= function(upData, callback){
  454. let billsLibId = upData.billsLibId;
  455. let updateDatas = upData.updateData;
  456. let eachDatas = [];
  457. for(let i=0; i< updateDatas.length; i++){
  458. if(updateDatas[i].ID.length > 1){
  459. let ids = updateDatas[i].ID;
  460. for(let j=0; j<ids.length; j++){
  461. let eachObj = {
  462. id: ids[j],
  463. data: updateDatas[i]
  464. }
  465. eachDatas.push(eachObj);
  466. }
  467. }
  468. else {
  469. eachDatas.push({id: updateDatas[i].ID, data: updateDatas[i]});
  470. }
  471. }
  472. console.log(eachDatas.length);
  473. async.each(eachDatas, function(eachObj, cb){
  474. let id = eachObj.id, data = eachObj.data;
  475. console.log(id);
  476. console.log(data);
  477. if(data.ParentID && data.NextSiblingID){
  478. console.log(`enter 1 ${id}`);
  479. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID, NextSiblingID: data.NextSiblingID}}, function(err){
  480. if(err){
  481. cb(err);
  482. }else {
  483. cb(null);
  484. }
  485. });
  486. }
  487. else if(data.ParentID && !data.NextSiblingID){
  488. console.log(`enter 2 ${id}`);
  489. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {ParentID: data.ParentID}}, function(err){
  490. if(err){
  491. if(err){
  492. cb(err);
  493. }else {
  494. cb(null);
  495. }
  496. }
  497. });
  498. }
  499. else if(!data.ParentID && data.NextSiblingID){
  500. console.log(`enter 3 ${id}`);
  501. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {NextSiblingID: data.NextSiblingID}}, function(err){
  502. if(err){
  503. cb(err);
  504. }else {
  505. cb(null);
  506. }
  507. });
  508. }
  509. }, function(err){
  510. if(err){
  511. console.log(`err`);
  512. callback(1, 'Error');
  513. }
  514. else {
  515. console.log(`noerr`);
  516. callback(0, '');
  517. }
  518. });
  519. }
  520. billsLibDao.prototype.updateBills = function(ubillsData, callback){
  521. let billsLibId = ubillsData.billsLibId;
  522. let updateId = ubillsData.updateId;
  523. let updateField = ubillsData.field;
  524. let updateData = ubillsData.data;
  525. if(updateField === "code"){
  526. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {code: updateData}}, function(err){
  527. if(err){
  528. callback(1, "Error");
  529. }
  530. else {
  531. callback(0, "");
  532. }
  533. });
  534. }
  535. else if(updateField === "name"){
  536. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {name: updateData}}, function(err){
  537. if(err){
  538. callback(1, "Error");
  539. }
  540. else {
  541. callback(0, "");
  542. }
  543. });
  544. }
  545. else if(updateField === "unit"){
  546. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {unit: updateData}}, function(err){
  547. if(err){
  548. callback(1, "Error");
  549. }
  550. else {
  551. callback(0, "");
  552. }
  553. });
  554. }
  555. else if(updateField === "ruleText"){
  556. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {ruleText: updateData}}, function(err){
  557. if(err){
  558. callback(1, "Error");
  559. }
  560. else {
  561. callback(0, "");
  562. }
  563. });
  564. }
  565. else if(updateField === "jobs"){
  566. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$addToSet: {jobs: updateData}}, function(err){
  567. if(err){
  568. callback(1, "Error");
  569. }
  570. else {
  571. callback(0, "");
  572. }
  573. });
  574. }
  575. else if(updateField === "items"){
  576. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$addToSet: {items: updateData}}, function(err){
  577. if(err){
  578. callback(1, "Error");
  579. }
  580. else {
  581. callback(0, "");
  582. }
  583. });
  584. }
  585. }
  586. billsLibDao.prototype.updateBillsArr = function(updateData, callback){
  587. let billsLibId = updateData.billsLibId;
  588. let updateId = updateData.updateId;
  589. let orgId = updateData.orgId;
  590. let newId = updateData.newId;
  591. let classify = updateData.classify;
  592. let type = updateData.type;
  593. let success = true;
  594. if(classify === 'jobs'){
  595. if(orgId && newId && type === 'update'){
  596. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'jobs.id': orgId}, {$set: {'jobs.$.id': newId}}, function(err){
  597. if(err){
  598. callback(1, 'Error');
  599. }
  600. else {
  601. callback(0, '');
  602. }
  603. });
  604. }
  605. if(orgId && !newId && type === 'delete'){
  606. async.each(orgId, function(oid, cb){
  607. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {jobs: {id: oid}}}, function(err){
  608. if(err){
  609. cb(err);
  610. }else {
  611. cb(null);
  612. }
  613. });
  614. }, function(err){
  615. if(err){
  616. callback(1, 'Error');
  617. }
  618. });
  619. }
  620. if(orgId && !newId && type === 'deleteAll'){
  621. let delArr = [];
  622. updateId.forEach(function(uid){
  623. orgId.forEach(function(oid){
  624. delArr.push({updateId: uid, delId: oid});
  625. });
  626. });
  627. async.each(delArr, function(delObj, cb){
  628. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {jobs: {id: delObj.delId}}}, function(err){
  629. if(err){
  630. cb(err);
  631. }else {
  632. cb(null);
  633. }
  634. });
  635. }, function(err){
  636. if(err){
  637. callback(1, 'Error');
  638. }else {
  639. callback(0, '');
  640. }
  641. });
  642. }
  643. }
  644. else if(classify === 'items'){
  645. if(orgId && newId && type === 'update'){
  646. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false, 'items.id': orgId}, {$set: {'items.$.id': newId}}, function(err){
  647. if(err){
  648. callback(1, 'Error');
  649. }
  650. else {
  651. callback(0, '');
  652. }
  653. });
  654. }
  655. if(orgId && !newId && type === 'delete'){
  656. async.each(orgId, function(oid, cb){
  657. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$pull: {items: {id: oid}}}, function(err){
  658. if(err){
  659. cb(err);
  660. }else {
  661. cb(null);
  662. }
  663. });
  664. }, function(err){
  665. if(err){
  666. callback(1, 'Error');
  667. }else {
  668. callback(0, '');
  669. }
  670. });
  671. }
  672. if(orgId && !newId && type === 'deleteAll'){
  673. let delArr = [];
  674. updateId.forEach(function(uid){
  675. orgId.forEach(function(oid){
  676. delArr.push({updateId: uid, delId: oid});
  677. });
  678. });
  679. async.each(delArr, function(delObj, cb){
  680. Bills.update({billsLibId: billsLibId, ID: delObj.updateId, deleted: false}, {$pull: {items: {id: delObj.delId}}}, function(err){
  681. if(err){
  682. cb(err);
  683. }else {
  684. cb(null);
  685. }
  686. });
  687. }, function(err){
  688. if(err){
  689. callback(1, 'Error');
  690. }else {
  691. callback(0, '');
  692. }
  693. });
  694. }
  695. }
  696. };
  697. billsLibDao.prototype.pasteBills = function(pData, callback){
  698. let datas = pData.datas;
  699. async.each(datas, function(data, cb){
  700. Bills.update({billsLibId: data.billsLibId, ID: data.ID, deleted: false}, {$set: {code: data.code, name: data.name, unit: data.unit, ruleText: data.ruleText}}, function(err){
  701. if(err){
  702. cb(err);
  703. }else {
  704. cb(null);
  705. }
  706. });
  707. }, function(err){
  708. if(err){
  709. callback(1, 'Error');
  710. }else {
  711. callback(0, '');
  712. }
  713. });
  714. }
  715. billsLibDao.prototype.updateRecharge = function(uData, callback){
  716. let billsLibId = uData.billsLibId;
  717. let updateId = uData.updateId;
  718. let data = uData.data;
  719. Bills.update({billsLibId: billsLibId, ID: updateId, deleted: false}, {$set: {recharge: data}}, function(err){
  720. if(err){
  721. callback(1, 'Error');
  722. }
  723. else {
  724. callback(0, '');
  725. }
  726. });
  727. /* async.each(updateIds, function(id, cb){
  728. Bills.update({billsLibId: billsLibId, ID: id, deleted: false}, {$set: {recharge: data}}, function(err){
  729. if(err){
  730. cb(err);
  731. }else {
  732. cb(null);
  733. }
  734. });
  735. }, function(err){
  736. if(err){
  737. callback(1, 'Error');
  738. }else {
  739. callback(0, '');
  740. }
  741. });*/
  742. };
  743. billsLibDao.prototype.pasteRel = function (data, callback) {
  744. const UpdateExist = 'updateExist', UpdateNew = 'updateNew', CreateExist = 'createExist', CreateNew = 'createNew';
  745. const Jobs = 'jobs', Items = 'items';
  746. let field = data.field;
  747. let updateDatas = data.updateDatas;
  748. let createDatas = data.createDatas;
  749. let functions = [];
  750. let parallelFucs = {
  751. updateExJobs: function(data){
  752. let orgJobId = data.orgJobId, newJobId = data.newJobId,
  753. nodeId = data.nodeId, billsLibId = data.billsLibId;
  754. return function (cb){
  755. if(orgJobId && newJobId && nodeId && billsLibId){
  756. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  757. if(err){
  758. cb(err);
  759. }
  760. else{
  761. cb(null, data)
  762. }
  763. });
  764. }
  765. }
  766. },
  767. updateNeJobs: function(data){
  768. let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
  769. orgJobId = data.orgJobId, code = data.code;
  770. return function (cb){
  771. if(billsLibId && nodeId && newData && orgJobId && code){
  772. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  773. if(err){
  774. cb(err);
  775. }
  776. else {
  777. let newJobId = result.value.sequence_value;
  778. let newJobContent = {
  779. id: newJobId,
  780. billsLibId: billsLibId,
  781. code: code,
  782. content: newData,
  783. deleted: false
  784. };
  785. JobContent.create(newJobContent, function(err){
  786. if(err){
  787. cb(err);
  788. }
  789. else{
  790. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  791. if(err){
  792. cb(err);
  793. }
  794. else{
  795. data.newJobId = newJobId;
  796. cb(null, data);
  797. }
  798. });
  799. }
  800. });
  801. }
  802. });
  803. }
  804. }
  805. },
  806. createExJobs: function(data){
  807. let billsLibId = data.billsLibId, newData = data.newData,
  808. nodeId = data.nodeId, jobId = data.jobId, serialNo = data.serialNo;
  809. return function (cb){
  810. if(billsLibId && newData && nodeId && jobId){
  811. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: jobId, serialNo: serialNo}}}, function(err){
  812. if(err){
  813. cb(err);
  814. }
  815. else {
  816. cb(null, data);
  817. }
  818. });
  819. }
  820. }
  821. },
  822. createNeJobs: function(data){
  823. let billsLibId = data.billsLibId, newData = data.newData,
  824. code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
  825. return function (cb){
  826. if(billsLibId && newData && code){
  827. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  828. if(err){
  829. cb(err);
  830. }
  831. else {
  832. let newJobId = result.value.sequence_value;
  833. let newJobContent = {
  834. id: newJobId,
  835. billsLibId: billsLibId,
  836. code: code,
  837. content: newData,
  838. deleted: false
  839. };
  840. JobContent.create(newJobContent, function(err){
  841. if(err){
  842. cb(err);
  843. }
  844. else{
  845. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
  846. if(err){
  847. cb(err);
  848. }
  849. else {
  850. data.newJobId = newJobId;
  851. cb(null, data);
  852. }
  853. });
  854. }
  855. });
  856. }
  857. });
  858. }
  859. }
  860. },
  861. updateExItems: function(data){
  862. let orgItemId = data.orgItemId, newItemId = data.newItemId,
  863. nodeId = data.nodeId, billsLibId = data.billsLibId;
  864. return function (cb){
  865. if(orgItemId && newItemId && nodeId && billsLibId){
  866. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  867. if(err){
  868. cb(err);
  869. }
  870. else{
  871. cb(null, data);
  872. }
  873. });
  874. }
  875. }
  876. },
  877. updateNeItems: function(data){
  878. let billsLibId = data.billsLibId, nodeId = data.nodeId, newData = data.newData,
  879. orgItemId = data.orgItemId, code = data.code;
  880. return function (cb){
  881. if(billsLibId && nodeId && newData && orgItemId && code){
  882. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  883. if(err){
  884. cb(err);
  885. }
  886. else {
  887. let newItemId = result.value.sequence_value;
  888. let newItemContent = {
  889. id: newItemId,
  890. billsLibId: billsLibId,
  891. code: code,
  892. content: newData,
  893. deleted: false
  894. };
  895. ItemCharacter.create(newItemContent, function(err){
  896. if(err){
  897. cb(err);
  898. }
  899. else{
  900. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  901. if(err){
  902. cb(err);
  903. }
  904. else{
  905. data.newItemId = newItemId;
  906. cb(null, data);
  907. }
  908. });
  909. }
  910. });
  911. }
  912. });
  913. }
  914. }
  915. },
  916. createExItems: function(data){
  917. let billsLibId = data.billsLibId, newData = data.newData,
  918. nodeId = data.nodeId, itemId = data.itemId, serialNo = data.serialNo;
  919. return function (cb){
  920. if(billsLibId && newData && nodeId && itemId){
  921. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: itemId, serialNo: serialNo}}}, function(err){
  922. if(err){
  923. cb(err);
  924. }
  925. else {
  926. cb(null, data);
  927. }
  928. });
  929. }
  930. }
  931. },
  932. createNeItems: function(data){
  933. let billsLibId = data.billsLibId, newData = data.newData,
  934. code = data.code, nodeId = data.nodeId, serialNo = data.serialNo;
  935. return function (cb){
  936. if(billsLibId && newData && code){
  937. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  938. if(err){
  939. cb(err);
  940. }
  941. else {
  942. let newItemId = result.value.sequence_value;
  943. let newItemContent = {
  944. id: newItemId,
  945. billsLibId: billsLibId,
  946. code: code,
  947. content: newData,
  948. deleted: false
  949. };
  950. ItemCharacter.create(newItemContent, function(err){
  951. if(err){
  952. cb(err);
  953. }
  954. else{
  955. Bills.update({billsLibId: billsLibId, ID: nodeId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){
  956. if(err){
  957. cb(err);
  958. }
  959. else {
  960. data.newItemId = newItemId;
  961. cb(null, data);
  962. }
  963. });
  964. }
  965. });
  966. }
  967. });
  968. }
  969. }
  970. }
  971. };
  972. if(field === Jobs){
  973. if(updateDatas.length > 0){
  974. for(let i=0; i<updateDatas.length; i++){
  975. if(updateDatas[i].type === UpdateExist){
  976. functions.push(parallelFucs.updateExJobs(updateDatas[i]));
  977. }
  978. if(updateDatas[i].type === UpdateNew){
  979. functions.push(parallelFucs.updateNeJobs(updateDatas[i]));
  980. }
  981. }
  982. }
  983. if(createDatas.length > 0){
  984. for(let i=0; i<createDatas.length; i++){
  985. if(createDatas[i].type === CreateExist){
  986. functions.push(parallelFucs.createExJobs(createDatas[i]));
  987. }
  988. if(createDatas[i].type === CreateNew){
  989. functions.push(parallelFucs.createNeJobs(createDatas[i]));
  990. }
  991. }
  992. }
  993. }
  994. else {
  995. if(updateDatas.length > 0){
  996. for(let i=0; i<updateDatas.length; i++){
  997. if(updateDatas[i].type === UpdateExist){
  998. functions.push(parallelFucs.updateExItems(updateDatas[i]));
  999. }
  1000. if(updateDatas[i].type === UpdateNew){
  1001. functions.push(parallelFucs.updateNeItems(updateDatas[i]));
  1002. }
  1003. }
  1004. }
  1005. if(createDatas.length > 0){
  1006. for(let i=0; i<createDatas.length; i++){
  1007. if(createDatas[i].type === CreateExist){
  1008. functions.push(parallelFucs.createExItems(createDatas[i]));
  1009. }
  1010. if(createDatas[i].type === CreateNew){
  1011. functions.push(parallelFucs.createNeItems(createDatas[i]));
  1012. }
  1013. }
  1014. }
  1015. }
  1016. async.parallel(functions, function(err, datas){
  1017. if(err){
  1018. callback(1, 'Error', null);
  1019. }else {
  1020. callback(0, '', datas);
  1021. }
  1022. });
  1023. };
  1024. billsLibDao.prototype.deleteBills = function(delData, callback){
  1025. let deleteIds = delData.deleteIds;
  1026. let billsLibId = delData.billsLibId;
  1027. let updateNode = delData.updateNode;
  1028. if(deleteIds){
  1029. async.parallel([
  1030. function(cb){
  1031. async.each(deleteIds, function(delId, ecb){
  1032. Bills.update({billsLibId: billsLibId, ID: delId, deleted: false}, {$set: {deleted: true}}, function(err){
  1033. if(err){
  1034. ecb(err);
  1035. }
  1036. else {
  1037. ecb(null);
  1038. }
  1039. });
  1040. }, function(err){
  1041. if(err){
  1042. cb(err);
  1043. }
  1044. else {
  1045. cb(null);
  1046. }
  1047. });
  1048. },
  1049. function(cb){
  1050. if(updateNode){
  1051. Bills.update({billsLibId: billsLibId, ID: updateNode.ID, deleted: false}, {$set: {NextSiblingID: updateNode.NextSiblingID}}, function(err){
  1052. if(err){
  1053. cb(err);
  1054. }
  1055. else {
  1056. cb(null);
  1057. }
  1058. });
  1059. }else {
  1060. cb(null);
  1061. }
  1062. }
  1063. ], function(err){
  1064. if(err){
  1065. callback(1, 'Error');
  1066. }else {
  1067. callback(0, '');
  1068. }
  1069. });
  1070. }
  1071. }
  1072. //--------------JobContent------------------
  1073. billsLibDao.prototype.getJobContent = function(gJobData, callback){
  1074. let billsLibId = gJobData.billsLibId;
  1075. JobContent.find({billsLibId: billsLibId, deleted: false}, '-_id').sort({code: 1}).exec(function(err, result){
  1076. if(err){
  1077. callback(1, 'Error', null);
  1078. }
  1079. else {
  1080. callback(0, '', result);
  1081. }
  1082. });
  1083. }
  1084. billsLibDao.prototype.createJobContent = function(cJobData, callback){
  1085. let data = cJobData.data;
  1086. let billsLibId = cJobData.billsLibId;
  1087. let serialNo = cJobData.serialNo;
  1088. let newJobContent;
  1089. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1090. if(err){
  1091. callback(1, 'Error', null)
  1092. }
  1093. else {
  1094. let newJobId = result.value.sequence_value;
  1095. newJobContent = {
  1096. id: newJobId,
  1097. billsLibId: billsLibId,
  1098. code: serialNo,
  1099. content: data,
  1100. deleted: false
  1101. }
  1102. JobContent.create(newJobContent, function(err){
  1103. if(err){
  1104. callback(1, "Error", null);
  1105. }
  1106. else{
  1107. callback(0, "", newJobId);
  1108. }
  1109. });
  1110. }
  1111. });
  1112. };
  1113. billsLibDao.prototype.updateJobContent = function(uJobData, callback){
  1114. let billsLibId = uJobData.billsLibId;
  1115. let field = uJobData.field;
  1116. let updateData = uJobData.data;
  1117. let updateid = uJobData.updateId;
  1118. if(field == "code"){
  1119. JobContent.update({billsLibId: billsLibId, id: updateid}, {$set: {code: updateData}}, function(err){
  1120. if(err){
  1121. callback(1, "Error");
  1122. }
  1123. else{
  1124. callback(0, "");
  1125. }
  1126. });
  1127. }
  1128. else if(field == "content"){
  1129. JobContent.update({billsLibId: billsLibId, id: updateid}, {$set: {content: updateData}}, function(err){
  1130. if(err){
  1131. callback(1, "Error");
  1132. }
  1133. else{
  1134. callback(0, "");
  1135. }
  1136. });
  1137. }
  1138. };
  1139. billsLibDao.prototype.deleteJobContent = function(data, callback){
  1140. let delIds = data.ids;
  1141. let billsLibId = data.billsLibId;
  1142. if(delIds){
  1143. async.each(delIds, function(id, cb){
  1144. JobContent.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
  1145. if(err){
  1146. cb(err);
  1147. }
  1148. else {
  1149. cb(null);
  1150. }
  1151. });
  1152. }, function(err){
  1153. if(err){
  1154. callback(1, 'Error');
  1155. }else {
  1156. callback(0, '');
  1157. }
  1158. });
  1159. }
  1160. }
  1161. billsLibDao.prototype.pasteJobs = function (data, callback) {
  1162. let pasteDatas = data.pasteDatas;
  1163. let updateDatas = pasteDatas.updateDatas,
  1164. createDatas = pasteDatas.createDatas;
  1165. let functions = [];
  1166. let parallelFucs = {
  1167. updateFuc: function(data){
  1168. let updateId = data.orgId,
  1169. field = data.field,
  1170. updateData = data.data, billsLibId = data.billsLibId;
  1171. if(field === 'code'){
  1172. return function (cb){
  1173. JobContent.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){
  1174. if(err){
  1175. cb(err);
  1176. }else {
  1177. cb(null, data);
  1178. }
  1179. });
  1180. };
  1181. }else {
  1182. return function (cb){
  1183. JobContent.update({billsLibId: billsLibId, id: updateId}, {$set: {content: updateData}}, function(err){
  1184. if(err){
  1185. cb(err);
  1186. }else {
  1187. cb(null, data);
  1188. }
  1189. });
  1190. }
  1191. }
  1192. },
  1193. createFuc: function(data){
  1194. let billsLibId = data.billsLibId,
  1195. code;
  1196. let jobObj;
  1197. if(data.type === 'CreateT'){
  1198. jobObj = {
  1199. billsLibId: billsLibId,
  1200. code: data.code,
  1201. content: data.content,
  1202. deleted: false
  1203. }
  1204. }
  1205. else{
  1206. if(data.field === 'code'){
  1207. jobObj = {
  1208. billsLibId: billsLibId,
  1209. code: data.data,
  1210. content: '',
  1211. deleted: false
  1212. }
  1213. }
  1214. else {
  1215. jobObj = {
  1216. billsLibId: billsLibId,
  1217. code: data.code,
  1218. content: data.data,
  1219. deleted: false
  1220. }
  1221. }
  1222. }
  1223. return function (cb){
  1224. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1225. if(err){
  1226. cb(err);
  1227. }
  1228. else {
  1229. let newJobId = result.value.sequence_value;
  1230. jobObj.id = newJobId;
  1231. data.newJobId = newJobId
  1232. JobContent.create(jobObj, function(err){
  1233. if(err){
  1234. cb(err);
  1235. }else {
  1236. cb(null, data);
  1237. }
  1238. });
  1239. }
  1240. });
  1241. }
  1242. }
  1243. };
  1244. if(updateDatas.length > 0){
  1245. for(let i=0; i<updateDatas.length; i++){
  1246. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  1247. }
  1248. }
  1249. if(createDatas.length > 0){
  1250. for(let i =0; i<createDatas.length; i++){
  1251. functions.push(parallelFucs.createFuc(createDatas[i]));
  1252. }
  1253. }
  1254. async.parallel(functions, function(err, datas){
  1255. if(err){
  1256. callback(1, 'Error', null);
  1257. }else {
  1258. callback(0, '', datas);
  1259. }
  1260. });
  1261. };
  1262. billsLibDao.prototype.edCreateJob = function(data, callback){
  1263. let billsLibId = data.billsLibId,
  1264. code = data.code,
  1265. billsId = data.billsId,
  1266. content = data.data,
  1267. serialNo = data.serialNo;
  1268. async.waterfall([
  1269. function(cb){
  1270. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1271. if(err){
  1272. cb(err, null);
  1273. }
  1274. else {
  1275. let newJobId = result.value.sequence_value;
  1276. cb(null, newJobId);
  1277. }
  1278. })
  1279. },
  1280. function(newJobId, cb){
  1281. async.parallel([
  1282. function(pcb){
  1283. JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  1284. if(err){
  1285. pcb(err, null);
  1286. }
  1287. else {
  1288. pcb(null, newJobId);
  1289. }
  1290. });
  1291. },
  1292. function(pcb){
  1293. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {jobs: {id: newJobId, serialNo: serialNo}}}, function(err){
  1294. if(err){
  1295. pcb(err, null);
  1296. }
  1297. else {
  1298. pcb(null, newJobId);
  1299. }
  1300. });
  1301. }
  1302. ], function(err, result){
  1303. if(err){
  1304. cb(err, null);
  1305. }
  1306. else {
  1307. cb(null, result[0]);
  1308. }
  1309. });
  1310. }
  1311. ], function(err, reslut){
  1312. if(err){
  1313. callback(1, "Error", null);
  1314. }
  1315. else {
  1316. callback(0, '', reslut);
  1317. }
  1318. });
  1319. };
  1320. billsLibDao.prototype.edUpdateJob = function(data, callback){
  1321. let billsLibId = data.billsLibId,
  1322. billsId = data.billsId,
  1323. content = data.content,
  1324. code = data.code,
  1325. orgJobId = data.orgJobId;
  1326. async.waterfall([
  1327. function(cb){
  1328. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_jobs, 1, function(err, result){
  1329. if(err){
  1330. cb(err, null);
  1331. }
  1332. else {
  1333. let newJobId = result.value.sequence_value;
  1334. cb(null, newJobId);
  1335. }
  1336. })
  1337. },
  1338. function(newJobId, cb){
  1339. async.parallel([
  1340. function(pcb){
  1341. JobContent.create({id: newJobId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  1342. if(err){
  1343. pcb(err, null);
  1344. }
  1345. else {
  1346. pcb(null, newJobId);
  1347. }
  1348. });
  1349. },
  1350. function(pcb){
  1351. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'jobs.id': orgJobId}, {$set: {'jobs.$.id': newJobId}}, function(err){
  1352. if(err){
  1353. pcb(err, null);
  1354. }
  1355. else {
  1356. pcb(null, newJobId);
  1357. }
  1358. });
  1359. }
  1360. ], function(err, result){
  1361. if(err){
  1362. cb(err, null);
  1363. }
  1364. else {
  1365. cb(null, result[0]);
  1366. }
  1367. });
  1368. }
  1369. ], function(err, reslut){
  1370. if(err){
  1371. callback(1, "Error", null);
  1372. }
  1373. else {
  1374. callback(0, '', reslut);
  1375. }
  1376. });
  1377. };
  1378. //----------------------ItemCharacter---------------------
  1379. billsLibDao.prototype.getItemCharacter = function(gdata, callback){
  1380. let billsLibId = gdata.billsLibId;
  1381. ItemCharacter.find({billsLibId: billsLibId, deleted: false}, '-_id').sort({code: 1}).exec(function(err, result){
  1382. if(err){
  1383. callback(1, 'Error', null);
  1384. }
  1385. else {
  1386. callback(0, '', result);
  1387. }
  1388. });
  1389. }
  1390. billsLibDao.prototype.createItemCharacter = function(cItemData, callback){
  1391. let data = cItemData.data;
  1392. let billsLibId = cItemData.billsLibId;
  1393. let serialNo = cItemData.serialNo;
  1394. let newItemCharacter;
  1395. let id = cItemData.id;
  1396. newItemCharacter = {
  1397. id: id,
  1398. billsLibId: billsLibId,
  1399. content: data,
  1400. code: serialNo,
  1401. deleted: false
  1402. }
  1403. ItemCharacter.create(newItemCharacter, function(err){
  1404. if(err){
  1405. callback(1, "Error", null);
  1406. }
  1407. else{
  1408. callback(0, "", id);
  1409. }
  1410. });
  1411. };
  1412. billsLibDao.prototype.updateItemCharacter = function(uItemData, callback){
  1413. let field = uItemData.field;
  1414. let updateData = uItemData.data;
  1415. let id = uItemData.updateId;
  1416. let billsLibId = uItemData.billsLibId;
  1417. if(field === "code"){
  1418. ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {code: updateData}}, function(err){
  1419. if(err){
  1420. callback(1, "Error");
  1421. }
  1422. else{
  1423. callback(0, "");
  1424. }
  1425. });
  1426. }
  1427. else if(field === "content"){
  1428. ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {content: updateData}}, function(err){
  1429. if(err){
  1430. callback(1, "Error");
  1431. }
  1432. else{
  1433. callback(0, "");
  1434. }
  1435. });
  1436. }
  1437. };
  1438. billsLibDao.prototype.updateValue = function(uData, callback){
  1439. let type = uData.type;
  1440. let updateId = uData.updateId;
  1441. let data = uData.data;
  1442. let deleteCodes = uData.deleteCodes;
  1443. let billsLibId = uData.billsLibId;
  1444. if(type === 'create'){
  1445. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$addToSet: {itemValue: data}}, function(err){
  1446. if(err){
  1447. callback(1, 'Error');
  1448. }
  1449. else{
  1450. callback(0, '');
  1451. }
  1452. });
  1453. }
  1454. else if(type === 'update'){
  1455. if(data.field === 'code'){
  1456. ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.code': data.newData}}, function(err){
  1457. if(err){
  1458. callback(1, 'Error');
  1459. }
  1460. else{
  1461. callback(0, '');
  1462. }
  1463. });
  1464. }
  1465. else {
  1466. ItemCharacter.update({billsLibId: billsLibId, id: updateId, 'itemValue.code': data.code}, {$set: {'itemValue.$.value': data.newData}}, function(err,result){
  1467. if(err){
  1468. callback(1, 'Error');
  1469. }
  1470. else{
  1471. console.log(`suc`);
  1472. console.log(result);
  1473. callback(0, '');
  1474. }
  1475. });
  1476. }
  1477. }
  1478. //delete
  1479. else {
  1480. if(deleteCodes.length > 0){
  1481. async.each(deleteCodes, function(code, cb){
  1482. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$pull: {itemValue: {code: code}}}, function(err){
  1483. if(err){
  1484. cb(err);
  1485. }else {
  1486. cb(null);
  1487. }
  1488. });
  1489. }, function(err){
  1490. if(err){
  1491. callback(1, 'Error');
  1492. }else {
  1493. callback(0, '');
  1494. }
  1495. });
  1496. }
  1497. }
  1498. };
  1499. billsLibDao.prototype.deleteItemCharacter = function(data, callback){
  1500. let delIds = data.ids;
  1501. let billsLibId = data.billsLibId;
  1502. if(delIds){
  1503. async.each(delIds, function(id, cb){
  1504. ItemCharacter.update({billsLibId: billsLibId, id: id}, {$set: {deleted: true}}, function(err){
  1505. if(err){
  1506. cb(err);
  1507. }else {
  1508. cb(null);
  1509. }
  1510. }, function(err){
  1511. if(err){
  1512. callback(1, 'Error');
  1513. }else {
  1514. callback(0, '');
  1515. }
  1516. });
  1517. });
  1518. }
  1519. };
  1520. billsLibDao.prototype.pasteItems = function (data, callback) {
  1521. let pasteDatas = data.pasteDatas;
  1522. let updateDatas = pasteDatas.updateDatas,
  1523. createDatas = pasteDatas.createDatas;
  1524. let functions = [];
  1525. let parallelFucs = {
  1526. updateFuc: function(data){
  1527. let updateId = data.orgId,
  1528. field = data.field,
  1529. updateData = data.data, billsLibId = data.billsLibId;
  1530. if(field === 'code'){
  1531. return function (cb){
  1532. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {code: updateData}}, function(err){
  1533. if(err){
  1534. cb(err);
  1535. }else {
  1536. cb(null, data);
  1537. }
  1538. });
  1539. };
  1540. }
  1541. else{
  1542. return function(cb){
  1543. ItemCharacter.update({billsLibId: billsLibId, id: updateId}, {$set: {content: updateData}}, function(err){
  1544. if(err){
  1545. cb(err);
  1546. }else {
  1547. cb(null, data);
  1548. }
  1549. });
  1550. }
  1551. }
  1552. },
  1553. createFuc: function(data){
  1554. let billsLibId = data.billsLibId,
  1555. code;
  1556. let itemObj;
  1557. if(data.type === 'CreateT'){
  1558. itemObj = {
  1559. billsLibId: billsLibId,
  1560. code: data.code,
  1561. content: data.content,
  1562. deleted: false
  1563. }
  1564. }
  1565. else{
  1566. if(data.field === 'code'){
  1567. itemObj = {
  1568. billsLibId: billsLibId,
  1569. code: data.data,
  1570. content: '',
  1571. deleted: false
  1572. }
  1573. }
  1574. else {
  1575. itemObj = {
  1576. billsLibId: billsLibId,
  1577. code: data.code,
  1578. content: data.data,
  1579. deleted: false
  1580. }
  1581. }
  1582. }
  1583. return function (cb){
  1584. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  1585. if(err){
  1586. cb(err);
  1587. }
  1588. else{
  1589. let newItemId = result.value.sequence_value;
  1590. itemObj.id = newItemId;
  1591. data.newItemId = newItemId;
  1592. ItemCharacter.create(itemObj, function(err){
  1593. if(err){
  1594. cb(err);
  1595. }else {
  1596. cb(null, data);
  1597. }
  1598. });
  1599. }
  1600. });
  1601. }
  1602. }
  1603. };
  1604. if(updateDatas.length > 0){
  1605. for(let i=0; i<updateDatas.length; i++){
  1606. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  1607. }
  1608. }
  1609. if(createDatas.length > 0){
  1610. for(let i =0; i<createDatas.length; i++){
  1611. functions.push(parallelFucs.createFuc(createDatas[i]));
  1612. }
  1613. }
  1614. async.parallel(functions, function(err, datas){
  1615. if(err){
  1616. callback(1, 'Error', null);
  1617. }else {
  1618. callback(0, '', datas);
  1619. }
  1620. });
  1621. };
  1622. billsLibDao.prototype.pasteValues = function(data, callback) {
  1623. let pasteDatas = data.pasteDatas;
  1624. let updateDatas = pasteDatas.updateDatas, createDatas = pasteDatas.createDatas;
  1625. let functions = [];
  1626. let parallelFucs = {
  1627. updateFuc: function(data){
  1628. let billsLibId = data.billsLibId, itemId = data.itemId, orgCode = data.orgId;
  1629. if (data.type === 'UpdateT') {
  1630. let valueObj = {code: data.code, value: data.content};
  1631. return function (cb){
  1632. ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$pull: {itemValue: {code: orgCode}}}, function (err) {
  1633. if (err) {
  1634. cb(err);
  1635. }
  1636. else {
  1637. ItemCharacter.update({billsLibId: billsLibId, id: itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  1638. if (err) {
  1639. cb(err);
  1640. }
  1641. else {
  1642. cb(null, data);
  1643. }
  1644. });
  1645. }
  1646. });
  1647. };
  1648. }
  1649. else if (data.type === 'Update' && data.field === 'code') {
  1650. return function (cb) {
  1651. ItemCharacter.update({billsLibId: billsLibId, id: itemId, 'itemValue.code': orgCode},
  1652. {$set: {'itemValue.$.code': data.data}}, function (err) {
  1653. if(err){
  1654. cb(err);
  1655. }
  1656. else {
  1657. cb(null, data);
  1658. }
  1659. });
  1660. }
  1661. }
  1662. else {
  1663. return function (cb){
  1664. ItemCharacter.update({billsLIbId: billsLibId, id: itemId, 'itemValue.code': orgCode}, {$set: {'itemValue.$.value': data.data}}, function(err){
  1665. if(err){
  1666. cb(err);
  1667. }
  1668. else {
  1669. cb(null, data);
  1670. }
  1671. });
  1672. };
  1673. }
  1674. },
  1675. createFuc: function(data){
  1676. let valueObj;
  1677. if(data.type === 'CreateT'){
  1678. valueObj = {code: data.code, value: data.content};
  1679. return function (cb){
  1680. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  1681. if (err) {
  1682. cb(err);
  1683. }
  1684. else {
  1685. cb(null, data);
  1686. }
  1687. });
  1688. };
  1689. }
  1690. else if(data.type === 'Create' && data.field === 'code'){
  1691. valueObj = {code: data.data, value: ''};
  1692. return function (cb){
  1693. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  1694. if (err) {
  1695. cb(err);
  1696. }
  1697. else {
  1698. cb(null, data);
  1699. }
  1700. });
  1701. };
  1702. }
  1703. else {
  1704. valueObj = {code: data.code, value: data.data};
  1705. return function(cb){
  1706. ItemCharacter.update({billsLibId: data.billsLibId, id: data.itemId}, {$addToSet: {itemValue: valueObj}}, function (err) {
  1707. if (err) {
  1708. cb(err);
  1709. }
  1710. else {
  1711. cb(null, data);
  1712. }
  1713. });
  1714. };
  1715. }
  1716. }
  1717. };
  1718. if (updateDatas.length > 0) {
  1719. for (let i = 0; i < updateDatas.length; i++) {
  1720. functions.push(parallelFucs.updateFuc(updateDatas[i]));
  1721. }
  1722. }
  1723. if(createDatas.length >0){
  1724. for(let i=0; i< createDatas.length; i++){
  1725. functions.push(parallelFucs.createFuc(createDatas[i]));
  1726. }
  1727. }
  1728. async.parallel(functions, function(err, datas){
  1729. if(err){
  1730. callback(1, 'Error', null);
  1731. }
  1732. else {
  1733. callback(0, '', datas);
  1734. }
  1735. });
  1736. };
  1737. billsLibDao.prototype.edCreateItem = function(data, callback){
  1738. let billsLibId = data.billsLibId,
  1739. code = data.code,
  1740. billsId = data.billsId,
  1741. content = data.data,
  1742. serialNo = data.serialNo;
  1743. async.waterfall([
  1744. function(cb){
  1745. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  1746. if(err){
  1747. cb(err, null);
  1748. }
  1749. else {
  1750. let newItemId = result.value.sequence_value;
  1751. cb(null, newItemId);
  1752. }
  1753. })
  1754. },
  1755. function(newItemId, cb){
  1756. async.parallel([
  1757. function(pcb){
  1758. ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  1759. if(err){
  1760. pcb(err, null);
  1761. }
  1762. else {
  1763. pcb(null, newItemId);
  1764. }
  1765. });
  1766. },
  1767. function(pcb){
  1768. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false}, {$addToSet: {items: {id: newItemId, serialNo: serialNo}}}, function(err){
  1769. if(err){
  1770. pcb(err, null);
  1771. }
  1772. else {
  1773. pcb(null, newItemId);
  1774. }
  1775. });
  1776. }
  1777. ], function(err, result){
  1778. if(err){
  1779. cb(err, null);
  1780. }
  1781. else {
  1782. cb(null, result[0]);
  1783. }
  1784. });
  1785. }
  1786. ], function(err, reslut){
  1787. if(err){
  1788. callback(1, "Error", null);
  1789. }
  1790. else {
  1791. callback(0, '', reslut);
  1792. }
  1793. });
  1794. };
  1795. billsLibDao.prototype.edUpdateItem = function(data, callback){
  1796. let billsLibId = data.billsLibId,
  1797. billsId = data.billsId,
  1798. content = data.content,
  1799. code = data.code,
  1800. orgItemId = data.orgItemId;
  1801. async.waterfall([
  1802. function(cb){
  1803. counter.counterDAO.getIDAfterCount(counter.moduleName.billsLib_items, 1, function(err, result){
  1804. if(err){
  1805. cb(err, null);
  1806. }
  1807. else {
  1808. let newItemId = result.value.sequence_value;
  1809. cb(null, newItemId);
  1810. }
  1811. })
  1812. },
  1813. function(newItemId, cb){
  1814. async.parallel([
  1815. function(pcb){
  1816. ItemCharacter.create({id: newItemId, billsLibId: billsLibId, code: code, content: content, deleted: false}, function(err){
  1817. if(err){
  1818. pcb(err, null);
  1819. }
  1820. else {
  1821. pcb(null, newItemId);
  1822. }
  1823. });
  1824. },
  1825. function(pcb){
  1826. Bills.update({billsLibId: billsLibId, ID: billsId, deleted: false, 'items.id': orgItemId}, {$set: {'items.$.id': newItemId}}, function(err){
  1827. if(err){
  1828. pcb(err, null);
  1829. }
  1830. else {
  1831. pcb(null, newItemId);
  1832. }
  1833. });
  1834. }
  1835. ], function(err, result){
  1836. if(err){
  1837. cb(err, null);
  1838. }
  1839. else {
  1840. cb(null, result[0]);
  1841. }
  1842. });
  1843. }
  1844. ], function(err, reslut){
  1845. if(err){
  1846. callback(1, "Error", null);
  1847. }
  1848. else {
  1849. callback(0, '', reslut);
  1850. }
  1851. });
  1852. };
  1853. //
  1854. module.exports = new billsLibDao();