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);
    }
}