calc_program_facade.js 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244
  1. /**
  2. * Created by CSL on 2017-10-22.
  3. */
  4. const uuidV1 = require('uuid/v1');
  5. let logger = require("../../../logs/log_helper").logger;
  6. let mongoose = require('mongoose');
  7. let stdCalcProgramsModel = mongoose.model('std_calc_programs');
  8. let projectCalcProgramsModel = mongoose.model('calc_programs');
  9. let EngineeringLibModel = require("../../users/models/engineering_lib_model");
  10. let _=require("lodash");
  11. let consts = require('../models/project_consts');
  12. let projectConsts = consts.projectConst;
  13. module.exports = {
  14. newProjectCalcProgramFile: newProjectCalcProgramFile,
  15. getProjectCalcProgramFile: getProjectCalcProgramFile,
  16. getStdCalcProgramFile: getStdCalcProgramFile,
  17. getData: getData,
  18. save: save,
  19. saveCalcItem: saveCalcItem,
  20. saveCalcItems: saveCalcItems,
  21. updateTemplate: updateTemplate,
  22. addTemplate: addTemplate,
  23. deleteTemplate: deleteTemplate
  24. };
  25. async function newProjectCalcProgramFile(data) {
  26. logger.info(`Create new CalcProgram file for project : ${data.ID}`);
  27. let rst = null;
  28. let egnrModel = new EngineeringLibModel();
  29. let egnr = await egnrModel.getEngineering(data.property.engineering_id);
  30. if(!egnr) return rst;
  31. let valid_CP_libs = egnr._doc.program_lib;
  32. if (valid_CP_libs == undefined || valid_CP_libs.length == 0) return rst;
  33. // 绑定多个计算程序标准文件时,默认取第一个作为标准模板。
  34. let stdCP = await getStdCalcProgramFile(valid_CP_libs[0].id);
  35. let doc={
  36. ID: uuidV1(),
  37. projectID: data.ID,
  38. name: data.name,
  39. libID: stdCP.ID,
  40. libName: stdCP.libName,
  41. templates: stdCP.templates
  42. };
  43. await projectCalcProgramsModel.create(doc);
  44. rst = {ID: doc.ID, name: doc.name};
  45. return rst;
  46. };
  47. async function getProjectCalcProgramFile(ID) {
  48. let projCP = await projectCalcProgramsModel.findOne({ID:ID});
  49. return projCP;
  50. };
  51. async function getStdCalcProgramFile(libID) {
  52. let stdCP = await stdCalcProgramsModel.findOne({ID:libID});
  53. return stdCP;
  54. };
  55. // 统一的 getData() 方法供project调用
  56. function getData(projectID, callback) {
  57. projectCalcProgramsModel.findOne({projectID: projectID}, '-_id', function (err, datas) {
  58. if (!err) {
  59. // 旧项目没有计算程序文件,默认给它生成一个。
  60. if (!datas) {
  61. logger.info(`Create a calcProgram file for old project : ${projectID}`);
  62. getStdCalcProgramFile(1).then(function (stdCP) {
  63. let doc = {
  64. ID: uuidV1(),
  65. projectID: projectID,
  66. name: '[旧项目补计算程序文件]',
  67. libID: stdCP.ID,
  68. libName: stdCP.libName,
  69. templates: stdCP.templates
  70. };
  71. projectCalcProgramsModel.create(doc);
  72. callback(0, projectConsts.CALC_PROGRAM, stdCP);
  73. });
  74. } else {
  75. callback(0, projectConsts.CALC_PROGRAM, datas);
  76. };
  77. } else {
  78. callback(1, projectConsts.CALC_PROGRAM, null);
  79. };
  80. });
  81. };
  82. // 统一的 save() 方法供project调用
  83. function save (user_id, datas, callback) {
  84. let returnData ={
  85. moduleName:'calc_program',
  86. data:{}
  87. };
  88. projectCalcProgramsModel.update({"projectID": 553}, {"libName":"goo—test"}, callback(null, returnData));
  89. }
  90. // saveCalcItem({projectID: 597, templatesID: 4, calcItem: calcItem})
  91. function saveCalcItem(dataObj, callback) {
  92. dataObj=JSON.parse(dataObj);
  93. projectCalcProgramsModel.findOne({projectID: dataObj.projectID}, function (err, data) {
  94. if(!err){
  95. for (let i = 0; i < data.templates.length; i++){
  96. if (data.templates[i].ID == dataObj.templatesID){
  97. for (let j=0; j < data.templates[i].calcItems.length; j++){
  98. if (data.templates[i].calcItems[j].ID == dataObj.calcItem.ID){
  99. data.templates[i].calcItems[j] = dataObj.calcItem;
  100. data.save(function (err) {
  101. if (err) {
  102. callback(1, '本条计算规则保存失败');
  103. } else {
  104. callback(0, '本条计算规则保存成功');
  105. }
  106. });
  107. break;
  108. };
  109. };
  110. break;
  111. };
  112. };
  113. }
  114. else {
  115. callback(1, '没有找到计算程序文件');
  116. }
  117. });
  118. };
  119. // { projectID: projectID, calcItems: [{templatesID, calcItem}] }
  120. function saveCalcItems(datas, callback) {
  121. let datasObj = JSON.parse(datas);
  122. projectCalcProgramsModel.findOne({projectID: datasObj.projectID}, function (err, data) {
  123. if(!err){
  124. for (let cI of datasObj.calcItems){
  125. for (let i = 0; i < data.templates.length; i++){
  126. if (data.templates[i].ID == cI.templatesID){
  127. for (let j=0; j < data.templates[i].calcItems.length; j++){
  128. if (data.templates[i].calcItems[j].ID == cI.calcItem.ID){
  129. data.templates[i].calcItems[j] = cI.calcItem;
  130. data.save(function (err) {
  131. if (err) {
  132. callback({err:1, msg:'本条计算规则保存失败'});
  133. } else {
  134. callback({err:0, msg:'本条计算规则保存成功'});
  135. }
  136. });
  137. break;
  138. };
  139. };
  140. break;
  141. };
  142. };
  143. };
  144. }
  145. else {
  146. callback( {err:1, msg:'没有找到计算程序文件'} );
  147. }
  148. });
  149. };
  150. // { projectID: 3, ID: 5, name: '建筑工程', custom: true, calcItems: [{},{}] } 其中name、custom、calcItems可选,其它必填。
  151. // 插入一条计算规则、删除一条计算规则,则整套计算规则整个传入更新,仅calcItems指定值。
  152. // 修改文件名称,则只传入name。
  153. function updateTemplate(dataObj, callback) {
  154. dataObj=JSON.parse(dataObj);
  155. projectCalcProgramsModel.findOne({projectID: dataObj.projectID}, function (err, data) {
  156. if(!err){
  157. for (let i = 0; i < data.templates.length; i++){
  158. if (data.templates[i].ID == dataObj.ID){
  159. if (dataObj.name)
  160. data.templates[i].name = dataObj.name;
  161. if (dataObj.custom)
  162. data.templates[i].custom = dataObj.custom;
  163. if (dataObj.calcItems)
  164. data.templates[i].calcItems = dataObj.calcItems;
  165. data.save(function (err) {
  166. if (err) {
  167. callback(1, '计算模板保存失败');
  168. } else {
  169. callback(0, '计算模板保存成功');
  170. }
  171. });
  172. break;
  173. };
  174. };
  175. }
  176. else {
  177. callback(1, '没有找到计算程序文件');
  178. }
  179. });
  180. };
  181. // { projectID: 1233, ID: 19, name: '建筑工程2', custom: true, calcItems: [{},{}] }
  182. function addTemplate(dataObj, callback) {
  183. dataObj=JSON.parse(dataObj);
  184. projectCalcProgramsModel.update({projectID: dataObj.projectID},
  185. {
  186. $push:{
  187. templates:{
  188. "ID": dataObj.ID,
  189. "name": dataObj.name,
  190. "calcItems": dataObj.calcItems,
  191. "custom": dataObj.custom
  192. }
  193. }
  194. },
  195. function (err) {
  196. if (!err) {
  197. callback(0, '计算模板创建成功');
  198. }
  199. else {
  200. callback(1, '计算模板创建失败');
  201. }
  202. }
  203. );
  204. };
  205. // { projectID: 1233, ID: 19}
  206. function deleteTemplate(dataObj, callback) {
  207. dataObj=JSON.parse(dataObj);
  208. projectCalcProgramsModel.update({projectID: dataObj.projectID},
  209. {
  210. $pull:{
  211. templates:{
  212. "ID": dataObj.ID
  213. }
  214. }
  215. },
  216. function (err) {
  217. if (!err) {
  218. callback(0, '计算模板删除成功');
  219. }
  220. else {
  221. callback(1, '计算模板删除失败');
  222. }
  223. }
  224. );
  225. };
  226. // for test
  227. // let s = '{"projectID":2164,"ID":23,"name":"建筑工程7","custom":true,"calcItems":[]}';
  228. // addTemplate(s, function(data){console.log('add successfull!')});
  229. // let s = '{"projectID":2164,"ID":15}';
  230. // deleteTemplate(s, function(data){console.log('delete successfull!')});