feat: Add ClubMembershipCQ - Phase 3 Application Layer

- Implemented 3 Commands with handlers and validators:
  * ActivateClubMembership: Create/reactivate membership
  * DeactivateClubMembership: Deactivate existing membership
  * AssignClubFeature: Assign features to club members

- Implemented 3 Queries with handlers, validators, and DTOs:
  * GetClubMembership: Retrieve single membership by UserId
  * GetAllClubMemberships: List with filtering and pagination
  * GetClubMembershipHistory: Audit trail with full history

- All operations include history tracking via ClubMembershipHistory
- Property names aligned with Domain entity definitions
- 21 new files, ~600 lines of code
- Build successful with 0 errors
This commit is contained in:
masoodafar-web
2025-11-29 04:13:27 +03:30
parent fb911cd0fd
commit fe66d478ee
21 changed files with 732 additions and 0 deletions

View File

@@ -0,0 +1,22 @@
namespace CMSMicroservice.Application.ClubMembershipCQ.Commands.ActivateClubMembership;
/// <summary>
/// Command برای فعال‌سازی عضویت باشگاه مشتریان یک کاربر
/// </summary>
public record ActivateClubMembershipCommand : IRequest<long>
{
/// <summary>
/// شناسه کاربر
/// </summary>
public long UserId { get; init; }
/// <summary>
/// تاریخ فعال‌سازی (اختیاری - پیش‌فرض: الان)
/// </summary>
public DateTimeOffset? ActivationDate { get; init; }
/// <summary>
/// دلیل فعال‌سازی (برای History)
/// </summary>
public string? Reason { get; init; }
}

View File

@@ -0,0 +1,84 @@
namespace CMSMicroservice.Application.ClubMembershipCQ.Commands.ActivateClubMembership;
public class ActivateClubMembershipCommandHandler : IRequestHandler<ActivateClubMembershipCommand, long>
{
private readonly IApplicationDbContext _context;
public ActivateClubMembershipCommandHandler(IApplicationDbContext context)
{
_context = context;
}
public async Task<long> Handle(ActivateClubMembershipCommand request, CancellationToken cancellationToken)
{
// بررسی وجود کاربر
var userExists = await _context.Users
.AnyAsync(x => x.Id == request.UserId, cancellationToken);
if (!userExists)
{
throw new NotFoundException(nameof(User), request.UserId);
}
// بررسی عضویت فعلی
var existingMembership = await _context.ClubMemberships
.FirstOrDefaultAsync(x => x.UserId == request.UserId, cancellationToken);
ClubMembership entity;
bool isNewMembership = existingMembership == null;
var activationDate = request.ActivationDate ?? DateTimeOffset.UtcNow;
if (isNewMembership)
{
// ایجاد عضویت جدید
entity = new ClubMembership
{
UserId = request.UserId,
IsActive = true,
ActivatedAt = activationDate.DateTime,
InitialContribution = 0,
TotalEarned = 0
};
await _context.ClubMemberships.AddAsync(entity, cancellationToken);
}
else
{
// فعال‌سازی مجدد عضویت موجود
entity = existingMembership;
if (entity.IsActive)
{
// اگر از قبل فعال است، فقط تاریخ را به‌روز می‌کنیم
entity.ActivatedAt = activationDate.DateTime;
}
else
{
// فعال‌سازی عضویت غیرفعال
entity.IsActive = true;
entity.ActivatedAt = activationDate.DateTime;
}
_context.ClubMemberships.Update(entity);
}
await _context.SaveChangesAsync(cancellationToken);
// ثبت تاریخچه
var history = new ClubMembershipHistory
{
ClubMembershipId = entity.Id,
UserId = entity.UserId,
OldIsActive = !isNewMembership && !existingMembership!.IsActive,
NewIsActive = true,
Action = ClubMembershipAction.Activated,
Reason = request.Reason ?? (isNewMembership ? "Initial activation" : "Reactivated"),
PerformedBy = "System" // TODO: باید از Current User گرفته شود
};
await _context.ClubMembershipHistories.AddAsync(history, cancellationToken);
await _context.SaveChangesAsync(cancellationToken);
return entity.Id;
}
}

View File

@@ -0,0 +1,34 @@
namespace CMSMicroservice.Application.ClubMembershipCQ.Commands.ActivateClubMembership;
public class ActivateClubMembershipCommandValidator : AbstractValidator<ActivateClubMembershipCommand>
{
public ActivateClubMembershipCommandValidator()
{
RuleFor(x => x.UserId)
.GreaterThan(0)
.WithMessage("شناسه کاربر معتبر نیست");
RuleFor(x => x.ActivationDate)
.LessThanOrEqualTo(DateTimeOffset.UtcNow.AddDays(1))
.WithMessage("تاریخ فعال‌سازی نمی‌تواند در آینده باشد")
.When(x => x.ActivationDate.HasValue);
RuleFor(x => x.Reason)
.MaximumLength(500)
.WithMessage("دلیل فعال‌سازی نمی‌تواند بیشتر از 500 کاراکتر باشد")
.When(x => !string.IsNullOrEmpty(x.Reason));
}
public Func<object, string, Task<IEnumerable<string>>> ValidateValue => async (model, propertyName) =>
{
var result = await ValidateAsync(
ValidationContext<ActivateClubMembershipCommand>.CreateWithOptions(
(ActivateClubMembershipCommand)model,
x => x.IncludeProperties(propertyName)));
if (result.IsValid)
return Array.Empty<string>();
return result.Errors.Select(e => e.ErrorMessage);
};
}