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 {
			// 生成 JWT 令牌
			token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{
				"username": user.Name,
				"id":       user.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(), "code": 1, "message": "error"})
				return
			}
			worker.SetRedisWithExpire(tokenString, tokenString, time.Hour*10) // 设置过期时间为10分钟
			// 返回令牌
			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})
}