rpt_controller.js 37 KB

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