TimerStatisticheLib.java

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

  21. package org.openspcoop2.pdd.timers;


  24. import java.sql.Connection;

  26. import org.openspcoop2.core.commons.dao.DAOFactory;
  27. import org.openspcoop2.core.commons.dao.DAOFactoryProperties;
  28. import org.openspcoop2.core.config.driver.IDriverConfigurazioneGet;
  29. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  30. import org.openspcoop2.core.statistiche.constants.TipoIntervalloStatistico;
  31. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  32. import org.openspcoop2.monitor.engine.statistic.StatisticsConfig;
  33. import org.openspcoop2.monitor.engine.statistic.StatisticsLibrary;
  34. import org.openspcoop2.pdd.config.ConfigurazionePdDReader;
  35. import org.openspcoop2.pdd.config.DBStatisticheManager;
  36. import org.openspcoop2.pdd.config.DBTransazioniManager;
  37. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  38. import org.openspcoop2.pdd.config.Resource;
  39. import org.openspcoop2.pdd.core.CostantiPdD;
  40. import org.openspcoop2.pdd.core.GestoreMessaggi;
  41. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  42. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  43. import org.openspcoop2.pdd.services.OpenSPCoop2Startup;
  44. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  45. import org.openspcoop2.protocol.engine.constants.Costanti;
  46. import org.openspcoop2.protocol.utils.ModIUtils;
  47. import org.openspcoop2.utils.TipiDatabase;
  48. import org.openspcoop2.utils.Utilities;
  49. import org.openspcoop2.utils.date.DateManager;
  50. import org.openspcoop2.utils.id.serial.InfoStatistics;
  51. import org.openspcoop2.utils.semaphore.Semaphore;
  52. import org.openspcoop2.utils.semaphore.SemaphoreConfiguration;
  53. import org.openspcoop2.utils.semaphore.SemaphoreMapping;
  54. import org.slf4j.Logger;


  57. /**     
  58.  * TimerStatisticheLib
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */
  64. public class TimerStatisticheLib {

  66.     private static TimerState STATE_STATISTICHE_ORARIE = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  67.     public static TimerState getSTATE_STATISTICHE_ORARIE() {
  68.         return STATE_STATISTICHE_ORARIE;
  69.     }
  70.     public static void setSTATE_STATISTICHE_ORARIE(TimerState sTATE_STATISTICHE_ORARIE) {
  71.         STATE_STATISTICHE_ORARIE = sTATE_STATISTICHE_ORARIE;
  72.     }

  74.     private static TimerState STATE_STATISTICHE_GIORNALIERE = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  75.     public static TimerState getSTATE_STATISTICHE_GIORNALIERE() {
  76.         return STATE_STATISTICHE_GIORNALIERE;
  77.     }
  78.     public static void setSTATE_STATISTICHE_GIORNALIERE(TimerState sTATE_STATISTICHE_GIORNALIERE) {
  79.         STATE_STATISTICHE_GIORNALIERE = sTATE_STATISTICHE_GIORNALIERE;
  80.     }

  82.     private static TimerState STATE_STATISTICHE_SETTIMANALI = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  83.     public static TimerState getSTATE_STATISTICHE_SETTIMANALI() {
  84.         return STATE_STATISTICHE_SETTIMANALI;
  85.     }
  86.     public static void setSTATE_STATISTICHE_SETTIMANALI(TimerState sTATE_STATISTICHE_SETTIMANALI) {
  87.         STATE_STATISTICHE_SETTIMANALI = sTATE_STATISTICHE_SETTIMANALI;
  88.     }

  90.     private static TimerState STATE_STATISTICHE_MENSILI = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  91.     public static TimerState getSTATE_STATISTICHE_MENSILI() {
  92.         return STATE_STATISTICHE_MENSILI;
  93.     }
  94.     public static void setSTATE_STATISTICHE_MENSILI(TimerState sTATE_STATISTICHE_MENSILI) {
  95.         STATE_STATISTICHE_MENSILI = sTATE_STATISTICHE_MENSILI;
  96.     }
  97.     
  98.     private static TimerState STATE_PDND_TRACCIAMENTO_PUBBLICAZIONE = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  99.     public static TimerState getSTATE_PDND_TRACCIAMENTO_PUBBLICAZIONE() {
  100.         return STATE_PDND_TRACCIAMENTO_PUBBLICAZIONE;
  101.     }
  102.     public static void setSTATE_PDND_TRACCIAMENTO_PUBBLICAZIONE(TimerState sTATE_PDND_TRACCIAMENTO_PUBBLICAZIONE) {
  103.         STATE_PDND_TRACCIAMENTO_PUBBLICAZIONE = sTATE_PDND_TRACCIAMENTO_PUBBLICAZIONE;
  104.     }

  106.     private static TimerState STATE_PDND_TRACCIAMENTO_GENERAZIONE = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  107.     public static TimerState getSTATE_PDND_TRACCIAMENTO_GENERAZIONE() {
  108.         return STATE_PDND_TRACCIAMENTO_GENERAZIONE;
  109.     }
  110.     public static void setSTATE_PDND_TRACCIAMENTO_GENERAZIONE(TimerState sTATE_PDND_TRACCIAMENTO_GENERAZIONE) {
  111.         STATE_PDND_TRACCIAMENTO_GENERAZIONE = sTATE_PDND_TRACCIAMENTO_GENERAZIONE;
  112.     }

  114.     /** Logger utilizzato per debug. */
  115.     private Logger logCore = null;
  116.     private Logger logSql = null;
  117.     private Logger logTimer = null;
  118.     private MsgDiagnostico msgDiag = null;

  120.     /** OpenSPCoop2Properties */
  121.     private OpenSPCoop2Properties op2Properties = null;
  122.     
  123.     /** Indicazione se devono essere generate le statistiche custom */
  124.     private boolean generazioneStatisticheCustom = false;
  125.     private boolean analisiTransazioniCustom = false;
  126.     
  127.     /** Indicazione se deve essere effettuato il log delle query */
  128.     private boolean debug = false;  
  129.     
  130.     /** Indicazione se deve essere usata la union per calcolare i tempi di latenza */
  131.     private boolean useUnionForLatency = false; 
  132.     
  133.     /** Intervallo di attesa prima di passare al prossimo intervallo */
  134.     private long waitMsBeforeNextInterval = -1;
  135.     
  136.     /** Attesa che tutte le transazioni siano state consegnate con successo prima di passare al prossimo intervallo */
  137.     private boolean waitStatiInConsegna = false;
  138.     
  139.     /** Tipologie di statistiche */
  140.     private TipoIntervalloStatistico tipoStatistica;
  141.     private boolean statisticheOrarie = false;
  142.     private boolean statisticheGiornaliere = false;
  143.     private boolean statisticheSettimanali = false;
  144.     private boolean statisticheMensili = false;
  145.     private boolean tracciamentoPdndGenerazione = false;
  146.     private boolean tracciamentoPdndPubblicazione = false;
  147.     
  148.     /** Tipologie di statistiche: gestione ultimo intervallo */
  149.     private boolean statisticheOrarie_gestioneUltimoIntervallo = false;
  150.     private boolean statisticheGiornaliere_gestioneUltimoIntervallo = false;
  151.     private boolean statisticheSettimanali_gestioneUltimoIntervallo = false;
  152.     private boolean statisticheMensili_gestioneUltimoIntervallo = false;
  153.     
  154.     /** Database */
  155. //  private DataSource ds = null;
  156. //  private String datasource = null;
  157.     private String tipoDatabase = null; //tipoDatabase
  158.     private DAOFactory daoFactory = null;
  159.     private Logger daoFactoryLogger = null;
  160.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni = null;
  161.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesStatistiche = null;
  162.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsStatistiche = null;
  163.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsBase = null;
  164.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesUtils = null;
  165.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsTransazioni = null;

  167.     /** StatisticsConfig */
  168.     private StatisticsConfig statisticsConfig;
  169.     
  170.     /** Timer */
  171.     private TimerLock timerLock = null;

  173.     /** Semaforo */
  174.     private Semaphore semaphore = null;
  175.     private InfoStatistics semaphore_statistics;

  177.     
  178.     
  179.     /** Costruttore */
  180.     public TimerStatisticheLib(TipoIntervalloStatistico tipoStatistica, MsgDiagnostico msgDiag,Logger logTimer,OpenSPCoop2Properties p) throws Exception{
  181.     
  182.         this.msgDiag = msgDiag;
  183.         this.op2Properties = p;
  184.         
  185.         this.debug = this.op2Properties.isStatisticheGenerazioneDebug();
  186.         
  187.         this.logCore = OpenSPCoop2Logger.getLoggerOpenSPCoopStatistiche(tipoStatistica, this.debug);
  188.         this.logSql = OpenSPCoop2Logger.getLoggerOpenSPCoopStatisticheSql(tipoStatistica, this.debug);
  189.         this.logTimer = logTimer;
  190.         
  191.         this.useUnionForLatency = this.op2Properties.isStatisticheGenerazioneUseUnionForLatency();
  192.         this.generazioneStatisticheCustom = this.op2Properties.isStatisticheGenerazioneCustomEnabled();
  193.         this.analisiTransazioniCustom = this.op2Properties.isStatisticheGenerazioneCustomSdkEnabled();
  194.         
  195.         this.tipoStatistica = tipoStatistica;
  196.         
  197.         switch (this.tipoStatistica) {
  198.         case STATISTICHE_ORARIE:
  199.             this.statisticheOrarie = this.op2Properties.isStatisticheGenerazioneBaseOrariaEnabled();
  200.             this.statisticheOrarie_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseOrariaEnabledUltimaOra();
  201.             break;
  202.         case STATISTICHE_GIORNALIERE:
  203.             this.statisticheGiornaliere = this.op2Properties.isStatisticheGenerazioneBaseGiornalieraEnabled();
  204.             this.statisticheGiornaliere_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseGiornalieraEnabledUltimoGiorno();
  205.             break;
  206.         case STATISTICHE_SETTIMANALI:
  207.             this.statisticheSettimanali = this.op2Properties.isStatisticheGenerazioneBaseSettimanaleEnabled();
  208.             this.statisticheSettimanali_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseSettimanaleEnabledUltimaSettimana();
  209.             break;
  210.         case STATISTICHE_MENSILI:
  211.             this.statisticheMensili = this.op2Properties.isStatisticheGenerazioneBaseMensileEnabled();
  212.             this.statisticheMensili_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseMensileEnabledUltimoMese();
  213.             break;
  214.         case PDND_GENERAZIONE_TRACCIAMENTO:
  215.             this.tracciamentoPdndGenerazione = this.op2Properties.isStatistichePdndTracciamentoGenerazioneEnabled();
  216.             break;
  217.         case PDND_PUBBLICAZIONE_TRACCIAMENTO:
  218.             this.tracciamentoPdndPubblicazione = this.op2Properties.isStatistichePdndTracciamentoPubblicazioneEnabled();
  219.             break;
  220.         }
  221.         
  222.         this.waitStatiInConsegna = this.op2Properties.isStatisticheGenerazioneAttendiCompletamentoTransazioniInFasiIntermedie();
  223.         this.waitMsBeforeNextInterval = this.op2Properties.getStatisticheGenerazioneTradeOffMs();
  224.                 
  225.         try{
  226.             
  227.             // se avviato il thread le statistiche devono essere nella base dati delle transazioni (altrimenti si usa il batch)
  228.             this.tipoDatabase = this.op2Properties.getDatabaseType();
  229.             if(this.tipoDatabase==null){
  230.                 throw new Exception("Tipo Database non definito");
  231.             }
  232.             
  233.             String tipoDatabaseTransazioni = DBTransazioniManager.getInstance().getTipoDatabase();
  234.             if(tipoDatabaseTransazioni==null){
  235.                 throw new Exception("Tipo Database Transazioni non definito");
  236.             }

  238.             // Inizializzazione datasource
  239. //          GestoreJNDI jndi = new GestoreJNDI();
  240. //          this.ds = (DataSource) jndi.lookup(this.datasource);
  241.         
  242.             // DAOFactory
  243.             DAOFactoryProperties daoFactoryProperties = null;
  244.             this.daoFactoryLogger = this.logSql;
  245.             this.daoFactory = DAOFactory.getInstance(this.daoFactoryLogger);
  246.             daoFactoryProperties = DAOFactoryProperties.getInstance(this.daoFactoryLogger);
  247.             
  248.             this.daoFactoryServiceManagerPropertiesTransazioni = 
  249.                     daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  250.             this.daoFactoryServiceManagerPropertiesTransazioni.setShowSql(this.debug);  
  251.             this.daoFactoryServiceManagerPropertiesTransazioni.setDatabaseType(tipoDatabaseTransazioni);
  252.             
  253.             this.daoFactoryServiceManagerPropertiesStatistiche = 
  254.                     daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance());
  255.             this.daoFactoryServiceManagerPropertiesStatistiche.setShowSql(this.debug);  
  256.             this.daoFactoryServiceManagerPropertiesStatistiche.setDatabaseType(tipoDatabaseTransazioni);
  257.             
  258.             if(this.generazioneStatisticheCustom){
  259.             
  260.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche = 
  261.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.monitor.engine.config.statistiche.utils.ProjectInfo.getInstance());
  262.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche.setShowSql(this.debug);   
  263.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche.setDatabaseType(this.tipoDatabase);
  264.                 
  265.                 this.daoFactoryServiceManagerPropertiesPluginsBase = 
  266.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance());
  267.                 this.daoFactoryServiceManagerPropertiesPluginsBase.setShowSql(this.debug);  
  268.                 this.daoFactoryServiceManagerPropertiesPluginsBase.setDatabaseType(this.tipoDatabase);
  269.                 
  270.                 this.daoFactoryServiceManagerPropertiesUtils = 
  271.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.commons.search.utils.ProjectInfo.getInstance());
  272.                 this.daoFactoryServiceManagerPropertiesUtils.setShowSql(this.debug);    
  273.                 this.daoFactoryServiceManagerPropertiesUtils.setDatabaseType(this.tipoDatabase);
  274.                 
  275.                 if(this.analisiTransazioniCustom){
  276.                 
  277.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni = 
  278.                             daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.monitor.engine.config.transazioni.utils.ProjectInfo.getInstance());
  279.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni.setShowSql(this.debug);   
  280.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni.setDatabaseType(this.tipoDatabase);
  281.                     
  282.                 }
  283.                 
  284.             }
  285.                 
  286.         }catch(Exception e){
  287.             throw new Exception("Errore durante l'inizializzazione del datasource: "+e.getMessage(),e);
  288.         }
  289.         
  290.         
  291.         try{
  292.             this.statisticsConfig = new StatisticsConfig(false);
  293.             
  294.             this.statisticsConfig.setLogCore(this.logCore);
  295.             this.statisticsConfig.setLogSql(this.logSql);
  296.             this.statisticsConfig.setGenerazioneStatisticheCustom(this.generazioneStatisticheCustom);
  297.             this.statisticsConfig.setAnalisiTransazioniCustom(this.analisiTransazioniCustom);
  298.             this.statisticsConfig.setDebug(this.debug);
  299.             this.statisticsConfig.setUseUnionForLatency(this.useUnionForLatency);
  300.             this.statisticsConfig.setStatisticheOrarie(this.statisticheOrarie);
  301.             this.statisticsConfig.setStatisticheGiornaliere(this.statisticheGiornaliere);
  302.             this.statisticsConfig.setStatisticheSettimanali(this.statisticheSettimanali);
  303.             this.statisticsConfig.setStatisticheMensili(this.statisticheMensili);
  304.             this.statisticsConfig.setStatisticheOrarieGestioneUltimoIntervallo(this.statisticheOrarie_gestioneUltimoIntervallo);
  305.             this.statisticsConfig.setStatisticheGiornaliereGestioneUltimoIntervallo(this.statisticheGiornaliere_gestioneUltimoIntervallo);
  306.             this.statisticsConfig.setStatisticheSettimanaliGestioneUltimoIntervallo(this.statisticheSettimanali_gestioneUltimoIntervallo);
  307.             this.statisticsConfig.setStatisticheMensiliGestioneUltimoIntervallo(this.statisticheMensili_gestioneUltimoIntervallo);
  308.             this.statisticsConfig.setWaitMsBeforeNextInterval(this.waitMsBeforeNextInterval);
  309.             this.statisticsConfig.setWaitStatiInConsegna(this.waitStatiInConsegna);
  310.             
  311.             if(ProtocolFactoryManager.getInstance().existsProtocolFactory(Costanti.MODIPA_PROTOCOL_NAME) 
  312.                     &&
  313.                     ModIUtils.isTracingPDNDEnabled()) {
  314.                 this.statisticsConfig.setPdndTracciamentoGenerazione(this.tracciamentoPdndGenerazione);
  315.                 this.statisticsConfig.setPdndTracciamentoPubblicazione(this.tracciamentoPdndPubblicazione);
  316.             }
  317.             else {
  318.                 this.statisticsConfig.setPdndTracciamentoGenerazione(false);
  319.                 this.statisticsConfig.setPdndTracciamentoPubblicazione(false);
  320.             }
  321.             this.statisticsConfig.setPdndTracciamentoErogazioniEnabled(this.op2Properties.isStatistichePdndTracciamentoErogazioniEnabled());
  322.             this.statisticsConfig.setPdndTracciamentoFruizioniEnabled(this.op2Properties.isStatistichePdndTracciamentoFruizioniEnabled());
  323.             this.statisticsConfig.setPdndTracciamentoRequestConfig(this.op2Properties.getStatistichePdndTracciamentoHttpRequestConfig());
  324.             this.statisticsConfig.setPdndTracciamentoSoggettiEnabled(this.op2Properties.getStatistichePdndTracciamentoSoggettiEnabled());
  325.             this.statisticsConfig.setPdndTracciamentoSoggettiDisabled(this.op2Properties.isStatistichePdndTracciamentoSoggettiDisabled());
  326.             this.statisticsConfig.setPdndTracciamentoMaxAttempt(this.op2Properties.getStatistichePdndTracciamentoMaxAttempts());
  327.             this.statisticsConfig.setPdndTracciamentoPendingCheck(this.op2Properties.getStatistichePdndTracciamentoPendingCheck());
  328.         }catch(Exception e){
  329.             throw new Exception("Errore durante la generazione delle statistiche (InitConfigurazione): "+e.getMessage(),e);
  330.         }
  331.         
  332.         switch (this.tipoStatistica) {
  333.         case STATISTICHE_ORARIE:
  334.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_ORARIE); 
  335.             break;
  336.         case STATISTICHE_GIORNALIERE:
  337.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_GIORNALIERE); 
  338.             break;
  339.         case STATISTICHE_SETTIMANALI:
  340.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_SETTIMANALI); 
  341.             break;
  342.         case STATISTICHE_MENSILI:
  343.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_MENSILI); 
  344.             break;
  345.         case PDND_GENERAZIONE_TRACCIAMENTO:
  346.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_PDND_TRACCIAMENTO_GENERAZIONE); 
  347.             break;
  348.         case PDND_PUBBLICAZIONE_TRACCIAMENTO:
  349.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_PDND_TRACCIAMENTO_PUBBLICAZIONE); 
  350.             break;
  351.         }
  352.         
  353.         if(this.op2Properties.isTimerLockByDatabase()) {
  354.             this.semaphore_statistics = new InfoStatistics();

  356.             SemaphoreConfiguration config = GestoreMessaggi.newSemaphoreConfiguration(this.op2Properties.getStatisticheGenerazioneTimerLockMaxLife(), 
  357.                     this.op2Properties.getStatisticheGenerazioneTimerLockIdleTime());

  359.             TipiDatabase databaseType = TipiDatabase.toEnumConstant(this.tipoDatabase);
  360.             try {
  361.                 this.semaphore = new Semaphore(this.semaphore_statistics, SemaphoreMapping.newInstance(this.timerLock.getIdLock()), 
  362.                         config, databaseType, this.logTimer);
  363.             }catch(Exception e) {
  364.                 throw new TimerException(e.getMessage(),e);
  365.             }
  366.         }
  367.     }
  368.     
  369.     public void check() throws TimerException {
  370.         
  371.         // Controllo che il sistema non sia andando in shutdown
  372.         if(OpenSPCoop2Startup.contextDestroyed){
  373.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Rilevato sistema in shutdown");
  374.             return;
  375.         }

  377.         // Controllo che l'inizializzazione corretta delle risorse sia effettuata
  378.         if(!OpenSPCoop2Startup.initialize){
  379.             this.msgDiag.logFatalError("inizializzazione di OpenSPCoop non effettuata", "Check Inizializzazione");
  380.             String msgErrore = "Riscontrato errore: inizializzazione del Timer o di OpenSPCoop non effettuata";
  381.             this.logTimer.error(msgErrore);
  382.             throw new TimerException(msgErrore);
  383.         }

  385.         // Controllo risorse di sistema disponibili
  386.         if( !TimerMonitoraggioRisorseThread.isRisorseDisponibili()){
  387.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Risorse di sistema non disponibili: "+TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile().getMessage(),TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile());
  388.             return;
  389.         }
  390.         if( !MsgDiagnostico.gestoreDiagnosticaDisponibile){
  391.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Sistema di diagnostica non disponibile: "+MsgDiagnostico.motivoMalfunzionamentoDiagnostici.getMessage(),MsgDiagnostico.motivoMalfunzionamentoDiagnostici);
  392.             return;
  393.         }
  394.         
  395.         boolean enabled = false;
  396.         switch (this.tipoStatistica) {
  397.         case STATISTICHE_ORARIE:
  398.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_ORARIE);
  399.             break;
  400.         case STATISTICHE_GIORNALIERE:
  401.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_GIORNALIERE);
  402.             break;
  403.         case STATISTICHE_SETTIMANALI:
  404.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_SETTIMANALI);
  405.             break;
  406.         case STATISTICHE_MENSILI:
  407.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_MENSILI);
  408.             break;
  409.         case PDND_GENERAZIONE_TRACCIAMENTO:
  410.             enabled = TimerState.ENABLED.equals(STATE_PDND_TRACCIAMENTO_GENERAZIONE);
  411.             break;
  412.         case PDND_PUBBLICAZIONE_TRACCIAMENTO:
  413.             enabled = TimerState.ENABLED.equals(STATE_PDND_TRACCIAMENTO_PUBBLICAZIONE);
  414.             break;
  415.         }
  416.         if(!enabled) {
  417.             this.msgDiag.logPersonalizzato("disabilitato");
  418.             this.logCore.info(this.msgDiag.getMessaggio_replaceKeywords("disabilitato"));
  419.             this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("disabilitato"));
  420.             return;
  421.         }
  422.         
  423.         
  424.         
  425.         this.msgDiag.logPersonalizzato("generazioneStatistiche");
  426.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche"));
  427.         long startControlloTimer = DateManager.getTimeMillis();
  428.             
  429.             
  430.         DBTransazioniManager dbTransazioniManager = null;
  431.         DBStatisticheManager dbStatisticheManager = null;
  432.         Resource rTransazioni = null;
  433.         Resource rStatistiche = null;
  434.         Connection conConfig = null;
  435.         DriverConfigurazioneDB driverConfigurazioneDB = null;
  436.         try{

  438.             dbTransazioniManager = DBTransazioniManager.getInstance();
  439.             rTransazioni = dbTransazioniManager.getResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, null);
  440.             if(rTransazioni==null){
  441.                 throw new Exception("Risorsa al database delle transazioni non disponibile");
  442.             }
  443.             Connection conTransazioni = (Connection) rTransazioni.getResource();
  444.             if(conTransazioni == null)
  445.                 throw new Exception("Connessione al database delle transazioni non disponibile");   

  447.             Connection conStatistiche = null;
  448.             if(this.op2Properties.isStatisticheUseTransazioniDatasource()) {
  449.                 conStatistiche = conTransazioni; // non prendo due connessioni per "atterrare" sul solito database
  450.             }
  451.             else if(this.op2Properties.isStatisticheUsePddRuntimeDatasource() && this.op2Properties.isTransazioniUsePddRuntimeDatasource()) {
  452.                 conStatistiche = conTransazioni; // non prendo due connessioni per "atterrare" sul solito database
  453.             }
  454.             else {
  455.                 dbStatisticheManager = DBStatisticheManager.getInstance();
  456.                 rStatistiche = dbStatisticheManager.getResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, null);
  457.                 if(rStatistiche==null){
  458.                     throw new Exception("Risorsa al database delle statistiche non disponibile");
  459.                 }
  460.                 conStatistiche = (Connection) rStatistiche.getResource();
  461.                 if(conStatistiche == null)
  462.                     throw new Exception("Connessione al database delle statistiche non disponibile");   
  463.             }
  464.             
  465.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  466.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) 
  467.                     this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(), conStatistiche,
  468.                         this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  469.                 
  470.             org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM = 
  471.                     (org.openspcoop2.core.transazioni.dao.IServiceManager) 
  472.                         this.daoFactory.getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(), conTransazioni,
  473.                         this.daoFactoryServiceManagerPropertiesTransazioni, this.daoFactoryLogger);
  474.             
  475.             org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager pluginsStatisticheSM = null;
  476.             org.openspcoop2.core.plugins.dao.IServiceManager pluginsBaseSM = null;
  477.             org.openspcoop2.core.commons.search.dao.IServiceManager utilsSM = null;
  478.             org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager pluginsTransazioniSM = null;
  479.             if(this.generazioneStatisticheCustom || this.tracciamentoPdndGenerazione || this.tracciamentoPdndPubblicazione){
  480.                 
  481.                 IDriverConfigurazioneGet driverConfigurazione = ConfigurazionePdDReader.getDriverConfigurazionePdD();
  482.                 if(driverConfigurazione instanceof DriverConfigurazioneDB) {
  483.                     driverConfigurazioneDB = (DriverConfigurazioneDB) driverConfigurazione;
  484.                 }
  485.                 else {
  486.                     throw new Exception("La generazione delle statistiche custom richiede una configurazione di tipo 'db', trovato: "+driverConfigurazione.getClass().getName());
  487.                 }
  488.                 conConfig = driverConfigurazioneDB.getConnection(TimerStatisticheThread.ID_MODULO+".customStats");
  489.                 
  490.                 pluginsStatisticheSM = (org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager) 
  491.                         this.daoFactory.getServiceManager(
  492.                                 org.openspcoop2.monitor.engine.config.statistiche.utils.ProjectInfo.getInstance(), conConfig,
  493.                                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche, this.daoFactoryLogger);
  494.                 pluginsBaseSM = (org.openspcoop2.core.plugins.dao.IServiceManager) 
  495.                         this.daoFactory.getServiceManager(
  496.                                 org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(), conConfig,
  497.                                 this.daoFactoryServiceManagerPropertiesPluginsBase, this.daoFactoryLogger);
  498.                 utilsSM = (org.openspcoop2.core.commons.search.dao.IServiceManager) 
  499.                         this.daoFactory.getServiceManager(
  500.                                 org.openspcoop2.core.commons.search.utils.ProjectInfo.getInstance(), conConfig,
  501.                                 this.daoFactoryServiceManagerPropertiesUtils, this.daoFactoryLogger);
  502.                 if(this.analisiTransazioniCustom){
  503.                     pluginsTransazioniSM = (org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager) 
  504.                             this.daoFactory.getServiceManager(
  505.                                     org.openspcoop2.monitor.engine.config.transazioni.utils.ProjectInfo.getInstance(), conConfig,
  506.                                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni, this.daoFactoryLogger);
  507.                 }
  508.             }
  509.             
  510.             // aggiorno configurazione per forceIndex
  511.             this.statisticsConfig.setForceIndexConfig(this.op2Properties.getStatisticheGenerazioneExternalForceIndexRepository());
  512.             
  513.             String causa = "Generazione Statistiche";
  514.             try {
  515.                 GestoreMessaggi.acquireLock(
  516.                         this.semaphore, conStatistiche, this.timerLock,
  517.                         this.msgDiag, causa, 
  518.                         this.op2Properties.getStatisticheGenerazioneTimerLockAttesaAttiva(), 
  519.                         this.op2Properties.getStatisticheGenerazioneTimerLockCheckInterval());
  520.                 
  521.                 StatisticsLibrary sLibrary = new StatisticsLibrary(this.statisticsConfig, statisticheSM, transazioniSM, 
  522.                         pluginsStatisticheSM, pluginsBaseSM, utilsSM, pluginsTransazioniSM);
  523.                 
  524.                 
  525.                 switch (this.tipoStatistica) {
  526.                 case STATISTICHE_ORARIE:
  527.                     if(generaStatistica("orario", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_ORARIE) == false) {
  528.                         return; // problemi con il lock
  529.                     }
  530.                     break;
  531.                 case STATISTICHE_GIORNALIERE:
  532.                     if(generaStatistica("giornaliero", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_GIORNALIERE) == false) {
  533.                         return; // problemi con il lock
  534.                     }
  535.                     break;
  536.                 case STATISTICHE_SETTIMANALI:
  537.                     if(generaStatistica("settimanale", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_SETTIMANALI) == false) {
  538.                         return; // problemi con il lock
  539.                     }
  540.                     break;
  541.                 case STATISTICHE_MENSILI:
  542.                     if(generaStatistica("mensile", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_MENSILI) == false) {
  543.                         return; // problemi con il lock
  544.                     }
  545.                     break;
  546.                 case PDND_GENERAZIONE_TRACCIAMENTO:
  547.                     if(!generaStatistica("pdnd tracciamento generazione", conStatistiche, sLibrary, TipoIntervalloStatistico.PDND_GENERAZIONE_TRACCIAMENTO)) {
  548.                         return; // problemi con il lock
  549.                     }
  550.                     break;
  551.                 case PDND_PUBBLICAZIONE_TRACCIAMENTO:
  552.                     if(!generaStatistica("pdnd pubblicazione generazione", conStatistiche, sLibrary, TipoIntervalloStatistico.PDND_PUBBLICAZIONE_TRACCIAMENTO)) {
  553.                         return; // problemi con il lock
  554.                     }
  555.                     break;
  556.                 }
  557.                 
  558.                 
  559.             }finally{
  560.                 try{
  561.                     GestoreMessaggi.releaseLock(
  562.                             this.semaphore, conStatistiche, this.timerLock,
  563.                             this.msgDiag, causa);
  564.                 }catch(Exception e){}
  565.             }
  566.             
  567.             
  568.             
  569.             // end
  570.             long endControlloTimer = DateManager.getTimeMillis();
  571.             long diff = (endControlloTimer-startControlloTimer);
  572.             this.logTimer.info("Generazione '"+this.tipoStatistica.getValue()+"' terminato in "+Utilities.convertSystemTimeIntoStringMillisecondi(diff, true));
  573.             
  574.             
  575.         }
  576.         catch(TimerLockNotAvailableException t) {
  577.             // msg diagnostico emesso durante l'emissione dell'eccezione
  578.             this.logTimer.info(t.getMessage(),t);
  579.         }
  580.         catch (Exception e) {
  581.             this.msgDiag.logErroreGenerico(e,"GenerazioneStatistiche");
  582.             this.logTimer.error("Riscontrato errore durante la generazione delle statistiche ("+this.tipoStatistica.getValue()+"): "+ e.getMessage(),e);
  583.         }finally{
  584.             try{
  585.                 if(rTransazioni!=null)
  586.                     dbTransazioniManager.releaseResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, rTransazioni);
  587.             }catch(Throwable eClose){}
  588.             try{
  589.                 if(rStatistiche!=null)
  590.                     dbStatisticheManager.releaseResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, rStatistiche);
  591.             }catch(Throwable eClose){}
  592.             try{
  593.                 if(conConfig!=null)
  594.                     driverConfigurazioneDB.releaseConnection(conConfig);
  595.             }catch(Throwable eClose){}
  596.         }
  597.             
  598.     }

  600.     
  601.     private boolean generaStatistica(String intervallo, Connection conStatistiche, StatisticsLibrary sLibrary, TipoIntervalloStatistico tipoIntervalloStatistico) {
  602.         
  603.         long startGenerazione = DateManager.getTimeMillis();
  604.         this.msgDiag.addKeyword(CostantiPdD.KEY_TIPO_STATISTICA, intervallo); // riferito a intervallo
  605.         this.msgDiag.logPersonalizzato("generazioneStatistiche.inCorso");
  606.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche.inCorso"));
  607.         
  608.         try{
  609.             GestoreMessaggi.updateLock(
  610.                     this.semaphore, conStatistiche, this.timerLock,
  611.                     this.msgDiag, "Generazione statistiche intervallo '"+intervallo+"' ...");
  612.         }catch(Throwable e){
  613.             this.msgDiag.logErroreGenerico(e,"TimerStatistiche-UpdateLock");
  614.             this.logTimer.error("TimerStatistiche-UpdateLock: "+e.getMessage(),e);
  615.             return false;
  616.         }
  617.         
  618.         switch (tipoIntervalloStatistico) {
  619.         case STATISTICHE_ORARIE:
  620.             sLibrary.generateStatisticaOraria();
  621.             break;
  622.         case STATISTICHE_GIORNALIERE:
  623.             sLibrary.generateStatisticaGiornaliera();
  624.             break;
  625.         case STATISTICHE_SETTIMANALI:
  626.             sLibrary.generateStatisticaSettimanale();
  627.             break;
  628.         case STATISTICHE_MENSILI:
  629.             sLibrary.generateStatisticaMensile();
  630.             break;
  631.         case PDND_GENERAZIONE_TRACCIAMENTO:
  632.             sLibrary.generatePdndGenerazioneTracciamento();
  633.             break;
  634.         case PDND_PUBBLICAZIONE_TRACCIAMENTO:
  635.             sLibrary.generatePdndPubblicazioneTracciamento();
  636.             break;
  637.         }   
  638.                 
  639.         long endGenerazione = DateManager.getTimeMillis();
  640.         String tempoImpiegato = Utilities.convertSystemTimeIntoStringMillisecondi((endGenerazione-startGenerazione), true);
  641.         this.msgDiag.addKeyword(CostantiPdD.KEY_TEMPO_GENERAZIONE, tempoImpiegato); 
  642.         this.msgDiag.logPersonalizzato("generazioneStatistiche.effettuata");
  643.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche.effettuata"));
  644.         
  645.         return true;
  646.     }
  647. }
Created with JaCoCo 0.8.8.202204050719