Merge branch 'Release/UpdateLogCall'

Sistemazione reload e params detail

MP.Data/Controllers/MpSpecController.cs

@@ -333,10 +333,10 @@ namespace MP.Data.Controllers
         /// </summary>
         /// <param name="IdxMacchina">* = tutte, altrimenti solo x una data macchina</param>
         /// <param name="CodArticolo">* = tutti, altrimenti solo x un dato articolo</param>
-        /// <param name="DtRef">Data di riferimento (Massima) per estrazioen records</param>
-        /// <param name="MaxRec">numero massimo record da restituire</param>
+        /// <param name="DtStart">Data minima per estrazione records</param>
+        /// <param name="DtEnd">Data Massima per estrazione records</param>
         /// <returns></returns>
-        public List<Dossiers> DossiersGetLastFilt(string IdxMacchina, string CodArticolo, DateTime DtRef, int MaxRec)
+        public List<Dossiers> DossiersGetLastFilt(string IdxMacchina, string CodArticolo, DateTime DtStart, DateTime DtEnd)
         {
             List<Dossiers> dbResult = new List<Dossiers>();
             using (var dbCtx = new MoonProContext(_configuration))
@@ -344,12 +344,11 @@ namespace MP.Data.Controllers
                 dbResult = dbCtx
                             .DbSetDossiers
                             .AsNoTracking()
-                            .Where(x => (IdxMacchina == "*" || x.IdxMacchina == IdxMacchina) && (CodArticolo == "*" || x.OdlNav.CodArticolo == CodArticolo) && x.DtRif <= DtRef)
+                            .Where(x => (IdxMacchina == "*" || x.IdxMacchina == IdxMacchina) && (CodArticolo == "*" || x.OdlNav.CodArticolo == CodArticolo) && (x.DtRif >= DtStart && x.DtRif <= DtEnd))
                             .Include(m => m.MachineNav)
                             .Include(o => o.OdlNav)
                             .Include(a => a.OdlNav.ArticoloNav)
                             .OrderByDescending(x => x.DtRif)
-                            .Take(MaxRec)
                             .ToList();
             }
             return dbResult;
@@ -602,10 +601,12 @@ namespace MP.Data.Controllers
         }
 
         /// <summary>
-        /// Elenco id Macchine che abbiano dati FLuxLog
+        /// Elenco id Macchine che abbiano dati FLuxLog, nel periodo indicato
         /// </summary>
+        /// <param name="dtStart"></param>
+        /// <param name="dtEnd"></param>
         /// <returns></returns>
-        public async Task<List<string>> MacchineWithFlux()
+        public async Task<List<string>> MacchineWithFlux(DateTime dtStart, DateTime dtEnd)
         {
             List<string> dbResult = new List<string>();
             using (var dbCtx = new MoonProContext(_configuration))
@@ -613,6 +614,7 @@ namespace MP.Data.Controllers
                 dbResult = await dbCtx
                                 .DbSetFluxLog
                                 .AsNoTracking()
+                                .Where(x => x.dtEvento >= dtStart && x.dtEvento <= dtEnd)
                                 .Select(i => i.IdxMacchina)
                                 .Distinct()
                                 .ToListAsync();
@@ -795,8 +797,10 @@ namespace MP.Data.Controllers
                             .DbSetFluxLog
                             .AsNoTracking()
                             .Where(x => (IdxMacchina == "*" || x.IdxMacchina == IdxMacchina))
+                            .Take(1000)
                             .Select(i => i.CodFlux)
                             .Distinct()
+                            .OrderBy(x => x)
                             .ToList();
             }
             return dbResult;

MP.SPEC/Components/DossiersFilter.razor

@@ -37,7 +37,22 @@
                     }
                 </select>
             </div>
-            <div class="input-group p-2">
+
+            <div class="small mt-2">
+                <label class="px-2" for="dtMin" title="Selezionare inizio periodo">Inizio Periodo</label>
+            </div>
+            <div class="px-2 input-group">
+                <label class="input-group-text" for="dtMin" title="Selezionare inizio periodo"><i class="fa-regular fa-calendar-minus"></i></label>
+                <input class="form-control" @bind="@selDtMin" id="dtMin" type="datetime-local" title="Data minima eventi da visualizzare">
+            </div>
+            <div class="small mt-2">
+                <label class="px-2" for="dtMax" title="Selezionare fine periodo">Fine Periodo</label>
+            </div>
+            <div class="px-2 input-group">
+                <label class="input-group-text" for="dtMax" title="Selezionare fine periodo"><i class="fa-regular fa-calendar-plus"></i></label>
+                <input class="form-control" @bind="@selDtMax" id="dtMax" type="datetime-local" title="Selezionare fine periodo">
+            </div>
+            @*<div class="input-group p-2">
                 <label class="input-group-text" for="DtMin" title="Selezionare la data da visualizzare"><i class="fa-solid fa-calendar-check"></i></label>
                 <input @bind="@selDtRef" id="DtMin" class="form-control" type="datetime-local" title="Selezionare la data minima da visualizzare" />
             </div>
