bills_lib_interfaces.js 112 KB

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