|
@@ -0,0 +1,41 @@
|
|
|
+'use strict';
|
|
|
+
|
|
|
+const assert = require('assert');
|
|
|
+const _ = require('lodash');
|
|
|
+const moment = require('moment');
|
|
|
+const { ObjectId } = require('mongoose').Types;
|
|
|
+const { CrudService } = require('naf-framework-mongoose/lib/service');
|
|
|
+const { BusinessError, ErrorCode } = require('naf-core').Error;
|
|
|
+
|
|
|
+class AnswerapplyService extends CrudService {
|
|
|
+ constructor(ctx) {
|
|
|
+ super(ctx, 'answerapply');
|
|
|
+ this.model = this.ctx.model.Answerapply;
|
|
|
+ }
|
|
|
+
|
|
|
+ // async create(data) {
|
|
|
+ // const { sender_id, sender_name, receiver_id, receiver_name, room, content } = data;
|
|
|
+ // assert(sender_id, '缺少发送人信息');
|
|
|
+ // assert(sender_name, '缺少发送人信息');
|
|
|
+ // assert(receiver_id, '缺少接收人信息');
|
|
|
+ // assert(receiver_name, '缺少接受人信息');
|
|
|
+ // assert(room, '缺少房间号');
|
|
|
+ // assert(content, '缺少发送内容');
|
|
|
+ // const send_time = moment().format('YYYY-MM-DD HH:mm:ss');
|
|
|
+ // const res = await this.model.create({ ...data, send_time });
|
|
|
+ // const { mq } = this.ctx;
|
|
|
+ // if (mq) {
|
|
|
+ // const exchange = 'answerchat';
|
|
|
+ // const parm = {
|
|
|
+ // durable: true,
|
|
|
+ // headers: {
|
|
|
+ // userid: 1,
|
|
|
+ // } };
|
|
|
+ // await mq.fanout(exchange, room, JSON.stringify(res), parm);
|
|
|
+ // }
|
|
|
+ // return res;
|
|
|
+ // }
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+module.exports = AnswerapplyService;
|