小鹏汽车Robotaxi
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2026-04-24 f161eb229c5fb0f82c2dfd26c6440dbf84cba1ca 
 xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java


@@ -3,7 +3,7 @@


import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.ObjectMapper;


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;


@@ -13,6 +13,7 @@


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.*;




import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.Set;


@@ -366,11 +367,13 @@


     * 运维工单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();




    }