ANTOOZA-BACKEND/Admin/Pages/Channel/List/Index.cshtml.cs

using SharedKernel.Helpers;
using SharedKernel.Extensions;
using Application.Abstractions.YouTube;
using MediatR;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.RazorPages;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;

namespace Admin.Pages.Channel.List;

public class IndexModel(IMediator mediator, IYouTubeLiveStateStore liveStateStore) : PageModel
{
    [BindProperty(SupportsGet = true)]
    public QueryParams Query { get; set; } = new();

    public sealed class QueryParams
    {
        public int? Search { get; set; }
        public string? Keyword { get; set; }
        public string? StartAt { get; set; }
        public string? EndAt { get; set; }
        public bool? IsVerified { get; set; }

        [Range(1, int.MaxValue)]
        [DisplayName("페이지 번호")]
        public int PageNum { get; set; } = 1;

        [Range(1, 100)]
        [DisplayName("페이지 목록 수")]
        public ushort PerPage { get; set; } = 20;
    }

    public int Total { get; set; } = 0;

    public List<(
        int Num,
        int ID,
        string SID,
        string Name,
        string? Handle,
        string? ThumbnailUrl,
        string YouTubeUrl,
        decimal PlatformFeeRate,
        char IsVerified,
        char IsActive,
        int MemberID,
        string? MemberName,
        string? MemberEmail,
        string? UpdatedAt,
        string CreatedAt
    )> List { get; set; } = [];

    public Pagination? Pagination { get; set; }

    /// <summary>현재 라이브 중인 채널 SID(=YouTube 채널 ID) 집합</summary>
    public HashSet<string> LiveChannelIds { get; set; } = [];

    public async Task OnGetAsync(CancellationToken ct)
    {
        if (!ModelState.IsValid)
        {
            return;
        }

        var result = await mediator.Send(new SearchChannels.Query(
            Query.Search,
            Query.Keyword,
            Query.IsVerified,
            Query.StartAt,
            Query.EndAt,
            Query.PageNum,
            Query.PerPage
        ), ct);

        Total = result.Total;
        List = [..result.List.Select(c => (
            c.Num,
            c.ID,
            c.SID,
            c.Name,
            c.Handle,
            c.ThumbnailUrl,
            c.YouTubeUrl,
            c.PlatformFeeRate,
            c.IsVerified ? 'Y' : 'N',
            c.IsActive ? 'Y' : 'N',
            c.MemberID,
            c.MemberName ?? "-",
            c.MemberEmail ?? "-",
            c.UpdatedAt.GetDateAt() ?? "-",
            c.CreatedAt.GetDateAt()
        ))];

        Pagination = new Pagination(result.Total, Query.PageNum, Query.PerPage);

        // Redis에서 현재 라이브 중인 채널 ID 조회 (API 호출 없음)
        var allLive = await liveStateStore.GetAllLiveAsync();

        LiveChannelIds = [..allLive.Select(l => l.ChannelId)];
    }

    public async Task<IActionResult> OnPostDeleteAsync(int[] ids, CancellationToken ct)
    {
        try
        {
            await mediator.Send(new DeleteChannel.Command(ids), ct);

            TempData["SuccessMessage"] = $"{ids.Length}건이 삭제되었습니다.";
        }
        catch (InvalidOperationException e)
        {
            TempData["ErrorMessages"] = e.Message;
        }
        catch (Microsoft.EntityFrameworkCore.DbUpdateException e)
        {
            var detail = e.InnerException?.Message ?? e.Message;
            TempData["ErrorMessages"] = $"데이터베이스 제약 조건 위반으로 삭제할 수 없습니다. 연관된 데이터를 먼저 정리해 주세요.\n상세: {detail}";
        }
        catch (Exception e)
        {
            TempData["ErrorMessages"] = e.Message;
        }

        return RedirectToPage("/Channel/List/Index", Query);
    }
}