Handler.cs 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using SharedKernel.Results;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Api.Crew.ConsentSession;
  6. internal sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result<Response>>
  7. {
  8. public async Task<Result<Response>> Handle(Command request, CancellationToken ct)
  9. {
  10. var consent = await db.CrewSessionConsent
  11. .FirstOrDefaultAsync(c => c.CrewSessionID == request.CrewSessionID && c.CrewMemberID == request.CrewMemberID, ct);
  12. if (consent is null)
  13. {
  14. return Result.Failure<Response>(Error.NotFound("Crew.ConsentNotFound", "동의 정보를 찾을 수 없습니다."));
  15. }
  16. if (consent.IsConsented)
  17. {
  18. return Result.Failure<Response>(Error.Conflict("Crew.AlreadyConsented", "이미 동의했습니다."));
  19. }
  20. consent.Consent();
  21. // 전원 동의 확인
  22. var allConsented = await db.CrewSessionConsent
  23. .Where(c => c.CrewSessionID == request.CrewSessionID)
  24. .AllAsync(c => c.IsConsented || c.CrewMemberID == request.CrewMemberID, ct);
  25. if (allConsented)
  26. {
  27. var session = await db.CrewSession.FindAsync([request.CrewSessionID], ct);
  28. session?.Activate();
  29. }
  30. await db.SaveChangesAsync(ct);
  31. return Result.Success(new Response(allConsented));
  32. }
  33. }