Mapo-IOB-WIN/IOB-WIN-NEXT/Iob/BaseObj.cs

using IOB_UT_NEXT;
using NLog;
using System;
using System.Collections.Generic;
using System.Diagnostics;

namespace IOB_WIN_NEXT.Iob
{
    /// <summary>
    /// Classe di base per IOB
    /// </summary>
    public class BaseObj
    {
        #region Public Fields

        /// <summary>
        /// valore booleano di check se sia stato AVVIATO l'adapter (Running)
        /// </summary>
        public bool adpRunning = false;

        /// <summary>
        /// valore booleano di check se l'adapter STIA SALVANDO
        /// </summary>
        public bool adpSaving = false;

        /// <summary>
        /// valore booleano (richiesta di riavvio automatico)
        /// </summary>
        public bool adpTryRestart;

        /// <summary>
        /// Struttura allarmi mappati
        /// </summary>
        public List<BaseAlarmConf> alarmMaps = new List<BaseAlarmConf>();

        /// <summary>
        /// Conf adapter corrente
        /// </summary>
        public IobConfiguration cIobConf;

        /// <summary>
        /// Conteggio ATTUALE ore macchina IN LAVORO
        /// </summary>
        public double contOreMaccLav;

        /// <summary>
        /// Conteggio ATTUALE ore macchina ON
        /// </summary>
        public double contOreMaccOn;

        /// <summary>
        /// contatore x simulazione valori input
        /// </summary>
        public int countSim = 0;

        /// <summary>
        /// ODL attualmente sulla macchina
        /// </summary>
        public Int32 currIdxODL = 0;

        /// <summary>
        /// Modo corrente (da classe ENUM)
        /// </summary>
        public CNC_MODE currMode;

        /// <summary>
        /// ODL corrente caricato sulla macchina (stringa, da chiamata MP/IO)
        /// </summary>
        public string currODL = "";

        /// <summary>
        /// Indica se sia richiesto campionamento memoria PERIODICO
        /// </summary>
        public bool doSampleMemory;

        /// <summary>
        /// Indica se si debba leggere e fare DUMP delle aree di memoria (1 volta solo all'avvio x debug...)
        /// </summary>
        public bool doStartMemDump;

        /// <summary>
        /// Data/ora ultimo avvio adapter
        /// </summary>
        public DateTime dtAvvioAdp = DateTime.Now;

        /// <summary>
        /// Data/ora ultimo spegnimento adapter
        /// </summary>
        public DateTime dtStopAdp = DateTime.Now;

        /// <summary>
        /// Indicazione VETO check status IOB x evitare loop troppo stretti...
        /// </summary>
        public DateTime dtVetoCheckIOB = DateTime.Now.AddDays(-1);

        /// <summary>
        /// Indicazione VETO check sync ricette x evitare loop troppo stretti...
        /// </summary>
        public DateTime dtVetoCheckSyncRecipe = DateTime.Now.AddHours(-1);

        /// <summary>
        /// Abilitazione lettura PrgName
        /// </summary>
        public bool enablePrgName = true;

        /// <summary>
        /// Abilitazione invio pezzi "in blocco" per recupero contapezzi
        /// </summary>
        public bool enableSendPzCountBlock = false;

        /// <summary>
        /// Determina se sia encessario convertire valori little/big endian (SIEMENS=true, OSAI=FALSE)
        /// </summary>
        public bool hasBigEndian = false;

        /// <summary>
        /// dataOra ultima verifica CNC disconnesso...
        /// </summary>
        public DateTime lastDisconnCheck;

        /// <summary>
        /// Data/ora ultima volta che IOB è stato dichiarato online
        /// </summary>
        public DateTime lastIobOnline = DateTime.Now.AddHours(-1);

        /// <summary>
        /// dataOra ultimo log periodico...
        /// </summary>
        public DateTime lastPeriodicLog;

        /// <summary>
        /// dataOra ultimo PING inviato verso il PLC...
        /// </summary>
        public DateTime lastPING = DateTime.Now.AddHours(-1);

        /// <summary>
        /// DataOra ultima lettura da PLC
        /// </summary>
        public DateTime lastReadPLC;

