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