report_controller.js 50 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011
  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 auditConst = require('../const/audit');
  8. const accountGroup = require('../const/account_group').group;
  9. const JpcEx = require('../reports/rpt_component/jpc_ex');
  10. const JV = require('../reports/rpt_component/jpc_value_define');
  11. const rpt_xl_util = require('../reports/util/rpt_excel_util');
  12. const rptDataExtractor = require('../reports/util/rpt_calculation_data_util');
  13. const fsUtil = require('../public/js/fsUtil');
  14. const fs = require('fs');
  15. const rptCronJob = require('../reports/util/rpt_tmp_file_sweep');
  16. const RPT_DEF_PROPERTIES = require('../const/report_defined_properties');
  17. const reportConst = require('../const/report');
  18. module.exports = app => {
  19. class ReportController extends app.BaseController {
  20. /**
  21. * 报表显示页面
  22. *
  23. * @param {Object} ctx - egg全局context
  24. * @return {void}
  25. */
  26. async index(ctx) {
  27. try {
  28. const tender = ctx.tender;
  29. const stage = ctx.stage;
  30. // console.log(tender.data);
  31. // console.log(tender.info);
  32. let stage_id = -1;
  33. let stage_order = -1;
  34. let sorder = -1;
  35. let stage_times = -1;
  36. let stage_status = -1;
  37. const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
  38. const custCfg = await ctx.service.rptCustomizeCfg.getCustomizeCfgByUserId('Administrator');
  39. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  40. const prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.data.project_id);
  41. const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
  42. const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tender.id);
  43. // 分类列表
  44. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  45. // 获取用户权限
  46. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  47. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  48. // 获取用户可查看的标段
  49. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  50. for (const t of tenderList) {
  51. if (t.ledger_status === auditConst.ledger.status.checked) {
  52. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  53. if (t.lastStage) {
  54. await this.ctx.service.stage.checkStageGatherData(t.lastStage);
  55. }
  56. }
  57. }
  58. // 获取汇总表,历史选择
  59. const cid = this.ctx.helper._.map(treeNodes, 'id');
  60. const customSelects = {};
  61. if (ctx.stage) {
  62. customSelects.audit_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  63. reportConst.rptCustomType[JV.NODE_CUS_AUDIT_SELECT], ctx.tender.id, ctx.stage.id);
  64. customSelects.stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(
  65. params.stage_id, params.stage_times);
  66. } else {
  67. customSelects.audit_select = [];
  68. }
  69. customSelects.gather_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  70. reportConst.rptCustomType[JV.NODE_CUS_GATHER_SELECT], ctx.tender.id, -1);
  71. // const allTpls = await ctx.service.rptTpl.getAllTplByIds(tmpRptIds);
  72. // for (const tpl of allTpls) {
  73. // const fName = tpl.id + '_' + tpl.rpt_tpl_name + '.js';
  74. // console.log('fName: ' + fName);
  75. // fsUtil.writeObjToFile(tpl, 'D:/Temp/计量临时/' + fName);
  76. // }
  77. // 完成历史任务,下一批
  78. // const filePath = 'D:/Temp/计量临时/';
  79. // const tplFiles = [];
  80. // fs.readdir(filePath, (err, files) => {
  81. // if (err) throw err;
  82. // files.forEach(file => {
  83. // const fPath = filePath + file;
  84. // // console.log('\'' + fPath + '\'');
  85. // tplFiles.push(fPath);
  86. // });
  87. // });
  88. //
  89. // setTimeout(function() {
  90. // console.log(tplFiles);
  91. // }, 2000);
  92. // 下一批
  93. // let cnt = 0;
  94. // for (const file of rptFiles) {
  95. // const tplObj = JSON.parse(fs.readFileSync(file, 'utf-8'));
  96. // const rst = await ctx.service.rptTpl.insertRptTpl(tplObj);
  97. // cnt++;
  98. // console.log(file);
  99. // }
  100. // console.log(cnt + ' 完成!');
  101. // console.log(maxStageAmt[0].maxAmt);
  102. // 备注:在报表界面初始化的时候,暂时不需要check stage,只有在点中某张表的时候才需要(签名交互需要)
  103. // if ((stage === null || stage === undefined) && stageList.length > 0) {
  104. // await ctx.service.stage.checkStage(stageList[stageList.length - 1].id);
  105. // stage = ctx.stage;
  106. // console.log(stage);
  107. // }
  108. if (stage !== null && stage !== undefined) {
  109. stage_id = stage.id;
  110. stage_order = stage.order;
  111. sorder = stage.curOrder;
  112. stage_times = stage.times;
  113. stage_status = stage.status;
  114. }
  115. for (const prjAcc of prjAccList) {
  116. prjAcc.account_group = accountGroup[prjAcc.account_group];
  117. }
  118. const renderData = {
  119. tender: tender.data,
  120. tenderInfo: tender.info,
  121. rpt_tpl_data: JSON.stringify(treeNodes),
  122. cust_cfg: JSON.stringify(custCfg),
  123. project_id: tender.data.project_id,
  124. tender_id: tender.id,
  125. tender_name: tender.data.name,
  126. stg_id: stage_id,
  127. stg_order: stage_order,
  128. cur_order: sorder,
  129. stg_times: stage_times,
  130. stg_status: stage_status,
  131. stage_list: JSON.stringify(stageList),
  132. prj_account_list: JSON.stringify(prjAccList),
  133. role_list: JSON.stringify(roleList),
  134. used_list: JSON.stringify(usedList),
  135. tenderMenu,
  136. preUrl: '/tender/' + tender.id,
  137. measureType,
  138. categoryData,
  139. tenderList,
  140. auditConst,
  141. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  142. customSelects,
  143. rptCustomType: reportConst.rptCustomType,
  144. };
  145. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  146. // await this.layout('report/index.ejs', renderData);
  147. // 在这里启动一个cron job,删除临时创建的excel文件
  148. if (!rptCronJob.started) {
  149. try {
  150. // console.log('rptCronJob.started: ' + rptCronJob.started);
  151. rptCronJob.started = true;
  152. rptCronJob.createJob(null, this.app.baseDir + '/app/public/download');
  153. } catch (ex) {
  154. rptCronJob.started = false;
  155. }
  156. }
  157. } catch (err) {
  158. this.log(err);
  159. console.log(err);
  160. // ctx.redirect('/tender/' + ctx.tender.id);
  161. }
  162. }
  163. /**
  164. * 报表打印页面
  165. *
  166. * @param {Object} ctx - egg全局context
  167. * @return {void}
  168. */
  169. async showPrintPage(ctx) {
  170. try {
  171. // const params = JSON.parse(ctx.request.body.params);
  172. const pageSize = ctx.params.size;
  173. // console.log('pageSize: ' + pageSize);
  174. const renderData = {
  175. size: pageSize,
  176. // orientation: params.orientation,
  177. };
  178. if (pageSize === 'A3') {
  179. await ctx.render('report/rpt_printA3.ejs', renderData);
  180. } else {
  181. await ctx.render('report/rpt_print.ejs', renderData);
  182. }
  183. } catch (err) {
  184. this.log(err);
  185. console.log(err);
  186. }
  187. }
  188. async _getReport(ctx, params) {
  189. // console.log('in getReport');
  190. // console.log(params);
  191. let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
  192. if (!rptTpl || rptTpl.length !== 1) {
  193. throw '获取模板失败';
  194. }
  195. rptTpl = JSON.parse(rptTpl[0].rpt_content);
  196. // console.log('get the template!');
  197. const customSelect = rptTpl[JV.NODE_CUSTOM_DEFINE] && rptTpl[JV.NODE_CUSTOM_DEFINE][JV.NODE_CUS_AUDIT_SELECT].enable
  198. ? await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, params.stage_id, params.rpt_tpl_id)
  199. : await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, -1, params.rpt_tpl_id);
  200. const copyCustomSelect = this.ctx.helper.clone(customSelect);
  201. if (!params.gather_select && copyCustomSelect) {
  202. delete copyCustomSelect.gather_select;
  203. }
  204. const pageRst = await getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir, copyCustomSelect);
  205. // console.log(pageRst);
  206. // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  207. const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id, params.stage_id); // 新需求中,允许在非审核状态下设置签名
  208. const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  209. const stgAuditForOrg = await ctx.service.stageAudit.getStageAudit(params.stage_id, 1);
  210. // console.log('after role stage!');
  211. // console.log(roleRel);
  212. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  213. await encodeDummySignatureDataUri(pageRst, this.app.baseDir);
  214. const stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(params.stage_id, params.stage_times);
  215. // console.log('encodeSignatureDataUri!');
  216. return {
  217. data: pageRst,
  218. signatureRelInfo: roleRel,
  219. stageAudit: stgAudit,
  220. stageAuditOrg: stgAuditForOrg,
  221. debugInfo: ctx.app.config.is_debug ? ctx.debugInfo : null,
  222. customDefine: rptTpl[JV.NODE_CUSTOM_DEFINE],
  223. stageFlow,
  224. customSelect,
  225. };
  226. }
  227. /**
  228. * 获取报表数据
  229. *
  230. * @param {Object} ctx - egg全局context
  231. * @return {void}
  232. */
  233. async getReport(ctx) {
  234. try {
  235. // console.log('in getReport');
  236. const params = JSON.parse(ctx.request.body.params);
  237. ctx.body = await this._getReport(ctx, params);
  238. // // console.log(params);
  239. // let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
  240. // if (!rptTpl || rptTpl.length !== 1) {
  241. // throw '获取模板失败';
  242. // }
  243. // rptTpl = JSON.parse(rptTpl[0].rpt_content);
  244. // // console.log('get the template!');
  245. // const pageRst = await getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  246. // // console.log(pageRst);
  247. // // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  248. // const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id); // 新需求中,允许在非审核状态下设置签名
  249. // const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  250. // // console.log('after role stage!');
  251. // // console.log(roleRel);
  252. // await encodeSignatureDataUri(roleRel, this.app.baseDir);
  253. // await encodeDummySignatureDataUri(pageRst, this.app.baseDir);
  254. // const stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(params.stage_id, params.stage_times);
  255. // const customSelect = await ctx.service.rptCustomDefine.getDataByCondition({
  256. // tid: params.tender_id, sid: params.stage_id, rid: params.rpt_tpl_id
  257. // });
  258. //
  259. // // console.log('encodeSignatureDataUri!');
  260. // ctx.body = {
  261. // data: pageRst,
  262. // signatureRelInfo: roleRel,
  263. // stageAudit: stgAudit,
  264. // debugInfo: ctx.app.config.is_debug ? ctx.debugInfo : null,
  265. // customDefine: rptTpl[JV.NODE_CUSTOM_DEFINE],
  266. // stageFlow,
  267. // customSelect,
  268. // };
  269. // // ctx.body = { data: { msg: 'test the network' } };
  270. ctx.status = 201;
  271. } catch (ex) {
  272. console.log(ex);
  273. this.setMessage(ex.toString(), this.messageType.ERROR);
  274. }
  275. }
  276. /**
  277. * 获取多批次报表数据
  278. *
  279. * @param {Object} ctx - egg全局context
  280. * @return {void}
  281. */
  282. async getMultiReportsEx(ctx) {
  283. // 原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  284. const params = JSON.parse(ctx.request.body.params);
  285. await this._saveCustomSelects(params);
  286. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  287. const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id)) : [];
  288. // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  289. roleRel.sort(function(rr1, rr2) {
  290. return params.rpt_ids.indexOf(parseInt(rr1.rpt_id)) - params.rpt_ids.indexOf(parseInt(rr2.rpt_id));
  291. });
  292. // console.log('roleRel: ');
  293. // console.log(roleRel);
  294. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  295. for (const pageRst of pageRstArr) {
  296. await encodeDummySignatureDataUri(pageRst, this.app.baseDir);
  297. }
  298. // console.log(pageRstArr);
  299. ctx.body = { data: pageRstArr, signatureRelInfo: roleRel };
  300. ctx.status = 201;
  301. }
  302. async _saveCustomSelects(params) {
  303. console.log(params);
  304. for (const [i, cs] of params.customSelect.entries()) {
  305. if (!cs) continue;
  306. cs.tender_id = params.tender_id;
  307. cs.stage_id = params.stage_id;
  308. cs.rpt_tpl_id = params.rpt_ids[i];
  309. await this.ctx.service.rptCustomDefine.saveCustomSelect(cs);
  310. }
  311. }
  312. async createExcelFilesEx(ctx) {
  313. const params = JSON.parse(ctx.request.body.params);
  314. await this._saveCustomSelects(params);
  315. const baseDir = this.app.baseDir;
  316. function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
  317. return new Promise(function(resolve, reject) {
  318. rpt_xl_util.exportExcel(pageRst, params.pageSize, rpt_name, params.isOneSheet, null, null, baseDir, innerRoleRel,
  319. (err, uuidName) => {
  320. if (err) return reject(err);
  321. const fileRst = { uuid: uuidName, reportName: rpt_name };
  322. resolve(fileRst);
  323. }
  324. );
  325. });
  326. }
  327. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id)) : [];
  328. // const roleRel = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id)) : [];
  329. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  330. await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  331. const runnableRst = [];
  332. for (let idx = 0; idx < pageRstArr.length; idx++) {
  333. let roleRel = null;
  334. for (const roleR of roleRelArr) {
  335. if (roleR.rpt_id === params.rpt_ids[idx]) {
  336. roleRel = JSON.parse(roleR.rel_content);
  337. break;
  338. }
  339. }
  340. // console.log('roleRel.rel_content: ' + roleRel.rel_content);
  341. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/testBuiltPageResult.jsp');
  342. runnableRst.push(getExcelByPageData(pageRstArr[idx], params.rpt_names[idx], roleRel));
  343. }
  344. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/计量导出pageArr.js');
  345. const uuidRst = await Promise.all(runnableRst);
  346. ctx.body = { data: uuidRst };
  347. ctx.status = 201;
  348. }
  349. async createExcelFilesInOneBookEx(ctx) {
  350. const params = JSON.parse(ctx.request.body.params);
  351. const baseDir = this.app.baseDir;
  352. function getExcelByPageData(pageRstArr, rpt_name, innerRoleRel) {
  353. return new Promise(function(resolve, reject) {
  354. rpt_xl_util.exportExcelInOneBook(pageRstArr, params.pageSize, rpt_name, baseDir, innerRoleRel,
  355. (err, uuidName) => {
  356. if (err) return reject(err);
  357. const fileRst = { uuid: uuidName, reportName: rpt_name };
  358. resolve(fileRst);
  359. }
  360. );
  361. });
  362. }
  363. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id)) : [];
  364. const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  365. await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  366. const runnableRst = [];
  367. let rptRoleRelArr = [];
  368. const reAssignSignatureName = function(pageData, roleRel, rpt_name_key) {
  369. const keyMap = {};
  370. for (const pageItem of pageData.items) {
  371. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  372. if (!keyMap.hasOwnProperty(signCell.signature_name)) {
  373. keyMap[signCell.signature_name] = rpt_name_key + '_' + signCell.signature_name;
  374. }
  375. }
  376. }
  377. for (const pageItem of pageData.items) {
  378. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  379. if (keyMap.hasOwnProperty(signCell.signature_name)) {
  380. signCell.signature_name = keyMap[signCell.signature_name];
  381. }
  382. }
  383. }
  384. for (const roleSign of roleRel) {
  385. if (keyMap.hasOwnProperty(roleSign.signature_name)) {
  386. roleSign.signature_name = keyMap[roleSign.signature_name];
  387. }
  388. }
  389. // console.log('keyMap of : ' + rpt_name_key);
  390. // console.log(keyMap);
  391. };
  392. for (let idx = 0; idx < pageRstArr.length; idx++) {
  393. let roleRel = null;
  394. for (const roleR of roleRelArr) {
  395. if (roleR.rpt_id === params.rpt_ids[idx]) {
  396. roleRel = JSON.parse(roleR.rel_content);
  397. // 这里要做些电子签名的signature_name转换,以防重名
  398. reAssignSignatureName(pageRstArr[idx], roleRel, params.rpt_names[idx]);
  399. rptRoleRelArr = rptRoleRelArr.concat(roleRel);
  400. break;
  401. }
  402. }
  403. }
  404. runnableRst.push(getExcelByPageData(pageRstArr, params.rptName, rptRoleRelArr));
  405. const uuidRst = await Promise.all(runnableRst);
  406. ctx.body = { data: uuidRst };
  407. ctx.status = 201;
  408. }
  409. async getFileByUUID(ctx) {
  410. // console.log('downloading : ' + ctx.params.uuid);
  411. const uuid = ctx.params.uuid;
  412. const rptName = ctx.params.rptName;
  413. const suffix = '.' + ctx.params.suffix;
  414. try {
  415. const rptNameURI = encodeURI(rptName);
  416. const filePath = this.app.baseDir + '/app/public/download/';
  417. // console.log('filePath: ' + filePath);
  418. // await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  419. ctx.set({
  420. 'Content-Type': 'application/vnd.openxmlformats',
  421. 'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
  422. });
  423. ctx.body = await fs.readFileSync(filePath + uuid + suffix);
  424. } catch (e) {
  425. console.log(e);
  426. }
  427. }
  428. async setCustomDefine(ctx) {
  429. try {
  430. const data = JSON.parse(ctx.request.body.data);
  431. await this.ctx.service.rptCustomDefine.saveCustomSelect(data);
  432. // const sid = data.gather_select ? -1 : data.stage_id;
  433. // const filter = {tid: data.tender_id, sid: sid, rid: data.rpt_tpl_id};
  434. // const count = await ctx.service.rptCustomDefine.count(filter);
  435. // const updateData = {};
  436. // if (data.audit_select) updateData.audit_select = JSON.stringify(data.audit_select);
  437. // if (data.gather_select) updateData.gather_select = JSON.stringify(data.gather_select);
  438. // if (count > 0) {
  439. // await ctx.service.rptCustomDefine.update(updateData, filter);
  440. // } else {
  441. // updateData.tid = data.tender_id;
  442. // updateData.sid = sid;
  443. // updateData.rid = data.rpt_tpl_id;
  444. // await ctx.service.rptCustomDefine.db.insert(ctx.service.rptCustomDefine.tableName, updateData);
  445. // }
  446. const result = await this._getReport(ctx, data);
  447. ctx.body = {err: 0, msg: '', data: result};
  448. } catch (err) {
  449. ctx.helper.log(err);
  450. ctx.body = this.ajaxErrorBody(err, '保存数据出错');
  451. }
  452. }
  453. }
  454. return ReportController;
  455. };
  456. async function checkStg(ctx, params) {
  457. if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) {
  458. await ctx.service.stage.checkStage(params.stage_id);
  459. if (ctx.stage) {
  460. params.stage_order = ctx.stage.curOrder;
  461. }
  462. }
  463. }
  464. /*
  465. async function getReportData(ctx, params, filters, memFieldKeys) {
  466. const rst = {};
  467. const runnableRst = [];
  468. const runnableKey = []; // 这个配合runnableRst用,未来考虑并行查询优化
  469. // console.log('params');
  470. // console.log(params);
  471. // console.log('memFieldKeys');
  472. // console.log(memFieldKeys);
  473. for (const filter of filters) {
  474. if (runnableKey.indexOf(filter) < 0) {
  475. switch (filter) {
  476. case 'project' :
  477. runnableRst.push(ctx.service.project.getProjectById(params.project_id));
  478. runnableKey.push('project');
  479. break;
  480. case 'tender_info' :
  481. runnableRst.push(ctx.service.tenderInfo.getTenderInfo(params.tender_id));
  482. runnableKey.push('tender_info');
  483. break;
  484. case 'ledger' :
  485. runnableRst.push(ctx.service.ledger.getData(params.tender_id, 0));
  486. runnableKey.push('ledger');
  487. break;
  488. case 'deal_bills' :
  489. // console.log('has push deal_bills! ' + params.tender_id);
  490. runnableRst.push(ctx.service.dealBills.getDataByTenderId(params.tender_id));
  491. runnableKey.push('deal_bills');
  492. break;
  493. case 'stage_bills':
  494. runnableRst.push(ctx.service.stageBills.getLastestStageData(params.tender_id, params.stage_id));
  495. runnableKey.push('stage_bills');
  496. break;
  497. case 'stage_bills_final':
  498. await checkStg(ctx, params);
  499. // const stage = ctx.stage;
  500. // runnableRst.push(ctx.service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order));
  501. runnableRst.push(ctx.service.stageBillsFinal.getFinalDataEx(params.tender_id, ctx.stage.order));
  502. runnableKey.push('stage_bills_final');
  503. break;
  504. case 'stage':
  505. runnableRst.push(ctx.service.stage.getStageById(params.stage_id));
  506. runnableKey.push('stage');
  507. break;
  508. case 'stage_pay':
  509. await checkStg(ctx, params);
  510. // const stage2 = ctx.stage;
  511. // runnableRst.push(ctx.service.stagePay.getAuditorStageData(params.stage_id, params.stage_times, params.stage_order));
  512. runnableRst.push(ctx.service.stagePay.getAuditorStageData(params.stage_id, ctx.stage.times, ctx.stage.order));
  513. runnableKey.push('stage_pay');
  514. break;
  515. case 'mem_stage_im_zl':
  516. // memFieldKeys[filter]
  517. runnableRst.push(ctx.service.reportMemory.getStageImZlData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  518. runnableKey.push(filter);
  519. break;
  520. case 'mem_month_progress':
  521. runnableRst.push(ctx.service.reportMemory.getMonthProgress(params.tender_id, memFieldKeys[filter]));
  522. runnableKey.push(filter);
  523. break;
  524. case 'mem_stage_bills':
  525. runnableRst.push(ctx.service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  526. runnableKey.push(filter);
  527. break;
  528. case 'mem_stage_pos':
  529. runnableRst.push(ctx.service.reportMemory.getStagePosData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  530. runnableKey.push(filter);
  531. break;
  532. case 'mem_stage_bills_compare':
  533. runnableRst.push(ctx.service.reportMemory.getStagePosData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  534. runnableKey.push(filter);
  535. break;
  536. case 'change':
  537. runnableRst.push(ctx.service.change.getListByStatus(params.tender_id, 3)); // 获取所有审核通过的变更主信息
  538. runnableKey.push('change');
  539. break;
  540. case 'change_audit_list':
  541. runnableRst.push(ctx.service.changeAuditList.getChangeAuditBills(params.tender_id)); // 获取所有审核通过的变更清单
  542. runnableKey.push('change_audit_list');
  543. break;
  544. default:
  545. break;
  546. }
  547. }
  548. }
  549. const queryRst = await Promise.all(runnableRst);
  550. for (let idx = 0; idx < runnableKey.length; idx++) {
  551. rst[runnableKey[idx]] = queryRst[idx];
  552. }
  553. for (const filter of filters) {
  554. switch (filter) {
  555. case 'mem_stage_im_tz':
  556. rst[filter] = await ctx.service.reportMemory.getStageImTzData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  557. break;
  558. case 'mem_stage_im_tz_bills':
  559. rst[filter] = await ctx.service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  560. break;
  561. default:
  562. break;
  563. }
  564. }
  565. return rst;
  566. }
  567. */
  568. async function getAllPagesCommon(ctx, rptTpl, params, option, outputType, baseDir, customSelect) {
  569. const rptDataUtil = new rptDataExtractor();
  570. rptDataUtil.initialize(rptTpl);
  571. const filter = rptDataUtil.getDataRequestFilter();
  572. // console.log(filter.tables);
  573. const rawDataObj = await ctx.service.report.getReportData(params, filter.tables, filter.memFieldKeys,
  574. rptTpl[JV.NODE_CUSTOM_DEFINE], customSelect);
  575. await ctx.helper.saveBufferFile(JSON.stringify(rawDataObj, "", "\t"), ctx.app.baseDir + '/mem.json');
  576. // console.log(rawDataObj);
  577. try {
  578. const printCom = JpcEx.createNew();
  579. if (params.pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  580. if (params.orientation && (params.orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = params.orientation;
  581. // let defProperties = await ctx.service.rptPreDefineCfg.getCfgById('Administrator');
  582. // defProperties = JSON.parse(defProperties[0].defined_content);
  583. const defProperties = RPT_DEF_PROPERTIES;
  584. // console.log('defProperties: ');
  585. // console.log(defProperties);
  586. // console.log('before assemble');
  587. const tplData = rptDataUtil.assembleData(ctx, rawDataObj, baseDir, printCom, customSelect);
  588. // console.log(tplData);
  589. if (params.custCfg) {
  590. setupCustomizeCfg(params.custCfg, rptTpl, defProperties);
  591. } else {
  592. // setupCustomizeCfg(defProperties, rptTpl, defProperties);
  593. }
  594. const dftOption = params.option || JV.PAGING_OPTION_NORMAL;
  595. printCom.initialize(rptTpl);
  596. // ctx.helper
  597. printCom.analyzeData(ctx.helper, rptTpl, tplData, defProperties, dftOption, outputType, customSelect);
  598. // console.log(JSON.stringify(rptTpl));
  599. const maxPages = printCom.totalPages;
  600. let pageRst = null;
  601. if (maxPages > 0) {
  602. pageRst = printCom.outputAsSimpleJSONPageArray(ctx.helper, rptTpl, tplData, 1, maxPages, defProperties, params.custCfg, customSelect);
  603. } else {
  604. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  605. }
  606. // fsUtil.writeObjToFile(pageRst, 'D:/GitHome/temp/计量testBuiltPageResult.jsp');
  607. // console.log(pageRst);
  608. return pageRst;
  609. } catch (ex) {
  610. console.log("报表数据异常, tender id: " + params.tender_id);
  611. console.log(ex);
  612. }
  613. }
  614. async function getMultiRptsCommon(ctx, params, outputType, baseDir) {
  615. const needCustomTables = ['mem_gather_stage_bills', 'mem_gather_deal_bills', 'mem_gather_stage_pay', 'mem_gather_tender_info'];
  616. for (let idx = 0; idx < params.rpt_ids.length; idx++) {
  617. params.rpt_ids[idx] = parseInt(params.rpt_ids[idx]); // 转换一下,以防万一
  618. }
  619. const rptTpls = await ctx.service.rptTpl.getAllTplByIds(params.rpt_ids);
  620. rptTpls.sort(function(rpt1, rpt2) {
  621. return params.rpt_ids.indexOf(rpt1.id) - params.rpt_ids.indexOf(rpt2.id);
  622. });
  623. for (let rtIdx = 0; rtIdx < rptTpls.length; rtIdx++) {
  624. const id = rptTpls[rtIdx].id;
  625. rptTpls[rtIdx] = JSON.parse(rptTpls[rtIdx].rpt_content);
  626. rptTpls[rtIdx].id = id;
  627. }
  628. const rptDataUtil = new rptDataExtractor();
  629. const filterTables = [];
  630. const memFieldKeys = {};
  631. if (rptTpls.length > 1) {
  632. rptTpls.sort(function(item1, item2) {
  633. const i1 = (item1._doc) ? item1._doc : item1;
  634. const i2 = (item2._doc) ? item2._doc : item2;
  635. const ID1 = params.rpt_ids.indexOf(i1[JV.PROP_ID]);
  636. const ID2 = params.rpt_ids.indexOf(i2[JV.PROP_ID]);
  637. return ID1 - ID2;
  638. });
  639. }
  640. for (const rptTpl of rptTpls) {
  641. rptDataUtil.initialize(rptTpl);
  642. const filter = rptDataUtil.getDataRequestFilter();
  643. // console.log(filter);
  644. for (const table of filter.tables) {
  645. if (filterTables.indexOf(table) < 0 && needCustomTables.indexOf(table) < 0) {
  646. filterTables.push(table);
  647. }
  648. // memFieldKeys[table] = [];
  649. }
  650. for (const tableKeyProp in filter.memFieldKeys) {
  651. if (needCustomTables.indexOf(tableKeyProp) >= 0) continue;
  652. if (!memFieldKeys.hasOwnProperty(tableKeyProp)) {
  653. memFieldKeys[tableKeyProp] = [];
  654. }
  655. for (const mfKey of filter.memFieldKeys[tableKeyProp]) {
  656. if (memFieldKeys[tableKeyProp].indexOf(mfKey) < 0) {
  657. memFieldKeys[tableKeyProp].push(mfKey);
  658. }
  659. }
  660. }
  661. }
  662. const rawDataObj = await ctx.service.report.getReportData(params, filterTables, memFieldKeys, {}, {});
  663. try {
  664. const rptPageRstArray = [];
  665. // 1. 这里只用一份数据,根据实际应用情况,先备份
  666. // const backupData = {};
  667. // for (let filterIdx = 0; filterIdx < filterTables.length; filterIdx++) {
  668. // backupData[filterTables[filterIdx]] = [];
  669. // Object.assign(backupData[filterTables[filterIdx]], rawDataObj[filterTables[filterIdx]]);
  670. // }
  671. // 2. 一个一个模板创建数据
  672. // let defProperties = await ctx.service.rptPreDefineCfg.getCfgById('Administrator');
  673. // defProperties = JSON.parse(defProperties[0].defined_content);
  674. const defProperties = RPT_DEF_PROPERTIES;
  675. for (let tplIdx = 0; tplIdx < rptTpls.length; tplIdx++) {
  676. const rptTpl = (rptTpls[tplIdx]._doc) ? rptTpls[tplIdx]._doc : rptTpls[tplIdx];
  677. rptDataUtil.initialize(rptTpl);
  678. const customSelect = rptTpl[JV.NODE_CUSTOM_DEFINE] && rptTpl[JV.NODE_CUSTOM_DEFINE][JV.NODE_CUS_AUDIT_SELECT].enable
  679. ? await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, params.stage_id, rptTpl.id)
  680. : await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, -1, rptTpl.id);
  681. // 从汇总的rawDataObj中拷贝所需数据表至curRawDataObj,以供后续使用
  682. const curRawDataObj = {};
  683. const filter = rptDataUtil.getDataRequestFilter();
  684. for (const table of filter.tables) {
  685. curRawDataObj[table] = ctx.helper.clone(rawDataObj[table]);
  686. }
  687. // 如果是用户交互类型的表,则应该单独获取数据
  688. if (params.customSelect && params.customSelect[tplIdx]) {
  689. const cfTables = [], cmFieldKeys = [];
  690. const curFilter = rptDataUtil.getDataRequestFilter();
  691. for (const table of curFilter.tables) {
  692. if (needCustomTables.indexOf(table) >= 0) {
  693. cfTables.push(table);
  694. }
  695. }
  696. for (const tableKeyProp in filter.memFieldKeys) {
  697. if (needCustomTables.indexOf(tableKeyProp) < 0) continue;
  698. if (!cmFieldKeys.hasOwnProperty(tableKeyProp)) {
  699. cmFieldKeys[tableKeyProp] = [];
  700. }
  701. for (const mfKey of filter.memFieldKeys[tableKeyProp]) {
  702. if (cmFieldKeys[tableKeyProp].indexOf(mfKey) < 0) {
  703. cmFieldKeys[tableKeyProp].push(mfKey);
  704. }
  705. }
  706. }
  707. console.log(customSelect);
  708. const customRawDataObj = await ctx.service.report.getReportData(params, cfTables, cmFieldKeys,
  709. rptTpl[JV.NODE_CUSTOM_DEFINE], customSelect);
  710. console.log(customRawDataObj);
  711. for (const prop in customRawDataObj) {
  712. curRawDataObj[prop] = customRawDataObj[prop];
  713. }
  714. }
  715. const tplData = rptDataUtil.assembleData(ctx, curRawDataObj, baseDir, null, customSelect);
  716. const printCom = JpcEx.createNew();
  717. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  718. if (params.pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  719. if (params.orientation && (params.orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = params.orientation;
  720. if (params.custCfg) setupCustomizeCfg(params.custCfg, rptTpl, defProperties);
  721. const dftOption = params.option || JV.PAGING_OPTION_NORMAL;
  722. printCom.initialize(rptTpl);
  723. // console.log(rptTpl);
  724. printCom.analyzeData(ctx.helper, rptTpl, tplData, defProperties, dftOption, outputType, customSelect);
  725. const maxPages = printCom.totalPages;
  726. let pageRst = null;
  727. // console.log(maxPages);
  728. if (maxPages > 0) {
  729. pageRst = printCom.outputAsSimpleJSONPageArray(ctx.helper, rptTpl, tplData, 1, maxPages, defProperties, params.custCfg, customSelect);
  730. } else {
  731. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  732. }
  733. rptPageRstArray.push(pageRst);
  734. // 注意:这里需要把备份数据assign回去!!!
  735. // if (tplIdx < rptTpls.length - 1) {
  736. // for (let filterIdx = 0; filterIdx < filterTables.length; filterIdx++) {
  737. // backupData[filterTables[filterIdx]] = [];
  738. // Object.assign(rawDataObj[filterTables[filterIdx]], backupData[filterTables[filterIdx]]);
  739. // }
  740. // }
  741. }
  742. return rptPageRstArray;
  743. } catch (ex) {
  744. console.log('报表数据异常(getMultiRptsCommon): project_id ' + params.project_id + ', tender_id: ' + params.tender_id + ', stage_id: ' + params.stage_id);
  745. console.log(ex);
  746. } finally {
  747. //
  748. }
  749. }
  750. function setupCustomizeCfg(customizeCfg, rptTpl, defProperties) {
  751. const tmpObj = {};
  752. // 1. 字体
  753. const newFonts = [];
  754. for (const font of defProperties.fonts) {
  755. const copyFont = {};
  756. copyFont.ID = font.ID;
  757. for (const fontProp of JV.FONT_PROPS) {
  758. copyFont[fontProp] = font[fontProp];
  759. }
  760. newFonts.push(copyFont);
  761. tmpObj[font.ID] = copyFont;
  762. }
  763. const private_setup_font = function(propStr, newFont) {
  764. if (tmpObj[propStr]) {
  765. tmpObj[propStr].Name = newFont.Name;
  766. tmpObj[propStr].FontHeight = String(newFont.FontHeight);
  767. tmpObj[propStr].FontBold = newFont.FontBold;
  768. tmpObj[propStr].FontItalic = newFont.FontItalic;
  769. tmpObj[propStr].FontUnderline = newFont.FontUnderline;
  770. }
  771. };
  772. for (const custFont of customizeCfg.fonts) {
  773. switch (custFont.CfgDispName) {
  774. case '表标题':
  775. private_setup_font('ReportTitle_Main', custFont);
  776. break;
  777. case '列标题':
  778. private_setup_font('HeaderColumn', custFont);
  779. private_setup_font('FooterColumn', custFont);
  780. break;
  781. case '正文内容':
  782. private_setup_font('Content', custFont);
  783. break;
  784. case '合计':
  785. private_setup_font('GrandTotal', custFont);
  786. private_setup_font('SectionTotal', custFont);
  787. break;
  788. case '表眉/表脚':
  789. private_setup_font('Header', custFont);
  790. private_setup_font('Footer', custFont);
  791. break;
  792. default:
  793. break;
  794. }
  795. }
  796. // 1.1 窄体
  797. if (tmpObj.Content_Narrow) {
  798. if (customizeCfg.isNarrow) {
  799. tmpObj.Content_Narrow.Name = 'Arial Narrow';
  800. } else {
  801. if (tmpObj.Content) {
  802. tmpObj.Content_Narrow.Name = tmpObj.Content.Name;
  803. } else {
  804. tmpObj.Content_Narrow.Name = '宋体';
  805. }
  806. }
  807. }
  808. defProperties.fonts = newFonts;
  809. // 2. 页边距
  810. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_LEFT] = customizeCfg.margins[JV.PROP_LEFT] / 10;
  811. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_RIGHT] = customizeCfg.margins[JV.PROP_RIGHT] / 10;
  812. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_TOP] = customizeCfg.margins[JV.PROP_TOP] / 10;
  813. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_BOTTOM] = customizeCfg.margins[JV.PROP_BOTTOM] / 10;
  814. // 3. 边框宽度
  815. if (customizeCfg.hasOwnProperty('borderThick')) {
  816. for (let i = 0; i < defProperties.styles.length; i++) {
  817. const style = defProperties.styles[i];
  818. if (style.ID === 'BORDER_ALL_AROUND') {
  819. for (const border of style.border_style) {
  820. border.LineWeight = customizeCfg.borderThick;
  821. }
  822. }
  823. }
  824. }
  825. // 4. 边框竖线
  826. if (!(customizeCfg.showVerticalLine)) {
  827. const private_copy_border = function(src) {
  828. const rst = {};
  829. rst.Position = src.Position;
  830. rst.LineWeight = src.LineWeight;
  831. rst.DashStyle = src.DashStyle;
  832. rst.Color = src.Color;
  833. return rst;
  834. };
  835. const newStyles = [];
  836. for (let i = 0; i < defProperties.styles.length; i++) {
  837. const style = defProperties.styles[i];
  838. newStyles.push(style);
  839. if (style.ID === 'BORDER_ALL_AROUND') {
  840. const newStyle = {};
  841. newStyle.ID = style.ID;
  842. newStyle.CfgDispName = style.CfgDispName;
  843. newStyle.border_style = [];
  844. for (const border of style.border_style) {
  845. const newBorder = private_copy_border(border);
  846. newStyle.border_style.push(newBorder);
  847. if (border.Position === 'Left' || border.Position === 'Right') {
  848. newBorder.LineWeight = 0;
  849. }
  850. }
  851. newStyles[newStyles.length - 1] = newStyle;
  852. }
  853. }
  854. defProperties.styles = newStyles;
  855. }
  856. // 5. 补0
  857. const private_Setup_Format = function(tabFields) {
  858. if (tabFields) {
  859. for (const tabField of tabFields) {
  860. if (tabField[JV.PROP_FORMAT]) {
  861. tabField[JV.PROP_FORMAT] = tabField[JV.PROP_FORMAT].replace(new RegExp('#', 'gm'), '0');
  862. }
  863. }
  864. }
  865. };
  866. if (customizeCfg.fillZero) {
  867. if (rptTpl[JV.NODE_FLOW_INFO]) {
  868. 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]);
  869. 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]);
  870. 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]);
  871. 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]);
  872. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  873. for (const discrete of rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  874. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  875. }
  876. }
  877. if (rptTpl[JV.NODE_FLOW_INFO_EX]) {
  878. 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]);
  879. 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]);
  880. 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]);
  881. 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]);
  882. 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]);
  883. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  884. for (const discrete of rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  885. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  886. }
  887. }
  888. }
  889. } else if (rptTpl[JV.NODE_BILL_INFO]) {
  890. 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]);
  891. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  892. for (const discrete of rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  893. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  894. }
  895. }
  896. } else if (rptTpl[JV.NODE_CROSS_INFO]) {
  897. 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]);
  898. 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]);
  899. 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]);
  900. 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]);
  901. 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]);
  902. 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]);
  903. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  904. for (const discrete of rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  905. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  906. }
  907. }
  908. }
  909. }
  910. }
  911. function isFileExisted(file) {
  912. return new Promise(function(resolve, reject) {
  913. fs.access(file, err => {
  914. if (err) {
  915. reject(false);
  916. } else {
  917. resolve(true);
  918. }
  919. });
  920. });
  921. }
  922. async function encodeSignatureDataUri(roleRel, baseDir) {
  923. if (roleRel) {
  924. for (const singleRoleRel of roleRel) {
  925. const roleRelContent = JSON.parse(singleRoleRel.rel_content);
  926. for (const role of roleRelContent) {
  927. // console.log(role);
  928. if (role.sign_path !== '') {
  929. const filePath = baseDir + '/app' + role.sign_path;
  930. try {
  931. const res = await isFileExisted(filePath);
  932. if (res) {
  933. const bData = fs.readFileSync(filePath);
  934. const base64Str = bData.toString('base64');
  935. const datauri = 'data:image/png;base64,' + base64Str;
  936. role.sign_pic = datauri;
  937. } else {
  938. console.log('文件不存在:' + filePath);
  939. }
  940. } catch (err) {
  941. console.error(err);
  942. }
  943. }
  944. }
  945. singleRoleRel.rel_content = JSON.stringify(roleRelContent);
  946. }
  947. }
  948. }
  949. async function encodeDummySignatureDataUri(pageRst, baseDir) {
  950. if (pageRst) {
  951. for (const page of pageRst.items) {
  952. for (const signature of page.signature_cells) {
  953. if (signature.signature_name === JV.SIGNATURE_NAME_DUMMY) {
  954. if (signature.path !== '') {
  955. const filePath = baseDir + '/app' + signature.path;
  956. try {
  957. const res = await isFileExisted(filePath);
  958. if (res) {
  959. const bData = fs.readFileSync(filePath);
  960. const base64Str = bData.toString('base64');
  961. const datauri = 'data:image/png;base64,' + base64Str;
  962. signature.pic = datauri;
  963. signature.path = '';
  964. } else {
  965. console.log('文件不存在:' + filePath);
  966. }
  967. } catch (err) {
  968. console.error(err);
  969. }
  970. }
  971. }
  972. }
  973. }
  974. }
  975. }