淘东电商项目（20） -会员唯一登录-阿里云开发者社区

CREATE TABLE `user_token` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `token` varchar(255) DEFAULT NULL,
  `login_type` varchar(255) CHARACTER SET utf8 DEFAULT NULL,
  `device_infor` varchar(255) DEFAULT NULL,
  `is_availability` int(2) DEFAULT NULL,
  `user_id` int(11) DEFAULT NULL,
  `create_time` date DEFAULT NULL,
  `update_time` date DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2

创建成功：

对应的UserTokenMapper：

/**
 * description: 用户TokenMapper
 * create by: YangLinWei
 * create time: 2020/3/3 4:42 下午
 */
public interface UserTokenMapper {
  /**
   * 根据userid+loginType +is_availability=0 进行查询
   * 
   * @param userId
   * @param loginType
   * @return
   */
  @Select("SELECT id as id ,token as token ,login_type as LoginType, device_infor as deviceInfor ,is_availability as isAvailability,user_id as userId"
      + "" + ""
      + " , create_time as createTime,update_time as updateTime   FROM user_token WHERE user_id=#{userId} AND login_type=#{loginType} and is_availability ='0'; ")
  UserTokenDo selectByUserIdAndLoginType(@Param("userId") Long userId, @Param("loginType") String loginType);
  /**
   * 根据userId+loginType token的状态修改为不可用
   * 
   * @param token
   * @return
   */
  @Update(" update user_token set is_availability  ='1', update_time=now() where token=#{token}")
  int updateTokenAvailability(@Param("token") String token);
  /**
   * token记录表中插入一条记录
   * 
   * @param userTokenDo
   * @return
   */
  @Insert("    INSERT INTO `user_token` VALUES (null, #{token},#{loginType}, #{deviceInfor}, 0, #{userId} ,now(),null ); ")
  int insertUserToken(UserTokenDo userTokenDo);
}

3.2 代码实现

3.2.1 用户登录

1.定义token生成工具类：

/**
 * description: Token生成工具类
 * create by: YangLinWei
 * create time: 2020/3/3 4:31 下午
 */
@Component
public class GenerateToken {
    @Autowired
    private RedisUtil redisUtil;
    /**
     * 生成令牌
     *
     * @param keyPrefix  令牌key前缀
     * @param redisValue redis存放的值
     * @return 返回token
     */
    public String createToken(String keyPrefix, String redisValue) {
        return createToken(keyPrefix, redisValue, null);
    }
    /**
     * 生成令牌
     *
     * @param keyPrefix  令牌key前缀
     * @param redisValue redis存放的值
     * @param time       有效期
     * @return 返回token
     */
    public String createToken(String keyPrefix, String redisValue, Long time) {
        if (StringUtils.isEmpty(redisValue)) {
            new Exception("redisValue Not nul");
        }
        String token = keyPrefix + UUID.randomUUID().toString().replace("-", "");
        redisUtil.setString(token, redisValue, time);
        return token;
    }
    /**
     * 根据token获取redis中的value值
     *
     * @param token
     * @return
     */
    public String getToken(String token) {
        if (StringUtils.isEmpty(token)) {
            return null;
        }
        String value = redisUtil.getString(token);
        return value;
    }
    /**
     * 移除token
     *
     * @param token
     * @return
     */
    public Boolean removeToken(String token) {
        if (StringUtils.isEmpty(token)) {
            return null;
        }
        return redisUtil.delKey(token);
    }
}

2.新增常量定义（其实不应该都只写到通用的Constants，应该每个微服务对应一个Constants。还有不会放到Apollo里，因为这些常量不经常变）：

// token
String MEMBER_TOKEN_KEYPREFIX = "taodong.member.login";
// 安卓的登陆类型
String MEMBER_LOGIN_TYPE_ANDROID = "Android";
// IOS的登陆类型
String MEMBER_LOGIN_TYPE_IOS = "IOS";
// PC的登陆类型
String MEMBER_LOGIN_TYPE_PC = "PC";
// 登陆超时时间 有效期 90天
Long MEMBRE_LOGIN_TOKEN_TIME = 77776000L;

3.用户登录接口：

/**
 * description: 用户登录接口服务
 * create by: YangLinWei
 * create time: 2020/3/3 4:35 下午
 */
@Api(tags = "用户登录服务接口")
public interface MemberLoginService {
    /**
     * 用户登录接口
     *
     * @param userLoginInDTO
     * @return
     */
    @PostMapping("/login")
    @ApiOperation(value = "会员用户登陆信息接口")
    BaseResponse<JSONObject> login(@RequestBody UserLoginInDTO userLoginInDTO);
}

