From b51c2679e44d0158c59e8f64fcd1be33b2c9b270 Mon Sep 17 00:00:00 2001 From: "zaccaria.majid" Date: Wed, 21 Sep 2022 09:17:28 +0200 Subject: [PATCH] aggiunta cache redis --- MP.SPEC/Data/MpDataService.cs | 12 +++++------- MP.SPEC/Data/SelectDossierParams.cs | 4 ++-- 2 files changed, 7 insertions(+), 9 deletions(-) diff --git a/MP.SPEC/Data/MpDataService.cs b/MP.SPEC/Data/MpDataService.cs index 7c1ba04f..3bdc25be 100644 --- a/MP.SPEC/Data/MpDataService.cs +++ b/MP.SPEC/Data/MpDataService.cs @@ -291,8 +291,7 @@ namespace MP.SPEC.Data /// public async Task> DossiersGetLastFilt(string IdxMacchina, DateTime DtRef, int MaxRec) { -#if false - List? result = new List(); + List? result = new List(); Stopwatch stopWatch = new Stopwatch(); stopWatch.Start(); string readType = "DB"; @@ -301,27 +300,26 @@ namespace MP.SPEC.Data RedisValue rawData = redisDb.StringGet(currKey); if (rawData.HasValue) { - result = JsonConvert.DeserializeObject>($"{rawData}"); + result = JsonConvert.DeserializeObject>($"{rawData}"); readType = "REDIS"; } else { - result = await Task.FromResult(dbController.ParametriGetFilt(IdxMacchina)); + result = await Task.FromResult(dbController.DossiersGetLastFilt(IdxMacchina, DtRef, MaxRec)); // serializzp e salvo... rawData = JsonConvert.SerializeObject(result); redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache)); } if (result == null) { - result = new List(); + result = new List(); } stopWatch.Stop(); TimeSpan ts = stopWatch.Elapsed; Log.Debug($"ParametriGetFilt | Read from {readType}: {ts.TotalMilliseconds}ms"); return result; -#endif - return await Task.FromResult(dbController.DossiersGetLastFilt(IdxMacchina, DtRef, MaxRec)); + //return await Task.FromResult(dbController.DossiersGetLastFilt(IdxMacchina, DtRef, MaxRec)); } public List convertToFluxLog(string Valore) { diff --git a/MP.SPEC/Data/SelectDossierParams.cs b/MP.SPEC/Data/SelectDossierParams.cs index 09a3630f..01ba368b 100644 --- a/MP.SPEC/Data/SelectDossierParams.cs +++ b/MP.SPEC/Data/SelectDossierParams.cs @@ -17,7 +17,7 @@         ///         ///         /// -        public static DateTime Init(int minRound, int numDayPrev) +        public static DateTime Init(int minRound) { TimeSpan DayElapsed = DateTime.Now.Subtract(DateTime.Today); int minDay = (int)(DayElapsed.TotalMinutes / minRound) * minRound; @@ -28,7 +28,7 @@ public string IdxMacchina { get; set; } = "*"; public int MaxRecord { get; set; } = 100; - public DateTime DtRef { get; set; } = Init(5, 1); + public DateTime DtRef { get; set; } = Init(3); public int CurrPage { get; set; } = 1; #endregion Public Properties