rpt_controller.js 63 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261
  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_yanghu_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 = [];
  227. let filter = rptDataUtil.getDataRequestFilter(summaryRst);
  228. let promiseArr = [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. rptTplDataFacade.prepareProjectData(user_id, prj_id, filter, function (err, msg, rawDataObj) {
  238. if (!err) {
  239. let buildPageData = function() {
  240. try {
  241. let tplData = rptDataUtil.assembleData(rawDataObj);
  242. let printCom = JpcEx.createNew();
  243. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  244. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  245. let defProperties = rptUtil.getReportDefaultCache();
  246. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  247. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  248. printCom.initialize(rptTpl);
  249. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  250. let maxPages = printCom.totalPages;
  251. let pageRst = null;
  252. if (maxPages > 0) {
  253. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  254. } else {
  255. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  256. }
  257. if (pageRst) {
  258. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  259. cb(null, pageRst);
  260. } else {
  261. cb('Have errors while on going...', null);
  262. }
  263. } catch (ex) {
  264. console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  265. console.log(ex);
  266. cb('Exception occurs while on going...', null);
  267. }
  268. };
  269. //*/
  270. //取汇总数据流程
  271. if (promiseArr[0] !== null) {
  272. promiseArr[0].then(function (rst) {
  273. rawDataObj.Construct = rst.parent;
  274. rawDataObj.ConstructDetail = rst.subList;
  275. if (promiseArr[1] !== null) {
  276. promiseArr[1].then(function (rst) {
  277. rawDataObj.Segment = rst.parent;
  278. rawDataObj.SegmentDetail = rst.subList;
  279. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  280. });
  281. } else {
  282. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  283. }
  284. });
  285. } else 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. let tplData = rptDataUtil.assembleData(rawDataObj);
  296. let printCom = JpcEx.createNew();
  297. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  298. //console.log("orientation: " + (orientation === 'null'));
  299. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  300. let defProperties = rptUtil.getReportDefaultCache();
  301. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  302. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  303. printCom.initialize(rptTpl);
  304. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  305. let maxPages = printCom.totalPages;
  306. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  307. if (pageRst) {
  308. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  309. cb(null, pageRst);
  310. } else {
  311. cb('Have errors while on going...', null);
  312. }
  313. //*/
  314. } else {
  315. cb('No report data were found!', null);
  316. }
  317. });
  318. } else {
  319. cb('No report template was found!', null);
  320. }
  321. });
  322. }
  323. function getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, option, outputType, cb) {
  324. for (let idx = 0; idx < rpt_ids.length; idx++) {
  325. rpt_ids[idx] = parseInt(rpt_ids[idx]); //转换一下,以防万一
  326. }
  327. rptTplFacade.getRptTemplates(rpt_ids).then(function(rptTpls) {
  328. let rptDataUtil = new rptDataExtractor();
  329. let filters = [];
  330. if (rptTpls.length > 1) {
  331. rptTpls.sort(function (item1, item2){
  332. let i1 = (item1._doc)?item1._doc:item1, i2 = (item2._doc)?item2._doc:item2;
  333. let ID1 = rpt_ids.indexOf(i1[JV.PROP_ID]), ID2 = rpt_ids.indexOf(i2[JV.PROP_ID]);
  334. return ID1 - ID2;
  335. });
  336. }
  337. for (let rptTpl of rptTpls) {
  338. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  339. let filter = rptDataUtil.getDataRequestFilter();
  340. for (let dtlFilter of filter) {
  341. if (filters.indexOf(dtlFilter) < 0) {
  342. filters.push(dtlFilter);
  343. }
  344. }
  345. }
  346. //正常应该根据报表模板定义的数据类型来请求数据
  347. rptTplDataFacade.prepareProjectData(user_id, prj_id, filters, function (err, msg, rawDataObj) {
  348. if (!err) {
  349. try {
  350. let rptPageRstArray = [];
  351. //1. 这里只用一份数据,根据实际应用情况,只需要保留copy三样数据: bills, ration, ration_glj, projectGLJ
  352. let savedBillsData = [], savedRationData = [], savedGljData = [], savedPrjGljData = [], savedFeeRateData = [];
  353. for (let dtlData of rawDataObj.prjData) {
  354. if (dtlData.moduleName === 'bills') {
  355. Object.assign(savedBillsData, dtlData.data);
  356. } else if (dtlData.moduleName === 'ration') {
  357. Object.assign(savedRationData, dtlData.data);
  358. } else if (dtlData.moduleName === 'ration_glj') {
  359. Object.assign(savedGljData, dtlData.data);
  360. } else if (dtlData.moduleName === 'feeRate') {
  361. Object.assign(savedFeeRateData, dtlData.data._doc.rates);
  362. } else if (dtlData.moduleName === 'projectGLJ') {
  363. Object.assign(savedPrjGljData, dtlData.data.gljList);
  364. }
  365. }
  366. //2. 一个一个模板创建数据
  367. for (let tplIdx = 0; tplIdx < rptTpls.length; tplIdx++) {
  368. let rptTpl = (rptTpls[tplIdx]._doc)?rptTpls[tplIdx]._doc:rptTpls[tplIdx];
  369. rptDataUtil.initialize(rptTpl);
  370. let tplData = rptDataUtil.assembleData(rawDataObj);
  371. let printCom = JpcEx.createNew();
  372. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  373. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  374. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  375. let defProperties = rptUtil.getReportDefaultCache();
  376. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  377. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  378. printCom.initialize(rptTpl);
  379. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  380. let maxPages = printCom.totalPages;
  381. let pageRst = null;
  382. if (maxPages > 0) {
  383. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  384. } else {
  385. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  386. }
  387. rptPageRstArray.push(pageRst);
  388. //注意:这里需要把清单、定额、工料机数据assign回去!!!
  389. for (let dtlData of rawDataObj.prjData) {
  390. if (dtlData.moduleName === 'bills' && savedBillsData.length > 0) {
  391. Object.assign(dtlData.data, savedBillsData);
  392. } else if (dtlData.moduleName === 'ration' && savedRationData.length > 0) {
  393. Object.assign(dtlData.data, savedRationData);
  394. } else if (dtlData.moduleName === 'ration_glj' && savedGljData.length > 0) {
  395. Object.assign(dtlData.data, savedGljData);
  396. } else if (dtlData.moduleName === 'feeRate' && savedFeeRateData.length > 0) {
  397. Object.assign(dtlData.data._doc.rates, savedFeeRateData);
  398. } else if (dtlData.moduleName === 'projectGLJ' && savedPrjGljData.length > 0) {
  399. Object.assign(dtlData.data.gljList, savedPrjGljData);
  400. }
  401. }
  402. }
  403. cb(null, rptPageRstArray);
  404. } catch (ex) {
  405. console.log("报表数据异常(getMultiRptsCommon): userId " + user_id + ", project id: " + prj_id);
  406. console.log(ex);
  407. cb('Exception occurs while on going...', null);
  408. } finally {
  409. }
  410. } else {
  411. cb('No report data were found!', null);
  412. }
  413. })
  414. });
  415. }
  416. function getBillsSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  417. let rptTpl = null;
  418. rptTplDataFacade.getBudgetSummayDatas(prjIds).then(function(summaryRawDataRst) {
  419. // console.log(summaryRawDataRst);
  420. rptTplFacade.getRptTemplate(rpt_id).then(function(rptTpl) {
  421. let rptDataUtil = new rptDataExtractor();
  422. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  423. try {
  424. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  425. let printCom = JpcEx.createNew();
  426. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  427. //console.log("orientation: " + (orientation === 'null'));
  428. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  429. let defProperties = rptUtil.getReportDefaultCache();
  430. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  431. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  432. printCom.initialize(rptTpl);
  433. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  434. let maxPages = printCom.totalPages;
  435. let pageRst = null;
  436. if (maxPages > 0) {
  437. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  438. } else {
  439. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  440. }
  441. if (pageRst) {
  442. cb(null, pageRst);
  443. } else {
  444. cb('Have errors while on going...', null);
  445. }
  446. } catch (ex) {
  447. console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  448. console.log(ex);
  449. cb('Exception occurs while on going...', null);
  450. }
  451. });
  452. });
  453. }
  454. function getSummaryComboPages(user_id, prjIds, billsSummaryRpt_ids, gljSummaryRpt_ids, pageSize, orientation, customizeCfg, option, outputType, cb) {
  455. let pageRstArr = [];
  456. let pri_setup_rpt_tpl_data = function (rptTpl, summaryRawDataRst) {
  457. let rptDataUtil = new rptDataExtractor();
  458. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  459. try {
  460. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  461. let printCom = JpcEx.createNew();
  462. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  463. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  464. let defProperties = rptUtil.getReportDefaultCache();
  465. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  466. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  467. printCom.initialize(rptTpl);
  468. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  469. let maxPages = printCom.totalPages;
  470. let pageRst = null;
  471. if (maxPages > 0) {
  472. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  473. } else {
  474. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  475. }
  476. pageRstArr.push(pageRst);
  477. } catch (ex) {
  478. console.log("Summary报表数据异常: userId " + user_id + ", project ids: " + prjIds);
  479. console.log(ex);
  480. }
  481. };
  482. let billRpts = [], gljRpts = [];
  483. rptTplFacade.getRptTemplates(billsSummaryRpt_ids.concat(gljSummaryRpt_ids)).then(function(rptTpls) {
  484. if (rptTpls && rptTpls.length > 0) {
  485. for (let rptTpl of rptTpls) {
  486. if (billsSummaryRpt_ids.indexOf(rptTpl.ID) >= 0) {
  487. billRpts.push(rptTpl);
  488. } else if (gljSummaryRpt_ids.indexOf(rptTpl.ID) >= 0) {
  489. gljRpts.push(rptTpl);
  490. }
  491. }
  492. }
  493. if (billRpts.length > 0) {
  494. rptTplDataFacade.getBudgetSummayDatas(prjIds).then(function(summaryRawDataRst) {
  495. let savedBillsData = [];
  496. Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  497. for (let idx = 0; idx < billRpts.length; idx++) {
  498. pri_setup_rpt_tpl_data(billRpts[idx], summaryRawDataRst);
  499. if (idx < billRpts.length - 1) {
  500. Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  501. }
  502. }
  503. if (gljRpts && gljRpts.length > 0) {
  504. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  505. let savedBillsData = [];
  506. Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  507. for (let idx = 0; idx < gljRpts.length; idx++) {
  508. pri_setup_rpt_tpl_data(gljRpts[idx], summaryRawDataRst);
  509. if (idx < gljRpts.length - 1) {
  510. Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  511. }
  512. }
  513. cb(null, pageRstArr);
  514. });
  515. } else {
  516. cb(null, pageRstArr);
  517. }
  518. });
  519. } else if (gljRpts.length > 0) {
  520. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  521. let savedBillsData = [];
  522. Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  523. for (let idx = 0; idx < gljRpts.length; idx++) {
  524. pri_setup_rpt_tpl_data(gljRpts[idx], summaryRawDataRst);
  525. if (idx < gljRpts.length - 1) {
  526. Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  527. }
  528. }
  529. cb(null, pageRstArr);
  530. });
  531. }
  532. });
  533. }
  534. function getGljSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  535. let rptTpl = null;
  536. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  537. rptTplFacade.getRptTemplate(rpt_id).then(function(rptTpl) {
  538. let rptDataUtil = new rptDataExtractor();
  539. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  540. try {
  541. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  542. let printCom = JpcEx.createNew();
  543. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  544. //console.log("orientation: " + (orientation === 'null'));
  545. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  546. let defProperties = rptUtil.getReportDefaultCache();
  547. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  548. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  549. printCom.initialize(rptTpl);
  550. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  551. let maxPages = printCom.totalPages;
  552. let pageRst = null;
  553. if (maxPages > 0) {
  554. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  555. } else {
  556. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  557. }
  558. if (pageRst) {
  559. cb(null, pageRst);
  560. } else {
  561. cb('Have errors while on going...', null);
  562. }
  563. } catch (ex) {
  564. // console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  565. console.log(ex);
  566. cb('Exception occurs while on going...', null);
  567. }
  568. });
  569. });
  570. }
  571. module.exports = {
  572. getReportAllPages: function (req, res) {
  573. let params = JSON.parse(req.body.params),
  574. rpt_id = params.rpt_tpl_id,
  575. prj_id = params.prj_id,
  576. pageSize = params.pageSize,
  577. orientation = params.orientation,
  578. customizeCfg = params.custCfg
  579. ;
  580. // req.session.sessionUser.ssoId
  581. let user_id = req.session.sessionUser.id;
  582. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  583. callback(req, res, err, pageRst);
  584. });
  585. },
  586. getMultiReports: function (req, res) {
  587. //打印预览用
  588. let params = JSON.parse(req.body.params),
  589. prj_id = params.prj_id,
  590. rpt_ids = params.rpt_ids.split(','),
  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 id of rpt_ids) {
  599. parallelFunctions.push((function (rpt_id) {
  600. return function (cb) {
  601. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  602. if(err){
  603. cb(err);
  604. }
  605. else{
  606. cb(null, pageRst);
  607. }
  608. })
  609. }
  610. })(parseInt(id)));
  611. }
  612. async.parallel(parallelFunctions, function (err, pageRstArray) {
  613. if (err) {
  614. callback(req, res, '数据有误', null);
  615. } else {
  616. callback(req, res, err, pageRstArray);
  617. }
  618. })
  619. },
  620. getMultiReportsEx: function (req, res) {
  621. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  622. let params = JSON.parse(req.body.params),
  623. prj_id = params.prj_id,
  624. rpt_ids = params.rpt_ids,
  625. //--以下是汇总类数据----------
  626. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  627. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  628. prjIds = params.prjIds,
  629. //------------
  630. pageSize = params.pageSize,
  631. orientation = params.orientation,
  632. customizeCfg = params.custCfg,
  633. option = params.option;
  634. let user_id = req.session.sessionUser.id;
  635. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  636. if (rpt_ids && rpt_ids.length > 0) {
  637. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  638. if (err) {
  639. callback(req, res, '数据有误', null);
  640. } else {
  641. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  642. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  643. callback(req, res, err, rptSumPageRstArray.concat(rptPageRstArray));
  644. });
  645. } else {
  646. callback(req, res, err, rptPageRstArray);
  647. }
  648. }
  649. });
  650. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  651. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  652. callback(req, res, err, rptSumPageRstArray);
  653. });
  654. }
  655. },
  656. getBillSummaryReportPages: function (req, res) {
  657. let params = JSON.parse(req.body.params),
  658. rpt_id = params.rpt_tpl_id,
  659. prjIds = params.prjIds,
  660. pageSize = params.pageSize,
  661. orientation = params.orientation,
  662. customizeCfg = params.custCfg
  663. ;
  664. let user_id = req.session.sessionUser.id;
  665. getBillsSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  666. callback(req, res, err, pageRst);
  667. });
  668. },
  669. getGljSummaryReportPages: function (req, res) {
  670. let params = JSON.parse(req.body.params),
  671. rpt_id = params.rpt_tpl_id,
  672. prjIds = params.prjIds,
  673. pageSize = params.pageSize,
  674. orientation = params.orientation,
  675. customizeCfg = params.custCfg
  676. ;
  677. let user_id = req.session.sessionUser.id;
  678. getGljSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  679. callback(req, res, err, pageRst);
  680. });
  681. },
  682. createSummaryReportFiles: function (req, res) {
  683. let params = JSON.parse(req.body.params),
  684. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  685. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  686. prjIds = params.prjIds,
  687. pageSize = params.pageSize,
  688. orientation = params.orientation,
  689. customizeCfg = params.custCfg
  690. ;
  691. let user_id = req.session.sessionUser.id;
  692. },
  693. getReportAllPagesSvg: function (req, res) {
  694. let params = JSON.parse(req.body.params),
  695. rpt_id = params.rpt_tpl_id,
  696. prj_id = params.prj_id,
  697. pageSize = params.pageSize,
  698. orientation = params.orientation,
  699. customizeCfg = params.custCfg
  700. ;
  701. let user_id = req.session.sessionUser.id;
  702. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  703. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  704. callback(req, res, err, svgRstStrArr);
  705. });
  706. },
  707. createExcelFilesInOneBook: function (req, res) {
  708. let params = JSON.parse(req.body.params),
  709. prj_id = params.prj_id,
  710. rpt_ids = params.rpt_ids,
  711. rptName = params.rptName,
  712. pageSize = params.pageSize,
  713. orientation = params.orientation,
  714. customizeCfg = params.custCfg,
  715. option = params.option;
  716. let user_id = req.session.sessionUser.id;
  717. let parallelFunctions = [];
  718. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  719. for (let idx = 0; idx < rpt_ids.length; idx++) {
  720. let r_id = rpt_ids[idx];
  721. parallelFunctions.push((function (rpt_id) {
  722. return function (cb) {
  723. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  724. if(err){
  725. cb(err);
  726. }
  727. else{
  728. cb(err, pageRst);
  729. }
  730. })
  731. }
  732. })(parseInt(r_id)));
  733. }
  734. async.parallel(parallelFunctions, function (err, pageRstArray) {
  735. if (err) {
  736. callback(req, res, '数据有误', null);
  737. } else {
  738. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(uuidName){
  739. let fileRst = {uuid: uuidName, reportName: rptName};
  740. callback(req, res, err, fileRst);
  741. });
  742. }
  743. })
  744. },
  745. createExcelFilesInOneBookEx: function (req, res) {
  746. //采用了优化策略
  747. let params = JSON.parse(req.body.params),
  748. prj_id = params.prj_id,
  749. rpt_ids = params.rpt_ids,
  750. //--以下是汇总类数据----------
  751. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  752. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  753. prjIds = params.prjIds,
  754. //------------
  755. rptName = params.rptName,
  756. pageSize = params.pageSize,
  757. orientation = params.orientation,
  758. customizeCfg = params.custCfg,
  759. option = params.option;
  760. let user_id = req.session.sessionUser.id;
  761. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  762. if (rpt_ids && rpt_ids.length > 0) {
  763. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  764. if(err){
  765. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  766. callback(req, res, '数据有误', null);
  767. } else {
  768. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  769. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  770. rpt_xl_util.exportExcelInOneBook(rptPageRstArray.concat(rptSumPageRstArray), pageSize, rptName, function(uuidName){
  771. let fileRst = {uuid: uuidName, reportName: rptName};
  772. callback(req, res, err, fileRst);
  773. });
  774. });
  775. } else {
  776. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  777. let fileRst = {uuid: uuidName, reportName: rptName};
  778. callback(req, res, err, fileRst);
  779. });
  780. }
  781. }
  782. });
  783. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  784. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  785. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  786. let fileRst = {uuid: uuidName, reportName: rptName};
  787. callback(req, res, err, fileRst);
  788. });
  789. });
  790. }
  791. },
  792. createExcelFiles: function (req, res) {
  793. let params = JSON.parse(req.body.params),
  794. prj_id = params.prj_id,
  795. rpt_ids = params.rpt_ids,
  796. rpt_names = params.rpt_names,
  797. pageSize = params.pageSize,
  798. orientation = params.orientation,
  799. isOneSheet = params.isOneSheet,
  800. customizeCfg = params.custCfg,
  801. option = params.option;
  802. let user_id = req.session.sessionUser.id;
  803. let parallelFunctions = [];
  804. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  805. for (let idx = 0; idx < rpt_ids.length; idx++) {
  806. let r_id = rpt_ids[idx];
  807. let r_name = rpt_names[idx];
  808. parallelFunctions.push((function (rpt_id, rpt_name) {
  809. return function (cb) {
  810. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  811. if(err){
  812. cb(err);
  813. } else {
  814. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  815. let fileRst = {uuid: uuidName, reportName: rpt_name};
  816. cb(err, fileRst);
  817. })
  818. }
  819. })
  820. }
  821. })(parseInt(r_id), r_name));
  822. }
  823. async.parallel(parallelFunctions, function (err, fileRstArray) {
  824. if (err) {
  825. callback(req, res, '数据有误', null);
  826. } else {
  827. // console.log(err);
  828. callback(req, res, err, fileRstArray);
  829. }
  830. })
  831. },
  832. createExcelFilesEx: function (req, res) {
  833. let params = JSON.parse(req.body.params),
  834. prj_id = params.prj_id,
  835. rpt_ids = params.rpt_ids,
  836. //--以下是汇总类数据----------
  837. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  838. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  839. prjIds = params.prjIds,
  840. sum_rpt_names = params.sum_rpt_names,
  841. //------------
  842. rpt_names = params.rpt_names,
  843. pageSize = params.pageSize,
  844. orientation = params.orientation,
  845. isOneSheet = params.isOneSheet,
  846. customizeCfg = params.custCfg,
  847. option = params.option;
  848. let user_id = req.session.sessionUser.id;
  849. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  850. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  851. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  852. parallelFunctions.push((function (pageRst, rpt_name) {
  853. return function (cb) {
  854. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  855. let fileRst = {uuid: uuidName, reportName: rpt_name};
  856. cb(err, fileRst);
  857. })
  858. };
  859. })(rptPageRstArray[idx], paraRptNames[idx]));
  860. }
  861. };
  862. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  863. async.parallel(parallelFunctions, function (err, fileRstArray) {
  864. if (err) {
  865. console.log('导出Excel错误(导出数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  866. callback(req, res, '数据导出错误', null);
  867. } else {
  868. // console.log(err);
  869. callback(req, res, err, fileRstArray);
  870. }
  871. });
  872. };
  873. if (rpt_ids && rpt_ids.length > 0) {
  874. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  875. if (err) {
  876. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  877. callback(req, res, '数据生成错误', null);
  878. } else {
  879. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  880. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  881. let parallelFunctions = [];
  882. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  883. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  884. pri_Run_Parallel_Functions(parallelFunctions);
  885. });
  886. } else {
  887. let parallelFunctions = [];
  888. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  889. pri_Run_Parallel_Functions(parallelFunctions);
  890. }
  891. }
  892. });
  893. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  894. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  895. let parallelFunctions = [];
  896. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  897. pri_Run_Parallel_Functions(parallelFunctions);
  898. });
  899. }
  900. },
  901. getFileByUUID: function (req, res) {
  902. let uuid = req.params.uuid,
  903. rptName = req.params.rptName,
  904. suffix = "." + req.params.suffix
  905. ;
  906. // let user_id = req.session.sessionUser.id; //未来要校验user id
  907. try {
  908. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  909. let rptNameURI = encodeURI(rptName);
  910. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  911. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  912. filestream.on('data', function(chunk) {
  913. res.write(chunk);
  914. });
  915. filestream.on('end', function() {
  916. res.end();
  917. });
  918. } catch (e) {
  919. console.log(e);
  920. }
  921. },
  922. getExcel: function(req, res) {
  923. let prj_id = req.params.prj_id,
  924. rpt_id = req.params.rpt_id,
  925. pageSize = req.params.size,
  926. orientation = req.params.orientation,
  927. rptName = req.params.rptName,
  928. isOneSheet = req.params.isOneSheet,
  929. option = req.params.option
  930. ;
  931. let customizeCfg = null;
  932. let user_id = req.session.sessionUser.id;
  933. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  934. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  935. try {
  936. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  937. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  938. let rptNameURI = encodeURI(rptName);
  939. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  940. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  941. filestream.on('data', function(chunk) {
  942. res.write(chunk);
  943. });
  944. filestream.on('end', function() {
  945. res.end();
  946. });
  947. });
  948. } catch (e) {
  949. console.log(e);
  950. }
  951. })
  952. },
  953. getExcelInOneBook: function (req, res) {
  954. let prj_id = req.params.prj_id,
  955. rpt_ids = req.params.rpt_ids.split(','),
  956. pageSize = req.params.size,
  957. rptName = req.params.rptName,
  958. option = req.params.option;
  959. let user_id = req.session.sessionUser.id;
  960. let parallelFunctions = [];
  961. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  962. for (let id of rpt_ids) {
  963. parallelFunctions.push((function (rpt_id) {
  964. return function (cb) {
  965. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  966. if(err){
  967. cb(err);
  968. }
  969. else{
  970. cb(null, pageRst);
  971. }
  972. })
  973. }
  974. })(parseInt(id)));
  975. }
  976. async.parallel(parallelFunctions, function (err, pageRstArray) {
  977. if (err) {
  978. callback(req, res, '数据有误', null);
  979. } else {
  980. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  981. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  982. let rptNameURI = encodeURI(rptName);
  983. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  984. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  985. filestream.on('data', function(chunk) {
  986. res.write(chunk);
  987. });
  988. filestream.on('end', function() {
  989. res.end();
  990. });
  991. });
  992. }
  993. })
  994. },
  995. createPdfFiles: function (req, res) {
  996. let params = JSON.parse(req.body.params),
  997. prj_id = params.prj_id,
  998. rpt_ids = params.rpt_ids,
  999. rpt_names = params.rpt_names,
  1000. pageSize = params.pageSize,
  1001. orientation = params.orientation,
  1002. customizeCfg = params.custCfg,
  1003. option = params.option;
  1004. let user_id = req.session.sessionUser.id;
  1005. let parallelFunctions = [];
  1006. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1007. for (let idx = 0; idx < rpt_ids.length; idx++) {
  1008. let r_id = rpt_ids[idx];
  1009. let r_name = rpt_names[idx];
  1010. parallelFunctions.push((function (rpt_id, rpt_name) {
  1011. return function (cb) {
  1012. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, pageRst) {
  1013. if(err){
  1014. cb(err);
  1015. }
  1016. else{
  1017. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  1018. let fileRst = {uuid: uuidName, reportName: rpt_name};
  1019. cb(err, fileRst);
  1020. })
  1021. }
  1022. })
  1023. }
  1024. })(parseInt(r_id), r_name));
  1025. }
  1026. async.parallel(parallelFunctions, function (err, fileRstArray) {
  1027. if (err) {
  1028. callback(req, res, '数据有误', null);
  1029. } else {
  1030. // console.log(err);
  1031. callback(req, res, err, fileRstArray);
  1032. }
  1033. })
  1034. },
  1035. createPdfFilesEx: function (req, res) {
  1036. let params = JSON.parse(req.body.params),
  1037. prj_id = params.prj_id,
  1038. rpt_ids = params.rpt_ids,
  1039. rpt_names = params.rpt_names,
  1040. //--以下是汇总类数据----------
  1041. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  1042. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  1043. prjIds = params.prjIds,
  1044. sum_rpt_names = params.sum_rpt_names,
  1045. //------------
  1046. pageSize = params.pageSize,
  1047. orientation = params.orientation,
  1048. customizeCfg = params.custCfg,
  1049. option = params.option;
  1050. let user_id = req.session.sessionUser.id;
  1051. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1052. console.log('start!');
  1053. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  1054. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  1055. parallelFunctions.push((function (pageRst, rpt_name) {
  1056. return function (cb) {
  1057. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  1058. let fileRst = {uuid: uuidName, reportName: rpt_name};
  1059. cb(err, fileRst);
  1060. })
  1061. };
  1062. })(rptPageRstArray[idx], paraRptNames[idx]));
  1063. }
  1064. };
  1065. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  1066. async.parallel(parallelFunctions, function (err, fileRstArray) {
  1067. if (err) {
  1068. console.log('导出PDF错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  1069. callback(req, res, '数据导出错误', null);
  1070. } else {
  1071. // console.log(err);
  1072. callback(req, res, err, fileRstArray);
  1073. }
  1074. });
  1075. };
  1076. if (rpt_ids && rpt_ids.length > 0) {
  1077. console.log(0);
  1078. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  1079. if (err) {
  1080. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  1081. callback(req, res, '数据生成错误', null);
  1082. } else {
  1083. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  1084. console.log(1);
  1085. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  1086. let parallelFunctions = [];
  1087. console.log(2);
  1088. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  1089. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  1090. pri_Run_Parallel_Functions(parallelFunctions);
  1091. });
  1092. } else {
  1093. console.log(3);
  1094. let parallelFunctions = [];
  1095. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  1096. pri_Run_Parallel_Functions(parallelFunctions);
  1097. }
  1098. }
  1099. });
  1100. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  1101. console.log(10);
  1102. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  1103. let parallelFunctions = [];
  1104. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  1105. pri_Run_Parallel_Functions(parallelFunctions);
  1106. });
  1107. }
  1108. },
  1109. getPDF:function (req, res) {
  1110. let prj_id = req.params.prj_id,
  1111. rpt_id = req.params.rpt_id,
  1112. pageSize = req.params.size,
  1113. orientation = req.params.orientation,
  1114. rptName = req.params.rptName
  1115. ;
  1116. let user_id = req.session.sessionUser.id;
  1117. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  1118. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  1119. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1120. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  1121. let rptNameURI = encodeURI(rptName);
  1122. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  1123. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  1124. filestream.on('data', function(chunk) {
  1125. res.write(chunk);
  1126. });
  1127. filestream.on('end', function() {
  1128. res.end();
  1129. });
  1130. })
  1131. })
  1132. },
  1133. getTestReportAllPages: function(req, res){
  1134. let rpt_id = req.body.ID;
  1135. let pageSize = req.body.pageSize;
  1136. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  1137. //fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  1138. callback(req, res, err, pageRst);
  1139. })
  1140. },
  1141. getTestExcel: function(req, res) {
  1142. let rpt_id = req.params.id,
  1143. pageSize = req.params.size,
  1144. rptName = req.params.rptName,
  1145. isOneSheet = req.params.isOneSheet,
  1146. option = req.params.option;
  1147. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1148. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function(err, pageRst){
  1149. fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  1150. try {
  1151. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  1152. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1153. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  1154. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  1155. filestream.on('data', function(chunk) {
  1156. res.write(chunk);
  1157. });
  1158. filestream.on('end', function() {
  1159. res.end();
  1160. });
  1161. });
  1162. } catch (e) {
  1163. console.log(e);
  1164. }
  1165. })
  1166. },
  1167. getTestExcelInOneBook: function(req, res) {
  1168. let rpt_ids = req.params.ids.split(','),
  1169. pageSize = req.params.size,
  1170. rptName = req.params.rptName,
  1171. option = req.params.option;
  1172. let parallelFunctions = [];
  1173. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1174. for (let id of rpt_ids) {
  1175. parallelFunctions.push((function (rpt_id) {
  1176. return function (cb) {
  1177. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function (err, pageRst) {
  1178. if(err){
  1179. cb(err);
  1180. }
  1181. else{
  1182. cb(null, pageRst);
  1183. }
  1184. })
  1185. }
  1186. })(parseInt(id)));
  1187. }
  1188. async.parallel(parallelFunctions, function (err, pageRstArray) {
  1189. if (err) {
  1190. callback(req, res, '数据有误', null);
  1191. } else {
  1192. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  1193. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1194. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  1195. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  1196. filestream.on('data', function(chunk) {
  1197. res.write(chunk);
  1198. });
  1199. filestream.on('end', function() {
  1200. res.end();
  1201. });
  1202. });
  1203. //callback(req, res, false, '', {compilation: rst, gljLibs: gljLibsRst});
  1204. }
  1205. })
  1206. },
  1207. getTestPDF:function (req, res) {
  1208. let rpt_id = req.params.id,
  1209. pageSize = req.params.size,
  1210. rptName = req.params.rptName;
  1211. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  1212. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  1213. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1214. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  1215. let rptNameURI = encodeURI(rptName);
  1216. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  1217. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  1218. filestream.on('data', function(chunk) {
  1219. res.write(chunk);
  1220. });
  1221. filestream.on('end', function() {
  1222. res.end();
  1223. });
  1224. })
  1225. })
  1226. }
  1227. };