MonitorUtilities.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.web.ctrlstat.servlet.monitor;

  23. import java.math.BigInteger;
  24. import java.util.List;

  26. import javax.xml.ws.BindingProvider;

  28. import org.openspcoop2.pdd.monitor.Messaggio;
  29. import org.openspcoop2.pdd.monitor.StatoPdd;
  30. import org.openspcoop2.pdd.monitor.driver.FilterSearch;
  31. import org.openspcoop2.pdd.monitor.driver.FiltroStatoConsegnaAsincrona;
  32. import org.openspcoop2.pdd.monitor.driver.StatoConsegneAsincrone;
  33. import org.openspcoop2.web.ctrlstat.core.ControlStationLogger;
  34. import org.openspcoop2.web.ctrlstat.dao.PdDControlStation;

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

  47.     public static long countListaRichiestePendenti(FilterSearch filter,String pddName, String sorgenteDati) throws Exception{
  48.         if(Monitor.singlePdD){
  49.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).countListaRichiestePendenti(filter);
  50.         }
  51.         else{
  52.             return getMessaggioWS(pddName).count(convertToSearchFilterMessaggio(filter));
  53.         }
  54.     }
  55.     
  56.     public static List<Messaggio> getListaRichiestePendenti(FilterSearch filter,String pddName, String sorgenteDati) throws Exception{
  57.         if(Monitor.singlePdD){
  58.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).getListaRichiestePendenti(filter);
  59.         }
  60.         else{
  61.             return getMessaggioWS(pddName).findAll(convertToSearchFilterMessaggio(filter));
  62.         }
  63.     }
  64.     
  65.     public static long deleteRichiestePendenti(FilterSearch filter,String pddName, String sorgenteDati) throws Exception{
  66.         if(Monitor.singlePdD){
  67.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).deleteRichiestePendenti(filter);
  68.         }
  69.         else{
  70.             return getMessaggioWS(pddName).deleteAllByFilter(convertToSearchFilterMessaggio(filter));
  71.         }
  72.     }
  73.     
  74.     public static long aggiornaDataRispedizioneRichiestePendenti(FilterSearch filter,String pddName, String sorgenteDati) throws Exception{
  75.         if(Monitor.singlePdD){
  76.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).aggiornaDataRispedizioneRichiestePendenti(filter);
  77.         }
  78.         else{
  79.             throw new Exception("Not Implemented");
  80.         }
  81.     }
  82.     
  83.     public static StatoPdd getStatoRichiestePendenti(FilterSearch filter,String pddName, String sorgenteDati) throws Exception{
  84.         if(Monitor.singlePdD){
  85.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).getStatoRichiestePendenti(filter);
  86.         }
  87.         else{
  88.             return getStatoPddWS(pddName).find(convertToSearchFilterStatoPdd(filter));
  89.         }
  90.     }
  91.     
  92.     public static StatoConsegneAsincrone getStatoConsegneAsincrone(FiltroStatoConsegnaAsincrona filtro, String sorgenteDati) throws Exception{
  93.         if(Monitor.singlePdD){
  94.             return Monitor.driverMonitoraggioLocale.get(sorgenteDati).getStatoConsegneAsincrone(filtro);
  95.         }
  96.         else{
  97.             throw new Exception("Non supportato");
  98.         }
  99.     }
  100.     
  101.     private static String getWSUrl(String pddName, boolean statoPdD) throws Exception{
  102.         String ipPdd = null;
  103.         String protocollo = null;
  104.         int porta = 80;
  105.         try {
  106.             // ipPdd = backEndConnector.getIPPdd(queueName);
  107.             PdDControlStation pdd = Monitor.pddCore.getPdDControlStation(pddName);
  108.             ipPdd = pdd.getIpGestione();
  109.             protocollo = pdd.getProtocolloGestione();
  110.             porta = pdd.getPortaGestione();

  112.             if (ipPdd == null || protocollo == null || porta <= 0)
  113.                 throw new Exception("Parametri Porta di Dominio non validi.");

  115.         } catch (Exception e) {
  116.             ControlStationLogger.getPddConsoleCoreLogger().error("Riscontrato errore durante la get dell'ip del pdd(" + pddName + "): " + e.toString(), e);
  117.             throw new Exception("Riscontrato errore durante la get dell'ip del pdd(" + pddName + "): " + e.toString(), e);
  118.         }
  119.         String prefixUrl = protocollo + "://" + ipPdd + ":" + porta + "/";
  120.         if(statoPdD){
  121.             return prefixUrl + Monitor.consoleProperties.getGestioneCentralizzataWSMonitorEndpointSuffixStatoPdd();
  122.         }
  123.         else{
  124.             return prefixUrl + Monitor.consoleProperties.getGestioneCentralizzataWSMonitorEndpointSuffixMessaggio();
  125.         }
  126.     }
  127.     
  128.     private static org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Messaggio getMessaggioWS(String pddName) throws Exception{
  129.         org.openspcoop2.pdd.monitor.ws.client.messaggio.all.MessaggioSoap11Service messaggioService = 
  130.                 new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.MessaggioSoap11Service();
  131.         org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Messaggio messaggioPort = messaggioService.getMessaggioPortSoap11();
  132.         ((BindingProvider)messaggioPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  133.                 getWSUrl(pddName, false));
  134.         ((BindingProvider)messaggioPort).getRequestContext().put("schema-validation-enabled", true);
  135.         String username = Monitor.consoleProperties.getGestioneCentralizzataWSMonitorCredenzialiBasicUsername();
  136.         String password = Monitor.consoleProperties.getGestioneCentralizzataWSMonitorCredenzialiBasicPassword();
  137.         if(username !=null && password!=null){
  138.             // to use Basic HTTP Authentication: 
  139.             ((BindingProvider)messaggioPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  140.             ((BindingProvider)messaggioPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  141.         }
  142.         return messaggioPort;
  143.     }
  144.     
  145.     private static org.openspcoop2.pdd.monitor.ws.client.statopdd.all.StatoPdd getStatoPddWS(String pddName) throws Exception{
  146.         org.openspcoop2.pdd.monitor.ws.client.statopdd.all.StatoPddSoap11Service statoPddService = 
  147.                 new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.StatoPddSoap11Service();
  148.         org.openspcoop2.pdd.monitor.ws.client.statopdd.all.StatoPdd statoPddPort = statoPddService.getStatoPddPortSoap11();
  149.         ((BindingProvider)statoPddPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  150.                 getWSUrl(pddName, true));
  151.         ((BindingProvider)statoPddPort).getRequestContext().put("schema-validation-enabled", true);
  152.         String username = Monitor.consoleProperties.getGestioneCentralizzataWSMonitorCredenzialiBasicUsername();
  153.         String password = Monitor.consoleProperties.getGestioneCentralizzataWSMonitorCredenzialiBasicPassword();
  154.         if(username !=null && password!=null){
  155.             // to use Basic HTTP Authentication: 
  156.             ((BindingProvider)statoPddPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  157.             ((BindingProvider)statoPddPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  158.         }
  159.         return statoPddPort;
  160.     }
  161.     
  162.     private static org.openspcoop2.pdd.monitor.ws.client.messaggio.all.SearchFilterMessaggio convertToSearchFilterMessaggio(FilterSearch filter){
  163.         org.openspcoop2.pdd.monitor.ws.client.messaggio.all.SearchFilterMessaggio filterWS = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.SearchFilterMessaggio();
  164.         
  165.         if(filter.getLimit()>0){
  166.             filterWS.setLimit(new BigInteger(filter.getLimit()+""));
  167.         }
  168.         if(filter.getOffset()>=0){
  169.             filterWS.setOffset(new BigInteger(filter.getOffset()+""));
  170.         }
  171.         
  172.         org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Filtro filtroInternoWS = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Filtro();
  173.         filtroInternoWS.setTipo(filter.getTipo());
  174.         filtroInternoWS.setStato(filter.getStato());
  175.         if(filter.getSoglia()>0)
  176.             filtroInternoWS.setSoglia(filter.getSoglia());
  177.         filtroInternoWS.setMessagePattern(filter.getMessagePattern());
  178.         filtroInternoWS.setIdMessaggio(filter.getIdMessaggio());
  179.         filtroInternoWS.setCorrelazioneApplicativa(filter.getCorrelazioneApplicativa());
  180.         org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Busta busta = null;
  181.         if(filter.getBusta()!=null){
  182.             busta = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.Busta();
  183.             
  184.             busta.setAttesaRiscontro(filter.getBusta().getAttesaRiscontro());
  185.             busta.setAzione(filter.getBusta().getAzione());
  186.             busta.setCollaborazione(filter.getBusta().getCollaborazione());
  187.             
  188.             org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaSoggetto bustaDestinatario = null;
  189.             if(filter.getBusta().getDestinatario()!=null){
  190.                 bustaDestinatario = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaSoggetto();
  191.                 bustaDestinatario.setNome(filter.getBusta().getDestinatario().getNome());
  192.                 bustaDestinatario.setTipo(filter.getBusta().getDestinatario().getTipo());
  193.             }
  194.             busta.setDestinatario(bustaDestinatario);
  195.             
  196.             org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaSoggetto bustaMittente = null;
  197.             if(filter.getBusta().getMittente()!=null){
  198.                 bustaMittente = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaSoggetto();
  199.                 bustaMittente.setNome(filter.getBusta().getMittente().getNome());
  200.                 bustaMittente.setTipo(filter.getBusta().getMittente().getTipo());
  201.             }
  202.             busta.setMittente(bustaMittente);
  203.             
  204.             org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaServizio bustaServizio = null;
  205.             if(filter.getBusta().getServizio()!=null){
  206.                 bustaServizio = new org.openspcoop2.pdd.monitor.ws.client.messaggio.all.BustaServizio();
  207.                 bustaServizio.setNome(filter.getBusta().getServizio().getNome());
  208.                 bustaServizio.setTipo(filter.getBusta().getServizio().getTipo());
  209.                 //bustaServizio.setVersione(filter.getBusta().getServizio().getVersione());
  210.             }
  211.             busta.setServizio(bustaServizio);
  212.             
  213.             busta.setProfiloCollaborazione(filter.getBusta().getProfiloCollaborazione());
  214.             busta.setRiferimentoMessaggio(filter.getBusta().getRiferimentoMessaggio());
  215.         }
  216.         filtroInternoWS.setBusta(busta);
  217.         filterWS.setFiltro(filtroInternoWS);
  218.         
  219.         return filterWS;
  220.     }
  221.     
  222.     private static org.openspcoop2.pdd.monitor.ws.client.statopdd.all.SearchFilterStatoPdd convertToSearchFilterStatoPdd(FilterSearch filter){
  223.         org.openspcoop2.pdd.monitor.ws.client.statopdd.all.SearchFilterStatoPdd filterWS = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.SearchFilterStatoPdd();
  224.         
  225.         if(filter.getLimit()>0){
  226.             filterWS.setLimit(new BigInteger(filter.getLimit()+""));
  227.         }
  228.         if(filter.getOffset()>=0){
  229.             filterWS.setOffset(new BigInteger(filter.getOffset()+""));
  230.         }
  231.         
  232.         org.openspcoop2.pdd.monitor.ws.client.statopdd.all.Filtro filtroInternoWS = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.Filtro();
  233.         filtroInternoWS.setTipo(filter.getTipo());
  234.         filtroInternoWS.setStato(filter.getStato());
  235.         if(filter.getSoglia()>0)
  236.             filtroInternoWS.setSoglia(filter.getSoglia());
  237.         filtroInternoWS.setMessagePattern(filter.getMessagePattern());
  238.         filtroInternoWS.setIdMessaggio(filter.getIdMessaggio());
  239.         filtroInternoWS.setCorrelazioneApplicativa(filter.getCorrelazioneApplicativa());
  240.         org.openspcoop2.pdd.monitor.ws.client.statopdd.all.Busta busta = null;
  241.         if(filter.getBusta()!=null){
  242.             busta = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.Busta();
  243.             
  244.             busta.setAttesaRiscontro(filter.getBusta().getAttesaRiscontro());
  245.             busta.setAzione(filter.getBusta().getAzione());
  246.             busta.setCollaborazione(filter.getBusta().getCollaborazione());
  247.             
  248.             org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaSoggetto bustaDestinatario = null;
  249.             if(filter.getBusta().getDestinatario()!=null){
  250.                 bustaDestinatario = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaSoggetto();
  251.                 bustaDestinatario.setNome(filter.getBusta().getDestinatario().getNome());
  252.                 bustaDestinatario.setTipo(filter.getBusta().getDestinatario().getTipo());
  253.             }
  254.             busta.setDestinatario(bustaDestinatario);
  255.             
  256.             org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaSoggetto bustaMittente = null;
  257.             if(filter.getBusta().getMittente()!=null){
  258.                 bustaMittente = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaSoggetto();
  259.                 bustaMittente.setNome(filter.getBusta().getMittente().getNome());
  260.                 bustaMittente.setTipo(filter.getBusta().getMittente().getTipo());
  261.             }
  262.             busta.setMittente(bustaMittente);
  263.             
  264.             org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaServizio bustaServizio = null;
  265.             if(filter.getBusta().getServizio()!=null){
  266.                 bustaServizio = new org.openspcoop2.pdd.monitor.ws.client.statopdd.all.BustaServizio();
  267.                 bustaServizio.setNome(filter.getBusta().getServizio().getNome());
  268.                 bustaServizio.setTipo(filter.getBusta().getServizio().getTipo());
  269.                 //bustaServizio.setVersione(filter.getBusta().getServizio().getVersione());
  270.             }
  271.             busta.setServizio(bustaServizio);
  272.             
  273.             busta.setProfiloCollaborazione(filter.getBusta().getProfiloCollaborazione());
  274.             busta.setRiferimentoMessaggio(filter.getBusta().getRiferimentoMessaggio());
  275.         }
  276.         filtroInternoWS.setBusta(busta);
  277.         filterWS.setFiltro(filtroInternoWS);
  278.         
  279.         return filterWS;
  280.     }
  281.     

  283.     
  284. }
Created with JaCoCo 0.8.8.202204050719