|
@@ -11,16 +11,20 @@ class PersonchatService extends CrudService {
|
|
|
super(ctx, 'chat');
|
|
|
this.model = this.ctx.model.Personchat;
|
|
|
}
|
|
|
- async create(query, { sender_id, receiver_id, content, personroom_id }) {
|
|
|
+ async create(query, { sender_id, sender_name, receiver_id, receiver_name, content, personroom_id }) {
|
|
|
assert(sender_id, '缺少发送人信息');
|
|
|
assert(content, '缺少发言内容');
|
|
|
assert(receiver_id, '缺少接收人信息');
|
|
|
assert(personroom_id, '缺少聊天房间信息');
|
|
|
+ const send_time = moment().format("YYYY-MM-DD HH:mm:ss");
|
|
|
const res = await this.model.create({
|
|
|
sender_id,
|
|
|
+ sender_name,
|
|
|
receiver_id,
|
|
|
+ receiver_name,
|
|
|
content,
|
|
|
personroom_id,
|
|
|
+ send_time,
|
|
|
});
|
|
|
// TODO MQ
|
|
|
const { mq } = this.ctx;
|