| | |
| | | WebSocketUsers.sendMessageToUsersByText(message); |
| | | return R.ok(); |
| | | } |
| | | |
| | | /** |
| | | * 批量向指定用户推送消息 |
| | | * @param dto |
| | | * @return |
| | | */ |
| | | @InnerAuth |
| | | @PostMapping("/push-batch") |
| | | public R<?> pushBatch(@RequestBody WebsocketMessageDTO dto) { |
| | | WebSocketUsers.sendMessageToUserById(dto.getUserId(), dto.getMessage()); |
| | | return R.ok(); |
| | | } |
| | | /** |
| | | * 通过用户id推送消息 |
| | | * @param type |
| | | * @param msg |
| | | * @return |
| | | */ |
| | | @GetMapping("/push-by-user-id/{userId}/{msg}") |
| | | public R<?> pushByUserId(@PathVariable("userId") Long userId, |
| | | @PathVariable("msg") String msg) { |
| | | WebSocketUsers.sendMessageToUserById(userId, msg); |
| | | return R.ok(); |
| | | } |
| | | } |