Merge pull request #16 from SoftTeam-Emergentes/feat/art-event-manage…

…ment2 feat: add delete features
SoftTeam-Emergentes · Nov 13, 2023 · 18ecebe · 18ecebe
2 parents 13a8e38 + 72cc50c
commit 18ecebe
Show file tree

Hide file tree

Showing 13 changed files with 166 additions and 5 deletions.
diff --git a/...TARS/AtEventManagement/Application/Participant/Command/DeleteParticipantCommandHandler.cs b/...TARS/AtEventManagement/Application/Participant/Command/DeleteParticipantCommandHandler.cs
@@ -0,0 +1,43 @@
+using MediatR;
+using PERUSTARS.AtEventManagement.Domain.Model.Aggregates;
+using PERUSTARS.AtEventManagement.Domain.Model.Commads;
+using PERUSTARS.AtEventManagement.Domain.Model.Repositories;
+using PERUSTARS.Shared.Domain.Repositories;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace PERUSTARS.AtEventManagement.Application.Participant.Command
+{
+    public class DeleteParticipantCommandHandler:IRequestHandler<DeleteParticipantCommand,string>
+    {
+        private readonly IParticipantRepository _participantRepository;
+        private readonly IUnitOfWork _unitOfWork;
+        public DeleteParticipantCommandHandler(IParticipantRepository participantRepository, IUnitOfWork unitOfWork)
+        {
+            _participantRepository = participantRepository;
+            _unitOfWork = unitOfWork;
+        }
+
+        public async Task<string> Handle(DeleteParticipantCommand request, CancellationToken cancellationToken)
+        {
+            try
+            {
+                PERUSTARS.AtEventManagement.Domain.Model.Aggregates.Participant p = _participantRepository.FindByIdAsync(request.id).Result;
+                if (p != null)
+                {
+                    _participantRepository.Remove(p);
+                    await _unitOfWork.CompleteAsync();
+                    return "Participant deleted";
+                }
+                else {
+                    return "Participant with the given Id doesn't exist";
+                }
+            }
+            catch (Exception e) {
+                throw new ApplicationException($"An error occurred while deleting the participant: {e.Message}");
+            }
+
+        }
+    }
+}
diff --git a/...RS/AtEventManagement/Application/Participant/Command/Service/ParticipantCommandService.cs b/...RS/AtEventManagement/Application/Participant/Command/Service/ParticipantCommandService.cs
@@ -0,0 +1,21 @@
+using MediatR;
+using PERUSTARS.AtEventManagement.Domain.Model.Commads;
+using PERUSTARS.AtEventManagement.Domain.Services.Participant;
+using System.Threading.Tasks;
+
+namespace PERUSTARS.AtEventManagement.Application.Participant.Command.Service
+{
+    public class ParticipantCommandService:IParticipantCommandService
+    {
+        private readonly IMediator _mediator;
+        public ParticipantCommandService(IMediator mediator)
+        {
+            _mediator = mediator;
+        }
+
+        public async Task<string> deleteParticipant(DeleteParticipantCommand deleteParticipantCommand)
+        {
+            return await _mediator.Send(deleteParticipantCommand);
+        }
+    }
+}
diff --git a/...ERUSTARS/AtEventManagement/Application/artevents/commands/DeleteArtEventCommandHandler.cs b/...ERUSTARS/AtEventManagement/Application/artevents/commands/DeleteArtEventCommandHandler.cs
@@ -0,0 +1,40 @@
+using MediatR;
+using PERUSTARS.AtEventManagement.Domain.Model.Aggregates;
+using PERUSTARS.AtEventManagement.Domain.Model.Commads;
+using PERUSTARS.AtEventManagement.Domain.Model.Repositories;
+using PERUSTARS.Shared.Domain.Repositories;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace PERUSTARS.AtEventManagement.Application.artevents.commands
+{
+    public class DeleteArtEventCommandHandler : IRequestHandler<DeleteArtEventCommand, string>
+    {
+        private readonly IArtEventRepository _artEventRepository;
+        private readonly IUnitOfWork _unitOfWork;
+        public DeleteArtEventCommandHandler(IArtEventRepository artEventRepository, IUnitOfWork unitOfWork)
+        {
+            _artEventRepository = artEventRepository;
+            _unitOfWork = unitOfWork;
+        }
+
+        public async Task<string> Handle(DeleteArtEventCommand request, CancellationToken cancellationToken)
+        {
+            try
+            {
+                ArtEvent artEvent= _artEventRepository.FindByIdAsync(request.id).Result;
+                if (artEvent != null) {
+                    _artEventRepository.Remove(artEvent);
+                    await _unitOfWork.CompleteAsync();
+
+                }
+            }
+            catch(Exception e) {
+                throw new ApplicationException($"An error occurred while deleting the art event: {e.Message}");
+
+            }
+            return "Art event deleted";
+        }
+    }
+}
diff --git a/...tManagement/Application/artevents/commands/RegisterParticipantToArtEventCommandHandler.cs b/...tManagement/Application/artevents/commands/RegisterParticipantToArtEventCommandHandler.cs
@@ -8,6 +8,7 @@
 using PERUSTARS.Shared.Domain.Repositories;
 using System.Threading;
 using System.Threading.Tasks;
