All checks were successful
CI/CD Pipeline / Build and Deploy with Docker Compose (push) Successful in 2m48s
107 lines
4.1 KiB
C#
107 lines
4.1 KiB
C#
using Domain.Entities;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.Extensions.Logging;
|
|
using Models.Helpers;
|
|
using Models.Interfaces;
|
|
using Models.Models;
|
|
using System.Xml.Linq;
|
|
|
|
namespace Models.Repositories
|
|
{
|
|
public class PhSCustomerRepository(PhronCareOperationsHubContext context, ILogger<PhSCustomerRepository> logger) : IPhSCustomerRepository
|
|
{
|
|
#region Declaraciones y Constructor
|
|
private readonly PhronCareOperationsHubContext _context = context;
|
|
private readonly ILogger<PhSCustomerRepository> _logger = logger;
|
|
|
|
#endregion
|
|
public async Task<IEnumerable<ECustomer>> GetAllAsync()
|
|
{
|
|
var customers = await _context.PhSCustomers
|
|
.Include(c => c.Accounttypes)
|
|
.Include(c => c.PhSCustomerAddresses)
|
|
.Include(c => c.PhSCustomerDocuments)
|
|
.Take(100)
|
|
.ToListAsync();
|
|
return customers.Select(EntityMapper.MapEntity<PhSCustomer, ECustomer>);
|
|
}
|
|
public async Task<ECustomer?> GetByIdAsync(int id)
|
|
{
|
|
var customer = await _context.PhSCustomers
|
|
.Include(c => c.Accounttypes)
|
|
.Include(c => c.PhSCustomerAddresses)
|
|
.Include(c => c.PhSCustomerDocuments)
|
|
.Include(c => c.PhSQuoteHeaders)
|
|
.FirstOrDefaultAsync(c => c.Id == id);
|
|
|
|
return customer != null ? EntityMapper.MapEntity<PhSCustomer, ECustomer>(customer) : null;
|
|
}
|
|
public async Task<IEnumerable<ECustomer>> SearchAsync(string? name, string? document, string? email)
|
|
{
|
|
var query = _context.PhSCustomers
|
|
.Include(c => c.Accounttypes)
|
|
.Include(c => c.PhSCustomerDocuments)
|
|
.Include(c => c.PhSCustomerAddresses)
|
|
.Take(3)
|
|
.AsQueryable();
|
|
|
|
if (!string.IsNullOrWhiteSpace(name))
|
|
{
|
|
var loweredName = name.ToLower();
|
|
query = query.Where(c =>
|
|
c.Name.ToLower().Contains(loweredName) ||
|
|
c.BusinessName.ToLower().Contains(loweredName));
|
|
}
|
|
|
|
if (!string.IsNullOrWhiteSpace(document) && document != "?")
|
|
{
|
|
query = query.Where(c =>
|
|
c.PhSCustomerDocuments.Any(a =>
|
|
EF.Functions.Like(a.DocumentNumber, $"%{document}%")));
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(email))
|
|
{
|
|
var loweredEmail = email.ToLower();
|
|
query = query.Where(c =>
|
|
c.PhSCustomerAddresses.Any(a =>
|
|
a.Email.ToLower().Contains(loweredEmail)));
|
|
}
|
|
|
|
var customers = await query.ToListAsync();
|
|
|
|
Console.WriteLine($"VALOR RECIBIDO DE 'name': {name}");
|
|
Console.WriteLine($"VALOR RECIBIDO DE 'document': {document}");
|
|
Console.WriteLine($"VALOR RECIBIDO DE 'email': {email}");
|
|
|
|
|
|
return customers.Select(EntityMapper.MapEntity<PhSCustomer, ECustomer>);
|
|
}
|
|
|
|
public async Task<ECustomer> AddAsync(ECustomer entity)
|
|
{
|
|
var customer = EntityMapper.MapEntity<ECustomer, PhSCustomer>(entity);
|
|
await _context.PhSCustomers.AddAsync(customer);
|
|
await _context.SaveChangesAsync();
|
|
return EntityMapper.MapEntity<PhSCustomer, ECustomer>(customer);
|
|
}
|
|
public async Task<bool> UpdateAsync(ECustomer entity)
|
|
{
|
|
var customer = await _context.PhSCustomers.FindAsync(entity.Id);
|
|
if (customer == null) return false;
|
|
|
|
_context.Entry(customer).CurrentValues.SetValues(entity);
|
|
await _context.SaveChangesAsync();
|
|
return true;
|
|
}
|
|
public async Task<bool> DeleteAsync(int id)
|
|
{
|
|
var customer = await _context.PhSCustomers.FindAsync(id);
|
|
if (customer == null) return false;
|
|
|
|
_context.PhSCustomers.Remove(customer);
|
|
await _context.SaveChangesAsync();
|
|
return true;
|
|
}
|
|
}
|
|
}
|