DriverRegistroServiziWS.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.  */




  24. package org.openspcoop2.core.registry.driver.ws;

  26. import java.util.ArrayList;
  27. import java.util.Calendar;
  28. import java.util.GregorianCalendar;
  29. import java.util.List;

  31. import javax.xml.datatype.DatatypeFactory;
  32. import javax.xml.ws.BindingProvider;

  34. import org.openspcoop2.core.commons.CoreException;
  35. import org.openspcoop2.core.commons.IMonitoraggioRisorsa;
  36. import org.openspcoop2.core.id.IDAccordo;
  37. import org.openspcoop2.core.id.IDAccordoAzione;
  38. import org.openspcoop2.core.id.IDAccordoCooperazione;
  39. import org.openspcoop2.core.id.IDFruizione;
  40. import org.openspcoop2.core.id.IDGruppo;
  41. import org.openspcoop2.core.id.IDPortType;
  42. import org.openspcoop2.core.id.IDPortTypeAzione;
  43. import org.openspcoop2.core.id.IDResource;
  44. import org.openspcoop2.core.id.IDRuolo;
  45. import org.openspcoop2.core.id.IDScope;
  46. import org.openspcoop2.core.id.IDServizio;
  47. import org.openspcoop2.core.id.IDSoggetto;
  48. import org.openspcoop2.core.registry.AccordoCooperazione;
  49. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  50. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  51. import org.openspcoop2.core.registry.Azione;
  52. import org.openspcoop2.core.registry.Fruitore;
  53. import org.openspcoop2.core.registry.Gruppo;
  54. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  55. import org.openspcoop2.core.registry.Documento;
  56. import org.openspcoop2.core.registry.IdAccordoCooperazione;
  57. import org.openspcoop2.core.registry.IdAccordoServizioParteComune;
  58. import org.openspcoop2.core.registry.IdAccordoServizioParteSpecifica;
  59. import org.openspcoop2.core.registry.IdGruppo;
  60. import org.openspcoop2.core.registry.IdPortaDominio;
  61. import org.openspcoop2.core.registry.IdRuolo;
  62. import org.openspcoop2.core.registry.IdScope;
  63. import org.openspcoop2.core.registry.IdSoggetto;
  64. import org.openspcoop2.core.registry.Operation;
  65. import org.openspcoop2.core.registry.PortType;
  66. import org.openspcoop2.core.registry.PortaDominio;
  67. import org.openspcoop2.core.registry.Resource;
  68. import org.openspcoop2.core.registry.Ruolo;
  69. import org.openspcoop2.core.registry.Scope;
  70. import org.openspcoop2.core.registry.Soggetto;
  71. import org.openspcoop2.core.registry.constants.CredenzialeTipo;
  72. import org.openspcoop2.core.registry.constants.TipiDocumentoLivelloServizio;
  73. import org.openspcoop2.core.registry.constants.TipiDocumentoSemiformale;
  74. import org.openspcoop2.core.registry.constants.TipiDocumentoSicurezza;
  75. import org.openspcoop2.core.registry.constants.TipologiaServizio;
  76. import org.openspcoop2.core.registry.driver.BeanUtilities;
  77. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  78. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  79. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  80. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  81. import org.openspcoop2.core.registry.driver.FiltroRicercaAzioni;
  82. import org.openspcoop2.core.registry.driver.FiltroRicercaFruizioniServizio;
  83. import org.openspcoop2.core.registry.driver.FiltroRicercaGruppi;
  84. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  85. import org.openspcoop2.core.registry.driver.FiltroRicercaPortTypes;
  86. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  87. import org.openspcoop2.core.registry.driver.FiltroRicercaRuoli;
  88. import org.openspcoop2.core.registry.driver.FiltroRicercaScope;
  89. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  90. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  91. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  92. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  93. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  94. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  95. import org.openspcoop2.core.registry.driver.ProtocolPropertiesUtilities;
  96. import org.openspcoop2.core.registry.ws.client.accordocooperazione.search.AccordoCooperazioneSoap11Service;
  97. import org.openspcoop2.core.registry.ws.client.accordocooperazione.search.SearchFilterAccordoCooperazione;
  98. import org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.AccordoServizioParteComuneSoap11Service;
  99. import org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.SearchFilterAccordoServizioParteComune;
  100. import org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.AccordoServizioParteSpecificaSoap11Service;
  101. import org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.SearchFilterAccordoServizioParteSpecifica;
  102. import org.openspcoop2.core.registry.ws.client.portadominio.search.PortaDominioSoap11Service;
  103. import org.openspcoop2.core.registry.ws.client.portadominio.search.SearchFilterPortaDominio;
  104. import org.openspcoop2.core.registry.ws.client.gruppo.search.GruppoSoap11Service;
  105. import org.openspcoop2.core.registry.ws.client.gruppo.search.SearchFilterGruppo;
  106. import org.openspcoop2.core.registry.ws.client.ruolo.search.RuoloSoap11Service;
  107. import org.openspcoop2.core.registry.ws.client.ruolo.search.SearchFilterRuolo;
  108. import org.openspcoop2.core.registry.ws.client.scope.search.ScopeSoap11Service;
  109. import org.openspcoop2.core.registry.ws.client.scope.search.SearchFilterScope;
  110. import org.openspcoop2.core.registry.ws.client.soggetto.search.SearchFilterSoggetto;
  111. import org.openspcoop2.core.registry.ws.client.soggetto.search.SoggettoSoap11Service;
  112. import org.openspcoop2.utils.LoggerWrapperFactory;
  113. import org.openspcoop2.utils.UtilsRuntimeException;
  114. import org.openspcoop2.utils.certificate.CertificateInfo;
  115. import org.openspcoop2.utils.crypt.CryptConfig;
  116. import org.openspcoop2.utils.crypt.CryptFactory;
  117. import org.openspcoop2.utils.crypt.ICrypt;
  118. import org.slf4j.Logger;



  122. /**
  123.  * Classe utilizzata per effettuare query ad un registro WS, riguardanti specifiche
  124.  * proprieta' di servizi presenti all'interno del registro.
  125.  *
  126.  *
  127.  * @author Poli Andrea (apoli@link.it)
  128.  * @author Lorenzo Nardi (nardi@link.it)
  129.  * @author $Author$
  130.  * @version $Rev$, $Date$
  131.  */

  133. public class DriverRegistroServiziWS extends BeanUtilities
  134.   implements IDriverRegistroServiziGet,IMonitoraggioRisorsa {



  138.     /* ********  F I E L D S  P R I V A T I  ******** */

  140.     /** Indicazione di una corretta creazione */
  141.     public boolean create = false;
  142.     public boolean isCreate() {
  143.         return this.create;
  144.     }
  145.     
  146.     /** Stub per invocazione del WS */
  147.     private org.openspcoop2.core.registry.ws.client.accordocooperazione.search.AccordoCooperazioneSoap11Service accordoCooperazioneService;
  148.     private org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.AccordoServizioParteComuneSoap11Service accordoServizioParteComuneService;
  149.     private org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.AccordoServizioParteSpecificaSoap11Service accordoServizioParteSpecificaService;
  150.     private org.openspcoop2.core.registry.ws.client.soggetto.search.SoggettoSoap11Service soggettoService;
  151.     private org.openspcoop2.core.registry.ws.client.portadominio.search.PortaDominioSoap11Service pddService;
  152.     private org.openspcoop2.core.registry.ws.client.gruppo.search.GruppoSoap11Service gruppoService;
  153.     private org.openspcoop2.core.registry.ws.client.ruolo.search.RuoloSoap11Service ruoloService;
  154.     private org.openspcoop2.core.registry.ws.client.scope.search.ScopeSoap11Service scopeService;
  155.     
  156.     private org.openspcoop2.core.registry.ws.client.accordocooperazione.search.AccordoCooperazione accordoCooperazionePort;
  157.     private org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.AccordoServizioParteComune accordoServizioParteComunePort;
  158.     private org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.AccordoServizioParteSpecifica accordoServizioParteSpecificaPort;
  159.     private org.openspcoop2.core.registry.ws.client.soggetto.search.Soggetto soggettoPort;
  160.     private org.openspcoop2.core.registry.ws.client.portadominio.search.PortaDominio pddPort;
  161.     private org.openspcoop2.core.registry.ws.client.gruppo.search.Gruppo gruppoPort;
  162.     private org.openspcoop2.core.registry.ws.client.ruolo.search.Ruolo ruoloPort;
  163.     private org.openspcoop2.core.registry.ws.client.scope.search.Scope scopePort;

  165.     
  166.     /** Logger utilizzato per info. */
  167.     private org.slf4j.Logger log = null;

  169.     private  DatatypeFactory dataTypeFactory = null;



  173.     /* ********  C O S T R U T T O R E  ******** */
  174.     /**
  175.      * Costruttore. 
  176.      *
  177.      * 
  178.      */
  179.     public DriverRegistroServiziWS(String prefixLocation,Logger alog){  
  180.         this(prefixLocation,null,null,alog);
  181.     }
  182.     /**
  183.      * Costruttore. 
  184.      *
  185.      * 
  186.      */
  187.     public DriverRegistroServiziWS(String prefixLocation,String username,String password,Logger alog){  
  188.         
  189.         if(alog==null)
  190.             this.log = LoggerWrapperFactory.getLogger(DriverRegistroServiziWS.class);
  191.         else
  192.             this.log = alog;
  193.         if(this.log==null) {
  194.             throw new UtilsRuntimeException("Logger unavailable");
  195.         }
  196.         try{    
  197.             // es. http://127.0.0.1:8080/openspcoop2Registry/
  198.             if(prefixLocation==null)
  199.                 throw new Exception("Location is null");
  200.             if(prefixLocation.endsWith("/")==false){
  201.                 prefixLocation = prefixLocation + "/";
  202.             }
  203.             
  204.             this.dataTypeFactory = DatatypeFactory.newInstance();
  205.             
  206.             this.accordoCooperazioneService = new AccordoCooperazioneSoap11Service();
  207.             this.accordoServizioParteComuneService = new AccordoServizioParteComuneSoap11Service();
  208.             this.accordoServizioParteSpecificaService = new AccordoServizioParteSpecificaSoap11Service();
  209.             this.soggettoService = new SoggettoSoap11Service();
  210.             this.pddService = new PortaDominioSoap11Service();
  211.             this.gruppoService = new GruppoSoap11Service();
  212.             this.ruoloService = new RuoloSoap11Service();
  213.             this.scopeService = new ScopeSoap11Service();
  214.             
  215.             this.accordoCooperazionePort = this.accordoCooperazioneService.getAccordoCooperazionePortSoap11();
  216.             this.accordoServizioParteComunePort = this.accordoServizioParteComuneService.getAccordoServizioParteComunePortSoap11();
  217.             this.accordoServizioParteSpecificaPort = this.accordoServizioParteSpecificaService.getAccordoServizioParteSpecificaPortSoap11();
  218.             this.soggettoPort = this.soggettoService.getSoggettoPortSoap11();
  219.             this.pddPort = this.pddService.getPortaDominioPortSoap11();
  220.             this.gruppoPort = this.gruppoService.getGruppoPortSoap11();
  221.             this.ruoloPort = this.ruoloService.getRuoloPortSoap11();
  222.             this.scopePort = this.scopeService.getScopePortSoap11();
  223.             
  224.             ((BindingProvider)this.accordoCooperazionePort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  225.                     prefixLocation+"AccordoCooperazione/Soap11");
  226.             ((BindingProvider)this.accordoServizioParteComunePort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  227.                     prefixLocation+"AccordoServizioParteComune/Soap11");
  228.             ((BindingProvider)this.accordoServizioParteSpecificaPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  229.                     prefixLocation+"AccordoServizioParteSpecifica/Soap11");
  230.             ((BindingProvider)this.soggettoPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  231.                     prefixLocation+"Soggetto/Soap11");
  232.             ((BindingProvider)this.pddPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  233.                     prefixLocation+"PortaDominio/Soap11");
  234.             ((BindingProvider)this.gruppoPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  235.                     prefixLocation+"Gruppo/Soap11");
  236.             ((BindingProvider)this.ruoloPort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  237.                     prefixLocation+"Ruolo/Soap11");
  238.             ((BindingProvider)this.scopePort).getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, 
  239.                     prefixLocation+"Scope/Soap11");
  240.             
  241.             ((BindingProvider)this.accordoCooperazionePort).getRequestContext().put("schema-validation-enabled", true);
  242.             ((BindingProvider)this.accordoServizioParteComunePort).getRequestContext().put("schema-validation-enabled", true);
  243.             ((BindingProvider)this.accordoServizioParteSpecificaPort).getRequestContext().put("schema-validation-enabled", true);
  244.             ((BindingProvider)this.soggettoPort).getRequestContext().put("schema-validation-enabled", true);
  245.             ((BindingProvider)this.pddPort).getRequestContext().put("schema-validation-enabled", true);
  246.             ((BindingProvider)this.gruppoPort).getRequestContext().put("schema-validation-enabled", true);
  247.             ((BindingProvider)this.ruoloPort).getRequestContext().put("schema-validation-enabled", true);
  248.             ((BindingProvider)this.scopePort).getRequestContext().put("schema-validation-enabled", true);
  249.             
  250.             if(username !=null && password!=null){
  251.                 // to use Basic HTTP Authentication: 
  252.                 
  253.                 ((BindingProvider)this.accordoCooperazionePort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  254.                 ((BindingProvider)this.accordoCooperazionePort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  255.                 
  256.                 ((BindingProvider)this.accordoServizioParteComunePort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  257.                 ((BindingProvider)this.accordoServizioParteComunePort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  258.                 
  259.                 ((BindingProvider)this.accordoServizioParteSpecificaPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  260.                 ((BindingProvider)this.accordoServizioParteSpecificaPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  261.                 
  262.                 ((BindingProvider)this.soggettoPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  263.                 ((BindingProvider)this.soggettoPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  264.                 
  265.                 ((BindingProvider)this.pddPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  266.                 ((BindingProvider)this.pddPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  267.                 
  268.                 ((BindingProvider)this.gruppoPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  269.                 ((BindingProvider)this.gruppoPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  270.                 
  271.                 ((BindingProvider)this.ruoloPort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  272.                 ((BindingProvider)this.ruoloPort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  273.                 
  274.                 ((BindingProvider)this.scopePort).getRequestContext().put(BindingProvider.USERNAME_PROPERTY, username);
  275.                 ((BindingProvider)this.scopePort).getRequestContext().put(BindingProvider.PASSWORD_PROPERTY, password);
  276.             }
  277.             
  278.             this.log.debug("GestoreRegistro: Inizializzato WebService. AccordoCooperazione: " + this.accordoCooperazioneService.getClass().getSimpleName());
  279.             this.log.debug("GestoreRegistro: Inizializzato WebService. AccordoServizioParteComune: " + this.accordoServizioParteComuneService.getClass().getSimpleName());
  280.             this.log.debug("GestoreRegistro: Inizializzato WebService. AccordoServizioParteSpecifica: " + this.accordoServizioParteSpecificaService.getClass().getSimpleName());
  281.             this.log.debug("GestoreRegistro: Inizializzato WebService. Soggetto: " + this.soggettoService.getClass().getSimpleName());
  282.             this.log.debug("GestoreRegistro: Inizializzato WebService. PortaDominio: " + this.pddService.getClass().getSimpleName());
  283.             this.log.debug("GestoreRegistro: Inizializzato WebService. Gruppo: " + this.gruppoService.getClass().getSimpleName());
  284.             this.log.debug("GestoreRegistro: Inizializzato WebService. Ruolo: " + this.ruoloService.getClass().getSimpleName());
  285.             this.log.debug("GestoreRegistro: Inizializzato WebService. Scope: " + this.scopeService.getClass().getSimpleName());
  286.             
  287.             this.create = true;
  288.         } catch(Exception e){
  289.             this.log.error("Inizializzazione fallita: "+e.getMessage());
  290.             this.create = false;
  291.         }
  292.     }
  293.     
  294.     
  295.     
  296.     // IS ALIVE
  297.     
  298.     @Override
  299.     public void isAlive() throws CoreException {
  300.         SearchFilterSoggetto filter = new SearchFilterSoggetto();
  301.         filter.setNome("ISALIVE");
  302.         try{
  303.             this.soggettoPort.count(new SearchFilterSoggetto());
  304.         }catch(Exception e){
  305.             throw new CoreException(e.getMessage(),e);
  306.         }
  307.     }
  308.     
  309.     
  310.     
  311.     // PORTE DOMINIO
  312.     
  313.     @Override
  314.     public PortaDominio getPortaDominio(String nomePdD)
  315.             throws DriverRegistroServiziException,
  316.             DriverRegistroServiziNotFound {
  317.         try{
  318.             return this.pddPort.get(new IdPortaDominio(nomePdD));
  319.         }catch(org.openspcoop2.core.registry.ws.client.portadominio.search.RegistryNotFoundException_Exception e){
  320.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  321.         }catch(Exception e){
  322.             throw new DriverRegistroServiziException(e.getMessage(),e);
  323.         }
  324.     }
  325.     @Override
  326.     public List<String> getAllIdPorteDominio(FiltroRicerca filtroRicerca)
  327.             throws DriverRegistroServiziException,
  328.             DriverRegistroServiziNotFound {
  329.         try{
  330.             SearchFilterPortaDominio filter = new SearchFilterPortaDominio();
  331.             if(filtroRicerca!=null){
  332.                 if(filtroRicerca.getTipo()!=null){
  333.                     // NOP
  334.                 }
  335.                 if(filtroRicerca.getNome()!=null){
  336.                     filter.setNome(filtroRicerca.getNome());
  337.                 }
  338.                 if(filtroRicerca.getMaxDate()!=null){
  339.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  340.                     cal.setTime(filtroRicerca.getMaxDate());
  341.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  342.                 }
  343.                 if(filtroRicerca.getMinDate()!=null){
  344.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  345.                     cal.setTime(filtroRicerca.getMinDate());
  346.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  347.                 }               
  348.             }
  349.             List<IdPortaDominio> ids = this.pddPort.findAllIds(filter);
  350.             if(ids==null || ids.size()<=0){
  351.                 throw new org.openspcoop2.core.registry.ws.client.portadominio.search.RegistryNotFoundException_Exception("La ricerca non ha trovato pdd");
  352.             }
  353.             List<String> idsOpenSPCoop = new ArrayList<>();
  354.             for (IdPortaDominio idPortaDominio : ids) {
  355.                 String idPortaDominioOpenSPCoop = idPortaDominio.getNome();
  356.                 idsOpenSPCoop.add(idPortaDominioOpenSPCoop);
  357.             }
  358.             
  359.             return idsOpenSPCoop;
  360.             
  361.         }catch(org.openspcoop2.core.registry.ws.client.portadominio.search.RegistryNotFoundException_Exception e){
  362.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  363.         }catch(Exception e){
  364.             throw new DriverRegistroServiziException(e.getMessage(),e);
  365.         }
  366.     }
  367.     
  368.     
  369.     
  370.     // GRUPPI

  372.     @Override
  373.     public Gruppo getGruppo(
  374.             IDGruppo idGruppo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  375.         try{
  376.             return this.gruppoPort.get(new IdGruppo(idGruppo));
  377.         }catch(org.openspcoop2.core.registry.ws.client.gruppo.search.RegistryNotFoundException_Exception e){
  378.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  379.         }catch(Exception e){
  380.             throw new DriverRegistroServiziException(e.getMessage(),e);
  381.         }
  382.     }


  385.     @Override
  386.     public List<IDGruppo> getAllIdGruppi(
  387.             FiltroRicercaGruppi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  388.         try{
  389.             SearchFilterGruppo filter = new SearchFilterGruppo();
  390.             if(filtroRicerca!=null){
  391.                 if(filtroRicerca.getNome()!=null){
  392.                     filter.setNome(filtroRicerca.getNome());
  393.                 }
  394.                 if(filtroRicerca.getServiceBinding()!=null){
  395.                     filter.setServiceBinding(filtroRicerca.getServiceBinding());
  396.                 }
  397.                 if(filtroRicerca.getMaxDate()!=null){
  398.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  399.                     cal.setTime(filtroRicerca.getMaxDate());
  400.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  401.                 }
  402.                 if(filtroRicerca.getMinDate()!=null){
  403.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  404.                     cal.setTime(filtroRicerca.getMinDate());
  405.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  406.                 }               
  407.             }
  408.             List<IdGruppo> ids = this.gruppoPort.findAllIds(filter);
  409.             if(ids==null || ids.size()<=0){
  410.                 throw new org.openspcoop2.core.registry.ws.client.gruppo.search.RegistryNotFoundException_Exception("La ricerca non ha trovato gruppi");
  411.             }
  412.             List<IDGruppo> idsOpenSPCoop = new ArrayList<IDGruppo>();
  413.             for (IdGruppo idGruppo : ids) {
  414.                 String idGruppoOpenSPCoop = idGruppo.getNome();
  415.                 idsOpenSPCoop.add(new IDGruppo(idGruppoOpenSPCoop));
  416.             }
  417.             
  418.             return idsOpenSPCoop;
  419.             
  420.         }catch(org.openspcoop2.core.registry.ws.client.gruppo.search.RegistryNotFoundException_Exception e){
  421.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  422.         }catch(Exception e){
  423.             throw new DriverRegistroServiziException(e.getMessage(),e);
  424.         }
  425.     }
  426.     
  427.     
  428.     
  429.     
  430.     // RUOLI

  432.     @Override
  433.     public Ruolo getRuolo(
  434.             IDRuolo idRuolo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  435.         try{
  436.             return this.ruoloPort.get(new IdRuolo(idRuolo));
  437.         }catch(org.openspcoop2.core.registry.ws.client.ruolo.search.RegistryNotFoundException_Exception e){
  438.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  439.         }catch(Exception e){
  440.             throw new DriverRegistroServiziException(e.getMessage(),e);
  441.         }
  442.     }


  445.     @Override
  446.     public List<IDRuolo> getAllIdRuoli(
  447.             FiltroRicercaRuoli filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  448.         try{
  449.             SearchFilterRuolo filter = new SearchFilterRuolo();
  450.             if(filtroRicerca!=null){
  451.                 if(filtroRicerca.getNome()!=null){
  452.                     filter.setNome(filtroRicerca.getNome());
  453.                 }
  454.                 if(filtroRicerca.getTipologia()!=null){
  455.                     filter.setTipologia(filtroRicerca.getTipologia());
  456.                 }
  457.                 if(filtroRicerca.getContesto()!=null){
  458.                     filter.setContestoUtilizzo(filtroRicerca.getContesto());
  459.                 }
  460.                 if(filtroRicerca.getMaxDate()!=null){
  461.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  462.                     cal.setTime(filtroRicerca.getMaxDate());
  463.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  464.                 }
  465.                 if(filtroRicerca.getMinDate()!=null){
  466.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  467.                     cal.setTime(filtroRicerca.getMinDate());
  468.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  469.                 }               
  470.             }
  471.             List<IdRuolo> ids = this.ruoloPort.findAllIds(filter);
  472.             if(ids==null || ids.size()<=0){
  473.                 throw new org.openspcoop2.core.registry.ws.client.ruolo.search.RegistryNotFoundException_Exception("La ricerca non ha trovato ruoli");
  474.             }
  475.             List<IDRuolo> idsOpenSPCoop = new ArrayList<IDRuolo>();
  476.             for (IdRuolo idRuolo : ids) {
  477.                 String idRuoloOpenSPCoop = idRuolo.getNome();
  478.                 idsOpenSPCoop.add(new IDRuolo(idRuoloOpenSPCoop));
  479.             }
  480.             
  481.             return idsOpenSPCoop;
  482.             
  483.         }catch(org.openspcoop2.core.registry.ws.client.ruolo.search.RegistryNotFoundException_Exception e){
  484.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  485.         }catch(Exception e){
  486.             throw new DriverRegistroServiziException(e.getMessage(),e);
  487.         }
  488.     }
  489.     
  490.     
  491.     
  492.     
  493.     // SCOPE

  495.     @Override
  496.     public Scope getScope(
  497.             IDScope idScope) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  498.         try{
  499.             return this.scopePort.get(new IdScope(idScope));
  500.         }catch(org.openspcoop2.core.registry.ws.client.scope.search.RegistryNotFoundException_Exception e){
  501.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  502.         }catch(Exception e){
  503.             throw new DriverRegistroServiziException(e.getMessage(),e);
  504.         }
  505.     }


  508.     @Override
  509.     public List<IDScope> getAllIdScope(
  510.             FiltroRicercaScope filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  511.         try{
  512.             SearchFilterScope filter = new SearchFilterScope();
  513.             if(filtroRicerca!=null){
  514.                 if(filtroRicerca.getNome()!=null){
  515.                     filter.setNome(filtroRicerca.getNome());
  516.                 }
  517.                 if(filtroRicerca.getTipologia()!=null){
  518.                     filter.setTipologia(filtroRicerca.getTipologia());
  519.                 }
  520.                 if(filtroRicerca.getContesto()!=null){
  521.                     filter.setContestoUtilizzo(filtroRicerca.getContesto());
  522.                 }
  523.                 if(filtroRicerca.getMaxDate()!=null){
  524.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  525.                     cal.setTime(filtroRicerca.getMaxDate());
  526.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  527.                 }
  528.                 if(filtroRicerca.getMinDate()!=null){
  529.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  530.                     cal.setTime(filtroRicerca.getMinDate());
  531.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  532.                 }               
  533.             }
  534.             List<IdScope> ids = this.scopePort.findAllIds(filter);
  535.             if(ids==null || ids.size()<=0){
  536.                 throw new org.openspcoop2.core.registry.ws.client.scope.search.RegistryNotFoundException_Exception("La ricerca non ha trovato scope");
  537.             }
  538.             List<IDScope> idsOpenSPCoop = new ArrayList<IDScope>();
  539.             for (IdScope idScope : ids) {
  540.                 String idScopeOpenSPCoop = idScope.getNome();
  541.                 idsOpenSPCoop.add(new IDScope(idScopeOpenSPCoop));
  542.             }
  543.             
  544.             return idsOpenSPCoop;
  545.             
  546.         }catch(org.openspcoop2.core.registry.ws.client.scope.search.RegistryNotFoundException_Exception e){
  547.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  548.         }catch(Exception e){
  549.             throw new DriverRegistroServiziException(e.getMessage(),e);
  550.         }
  551.     }
  552.         
  553.     
  554.     
  555.     
  556.     // SOGGETTI
  557.     
  558.     @Override
  559.     public Soggetto getSoggetto(IDSoggetto idSoggetto)
  560.             throws DriverRegistroServiziException,
  561.             DriverRegistroServiziNotFound {
  562.         try{
  563.             return this.soggettoPort.get(new IdSoggetto(idSoggetto));
  564.         }catch(org.openspcoop2.core.registry.ws.client.soggetto.search.RegistryNotFoundException_Exception e){
  565.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  566.         }catch(Exception e){
  567.             throw new DriverRegistroServiziException(e.getMessage(),e);
  568.         }
  569.     }
  570.     
  571.     @Override
  572.     public Soggetto getSoggettoByCredenzialiBasic(
  573.             String user,String password, 
  574.             CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  575.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.BASIC, user, password, 
  576.                 null, null, null, false,
  577.                 null,
  578.                 config,
  579.                 false);
  580.     }
  581.     
  582.     @Override
  583.     public Soggetto getSoggettoByCredenzialiApiKey(
  584.             String user,String password, boolean appId,
  585.             CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  586.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.BASIC, user, password, 
  587.                 null, null, null, false,
  588.                 null,
  589.                 config,
  590.                 appId);
  591.     }
  592.     
  593.     @Override
  594.     public Soggetto getSoggettoByCredenzialiSsl(
  595.             String subject, String issuer) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  596.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  597.                 subject, issuer, null, false,
  598.                 null,
  599.                 null,
  600.                 false);
  601.     }
  602.     
  603.     @Override
  604.     public Soggetto getSoggettoByCredenzialiSsl(CertificateInfo certificate, boolean strictVerifier) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  605.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  606.                 null, null, certificate, strictVerifier,
  607.                 null,
  608.                 null,
  609.                 false);
  610.     }
  611.     
  612.     @Override
  613.     public Soggetto getSoggettoByCredenzialiPrincipal(
  614.             String principal) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  615.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.PRINCIPAL, null, null, 
  616.                 null, null, null, false,
  617.                 principal,
  618.                 null,
  619.                 false);
  620.     }
  621.     private org.openspcoop2.core.registry.Soggetto getEngineSoggettoAutenticato(CredenzialeTipo tipoCredenziale, String user,String password, 
  622.             String aSubject, String aIssuer, CertificateInfo aCertificate, boolean aStrictVerifier, 
  623.             String principal, 
  624.             CryptConfig config,
  625.             boolean appId) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  626.         
  627.         // conrollo consistenza
  628.         if (tipoCredenziale == null)
  629.             throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro tipoCredenziale is null");

  631.         switch (tipoCredenziale) {
  632.         case BASIC:
  633.             if (user == null || "".equalsIgnoreCase(user))
  634.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for basic auth)");
  635.             if (password == null || "".equalsIgnoreCase(password))
  636.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for basic auth)");
  637.             break;
  638.         case APIKEY:
  639.             if (user == null || "".equalsIgnoreCase(user))
  640.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for apikey auth)");
  641.             if (password == null || "".equalsIgnoreCase(password))
  642.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for apikey auth)");
  643.             break;
  644.         case SSL:
  645.             if ( (aSubject == null || "".equalsIgnoreCase(aSubject)) && (aCertificate==null))
  646.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro subject/certificate is null (required for ssl auth)");
  647.             break;
  648.         case PRINCIPAL:
  649.             if (principal == null || "".equalsIgnoreCase(principal))
  650.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro principal is null (required for principal auth)");
  651.             break;
  652.         }

  654.         IDSoggetto idSoggetto = null;
  655.         try{
  656.             FiltroRicercaSoggetti filtroRicerca = new FiltroRicercaSoggetti();
  657.             CredenzialiSoggetto credenzialiSoggetto = new CredenzialiSoggetto();
  658.             credenzialiSoggetto.setTipo(tipoCredenziale);
  659.             switch (tipoCredenziale) {
  660.             case BASIC:
  661.                 credenzialiSoggetto.setUser(user);
  662.                 credenzialiSoggetto.setPassword(password);
  663.                 break;
  664.             case APIKEY:
  665.                 credenzialiSoggetto.setUser(user);
  666.                 credenzialiSoggetto.setPassword(password);
  667.                 credenzialiSoggetto.setAppId(appId);
  668.                 break;
  669.             case SSL:
  670.                 credenzialiSoggetto.setSubject(aSubject);
  671.                 credenzialiSoggetto.setIssuer(aIssuer);
  672.                 if(aCertificate!=null) {
  673.                     try {
  674.                         credenzialiSoggetto.setCertificate(aCertificate.getCertificate().getEncoded());
  675.                     }catch(Exception e) {
  676.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  677.                     }
  678.                 }
  679.                 credenzialiSoggetto.setCertificateStrictVerification(aStrictVerifier);
  680.                 break;
  681.             case PRINCIPAL:
  682.                 credenzialiSoggetto.setUser(principal);
  683.                 break;
  684.             }
  685.             filtroRicerca.setCredenzialiSoggetto(credenzialiSoggetto, config);
  686.             List<IDSoggetto> l = this.getAllIdSoggetti(filtroRicerca);
  687.             if(l.size()>1){
  688.                 throw new DriverRegistroServiziException("Trovato più di un soggetto che possiede le credenziali '"+tipoCredenziale.toString()+"' fornite");
  689.             }
  690.             else if(l.size()==1){
  691.                 idSoggetto = l.get(0);
  692.             }
  693.         }catch(DriverRegistroServiziNotFound notFound){}
  694.         
  695.         if(idSoggetto==null){
  696.             throw new DriverRegistroServiziNotFound("Nessun soggetto trovato che possiede le credenziali '"+tipoCredenziale.toString()+"' fornite");
  697.         }
  698.         else{
  699.             return this.getSoggetto(idSoggetto);
  700.         }
  701.     }
  702.     
  703.     @Override
  704.     public List<IDSoggetto> getAllIdSoggetti(FiltroRicercaSoggetti filtroRicerca)
  705.             throws DriverRegistroServiziException,
  706.             DriverRegistroServiziNotFound {
  707.         try{
  708.             @SuppressWarnings("unused")
  709.             boolean testInChiaro = false;
  710.             @SuppressWarnings("unused")
  711.             ICrypt crypt = null;
  712.             if(filtroRicerca!=null && filtroRicerca.getCredenzialiSoggetto()!=null && filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  713.                 CredenzialeTipo cTipo = filtroRicerca.getCredenzialiSoggetto().getTipo();
  714.                 if(CredenzialeTipo.BASIC.equals(cTipo)){
  715.                     CryptConfig config = filtroRicerca.getCryptConfig();
  716.                     if(config==null || config.isBackwardCompatibility()) {
  717.                         testInChiaro = true;
  718.                     }
  719.                     if(config!=null) {
  720.                         try {
  721.                             crypt = CryptFactory.getCrypt(this.log, config);
  722.                         }catch(Exception e) {
  723.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  724.                         }
  725.                     }
  726.                 }
  727.                 else if(CredenzialeTipo.APIKEY.equals(cTipo)){
  728.                     CryptConfig config = filtroRicerca.getCryptConfig();
  729.                     if(config!=null) {
  730.                         try {
  731.                             crypt = CryptFactory.getCrypt(this.log, config);
  732.                         }catch(Exception e) {
  733.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  734.                         }
  735.                     }
  736.                     else {
  737.                         testInChiaro = true;
  738.                     }
  739.                 }
  740.             }
  741.             
  742.             SearchFilterSoggetto filter = new SearchFilterSoggetto();
  743.             if(filtroRicerca!=null){
  744.                 if(filtroRicerca.getTipo()!=null){
  745.                     filter.setTipo(filtroRicerca.getTipo());
  746.                 }
  747.                 if(filtroRicerca.getNome()!=null){
  748.                     filter.setNome(filtroRicerca.getNome());
  749.                 }
  750.                 if(filtroRicerca.getNomePdd()!=null){
  751.                     filter.setPortaDominio(filtroRicerca.getNomePdd());
  752.                 }
  753.                 if(filtroRicerca.getMaxDate()!=null){
  754.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  755.                     cal.setTime(filtroRicerca.getMaxDate());
  756.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  757.                 }
  758.                 if(filtroRicerca.getMinDate()!=null){
  759.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  760.                     cal.setTime(filtroRicerca.getMinDate());
  761.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  762.                 }
  763.                 // Filtro By Ruolo
  764.                 if(filtroRicerca.getIdRuolo()!=null){
  765.                     throw new DriverRegistroServiziException("Not Implemented");
  766.                 }
  767.                 // Filtro By Credenziali
  768.                 if(filtroRicerca.getCredenzialiSoggetto()!=null){
  769.                     org.openspcoop2.core.registry.ws.client.soggetto.search.CredenzialiSoggetto credenziali = new 
  770.                             org.openspcoop2.core.registry.ws.client.soggetto.search.CredenzialiSoggetto();
  771.                     if(filtroRicerca.getCredenzialiSoggetto().getTipo()!=null){
  772.                         credenziali.setTipo(filtroRicerca.getCredenzialiSoggetto().getTipo());
  773.                     }
  774.                     if(filtroRicerca.getCredenzialiSoggetto().getUser()!=null){
  775.                         credenziali.setUser(filtroRicerca.getCredenzialiSoggetto().getUser());
  776.                     }
  777.                     if(filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  778.                         credenziali.setPassword(filtroRicerca.getCredenzialiSoggetto().getPassword());
  779.                     }
  780.                     if(filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  781.                         credenziali.setSubject(filtroRicerca.getCredenzialiSoggetto().getSubject());
  782.                     }
  783.                     if(filtroRicerca.getCredenzialiSoggetto().getIssuer()!=null){
  784.                         credenziali.setSubject(filtroRicerca.getCredenzialiSoggetto().getIssuer());
  785.                     }
  786.                     if(filtroRicerca.getCredenzialiSoggetto().getCertificate()!=null){
  787.                         credenziali.setCertificate(filtroRicerca.getCredenzialiSoggetto().getCertificate());
  788.                         credenziali.setCertificateStrictVerification(filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification());
  789.                     }
  790.                     if(filtroRicerca.getCredenzialiSoggetto().getCnSubject()!=null){
  791.                         credenziali.setCnSubject(filtroRicerca.getCredenzialiSoggetto().getCnSubject());
  792.                     }
  793.                     if(filtroRicerca.getCredenzialiSoggetto().getCnIssuer()!=null){
  794.                         credenziali.setCnIssuer(filtroRicerca.getCredenzialiSoggetto().getCnIssuer());
  795.                     }
  796.                     filter.setCredenziali(credenziali);
  797.                 }
  798.             }
  799.             List<IDSoggetto> idsOpenSPCoop = new ArrayList<IDSoggetto>();
  800.             if(filtroRicerca==null || filtroRicerca.getProtocolProperties()==null || filtroRicerca.getProtocolProperties().size()<=0){
  801.                 List<IdSoggetto> ids = this.soggettoPort.findAllIds(filter);
  802.                 if(ids==null || ids.size()<=0){
  803.                     throw new org.openspcoop2.core.registry.ws.client.soggetto.search.RegistryNotFoundException_Exception("La ricerca non ha trovato soggetti");
  804.                 }
  805.                 for (IdSoggetto idSoggetto : ids) {
  806.                     IDSoggetto idSoggettoOpenSPCoop = new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome());
  807.                     idsOpenSPCoop.add(idSoggettoOpenSPCoop);
  808.                 }
  809.             }
  810.             else{
  811.                 List<Soggetto> ss = this.soggettoPort.findAll(filter);
  812.                 if(ss==null || ss.size()<=0){
  813.                     throw new org.openspcoop2.core.registry.ws.client.soggetto.search.RegistryNotFoundException_Exception("La ricerca non ha trovato soggetti");
  814.                 }
  815.                 for (Soggetto soggetto : ss) {
  816.                     // ProtocolProperties
  817.                     if(ProtocolPropertiesUtilities.isMatch(soggetto, filtroRicerca.getProtocolProperties())==false){
  818.                         continue;
  819.                     }
  820.                     IDSoggetto idSoggettoOpenSPCoop = new IDSoggetto(soggetto.getTipo(), soggetto.getNome());
  821.                     idsOpenSPCoop.add(idSoggettoOpenSPCoop);
  822.                 }
  823.                 if(idsOpenSPCoop==null || idsOpenSPCoop.size()<=0){
  824.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  825.                 }
  826.             }
  827.             
  828.             return idsOpenSPCoop;
  829.             
  830.         }catch(org.openspcoop2.core.registry.ws.client.soggetto.search.RegistryNotFoundException_Exception e){
  831.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  832.         }catch(Exception e){
  833.             throw new DriverRegistroServiziException(e.getMessage(),e);
  834.         }
  835.     }
  836.     
  837.     
  838.     
  839.     // ACCORDI COOPERAZIONE
  840.     
  841.     @Override
  842.     public AccordoCooperazione getAccordoCooperazione(
  843.             IDAccordoCooperazione idAccordo)
  844.             throws DriverRegistroServiziException,
  845.             DriverRegistroServiziNotFound {
  846.         try{
  847.             return this.accordoCooperazionePort.get(new IdAccordoCooperazione(idAccordo));
  848.         }catch(org.openspcoop2.core.registry.ws.client.accordocooperazione.search.RegistryNotFoundException_Exception e){
  849.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  850.         }catch(Exception e){
  851.             throw new DriverRegistroServiziException(e.getMessage(),e);
  852.         }
  853.     }
  854.     @Override
  855.     public List<IDAccordoCooperazione> getAllIdAccordiCooperazione(
  856.             FiltroRicercaAccordi filtroRicerca)
  857.             throws DriverRegistroServiziException,
  858.             DriverRegistroServiziNotFound {
  859.         try{
  860.             SearchFilterAccordoCooperazione filter = new SearchFilterAccordoCooperazione();
  861.             if(filtroRicerca!=null){
  862.                 if(filtroRicerca.getVersione()!=null){
  863.                     filter.setVersione(Long.valueOf(filtroRicerca.getVersione()));
  864.                 }
  865.                 if(filtroRicerca.getTipoSoggettoReferente()!=null || filtroRicerca.getNomeSoggettoReferente()!=null){
  866.                     filter.setSoggettoReferente(new org.openspcoop2.core.registry.ws.client.accordocooperazione.search.IdSoggetto());
  867.                     if(filtroRicerca.getTipoSoggettoReferente()!=null){
  868.                         filter.getSoggettoReferente().setTipo(filtroRicerca.getTipoSoggettoReferente());
  869.                     }
  870.                     if(filtroRicerca.getNomeSoggettoReferente()!=null){
  871.                         filter.getSoggettoReferente().setNome(filtroRicerca.getNomeSoggettoReferente());
  872.                     }
  873.                 }
  874.                 if(filtroRicerca.getNomeAccordo()!=null){
  875.                     filter.setNome(filtroRicerca.getNomeAccordo());
  876.                 }
  877.                 if(filtroRicerca.getMaxDate()!=null){
  878.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  879.                     cal.setTime(filtroRicerca.getMaxDate());
  880.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  881.                 }
  882.                 if(filtroRicerca.getMinDate()!=null){
  883.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  884.                     cal.setTime(filtroRicerca.getMinDate());
  885.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  886.                 }               
  887.             }
  888.             List<IDAccordoCooperazione> idsOpenSPCoop = new ArrayList<IDAccordoCooperazione>();
  889.             if(filtroRicerca==null || filtroRicerca.getProtocolPropertiesAccordo()==null || filtroRicerca.getProtocolPropertiesAccordo().size()<=0){
  890.                 List<IdAccordoCooperazione> ids = this.accordoCooperazionePort.findAllIds(filter);
  891.                 if(ids==null || ids.size()<=0){
  892.                     throw new org.openspcoop2.core.registry.ws.client.accordocooperazione.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  893.                 }
  894.                 for (IdAccordoCooperazione idAccordoCooperazione : ids) {
  895.                     IDAccordoCooperazione idAccordoCooperazioneOpenSPCoop = 
  896.                             IDAccordoCooperazioneFactory.getInstance().getIDAccordoFromValues(idAccordoCooperazione.getNome(), 
  897.                                     new IDSoggetto(idAccordoCooperazione.getSoggettoReferente().getTipo(), idAccordoCooperazione.getSoggettoReferente().getNome()),
  898.                                     idAccordoCooperazione.getVersione());
  899.                     idsOpenSPCoop.add(idAccordoCooperazioneOpenSPCoop);
  900.                 }
  901.             }
  902.             else{
  903.                 List<AccordoCooperazione> accordi = this.accordoCooperazionePort.findAll(filter);
  904.                 if(accordi==null || accordi.size()<=0){
  905.                     throw new org.openspcoop2.core.registry.ws.client.accordocooperazione.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  906.                 }
  907.                 for (AccordoCooperazione accordoCooperazione : accordi) {
  908.                     // ProtocolProperties
  909.                     if(ProtocolPropertiesUtilities.isMatch(accordoCooperazione, filtroRicerca.getProtocolPropertiesAccordo())==false){
  910.                         continue;
  911.                     }
  912.                     IDAccordoCooperazione idAccordoCooperazioneOpenSPCoop = 
  913.                             IDAccordoCooperazioneFactory.getInstance().getIDAccordoFromValues(accordoCooperazione.getNome(), 
  914.                                     new IDSoggetto(accordoCooperazione.getSoggettoReferente().getTipo(), accordoCooperazione.getSoggettoReferente().getNome()),
  915.                                     accordoCooperazione.getVersione());
  916.                     idsOpenSPCoop.add(idAccordoCooperazioneOpenSPCoop);
  917.                 }
  918.                 if(idsOpenSPCoop==null || idsOpenSPCoop.size()<=0){
  919.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  920.                 }
  921.             }
  922.             
  923.             return idsOpenSPCoop;
  924.             
  925.         }catch(org.openspcoop2.core.registry.ws.client.accordocooperazione.search.RegistryNotFoundException_Exception e){
  926.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  927.         }catch(Exception e){
  928.             throw new DriverRegistroServiziException(e.getMessage(),e);
  929.         }
  930.     }
  931.     
  932.     
  933.     
  934.     // ACCORDI SERVIZIO PARTE COMUNE
  935.     
  936.     @Override
  937.     public AccordoServizioParteComune getAccordoServizioParteComune(
  938.             IDAccordo idAccordo) throws DriverRegistroServiziException,
  939.             DriverRegistroServiziNotFound {
  940.         try{
  941.             return this.accordoServizioParteComunePort.get(new IdAccordoServizioParteComune(idAccordo));
  942.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception e){
  943.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  944.         }catch(Exception e){
  945.             throw new DriverRegistroServiziException(e.getMessage(),e);
  946.         }
  947.     }
  948.     @Override
  949.     public List<IDAccordo> getAllIdAccordiServizioParteComune(
  950.             FiltroRicercaAccordi filtroRicerca)
  951.             throws DriverRegistroServiziException,
  952.             DriverRegistroServiziNotFound {
  953.         try{
  954.             SearchFilterAccordoServizioParteComune filter = new SearchFilterAccordoServizioParteComune();
  955.             if(filtroRicerca!=null){
  956.                 if(filtroRicerca.getVersione()!=null){
  957.                     filter.setVersione(Long.valueOf(filtroRicerca.getVersione()));
  958.                 }
  959.                 if(filtroRicerca.getTipoSoggettoReferente()!=null || filtroRicerca.getNomeSoggettoReferente()!=null){
  960.                     filter.setSoggettoReferente(new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.IdSoggetto());
  961.                     if(filtroRicerca.getTipoSoggettoReferente()!=null){
  962.                         filter.getSoggettoReferente().setTipo(filtroRicerca.getTipoSoggettoReferente());
  963.                     }
  964.                     if(filtroRicerca.getNomeSoggettoReferente()!=null){
  965.                         filter.getSoggettoReferente().setNome(filtroRicerca.getNomeSoggettoReferente());
  966.                     }
  967.                 }
  968.                 if(filtroRicerca.getNomeAccordo()!=null){
  969.                     filter.setNome(filtroRicerca.getNomeAccordo());
  970.                 }
  971.                 if(filtroRicerca.getMaxDate()!=null){
  972.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  973.                     cal.setTime(filtroRicerca.getMaxDate());
  974.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  975.                 }
  976.                 if(filtroRicerca.getMinDate()!=null){
  977.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  978.                     cal.setTime(filtroRicerca.getMinDate());
  979.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  980.                 }           
  981.                 if(filtroRicerca.getIdAccordoCooperazione()!=null){
  982.                     // NOP
  983.                 }
  984.                 if(filtroRicerca.getServiceBinding()!=null){
  985.                     filter.setServiceBinding(filtroRicerca.getServiceBinding());
  986.                 }
  987.             }
  988.             List<IDAccordo> idsOpenSPCoop = new ArrayList<IDAccordo>();
  989.             if(filtroRicerca==null || filtroRicerca.getProtocolPropertiesAccordo()==null || filtroRicerca.getProtocolPropertiesAccordo().size()<=0){
  990.                 List<IdAccordoServizioParteComune> ids = this.accordoServizioParteComunePort.findAllIds(filter);
  991.                 if(ids==null || ids.size()<=0){
  992.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  993.                 }
  994.                 for (IdAccordoServizioParteComune idAccordoServizioParteComune : ids) {
  995.                     IDSoggetto idSoggetto = null;
  996.                     if(idAccordoServizioParteComune.getSoggettoReferente()!=null){
  997.                         idSoggetto = new IDSoggetto(idAccordoServizioParteComune.getSoggettoReferente().getTipo(), idAccordoServizioParteComune.getSoggettoReferente().getNome());
  998.                     }
  999.                     IDAccordo idAccordoServizioParteComuneOpenSPCoop = 
  1000.                             IDAccordoFactory.getInstance().getIDAccordoFromValues(idAccordoServizioParteComune.getNome(), idSoggetto, idAccordoServizioParteComune.getVersione());
  1001.                     idsOpenSPCoop.add(idAccordoServizioParteComuneOpenSPCoop);
  1002.                 }
  1003.             }
  1004.             else{
  1005.                 List<AccordoServizioParteComune> accordi = this.accordoServizioParteComunePort.findAll(filter);
  1006.                 if(accordi==null || accordi.size()<=0){
  1007.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1008.                 }
  1009.                 for (AccordoServizioParteComune accordoServizioParteComune : accordi) {
  1010.                     // ProtocolProperties
  1011.                     if(ProtocolPropertiesUtilities.isMatch(accordoServizioParteComune, filtroRicerca.getProtocolPropertiesAccordo())==false){
  1012.                         continue;
  1013.                     }
  1014.                     IDSoggetto idSoggetto = null;
  1015.                     if(accordoServizioParteComune.getSoggettoReferente()!=null){
  1016.                         idSoggetto = new IDSoggetto(accordoServizioParteComune.getSoggettoReferente().getTipo(), accordoServizioParteComune.getSoggettoReferente().getNome());
  1017.                     }
  1018.                     IDAccordo idAccordoServizioParteComuneOpenSPCoop = 
  1019.                             IDAccordoFactory.getInstance().getIDAccordoFromValues(accordoServizioParteComune.getNome(), idSoggetto, accordoServizioParteComune.getVersione());
  1020.                     idsOpenSPCoop.add(idAccordoServizioParteComuneOpenSPCoop);
  1021.                 }
  1022.                 if(idsOpenSPCoop==null || idsOpenSPCoop.size()<=0){
  1023.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1024.                 }
  1025.             }
  1026.             
  1027.             return idsOpenSPCoop;
  1028.             
  1029.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception e){
  1030.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1031.         }catch(Exception e){
  1032.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1033.         }
  1034.     }
  1035.     
  1036.     
  1037.     @Override
  1038.     public List<IDPortType> getAllIdPortType(FiltroRicercaPortTypes filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1039.         
  1040.         List<IDPortType> list = new ArrayList<IDPortType>();
  1041.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdPortType", filtroRicerca, filtroRicerca, null, null, null, list);
  1042.         return list;
  1043.         
  1044.     }
  1045.     
  1046.     @Override
  1047.     public List<IDPortTypeAzione> getAllIdAzionePortType(FiltroRicercaOperations filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1048.     
  1049.         List<IDPortTypeAzione> list = new ArrayList<IDPortTypeAzione>();
  1050.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzionePortType", filtroRicerca, null, filtroRicerca, null, null, list);
  1051.         return list;
  1052.         
  1053.     }
  1054.     
  1055.     @Override
  1056.     public List<IDAccordoAzione> getAllIdAzioneAccordo(FiltroRicercaAzioni filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1057.         
  1058.         List<IDAccordoAzione> list = new ArrayList<IDAccordoAzione>();
  1059.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzioneAccordo", filtroRicerca, null, null, filtroRicerca, null, list);
  1060.         return list;
  1061.         
  1062.     }
  1063.     
  1064.     @Override
  1065.     public List<IDResource> getAllIdResource(FiltroRicercaResources filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1066.         
  1067.         List<IDResource> list = new ArrayList<IDResource>();
  1068.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdResource", filtroRicerca, null, null, null, filtroRicerca, list);
  1069.         return list;
  1070.         
  1071.     }
  1072.     
  1073.     @SuppressWarnings("unchecked")
  1074.     public <T> void _fillAllIdAccordiServizioParteComuneEngine(String nomeMetodo, 
  1075.             FiltroRicercaAccordi filtroRicercaBase,
  1076.             FiltroRicercaPortTypes filtroPT, FiltroRicercaOperations filtroOP, FiltroRicercaAzioni filtroAZ,
  1077.             FiltroRicercaResources filtroResource,
  1078.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1079.         
  1080.         try{
  1081.             SearchFilterAccordoServizioParteComune filter = new SearchFilterAccordoServizioParteComune();
  1082.             if(filtroRicercaBase!=null){
  1083.                 if(filtroRicercaBase.getVersione()!=null){
  1084.                     filter.setVersione(Long.valueOf(filtroRicercaBase.getVersione()));
  1085.                 }
  1086.                 if(filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  1087.                     filter.setSoggettoReferente(new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.IdSoggetto());
  1088.                     if(filtroRicercaBase.getTipoSoggettoReferente()!=null){
  1089.                         filter.getSoggettoReferente().setTipo(filtroRicercaBase.getTipoSoggettoReferente());
  1090.                     }
  1091.                     if(filtroRicercaBase.getNomeSoggettoReferente()!=null){
  1092.                         filter.getSoggettoReferente().setNome(filtroRicercaBase.getNomeSoggettoReferente());
  1093.                     }
  1094.                 }
  1095.                 if(filtroRicercaBase.getNomeAccordo()!=null){
  1096.                     filter.setNome(filtroRicercaBase.getNomeAccordo());
  1097.                 }
  1098.                 if(filtroRicercaBase.getMaxDate()!=null){
  1099.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1100.                     cal.setTime(filtroRicercaBase.getMaxDate());
  1101.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1102.                 }
  1103.                 if(filtroRicercaBase.getMinDate()!=null){
  1104.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1105.                     cal.setTime(filtroRicercaBase.getMinDate());
  1106.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1107.                 }           
  1108.                 if(filtroRicercaBase.getIdAccordoCooperazione()!=null){
  1109.                     // NOP
  1110.                 }
  1111.                 if(filtroRicercaBase.getServiceBinding()!=null){
  1112.                     filter.setServiceBinding(filtroRicercaBase.getServiceBinding());
  1113.                 }
  1114.             }
  1115.             
  1116.             List<AccordoServizioParteComune> accordi = this.accordoServizioParteComunePort.findAll(filter);
  1117.             if(accordi==null || accordi.size()<=0){
  1118.                 throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1119.             }
  1120.             for (AccordoServizioParteComune as : accordi) {
  1121.                 
  1122.                 // ProtocolProperties
  1123.                 if(ProtocolPropertiesUtilities.isMatch(as, filtroRicercaBase.getProtocolPropertiesAccordo())==false){
  1124.                     continue;
  1125.                 }
  1126.                 
  1127.                 IDSoggetto idSoggetto = null;
  1128.                 if(as.getSoggettoReferente()!=null){
  1129.                     idSoggetto = new IDSoggetto(as.getSoggettoReferente().getTipo(), as.getSoggettoReferente().getNome());
  1130.                 }
  1131.                 IDAccordo idAccordo = 
  1132.                         IDAccordoFactory.getInstance().getIDAccordoFromValues(as.getNome(), idSoggetto, as.getVersione());
  1133.                 
  1134.                 
  1135.                 if(filtroPT!=null){
  1136.                     for (PortType pt : as.getPortTypeList()) {
  1137.                         // Nome PT
  1138.                         if(filtroPT.getNomePortType()!=null){
  1139.                             if(pt.getNome().equals(filtroPT.getNomePortType()) == false){
  1140.                                 continue;
  1141.                             }
  1142.                         }
  1143.                         // ProtocolProperties PT
  1144.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroPT.getProtocolPropertiesPortType())==false){
  1145.                             continue;
  1146.                         }
  1147.                         
  1148.                         IDPortType idPT = new IDPortType();
  1149.                         idPT.setIdAccordo(idAccordo);
  1150.                         idPT.setNome(pt.getNome());
  1151.                         listReturn.add((T)idPT);
  1152.                     }
  1153.                 }
  1154.                 else if(filtroOP!=null){
  1155.                     for (PortType pt : as.getPortTypeList()) {
  1156.                         
  1157.                         // Nome PT
  1158.                         if(filtroOP.getNomePortType()!=null){
  1159.                             if(pt.getNome().equals(filtroOP.getNomePortType()) == false){
  1160.                                 continue;
  1161.                             }
  1162.                         }
  1163.                         // ProtocolProperties PT
  1164.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesPortType())==false){
  1165.                             continue;
  1166.                         }
  1167.                         
  1168.                         for (Operation op : pt.getAzioneList()) {
  1169.                             
  1170.                             // Nome OP
  1171.                             if(filtroOP.getNomeAzione()!=null){
  1172.                                 if(op.getNome().equals(filtroOP.getNomeAzione()) == false){
  1173.                                     continue;
  1174.                                 }
  1175.                             }
  1176.                             // ProtocolProperties OP
  1177.                             if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesAzione())==false){
  1178.                                 continue;
  1179.                             }
  1180.                         
  1181.                             IDPortTypeAzione idAzione = new IDPortTypeAzione();
  1182.                             IDPortType idPT = new IDPortType();
  1183.                             idPT.setIdAccordo(idAccordo);
  1184.                             idPT.setNome(pt.getNome());
  1185.                             idAzione.setIdPortType(idPT);
  1186.                             idAzione.setNome(op.getNome());
  1187.                             listReturn.add((T)idAzione);
  1188.                         }
  1189.                     }
  1190.                 }
  1191.                 else if(filtroAZ!=null){
  1192.                     for (Azione az : as.getAzioneList()) {
  1193.                         
  1194.                         // Nome AZ
  1195.                         if(filtroAZ.getNomeAzione()!=null){
  1196.                             if(az.getNome().equals(filtroAZ.getNomeAzione()) == false){
  1197.                                 continue;
  1198.                             }
  1199.                         }
  1200.                         // ProtocolProperties PT
  1201.                         if(ProtocolPropertiesUtilities.isMatch(az, filtroAZ.getProtocolPropertiesAzione())==false){
  1202.                             continue;
  1203.                         }
  1204.                         
  1205.                         IDAccordoAzione idAzione = new IDAccordoAzione();
  1206.                         idAzione.setIdAccordo(idAccordo);
  1207.                         idAzione.setNome(az.getNome());
  1208.                         listReturn.add((T)idAzione);
  1209.                     }
  1210.                 }
  1211.                 else if(filtroResource!=null){
  1212.                     for (Resource resource : as.getResourceList()) {
  1213.                         // Nome Risorsa
  1214.                         if(filtroResource.getResourceName()!=null){
  1215.                             if(resource.getNome().equals(filtroResource.getResourceName()) == false){
  1216.                                 continue;
  1217.                             }
  1218.                         }
  1219.                         // ProtocolProperties PT
  1220.                         if(ProtocolPropertiesUtilities.isMatch(resource, filtroResource.getProtocolPropertiesResources())==false){
  1221.                             continue;
  1222.                         }
  1223.                         
  1224.                         IDResource idResource = new IDResource();
  1225.                         idResource.setIdAccordo(idAccordo);
  1226.                         idResource.setNome(resource.getNome());
  1227.                         listReturn.add((T)idResource);
  1228.                     }
  1229.                 }
  1230.                 
  1231.             }
  1232.             
  1233.             if(listReturn==null || listReturn.size()<=0){
  1234.                 throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1235.             }
  1236.             
  1237.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartecomune.search.RegistryNotFoundException_Exception e){
  1238.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1239.         }catch(Exception e){
  1240.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1241.         }
  1242.         
  1243.     }
  1244.     
  1245.     @Override
  1246.     public Documento getAllegato(IDAccordo idAccordo, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1247.         throw new DriverRegistroServiziException("Not Implemented");
  1248.     }
  1249.     @Override
  1250.     public Documento getSpecificaSemiformale(IDAccordo idAccordo, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1251.         throw new DriverRegistroServiziException("Not Implemented");
  1252.     }
  1253.     
  1254.     
  1255.     
  1256.     
  1257.     // ACCORDI SERVIZIO PARTE SPECIFICA
  1258.     
  1259.     @Override
  1260.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(
  1261.             IDServizio idServizio) throws DriverRegistroServiziException,
  1262.             DriverRegistroServiziNotFound {
  1263.         try{
  1264.             SearchFilterAccordoServizioParteSpecifica filter = new SearchFilterAccordoServizioParteSpecifica();
  1265.             filter.setTipo(idServizio.getTipo());
  1266.             filter.setNome(idServizio.getNome());
  1267.             filter.setVersione(Long.valueOf(idServizio.getVersione()));
  1268.             if(idServizio.getSoggettoErogatore()!=null){
  1269.                 filter.setTipoSoggettoErogatore(idServizio.getSoggettoErogatore().getTipo());
  1270.                 filter.setNomeSoggettoErogatore(idServizio.getSoggettoErogatore().getNome());
  1271.             }
  1272.             return this.accordoServizioParteSpecificaPort.find(filter);
  1273.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception e){
  1274.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1275.         }catch(Exception e){
  1276.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1277.         }
  1278.     }
  1279.     @Override
  1280.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(
  1281.             IDSoggetto idSoggetto, IDAccordo idAccordoServizioParteComune)
  1282.             throws DriverRegistroServiziException,
  1283.             DriverRegistroServiziNotFound {
  1284.         try{
  1285.             SearchFilterAccordoServizioParteSpecifica filter = new SearchFilterAccordoServizioParteSpecifica();
  1286.             filter.setAccordoServizioParteComune(IDAccordoFactory.getInstance().getUriFromIDAccordo(idAccordoServizioParteComune));
  1287.             if(idSoggetto!=null){
  1288.                 filter.setTipoSoggettoErogatore(idSoggetto.getTipo());
  1289.                 filter.setNomeSoggettoErogatore(idSoggetto.getNome());
  1290.                 filter.setTipologiaServizio(TipologiaServizio.CORRELATO);
  1291.             }
  1292.             return this.accordoServizioParteSpecificaPort.find(filter);
  1293.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception e){
  1294.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1295.         }catch(Exception e){
  1296.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1297.         }
  1298.     }
  1299.     
  1300.     @Override
  1301.     public List<IDServizio> getAllIdServizi(FiltroRicercaServizi filtroRicerca)
  1302.             throws DriverRegistroServiziException,
  1303.             DriverRegistroServiziNotFound {
  1304.         try{
  1305.             SearchFilterAccordoServizioParteSpecifica filter = new SearchFilterAccordoServizioParteSpecifica();
  1306.             if(filtroRicerca!=null){
  1307.                 if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  1308.                     filter.setAccordoServizioParteComune(IDAccordoFactory.getInstance().getUriFromIDAccordo(filtroRicerca.getIdAccordoServizioParteComune()));
  1309.                 }
  1310.                 if(filtroRicerca.getNome()!=null || filtroRicerca.getTipo()!=null || filtroRicerca.getVersione()!=null ||
  1311.                         filtroRicerca.getPortType()!=null ||
  1312.                         filtroRicerca.getNomeSoggettoErogatore()!=null ||
  1313.                         filtroRicerca.getTipoSoggettoErogatore()!=null ||
  1314.                         filtroRicerca.getTipologia()!=null){
  1315.                     filter.setTipo(filtroRicerca.getTipo());
  1316.                     filter.setNome(filtroRicerca.getNome());
  1317.                     filter.setVersione(Long.valueOf(filtroRicerca.getVersione()));
  1318.                     filter.setPortType(filtroRicerca.getPortType());
  1319.                     filter.setTipoSoggettoErogatore(filtroRicerca.getTipoSoggettoErogatore());
  1320.                     filter.setNomeSoggettoErogatore(filtroRicerca.getNomeSoggettoErogatore());
  1321.                     if(filtroRicerca.getTipologia()!=null){
  1322.                         filter.setTipologiaServizio(TipologiaServizio.toEnumConstant(filtroRicerca.getTipologia().getValue()));
  1323.                     }
  1324.                 }
  1325.                 if(filtroRicerca.getMaxDate()!=null){
  1326.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1327.                     cal.setTime(filtroRicerca.getMaxDate());
  1328.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1329.                 }
  1330.                 if(filtroRicerca.getMinDate()!=null){
  1331.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1332.                     cal.setTime(filtroRicerca.getMinDate());
  1333.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1334.                 }
  1335.                 // Filtro By Tipo e/o Nome Soggetto Fruitore
  1336.                 if(filtroRicerca.getTipoSoggettoFruitore()!=null || filtroRicerca.getNomeSoggettoFruitore()!=null){
  1337.                     throw new DriverRegistroServiziException("Not Implemented");
  1338.                 }
  1339.             }
  1340.             List<IDServizio> idsOpenSPCoop = new ArrayList<IDServizio>();
  1341.             if(filtroRicerca==null || filtroRicerca.getProtocolProperties()==null || filtroRicerca.getProtocolProperties().size()<=0){
  1342.                 List<IdAccordoServizioParteSpecifica> ids = this.accordoServizioParteSpecificaPort.findAllIds(filter);
  1343.                 if(ids==null || ids.size()<=0){
  1344.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1345.                 }
  1346.                 for (IdAccordoServizioParteSpecifica idAccordoServizioParteSpecifica : ids) {
  1347.                     AccordoServizioParteSpecifica asps = this.accordoServizioParteSpecificaPort.get(idAccordoServizioParteSpecifica);
  1348.                     IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(asps.getTipo(), asps.getNome(), 
  1349.                             new IDSoggetto(asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore()), 
  1350.                             asps.getVersione()); 
  1351.                     idsOpenSPCoop.add(idServizio);
  1352.                 }
  1353.             }
  1354.             else{
  1355.                 List<AccordoServizioParteSpecifica> accordi = this.accordoServizioParteSpecificaPort.findAll(filter);
  1356.                 if(accordi==null || accordi.size()<=0){
  1357.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1358.                 }
  1359.                 for (AccordoServizioParteSpecifica asps : accordi) {
  1360.                     
  1361.                     // ProtocolProperties
  1362.                     if(ProtocolPropertiesUtilities.isMatch(asps, filtroRicerca.getProtocolProperties())==false){
  1363.                         continue;
  1364.                     }
  1365.                     
  1366.                     IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(asps.getTipo(), asps.getNome(), 
  1367.                             new IDSoggetto(asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore()), 
  1368.                             asps.getVersione()); 
  1369.                     idsOpenSPCoop.add(idServizio);
  1370.                 }
  1371.                 if(idsOpenSPCoop==null || idsOpenSPCoop.size()<=0){
  1372.                     throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1373.                 }
  1374.             }
  1375.             
  1376.             return idsOpenSPCoop;
  1377.             
  1378.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception e){
  1379.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1380.         }catch(Exception e){
  1381.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1382.         }
  1383.     }

  1385.     @Override
  1386.     public List<IDFruizione> getAllIdFruizioniServizio(
  1387.             FiltroRicercaFruizioniServizio filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1388.         
  1389.         try{
  1390.             SearchFilterAccordoServizioParteSpecifica filter = new SearchFilterAccordoServizioParteSpecifica();
  1391.             if(filtroRicerca!=null){
  1392.                 if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  1393.                     filter.setAccordoServizioParteComune(IDAccordoFactory.getInstance().getUriFromIDAccordo(filtroRicerca.getIdAccordoServizioParteComune()));
  1394.                 }
  1395.                 if(filtroRicerca.getNome()!=null || filtroRicerca.getTipo()!=null || filtroRicerca.getVersione()!=null ||
  1396.                         filtroRicerca.getPortType()!=null ||
  1397.                         filtroRicerca.getNomeSoggettoErogatore()!=null ||
  1398.                         filtroRicerca.getTipoSoggettoErogatore()!=null ||
  1399.                         filtroRicerca.getTipologia()!=null){
  1400.                     filter.setTipo(filtroRicerca.getTipo());
  1401.                     filter.setNome(filtroRicerca.getNome());
  1402.                     filter.setVersione(Long.valueOf(filtroRicerca.getVersione()));
  1403.                     filter.setPortType(filtroRicerca.getPortType());
  1404.                     filter.setTipoSoggettoErogatore(filtroRicerca.getTipoSoggettoErogatore());
  1405.                     filter.setNomeSoggettoErogatore(filtroRicerca.getNomeSoggettoErogatore());
  1406.                     if(filtroRicerca.getTipologia()!=null){
  1407.                         filter.setTipologiaServizio(TipologiaServizio.toEnumConstant(filtroRicerca.getTipologia().getValue()));
  1408.                     }
  1409.                 }
  1410.                 if(filtroRicerca.getMaxDate()!=null){
  1411.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1412.                     cal.setTime(filtroRicerca.getMaxDate());
  1413.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1414.                 }
  1415.                 if(filtroRicerca.getMinDate()!=null){
  1416.                     GregorianCalendar cal = (GregorianCalendar) Calendar.getInstance();
  1417.                     cal.setTime(filtroRicerca.getMinDate());
  1418.                     filter.setOraRegistrazioneMax(this.dataTypeFactory.newXMLGregorianCalendar(cal));
  1419.                 }   
  1420.             }
  1421.             List<IDFruizione> idsOpenSPCoop = new ArrayList<IDFruizione>();
  1422.             
  1423.             List<AccordoServizioParteSpecifica> accordi = this.accordoServizioParteSpecificaPort.findAll(filter);
  1424.             if(accordi==null || accordi.size()<=0){
  1425.                 throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1426.             }
  1427.             for (AccordoServizioParteSpecifica asps : accordi) {
  1428.                 
  1429.                 // ProtocolProperties
  1430.                 if(ProtocolPropertiesUtilities.isMatch(asps, filtroRicerca.getProtocolProperties())==false){
  1431.                     continue;
  1432.                 }
  1433.                 
  1434.                 IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(asps.getTipo(), asps.getNome(), 
  1435.                         new IDSoggetto(asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore()), 
  1436.                         asps.getVersione()); 
  1437.                 
  1438.                 for (Fruitore fruitore : asps.getFruitoreList()) {
  1439.                     
  1440.                     // Tipo
  1441.                     if(filtroRicerca.getTipoSoggettoFruitore()!=null){
  1442.                         if(fruitore.getTipo().equals(filtroRicerca.getTipoSoggettoFruitore()) == false){
  1443.                             continue;
  1444.                         }
  1445.                     }
  1446.                     // Nome
  1447.                     if(filtroRicerca.getNomeSoggettoFruitore()!=null){
  1448.                         if(fruitore.getNome().equals(filtroRicerca.getNomeSoggettoFruitore()) == false){
  1449.                             continue;
  1450.                         }
  1451.                     }
  1452.                     // ProtocolProperties
  1453.                     if(ProtocolPropertiesUtilities.isMatch(fruitore, filtroRicerca.getProtocolPropertiesFruizione())==false){
  1454.                         continue;
  1455.                     }
  1456.                     
  1457.                     IDFruizione idFruizione = new IDFruizione();
  1458.                     idFruizione.setIdServizio(idServizio);
  1459.                     idFruizione.setIdFruitore(new IDSoggetto(fruitore.getTipo(), fruitore.getNome()));
  1460.                     idsOpenSPCoop.add(idFruizione);
  1461.                 }

  1463.             }
  1464.             if(idsOpenSPCoop==null || idsOpenSPCoop.size()<=0){
  1465.                 throw new org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception("La ricerca non ha trovato accordi");
  1466.             }
  1467.             
  1468.             return idsOpenSPCoop;
  1469.             
  1470.         }catch(org.openspcoop2.core.registry.ws.client.accordoserviziopartespecifica.search.RegistryNotFoundException_Exception e){
  1471.             throw new DriverRegistroServiziNotFound(e.getMessage(),e);
  1472.         }catch(Exception e){
  1473.             throw new DriverRegistroServiziException(e.getMessage(),e);
  1474.         }
  1475.         
  1476.     }

  1478.     
  1479.     @Override
  1480.     public Documento getAllegato(IDServizio idASPS, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1481.         throw new DriverRegistroServiziException("Not Implemented");
  1482.     }
  1483.     @Override
  1484.     public Documento getSpecificaSemiformale(IDServizio idASPS, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1485.         throw new DriverRegistroServiziException("Not Implemented");
  1486.     }
  1487.     @Override
  1488.     public Documento getSpecificaSicurezza(IDServizio idASPS, TipiDocumentoSicurezza tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1489.         throw new DriverRegistroServiziException("Not Implemented");
  1490.     }
  1491.     @Override
  1492.     public Documento getSpecificaLivelloServizio(IDServizio idASPS, TipiDocumentoLivelloServizio tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1493.         throw new DriverRegistroServiziException("Not Implemented");
  1494.     }
  1495. }
Created with JaCoCo 0.8.8.202204050719