videoplayer/handler/user.go

package handler

import (
	"crypto/md5"
	"encoding/hex"
	"fmt"
	"github.com/gin-gonic/gin"
	"github.com/golang-jwt/jwt"
	"time"
	"videoplayer/service"
	"videoplayer/worker"
)

var signingKey = []byte("aadafcvretmoi9")

func SetUpUserGroup(router *gin.Engine) {
	userGroup := router.Group("/user")
	userGroup.POST("/register", registerHandler)
	userGroup.POST("/login", loginHandler)
}

type RLReq struct {
	User     string `json:"username" form:"username"`
	Email    string `json:"email" form:"email"`
	Password string `json:"password" form:"password"`
}

func loginHandler(c *gin.Context) {
	var req_data RLReq
	tokenString := ""
	if err := c.ShouldBind(&req_data); err == nil {
		if len(req_data.Password) < 32 {
			hasher := md5.New()
			hasher.Write([]byte(req_data.Password))                 // 生成密码的 MD5 散列值
			req_data.Password = hex.EncodeToString(hasher.Sum(nil)) // 生成密码的 MD5 散列值
		}
		user := service.GetUser(req_data.User, req_data.Password)
		if user.ID != 0 {
			redis_token := worker.GetRedis("user_" + user.Name)
			if redis_token == "" {
				// 生成 JWT 令牌
				token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{
					"username": user.Name,
					"id":       user.ID,
					"exp":      time.Now().Add(time.Hour * 10).Unix(), // 令牌过期时间, 10小时后过期
				})
				tokenString, err = token.SignedString(signingKey)
				if err != nil {
					c.JSON(200, gin.H{"error": err.Error(), "code": 1, "message": "error"})
					return
				}

				worker.SetRedisWithExpire("user_"+user.Name, tokenString, time.Hour*10) // 将用户信息存入
				worker.SetRedisWithExpire(tokenString, tokenString, time.Hour*10)       // 设置过期时间为10分钟
				worker.SetHash(tokenString, int(user.ID), user.Name, user.Email)        // 将用户信息存入
			} else {
				tokenString = redis_token
			}
			// 返回令牌
			data := make(map[string]interface{})
			data["id"] = user.ID
			data["username"] = user.Name
			data["email"] = user.Email
			data["token"] = tokenString
			c.JSON(200, gin.H{"code": 0, "message": "success", "data": data})
		} else {
			c.JSON(200, gin.H{"error": "user not found", "code": 1, "message": "error"})
		}
	} else {
		c.JSON(200, gin.H{"error": err.Error(), "code": 1, "message": "error"})
	}

}

func registerHandler(c *gin.Context) {
	var req_data RLReq
	tokenString := ""
	if err := c.ShouldBindJSON(&req_data); err == nil {
		if len(req_data.Password) < 32 {
			hasher := md5.New()
			hasher.Write([]byte(req_data.Password))                 // 生成密码的 MD5 散列值
			req_data.Password = hex.EncodeToString(hasher.Sum(nil)) // 生成密码的 MD5 散列值
		}
		if service.ContainsUser(req_data.User, req_data.Email) == true {
			c.JSON(200, gin.H{"error": "user already exists", "code": 1, "message": "error"})
			return
		}
		id := service.CreateUser(req_data.User, req_data.Password, req_data.Email)
		// 生成 JWT 令牌
		token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{
			"username": req_data.User,
			"id":       id,
			"exp":      time.Now().Add(time.Hour * 10).Unix(), // 令牌过期时间, 1分钟后过期
		})
		tokenString, err = token.SignedString(signingKey)
		if err != nil {
			c.JSON(200, gin.H{"error": err.Error()})
		}
	} else {
		c.JSON(200, gin.H{"error": err.Error()})
	}
	fmt.Println(req_data)
	worker.SetRedisWithExpire(tokenString, tokenString, time.Hour*10) // 设置过期时间为10分钟
	// 返回令牌
	c.JSON(200, gin.H{"token": tokenString, "username": req_data.User})
}