fix: 修复playground优先级失效

controller/playground.go

@@ -58,26 +58,27 @@ func Playground(c *gin.Context) {
 	}
 	}
 
 
 	userId := c.GetInt("id")
 	userId := c.GetInt("id")
-	//c.Set("token_name", "playground-"+group)
+
+	// Write user context to ensure acceptUnsetRatio is available
+	userCache, err := model.GetUserCache(userId)
+	if err != nil {
+		newAPIError = types.NewError(err, types.ErrorCodeQueryDataError)
+		return
+	}
+	userCache.WriteContext(c)
+
 	tempToken := &model.Token{
 	tempToken := &model.Token{
 		UserId: userId,
 		UserId: userId,
 		Name:   fmt.Sprintf("playground-%s", group),
 		Name:   fmt.Sprintf("playground-%s", group),
 		Group:  group,
 		Group:  group,
 	}
 	}
 	_ = middleware.SetupContextForToken(c, tempToken)
 	_ = middleware.SetupContextForToken(c, tempToken)
-	_, newAPIError = getChannel(c, group, playgroundRequest.Model, 1)
+	_, newAPIError = getChannel(c, group, playgroundRequest.Model, 0)
 	if newAPIError != nil {
 	if newAPIError != nil {
 		return
 		return
 	}
 	}
 	//middleware.SetupContextForSelectedChannel(c, channel, playgroundRequest.Model)
 	//middleware.SetupContextForSelectedChannel(c, channel, playgroundRequest.Model)
 	common.SetContextKey(c, constant.ContextKeyRequestStartTime, time.Now())
 	common.SetContextKey(c, constant.ContextKeyRequestStartTime, time.Now())
 
 
-	// Write user context to ensure acceptUnsetRatio is available
-	userCache, err := model.GetUserCache(userId)
-	if err != nil {
-		newAPIError = types.NewError(err, types.ErrorCodeQueryDataError)
-		return
-	}
-	userCache.WriteContext(c)
 	Relay(c)
 	Relay(c)
 }
 }

middleware/auth.go

@@ -124,16 +124,16 @@ func authHelper(c *gin.Context, minRole int) {
 	c.Set("group", session.Get("group"))
 	c.Set("group", session.Get("group"))
 	c.Set("use_access_token", useAccessToken)
 	c.Set("use_access_token", useAccessToken)
 
 
-	userCache, err := model.GetUserCache(id.(int))
-	if err != nil {
-		c.JSON(http.StatusOK, gin.H{
-			"success": false,
-			"message": err.Error(),
-		})
-		c.Abort()
-		return
-	}
-	userCache.WriteContext(c)
+	//userCache, err := model.GetUserCache(id.(int))
+	//if err != nil {
+	//	c.JSON(http.StatusOK, gin.H{
+	//		"success": false,
+	//		"message": err.Error(),
+	//	})
+	//	c.Abort()
+	//	return
+	//}
+	//userCache.WriteContext(c)
 
 
 	c.Next()
 	c.Next()
 }
 }

model/ability.go

@@ -87,26 +87,29 @@ func getPriority(group string, model string, retry int) (int, error) {
 	return priorityToUse, nil
 	return priorityToUse, nil
 }
 }
 
 
-func getChannelQuery(group string, model string, retry int) *gorm.DB {
+func getChannelQuery(group string, model string, retry int) (*gorm.DB, error) {
 	maxPrioritySubQuery := DB.Model(&Ability{}).Select("MAX(priority)").Where(commonGroupCol+" = ? and model = ? and enabled = ?", group, model, true)
 	maxPrioritySubQuery := DB.Model(&Ability{}).Select("MAX(priority)").Where(commonGroupCol+" = ? and model = ? and enabled = ?", group, model, true)
 	channelQuery := DB.Where(commonGroupCol+" = ? and model = ? and enabled = ? and priority = (?)", group, model, true, maxPrioritySubQuery)
 	channelQuery := DB.Where(commonGroupCol+" = ? and model = ? and enabled = ? and priority = (?)", group, model, true, maxPrioritySubQuery)
 	if retry != 0 {
 	if retry != 0 {
 		priority, err := getPriority(group, model, retry)
 		priority, err := getPriority(group, model, retry)
 		if err != nil {
 		if err != nil {
-			common.SysError(fmt.Sprintf("Get priority failed: %s", err.Error()))
+			return nil, err
 		} else {
 		} else {
 			channelQuery = DB.Where(commonGroupCol+" = ? and model = ? and enabled = ? and priority = ?", group, model, true, priority)
 			channelQuery = DB.Where(commonGroupCol+" = ? and model = ? and enabled = ? and priority = ?", group, model, true, priority)
 		}
 		}
 	}
 	}
 
 
-	return channelQuery
+	return channelQuery, nil
 }
 }
 
 
 func GetRandomSatisfiedChannel(group string, model string, retry int) (*Channel, error) {
 func GetRandomSatisfiedChannel(group string, model string, retry int) (*Channel, error) {
 	var abilities []Ability
 	var abilities []Ability
 
 
 	var err error = nil
 	var err error = nil
-	channelQuery := getChannelQuery(group, model, retry)
+	channelQuery, err := getChannelQuery(group, model, retry)
+	if err != nil {
+		return nil, err
+	}
 	if common.UsingSQLite || common.UsingPostgreSQL {
 	if common.UsingSQLite || common.UsingPostgreSQL {
 		err = channelQuery.Order("weight DESC").Find(&abilities).Error
 		err = channelQuery.Order("weight DESC").Find(&abilities).Error
 	} else {
 	} else {