@@ -49,7 +64,7 @@
                     <option value="250">250</option>
                     <option value="500">500</option>
                 </select>
-            </div>
+            </div>*@
         </div>
     </div>
 </div>

MP.SPEC/Components/DossiersFilter.razor.cs

@@ -39,18 +39,35 @@ namespace MP.SPEC.Components
             }
         }
 
-        protected DateTime selDtRef
+        protected DateTime selDtMax
         {
             get
             {
-                return SelFilterDossier.DtRef;
+                return SelFilterDossier.DtEnd;
             }
 
             set
             {
-                if (!SelFilterDossier.DtRef.Equals(value))
+                if (!SelFilterDossier.DtEnd.Equals(value))
                 {
-                    SelFilterDossier.DtRef = value;
+                    SelFilterDossier.DtEnd = value;
+                    reportChange();
+                }
+            }
+        }
+
+        protected DateTime selDtMin
+        {
+            get
+            {
+                return SelFilterDossier.DtStart;
+            }
+
+            set
+            {
+                if (!SelFilterDossier.DtStart.Equals(value))
+                {
+                    SelFilterDossier.DtStart = value;
                     reportChange();
                 }
             }
@@ -101,7 +118,9 @@ namespace MP.SPEC.Components
         protected override async Task OnInitializedAsync()
         {
             SelFilterDossier = new SelectDossierParams();
-            ListMacchine = await MDService.MacchineWithFlux();
+            DateTime dtEnd = SelFilterDossier.DtEnd;
+            DateTime dtStart = dtEnd.Subtract(SelFilterDossier.DtStart).TotalDays < 15 ? SelFilterDossier.DtStart : dtEnd.AddDays(-14);
+            ListMacchine = await MDService.MacchineWithFlux(dtStart, dtEnd);
             ListArticoli = await MDService.ArticleWithDossier();
             await FilterChanged.InvokeAsync(SelFilterDossier);
         }

MP.SPEC/Components/ListDossiers.razor

@@ -17,7 +17,7 @@ else
                 <thead>
                     <tr>
                         <th>
-                            <button @onclick="() => unToggleTableFlux()" class="btn btn-primary btn-sm"><i class="bi bi-arrow-counterclockwise"></i></button>
+                            <button @onclick="() => closeTableFlux()" class="btn btn-primary btn-sm"><i class="bi bi-arrow-counterclockwise"></i></button>
                         </th>
                         <th><i class="fa-solid fa-file"></i> Articolo</th>
                         <th><i class="fa-solid fa-screwdriver-wrench"></i> Fase</th>
@@ -75,15 +75,15 @@ else
                         <table class="table table-light table-sm table-striped small mb-0">
                             <thead>
                                 <tr>
-                                    <th></th>
+                                    <th>
+                                        <button class="btn btn-info" @onclick="() => closeTableFlux()"><i class="fa-solid fa-xmark"></i></button>
+                                    </th>
                                     <th><i class="fa-solid fa-hard-drive"></i> Macchina</th>
                                     <th><i class="fa-regular fa-calendar-days"></i> Data</th>
                                     <th><i class="fa-solid fa-sliders"></i> Data Type</th>
                                     <th>
                                         <div class="d-flex justify-content-between col-12">
                                             <span class="col-11" style="text-align: right;"> Valore </span>
-                                            <button class="btn btn-primary btn-sm py-0" @onclick="() => unToggleTableFlux()"><i class="fa-solid fa-xmark"></i></button>
-
                                         </div>
                                     </th>
                                 </tr>
@@ -91,7 +91,7 @@ else
                             <tbody>
                                 @foreach (var record in listaFlux)
                                 {
-                                    <tr>
+                                    <tr class="@checkSelPar(@record)">
                                         <td>
                                             <button @onclick="() => editRecord(record)" class="btn btn-primary btn-sm" title="Modifica Record"><i class="bi bi-pencil-square"></i></button>
                                         </td>
@@ -105,8 +105,15 @@ else
                                             @record.CodFlux
                                         </td>
                                         <td style="text-align: right;">
-                                            <div><span class="small text-dark">Modificato:  </span><b>@record.ValoreEdit</b></div>
-                                            <div class="small text-secondary"><span class="small text-dark">Originale:  </span><i>@record.Valore</i></div>
+                                            @if (record.ValoreEdit != record.Valore)
+                                            {
+                                                <div title="Valore Modificato"><span class="small text-dark"></span><b>@record.ValoreEdit</b></div>
+                                                <div class="small text-secondary" title="Valore Registrato">(<i>@record.Valore</i>)</div>
+                                            }
+                                            else
+                                            {
+                                                <div><span class="small text-dark"></span>@record.ValoreEdit</div>
+                                            }
                                         </td>
                                     </tr>
                                 }

MP.SPEC/Components/ListDossiers.razor.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.Components;
+using Microsoft.AspNetCore.DataProtection;
 using Microsoft.JSInterop;
 using MP.Data.DatabaseModels;
 using MP.Data.DTO;
@@ -6,7 +7,7 @@ using MP.SPEC.Data;
 
 namespace MP.SPEC.Components
 {
-    public partial class ListDossiers: IDisposable
+    public partial class ListDossiers : IDisposable
     {
         #region Public Properties
 
@@ -26,6 +27,24 @@ namespace MP.SPEC.Components
 
         #region Public Methods
 
+        private FluxLogDTO? currFluxLogDto = null;
+
+
+        public string checkSelPar(FluxLogDTO recordSel)
+        {
+            string answ = "";
+            if (currFluxLogDto != null)
+            {
+                try
+                {
+                    answ = (currFluxLogDto.CodFlux == recordSel.CodFlux && currFluxLogDto.dtEvento== recordSel.dtEvento) ? "table-info" : "";
+                }
+                catch
+                { }
+            }
+            return answ;
+        }
+
         public string checkSelect(Dossiers recordSel)
         {
             string answ = "";
@@ -87,6 +106,7 @@ namespace MP.SPEC.Components
 
         protected async Task editRecord(FluxLogDTO selRec)
         {
+            currFluxLogDto = selRec;
             // indico record selezionato
             await RecordSelFlux.InvokeAsync(selRec);
         }
@@ -166,9 +186,13 @@ namespace MP.SPEC.Components
             get => SelFilter.CodArticolo;
         }
 
-        private DateTime SelDtRef
+        private DateTime SelDtEnd
         {
-            get => SelFilter.DtRef;
+            get => SelFilter.DtEnd;
+        }
+        private DateTime SelDtStart
+        {
+            get => SelFilter.DtStart;
         }
 
         private string SelMacchina
@@ -203,7 +227,7 @@ namespace MP.SPEC.Components
         private async Task reloadData(bool setChanged)
         {
             isLoading = true;
-            SearchRecords = await MDService.DossiersGetLastFilt(SelMacchina, SelArticolo, SelDtRef, MaxRecord);
+            SearchRecords = await MDService.DossiersGetLastFilt(SelMacchina, SelArticolo, SelDtStart, SelDtEnd);
             totalCount = SearchRecords.Count;
             ListRecords = SearchRecords.Skip(numRecord * (currPage - 1)).Take(numRecord).ToList();
             await Task.Delay(1);
@@ -234,10 +258,12 @@ namespace MP.SPEC.Components
             return answ;
         }
 
-        private async Task unToggleTableFlux()
+        private async Task closeTableFlux()
         {
+            currFluxLogDto = null;
             currRecord = null;
             visualizzaFlux = true;
+            await RecordSelFlux.InvokeAsync(currFluxLogDto);
             await Task.Delay(1);
         }
 

MP.SPEC/Components/ListODL.razor.cs

@@ -3,6 +3,7 @@ using Microsoft.JSInterop;
 using MP.Data.DatabaseModels;
 using MP.SPEC.Data;
 using MP.SPEC.Services;
+using NLog;
 
 namespace MP.SPEC.Components
 {
@@ -84,6 +85,7 @@ namespace MP.SPEC.Components
             {
                 // effettua chiusura sul DB
                 await MDService.ODLClose(currRecord.IdxOdl, currRecord.IdxMacchina, 0, true);
+                Log.Info($"Effettuata chiusura ODL {currRecord.IdxOdl}");
                 // ricarica...
                 await selectRecord(null);
             }
@@ -112,6 +114,7 @@ namespace MP.SPEC.Components
             if (currRecord != null)
             {
                 await callSyncDb(currRecord.IdxMacchina);
+                Log.Info($"Richiesto forceSyncDb per idxMacc {currRecord.IdxMacchina}");
                 // ricarica...
                 await selectRecord(null);
             }
@@ -197,6 +200,7 @@ namespace MP.SPEC.Components
 
         #region Private Fields
 
+        private static Logger Log = LogManager.GetCurrentClassLogger();
         private ODLModel? currRecord = null;
 
         private List<StatODLModel>? ListOdlStats;
@@ -273,6 +277,7 @@ namespace MP.SPEC.Components
             }
             catch (Exception exc)
             {
+                Log.Error($"Errore durante chiamata: {Environment.NewLine}{exc}");
             }
         }
 

MP.SPEC/Components/ListPODL.razor.cs

@@ -3,6 +3,7 @@ using Microsoft.JSInterop;
 using MP.Data.DatabaseModels;
 using MP.SPEC.Data;
 using MP.SPEC.Services;
+using NLog;
 
 namespace MP.SPEC.Components
 {
@@ -13,8 +14,6 @@ namespace MP.SPEC.Components
         [Parameter]
         public SelectPOdlParams actFilter { get; set; } = new SelectPOdlParams();
 
-        private SelectPOdlParams lastFilter { get; set; } = new SelectPOdlParams() { CurrPage = -1 };
-
         [Parameter]
         public EventCallback<bool> PagerResetReq { get; set; }
 
@@ -43,8 +42,6 @@ namespace MP.SPEC.Components
             return answ;
         }
 
-        #endregion Public Methods
-
         public void Dispose()
         {
             currRecord = null;
@@ -54,6 +51,8 @@ namespace MP.SPEC.Components
             GC.Collect();
         }
 
+        #endregion Public Methods
+
         #region Protected Properties
 
         [Inject]
@@ -211,12 +210,21 @@ namespace MP.SPEC.Components
 
         #region Private Fields
 
+        private static Logger Log = LogManager.GetCurrentClassLogger();
         private PODLModel? currRecord = null;
-
         private List<PODLModel>? ListRecords;
-
         private List<ListValues>? ListStati;
 
+        /// <summary>
+        /// scadenza validità lista ODL correnti
+        /// </summary>
+        private DateTime odlCurrExp = DateTime.Now.AddMinutes(-1);
+
+        /// <summary>
+        /// Elenco ODL correnti...
+        /// </summary>
+        private List<string> odlCurrList = new List<string>();
+
         private List<PODLModel>? SearchRecords;
 
         #endregion Private Fields
@@ -232,6 +240,7 @@ namespace MP.SPEC.Components
         }
 
         private bool isLoading { get; set; } = false;
+        private SelectPOdlParams lastFilter { get; set; } = new SelectPOdlParams() { CurrPage = -1 };
 
         private int numRecord
         {
@@ -282,6 +291,7 @@ namespace MP.SPEC.Components
             }
             catch (Exception exc)
             {
+                Log.Error($"Errore durante chiamata: {Environment.NewLine}{exc}");
             }
         }
 
