Add RenderBumperPreviewCommandHandler: implement command handler for rendering bumper previews, including channel and template validation, audio duration handling, and rendering logic for bumper variants.

2026-07-25 23:14:46 +03:00
parent 058cbc6994
commit a261e261f0
1 changed files with 0 additions and 0 deletions
@@ -0,0 +1,123 @@
+using LiteCqrs;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Options;
+using TeleWave.Application.Common.Interfaces;
+using TeleWave.Application.Common.Models;
+using TeleWave.Application.Streaming;
+using TeleWave.Domain.Broadcast;
+
+namespace TeleWave.Application.Broadcast.Bumpers;
+
+public sealed class RenderBumperPreviewQueryHandler(
+    IAppDbContext dbContext,
+    IBumperRenderer renderer,
+    IBumperTemplateStorage storage,
+    IImageStore imageStore,
+    IOptions<BumperOptions> bumperOptions,
+    IOptions<StreamingOptions> streamingOptions
+) : IQueryHandler<RenderBumperPreviewQuery, Result>
+{
+    private readonly BumperOptions _bumper = bumperOptions.Value;
+    private readonly int _segmentSeconds = Math.Max(1, streamingOptions.Value.SegmentSeconds);
+
+    /// <summary>Длительность заставки без загруженного звука (сек) — как в генераторе.</summary>
+    private const int DefaultBumperDurationSeconds = 8;
+
+    public async Task<Result> Handle(
+        RenderBumperPreviewQuery query,
+        CancellationToken cancellationToken
+    )
+    {
+        var channel = await dbContext
+            .Channels.AsNoTracking()
+            .Include(c => c.BumperTemplates)
+                .ThenInclude(t => t.Variants)
+            .Include(c => c.Shows)
+            .AsSplitQuery()
+            .FirstOrDefaultAsync(c => c.Id == query.ChannelId, cancellationToken);
+        if (channel is null)
+            return Result.Failure(ChannelErrors.NotFound);
+
+        var template = channel.BumperTemplates.FirstOrDefault(t => t.Id == query.TemplateId);
+        if (template is null)
+            return Result.Failure(ChannelErrors.BumperTemplateNotFound);
+
+        var (fromName, toName) = await SampleNamesAsync(channel, cancellationToken);
+        var fontFile =
+            channel.BumperFont == BumperFont.Serif ? _bumper.FontFileSerif : _bumper.FontFileSans;
+
+        // Фон блока — из общего реестра по id (общий для всех подблоков).
+        string? backgroundPath = null;
+        if (template.BackgroundImageId is { } bgId)
+        {
+            var bgExt = await dbContext
+                .Images.AsNoTracking()
+                .Where(i => i.Id == bgId)
+                .Select(i => i.FileExtension)
+                .FirstOrDefaultAsync(cancellationToken);
+            if (bgExt is not null)
+                backgroundPath = imageStore.ResolvePath(bgId, bgExt);
+        }
+
+        var seconds = template.AudioDurationSeconds is { } d and > 0
+            ? d
+            : DefaultBumperDurationSeconds;
+        var aligned = (int)(
+            Math.Ceiling(Math.Max(_segmentSeconds, seconds) / _segmentSeconds) * _segmentSeconds
+        );
+        var audioPath = storage.AudioPath(template.Id, template.AudioExtension);
+
+        // Рендерим каждый подблок в свой ассет-превью (id по подблоку).
+        foreach (var variant in template.Variants.OrderBy(v => v.Position))
+        {
+            var free = variant.Kind == BumperTextKind.Free;
+            var spec = new BumperRenderSpec(
+                aligned,
+                _bumper.Width,
+                _bumper.Height,
+                template.BackgroundColor,
+                template.BackgroundColor2,
+                template.AccentColor,
+                template.TextColor,
+                fontFile,
+                free ? "" : variant.NowLabel,
+                free ? "" : fromName,
+                free ? "" : variant.NextLabel,
+                free ? "" : toName,
+                backgroundPath,
+                audioPath,
+                // Постер зависит от конкретного «следующего» шоу — в превью не подставляем.
+                null,
+                free,
+                variant.Line1,
+                variant.Line2
+            );
+            await renderer.RenderAsync(BumperPreview.AssetId(variant.Id), spec, cancellationToken);
+        }
+
+        return Result.Success();
+    }
+
+    /// <summary>Примерные названия «из/в» — берём первые два шоу канала, иначе заглушки.</summary>
+    private async Task<(string From, string To)> SampleNamesAsync(
+        Channel channel,
+        CancellationToken cancellationToken
+    )
+    {
+        var showIds = channel.Shows.Select(s => s.ShowId).Distinct().Take(2).ToList();
+        var names =
+            showIds.Count == 0
+                ? []
+                : await dbContext
+                    .Shows.AsNoTracking()
+                    .Where(s => showIds.Contains(s.Id))
+                    .Select(s => s.Name)
+                    .Take(2)
+                    .ToListAsync(cancellationToken);
+
+        return (
+            names.ElementAtOrDefault(0) ?? "Первое шоу",
+            names.ElementAtOrDefault(1) ?? "Второе шоу"
+        );
+    }
+}