update
This commit is contained in:
@@ -13,6 +13,16 @@ public class CreateNewUserCartsCommandHandler : IRequestHandler<CreateNewUserCar
|
|||||||
CancellationToken cancellationToken)
|
CancellationToken cancellationToken)
|
||||||
{
|
{
|
||||||
var entity = request.Adapt<UserCarts>();
|
var entity = request.Adapt<UserCarts>();
|
||||||
|
var existingUserCart = await _context.UserCartss
|
||||||
|
.FirstOrDefaultAsync(x => x.UserId == entity.UserId && x.ProductId == entity.ProductId && !x.IsDeleted, cancellationToken);
|
||||||
|
if (existingUserCart != null)
|
||||||
|
{
|
||||||
|
existingUserCart.Count += entity.Count;
|
||||||
|
_context.UserCartss.Update(existingUserCart);
|
||||||
|
existingUserCart.AddDomainEvent(new UpdateUserCartsEvent(existingUserCart));
|
||||||
|
await _context.SaveChangesAsync(cancellationToken);
|
||||||
|
return existingUserCart.Adapt<CreateNewUserCartsResponseDto>();
|
||||||
|
}
|
||||||
await _context.UserCartss.AddAsync(entity, cancellationToken);
|
await _context.UserCartss.AddAsync(entity, cancellationToken);
|
||||||
entity.AddDomainEvent(new CreateNewUserCartsEvent(entity));
|
entity.AddDomainEvent(new CreateNewUserCartsEvent(entity));
|
||||||
await _context.SaveChangesAsync(cancellationToken);
|
await _context.SaveChangesAsync(cancellationToken);
|
||||||
|
|||||||
Reference in New Issue
Block a user