        /// <summary>
        /// ULtimo valore inviato (in caso di disconnessione lo reinvia x garantire watchdog...)
        /// </summary>
        public string lastSignInVal = "";

        /// <summary>
        /// DateTime Ultimo valore simulazione generato
        /// </summary>
        public DateTime lastSim;

        /// <summary>
        /// dataOra ultimo segnale inviato al SERVER...
        /// </summary>
        public DateTime lastWatchDog;

        /// <summary>
        /// dataOra ultimo segnale inviato a macchina/PLC...
        /// </summary>
        public DateTime lastWatchDogPLC = DateTime.Now;

        /// <summary>
        /// Massimo numero di px da inviare in blocco
        /// </summary>
        public int maxSendPzCountBlock = 10;

        /// <summary>
        /// Struttura memoria PLC x lettura/scrittura da JSON file
        /// </summary>
        public plcMemMapExt memMap;

        /// <summary>
        /// Minimo numero di px da inviare in blocco
        /// </summary>
        public int minSendPzCountBlock = 5;

        /// <summary>
        /// Variabile booleana che indica se sia necessario fare refresh del contapezzi
        /// </summary>
        public bool needRefreshPzCount = true;

        /// <summary>
        /// Dizionario di persistenza per i valori da salvare da/su file
        /// </summary>
        public Dictionary<string, string> persistenceLayer;

        /// <summary>
        /// Determina se utilizzare blocchi di memoria IOT contigui (e quindi processing
        /// "monoblocco" semplificato"=
        /// </summary>
        public bool procIotMem = false;

        /// <summary>
        /// Coda valori ALLARMI ove gestiti...
        /// </summary>
        public DataQueue QueueAlarm = new DataQueue("000", "QueueAlarm", false);

        //public ConcurrentQueue<string> QueueAlarm = new ConcurrentQueue<string>();

        /// <summary>
        /// Oggetto della coda degli elementi letti di tipo FluxLog (e non ancora trasmessi)
        /// </summary>
        public DataQueue QueueFLog = new DataQueue("000", "QueueFLog", false);

        //public ConcurrentQueue<string> QueueFLog = new ConcurrentQueue<string>();

        /// <summary>
        /// Oggetto della coda degli elementi letti (e non ancora trasmessi)
        /// </summary>
        public DataQueue QueueIN = new DataQueue("000", "QueueIN", false);

        //public ConcurrentQueue<string> QueueIN = new ConcurrentQueue<string>();

        /// <summary>
        /// Coda valori MESSAGGI/EVENTI (da non sottocampionare come samples)...
        /// </summary>
        public DataQueue QueueMessages = new DataQueue("000", "QueueMessages", false);

        //public ConcurrentQueue<string> QueueMessages = new ConcurrentQueue<string>();

        /// <summary>
        /// Oggetto della coda degli elementi di tipo RawTransf (e non ancora trasmessi)
        /// NB: sono salvati serializzati come stringhe
        /// </summary>
        public DataQueue QueueRawTransf = new DataQueue("000", "QueueRawTransf", false);

        //public ConcurrentQueue<string> QueueRawTransf = new ConcurrentQueue<string>();

        /// <summary>
        /// Coda valori LOG UTENTE (da non sottocampionare come samples)...
        /// </summary>
        public DataQueue QueueULog = new DataQueue("000", "QueueULog", false);

        //public ConcurrentQueue<string> QueueULog = new ConcurrentQueue<string>();

        /// <summary>
        /// alias booleano false = R
        /// </summary>
        public bool R = false;

        /// <summary>
        /// 32 byte input base (es strobe, 8 word da 32 bit di flags...)
        /// </summary>
        public byte[] RawInput = new byte[32];

        /// <summary>
        /// 32 byte output base (es ack, 8 word da 32 bit di flags...)
        /// </summary>
        public byte[] RawOutput = new byte[32];

        /// <summary>
        /// Oggetto connessione REDIS
        /// </summary>
        public RedisIobCache redisMan;

        /// <summary>
        /// Oggetto cronometro x campionamento durate chiamate
        /// </summary>
        public Stopwatch stopwatch = new Stopwatch();

        /// <summary>
        /// Oggetto gestione TempiCiclo e contapezzi
        /// </summary>
        public TCMan tcMan = new TCMan(0.5, 1.3, 5);