@@ -325,8 +335,15 @@ namespace MP.SPEC.Components
         /// <returns></returns>
         private bool canStartOdl(string idxMacchina)
         {
-            var listOdlCurr = MDService.OdlGetCurrent();
-            bool answ = !listOdlCurr.Contains(idxMacchina);
+            // controllo se lista scaduta...
+            bool answ = false;
+            DateTime adesso = DateTime.Now;
+            if (adesso > odlCurrExp || odlCurrList == null || odlCurrList.Count == 0)
+            {
+                odlCurrList = MDService.OdlGetCurrent();
+                odlCurrExp = adesso.AddSeconds(2);
+            }
+            answ = !odlCurrList.Contains(idxMacchina);
             return answ;
         }
 

MP.SPEC/Components/ParamsFilter.razor

@@ -1,7 +1,6 @@
 <div class="d-flex justify-content-between">
     <div class="d-flex justify-content-between pt-1 mb-1">
         <div class="px-2">
-
             @if (!liveUpdate)
             {
                 <button class="btn btn-secondary" type="button" @onclick="() => toggleUpdate()" title="Click per tornare a Valori Live">

MP.SPEC/Components/ParamsFilter.razor.cs

@@ -168,7 +168,10 @@ namespace MP.SPEC.Components
         protected override async Task OnInitializedAsync()
         {
             SelFilter = new SelectFluxParams();
-            ListMacchine = await MDService.MacchineWithFlux();
+            setDtMax();
+            DateTime dtStart = SelFilter.dtMin != null ? (DateTime)SelFilter.dtMin : DateTime.Now.AddDays(-7);
+            DateTime dtEnd = SelFilter.dtMax != null ? (DateTime)SelFilter.dtMax : DateTime.Now;
+            ListMacchine = await MDService.MacchineWithFlux(dtStart, dtEnd);
             ListFlux = await MDService.ParametriGetFilt(selMacchina);
 
             var configData = await MDService.ConfigGetAll();
@@ -186,7 +189,7 @@ namespace MP.SPEC.Components
             // copio il filtro
             var currFilt = SelFilter;
             // fermo update
-            //currFilt.LiveUpdate = false;
+            currFilt.LiveUpdate = true;
             currFilt.CurrPage = 0;
             currFilt.lastUpdate = $"{DateTime.Now:yyyy/MM/dd HH:mm:ss}";
             currFilt.dtMax = RoundDatetime(5);
@@ -210,9 +213,8 @@ namespace MP.SPEC.Components
             // se non ho data rif uso adesso...
             DateTime dtMax = selDtMax == null ? RoundDatetime(5) : (DateTime)selDtMax;
             DateTime dtMin = selDtMin == null ? RoundDatetime(5).AddHours(-numOreAnticipoSnapshot) : (DateTime)selDtMin;
-            // aggiungo 2 sec
+            // aggiungo 15 sec
             dtMax = dtMax.AddSeconds(15);
-            //dtMin = dtMin.AddMinutes(-30);
             await MDService.DossiersTakeParamsSnapshotLast(selMacchina, dtMin, dtMax);
             lastUpdate = $"{DateTime.Now:yyyy/MM/dd HH:mm:ss}";
             // indico snapshot fatto
@@ -267,7 +269,7 @@ namespace MP.SPEC.Components
                     // copio il filtro
                     var currFilt = SelFilter;
                     // fermo update
-                    currFilt.LiveUpdate = false;
+                    currFilt.LiveUpdate = (value == null);
                     currFilt.CurrPage = 0;
                     currFilt.lastUpdate = $"{DateTime.Now:yyyy/MM/dd HH:mm:ss}";
                     currFilt.dtMax = value;

MP.SPEC/Data/MpDataService.cs

@@ -82,7 +82,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.AnagStatiComm());
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 await redisDb.StringSetAsync(redisStatoCom, rawData, getRandTOut(redisLongTimeCache));
                 stopWatch.Stop();
@@ -113,7 +113,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.AnagTipoArtLV());
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 await redisDb.StringSetAsync(redisTipoArt, rawData, getRandTOut(redisLongTimeCache));
                 stopWatch.Stop();
