using EgwCoreLib.Lux.Data.DbModel.Utils; using Microsoft.EntityFrameworkCore; namespace EgwCoreLib.Lux.Data.Repository.Utils { public class GenValRepository : BaseRepository, IGenValRepository { #region Public Constructors public GenValRepository(DataLayerContext db) : base(db) { } #endregion Public Constructors #region Public Methods public void Add(GenValueModel entity) => _dbCtx.DbSetGenVal.Add(entity); public async Task DeleteAsync(GenValueModel rec2del) { // 1. Recupero il record da eliminare var dbResult = await _dbCtx.DbSetGenVal .FirstOrDefaultAsync(x => x.GenValID == rec2del.GenValID); if (dbResult == null) return false; // 2. Recupero i record successivi da shiftare var list2Move = await _dbCtx.DbSetGenVal .Where(x => x.ClassCod == rec2del.ClassCod && x.Index > dbResult.Index) .ToListAsync(); foreach (var item in list2Move) { item.Index--; _dbCtx.Entry(item).State = EntityState.Modified; } // 3. Rimuovo il record _dbCtx.DbSetGenVal.Remove(dbResult); // 4. Salvo tutto return await _dbCtx.SaveChangesAsync() > 0; } public async Task GetByIdAsync(int Id) => await _dbCtx.DbSetGenVal.FirstOrDefaultAsync(x => x.GenValID == Id); public async Task> GetFiltAsync(string codClass) { return await _dbCtx.DbSetGenVal .Where(x => x.ClassCod == codClass) .AsNoTracking() .ToListAsync(); } public async Task MoveAsync(GenValueModel selRec, bool moveUp) { // 1. Recupero il record corrente var currRec = await _dbCtx.DbSetGenVal .FirstOrDefaultAsync(x => x.GenValID == selRec.GenValID); if (currRec == null) return false; // 2. Numero totale record della classe int numRec = await _dbCtx.DbSetGenVal .CountAsync(x => x.ClassCod == selRec.ClassCod); // 3. Calcolo nuova posizione int newPos = moveUp ? currRec.Index - 1 : currRec.Index + 1; bool canMove = moveUp ? newPos > 0 : newPos <= numRec; if (!canMove) return false; // 4. Recupero il record da scambiare var otherRec = await _dbCtx.DbSetGenVal .FirstOrDefaultAsync(x => x.ClassCod == selRec.ClassCod && x.Index == newPos); if (otherRec == null) return false; // 5. Swap indici otherRec.Index = currRec.Index; currRec.Index = newPos; _dbCtx.Entry(otherRec).State = EntityState.Modified; _dbCtx.Entry(currRec).State = EntityState.Modified; // 6. Salvo return await _dbCtx.SaveChangesAsync() > 0; } public void Update(GenValueModel entity) { // Recuperiamo l'entità tracciata dal context var trackedEntity = _dbCtx.DbSetGenVal.Local.FirstOrDefault(x => x.GenValID == entity.GenValID); if (trackedEntity != null) { // Aggiorna i valori dell'entità tracciata con quelli della nuova _dbCtx.Entry(trackedEntity).CurrentValues.SetValues(entity); } else { _dbCtx.DbSetGenVal.Update(entity); } } #endregion Public Methods } }