rpt_controller.js 63 KB

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