Erik Pique
5 years ago
5 changed files with 97 additions and 52 deletions
Split View
Diff Options
-
+0 -51eShopOnContainers-ServicesAndWebApps.sln
-
+90 -0src/Services/Ordering/Ordering.API/Infrastructure/Tasks/GracePeriodManagerTask.cs
-
+3 -0src/Services/Ordering/Ordering.API/OrderingSettings.cs
-
+3 -1src/Services/Ordering/Ordering.API/Program.cs
-
+1 -0src/Services/Ordering/Ordering.API/appsettings.json
+ 0
- 51
eShopOnContainers-ServicesAndWebApps.sln
View File
+ 90
- 0
src/Services/Ordering/Ordering.API/Infrastructure/Tasks/GracePeriodManagerTask.cs
View File
| @ -0,0 +1,90 @@ | |||
| using Dapper; | |||
| using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions; | |||
| using Microsoft.eShopOnContainers.Services.Ordering.API; | |||
| using Microsoft.Extensions.Hosting; | |||
| using Microsoft.Extensions.Logging; | |||
| using Microsoft.Extensions.Options; | |||
| using Ordering.API.Application.IntegrationEvents.Events; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Data.SqlClient; | |||
| using System.Threading; | |||
| using System.Threading.Tasks; | |||
| namespace Ordering.API.Infrastructure.Tasks | |||
| { | |||
| public class GracePeriodManagerService : BackgroundService | |||
| { | |||
| private readonly ILogger<GracePeriodManagerService> _logger; | |||
| private readonly OrderingSettings _settings; | |||
| private readonly IEventBus _eventBus; | |||
| public GracePeriodManagerService(IOptions<OrderingSettings> settings, IEventBus eventBus, ILogger<GracePeriodManagerService> logger) | |||
| { | |||
| _settings = settings?.Value ?? throw new ArgumentNullException(nameof(settings)); | |||
| _eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus)); | |||
| _logger = logger ?? throw new ArgumentNullException(nameof(logger)); | |||
| } | |||
| protected override async Task ExecuteAsync(CancellationToken stoppingToken) | |||
| { | |||
| _logger.LogDebug("GracePeriodManagerService is starting."); | |||
| stoppingToken.Register(() => _logger.LogDebug("#1 GracePeriodManagerService background task is stopping.")); | |||
| while (!stoppingToken.IsCancellationRequested) | |||
| { | |||
| _logger.LogDebug("GracePeriodManagerService background task is doing background work."); | |||
| CheckConfirmedGracePeriodOrders(); | |||
| await Task.Delay(_settings.CheckUpdateTime, stoppingToken); | |||
| } | |||
| _logger.LogDebug("GracePeriodManagerService background task is stopping."); | |||
| await Task.CompletedTask; | |||
| } | |||
| private void CheckConfirmedGracePeriodOrders() | |||
| { | |||
| _logger.LogDebug("Checking confirmed grace period orders"); | |||
| var orderIds = GetConfirmedGracePeriodOrders(); | |||
| foreach (var orderId in orderIds) | |||
| { | |||
| var confirmGracePeriodEvent = new GracePeriodConfirmedIntegrationEvent(orderId); | |||
| _logger.LogInformation("----- Publishing integration event: {IntegrationEventId} from {AppName} - ({@IntegrationEvent})", confirmGracePeriodEvent.Id, Program.AppName, confirmGracePeriodEvent); | |||
| _eventBus.Publish(confirmGracePeriodEvent); | |||
| } | |||
| } | |||
| private IEnumerable<int> GetConfirmedGracePeriodOrders() | |||
| { | |||
| IEnumerable<int> orderIds = new List<int>(); | |||
| using (var conn = new SqlConnection(_settings.ConnectionString)) | |||
| { | |||
| try | |||
| { | |||
| conn.Open(); | |||
| orderIds = conn.Query<int>( | |||
| @"SELECT Id FROM [ordering].[orders] | |||
| WHERE DATEDIFF(minute, [OrderDate], GETDATE()) >= @GracePeriodTime | |||
| AND [OrderStatusId] = 1", | |||
| new { _settings.GracePeriodTime }); | |||
| } | |||
| catch (SqlException exception) | |||
| { | |||
| _logger.LogCritical(exception, "FATAL ERROR: Database connections could not be opened: {Message}", exception.Message); | |||
| } | |||
| } | |||
| return orderIds; | |||
| } | |||
| } | |||
| } | |||