From 3421ca9d6195a96d0e63b4acc2cc9a77fe1b5564 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期二, 21 六月 2022 09:41:05 +0800
Subject: [PATCH] bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/handel/UserAuthenticationProvider.java |   50 +++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 45 insertions(+), 5 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/handel/UserAuthenticationProvider.java b/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/handel/UserAuthenticationProvider.java
index c358831..947e5f2 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/handel/UserAuthenticationProvider.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/auth/src/main/java/com/panzhihua/auth/handel/UserAuthenticationProvider.java
@@ -1,11 +1,22 @@
 package com.panzhihua.auth.handel;
 
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Set;
 
 import javax.annotation.Resource;
+import javax.crypto.BadPaddingException;
+import javax.crypto.IllegalBlockSizeException;
+import javax.crypto.NoSuchPaddingException;
 
+import com.panzhihua.auth.config.MyAESUtil;
+import com.panzhihua.common.model.helper.AESUtil;
+import com.panzhihua.common.utlis.AES;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.security.authentication.AuthenticationProvider;
 import org.springframework.security.authentication.BadCredentialsException;
 import org.springframework.security.authentication.LockedException;
@@ -33,17 +44,34 @@
 public class UserAuthenticationProvider implements AuthenticationProvider {
     @Resource
     private UserService userService;
+    @Resource
+    private RedisTemplate redisTemplate;
+
+    private static String LOGIN_FAIL="LOGIN_FAIL_";
 
     @Override
     public Authentication authenticate(Authentication authentication) throws AuthenticationException {
         // 获取表单输入中返回的用户名
         String userName = (String)authentication.getPrincipal();
-        // 获取表单中输入的密码
-        String password = (String)authentication.getCredentials();
+        String password =(String)authentication.getCredentials();
+        try {
+            password = MyAESUtil.Decrypt((String)authentication.getCredentials(),"Ryo7M3n8loC5Abcd");
+        } 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<>();
@@ -53,11 +81,13 @@
                 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("密码不正确");
         }
         // 还可以加一些其他信息的判断,比如用户账号已停用等判断
@@ -73,4 +103,14 @@
     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));
+        }
+    }
 }

--
Gitblit v1.7.1