@@ -148,7 +148,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.ArticleWithDossier());
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache));
             }
@@ -277,7 +277,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.ConfigGetAll());
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 await redisDb.StringSetAsync(redisConfKey, rawData, getRandTOut(redisLongTimeCache));
                 stopWatch.Stop();
@@ -341,16 +341,16 @@ namespace MP.SPEC.Data
         /// macchina (ordinato x data registrazione)
         /// </summary>
         /// <param name="IdxMacchina">* = tutte, altrimenti solo x una data macchina</param>
-        /// <param name="DtRef">Data di riferimento (Massima) per estrazione records</param>
-        /// <param name="MaxRec">numero massimo record da restituire</param>
+        /// <param name="DtStart">Data minima per estrazione records</param>
+        /// <param name="DtEnd">Data Massima per estrazione records</param>
         /// <returns></returns>
-        public async Task<List<Dossiers>> DossiersGetLastFilt(string IdxMacchina, string CodArticolo, DateTime DtRef, int MaxRec)
+        public async Task<List<Dossiers>> DossiersGetLastFilt(string IdxMacchina, string CodArticolo, DateTime DtStart, DateTime DtEnd)
         {
             List<Dossiers>? result = new List<Dossiers>();
             Stopwatch stopWatch = new Stopwatch();
             stopWatch.Start();
             string readType = "DB";
-            string currKey = $"{redisDossByMac}:{IdxMacchina}:{CodArticolo}:{DtRef}:{MaxRec}";
+            string currKey = $"{redisDossByMac}:{IdxMacchina}:{CodArticolo}:{DtStart:yyyyMMddHHmm}:{DtEnd:yyyyMMddHHmm}";
             // cerco in redis dato valore sel macchina...
             RedisValue rawData = redisDb.StringGet(currKey);
             if (rawData.HasValue)
@@ -360,8 +360,8 @@ namespace MP.SPEC.Data
             }
             else
             {
-                result = await Task.FromResult(dbController.DossiersGetLastFilt(IdxMacchina, CodArticolo, DtRef, MaxRec));
-                // serializzp e salvo...
+                result = await Task.FromResult(dbController.DossiersGetLastFilt(IdxMacchina, CodArticolo, DtStart, DtEnd));
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache / 5));
             }
