Do not add duplicate entries in processed logs

Author: RustyCZ

PbLayla/Processing/TransferProfit.cs

@@ -121,14 +121,14 @@ private async Task ExecuteInnerAsync(CancellationToken cancel)
             }
         }
 
-        m_logger.LogInformation("{AccountName}: Marking {TransactionCount} transaction logs as processed", m_options.Value.AccountName, transactionLogs.Length);
-        await m_profitTransferRepository.MarkTransactionLogsProcessedAsync(transactionLogs,
+        m_logger.LogInformation("{AccountName}: Marking {TransactionCount} transaction logs as processed", m_options.Value.AccountName, missingLogs.Length);
+        await m_profitTransferRepository.MarkTransactionLogsProcessedAsync(missingLogs,
             monthlyTotalProfitChanges,
             monthlyTransferredProfitChanges,
             monthlyRemainingProfitChanges,
             transferDeficit,
             cancel);
-        m_logger.LogInformation("{AccountName}: Marked {TransactionCount} transaction logs as processed", m_options.Value.AccountName, transactionLogs.Length);
+        m_logger.LogInformation("{AccountName}: Marked {TransactionCount} transaction logs as processed", m_options.Value.AccountName, missingLogs.Length);
     }
 
     private static string GetMonthKey(DateTime date)

PbLayla/Repositories/FileProfitTransferRepository.cs

@@ -42,6 +42,10 @@ public async Task MarkTransactionLogsProcessedAsync(IReadOnlyList<TransactionLog
     {
         var processedLogs = await GetProcessedProfitTransferAsync(cancel);
         processedLogs.ProcessedLogs.AddRange(transactionLogs);
+        processedLogs.ProcessedLogs = processedLogs.ProcessedLogs
+            .DistinctBy(x => x.Id)
+            .OrderByDescending(x => x.TransactionType)
+            .ToList();
         processedLogs.TransferDeficit = transferDeficit;
         foreach (var (key, value) in monthlyTotalProfitChanges)
         {