rpt_controller.js 63 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262
  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. // fsUtil.writeObjToFile(summaryRawDataRst, "D:/GitHome/temp/summaryRawDataRstRawData.jsp");
  542. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  543. let printCom = JpcEx.createNew();
  544. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  545. //console.log("orientation: " + (orientation === 'null'));
  546. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  547. let defProperties = rptUtil.getReportDefaultCache();
  548. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  549. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  550. printCom.initialize(rptTpl);
  551. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  552. let maxPages = printCom.totalPages;
  553. let pageRst = null;
  554. if (maxPages > 0) {
  555. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  556. } else {
  557. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  558. }
  559. if (pageRst) {
  560. cb(null, pageRst);
  561. } else {
  562. cb('Have errors while on going...', null);
  563. }
  564. } catch (ex) {
  565. // console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  566. console.log(ex);
  567. cb('Exception occurs while on going...', null);
  568. }
  569. });
  570. });
  571. }
  572. module.exports = {
  573. getReportAllPages: function (req, res) {
  574. let params = JSON.parse(req.body.params),
  575. rpt_id = params.rpt_tpl_id,
  576. prj_id = params.prj_id,
  577. pageSize = params.pageSize,
  578. orientation = params.orientation,
  579. customizeCfg = params.custCfg
  580. ;
  581. // req.session.sessionUser.ssoId
  582. let user_id = req.session.sessionUser.id;
  583. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  584. callback(req, res, err, pageRst);
  585. });
  586. },
  587. getMultiReports: function (req, res) {
  588. //打印预览用
  589. let params = JSON.parse(req.body.params),
  590. prj_id = params.prj_id,
  591. rpt_ids = params.rpt_ids.split(','),
  592. pageSize = params.pageSize,
  593. orientation = params.orientation,
  594. customizeCfg = params.custCfg,
  595. option = params.option;
  596. let user_id = req.session.sessionUser.id;
  597. let parallelFunctions = [];
  598. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  599. for (let id of rpt_ids) {
  600. parallelFunctions.push((function (rpt_id) {
  601. return function (cb) {
  602. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  603. if(err){
  604. cb(err);
  605. }
  606. else{
  607. cb(null, pageRst);
  608. }
  609. })
  610. }
  611. })(parseInt(id)));
  612. }
  613. async.parallel(parallelFunctions, function (err, pageRstArray) {
  614. if (err) {
  615. callback(req, res, '数据有误', null);
  616. } else {
  617. callback(req, res, err, pageRstArray);
  618. }
  619. })
  620. },
  621. getMultiReportsEx: function (req, res) {
  622. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  623. let params = JSON.parse(req.body.params),
  624. prj_id = params.prj_id,
  625. rpt_ids = params.rpt_ids,
  626. //--以下是汇总类数据----------
  627. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  628. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  629. prjIds = params.prjIds,
  630. //------------
  631. pageSize = params.pageSize,
  632. orientation = params.orientation,
  633. customizeCfg = params.custCfg,
  634. option = params.option;
  635. let user_id = req.session.sessionUser.id;
  636. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  637. if (rpt_ids && rpt_ids.length > 0) {
  638. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  639. if (err) {
  640. callback(req, res, '数据有误', null);
  641. } else {
  642. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  643. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  644. callback(req, res, err, rptSumPageRstArray.concat(rptPageRstArray));
  645. });
  646. } else {
  647. callback(req, res, err, rptPageRstArray);
  648. }
  649. }
  650. });
  651. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  652. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  653. callback(req, res, err, rptSumPageRstArray);
  654. });
  655. }
  656. },
  657. getBillSummaryReportPages: function (req, res) {
  658. let params = JSON.parse(req.body.params),
  659. rpt_id = params.rpt_tpl_id,
  660. prjIds = params.prjIds,
  661. pageSize = params.pageSize,
  662. orientation = params.orientation,
  663. customizeCfg = params.custCfg
  664. ;
  665. let user_id = req.session.sessionUser.id;
  666. getBillsSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  667. callback(req, res, err, pageRst);
  668. });
  669. },
  670. getGljSummaryReportPages: function (req, res) {
  671. let params = JSON.parse(req.body.params),
  672. rpt_id = params.rpt_tpl_id,
  673. prjIds = params.prjIds,
  674. pageSize = params.pageSize,
  675. orientation = params.orientation,
  676. customizeCfg = params.custCfg
  677. ;
  678. let user_id = req.session.sessionUser.id;
  679. getGljSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  680. callback(req, res, err, pageRst);
  681. });
  682. },
  683. createSummaryReportFiles: function (req, res) {
  684. let params = JSON.parse(req.body.params),
  685. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  686. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  687. prjIds = params.prjIds,
  688. pageSize = params.pageSize,
  689. orientation = params.orientation,
  690. customizeCfg = params.custCfg
  691. ;
  692. let user_id = req.session.sessionUser.id;
  693. },
  694. getReportAllPagesSvg: function (req, res) {
  695. let params = JSON.parse(req.body.params),
  696. rpt_id = params.rpt_tpl_id,
  697. prj_id = params.prj_id,
  698. pageSize = params.pageSize,
  699. orientation = params.orientation,
  700. customizeCfg = params.custCfg
  701. ;
  702. let user_id = req.session.sessionUser.id;
  703. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  704. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  705. callback(req, res, err, svgRstStrArr);
  706. });
  707. },
  708. createExcelFilesInOneBook: function (req, res) {
  709. let params = JSON.parse(req.body.params),
  710. prj_id = params.prj_id,
  711. rpt_ids = params.rpt_ids,
  712. rptName = params.rptName,
  713. pageSize = params.pageSize,
  714. orientation = params.orientation,
  715. customizeCfg = params.custCfg,
  716. option = params.option;
  717. let user_id = req.session.sessionUser.id;
  718. let parallelFunctions = [];
  719. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  720. for (let idx = 0; idx < rpt_ids.length; idx++) {
  721. let r_id = rpt_ids[idx];
  722. parallelFunctions.push((function (rpt_id) {
  723. return function (cb) {
  724. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  725. if(err){
  726. cb(err);
  727. }
  728. else{
  729. cb(err, pageRst);
  730. }
  731. })
  732. }
  733. })(parseInt(r_id)));
  734. }
  735. async.parallel(parallelFunctions, function (err, pageRstArray) {
  736. if (err) {
  737. callback(req, res, '数据有误', null);
  738. } else {
  739. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(uuidName){
  740. let fileRst = {uuid: uuidName, reportName: rptName};
  741. callback(req, res, err, fileRst);
  742. });
  743. }
  744. })
  745. },
  746. createExcelFilesInOneBookEx: function (req, res) {
  747. //采用了优化策略
  748. let params = JSON.parse(req.body.params),
  749. prj_id = params.prj_id,
  750. rpt_ids = params.rpt_ids,
  751. //--以下是汇总类数据----------
  752. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  753. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  754. prjIds = params.prjIds,
  755. //------------
  756. rptName = params.rptName,
  757. pageSize = params.pageSize,
  758. orientation = params.orientation,
  759. customizeCfg = params.custCfg,
  760. option = params.option;
  761. let user_id = req.session.sessionUser.id;
  762. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  763. if (rpt_ids && rpt_ids.length > 0) {
  764. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  765. if(err){
  766. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  767. callback(req, res, '数据有误', null);
  768. } else {
  769. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  770. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  771. rpt_xl_util.exportExcelInOneBook(rptPageRstArray.concat(rptSumPageRstArray), pageSize, rptName, function(uuidName){
  772. let fileRst = {uuid: uuidName, reportName: rptName};
  773. callback(req, res, err, fileRst);
  774. });
  775. });
  776. } else {
  777. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  778. let fileRst = {uuid: uuidName, reportName: rptName};
  779. callback(req, res, err, fileRst);
  780. });
  781. }
  782. }
  783. });
  784. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  785. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  786. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  787. let fileRst = {uuid: uuidName, reportName: rptName};
  788. callback(req, res, err, fileRst);
  789. });
  790. });
  791. }
  792. },
  793. createExcelFiles: function (req, res) {
  794. let params = JSON.parse(req.body.params),
  795. prj_id = params.prj_id,
  796. rpt_ids = params.rpt_ids,
  797. rpt_names = params.rpt_names,
  798. pageSize = params.pageSize,
  799. orientation = params.orientation,
  800. isOneSheet = params.isOneSheet,
  801. customizeCfg = params.custCfg,
  802. option = params.option;
  803. let user_id = req.session.sessionUser.id;
  804. let parallelFunctions = [];
  805. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  806. for (let idx = 0; idx < rpt_ids.length; idx++) {
  807. let r_id = rpt_ids[idx];
  808. let r_name = rpt_names[idx];
  809. parallelFunctions.push((function (rpt_id, rpt_name) {
  810. return function (cb) {
  811. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  812. if(err){
  813. cb(err);
  814. } else {
  815. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  816. let fileRst = {uuid: uuidName, reportName: rpt_name};
  817. cb(err, fileRst);
  818. })
  819. }
  820. })
  821. }
  822. })(parseInt(r_id), r_name));
  823. }
  824. async.parallel(parallelFunctions, function (err, fileRstArray) {
  825. if (err) {
  826. callback(req, res, '数据有误', null);
  827. } else {
  828. // console.log(err);
  829. callback(req, res, err, fileRstArray);
  830. }
  831. })
  832. },
  833. createExcelFilesEx: function (req, res) {
  834. let params = JSON.parse(req.body.params),
  835. prj_id = params.prj_id,
  836. rpt_ids = params.rpt_ids,
  837. //--以下是汇总类数据----------
  838. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  839. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  840. prjIds = params.prjIds,
  841. sum_rpt_names = params.sum_rpt_names,
  842. //------------
  843. rpt_names = params.rpt_names,
  844. pageSize = params.pageSize,
  845. orientation = params.orientation,
  846. isOneSheet = params.isOneSheet,
  847. customizeCfg = params.custCfg,
  848. option = params.option;
  849. let user_id = req.session.sessionUser.id;
  850. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  851. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  852. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  853. parallelFunctions.push((function (pageRst, rpt_name) {
  854. return function (cb) {
  855. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  856. let fileRst = {uuid: uuidName, reportName: rpt_name};
  857. cb(err, fileRst);
  858. })
  859. };
  860. })(rptPageRstArray[idx], paraRptNames[idx]));
  861. }
  862. };
  863. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  864. async.parallel(parallelFunctions, function (err, fileRstArray) {
  865. if (err) {
  866. console.log('导出Excel错误(导出数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  867. callback(req, res, '数据导出错误', null);
  868. } else {
  869. // console.log(err);
  870. callback(req, res, err, fileRstArray);
  871. }
  872. });
  873. };
  874. if (rpt_ids && rpt_ids.length > 0) {
  875. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  876. if (err) {
  877. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  878. callback(req, res, '数据生成错误', null);
  879. } else {
  880. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  881. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  882. let parallelFunctions = [];
  883. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  884. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  885. pri_Run_Parallel_Functions(parallelFunctions);
  886. });
  887. } else {
  888. let parallelFunctions = [];
  889. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  890. pri_Run_Parallel_Functions(parallelFunctions);
  891. }
  892. }
  893. });
  894. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  895. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  896. let parallelFunctions = [];
  897. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  898. pri_Run_Parallel_Functions(parallelFunctions);
  899. });
  900. }
  901. },
  902. getFileByUUID: function (req, res) {
  903. let uuid = req.params.uuid,
  904. rptName = req.params.rptName,
  905. suffix = "." + req.params.suffix
  906. ;
  907. // let user_id = req.session.sessionUser.id; //未来要校验user id
  908. try {
  909. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  910. let rptNameURI = encodeURI(rptName);
  911. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  912. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  913. filestream.on('data', function(chunk) {
  914. res.write(chunk);
  915. });
  916. filestream.on('end', function() {
  917. res.end();
  918. });
  919. } catch (e) {
  920. console.log(e);
  921. }
  922. },
  923. getExcel: function(req, res) {
  924. let prj_id = req.params.prj_id,
  925. rpt_id = req.params.rpt_id,
  926. pageSize = req.params.size,
  927. orientation = req.params.orientation,
  928. rptName = req.params.rptName,
  929. isOneSheet = req.params.isOneSheet,
  930. option = req.params.option
  931. ;
  932. let customizeCfg = null;
  933. let user_id = req.session.sessionUser.id;
  934. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  935. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  936. try {
  937. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  938. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  939. let rptNameURI = encodeURI(rptName);
  940. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  941. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  942. filestream.on('data', function(chunk) {
  943. res.write(chunk);
  944. });
  945. filestream.on('end', function() {
  946. res.end();
  947. });
  948. });
  949. } catch (e) {
  950. console.log(e);
  951. }
  952. })
  953. },
  954. getExcelInOneBook: function (req, res) {
  955. let prj_id = req.params.prj_id,
  956. rpt_ids = req.params.rpt_ids.split(','),
  957. pageSize = req.params.size,
  958. rptName = req.params.rptName,
  959. option = req.params.option;
  960. let user_id = req.session.sessionUser.id;
  961. let parallelFunctions = [];
  962. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  963. for (let id of rpt_ids) {
  964. parallelFunctions.push((function (rpt_id) {
  965. return function (cb) {
  966. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  967. if(err){
  968. cb(err);
  969. }
  970. else{
  971. cb(null, pageRst);
  972. }
  973. })
  974. }
  975. })(parseInt(id)));
  976. }
  977. async.parallel(parallelFunctions, function (err, pageRstArray) {
  978. if (err) {
  979. callback(req, res, '数据有误', null);
  980. } else {
  981. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  982. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  983. let rptNameURI = encodeURI(rptName);
  984. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  985. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  986. filestream.on('data', function(chunk) {
  987. res.write(chunk);
  988. });
  989. filestream.on('end', function() {
  990. res.end();
  991. });
  992. });
  993. }
  994. })
  995. },
  996. createPdfFiles: function (req, res) {
  997. let params = JSON.parse(req.body.params),
  998. prj_id = params.prj_id,
  999. rpt_ids = params.rpt_ids,
  1000. rpt_names = params.rpt_names,
  1001. pageSize = params.pageSize,
  1002. orientation = params.orientation,
  1003. customizeCfg = params.custCfg,
  1004. option = params.option;
  1005. let user_id = req.session.sessionUser.id;
  1006. let parallelFunctions = [];
  1007. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1008. for (let idx = 0; idx < rpt_ids.length; idx++) {
  1009. let r_id = rpt_ids[idx];
  1010. let r_name = rpt_names[idx];
  1011. parallelFunctions.push((function (rpt_id, rpt_name) {
  1012. return function (cb) {
  1013. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, pageRst) {
  1014. if(err){
  1015. cb(err);
  1016. }
  1017. else{
  1018. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  1019. let fileRst = {uuid: uuidName, reportName: rpt_name};
  1020. cb(err, fileRst);
  1021. })
  1022. }
  1023. })
  1024. }
  1025. })(parseInt(r_id), r_name));
  1026. }
  1027. async.parallel(parallelFunctions, function (err, fileRstArray) {
  1028. if (err) {
  1029. callback(req, res, '数据有误', null);
  1030. } else {
  1031. // console.log(err);
  1032. callback(req, res, err, fileRstArray);
  1033. }
  1034. })
  1035. },
  1036. createPdfFilesEx: function (req, res) {
  1037. let params = JSON.parse(req.body.params),
  1038. prj_id = params.prj_id,
  1039. rpt_ids = params.rpt_ids,
  1040. rpt_names = params.rpt_names,
  1041. //--以下是汇总类数据----------
  1042. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  1043. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  1044. prjIds = params.prjIds,
  1045. sum_rpt_names = params.sum_rpt_names,
  1046. //------------
  1047. pageSize = params.pageSize,
  1048. orientation = params.orientation,
  1049. customizeCfg = params.custCfg,
  1050. option = params.option;
  1051. let user_id = req.session.sessionUser.id;
  1052. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1053. console.log('start!');
  1054. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  1055. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  1056. parallelFunctions.push((function (pageRst, rpt_name) {
  1057. return function (cb) {
  1058. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  1059. let fileRst = {uuid: uuidName, reportName: rpt_name};
  1060. cb(err, fileRst);
  1061. })
  1062. };
  1063. })(rptPageRstArray[idx], paraRptNames[idx]));
  1064. }
  1065. };
  1066. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  1067. async.parallel(parallelFunctions, function (err, fileRstArray) {
  1068. if (err) {
  1069. console.log('导出PDF错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  1070. callback(req, res, '数据导出错误', null);
  1071. } else {
  1072. // console.log(err);
  1073. callback(req, res, err, fileRstArray);
  1074. }
  1075. });
  1076. };
  1077. if (rpt_ids && rpt_ids.length > 0) {
  1078. console.log(0);
  1079. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  1080. if (err) {
  1081. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  1082. callback(req, res, '数据生成错误', null);
  1083. } else {
  1084. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  1085. console.log(1);
  1086. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  1087. let parallelFunctions = [];
  1088. console.log(2);
  1089. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  1090. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  1091. pri_Run_Parallel_Functions(parallelFunctions);
  1092. });
  1093. } else {
  1094. console.log(3);
  1095. let parallelFunctions = [];
  1096. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  1097. pri_Run_Parallel_Functions(parallelFunctions);
  1098. }
  1099. }
  1100. });
  1101. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  1102. console.log(10);
  1103. getSummaryComboPages(user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  1104. let parallelFunctions = [];
  1105. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  1106. pri_Run_Parallel_Functions(parallelFunctions);
  1107. });
  1108. }
  1109. },
  1110. getPDF:function (req, res) {
  1111. let prj_id = req.params.prj_id,
  1112. rpt_id = req.params.rpt_id,
  1113. pageSize = req.params.size,
  1114. orientation = req.params.orientation,
  1115. rptName = req.params.rptName
  1116. ;
  1117. let user_id = req.session.sessionUser.id;
  1118. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  1119. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  1120. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1121. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  1122. let rptNameURI = encodeURI(rptName);
  1123. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  1124. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  1125. filestream.on('data', function(chunk) {
  1126. res.write(chunk);
  1127. });
  1128. filestream.on('end', function() {
  1129. res.end();
  1130. });
  1131. })
  1132. })
  1133. },
  1134. getTestReportAllPages: function(req, res){
  1135. let rpt_id = req.body.ID;
  1136. let pageSize = req.body.pageSize;
  1137. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  1138. //fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  1139. callback(req, res, err, pageRst);
  1140. })
  1141. },
  1142. getTestExcel: function(req, res) {
  1143. let rpt_id = req.params.id,
  1144. pageSize = req.params.size,
  1145. rptName = req.params.rptName,
  1146. isOneSheet = req.params.isOneSheet,
  1147. option = req.params.option;
  1148. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1149. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function(err, pageRst){
  1150. fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  1151. try {
  1152. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  1153. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1154. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  1155. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  1156. filestream.on('data', function(chunk) {
  1157. res.write(chunk);
  1158. });
  1159. filestream.on('end', function() {
  1160. res.end();
  1161. });
  1162. });
  1163. } catch (e) {
  1164. console.log(e);
  1165. }
  1166. })
  1167. },
  1168. getTestExcelInOneBook: function(req, res) {
  1169. let rpt_ids = req.params.ids.split(','),
  1170. pageSize = req.params.size,
  1171. rptName = req.params.rptName,
  1172. option = req.params.option;
  1173. let parallelFunctions = [];
  1174. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  1175. for (let id of rpt_ids) {
  1176. parallelFunctions.push((function (rpt_id) {
  1177. return function (cb) {
  1178. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function (err, pageRst) {
  1179. if(err){
  1180. cb(err);
  1181. }
  1182. else{
  1183. cb(null, pageRst);
  1184. }
  1185. })
  1186. }
  1187. })(parseInt(id)));
  1188. }
  1189. async.parallel(parallelFunctions, function (err, pageRstArray) {
  1190. if (err) {
  1191. callback(req, res, '数据有误', null);
  1192. } else {
  1193. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  1194. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1195. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  1196. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  1197. filestream.on('data', function(chunk) {
  1198. res.write(chunk);
  1199. });
  1200. filestream.on('end', function() {
  1201. res.end();
  1202. });
  1203. });
  1204. //callback(req, res, false, '', {compilation: rst, gljLibs: gljLibsRst});
  1205. }
  1206. })
  1207. },
  1208. getTestPDF:function (req, res) {
  1209. let rpt_id = req.params.id,
  1210. pageSize = req.params.size,
  1211. rptName = req.params.rptName;
  1212. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  1213. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  1214. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  1215. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  1216. let rptNameURI = encodeURI(rptName);
  1217. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  1218. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  1219. filestream.on('data', function(chunk) {
  1220. res.write(chunk);
  1221. });
  1222. filestream.on('end', function() {
  1223. res.end();
  1224. });
  1225. })
  1226. })
  1227. }
  1228. };