report_controller.js 119 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314
  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 advanceConst = require('../const/advance');
  20. const typeConsts = require('../const/advance');
  21. // const stringUtil = require('../public/js/string_util_light');
  22. const needCustomTables = [
  23. 'mem_custom_select',
  24. 'mem_gather_stage_bills', 'mem_gather_deal_bills', 'mem_gather_stage_pay', 'mem_gather_tender_info',
  25. 'mem_stage_sum_bills', 'mem_stage_sum_pay',
  26. 'mem_jh_gather_im_change', 'mem_jh_im_change', 'mem_jh_gather_stage_bills_compare',
  27. 'mem_material_sum_gl',
  28. ];
  29. const PermissionCheck = require('../const/account_permission').PermissionCheck;
  30. const STD_COMP_STAMP_SIZE_WIDTH = Math.round(5 * 96 / 2.54); // 公章标准尺寸(宽4.2厘米)转成像素
  31. const STD_COMP_STAMP_SIZE_HEIGHT = STD_COMP_STAMP_SIZE_WIDTH; // 公章标准尺寸(高4.2厘米)转成像素
  32. const NORMAL_SIGN_STR = 'normal_sign';
  33. const COMPANY_SIGN_STR = 'company_stamp';
  34. const PRIVATE_SIGN_STR = 'private_stamp';
  35. const sourceTypeConst = require('../const/source_type');
  36. const rptBusiness = require('../const/rpt_archive');
  37. module.exports = app => {
  38. class ReportController extends app.BaseController {
  39. /**
  40. * 获取审批界面所需的 原报、审批人数据等
  41. * @param {Object} ctx - egg全局context
  42. * @return {void}
  43. * @private
  44. */
  45. async _getStageAuditViewData(ctx) {
  46. if (!ctx.stage) return;
  47. await ctx.service.stage.loadStageAuditViewData(ctx.stage);
  48. }
  49. async _chkIfStageAuditor(ctx, stage) {
  50. //
  51. }
  52. async _filterStageList(ctx, stageList) {
  53. //
  54. // throw
  55. }
  56. async _getCustFolder(ctx, acc_id, tender_id) {
  57. const rst = [];
  58. // 因新需求,将增加tender_id作为定制化显示,但考虑到无缝链接,还是保留acc_id的判断:
  59. const custFolders1 = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(acc_id);
  60. const custFolders2 = await ctx.service.rptTreeNodeCust.getCustFolderByTenderId(tender_id);
  61. // 1. 两种条件都要查询结果,然后:
  62. // 1.1. 两种条件都没有,返回空数组
  63. // 1.2. 两种条件都有,返回tender_id的,删除acc_id的
  64. // 1.3. 只有acc_id的,那么:
  65. // 1.3.1 增加新记录,用tender_id作为索引保存(acc_id = -1);
  66. // 1.3.2 删除acc_id的这条记录,返回tender_id的这条记录
  67. // 1.4. 只有tender_id的,返回这条记录
  68. if (custFolders1.length > 0) {
  69. if (custFolders2.length > 0) {
  70. rst.push(custFolders2[0]);
  71. } else {
  72. await ctx.service.rptTreeNodeCust.createCustNodeByTenderId(acc_id, tender_id, custFolders1[0].rpt_tpl_items);
  73. rst.push(custFolders1[0]); // 直接拿原先的用了
  74. }
  75. // 现在会记录最后一个修改用户的id,所以不能直接删除,需要先判断
  76. if (custFolders1[0].id !== custFolders2[0].id) await ctx.service.rptTreeNodeCust.removeCustFolder(custFolders1[0].id);
  77. } else if (custFolders2.length > 0) {
  78. rst.push(custFolders2[0]);
  79. }
  80. return rst;
  81. }
  82. async _createNodes(ctx, source_type, pid) {
  83. const treeNodes = await ctx.service.rptTreeNode.getNodesBySourceType([pid], source_type); // 这个查定制的
  84. const commonTreeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1]); // 这个查通用的
  85. const allTreeNodes = await ctx.service.rptTreeNode.getAllNodes([-1]); // 这个得到所有通用的(新业务需求)
  86. const allTreeItems = JSON.parse(allTreeNodes[0].items);
  87. const allIndivTreeNodes = await ctx.service.rptTreeNode.getAllNodes([pid]); // 这个得到所有定制的(新业务需求)
  88. // const allIndivTreeItems = JSON.parse(allIndivTreeNodes[0].items);
  89. const allIndivTreeItems = [];
  90. allIndivTreeNodes.forEach(indiTreeNode => {
  91. const newTopIndivNode = {
  92. ID: indiTreeNode.id || -1,
  93. name: indiTreeNode.name || '',
  94. // rpt_type: indiTreeNode.rpt_type || 1,
  95. source_type: indiTreeNode.source_type,
  96. // isParent: true,
  97. nodeType: 1,
  98. items: JSON.parse(indiTreeNode.items),
  99. };
  100. // allIndivTreeItems.push(...JSON.parse(indiTreeNode.items));
  101. allIndivTreeItems.push(newTopIndivNode);
  102. });
  103. const nodeItems = JSON.parse(commonTreeNodes[0].items);
  104. const commonArrs = [];
  105. nodeItems.forEach(nodeItem => {
  106. const srcType = nodeItem.source_type ? nodeItem.source_type : 1;
  107. if (srcType === source_type) {
  108. commonArrs.push(nodeItem);
  109. }
  110. });
  111. // 加一个dummy的通用报表
  112. const dummyCommonRptNode = { id: 1, name: '通用报表', pid: -1, rpt_type: 0, items: JSON.stringify(commonArrs) };
  113. treeNodes.push(dummyCommonRptNode);
  114. const custCfg = await ctx.service.rptCustomizeCfg.getCustomizeCfgByUserId('Administrator');
  115. return { treeNodes, commonArrs, custCfg, allTreeItems, allIndivTreeItems };
  116. }
  117. async _getInvolveAcc(ctx, tId) {
  118. // 获取所有项目参与者
  119. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  120. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  121. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  122. });
  123. const newAccountGroup = accountGroup.map((item, idx) => {
  124. const groupList = accountList.filter(item => item.account_group === idx);
  125. return { groupName: item, groupList };
  126. });
  127. const where = { tid: tId };
  128. const advance = await ctx.service.advance.getAllDataByCondition({
  129. columns: ['id', 'order', 'status', 'selected', 'type'],
  130. where,
  131. orders: [['type', 'asc'], ['create_time', 'desc']],
  132. });
  133. advance.forEach(x => {
  134. x.statusStr = auditConst.advance.statusString[x.status];
  135. x.typeStr = advanceConst.typeColMap[x.type].text;
  136. });
  137. return { accountList, newAccountGroup, advance };
  138. }
  139. /**
  140. * 报表显示页面
  141. *
  142. * @param {Object} ctx - egg全局context
  143. * @return {void}
  144. */
  145. async index(ctx) {
  146. // 普通情况(计量期入口)
  147. try {
  148. await this._getStageAuditViewData(ctx);
  149. const pageShow = ctx.session.sessionProject.page_show;
  150. pageShow.showArchive = 1;
  151. const tender = ctx.tender;
  152. const stage = ctx.stage;
  153. let stage_id = -1;
  154. let stage_order = -1;
  155. let sorder = -1;
  156. let stage_times = -1;
  157. let stage_status = -1;
  158. const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
  159. // const custTreeFolders = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
  160. const custTreeFolders = await this._getCustFolder(ctx, this.ctx.session.sessionUser.accountId, tender.id);
  161. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  162. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: tender.data.project_id } }); // 找公司章用的
  163. // 以后还有预付款、材差
  164. // const advanceType = typeConsts.typeCol.find(item => item.key === 'start');
  165. // const advanceList = await ctx.service.advance.getAdvanceListDirectly(tender.id, advanceType.type);
  166. const advanceList = await ctx.service.advance.getAdvanceListDirectly(tender.id);
  167. const advanceAuditList = await ctx.service.advanceAudit.getAuditAdvanceByTender(tender.id);
  168. // const materialList = await ctx.service.advance.getValidMaterials(tender.id);
  169. const isAdmin = ctx.session.sessionUser.is_admin;
  170. // console.log('this.ctx.session.sessionUser.accountId: ' + this.ctx.session.sessionUser.accountId);
  171. if (stage && stage.status === auditConst.stage.status.uncheck) {
  172. // 得判断账号是否在审核人列表中(不含原报)
  173. if (stage.auditorList === undefined || stage.auditorList === null) {
  174. stage.auditorList = await ctx.service.stageAudit.getAuditors(ctx.stage.id, ctx.stage.times);
  175. }
  176. let isAudit = false;
  177. for (const audit of stage.auditorList) {
  178. if (audit.aid === this.ctx.session.sessionUser.accountId) {
  179. isAudit = true;
  180. break;
  181. }
  182. }
  183. if (isAudit) {
  184. throw '未上报!';
  185. }
  186. } else {
  187. // 剔除未上报期(审核人(非原报人)才需要判断)
  188. for (let idx = stageList.length - 1; idx >= 0; idx--) {
  189. if (stageList[idx].status === auditConst.stage.status.uncheck) {
  190. if (stageList[idx].auditorList === undefined || stageList[idx].auditorList === null) {
  191. stageList[idx].auditorList = await ctx.service.stageAudit.getAuditors(stageList[idx].id, stageList[idx].times);
  192. }
  193. let isAudit = false;
  194. for (const audit of stageList[idx].auditorList) {
  195. if (audit.aid === this.ctx.session.sessionUser.accountId) {
  196. isAudit = true;
  197. break;
  198. }
  199. }
  200. if (isAudit) {
  201. stageList.splice(idx, 1);
  202. }
  203. }
  204. }
  205. }
  206. let lastAuditor = null;
  207. if (stage) {
  208. lastAuditor = await ctx.service.stageAudit.getLastestAuditor(ctx.stage.id, ctx.stage.times, auditConst.stage.status.checked);
  209. } else {
  210. lastAuditor = stageList.length > 0 ? await ctx.service.stageAudit.getLastestAuditor(stageList[stageList.length - 1].id, stageList[stageList.length - 1].times, auditConst.stage.status.checked) : null;
  211. }
  212. let archiveList = [];
  213. if (stage) {
  214. const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
  215. if (archives.length > 0) {
  216. archiveList = JSON.parse(archives[0].content);
  217. }
  218. } else {
  219. const archives = stageList.length > 0 ? await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id) : [];
  220. // console.log(archives);
  221. if (archives && archives.length > 0) {
  222. archiveList = JSON.parse(archives[0].content);
  223. }
  224. }
  225. let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.data.project_id);
  226. prjAccList = prjAccList.filter(pa => pa.enable !== 0);
  227. const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
  228. const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tender.id);
  229. // ctx.session.sessionUser.is_admin
  230. // const pageShow = ctx.session.sessionProject.page_show;
  231. // 根据需求,如果开启了‘开启个人「签字」’功能,则只能是本身用户签名,管理员例外
  232. if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
  233. // 削减其他account
  234. const newAccList = [];
  235. for (const acc of prjAccList) {
  236. if (acc.id === this.ctx.session.sessionUser.accountId) {
  237. newAccList.push(acc);
  238. }
  239. }
  240. prjAccList = newAccList;
  241. }
  242. // 分类列表
  243. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  244. // 获取用户权限
  245. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  246. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  247. // 获取用户可查看的标段
  248. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  249. for (const t of tenderList) {
  250. if (t.ledger_status === auditConst.ledger.status.checked) {
  251. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  252. // if (t.lastStage) {
  253. // await this.ctx.service.stage.checkStageGatherData(t.lastStage, this.ctx.session.sessionUser.is_admin);
  254. // }
  255. }
  256. }
  257. // 获取汇总表,历史选择
  258. const cid = this.ctx.helper._.map(treeNodes, 'id');
  259. const customSelects = {};
  260. if (ctx.stage) {
  261. customSelects.audit_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  262. reportConst.rptCustomType[JV.NODE_CUS_AUDIT_SELECT], ctx.tender.id, ctx.stage.id);
  263. customSelects.stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(
  264. ctx.stage.stage_id, ctx.stage.stage_times);
  265. customSelects.stageFlow.forEach(x => {
  266. if (!x) return;
  267. x.visible = (!ctx.session.sessionUser.is_admin && ctx.session.sessionProject.page_show.individualSign === 1)
  268. ? x.aid === ctx.session.sessionUser.accountId : true;
  269. });
  270. } else {
  271. customSelects.audit_select = [];
  272. }
  273. customSelects.gather_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  274. reportConst.rptCustomType[JV.NODE_CUS_GATHER_SELECT], ctx.tender.id, -1);
  275. customSelects.stage_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  276. reportConst.rptCustomType[JV.NODE_CUS_STAGE_SELECT], ctx.tender.id, -1);
  277. customSelects.change_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  278. reportConst.rptCustomType[JV.NODE_CUS_CHANGE_SELECT], ctx.tender.id, -1);
  279. customSelects.material_sum_select = await ctx.service.rptCustomDefine.getCustomSelectByRpt(cid,
  280. reportConst.rptCustomType[JV.NODE_CUS_MATERIAL_SUM_SELECT], ctx.tender.id, -1);
  281. const dataSelects = {};
  282. dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
  283. reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);
  284. const materialList = await ctx.service.material.getValidMaterials(ctx.tender.id);
  285. const materialAdjAuditList = await ctx.service.materialAudit.getAuditorsByTender(tender.id);
  286. if (stage !== null && stage !== undefined) {
  287. stage_id = stage.id;
  288. stage_order = stage.order;
  289. sorder = stage.curOrder;
  290. stage_times = stage.times;
  291. stage_status = stage.status;
  292. }
  293. for (const prjAcc of prjAccList) {
  294. prjAcc.account_group = prjAcc.company;
  295. }
  296. const cust_select_keys = JSON.stringify(['common', 'customize']); // 因其他地方也有可能保存用户报表的显示选择项,因当初设计问题,不好改数据库结构了,但可以调节内部json来满足需求
  297. const rpt_tpl_items = { customize: [], common: [] };
  298. if (custTreeFolders.length > 0) {
  299. const cust_select_item = JSON.parse(custTreeFolders[0].rpt_tpl_items);
  300. if (cust_select_item.common) rpt_tpl_items.common = cust_select_item.common;
  301. if (cust_select_item.customize) rpt_tpl_items.customize = cust_select_item.customize;
  302. }
  303. // 获取所有项目参与者
  304. const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, this.ctx.tender.id);
  305. const renderData = {
  306. accountGroup: newAccountGroup,
  307. accountList,
  308. unitList: JSON.stringify(unitList),
  309. tender: tender.data,
  310. tenderInfo: tender.info,
  311. rpt_tpl_data: JSON.stringify(treeNodes),
  312. cust_tpl_data: JSON.stringify(rpt_tpl_items),
  313. all_common_tpl_data: JSON.stringify(allTreeItems),
  314. all_indivi_tpl_data: JSON.stringify(allIndivTreeItems),
  315. cust_select_keys,
  316. cust_cfg: JSON.stringify(custCfg),
  317. project_id: tender.data.project_id,
  318. tender_id: tender.id,
  319. tender_name: tender.data.name,
  320. budget_id: -1,
  321. sp_id: -1,
  322. detail_id: -1,
  323. stg_id: stage_id,
  324. stg_order: stage_order,
  325. cur_order: sorder,
  326. stg_times: stage_times,
  327. stg_status: stage_status,
  328. stage_list: JSON.stringify(stageList),
  329. prj_account_list: JSON.stringify(prjAccList),
  330. role_list: JSON.stringify(roleList),
  331. used_list: JSON.stringify(usedList),
  332. tenderMenu,
  333. preUrl: '/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order,
  334. measureType,
  335. categoryData,
  336. tenderList,
  337. auditConst: auditConst.stage,
  338. ledgerAuditConst: auditConst.ledger,
  339. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  340. customSelects,
  341. rptCustomType: reportConst.rptCustomType,
  342. advanceList: JSON.stringify(advanceList),
  343. advanceAuditList: JSON.stringify(advanceAuditList),
  344. materialAdjList: JSON.stringify(materialList),
  345. materialAdjAuditList: JSON.stringify(materialAdjAuditList),
  346. materialList,
  347. stages: stageList,
  348. dataSelects,
  349. // pageShow: JSON.stringify(pageShow),
  350. pageShow,
  351. authMobile: accountInfo.auth_mobile,
  352. shenpiConst,
  353. archiveList,
  354. lastAuditor,
  355. rpt_id: ctx.query.rpt_id,
  356. isAdmin,
  357. prePay: JSON.stringify(advance),
  358. OSS_PATH: ctx.app.config.fujianOssPath,
  359. viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
  360. auditType: auditConst.auditType,
  361. source_type: 1,
  362. bglObj: 'null',
  363. changes: 'null',
  364. otherChangeList: 'null',
  365. otherHintName: '',
  366. advanceConst,
  367. };
  368. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  369. // await this.layout('report/index.ejs', renderData);
  370. // 在这里启动一个cron job,删除临时创建的excel文件
  371. if (!rptCronJob.started) {
  372. try {
  373. // console.log('rptCronJob.started: ' + rptCronJob.started);
  374. rptCronJob.started = true;
  375. // console.log('this.app.baseDir: ' + this.app.baseDir);
  376. rptCronJob.createJob(null, this.app.baseDir + '/app/public/download');
  377. } catch (ex) {
  378. rptCronJob.started = false;
  379. }
  380. }
  381. } catch (err) {
  382. this.log(err);
  383. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  384. }
  385. }
  386. async indexForPaymentSafe(ctx) {
  387. // 安全生产费入口
  388. try {
  389. await this._getStageAuditViewData(ctx);
  390. const pageShow = ctx.session.sessionProject.page_show;
  391. // pageShow.showArchive = 1;
  392. pageShow.showArchive = 0;
  393. // pageShow.closeWatermark = 1;
  394. pageShow.closeShowAllCustomized = 0;
  395. const tenderId = ctx.params.id;
  396. const paymentDetail_id = ctx.params.did;
  397. // 支付审批: ctx.params.did 是 zh_payment_detail表的id, 通过这个did在 zh_payment_detail_audit表里找审核信息(td_id = ctx.params.did)
  398. // 没有计量期的概念!!!
  399. // const paymentAuditorList = await ctx.service.paymentDetailAudit.getAuditors(paymentDetail_id);
  400. const tender = ctx.paymentTender;
  401. const { treeNodes, commonArrs, custCfg } = await this._createNodes(ctx, sourceTypeConst.sourceType.payment_safe, tender.pid);
  402. // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
  403. const stageList = [];
  404. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: tender.pid } }); // 找公司章用的
  405. const isAdmin = ctx.session.sessionUser.is_admin;
  406. const lastAuditor = null;
  407. const archiveList = [];
  408. let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.pid);
  409. prjAccList = prjAccList.filter(pa => pa.enable !== 0);
  410. const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
  411. const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tender.id);
  412. // 根据需求,如果开启了‘开启个人「签字」’功能,则只能是本身用户签名,管理员例外
  413. if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
  414. // 削减其他account
  415. const newAccList = [];
  416. for (const acc of prjAccList) {
  417. if (acc.id === this.ctx.session.sessionUser.accountId) {
  418. newAccList.push(acc);
  419. }
  420. }
  421. prjAccList = newAccList;
  422. }
  423. // 分类列表
  424. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  425. // 获取用户权限
  426. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  427. // const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  428. // 获取用户可查看的标段
  429. // ...
  430. const tenderList = [];
  431. const cid = this.ctx.helper._.map(treeNodes, 'id');
  432. const customSelects = null;
  433. const dataSelects = {};
  434. dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
  435. reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);
  436. const materialList = await ctx.service.material.getValidMaterials();
  437. const stage_id = -100;
  438. let stage_order = -1;
  439. let sorder = -1;
  440. let stage_times = -1;
  441. let stage_status = -1;
  442. const paymentDetailList = await ctx.service.paymentDetail.getDetail(paymentDetail_id);
  443. if (paymentDetailList && paymentDetailList.length > 0) {
  444. const payment = paymentDetailList[0];
  445. stage_status = payment.status;
  446. stage_order = payment.order;
  447. sorder = stage_order;
  448. stage_times = payment.times;
  449. stageList.push({ id: stage_id, user_id: payment.uid, status: payment.status });
  450. }
  451. for (const prjAcc of prjAccList) {
  452. prjAcc.account_group = prjAcc.company;
  453. }
  454. const cust_select_keys = JSON.stringify(['common_safe', 'customize_safe']); // 因其他地方也有可能保存用户报表的显示选择项,因当初设计问题,不好改数据库结构了,但可以调节内部json来满足需求,安全生产费没有这个,就过了
  455. const rpt_tpl_items = { customize: [], common: [] };
  456. commonArrs.forEach(item => {
  457. rpt_tpl_items.common.push(item.name);
  458. });
  459. // 获取所有项目参与者
  460. const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);
  461. const renderData = {
  462. accountGroup: newAccountGroup,
  463. accountList,
  464. unitList: JSON.stringify(unitList),
  465. tender: null,
  466. tenderInfo: null,
  467. rpt_tpl_data: JSON.stringify(treeNodes),
  468. cust_tpl_data: JSON.stringify(rpt_tpl_items),
  469. all_common_tpl_data: JSON.stringify([]),
  470. all_indivi_tpl_data: JSON.stringify([]),
  471. cust_select_keys,
  472. cust_cfg: JSON.stringify(custCfg),
  473. project_id: tender.pid,
  474. tender_id: tenderId,
  475. tender_name: tender.name,
  476. detail_id: paymentDetail_id,
  477. stg_id: stage_id,
  478. budget_id: -1,
  479. sp_id: -1,
  480. stg_order: stage_order,
  481. cur_order: sorder,
  482. stg_times: stage_times,
  483. stg_status: stage_status,
  484. stage_list: JSON.stringify(stageList),
  485. prj_account_list: JSON.stringify(prjAccList),
  486. role_list: JSON.stringify(roleList),
  487. used_list: JSON.stringify(usedList),
  488. tenderMenu,
  489. preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
  490. measureType,
  491. categoryData,
  492. tenderList,
  493. auditConst: auditConst.stage,
  494. ledgerAuditConst: auditConst.ledger,
  495. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  496. customSelects,
  497. rptCustomType: reportConst.rptCustomType,
  498. advanceList: JSON.stringify([]),
  499. advanceAuditList: JSON.stringify([]),
  500. materialAdjList: JSON.stringify(materialList),
  501. materialAdjAuditList: JSON.stringify([]),
  502. materialList,
  503. stages: stageList,
  504. dataSelects,
  505. pageShow,
  506. authMobile: accountInfo.auth_mobile,
  507. shenpiConst,
  508. archiveList,
  509. lastAuditor,
  510. rpt_id: ctx.query.rpt_id,
  511. isAdmin,
  512. prePay: JSON.stringify(advance),
  513. OSS_PATH: ctx.app.config.fujianOssPath,
  514. viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
  515. source_type: 101,
  516. bglObj: 'null',
  517. changes: 'null',
  518. otherChangeList: 'null',
  519. otherHintName: '',
  520. };
  521. /*
  522. //*/
  523. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  524. } catch (err) {
  525. this.log(err);
  526. // ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  527. }
  528. }
  529. async indexForDynamicGrandTotal(ctx) {
  530. // 动态决算(动态投资)入口 (以独立报表为蓝本(index入口))
  531. try {
  532. await this._getStageAuditViewData(ctx);
  533. const pageShow = ctx.session.sessionProject.page_show;
  534. // pageShow.closeWatermark = 1;
  535. pageShow.showArchive = 0;
  536. pageShow.closeShowAllCustomized = 0;
  537. const tenderId = -1;
  538. const paymentDetail_id = -1;
  539. // const tender = ctx.paymentTender;
  540. const pid = ctx.budget.pid;
  541. const budget_id = ctx.budget.id;
  542. const subProj = await ctx.service.subProject.getDataByCondition({ budget_id });
  543. const sp_id = subProj.id;
  544. const { treeNodes, commonArrs, custCfg } = await this._createNodes(ctx, sourceTypeConst.sourceType.budget, pid);
  545. // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
  546. const stageList = [];
  547. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid } }); // 找公司章用的
  548. const isAdmin = ctx.session.sessionUser.is_admin;
  549. const lastAuditor = null;
  550. const archiveList = [];
  551. let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(pid);
  552. prjAccList = prjAccList.filter(pa => pa.enable !== 0);
  553. const roleList = [];
  554. const usedList = [];
  555. // 根据需求,如果开启了‘开启个人「签字」’功能,则只能是本身用户签名,管理员例外
  556. if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
  557. // 削减其他account
  558. const newAccList = [];
  559. for (const acc of prjAccList) {
  560. if (acc.id === this.ctx.session.sessionUser.accountId) {
  561. newAccList.push(acc);
  562. }
  563. }
  564. prjAccList = newAccList;
  565. }
  566. // 分类列表
  567. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  568. // 获取用户权限
  569. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  570. // const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  571. // 获取用户可查看的标段
  572. // ...
  573. const tenderList = [];
  574. const cid = this.ctx.helper._.map(treeNodes, 'id');
  575. const customSelects = null;
  576. const dataSelects = {};
  577. dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
  578. reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);
  579. const materialList = await ctx.service.material.getValidMaterials();
  580. const stage_id = -200;
  581. const stage_order = -1;
  582. const sorder = -1;
  583. const stage_times = -1;
  584. const stage_status = -1;
  585. for (const prjAcc of prjAccList) {
  586. prjAcc.account_group = prjAcc.company;
  587. }
  588. const cust_select_keys = JSON.stringify(['common_dynamic', 'customize_dynamic']); // 因其他地方也有可能保存用户报表的显示选择项,因当初设计问题,不好改数据库结构了,但可以调节内部json来满足需求
  589. const rpt_tpl_items = { customize: [], common: [] };
  590. const custTreeFolders = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
  591. if (custTreeFolders.length > 0) {
  592. const cust_select_item = JSON.parse(custTreeFolders[0].rpt_tpl_items);
  593. if (cust_select_item.common_dynamic) rpt_tpl_items.common = cust_select_item.common_dynamic;
  594. if (cust_select_item.customize_dynamic) rpt_tpl_items.customize = cust_select_item.customize_dynamic;
  595. if (!cust_select_item.hasOwnProperty('common_dynamic') && !cust_select_item.hasOwnProperty('customize_dynamic')) {
  596. commonArrs.forEach(item => {
  597. rpt_tpl_items.common.push(item.name);
  598. });
  599. }
  600. } else {
  601. commonArrs.forEach(item => {
  602. rpt_tpl_items.common.push(item.name);
  603. });
  604. }
  605. // 获取所有项目参与者
  606. const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);
  607. const renderData = {
  608. accountGroup: newAccountGroup,
  609. accountList,
  610. unitList: JSON.stringify(unitList),
  611. tender: null,
  612. tenderInfo: null,
  613. rpt_tpl_data: JSON.stringify(treeNodes),
  614. cust_tpl_data: JSON.stringify(rpt_tpl_items),
  615. all_common_tpl_data: JSON.stringify([]),
  616. all_indivi_tpl_data: JSON.stringify([]),
  617. cust_select_keys,
  618. cust_cfg: JSON.stringify(custCfg),
  619. project_id: pid,
  620. tender_id: tenderId,
  621. budget_id,
  622. sp_id,
  623. tender_name: ctx.budget.name,
  624. detail_id: paymentDetail_id,
  625. stg_id: stage_id,
  626. stg_order: stage_order,
  627. cur_order: sorder,
  628. stg_times: stage_times,
  629. stg_status: stage_status,
  630. stage_list: JSON.stringify(stageList),
  631. prj_account_list: JSON.stringify(prjAccList),
  632. role_list: JSON.stringify(roleList),
  633. used_list: JSON.stringify(usedList),
  634. tenderMenu,
  635. preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
  636. measureType,
  637. categoryData,
  638. tenderList,
  639. auditConst: auditConst.stage,
  640. ledgerAuditConst: auditConst.ledger,
  641. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  642. customSelects,
  643. rptCustomType: reportConst.rptCustomType,
  644. advanceList: JSON.stringify([]),
  645. advanceAuditList: JSON.stringify([]),
  646. materialAdjList: JSON.stringify(materialList),
  647. materialAdjAuditList: JSON.stringify([]),
  648. materialList,
  649. stages: stageList,
  650. dataSelects,
  651. pageShow,
  652. authMobile: accountInfo.auth_mobile,
  653. shenpiConst,
  654. archiveList,
  655. lastAuditor,
  656. rpt_id: ctx.query.rpt_id,
  657. isAdmin,
  658. prePay: JSON.stringify(advance),
  659. OSS_PATH: ctx.app.config.fujianOssPath,
  660. viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
  661. source_type: 200,
  662. bglObj: 'null',
  663. changes: 'null',
  664. otherChangeList: 'null',
  665. otherHintName: '',
  666. };
  667. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  668. } catch (err) {
  669. this.log(err);
  670. }
  671. }
  672. async _indexForBGL(ctx, source_type, stage_id) {
  673. // 变更令、变更方案、变更立项、变更申请 报表入口
  674. try {
  675. await this._getStageAuditViewData(ctx);
  676. const pageShow = ctx.session.sessionProject.page_show;
  677. pageShow.closeWatermark = 1;
  678. pageShow.showArchive = 1;
  679. pageShow.closeShowAllCustomized = 0;
  680. const tenderId = ctx.params.id;
  681. const bglObj = {};
  682. if (stage_id === -300) {
  683. bglObj.BUSINESS_ID = ctx.params.cid;
  684. bglObj.change = await ctx.service.change.getChangeByCid(ctx.params.cid);
  685. bglObj.currentBz = bglObj.change;
  686. bglObj.status = bglObj.change.status;
  687. // const audit = await ctx.service.changeAudit.getChangeByCid(ctx.params.cid);
  688. }
  689. if (stage_id === -301) {
  690. bglObj.BUSINESS_ID = ctx.params.cplnid;
  691. bglObj.change_plan = await ctx.service.changePlan.getDataById(ctx.params.cplnid);
  692. bglObj.currentBz = bglObj.change_plan;
  693. bglObj.status = bglObj.change_plan.status;
  694. }
  695. if (stage_id === -302) {
  696. bglObj.BUSINESS_ID = ctx.params.cprjid;
  697. bglObj.change_project = await ctx.service.changeProject.getDataById(ctx.params.cprjid);
  698. bglObj.currentBz = bglObj.change_project;
  699. bglObj.status = bglObj.change_project.status;
  700. }
  701. if (stage_id === -303) {
  702. bglObj.BUSINESS_ID = ctx.params.caid;
  703. bglObj.change_apply = await ctx.service.changeApply.getDataById(ctx.params.caid);
  704. bglObj.currentBz = bglObj.change_apply;
  705. bglObj.status = bglObj.change_apply.status;
  706. }
  707. const changeId = ctx.params.cid;
  708. const paymentDetail_id = -1;
  709. const pid = ctx.session.sessionProject.id;
  710. const budget_id = -1;
  711. const sp_id = -1;
  712. const { treeNodes, custCfg } = await this._createNodes(ctx, source_type, pid);
  713. // const { treeNodes, custCfg, allTreeItems, allIndivTreeItems } = await this._createNodes(ctx, sourceTypeConst.sourceType.tender, tender.data.project_id);
  714. const state = ctx.session.sessionProject.page_show.openChangeState && ctx.query.state ? parseInt(ctx.query.state) : 0;
  715. const changes = await ctx.service.change.getListByStatus(tenderId, 0, 0, 0, 0, state);
  716. let change_times = 1;
  717. const stageList = [];
  718. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid } }); // 找公司章用的
  719. const isAdmin = ctx.session.sessionUser.is_admin;
  720. let lastAuditor = null;
  721. for (let cIdx = 0; cIdx < changes.length; cIdx++) {
  722. if (changes[cIdx].cid === changeId) {
  723. if (changes[cIdx].times > change_times) change_times = changes[cIdx].times;
  724. if (changes[cIdx].status === 3) {
  725. const changeAudit = await ctx.service.changeAudit.getLastUser(changeId, changes[cIdx].times, 3);
  726. if (changeAudit) {
  727. lastAuditor = { end_time: changeAudit.sin_time, sdesc: changeAudit.sdesc };
  728. }
  729. }
  730. break;
  731. }
  732. }
  733. let otherChangeList = [],
  734. otherHintName = '';
  735. switch (stage_id) {
  736. case rptBusiness.BusinessStageId.change_plan:
  737. otherChangeList = await ctx.service.changePlan.getListByStatus(tenderId, 0, 0, 0, 0, state);
  738. otherHintName = '变更方案';
  739. break;
  740. case rptBusiness.BusinessStageId.change_project:
  741. otherChangeList = await ctx.service.changeProject.getListByStatus(tenderId, 0, 0, 0, 0, state);
  742. otherHintName = '变更立项';
  743. break;
  744. case rptBusiness.BusinessStageId.change_apply:
  745. otherChangeList = await ctx.service.changeApply.getListByStatus(tenderId, 0, 0, 0, 0, state);
  746. otherHintName = '变更申请';
  747. break;
  748. default:
  749. break;
  750. }
  751. otherChangeList = otherChangeList.filter(x => { return x.id != bglObj.BUSINESS_ID; });
  752. let archiveList = [];
  753. const archives = await ctx.service.rptArchive.getArchiveByBzId(pid, stage_id, bglObj.BUSINESS_ID);
  754. if (archives.length > 0) {
  755. archiveList = JSON.parse(archives[0].content);
  756. }
  757. let prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(pid);
  758. prjAccList = prjAccList.filter(pa => pa.enable !== 0);
  759. const roleList = [];
  760. const usedList = await ctx.service.signatureUsed.getSignatureUsedByTenderId(tenderId);
  761. // 根据需求,如果开启了‘开启个人「签字」’功能,则只能是本身用户签名,管理员例外
  762. if (!ctx.session.sessionUser.is_admin && pageShow.individualSign === 1) {
  763. // 削减其他account
  764. const newAccList = [];
  765. for (const acc of prjAccList) {
  766. if (acc.id === this.ctx.session.sessionUser.accountId) {
  767. newAccList.push(acc);
  768. }
  769. }
  770. prjAccList = newAccList;
  771. }
  772. // 分类列表
  773. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  774. // 获取用户权限
  775. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  776. // const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  777. // 获取用户可查看的标段
  778. // ...
  779. const tenderList = [];
  780. const cid = this.ctx.helper._.map(treeNodes, 'id');
  781. const customSelects = null;
  782. const dataSelects = {};
  783. dataSelects.material_select = await ctx.service.rptCustomDefine.getDataSelectByRpt(cid,
  784. reportConst.rptDataType[JV.NODE_CUS_MATERIAL_SELECT]);
  785. const materialList = await ctx.service.material.getValidMaterials();
  786. const stage_order = -1;
  787. const sorder = -1;
  788. const stage_times = -1;
  789. const stage_status = -1;
  790. for (const prjAcc of prjAccList) {
  791. // prjAcc.account_group = accountGroup[prjAcc.account_group];
  792. prjAcc.account_group = prjAcc.company;
  793. }
  794. const cust_select_keys = JSON.stringify(['common', 'customize']); // 因其他地方也有可能保存用户报表的显示选择项,因当初设计问题,不好改数据库结构了,但可以调节内部json来满足需求
  795. const rpt_tpl_items = { customize: [], common: [] };
  796. if (treeNodes && treeNodes.length > 0) {
  797. for (let tIdx = treeNodes.length - 1; tIdx >= 0; tIdx--) {
  798. if (treeNodes[tIdx].name === '通用报表') {
  799. const items = JSON.parse(treeNodes[tIdx].items);
  800. for (let itemIdx = items.length - 1; itemIdx >= 0; itemIdx--) {
  801. rpt_tpl_items.common.push(items[itemIdx].name);
  802. }
  803. } else {
  804. rpt_tpl_items.customize.push(treeNodes[tIdx].name);
  805. }
  806. }
  807. }
  808. // 获取所有项目参与者
  809. const { accountList, newAccountGroup, advance } = await this._getInvolveAcc(ctx, tenderId);
  810. const renderData = {
  811. accountGroup: newAccountGroup,
  812. accountList,
  813. unitList: JSON.stringify(unitList),
  814. tender: null,
  815. tenderInfo: null,
  816. rpt_tpl_data: JSON.stringify(treeNodes),
  817. cust_tpl_data: JSON.stringify(rpt_tpl_items),
  818. all_common_tpl_data: JSON.stringify([]),
  819. all_indivi_tpl_data: JSON.stringify([]),
  820. cust_select_keys,
  821. cust_cfg: JSON.stringify(custCfg),
  822. project_id: pid,
  823. tender_id: tenderId,
  824. budget_id,
  825. sp_id,
  826. tender_name: ctx.tender.data.name,
  827. detail_id: paymentDetail_id,
  828. stg_id: stage_id,
  829. stg_order: stage_order,
  830. cur_order: sorder,
  831. stg_times: stage_times,
  832. stg_status: stage_status,
  833. stage_list: JSON.stringify(stageList),
  834. prj_account_list: JSON.stringify(prjAccList),
  835. role_list: JSON.stringify(roleList),
  836. used_list: JSON.stringify(usedList),
  837. tenderMenu,
  838. preUrl: '/tender/' + tenderId + '/measure/stage/' + ctx.params.order,
  839. measureType,
  840. categoryData,
  841. tenderList,
  842. auditConst: auditConst.stage,
  843. ledgerAuditConst: auditConst.ledger,
  844. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  845. customSelects,
  846. rptCustomType: reportConst.rptCustomType,
  847. advanceList: JSON.stringify([]),
  848. advanceAuditList: JSON.stringify([]),
  849. materialAdjList: JSON.stringify(materialList),
  850. materialAdjAuditList: JSON.stringify([]),
  851. materialList,
  852. stages: stageList,
  853. dataSelects,
  854. pageShow,
  855. authMobile: accountInfo.auth_mobile,
  856. shenpiConst,
  857. archiveList,
  858. lastAuditor,
  859. rpt_id: ctx.query.rpt_id,
  860. isAdmin,
  861. prePay: JSON.stringify(advance),
  862. OSS_PATH: ctx.app.config.fujianOssPath,
  863. viewPmData: PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission),
  864. source_type,
  865. bglObj: JSON.stringify(bglObj),
  866. changes: JSON.stringify(changes),
  867. otherChangeList: JSON.stringify(otherChangeList || []),
  868. otherHintName,
  869. bizId: bglObj.BUSINESS_ID,
  870. };
  871. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  872. } catch (err) {
  873. this.log(err);
  874. }
  875. }
  876. async indexForChange(ctx) {
  877. // 变更令报表入口
  878. await this._indexForBGL(ctx, sourceTypeConst.sourceType.change, -300);
  879. }
  880. async indexForChangePlan(ctx) {
  881. // 变更方案报表入口
  882. await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_plan, -301);
  883. }
  884. async indexForChangeProject(ctx) {
  885. // 变更立项报表入口
  886. await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_project, -302);
  887. }
  888. async indexForChangeApply(ctx) {
  889. // 变更申请报表入口
  890. await this._indexForBGL(ctx, sourceTypeConst.sourceType.change_apply, -303);
  891. }
  892. /**
  893. * 报表打印页面
  894. *
  895. * @param {Object} ctx - egg全局context
  896. * @return {void}
  897. */
  898. async showPrintPage(ctx) {
  899. try {
  900. // const params = JSON.parse(ctx.request.body.params);
  901. const pageSize = ctx.params.size;
  902. // console.log('pageSize: ' + pageSize);
  903. const renderData = {
  904. size: pageSize,
  905. // orientation: params.orientation,
  906. };
  907. await ctx.render('report/rpt_print.ejs', renderData);
  908. } catch (err) {
  909. this.log(err);
  910. console.log(err);
  911. }
  912. }
  913. async showIndividualPage(ctx) {
  914. try {
  915. // const params = JSON.parse(ctx.request.body.params);
  916. const pageSize = ctx.params.size;
  917. // console.log('pageSize: ' + pageSize);
  918. const renderData = {
  919. size: pageSize,
  920. OSS_PATH: ctx.app.config.fujianOssPath,
  921. // orientation: params.orientation,
  922. };
  923. await ctx.render('report/rpt_individual.ejs', renderData);
  924. } catch (err) {
  925. this.log(err);
  926. console.log(err);
  927. }
  928. }
  929. _mergeBlankRoleSignDate(roleRel, auditors) {
  930. // 有些签名信息的sign_date是空白的(从前一业务copy过来并清理),需要根据审核信息来自动填写上审核时间
  931. // 1. 用户ID 2. sign_date为空白
  932. if (roleRel && auditors) {
  933. roleRel.forEach(record => {
  934. const contents = JSON.parse(record.rel_content);
  935. let hasMerge = false;
  936. contents.forEach(role => {
  937. if (!role.sign_date || role.sign_date === '') {
  938. auditors.forEach(audit => {
  939. if (audit.aid === role.acc_id) {
  940. role.sign_date = audit.end_time;
  941. hasMerge = true;
  942. }
  943. });
  944. }
  945. });
  946. if (hasMerge) {
  947. record.rel_content = JSON.stringify(contents);
  948. }
  949. });
  950. }
  951. }
  952. async _commonGetAudit(ctx, params, stgAudit, stageFlow) {
  953. const COMMON_INVALID_STATUS_FOR_ORG = [1, 6]; // 对原报来说,待上报、重新上报状态就不能默认为审核通过
  954. switch (params.stage_id) {
  955. case -300: // 变更令
  956. const changeAudit = await ctx.service.changeAudit.getAuditors(params.change_id, params.change_times, 'asc', true);
  957. const change = await ctx.service.change.getChangeByCid(params.change_id);
  958. let orgChangeStatus = 3;
  959. if ([1, 9].includes(change.status)) orgChangeStatus = 1; // 原报只要已上报(非1、9),status都是3
  960. stgAudit.push({ aid: change.uid, status: orgChangeStatus, opinion: '', end_time: change.in_time, order: 0 }); // 加上原报
  961. changeAudit.forEach(audit => {
  962. stgAudit.push({ aid: audit.uid, status: audit.status, opinion: audit.sdesc, end_time: audit.sin_time, order: audit.usite });
  963. // 创建dummy stageFlow
  964. stageFlow.push({ aid: audit.uid || audit.aid, audit_type: audit.audit_type, status: audit.status, order: audit.audit_order });
  965. });
  966. break;
  967. case -301: // 变更方案
  968. const changePlanAudit = await ctx.service.changePlanAudit.getAuditors(params.business_id, params.change_plan_times, 'asc', true);
  969. const change_plan = await ctx.service.changePlan.getDataById(params.business_id);
  970. let orgChangePlanStatus = 3;
  971. if ([1, 9].includes(change_plan.status)) orgChangePlanStatus = 1; // 原报只要已上报(非1、9),status都是3
  972. stgAudit.push({ aid: change_plan.uid, status: orgChangePlanStatus, opinion: '', end_time: change_plan.in_time, order: 0 }); // 加上原报
  973. changePlanAudit.forEach(audit => {
  974. if (audit.order === 1) {
  975. stgAudit[0].end_time = audit.begin_time || stgAudit[0].end_time; // 如果没有begin_time,则保留时间
  976. }
  977. stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
  978. // 创建dummy stageFlow
  979. stageFlow.push({ aid: audit.uid || audit.aid, audit_type: audit.audit_type, status: audit.status, order: audit.audit_order });
  980. });
  981. break;
  982. case -302: // 变更立项
  983. const changeProjectAudit = await ctx.service.changeProjectAudit.getAuditors(params.business_id, params.change_project_times, 'asc', true);
  984. const change_project = await ctx.service.changeProject.getDataById(params.business_id);
  985. let orgChangePrjStatus = 3;
  986. if ([1, 9].includes(change_project.status)) orgChangePrjStatus = 1; // 原报只要已上报(非1、9),status都是3
  987. stgAudit.push({ aid: change_project.uid, status: orgChangePrjStatus, opinion: '', end_time: change_project.in_time, order: 0 }); // 加上原报
  988. changeProjectAudit.forEach(audit => {
  989. if (audit.order === 1) {
  990. stgAudit[0].end_time = audit.begin_time || stgAudit[0].end_time; // 如果没有begin_time,则保留时间
  991. }
  992. stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
  993. // 创建dummy stageFlow
  994. stageFlow.push({ aid: audit.uid || audit.aid, audit_type: audit.audit_type, status: audit.status, order: audit.audit_order });
  995. });
  996. break;
  997. case -303: // 变更申请
  998. const changeApplyAudit = await ctx.service.changeApplyAudit.getAuditors(params.business_id, params.change_apply_times, 'asc', true);
  999. const change_apply = await ctx.service.changeApply.getDataById(params.business_id);
  1000. let orgChangeApplyStatus = 3;
  1001. if ([1, 9].includes(change_apply.status)) orgChangeApplyStatus = 1; // 原报只要已上报(非1、9),status都是3
  1002. stgAudit.push({ aid: change_apply.uid, status: orgChangeApplyStatus, opinion: '', end_time: change_apply.in_time, order: 0 }); // 加上原报
  1003. changeApplyAudit.forEach(audit => {
  1004. if (audit.order === 1) {
  1005. stgAudit[0].end_time = audit.begin_time || stgAudit[0].end_time; // 如果没有begin_time,则保留时间
  1006. }
  1007. stgAudit.push({ aid: audit.aid, status: audit.status, opinion: audit.opinion, end_time: audit.end_time, times: audit.times, order: audit.order });
  1008. // 创建dummy stageFlow
  1009. stageFlow.push({ aid: audit.uid || audit.aid, audit_type: audit.audit_type, status: audit.status, order: audit.audit_order });
  1010. });
  1011. break;
  1012. case -400: // 预付款
  1013. const advanceList = await ctx.service.advance.getAdvanceListDirectly(params.tender_id);
  1014. for (const advance of advanceList) {
  1015. if (advance.id === params.advance_id) {
  1016. stgAudit.push({ aid: advance.uid, status: 3, opinion: '同意', end_time: advance.create_time || (new Date()), order: 0 }); // 加上原报,默认status为3
  1017. if (COMMON_INVALID_STATUS_FOR_ORG.includes(advance.status)) stgAudit[0].status = advance.status;
  1018. break;
  1019. }
  1020. }
  1021. const advanceAuditList = await ctx.service.advanceAudit.getAuditAdvanceByTender(params.tender_id);
  1022. // let maxTimes = -1;
  1023. advanceAuditList.forEach(advAudit => {
  1024. if (advAudit.vid === params.advance_id) {
  1025. stgAudit.push({ aid: advAudit.audit_id, status: advAudit.status, opinion: advAudit.opinion || '同意', end_time: advAudit.end_time || (new Date()), times: advAudit.times, order: advAudit.order });
  1026. }
  1027. });
  1028. break;
  1029. case -500: // 材差
  1030. const materialList = await ctx.service.material.getValidMaterials(params.tender_id);
  1031. for (const material of materialList) {
  1032. if (material.id === params.material_id) {
  1033. stgAudit.push({ aid: material.user_id, status: 3, opinion: '同意', end_time: material.in_time, order: 0 }); // 加上原报,默认status为3
  1034. if (COMMON_INVALID_STATUS_FOR_ORG.includes(material.status)) stgAudit[0].status = material.status;
  1035. break;
  1036. }
  1037. }
  1038. const materialAdjAuditList = await ctx.service.materialAudit.getAuditorsByTender(params.tender_id);
  1039. let maxTimes = -1;
  1040. // let orgTime = null;
  1041. materialAdjAuditList.forEach(material => {
  1042. if (material.mid === params.material_id) {
  1043. if (material.times > maxTimes) {
  1044. maxTimes = material.times;
  1045. if (material.order === 1) {
  1046. // orgTime = material.begin_time;
  1047. stgAudit[0].end_time = material.begin_time || stgAudit[0].end_time; // 如果是待上报,没有begin_time,则保留时间
  1048. }
  1049. }
  1050. }
  1051. });
  1052. materialAdjAuditList.forEach(material => {
  1053. if (material.mid === params.material_id) {
  1054. stgAudit.push({ aid: material.aid, status: material.status, opinion: material.opinion, end_time: material.end_time, order: material.order }); // 加上原报
  1055. }
  1056. });
  1057. break;
  1058. default:
  1059. break;
  1060. }
  1061. }
  1062. async _getReport(ctx, params) {
  1063. // console.log('in getReport');
  1064. // console.log(params);
  1065. let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
  1066. if (!rptTpl || rptTpl.length !== 1) {
  1067. throw '获取模板失败';
  1068. }
  1069. const source_type = rptTpl[0].source_type;
  1070. rptTpl = JSON.parse(rptTpl[0].rpt_content);
  1071. rptTpl.source_type = source_type || params.source_type || sourceTypeConst.defaultSourceType;
  1072. rptTpl.id = params.rpt_tpl_id;
  1073. // console.log('get the template!');
  1074. const customSelect = rptTpl[JV.NODE_CUSTOM_DEFINE] && rptTpl[JV.NODE_CUSTOM_DEFINE][JV.NODE_CUS_AUDIT_SELECT].enable
  1075. ? await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, params.stage_id, params.rpt_tpl_id)
  1076. : await ctx.service.rptCustomDefine.getCustomDefine(params.tender_id, -1, params.rpt_tpl_id);
  1077. let copyCustomSelect = this.ctx.helper.clone(customSelect);
  1078. if (!params.gather_select && copyCustomSelect) delete copyCustomSelect.gather_select;
  1079. if (!params.stage_select && copyCustomSelect) delete copyCustomSelect.stage_select;
  1080. if (!params.material_sum_select && copyCustomSelect) delete copyCustomSelect.material_sum_select;
  1081. if (params.change_select) {
  1082. copyCustomSelect = { tid: params.tender_id, rid: params.rpt_tpl_id, sid: -1, change_select: params.change_select };
  1083. }
  1084. const pageRst = await ctx.service.jpcReport.getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir, copyCustomSelect);
  1085. for (const page of pageRst.items) {
  1086. page[JV.PROP_WATERMARK_CELLS] = [];
  1087. }
  1088. let waterMarkStr = null;
  1089. if (params.stage_status !== 3 && params.closeWatermark === 0) {
  1090. // 加水印
  1091. fillWaterMark([pageRst]);
  1092. if (params.needWaterMark) {
  1093. waterMarkStr = await getWatermarkPicData(pageRst, this.app.baseDir);
  1094. }
  1095. }
  1096. // console.log(pageRst);
  1097. const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id, params.stage_id, params.business_id); // 新需求中,允许在非审核状态下设置签名
  1098. let stgAudit = null,
  1099. stgAuditForOrg = null,
  1100. stageFlow = null,
  1101. stageList = [],
  1102. ledger = [];
  1103. if (params.stage_id > 0) {
  1104. stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  1105. stgAuditForOrg = await ctx.service.stageAudit.getStageAudit(params.stage_id, 1);
  1106. stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
  1107. stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(params.stage_id, params.stage_times);
  1108. ledger = await ctx.service.ledger.getDataOnlyByNodeId(params.tender_id);
  1109. } else if ([-100, -200].includes(params.stage_id)) {
  1110. stgAudit = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id, params.stage_times);
  1111. stgAuditForOrg = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id, 1);
  1112. stageFlow = await ctx.service.paymentDetailAudit.getAuditorsWithOwner(params.detail_id);
  1113. const paymentDetailList = await ctx.service.paymentDetail.getDetail(params.detail_id);
  1114. if (paymentDetailList && paymentDetailList.length > 0) {
  1115. const payment = paymentDetailList[0];
  1116. stageList.push({ id: params.stage_id, user_id: payment.uid, status: payment.status });
  1117. }
  1118. } else if ([-300, -301, -302, -303, -400, -500].includes(params.stage_id)) {
  1119. // 变更令、预付款、材差相关的
  1120. stgAudit = [];
  1121. stgAuditForOrg = [];
  1122. stageFlow = [];
  1123. await this._commonGetAudit(ctx, params, stgAudit, stageFlow);
  1124. stgAudit.sort(function(stg1, stg2) {
  1125. return stg1.order - stg2.order;
  1126. });
  1127. this._mergeBlankRoleSignDate(roleRel, stgAudit);
  1128. }
  1129. if (stageFlow) {
  1130. stageFlow.forEach(x => {
  1131. if (!x) return;
  1132. x.visible = (!ctx.session.sessionUser.is_admin && ctx.session.sessionProject.page_show.individualSign === 1)
  1133. ? x.aid === ctx.session.sessionUser.accountId : true;
  1134. });
  1135. }
  1136. mergeStampSignature(ctx, params.stage_status, pageRst, roleRel[0], null, stgAudit, stageList);
  1137. mergeTextSignature(params.isTextSignature, params.stage_status, pageRst, roleRel[0], [], stgAudit, stageList);
  1138. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  1139. if (params.getPicFlag) {
  1140. await encodeDummySignatureDataUri(pageRst, this.app.baseDir); // 注意草图数据量问题!
  1141. }
  1142. // console.log('encodeSignatureDataUri!');
  1143. // fsUtil.writeObjToFile(pageRst, 'D:/GitHome/Temp/testBuiltPageResult2.js');
  1144. return {
  1145. data: pageRst,
  1146. signatureRelInfo: roleRel,
  1147. stageAudit: stgAudit,
  1148. stageAuditOrg: stgAuditForOrg,
  1149. debugInfo: ctx.session.sessionUser.loginStatus ? ctx.debugInfo : null,
  1150. customDefine: rptTpl[JV.NODE_CUSTOM_DEFINE],
  1151. stageFlow,
  1152. ledger,
  1153. customSelect,
  1154. waterMarkStr,
  1155. };
  1156. }
  1157. /**
  1158. * 获取报表数据
  1159. *
  1160. * @param {Object} ctx - egg全局context
  1161. * @return {void}
  1162. */
  1163. async getReport(ctx) {
  1164. try {
  1165. // console.log('in getReport');
  1166. const params = JSON.parse(ctx.request.body.params);
  1167. ctx.body = await this._getReport(ctx, params);
  1168. ctx.status = 201;
  1169. } catch (ex) {
  1170. console.log(ex);
  1171. this.setMessage(ex.toString(), this.messageType.ERROR);
  1172. }
  1173. }
  1174. async getTestReport(ctx) {
  1175. try {
  1176. const file = 'D:/GitHome/Temp/导出PDF_格式样本1.js';
  1177. const tplObj = JSON.parse(fs.readFileSync(file, 'utf-8'));
  1178. ctx.body = { data: tplObj };
  1179. ctx.status = 201;
  1180. } catch (ex) {
  1181. this.setMessage(ex.toString(), this.messageType.ERROR);
  1182. }
  1183. }
  1184. /**
  1185. * 获取多批次报表数据
  1186. *
  1187. * @param {Object} ctx - egg全局context
  1188. * @return {void}
  1189. */
  1190. async getMultiReportsEx(ctx) {
  1191. // 原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  1192. const params = JSON.parse(ctx.request.body.params);
  1193. const pageShow = ctx.session.sessionProject.page_show;
  1194. if (pageShow !== null
  1195. && pageShow !== undefined
  1196. && params.outputType
  1197. && ((params.outputType === 'PDF' && parseInt(pageShow.closeExportPdf) === 1)
  1198. || (params.outputType === 'Excel' && parseInt(pageShow.closeExportExcel) === 1)
  1199. )
  1200. ) {
  1201. ctx.body = { data: [], signatureRelInfo: [], stageAudit: [] };
  1202. ctx.status = 201;
  1203. return;
  1204. }
  1205. if (params.stage_id > 0) {
  1206. await this._saveCustomSelects(params);
  1207. }
  1208. // const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir) || [];
  1209. const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir) || [];
  1210. for (const pageRst of pageRstArr) {
  1211. for (const page of pageRst.items) {
  1212. page[JV.PROP_WATERMARK_CELLS] = [];
  1213. }
  1214. }
  1215. let waterMarkStr = null;
  1216. if (params.stage_status !== 3 && params.closeWatermark === 0) {
  1217. // 加水印
  1218. fillWaterMark(pageRstArr);
  1219. if (params.needWaterMark) {
  1220. waterMarkStr = await getWatermarkPicData(pageRstArr[0], this.app.baseDir);
  1221. }
  1222. }
  1223. const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id, params.business_id); // 新需求:在审批流程中的签名需要显示
  1224. supplementRoles(params.rpt_ids, roleRel);
  1225. roleRel.sort(function(rr1, rr2) {
  1226. return params.rpt_ids.indexOf(parseInt(rr1.rpt_id)) - params.rpt_ids.indexOf(parseInt(rr2.rpt_id));
  1227. });
  1228. let stgAudit = null,
  1229. stageFlow = null,
  1230. stageList = [];
  1231. if (params.stage_id > 0) {
  1232. stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  1233. stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
  1234. stageFlow = await ctx.service.stageAudit.getAuditGroupByListWithOwner(params.stage_id, params.stage_times);
  1235. } else if ([-100, -200].includes(params.stage_id)) {
  1236. stgAudit = await ctx.service.paymentDetailAudit.getAuditors(params.detail_id);
  1237. stageFlow = await ctx.service.paymentDetailAudit.getAuditorsWithOwner(params.detail_id);
  1238. const paymentDetailList = await ctx.service.paymentDetail.getDetail(params.detail_id);
  1239. if (paymentDetailList && paymentDetailList.length > 0) {
  1240. const payment = paymentDetailList[0];
  1241. stageList.push({ id: params.stage_id, user_id: payment.uid, status: payment.status });
  1242. }
  1243. } else if ([-300, -301, -302, -303, -400, -500].includes(params.stage_id)) {
  1244. stgAudit = [];
  1245. stageFlow = [];
  1246. await this._commonGetAudit(ctx, params, stgAudit, stageFlow);
  1247. this._mergeBlankRoleSignDate(roleRel, stgAudit);
  1248. } else if ([-400, -500].includes(params.stage_id)) {
  1249. stgAudit = [];
  1250. }
  1251. mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRel, params.rpt_ids, stgAudit, stageList);
  1252. mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRel, params.rpt_ids, stgAudit, stageList, !!params.closeArchiveSignature, !!params.isArchive);
  1253. await encodeSignatureDataUri(roleRel, this.app.baseDir);
  1254. if (params.getPicFlag) {
  1255. for (const pageRst of pageRstArr) {
  1256. await encodeDummySignatureDataUri(pageRst, this.app.baseDir); // 注意草图数据量问题!
  1257. }
  1258. }
  1259. // console.log(pageRstArr);
  1260. ctx.body = { data: pageRstArr, signatureRelInfo: roleRel, stageAudit: stgAudit, stageFlow, waterMarkStr };
  1261. ctx.status = 201;
  1262. }
  1263. async _saveCustomSelects(params) {
  1264. for (const [i, cs] of params.customSelect.entries()) {
  1265. if (!cs) continue;
  1266. cs.tender_id = params.tender_id;
  1267. cs.stage_id = params.stage_id;
  1268. cs.rpt_tpl_id = params.rpt_ids[i];
  1269. await this.ctx.service.rptCustomDefine.saveCustomSelect(cs);
  1270. }
  1271. }
  1272. async createExcelFilesEx(ctx) {
  1273. const params = JSON.parse(ctx.request.body.params);
  1274. const pageShow = ctx.session.sessionProject.page_show;
  1275. if (pageShow !== null && pageShow !== undefined && parseInt(pageShow.closeExportExcel) === 1) {
  1276. ctx.body = { data: [] };
  1277. ctx.status = 201;
  1278. return;
  1279. }
  1280. await this._saveCustomSelects(params);
  1281. const baseDir = this.app.baseDir;
  1282. function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
  1283. return new Promise(function(resolve, reject) {
  1284. rpt_xl_util.exportExcel(pageRst, params.pageSize, rpt_name, params.isOneSheet, null, null, baseDir, innerRoleRel,
  1285. (err, uuidName) => {
  1286. if (err) return reject(err);
  1287. const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
  1288. resolve(fileRst);
  1289. }
  1290. );
  1291. });
  1292. }
  1293. // const stgAudit = (params.stage_status === 3) ? (await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times)) : [];
  1294. const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  1295. const stgAuditForOrg = (params.stage_status === 3) ? (await ctx.service.stageAudit.getStageAudit(params.stage_id, 1)) : [];
  1296. // const stageList = (params.stage_status === 3) ? (await ctx.service.stage.getValidStagesShort(params.tender_id)) : [];
  1297. const stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
  1298. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id, params.business_id)) : [];
  1299. const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, baseDir);
  1300. // console.log('params.stage_status: ' + params.stage_status);
  1301. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/testBuiltPageResult1.js');
  1302. for (const pageRst of pageRstArr) {
  1303. for (const page of pageRst.items) {
  1304. page[JV.PROP_WATERMARK_CELLS] = [];
  1305. }
  1306. }
  1307. let waterMarkStr = null;
  1308. if (params.stage_status !== 3 && params.closeWatermark === 0) {
  1309. // if (params.stage_status !== 3 && params.closeWatermark === 0 && params.option === JV.PAGING_OPTION_NORMAL) {
  1310. // 加水印(注意:还得看用户设置是否需要加水印)
  1311. fillWaterMark(pageRstArr);
  1312. if (params.needWaterMark) {
  1313. waterMarkStr = await getWatermarkPicData(pageRstArr[0], baseDir);
  1314. }
  1315. }
  1316. mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
  1317. mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
  1318. await this.ctx.helper.recursiveMkdirSync(baseDir + '/app/public/download');
  1319. const runnableRst = [];
  1320. // 1. merge签名相关信息
  1321. const pageBrkSize = 62914560; // 60M, 1024*1024*6*10
  1322. for (let idx = 0; idx < pageRstArr.length; idx++) {
  1323. let roleRel = null;
  1324. for (const roleR of roleRelArr) {
  1325. if (roleR.rpt_id === params.rpt_ids[idx]) {
  1326. roleRel = JSON.parse(roleR.rel_content);
  1327. break;
  1328. }
  1329. }
  1330. if (params.stage_status === 3) {
  1331. mergeSignAudit(pageRstArr[idx], roleRel, stgAudit);
  1332. mergeSignDate(pageRstArr[idx], params.stage_id, roleRel, stgAudit, stgAuditForOrg, stageList);
  1333. }
  1334. // 2. 判断草图大小是否需要分页
  1335. const picSize = await _chkRawPicSize(pageRstArr[idx], baseDir);
  1336. // const picSize = 262914560; // 测试用,强制分页
  1337. if (picSize > pageBrkSize) {
  1338. // let pageBrkAmt = Math.ceil(picSize / pageBrkSize);
  1339. let pageBrkAmt = Math.floor(pageRstArr[idx].items.length / Math.ceil(picSize / pageBrkSize));
  1340. if (pageBrkAmt < 10) {
  1341. // 不用管
  1342. } else if (pageBrkAmt < 100) {
  1343. pageBrkAmt = Math.floor(pageBrkAmt / 10) * 10;
  1344. } else if (pageBrkAmt < 1000) {
  1345. pageBrkAmt = Math.floor(pageBrkAmt / 100) * 100;
  1346. } else {
  1347. // 暂时不管
  1348. }
  1349. const newRptNames = []; // 这个为导出控制分页用
  1350. const newPageDataRst = _resetPageDataByBreaks([pageRstArr[idx]], pageBrkAmt, [params.rpt_names[idx]], newRptNames);
  1351. for (let dtlIdx = 0; dtlIdx < newPageDataRst.length; dtlIdx++) {
  1352. runnableRst.push(getExcelByPageData(newPageDataRst[dtlIdx], newRptNames[dtlIdx], roleRel));
  1353. }
  1354. } else {
  1355. runnableRst.push(getExcelByPageData(pageRstArr[idx], params.rpt_names[idx], roleRel));
  1356. }
  1357. }
  1358. // */
  1359. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/计量导出pageArr.js');
  1360. const uuidRst = await Promise.all(runnableRst);
  1361. ctx.body = { data: uuidRst, waterMarkStr };
  1362. ctx.status = 201;
  1363. }
  1364. _getExcelByPageData(pageRst, rpt_name, pageSize, baseDir, innerRoleRel) {
  1365. return new Promise(function(resolve, reject) {
  1366. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, true, null, null, baseDir, innerRoleRel,
  1367. (err, uuidName) => {
  1368. if (err) return reject(err);
  1369. const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
  1370. resolve(fileRst);
  1371. }
  1372. );
  1373. });
  1374. }
  1375. async createExcelFilesFromDirectData(ctx) {
  1376. const params = JSON.parse(ctx.request.body.params);
  1377. const names = params.rptNames;
  1378. const pageDataArr = params.pageData;
  1379. const runnableRst = [];
  1380. for (let idx = 0; idx < names.length; idx++) {
  1381. runnableRst.push(this._getExcelByPageData(pageDataArr[idx], names[idx], 'A4', this.app.baseDir, null));
  1382. }
  1383. const uuidRst = await Promise.all(runnableRst);
  1384. ctx.body = { data: uuidRst, waterMarkStr: null };
  1385. ctx.status = 201;
  1386. }
  1387. async createExcelFilesFromLocal(ctx) {
  1388. const baseDir = this.app.baseDir;
  1389. function getExcelByPageData(pageRst, rpt_name, innerRoleRel) {
  1390. return new Promise(function(resolve, reject) {
  1391. rpt_xl_util.exportExcel(pageRst, 'A4', rpt_name, true, null, null, baseDir, innerRoleRel,
  1392. (err, uuidName) => {
  1393. if (err) return reject(err);
  1394. const fileRst = { uuid: uuidName, reportName: rpt_name.replace(new RegExp('%', 'gm'), '_') };
  1395. resolve(fileRst);
  1396. }
  1397. );
  1398. });
  1399. }
  1400. try {
  1401. console.log('start:');
  1402. const pageRst = JSON.parse(fs.readFileSync('D:/GitHome/temp/计量excel原始数据_A3BZ6_5384_112表(清单).js', 'utf-8'));
  1403. console.log('read it');
  1404. const runnableRst = [];
  1405. const pageBrkSize = 6291456; // 6M, 1024*1024*6
  1406. // const pageBrkSize = 1048576; // 1M, 1024*1024*1
  1407. console.log('pageBrkSize:' + pageBrkSize);
  1408. const picSize = await _chkRawPicSize(pageRst, baseDir);
  1409. console.log('picSize:' + picSize);
  1410. if (picSize > pageBrkSize) {
  1411. let pageBrkAmt = Math.floor(pageRst.items.length / Math.ceil(picSize / pageBrkSize));
  1412. console.log('pageBrkAmt:' + pageBrkAmt);
  1413. if (pageBrkAmt < 10) {
  1414. // 不用管
  1415. } else if (pageBrkAmt < 100) {
  1416. pageBrkAmt = Math.floor(pageBrkAmt / 10) * 10;
  1417. } else if (pageBrkAmt < 1000) {
  1418. pageBrkAmt = Math.floor(pageBrkAmt / 100) * 100;
  1419. } else {
  1420. // 暂时不管
  1421. }
  1422. const newRptNames = []; // 这个为导出控制分页用
  1423. const newPageDataRst = _resetPageDataByBreaks([pageRst], pageBrkAmt, ['工程计量表(计量单元-清单)'], newRptNames);
  1424. for (let dtlIdx = 0; dtlIdx < newPageDataRst.length; dtlIdx++) {
  1425. runnableRst.push(getExcelByPageData(newPageDataRst[dtlIdx], newRptNames[dtlIdx], null));
  1426. }
  1427. } else {
  1428. runnableRst.push(getExcelByPageData(pageRst, '工程计量表(计量单元-清单)', null));
  1429. }
  1430. const uuidRst = await Promise.all(runnableRst);
  1431. ctx.body = { data: uuidRst, waterMarkStr: null };
  1432. ctx.status = 201;
  1433. } catch (ex) {
  1434. console.log(ex.toString());
  1435. ctx.status = 500;
  1436. }
  1437. }
  1438. async createExcelFilesInOneBookEx(ctx) {
  1439. const params = JSON.parse(ctx.request.body.params);
  1440. const baseDir = this.app.baseDir;
  1441. function getExcelByPageData(pageRstArr, rpt_name, innerRoleRel) {
  1442. return new Promise(function(resolve, reject) {
  1443. rpt_xl_util.exportExcelInOneBook(pageRstArr, params.pageSize, rpt_name, baseDir, innerRoleRel,
  1444. (err, uuidName) => {
  1445. if (err) return reject(err);
  1446. const fileRst = { uuid: uuidName, reportName: rpt_name };
  1447. resolve(fileRst);
  1448. }
  1449. );
  1450. });
  1451. }
  1452. const roleRelArr = (params.stage_status === 3) ? (await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_ids, params.stage_id)) : [];
  1453. // console.log(`baseDir: ${baseDir}`);
  1454. // fsUtil.writeObjToFile(roleRelArr, 'D:/GitHome/temp/签名信息.js');
  1455. const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  1456. const stgAuditForOrg = await ctx.service.stageAudit.getStageAudit(params.stage_id, 1);
  1457. const stageList = await ctx.service.stage.getValidStagesShort(params.tender_id);
  1458. // const pageRstArr = await getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  1459. const pageRstArr = await ctx.service.jpcReport.getMultiRptsCommon(ctx, params, JV.OUTPUT_TYPE_NORMAL, this.app.baseDir);
  1460. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/pageRstArrForExcel.js');
  1461. for (const pageRst of pageRstArr) {
  1462. for (const page of pageRst.items) {
  1463. page[JV.PROP_WATERMARK_CELLS] = [];
  1464. }
  1465. }
  1466. let waterMarkStr = null;
  1467. if (params.stage_status !== 3 && params.closeWatermark === 0) {
  1468. // if (params.stage_status !== 3 && params.closeWatermark === 0 && params.option === JV.PAGING_OPTION_NORMAL) {
  1469. // 加水印
  1470. fillWaterMark(pageRstArr);
  1471. if (params.needWaterMark) {
  1472. waterMarkStr = await getWatermarkPicData(pageRstArr[0], this.app.baseDir);
  1473. }
  1474. }
  1475. mergeStampSignature(ctx, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
  1476. mergeTextSignature(params.isTextSignature, params.stage_status, pageRstArr, roleRelArr, params.rpt_ids, stgAudit, stageList);
  1477. await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  1478. const runnableRst = [];
  1479. let rptRoleRelArr = [];
  1480. const reAssignSignatureName = function(pageData, roleRel, rpt_name_key) {
  1481. const keyMap = {};
  1482. for (const pageItem of pageData.items) {
  1483. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  1484. if (!keyMap.hasOwnProperty(signCell.signature_name)) {
  1485. keyMap[signCell.signature_name] = rpt_name_key + '_' + signCell.signature_name;
  1486. }
  1487. }
  1488. }
  1489. for (const pageItem of pageData.items) {
  1490. for (const signCell of pageItem[JV.PROP_SIGNATURE_CELLS]) {
  1491. if (keyMap.hasOwnProperty(signCell.signature_name)) {
  1492. signCell.signature_name = keyMap[signCell.signature_name];
  1493. }
  1494. }
  1495. }
  1496. for (const roleSign of roleRel) {
  1497. if (keyMap.hasOwnProperty(roleSign.signature_name)) {
  1498. roleSign.signature_name = keyMap[roleSign.signature_name];
  1499. }
  1500. }
  1501. // console.log('keyMap of : ' + rpt_name_key);
  1502. // console.log(keyMap);
  1503. };
  1504. for (let idx = 0; idx < pageRstArr.length; idx++) {
  1505. let roleRel = null;
  1506. for (const roleR of roleRelArr) {
  1507. if (roleR.rpt_id === params.rpt_ids[idx]) {
  1508. roleRel = JSON.parse(roleR.rel_content);
  1509. if (params.stage_status === 3) {
  1510. mergeSignAudit(pageRstArr[idx], roleRel, stgAudit);
  1511. mergeSignDate(pageRstArr[idx], params.stage_id, roleRel, stgAudit, stgAuditForOrg, stageList);
  1512. }
  1513. // 这里要做些电子签名的signature_name转换,以防重名
  1514. reAssignSignatureName(pageRstArr[idx], roleRel, params.rpt_names[idx]);
  1515. rptRoleRelArr = rptRoleRelArr.concat(roleRel);
  1516. break;
  1517. }
  1518. }
  1519. }
  1520. // fsUtil.writeObjToFile(pageRstArr, 'D:/GitHome/temp/pageRstArrForExcelAfterReAssign.js');
  1521. // fsUtil.writeObjToFile(rptRoleRelArr, 'D:/GitHome/temp/签名信息_新.js');
  1522. runnableRst.push(getExcelByPageData(pageRstArr, params.rptName, rptRoleRelArr));
  1523. const uuidRst = await Promise.all(runnableRst);
  1524. ctx.body = { data: uuidRst, waterMarkStr };
  1525. ctx.status = 201;
  1526. }
  1527. async getFileByUUID(ctx) {
  1528. // console.log('downloading : ' + ctx.params.uuid);
  1529. const uuid = ctx.params.uuid;
  1530. const rptName = ctx.params.rptName;
  1531. const suffix = '.' + ctx.params.suffix;
  1532. try {
  1533. const rptNameURI = encodeURI(rptName);
  1534. const filePath = this.app.baseDir + '/app/public/download/';
  1535. // console.log('filePath: ' + filePath);
  1536. // await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  1537. ctx.set({
  1538. 'Content-Type': 'application/vnd.openxmlformats',
  1539. 'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
  1540. });
  1541. ctx.body = await fs.readFileSync(filePath + uuid + suffix);
  1542. } catch (e) {
  1543. console.log(e);
  1544. }
  1545. }
  1546. /**
  1547. * 更新用户通用报表显示配置
  1548. *
  1549. * @param {Object} ctx - egg全局context
  1550. * @return {void}
  1551. */
  1552. async updateCustNode(ctx) {
  1553. const params = JSON.parse(ctx.request.body.params);
  1554. // console.log(params);
  1555. const custId = this.ctx.session.sessionUser.accountId;
  1556. const newNodeItems = JSON.stringify(params.nodeItems);
  1557. const rst = await ctx.service.rptTreeNodeCust.updateCustNodeByTenderId(custId, params.tender_id, newNodeItems);
  1558. // console.log(rst);
  1559. ctx.body = { data: rst };
  1560. // ctx.body = { data: { msg: 'test the network' } };
  1561. ctx.status = 201;
  1562. }
  1563. async setCustomDefine(ctx) {
  1564. try {
  1565. const data = JSON.parse(ctx.request.body.data);
  1566. await this.ctx.service.rptCustomDefine.saveCustomSelect(data);
  1567. const result = await this._getReport(ctx, data);
  1568. ctx.body = { err: 0, msg: '', data: result };
  1569. } catch (err) {
  1570. ctx.helper.log(err);
  1571. ctx.body = this.ajaxErrorBody(err, '保存数据出错');
  1572. }
  1573. }
  1574. }
  1575. return ReportController;
  1576. };
  1577. function isFileExisted(file) {
  1578. return new Promise(function(resolve, reject) {
  1579. fs.access(file, err => {
  1580. if (err) {
  1581. reject(false);
  1582. } else {
  1583. resolve(true);
  1584. }
  1585. });
  1586. });
  1587. }
  1588. function fillWaterMark(pageRstArray) {
  1589. const orgWaterMarkWidth = 600;
  1590. const orgWaterMarkHeight = 288;
  1591. const createWaterCell = function(area) {
  1592. const w = area[JV.PROP_RIGHT] - area[JV.PROP_LEFT];
  1593. const h = area[JV.PROP_BOTTOM] - area[JV.PROP_TOP];
  1594. const left = Math.round(area[JV.PROP_LEFT] + w / 2 - orgWaterMarkWidth / 2);
  1595. const right = left + orgWaterMarkWidth;
  1596. const top = Math.round(area[JV.PROP_TOP] + h / 2 - orgWaterMarkHeight / 2);
  1597. const bottom = top + orgWaterMarkHeight;
  1598. return {
  1599. signature_name: JV.SIGNATURE_NAME_DUMMY_WATER_MARK,
  1600. path: '/public/images/not_Approve.png',
  1601. sign_path: '/public/images/not_Approve.png',
  1602. pic: null,
  1603. control: 'Title',
  1604. style: 'Default_None',
  1605. area: {
  1606. Left: left,
  1607. Right: right,
  1608. Top: top,
  1609. Bottom: bottom,
  1610. },
  1611. };
  1612. };
  1613. for (const pageRst of pageRstArray) {
  1614. for (const page of pageRst.items) {
  1615. page[JV.PROP_WATERMARK_CELLS] = [];
  1616. if (page[JV.PROP_PAGE_MERGE_BORDER]) {
  1617. const wmCell = createWaterCell(page[JV.PROP_PAGE_MERGE_BORDER]);
  1618. page[JV.PROP_WATERMARK_CELLS].push(wmCell);
  1619. } else if (page[JV.PAGE_SPECIAL_MERGE_POS]) {
  1620. if (page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT]) {
  1621. for (let i = 0; i < page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT].length; i++) {
  1622. const area = {};
  1623. area[JV.PROP_LEFT] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_LEFT][i];
  1624. area[JV.PROP_RIGHT] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_RIGHT][i];
  1625. area[JV.PROP_TOP] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_TOP][i];
  1626. area[JV.PROP_BOTTOM] = page[JV.PAGE_SPECIAL_MERGE_POS][JV.PROP_BOTTOM][i];
  1627. const wmCell = createWaterCell(area);
  1628. page[JV.PROP_WATERMARK_CELLS].push(wmCell);
  1629. }
  1630. }
  1631. }
  1632. }
  1633. }
  1634. }
  1635. async function encodeSignatureDataUri(roleRel, baseDir) {
  1636. if (roleRel) {
  1637. for (const singleRoleRel of roleRel) {
  1638. if (singleRoleRel.rel_content !== null && singleRoleRel.rel_content !== undefined && singleRoleRel.rel_content !== '') {
  1639. const roleRelContent = JSON.parse(singleRoleRel.rel_content);
  1640. for (const role of roleRelContent) {
  1641. // console.log(role);
  1642. if (role.sign_path !== '') {
  1643. const filePath = baseDir + '/app' + role.sign_path;
  1644. try {
  1645. const res = await isFileExisted(filePath);
  1646. if (res) {
  1647. const bData = fs.readFileSync(filePath);
  1648. const base64Str = bData.toString('base64');
  1649. const datauri = 'data:image/png;base64,' + base64Str;
  1650. role.sign_pic = datauri;
  1651. } else {
  1652. console.log('文件不存在:' + filePath);
  1653. }
  1654. } catch (err) {
  1655. console.error(err);
  1656. }
  1657. }
  1658. }
  1659. singleRoleRel.rel_content = JSON.stringify(roleRelContent);
  1660. } else {
  1661. singleRoleRel.rel_content = [];
  1662. }
  1663. }
  1664. }
  1665. }
  1666. async function encodeDummySignatureDataUri(pageRst, baseDir) {
  1667. if (pageRst) {
  1668. for (const page of pageRst.items) {
  1669. for (const signature of page[JV.PROP_SIGNATURE_CELLS]) {
  1670. if (signature.signature_name === JV.SIGNATURE_NAME_DUMMY) {
  1671. if (signature.path !== '') {
  1672. const filePath = baseDir + '/app' + signature.path;
  1673. try {
  1674. const res = await isFileExisted(filePath);
  1675. if (res) {
  1676. const bData = fs.readFileSync(filePath);
  1677. const base64Str = bData.toString('base64');
  1678. const datauri = 'data:image/png;base64,' + base64Str;
  1679. signature.pic = datauri;
  1680. signature.path = '';
  1681. } else {
  1682. console.log('文件不存在:' + filePath);
  1683. }
  1684. } catch (err) {
  1685. console.error(err);
  1686. }
  1687. }
  1688. }
  1689. }
  1690. // 考虑优化,水印只需要一张即可,不需要每页都设置
  1691. // for (const signature of page[JV.PROP_WATERMARK_CELLS]) {
  1692. // if (signature.path !== '') {
  1693. // const filePath = baseDir + '/app' + signature.path;
  1694. // try {
  1695. // const res = await isFileExisted(filePath);
  1696. // if (res) {
  1697. // const bData = fs.readFileSync(filePath);
  1698. // const base64Str = bData.toString('base64');
  1699. // const datauri = 'data:image/png;base64,' + base64Str;
  1700. // signature.pic = datauri;
  1701. // signature.path = '';
  1702. // } else {
  1703. // console.log('文件不存在:' + filePath);
  1704. // }
  1705. // } catch (err) {
  1706. // console.error(err);
  1707. // }
  1708. // }
  1709. // }
  1710. }
  1711. }
  1712. }
  1713. async function getWatermarkPicData(pageRst, baseDir) {
  1714. if (pageRst) {
  1715. for (const page of pageRst.items) {
  1716. for (const signature of page[JV.PROP_WATERMARK_CELLS]) {
  1717. if (signature.path !== '') {
  1718. const filePath = baseDir + '/app' + signature.path;
  1719. try {
  1720. const res = await isFileExisted(filePath);
  1721. if (res) {
  1722. const bData = fs.readFileSync(filePath);
  1723. const base64Str = bData.toString('base64');
  1724. return 'data:image/png;base64,' + base64Str;
  1725. }
  1726. } catch (err) {
  1727. console.error(err);
  1728. }
  1729. }
  1730. }
  1731. }
  1732. }
  1733. return '';
  1734. }
  1735. function mergeTextSignature(isTxtSignature, status, pageData, singleRoleRel, rpt_ids, stgAudit, stageList, closeArchiveSignature = false, isArchive = false) {
  1736. // 依据需求,有些用户不需要签名图片,那么从源头上把签名从signature_cells转移到cells下,省得后续 预览、打印、导出PDF、导出EXCEL每个地方都改动
  1737. const _mergeSingle = function(_page, _roleRelList, isDeleteSignCell, checkAudit = false) {
  1738. // console.log(_roleRelList);
  1739. let roleRelContent = [];
  1740. if (_roleRelList && _roleRelList.rel_content !== null && _roleRelList.rel_content !== undefined && _roleRelList.rel_content !== '') {
  1741. roleRelContent = JSON.parse(_roleRelList.rel_content);
  1742. }
  1743. for (const page of _page.items) {
  1744. if (page.signature_cells) {
  1745. const deleteSCellsIdx = [];
  1746. for (let scIdx = 0; scIdx < page.signature_cells.length; scIdx++) {
  1747. const sCell = page.signature_cells[scIdx];
  1748. if (sCell.signature_name !== JV.SIGNATURE_NAME_DUMMY) {
  1749. sCell.Value = ''; // 这里要先清除原有信息
  1750. sCell.path = '';
  1751. sCell.pic = '';
  1752. let needTransferText = true;
  1753. for (const role_rel of roleRelContent) {
  1754. if (sCell.signature_name === role_rel.signature_name) {
  1755. if (!checkAudit || _chkIfAudit(role_rel, stgAudit || [], stageList || [])) {
  1756. sCell.Value = role_rel.user_name; // 只有审核通过了才需要文本签名内容
  1757. if (role_rel.sign_output && role_rel.sign_output.indexOf(NORMAL_SIGN_STR) < 0) {
  1758. // 用户选择不签名,则不迁移
  1759. needTransferText = false;
  1760. }
  1761. break;
  1762. }
  1763. }
  1764. }
  1765. if (needTransferText) {
  1766. const newCell = {
  1767. font: 'Footer',
  1768. control: sCell.control,
  1769. style: sCell.style,
  1770. Value: sCell.Value,
  1771. area: { Left: sCell.area.Left, Right: sCell.area.Right, Top: sCell.area.Top, Bottom: sCell.area.Bottom },
  1772. };
  1773. if (isArchive && closeArchiveSignature) {
  1774. // 如果正在归档 且 归档不显示签名标记为true时,不输出文本签名,但要有这个空格子(边框用)
  1775. newCell.Value = '';
  1776. }
  1777. page.cells.push(newCell); // 迁移
  1778. deleteSCellsIdx.push(scIdx);
  1779. }
  1780. }
  1781. }
  1782. // 删除 page.signature_cells 签名(草图不能删);
  1783. // console.log('isDeleteSignCell: ' + isDeleteSignCell);
  1784. // console.log(deleteSCellsIdx);
  1785. if (isDeleteSignCell) {
  1786. for (let dIdx = deleteSCellsIdx.length - 1; dIdx >= 0; dIdx--) {
  1787. page.signature_cells.splice(deleteSCellsIdx[dIdx], 1);
  1788. }
  1789. }
  1790. }
  1791. }
  1792. };
  1793. if (isTxtSignature) {
  1794. if (pageData instanceof Array) {
  1795. pageData.forEach((dtlPage, index) => {
  1796. let dftRolRel = [];
  1797. const rpt_id = rpt_ids[index];
  1798. for (const roleRel of singleRoleRel) {
  1799. if (roleRel.rpt_id === rpt_id) {
  1800. dftRolRel = roleRel;
  1801. }
  1802. }
  1803. // _mergeSingle(dtlPage, dftRolRel, true, status !== 3);
  1804. _mergeSingle(dtlPage, dftRolRel, false, status !== 3); // 因加了个标记(归档不输出签名),前端做了大量的签名处理工作,导致现在不能删除,否则还会出现遗漏
  1805. });
  1806. } else {
  1807. _mergeSingle(pageData, singleRoleRel, false, status !== 3);
  1808. }
  1809. }
  1810. }
  1811. function _chkIfAudit(role_rel, STAGE_AUDIT = [], STAGE_LIST = []) {
  1812. let rst = false;
  1813. for (const stg_audit of STAGE_AUDIT) {
  1814. if (role_rel.acc_id === stg_audit.aid) {
  1815. if (stg_audit.status === 3) {
  1816. rst = true;
  1817. } else {
  1818. rst = false;
  1819. }
  1820. // break; //因为实际业务中会有反复,所以就不break了,一直判断,以最后一个为准
  1821. }
  1822. }
  1823. if (!rst) {
  1824. // 还有原报需要检测
  1825. for (const stg_ort_rpt of STAGE_LIST) {
  1826. if (role_rel.acc_id === stg_ort_rpt.user_id) {
  1827. if (stg_ort_rpt.status !== 1 && stg_ort_rpt.status !== 4) {
  1828. // 只要不是待上报(1)、退回审批(4) 状态,都需要显示
  1829. rst = true;
  1830. } else {
  1831. rst = false;
  1832. }
  1833. // break; //因为实际业务中会有反复,所以就不break了,一直判断,以最后一个为准
  1834. }
  1835. }
  1836. }
  1837. // rst = true; //测试,未来将屏蔽
  1838. return rst;
  1839. }
  1840. // 因机制问题,此方法必须在mergeTextSignature之前调用
  1841. async function mergeStampSignature(ctx, status, pageData, singleRoleRel, rpt_ids, stgAudit, stageList) {
  1842. const dupPicPaths = [];
  1843. const _getMaxRect = function(page) {
  1844. const rect = [100000000, 100000000, 0, 0];
  1845. for (const cell of page.cells) {
  1846. rect[0] = rect[0] > cell.area.Left ? cell.area.Left : rect[0];
  1847. rect[1] = rect[1] > cell.area.Top ? cell.area.Top : rect[1];
  1848. rect[2] = rect[2] < cell.area.Right ? cell.area.Right : rect[2];
  1849. rect[3] = rect[3] < cell.area.Bottom ? cell.area.Bottom : rect[3];
  1850. }
  1851. for (const sCell of page.signature_cells) {
  1852. rect[0] = rect[0] > sCell.area.Left ? sCell.area.Left : rect[0];
  1853. rect[1] = rect[1] > sCell.area.Top ? sCell.area.Top : rect[1];
  1854. rect[2] = rect[2] < sCell.area.Right ? sCell.area.Right : rect[2];
  1855. rect[3] = rect[3] < sCell.area.Bottom ? sCell.area.Bottom : rect[3];
  1856. }
  1857. return rect;
  1858. };
  1859. const createStampArea = function(orgCell, controls, maxRect) {
  1860. const ctrl = controls[orgCell.control];
  1861. const rst = { Left: orgCell.area.Left, Right: orgCell.area.Right, Top: orgCell.area.Top, Bottom: orgCell.area.Bottom };
  1862. let pLeft = orgCell.area.Left,
  1863. pTop = orgCell.area.Top;
  1864. switch (ctrl[JV.CONTROL_PROPS[JV.CONTROL_PROP_IDX_HORIZON]]) {
  1865. case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_LEFT]:
  1866. pLeft = orgCell.area.Left;
  1867. break;
  1868. case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_CENTER]:
  1869. pLeft = (orgCell.area.Left + orgCell.area.Right - STD_COMP_STAMP_SIZE_WIDTH) / 2;
  1870. break;
  1871. case JV.OUTPUT_ALIGN.H[JV.H_ALIGN_IDX_RIGHT]:
  1872. pLeft = orgCell.area.Right - STD_COMP_STAMP_SIZE_WIDTH;
  1873. break;
  1874. default:break;
  1875. }
  1876. switch (ctrl[JV.CONTROL_PROPS[JV.CONTROL_PROP_IDX_VERTICAL]]) {
  1877. case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_TOP]:
  1878. pTop = orgCell.area.Top;
  1879. break;
  1880. case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_CENTER]:
  1881. pTop = (orgCell.area.Top + orgCell.area.Bottom - STD_COMP_STAMP_SIZE_HEIGHT) / 2;
  1882. break;
  1883. case JV.OUTPUT_ALIGN.H[JV.V_ALIGN_IDX_BOTTOM]:
  1884. pTop = orgCell.area.Bottom - STD_COMP_STAMP_SIZE_HEIGHT;
  1885. break;
  1886. default:break;
  1887. }
  1888. rst.Left = pLeft;
  1889. rst.Top = pTop;
  1890. rst.Right = pLeft + STD_COMP_STAMP_SIZE_WIDTH;
  1891. rst.Bottom = pTop + STD_COMP_STAMP_SIZE_WIDTH;
  1892. // 最后一步,如超过报表范围,则要调整坐标
  1893. // if (rst.Left < maxRect[0]) {
  1894. // const width = maxRect[0] - rst.Left;
  1895. // rst.Left += width;
  1896. // rst.Right += width;
  1897. // }
  1898. // if (rst.Top < maxRect[1]) {
  1899. // const height = maxRect[1] - rst.Top;
  1900. // rst.Top += height;
  1901. // rst.Bottom += height;
  1902. // }
  1903. // if (rst.Right > maxRect[2]) {
  1904. // const width = maxRect[2] - rst.Right; // 负
  1905. // rst.Left += width;
  1906. // rst.Right += width;
  1907. // }
  1908. // if (rst.Bottom > maxRect[3]) {
  1909. // const height = maxRect[3] - rst.Bottom;
  1910. // rst.Top += height;
  1911. // rst.Bottom += height;
  1912. // }
  1913. return rst;
  1914. };
  1915. const _mergeSingleStamp = async function(_page, _roleRelList, checkAudit = false) {
  1916. let roleRelContent = [];
  1917. if (_roleRelList && _roleRelList.rel_content !== null && _roleRelList.rel_content !== undefined && _roleRelList.rel_content !== '') {
  1918. roleRelContent = JSON.parse(_roleRelList.rel_content);
  1919. }
  1920. for (const page of _page.items) {
  1921. const maxRect = _getMaxRect(page);
  1922. if (page.signature_cells) {
  1923. const newStampCells = [];
  1924. for (let scIdx = 0; scIdx < page.signature_cells.length; scIdx++) {
  1925. const sCell = page.signature_cells[scIdx];
  1926. for (const role_rel of roleRelContent) {
  1927. if (sCell.signature_name === role_rel.signature_name) {
  1928. if (!checkAudit || _chkIfAudit(role_rel, stgAudit || [], stageList || [])) {
  1929. if (Array.isArray(role_rel.sign_output) && role_rel.sign_output.length > 0) {
  1930. for (const signType of role_rel.sign_output) {
  1931. switch (signType) {
  1932. case COMPANY_SIGN_STR:
  1933. case PRIVATE_SIGN_STR:
  1934. // 创建一个新的cell
  1935. let stampPath = (signType === COMPANY_SIGN_STR) ? role_rel.company_stamp_path : role_rel.private_stamp_path;
  1936. stampPath = ctx.app.config.fujianOssPath + stampPath;
  1937. if (dupPicPaths.indexOf(stampPath) < 0) {
  1938. dupPicPaths.push(stampPath);
  1939. // await _chkRawPicSizeOSS(ctx, stampPath);
  1940. }
  1941. // 保存在签字信息中的签章信息
  1942. let signatureArea;
  1943. if (role_rel.areaData && role_rel.areaData[signType]) {
  1944. signatureArea = role_rel.areaData[signType];
  1945. }
  1946. const newStampCell = {
  1947. signature_name: JV.SIGNATURE_NAME_DUMMY,
  1948. control: sCell.control,
  1949. style: sCell.style,
  1950. path: stampPath,
  1951. isStamp: true,
  1952. maxRect,
  1953. orgArea: sCell.area,
  1954. area: signatureArea || createStampArea(sCell, _page[JV.NODE_CONTROL_COLLECTION], maxRect), // 有签章信息就直接取,没有的话就走原来的逻辑
  1955. signatureName: role_rel.signature_name, // 节点名称
  1956. signType, // 签章信息
  1957. isSaveSignature: !!signatureArea, // 是否有签章位置信息
  1958. };
  1959. newStampCells.push(newStampCell);
  1960. break;
  1961. default: break;
  1962. }
  1963. }
  1964. }
  1965. }
  1966. }
  1967. }
  1968. }
  1969. if (newStampCells.length > 0) {
  1970. if (page.liftUpInfo) {
  1971. const tmpStampCells = [];
  1972. newStampCells.forEach(newStampCell => {
  1973. const tmpCell = JSON.parse(JSON.stringify(newStampCell));
  1974. tmpStampCells.push(tmpCell);
  1975. let adjustHeight = page.liftUpInfo.liftUpHeight;
  1976. const tmpTop = tmpCell.area.Top - adjustHeight;
  1977. if (tmpTop < 10) {
  1978. adjustHeight = adjustHeight - (10 - tmpTop);
  1979. }
  1980. tmpCell.area.Top = tmpCell.area.Top - adjustHeight;
  1981. tmpCell.area.Bottom = tmpCell.area.Bottom - adjustHeight;
  1982. });
  1983. page.signature_cells = page.signature_cells.concat(tmpStampCells);
  1984. } else {
  1985. page.signature_cells = page.signature_cells.concat(newStampCells);
  1986. }
  1987. }
  1988. }
  1989. }
  1990. };
  1991. if (pageData instanceof Array) {
  1992. pageData.forEach((dtlPage, index) => {
  1993. let dftRolRel = [];
  1994. const rpt_id = rpt_ids[index];
  1995. for (const roleRel of singleRoleRel) {
  1996. if (roleRel.rpt_id === rpt_id) {
  1997. dftRolRel = roleRel;
  1998. }
  1999. }
  2000. _mergeSingleStamp(dtlPage, dftRolRel, status !== 3);
  2001. });
  2002. } else {
  2003. _mergeSingleStamp(pageData, singleRoleRel, status !== 3);
  2004. }
  2005. }
  2006. function mergeSignAudit(pageData, currRoleRelList, currAuditList) {
  2007. for (const page of pageData.items) {
  2008. if (page.signature_audit_cells) {
  2009. for (const sCell of page.signature_audit_cells) {
  2010. sCell.Value = ''; // 这里要先清除原有信息
  2011. if (currRoleRelList && currRoleRelList.length > 0) {
  2012. for (const role_rel of currRoleRelList) {
  2013. if (sCell.signature_name === role_rel.signature_name + '_审核意见') {
  2014. let preDate = '';
  2015. sCell.Value = '同意'; // 只有选择了签名的,才需要初始化一个默认的意见(之前的逻辑在有多个签名,哪怕只选择了一个,其他的意见都会有默认意见)
  2016. if (currAuditList && currAuditList.length > 0) {
  2017. for (const audit_rel of currAuditList) {
  2018. if (role_rel.acc_id === audit_rel.aid) {
  2019. if (audit_rel.end_time > preDate && audit_rel.status === 3) {
  2020. sCell.Value = audit_rel.opinion;
  2021. preDate = audit_rel.end_time;
  2022. }
  2023. // 不能break,实际会有多个审核意见,以最后一个为准
  2024. }
  2025. }
  2026. }
  2027. break;
  2028. }
  2029. }
  2030. }
  2031. }
  2032. }
  2033. }
  2034. }
  2035. function mergeSignDate(pageData, current_stage_id, currRoleRelList, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST) {
  2036. if (currRoleRelList && currRoleRelList.length > 0 && STAGE_AUDIT && STAGE_AUDIT.length > 0) {
  2037. for (let rridx = 0; rridx < currRoleRelList.length; rridx++) {
  2038. const role_rel = currRoleRelList[rridx];
  2039. if (role_rel.sign_date === undefined || role_rel.sign_date === null || role_rel.sign_date === '') {
  2040. const dftDate = _getSignDateByAllScenarios(role_rel.acc_id, current_stage_id, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST);
  2041. role_rel.sign_date = dftDate;
  2042. }
  2043. }
  2044. }
  2045. if (currRoleRelList && currRoleRelList.length > 0) {
  2046. for (const page of pageData.items) {
  2047. if (page.signature_date_cells) {
  2048. for (const sCell of page.signature_date_cells) {
  2049. sCell.Value = _getSignDateDftName();
  2050. for (const role_rel of currRoleRelList) {
  2051. if (sCell.signature_name === role_rel.signature_name + '_签字日期') {
  2052. if (role_rel.sign_date !== '') {
  2053. if (typeof role_rel.sign_date === 'string') {
  2054. role_rel.sign_date = new Date(role_rel.sign_date);
  2055. }
  2056. sCell.Value = role_rel.sign_date.Format(role_rel.sign_date_format);
  2057. }
  2058. break;
  2059. }
  2060. }
  2061. }
  2062. }
  2063. }
  2064. }
  2065. }
  2066. function _getSignDateByAllScenarios(userAccId, current_stage_id, STAGE_AUDIT, STAGE_AUDIT_ORG, STAGE_LIST) {
  2067. let rst = '';
  2068. let hasAudit = false;
  2069. for (const stg_audit of STAGE_AUDIT) {
  2070. if (stg_audit.aid === userAccId) {
  2071. hasAudit = true;
  2072. if (stg_audit.status === 3) {
  2073. rst = stg_audit.end_time;
  2074. } else {
  2075. rst = '';
  2076. }
  2077. // break; //因为实际业务中会有反复,所以就不break了,一直判断,以最后一个为准
  2078. }
  2079. }
  2080. let isOrgRpt = false;
  2081. for (const stg of STAGE_LIST) {
  2082. if (stg.id === current_stage_id) {
  2083. if (stg.user_id === userAccId) {
  2084. isOrgRpt = true;
  2085. }
  2086. break;
  2087. }
  2088. }
  2089. if (isOrgRpt && !hasAudit && STAGE_AUDIT_ORG && STAGE_AUDIT_ORG.length > 0) {
  2090. if (STAGE_AUDIT_ORG[0].begin_time && STAGE_AUDIT_ORG[0].begin_time !== '' && STAGE_AUDIT_ORG[0].begin_time.length > 20) {
  2091. rst = STAGE_AUDIT_ORG[0].begin_time;
  2092. }
  2093. }
  2094. if (!isOrgRpt && !hasAudit) {
  2095. // 非审批流程人员以及非原报,则显示期截至时间
  2096. // 之前给我的解释有问题的,不应该找stage的period属性,而是找当期最后一个status===3的end_time时间(STAGE_AUDIT已经取了最后times,并已排序了)
  2097. for (const stg_audit of STAGE_AUDIT) {
  2098. if (stg_audit.status === 3) {
  2099. rst = stg_audit.end_time;
  2100. }
  2101. }
  2102. }
  2103. return rst;
  2104. }
  2105. function _getSignDateDftName() {
  2106. return ' 年 月 日';
  2107. }
  2108. async function _chkRawPicSize(pageData, baseDir) {
  2109. let rst = 0;
  2110. const picKeys = [];
  2111. for (let pi = 0; pi < pageData.items.length; pi++) {
  2112. // 每页判断
  2113. for (let ci = 0; ci < pageData.items[pi][JV.PROP_SIGNATURE_CELLS].length; ci++) {
  2114. const picPath = pageData.items[pi][JV.PROP_SIGNATURE_CELLS][ci].path;
  2115. // if (picPath && picPath.indexOf('/sign') < 0 && picKeys.indexOf(picPath) < 0) {
  2116. if (picPath && picPath !== '' && picKeys.indexOf(picPath) < 0) {
  2117. // 签名图片也要计算在内,反正不重复
  2118. picKeys.push(picPath);
  2119. }
  2120. // signature_cells PROP_SIGNATURE_CELLS
  2121. }
  2122. }
  2123. // console.log(picKeys);
  2124. for (const pKey of picKeys) {
  2125. const filePath = `${baseDir}/app${pKey}`;
  2126. console.log('filePath: ' + filePath);
  2127. let isExist = false;
  2128. try {
  2129. isExist = await isFileExisted(filePath);
  2130. } catch (ex) {
  2131. isExist = false;
  2132. }
  2133. console.log('isExist: ' + isExist);
  2134. if (isExist) {
  2135. const obj = fs.statSync(filePath);
  2136. if (obj) {
  2137. rst += obj.size;
  2138. } else {
  2139. console.log('no statSync resutl: ' + filePath);
  2140. }
  2141. // rst += fs.statSync(filePath).size;
  2142. } else {
  2143. console.log(`${pKey} not exists!`);
  2144. }
  2145. }
  2146. return rst;
  2147. }
  2148. async function _chkRawPicSizeOSS(ctx, picPath) {
  2149. // 计量的草图、签章都放在OSS服务器上,需要另外的方式来获取,考虑到效率问题,机制上得有所变化
  2150. const rst = [0, 0];
  2151. try {
  2152. const pf = await ctx.app.signPdfOss.get(picPath);
  2153. console.log('get pic successfully!');
  2154. console.log(pf);
  2155. } catch (ex) {
  2156. console.log(ex);
  2157. } finally {
  2158. console.log('finally!');
  2159. }
  2160. return rst;
  2161. }
  2162. function _resetPageDataByBreaks(pageDataArr, breakAmt, rpt_names, newRptNames) {
  2163. const rst = [];
  2164. for (let pi = 0; pi < pageDataArr.length; pi++) {
  2165. const pageItem = pageDataArr[pi];
  2166. const currentRptName = rpt_names[pi];
  2167. if (pageItem.items.length > breakAmt) {
  2168. let pa = Math.floor(pageItem.items.length / breakAmt);
  2169. if (pageItem.items.length % breakAmt > 0) {
  2170. pa++;
  2171. }
  2172. for (let idx = 0; idx < pa; idx++) {
  2173. const newPageDataObj = { items: [] };
  2174. // newPageDataObj[JV.NODE_PAGE_INFO] = JSON.parse(JSON.stringify(pageItem[JV.NODE_PAGE_INFO]));
  2175. newPageDataObj[JV.NODE_PAGE_INFO] = pageItem[JV.NODE_PAGE_INFO];
  2176. // newPageDataObj[JV.BAND_PROP_MERGE_BAND] = JSON.parse(JSON.stringify(pageItem[JV.BAND_PROP_MERGE_BAND]));
  2177. newPageDataObj[JV.BAND_PROP_MERGE_BAND] = pageItem[JV.BAND_PROP_MERGE_BAND];
  2178. newPageDataObj[JV.NODE_FONT_COLLECTION] = pageItem[JV.NODE_FONT_COLLECTION];
  2179. newPageDataObj[JV.NODE_STYLE_COLLECTION] = pageItem[JV.NODE_STYLE_COLLECTION];
  2180. newPageDataObj[JV.NODE_CONTROL_COLLECTION] = pageItem[JV.NODE_CONTROL_COLLECTION];
  2181. for (let dIdx = idx * breakAmt; dIdx < (Math.min((idx + 1) * breakAmt, pageItem.items.length)); dIdx++) {
  2182. newPageDataObj.items.push(pageItem.items[dIdx]);
  2183. }
  2184. rst.push(newPageDataObj);
  2185. newRptNames.push(currentRptName + '_' + (idx + 1));
  2186. }
  2187. } else {
  2188. rst.push(pageItem);
  2189. newRptNames.push(currentRptName);
  2190. }
  2191. }
  2192. return rst;
  2193. }
  2194. function supplementRoles(rptIds, roleRel) {
  2195. const supplementRptIds = [];
  2196. supplementRptIds.push(...rptIds);
  2197. roleRel.forEach(role => {
  2198. const idx = supplementRptIds.indexOf(role.rpt_id);
  2199. if (idx >= 0) {
  2200. supplementRptIds.splice(idx, 1);
  2201. }
  2202. });
  2203. supplementRptIds.forEach(sRptId => {
  2204. // ['id', 'tender_id', 'rpt_id', 'sid', 'business_id', 'rel_content'];
  2205. const dummyRole = {
  2206. rpt_id: sRptId,
  2207. rel_content: '[]',
  2208. };
  2209. roleRel.push(dummyRole);
  2210. });
  2211. }