From 50cc796344bfce02e9281c5f19669248d0f790f9 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 17 四月 2026 16:45:59 +0800
Subject: [PATCH] Merge branch '1.0' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi into 1.0
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 128 +++++++++++++++++++++---------------------
1 files changed, 64 insertions(+), 64 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
index 444fe66..88a2f71 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
@@ -1,64 +1,64 @@
-package com.xiaopeng.automaticPilot.controller;
-
-import com.alibaba.fastjson2.JSONObject;
-import com.xiaopeng.api.vo.automaticPilot.MqttPublishVo;
-import com.xiaopeng.automaticPilot.service.KafkaConsumerService;
-import com.xiaopeng.common.core.domain.R;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@Slf4j
-@RestController
-public class KafkaTestController {
-
- @Autowired
- private KafkaConsumerService kafkaConsumerService;
-
- //TODO 少了factory属性声明
-
- /**
- * 消费消息 - XPU上报Robotaxi云端的消息topic（高优先级）
- *
- * @param message 消息内容
- */
- @PostMapping("/test/kafka/xpu-high")
- @KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
- public void topicProdRobotaxiXpuHigh(@RequestBody String message) {
- log.info("收到XPU上报高优先级主题消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
- }
-
- //TODO 少了factory属性声明
-
- /**
- * 消费消息 - XPU上报Robotaxi云端的消息topic（低优先级）
- *
- * @param message 消息内容
- */
- @PostMapping("/test/kafka/xpu-normal")
- @KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
- public void topicProdRobotaxiXpuNormal(String message) {
- log.info("收到XPU上报低优先级主题消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
- }
-
- /**
- * 模拟推送XPU消息
- * @param message
- * @return
- */
- @PostMapping("/base/v1/pushXPUMessage")
- public R pushXPUMessage(@RequestBody String message) {
- log.info("收到XPU推送消息: {}", message);
- JSONObject json = new JSONObject();
- json.put("ts", System.currentTimeMillis());
- json.put("payload", message);
- kafkaConsumerService.topicProdRobotaxiXpuHigh(json.toJSONString());
- return R.ok();
- }
-}
+//package com.xiaopeng.automaticPilot.controller;
+//
+//import com.alibaba.fastjson2.JSONObject;
+//import com.xiaopeng.api.vo.automaticPilot.MqttPublishVo;
+//import com.xiaopeng.automaticPilot.service.KafkaConsumerService;
+//import com.xiaopeng.common.core.domain.R;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.kafka.annotation.KafkaListener;
+//import org.springframework.web.bind.annotation.PostMapping;
+//import org.springframework.web.bind.annotation.PostMapping;
+//import org.springframework.web.bind.annotation.RequestBody;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//@Slf4j
+//@RestController
+//public class KafkaTestController {
+//
+// @Autowired
+// private KafkaConsumerService kafkaConsumerService;
+//
+// //TODO 少了factory属性声明
+//
+// /**
+// * 消费消息 - XPU上报Robotaxi云端的消息topic（高优先级）
+// *
+// * @param message 消息内容
+// */
+// @PostMapping("/test/kafka/xpu-high")
+// @KafkaListener(topics = "topic-prod-robotaxi-xpu-high", groupId = "group-robotaxi-xpu")
+// public void topicProdRobotaxiXpuHigh(@RequestBody String message) {
+// log.info("收到XPU上报高优先级主题消息: {}", message);
+// kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
+// }
+//
+// //TODO 少了factory属性声明
+//
+// /**
+// * 消费消息 - XPU上报Robotaxi云端的消息topic（低优先级）
+// *
+// * @param message 消息内容
+// */
+// @PostMapping("/test/kafka/xpu-normal")
+// @KafkaListener(topics = "topic-prod-robotaxi-xpu-normal", groupId = "group-robotaxi-xpu")
+// public void topicProdRobotaxiXpuNormal(String message) {
+// log.info("收到XPU上报低优先级主题消息: {}", message);
+// kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
+// }
+//
+// /**
+// * 模拟推送XPU消息
+// * @param message
+// * @return
+// */
+// @PostMapping("/base/v1/pushXPUMessage")
+// public R pushXPUMessage(@RequestBody String message) {
+// log.info("收到XPU推送消息: {}", message);
+// JSONObject json = new JSONObject();
+// json.put("ts", System.currentTimeMillis());
+// json.put("payload", message);
+// kafkaConsumerService.topicProdRobotaxiXpuHigh(json.toJSONString());
+// return R.ok();
+// }
+//}
--
Gitblit v1.7.1