123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520 |
- /**
- * Created by Tony on 2017/6/1.
- */
- import mongoose from "mongoose";
- import async from "async";
- import counter from "../../../public/counter/counter";
- let RptTplModel = mongoose.model('rpt_templates');
- let TreeNodeModel = mongoose.model('rpt_tpl_tree');
- let rptExtCodeModel = mongoose.model('rpt_ext_code_tpl');
- let rptCustCfgFacade = require("../facade/rpt_cust_cfg_facade");
- import JV from "../rpt_component/jpc_value_define";
- import rttFacade from "../facade/rpt_tpl_tree_node_facade";
- import CompilationModel from "../../users/models/compilation_model";
- //统一回调函数
- let callback = function(req, res, err, message, data){
- res.json({error: err, message: message, data: data});
- };
- let mExport = {
- getCustomerCfg: function(req, res) {
- let params = JSON.parse(req.body.params),
- userId = params.userId,
- me = this;
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id;
- let userIds = [];
- userIds.push(userId);
- if (userId !== "-100") {
- userIds.push("-100");
- }
- rptCustCfgFacade.getCustomizeCfg(userIds).then(function (custCfg) {
- if (custCfg) {
- //success
- let rst = null;
- if (custCfg.length > 0) {
- rst = [];
- rst.push(null);
- for (let itemCfg of custCfg) {
- // rst = itemCfg;
- let doc = (itemCfg._doc)?itemCfg._doc:itemCfg;
- let dest = {};
- copyRptCfg(doc, dest);
- if (doc.userId !== "-100") {
- rst.push(dest);
- } else {
- rst[0] = dest;
- }
- }
- }
- if (rst !== null && rst.length === 1) {
- //copy dft config
- let userDest = {};
- copyRptCfg(rst[0], userDest);
- rst.push(userDest);
- }
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "失败!", null);
- }
- })
- },
- saveCustomerCfg: function (req, res) {
- let params = JSON.parse(req.body.params),
- userId = params.userId,
- custCfg = params.custCfg;
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id;
- custCfg.userId = userId;
- rptCustCfgFacade.saveCustomizeCfg(custCfg).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", "success!");
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- })
- },
- getDftTemplates: function(req, res) {
- let filter = {"userId": "-100", "$or": [{"isDeleted": null}, {"isDeleted": false} ]};
- TreeNodeModel.find(filter, '-_id', function(err, data){
- if (err) {
- callback(req,res, true,"", null);
- } else {
- callback(req,res,false,"", data);
- }
- });
- },
- getExtCodeTpl: function(req, res) {
- rptExtCodeModel.find({}).exec().then(function(rstCodeTpl) {
- if (rstCodeTpl) {
- callback(req,res, false, "", rstCodeTpl);
- } else {
- callback(req, res, 'The report template was not found!', null);
- }
- })
- },
- async getCompilationList(req, res) {
- let compilationModel = new CompilationModel();
- // let compilationList = await compilationModel.getPermissionCompilationList(req);
- let compilationList = await compilationModel.getCompilationList();
- if (compilationList) {
- // compilationList.then(function (rst) {
- // callback(req,res,false,"", rst);
- // })
- callback(req,res,false,"", compilationList);
- } else {
- callback(req,res, true,"no result", null);
- }
- },
- getRptTplTree: function(req, res) {
- let params = JSON.parse(req.body.params),
- compilationId = params.compilationId,
- userId = params.userId,
- sessionUserId = null;
- let userIds = ["-100"];
- if (req.session.sessionUser && req.session.sessionUser.id) sessionUserId = req.session.sessionUser.id;
- if (userId !== null) {
- if (typeof userId === "string") {
- if (userIds.indexOf(userId) < 0) userIds.push(userId);
- } else if (userId instanceof Array) {
- for (let uid of userId) {
- userIds.push(uid);
- }
- }
- } else {
- }
- if (sessionUserId && userIds.indexOf(sessionUserId) < 0) userIds.push(sessionUserId);
- if (!compilationId) {
- compilationId = req.session.sessionCompilation._id;
- }
- rttFacade.findTplTree(compilationId, userIds).then(function(result) {
- if (result) {
- callback(req,res,false,"", result);
- } else {
- callback(req,res, true,"no result", null);
- }
- });
- },
- getTplTreeByCompilation: function (req, res) {
- let params = JSON.parse(req.body.params),
- compilationId = params.compilationId;
- // if (req.session.sessionUser && req.session.sessionUser.id) sessionUserId = req.session.sessionUser.id;
- if (!compilationId) {
- compilationId = req.session.sessionCompilation._id;
- }
- rttFacade.findTplTreeByCompilation(compilationId).then(function(result) {
- if (result) {
- callback(req,res,false,"", result);
- } else {
- callback(req,res, true,"no result", null);
- }
- });
- },
- updateTreeNodes: function(req, res) {
- let params = JSON.parse(req.body.params),
- nodes = params.nodes;
- let functions = [];
- for (let node of nodes) {
- functions.push((function(doc) {
- return function(cb) {
- TreeNodeModel.update({ID: doc.ID}, doc, cb);
- };
- })(node));
- }
- async.parallel(functions, function(err, results) {
- callback(req,res, err, "", results);
- });
- },
- deleteRptTplNodes: function(req, res){
- let params = JSON.parse(req.body.params),
- nodeIds = params.nodeIds,
- preNodeId = params.preNodeId,
- preNodeNextId = params.preNodeNextId;
- let functions = [];
- if (preNodeId !== -1) {
- functions.push((function(nodeId, nextId) {
- return function(cb) {
- TreeNodeModel.update({ID: nodeId}, {"NextSiblingID": nextId}, cb);
- };
- })(preNodeId, preNodeNextId));
- }
- for (let nId of nodeIds) {
- functions.push((function(nodeId) {
- return function(cb) {
- TreeNodeModel.update({ID: nodeId}, {"isDeleted": true}, cb);
- };
- })(nId));
- }
- async.parallel(functions, function(err, results) {
- callback(req,res, err, "", results);
- });
- },
- createTreeRootNode: function(req, res){
- let params = JSON.parse(req.body.params),
- doc = params.doc;
- rttFacade.createNewTree(doc).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "创建失败!", null);
- }
- })
- },
- updateTreeRootNode: function(req, res){
- let params = JSON.parse(req.body.params),
- doc = params.doc;
- rttFacade.updateTree(doc.compilationId, doc.engineerId, doc.userId, doc).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- })
- },
- partialUpdateTreeNode: function (req, res) {
- const params = JSON.parse(req.body.params);
- const pathArray = params.pathArray;
- const nodeArray = params.nodeArray;
- const _getCurrentNodeSerialOrder = function(parentItems, pathName) {
- let rst = -1;
- if (parentItems) {
- for (let idx = 0; idx < parentItems.length; idx++) {
- if (parentItems[idx].name === pathName) {
- rst = idx;
- break;
- }
- }
- }
- return rst;
- };
- const _updateNodeByPath = function(path, node, topNodeItems) {
- let rst = false;
- let tmpParentItems = topNodeItems;
- for (let idx = 0; idx < path.node_path.length; idx++) {
- const nIdx = _getCurrentNodeSerialOrder(tmpParentItems, path.node_path[idx]);
- if (nIdx >= 0) {
- if (idx === path.node_path.length - 1) {
- tmpParentItems[nIdx] = node;
- rst = true;
- } else {
- tmpParentItems = tmpParentItems[nIdx].items;
- }
- }
- }
- return rst;
- };
- const _addNodeByPath = function(path, node, topNodeItems) {
- let rst = false;
- let tmpParentItems = topNodeItems;
- if (path === null || path === '' || path.node_path.length === 0) {
- topNodeItems.push(node);
- rst = true;
- } else {
- for (let idx = 0; idx < path.node_path.length; idx++) {
- const nIdx = _getCurrentNodeSerialOrder(tmpParentItems, path.node_path[idx]);
- if (nIdx >= 0) {
- if (idx === path.node_path.length - 1) {
- if (tmpParentItems[nIdx].nodeType === 1) {
- if (!tmpParentItems[nIdx].items) {
- tmpParentItems[nIdx].items = [];
- }
- tmpParentItems[nIdx].items.push(node);
- rst = true;
- }
- } else {
- tmpParentItems = tmpParentItems[nIdx].items;
- }
- }
- }
- }
- return rst;
- };
- const _deleteNodeByPath = function(path, node, topNodeItems) {
- let rst = false;
- let tmpParentItems = topNodeItems;
- for (let idx = 0; idx < path.node_path.length; idx++) {
- const nIdx = _getCurrentNodeSerialOrder(tmpParentItems, path.node_path[idx]);
- if (nIdx >= 0) {
- if (idx === path.node_path.length - 1) {
- tmpParentItems.splice(nIdx, 1);
- rst = true;
- } else {
- tmpParentItems = tmpParentItems[nIdx].items;
- }
- }
- }
- return rst;
- };
- // console.log('compilationId: ' + compilationId);
- rttFacade.findTplTree(params.compilationId, params.userId).then(function (targetTplTreeNode) {
- if (pathArray && pathArray.length > 0 && nodeArray && nodeArray.length === pathArray.length) {
- let doc = targetTplTreeNode._doc ? targetTplTreeNode._doc[0] : targetTplTreeNode[0];
- // console.log(doc);
- const topNodeItems = doc.items;
- for (let idx = 0; idx < pathArray.length; idx++) {
- if (pathArray[idx].operation_type === 'update') {
- _updateNodeByPath(pathArray[idx], nodeArray[idx], topNodeItems);
- } else if (pathArray[idx].operation_type === 'add') {
- _addNodeByPath(pathArray[idx], nodeArray[idx], topNodeItems);
- } else if (pathArray[idx].operation_type === 'delete') {
- _deleteNodeByPath(pathArray[idx], nodeArray[idx], topNodeItems);
- } else {
- // out of control
- }
- }
- // console.log(topNodeItems);
- // console.log(doc);
- rttFacade.updateTree(doc.compilationId, doc.engineerId, doc.userId, doc).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- })
- }
- })
- },
- updateTopNodeName: function (req, res) {
- //备注:因设计的更改,此方法将被放弃
- let params = JSON.parse(req.body.params),
- compilationId = params.compilationId, engineerId = params.engineerId,
- userId = params.userId,
- nodeName = params.nodeName
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id;
- let filter = {"compilationId": compilationId, "engineerId": engineerId, "userId": userId, "$or": [{"isDeleted": null}, {"isDeleted": false}]};
- let updateStatement = {"$set": {"name": nodeName}};
- rttFacade.updateTreeInDetail(filter, updateStatement).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- });
- },
- updateSubLevelOneNode: function (req, res) {
- let params = JSON.parse(req.body.params),
- compilationId = params.compilationId,
- // engineerId = params.engineerId,
- userId = params.userId,
- subNode = params.subNode
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id; //备注:这段逻辑只会在前端有效,后端运维不会走到
- let filter = {"compilationId": compilationId, "userId": userId, "items.ID": subNode.ID, "$or": [{"isDeleted": null}, {"isDeleted": false}]};
- let updateStatement = {$set: {"items.$": subNode}};
- rttFacade.updateTreeInDetail(filter, updateStatement).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- });
- },
- removeTreeRootNode: function (req, res) {
- let params = JSON.parse(req.body.params),
- compilationId = params.compilationId,
- engineerId = params.engineerId,
- userId = params.userId,
- isPhysically = params.isPhysically
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id;
- if (isPhysically) {
- rttFacade.removeTreePhycically(compilationId, engineerId, userId).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "删除失败!", null);
- }
- })
- } else {
- rttFacade.removeTree(compilationId, engineerId, userId).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", rst);
- } else {
- //failed
- callback(req,res, true, "删除失败!", null);
- }
- })
- }
- },
- getNewNodeID: function(req, res) {
- let params = JSON.parse(req.body.params),
- scope = params.scope;
- counter.counterDAO.getIDAfterCount(counter.moduleName.report, scope, function(err, result){
- callback(req,res, false, "", result.sequence_value);
- });
- },
- createDftRptTpl: function(req, res) {
- let params = JSON.parse(req.body.params),
- treeNodeId = params.treeNodeId,
- rptDftTplId = params.rptDftTplId,
- rptName = params.rptName,
- grpKey = params.grpKey,
- compilationId = params.compilationId,
- engineerId = params.engineerId,
- userId = params.userId,
- subNode = params.subNode
- ;
- if (req.session.sessionUser && req.session.sessionUser.id) userId = req.session.sessionUser.id;
- let filter = {"ID": rptDftTplId};
- RptTplModel.findOne(filter, '-_id').exec().then(function(dftTplRst) {
- if (dftTplRst) {
- let _doc = dftTplRst["_doc"];
- _doc["ID"] = treeNodeId;
- _doc["GROUP_KEY"] = grpKey;
- _doc["ID_KEY"] = "";
- _doc[JV.NODE_MAIN_INFO][JV.NODE_MAIN_INFO_RPT_NAME] = rptName;
- let rptTpl = new RptTplModel(_doc);
- rptTpl.save(function (err, actTplRst) {
- if (err) {
- callback(req,res, "报表模板创建错误", "", null);
- } else {
- let filter = {"compilationId": compilationId, "engineerId": engineerId, "userId": userId, "items.ID": subNode.ID, "$or": [{"isDeleted": null}, {"isDeleted": false}]};
- let updateStatement = {$set: {"items.$": subNode}};
- rttFacade.updateTreeInDetail(filter, updateStatement).then(function (rst) {
- if (rst) {
- //success
- callback(req,res, false, "", actTplRst);
- } else {
- //failed
- callback(req,res, true, "更新失败!", null);
- }
- });
- }
- });
- } else {
- callback(req, res, 'Create report template failed!', null);
- }
- })
- },
- getRefRptTpl: function (req, res) {
- let params = JSON.parse(req.body.params),
- rptTplId = params.rptTplId;
- let filter = {"ID": rptTplId};
- RptTplModel.findOne(filter, '-_id').exec().then(function(rstTpl) {
- if (rstTpl) {
- callback(req,res, false, "", rstTpl);
- } else {
- callback(req, res, 'The report template was not found!', null);
- }
- })
- },
- updateRptTpl: function (req, res) {
- let params = JSON.parse(req.body.params),
- rptTpl = JSON.parse(params.rptTpl);
- let filter = {"ID": parseInt(rptTpl[JV.PROP_ID])},
- options = {"overwrite": true};
- RptTplModel.update(filter, rptTpl, options, function (err, rst) {
- if (err) {
- callback(req, res, true, 'The report template was updated failed!', false);
- } else {
- callback(req, res, false, 'The report template was updated successfully!', true);
- }
- });
- },
- copyRptTpl: function (req, res) {
- let params = JSON.parse(req.body.params),
- orgRptTplId = params.orgRptTplId,
- newID = params.newRptTplId;
- let filter = {"ID": orgRptTplId};
- RptTplModel.findOne(filter, '-_id').exec().then(function(baseTplRst) {
- if (baseTplRst) {
- let _doc = baseTplRst["_doc"];
- _doc["ID"] = newID;
- if (_doc["GROUP_KEY"].indexOf("(Copy)") < 0) {
- _doc["GROUP_KEY"] = _doc["GROUP_KEY"] + "(Copy)";
- }
- let rptTpl = new RptTplModel(_doc);
- rptTpl.save(function (err, actTplRst) {
- if (err) {
- callback(req,res, "报表模板创建错误", "", null);
- } else {
- callback(req,res, false, "", newID);
- }
- });
- } else {
- callback(req, res, 'Create report template failed!', null);
- }
- });
- }
- };
- function copyRptCfg(src, dest) {
- dest.margins = {Left: src.margins.Left, Right: src.margins.Right, Top: src.margins.Top, Bottom: src.margins.Bottom};
- dest.showVerticalLine = src.showVerticalLine;
- dest.isNarrow = src.isNarrow;
- dest.fillZero = src.fillZero;
- dest.fonts = [];
- for (let font of src.fonts) {
- dest.fonts.push({"ID": font["ID"], "CfgDispName": font["CfgDispName"], "Name": font["Name"], "FontHeight": font["FontHeight"], "FontColor": font["FontColor"],
- "FontBold": font["FontBold"], "FontItalic": font["FontItalic"], "FontUnderline": font["FontUnderline"], "FontStrikeOut": font["FontStrikeOut"], "FontAngle": font["FontAngle"]});
- }
- }
- export default mExport;
|