楠笙の博客

static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) { Map<Object,Boolean> seen = new ConcurrentHashMap<>(); //putIfAbsent方法添加键值对，如果map集合中没有该key对应的值，则直接添加，并返回null，如果已经存在对应的值，则依旧为原来的值。 //如果返回null表示添加数据成功(不重复)，不重复(null==null :TRUE) return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null; }

// 解析 JWT 获取用户 ID Claims authorization = new JwtTokenUtil().parseToken(request.getHeader("authorization")); Integer userId = Integer.parseInt(authorization.getSubject()); // Redis Key 的构建，存储格式为 "user:failed_attempts:{userId}" String redisKey = "user:failed_attempts:" + userId; // 检查 Redis 中是否有该用户的查询失败记录 String failedAttemptsStr = (String) redisService.get(redisKey); Integer failedAttempts = failedAttemptsStr != null ? Integer.parseInt(failedAttemptsStr) : null; if (failedAttempts != null && failedAttempts >= 5) { // 如果失败次数达到5次，返回锁定信息 Long remainingTime = redisService.getExpire(redisKey, TimeUnit.MINUTES); return ResultData.fail("500","查询失败，次数已达上限，请在 " + remainingTime + " 分钟后再试。"); } // 构建查询条件 QueryWrapper<ASchoolMessagePeople> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("leader_group_id_card", idCard) .or() .eq("advisor_teacher_card", idCard) .or() .eq("competition_people_card", idCard); // 查询数据库 List<ASchoolMessagePeople> schoolMessagePeople = schoolMessagePeopleMapper.selectList(queryWrapper); if (CollectionUtils.isEmpty(schoolMessagePeople)) { // 如果没有查到信息，更新 Redis 中的失败记录 if (failedAttempts == null) { failedAttempts = 1; } else { failedAttempts++; } redisService.set(redisKey, String.valueOf(failedAttempts), 30, TimeUnit.MINUTES); int remainingAttempts = 5 - failedAttempts; return ResultData.fail("500","未找到相关信息，您还可以尝试 " + remainingAttempts + " 次。"); } // 查询成功，删除 Redis 中的失败记录 if (failedAttempts != null) { redisService.delete(redisKey); }