From 1ae8bd603e8d2f004f7380d4a7541e9be94ad9b3 Mon Sep 17 00:00:00 2001 From: ilitirit Date: Wed, 7 Aug 2024 16:01:00 +0200 Subject: [PATCH] Don't double-upload --- .../Consumers/DutyCompletionResultConsumer.cs | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs index 2f2a357..5a7cc52 100644 --- a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs +++ b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs @@ -64,7 +64,15 @@ namespace Expedience.Api.Consumers UploadedAt = message.UploadDateUtc, }; - dbContext.DutyCompletionResults.Add(completionResult); + var dutyCompletionResult = dbContext.DutyCompletionResults.FirstOrDefault(d => d.Id == message.UploadId); + if (dutyCompletionResult == null) + { + dbContext.DutyCompletionResults.Add(completionResult); + } + else + { + _logger.LogWarning($"The Result with Id {message.Uploadid} has already been uploaded"); + } // Insert this territory if it does not exist var territory = dbContext.Territories.FirstOrDefault(t => t.TerritoryId == completionResult.TerritoryId);