|
@@ -36,8 +36,10 @@ export class ChatRecordController extends BaseController {
|
|
async create(@Body() data: CreateDTO_chatRecord) {
|
|
async create(@Body() data: CreateDTO_chatRecord) {
|
|
data.time = dayjs().format('YYYY-MM-DD HH:mm:ss');
|
|
data.time = dayjs().format('YYYY-MM-DD HH:mm:ss');
|
|
let result;
|
|
let result;
|
|
|
|
+ let updateRoom = false;
|
|
if (data.room) {
|
|
if (data.room) {
|
|
result = await this.service.create(data);
|
|
result = await this.service.create(data);
|
|
|
|
+ updateRoom = true;
|
|
} else {
|
|
} else {
|
|
// 先创建room,再创建聊天记录
|
|
// 先创建room,再创建聊天记录
|
|
const { customer, shop, speaker } = data;
|
|
const { customer, shop, speaker } = data;
|
|
@@ -64,6 +66,10 @@ export class ChatRecordController extends BaseController {
|
|
}
|
|
}
|
|
result = await this.service.create(data);
|
|
result = await this.service.create(data);
|
|
}
|
|
}
|
|
|
|
+ if (updateRoom) {
|
|
|
|
+ const rd = { last_chat: data.content, last_person: data.speaker, last_time: data.time };
|
|
|
|
+ await this.roomService.updateOne(data.room, rd);
|
|
|
|
+ }
|
|
// mq 发送消息
|
|
// mq 发送消息
|
|
const room = await this.roomService.fetch(data.room);
|
|
const room = await this.roomService.fetch(data.room);
|
|
let receiver;
|
|
let receiver;
|