From 234a2cef26c51478b9616882ee6f74e804c7f9fc Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 10 三月 2026 14:36:40 +0800
Subject: [PATCH] 合并代码
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java | 6 +++---
1 files changed, 3 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 0139579..f6cd82c 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
@@ -248,7 +248,7 @@
RtTaskListResponse response = msgContent.getRtTaskListResponse();
try {
log.info("云端下发订单操作的响应消息 (XPU→云端)：{}", jsonPrinter.print(response));
- Object sequence = redisTemplate.opsForValue().get("CREATE_ORDER:" + response.getResults().getOrderId());
+ Object sequence = redisService.getCacheObject("CREATE_ORDER:" + response.getResults().getOrderId());
if(sequence!=null){
JSONObject jsonObject = JSON.parseObject(sequence.toString());
String orderId = jsonObject.getString("orderId");
@@ -369,7 +369,7 @@
// 存储车辆挡位
GearLevel gearLevel = systemRuntimeStatus.getVehicleStatus().getDynamicStatus().getGearLevel();
int value = gearLevel.getNumber();
- redisTemplate.opsForValue().set(CacheConstants.GEAR_LEVEL + systemRuntimeStatus.getVehicleStatus().getStaticInfo().getXpuId(), value);
+ redisService.setCacheObject(CacheConstants.GEAR_LEVEL + systemRuntimeStatus.getVehicleStatus().getStaticInfo().getXpuId(), value);
// 判断是否为故障状态
if (abnormalReason == AbnormalReason.FAULT) {
log.info("车辆故障，开始处理故障");
@@ -736,7 +736,7 @@
snowFlake.withStartTimestamp(1420041600000L);
long sequence = snowFlake.nextId();
// 处理数据
- redisTemplate.opsForValue().set(sequence,"pushOrder_"+orderId+"_"+vin,30, TimeUnit.MINUTES);
+ redisService.setCacheObject(sequence + "","pushOrder_"+orderId+"_"+vin,30L, TimeUnit.MINUTES);
//开发发送请求到XPU
xpuUtil.cloudOrderOperation(orderOperationBuilder.build(), vin,sequence);
}
--
Gitblit v1.7.1