9 Commits

Author SHA1 Message Date
285063ebcd - Endpoints fini.. 2025-03-06 00:12:23 +01:00
37eca08753 - Ajout de la fonctionnalité de recherche
- Ajout du Seed
2025-03-05 21:00:30 +01:00
3041e85add - Ajout des méthodes dans le I/RepositoryBase.cs et dans le ServiceBase.cs : ces méthodes permettent de retourner les relations précisées en argumant des fonctions GetAllWithRelations et GetByIdWithRelations.
- Ajout d'une vérification des entrées dans les méthodes génériques. On passe par des inputDto qui
2025-03-05 14:07:23 +01:00
yoannlgd
f0928aae3b - Push des classes qui n'ont pas été jetées 2025-03-04 09:11:23 +01:00
yoannlgd
fe91908098 - Ajout d'un service base pour plus de scalabilité et de duplication de code 2025-03-03 18:31:37 +01:00
aed5f7ea93 Merge pull request '- Ajout de tous les crud' (#5) from feat/poursuite-crud into dev
Reviewed-on: http://192.168.1.94:3000/Yoann/ldap-cesi/pulls/5
2025-03-03 00:57:29 +01:00
1fb1f49f9d - Ajout de tous les crud
//TODO : revoir le retour des fonctions getSSalarieByService/site
2025-03-03 00:56:59 +01:00
fe7d50971f Merge pull request '- Ajout de fluent validator' (#4) from feat/add-fluent-validator into dev
Reviewed-on: http://192.168.1.94:3000/Yoann/ldap-cesi/pulls/4
2025-03-02 17:19:10 +01:00
272e928304 - Ajout de fluent validator
- Ajout d'une validation sur le dtoLogin
2025-03-02 17:18:54 +01:00
50 changed files with 1833 additions and 145 deletions

View File

@@ -1,4 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="VcsDirectoryMappings" defaultProject="true" /> <component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project> </project>

View File

@@ -1,6 +1,8 @@
using System.Reflection; using System.Reflection;
using System.Security.Cryptography; using System.Security.Cryptography;
using System.Text; using System.Text;
using FluentValidation;
using FluentValidation.AspNetCore;
using ldap_cesi.Context; using ldap_cesi.Context;
using ldap_cesi.Repository; using ldap_cesi.Repository;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
@@ -27,6 +29,7 @@ public static class Conf
builder.AddSerilog(); builder.AddSerilog();
builder.AddJwt(); builder.AddJwt();
builder.Services.AddAutoMapper(typeof(Program)); builder.Services.AddAutoMapper(typeof(Program));
} }
public static void AddRepositories(this WebApplicationBuilder builder) public static void AddRepositories(this WebApplicationBuilder builder)
@@ -41,18 +44,20 @@ public static class Conf
public static void AddServices(this WebApplicationBuilder builder) public static void AddServices(this WebApplicationBuilder builder)
{ {
builder.Services.AddScoped<IServiceService, ServiceService >(); builder.Services.AddScoped<IServiceService, ServiceService >();
// builder.Services.AddScoped<IRoleService, RoleService>(); builder.Services.AddScoped<IRoleService, RoleService>();
// builder.Services.AddScoped<ISiteService, SiteService>(); builder.Services.AddScoped<ISiteService, SiteService>();
builder.Services.AddScoped<ISalarieService, SalarieService>(); builder.Services.AddScoped<ISalarieService, SalarieService>();
builder.Services.AddScoped<IUtilisateurService, UtilisateurService>(); builder.Services.AddScoped<IUtilisateurService, UtilisateurService>();
builder.Services.AddScoped<IJwtService, JwtService>(); builder.Services.AddScoped<IJwtService, JwtService>();
builder.Services.AddSingleton<IRsaKeyService, RsaKeyService>(); builder.Services.AddSingleton<IRsaKeyService, RsaKeyService>();
builder.Services.AddValidatorsFromAssemblyContaining<Program>();
builder.Services.AddFluentValidationAutoValidation();
} }
public static void AddEFCoreConfiguration(this WebApplicationBuilder builder) public static void AddEFCoreConfiguration(this WebApplicationBuilder builder)
{ {
string connectionString = builder.Configuration.GetConnectionString("DefaultConnection"); string connectionString = builder.Configuration.GetConnectionString("DefaultConnection");
builder.Services.AddDbContext<PgContext>(options => options.UseNpgsql(connectionString)); builder.Services.AddDbContext<PgContext>(options => options.UseNpgsql(connectionString));
} }
public static void CorseConfiguration(this WebApplicationBuilder builder) public static void CorseConfiguration(this WebApplicationBuilder builder)
{ {
builder.Services.AddCors(options => builder.Services.AddCors(options =>

View File

@@ -0,0 +1,88 @@
using Microsoft.AspNetCore.Mvc;
using ldap_cesi.DTOs.Inputs.Role;
using ldap_cesi.Services.Interfaces;
using Microsoft.AspNetCore.Authorization;
namespace ldap_cesi.Controllers
{
[Route("api/[controller]")]
[ApiController]
public class RoleController : ControllerBase
{
private readonly IRoleService _roleService;
public RoleController(IRoleService roleService)
{
_roleService = roleService;
}
// GET: api/Role
/// <summary>
/// Endpoint qui retourne tous les rôles
/// </summary>
/// <returns>Un tableau de rôle</returns>
[HttpGet]
[Authorize(Roles = "admin")]
public async Task<IActionResult> GetAllRoles()
{
var result = await _roleService.GetAll();
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
// GET: api/Role/{id}
/// <summary>
/// Endpoint qui retourne le role
/// </summary>
/// <param name="id">L'id du rôle.</param>
/// <returns>Le role update</returns>
[HttpGet("{id}")]
[Authorize(Roles = "admin")]
public async Task<IActionResult> GetRoleById(int id)
{
var result = await _roleService.GetById(id);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
// POST: api/Role
/// <summary>
/// Endpoint créer le Role
/// </summary>
/// <param name="CreateRoleInput">Le nom du rôle.</param>
/// <returns>Response.</returns>
[HttpPost]
[Authorize(Roles = "admin")]
public async Task<IActionResult> CreateRole([FromBody] RoleCreateDto roleDto)
{
var result = await _roleService.Create(roleDto);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
// PUT: api/Role
/// <summary>
/// Endpoint qui met à jour un role.
/// </summary>
/// <param name="roleUpdateDto">Les informations du role à mettre à jour. Id, nom</param>
/// <returns>Le role mis à jour.</returns>
[HttpPut]
[Authorize(Roles = "admin")]
public async Task<IActionResult> UpdateRole([FromBody] RoleUpdateDto roleDto)
{
var result = await _roleService.Update(roleDto);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
// DELETE: api/Role/{id}
/// <summary>
/// Endpoint qui supprime un rôle.
/// </summary>
/// <param name="id">L'ID du rôle à supprimer.</param>
/// <returns>Un message de confirmation de suppression.</returns>
[HttpDelete("{id}")]
[Authorize(Roles = "admin")]
public async Task<IActionResult> DeleteRole(int id)
{
var result = await _roleService.Delete(id);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
}
}

View File

@@ -1,4 +1,7 @@
using ldap_cesi.DTOs.Inputs.Salarie;
using ldap_cesi.DTOs.Inputs.Service;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
namespace ldap_cesi.Controllers; namespace ldap_cesi.Controllers;
@@ -13,27 +16,132 @@ public class SalarieController : ControllerBase
_salarieService = salarieService; _salarieService = salarieService;
} }
// GET: api/salaries
/// <summary> /// <summary>
/// Endpoint qui retournes tous les salaries /// Endpoint qui retourne tous les salariés.
/// </summary> /// </summary>
/// <returns>List<Salarie></returns> /// <returns>Une liste de salariés.</returns>
[HttpGet] [HttpGet]
public async Task<ActionResult> GetUtilisateurs() public async Task<IActionResult> GetAllSalaries()
{ {
var result = await _salarieService.GetAll(); var result = await _salarieService.GetAll();
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
} }
// GET: api/salaries
[HttpGet("search")]
[Authorize(Roles = "admin")]
public async Task<IActionResult> SearchSalaries(
[FromQuery] string searchTerm,
[FromQuery] int pageNumber = 1,
[FromQuery] int pageSize = 10)
{
if (string.IsNullOrWhiteSpace(searchTerm) || searchTerm.Length < 2)
{
return BadRequest("Votre recherche doit contenir au moins deux caractères.");
}
var result = await _salarieService.SearchWithRelations(
searchTerm, pageNumber, pageSize, s => s.IdServiceNavigation, s => s.IdSiteNavigation);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary> /// <summary>
/// Endpoint retourne le salarie correspondant à l'id en param /// Endpoint qui retourne le salarié correspondant à l'ID en paramètre.
/// </summary> /// </summary>
/// <returns>Salarie</returns> /// <param name="id">L'ID du salarié.</param>
/// <returns>Le salarié correspondant à l'ID.</returns>
[HttpGet("{id}")] [HttpGet("{id}")]
public async Task<ActionResult> GetUtilisateurById(int id) public async Task<IActionResult> GetById(int id)
{ {
var result = await _salarieService.GetById(id); var result = await _salarieService.GetById(id);
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui retourne le salarié correspondant à l'ID en paramètre. Avec le nom de service et de site auxquels il apaprtient.
/// </summary>
/// <param name="id">L'ID du salarié.</param>
/// <returns>Le salarié correspondant à l'ID. Ainsi que son service et son site</returns>
[HttpGet("/complet/{id}")]
public async Task<IActionResult> GetSalarieCompletById(int id)
{
var result = await _salarieService.GetByIdWithRelations(id,s => s.IdServiceNavigation, s => s.IdSiteNavigation);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
} }
}
/// <summary>
/// Endpoint qui retourne tout les salariés et les relations qu'il détient
/// </summary>
/// <returns>Tous les salariés avec leurs relations</returns>
[HttpGet("all")]
public async Task<IActionResult> GetAllSariesWithRelations()
{
var result = await _salarieService.GetAllWithRelationsAsync(s => s.IdServiceNavigation, s => s.IdSiteNavigation);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui crée un salarié.
/// </summary>
/// <param name="salarieInput">Les informations du salarié à créer.</param>
/// <returns>Le salarié créé.</returns>
[HttpPost]
[Authorize(Roles = "admin")]
public async Task<IActionResult> CreateSalarie([FromBody] SalarieCreateDto salarieInput)
{
var result = await _salarieService.Create(salarieInput);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui met à jour un salarié.
/// </summary>
/// <param name="salarieInput">Les informations du salarié à mettre à jour.</param>
/// <returns>Le salarié mis à jour.</returns>
[HttpPut]
[Authorize(Roles = "admin")]
public async Task<IActionResult> UpdateSalarie([FromBody] SalarieUpdateDto salarieInput)
{
var result = await _salarieService.Update(salarieInput);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui supprime un salarié.
/// </summary>
/// <param name="id">L'ID du salarié à supprimer.</param>
/// <returns>Un message de confirmation de suppression.</returns>
[HttpDelete("{id}")]
[Authorize(Roles = "admin")]
public async Task<IActionResult> DeleteSalarie(int id)
{
var result = await _salarieService.Delete(id);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Récupère les salariés appartenant à un site spécifique
/// </summary>
/// <param name="siteId">Identifiant du site</param>
/// <returns>Liste des salariés du site</returns>
[HttpGet("site/{siteId}")]
public async Task<IActionResult> GetSalariesBySite(int siteId)
{
var result = await _salarieService.GetSalariesBySite(siteId);
return result.Success ? Ok(result.Data) : NotFound(result.Message);
}
/// <summary>
/// Récupère les salariés appartenant à un service spécifique
/// </summary>
/// <param name="serviceId">Identifiant du service</param>
/// <returns>Liste des salariés du service</returns>
[HttpGet("service/{serviceId}")]
public async Task<IActionResult> GetSalariesByService(int serviceId)
{
var result = await _salarieService.GetSalariesByService(serviceId);
return result.Success ? Ok(result.Data) : NotFound(result.Message);
}
}

View File

@@ -16,40 +16,77 @@ public class ServicesController : ControllerBase
_serviceService = serviceService; _serviceService = serviceService;
} }
// GET: api/services
/// <summary> /// <summary>
/// Endpoint qui retournes tous les services /// Endpoint qui retourne tous les services.
/// </summary> /// </summary>
/// <returns>Retourne tous les services</returns> /// <returns>Retourne tous les services.</returns>
[HttpGet] [HttpGet]
// [Authorize(Roles = "admin")] public async Task<IActionResult> GetServices()
public async Task<ActionResult> GetServices()
{ {
var result = await _serviceService.GetAll(); var result = await _serviceService.GetAll();
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
} }
// GET: api/services
/// <summary> /// <summary>
/// Endpoint retourne le service correspondant à l'id en param /// Endpoint qui retourne le service correspondant à l'id en paramètre.
/// </summary> /// </summary>
/// <returns>Service</returns> /// <param name="id">L'ID du service.</param>
/// <returns>Le service correspondant à l'ID.</returns>
[HttpGet("{id}")] [HttpGet("{id}")]
public async Task<ActionResult> GetServices(int id) public async Task<IActionResult> GetServiceById(int id)
{ {
var result = await _serviceService.GetById(id); var result = await _serviceService.GetById(id);
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
// {POST}: api/services
/// <summary>
/// Endpoint qui créé un service
/// </summary>
/// <returns>Retourne tous les services</returns>
[HttpPost]
public async Task<ActionResult> CreateService([FromBody] ServiceCreateDto serviceInputDto)
{
var result = await _serviceService.CreateService(serviceInputDto);
return result.Success ? Ok(result) : BadRequest(result);
} }
/// <summary>
/// Endpoint qui retourne le service et ses salariés correspondant à l'id en paramètre.
/// </summary>
/// <param name="id">L'ID du service.</param>
/// <returns>Le service correspondant à l'ID, avec ses salariés</returns>
[HttpGet("complete/{id}")]
public async Task<IActionResult> GetServiceByIdWithSalaries(int id)
{
var result = await _serviceService.GetByIdWithRelations(id, s=>s.Salaries);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui crée un service.
/// </summary>
/// <param name="serviceInputDto">Les informations du service à créer.</param>
/// <returns>Le service créé.</returns>
[HttpPost]
[Authorize(Roles = "admin")]
public async Task<IActionResult> CreateService([FromBody] ServiceCreateDto serviceInputDto)
{
var result = await _serviceService.Create(serviceInputDto);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui met à jour un service.
/// </summary>
/// <param name="serviceUpdateDto">Les informations du service à mettre à jour.</param>
/// <returns>Le service mis à jour.</returns>
[HttpPut]
[Authorize(Roles = "admin")]
public async Task<IActionResult> UpdateService([FromBody] ServiceUpdateDto serviceUpdateDto)
{
var result = await _serviceService.Update(serviceUpdateDto);
return result.Success ? Ok(result.Data) : BadRequest(result.Message);
}
/// <summary>
/// Endpoint qui supprime un service.
/// </summary>
/// <param name="id">L'ID du service à supprimer.</param>
/// <returns>Un message de confirmation de suppression.</returns>
[HttpDelete("{id}")]
[Authorize(Roles = "admin")]
public async Task<IActionResult> DeleteService(int id)
{
var result = await _serviceService.Delete(id);
return result.Success ? Ok(result.Message) : BadRequest(result.Message);
}
} }

View File

@@ -0,0 +1,97 @@
using ldap_cesi.DTOs.Inputs.Site;
using ldap_cesi.Services.Interfaces;
using Microsoft.AspNetCore.Mvc;
namespace ldap_cesi.Controllers;
[ApiController]
[Route("/api/site")]
public class SiteController : ControllerBase
{
private readonly ISiteService _siteService;
public SiteController(ISiteService siteService)
{
_siteService = siteService;
}
// GET: api/site
/// <summary>
/// Récupère la liste de tous les sites.
/// </summary>
/// <returns>Retourne une liste de tous les sites.</returns>
[HttpGet]
public async Task<ActionResult> GetSites()
{
var result = await _siteService.GetAll();
return result.Success ? Ok(result) : BadRequest(result);
}
// GET: api/site/{id}
/// <summary>
/// Récupère un site spécifique par son identifiant.
/// </summary>
/// <param name="id">L'identifiant du site à récupérer.</param>
/// <returns>Retourne le site correspondant à l'identifiant.</returns>
/// <response code="200">Le site a été récupéré avec succès.</response>
/// <response code="400">Une erreur s'est produite lors de la récupération du site.</response>
/// <response code="404">Le site n'a pas été trouvé.</response>
[HttpGet("{id}")]
public async Task<ActionResult> GetSite(int id)
{
var result = await _siteService.GetById(id);
return result.Success ? Ok(result) : BadRequest(result);
}
// GET: api/site/{id}
/// <summary>
/// Récupère un site et ses salariés spécifique par son identifiant.
/// </summary>
/// <param name="id">L'identifiant du site à récupérer.</param>
/// <returns>Retourne le site et ses salariés</returns>
[HttpGet("/complete/{id}")]
public async Task<ActionResult> GetSiteWithClient(int id)
{
var result = await _siteService.GetByIdWithRelations(id, s => s.Salaries);
return result.Success ? Ok(result) : BadRequest(result);
}
// POST: api/site
/// <summary>
/// Crée un nouveau site.
/// </summary>
/// <param name="siteCreateDto">Les données du site à créer.</param>
/// <returns>Retourne l'identifiant du site créé.</returns>
[HttpPost]
public async Task<ActionResult> CreateSite([FromBody] SiteCreateDto siteCreateDto)
{
var result = await _siteService.CreateSite(siteCreateDto);
return result.Success ? Ok(result) : BadRequest(result);
}
// PUT: api/site
/// <summary>
/// Met à jour un site existant.
/// </summary>
/// <param name="siteUpdateDto">Les données du site à mettre à jour.</param>
/// <returns>Retourne l'objet ou une erreur.</returns>
[HttpPut]
public async Task<IActionResult> UpdateSite([FromBody] SiteUpdateDto siteUpdateDto)
{
var result = await _siteService.UpdateSite(siteUpdateDto);
return result.Success ? Ok(result) : BadRequest(result);
}
// DELETE: api/site/{id}
/// <summary>
/// Supprime un site par son identifiant.
/// </summary>
/// <param name="id">L'identifiant du site à supprimer.</param>
/// <returns>Retourne l'id, ou l'erreur</returns>
[HttpDelete("{id}")]
public async Task<IActionResult> DeleteSite(int id)
{
var result = await _siteService.DeleteSite(id);
return result.Success ? Ok(result) : BadRequest(result);
}
}

View File

@@ -1,5 +1,6 @@
using ldap_cesi.DTOs.Inputs; using ldap_cesi.DTOs.Inputs;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
namespace ldap_cesi.Controllers; namespace ldap_cesi.Controllers;
@@ -13,35 +14,42 @@ public class UtilisateurController : ControllerBase
{ {
_utilisateurService = utilisateurService; _utilisateurService = utilisateurService;
} }
/// <summary>
/// Endpoint pour la connexion des utilisateurs.
/// </summary>
/// <param name="utilisateurInput">Les informations de connexion de l'utilisateur.</param>
/// <returns>Un token JWT si la connexion est réussie.</returns>
[HttpPost("login")] [HttpPost("login")]
public async Task<IActionResult> Login([FromBody] UtilisateurLoginDto utilisateurInput) public async Task<IActionResult> Login([FromBody] UtilisateurLoginDto utilisateurInput)
{ {
var response = await _utilisateurService.Login(utilisateurInput); var response = await _utilisateurService.Login(utilisateurInput);
return StatusCode(response.StatusCode, response); return StatusCode(response.StatusCode, response);
} }
// GET: api/utilisateurs
/// <summary> /// <summary>
/// Endpoint qui retournes tous les utilisateurs /// Endpoint pour récupérer tous les utilisateurs.
/// </summary> /// </summary>
/// <returns>List<Utilisateur></returns> /// <returns>Une liste d'utilisateurs.</returns>
[HttpGet] [HttpGet]
public async Task<ActionResult> GetUtilisateurs() [Authorize(Roles = "admin")]
public async Task<IActionResult> GetUtilisateurs()
{ {
var result = await _utilisateurService.GetAll(); var result = await _utilisateurService.GetAll();
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
} }
// GET: api/utilisateur
/// <summary> /// <summary>
/// Endpoint retourne l'utilisateur correspondant à l'id en param /// Endpoint pour récupérer un utilisateur par son ID.
/// </summary> /// </summary>
/// <returns>Utilisateur</returns> /// <param name="id">L'ID de l'utilisateur.</param>
/// <returns>L'utilisateur correspondant à l'ID.</returns>
[HttpGet("{id}")] [HttpGet("{id}")]
public async Task<ActionResult> GetUtilisateurById(int id) [Authorize(Roles = "admin")]
public async Task<IActionResult> GetUtilisateurById(int id)
{ {
var result = await _utilisateurService.GetById(id); var result = await _utilisateurService.GetById(id);
return result.Success ? Ok(result) : BadRequest(result); return result.Success ? Ok(result.Data) : BadRequest(result.Message);
} }
} }

View File

@@ -0,0 +1,8 @@
namespace ldap_cesi.DTOs;
public class RoleDto
{
public int Id { get; set; }
public string Nom { get; set; }
}

View File

@@ -0,0 +1,19 @@
namespace ldap_cesi.DTOs;
public class SalarieDto
{
public int Id { get; set; }
public string Nom { get; set; } = null!;
public string Prenom { get; set; } = null!;
public string TelephoneFixe { get; set; } = null!;
public string TelephonePortable { get; set; } = null!;
public string Email { get; set; } = null!;
public ServiceDto Service { get; set; }
public SiteDto Site { get; set; }
}

View File

@@ -0,0 +1,11 @@
using ldap_cesi.DTOs.Outputs.Salarie;
namespace ldap_cesi.DTOs;
public class ServiceDto
{
public int Id { get; set; }
public string Nom { get; set; }
public List<SalarieMinimalDto> Salaries { get; set; }
}

View File

@@ -0,0 +1,11 @@
using ldap_cesi.DTOs.Outputs.Salarie;
namespace ldap_cesi.DTOs;
public class SiteDto
{
public int Id { get; set; }
public string Ville { get; set; }
public ICollection<SalarieMinimalDto> Salaries { get; set; }
}

View File

@@ -0,0 +1,7 @@
namespace ldap_cesi.DTOs.Inputs.Role;
public class RoleCreateDto
{
public string Nom { get; set; }
}

View File

@@ -0,0 +1,7 @@
namespace ldap_cesi.DTOs.Inputs.Role;
public class RoleUpdateDto
{
public int Id { get; set; }
public string Nom { get; set; }
}

View File

@@ -4,8 +4,8 @@ public class SalarieCreateDto
{ {
public string Nom { get; set; } public string Nom { get; set; }
public string Prenom { get; set; } public string Prenom { get; set; }
public string Telephone_fix { get; set; } public string TelephoneFix { get; set; }
public string Telephone_portable { get; set; } public string TelephonePortable { get; set; }
public string Email { get; set; } public string Email { get; set; }
public int IdSite { get; set; } public int IdSite { get; set; }
public int IdService { get; set; } public int IdService { get; set; }

View File

@@ -0,0 +1,12 @@
namespace ldap_cesi.DTOs.Outputs.Salarie;
public class SalarieListDto
{
public int Id { get; set; }
public string Nom { get; set; }
public string Prenom { get; set; }
public string NomComplet => $"{Prenom} {Nom}";
public ServiceDto Service { get; set; }
public SiteDto Site { get; set; }
}

View File

@@ -0,0 +1,17 @@
namespace ldap_cesi.DTOs.Outputs.Salarie;
public class SalarieMinimalDto
{
public int Id { get; set; }
public string Nom { get; set; } = null!;
public string Prenom { get; set; } = null!;
public string TelephoneFixe { get; set; } = null!;
public string TelephonePortable { get; set; } = null!;
public string Email { get; set; } = null!;
}

View File

@@ -0,0 +1,19 @@
namespace ldap_cesi.DTOs.Outputs.Salarie;
public class SalarieOutputDetail
{
public int Id { get; set; }
public string Nom { get; set; }
public string Prenom { get; set; }
public string TelephoneFixe { get; set; }
public string TelephonePortable { get; set; }
public string Email { get; set; }
public ServiceDto Service { get; set; }
public SiteDto Site { get; set; }
}

View File

@@ -1,5 +1,10 @@
using AutoMapper; using AutoMapper;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Role;
using ldap_cesi.DTOs.Inputs.Salarie;
using ldap_cesi.DTOs.Inputs.Service; using ldap_cesi.DTOs.Inputs.Service;
using ldap_cesi.DTOs.Inputs.Site;
using ldap_cesi.DTOs.Outputs.Salarie;
using ldap_cesi.DTOs.Outputs.Utilisateur; using ldap_cesi.DTOs.Outputs.Utilisateur;
using ldap_cesi.Entities; using ldap_cesi.Entities;
@@ -9,8 +14,33 @@ public class AutoMapperProfile : Profile
{ {
public AutoMapperProfile() public AutoMapperProfile()
{ {
// INPUTS MAPPER
CreateMap<ServiceCreateDto, Service>();
CreateMap<ServiceUpdateDto, Service>();
CreateMap<SiteCreateDto, Site>();
CreateMap<RoleCreateDto, Role>();
CreateMap<SiteUpdateDto, Site>();
CreateMap<SalarieCreateDto, Salarie>()
.ForMember(dest => dest.TelephoneFixe, opt => opt.MapFrom(src => src.TelephoneFix))
.ForMember(dest => dest.TelephonePortable, opt => opt.MapFrom(src => src.TelephonePortable));
CreateMap<SalarieUpdateDto, Salarie>()
.ForMember(dest => dest.TelephoneFixe, opt => opt.MapFrom(src => src.TelephoneFixe))
.ForMember(dest => dest.TelephonePortable, opt => opt.MapFrom(src => src.TelephonePortable));
//OUTPUTS MAPPER
CreateMap<Utilisateur, UtilisateurOutputDto>() CreateMap<Utilisateur, UtilisateurOutputDto>()
.ForMember(dest => dest.RoleNom, opt => opt.MapFrom(src => src.IdRoleNavigation.Nom)); .ForMember(dest => dest.RoleNom, opt => opt.MapFrom(src => src.IdRoleNavigation.Nom));
CreateMap<ServiceCreateDto, Service>(); CreateMap<Salarie, SalarieDto>()
.ForMember(dest => dest.Service, opt => opt.MapFrom(src => src.IdServiceNavigation))
.ForMember(dest => dest.Site, opt => opt.MapFrom(src => src.IdSiteNavigation));
CreateMap<Service, ServiceDto>();
CreateMap<Site, SiteDto>()
.ForMember(dest => dest.Salaries, opt => opt.MapFrom(src => src.Salaries));
CreateMap<Salarie, SalarieListDto>();
CreateMap<Salarie, SalarieMinimalDto>();
CreateMap<Salarie, SalarieListDto>()
.ForMember(dest => dest.Service, opt => opt.MapFrom(src => src.IdServiceNavigation.Nom))
.ForMember(dest => dest.Site, opt => opt.MapFrom(src => src.IdSiteNavigation.Ville));
} }
} }

View File

@@ -0,0 +1,21 @@
namespace ldap_cesi.Models;
public class PaginatedList<T>
{
public List<T> Datas { get; }
public int TotalCount { get; }
public int PageNumber { get; }
public int PageSize { get; }
public int TotalPages => (int)Math.Ceiling(TotalCount / (double)PageSize);
public PaginatedList(List<T> donnees, int totalCount, int pageNumber, int pageSize)
{
Datas = donnees;
TotalCount = totalCount;
PageNumber = pageNumber;
PageSize = pageSize;
}
public bool HasPreviousPage => PageNumber > 1;
public bool HasNextPage => PageNumber < TotalPages;
}

View File

@@ -3,5 +3,4 @@ namespace ldap_cesi.Models;
public class ResponseDataModel<T> : ResponseModel, IResponseDataModel<T> where T : class public class ResponseDataModel<T> : ResponseModel, IResponseDataModel<T> where T : class
{ {
public T Data { get; set; } = null!; public T Data { get; set; } = null!;
public string Token { get; set; }
} }

View File

@@ -4,7 +4,7 @@ public class ResponseModel : IResponseModel
{ {
public bool Success { get; set; } public bool Success { get; set; }
public string? Message { get; set; } public string? Message { get; set; }
public string? TokenJWT { get; set; } public string? Token { get; set; }
public int StatusCode { get; set; } public int StatusCode { get; set; }
} }

View File

@@ -1,4 +1,6 @@
using ldap_cesi.Configurations; using ldap_cesi.Configurations;
using ldap_cesi.Context;
using ldap_cesi.Seeders;
var builder = WebApplication.CreateBuilder(args); var builder = WebApplication.CreateBuilder(args);
builder.BuildConf(); builder.BuildConf();
@@ -21,6 +23,18 @@ if (app.Environment.IsDevelopment())
}); });
} }
using (var scope = app.Services.CreateScope())
{
var services = scope.ServiceProvider;
var context = services.GetRequiredService<PgContext>();
var seeder = new Seeders(context);
if (app.Environment.IsDevelopment())
{
await seeder.GenerateSalaries(500);
}
}
app.UseHttpsRedirection(); app.UseHttpsRedirection();
app.UseRouting(); app.UseRouting();
app.UseAuthentication(); app.UseAuthentication();

View File

@@ -8,8 +8,16 @@ public interface IRepositoryBase<TEntity> where TEntity : class
Task<bool> AnyAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default); Task<bool> AnyAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default);
Task<TEntity> GetByIdAsync<TId>(TId id, CancellationToken cancellationToken = default) where TId : notnull; Task<TEntity> GetByIdAsync<TId>(TId id, CancellationToken cancellationToken = default) where TId : notnull;
Task<List<TEntity>> GetAllAsync(CancellationToken cancellationToken = default); Task<List<TEntity>> GetAllAsync(CancellationToken cancellationToken = default);
Task UpdateAsync(TEntity entity, CancellationToken cancellationToken = default); Task<bool> UpdateAsync(TEntity entity, CancellationToken cancellationToken = default);
Task DeleteAsync(TEntity entity, CancellationToken cancellationToken = default); Task<bool> DeleteAsync(TEntity entity, CancellationToken cancellationToken = default);
Task<TEntity> GetWithRelationsAsync(int id, params Expression<Func<TEntity, object>>[] relationsAInclude);
Task<List<TEntity>> GetAllWithRelationsAsync(params Expression<Func<TEntity, object>>[] relationsAInclude);
Task<List<TEntity>> SearchAsync(Expression<Func<TEntity, bool>> predicate, int numPage, int taillePage,
params Expression<Func<TEntity, object>>[] relationsAInclude);
Task<TEntity?> FirstOrDefaultAsync(Expression<Func<TEntity, bool>> predicate, Task<TEntity?> FirstOrDefaultAsync(Expression<Func<TEntity, bool>> predicate,
CancellationToken cancellationToken = default); CancellationToken cancellationToken = default);
Task<int> CountAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default);
} }

