Move vecchia soluzione NET5

2022-04-12 14:26:09 +02:00
parent f0d8ede575
commit df973a4fbe
72 changed files with 0 additions and 0 deletions
@@ -0,0 +1,160 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using System.Configuration;
+using System.Text;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using BlaServApp.Data;
+using Microsoft.Extensions.Caching.Distributed;
+using Microsoft.Extensions.Caching.Memory;
+using Newtonsoft.Json;
+using System.Diagnostics;
+using NLog;
+
+namespace BlaServApp.UI.Data
+{
+    public class BlaServAppDataService
+    {
+        #region Private Fields
+
+        private static IConfiguration _configuration;
+        private static ILogger<BlaServAppDataService> _logger;
+
+        private static NLog.Logger Log = LogManager.GetCurrentClassLogger();
+        private readonly IDistributedCache distributedCache;
+        private readonly IMemoryCache memoryCache;
+
+        /// <summary>
+        /// Durata assoluta massima della cache
+        /// </summary>
+        private int chAbsExp = 15;
+
+        /// <summary>
+        /// Durata della cache in modalità inattiva (non acceduta) prima di venire rimossa
+        /// NON estende oltre il tempo massimo di validità della cache (chAbsExp)
+        /// </summary>
+        private int chSliExp = 5;
+
+        #endregion Private Fields
+
+        #region Protected Fields
+
+        protected static string connStringBBM = "";
+
+        #endregion Protected Fields
+
+        #region Public Fields
+
+        public static BlaServApp.Data.Controllers.BlaServAppController dbController;
+
+        #endregion Public Fields
+
+        #region Public Constructors
+
+        public BlaServAppDataService(IConfiguration configuration, ILogger<BlaServAppDataService> logger, IMemoryCache memoryCache, IDistributedCache distributedCache)
+        {
+            _logger = logger;
+            _configuration = configuration;
+            // conf cache
+            this.memoryCache = memoryCache;
+            this.distributedCache = distributedCache;
+            // conf DB
+            string connStr = _configuration.GetConnectionString("BlaServApp.Data");
+            if (string.IsNullOrEmpty(connStr))
+            {
+                _logger.LogError("ConnString empty!");
+            }
+            else
+            {
+                dbController = new BlaServApp.Data.Controllers.BlaServAppController(configuration);
+                StringBuilder sb = new StringBuilder();
+                sb.AppendLine($"DbController OK");
+                _logger.LogInformation(sb.ToString());
+            }
+        }
+
+        #endregion Public Constructors
+
+        #region Private Properties
+
+        private DistributedCacheEntryOptions cacheOpt
+        {
+            get
+            {
+                return new DistributedCacheEntryOptions().SetAbsoluteExpiration(DateTime.Now.AddMinutes(chAbsExp)).SetSlidingExpiration(TimeSpan.FromMinutes(chSliExp));
+            }
+        }
+
+        #endregion Private Properties
+
+        #region Protected Methods
+
+        protected string getCacheKey(string TableName, SelectData CurrFilter)
+        {
+            string answ = $"{TableName}:M_{CurrFilter.IdxMacchina}:A_{CurrFilter.CodArticolo}:K_{CurrFilter.KeyRichiesta}:O_{CurrFilter.IdxOdl}:D_{CurrFilter.DateStart:yyyyMMddHHmm}_{CurrFilter.DateEnd:yyyyMMddHHmm}";
+            return answ;
+        }
+
+        #endregion Protected Methods
+
+        #region Public Methods
+
+        public async Task<List<BlaServApp.Data.DatabaseModels.Articoli>> ArticoliGetAll()
+        {
+            //return Task.FromResult(dbController.ActionsGetAll());
+            List<BlaServApp.Data.DatabaseModels.Articoli> dbResult = new List<BlaServApp.Data.DatabaseModels.Articoli>();
+            string cacheKey = "BlaServApp:DATA:ARTICOLI";
+            string rawData;
+            var redisDataList = await distributedCache.GetAsync(cacheKey);
+            if (redisDataList != null)
+            {
+                rawData = Encoding.UTF8.GetString(redisDataList);
+                dbResult = JsonConvert.DeserializeObject<List<BlaServApp.Data.DatabaseModels.Articoli>>(rawData);
+            }
+            else
+            {
+                Stopwatch stopWatch = new Stopwatch();
+                stopWatch.Start();
+                dbResult = dbController.getArticoli();
+                rawData = JsonConvert.SerializeObject(dbResult);
+                redisDataList = Encoding.UTF8.GetBytes(rawData);
+                await distributedCache.SetAsync(cacheKey, redisDataList, cacheOpt);
+                stopWatch.Stop();
+                TimeSpan ts = stopWatch.Elapsed;
+                Log.Info($"Effettuata lettura da DB + caching per ArticoliGetAll: {ts.TotalMilliseconds} ms");
+            }
+            return await Task.FromResult(dbResult);
+        }
+
+        public async Task<List<BlaServApp.Data.DatabaseModels.Config>> ConfigGetAll()
+        {
+            //return Task.FromResult(dbController.ActionsGetAll());
+            List<BlaServApp.Data.DatabaseModels.Config> dbResult = new List<BlaServApp.Data.DatabaseModels.Config>();
+            string cacheKey = "BlaServApp:DATA:CONFIG";
+            string rawData;
+            var redisDataList = await distributedCache.GetAsync(cacheKey);
+            if (redisDataList != null)
+            {
+                rawData = Encoding.UTF8.GetString(redisDataList);
+                dbResult = JsonConvert.DeserializeObject<List<BlaServApp.Data.DatabaseModels.Config>>(rawData);
+            }
+            else
+            {
+                Stopwatch stopWatch = new Stopwatch();
+                stopWatch.Start();
+                dbResult = dbController.getConfig();
+                rawData = JsonConvert.SerializeObject(dbResult);
+                redisDataList = Encoding.UTF8.GetBytes(rawData);
+                await distributedCache.SetAsync(cacheKey, redisDataList, cacheOpt);
+                stopWatch.Stop();
+                TimeSpan ts = stopWatch.Elapsed;
+                Log.Info($"Effettuata lettura da DB + caching per ConfigGetAll: {ts.TotalMilliseconds} ms");
+            }
+            return await Task.FromResult(dbResult);
+        }
+
+        #endregion Public Methods
+    }
+}
@@ -0,0 +1,150 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace BlaServApp.UI.Data
+{
+    public class MessageService
+    {
+        #region Private Fields
+
+        private SelectData _detailFilter = SelectData.Init(5, 7);
+        private string _pageIcon;
+        private string _pageName;
+        private string _searchVal;
+        private bool showSearch;
+
+        #endregion Private Fields
+
+        #region Public Events
+
+        public event Action EA_FilterUpdated;
+
+        public event Action EA_HideSearch;
+
+        public event Action EA_PageUpdated;
+
+        public event Action EA_SearchUpdated;
+
+        public event Action EA_ShowSearch;
+
+        #endregion Public Events
+
+        #region Public Properties
+
+        public SelectData DDB_Filter { get; set; } = SelectData.Init(5, 3);
+
+        public SelectData DetailFilter
+        {
+            get => _detailFilter;
+            set
+            {
+                if (_detailFilter != value)
+                {
+                    _detailFilter = value;
+
+                    if (EA_FilterUpdated != null)
+                    {
+                        EA_FilterUpdated?.Invoke();
+                    }
+                }
+            }
+        }
+
+        public SelectData KRE_Filter { get; set; } = SelectData.Init(5, 7);
+        public SelectData ODL_Filter { get; set; } = SelectData.Init(5, 7);
+        public SelectData OEE_Filter { get; set; } = SelectData.Init(5, 7);
+
+        public string PageIcon
+        {
+            get => _pageIcon;
+            set
+            {
+                if (_pageIcon != value)
+                {
+                    _pageIcon = value;
+                    ReportPageUpd();
+                }
+            }
+        }
+
+        public string PageName
+        {
+            get => _pageName;
+            set
+            {
+                if (_pageName != value)
+                {
+                    _pageName = value;
+                    ReportPageUpd();
+                }
+            }
+        }
+
+        public string SearchVal
+        {
+            get => _searchVal;
+            set
+            {
+                if (_searchVal != value)
+                {
+                    _searchVal = value;
+
+                    if (EA_SearchUpdated != null)
+                    {
+                        EA_SearchUpdated?.Invoke();
+                    }
+                }
+            }
+        }
+
+        public bool ShowSearch
+        {
+            get => showSearch;
+            set
+            {
+                if (showSearch != value)
+                {
+                    showSearch = value;
+                    if (showSearch)
+                    {
+                        if (EA_ShowSearch != null)
+                        {
+                            EA_ShowSearch?.Invoke();
+                        }
+                    }
+                    else
+                    {
+                        if (EA_HideSearch != null)
+                        {
+                            EA_HideSearch?.Invoke();
+                        }
+                    }
+                }
+            }
+        }
+
+        #endregion Public Properties
+
+        #region Private Methods
+
+        private void ReportPageUpd()
+        {
+            if (EA_PageUpdated != null)
+            {
+                EA_PageUpdated?.Invoke();
+            }
+        }
+
+        private void ReportSearch()
+        {
+            if (EA_SearchUpdated != null)
+            {
+                EA_SearchUpdated?.Invoke();
+            }
+        }
+
+        #endregion Private Methods
+    }
+}
@@ -0,0 +1,70 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace BlaServApp.UI.Data
+{
+    public class SelectData
+    {
+        #region Public Properties
+
+        public string CodArticolo { get; set; } = "*";
+        public DateTime DateEnd { get; set; } = DateTime.Now.AddMinutes(1);
+        public DateTime DateStart { get; set; } = DateTime.Now.AddDays(-7);
+        public string IdxMacchina { get; set; } = "*";
+        public int IdxOdl { get; set; } = -999;
+        public string KeyRichiesta { get; set; } = "*";
+
+        #endregion Public Properties
+
+        #region Public Methods
+
+        /// <summary>
+        /// Inizializzazione con periodo e arrotondamento
+        /// </summary>
+        /// <param name="minRound"></param>
+        /// <param name="numDayPrev"></param>
+        /// <returns></returns>
+        public static SelectData Init(int minRound, int numDayPrev)
+        {
+            TimeSpan DayElapsed = DateTime.Now.Subtract(DateTime.Today);
+            int minDay = (int)(DayElapsed.TotalMinutes / minRound) * minRound;
+            DateTime endRounded = DateTime.Today.AddMinutes(minDay);
+            SelectData answ = new SelectData()
+            {
+                DateEnd = endRounded,
+                DateStart = endRounded.AddDays(-numDayPrev)
+            };
+            return answ;
+        }
+
+        public override bool Equals(object obj)
+        {
+            if (!(obj is SelectData item))
+                return false;
+
+            if (CodArticolo != item.CodArticolo)
+                return false;
+            if (DateEnd != item.DateEnd)
+                return false;
+            if (DateStart != item.DateStart)
+                return false;
+            if (IdxMacchina != item.IdxMacchina)
+                return false;
+            if (IdxOdl != item.IdxOdl)
+                return false;
+            if (KeyRichiesta != item.KeyRichiesta)
+                return false;
+
+            return true;
+        }
+
+        public override int GetHashCode()
+        {
+            return base.GetHashCode();
+        }
+
+        #endregion Public Methods
+    }
+}