ConstructionOperation/modules/users/models/compilation_model.js

/**
 * 编办管理业务逻辑模型
 *
 * @author CaiAoLin
 * @date 2017/7/28
 * @version
 */
import mongoose from "mongoose";
import BaseModel from "../../common/base/base_model";
import uuidV1 from "uuid/v1";
const engineeringModel = mongoose.model("engineering_lib");
const compilationModel = mongoose.model("compilation");

class CompilationModel extends BaseModel {
  /**
   * 允许的块
   *
   * @var {Array}
   */
  sectionList = ["bill", "ration"];

  /**
   * 构造函数
   *
   * @return {void}
   */
  constructor() {
    let parent = super();
    parent.model = mongoose.model("compilation");
    parent.init();
  }

  /**
   * 获取编办列表
   *
   * @return {Promise}
   */
  async getCompilationList(fields = null) {
    // 筛选字段
    let field =
      fields == null
        ? {
            _id: 1,
            name: 1,
            is_release: 1,
            release_time: 1,
            categoryID: 1,
            defaultLocation: 1,
            description: 1,
            overWriteUrl: 1,
            example: 1,
            edition: 1,
            serialNumber: 1,
            freeUse: 1,
            "ration_valuation.id": 1,
            "ration_valuation.name": 1,
            "ration_valuation.enable": 1,
            "bill_valuation.id": 1,
            "bill_valuation.name": 1,
            "bill_valuation.enable": 1,
            "bill_valuation.fileTypes": 1,
          }
        : fields;
    // 一定要查询序号，然后排序输出
    field.serialNumber = 1;
    let compilationData = await this.findDataByCondition(
      { name: { $ne: "" } },
      field,
      false
    );
    if (compilationData) {
      compilationData.sort((aa, bb) => {
        return (aa.serialNumber || 99999) - (bb.serialNumber || 99999);
      });
      return compilationData;
    }
    return [];
  }

  // 根据用户权限过滤编办
  async getPermissionCompilationList(req, fields = null) {
    const compilationPermission =
      req.session.managerData.compilationPermission || [];
    console.log(`req.session.managerData`);
    console.log(req.session.managerData.compilationPermission);
    const compilationList = await this.getCompilationList(fields);
    console.log(compilationList);
    return compilationList.filter(
      (item) =>
        compilationPermission.includes(item._id) ||
        compilationPermission.includes(item._id.toString())
    );
  }

  /**
   * 获取编办列表
   *
   * @return {Promise}
   */
  async getList() {
    // 筛选字段
    let field = {
      _id: 1,
      name: 1,
      is_release: 1,
      description: 1,
      categoryID: 1,
    };
    let compilationData = await this.findDataByCondition(
      { name: { $ne: "" }, is_release: true },
      field,
      false
    );

    return compilationData === null ? [] : compilationData;
  }

  /**
   * 根据id获取可用的编办数据
   *
   * @param {String} id
   * @return {Promise}
   */
  async getCompilationById(id) {
    let condition = { _id: id, is_release: true };
    let compilationData = await this.findDataByCondition(condition);
    if (!compilationData || compilationData.bill_valuation === undefined) {
      return compilationData;
    }

    if (compilationData.bill_valuation.length > 0) {
      let enableValuation = [];
      for (let index in compilationData.bill_valuation) {
        if (compilationData.bill_valuation[index].enable) {
          enableValuation.push(compilationData.bill_valuation[index]);
        }
      }
      compilationData.bill_valuation = enableValuation;
    }

    if (compilationData.ration_valuation.length > 0) {
      let enableValuation = [];
      for (let index in compilationData.ration_valuation) {
        if (compilationData.ration_valuation[index].enable) {
          enableValuation.push(compilationData.bill_valuation[index]);
        }
      }
      compilationData.ration_valuation = enableValuation;
    }

    return compilationData;
  }

  /**
   * 设置场景
   *
   * @param {string} scene
   * @return {void}
   */
  setScene(scene = "") {
    switch (scene) {
      // 新增
      case "add":
        this.model.schema.path("name").required(true);
        this.model.schema.path("creator").required(true);
        this.model.schema.path("create_time").required(true);
        break;
    }
  }

  /**
   * 新增编办
   *
   * @param {Object} data
   * @return {Promise}
   */
  async add(data) {
    let result = false;
    if (Object.keys(data).length <= 0) {
      return result;
    }

    this.setScene("add");
    data.create_time = new Date().getTime();
    result = this.db.create(data);
    return result;
  }

  /*
   * 设置版本描述
   *
   * @param {String} compilationId
   * @param {String} description
   * @return {Promise}
   * */
  async setDescription(compilationId, description) {
    return await this.updateById(compilationId, { description: description });
  }

