hongze 7 months ago
parent
commit
bc6ce0f8b1
3 changed files with 26 additions and 2 deletions
  1. 13 0
      domian/user/user_serivce.go
  2. 4 2
      middleware/auth_middleware.go
  3. 9 0
      service/user/user_service.go

+ 13 - 0
domian/user/user_serivce.go

@@ -98,3 +98,16 @@ func BindUserMobile(userId int, mobile string) (err error) {
 	}
 	return
 }
+
+func GetUserByOpenId(openId string) (UserDTO, error) {
+	var dto UserDTO
+	templateUser, err := userDao.GetUserByOpenId(openId)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			logger.Error("查询用户失败:%v", err)
+		}
+		return dto, err
+	}
+	dto = convertUserDTO(templateUser)
+	return dto, nil
+}

+ 4 - 2
middleware/auth_middleware.go

@@ -67,16 +67,18 @@ func AuthMiddleware() web.FilterFunc {
 				_ = ctx.JSONResp(rep)
 				return
 			}
+			fmt.Println(info)
 			//校验redis中是否合法
-			redisToken := rd().GetString(redis.GenerateTokenKey(info.Mobile))
+			redisToken := rd().GetString(redis.GenerateTokenKey(info.OpenId))
 			if redisToken != parts[1] {
 				logger.Error("token无效:用户token已刷新")
 				_ = ctx.JSONResp(tokenExpired())
 				return
 			}
+			fmt.Println()
 			//组装用户信息
 			var userInfo user.User
-			userInfo, err = user.GetUserByMobile(info.Mobile)
+			userInfo, err = user.GetUserByOpenId(info.OpenId)
 
 			fmt.Println(userInfo)
 			if err != nil {

+ 9 - 0
service/user/user_service.go

@@ -133,6 +133,15 @@ func GetUserByMobile(mobile string) (user User, err error) {
 	}
 	return
 }
+
+func GetUserByOpenId(openId string) (user User, err error) {
+	userDTO, err := userService.GetUserByOpenId(openId)
+	if err == nil {
+		user = convertToUser(userDTO)
+	}
+	return
+}
+
 func convertToUser(userDTO userService.UserDTO) User {
 	return User{
 		Id:       userDTO.Id,