package com.xiaopeng.automaticPilot.service.impl;

import com.xiaopeng.automaticPilot.dto.XpCommonResponse;
import com.xiaopeng.automaticPilot.dto.RobotaxiSmsCodeRequest;
import com.xiaopeng.automaticPilot.dto.RobotaxiSmsValidateRequest;
import com.xiaopeng.automaticPilot.service.VehicleRtInfoService;
import com.xiaopeng.api.dto.vehicleConvoy.UpdateVehicleStateDto;
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
import com.xiaopeng.common.core.utils.MsgUtil;
import com.xiaopeng.common.core.utils.StringUtils;
import com.xiaopeng.common.redis.service.RedisService;
import com.xiaopeng.automaticPilot.enums.RobotaxiErrorEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.TimeUnit;

@Slf4j
@Service
public class VehicleRtInfoServiceImpl implements VehicleRtInfoService {

    private static final long CODE_TTL_MINUTES = 5L;

    @Resource
    private RedisService redisService;

    @Resource
    private XpVehicleClient xpVehicleClient;

    @Value("#{'${robotaxi.sms.whitelist.mobiles:}'.split(',')}")
    private List<String> whitelistMobiles;

    @Override
    public XpCommonResponse<?> getRobotaxiSmsCode(RobotaxiSmsCodeRequest request) {
        XpCommonResponse<?> paramCheckError = validateSmsCodeRequest(request);
        if (paramCheckError != null) {
            return paramCheckError;
        }

        XpCommonResponse<?> vehicleCheckError = validateVehicleReadyIfNeeded(request.getSmsType(), request.getVin());
        if (vehicleCheckError != null) {
            return vehicleCheckError;
        }

        String code = MsgUtil.createCode();
        log.info("Robotaxi SMS code generated for mobile {}: {}", request.getMobile(), code);
        
        // TODO: Call SMS interface to send code when available
        // sendSms(request.getMobile(), code);

        String key = buildSmsCodeKey(request.getSmsType(), request.getVin(), request.getMobile());
        redisService.setCacheObject(key, code, CODE_TTL_MINUTES, TimeUnit.MINUTES);
        return XpCommonResponse.ok(Collections.emptyMap());
    }

    @Override
    public XpCommonResponse<?> validateRobotaxiSmsCode(RobotaxiSmsValidateRequest request) {
        XpCommonResponse<?> paramCheckError = validateSmsValidateRequest(request);
        if (paramCheckError != null) {
            return paramCheckError;
        }

        XpCommonResponse<?> vehicleCheckError = validateVehicleReadyIfNeeded(request.getSmsType(), request.getVin());
        if (vehicleCheckError != null) {
            return vehicleCheckError;
        }

        boolean isWhitelisted = whitelistMobiles != null && whitelistMobiles.contains(request.getMobile());
        
        String key = buildSmsCodeKey(request.getSmsType(), request.getVin(), request.getMobile());

        if (!isWhitelisted) {
            String cachedCode = redisService.getCacheObject(key);
            if (StringUtils.isEmpty(cachedCode)) {
                return XpCommonResponse.fail(RobotaxiErrorEnum.GENERAL_ERROR);
            }
            if (!cachedCode.equals(request.getCode())) {
                return XpCommonResponse.fail(RobotaxiErrorEnum.VERIFY_CODE_ERROR);
            }
            redisService.deleteObject(key);
        } else {
            redisService.deleteObject(key);
        }
        return XpCommonResponse.ok(Collections.emptyMap());
    }

    private XpCommonResponse<?> validateSmsCodeRequest(RobotaxiSmsCodeRequest request) {
        if (StringUtils.isAnyEmpty(request.getSmsType(), request.getVin(), request.getMobile())) {
            return XpCommonResponse.fail(RobotaxiErrorEnum.GENERAL_ERROR);
        }
        if (!isSupportedSmsType(request.getSmsType())) {
            return XpCommonResponse.fail(RobotaxiErrorEnum.GENERAL_ERROR);
        }
        return null;
    }

    private XpCommonResponse<?> validateSmsValidateRequest(RobotaxiSmsValidateRequest request) {
        if (StringUtils.isAnyEmpty(request.getSmsType(), request.getVin(), request.getMobile(), request.getCode())) {
            return XpCommonResponse.fail(RobotaxiErrorEnum.GENERAL_ERROR);
        }
        if (!isSupportedSmsType(request.getSmsType())) {
            return XpCommonResponse.fail(RobotaxiErrorEnum.GENERAL_ERROR);
        }
        return null;
    }

    private boolean isSupportedSmsType(String smsType) {
        return SmsType.ACCEPT_RIDES.name().equals(smsType) || SmsType.STOP_ACCEPT_RIDES.name().equals(smsType);
    }

    private XpCommonResponse<?> validateVehicleReadyIfNeeded(String smsType, String vin) {
        if (!SmsType.ACCEPT_RIDES.name().equals(smsType)) {
            return null;
        }
//        XpVehicle vehicle = xpVehicleClient.findByVehicleVin(vin).getData();
//        if (vehicle == null) {
//            return XpCommonResponse.fail(RobotaxiErrorEnum.MOBILE_VIN_MISMATCH);
//        }
//        Integer status = vehicle.getStatus();
//        Integer operatingStatus = vehicle.getOperatingStatus();
//        if (status == null || status != 2 || operatingStatus == null || operatingStatus != 1) {
//            return XpCommonResponse.fail(RobotaxiErrorEnum.VEHICLE_NOT_READY);
//        }

        return null;
    }

    private String buildSmsCodeKey(String smsType, String vin, String mobile) {
        return "ROBOTAXI_SMS_CODE:" + smsType + ":" + vin + ":" + mobile;
    }
}