roomchat.js 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. 'use strict';
  2. const assert = require('assert');
  3. // const _ = require('lodash');
  4. // const { ObjectId } = require('mongoose').Types;
  5. const moment = require('moment');
  6. const { CrudService } = require('naf-framework-mongoose/lib/service');
  7. // const { BusinessError, ErrorCode } = require('naf-core').Error;
  8. class RoomchatService extends CrudService {
  9. constructor(ctx) {
  10. super(ctx, 'roomchat');
  11. this.model = this.ctx.model.Roomchat;
  12. }
  13. async create(query, { number, sender_id, sender_name, content, role }) {
  14. assert(sender_name, '缺少发言人信息');
  15. assert(content, '缺少发言内容');
  16. assert(number, '缺少房间号');
  17. const send_time = moment().format('YYYY-MM-DD HH:mm:ss');
  18. const res = await this.model.create({ number, sender_id, sender_name, content, send_time, role });
  19. // TODO MQ
  20. const { mq } = this.ctx;
  21. if (mq) {
  22. const exchange = 'room_chat';
  23. const parm = {
  24. durable: true,
  25. headers: {
  26. number,
  27. } };
  28. mq.fanout(exchange, number, JSON.stringify(res), parm);
  29. }
  30. return res;
  31. }
  32. }
  33. module.exports = RoomchatService;