  /*
   * 设置版本号
   *
   * @param {String} compilationId
   * @param {String} edition
   * @return {Promise}
   * */
  async setEdition(compilationId, edition) {
    return await this.updateById(compilationId, { edition: edition });
  }
  /*
   * 设置序号号
   *
   * @param {String} compilationId
   * @param {String} serialNumber
   * @return {Promise}
   * */
  async setSerialNumber(compilationId, serialNumber) {
    return await this.updateById(compilationId, { serialNumber: serialNumber });
  }
  /*
        设置代码覆盖路径
     */
  async setOverWriteUrl(
    compilationId,
    overWriteUrl,
    priceProp,
    consumeAmtProp
  ) {
    return await this.updateById(compilationId, {
      overWriteUrl: overWriteUrl,
      priceProperties: priceProp,
      consumeAmtProperties: consumeAmtProp,
    });
  }

  /*
   * 设置例题
   * @param {String} compilationId
   * @param {Array} example
   * @return {Promise}
   * */
  async setExample(compilationId, example) {
    let data = [];
    if (example) {
      for (let projId of example) {
        if (/^[0-9]+$/.test(projId)) {
          data.push(parseInt(projId));
        } else if (projId) {
          data.push(projId);
        }
      }
    }
    return await this.updateById(compilationId, { example: data });
  }

  /**
   * 新增计价规则
   *
   * @param {String} id
   * @param {String} section
   * @param {Object} data
   * @return {Promise}
   */
  async addValuation(id, section, data) {
    let condition = { _id: id };
    let compilationData = await this.findDataByCondition(condition);
    if (compilationData === null || compilationData.name === undefined) {
      throw "没有找到对应的数据";
    }

    if (data.name === undefined || data.name === "") {
      throw "计价规则名称为空";
    }
    if (this.sectionList.indexOf(section) < 0) {
      console.log("2");
      throw "数据有误";
    }

    let insertData = {};
    data.id = uuidV1();
    insertData[section + "_valuation"] = data;
    let result = await this.db.addToSet(condition, insertData);
    return result.ok === undefined ? false : data.id;
  }

  /**
   * 保存计价数据
   *
   * @param {String} valuationId
   * @param {Object} data
   * @return {Promise}
   */
  async saveValuation(valuationId, data) {
    data = this._filterValuationData(data);
    let sectionString = data.section + "_valuation";
    let condition = {};
    condition[sectionString + ".id"] = valuationId;

    let updateData = {};
    updateData[sectionString + ".$.name"] = data.valuationName;

    let result = await this.db.update(condition, updateData);

    return result !== null && result.ok === 1;
  }

  /**
   * 更改启用/禁用
   *
   * @param {String} valuationId
   * @param {String} section
   * @param {String} enable
   * @return {Promise}
   */
  async switchEnable(valuationId, section, enable) {
    let sectionString = section + "_valuation";
    let condition = {};
    condition[sectionString + ".id"] = valuationId;

    let updateData = {};
    updateData[sectionString + ".$.enable"] = enable === "true";

    let result = await this.db.update(condition, updateData);

    return result !== null && result.ok === 1;
  }

  /**
   * 设置计价规则适用类型
   *
   * @param {String} valuationId
   * @param {String} section
   * @param {String} setFileTypes
   * @return {Promise}
   */
  async setFileTypes(valuationId, section, fileTypes) {
    let sectionString = section + "_valuation";
    let condition = {};
    condition[sectionString + ".id"] = valuationId;

    let updateData = {};
    updateData[sectionString + ".$.fileTypes"] = fileTypes;

    let result = await this.db.update(condition, updateData);

    return result !== null && result.ok === 1;
  }

  /**
   * 过滤计价数据
   *
   * @param {Object} data
   * @return {Object}
   */
  _filterValuationData(data) {
    if (Object.keys(data).length <= 0) {
      console.log("3");
      throw "数据有误";
    }

    if (
      data.section === undefined ||
      data.section === "" ||
      this.sectionList.indexOf(data.section) < 0
    ) {
      throw "类型错误";
    }

    // 判断名称
    if (data.valuationName === undefined || data.valuationName === "") {
      throw "名称不能为空";
    }

    return data;
  }

  /**
   * 获取计价规则数据
   *
   * @param {String} compilationId
   * @param {String} id
   * @param {String} section
   * @return {Promise|Array}
   */
  async getValuation(compilationId, id, section) {
    if (this.sectionList.indexOf(section) < 0) {
      throw "数据有误";
    }
    let compilationData = await this.findDataByCondition({
      _id: compilationId,
    });
    if (Object.keys(compilationData).length <= 0) {
      throw "编办数据有误";
    }
    let result = {};
    let sectionString = section + "_valuation";

    for (let valuation of compilationData[sectionString]) {
      if (valuation.id.toString() === id) {
        result = valuation;
        break;
      }
    }

    return [result, compilationData[sectionString]];
    /* 数据库获取编办
        let condition = {_id: versionId};
        let childCondition = {};
        childCondition[sectionString] = {$elemMatch: {_id: id}};

        let result = await this.db.findOne(condition, childCondition);

        return result !== null && result.bill_valuation.length > 0 ? result.bill_valuation[0] : {};
        */
  }

