package com.ard.work.device.camera.service;

import com.ard.work.device.camera.domain.PtzParamDTO;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;

/**
 * ptz缓存管理器
 *
 * @author 刘苏义
 * @date 2026-03-20
 */

@Component
public class PtzCacheManager {
    // Key: cameraId_chanNo (例如 "CAM001_1"), Value: 最新的 PTZ 数据对象
    // 使用 ConcurrentHashMap 保证多线程安全
    private final ConcurrentHashMap<String, PtzParamDTO> ptzDataMap = new ConcurrentHashMap<>();
    
    // 记录最后更新时间，用于判断数据是否过期
    private final ConcurrentHashMap<String, Long> updateTimeMap = new ConcurrentHashMap<>();

    public void updatePtzData(String key, PtzParamDTO data) {
        ptzDataMap.put(key, data);
        updateTimeMap.put(key, System.currentTimeMillis());
    }

    public PtzParamDTO getPtzData(String key) {
        return ptzDataMap.get(key);
    }
    
    // 获取所有有效数据快照
    public List<PtzParamDTO> getAllValidData(long timeoutMs) {
        long now = System.currentTimeMillis();
        return ptzDataMap.entrySet().stream()
            .filter(entry -> (now - updateTimeMap.get(entry.getKey())) < timeoutMs)
            .map(Map.Entry::getValue)
            .collect(Collectors.toList());
    }
    
    public void removeData(String key) {
        ptzDataMap.remove(key);
        updateTimeMap.remove(key);
    }
}