zhouhn
2026-02-23 4fe4a4616b3c762eafabe238acf40fac30fd25a3
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java
@@ -56,6 +56,7 @@
     * @param task
     * @return
     */
    //TODO 没有处理feign调用的异常
    public MqttPublishDto cloudCreateOrder(RTTask task, String vin, Long sequence) {
        MsgContent msgContent = new MsgContent();
        // 消息头
@@ -75,6 +76,7 @@
        String xpuId = getXpuIdByVin(vin);
        //组装请求消息体
        MqttPublishVo vo = new MqttPublishVo();
        //TODO 这里的topic组装有问题
        vo.setTopic(topic + "/" + xpuId);
        vo.setPayload(JSON.toJSONString(msgContent));
        return xpuClient.publish(vo);
@@ -88,6 +90,7 @@
     * @param operation
     * @return
     */
    //TODO 没有处理feign调用的异常
    public MqttPublishDto cloudOrderOperation(OrderOperation operation, String vin,Long  sequence) {
        MsgContent msgContent = new MsgContent();
        // 消息头