buhuazhen
15 小时以前 bda2d004876498d1618a8a6e5fa0363e19d5c011
fix(approve): 优化审批计数器的自增逻辑

- 使用 Redis 原子自增函数替代原先手动获取和设置逻辑
- 修正首次自增时从数据库查询最大审批数,避免并发覆盖
- 调整查询条件,确保统计当天有效审批记录
- 设置 Redis 键过期时间为1小时,防止数据持久失效
- 提升计数器性能和准确性,减少数据库访问频率
已修改1个文件
44 ■■■■ 文件已修改
src/main/java/com/ruoyi/approve/utils/DailyRedisCounter.java 44 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/ruoyi/approve/utils/DailyRedisCounter.java
@@ -71,29 +71,33 @@
     * @return 今日自增后的计数值
     */
    public long incrementAndGetByDb() {
        String approveId = redisTemplate.opsForValue().get("approveNum");
        if(approveId == null){
        String key = "approveNumHSXNY";
        // 1. 先尝试从 Redis 自增(原子操作)
        Long num = redisTemplate.opsForValue().increment(key);
        // 2. 如果是第一次(说明 key 不存在)
        if (num == null || num == 1L) {
            // 查询数据库当前最大值(更合理)
            StartAndEndDateDto dateTime = getDateTime();
            LambdaQueryWrapper<ApproveProcess> approveProcessLambdaQueryWrapper = new LambdaQueryWrapper<>();
            approveProcessLambdaQueryWrapper
                    .eq(ApproveProcess::getApproveDelete,0)
                    .gt(ApproveProcess::getCreateTime,dateTime.getStartDate())
                    .lt(ApproveProcess::getCreateTime,dateTime.getEndDate());
            Long aLong = approveProcessMapper.selectCount(approveProcessLambdaQueryWrapper);
            if(aLong == null){
                redisTemplate.opsForValue().set("approveNum","1",1L, TimeUnit.HOURS);
                return 1;
            }else{
                aLong += 1;
                redisTemplate.opsForValue().set("approveNum",aLong.toString(),1L, TimeUnit.HOURS);
                return aLong;
            }
        }else{
            Long num = Long.parseLong(approveId) + 1;
            redisTemplate.opsForValue().set("approveNum",num.toString(),1L, TimeUnit.HOURS);
            return Long.parseLong(approveId);
            LambdaQueryWrapper<ApproveProcess> wrapper = new LambdaQueryWrapper<>();
            wrapper.eq(ApproveProcess::getApproveDelete, 0)
                    .ge(ApproveProcess::getCreateTime, dateTime.getStartDate())
                    .lt(ApproveProcess::getCreateTime, dateTime.getEndDate());
            Long count = approveProcessMapper.selectCount(wrapper);
            long start = (count == null ? 0 : count) + 1;
            // 设置初始值(避免覆盖并发)
            redisTemplate.opsForValue().set(key, String.valueOf(start), 1L, TimeUnit.HOURS);
            return start;
        }
        return num;
    }
    /**