ReportisticaHelper.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.core.monitor.rs.server.api.impl.utils;

  23. import java.sql.Connection;
  24. import java.text.SimpleDateFormat;
  25. import java.util.ArrayList;
  26. import java.util.List;
  27. import java.util.Optional;

  29. import org.apache.commons.lang3.StringUtils;
  30. import org.openspcoop2.core.id.IDAccordo;
  31. import org.openspcoop2.core.id.IDSoggetto;
  32. import org.openspcoop2.core.monitor.rs.server.config.DBManager;
  33. import org.openspcoop2.core.monitor.rs.server.config.LoggerProperties;
  34. import org.openspcoop2.core.monitor.rs.server.model.BaseOggettoWithSimpleName;
  35. import org.openspcoop2.core.monitor.rs.server.model.DimensioniReportCustomEnum;
  36. import org.openspcoop2.core.monitor.rs.server.model.DimensioniReportEnum;
  37. import org.openspcoop2.core.monitor.rs.server.model.EsitoTransazioneFullSearchEnum;
  38. import org.openspcoop2.core.monitor.rs.server.model.FiltroApiBase;
  39. import org.openspcoop2.core.monitor.rs.server.model.FiltroApiImplementata;
  40. import org.openspcoop2.core.monitor.rs.server.model.FiltroApiSoggetti;
  41. import org.openspcoop2.core.monitor.rs.server.model.FiltroEsito;
  42. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteErogazioneApplicativo;
  43. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteErogazioneSoggetto;
  44. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteFruizioneApplicativo;
  45. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteIdAutenticato;
  46. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteIndirizzoIP;
  47. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteTokenClaim;
  48. import org.openspcoop2.core.monitor.rs.server.model.FiltroMittenteTokenClaimSoggetto;
  49. import org.openspcoop2.core.monitor.rs.server.model.FiltroRicercaRuoloTransazioneEnum;
  50. import org.openspcoop2.core.monitor.rs.server.model.FormatoReportEnum;
  51. import org.openspcoop2.core.monitor.rs.server.model.OccupazioneBandaEnum;
  52. import org.openspcoop2.core.monitor.rs.server.model.OccupazioneBandaTipi;
  53. import org.openspcoop2.core.monitor.rs.server.model.OpzioniGenerazioneReport;
  54. import org.openspcoop2.core.monitor.rs.server.model.OpzioniGenerazioneReportBase;
  55. import org.openspcoop2.core.monitor.rs.server.model.OpzioniGenerazioneReportDimensioni;
  56. import org.openspcoop2.core.monitor.rs.server.model.OpzioniGenerazioneReportMultiLine;
  57. import org.openspcoop2.core.monitor.rs.server.model.RicercaBaseStatistica;
  58. import org.openspcoop2.core.monitor.rs.server.model.RicercaBaseStatisticaSoggetti;
  59. import org.openspcoop2.core.monitor.rs.server.model.RicercaConfigurazioneApi;
  60. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaAndamentoTemporale;
  61. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneApi;
  62. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneApplicativo;
  63. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneApplicativoRegistrato;
  64. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneAzione;
  65. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneErrori;
  66. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneEsiti;
  67. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneSoggettoLocale;
  68. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneSoggettoRemoto;
  69. import org.openspcoop2.core.monitor.rs.server.model.RicercaStatisticaDistribuzioneTokenInfo;
  70. import org.openspcoop2.core.monitor.rs.server.model.TempoMedioRispostaEnum;
  71. import org.openspcoop2.core.monitor.rs.server.model.TempoMedioRispostaTipi;
  72. import org.openspcoop2.core.monitor.rs.server.model.TipoFiltroMittenteEnum;
  73. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportEnum;
  74. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportMultiLineNumeroTransazioni;
  75. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportMultiLineOccupazioneBanda;
  76. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportMultiLineTempoMedioRisposta;
  77. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportNumeroTransazioni;
  78. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportOccupazioneBanda;
  79. import org.openspcoop2.core.monitor.rs.server.model.TipoInformazioneReportTempoMedioRisposta;
  80. import org.openspcoop2.core.monitor.rs.server.model.UnitaTempoReportEnum;
  81. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  82. import org.openspcoop2.generic_project.exception.NotFoundException;
  83. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  84. import org.openspcoop2.message.constants.ServiceBinding;
  85. import org.openspcoop2.protocol.sdk.config.IProtocolConfiguration;
  86. import org.openspcoop2.utils.date.DateUtils;
  87. import org.openspcoop2.utils.regexp.RegExpNotFoundException;
  88. import org.openspcoop2.utils.regexp.RegularExpressionEngine;
  89. import org.openspcoop2.utils.service.beans.TransazioneRuoloEnum;
  90. import org.openspcoop2.utils.service.context.IContext;
  91. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  92. import org.openspcoop2.web.monitor.statistiche.constants.CostantiExporter;
  93. import org.openspcoop2.web.monitor.statistiche.dao.ConfigurazioniGeneraliService;
  94. import org.openspcoop2.web.monitor.statistiche.dao.StatisticheGiornaliereService;


  97. /**
  98.  * ReportisticaHelper
  99.  * 
  100.  * @author $Author$
  101.  * @version $Rev$, $Date$
  102.  * 
  103.  */
  104. public class ReportisticaHelper {

  106.     private static void setEsitoCodice(EsitoTransazioneFullSearchEnum tipo , FiltroEsito filtro, HttpRequestWrapper wrap) {
  107.         if(filtro.getCodice()!=null) {
  108.             wrap.overrideParameter(CostantiExporter.ESITO, filtro.getCodice().toString());
  109.         }
  110.         else if(filtro.getCodici()!=null && !filtro.getCodici().isEmpty()) {
  111.             if(filtro.getCodici().size()==1) {
  112.                 wrap.overrideParameter(CostantiExporter.ESITO, filtro.getCodici().get(0).toString());
  113.             }
  114.             else {
  115.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Con il tipo di esito indicato '"+tipo.toString()+"' può essere indicato solamente un codice");
  116.             }
  117.         }
  118.     }
  119.     public static final void overrideFiltroEsito(FiltroEsito filtro, HttpRequestWrapper wrap, MonitoraggioEnv env) {

  121.         if (filtro != null) {

  123.             EsitoTransazioneFullSearchEnum tipo = CheckNotNull.getEsitoTransazione(filtro);
  124.             
  125.             switch (tipo) {
  126.             case QUALSIASI:
  127.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_OK);
  128.                 setEsitoCodice(tipo, filtro, wrap);
  129.                 if(filtro.isEscludiScartate()!=null) {
  130.                     wrap.overrideParameter(CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE, 
  131.                             filtro.isEscludiScartate() ? CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_TRUE : CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_FALSE);
  132.                 }
  133.                 break;
  134.             case OK:
  135.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_OK);
  136.                 setEsitoCodice(tipo, filtro, wrap);
  137.                 break;
  138.             case FAULT:
  139.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_FAULT_APPLICATIVO);
  140.                 setEsitoCodice(tipo, filtro, wrap);
  141.                 break;
  142.             case FALLITE:
  143.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_FALLITE);
  144.                 setEsitoCodice(tipo, filtro, wrap);
  145.                 if(filtro.isEscludiScartate()!=null) {
  146.                     wrap.overrideParameter(CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE, 
  147.                             filtro.isEscludiScartate() ? CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_TRUE : CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_FALSE);
  148.                 }
  149.                 break;
  150.             case FALLITE_E_FAULT:
  151.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO,
  152.                         CostantiExporter.ESITO_GRUPPO_FALLITE_E_FAULT_APPLICATIVO);
  153.                 setEsitoCodice(tipo, filtro, wrap);
  154.                 if(filtro.isEscludiScartate()!=null) {
  155.                     wrap.overrideParameter(CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE, 
  156.                             filtro.isEscludiScartate() ? CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_TRUE : CostantiExporter.ESCLUDI_RICHIESTE_SCARTATE_FALSE);
  157.                 }
  158.                 break;
  159.             case ERRORI_CONSEGNA:
  160.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_ERRORI_CONSEGNA);
  161.                 setEsitoCodice(tipo, filtro, wrap);
  162.                 break;
  163.             case RICHIESTE_SCARTATE:
  164.                 wrap.overrideParameter(CostantiExporter.ESITO_GRUPPO, CostantiExporter.ESITO_GRUPPO_RICHIESTE_SCARTATE);
  165.                 setEsitoCodice(tipo, filtro, wrap);
  166.                 break;
  167.             case PERSONALIZZATO:
  168.                 
  169.                 if(filtro.getCodice()==null && (filtro.getCodici()==null || filtro.getCodici().isEmpty())) {
  170.                     throw FaultCode.RICHIESTA_NON_VALIDA.toException("Con il tipo di esito indicato '"+tipo.toString()+"' deve essere indicato almeno un codice");
  171.                 }
  172.                 List<Integer> dettaglioEsito = filtro.getCodici();
  173.                 if(dettaglioEsito==null || dettaglioEsito.isEmpty()) {
  174.                     dettaglioEsito = new ArrayList<Integer>();
  175.                     dettaglioEsito.add(filtro.getCodice());
  176.                 }
  177.                 
  178.                 Iterable<String> esiti = dettaglioEsito.stream()
  179.                         .map(e -> e.toString())::iterator;

  181.                 wrap.overrideParameter(CostantiExporter.ESITO, String.join(",", esiti));
  182.                 
  183.                 break;
  184.             }
  185.         }
  186.     }

  188.     public static final void overrideRicercaBaseStatistica(RicercaBaseStatistica body, HttpRequestWrapper wrap,
  189.             MonitoraggioEnv env) {
  190.         if (body == null)
  191.             return;

  193.         // defaults:
  194.         if (body.getUnitaTempo() == null)
  195.             body.setUnitaTempo(UnitaTempoReportEnum.GIORNALIERO);
  196.         // Intervallo Temporale
  197.         SimpleDateFormat sdf = DateUtils.getSimpleDateFormatMs();
  198.         wrap.overrideParameter(CostantiExporter.DATA_INIZIO,
  199.                 sdf.format(body.getIntervalloTemporale().getDataInizio().toDate()));
  200.         wrap.overrideParameter(CostantiExporter.DATA_FINE,
  201.                 sdf.format(body.getIntervalloTemporale().getDataFine().toDate()));
  202.         wrap.overrideParameter(CostantiExporter.TIPO_UNITA_TEMPORALE,
  203.                 Enums.toStatisticType.get(body.getUnitaTempo()).toString());
  204.         wrap.overrideParameter(CostantiExporter.TIPOLOGIA,
  205.                 Enums.toTipologiaFiltroRicercaRuoloTransazioneEnum.get(body.getTipo()).toString());
  206.         if(body.getIdCluster()!=null) {
  207.             wrap.overrideParameter(CostantiExporter.ID_CLUSTER,
  208.                     body.getIdCluster());
  209.         }
  210.         if(body.getTag()!=null) {
  211.             wrap.overrideParameter(CostantiExporter.GRUPPO,
  212.                     body.getTag());
  213.         }
  214.     }

  216.     public static final void overrideFiltroMittenteIdApplicativo(FiltroMittenteIdAutenticato filtro,
  217.             HttpRequestWrapper wrap, MonitoraggioEnv env) {
  218.         if (filtro == null)
  219.             return;
  220.         
  221.         wrap.overrideParameter(CostantiExporter.TIPO_AUTENTICAZIONE,Enums.toTipoAutenticazione.get(filtro.getAutenticazione()).getValue());
  222.         if (filtro.getId() != null) {
  223.             wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, filtro.getId());
  224.         }
  225.         if (filtro.isRicercaEsatta() != null) {
  226.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, filtro.isRicercaEsatta() + "");
  227.         }
  228.         if (filtro.isCaseSensitive() != null) {
  229.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE,
  230.                     filtro.isCaseSensitive() + "");
  231.         }
  232.     }
  233.     
  234.     public static final void overrideFiltroMittenteIndirizzoIP(FiltroMittenteIndirizzoIP filtro,
  235.             HttpRequestWrapper wrap, MonitoraggioEnv env) {
  236.         if (filtro == null)
  237.             return;
  238.         
  239.         if(filtro.getTipo()!=null) {
  240.             wrap.overrideParameter(CostantiExporter.TIPO_INDIRIZZO_IP,Enums.toTipoIndirizzzoIP.get(filtro.getTipo()));
  241.         }
  242.         if (filtro.getId() != null) {
  243.             wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, filtro.getId());
  244.         }
  245.         if (filtro.isRicercaEsatta() != null) {
  246.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, filtro.isRicercaEsatta() + "");
  247.         }
  248.         if (filtro.isCaseSensitive() != null) {
  249.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE,
  250.                     filtro.isCaseSensitive() + "");
  251.         }
  252.     }
  253.     
  254.     public static final void overrideFiltroMittenteFruizione(TipoFiltroMittenteEnum tipo, Object filtro, boolean isDistribuzioneSoggettoRemoto, HttpRequestWrapper wrap,
  255.             MonitoraggioEnv env) {
  256.         if (filtro == null)
  257.             return;
  258.         if (tipo == null)
  259.             return;

  261.         wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE, Enums.toTipoRicercaMittente(tipo));
  262.         
  263.         switch (tipo) {
  264.         
  265.         case EROGAZIONE_SOGGETTO: {
  266.             throw FaultCode.RICHIESTA_NON_VALIDA
  267.                 .toException("Identificazione '"+tipo.toString()+"' "
  268.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.FRUIZIONE.toString()+"'");
  269.         }
  270.         
  271.         case FRUIZIONE_APPLICATIVO: {
  272.             
  273.             if(! (filtro instanceof FiltroMittenteFruizioneApplicativo)) {
  274.                 throw FaultCode.RICHIESTA_NON_VALIDA
  275.                 .toException("Identificazione '"+tipo.toString()+"' "
  276.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteFruizioneApplicativo.class.getName()+")");
  277.             }
  278.             FiltroMittenteFruizioneApplicativo fAppl = (FiltroMittenteFruizioneApplicativo) filtro;
  279.             if(fAppl.getTipoIdentificazioneApplicativo()!=null) {
  280.                 switch (fAppl.getTipoIdentificazioneApplicativo()) {
  281.                 case TRASPORTO:
  282.                     wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  283.                     break;
  284.                 case TOKEN:
  285.                     wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TOKEN);
  286.                     break;
  287.                 }
  288.             }
  289.             else {
  290.                 wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  291.             }
  292.             wrap.overrideParameter(CostantiExporter.APPLICATIVO, fAppl.getApplicativo());
  293.             break;
  294.         }
  295.         
  296.         case EROGAZIONE_APPLICATIVO: {
  297.             throw FaultCode.RICHIESTA_NON_VALIDA
  298.                 .toException("Identificazione '"+tipo.toString()+"' "
  299.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.FRUIZIONE.toString()+"'");
  300.         }
  301.         
  302.         case IDENTIFICATIVO_AUTENTICATO: {
  303.             
  304.             if(! (filtro instanceof FiltroMittenteIdAutenticato)) {
  305.                 throw FaultCode.RICHIESTA_NON_VALIDA
  306.                 .toException("Identificazione '"+tipo.toString()+"' "
  307.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIdAutenticato.class.getName()+")");
  308.             }
  309.             FiltroMittenteIdAutenticato fIdAutenticato = (FiltroMittenteIdAutenticato) filtro;
  310.             ReportisticaHelper.overrideFiltroMittenteIdApplicativo(fIdAutenticato, wrap, env);
  311.             break;
  312.         }
  313.         
  314.         case EROGAZIONE_TOKEN_INFO: {
  315.             throw FaultCode.RICHIESTA_NON_VALIDA
  316.                 .toException("Identificazione '"+tipo.toString()+"' "
  317.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.FRUIZIONE.toString()+"'");
  318.         }
  319.         
  320.         case TOKEN_INFO: {
  321.             if(! (filtro instanceof FiltroMittenteTokenClaim)) {
  322.                 throw FaultCode.RICHIESTA_NON_VALIDA
  323.                 .toException("Identificazione '"+tipo.toString()+"' "
  324.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteTokenClaim.class.getName()+")");
  325.             }
  326.             FiltroMittenteTokenClaim fClaim = (FiltroMittenteTokenClaim) filtro;
  327.             wrap.overrideParameter(CostantiExporter.RICERCA_MITTENTE_TIPO_CLAIM, Enums.toTokenSearchClaim.get(fClaim.getClaim()));
  328.             wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, fClaim.getId());
  329.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, fClaim.isRicercaEsatta() + "");
  330.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE,fClaim.isCaseSensitive() + "");
  331.             break;
  332.         }
  333.         case INDIRIZZO_IP: {
  334.             
  335.             if(! (filtro instanceof FiltroMittenteIndirizzoIP)) {
  336.                 throw FaultCode.RICHIESTA_NON_VALIDA
  337.                 .toException("Identificazione '"+tipo.toString()+"' "
  338.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIndirizzoIP.class.getName()+")");
  339.             }
  340.             FiltroMittenteIndirizzoIP indirizzoIP = (FiltroMittenteIndirizzoIP) filtro;
  341.             ReportisticaHelper.overrideFiltroMittenteIndirizzoIP(indirizzoIP, wrap, env);
  342.             break;
  343.         }
  344.         }
  345.     }
  346.     
  347.     public static final void overrideFiltroMittenteErogazione(TipoFiltroMittenteEnum tipo, Object filtro, boolean isDistribuzioneSoggettoRemoto, HttpRequestWrapper wrap,
  348.             MonitoraggioEnv env) {
  349.         if (filtro == null)
  350.             return;
  351.         if (tipo == null)
  352.             return;
  353.         
  354.         wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE, Enums.toTipoRicercaMittente(tipo));
  355.         
  356.         switch (tipo) {
  357.             case EROGAZIONE_SOGGETTO: {
  358.                 
  359.                 if(isDistribuzioneSoggettoRemoto) {
  360.                     throw FaultCode.RICHIESTA_NON_VALIDA
  361.                     .toException("Identificazione '"+tipo.toString()+"' "
  362.                             + "non utilizzabile nella generazione di un report con distribuzione per soggetto remoto");
  363.                 }
  364.                 
  365.                 if(! (filtro instanceof FiltroMittenteErogazioneSoggetto)) {
  366.                     throw FaultCode.RICHIESTA_NON_VALIDA
  367.                     .toException("Identificazione '"+tipo.toString()+"' "
  368.                             + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteErogazioneSoggetto.class.getName()+")");
  369.                 }
  370.                 FiltroMittenteErogazioneSoggetto fSogg = (FiltroMittenteErogazioneSoggetto) filtro;
  371.                 wrap.overrideParameter(CostantiExporter.MITTENTE, new IDSoggetto(env.tipoSoggetto, fSogg.getSoggetto()).toString());
  372.                 break;
  373.             }
  374.             
  375.             case FRUIZIONE_APPLICATIVO: {
  376.                 throw FaultCode.RICHIESTA_NON_VALIDA
  377.                 .toException("Identificazione '"+tipo.toString()+"' "
  378.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.EROGAZIONE.toString()+"'");
  379.             }
  380.             
  381.             case EROGAZIONE_APPLICATIVO: {
  382.                 
  383.                 if(isDistribuzioneSoggettoRemoto) {
  384.                     throw FaultCode.RICHIESTA_NON_VALIDA
  385.                     .toException("Identificazione '"+tipo.toString()+"' "
  386.                             + "non utilizzabile nella generazione di un report con distribuzione per soggetto remoto");
  387.                 }
  388.                 
  389.                 if(! (filtro instanceof FiltroMittenteErogazioneApplicativo)) {
  390.                     throw FaultCode.RICHIESTA_NON_VALIDA
  391.                     .toException("Identificazione '"+tipo.toString()+"' "
  392.                             + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteErogazioneApplicativo.class.getName()+")");
  393.                 }
  394.                 FiltroMittenteErogazioneApplicativo fAppl = (FiltroMittenteErogazioneApplicativo) filtro;
  395.                 if(fAppl.getTipoIdentificazioneApplicativo()!=null) {
  396.                     switch (fAppl.getTipoIdentificazioneApplicativo()) {
  397.                     case TRASPORTO:
  398.                         wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  399.                         break;
  400.                     case TOKEN:
  401.                         wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TOKEN);
  402.                         break;
  403.                     }
  404.                 }
  405.                 else {
  406.                     wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  407.                 }
  408.                 wrap.overrideParameter(CostantiExporter.APPLICATIVO, fAppl.getApplicativo());
  409.                 wrap.overrideParameter(CostantiExporter.MITTENTE,new IDSoggetto(env.tipoSoggetto, fAppl.getSoggetto()).toString());
  410.                 break;
  411.             }
  412.             
  413.             case IDENTIFICATIVO_AUTENTICATO: {
  414.                 
  415.                 if(! (filtro instanceof FiltroMittenteIdAutenticato)) {
  416.                     throw FaultCode.RICHIESTA_NON_VALIDA
  417.                     .toException("Identificazione '"+tipo.toString()+"' "
  418.                             + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIdAutenticato.class.getName()+")");
  419.                 }
  420.                 FiltroMittenteIdAutenticato fIdAutenticato = (FiltroMittenteIdAutenticato) filtro;
  421.                 ReportisticaHelper.overrideFiltroMittenteIdApplicativo(fIdAutenticato, wrap, env);
  422.                 break;
  423.             }
  424.             
  425.             case EROGAZIONE_TOKEN_INFO: {
  426.                 if(isDistribuzioneSoggettoRemoto) {
  427.                     throw FaultCode.RICHIESTA_NON_VALIDA
  428.                     .toException("Identificazione '"+tipo.toString()+"' "
  429.                             + "non utilizzabile nella generazione di un report con distribuzione per soggetto remoto");
  430.                 }
  431.                 else {
  432.                     if(! (filtro instanceof FiltroMittenteTokenClaimSoggetto)) {
  433.                         throw FaultCode.RICHIESTA_NON_VALIDA
  434.                         .toException("Identificazione '"+tipo.toString()+"' "
  435.                                 + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteTokenClaimSoggetto.class.getName()+")");
  436.                     }
  437.                     FiltroMittenteTokenClaimSoggetto fClaim = (FiltroMittenteTokenClaimSoggetto) filtro;
  438.                     wrap.overrideParameter(CostantiExporter.RICERCA_MITTENTE_TIPO_CLAIM, Enums.toTokenSearchClaim.get(fClaim.getClaim()));
  439.                     wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, fClaim.getId());
  440.                     wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, fClaim.isRicercaEsatta() + "");
  441.                     wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE, fClaim.isCaseSensitive() + "");
  442.                     if (fClaim.getSoggetto() != null) {
  443.                         wrap.overrideParameter(CostantiExporter.MITTENTE, new IDSoggetto(env.tipoSoggetto, fClaim.getSoggetto()).toString());
  444.                     }
  445.                     break;
  446.                 }
  447.             }
  448.             
  449.             case TOKEN_INFO: {
  450.                 if(! (filtro instanceof FiltroMittenteTokenClaim)) {
  451.                     throw FaultCode.RICHIESTA_NON_VALIDA
  452.                     .toException("Identificazione '"+tipo.toString()+"' "
  453.                             + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteTokenClaim.class.getName()+")");
  454.                 }
  455.                 FiltroMittenteTokenClaim fClaim = (FiltroMittenteTokenClaim) filtro;
  456.                 wrap.overrideParameter(CostantiExporter.RICERCA_MITTENTE_TIPO_CLAIM, Enums.toTokenSearchClaim.get(fClaim.getClaim()));
  457.                 wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, fClaim.getId());
  458.                 wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, fClaim.isRicercaEsatta() + "");
  459.                 wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE, fClaim.isCaseSensitive() + "");
  460.                 break;
  461.             }
  462.             
  463.             case INDIRIZZO_IP: {
  464.                 
  465.                 if(! (filtro instanceof FiltroMittenteIndirizzoIP)) {
  466.                     throw FaultCode.RICHIESTA_NON_VALIDA
  467.                     .toException("Identificazione '"+tipo.toString()+"' "
  468.                             + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIndirizzoIP.class.getName()+")");
  469.                 }
  470.                 FiltroMittenteIndirizzoIP indirizzoIP = (FiltroMittenteIndirizzoIP) filtro;
  471.                 ReportisticaHelper.overrideFiltroMittenteIndirizzoIP(indirizzoIP, wrap, env);
  472.                 break;
  473.             }
  474.         } // switch
  475.         
  476.     }
  477.         

  479.     
  480.     
  481.     
  482.     public static final void overrideFiltroMittenteQualsiasi(TipoFiltroMittenteEnum tipo, Object filtro, boolean isDistribuzioneSoggettoRemoto, HttpRequestWrapper wrap,
  483.             MonitoraggioEnv env) {
  484.         if (filtro == null)
  485.             return;
  486.         if (tipo == null)
  487.             return;

  489.         wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE, Enums.toTipoRicercaMittente(tipo));
  490.         
  491.         switch (tipo) {
  492.         
  493.         case EROGAZIONE_SOGGETTO: {
  494.             throw FaultCode.RICHIESTA_NON_VALIDA
  495.                 .toException("Identificazione '"+tipo.toString()+"' "
  496.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.QUALSIASI.toString()+"'");
  497.         }
  498.         
  499.         case FRUIZIONE_APPLICATIVO: {
  500.             throw FaultCode.RICHIESTA_NON_VALIDA
  501.                 .toException("Identificazione '"+tipo.toString()+"' "
  502.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.QUALSIASI.toString()+"'");
  503.         }
  504.         
  505.         case EROGAZIONE_APPLICATIVO: {
  506.             throw FaultCode.RICHIESTA_NON_VALIDA
  507.                 .toException("Identificazione '"+tipo.toString()+"' "
  508.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.QUALSIASI.toString()+"'");
  509.         }
  510.         
  511.         case IDENTIFICATIVO_AUTENTICATO: {
  512.             
  513.             if(! (filtro instanceof FiltroMittenteIdAutenticato)) {
  514.                 throw FaultCode.RICHIESTA_NON_VALIDA
  515.                 .toException("Identificazione '"+tipo.toString()+"' "
  516.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIdAutenticato.class.getName()+")");
  517.             }
  518.             FiltroMittenteIdAutenticato fIdAutenticato = (FiltroMittenteIdAutenticato) filtro;
  519.             ReportisticaHelper.overrideFiltroMittenteIdApplicativo(fIdAutenticato, wrap, env);
  520.             break;
  521.         }
  522.         
  523.         case EROGAZIONE_TOKEN_INFO: {
  524.             if(isDistribuzioneSoggettoRemoto) {
  525.                 throw FaultCode.RICHIESTA_NON_VALIDA
  526.                 .toException("Identificazione '"+tipo.toString()+"' "
  527.                         + "non utilizzabile nella generazione di un report con distribuzione per soggetto remoto");
  528.             }
  529.             else {
  530.                 throw FaultCode.RICHIESTA_NON_VALIDA
  531.                 .toException("Identificazione '"+tipo.toString()+"' "
  532.                         + "non utilizzabile nella generazione di un report con il criterio 'ruolo transazione' impostato al valore '"+FiltroRicercaRuoloTransazioneEnum.QUALSIASI.toString()+"'");
  533.             }
  534.         }
  535.         
  536.         case TOKEN_INFO: {
  537.             if(! (filtro instanceof FiltroMittenteTokenClaim)) {
  538.                 throw FaultCode.RICHIESTA_NON_VALIDA
  539.                 .toException("Identificazione '"+tipo.toString()+"' "
  540.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteTokenClaim.class.getName()+")");
  541.             }
  542.             FiltroMittenteTokenClaim fClaim = (FiltroMittenteTokenClaim) filtro;
  543.             wrap.overrideParameter(CostantiExporter.RICERCA_MITTENTE_TIPO_CLAIM, Enums.toTokenSearchClaim.get(fClaim.getClaim()));
  544.             wrap.overrideParameter(CostantiExporter.IDENTIFICATIVO_RICERCA_MITTENTE, fClaim.getId());
  545.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_ESATTA, fClaim.isRicercaEsatta() + "");
  546.             wrap.overrideParameter(CostantiExporter.TIPO_RICERCA_MITTENTE_CASE_SENSITIVE,fClaim.isCaseSensitive() + "");
  547.             break;
  548.         }
  549.         
  550.         case INDIRIZZO_IP: {
  551.             
  552.             if(! (filtro instanceof FiltroMittenteIndirizzoIP)) {
  553.                 throw FaultCode.RICHIESTA_NON_VALIDA
  554.                 .toException("Identificazione '"+tipo.toString()+"' "
  555.                         + "non utilizzabile con il tipo di filtro mittente utilizzato '"+filtro.getClass().getName()+"' (atteso: "+FiltroMittenteIndirizzoIP.class.getName()+")");
  556.             }
  557.             FiltroMittenteIndirizzoIP indirizzoIP = (FiltroMittenteIndirizzoIP) filtro;
  558.             ReportisticaHelper.overrideFiltroMittenteIndirizzoIP(indirizzoIP, wrap, env);
  559.             break;
  560.         }
  561.         }
  562.     }

  564.     public static final void overrideOpzioniGenerazioneReportBase(OpzioniGenerazioneReportBase body,
  565.             HttpRequestWrapper wrap, MonitoraggioEnv env) {
  566.         if (body == null)
  567.             return;

  569.         wrap.overrideParameter(CostantiExporter.TIPO_FORMATO, Enums.toTipoFormato.get(body.getFormato()));

  571.         org.openspcoop2.core.statistiche.constants.TipoReport tipoReport = Enums.toTipoReport.get(body.getTipo());
  572.         if (tipoReport == null)
  573.             tipoReport = org.openspcoop2.core.statistiche.constants.TipoReport.TABELLA;

  575.         wrap.overrideParameter(CostantiExporter.TIPO_REPORT, tipoReport.toString());
  576.     }

  578.     public static final void setTipoInformazioneReport(OpzioniGenerazioneReport opzioni, TipoInformazioneReportEnum tipoInformazioneReport, 
  579.             DimensioniReportEnum dimensioniReport, DimensioniReportCustomEnum dimensioniReportCustomInfo) {
  580.         TipoInformazioneReportEnum tipoInfo = tipoInformazioneReport!=null ? tipoInformazioneReport : TipoInformazioneReportEnum.NUMERO_TRANSAZIONI;
  581.         switch (tipoInfo) {
  582.         case NUMERO_TRANSAZIONI:
  583.             opzioni.setTipoInformazione(new TipoInformazioneReportNumeroTransazioni());
  584.             ((TipoInformazioneReportNumeroTransazioni)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  585.             break;
  586.         case OCCUPAZIONE_BANDA:
  587.             opzioni.setTipoInformazione(new TipoInformazioneReportOccupazioneBanda());
  588.             ((TipoInformazioneReportOccupazioneBanda)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  589.             break;
  590.         case TEMPO_MEDIO_RISPOSTA:
  591.             opzioni.setTipoInformazione(new TipoInformazioneReportTempoMedioRisposta());
  592.             ((TipoInformazioneReportTempoMedioRisposta)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  593.             break;
  594.         }
  595.         
  596.         if(dimensioniReport!=null && opzioni instanceof OpzioniGenerazioneReportDimensioni) {
  597.             OpzioniGenerazioneReportDimensioni o = (OpzioniGenerazioneReportDimensioni) opzioni;
  598.             o.setDimensioni(dimensioniReport);
  599.             if(dimensioniReportCustomInfo!=null && !DimensioniReportEnum._3DCUSTOM.equals(dimensioniReport)) {
  600.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Solamente con una dimensione '"+DimensioniReportEnum._3DCUSTOM.toString()+"' è possibile indicare una informazione custom da includere nel report");
  601.             }
  602.             o.setCustomInfo(dimensioniReportCustomInfo);
  603.         }
  604.     }
  605.     
  606.     public static final void overrideOpzioniGenerazioneReport(OpzioniGenerazioneReport body, HttpRequestWrapper wrap,
  607.             MonitoraggioEnv env) {
  608.         if (body == null)
  609.             return;

  611.         ReportisticaHelper.overrideOpzioniGenerazioneReportBase(body, wrap, env);

  613.         // defaults
  614.         if (body.getTipoInformazione() == null)
  615.             body.setTipoInformazione(new TipoInformazioneReportNumeroTransazioni());
  616.         if (body.getTipoInformazione().getTipo() == null) {
  617.             if(body.getTipoInformazione() instanceof TipoInformazioneReportNumeroTransazioni) {
  618.                 ((TipoInformazioneReportNumeroTransazioni)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.NUMERO_TRANSAZIONI);
  619.             }
  620.             else if(body.getTipoInformazione() instanceof TipoInformazioneReportOccupazioneBanda) {
  621.                 ((TipoInformazioneReportOccupazioneBanda)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.OCCUPAZIONE_BANDA);
  622.             }
  623.             else if(body.getTipoInformazione() instanceof TipoInformazioneReportTempoMedioRisposta) {
  624.                 ((TipoInformazioneReportTempoMedioRisposta)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.TEMPO_MEDIO_RISPOSTA);
  625.             }
  626.         }

  628.         wrap.overrideParameter(CostantiExporter.TIPO_INFORMAZIONE_VISUALIZZATA, Enums.toTipoVisualizzazione.get(body.getTipoInformazione().getTipo()).toString());
  629.         switch (body.getTipoInformazione().getTipo()) {
  630.         case NUMERO_TRANSAZIONI:
  631.             break;
  632.         case OCCUPAZIONE_BANDA: {
  633.             TipoInformazioneReportOccupazioneBanda ob = (TipoInformazioneReportOccupazioneBanda) body.getTipoInformazione();
  634.             OccupazioneBandaEnum val = ob.getOccupazioneBanda();
  635.             if(val==null) {
  636.                 val = OccupazioneBandaEnum.COMPLESSIVA;
  637.             }
  638.             wrap.overrideParameter(CostantiExporter.TIPO_BANDA_VISUALIZZATA, Enums.toTipoBanda.get(val).toString());
  639.             break;
  640.         }
  641.         case TEMPO_MEDIO_RISPOSTA: {
  642.             TipoInformazioneReportTempoMedioRisposta tm = (TipoInformazioneReportTempoMedioRisposta) body.getTipoInformazione();
  643.             TempoMedioRispostaEnum val = tm.getTempoMedioRisposta();
  644.             if(val==null) {
  645.                 val = TempoMedioRispostaEnum.TOTALE;
  646.             }
  647.             wrap.overrideParameter(CostantiExporter.TIPO_LATENZA_VISUALIZZATA, Enums.toTipoLatenza.get(val).toString());
  648.             break;
  649.         }
  650.         }
  651.         
  652.         if(body instanceof OpzioniGenerazioneReportDimensioni) {
  653.             OpzioniGenerazioneReportDimensioni o = (OpzioniGenerazioneReportDimensioni) body;
  654.             if(o.getDimensioni()!=null) {
  655.                 wrap.overrideParameter(CostantiExporter.DIMENSIONI_VISUALIZZATE, Enums.getNumeroDimensioniMap().get(o.getDimensioni()).getValue());
  656.             }
  657.             if(o.getCustomInfo()!=null) {
  658.                 wrap.overrideParameter(CostantiExporter.DIMENSIONE_INFO_CUSTOM, Enums.getInformazioneDimensioneCustom().get(o.getCustomInfo()).getValue());
  659.             }
  660.         }
  661.     }

  663.     public static final void setTipoInformazioneReportMultiLine(OpzioniGenerazioneReportMultiLine opzioni, TipoInformazioneReportEnum tipoInformazioneReport) {
  664.         TipoInformazioneReportEnum tipoInfo = tipoInformazioneReport!=null ? tipoInformazioneReport : TipoInformazioneReportEnum.NUMERO_TRANSAZIONI;
  665.         switch (tipoInfo) {
  666.         case NUMERO_TRANSAZIONI:
  667.             opzioni.setTipoInformazione(new TipoInformazioneReportMultiLineNumeroTransazioni());
  668.             ((TipoInformazioneReportMultiLineNumeroTransazioni)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  669.             break;
  670.         case OCCUPAZIONE_BANDA:
  671.             opzioni.setTipoInformazione(new TipoInformazioneReportMultiLineOccupazioneBanda());
  672.             ((TipoInformazioneReportMultiLineOccupazioneBanda)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  673.             break;
  674.         case TEMPO_MEDIO_RISPOSTA:
  675.             opzioni.setTipoInformazione(new TipoInformazioneReportMultiLineTempoMedioRisposta());
  676.             ((TipoInformazioneReportMultiLineTempoMedioRisposta)opzioni.getTipoInformazione()).setTipo(tipoInfo);
  677.             break;
  678.         }
  679.     }
  680.     
  681.     public static final void overrideOpzioniGenerazioneReportMultiLine(OpzioniGenerazioneReportMultiLine body,HttpRequestWrapper wrap, MonitoraggioEnv env) {
  682.         if (body == null)
  683.             return;

  685.         ReportisticaHelper.overrideOpzioniGenerazioneReportBase(body, wrap, env);

  687.         // defaults
  688.         if (body.getTipoInformazione() == null)
  689.             body.setTipoInformazione(new TipoInformazioneReportMultiLineNumeroTransazioni());
  690.         if (body.getTipoInformazione().getTipo() == null) {
  691.             if(body.getTipoInformazione() instanceof TipoInformazioneReportMultiLineNumeroTransazioni) {
  692.                 ((TipoInformazioneReportMultiLineNumeroTransazioni)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.NUMERO_TRANSAZIONI);
  693.             }
  694.             else if(body.getTipoInformazione() instanceof TipoInformazioneReportMultiLineOccupazioneBanda) {
  695.                 ((TipoInformazioneReportMultiLineOccupazioneBanda)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.OCCUPAZIONE_BANDA);
  696.             }
  697.             else if(body.getTipoInformazione() instanceof TipoInformazioneReportMultiLineTempoMedioRisposta) {
  698.                 ((TipoInformazioneReportMultiLineTempoMedioRisposta)body.getTipoInformazione()).setTipo(TipoInformazioneReportEnum.TEMPO_MEDIO_RISPOSTA);
  699.             }
  700.         }
  701.         
  702.         wrap.overrideParameter(CostantiExporter.TIPO_INFORMAZIONE_VISUALIZZATA, Enums.toTipoVisualizzazione.get(body.getTipoInformazione().getTipo()).toString());
  703.         switch (body.getTipoInformazione().getTipo()) {
  704.         case NUMERO_TRANSAZIONI:
  705.             break;
  706.         case OCCUPAZIONE_BANDA: {
  707.             TipoInformazioneReportMultiLineOccupazioneBanda ob = (TipoInformazioneReportMultiLineOccupazioneBanda) body.getTipoInformazione();
  708.             OccupazioneBandaTipi val = ob.getOccupazioneBanda();
  709.             if(val==null) {
  710.                 val = new OccupazioneBandaTipi(); // dentro il bean ci sono i default
  711.             }
  712.             ArrayList<String> abilitati = new ArrayList<>();
  713.             if (val.isBandaComplessiva())
  714.                 abilitati.add(Enums.toTipoBanda.get(OccupazioneBandaEnum.COMPLESSIVA).toString());
  715.             if (val.isBandaEsterna())
  716.                 abilitati.add(Enums.toTipoBanda.get(OccupazioneBandaEnum.ESTERNA).toString());
  717.             if (val.isBandaInterna())
  718.                 abilitati.add(Enums.toTipoBanda.get(OccupazioneBandaEnum.INTERNA).toString());

  720.             wrap.overrideParameter(CostantiExporter.TIPO_BANDA_VISUALIZZATA, String.join(",", abilitati));
  721.             break;
  722.         }
  723.         case TEMPO_MEDIO_RISPOSTA: {
  724.             TipoInformazioneReportMultiLineTempoMedioRisposta tm = (TipoInformazioneReportMultiLineTempoMedioRisposta) body.getTipoInformazione();
  725.             TempoMedioRispostaTipi val = tm.getTempoMedioRisposta();
  726.             if(val==null) {
  727.                 val = new TempoMedioRispostaTipi(); // dentro il bean ci sono i default
  728.             }
  729.             ArrayList<String> abilitati = new ArrayList<>();
  730.             if (val.isLatenzaGateway())
  731.                 abilitati.add(Enums.toTipoLatenza.get(TempoMedioRispostaEnum.GATEWAY).toString());
  732.             if (val.isLatenzaServizio())
  733.                 abilitati.add(Enums.toTipoLatenza.get(TempoMedioRispostaEnum.SERVIZIO).toString());
  734.             if (val.isLatenzaTotale())
  735.                 abilitati.add(Enums.toTipoLatenza.get(TempoMedioRispostaEnum.TOTALE).toString());

  737.             wrap.overrideParameter(CostantiExporter.TIPO_LATENZA_VISUALIZZATA, String.join(",", abilitati));
  738.             break;
  739.         }
  740.         }
  741.     }


  744.     public static final void overrideRicercaBaseStatisticaSoggetti(RicercaBaseStatisticaSoggetti body,
  745.             HttpRequestWrapper wrap, MonitoraggioEnv env) throws Exception {
  746.         if (body == null)
  747.             return;

  749.         ReportisticaHelper.overrideRicercaBaseStatistica(body, wrap, env);

  751.         switch (body.getTipo()) {
  752.         case EROGAZIONE:
  753.             ReportisticaHelper.overrideFiltroErogazione(body.getTag(), body.getApi(), wrap, env);
  754.             break;
  755.         case FRUIZIONE:
  756.             ReportisticaHelper.overrideFiltroFruizione(body.getTag(), body.getApi(), wrap, env);
  757.             break;
  758.         case QUALSIASI:
  759.             ReportisticaHelper.overrideFiltroQualsiasi(body.getTag(), body.getApi(), wrap, env);
  760.             break;
  761.         }
  762.     }

  764.     public static final void overrideFiltroFruizione(String tag, FiltroApiSoggetti body, HttpRequestWrapper wrap,
  765.             MonitoraggioEnv env) throws Exception {
  766.         if (body == null) return;
  767.         
  768.         IDSoggetto erogatore = new IDSoggetto(env.tipoSoggetto, body.getErogatore());
  769.         ReportisticaHelper.overrideFiltroApiBase(tag, body, erogatore, wrap, env);
  770.     }

  772.     public static final void overrideFiltroErogazione(String tag, FiltroApiSoggetti body, HttpRequestWrapper wrap, MonitoraggioEnv env) throws Exception {
  773.         if (body == null)
  774.             return;
  775.         IDSoggetto idSoggettoLocale = new IDSoggetto(env.tipoSoggetto, env.nomeSoggettoLocale);
  776.         ReportisticaHelper.overrideFiltroApiBase(tag, body, idSoggettoLocale, wrap, env);
  777.     }
  778.     
  779.     public static final void overrideFiltroQualsiasi(String tag, FiltroApiSoggetti body, HttpRequestWrapper wrap, MonitoraggioEnv env) throws Exception {
  780.         if (body == null)
  781.             return;
  782.         
  783.         IDSoggetto erogatore = new IDSoggetto(env.tipoSoggetto, body.getErogatore());
  784.         ReportisticaHelper.overrideFiltroApiBase(tag, body, erogatore, wrap, env);
  785.         if (!StringUtils.isEmpty(body.getSoggettoRemoto())) {
  786.             IDSoggetto remoto = new IDSoggetto(env.tipoSoggetto, body.getSoggettoRemoto());
  787.             wrap.overrideParameter(CostantiExporter.TRAFFICO_PER_SOGGETTO, remoto.toString() );
  788.         }
  789.         
  790.     }

  792.     public static final void overrideFiltroApiBase(String tag, FiltroApiBase filtro_api, IDSoggetto erogatore, HttpRequestWrapper wrap, MonitoraggioEnv env) throws Exception {
  793.         if(tag!=null) {
  794.             wrap.overrideParameter(CostantiExporter.GRUPPO, tag);
  795.         }
  796.         
  797.         if (filtro_api == null)
  798.             return;
  799.         
  800.         if ( !StringUtils.isEmpty(filtro_api.getNome()) || filtro_api.getVersione() != null || !StringUtils.isEmpty(filtro_api.getTipo())) {
  801.             
  802.             if (StringUtils.isEmpty(filtro_api.getNome())) {
  803.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Filtro Api incompleto. Specificare il nome della API");
  804.             }
  805.                         
  806.             if (erogatore == null || TransazioniHelper.isEmpty(erogatore)) {
  807.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Filtro Api incompleto. Specificare il Soggetto Erogatore (Nelle fruizioni è il soggetto remoto)");
  808.             }
  809.             
  810.             if (filtro_api.getVersione() == null) {
  811.                 filtro_api.setVersione(1);
  812.             }
  813.             
  814.             if (filtro_api.getTipo() == null) {
  815.                 try {
  816.                     IProtocolConfiguration protocolConf = env.protocolFactoryMgr
  817.                             .getProtocolFactoryByName(env.tipo_protocollo).createProtocolConfiguration();
  818.                     ServiceBinding defaultBinding = protocolConf.getDefaultServiceBindingConfiguration(null)
  819.                             .getDefaultBinding();
  820.                     filtro_api.setTipo(protocolConf.getTipoServizioDefault(defaultBinding));
  821.                 } catch (Exception e) {
  822.                     throw FaultCode.ERRORE_INTERNO
  823.                             .toException("Impossibile determinare il tipo del servizio: " + e.getMessage());
  824.                 }

  826.             }
  827.             wrap.overrideParameter(CostantiExporter.SERVIZIO,
  828.                     ReportisticaHelper.buildNomeServizioForOverride(filtro_api.getNome(), filtro_api.getTipo(), filtro_api.getVersione(), Optional.of(erogatore)));
  829.         }
  830.         
  831.         if(filtro_api instanceof FiltroApiSoggetti) {
  832.             FiltroApiSoggetti filtroApiSoggetti = (FiltroApiSoggetti) filtro_api;
  833.             if(filtroApiSoggetti.getApiImplementata()!=null) {
  834.                 wrap.overrideParameter(CostantiExporter.API,
  835.                         ReportisticaHelper.toUriApiImplementata(filtroApiSoggetti.getApiImplementata(), env));
  836.             }
  837.         }
  838.     }

  840.     public static final void overrideRicercaStatisticaDistribuzioneApplicativo(
  841.             RicercaStatisticaDistribuzioneApplicativo body, HttpRequestWrapper wrap, MonitoraggioEnv env) throws Exception {
  842.         if (body == null)
  843.             return;
  844.         
  845.         if (body.getAzione() != null && body.getApi() == null) {
  846.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  847.         }

  849.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  850.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());
  851.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);
  852.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  853.     }
  854.     

  856.     public static final byte[] generateReport(HttpRequestWrapper request, IContext context) throws Exception {
  857.         DBManager dbManager = DBManager.getInstance();
  858.         Connection connectionConfig = null;
  859.         Connection connectionStats = null;
  860.         Connection connectionTransazioni = null;
  861.         StatisticheGiornaliereService statisticheService = null;
  862.         ServiceManagerProperties smp = null;
  863.         boolean uniqueConnection = false;
  864.         try {
  865.             connectionStats = dbManager.getConnectionStatistiche();
  866.             smp = dbManager.getServiceManagerPropertiesTracce();
  867.             
  868.             if(dbManager.getDataSourceStatisticheName().equals(dbManager.getDataSourceTracceName()) && 
  869.                     dbManager.getDataSourceStatisticheName().equals(dbManager.getDataSourceConfigName())) {
  870.                 // unico datasource
  871.                 uniqueConnection = true;
  872.             }
  873.             
  874.             if(uniqueConnection) {
  875.                 statisticheService = new StatisticheGiornaliereService(connectionStats, true, smp,
  876.                         LoggerProperties.getLoggerDAO());
  877.             }
  878.             else {
  879.                 
  880.                 Connection ctracce = connectionStats;
  881.                 if( !dbManager.getDataSourceStatisticheName().equals(dbManager.getDataSourceTracceName()) ) {
  882.                     connectionTransazioni = dbManager.getConnectionTracce();
  883.                     ctracce = connectionTransazioni;
  884.                 }
  885.                 
  886.                 Connection cconfig = connectionStats;
  887.                 if( !dbManager.getDataSourceStatisticheName().equals(dbManager.getDataSourceConfigName()) ) {
  888.                     connectionConfig = dbManager.getConnectionConfig();
  889.                     cconfig = connectionConfig;
  890.                 }
  891.                 
  892.                 statisticheService = new StatisticheGiornaliereService(cconfig, connectionStats, ctracce, true, smp,
  893.                         LoggerProperties.getLoggerDAO());
  894.             }

  896.         } catch (Exception e) {
  897.             dbManager.releaseConnectionStatistiche(connectionStats);
  898.             if(!uniqueConnection) {
  899.                 dbManager.releaseConnectionConfig(connectionConfig);
  900.                 dbManager.releaseConnectionTracce(connectionTransazioni);
  901.             }
  902.             throw FaultCode.ERRORE_INTERNO.toException(e);
  903.         }

  905.         try {
  906.             return StatsGenerator.generateReport(request, context, statisticheService);
  907.         } catch (NotFoundException e) {
  908.             throw FaultCode.NOT_FOUND.toException(e);
  909.         } catch (Exception e) {
  910.             throw FaultCode.ERRORE_INTERNO.toException(e);
  911.         } finally {
  912.             dbManager.releaseConnectionStatistiche(connectionStats);
  913.             if(!uniqueConnection) {
  914.                 dbManager.releaseConnectionConfig(connectionConfig);
  915.                 dbManager.releaseConnectionTracce(connectionTransazioni);
  916.             }
  917.         }
  918.     }

  920.     public static final byte[] getReportDistribuzioneApi(RicercaStatisticaDistribuzioneApi body, MonitoraggioEnv env)
  921.             throws Exception {

  923.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  924.         HttpRequestWrapper request = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  925.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.api);

  927.         ReportisticaHelper.overrideRicercaBaseStatistica(body, request, env);
  928.         // Api Implementata
  929.         if(body.isDistinguiApiImplementata()!=null) {
  930.             request.overrideParameter(CostantiExporter.API_DISTINGUI_IMPLEMENTAZIONE,
  931.                     body.isDistinguiApiImplementata() ? CostantiExporter.API_DISTINGUI_IMPLEMENTAZIONE_TRUE : CostantiExporter.API_DISTINGUI_IMPLEMENTAZIONE_FALSE);
  932.         }
  933.         // Mittente
  934.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  935.             switch (body.getTipo()) {
  936.             case EROGAZIONE:
  937.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), false,
  938.                         request,env);
  939.                 break;
  940.             case FRUIZIONE:
  941.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), false,
  942.                         request, env);
  943.                 break;
  944.             case QUALSIASI:
  945.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), false,
  946.                         request, env);
  947.                 break;
  948.             }
  949.         }
  950.         // FiltroEsito
  951.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), request, env);
  952.         // Soggetto Erogatore
  953.         if(body.getSoggettoErogatore()!=null) {
  954.             if(!FiltroRicercaRuoloTransazioneEnum.FRUIZIONE.equals(body.getTipo())) {
  955.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Il criterio di ricerca per soggetto erogatore è indicabile solamente se si genera report relativi a transazioni con ruolo '"+FiltroRicercaRuoloTransazioneEnum.FRUIZIONE.toString()+"'");
  956.             }
  957.             BaseOggettoWithSimpleName base = body.getSoggettoErogatore();
  958.             if(base.getNome()!=null) {
  959.                 request.overrideParameter(CostantiExporter.DESTINATARIO, new IDSoggetto(env.tipoSoggetto,base.getNome()));
  960.             }
  961.         }
  962.         // Opzioni Report
  963.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), request, env);

  965.         return ReportisticaHelper.generateReport(request, env.context);
  966.     }

  968.     public static final byte[] getReportDistribuzioneApplicativo(RicercaStatisticaDistribuzioneApplicativoRegistrato body,
  969.             MonitoraggioEnv env) throws Exception {
  970.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  971.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  972.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.applicativo);
  973.         
  974.         if (body.getAzione() != null && body.getApi() == null) {
  975.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  976.         }

  978.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  979.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  980.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);
  981.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());

  983.         if(body.getTipoIdentificazioneApplicativo()!=null) {
  984.             switch (body.getTipoIdentificazioneApplicativo()) {
  985.             case TRASPORTO:
  986.                 wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  987.                 break;
  988.             case TOKEN:
  989.                 wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TOKEN);
  990.                 break;
  991.             }
  992.         }
  993.         else {
  994.             wrap.overrideParameter(CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO, CostantiExporter.TIPO_IDENTIFICAZIONE_APPLICATIVO_TRASPORTO);
  995.         }
  996.         
  997.         if(body.getSoggettoMittente()!=null && !StringUtils.isEmpty(body.getSoggettoMittente())) {
  998.             if(body.getTipo()!=null && FiltroRicercaRuoloTransazioneEnum.EROGAZIONE.equals(body.getTipo())) {
  999.                 wrap.overrideParameter(CostantiExporter.MITTENTE,new IDSoggetto(env.tipoSoggetto, body.getSoggettoMittente()).toString());
  1000.             }
  1001.             else {
  1002.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Nel caso di ruolo <" + body.getTipo()
  1003.                         + ">, non è possibile specificare il soggetto mittente");
  1004.             }
  1005.         }
  1006.         
  1007.         return ReportisticaHelper.generateReport(wrap, env.context);
  1008.     }

  1010.     public static final byte[] getReportDistribuzioneAzione(RicercaStatisticaDistribuzioneAzione body,MonitoraggioEnv env) throws Exception {
  1011.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1012.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1013.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.azione);

  1015.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  1016.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  1017.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);

  1019.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1020.             switch (body.getTipo()) {
  1021.             case EROGAZIONE:
  1022.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1023.                 break;
  1024.             case FRUIZIONE:
  1025.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1026.                 break;
  1027.             case QUALSIASI:
  1028.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1029.                 break;
  1030.             }
  1031.         }

  1033.         return ReportisticaHelper.generateReport(wrap, env.context);
  1034.     }
  1035.     
  1036.     public static final byte[] getReportDistribuzioneErrori(RicercaStatisticaDistribuzioneErrori body,MonitoraggioEnv env) throws Exception {
  1037.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1038.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1039.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.errori);

  1041.         if(body.getEsito()==null) {
  1042.             body.setEsito(new FiltroEsito());
  1043.         }
  1044.         CheckNotNull.setTipoEsito(body);
  1045.         
  1046.         if(EsitoTransazioneFullSearchEnum.QUALSIASI.equals(body.getEsito().getTipo())) {
  1047.             body.getEsito().setTipo(EsitoTransazioneFullSearchEnum.FALLITE_E_FAULT); // forzo fallite
  1048.         }
  1049.         else if(EsitoTransazioneFullSearchEnum.OK.equals(body.getEsito().getTipo())) {
  1050.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Esito 'OK' non utilizzabile con questo tipo di report");
  1051.         }
  1052.         
  1053.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  1054.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  1055.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);

  1057.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1058.             switch (body.getTipo()) {
  1059.             case EROGAZIONE:
  1060.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1061.                 break;
  1062.             case FRUIZIONE:
  1063.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1064.                 break;
  1065.             case QUALSIASI:
  1066.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1067.                 break;
  1068.             }
  1069.         }
  1070.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());

  1072.         return ReportisticaHelper.generateReport(wrap, env.context);
  1073.     }

  1075.     public static final byte[] getReportDistribuzioneEsiti(RicercaStatisticaDistribuzioneEsiti body,MonitoraggioEnv env) throws Exception {
  1076.         
  1077.         if (body.getAzione() != null && body.getApi() == null) {
  1078.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  1079.         }
  1080.         
  1081.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1082.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1083.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.esiti);

  1085.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  1086.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);
  1087.         // Mittente
  1088.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1089.             switch (body.getTipo()) {
  1090.             case EROGAZIONE:
  1091.                 ReportisticaHelper.overrideFiltroMittenteErogazione( body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1092.                 break;
  1093.             case FRUIZIONE:
  1094.                 ReportisticaHelper.overrideFiltroMittenteFruizione( body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1095.                 break;
  1096.             case QUALSIASI:
  1097.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi( body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1098.                 break;
  1099.             }
  1100.         }
  1101.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());
  1102.         return ReportisticaHelper.generateReport(wrap, env.context);
  1103.     }

  1105.     public static final byte[] getReportDistribuzioneIdAutenticato(RicercaStatisticaDistribuzioneApplicativo body,
  1106.             MonitoraggioEnv env) throws Exception {
  1107.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1108.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1109.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, 
  1110.                 TipoReport.identificativo_autenticato);

  1112.         ReportisticaHelper.overrideRicercaStatisticaDistribuzioneApplicativo(body, wrap, env);

  1114.         return ReportisticaHelper.generateReport(wrap, env.context);
  1115.     }
  1116.     
  1117.     public static final byte[] getReportDistribuzioneIndirizzoIP(RicercaStatisticaDistribuzioneApplicativo body,
  1118.             MonitoraggioEnv env) throws Exception {
  1119.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1120.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1121.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, 
  1122.                 TipoReport.indirizzo_ip);

  1124.         ReportisticaHelper.overrideRicercaStatisticaDistribuzioneApplicativo(body, wrap, env);

  1126.         return ReportisticaHelper.generateReport(wrap, env.context);
  1127.     }


  1130.     public static final byte[] getReportDistribuzioneSoggettoRemoto(RicercaStatisticaDistribuzioneSoggettoRemoto body,
  1131.             MonitoraggioEnv env) throws Exception {
  1132.         
  1133.         if (body.getAzione() != null && body.getApi() == null) {
  1134.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  1135.         }
  1136.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1137.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1138.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.soggetto_remoto);
  1139.         ReportisticaHelper.overrideRicercaBaseStatistica(body, wrap, env);
  1140.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);
  1141.         switch (body.getTipo()) {
  1142.         case EROGAZIONE:
  1143.             if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1144.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), true, wrap, env);
  1145.             }
  1146.             if(body.getApi()!=null) {
  1147.                 ReportisticaHelper.overrideFiltroErogazione(body.getTag(), body.getApi(), wrap,env);
  1148.             }
  1149.             break;
  1150.         case FRUIZIONE:
  1151.             if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1152.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), true, wrap, env);
  1153.             }
  1154.             if(body.getApi()!=null) {
  1155.                 ReportisticaHelper.overrideFiltroFruizione(body.getTag(), body.getApi(), wrap, env);
  1156.             }
  1157.             break;
  1158.         case QUALSIASI:
  1159.             if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1160.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), true, wrap, env);
  1161.             }
  1162.             if(body.getApi()!=null) {
  1163.                 ReportisticaHelper.overrideFiltroQualsiasi(body.getTag(), body.getApi(), wrap, env);
  1164.             }
  1165.             break;
  1166.         }
  1167.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  1168.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());

  1170.         return ReportisticaHelper.generateReport(wrap, env.context);
  1171.     }

  1173.     public static final byte[] getReportDistribuzioneTemporale(RicercaStatisticaAndamentoTemporale body,MonitoraggioEnv env) throws Exception {
  1174.         
  1175.         if (body.getAzione() != null && body.getApi() == null) {
  1176.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  1177.         }
  1178.         
  1179.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1180.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1181.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.temporale);

  1183.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  1184.         ReportisticaHelper.overrideOpzioniGenerazioneReportMultiLine(body.getReport(), wrap, env);
  1185.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1186.             switch (body.getTipo()) {
  1187.             case EROGAZIONE:
  1188.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1189.                 break;
  1190.             case FRUIZIONE:
  1191.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1192.                 break;
  1193.             case QUALSIASI:
  1194.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1195.                 break;
  1196.             }
  1197.         }
  1198.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  1199.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());

  1201.         return ReportisticaHelper.generateReport(wrap, env.context);
  1202.     }

  1204.     public static final byte[] getReportDistribuzioneTokenInfo(RicercaStatisticaDistribuzioneTokenInfo body,
  1205.             MonitoraggioEnv env) throws Exception {
  1206.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1207.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo,
  1208.                 env.nomeSoggettoLocale, body.getTipo(), body.getReport().getFormato(), true, TipoReport.token_info);

  1210.         ReportisticaHelper.overrideRicercaStatisticaDistribuzioneApplicativo(body, wrap, env);
  1211.         wrap.overrideParameter(CostantiExporter.CLAIM, Enums.toDistribuzioneTokenClaim.get(body.getClaim()).toString());

  1213.         if(body.getSoggetto()!=null) {
  1214.             if(!FiltroRicercaRuoloTransazioneEnum.EROGAZIONE.equals(body.getTipo())) {
  1215.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Il criterio di ricerca per soggetto è indicabile solamente se si genera report relativi a transazioni con ruolo '"+FiltroRicercaRuoloTransazioneEnum.EROGAZIONE.toString()+"'");
  1216.             }
  1217.             BaseOggettoWithSimpleName base = body.getSoggetto();
  1218.             if(base.getNome()!=null) {
  1219.                 wrap.overrideParameter(CostantiExporter.MITTENTE,new IDSoggetto(env.tipoSoggetto, base.getNome()).toString());
  1220.             }
  1221.         }

  1223.         return ReportisticaHelper.generateReport(wrap, env.context);
  1224.     }

  1226.     public static final byte[] getReportDistribuzioneSoggettoLocale(RicercaStatisticaDistribuzioneSoggettoLocale body,
  1227.             MonitoraggioEnv env) throws Exception {
  1228.         
  1229.         if (body.getAzione() != null && body.getApi() == null) {
  1230.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Se viene specificato il filtro 'azione' è necessario specificare anche il filtro Api");
  1231.         }
  1232.         
  1233.         SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  1234.         HttpRequestWrapper wrap = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo, null,
  1235.                 body.getTipo(), body.getReport().getFormato(), true, TipoReport.soggetto_locale);

  1237.         ReportisticaHelper.overrideRicercaBaseStatisticaSoggetti(body, wrap, env);
  1238.         ReportisticaHelper.overrideFiltroEsito(body.getEsito(), wrap, env);
  1239.         ReportisticaHelper.overrideOpzioniGenerazioneReport(body.getReport(), wrap, env);

  1241.         if(body.getMittente()!=null && body.getMittente().getIdentificazione()!=null) {
  1242.             switch (body.getTipo()) {
  1243.             case EROGAZIONE:
  1244.                 ReportisticaHelper.overrideFiltroMittenteErogazione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1245.                 break;
  1246.             case FRUIZIONE:
  1247.                 ReportisticaHelper.overrideFiltroMittenteFruizione(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1248.                 break;
  1249.             case QUALSIASI:
  1250.                 ReportisticaHelper.overrideFiltroMittenteQualsiasi(body.getMittente().getIdentificazione(), body.getMittente(), false, wrap, env);
  1251.                 break;
  1252.             }
  1253.         }

  1255.         wrap.overrideParameter(CostantiExporter.AZIONE, body.getAzione());

  1257.         return ReportisticaHelper.generateReport(wrap, env.context);
  1258.     }

  1260.     public static final String buildNomeServizioForOverride(String nomeServizio, String tipoServizio,
  1261.             Integer versioneServizio, Optional<IDSoggetto> erogatore) {
  1262.         if (nomeServizio == null || tipoServizio == null || versioneServizio == null)
  1263.             return null;

  1265.         StringBuilder uri = new StringBuilder();
  1266.         String nomeAsps = nomeServizio;
  1267.         String tipoAsps = tipoServizio;

  1269.         // Per popolare il campo NomeServizio seguo quanto fatto in
  1270.         // DynamicPdDBeanUtils._getListaSelectItemsElencoServiziErogazione
  1271.         uri.append(tipoAsps).append("/");
  1272.         uri.append(nomeAsps).append(":").append(versioneServizio);
  1273.         if (erogatore.isPresent())
  1274.             uri.append(" (").append(erogatore.get().getTipo()).append("/").append(erogatore.get().getNome())
  1275.                     .append(")");

  1277.         return uri.toString();
  1278.     }

  1280.     public static final String getTipoServizioDefault(MonitoraggioEnv env) {

  1282.         try {
  1283.             IProtocolConfiguration protocolConf = env.protocolFactoryMgr.getProtocolFactoryByName(env.tipo_protocollo)
  1284.                     .createProtocolConfiguration();
  1285.             ServiceBinding defaultBinding = protocolConf.getDefaultServiceBindingConfiguration(null)
  1286.                     .getDefaultBinding();
  1287.             return protocolConf.getTipoServizioDefault(defaultBinding);
  1288.         } catch (Exception e) {
  1289.             throw FaultCode.ERRORE_INTERNO
  1290.                     .toException("Impossibile determinare il tipo del servizio: " + e.getMessage());
  1291.         }
  1292.     }

  1294.     public static final byte[] exportConfigurazioneApi(RicercaConfigurazioneApi body, MonitoraggioEnv env) throws Exception {
  1295.         DBManager dbManager = DBManager.getInstance();
  1296.         Connection connection = null;
  1297.         ConfigurazioniGeneraliService configurazioniService = null;
  1298.         SearchFormUtilities searchFormUtilities = null;
  1299.         HttpRequestWrapper request = null;
  1300.                 
  1301.         try {
  1302.             connection = dbManager.getConnectionConfig();
  1303.             ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesConfig();
  1304.             configurazioniService = new ConfigurazioniGeneraliService(connection, true, smp, LoggerProperties.getLoggerDAO());
  1305.             searchFormUtilities = new SearchFormUtilities();
  1306.             FormatoReportEnum formatoReport = null;
  1307.             if(body.getFormato()!=null) {
  1308.                 switch (body.getFormato()) {
  1309.                 case CSV:
  1310.                     formatoReport = FormatoReportEnum.CSV;
  1311.                     break;
  1312.                 case XLS:
  1313.                     formatoReport = FormatoReportEnum.XLS;
  1314.                     break;
  1315.                 default:
  1316.                     formatoReport = FormatoReportEnum.CSV;
  1317.                     break;
  1318.                 }
  1319.             }
  1320.             else {
  1321.                 formatoReport = FormatoReportEnum.CSV;
  1322.             }
  1323.             request = searchFormUtilities.getHttpRequestWrapper(env.context, env.profilo, env.nomeSoggettoLocale,
  1324.                     body.getTipo(), formatoReport, false, TipoReport.api);
  1325.         }
  1326.         catch (Exception e) {
  1327.             dbManager.releaseConnectionConfig(connection);
  1328.             throw new RuntimeException(e);
  1329.         }
  1330.         
  1331.         String tag = null;
  1332.         switch (body.getTipo()) {
  1333.             case EROGAZIONE: {          
  1334.                 ReportisticaHelper.overrideFiltroErogazione(tag, body.getApi(), request, env);
  1335.                 break;
  1336.             }
  1337.             case FRUIZIONE:
  1338.                 ReportisticaHelper.overrideFiltroFruizione(tag, body.getApi(), request, env);
  1339.                 break;
  1340.         }

  1342.         try {
  1343.             byte[] report = StatsGenerator.generateReport(request, env.context, configurazioniService);
  1344.             return report;
  1345.         } catch (NotFoundException e) {
  1346.             throw FaultCode.NOT_FOUND.toException(e);
  1347.         } catch (Exception e) {
  1348.             throw FaultCode.ERRORE_INTERNO.toException(e);
  1349.         } finally {
  1350.             dbManager.releaseConnectionConfig(connection);
  1351.         }
  1352.     }
  1353.     
  1354.     public static final FiltroApiImplementata parseUriApiImplementata(String uriApiImplementata, MonitoraggioEnv env) throws Exception {
  1355.         //  tipoSoggettoReferente/nomeSoggettoReferente:nomeAccordo:versione
  1356.         String pattern1 = "^[a-z]{2,20}/[0-9A-Za-z]+:[_A-Za-z][\\-\\._A-Za-z0-9]*:\\d$";
  1357.         String pattern2 = "^[_A-Za-z][\\-\\._A-Za-z0-9]*:\\d$";
  1358.         IDAccordo idAccordo = null;
  1359.         try {
  1360.             if(RegularExpressionEngine.isMatch(uriApiImplementata, pattern1)) {
  1361.                 idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromUri(uriApiImplementata);
  1362.             }
  1363.             else if(RegularExpressionEngine.isMatch(uriApiImplementata, pattern2)) {
  1364.                 String uriCompleto = env.tipoSoggetto+"/"+env.nomeSoggettoLocale+":"+uriApiImplementata;
  1365.                 idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromUri(uriCompleto);
  1366.             }
  1367.             else {
  1368.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("La uri fornita '"+uriApiImplementata+"' non rispetta il formato atteso '"+pattern1+"|"+pattern2+"'");
  1369.             }
  1370.         }catch(RegExpNotFoundException e) {
  1371.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("La uri fornita '"+uriApiImplementata+"' non rispetta il formato atteso '"+pattern1+"|"+pattern2+"': "+e.getMessage());
  1372.         }
  1373.         FiltroApiImplementata filtro = new FiltroApiImplementata();
  1374.         filtro.setNome(idAccordo.getNome());
  1375.         filtro.setReferente(idAccordo.getSoggettoReferente().getNome());
  1376.         filtro.setVersione(idAccordo.getVersione());
  1377.         return filtro;
  1378.     }
  1379.     
  1380.     public static final String toUriApiImplementata(FiltroApiImplementata filtroApiImplementata, MonitoraggioEnv env) throws Exception {
  1381.         //  tipoSoggettoReferente/nomeSoggettoReferente:nomeAccordo:versione
  1382.         String tipoSoggetto = env.tipoSoggetto;
  1383.         String nomeSoggetto = filtroApiImplementata.getReferente()!=null ? filtroApiImplementata.getReferente() : env.nomeSoggettoLocale;
  1384.         if(nomeSoggetto==null || "".equals(nomeSoggetto)) {
  1385.             if(!env.supportatoSoggettoReferenteAPI) {
  1386.                 // Recupero Soggetto Default per l'API
  1387.                 if(env.soggettoReferenteAPIDefault!=null) {
  1388.                     nomeSoggetto = env.soggettoReferenteAPIDefault.getNome();
  1389.                 }
  1390.                 
  1391.             }
  1392.         }
  1393.         return IDAccordoFactory.getInstance().getUriFromValues(filtroApiImplementata.getNome(), tipoSoggetto, nomeSoggetto, filtroApiImplementata.getVersione());
  1394.     }
  1395.     
  1396.     public static final FiltroApiSoggetti parseFiltroApiMap(FiltroRicercaRuoloTransazioneEnum tipo,
  1397.             String nomeServizio, String tipoServizio, Integer versioneServizio, String soggettoRemoto,
  1398.             String soggettoErogatore,
  1399.             MonitoraggioEnv env, String uriApiImplementata) throws Exception {
  1400.         
  1401.         // In caso di Fruizione, fin'ora si è sempre specificato l'erogatore per mezzo del parametro soggettoRemoto.
  1402.         // Per mantenere i controlli corretti sul filtroApi, nel caso FRUIZIONE se viene specificato il soggettoRemoto
  1403.         // allora si sta specificando un pezzo del filtroAPI, che va specificato per intero.
  1404.         if (tipo == FiltroRicercaRuoloTransazioneEnum.FRUIZIONE) {
  1405.             soggettoErogatore = soggettoRemoto;
  1406.         }

  1408.         if (tipo == FiltroRicercaRuoloTransazioneEnum.EROGAZIONE 
  1409.                 && (!StringUtils.isEmpty(soggettoRemoto) || !StringUtils.isEmpty(soggettoErogatore))) {
  1410.             
  1411.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Nel caso di ruolo <" + tipo
  1412.                     + ">, non bisogna specificare né soggetto_remoto né soggetto_erogatore");
  1413.         }

  1415.         if (tipo == FiltroRicercaRuoloTransazioneEnum.FRUIZIONE 
  1416.                 && !StringUtils.isEmpty(soggettoErogatore)
  1417.                 && !StringUtils.isEmpty(soggettoRemoto) 
  1418.                 && !StringUtils.equals(soggettoRemoto, soggettoErogatore)) {
  1419.             
  1420.             throw FaultCode.RICHIESTA_NON_VALIDA.toException("Ricerca ambigua. Nel caso di ruolo <"
  1421.                     + tipo
  1422.                     + ">, soggettoErogatore e soggettoRemoto specificano la stessa informazione."
  1423.                     + "Se specificati entrambi allora devono essere uguali");
  1424.         }   

  1426.         // Se specifico un pezzo del filtroAPI, allora devo avere un filtro completo.
  1427.         // (meno i defaults)
  1428.         if (nomeServizio != null || tipoServizio != null || soggettoErogatore != null
  1429.                 // || versioneServizio != null  default value is 1
  1430.                 ) {
  1431.         
  1432.             if (nomeServizio == null) {
  1433.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Specificare il nome_servizio");
  1434.             }

  1436.             if (tipo == FiltroRicercaRuoloTransazioneEnum.FRUIZIONE && (StringUtils.isEmpty(soggettoRemoto) || StringUtils.isEmpty(soggettoErogatore)) ) {
  1437.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Specificando un filtro API per il ruolo <" + tipo
  1438.                         + ">, è necessario specificare anche il soggetto_remoto (Erogatore in caso di Fruizioni)");
  1439.             }
  1440.             
  1441.             if (tipo == FiltroRicercaRuoloTransazioneEnum.QUALSIASI && StringUtils.isEmpty(soggettoErogatore)) {
  1442.                 throw FaultCode.RICHIESTA_NON_VALIDA.toException("Specificando un filtro API per il ruolo <" + tipo
  1443.                         + ">, è necessario specificare anche il soggetto_erogatore");
  1444.             }
  1445.             // TODO: Gli altri due hanno i defaults. (Che dovrei metttere ora?)
  1446.         }

  1448.         return ReportisticaHelper.buildFiltroApiMap(tipo, nomeServizio, tipoServizio, versioneServizio, soggettoRemoto, soggettoErogatore, 
  1449.                 env, uriApiImplementata);
  1450.     }
  1451.     
  1452.     public static final FiltroApiSoggetti parseFiltroApiMap(TransazioneRuoloEnum tipo, String nomeServizio,
  1453.             String tipoServizio, Integer versioneServizio, String soggettoRemoto,
  1454.             MonitoraggioEnv env, String uriApiImplementata) throws Exception {
  1455.         // In Questo caso non abbiamo il tipo QUALSIASI, quindi parsiamo il filtro senza il soggettoErogatore (ultimo parametro a null)
  1456.         FiltroRicercaRuoloTransazioneEnum newTipo = tipo == TransazioneRuoloEnum.EROGAZIONE ? FiltroRicercaRuoloTransazioneEnum.EROGAZIONE : FiltroRicercaRuoloTransazioneEnum.FRUIZIONE;
  1457.         return ReportisticaHelper.parseFiltroApiMap(newTipo, nomeServizio, tipoServizio, versioneServizio, soggettoRemoto,null, 
  1458.                 env, uriApiImplementata);
  1459.     }
  1460.     
  1461.     private static final FiltroApiSoggetti buildFiltroApiMap(FiltroRicercaRuoloTransazioneEnum tipo, String nomeServizio,
  1462.             String tipoServizio, Integer versioneServizio, String soggettoRemoto, String soggettoErogatore,
  1463.             MonitoraggioEnv env, String uriApiImplementata) throws Exception {

  1465.         FiltroApiImplementata apiImplementata = null;
  1466.         if(uriApiImplementata!=null && !"".equals(uriApiImplementata)) {
  1467.             apiImplementata = ReportisticaHelper.parseUriApiImplementata(uriApiImplementata, env);
  1468.         }
  1469.         
  1470.         // Se non ho specificato nessun pezzo del filtro api, allora per le versioni full è come aver passato un FiltroApi a null.
  1471.         if (StringUtils.isEmpty(nomeServizio) && StringUtils.isEmpty(tipoServizio) && StringUtils.isEmpty(soggettoRemoto) && StringUtils.isEmpty(soggettoErogatore) 
  1472.                 //&& versioneServizio == null default value is 1
  1473.                 ) {
  1474.             if(apiImplementata!=null) {
  1475.                 FiltroApiSoggetti filtroApiBase = new FiltroApiSoggetti();
  1476.                 filtroApiBase.setApiImplementata(apiImplementata);
  1477.                 return filtroApiBase;
  1478.             }
  1479.             return null;
  1480.         }
  1481.         
  1482.         FiltroApiSoggetti filtroApiBase = new FiltroApiSoggetti();
  1483.         
  1484.         filtroApiBase.setNome(nomeServizio);
  1485.         filtroApiBase.setTipo(tipoServizio);
  1486.         if(nomeServizio!=null || tipoServizio!=null) {
  1487.             filtroApiBase.setVersione(versioneServizio!=null ? versioneServizio : 1);
  1488.         }
  1489.         
  1490.         switch (tipo) {
  1491.         case EROGAZIONE:
  1492.             break;
  1493.         case FRUIZIONE:
  1494.             if (!StringUtils.isEmpty(soggettoErogatore)) {
  1495.                 soggettoRemoto = soggettoErogatore;
  1496.             }
  1497.             filtroApiBase.setErogatore(soggettoRemoto);
  1498.             break;
  1499.         case QUALSIASI:
  1500.             filtroApiBase.setErogatore(soggettoErogatore);
  1501.             filtroApiBase.setSoggettoRemoto(soggettoRemoto);
  1502.             break;
  1503.         }
  1504.         
  1505.         filtroApiBase.setApiImplementata(apiImplementata);
  1506.         
  1507.         return filtroApiBase;
  1508.     }
  1509.     
  1510. }
Created with JaCoCo 0.8.8.202204050719