From 5f7a82bca016b27f8e05d2892ca7b64b0d7d9797 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期四, 26 三月 2026 18:13:06 +0800
Subject: [PATCH] 修改bug
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
index 6e192e5..c4f8ba8 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
@@ -376,8 +376,8 @@
.set("addTime", System.currentTimeMillis()));
mongoTemplate.updateFirst(new Query(Criteria.where("vin").is(vin)), update, VehiclePosition.class);
}
- //调用推送服务接口
- if (null != orderId && !order_id.contains("XU") && !order_id.contains("TEST")) {
+ //调用推送服务接口，给乘客推送剩余轨迹和里程时长
+ if (null != orderId && !order_id.contains("XU")) {
RtTripInfo rtTripInfo = systemRuntimeStatus.getRtTripInfo();
PushOrderRouteDTO dto = new PushOrderRouteDTO();
dto.setOrderId(orderId);
@@ -388,7 +388,10 @@
// dto.setDuration(rtTripInfo.getRemaining_time());
// dto.setDistance(rtTripInfo.getRemaining_distance().intValue());
// dto.setDirection();
- xpPushMessageClient.pushOrderRoute(dto);
+ //只有乘客订单需要推送剩余导航数据
+ if(!order_id.contains("TEST")){
+ xpPushMessageClient.pushOrderRoute(dto);
+ }
//存储历史轨迹
OrderTrajectoryVo orderTrajectory = new OrderTrajectoryVo();
--
Gitblit v1.7.1