fix

internal/infrastructure/database/repositories/product/gorm_product_repository.go

@@ -183,6 +183,110 @@ func (r *GormProductRepository) ListProducts(ctx context.Context, query *queries
 	return result, total, nil
 }
 
+// ListProductsWithSubscriptionStatus 获取产品列表（包含订阅状态）
+func (r *GormProductRepository) ListProductsWithSubscriptionStatus(ctx context.Context, query *queries.ListProductsQuery) ([]*entities.Product, map[string]bool, int64, error) {
+	var productEntities []entities.Product
+	var total int64
+
+	dbQuery := r.GetDB(ctx).Model(&entities.Product{})
+
+	// 应用筛选条件
+	if query.Keyword != "" {
+		dbQuery = dbQuery.Where("name LIKE ? OR description LIKE ? OR code LIKE ?",
+			"%"+query.Keyword+"%", "%"+query.Keyword+"%", "%"+query.Keyword+"%")
+	}
+	if query.CategoryID != "" {
+		dbQuery = dbQuery.Where("category_id = ?", query.CategoryID)
+	}
+	if query.MinPrice != nil {
+		dbQuery = dbQuery.Where("price >= ?", *query.MinPrice)
+	}
+	if query.MaxPrice != nil {
+		dbQuery = dbQuery.Where("price <= ?", *query.MaxPrice)
+	}
+	if query.IsEnabled != nil {
+		dbQuery = dbQuery.Where("is_enabled = ?", *query.IsEnabled)
+	}
+	if query.IsVisible != nil {
+		dbQuery = dbQuery.Where("is_visible = ?", *query.IsVisible)
+	}
+	if query.IsPackage != nil {
+		dbQuery = dbQuery.Where("is_package = ?", *query.IsPackage)
+	}
+
+	// 如果指定了用户ID，添加订阅状态筛选
+	if query.UserID != "" && query.IsSubscribed != nil {
+		if *query.IsSubscribed {
+			// 筛选已订阅的产品
+			dbQuery = dbQuery.Where("EXISTS (SELECT 1 FROM subscription WHERE subscription.product_id = product.id AND subscription.user_id = ?)", query.UserID)
+		} else {
+			// 筛选未订阅的产品
+			dbQuery = dbQuery.Where("NOT EXISTS (SELECT 1 FROM subscription WHERE subscription.product_id = product.id AND subscription.user_id = ?)", query.UserID)
+		}
+	}
+
+	// 获取总数
+	if err := dbQuery.Count(&total).Error; err != nil {
+		return nil, nil, 0, err
+	}
+
+	// 应用排序
+	if query.SortBy != "" {
+		order := query.SortBy
+		if query.SortOrder == "desc" {
+			order += " DESC"
+		} else {
+			order += " ASC"
+		}
+		dbQuery = dbQuery.Order(order)
+	} else {
+		dbQuery = dbQuery.Order("created_at DESC")
+	}
+
+	// 应用分页
+	if query.Page > 0 && query.PageSize > 0 {
+		offset := (query.Page - 1) * query.PageSize
+		dbQuery = dbQuery.Offset(offset).Limit(query.PageSize)
+	}
+
+	// 预加载分类信息并获取数据
+	if err := dbQuery.Preload("Category").Find(&productEntities).Error; err != nil {
+		return nil, nil, 0, err
+	}
+
+	// 转换为指针切片
+	result := make([]*entities.Product, len(productEntities))
+	for i := range productEntities {
+		result[i] = &productEntities[i]
+	}
+
+	// 获取订阅状态映射
+	subscriptionStatusMap := make(map[string]bool)
+	if query.UserID != "" && len(result) > 0 {
+		productIDs := make([]string, len(result))
+		for i, product := range result {
+			productIDs[i] = product.ID
+		}
+
+		// 查询用户的订阅状态
+		var subscriptions []struct {
+			ProductID string `gorm:"column:product_id"`
+		}
+		err := r.GetDB(ctx).Table("subscription").
+			Select("product_id").
+			Where("user_id = ? AND product_id IN ?", query.UserID, productIDs).
+			Find(&subscriptions).Error
+
+		if err == nil {
+			for _, sub := range subscriptions {
+				subscriptionStatusMap[sub.ProductID] = true
+			}
+		}
+	}
+
+	return result, subscriptionStatusMap, total, nil
+}
+
 // FindSubscribableProducts 查找可订阅产品
 func (r *GormProductRepository) FindSubscribableProducts(ctx context.Context, userID string) ([]*entities.Product, error) {
 	var productEntities []entities.Product

internal/infrastructure/database/repositories/product/gorm_subscription_repository.go

@@ -15,7 +15,7 @@ import (
 )
 
 const (
-	SubscriptionsTable = "subscriptions"
+	SubscriptionsTable = "subscription"
 	SubscriptionCacheTTL = 60 * time.Minute
 )