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));
|
}
|
|
}
|
