test_tpl_05.js 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154
  1. /**
  2. * Created by Tony on 2018/8/15.
  3. */
  4. let test = require('tape');
  5. import JpcEx from "../../../modules/reports/rpt_component/jpc_ex";
  6. import JV from "../../../modules/reports/rpt_component/jpc_value_define";
  7. let config = require("../../../config/config.js");
  8. config.setupDb(process.env.NODE_ENV);
  9. let mongoose = require("mongoose");
  10. let fileUtils = require("../../../modules/common/fileUtils");
  11. let path = require('path');
  12. let dbm = require("../../../config/db/db_manager");
  13. let rpt_cfg = require('./rpt_cfg');
  14. let consts = require('../../../modules/main/models/project_consts');
  15. dbm.connect(process.env.NODE_ENV);
  16. //统一引用models
  17. fileUtils.getGlobbedFiles('../../../modules/all_models/*.js').forEach(function(modelPath) {
  18. require(path.resolve(modelPath));
  19. });
  20. let cfgCacheUtil = require("../../../config/cacheCfg");
  21. cfgCacheUtil.setupDftCache();
  22. let fsUtil = require("../../../public/fsUtil");
  23. let demoPrjId = - 1;
  24. // let demoRptId = 551; //05
  25. let demoRptId = 626; //06
  26. let pagesize = "A4";
  27. // demoPrjId = 720; //QA: DW3
  28. // demoPrjId = 4563; //QA:
  29. demoPrjId = 4107; //UAT:
  30. //*/
  31. // let userId_Leng = "59cdf14a0034a1000ba52b97"; //小冷User Id 换成_id了
  32. let userId_Leng = "5b5a66c4a3c23e000dccdd77"; //海珠的 _id
  33. let userId_Dft = userId_Leng;
  34. /*/
  35. let userId_Dft = "595328da1934dc327cad08eb";
  36. //*/
  37. let rptTplFacade = require("../../../modules/reports/facade/rpt_template_facade");
  38. let rptTplDataFacade = require("../../../modules/reports/facade/rpt_tpl_data_facade");
  39. let pm_facade = require('../../../modules/pm/facade/pm_facade');
  40. import rptDataExtractor from "../../../modules/reports/util/rpt_construct_data_util";
  41. let fs = require('fs');
  42. //设置Date Format函数
  43. fs.readFile(__dirname.slice(0, __dirname.length - 18) + '/public/web/date_util.js', 'utf8', 'r', function (err, data) {
  44. eval(data);
  45. });
  46. //*
  47. test('测试 - 模板05汇总表: ', function (t) {
  48. rptTplFacade.getRptTemplate(demoRptId).then(function(rptTpl) {
  49. let rptDataUtil = new rptDataExtractor();
  50. rptDataUtil.initialize(rptTpl._doc);
  51. let summaryRst = [];
  52. let filter = rptDataUtil.getDataRequestFilter(summaryRst);
  53. console.log(filter);
  54. console.log(summaryRst);
  55. let promiseArr = [null, null];
  56. if (summaryRst.length > 0) {
  57. if (summaryRst.indexOf(`Construct`) >= 0 || summaryRst.indexOf(`ConstructDetail`) >= 0) {
  58. promiseArr[0] = pm_facade.getSummaryInfoByTender(demoPrjId, pm_facade.projectType.project);
  59. }
  60. if (summaryRst.indexOf(`Segment`) >= 0 || summaryRst.indexOf(`SegmentDetail`) >= 0) {
  61. promiseArr[1] = pm_facade.getSummaryInfoByTender(demoPrjId, pm_facade.projectType.engineering);
  62. }
  63. }
  64. //*/
  65. rptTplDataFacade.prepareProjectData(userId_Dft, demoPrjId, filter, function (err, msg, rawDataObj) {
  66. if (!err) {
  67. //取汇总数据流程
  68. if (promiseArr[0] !== null) {
  69. promiseArr[0].then(function (rst) {
  70. rawDataObj.Construct = rst.parent;
  71. rawDataObj.ConstructDetail = rst.subList;
  72. if (promiseArr[1] !== null) {
  73. promiseArr[1].then(function (rst) {
  74. rawDataObj.Segment = rst.parent;
  75. rawDataObj.SegmentDetail = rst.subList;
  76. buildPageData(t, rawDataObj, rptDataUtil, rptTpl);
  77. });
  78. } else {
  79. buildPageData(t, rawDataObj, rptDataUtil, rptTpl);
  80. }
  81. });
  82. } else if (promiseArr[1] !== null) {
  83. promiseArr[1].then(function (rst) {
  84. rawDataObj.Segment = rst.parent;
  85. rawDataObj.SegmentDetail = rst.subList;
  86. buildPageData(t, rawDataObj, rptDataUtil, rptTpl);
  87. });
  88. } else {
  89. buildPageData(t, rawDataObj, rptDataUtil, rptTpl);
  90. }
  91. } else {
  92. console.log(msg);
  93. t.pass('pass with error!');
  94. t.end();
  95. }
  96. });
  97. //*/
  98. //正常应该根据报表模板定义的数据类型来请求数据
  99. });
  100. });
  101. //*/
  102. function buildPageData(t, rawDataObj, rptDataUtil, rptTpl) {
  103. try {
  104. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/rptTplRawDataObject_汇总表.jsp");
  105. let tplData = rptDataUtil.assembleData(rawDataObj);
  106. fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/rptTplRawDataAfterCacl_汇总表.jsp");
  107. fsUtil.writeObjToFile(tplData, "D:/GitHome/ConstructionCost/tmp/rptTplAssembledData_汇总表.jsp");
  108. //it's time to build the report!!!
  109. let printCom = JpcEx.createNew();
  110. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pagesize;
  111. let defProperties = rpt_cfg;
  112. let dftOption = JV.PAGING_OPTION_NORMAL;
  113. printCom.initialize(rptTpl);
  114. // fsUtil.writeObjToFile(tplData, "D:/GitHome/ConstructionCost/tmp/rptAssembledData_汇总表.jsp");
  115. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/rptRawDataAfterAssembled_汇总表.jsp");
  116. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption);
  117. let maxPages = printCom.totalPages;
  118. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties);
  119. if (pageRst) {
  120. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/rptPageResult_汇总表.jsp");
  121. } else {
  122. console.log("oh! no pages were created!");
  123. }
  124. } catch (ex) {
  125. console.log(ex);
  126. t.pass('pass with exception!');
  127. t.end();
  128. }
  129. t.pass('pass succeeded!');
  130. t.end();
  131. }
  132. test('close the connection', function (t) {
  133. setTimeout(function () {
  134. mongoose.disconnect();
  135. t.pass('closing db connection');
  136. t.end();
  137. }, 3000);
  138. // mongoose.disconnect();
  139. // t.pass('closing db connection');
  140. // t.end();
  141. });