billsLibInterfaces.js 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539
  1. /**
  2. * Created by vian on 2017/3/20.
  3. */
  4. var model = require("./billsLibModel");
  5. var counter = require("../../../public/counter/counter");
  6. var StdBillsLib = model.stdBillsLibMod;
  7. var Bills = model.billsMod;
  8. var JobContent = model.jobContentMod;
  9. var ItemCharacter = model.itemCharacterMod;
  10. var fieldArr = ["code", "name", "unit", "ruleText", "Expression"];
  11. var billsLibDao = function(){};
  12. billsLibDao.prototype.getMaxNumber = function(gData, callback){
  13. var billsLibId = gData.billsLibId;
  14. var field = gData.field;
  15. if(field === 'jobs'){
  16. JobContent.find().sort({code: -1}).limit(1).exec(function(err, result){
  17. if(err){
  18. callback(1, 'Error', null);
  19. }
  20. else {
  21. callback(0, '', result.code);
  22. }
  23. });
  24. }
  25. else if(field === 'items'){
  26. ItemCharacter.find().sort({code: -1}).limit(1).exec(function(err, result){
  27. if(err){
  28. callback(1, 'Error', null);
  29. }
  30. else {
  31. callback(0, '', result.code);
  32. }
  33. });
  34. }
  35. };
  36. //----------StdBillsLib-------------------
  37. billsLibDao.prototype.getStdBillsLib = function(userId, callback){
  38. StdBillsLib.find({}, "-_id", function(err, data){
  39. if(err){
  40. callback(1, "Error", null);
  41. }
  42. else{
  43. callback(0, "", data);
  44. }
  45. })
  46. }
  47. billsLibDao.prototype.createStdBillsLib = function(clibData, callback){
  48. counter.counterDAO.getIDAfterCount(counter.moduleName.bills, 1, function(err, result){
  49. var billsLibId = result.value.sequence_value;
  50. var billsLibName = clibData.name;
  51. var createDate = Date.now();
  52. var newStdBillsLib = {
  53. billsLibId: billsLibId,
  54. billsLibName: billsLibName,
  55. createDate: createDate
  56. }
  57. StdBillsLib.create(newStdBillsLib, function(err){
  58. if(err){
  59. callback(1, "Error", null);
  60. }
  61. else {
  62. StdBillsLib.find({billsLibId: billsLibId}, function(err, data){
  63. if(err){
  64. callback(1, "Error", null)
  65. }
  66. else {
  67. callback(0, "", data);
  68. }
  69. });
  70. }
  71. });
  72. });
  73. }
  74. billsLibDao.prototype.deleteStdBillsLib = function(billsLibId, callback){
  75. StdBillsLib.remove({billsLibId: billsLibId}, function(err){
  76. if(err){
  77. callback(1, "Error");
  78. }
  79. else{
  80. callback(0, "");
  81. }
  82. });
  83. }
  84. billsLibDao.prototype.renameStdBillsLib = function(renameData, callback){
  85. var billsLibId = renameData.id;
  86. var renameVal = renameData.value;
  87. StdBillsLib.update({billsLibId: billsLibId}, {$set:{billsLibName: renameVal}}, function(err){
  88. if(err){
  89. callback(1, "Error");
  90. }
  91. else{
  92. callback(0, "");
  93. }
  94. });
  95. }
  96. billsLibDao.prototype.getStdBillsLibName = function(billsLibId, callback){
  97. StdBillsLib.find({billsLibId: billsLibId}, "-_id", function(err, data){
  98. if(err){
  99. callback(1, "Error", null);
  100. }
  101. else {
  102. callback(0, "", data);
  103. }
  104. });
  105. }
  106. //----------------------------Bills---------------------
  107. billsLibDao.prototype.getBills = function (billsLibId, callback) {
  108. Bills.find({billsLibId: billsLibId}, "-_id", function(err, billsData){
  109. if(err){
  110. callback(1, "Error", null);
  111. }
  112. else{
  113. callback(0, "", billsData);
  114. }
  115. });
  116. }
  117. billsLibDao.prototype.createBills = function(cbillsData, callback){
  118. var newId = cbillsData.newId;
  119. var pid = cbillsData.ParentID;
  120. var nid = cbillsData.NextSiblingID;
  121. var billsLibId = cbillsData.billsLibId;
  122. var newBills = {
  123. ID: newId,
  124. ParentID: pid,
  125. NextSiblingID: nid,
  126. billsLibId: billsLibId,
  127. code: '',
  128. name: '',
  129. unit: '',
  130. ruleText: '',
  131. Expression: '',
  132. recharge:'',
  133. };
  134. Bills.create(newBills, function(err){
  135. if(err){
  136. callback(1, "Error");
  137. }
  138. else{
  139. callback(0, "");
  140. }
  141. });
  142. }
  143. billsLibDao.prototype.updatePNId= function(updateData, callback){
  144. var billsLibId = updateData.billsLibId;
  145. var updateId = updateData.updateId;
  146. var updatepid= updateData.ParentID;
  147. var updatenid = updateData.NextSiblingID;
  148. var success = true;
  149. if(!updatepid){
  150. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {NextSiblingID: updatenid}}, function(err){
  151. if(err){
  152. callback(1, "Error")
  153. }
  154. else{
  155. callback(0, "");
  156. }
  157. });
  158. }
  159. else if(!updatenid){
  160. updateId.forEach(function(uid){
  161. Bills.update({billsLibId: billsLibId, ID: uid}, {$set: {ParentID: updatepid}}, function(err){
  162. if(err){
  163. success = false;
  164. }
  165. });
  166. });
  167. if(!success){
  168. callback(1, 'Error');
  169. }
  170. else {
  171. callback(0, '');
  172. }
  173. }
  174. else {
  175. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {ParentID: updatepid, NextSiblingID: updatenid}}, function(err){
  176. if(err){
  177. callback(1, "Error")
  178. }
  179. else{
  180. callback(0, "");
  181. }
  182. });
  183. }
  184. }
  185. billsLibDao.prototype.updateBills = function(ubillsData, callback){
  186. var billsLibId = ubillsData.billsLibId;
  187. var updateId = ubillsData.updateId;
  188. var updateField = ubillsData.field;
  189. var updateData = ubillsData.data;
  190. if(updateField === "code"){
  191. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {code: updateData}}, function(err){
  192. if(err){
  193. callback(1, "Error");
  194. }
  195. else {
  196. callback(0, "");
  197. }
  198. });
  199. }
  200. else if(updateField === "name"){
  201. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {name: updateData}}, function(err){
  202. if(err){
  203. callback(1, "Error");
  204. }
  205. else {
  206. callback(0, "");
  207. }
  208. });
  209. }
  210. else if(updateField === "unit"){
  211. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {unit: updateData}}, function(err){
  212. if(err){
  213. callback(1, "Error");
  214. }
  215. else {
  216. callback(0, "");
  217. }
  218. });
  219. }
  220. else if(updateField === "ruleText"){
  221. Bills.update({billsLibId: billsLibId, ID: updateId}, {$set: {ruleText: updateData}}, function(err){
  222. if(err){
  223. callback(1, "Error");
  224. }
  225. else {
  226. callback(0, "");
  227. }
  228. });
  229. }
  230. else if(updateField === "jobs"){
  231. Bills.update({billsLibId: billsLibId, ID: updateId}, {$addToSet: {jobs: updateData}}, function(err){
  232. if(err){
  233. callback(1, "Error");
  234. }
  235. else {
  236. callback(0, "");
  237. }
  238. });
  239. }
  240. else if(updateField === "items"){
  241. Bills.update({billsLibId: billsLibId, ID: updateId}, {$addToSet: {items: updateData}}, function(err){
  242. if(err){
  243. callback(1, "Error");
  244. }
  245. else {
  246. callback(0, "");
  247. }
  248. });
  249. }
  250. }
  251. billsLibDao.prototype.updateBillsArr = function(updateData, callback){
  252. var billsLibId = updateData.billsLibId;
  253. var updateId = updateData.updateId;
  254. var id = updateData.id;
  255. var data = updateData.data;
  256. var classify = updateData.classify;
  257. var success = true;
  258. if(classify === 'jobs'){
  259. if(data.id){
  260. Bills.update({billsLibId: billsLibId, ID: updateId, 'jobs.id': id}, {$set: {'jobs.$.id': data.id}}, function(err){
  261. if(err){
  262. success = false;
  263. }
  264. });
  265. }
  266. else if(data.code){
  267. Bills.update({billsLibId: billsLibId, ID: updateId, 'jobs.id': id}, {$set: {'jobs.$.code': data.code}}, function(err){
  268. if(err){
  269. success = false;
  270. }
  271. });
  272. }
  273. else {
  274. Bills.update({billsLibId: billsLibId, ID: updateId, 'jobs.id': id}, {$set: {'jobs.$.content': data.content}}, function(err){
  275. if(err){
  276. success =false
  277. }
  278. });
  279. }
  280. /* if(!success){
  281. callback(1, 'Error');
  282. }
  283. else {
  284. callback(0, '');
  285. }*/
  286. }
  287. else if(classify === 'items') {
  288. if(field === 'code'){
  289. updateIds.forEach(function(updateId){
  290. Bills.update({billsLibId: billsLibId, ID: updateId, 'items.id': id}, {$set: {'items.$.code': data}}, function(err){
  291. if(err){
  292. success = false;
  293. }
  294. });
  295. });
  296. if(!success){
  297. callback(1, 'Error');
  298. }
  299. else {
  300. callback(0, '');
  301. }
  302. }
  303. else {
  304. updateIds.forEach(function(updateId){
  305. Bills.update({billsLibId: billsLibId, ID: updateId, 'items.id': id}, {$set: {'items.$.content': data}}, function(err){
  306. if(err){
  307. success = false;
  308. }
  309. });
  310. });
  311. if(!success){
  312. callback(1, 'Error');
  313. }
  314. else {
  315. callback(0, '');
  316. }
  317. }
  318. }
  319. }
  320. billsLibDao.prototype.deleteBills = function(delData, callback){
  321. var deleteIds = delData.deleteIds;
  322. var billsLibId = delData.billsLibId;
  323. if(deleteIds){
  324. //deleteIds.forEach(function(deleteId){
  325. Bills.remove({billsLibId: billsLibId, ID: {$in: deleteIds}}, function(err){
  326. if(err){
  327. callback(1, 'Error');
  328. }
  329. else {
  330. callback(0, '');
  331. }
  332. });
  333. // });
  334. }
  335. }
  336. //--------------JobContent------------------
  337. billsLibDao.prototype.getJobContent = function(gJobData, callback){
  338. var billsLibId = gJobData.billsLibId;
  339. JobContent.find({billsLibId: billsLibId}, "-_id", function(err, jobs){
  340. if(err){
  341. callback(1, "Error", null);
  342. }
  343. else{
  344. callback(0, "", jobs)
  345. }
  346. });
  347. }
  348. billsLibDao.prototype.getSomeJobs = function(gJobData, callback){
  349. var billsLibId = gJobData.billsLibId;
  350. var ids = gJobData.ids;
  351. JobContent.find({billsLibId: billsLibId, id: {$in: ids}}, "-_id", function(err, jobs){
  352. if(err){
  353. callback(1, "Error", null);
  354. }
  355. else{
  356. callback(0, "", jobs)
  357. }
  358. });
  359. }
  360. billsLibDao.prototype.createJobContent = function(cJobData, callback){
  361. var field = cJobData.field;
  362. var data = cJobData.data;
  363. var billsLibId = cJobData.billsLibId;
  364. var serialNo = cJobData.serialNo;
  365. counter.counterDAO.getIDAfterCount(counter.moduleName.bills, 1, function(err, result){
  366. var id = result.value.sequence_value;
  367. var newJobContent;
  368. /*if(field == "code"){
  369. newJobContent = {
  370. id: id,
  371. billsLibId: billsLibId,
  372. code: data,
  373. content: ''
  374. }
  375. }*/
  376. if(field == "content"){
  377. newJobContent = {
  378. id: id,
  379. billsLibId: billsLibId,
  380. code: serialNo,
  381. content: data,
  382. }
  383. }
  384. JobContent.create(newJobContent, function(err){
  385. if(err){
  386. callback(1, "Error", null);
  387. console.log('error');
  388. }
  389. else{
  390. console.log(id);
  391. callback(0, "", id);
  392. }
  393. });
  394. });
  395. }
  396. billsLibDao.prototype.updateJobContent = function(uJobData, callback){
  397. var field = uJobData.field;
  398. var updateData = uJobData.data;
  399. var updateid = uJobData.updateId;
  400. if(field == "code"){
  401. JobContent.update({id: updateid}, {$set: {code: updateData}}, function(err){
  402. if(err){
  403. callback(1, "Error");
  404. }
  405. else{
  406. callback(0, "");
  407. }
  408. });
  409. }
  410. else if(field == "content"){
  411. JobContent.update({id: updateid}, {$set: {content: updateData}}, function(err){
  412. if(err){
  413. callback(1, "Error");
  414. }
  415. else{
  416. callback(0, "");
  417. }
  418. });
  419. }
  420. }
  421. billsLibDao.prototype.deleteJobContent = function(jobId, callback){
  422. JobContent.remove({id: jobId}, function(err){
  423. if(err){
  424. callback(1, "Error");
  425. }
  426. else{
  427. callback(0, "");
  428. }
  429. });
  430. }
  431. //----------------------ItemCharacter---------------------
  432. billsLibDao.prototype.getItemCharacter = function(gdata, callback){
  433. var billsLibId = gdata.billsLibId;
  434. ItemCharacter.find({billsLibId: billsLibId}, "-_id", function(err, items){
  435. if(err){
  436. callback(1, "Error", null);
  437. }
  438. else{
  439. callback(0, "", items)
  440. }
  441. });
  442. }
  443. billsLibDao.prototype.createItemCharacter = function(cItemData, callback){
  444. var field = cItemData.field;
  445. var data = cItemData.data;
  446. var billsLibId = cItemData.billsLibId;
  447. var newItemCharacter;
  448. counter.counterDAO.getIDAfterCount(counter.moduleName.bills, 1, function(err, result){
  449. var id = result.value.sequence_value;
  450. if(field === 'code'){
  451. newItemCharacter = {
  452. id: id,
  453. billsLibId: billsLibId,
  454. code: data,
  455. content: ''
  456. }
  457. }
  458. else if(field === 'content'){
  459. newItemCharacter = {
  460. id: id,
  461. billsLibId: billsLibId,
  462. content: data,
  463. code: ''
  464. }
  465. }
  466. ItemCharacter.create(newItemCharacter, function(err){
  467. if(err){
  468. callback(1, "Error", null);
  469. }
  470. else{
  471. callback(0, "", id);
  472. }
  473. });
  474. });
  475. }
  476. billsLibDao.prototype.updateItemCharacter = function(uItemData, callback){
  477. var field = uItemData.field;
  478. var updateData = uItemData.data;
  479. var id = uItemData.updateId;
  480. if(field === "code"){
  481. ItemCharacter.update({id: id}, {$set: {code: updateData}}, function(err){
  482. if(err){
  483. callback(1, "Error");
  484. }
  485. else{
  486. callback(0, "");
  487. }
  488. });
  489. }
  490. else if(field === "content"){
  491. ItemCharacter.update({id: id}, {$set: {content: updateData}}, function(err){
  492. if(err){
  493. callback(1, "Error");
  494. }
  495. else{
  496. callback(0, "");
  497. }
  498. });
  499. }
  500. }
  501. billsLibDao.prototype.deleteItemCharacter = function(itemId, callback){
  502. JobContent.remove({id: itemId}, function(err){
  503. if(err){
  504. callback(1, "Error");
  505. }
  506. else{
  507. callback(0, "");
  508. }
  509. });
  510. }
  511. //----------------------itemValue
  512. //-----------------------------
  513. module.exports = new billsLibDao();