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.utils.TipiDatabase;
  45. import org.openspcoop2.utils.Utilities;
  46. import org.openspcoop2.utils.date.DateManager;
  47. import org.openspcoop2.utils.id.serial.InfoStatistics;
  48. import org.openspcoop2.utils.semaphore.Semaphore;
  49. import org.openspcoop2.utils.semaphore.SemaphoreConfiguration;
  50. import org.openspcoop2.utils.semaphore.SemaphoreMapping;
  51. import org.slf4j.Logger;


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

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

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

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

  87.     private static TimerState STATE_STATISTICHE_MENSILI = TimerState.OFF; // abilitato in OpenSPCoop2Startup al momento dell'avvio
  88.     public static TimerState getSTATE_STATISTICHE_MENSILI() {
  89.         return STATE_STATISTICHE_MENSILI;
  90.     }
  91.     public static void setSTATE_STATISTICHE_MENSILI(TimerState sTATE_STATISTICHE_MENSILI) {
  92.         STATE_STATISTICHE_MENSILI = sTATE_STATISTICHE_MENSILI;
  93.     }

  95.     /** Logger utilizzato per debug. */
  96.     private Logger logCore = null;
  97.     private Logger logSql = null;
  98.     private Logger logTimer = null;
  99.     private MsgDiagnostico msgDiag = null;

  101.     /** OpenSPCoop2Properties */
  102.     private OpenSPCoop2Properties op2Properties = null;
  103.     
  104.     /** Indicazione se devono essere generate le statistiche custom */
  105.     private boolean generazioneStatisticheCustom = false;
  106.     private boolean analisiTransazioniCustom = false;
  107.     
  108.     /** Indicazione se deve essere effettuato il log delle query */
  109.     private boolean debug = false;  
  110.     
  111.     /** Indicazione se deve essere usata la union per calcolare i tempi di latenza */
  112.     private boolean useUnionForLatency = false; 
  113.     
  114.     /** Intervallo di attesa prima di passare al prossimo intervallo */
  115.     private long waitMsBeforeNextInterval = -1;
  116.     
  117.     /** Attesa che tutte le transazioni siano state consegnate con successo prima di passare al prossimo intervallo */
  118.     private boolean waitStatiInConsegna = false;
  119.     
  120.     /** Tipologie di statistiche */
  121.     private TipoIntervalloStatistico tipoStatistica;
  122.     private boolean statisticheOrarie = false;
  123.     private boolean statisticheGiornaliere = false;
  124.     private boolean statisticheSettimanali = false;
  125.     private boolean statisticheMensili = false;
  126.     
  127.     /** Tipologie di statistiche: gestione ultimo intervallo */
  128.     private boolean statisticheOrarie_gestioneUltimoIntervallo = false;
  129.     private boolean statisticheGiornaliere_gestioneUltimoIntervallo = false;
  130.     private boolean statisticheSettimanali_gestioneUltimoIntervallo = false;
  131.     private boolean statisticheMensili_gestioneUltimoIntervallo = false;
  132.     
  133.     /** Database */
  134. //  private DataSource ds = null;
  135. //  private String datasource = null;
  136.     private String tipoDatabase = null; //tipoDatabase
  137.     private DAOFactory daoFactory = null;
  138.     private Logger daoFactoryLogger = null;
  139.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni = null;
  140.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesStatistiche = null;
  141.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsStatistiche = null;
  142.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsBase = null;
  143.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesUtils = null;
  144.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesPluginsTransazioni = null;

  146.     /** StatisticsConfig */
  147.     private StatisticsConfig statisticsConfig;
  148.     
  149.     /** Timer */
  150.     private TimerLock timerLock = null;

  152.     /** Semaforo */
  153.     private Semaphore semaphore = null;
  154.     private InfoStatistics semaphore_statistics;

  156.     
  157.     
  158.     /** Costruttore */
  159.     public TimerStatisticheLib(TipoIntervalloStatistico tipoStatistica, MsgDiagnostico msgDiag,Logger logTimer,OpenSPCoop2Properties p) throws Exception{
  160.     
  161.         this.msgDiag = msgDiag;
  162.         this.op2Properties = p;
  163.         
  164.         this.debug = this.op2Properties.isStatisticheGenerazioneDebug();
  165.         
  166.         this.logCore = OpenSPCoop2Logger.getLoggerOpenSPCoopStatistiche(tipoStatistica, this.debug);
  167.         this.logSql = OpenSPCoop2Logger.getLoggerOpenSPCoopStatisticheSql(tipoStatistica, this.debug);
  168.         this.logTimer = logTimer;
  169.         
  170.         this.useUnionForLatency = this.op2Properties.isStatisticheGenerazioneUseUnionForLatency();
  171.         this.generazioneStatisticheCustom = this.op2Properties.isStatisticheGenerazioneCustomEnabled();
  172.         this.analisiTransazioniCustom = this.op2Properties.isStatisticheGenerazioneCustomSdkEnabled();
  173.         
  174.         this.tipoStatistica = tipoStatistica;
  175.         
  176.         switch (this.tipoStatistica) {
  177.         case STATISTICHE_ORARIE:
  178.             this.statisticheOrarie = this.op2Properties.isStatisticheGenerazioneBaseOrariaEnabled();
  179.             this.statisticheOrarie_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseOrariaEnabledUltimaOra();
  180.             break;
  181.         case STATISTICHE_GIORNALIERE:
  182.             this.statisticheGiornaliere = this.op2Properties.isStatisticheGenerazioneBaseGiornalieraEnabled();
  183.             this.statisticheGiornaliere_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseGiornalieraEnabledUltimoGiorno();
  184.             break;
  185.         case STATISTICHE_SETTIMANALI:
  186.             this.statisticheSettimanali = this.op2Properties.isStatisticheGenerazioneBaseSettimanaleEnabled();
  187.             this.statisticheSettimanali_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseSettimanaleEnabledUltimaSettimana();
  188.             break;
  189.         case STATISTICHE_MENSILI:
  190.             this.statisticheMensili = this.op2Properties.isStatisticheGenerazioneBaseMensileEnabled();
  191.             this.statisticheMensili_gestioneUltimoIntervallo = this.op2Properties.isStatisticheGenerazioneBaseMensileEnabledUltimoMese();
  192.             break;
  193.         default:
  194.             break;
  195.         }
  196.         
  197.         this.waitStatiInConsegna = this.op2Properties.isStatisticheGenerazioneAttendiCompletamentoTransazioniInFasiIntermedie();
  198.         this.waitMsBeforeNextInterval = this.op2Properties.getStatisticheGenerazioneTradeOffMs();
  199.                 
  200.         try{
  201.             
  202.             // se avviato il thread le statistiche devono essere nella base dati delle transazioni (altrimenti si usa il batch)
  203.             this.tipoDatabase = this.op2Properties.getDatabaseType();
  204.             if(this.tipoDatabase==null){
  205.                 throw new Exception("Tipo Database non definito");
  206.             }
  207.             
  208.             String tipoDatabaseTransazioni = DBTransazioniManager.getInstance().getTipoDatabase();
  209.             if(tipoDatabaseTransazioni==null){
  210.                 throw new Exception("Tipo Database Transazioni non definito");
  211.             }

  213.             // Inizializzazione datasource
  214. //          GestoreJNDI jndi = new GestoreJNDI();
  215. //          this.ds = (DataSource) jndi.lookup(this.datasource);
  216.         
  217.             // DAOFactory
  218.             DAOFactoryProperties daoFactoryProperties = null;
  219.             this.daoFactoryLogger = this.logSql;
  220.             this.daoFactory = DAOFactory.getInstance(this.daoFactoryLogger);
  221.             daoFactoryProperties = DAOFactoryProperties.getInstance(this.daoFactoryLogger);
  222.             
  223.             this.daoFactoryServiceManagerPropertiesTransazioni = 
  224.                     daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  225.             this.daoFactoryServiceManagerPropertiesTransazioni.setShowSql(this.debug);  
  226.             this.daoFactoryServiceManagerPropertiesTransazioni.setDatabaseType(tipoDatabaseTransazioni);
  227.             
  228.             this.daoFactoryServiceManagerPropertiesStatistiche = 
  229.                     daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance());
  230.             this.daoFactoryServiceManagerPropertiesStatistiche.setShowSql(this.debug);  
  231.             this.daoFactoryServiceManagerPropertiesStatistiche.setDatabaseType(tipoDatabaseTransazioni);
  232.             
  233.             if(this.generazioneStatisticheCustom){
  234.             
  235.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche = 
  236.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.monitor.engine.config.statistiche.utils.ProjectInfo.getInstance());
  237.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche.setShowSql(this.debug);   
  238.                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche.setDatabaseType(this.tipoDatabase);
  239.                 
  240.                 this.daoFactoryServiceManagerPropertiesPluginsBase = 
  241.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance());
  242.                 this.daoFactoryServiceManagerPropertiesPluginsBase.setShowSql(this.debug);  
  243.                 this.daoFactoryServiceManagerPropertiesPluginsBase.setDatabaseType(this.tipoDatabase);
  244.                 
  245.                 this.daoFactoryServiceManagerPropertiesUtils = 
  246.                         daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.commons.search.utils.ProjectInfo.getInstance());
  247.                 this.daoFactoryServiceManagerPropertiesUtils.setShowSql(this.debug);    
  248.                 this.daoFactoryServiceManagerPropertiesUtils.setDatabaseType(this.tipoDatabase);
  249.                 
  250.                 if(this.analisiTransazioniCustom){
  251.                 
  252.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni = 
  253.                             daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.monitor.engine.config.transazioni.utils.ProjectInfo.getInstance());
  254.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni.setShowSql(this.debug);   
  255.                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni.setDatabaseType(this.tipoDatabase);
  256.                     
  257.                 }
  258.                 
  259.             }
  260.                 
  261.         }catch(Exception e){
  262.             throw new Exception("Errore durante l'inizializzazione del datasource: "+e.getMessage(),e);
  263.         }
  264.         
  265.         
  266.         try{
  267.             this.statisticsConfig = new StatisticsConfig(false);
  268.             
  269.             this.statisticsConfig.setLogCore(this.logCore);
  270.             this.statisticsConfig.setLogSql(this.logSql);
  271.             this.statisticsConfig.setGenerazioneStatisticheCustom(this.generazioneStatisticheCustom);
  272.             this.statisticsConfig.setAnalisiTransazioniCustom(this.analisiTransazioniCustom);
  273.             this.statisticsConfig.setDebug(this.debug);
  274.             this.statisticsConfig.setUseUnionForLatency(this.useUnionForLatency);
  275.             this.statisticsConfig.setStatisticheOrarie(this.statisticheOrarie);
  276.             this.statisticsConfig.setStatisticheGiornaliere(this.statisticheGiornaliere);
  277.             this.statisticsConfig.setStatisticheSettimanali(this.statisticheSettimanali);
  278.             this.statisticsConfig.setStatisticheMensili(this.statisticheMensili);
  279.             this.statisticsConfig.setStatisticheOrarieGestioneUltimoIntervallo(this.statisticheOrarie_gestioneUltimoIntervallo);
  280.             this.statisticsConfig.setStatisticheGiornaliereGestioneUltimoIntervallo(this.statisticheGiornaliere_gestioneUltimoIntervallo);
  281.             this.statisticsConfig.setStatisticheSettimanaliGestioneUltimoIntervallo(this.statisticheSettimanali_gestioneUltimoIntervallo);
  282.             this.statisticsConfig.setStatisticheMensiliGestioneUltimoIntervallo(this.statisticheMensili_gestioneUltimoIntervallo);
  283.             this.statisticsConfig.setWaitMsBeforeNextInterval(this.waitMsBeforeNextInterval);
  284.             this.statisticsConfig.setWaitStatiInConsegna(this.waitStatiInConsegna);
  285.         }catch(Exception e){
  286.             throw new Exception("Errore durante la generazione delle statistiche (InitConfigurazione): "+e.getMessage(),e);
  287.         }
  288.         
  289.         switch (this.tipoStatistica) {
  290.         case STATISTICHE_ORARIE:
  291.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_ORARIE); 
  292.             break;
  293.         case STATISTICHE_GIORNALIERE:
  294.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_GIORNALIERE); 
  295.             break;
  296.         case STATISTICHE_SETTIMANALI:
  297.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_SETTIMANALI); 
  298.             break;
  299.         case STATISTICHE_MENSILI:
  300.             this.timerLock = new TimerLock(TipoLock.GENERAZIONE_STATISTICHE_MENSILI); 
  301.             break;
  302.         default:
  303.             break;
  304.         }
  305.         
  306.         if(this.op2Properties.isTimerLockByDatabase()) {
  307.             this.semaphore_statistics = new InfoStatistics();

  309.             SemaphoreConfiguration config = GestoreMessaggi.newSemaphoreConfiguration(this.op2Properties.getStatisticheGenerazioneTimerLockMaxLife(), 
  310.                     this.op2Properties.getStatisticheGenerazioneTimerLockIdleTime());

  312.             TipiDatabase databaseType = TipiDatabase.toEnumConstant(this.tipoDatabase);
  313.             try {
  314.                 this.semaphore = new Semaphore(this.semaphore_statistics, SemaphoreMapping.newInstance(this.timerLock.getIdLock()), 
  315.                         config, databaseType, this.logTimer);
  316.             }catch(Exception e) {
  317.                 throw new TimerException(e.getMessage(),e);
  318.             }
  319.         }
  320.     }
  321.     
  322.     public void check() throws TimerException {
  323.         
  324.         // Controllo che il sistema non sia andando in shutdown
  325.         if(OpenSPCoop2Startup.contextDestroyed){
  326.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Rilevato sistema in shutdown");
  327.             return;
  328.         }

  330.         // Controllo che l'inizializzazione corretta delle risorse sia effettuata
  331.         if(!OpenSPCoop2Startup.initialize){
  332.             this.msgDiag.logFatalError("inizializzazione di OpenSPCoop non effettuata", "Check Inizializzazione");
  333.             String msgErrore = "Riscontrato errore: inizializzazione del Timer o di OpenSPCoop non effettuata";
  334.             this.logTimer.error(msgErrore);
  335.             throw new TimerException(msgErrore);
  336.         }

  338.         // Controllo risorse di sistema disponibili
  339.         if( !TimerMonitoraggioRisorseThread.isRisorseDisponibili()){
  340.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Risorse di sistema non disponibili: "+TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile().getMessage(),TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile());
  341.             return;
  342.         }
  343.         if( !MsgDiagnostico.gestoreDiagnosticaDisponibile){
  344.             this.logTimer.error("["+TimerStatisticheThread.ID_MODULO+"] Sistema di diagnostica non disponibile: "+MsgDiagnostico.motivoMalfunzionamentoDiagnostici.getMessage(),MsgDiagnostico.motivoMalfunzionamentoDiagnostici);
  345.             return;
  346.         }
  347.         
  348.         boolean enabled = false;
  349.         switch (this.tipoStatistica) {
  350.         case STATISTICHE_ORARIE:
  351.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_ORARIE);
  352.             break;
  353.         case STATISTICHE_GIORNALIERE:
  354.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_GIORNALIERE);
  355.             break;
  356.         case STATISTICHE_SETTIMANALI:
  357.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_SETTIMANALI);
  358.             break;
  359.         case STATISTICHE_MENSILI:
  360.             enabled = TimerState.ENABLED.equals(STATE_STATISTICHE_MENSILI);
  361.             break;
  362.         default:
  363.             break;
  364.         }
  365.         if(!enabled) {
  366.             this.msgDiag.logPersonalizzato("disabilitato");
  367.             this.logCore.info(this.msgDiag.getMessaggio_replaceKeywords("disabilitato"));
  368.             this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("disabilitato"));
  369.             return;
  370.         }
  371.         
  372.         
  373.         
  374.         this.msgDiag.logPersonalizzato("generazioneStatistiche");
  375.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche"));
  376.         long startControlloTimer = DateManager.getTimeMillis();
  377.             
  378.             
  379.         DBTransazioniManager dbTransazioniManager = null;
  380.         DBStatisticheManager dbStatisticheManager = null;
  381.         Resource rTransazioni = null;
  382.         Resource rStatistiche = null;
  383.         Connection conConfig = null;
  384.         DriverConfigurazioneDB driverConfigurazioneDB = null;
  385.         try{

  387.             dbTransazioniManager = DBTransazioniManager.getInstance();
  388.             rTransazioni = dbTransazioniManager.getResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, null);
  389.             if(rTransazioni==null){
  390.                 throw new Exception("Risorsa al database delle transazioni non disponibile");
  391.             }
  392.             Connection conTransazioni = (Connection) rTransazioni.getResource();
  393.             if(conTransazioni == null)
  394.                 throw new Exception("Connessione al database delle transazioni non disponibile");   

  396.             Connection conStatistiche = null;
  397.             if(this.op2Properties.isStatisticheUseTransazioniDatasource()) {
  398.                 conStatistiche = conTransazioni; // non prendo due connessioni per "atterrare" sul solito database
  399.             }
  400.             else if(this.op2Properties.isStatisticheUsePddRuntimeDatasource() && this.op2Properties.isTransazioniUsePddRuntimeDatasource()) {
  401.                 conStatistiche = conTransazioni; // non prendo due connessioni per "atterrare" sul solito database
  402.             }
  403.             else {
  404.                 dbStatisticheManager = DBStatisticheManager.getInstance();
  405.                 rStatistiche = dbStatisticheManager.getResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, null);
  406.                 if(rStatistiche==null){
  407.                     throw new Exception("Risorsa al database delle statistiche non disponibile");
  408.                 }
  409.                 conStatistiche = (Connection) rStatistiche.getResource();
  410.                 if(conStatistiche == null)
  411.                     throw new Exception("Connessione al database delle statistiche non disponibile");   
  412.             }
  413.             
  414.             org.openspcoop2.core.statistiche.dao.IServiceManager statisticheSM = 
  415.                     (org.openspcoop2.core.statistiche.dao.IServiceManager) 
  416.                     this.daoFactory.getServiceManager(org.openspcoop2.core.statistiche.utils.ProjectInfo.getInstance(), conStatistiche,
  417.                         this.daoFactoryServiceManagerPropertiesStatistiche, this.daoFactoryLogger);
  418.                 
  419.             org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM = 
  420.                     (org.openspcoop2.core.transazioni.dao.IServiceManager) 
  421.                         this.daoFactory.getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(), conTransazioni,
  422.                         this.daoFactoryServiceManagerPropertiesTransazioni, this.daoFactoryLogger);
  423.             
  424.             org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager pluginsStatisticheSM = null;
  425.             org.openspcoop2.core.plugins.dao.IServiceManager pluginsBaseSM = null;
  426.             org.openspcoop2.core.commons.search.dao.IServiceManager utilsSM = null;
  427.             org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager pluginsTransazioniSM = null;
  428.             if(this.generazioneStatisticheCustom){
  429.                 
  430.                 IDriverConfigurazioneGet driverConfigurazione = ConfigurazionePdDReader.getDriverConfigurazionePdD();
  431.                 if(driverConfigurazione instanceof DriverConfigurazioneDB) {
  432.                     driverConfigurazioneDB = (DriverConfigurazioneDB) driverConfigurazione;
  433.                 }
  434.                 else {
  435.                     throw new Exception("La generazione delle statistiche custom richiede una configurazione di tipo 'db', trovato: "+driverConfigurazione.getClass().getName());
  436.                 }
  437.                 conConfig = driverConfigurazioneDB.getConnection(TimerStatisticheThread.ID_MODULO+".customStats");
  438.                 
  439.                 pluginsStatisticheSM = (org.openspcoop2.monitor.engine.config.statistiche.dao.IServiceManager) 
  440.                         this.daoFactory.getServiceManager(
  441.                                 org.openspcoop2.monitor.engine.config.statistiche.utils.ProjectInfo.getInstance(), conConfig,
  442.                                 this.daoFactoryServiceManagerPropertiesPluginsStatistiche, this.daoFactoryLogger);
  443.                 pluginsBaseSM = (org.openspcoop2.core.plugins.dao.IServiceManager) 
  444.                         this.daoFactory.getServiceManager(
  445.                                 org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(), conConfig,
  446.                                 this.daoFactoryServiceManagerPropertiesPluginsBase, this.daoFactoryLogger);
  447.                 utilsSM = (org.openspcoop2.core.commons.search.dao.IServiceManager) 
  448.                         this.daoFactory.getServiceManager(
  449.                                 org.openspcoop2.core.commons.search.utils.ProjectInfo.getInstance(), conConfig,
  450.                                 this.daoFactoryServiceManagerPropertiesUtils, this.daoFactoryLogger);
  451.                 if(this.analisiTransazioniCustom){
  452.                     pluginsTransazioniSM = (org.openspcoop2.monitor.engine.config.transazioni.dao.IServiceManager) 
  453.                             this.daoFactory.getServiceManager(
  454.                                     org.openspcoop2.monitor.engine.config.transazioni.utils.ProjectInfo.getInstance(), conConfig,
  455.                                     this.daoFactoryServiceManagerPropertiesPluginsTransazioni, this.daoFactoryLogger);
  456.                 }
  457.             }
  458.             
  459.             // aggiorno configurazione per forceIndex
  460.             this.statisticsConfig.setForceIndexConfig(this.op2Properties.getStatisticheGenerazioneExternalForceIndexRepository());
  461.             
  462.             String causa = "Generazione Statistiche";
  463.             try {
  464.                 GestoreMessaggi.acquireLock(
  465.                         this.semaphore, conStatistiche, this.timerLock,
  466.                         this.msgDiag, causa, 
  467.                         this.op2Properties.getStatisticheGenerazioneTimerLockAttesaAttiva(), 
  468.                         this.op2Properties.getStatisticheGenerazioneTimerLockCheckInterval());
  469.                 
  470.                 StatisticsLibrary sLibrary = new StatisticsLibrary(this.statisticsConfig, statisticheSM, transazioniSM, 
  471.                         pluginsStatisticheSM, pluginsBaseSM, utilsSM, pluginsTransazioniSM);
  472.                 
  473.                 
  474.                 switch (this.tipoStatistica) {
  475.                 case STATISTICHE_ORARIE:
  476.                     if(generaStatistica("orario", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_ORARIE) == false) {
  477.                         return; // problemi con il lock
  478.                     }
  479.                     break;
  480.                 case STATISTICHE_GIORNALIERE:
  481.                     if(generaStatistica("giornaliero", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_GIORNALIERE) == false) {
  482.                         return; // problemi con il lock
  483.                     }
  484.                     break;
  485.                 case STATISTICHE_SETTIMANALI:
  486.                     if(generaStatistica("settimanale", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_SETTIMANALI) == false) {
  487.                         return; // problemi con il lock
  488.                     }
  489.                     break;
  490.                 case STATISTICHE_MENSILI:
  491.                     if(generaStatistica("mensile", conStatistiche, sLibrary, TipoIntervalloStatistico.STATISTICHE_MENSILI) == false) {
  492.                         return; // problemi con il lock
  493.                     }
  494.                     break;
  495.                 default:
  496.                     break;
  497.                 }
  498.                 
  499.             }finally{
  500.                 try{
  501.                     GestoreMessaggi.releaseLock(
  502.                             this.semaphore, conStatistiche, this.timerLock,
  503.                             this.msgDiag, causa);
  504.                 }catch(Exception e){}
  505.             }
  506.             
  507.             
  508.             
  509.             // end
  510.             long endControlloTimer = DateManager.getTimeMillis();
  511.             long diff = (endControlloTimer-startControlloTimer);
  512.             this.logTimer.info("Generazione '"+this.tipoStatistica.getValue()+"' terminato in "+Utilities.convertSystemTimeIntoStringMillisecondi(diff, true));
  513.             
  514.             
  515.         }
  516.         catch(TimerLockNotAvailableException t) {
  517.             // msg diagnostico emesso durante l'emissione dell'eccezione
  518.             this.logTimer.info(t.getMessage(),t);
  519.         }
  520.         catch (Exception e) {
  521.             this.msgDiag.logErroreGenerico(e,"GenerazioneStatistiche");
  522.             this.logTimer.error("Riscontrato errore durante la generazione delle statistiche ("+this.tipoStatistica.getValue()+"): "+ e.getMessage(),e);
  523.         }finally{
  524.             try{
  525.                 if(rTransazioni!=null)
  526.                     dbTransazioniManager.releaseResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, rTransazioni);
  527.             }catch(Throwable eClose){}
  528.             try{
  529.                 if(rStatistiche!=null)
  530.                     dbStatisticheManager.releaseResource(this.op2Properties.getIdentitaPortaDefaultWithoutProtocol(), TimerStatisticheThread.ID_MODULO, rStatistiche);
  531.             }catch(Throwable eClose){}
  532.             try{
  533.                 if(conConfig!=null)
  534.                     driverConfigurazioneDB.releaseConnection(conConfig);
  535.             }catch(Throwable eClose){}
  536.         }
  537.             
  538.     }

  540.     
  541.     private boolean generaStatistica(String intervallo, Connection conStatistiche, StatisticsLibrary sLibrary, TipoIntervalloStatistico tipoIntervalloStatistico) {
  542.         
  543.         long startGenerazione = DateManager.getTimeMillis();
  544.         this.msgDiag.addKeyword(CostantiPdD.KEY_TIPO_STATISTICA, intervallo); // riferito a intervallo
  545.         this.msgDiag.logPersonalizzato("generazioneStatistiche.inCorso");
  546.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche.inCorso"));
  547.         
  548.         try{
  549.             GestoreMessaggi.updateLock(
  550.                     this.semaphore, conStatistiche, this.timerLock,
  551.                     this.msgDiag, "Generazione statistiche intervallo '"+intervallo+"' ...");
  552.         }catch(Throwable e){
  553.             this.msgDiag.logErroreGenerico(e,"TimerStatistiche-UpdateLock");
  554.             this.logTimer.error("TimerStatistiche-UpdateLock: "+e.getMessage(),e);
  555.             return false;
  556.         }
  557.         
  558.         switch (tipoIntervalloStatistico) {
  559.         case STATISTICHE_ORARIE:
  560.             sLibrary.generateStatisticaOraria();
  561.             break;
  562.         case STATISTICHE_GIORNALIERE:
  563.             sLibrary.generateStatisticaGiornaliera();
  564.             break;
  565.         case STATISTICHE_SETTIMANALI:
  566.             sLibrary.generateStatisticaSettimanale();
  567.             break;
  568.         case STATISTICHE_MENSILI:
  569.             sLibrary.generateStatisticaMensile();
  570.             break;
  571.         }   
  572.                 
  573.         long endGenerazione = DateManager.getTimeMillis();
  574.         String tempoImpiegato = Utilities.convertSystemTimeIntoStringMillisecondi((endGenerazione-startGenerazione), true);
  575.         this.msgDiag.addKeyword(CostantiPdD.KEY_TEMPO_GENERAZIONE, tempoImpiegato); 
  576.         this.msgDiag.logPersonalizzato("generazioneStatistiche.effettuata");
  577.         this.logTimer.info(this.msgDiag.getMessaggio_replaceKeywords("generazioneStatistiche.effettuata"));
  578.         
  579.         return true;
  580.     }
  581. }
Created with JaCoCo 0.8.8.202204050719