+using System;
 
 namespace PERUSTARS.AtEventManagement.Application.artevents.commands
 {
@@ -35,7 +36,7 @@ public async Task<string> Handle(RegisterParticipantToArtEventCommand request, C
                 id: 0,
                 userName: "A",
                 registerDateTime: new System.DateTime(),
-                checkInDateTime: null,
+                checkInDateTime: DateTime.UtcNow,
                 hobbyistId: request.hobbyistId,
                 artEventId: request.artEventId,
                 hobbyist: hobbyist,

diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Application/artevents/service/ArtEventService.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Application/artevents/service/ArtEventService.cs
@@ -50,5 +50,9 @@ public async Task<string> startArtEventCommand(StartArtEventCommand startArtEven
         {
             return await _mediator.Send(startArtEventCommand);
         }
+
+        public async Task<string> deleteArtEvent(DeleteArtEventCommand deleteArtEventCommand) {
+            return await _mediator.Send(deleteArtEventCommand);
+        }
     }
 }
diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Aggregates/Participant.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Aggregates/Participant.cs
@@ -24,6 +24,7 @@ public Participant(long id, string userName, DateTime registerDateTime, DateTime
             UserName = userName;
             RegisterDateTime = registerDateTime;
             CheckInDateTime = checkInDateTime;
+            ParticipantRegistrationDateTime = DateTime.UtcNow;
             HobbyistId = hobbyistId;
             ArtEventId = artEventId;
             Hobyst = hobbyist;

diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Commads/DeleteArtEventCommand.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Commads/DeleteArtEventCommand.cs
@@ -0,0 +1,9 @@
+using MediatR;
+
+namespace PERUSTARS.AtEventManagement.Domain.Model.Commads
+{
+    public class DeleteArtEventCommand:IRequest<string>
+    {
+        public int id { get; set; }
+    }
+}
diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Commads/DeleteParticipantCommand.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Model/Commads/DeleteParticipantCommand.cs
@@ -0,0 +1,9 @@
+using MediatR;
+
+namespace PERUSTARS.AtEventManagement.Domain.Model.Commads
+{
+    public class DeleteParticipantCommand:IRequest<string>
+    {
+        public int id { get; set; }
+    }
+}
diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Services/ArtEvent/IArtEventCommandService.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Domain/Services/ArtEvent/IArtEventCommandService.cs
@@ -12,5 +12,6 @@ public interface IArtEventCommandService
         Task<string> finishArtEvent(FinishArtEventCommand finishArtEventCommand);
         Task<string> rescheduleArtEvent(RescheduleArtEventCommand rescheduleArtEventCommand);
         Task<string> startArtEventCommand(StartArtEventCommand startArtEventCommand);
+        Task<string> deleteArtEvent(DeleteArtEventCommand deleteArtEventCommand);
     }
 }
diff --git a/...ARS/PERUSTARS/AtEventManagement/Domain/Services/Participant/IParticipantCommandService.cs b/...ARS/PERUSTARS/AtEventManagement/Domain/Services/Participant/IParticipantCommandService.cs
@@ -0,0 +1,10 @@
+using PERUSTARS.AtEventManagement.Domain.Model.Commads;
+using System.Threading.Tasks;
+
+namespace PERUSTARS.AtEventManagement.Domain.Services.Participant
+{
+    public interface IParticipantCommandService
+    {
+        Task<string> deleteParticipant(DeleteParticipantCommand deleteParticipantCommand);
+    }
+}
diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Interfaces/rest/ArtEventController.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Interfaces/rest/ArtEventController.cs
@@ -77,5 +77,14 @@ public async Task<IActionResult> createParticipant([FromBody] RegisterParticipan
             string response= await _artEventCommandService.registerParticipantToArtEvent(registerParticipantToArtEvent);
             return Ok(response);
         }
