limanapp/LiMan.UI/Components/InstallInfoStats.razor.cs

using LiMan.DB;
using LiMan.DB.DBModels;
using LiMan.DB.DTO;
using LiMan.UI.Data;
using Microsoft.AspNetCore.Components;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using static Core.Enum;

namespace LiMan.UI.Components
{
    public partial class InstallInfoStats : IDisposable
    {
        #region Public Methods

        public void Dispose()
        {
            LMDService.EnrollMessPipe.EA_NewMessage -= async (sender, e) => await EnrollMessPipe_EA_NewMessage(sender, e);
            LMDService.TaskMessPipe.EA_NewMessage -= async (sender, e) => await TaskMessPipe_EA_NewMessage(sender, e);
            MServ.EA_SelCodImp -= async () => await MServ_EA_SelCodImp();
            MServ.EA_SelCodInst -= async () => await MServ_EA_SelCodInst();
        }

        #endregion Public Methods

        #region Protected Properties

        /// <summary>
        /// Codice installazione selezionata
        /// </summary>
        protected string CodInstSel
        {
            get => codInstSel;
            set
            {
                if (codInstSel != value)
                {
                    codInstSel = value;
                    isLoading = true;
                    var pUpd = Task.Run(async () =>
                    {
                        await ReloadData();
                    });
                    pUpd.Wait();
                    isLoading = false;
                }
            }
        }

        [Inject]
        protected LiManDataService LMDService { get; set; } = null!;

        [Inject]
        protected MessageService MServ { get; set; } = null!;

        #endregion Protected Properties

        #region Protected Methods

        protected override async Task OnInitializedAsync()
        {
            LMDService.EnrollMessPipe.EA_NewMessage += async (sender, e) => await EnrollMessPipe_EA_NewMessage(sender, e);
            LMDService.TaskMessPipe.EA_NewMessage += async (sender, e) => await TaskMessPipe_EA_NewMessage(sender, e);
            MServ.EA_SelCodImp += async () => await MServ_EA_SelCodImp();
            MServ.EA_SelCodInst += async () => await MServ_EA_SelCodInst();
            await ReloadLicData();
            await ReloadData();
        }

        #endregion Protected Methods

        #region Private Fields

        private string CodDeviceSel = "";
        private string codInstSel = "";

        private Dictionary<string, string> DetailFilt = new Dictionary<string, string>();

        private bool HasFiltClienti = false;

        private bool HasFiltImpiego = false;

        private List<InstallazioneModel> ListInstall;

        #endregion Private Fields

        #region Private Properties

        private string CodImpSel { get; set; } = "";

        private string cssBtnCli
        {
            get => HasFiltClienti ? "btn-info" : "btn-primary";
        }

        private DateTime DtFine { get; set; } = DateTime.Today.AddHours(DateTime.Now.Hour);
        private DateTime DtInizio { get; set; } = DateTime.Today.AddMonths(-1);
        private InstallStatusDTO InfoStats { get; set; } = new InstallStatusDTO();
        private bool isLoading { get; set; } = false;
        private Dictionary<string, DeviceDTO> ListDevices { get; set; } = new Dictionary<string, DeviceDTO>();

        #endregion Private Properties

        #region Private Methods

        private async Task CloseDetail()
        {
            isLoading = true;
            await InvokeAsync(StateHasChanged);
            HasFiltImpiego = false;
            CodImpSel = "";
            DetailFilt.Clear();
            isLoading = false;
            await InvokeAsync(StateHasChanged);
        }

        /// <summary>
        /// Evento refresh legato a ricezione evento da MessagePipe
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private async Task EnrollMessPipe_EA_NewMessage(object sender, EventArgs e)
        {
            PubSubEventArgs currArgs = (PubSubEventArgs)e;
            // qualsiasi messaggio fa scattare reload data
            if (!string.IsNullOrEmpty(currArgs.newMessage))
            {
                isLoading = true;
                await InvokeAsync(StateHasChanged);
                await ReloadLicData();
                await ReloadData();
                isLoading = false;
                await InvokeAsync(StateHasChanged);
            }
        }

        /// <summary>
        /// Evento refresh legato a ricezione evento da MessagePipe
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private async Task TaskMessPipe_EA_NewMessage(object sender, EventArgs e)
        {
            PubSubEventArgs currArgs = (PubSubEventArgs)e;
            // qualsiasi messaggio fa scattare reload data
            if (!string.IsNullOrEmpty(currArgs.newMessage))
            {
                // verifico se sia il cod impianto selezionato, nel faso forzo refreesh...
                if (!string.IsNullOrEmpty(CodImpSel) && CodImpSel.Equals(currArgs.newMessage))
                {
                    isLoading = true;
                    ReloadTaskStatus();
                    isLoading = false;
                    await InvokeAsync(StateHasChanged);
                }
            }
        }

