|
@@ -11,13 +11,13 @@ export class SendController {
|
|
|
async sendMsg(@Body() body: object) {
|
|
|
const target = get(body, 'target');
|
|
|
const userType = get(body, 'userType');
|
|
|
- const data_id = get(body, 'data_id');
|
|
|
+ const content = get(body, 'content');
|
|
|
let ex;
|
|
|
if (userType === MessageUserType.ADMIN) {
|
|
|
ex = this.mqService.system.ex;
|
|
|
} else if (userType === MessageUserType.USER) {
|
|
|
ex = this.mqService.user.ex;
|
|
|
}
|
|
|
- return this.mqService.publish(ex, target, data_id);
|
|
|
+ return this.mqService.publish(ex, target, content);
|
|
|
}
|
|
|
}
|