StatisticsLibrary.java

/*
 * GovWay - A customizable API Gateway 
 * https://govway.org
 * 
 * Copyright (c) 2005-2025 Link.it srl (https://link.it).
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3, as published by
 * the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
package org.openspcoop2.monitor.engine.statistic;

import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerBase;

/**
 * StatisticsLibrary
 *
 * @author Poli Andrea (apoli@link.it)
 * @author $Author$
 * @version $Rev$, $Date$
 */
public class StatisticsLibrary {

    private StatisticsConfig config;
    private org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM;
    private org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM;
    private org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager pluginsStatisticheSM;
    private org.openspcoop2.core.plugins.dao.IServiceManager pluginsBaseSM;
    private org.openspcoop2.core.commons.search.dao.IServiceManager utilsSM;
    private org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager pluginsTransazioniSM;
    
    private static final String ERRORE = "Errore durante la generazione delle statistiche: ";
    
    public StatisticsLibrary(StatisticsConfig config,
            org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM,
            org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM,
            org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager pluginsStatisticheSM,
            org.openspcoop2.core.plugins.dao.IServiceManager pluginsBaseSM,
            org.openspcoop2.core.commons.search.dao.IServiceManager utilsSM,
            org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager pluginsTransazioniSM){
        this.config = config;
        this.statisticheSM = statisticheSM;
        this.transazioniSM = transazioniSM;
        this.pluginsStatisticheSM = pluginsStatisticheSM;
        this.pluginsBaseSM = pluginsBaseSM;
        this.utilsSM = utilsSM;
        this.pluginsTransazioniSM = pluginsTransazioniSM;
    }
    
    public void close() {
        if(this.statisticheSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.statisticheSM,"Statistiche");
        }
        if(this.transazioniSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.transazioniSM,"Transazioni");
        }
        if(this.utilsSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.utilsSM,"Utils");
        }
        if(this.pluginsBaseSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.pluginsBaseSM,"PluginBase");
        }
        if(this.pluginsStatisticheSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.pluginsStatisticheSM,"PluginStatistiche");
        }
        if(this.pluginsTransazioniSM instanceof JDBCServiceManagerBase) {
            closeEngine((JDBCServiceManagerBase)this.pluginsTransazioniSM,"PluginTransazioni");
        }
    }
    private void closeEngine(JDBCServiceManagerBase serviceManager, String tipo) {
        try {
            serviceManager.close();
        }catch(Exception t) {
            String msgError = "Rilascio connessione '"+tipo+"' fallita: "+t.getMessage();
            if(this.config.getLogSql()!=null) {
                this.config.getLogSql().error(msgError, t);
            }
            else if(this.config.getLogCore()!=null) {
                this.config.getLogCore().error(msgError, t);
            }
            else {
                t.printStackTrace(System.err);
            }
        }
    }
    
    public void generateStatisticaOraria(){
        try{
            
            if(this.config.isStatisticheOrarie()){
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche orarie ....");
                }
                StatisticheOrarie sg = new StatisticheOrarie( this.config.getLogCore(), this.config.isDebug(), 
                        this.config.isUseUnionForLatency(),
                        this.config.isGenerazioneStatisticheCustom(),
                        this.config.isAnalisiTransazioniCustom(),
                        this.config.getForceIndexConfig(),
                        this.statisticheSM, this.transazioniSM, 
                        this.pluginsStatisticheSM, this.pluginsBaseSM, this.utilsSM, this.pluginsTransazioniSM );
                sg.generaStatistiche( this.config.isStatisticheOrarieGestioneUltimoIntervallo(),
                        this.config.getWaitMsBeforeNextInterval(),
                        this.config.isWaitStatiInConsegna());
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche orarie  terminata");
                }
            }else{
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Thread per generazione statistiche orarie disabilitato");
                }
            }
            
        }catch(Exception e){
            String msg = ERRORE+e.getMessage();
            this.config.getLogCore().error(msg,e);
        } 
    }
    
    public void generateStatisticaGiornaliera(){
        try{
            
            if(this.config.isStatisticheGiornaliere()){
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche giornaliere ....");
                }
                StatisticheGiornaliere sg = new StatisticheGiornaliere( this.config.getLogCore(), this.config.isDebug(), 
                        this.config.isUseUnionForLatency(),
                        this.config.isGenerazioneStatisticheCustom(),
                        this.config.isAnalisiTransazioniCustom(),
                        this.config.getForceIndexConfig(),
                        this.statisticheSM, this.transazioniSM, 
                        this.pluginsStatisticheSM, this.pluginsBaseSM, this.utilsSM, this.pluginsTransazioniSM );
                sg.generaStatistiche( this.config.isStatisticheGiornaliereGestioneUltimoIntervallo(),
                        this.config.getWaitMsBeforeNextInterval(),
                        this.config.isWaitStatiInConsegna() );
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche giornaliere  terminata");
                }
            }else{
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Thread per generazione statistiche giornaliere disabilitato");
                }
            }
            
        }catch(Exception e){
            this.config.getLogCore().error(ERRORE+e.getMessage(),e);
        } 
    }
            
    public void generateStatisticaSettimanale(){
        try{
            if(this.config.isStatisticheSettimanali()){
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche settimanali ....");
                }
                StatisticheSettimanali sg = new StatisticheSettimanali( this.config.getLogCore(), this.config.isDebug(), 
                        this.config.isUseUnionForLatency(),
                        this.config.isGenerazioneStatisticheCustom(),
                        this.config.isAnalisiTransazioniCustom(),
                        this.config.getForceIndexConfig(),
                        this.statisticheSM, this.transazioniSM, 
                        this.pluginsStatisticheSM, this.pluginsBaseSM, this.utilsSM, this.pluginsTransazioniSM );
                sg.generaStatistiche( this.config.isStatisticheSettimanaliGestioneUltimoIntervallo(),
                        this.config.getWaitMsBeforeNextInterval(),
                        this.config.isWaitStatiInConsegna() );
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche settimanali  terminata");
                }
            }else{
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Thread per generazione statistiche settimanali disabilitato");
                }
            }
        }catch(Exception e){
            this.config.getLogCore().error(ERRORE+e.getMessage(),e);
        } 
    }
            
    public void generateStatisticaMensile(){
        try{
            if(this.config.isStatisticheMensili()){
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche mensili ....");
                }
                StatisticheMensili sg = new StatisticheMensili( this.config.getLogCore(), this.config.isDebug(), 
                        this.config.isUseUnionForLatency(),
                        this.config.isGenerazioneStatisticheCustom(),
                        this.config.isAnalisiTransazioniCustom(),
                        this.config.getForceIndexConfig(),
                        this.statisticheSM, this.transazioniSM, 
                        this.pluginsStatisticheSM, this.pluginsBaseSM, this.utilsSM, this.pluginsTransazioniSM );
                sg.generaStatistiche( this.config.isStatisticheMensiliGestioneUltimoIntervallo(),
                        this.config.getWaitMsBeforeNextInterval(),
                        this.config.isWaitStatiInConsegna() );
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Esecuzione thread per generazione statistiche mensili  terminata");
                }
            }else{
                if(this.config.isDebug()){
                    this.config.getLogCore().debug("Thread per generazione statistiche mensili disabilitato");
                }
            }
            
        }catch(Exception e){
            this.config.getLogCore().error(ERRORE+e.getMessage(),e);
        } 
    }
    
}