package com.xiaopeng.automaticPilot.controller;
|
|
import com.xiaopeng.api.feignClient.map.XpMapClient;
|
import com.xiaopeng.api.feignClient.operation.ReassignOrderClient;
|
import com.xiaopeng.api.feignClient.operation.XpCruisePlanClient;
|
import com.xiaopeng.api.feignClient.order.XpCruiseOrderClient;
|
import com.xiaopeng.api.feignClient.order.XpOrderClient;
|
import com.xiaopeng.api.feignClient.pushMessage.XpPushMessageClient;
|
import com.xiaopeng.api.feignClient.vehicleConvoy.UserVehicleClient;
|
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
|
import com.xiaopeng.api.model.order.XpOrder;
|
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
|
import com.xiaopeng.api.vo.automaticPilot.VehiclePosition;
|
import com.xiaopeng.api.vo.operation.RouteVo;
|
import com.xiaopeng.automaticPilot.service.KafkaConsumerService;
|
import com.xiaopeng.automaticPilot.util.XPUUtil;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.redis.service.RedisService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.junit.jupiter.api.BeforeEach;
|
import org.junit.jupiter.api.DisplayName;
|
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.extension.ExtendWith;
|
import org.mockito.InjectMocks;
|
import org.mockito.Mock;
|
import org.mockito.Spy;
|
import org.mockito.junit.jupiter.MockitoExtension;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.geo.GeoJsonPoint;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.data.redis.core.GeoOperations;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.data.redis.core.ValueOperations;
|
import org.springframework.test.util.ReflectionTestUtils;
|
|
import java.io.IOException;
|
import java.nio.charset.StandardCharsets;
|
import java.nio.file.Files;
|
import java.nio.file.Paths;
|
|
import static org.mockito.Mockito.*;
|
|
/**
|
* KafkaTestController 单元测试
|
*/
|
@Slf4j
|
@DisplayName("Kafka测试控制器单元测试")
|
@ExtendWith(MockitoExtension.class)
|
public class KafkaTestControllerTest {
|
|
@Mock
|
private XpVehicleClient xpVehicleClient;
|
|
@Mock
|
private XpMapClient xpMapClient;
|
|
@Mock
|
private XpOrderClient xpOrderClient;
|
|
@Mock
|
private MongoTemplate mongoTemplate;
|
|
@Mock
|
private XPUUtil xpuUtil;
|
|
@Mock
|
private RedisTemplate redisTemplate;
|
|
@Mock
|
private XpPushMessageClient xpPushMessageClient;
|
|
@Mock
|
private ReassignOrderClient reassignOrderClient;
|
|
@Mock
|
private UserVehicleClient userVehicleClient;
|
|
@Mock
|
private XpCruiseOrderClient xpCruiseOrderClient;
|
|
@Mock
|
private RedisService redisService;
|
|
@Mock
|
private XpCruisePlanClient xpCruisePlanClient;
|
|
@Mock
|
private ValueOperations valueOperations;
|
|
@Mock
|
private GeoOperations geoOperations;
|
|
@InjectMocks
|
private KafkaConsumerService kafkaConsumerService;
|
|
@Spy
|
@InjectMocks
|
private KafkaTestController kafkaTestController;
|
|
@Mock
|
private R<XpVehicle> mockResponseResult;
|
|
@Mock
|
private R<XpOrder> mockOrderResponseResult;
|
|
// 模拟的XpVehicle对象
|
private XpVehicle mockXpVehicle;
|
|
@BeforeEach
|
public void setUp() {
|
// 将包含所有 mock 依赖的 kafkaConsumerService 注入到 kafkaTestController
|
ReflectionTestUtils.setField(kafkaTestController, "kafkaConsumerService", kafkaConsumerService);
|
}
|
|
/**
|
* 从本地文件读取JSON内容
|
*
|
* @param filePath 文件路径
|
* @return JSON字符串
|
* @throws IOException 如果文件读取失败
|
*/
|
private String readJsonFile(String filePath) throws IOException {
|
return new String(Files.readAllBytes(Paths.get(filePath)), StandardCharsets.UTF_8);
|
}
|
|
@Test
|
@DisplayName("测试XPU发生系统运行状态")
|
public void testXpuSendSystemRuntimeStatus() throws IOException {
|
// 从本地文件读取测试数据
|
String testMessage = readJsonFile("src/test/resources/jsondemo/common/system_runtime_status.json");
|
|
mockXpVehicle = new XpVehicle();
|
mockXpVehicle.setXpuId("xpu-001");
|
mockXpVehicle.setVehicleVin("test-vin");
|
|
when(mockResponseResult.getData()).thenReturn(mockXpVehicle);
|
when(xpVehicleClient.findByVehicleXpuId(anyString())).thenReturn(mockResponseResult);
|
|
// mock redisTemplate 的 geo 和 value 操作，避免空指针
|
when(redisTemplate.opsForGeo()).thenReturn(geoOperations);
|
when(redisTemplate.opsForValue()).thenReturn(valueOperations);
|
|
// 执行测试
|
kafkaTestController.topicProdRobotaxiXpuHigh(testMessage);
|
}
|
|
@Test
|
@DisplayName("测试XPU发送导航请求")
|
public void testXPUSendNavigationRequest() throws IOException {
|
// 从本地文件读取测试数据
|
String testMessage = readJsonFile("src/test/resources/jsondemo/cloud/navigation_requset.json");
|
|
XpOrder mockOrder = new XpOrder();
|
mockOrder.setId(1881347710714060802L);
|
mockOrder.setVehicleId(1L);
|
when(mockOrderResponseResult.getCode()).thenReturn(200);
|
when(mockOrderResponseResult.getData()).thenReturn(mockOrder);
|
when(xpOrderClient.queryOrderById(anyLong())).thenReturn(mockOrderResponseResult);
|
|
mockXpVehicle = new XpVehicle();
|
mockXpVehicle.setXpuId("xpu-001");
|
mockXpVehicle.setVehicleVin("test-vin");
|
|
when(mockResponseResult.getData()).thenReturn(mockXpVehicle);
|
when(xpVehicleClient.queryById(anyLong())).thenReturn(mockResponseResult);
|
|
// mock mongoTemplate.findOne 返回 VehiclePosition，避免 "车辆位置信息不存在" 异常
|
VehiclePosition mockVehiclePosition = new VehiclePosition();
|
mockVehiclePosition.setVin("test-vin");
|
mockVehiclePosition.setPoint(new GeoJsonPoint(113.3245, 23.1235));
|
when(mongoTemplate.findOne(any(Query.class), eq(VehiclePosition.class))).thenReturn(mockVehiclePosition);
|
|
RouteVo mockRouteVo = new RouteVo();
|
mockRouteVo.setRouteID("test-route-id");
|
when(xpMapClient.getOrderDistanceAndDuration(any())).thenReturn(R.ok(mockRouteVo));
|
|
when(xpMapClient.queryRouted(any())).thenReturn(R.ok("test-routed-data"));
|
|
when(redisTemplate.opsForValue()).thenReturn(valueOperations);
|
// 执行测试
|
kafkaTestController.topicProdRobotaxiXpuHigh(testMessage);
|
}
|
|
@Test
|
@DisplayName("测试XPU发送订单状态请求")
|
public void testXPUSendOrderStatusRequest() throws IOException {
|
// 从本地文件读取测试数据
|
String testMessage = readJsonFile("src/test/resources/jsondemo/cloud/order_status_info_event.json");
|
// 执行测试
|
kafkaTestController.topicProdRobotaxiXpuHigh(testMessage);
|
}
|
|
//当前没有处理
|
@Test
|
@DisplayName("测试XPU发送导航信息更新")
|
public void testXPUSendNavigationInfoUpdate() throws IOException {
|
// 从本地文件读取测试数据
|
String testMessage = readJsonFile("src/test/resources/jsondemo/cloud/navigation_info_update_event.json");
|
// 执行测试
|
kafkaTestController.topicProdRobotaxiXpuHigh(testMessage);
|
}
|
|
@Test
|
@DisplayName("测试XPU发送偏航信息")
|
public void testXPUSendNavigationDeviationEvent() throws IOException {
|
// 从本地文件读取测试数据
|
String testMessage = readJsonFile("src/test/resources/jsondemo/cloud/navi_deviation_event.json");
|
|
XpOrder mockOrder = new XpOrder();
|
mockOrder.setId(1881347710714060802L);
|
mockOrder.setStatus(3);
|
mockOrder.setVehicleId(1L);
|
when(mockOrderResponseResult.getCode()).thenReturn(200);
|
when(mockOrderResponseResult.getData()).thenReturn(mockOrder);
|
when(xpOrderClient.queryOrderById(anyLong())).thenReturn(mockOrderResponseResult);
|
|
mockXpVehicle = new XpVehicle();
|
mockXpVehicle.setXpuId("xpu-001");
|
mockXpVehicle.setVehicleVin("test-vin");
|
|
when(mockResponseResult.getData()).thenReturn(mockXpVehicle);
|
when(xpVehicleClient.queryById(anyLong())).thenReturn(mockResponseResult);
|
|
RouteVo mockRouteVo = new RouteVo();
|
mockRouteVo.setRouteID("test-route-id");
|
when(xpMapClient.getOrderDistanceAndDuration(any())).thenReturn(R.ok(mockRouteVo));
|
|
when(xpMapClient.queryRouted(any())).thenReturn(R.ok("test-routed-data"));
|
|
when(redisTemplate.opsForValue()).thenReturn(valueOperations);
|
// 执行测试
|
kafkaTestController.topicProdRobotaxiXpuHigh(testMessage);
|
}
|
}
|
