changes after convo

Author: nvmLantana

DotNet/DataAcquisition.Domain/Application/Managers/DataAcquisitionLogManager.cs

@@ -208,7 +208,7 @@ public async Task UpdateTailFlagForFacilityCorrelationIdReportTrackingId(List<lo
 
     public async Task ThrottleFacilityAcquisitions(string facilityId, DateTime executionDate, CancellationToken cancellationToken = default)
     {
-        var lastId = 0;
+        long? lastId = null;
         var batchSize = 1000;
         while (true)
         {
@@ -227,6 +227,8 @@ public async Task ThrottleFacilityAcquisitions(string facilityId, DateTime execu
             }
 
             await _database.DataAcquisitionLogRepository.SaveChangesAsync();
+
+            lastId = toThrottle.Max(l => l.Id);
         }
     }
 }

DotNet/DataAcquisition.Domain/Application/Queries/DataAcquisitionLogQueries.cs

@@ -575,9 +575,7 @@ public async Task<List<DataAcquisitionLogModel>> GetNextEligibleBatchForFacility
                         && (lastId == null || log.Id > lastId)
                         && (log.ExecutionDate == null || log.ExecutionDate <= designagtedExecutionTime)
                         && (log.Status == null || statuses.Contains(log.Status.Value))
-                    orderby log.Priority ascending, 
-                    log.ExecutionDate ascending, 
-                    log.Id ascending
+                    orderby log.Id
                     select new DataAcquisitionLogModel
                     {
                         Id = log.Id,

DotNet/DataAcquisition.Domain/Application/Services/PatientDataService.cs

@@ -227,8 +227,7 @@ public async Task CreateLogEntries(GetPatientDataRequest request, CancellationTo
             {
                 if (request.QueryPlanType == QueryPlanType.Initial)
                 {
-                    var priority = schedReport.ReportTypes?.Any(t => t.Equals("Daily", StringComparison.OrdinalIgnoreCase)) == true
-                        ? AcquisitionPriority.High : AcquisitionPriority.Normal;
+                    var priority = schedReport.Frequency == Frequency.Daily ? AcquisitionPriority.High : AcquisitionPriority.Normal;
 
                     try
                     {
@@ -325,8 +324,7 @@ public async Task ExecuteLogRequest(AcquisitionRequest request, CancellationToke
                     throw new ArgumentException($"Log with ID {request.logId} does not exist.");
                 }
 
-                var now = DateTime.UtcNow;
-                if(log.ExecutionDate >  DateTime.UtcNow)
+                if(log.ExecutionDate > DateTime.UtcNow)
                 {
                     throw new ProcessingDelayException(@$"Log Exection Date {log.ExecutionDate} indicates a future processing time.");
                 }

DotNet/DataAcquisition.Domain/Infrastructure/Models/Enums/AcquisitionPriority.cs

@@ -1,9 +1,4 @@
 using LantanaGroup.Link.Shared.Application.Utilities;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace LantanaGroup.Link.DataAcquisition.Domain.Infrastructure.Models.Enums;
 public enum AcquisitionPriority
@@ -14,4 +9,4 @@ public enum AcquisitionPriority
     High = 1,
     [StringValue("Critical")]
     Critical = 0
-}
+}