using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using MP.Data.DbModels;
using MP.Data.DbModels.Anag;
using NLog;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;

namespace MP.Data.Controllers
{
    public class MpIocController : IDisposable
    {
        #region Public Constructors

        public MpIocController(IConfiguration configuration)
        {
            _configuration = configuration;
            Log.Info("Avviata classe MpIocController");
        }

        #endregion Public Constructors

        #region Public Methods

        /// <summary>
        /// Insert record allarme
        /// </summary>
        /// <param name="dtRif">Data evento</param>
        /// <param name="machineId">Id macchina</param>
        /// <param name="memAddress">area memoria</param>
        /// <param name="memAddress">indice memoria</param>
        /// <param name="memAddress">valore status</param>
        /// <param name="memAddress">valore decodificato</param>
        /// <returns></returns>
        public async Task<bool> AlarmLogInsertAsync(DateTime dtRif, string machineId, string memAddress, int memIndex, int statusVal, string valDecoded)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var DtRif = new SqlParameter("@DtRif", dtRif);
                var MachineId = new SqlParameter("@MachineId", machineId);
                var MemAddress = new SqlParameter("@MemAddress", memAddress);
                var MemIndex = new SqlParameter("@MemIndex", memIndex);
                var StatusVal = new SqlParameter("@StatusVal", statusVal);
                var ValDecoded = new SqlParameter("@ValDecoded", valDecoded);