View File

@@ -4,5 +4,8 @@ namespace ldap_cesi.Repository.Services;
public interface IRepositorySalarie : IRepositoryBase<Salarie> public interface IRepositorySalarie : IRepositoryBase<Salarie>
{ {
Task<Salarie> GetSalarieWithRelationsAsync(int id);
Task<List<Salarie>> SearchByNameAsync(string inputRecherche);
Task<List<Salarie>> GetSalariesBySiteAsync(int siteId);
Task<List<Salarie>> GetSalariesByServiceAsync(int serviceId);
} }

View File

@@ -1,5 +1,6 @@
using System.Linq.Expressions; using System.Linq.Expressions;
using ldap_cesi.Context; using ldap_cesi.Context;
using ldap_cesi.Models;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -8,10 +9,11 @@ namespace ldap_cesi.Repository;
public class RepositoryBase<TEntity> : IRepositoryBase<TEntity> where TEntity : class public class RepositoryBase<TEntity> : IRepositoryBase<TEntity> where TEntity : class
{ {
protected readonly PgContext _context; protected readonly PgContext _context;
protected readonly DbSet<TEntity> _dbSet;
public RepositoryBase(PgContext context) public RepositoryBase(PgContext context)
{ {
_context = context ?? throw new ArgumentNullException(nameof(context)); _context = context ?? throw new ArgumentNullException(nameof(context));
_dbSet = context.Set<TEntity>();
} }
public virtual async Task<TEntity> AddAsync(TEntity entity, CancellationToken cancellationToken = default) public virtual async Task<TEntity> AddAsync(TEntity entity, CancellationToken cancellationToken = default)
{ {
@@ -49,12 +51,13 @@ public class RepositoryBase<TEntity> : IRepositoryBase<TEntity> where TEntity :
return await _context.Set<TEntity>().FirstOrDefaultAsync(predicate, cancellationToken); return await _context.Set<TEntity>().FirstOrDefaultAsync(predicate, cancellationToken);
} }
public virtual async Task UpdateAsync(TEntity entity, CancellationToken cancellationToken = default) public virtual async Task<bool> UpdateAsync(TEntity entity, CancellationToken cancellationToken = default)
{ {
try try
{ {
_context.Set<TEntity>().Update(entity); _context.Set<TEntity>().Update(entity);
await SaveChangesAsync(cancellationToken); await SaveChangesAsync(cancellationToken);
return true;
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -74,12 +77,13 @@ public class RepositoryBase<TEntity> : IRepositoryBase<TEntity> where TEntity :
} }
} }
public virtual async Task DeleteAsync(TEntity entity, CancellationToken cancellationToken = default) public virtual async Task<bool> DeleteAsync(TEntity entity, CancellationToken cancellationToken = default)
{ {
try try
{ {
_context.Set<TEntity>().Remove(entity); _context.Set<TEntity>().Remove(entity);
await SaveChangesAsync(cancellationToken); await SaveChangesAsync(cancellationToken);
return true;
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -110,5 +114,51 @@ public class RepositoryBase<TEntity> : IRepositoryBase<TEntity> where TEntity :
throw new Exception("Erreur qui concerne le listing des entités", ex); throw new Exception("Erreur qui concerne le listing des entités", ex);
} }
} }
public virtual async Task<List<TEntity>> GetAllWithRelationsAsync(params Expression<Func<TEntity, object>>[] relationInclues)
{
IQueryable<TEntity> query = _dbSet;
foreach (var relationInclue in relationInclues)
{
query = query.Include(relationInclue);
}
return await query.ToListAsync();
}
public virtual async Task<TEntity> GetWithRelationsAsync(int id, params Expression<Func<TEntity, object>>[] relationInclues)
{
IQueryable<TEntity> query = _dbSet;
foreach (var relationInclue in relationInclues)
{
query = query.Include(relationInclue);
}
return await query.FirstOrDefaultAsync(e => EF.Property<int>(e, "Id") == id);
}
public virtual async Task<List<TEntity>> SearchAsync(Expression<Func<TEntity, bool>> predicate, int numPage, int taillePage, params Expression<Func<TEntity, object>>[] relationsAInclude)
{
IQueryable<TEntity> query = _dbSet;
foreach (var relationInclue in relationsAInclude)
{
query = query.Include(relationInclue);
}
query = query.Where(predicate);
return await query
.Skip((numPage - 1) * taillePage)
.Take(taillePage)
.ToListAsync();
}
public virtual async Task<int> CountAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
{
return await _dbSet.CountAsync(predicate, cancellationToken);
}
} }

