service-live/app/service/dock.js

'use strict';

const assert = require('assert');
const _ = require('lodash');
const { ObjectId } = require('mongoose').Types;
const { CrudService } = require('naf-framework-mongoose/lib/service');
const { BusinessError, ErrorCode } = require('naf-core').Error;
const moment = require('moment');
class ChatService extends CrudService {
  constructor(ctx) {
    super(ctx, 'dock');
    this.model = this.ctx.model.Dock;
  }
  async create(body) {
    const res = await this.model.create(body);
    if (res) {
      const url = this.ctx.app.config.axios.auth.baseUrl;
      const newdata = {
        name: body.adminuser,
        phone: body.phone,
        passwd: body.passwd,
        uid: res.id,
        role: '4',
        pid: body.pid,
        code: body.code,
      };
      const user = await this.ctx.curl(url, {
        method: 'post',
        headers: {
          'content-type': 'application/json',
        },
        dataType: 'json',
        data: JSON.stringify(newdata),
      });
      if (user.data.errcode === 0) {
        const result = await this.model.findById(res.id);
        result.uid = user.data.data.id;
        result.adminuser = body.adminuser;
        result.phone = body.phone;
        result.save();
      }
    }
    return { ...JSON.parse(JSON.stringify(res)), adminuser: body.adminuser, phone: body.phone };
  }
  async apply({ id }, body) {
    const dock = await this.model.findOne({ _id: ObjectId(id) });
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    dock.apply.push({
      ...body,
      apply_time: moment().format('YYYY-MM-DD HH:mm:ss'),
    });
    const res = await dock.save();
    const info = _.last(res.apply);
    return info;
  }

  async check({ id, dock_id }, { status }) {
    assert(status, '请审核是否允许参加对接会');
    const dock = await this.model.findOne({ _id: ObjectId(dock_id) });
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    const user = dock.apply.id(id);
    if (!user) {
      throw new BusinessError('没有查询到用户的申请');
    }
    user.status = status;
    const res = dock.save();
    return res;
  }
  async dockCheck({ id }, { is_allowed, reason = '' }) {
    const dock = await this.model.findOne({ _id: ObjectId(id) });
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    assert(is_allowed, '请选择审核结果');
    dock.is_allowed = is_allowed;
    dock.reason = reason;
    const res = await dock.save();
    return res;
  }

  // 根据申请人id查询所有申请的对接会
  async myapply({ user_id, status, skip, limit }) {
    const total = await this.model.count({ status, 'apply.user_id': user_id });
    const data = await this.model.find({ status, 'apply.user_id': user_id }).skip(Number(skip)).limit(Number(limit));
    const result = { total, data };
    return result;
  }

  async updatevipuser({ id }, info) {
    const dock = await this.model.findById(id);
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    const vipuser = await dock.vipuser.id(info.vipid);
    if (!vipuser) {
      throw new BusinessError('没有查询到vip用户');
    }
    if (info.vipname) {
      vipuser.vipname = info.vipname;
    }
    if (info.vipphone) {
      vipuser.vipphone = info.vipphone;
    }
    if (info.role) {
      vipuser.role = info.role;
    }
    if (info.company) {
      vipuser.company = info.company;
    }
    if (info.email) {
      vipuser.email = info.email;
    }
    if (info.content) {
      vipuser.content = info.content;
    }
    return await dock.save();
  }

  async createvipuser({ id }, info) {
    const dock = await this.model.findById(id);
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    const vipuser = {};
    vipuser.uid = info.uid;
    vipuser.vipname = info.vipname;
    vipuser.vipphone = info.vipphone;
    vipuser.role = info.role;
    vipuser.company = info.company;
    vipuser.email = info.email;
    vipuser.content = info.content;
    dock.vipuser.push(vipuser);
    return await dock.save();
  }

  async dockfetch({ id }) {
    const dock = await this.model.findById(id);
    const data = JSON.parse(JSON.stringify(dock));
    if (dock) {
      const applydata = [];
      for (const elm of dock.apply) {
        const url = 'http://localhost:9004/api/market/transaction?userid=' + elm.user_id;
        const res = await this.ctx.curl(url, {
          method: 'get',
          headers: {
            'content-type': 'application/json',
          },
          dataType: 'json',
        });
        const newdata = { ...JSON.parse(JSON.stringify(elm)), transdata: res.data.data };
        applydata.push(newdata);
      }
      data.apply = applydata;
    }
    return data;
  }
}

module.exports = ChatService;