        /// <summary>
        /// Esegue update stato task
        /// </summary>
        private void ReloadTaskStatus()
        {
            TaskReq = new Dictionary<string, string>();
            TaskRun = new Dictionary<string, string>();
            TaskDone = new Dictionary<string, string>();
            if (!string.IsNullOrEmpty(CodImpSel))
            {
                TaskReq = LMDService.TaskReqGet(CodImpSel);
                TaskRun = LMDService.TaskRunGet(CodImpSel);
                TaskDone = LMDService.TaskDoneGet(CodImpSel);
            }
        }

        private string BtnState(int numRec)
        {
            return numRec > 0 ? "text-bg-dark" : "text-bg-secondary";
        }

        /// <summary>
        /// Lista Task in stato DONE
        /// </summary>
        private Dictionary<string, string> TaskDone = new Dictionary<string, string>();

        /// <summary>
        /// Lista Task in stato REQUESTED
        /// </summary>
        private Dictionary<string, string> TaskReq = new Dictionary<string, string>();

        /// <summary>
        /// Lista Task in stato RUNNING
        /// </summary>
        private Dictionary<string, string> TaskRun = new Dictionary<string, string>();

        /// <summary>
        /// Selezionato CodImp (PC)
        /// </summary>
        /// <exception cref="NotImplementedException"></exception>
        private async Task MServ_EA_SelCodImp()
        {
            isLoading = true;
            // se trovo salvate in preferenze utente le info necessarie...
            CodImpSel = MServ.UsrParamGet("CodImp");
            HasFiltImpiego = !string.IsNullOrEmpty(CodImpSel);
            DetailFilt.Clear();
            DetailFilt.Add("Cliente", MServ.UsrParamGet("Cliente"));
            DetailFilt.Add("PC", MServ.UsrParamGet("PcInst"));
            ReloadTaskStatus();
            isLoading = false;
            await InvokeAsync(StateHasChanged);
        }

        /// <summary>
        /// Selezionato CodInstall (Cliente)
        /// </summary>
        /// <exception cref="NotImplementedException"></exception>
        private async Task MServ_EA_SelCodInst()
        {
            isLoading = true;
            CodInstSel = MServ.UsrParamGet("CodInst");
            HasFiltClienti = !string.IsNullOrEmpty(CodInstSel);
            ReloadDevices();
            isLoading = false;
            await InvokeAsync(StateHasChanged);
        }

        private async Task ReloadData()
        {
            isLoading = true;
            InfoStats = await LMDService.InstallStatusGetInfo(DtInizio, DtFine, CodInstSel);
            ReloadDevices();
            isLoading = false;
        }

        private void ReloadDevices()
        {
            ListDevices = new Dictionary<string, DeviceDTO>();
            if (InfoStats != null)
            {
                // se necessario filtro...
                if (HasFiltClienti)
                {
                    ListDevices = InfoStats
                                    .InstDevices
                                    .Where(x => x.Value.CodInst == CodInstSel)
                                    .OrderBy(x => x.Value.DevName)
                                    .ToDictionary(x => x.Key, x => x.Value);
                }
                else
                {
                    ListDevices = InfoStats
                                    .InstDevices
                                    .OrderBy(x => x.Value.DevName)
                                    .ToDictionary(x => x.Key, x => x.Value);
                }
            }
        }

        private async Task ReloadLicData()
        {
            ListInstall = await LMDService.InstallazioniNextGetAll();
        }

        /// <summary>
        /// Resetta le richeiste di task x impiango corrente
        /// </summary>
        private async Task ResetTaskReq()
        {
            if (!string.IsNullOrEmpty(CodImpSel))
            {
                // registro la richiesta
                LMDService.TaskReqReset(CodImpSel);
                await Task.Delay(5);
                // mando notifica con messageservice...
                MServ.ReportTaskChange();
            }
        }

        /// <summary>
        /// Invia una richiesta esecuzione task
        /// </summary>
        /// <param name="reqTask"></param>
        /// <param name="optPar">Parametri opzionali x svolgiimento</param>
        private void SendTask(EgwAccTask reqTask, string optPar = "")
        {
            if (!string.IsNullOrEmpty(CodImpSel))
            {
                // se parametro vuoto metto dataora...
                optPar = string.IsNullOrEmpty(optPar) ? $"{DateTime.Now:yyyy-MM-dd HH:mm:ss}" : optPar;
                // registro la richiesta
                LMDService.TaskReqAdd(CodImpSel, reqTask, optPar);
                // aggiorno stato...
                ReloadTaskStatus();
                // mando notifica con messageservice...
                MServ.ReportTaskChange();
#if false
                // invio string in messagepipe x forzare refresh...
                LMDService.TaskMessPipe.sendMessage(CodImpSel); 
#endif
            }
        }

        private void TglFiltCli()
        {
            HasFiltClienti = !HasFiltClienti;
            if (!HasFiltClienti)
            {
                CodInstSel = "";
            }
        }

        #endregion Private Methods
    }
}