// 添加未讀數(shù)（默認新增1條待審核提醒）
appletRedisUtil.addUnreadCount(cityPartner.getId());

import jakarta.annotation.Resource;
import org.springblade.business.constant.RedisKeyConstant;
import org.springblade.business.pojo.entity.ProductApplyRecord;
import org.springblade.business.service.ProductApplyRecordService;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.Objects;
 
@Component // 注入Spring容器，全局可用
public class AppletRedisUtil {
 
    @Resource
    private RedisTemplate<String, Long> redisTemplate; // 操作Redis的核心組件
 
    // 1. 重載方法：默認給城市合伙人新增1條未讀消息
    public void addUnreadCount(Long miniUserId) {
        addUnreadCount(miniUserId, 1L);
    }
 
    // 2. 核心方法：支持自定義新增未讀條數(shù)，含數(shù)據(jù)準(zhǔn)確性校驗
    public void addUnreadCount(Long miniUserId, Long value) {
        // 2.1 工具類無法直接注入Service，通過Spring上下文獲取
        ProductApplyRecordService productApplyRecordService = SpringContextUtil.getBean(ProductApplyRecordService.class);
        
        // 2.2 查該城市合伙人的總申請數(shù)（未讀上限，避免未讀數(shù)超過實際總數(shù)）
        Long totalCount = productApplyRecordService.lambdaQuery()
            .eq(ProductApplyRecord::getCityPartnerId, miniUserId)
            .count();
        
        // 2.3 查當(dāng)前Redis中的未讀數(shù)量（空值兜底返回0，避免空指針）
        Long currentUnread = getUnreadCount(miniUserId);
        
        // 2.4 修正未讀數(shù)量：若累加后超總申請數(shù)，取總申請數(shù)（防止數(shù)據(jù)異常）
        value = (currentUnread + value) > totalCount ? totalCount : (currentUnread + value);
        
        // 2.5 更新Redis：用“常量前綴+用戶ID”作為key，原子自增未讀數(shù)量
        redisTemplate.opsForValue().increment(RedisKeyConstant.PRODUCT_APPLY_UNREAD_NUM + miniUserId, value);
    }
 
    // 3. 查詢未讀數(shù)量：空值兜底，確保返回非null
    public Long getUnreadCount(Long miniUserId) {
        String key = RedisKeyConstant.PRODUCT_APPLY_UNREAD_NUM + miniUserId;
        Long unread = redisTemplate.opsForValue().get(key);
        return Objects.isNull(unread) ? 0L : unread;
    }
 
    // 4. 重置未讀數(shù)量：先置0再刪key，確保狀態(tài)徹底清空
    public void resetUnreadCount(Long miniUserId) {
        String key = RedisKeyConstant.PRODUCT_APPLY_UNREAD_NUM + miniUserId;
        redisTemplate.opsForValue().set(key, 0L);
        redisTemplate.delete(key);
    }
}