namespace Brizco.Repository.Handlers.Position; public class UpdatePositionCommandHandler : IRequestHandler { private readonly IRepositoryWrapper _repositoryWrapper; private readonly ICurrentUserService _currentUserService; public UpdatePositionCommandHandler(IRepositoryWrapper repositoryWrapper, ICurrentUserService currentUserService) { _repositoryWrapper = repositoryWrapper; _currentUserService = currentUserService; } public async Task Handle(UpdatePositionCommand request, CancellationToken cancellationToken) { var shift = await _repositoryWrapper.SetRepository() .TableNoTracking.FirstOrDefaultAsync(s => s.Id == request.Id, cancellationToken); if (shift == null) throw new AppException("Postion not found", ApiResultStatusCode.NotFound); if (_currentUserService.ComplexId == null) throw new AppException("ComplexId is null", ApiResultStatusCode.NotFound); if (!Guid.TryParse(_currentUserService.ComplexId, out Guid complexId)) throw new AppException("ComplexId is wrong", ApiResultStatusCode.NotFound); var newPosition = Domain.Entities.Complex.Position.Create(request.Title, request.Description, complexId, request.SectionId); newPosition.Id = request.Id; var users = await _repositoryWrapper.SetRepository().TableNoTracking .Where(pu => pu.PositionId == newPosition.Id) .ToListAsync(cancellationToken); //foreach (var user in users) //{ // if (!request.UserIds.Contains(user.ApplicationUserId)) // { // _repositoryWrapper.SetRepository() // .Delete(user); // await _repositoryWrapper.SaveChangesAsync(cancellationToken); // } //} //foreach (var userId in request.UserIds) //{ // if (users.FirstOrDefault(u => u.ApplicationUserId == userId) == null) // { // newPosition.AddUser(userId); // } //} _repositoryWrapper.SetRepository() .Update(newPosition); await _repositoryWrapper.SaveChangesAsync(cancellationToken); return true; } }