package com.doumee.core.track;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;

/**
 * 电车「车辆 → 活跃骑行订单」Redis 缓存,收口读写删,供开锁 / 还车 / 位置上报三处统一调用。
 * <p>用途:位置上报(JT/T 808,秒级高频)时,用 bikeCode O(1) 取活跃订单,
 * 替代每次查 member_rides,避免高频 DB 查询。
 * <p>生命周期:
 * <ul>
 *   <li>电车开锁成功(→ 骑行中):{@link #set} 写入,带 24h TTL</li>
 *   <li>电车还车成功(→ 已还车):{@link #remove} 删除(覆盖 backBike / autoBackBike / forceBack 多入口)</li>
 *   <li>临停(→ 临停中):不删,期间照常写轨迹</li>
 * </ul>
 * <p>TTL 仅为兜底:正常还车会主动删;防还车异常分支漏删导致映射泄漏 → 已还车的车继续被当活跃写脏轨迹。
 * <p>降级:本类方法不吞异常,由调用方 try-catch 降级(缓存是优化、非业务正确性来源,失败不得阻断主流程)。
 * <p>value 以 JSON 字符串存取(与抖音 token 缓存一致,避开 RedisTemplate 序列化器对 POJO 的依赖)。
 *
 * @author rk
 * @date 2026/06/25
 */
@Slf4j
@Component
public class RideActiveCache {

    /** Redis key 前缀:车辆维度活跃订单映射 */
    private static final String KEY_PREFIX = "ride:active:";

    /** 缓存 TTL(秒):24 小时,覆盖最长骑行;兜底防还车漏删导致映射泄漏 */
    private static final long TTL_SECONDS = 24L * 60L * 60L;

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /** 拼 Redis key:ride:active:{bikeCode} */
    private static String key(String bikeCode) {
        return KEY_PREFIX + bikeCode;
    }

    /**
     * 开锁成功时写入活跃订单映射(带 24h TTL)。
     *
     * @param bikeCode 车辆编码(缓存维度)
     * @param ridesId  骑行订单主键 member_rides.id
     * @param orderId  支付订单主键 member_rides.ordre_id → goodsorder.id(可 null)
     */
    public void set(String bikeCode, String ridesId, String orderId) {
        if (StringUtils.isBlank(bikeCode)) {
            return;
        }
        RideActiveInfo info = new RideActiveInfo();
        info.setRidesId(ridesId);
        info.setOrderId(orderId);
        redisTemplate.opsForValue().set(key(bikeCode), JSON.toJSONString(info), TTL_SECONDS, TimeUnit.SECONDS);
    }

    /**
     * 位置上报时读取活跃订单映射。
     *
     * @param bikeCode 车辆编码
     * @return 活跃订单载荷;无映射 / 非 String 值返回 null(调用方据此跳过轨迹写入)
     */
    public RideActiveInfo get(String bikeCode) {
        if (StringUtils.isBlank(bikeCode)) {
            return null;
        }
        Object cached = redisTemplate.opsForValue().get(key(bikeCode));
        if (cached instanceof String) {
            return JSON.parseObject((String) cached, RideActiveInfo.class);
        }
        return null;
    }

    /**
     * 还车成功时删除活跃订单映射。
     *
     * @param bikeCode 车辆编码
     */
    public void remove(String bikeCode) {
        if (StringUtils.isBlank(bikeCode)) {
            return;
        }
        redisTemplate.delete(key(bikeCode));
    }
}