| | |
|---|
| | | * @return 操作结果 |
|---|
| | | */ |
|---|
| | | @ApiOperation(value = "发送订单状态") |
|---|
| | | @PostMapping("/inner/websocket/order/sendStatus") |
|---|
| | | @PostMapping("/logan/inner/websocket/order/sendStatus") |
|---|
| | | public R<String> sendStatus(@RequestBody SendMessageDTO dto) { |
|---|
| | | try { |
|---|
| | | String message = dto.getMessage(); |
|---|
| | |
|---|
| | | public R<?> pushTask(@RequestBody XpTaskVO vo) throws JsonProcessingException { |
|---|
| | | |
|---|
| | | String handleUserId = vo.getHandleUserId(); |
|---|
| | | Map<String, Object> msg = new HashMap(); |
|---|
| | | Map<String, Object> msg = new HashMap<>(); |
|---|
| | | msg.put("type", "task"); |
|---|
| | | msg.put("data", vo); |
|---|
| | | webSocketUserService.sendMessageToUser(handleUserId, om.writeValueAsString(msg)); |
|---|