@@ -468,13 +468,33 @@ namespace MP.SPEC.Data
         /// <returns></returns>
         public async Task<List<FluxLog>> FluxLogGetLastFilt(DateTime DtMax, string IdxMacchina, string CodFlux, int MaxRec)
         {
+            List<FluxLog>? result = new List<FluxLog>();
             Stopwatch stopWatch = new Stopwatch();
             stopWatch.Start();
-            var results = await Task.FromResult(dbController.FluxLogGetLastFilt(DtMax, IdxMacchina, CodFlux, MaxRec));
+            string readType = "DB";
+            string currKey = $"{redisFluxLogFilt}:{IdxMacchina}:{CodFlux}:{MaxRec}:{DtMax:yyyyMMdd}:{DtMax:HHmm}";
+            // cerco in redis dato valore sel macchina...
+            RedisValue rawData = redisDb.StringGet(currKey);
+            if (rawData.HasValue)
+            {
+                result = JsonConvert.DeserializeObject<List<FluxLog>>($"{rawData}");
+                readType = "REDIS";
+            }
+            else
+            {
+                result = await Task.FromResult(dbController.FluxLogGetLastFilt(DtMax, IdxMacchina, CodFlux, MaxRec));
+                // serializzo e salvo...
+                rawData = JsonConvert.SerializeObject(result);
+                redisDb.StringSet(currKey, rawData, TimeSpan.FromSeconds(10));
+            }
+            if (result == null)
+            {
+                result = new List<FluxLog>();
+            }
             stopWatch.Stop();
             TimeSpan ts = stopWatch.Elapsed;
-            Log.Debug($"FluxLogGetLastFilt | Read from DB: {ts.TotalMilliseconds}ms");
-            return results;
+            Log.Debug($"FluxLogGetLastFilt | Read from {readType}: {ts.TotalMilliseconds}ms");
+            return result;
         }
 
         /// <summary>
