service-achieve/app/service/achieve_apply_expert.js

'use strict';
const { CrudService } = require('naf-framework-mongoose/lib/service');
const { BusinessError, ErrorCode } = require('naf-core').Error;
const _ = require('lodash');
const assert = require('assert');

// 专家分配的申请表
class Achieve_apply_expertService extends CrudService {
  constructor(ctx) {
    super(ctx, 'achieve_apply_expert');
    this.model = this.ctx.model.AchieveApplyExpert;
  }
  async query(querys, { skip = 0, limit = 0 } = {}) {
    const { expert = false, apply, ...query } = querys;
    const pop = [];
    if (expert) pop.push('expert_id');
    if (apply)pop.push('apply_id');
    const res = await this.model.find(query)
      .populate(pop)
      .skip(parseInt(skip))
      .limit(parseInt(limit));
    return res;
  }

  async count(querys) {
    const { expert = false, apply, ...query } = querys;
    const res = await this.model.count(query);
    return res;
  }

  async create(data) {
    const { apply_id, expert_id, type } = data;
    console.log(expert_id);
    let idata = [];
    if (_.isArray(expert_id)) {
      for (const e_id of expert_id) {
        const obj = { apply_id, expert_id: e_id, type };
        const res = await this.isInApply(obj);
        if (res)idata.push(obj);
      }
      await this.model.insertMany(idata);
    } else {
      idata = { apply_id, expert_id, type };
      const res = await this.isInApply(idata);
      if (res) { await this.model.create(idata); }
    }
  }

  async isInApply(data) {
    const count = await this.model.count(data);
    return count <= 0;
  }
}

module.exports = Achieve_apply_expertService;