diff --git a/PartSource.Automation/Jobs/POC/UpdateWiperFitment.cs b/PartSource.Automation/Jobs/POC/UpdateWiperFitment.cs index ff38bc4..68d58d4 100644 --- a/PartSource.Automation/Jobs/POC/UpdateWiperFitment.cs +++ b/PartSource.Automation/Jobs/POC/UpdateWiperFitment.cs @@ -52,7 +52,7 @@ namespace PartSource.Automation.Jobs.POC { BaseVehicleId = baseVehicleId }, - MfrCode = new[] { "BOS", "TRI" }, + MfrCode = new[] { "CSD" }, PartType = new[] { new PartType { Id = 8852 } }, Criterion = new[] { diff --git a/PartSource.Automation/Jobs/ProcessWhiFitment.cs b/PartSource.Automation/Jobs/ProcessWhiFitment.cs index 240ebac..b625e65 100644 --- a/PartSource.Automation/Jobs/ProcessWhiFitment.cs +++ b/PartSource.Automation/Jobs/ProcessWhiFitment.cs @@ -43,10 +43,10 @@ namespace PartSource.Automation.Jobs [System.Diagnostics.CodeAnalysis.SuppressMessage("Reliability", "CA2008:Do not create tasks without passing a TaskScheduler", Justification = "")] public async Task Run(CancellationToken token, params string[] arguments) { - _whiSeoService.TruncateFitmentTables(); - // _whiSeoService.GetFiles(_seoDataType); + _whiSeoService.TruncateFitmentTables(); + _whiSeoService.GetFiles(_seoDataType); - string directory = Path.Combine(_ftpConfiguration.Destination, _seoDataType.ToString().ToLowerInvariant()); + string directory = Path.Combine(_ftpConfiguration.Destination, _seoDataType.ToString().ToLowerInvariant()); DirectoryInfo directoryInfo = new DirectoryInfo(directory); ConcurrentQueue> fileGroups = new ConcurrentQueue>(); @@ -96,9 +96,9 @@ namespace PartSource.Automation.Jobs Task.WaitAll(taskArray); - _whiSeoService.CreateFitmentView(); + // _whiSeoService.CreateFitmentView(); - _whiSeoService.SaveNotes(_noteDictionary); + //_whiSeoService.SaveNotes(_noteDictionary); } public string Decompress(FileInfo fileInfo) diff --git a/PartSource.Automation/Jobs/ProcessWhiVehicles.cs b/PartSource.Automation/Jobs/ProcessWhiVehicles.cs index 2a0bae5..6ff9f06 100644 --- a/PartSource.Automation/Jobs/ProcessWhiVehicles.cs +++ b/PartSource.Automation/Jobs/ProcessWhiVehicles.cs @@ -40,7 +40,7 @@ namespace PartSource.Automation.Jobs public async Task Run(CancellationToken token, params string[] arguments) { _whiSeoService.TruncateVehicleTable(); - // _whiSeoService.GetFiles(_seoDataType); + _whiSeoService.GetFiles(_seoDataType); string directory = Path.Combine(_ftpConfiguration.Destination, _seoDataType.ToString().ToLowerInvariant()); DirectoryInfo directoryInfo = new DirectoryInfo(directory); @@ -123,9 +123,9 @@ namespace PartSource.Automation.Jobs && int.TryParse(columns[35], out int engineConfigId) && int.TryParse(columns[36], out int vehicleToEngineConfigId)) { - if (regionId == 2 && new[] { 5, 6, 7 }.Contains(vehicleTypeId)) - { - dataTable.Rows.Add(new object[] { year, makeId, makeName, modelId, modelName, regionId, regionName, vehicleTypeId, engineConfigId, engineDescription, baseVehicleId, vehicleToEngineConfigId, submodelId, submodelName }); + if (regionId == 2 && new[] { 5, 6, 7 }.Contains(vehicleTypeId)) + { + dataTable.Rows.Add(new object[] { year, makeId, makeName, modelId, modelName, regionId, regionName, vehicleTypeId, engineConfigId, engineDescription, baseVehicleId, vehicleToEngineConfigId, submodelId, submodelName }); } } } diff --git a/PartSource.Automation/Jobs/UpdateFitment.cs b/PartSource.Automation/Jobs/UpdateFitment.cs index 60efb30..3b74881 100644 --- a/PartSource.Automation/Jobs/UpdateFitment.cs +++ b/PartSource.Automation/Jobs/UpdateFitment.cs @@ -40,7 +40,11 @@ namespace PartSource.Automation.Jobs try { - products = await _shopifyClient.Products.Get(new Dictionary { { "limit", 250 } }); + products = await _shopifyClient.Products.Get(new Dictionary { { "limit", 250 }, { "product_type", "CA111-SC250-FL25049_Entry Ball Joints" } }); + //products = new List + //{ + // await _shopifyClient.Products.GetById(4388919574575) + //}; } catch (Exception ex) @@ -62,8 +66,8 @@ namespace PartSource.Automation.Jobs IEnumerable metafields = await _shopifyClient.Metafields.Get(new Dictionary { { "metafield[owner_id]", product.Id }, { "metafield[owner_resource]", "product" } }); importData = new ImportData { - LineCode = metafields.FirstOrDefault(m => m.Key == "custom_label_0").Value ?? string.Empty, - PartNumber = metafields.FirstOrDefault(m => m.Key == "custom_label_1").Value ?? string.Empty, + LineCode = metafields.FirstOrDefault(m => m.Key == "custom_label_0")?.Value ?? string.Empty, + PartNumber = metafields.FirstOrDefault(m => m.Key == "custom_label_1")?.Value ?? string.Empty, VariantSku = product.Variants[0].Sku // They know we can't do fitment for variants }; diff --git a/PartSource.Automation/Program.cs b/PartSource.Automation/Program.cs index 4ef6835..90a8d1d 100644 --- a/PartSource.Automation/Program.cs +++ b/PartSource.Automation/Program.cs @@ -100,7 +100,7 @@ namespace PartSource.Automation // //.StartsAt(DateTime.Today.AddHours(25)) // ) - .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) + .HasJob(options => options.HasInterval(new TimeSpan(24, 0, 0)) //.HasDependency() // .StartsAt(DateTime.Today.AddHours(28)) );