+
+        [HttpDelete("id")]
+        public async Task<IActionResult> deleteArtEvent(int id) {
+            DeleteArtEventCommand deleteArtEventCommand = new DeleteArtEventCommand();
+            deleteArtEventCommand.id=id;
+            string response = await _artEventCommandService.deleteArtEvent(deleteArtEventCommand);
+            return Ok(response);
+        }
+
     }
 }
diff --git a/PERUSTARS/PERUSTARS/AtEventManagement/Interfaces/rest/ParticipantController.cs b/PERUSTARS/PERUSTARS/AtEventManagement/Interfaces/rest/ParticipantController.cs
@@ -2,6 +2,7 @@
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.EntityFrameworkCore.Metadata;
 using PERUSTARS.AtEventManagement.Domain.Model.Aggregates;
+using PERUSTARS.AtEventManagement.Domain.Model.Commads;
 using PERUSTARS.AtEventManagement.Domain.Services.Participant;
 using System.Collections;
 using System.Collections.Generic;
@@ -14,10 +15,12 @@ public class ParticipantController : ControllerBase
     {
         private readonly IMapper _mapper;
         private readonly IParticipantQueryService _participantQueryService;
-        public ParticipantController(IMapper mapper, IParticipantQueryService participantQueryService)
+        private readonly IParticipantCommandService _participantCommandService;
+        public ParticipantController(IMapper mapper, IParticipantQueryService participantQueryService, IParticipantCommandService participantCommandService)
         {
             _mapper = mapper;
             _participantQueryService = participantQueryService;
+            _participantCommandService=participantCommandService;
         }
 
         [HttpGet]
@@ -27,17 +30,25 @@ public async Task<IActionResult> getParticipants()
             return Ok(participants);
         }
 
-        [HttpGet("/hobbyist/{id}")]
+        [HttpGet("hobbyist/{id}")]
         public async Task<IActionResult> getParticipantsByHobbyistId(int id)
         {
             IEnumerable<Participant> participants = _participantQueryService.getParticipantByHobbyistId(id);
             return Ok(participants);
         }
-        [HttpGet("/artevent/{id}")]
+        [HttpGet("artevent/{id}")]
         public async Task<IActionResult> getParticipantsByArtEventId(int id)
         {
             IEnumerable<Participant> participants = _participantQueryService.getParticipantByEventId(id);
             return Ok(participants);
         }
+
+        [HttpDelete("{id}")]
+        public async Task<IActionResult> deleteParticipant(int id) {
+            DeleteParticipantCommand d = new DeleteParticipantCommand();
+            d.id = id;
+            string response = _participantCommandService.deleteParticipant(d).Result;
+            return Ok(response);
+        }
     }
 }
diff --git a/PERUSTARS/PERUSTARS/Startup.cs b/PERUSTARS/PERUSTARS/Startup.cs
@@ -48,6 +48,8 @@
 using PERUSTARS.DataAnalytics.Domain.Services;
 using PERUSTARS.DataAnalytics.Application.Commands.Services;
 using Microsoft.Extensions.Logging;
+using PERUSTARS.AtEventManagement.Application.Participant.Command.Service;
+
 using PERUSTARS.DataAnalytics.Application.Jobs;
 using PERUSTARS.DataAnalytics.Infrastructure.FeignClients;
 
@@ -127,7 +129,7 @@ public void ConfigureServices(IServiceCollection services)
             services.AddScoped<IArtEventCommandService, ArtEventService>();
             services.AddScoped<IArtEventQueryService, ArtEventQueryService>();
             services.AddScoped<IParticipantQueryService, ParticipantQueryService>();
-
+            services.AddScoped<IParticipantCommandService, ParticipantCommandService>();
 
             services.AddScoped<IArtworkCommandService, ArtworkCommandService>();
             services.AddScoped<IArtworkRecommendationCommandService, ArtworkRecommendationCommandService>();