service-center/app/service/liveroom.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;

class LiveroomService extends CrudService {
  constructor(ctx) {
    super(ctx, 'liveroom');
    this.model = this.ctx.model.Liveroom;
  }
  async create(data) {
    const { subid, teacherid } = data;
    assert(subid, '缺少科目信息');
    assert(teacherid, '缺少教师信息');
    const list = await this.model.find();
    const last = _.last(list);
    let number = '000001';
    if (last) {
      number = last.number * 1 + 1;
    }
    data.number = number;
    const res = await this.model.create(data);
    return res;
  }

  async personcount(data) {
    const { number, name, userid, type } = data;
    // 取出已经进入直播的用户列表
    let list = await this.app.redis.get(`liveroom${number}`);
    console.log(_.cloneDeep(list));
    if (list) {
      // 已经开始直播,并且有人观看
      list = JSON.parse(list);
      if (!type) {
        list = _.uniqBy(list.push({ name, userid }), 'userid');
      } else {
        list = list.filter(f => f.userid !== userid);
      }
      list = JSON.stringify(list);
    } else {
      // 还没有人进直播
      list = JSON.stringify([{ name, userid }]);
    }
    await this.app.redis.set(`liveroom${number}`, list);
    const { mq } = this.ctx;
    if (mq) {
      const exchange = 'liveroom-personcount';
      const parm = {
        durable: true,
        headers: {
          userid: 1,
        },
      };
      await mq.fanout(exchange, number, list, parm);
    }
  }
}

module.exports = LiveroomService;