rogee/quyun-v2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: tenant content publish

Browse Source
This commit is contained in:
Rogee
2025-12-25 14:29:16 +08:00
parent a66c0d9b90
commit 6542c71ec0
15 changed files with 1082 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

283
backend/app/services/content.go
View File

@@ -2,7 +2,9 @@ package services
import (
"context"
"encoding/json"
"errors"
"strings"
"time"
"quyun/v2/app/errorx"
@@ -16,6 +18,7 @@ import (
"github.com/samber/lo"
log "github.com/sirupsen/logrus"
"go.ipao.vip/gen"
"go.ipao.vip/gen/types"
"gorm.io/gorm"
)
@@ -34,6 +37,20 @@ type ContentDetailResult struct {
HasAccess bool
}
// ContentPublishResult 为“内容发布（创建+绑定资源+定价）”的内部结果。
type ContentPublishResult struct {
// Content 内容主体。
Content *models.Content
// Price 定价信息。
Price *models.ContentPrice
// CoverAssets 封面图绑定结果（role=cover）。
CoverAssets []*models.ContentAsset
// MainAssets 主资源绑定结果（role=main）。
MainAssets []*models.ContentAsset
// ContentTypes 内容类型列表：text/audio/video/image/multi_image（用于前端展示）。
ContentTypes []string
}
func requiredMediaAssetVariantForRole(role consts.ContentAssetRole) consts.MediaAssetVariant {
switch role {
case consts.ContentAssetRolePreview:
@@ -78,6 +95,272 @@ func (s *content) Create(ctx context.Context, tenantID, userID int64, form *dto.
return m, nil
}
// Publish 租户管理员发布内容（创建内容 + 绑定封面/主资源 + 定价）。
// 说明：此接口面向“创作者/租户管理员”的内容发布场景，支持多种内容类型组合存在。
func (s *content) Publish(ctx context.Context, tenantID, userID int64, form *dto.ContentPublishForm) (*ContentPublishResult, error) {
if tenantID <= 0 || userID <= 0 {
return nil, errorx.ErrInvalidParameter.WithMsg("tenant_id/user_id must be > 0")
}
if form == nil {
return nil, errorx.ErrMissingParameter.WithMsg("form is required")
}
title := strings.TrimSpace(form.Title)
if title == "" {
return nil, errorx.ErrMissingParameter.WithMsg("请填写标题")
}
summary := strings.TrimSpace(form.Summary)
if len([]rune(summary)) > 256 {
return nil, errorx.ErrInvalidParameter.WithMsg("简介过长（建议不超过 256 字符）")
}
detail := strings.TrimSpace(form.Detail)
if len(form.CoverAssetIDs) < 1 || len(form.CoverAssetIDs) > 3 {
return nil, errorx.ErrInvalidParameter.WithMsg("展示图需为 1-3 张")
}
hasText := detail != ""
hasAudio := len(form.AudioAssetIDs) > 0
hasVideo := len(form.VideoAssetIDs) > 0
hasImage := len(form.ImageAssetIDs) > 0
if !hasText && !hasAudio && !hasVideo && !hasImage {
return nil, errorx.ErrInvalidParameter.WithMsg("请至少提供一种内容类型（文字/音频/视频/多图）")
}
visibility := form.Visibility
if visibility == "" {
visibility = consts.ContentVisibilityTenantOnly
}
previewSeconds := consts.DefaultContentPreviewSeconds
if form.PreviewSeconds != nil && *form.PreviewSeconds > 0 {
previewSeconds = *form.PreviewSeconds
}
currency := form.Currency
if currency == "" {
currency = consts.CurrencyCNY
}
if form.PriceAmount < 0 {
return nil, errorx.ErrInvalidParameter.WithMsg("价格不合法（需为 0 或正整数）")
}
// 标签：trim + 去重；限制数量与长度，避免滥用导致索引/存储膨胀。
tags := make([]string, 0, len(form.Tags))
seenTag := map[string]struct{}{}
for _, raw := range form.Tags {
v := strings.TrimSpace(raw)
if v == "" {
continue
}
if len([]rune(v)) > 20 {
return nil, errorx.ErrInvalidParameter.WithMsg("标签过长（单个标签建议不超过 20 字符）")
}
if _, ok := seenTag[v]; ok {
continue
}
seenTag[v] = struct{}{}
tags = append(tags, v)
if len(tags) >= 20 {
return nil, errorx.ErrInvalidParameter.WithMsg("标签数量过多（建议不超过 20 个）")
}
}
tagBytes, _ := json.Marshal(tags)
if len(tagBytes) == 0 {
tagBytes = []byte("[]")
}
// 资源去重与批量拉取。
allAssetIDs := make([]int64, 0, len(form.CoverAssetIDs)+len(form.AudioAssetIDs)+len(form.VideoAssetIDs)+len(form.ImageAssetIDs))
assetSeen := map[int64]struct{}{}
addIDs := func(ids []int64) error {
for _, id := range ids {
if id <= 0 {
return errorx.ErrInvalidParameter.WithMsg("资源ID不合法")
}
if _, ok := assetSeen[id]; ok {
return errorx.ErrInvalidParameter.WithMsg("同一资源不可重复绑定（封面/主资源之间也不可重复）")
}
assetSeen[id] = struct{}{}
allAssetIDs = append(allAssetIDs, id)
}
return nil
}
if err := addIDs(form.CoverAssetIDs); err != nil {
return nil, err
}
if err := addIDs(form.AudioAssetIDs); err != nil {
return nil, err
}
if err := addIDs(form.VideoAssetIDs); err != nil {
return nil, err
}
if err := addIDs(form.ImageAssetIDs); err != nil {
return nil, err
}
out := &ContentPublishResult{}
log.WithFields(log.Fields{
"tenant_id": tenantID,
"user_id": userID,
"title": title,
"price": form.PriceAmount,
}).Info("services.content.publish")
err := models.Q.Transaction(func(tx *models.Query) error {
// 1) 校验资源（必须属于租户、未删除、ready、variant=main）
assetTbl, assetQuery := tx.MediaAsset.QueryContext(ctx)
assets, err := assetQuery.Where(
assetTbl.TenantID.Eq(tenantID),
assetTbl.ID.In(allAssetIDs...),
assetTbl.DeletedAt.IsNull(),
).Find()
if err != nil {
return err
}
assetMap := make(map[int64]*models.MediaAsset, len(assets))
for _, a := range assets {
if a == nil {
continue
}
assetMap[a.ID] = a
}
for _, id := range allAssetIDs {
a := assetMap[id]
if a == nil {
return errorx.ErrRecordNotFound.WithMsg("资源不存在或无权限访问")
}
if a.Status != consts.MediaAssetStatusReady {
return errorx.ErrPreconditionFailed.WithMsg("存在未处理完成的资源，请稍后再试")
}
if a.Variant != consts.MediaAssetVariantMain {
return errorx.ErrInvalidParameter.WithMsg("资源产物类型不正确（需为正片 main）")
}
}
// 2) 创建内容（默认进入审核中）
content := &models.Content{
TenantID: tenantID,
UserID: userID,
Title: title,
Summary: summary,
Description: detail,
Tags: types.JSON(tagBytes),
Status: consts.ContentStatusReviewing,
Visibility: visibility,
PreviewSeconds: previewSeconds,
PreviewDownloadable: false,
}
if err := tx.Content.WithContext(ctx).Create(content); err != nil {
return err
}
// 3) 创建定价（固定 CNY，折扣默认 none）
price := &models.ContentPrice{
TenantID: tenantID,
UserID: userID,
ContentID: content.ID,
Currency: currency,
PriceAmount: form.PriceAmount,
DiscountType: consts.DiscountTypeNone,
DiscountValue: 0,
DiscountStartAt: time.Time{},
DiscountEndAt: time.Time{},
}
if err := tx.ContentPrice.WithContext(ctx).Create(price); err != nil {
return err
}
// 4) 绑定封面图（role=cover）
coverAssets := make([]*models.ContentAsset, 0, len(form.CoverAssetIDs))
for i, id := range form.CoverAssetIDs {
a := assetMap[id]
if a.Type != consts.MediaAssetTypeImage {
return errorx.ErrInvalidParameter.WithMsg("展示图必须为图片资源")
}
ca := &models.ContentAsset{
TenantID: tenantID,
UserID: userID,
ContentID: content.ID,
AssetID: id,
Role: consts.ContentAssetRoleCover,
Sort: int32(i),
}
if err := tx.ContentAsset.WithContext(ctx).Create(ca); err != nil {
return err
}
coverAssets = append(coverAssets, ca)
}
// 5) 绑定主资源（role=main；支持音频/视频/多图组合）
mainAssets := make([]*models.ContentAsset, 0, len(form.AudioAssetIDs)+len(form.VideoAssetIDs)+len(form.ImageAssetIDs))
sort := int32(0)
attachMain := func(ids []int64, wantType consts.MediaAssetType) error {
for _, id := range ids {
a := assetMap[id]
if a.Type != wantType {
return errorx.ErrInvalidParameter.WithMsg("主资源类型与选择不匹配")
}
ca := &models.ContentAsset{
TenantID: tenantID,
UserID: userID,
ContentID: content.ID,
AssetID: id,
Role: consts.ContentAssetRoleMain,
Sort: sort,
}
if err := tx.ContentAsset.WithContext(ctx).Create(ca); err != nil {
return err
}
mainAssets = append(mainAssets, ca)
sort++
}
return nil
}
// 顺序：视频 -> 音频 -> 图片（多图）
if err := attachMain(form.VideoAssetIDs, consts.MediaAssetTypeVideo); err != nil {
return err
}
if err := attachMain(form.AudioAssetIDs, consts.MediaAssetTypeAudio); err != nil {
return err
}
if err := attachMain(form.ImageAssetIDs, consts.MediaAssetTypeImage); err != nil {
return err
}
typesOut := make([]string, 0, 4)
if hasText {
typesOut = append(typesOut, "text")
}
if hasAudio {
typesOut = append(typesOut, "audio")
}
if hasVideo {
typesOut = append(typesOut, "video")
}
if hasImage {
if len(form.ImageAssetIDs) >= 2 {
typesOut = append(typesOut, "multi_image")
} else {
typesOut = append(typesOut, "image")
}
}
out.Content = content
out.Price = price
out.CoverAssets = coverAssets
out.MainAssets = mainAssets
out.ContentTypes = typesOut
return nil
})
if err != nil {
return nil, err
}
return out, nil
}
func (s *content) Update(ctx context.Context, tenantID, userID, contentID int64, form *dto.ContentUpdateForm) (*models.Content, error) {
log.WithFields(log.Fields{
"tenant_id": tenantID,