rts-sim-testing-service/middleware/auth.go

package middleware

import (
	"log/slog"
	"regexp"
	"strings"

	"github.com/gin-gonic/gin"
	"joylink.club/bj-rtsts-server/db/model"
	"joylink.club/bj-rtsts-server/dto"
	"joylink.club/bj-rtsts-server/service"
	"joylink.club/bj-rtsts-server/sys_error"
)

// 用户权限缓存
var userAuthPathMap = make(map[int32]*dto.AuthUserStorageDto)

var PermissMiddleware = permissionMiddleware()

// 权限验证信息0
func permissionMiddleware() gin.HandlerFunc {
	return func(c *gin.Context) {
		user, _ := c.Get(IdentityKey)
		if user == nil { // 用户未登录
			c.Next()
			return
		}
		uid := user.(*model.User).ID
		userAuth := userAuthPathMap[uid]
		if userAuth == nil {
			userAuthPathMap[uid] = service.QueryUserAuthApiPath(uid)
			userAuth = userAuthPathMap[uid]
		}
		if userAuth.IsAdmin { // 用户是超级管理员
			c.Next()
			return
		}
		path, method := c.Request.URL.Path, c.Request.Method
		if validateUserPath(path, method, userAuth.AuthPaths) { // 用户有权限
			c.Next()
			return
		}
		slog.Error("无权限操作请求路径", "path", path, "method", method)
		panic(sys_error.New("权限不足"))
	}
}

// 验证路径
func validateUserPath(path, method string, paths []*dto.AuthPath) bool {
	for _, p := range paths {
		if p.Method != "*" && !strings.Contains(p.Method, method) { // 判断方法是否匹配
			continue
		}
		if p.Path == path {
			return true
		}
		authReg, _ := regexp.Compile(p.Path)
		if authReg.MatchString(path) { // 匹配路径
			return true
		}
	}
	return false
}

// 重新登录时移除权限
func ClearUserPermission(userId int32) {
	delete(userAuthPathMap, userId)
}

// 修改角色后清理用户权限
func ClearUserPermissionByRid(roleId int32) {
	var uids []int32
	for uid, u := range userAuthPathMap {
		for _, r := range u.RoleIds {
			if r == roleId {
				uids = append(uids, uid)
				break
			}
		}
	}
	if len(uids) == 0 {
		return
	}
	for _, uid := range uids {
		ClearUserPermission(uid)
	}
}