/**
     * 發(fā)送驗(yàn)證碼
     */
    @Override
    public Result sendCode(String phone, HttpSession session) {
        // 1、判斷手機(jī)號(hào)是否合法
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式不正確");
        }
        // 2、手機(jī)號(hào)合法，生成驗(yàn)證碼，并保存到Session中
        String code = RandomUtil.randomNumbers(6);
        session.setAttribute(SystemConstants.VERIFY_CODE, code);
        // 3、發(fā)送驗(yàn)證碼
        log.info("驗(yàn)證碼:{}", code);
        return Result.ok();
    }
 
    /**
     * 用戶登錄
     */
    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        String phone = loginForm.getPhone();
        String code = loginForm.getCode();
        // 1、判斷手機(jī)號(hào)是否合法
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式不正確");
        }
        // 2、判斷驗(yàn)證碼是否正確
        String sessionCode = (String) session.getAttribute(LOGIN_CODE);
        if (code == null || !code.equals(sessionCode)) {
            return Result.fail("驗(yàn)證碼不正確");
        }
        // 3、判斷手機(jī)號(hào)是否是已存在的用戶
        User user = this.getOne(new LambdaQueryWrapper<User>()
                .eq(User::getPassword, phone));
        if (Objects.isNull(user)) {
            // 用戶不存在，需要注冊(cè)
            user = createUserWithPhone(phone);
        }
        // 4、保存用戶信息到Session中，便于后面邏輯的判斷（比如登錄判斷、隨時(shí)取用戶信息，減少對(duì)數(shù)據(jù)庫(kù)的查詢）
        session.setAttribute(LOGIN_USER, user);
        return Result.ok();
    }
 
    /**
     * 根據(jù)手機(jī)號(hào)創(chuàng)建用戶
     */
    private User createUserWithPhone(String phone) {
        User user = new User();
        user.setPhone(phone);
        user.setNickName(SystemConstants.USER_NICK_NAME_PREFIX + RandomUtil.randomString(10));
        this.save(user);
        return user;
    }

public class LoginInterceptor implements HandlerInterceptor {
    /**
     * 前置攔截器，用于判斷用戶是否登錄
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        HttpSession session = request.getSession();
        // 1、判斷用戶是否存在
        User user = (User) session.getAttribute(LOGIN_USER);
        if (Objects.isNull(user)){
            // 用戶不存在，直接攔截
            response.setStatus(HttpStatus.HTTP_UNAUTHORIZED);
            return false;
        }
        // 2、用戶存在，則將用戶信息保存到ThreadLocal中，方便后續(xù)邏輯處理
        // 比如：方便獲取和使用用戶信息，session獲取用戶信息是具有侵入性的
        ThreadLocalUtls.saveUser(user);
 
        return HandlerInterceptor.super.preHandle(request, response, handler);
    }
}

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        // 添加登錄攔截器
        registry.addInterceptor(new LoginInterceptor())
                // 設(shè)置放行請(qǐng)求
                .excludePathPatterns(
                        "/user/code",
                        "/user/login",
                        "/blog/hot",
                        "/shop/**",
                        "/shop-type/**",
                        "/upload/**",
                        "/voucher/**"
                );
    }
}
 

    /**
     * 發(fā)送驗(yàn)證碼
     *
     * @param phone
     * @param session
     * @return
     */
    @Override
    public Result sendCode(String phone, HttpSession session) {
        // 1、判斷手機(jī)號(hào)是否合法
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式不正確");
        }
        // 2、手機(jī)號(hào)合法，生成驗(yàn)證碼，并保存到Redis中
        String code = RandomUtil.randomNumbers(6);
        stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY + phone, code,
                RedisConstants.LOGIN_CODE_TTL, TimeUnit.MINUTES);
        // 3、發(fā)送驗(yàn)證碼
        log.info("驗(yàn)證碼:{}", code);
        return Result.ok();
    }
 
    /**
     * 用戶登錄
     *
     * @param loginForm
     * @param session
     * @return
     */
    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        String phone = loginForm.getPhone();
        String code = loginForm.getCode();
        // 1、判斷手機(jī)號(hào)是否合法
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式不正確");
        }
        // 2、判斷驗(yàn)證碼是否正確
        String redisCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);
        if (code == null || !code.equals(redisCode)) {
            return Result.fail("驗(yàn)證碼不正確");
        }
        // 3、判斷手機(jī)號(hào)是否是已存在的用戶
        User user = this.getOne(new LambdaQueryWrapper<User>()
                .eq(User::getPhone, phone));
        if (Objects.isNull(user)) {
            // 用戶不存在，需要注冊(cè)
            user = createUserWithPhone(phone);
        }
        // 4、保存用戶信息到Redis中，便于后面邏輯的判斷（比如登錄判斷、隨時(shí)取用戶信息，減少對(duì)數(shù)據(jù)庫(kù)的查詢）
        UserDTO userDTO = BeanUtil.copyProperties(user, UserDTO.class);
        // 將對(duì)象中字段全部轉(zhuǎn)成string類型，StringRedisTemplate只能存字符串類型的數(shù)據(jù)
        Map<String, Object> userMap = BeanUtil.beanToMap(userDTO, new HashMap<>(),
                CopyOptions.create().setIgnoreNullValue(true).
                        setFieldValueEditor((fieldName, fieldValue) -> fieldValue.toString()));
        String token = UUID.randomUUID().toString(true);
        String tokenKey = LOGIN_USER_KEY + token;
        stringRedisTemplate.opsForHash().putAll(tokenKey, userMap);
        stringRedisTemplate.expire(tokenKey, LOGIN_USER_TTL, TimeUnit.MINUTES);
 
        return Result.ok(token);
    }
 
    /**
     * 根據(jù)手機(jī)號(hào)創(chuàng)建用戶并保存
     *
     * @param phone
     * @return
     */
    private User createUserWithPhone(String phone) {
        User user = new User();
        user.setPhone(phone);
        user.setNickName(SystemConstants.USER_NICK_NAME_PREFIX + RandomUtil.randomString(10));
        this.save(user);
        return user;
    }