@@ -546,7 +566,35 @@ namespace MP.SPEC.Data
         /// <returns></returns>
         public async Task<List<PODLModel>> ListPODLFilt(string codArt, string keyRichPart)
         {
-            return await Task.FromResult(dbController.ListPODLFilt(codArt, keyRichPart));
+            List<PODLModel>? result = new List<PODLModel>();
+            Stopwatch stopWatch = new Stopwatch();
+            stopWatch.Start();
+            string readType = "DB";
+            string currKey = $"{redisPOdlList}:{codArt}:{keyRichPart}";
+            // cerco in redis dato valore sel macchina...
+            RedisValue rawData = redisDb.StringGet(currKey);
+            if (rawData.HasValue)
+            {
+                result = JsonConvert.DeserializeObject<List<PODLModel>>($"{rawData}");
+                readType = "REDIS";
+            }
+            else
+            {
+                result = await Task.FromResult(dbController.ListPODLFilt(codArt, keyRichPart));
+                // serializzo e salvo...
+                rawData = JsonConvert.SerializeObject(result);
+                redisDb.StringSet(currKey, rawData, TimeSpan.FromSeconds(3));
+            }
+            if (result == null)
+            {
+                result = new List<PODLModel>();
+            }
+            stopWatch.Stop();
+            TimeSpan ts = stopWatch.Elapsed;
+            Log.Debug($"ListPODLFilt | Read from {readType}: {ts.TotalMilliseconds}ms");
+            return result;
+
+
         }
 
         /// <summary>
@@ -570,7 +618,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.MacchineGetAll());
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache));
             }
@@ -585,16 +633,18 @@ namespace MP.SPEC.Data
         }
 
         /// <summary>
-        /// Elenco ID macchine con dati FluxLog gestite
+        /// Elenco id Macchine che abbiano dati FLuxLog, nel periodo indicato
         /// </summary>
+        /// <param name="dtStart"></param>
+        /// <param name="dtEnd"></param>
         /// <returns></returns>
-        public async Task<List<string>> MacchineWithFlux()
+        public async Task<List<string>> MacchineWithFlux(DateTime dtStart, DateTime dtEnd)
         {
             List<string>? result = new List<string>();
             Stopwatch stopWatch = new Stopwatch();
             stopWatch.Start();
             string readType = "DB";
-            string currKey = redisMacByFlux;
+            string currKey = $"{redisMacByFlux}:{dtStart:yyyyMMddHHmm}:{dtEnd:yyyyMMddHHmm}";
             // cerco in redis dato valore sel macchina...
             RedisValue rawData = redisDb.StringGet(currKey);
             if (rawData.HasValue)
@@ -604,8 +654,8 @@ namespace MP.SPEC.Data
             }
             else
             {
-                result = await dbController.MacchineWithFlux();
-                // serializzp e salvo...
+                result = await dbController.MacchineWithFlux(dtStart, dtEnd);
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache));
             }
@@ -728,7 +778,7 @@ namespace MP.SPEC.Data
             else
             {
                 result = await Task.FromResult(dbController.ParametriGetFilt(IdxMacchina));
-                // serializzp e salvo...
+                // serializzo e salvo...
                 rawData = JsonConvert.SerializeObject(result);
                 redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache));
             }
@@ -779,7 +829,12 @@ namespace MP.SPEC.Data
         /// <returns></returns>
         public async Task<bool> POdlUpdateRecord(PODLModel currRec)
         {
-            return await dbController.PODLUpdateRecord(currRec);
+            var dbResult = await dbController.PODLUpdateRecord(currRec);
+            // elimino cache redis...
+            RedisValue pattern = new RedisValue($"{redisPOdlList}:*");
+            bool answ = await ExecFlushRedisPattern(pattern);
+
+            return dbResult;
         }
 
         /// <summary>
@@ -868,6 +923,8 @@ namespace MP.SPEC.Data
 
         private const string redisMacByFlux = redisBaseAddr + "SPEC:Cache:MacByFlux";
         private const string redisMacList = redisBaseAddr + "SPEC:Cache:MacList";
+        private const string redisPOdlList = redisBaseAddr + "SPEC:Cache:POdlList";
+        private const string redisFluxLogFilt = redisBaseAddr + "SPEC:Cache:FluxLogFilt";
 
         private const string redisStatoCom = redisBaseAddr + "SPEC:Cache:StatoCom";
 

MP.SPEC/Data/SelectDossierParams.cs