View File

@@ -1,6 +1,7 @@
using ldap_cesi.Context; using ldap_cesi.Context;
using ldap_cesi.Entities; using ldap_cesi.Entities;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using Microsoft.EntityFrameworkCore;
namespace ldap_cesi.Repository; namespace ldap_cesi.Repository;
@@ -10,4 +11,39 @@ public class SalarieRepository : RepositoryBase<Salarie>, IRepositorySalarie
{ {
} }
public async Task<Salarie> GetSalarieWithRelationsAsync(int id)
{
return await _context.Salaries
.Include(s => s.IdServiceNavigation)
.Include(s => s.IdSiteNavigation)
.FirstOrDefaultAsync(s => s.Id == id);
}
public async Task<List<Salarie>> SearchByNameAsync(string inputRecherche)
{
return await _context.Salaries
.Where(s => s.Nom.Contains(inputRecherche) || s.Prenom.Contains(inputRecherche))
.Include(s => s.IdServiceNavigation)
.Include(s => s.IdSiteNavigation)
.ToListAsync();
}
public async Task<List<Salarie>> GetSalariesBySiteAsync(int siteId)
{
return await _context.Salaries
.Where(s => s.IdSite == siteId)
.Include(s => s.IdServiceNavigation)
.Include(s => s.IdSiteNavigation)
.ToListAsync();
}
public async Task<List<Salarie>> GetSalariesByServiceAsync(int serviceId)
{
return await _context.Salaries
.Where(s => s.IdService == serviceId)
.Include(s => s.IdServiceNavigation)
.Include(s => s.IdSiteNavigation)
.ToListAsync();
}
} }