public class LoginInterceptor implements HandlerInterceptor {
 
    /**
     * 前置攔截器，用于判斷用戶是否登錄
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 判斷當(dāng)前用戶是否已登錄
        if (ThreadLocalUtls.getUser() == null){
            // 當(dāng)前用戶未登錄，直接攔截
            response.setStatus(HttpStatus.HTTP_UNAUTHORIZED);
            return false;
        }
        // 用戶存在，直接放行
        return true;
    }
}

public class RefreshTokenInterceptor implements HandlerInterceptor {
 
    // new出來(lái)的對(duì)象是無(wú)法直接注入IOC容器的（LoginInterceptor是直接new出來(lái)的）
    // 所以這里需要再配置類中注入，然后通過(guò)構(gòu)造器傳入到當(dāng)前類中
    private StringRedisTemplate stringRedisTemplate;
 
    public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }
 
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1、獲取token，并判斷token是否存在
        String token = request.getHeader("authorization");
        if (StrUtil.isBlank(token)){
            // token不存在，說(shuō)明當(dāng)前用戶未登錄，不需要刷新直接放行
            return true;
        }
        // 2、判斷用戶是否存在
        String tokenKey = LOGIN_USER_KEY + token;
        Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(tokenKey);
        if (userMap.isEmpty()){
            // 用戶不存在，說(shuō)明當(dāng)前用戶未登錄，不需要刷新直接放行
            return true;
        }
        // 3、用戶存在，則將用戶信息保存到ThreadLocal中，方便后續(xù)邏輯處理，比如：方便獲取和使用用戶信息，Redis獲取用戶信息是具有侵入性的
        UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);
        ThreadLocalUtls.saveUser(BeanUtil.copyProperties(userMap, UserDTO.class));
        // 4、刷新token有效期
        stringRedisTemplate.expire(token, LOGIN_USER_TTL, TimeUnit.MINUTES);
        return true;
    }
}

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {
 
    // new出來(lái)的對(duì)象是無(wú)法直接注入IOC容器的（LoginInterceptor是直接new出來(lái)的）
    // 所以這里需要再配置類中注入，然后通過(guò)構(gòu)造器傳入到當(dāng)前類中
    @Resource
    private StringRedisTemplate stringRedisTemplate;
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        // 添加登錄攔截器
        registry.addInterceptor(new LoginInterceptor())
                // 設(shè)置放行請(qǐng)求
                .excludePathPatterns(
                        "/user/code",
                        "/user/login",
                        "/blog/hot",
                        "/shop/**",
                        "/shop-type/**",
                        "/upload/**",
                        "/voucher/**"
                ).order(1); // 優(yōu)先級(jí)默認(rèn)都是0，值越大優(yōu)先級(jí)越低
        // 添加刷新token的攔截器
        registry.addInterceptor(new RefreshTokenInterceptor(stringRedisTemplate)).addPathPatterns("/**").order(0);
    }
}