report_controller.js 33 KB

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