TAB:

- aggiunta gest tab gruppi2operatore - metodi estrazione macchine x operatori - test filtro TCiclo
2023-09-27 19:18:57 +02:00
parent f5f8a73ecb
commit 010207d331
8 changed files with 271 additions and 36 deletions
@@ -0,0 +1,204 @@
+using Microsoft.Extensions.Configuration;
+using MP.Data.Conf;
+using MP.Data.DatabaseModels;
+using Newtonsoft.Json;
+using NLog;
+using StackExchange.Redis;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MP.Data.Services
+{
+    /// <summary>
+    /// Classe accesso dati filtrati per operatore
+    /// </summary>
+    public class OprFiltData : BaseServ, IDisposable
+    {
+        #region Public Constructors
+
+        public OprFiltData(IConfiguration configuration)
+        {
+            _configuration = configuration;
+
+            // setup compoenti REDIS
+            redisConn = ConnectionMultiplexer.Connect(_configuration.GetConnectionString("Redis"));
+            redisDb = redisConn.GetDatabase();
+
+            // conf DB
+            string connStr = _configuration.GetConnectionString("Mp.All");
+            if (string.IsNullOrEmpty(connStr))
+            {
+                Log.Error("ConnString empty!");
+            }
+            else
+            {
+                dbController = new Controllers.MpSpecController(configuration);
+                StringBuilder sb = new StringBuilder();
+                sb.AppendLine($"MenuData | MpSpecController OK");
+                Log.Info(sb.ToString());
+            }
+        }
+
+        #endregion Public Constructors
+
+        #region Public Properties
+
+        public static Controllers.MpSpecController dbController { get; set; } = null!;
+
+        #endregion Public Properties
+
+        #region Public Methods
+
+        public Task<List<ConfigModel>> ConfigGetAll()
+        {
+            return Task.FromResult(dbController.ConfigGetAll().ToList());
+        }
+
+        public void Dispose()
+        {
+            // Clear database controller
+            dbController.Dispose();
+        }
+
+        /// <summary>
+        /// Elenco link JQM dato filtro tipo
+        /// </summary>
+        /// <param name="tipoLink"></param>
+        /// <returns></returns>
+        public async Task<List<LinkMenu>> ListLinkFilt(string tipoLink)
+        {
+            string source = "DB";
+            Stopwatch sw = new Stopwatch();
+            sw.Start();
+            List<LinkMenu>? result = new List<LinkMenu>();
+            // cerco in redis...
+            string currKey = $"{redisBaseKey}:Menu:{tipoLink}";
+            RedisValue rawData = await redisDb.StringGetAsync(currKey);
+            if (!string.IsNullOrEmpty($"{rawData}"))
+            {
+                result = JsonConvert.DeserializeObject<List<LinkMenu>>($"{rawData}");
+                source = "REDIS";
+            }
+            else
+            {
+                result = await Task.FromResult(dbController.ListLinkFilt(tipoLink));
+                // serializzp e salvo...
+                rawData = JsonConvert.SerializeObject(result);
+                await redisDb.StringSetAsync(currKey, rawData, UltraLongCache);
+            }
+            if (result == null)
+            {
+                result = new List<LinkMenu>();
+            }
+            sw.Stop();
+            Log.Debug($"ListLinkFilt | tipoLink: {tipoLink} | {source} | {sw.Elapsed.TotalMilliseconds}ms");
+            return result;
+        }
+
+
+        /// <summary>
+        /// Elenco Macchine dato operatore secondo gruppi (macchine/operatore)
+        /// </summary>
+        /// <param name="MatrOpr"></param>
+        /// <returns></returns>
+        public async Task<List<Macchine>> MacchineByMatrOper(int MatrOpr)
+        {
+            string source = "DB";
+            Stopwatch sw = new Stopwatch();
+            sw.Start();
+            List<Macchine>? result = new List<Macchine>();
+            // cerco in redis...
+            string currKey = $"{redisBaseKey}:Macc:{MatrOpr}";
+            RedisValue rawData = await redisDb.StringGetAsync(currKey);
+            if (!string.IsNullOrEmpty($"{rawData}"))
+            {
+                result = JsonConvert.DeserializeObject<List<Macchine>>($"{rawData}");
+                source = "REDIS";
+            }
+            else
+            {
+                result = await Task.FromResult(dbController.MacchineByMatrOper(MatrOpr));
+                // serializzp e salvo...
+                rawData = JsonConvert.SerializeObject(result);
+                await redisDb.StringSetAsync(currKey, rawData, UltraLongCache);
+            }
+            if (result == null)
+            {
+                result = new List<Macchine>();
+            }
+            sw.Stop();
+            Log.Debug($"MacchineGetFilt | MatrOpr: {MatrOpr} | {source} | {sw.Elapsed.TotalMilliseconds}ms");
+            return result;
+        }
+
+
+
+        /// <summary>
+        /// Elenco tabella Articoli da filtro
+        /// </summary>
+        /// <param name="numRecord">Numero record max da recuperare</param>
+        /// <param name="azienda">cod azienda, * = tutte</param>
+        /// <param name="searchVal">Ricerca testuale</param>
+        /// <returns></returns>
+        public async Task<List<AnagArticoli>> ArticoliGetSearch(int numRecord, string azienda, string searchVal)
+        {
+            string source = "DB";
+            Stopwatch sw = new Stopwatch();
+            sw.Start();
+            List<AnagArticoli>? result = new List<AnagArticoli>();
+            // cerco in redis...
+            string currKey = $"{redisBaseKey}:Art:{azienda}:{searchVal}:{numRecord}";
+            RedisValue rawData = await redisDb.StringGetAsync(currKey);
+            if (!string.IsNullOrEmpty($"{rawData}"))
+            {
+                result = JsonConvert.DeserializeObject<List<AnagArticoli>>($"{rawData}");
+                source = "REDIS";
+            }
+            else
+            {
+                result = await Task.FromResult(dbController.ArticoliGetSearch(numRecord, azienda, searchVal));
+                // serializzp e salvo...
+                rawData = JsonConvert.SerializeObject(result);
+                await redisDb.StringSetAsync(currKey, rawData, LongCache);
+            }
+            if (result == null)
+            {
+                result = new List<AnagArticoli>();
+            }
+            sw.Stop();
+            Log.Debug($"ArticoliGetSearch | azienda: {azienda} | searchVal: {searchVal} | numRecord: {numRecord} | {source} | {sw.Elapsed.TotalMilliseconds}ms");
+            return result;
+        }
+
+        #endregion Public Methods
+
+        #region Protected Fields
+
+        /// <summary>
+        /// Oggetto per connessione a REDIS
+        /// </summary>
+        protected ConnectionMultiplexer redisConn = null!;
+
+        /// <summary>
+        /// Oggetto DB redis da impiegare x chiamate R/W
+        /// </summary>
+        protected IDatabase redisDb = null!;
+
+        #endregion Protected Fields
+
+        #region Private Fields
+
+        private static IConfiguration _configuration = null!;
+
+        private static Logger Log = LogManager.GetCurrentClassLogger();
+        private string redisBaseKey = "MP:ALL:Cache";
+
+        #endregion Private Fields
+    }
+}