| | |
| | | package com.ruoyi.approve.utils; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.ruoyi.approve.mapper.ApproveProcessMapper; |
| | | import com.ruoyi.approve.pojo.ApproveProcess; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.data.redis.core.StringRedisTemplate; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.Duration; |
| | | import java.time.LocalDate; |
| | | import java.time.LocalDateTime; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.Calendar; |
| | | import java.util.Date; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | |
| | |
| | | this.redisTemplate = redisTemplate; |
| | | } |
| | | |
| | | /** |
| | | @Value("${ruoyi.approvalNumberPrefix}") |
| | | private String approvalNumberPrefix; |
| | | |
| | | /**查缓存 |
| | | * 获取指定计数器在今日的数值,并自增1 |
| | | * @param counterName 计数器名称(例如:login_count、order_count) |
| | | * @return 今日自增后的计数值 |
| | |
| | | return count; |
| | | } |
| | | |
| | | @Autowired |
| | | private ApproveProcessMapper approveProcessMapper; |
| | | |
| | | /** |
| | | * 获取当前时间的 开始日期 ,结束日期 |
| | | * @return |
| | | */ |
| | | public static StartAndEndDateDto getDateTime(){ |
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); |
| | | Date date = new Date(); |
| | | Calendar cal = Calendar.getInstance(); |
| | | cal.setTime(date); |
| | | cal.add(Calendar.DATE,1); |
| | | String startDateTime = simpleDateFormat.format(date); |
| | | String endDateTime = simpleDateFormat.format(cal.getTime()); |
| | | StartAndEndDateDto startAndEndDateDto = new StartAndEndDateDto(); |
| | | startAndEndDateDto.setStartDate(startDateTime); |
| | | startAndEndDateDto.setEndDate(endDateTime); |
| | | return startAndEndDateDto; |
| | | } |
| | | |
| | | /**查数据库 |
| | | * 获取指定计数器在今日的数值,并自增1 |
| | | * @return 今日自增后的计数值 |
| | | */ |
| | | public long incrementAndGetByDb() { |
| | | String today = LocalDate.now().format(DATE_FORMAT); |
| | | String key = approvalNumberPrefix + ":approveNum:" + today; |
| | | String lockKey = "lock:" + key; |
| | | |
| | | if (Boolean.FALSE.equals(redisTemplate.hasKey(key))) { |
| | | Boolean acquired = redisTemplate.opsForValue().setIfAbsent(lockKey, "1", 10, TimeUnit.SECONDS); |
| | | if (Boolean.TRUE.equals(acquired)) { |
| | | try { |
| | | if (Boolean.FALSE.equals(redisTemplate.hasKey(key))) { |
| | | StartAndEndDateDto dateTime = getDateTime(); |
| | | LambdaQueryWrapper<ApproveProcess> approveProcessLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | approveProcessLambdaQueryWrapper |
| | | .eq(ApproveProcess::getApproveDelete, 0) |
| | | .gt(ApproveProcess::getCreateTime, dateTime.getStartDate()) |
| | | .lt(ApproveProcess::getCreateTime, dateTime.getEndDate()); |
| | | Long count = approveProcessMapper.selectCount(approveProcessLambdaQueryWrapper); |
| | | long initialCount = (count == null) ? 0 : count; |
| | | |
| | | redisTemplate.opsForValue().set(key, String.valueOf(initialCount), 24, TimeUnit.HOURS); |
| | | } |
| | | } finally { |
| | | // 释放锁 |
| | | redisTemplate.delete(lockKey); |
| | | } |
| | | } else { |
| | | try { |
| | | Thread.sleep(100); |
| | | } catch (InterruptedException e) { |
| | | Thread.currentThread().interrupt(); |
| | | } |
| | | return incrementAndGetByDb(); // 递归重试 |
| | | } |
| | | } |
| | | |
| | | return redisTemplate.opsForValue().increment(key); |
| | | } |
| | | |
| | | /** |
| | | * 获取指定计数器在今日的当前数值 |
| | | * @param counterName 计数器名称 |
| | |
| | | * 计算距离次日凌晨的秒数 |
| | | */ |
| | | private long calculateSecondsUntilMidnight() { |
| | | LocalDate tomorrow = LocalDate.now().plusDays(1); |
| | | LocalDate midnight = tomorrow.atStartOfDay().toLocalDate(); |
| | | return java.time.Duration.between( |
| | | LocalDate.now().atTime(23, 59, 59), |
| | | midnight.atTime(0, 0, 0) |
| | | ).getSeconds() + 1; |
| | | LocalDateTime now = LocalDateTime.now(); |
| | | LocalDateTime midnight = now.toLocalDate().plusDays(1).atStartOfDay(); |
| | | return Duration.between(now, midnight).getSeconds(); |
| | | } |
| | | |
| | | /** |