        /// <summary>
        /// Imposta veto lettura dati (es per DB a 2 sec)
        /// </summary>
        public DateTime vetoDataRead = DateTime.Now;

        /// <summary>
        /// Imposta veto SYNC dati (es per DB 2 DB a 10 sec)
        /// </summary>
        public DateTime vetoDataSync = DateTime.Now;

        /// <summary>
        /// Imposta veto chiamata split (durante chiamata, per 60 sec)
        /// </summary>
        public DateTime vetoSplit = DateTime.Now.AddMinutes(1);

        /// <summary>
        /// alias booleano true = W
        /// </summary>
        public bool W = true;

        #endregion Public Fields

        #region Protected Fields

        /// <summary>
        /// wrapper di log
        /// </summary>
        protected static Logger lg;

        /// <summary>
        /// Ultimo LOG registrazione avvio (x ridurre log notturni...)
        /// </summary>
        protected DateTime lastLogStartup = DateTime.Today.AddHours(-1);

        /// <summary>
        /// Form chiamante
        /// </summary>
        protected AdapterForm parentForm;

        /// <summary>
        /// Veto per registrazione completa log di startup (minuti)
        /// </summary>
        protected int vetoLogStartupDuration = 60;

        #endregion Protected Fields

        #region Protected Properties

        /// <summary>
        /// Dizionario condizioni di veto log x ogni tipo di messaggio (periodo differente secondo livello)
        /// </summary>
        protected Dictionary<string, DateTime> VetoLog { get; set; } = new Dictionary<string, DateTime>();

        /// <summary>
        /// Dizionario conteggio numero volte che si fa veto log x ogni tipo di messaggio
        /// </summary>
        protected Dictionary<string, int> VetoLogCount { get; set; } = new Dictionary<string, int>();

        #endregion Protected Properties

        #region Protected Methods

