rpt_controller.js 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802
  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_construct_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. const WATERMARK_FONT = {
  32. "Name": "宋体",
  33. "FontHeight": "32",
  34. "FontColor": "CYAN",
  35. "FontBold": "T",
  36. "FontItalic": "F",
  37. "FontUnderline": "F",
  38. "FontStrikeOut": "F",
  39. "FontAngle": "45"
  40. };
  41. function getAllPagesCommonOrg(rpt_id, pageSize, option, cb) {
  42. let rptTpl = null;
  43. rptTplFacade.getRptTemplate(rpt_id).then(function(rst) {
  44. rptTpl = rst;
  45. if (rptTpl) {
  46. if (rptTpl.ID_KEY) {
  47. return demoTemplateFacade.getDemoData(rptTpl.ID_KEY);
  48. } else {
  49. //callback(req, res, 'No report template data were found!', null);
  50. cb('No report template data were found!', null);
  51. }
  52. } else {
  53. //callback(req, res, 'No report template was found!', null);
  54. cb('No report template was found!', null);
  55. }
  56. }).then(function(tplData){
  57. if (tplData) {
  58. let printCom = JpcEx.createNew();
  59. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  60. let defProperties = rptUtil.getReportDefaultCache();
  61. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  62. printCom.initialize(rptTpl);
  63. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, JV.OUTPUT_TYPE_NORMAL);
  64. let maxPages = printCom.totalPages;
  65. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties);
  66. if (pageRst) {
  67. cb(null, pageRst);
  68. } else {
  69. //callback(req, res, "Have errors while on going...", null);
  70. cb('Have errors while on going...', null);
  71. }
  72. } else {
  73. //callback(req, res, 'No report data were found!', null);
  74. cb('No report data were found!', null);
  75. }
  76. }
  77. );
  78. }
  79. function setupCustomizeCfg(customizeCfg, rptTpl, defProperties) {
  80. let tmpObj = {};
  81. //1. 字体
  82. let newFonts = [];
  83. for (let font of defProperties.fonts) {
  84. let copyFont = {};
  85. copyFont.ID = font.ID;
  86. for (let fontProp of JV.FONT_PROPS) {
  87. copyFont[fontProp] = font[fontProp];
  88. }
  89. newFonts.push(copyFont);
  90. tmpObj[font.ID] = copyFont;
  91. }
  92. let private_setup_font = function (propStr, newFont) {
  93. if (tmpObj[propStr]) {
  94. tmpObj[propStr].Name = newFont.Name;
  95. tmpObj[propStr].FontHeight = String(newFont.FontHeight);
  96. tmpObj[propStr].FontBold = newFont.FontBold;
  97. tmpObj[propStr].FontItalic = newFont.FontItalic;
  98. tmpObj[propStr].FontUnderline = newFont.FontUnderline;
  99. }
  100. };
  101. for (let custFont of customizeCfg.fonts) {
  102. switch (custFont.CfgDispName) {
  103. case "表标题":
  104. private_setup_font("ReportTitle_Main", custFont);
  105. break;
  106. case "列标题":
  107. private_setup_font("HeaderColumn", custFont);
  108. private_setup_font("FooterColumn", custFont);
  109. break;
  110. case "正文内容":
  111. private_setup_font("Content", custFont);
  112. break;
  113. case "合计":
  114. private_setup_font("GrandTotal", custFont);
  115. private_setup_font("SectionTotal", custFont);
  116. break;
  117. case "表眉/表脚":
  118. private_setup_font("Header", custFont);
  119. private_setup_font("Footer", custFont);
  120. break;
  121. }
  122. }
  123. // 1.1 窄体
  124. if (tmpObj["Content_Narrow"]) {
  125. if (customizeCfg.isNarrow) {
  126. tmpObj["Content_Narrow"].Name = "Arial Narrow";
  127. } else {
  128. if (tmpObj["Content"]) {
  129. tmpObj["Content_Narrow"].Name = tmpObj["Content"].Name;
  130. } else {
  131. tmpObj["Content_Narrow"].Name = "宋体";
  132. }
  133. }
  134. }
  135. defProperties.fonts = newFonts;
  136. //2. 页边距
  137. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_LEFT] = customizeCfg.margins[JV.PROP_LEFT] / 10;
  138. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_RIGHT] = customizeCfg.margins[JV.PROP_RIGHT] / 10;
  139. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_TOP] = customizeCfg.margins[JV.PROP_TOP] / 10;
  140. rptTpl[JV.NODE_MAIN_INFO][JV.NODE_MARGINS][JV.PROP_BOTTOM] = customizeCfg.margins[JV.PROP_BOTTOM] / 10;
  141. //3. 边框竖线
  142. if (!(customizeCfg.showVerticalLine)) {
  143. let private_copy_border = function (src) {
  144. let rst = {};
  145. rst.Position = src.Position;
  146. rst.LineWeight = src.LineWeight;
  147. rst.DashStyle = src.DashStyle;
  148. rst.Color = src.Color;
  149. return rst;
  150. };
  151. let newStyles = [];
  152. for (let i =0 ; i < defProperties.styles.length; i++) {
  153. let style = defProperties.styles[i];
  154. newStyles.push(style);
  155. if (style.ID === "BORDER_ALL_AROUND") {
  156. let newStyle = {};
  157. newStyle.ID = style.ID;
  158. newStyle.CfgDispName = style.CfgDispName;
  159. newStyle.border_style = [];
  160. for (let border of style.border_style) {
  161. let newBorder = private_copy_border(border);
  162. newStyle.border_style.push(newBorder);
  163. if (border.Position === "Left" || border.Position === "Right") {
  164. newBorder.LineWeight = 0;
  165. }
  166. }
  167. newStyles[newStyles.length - 1] = newStyle;
  168. }
  169. }
  170. defProperties.styles = newStyles;
  171. }
  172. //4. 补0
  173. let private_Setup_Format = function(tabFields) {
  174. if (tabFields) {
  175. for (let tabField of tabFields) {
  176. if (tabField[JV.PROP_FORMAT]) {
  177. tabField[JV.PROP_FORMAT] = tabField[JV.PROP_FORMAT].replace(new RegExp("#","gm"),"0");
  178. }
  179. }
  180. }
  181. };
  182. if (customizeCfg.fillZero) {
  183. if (rptTpl[JV.NODE_FLOW_INFO]) {
  184. 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]);
  185. 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]);
  186. 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]);
  187. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP] && rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES])
  188. private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  189. if (rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  190. for (let discrete of rptTpl[JV.NODE_FLOW_INFO][JV.NODE_DISCRETE_INFO]) {
  191. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  192. }
  193. }
  194. if (rptTpl[JV.NODE_FLOW_INFO_EX]) {
  195. 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]);
  196. 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]);
  197. 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]);
  198. 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]);
  199. 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])
  200. private_Setup_Format(rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][JV.PROP_SUM_FIELDS]);
  201. if (rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  202. for (let discrete of rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_DISCRETE_INFO]) {
  203. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  204. }
  205. }
  206. }
  207. } else if (rptTpl[JV.NODE_BILL_INFO]) {
  208. 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]);
  209. if (rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  210. for (let discrete of rptTpl[JV.NODE_BILL_INFO][JV.NODE_DISCRETE_INFO]) {
  211. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  212. }
  213. }
  214. } else if (rptTpl[JV.NODE_CROSS_INFO]) {
  215. 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]);
  216. 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]);
  217. 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]);
  218. 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]);
  219. 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]);
  220. 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]);
  221. if (rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  222. for (let discrete of rptTpl[JV.NODE_CROSS_INFO][JV.NODE_DISCRETE_INFO]) {
  223. private_Setup_Format(discrete[JV.PROP_DISCRETE_FIELDS]);
  224. }
  225. }
  226. }
  227. }
  228. }
  229. function getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, option, outputType, cb) {
  230. let rptTpl = null;
  231. rptTplFacade.getRptTemplate(rpt_id).then(function(rst) {
  232. rptTpl = rst;
  233. if (rptTpl) {
  234. let rptDataUtil = new rptDataExtractor();
  235. rptDataUtil.initialize((rptTpl._doc)?rptTpl._doc:rptTpl);
  236. let summaryRst = [], economicRst = [];
  237. let filter = rptDataUtil.getDataRequestFilter(summaryRst, economicRst);
  238. let promiseArr = [null, null, null];
  239. if (summaryRst.length > 0) {
  240. if (summaryRst.indexOf(`Construct`) >= 0 || summaryRst.indexOf(`ConstructDetail`) >= 0) {
  241. promiseArr[0] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.project);
  242. }
  243. if (summaryRst.indexOf(`Segment`) >= 0 || summaryRst.indexOf(`SegmentDetail`) >= 0) {
  244. promiseArr[1] = pm_facade.getSummaryInfoByTender(prj_id, pm_facade.projectType.engineering);
  245. }
  246. }
  247. if (economicRst.length > 0) {
  248. // economicRst.push('ProjectInfoFields');
  249. // economicRst.push('ProjectFeatureFields');
  250. promiseArr[2] = pm_facade.getIndexReportData(prj_id, economicRst);
  251. }
  252. rptTplDataFacade.prepareProjectData(user_id, prj_id, filter, function (err, msg, rawDataObj) {
  253. if (!err) {
  254. let buildPageData = function() {
  255. try {
  256. let tplData = rptDataUtil.assembleData(rawDataObj);
  257. let printCom = JpcEx.createNew();
  258. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  259. //console.log("orientation: " + (orientation === 'null'));
  260. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  261. let defProperties = rptUtil.getReportDefaultCache();
  262. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  263. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  264. printCom.initialize(rptTpl);
  265. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  266. let maxPages = printCom.totalPages;
  267. let pageRst = null;
  268. if (maxPages > 0) {
  269. pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  270. } else {
  271. pageRst = printCom.outputAsPreviewPage(rptTpl, defProperties);
  272. }
  273. if (pageRst) {
  274. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  275. cb(null, pageRst);
  276. } else {
  277. cb('Have errors while on going...', null);
  278. }
  279. } catch (ex) {
  280. console.log("报表数据异常: userId " + user_id + ", project id: " + prj_id);
  281. console.log(ex);
  282. cb('Exception occurs while on going...', null);
  283. }
  284. };
  285. //*/
  286. //取汇总数据流程
  287. if (promiseArr[0] !== null) {
  288. promiseArr[0].then(function (rst) {
  289. rawDataObj.Construct = rst.parent;
  290. rawDataObj.ConstructDetail = rst.subList;
  291. if (promiseArr[1] !== null) {
  292. promiseArr[1].then(function (rst) {
  293. rawDataObj.Segment = rst.parent;
  294. rawDataObj.SegmentDetail = rst.subList;
  295. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  296. });
  297. } else {
  298. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  299. }
  300. });
  301. } else if (promiseArr[1] !== null) {
  302. promiseArr[1].then(function (rst) {
  303. rawDataObj.Segment = rst.parent;
  304. rawDataObj.SegmentDetail = rst.subList;
  305. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  306. });
  307. } else {
  308. if (promiseArr[2] !== null) {
  309. promiseArr[2].then(function (rst) {
  310. let ecoFieldsRst = (rst._doc)?rst._doc:rst;
  311. // fsUtil.writeObjToFile(ecoFieldsRst, "D:/GitHome/ConstructionCost/tmp/testEcoFieldsResult.jsp");
  312. rawDataObj.prjData.push({moduleName: 'ProjectInfoFields', data: ecoFieldsRst.ProjectInfoFields});
  313. rawDataObj.prjData.push({moduleName: 'ProjectFeatureFields', data: ecoFieldsRst.ProjectFeatureFields});
  314. rawDataObj.prjData.push({moduleName: 'ProjectCostFields', data: ecoFieldsRst.ProjectCostFields});
  315. rawDataObj.prjData.push({moduleName: 'ProjectEcoFields', data: ecoFieldsRst.ProjectEcoFields});
  316. rawDataObj.prjData.push({moduleName: 'ProjectLabMaterialFields', data: ecoFieldsRst.ProjectLabMaterialFields});
  317. rawDataObj.prjData.push({moduleName: 'ProjectQtyFields', data: ecoFieldsRst.ProjectQtyFields});
  318. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  319. });
  320. } else {
  321. buildPageData(rawDataObj, rptDataUtil, rptTpl);
  322. }
  323. }
  324. /*/
  325. let tplData = rptDataUtil.assembleData(rawDataObj);
  326. let printCom = JpcEx.createNew();
  327. if (pageSize) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_PAGE_SIZE] = pageSize;
  328. //console.log("orientation: " + (orientation === 'null'));
  329. if (orientation && (orientation !== 'null')) rptTpl[JV.NODE_MAIN_INFO][JV.NODE_PAGE_INFO][JV.PROP_ORIENTATION] = orientation;
  330. let defProperties = rptUtil.getReportDefaultCache();
  331. if (customizeCfg) setupCustomizeCfg(customizeCfg, rptTpl, defProperties);
  332. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  333. printCom.initialize(rptTpl);
  334. printCom.analyzeData(rptTpl, tplData, defProperties, dftOption, outputType);
  335. let maxPages = printCom.totalPages;
  336. let pageRst = printCom.outputAsSimpleJSONPageArray(rptTpl, tplData, 1, maxPages, defProperties, customizeCfg);
  337. if (pageRst) {
  338. // fsUtil.writeObjToFile(pageRst, "D:/GitHome/ConstructionCost/tmp/testBuiltPageResult.jsp");
  339. cb(null, pageRst);
  340. } else {
  341. cb('Have errors while on going...', null);
  342. }
  343. //*/
  344. } else {
  345. cb('No report data were found!', null);
  346. }
  347. });
  348. } else {
  349. cb('No report template was found!', null);
  350. }
  351. })
  352. }
  353. function fillWaterMark(pageRstArray) {
  354. for (const pageRst of pageRstArray) {
  355. if (!pageRst[JV.NODE_FONT_COLLECTION].hasOwnProperty('WaterMark')) {
  356. pageRst[JV.NODE_FONT_COLLECTION]['WaterMark'] = WATERMARK_FONT;
  357. }
  358. for (const page of pageRst.items) {
  359. const warterCell = {
  360. "font": "WaterMark",
  361. "control": "NewContent_Center",
  362. "style": "Default_None",
  363. "Value": "大司空云计价",
  364. "area": {
  365. "Left": 300,
  366. "Right": 500,
  367. "Top": 300,
  368. "Bottom": 500
  369. }
  370. };
  371. page.cells.push(warterCell);
  372. }
  373. }
  374. }
  375. module.exports = {
  376. getReportAllPages: function (req, res) {
  377. let params = JSON.parse(req.body.params),
  378. rpt_id = params.rpt_tpl_id,
  379. prj_id = params.prj_id,
  380. pageSize = params.pageSize,
  381. orientation = params.orientation,
  382. customizeCfg = params.custCfg
  383. ;
  384. // req.session.sessionUser.ssoId
  385. let user_id = req.session.sessionUser.id;
  386. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  387. callback(req, res, err, pageRst);
  388. });
  389. },
  390. getMultiReports: function (req, res) {
  391. let params = JSON.parse(req.body.params),
  392. prj_id = params.prj_id,
  393. rpt_ids = params.rpt_ids.split(','),
  394. pageSize = params.pageSize,
  395. orientation = params.orientation,
  396. customizeCfg = params.custCfg,
  397. option = params.option;
  398. let user_id = req.session.sessionUser.id;
  399. let parallelFunctions = [];
  400. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  401. for (let id of rpt_ids) {
  402. parallelFunctions.push((function (rpt_id) {
  403. return function (cb) {
  404. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_NORMAL, function (err, pageRst) {
  405. if(err){
  406. cb(err);
  407. }
  408. else{
  409. cb(null, pageRst);
  410. }
  411. })
  412. }
  413. })(parseInt(id)));
  414. }
  415. async.parallel(parallelFunctions, function (err, pageRstArray) {
  416. if (err) {
  417. callback(req, res, '数据有误', null);
  418. } else {
  419. callback(req, res, err, pageRstArray);
  420. }
  421. })
  422. },
  423. getMultiReportsEx: function (req, res) {
  424. //原则说明:把所有报表模板集中获取,统一filter,只读一次数据!(有空再整)
  425. let params = JSON.parse(req.body.params),
  426. prj_id = params.prj_id,
  427. rpt_ids = params.rpt_ids.split(','),
  428. pageSize = params.pageSize,
  429. orientation = params.orientation,
  430. customizeCfg = params.custCfg,
  431. option = params.option;
  432. let user_id = req.session.sessionUser.id;
  433. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  434. },
  435. getReportAllPagesSvg: function (req, res) {
  436. let params = JSON.parse(req.body.params),
  437. rpt_id = params.rpt_tpl_id,
  438. prj_id = params.prj_id,
  439. pageSize = params.pageSize,
  440. orientation = params.orientation,
  441. customizeCfg = params.custCfg
  442. ;
  443. let user_id = req.session.sessionUser.id;
  444. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, null, JV.OUTPUT_TYPE_SVG, function (err, pageRst) {
  445. let svgRstStrArr = rpt_svg_util.exportSvgStr(pageRst, 0, 0);
  446. callback(req, res, err, svgRstStrArr);
  447. });
  448. },
  449. createExcelFilesInOneBook: function (req, res) {
  450. let params = JSON.parse(req.body.params),
  451. prj_id = params.prj_id,
  452. rpt_ids = params.rpt_ids,
  453. rptName = params.rptName,
  454. pageSize = params.pageSize,
  455. orientation = params.orientation,
  456. customizeCfg = params.custCfg,
  457. option = params.option;
  458. let user_id = req.session.sessionUser.id;
  459. let parallelFunctions = [];
  460. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  461. for (let idx = 0; idx < rpt_ids.length; idx++) {
  462. let r_id = rpt_ids[idx];
  463. parallelFunctions.push((function (rpt_id) {
  464. return function (cb) {
  465. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  466. if(err){
  467. cb(err);
  468. }
  469. else{
  470. cb(err, pageRst);
  471. }
  472. })
  473. }
  474. })(parseInt(r_id)));
  475. }
  476. async.parallel(parallelFunctions, function (err, pageRstArray) {
  477. if (err) {
  478. callback(req, res, '数据有误', null);
  479. } else {
  480. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(uuidName){
  481. let fileRst = {uuid: uuidName, reportName: rptName};
  482. callback(req, res, err, fileRst);
  483. });
  484. }
  485. })
  486. },
  487. createExcelFiles: function (req, res) {
  488. let params = JSON.parse(req.body.params),
  489. prj_id = params.prj_id,
  490. rpt_ids = params.rpt_ids,
  491. rpt_names = params.rpt_names,
  492. pageSize = params.pageSize,
  493. orientation = params.orientation,
  494. isOneSheet = params.isOneSheet,
  495. customizeCfg = params.custCfg,
  496. option = params.option;
  497. let user_id = req.session.sessionUser.id;
  498. let parallelFunctions = [];
  499. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  500. for (let idx = 0; idx < rpt_ids.length; idx++) {
  501. let r_id = rpt_ids[idx];
  502. let r_name = rpt_names[idx];
  503. parallelFunctions.push((function (rpt_id, rpt_name) {
  504. return function (cb) {
  505. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  506. if(err){
  507. cb(err);
  508. } else {
  509. rpt_xl_util.exportExcel(pageRst, pageSize, rpt_name, isOneSheet, null, null, function(uuidName){
  510. let fileRst = {uuid: uuidName, reportName: rpt_name};
  511. cb(err, fileRst);
  512. })
  513. }
  514. })
  515. }
  516. })(parseInt(r_id), r_name));
  517. }
  518. async.parallel(parallelFunctions, function (err, fileRstArray) {
  519. if (err) {
  520. callback(req, res, '数据有误', null);
  521. } else {
  522. // console.log(err);
  523. callback(req, res, err, fileRstArray);
  524. }
  525. })
  526. },
  527. getFileByUUID: function (req, res) {
  528. let uuid = req.params.uuid,
  529. rptName = req.params.rptName,
  530. suffix = "." + req.params.suffix
  531. ;
  532. // let user_id = req.session.sessionUser.id; //未来要校验user id
  533. try {
  534. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  535. let rptNameURI = encodeURI(rptName);
  536. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix );
  537. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuid + suffix);
  538. filestream.on('data', function(chunk) {
  539. res.write(chunk);
  540. });
  541. filestream.on('end', function() {
  542. res.end();
  543. });
  544. } catch (e) {
  545. console.log(e);
  546. }
  547. },
  548. getExcel: function(req, res) {
  549. let prj_id = req.params.prj_id,
  550. rpt_id = req.params.rpt_id,
  551. pageSize = req.params.size,
  552. orientation = req.params.orientation,
  553. rptName = req.params.rptName,
  554. isOneSheet = req.params.isOneSheet,
  555. option = req.params.option
  556. ;
  557. let customizeCfg = null;
  558. let user_id = req.session.sessionUser.id;
  559. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  560. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_EXCEL, function(err, pageRst){
  561. try {
  562. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  563. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  564. let rptNameURI = encodeURI(rptName);
  565. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx' );
  566. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  567. filestream.on('data', function(chunk) {
  568. res.write(chunk);
  569. });
  570. filestream.on('end', function() {
  571. res.end();
  572. });
  573. });
  574. } catch (e) {
  575. console.log(e);
  576. }
  577. })
  578. },
  579. getExcelInOneBook: function (req, res) {
  580. let prj_id = req.params.prj_id,
  581. rpt_ids = req.params.rpt_ids.split(','),
  582. pageSize = req.params.size,
  583. rptName = req.params.rptName,
  584. option = req.params.option;
  585. let user_id = req.session.sessionUser.id;
  586. let parallelFunctions = [];
  587. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  588. for (let id of rpt_ids) {
  589. parallelFunctions.push((function (rpt_id) {
  590. return function (cb) {
  591. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, null, null, dftOption, JV.OUTPUT_TYPE_EXCEL, function (err, pageRst) {
  592. if(err){
  593. cb(err);
  594. }
  595. else{
  596. cb(null, pageRst);
  597. }
  598. })
  599. }
  600. })(parseInt(id)));
  601. }
  602. async.parallel(parallelFunctions, function (err, pageRstArray) {
  603. if (err) {
  604. callback(req, res, '数据有误', null);
  605. } else {
  606. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  607. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  608. let rptNameURI = encodeURI(rptName);
  609. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".xlsx\"; filename*=utf-8''" + rptNameURI + '.xlsx');
  610. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  611. filestream.on('data', function(chunk) {
  612. res.write(chunk);
  613. });
  614. filestream.on('end', function() {
  615. res.end();
  616. });
  617. });
  618. }
  619. })
  620. },
  621. createPdfFiles: function (req, res) {
  622. let params = JSON.parse(req.body.params),
  623. prj_id = params.prj_id,
  624. rpt_ids = params.rpt_ids,
  625. rpt_names = params.rpt_names,
  626. pageSize = params.pageSize,
  627. orientation = params.orientation,
  628. customizeCfg = params.custCfg,
  629. option = params.option;
  630. let user_id = req.session.sessionUser.id;
  631. let parallelFunctions = [];
  632. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  633. for (let idx = 0; idx < rpt_ids.length; idx++) {
  634. let r_id = rpt_ids[idx];
  635. let r_name = rpt_names[idx];
  636. parallelFunctions.push((function (rpt_id, rpt_name) {
  637. return function (cb) {
  638. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, customizeCfg, dftOption, JV.OUTPUT_TYPE_PDF, function (err, pageRst) {
  639. if(err){
  640. cb(err);
  641. }
  642. else{
  643. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rpt_name, function(uuidName){
  644. let fileRst = {uuid: uuidName, reportName: rpt_name};
  645. cb(err, fileRst);
  646. })
  647. }
  648. })
  649. }
  650. })(parseInt(r_id), r_name));
  651. }
  652. async.parallel(parallelFunctions, function (err, fileRstArray) {
  653. if (err) {
  654. callback(req, res, '数据有误', null);
  655. } else {
  656. // console.log(err);
  657. callback(req, res, err, fileRstArray);
  658. }
  659. })
  660. },
  661. getPDF:function (req, res) {
  662. let prj_id = req.params.prj_id,
  663. rpt_id = req.params.rpt_id,
  664. pageSize = req.params.size,
  665. orientation = req.params.orientation,
  666. rptName = req.params.rptName
  667. ;
  668. let user_id = req.session.sessionUser.id;
  669. getAllPagesCommon(user_id, prj_id, rpt_id, pageSize, orientation, null, JV.PAGING_OPTION_NORMAL, JV.OUTPUT_TYPE_PDF, function(err, pageRst){
  670. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  671. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  672. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  673. let rptNameURI = encodeURI(rptName);
  674. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  675. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  676. filestream.on('data', function(chunk) {
  677. res.write(chunk);
  678. });
  679. filestream.on('end', function() {
  680. res.end();
  681. });
  682. })
  683. })
  684. },
  685. getTestReportAllPages: function(req, res){
  686. let rpt_id = req.body.ID;
  687. let pageSize = req.body.pageSize;
  688. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  689. //fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  690. callback(req, res, err, pageRst);
  691. })
  692. },
  693. getTestExcel: function(req, res) {
  694. let rpt_id = req.params.id,
  695. pageSize = req.params.size,
  696. rptName = req.params.rptName,
  697. isOneSheet = req.params.isOneSheet,
  698. option = req.params.option;
  699. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  700. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function(err, pageRst){
  701. fs.writeFileSync('D:/GitHome/ConstructionOperation/tmp/testRpt.js', JSON.stringify(pageRst));
  702. try {
  703. rpt_xl_util.exportExcel(pageRst, pageSize, rptName, isOneSheet, null, null, function(uuidName){
  704. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  705. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  706. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.xlsx');
  707. filestream.on('data', function(chunk) {
  708. res.write(chunk);
  709. });
  710. filestream.on('end', function() {
  711. res.end();
  712. });
  713. });
  714. } catch (e) {
  715. console.log(e);
  716. }
  717. })
  718. },
  719. getTestExcelInOneBook: function(req, res) {
  720. let rpt_ids = req.params.ids.split(','),
  721. pageSize = req.params.size,
  722. rptName = req.params.rptName,
  723. option = req.params.option;
  724. let parallelFunctions = [];
  725. let dftOption = option||JV.PAGING_OPTION_NORMAL;
  726. for (let id of rpt_ids) {
  727. parallelFunctions.push((function (rpt_id) {
  728. return function (cb) {
  729. getAllPagesCommonOrg(rpt_id, pageSize, dftOption, function (err, pageRst) {
  730. if(err){
  731. cb(err);
  732. }
  733. else{
  734. cb(null, pageRst);
  735. }
  736. })
  737. }
  738. })(parseInt(id)));
  739. }
  740. async.parallel(parallelFunctions, function (err, pageRstArray) {
  741. if (err) {
  742. callback(req, res, '数据有误', null);
  743. } else {
  744. rpt_xl_util.exportExcelInOneBook(pageRstArray, pageSize, rptName, function(tmpFilePath){
  745. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  746. res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".xlsx");
  747. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + tmpFilePath + '.xlsx');
  748. filestream.on('data', function(chunk) {
  749. res.write(chunk);
  750. });
  751. filestream.on('end', function() {
  752. res.end();
  753. });
  754. });
  755. //callback(req, res, false, '', {compilation: rst, gljLibs: gljLibsRst});
  756. }
  757. })
  758. },
  759. getTestPDF:function (req, res) {
  760. let rpt_id = req.params.id,
  761. pageSize = req.params.size,
  762. rptName = req.params.rptName;
  763. getAllPagesCommonOrg(rpt_id, pageSize, JV.PAGING_OPTION_NORMAL, function(err, pageRst){
  764. rpt_pdf_util.export_pdf_file(pageRst, pageSize, rptName,function (uuidName) {
  765. res.setHeader('Content-Type', 'application/vnd.openxmlformats');
  766. // res.setHeader("Content-Disposition", "attachment; filename=" + strUtil.getPinYinCamelChars(rptName) + ".pdf");
  767. let rptNameURI = encodeURI(rptName);
  768. res.setHeader("Content-Disposition", "attachment; filename=\"" + rptNameURI + ".pdf\"; filename*=utf-8''" + rptNameURI + ".pdf" );
  769. let filestream = fs.createReadStream(__dirname.slice(0, __dirname.length - 28) + '/tmp/' + uuidName + '.pdf');
  770. filestream.on('data', function(chunk) {
  771. res.write(chunk);
  772. });
  773. filestream.on('end', function() {
  774. res.end();
  775. });
  776. })
  777. })
  778. }
  779. };