rpt_controller.js 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718
  1. /**
  2. * Created by Tony on 2017/3/13.
  3. */
  4. let UserModel = require("../../users/models/user_model");
  5. const mongoose = require("mongoose");
  6. const async = require("async");
  7. const JV = require("../rpt_component/jpc_value_define");
  8. let Template = mongoose.model('rpt_templates');
  9. let rptTplDataFacade = require("../facade/rpt_tpl_data_facade");
  10. let fsUtil = require("../../../public/fsUtil");
  11. let pm_facade = require('../../../modules/pm/facade/pm_facade');
  12. const rptTplFacade = require("../facade/rpt_template_facade");
  13. const demoTemplateFacade = require("../facade/rpt_tpl_data_demo_facade");
  14. const JpcEx = require("../rpt_component/jpc_ex");
  15. const rptUtil = require("../util/rpt_util");
  16. const rpt_xl_util = require("../util/rpt_excel_util");
  17. const rpt_pdf_util = require("../util/rpt_pdf_util");
  18. const rpt_svg_util = require("../util/rpt_svg_util");
  19. const fs = require("fs");
  20. const strUtil = require("../../../public/stringUtil");
  21. const rptDataExtractor = require("../util/rpt_construct_data_util");
  22. //统一回调函数
  23. let callback = function(req, res, err, data){
  24. if(err){
  25. res.json({success: false, error: err});
  26. }
  27. else{
  28. //res.send({success: true, data: data});
  29. res.json({success:true, data: data});
  30. }
  31. };
  32. const WATERMARK_FONT = {
  33. "Name": "宋体",
  34. "FontHeight": "32",
  35. "FontColor": "GOLD",
  36. "FontBold": "T",
  37. "FontItalic": "F",
  38. "FontUnderline": "F",
  39. "FontStrikeOut": "F",
  40. "FontAngle": "45"
  41. };
  42. function getAllPagesCommonOrg(rpt_id, pageSize, option, cb) {
  43. let rptTpl = null;
  44. rptTplFacade.getRptTemplate(rpt_id).then(function(rst) {
  45. rptTpl = rst;
  46. if (rptTpl) {
  47. if (rptTpl.ID_KEY) {
  48. return demoTemplateFacade.getDemoData(rptTpl.ID_KEY);
  49. } else {
  50. //callback(req, res, 'No report template data were found!', null);
  51. cb('No report template data were found!', null);
  52. }
  53. } else {
  54. //callback(req, res, 'No report template was found!', null);
  55. cb('No report template was found!', null);
  56. }
  57. }).then(function(tplData){
  58. if (tplData) {
  59. let printCom = JpcEx.createNew();
  60. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  61. let defProperties = rptUtil.getReportDefaultCache();
  62. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  63. printCom.initialize(rptTpl);
  64. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, JV.OUTPUT_TYPE_NORMAL);
  65. let maxPages = printCom.totalPages;
  66. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties);
  67. if (pageRst) {
  68. cb(null, pageRst);
  69. } else {
  70. //callback(req, res, "Have errors while on going...", null);
  71. cb('Have errors while on going...', null);
  72. }
  73. } else {
  74. //callback(req, res, 'No report data were found!', null);
  75. cb('No report data were found!', null);
  76. }
  77. }
  78. );
  79. }
  80. function setupCustomizeCfg(customizeCfg, rptTpl, defProperties) {
  81. let tmpObj = {};
  82. //1. 字体
  83. let newFonts = [];
  84. for (let font of defProperties.fonts) {
  85. let copyFont = {};
  86. copyFont.ID = font.ID;
  87. for (let fontProp of JV.FONT_PROPS) {
  88. copyFont[fontProp] = font[fontProp];
  89. }
  90. newFonts.push(copyFont);
  91. tmpObj[font.ID] = copyFont;
  92. }
  93. let private_setup_font = function (propStr, newFont) {
  94. if (tmpObj[propStr]) {
  95. tmpObj[propStr].Name = newFont.Name;
  96. tmpObj[propStr].FontHeight = String(newFont.FontHeight);
  97. tmpObj[propStr].FontBold = newFont.FontBold;
  98. tmpObj[propStr].FontItalic = newFont.FontItalic;
  99. tmpObj[propStr].FontUnderline = newFont.FontUnderline;
  100. }
  101. };
  102. for (let custFont of customizeCfg.fonts) {
  103. switch (custFont.CfgDispName) {
  104. case "表标题":
  105. private_setup_font("ReportTitle_Main", custFont);
  106. break;
  107. case "列标题":
  108. private_setup_font("HeaderColumn", custFont);
  109. private_setup_font("FooterColumn", custFont);
  110. break;
  111. case "正文内容":
  112. private_setup_font("Content", custFont);
  113. break;
  114. case "合计":
  115. private_setup_font("GrandTotal", custFont);
  116. private_setup_font("SectionTotal", custFont);
  117. break;
  118. case "表眉/表脚":
  119. private_setup_font("Header", custFont);
  120. private_setup_font("Footer", custFont);
  121. break;
  122. }
  123. }
  124. // 1.1 窄体
  125. if (tmpObj["Content_Narrow"]) {
  126. if (customizeCfg.isNarrow) {
  127. tmpObj["Content_Narrow"].Name = "Arial Narrow";
  128. } else {
  129. if (tmpObj["Content"]) {
  130. tmpObj["Content_Narrow"].Name = tmpObj["Content"].Name;
  131. } else {
  132. tmpObj["Content_Narrow"].Name = "宋体";
  133. }
  134. }
  135. }
  136. defProperties.fonts = newFonts;
  137. //2. 页边距
  138. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_LEFT] = customizeCfg.margins[JV.PROP_LEFT] / 10;
  139. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_RIGHT] = customizeCfg.margins[JV.PROP_RIGHT] / 10;
  140. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_TOP] = customizeCfg.margins[JV.PROP_TOP] / 10;
  141. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_BOTTOM] = customizeCfg.margins[JV.PROP_BOTTOM] / 10;
  142. //3. 边框竖线
  143. if (!(customizeCfg.showVerticalLine)) {
  144. let private_copy_border = function (src) {
  145. let rst = {};
  146. rst.Position = src.Position;
  147. rst.LineWeight = src.LineWeight;
  148. rst.DashStyle = src.DashStyle;
  149. rst.Color = src.Color;
  150. return rst;
  151. };
  152. let newStyles = [];
  153. for (let i =0 ; i < defProperties.styles.length; i++) {
  154. let style = defProperties.styles[i];
  155. newStyles.push(style);
  156. if (style.ID === "BORDER_ALL_AROUND") {
  157. let newStyle = {};
  158. newStyle.ID = style.ID;
  159. newStyle.CfgDispName = style.CfgDispName;
  160. newStyle.border_style = [];
  161. for (let border of style.border_style) {
  162. let newBorder = private_copy_border(border);
  163. newStyle.border_style.push(newBorder);
  164. if (border.Position === "Left" || border.Position === "Right") {
  165. newBorder.LineWeight = 0;
  166. }
  167. }
  168. newStyles[newStyles.length - 1] = newStyle;
  169. }
  170. }
  171. defProperties.styles = newStyles;
  172. }
  173. //4. 补0
  174. let private_Setup_Format = function(tabFields) {
  175. if (tabFields) {
  176. for (let tabField of tabFields) {
  177. if (tabField[JV.PROP_FORMAT]) {
  178. tabField[JV.PROP_FORMAT] = tabField[JV.PROP_FORMAT].replace(new RegExp("#","gm"),"0");
  179. }
  180. }
  181. }
  182. };
  183. if (customizeCfg.fillZero) {
  184. if (rptTpl[JV.NODE_FLOW_INFO]) {
  185. 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]);
  186. 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]);
  187. 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]);
  188. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES])
  189. private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  190. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  191. for (let discrete of rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  192. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  193. }
  194. }
  195. if (rptTpl[JV.NODE_FLOW_INFO_EX]) {
  196. 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]);
  197. 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]);
  198. 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]);
  199. 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]);
  200. 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])
  201. private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  202. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  203. for (let discrete of rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  204. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  205. }
  206. }
  207. }
  208. } else if (rptTpl[JV.NODE_BILL_INFO]) {
  209. 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]);
  210. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  211. for (let discrete of rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  212. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  213. }
  214. }
  215. } else if (rptTpl[JV.NODE_CROSS_INFO]) {
  216. 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]);
  217. 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]);
  218. 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]);
  219. 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]);
  220. 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]);
  221. 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]);
  222. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  223. for (let discrete of rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  224. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  225. }
  226. }
  227. }
  228. }
  229. }
  230. function getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  231. let rptTpl = null;
  232. rptTplFacade.getRptTemplate(rpt_id).then(function(rst) {
  233. rptTpl = rst;
  234. if (rptTpl) {
  235. let rptDataUtil = new rptDataExtractor();
  236. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  237. let summaryRst = [], economicRst = [];
  238. let filter = rptDataUtil.getDataRequestFilter(summaryRst, economicRst);
  239. let promiseArr = [null, null, null];
  240. if (summaryRst.length > 0) {
  241. if (summaryRst.indexOf(`Construct`) >= 0 || summaryRst.indexOf(`ConstructDetail`) >= 0) {
  242. promiseArr[0] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.project);
  243. }
  244. if (summaryRst.indexOf(`Segment`) >= 0 || summaryRst.indexOf(`SegmentDetail`) >= 0) {
  245. promiseArr[1] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.engineering);
  246. }
  247. }
  248. if (economicRst.length > 0) {
  249. // economicRst.push('ProjectInfoFields');
  250. // economicRst.push('ProjectFeatureFields');
  251. promiseArr[2] = pm_facade.getIndexReportData(prj_id, economicRst);
  252. }
  253. rptTplDataFacade.prepareProjectData(user_id, prj_id, filter, function (err, msg, rawDataObj) {
  254. if (!err) {
  255. let buildPageData = function() {
  256. try {
  257. let tplData = rptDataUtil.assembleData(rawDataObj);
  258. let printCom = JpcEx.createNew();
  259. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  260. //console.log("orientation: " + (orientation === 'null'));
  261. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  262. let defProperties = rptUtil.getReportDefaultCache();
  263. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  264. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  265. printCom.initialize(rptTpl);
  266. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  267. let maxPages = printCom.totalPages;
  268. let pageRst = null;
  269. if (maxPages > 0) {
  270. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  271. } else {
  272. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  273. }
  274. if (pageRst) {
  275. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  276. cb(null, pageRst);
  277. } else {
  278. cb('Have errors while on going...', null);
  279. }
  280. } catch (ex) {
  281. console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  282. console.log(ex);
  283. cb('Exception occurs while on going...', null);
  284. }
  285. };
  286. //*/
  287. //取汇总数据流程
  288. if (promiseArr[0] !== null) {
  289. promiseArr[0].then(function (rst) {
  290. rawDataObj.Construct = rst.parent;
  291. rawDataObj.ConstructDetail = rst.subList;
  292. if (promiseArr[1] !== null) {
  293. promiseArr[1].then(function (rst) {
  294. rawDataObj.Segment = rst.parent;
  295. rawDataObj.SegmentDetail = rst.subList;
  296. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  297. });
  298. } else {
  299. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  300. }
  301. });
  302. } else if (promiseArr[1] !== null) {
  303. promiseArr[1].then(function (rst) {
  304. rawDataObj.Segment = rst.parent;
  305. rawDataObj.SegmentDetail = rst.subList;
  306. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  307. });
  308. } else {
  309. if (promiseArr[2] !== null) {
  310. promiseArr[2].then(function (rst) {
  311. let ecoFieldsRst = (rst._doc)?rst._doc:rst;
  312. // fsUtil.writeObjToFile(ecoFieldsRst, "D:/GitHome/ConstructionCost/tmp/testEcoFieldsResult.jsp");
  313. rawDataObj.prjData.push({moduleName: 'ProjectInfoFields', data: ecoFieldsRst.ProjectInfoFields});
  314. rawDataObj.prjData.push({moduleName: 'ProjectFeatureFields', data: ecoFieldsRst.ProjectFeatureFields});
  315. rawDataObj.prjData.push({moduleName: 'ProjectCostFields', data: ecoFieldsRst.ProjectCostFields});
  316. rawDataObj.prjData.push({moduleName: 'ProjectEcoFields', data: ecoFieldsRst.ProjectEcoFields});
  317. rawDataObj.prjData.push({moduleName: 'ProjectLabMaterialFields', data: ecoFieldsRst.ProjectLabMaterialFields});
  318. rawDataObj.prjData.push({moduleName: 'ProjectQtyFields', data: ecoFieldsRst.ProjectQtyFields});
  319. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  320. });
  321. } else {
  322. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  323. }
  324. }
  325. /*/
  326. let tplData = rptDataUtil.assembleData(rawDataObj);
  327. let printCom = JpcEx.createNew();
  328. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  329. //console.log("orientation: " + (orientation === 'null'));
  330. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  331. let defProperties = rptUtil.getReportDefaultCache();
  332. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  333. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  334. printCom.initialize(rptTpl);
  335. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  336. let maxPages = printCom.totalPages;
  337. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  338. if (pageRst) {
  339. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  340. cb(null, pageRst);
  341. } else {
  342. cb('Have errors while on going...', null);
  343. }
  344. //*/
  345. } else {
  346. cb('No report data were found!', null);
  347. }
  348. });
  349. } else {
  350. cb('No report template was found!', null);
  351. }
  352. })
  353. }
  354. function fillWaterMark(pageRstArray) {
  355. for (const pageRst of pageRstArray) {
  356. if (!pageRst[JV.NODE_FONT_COLLECTION].hasOwnProperty(JV.PROP_WATERMARK)) {
  357. pageRst[JV.NODE_FONT_COLLECTION][JV.PROP_WATERMARK] = WATERMARK_FONT;
  358. }
  359. for (const page of pageRst.items) {
  360. const warterCell = {
  361. "font": "WaterMark",
  362. "control": "NewContent_Center",
  363. "style": "Default_None",
  364. "Value": "大司空云计价",
  365. "area": {
  366. "Left": 300,
  367. "Right": 500,
  368. "Top": 300,
  369. "Bottom": 500
  370. }
  371. };
  372. //page.cells.push(warterCell);
  373. page.cells.unshift(warterCell);
  374. }
  375. }
  376. }
  377. module.exports = {
  378. getReportAllPages: function (req, res) {
  379. let params = JSON.parse(req.body.params),
  380. rpt_id = params.rpt_tpl_id,
  381. prj_id = params.prj_id,
  382. pageSize = params.pageSize,
  383. orientation = params.orientation,
  384. customizeCfg = params.custCfg
  385. ;
  386. // req.session.sessionUser.ssoId
  387. let user_id = req.session.sessionUser.id;
  388. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  389. try {
  390. let userModel = new UserModel();
  391. // console.log('req.session.sessionUser.ssoId: ' + req.session.sessionUser.ssoId);
  392. userModel.isFree(req.session.sessionUser.ssoId, params.compilation).then(function(rst) {
  393. // console.log('is Free user? ' + rst);
  394. if (rst) {
  395. //加水印!
  396. // fillWaterMark([pageRst]);
  397. }
  398. callback(req, res, err, pageRst);
  399. });
  400. } catch (error) {
  401. //
  402. } finally {
  403. //callback(req, res, err, pageRst);
  404. }
  405. });
  406. },
  407. getMultiReports: function (req, res) {
  408. let params = JSON.parse(req.body.params),
  409. prj_id = params.prj_id,
  410. rpt_ids = params.rpt_ids.split(','),
  411. pageSize = params.pageSize,
  412. orientation = params.orientation,
  413. customizeCfg = params.custCfg,
  414. option = params.option;
  415. let user_id = req.session.sessionUser.id;
  416. let parallelFunctions = [];
  417. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  418. for (let id of rpt_ids) {
  419. parallelFunctions.push((function (rpt_id) {
  420. return function (cb) {
  421. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  422. if(err){
  423. cb(err);
  424. }
  425. else{
  426. cb(null, pageRst);
  427. }
  428. })
  429. }
  430. })(parseInt(id)));
  431. }
  432. async.parallel(parallelFunctions, function (err, pageRstArray) {
  433. if (err) {
  434. callback(req, res, '数据有误', null);
  435. } else {
  436. callback(req, res, err, pageRstArray);
  437. }
  438. })
  439. },
  440. getMultiReportsEx: function (req, res) {
  441. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!(有空再整)
  442. let params = JSON.parse(req.body.params),
  443. prj_id = params.prj_id,
  444. rpt_ids = params.rpt_ids.split(','),
  445. pageSize = params.pageSize,
  446. orientation = params.orientation,
  447. customizeCfg = params.custCfg,
  448. option = params.option;
  449. let user_id = req.session.sessionUser.id;
  450. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  451. },
  452. getReportAllPagesSvg: function (req, res) {
  453. let params = JSON.parse(req.body.params),
  454. rpt_id = params.rpt_tpl_id,
  455. prj_id = params.prj_id,
  456. pageSize = params.pageSize,
  457. orientation = params.orientation,
  458. customizeCfg = params.custCfg
  459. ;
  460. let user_id = req.session.sessionUser.id;
  461. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  462. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  463. callback(req, res, err, svgRstStrArr);
  464. });
  465. },
  466. createExcelFilesInOneBook: function (req, res) {
  467. let params = JSON.parse(req.body.params),
  468. prj_id = params.prj_id,
  469. rpt_ids = params.rpt_ids,
  470. rptName = params.rptName,
  471. pageSize = params.pageSize,
  472. orientation = params.orientation,
  473. customizeCfg = params.custCfg,
  474. option = params.option;
  475. let user_id = req.session.sessionUser.id;
  476. let parallelFunctions = [];
  477. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  478. for (let idx = 0; idx < rpt_ids.length; idx++) {
  479. let r_id = rpt_ids[idx];
  480. parallelFunctions.push((function (rpt_id) {
  481. return function (cb) {
  482. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  483. if(err){
  484. cb(err);
  485. }
  486. else{
  487. cb(err, pageRst);
  488. }
  489. })
  490. }
  491. })(parseInt(r_id)));
  492. }
  493. async.parallel(parallelFunctions, function (err, pageRstArray) {
  494. if (err) {
  495. callback(req, res, '数据有误', null);
  496. } else {
  497. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(uuidName){
  498. let fileRst = {uuid: uuidName, reportName: rptName};
  499. callback(req, res, err, fileRst);
  500. });
  501. }
  502. })
  503. },
  504. createExcelFiles: function (req, res) {
  505. let params = JSON.parse(req.body.params),
  506. prj_id = params.prj_id,
  507. rpt_ids = params.rpt_ids,
  508. rpt_names = params.rpt_names,
  509. pageSize = params.pageSize,
  510. orientation = params.orientation,
  511. isOneSheet = params.isOneSheet,
  512. customizeCfg = params.custCfg,
  513. option = params.option;
  514. let user_id = req.session.sessionUser.id;
  515. let parallelFunctions = [];
  516. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  517. for (let idx = 0; idx < rpt_ids.length; idx++) {
  518. let r_id = rpt_ids[idx];
  519. let r_name = rpt_names[idx];
  520. parallelFunctions.push((function (rpt_id, rpt_name) {
  521. return function (cb) {
  522. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  523. if(err){
  524. cb(err);
  525. } else {
  526. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  527. let fileRst = {uuid: uuidName, reportName: rpt_name};
  528. cb(err, fileRst);
  529. })
  530. }
  531. })
  532. }
  533. })(parseInt(r_id), r_name));
  534. }
  535. async.parallel(parallelFunctions, function (err, fileRstArray) {
  536. if (err) {
  537. callback(req, res, '数据有误', null);
  538. } else {
  539. // console.log(err);
  540. callback(req, res, err, fileRstArray);
  541. }
  542. })
  543. },
  544. getFileByUUID: function (req, res) {
  545. let uuid = req.params.uuid,
  546. rptName = req.params.rptName,
  547. suffix = "." + req.params.suffix
  548. ;
  549. // let user_id = req.session.sessionUser.id; //未来要校验user id
  550. try {
  551. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  552. let rptNameURI = encodeURI(rptName);
  553. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  554. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  555. filestream.on('data', function(chunk) {
  556. res.write(chunk);
  557. });
  558. filestream.on('end', function() {
  559. res.end();
  560. });
  561. } catch (e) {
  562. console.log(e);
  563. }
  564. },
  565. getExcel: function(req, res) {
  566. let prj_id = req.params.prj_id,
  567. rpt_id = req.params.rpt_id,
  568. pageSize = req.params.size,
  569. orientation = req.params.orientation,
  570. rptName = req.params.rptName,
  571. isOneSheet = req.params.isOneSheet,
  572. option = req.params.option
  573. ;
  574. let customizeCfg = null;
  575. let user_id = req.session.sessionUser.id;
  576. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  577. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  578. try {
  579. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  580. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  581. let rptNameURI = encodeURI(rptName);
  582. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  583. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  584. filestream.on('data', function(chunk) {
  585. res.write(chunk);
  586. });
  587. filestream.on('end', function() {
  588. res.end();
  589. });
  590. });
  591. } catch (e) {
  592. console.log(e);
  593. }
  594. })
  595. },
  596. getExcelInOneBook: function (req, res) {
  597. let prj_id = req.params.prj_id,
  598. rpt_ids = req.params.rpt_ids.split(','),
  599. pageSize = req.params.size,
  600. rptName = req.params.rptName,
  601. option = req.params.option;
  602. let user_id = req.session.sessionUser.id;
  603. let parallelFunctions = [];
  604. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  605. for (let id of rpt_ids) {
  606. parallelFunctions.push((function (rpt_id) {
  607. return function (cb) {
  608. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  609. if(err){
  610. cb(err);
  611. }
  612. else{
  613. cb(null, pageRst);
  614. }
  615. })
  616. }
  617. })(parseInt(id)));
  618. }
  619. async.parallel(parallelFunctions, function (err, pageRstArray) {
  620. if (err) {
  621. callback(req, res, '数据有误', null);
  622. } else {
  623. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  624. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  625. let rptNameURI = encodeURI(rptName);
  626. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  627. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  628. filestream.on('data', function(chunk) {
  629. res.write(chunk);
  630. });
  631. filestream.on('end', function() {
  632. res.end();
  633. });
  634. });
  635. }
  636. })
  637. },
  638. createPdfFiles: function (req, res) {
  639. let params = JSON.parse(req.body.params),
  640. prj_id = params.prj_id,
  641. rpt_ids = params.rpt_ids,
  642. rpt_names = params.rpt_names,
  643. pageSize = params.pageSize,
  644. orientation = params.orientation,
  645. customizeCfg = params.custCfg,
  646. option = params.option;
  647. let user_id = req.session.sessionUser.id;
  648. let parallelFunctions = [];
  649. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  650. for (let idx = 0; idx < rpt_ids.length; idx++) {
  651. let r_id = rpt_ids[idx];
  652. let r_name = rpt_names[idx];
  653. parallelFunctions.push((function (rpt_id, rpt_name) {
  654. return function (cb) {
  655. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, pageRst) {
  656. if(err){
  657. cb(err);
  658. }
  659. else{
  660. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  661. let fileRst = {uuid: uuidName, reportName: rpt_name};
  662. cb(err, fileRst);
  663. })
  664. }
  665. })
  666. }
  667. })(parseInt(r_id), r_name));
  668. }
  669. async.parallel(parallelFunctions, function (err, fileRstArray) {
  670. if (err) {
  671. callback(req, res, '数据有误', null);
  672. } else {
  673. // console.log(err);
  674. callback(req, res, err, fileRstArray);
  675. }
  676. })
  677. },
  678. getPDF:function (req, res) {
  679. let prj_id = req.params.prj_id,
  680. rpt_id = req.params.rpt_id,
  681. pageSize = req.params.size,
  682. orientation = req.params.orientation,
  683. rptName = req.params.rptName
  684. ;
  685. let user_id = req.session.sessionUser.id;
  686. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  687. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  688. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  689. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  690. let rptNameURI = encodeURI(rptName);
  691. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  692. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  693. filestream.on('data', function(chunk) {
  694. res.write(chunk);
  695. });
  696. filestream.on('end', function() {
  697. res.end();
  698. });
  699. })
  700. })
  701. }
  702. };