rpt_tpl_controller.js 21 KB

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