ration_controller.js 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. /**
  2. * Created by jimiz on 2017/4/9.
  3. */
  4. let rationData = require('../models/ration');
  5. let ration_glj_facade = require('../../ration_glj/facade/ration_glj_facade');
  6. let ration_ass_facade = require('../../ration_glj/facade/ration_ass_facade');
  7. let ration_facade = require('../facade/ration_facade');
  8. let bill_facade = require('../facade/bill_facade');
  9. let project_facade = require("../facade/project_facade");
  10. let logger = require("../../../logs/log_helper").logger;
  11. const GLJController = require("../../glj/controllers/glj_controller");
  12. let controller = {
  13. insertGLJAsRation:async function (req){
  14. let data = req.body.data;
  15. data = JSON.parse(data);
  16. return await ration_glj_facade.insertGLJAsRation(data,req.session.sessionCompilation);
  17. },
  18. replaceRations:async function (req) {
  19. let data = req.body.data;
  20. data = JSON.parse(data);
  21. let userID = req.session.sessionUser.id;
  22. return await ration_facade.replaceRations(userID,data,req.session.sessionCompilation);
  23. },
  24. addNewRation:async function(req) {
  25. let data = req.body.data;
  26. if(typeof data === 'object'){
  27. data = JSON.stringify(data);
  28. }
  29. data = JSON.parse(data);
  30. let result = await ration_facade.addNewRation(data,req.session.sessionCompilation);
  31. //合并取项目工料机数据的情求,用于刷新项目工料机数据,当有添加、替换项目工料机的情况,才需要刷新
  32. /* if(result.ration_gljs && result.ration_gljs.length > 0 && data.newData){
  33. result.projectGLJDatas = await getProjectGLJData(data.newData.projectID);
  34. }*/
  35. return result;
  36. },
  37. addMultiRation: async function (req) {
  38. let data = req.body.data;
  39. if(typeof data === 'object'){
  40. data = JSON.stringify(data);
  41. }
  42. data = JSON.parse(data);
  43. return await ration_facade.addMultiRation(data.newDatas,req.session.sessionCompilation);
  44. },
  45. getSameSectionRations:async function(req){//取同个章节相邻的定额
  46. let data = req.body.data;
  47. data = JSON.parse(data);
  48. return await ration_facade.getSameSectionRations(data,req.session.sessionUser.id, req.session.sessionCompilation._id);
  49. },
  50. //取定额默认的取费专业
  51. getDefaultProgramID:async function(req){
  52. let data = req.body.data;
  53. data = JSON.parse(data);
  54. data.userID = req.session.sessionUser.id;
  55. data.compilationId = req.session.sessionCompilation._id;
  56. return await ration_facade.getDefaultProgramID(data);
  57. },
  58. //应用定额关联子目
  59. applyTemplate:async function(req){
  60. let data = req.body.data;
  61. data = JSON.parse(data);
  62. let updateDatas =[];
  63. let applyTasks = [
  64. ration_facade.addMultiRation(data.rations.create,req.session.sessionCompilation),//先生成新定额
  65. bill_facade.createNewBills(data.bills.create),
  66. ration_facade.deleteMultiRation(data.rations.delete)
  67. ];
  68. //整理更新的数据,调用一个方法更新
  69. updateDatas.push(data.ration_template);
  70. if(data.rations.update.length > 0) prepareUpdateNodes(data.rations.update,updateDatas,"ration");
  71. if(data.bills.update.length > 0) prepareUpdateNodes(data.bills.update,updateDatas,"bills");
  72. applyTasks.push(project_facade.updateNodes(updateDatas));
  73. let [rationResult,billsResult,deleteResult,updates] = await Promise.all(applyTasks);
  74. return {rationResult:rationResult,billsResult:billsResult,updateDatas:updateDatas};
  75. },
  76. //更新辅助定额
  77. updateRationAss:async function(req){
  78. let data = req.body.data;
  79. data = JSON.parse(data);
  80. return ration_ass_facade.updateRationAss(data);
  81. },
  82. //勾选定额调整系数
  83. updateCoeAdjust:async function(req){
  84. let data = req.body.data;
  85. data = JSON.parse(data);
  86. let result = await ration_facade.updateCoeAdjust(data,req.session.sessionCompilation);
  87. //合并取项目工料机数据的情求,用于刷新项目工料机数据,当有添加、替换项目工料机的情况,才需要刷新
  88. /* if(result.add.length > 0 || result.replace.length > 0){
  89. result.projectGLJDatas = await getProjectGLJData(data.projectID);
  90. }*/
  91. return result;
  92. }
  93. };
  94. async function getProjectGLJData(projectID) {
  95. let gljController = new GLJController();
  96. let responseData = await gljController.getProjectGLJsByProjectID(projectID);
  97. return responseData.data;
  98. }
  99. function prepareUpdateNodes(datas,nodes,type) {
  100. for(let d of datas){
  101. nodes.push({type:type,data:d});
  102. }
  103. }
  104. //统一回调函数
  105. let callback = function(req, res, err, message, data){
  106. res.json({error: err, message: message, data: data});
  107. };
  108. module.exports = {
  109. getData: function(req, res){
  110. var data = JSON.parse(req.body.data);
  111. rationData.getData(data.projectId, function(err, message, rationList){
  112. if (err === 0) {
  113. callback(req, res, err, message, rationList);
  114. } else {
  115. callback(req, res, err, message, null);
  116. }
  117. });
  118. },
  119. getItemTemplate: function(req, res){
  120. //var data = JSON.parse(req.body.data);
  121. rationData.getItemTemplate(function(err, message, rationItem){
  122. if (billsItem) {
  123. callback(req, res, err, message, rationItem);
  124. } else {
  125. callback(req, res, err, message, null);
  126. }
  127. });
  128. },
  129. allocIDs: function(req, res){
  130. rationData.allocIDs(function(err, message, data){
  131. if (err) {
  132. callback(req, res, err, message, data);
  133. } else {
  134. callback(req, res, err, message, null);
  135. }
  136. });
  137. },
  138. action:async function(req,res){//自动跳转到URL对应的controller方法
  139. let result={
  140. error:0
  141. }
  142. try {
  143. let functionName = req.url.replace(/\//g,"");
  144. result.data = controller[functionName]?await controller[functionName](req):"";
  145. }catch (err){
  146. logger.err(err);
  147. result.error=1;
  148. result.message = err.message;
  149. }
  150. res.json(result);
  151. }
  152. };