rpt_controller.js 29 KB

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