report_controller.js 55 KB

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