report_controller.js 105 KB

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