report_controller.js 67 KB

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