coe.js 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. /**
  2. * Created by CSL on 2017/5/3.
  3. * 系数表。
  4. */
  5. var mongoose = require("mongoose");
  6. var counter = require('../../../public/counter/counter');
  7. var coeListModel = mongoose.model("std_ration_lib_coe_list");
  8. var coeListDAO = function(){};
  9. const compleCoeModel = mongoose.model('complementary_ration_coe_list');
  10. coeListDAO.prototype.getComplementaryCoes = async function (userId, compilationId, callback) {
  11. try {
  12. let coeData = await compleCoeModel.find({userId, compilationId});
  13. callback(0, coeData);
  14. } catch (err) {
  15. callback(1, null);
  16. }
  17. };
  18. coeListDAO.prototype.getCoe = function (data, callback) {
  19. coeListModel.findOne({
  20. "libID": data.libID,
  21. "ID": data.ID,
  22. "$or": [{"isDeleted": null}, {"isDeleted": false}]
  23. },
  24. function (err, doc) {
  25. if (err) callback("获取系数明细错误!", null)
  26. else callback(null, doc);
  27. })
  28. };
  29. coeListDAO.prototype.getCoeItemsByIDs = function (data, callback) {
  30. coeListModel.find({
  31. "libID": data.libID,
  32. "ID": {"$in":data.coeIDs}
  33. }, ["libID","ID", "serialNo","name","content","-_id"],
  34. function (err, doc) {
  35. if (err) callback("批量获取系数明细错误!", null)
  36. else callback(0, doc);
  37. })
  38. };
  39. coeListDAO.prototype.getCoeItemsByNos = function (data, callback) {
  40. coeListModel.find({
  41. "libID": data.libID,
  42. "serialNo": {"$in":data.coeNos}
  43. }, ["libID","ID","serialNo","name","content","-_id"],
  44. function (err, doc) {
  45. if (err) callback("批量获取系数明细错误!", null)
  46. else callback(0, doc);
  47. })
  48. };
  49. coeListDAO.prototype.getCoesByLibID = function (libID, callback) {
  50. coeListModel.find({ "libID": libID },
  51. function (err, doc) {
  52. if (err) callback("获取定额库系数表错误", null)
  53. else callback(0, doc);
  54. })
  55. };
  56. coeListDAO.prototype.saveToCoeList = function(data, callback) {
  57. var me = this;
  58. if (data.addArr.length > 0) {
  59. me.addItems(data.addArr, callback);
  60. };
  61. if (data.deleteArr.length > 0) {
  62. me.deleteItems(data.deleteArr, callback);
  63. };
  64. if (data.updateArr.length > 0) {
  65. me.updateItems(data.updateArr, callback);
  66. };
  67. };
  68. coeListDAO.prototype.addItems = function(addArr, callback) {
  69. if (addArr && addArr.length > 0) {
  70. counter.counterDAO.getIDAfterCount(counter.moduleName.coeList, addArr.length, function(err, result){
  71. var maxId = result.sequence_value;
  72. for (var i = 0; i < addArr.length; i++) {
  73. var obj = new coeListModel(addArr[i]);
  74. obj.ID = (maxId - (addArr.length - 1) + i);
  75. coeListModel.create(obj, function(err) {
  76. if (err) {
  77. callback(true, "add fail", null);
  78. } else {
  79. callback(false, "add success", obj.ID);
  80. };
  81. });
  82. };
  83. });
  84. } else {
  85. callback(true, "no source", null);
  86. };
  87. };
  88. coeListDAO.prototype.updateItems = function(updateArr, callback) {
  89. if (updateArr && updateArr.length > 0) {
  90. for (var i = 0; i < updateArr.length; i++) {
  91. var obj = updateArr[i];
  92. coeListModel.update({"libID": obj.libID, "ID": obj.ID}, updateArr[i], function(err) {
  93. if (err) {
  94. callback(true, "update fail", null);
  95. } else {
  96. callback(false, "update success", obj.ID);
  97. };
  98. });
  99. };
  100. } else {
  101. callback(true, "no source", null);
  102. };
  103. };
  104. coeListDAO.prototype.deleteItems = function(deleteArr, callback) {
  105. if (deleteArr && deleteArr.length > 0) {
  106. for (var i = 0; i < deleteArr.length; i++) {
  107. var obj = deleteArr[i];
  108. coeListModel.remove({"libID": obj.libID, "ID": obj.ID}, function(err) {
  109. if (err) {
  110. callback(true, "delete fail", null);
  111. } else {
  112. callback(false, "delete success", obj.ID);
  113. };
  114. });
  115. };
  116. } else {
  117. callback(true, "no source", null);
  118. };
  119. };
  120. module.exports = new coeListDAO();