rpt_controller.js 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008
  1. /**
  2. * Created by Tony on 2017/3/13.
  3. */
  4. const mongoose = require("mongoose");
  5. const async = require("async");
  6. const JV = require("../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. const rptTplFacade = require("../facade/rpt_template_facade");
  12. const demoTemplateFacade = require("../facade/rpt_tpl_data_demo_facade");
  13. const JpcEx = require("../rpt_component/jpc_ex");
  14. const rptUtil = require("../util/rpt_util");
  15. const rpt_xl_util = require("../util/rpt_excel_util");
  16. const rpt_pdf_util = require("../util/rpt_pdf_util");
  17. const rpt_svg_util = require("../util/rpt_svg_util");
  18. const fs = require("fs");
  19. const strUtil = require("../../../public/stringUtil");
  20. const rptDataExtractor = require("../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.message);
  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.sessionUser.id, req.session.sessionCompilation._id, 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. // fsUtil.writeObjToFile(summaryRawDataRst, "D:/GitHome/temp/billsSummaryRawDataRstRawData.jsp");
  426. let printCom = JpcEx.createNew();
  427. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  428. //console.log("orientation: " + (orientation === 'null'));
  429. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  430. let defProperties = rptUtil.getReportDefaultCache();
  431. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  432. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  433. printCom.initialize(rptTpl);
  434. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  435. let maxPages = printCom.totalPages;
  436. let pageRst = null;
  437. if (maxPages > 0) {
  438. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  439. } else {
  440. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  441. }
  442. if (pageRst) {
  443. cb(null, pageRst);
  444. } else {
  445. cb('Have errors while on going...', null);
  446. }
  447. } catch (ex) {
  448. console.log("报表数据异常: userId " + user_id + ", project id: " + JSON.stringify(prjIds));
  449. console.log(ex.message);
  450. cb('Exception occurs while on going...', null);
  451. }
  452. });
  453. });
  454. }
  455. function getSummaryComboPages(req, user_id, prjIds, billsSummaryRpt_ids, gljSummaryRpt_ids, pageSize, orientation, customizeCfg, option, outputType, cb) {
  456. let pageRstArr = [];
  457. let pri_setup_rpt_tpl_data = function (rptTpl, summaryRawDataRst) {
  458. let rptDataUtil = new rptDataExtractor();
  459. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  460. try {
  461. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  462. let printCom = JpcEx.createNew();
  463. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  464. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  465. let defProperties = rptUtil.getReportDefaultCache();
  466. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  467. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  468. printCom.initialize(rptTpl);
  469. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  470. let maxPages = printCom.totalPages;
  471. let pageRst = null;
  472. if (maxPages > 0) {
  473. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  474. } else {
  475. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  476. }
  477. pageRstArr.push(pageRst);
  478. } catch (ex) {
  479. console.log("Summary报表数据异常: userId " + user_id + ", project ids: " + prjIds);
  480. console.log(ex.message);
  481. }
  482. };
  483. let billRpts = [], gljRpts = [];
  484. rptTplFacade.getRptTemplates(billsSummaryRpt_ids.concat(gljSummaryRpt_ids)).then(function(rptTpls) {
  485. if (rptTpls && rptTpls.length > 0) {
  486. for (let rptTpl of rptTpls) {
  487. if (billsSummaryRpt_ids.indexOf(rptTpl.ID) >= 0) {
  488. billRpts.push(rptTpl);
  489. } else if (gljSummaryRpt_ids.indexOf(rptTpl.ID) >= 0) {
  490. gljRpts.push(rptTpl);
  491. }
  492. }
  493. }
  494. if (billRpts.length > 0) {
  495. rptTplDataFacade.getBudgetSummayDatas(prjIds, req.session.sessionUser.id, req.session.sessionCompilation._id, req.session.sessionCompilation.overWriteUrl).then(function(summaryRawDataRst) {
  496. // let savedBillsData = [];
  497. try {
  498. // Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  499. for (let idx = 0; idx < billRpts.length; idx++) {
  500. pri_setup_rpt_tpl_data(billRpts[idx], summaryRawDataRst);
  501. // if (idx < billRpts.length - 1) {
  502. // Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  503. // }
  504. }
  505. if (gljRpts && gljRpts.length > 0) {
  506. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  507. // let savedBillsData = [];
  508. // Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  509. for (let idx = 0; idx < gljRpts.length; idx++) {
  510. pri_setup_rpt_tpl_data(gljRpts[idx], summaryRawDataRst);
  511. // if (idx < gljRpts.length - 1) {
  512. // Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  513. // }
  514. }
  515. cb(null, pageRstArr);
  516. });
  517. } else {
  518. cb(null, pageRstArr);
  519. }
  520. } catch (ex) {
  521. console.log(ex);
  522. cb(null, pageRstArr);
  523. }
  524. });
  525. } else if (gljRpts.length > 0) {
  526. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  527. // let savedBillsData = [];
  528. // Object.assign(savedBillsData, summaryRawDataRst.SummaryAuditDetail);
  529. // 养护工料机汇总不用考虑back up问题。模板需要自觉一点,不要修改数据!!!
  530. for (let idx = 0; idx < gljRpts.length; idx++) {
  531. pri_setup_rpt_tpl_data(gljRpts[idx], summaryRawDataRst);
  532. if (idx < gljRpts.length - 1) {
  533. // Object.assign(summaryRawDataRst.SummaryAuditDetail, savedBillsData);
  534. }
  535. }
  536. cb(null, pageRstArr);
  537. });
  538. }
  539. });
  540. }
  541. function getGljSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  542. let rptTpl = null;
  543. rptTplDataFacade.getGLJSummayDatas(prjIds).then(function(summaryRawDataRst) {
  544. rptTplFacade.getRptTemplate(rpt_id).then(function(rptTpl) {
  545. let rptDataUtil = new rptDataExtractor();
  546. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  547. try {
  548. // fsUtil.writeObjToFile(summaryRawDataRst, "D:/GitHome/temp/gljSummaryRawDataRstRawData.jsp");
  549. let tplData = rptDataUtil.assembleData(summaryRawDataRst);
  550. let printCom = JpcEx.createNew();
  551. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  552. //console.log("orientation: " + (orientation === 'null'));
  553. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  554. let defProperties = rptUtil.getReportDefaultCache();
  555. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  556. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  557. printCom.initialize(rptTpl);
  558. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  559. let maxPages = printCom.totalPages;
  560. let pageRst = null;
  561. if (maxPages > 0) {
  562. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  563. } else {
  564. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  565. }
  566. if (pageRst) {
  567. cb(null, pageRst);
  568. } else {
  569. cb('Have errors while on going...', null);
  570. }
  571. } catch (ex) {
  572. // console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  573. console.log(ex);
  574. cb('Exception occurs while on going...', null);
  575. }
  576. });
  577. });
  578. }
  579. module.exports = {
  580. getReportAllPages: function (req, res) {
  581. let params = JSON.parse(req.body.params),
  582. rpt_id = params.rpt_tpl_id,
  583. prj_id = params.prj_id,
  584. pageSize = params.pageSize,
  585. orientation = params.orientation,
  586. customizeCfg = params.custCfg
  587. ;
  588. // req.session.sessionUser.ssoId
  589. let user_id = req.session.sessionUser.id;
  590. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  591. callback(req, res, err, pageRst);
  592. });
  593. },
  594. getMultiReportsEx: function (req, res) {
  595. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!
  596. let params = JSON.parse(req.body.params),
  597. prj_id = params.prj_id,
  598. rpt_ids = params.rpt_ids,
  599. //--以下是汇总类数据----------
  600. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  601. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  602. prjIds = params.prjIds,
  603. //------------
  604. pageSize = params.pageSize,
  605. orientation = params.orientation,
  606. customizeCfg = params.custCfg,
  607. option = params.option;
  608. let user_id = req.session.sessionUser.id;
  609. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  610. if (rpt_ids && rpt_ids.length > 0) {
  611. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  612. if (err) {
  613. callback(req, res, '数据有误', null);
  614. } else {
  615. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  616. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  617. callback(req, res, err, rptSumPageRstArray.concat(rptPageRstArray));
  618. });
  619. } else {
  620. callback(req, res, err, rptPageRstArray);
  621. }
  622. }
  623. });
  624. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  625. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  626. callback(req, res, err, rptSumPageRstArray);
  627. });
  628. }
  629. },
  630. getBillSummaryReportPages: function (req, res) {
  631. let params = JSON.parse(req.body.params),
  632. rpt_id = params.rpt_tpl_id,
  633. prjIds = params.prjIds,
  634. pageSize = params.pageSize,
  635. orientation = params.orientation,
  636. customizeCfg = params.custCfg
  637. ;
  638. let user_id = req.session.sessionUser.id;
  639. getBillsSummaryReportPages(req, user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  640. callback(req, res, err, pageRst);
  641. });
  642. },
  643. getGljSummaryReportPages: function (req, res) {
  644. let params = JSON.parse(req.body.params),
  645. rpt_id = params.rpt_tpl_id,
  646. prjIds = params.prjIds,
  647. pageSize = params.pageSize,
  648. orientation = params.orientation,
  649. customizeCfg = params.custCfg
  650. ;
  651. let user_id = req.session.sessionUser.id;
  652. getGljSummaryReportPages(user_id, prjIds, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  653. callback(req, res, err, pageRst);
  654. });
  655. },
  656. getReportAllPagesSvg: function (req, res) {
  657. let params = JSON.parse(req.body.params),
  658. rpt_id = params.rpt_tpl_id,
  659. prj_id = params.prj_id,
  660. pageSize = params.pageSize,
  661. orientation = params.orientation,
  662. customizeCfg = params.custCfg
  663. ;
  664. let user_id = req.session.sessionUser.id;
  665. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  666. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  667. callback(req, res, err, svgRstStrArr);
  668. });
  669. },
  670. createExcelFilesInOneBookEx: function (req, res) {
  671. //采用了优化策略
  672. let params = JSON.parse(req.body.params),
  673. prj_id = params.prj_id,
  674. rpt_ids = params.rpt_ids,
  675. //--以下是汇总类数据----------
  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. //------------
  680. rptName = params.rptName,
  681. pageSize = params.pageSize,
  682. orientation = params.orientation,
  683. customizeCfg = params.custCfg,
  684. option = params.option;
  685. let user_id = req.session.sessionUser.id;
  686. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  687. if (rpt_ids && rpt_ids.length > 0) {
  688. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  689. if(err){
  690. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  691. callback(req, res, '数据有误', null);
  692. } else {
  693. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  694. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  695. rpt_xl_util.exportExcelInOneBook(rptPageRstArray.concat(rptSumPageRstArray), pageSize, rptName, function(uuidName){
  696. let fileRst = {uuid: uuidName, reportName: rptName};
  697. callback(req, res, err, fileRst);
  698. });
  699. });
  700. } else {
  701. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  702. let fileRst = {uuid: uuidName, reportName: rptName};
  703. callback(req, res, err, fileRst);
  704. });
  705. }
  706. }
  707. });
  708. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  709. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  710. rpt_xl_util.exportExcelInOneBook(rptPageRstArray, pageSize, rptName, function(uuidName){
  711. let fileRst = {uuid: uuidName, reportName: rptName};
  712. callback(req, res, err, fileRst);
  713. });
  714. });
  715. }
  716. },
  717. createExcelFilesEx: function (req, res) {
  718. let params = JSON.parse(req.body.params),
  719. prj_id = params.prj_id,
  720. rpt_ids = params.rpt_ids,
  721. //--以下是汇总类数据----------
  722. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  723. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  724. prjIds = params.prjIds,
  725. sum_rpt_names = params.sum_rpt_names,
  726. //------------
  727. rpt_names = params.rpt_names,
  728. pageSize = params.pageSize,
  729. orientation = params.orientation,
  730. isOneSheet = params.isOneSheet,
  731. customizeCfg = params.custCfg,
  732. option = params.option;
  733. let user_id = req.session.sessionUser.id;
  734. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  735. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  736. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  737. parallelFunctions.push((function (pageRst, rpt_name) {
  738. return function (cb) {
  739. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  740. let fileRst = {uuid: uuidName, reportName: rpt_name};
  741. cb(err, fileRst);
  742. })
  743. };
  744. })(rptPageRstArray[idx], paraRptNames[idx]));
  745. }
  746. };
  747. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  748. async.parallel(parallelFunctions, function (err, fileRstArray) {
  749. if (err) {
  750. console.log('导出Excel错误(导出数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  751. callback(req, res, '数据导出错误', null);
  752. } else {
  753. // console.log(err);
  754. callback(req, res, err, fileRstArray);
  755. }
  756. });
  757. };
  758. if (rpt_ids && rpt_ids.length > 0) {
  759. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, rptPageRstArray) {
  760. if (err) {
  761. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  762. callback(req, res, '数据生成错误', null);
  763. } else {
  764. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  765. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  766. let parallelFunctions = [];
  767. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  768. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  769. pri_Run_Parallel_Functions(parallelFunctions);
  770. });
  771. } else {
  772. let parallelFunctions = [];
  773. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  774. pri_Run_Parallel_Functions(parallelFunctions);
  775. }
  776. }
  777. });
  778. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  779. // console.log('rpt_bill_tpl_ids:');
  780. // console.log(rpt_bill_tpl_ids);
  781. // console.log('rpt_glj_tpl_ids:');
  782. // console.log(rpt_glj_tpl_ids);
  783. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  784. let parallelFunctions = [];
  785. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  786. pri_Run_Parallel_Functions(parallelFunctions);
  787. });
  788. }
  789. },
  790. getFileByUUID: function (req, res) {
  791. let uuid = req.params.uuid,
  792. rptName = req.params.rptName,
  793. suffix = "." + req.params.suffix
  794. ;
  795. // let user_id = req.session.sessionUser.id; //未来要校验user id
  796. try {
  797. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  798. let rptNameURI = encodeURI(rptName);
  799. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  800. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  801. filestream.on('data', function(chunk) {
  802. res.write(chunk);
  803. });
  804. filestream.on('end', function() {
  805. res.end();
  806. });
  807. } catch (e) {
  808. console.log(e);
  809. }
  810. },
  811. getExcel: function(req, res) {
  812. let prj_id = req.params.prj_id,
  813. rpt_id = req.params.rpt_id,
  814. pageSize = req.params.size,
  815. orientation = req.params.orientation,
  816. rptName = req.params.rptName,
  817. isOneSheet = req.params.isOneSheet,
  818. option = req.params.option
  819. ;
  820. let customizeCfg = null;
  821. let user_id = req.session.sessionUser.id;
  822. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  823. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  824. try {
  825. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  826. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  827. let rptNameURI = encodeURI(rptName);
  828. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  829. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  830. filestream.on('data', function(chunk) {
  831. res.write(chunk);
  832. });
  833. filestream.on('end', function() {
  834. res.end();
  835. });
  836. });
  837. } catch (e) {
  838. console.log(e);
  839. }
  840. })
  841. },
  842. getExcelInOneBook: function (req, res) {
  843. let prj_id = req.params.prj_id,
  844. rpt_ids = req.params.rpt_ids.split(','),
  845. pageSize = req.params.size,
  846. rptName = req.params.rptName,
  847. option = req.params.option;
  848. let user_id = req.session.sessionUser.id;
  849. let parallelFunctions = [];
  850. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  851. for (let id of rpt_ids) {
  852. parallelFunctions.push((function (rpt_id) {
  853. return function (cb) {
  854. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  855. if(err){
  856. cb(err);
  857. }
  858. else{
  859. cb(null, pageRst);
  860. }
  861. })
  862. }
  863. })(parseInt(id)));
  864. }
  865. async.parallel(parallelFunctions, function (err, pageRstArray) {
  866. if (err) {
  867. callback(req, res, '数据有误', null);
  868. } else {
  869. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  870. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  871. let rptNameURI = encodeURI(rptName);
  872. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  873. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  874. filestream.on('data', function(chunk) {
  875. res.write(chunk);
  876. });
  877. filestream.on('end', function() {
  878. res.end();
  879. });
  880. });
  881. }
  882. })
  883. },
  884. createPdfFilesEx: function (req, res) {
  885. let params = JSON.parse(req.body.params),
  886. prj_id = params.prj_id,
  887. rpt_ids = params.rpt_ids,
  888. rpt_names = params.rpt_names,
  889. //--以下是汇总类数据----------
  890. rpt_bill_tpl_ids = params.rpt_bill_tpl_ids,
  891. rpt_glj_tpl_ids = params.rpt_glj_tpl_ids,
  892. prjIds = params.prjIds,
  893. sum_rpt_names = params.sum_rpt_names,
  894. //------------
  895. pageSize = params.pageSize,
  896. orientation = params.orientation,
  897. customizeCfg = params.custCfg,
  898. option = params.option;
  899. let user_id = req.session.sessionUser.id;
  900. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  901. console.log('start!');
  902. let pri_Add_Parallel_Functions = function (parallelFunctions, rptPageRstArray, paraRptNames, err) {
  903. for (let idx = 0; idx < rptPageRstArray.length; idx++) {
  904. parallelFunctions.push((function (pageRst, rpt_name) {
  905. return function (cb) {
  906. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  907. let fileRst = {uuid: uuidName, reportName: rpt_name};
  908. cb(err, fileRst);
  909. })
  910. };
  911. })(rptPageRstArray[idx], paraRptNames[idx]));
  912. }
  913. };
  914. let pri_Run_Parallel_Functions = function (parallelFunctions) {
  915. async.parallel(parallelFunctions, function (err, fileRstArray) {
  916. if (err) {
  917. console.log('导出PDF错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  918. callback(req, res, '数据导出错误', null);
  919. } else {
  920. // console.log(err);
  921. callback(req, res, err, fileRstArray);
  922. }
  923. });
  924. };
  925. if (rpt_ids && rpt_ids.length > 0) {
  926. console.log(0);
  927. getMultiRptsCommon(user_id, prj_id, rpt_ids, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, rptPageRstArray) {
  928. if (err) {
  929. console.log('导出Excel错误(生成数据过程错误), userId: ' + user_id + ', prjId' + prj_id);
  930. callback(req, res, '数据生成错误', null);
  931. } else {
  932. if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  933. console.log(1);
  934. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  935. let parallelFunctions = [];
  936. console.log(2);
  937. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  938. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  939. pri_Run_Parallel_Functions(parallelFunctions);
  940. });
  941. } else {
  942. console.log(3);
  943. let parallelFunctions = [];
  944. pri_Add_Parallel_Functions(parallelFunctions, rptPageRstArray, rpt_names, err);
  945. pri_Run_Parallel_Functions(parallelFunctions);
  946. }
  947. }
  948. });
  949. } else if ((rpt_bill_tpl_ids && rpt_bill_tpl_ids.length > 0) || (rpt_glj_tpl_ids && rpt_glj_tpl_ids.length > 0)) {
  950. console.log(10);
  951. getSummaryComboPages(req, user_id, prjIds, rpt_bill_tpl_ids, rpt_glj_tpl_ids, pageSize, orientation, customizeCfg, option, JV.OUTPUT_TYPE_NORMAL, function (err, rptSumPageRstArray) {
  952. let parallelFunctions = [];
  953. pri_Add_Parallel_Functions(parallelFunctions, rptSumPageRstArray, sum_rpt_names, err);
  954. pri_Run_Parallel_Functions(parallelFunctions);
  955. });
  956. }
  957. },
  958. getPDF:function (req, res) {
  959. let prj_id = req.params.prj_id,
  960. rpt_id = req.params.rpt_id,
  961. pageSize = req.params.size,
  962. orientation = req.params.orientation,
  963. rptName = req.params.rptName
  964. ;
  965. let user_id = req.session.sessionUser.id;
  966. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  967. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  968. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  969. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  970. let rptNameURI = encodeURI(rptName);
  971. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  972. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  973. filestream.on('data', function(chunk) {
  974. res.write(chunk);
  975. });
  976. filestream.on('end', function() {
  977. res.end();
  978. });
  979. })
  980. })
  981. }
  982. };