| | |
| | | |
| | | import java.security.InvalidKeyException; |
| | | import java.security.NoSuchAlgorithmException; |
| | | import java.time.Duration; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Set; |
| | |
| | | @Resource |
| | | private RedisTemplate redisTemplate; |
| | | |
| | | private static String LOGIN_FAIL="LOGIN_FAIL_"; |
| | | |
| | | @Override |
| | | public Authentication authenticate(Authentication authentication) throws AuthenticationException { |
| | | // 获取表单输入中返回的用户名 |
| | |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | boolean flag= redisTemplate.hasKey(LOGIN_FAIL+userName); |
| | | if(flag){ |
| | | Integer time= (Integer) redisTemplate.opsForValue().get(LOGIN_FAIL+userName); |
| | | if(time>=5){ |
| | | redisTemplate.opsForValue().set(LOGIN_FAIL+userName,5, Duration.ofMinutes(5)); |
| | | throw new LockedException("登录错误超过限制,请五分钟后重试"); |
| | | } |
| | | } |
| | | // 查询用户是否存在 |
| | | R<LoginUserInfoVO> r = userService.getUserInfo(userName); |
| | | if (r.getCode() != 200) { |
| | | throw new UsernameNotFoundException("该账号不存在"); |
| | | lockLogin(flag,userName); |
| | | throw new UsernameNotFoundException("账号或密码错误"); |
| | | } |
| | | LoginUserInfoVO loginUserInfoVO = r.getData(); |
| | | List<GrantedAuthority> grantedAuthorityList = new ArrayList<>(); |
| | |
| | | grantedAuthorityList.add(new SimpleGrantedAuthority(s)); |
| | | }); |
| | | } |
| | | if (ObjectUtils.isEmpty(loginUserInfoVO.getAccount())) { |
| | | throw new UsernameNotFoundException("该账号不存在"); |
| | | if (ObjectUtils.isEmpty(loginUserInfoVO.getAccount())||ObjectUtils.isEmpty(password)) { |
| | | lockLogin(flag,userName); |
| | | throw new UsernameNotFoundException("账号或密码错误"); |
| | | } |
| | | // 我们还要判断密码是否正确,这里我们的密码使用BCryptPasswordEncoder进行加密的 |
| | | if (!new BCryptPasswordEncoder().matches(password, loginUserInfoVO.getPassword())) { |
| | | lockLogin(flag,userName); |
| | | throw new BadCredentialsException("密码不正确"); |
| | | } |
| | | // 还可以加一些其他信息的判断,比如用户账号已停用等判断 |
| | |
| | | public boolean supports(Class<?> aClass) { |
| | | return true; |
| | | } |
| | | |
| | | private void lockLogin(Boolean flag,String userName){ |
| | | if(flag){ |
| | | Integer time= (Integer) redisTemplate.opsForValue().get(LOGIN_FAIL+userName); |
| | | redisTemplate.opsForValue().set(LOGIN_FAIL+userName,time+1, Duration.ofMinutes(5)); |
| | | } |
| | | else { |
| | | redisTemplate.opsForValue().set(LOGIN_FAIL+userName,1, Duration.ofMinutes(5)); |
| | | } |
| | | } |
| | | } |