From 92f584e91d0e6bb1c3b1004af6ba358198803431 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 13 二月 2026 20:37:41 +0800
Subject: [PATCH] refactor(KafkaConsumerService): 优化推单和取消订单处理逻辑
---
xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 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 2f6c56b..246c147 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
@@ -184,16 +184,20 @@
Object sequence = redisTemplate.opsForValue().get(requestSeq);
if(sequence!=null){
String[] split = sequence.toString().split("_");
-
+ String typeStr = split[0];
// 推单处理
- if(split[0].equals("pushOrder")){
+ if(typeStr.equals("pushOrder")){
PopOrderDto dto = new PopOrderDto();
dto.setOrderId(Long.valueOf(split[1]));
dto.setXpVehicleVin(split[2]);
xpOrderClient.popOrder(dto);
+ }else if(typeStr.equals("cancelOrder")){
+ xpOrderClient.cancelOrder(split[1]);
}
+
+
// 取消订单处理
}
}
--
Gitblit v1.7.1