|
@@ -15,11 +15,12 @@ export class ChatService extends BaseService<modelType> {
|
|
|
|
|
|
async sendMq(data) {
|
|
|
// 队列: /${群组id}/${患者id}
|
|
|
- const { group, patient } = data;
|
|
|
+ const { group, patient, _id } = data;
|
|
|
// 没有群组&患者id直接返回,无法构成队列
|
|
|
if (!(group && patient)) return;
|
|
|
const routingKey = `${group}_${patient}`;
|
|
|
- await this.chatMqService.sendExMsg(routingKey, JSON.stringify(data));
|
|
|
+ const nd = await this.fetch(_id);
|
|
|
+ await this.chatMqService.sendExMsg(routingKey, JSON.stringify(nd));
|
|
|
}
|
|
|
|
|
|
async query(filter: SearchBase, pageOptions: PageOptions = {}): Promise<Array<any>> {
|