report_controller.js 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754
  1. 'use strict';
  2. /**
  3. * Created by Tony on 2019/7/5.
  4. */
  5. const tenderMenu = require('../../config/menu').tenderMenu;
  6. const measureType = require('../const/tender').measureType;
  7. const accountGroup = require('../const/account_group').group;
  8. const JpcEx = require('../reports/rpt_component/jpc_ex');
  9. const JV = require('../reports/rpt_component/jpc_value_define');
  10. const rpt_xl_util = require('../reports/util/rpt_excel_util');
  11. const rptDataExtractor = require('../reports/util/rpt_calculation_data_util');
  12. const fsUtil = require('../public/js/fsUtil');
  13. const fs = require('fs');
  14. const rptCronJob = require('../reports/util/rpt_tmp_file_sweep');
  15. module.exports = app => {
  16. class ReportController extends app.BaseController {
  17. /**
  18. * 报表显示页面
  19. *
  20. * @param {Object} ctx - egg全局context
  21. * @return {void}
  22. */
  23. async index(ctx) {
  24. try {
  25. const tender = ctx.tender;
  26. const stage = ctx.stage;
  27. // console.log(tender.data);
  28. // console.log(tender.info);
  29. let stage_id = -1;
  30. let stage_order = -1;
  31. let sorder = -1;
  32. let stage_times = -1;
  33. let stage_status = -1;
  34. const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
  35. const custCfg = await ctx.service.rptCustomizeCfg.getCustomizeCfgByUserId('Administrator');
  36. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  37. const prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.data.project_id);
  38. const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
  39. // console.log(maxStageAmt[0].maxAmt);
  40. // if ((stage === null || stage === undefined) && stageList.length > 0) {
  41. // await ctx.service.stage.checkStage(stageList[stageList.length - 1].id);
  42. // stage = ctx.stage;
  43. // }
  44. if (stage !== null && stage !== undefined) {
  45. stage_id = stage.id;
  46. stage_order = stage.order;
  47. sorder = stage.curOrder;
  48. stage_times = stage.times;
  49. stage_status = stage.status;
  50. }
  51. for (const prjAcc of prjAccList) {
  52. prjAcc.account_group = accountGroup[prjAcc.account_group];
  53. }
  54. const renderData = {
  55. tender: tender.data,
  56. tenderInfo: tender.info,
  57. rpt_tpl_data: JSON.stringify(treeNodes),
  58. cust_cfg: JSON.stringify(custCfg),
  59. project_id: tender.data.project_id,
  60. tender_id: tender.id,
  61. tender_name: tender.data.name,
  62. stg_id: stage_id,
  63. stg_order: stage_order,
  64. cur_order: sorder,
  65. stg_times: stage_times,
  66. stg_status: stage_status,
  67. stage_list: JSON.stringify(stageList),
  68. prj_account_list: JSON.stringify(prjAccList),
  69. role_list: JSON.stringify(roleList),
  70. tenderMenu,
  71. preUrl: '/tender/' + tender.id,
  72. measureType,
  73. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.explode),
  74. };
  75. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  76. // await this.layout('report/index.ejs', renderData);
  77. // 在这里启动一个cron job,删除临时创建的excel文件
  78. if (!rptCronJob.started) {
  79. try {
  80. // console.log('rptCronJob.started: ' + rptCronJob.started);
  81. rptCronJob.started = true;
  82. rptCronJob.createJob(null, this.app.baseDir + '/app/public/download');
  83. } catch (ex) {
  84. rptCronJob.started = false;
  85. }
  86. }
  87. } catch (err) {
  88. this.log(err);
  89. console.log(err);
  90. // ctx.redirect('/tender/' + ctx.tender.id);
  91. }
  92. }
  93. /**
  94. * 报表打印页面
  95. *
  96. * @param {Object} ctx - egg全局context
  97. * @return {void}
  98. */
  99. async showPrintPage(ctx) {
  100. try {
  101. // const params = JSON.parse(ctx.request.body.params);
  102. const pageSize = ctx.params.size;
  103. // console.log('pageSize: ' + pageSize);
  104. const renderData = {
  105. size: pageSize,
  106. // orientation: params.orientation,
  107. };
  108. if (pageSize === 'A3') {
  109. await ctx.render('report/rpt_printA3.ejs', renderData);
  110. } else {
  111. await ctx.render('report/rpt_print.ejs', renderData);
  112. }
  113. } catch (err) {
  114. this.log(err);
  115. console.log(err);
  116. }
  117. }
  118. /**
  119. * 获取报表数据
  120. *
  121. * @param {Object} ctx - egg全局context
  122. * @return {void}
  123. */
  124. async getReport(ctx) {
  125. try {
  126. // console.log('in getReport');
  127. const params = JSON.parse(ctx.request.body.params);
  128. // console.log(params);
  129. let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
  130. if (!rptTpl || rptTpl.length !== 1) {
  131. throw '获取模板失败';
  132. }
  133. rptTpl = JSON.parse(rptTpl[0].rpt_content);
  134. // console.log('get the template!');
  135. const pageRst = await getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  136. // console.log(pageRst);
  137. const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  138. const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  139. // console.log('after role stage!');
  140. // console.log(roleRel);
  141. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  142. await encodeDummySignatureDataUri(pageRst, this.app.baseDir);
  143. // console.log('encodeSignatureDataUri!');
  144. ctx.body = { data: pageRst, signatureRelInfo: roleRel, stageAudit: stgAudit };
  145. // ctx.body = { data: { msg: 'test the network' } };
  146. ctx.status = 201;
  147. } catch (ex) {
  148. console.log(ex);
  149. this.setMessage(ex.toString(), this.messageType.ERROR);
  150. }
  151. }
  152. /**
  153. * 获取多批次报表数据
  154. *
  155. * @param {Object} ctx - egg全局context
  156. * @return {void}
  157. */
  158. async getMultiReportsEx(ctx) {
  159. // 原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  160. const params = JSON.parse(ctx.request.body.params);
  161. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  162. const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids)) : [];
  163. // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  164. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  165. for (const pageRst of pageRstArr) {
  166. await encodeDummySignatureDataUri(pageRst, this.app.baseDir);
  167. }
  168. // console.log(pageRstArr);
  169. ctx.body = { data: pageRstArr, signatureRelInfo: roleRel };
  170. ctx.status = 201;
  171. }
  172. async createExcelFilesEx(ctx) {
  173. const params = JSON.parse(ctx.request.body.params);
  174. const baseDir = this.app.baseDir;
  175. function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
  176. return new Promise(function(resolve, reject) {
  177. rpt_xl_util.exportExcel(pageRst, params.pageSize, rpt_name, params.isOneSheet, null, null, baseDir, innerRoleRel,
  178. (err, uuidName) => {
  179. if (err) return reject(err);
  180. const fileRst = { uuid: uuidName, reportName: rpt_name };
  181. resolve(fileRst);
  182. }
  183. );
  184. });
  185. }
  186. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids)) : [];
  187. // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  188. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  189. const runnableRst = [];
  190. for (let idx = 0; idx < pageRstArr.length; idx++) {
  191. let roleRel = null;
  192. for (const roleR of roleRelArr) {
  193. if (roleR.rpt_id === params.rpt_ids[idx]) {
  194. roleRel = JSON.parse(roleR.rel_content);
  195. break;
  196. }
  197. }
  198. // console.log('roleRel.rel_content: ' + roleRel.rel_content);
  199. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/testBuiltPageResult.jsp');
  200. runnableRst.push(getExcelByPageData(pageRstArr[idx], params.rpt_names[idx], roleRel));
  201. }
  202. const uuidRst = await Promise.all(runnableRst);
  203. ctx.body = { data: uuidRst };
  204. ctx.status = 201;
  205. }
  206. async createExcelFilesInOneBookEx(ctx) {
  207. const params = JSON.parse(ctx.request.body.params);
  208. const baseDir = this.app.baseDir;
  209. function getExcelByPageData(pageRstArr, rpt_name, innerRoleRel) {
  210. return new Promise(function(resolve, reject) {
  211. rpt_xl_util.exportExcelInOneBook(pageRstArr, params.pageSize, rpt_name, baseDir, innerRoleRel,
  212. (err, uuidName) => {
  213. if (err) return reject(err);
  214. const fileRst = { uuid: uuidName, reportName: rpt_name };
  215. resolve(fileRst);
  216. }
  217. );
  218. });
  219. }
  220. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids)) : [];
  221. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  222. const runnableRst = [];
  223. let rptRoleRelArr = [];
  224. const reAssignSignatureName = function(pageData, roleRel, rpt_name_key) {
  225. const keyMap = {};
  226. for (const pageItem of pageData.items) {
  227. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  228. if (!keyMap.hasOwnProperty(signCell.signature_name)) {
  229. keyMap[signCell.signature_name] = rpt_name_key + '_' + signCell.signature_name;
  230. }
  231. }
  232. }
  233. for (const pageItem of pageData.items) {
  234. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  235. if (keyMap.hasOwnProperty(signCell.signature_name)) {
  236. signCell.signature_name = keyMap[signCell.signature_name];
  237. }
  238. }
  239. }
  240. for (const roleSign of roleRel) {
  241. if (keyMap.hasOwnProperty(roleSign.signature_name)) {
  242. roleSign.signature_name = keyMap[roleSign.signature_name];
  243. }
  244. }
  245. // console.log('keyMap of : ' + rpt_name_key);
  246. // console.log(keyMap);
  247. };
  248. for (let idx = 0; idx < pageRstArr.length; idx++) {
  249. let roleRel = null;
  250. for (const roleR of roleRelArr) {
  251. if (roleR.rpt_id === params.rpt_ids[idx]) {
  252. roleRel = JSON.parse(roleR.rel_content);
  253. // 这里要做些电子签名的signature_name转换,以防重名
  254. reAssignSignatureName(pageRstArr[idx], roleRel, params.rpt_names[idx]);
  255. rptRoleRelArr = rptRoleRelArr.concat(roleRel);
  256. break;
  257. }
  258. }
  259. }
  260. runnableRst.push(getExcelByPageData(pageRstArr, params.rptName, rptRoleRelArr));
  261. const uuidRst = await Promise.all(runnableRst);
  262. ctx.body = { data: uuidRst };
  263. ctx.status = 201;
  264. }
  265. async getFileByUUID(ctx) {
  266. // console.log('downloading : ' + ctx.params.uuid);
  267. const uuid = ctx.params.uuid;
  268. const rptName = ctx.params.rptName;
  269. const suffix = '.' + ctx.params.suffix;
  270. function getUuidFile(filestream) {
  271. return new Promise(function(resolve, reject) {
  272. filestream.on('data', function(chunk) {
  273. resolve(chunk);
  274. });
  275. });
  276. }
  277. try {
  278. const rptNameURI = encodeURI(rptName);
  279. const filePath = this.app.baseDir + '/app/public/download/';
  280. const filestream = fs.createReadStream(filePath + uuid + suffix);
  281. const chunk = await getUuidFile(filestream);
  282. ctx.set({
  283. 'Content-Type': 'application/vnd.openxmlformats',
  284. 'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
  285. 'Content-Length': chunk.length,
  286. });
  287. ctx.body = chunk;
  288. } catch (e) {
  289. console.log(e);
  290. }
  291. }
  292. }
  293. return ReportController;
  294. };
  295. async function checkStg(ctx, params) {
  296. if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) {
  297. await ctx.service.stage.checkStage(params.stage_id);
  298. if (ctx.stage) {
  299. params.stage_order = ctx.stage.curOrder;
  300. }
  301. }
  302. }
  303. async function getReportData(ctx, params, filters) {
  304. const rst = {};
  305. const runnableRst = [];
  306. const runnableKey = []; // 这个配合runnableRst用,未来考虑并行查询优化
  307. // console.log('params');
  308. // console.log(params);
  309. for (const filter of filters) {
  310. if (runnableKey.indexOf(filter) < 0) {
  311. switch (filter) {
  312. case 'project' :
  313. runnableRst.push(ctx.service.project.getProjectById(params.project_id));
  314. runnableKey.push('project');
  315. break;
  316. case 'tender_info' :
  317. runnableRst.push(ctx.service.tenderInfo.getTenderInfo(params.tender_id));
  318. runnableKey.push('tender_info');
  319. break;
  320. case 'ledger' :
  321. runnableRst.push(ctx.service.ledger.getData(params.tender_id, 0));
  322. runnableKey.push('ledger');
  323. break;
  324. case 'stage_bills':
  325. runnableRst.push(ctx.service.stageBills.getLastestStageData(params.tender_id, params.stage_id));
  326. runnableKey.push('stage_bills');
  327. break;
  328. case 'stage_bills_final':
  329. await checkStg(ctx, params);
  330. runnableRst.push(ctx.service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order));
  331. runnableKey.push('stage_bills_final');
  332. break;
  333. case 'stage':
  334. runnableRst.push(ctx.service.stage.getStageById(params.stage_id));
  335. runnableKey.push('stage');
  336. break;
  337. case 'stage_pay':
  338. await checkStg(ctx, params);
  339. runnableRst.push(ctx.service.stagePay.getAuditorStageData(params.stage_id, params.stage_times, params.stage_order));
  340. runnableKey.push('stage_pay');
  341. break;
  342. case 'mem_stage_im_zl':
  343. runnableRst.push(ctx.service.reportMemory.getStageImZlData(params.tender_id, params.stage_id));
  344. runnableKey.push('mem_stage_im_zl');
  345. break;
  346. case 'mem_month_progress':
  347. runnableRst.push(ctx.service.reportMemory.getMonthProgress(params.tender_id));
  348. runnableKey.push('mem_month_progress');
  349. break;
  350. case 'change':
  351. runnableRst.push(ctx.service.change.getListByStatus(params.tender_id, 3)); // 获取所有审核通过的变更主信息
  352. runnableKey.push('change');
  353. break;
  354. case 'change_audit_list':
  355. runnableRst.push(ctx.service.changeAuditList.getChangeAuditBills(params.tender_id)); // 获取所有审核通过的变更清单
  356. runnableKey.push('change_audit_list');
  357. break;
  358. default:
  359. break;
  360. }
  361. }
  362. }
  363. const queryRst = await Promise.all(runnableRst);
  364. for (let idx = 0; idx < runnableKey.length; idx++) {
  365. rst[runnableKey[idx]] = queryRst[idx];
  366. }
  367. for (const filter of filters) {
  368. switch (filter) {
  369. case 'mem_stage_im_tz':
  370. rst[filter] = await ctx.service.reportMemory.getStageImTzData(params.tender_id, params.stage_id);
  371. break;
  372. case 'mem_stage_im_tz_bills':
  373. rst[filter] = await ctx.service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id);
  374. break;
  375. default:
  376. break;
  377. }
  378. }
  379. return rst;
  380. }
  381. async function getAllPagesCommon(ctx, rptTpl, params, option, outputType, baseDir) {
  382. // let rptTpl = null;
  383. const rptDataUtil = new rptDataExtractor();
  384. rptDataUtil.initialize(rptTpl);
  385. // console.log(rptTpl);
  386. const filter = rptDataUtil.getDataRequestFilter();
  387. // console.log(filter.tables);
  388. const rawDataObj = await getReportData(ctx, params, filter.tables);
  389. // console.log(rawDataObj);
  390. try {
  391. // console.log('before assemble');
  392. const tplData = rptDataUtil.assembleData(rawDataObj, baseDir);
  393. // console.log(tplData);
  394. const printCom = JpcEx.createNew();
  395. if (params.pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  396. if (params.orientation && (params.orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = params.orientation;
  397. let defProperties = await ctx.service.rptPreDefineCfg.getCfgById('Administrator');
  398. // console.log('defProperties: ');
  399. // console.log(defProperties[0].defined_content);
  400. defProperties = JSON.parse(defProperties[0].defined_content);
  401. if (params.custCfg) {
  402. setupCustomizeCfg(params.custCfg, rptTpl, defProperties);
  403. } else {
  404. // setupCustomizeCfg(defProperties, rptTpl, defProperties);
  405. }
  406. const dftOption = params.option || JV.PAGING_OPTION_NORMAL;
  407. printCom.initialize(rptTpl);
  408. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  409. const maxPages = printCom.totalPages;
  410. let pageRst = null;
  411. if (maxPages > 0) {
  412. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, params.custCfg);
  413. } else {
  414. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  415. }
  416. if (pageRst) {
  417. // fsUtil.writeObjToFile(pageRst, 'D:/GitHome/temp/testBuiltPageResult.jsp');
  418. } else {
  419. //
  420. }
  421. // console.log(pageRst);
  422. return pageRst;
  423. } catch (ex) {
  424. // console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  425. console.log(ex);
  426. }
  427. }
  428. async function getMultiRptsCommon(ctx, params, outputType, baseDir) {
  429. for (let idx = 0; idx < params.rpt_ids.length; idx++) {
  430. params.rpt_ids[idx] = parseInt(params.rpt_ids[idx]); // 转换一下,以防万一
  431. }
  432. const rptTpls = await ctx.service.rptTpl.getAllTplByIds(params.rpt_ids);
  433. // console.log(rptTpls);
  434. for (let rtIdx = 0; rtIdx < rptTpls.length; rtIdx++) {
  435. rptTpls[rtIdx] = JSON.parse(rptTpls[rtIdx].rpt_content);
  436. }
  437. const rptDataUtil = new rptDataExtractor();
  438. const filterTables = [];
  439. if (rptTpls.length > 1) {
  440. rptTpls.sort(function(item1, item2) {
  441. const i1 = (item1._doc) ? item1._doc : item1;
  442. const i2 = (item2._doc) ? item2._doc : item2;
  443. const ID1 = params.rpt_ids.indexOf(i1[JV.PROP_ID]);
  444. const ID2 = params.rpt_ids.indexOf(i2[JV.PROP_ID]);
  445. return ID1 - ID2;
  446. });
  447. }
  448. for (const rptTpl of rptTpls) {
  449. rptDataUtil.initialize(rptTpl);
  450. const filter = rptDataUtil.getDataRequestFilter();
  451. // console.log(filter);
  452. for (const table of filter.tables) {
  453. if (filterTables.indexOf(table) < 0) {
  454. filterTables.push(table);
  455. }
  456. }
  457. }
  458. const rawDataObj = await getReportData(ctx, params, filterTables);
  459. try {
  460. const rptPageRstArray = [];
  461. // 1. 这里只用一份数据,根据实际应用情况,先备份
  462. const backupData = {};
  463. for (let filterIdx = 0; filterIdx < filterTables.length; filterIdx++) {
  464. backupData[filterTables[filterIdx]] = [];
  465. Object.assign(backupData[filterTables[filterIdx]], rawDataObj[filterTables[filterIdx]]);
  466. }
  467. // 2. 一个一个模板创建数据
  468. let defProperties = await ctx.service.rptPreDefineCfg.getCfgById('Administrator');
  469. // console.log('defProperties: ');
  470. // console.log(defProperties[0].defined_content);
  471. defProperties = JSON.parse(defProperties[0].defined_content);
  472. for (let tplIdx = 0; tplIdx < rptTpls.length; tplIdx++) {
  473. const rptTpl = (rptTpls[tplIdx]._doc) ? rptTpls[tplIdx]._doc : rptTpls[tplIdx];
  474. rptDataUtil.initialize(rptTpl);
  475. const tplData = rptDataUtil.assembleData(rawDataObj, baseDir);
  476. const printCom = JpcEx.createNew();
  477. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  478. if (params.pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  479. if (params.orientation && (params.orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = params.orientation;
  480. if (params.custCfg) setupCustomizeCfg(params.custCfg, rptTpl, defProperties);
  481. const dftOption = params.option || JV.PAGING_OPTION_NORMAL;
  482. printCom.initialize(rptTpl);
  483. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  484. const maxPages = printCom.totalPages;
  485. let pageRst = null;
  486. if (maxPages > 0) {
  487. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, params.custCfg);
  488. } else {
  489. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  490. }
  491. rptPageRstArray.push(pageRst);
  492. // 注意:这里需要把备份数据assign回去!!!
  493. if (tplIdx < rptTpls.length - 1) {
  494. for (let filterIdx = 0; filterIdx < filterTables.length; filterIdx++) {
  495. backupData[filterTables[filterIdx]] = [];
  496. Object.assign(rawDataObj[filterTables[filterIdx]], backupData[filterTables[filterIdx]]);
  497. }
  498. }
  499. }
  500. return rptPageRstArray;
  501. } catch (ex) {
  502. console.log('报表数据异常(getMultiRptsCommon): project_id ' + params.project_id + ', tender_id: ' + params.tender_id + ', stage_id: ' + params.stage_id);
  503. console.log(ex);
  504. } finally {
  505. //
  506. }
  507. }
  508. function setupCustomizeCfg(customizeCfg, rptTpl, defProperties) {
  509. const tmpObj = {};
  510. // 1. 字体
  511. const newFonts = [];
  512. for (const font of defProperties.fonts) {
  513. const copyFont = {};
  514. copyFont.ID = font.ID;
  515. for (const fontProp of JV.FONT_PROPS) {
  516. copyFont[fontProp] = font[fontProp];
  517. }
  518. newFonts.push(copyFont);
  519. tmpObj[font.ID] = copyFont;
  520. }
  521. const private_setup_font = function(propStr, newFont) {
  522. if (tmpObj[propStr]) {
  523. tmpObj[propStr].Name = newFont.Name;
  524. tmpObj[propStr].FontHeight = String(newFont.FontHeight);
  525. tmpObj[propStr].FontBold = newFont.FontBold;
  526. tmpObj[propStr].FontItalic = newFont.FontItalic;
  527. tmpObj[propStr].FontUnderline = newFont.FontUnderline;
  528. }
  529. };
  530. for (const custFont of customizeCfg.fonts) {
  531. switch (custFont.CfgDispName) {
  532. case '表标题':
  533. private_setup_font('ReportTitle_Main', custFont);
  534. break;
  535. case '列标题':
  536. private_setup_font('HeaderColumn', custFont);
  537. private_setup_font('FooterColumn', custFont);
  538. break;
  539. case '正文内容':
  540. private_setup_font('Content', custFont);
  541. break;
  542. case '合计':
  543. private_setup_font('GrandTotal', custFont);
  544. private_setup_font('SectionTotal', custFont);
  545. break;
  546. case '表眉/表脚':
  547. private_setup_font('Header', custFont);
  548. private_setup_font('Footer', custFont);
  549. break;
  550. default:
  551. break;
  552. }
  553. }
  554. // 1.1 窄体
  555. if (tmpObj.Content_Narrow) {
  556. if (customizeCfg.isNarrow) {
  557. tmpObj.Content_Narrow.Name = 'Arial Narrow';
  558. } else {
  559. if (tmpObj.Content) {
  560. tmpObj.Content_Narrow.Name = tmpObj.Content.Name;
  561. } else {
  562. tmpObj.Content_Narrow.Name = '宋体';
  563. }
  564. }
  565. }
  566. defProperties.fonts = newFonts;
  567. // 2. 页边距
  568. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_LEFT] = customizeCfg.margins[JV.PROP_LEFT] / 10;
  569. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_RIGHT] = customizeCfg.margins[JV.PROP_RIGHT] / 10;
  570. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_TOP] = customizeCfg.margins[JV.PROP_TOP] / 10;
  571. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_BOTTOM] = customizeCfg.margins[JV.PROP_BOTTOM] / 10;
  572. // 3. 边框宽度
  573. if (customizeCfg.hasOwnProperty('borderThick')) {
  574. for (let i = 0; i < defProperties.styles.length; i++) {
  575. const style = defProperties.styles[i];
  576. if (style.ID === 'BORDER_ALL_AROUND') {
  577. for (const border of style.border_style) {
  578. border.LineWeight = customizeCfg.borderThick;
  579. }
  580. }
  581. }
  582. }
  583. // 4. 边框竖线
  584. if (!(customizeCfg.showVerticalLine)) {
  585. const private_copy_border = function(src) {
  586. const rst = {};
  587. rst.Position = src.Position;
  588. rst.LineWeight = src.LineWeight;
  589. rst.DashStyle = src.DashStyle;
  590. rst.Color = src.Color;
  591. return rst;
  592. };
  593. const newStyles = [];
  594. for (let i = 0; i < defProperties.styles.length; i++) {
  595. const style = defProperties.styles[i];
  596. newStyles.push(style);
  597. if (style.ID === 'BORDER_ALL_AROUND') {
  598. const newStyle = {};
  599. newStyle.ID = style.ID;
  600. newStyle.CfgDispName = style.CfgDispName;
  601. newStyle.border_style = [];
  602. for (const border of style.border_style) {
  603. const newBorder = private_copy_border(border);
  604. newStyle.border_style.push(newBorder);
  605. if (border.Position === 'Left' || border.Position === 'Right') {
  606. newBorder.LineWeight = 0;
  607. }
  608. }
  609. newStyles[newStyles.length - 1] = newStyle;
  610. }
  611. }
  612. defProperties.styles = newStyles;
  613. }
  614. // 5. 补0
  615. const private_Setup_Format = function(tabFields) {
  616. if (tabFields) {
  617. for (const tabField of tabFields) {
  618. if (tabField[JV.PROP_FORMAT]) {
  619. tabField[JV.PROP_FORMAT] = tabField[JV.PROP_FORMAT].replace(new RegExp('#', 'gm'), '0');
  620. }
  621. }
  622. }
  623. };
  624. if (customizeCfg.fillZero) {
  625. if (rptTpl[JV.NODE_FLOW_INFO]) {
  626. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS]);
  627. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_PAGE_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_PAGE_SUM][JV.PROP_SUM_FIELDS]);
  628. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_SEG_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_SEG_SUM][JV.PROP_SUM_FIELDS]);
  629. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  630. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  631. for (const discrete of rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  632. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  633. }
  634. }
  635. if (rptTpl[JV.NODE_FLOW_INFO_EX]) {
  636. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS]);
  637. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_PAGE_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_PAGE_SUM][JV.PROP_SUM_FIELDS]);
  638. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_SEG_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_SEG_SUM][JV.PROP_SUM_FIELDS]);
  639. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_SUM_FIELDS]);
  640. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  641. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  642. for (const discrete of rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  643. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  644. }
  645. }
  646. }
  647. } else if (rptTpl[JV.NODE_BILL_INFO]) {
  648. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_BILL_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_BILL_INFO][JV.NODE_BILL_CONTENT][JV.PROP_BILL_FIELDS]);
  649. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  650. for (const discrete of rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  651. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  652. }
  653. }
  654. } else if (rptTpl[JV.NODE_CROSS_INFO]) {
  655. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_CONTENT][JV.TAB_CROSS_FIELDS]);
  656. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW][JV.TAB_CROSS_FIELDS]);
  657. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL][JV.TAB_CROSS_FIELDS]);
  658. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL_SUM]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL_SUM][JV.TAB_CROSS_FIELDS]);
  659. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_EXT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_EXT][JV.TAB_CROSS_FIELDS]);
  660. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_SUM_EXT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_SUM_EXT][JV.TAB_CROSS_FIELDS]);
  661. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  662. for (const discrete of rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  663. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  664. }
  665. }
  666. }
  667. }
  668. }
  669. function isFileExisted(file) {
  670. return new Promise(function(resolve, reject) {
  671. fs.access(file, err => {
  672. if (err) {
  673. reject(false);
  674. } else {
  675. resolve(true);
  676. }
  677. });
  678. });
  679. }
  680. async function encodeSignatureDataUri(roleRel, baseDir) {
  681. if (roleRel) {
  682. for (const singleRoleRel of roleRel) {
  683. const roleRelContent = JSON.parse(singleRoleRel.rel_content);
  684. for (const role of roleRelContent) {
  685. // console.log(role);
  686. if (role.sign_path !== '') {
  687. const filePath = baseDir + '/app' + role.sign_path;
  688. try {
  689. const res = await isFileExisted(filePath);
  690. if (res) {
  691. const bData = fs.readFileSync(filePath);
  692. const base64Str = bData.toString('base64');
  693. const datauri = 'data:image/png;base64,' + base64Str;
  694. role.sign_pic = datauri;
  695. } else {
  696. console.log('文件不存在:' + filePath);
  697. }
  698. } catch (err) {
  699. console.error(err);
  700. }
  701. }
  702. }
  703. singleRoleRel.rel_content = JSON.stringify(roleRelContent);
  704. }
  705. }
  706. }
  707. async function encodeDummySignatureDataUri(pageRst, baseDir) {
  708. if (pageRst) {
  709. for (const page of pageRst.items) {
  710. for (const signature of page.signature_cells) {
  711. if (signature.signature_name === JV.SIGNATURE_NAME_DUMMY) {
  712. if (signature.path !== '') {
  713. const filePath = baseDir + '/app' + signature.path;
  714. try {
  715. const res = await isFileExisted(filePath);
  716. if (res) {
  717. const bData = fs.readFileSync(filePath);
  718. const base64Str = bData.toString('base64');
  719. const datauri = 'data:image/png;base64,' + base64Str;
  720. signature.pic = datauri;
  721. signature.path = '';
  722. } else {
  723. console.log('文件不存在:' + filePath);
  724. }
  725. } catch (err) {
  726. console.error(err);
  727. }
  728. }
  729. }
  730. }
  731. }
  732. }
  733. }