From 6824d033897994a0840fac9fcf3262ff3542cb91 Mon Sep 17 00:00:00 2001 From: alexandr andreev Date: Tue, 13 Oct 2020 14:17:32 +0300 Subject: [PATCH] VP-5334 Call ClearCache before publish event (#44) --- .../Services/PaymentPlanService.cs | 9 +++++---- .../Services/SubscriptionServiceImpl.cs | 9 +++++---- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/src/VirtoCommerce.SubscriptionModule.Data/Services/PaymentPlanService.cs b/src/VirtoCommerce.SubscriptionModule.Data/Services/PaymentPlanService.cs index f468ba5..8c3bd8d 100644 --- a/src/VirtoCommerce.SubscriptionModule.Data/Services/PaymentPlanService.cs +++ b/src/VirtoCommerce.SubscriptionModule.Data/Services/PaymentPlanService.cs @@ -85,10 +85,11 @@ public virtual async Task SavePlansAsync(PaymentPlan[] plans) await _eventPublisher.Publish(new PaymentPlanChangingEvent(changedEntries)); await repository.UnitOfWork.CommitAsync(); pkMap.ResolvePrimaryKeys(); + + ClearCacheFor(plans); + await _eventPublisher.Publish(new PaymentPlanChangedEvent(changedEntries)); } - - ClearCacheFor(plans); } public virtual async Task DeleteAsync(string[] ids) @@ -104,10 +105,10 @@ public virtual async Task DeleteAsync(string[] ids) await repository.RemovePaymentPlansByIdsAsync(ids); await repository.UnitOfWork.CommitAsync(); + ClearCacheFor(paymentPlans); + await _eventPublisher.Publish(new PaymentPlanChangedEvent(changedEntries)); } - - ClearCacheFor(paymentPlans); } } diff --git a/src/VirtoCommerce.SubscriptionModule.Data/Services/SubscriptionServiceImpl.cs b/src/VirtoCommerce.SubscriptionModule.Data/Services/SubscriptionServiceImpl.cs index 2068974..ef38d6f 100644 --- a/src/VirtoCommerce.SubscriptionModule.Data/Services/SubscriptionServiceImpl.cs +++ b/src/VirtoCommerce.SubscriptionModule.Data/Services/SubscriptionServiceImpl.cs @@ -153,10 +153,11 @@ public virtual async Task SaveSubscriptionsAsync(Subscription[] subscriptions) await _eventPublisher.Publish(new SubscriptionChangingEvent(changedEntries)); await repository.UnitOfWork.CommitAsync(); pkMap.ResolvePrimaryKeys(); + + ClearCacheFor(subscriptions); + await _eventPublisher.Publish(new SubscriptionChangedEvent(changedEntries)); } - - ClearCacheFor(subscriptions); } public virtual async Task DeleteAsync(string[] ids) @@ -176,9 +177,9 @@ public virtual async Task DeleteAsync(string[] ids) await repository.RemoveSubscriptionsByIdsAsync(ids); await repository.UnitOfWork.CommitAsync(); - await _eventPublisher.Publish(new SubscriptionChangedEvent(changedEntries)); - ClearCacheFor(subscriptions); + + await _eventPublisher.Publish(new SubscriptionChangedEvent(changedEntries)); } } }