lux/EgwCoreLib.Lux.Data/Repository/Stats/StatsAggrRepository.cs

using EgwCoreLib.Lux.Data.DbModel.Stats;
using EgwCoreLib.Utils;
using Microsoft.EntityFrameworkCore;

namespace EgwCoreLib.Lux.Data.Repository.Stats
{
    public class StatsAggrRepository : BaseRepository, IStatsAggrRepository
    {
        #region Public Constructors

        public StatsAggrRepository(IDbContextFactory<DataLayerContext> ctxFactory) : base(ctxFactory)
        {
        }

        #endregion Public Constructors

        #region Public Methods

        /// <summary>
        /// Elenco da DB delel stats aggregate dato periodo inizio/fine
        /// </summary>
        /// <param name="dtStart"></param>
        /// <param name="dtEnd"></param>
        /// <returns></returns>
        public async Task<List<StatsAggregatedModel>> GetFiltAsync(DateTime dtStart, DateTime dtEnd)
        {
            await using var dbCtx = await CreateContextAsync();
            return await dbCtx
                            .DbSetStatsAggr
                            .Where(x => x.Hour >= dtStart && x.Hour <= dtEnd)
                            .AsNoTracking()
                            .OrderBy(x => x.Hour)
                            .ToListAsync();
        }

        /// <summary>
        /// Range periodo per chiamate aggregate
        /// </summary>
        /// <returns></returns>
        public async Task<DtUtils.Periodo> GetRangeAsync()
        {
            await using var dbCtx = await CreateContextAsync();
            DtUtils.Periodo answ = new DtUtils.Periodo(DtUtils.PeriodSet.Today);
            var query = dbCtx.DbSetStatsAggr.AsQueryable();
            var minHour = await query.MinAsync(x => x.Hour);
            var maxHour = await query.MaxAsync(x => x.Hour);
            answ.Inizio = minHour;
            answ.Fine = maxHour;
            // ritorno!
            return answ;
        }

        /// <summary>
        /// Esegue insert statistiche aggregate sul DB
        /// </summary>
        /// <param name="listRecords">Elenco dei record da inserire</param>
        /// <param name="removeOld">Se true preventivamente elimina record nel periodo richiesto</param>
        /// <returns></returns>
        public async Task<int> UpsertManyAsync(List<StatsAggregatedModel> listRecords, bool removeOld)
        {
            int answ = 0;
            await using var dbCtx = await CreateContextAsync();
            await using var tx = await dbCtx.Database.BeginTransactionAsync();
            try
            {
                // in primis se richiesto calcolo range periodo e svuoto...
                if (removeOld)
                {
                    var firstRec = listRecords.OrderBy(x => x.Hour).FirstOrDefault();
                    var lastRec = listRecords.OrderByDescending(x => x.Hour).FirstOrDefault();

                    if (firstRec != null && lastRec != null)
                    {
                        DateTime startDate = firstRec.Hour;
                        DateTime endDate = lastRec.Hour;
                        // uso direttamente ExecuteDelete
                        await dbCtx
                                .DbSetStatsAggr
                                .Where(x => x.Hour >= startDate && x.Hour <= endDate)
                                .ExecuteDeleteAsync();
                    }
                }

                // ora preparo inserimento massivo
                await dbCtx
                        .DbSetStatsAggr
                        .AddRangeAsync(listRecords);

                // salvo!
                answ = await dbCtx.SaveChangesAsync();

                // commit transazione
                tx.Commit();

                // libero memoria del changeTracker
                dbCtx.ChangeTracker.Clear();
                return answ;
            }
            catch
            {
                tx.Rollback();
                throw;
            }
        }

        #endregion Public Methods
    }
}