View File

@@ -0,0 +1,49 @@
using Bogus;
using ldap_cesi.Context;
using ldap_cesi.Entities;
using Microsoft.EntityFrameworkCore;
namespace ldap_cesi.Seeders;
public class Seeders
{
private readonly PgContext _context;
public Seeders(PgContext context)
{
_context = context;
}
public async Task GenerateSalaries(int count = 1000)
{
if (await _context.Salaries.AnyAsync())
{
Console.WriteLine("Des salariés existent déjà dans la base de données. Aucune donnée insérée.");
return;
}
var salarieFaker = new Faker<Salarie>("fr")
.RuleFor(s => s.Nom, f => f.Name.LastName())
.RuleFor(s => s.Prenom, f => f.Name.FirstName())
.RuleFor(s => s.TelephoneFixe, f => f.Phone.PhoneNumber())
.RuleFor(s => s.TelephonePortable, f => f.Phone.PhoneNumber())
.RuleFor(s => s.Email, (f, s) => f.Internet.Email(s.Prenom, s.Nom));
var salaries = salarieFaker.Generate(count);
// on s'assure que les relations (Service, Site) existent avant d'ajouter les salariés
var services = await _context.Services.ToListAsync();
var sites = await _context.Sites.ToListAsync();
var random = new Random();
foreach (var salarie in salaries)
{
salarie.IdServiceNavigation = services[random.Next(services.Count)];
salarie.IdSiteNavigation = sites[random.Next(sites.Count)];
}
await _context.Salaries.AddRangeAsync(salaries);
await _context.SaveChangesAsync();
}
}

View File

@@ -1,6 +1,10 @@
namespace ldap_cesi.Services.Interfaces; using ldap_cesi.Entities;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Role;
public interface IRoleService namespace ldap_cesi.Services.Interfaces
{ {
public interface IRoleService : IServiceBase<Role, RoleDto, RoleCreateDto, RoleUpdateDto>
{
}
} }

View File

@@ -1,10 +1,16 @@
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Salarie;
using ldap_cesi.DTOs.Inputs.Service;
using ldap_cesi.DTOs.Outputs.Salarie;
using ldap_cesi.Entities; using ldap_cesi.Entities;
using ldap_cesi.Models; using ldap_cesi.Models;
namespace ldap_cesi.Services.Interfaces; namespace ldap_cesi.Services.Interfaces;
public interface ISalarieService public interface ISalarieService : IServiceBase<Salarie, SalarieDto, SalarieCreateDto, SalarieUpdateDto>
{ {
Task<IResponseDataModel<List<Salarie>>> GetAll(); Task<IResponseDataModel<List<Salarie>>> GetAllWithoutIService();
Task<IResponseDataModel<Salarie>> GetById(int id); Task<IResponseDataModel<List<SalarieListDto>>> GetSalariesBySite(int siteId);
Task<IResponseDataModel<List<SalarieListDto>>> GetSalariesByService(int serviceId);
Task<IResponseDataModel<SalarieDto>> GetCompletById(int id);
} }

View File

