|
|
|
@ -5,22 +5,20 @@ using Volo.Abp.EventBus.Distributed; |
|
|
|
|
|
|
|
namespace EShopOnAbp.BasketService.Orders |
|
|
|
{ |
|
|
|
public class OrderAcceptedEventHandler : |
|
|
|
IDistributedEventHandler<OrderAcceptedEto>, |
|
|
|
ITransientDependency |
|
|
|
public class OrderPlacedEventHandler : IDistributedEventHandler<OrderPlacedEto>, ITransientDependency |
|
|
|
{ |
|
|
|
private readonly IBasketRepository _basketRepository; |
|
|
|
|
|
|
|
public OrderAcceptedEventHandler(IBasketRepository basketRepository) |
|
|
|
public OrderPlacedEventHandler(IBasketRepository basketRepository) |
|
|
|
{ |
|
|
|
_basketRepository = basketRepository; |
|
|
|
} |
|
|
|
|
|
|
|
public async Task HandleEventAsync(OrderAcceptedEto eventData) |
|
|
|
public async Task HandleEventAsync(OrderPlacedEto eventData) |
|
|
|
{ |
|
|
|
var basket = await _basketRepository.GetAsync(eventData.BuyerId); |
|
|
|
var basket = await _basketRepository.GetAsync(eventData.Buyer.BuyerId); |
|
|
|
basket.Clear(); |
|
|
|
await _basketRepository.UpdateAsync(basket); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |