StatisticsConfig.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.  */
  20. package org.openspcoop2.monitor.engine.statistic;

  22. import org.openspcoop2.monitor.engine.exceptions.EngineException;

  24. import java.util.Arrays;
  25. import java.util.List;
  26. import java.util.Set;
  27. import java.util.stream.Collectors;

  29. import org.apache.commons.lang.StringUtils;
  30. import org.openspcoop2.monitor.engine.config.MonitorProperties;
  31. import org.openspcoop2.monitor.engine.constants.CostantiConfigurazione;

  33. import org.openspcoop2.utils.LoggerWrapperFactory;
  34. import org.openspcoop2.utils.UtilsException;
  35. import org.openspcoop2.utils.transport.http.HttpRequestConfig;
  36. import org.slf4j.Logger;

  38. /**
  39.  * StatisticsConfig
  40.  *
  41.  * @author Poli Andrea (apoli@link.it)
  42.  * @author $Author$
  43.  * @version $Rev$, $Date$
  44.  */
  45. public class StatisticsConfig {

  47.     private Logger logCore = null;
  48.     private Logger logSql = null;

  50.     /** Indicazione se deve essere effettuato il log delle query */
  51.     private boolean debug = false;  
  52.     
  53.     /** Indicazione se deve essere usata la union per calcolare i tempi di latenza */
  54.     private boolean useUnionForLatency = false; 
  55.     
  56.     /** Indicazione se devono essere generate le statistiche custom */
  57.     private boolean generazioneStatisticheCustom = false;
  58.     
  59.     /** Indicazione se devono analizzate le transazioni custom */
  60.     private boolean analisiTransazioniCustom = false;
  61.     
  62.     /** Intervallo di attesa prima di passare al prossimo intervallo */
  63.     private long waitMsBeforeNextInterval = -1;
  64.     
  65.     /** Attesa che tutte le transazioni siano state consegnate con successo prima di passare al prossimo intervallo */
  66.     private boolean waitStatiInConsegna = false;
  67.     
  68.     /** Tipologie di statistiche */
  69.     private boolean statisticheOrarie = false;
  70.     private boolean statisticheGiornaliere = false;
  71.     private boolean statisticheSettimanali = false;
  72.     private boolean statisticheMensili = false;
  73.     
  74.     /** Tipologie di statistiche: gestione ultimo intervallo */
  75.     private boolean statisticheOrarieGestioneUltimoIntervallo = false;
  76.     private boolean statisticheGiornaliereGestioneUltimoIntervallo = false;
  77.     private boolean statisticheSettimanaliGestioneUltimoIntervallo = false;
  78.     private boolean statisticheMensiliGestioneUltimoIntervallo = false;
  79.         
  80.     /** Lista di indici forzati */
  81.     private StatisticsForceIndexConfig forceIndexConfig = null;
  82.     
  83.     /** PDND Tracing **/
  84.     private boolean pdndTracciamentoGenerazione = false;
  85.     private boolean pdndTracciamentoPubblicazione = false;
  86.     private HttpRequestConfig pdndTracciamentoRequestConfig;
  87.     private boolean pdndTracciamentoSoggettiDisabled = false;
  88.     private Set<String> pdndTracciamentoSoggettiEnabled;
  89.     private Integer pdndTracciamentoMaxAttempt = null;
  90.     private List<Integer> pdndTracciamentoPendingCheck = null;
  91.     private boolean pdndTracciamentoErogazioniEnabled = true;
  92.     private boolean pdndTracciamentoFruizioniEnabled = true;
  93.     
  94.     private static final String FALSE = "false";
  95.     
  96.     /** Costruttore */
  97.     public StatisticsConfig(boolean readPropertiesFromFile) throws EngineException{
  98.     
  99.         try{
  100.             if(readPropertiesFromFile){
  101.                 
  102.                 this.logCore = LoggerWrapperFactory.getLogger("org.openspcoop2.monitor.engine.statistic");
  103.                 this.logSql = LoggerWrapperFactory.getLogger("org.openspcoop2.monitor.engine.statistic.sql");
  104.                 
  105.                 MonitorProperties props = MonitorProperties.getInstance(this.logCore);
  106.     
  107.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_DEBUG, FALSE, true))) {
  108.                     this.debug = true;
  109.                 } else {
  110.                     this.debug = false;
  111.                 }
  112.                 
  113.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_USE_UNION_FOR_LATENCY, FALSE, true))) {
  114.                     this.useUnionForLatency = true;
  115.                 } else {
  116.                     this.useUnionForLatency = false;
  117.                 }
  118.                 
  119.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_CUSTOM_STATISTICS, FALSE, true))) {
  120.                     this.generazioneStatisticheCustom = true;
  121.                 } else {
  122.                     this.generazioneStatisticheCustom = false;
  123.                 }
  124.                 
  125.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_CUSTOM_TRANSACTION_STATISTICS, FALSE, true))) {
  126.                     this.analisiTransazioniCustom = true;
  127.                 } else {
  128.                     this.analisiTransazioniCustom = false;
  129.                 }
  130.         
  131.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_HOURLY, "true", true))) {
  132.                     this.statisticheOrarie = true;
  133.                 } else {
  134.                     this.statisticheOrarie = false;
  135.                 }
  136.                 
  137.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_DAILY, "true", true))) {
  138.                     this.statisticheGiornaliere = true;
  139.                 } else {
  140.                     this.statisticheGiornaliere = false;
  141.                 }
  142.         
  143.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_WEEKLY, "true", true))) {
  144.                     this.statisticheSettimanali = true;
  145.                 } else {
  146.                     this.statisticheSettimanali = false;
  147.                 }
  148.         
  149.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_MONTHLY, "true", true))) {
  150.                     this.statisticheMensili = true;
  151.                 } else {
  152.                     this.statisticheMensili = false;
  153.                 }
  154.                 
  155.                 this.pdndTracciamentoGenerazione = parsePdndGenerazioneTracciamentoProperty(props);
  156.                 this.pdndTracciamentoPubblicazione = parsePdndPubblicazioneTracciamentoProperty(props);
  157.                 this.pdndTracciamentoRequestConfig = parsePdndTracingRequestConfig(props);
  158.                 this.pdndTracciamentoSoggettiEnabled = parsePdndTracingSoggettiEnabled(props);
  159.                 this.pdndTracciamentoSoggettiDisabled = parsePdndTracingSoggettiDisabled(props);
  160.                 this.pdndTracciamentoErogazioniEnabled = parsePdndTracingErogazioniEnabled(props);
  161.                 this.pdndTracciamentoFruizioniEnabled = parsePdndTracingFruizioniEnabled(props);
  162.                 this.pdndTracciamentoPendingCheck = parsePdndTracciamentoPendingCheck(props);
  163.                 this.pdndTracciamentoMaxAttempt = parsePdndTracciamentoMaxAttempts(props);
  164.                 
  165.                 if ("true".equals(props.getProperty(CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_ENABLED, "true", true))) {
  166.                     this.pdndTracciamentoPubblicazione = true;
  167.                 } else {
  168.                     this.pdndTracciamentoPubblicazione = false;
  169.                 }
  170.         
  171.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_HOURLY_LASTINT, "true", true))) {
  172.                     this.statisticheOrarieGestioneUltimoIntervallo = true;
  173.                 } else {
  174.                     this.statisticheOrarieGestioneUltimoIntervallo = false;
  175.                 }
  176.                 
  177.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_DAILY_LASTINT, "true", true))) {
  178.                     this.statisticheGiornaliereGestioneUltimoIntervallo = true;
  179.                 } else {
  180.                     this.statisticheGiornaliereGestioneUltimoIntervallo = false;
  181.                 }
  182.         
  183.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_WEEKLY_LASTINT, "true", true))) {
  184.                     this.statisticheSettimanaliGestioneUltimoIntervallo = true;
  185.                 } else {
  186.                     this.statisticheSettimanaliGestioneUltimoIntervallo = false;
  187.                 }
  188.         
  189.                 if ("true".equals(props.getProperty(CostantiConfigurazione.STAT_MONTHLY_LASTINT, "true", true))) {
  190.                     this.statisticheMensiliGestioneUltimoIntervallo = true;
  191.                 } else {
  192.                     this.statisticheMensiliGestioneUltimoIntervallo = false;
  193.                 }
  194.                 
  195.             }
  196.             
  197.         }catch(Exception e){
  198.             throw new EngineException(e.getMessage(),e);
  199.         }
  200.     }
  201.     
  202.     private static boolean parsePdndGenerazioneTracciamentoProperty(MonitorProperties props) throws UtilsException {
  203.         String propId = CostantiConfigurazione.PDND_GENERAZIONE_TRACCIAMENTO_ENABLED;
  204.         return "true".equals(props.getProperty(propId, "true", true));
  205.     }
  206.     
  207.     private static boolean parsePdndPubblicazioneTracciamentoProperty(MonitorProperties props) throws UtilsException {
  208.         String propId = CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_ENABLED;
  209.         return "true".equals(props.getProperty(propId, "true", true));
  210.     }
  211.     
  212.     private static boolean parsePdndTracingErogazioniEnabled(MonitorProperties props) throws UtilsException {
  213.         String propId = CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_EROGAZIONI_ENABLED;
  214.         return "true".equals(props.getProperty(propId, "true", true));
  215.     }
  216.     
  217.     private static boolean parsePdndTracingFruizioniEnabled(MonitorProperties props) throws UtilsException {
  218.         String propId = CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_FRUIZIONI_ENABLED;
  219.         return "true".equals(props.getProperty(propId, "true", true));
  220.     }
  221.     
  222.     private static HttpRequestConfig parsePdndTracingRequestConfig(MonitorProperties props) {
  223.         return new HttpRequestConfig("pdnd.tracciamento", str -> {
  224.             try {
  225.                 return props.getProperty(str, false, true);
  226.             } catch (UtilsException e) {
  227.                 return null;
  228.             }
  229.         });
  230.     }
  231.     
  232.     private static Set<String> parsePdndTracingSoggettiEnabled(MonitorProperties props) throws UtilsException {
  233.         String propId = CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_SOGGETTI_ENABLED;
  234.         String value = props.getProperty(propId, "", false);
  235.         if (value == null || StringUtils.isEmpty(value.trim()) || "*".equals(value.trim()))
  236.             return Set.of();
  237.         return Arrays.stream(value.split(","))
  238.                 .map(String::trim)
  239.                 .collect(Collectors.toSet());
  240.     }
  241.     private boolean parsePdndTracingSoggettiDisabled(MonitorProperties props) throws UtilsException {
  242.         String propId = CostantiConfigurazione.PDND_PUBBLICAZIONE_TRACCIAMENTO_SOGGETTI_ENABLED;
  243.         String value = props.getProperty(propId, "", false);
  244.         return value==null || StringUtils.isEmpty(value.trim());
  245.     }
  246.     
  247.     private List<Integer> parsePdndTracciamentoPendingCheck(MonitorProperties props) throws UtilsException {
  248.         String propId = CostantiConfigurazione.PDND_TRACCIAMENTO_PUBBLICAZIONE_PENDING_CHECK;
  249.         String value = props.getProperty(propId, "", false);
  250.         return value == null || StringUtils.isEmpty(value.trim()) ? List.of(0) : Arrays.stream(value.split(","))
  251.                 .map(Integer::valueOf)
  252.                 .collect(Collectors.toList());
  253.     }
  254.     
  255.     private Integer parsePdndTracciamentoMaxAttempts(MonitorProperties props) throws UtilsException {
  256.         String propId = CostantiConfigurazione.PDND_TRACCIAMENTO_PUBBLICAZIONE_MAX_ATTEMPTS;
  257.         String value = props.getProperty(propId, "", false);
  258.         return value == null || StringUtils.isEmpty(value.trim()) ? null : Integer.valueOf(value);
  259.     }
  260.     
  261.     public Logger getLogCore() {
  262.         return this.logCore;
  263.     }
  264.     
  265.     public void setLogCore(Logger logCore) {
  266.         this.logCore = logCore;
  267.     }

  269.     public Logger getLogSql() {
  270.         return this.logSql;
  271.     }

  273.     public void setLogSql(Logger logSql) {
  274.         this.logSql = logSql;
  275.     }
  276.     
  277.     public boolean isDebug() {
  278.         return this.debug;
  279.     }

  281.     public void setDebug(boolean debug) {
  282.         this.debug = debug;
  283.     }

  285.     public boolean isUseUnionForLatency() {
  286.         return this.useUnionForLatency;
  287.     }

  289.     public void setUseUnionForLatency(boolean useUnionForLatency) {
  290.         this.useUnionForLatency = useUnionForLatency;
  291.     }
  292.     
  293.     public boolean isGenerazioneStatisticheCustom() {
  294.         return this.generazioneStatisticheCustom;
  295.     }

  297.     public void setGenerazioneStatisticheCustom(boolean generazioneStatisticheCustom) {
  298.         this.generazioneStatisticheCustom = generazioneStatisticheCustom;
  299.     }

  301.     public boolean isStatisticheOrarie() {
  302.         return this.statisticheOrarie;
  303.     }

  305.     public void setStatisticheOrarie(boolean statisticheOrarie) {
  306.         this.statisticheOrarie = statisticheOrarie;
  307.     }

  309.     public boolean isStatisticheGiornaliere() {
  310.         return this.statisticheGiornaliere;
  311.     }

  313.     public void setStatisticheGiornaliere(boolean statisticheGiornaliere) {
  314.         this.statisticheGiornaliere = statisticheGiornaliere;
  315.     }

  317.     public boolean isStatisticheSettimanali() {
  318.         return this.statisticheSettimanali;
  319.     }

  321.     public void setStatisticheSettimanali(boolean statisticheSettimanali) {
  322.         this.statisticheSettimanali = statisticheSettimanali;
  323.     }

  325.     public boolean isStatisticheMensili() {
  326.         return this.statisticheMensili;
  327.     }

  329.     public void setStatisticheMensili(boolean statisticheMensili) {
  330.         this.statisticheMensili = statisticheMensili;
  331.     }

  333.     public boolean isStatisticheOrarieGestioneUltimoIntervallo() {
  334.         return this.statisticheOrarieGestioneUltimoIntervallo;
  335.     }
  336.     

  338.     public void setStatisticheOrarieGestioneUltimoIntervallo(
  339.             boolean statisticheOrarieGestioneUltimoIntervallo) {
  340.         this.statisticheOrarieGestioneUltimoIntervallo = statisticheOrarieGestioneUltimoIntervallo;
  341.     }

  343.     public boolean isStatisticheGiornaliereGestioneUltimoIntervallo() {
  344.         return this.statisticheGiornaliereGestioneUltimoIntervallo;
  345.     }

  347.     public void setStatisticheGiornaliereGestioneUltimoIntervallo(
  348.             boolean statisticheGiornaliereGestioneUltimoIntervallo) {
  349.         this.statisticheGiornaliereGestioneUltimoIntervallo = statisticheGiornaliereGestioneUltimoIntervallo;
  350.     }

  352.     public boolean isStatisticheSettimanaliGestioneUltimoIntervallo() {
  353.         return this.statisticheSettimanaliGestioneUltimoIntervallo;
  354.     }

  356.     public void setStatisticheSettimanaliGestioneUltimoIntervallo(
  357.             boolean statisticheSettimanaliGestioneUltimoIntervallo) {
  358.         this.statisticheSettimanaliGestioneUltimoIntervallo = statisticheSettimanaliGestioneUltimoIntervallo;
  359.     }

  361.     public boolean isStatisticheMensiliGestioneUltimoIntervallo() {
  362.         return this.statisticheMensiliGestioneUltimoIntervallo;
  363.     }

  365.     public void setStatisticheMensiliGestioneUltimoIntervallo(
  366.             boolean statisticheMensiliGestioneUltimoIntervallo) {
  367.         this.statisticheMensiliGestioneUltimoIntervallo = statisticheMensiliGestioneUltimoIntervallo;
  368.     }
  369.     
  370.     public boolean isAnalisiTransazioniCustom() {
  371.         return this.analisiTransazioniCustom;
  372.     }

  374.     public void setAnalisiTransazioniCustom(boolean analisiTransazioniCustom) {
  375.         this.analisiTransazioniCustom = analisiTransazioniCustom;
  376.     }
  377.     
  378.     public StatisticsForceIndexConfig getForceIndexConfig() {
  379.         return this.forceIndexConfig;
  380.     }

  382.     public void setForceIndexConfig(StatisticsForceIndexConfig forceIndexConfig) {
  383.         this.forceIndexConfig = forceIndexConfig;
  384.     }
  385.     
  386.     public long getWaitMsBeforeNextInterval() {
  387.         return this.waitMsBeforeNextInterval;
  388.     }

  390.     public void setWaitMsBeforeNextInterval(long waitMsBeforeNextInterval) {
  391.         this.waitMsBeforeNextInterval = waitMsBeforeNextInterval;
  392.     }

  394.     public boolean isWaitStatiInConsegna() {
  395.         return this.waitStatiInConsegna;
  396.     }

  398.     public void setWaitStatiInConsegna(boolean waitStatiInConsegna) {
  399.         this.waitStatiInConsegna = waitStatiInConsegna;
  400.     }
  401.     
  402.     public boolean isPdndTracciamentoPubblicazione() {
  403.         return this.pdndTracciamentoPubblicazione;
  404.     }

  406.     public void setPdndTracciamentoPubblicazione(boolean pdndPubblicazioneTracciamento) {
  407.         this.pdndTracciamentoPubblicazione = pdndPubblicazioneTracciamento;
  408.     }
  409.     
  410.     public boolean isPdndTracciamentoGenerazione() {
  411.         return this.pdndTracciamentoGenerazione;
  412.     }

  414.     public void setPdndTracciamentoGenerazione(boolean pdndGenerazioneTracciamento) {
  415.         this.pdndTracciamentoGenerazione = pdndGenerazioneTracciamento;
  416.     }
  417.     
  418.     public HttpRequestConfig getPdndTracciamentoRequestConfig() {
  419.         return this.pdndTracciamentoRequestConfig;
  420.     }

  422.     public void setPdndTracciamentoRequestConfig(HttpRequestConfig pdndTracingRequestConfig) {
  423.         this.pdndTracciamentoRequestConfig = pdndTracingRequestConfig;
  424.     }
  425.     
  426.     public void setPdndTracciamentoMaxAttempt(Integer maxAttempt) {
  427.         this.pdndTracciamentoMaxAttempt = maxAttempt;
  428.     }
  429.     
  430.     public Integer getPdndTracciamentoMaxAttempt() {
  431.         return this.pdndTracciamentoMaxAttempt;
  432.     }
  433.     
  434.     public void setPdndTracciamentoPendingCheck(List<Integer> pdndTracciamentoPendingCheck) {
  435.         this.pdndTracciamentoPendingCheck = pdndTracciamentoPendingCheck;
  436.     }
  437.     
  438.     public List<Integer> getPdndTracciamentoPendingCheck() {
  439.         return this.pdndTracciamentoPendingCheck;
  440.     }
  441.     
  442.     public void setPdndTracciamentoSoggettiEnabled(Set<String> pdndTracingSoggettiEnabled) {
  443.         this.pdndTracciamentoSoggettiEnabled = pdndTracingSoggettiEnabled;
  444.     }
  445.     
  446.     public Set<String> getPdndTracciamentoSoggettiEnabled() {
  447.         return this.pdndTracciamentoSoggettiEnabled;
  448.     }

  450.     public boolean isPdndTracciamentoSoggettiDisabled() {
  451.         return this.pdndTracciamentoSoggettiDisabled;
  452.     }

  454.     public void setPdndTracciamentoSoggettiDisabled(boolean pdndTracciamentoSoggettiDisabled) {
  455.         this.pdndTracciamentoSoggettiDisabled = pdndTracciamentoSoggettiDisabled;
  456.     }
  457.     
  458.     public boolean isPdndTracciamentoErogazioniEnabled() {
  459.         return this.pdndTracciamentoErogazioniEnabled;
  460.     }

  462.     public void setPdndTracciamentoErogazioniEnabled(boolean pdndTracingErogazioniEnabled) {
  463.         this.pdndTracciamentoErogazioniEnabled = pdndTracingErogazioniEnabled;
  464.     }

  466.     public boolean isPdndTracciamentoFruizioniEnabled() {
  467.         return this.pdndTracciamentoFruizioniEnabled;
  468.     }

  470.     public void setPdndTracciamentoFruizioniEnabled(boolean pdndTracingFruizioniEnabled) {
  471.         this.pdndTracciamentoFruizioniEnabled = pdndTracingFruizioniEnabled;
  472.     }
  473. }
Created with JaCoCo 0.8.8.202204050719