Added base decoding logic + notification logic.

This commit is contained in:
Patrick Fic
2020-01-17 11:03:11 -08:00
parent 572f409176
commit 3357a8a564
11 changed files with 659 additions and 11 deletions

View File

@@ -57,9 +57,7 @@ namespace BodyshopUploader.Utils
try
{
Thread.Sleep(1000);//Allow a small amount of time to pass before processing the queue item so that any writes can finish.
DecodeQueueItemJob(item);
UpsertQueueItem(item);
}
catch
@@ -74,12 +72,13 @@ namespace BodyshopUploader.Utils
{
//Process the job.
logger.Info("Should process the job here. {0}", item.FilePath);
item.Job = Utils.Decoder.EstimateDecoder.CIECAEstimateImport.DecodeEstimate(item.FilePath);
}
private static void UpsertQueueItem(DTO_QueueItem item)
{
//Save the job to the DB.
logger.Info("Should upsert the job graphqlly here. {0}", item.FilePath);
logger.Info("Should upsert the job graphqlly here. {0}", item.Job);
_jobs.Dequeue();
}