From b6bc214b8ac163ecbe40da3c9b0664fbaa97ad32 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 13 二月 2026 14:53:15 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi
---
xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
index 1f46d8e..07fff2e 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
@@ -153,7 +153,15 @@
}
+ //消息应答
+ if(MessageType.MESSAGE_TYPE_RESPONSE == type){
+ com.xiaopeng.api.vo.automaticPilot.proto.up.ResponseMessage resposne = msgContent.getContent_detail().getObject("resposne", com.xiaopeng.api.vo.automaticPilot.proto.up.ResponseMessage.class);
+ com.xiaopeng.api.vo.automaticPilot.proto.up.StatusCode code = resposne.getCode();
+ Long requestSeq = resposne.getRequest_seq();
+ if(code == com.xiaopeng.api.vo.automaticPilot.proto.up.StatusCode.OK){
+ }
+ }
}
/**
--
Gitblit v1.7.1