using SharedKernel.Helpers; using Application.Abstractions.Messaging; using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc.RazorPages; using System.ComponentModel; using System.ComponentModel.DataAnnotations; namespace Admin.Pages.Mail; public class ListModel(IMediator mediator) : PageModel { [BindProperty(SupportsGet = true)] public QueryParams Query { get; set; } = new(); public sealed class QueryParams { [Range(1, int.MaxValue)] [DisplayName("페이지 번호")] public int PageNum { get; set; } = 1; [Range(1, 100)] [DisplayName("페이지 목록 수")] public ushort PerPage { get; set; } = 10; [DisplayName("검색 조건")] [Range(1, 4, ErrorMessage = "{0}이(가) 올바르지 않습니다.")] public int? Search { get; set; } [DisplayName("검색어")] [MaxLength(100, ErrorMessage = "{0}은(는) {1}자 이하로 입력하세요.")] public string? Keyword { get; set; } [DisplayName("시작일")] public string? StartAt { get; set; } [DisplayName("종료일")] public string? EndAt { get; set; } [DisplayName("탭")] [Range(0, 4)] public int Tab { get; set; } = 0; } public int Total { get; set; } = 0; public int PendingCount { get; set; } = 0; public int ProcessingCount { get; set; } = 0; public int SentCount { get; set; } = 0; public int FailedCount { get; set; } = 0; public List List { get; set; } = []; public Pagination? Pagination { get; set; } public async Task OnGetAsync(CancellationToken ct) { if (!ModelState.IsValid) { return; } var result = await mediator.Send(new SearchEmailLogs.Query( Query.PageNum, Query.PerPage, Query.Search, Query.Keyword, Query.StartAt, Query.EndAt, Query.Tab ), ct); Total = result.Total; PendingCount = result.Pending; ProcessingCount = result.Processing; SentCount = result.Sent; FailedCount = result.Failed; List = [.. result.List]; Pagination = new Pagination(result.Total, Query.PageNum, Query.PerPage, Request.QueryString.ToString()); } public async Task OnPostResendAsync(long[] ids, CancellationToken ct) { try { if (ids is null || ids.Length == 0) { throw new Exception("재전송할 항목을 선택해주세요."); } await mediator.Send(new ResendEmailLog.Command(ids), ct); TempData["SuccessMessage"] = $"{ids.Length}건이 재전송 대기열에 추가되었습니다."; } catch (Exception e) { TempData["ErrorMessages"] = e.Message; } return Redirect($"{Request.Path}{Request.QueryString}"); } public async Task OnPostDeleteAsync(long[] ids, CancellationToken ct) { try { if (ids is null || ids.Length == 0) { throw new Exception("삭제할 항목을 선택해주세요."); } await mediator.Send(new DeleteEmailLog.Command(ids), ct); TempData["SuccessMessage"] = $"{ids.Length}건이 삭제되었습니다."; } catch (Exception e) { TempData["ErrorMessages"] = e.Message; } return Redirect($"{Request.Path}{Request.QueryString}"); } }