From e1df35dffc9f10e0691d3b9a9237e71fe1fa8b89 Mon Sep 17 00:00:00 2001
From: zhuml4 <zhuml4@xiaopeng.com>
Date: 星期六, 07 三月 2026 21:01:24 +0800
Subject: [PATCH] fix:xpu topic
---
xp-robotaxi-automatic-pilot-boot/src/test/java/com/xiaopeng/automaticPilot/util/XPUUtilTest.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/test/java/com/xiaopeng/automaticPilot/util/XPUUtilTest.java b/xp-robotaxi-automatic-pilot-boot/src/test/java/com/xiaopeng/automaticPilot/util/XPUUtilTest.java
index 72b2034..3a08808 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/test/java/com/xiaopeng/automaticPilot/util/XPUUtilTest.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/test/java/com/xiaopeng/automaticPilot/util/XPUUtilTest.java
@@ -29,7 +29,7 @@
// Mock VmpOpenServiceClient
vmpClient = Mockito.mock(VmpOpenServiceClient.class);
Map<String, String> mapping = new HashMap<>();
- mapping.put(XPUUtil.XPU_ID_TYPE, "1234567890ABCDEFGHIJKL");
+ mapping.put(XPUUtil.XPU_ID_TYPE, "c47b405bee79000f282a36e800000000");
Mockito.when(vmpClient.getVehicleBindInfoByVin(Mockito.anyString(), Mockito.anyList()))
.thenReturn(mapping);
@@ -57,7 +57,7 @@
Method buildTopic = XPUUtil.class.getDeclaredMethod("buildTopicByVin", String.class);
buildTopic.setAccessible(true);
String result = (String) buildTopic.invoke(xpuUtil, "VIN123");
- Assertions.assertEquals("Robotaxi/Msg/Xpu/ABCDEFGHIJKL00000000", result);
+ Assertions.assertEquals("Robotaxi/Msg/Xpu/c47b405bee79000f282a36e800000000", result);
}
@Test
@@ -94,7 +94,7 @@
Mockito.verify(xpuClient).publish(captor.capture());
MqttPublishVo capturedVo = captor.getValue();
- Assertions.assertEquals("Robotaxi/Msg/Xpu/ABCDEFGHIJKL00000000", capturedVo.getTopic());
+ Assertions.assertEquals("Robotaxi/Msg/Xpu/c47b405bee79000f282a36e800000000", capturedVo.getTopic());
// Note: Current implementation serializes enum as ordinal.
Assertions.assertTrue(capturedVo.getPayload().contains("\"cmd\": 10003"), "Payload should contain cmd CLOUD_CREATE_ORDER (10003), but was: " + capturedVo.getPayload());
}
@@ -141,7 +141,7 @@
Mockito.verify(xpuClient).publish(captor.capture());
MqttPublishVo capturedVo = captor.getValue();
- Assertions.assertEquals("Robotaxi/Msg/Xpu/ABCDEFGHIJKL00000000", capturedVo.getTopic());
+ Assertions.assertEquals("Robotaxi/Msg/Xpu/c47b405bee79000f282a36e800000000", capturedVo.getTopic());
// Note: CLOUD_ORDER_OPERATION is 10001
Assertions.assertTrue(capturedVo.getPayload().contains("\"cmd\": 10001"), "Payload should contain cmd CLOUD_ORDER_OPERATION (10001), but was: " + capturedVo.getPayload());
}
@@ -161,7 +161,7 @@
Mockito.verify(xpuClient).publish(captor.capture());
MqttPublishVo capturedVo = captor.getValue();
- Assertions.assertEquals("Robotaxi/Msg/Xpu/ABCDEFGHIJKL00000000", capturedVo.getTopic());
+ Assertions.assertEquals("Robotaxi/Msg/Xpu/c47b405bee79000f282a36e800000000", capturedVo.getTopic());
// Note: CLOUD_TASK_CONTROL (used in responseMessage method? check code)
// In XPUUtil.java: headerBuilder.setCmd(RTCmdType.CLOUD_TASK_CONTROL.getValue());
// CLOUD_TASK_CONTROL is 10002
@@ -178,7 +178,7 @@
navigationDataBuilder.setContent(content);
navigationDataBuilder.setTimestamp(System.currentTimeMillis());
- String xpuId = "1234567890ABCDEFGHIJKL";
+ String xpuId = "c47b405bee79000f282a36e800000000";
Long sequence = 3L;
xpuUtil.cloudPushNavigation(navigationDataBuilder.build(), xpuId, sequence);
@@ -187,7 +187,7 @@
Mockito.verify(xpuClient).publish(captor.capture());
MqttPublishVo capturedVo = captor.getValue();
- Assertions.assertEquals("Robotaxi/Msg/Xpu/ABCDEFGHIJKL00000000", capturedVo.getTopic());
+ Assertions.assertEquals("Robotaxi/Msg/Xpu/c47b405bee79000f282a36e800000000", capturedVo.getTopic());
// Note: CLOUD_NAVIGATION_RESPONSE is 10006
Assertions.assertTrue(capturedVo.getPayload().contains("\"cmd\": 10006"), "Payload should contain cmd CLOUD_NAVIGATION_RESPONSE (10006), but was: " + capturedVo.getPayload());
}
--
Gitblit v1.7.1