Appman-2964: handle ilr resume event

src/CommitmentsV2/SFA.DAS.CommitmentsV2.ExternalHandlers/EventHandlers/LearningResumedEventHandler.cs

@@ -0,0 +1,105 @@
+using System;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+using SFA.DAS.CommitmentsV2.Data;
+using SFA.DAS.CommitmentsV2.Domain.Exceptions;
+using SFA.DAS.CommitmentsV2.Messages.Commands;
+using SFA.DAS.CommitmentsV2.Models;
+using SFA.DAS.CommitmentsV2.Shared.Extensions;
+using SFA.DAS.CommitmentsV2.Types;
+using SFA.DAS.Learning.Types;
+
+namespace SFA.DAS.CommitmentsV2.ExternalHandlers.EventHandlers;
+
+public class LearningResumedEventHandler(
+    Lazy<ProviderCommitmentsDbContext> dbContext,
+    ILogger<LearningResumedEventHandler> logger)
+    : IHandleMessages<LearningResumedEvent>
+{
+    public async Task Handle(LearningResumedEvent message, IMessageHandlerContext context)
+    {
+        try
+        {
+            logger.LogInformation(" Started executing {Event}", nameof(LearningResumedEvent));
+
+            if (message is null)
+            {
+                logger.LogInformation("Event received null message : {Event}", nameof(LearningResumedEvent));
+                return;
+            }
+
+            logger.LogInformation("LearningResumedEvent for ApprenticeshipId {ApprenticeshipId} with ResumeDate {ResumeDate}",
+                message.ApprenticeshipId, message.ResumeDate);
+            var db = dbContext.Value;
+            var apprentice = await db.Apprenticeships
+                .Include(a => a.Cohort)
+                    .ThenInclude(c => c.Provider)
+                .SingleOrDefaultAsync(t => t.Id == message.ApprenticeshipId);
+
+            if (apprentice == null)
+            {
+                throw new DomainException(nameof(apprentice), $"Apprenticeship with Id {message.ApprenticeshipId} not found.");
+            }
+
+            if (apprentice.PaymentStatus == PaymentStatus.Active && !apprentice.PauseDate.HasValue)
+            {
+                logger.LogInformation("Apprenticeship {ApprenticeshipId} is already active and resumed.", apprentice.Id);
+            }
+            else
+            {
+                ValidateResumeDate(message.ResumeDate, apprentice);
+
+                apprentice.SetIlrResumed(message.ResumeDate);
+
+                var historyCommand = new StoreLearningHistoryCommand
+                {
+                    ApprenticeshipId = message.ApprenticeshipId,
+                    Source = LearningSourceType.ILRStatusChange,
+                    ChangeType = LearningChangeType.AutoApproved,
+                    LearningKey = message.LearningKey,
+                    AppliedDate = message.Created,
+                    Description = $"Learning has been resumed on {message.ResumeDate.ToGdsFormat()}"
+                };
+                await context.Send(historyCommand);
+
+                logger.LogInformation(" Executing {Event} completed", nameof(LearningResumedEvent));
+            }
+        }
+        catch (Exception e)
+        {
+            logger.LogError(e, "Error processing LearningResumedEventHandler for ApprenticeshipId {0}", message?.ApprenticeshipId);
+            throw;
+        }
+    }
+
+    private void ValidateResumeDate(DateTime resumeDate, Apprenticeship apprenticeship)
+    {
+        if (apprenticeship.PaymentStatus == PaymentStatus.Completed || apprenticeship.PaymentStatus == PaymentStatus.Withdrawn)
+        {
+            throw new DomainException(nameof(resumeDate), "Learning cannot be Resumed if Payment Status is Completed or Withdrawn. Unable to resume apprenticeship");
+        }
+
+        if (apprenticeship.StartDate.HasValue && apprenticeship.StartDate.Value.Date >= resumeDate.Date)
+        {
+            throw new DomainException(nameof(resumeDate), "Invalid resume date. Learner not started.");
+        }
+
+        if (apprenticeship.EndDate.HasValue && resumeDate.Date >= apprenticeship.EndDate.Value.Date)
+        {
+            throw new DomainException(nameof(resumeDate), "Invalid resume date. Resume date cannot be on or after the end date.");
+        }
+
+        if (apprenticeship.PauseDate.HasValue && resumeDate.Date < apprenticeship.PauseDate.Value.Date)
+        {
+            throw new DomainException(nameof(resumeDate), "Invalid resume date. Resume date cannot be before the pausedate.");
+        }
+
+        if (!apprenticeship.PauseDate.HasValue && resumeDate.Date != DateTime.MinValue)
+        {
+            logger.LogInformation("Apprenticeship paused date is missing for apprenticeship {ApprenticeshipId}.", apprenticeship.Id);
+        }
+    }
+}

src/CommitmentsV2/SFA.DAS.CommitmentsV2.ExternalHandlers/LearningEvents/LearningResumedEvent.cs

@@ -0,0 +1,13 @@
+using System;
+
+namespace SFA.DAS.Learning.Types;
+
+// Replace with SFA.DAS.Learning.Types NuGet package when LearningResumedEvent is published.
+
+public class LearningResumedEvent
+{
+    public Guid LearningKey { get; set; }
+    public long ApprenticeshipId { get; set; }
+    public DateTime Created { get; set; }
+    public DateTime ResumeDate { get; set; }
+}