mapo-core/MP-TAB3/Pages/BasePage.razor.cs

using Microsoft.AspNetCore.Components;
using MP.Data.DatabaseModels;
using MP.Data;
using MP.Data.Services;
using Newtonsoft.Json;
using NLog.Fluent;

namespace MP_TAB3.Pages
{
    /// <summary>
    /// Pagina base da cui ereditare metodi x refresh dati da RedisChannel (MessagePipe)
    /// </summary>
    public partial class BasePage : IDisposable
    {
        #region Public Properties

        /// <summary>
        /// Dato di dettaglio MSE per macchina
        /// </summary>
        public MappaStatoExpl? CurrMSE { get; set; } = null;

        /// <summary>
        /// Macchina selezionata
        /// </summary>
        public string IdxMacc { get; set; } = "";

        [Inject]
        public MessageService MsgServ { get; set; } = null!;

        [Inject]
        public TabDataFeeder TDFeeder { get; set; } = null!;

        #endregion Public Properties

        #region Public Methods

        /// <summary>
        /// Metodo dispose
        /// </summary>
        public virtual void Dispose()
        {
            IdxMacc = "";
            CurrMSE = null;
            TDFeeder.dataPipe.EA_NewMessage -= DataPipe_EA_NewMessage;
            TDFeeder.blinkPipe.EA_NewMessage -= BlinkPipe_EA_NewMessage;
        }

        #endregion Public Methods

        #region Protected Methods

        /// <summary>
        /// Override Oninit x aggancio evento update da MessagePipe
        /// </summary>
        /// <returns></returns>
        protected override async Task OnInitializedAsync()
        {
            await base.OnInitializedAsync();
            TDFeeder.dataPipe.EA_NewMessage += DataPipe_EA_NewMessage;
            TDFeeder.blinkPipe.EA_NewMessage += BlinkPipe_EA_NewMessage;
        }

        protected override async Task OnParametersSetAsync()
        {
            await ReloadData();
        }

        /// <summary>
        /// Metodo refresh con controllo salvataggio in LocalStorage ogni 5 sec
        /// </summary>
        /// <param name="ListMSE"></param>
        /// <returns></returns>
        protected async Task RefreshData(List<MappaStatoExpl> ListMSE)
        {
            // se vecchio salvo sul browser...
            if (DateTime.Now.Subtract(lastSave).TotalSeconds > 5)
            {
                // salvo in LocalStorage...
                await MsgServ.SaveMse(ListMSE);
                lastSave = DateTime.Now;
            }
            if (!string.IsNullOrEmpty(IdxMacc))
            {
                var rawData = ListMSE.Find(x => x.IdxMacchina == IdxMacc);
                if (rawData != null)
                {
                    CurrMSE = rawData;
                }
                else
                {
                    await RefreshMBlock();
                }
            }
        }

        /// <summary>
        /// Refresh con rilettura da LocalStorage
        /// </summary>
        /// <returns></returns>
        protected async Task RefreshMBlock()
        {
            // recupero MSE macchina....
            if (!string.IsNullOrEmpty(IdxMacc))
            {
                CurrMSE = await MsgServ.GetMachineMse(IdxMacc);
            }
        }

        protected virtual async Task ReloadData()
        {
            if (string.IsNullOrEmpty(IdxMacc))
            {
                IdxMacc = await MsgServ.IdxMaccGet();
            }
            // recupero MSE macchina....
            if (!string.IsNullOrEmpty(IdxMacc))
            {
                CurrMSE = await MsgServ.GetMachineMse(IdxMacc);
            }
        }

        #endregion Protected Methods

        #region Private Fields

        private bool doBlink = false;

        /// <summary>
        /// DateTime ultimo salvataggio in LocalStorage
        /// </summary>
        private DateTime lastSave = DateTime.Now;

        #endregion Private Fields

        #region Private Methods

        /// <summary>
        /// Ricezione evento blink
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void BlinkPipe_EA_NewMessage(object? sender, EventArgs e)
        {
            PubSubEventArgs currArgs = (PubSubEventArgs)e;
            // conversione on-the-fly List<string> --> allarmi
            if (!string.IsNullOrEmpty(currArgs.newMessage))
            {
                try
                {
                    var dataRaw = JsonConvert.DeserializeObject<string>(currArgs.newMessage);
                    if (dataRaw != null)
                    {
                        bool.TryParse($"{dataRaw}", out doBlink);
                    }
                }
                catch
                { }
                InvokeAsync(() =>
                {
                    StateHasChanged();
                });
            }
        }

        /// <summary>
        /// Ricevuto nuovi dati da mostrare!
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        /// <exception cref="NotImplementedException"></exception>
        private void DataPipe_EA_NewMessage(object? sender, EventArgs e)
        {
            PubSubEventArgs currArgs = (PubSubEventArgs)e;
            // conversione on-the-fly List<string> --> allarmi
            if (!string.IsNullOrEmpty(currArgs.newMessage))
            {
                try
                {
                    List<MappaStatoExpl>? dataList = JsonConvert.DeserializeObject<List<MappaStatoExpl>>(currArgs.newMessage);
                    if (dataList != null)
                    {
                        InvokeAsync(() => RefreshData(dataList));
                    }
                }
                catch
                { }
            }
            InvokeAsync(() =>
            {
                StateHasChanged();
            });
        }

        #endregion Private Methods
    }
}