Невозможно добавить второй объект при добавлении его в команду 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;
}
}

AppDbContext
public class AppDbContext : IdentityDbContext
{
public AppDbContext(DbContextOptions options)
: base(options)
{
}

// This is used to return the UTC time when queried, knowing
// that SQL has an issue returning UTC time by not adding the "z"
// suffix character that tells JS that the time is UTC.
// It's added to entity configurations using .HasConversion(AppDbContext.utcConverter).
public static ValueConverter utcConverter = new ValueConverter(
toDb => toDb,
fromDb =>
DateTime.SpecifyKind(fromDb, DateTimeKind.Utc));

public DbSet Categories { get; set; }
public DbSet Rewards { get; set; }
public DbSet UserReward { get; set; }

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.ApplyConfiguration(new ApplicationUserConfiguration());
modelBuilder.ApplyConfiguration(new CategoryConfiguration());
modelBuilder.ApplyConfiguration(new RewardConfiguration());
modelBuilder.ApplyConfiguration(new UserRewardConfiguration());
}

Контейнер внедрения внедрения служб
public static IServiceCollection AddInfrastructure(this IServiceCollection services,
IConfiguration configuration,
WebApplicationBuilder builder)
{
services.AddEntityFrameworkNpgsql().AddDbContext(opt =>
opt.UseNpgsql(configuration.GetConnectionString("PostgreSQLServerConnectionString")));

// Used for .NET Aspire container DB
//builder.AddSqlServerDbContext("SomethingDb");

// Add EF Core Identity
services.AddIdentity()
.AddEntityFrameworkStores().AddDefaultTokenProviders();

services.AddScoped(typeof(IAsyncRepository), typeof(BaseRepository));

services.AddTransient();

// Repositories
services.AddScoped();
services.AddScoped();
services.AddScoped();
services.AddScoped();
services.AddScoped();

// Reward services
services.AddScoped();

services.AddSingleton();

services.AddHttpContextAccessor();

services.AddLazyResolution();

Return services
}
}
}


Я пытаюсь это сделать:
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);

ОБНОВЛЕНИЕ
Исключение не было создано, но теперь я его получаю:

ОБНОВЛЕНИЕ
Исключение не было создано, но теперь оно есть:

Microsoft.EntityFrameworkCore.DbUpdateException: произошла ошибка
при сохранении изменений сущности. Подробности смотрите во внутреннем исключении.
---> Npgsql.PostgresException (0x80004005): 23503: вставка или обновление
в таблице «UserReward» нарушает ограничение внешнего ключа
"FK_UserReward_Rewards_RewardId"

Из-за этого кода:
public async Task Handle(AddRewardCommand request, CancellationToken cancellationToken)
{
Domain.Entities.Reward reward;

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

// Create a new reward with the HasBeenUsed property false
var newReward = new Domain.Entities.Reward()
{
RewardId = Guid.NewGuid(),
Name = request.Name,
HasBeenUsed = false,
ExpiresOn = DateTime.UtcNow.AddDays(16),
CreatedOn = DateTime.Now.ToUniversalTime()
};

// 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,
CreatedOn = DateTime.Now.ToUniversalTime()
};

userRewardsList.Add(userReward);
}

// /!\
// HERE IS THE CHANGE USING ADDRANGE INSTEAD OF ADDASYNC
var t = await userRewardRepository.AddUserRewardRange(userRewardsList);

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

reward = await repository.AddAsync(reward);

return reward.RewardId;
}

И добавил этот метод в UserRewardRepository:
public async Task AddUserRewardRange(List userRewards)
{
context.Set().AddRange(userRewards);
await context.SaveChangesAsync();

return userRewards;
}


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