Update gestione parametro display PDF + inizio TabDataFeeder

2024-02-26 15:15:24 +01:00
parent cb3ad67aaa
commit 553fa000b5
9 changed files with 212 additions and 59 deletions
@@ -15,8 +15,8 @@ namespace MP.Data.Services
        {

            // setup canali pub/sub
-            dataPipe = new MessagePipe(redisConn, Constants.ACT_MSE_DATA_KEY);
-            blinkPipe = new MessagePipe(redisConn, Constants.ACT_BLINK_KEY);
+            dataPipe = new MessagePipe(redisConn, Constants.MON_ACT_MSE_DATA_KEY);
+            blinkPipe = new MessagePipe(redisConn, Constants.MON_ACT_BLINK_KEY);

            // avvio timers...
            startTimers();
@@ -40,13 +40,15 @@ namespace MP.Data.Services
            stopTimers();
        }

+#if false
        /// <summary>
        /// Richiesta attivazione --&gt; sposto avanti 1 minuto il periodo limite x fast running
        /// </summary>
        public void doActivate()
        {
            fastLimit = DateTime.Now.AddMinutes(1);
-        }
+        } 
+#endif

        /// <summary>
        /// Impostazione forzata timer refresh
@@ -85,11 +87,13 @@ namespace MP.Data.Services

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

+#if false
        /// <summary>
        /// Limite in formato data-ora per inviare dati rapidamente (incrementato come now + 1 min
        /// ad ogni chiamata client)
        /// </summary>
-        private DateTime fastLimit = DateTime.Now;
+        private DateTime fastLimit = DateTime.Now; 
+#endif

        private int fastRefreshMs = 1000;

@@ -0,0 +1,135 @@
+using Microsoft.Extensions.Configuration;
+using Newtonsoft.Json;
+using NLog;
+using StackExchange.Redis;
+using System;
+using System.Threading.Tasks;
+
+namespace MP.Data.Services
+{
+    public class TabDataFeeder : StatusData, IDisposable
+    {
+        #region Public Constructors
+
+        public TabDataFeeder(IConfiguration configuration) : base(configuration)
+        {
+
+            // setup canali pub/sub
+            dataPipe = new MessagePipe(redisConn, Constants.TAB_ACT_MSE_DATA_KEY);
+            blinkPipe = new MessagePipe(redisConn, Constants.TAB_ACT_BLINK_KEY);
+
+            // avvio timers...
+            startTimers();
+        }
+
+        #endregion Public Constructors
+
+        #region Public Properties
+
+        public MessagePipe blinkPipe { get; set; } = null!;
+
+        public MessagePipe dataPipe { get; set; } = null!;
+
+        #endregion Public Properties
+
+        #region Public Methods
+
+        public new void Dispose()
+        {
+            base.Dispose();
+            stopTimers();
+        }
+
+#if false
+        /// <summary>
+        /// Richiesta attivazione --&gt; sposto avanti 1 minuto il periodo limite x fast running
+        /// </summary>
+        public void doActivate()
+        {
+            fastLimit = DateTime.Now.AddMinutes(1);
+        } 
+#endif
+
+        /// <summary>
+        /// Impostazione forzata timer refresh
+        /// </summary>
+        /// <param name="FastTimerMs"></param>
+        public void setTimers(int FastTimerMs)
+        {
+            stopTimers();
+            fastRefreshMs = FastTimerMs;
+            // avvio timers...
+            startTimers();
+        }
+
+        public void startTimers()
+        {
+            fastTimer = new System.Timers.Timer(fastRefreshMs);
+            fastTimer.Elapsed += ElapsedFastTimer;
+            fastTimer.Enabled = true;
+            fastTimer.Start();
+        }
+
+        public void stopTimers()
+        {
+            // stop timers
+            fastTimer.Elapsed -= ElapsedFastTimer;
+            fastTimer.Enabled = false;
+            fastTimer.Stop();
+            fastTimer.Dispose();
+        }
+
+        #endregion Public Methods
+
+        #region Private Fields
+
+        private static System.Timers.Timer fastTimer = new System.Timers.Timer(4000);
+
+        private static NLog.Logger Log = LogManager.GetCurrentClassLogger();
+
+#if false
+        /// <summary>
+        /// Limite in formato data-ora per inviare dati rapidamente (incrementato come now + 1 min
+        /// ad ogni chiamata client)
+        /// </summary>
+        private DateTime fastLimit = DateTime.Now; 
+#endif
+
+        private int fastRefreshMs = 1000;
+
+
+        #endregion Private Fields
+
+        #region Private Methods
+
+        private void ElapsedFastTimer(object? source, System.Timers.ElapsedEventArgs e)
+        {
+            var pUpd = Task.Run(async () =>
+            {
+                // secondi pari --> blink, secondi dispari --> ricarica
+                DateTime adesso = DateTime.Now;
+                int resto = 0;
+                Math.DivRem(adesso.Second, 2, out resto);
+                if (resto == 0)
+                {
+                    // invio in channel blink il segnale
+                    blinkPipe.sendMessage("true");
+                    Log.Debug("Elapsed Fast Timer Blink");
+                }
+                else
+                {
+                    // invio in channel blink segnale false
+                    blinkPipe.sendMessage("false");
+                    // rileggo dati...
+                    var newData = await MseGetAll();
+                    // invio tramite la pipe...
+                    dataPipe.sendMessage(JsonConvert.SerializeObject(newData));
+                    Log.Debug("Elapsed Fast Timer reload");
+                }
+            });
+            pUpd.Wait();
+        }
+
+        #endregion Private Methods
+    }
+}