rpt_tpl_controller.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571
  1. /**
  2. * Created by Tony on 2017/6/1.
  3. */
  4. import mongoose from "mongoose";
  5. import async from "async";
  6. import counter from "../../../public/counter/counter";
  7. let RptTplModel = mongoose.model("rpt_templates");
  8. let TreeNodeModel = mongoose.model("rpt_tpl_tree");
  9. let rptExtCodeModel = mongoose.model("rpt_ext_code_tpl");
  10. let rptCustCfgFacade = require("../facade/rpt_cust_cfg_facade");
  11. let costIndexModel = mongoose.model("costIndexReport");
  12. let Rpt_Map_Fld_Mdl = mongoose.model("rpt_mapping_field");
  13. let rpt_cfg_mdl = mongoose.model("rpt_cfg");
  14. import JV from "../rpt_component/jpc_value_define";
  15. import rttFacade from "../facade/rpt_tpl_tree_node_facade";
  16. import CompilationModel from "../../users/models/compilation_model";
  17. import fs from "fs";
  18. let JSZip = require("jszip");
  19. //统一回调函数
  20. let callback = function (req, res, err, message, data) {
  21. res.json({ error: err, message: message, data: data });
  22. };
  23. let mExport = {
  24. getCustomerCfg: function (req, res) {
  25. let params = JSON.parse(req.body.params),
  26. userId = params.userId,
  27. me = this;
  28. if (req.session.sessionUser && req.session.sessionUser.id)
  29. userId = req.session.sessionUser.id;
  30. let userIds = [];
  31. userIds.push(userId);
  32. if (userId !== "-100") {
  33. userIds.push("-100");
  34. }
  35. rptCustCfgFacade.getCustomizeCfg(userIds).then(function (custCfg) {
  36. if (custCfg) {
  37. //success
  38. let rst = null;
  39. if (custCfg.length > 0) {
  40. rst = [];
  41. rst.push(null);
  42. for (let itemCfg of custCfg) {
  43. // rst = itemCfg;
  44. let doc = itemCfg._doc ? itemCfg._doc : itemCfg;
  45. let dest = {};
  46. copyRptCfg(doc, dest);
  47. if (doc.userId !== "-100") {
  48. rst.push(dest);
  49. } else {
  50. rst[0] = dest;
  51. }
  52. }
  53. }
  54. if (rst !== null && rst.length === 1) {
  55. //copy dft config
  56. let userDest = {};
  57. copyRptCfg(rst[0], userDest);
  58. rst.push(userDest);
  59. }
  60. callback(req, res, false, "", rst);
  61. } else {
  62. //failed
  63. callback(req, res, true, "失败!", null);
  64. }
  65. });
  66. },
  67. saveCustomerCfg: function (req, res) {
  68. let params = JSON.parse(req.body.params),
  69. userId = params.userId,
  70. custCfg = params.custCfg;
  71. if (req.session.sessionUser && req.session.sessionUser.id)
  72. userId = req.session.sessionUser.id;
  73. custCfg.userId = userId;
  74. rptCustCfgFacade.saveCustomizeCfg(custCfg).then(function (rst) {
  75. if (rst) {
  76. //success
  77. callback(req, res, false, "", "success!");
  78. } else {
  79. //failed
  80. callback(req, res, true, "更新失败!", null);
  81. }
  82. });
  83. },
  84. getDftTemplates: function (req, res) {
  85. let filter = {
  86. userId: "-100",
  87. $or: [{ isDeleted: null }, { isDeleted: false }],
  88. };
  89. TreeNodeModel.find(filter, "-_id", function (err, data) {
  90. if (err) {
  91. callback(req, res, true, "", null);
  92. } else {
  93. callback(req, res, false, "", data);
  94. }
  95. });
  96. },
  97. getExtCodeTpl: function (req, res) {
  98. rptExtCodeModel
  99. .find({})
  100. .exec()
  101. .then(function (rstCodeTpl) {
  102. if (rstCodeTpl) {
  103. callback(req, res, false, "", rstCodeTpl);
  104. } else {
  105. callback(req, res, "The report template was not found!", null);
  106. }
  107. });
  108. },
  109. async getCompilationList(req, res) {
  110. let compilationModel = new CompilationModel();
  111. // let compilationList = await compilationModel.getPermissionCompilationList(req);
  112. let compilationList = await compilationModel.getCompilationList();
  113. console.log(compilationList);
  114. if (compilationList) {
  115. // console.log(compilationList);
  116. // compilationList.then(function (rst) {
  117. // console.log(rst);
  118. // callback(req, res, false, "", rst);
  119. // })
  120. callback(req, res, false, "", compilationList);
  121. } else {
  122. callback(req, res, true, "no result", null);
  123. }
  124. },
  125. getRptTplTree: function (req, res) {
  126. let params = JSON.parse(req.body.params),
  127. compilationId = params.compilationId,
  128. userId = params.userId,
  129. sessionUserId = null;
  130. let userIds = ["-100"];
  131. if (req.session.sessionUser && req.session.sessionUser.id)
  132. sessionUserId = req.session.sessionUser.id;
  133. if (userId !== null) {
  134. if (typeof userId === "string") {
  135. if (userIds.indexOf(userId) < 0) userIds.push(userId);
  136. } else if (userId instanceof Array) {
  137. for (let uid of userId) {
  138. userIds.push(uid);
  139. }
  140. }
  141. } else {
  142. }
  143. if (sessionUserId && userIds.indexOf(sessionUserId) < 0)
  144. userIds.push(sessionUserId);
  145. if (!compilationId) {
  146. compilationId = req.session.sessionCompilation._id;
  147. }
  148. rttFacade.findTplTree(compilationId, userIds).then(function (result) {
  149. if (result) {
  150. callback(req, res, false, "", result);
  151. } else {
  152. callback(req, res, true, "no result", null);
  153. }
  154. });
  155. },
  156. getTplTreeByCompilation: function (req, res) {
  157. let params = JSON.parse(req.body.params),
  158. compilationId = params.compilationId;
  159. // if (req.session.sessionUser && req.session.sessionUser.id) sessionUserId = req.session.sessionUser.id;
  160. console.log(params);
  161. if (!compilationId) {
  162. console.log(req.session.sessionCompilation);
  163. compilationId = req.session.sessionCompilation._id;
  164. }
  165. rttFacade.findTplTreeByCompilation(compilationId).then(function (result) {
  166. if (result) {
  167. callback(req, res, false, "", result);
  168. } else {
  169. callback(req, res, true, "no result", null);
  170. }
  171. });
  172. },
  173. updateTreeNodes: function (req, res) {
  174. let params = JSON.parse(req.body.params),
  175. nodes = params.nodes;
  176. let functions = [];
  177. for (let node of nodes) {
  178. functions.push(
  179. (function (doc) {
  180. return function (cb) {
  181. TreeNodeModel.update({ ID: doc.ID }, doc, cb);
  182. };
  183. })(node)
  184. );
  185. }
  186. async.parallel(functions, function (err, results) {
  187. callback(req, res, err, "", results);
  188. });
  189. },
  190. deleteRptTplNodes: function (req, res) {
  191. let params = JSON.parse(req.body.params),
  192. nodeIds = params.nodeIds,
  193. preNodeId = params.preNodeId,
  194. preNodeNextId = params.preNodeNextId;
  195. let functions = [];
  196. if (preNodeId !== -1) {
  197. functions.push(
  198. (function (nodeId, nextId) {
  199. return function (cb) {
  200. TreeNodeModel.update({ ID: nodeId }, { NextSiblingID: nextId }, cb);
  201. };
  202. })(preNodeId, preNodeNextId)
  203. );
  204. }
  205. for (let nId of nodeIds) {
  206. functions.push(
  207. (function (nodeId) {
  208. return function (cb) {
  209. TreeNodeModel.update({ ID: nodeId }, { isDeleted: true }, cb);
  210. };
  211. })(nId)
  212. );
  213. }
  214. async.parallel(functions, function (err, results) {
  215. callback(req, res, err, "", results);
  216. });
  217. },
  218. createTreeRootNode: function (req, res) {
  219. let params = JSON.parse(req.body.params),
  220. doc = params.doc;
  221. rttFacade.createNewTree(doc).then(function (rst) {
  222. if (rst) {
  223. //success
  224. callback(req, res, false, "", rst);
  225. } else {
  226. //failed
  227. callback(req, res, true, "创建失败!", null);
  228. }
  229. });
  230. },
  231. updateTreeRootNode: function (req, res) {
  232. let params = JSON.parse(req.body.params),
  233. doc = params.doc;
  234. rttFacade
  235. .updateTree(doc.compilationId, doc.engineerId, doc.userId, doc)
  236. .then(function (rst) {
  237. if (rst) {
  238. //success
  239. callback(req, res, false, "", rst);
  240. } else {
  241. //failed
  242. callback(req, res, true, "更新失败!", null);
  243. }
  244. });
  245. },
  246. updateTopNodeName: function (req, res) {
  247. //备注:因设计的更改,此方法将被放弃
  248. let params = JSON.parse(req.body.params),
  249. compilationId = params.compilationId,
  250. engineerId = params.engineerId,
  251. userId = params.userId,
  252. nodeName = params.nodeName;
  253. if (req.session.sessionUser && req.session.sessionUser.id)
  254. userId = req.session.sessionUser.id;
  255. let filter = {
  256. compilationId: compilationId,
  257. engineerId: engineerId,
  258. userId: userId,
  259. $or: [{ isDeleted: null }, { isDeleted: false }],
  260. };
  261. let updateStatement = { $set: { name: nodeName } };
  262. rttFacade.updateTreeInDetail(filter, updateStatement).then(function (rst) {
  263. if (rst) {
  264. //success
  265. callback(req, res, false, "", rst);
  266. } else {
  267. //failed
  268. callback(req, res, true, "更新失败!", null);
  269. }
  270. });
  271. },
  272. updateSubLevelOneNode: function (req, res) {
  273. let params = JSON.parse(req.body.params),
  274. compilationId = params.compilationId,
  275. // engineerId = params.engineerId,
  276. userId = params.userId,
  277. subNode = params.subNode;
  278. if (req.session.sessionUser && req.session.sessionUser.id)
  279. userId = req.session.sessionUser.id; //备注:这段逻辑只会在前端有效,后端运维不会走到
  280. let filter = {
  281. compilationId: compilationId,
  282. userId: userId,
  283. "items.ID": subNode.ID,
  284. $or: [{ isDeleted: null }, { isDeleted: false }],
  285. };
  286. let updateStatement = { $set: { "items.$": subNode } };
  287. rttFacade.updateTreeInDetail(filter, updateStatement).then(function (rst) {
  288. if (rst) {
  289. //success
  290. callback(req, res, false, "", rst);
  291. } else {
  292. //failed
  293. callback(req, res, true, "更新失败!", null);
  294. }
  295. });
  296. },
  297. removeTreeRootNode: function (req, res) {
  298. let params = JSON.parse(req.body.params),
  299. compilationId = params.compilationId,
  300. engineerId = params.engineerId,
  301. userId = params.userId,
  302. isPhysically = params.isPhysically;
  303. if (req.session.sessionUser && req.session.sessionUser.id)
  304. userId = req.session.sessionUser.id;
  305. if (isPhysically) {
  306. rttFacade
  307. .removeTreePhycically(compilationId, engineerId, userId)
  308. .then(function (rst) {
  309. if (rst) {
  310. //success
  311. callback(req, res, false, "", rst);
  312. } else {
  313. //failed
  314. callback(req, res, true, "删除失败!", null);
  315. }
  316. });
  317. } else {
  318. rttFacade
  319. .removeTree(compilationId, engineerId, userId)
  320. .then(function (rst) {
  321. if (rst) {
  322. //success
  323. callback(req, res, false, "", rst);
  324. } else {
  325. //failed
  326. callback(req, res, true, "删除失败!", null);
  327. }
  328. });
  329. }
  330. },
  331. getNewNodeID: function (req, res) {
  332. let params = JSON.parse(req.body.params),
  333. scope = params.scope;
  334. counter.counterDAO.getIDAfterCount(
  335. counter.moduleName.report,
  336. scope,
  337. function (err, result) {
  338. callback(req, res, false, "", result.sequence_value);
  339. }
  340. );
  341. },
  342. createDftRptTpl: function (req, res) {
  343. let params = JSON.parse(req.body.params),
  344. treeNodeId = params.treeNodeId,
  345. rptDftTplId = params.rptDftTplId,
  346. rptName = params.rptName,
  347. grpKey = params.grpKey,
  348. compilationId = params.compilationId,
  349. engineerId = params.engineerId,
  350. userId = params.userId,
  351. subNode = params.subNode;
  352. if (req.session.sessionUser && req.session.sessionUser.id)
  353. userId = req.session.sessionUser.id;
  354. let filter = { ID: rptDftTplId };
  355. RptTplModel.findOne(filter, "-_id")
  356. .exec()
  357. .then(function (dftTplRst) {
  358. if (dftTplRst) {
  359. let _doc = dftTplRst["_doc"];
  360. _doc["ID"] = treeNodeId;
  361. _doc["GROUP_KEY"] = grpKey;
  362. _doc["ID_KEY"] = "";
  363. _doc[JV.NODE_MAIN_INFO][JV.NODE_MAIN_INFO_RPT_NAME] = rptName;
  364. let rptTpl = new RptTplModel(_doc);
  365. rptTpl.save(function (err, actTplRst) {
  366. if (err) {
  367. callback(req, res, "报表模板创建错误", "", null);
  368. } else {
  369. let filter = {
  370. compilationId: compilationId,
  371. engineerId: engineerId,
  372. userId: userId,
  373. "items.ID": subNode.ID,
  374. $or: [{ isDeleted: null }, { isDeleted: false }],
  375. };
  376. let updateStatement = { $set: { "items.$": subNode } };
  377. rttFacade
  378. .updateTreeInDetail(filter, updateStatement)
  379. .then(function (rst) {
  380. if (rst) {
  381. //success
  382. callback(req, res, false, "", actTplRst);
  383. } else {
  384. //failed
  385. callback(req, res, true, "更新失败!", null);
  386. }
  387. });
  388. }
  389. });
  390. } else {
  391. callback(req, res, "Create report template failed!", null);
  392. }
  393. });
  394. },
  395. getRefRptTpl: function (req, res) {
  396. let params = JSON.parse(req.body.params),
  397. rptTplId = params.rptTplId;
  398. let filter = { ID: rptTplId };
  399. RptTplModel.findOne(filter, "-_id")
  400. .exec()
  401. .then(function (rstTpl) {
  402. if (rstTpl) {
  403. callback(req, res, false, "", rstTpl);
  404. } else {
  405. callback(req, res, "The report template was not found!", null);
  406. }
  407. });
  408. },
  409. updateRptTpl: function (req, res) {
  410. let params = JSON.parse(req.body.params),
  411. rptTpl = JSON.parse(params.rptTpl);
  412. let filter = { ID: parseInt(rptTpl[JV.PROP_ID]) },
  413. options = { overwrite: true };
  414. RptTplModel.update(filter, rptTpl, options, function (err, rst) {
  415. if (err) {
  416. callback(
  417. req,
  418. res,
  419. true,
  420. "The report template was updated failed!",
  421. false
  422. );
  423. } else {
  424. callback(
  425. req,
  426. res,
  427. false,
  428. "The report template was updated successfully!",
  429. true
  430. );
  431. }
  432. });
  433. },
  434. copyRptTpl: function (req, res) {
  435. let params = JSON.parse(req.body.params),
  436. orgRptTplId = params.orgRptTplId,
  437. newID = params.newRptTplId;
  438. let filter = { ID: orgRptTplId };
  439. RptTplModel.findOne(filter, "-_id")
  440. .exec()
  441. .then(function (baseTplRst) {
  442. if (baseTplRst) {
  443. let _doc = baseTplRst["_doc"];
  444. _doc["ID"] = newID;
  445. if (_doc["GROUP_KEY"].indexOf("(Copy)") < 0) {
  446. _doc["GROUP_KEY"] = _doc["GROUP_KEY"] + "(Copy)";
  447. }
  448. let rptTpl = new RptTplModel(_doc);
  449. rptTpl.save(function (err, actTplRst) {
  450. if (err) {
  451. callback(req, res, "报表模板创建错误", "", null);
  452. } else {
  453. callback(req, res, false, "", newID);
  454. }
  455. });
  456. } else {
  457. callback(req, res, "Create report template failed!", null);
  458. }
  459. });
  460. },
  461. // 接口指标报表编辑器,新增的辅表选项数据
  462. getAidReportDataList: function (req, res) {
  463. let params = JSON.parse(req.body.params),
  464. compilationID = params.compilationID;
  465. let filter = { compilationID };
  466. costIndexModel
  467. .find(filter, "-_id")
  468. .exec()
  469. .then(function (data) {
  470. if (data) {
  471. callback(req, res, false, "", data);
  472. } else {
  473. callback(req, res, "The aidReportData template was not found!", null);
  474. }
  475. });
  476. },
  477. // 导出所有的报表数据
  478. async getAllBackupData(req, res) {
  479. try {
  480. const filePath = "./public/highWay_reportBackup.zip";
  481. const rptConfig = await rpt_cfg_mdl.find({}, "-_id");
  482. const rptTemplate = await RptTplModel.find({}, "-_id");
  483. const rptTplTree = await TreeNodeModel.find({}, "-_id");
  484. const rptField = await Rpt_Map_Fld_Mdl.find({}, "-_id");
  485. var zip = new JSZip();
  486. zip.file(
  487. "报表模板备份.json",
  488. JSON.stringify({
  489. type: `highWay`,
  490. name: `reportTemplate`,
  491. data: rptTemplate,
  492. })
  493. );
  494. zip.file(
  495. "报表树备份.json",
  496. JSON.stringify({
  497. type: `highWay`,
  498. name: `reportTree`,
  499. data: rptTplTree,
  500. })
  501. );
  502. zip.file(
  503. "报表配置备份.json",
  504. JSON.stringify({
  505. type: `highWay`,
  506. name: `reportConfig`,
  507. data: rptConfig,
  508. })
  509. );
  510. zip.file(
  511. "报表指标备份.json",
  512. JSON.stringify({
  513. type: `highWay`,
  514. name: `reportField`,
  515. data: rptField,
  516. })
  517. );
  518. // 将Zip打包成Blob对象
  519. zip
  520. .generateNodeStream({ type: "nodebuffer", streamFiles: true })
  521. .pipe(fs.createWriteStream(filePath))
  522. .on("finish", function () {
  523. // JSZip generates a readable stream with a "end" event,
  524. // but is piped here in a writable stream which emits a "finish" event.
  525. console.log("报表模板备份已导出");
  526. callback(req, res, false, "", filePath);
  527. });
  528. } catch (e) {
  529. callback(req, res, true, "no result", null);
  530. }
  531. },
  532. };
  533. function copyRptCfg(src, dest) {
  534. dest.margins = {
  535. Left: src.margins.Left,
  536. Right: src.margins.Right,
  537. Top: src.margins.Top,
  538. Bottom: src.margins.Bottom,
  539. };
  540. dest.showVerticalLine = src.showVerticalLine;
  541. dest.isNarrow = src.isNarrow;
  542. dest.fillZero = src.fillZero;
  543. dest.fonts = [];
  544. for (let font of src.fonts) {
  545. dest.fonts.push({
  546. ID: font["ID"],
  547. CfgDispName: font["CfgDispName"],
  548. Name: font["Name"],
  549. FontHeight: font["FontHeight"],
  550. FontColor: font["FontColor"],
  551. FontBold: font["FontBold"],
  552. FontItalic: font["FontItalic"],
  553. FontUnderline: font["FontUnderline"],
  554. FontStrikeOut: font["FontStrikeOut"],
  555. FontAngle: font["FontAngle"],
  556. });
  557. }
  558. }
  559. export default mExport;