rpt_controller.js 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764
  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 getEcoFieldsData() {
  220. let dummyDataObj = null;
  221. let data = fs.readFileSync('D:/Temp/demoFieldData.js', 'utf8', 'r');
  222. eval('dummyDataObj = ' + data + ';');
  223. return dummyDataObj;
  224. }
  225. function getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  226. let rptTpl = null;
  227. rptTplFacade.getRptTemplate(rpt_id).then(function(rst) {
  228. rptTpl = rst;
  229. if (rptTpl) {
  230. let rptDataUtil = new rptDataExtractor();
  231. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  232. let summaryRst = [], economicRst = [];
  233. let filter = rptDataUtil.getDataRequestFilter(summaryRst, economicRst);
  234. let promiseArr = [null, null, null];
  235. if (summaryRst.length > 0) {
  236. if (summaryRst.indexOf(`Construct`) >= 0 || summaryRst.indexOf(`ConstructDetail`) >= 0) {
  237. promiseArr[0] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.project);
  238. }
  239. if (summaryRst.indexOf(`Segment`) >= 0 || summaryRst.indexOf(`SegmentDetail`) >= 0) {
  240. promiseArr[1] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.engineering);
  241. }
  242. }
  243. if (economicRst.length > 0) {
  244. promiseArr[2] = getEcoFieldsData();
  245. }
  246. rptTplDataFacade.prepareProjectData(user_id, prj_id, filter, function (err, msg, rawDataObj) {
  247. if (!err) {
  248. let buildPageData = function() {
  249. try {
  250. let tplData = rptDataUtil.assembleData(rawDataObj);
  251. let printCom = JpcEx.createNew();
  252. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  253. //console.log("orientation: " + (orientation === 'null'));
  254. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  255. let defProperties = rptUtil.getReportDefaultCache();
  256. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  257. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  258. printCom.initialize(rptTpl);
  259. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  260. let maxPages = printCom.totalPages;
  261. let pageRst = null;
  262. if (maxPages > 0) {
  263. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  264. } else {
  265. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  266. }
  267. if (pageRst) {
  268. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  269. cb(null, pageRst);
  270. } else {
  271. cb('Have errors while on going...', null);
  272. }
  273. } catch (ex) {
  274. console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  275. console.log(ex);
  276. cb('Exception occurs while on going...', null);
  277. }
  278. };
  279. //*/
  280. //取汇总数据流程
  281. if (promiseArr[0] !== null) {
  282. promiseArr[0].then(function (rst) {
  283. rawDataObj.Construct = rst.parent;
  284. rawDataObj.ConstructDetail = rst.subList;
  285. if (promiseArr[1] !== null) {
  286. promiseArr[1].then(function (rst) {
  287. rawDataObj.Segment = rst.parent;
  288. rawDataObj.SegmentDetail = rst.subList;
  289. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  290. });
  291. } else {
  292. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  293. }
  294. });
  295. } else if (promiseArr[1] !== null) {
  296. promiseArr[1].then(function (rst) {
  297. rawDataObj.Segment = rst.parent;
  298. rawDataObj.SegmentDetail = rst.subList;
  299. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  300. });
  301. } else {
  302. if (promiseArr[2] !== null) {
  303. //暂时这样测试
  304. rawDataObj.prjData.push({moduleName: 'ProjectCostFields', data: promiseArr[2].ProjectCostFields});
  305. rawDataObj.prjData.push({moduleName: 'ProjectEcoFields', data: promiseArr[2].ProjectEcoFields});
  306. rawDataObj.prjData.push({moduleName: 'ProjectLabMaterialFields', data: promiseArr[2].ProjectLabMaterialFields});
  307. rawDataObj.prjData.push({moduleName: 'ProjectQtyFields', data: promiseArr[2].ProjectQtyFields});
  308. }
  309. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  310. }
  311. /*/
  312. let tplData = rptDataUtil.assembleData(rawDataObj);
  313. let printCom = JpcEx.createNew();
  314. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  315. //console.log("orientation: " + (orientation === 'null'));
  316. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  317. let defProperties = rptUtil.getReportDefaultCache();
  318. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  319. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  320. printCom.initialize(rptTpl);
  321. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  322. let maxPages = printCom.totalPages;
  323. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  324. if (pageRst) {
  325. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  326. cb(null, pageRst);
  327. } else {
  328. cb('Have errors while on going...', null);
  329. }
  330. //*/
  331. } else {
  332. cb('No report data were found!', null);
  333. }
  334. });
  335. } else {
  336. cb('No report template was found!', null);
  337. }
  338. })
  339. }
  340. module.exports = {
  341. getReportAllPages: function (req, res) {
  342. let params = JSON.parse(req.body.params),
  343. rpt_id = params.rpt_tpl_id,
  344. prj_id = params.prj_id,
  345. pageSize = params.pageSize,
  346. orientation = params.orientation,
  347. customizeCfg = params.custCfg
  348. ;
  349. // req.session.sessionUser.ssoId
  350. let user_id = req.session.sessionUser.id;
  351. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  352. callback(req, res, err, pageRst);
  353. });
  354. },
  355. getMultiReports: function (req, res) {
  356. let params = JSON.parse(req.body.params),
  357. prj_id = params.prj_id,
  358. rpt_ids = params.rpt_ids.split(','),
  359. pageSize = params.pageSize,
  360. orientation = params.orientation,
  361. customizeCfg = params.custCfg,
  362. option = params.option;
  363. let user_id = req.session.sessionUser.id;
  364. let parallelFunctions = [];
  365. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  366. for (let id of rpt_ids) {
  367. parallelFunctions.push((function (rpt_id) {
  368. return function (cb) {
  369. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  370. if(err){
  371. cb(err);
  372. }
  373. else{
  374. cb(null, pageRst);
  375. }
  376. })
  377. }
  378. })(parseInt(id)));
  379. }
  380. async.parallel(parallelFunctions, function (err, pageRstArray) {
  381. if (err) {
  382. callback(req, res, '数据有误', null);
  383. } else {
  384. callback(req, res, err, pageRstArray);
  385. }
  386. })
  387. },
  388. getMultiReportsEx: function (req, res) {
  389. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!(有空再整)
  390. let params = JSON.parse(req.body.params),
  391. prj_id = params.prj_id,
  392. rpt_ids = params.rpt_ids.split(','),
  393. pageSize = params.pageSize,
  394. orientation = params.orientation,
  395. customizeCfg = params.custCfg,
  396. option = params.option;
  397. let user_id = req.session.sessionUser.id;
  398. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  399. },
  400. getReportAllPagesSvg: function (req, res) {
  401. let params = JSON.parse(req.body.params),
  402. rpt_id = params.rpt_tpl_id,
  403. prj_id = params.prj_id,
  404. pageSize = params.pageSize,
  405. orientation = params.orientation,
  406. customizeCfg = params.custCfg
  407. ;
  408. let user_id = req.session.sessionUser.id;
  409. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  410. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  411. callback(req, res, err, svgRstStrArr);
  412. });
  413. },
  414. createExcelFilesInOneBook: function (req, res) {
  415. let params = JSON.parse(req.body.params),
  416. prj_id = params.prj_id,
  417. rpt_ids = params.rpt_ids,
  418. rptName = params.rptName,
  419. pageSize = params.pageSize,
  420. orientation = params.orientation,
  421. customizeCfg = params.custCfg,
  422. option = params.option;
  423. let user_id = req.session.sessionUser.id;
  424. let parallelFunctions = [];
  425. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  426. for (let idx = 0; idx < rpt_ids.length; idx++) {
  427. let r_id = rpt_ids[idx];
  428. parallelFunctions.push((function (rpt_id) {
  429. return function (cb) {
  430. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  431. if(err){
  432. cb(err);
  433. }
  434. else{
  435. cb(err, pageRst);
  436. }
  437. })
  438. }
  439. })(parseInt(r_id)));
  440. }
  441. async.parallel(parallelFunctions, function (err, pageRstArray) {
  442. if (err) {
  443. callback(req, res, '数据有误', null);
  444. } else {
  445. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(uuidName){
  446. let fileRst = {uuid: uuidName, reportName: rptName};
  447. callback(req, res, err, fileRst);
  448. });
  449. }
  450. })
  451. },
  452. createExcelFiles: function (req, res) {
  453. let params = JSON.parse(req.body.params),
  454. prj_id = params.prj_id,
  455. rpt_ids = params.rpt_ids,
  456. rpt_names = params.rpt_names,
  457. pageSize = params.pageSize,
  458. orientation = params.orientation,
  459. isOneSheet = params.isOneSheet,
  460. customizeCfg = params.custCfg,
  461. option = params.option;
  462. let user_id = req.session.sessionUser.id;
  463. let parallelFunctions = [];
  464. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  465. for (let idx = 0; idx < rpt_ids.length; idx++) {
  466. let r_id = rpt_ids[idx];
  467. let r_name = rpt_names[idx];
  468. parallelFunctions.push((function (rpt_id, rpt_name) {
  469. return function (cb) {
  470. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  471. if(err){
  472. cb(err);
  473. } else {
  474. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  475. let fileRst = {uuid: uuidName, reportName: rpt_name};
  476. cb(err, fileRst);
  477. })
  478. }
  479. })
  480. }
  481. })(parseInt(r_id), r_name));
  482. }
  483. async.parallel(parallelFunctions, function (err, fileRstArray) {
  484. if (err) {
  485. callback(req, res, '数据有误', null);
  486. } else {
  487. // console.log(err);
  488. callback(req, res, err, fileRstArray);
  489. }
  490. })
  491. },
  492. getFileByUUID: function (req, res) {
  493. let uuid = req.params.uuid,
  494. rptName = req.params.rptName,
  495. suffix = "." + req.params.suffix
  496. ;
  497. // let user_id = req.session.sessionUser.id; //未来要校验user id
  498. try {
  499. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  500. let rptNameURI = encodeURI(rptName);
  501. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  502. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  503. filestream.on('data', function(chunk) {
  504. res.write(chunk);
  505. });
  506. filestream.on('end', function() {
  507. res.end();
  508. });
  509. } catch (e) {
  510. console.log(e);
  511. }
  512. },
  513. getExcel: function(req, res) {
  514. let prj_id = req.params.prj_id,
  515. rpt_id = req.params.rpt_id,
  516. pageSize = req.params.size,
  517. orientation = req.params.orientation,
  518. rptName = req.params.rptName,
  519. isOneSheet = req.params.isOneSheet,
  520. option = req.params.option
  521. ;
  522. let customizeCfg = null;
  523. let user_id = req.session.sessionUser.id;
  524. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  525. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  526. try {
  527. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  528. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  529. let rptNameURI = encodeURI(rptName);
  530. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  531. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  532. filestream.on('data', function(chunk) {
  533. res.write(chunk);
  534. });
  535. filestream.on('end', function() {
  536. res.end();
  537. });
  538. });
  539. } catch (e) {
  540. console.log(e);
  541. }
  542. })
  543. },
  544. getExcelInOneBook: function (req, res) {
  545. let prj_id = req.params.prj_id,
  546. rpt_ids = req.params.rpt_ids.split(','),
  547. pageSize = req.params.size,
  548. rptName = req.params.rptName,
  549. option = req.params.option;
  550. let user_id = req.session.sessionUser.id;
  551. let parallelFunctions = [];
  552. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  553. for (let id of rpt_ids) {
  554. parallelFunctions.push((function (rpt_id) {
  555. return function (cb) {
  556. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  557. if(err){
  558. cb(err);
  559. }
  560. else{
  561. cb(null, pageRst);
  562. }
  563. })
  564. }
  565. })(parseInt(id)));
  566. }
  567. async.parallel(parallelFunctions, function (err, pageRstArray) {
  568. if (err) {
  569. callback(req, res, '数据有误', null);
  570. } else {
  571. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  572. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  573. let rptNameURI = encodeURI(rptName);
  574. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  575. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  576. filestream.on('data', function(chunk) {
  577. res.write(chunk);
  578. });
  579. filestream.on('end', function() {
  580. res.end();
  581. });
  582. });
  583. }
  584. })
  585. },
  586. createPdfFiles: function (req, res) {
  587. let params = JSON.parse(req.body.params),
  588. prj_id = params.prj_id,
  589. rpt_ids = params.rpt_ids,
  590. rpt_names = params.rpt_names,
  591. pageSize = params.pageSize,
  592. orientation = params.orientation,
  593. customizeCfg = params.custCfg,
  594. option = params.option;
  595. let user_id = req.session.sessionUser.id;
  596. let parallelFunctions = [];
  597. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  598. for (let idx = 0; idx < rpt_ids.length; idx++) {
  599. let r_id = rpt_ids[idx];
  600. let r_name = rpt_names[idx];
  601. parallelFunctions.push((function (rpt_id, rpt_name) {
  602. return function (cb) {
  603. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, pageRst) {
  604. if(err){
  605. cb(err);
  606. }
  607. else{
  608. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  609. let fileRst = {uuid: uuidName, reportName: rpt_name};
  610. cb(err, fileRst);
  611. })
  612. }
  613. })
  614. }
  615. })(parseInt(r_id), r_name));
  616. }
  617. async.parallel(parallelFunctions, function (err, fileRstArray) {
  618. if (err) {
  619. callback(req, res, '数据有误', null);
  620. } else {
  621. // console.log(err);
  622. callback(req, res, err, fileRstArray);
  623. }
  624. })
  625. },
  626. getPDF:function (req, res) {
  627. let prj_id = req.params.prj_id,
  628. rpt_id = req.params.rpt_id,
  629. pageSize = req.params.size,
  630. orientation = req.params.orientation,
  631. rptName = req.params.rptName
  632. ;
  633. let user_id = req.session.sessionUser.id;
  634. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  635. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  636. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  637. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  638. let rptNameURI = encodeURI(rptName);
  639. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  640. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  641. filestream.on('data', function(chunk) {
  642. res.write(chunk);
  643. });
  644. filestream.on('end', function() {
  645. res.end();
  646. });
  647. })
  648. })
  649. },
  650. getTestReportAllPages: function(req, res){
  651. let rpt_id = req.body.ID;
  652. let pageSize = req.body.pageSize;
  653. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  654. //fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  655. callback(req, res, err, pageRst);
  656. })
  657. },
  658. getTestExcel: function(req, res) {
  659. let rpt_id = req.params.id,
  660. pageSize = req.params.size,
  661. rptName = req.params.rptName,
  662. isOneSheet = req.params.isOneSheet,
  663. option = req.params.option;
  664. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  665. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function(err, pageRst){
  666. fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  667. try {
  668. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  669. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  670. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  671. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  672. filestream.on('data', function(chunk) {
  673. res.write(chunk);
  674. });
  675. filestream.on('end', function() {
  676. res.end();
  677. });
  678. });
  679. } catch (e) {
  680. console.log(e);
  681. }
  682. })
  683. },
  684. getTestExcelInOneBook: function(req, res) {
  685. let rpt_ids = req.params.ids.split(','),
  686. pageSize = req.params.size,
  687. rptName = req.params.rptName,
  688. option = req.params.option;
  689. let parallelFunctions = [];
  690. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  691. for (let id of rpt_ids) {
  692. parallelFunctions.push((function (rpt_id) {
  693. return function (cb) {
  694. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function (err, pageRst) {
  695. if(err){
  696. cb(err);
  697. }
  698. else{
  699. cb(null, pageRst);
  700. }
  701. })
  702. }
  703. })(parseInt(id)));
  704. }
  705. async.parallel(parallelFunctions, function (err, pageRstArray) {
  706. if (err) {
  707. callback(req, res, '数据有误', null);
  708. } else {
  709. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  710. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  711. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  712. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  713. filestream.on('data', function(chunk) {
  714. res.write(chunk);
  715. });
  716. filestream.on('end', function() {
  717. res.end();
  718. });
  719. });
  720. //callback(req, res, false, '', {compilation: rst, gljLibs: gljLibsRst});
  721. }
  722. })
  723. },
  724. getTestPDF:function (req, res) {
  725. let rpt_id = req.params.id,
  726. pageSize = req.params.size,
  727. rptName = req.params.rptName;
  728. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  729. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  730. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  731. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  732. let rptNameURI = encodeURI(rptName);
  733. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  734. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  735. filestream.on('data', function(chunk) {
  736. res.write(chunk);
  737. });
  738. filestream.on('end', function() {
  739. res.end();
  740. });
  741. })
  742. })
  743. }
  744. };