Handler.cs 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. using Application.Abstractions.Channels;
  2. using Application.Abstractions.Data;
  3. using Application.Abstractions.Messaging;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Api.DonationAlert.GetSignatureImages;
  6. internal sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
  7. {
  8. public async Task<Response> Handle(Query request, CancellationToken ct)
  9. {
  10. var page = request.Page < 1 ? 1 : request.Page;
  11. var perPage = request.PerPage < 1 ? 6 : request.PerPage > 30 ? 30 : request.PerPage;
  12. var resolved = await ChannelIdentifierResolver.ResolveAsync(db, request.Identifier, ct);
  13. if (resolved.ChannelSID is null)
  14. {
  15. return new Response([], 0, false);
  16. }
  17. var channelID = await db.Channel.AsNoTracking()
  18. .Where(c => c.SID == resolved.ChannelSID && c.IsActive)
  19. .Select(c => (int?)c.ID)
  20. .FirstOrDefaultAsync(ct);
  21. if (channelID is null)
  22. {
  23. return new Response([], 0, false);
  24. }
  25. var baseQuery = db.DonationAlertConfig.AsNoTracking()
  26. .Where(c => c.ChannelID == channelID.Value
  27. && c.IsActive
  28. && c.EnableImage
  29. && c.ImageUrl != null);
  30. var total = await baseQuery.CountAsync(ct);
  31. var list = await baseQuery
  32. .OrderBy(c => c.Amount)
  33. .Skip((page - 1) * perPage)
  34. .Take(perPage)
  35. .Select(c => new SignatureItem(
  36. c.ID,
  37. c.Title,
  38. c.Amount,
  39. c.MatchType,
  40. c.ImageUrl!
  41. ))
  42. .ToListAsync(ct);
  43. var hasMore = page * perPage < total;
  44. return new Response(list, total, hasMore);
  45. }
  46. }