105 lines
2.4 KiB
C#
105 lines
2.4 KiB
C#
using PartSource.Automation.Jobs.Interfaces;
|
|
using PartSource.Automation.Models;
|
|
using PartSource.Data;
|
|
using PartSource.Data.Models;
|
|
using PartSource.Data.Shopify;
|
|
using PartSource.Services.Integrations;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace PartSource.Automation.Jobs
|
|
{
|
|
public class UpdatePricing : IAutomationJob
|
|
{
|
|
private readonly PartSourceContext _partSourceContext;
|
|
private readonly ShopifyClient _shopifyClient;
|
|
|
|
public UpdatePricing(PartSourceContext partSourceContext, ShopifyClient shopifyClient)
|
|
{
|
|
_partSourceContext = partSourceContext;
|
|
_shopifyClient = shopifyClient;
|
|
|
|
}
|
|
|
|
public async Task<AutomationJobResult> Run()
|
|
{
|
|
IEnumerable<Product> products = null;
|
|
int updateCount = 0;
|
|
|
|
try
|
|
{
|
|
products = await _shopifyClient.Products.Get();
|
|
}
|
|
|
|
catch (Exception ex)
|
|
{
|
|
// TODO: Logging
|
|
|
|
return new AutomationJobResult
|
|
{
|
|
Message = "Failed to get products from Shopify",
|
|
IsSuccess = false
|
|
};
|
|
}
|
|
|
|
while (products != null && products.Any())
|
|
{
|
|
foreach (Product product in products)
|
|
{
|
|
if (product.Variants.Length > 0)
|
|
{
|
|
ProductVariant variant = product.Variants[0];
|
|
PartPrice partPrice = _partSourceContext.PartPrices.Where(p => p.SKU == variant.Sku).FirstOrDefault();
|
|
|
|
if (partPrice == null)
|
|
{
|
|
continue;
|
|
}
|
|
|
|
if (product.Variants[0].Price != partPrice.Your_Price.Value || product.Variants[0].CompareAtPrice != partPrice.Compare_Price.Value)
|
|
{
|
|
product.Variants[0].Price = partPrice.Your_Price.Value;
|
|
product.Variants[0].CompareAtPrice = partPrice.Compare_Price.Value;
|
|
|
|
try
|
|
{
|
|
await _shopifyClient.Products.Update(product);
|
|
|
|
updateCount++;
|
|
}
|
|
|
|
catch (Exception ex)
|
|
{
|
|
// TODO: Logged failed pricing update here
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
try
|
|
{
|
|
products = await _shopifyClient.Products.GetNext();
|
|
}
|
|
|
|
catch (Exception ex)
|
|
{
|
|
// TODO: Logging
|
|
|
|
return new AutomationJobResult
|
|
{
|
|
Message = $"Failed to get the next set of products from Shopify.\n\n {ex}\n\n {updateCount} products were able to be updated.",
|
|
IsSuccess = false
|
|
};
|
|
}
|
|
}
|
|
|
|
return new AutomationJobResult
|
|
{
|
|
Message = $"The nightly pricing update has completed. {updateCount} products were updated.",
|
|
IsSuccess = true
|
|
};
|
|
}
|
|
}
|
|
} |