ConstructionOperation/modules/reports/controllers/rpt_tpl_controller.js

/**
 * 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 Rpt_Map_Fld_Mdl = mongoose.model("rpt_mapping_field");
let rpt_cfg_mdl = mongoose.model("rpt_cfg");
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";

import fs from "fs";
let JSZip = require("jszip");
//统一回调函数
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);
        }
      });
  },
  // 导出所有的报表数据
  getAllBackupData: async function (req, res) {
    try {
      const filePath = "./public/building_reportBackup.zip";
      let rptTemplate = [];
      let rptTplTree = [];
      let rptConfig = [];
      let rptField = [];
      await new Promise(async function (resolve) {
        rptTemplate = await RptTplModel.find({}, "-_id");
        resolve();
      });

      await new Promise(async function (resolve) {
        rptTplTree = await TreeNodeModel.find({}, "-_id");
        resolve();
      });
      await new Promise(async function (resolve) {
        rptConfig = await rpt_cfg_mdl.find({}, "-_id");
        resolve();
      });
      await new Promise(async function (resolve) {
        rptField = await Rpt_Map_Fld_Mdl.find({}, "-_id");
        resolve();
      });
      var zip = new JSZip();
      zip.file(
        "报表模板备份.json",
        JSON.stringify({
          type: `building`,
          name: `reportTemplate`,
          data: rptTemplate,
        })
      );
      zip.file(
        "报表树备份.json",
        JSON.stringify({
          type: `building`,
          name: `reportTree`,
          data: rptTplTree,
        })
      );
      zip.file(
        "报表配置备份.json",
        JSON.stringify({
          type: `building`,
          name: `reportConfig`,
          data: rptConfig,
        })
      );
      zip.file(
        "报表指标备份.json",
        JSON.stringify({
          type: `building`,
          name: `reportField`,
          data: rptField,
        })
      );
      // 将Zip打包成Blob对象
      zip
        .generateNodeStream({ type: "nodebuffer", streamFiles: true })
        .pipe(fs.createWriteStream(filePath))
        .on("finish", function () {
          // JSZip generates a readable stream with a "end" event,
          // but is piped here in a writable stream which emits a "finish" event.
          console.log("报表模板备份已导出");
          callback(req, res, false, "", filePath);
        });
    } catch (e) {
      callback(req, res, true, "no result", 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;