Browse Source

Merge c203f9cdcf into 9486760a9e

pull/574/merge
Roma Marusyk 6 years ago
committed by GitHub
parent
commit
3cf95c0cf1
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 8 deletions
  1. +2
    -2
      src/Services/Marketing/Marketing.API/Infrastructure/MarketingContextSeed.cs
  2. +4
    -4
      src/Services/Marketing/Marketing.API/Infrastructure/Repositories/MarketingDataRepository.cs
  3. +2
    -2
      src/Services/Payment/Payment.API/IntegrationEvents/EventHandling/OrderStatusChangedToStockConfirmedIntegrationEventHandler.cs

+ 2
- 2
src/Services/Marketing/Marketing.API/Infrastructure/MarketingContextSeed.cs View File

@ -11,11 +11,11 @@
public class MarketingContextSeed public class MarketingContextSeed
{ {
public async Task SeedAsync(MarketingContext context,ILogger<MarketingContextSeed> logger,int retries = 3)
public Task SeedAsync(MarketingContext context,ILogger<MarketingContextSeed> logger,int retries = 3)
{ {
var policy = CreatePolicy(retries, logger, nameof(MarketingContextSeed)); var policy = CreatePolicy(retries, logger, nameof(MarketingContextSeed));
await policy.ExecuteAsync(async () =>
return policy.ExecuteAsync(async () =>
{ {
if (!context.Campaigns.Any()) if (!context.Campaigns.Any())
{ {


+ 4
- 4
src/Services/Marketing/Marketing.API/Infrastructure/Repositories/MarketingDataRepository.cs View File

@ -15,22 +15,22 @@ namespace Microsoft.eShopOnContainers.Services.Marketing.API.Infrastructure.Repo
_context = new MarketingReadDataContext(settings); _context = new MarketingReadDataContext(settings);
} }
public async Task<MarketingData> GetAsync(string userId)
public Task<MarketingData> GetAsync(string userId)
{ {
var filter = Builders<MarketingData>.Filter.Eq("UserId", userId); var filter = Builders<MarketingData>.Filter.Eq("UserId", userId);
return await _context.MarketingData
return _context.MarketingData
.Find(filter) .Find(filter)
.FirstOrDefaultAsync(); .FirstOrDefaultAsync();
} }
public async Task UpdateLocationAsync(MarketingData marketingData)
public Task UpdateLocationAsync(MarketingData marketingData)
{ {
var filter = Builders<MarketingData>.Filter.Eq("UserId", marketingData.UserId); var filter = Builders<MarketingData>.Filter.Eq("UserId", marketingData.UserId);
var update = Builders<MarketingData>.Update var update = Builders<MarketingData>.Update
.Set("Locations", marketingData.Locations) .Set("Locations", marketingData.Locations)
.CurrentDate("UpdateDate"); .CurrentDate("UpdateDate");
await _context.MarketingData
return _context.MarketingData
.UpdateOneAsync(filter, update, new UpdateOptions { IsUpsert = true }); .UpdateOneAsync(filter, update, new UpdateOptions { IsUpsert = true });
} }
} }


+ 2
- 2
src/Services/Payment/Payment.API/IntegrationEvents/EventHandling/OrderStatusChangedToStockConfirmedIntegrationEventHandler.cs View File

@ -19,7 +19,7 @@
_settings = settings.Value; _settings = settings.Value;
} }
public async Task Handle(OrderStatusChangedToStockConfirmedIntegrationEvent @event)
public Task Handle(OrderStatusChangedToStockConfirmedIntegrationEvent @event)
{ {
IntegrationEvent orderPaymentIntegrationEvent; IntegrationEvent orderPaymentIntegrationEvent;
@ -40,7 +40,7 @@
_eventBus.Publish(orderPaymentIntegrationEvent); _eventBus.Publish(orderPaymentIntegrationEvent);
await Task.CompletedTask;
return Task.CompletedTask;
} }
} }
} }

Loading…
Cancel
Save