@@ -13,7 +13,9 @@
 
         public int CurrPage { get; set; } = 1;
 
-        public DateTime DtRef { get; set; } = InitDatetime(5);
+        public DateTime DtEnd { get; set; } = InitDatetime(5);
+
+        public DateTime DtStart { get; set; } = InitDatetime(5).AddDays(-730);
 
         public string IdxMacchina { get; set; } = "*";
 
@@ -52,14 +54,12 @@
             if (MaxRecord != item.MaxRecord)
                 return false;
 
-            if (DtRef != item.DtRef)
+            if (DtEnd != item.DtEnd)
                 return false;
 
             if (CurrPage != item.CurrPage)
                 return false;
 
-            //if (lastUpdate != item.lastUpdate)
-            //    return false;
 
             return true;
         }

MP.SPEC/MP.SPEC.csproj

@@ -5,7 +5,7 @@
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
     <RootNamespace>MP.SPEC</RootNamespace>
-    <Version>6.16.2210.1817</Version>
+    <Version>6.16.2210.1910</Version>
   </PropertyGroup>
 
   <ItemGroup>

MP.SPEC/Pages/DOSS.razor

@@ -38,7 +38,7 @@
                                 <div class="col-3 pe-0">
                                     <div class="input-group input-group-sm">
                                         <span class="input-group-text" id="inputGroup-sizing-sm">DATA</span>
-                                        <input type="text" class="form-control" disabled aria-label="Art search" aria-describedby="inputGroup-sizing-sm"  @bind-value="@currDetFluxLogRecord.dtEvento">
+                                        <input type="text" class="form-control" disabled aria-label="Art search" aria-describedby="inputGroup-sizing-sm" @bind-value="@currDetFluxLogRecord.dtEvento">
                                     </div>
                                 </div>
                                 <div class="col-3 pe-0">
@@ -75,18 +75,16 @@
                 </div>
             </div>
         }
+        @if (isLoading)
+        {
+            <LoadingData></LoadingData>
+        }
+        else
+        {
+            <ListDossiers SelFilter="@currFilter" RecordSel="@selRecordDoss" RecordSelFlux="@selRecordFlux" TotRecordChanged="updateTotal"></ListDossiers>
+        }
+    </div>
+    <div class="card-footer py-1">
+        <DataPager @ref="pagerODL" PageSize="numRecord" currPage="currPage" numRecordChanged="ForceReload" numPageChanged="ForceReloadPage" totalCount="totalCount" showLoading="isLoading" />
     </div>
-    @if (isLoading)
-    {
-        <LoadingData></LoadingData>
-    }
-    else
-    {
-        <ListDossiers SelFilter="@currFilter" RecordSel="@selRecordDoss" RecordSelFlux="@selRecordFlux" TotRecordChanged="updateTotal"></ListDossiers>
-    }
 </div>
-<div class="card-footer py-1">
-    <DataPager @ref="pagerODL" PageSize="numRecord" currPage="currPage" numRecordChanged="ForceReload" numPageChanged="ForceReloadPage" totalCount="totalCount" showLoading="isLoading" />
-</div>
-
-

MP.SPEC/Pages/ODL.razor.cs

@@ -85,7 +85,7 @@ namespace MP.SPEC.Pages
         protected override async Task OnInitializedAsync()
         {
             ListStati = await MDService.AnagStatiComm();
-            ListMacchine = await MDService.MacchineWithFlux();
+            ListMacchine = await MDService.MacchineWithFlux(currFilter.DtStart, currFilter.DtEnd);
         }
 
         protected async Task pgResetReq(bool doReset)

MP.SPEC/Pages/PARAMS.razor

@@ -32,5 +32,3 @@
         <DataPager @ref="pagerODL" PageSize="numRecord" currPage="currPage" numRecordChanged="ForceReload" numPageChanged="ForceReloadPage" totalCount="totalCount" showLoading="isLoading" />
     </div>
 </div>
-
-

MP.SPEC/Pages/PARAMS.razor.cs

@@ -128,7 +128,7 @@ namespace MP.SPEC.Pages
             if (newParams.CurrPage == 0)
             {
                 newParams.CurrPage = 1;
-                newParams.LiveUpdate = false;
+                //newParams.LiveUpdate = false;
             }
             else
             {

MP.SPEC/Pages/PODL.razor.cs

@@ -4,6 +4,7 @@ using MP.Data.DatabaseModels;
 using MP.SPEC.Components;
 using MP.SPEC.Data;
 using MP.SPEC.Services;
+using NLog;
 
 namespace MP.SPEC.Pages
 {
@@ -150,6 +151,9 @@ namespace MP.SPEC.Pages
             await callSyncDb(selRec);
             currRecord = null;
             await reloadData();
+            // forzo update parametri
+            await Task.Delay(1);
+            currFase = "*";
             await Task.Delay(1);
         }
 
@@ -162,6 +166,7 @@ namespace MP.SPEC.Pages
 
         #region Private Fields
 
+        private static Logger Log = LogManager.GetCurrentClassLogger();
         private PODLModel? _currRecord = null;
         private List<AnagArticoli>? ListArticoli;
         private List<AnagGruppi>? ListAziende;
@@ -223,6 +228,19 @@ namespace MP.SPEC.Pages
             }
         }
 
