| 1234567891011121314151617181920212223242526272829303132333435363738394041 |
- using Application.Abstractions.Data;
- using Application.Abstractions.Messaging;
- using SharedKernel.Results;
- using Microsoft.EntityFrameworkCore;
- namespace Application.Features.Api.Crew.ConsentSession;
- internal sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result<Response>>
- {
- public async Task<Result<Response>> Handle(Command request, CancellationToken ct)
- {
- var consent = await db.CrewSessionConsent
- .FirstOrDefaultAsync(c => c.CrewSessionID == request.CrewSessionID && c.CrewMemberID == request.CrewMemberID, ct);
- if (consent is null)
- {
- return Result.Failure<Response>(Error.NotFound("Crew.ConsentNotFound", "동의 정보를 찾을 수 없습니다."));
- }
- if (consent.IsConsented)
- {
- return Result.Failure<Response>(Error.Conflict("Crew.AlreadyConsented", "이미 동의했습니다."));
- }
- consent.Consent();
- // 전원 동의 확인
- var allConsented = await db.CrewSessionConsent
- .Where(c => c.CrewSessionID == request.CrewSessionID)
- .AllAsync(c => c.IsConsented || c.CrewMemberID == request.CrewMemberID, ct);
- if (allConsented)
- {
- var session = await db.CrewSession.FindAsync([request.CrewSessionID], ct);
- session?.Activate();
- }
- await db.SaveChangesAsync(ct);
- return Result.Success(new Response(allConsented));
- }
- }
|