report_controller.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365
  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 JpcEx = require('../reports/rpt_component/jpc_ex');
  8. const JV = require('../reports/rpt_component/jpc_value_define');
  9. const rptDataExtractor = require('../reports/util/rpt_calculation_data_util');
  10. const fsUtil = require('../public/js/fsUtil');
  11. module.exports = app => {
  12. class ReportController extends app.BaseController {
  13. /**
  14. * 报表显示页面
  15. *
  16. * @param {Object} ctx - egg全局context
  17. * @return {void}
  18. */
  19. async index(ctx) {
  20. try {
  21. const tender = ctx.tender;
  22. const stage = ctx.stage;
  23. // console.log(tender.data);
  24. // console.log(stage);
  25. let stage_id = -1;
  26. let stage_order = -1;
  27. let stage_times = -1;
  28. let stage_status = -1;
  29. const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
  30. const custCfg = await ctx.service.rptCustomizeCfg.getCustomizeCfgByUserId('Administrator');
  31. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  32. const prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(tender.data.project_id);
  33. const roleList = await ctx.service.signatureRole.getSignatureRolesByTenderId(tender.id);
  34. // console.log(maxStageAmt[0].maxAmt);
  35. if (stage !== null && stage !== undefined) {
  36. stage_id = stage.id;
  37. stage_order = stage.order;
  38. stage_times = stage.times;
  39. stage_status = stage.status;
  40. }
  41. const renderData = {
  42. tender: tender.data,
  43. tenderInfo: tender.info,
  44. rpt_tpl_data: JSON.stringify(treeNodes),
  45. cust_cfg: JSON.stringify(custCfg),
  46. project_id: tender.data.project_id,
  47. tender_id: tender.id,
  48. stg_id: stage_id,
  49. stg_order: stage_order,
  50. stg_times: stage_times,
  51. stg_status: stage_status,
  52. stage_list: JSON.stringify(stageList),
  53. prj_account_list: JSON.stringify(prjAccList),
  54. role_list: JSON.stringify(roleList),
  55. tenderMenu,
  56. preUrl: '/tender/' + tender.id,
  57. measureType,
  58. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.explode),
  59. };
  60. // await this.layout('report/index.ejs', renderData, 'ledger/audit_modal.ejs');
  61. await this.layout('report/index.ejs', renderData, 'report/rpt_all_popup.ejs');
  62. // await this.layout('report/index.ejs', renderData);
  63. } catch (err) {
  64. this.log(err);
  65. console.log(err);
  66. // ctx.redirect('/tender/' + ctx.tender.id);
  67. }
  68. }
  69. /**
  70. * 获取报表数据
  71. *
  72. * @param {Object} ctx - egg全局context
  73. * @return {void}
  74. */
  75. async getReport(ctx) {
  76. try {
  77. // console.log('in getReport');
  78. const params = JSON.parse(ctx.request.body.params);
  79. // console.log(params);
  80. let rptTpl = await ctx.service.rptTpl.getTplById(params.rpt_tpl_id);
  81. if (!rptTpl || rptTpl.length !== 1) {
  82. throw '获取模板失败';
  83. }
  84. rptTpl = JSON.parse(rptTpl[0].rpt_content);
  85. // console.log('get the template!');
  86. const pageRst = await getAllPagesCommon(ctx, rptTpl, params, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_NORMAL);
  87. // console.log(pageRst);
  88. const roleRel = await ctx.service.roleRptRel.getRoleRptRelByDetailIds(params.tender_id, params.rpt_tpl_id);
  89. const stgAudit = await ctx.service.stageAudit.getStageAudit(params.stage_id, params.stage_times);
  90. ctx.body = { data: pageRst, signatureRelInfo: roleRel, stageAudit: stgAudit };
  91. // ctx.body = { data: { msg: 'test the network' } };
  92. ctx.status = 201;
  93. } catch (ex) {
  94. this.setMessage(ex.toString(), this.messageType.ERROR);
  95. }
  96. }
  97. }
  98. return ReportController;
  99. };
  100. async function getReportData(ctx, params, filters) {
  101. const rst = {};
  102. const runnableRst = [];
  103. const runnableKey = []; // 这个配合runnableRst用,未来考虑并行查询优化
  104. for (const filter of filters) {
  105. switch (filter) {
  106. case 'project' :
  107. runnableRst.push(ctx.service.project.getProjectById(params.project_id));
  108. runnableKey.push('project');
  109. break;
  110. case 'tender_info' :
  111. runnableRst.push(ctx.service.tenderInfo.getTenderInfo(params.tender_id));
  112. runnableKey.push('tender_info');
  113. break;
  114. case 'ledger' :
  115. runnableRst.push(ctx.service.ledger.getData(params.tender_id, 0));
  116. runnableKey.push('ledger');
  117. break;
  118. case 'stage_bills':
  119. runnableRst.push(ctx.service.stageBills.getLastestStageData(params.tender_id, params.stage_id));
  120. runnableKey.push('stage_bills');
  121. break;
  122. case 'stage_bills_final':
  123. runnableRst.push(ctx.service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order));
  124. runnableKey.push('stage_bills_final');
  125. break;
  126. case 'stage':
  127. runnableRst.push(ctx.service.stage.getStageById(params.stage_id));
  128. runnableKey.push('stage');
  129. break;
  130. case 'stage_pay':
  131. runnableRst.push(ctx.service.stagePay.getAuditorStageData(params.stage_id, params.stage_times, params.stage_order));
  132. runnableKey.push('stage_pay');
  133. break;
  134. default:
  135. break;
  136. }
  137. }
  138. const queryRst = await Promise.all(runnableRst);
  139. for (let idx = 0; idx < runnableKey.length; idx++) {
  140. rst[runnableKey[idx]] = queryRst[idx];
  141. // console.log(runnableKey[idx]);
  142. // if (rst[runnableKey[idx]] instanceof Array) console.log('is Array')
  143. // else console.log('is not Array');
  144. }
  145. return rst;
  146. }
  147. async function getAllPagesCommon(ctx, rptTpl, params, option, outputType) {
  148. // let rptTpl = null;
  149. const rptDataUtil = new rptDataExtractor();
  150. rptDataUtil.initialize(rptTpl);
  151. // console.log(rptTpl);
  152. const filter = rptDataUtil.getDataRequestFilter();
  153. // console.log(filter.tables);
  154. const rawDataObj = await getReportData(ctx, params, filter.tables);
  155. // console.log(rawDataObj);
  156. try {
  157. // console.log('before assemble');
  158. const tplData = rptDataUtil.assembleData(rawDataObj);
  159. // console.log(tplData);
  160. const printCom = JpcEx.createNew();
  161. if (params.pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = params.pageSize;
  162. if (params.orientation && (params.orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = params.orientation;
  163. let defProperties = await ctx.service.rptPreDefineCfg.getCfgById('Administrator');
  164. // console.log('defProperties: ');
  165. // console.log(defProperties[0].defined_content);
  166. defProperties = JSON.parse(defProperties[0].defined_content);
  167. if (params.custCfg) {
  168. setupCustomizeCfg(params.custCfg, rptTpl, defProperties);
  169. } else {
  170. // setupCustomizeCfg(defProperties, rptTpl, defProperties);
  171. }
  172. const dftOption = params.option || JV.PAGING_OPTION_NORMAL;
  173. printCom.initialize(rptTpl);
  174. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  175. const maxPages = printCom.totalPages;
  176. let pageRst = null;
  177. if (maxPages > 0) {
  178. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, params.custCfg);
  179. } else {
  180. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  181. }
  182. if (pageRst) {
  183. // fsUtil.writeObjToFile(pageRst, 'D:/GitHome/temp/testBuiltPageResult.jsp');
  184. } else {
  185. //
  186. }
  187. // console.log(pageRst);
  188. return pageRst;
  189. } catch (ex) {
  190. // console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  191. console.log(ex);
  192. }
  193. }
  194. function setupCustomizeCfg(customizeCfg, rptTpl, defProperties) {
  195. const tmpObj = {};
  196. // 1. 字体
  197. const newFonts = [];
  198. for (const font of defProperties.fonts) {
  199. const copyFont = {};
  200. copyFont.ID = font.ID;
  201. for (const fontProp of JV.FONT_PROPS) {
  202. copyFont[fontProp] = font[fontProp];
  203. }
  204. newFonts.push(copyFont);
  205. tmpObj[font.ID] = copyFont;
  206. }
  207. const private_setup_font = function(propStr, newFont) {
  208. if (tmpObj[propStr]) {
  209. tmpObj[propStr].Name = newFont.Name;
  210. tmpObj[propStr].FontHeight = String(newFont.FontHeight);
  211. tmpObj[propStr].FontBold = newFont.FontBold;
  212. tmpObj[propStr].FontItalic = newFont.FontItalic;
  213. tmpObj[propStr].FontUnderline = newFont.FontUnderline;
  214. }
  215. };
  216. for (const custFont of customizeCfg.fonts) {
  217. switch (custFont.CfgDispName) {
  218. case '表标题':
  219. private_setup_font('ReportTitle_Main', custFont);
  220. break;
  221. case '列标题':
  222. private_setup_font('HeaderColumn', custFont);
  223. private_setup_font('FooterColumn', custFont);
  224. break;
  225. case '正文内容':
  226. private_setup_font('Content', custFont);
  227. break;
  228. case '合计':
  229. private_setup_font('GrandTotal', custFont);
  230. private_setup_font('SectionTotal', custFont);
  231. break;
  232. case '表眉/表脚':
  233. private_setup_font('Header', custFont);
  234. private_setup_font('Footer', custFont);
  235. break;
  236. default:
  237. break;
  238. }
  239. }
  240. // 1.1 窄体
  241. if (tmpObj.Content_Narrow) {
  242. if (customizeCfg.isNarrow) {
  243. tmpObj.Content_Narrow.Name = 'Arial Narrow';
  244. } else {
  245. if (tmpObj.Content) {
  246. tmpObj.Content_Narrow.Name = tmpObj.Content.Name;
  247. } else {
  248. tmpObj.Content_Narrow.Name = '宋体';
  249. }
  250. }
  251. }
  252. defProperties.fonts = newFonts;
  253. // 2. 页边距
  254. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_LEFT] = customizeCfg.margins[JV.PROP_LEFT] / 10;
  255. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_RIGHT] = customizeCfg.margins[JV.PROP_RIGHT] / 10;
  256. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_TOP] = customizeCfg.margins[JV.PROP_TOP] / 10;
  257. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_BOTTOM] = customizeCfg.margins[JV.PROP_BOTTOM] / 10;
  258. // 3. 边框竖线
  259. if (!(customizeCfg.showVerticalLine)) {
  260. const private_copy_border = function(src) {
  261. const rst = {};
  262. rst.Position = src.Position;
  263. rst.LineWeight = src.LineWeight;
  264. rst.DashStyle = src.DashStyle;
  265. rst.Color = src.Color;
  266. return rst;
  267. };
  268. const newStyles = [];
  269. for (let i = 0; i < defProperties.styles.length; i++) {
  270. const style = defProperties.styles[i];
  271. newStyles.push(style);
  272. if (style.ID === 'BORDER_ALL_AROUND') {
  273. const newStyle = {};
  274. newStyle.ID = style.ID;
  275. newStyle.CfgDispName = style.CfgDispName;
  276. newStyle.border_style = [];
  277. for (const border of style.border_style) {
  278. const newBorder = private_copy_border(border);
  279. newStyle.border_style.push(newBorder);
  280. if (border.Position === 'Left' || border.Position === 'Right') {
  281. newBorder.LineWeight = 0;
  282. }
  283. }
  284. newStyles[newStyles.length - 1] = newStyle;
  285. }
  286. }
  287. defProperties.styles = newStyles;
  288. }
  289. // 4. 补0
  290. const private_Setup_Format = function(tabFields) {
  291. if (tabFields) {
  292. for (const tabField of tabFields) {
  293. if (tabField[JV.PROP_FORMAT]) {
  294. tabField[JV.PROP_FORMAT] = tabField[JV.PROP_FORMAT].replace(new RegExp('#', 'gm'), '0');
  295. }
  296. }
  297. }
  298. };
  299. if (customizeCfg.fillZero) {
  300. if (rptTpl[JV.NODE_FLOW_INFO]) {
  301. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS]);
  302. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_PAGE_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_PAGE_SUM][JV.PROP_SUM_FIELDS]);
  303. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_SEG_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_SEG_SUM][JV.PROP_SUM_FIELDS]);
  304. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  305. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  306. for (const discrete of rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  307. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  308. }
  309. }
  310. if (rptTpl[JV.NODE_FLOW_INFO_EX]) {
  311. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS]);
  312. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_PAGE_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_PAGE_SUM][JV.PROP_SUM_FIELDS]);
  313. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_SEG_SUM]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_SEG_SUM][JV.PROP_SUM_FIELDS]);
  314. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_SUM_FIELDS]);
  315. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES]) private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  316. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  317. for (const discrete of rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  318. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  319. }
  320. }
  321. }
  322. } else if (rptTpl[JV.NODE_BILL_INFO]) {
  323. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_BILL_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_BILL_INFO][JV.NODE_BILL_CONTENT][JV.PROP_BILL_FIELDS]);
  324. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  325. for (const discrete of rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  326. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  327. }
  328. }
  329. } else if (rptTpl[JV.NODE_CROSS_INFO]) {
  330. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_CONTENT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_CONTENT][JV.TAB_CROSS_FIELDS]);
  331. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW][JV.TAB_CROSS_FIELDS]);
  332. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL][JV.TAB_CROSS_FIELDS]);
  333. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL_SUM]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_COL_SUM][JV.TAB_CROSS_FIELDS]);
  334. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_EXT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_EXT][JV.TAB_CROSS_FIELDS]);
  335. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_SUM_EXT]) private_Setup_Format(rptTpl[JV.NODE_CROSS_INFO][JV.NODE_CROSS_ROW_SUM_EXT][JV.TAB_CROSS_FIELDS]);
  336. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  337. for (const discrete of rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  338. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  339. }
  340. }
  341. }
  342. }
  343. }
  344. function hasSignatureDate(pageRst) {
  345. let rst = false;
  346. if (pageRst && pageRst.items.length > 0) {
  347. for (const page of pageRst.items) {
  348. if (page[JV.PROP_SIGNATURE_DATE_CELLS] && page[JV.PROP_SIGNATURE_DATE_CELLS].length > 0) {
  349. rst = true;
  350. break;
  351. }
  352. }
  353. }
  354. return rst;
  355. }