package cn.iocoder.yudao.module.hrm.dal.redis;

import jakarta.annotation.Resource;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Repository;

import java.time.Duration;
import java.time.LocalDate;

/**
 * HRM 证书/合同到期提醒 Redis DAO
 *
 * <p>用于到期站内信的去重（同一业务同一到期日只提醒一次）与当天扫描门闩（避免多实例/多次并发重复扫描），
 * 思路参照 MES 计量器具到期提醒。
 *
 * @author 超级管理员
 */
@Repository
public class HrmExpiryRemindRedisDAO {

    /**
     * 提醒去重 KEY 的过期时间（60 天）：同一业务记录同一到期日 60 天内只提醒一次
     */
    private static final Duration REMIND_TIMEOUT = Duration.ofDays(60);
    /**
     * 扫描门闩的过期时间（30 分钟）：避免多实例/多次并发重复扫描
     */
    private static final Duration SCAN_LOCK_TIMEOUT = Duration.ofMinutes(30);

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    /**
     * 尝试标记已提醒（同一业务记录同一到期日 60 天内只提醒一次）
     *
     * @param biz 业务标识（如 cert=证书资质、contract=员工合同）
     * @param bizId 业务记录编号
     * @param expireDate 到期日
     * @return true 表示首次标记成功，需要发送提醒
     */
    public boolean tryMarkReminded(String biz, Long bizId, LocalDate expireDate) {
        String key = HrmRedisKeyConstants.EXPIRE_REMIND + biz + ":" + bizId + ":" + expireDate;
        return Boolean.TRUE.equals(stringRedisTemplate.opsForValue().setIfAbsent(key, "1", REMIND_TIMEOUT));
    }

    /**
     * 尝试获取当天的扫描门闩，避免多实例并发重复扫描
     *
     * @param biz 业务标识（如 cert=证书资质、contract=员工合同）
     * @param today 当天日期
     * @return true 表示获取成功（可以执行扫描）
     */
    public boolean tryAcquireScanLock(String biz, LocalDate today) {
        String key = HrmRedisKeyConstants.EXPIRE_REMIND_SCAN + biz + ":" + today;
        return Boolean.TRUE.equals(stringRedisTemplate.opsForValue().setIfAbsent(key, "1", SCAN_LOCK_TIMEOUT));
    }

}