project.js 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178
  1. /**
  2. * Created by jimiz on 2017/4/16.
  3. */
  4. var billsData = require('./bills');
  5. var rationData = require('./ration');
  6. var ration_glj_data = require('../../ration_glj/facade/ration_glj_facade');
  7. var ration_coe_data = require('../../ration_glj/facade/ration_coe_facade');
  8. var ration_ass_data = require('../../ration_glj/facade/ration_ass_facade');
  9. let ration_installation = require('../facade/ration_installation_facade');
  10. let ration_template = require('../facade/ration_template_facade');
  11. var quantity_detail_data = require('../facade/quantity_detail_facade');
  12. var fee_rate_data = require('../../fee_rates/facade/fee_rates_facade');
  13. let projCounter = require('./proj_counter_model');
  14. let projSetting = require('./proj_setting_model');
  15. // let volumePriceData = require('../../volume_price/models/volume_price_model');
  16. var labour_coe_facade = require('../facade/labour_coe_facade');
  17. var calc_program_facade = require('../facade/calc_program_facade');
  18. import GLJController from "../../glj/controllers/glj_controller";
  19. let installation_facade = require('../facade/installation_facade');
  20. let evaluate_facade = require('../facade/evaluate_facade');
  21. let bid_facade = require('../facade/bid_facade');
  22. let contractor_facade = require('../facade/contractor_facade');
  23. let pmController = require('../../pm/controllers/pm_controller');
  24. const ProjectModel = require('../../pm/models/project_model').project;
  25. import GLJListModel from "../../glj/models/glj_list_model";
  26. var consts = require('./project_consts');
  27. var projectConsts = consts.projectConst;
  28. var asyncTool = require("async");
  29. var moduleMap = {};
  30. moduleMap[projectConsts.BILLS] = billsData;
  31. moduleMap[projectConsts.RATION] = rationData;
  32. moduleMap[projectConsts.RATION_GLJ] = ration_glj_data;
  33. moduleMap[projectConsts.RATION_COE] = ration_coe_data;
  34. moduleMap[projectConsts.RATION_ASS] = ration_ass_data;
  35. moduleMap[projectConsts.RATION_INSTALLATION] = ration_installation;
  36. moduleMap[projectConsts.QUANTITY_DETAIL] = quantity_detail_data;
  37. moduleMap[projCounter.collectionName] = projCounter;
  38. moduleMap[projSetting.collectionName] = projSetting;
  39. moduleMap[projectConsts.FEERATE] = fee_rate_data;
  40. moduleMap[projectConsts.LABOUR_COE] = labour_coe_facade;
  41. moduleMap[projectConsts.CALC_PROGRAM] = calc_program_facade;
  42. moduleMap[projectConsts.PROJECTGLJ] = new GLJController();
  43. moduleMap[projectConsts.INSTALLATION_FEE] = installation_facade;
  44. moduleMap[projectConsts.RATION_TEMPLATE] = ration_template;
  45. moduleMap[projectConsts.PROJECT_INFO] = pmController;
  46. moduleMap[projectConsts.EVALUATE_LIST] = evaluate_facade;
  47. moduleMap[projectConsts.BID_EVALUATION_LIST] = bid_facade;
  48. moduleMap[projectConsts.contractor_list] = contractor_facade;
  49. var Project = function (){};
  50. Project.prototype.datas = [];
  51. Project.prototype.prepare = function(data, callback){
  52. var me = this;
  53. data.update_data.forEach(function(item){
  54. item.user_id = data.user_id;
  55. me.datas.push(item);
  56. /*
  57. to do
  58. moduleMap[item.moduleName].prepare(item.data, jobCallback);
  59. */
  60. });
  61. };
  62. Project.prototype.save = function(datas, callback){
  63. var job, savePoint;
  64. var functions = [];
  65. var item;
  66. var me = this;
  67. me.prepare(datas, function(job, savePoint){});
  68. function saveModule(data) {
  69. return function (cb) {
  70. if(data.moduleName!=undefined){
  71. moduleMap[data.moduleName].save(data.user_id, data.data, cb);
  72. }
  73. // console.log(moduleMap[data.moduleName])
  74. }
  75. }
  76. for (var i = 0; i < me.datas.length; i++){
  77. item = me.datas[i];
  78. functions.push(saveModule(item));
  79. }
  80. asyncTool.parallel(functions, function(err, results) {
  81. if (!err){
  82. callback(null, '', results)
  83. } else{
  84. console.log(err);
  85. callback(1, 'save project failed', null)
  86. }
  87. });
  88. me.datas = [];
  89. };
  90. Project.prototype.getData = function(projectID, callback){
  91. var functions = [];
  92. var itemName;
  93. let firstTime = +new Date();
  94. for (itemName in moduleMap){
  95. functions.push((function(itemName){
  96. return function (cb) {
  97. let startTime = +new Date();
  98. moduleMap[itemName].getData(projectID, function(err, moduleName, data){
  99. let endTime = +new Date();
  100. console.log(moduleName+'---------------'+(endTime - startTime));
  101. cb(err, {moduleName: moduleName, data: data})
  102. })
  103. }
  104. })(itemName))
  105. }
  106. asyncTool.parallel(functions, function(err, results) {
  107. if (!err){
  108. let lastTime = +new Date();
  109. console.log('最后加载时间---------------'+(lastTime - firstTime));
  110. callback(0, '', results)
  111. }
  112. else{
  113. callback(1, 'load project failed', null)
  114. }
  115. });
  116. };
  117. Project.prototype.getFilterData = function (projectID, filter, callback) {
  118. let functions = [];
  119. let getModuleData = function (moduleName) {
  120. return async function (cb) {
  121. if (moduleMap[moduleName]) {
  122. moduleMap[moduleName].getData(projectID, function (err, name, data) {
  123. cb(err, {'moduleName': name, 'data': data})
  124. });
  125. } else if (moduleName === projectConsts.PROJECTGLJ) {
  126. try {
  127. if (isNaN(projectID) || projectID <= 0) {
  128. throw '标段id有误';
  129. }
  130. // 获取标段对应的单价文件id
  131. let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectID);
  132. if (unitPriceFileId <= 0) {
  133. throw '没有对应的单价文件';
  134. }
  135. // 先获取对应标段的项目工料机数据
  136. let gljListModel = new GLJListModel();
  137. let [gljList, mixRatioConnectData] = await gljListModel.getListByProjectId(projectID, unitPriceFileId);
  138. cb(null, {'moduleName': moduleName, 'data': gljList});
  139. } catch (error) {
  140. cb(error, null);
  141. }
  142. } else {
  143. throw '要查询的项目模块不存在';
  144. }
  145. }
  146. };
  147. for (let itemName of filter) {
  148. functions.push(getModuleData(itemName));
  149. }
  150. asyncTool.parallel(functions, function (err, results) {
  151. //console.log(results);
  152. if (err) {
  153. throw '获取项目数据出错';
  154. } else {
  155. callback(results);
  156. }
  157. });
  158. };
  159. module.exports = new Project();