MonitoraggioApiServiceImpl.java

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

  22. import java.sql.Connection;
  23. import java.util.List;
  24. import java.util.UUID;

  26. import org.apache.commons.lang3.BooleanUtils;
  27. import org.joda.time.DateTime;
  28. import org.openspcoop2.core.monitor.rs.server.api.MonitoraggioApi;
  29. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.Converter;
  30. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.Enums;
  31. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.MonitoraggioEnv;
  32. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.ReportisticaHelper;
  33. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.SearchFormUtilities;
  34. import org.openspcoop2.core.monitor.rs.server.api.impl.utils.TransazioniHelper;
  35. import org.openspcoop2.core.monitor.rs.server.config.DBManager;
  36. import org.openspcoop2.core.monitor.rs.server.config.LoggerProperties;
  37. import org.openspcoop2.core.monitor.rs.server.config.ServerProperties;
  38. import org.openspcoop2.core.monitor.rs.server.model.DetailTransazione;
  39. import org.openspcoop2.core.monitor.rs.server.model.EsitoTransazioneFullSearchEnum;
  40. import org.openspcoop2.core.monitor.rs.server.model.EsitoTransazioneSimpleSearchEnum;
  41. import org.openspcoop2.core.monitor.rs.server.model.Evento;
  42. import org.openspcoop2.core.monitor.rs.server.model.FiltroEsito;
  43. import org.openspcoop2.core.monitor.rs.server.model.FiltroRicercaRuoloTransazioneEnum;
  44. import org.openspcoop2.core.monitor.rs.server.model.FiltroTemporale;
  45. import org.openspcoop2.core.monitor.rs.server.model.ListaEventi;
  46. import org.openspcoop2.core.monitor.rs.server.model.ListaTransazioni;
  47. import org.openspcoop2.core.monitor.rs.server.model.RicercaIdApplicativo;
  48. import org.openspcoop2.core.monitor.rs.server.model.RicercaIntervalloTemporale;
  49. import org.openspcoop2.core.monitor.rs.server.model.TipoIdApplicativoEnum;
  50. import org.openspcoop2.core.monitor.rs.server.model.TipoMessaggioEnum;
  51. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  52. import org.openspcoop2.utils.service.BaseImpl;
  53. import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
  54. import org.openspcoop2.utils.service.authorization.AuthorizationManager;
  55. import org.openspcoop2.utils.service.beans.DiagnosticoSeveritaEnum;
  56. import org.openspcoop2.utils.service.beans.FiltroRicercaId;
  57. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  58. import org.openspcoop2.utils.service.beans.utils.BaseHelper;
  59. import org.openspcoop2.utils.service.beans.utils.ListaUtils;
  60. import org.openspcoop2.utils.service.context.IContext;
  61. import org.openspcoop2.utils.service.fault.jaxrs.FaultCode;
  62. import org.openspcoop2.web.monitor.core.constants.CaseSensitiveMatch;
  63. import org.openspcoop2.web.monitor.core.constants.TipoMatch;
  64. import org.openspcoop2.web.monitor.eventi.bean.EventiSearchForm;
  65. import org.openspcoop2.web.monitor.eventi.bean.EventoBean;
  66. import org.openspcoop2.web.monitor.eventi.dao.EventiService;
  67. import org.openspcoop2.web.monitor.transazioni.bean.TransazioneBean;
  68. import org.openspcoop2.web.monitor.transazioni.bean.TransazioniSearchForm;
  69. import org.openspcoop2.web.monitor.transazioni.dao.TransazioniService;

  71. /**
  72.  * MonitoraggioApiServiceImpl
  73.  *
  74.  * @author $Author$
  75.  * @version $Rev$, $Date$
  76.  */
  77. public class MonitoraggioApiServiceImpl extends BaseImpl implements MonitoraggioApi {

  79.     public MonitoraggioApiServiceImpl(){
  80.         super(org.slf4j.LoggerFactory.getLogger(MonitoraggioApiServiceImpl.class));
  81.     }

  83.     private AuthorizationConfig getAuthorizationConfig() throws Exception{
  84.         return new AuthorizationConfig(ServerProperties.getInstance().getProperties());
  85.     }

  87.     /**
  88.      * Ricerca di Eventi
  89.      *
  90.      * Questa operazione consente di effettuare una ricerca nell&#x27;archivio degli eventi specificando i criteri di filtraggio
  91.      *
  92.      */
  93.     @Override
  94.     public ListaEventi findAllEventi(DateTime dataInizio, DateTime dataFine, Integer offset, Integer limit, DiagnosticoSeveritaEnum severita, String tipo, String codice, String origine, Boolean ricercaEsatta, Boolean caseSensitive) {
  95.         IContext context = this.getContext();
  96.         try {
  97.             context.getLogger().info("Invocazione in corso ...");     

  99.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  100.             context.getLogger().debug("Autorizzazione completata con successo");     
  101.                         
  102.             DBManager dbManager = DBManager.getInstance();
  103.             Connection connection = null;
  104.             try {
  105.                 connection = dbManager.getConnectionTracce();
  106.                 ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
  107.                 EventiService eventiService = new EventiService(connection, true, smp, LoggerProperties.getLoggerDAO());
  108.                 
  109.                 ServerProperties serverProperties = ServerProperties.getInstance();
  110.                 SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  111.                 
  112.                 EventiSearchForm search = searchFormUtilities.getEventiSearchForm(context, dataInizio, dataFine);
  113.                 search.setCodice(codice);
  114.                 search.setTipo(tipo);
  115.                 search.setSeverita(BaseHelper.evalnull( () -> Enums.toTipoSeverita.get(severita).toString()));
  116.                 search.setCaseSensitiveType( (BooleanUtils.isTrue(caseSensitive) ? CaseSensitiveMatch.SENSITIVE : CaseSensitiveMatch.INSENSITIVE).toString() );
  117.                 search.setMatchingType( (BooleanUtils.isTrue(ricercaEsatta) ? TipoMatch.EQUALS : TipoMatch.LIKE ).toString());
  118.                 search.setIdConfigurazione(origine);
  119.             
  120.                 eventiService.setSearch(search);    
  121.                 List<EventoBean> listEventiDB = eventiService.findAll(Converter.toOffset(offset), Converter.toLimit(limit));
  122.                 ListaEventi ret = ListaUtils.costruisciLista(
  123.                         context.getUriInfo(),
  124.                         Converter.toOffset(offset), Converter.toLimit(limit), 
  125.                         listEventiDB!=null ? listEventiDB.size() : 0, 
  126.                                 ListaEventi.class
  127.                     ); 
  128.                 
  129.                 if ( serverProperties.isFindall404() && (listEventiDB==null || listEventiDB.isEmpty()) )
  130.                     throw FaultCode.NOT_FOUND.toException("Nessun evento trovato corrispondente ai criteri di ricerca");
  131.                 
  132.                 if(listEventiDB!=null && !listEventiDB.isEmpty()) {
  133.                     listEventiDB.forEach( eventoDB -> 
  134.                         {
  135.                             try {
  136.                                 ret.addItemsItem( Converter.toEvento(eventoDB, this.log) );
  137.                             } catch (Exception e) {
  138.                                 throw new RuntimeException(e.getMessage(),e);
  139.                             }
  140.                         }
  141.                         );
  142.                 }
  143.         
  144.                 context.getLogger().info("Invocazione completata con successo");
  145.                 return ret;
  146.             }
  147.             finally {
  148.                 dbManager.releaseConnectionTracce(connection);
  149.             }
  150.      
  151.         }
  152.         catch(javax.ws.rs.WebApplicationException e) {
  153.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  154.             throw e;
  155.         }
  156.         catch(Throwable e) {
  157.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  158.             throw FaultCode.ERRORE_INTERNO.toException(e);
  159.         }
  160.     }
  161.     
  162.     /**
  163.      * Ricerca delle transazioni in base all&#x27;identificativo dell&#x27;applicativo
  164.      *
  165.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all&#x27;identificativo dell&#x27;applicativo
  166.      *
  167.      */
  168.     @Override
  169.     public ListaTransazioni findAllTransazioniByIdApplicativo(TipoIdApplicativoEnum tipoIdentificativo, String id, ProfiloEnum profilo, String soggetto, Integer offset, Integer limit, String sort) {
  170.         IContext context = this.getContext();
  171.         try {
  172.             context.getLogger().info("Invocazione in corso ...");     

  174.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  175.             context.getLogger().debug("Autorizzazione completata con successo");     
  176.                         
  177.             SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  178.             TransazioniSearchForm search = searchFormUtilities.getIdApplicativoBaseSearchForm(context, profilo, soggetto);
  179.             
  180.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
  181.             search.setIdCorrelazioneApplicativa(id);
  182.             switch (tipoIdentificativo) {
  183.             case RICHIESTA:
  184.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Richiesta.name());
  185.                 break;
  186.             case RISPOSTA:
  187.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Risposta.name());
  188.                 break;
  189.             }

  191.             ListaTransazioni ret = TransazioniHelper.searchTransazioni(search, offset, limit, sort, env);        
  192.             context.getLogger().info("Invocazione completata con successo");
  193.             return ret;
  194.      
  195.         }
  196.         catch(javax.ws.rs.WebApplicationException e) {
  197.             context.getLogger().error("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  198.             throw e;
  199.         }
  200.         catch(Throwable e) {
  201.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  202.             throw FaultCode.ERRORE_INTERNO.toException(e);
  203.         }
  204.     }

  206.     /**
  207.      * Ricerca completa delle transazioni per intervallo temporale
  208.      *
  209.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay, limitando i risultati di ricerca ad un intervallo di date
  210.      *
  211.      */
  212.     @Override
  213.     public ListaTransazioni findAllTransazioniByFullSearch(RicercaIntervalloTemporale body, ProfiloEnum profilo, String soggetto) {
  214.         IContext context = this.getContext();
  215.         
  216.         try {
  217.             context.getLogger().info("Invocazione in corso ...");     
  218.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  219.             context.getLogger().debug("Autorizzazione completata con successo");     

  221.             BaseHelper.throwIfNull(body);
  222.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
  223.             
  224.             ListaTransazioni ret = TransazioniHelper.findAllTransazioni(body, env);
  225.             context.getLogger().info("Invocazione completata con successo");
  226.             return ret;
  227.         }
  228.         catch(javax.ws.rs.WebApplicationException e) {
  229.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  230.             throw e;
  231.         }
  232.         catch(Throwable e) {
  233.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  234.             throw FaultCode.ERRORE_INTERNO.toException(e);
  235.         }
  236.     }
  237.     
  238.     /**
  239.      * Ricerca completa delle transazioni in base all&#x27;identificativo applicativo
  240.      *
  241.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all&#x27;identificativo applicativo e i parametri di filtro completi
  242.      *
  243.      */
  244.     @Override
  245.     public ListaTransazioni findAllTransazioniByIdApplicativoFullSearch(RicercaIdApplicativo body, ProfiloEnum profilo, String soggetto) {
  246.         IContext context = this.getContext();
  247.         try {
  248.             context.getLogger().info("Invocazione in corso ...");     
  249.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  250.             context.getLogger().debug("Autorizzazione completata con successo");                             
  251.             
  252.             BaseHelper.throwIfNull(body);
  253.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);            
  254.             ListaTransazioni ret = TransazioniHelper.findAllTransazioniByIdApplicativo(body, env);
  255.             context.getLogger().info("Invocazione completata con successo");
  256.             return ret;
  257.         }
  258.         catch(javax.ws.rs.WebApplicationException e) {
  259.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  260.             throw e;
  261.         }
  262.         catch(Throwable e) {
  263.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  264.             throw FaultCode.ERRORE_INTERNO.toException(e);
  265.         }
  266.     }
  267.     
  268.     /**
  269.      * Ricerca semplificata delle transazioni in base all&#x27;identificativo applicativo
  270.      *
  271.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay, ricercandole in base all&#x27;identificativo applicativo e i parametri di filtro di uso più comune
  272.      *
  273.      */
  274.     @Override
  275.     public ListaTransazioni findAllTransazioniByIdApplicativoSimpleSearch(DateTime dataInizio, DateTime dataFine,
  276.             FiltroRicercaRuoloTransazioneEnum tipo, String idApplicativo, ProfiloEnum profilo, String soggetto,
  277.             Integer offset, Integer limit, String sort, String idCluster, String soggettoRemoto,
  278.             String soggettoErogatore, String tag, String uriApiImplementata, 
  279.             String nomeServizio, String tipoServizio, Integer versioneServizio,
  280.             String azione, EsitoTransazioneSimpleSearchEnum esito, Boolean escludiScartate, 
  281.             Boolean ricercaEsatta, Boolean caseSensitive) {
  282.         IContext context = this.getContext();
  283.         try {
  284.             context.getLogger().info("Invocazione in corso ...");     
  285.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  286.             context.getLogger().debug("Autorizzazione completata con successo");     
  287.                        
  288.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
  289.             
  290.             RicercaIdApplicativo bodyRicerca = new RicercaIdApplicativo();
  291.             bodyRicerca.setTipo(tipo);
  292.             bodyRicerca.setApi(ReportisticaHelper.parseFiltroApiMap(tipo, nomeServizio, tipoServizio, versioneServizio, soggettoRemoto, soggettoErogatore,
  293.                     env, uriApiImplementata));          
  294.             FiltroTemporale iTemporale = new FiltroTemporale();
  295.             iTemporale.setDataInizio(dataInizio);
  296.             iTemporale.setDataFine(dataFine);
  297.             bodyRicerca.setIntervalloTemporale(iTemporale);
  298.             FiltroRicercaId filtroId = new FiltroRicercaId();
  299.             filtroId.setId(idApplicativo);
  300.             filtroId.setCaseSensitive(caseSensitive);
  301.             filtroId.setRicercaEsatta(ricercaEsatta);
  302.             bodyRicerca.setIdApplicativo(filtroId);
  303.             bodyRicerca.setIdCluster(idCluster);
  304.             bodyRicerca.setTag(tag);
  305.             bodyRicerca.setAzione(azione);
  306.             
  307.             bodyRicerca.setLimit(limit);
  308.             bodyRicerca.setOffset(offset);
  309.             bodyRicerca.setSort(sort);
  310.             if (esito != null || escludiScartate!=null) {
  311.                 FiltroEsito filtroEsito = new FiltroEsito();
  312.                 if(esito!=null) {
  313.                     filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.valueOf(esito.name()));
  314.                 }
  315.                 else {
  316.                     filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.QUALSIASI);
  317.                 }
  318.                 if(escludiScartate!=null) {
  319.                     filtroEsito.setEscludiScartate(escludiScartate);
  320.                 }
  321.                 bodyRicerca.setEsito(filtroEsito);
  322.             }
  323.             
  324.             ListaTransazioni ret = TransazioniHelper.findAllTransazioniByIdApplicativo(bodyRicerca, env);
  325.             context.getLogger().info("Invocazione completata con successo");
  326.             return ret;
  327.         }
  328.         catch(javax.ws.rs.WebApplicationException e) {
  329.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  330.             throw e;
  331.         }
  332.         catch(Throwable e) {
  333.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  334.             throw FaultCode.ERRORE_INTERNO.toException(e);
  335.         }
  336.     }
  337.     
  338.     /**
  339.      * Ricerca semplificata delle transazioni in base all&#x27;identificativo
  340.      * messaggio
  341.      *
  342.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay,
  343.      * ricercandole in base all&#x27;identificativo messaggio
  344.      *
  345.      */
  346.     @Override
  347.     public ListaTransazioni findAllTransazioniByIdMessaggio(TipoMessaggioEnum tipoMessaggio, String id,
  348.             ProfiloEnum profilo, String soggetto, Integer offset, Integer limit, String sort) {
  349.         IContext context = this.getContext();
  350.         try {
  351.             context.getLogger().info("Invocazione in corso ...");

  353.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  354.             context.getLogger().debug("Autorizzazione completata con successo");

  356.             SearchFormUtilities searchFormUtilities = new SearchFormUtilities();
  357.             TransazioniSearchForm search = searchFormUtilities.getIdMessaggioSearchForm(context, profilo, soggetto);
  358.             
  359.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);
  360.             search.setIdEgov(id);
  361.             switch (tipoMessaggio) {
  362.             case RICHIESTA:
  363.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Richiesta.name());
  364.                 break;
  365.             case RISPOSTA:
  366.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Risposta.name());
  367.                 break;
  368.             case CONVERSAZIONE:
  369.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.Collaborazione.name());
  370.                 break;
  371.             case RIFERIMENTO_RICHIESTA:
  372.                 search.setTipoIdMessaggio(org.openspcoop2.web.monitor.core.constants.TipoMessaggio.RiferimentoRichiesta.name());
  373.                 break;
  374.             }

  376.             ListaTransazioni ret = TransazioniHelper.searchTransazioni(search, offset, limit, sort, env);
  377.             context.getLogger().info("Invocazione completata con successo");
  378.             return ret;
  379.         } catch (javax.ws.rs.WebApplicationException e) {
  380.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s", e, e.getMessage());
  381.             throw e;
  382.         } catch (Throwable e) {
  383.             context.getLogger().error("Invocazione terminata con errore: %s", e, e.getMessage());
  384.             throw FaultCode.ERRORE_INTERNO.toException(e);
  385.         }
  386.     }
  387.     
  388.     /**
  389.      * Ricerca semplificata delle transazioni in base ai parametri di uso più comune
  390.      *
  391.      * Permette di recuperare i dettagli delle transazioni, gestite su GovWay,
  392.      * ricercandole in base a parametri di filtro di uso più comune
  393.      *
  394.      */
  395.     @Override
  396.     public ListaTransazioni findAllTransazioniBySimpleSearch(DateTime dataInizio, DateTime dataFine,
  397.             FiltroRicercaRuoloTransazioneEnum tipo, ProfiloEnum profilo, String soggetto, Integer offset, Integer limit,
  398.             String sort, String idCluster, String soggettoRemoto, String soggettoErogatore, String tag, String uriApiImplementata,
  399.             String nomeServizio, String tipoServizio, Integer versioneServizio, String azione,
  400.             EsitoTransazioneSimpleSearchEnum esito,Boolean escludiScartate) {
  401.         IContext context = this.getContext();
  402.         try {
  403.             context.getLogger().info("Invocazione in corso ...");

  405.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  406.             context.getLogger().debug("Autorizzazione completata con successo");

  408.             MonitoraggioEnv env = new MonitoraggioEnv(context, profilo, soggetto, this.log);

  410.             RicercaIntervalloTemporale bodyRicerca = new RicercaIntervalloTemporale();
  411.             FiltroTemporale intervalloTemporale = new FiltroTemporale();
  412.             intervalloTemporale.setDataFine(dataFine);
  413.             intervalloTemporale.setDataInizio(dataInizio);
  414.             bodyRicerca.setIntervalloTemporale(intervalloTemporale);
  415.             bodyRicerca.setTipo(tipo);
  416.             bodyRicerca.setIdCluster(idCluster);
  417.             bodyRicerca.setTag(tag);
  418.             bodyRicerca.setAzione(azione);

  420.             bodyRicerca.setSort(sort);
  421.             bodyRicerca.setLimit(limit);
  422.             bodyRicerca.setOffset(offset);

  424.             if (esito != null || escludiScartate!=null) {
  425.                 FiltroEsito filtroEsito = new FiltroEsito();
  426.                 if(esito!=null) {
  427.                     filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.valueOf(esito.name()));
  428.                 }
  429.                 else {
  430.                     filtroEsito.setTipo(EsitoTransazioneFullSearchEnum.QUALSIASI);
  431.                 }
  432.                 if(escludiScartate!=null) {
  433.                     filtroEsito.setEscludiScartate(escludiScartate);
  434.                 }
  435.                 bodyRicerca.setEsito(filtroEsito);
  436.             }
  437.             
  438.             bodyRicerca.setApi(ReportisticaHelper.parseFiltroApiMap(tipo, nomeServizio, tipoServizio, versioneServizio,
  439.                     soggettoRemoto,soggettoErogatore,
  440.                     env, uriApiImplementata));

  442.             ListaTransazioni ret = TransazioniHelper.findAllTransazioni(bodyRicerca, env);
  443.             context.getLogger().info("Invocazione completata con successo");
  444.             return ret;
  445.         } catch (javax.ws.rs.WebApplicationException e) {
  446.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s", e, e.getMessage());
  447.             throw e;
  448.         } catch (Throwable e) {
  449.             context.getLogger().error("Invocazione terminata con errore: %s", e, e.getMessage());
  450.             throw FaultCode.ERRORE_INTERNO.toException(e);
  451.         }
  452.     }
  453.     
  454.     /**
  455.      * Dettaglio di un evento
  456.      *
  457.      * Permette di recuperare il dettaglio di un evento in base al suo identificativo
  458.      *
  459.      */
  460.     @Override
  461.     public Evento getEvento(Long id) {
  462.         IContext context = this.getContext();
  463.         try {
  464.             context.getLogger().info("Invocazione in corso ...");     

  466.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  467.             context.getLogger().debug("Autorizzazione completata con successo");     
  468.                
  469.             if(id==null) {
  470.                 FaultCode.RICHIESTA_NON_VALIDA.throwException("Id undefined");
  471.             }
  472.             
  473.             DBManager dbManager = DBManager.getInstance();
  474.             Connection connection = null;
  475.             try {
  476.                 connection = dbManager.getConnectionTracce();
  477.                 ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
  478.                 EventiService eventiService = new EventiService(connection, true, smp, LoggerProperties.getLoggerDAO());
  479.                 
  480.                 EventoBean eventoDB = eventiService.findById(id);
  481.                 if(eventoDB==null) {
  482.                     FaultCode.NOT_FOUND.throwException("Evento con id '"+id+"' non esistente");
  483.                 }
  484.                 Evento evento = Converter.toEvento(eventoDB, this.log);     
  485.                 context.getLogger().info("Invocazione completata con successo");
  486.                 return evento;
  487.             }
  488.             finally {
  489.                 dbManager.releaseConnectionTracce(connection);
  490.             }
  491.      
  492.         }
  493.         catch(javax.ws.rs.WebApplicationException e) {
  494.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  495.             throw e;
  496.         }
  497.         catch(Throwable e) {
  498.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  499.             throw FaultCode.ERRORE_INTERNO.toException(e);
  500.         }
  501.     }
  502.     
  503.     /**
  504.      * Dettaglio della transazione
  505.      *
  506.      * Questa operazione consente di ottenere il dettaglio di una transazione
  507.      *
  508.      */
  509.     @Override
  510.     public DetailTransazione getTransazione(UUID id) {
  511.         IContext context = this.getContext();
  512.         try {
  513.             context.getLogger().info("Invocazione in corso ...");     

  515.             AuthorizationManager.authorize(context, getAuthorizationConfig());
  516.             context.getLogger().debug("Autorizzazione completata con successo");     
  517.             
  518.             String idSearch = null;
  519.             if(id==null) {
  520.                 FaultCode.RICHIESTA_NON_VALIDA.throwException("Id undefined");
  521.             }
  522.             else {
  523.                 idSearch = id.toString();
  524.             }
  525.             
  526.             DBManager dbManager = DBManager.getInstance();
  527.             Connection connection = null;
  528.             try {
  529.                 connection = dbManager.getConnectionTracce();
  530.                 ServiceManagerProperties smp = dbManager.getServiceManagerPropertiesTracce();
  531.                 TransazioniService transazioniService = new TransazioniService(connection, true, smp, LoggerProperties.getLoggerDAO());
  532.                 TransazioneBean transazioneDB = transazioniService.findByIdTransazione(idSearch);
  533.                 if(transazioneDB==null) {
  534.                     FaultCode.NOT_FOUND.throwException("Traccia con id '"+id+"' non esistente");
  535.                 }
  536.                 DetailTransazione transazione = org.openspcoop2.core.monitor.rs.server.api.impl.utils.Converter.toTransazioneExt(transazioneDB, transazioniService, 
  537.                         connection, smp,
  538.                         this.log);
  539.                 context.getLogger().info("Invocazione completata con successo");
  540.                 return transazione;
  541.             }
  542.             finally {
  543.                 dbManager.releaseConnectionTracce(connection);
  544.             }
  545.         }
  546.         catch(javax.ws.rs.WebApplicationException e) {
  547.             context.getLogger().error_except404("Invocazione terminata con errore '4xx': %s",e, e.getMessage());
  548.             throw e;
  549.         }
  550.         catch(Throwable e) {
  551.             context.getLogger().error("Invocazione terminata con errore: %s",e, e.getMessage());
  552.             throw FaultCode.ERRORE_INTERNO.toException(e);
  553.         }
  554.     }
  555.     
  556. }
Created with JaCoCo 0.8.8.202204050719