feat(club-membership): enhance club membership history queries and responses
Build and Deploy to Kubernetes / build-and-deploy (push) Failing after 17m54s

- Added filtering capabilities to GetClubMembershipHistoryQuery, allowing optional filters for UserId, ClubMembershipId, Action, and date range.
- Updated GetClubMembershipHistoryQueryHandler to utilize the new filter structure.
- Enhanced GetAllClubMembershipsQueryHandler to include LastPackage details in the response.
- Introduced new properties in GetAllClubMembershipsResponseModel for PackageId and PackageName.
- Updated Protobuf definitions to reflect changes in club membership history queries and responses.
- Refactored mapping configurations to accommodate new DTOs and filters.
This commit is contained in:
masoodafar-web
2026-06-22 22:19:44 +03:30
parent 6395f63ab5
commit f8794bbb63
41 changed files with 1590 additions and 74 deletions
@@ -1,4 +1,5 @@
using CMSMicroservice.Application.Common.Exceptions;
using CMSMicroservice.Application.Common.Helpers;
using CMSMicroservice.Application.Common.Interfaces;
using CMSMicroservice.Application.Common.Models;
using CMSMicroservice.Domain.Common;
@@ -272,6 +273,7 @@ public class ActivateClubMembershipCommandHandler : IRequestHandler<ActivateClub
foreach (var prevCycle in previousCycles)
{
prevCycle.IsCurrentCycle = false;
ClubMembershipCycleHistoryWriter.WriteCycleClosed(_context, prevCycle, reason: "شروع دوره جدید");
}
var maxCycleNumber = await _context.ClubMembershipCycles
@@ -293,6 +295,9 @@ public class ActivateClubMembershipCommandHandler : IRequestHandler<ActivateClub
_context.ClubMembershipCycles.Add(newCycle);
await _context.SaveChangesAsync(cancellationToken);
ClubMembershipCycleHistoryWriter.WriteCycleStarted(_context, newCycle, reason: "فعال‌سازی عضویت باشگاه");
await _context.SaveChangesAsync(cancellationToken);
_logger.LogInformation(
"Created ClubMembershipCycle #{CycleNumber} for UserId {UserId}, MembershipId {MembershipId}",
newCycle.CycleNumber,
@@ -13,6 +13,7 @@ public class GetAllClubMembershipsQueryHandler : IRequestHandler<GetAllClubMembe
{
var query = _context.ClubMemberships
.Include(x => x.User)
.Include(x => x.LastPackage)
.ApplyOrder(sortBy: request.SortBy)
.AsNoTracking()
.AsQueryable();
@@ -35,8 +36,10 @@ public class GetAllClubMembershipsQueryHandler : IRequestHandler<GetAllClubMembe
Id = x.Id,
UserId = x.UserId,
UserName = x.User != null ? $"{x.User.FirstName} {x.User.LastName}" : string.Empty,
PackageId = x.LastPackageId ?? 0,
PackageName = x.LastPackage != null ? x.LastPackage.Title : string.Empty,
IsActive = x.IsActive,
ActivatedAt = x.ActivatedAt,
ActivatedAt = x.LastActivationDate ?? x.ActivatedAt,
InitialContribution = x.InitialContribution,
TotalEarned = x.TotalEarned,
Created = x.Created,
@@ -11,6 +11,8 @@ public class GetAllClubMembershipsResponseModel
public long Id { get; set; }
public long UserId { get; set; }
public string UserName { get; set; } = string.Empty;
public long PackageId { get; set; }
public string PackageName { get; set; } = string.Empty;
public bool IsActive { get; set; }
public DateTime? ActivatedAt { get; set; }
public long InitialContribution { get; set; }
@@ -1,27 +1,17 @@
namespace CMSMicroservice.Application.ClubMembershipCQ.Queries.GetClubMembershipHistory;
/// <summary>
/// Query برای دریافت تاریخچه تغییرات عضویت باشگاه
/// </summary>
public record GetClubMembershipHistoryQuery : IRequest<GetClubMembershipHistoryResponseDto>
{
/// <summary>
/// شناسه عضویت (اختیاری)
/// </summary>
public long? MembershipId { get; init; }
/// <summary>
/// شناسه کاربر (اختیاری)
/// </summary>
public long? UserId { get; init; }
/// <summary>
/// موقعیت صفحه‌بندی
/// </summary>
public PaginationState? PaginationState { get; init; }
/// <summary>
/// مرتب‌سازی بر اساس
/// </summary>
public string? SortBy { get; init; }
public GetClubMembershipHistoryFilter? Filter { get; init; }
}
public class GetClubMembershipHistoryFilter
{
public long? UserId { get; set; }
public long? ClubMembershipId { get; set; }
public ClubMembershipAction? Action { get; set; }
public DateTime? CreatedFrom { get; set; }
public DateTime? CreatedTo { get; set; }
}
@@ -12,20 +12,30 @@ public class GetClubMembershipHistoryQueryHandler : IRequestHandler<GetClubMembe
public async Task<GetClubMembershipHistoryResponseDto> Handle(GetClubMembershipHistoryQuery request, CancellationToken cancellationToken)
{
var query = _context.ClubMembershipHistories
.Include(x => x.ClubMembership)
.ThenInclude(m => m!.User)
.AsNoTracking()
.AsQueryable();
if (request.MembershipId.HasValue)
if (request.Filter != null)
{
query = query.Where(x => x.ClubMembershipId == request.MembershipId.Value);
if (request.Filter.ClubMembershipId.HasValue)
query = query.Where(x => x.ClubMembershipId == request.Filter.ClubMembershipId.Value);
if (request.Filter.UserId.HasValue)
query = query.Where(x => x.UserId == request.Filter.UserId.Value);
if (request.Filter.Action.HasValue)
query = query.Where(x => x.Action == request.Filter.Action.Value);
if (request.Filter.CreatedFrom.HasValue)
query = query.Where(x => x.Created >= request.Filter.CreatedFrom.Value);
if (request.Filter.CreatedTo.HasValue)
query = query.Where(x => x.Created <= request.Filter.CreatedTo.Value);
}
if (request.UserId.HasValue)
{
query = query.Where(x => x.UserId == request.UserId.Value);
}
query = query.ApplyOrder(sortBy: request.SortBy ?? "Created"); // پیش‌فرض: جدیدترین اول
query = query.ApplyOrder(sortBy: request.SortBy ?? "-Created");
var meta = await query.GetMetaData(request.PaginationState, cancellationToken);
@@ -36,6 +46,9 @@ public class GetClubMembershipHistoryQueryHandler : IRequestHandler<GetClubMembe
Id = x.Id,
ClubMembershipId = x.ClubMembershipId,
UserId = x.UserId,
UserName = x.ClubMembership != null && x.ClubMembership.User != null
? $"{x.ClubMembership.User.FirstName} {x.ClubMembership.User.LastName}"
: string.Empty,
OldIsActive = x.OldIsActive,
NewIsActive = x.NewIsActive,
OldInitialContribution = x.OldInitialContribution,
@@ -4,31 +4,6 @@ public class GetClubMembershipHistoryQueryValidator : AbstractValidator<GetClubM
{
public GetClubMembershipHistoryQueryValidator()
{
RuleFor(x => x.MembershipId)
.GreaterThan(0)
.WithMessage("شناسه عضویت معتبر نیست")
.When(x => x.MembershipId.HasValue);
RuleFor(x => x.UserId)
.GreaterThan(0)
.WithMessage("شناسه کاربر معتبر نیست")
.When(x => x.UserId.HasValue);
RuleFor(x => x)
.Must(x => x.MembershipId.HasValue || x.UserId.HasValue)
.WithMessage("حداقل یکی از MembershipId یا UserId باید مقداردهی شود");
// Admin report: filters are all optional
}
public Func<object, string, Task<IEnumerable<string>>> ValidateValue => async (model, propertyName) =>
{
var result = await ValidateAsync(
ValidationContext<GetClubMembershipHistoryQuery>.CreateWithOptions(
(GetClubMembershipHistoryQuery)model,
x => x.IncludeProperties(propertyName)));
if (result.IsValid)
return Array.Empty<string>();
return result.Errors.Select(e => e.ErrorMessage);
};
}
@@ -11,6 +11,7 @@ public class GetClubMembershipHistoryResponseModel
public long Id { get; set; }
public long ClubMembershipId { get; set; }
public long UserId { get; set; }
public string UserName { get; set; } = string.Empty;
public bool OldIsActive { get; set; }
public bool NewIsActive { get; set; }
public long? OldInitialContribution { get; set; }
@@ -0,0 +1,46 @@
using CMSMicroservice.Domain.Entities.Club;
namespace CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetAllClubMembershipCycleByFilter;
public static class ClubMembershipCycleFilterExtensions
{
public static IQueryable<ClubMembershipCycle> ApplyClubMembershipCycleFilter(
this IQueryable<ClubMembershipCycle> query,
GetAllClubMembershipCycleByFilterFilter? filter)
{
if (filter == null) return query;
if (filter.UserId.HasValue)
query = query.Where(x => x.UserId == filter.UserId.Value);
if (filter.IsCurrentCycle.HasValue)
query = query.Where(x => x.IsCurrentCycle == filter.IsCurrentCycle.Value);
if (filter.PackageId.HasValue)
query = query.Where(x => x.PackageId == filter.PackageId.Value);
if (filter.CycleNumber.HasValue)
query = query.Where(x => x.CycleNumber == filter.CycleNumber.Value);
if (filter.PurchaseMethod.HasValue)
query = query.Where(x => x.PurchaseMethod == filter.PurchaseMethod.Value);
if (filter.MagicState.HasValue)
{
query = filter.MagicState.Value switch
{
1 => query.Where(x => x.MagicStartedAt != null && x.MagicCompletedAt == null),
2 => query.Where(x => x.MagicCompletedAt != null),
_ => query.Where(x => x.MagicStartedAt == null && x.MagicCompletedAt == null)
};
}
if (filter.PackagePurchasedFrom.HasValue)
query = query.Where(x => x.PackagePurchasedAt >= filter.PackagePurchasedFrom.Value);
if (filter.PackagePurchasedTo.HasValue)
query = query.Where(x => x.PackagePurchasedAt <= filter.PackagePurchasedTo.Value);
return query;
}
}
@@ -0,0 +1,47 @@
using CMSMicroservice.Domain.Enums;
namespace CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetAllClubMembershipCycleByFilter;
public record GetAllClubMembershipCycleByFilterQuery : IRequest<GetAllClubMembershipCycleByFilterResponseDto>
{
public PaginationState? PaginationState { get; init; }
public string? SortBy { get; init; }
public GetAllClubMembershipCycleByFilterFilter? Filter { get; init; }
}
public class GetAllClubMembershipCycleByFilterFilter
{
public long? UserId { get; set; }
public bool? IsCurrentCycle { get; set; }
public long? PackageId { get; set; }
public int? CycleNumber { get; set; }
public PackagePurchaseMethod? PurchaseMethod { get; set; }
/// <summary>0=none, 1=active magic, 2=completed magic</summary>
public int? MagicState { get; set; }
public DateTime? PackagePurchasedFrom { get; set; }
public DateTime? PackagePurchasedTo { get; set; }
}
public class GetAllClubMembershipCycleByFilterResponseDto
{
public MetaData MetaData { get; set; }
public List<GetAllClubMembershipCycleByFilterResponseModel>? Models { get; set; }
}
public class GetAllClubMembershipCycleByFilterResponseModel
{
public long Id { get; set; }
public long UserId { get; set; }
public string UserName { get; set; } = string.Empty;
public long ClubMembershipId { get; set; }
public int CycleNumber { get; set; }
public long PackageId { get; set; }
public string PackageName { get; set; } = string.Empty;
public long PackageAmount { get; set; }
public PackagePurchaseMethod PurchaseMethod { get; set; }
public DateTime PackagePurchasedAt { get; set; }
public DateTime? MagicStartedAt { get; set; }
public DateTime? MagicCompletedAt { get; set; }
public bool IsCurrentCycle { get; set; }
public DateTimeOffset Created { get; set; }
}
@@ -0,0 +1,49 @@
namespace CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetAllClubMembershipCycleByFilter;
public class GetAllClubMembershipCycleByFilterQueryHandler
: IRequestHandler<GetAllClubMembershipCycleByFilterQuery, GetAllClubMembershipCycleByFilterResponseDto>
{
private readonly IApplicationDbContext _context;
public GetAllClubMembershipCycleByFilterQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetAllClubMembershipCycleByFilterResponseDto> Handle(
GetAllClubMembershipCycleByFilterQuery request,
CancellationToken cancellationToken)
{
var query = _context.ClubMembershipCycles
.Include(x => x.User)
.Include(x => x.Package)
.AsNoTracking()
.ApplyClubMembershipCycleFilter(request.Filter)
.ApplyOrder(sortBy: request.SortBy ?? "-PackagePurchasedAt");
return new GetAllClubMembershipCycleByFilterResponseDto
{
MetaData = await query.GetMetaData(request.PaginationState, cancellationToken),
Models = await query
.PaginatedListAsync(paginationState: request.PaginationState)
.Select(x => new GetAllClubMembershipCycleByFilterResponseModel
{
Id = x.Id,
UserId = x.UserId,
UserName = x.User != null ? $"{x.User.FirstName} {x.User.LastName}" : string.Empty,
ClubMembershipId = x.ClubMembershipId,
CycleNumber = x.CycleNumber,
PackageId = x.PackageId,
PackageName = x.Package != null ? x.Package.Title : string.Empty,
PackageAmount = x.PackageAmount,
PurchaseMethod = x.PurchaseMethod,
PackagePurchasedAt = x.PackagePurchasedAt,
MagicStartedAt = x.MagicStartedAt,
MagicCompletedAt = x.MagicCompletedAt,
IsCurrentCycle = x.IsCurrentCycle,
Created = x.Created
})
.ToListAsync(cancellationToken)
};
}
}
@@ -0,0 +1,13 @@
namespace CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetClubMembershipCycleSummary;
public record GetClubMembershipCycleSummaryQuery : IRequest<GetClubMembershipCycleSummaryResponseDto>
{
public GetAllClubMembershipCycleByFilter.GetAllClubMembershipCycleByFilterFilter? Filter { get; init; }
}
public class GetClubMembershipCycleSummaryResponseDto
{
public long TotalCount { get; set; }
public long CurrentCycleCount { get; set; }
public long MagicActiveCount { get; set; }
}
@@ -0,0 +1,36 @@
using CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetAllClubMembershipCycleByFilter;
namespace CMSMicroservice.Application.ClubMembershipCycleCQ.Queries.GetClubMembershipCycleSummary;
public class GetClubMembershipCycleSummaryQueryHandler
: IRequestHandler<GetClubMembershipCycleSummaryQuery, GetClubMembershipCycleSummaryResponseDto>
{
private readonly IApplicationDbContext _context;
public GetClubMembershipCycleSummaryQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetClubMembershipCycleSummaryResponseDto> Handle(
GetClubMembershipCycleSummaryQuery request,
CancellationToken cancellationToken)
{
var query = _context.ClubMembershipCycles
.AsNoTracking()
.ApplyClubMembershipCycleFilter(request.Filter);
var totalCount = await query.LongCountAsync(cancellationToken);
var currentCycleCount = await query.LongCountAsync(x => x.IsCurrentCycle, cancellationToken);
var magicActiveCount = await query.LongCountAsync(
x => x.MagicStartedAt != null && x.MagicCompletedAt == null,
cancellationToken);
return new GetClubMembershipCycleSummaryResponseDto
{
TotalCount = totalCount,
CurrentCycleCount = currentCycleCount,
MagicActiveCount = magicActiveCount
};
}
}
@@ -0,0 +1,33 @@
using CMSMicroservice.Domain.Entities.History;
namespace CMSMicroservice.Application.ClubMembershipCycleHistoryCQ.Queries.GetAllClubMembershipCycleHistoryByFilter;
public static class ClubMembershipCycleHistoryFilterExtensions
{
public static IQueryable<ClubMembershipCycleHistory> ApplyClubMembershipCycleHistoryFilter(
this IQueryable<ClubMembershipCycleHistory> query,
GetAllClubMembershipCycleHistoryByFilterFilter? filter)
{
if (filter == null) return query;
if (filter.UserId.HasValue)
query = query.Where(x => x.UserId == filter.UserId.Value);
if (filter.ClubMembershipCycleId.HasValue)
query = query.Where(x => x.ClubMembershipCycleId == filter.ClubMembershipCycleId.Value);
if (filter.CycleNumber.HasValue)
query = query.Where(x => x.CycleNumber == filter.CycleNumber.Value);
if (filter.Action.HasValue)
query = query.Where(x => x.Action == filter.Action.Value);
if (filter.CreatedFrom.HasValue)
query = query.Where(x => x.Created >= filter.CreatedFrom.Value);
if (filter.CreatedTo.HasValue)
query = query.Where(x => x.Created <= filter.CreatedTo.Value);
return query;
}
}
@@ -0,0 +1,45 @@
using CMSMicroservice.Domain.Enums;
namespace CMSMicroservice.Application.ClubMembershipCycleHistoryCQ.Queries.GetAllClubMembershipCycleHistoryByFilter;
public record GetAllClubMembershipCycleHistoryByFilterQuery : IRequest<GetAllClubMembershipCycleHistoryByFilterResponseDto>
{
public PaginationState? PaginationState { get; init; }
public string? SortBy { get; init; }
public GetAllClubMembershipCycleHistoryByFilterFilter? Filter { get; init; }
}
public class GetAllClubMembershipCycleHistoryByFilterFilter
{
public long? UserId { get; set; }
public long? ClubMembershipCycleId { get; set; }
public int? CycleNumber { get; set; }
public ClubMembershipCycleAction? Action { get; set; }
public DateTime? CreatedFrom { get; set; }
public DateTime? CreatedTo { get; set; }
}
public class GetAllClubMembershipCycleHistoryByFilterResponseDto
{
public MetaData MetaData { get; set; }
public List<GetAllClubMembershipCycleHistoryByFilterResponseModel>? Models { get; set; }
}
public class GetAllClubMembershipCycleHistoryByFilterResponseModel
{
public long Id { get; set; }
public long ClubMembershipCycleId { get; set; }
public long UserId { get; set; }
public string UserName { get; set; } = string.Empty;
public int CycleNumber { get; set; }
public bool OldIsCurrentCycle { get; set; }
public bool NewIsCurrentCycle { get; set; }
public DateTime? OldMagicStartedAt { get; set; }
public DateTime? NewMagicStartedAt { get; set; }
public DateTime? OldMagicCompletedAt { get; set; }
public DateTime? NewMagicCompletedAt { get; set; }
public ClubMembershipCycleAction Action { get; set; }
public string? PerformedBy { get; set; }
public string? Reason { get; set; }
public DateTimeOffset Created { get; set; }
}
@@ -0,0 +1,52 @@
namespace CMSMicroservice.Application.ClubMembershipCycleHistoryCQ.Queries.GetAllClubMembershipCycleHistoryByFilter;
public class GetAllClubMembershipCycleHistoryByFilterQueryHandler
: IRequestHandler<GetAllClubMembershipCycleHistoryByFilterQuery, GetAllClubMembershipCycleHistoryByFilterResponseDto>
{
private readonly IApplicationDbContext _context;
public GetAllClubMembershipCycleHistoryByFilterQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetAllClubMembershipCycleHistoryByFilterResponseDto> Handle(
GetAllClubMembershipCycleHistoryByFilterQuery request,
CancellationToken cancellationToken)
{
var query = _context.ClubMembershipCycleHistories
.Include(x => x.ClubMembershipCycle)
.ThenInclude(c => c!.User)
.AsNoTracking()
.ApplyClubMembershipCycleHistoryFilter(request.Filter)
.ApplyOrder(sortBy: request.SortBy ?? "-Created");
return new GetAllClubMembershipCycleHistoryByFilterResponseDto
{
MetaData = await query.GetMetaData(request.PaginationState, cancellationToken),
Models = await query
.PaginatedListAsync(paginationState: request.PaginationState)
.Select(x => new GetAllClubMembershipCycleHistoryByFilterResponseModel
{
Id = x.Id,
ClubMembershipCycleId = x.ClubMembershipCycleId,
UserId = x.UserId,
UserName = x.ClubMembershipCycle != null && x.ClubMembershipCycle.User != null
? $"{x.ClubMembershipCycle.User.FirstName} {x.ClubMembershipCycle.User.LastName}"
: string.Empty,
CycleNumber = x.CycleNumber,
OldIsCurrentCycle = x.OldIsCurrentCycle,
NewIsCurrentCycle = x.NewIsCurrentCycle,
OldMagicStartedAt = x.OldMagicStartedAt,
NewMagicStartedAt = x.NewMagicStartedAt,
OldMagicCompletedAt = x.OldMagicCompletedAt,
NewMagicCompletedAt = x.NewMagicCompletedAt,
Action = x.Action,
PerformedBy = x.PerformedBy,
Reason = x.Reason,
Created = x.Created
})
.ToListAsync(cancellationToken)
};
}
}
@@ -0,0 +1,54 @@
using CMSMicroservice.Domain.Entities.Club;
using CMSMicroservice.Domain.Entities.History;
using CMSMicroservice.Domain.Enums;
namespace CMSMicroservice.Application.Common.Helpers;
public static class ClubMembershipCycleHistoryWriter
{
public static void WriteCycleStarted(
IApplicationDbContext context,
ClubMembershipCycle cycle,
string? performedBy = "System",
string? reason = null)
{
context.ClubMembershipCycleHistories.Add(new ClubMembershipCycleHistory
{
ClubMembershipCycleId = cycle.Id,
UserId = cycle.UserId,
CycleNumber = cycle.CycleNumber,
OldIsCurrentCycle = false,
NewIsCurrentCycle = cycle.IsCurrentCycle,
OldMagicStartedAt = null,
NewMagicStartedAt = cycle.MagicStartedAt,
OldMagicCompletedAt = null,
NewMagicCompletedAt = cycle.MagicCompletedAt,
Action = ClubMembershipCycleAction.Started,
PerformedBy = performedBy,
Reason = reason
});
}
public static void WriteCycleClosed(
IApplicationDbContext context,
ClubMembershipCycle cycle,
string? performedBy = "System",
string? reason = null)
{
context.ClubMembershipCycleHistories.Add(new ClubMembershipCycleHistory
{
ClubMembershipCycleId = cycle.Id,
UserId = cycle.UserId,
CycleNumber = cycle.CycleNumber,
OldIsCurrentCycle = true,
NewIsCurrentCycle = false,
OldMagicStartedAt = cycle.MagicStartedAt,
NewMagicStartedAt = cycle.MagicStartedAt,
OldMagicCompletedAt = cycle.MagicCompletedAt,
NewMagicCompletedAt = cycle.MagicCompletedAt,
Action = ClubMembershipCycleAction.Completed,
PerformedBy = performedBy,
Reason = reason ?? "دوره جدید جایگزین شد"
});
}
}
@@ -0,0 +1,46 @@
namespace CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetAllPaymentTransactionByFilter;
public record GetAllPaymentTransactionByFilterQuery : IRequest<GetAllPaymentTransactionByFilterResponseDto>
{
public PaginationState? PaginationState { get; init; }
public string? SortBy { get; init; }
public GetAllPaymentTransactionByFilterFilter? Filter { get; init; }
}
public class GetAllPaymentTransactionByFilterFilter
{
public long? UserId { get; set; }
public string? Mobile { get; set; }
public string? GatewayProvider { get; set; }
public bool? PaymentStatus { get; set; }
public string? Authority { get; set; }
public string? RefId { get; set; }
public string? OrderId { get; set; }
public DateTime? CreatedFrom { get; set; }
public DateTime? CreatedTo { get; set; }
}
public class GetAllPaymentTransactionByFilterResponseDto
{
public MetaData MetaData { get; set; }
public List<GetAllPaymentTransactionByFilterResponseModel>? Models { get; set; }
}
public class GetAllPaymentTransactionByFilterResponseModel
{
public long Id { get; set; }
public long? UserId { get; set; }
public string? Mobile { get; set; }
public string GatewayProvider { get; set; } = string.Empty;
public long Amount { get; set; }
public string? Authority { get; set; }
public bool PaymentStatus { get; set; }
public int? VerificationStatusCode { get; set; }
public string? VerificationStatusMessage { get; set; }
public string? RefId { get; set; }
public string? CardPan { get; set; }
public string? OrderId { get; set; }
public long? TransactionId { get; set; }
public string? Description { get; set; }
public DateTimeOffset Created { get; set; }
}
@@ -0,0 +1,48 @@
namespace CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetAllPaymentTransactionByFilter;
public class GetAllPaymentTransactionByFilterQueryHandler
: IRequestHandler<GetAllPaymentTransactionByFilterQuery, GetAllPaymentTransactionByFilterResponseDto>
{
private readonly IApplicationDbContext _context;
public GetAllPaymentTransactionByFilterQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetAllPaymentTransactionByFilterResponseDto> Handle(
GetAllPaymentTransactionByFilterQuery request,
CancellationToken cancellationToken)
{
var query = _context.PaymentTransactions
.AsNoTracking()
.ApplyPaymentTransactionFilter(request.Filter)
.ApplyOrder(sortBy: request.SortBy ?? "-Created");
return new GetAllPaymentTransactionByFilterResponseDto
{
MetaData = await query.GetMetaData(request.PaginationState, cancellationToken),
Models = await query
.PaginatedListAsync(paginationState: request.PaginationState)
.Select(x => new GetAllPaymentTransactionByFilterResponseModel
{
Id = x.Id,
UserId = x.UserId,
Mobile = x.Mobile,
GatewayProvider = x.GatewayProvider,
Amount = x.Amount,
Authority = x.Authority,
PaymentStatus = x.PaymentStatus,
VerificationStatusCode = x.VerificationStatusCode,
VerificationStatusMessage = x.VerificationStatusMessage,
RefId = x.RefId,
CardPan = x.CardPan,
OrderId = x.OrderId,
TransactionId = x.TransactionId,
Description = x.Description,
Created = x.Created
})
.ToListAsync(cancellationToken)
};
}
}
@@ -0,0 +1,42 @@
using CMSMicroservice.Domain.Entities.Payment;
namespace CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetAllPaymentTransactionByFilter;
public static class PaymentTransactionFilterExtensions
{
public static IQueryable<PaymentTransaction> ApplyPaymentTransactionFilter(
this IQueryable<PaymentTransaction> query,
GetAllPaymentTransactionByFilterFilter? filter)
{
if (filter == null) return query;
if (filter.UserId.HasValue)
query = query.Where(x => x.UserId == filter.UserId.Value);
if (!string.IsNullOrWhiteSpace(filter.Mobile))
query = query.Where(x => x.Mobile != null && x.Mobile.Contains(filter.Mobile));
if (!string.IsNullOrWhiteSpace(filter.GatewayProvider))
query = query.Where(x => x.GatewayProvider == filter.GatewayProvider);
if (filter.PaymentStatus.HasValue)
query = query.Where(x => x.PaymentStatus == filter.PaymentStatus.Value);
if (!string.IsNullOrWhiteSpace(filter.Authority))
query = query.Where(x => x.Authority != null && x.Authority.Contains(filter.Authority));
if (!string.IsNullOrWhiteSpace(filter.RefId))
query = query.Where(x => x.RefId != null && x.RefId.Contains(filter.RefId));
if (!string.IsNullOrWhiteSpace(filter.OrderId))
query = query.Where(x => x.OrderId != null && x.OrderId.Contains(filter.OrderId));
if (filter.CreatedFrom.HasValue)
query = query.Where(x => x.Created >= filter.CreatedFrom.Value);
if (filter.CreatedTo.HasValue)
query = query.Where(x => x.Created <= filter.CreatedTo.Value);
return query;
}
}
@@ -0,0 +1,14 @@
namespace CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetPaymentTransactionSummary;
public record GetPaymentTransactionSummaryQuery : IRequest<GetPaymentTransactionSummaryResponseDto>
{
public GetAllPaymentTransactionByFilter.GetAllPaymentTransactionByFilterFilter? Filter { get; init; }
}
public class GetPaymentTransactionSummaryResponseDto
{
public long TotalCount { get; set; }
public long TotalAmount { get; set; }
public long SuccessfulCount { get; set; }
public long PendingCount { get; set; }
}
@@ -0,0 +1,36 @@
using CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetAllPaymentTransactionByFilter;
namespace CMSMicroservice.Application.PaymentTransactionCQ.Queries.GetPaymentTransactionSummary;
public class GetPaymentTransactionSummaryQueryHandler
: IRequestHandler<GetPaymentTransactionSummaryQuery, GetPaymentTransactionSummaryResponseDto>
{
private readonly IApplicationDbContext _context;
public GetPaymentTransactionSummaryQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetPaymentTransactionSummaryResponseDto> Handle(
GetPaymentTransactionSummaryQuery request,
CancellationToken cancellationToken)
{
var query = _context.PaymentTransactions
.AsNoTracking()
.ApplyPaymentTransactionFilter(request.Filter);
var totalCount = await query.LongCountAsync(cancellationToken);
var totalAmount = totalCount > 0 ? await query.SumAsync(x => x.Amount, cancellationToken) : 0;
var successfulCount = await query.LongCountAsync(x => x.PaymentStatus, cancellationToken);
var pendingCount = await query.LongCountAsync(x => !x.PaymentStatus, cancellationToken);
return new GetPaymentTransactionSummaryResponseDto
{
TotalCount = totalCount,
TotalAmount = totalAmount,
SuccessfulCount = successfulCount,
PendingCount = pendingCount
};
}
}
@@ -0,0 +1,43 @@
using CMSMicroservice.Domain.Enums;
namespace CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetAllUserPackagePurchaseByFilter;
public record GetAllUserPackagePurchaseByFilterQuery : IRequest<GetAllUserPackagePurchaseByFilterResponseDto>
{
public PaginationState? PaginationState { get; init; }
public string? SortBy { get; init; }
public GetAllUserPackagePurchaseByFilterFilter? Filter { get; init; }
}
public class GetAllUserPackagePurchaseByFilterFilter
{
public long? UserId { get; set; }
public long? PackageId { get; set; }
public PackagePurchaseMethod? PurchaseMethod { get; set; }
public DateTime? PurchasedFrom { get; set; }
public DateTime? PurchasedTo { get; set; }
public long? MinAmount { get; set; }
public long? MaxAmount { get; set; }
}
public class GetAllUserPackagePurchaseByFilterResponseDto
{
public MetaData MetaData { get; set; }
public List<GetAllUserPackagePurchaseByFilterResponseModel>? Models { get; set; }
}
public class GetAllUserPackagePurchaseByFilterResponseModel
{
public long Id { get; set; }
public long UserId { get; set; }
public string UserName { get; set; } = string.Empty;
public string UserMobile { get; set; } = string.Empty;
public long PackageId { get; set; }
public string PackageName { get; set; } = string.Empty;
public PackagePurchaseMethod PurchaseMethod { get; set; }
public DateTime PurchasedAt { get; set; }
public long Amount { get; set; }
public long? OrderId { get; set; }
public long? TransactionId { get; set; }
public DateTimeOffset Created { get; set; }
}
@@ -0,0 +1,47 @@
namespace CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetAllUserPackagePurchaseByFilter;
public class GetAllUserPackagePurchaseByFilterQueryHandler
: IRequestHandler<GetAllUserPackagePurchaseByFilterQuery, GetAllUserPackagePurchaseByFilterResponseDto>
{
private readonly IApplicationDbContext _context;
public GetAllUserPackagePurchaseByFilterQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetAllUserPackagePurchaseByFilterResponseDto> Handle(
GetAllUserPackagePurchaseByFilterQuery request,
CancellationToken cancellationToken)
{
var query = _context.UserPackagePurchases
.Include(x => x.User)
.Include(x => x.Package)
.AsNoTracking()
.ApplyUserPackagePurchaseFilter(request.Filter)
.ApplyOrder(sortBy: request.SortBy ?? "-PurchasedAt");
return new GetAllUserPackagePurchaseByFilterResponseDto
{
MetaData = await query.GetMetaData(request.PaginationState, cancellationToken),
Models = await query
.PaginatedListAsync(paginationState: request.PaginationState)
.Select(x => new GetAllUserPackagePurchaseByFilterResponseModel
{
Id = x.Id,
UserId = x.UserId,
UserName = x.User != null ? $"{x.User.FirstName} {x.User.LastName}" : string.Empty,
UserMobile = x.User != null ? x.User.Mobile : string.Empty,
PackageId = x.PackageId,
PackageName = x.Package != null ? x.Package.Title : string.Empty,
PurchaseMethod = x.PurchaseMethod,
PurchasedAt = x.PurchasedAt,
Amount = x.Amount,
OrderId = x.OrderId,
TransactionId = x.TransactionId,
Created = x.Created
})
.ToListAsync(cancellationToken)
};
}
}
@@ -0,0 +1,36 @@
using CMSMicroservice.Domain.Entities;
namespace CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetAllUserPackagePurchaseByFilter;
public static class UserPackagePurchaseFilterExtensions
{
public static IQueryable<UserPackagePurchase> ApplyUserPackagePurchaseFilter(
this IQueryable<UserPackagePurchase> query,
GetAllUserPackagePurchaseByFilterFilter? filter)
{
if (filter == null) return query;
if (filter.UserId.HasValue)
query = query.Where(x => x.UserId == filter.UserId.Value);
if (filter.PackageId.HasValue)
query = query.Where(x => x.PackageId == filter.PackageId.Value);
if (filter.PurchaseMethod.HasValue)
query = query.Where(x => x.PurchaseMethod == filter.PurchaseMethod.Value);
if (filter.PurchasedFrom.HasValue)
query = query.Where(x => x.PurchasedAt >= filter.PurchasedFrom.Value);
if (filter.PurchasedTo.HasValue)
query = query.Where(x => x.PurchasedAt <= filter.PurchasedTo.Value);
if (filter.MinAmount.HasValue)
query = query.Where(x => x.Amount >= filter.MinAmount.Value);
if (filter.MaxAmount.HasValue)
query = query.Where(x => x.Amount <= filter.MaxAmount.Value);
return query;
}
}
@@ -0,0 +1,12 @@
namespace CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetUserPackagePurchaseSummary;
public record GetUserPackagePurchaseSummaryQuery : IRequest<GetUserPackagePurchaseSummaryResponseDto>
{
public GetAllUserPackagePurchaseByFilter.GetAllUserPackagePurchaseByFilterFilter? Filter { get; init; }
}
public class GetUserPackagePurchaseSummaryResponseDto
{
public long TotalCount { get; set; }
public long TotalAmount { get; set; }
}
@@ -0,0 +1,32 @@
using CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetAllUserPackagePurchaseByFilter;
namespace CMSMicroservice.Application.UserPackagePurchaseCQ.Queries.GetUserPackagePurchaseSummary;
public class GetUserPackagePurchaseSummaryQueryHandler
: IRequestHandler<GetUserPackagePurchaseSummaryQuery, GetUserPackagePurchaseSummaryResponseDto>
{
private readonly IApplicationDbContext _context;
public GetUserPackagePurchaseSummaryQueryHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<GetUserPackagePurchaseSummaryResponseDto> Handle(
GetUserPackagePurchaseSummaryQuery request,
CancellationToken cancellationToken)
{
var query = _context.UserPackagePurchases
.AsNoTracking()
.ApplyUserPackagePurchaseFilter(request.Filter);
var totalCount = await query.LongCountAsync(cancellationToken);
var totalAmount = totalCount > 0 ? await query.SumAsync(x => x.Amount, cancellationToken) : 0;
return new GetUserPackagePurchaseSummaryResponseDto
{
TotalCount = totalCount,
TotalAmount = totalAmount
};
}
}