rpt_controller.js 64 KB

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