SET logscraping:mediaAdId [id1, id2, id3, ...]

HASH logscraping:mediaAdId
    id1 -> { "name": "廣告位1", "status": "active" }
    id2 -> { "name": "廣告位2", "status": "inactive" }

@Component
@Slf4j
@RequiredArgsConstructor
public class LogMediaAdIdCache {
    private final RedisTemplate<String, String> redisTemplate;
    private volatile Set<Long> cachedLogMediaAdIds = Collections.emptySet();
    public static final String LOG_REDIS_KEY = "logscraping:mediaAdId";

    @PostConstruct
    public void init() {
        refreshCache();
    }

    @Scheduled(fixedRate = 5 * 1000) // 每5秒刷新一次
    public void refreshCache() {
        try {
            Map<Object, Object> idMap = redisTemplate.opsForHash().entries(LOG_REDIS_KEY);
            if (idMap != null) {
                Set<Long> newCache = idMap.keySet().stream()
                        .map(key -> Long.valueOf(key.toString()))
                        .collect(Collectors.toSet());
                this.cachedLogMediaAdIds = newCache;
                log.info("廣告位ID緩存刷新成功，數(shù)量: {}", newCache.size());
            }
        } catch (Exception e) {
            log.error("刷新廣告位ID緩存失敗", e);
        }
    }

    public Set<Long> getLogMediaAdIds() {
        return Collections.unmodifiableSet(cachedLogMediaAdIds);
    }

    public boolean contains(Long mediaAdId) {
        return cachedLogMediaAdIds.contains(mediaAdId);
    }

    // 新增方法：獲取廣告位詳情
    public String getAdInfo(Long mediaAdId) {
        return redisTemplate.<String, String>opsForHash().get(LOG_REDIS_KEY, mediaAdId.toString());
    }

    // 新增方法：更新廣告位信息
    public void updateAdInfo(Long mediaAdId, String info) {
        redisTemplate.opsForHash().put(LOG_REDIS_KEY, mediaAdId.toString(), info);
        refreshCache(); // 立即刷新緩存
    }
}

@Component
@Slf4j
@RequiredArgsConstructor
public class LogStatsMonitorJob {
    private final RedisTemplate<String, String> redisTemplate;
    private static final String LOG_STATS_KEY = "log:stats:1635474646";

    @Scheduled(fixedRate = 10 * 1000) // 每10秒執(zhí)行一次
    public void monitorLogStats() {
        String currentTimeKey = getFormattedTime();
        String fullKey = LOG_STATS_KEY + ":" + currentTimeKey;

        try {
            Map<Object, Object> stats = redisTemplate.opsForHash().entries(fullKey);
            if (stats == null || stats.isEmpty()) {
                log.warn("未找到統(tǒng)計(jì)信息: {}", fullKey);
                return;
            }

            log.info("----- 統(tǒng)計(jì)信息監(jiān)控（Key: {}）-----", fullKey);
            stats.forEach((field, value) -> 
                log.info("{}: {}", field, value));

            // 業(yè)務(wù)處理示例
            int total = Integer.parseInt(stats.getOrDefault("total", "0").toString());
            if (total > 1000) {
                log.warn("警告：數(shù)據(jù)量過大（{}條）", total);
            }
        } catch (Exception e) {
            log.error("監(jiān)控統(tǒng)計(jì)信息失敗", e);
        }
    }

    private String getFormattedTime() {
        // 生成格式化的時(shí)間戳，如 20250609175050
        return LocalDateTime.now()
                .format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));
    }
}

@Configuration
@EnableScheduling
public class SchedulingConfig {
    // 啟用定時(shí)任務(wù)
}