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 } = require('naf-core').Error;
const moment = require('moment');
const jwt = require('jsonwebtoken');

class ChatService extends CrudService {
  constructor(ctx) {
    super(ctx, 'dock');
    this.model = this.ctx.model.Dock;
  }
  // 创建登录Token
  async createJwtPwd(password) {
    const { secret } = this.config.jwt;
    const token = await jwt.sign(password, secret);
    return token;
  }
  async create(body) {
    // roomid与密码每次加一
    const findroom = await this.model.find().sort({ room_id: -1 });
    if (findroom.length > 0) {
      const room = (parseInt(findroom[0].room_id) + 1) + '';
      // 将用户输入的密码进行加密并与查询到的用户数据密码相比对
      const pas = await this.createJwtPwd(room);
      body.room_id = room;
      body.password = { secret: pas };
    } else {
      // 将用户输入的密码进行加密并与查询到的用户数据密码相比对
      const room = '1001';
      const pas = await this.createJwtPwd(room);
      body.room_id = room;
      body.password = { secret: pas };
    }
    const res = await this.model.create(body);
    return { ...JSON.parse(JSON.stringify(res)), password: res.password.secret, room_id: res.room_id };
  }
  // 产品
  async goods({ id }, body) {
    // console.log(body);
    const dock = await this.model.findOne({ _id: ObjectId(id) });
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    if (body._id) {
      const goods = dock.apply.map(i => i.goodsList).flat().find(function(item) {
        return item.id === body._id;
      });
      if (body.dockStatus) {
        goods.dockStatus = body.dockStatus;
      }
    } else {
      dock.apply.goodsList.push({
        ...body,
      });
    }

    const res = await dock.save();
    const info = _.last(res.apply.goodsList);
    return info;
  }

  async apply({ id }, body) {
    const dock = await this.model.findOne({ _id: ObjectId(id) });
    if (!dock) {
      throw new BusinessError('没有查询到该对接会');
    }
    if (body._id) {
      // 修改
      const apply = dock.apply.find(item => item._id === body._id);
      if (body.user_name) {
        apply.user_name = body.user_name;
      }
      if (body.goodsList) {
        apply.goodsList = body.goodsList;
      }
      if (body.contact_tel) {
        apply.contact_tel = body.contact_tel;
      }
      if (body.apply_time) {
        apply.apply_time = body.apply_time;
      }
      if (body.role) {
        apply.role = body.role;
      }
      if (body.status) {
        apply.status = body.status;
      }
    } else {
      // 保存
      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.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;
  }

  async getdock({ id }) {
    const res = await this.model.find({ vipuser: { $elemMatch: { uid: id } } });
    return res;
  }

  async getdockByopenid({ openid }) {
    const res = await this.model.findOne({ openid });
    return res;
  }
  async getapply({ user_id }) {
    const res = await this.model.find({ 'apply.user_id': { $regex: user_id } });
    return _.flatten(res);
  }

  async getgoodslist({ name }) {
    assert(name, '请输入产品名称');
    const res = await this.model.find({ 'apply.goodsList.name': { $regex: name } });
    const data = [];
    for (const elm of res) {
      const applys = elm.apply;
      for (const el of applys) {
        const goodlists = el.goodsList;
        const goodlist = _.filter(goodlists, function(o) {
          const oo = _.includes(o.name, name);
          console.log(oo);
          return oo;
        });
        data.push(goodlist);
      }
    }
    return _.flatten(data);
  }
}

module.exports = ChatService;