4.用户登录接口实现：

@RestController
public class MemberLoginServiceImpl extends BaseApiService<JSONObject> implements MemberLoginService {
  @Autowired
  private UserMapper userMapper;
  @Autowired
  private GenerateToken generateToken;
  @Autowired
  private UserTokenMapper userTokenMapper;
  @Override
  public BaseResponse<JSONObject> login(@RequestBody UserLoginInDTO userLoginInpDTO) {
    // 1.验证参数
    String mobile = userLoginInpDTO.getMobile();
    if (StringUtils.isEmpty(mobile)) {
      return setResultError("手机号码不能为空!");
    }
    String password = userLoginInpDTO.getPassword();
    if (StringUtils.isEmpty(password)) {
      return setResultError("密码不能为空!");
    }
    // 判断登陆类型
    String loginType = userLoginInpDTO.getLoginType();
    if (StringUtils.isEmpty(loginType)) {
      return setResultError("登陆类型不能为空!");
    }
    // 目的是限制范围
    if (!(loginType.equals(Constants.MEMBER_LOGIN_TYPE_ANDROID) || loginType.equals(Constants.MEMBER_LOGIN_TYPE_IOS)
        || loginType.equals(Constants.MEMBER_LOGIN_TYPE_PC))) {
      return setResultError("登陆类型出现错误!");
    }
    // 设备信息
    String deviceInfor = userLoginInpDTO.getDeviceInfor();
    if (StringUtils.isEmpty(deviceInfor)) {
      return setResultError("设备信息不能为空!");
    }
    // 2.对登陆密码实现加密
    String newPassWord = MD5Util.MD5(password);
    // 3.使用手机号码+密码查询数据库 ，判断用户是否存在
    UserDo userDo = userMapper.login(mobile, newPassWord);
    if (userDo == null) {
      return setResultError("用户名称或者密码错误!");
    }
    // 用户登陆Token Session 区别
    // 用户每一个端登陆成功之后，会对应生成一个token令牌（临时且唯一）存放在redis中作为rediskey value userid
    // 4.获取userid
    Long userId = userDo.getUserId();
    // 5.根据userId+loginType 查询当前登陆类型账号之前是否有登陆过，如果登陆过 清除之前redistoken
    UserTokenDo userTokenDo = userTokenMapper.selectByUserIdAndLoginType(userId, loginType);
    if (userTokenDo != null) {
      // 如果登陆过 清除之前redistoken
      String token = userTokenDo.getToken();
      Boolean isremoveToken = generateToken.removeToken(token);
      if (isremoveToken) {
       // 把该token的状态改为1
       userTokenMapper.updateTokenAvailability(token);
      }
    }
    // .生成对应用户令牌存放在redis中
    String keyPrefix = Constants.MEMBER_TOKEN_KEYPREFIX + loginType;
    String newToken = generateToken.createToken(keyPrefix, userId + "");
    // 1.插入新的token
    UserTokenDo userToken = new UserTokenDo();
    userToken.setUserId(userId);
    userToken.setLoginType(userLoginInpDTO.getLoginType());
    userToken.setToken(newToken);
    userToken.setDeviceInfor(deviceInfor);
    userTokenMapper.insertUserToken(userToken);
    JSONObject data = new JSONObject();
    data.put("token", newToken);
    return setResultSuccess(data);
  }
}

3.2.2 获取用户信息

1.新增获取用户信息接口：

/**
     * 根据token查询用户信息
     *
     * @param token
     * @return
     */
    @GetMapping("/getUserInfo")
    @ApiOperation(value = "/getUserInfo")
    BaseResponse<UserOutDTO> getInfo(@RequestParam("token") String token);

2.实现接口：

@Override
    public BaseResponse<UserOutDTO> getInfo(String token) {
        // 1.验证token参数
        if (StringUtils.isEmpty(token)) {
            return setResultError("token不能为空!");
        }
        // 2.使用token查询redis 中的userId
        String redisUserId = generateToken.getToken(token);
        if (StringUtils.isEmpty(redisUserId)) {
            return setResultError("token已经失效或者token错误!");
        }
        // 3.使用userID查询 数据库用户信息
        Long userId = TypeCastHelper.toLong(redisUserId);
        UserDo userDo = userMapper.findByUserId(userId);
        if (userDo == null) {
            return setResultError("用户不存在!");
        }
        // 下节课将 转换代码放入在BaseApiService
        return setResultSuccess(MeiteBeanUtils.doToDto(userDo, UserOutDTO.class));
    }