《毕业设计》--毕业设计项目 基于SSM框架的健身房管理系统 后端Spring Boot项目.zip

package com.yang.springboot.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yang.springboot.common.Constants; import com.yang.springboot.common.lang.Result; import com.yang.springboot.entity.Role; import com.yang.springboot.entity.User; import com.yang.springboot.mapper.UserDao; import com.yang.springboot.param.LoginParam; import com.yang.springboot.param.LoginUser; import com.yang.springboot.param.RegisterParam; import com.yang.springboot.param.UserInfoParam; import com.yang.springboot.param.vo.UserInfoVo; import com.yang.springboot.service.UserService; import com.yang.springboot.utils.JwtUtils; import com.yang.springboot.utils.RedisCache; import com.yang.springboot.utils.UserUtils; import io.jsonwebtoken.Claims; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.authentication.AuthenticationManager; import org.springframework.security.authentication.InternalAuthenticationServiceException; import org.springframework.security.authentication.LockedException; import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; import org.springframework.security.core.Authentication; import org.springframework.security.core.context.SecurityContextHolder; import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.util.*; import java.util.concurrent.TimeUnit; /** * <p> * 服务实现类 * </p> * * @author LambCcc * @since 2022-04-14 */ @Service public class UserServiceImpl extends ServiceImpl<UserDao, User> implements UserService { private final AuthenticationManager authenticationManager; private final RedisCache redisCache; private final UserDao userDao; @Autowired public UserServiceImpl(AuthenticationManager authenticationManager, RedisCache redisCache, UserDao userDao) { this.authenticationManager = authenticationManager; this.redisCache = redisCache; this.userDao = userDao; } @Override public Result getUserPage(String type, Integer currentPage, Integer pageSize, String username, String nickname, String phone) { // 根据currentPage和pageSize 设置分页查询范围 Page<User> userPage = new Page<>(currentPage, pageSize); LambdaQueryWrapper<User> userLambdaQueryWrapper = new LambdaQueryWrapper<>(); // 根据username nickname phone查询数据库 // 判断参数是否为空 决定是否拼接条件 // 使用like对查询条件进行模糊查询 switch (type) { case "admin": userLambdaQueryWrapper.eq(User::getRoleId, 1); break; case "stuff": userLambdaQueryWrapper.eq(User::getRoleId, 2); break; case "coach": userLambdaQueryWrapper.eq(User::getRoleId, 3); break; case "member": userLambdaQueryWrapper.eq(User::getRoleId, 4); break; case "all": default: break; } if (StrUtil.isNotEmpty(username)) { userLambdaQueryWrapper.like(User::getUsername, username); } if (StrUtil.isNotEmpty(nickname)) { userLambdaQueryWrapper.like(User::getNickname, nickname); } if (StrUtil.isNotEmpty(phone)) { userLambdaQueryWrapper.like(User::getPhone, phone); } return new Result(Constants.CODE_200, "获取分页信息成功!", page(userPage, userLambdaQueryWrapper)); } /** * 登录操作的实现类 * 1. 首先验证 输入的验证码是否正确 如果不正确直接返回错误 * 2. 调用自定义的登录接口 调用ProviderManager的authenticate方法进行认证 如果认证通过则进行生成jwt * 3. 将token存入Redis中进行缓存 * @param loginParam 登录所需要的参数 */ @Override public Result login(LoginParam loginParam) { // 获取Cookie中携带的uuid 根据uuid获取Redis中的验证码 String uuid = loginParam.getUuid(); String codeInRedis = redisCache.getCacheObject(uuid).toString(); // 校验token if (StrUtil.isEmpty(codeInRedis)) { return new Result(Constants.CODE_500, "验证码不存在!请重试!", null); } else if (!codeInRedis.equals(loginParam.getCaptchaCode())) { return new Result(Constants.CODE_500, "验证码错误!请重新输入!", null); } UsernamePasswordAuthenticationToken authenticationToken = new UsernamePasswordAuthenticationToken(loginParam.getUsername(), loginParam.getPassword()); Authentication authentication = null; try { authentication = authenticationManager.authenticate(authenticationToken); } catch (LockedException e) { return new Result(Constants.CODE_500, "账号已停用!", null); } catch (InternalAuthenticationServiceException e) { return new Result(Constants.CODE_500, "登录失败!", null); } if (Objects.isNull(authentication)) { throw new RuntimeException("用户名或密码错误!"); } LoginUser loginUser = (LoginUser) authentication.getPrincipal(); // 获取用户id生成token String userId = loginUser.getUser().getId().toString(); String token = JwtUtils.createJWT(userId); // 将数据存入Redis 根据ID查找和存储 redisCache.setCacheObject("UserLogin: " + userId, loginUser, 1, TimeUnit.DAYS); // 以KEY-VALUE形式返回给前端 Map<String, String> map = new HashMap<>(); map.put("token", token); return new Result(Constants.CODE_200, "登录成功!", map); } /** * 注册操作 * 1. 首先校验验证码 如果输入错误 直接返回错误 * 2. 如果选择的职别是健身教练/工作人员/管理员 校验内部验证码是否正确 如果错误 直接返回错误 * 3. 查询数据库中是否已存在username 如果有相同username 直接返回错误 * @param registerParam 注册所需要的参数 */ @Override public Result register(RegisterParam registerParam) { // 获取Cookie中携带的uuid 根据uuid获取Redis中的验证码 String uuid = registerParam.getUuid(); String codeInRedis = redisCache.getCacheObject(uuid).toString(); // 校验验证码 if (StrUtil.isEmpty(codeInRedis)) { return new Result(Constants.CODE_500, "验证码不存在!请重试!", null); } else if (!codeInRedis.equals(registerParam.getCaptchaCode())) { return new Result(Constants.CODE_500, "验证码错误!请重新输入!", null); } // 如果注册的不是会员用户 则进行校验码判断 switch (registerParam.getRoleId()) { case 1: // roleId为1 表示管理员 if (Constants.VERIFY_CODE_REGISTER_ADMIN.equals(registerParam.getVerifyCode())) { return new Result(Constants.CODE_401, "内部验证码输入错误!请重试!", null); } break; case 2: // roleId为2 表示工作人员 if (Constants.VERIFY_CODE_REGISTER_STUFF.equals(registerParam.getVerifyCode())) { return new Result(Constants.CODE_401, "内部验证码输入错误!请重试!", null); } break; case 3: // roleId为3 表示健身教练 if (Constants.VERIFY_CODE_REGISTER_COACH.equals(registerParam.getVerifyCode())) { return new Result(Constants.CODE