diff --git a/PartSource.Automation/Jobs/UpdatePricing.cs b/PartSource.Automation/Jobs/UpdatePricing.cs index df4a0f4..1ee53c9 100644 --- a/PartSource.Automation/Jobs/UpdatePricing.cs +++ b/PartSource.Automation/Jobs/UpdatePricing.cs @@ -12,6 +12,7 @@ using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Microsoft.Extensions.Logging; +using PartSource.Automation.Services; namespace PartSource.Automation.Jobs { @@ -20,12 +21,14 @@ namespace PartSource.Automation.Jobs private readonly ILogger _logger; private readonly PartSourceContext _partSourceContext; private readonly ShopifyClient _shopifyClient; + private readonly EmailService _emailService; - public UpdatePricing(ILogger logger, PartSourceContext partSourceContext, ShopifyClient shopifyClient) + public UpdatePricing(ILogger logger, PartSourceContext partSourceContext, ShopifyClient shopifyClient, EmailService emailService) { _logger = logger; _partSourceContext = partSourceContext; _shopifyClient = shopifyClient; + _emailService = emailService; } public async Task Run() @@ -97,7 +100,7 @@ namespace PartSource.Automation.Jobs try { - products = await _shopifyClient.Products.GetNext(); + products = await _shopifyClient.Products.GetNext(); _logger.LogInformation($"Total updated: {updateCount}"); } @@ -108,6 +111,8 @@ namespace PartSource.Automation.Jobs products = await _shopifyClient.Products.GetPrevious(); } } + + _emailService.Send("Update Pricing Completed", $"{updateCount} prices were updated"); } } } \ No newline at end of file diff --git a/PartSource.Automation/Program.cs b/PartSource.Automation/Program.cs index 0829c18..3a165aa 100644 --- a/PartSource.Automation/Program.cs +++ b/PartSource.Automation/Program.cs @@ -68,22 +68,27 @@ namespace PartSource.Automation .AddAutomation(options => { - options.HasBaseInterval(new TimeSpan(0, 1, 0)) + options.HasBaseInterval(new TimeSpan(0, 15, 0)) .HasMaxFailures(5) - .HasJob(options => options.HasInterval(5)) - //.HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) - // .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) - //.HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) - // .HasDependency() - // .StartsAt(DateTime.Today.AddHours(8)) - //) - - //.HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) - // .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0))) - //.HasDependency() - //.StartsAt(DateTime.Now.AddMinutes(15)) - //) - .AddApiServer(); + // + //.HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + // .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + //.HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + // .HasDependency() + // .StartsAt(DateTime.Today.AddHours(8)) + //) + .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + .StartsAt(DateTime.Parse("2021-04-01 08:00:00")) + ) + .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + .StartsAt(DateTime.Today.AddHours(26)) + ) + .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + .HasDependency() + .StartsAt(DateTime.Today.AddHours(27) + ) + ); + //.AddApiServer(); }) .AddSingleton() @@ -96,9 +101,10 @@ namespace PartSource.Automation }) .ConfigureLogging((builder, logging) => { + //logging.AddEventLog(); logging.AddConsole(); - logging.AddProvider(new AutomationLoggerProvider()); + // logging.AddProvider(new AutomationLoggerProvider()); }); } } diff --git a/PartSource.Automation/appsettings.json b/PartSource.Automation/appsettings.json index 535d35c..86768e4 100644 --- a/PartSource.Automation/appsettings.json +++ b/PartSource.Automation/appsettings.json @@ -5,7 +5,7 @@ }, "emailConfiguration": { - "From": "alerts@ps-shopify.canadaeast.cloudapp.azure.com", + "From": "alerts@ps-automation.eastus2.cloudapp.azure.com", // "To": "tom@soundpress.com,Anas.Bajwa@Partsource.ca", "To": "tom@tomraterman.com", "SmtpHost": "localhost"