                var result = await dbCtx
                                .Database
                                .ExecuteSqlRawAsync("EXEC stp_AL_insertQuery @DtRif, @MachineId, @MemAddress, @MemIndex, @StatusVal, @ValDecoded, ", DtRif, MachineId, MemAddress, MemIndex, StatusVal, ValDecoded);
                fatto = result != 0;
            }
            return fatto;
        }

        /// <summary>
        /// Restituisce l'anagrafica STATI per intero
        /// </summary>
        /// <returns></returns>
        public async Task<List<AnagStatiModel>> AnagStatiGetAllAsync()
        {
            List<AnagStatiModel> dbResult = new List<AnagStatiModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                                    .DbSetAnagStati
                                    .AsNoTracking()
                                    .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Restitusice elenco ultimi articoli per macchina
        /// </summary>
        /// <param name="tipo"></param>
        /// <param name="azienda"></param>
        /// </summary>
        /// <returns></returns>
        public async Task<List<AnagArticoliModel>> ArticoliGetLastByMaccAsync(string idxMacc)
        {
            List<AnagArticoliModel> dbResult = new List<AnagArticoliModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);

                dbResult = await dbCtx
                                 .DbSetArticoli
                                 .FromSqlRaw("exec dbo.stp_ART_getLastByMacch @idxMacchina", IdxMacchina)
                                 .AsNoTracking()
                                 .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Apre in automatico un nuovo PODL/ODL chiudendo l'attuale (aperto)
        /// </summary>
        /// <param name="idxOdl">Idx ODL corrente</param>
        /// <param name="MatrOpr">Matricola operatore</param>
        /// <param name="idxMacchina">idx macchina da confermare</param>
        /// <param name="tCRich">TempoCiclo richiesto in attrezzaggio</param>
        /// <param name="pzPallet"># pz pallet</param>
        /// <param name="note">note ODL</param>
        /// <param name="startNewOdl">bool per avvio nuovo ODL (def: true)</param>
        /// <param name="qtyRich">Qty da produrre, deve essere >0</param>
        /// <param name="keyRich">KeyRich esterno, se vuoto uso vecchia, se KIT sovrascritto con KeyKit</param>
        /// <returns></returns>
        public async Task<bool> AutoStartOdlAsync(int idxOdl, int MatrOpr, string idxMacchina, decimal tCRich, int pzPallet, string note, bool startNewOdl, int qtyRich, string keyRich)
        {
            bool answ = false;
            try
            {
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    var IdxOdl = new SqlParameter("@idxOdl ", idxOdl);
                    var MatrApp = new SqlParameter("@MatrApp ", MatrOpr);
                    var IdxMacchina = new SqlParameter("@idxMacchina", idxMacchina);
                    var TCRich = new SqlParameter("@TCRichAttr", tCRich);
                    var PzPallet = new SqlParameter("@PzPallet", pzPallet);
                    var Note = new SqlParameter("@Note", note);
                    var StartNewOdl = new SqlParameter("@StartNewOdl", startNewOdl);
                    var QtyRich = new SqlParameter("@QtyRich", qtyRich);
                    var KeyRichiesta = new SqlParameter("@KeyRichiesta", keyRich);

                    var result = await dbCtx
                                    .Database
                                    .ExecuteSqlRawAsync("EXEC stp_ODL_AutoStart @idxOdl, @MatrApp, @idxMacchina, @TCRichAttr, @PzPallet, @Note, @StartNewOdl, @QtyRich, @KeyRichiesta", IdxOdl, MatrApp, IdxMacchina, TCRich, PzPallet, Note, StartNewOdl, QtyRich, KeyRichiesta);

                    // indico eseguito!
                    answ = result > 0;
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in ConfermaProdMacchina:{Environment.NewLine}{exc}");
            }
            return answ;
        }

        /// <summary>
        /// Effettua conferma prod macchina dell'intero periodo da confermare (ultima conferma - dtEvent)
        /// </summary>
        /// <param name="idxMacchina">idx macchina da confermare</param>
        /// <param name="modoConfProd">0=periodo, 1 = giorno, 2 = turno</param>
        /// <param name="numPzConfermati">qta pezzi BUONI da confermare</param>
        /// <param name="numPzScarto">qta pezzi SCARTO da confermare</param>
        /// <param name="DataOraApp">DataOra in cui registrare approvazione</param>
        /// <param name="MatrOpr">Matricola operatore</param>
        /// <returns></returns>
        public async Task<bool> ConfermaProdMacchinaAsync(string idxMacchina, int modoConfProd, int numPzConfermati, int numPzScarto, DateTime DataOraApp, int MatrOpr)
        {
            bool answ = false;
            try
            {
                var rigaProd = await StatoProdMacchinaAsync(idxMacchina, DateTime.Now);
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    var IdxMacchina = new SqlParameter("@idxMacchina", idxMacchina);
                    var MatrApp = new SqlParameter("@MatrApp ", MatrOpr);
                    var DataFrom = new SqlParameter("@dataFrom ", rigaProd.DataFrom);
                    var DataTo = new SqlParameter("@dataTo", DataOraApp);
                    var PezziConf = new SqlParameter("@pezziConf", numPzConfermati);
                    var PezziScar = new SqlParameter("@pezziScar", numPzScarto);
                    var TipoConf = new SqlParameter("@TipoConf", modoConfProd);
                    var DtOraApp = new SqlParameter("@DataOraApp", DataOraApp);
                    var TestConferma = new SqlParameter("@TestConferma", true);

                    var result = await dbCtx
                                    .Database
                                    .ExecuteSqlRawAsync("EXEC stp_ConfermaProduzCompleta @idxMacchina, @MatrApp, @dataFrom, @dataTo, @pezziConf, @pezziScar, @TipoConf, @DataOraApp, @TestConferma ", IdxMacchina, MatrApp, DataFrom, DataTo, PezziConf, PezziScar, TipoConf, DtOraApp, TestConferma);

                    // indico eseguito!
                    answ = result > 0;
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in ConfermaProdMacchina:{Environment.NewLine}{exc}");
            }
            return answ;
        }

        /// <summary>
        /// Effettua conferma prod macchina dell'intero periodo da confermare (ultima conferma - dtEvent)
        /// </summary>
        /// <param name="idxMacchina">idx macchina da confermare</param>
        /// <param name="modoConfProd">0=periodo, 1 = giorno, 2 = turno</param>
        /// <param name="numPzConfermati">qta pezzi BUONI da confermare</param>
        /// <param name="numPzLasciati">qta pezzi LASCIATI da confermare</param>
        /// <param name="numPzScarto">qta pezzi SCARTO da confermare</param>
        /// <param name="DataOraApp">DataOra in cui registrare approvazione</param>
        /// <param name="MatrOpr">Matricola operatore</param>
        /// <returns></returns>
        public async Task<bool> ConfermaProdMacchinaFullAsync(string idxMacchina, int modoConfProd, int numPzConfermati, int numPzLasciati, int numPzScarto, DateTime DataOraApp, int MatrOpr)
        {
            bool answ = false;
            try
            {
                var rigaProd = await StatoProdMacchinaAsync(idxMacchina, DateTime.Now);
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    var IdxMacchina = new SqlParameter("@idxMacchina", idxMacchina);
                    var MatrApp = new SqlParameter("@MatrApp ", MatrOpr);
                    var DataFrom = new SqlParameter("@dataFrom ", rigaProd.DataFrom);
                    var DataTo = new SqlParameter("@dataTo", DataOraApp);
                    var PezziConf = new SqlParameter("@pezziConf", numPzConfermati);
                    var PezziLasc = new SqlParameter("@pezziLasciati", numPzLasciati);
                    var PezziScar = new SqlParameter("@pezziScar", numPzScarto);
                    var TipoConf = new SqlParameter("@TipoConf", modoConfProd);
                    var DtOraApp = new SqlParameter("@DataOraApp", DataOraApp);
                    var TestConferma = new SqlParameter("@TestConferma", true);
                    var Force = new SqlParameter("@Force", false);

                    var result = await dbCtx
                                    .Database
                                    .ExecuteSqlRawAsync("EXEC stp_ConfermaProduzCompletaFull @idxMacchina, @MatrApp, @dataFrom, @dataTo, @pezziConf, @pezziLasciati, @pezziScar, @TipoConf, @DataOraApp, @TestConferma,@Force", IdxMacchina, MatrApp, DataFrom, DataTo, PezziConf, PezziLasc, PezziScar, TipoConf, DtOraApp, TestConferma, Force);

                    // indico eseguito!
                    answ = result > 0;
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in ConfermaProdMacchinaAsync:{Environment.NewLine}{exc}");
            }
            return answ;
        }

        /// <summary>
        /// Record ConfFlux dato macchina (oppure tutti se vuoto)
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public async Task<List<ConfFluxModel>> ConfFluxFiltAsync(string idxMacc)
        {
            List<ConfFluxModel> dbResult = new();
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                var query = dbCtx.DbSetConfFlux
                                    .AsNoTracking()
                                    .AsQueryable();

                if (!string.IsNullOrEmpty(idxMacc))
                    query = query.Where(x => x.IdxMacchina == idxMacc);

                dbResult = await query.ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Elenco da tabella Config
        /// </summary>
        /// <returns></returns>
        public List<ConfigModel> ConfigGetAll()
        {
            List<ConfigModel> dbResult = new List<ConfigModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetConfig
                            .AsNoTracking()
                            .OrderBy(x => x.Chiave)
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Update record config
        /// </summary>
        /// <returns></returns>
        public bool ConfigUpdate(ConfigModel updRec)
        {
            bool fatto = false;
            ConfigModel dbResult = new ConfigModel();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                .DbSetConfig
                .Where(x => x.Chiave == updRec.Chiave)
                .FirstOrDefault();
                if (dbResult != null)
                {
                    dbResult.Valore = updRec.Valore;
                    dbCtx.SaveChanges();
                    fatto = true;
                }
            }
            return fatto;
        }

        /// <summary>
        /// Intera tab dati macchina
        /// </summary>
        /// <returns></returns>
        public List<DatiMacchineModel> DatiMacchineGetAll()
        {
            List<DatiMacchineModel> dbResult = new List<DatiMacchineModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetDatiMacchine
                            .AsNoTracking()
                            .OrderBy(x => x.IdxMacchina)
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera tab dati macchina
        /// </summary>
        /// <returns></returns>
        public async Task<List<DatiMacchineModel>> DatiMacchineGetAllAsync()
        {
            List<DatiMacchineModel> dbResult = new List<DatiMacchineModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                                    .DbSetDatiMacchine
                                    .AsNoTracking()
                                    .OrderBy(x => x.IdxMacchina)
                                    .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Inserimento record in DDB
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="inizioStato"></param>
        /// <param name="idxStato"></param>
        /// <param name="codArt"></param>
        /// <param name="value"></param>
        /// <param name="matrOpr"></param>
        /// <param name="pallet"></param>
        /// <returns></returns>
        public bool DDB_InsStatoBatch(string idxMacchina, DateTime inizioStato, int idxStato, string codArt, string value, int matrOpr, string pallet)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var InizioStato = new SqlParameter("@InizioStato", inizioStato);
                var IdxStato = new SqlParameter("@IdxStato", idxStato);
                var CodArticolo = new SqlParameter("@codArticolo", codArt);
                var Value = new SqlParameter("@Value", value);
                var MatrOpr = new SqlParameter("@MatrOpr", matrOpr);
                var Pallet = new SqlParameter("@pallet", pallet);

                var result = dbCtx
                            .Database
                            .ExecuteSqlRaw("exec dbo.stp_DDB_InsStatoBatch @IdxMacchina, @InizioStato, @IdxStato, @codArticolo, @Value, @MatrOpr, @pallet", IdxMacchina, InizioStato, IdxStato, CodArticolo, Value, MatrOpr, Pallet);

                // indico eseguito!
                fatto = result > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Elenco tabella decodifica articoli / codice decimale
        /// </summary>
        /// <param name="codArt">Vuoto = tutti / Singolo CodArt</param>
        /// <returns></returns>
        public async Task<List<DecNumArticoliModel>> DecNumArtGetFiltAsync(string codArt = "")
        {
            List<DecNumArticoliModel> dbResult = new List<DecNumArticoliModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var query = dbCtx.DbSetDecNumArt
                                    .AsNoTracking()
                                    .AsQueryable();

                if (!string.IsNullOrEmpty(codArt))
                    query = query.Where(x => x.CodArticolo == codArt);

                dbResult = await query.ToListAsync();
            }
            return dbResult;
        }

        public void Dispose()
        {
            _configuration = null;
        }

        /// <summary>
        /// Stored x recuperare ultimi dossier macchina
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public async Task<List<DossierModel>> DossGetLastByMaccAsync(string idxMacc)
        {
            List<DossierModel> dbResult = new();
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);
                dbResult = await dbCtx
                                 .DbSetDossiers
                                 .FromSqlRaw("exec dbo.stp_DOSS_getLastByMacch @idxMacchina", IdxMacchina)
                                 .AsNoTracking()
                                 .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Aggiunta record EventList
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public bool EvListInsert(EventListModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetEvList
                                    .Add(newRec);
                    dbCtx.SaveChanges();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante EvListInsert{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record EventList
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> EvListInsertAsync(EventListModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetEvList
                                    .Add(newRec);
                    await dbCtx.SaveChangesAsync();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante EvListInsertAsync{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }
        /// <summary>
        /// Fix ODL per macchine SLAVE
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="numDayPrev"></param>
        /// <param name="doInsert"></param>
        /// <returns></returns>
        public bool OdlFixMachineSlave(string idxMacchina, int numDayPrev, int doInsert)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var IdxMacc = new SqlParameter("@IdxMacchina", idxMacchina);
                    var NumDayPrev = new SqlParameter("@NumDayPrev", numDayPrev);
                    var DoInsert = new SqlParameter("@DoInsert", doInsert);
                    var result = dbCtx
                                .Database
                                .ExecuteSqlRaw("EXEC stp_ODL_fixMachineSlave @IdxMacchina, @NumDayPrev, @DoInsert", IdxMacc, NumDayPrev, DoInsert);
                    fatto = result != 0;
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlFixMachineSlave{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Fix ODL per macchine SLAVE Async
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="numDayPrev"></param>
        /// <param name="doInsert"></param>
        /// <returns></returns>
        public async Task<bool> OdlFixMachineSlaveAsync(string idxMacchina, int numDayPrev, int doInsert)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var IdxMacc = new SqlParameter("@IdxMacchina", idxMacchina);
                    var NumDayPrev = new SqlParameter("@NumDayPrev", numDayPrev);
                    var DoInsert = new SqlParameter("@DoInsert", doInsert);
                    var result = await dbCtx
                                .Database
                                .ExecuteSqlRawAsync("EXEC stp_ODL_fixMachineSlave @IdxMacchina, @NumDayPrev, @DoInsert", IdxMacc, NumDayPrev, DoInsert);
                    fatto = result != 0;
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlFixMachineSlaveAsync{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Chiamata x stored recupero FluxLog x macchina (first)
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <param name="numMax"></param>
        /// <returns></returns>
        public async Task<List<FluxLogModel>> FluxLogFirstByMaccAsync(string idxMacc, int numMax)
        {
            List<FluxLogModel> dbResult = new();
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);
                var NumMax = new SqlParameter("@numMax", numMax);

                dbResult = await dbCtx
                                 .DbSetFluxLog
                                 .FromSqlRaw("exec dbo.stp_FL_getFirstByMacc @IdxMacchina, @numMax", IdxMacchina, NumMax)
                                 .AsNoTracking()
                                 .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Elenco ultimi n record flux log dato macchina e flusso (ordinato x data registrazione)
        /// </summary>
        /// <param name="DtMax">Data massima x eventi</param>
        /// <param name="DtMin">Data minima x eventi</param>
        /// <param name="IdxMacchina">* = tutte, altrimenti solo x una data macchina</param>
        /// <param name="CodFlux">*=tutti, altrimenti solo selezionato</param>
        /// <param name="MaxRec">numero massimo record da restituire</param>
        /// <returns></returns>
        public List<FluxLogModel> FluxLogGetLastFilt(DateTime DtMax, DateTime DtMin, string IdxMacchina, string CodFlux, int MaxRec)
        {
            List<FluxLogModel> dbResult = new List<FluxLogModel>();
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetFluxLog
                            .AsNoTracking()
                            .Where(x => (x.dtEvento >= DtMin && x.dtEvento <= DtMax) && (IdxMacchina == "*" || x.IdxMacchina == IdxMacchina) && (CodFlux == "*" || x.CodFlux == CodFlux))
                            .OrderByDescending(x => x.dtEvento)
                            .Take(MaxRec)
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Aggiunta record FluxLog
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public bool FluxLogInsert(FluxLogModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetFluxLog
                                    .Add(newRec);
                    dbCtx.SaveChanges();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante FluxLogInsert{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record FluxLog Async
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> FluxLogInsertAsync(FluxLogModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetFluxLog
                                    .Add(newRec);
                    await dbCtx.SaveChangesAsync();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante FluxLogInsertAsync{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Stored x eseguire Snapshot FluxLog (= Dossier) dato periodo
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public async Task<bool> FluxLogTakeSnapshotLastAsync(string idxMacc, DateTime dataInizio, DateTime dataFine)
        {
            bool fatto = false;
            using (var dbCtx = new MoonPro_FluxContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);
                var DataInizio = new SqlParameter("@DtMin", dataInizio);
                var DataFine = new SqlParameter("@DtMax", dataFine);

                var result = await dbCtx
                                .Database
                                .ExecuteSqlRawAsync("EXEC stp_FL_TakeSnapshotLast @IdxMacchina, @DtMin, @DtMax", IdxMacchina, DataInizio, DataFine);
                fatto = result > 0;
            }
            return fatto;
        }

        public bool KeepAliveUpsert(string IdxMacc, DateTime OraServer, DateTime OraMacc)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var currRec = dbCtx
                                .DbSetKeepAlive
                                .Where(x => x.IdxMacchina == IdxMacc)
                                .FirstOrDefault();
                if (currRec != null)
                {
                    currRec.DataOraServer = OraServer;
                    currRec.DataOraMacchina = OraMacc;
                    dbCtx.Entry(currRec).State = EntityState.Modified;
                }
                else
                {
                    KeepAliveModel newRec = new KeepAliveModel()
                    {
                        IdxMacchina = IdxMacc,
                        DataOraMacchina = OraMacc,
                        DataOraServer = OraServer,
                        DataOraStart = DateTime.Now
                    };
                    dbCtx
                        .DbSetKeepAlive
                        .Add(newRec);
                }
                dbCtx.SaveChanges();
                fatto = true;
            }
            return fatto;
        }

        public async Task<bool> KeepAliveUpsertAsync(string IdxMacc, DateTime OraServer, DateTime OraMacc)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var currRec = await dbCtx
                                .DbSetKeepAlive
                                .Where(x => x.IdxMacchina == IdxMacc)
                                .FirstOrDefaultAsync();
                if (currRec != null)
                {
                    currRec.DataOraServer = OraServer;
                    currRec.DataOraMacchina = OraMacc;
                    dbCtx.Entry(currRec).State = EntityState.Modified;
                }
                else
                {
                    KeepAliveModel newRec = new KeepAliveModel()
                    {
                        IdxMacchina = IdxMacc,
                        DataOraMacchina = OraMacc,
                        DataOraServer = OraServer,
                        DataOraStart = DateTime.Now
                    };
                    dbCtx
                        .DbSetKeepAlive
                        .Add(newRec);
                }
                fatto = await dbCtx.SaveChangesAsync() > 0;
            }
            return fatto;
        }

        public List<LinkMenuModel> ListLinkFilt(string tipoLink)
        {
            List<LinkMenuModel> dbResult = new List<LinkMenuModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                .DbSetLinkMenu
                .Where(x => x.TipoLink == tipoLink)
                .AsNoTracking()
                .OrderBy(x => x.Ordine)
                .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Elenco valori ammessi x tabella/colonna con filtro parametrico
        /// </summary>
        /// <param name="tabName">Filtro tabella (se "" tutto)</param>
        /// <param name="fieldName">Filtro colonna (se "" tutto)</param>
        /// <returns></returns>
        public async Task<List<ListValuesModel>> ListValuesFilt(string tabName, string fieldName)
        {
            List<ListValuesModel> dbResult = new List<ListValuesModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var query = dbCtx.DbSetListValues
                                   .AsNoTracking()
                                   .AsQueryable();

                if (!string.IsNullOrEmpty(tabName))
                    query = query.Where(x => x.TableName == tabName);
                if (!string.IsNullOrEmpty(fieldName))
                    query = query.Where(x => x.FieldName == fieldName);

                dbResult = await query.ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera tabella relazione master/slave in machine (gestione setup master --&gt; slave)
        /// </summary>
        /// <returns></returns>
        public List<Macchine2SlaveModel> Macchine2Slave()
        {
            List<Macchine2SlaveModel> dbResult = new List<Macchine2SlaveModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetM2S
                            .AsNoTracking()
                            .OrderBy(x => x.IdxMacchina)
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera tabella relazione master/slave in machine (gestione setup master --&gt; slave)
        /// </summary>
        /// <returns></returns>
        public async Task<List<Macchine2SlaveModel>> Macchine2SlaveAsync()
        {
            List<Macchine2SlaveModel> dbResult = new List<Macchine2SlaveModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                                    .DbSetM2S
                                    .AsNoTracking()
                                    .OrderBy(x => x.IdxMacchina)
                                    .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Elenco Record Macchine
        /// </summary>
        /// <returns></returns>
        public List<MacchineModel> MacchineGetAll()
        {
            List<MacchineModel> dbResult = new List<MacchineModel>();
            using (MoonProContext dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetMacchine
                            .ToList();
            }
            return dbResult;
        }

        public MacchineModel? MacchineGetByIdx(string IdxMacchina)
        {
            MacchineModel dbResult = null;
            using (MoonProContext dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetMacchine
                            .FirstOrDefault(x => x.IdxMacchina == IdxMacchina);
            }
            return dbResult;
        }
        public async Task<MacchineModel?> MacchineGetByIdxAsync(string IdxMacchina)
        {
            MacchineModel dbResult = null;
            using (MoonProContext dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                            .DbSetMacchine
                            .FirstOrDefaultAsync(x => x.IdxMacchina == IdxMacchina);
            }
            return dbResult;
        }

        /// <summary>
        /// Elenco da tabella Macchine
        /// </summary>
        /// <param name="codGruppo"></param>
        /// <returns></returns>
        public List<MacchineModel> MacchineGetFilt(string codGruppo)
        {
            List<MacchineModel> dbResult = new List<MacchineModel>();
            try
            {
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    if (codGruppo == "*")
                    {
                        dbResult = dbCtx
                        .DbSetMacchine
                        .AsNoTracking()
                        .OrderBy(x => x.IdxMacchina)
                        .ToList();
                    }
                    else
                    {
                        dbResult = dbCtx
                        .DbSetGrp2Macc
                        .Where(g => g.CodGruppo == codGruppo)
                        .Join(dbCtx.DbSetMacchine,
                            g => g.IdxMacchina,
                            m => m.IdxMacchina,
                            (g, m) => m
                        )
                        .AsNoTracking()
                        .OrderBy(x => x.IdxMacchina)
                        .ToList();
                    }
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in MacchineGetFilt{Environment.NewLine}{exc}");
            }
            return dbResult;
        }

        /// <summary>
        /// Upsert Record Macchine
        /// </summary>
        /// <returns></returns>
        public bool MacchineUpsert(MacchineModel entity)
        {
            using (MoonProContext dbCtx = new MoonProContext(_configuration))
            {
                // Recuperiamo l'entità tracciata dal context
                var trackedEntity = dbCtx.DbSetMacchine.FirstOrDefault(x => x.IdxMacchina == entity.IdxMacchina);

                if (trackedEntity != null)
                {
                    // Aggiorna i valori dell'entità tracciata con quelli della nuova
                    dbCtx.Entry(trackedEntity).CurrentValues.SetValues(entity);
                }
                else
                {
                    dbCtx.DbSetMacchine.Update(entity);
                }
                return dbCtx.SaveChanges() > 0;
            }
        }

        /// <summary>
        /// Upsert Record Macchine ASYNC
        /// </summary>
        /// <returns></returns>
        public async Task<bool> MacchineUpsertAsync(MacchineModel entity)
        {
            using (MoonProContext dbCtx = new MoonProContext(_configuration))
            {
                // Recuperiamo l'entità tracciata dal context
                var trackedEntity = await dbCtx.DbSetMacchine.FirstOrDefaultAsync(x => x.IdxMacchina == entity.IdxMacchina);

                if (trackedEntity != null)
                {
                    // Aggiorna i valori dell'entità tracciata con quelli della nuova
                    dbCtx.Entry(trackedEntity).CurrentValues.SetValues(entity);
                }
                else
                {
                    dbCtx.DbSetMacchine.Update(entity);
                }
                bool fatto = await dbCtx.SaveChangesAsync() > 0;
                return fatto;
            }
        }

        /// <summary>
        /// Elenco da tabella Macchine
        /// </summary>
        /// <param name="IdxMacc"></param>
        /// <returns></returns>
        public List<MicroStatoMacchinaModel> MicroStatoMacchinaGetByIdxMacc(string IdxMacc)
        {
            List<MicroStatoMacchinaModel> dbResult = new List<MicroStatoMacchinaModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetMicroStatoMacc
                            .Where(x => x.IdxMacchina == IdxMacc)
                            .AsNoTracking()
                            .ToList();
                return dbResult;
            }
        }
        /// <summary>
        /// Elenco da tabella Macchine
        /// </summary>
        /// <param name="IdxMacc"></param>
        /// <returns></returns>
        public async Task<List<MicroStatoMacchinaModel>> MicroStatoMacchinaGetByIdxMaccAsync(string IdxMacc)
        {
            List<MicroStatoMacchinaModel> dbResult = new List<MicroStatoMacchinaModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                                .DbSetMicroStatoMacc
                                .Where(x => x.IdxMacchina == IdxMacc)
                                .AsNoTracking()
                                .ToListAsync();
                return dbResult;
            }
        }

        /// <summary>
        /// Aggiornamento record Microstato macchina
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public bool MicroStatoMacchinaUpsert(MicroStatoMacchinaModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var actRec = dbCtx
                                .DbSetMicroStatoMacc
                                .Where(x => x.IdxMacchina == newRec.IdxMacchina)
                                .AsNoTracking()
                                .FirstOrDefault();
                if (actRec == null)
                {
                    dbCtx
                        .DbSetMicroStatoMacc
                        .Add(newRec);
                }
                else
                {
                    actRec.IdxMicroStato = newRec.IdxMicroStato;
                    actRec.InizioStato = newRec.InizioStato;
                    actRec.Value = newRec.Value;

                    dbCtx.Entry(actRec).State = EntityState.Modified;
                }
                fatto = dbCtx.SaveChanges() > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Aggiornamento record Microstato macchina
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> MicroStatoMacchinaUpsertAsync(MicroStatoMacchinaModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var actRec = await dbCtx
                                .DbSetMicroStatoMacc
                                .Where(x => x.IdxMacchina == newRec.IdxMacchina)
                                .AsNoTracking()
                                .FirstOrDefaultAsync();
                if (actRec == null)
                {
                    dbCtx
                        .DbSetMicroStatoMacc
                        .Add(newRec);
                }
                else
                {
                    actRec.IdxMicroStato = newRec.IdxMicroStato;
                    actRec.InizioStato = newRec.InizioStato;
                    actRec.Value = newRec.Value;

                    dbCtx.Entry(actRec).State = EntityState.Modified;
                }
                fatto = await dbCtx.SaveChangesAsync() > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Elenco da tabella MappaStatoExplModel
        /// </summary>
        /// <returns></returns>
        public async Task<List<MappaStatoExplModel>> MseGetAllAsync(int maxAge = 2000)
        {
            List<MappaStatoExplModel> dbResult = new List<MappaStatoExplModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var maxAgeSec = new SqlParameter("@maxAgeSec", maxAge);

                dbResult = await dbCtx
                                .DbSetMSE
                                .FromSqlRaw("EXEC stp_MSE_getData @maxAgeSec", maxAgeSec)
                                .AsNoTracking()
                                .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Generazione automatica ODL
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public async Task<bool> OdlAutoDayGenAsync(string idxMacchina, DateTime dataInizio, DateTime dataFine, string codArticolo)
        {
            bool answ = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    var DataInizio = new SqlParameter("@DataInizio", dataInizio);
                    var DataFine = new SqlParameter("@DataFine", dataFine);
                    var CodArticolo = new SqlParameter("@codArticolo", codArticolo);

                    var result = dbCtx
                                    .Database
                                    .ExecuteSqlRaw("EXEC stp_ODL_AutoDayGener @IdxMacchina, @DataInizio, @DataFine, @codArticolo", IdxMacchina, DataInizio, DataFine, CodArticolo);

                    // indico eseguito!
                    answ = result > 0;
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante stp_ODL_AutoDayGener{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// Generazione automatica ODL completa
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public async Task<bool> OdlAutoDayGenFullAsync(string idxMacchina, DateTime dataInizio, DateTime dataFine, string codArticolo, int? pzPODL, int? pzPallet, string? keyRichiesta, int? tcAssegnato, string? codGruppo, bool flgCreaPODL, bool flgCheckTC)
        {
            bool answ = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    var DataInizio = new SqlParameter("@DataInizio", dataInizio);
                    var DataFine = new SqlParameter("@DataFine", dataFine);
                    var CodArticolo = new SqlParameter("@codArticolo", codArticolo);
                    var PzPODL = new SqlParameter("@PzPODL", pzPODL);
                    var PzPallet = new SqlParameter("@PzPallet", pzPallet);
                    var KeyRichiesta = new SqlParameter("@KeyRichiesta", keyRichiesta);
                    var TCAssegnato = new SqlParameter("@TCAssegnato", tcAssegnato);
                    var CodGruppo = new SqlParameter("@codGruppo", codGruppo);
                    var FlgCreaPODL = new SqlParameter("@flgCreaPODL", flgCreaPODL);
                    var FlgCheckTC = new SqlParameter("@flgCheckTC", flgCheckTC);

                    var result = dbCtx
                                    .Database
                                    .ExecuteSqlRaw("EXEC stp_ODL_AutoDayGenerFull @IdxMacchina, @DataInizio, @DataFine, @codArticolo, @PzPODL, @PzPallet, @KeyRichiesta, @TCAssegnato, @codGruppo, @flgCreaPODL, @flgCheckTC", IdxMacchina, DataInizio, DataFine, CodArticolo, PzPODL, PzPallet, KeyRichiesta, TCAssegnato, CodGruppo, FlgCreaPODL, FlgCheckTC);

                    // indico eseguito!
                    answ = result > 0;
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante stp_ODL_AutoDayGenerFull{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// ODL corrente macchina
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public ODLExpModel OdlCurrByMacc(string idxMacchina)
        {
            ODLExpModel answ = new();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    var dbRes = (dbCtx.DbSetODLExp
                         .FromSqlRaw("EXEC stp_ODL_getByMacchina @IdxMacchina", pIdxMacchina)
                         .AsNoTracking()
                         .ToList()) // Esegue la query e scarica i risultati in memoria
                         .FirstOrDefault(); // Prende il primo elemento dalla lista in RAM
                    answ = dbRes ?? new();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlCurrByMacc{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// ODL corrente macchina
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public async Task<ODLExpModel> OdlCurrByMaccAsync(string idxMacchina)
        {
            ODLExpModel answ = new();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    // attenzione: se la stored resituisce una tabella, il primo elemento va recuperato in RAM!!!
                    var dbRes = (await dbCtx.DbSetODLExp
                         .FromSqlRaw("EXEC stp_ODL_getByMacchina @IdxMacchina", pIdxMacchina)
                         .AsNoTracking()
                         .ToListAsync()) // Esegue la query e scarica i risultati in memoria
                         .FirstOrDefault(); // Prende il primo elemento dalla lista in RAM
                    answ = dbRes ?? new();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlCurrByMaccAsync{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// ODL corrente macchina
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public async Task<ODLExpModel> OdlLastByMaccAsync(string idxMacchina)
        {
            ODLExpModel answ = new();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    // attenzione: se la stored resituisce una tabella, il primo elemento va recuperato in RAM!!!
                    var dbRes = (await dbCtx.DbSetODLExp
                         .FromSqlRaw("EXEC stp_ODL_getLastByMacchina @IdxMacchina", pIdxMacchina)
                         .AsNoTracking()
                         .ToListAsync()) // Esegue la query e scarica i risultati in memoria
                         .FirstOrDefault(); // Prende il primo elemento dalla lista in RAM
                    answ = dbRes ?? new();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlCurrByMaccAsync{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// Elenco ODL data macchina e periodo
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="dtStart"></param>
        /// <param name="dtEnd"></param>
        /// <returns></returns>
        public List<ODLExpModel> OdlListByMaccPeriodo(string idxMacchina, DateTime dtStart, DateTime dtEnd)
        {
            List<ODLExpModel> dbResult = new List<ODLExpModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                    var DataFrom = new SqlParameter("@dataFrom", dtStart);
                    var DataTo = new SqlParameter("@dataTo", dtEnd);
                    dbResult = dbCtx
                                .DbSetODLExp
                                .FromSqlRaw("EXEC stp_ODL_getByMacchinaPeriodo @IdxMacchina, @dataFrom, @dataTo", IdxMacchina, DataFrom, DataTo)
                                .AsNoTracking()
                                .ToList();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante OdlListByMaccPeriodo{Environment.NewLine}{exc}");
                }
            }
            return dbResult;
        }

        /// <summary>
        /// Conteggio PzProd Macchina
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public PzProdModel PezziProdMacchina(string idxMacchina)
        {
            PzProdModel dbResult = new PzProdModel();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                dbResult = (dbCtx
                            .DbSetPzProd
                            .FromSqlRaw("EXEC stp_PzProd_getByMacchina @IdxMacchina", pIdxMacchina)
                            .AsNoTracking()
                            .ToList())
                            .FirstOrDefault(); // recupero da RAM
            }
            return dbResult;
        }

        /// <summary>
        /// Conteggio PzProd Macchina Async
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <returns></returns>
        public async Task<PzProdModel> PezziProdMacchinaAsync(string idxMacchina)
        {
            PzProdModel dbResult = new PzProdModel();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                dbResult = (await dbCtx
                                    .DbSetPzProd
                                    .FromSqlRaw("EXEC stp_PzProd_getByMacchina @IdxMacchina", pIdxMacchina)
                                    .AsNoTracking()
                                    .ToListAsync())
                                    .FirstOrDefault(); // recupero da RAM
            }
            return dbResult;
        }

        /// <summary>
        /// Recupero elenco PODL EXPL filtrati x macchina, articolo...
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="codArticolo"></param>
        /// <param name="codGruppo"></param>
        /// <param name="onlyFree">True = aperti (=senza ODL)</param>
        /// <returns></returns>
        public async Task<List<PODLExpModel>> POdlGetByMaccArtAsync(string idxMacchina, string codArticolo, string codGruppo, bool onlyFree)
        {
            List<PODLExpModel> dbResult = new List<PODLExpModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var pIdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var pCodArticolo = new SqlParameter("@CodArticolo", codArticolo);
                var pCodGruppo = new SqlParameter("@CodGruppo", codGruppo);
                var pOnlyFree = new SqlParameter("@onlyFree", onlyFree);

                dbResult = await dbCtx
                                .DbSetPODLExp
                                .FromSqlRaw("EXEC stp_PODL_getByMaccArt @IdxMacchina, @CodArticolo, @CodGruppo, @onlyFree", pIdxMacchina, pCodArticolo, pCodGruppo, pOnlyFree)
                                .AsNoTracking()
                                .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Effettua ricalcolo MSE x macchina indicata
        /// </summary>
        /// <param name="idxMacchina">idx macchina da confermare</param>
        /// <param name="maxAgeSec">Num massimo secondi di "vecchiaia" del dato</param>
        /// <returns></returns>
        public bool RecalcMse(string idxMacchina, int maxAgeSec)
        {
            bool answ = false;
            try
            {
                var rigaProd = StatoProdMacchina(idxMacchina, DateTime.Now);
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    var MaxAgeSec = new SqlParameter("@maxAgeSec ", maxAgeSec);
                    var IdxMacchina = new SqlParameter("@idxMacchina", idxMacchina);

                    var result = dbCtx
                                    .Database
                                    .ExecuteSqlRaw("EXEC stp_MSE_recalc @maxAgeSec, @idxMacchina ", MaxAgeSec, IdxMacchina);

                    // indico eseguito!
                    answ = result > 0;
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in RecalcMse:{Environment.NewLine}{exc}");
            }
            return answ;
        }
        /// <summary>
        /// Effettua ricalcolo MSE x macchina indicata
        /// </summary>
        /// <param name="idxMacchina">idx macchina da confermare</param>
        /// <param name="maxAgeSec">Num massimo secondi di "vecchiaia" del dato</param>
        /// <returns></returns>
        public async Task<bool> RecalcMseAsync(string idxMacchina, int maxAgeSec)
        {
            bool answ = false;
            try
            {
                var rigaProd = await StatoProdMacchinaAsync(idxMacchina, DateTime.Now);
                using (var dbCtx = new MoonProContext(_configuration))
                {
                    var MaxAgeSec = new SqlParameter("@maxAgeSec ", maxAgeSec);
                    var IdxMacchina = new SqlParameter("@idxMacchina", idxMacchina);

                    var result = await dbCtx
                                    .Database
                                    .ExecuteSqlRawAsync("EXEC stp_MSE_recalc @maxAgeSec, @idxMacchina ", MaxAgeSec, IdxMacchina);

                    // indico eseguito!
                    answ = result > 0;
                }
            }
            catch (Exception exc)
            {
                Log.Error($"Eccezione in RecalcMseAsync:{Environment.NewLine}{exc}");
            }
            return answ;
        }

        /// <summary>
        /// Registra controllo
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="matrOpr"></param>
        /// <param name="esitoOk"></param>
        /// <param name="note"></param>
        /// <param name="dataOra"></param>
        /// <returns></returns>
        public async Task<bool> RegControlliInsert(string idxMacchina, int matrOpr, bool esitoOk, string note, DateTime dataOra)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacc = new SqlParameter("@IdxMacchina", idxMacchina);
                var MatrOpr = new SqlParameter("@MatrOpr", matrOpr);
                var EsitoOk = new SqlParameter("@EsitoOk", esitoOk);
                var Note = new SqlParameter("@Note", note);
                var DataOra = new SqlParameter("@DataOra", dataOra);

                var result = await dbCtx
                                .Database
                                .ExecuteSqlRawAsync("EXEC stp_RC_insert @IdxMacchina, @MatrOpr, @EsitoOk, @Note, @DataOra", IdxMacc, MatrOpr, EsitoOk, Note, DataOra);
                fatto = result != 0;
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record Registro Dichiarazioni
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> RegDichiarInsert(RegistroDichiarazioniModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var TagCode = new SqlParameter("@TagCode", newRec.TagCode);
                var IdxMacchina = new SqlParameter("@IdxMacchina", newRec.IdxMacchina);
                var DtRec = new SqlParameter("@DtRec", newRec.DtRec);
                var MatrOpr = new SqlParameter("@MatrOpr", newRec.MatrOpr);
                var ValString = new SqlParameter("@ValString", newRec.ValString);

                var result = await dbCtx
                                 .Database
                                 .ExecuteSqlRawAsync("exec dbo.stp_DD_insertQuery @TagCode, @IdxMacchina, @DtRec, @MatrOpr, @ValString", TagCode, IdxMacchina, DtRec, MatrOpr, ValString);
                // indico eseguito!
                fatto = result > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Update record Registro Dichiarazioni
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> RegDichiarUpdate(RegistroDichiarazioniModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var Original_IdxDich = new SqlParameter("@Original_IdxDich", newRec.IdxDich);
                var DtRec = new SqlParameter("@DtRec", newRec.DtRec);
                var TagCode = new SqlParameter("@TagCode", newRec.TagCode);
                var ValString = new SqlParameter("@ValString", newRec.ValString);
                var MatrOpr = new SqlParameter("@MatrOpr", newRec.MatrOpr);

                var result = await dbCtx
                                 .Database
                                 .ExecuteSqlRawAsync("exec dbo.stp_DD_updateQuery @Original_IdxDich, @DtRec, @TagCode, @ValString, @MatrOpr", Original_IdxDich, DtRec, TagCode, ValString, MatrOpr);
                // indico eseguito!
                fatto = result > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record RegistroScarti
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> RegScartiInsert(RegistroScartiModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@idxMacchina", newRec.IdxMacchina);
                var DataOra = new SqlParameter("@DataOra", newRec.DataOra);
                var Causale = new SqlParameter("@Causale", newRec.Causale);
                var Qta = new SqlParameter("@Qta", newRec.Qta);
                var Note = new SqlParameter("@Note", newRec.Note);
                var MatrOpr = new SqlParameter("@MatrOpr", newRec.MatrOpr);

                var result = await dbCtx
                                 .DbSetRegWithCheck
                                 .FromSqlRaw("exec dbo.stp_RS_Insert_withCheck @idxMacchina, @DataOra, @Causale, @Qta, @Note, @MatrOpr", IdxMacchina, DataOra, Causale, Qta, Note, MatrOpr)
                                 .AsNoTracking()
                                 .ToListAsync();
                // indico eseguito!
                // -1 = restituisce una select
                fatto = result.Count > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record RemoteRebootLog
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> RemRebootLogAddAsync(RemoteRebootLogModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var dbResult = dbCtx
                                 .DbSetRemRebLog
                                 .Add(newRec);
                fatto = await dbCtx.SaveChangesAsync() > 0;
            }
            return fatto;
        }

        /// <summary>
        /// Recupera tutti i record di RemoteRebootLog
        /// </summary>
        /// <returns></returns>
        public async Task<List<RemoteRebootLogModel>> RemRebootLogGetAllAsync()
        {
            List<RemoteRebootLogModel> dbResult = new List<RemoteRebootLogModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                                .DbSetRemRebLog
                                .AsNoTracking()
                                .OrderByDescending(x => x.IdxReboot)
                                .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Recupera ultimo record x ogni IdxMacchina x avere ultimo attivo
        /// </summary>
        /// <returns></returns>
        public async Task<List<RemoteRebootLogModel>> RemRebootLogGetLastAsync()
        {
            List<RemoteRebootLogModel> dbResult = new List<RemoteRebootLogModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = await dbCtx
                            .DbSetRemRebLog
                            .FromSqlRaw("EXEC stp_RRL_getLast")
                            .AsNoTracking()
                            .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Recupera ultimo record x ogni IdxMacchina x avere ultimo attivo
        /// </summary>
        /// <returns></returns>
        public async Task<bool> RemRebootLogKeepLastAsync(int num2keep)
        {
            bool answ = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var Num2keep = new SqlParameter("@num2keep", num2keep);
                var dbResult = await dbCtx
                           .Database
                           .ExecuteSqlRawAsync("exec dbo.stp_RRL_KeepLatest @num2keep", Num2keep);
                answ = dbResult > 0;
            }
            return answ;
        }

        /// <summary>
        /// Annulla modifiche su una specifica entity (cancel update)
        /// </summary>
        /// <param name="item"></param>
        /// <returns></returns>
        public bool RollBackEntity(object item)
        {
            bool answ = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    if (dbCtx.Entry(item).State == Microsoft.EntityFrameworkCore.EntityState.Deleted || dbCtx.Entry(item).State == Microsoft.EntityFrameworkCore.EntityState.Modified)
                    {
                        dbCtx.Entry(item).Reload();
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione in rollBackEntity{Environment.NewLine}{exc}");
                }
            }
            return answ;
        }

        /// <summary>
        /// Aggiunta record SignalLog
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public bool SignalLogInsert(SignalLogModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetSignalLog
                                    .Add(newRec);
                    dbCtx.SaveChanges();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante SignalLogInsert{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Aggiunta record SignalLog Async
        /// </summary>
        /// <param name="newRec"></param>
        /// <returns></returns>
        public async Task<bool> SignalLogInsertAsync(SignalLogModel newRec)
        {
            bool fatto = false;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    var currRec = dbCtx
                                    .DbSetSignalLog
                                    .Add(newRec);
                    await dbCtx.SaveChangesAsync();
                }
                catch (Exception exc)
                {
                    Log.Error($"Eccezione durante SignalLogInsertAsync{Environment.NewLine}{exc}");
                }
            }
            return fatto;
        }

        /// <summary>
        /// Tabella state machine eventi 2 stati data macchina e tipo evento
        /// </summary>
        /// <param name="idxTipo"></param>
        /// <returns></returns>
        public List<TransizioneStatiModel> SMES_getHwTransitions(string idxMacchina, int idxTipo)
        {
            List<TransizioneStatiModel> dbResult = new List<TransizioneStatiModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var IdxTipo = new SqlParameter("@IdxTipo", idxTipo);
                dbResult = dbCtx
                            .DbSetSMES
                            .FromSqlRaw("exec dbo.stp_TS_getByIdxMacchIdxTipoEv @IdxMacchina, @IdxTipo", IdxMacchina, IdxTipo)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Tabella state machine eventi 2 stati data macchina e tipo evento
        /// </summary>
        /// <param name="idxTipo"></param>
        /// <returns></returns>
        public List<TransizioneStatiModel> SMES_getUserForced(string idxMacchina, int idxTipo)
        {
            List<TransizioneStatiModel> dbResult = new List<TransizioneStatiModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var IdxTipo = new SqlParameter("@IdxTipo", idxTipo);
                dbResult = dbCtx
                            .DbSetSMES
                            .FromSqlRaw("exec dbo.stp_TS_getUserForcedTrans @IdxMacchina, @IdxTipo", IdxMacchina, IdxTipo)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera tabella state machine ingressi 2 eventi
        /// </summary>
        /// <returns></returns>
        public List<TransizioneIngressiModel> StateMachineIngressi(int idxFam)
        {
            List<TransizioneIngressiModel> dbResult = new List<TransizioneIngressiModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxFamIn = new SqlParameter("@IdxFamigliaIngresso", idxFam);
                dbResult = dbCtx
                            .DbSetSMI
                            .FromSqlRaw("exec dbo.stp_TRI_getByIdxFamIng @IdxFamigliaIngresso", IdxFamIn)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera tabella state machine ingressi 2 eventi
        /// </summary>
        /// <returns></returns>
        public async Task<List<TransizioneIngressiModel>> StateMachineIngressiAsync(int idxFam)
        {
            List<TransizioneIngressiModel> dbResult = new List<TransizioneIngressiModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxFamIn = new SqlParameter("@IdxFamigliaIngresso", idxFam);
                dbResult = await dbCtx
                            .DbSetSMI
                            .FromSqlRaw("exec dbo.stp_TRI_getByIdxFamIng @IdxFamigliaIngresso", IdxFamIn)
                            .AsNoTracking()
                            .ToListAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Stato prod macchina (completo)
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="dtReq"></param>
        /// <returns></returns>
        public StatoProdModel StatoProdMacchina(string idxMacchina, DateTime dtReq)
        {
            StatoProdModel dbResult = new StatoProdModel();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var DataOra = new SqlParameter("@DataOra ", dtReq);
                var rawData = dbCtx
                            .DbSetStatoProd
                            .FromSqlRaw("EXEC stp_StatoProd_getByMacchina @IdxMacchina, @DataOra ", IdxMacchina, DataOra)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
                dbResult = rawData
                            .FirstOrDefault();
            }
            return dbResult;
        }

        /// <summary>
        /// Stato prod macchina (completo) Async
        /// </summary>
        /// <param name="idxMacchina"></param>
        /// <param name="dtReq"></param>
        /// <returns></returns>
        public async Task<StatoProdModel> StatoProdMacchinaAsync(string idxMacchina, DateTime dtReq)
        {
            StatoProdModel dbResult = new StatoProdModel();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacchina);
                var DataOra = new SqlParameter("@DataOra ", dtReq);
                dbResult = (await dbCtx
                            .DbSetStatoProd
                            .FromSqlRaw("EXEC stp_StatoProd_getByMacchina @IdxMacchina, @DataOra ", IdxMacchina, DataOra)
                            .AsNoTracking()
                            .ToListAsync())
                            .FirstOrDefault();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera vista v_MSFD
        /// </summary>
        /// <returns></returns>
        public List<VMSFDModel> VMSFDGetAll()
        {
            List<VMSFDModel> dbResult = new List<VMSFDModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                dbResult = dbCtx
                            .DbSetMSFD
                            .AsNoTracking()
                            .OrderBy(x => x.IdxMacchina)
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Intera vista v_MSFD in modo ASYNC
        /// </summary>
        /// <returns></returns>
        public async Task<List<VMSFDModel>> VMSFDGetAllAsync()
        {
            List<VMSFDModel> dbResult = new List<VMSFDModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                try
                {
                    dbResult = await dbCtx
                            .DbSetMSFD
                            .AsNoTracking()
                            .OrderBy(x => x.IdxMacchina)
                            .ToListAsync();
                }
                catch (Exception exc)
                {
                }
            }
            return dbResult;
        }

        /// <summary>
        /// Vista v_MSFD x singola macchina (da stored) - singolo record
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public List<VMSFDModel> VMSFDGetByMacc(string idxMacc)
        {
            List<VMSFDModel> dbResult = new List<VMSFDModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);

                dbResult = dbCtx
                            .DbSetMSFD
                            .FromSqlRaw("exec dbo.stp_MSFD_getMacc @IdxMacchina", IdxMacchina)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
            }
            return dbResult;
        }

        /// <summary>
        /// Vista v_MSFD x singola macchina (da stored) - singolo record
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public async Task<VMSFDModel?> VMSFDGetByMaccAsync(string idxMacc)
        {
            VMSFDModel? dbResult = null;
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);
                dbResult = await dbCtx
                            .DbSetMSFD
                            .FromSqlRaw("exec dbo.stp_MSFD_getMacc @IdxMacchina", IdxMacchina)
                            .AsNoTracking()
                            .FirstOrDefaultAsync();
            }
            return dbResult;
        }

        /// <summary>
        /// Vista v_MSFD delle machine MULTI filtrato x macchina (da stored)
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public List<VMSFDModel> VMSFDGetMultiByMacc(string idxMacc)
        {
            List<VMSFDModel> dbResult = new List<VMSFDModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);

                dbResult = dbCtx
                            .DbSetMSFD
                            .FromSqlRaw("exec dbo.stp_MSFD_getMulti @IdxMacchina", IdxMacchina)
                            .AsNoTracking()
                            .AsEnumerable()
                            .ToList();
            }
            return dbResult;
        }
        /// <summary>
        /// Vista v_MSFD delle machine MULTI filtrato x macchina (da stored)
        /// </summary>
        /// <param name="idxMacc"></param>
        /// <returns></returns>
        public async Task<List<VMSFDModel>> VMSFDGetMultiByMaccAsync(string idxMacc)
        {
            List<VMSFDModel> dbResult = new List<VMSFDModel>();
            using (var dbCtx = new MoonProContext(_configuration))
            {
                var IdxMacchina = new SqlParameter("@IdxMacchina", idxMacc);

                dbResult = await dbCtx
                            .DbSetMSFD
                            .FromSqlRaw("exec dbo.stp_MSFD_getMulti @IdxMacchina", IdxMacchina)
                            .AsNoTracking()
                            //.AsEnumerable()
                            .ToListAsync();
            }
            return dbResult;
        }

        #endregion Public Methods

        #region Private Fields

        private static IConfiguration _configuration;

        private static NLog.Logger Log = LogManager.GetCurrentClassLogger();

        #endregion Private Fields
    }
}