| | |
|---|
| | | package com.xiaopeng.pushMessage.webSocket.controller; |
|---|
| | | |
|---|
| | | import com.fasterxml.jackson.core.JsonProcessingException; |
|---|
| | | import com.fasterxml.jackson.databind.DeserializationFeature; |
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
|---|
| | | import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; |
|---|
| | | import com.xiaopeng.api.dto.pushMessage.SendMessageDTO; |
|---|
| | | import com.xiaopeng.api.vo.TaskVO; |
|---|
| | | import com.xiaopeng.api.vo.XpTaskVO; |
|---|
| | | import com.xiaopeng.common.core.domain.R; |
|---|
| | | import com.xiaopeng.common.core.web.controller.BaseController; |
|---|
| | | import com.xiaopeng.pushMessage.webSocket.service.WebSocketUserService; |
|---|
| | |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | |
|---|
| | | import javax.annotation.PostConstruct; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Set; |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private WebSocketUserService webSocketUserService; |
|---|
| | | |
|---|
| | | private ObjectMapper om; |
|---|
| | | |
|---|
| | | @PostConstruct |
|---|
| | | void setupObjectMapper() { |
|---|
| | | // 允许对象忽略json中不存在的属性 |
|---|
| | | om = new ObjectMapper(); |
|---|
| | | om.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); |
|---|
| | | om.registerModule(new JavaTimeModule()); |
|---|
| | | } |
|---|
| | | @Autowired ObjectMapper om; |
|---|
| | | |
|---|
| | | // ==================== 基于XpAppUser的WebSocket接口 ==================== |
|---|
| | | |
|---|
| | |
|---|
| | | * @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(); |
|---|
| | |
|---|
| | | * @return 操作结果 |
|---|
| | | */ |
|---|
| | | @ApiOperation(value = "发送车辆路线、时间") |
|---|
| | | @PostMapping("/inner/websocket/order/sendRoute") |
|---|
| | | @PostMapping("/logan/inner/websocket/order/sendRoute") |
|---|
| | | public R<String> sendRoute(@RequestBody SendMessageDTO dto) { |
|---|
| | | try { |
|---|
| | | String message = dto.getMessage(); |
|---|
| | |
|---|
| | | * 运维工单app推送 |
|---|
| | | */ |
|---|
| | | @PostMapping("/inner/websocket/push/task") |
|---|
| | | public R<?> pushTask(@RequestBody TaskVO vo) throws JsonProcessingException { |
|---|
| | | public R<?> pushTask(@RequestBody XpTaskVO vo) throws JsonProcessingException { |
|---|
| | | |
|---|
| | | String handleUserId = vo.getHandleUserId(); |
|---|
| | | String msg = om.writeValueAsString(vo); |
|---|
| | | webSocketUserService.sendMessageToUser(handleUserId, msg); |
|---|
| | | Map<String, Object> msg = new HashMap<>(); |
|---|
| | | msg.put("type", "task"); |
|---|
| | | msg.put("data", vo); |
|---|
| | | webSocketUserService.sendMessageToUser(handleUserId, om.writeValueAsString(msg)); |
|---|
| | | return R.ok(); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