@@ -0,0 +1,22 @@
using System.Linq.Expressions;
using ldap_cesi.Models;
namespace ldap_cesi.Services.Interfaces;
public interface IServiceBase<T, TDto, TCreateDto, TUpdateDto>
where T : class
where TDto : class
where TCreateDto : class
where TUpdateDto : class
{
Task<IResponseDataModel<List<T>>> GetAll();
Task<IResponseDataModel<T>> GetById(int id);
Task<IResponseDataModel<TDto>> GetByIdWithRelations(int id, params Expression<Func<T, object>>[] relationsAInclures); // préciser avec une ou des fonctions lambda les relations à inclure dans la réponse
Task<IResponseDataModel<List<TDto>>> GetAllWithRelationsAsync(params Expression<Func<T, object>>[] relationsAInclure);
Task<IResponseDataModel<PaginatedList<TDto>>> SearchWithRelations(string searchTerm, int pageNumber, int pageSize,
params Expression<Func<T, object>>[] includeProperties);
Task<IResponseDataModel<T>> Create(TCreateDto dto);
Task<IResponseDataModel<T>> Update(TUpdateDto dto);
Task<IResponseDataModel<string>> Delete(int id);
}

View File

@@ -1,12 +1,11 @@
using ldap_cesi.DTOs.Inputs.Service; using ldap_cesi.DTOs.Inputs.Service;
using ldap_cesi.DTOs;
using ldap_cesi.Entities; using ldap_cesi.Entities;
using ldap_cesi.Models; using ldap_cesi.Models;
namespace ldap_cesi.Services.Interfaces; namespace ldap_cesi.Services.Interfaces
public interface IServiceService
{ {
Task<IResponseDataModel<List<Service>>> GetAll(); public interface IServiceService : IServiceBase<Service, ServiceDto, ServiceCreateDto, ServiceUpdateDto>
Task<IResponseDataModel<Service>> GetById(int id); {
Task<IResponseDataModel<string>> CreateService(ServiceCreateDto serviceCreateDto); }
} }

View File

@@ -1,6 +1,15 @@
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Site;
using ldap_cesi.Entities;
using ldap_cesi.Models;
namespace ldap_cesi.Services.Interfaces; namespace ldap_cesi.Services.Interfaces;
public interface ISiteService public interface ISiteService : IServiceBase<Site, SiteDto, SiteCreateDto, SiteUpdateDto>
{ {
Task<IResponseDataModel<List<Site>>> GetAll();
Task<IResponseDataModel<Site>> GetById(int id);
Task<IResponseDataModel<string>> CreateSite(SiteCreateDto siteCreateDto);
Task<IResponseDataModel<Site>> UpdateSite(SiteUpdateDto siteUpdate);
Task<IResponseDataModel<string>> DeleteSite(int id);
} }

View File

@@ -7,7 +7,7 @@ namespace ldap_cesi.Services.Interfaces;
public interface IUtilisateurService public interface IUtilisateurService
{ {
Task<IResponseDataModel<List<Utilisateur>>> GetAll(); Task<IResponseDataModel<List<UtilisateurOutputDto>>> GetAll();
Task<IResponseDataModel<Utilisateur>> GetById(int id); Task<IResponseDataModel<UtilisateurOutputDto>> GetById(int id);
Task<IResponseDataModel<UtilisateurOutputDto>> Login(UtilisateurLoginDto utilisateurInput); Task<IResponseDataModel<UtilisateurOutputDto>> Login(UtilisateurLoginDto utilisateurInput);
} }

View File

@@ -60,7 +60,7 @@ public class JwtService : IJwtService
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "An error occurred while generating the JWT token."); _logger.LogError(ex, "Une erreur s'est produitel lors de la génération du token.");
throw; throw;
} }
} }
@@ -74,7 +74,7 @@ public class JwtService : IJwtService
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "An error occurred while retrieving the public key."); _logger.LogError(ex, "Une erreur s'est produite pendant la récupération de la clé.");
throw; throw;
} }
} }
@@ -100,14 +100,14 @@ public class JwtService : IJwtService
var nameIdClaim = principal.FindFirst(ClaimTypes.NameIdentifier); var nameIdClaim = principal.FindFirst(ClaimTypes.NameIdentifier);
if (nameIdClaim == null || !int.TryParse(nameIdClaim.Value, out var tokenUserId) || tokenUserId != userId) if (nameIdClaim == null || !int.TryParse(nameIdClaim.Value, out var tokenUserId) || tokenUserId != userId)
{ {
_logger.LogWarning("Token validation failed: Invalid user ID."); _logger.LogWarning("Erreur de validation : Id utilisateur invalide.");
return false; return false;
} }
var utilisateur = await _context.Utilisateurs.FindAsync(userId); var utilisateur = await _context.Utilisateurs.FindAsync(userId);
if (utilisateur == null) if (utilisateur == null)
{ {
_logger.LogWarning("Token validation failed: User not found."); _logger.LogWarning("Erreur de validation : Utilisateur non trouvé.");
return false; return false;
} }
@@ -119,7 +119,7 @@ public class JwtService : IJwtService
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "An error occurred while validating the JWT token."); _logger.LogError(ex, "Une erreur s'est produite lors pendant la validation du token JWT.");
return false; return false;
} }
} }

View File

@@ -1,15 +1,17 @@
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using ldap_cesi.Entities;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Role;
using AutoMapper;
using ldap_cesi.Validator.Role;
namespace ldap_cesi.Services; namespace ldap_cesi.Services;
public class RoleService : IRoleService public class RoleService : ServiceBase<Role, RoleDto, RoleCreateDto, RoleUpdateDto>,IRoleService
{ {
private IRepositoryRole _repositoryRole; public RoleService(IRepositoryRole repositoryRole, IMapper mapper, ILogger<RoleService> logger, RoleCreateValidator roleCreateValidator, RoleUpdateValidator roleUpdateValidator)
: base(repositoryRole, mapper, logger, roleCreateValidator, roleUpdateValidator)
public RoleService(IRepositoryRole repositoryRole)
{ {
_repositoryRole = repositoryRole;
} }
} }

View File

@@ -1,20 +1,34 @@
using AutoMapper;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Salarie;
using ldap_cesi.DTOs.Inputs.Service;
using ldap_cesi.DTOs.Outputs.Salarie;
using ldap_cesi.Entities; using ldap_cesi.Entities;
using ldap_cesi.Models; using ldap_cesi.Models;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using ldap_cesi.Validator.Salarie;
namespace ldap_cesi.Services; namespace ldap_cesi.Services;
public class SalarieService : ISalarieService public class SalarieService : ServiceBase<Salarie, SalarieDto, SalarieCreateDto, SalarieUpdateDto>, ISalarieService
{ {
private IRepositorySalarie _repositorySalarie; private IRepositorySalarie _repositorySalarie;
private readonly IRepositorySite _repositorySite;
private readonly IRepositoryService _repositoryService;
private readonly IMapper _mapper;
public SalarieService(IRepositorySalarie repositorySalarie) public SalarieService(IRepositorySalarie repositorySalarie, IMapper mapper, IRepositorySite repositorySite, IRepositoryService repositoryService,
ILogger<SalarieService> logger, SalarieCreateValidator salarieCreateValidator, SalarieUpdateValidator salarieUpdateValidator)
: base(repositorySalarie, mapper, logger, salarieCreateValidator, salarieUpdateValidator)
{ {
_repositorySalarie = repositorySalarie; _repositorySalarie = repositorySalarie;
_repositorySite = repositorySite;
_repositoryService = repositoryService;
_mapper = mapper;
} }
public async Task<IResponseDataModel<List<Salarie>>> GetAll() public async Task<IResponseDataModel<List<Salarie>>> GetAllWithoutIService()
{ {
var salaries = await _repositorySalarie.GetAllAsync(); var salaries = await _repositorySalarie.GetAllAsync();
return new ResponseDataModel<List<Salarie>> return new ResponseDataModel<List<Salarie>>
@@ -25,14 +39,204 @@ public class SalarieService : ISalarieService
}; };
} }
public async Task<IResponseDataModel<Salarie>> GetById(int id) // public async Task<IResponseDataModel<Salarie>> GetById(int id)
// {
// var salarie = await _repositorySalarie.GetSalarieWithRelationsAsync(id);
// return new ResponseDataModel<Salarie>
// {
// Success = true,
// Data = salarie,
// StatusCode = 200,
// };
// }
public async Task<IResponseDataModel<SalarieDto>> GetCompletById(int id)
{ {
var service = await _repositorySalarie.GetByIdAsync(id); var salarie = await _repositorySalarie.GetSalarieWithRelationsAsync(id);
return new ResponseDataModel<Salarie> var salarieOutput = _mapper.Map<SalarieDto>(salarie);
return new ResponseDataModel<SalarieDto>
{ {
Success = true, Success = true,
Data = service, Data = salarieOutput,
StatusCode = 200, StatusCode = 200,
}; };
} }
public async Task<IResponseDataModel<List<SalarieListDto>>> GetSalariesBySite(int siteId)
{
var site = await _repositorySite.GetByIdAsync(siteId);
if (site == null)
{
return new ResponseDataModel<List<SalarieListDto>>
{
Success = false,
Message = "Site non trouvé",
StatusCode = 404
};
}
var salaries = await _repositorySalarie.GetSalariesBySiteAsync(siteId);
if (!salaries.Any())
{
return new ResponseDataModel<List<SalarieListDto>>
{
Success = true,
Message = "Aucun salarié trouvé pour ce site",
Data = new List<SalarieListDto>(),
StatusCode = 200
};
}
var salariesDto = _mapper.Map<List<SalarieListDto>>(salaries);
return new ResponseDataModel<List<SalarieListDto>>
{
Success = true,
Data = salariesDto,
StatusCode = 200
};
}
public async Task<IResponseDataModel<List<SalarieListDto>>> GetSalariesByService(int serviceId)
{
var service = await _repositoryService.GetByIdAsync(serviceId);
if (service == null)
{
return new ResponseDataModel<List<SalarieListDto>>
{
Success = false,
Message = "Service non trouvé",
StatusCode = 404
};
}
var salaries = await _repositorySalarie.GetSalariesByServiceAsync(serviceId);
var salariesDto = _mapper.Map<List<SalarieListDto>>(salaries);
return new ResponseDataModel<List<SalarieListDto>>
{
Success = true,
Data = salariesDto,
StatusCode = 200
};
}
public async Task<IResponseDataModel<List<SalarieListDto>>> RechercherParNom(string nom)
{
var salaries = await _repositorySalarie.SearchByNameAsync(nom);
var salariesDto = _mapper.Map<List<SalarieListDto>>(salaries);
return new ResponseDataModel<List<SalarieListDto>>
{
Success = true,
Data = salariesDto,
StatusCode = 200
};
}
// public async Task<IResponseDataModel<string>> Create(SalarieCreateDto salarieInput)
// {
// var validation = new SalarieCreateValidator();
// var result = validation.Validate(salarieInput);
// if (!result.IsValid)
// {
// return new ResponseDataModel<string>
// {
// StatusCode = 400,
// Success = false,
// Message = "Données salariées invalides: " + string.Join(", ", result.Errors)
// };
// }
// var service = _mapper.Map<Salarie>(salarieInput);
// var response = await _repositorySalarie.AddAsync(service);
// return new ResponseDataModel<string>
// {
// StatusCode = 201,
// Success = true,
// Data = response.Id.ToString(),
// };
// }
// public async Task<IResponseDataModel<Salarie>> Update(SalarieUpdateDto salarieInput)
// {
// var validation = new SalarieUpdateValidator();
// var result = validation.Validate(salarieInput);
// if (!result.IsValid)
// {
// return new ResponseDataModel<Salarie>
// {
// StatusCode = 400,
// Success = false,
// Message = "Données salariées invalides: " + string.Join(", ", result.Errors)
// };
// }
// var salarieFind = await _repositorySalarie.GetByIdAsync(salarieInput.Id);
// if (salarieFind == null)
// {
// return new ResponseDataModel<Salarie>
// {
// Success = false,
// Message = "Salarié introuvable.",
// StatusCode = 404
// };
// }
// var salarie = _mapper.Map(salarieInput, salarieFind);
// var response = await _repositorySalarie.UpdateAsync(salarie);
// if (!response)
// {
// return new ResponseDataModel<Salarie>
// {
// StatusCode = 500,
// Success = false,
// Message = "Erreur lors de la mise à jour du salarié : " + string.Join(", ", result.Errors)
// };
// }
// return new ResponseDataModel<Salarie>
// {
// StatusCode = 200,
// Success = true,
// Data = salarie,
// };
// }
// public async Task<IResponseDataModel<string>> Delete(int id)
// {
// if (id == null)
// {
// return new ResponseDataModel<string>
// {
// StatusCode = 400,
// Success = false,
// Message = "Id manquant"
// };
// }
// var salarie = await _repositorySalarie.GetByIdAsync(id);
// if (salarie == null)
// {
// return new ResponseDataModel<string>
// {
// Success = false,
// Message = "Salarié introuvable.",
// StatusCode = 404
// };
// }
// var response = await _repositorySalarie.DeleteAsync(salarie);
// if (!response)
// {
// return new ResponseDataModel<string>
// {
// StatusCode = 500,
// Success = false,
// Message = "Erreur durant la suppression du service"
// };
// }
// return new ResponseDataModel<string>
// {
// StatusCode = 200,
// Success = true,
// Data = salarie.Id.ToString(),
// };
// }
} }