+        private string currFase
+        {
+            get => currFilter.CodFase;
+            set
+            {
+                if (!currFilter.CodFase.Equals(value))
+                {
+                    currFilter.CodFase = value;
+                    currPage = 1;
+                }
+            }
+        }
+
         private SelectPOdlParams currFilter { get; set; } = new SelectPOdlParams();
 
         private int currPage
@@ -249,19 +267,6 @@ namespace MP.SPEC.Pages
             set => currFilter.NumRec = value;
         }
 
-        private string currFase
-        {
-            get => currFilter.CodFase;
-            set
-            {
-                if (!currFilter.CodFase.Equals(value))
-                {
-                    currFilter.CodFase = value;
-                    currPage = 1;
-                }
-            }
-        }
-
         private int totalCount
         {
             get => currFilter.TotCount;
@@ -282,7 +287,14 @@ namespace MP.SPEC.Pages
             // chiamo aggiunta task SyncDb...
             string idxMacc = selRec.IdxMacchina;
             string restUrl = $"IOB/addTask2Exe/{idxMacc}?taskName=syncDbData&taskVal=";
-            var response = await MpIoApiCall.callMpIoUrlGet(restUrl);
+            try
+            {
+                var response = await MpIoApiCall.callMpIoUrlGet(restUrl);
+            }
+            catch (Exception exc)
+            {
+                Log.Error($"Errore durante chiamata: {Environment.NewLine}{exc}");
+            }
         }
 
         private async Task reloadData()

MP.SPEC/Resources/ChangeLog.html

@@ -1,6 +1,6 @@
 <body>
     <i>Modulo MAPOSPEC </i>
-    <h4>Versione: 6.16.2210.1817</h4>
+    <h4>Versione: 6.16.2210.1910</h4>
     <br /> Note di rilascio:
     <ul>
         <li>

MP.SPEC/Resources/VersNum.txt

@@ -1 +1 @@
-6.16.2210.1817
+6.16.2210.1910

MP.SPEC/Resources/manifest.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <item>
-  <version>6.16.2210.1817</version>
+  <version>6.16.2210.1910</version>
   <url>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/MP.SPEC.zip</url>
   <changelog>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/ChangeLog.html</changelog>
   <mandatory>false</mandatory>

MP.SPEC/Services/IOApiService.cs

@@ -1,5 +1,6 @@
 using Microsoft.Extensions.Configuration;
 using MP.SPEC.Data;
+using NLog;
 using System.Text.Json;
 
 namespace MP.SPEC.Services
@@ -18,6 +19,9 @@ namespace MP.SPEC.Services
         private static IConfiguration _configuration = null!;
 
 
+
+        private static Logger Log = LogManager.GetCurrentClassLogger();
+
         private static string MpIoBaseUrl = "";
 
         public IOApiService(IHttpClientFactory clientFactory, IConfiguration configuration, ILogger<MpDataService> logger)
@@ -40,15 +44,18 @@ namespace MP.SPEC.Services
             var request = new HttpRequestMessage(HttpMethod.Get, $"{MpIoBaseUrl}{relUrl}");
             request.Headers.Add("Accept", "application/vnd.github.v3+json");
             var client = _clientFactory.CreateClient();
+            Log.Info($"Richiesta call per {MpIoBaseUrl}{relUrl}");
             var response = await client.SendAsync(request);
             if (response.IsSuccessStatusCode)
             {
                 var stringResponse = await response.Content.ReadAsStringAsync();
                 result = stringResponse;
+                Log.Info($"Richiesta call per {MpIoBaseUrl}{relUrl}");
             }
             else
             {
                 result = "NO";
+                Log.Error($"Errore in chaimata | code {response.StatusCode} | {response.Content}");
             }
             return result;
         }

MP.SPEC/appsettings.Development.json

@@ -5,5 +5,11 @@
       "Default": "Information",
       "Microsoft.AspNetCore": "Warning"
     }
+  },
+  "ServerConf": {
+    "maxAge": "2000",
+    "cacheCheckArtUsato": 2,
+    "redisLongTimeCache": 15,
+    "MpIoBaseUrl": "https://iis01.egalware.com/MP/IO/"
   }
 }

MP.SPEC/appsettings.Staging.json

@@ -0,0 +1,15 @@
+{
+  "DetailedErrors": true,
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "ServerConf": {
+    "maxAge": "2000",
+    "cacheCheckArtUsato": 2,
+    "redisLongTimeCache": 15,
+    "MpIoBaseUrl": "http://localhost/MP/IO/"
+  }
+}