package com.xiaopeng.vehicleConvoy.util;


import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson2.JSON;
import com.xiaopeng.api.dto.vehicleConvoy.BaseImOpenDto;
import com.xiaopeng.api.dto.vehicleConvoy.ImOpenQueryStateDto;
import com.xiaopeng.api.dto.vehicleConvoy.VehicleTemperatureDto;
import com.xiaopeng.api.feignClient.vehicleConvoy.VehicleControlClient;
import com.xiaopeng.api.vo.vehicleConvoy.VehicleStateVo;
import com.xiaopeng.api.vo.vehicleConvoy.VehiclesCommandVo;
import com.xiaopeng.vehicleConvoy.service.AsyncVehicleStateService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CompletableFuture;

/**
 * 车辆控制工具类
 */
@Slf4j
@Component
public class VehicleControlUtil {

    public static final String OPEN_ID_ROBOT_TAXI = "robot_taxi";
    @Resource
    private VehicleControlClient vehicleControlClient;
    @Resource
    private AsyncVehicleStateService asyncVehicleStateService;
    // 车辆控制接口appid
    @Value("${vehicle.control.appId}")
    private String appid;
    // 车辆控制接口appSecret
    @Value("${vehicle.control.appSecret}")
    private String appSecret;


    /**
     * 查询车辆内温度
     *
     * @param uid 用户id
     * @param vin 车辆vin
     *            测试车辆：L1NNSGHA5PB000204
     * @return 车辆温度信息
     */
    public VehicleTemperatureDto queryVehicleTemperature(String uid, String vin) {
        String nonce = System.currentTimeMillis() + "";
        Set<String> stateList = new HashSet<>();
        stateList.add("hvacInnerTemp");
        stateList.add("trunkAjarCloseSt");
        Map<String, String> map = new HashMap<>();
        map.put("nonce", nonce);
        map.put("openId", OPEN_ID_ROBOT_TAXI);
        map.put("accessToken", "");
        map.put("body", "");
        map.put("vin", vin);
        map.put("stateList", StrUtil.join(",", stateList));
        String sign = SignatureUtils.getSignatureSHA1(appid, map, appSecret);
        log.info("查询车内温度 请求参数：uid={}, vin={}", uid, vin);
        ImOpenQueryStateDto baseImOpenDto = vehicleControlClient.queryVehicleTemperature(appid, nonce, "", sign, OPEN_ID_ROBOT_TAXI, vin, stateList, uid);
        log.info("查询车内温度 结果：{}", JSON.toJSONString(baseImOpenDto));
        if (null == baseImOpenDto || null == baseImOpenDto.getData()) {
            throw new RuntimeException("查询车内温度失败");
        }
        if (0 != baseImOpenDto.getCode()) {
            throw new RuntimeException("查询车内温度失败：" + baseImOpenDto.getMsg());
        }
        VehicleTemperatureDto vehicleTemperatureDto = baseImOpenDto.getData();
        vehicleTemperatureDto.setVin(vin);
        return vehicleTemperatureDto;
    }

    /**
     * 同步查询车辆后备箱状态
     * 下发一次指令，等待回调结果（1秒超时）
     *
     * @param uid 用户ID
     * @param vin 车辆VIN码
     * @return 查询后备箱开关状态（打开状态=true，关闭状态=false）
     * @throws RuntimeException 查询失败或1秒超时
     */
    public Boolean queryTrunkDoorStateSync(Long uid, String vin, boolean reportEnable) {
        log.info("开始同步查询车辆后备箱状态: uid={}, vin={} (1秒超时)", uid, vin);
        if (!reportEnable) {
            VehicleTemperatureDto vehicleTemperatureDto = queryVehicleTemperature(String.valueOf(uid), vin);
            VehicleStateVo vehicleStateVo = vehicleTemperatureDto.getStateMap().get("trunkAjarCloseSt");
            return null != vehicleStateVo && vehicleStateVo.getValue().equals("1");
        }
        try {
            // 使用异步服务查询状态，内部有1秒超时处理
            CompletableFuture<VehicleTemperatureDto> future = asyncVehicleStateService
                    .queryVehicleStateAsync(String.valueOf(uid), vin);

            // 等待回调结果，由AsyncVehicleStateService内部处理超时
            VehicleTemperatureDto result = future.get();

            if (result == null) {
                throw new RuntimeException("查询车辆状态失败: 未获取到状态数据");
            }

            log.info("同步查询车辆后备箱状态成功: uid={}, vin={}", uid, vin);
            VehicleStateVo vehicleStateVo = result.getStateMap().get("trunkAjarCloseSt");
            log.info("同步查询车辆后备箱状态成功: uid={}, vin={}, vehicleStateVo={}", uid, vin, JSON.toJSONString(vehicleStateVo));
            return null != vehicleStateVo && vehicleStateVo.getValue().equals("5");

        } catch (java.util.concurrent.ExecutionException e) {
            Throwable cause = e.getCause();
            if (cause instanceof RuntimeException && cause.getMessage().contains("查询超时")) {
                log.error("查询车辆后备箱状态超时: uid={}, vin={} (1秒超时)", uid, vin);
                throw new RuntimeException("查询车辆状态超时，请稍后重试");
            } else {
                log.error("同步查询车辆后备箱状态失败: uid={}, vin={}", uid, vin, cause);
                throw new RuntimeException("查询车辆状态失败: " + (cause != null ? cause.getMessage() : e.getMessage()));
            }
        } catch (Exception e) {
            log.error("同步查询车辆后备箱状态失败: uid={}, vin={}", uid, vin, e);
            throw new RuntimeException("查询车辆状态失败: " + e.getMessage());
        }
    }


    /**
     * 车辆控制操作
     * <p>
     * 注意：签名计算由 VehicleControlSignatureInterceptor 拦截器处理
     * 拦截器会在 Feign 序列化 body 后，使用真实的 body 重新计算签名
     *
     * @param commandVo 车辆控制命令参数
     * @return msgId 消息id，对比消息回调通知
     * 测试车辆：L1NNSGHA5PB000204
     */
    public String vehiclesCommand(VehiclesCommandVo commandVo, Long uid) {
        String nonce = System.currentTimeMillis() + "";
        BaseImOpenDto baseImOpenDto = vehicleControlClient.vehiclesCommand(
                appid,
                nonce,
                "",
                "",
                OPEN_ID_ROBOT_TAXI,
                commandVo,
                uid
        );

        if (null == baseImOpenDto || null == baseImOpenDto.getData()) {
            throw new RuntimeException("车辆控制失败");
        }
        if (0 != baseImOpenDto.getCode()) {
            throw new RuntimeException("车辆控制失败：" + baseImOpenDto.getMsg());
        }
        return baseImOpenDto.getData().getMsgId();
    }
}