View File

@@ -0,0 +1,315 @@
using AutoMapper;
using ldap_cesi.DTOs.Inputs.Site;
using ldap_cesi.Entities;
using ldap_cesi.Models;
using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces;
using ldap_cesi.Validator.Site;
using Microsoft.Extensions.Logging;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Threading.Tasks;
using FluentValidation;
using Microsoft.EntityFrameworkCore;
namespace ldap_cesi.Services;
public class ServiceBase<T, TDto, TCreateDto, TUpdateDto> : IServiceBase<T, TDto, TCreateDto, TUpdateDto>
where T : class
where TDto : class
where TCreateDto : class
where TUpdateDto : class
{
protected readonly IRepositoryBase<T> _repository;
protected readonly IMapper _mapper;
protected readonly ILogger<ServiceBase<T, TDto, TCreateDto, TUpdateDto>> _logger;
protected readonly IValidator<TCreateDto> _createDtoValidator;
protected readonly IValidator<TUpdateDto> _updateDtoValidator;
public ServiceBase(IRepositoryBase<T> repository, IMapper mapper, ILogger<ServiceBase<T, TDto, TCreateDto, TUpdateDto>> logger, IValidator<TCreateDto> createDtoValidator, IValidator<TUpdateDto> updateDtoValidator)
{
_repository = repository;
_mapper = mapper;
_logger = logger;
_createDtoValidator = createDtoValidator;
_updateDtoValidator = updateDtoValidator;
}
private Expression<Func<T, bool>> BuildSearchPredicate(string inputSearch)
{
return entity =>
EF.Functions.ILike(EF.Property<string>(entity, "Nom"), $"%{inputSearch}%") ||
EF.Functions.ILike(EF.Property<string>(entity, "Prenom"), $"%{inputSearch}%");
}
public virtual async Task<IResponseDataModel<List<T>>> GetAll()
{
try
{
var entities = await _repository.GetAllAsync();
return new ResponseDataModel<List<T>>
{
Success = true,
Data = entities,
StatusCode = 200,
Message = "Liste des entités récupérée avec succès."
};
}
catch (Exception ex)
{
_logger.LogError(ex, "Une erreur s'est produite lors de la récupération des entités.");
return new ResponseDataModel<List<T>>
{
Success = false,
Message = "Une erreur s'est produite lors de la récupération des entités.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<T>> GetById(int id)
{
try
{
var entity = await _repository.GetByIdAsync(id);
if (entity == null)
{
return new ResponseDataModel<T>
{
Success = false,
Message = $"Aucune entité trouvée avec l'identifiant {id}.",
StatusCode = 404
};
}
return new ResponseDataModel<T>
{
Success = true,
Data = entity,
StatusCode = 200,
Message = "Entité récupérée avec succès."
};
}
catch (Exception ex)
{
_logger.LogError(ex, $"Une erreur s'est produite lors de la récupération de l'entité avec l'identifiant {id}.");
return new ResponseDataModel<T>
{
Success = false,
Message = "Une erreur s'est produite lors de la récupération de l'entité.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<List<TDto>>> GetAllWithRelationsAsync(params Expression<Func<T, object>>[] relationsAInclure)
{
try
{
var entities = await _repository.GetAllWithRelationsAsync(relationsAInclure);
var dtos = _mapper.Map<List<TDto>>(entities);
return new ResponseDataModel<List<TDto>>
{
Success = true,
Data = dtos,
StatusCode = 200,
Message = "Liste des entités récupérée avec succès."
};
}
catch (Exception ex)
{
_logger.LogError(ex, "Une erreur s'est produite lors de la récupération des entités.");
return new ResponseDataModel<List<TDto>>
{
Success = false,
Message = "Une erreur s'est produite lors de la récupération des entités.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<TDto>> GetByIdWithRelations(int id, params Expression<Func<T, object>>[] relationsAInclure)
{
try
{
var entity = await _repository.GetWithRelationsAsync(id, relationsAInclure);
if (entity == null)
{
return new ResponseDataModel<TDto>
{
Success = false,
Message = $"Aucune entité trouvée avec l'identifiant {id}.",
StatusCode = 404
};
}
var dto = _mapper.Map<TDto>(entity);
return new ResponseDataModel<TDto>
{
Success = true,
Data = dto,
StatusCode = 200,
Message = "Entité avec relations récupérée avec succès."
};
}
catch (Exception ex)
{
_logger.LogError(ex, $"Une erreur s'est produite lors de la récupération de l'entité avec l'identifiant {id}.");
return new ResponseDataModel<TDto>
{
Success = false,
Message = "Une erreur s'est produite lors de la récupération de l'entité avec relations.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<T>> Create(TCreateDto dto)
{
try
{
var validationResult = _createDtoValidator.Validate(dto);
if (!validationResult.IsValid)
{
return new ResponseDataModel<T>
{
Success = false,
Message = string.Join("; ", validationResult.Errors.Select(e => e.ErrorMessage)),
StatusCode = 400
};
}
var entity = _mapper.Map<T>(dto);
var createdEntity = await _repository.AddAsync(entity);
return new ResponseDataModel<T>
{
Success = createdEntity != null,
Data = createdEntity,
StatusCode = createdEntity != null ? 201 : 500,
Message = createdEntity != null ? "Entité créée avec succès." : "Échec de la création de l'entité."
};
}
catch (Exception ex)
{
_logger.LogError(ex, "Une erreur s'est produite lors de la création de l'entité.");
return new ResponseDataModel<T>
{
Success = false,
Message = "Une erreur s'est produite lors de la création de l'entité.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<T>> Update(TUpdateDto dto)
{
try
{
var validationResult = _updateDtoValidator.Validate(dto);
if (!validationResult.IsValid)
{
return new ResponseDataModel<T>
{
Success = false,
Message = string.Join("; ", validationResult.Errors.Select(e => e.ErrorMessage)),
StatusCode = 400
};
}
var entity = _mapper.Map<T>(dto);
bool isUpdated = await _repository.UpdateAsync(entity);
return new ResponseDataModel<T>
{
Success = isUpdated,
Data = isUpdated ? entity : default,
StatusCode = isUpdated ? 200 : 500,
Message = isUpdated ? "Entité mise à jour avec succès." : "Échec de la mise à jour de l'entité."
};
}
catch (Exception ex)
{
_logger.LogError(ex, "Une erreur s'est produite lors de la mise à jour de l'entité.");
return new ResponseDataModel<T>
{
Success = false,
Message = "Une erreur s'est produite lors de la mise à jour de l'entité.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<string>> Delete(int id)
{
try
{
var entity = await _repository.GetByIdAsync(id);
if (entity == null)
{
return new ResponseDataModel<string>
{
Success = false,
Message = $"Aucune entité trouvée avec l'identifiant {id}.",
StatusCode = 404
};
}
var isDeleted = await _repository.DeleteAsync(entity);
return new ResponseDataModel<string>
{
Success = isDeleted,
Data = isDeleted ? id.ToString() : null,
StatusCode = isDeleted ? 200 : 500,
Message = isDeleted ? "Entité supprimée avec succès." : "Échec de la suppression de l'entité."
};
}
catch (Exception ex)
{
_logger.LogError(ex, $"Une erreur s'est produite lors de la suppression de l'entité avec l'identifiant {id}.");
return new ResponseDataModel<string>
{
Success = false,
Message = "Une erreur s'est produite lors de la suppression de l'entité.",
StatusCode = 500
};
}
}
public virtual async Task<IResponseDataModel<PaginatedList<TDto>>> SearchWithRelations(string searchTerm, int pageNumber, int pageSize, params Expression<Func<T, object>>[] includeProperties)
{
if (string.IsNullOrWhiteSpace(searchTerm) || searchTerm.Length < 2)
{
return new ResponseDataModel<PaginatedList<TDto>>
{
Success = false,
Message = "Le terme de recherche doit contenir au moins deux caractères.",
StatusCode = 400
};
}
try
{
var predicate = BuildSearchPredicate(searchTerm);
var entities = await _repository.SearchAsync(predicate, pageNumber, pageSize, includeProperties);
var dtos = _mapper.Map<List<TDto>>(entities);
var totalCount = await _repository.CountAsync(predicate);
var paginatedList = new PaginatedList<TDto>(dtos, totalCount, pageNumber, pageSize);
return new ResponseDataModel<PaginatedList<TDto>>
{
Success = true,
Data = paginatedList,
StatusCode = 200,
Message = "Recherche effectuée avec succès."
};
}
catch (Exception ex)
{
_logger.LogError(ex, "Une erreur s'est produite lors de la recherche des entités.");
return new ResponseDataModel<PaginatedList<TDto>>
{
Success = false,
Message = "Une erreur s'est produite lors de la recherche des entités.",
StatusCode = 500
};
}
}
}

View File

@@ -4,51 +4,146 @@ using ldap_cesi.Entities;
using ldap_cesi.Models; using ldap_cesi.Models;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using ldap_cesi.Validator.Service;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Service;
namespace ldap_cesi.Services; namespace ldap_cesi.Services;
public class ServiceService : IServiceService public class ServiceService : ServiceBase<Service, ServiceDto, ServiceCreateDto, ServiceUpdateDto>, IServiceService
{ {
private readonly IRepositoryService _repositoryService;
private readonly IMapper _mapper;
public ServiceService(IRepositoryService repositoryService, IMapper mapper) public ServiceService(IRepositoryService repositoryService, IMapper mapper, ILogger<ServiceService> logger, ServiceCreateValidator serviceCreateValidator, ServiceUpdateValidator serviceUpdateValidator)
: base(repositoryService, mapper, logger, serviceCreateValidator, serviceUpdateValidator)
{ {
_repositoryService = repositoryService;
_mapper = mapper;
} }
public async Task<IResponseDataModel<List<Service>>> GetAll() // public async Task<IResponseDataModel<List<Service>>> GetAll()
{ // {
var services = await _repositoryService.GetAllAsync(); // var services = await _repositoryService.GetAllAsync();
return new ResponseDataModel<List<Service>> // return new ResponseDataModel<List<Service>>
{ // {
Success = true, // Success = true,
Data = services, // Data = services,
StatusCode = 200, // StatusCode = 200,
}; // };
} // }
public async Task<IResponseDataModel<Service>> GetById(int id) // public async Task<IResponseDataModel<Service>> GetById(int id)
{ // {
var service = await _repositoryService.GetByIdAsync(id); // var service = await _repositoryService.GetByIdAsync(id);
return new ResponseDataModel<Service> // return new ResponseDataModel<Service>
{ // {
Success = true, // Success = true,
Data = service, // Data = service,
StatusCode = 200, // StatusCode = 200,
}; // };
} // }
public async Task<IResponseDataModel<string>> CreateService(ServiceCreateDto serviceCreateDto) // public async Task<IResponseDataModel<string>> CreateService(ServiceCreateDto serviceCreateDto)
{ // {
var service = _mapper.Map<Service>(serviceCreateDto); // var validation = new ServiceCreateValidator();
var response = await _repositoryService.AddAsync(service); // var result = validation.Validate(serviceCreateDto);
return new ResponseDataModel<string> // if (!result.IsValid)
{ // {
Success = true, // return new ResponseDataModel<string>
Data = response.Id.ToString(), // {
}; // StatusCode = 400,
} // Success = false,
// Message = "Données du service invalides: " + string.Join(", ", result.Errors)
// };
// }
// var service = _mapper.Map<Service>(serviceCreateDto);
// var response = await _repositoryService.AddAsync(service);
// return new ResponseDataModel<string>
// {
// StatusCode = 201,
// Success = true,
// Data = response.Id.ToString(),
// };
// }
// public async Task<IResponseDataModel<Service>> UpdateService(ServiceUpdateDto serviceUpdateDto)
// {
// var validation = new ServiceUpdateValidator();
// var result = validation.Validate(serviceUpdateDto);
// if (!result.IsValid)
// {
// return new ResponseDataModel<Service>
// {
// StatusCode = 400,
// Success = false,
// Message = "Données du service invalides: " + string.Join(", ", result.Errors)
// };
// }
// var serviceFind = await _repositoryService.GetByIdAsync(serviceUpdateDto.Id);
// if (serviceFind is null)
// {
// return new ResponseDataModel<Service>
// {
// Success = false,
// Message = "Service introuvable.",
// StatusCode = 404
// };
// }
// var service = _mapper.Map(serviceUpdateDto, serviceFind);
// var response = await _repositoryService.UpdateAsync(service);
// if (!response)
// {
// return new ResponseDataModel<Service>
// {
// StatusCode = 500,
// Success = false,
// Message = "Erreur lors de la mise à jour du service : " + string.Join(", ", result.Errors)
// };
// }
// return new ResponseDataModel<Service>
// {
// StatusCode = 200,
// Success = true,
// Data = service,
// };
// }
// public async Task<IResponseDataModel<string>> DeleteService(int idService)
// {
// if (idService == null)
// {
// return new ResponseDataModel<string>
// {
// StatusCode = 400,
// Success = false,
// Message = "Id manquant"
// };
// }
// var service = await _repositoryService.GetByIdAsync(idService);
// if (service == null)
// {
// return new ResponseDataModel<string>
// {
// Success = false,
// Message = "Service introuvable.",
// StatusCode = 404
// };
// }
// var response = await _repositoryService.DeleteAsync(service);
// if (!response)
// {
// return new ResponseDataModel<string>
// {
// StatusCode = 500,
// Success = false,
// Message = "Erreur durant la suppression du service"
// };
// }
// return new ResponseDataModel<string>
// {
// StatusCode = 200,
// Success = true,
// Data = service.Id.ToString(),
// };
// }
} }

View File

@@ -0,0 +1,152 @@
using AutoMapper;
using ldap_cesi.DTOs;
using ldap_cesi.DTOs.Inputs.Site;
using ldap_cesi.Entities;
using ldap_cesi.Models;
using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces;
using ldap_cesi.Validator.Site;
namespace ldap_cesi.Services;
public class SiteService : ServiceBase<Site, SiteDto, SiteCreateDto, SiteUpdateDto>, ISiteService
{
private readonly IRepositorySite _repositorySite;
public SiteService(IRepositorySite repositorySite, IMapper mapper,
ILogger<SiteService> logger, SiteCreateValidator siteCreateValidator, SiteUpdateValidator siteUpdateValidator)
: base(repositorySite, mapper, logger, siteCreateValidator, siteUpdateValidator )
{
_repositorySite = repositorySite;
}
public async Task<IResponseDataModel<List<Site>>> GetAll()
{
var sites = await _repositorySite.GetAllAsync();
return new ResponseDataModel<List<Site>>
{
Success = true,
Data = sites,
StatusCode = 200,
};
}
public async Task<IResponseDataModel<Site>> GetById(int id)
{
var site = await _repositorySite.GetByIdAsync(id);
return new ResponseDataModel<Site>
{
Success = true,
Data = site,
StatusCode = 200,
};
}
public async Task<IResponseDataModel<string>> CreateSite(SiteCreateDto siteCreateDto)
{
var validation = new SiteCreateValidator();
var result = validation.Validate(siteCreateDto);
if (!result.IsValid)
{
return new ResponseDataModel<string>
{
StatusCode = 400,
Success = false,
Message = "Données du site invalides: " + string.Join(", ", result.Errors)
};
}
var site = _mapper.Map<Site>(siteCreateDto);
var response = await _repositorySite.AddAsync(site);
return new ResponseDataModel<string>
{
StatusCode = 201,
Success = true,
Data = response.Id.ToString(),
};
}
public async Task<IResponseDataModel<Site>> UpdateSite(SiteUpdateDto siteUpdate)
{
var validation = new SiteUpdateValidator();
var result = validation.Validate(siteUpdate);
if (!result.IsValid)
{
return new ResponseDataModel<Site>
{
StatusCode = 400,
Success = false,
Message = "Données du site invalides: " + string.Join(", ", result.Errors)
};
}
var siteFind = await _repositorySite.GetByIdAsync(siteUpdate.Id);
if (siteFind is null)
{
return new ResponseDataModel<Site>
{
Success = false,
Message = "Site introuvable.",
StatusCode = 404
};
}
var site = _mapper.Map(siteUpdate, siteFind);
var response = await _repositorySite.UpdateAsync(site);
if (!response)
{
return new ResponseDataModel<Site>
{
StatusCode = 500,
Success = false,
Message = "Erreur lors de la mise à jour du site : " + string.Join(", ", result.Errors)
};
}
return new ResponseDataModel<Site>
{
StatusCode = 200,
Success = true,
Data = site,
};
}
public async Task<IResponseDataModel<string>> DeleteSite(int id)
{
if (id == null)
{
return new ResponseDataModel<string>
{
StatusCode = 400,
Success = false,
Message = "Id manquant"
};
}
var site = await _repositorySite.GetByIdAsync(id);
if (site == null)
{
return new ResponseDataModel<string>
{
Success = false,
Message = "Site introuvable.",
StatusCode = 404
};
}
var response = await _repositorySite.DeleteAsync(site);
if (!response)
{
return new ResponseDataModel<string>
{
StatusCode = 500,
Success = false,
Message = "Erreur durant la suppression du site"
};
}
return new ResponseDataModel<string>
{
StatusCode = 200,
Success = true,
Data = site.Id.ToString(),
};
}
}

View File

@@ -5,6 +5,7 @@ using ldap_cesi.Entities;
using ldap_cesi.Models; using ldap_cesi.Models;
using ldap_cesi.Repository.Services; using ldap_cesi.Repository.Services;
using ldap_cesi.Services.Interfaces; using ldap_cesi.Services.Interfaces;
using ldap_cesi.Validator.Utilisateur;
namespace ldap_cesi.Services; namespace ldap_cesi.Services;
@@ -20,30 +21,44 @@ public class UtilisateurService : IUtilisateurService
_mapper = mapper; _mapper = mapper;
} }
public async Task<IResponseDataModel<List<Utilisateur>>> GetAll() public async Task<IResponseDataModel<List<UtilisateurOutputDto>>> GetAll()
{ {
var utilisateurs = await _repositoryUtilisateur.GetAllAsync(); var utilisateurs = await _repositoryUtilisateur.GetAllAsync();
return new ResponseDataModel<List<Utilisateur>> var utilisateursOutputDto = _mapper.Map<List<UtilisateurOutputDto>>(utilisateurs);
return new ResponseDataModel<List<UtilisateurOutputDto>>
{ {
Success = true, Success = true,
StatusCode = 200, StatusCode = 200,
Data = utilisateurs, Data = utilisateursOutputDto,
}; };
} }
public async Task<IResponseDataModel<Utilisateur>> GetById(int id) public async Task<IResponseDataModel<UtilisateurOutputDto>> GetById(int id)
{ {
var utililisateur = await _repositoryUtilisateur.GetByIdAsync(id); var utililisateur = await _repositoryUtilisateur.GetByIdAsync(id);
return new ResponseDataModel<Utilisateur> var utilisateurOutput = _mapper.Map<UtilisateurOutputDto>(utililisateur);
return new ResponseDataModel<UtilisateurOutputDto>
{ {
Success = true, Success = true,
StatusCode = 200, StatusCode = 200,
Data = utililisateur, Data = utilisateurOutput,
}; };
} }
public async Task<IResponseDataModel<UtilisateurOutputDto>> Login(UtilisateurLoginDto utilisateurInput) public async Task<IResponseDataModel<UtilisateurOutputDto>> Login(UtilisateurLoginDto utilisateurInput)
{ {
var validation = new UtilisateurLoginValidator();
var result = validation.Validate(utilisateurInput);
if (!result.IsValid)
{
return new ResponseDataModel<UtilisateurOutputDto>
{
StatusCode = 400,
Success = false,
Message = "Données utilisateur invalides: " + string.Join(", ", result.Errors)
};
}
var utilisateur = await _repositoryUtilisateur.GetByEmailAsync(utilisateurInput.Email); var utilisateur = await _repositoryUtilisateur.GetByEmailAsync(utilisateurInput.Email);
if (utilisateur == null) if (utilisateur == null)

View File

@@ -0,0 +1,14 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Role;
namespace ldap_cesi.Validator.Role;
public class RoleCreateValidator : AbstractValidator<RoleCreateDto>
{
public RoleCreateValidator()
{
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
}
}

View File

@@ -0,0 +1,16 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Role;
namespace ldap_cesi.Validator.Role;
public class RoleUpdateValidator : AbstractValidator<RoleUpdateDto>
{
public RoleUpdateValidator()
{
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.Id)
.NotEmpty().WithMessage("L'identifiant du Rôle est requis.");
}
}

View File

@@ -0,0 +1,41 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Salarie;
namespace ldap_cesi.Validator.Salarie;
public class SalarieCreateValidator : AbstractValidator<SalarieCreateDto>
{
public SalarieCreateValidator()
{
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.Prenom)
.NotEmpty().WithMessage("Le prénom est requis.")
.MaximumLength(50).WithMessage("Le prénom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.TelephoneFix)
.NotEmpty().WithMessage("Le téléphone fixe est requis.")
.Matches(@"^(\+33|0)[1-9](\d{2}){4}$")
.WithMessage("Le numéro de téléphone fixe n'est pas valide. Format attendu : +33XXXXXXXXX ou 0XXXXXXXXX.")
.MaximumLength(15).WithMessage("Le téléphone fixe ne doit pas dépasser 15 caractères.");
RuleFor(x => x.TelephonePortable)
.NotEmpty().WithMessage("Le téléphone portable est requis.")
.Matches(@"^(\+33|0)[6-7](\d{2}){4}$")
.WithMessage("Le numéro de téléphone portable n'est pas valide. Format attendu : +33XXXXXXXXX ou 0XXXXXXXXX.")
.MaximumLength(15).WithMessage("Le téléphone portable ne doit pas dépasser 15 caractères.");
RuleFor(x => x.Email)
.NotEmpty().WithMessage("L'email est requis.")
.EmailAddress().WithMessage("L'email n'est pas valide.")
.MaximumLength(50).WithMessage("L'email ne doit pas dépasser 50 caractères.");
RuleFor(x => x.IdSite)
.NotEmpty().WithMessage("L'ID du site est requis.");
RuleFor(x => x.IdService)
.NotEmpty().WithMessage("L'ID du service est requis.");
}
}

View File

@@ -0,0 +1,43 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Service;
namespace ldap_cesi.Validator.Salarie;
public class SalarieUpdateValidator : AbstractValidator<SalarieUpdateDto>
{
public SalarieUpdateValidator()
{
RuleFor(x => x.Id)
.NotEmpty().WithMessage("L'identifiant du salarié est requis.");
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.Prenom)
.NotEmpty().WithMessage("Le prénom est requis.")
.MaximumLength(50).WithMessage("Le prénom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.TelephoneFixe)
.NotEmpty().WithMessage("Le téléphone fixe est requis.")
.Matches(@"^(\+33|0)[1-9](\d{2}){4}$")
.WithMessage("Le numéro de téléphone fixe n'est pas valide. Format attendu : +33XXXXXXXXX ou 0XXXXXXXXX.")
.MaximumLength(15).WithMessage("Le téléphone fixe ne doit pas dépasser 15 caractères.");
RuleFor(x => x.TelephonePortable)
.NotEmpty().WithMessage("Le téléphone portable est requis.")
.Matches(@"^(\+33|0)[6-7](\d{2}){4}$")
.WithMessage("Le numéro de téléphone portable n'est pas valide. Format attendu : +33XXXXXXXXX ou 0XXXXXXXXX.")
.MaximumLength(15).WithMessage("Le téléphone portable ne doit pas dépasser 15 caractères.");
RuleFor(x => x.Email)
.NotEmpty().WithMessage("L'email est requis.")
.EmailAddress().WithMessage("L'email n'est pas valide.")
.MaximumLength(50).WithMessage("L'email ne doit pas dépasser 50 caractères.");
RuleFor(x => x.IdSite)
.NotEmpty().WithMessage("L'ID du site est requis.");
RuleFor(x => x.IdService)
.NotEmpty().WithMessage("L'ID du service est requis.");
}
}

View File

@@ -0,0 +1,14 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Service;
namespace ldap_cesi.Validator.Service;
public class ServiceCreateValidator : AbstractValidator<ServiceCreateDto>
{
public ServiceCreateValidator()
{
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
}
}

View File

@@ -0,0 +1,18 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Service;
namespace ldap_cesi.Validator.Service;
public class ServiceUpdateValidator : AbstractValidator<ServiceUpdateDto>
{
public ServiceUpdateValidator()
{
RuleFor(x => x.Nom)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(50).WithMessage("Le nom ne doit pas dépasser 50 caractères.");
RuleFor(x => x.Id)
.NotEmpty().WithMessage("L'identifiant du service est requis.");
}
}

View File

@@ -0,0 +1,14 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Site;
namespace ldap_cesi.Validator.Site;
public class SiteCreateValidator : AbstractValidator<SiteCreateDto>
{
public SiteCreateValidator()
{
RuleFor(x => x.Ville)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(150).WithMessage("Le nom de la ville ne doit pas dépasser 150 caractères.");
}
}

View File

@@ -0,0 +1,16 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs.Site;
namespace ldap_cesi.Validator.Site;
public class SiteUpdateValidator : AbstractValidator<SiteUpdateDto>
{
public SiteUpdateValidator()
{
RuleFor(x => x.Ville)
.NotEmpty().WithMessage("Le nom est requis.")
.MaximumLength(150).WithMessage("Le nom de la ville ne doit pas dépasser 150 caractères.");
RuleFor(x => x.Id)
.NotEmpty().WithMessage("L'identifiant du site est requis.");
}
}

View File

@@ -0,0 +1,20 @@
using FluentValidation;
using ldap_cesi.DTOs.Inputs;
namespace ldap_cesi.Validator.Utilisateur;
public class UtilisateurLoginValidator : AbstractValidator<UtilisateurLoginDto>
{
public UtilisateurLoginValidator()
{
RuleFor(x => x.Email)
.NotEmpty().WithMessage("L'email est requis.")
.EmailAddress().WithMessage("L'email n'est pas valide.")
.MaximumLength(50).WithMessage("L'email ne doit pas dépasser 50 caractères.");
RuleFor(x => x.MotDePasse)
.NotEmpty().WithMessage("Le mot de passe est requis.")
.MinimumLength(6).WithMessage("Le mot de passe doit contenir au moins 6 caractères.")
.MaximumLength(20).WithMessage("Le mot de passe ne doit pas dépasser 20 caractères.");
}
}

View File

@@ -5,14 +5,18 @@
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
<RootNamespace>ldap_cesi</RootNamespace> <RootNamespace>ldap_cesi</RootNamespace>
<NoWarn>CS0472,CS1591,CS1587</NoWarn>
<GenerateDocumentationFile>true</GenerateDocumentationFile> <GenerateDocumentationFile>true</GenerateDocumentationFile>
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="AutoMapper" Version="14.0.0" /> <PackageReference Include="AutoMapper" Version="14.0.0" />
<PackageReference Include="BCrypt.Net-Next" Version="4.0.3" /> <PackageReference Include="BCrypt.Net-Next" Version="4.0.3" />
<PackageReference Include="Bogus" Version="35.6.2" />
<PackageReference Include="FluentValidation" Version="11.11.0" />
<PackageReference Include="FluentValidation.AspNetCore" Version="11.3.0" />
<PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.2" /> <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.2" />
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.2"/> <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.2" />
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.2" /> <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.2" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="9.0.2"> <PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="9.0.2">
<PrivateAssets>all</PrivateAssets> <PrivateAssets>all</PrivateAssets>
@@ -29,7 +33,6 @@
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Folder Include="Entities\" />
<Folder Include="Migrations\" /> <Folder Include="Migrations\" />
</ItemGroup> </ItemGroup>