report_controller.js 45 KB

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