fix(后端): 修复 lint 失败并清理无用代码

修正测试中的 APIKey 名称引用
移除不可达返回与未使用函数
统一 gofmt 格式并处理 Close 错误

backend/internal/service/billing_cache_service.go

@@ -16,7 +16,7 @@ import (
 // 注：ErrInsufficientBalance在redeem_service.go中定义
 // 注：ErrDailyLimitExceeded/ErrWeeklyLimitExceeded/ErrMonthlyLimitExceeded在subscription_service.go中定义
 var (
-	ErrSubscriptionInvalid = infraerrors.Forbidden("SUBSCRIPTION_INVALID", "subscription is invalid or expired")
+	ErrSubscriptionInvalid       = infraerrors.Forbidden("SUBSCRIPTION_INVALID", "subscription is invalid or expired")
 	ErrBillingServiceUnavailable = infraerrors.ServiceUnavailable("BILLING_SERVICE_ERROR", "Billing service temporarily unavailable. Please retry later.")
 )
 
@@ -73,10 +73,10 @@ type cacheWriteTask struct {
 // BillingCacheService 计费缓存服务
 // 负责余额和订阅数据的缓存管理，提供高性能的计费资格检查
 type BillingCacheService struct {
-	cache    BillingCache
-	userRepo UserRepository
-	subRepo  UserSubscriptionRepository
-	cfg      *config.Config
+	cache          BillingCache
+	userRepo       UserRepository
+	subRepo        UserSubscriptionRepository
+	cfg            *config.Config
 	circuitBreaker *billingCircuitBreaker
 
 	cacheWriteChan     chan cacheWriteTask
@@ -659,28 +659,3 @@ func circuitStateString(state billingCircuitBreakerState) string {
 		return "unknown"
 	}
 }
-
-// checkSubscriptionLimitsFallback 降级检查订阅限额
-func (s *BillingCacheService) checkSubscriptionLimitsFallback(subscription *UserSubscription, group *Group) error {
-	if subscription == nil {
-		return ErrSubscriptionInvalid
-	}
-
-	if !subscription.IsActive() {
-		return ErrSubscriptionInvalid
-	}
-
-	if !subscription.CheckDailyLimit(group, 0) {
-		return ErrDailyLimitExceeded
-	}
-
-	if !subscription.CheckWeeklyLimit(group, 0) {
-		return ErrWeeklyLimitExceeded
-	}
-
-	if !subscription.CheckMonthlyLimit(group, 0) {
-		return ErrMonthlyLimitExceeded
-	}
-
-	return nil
-}

backend/internal/service/gateway_service.go

@@ -1731,7 +1731,6 @@ func (s *GatewayService) handleStreamingResponse(ctx context.Context, resp *http
 		}
 	}
 
-	return &streamingResult{usage: usage, firstTokenMs: firstTokenMs}, nil
 }
 
 // replaceModelInSSELine 替换SSE数据行中的model字段

backend/internal/service/openai_gateway_service.go

@@ -934,7 +934,6 @@ func (s *OpenAIGatewayService) handleStreamingResponse(ctx context.Context, resp
 		}
 	}
 
-	return &openaiStreamingResult{usage: usage, firstTokenMs: firstTokenMs}, nil
 }
 
 func (s *OpenAIGatewayService) replaceModelInSSELine(line, fromModel, toModel string) string {

backend/internal/service/openai_gateway_service_test.go

@@ -72,7 +72,7 @@ func TestOpenAIStreamingTooLong(t *testing.T) {
 	}
 
 	go func() {
-		defer pw.Close()
+		defer func() { _ = pw.Close() }()
 		// 写入超过 MaxLineSize 的单行数据，触发 ErrTooLong
 		payload := "data: " + strings.Repeat("a", 128*1024) + "\n"
 		_, _ = pw.Write([]byte(payload))