Невозможно добавить второй объект при добавлении его в команду CQRS. ⇐ C#

[Anonymous]

Я пытаюсь добавить объект в свой класс команд CQRS, и пока никаких проблем не возникает. Единственная проблема заключается в том, что я пытаюсь добавить второй объект до его завершения. для выполнения.
вот мои объекты и их репозитории:

Код: Выделить всё

ApplicationUser

Код: Выделить всё

    public class ApplicationUser : IdentityUser
{

public string FirstName { get; set; }
public string LastName { get; set; }
public IList UserRewards { get; set; }
}

Код: Выделить всё

Reward

Код: Выделить всё

    public class Reward
{
public Guid RewardId { get; set; }
public string Name { get; set; }
public IList UserRewards { get; set; }
}

Код: Выделить всё

RewardRepository : BaseRepository

Код: Выделить всё

    public class BaseRepository : IAsyncRepository where T : class
{
private readonly AppDbContext context;

public BaseRepository(AppDbContext context)
{
this.context = context;
}
public async Task AddAsync(T entity)
{
await context.Set().AddAsync(entity);
await context.SaveChangesAsync();

return entity;
}
}

Код: Выделить всё

UserReward

Код: Выделить всё

    public class UserReward
{
public Guid ApplicationUserId { get; set; }
public ApplicationUser User { get; set; }
public Guid RewardId { get; set; }
public Reward Reward { get; set; }
}

Код: Выделить всё

UserRewardRepository : BaseRepository

Код: Выделить всё

    public class BaseRepository : IAsyncRepository where T : class
{
private readonly AppDbContext context;

public BaseRepository(AppDbContext context)
{
this.context = context;
}
public async Task AddAsync(T entity)
{
await context.Set().AddAsync(entity);
await context.SaveChangesAsync();

return entity;
}
}

Я пытаюсь это сделать:

Код: Выделить всё

AddRewardCommand

Код: Выделить всё

    public class AddRewardCommand : IRequest
{
public string Name { get; set; }
}

Код: Выделить всё

AddRewardCommandHandler

Код: Выделить всё

    public class AddRewardCommandHandler
: IRequestHandler
{
private readonly IMapper mapper;
private readonly IRewardRepository repository;
private readonly IUserRewardRepository userRewardRepository;
private readonly IAuthenticationService authenticationService;

public AddRewardCommandHandler(IMapper mapper,
IRewardRepository repository,
IUserRewardRepository userRewardRepository,
IAuthenticationService authenticationService)
{
this.mapper = mapper
?? throw new ArgumentNullException(nameof(mapper));
this.repository = repository
?? throw new ArgumentNullException(nameof(repository));
this.userRewardRepository = userRewardRepository
?? throw new ArgumentNullException(nameof(userRewardRepository));
this.authenticationService = authenticationService
?? throw new ArgumentNullException(nameof(authenticationService));
}

public async Task Handle(AddRewardCommand request, CancellationToken cancellationToken)
{
Domain.Entities.Reward reward;

// Get all users
var userList= await authenticationService.GetAllUsersWithPhoneConfirmedAsync();

// Create a new reward with the HasBeenUsed property false
var newReward = new Domain.Entities.Reward()
{
RewardId = Guid.NewGuid(),
Name = request.Name
};

// Foreach user in the DB, add this new reward to their account
foreach (GetUserResponse user in userList)
{
var userReward = new Domain.Entities.UserReward()
{
ApplicationUserId = user.UserId,
RewardId = newReward.RewardId
};

// /!\
// THIS IS WHERE IT DOESN'T WORK
var t = await userRewardRepository.AddAsync(userReward);
}

try
{
reward = mapper.Map(request);
}
catch (AutoMapperMappingException autoMapperException)
{
throw autoMapperException.InnerException;
}

reward = await repository.AddAsync(reward);

return reward.RewardId;
}
}

Эта строка в цикле foreach почему-то не работает:

Код: Выделить всё

var t = await userRewardRepository.AddAsync(userReward); 

Исключения не создаются, даже при отладке

Подробнее здесь: https://stackoverflow.com/questions/791 ... rs-command