  /**
   * 删除计价规则
   *
   * @param {String} compilationId
   * @param {String} valuationId
   * @param {String} section
   * @return {Promise}
   */
  async deleteValuation(compilationId, valuationId, section) {
    let condition = { _id: compilationId };
    let sectionString = section + "_valuation";
    let deleteData = {};
    deleteData[sectionString] = { id: valuationId };

    // 利用pull删除嵌套数据
    let result = await this.db.deleteSet(condition, deleteData);

    return result !== null && result.ok === 1;
  }

  /**
   * 发布编办
   *
   * @param {String} id
   * @param {Number} status
   * @return {Promise}
   */
  async release(id, status) {
    // 如果是发布编办则需要判断配置的内容是否满足发布条件
    if (status) {
      let compilationData = await this.findDataByCondition({ _id: id });
      // 最少需要有一个计价规则存在
      if (
        compilationData.bill_valuation.length <= 0 &&
        compilationData.ration_valuation.length <= 0
      ) {
        throw "至少需要一个计价规则";
      }

      // 判断是否全部禁止
      let hasEnable = false;
      let valuationList = compilationData.bill_valuation.concat(
        compilationData.ration_valuation
      );
      for (let valuation of valuationList) {
        if (valuation.enable) {
          hasEnable = true;
          break;
        }
      }

      if (!hasEnable) {
        throw "至少需要一个可用的计价规则";
      }
    }

    let updateData = {
      is_release: status === 1,
      release_time: new Date().getTime(),
    };
    return this.updateById(id, updateData);
  }

  /**
   * 根据专业工程获取对应专业工程标准库id
   *
   * @param {String} valuationId
   * @param {String} section
   * @param {Number} engineering
   * @return {Promise}
   */
  async getEngineeringLib(valuationId, section, engineering) {
    let sectionString = section + "_valuation";
    let condition = {};
    condition[sectionString + ".id"] = valuationId;

    let compilationData = await this.findDataByCondition(condition);
    if (compilationData === null) {
      throw "不存在对应编办";
    }
    let valuationData = null;
    for (let valuation of compilationData[sectionString]) {
      if (valuation.id === valuationId) {
        valuationData = valuation;
      }
    }

    if (valuationData === null) {
      throw "不存在对应计价规则";
    }

    // 判断是否已有对应数据
    let engineeringList = valuationData.engineering_list;
    let engineeringLib = null;
    for (let tmpEngineering of engineeringList) {
      if (tmpEngineering.engineering === engineering) {
        engineeringLib = tmpEngineering;
        break;
      }
    }

    return engineeringLib;
  }

  /**
   * 新增专业工程标准库
   *
   * @param {String} valuationId
   * @param {String} section
   * @param {Object} data
   * @return {Promise}
   */
  async addEngineeringLib(valuationId, section, data) {
    let sectionString = section + "_valuation";
    let condition = {};
    condition[sectionString + ".id"] = valuationId;

    let insertData = {};
    insertData[sectionString + ".$.engineering_list"] = data;
    let result = await this.db.addToSet(condition, insertData);

    return result.ok === 1;
  }

  /*
   * 设置CLD办事处信息
   *
   * @param {String} compilationId
   * @param {int} category
   * @return {Promise}
   * */
  async updateCategory(compilationId, category) {
    return await this.updateById(compilationId, { categoryID: category });
  }

  /*
   * 设置工程默认所在地
   *
   * @param {String} compilationId
   * @param {int} location
   * @return {Promise}
   * */
  async updateLocation(compilationId, location) {
    return await this.updateById(compilationId, { defaultLocation: location });
  }

  /*
   * 设置是否提供免费版
   *
   * @param {String} compilationId
   * @param {int} location
   * @return {Promise}
   * */
  async updateFreeUse(compilationId, freeUse) {
    return await this.updateById(compilationId, { freeUse: freeUse });
  }

  // 拷贝计价规则
  async copyValuation(compilationID, valuationType, orgValuationID, newName) {
    const objectId = mongoose.Types.ObjectId(compilationID);
    const compilationData = await compilationModel
      .findOne({ _id: objectId })
      .lean();
    const orgValuation = compilationData[valuationType].find(
      (item) => item.id === orgValuationID
    );
    if (!orgValuation) {
      throw "不存在对应计价规则";
    }
    const newValuation = {
      ...orgValuation,
      id: uuidV1(),
      enable: false,
      name: newName,
    };
    await compilationModel.update(
      { _id: objectId },
      { $push: { [valuationType]: newValuation } }
    );
    await this.copyEngineeringList(orgValuationID, newValuation.id);
  }

  // 拷贝工程专业
  async copyEngineeringList(orgValuationID, newValuationID) {
    const engineeringList = await engineeringModel
      .find({ valuationID: orgValuationID }, "-_id")
      .lean();
    console.log(engineeringList);
    const newEngineeringList = engineeringList.map((item) => ({
      ...item,
      valuationID: newValuationID,
    }));
    if (newEngineeringList.length) {
      await engineeringModel.insertMany(newEngineeringList);
    }
  }
}

export default CompilationModel;