Files
lux/EgwCoreLib.Lux.Data/Repository/Config/ConfProfileRepository.cs
T
2026-03-20 08:27:38 +01:00

79 lines
2.7 KiB
C#

using EgwCoreLib.Lux.Data.DbModel.Config;
using Microsoft.EntityFrameworkCore;
namespace EgwCoreLib.Lux.Data.Repository.Config
{
public class ConfProfileRepository : BaseRepository, IConfProfileRepository
{
#region Public Constructors
public ConfProfileRepository(IDbContextFactory<DataLayerContext> ctxFactory) : base(ctxFactory)
{
}
#endregion Public Constructors
#region Public Methods
public async Task<bool> AddAsync(ProfileModel entity)
{
await using var dbCtx = await CreateContextAsync();
await dbCtx.DbSetConfProfile.AddAsync(entity);
return await dbCtx.SaveChangesAsync() > 0;
}
public async Task<bool> AddRangeAsync(List<ProfileModel> entityList)
{
await using var dbCtx = await CreateContextAsync();
await dbCtx.DbSetConfProfile.AddRangeAsync(entityList);
return await dbCtx.SaveChangesAsync() > 0;
}
public async Task<bool> DeleteAsync(ProfileModel entity)
{
await using var dbCtx = await CreateContextAsync();
dbCtx.DbSetConfProfile.Remove(entity);
return await dbCtx.SaveChangesAsync() > 0;
}
public async Task<List<ProfileModel>> GetAllAsync()
{
await using var dbCtx = await CreateContextAsync();
return await dbCtx.DbSetConfProfile.AsNoTracking().ToListAsync();
}
public async Task<ProfileModel?> GetByIdAsync(int recId)
{
await using var dbCtx = await CreateContextAsync();
return await dbCtx.DbSetConfProfile
.FirstOrDefaultAsync(x => x.ProfileID == recId);
//.Where(x => x.ProfileID == recId)
}
public async Task<ProfileModel?> GetByUidAsync(string uID)
{
await using var dbCtx = await CreateContextAsync();
return await dbCtx.DbSetConfProfile
.FirstOrDefaultAsync(x => x.Code == uID);
//.FirstOrDefaultAsync();
}
public async Task<bool> UpdateAsync(ProfileModel entity)
{
await using var dbCtx = await CreateContextAsync();
var trackedEntity = dbCtx.DbSetConfProfile.Local.FirstOrDefault(x => x.ProfileID == entity.ProfileID);
if (trackedEntity != null)
{
// Aggiorna i valori dell'entità tracciata con quelli della nuova
dbCtx.Entry(trackedEntity).CurrentValues.SetValues(entity);
}
else
{
dbCtx.DbSetConfProfile.Update(entity);
}
return await dbCtx.SaveChangesAsync() > 0;
}
#endregion Public Methods
}
}