        /// <summary>
        /// Effettua logging DEBUG corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        protected void lgDebug(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(20, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Debug(message);
                if (sendToForm)
                {
                    sendToLogWatch("DEBUG", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging DEBUG corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgDebug(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(20, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Debug(message, args);
                sendToLogWatch("DEBUG", message, args);
            }
        }

        /// <summary>
        /// Effettua logging ERROR corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        protected void lgError(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(2, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Error(message);
                if (sendToForm)
                {
                    sendToLogWatch("ERROR", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging ERROR corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgError(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(2, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Error(message, args);
                sendToLogWatch("ERROR", message, args);
            }
        }

        /// <summary>
        /// Effettua logging ERROR corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="exception"></param>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgError(Exception exception, string message, params object[] args)
        {
            bool doVeto = checkLogVeto(2, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Error(exception, message, args);
                sendToLogWatch("ERROR", message, exception, args);
            }
        }

        /// <summary>
        /// Effettua logging FATAL corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        protected void lgFatal(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(1, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Fatal(message);
                if (sendToForm)
                {
                    sendToLogWatch("FATAL", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging FATAL corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgFatal(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(1, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Fatal(message, args);
                sendToLogWatch("FATAL", message, args);
            }
        }

        /// <summary>
        /// Effettua logging FATAL corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="exception"></param>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgFatal(Exception exception, string message, params object[] args)
        {
            bool doVeto = checkLogVeto(1, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Fatal(exception, message, args);
                sendToLogWatch("FATAL", message, exception, args);
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        protected void lgInfo(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(30, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Info(message);
                if (sendToForm)
                {
                    sendToLogWatch("INFO", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgInfo(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(30, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Info(message, args);
                sendToLogWatch("INFO", message, args);
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="sendToForm"></param>
        protected void lgInfoStartup(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(30, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                DateTime adesso = DateTime.Now;
                if (adesso.Subtract(lastLogStartup).TotalMinutes > vetoLogStartupDuration)
                {
                    lg.Info(message);
                    // se supera di 5 minutis cadenza -_> reimposto veto...
                    if (adesso.Subtract(lastLogStartup).TotalMinutes > vetoLogStartupDuration + 5)
                    {
                        lastLogStartup = adesso;
                    }
                }
                if (sendToForm)
                {
                    sendToLogWatch("INFO", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgInfoStartup(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(30, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                DateTime adesso = DateTime.Now;
                if (adesso.Subtract(lastLogStartup).TotalMinutes > vetoLogStartupDuration)
                {
                    lg.Info(message, args);
                    // se supera di 5 minutis cadenza -_> reimposto veto...
                    if (adesso.Subtract(lastLogStartup).TotalMinutes > vetoLogStartupDuration + 5)
                    {
                        lastLogStartup = adesso;
                    }
                }
                sendToLogWatch("INFO", message, args);
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        protected void lgTrace(string message, bool sendToForm = true)
        {
            bool doVeto = checkLogVeto(60, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Trace(message);
                if (sendToForm)
                {
                    sendToLogWatch("TRACE", message);
                }
            }
        }

        /// <summary>
        /// Effettua logging INFO corretto impostanto anche la variabile IOB prima di scrivere...
        /// </summary>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void lgTrace(string message, params object[] args)
        {
            bool doVeto = checkLogVeto(60, ref message);
            // se non ho veto --> loggo
            if (!doVeto)
            {
                lg.Factory.Configuration.Variables["codIOB"] = cIobConf.codIOB;
                lg.Trace(message, args);
                sendToLogWatch("TRACE", message, args);
            }
        }

        /// <summary>
        /// Invia messaggio a logWatcher
        /// </summary>
        /// <param name="messType"></param>
        /// <param name="message"></param>
        protected void sendToLogWatch(string messType, string message)
        {
            newDisplayData currDispData = new newDisplayData();
            currDispData.newLiveLogData = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} | {messType} | {message}";
            parentForm.updateFormDisplay(currDispData);
        }

        /// <summary>
        /// Invia messaggio a logWatcher
        /// </summary>
        /// <param name="messType"></param>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void sendToLogWatch(string messType, string message, params object[] args)
        {
            try
            {
                string expString = string.Format(message, args);
                newDisplayData currDispData = new newDisplayData();
                currDispData.newLiveLogData = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} | {messType} | {expString}";
                parentForm.updateFormDisplay(currDispData);
            }
            catch
            { }
        }

        /// <summary>
        /// Invia messaggio a logWatcher
        /// </summary>
        /// <param name="messType"></param>
        /// <param name="exception"></param>
        /// <param name="message"></param>
        /// <param name="args"></param>
        protected void sendToLogWatch(string messType, string message, Exception exception, params object[] args)
        {
            try
            {
                string expString = string.Format(message, args);
                newDisplayData currDispData = new newDisplayData();
                currDispData.newLiveLogData = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} | {messType} | {expString}{Environment.NewLine}{exception}";
                parentForm.updateFormDisplay(currDispData);
            }
            catch
            { }
        }

        #endregion Protected Methods

        #region Private Methods

        /// <summary>
        /// Verifica se ci sia veto log attivo e gestisce casistiche
        /// </summary>
        /// <param name="vetoSec"></param>
        /// <param name="message"></param>
        /// <returns></returns>
        private bool checkLogVeto(int vetoSec, ref string message)
        {
            //verifico SE si debba fare log, altrimenti metto in coda...
            bool doVeto = true;
            DateTime adesso = DateTime.Now;
            if (VetoLog.ContainsKey(message))
            {
                // conteggio num veto a +1...
                if (VetoLogCount.ContainsKey(message))
                {
                    VetoLogCount[message]++;
                }
                else
                {
                    VetoLogCount.Add(message, 1);
                }
                // controllo scadenza, quando superata soglia aggiorno messaggio con {n} x {messaggio}
                if (adesso.Subtract(VetoLog[message]).TotalSeconds > vetoSec)
                {
                    doVeto = false;
                    string newMessage = $"{VetoLogCount[message]} x {message}";
                    VetoLog.Remove(message);
                    VetoLogCount.Remove(message);
                    message = newMessage;
                }
            }
            else
            {
                // primo --> loggo
                doVeto = false;
                VetoLog.Add(message, adesso.AddSeconds(vetoSec));
                VetoLogCount.Add(message, 0);
            }
            // restituisco esito!
            return doVeto;
        }

        #endregion Private Methods
    }
}