From d341f0b509ba534418d9970a1a3541334bee0eba Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 28 二月 2026 17:15:08 +0800
Subject: [PATCH] 修改排班统计查询bug
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 23 +++++++++++++----------
1 files changed, 13 insertions(+), 10 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 0c47a3f..a4ea4c0 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
@@ -27,15 +27,18 @@
import com.xiaopeng.api.vo.OrderType;
import com.xiaopeng.api.vo.SystemEventType;
import com.xiaopeng.api.vo.automaticPilot.VehiclePosition;
-import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudOrderOperation.ActionType;
-import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudOrderOperation.OrderOperationType;
-import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudOrderOperation.PointType;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.navigationDeviationEvent.NavigationDeviationEvent;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.navigationDeviationEvent.NavigationDeviationMessage;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.orderStateUpdateEvent.OrderStatusInfoEvent;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.systemStatusXpu.*;
-import com.xiaopeng.api.vo.automaticPilot.proto.up.xpuNavigationRequest.NavigationRequest;
import com.xiaopeng.api.vo.automaticPilot.protobuf.*;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.AbnormalReason;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.GearLevel;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.OrderPhase;import com.xiaopeng.api.vo.automaticPilot.protobuf.OrderStatusInfo;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.RealtimePose;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.ResponseMessage;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.RtTripInfo;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.StatusCode;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.VehicleDynamicStatus;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.VehicleStaticInfo;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.VehicleStatus;
+import com.xiaopeng.api.vo.automaticPilot.protobuf.Wgs;
import com.xiaopeng.api.vo.operation.RouteVo;
import com.xiaopeng.api.vo.vehicleConvoy.CancelTaxiPassengerVo;
import com.xiaopeng.automaticPilot.util.XPUUtil;
@@ -868,8 +871,8 @@
taskBuilder.setTaskId("MISSION_"+ IdUtil.fastUUID());
taskBuilder.setTaskType(com.xiaopeng.api.vo.automaticPilot.protobuf.OrderType.ORDER_TYPE_CRUISE);
- com.xiaopeng.api.vo.automaticPilot.protobuf.RtTask task = taskBuilder.build();
- com.xiaopeng.api.vo.automaticPilot.protobuf.RtTaskList taskList = com.xiaopeng.api.vo.automaticPilot.protobuf.RtTaskList.newBuilder().addTasks(task).build();
+ RtTask task = taskBuilder.build();
+ RtTaskList taskList = RtTaskList.newBuilder().addTasks(task).build();
SnowFlake snowFlake = new SnowFlake(0, 0);
--
Gitblit v1.7.1