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



  23. package org.openspcoop2.protocol.registry;

  25. import java.io.Serializable;
  26. import java.lang.reflect.Method;
  27. import java.sql.Connection;
  28. import java.util.ArrayList;
  29. import java.util.HashMap;
  30. import java.util.List;
  31. import java.util.Map;
  32. import java.util.Set;

  34. import org.openspcoop2.core.byok.IDriverBYOK;
  35. import org.openspcoop2.core.byok.IDriverBYOKConfig;
  36. import org.openspcoop2.core.config.AccessoRegistro;
  37. import org.openspcoop2.core.config.AccessoRegistroRegistro;
  38. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  39. import org.openspcoop2.core.id.IDAccordo;
  40. import org.openspcoop2.core.id.IDAccordoAzione;
  41. import org.openspcoop2.core.id.IDAccordoCooperazione;
  42. import org.openspcoop2.core.id.IDFruizione;
  43. import org.openspcoop2.core.id.IDGruppo;
  44. import org.openspcoop2.core.id.IDPortType;
  45. import org.openspcoop2.core.id.IDPortTypeAzione;
  46. import org.openspcoop2.core.id.IDResource;
  47. import org.openspcoop2.core.id.IDRuolo;
  48. import org.openspcoop2.core.id.IDScope;
  49. import org.openspcoop2.core.id.IDServizio;
  50. import org.openspcoop2.core.id.IDSoggetto;
  51. import org.openspcoop2.core.registry.AccordoCooperazione;
  52. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  53. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  54. import org.openspcoop2.core.registry.Azione;
  55. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  56. import org.openspcoop2.core.registry.Documento;
  57. import org.openspcoop2.core.registry.Fruitore;
  58. import org.openspcoop2.core.registry.Gruppo;
  59. import org.openspcoop2.core.registry.Operation;
  60. import org.openspcoop2.core.registry.PortType;
  61. import org.openspcoop2.core.registry.PortaDominio;
  62. import org.openspcoop2.core.registry.Resource;
  63. import org.openspcoop2.core.registry.Ruolo;
  64. import org.openspcoop2.core.registry.Scope;
  65. import org.openspcoop2.core.registry.Soggetto;
  66. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  67. import org.openspcoop2.core.registry.constants.CredenzialeTipo;
  68. import org.openspcoop2.core.registry.constants.FormatoSpecifica;
  69. import org.openspcoop2.core.registry.constants.ProfiloCollaborazione;
  70. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  71. import org.openspcoop2.core.registry.constants.StatiAccordo;
  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.DriverRegistroServiziException;
  77. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  78. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  79. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  80. import org.openspcoop2.core.registry.driver.FiltroRicercaAzioni;
  81. import org.openspcoop2.core.registry.driver.FiltroRicercaFruizioniServizio;
  82. import org.openspcoop2.core.registry.driver.FiltroRicercaGruppi;
  83. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  84. import org.openspcoop2.core.registry.driver.FiltroRicercaPortTypes;
  85. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  86. import org.openspcoop2.core.registry.driver.FiltroRicercaRuoli;
  87. import org.openspcoop2.core.registry.driver.FiltroRicercaScope;
  88. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  89. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  90. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  91. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  92. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  93. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  94. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  95. import org.openspcoop2.core.registry.driver.uddi.DriverRegistroServiziUDDI;
  96. import org.openspcoop2.core.registry.driver.utils.DriverRegistroServiziWSInitUtilities;
  97. import org.openspcoop2.core.registry.driver.web.DriverRegistroServiziWEB;
  98. import org.openspcoop2.core.registry.driver.xml.DriverRegistroServiziXML;
  99. import org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper;
  100. import org.openspcoop2.core.registry.wsdl.AccordoServizioWrapperUtilities;
  101. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  102. import org.openspcoop2.protocol.sdk.constants.InformationApiSource;
  103. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  104. import org.openspcoop2.utils.LoggerWrapperFactory;
  105. import org.openspcoop2.utils.SemaphoreLock;
  106. import org.openspcoop2.utils.UtilsException;
  107. import org.openspcoop2.utils.UtilsRuntimeException;
  108. import org.openspcoop2.utils.cache.Cache;
  109. import org.openspcoop2.utils.cache.CacheAlgorithm;
  110. import org.openspcoop2.utils.cache.CacheResponse;
  111. import org.openspcoop2.utils.cache.CacheType;
  112. import org.openspcoop2.utils.certificate.ArchiveLoader;
  113. import org.openspcoop2.utils.certificate.ArchiveType;
  114. import org.openspcoop2.utils.certificate.CertificateInfo;
  115. import org.openspcoop2.utils.crypt.CryptConfig;
  116. import org.openspcoop2.utils.rest.api.ApiOperation;
  117. import org.slf4j.Logger;




  122. /**
  123.  * Classe utilizzata per effettuare query a registri di servizio di openspcoop.
  124.  * E' possibile indicare piu' di una sorgente e/o una cache
  125.  *
  126.  *
  127.  * @author Poli Andrea (apoli@link.it)
  128.  * @author $Author$
  129.  * @version $Rev$, $Date$
  130.  */

  132. public class RegistroServizi  {

  134.     /** Fonti su cui effettuare le query:
  135.      * - CACHE
  136.      * - Registri deployati
  137.      */
  138.     private Cache cache = null;
  139.     private java.util.Map<String,IDriverRegistroServiziGet> driverRegistroServizi;

  141.     /** Indicazione se usare la connessione della PdD */
  142.     private Map<String, String> mappingNomeRegistroToTipiDatabase = new HashMap<>();
  143.     private Map<String, Boolean> mappingNomeRegistroToUseConnectionPdD = new HashMap<String, Boolean>();
  144.     
  145.     /** Eventuale RegistriXML da cui prelevare le definizioni dei connettori */
  146.     private List<DriverRegistroServiziXML> registriXML;

  148.     /** Logger utilizzato per debug. */
  149.     private Logger log = null;

  151.     /** Indicazione sulla gestione della gerarchia dei registri */
  152.     private boolean raggiungibilitaTotale = false;
  153.     
  154.     /** Indicazione se la porta di dominio deve processare gli accordi di servizio, i servizi e i fruitori ancora in stato di bozza */
  155.     private boolean readObjectStatoBozza = false;
  156. //  public boolean isReadObjectStatoBozza() {
  157. //      return this.readObjectStatoBozza;
  158. //  }

  160.     // Factory
  161.     private IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();
  162.     private IDAccordoCooperazioneFactory idAccordoCooperazioneFactory = IDAccordoCooperazioneFactory.getInstance();

  164.     private static String notFoundClassName = DriverRegistroServiziNotFound.class.getName()+"";
  165.     private static String excClassName = org.openspcoop2.core.registry.driver.DriverRegistroServiziException.class.getName() + "";
  166.         
  167.     
  168.     /* --------------- Cache --------------------*/
  169.     public boolean isCacheAbilitata(){
  170.         return this.cache!=null;
  171.     }
  172.     public void resetCache() throws DriverRegistroServiziException{
  173.         if(this.cache!=null){
  174.             try{
  175.                 this.cache.clear();
  176.             }catch(Exception e){
  177.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  178.             }
  179.         }
  180.     }
  181.     public String printStatsCache(String separator) throws DriverRegistroServiziException{
  182.         if(this.cache!=null){
  183.             try{
  184.                 return this.cache.printStats(separator);
  185.             }catch(Exception e){
  186.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  187.             }
  188.         }else{
  189.             throw new DriverRegistroServiziException("Cache non abilitata");
  190.         }
  191.     }
  192.     public void abilitaCache() throws DriverRegistroServiziException{
  193.         if(this.cache!=null)
  194.             throw new DriverRegistroServiziException("Cache gia' abilitata");
  195.         else{
  196.             try{
  197.                 this.cache = new Cache(CacheType.JCS, CostantiRegistroServizi.CACHE_REGISTRO_SERVIZI);  // lascio JCS come default abilitato via jmx
  198.                 this.cache.build();
  199.             }catch(Exception e){
  200.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  201.             }
  202.         }
  203.     }
  204.     public void abilitaCache(Long dimensioneCache,Boolean algoritmoCacheLRU,Long itemIdleTime,Long itemLifeSecond, CryptConfig cryptConfigSoggetti) throws DriverRegistroServiziException{
  205.         if(this.cache!=null)
  206.             throw new DriverRegistroServiziException("Cache gia' abilitata");
  207.         else{
  208.             try{
  209.                 org.openspcoop2.core.config.Cache configurazioneCache = new org.openspcoop2.core.config.Cache();
  210.                 if(dimensioneCache!=null)
  211.                     configurazioneCache.setDimensione(dimensioneCache+"");
  212.                 if(algoritmoCacheLRU!=null){
  213.                     if(algoritmoCacheLRU)
  214.                         configurazioneCache.setAlgoritmo(CostantiConfigurazione.CACHE_LRU);
  215.                     else
  216.                         configurazioneCache.setAlgoritmo(CostantiConfigurazione.CACHE_MRU);
  217.                 }
  218.                 if(itemIdleTime!=null){
  219.                     configurazioneCache.setItemIdleTime(itemIdleTime+"");
  220.                 }
  221.                 if(itemLifeSecond!=null){
  222.                     configurazioneCache.setItemLifeSecond(itemLifeSecond+"");
  223.                 }
  224.                 initCacheRegistriServizi(CacheType.JCS, configurazioneCache,null,false, cryptConfigSoggetti);  // lascio JCS come default abilitato via jmx
  225.             }catch(Exception e){
  226.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  227.             }
  228.         }
  229.     }
  230.     public void disabilitaCache() throws DriverRegistroServiziException{
  231.         if(this.cache==null)
  232.             throw new DriverRegistroServiziException("Cache gia' disabilitata");
  233.         else{
  234.             try{
  235.                 this.cache.clear();
  236.                 this.cache = null;
  237.             }catch(Exception e){
  238.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  239.             }
  240.         }
  241.     }
  242.     public String listKeysCache(String separator) throws DriverRegistroServiziException{
  243.         if(this.cache!=null){
  244.             try{
  245.                 return this.cache.printKeys(separator);
  246.             }catch(Exception e){
  247.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  248.             }
  249.         }else{
  250.             throw new DriverRegistroServiziException("Cache non abilitata");
  251.         }
  252.     }
  253.     public List<String> keysCache() throws DriverRegistroServiziException{
  254.         if(this.cache!=null){
  255.             try{
  256.                 return this.cache.keys();
  257.             }catch(Exception e){
  258.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  259.             }
  260.         }else{
  261.             throw new DriverRegistroServiziException("Cache non abilitata");
  262.         }
  263.     }
  264.     public String getObjectCache(String key) throws DriverRegistroServiziException{
  265.         if(this.cache!=null){
  266.             try{
  267.                 Object o = this.cache.get(key);
  268.                 if(o!=null){
  269.                     return o.toString();
  270.                 }else{
  271.                     return "oggetto con chiave ["+key+"] non presente";
  272.                 }
  273.             }catch(Exception e){
  274.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  275.             }
  276.         }else{
  277.             throw new DriverRegistroServiziException("Cache non abilitata");
  278.         }
  279.     }
  280.     public Object getRawObjectCache(String key) throws DriverRegistroServiziException{
  281.         if(this.cache!=null){
  282.             try{
  283.                 Object o = this.cache.get(key);
  284.                 if(o!=null){
  285.                     if(o instanceof CacheResponse) {
  286.                         CacheResponse cR = (CacheResponse) o;
  287.                         if(cR.getObject()!=null) {
  288.                             o = cR.getObject();
  289.                         }
  290.                         else if(cR.getException()!=null) {
  291.                             o = cR.getException();
  292.                         }
  293.                     }
  294.                     return o;
  295.                 }else{
  296.                     return null;
  297.                 }
  298.             }catch(Exception e){
  299.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  300.             }
  301.         }else{
  302.             throw new DriverRegistroServiziException("Cache non abilitata");
  303.         }
  304.     }
  305.     public void removeObjectCache(String key) throws DriverRegistroServiziException{
  306.         if(this.cache!=null){
  307.             try{
  308.                 this.cache.remove(key);
  309.             }catch(Exception e){
  310.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  311.             }
  312.         }else{
  313.             throw new DriverRegistroServiziException("Cache non abilitata");
  314.         }
  315.     }



  319.     /*   -------------- Costruttore -----------------  */ 

  321.     /**
  322.      * Si occupa di inizializzare l'engine che permette di effettuare
  323.      * query al registro dei servizi.
  324.      * L'engine inizializzato sara' diverso a seconda del <var>tipo</var> di registro :
  325.      * <ul>
  326.      * <li> {@link DriverRegistroServiziUDDI}, interroga un registro dei servizi UDDI.
  327.      * <li> {@link DriverRegistroServiziXML}, interroga un registro dei servizi realizzato tramite un file xml.
  328.      * <li> {@link DriverRegistroServiziWEB}, interroga un registro dei servizi realizzato come un WEB Server.
  329.      * <li> {@link DriverRegistroServiziDB}, interroga un registro dei servizi realizzato come un Database relazionale.
  330.      * </ul>
  331.      *
  332.      * @param accessoRegistro Informazioni per accedere al registro Servizi.
  333.      */
  334.     public RegistroServizi(AccessoRegistro accessoRegistro,Logger alog,
  335.             Logger alogConsole,boolean raggiungibilitaTotale, boolean readObjectStatoBozza, 
  336.             String jndiNameDatasourcePdD, boolean useOp2UtilsDatasource, boolean bindJMX, 
  337.             boolean prefillCache, CryptConfig cryptConfigSoggetti,
  338.             CacheType cacheType, IDriverBYOK driverBYOK)throws DriverRegistroServiziException{

  340.         if(alog!=null)
  341.             this.log = alog;
  342.         else
  343.             this.log = LoggerWrapperFactory.getLogger(RegistroServizi.class);
  344.         if(this.log==null) {
  345.             throw new UtilsRuntimeException("Logger unavailable");
  346.         }
  347.         
  348.         try{ 
  349.             this.driverRegistroServizi = new java.util.HashMap<>();
  350.             this.registriXML = new ArrayList<>();

  352.             this.raggiungibilitaTotale = raggiungibilitaTotale;

  354.             this.readObjectStatoBozza = readObjectStatoBozza;
  355.             
  356.             for(int i=0; i<accessoRegistro.sizeRegistroList(); i++){    

  358.                 IDriverRegistroServiziGet driver = null;
  359.                 AccessoRegistroRegistro registro = accessoRegistro.getRegistro(i);
  360.                 String nomeRegistro = registro.getNome();
  361.                 if(nomeRegistro == null)
  362.                     nomeRegistro = "Registro"+i+registro.getTipo();


  365.                 String path = registro.getLocation();
  366.                 if(CostantiConfigurazione.REGISTRO_XML.equals(registro.getTipo())){
  367.                     //if( (path.startsWith("http://")==false) && (path.startsWith("file://")==false) ){
  368.                     while (path.indexOf("${")!=-1){
  369.                         int indexStart = path.indexOf("${");
  370.                         int indexEnd = path.indexOf("}");
  371.                         if(indexEnd==-1){
  372.                             this.log.error("errore durante l'interpretazione del path ["+path+"]: ${ utilizzato senza la rispettiva chiusura }");
  373.                             continue;
  374.                         }
  375.                         String nameSystemProperty = path.substring(indexStart+"${".length(),indexEnd);
  376.                         String valueSystemProperty = System.getProperty(nameSystemProperty);
  377.                         if(valueSystemProperty==null){
  378.                             this.log.error("errore durante l'interpretazione del path ["+path+"]: variabile di sistema ${"+nameSystemProperty+"} non esistente");
  379.                             continue;
  380.                         }
  381.                         path = path.replace("${"+nameSystemProperty+"}", valueSystemProperty);
  382.                     }
  383.                     //}
  384.                 }


  387.                 String msg = "carico registro "+nomeRegistro+" di tipo["+registro.getTipo()+"]   location["+path+"]";
  388.                 this.log.info(msg);
  389.                 if(alogConsole!=null)
  390.                     alogConsole.info(msg);


  393.                 // inizializzazione XML
  394.                 if(CostantiConfigurazione.REGISTRO_XML.equals(registro.getTipo())){

  396.                     driver = new DriverRegistroServiziXML(path,this.log);
  397.                     if( ((DriverRegistroServiziXML)driver).create ){
  398.                         this.driverRegistroServizi.put(nomeRegistro,driver);
  399.                         this.registriXML.add((DriverRegistroServiziXML)driver);
  400.                     }else{
  401.                         msg ="Riscontrato errore durante l'inizializzazione del registro di tipo "+
  402.                         registro.getTipo()+" con location: "+registro.getLocation();
  403.                         this.log.error(msg);
  404.                         if(alogConsole!=null)
  405.                             alogConsole.info(msg);
  406.                     }
  407.                 } 

  409.                 // inizializzazione UDDI
  410.                 else if(CostantiConfigurazione.REGISTRO_UDDI.equals(registro.getTipo())){
  411.                     if( (registro.getUser()!=null) && (registro.getPassword()!=null))
  412.                         driver = new DriverRegistroServiziUDDI(path,
  413.                                 registro.getUser(),
  414.                                 registro.getPassword(),this.log);
  415.                     else
  416.                         driver = new DriverRegistroServiziUDDI(registro.getLocation(),this.log);
  417.                     if( ((DriverRegistroServiziUDDI)driver).create ){
  418.                         this.driverRegistroServizi.put(nomeRegistro,driver);
  419.                     }else{
  420.                         msg = "Riscontrato errore durante l'inizializzazione del registro di tipo "+
  421.                         registro.getTipo()+" con location: "+registro.getLocation();
  422.                         this.log.error(msg);
  423.                         if(alogConsole!=null)
  424.                             alogConsole.info(msg);
  425.                     }
  426.                 }

  428.                 // inizializzazione WEB
  429.                 else if(CostantiConfigurazione.REGISTRO_WEB.equals(registro.getTipo())){
  430.                     driver = new DriverRegistroServiziWEB(path,this.log);
  431.                     if( ((DriverRegistroServiziWEB)driver).create ){
  432.                         this.driverRegistroServizi.put(nomeRegistro,driver);
  433.                     }else{
  434.                         msg ="Riscontrato errore durante l'inizializzazione del registro di tipo "+
  435.                         registro.getTipo()+" con location: "+registro.getLocation();
  436.                         this.log.error(msg);
  437.                         if(alogConsole!=null)
  438.                             alogConsole.info(msg);
  439.                     }
  440.                 }

  442.                 // inizializzazione DB
  443.                 else if(CostantiConfigurazione.REGISTRO_DB.equals(registro.getTipo())){
  444.                     driver = new DriverRegistroServiziDB(path,null,this.log,registro.getTipoDatabase(),
  445.                             useOp2UtilsDatasource,bindJMX);
  446.                     this.mappingNomeRegistroToTipiDatabase.put(nomeRegistro, registro.getTipoDatabase());
  447.                     this.mappingNomeRegistroToUseConnectionPdD.put(nomeRegistro, path.equals(jndiNameDatasourcePdD));
  448.                     if( ((DriverRegistroServiziDB)driver).create ){
  449.                         this.driverRegistroServizi.put(nomeRegistro,driver);
  450.                     }else{
  451.                         msg ="Riscontrato errore durante l'inizializzazione del registro di tipo "+
  452.                         registro.getTipo()+" con location: "+registro.getLocation();
  453.                         this.log.error(msg);
  454.                         if(alogConsole!=null)
  455.                             alogConsole.info(msg);
  456.                     }
  457.                     
  458.                     if(driver instanceof IDriverBYOKConfig) {
  459.                         IDriverBYOKConfig c = (IDriverBYOKConfig) driver;
  460.                         c.initialize(driverBYOK, false, true);
  461.                     }
  462.                 }

  464.                 // inizializzazione WS
  465.                 else if(CostantiConfigurazione.REGISTRO_WS.equals(registro.getTipo())){
  466.                     try{
  467.                         driver = DriverRegistroServiziWSInitUtilities.newInstance(registro.getLocation(), 
  468.                                 registro.getUser(),
  469.                                 registro.getPassword(), this.log);
  470.                         this.driverRegistroServizi.put(nomeRegistro,driver);
  471.                     }catch(Throwable e){
  472.                         msg ="Riscontrato errore durante l'inizializzazione del registro di tipo "+
  473.                                 registro.getTipo()+" con location: "+registro.getLocation();
  474.                         this.log.error(msg);
  475.                         if(alogConsole!=null)
  476.                             alogConsole.info(msg);
  477.                     }
  478.                 }

  480.                 // tipo di registro non conosciuto
  481.                 else{
  482.                     msg = "Riscontrato errore durante l'inizializzazione del registro di tipo sconosciuto "+
  483.                     registro.getTipo()+" con location: "+registro.getLocation();
  484.                     this.log.error(msg);
  485.                     if(alogConsole!=null)
  486.                         alogConsole.info(msg);
  487.                 }
  488.             }


  491.             // Inizializzazione della Cache
  492.             if(accessoRegistro.getCache()!=null){
  493.                 initCacheRegistriServizi(cacheType, accessoRegistro.getCache(),alogConsole,prefillCache, cryptConfigSoggetti);
  494.             }

  496.         }catch(Exception e){
  497.             String msg = "Riscontrato errore durante l'inizializzazione del registro: "+e.getMessage();
  498.             this.log.error(msg);
  499.             if(alogConsole!=null)
  500.                 alogConsole.info(msg);
  501.             throw new DriverRegistroServiziException("Riscontrato errore durante l'inizializzazione del registro: "+e.getMessage());
  502.         }

  504.         if( this.driverRegistroServizi.size() == 0 )
  505.             throw new DriverRegistroServiziException("Non e' stato possibile inizializzare nessuna sorgente di lettura per un Registro dei Servizi");
  506.     }
  507.     
  508.     // Costruttore per implementare classe org.openspcoop2.protocol.basic.registry.RegistryReader
  509.     public RegistroServizi(IDriverRegistroServiziGet driverRegistroServiziGET, Logger alog, boolean readObjectStatoBozza, String tipoRegistro)throws DriverRegistroServiziException{

  511.         if(alog!=null)
  512.             this.log = alog;
  513.         else
  514.             this.log = LoggerWrapperFactory.getLogger(RegistroServizi.class);
  515.         if(this.log==null) {
  516.             throw new UtilsRuntimeException("Logger unavailable");
  517.         }
  518.         
  519.         try{ 
  520.             this.driverRegistroServizi = new java.util.HashMap<>();
  521.             this.registriXML = new ArrayList<>();

  523.             this.raggiungibilitaTotale = true;

  525.             this.readObjectStatoBozza = readObjectStatoBozza;
  526.             
  527.             IDriverRegistroServiziGet driver = driverRegistroServiziGET;
  528.             String nomeRegistro = "Registro_"+tipoRegistro;
  529.             
  530.             this.mappingNomeRegistroToTipiDatabase.put(nomeRegistro, tipoRegistro);
  531.             this.mappingNomeRegistroToUseConnectionPdD.put(nomeRegistro, false);
  532.             this.driverRegistroServizi.put(nomeRegistro,driver);

  534.         }catch(Exception e){
  535.             String msg = "Riscontrato errore durante l'inizializzazione del registro: "+e.getMessage();
  536.             this.log.error(msg);
  537.             throw new DriverRegistroServiziException("Riscontrato errore durante l'inizializzazione del registro: "+e.getMessage());
  538.         }

  540.         if( this.driverRegistroServizi.size() == 0 )
  541.             throw new DriverRegistroServiziException("Non e' stato possibile inizializzare nessuna sorgente di lettura per un Registro dei Servizi");
  542.     }




  547.     private void initCacheRegistriServizi(CacheType cacheType, org.openspcoop2.core.config.Cache configurazioneCache,Logger alogConsole, boolean prefillCache, CryptConfig cryptConfigSoggetti) throws Exception{
  548.         this.cache = new Cache(cacheType, CostantiRegistroServizi.CACHE_REGISTRO_SERVIZI);

  550.         if( (configurazioneCache.getDimensione()!=null) ||
  551.                 (configurazioneCache.getAlgoritmo() != null) ){

  553.             try{
  554.                 if( configurazioneCache.getDimensione()!=null ){
  555.                     int dimensione = -1;                
  556.                     if(prefillCache){
  557.                         dimensione = Integer.MAX_VALUE;
  558.                     }
  559.                     else{
  560.                         dimensione = Integer.parseInt(configurazioneCache.getDimensione());
  561.                     }
  562.                     String msg = "Dimensione della cache (RegistroServizi) impostata al valore: "+dimensione;
  563.                     if(prefillCache){
  564.                         msg = "[Prefill Enabled] " + msg;
  565.                     }
  566.                     if(prefillCache){
  567.                         this.log.warn(msg);
  568.                     }
  569.                     else{
  570.                         this.log.info(msg);
  571.                     }
  572.                     if(alogConsole!=null){
  573.                         if(prefillCache){
  574.                             alogConsole.warn(msg);
  575.                         }
  576.                         else{
  577.                             alogConsole.info(msg);
  578.                         }
  579.                     }
  580.                     this.cache.setCacheSize(dimensione);
  581.                 }
  582.                 else{
  583.                     if(prefillCache){
  584.                         int dimensione = Integer.MAX_VALUE;
  585.                         String msg = "[Prefill Enabled] Dimensione della cache (RegistroServizi) impostata al valore: "+dimensione;
  586.                         this.log.warn(msg);
  587.                         if(alogConsole!=null){
  588.                             alogConsole.warn(msg);
  589.                         }
  590.                         this.cache.setCacheSize(dimensione);
  591.                     }
  592.                 }
  593.             }catch(Exception error){
  594.                 String msg = "Parametro errato per la dimensione della cache (RegistroServizi): "+error.getMessage();
  595.                 this.log.error(msg);
  596.                 if(alogConsole!=null)
  597.                     alogConsole.info(msg);
  598.             }
  599.             
  600.             if( configurazioneCache.getAlgoritmo() != null ){
  601.                 String msg = "Algoritmo di cache (RegistroServizi) impostato al valore: "+configurazioneCache.getAlgoritmo();
  602.                 this.log.info(msg);
  603.                 if(alogConsole!=null)
  604.                     alogConsole.info(msg);
  605.                 if(CostantiConfigurazione.CACHE_MRU.equals(configurazioneCache.getAlgoritmo()))
  606.                     this.cache.setCacheAlgoritm(CacheAlgorithm.MRU);
  607.                 else
  608.                     this.cache.setCacheAlgoritm(CacheAlgorithm.LRU);
  609.             }

  611.         }
  612.         if( (configurazioneCache.getItemIdleTime() != null) ||
  613.                 (configurazioneCache.getItemLifeSecond() != null) ){

  615.             try{
  616.                 if( configurazioneCache.getItemIdleTime() != null  ){
  617.                     int itemIdleTime = -1;              
  618.                     if(prefillCache){
  619.                         itemIdleTime = -1;
  620.                     }
  621.                     else{
  622.                         itemIdleTime = Integer.parseInt(configurazioneCache.getItemIdleTime());
  623.                     }
  624.                     String msg = "Attributo 'IdleTime' (RegistroServizi) impostato al valore: "+itemIdleTime;
  625.                     if(prefillCache){
  626.                         msg = "[Prefill Enabled] " + msg;
  627.                     }
  628.                     if(prefillCache){
  629.                         this.log.warn(msg);
  630.                     }
  631.                     else{
  632.                         this.log.info(msg);
  633.                     }
  634.                     if(alogConsole!=null){
  635.                         if(prefillCache){
  636.                             alogConsole.warn(msg);
  637.                         }
  638.                         else{
  639.                             alogConsole.info(msg);
  640.                         }
  641.                     }
  642.                     this.cache.setItemIdleTime(itemIdleTime);
  643.                 }
  644.                 else{
  645.                     if(prefillCache){
  646.                         int itemIdleTime = -1;
  647.                         String msg = "[Prefill Enabled] Attributo 'IdleTime' (RegistroServizi) impostato al valore: "+itemIdleTime;
  648.                         this.log.warn(msg);
  649.                         if(alogConsole!=null){
  650.                             alogConsole.warn(msg);
  651.                         }
  652.                         this.cache.setItemIdleTime(itemIdleTime);
  653.                     }
  654.                 }
  655.             }catch(Exception error){
  656.                 String msg = "Parametro errato per l'attributo 'IdleTime' (RegistroServizi): "+error.getMessage();
  657.                 this.log.error(msg);
  658.                 if(alogConsole!=null)
  659.                     alogConsole.info(msg);
  660.             }
  661.             
  662.             try{
  663.                 if( configurazioneCache.getItemLifeSecond() != null  ){
  664.                     int itemLifeSecond = -1;                
  665.                     if(prefillCache){
  666.                         itemLifeSecond = -1;
  667.                     }
  668.                     else{
  669.                         itemLifeSecond = Integer.parseInt(configurazioneCache.getItemLifeSecond());
  670.                     }
  671.                     String msg = "Attributo 'MaxLifeSecond' (RegistroServizi) impostato al valore: "+itemLifeSecond;
  672.                     if(prefillCache){
  673.                         msg = "[Prefill Enabled] " + msg;
  674.                     }
  675.                     if(prefillCache){
  676.                         this.log.warn(msg);
  677.                     }
  678.                     else{
  679.                         this.log.info(msg);
  680.                     }
  681.                     if(alogConsole!=null){
  682.                         if(prefillCache){
  683.                             alogConsole.warn(msg);
  684.                         }
  685.                         else{
  686.                             alogConsole.info(msg);
  687.                         }
  688.                     }
  689.                     this.cache.setItemLifeTime(itemLifeSecond);
  690.                 }
  691.                 else{
  692.                     if(prefillCache){
  693.                         int itemLifeSecond = -1;
  694.                         String msg = "Attributo 'MaxLifeSecond' (RegistroServizi) impostato al valore: "+itemLifeSecond;
  695.                         this.log.warn(msg);
  696.                         if(alogConsole!=null){
  697.                             alogConsole.warn(msg);
  698.                         }
  699.                         this.cache.setItemLifeTime(itemLifeSecond);
  700.                     }
  701.                 }
  702.             }catch(Exception error){
  703.                 String msg = "Parametro errato per l'attributo 'MaxLifeSecond' (RegistroServizi): "+error.getMessage();
  704.                 this.log.error(msg);
  705.                 if(alogConsole!=null)
  706.                     alogConsole.info(msg);
  707.             }

  709.         }
  710.         
  711.         this.cache.build();
  712.         
  713.         if(prefillCache){
  714.             this.prefillCache(null,alogConsole, cryptConfigSoggetti);
  715.         }
  716.     }

  718.     @SuppressWarnings("deprecation")
  719.     @Deprecated
  720.     public void disableSyncronizedGet() throws UtilsException {
  721.         if(this.cache==null) {
  722.             throw new UtilsException("Cache disabled");
  723.         }
  724.         this.cache.disableSyncronizedGet();
  725.     }
  726.     @SuppressWarnings("deprecation")
  727.     @Deprecated
  728.     public boolean isDisableSyncronizedGet() throws UtilsException {
  729.         if(this.cache==null) {
  730.             throw new UtilsException("Cache disabled");
  731.         }
  732.         return this.cache.isDisableSyncronizedGet();
  733.     }



  737.     protected java.util.Map<String, IDriverRegistroServiziGet> getDriverRegistroServizi() {
  738.         return this.driverRegistroServizi;
  739.     }

  741.     public void prefillCache(Connection connectionPdD,Logger alogConsole,
  742.             CryptConfig cryptConfigSoggetti){
  743.         
  744.         String msg = "[Prefill] Inizializzazione cache (RegistroServizi) in corso ...";
  745.         this.log.info(msg);
  746.         if(alogConsole!=null){
  747.             alogConsole.info(msg);
  748.         }
  749.         
  750.         Set<String> registri = this.driverRegistroServizi.keySet();
  751.                 
  752.         for (String nomeRegistro : registri) {
  753.         
  754.             
  755.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"]";
  756.             this.log.debug(msg);
  757.             if(alogConsole!=null){
  758.                 alogConsole.debug(msg);
  759.             }
  760.             
  761.             
  762.             /* ********  R I C E R C A    S E R V I Z I  (utilizzo dei driver) ******** */
  763.             

  765.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero accordi di servizio parte comune ...";
  766.             this.log.debug(msg);
  767.             if(alogConsole!=null){
  768.                 alogConsole.debug(msg);
  769.             }
  770.             
  771.             FiltroRicercaAccordi filtroAccordi = new FiltroRicercaAccordi();
  772.             List<IDAccordo> listAccordi = null;
  773.             try{
  774.                 listAccordi = this.driverRegistroServizi.get(nomeRegistro).getAllIdAccordiServizioParteComune(filtroAccordi);
  775.             }
  776.             catch(DriverRegistroServiziNotFound notFound){
  777.                 // ignore
  778.             }
  779.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  780.             
  781.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listAccordi!=null ? listAccordi.size() : 0)+" accordi di servizio parte comune";
  782.             this.log.debug(msg);
  783.             if(alogConsole!=null){
  784.                 alogConsole.debug(msg);
  785.             }
  786.             
  787.             if(listAccordi!=null && listAccordi.size()>0){
  788.                 
  789.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listAccordi.size()+" accordi di servizio parte comune ...";
  790.                 this.log.debug(msg);
  791.                 if(alogConsole!=null){
  792.                     alogConsole.debug(msg);
  793.                 }
  794.                 
  795.                 for (IDAccordo idAccordo : listAccordi) {
  796.                     
  797.                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero dati per l'accordo di servizio parte comune ["+idAccordo+"] ...";
  798.                     this.log.debug(msg);
  799.                     if(alogConsole!=null){
  800.                         alogConsole.debug(msg);
  801.                     }
  802.                     
  803.                     try{
  804.                         this.cache.remove(_getKey_getAccordoServizioParteComune(this.idAccordoFactory, idAccordo, null, null));
  805.                         this.getAccordoServizioParteComune(connectionPdD, nomeRegistro, idAccordo);
  806.                     }
  807.                     catch(DriverRegistroServiziNotFound notFound){
  808.                         // ignore
  809.                     }
  810.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  811.                     
  812.                     // uguale a quello sopra
  813. //                  try{
  814. //                      this.cache.remove(_getKey_getAccordoServizioParteComune(this.idAccordoFactory, idAccordo, false, false));
  815. //                      this.getAccordoServizioParteComune(connectionPdD, nomeRegistro, idAccordo, false, false);
  816. //                  }
  817. //                  catch(DriverRegistroServiziNotFound notFound){
  818. //                      // ignore                   
  819. //                  }
  820. //                  catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  821.                     
  822.                     AccordoServizioParteComune as = null;
  823.                     try{
  824.                         this.cache.remove(_getKey_getAccordoServizioParteComune(this.idAccordoFactory, idAccordo, true, true));
  825.                         as = this.getAccordoServizioParteComune(connectionPdD, nomeRegistro, idAccordo, true, true);
  826.                     }
  827.                     catch(DriverRegistroServiziNotFound notFound){
  828.                         // ignore
  829.                     }
  830.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  831.                                         
  832.                     boolean serviziCorrelati = false;
  833.                     if(as!=null) {
  834.                         ProfiloCollaborazione profiloAS = as.getProfiloCollaborazione();
  835.                         for (Azione az : as.getAzioneList()) {
  836.                             ProfiloCollaborazione profiloAZ = profiloAS;
  837.                             if (CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(az.getProfAzione())) {
  838.                                 profiloAZ = az.getProfiloCollaborazione();
  839.                             }
  840.                             if(ProfiloCollaborazione.ASINCRONO_ASIMMETRICO.equals(profiloAZ) || 
  841.                                     ProfiloCollaborazione.ASINCRONO_SIMMETRICO.equals(profiloAZ)) {
  842.                                 serviziCorrelati = true;
  843.                                 break;
  844.                             } 
  845.                         }
  846.                         if(!serviziCorrelati) {
  847.                             for (PortType pt : as.getPortTypeList()) {
  848.                                 ProfiloCollaborazione profiloPT = profiloAS;
  849.                                 if (CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(pt.getProfiloPT())) {
  850.                                     profiloPT = pt.getProfiloCollaborazione();
  851.                                 }
  852.                                 for (Operation az : pt.getAzioneList()) {
  853.                                     ProfiloCollaborazione profiloAZ = profiloPT;
  854.                                     if (CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(az.getProfAzione())) {
  855.                                         profiloAZ = az.getProfiloCollaborazione();
  856.                                     }
  857.                                     if(ProfiloCollaborazione.ASINCRONO_ASIMMETRICO.equals(profiloAZ) || 
  858.                                             ProfiloCollaborazione.ASINCRONO_SIMMETRICO.equals(profiloAZ)) {
  859.                                         serviziCorrelati = true;
  860.                                         break;
  861.                                     } 
  862.                                 }
  863.                                 if(serviziCorrelati) {
  864.                                     break;
  865.                                 }
  866.                             }
  867.                         }
  868.                     }
  869.                     
  870.                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero dati per l'accordo di servizio parte comune ["+idAccordo+"] completato";
  871.                     this.log.debug(msg);
  872.                     if(alogConsole!=null){
  873.                         alogConsole.debug(msg);
  874.                     }
  875.                     
  876.                     if(serviziCorrelati) {
  877.                     
  878.                         msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], (analisi profilo asincrono) recupero servizi che implementano l'accordo di servizio parte comune ["+idAccordo+"] ...";
  879.                         this.log.debug(msg);
  880.                         if(alogConsole!=null){
  881.                             alogConsole.debug(msg);
  882.                         }
  883.                     
  884.                         FiltroRicercaServizi filtroServizi = new FiltroRicercaServizi();
  885.                         filtroServizi.setIdAccordoServizioParteComune(idAccordo);
  886.                         List<IDServizio> listServizi = null;
  887.                         try{
  888.                             listServizi = this.driverRegistroServizi.get(nomeRegistro).getAllIdServizi(filtroServizi);
  889.                         }
  890.                         catch(DriverRegistroServiziNotFound notFound){
  891.                             // ignore
  892.                         }
  893.                         catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}

  895.                         msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], (analisi profilo asincrono) recuperati "+(listServizi!=null ? listServizi.size() : 0)+" servizi che implementano l'accordo di servizio parte comune ["+idAccordo+"]";
  896.                         this.log.debug(msg);
  897.                         if(alogConsole!=null){
  898.                             alogConsole.debug(msg);
  899.                         }
  900.                         
  901.                         if(listServizi!=null && listServizi.size()>0) {
  902.                             for (IDServizio idServizio : listServizi) {
  903.                                 
  904.                                 IDSoggetto idSoggetto = idServizio.getSoggettoErogatore();
  905.                                 
  906.                                 if(org.openspcoop2.core.constants.TipologiaServizio.CORRELATO.equals(idServizio.getTipologia())) {
  907.                                     
  908.                                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+
  909.                                             "], recupero dati asincroni per l'accordo di servizio parte comune ["+idAccordo+"] e soggetto ["+idSoggetto+"] ...";
  910.                                     this.log.debug(msg);
  911.                                     if(alogConsole!=null){
  912.                                         alogConsole.debug(msg);
  913.                                     }
  914.                                                                         
  915.                                     try{
  916.                                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto, idAccordo,null));
  917.                                         this.getAccordoServizioParteSpecifica_ServizioCorrelato(connectionPdD, nomeRegistro, idSoggetto, idAccordo);
  918.                                     }
  919.                                     catch(DriverRegistroServiziNotFound notFound){
  920.                                         // ignore
  921.                                     }
  922.                                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  923.                                     
  924.                                     try{
  925.                                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto, idAccordo,false));
  926.                                         this.getAccordoServizioParteSpecifica_ServizioCorrelato(connectionPdD, nomeRegistro, idSoggetto, idAccordo, false);
  927.                                     }
  928.                                     catch(DriverRegistroServiziNotFound notFound){
  929.                                         // ignore
  930.                                     }
  931.                                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  932.                                     
  933.                                     try{
  934.                                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto, idAccordo,true));
  935.                                         this.getAccordoServizioParteSpecifica_ServizioCorrelato(connectionPdD, nomeRegistro, idSoggetto, idAccordo, true);
  936.                                     }
  937.                                     catch(DriverRegistroServiziNotFound notFound){
  938.                                         // ignore
  939.                                     }
  940.                                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  941.                                     
  942.                                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+
  943.                                             "], recupero dati asincroni per l'accordo di servizio parte comune ["+idAccordo+"] e soggetto ["+idSoggetto+"] completato";
  944.                                     this.log.debug(msg);
  945.                                     if(alogConsole!=null){
  946.                                         alogConsole.debug(msg);
  947.                                     }
  948.                                     
  949.                                 }
  950.                                 
  951.                                 else {
  952.                                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+
  953.                                             "], recupero dati asincroni per l'accordo di servizio parte comune ["+idAccordo+"] e soggetto ["+idSoggetto+"] non effettuata essendo il servizio non di tipologia correlata";
  954.                                     this.log.debug(msg);
  955.                                     if(alogConsole!=null){
  956.                                         alogConsole.debug(msg);
  957.                                     }
  958.                                 }
  959.                             }
  960.                         }
  961.                     }

  963.                 }
  964.                 
  965.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listAccordi.size()+" accordi di servizio parte comune completato";
  966.                 this.log.debug(msg);
  967.                 if(alogConsole!=null){
  968.                     alogConsole.debug(msg);
  969.                 }
  970.             }
  971.             
  972.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero porte di dominio ...";
  973.             this.log.debug(msg);
  974.             if(alogConsole!=null){
  975.                 alogConsole.debug(msg);
  976.             }
  977.             
  978.             FiltroRicerca filtroPdd = new FiltroRicerca();
  979.             List<String> listPdd = null;
  980.             try{
  981.                 listPdd = this.driverRegistroServizi.get(nomeRegistro).getAllIdPorteDominio(filtroPdd);
  982.             }
  983.             catch(DriverRegistroServiziNotFound notFound){
  984.                 // ignore
  985.             }
  986.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  987.             
  988.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperate "+(listPdd!=null ? listPdd.size() : 0)+" porte di dominio";
  989.             this.log.debug(msg);
  990.             if(alogConsole!=null){
  991.                 alogConsole.debug(msg);
  992.             }
  993.             
  994.             if(listPdd!=null && listPdd.size()>0){
  995.                 
  996.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listPdd.size()+" porte di dominio ...";
  997.                 this.log.debug(msg);
  998.                 if(alogConsole!=null){
  999.                     alogConsole.debug(msg);
  1000.                 }
  1001.                 
  1002.                 for (String idPdd : listPdd) {
  1003.                     
  1004.                     try{
  1005.                         this.cache.remove(_getKey_getPortaDominio(idPdd));
  1006.                         this.getPortaDominio(connectionPdD, nomeRegistro, idPdd);
  1007.                     }
  1008.                     catch(DriverRegistroServiziNotFound notFound){
  1009.                         // ignore
  1010.                     }
  1011.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1012.                     
  1013.                 }
  1014.                 
  1015.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listPdd.size()+" porte di dominio completata";
  1016.                 this.log.debug(msg);
  1017.                 if(alogConsole!=null){
  1018.                     alogConsole.debug(msg);
  1019.                 }
  1020.             }
  1021.             
  1022.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero ruoli ...";
  1023.             this.log.debug(msg);
  1024.             if(alogConsole!=null){
  1025.                 alogConsole.debug(msg);
  1026.             }
  1027.             
  1028.             FiltroRicercaRuoli filtroRuoli = new FiltroRicercaRuoli();
  1029.             List<IDRuolo> listRuoli = null;
  1030.             try{
  1031.                 listRuoli = this.driverRegistroServizi.get(nomeRegistro).getAllIdRuoli(filtroRuoli);
  1032.             }
  1033.             catch(DriverRegistroServiziNotFound notFound){
  1034.                 // ignore
  1035.             }
  1036.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1037.             
  1038.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listRuoli!=null ? listRuoli.size() : 0)+" ruoli";
  1039.             this.log.debug(msg);
  1040.             if(alogConsole!=null){
  1041.                 alogConsole.debug(msg);
  1042.             }
  1043.             
  1044.             if(listRuoli!=null && listRuoli.size()>0){
  1045.                 
  1046.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listRuoli.size()+" ruoli ...";
  1047.                 this.log.debug(msg);
  1048.                 if(alogConsole!=null){
  1049.                     alogConsole.debug(msg);
  1050.                 }
  1051.                 
  1052.                 for (IDRuolo idRuolo : listRuoli) {
  1053.                     
  1054.                     try{
  1055.                         this.cache.remove(_getKey_getRuolo(idRuolo.getNome()));
  1056.                         this.getRuolo(connectionPdD, nomeRegistro, idRuolo.getNome());
  1057.                     }
  1058.                     catch(DriverRegistroServiziNotFound notFound){
  1059.                         // ignore
  1060.                     }
  1061.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1062.                     
  1063.                 }
  1064.                 
  1065.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listRuoli.size()+" ruoli completata";
  1066.                 this.log.debug(msg);
  1067.                 if(alogConsole!=null){
  1068.                     alogConsole.debug(msg);
  1069.                 }
  1070.             }
  1071.             
  1072.             
  1073.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero scope ...";
  1074.             this.log.debug(msg);
  1075.             if(alogConsole!=null){
  1076.                 alogConsole.debug(msg);
  1077.             }
  1078.             
  1079.             FiltroRicercaScope filtroScope = new FiltroRicercaScope();
  1080.             List<IDScope> listScope = null;
  1081.             try{
  1082.                 listScope = this.driverRegistroServizi.get(nomeRegistro).getAllIdScope(filtroScope);
  1083.             }
  1084.             catch(DriverRegistroServiziNotFound notFound){
  1085.                 // ignore
  1086.             }
  1087.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1088.             
  1089.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listScope!=null ? listScope.size() : 0)+" scope";
  1090.             this.log.debug(msg);
  1091.             if(alogConsole!=null){
  1092.                 alogConsole.debug(msg);
  1093.             }
  1094.             
  1095.             if(listScope!=null && listScope.size()>0){
  1096.                 
  1097.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listScope.size()+" scope ...";
  1098.                 this.log.debug(msg);
  1099.                 if(alogConsole!=null){
  1100.                     alogConsole.debug(msg);
  1101.                 }
  1102.                 
  1103.                 for (IDScope idScope : listScope) {
  1104.                     
  1105.                     try{
  1106.                         this.cache.remove(_getKey_getScope(idScope.getNome()));
  1107.                         this.getScope(connectionPdD, nomeRegistro, idScope.getNome());
  1108.                     }
  1109.                     catch(DriverRegistroServiziNotFound notFound){
  1110.                         // ignore
  1111.                     }
  1112.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1113.                     
  1114.                 }
  1115.                 
  1116.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listScope.size()+" scope completata";
  1117.                 this.log.debug(msg);
  1118.                 if(alogConsole!=null){
  1119.                     alogConsole.debug(msg);
  1120.                 }
  1121.             }
  1122.             
  1123.             
  1124.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero soggetti ...";
  1125.             this.log.debug(msg);
  1126.             if(alogConsole!=null){
  1127.                 alogConsole.debug(msg);
  1128.             }
  1129.             
  1130.             FiltroRicercaSoggetti filtroSoggetti = new FiltroRicercaSoggetti();
  1131.             List<IDSoggetto> listSoggetti = null;
  1132.             try{
  1133.                 listSoggetti = this.driverRegistroServizi.get(nomeRegistro).getAllIdSoggetti(filtroSoggetti);
  1134.             }
  1135.             catch(DriverRegistroServiziNotFound notFound){
  1136.                 // ignore
  1137.             }
  1138.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1139.             
  1140.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listSoggetti!=null ? listSoggetti.size() : 0)+" soggetti";
  1141.             this.log.debug(msg);
  1142.             if(alogConsole!=null){
  1143.                 alogConsole.debug(msg);
  1144.             }
  1145.             
  1146.             if(listSoggetti!=null && listSoggetti.size()>0){
  1147.                 
  1148.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listSoggetti.size()+" soggetti ...";
  1149.                 this.log.debug(msg);
  1150.                 if(alogConsole!=null){
  1151.                     alogConsole.debug(msg);
  1152.                 }
  1153.                 
  1154.                 for (IDSoggetto idSoggetto : listSoggetti) {
  1155.                     
  1156.                     try{
  1157.                         this.cache.remove(_getKey_getSoggetto(idSoggetto));
  1158.                         this.getSoggetto(connectionPdD, nomeRegistro, idSoggetto);
  1159.                     }
  1160.                     catch(DriverRegistroServiziNotFound notFound){
  1161.                         // ignore
  1162.                     }
  1163.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1164.                     
  1165.                     Soggetto soggetto = null;
  1166.                     try{
  1167.                         soggetto = this.driverRegistroServizi.get(nomeRegistro).getSoggetto(idSoggetto);
  1168.                     }
  1169.                     catch(DriverRegistroServiziNotFound notFound){
  1170.                         // ignore
  1171.                     }
  1172.                     catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1173.                     
  1174.                     if(soggetto!=null){
  1175.                         if(soggetto.sizeCredenzialiList()>0){
  1176.                             for (CredenzialiSoggetto credenziale : soggetto.getCredenzialiList()) {
  1177.                                 if(credenziale!=null && credenziale.getTipo()!=null){
  1178.                                     if(CredenzialeTipo.BASIC.equals(credenziale.getTipo())){
  1179.                                         try{
  1180.                                             this.cache.remove(_getKey_getSoggettoByCredenzialiBasic(credenziale.getUser(), credenziale.getPassword()));
  1181.                                             this.getSoggettoByCredenzialiBasic(connectionPdD, nomeRegistro, credenziale.getUser(), credenziale.getPassword(), cryptConfigSoggetti);
  1182.                                         }
  1183.                                         catch(DriverRegistroServiziNotFound notFound){
  1184.                                             // ignore
  1185.                                         }
  1186.                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1187.                                     }
  1188.                                     else if(CredenzialeTipo.APIKEY.equals(credenziale.getTipo())){
  1189.                                         try{
  1190.                                             this.cache.remove(_getKey_getSoggettoByCredenzialiApiKey(credenziale.getUser(), credenziale.getPassword(), credenziale.isCertificateStrictVerification()));
  1191.                                             this.getSoggettoByCredenzialiApiKey(connectionPdD, nomeRegistro, credenziale.getUser(), credenziale.getPassword(), credenziale.isCertificateStrictVerification(), cryptConfigSoggetti);
  1192.                                         }
  1193.                                         catch(DriverRegistroServiziNotFound notFound){
  1194.                                             // ignore
  1195.                                         }
  1196.                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1197.                                     }
  1198.                                     else if(CredenzialeTipo.SSL.equals(credenziale.getTipo())){
  1199.                                         if(credenziale.getSubject()!=null) {
  1200.                                             try{
  1201.                                                 this.cache.remove(_getKey_getSoggettoByCredenzialiSsl(credenziale.getSubject(),credenziale.getIssuer()));
  1202.                                                 this.getSoggettoByCredenzialiSsl(connectionPdD, nomeRegistro, credenziale.getSubject(),credenziale.getIssuer());
  1203.                                             }
  1204.                                             catch(DriverRegistroServiziNotFound notFound){
  1205.                                                 // ignore
  1206.                                             }
  1207.                                             catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1208.                                         }
  1209.                                         if(credenziale.getCertificate()!=null) {
  1210.                                             try{
  1211.                                                 CertificateInfo certificato = ArchiveLoader.load(ArchiveType.CER, credenziale.getCertificate(), 0, null).getCertificate();
  1212.                                                 this.cache.remove(_getKey_getSoggettoByCredenzialiSsl(certificato, credenziale.isCertificateStrictVerification()));
  1213.                                                 this.getSoggettoByCredenzialiSsl(connectionPdD, nomeRegistro, certificato, credenziale.isCertificateStrictVerification());
  1214.                                             }
  1215.                                             catch(DriverRegistroServiziNotFound notFound){
  1216.                                                 // ignore
  1217.                                             }
  1218.                                             catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1219.                                         }
  1220.                                     }
  1221.                                     else if(CredenzialeTipo.PRINCIPAL.equals(credenziale.getTipo())){
  1222.                                         try{
  1223.                                             this.cache.remove(_getKey_getSoggettoByCredenzialiPrincipal(credenziale.getUser()));
  1224.                                             this.getSoggettoByCredenzialiPrincipal(connectionPdD, nomeRegistro, credenziale.getUser());
  1225.                                         }
  1226.                                         catch(DriverRegistroServiziNotFound notFound){
  1227.                                             // ignore
  1228.                                         }
  1229.                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1230.                                     }
  1231.                                 }
  1232.                             }
  1233.                         }
  1234.                     }
  1235.                 }
  1236.                 
  1237.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listSoggetti.size()+" soggetti completata";
  1238.                 this.log.debug(msg);
  1239.                 if(alogConsole!=null){
  1240.                     alogConsole.debug(msg);
  1241.                 }
  1242.             }
  1243.             
  1244.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero servizi ...";
  1245.             this.log.debug(msg);
  1246.             if(alogConsole!=null){
  1247.                 alogConsole.debug(msg);
  1248.             }
  1249.             
  1250.             FiltroRicercaServizi filtroServizi = new FiltroRicercaServizi();
  1251.             List<IDServizio> listServizi = null;
  1252.             try{
  1253.                 listServizi = this.driverRegistroServizi.get(nomeRegistro).getAllIdServizi(filtroServizi);
  1254.             }
  1255.             catch(DriverRegistroServiziNotFound notFound){
  1256.                 // ignore
  1257.             }
  1258.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1259.             
  1260.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listServizi!=null ? listServizi.size() : 0)+" servizi";
  1261.             this.log.debug(msg);
  1262.             if(alogConsole!=null){
  1263.                 alogConsole.debug(msg);
  1264.             }
  1265.             
  1266.             if(listServizi!=null && listServizi.size()>0){
  1267.                 
  1268.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listServizi.size()+" servizi ...";
  1269.                 this.log.debug(msg);
  1270.                 if(alogConsole!=null){
  1271.                     alogConsole.debug(msg);
  1272.                 }
  1273.                 
  1274.                 for (IDServizio idServizio : listServizi) {
  1275.                     
  1276.                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero dati per l'accordo di servizio parte specifica ["+idServizio+"] ...";
  1277.                     this.log.debug(msg);
  1278.                     if(alogConsole!=null){
  1279.                         alogConsole.debug(msg);
  1280.                     }
  1281.                     
  1282.                     try{
  1283.                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,null));
  1284.                         this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio);
  1285.                     }
  1286.                     catch(DriverRegistroServiziNotFound notFound){
  1287.                         // ignore
  1288.                     }
  1289.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1290.                                         
  1291.                     try{
  1292.                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,false));
  1293.                         this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, false);
  1294.                     }
  1295.                     catch(DriverRegistroServiziNotFound notFound){
  1296.                         // ignore
  1297.                     }
  1298.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1299.                     
  1300.                     try{
  1301.                         this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,true));
  1302.                         this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, true);
  1303.                     }
  1304.                     catch(DriverRegistroServiziNotFound notFound){
  1305.                         // ignore
  1306.                     }
  1307.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1308.                 
  1309.                     AccordoServizioParteSpecifica asps = null;
  1310.                     try{
  1311.                         asps = this.driverRegistroServizi.get(nomeRegistro).getAccordoServizioParteSpecifica(idServizio);
  1312.                     }
  1313.                     catch(DriverRegistroServiziNotFound notFound){
  1314.                         // ignore
  1315.                     }
  1316.                     catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1317.                     
  1318.                     try{
  1319.                         if(asps!=null && asps.getAccordoServizioParteComune()!=null){
  1320.                             IDAccordo idAPC = this.idAccordoFactory.getIDAccordoFromUri(asps.getAccordoServizioParteComune());
  1321.                             AccordoServizioParteComune apc = this.getAccordoServizioParteComune(connectionPdD,nomeRegistro,idAPC); // già aggiornato precedentemente
  1322.                             if(apc!=null){
  1323.                                 if(asps.getPortType()!=null && !"".equals(asps.getPortType())){
  1324.                                     if(apc.sizePortTypeList()>0){
  1325.                                         for (PortType pt : apc.getPortTypeList()) {
  1326.                                             if(pt.getNome().equals(asps.getPortType())){
  1327.                                                 if(pt.sizeAzioneList()>0){
  1328.                                                     for (Operation azione : pt.getAzioneList()) {
  1329.                                                         idServizio.setAzione(azione.getNome());
  1330.                                                         try{
  1331.                                                             this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,null));
  1332.                                                             this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio);
  1333.                                                         }
  1334.                                                         catch(DriverRegistroServiziNotFound notFound){
  1335.                                                             // ignore
  1336.                                                         }
  1337.                                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1338.                                                         
  1339.                                                         try{
  1340.                                                             this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,false));
  1341.                                                             this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, false);
  1342.                                                         }
  1343.                                                         catch(DriverRegistroServiziNotFound notFound){
  1344.                                                             // ignore
  1345.                                                         }
  1346.                                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1347.                                                         
  1348.                                                         try{
  1349.                                                             this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,true));
  1350.                                                             this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, true);
  1351.                                                         }
  1352.                                                         catch(DriverRegistroServiziNotFound notFound){
  1353.                                                             // ignore
  1354.                                                         }
  1355.                                                         catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1356.                                                     }
  1357.                                                 }
  1358.                                             }
  1359.                                         }
  1360.                                     }
  1361.                                 }
  1362.                                 else{
  1363.                                     if(apc.sizeAzioneList()>0){
  1364.                                         for (Azione azione : apc.getAzioneList()) {
  1365.                                             idServizio.setAzione(azione.getNome());
  1366.                                             try{
  1367.                                                 this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,null));
  1368.                                                 this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio);
  1369.                                             }
  1370.                                             catch(DriverRegistroServiziNotFound notFound){
  1371.                                                 // ignore
  1372.                                             }
  1373.                                             catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1374.                                             
  1375.                                             try{
  1376.                                                 this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,false));
  1377.                                                 this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, false);
  1378.                                             }
  1379.                                             catch(DriverRegistroServiziNotFound notFound){
  1380.                                                 // ignore
  1381.                                             }
  1382.                                             catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1383.                                             
  1384.                                             try{
  1385.                                                 this.cache.remove(_getKey_getAccordoServizioParteSpecifica(idServizio,true));
  1386.                                                 this.getAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, idServizio, true);
  1387.                                             }
  1388.                                             catch(DriverRegistroServiziNotFound notFound){
  1389.                                                 // ignore
  1390.                                             }
  1391.                                             catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1392.                                         }
  1393.                                     }
  1394.                                 }
  1395.                             }
  1396.                         }
  1397.                     }catch(DriverRegistroServiziNotFound notFound){
  1398.                         // ignore
  1399.                     }
  1400.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1401.                     
  1402.                     // Correlato implementato nella parte comune
  1403.                     
  1404.                     msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero dati per l'accordo di servizio parte specifica ["+idServizio+"] completata";
  1405.                     this.log.debug(msg);
  1406.                     if(alogConsole!=null){
  1407.                         alogConsole.debug(msg);
  1408.                     }
  1409.                 }
  1410.                 
  1411.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listServizi.size()+" servizi completata";
  1412.                 this.log.debug(msg);
  1413.                 if(alogConsole!=null){
  1414.                     alogConsole.debug(msg);
  1415.                 }
  1416.             }
  1417.             
  1418.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recupero accordi di cooperazione ...";
  1419.             this.log.debug(msg);
  1420.             if(alogConsole!=null){
  1421.                 alogConsole.debug(msg);
  1422.             }
  1423.             
  1424.             FiltroRicercaAccordi filtroAccordiCooperazione = new FiltroRicercaAccordi();
  1425.             List<IDAccordoCooperazione> listAccordiCooperazione = null;
  1426.             try{
  1427.                 listAccordiCooperazione = this.driverRegistroServizi.get(nomeRegistro).getAllIdAccordiCooperazione(filtroAccordiCooperazione);
  1428.             }
  1429.             catch(DriverRegistroServiziNotFound notFound){
  1430.                 // ignore
  1431.             }
  1432.             catch(DriverRegistroServiziException e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1433.             
  1434.             msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], recuperati "+(listAccordiCooperazione!=null ? listAccordiCooperazione.size() : 0)+" accordi di cooperazione";
  1435.             this.log.debug(msg);
  1436.             if(alogConsole!=null){
  1437.                 alogConsole.debug(msg);
  1438.             }
  1439.             
  1440.             if(listAccordiCooperazione!=null && listAccordiCooperazione.size()>0){
  1441.                 
  1442.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listAccordiCooperazione.size()+" accordi di cooperazione ...";
  1443.                 this.log.debug(msg);
  1444.                 if(alogConsole!=null){
  1445.                     alogConsole.debug(msg);
  1446.                 }
  1447.                 
  1448.                 for (IDAccordoCooperazione idAccordoCooperazione : listAccordiCooperazione) {
  1449.                     
  1450.                     try{
  1451.                         this.cache.remove(_getKey_getAccordoCooperazione(this.idAccordoCooperazioneFactory, idAccordoCooperazione, null));
  1452.                         this.getAccordoCooperazione(connectionPdD, nomeRegistro, idAccordoCooperazione);
  1453.                     }
  1454.                     catch(DriverRegistroServiziNotFound notFound){
  1455.                         // ignore
  1456.                     }
  1457.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1458.                     
  1459.                     try{
  1460.                         this.cache.remove(_getKey_getAccordoCooperazione(this.idAccordoCooperazioneFactory, idAccordoCooperazione, false));
  1461.                         this.getAccordoCooperazione(connectionPdD, nomeRegistro, idAccordoCooperazione, false);
  1462.                     }
  1463.                     catch(DriverRegistroServiziNotFound notFound){
  1464.                         // ignore
  1465.                     }
  1466.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}
  1467.                     
  1468.                     try{
  1469.                         this.cache.remove(_getKey_getAccordoCooperazione(this.idAccordoCooperazioneFactory, idAccordoCooperazione, true));
  1470.                         this.getAccordoCooperazione(connectionPdD, nomeRegistro, idAccordoCooperazione, true);
  1471.                     }
  1472.                     catch(DriverRegistroServiziNotFound notFound){
  1473.                         // ignore
  1474.                     }
  1475.                     catch(Exception e){this.log.error("[prefill] errore"+e.getMessage(),e);}

  1477.                 }
  1478.                 
  1479.                 msg = "[Prefill] Inizializzazione cache (RegistroServizi) per il registro ["+nomeRegistro+"], lettura di "+listAccordiCooperazione.size()+" accordi di cooperazione completata";
  1480.                 this.log.debug(msg);
  1481.                 if(alogConsole!=null){
  1482.                     alogConsole.debug(msg);
  1483.                 }
  1484.             }
  1485.             
  1486.             
  1487.             
  1488.             /* ********  R I C E R C A  I D   E L E M E N T I   P R I M I T I V I  ******** */
  1489.             
  1490.             // Dipende dal filtro, non è possibile pre-inizializzarlo
  1491.         }
  1492.         
  1493.         
  1494.         msg = "[Prefill] Inizializzazione cache (RegistroServizi) completata";
  1495.         this.log.info(msg);
  1496.         if(alogConsole!=null){
  1497.             alogConsole.info(msg);
  1498.         }
  1499.     }




  1504.     /**
  1505.      * Si occupa di effettuare una ricerca nei registri, e di inserire la ricerca in cache
  1506.      */
  1507.     public Object getObjectCache(String keyCache,String methodName,
  1508.             String nomeRegistro,
  1509.             Boolean readContenutoAllegati,
  1510.             Connection connectionPdD,
  1511.             Object ... instances) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1512.         Class<?>[] classArgoments = null;
  1513.         Object[] values = null;
  1514.         if(instances!=null && instances.length>0){
  1515.             classArgoments = new Class<?>[instances.length];
  1516.             values = new Object[instances.length];
  1517.             for (int i = 0; i < instances.length; i++) {
  1518.                 if("getAccordoServizioParteComune".equals(methodName) && i==1) {
  1519.                     classArgoments[i] = boolean.class; // readDatiRegistro
  1520.                 }
  1521.                 else {
  1522.                     classArgoments[i] = instances[i].getClass();
  1523.                 }
  1524.                 values[i] = instances[i];
  1525.             }
  1526.         }
  1527.         return getObjectCache(keyCache, methodName, nomeRegistro, readContenutoAllegati, connectionPdD, classArgoments, values);
  1528.     }
  1529.     private static org.openspcoop2.utils.Semaphore semaphore_getObjectCache = new org.openspcoop2.utils.Semaphore("RegistroServizi_Object");
  1530.     public Object getObjectCache(String keyCache,String methodName,
  1531.             String nomeRegistro,
  1532.             Boolean readContenutoAllegati,
  1533.             Connection connectionPdD,
  1534.             Class<?>[] classArgoments, Object[] values) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1536.         SemaphoreLock lock = semaphore_getObjectCache.acquireThrowRuntime("getObjectCache");        
  1537.         DriverRegistroServiziNotFound dNotFound = null;
  1538.         Object obj = null;
  1539.         try{

  1541. //          System.out.println("@"+keyCache+"@ INFO CACHE: "+this.cache.toString());
  1542. //          System.out.println("@"+keyCache+"@ KEYS: \n\t"+this.cache.printKeys("\n\t"));
  1543.             
  1544.             // Raccolta dati
  1545.             if(keyCache == null)
  1546.                 throw new DriverRegistroServiziException("["+methodName+"]: KeyCache non definita");    

  1548.             // se e' attiva una cache provo ad utilizzarla
  1549.             if(this.cache!=null){
  1550.                 org.openspcoop2.utils.cache.CacheResponse response = 
  1551.                     (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(keyCache);
  1552.                 if(response != null){
  1553.                     if(response.getObject()!=null){
  1554.                         this.log.debug("Oggetto (tipo:"+response.getObject().getClass().getName()+") con chiave ["+keyCache+"] (method:"+methodName+") nel registro["+nomeRegistro+"] in cache.");
  1555.                         return response.getObject();
  1556.                     }else if(response.getException()!=null){
  1557.                         this.log.debug("Eccezione (tipo:"+response.getException().getClass().getName()+") con chiave ["+keyCache+"] (method:"+methodName+") nel registro["+nomeRegistro+"] in cache.");
  1558.                         throw (Exception) response.getException();
  1559.                     }else{
  1560.                         this.log.error("In cache non e' presente ne un oggetto ne un'eccezione.");
  1561.                     }
  1562.                 }
  1563.             }

  1565.             // Effettuo le query nella mia gerarchia di registri.
  1566.             this.log.debug("oggetto con chiave ["+keyCache+"] (method:"+methodName+") nel registro["+nomeRegistro+"] non in cache, ricerco nel registro...");
  1567.             try{
  1568.                 obj = getObject(methodName,nomeRegistro,readContenutoAllegati,connectionPdD,classArgoments,values);
  1569.             }catch(DriverRegistroServiziNotFound e){
  1570.                 dNotFound = e;
  1571.             }

  1573.             // Aggiungo la risposta in cache (se esiste una cache)  
  1574.             // Se ho una eccezione aggiungo in cache solo una not found
  1575.             if( this.cache!=null ){     
  1576.                 if(dNotFound!=null){
  1577.                     this.log.info("Aggiungo eccezione ["+keyCache+"] in cache");
  1578.                 }else if(obj!=null){
  1579.                     this.log.info("Aggiungo oggetto ["+keyCache+"] in cache");
  1580.                 }else{
  1581.                     throw new Exception("Metodo ("+methodName+") nel registro["+nomeRegistro+"] ha ritornato un valore null");
  1582.                 }
  1583.                 try{    
  1584.                     org.openspcoop2.utils.cache.CacheResponse responseCache = new org.openspcoop2.utils.cache.CacheResponse();
  1585.                     if(dNotFound!=null){
  1586.                         responseCache.setException(dNotFound);
  1587.                     }else{
  1588.                         responseCache.setObject((java.io.Serializable)obj);
  1589.                     }
  1590.                     this.cache.put(keyCache,responseCache);
  1591.                 }catch(UtilsException e){
  1592.                     this.log.error("Errore durante l'inserimento in cache ["+keyCache+"]: "+e.getMessage());
  1593.                 }
  1594.             }

  1596.         }catch(DriverRegistroServiziException e){
  1597.             throw e;
  1598.         }catch(DriverRegistroServiziNotFound e){
  1599.             throw e;
  1600.         }
  1601.         catch(Exception e){
  1602.             if(notFoundClassName.equals(e.getClass().getName()))
  1603.                 throw (DriverRegistroServiziNotFound) e;
  1604.             else
  1605.                 throw new DriverRegistroServiziException("RegistroServizi, Algoritmo di Cache fallito: "+e.getMessage(),e);
  1606.         }finally {
  1607.             semaphore_getObjectCache.release(lock, "getObjectCache");
  1608.         }

  1610.         if(dNotFound!=null){
  1611.             throw dNotFound;
  1612.         }else
  1613.             return obj;
  1614.     }


  1617.     /**
  1618.      * Si occupa di effettuare una ricerca nei registri
  1619.      */
  1620.     public Object getObject(String methodName,
  1621.             String nomeRegistro,
  1622.             Boolean readContenutoAllegati,
  1623.             Connection connectionPdD,
  1624.             Object ... instances) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1625.         Class<?>[] classArgoments = null;
  1626.         Object[] values = null;
  1627.         if(instances!=null && instances.length>0){
  1628.             classArgoments = new Class<?>[instances.length];
  1629.             values = new Object[instances.length];
  1630.             for (int i = 0; i < instances.length; i++) {
  1631.                 if("getAccordoServizioParteComune".equals(methodName) && i==1) {
  1632.                     classArgoments[i] = boolean.class; // readDatiRegistro
  1633.                 }
  1634.                 else {
  1635.                     classArgoments[i] = instances[i].getClass();
  1636.                 }
  1637.                 values[i] = instances[i];
  1638.             }
  1639.         }
  1640.         return getObject(methodName, nomeRegistro, readContenutoAllegati, connectionPdD, classArgoments, values);
  1641.     }
  1642.     public Object getObject(String methodName,
  1643.             String nomeRegistro,
  1644.             Boolean readContenutoAllegati,
  1645.             Connection connectionPdD,
  1646.             Class<?>[] classArgoments, Object[] values) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{


  1649.         // Effettuo le query nella mia gerarchia di registri.
  1650.         Object obj = null;
  1651.         //Recupero la classe specificata dal parametro passato
  1652.         if(nomeRegistro!=null){
  1653.             this.log.debug("Cerco nel registro ["+nomeRegistro+"]");
  1654.             try{
  1655.                 //org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.driverRegistroServizi.get(nomeRegistro);
  1656.                 org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.getDriver(connectionPdD, nomeRegistro);
  1657.                 this.log.debug("invocazione metodo ["+methodName+"]...");
  1658.                 if(classArgoments==null || classArgoments.length==0){
  1659.                     Method method =  null;
  1660.                     if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1661.                         method = driver.getClass().getMethod(methodName,boolean.class);
  1662.                         obj = method.invoke(driver,readContenutoAllegati);
  1663.                     }else{
  1664.                         method = driver.getClass().getMethod(methodName);
  1665.                         obj = method.invoke(driver);
  1666.                     }
  1667.                 }else if(classArgoments.length==1){
  1668.                     Method method =  null;
  1669.                     if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1670.                         method = driver.getClass().getMethod(methodName,classArgoments[0],boolean.class);
  1671.                         obj = method.invoke(driver,values[0],readContenutoAllegati);
  1672.                     }else{
  1673.                         method = driver.getClass().getMethod(methodName,classArgoments[0]);
  1674.                         obj = method.invoke(driver,values[0]);
  1675.                     }
  1676.                 }else if(classArgoments.length==2){
  1677.                     Method method =  null;
  1678.                     if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1679.                         if("getAccordoServizioParteComune".equals(methodName)) {
  1680.                             method = driver.getClass().getMethod(methodName,classArgoments[0],boolean.class,classArgoments[1]);
  1681.                             obj = method.invoke(driver,values[0],readContenutoAllegati,values[1]);
  1682.                         }
  1683.                         else {
  1684.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],boolean.class);
  1685.                             obj = method.invoke(driver,values[0],values[1],readContenutoAllegati);
  1686.                         }
  1687.                     }else{
  1688.                         if("getAccordoServizioParteComune".equals(methodName)) {
  1689.                             method = driver.getClass().getMethod(methodName,classArgoments[0]);
  1690.                             obj = method.invoke(driver,values[0]);
  1691.                         }
  1692.                         else {
  1693.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1]);
  1694.                             obj = method.invoke(driver,values[0],values[1]);
  1695.                         }
  1696.                     }
  1697.                 }else if(classArgoments.length==3){
  1698.                     Method method =  null;
  1699.                     if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1700.                         method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],classArgoments[2],boolean.class);
  1701.                         obj = method.invoke(driver,values[0],values[1],values[2],readContenutoAllegati);
  1702.                     }else{
  1703.                         method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],classArgoments[2]);
  1704.                         obj = method.invoke(driver,values[0],values[1],values[2]);
  1705.                     }
  1706.                 }else if(classArgoments.length==4){
  1707.                     
  1708.                     Class<?> cArg2 = classArgoments[2];
  1709.                     if("getSoggettoByCredenzialiApiKey".equals(methodName)) {
  1710.                         cArg2 = boolean.class;
  1711.                     }
  1712.                     
  1713.                     Method method =  null;
  1714.                     if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1715.                         method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],cArg2,classArgoments[3],boolean.class);
  1716.                         obj = method.invoke(driver,values[0],values[1],values[2],values[3],readContenutoAllegati);
  1717.                     }else{
  1718.                         method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],cArg2,classArgoments[3]);
  1719.                         obj = method.invoke(driver,values[0],values[1],values[2],values[3]);
  1720.                     }
  1721.                 }else
  1722.                     throw new Exception("Troppi argomenti per gestire la chiamata del metodo");
  1723.                 
  1724.                 // Check stato
  1725.                 if( (!this.readObjectStatoBozza) && (driver instanceof DriverRegistroServiziDB) ){
  1726.                     if(obj instanceof AccordoCooperazione){
  1727.                         AccordoCooperazione ac = (AccordoCooperazione) obj;
  1728.                         if(StatiAccordo.bozza.toString().equals(ac.getStatoPackage())){
  1729.                             obj = null;
  1730.                             throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1731.                         }
  1732.                     }else if(obj instanceof AccordoServizioParteComune){
  1733.                         AccordoServizioParteComune as = (AccordoServizioParteComune) obj;
  1734.                         if(StatiAccordo.bozza.toString().equals(as.getStatoPackage())){
  1735.                             obj = null;
  1736.                             throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1737.                         }
  1738.                     }else if(obj instanceof AccordoServizioParteSpecifica){
  1739.                         AccordoServizioParteSpecifica s = (AccordoServizioParteSpecifica) obj;
  1740.                         if(StatiAccordo.bozza.toString().equals(s.getStatoPackage())){
  1741.                             obj = null;
  1742.                             throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1743.                         }else{
  1744.                             // Check fruitori
  1745.                             List<Fruitore> fruitoriConStatoNonBozza = new ArrayList<Fruitore>();
  1746.                             while(s.sizeFruitoreList()>0){
  1747.                                 Fruitore tmpF = s.removeFruitore(0);
  1748.                                 if(StatiAccordo.bozza.toString().equals(tmpF.getStatoPackage())==false){
  1749.                                     fruitoriConStatoNonBozza.add(tmpF);
  1750.                                 }
  1751.                             }
  1752.                             while(fruitoriConStatoNonBozza.size()>0){
  1753.                                 s.addFruitore(fruitoriConStatoNonBozza.remove(0));
  1754.                             }
  1755.                         }
  1756.                     }
  1757.                 }
  1758.                 
  1759.             }catch(DriverRegistroServiziNotFound e){
  1760.                 // Non presente
  1761.                 this.log.debug("Ricerca nel registro non riuscita (metodo ["+methodName+"]): "+e.getMessage());
  1762.                 throw e;
  1763.             }
  1764.             catch(java.lang.reflect.InvocationTargetException e){
  1765.                 if(e.getTargetException()!=null){
  1766.                     if(notFoundClassName.equals(e.getTargetException().getClass().getName())){
  1767.                         // Non presente
  1768.                         this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita [NotFound] (metodo ["+methodName+"]): "+e.getTargetException().getMessage());
  1769.                         throw new DriverRegistroServiziNotFound(e.getTargetException().getMessage(),e.getTargetException());
  1770.                     }else if(excClassName.equals(e.getTargetException().getClass().getName())){
  1771.                         // Non presente
  1772.                         this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita [DriverException] (metodo ["+methodName+"]): "+e.getTargetException().getMessage(),e.getTargetException());
  1773.                         throw new DriverRegistroServiziException(e.getTargetException().getMessage(),e.getTargetException());
  1774.                     }else{
  1775.                         this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita [InvTargetExcp.getTarget] (metodo ["+methodName+"]), "+e.getTargetException().getMessage(),e.getTargetException());
  1776.                         throw new DriverRegistroServiziException(e.getTargetException().getMessage(),e.getTargetException());
  1777.                     }
  1778.                 }else{
  1779.                     this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita [InvTargetExcp] (metodo ["+methodName+"]), "+e.getMessage(),e);
  1780.                     throw new DriverRegistroServiziException(e.getMessage(),e);
  1781.                 }
  1782.             }
  1783.             catch(Exception e){
  1784.                 // Non presente
  1785.                 this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita, "+e.getMessage(),e);
  1786.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  1787.             }

  1789.             this.log.debug("invocazione metodo ["+methodName+"] completata.");
  1790.             return obj;

  1792.         }else{
  1793.             this.log.debug("Cerco nella mia gerarchia di registri");
  1794.             StringBuilder notFoundProblem = new StringBuilder();
  1795.             StringBuilder exceptionProblem = new StringBuilder();
  1796.             boolean find = false;
  1797.             for (String nomeRegInLista : this.driverRegistroServizi.keySet()) {
  1798.                 this.log.debug("Cerco nel registro con nome["+nomeRegInLista+"]");
  1799.                 try{
  1800.                     //org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.driverRegistroServizi.get(nomeRegInLista);
  1801.                     org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.getDriver(connectionPdD, nomeRegInLista);
  1802.                     this.log.debug("invocazione metodo ["+methodName+"] nel registro["+nomeRegInLista+"]...");
  1803.                     if(classArgoments==null || classArgoments.length==0){
  1804.                         Method method =  null;
  1805.                         if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1806.                             method = driver.getClass().getMethod(methodName,boolean.class);
  1807.                             obj = method.invoke(driver,readContenutoAllegati);
  1808.                         }else{
  1809.                             method = driver.getClass().getMethod(methodName);
  1810.                             obj = method.invoke(driver);
  1811.                         }
  1812.                         find = true;
  1813.                     }else if(classArgoments.length==1){
  1814.                         Method method =  null;
  1815.                         if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1816.                             method = driver.getClass().getMethod(methodName,classArgoments[0],boolean.class);
  1817.                             obj = method.invoke(driver,values[0],readContenutoAllegati);
  1818.                         }else{
  1819.                             method = driver.getClass().getMethod(methodName,classArgoments[0]);
  1820.                             obj = method.invoke(driver,values[0]);
  1821.                         }
  1822.                         find = true;
  1823.                     }else if(classArgoments.length==2){
  1824.                         Method method =  null;
  1825.                         if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1826.                             if("getAccordoServizioParteComune".equals(methodName)) {
  1827.                                 method = driver.getClass().getMethod(methodName,classArgoments[0],boolean.class,classArgoments[1]);
  1828.                                 obj = method.invoke(driver,values[0],readContenutoAllegati,values[1]);
  1829.                             }
  1830.                             else {
  1831.                                 method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],boolean.class);
  1832.                                 obj = method.invoke(driver,values[0],values[1],readContenutoAllegati);
  1833.                             }
  1834.                         }else{
  1835.                             if("getAccordoServizioParteComune".equals(methodName)) {
  1836.                                 method = driver.getClass().getMethod(methodName,classArgoments[0]);
  1837.                                 obj = method.invoke(driver,values[0]);
  1838.                             }
  1839.                             else {
  1840.                                 method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1]);
  1841.                                 obj = method.invoke(driver,values[0],values[1]);
  1842.                             }
  1843.                         }
  1844.                         find = true;
  1845.                     }else if(classArgoments.length==3){
  1846.                         Method method =  null;
  1847.                         if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1848.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],classArgoments[2],boolean.class);
  1849.                             obj = method.invoke(driver,values[0],values[1],values[2],readContenutoAllegati);
  1850.                         }else{
  1851.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],classArgoments[2]);
  1852.                             obj = method.invoke(driver,values[0],values[1],values[2]);
  1853.                         }
  1854.                         find = true;
  1855.                     }else if(classArgoments.length==4){
  1856.                         
  1857.                         Class<?> cArg2 = classArgoments[2];
  1858.                         if("getSoggettoByCredenzialiApiKey".equals(methodName)) {
  1859.                             cArg2 = boolean.class;
  1860.                         }
  1861.                         
  1862.                         Method method =  null;
  1863.                         if((driver instanceof DriverRegistroServiziDB) && (readContenutoAllegati!=null) ){
  1864.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],cArg2,classArgoments[3],boolean.class);
  1865.                             obj = method.invoke(driver,values[0],values[1],values[2],values[3],readContenutoAllegati);
  1866.                         }else{
  1867.                             method = driver.getClass().getMethod(methodName,classArgoments[0],classArgoments[1],cArg2,classArgoments[3]);
  1868.                             obj = method.invoke(driver,values[0],values[1],values[2],values[3]);
  1869.                         }
  1870.                         find = true;
  1871.                     }else
  1872.                         throw new Exception("Troppi argomenti per gestire la chiamata del metodo");
  1873.                     
  1874.                     // Check stato
  1875.                     if((!this.readObjectStatoBozza) && (driver instanceof DriverRegistroServiziDB) ){
  1876.                         if(obj instanceof AccordoCooperazione){
  1877.                             AccordoCooperazione ac = (AccordoCooperazione) obj;
  1878.                             if(StatiAccordo.bozza.toString().equals(ac.getStatoPackage())){
  1879.                                 obj = null;
  1880.                                 find = false;
  1881.                                 throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1882.                             }
  1883.                         }else if(obj instanceof AccordoServizioParteComune){
  1884.                             AccordoServizioParteComune as = (AccordoServizioParteComune) obj;
  1885.                             if(StatiAccordo.bozza.toString().equals(as.getStatoPackage())){
  1886.                                 obj = null;
  1887.                                 find = false;
  1888.                                 throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1889.                             }
  1890.                         }else if(obj instanceof AccordoServizioParteSpecifica){
  1891.                             AccordoServizioParteSpecifica s = (AccordoServizioParteSpecifica) obj;
  1892.                             if(StatiAccordo.bozza.toString().equals(s.getStatoPackage())){
  1893.                                 obj = null;
  1894.                                 find = false;
  1895.                                 throw new DriverRegistroServiziNotFound("Accordo presente in uno stato bozza");
  1896.                             }else{
  1897.                                 // Check fruitori
  1898.                                 List<Fruitore> fruitoriConStatoNonBozza = new ArrayList<Fruitore>();
  1899.                                 while(s.sizeFruitoreList()>0){
  1900.                                     Fruitore tmpF = s.removeFruitore(0);
  1901.                                     if(StatiAccordo.bozza.toString().equals(tmpF.getStatoPackage())==false){
  1902.                                         fruitoriConStatoNonBozza.add(tmpF);
  1903.                                     }
  1904.                                 }
  1905.                                 while(fruitoriConStatoNonBozza.size()>0){
  1906.                                     s.addFruitore(fruitoriConStatoNonBozza.remove(0));
  1907.                                 }
  1908.                             }
  1909.                         }
  1910.                     }
  1911.                     
  1912.                 }catch(DriverRegistroServiziNotFound ed){
  1913.                     // Non presente
  1914.                     this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita (metodo ["+methodName+"]): "+ed.getMessage());
  1915.                     notFoundProblem.append("\nRegistro["+nomeRegInLista+"], ricerca fallita: "+ed.getMessage());
  1916.                 }
  1917.                 catch(java.lang.reflect.InvocationTargetException e){
  1918.                     if(e.getTargetException()!=null){
  1919.                         if(notFoundClassName.equals(e.getTargetException().getClass().getName())){
  1920.                             // Non presente
  1921.                             this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita [NotFound] (metodo ["+methodName+"]): "+e.getTargetException().getMessage());
  1922.                             notFoundProblem.append("\nRegistro["+nomeRegInLista+"], ricerca fallita: "+e.getTargetException().getMessage());
  1923.                         }else if(excClassName.equals(e.getTargetException().getClass().getName())){
  1924.                             // Non presente
  1925.                             this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita [DriverException] (metodo ["+methodName+"]): "+e.getTargetException().getMessage(),e.getTargetException());
  1926.                             if(this.raggiungibilitaTotale)
  1927.                                 throw new DriverRegistroServiziException(e.getTargetException().getMessage(),e.getTargetException());
  1928.                             else
  1929.                                 exceptionProblem.append("\nRegistro["+nomeRegInLista+"], accesso non riuscito: "+e.getTargetException().getMessage());
  1930.                         }else{
  1931.                             this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita [InvTargetExcp.getTarget] (metodo ["+methodName+"]), "+e.getTargetException().getMessage(),e.getTargetException());
  1932.                             if(this.raggiungibilitaTotale)
  1933.                                 throw new DriverRegistroServiziException(e.getTargetException().getMessage(),e.getTargetException());
  1934.                             else
  1935.                                 exceptionProblem.append("\nRegistro["+nomeRegInLista+"], accesso non riuscito: "+e.getTargetException().getMessage());
  1936.                         }
  1937.                     }else{
  1938.                         this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita [InvTargetExcp] (metodo ["+methodName+"]), "+e.getMessage(),e);
  1939.                         if(this.raggiungibilitaTotale)
  1940.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  1941.                         else
  1942.                             exceptionProblem.append("\nRegistro["+nomeRegInLista+"], accesso non riuscito: "+e.getMessage());
  1943.                     }
  1944.                 }catch(Exception e){
  1945.                     // Non presente
  1946.                     this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita, "+e.getMessage(),e);
  1947.                     if(this.raggiungibilitaTotale)
  1948.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  1949.                     else
  1950.                         exceptionProblem.append("\nRegistro["+nomeRegInLista+"], accesso non riuscito: "+e.getMessage());
  1951.                 }
  1952.                 if(find)
  1953.                     break;
  1954.             }

  1956.             this.log.debug("invocazione metodo ["+methodName+"] completata.");
  1957.             if(find){
  1958.                 return obj;
  1959.             }else if(exceptionProblem.length()>0 && notFoundProblem.length()>0){
  1960.                 throw new DriverRegistroServiziException("["+methodName+"]:"+exceptionProblem.toString()+notFoundProblem.toString());
  1961.             }else if(exceptionProblem.length()>0){
  1962.                 throw new DriverRegistroServiziException("["+methodName+"]:"+exceptionProblem.toString());
  1963.             }else if(notFoundProblem.length()>0){
  1964.                 throw new DriverRegistroServiziNotFound("["+methodName+"]:"+notFoundProblem.toString());
  1965.             }else{
  1966.                 throw new DriverRegistroServiziException("["+methodName+"]: ricerca non riuscita in tutti i registri");
  1967.             }
  1968.         }


  1971.     }


  1974.     private org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet getDriver(Connection connectionPdD,String nomeRegistro) throws DriverRegistroServiziException{
  1975.         
  1976.         org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.driverRegistroServizi.get(nomeRegistro);
  1977.         if((driver instanceof DriverRegistroServiziDB)){
  1978.             Boolean useConnectionPdD = this.mappingNomeRegistroToUseConnectionPdD.get(nomeRegistro);
  1979.             if(connectionPdD!=null && useConnectionPdD){
  1980.                 //System.out.println("[REGISTRY] USE CONNECTION VERSIONE!!!!!");
  1981.                 driver = new DriverRegistroServiziDB(connectionPdD, this.log, this.mappingNomeRegistroToTipiDatabase.get(nomeRegistro));
  1982.                 if( ((DriverRegistroServiziDB)driver).create == false){
  1983.                     throw new DriverRegistroServiziException("Inizializzazione DriverRegistroServizi("+nomeRegistro+") con connessione PdD non riuscita");
  1984.                 }
  1985.             }
  1986.             else{
  1987.                 //System.out.println("[REGISTRY] USE DATASOURCE VERSIONE!!!!!");
  1988.             }
  1989.         }
  1990.         
  1991.         return driver;
  1992.     }














  2007.     /* ********  R I C E R C A    S E R V I Z I  (utilizzo dei driver) ******** */ 
  2008.     
  2009.     protected static String _getKey_getAccordoServizioParteComune(IDAccordoFactory idAccordoFactory, IDAccordo idAccordo,Boolean readContenutiAllegati,Boolean readDatiRegistro) throws DriverRegistroServiziException{
  2010.         String uriAccordoServizio = idAccordoFactory.getUriFromIDAccordo(idAccordo);
  2011.         String key = "getAccordoServizio_" + uriAccordoServizio;
  2012.         if(readContenutiAllegati!=null && readContenutiAllegati){
  2013.             key = key + "_READ-ALLEGATI("+readContenutiAllegati.booleanValue()+")";
  2014.         }
  2015.         if(readDatiRegistro!=null && readDatiRegistro){
  2016.             key = key + "_READ-DATI-REGISTRO("+readDatiRegistro.booleanValue()+")";
  2017.         }
  2018.         return key;
  2019.     }
  2020.     public AccordoServizioParteComune getAccordoServizioParteComune(Connection connectionPdD,String nomeRegistro,IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2021.         return getAccordoServizioParteComune(connectionPdD, nomeRegistro, idAccordo, null, null);
  2022.     }
  2023.     public AccordoServizioParteComune getAccordoServizioParteComune(Connection connectionPdD,String nomeRegistro,IDAccordo idAccordo,Boolean readContenutiAllegati,Boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2025.         // Raccolta dati
  2026.         if(idAccordo == null)
  2027.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune]: Parametro non definito");    
  2028.         if(idAccordo.getNome() == null)
  2029.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune]: Nome accordo di servizio non definito"); 
  2030.         
  2031.         // se e' attiva una cache provo ad utilizzarla
  2032.         String key = null;  
  2033.         if(this.cache!=null){
  2034.             key = _getKey_getAccordoServizioParteComune(this.idAccordoFactory, idAccordo, readContenutiAllegati, readDatiRegistro);
  2035.             org.openspcoop2.utils.cache.CacheResponse response = 
  2036.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2037.             if(response != null){
  2038.                 if(response.getException()!=null){
  2039.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2040.                         throw (DriverRegistroServiziNotFound) response.getException();
  2041.                     else
  2042.                         throw (DriverRegistroServiziException) response.getException();
  2043.                 }else{
  2044.                     return ((AccordoServizioParteComune) response.getObject());
  2045.                 }
  2046.             }
  2047.         }


  2050.         // Algoritmo CACHE
  2051.         AccordoServizioParteComune as = null;
  2052.         if(this.cache!=null){
  2053.             if(readDatiRegistro!=null) {
  2054.                 as = (AccordoServizioParteComune) this.getObjectCache(key,"getAccordoServizioParteComune",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo,readDatiRegistro);
  2055.             }else {
  2056.                 as = (AccordoServizioParteComune) this.getObjectCache(key,"getAccordoServizioParteComune",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo);
  2057.             }
  2058.         }else{
  2059.             if(readDatiRegistro!=null) {
  2060.                 as = (AccordoServizioParteComune) this.getObject("getAccordoServizioParteComune",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo,readDatiRegistro);
  2061.             }
  2062.             else {
  2063.                 as = (AccordoServizioParteComune) this.getObject("getAccordoServizioParteComune",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo);
  2064.             }
  2065.         }

  2067.         if(as!=null)
  2068.             return as;
  2069.         else
  2070.             throw new DriverRegistroServiziNotFound("[getAccordoServizio] Accordo di Servizio ["+idAccordo+"] non trovato");



  2074.     }

  2076.     
  2077.     protected static String _getKey_getPortaDominio(String nomePdD) throws DriverRegistroServiziException{
  2078.         return "getPortaDominio_" + nomePdD;
  2079.     }
  2080.     public org.openspcoop2.core.registry.PortaDominio getPortaDominio(Connection connectionPdD,String nomeRegistro,String nomePdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2081.         
  2082.         // Raccolta dati
  2083.         if(nomePdD == null)
  2084.             throw new DriverRegistroServiziException("[getPortaDominio]: Parametro non definito");  

  2086.         // se e' attiva una cache provo ad utilizzarla
  2087.         String key = null;  
  2088.         if(this.cache!=null){
  2089.             key = _getKey_getPortaDominio(nomePdD);
  2090.             org.openspcoop2.utils.cache.CacheResponse response = 
  2091.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2092.             if(response != null){
  2093.                 if(response.getException()!=null){
  2094.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2095.                         throw (DriverRegistroServiziNotFound) response.getException();
  2096.                     else
  2097.                         throw (DriverRegistroServiziException) response.getException();
  2098.                 }else{
  2099.                     return ((PortaDominio) response.getObject());
  2100.                 }
  2101.             }
  2102.         }


  2105.         // Algoritmo CACHE
  2106.         PortaDominio pd = null;
  2107.         if(this.cache!=null){
  2108.             pd = (PortaDominio) this.getObjectCache(key,"getPortaDominio",nomeRegistro,null,connectionPdD,nomePdD);
  2109.         }else{
  2110.             pd = (PortaDominio) this.getObject("getPortaDominio",nomeRegistro,null,connectionPdD,nomePdD);
  2111.         }

  2113.         if(pd!=null)
  2114.             return pd;
  2115.         else
  2116.             throw new DriverRegistroServiziNotFound("[getPortaDominio] Porta di dominio ["+nomePdD+"] non Trovata");

  2118.     }
  2119.     
  2120.     
  2121.     protected static String _getKey_getGruppo(String nomeGruppo) throws DriverRegistroServiziException{
  2122.         return "getGruppo_" + nomeGruppo;
  2123.     }
  2124.     public org.openspcoop2.core.registry.Gruppo getGruppo(Connection connectionPdD,String nomeRegistro,String nomeGruppo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2125.         
  2126.         // Raccolta dati
  2127.         if(nomeGruppo == null)
  2128.             throw new DriverRegistroServiziException("[getGruppo]: Parametro non definito");    
  2129.         IDGruppo idGruppo = new IDGruppo(nomeGruppo);
  2130.         
  2131.         // se e' attiva una cache provo ad utilizzarla
  2132.         String key = null;  
  2133.         if(this.cache!=null){
  2134.             key = _getKey_getGruppo(nomeGruppo);
  2135.             org.openspcoop2.utils.cache.CacheResponse response = 
  2136.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2137.             if(response != null){
  2138.                 if(response.getException()!=null){
  2139.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2140.                         throw (DriverRegistroServiziNotFound) response.getException();
  2141.                     else
  2142.                         throw (DriverRegistroServiziException) response.getException();
  2143.                 }else{
  2144.                     return ((Gruppo) response.getObject());
  2145.                 }
  2146.             }
  2147.         }


  2150.         // Algoritmo CACHE
  2151.         Gruppo gruppo = null;
  2152.         if(this.cache!=null){
  2153.             gruppo = (Gruppo) this.getObjectCache(key,"getGruppo",nomeRegistro,null,connectionPdD,idGruppo);
  2154.         }else{
  2155.             gruppo = (Gruppo) this.getObject("getGruppo",nomeRegistro,null,connectionPdD,idGruppo);
  2156.         }

  2158.         if(gruppo!=null)
  2159.             return gruppo;
  2160.         else
  2161.             throw new DriverRegistroServiziNotFound("[getGruppo] Gruppo ["+nomeGruppo+"] non trovato");

  2163.     }
  2164.     
  2165.     
  2166.     
  2167.     protected static String _getKey_getRuolo(String nomeRuolo) throws DriverRegistroServiziException{
  2168.         return "getRuolo_" + nomeRuolo;
  2169.     }
  2170.     public org.openspcoop2.core.registry.Ruolo getRuolo(Connection connectionPdD,String nomeRegistro,String nomeRuolo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2171.         
  2172.         // Raccolta dati
  2173.         if(nomeRuolo == null)
  2174.             throw new DriverRegistroServiziException("[getRuolo]: Parametro non definito"); 
  2175.         IDRuolo idRuolo = new IDRuolo(nomeRuolo);
  2176.         
  2177.         // se e' attiva una cache provo ad utilizzarla
  2178.         String key = null;  
  2179.         if(this.cache!=null){
  2180.             key = _getKey_getRuolo(nomeRuolo);
  2181.             org.openspcoop2.utils.cache.CacheResponse response = 
  2182.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2183.             if(response != null){
  2184.                 if(response.getException()!=null){
  2185.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2186.                         throw (DriverRegistroServiziNotFound) response.getException();
  2187.                     else
  2188.                         throw (DriverRegistroServiziException) response.getException();
  2189.                 }else{
  2190.                     return ((Ruolo) response.getObject());
  2191.                 }
  2192.             }
  2193.         }


  2196.         // Algoritmo CACHE
  2197.         Ruolo ruolo = null;
  2198.         if(this.cache!=null){
  2199.             ruolo = (Ruolo) this.getObjectCache(key,"getRuolo",nomeRegistro,null,connectionPdD,idRuolo);
  2200.         }else{
  2201.             ruolo = (Ruolo) this.getObject("getRuolo",nomeRegistro,null,connectionPdD,idRuolo);
  2202.         }

  2204.         if(ruolo!=null)
  2205.             return ruolo;
  2206.         else
  2207.             throw new DriverRegistroServiziNotFound("[getRuolo] Ruolo ["+nomeRuolo+"] non trovato");

  2209.     }
  2210.     
  2211.     
  2212.     protected static String _getKey_getScope(String nomeScope) throws DriverRegistroServiziException{
  2213.         return "getScope_" + nomeScope;
  2214.     }
  2215.     public org.openspcoop2.core.registry.Scope getScope(Connection connectionPdD,String nomeRegistro,String nomeScope) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2216.         
  2217.         // Raccolta dati
  2218.         if(nomeScope == null)
  2219.             throw new DriverRegistroServiziException("[getScope]: Parametro non definito"); 
  2220.         IDScope idScope = new IDScope(nomeScope);
  2221.         
  2222.         // se e' attiva una cache provo ad utilizzarla
  2223.         String key = null;  
  2224.         if(this.cache!=null){
  2225.             key = _getKey_getScope(nomeScope);
  2226.             org.openspcoop2.utils.cache.CacheResponse response = 
  2227.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2228.             if(response != null){
  2229.                 if(response.getException()!=null){
  2230.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2231.                         throw (DriverRegistroServiziNotFound) response.getException();
  2232.                     else
  2233.                         throw (DriverRegistroServiziException) response.getException();
  2234.                 }else{
  2235.                     return ((Scope) response.getObject());
  2236.                 }
  2237.             }
  2238.         }


  2241.         // Algoritmo CACHE
  2242.         Scope scope = null;
  2243.         if(this.cache!=null){
  2244.             scope = (Scope) this.getObjectCache(key,"getScope",nomeRegistro,null,connectionPdD,idScope);
  2245.         }else{
  2246.             scope = (Scope) this.getObject("getScope",nomeRegistro,null,connectionPdD,idScope);
  2247.         }

  2249.         if(scope!=null)
  2250.             return scope;
  2251.         else
  2252.             throw new DriverRegistroServiziNotFound("[getScope] Scope ["+nomeScope+"] non trovato");

  2254.     }
  2255.     
  2256.     protected static String _getKey_getSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException{
  2257.         return "getSoggetto_" + idSoggetto.getTipo() +"/" + idSoggetto.getNome();
  2258.     }
  2259.     public Soggetto getSoggetto(Connection connectionPdD,String nomeRegistro,IDSoggetto idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2261.         // Raccolta dati
  2262.         if(idSoggetto==null)
  2263.             throw new DriverRegistroServiziException("[getSoggetto] Parametro Non Valido");
  2264.         String tipoSP = idSoggetto.getTipo();
  2265.         String codiceSP = idSoggetto.getNome();
  2266.         if(tipoSP == null || codiceSP == null)
  2267.             throw new DriverRegistroServiziException("[getSoggetto] Parametri Non Validi");

  2269.         //  se e' attiva una cache provo ad utilizzarla
  2270.         String key = null;  
  2271.         if(this.cache!=null){
  2272.             key = _getKey_getSoggetto(idSoggetto);
  2273.             org.openspcoop2.utils.cache.CacheResponse response = 
  2274.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2275.             if(response != null){
  2276.                 if(response.getException()!=null){
  2277.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2278.                         throw (DriverRegistroServiziNotFound) response.getException();
  2279.                     else
  2280.                         throw (DriverRegistroServiziException) response.getException();
  2281.                 }else{
  2282.                     return ((Soggetto) response.getObject());
  2283.                 }
  2284.             }
  2285.         }

  2287.         // Algoritmo CACHE
  2288.         Soggetto soggetto = null;
  2289.         if(this.cache!=null){
  2290.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggetto",nomeRegistro,null,connectionPdD,idSoggetto);
  2291.         }else{
  2292.             soggetto = (Soggetto) this.getObject("getSoggetto",nomeRegistro,null,connectionPdD,idSoggetto);
  2293.         }

  2295.         if(soggetto!=null)
  2296.             return soggetto;
  2297.         else
  2298.             throw new DriverRegistroServiziNotFound("[getSoggetto] Soggetto non trovato");

  2300.     }

  2302.     protected static String _toKey_getSoggettoByCredenzialiBasicPrefix() {
  2303.         return "getSoggettoByCredenzialiBasic_";
  2304.     }
  2305.     private String _getKey_getSoggettoByCredenzialiBasic(String user,String password) throws DriverRegistroServiziException{
  2306.         return _toKey_getSoggettoByCredenzialiBasicPrefix() + user +"_" + password;
  2307.     }
  2308.     public Soggetto getSoggettoByCredenzialiBasic(Connection connectionPdD,String nomeRegistro,String user,String password, CryptConfig config) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2310.         // Raccolta dati
  2311.         if(user==null)
  2312.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiBasic] Parametro user Non Valido");
  2313.         if(password==null)
  2314.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiBasic] Parametro password Non Valido");

  2316.         //  se e' attiva una cache provo ad utilizzarla
  2317.         String key = null;  
  2318.         if(this.cache!=null){
  2319.             key = this._getKey_getSoggettoByCredenzialiBasic(user, password);
  2320.             org.openspcoop2.utils.cache.CacheResponse response = 
  2321.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2322.             if(response != null){
  2323.                 if(response.getException()!=null){
  2324.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2325.                         throw (DriverRegistroServiziNotFound) response.getException();
  2326.                     else
  2327.                         throw (DriverRegistroServiziException) response.getException();
  2328.                 }else{
  2329.                     return ((Soggetto) response.getObject());
  2330.                 }
  2331.             }
  2332.         }

  2334.         // Algoritmo CACHE
  2335.         Soggetto soggetto = null;
  2336.         if(this.cache!=null){
  2337.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggettoByCredenzialiBasic",nomeRegistro,null,connectionPdD,user,password,config);
  2338.         }else{
  2339.             soggetto = (Soggetto) this.getObject("getSoggettoByCredenzialiBasic",nomeRegistro,null,connectionPdD,user,password,config);
  2340.         }

  2342.         if(soggetto!=null)
  2343.             return soggetto;
  2344.         else
  2345.             throw new DriverRegistroServiziNotFound("[getSoggettoByCredenzialiBasic] Soggetto non Trovato");

  2347.     }
  2348.     
  2349.     protected static String _toKey_getSoggettoByCredenzialiApiKeyPrefix(boolean appId) {
  2350.         return (appId ? "getSoggettoByCredenzialiMultipleApiKey_" : "getSoggettoByCredenzialiApiKey_");
  2351.     }
  2352.     private String _getKey_getSoggettoByCredenzialiApiKey(String user,String password, boolean appId) throws DriverRegistroServiziException{
  2353.         return _toKey_getSoggettoByCredenzialiApiKeyPrefix(appId) + user +"_" + password;
  2354.     }
  2355.     public Soggetto getSoggettoByCredenzialiApiKey(Connection connectionPdD,String nomeRegistro,String user,String password, boolean appId, CryptConfig config) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2357.         // Raccolta dati
  2358.         if(user==null)
  2359.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiApiKey] Parametro user Non Valido");
  2360.         if(password==null)
  2361.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiApiKey] Parametro password Non Valido");

  2363.         //  se e' attiva una cache provo ad utilizzarla
  2364.         String key = null;  
  2365.         if(this.cache!=null){
  2366.             key = this._getKey_getSoggettoByCredenzialiApiKey(user, password, appId);
  2367.             org.openspcoop2.utils.cache.CacheResponse response = 
  2368.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2369.             if(response != null){
  2370.                 if(response.getException()!=null){
  2371.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2372.                         throw (DriverRegistroServiziNotFound) response.getException();
  2373.                     else
  2374.                         throw (DriverRegistroServiziException) response.getException();
  2375.                 }else{
  2376.                     return ((Soggetto) response.getObject());
  2377.                 }
  2378.             }
  2379.         }

  2381.         // Algoritmo CACHE
  2382.         Soggetto soggetto = null;
  2383.         if(this.cache!=null){
  2384.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggettoByCredenzialiApiKey",nomeRegistro,null,connectionPdD,user,password,appId,config);
  2385.         }else{
  2386.             soggetto = (Soggetto) this.getObject("getSoggettoByCredenzialiApiKey",nomeRegistro,null,connectionPdD,user,password,appId,config);
  2387.         }

  2389.         if(soggetto!=null)
  2390.             return soggetto;
  2391.         else
  2392.             throw new DriverRegistroServiziNotFound("[getSoggettoByCredenzialiApiKey] Soggetto non Trovato");

  2394.     }
  2395.     
  2396.     protected static String _toKey_getSoggettoByCredenzialiSslPrefix(boolean separator) {
  2397.         return "getSoggettoByCredenzialiSsl"+(separator?"_":"");
  2398.     }
  2399.     private String _getKey_getSoggettoByCredenzialiSsl(String aSubject, String Issuer){
  2400.         String key = _toKey_getSoggettoByCredenzialiSslPrefix(false);
  2401.         key = key +"_subject:"+aSubject;
  2402.         if(Issuer!=null) {
  2403.             key = key +"_issuer:"+Issuer;
  2404.         }
  2405.         else {
  2406.             key = key +"_issuer:nonDefinito";
  2407.         }
  2408.         return key;
  2409.     }
  2410.     public Soggetto getSoggettoByCredenzialiSsl(Connection connectionPdD,String nomeRegistro,String subject, String issuer) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2412.         // Raccolta dati
  2413.         if(subject==null)
  2414.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiSsl] Parametro subject Non Valido");

  2416.         //  se e' attiva una cache provo ad utilizzarla
  2417.         String key = null;  
  2418.         if(this.cache!=null){
  2419.             key = this._getKey_getSoggettoByCredenzialiSsl(subject, issuer);
  2420.             org.openspcoop2.utils.cache.CacheResponse response = 
  2421.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2422.             if(response != null){
  2423.                 if(response.getException()!=null){
  2424.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2425.                         throw (DriverRegistroServiziNotFound) response.getException();
  2426.                     else
  2427.                         throw (DriverRegistroServiziException) response.getException();
  2428.                 }else{
  2429.                     return ((Soggetto) response.getObject());
  2430.                 }
  2431.             }
  2432.         }

  2434.         // Algoritmo CACHE
  2435.         Class<?>[] classArguments = new Class[] {String.class, String.class};
  2436.         Object[]values = new Object[] {subject,issuer}; // passo gli argomenti tramite array poich' aIssuer puo' essere null
  2437.         Soggetto soggetto = null;
  2438.         if(this.cache!=null){
  2439.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggettoByCredenzialiSsl",nomeRegistro,null,connectionPdD,classArguments, values);
  2440.         }else{
  2441.             soggetto = (Soggetto) this.getObject("getSoggettoByCredenzialiSsl",nomeRegistro,null,connectionPdD,classArguments, values);
  2442.         }

  2444.         if(soggetto!=null)
  2445.             return soggetto;
  2446.         else
  2447.             throw new DriverRegistroServiziNotFound("[getSoggettoByCredenzialiSsl] Soggetto non Trovato");

  2449.     }
  2450.     
  2451.     protected static String _toKey_getSoggettoByCredenzialiSslCertPrefix(boolean separator) {
  2452.         return "getSoggettoByCredenzialiSslCert"+(separator?"_":"");
  2453.     }
  2454.     private String _getKey_getSoggettoByCredenzialiSsl(CertificateInfo certificate, boolean strictVerifier) throws DriverRegistroServiziException{
  2455.         try {
  2456.             String key = _toKey_getSoggettoByCredenzialiSslCertPrefix(false);
  2457.             key = key +"_cert:"+certificate.digestBase64Encoded();
  2458.             key = key +"_strictVerifier:"+strictVerifier;
  2459.             return key;
  2460.         }catch(Exception e) {
  2461.             throw new DriverRegistroServiziException(e.getMessage(),e);
  2462.         }
  2463.     }
  2464.     public Soggetto getSoggettoByCredenzialiSsl(Connection connectionPdD,String nomeRegistro,CertificateInfo certificate, boolean strictVerifier) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2466.         // Raccolta dati
  2467.         if(certificate==null)
  2468.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiSsl] Parametro certificate Non Valido");

  2470.         //  se e' attiva una cache provo ad utilizzarla
  2471.         String key = null;  
  2472.         if(this.cache!=null){
  2473.             key = this._getKey_getSoggettoByCredenzialiSsl(certificate, strictVerifier);
  2474.             org.openspcoop2.utils.cache.CacheResponse response = 
  2475.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2476.             if(response != null){
  2477.                 if(response.getException()!=null){
  2478.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2479.                         throw (DriverRegistroServiziNotFound) response.getException();
  2480.                     else
  2481.                         throw (DriverRegistroServiziException) response.getException();
  2482.                 }else{
  2483.                     return ((Soggetto) response.getObject());
  2484.                 }
  2485.             }
  2486.         }

  2488.         // Algoritmo CACHE
  2489.         Class<?>[] classArguments = new Class[] {CertificateInfo.class, boolean.class};
  2490.         Object[]values = new Object[] {certificate , strictVerifier};
  2491.         Soggetto soggetto = null;
  2492.         if(this.cache!=null){
  2493.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggettoByCredenzialiSsl",nomeRegistro,null,connectionPdD, classArguments, values);
  2494.         }else{
  2495.             soggetto = (Soggetto) this.getObject("getSoggettoByCredenzialiSsl",nomeRegistro,null,connectionPdD, classArguments, values);
  2496.         }

  2498.         if(soggetto!=null)
  2499.             return soggetto;
  2500.         else
  2501.             throw new DriverRegistroServiziNotFound("[getSoggettoByCredenzialiSsl] Soggetto non Trovato");

  2503.     }
  2504.     
  2505.     protected static String _toKey_getSoggettoByCredenzialiPrincipalPrefix() {
  2506.         return "getSoggettoByCredenzialiPrincipal_";
  2507.     }
  2508.     private String _getKey_getSoggettoByCredenzialiPrincipal(String principal) throws DriverRegistroServiziException{
  2509.         return _toKey_getSoggettoByCredenzialiPrincipalPrefix() + principal;
  2510.     }
  2511.     public Soggetto getSoggettoByCredenzialiPrincipal(Connection connectionPdD,String nomeRegistro,String principal) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2513.         // Raccolta dati
  2514.         if(principal==null)
  2515.             throw new DriverRegistroServiziException("[getSoggettoByCredenzialiPrincipal] Parametro principal Non Valido");

  2517.         //  se e' attiva una cache provo ad utilizzarla
  2518.         String key = null;  
  2519.         if(this.cache!=null){
  2520.             key = this._getKey_getSoggettoByCredenzialiPrincipal(principal);
  2521.             org.openspcoop2.utils.cache.CacheResponse response = 
  2522.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2523.             if(response != null){
  2524.                 if(response.getException()!=null){
  2525.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2526.                         throw (DriverRegistroServiziNotFound) response.getException();
  2527.                     else
  2528.                         throw (DriverRegistroServiziException) response.getException();
  2529.                 }else{
  2530.                     return ((Soggetto) response.getObject());
  2531.                 }
  2532.             }
  2533.         }

  2535.         // Algoritmo CACHE
  2536.         Soggetto soggetto = null;
  2537.         if(this.cache!=null){
  2538.             soggetto = (Soggetto) this.getObjectCache(key,"getSoggettoByCredenzialiPrincipal",nomeRegistro,null,connectionPdD,principal);
  2539.         }else{
  2540.             soggetto = (Soggetto) this.getObject("getSoggettoByCredenzialiPrincipal",nomeRegistro,null,connectionPdD,principal);
  2541.         }

  2543.         if(soggetto!=null)
  2544.             return soggetto;
  2545.         else
  2546.             throw new DriverRegistroServiziNotFound("[getSoggettoByCredenzialiPrincipal] Soggetto non Trovato");

  2548.     }
  2549.     
  2550.     protected static String _toKey_getAccordoServizioParteSpecificaPrefix(IDServizio idService) throws DriverRegistroServiziException{
  2551.         String servizio = idService.getNome();
  2552.         String tipoServizio = idService.getTipo();
  2553.         Integer versioneServizio = idService.getVersione();
  2554.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  2555.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  2556.         
  2557.         String key = "getServizio_"+ tipoSogg +"/" + nomeSogg +
  2558.                 "_" + tipoServizio + "/" + servizio+"/"+versioneServizio.intValue();
  2559.         
  2560.         return key;
  2561.     }
  2562.     protected static String _getKey_getAccordoServizioParteSpecifica(IDServizio idService,Boolean readContenutiAllegati) throws DriverRegistroServiziException{
  2563.         String key = _toKey_getAccordoServizioParteSpecificaPrefix(idService);
  2564.         String azione = idService.getAzione();
  2565.         if(azione !=null)
  2566.             key = key + "_" + azione;      
  2567.         if(readContenutiAllegati!=null){
  2568.             key = key + "_READ-ALLEGATI("+readContenutiAllegati.booleanValue()+")";
  2569.         }
  2570.         return key;
  2571.     }
  2572.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(Connection connectionPdD,String nomeRegistro,IDServizio idService) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2573.         return getAccordoServizioParteSpecifica(connectionPdD,nomeRegistro, idService, null);
  2574.     }
  2575.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(Connection connectionPdD,String nomeRegistro,IDServizio idService,Boolean readContenutiAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2577.         // Raccolta dati
  2578.         if(idService == null)
  2579.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Parametro Non Valido");
  2580.         String servizio = idService.getNome();
  2581.         String tipoServizio = idService.getTipo();
  2582.         Integer versioneServizio = idService.getVersione();
  2583.         if(servizio == null || tipoServizio == null || versioneServizio==null)
  2584.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Parametri (Servizio) Non Validi");
  2585.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  2586.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  2587.         if(tipoSogg == null || nomeSogg == null)
  2588.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Parametri (Soggetto) Non Validi");

  2590.         //  se e' attiva una cache provo ad utilizzarla
  2591.         String key = null;  
  2592.         if(this.cache!=null){
  2593.             key = _getKey_getAccordoServizioParteSpecifica(idService, readContenutiAllegati);
  2594.             org.openspcoop2.utils.cache.CacheResponse response = 
  2595.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2596.             if(response != null){
  2597.                 if(response.getException()!=null){
  2598.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2599.                         throw (DriverRegistroServiziNotFound) response.getException();
  2600.                     else
  2601.                         throw (DriverRegistroServiziException) response.getException();
  2602.                 }else{
  2603.                     return ((AccordoServizioParteSpecifica) response.getObject());
  2604.                 }
  2605.             }
  2606.         }

  2608.         // Algoritmo CACHE
  2609.         AccordoServizioParteSpecifica serv = null;
  2610.         if(this.cache!=null){
  2611.             serv = (AccordoServizioParteSpecifica) this.getObjectCache(key,"getAccordoServizioParteSpecifica",nomeRegistro,readContenutiAllegati,connectionPdD,idService);
  2612.         }else{
  2613.             serv = (AccordoServizioParteSpecifica) this.getObject("getAccordoServizioParteSpecifica",nomeRegistro,readContenutiAllegati,connectionPdD,idService);
  2614.         }

  2616.         if(serv!=null)
  2617.             return serv;
  2618.         else
  2619.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica] Servizio non trovato");
  2620.     }

  2622.     protected static String _toKey_getAccordoServizioParteSpecifica_ServizioCorrelato_prefix() throws DriverRegistroServiziException{
  2623.         return "getServizioCorrelato(RicercaPerAccordo)_";
  2624.     }
  2625.     protected static String _toKey_getAccordoServizioParteSpecifica_ServizioCorrelato(IDAccordoFactory idAccordoFactory, IDAccordo idAccordo) throws DriverRegistroServiziException{
  2626.         return "_"+idAccordoFactory.getUriFromIDAccordo(idAccordo)+"_";
  2627.     }
  2628.     private String _getKey_getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto, IDAccordo idAccordo,Boolean readContenutiAllegati) throws DriverRegistroServiziException{
  2629.         String key = _toKey_getAccordoServizioParteSpecifica_ServizioCorrelato_prefix() + idSoggetto.getTipo() +"/" + idSoggetto.getNome();
  2630.         key = key + _toKey_getAccordoServizioParteSpecifica_ServizioCorrelato(this.idAccordoFactory, idAccordo);
  2631.         if(readContenutiAllegati!=null){
  2632.             key = key + "READ-ALLEGATI("+readContenutiAllegati.booleanValue()+")";
  2633.         }
  2634.         return key;
  2635.     }
  2636.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(Connection connectionPdD,String nomeRegistro,IDSoggetto idSoggetto, IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2637.         return getAccordoServizioParteSpecifica_ServizioCorrelato(connectionPdD,nomeRegistro, idSoggetto, idAccordo,null);
  2638.     }
  2639.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(Connection connectionPdD,String nomeRegistro,
  2640.             IDSoggetto idSoggetto, IDAccordo idAccordo,Boolean readContenutiAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2642.         // Raccolta dati
  2643.         if(idSoggetto == null)
  2644.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Parametro Non Valido");
  2645.         String nome = idSoggetto.getNome();
  2646.         String tipo = idSoggetto.getTipo();
  2647.         if(tipo == null || nome == null || idAccordo==null)
  2648.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Parametri Non Validi");

  2650.         //  se e' attiva una cache provo ad utilizzarla
  2651.         String key = null;  
  2652.         if(this.cache!=null){
  2653.             key = this._getKey_getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto, idAccordo, readContenutiAllegati);
  2654.             org.openspcoop2.utils.cache.CacheResponse response = 
  2655.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2656.             if(response != null){
  2657.                 if(response.getException()!=null){
  2658.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2659.                         throw (DriverRegistroServiziNotFound) response.getException();
  2660.                     else
  2661.                         throw (DriverRegistroServiziException) response.getException();
  2662.                 }else{
  2663.                     return ((AccordoServizioParteSpecifica) response.getObject());
  2664.                 }
  2665.             }
  2666.         }

  2668.         // Algoritmo CACHE
  2669.         AccordoServizioParteSpecifica servCorrelato = null;
  2670.         if(this.cache!=null){
  2671.             servCorrelato = (AccordoServizioParteSpecifica) this.getObjectCache(key,"getAccordoServizioParteSpecifica_ServizioCorrelato",nomeRegistro,readContenutiAllegati,connectionPdD,idSoggetto,idAccordo);
  2672.         }else{
  2673.             servCorrelato = (AccordoServizioParteSpecifica) this.getObject("getAccordoServizioParteSpecifica_ServizioCorrelato",nomeRegistro,readContenutiAllegati,connectionPdD,idSoggetto,idAccordo);
  2674.         }

  2676.         if(servCorrelato!=null)
  2677.             return servCorrelato;
  2678.         else
  2679.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica_ServizioCorrelato] ServizioCorrelato non trovato");
  2680.     }
  2681.     
  2682.     protected static String _getKey_getAccordoCooperazione(IDAccordoCooperazioneFactory idAccordoCooperazioneFactory, IDAccordoCooperazione idAccordo,Boolean readContenutiAllegati) throws DriverRegistroServiziException{
  2683.         String uriAccordoCooperazione = idAccordoCooperazioneFactory.getUriFromIDAccordo(idAccordo);

  2685.         String key = "getAccordoCooperazione_" + uriAccordoCooperazione;   
  2686.         if(readContenutiAllegati!=null){
  2687.             key = key + "_READ-ALLEGATI("+readContenutiAllegati.booleanValue()+")";
  2688.         }
  2689.         return key;
  2690.     }
  2691.     public AccordoCooperazione getAccordoCooperazione(Connection connectionPdD,String nomeRegistro,IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2692.         return getAccordoCooperazione(connectionPdD,nomeRegistro, idAccordo, null);
  2693.     }
  2694.     public AccordoCooperazione getAccordoCooperazione(Connection connectionPdD,String nomeRegistro,IDAccordoCooperazione idAccordo,Boolean readContenutiAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2696.         // Raccolta dati
  2697.         if(idAccordo == null)
  2698.             throw new DriverRegistroServiziException("[getAccordoCooperazione]: Parametro non definito");   
  2699.         if(idAccordo.getNome() == null)
  2700.             throw new DriverRegistroServiziException("[getAccordoCooperazione]: Nome accordo di servizio non definito");    
  2701.         
  2702.         // se e' attiva una cache provo ad utilizzarla
  2703.         String key = null;  
  2704.         if(this.cache!=null){
  2705.             key = _getKey_getAccordoCooperazione(this.idAccordoCooperazioneFactory, idAccordo, readContenutiAllegati);
  2706.             org.openspcoop2.utils.cache.CacheResponse response = 
  2707.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2708.             if(response != null){
  2709.                 if(response.getException()!=null){
  2710.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2711.                         throw (DriverRegistroServiziNotFound) response.getException();
  2712.                     else
  2713.                         throw (DriverRegistroServiziException) response.getException();
  2714.                 }else{
  2715.                     return ((AccordoCooperazione) response.getObject());
  2716.                 }
  2717.             }
  2718.         }

  2720.         // Algoritmo CACHE
  2721.         AccordoCooperazione ac = null;
  2722.         if(this.cache!=null){
  2723.             ac = (AccordoCooperazione) this.getObjectCache(key,"getAccordoCooperazione",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo);
  2724.         }else{
  2725.             ac = (AccordoCooperazione) this.getObject("getAccordoCooperazione",nomeRegistro,readContenutiAllegati,connectionPdD,idAccordo);
  2726.         }

  2728.         if(ac!=null)
  2729.             return ac;
  2730.         else
  2731.             throw new DriverRegistroServiziNotFound("[getAccordoCooperazione] Accordo non trovato");
  2732.     }

  2734.     
  2735.     
  2736.     
  2737.     
  2738.     /* ********  R I C E R C A  I D   E L E M E N T I   P R I M I T I V I  ******** */
  2739.     
  2740.     protected static String _toKey_getAllIdPorteDominio_method(){
  2741.         return "getAllIdPorteDominio";
  2742.     }
  2743.     @SuppressWarnings("unchecked")
  2744.     public List<String> getAllIdPorteDominio(Connection connectionPdD,String nomeRegistro,FiltroRicerca filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2745.         return (List<String>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdPorteDominio_method());
  2746.     }
  2747.     
  2748.     protected static String _toKey_getAllIdGruppi_method(){
  2749.         return "getAllIdGruppi";
  2750.     }
  2751.     @SuppressWarnings("unchecked")
  2752.     public List<IDGruppo> getAllIdGruppi(Connection connectionPdD,String nomeRegistro,FiltroRicercaGruppi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2753.         return (List<IDGruppo>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdGruppi_method());
  2754.     }
  2755.     
  2756.     protected static String _toKey_getAllIdRuoli_method(){
  2757.         return "getAllIdRuoli";
  2758.     }
  2759.     @SuppressWarnings("unchecked")
  2760.     public List<IDRuolo> getAllIdRuoli(Connection connectionPdD,String nomeRegistro,FiltroRicercaRuoli filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2761.         return (List<IDRuolo>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdRuoli_method());
  2762.     }
  2763.     
  2764.     protected static String _toKey_getAllIdScope_method(){
  2765.         return "getAllIdScope";
  2766.     }
  2767.     @SuppressWarnings("unchecked")
  2768.     public List<IDScope> getAllIdScope(Connection connectionPdD,String nomeRegistro,FiltroRicercaScope filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2769.         return (List<IDScope>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdScope_method());
  2770.     }

  2772.     protected static String _toKey_getAllIdSoggetti_method(){
  2773.         return "getAllIdSoggetti";
  2774.     }
  2775.     @SuppressWarnings("unchecked")
  2776.     public List<IDSoggetto> getAllIdSoggetti(Connection connectionPdD,String nomeRegistro, FiltroRicercaSoggetti filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2777.         return (List<IDSoggetto>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdSoggetti_method());
  2778.     }
  2779.     
  2780.     protected static String _toKey_getAllIdAccordiCooperazione_method(){
  2781.         return "getAllIdAccordiCooperazione";
  2782.     }
  2783.     @SuppressWarnings("unchecked")
  2784.     public List<IDAccordoCooperazione> getAllIdAccordiCooperazione(Connection connectionPdD,String nomeRegistro, FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2785.         return (List<IDAccordoCooperazione>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdAccordiCooperazione_method());
  2786.     }
  2787.     
  2788.     protected static String _toKey_getAllIdAccordiServizioParteComune_method(){
  2789.         return "getAllIdAccordiServizioParteComune";
  2790.     }
  2791.     @SuppressWarnings("unchecked")
  2792.     public List<IDAccordo> getAllIdAccordiServizioParteComune(Connection connectionPdD,String nomeRegistro, FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2793.         return (List<IDAccordo>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdAccordiServizioParteComune_method());
  2794.     }
  2795.     
  2796.     protected static String _toKey_getAllIdPortType_method(){
  2797.         return "getAllIdPortType";
  2798.     }
  2799.     @SuppressWarnings("unchecked")
  2800.     public List<IDPortType> getAllIdPortType(Connection connectionPdD,String nomeRegistro, FiltroRicercaPortTypes filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2801.         return (List<IDPortType>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdPortType_method());
  2802.     }
  2803.     
  2804.     protected static String _toKey_getAllIdAzionePortType_method(){
  2805.         return "getAllIdAzionePortType";
  2806.     }
  2807.     @SuppressWarnings("unchecked")
  2808.     public List<IDPortTypeAzione> getAllIdAzionePortType(Connection connectionPdD, String nomeRegistro, FiltroRicercaOperations filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2809.         return (List<IDPortTypeAzione>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdAzionePortType_method());
  2810.     }
  2811.     
  2812.     protected static String _toKey_getAllIdAzione_method(){
  2813.         return "getAllIdAzioneAccordo";
  2814.     }
  2815.     @SuppressWarnings("unchecked")
  2816.     public List<IDAccordoAzione> getAllIdAzioneAccordo(Connection connectionPdD, String nomeRegistro, FiltroRicercaAzioni filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2817.         return (List<IDAccordoAzione>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdAzione_method());
  2818.     }
  2819.     
  2820.     protected static String _toKey_getAllIdResource_method(){
  2821.         return "getAllIdResource";
  2822.     }
  2823.     @SuppressWarnings("unchecked")
  2824.     public List<IDResource> getAllIdResource(Connection connectionPdD, String nomeRegistro, FiltroRicercaResources filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2825.         return (List<IDResource>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdResource_method());
  2826.     }
  2827.     
  2828.     protected static String _toKey_getAllIdServizi_method(){
  2829.         return "getAllIdServizi";
  2830.     }
  2831.     @SuppressWarnings("unchecked")
  2832.     public List<IDServizio> getAllIdServizi(Connection connectionPdD, String nomeRegistro, FiltroRicercaServizi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2833.         return (List<IDServizio>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdServizi_method());
  2834.     }
  2835.     
  2836.     protected static String _toKey_getAllIdFruizioniServizio_method(){
  2837.         return "getAllIdFruizioniServizio";
  2838.     }
  2839.     @SuppressWarnings("unchecked")
  2840.     public List<IDFruizione> getAllIdFruizioniServizio(Connection connectionPdD, String nomeRegistro, FiltroRicercaFruizioniServizio filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2841.         return (List<IDFruizione>) _getAllIdEngine(connectionPdD, nomeRegistro, filtroRicerca, _toKey_getAllIdFruizioniServizio_method());
  2842.     }
  2843.     
  2844.     private List<?> _getAllIdEngine(Connection connectionPdD,String nomeRegistro,Object filtroRicerca,String nomeMetodo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2845.         
  2846.         // Raccolta dati
  2847.         if(filtroRicerca == null)
  2848.             throw new DriverRegistroServiziException("["+nomeMetodo+"]: Parametro non definito");   

  2850.         // se e' attiva una cache provo ad utilizzarla
  2851.         String key = null;  
  2852.         if(this.cache!=null){
  2853.             key = nomeMetodo+"_" + filtroRicerca.toString();   
  2854.             org.openspcoop2.utils.cache.CacheResponse response = 
  2855.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2856.             if(response != null){
  2857.                 if(response.getException()!=null){
  2858.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2859.                         throw (DriverRegistroServiziNotFound) response.getException();
  2860.                     else
  2861.                         throw (DriverRegistroServiziException) response.getException();
  2862.                 }else{
  2863.                     return ((List<?>) response.getObject());
  2864.                 }
  2865.             }
  2866.         }

  2868.         // Algoritmo CACHE
  2869.         List<?> list = null;
  2870.         if(this.cache!=null){
  2871.             list = (List<?>) this.getObjectCache(key,nomeMetodo,nomeRegistro,null,connectionPdD,filtroRicerca);
  2872.         }else{
  2873.             list = (List<?>) this.getObject(nomeMetodo,nomeRegistro,null,connectionPdD,filtroRicerca);
  2874.         }

  2876.         if(list!=null)
  2877.             return list;
  2878.         else
  2879.             throw new DriverRegistroServiziNotFound("["+nomeMetodo+"] Elementi non trovati");
  2880.     }
  2881.     
  2882.     
  2883.     
  2884.     
  2885.     
  2886.     /* ********  R I C E R C A  D O C U M E N T I  ******** */
  2887.     
  2888.     protected static String _toKey_prefixGetAllegatoAccordoServizioParteComune(IDAccordo idAccordo){
  2889.         return "getAllegatoAccordoServizioParteComune_"+idAccordo.toString()+"_";
  2890.     }
  2891.     protected static String getKeyGetAllegatoAccordoServizioParteComune(IDAccordo idAccordo, RuoliDocumento ruolo, Object tipo, String nome){
  2892.         StringBuilder key = new StringBuilder(_toKey_prefixGetAllegatoAccordoServizioParteComune(idAccordo));
  2893.         key.append(ruolo.toString());
  2894.         if(tipo!=null) {
  2895.             key.append("_").append(tipo.toString());
  2896.         }
  2897.         key.append("_").append(nome);
  2898.         return key.toString();
  2899.     }
  2900.     
  2901.     protected Documento getAllegato(Connection connectionPdD, String nomeRegistro, IDAccordo idAccordo, String nome,
  2902.             RequestInfo requestInfo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2903.         return _getAllegatoAccordoServizioParteComune(connectionPdD, nomeRegistro, "getAllegato", 
  2904.                 idAccordo,
  2905.                 RuoliDocumento.allegato, null, nome,
  2906.                 requestInfo);
  2907.     }
  2908.     protected Documento getSpecificaSemiformale(Connection connectionPdD, String nomeRegistro, IDAccordo idAccordo, TipiDocumentoSemiformale tipo, String nome,
  2909.             RequestInfo requestInfo)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2910.         return _getAllegatoAccordoServizioParteComune(connectionPdD, nomeRegistro, "getSpecificaSemiformale", 
  2911.                 idAccordo,
  2912.                 RuoliDocumento.specificaSemiformale, tipo, nome,
  2913.                 requestInfo);
  2914.     }
  2915.     
  2916.     private Documento _getAllegatoAccordoServizioParteComune(Connection connectionPdD, String nomeRegistro, String nomeMetodo, 
  2917.             IDAccordo idAccordo,
  2918.             RuoliDocumento ruolo, Object tipo, String nome,
  2919.             RequestInfo requestInfo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  2920.                     
  2921.         String key = getKeyGetAllegatoAccordoServizioParteComune(idAccordo, ruolo, tipo, nome);   
  2922.         
  2923.         boolean useRequestInfo = requestInfo!=null && requestInfo.getRequestConfig()!=null;
  2924.         if(useRequestInfo) {
  2925.             Documento doc = requestInfo.getRequestConfig().getAllegatoApi(key);
  2926.             if(doc!=null) {
  2927.                 return doc;
  2928.             }
  2929.         }
  2930.         
  2931.         Documento doc = _getAllegatoAccordoServizioParteComune(connectionPdD, nomeRegistro, nomeMetodo, 
  2932.                 idAccordo,
  2933.                 ruolo, tipo, nome,
  2934.                 key);
  2935.         if(useRequestInfo && requestInfo!=null) {
  2936.             requestInfo.getRequestConfig().addAllegatoApi(key, doc, 
  2937.                     requestInfo.getIdTransazione());
  2938.         }
  2939.         return doc;
  2940.     }
  2941.     private Documento _getAllegatoAccordoServizioParteComune(Connection connectionPdD, String nomeRegistro, String nomeMetodo, 
  2942.             IDAccordo idAccordo,
  2943.             RuoliDocumento ruolo, Object tipo, String nome,
  2944.             String key) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  2945.         
  2946.         // Raccolta dati
  2947.         if(idAccordo == null || ruolo==null || nome == null)
  2948.             throw new DriverRegistroServiziException("["+nomeMetodo+"]: Parametri non definito");
  2949.         if(!RuoliDocumento.allegato.equals(ruolo)) {
  2950.             if(tipo==null) {
  2951.                 throw new DriverRegistroServiziException("["+nomeMetodo+"]: Tipo documento definito");
  2952.             }
  2953.         }

  2955.         // se e' attiva una cache provo ad utilizzarla
  2956.         if(this.cache!=null){
  2957.             org.openspcoop2.utils.cache.CacheResponse response = 
  2958.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  2959.             if(response != null){
  2960.                 if(response.getException()!=null){
  2961.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  2962.                         throw (DriverRegistroServiziNotFound) response.getException();
  2963.                     else
  2964.                         throw (DriverRegistroServiziException) response.getException();
  2965.                 }else{
  2966.                     return ((Documento) response.getObject());
  2967.                 }
  2968.             }
  2969.         }

  2971.         // Algoritmo CACHE
  2972.         Documento documento = null;
  2973.         if(RuoliDocumento.allegato.equals(ruolo)) {
  2974.             if(this.cache!=null){
  2975.                 documento = (Documento) this.getObjectCache(key,nomeMetodo,nomeRegistro,null,connectionPdD, idAccordo, nome);
  2976.             }else{
  2977.                 documento = (Documento) this.getObject(nomeMetodo,nomeRegistro,null,connectionPdD, idAccordo, nome);
  2978.             }
  2979.         }
  2980.         else {
  2981.             if(this.cache!=null){
  2982.                 documento = (Documento) this.getObjectCache(key,nomeMetodo,nomeRegistro,null,connectionPdD, idAccordo, tipo, nome);
  2983.             }else{
  2984.                 documento = (Documento) this.getObject(nomeMetodo,nomeRegistro,null,connectionPdD, idAccordo, tipo, nome);
  2985.             }
  2986.         }

  2988.         if(documento!=null)
  2989.             return documento;
  2990.         else
  2991.             throw new DriverRegistroServiziNotFound("["+nomeMetodo+"] Documento non trovato");
  2992.         
  2993.     }
  2994.     
  2995.     
  2996.     
  2997.     protected static String _toKey_prefixGetAllegatoAccordoServizioParteSpecifica(IDServizio idServizio){
  2998.         return "getAllegatoAccordoServizioParteSpecifica_"+idServizio.toString(false)+"_";
  2999.     }
  3000.     protected static String getKeyGetAllegatoAccordoServizioParteSpecifica(IDServizio idServizio, RuoliDocumento ruolo, Object tipo, String nome){
  3001.         StringBuilder key = new StringBuilder(_toKey_prefixGetAllegatoAccordoServizioParteSpecifica(idServizio));
  3002.         key.append(ruolo.toString());
  3003.         if(tipo!=null) {
  3004.             key.append("_").append(tipo.toString());
  3005.         }
  3006.         key.append("_").append(nome);
  3007.         return key.toString();
  3008.     }
  3009.     
  3010.     protected Documento getAllegato(Connection connectionPdD, String nomeRegistro, IDServizio idServizio, String nome,
  3011.             RequestInfo requestInfo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  3012.         return _getAllegatoAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, "getAllegato", 
  3013.                 idServizio,
  3014.                 RuoliDocumento.allegato, null, nome,
  3015.                 requestInfo);
  3016.     }
  3017.     protected Documento getSpecificaSemiformale(Connection connectionPdD, String nomeRegistro, IDServizio idServizio, TipiDocumentoSemiformale tipo, String nome,
  3018.             RequestInfo requestInfo)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  3019.         return _getAllegatoAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, "getSpecificaSemiformale", 
  3020.                 idServizio,
  3021.                 RuoliDocumento.specificaSemiformale, tipo, nome,
  3022.                 requestInfo);
  3023.     }
  3024.     protected Documento getSpecificaSicurezza(Connection connectionPdD, String nomeRegistro,  IDServizio idServizio, TipiDocumentoSicurezza tipo, String nome,
  3025.             RequestInfo requestInfo)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  3026.         return _getAllegatoAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, "getSpecificaSicurezza", 
  3027.                 idServizio,
  3028.                 RuoliDocumento.specificaSicurezza, tipo, nome,
  3029.                 requestInfo);
  3030.     }
  3031.     protected Documento getSpecificaLivelloServizio(Connection connectionPdD, String nomeRegistro,  IDServizio idServizio, TipiDocumentoLivelloServizio tipo, String nome,
  3032.             RequestInfo requestInfo)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  3033.         return _getAllegatoAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, "getSpecificaLivelloServizio", 
  3034.                 idServizio,
  3035.                 RuoliDocumento.specificaSicurezza, tipo, nome,
  3036.                 requestInfo);
  3037.     }
  3038.     
  3039.     private Documento _getAllegatoAccordoServizioParteSpecifica(Connection connectionPdD, String nomeRegistro, String nomeMetodo, 
  3040.             IDServizio idServizio,
  3041.             RuoliDocumento ruolo, Object tipo, String nome,
  3042.             RequestInfo requestInfo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  3043.     
  3044.         String key = getKeyGetAllegatoAccordoServizioParteSpecifica(idServizio, ruolo, tipo, nome);  
  3045.     
  3046.         boolean useRequestInfo = requestInfo!=null && requestInfo.getRequestConfig()!=null;
  3047.         if(useRequestInfo) {
  3048.             Documento doc = requestInfo.getRequestConfig().getAllegatoServizio(key);
  3049.             if(doc!=null) {
  3050.                 return doc;
  3051.             }
  3052.         }
  3053.     
  3054.         Documento doc = _getAllegatoAccordoServizioParteSpecifica(connectionPdD, nomeRegistro, nomeMetodo, 
  3055.                 idServizio,
  3056.                 ruolo, tipo, nome,
  3057.                 key);
  3058.         if(useRequestInfo && requestInfo!=null) {
  3059.             requestInfo.getRequestConfig().addAllegatoServizio(key, doc, 
  3060.                     requestInfo.getIdTransazione());
  3061.         }
  3062.         return doc;
  3063.     }
  3064.     private Documento _getAllegatoAccordoServizioParteSpecifica(Connection connectionPdD, String nomeRegistro, String nomeMetodo, 
  3065.             IDServizio idServizio,
  3066.             RuoliDocumento ruolo, Object tipo, String nome,
  3067.             String key) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  3068.         
  3069.         // Raccolta dati
  3070.         if(idServizio == null || ruolo==null || nome == null)
  3071.             throw new DriverRegistroServiziException("["+nomeMetodo+"]: Parametri non definito");
  3072.         if(!RuoliDocumento.allegato.equals(ruolo)) {
  3073.             if(tipo==null) {
  3074.                 throw new DriverRegistroServiziException("["+nomeMetodo+"]: Tipo documento definito");
  3075.             }
  3076.         }

  3078.         // se e' attiva una cache provo ad utilizzarla
  3079.         if(this.cache!=null){
  3080.             org.openspcoop2.utils.cache.CacheResponse response = 
  3081.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  3082.             if(response != null){
  3083.                 if(response.getException()!=null){
  3084.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  3085.                         throw (DriverRegistroServiziNotFound) response.getException();
  3086.                     else
  3087.                         throw (DriverRegistroServiziException) response.getException();
  3088.                 }else{
  3089.                     return ((Documento) response.getObject());
  3090.                 }
  3091.             }
  3092.         }

  3094.         // Algoritmo CACHE
  3095.         Documento documento = null;
  3096.         if(RuoliDocumento.allegato.equals(ruolo)) {
  3097.             if(this.cache!=null){
  3098.                 documento = (Documento) this.getObjectCache(key,nomeMetodo,nomeRegistro,null,connectionPdD, idServizio, nome);
  3099.             }else{
  3100.                 documento = (Documento) this.getObject(nomeMetodo,nomeRegistro,null,connectionPdD, idServizio, nome);
  3101.             }
  3102.         }
  3103.         else {
  3104.             if(this.cache!=null){
  3105.                 documento = (Documento) this.getObjectCache(key,nomeMetodo,nomeRegistro,null,connectionPdD, idServizio, tipo, nome);
  3106.             }else{
  3107.                 documento = (Documento) this.getObject(nomeMetodo,nomeRegistro,null,connectionPdD, idServizio, tipo, nome);
  3108.             }
  3109.         }

  3111.         if(documento!=null)
  3112.             return documento;
  3113.         else
  3114.             throw new DriverRegistroServiziNotFound("["+nomeMetodo+"] Documento non trovato");
  3115.         
  3116.     }
  3117.     
  3118.     
  3119.     

  3121.     /**
  3122.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.RegistroServizi}, 
  3123.      * identificato grazie al parametro 
  3124.      * <var>idSoggetto</var> di tipo {@link org.openspcoop2.core.id.IDSoggetto}. 
  3125.      * Il connettore viene ricercato come definizione esterna, al soggetto (xml nel registro direttamente)
  3126.      *
  3127.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.RegistroServizi} se la ricerca nel registro ha successo,
  3128.      *         null altrimenti.
  3129.      * 
  3130.      */
  3131.     public org.openspcoop2.core.registry.RegistroServizi[] getRegistriServiziXML(){
  3132.         if(this.registriXML.size()>0){
  3133.             org.openspcoop2.core.registry.RegistroServizi[] r = new org.openspcoop2.core.registry.RegistroServizi[this.registriXML.size()];
  3134.             for(int i=0; i<this.registriXML.size(); i++){
  3135.                 r[i] = this.registriXML.get(i).getRegistroXML();
  3136.             }
  3137.             return r;
  3138.         }else{
  3139.             return null;
  3140.         }
  3141.     }










  3152.     protected static String _toKey_getWsdlAccordoServizioPrefix(){
  3153.         return "getWsdlAccordoServizio_";
  3154.     }
  3155.     protected static String _toKey_getWsdlAccordoServizioService(IDServizio idService){
  3156.         String servizio = idService.getNome();
  3157.         String tipoServizio = idService.getTipo();
  3158.         Integer versioneServizio = idService.getVersione();
  3159.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3160.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3161.         return "_"+ tipoSogg +"/" + nomeSogg +
  3162.                 "_" + tipoServizio + "/" + servizio+"/"+versioneServizio.intValue()+"_";
  3163.     }
  3164.     
  3165.     /**
  3166.      * Si occupa di ritornare le informazioni sui wsdl di un servizio
  3167.      * 
  3168.      * @param idService Identificatore del Servizio di tipo {@link org.openspcoop2.core.id.IDServizio}.
  3169.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper} se la ricerca nel registro ha successo,
  3170.      *         null altrimenti.
  3171.      */
  3172.     public org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper getWsdlAccordoServizio(Connection connectionPdD,String nomeRegistro,
  3173.             IDServizio idService,InformationApiSource infoWsdlSource,boolean buildSchemaXSD, boolean readDatiRegistro)
  3174.     throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3176.         // Raccolta dati
  3177.         if(idService == null)
  3178.             throw new DriverRegistroServiziException("[getWsdlAccordoServizio] Parametro Non Valido");
  3179.         String servizio = idService.getNome();
  3180.         String tipoServizio = idService.getTipo();
  3181.         Integer versioneServizio = idService.getVersione();
  3182.         if(servizio == null || tipoServizio == null || versioneServizio==null)
  3183.             throw new DriverRegistroServiziException("[getWsdlAccordoServizio] Parametri (Servizio) Non Validi");
  3184.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3185.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3186.         if(tipoSogg == null || nomeSogg == null)
  3187.             throw new DriverRegistroServiziException("[getWsdlAccordoServizio] Parametri (Soggetto) Non Validi");

  3189.         // se e' attiva una cache provo ad utilizzarla
  3190.         String key = null;  
  3191.         if(this.cache!=null){
  3192.             key = _toKey_getWsdlAccordoServizioPrefix()+infoWsdlSource.name()+
  3193.                     _toKey_getWsdlAccordoServizioService(idService)+
  3194.                     "schema_"+buildSchemaXSD+
  3195.                     "readDatiRegistro_"+readDatiRegistro;
  3196.             org.openspcoop2.utils.cache.CacheResponse response = 
  3197.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  3198.             if(response != null){
  3199.                 if(response.getException()!=null){
  3200.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  3201.                         throw (DriverRegistroServiziNotFound) response.getException();
  3202.                     else
  3203.                         throw (DriverRegistroServiziException) response.getException();
  3204.                 }else{
  3205.                     return ((org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper) response.getObject());
  3206.                 }
  3207.             }
  3208.         }

  3210.         // Algoritmo CACHE
  3211.         org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper wsdlAS = null;
  3212.         if(this.cache!=null){
  3213.             wsdlAS = this.getAccordoServizioSoapCache(key, idService, infoWsdlSource, nomeRegistro, connectionPdD,buildSchemaXSD, readDatiRegistro);
  3214.         }else{
  3215.             wsdlAS = this.getAccordoServizioSoapEngine(idService, infoWsdlSource, nomeRegistro, connectionPdD,buildSchemaXSD, readDatiRegistro);
  3216.         }

  3218.         if(wsdlAS!=null)
  3219.             return wsdlAS;
  3220.         else
  3221.             throw new DriverRegistroServiziNotFound("[getWsdlAccordoServizio] WSDLAccordoServizio non trovato");
  3222.     }



  3226.     /**
  3227.      * Si occupa di effettuare una ricerca nei registri, e di inserire la ricerca in cache
  3228.      *
  3229.      * @param keyCache Chiave di ricerca in cache
  3230.      * @param idService ID del Servizio
  3231.      * @param nomeRegistro Nome del registro su cui effettuare la ricerca (null per tutti i registri)
  3232.      * @return l'oggetto se trovato, null altrimenti.
  3233.      * 
  3234.      */
  3235.     private static org.openspcoop2.utils.Semaphore semaphore_getAccordoServizioSoapCache = new org.openspcoop2.utils.Semaphore("RegistroServizi_AccordoServizioSoap");
  3236.     private org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper getAccordoServizioSoapCache(String keyCache,IDServizio idService,
  3237.             InformationApiSource infoWsdlSource,String nomeRegistro,Connection connectionPdD,boolean buildSchemaXSD,boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3239.         SemaphoreLock lock = semaphore_getAccordoServizioSoapCache.acquireThrowRuntime("getAccordoServizioSoapCache");
  3240.         DriverRegistroServiziNotFound dNotFound = null;
  3241.         org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper obj = null;
  3242.         try{

  3244. //          System.out.println("@"+keyCache+"@ INFO CACHE: "+this.cache.toString());
  3245. //          System.out.println("@"+keyCache+"@ KEYS: \n\t"+this.cache.printKeys("\n\t"));
  3246.             
  3247.             // Raccolta dati
  3248.             if(keyCache == null)
  3249.                 throw new DriverRegistroServiziException("[getWSDLAccordoServizio]: KeyCache non definita");    

  3251.             // se e' attiva una cache provo ad utilizzarla
  3252.             if(this.cache!=null){
  3253.                 org.openspcoop2.utils.cache.CacheResponse response = 
  3254.                     (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(keyCache);
  3255.                 if(response != null){
  3256.                     if(response.getObject()!=null){
  3257.                         this.log.debug("Oggetto (tipo:"+response.getObject().getClass().getName()+") con chiave ["+keyCache+"] (method:getWSDLAccordoServizio) nel registro["+nomeRegistro+"] in cache.");
  3258.                         return (org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper) response.getObject();
  3259.                     }else if(response.getException()!=null){
  3260.                         this.log.debug("Eccezione (tipo:"+response.getException().getClass().getName()+") con chiave ["+keyCache+"] (method:getWSDLAccordoServizio) nel registro["+nomeRegistro+"] in cache.");
  3261.                         throw (Exception) response.getException();
  3262.                     }else{
  3263.                         this.log.error("In cache non e' presente ne un oggetto ne un'eccezione.");
  3264.                     }
  3265.                 }
  3266.             }

  3268.             // Effettuo le query nella mia gerarchia di registri.
  3269.             this.log.debug("oggetto con chiave ["+keyCache+"] (method:WSDLAccordoServizio) nel registro["+nomeRegistro+"] non in cache, ricerco nel registro...");
  3270.             try{
  3271.                 obj = getAccordoServizioSoapEngine(idService, infoWsdlSource,nomeRegistro,connectionPdD,buildSchemaXSD,readDatiRegistro);
  3272.             }catch(DriverRegistroServiziNotFound e){
  3273.                 dNotFound = e;
  3274.             }

  3276.             // Aggiungo la risposta in cache (se esiste una cache)  
  3277.             // Se ho una eccezione aggiungo in cache solo una not found
  3278.             if( this.cache!=null ){     
  3279.                 if(obj!=null){
  3280.                     this.log.info("Aggiungo oggetto ["+keyCache+"] in cache");
  3281.                 }
  3282.                 else { 
  3283.                 //  if(dNotFound!=null){
  3284.                     this.log.info("Aggiungo eccezione ["+keyCache+"] in cache");
  3285.                 }
  3286. //              else{
  3287. //                  throw new Exception("Metodo (WSDLAccordoServizio) nel registro["+nomeRegistro+"] ha ritornato un valore null");
  3288. //              }
  3289.                 try{    
  3290.                     org.openspcoop2.utils.cache.CacheResponse responseCache = new org.openspcoop2.utils.cache.CacheResponse();
  3291.                     if(dNotFound!=null){
  3292.                         responseCache.setException(dNotFound);
  3293.                     }else{
  3294.                         responseCache.setObject(obj);
  3295.                     }
  3296.                     this.cache.put(keyCache,responseCache);
  3297.                 }catch(UtilsException e){
  3298.                     this.log.error("Errore durante l'inserimento in cache ["+keyCache+"]: "+e.getMessage());
  3299.                 }
  3300.             }

  3302.         }catch(DriverRegistroServiziException e){
  3303.             throw e;
  3304.         }catch(DriverRegistroServiziNotFound e){
  3305.             throw e;
  3306.         }
  3307.         catch(Exception e){
  3308.             if(notFoundClassName.equals(e.getClass().getName()))
  3309.                 throw (DriverRegistroServiziNotFound) e;
  3310.             else
  3311.                 throw new DriverRegistroServiziException("RegistroServizi, Algoritmo di Cache fallito: "+e.getMessage(),e);
  3312.         }finally {
  3313.             semaphore_getAccordoServizioSoapCache.release(lock, "getAccordoServizioSoapCache");
  3314.         }

  3316.         if(dNotFound!=null){
  3317.             throw dNotFound;
  3318.         }else
  3319.             return obj;
  3320.     }


  3323.     /**
  3324.      * Si occupa di effettuare una ricerca nei registri
  3325.      *
  3326.      * @param idService ID del Servizio
  3327.      * @param nomeRegistro Nome del registro su cui effettuare la ricerca (null per tutti i registri)
  3328.      * @return l'oggetto se trovato, null altrimenti.
  3329.      * 
  3330.      */
  3331.     private org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper getAccordoServizioSoapEngine(IDServizio idService,InformationApiSource infoWsdlSource,
  3332.             String nomeRegistro,Connection connectionPdD,boolean buildSchemaXSD,boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3334.         _ASWrapperDati asWrapper = this.buildASWrapperDati(nomeRegistro, idService, connectionPdD, readDatiRegistro);
  3335.         
  3336.         // Effettuo le query nella mia gerarchia di registri.
  3337.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica servizio = asWrapper.servizio;
  3338.         org.openspcoop2.core.registry.AccordoServizioParteComune as = asWrapper.as;

  3340.         //Recupero la classe specificata dal parametro passato
  3341.         boolean registroServiziDB = asWrapper.registroServiziDB;



  3345.         // Costruisco oggetto
  3346.         org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper accordoServizioWrapper = new org.openspcoop2.core.registry.wsdl.AccordoServizioWrapper();

  3348.         IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromAccordo(as);
  3349.         accordoServizioWrapper.setIdAccordoServizio(idAccordo);
  3350.         
  3351.         accordoServizioWrapper.setNomePortType(servizio.getPortType());
  3352.         
  3353.         accordoServizioWrapper.setTipologiaServizio(servizio.getTipologiaServizio());
  3354.         
  3355.         accordoServizioWrapper.setAccordoServizio(as);
  3356.         
  3357.         accordoServizioWrapper.setLocationWsdlImplementativoErogatore(servizio.getWsdlImplementativoErogatore());
  3358.         accordoServizioWrapper.setLocationWsdlImplementativoFruitore(servizio.getWsdlImplementativoFruitore());
  3359.         accordoServizioWrapper.setBytesWsdlImplementativoErogatore(servizio.getByteWsdlImplementativoErogatore());
  3360.         accordoServizioWrapper.setBytesWsdlImplementativoFruitore(servizio.getByteWsdlImplementativoFruitore());
  3361.         
  3362.         OpenSPCoop2MessageFactory defaultMessageFactory = OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  3363.         
  3364.         AccordoServizioWrapperUtilities wsdlWrapperUtilities = new AccordoServizioWrapperUtilities(defaultMessageFactory, this.log);
  3365.         wsdlWrapperUtilities.setAccordoServizio(accordoServizioWrapper);
  3366.             
  3367.         if(buildSchemaXSD){
  3368.             try{
  3369.                 boolean buildFromBytes = registroServiziDB;
  3370.                 // buildFromBytes=false: Costruzione attraverso Location (versione XML,WEB,UDDI)
  3371.                 // buildFromBytes=true:  Costruzione attraverso bytes registrati sul DB
  3372.                 wsdlWrapperUtilities.buildSchema(buildFromBytes);
  3373.                 
  3374.             }catch(DriverRegistroServiziException e){
  3375.                 throw new DriverRegistroServiziException("[SchemaXSD] "+e.getMessage(),e);
  3376.             }
  3377.         }

  3379.         try{
  3380.             if(InformationApiSource.SPECIFIC.equals(infoWsdlSource)){
  3381.                 
  3382.                 this.log.debug("Costruisco WSDLAccordoServizio from WSDL...");
  3383.                 _loadFromWsdl(servizio, registroServiziDB, wsdlWrapperUtilities);
  3384.                 
  3385.             }else if(InformationApiSource.REGISTRY.equals(infoWsdlSource)){
  3386.                 
  3387.                 this.log.debug("Costruisco WSDLAccordoServizio from AccordoServizio...");
  3388.                 wsdlWrapperUtilities.buildAccordoServizioWrapperFromOpenSPCoopAS(as);
  3389.                 
  3390.             }
  3391.             else if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource) || 
  3392.                     InformationApiSource.SAFE_SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3393.             
  3394.                 this.log.debug("Costruisco WSDLAccordoServizio from WSDL (Step1)...");
  3395.                 try{
  3396.                     _loadFromWsdl(servizio, registroServiziDB, wsdlWrapperUtilities);
  3397.                 }catch(DriverRegistroServiziException e){
  3398.                     if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3399.                         throw e;
  3400.                     }
  3401.                 }
  3402.                 
  3403.                 this.log.debug("Costruisco WSDLAccordoServizio from AccordoServizio (Step2)...");
  3404.                 AccordoServizioWrapperUtilities wsdlWrapperUtilitiesStep2 = new AccordoServizioWrapperUtilities(defaultMessageFactory, this.log);
  3405.                 AccordoServizioWrapper accordoServizioWrapperStep2 = accordoServizioWrapper.clone(false);
  3406.                 wsdlWrapperUtilitiesStep2.setAccordoServizio(accordoServizioWrapperStep2);
  3407.                 try{
  3408.                     wsdlWrapperUtilitiesStep2.buildAccordoServizioWrapperFromOpenSPCoopAS(as);
  3409.                 }catch(DriverRegistroServiziException e){
  3410.                     if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3411.                         throw e;
  3412.                     }
  3413.                 }
  3414.                 
  3415.                 this.log.debug("Costruisco WSDLAccordoServizio merge WSDL e AccordoServizio (Step3)...");
  3416.                 _merge(accordoServizioWrapper, accordoServizioWrapperStep2);
  3417.                 
  3418.             }
  3419.             else if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource) || 
  3420.                     InformationApiSource.SAFE_REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3421.                 
  3422.                 this.log.debug("Costruisco WSDLAccordoServizio from AccordoServizio (Step1)...");
  3423.                 try{
  3424.                     wsdlWrapperUtilities.buildAccordoServizioWrapperFromOpenSPCoopAS(as);
  3425.                 }catch(DriverRegistroServiziException e){
  3426.                     if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3427.                         throw e;
  3428.                     }
  3429.                 }
  3430.                 
  3431.                 this.log.debug("Costruisco WSDLAccordoServizio from WSDL (Step2)...");
  3432.                 AccordoServizioWrapperUtilities wsdlWrapperUtilitiesStep2 = new AccordoServizioWrapperUtilities(defaultMessageFactory, this.log);
  3433.                 AccordoServizioWrapper accordoServizioWrapperStep2 = accordoServizioWrapper.clone(false);
  3434.                 wsdlWrapperUtilitiesStep2.setAccordoServizio(accordoServizioWrapperStep2);
  3435.                 try{
  3436.                     _loadFromWsdl(servizio, registroServiziDB, wsdlWrapperUtilitiesStep2);
  3437.                 }catch(DriverRegistroServiziException e){
  3438.                     if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3439.                         throw e;
  3440.                     }
  3441.                 }
  3442.                     
  3443.                 this.log.debug("Costruisco WSDLAccordoServizio merge  AccordoServizio e WSDL (Step3)...");
  3444.                 _merge(accordoServizioWrapper, accordoServizioWrapperStep2);
  3445.                                 
  3446.             }
  3447.         }catch(DriverRegistroServiziException e){
  3448.             if(TipologiaServizio.CORRELATO.equals(servizio.getTipologiaServizio())){
  3449.                 throw new DriverRegistroServiziException("[WSDL-FRUITORE] "+e.getMessage(),e);
  3450.             }else{
  3451.                 throw new DriverRegistroServiziException("[WSDL-EROGATORE] "+e.getMessage(),e);
  3452.             }
  3453.         }

  3455.         this.log.debug("invocazione metodo getWSDLAccordoServizio completata.");
  3456.         return accordoServizioWrapper;
  3457.     }

  3459.     private void _loadFromWsdl(AccordoServizioParteSpecifica servizio, boolean registroServiziDB, AccordoServizioWrapperUtilities wsdlWrapperUtilities) throws DriverRegistroServiziException{
  3460.         if(TipologiaServizio.CORRELATO.equals(servizio.getTipologiaServizio())){
  3461.             javax.wsdl.Definition wsdlFruitore = null;
  3462.             if(registroServiziDB){
  3463.                 wsdlFruitore = wsdlWrapperUtilities.buildWsdlFruitoreFromBytes();
  3464.             }else{
  3465.                 wsdlFruitore = wsdlWrapperUtilities.buildWsdlFruitore();
  3466.             }
  3467.             boolean readParteImplementativa = 
  3468.                 ( (servizio.getWsdlImplementativoFruitore()!=null) && ("".equals(servizio.getWsdlImplementativoFruitore())==false) )
  3469.                 ||
  3470.                 (servizio.getByteWsdlImplementativoFruitore()!=null) 
  3471.                 ||
  3472.                 (wsdlFruitore.getAllBindings()!=null && wsdlFruitore.getAllBindings().size()>0) 
  3473.                 ;
  3474.             wsdlWrapperUtilities.buildAccordoServizioWrapperFromWsdl(wsdlFruitore,readParteImplementativa);
  3475.         }else{
  3476.             javax.wsdl.Definition wsdlErogatore = null;
  3477.             if(registroServiziDB){
  3478.                 wsdlErogatore = wsdlWrapperUtilities.buildWsdlErogatoreFromBytes();
  3479.             }else{
  3480.                 wsdlErogatore = wsdlWrapperUtilities.buildWsdlErogatore();
  3481.             }
  3482.             boolean readParteImplementativa =    
  3483.                 ( (servizio.getWsdlImplementativoErogatore()!=null) && ("".equals(servizio.getWsdlImplementativoErogatore())==false) )
  3484.                 ||
  3485.                 (servizio.getByteWsdlImplementativoErogatore()!=null) 
  3486.                 ||
  3487.                 (wsdlErogatore.getAllBindings()!=null && wsdlErogatore.getAllBindings().size()>0) 
  3488.                 ;
  3489.             wsdlWrapperUtilities.buildAccordoServizioWrapperFromWsdl(wsdlErogatore,readParteImplementativa);
  3490.         }
  3491.     }
  3492.     
  3493.     private void _merge(AccordoServizioWrapper ptA, AccordoServizioWrapper ptB){
  3494.         for (int i = 0; i < ptB.sizePortTypeList(); i++) {
  3495.             PortType portTypeB = ptB.getPortType(i);
  3496.             boolean exists = false;
  3497.             for (int j = 0; j < ptA.sizePortTypeList(); j++) {
  3498.                 PortType portTypeA = ptA.getPortType(j);
  3499.                 if(portTypeB.getNome().equals(portTypeA.getNome())){
  3500.                     
  3501.                     // verifico le operation interne
  3502.                     for (Operation opB : portTypeB.getAzioneList()) {
  3503.                         boolean existsOperation = false;
  3504.                         for (Operation opA : portTypeA.getAzioneList()) {
  3505.                             if(opB.getNome().equals(opA.getNome())){
  3506.                                 existsOperation = true;
  3507.                                 break;
  3508.                             }
  3509.                         }
  3510.                         if(!existsOperation){
  3511.                             //System.out.println("ADD OP ["+opB.getNome()+"]");
  3512.                             portTypeA.addAzione(opB);
  3513.                         }
  3514.                     }
  3515.                     
  3516.                     exists = true;
  3517.                     break;
  3518.                 }
  3519.             }
  3520.             if(!exists){
  3521.                 //System.out.println("ADD PT ["+portTypeB.getNome()+"]");
  3522.                 ptA.addPortType(portTypeB);
  3523.             }
  3524.         }
  3525.         
  3526.     }
  3527.     
  3528.     
  3529.     
  3530.     
  3531.     
  3532.     
  3533.     
  3534.     
  3535.     
  3536.     
  3537.     
  3538.     
  3539.     
  3540.     
  3541.     
  3542.     
  3543.     protected static String _toKey_getRestAccordoServizioPrefix(){
  3544.         return "getRestAccordoServizio_";
  3545.     }
  3546.     protected static String _toKey_getRestAccordoServizioService(IDServizio idService){
  3547.         String servizio = idService.getNome();
  3548.         String tipoServizio = idService.getTipo();
  3549.         Integer versioneServizio = idService.getVersione();
  3550.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3551.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3552.         return "_"+ tipoSogg +"/" + nomeSogg +
  3553.                 "_" + tipoServizio + "/" + servizio+"/"+versioneServizio.intValue()+"_";
  3554.     }
  3555.     
  3556.     /**
  3557.      * Si occupa di ritornare le informazioni sulla specifica REST di un servizio
  3558.      * 
  3559.      * @param idService Identificatore del Servizio di tipo {@link org.openspcoop2.core.id.IDServizio}.
  3560.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.rest.AccordoServizioWrapper} se la ricerca nel registro ha successo,
  3561.      *         null altrimenti.
  3562.      */
  3563.     public org.openspcoop2.core.registry.rest.AccordoServizioWrapper getRestAccordoServizio(Connection connectionPdD,String nomeRegistro,
  3564.             IDServizio idService,InformationApiSource infoWsdlSource,boolean buildSchemaXSD, boolean processIncludeForOpenApi, boolean readDatiRegistro)
  3565.     throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3567.         // Raccolta dati
  3568.         if(idService == null)
  3569.             throw new DriverRegistroServiziException("[getRestAccordoServizio] Parametro Non Valido");
  3570.         String servizio = idService.getNome();
  3571.         String tipoServizio = idService.getTipo();
  3572.         Integer versioneServizio = idService.getVersione();
  3573.         if(servizio == null || tipoServizio == null || versioneServizio==null)
  3574.             throw new DriverRegistroServiziException("[getRestAccordoServizio] Parametri (Servizio) Non Validi");
  3575.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3576.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3577.         if(tipoSogg == null || nomeSogg == null)
  3578.             throw new DriverRegistroServiziException("[getRestAccordoServizio] Parametri (Soggetto) Non Validi");

  3580.         // se e' attiva una cache provo ad utilizzarla
  3581.         String key = null;  
  3582.         if(this.cache!=null){
  3583.             key = _toKey_getRestAccordoServizioPrefix()+infoWsdlSource.name()+
  3584.             _toKey_getRestAccordoServizioService(idService)
  3585.             +"schema_"+buildSchemaXSD
  3586.             +"_processInclude_"+processIncludeForOpenApi
  3587.             +"_readDatiRegistro_"+readDatiRegistro;
  3588.             org.openspcoop2.utils.cache.CacheResponse response = 
  3589.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  3590.             if(response != null){
  3591.                 if(response.getException()!=null){
  3592.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  3593.                         throw (DriverRegistroServiziNotFound) response.getException();
  3594.                     else
  3595.                         throw (DriverRegistroServiziException) response.getException();
  3596.                 }else{
  3597.                     return ((org.openspcoop2.core.registry.rest.AccordoServizioWrapper) response.getObject());
  3598.                 }
  3599.             }
  3600.         }

  3602.         // Algoritmo CACHE
  3603.         org.openspcoop2.core.registry.rest.AccordoServizioWrapper restAS = null;
  3604.         if(this.cache!=null){
  3605.             restAS = this.getAccordoServizioRestCache(key, idService, infoWsdlSource, nomeRegistro, connectionPdD,buildSchemaXSD, processIncludeForOpenApi, readDatiRegistro);
  3606.         }else{
  3607.             restAS = this.getAccordoServizioRestEngine(idService, infoWsdlSource, nomeRegistro, connectionPdD,buildSchemaXSD, processIncludeForOpenApi, readDatiRegistro);
  3608.         }

  3610.         if(restAS!=null)
  3611.             return restAS;
  3612.         else
  3613.             throw new DriverRegistroServiziNotFound("[getRestAccordoServizio] API non trovata");
  3614.     }



  3618.     /**
  3619.      * Si occupa di effettuare una ricerca nei registri, e di inserire la ricerca in cache
  3620.      *
  3621.      * @param keyCache Chiave di ricerca in cache
  3622.      * @param idService ID del Servizio
  3623.      * @param nomeRegistro Nome del registro su cui effettuare la ricerca (null per tutti i registri)
  3624.      * @return l'oggetto se trovato, null altrimenti.
  3625.      * 
  3626.      */
  3627.     private static org.openspcoop2.utils.Semaphore semaphore_getAccordoServizioRestCache = new org.openspcoop2.utils.Semaphore("RegistroServizi_AccordoServizioRest");
  3628.     private org.openspcoop2.core.registry.rest.AccordoServizioWrapper getAccordoServizioRestCache(String keyCache,IDServizio idService,
  3629.             InformationApiSource infoWsdlSource,String nomeRegistro,Connection connectionPdD,boolean buildSchemaXSD, boolean processIncludeForOpenApi, boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3631.         SemaphoreLock lock = semaphore_getAccordoServizioRestCache.acquireThrowRuntime("getAccordoServizioRestCache");
  3632.         DriverRegistroServiziNotFound dNotFound = null;
  3633.         org.openspcoop2.core.registry.rest.AccordoServizioWrapper obj = null;
  3634.         try{

  3636. //          System.out.println("@"+keyCache+"@ INFO CACHE: "+this.cache.toString());
  3637. //          System.out.println("@"+keyCache+"@ KEYS: \n\t"+this.cache.printKeys("\n\t"));
  3638.             
  3639.             // Raccolta dati
  3640.             if(keyCache == null)
  3641.                 throw new DriverRegistroServiziException("[getRestAccordoServizio]: KeyCache non definita");    

  3643.             // se e' attiva una cache provo ad utilizzarla
  3644.             if(this.cache!=null){
  3645.                 org.openspcoop2.utils.cache.CacheResponse response = 
  3646.                     (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(keyCache);
  3647.                 if(response != null){
  3648.                     if(response.getObject()!=null){
  3649.                         this.log.debug("Oggetto (tipo:"+response.getObject().getClass().getName()+") con chiave ["+keyCache+"] (method:getRestAccordoServizio) nel registro["+nomeRegistro+"] in cache.");
  3650.                         return (org.openspcoop2.core.registry.rest.AccordoServizioWrapper) response.getObject();
  3651.                     }else if(response.getException()!=null){
  3652.                         this.log.debug("Eccezione (tipo:"+response.getException().getClass().getName()+") con chiave ["+keyCache+"] (method:getRestAccordoServizio) nel registro["+nomeRegistro+"] in cache.");
  3653.                         throw (Exception) response.getException();
  3654.                     }else{
  3655.                         this.log.error("In cache non e' presente ne un oggetto ne un'eccezione.");
  3656.                     }
  3657.                 }
  3658.             }

  3660.             // Effettuo le query nella mia gerarchia di registri.
  3661.             this.log.debug("oggetto con chiave ["+keyCache+"] (method:getRestAccordoServizio) nel registro["+nomeRegistro+"] non in cache, ricerco nel registro...");
  3662.             try{
  3663.                 obj = getAccordoServizioRestEngine(idService, infoWsdlSource,nomeRegistro,connectionPdD,buildSchemaXSD, processIncludeForOpenApi,readDatiRegistro);
  3664.             }catch(DriverRegistroServiziNotFound e){
  3665.                 dNotFound = e;
  3666.             }

  3668.             // Aggiungo la risposta in cache (se esiste una cache)  
  3669.             // Se ho una eccezione aggiungo in cache solo una not found
  3670.             if( this.cache!=null ){     
  3671.                 if(obj!=null){
  3672.                     this.log.info("Aggiungo oggetto ["+keyCache+"] in cache");
  3673.                 }
  3674.                 else { 
  3675.                 //  if(dNotFound!=null){
  3676.                     this.log.info("Aggiungo eccezione ["+keyCache+"] in cache");
  3677.                 }
  3678. //              else{
  3679. //                  throw new Exception("Metodo (getRestAccordoServizio) nel registro["+nomeRegistro+"] ha ritornato un valore null");
  3680. //              }
  3681.                 try{    
  3682.                     org.openspcoop2.utils.cache.CacheResponse responseCache = new org.openspcoop2.utils.cache.CacheResponse();
  3683.                     if(dNotFound!=null){
  3684.                         responseCache.setException(dNotFound);
  3685.                     }else{
  3686.                         responseCache.setObject(obj);
  3687.                     }
  3688.                     this.cache.put(keyCache,responseCache);
  3689.                 }catch(UtilsException e){
  3690.                     this.log.error("Errore durante l'inserimento in cache ["+keyCache+"]: "+e.getMessage());
  3691.                 }
  3692.             }

  3694.         }catch(DriverRegistroServiziException e){
  3695.             throw e;
  3696.         }catch(DriverRegistroServiziNotFound e){
  3697.             throw e;
  3698.         }
  3699.         catch(Exception e){
  3700.             if(notFoundClassName.equals(e.getClass().getName()))
  3701.                 throw (DriverRegistroServiziNotFound) e;
  3702.             else
  3703.                 throw new DriverRegistroServiziException("RegistroServizi, Algoritmo di Cache fallito: "+e.getMessage(),e);
  3704.         }finally {
  3705.             semaphore_getAccordoServizioRestCache.release(lock, "getAccordoServizioRestCache");
  3706.         }

  3708.         if(dNotFound!=null){
  3709.             throw dNotFound;
  3710.         }else
  3711.             return obj;
  3712.     }
  3713.     
  3714.     /**
  3715.      * Si occupa di effettuare una ricerca nei registri
  3716.      *
  3717.      * @param idService ID del Servizio
  3718.      * @param nomeRegistro Nome del registro su cui effettuare la ricerca (null per tutti i registri)
  3719.      * @return l'oggetto se trovato, null altrimenti.
  3720.      * 
  3721.      */
  3722.     private org.openspcoop2.core.registry.rest.AccordoServizioWrapper getAccordoServizioRestEngine(IDServizio idService,InformationApiSource infoWsdlSource,
  3723.             String nomeRegistro,Connection connectionPdD,boolean buildSchemi,boolean processIncludeForOpenApi,
  3724.             boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{


  3727.         _ASWrapperDati asWrapper = this.buildASWrapperDati(nomeRegistro, idService, connectionPdD,
  3728.                 readDatiRegistro);
  3729.         
  3730.         // Effettuo le query nella mia gerarchia di registri.
  3731.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica servizio = asWrapper.servizio;
  3732.         org.openspcoop2.core.registry.AccordoServizioParteComune as = asWrapper.as;
  3733.         if(as==null) {
  3734.             throw new DriverRegistroServiziException("AS undefined");
  3735.         }

  3737.         //Recupero la classe specificata dal parametro passato
  3738.         boolean registroServiziDB = asWrapper.registroServiziDB;



  3742.         // Costruisco oggetto
  3743.         org.openspcoop2.core.registry.rest.AccordoServizioWrapper accordoServizioWrapper = new org.openspcoop2.core.registry.rest.AccordoServizioWrapper();

  3745.         IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromAccordo(as);
  3746.         accordoServizioWrapper.setIdAccordoServizio(idAccordo);
  3747.         
  3748.         accordoServizioWrapper.setAccordoServizio(as);
  3749.         boolean processInclude = buildSchemi;
  3750.         if(buildSchemi && as!=null && FormatoSpecifica.OPEN_API_3.equals(as.getFormatoSpecifica())) {
  3751.             processInclude = processIncludeForOpenApi;
  3752.         }
  3753.         
  3754.         accordoServizioWrapper.setLocationSpecifica(as.getWsdlConcettuale());
  3755.         accordoServizioWrapper.setBytesSpecifica(as.getByteWsdlConcettuale());
  3756.         
  3757.         accordoServizioWrapper.setRegistroServiziDB(asWrapper.registroServiziDB);
  3758.         
  3759.         OpenSPCoop2MessageFactory defaultMessageFactory = OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  3760.         
  3761.         org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities wsdlWrapperUtilities = 
  3762.                 new org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities(defaultMessageFactory, this.log, accordoServizioWrapper);
  3763.             

  3765.         try{
  3766.             if(InformationApiSource.SPECIFIC.equals(infoWsdlSource)){
  3767.                 
  3768.                 this.log.debug("Costruisco API tramite la specifica...");
  3769.                 wsdlWrapperUtilities.buildApiFromSpecific(registroServiziDB, buildSchemi, processInclude);
  3770.                 
  3771.             }else if(InformationApiSource.REGISTRY.equals(infoWsdlSource)){
  3772.                 
  3773.                 this.log.debug("Costruisco API tramite il registro...");
  3774.                 wsdlWrapperUtilities.buildApiFromRegistry(registroServiziDB, buildSchemi);
  3775.                 
  3776.             }
  3777.             else if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource) || 
  3778.                     InformationApiSource.SAFE_SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3779.             
  3780.                 this.log.debug("Costruisco API tramite la specifica (Step1)...");
  3781.                 try{
  3782.                     wsdlWrapperUtilities.buildApiFromSpecific(registroServiziDB, buildSchemi, processInclude);
  3783.                 }catch(DriverRegistroServiziException e){
  3784.                     if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3785.                         throw e;
  3786.                     }
  3787.                     else {
  3788.                         String errorMsg = "Costruisco API tramite il registro (Step1) error: "+e.getMessage();
  3789.                         if(org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities.API_SENZA_SPECIFICA.equals(e.getMessage())) {
  3790.                             this.log.warn(errorMsg,e);
  3791.                         }
  3792.                         else {
  3793.                             this.log.error(errorMsg,e);
  3794.                         }
  3795.                     }
  3796.                 }
  3797.                 
  3798.                 this.log.debug("Costruisco API tramite il registro (Step2)...");
  3799.                 org.openspcoop2.core.registry.rest.AccordoServizioWrapper accordoServizioWrapperStep2 = accordoServizioWrapper.clone();
  3800.                 org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities wsdlWrapperUtilitiesStep2 = 
  3801.                         new org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities(defaultMessageFactory, this.log, accordoServizioWrapperStep2);
  3802.                 try{
  3803.                     wsdlWrapperUtilitiesStep2.buildApiFromRegistry(registroServiziDB, buildSchemi);
  3804.                 }catch(DriverRegistroServiziException e){
  3805.                     if(InformationApiSource.SPECIFIC_REGISTRY.equals(infoWsdlSource)){
  3806.                         throw e;
  3807.                     }
  3808.                     else {
  3809.                         String errorMsg = "Costruisco API tramite il registro (Step2) error: "+e.getMessage();
  3810.                         if(org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities.API_SENZA_SPECIFICA.equals(e.getMessage())) {
  3811.                             this.log.warn(errorMsg,e);
  3812.                         }
  3813.                         else {
  3814.                             this.log.error(errorMsg,e);
  3815.                         }
  3816.                     }
  3817.                 }
  3818.                 
  3819.                 this.log.debug("Costruisco API merge specifica e registro (Step3)...");
  3820.                 _merge(accordoServizioWrapper, accordoServizioWrapperStep2);
  3821.                 
  3822.             }
  3823.             else if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource) || 
  3824.                     InformationApiSource.SAFE_REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3825.                 
  3826.                 this.log.debug("Costruisco API tramite il registro (Step1)...");
  3827.                 try{
  3828.                     wsdlWrapperUtilities.buildApiFromRegistry(registroServiziDB, buildSchemi);
  3829.                 }catch(DriverRegistroServiziException e){
  3830.                     if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3831.                         throw e;
  3832.                     }
  3833.                     else {
  3834.                         String errorMsg = "Costruisco API tramite il registro (Step1) error: "+e.getMessage();
  3835.                         if(org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities.API_SENZA_SPECIFICA.equals(e.getMessage())) {
  3836.                             this.log.warn(errorMsg,e);
  3837.                         }
  3838.                         else {
  3839.                             this.log.error(errorMsg,e);
  3840.                         }
  3841.                     }
  3842.                 }
  3843.                 
  3844.                 this.log.debug("Costruisco API tramite la specifica (Step2)...");
  3845.                 org.openspcoop2.core.registry.rest.AccordoServizioWrapper accordoServizioWrapperStep2 = accordoServizioWrapper.clone();
  3846.                 org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities wsdlWrapperUtilitiesStep2 = 
  3847.                         new org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities(defaultMessageFactory, this.log, accordoServizioWrapperStep2);
  3848.                 try{
  3849.                     wsdlWrapperUtilitiesStep2.buildApiFromSpecific(registroServiziDB, buildSchemi, processInclude);
  3850.                 }catch(DriverRegistroServiziException e){
  3851.                     if(InformationApiSource.REGISTRY_SPECIFIC.equals(infoWsdlSource)){
  3852.                         throw e;
  3853.                     }
  3854.                     else {
  3855.                         String errorMsg = "Costruisco API tramite il registro (Step2) error: "+e.getMessage();
  3856.                         if(org.openspcoop2.core.registry.rest.AccordoServizioWrapperUtilities.API_SENZA_SPECIFICA.equals(e.getMessage())) {
  3857.                             this.log.warn(errorMsg,e);
  3858.                         }
  3859.                         else {
  3860.                             this.log.error(errorMsg,e);
  3861.                         }
  3862.                     }
  3863.                 }
  3864.                     
  3865.                 this.log.debug("Costruisco WSDLAccordoServizio merge  AccordoServizio e WSDL (Step3)...");
  3866.                 _merge(accordoServizioWrapper, accordoServizioWrapperStep2);
  3867.                                 
  3868.             }
  3869.         }catch(DriverRegistroServiziException e){
  3870.             if(TipologiaServizio.CORRELATO.equals(servizio.getTipologiaServizio())){
  3871.                 throw new DriverRegistroServiziException("[CORRELATO] "+e.getMessage(),e);
  3872.             }else{
  3873.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  3874.             }
  3875.         }

  3877.         this.log.debug("invocazione metodo getWSDLAccordoServizio completata.");
  3878.         return accordoServizioWrapper;
  3879.     }
  3880.     
  3881.     private void _merge(org.openspcoop2.core.registry.rest.AccordoServizioWrapper asAwrapper, org.openspcoop2.core.registry.rest.AccordoServizioWrapper asBwrapper){
  3882.         AccordoServizioParteComune asA = asAwrapper.getAccordoServizio();
  3883.         AccordoServizioParteComune asB = asBwrapper.getAccordoServizio();
  3884.         for (int i = 0; i < asB.sizeResourceList(); i++) {
  3885.             Resource resourceB = asB.getResource(i);
  3886.             boolean exists = false;
  3887.             for (int j = 0; j < asA.sizeResourceList(); j++) {
  3888.                 Resource resourceA = asA.getResource(j);
  3889.                 if(resourceB.getNome().equals(resourceA.getNome())){
  3890.                     
  3891.                     exists = true;
  3892.                     break;
  3893.                 }
  3894.             }
  3895.             if(!exists){
  3896.                 //System.out.println("ADD PT ["+portTypeB.getNome()+"]");
  3897.                 asA.addResource(resourceB);
  3898.             }
  3899.         }
  3900.         
  3901.         // merge API
  3902.         if(asAwrapper.getApi()==null) {
  3903.             asAwrapper.setApi(asBwrapper.getApi());
  3904.         }
  3905.         else {
  3906.             if(asBwrapper.getApi()!=null) {
  3907.                 for (int i = 0; i < asBwrapper.getApi().sizeOperations(); i++) {
  3908.                     ApiOperation apiOpB = asBwrapper.getApi().getOperation(i);
  3909.                     boolean exists = false;
  3910.                     for (int j = 0; j < asAwrapper.getApi().sizeOperations(); j++) {
  3911.                         ApiOperation apiOpA = asAwrapper.getApi().getOperation(j);
  3912.                         
  3913.                         if(apiOpA.getPath()==null) {
  3914.                             if(apiOpB.getPath()!=null) {
  3915.                                 continue;
  3916.                             }
  3917.                         }
  3918.                         else if(!apiOpA.getPath().equals(apiOpB.getPath())) {
  3919.                             continue;
  3920.                         }
  3921.                         
  3922.                         if(apiOpA.getHttpMethod()==null) {
  3923.                             if(apiOpB.getHttpMethod()!=null) {
  3924.                                 continue;
  3925.                             }
  3926.                         }
  3927.                         else {
  3928.                             if(apiOpB.getHttpMethod()==null) {
  3929.                                 continue;
  3930.                             }
  3931.                             if(!apiOpA.getHttpMethod().equals(apiOpB.getHttpMethod())) {
  3932.                                 continue;
  3933.                             }
  3934.                         }
  3935.                         exists = true;
  3936.                         break;
  3937.                     }
  3938.                     if(!exists){
  3939.                         //System.out.println("ADD OP ["+apiOpB.getHttpMethod()+"] ["+apiOpB.getPath()+"]");
  3940.                         asAwrapper.getApi().addOperation(apiOpB);
  3941.                     }
  3942.                 }
  3943.             }
  3944.         }
  3945.     }
  3946.     
  3947.     
  3948.     
  3949.     
  3950.     
  3951.     protected static String _getKey_getServiceBinding(IDServizio idService){
  3952.         String servizio = idService.getNome();
  3953.         String tipoServizio = idService.getTipo();
  3954.         Integer versioneServizio = idService.getVersione();
  3955.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3956.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3957.         return "getServiceBinding_"+tipoSogg +"/" + nomeSogg +
  3958.                 "_" + tipoServizio + "/" + servizio+"/"+versioneServizio.intValue();
  3959.     }
  3960.     /**
  3961.      * Si occupa di ritornare il tipo di service binding del servizio
  3962.      * 
  3963.      * @param idService Identificatore del Servizio di tipo {@link org.openspcoop2.core.id.IDServizio}.
  3964.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.constants.ServiceBinding} se la ricerca nel registro ha successo,
  3965.      *         null altrimenti.
  3966.      */
  3967.     public org.openspcoop2.core.registry.constants.ServiceBinding getServiceBinding(Connection connectionPdD,String nomeRegistro,IDServizio idService)
  3968.     throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  3970.         // Raccolta dati
  3971.         if(idService == null)
  3972.             throw new DriverRegistroServiziException("[getServiceBinding] Parametro Non Valido");
  3973.         String servizio = idService.getNome();
  3974.         String tipoServizio = idService.getTipo();
  3975.         Integer versioneServizio = idService.getVersione();
  3976.         if(servizio == null || tipoServizio == null || versioneServizio==null)
  3977.             throw new DriverRegistroServiziException("[getServiceBinding] Parametri (Servizio) Non Validi");
  3978.         String tipoSogg = idService.getSoggettoErogatore().getTipo();
  3979.         String nomeSogg = idService.getSoggettoErogatore().getNome();
  3980.         if(tipoSogg == null || nomeSogg == null)
  3981.             throw new DriverRegistroServiziException("[getServiceBinding] Parametri (Soggetto) Non Validi");

  3983.         // se e' attiva una cache provo ad utilizzarla
  3984.         String key = null;  
  3985.         if(this.cache!=null){
  3986.             key = _getKey_getServiceBinding(idService);
  3987.             org.openspcoop2.utils.cache.CacheResponse response = 
  3988.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  3989.             if(response != null){
  3990.                 if(response.getException()!=null){
  3991.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  3992.                         throw (DriverRegistroServiziNotFound) response.getException();
  3993.                     else
  3994.                         throw (DriverRegistroServiziException) response.getException();
  3995.                 }else{
  3996.                     return ((org.openspcoop2.core.registry.constants.ServiceBinding) response.getObject());
  3997.                 }
  3998.             }
  3999.         }

  4001.         // Algoritmo CACHE
  4002.         org.openspcoop2.core.registry.constants.ServiceBinding sb = null;
  4003.         if(this.cache!=null){
  4004.             sb = this.getServiceBindingCache(key, idService, nomeRegistro, connectionPdD);
  4005.         }else{
  4006.             sb = this.getServiceBindingEngine(idService, nomeRegistro, connectionPdD);
  4007.         }

  4009.         if(sb!=null)
  4010.             return sb;
  4011.         else
  4012.             throw new DriverRegistroServiziNotFound("[getServiceBinding] API non trovata");
  4013.     }



  4017.     /**
  4018.      * Si occupa di effettuare una ricerca nei registri, e di inserire la ricerca in cache
  4019.      *
  4020.      * @param keyCache Chiave di ricerca in cache
  4021.      * @param idService ID del Servizio
  4022.      * @param nomeRegistro Nome del registro su cui effettuare la ricerca (null per tutti i registri)
  4023.      * @return l'oggetto se trovato, null altrimenti.
  4024.      * 
  4025.      */
  4026.     private static org.openspcoop2.utils.Semaphore semaphore_getServiceBindingCache = new org.openspcoop2.utils.Semaphore("RegistroServizi_ServiceBinding");
  4027.     private org.openspcoop2.core.registry.constants.ServiceBinding getServiceBindingCache(String keyCache,IDServizio idService,
  4028.             String nomeRegistro,Connection connectionPdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  4030.         SemaphoreLock lock = semaphore_getServiceBindingCache.acquireThrowRuntime("getServiceBindingCache");
  4031.         DriverRegistroServiziNotFound dNotFound = null;
  4032.         org.openspcoop2.core.registry.constants.ServiceBinding obj = null;
  4033.         try{

  4035. //          System.out.println("@"+keyCache+"@ INFO CACHE: "+this.cache.toString());
  4036. //          System.out.println("@"+keyCache+"@ KEYS: \n\t"+this.cache.printKeys("\n\t"));
  4037.             
  4038.             // Raccolta dati
  4039.             if(keyCache == null)
  4040.                 throw new DriverRegistroServiziException("[getServiceBinding]: KeyCache non definita"); 

  4042.             // se e' attiva una cache provo ad utilizzarla
  4043.             if(this.cache!=null){
  4044.                 org.openspcoop2.utils.cache.CacheResponse response = 
  4045.                     (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(keyCache);
  4046.                 if(response != null){
  4047.                     if(response.getObject()!=null){
  4048.                         this.log.debug("Oggetto (tipo:"+response.getObject().getClass().getName()+") con chiave ["+keyCache+"] (method:getServiceBinding) nel registro["+nomeRegistro+"] in cache.");
  4049.                         return (org.openspcoop2.core.registry.constants.ServiceBinding) response.getObject();
  4050.                     }else if(response.getException()!=null){
  4051.                         this.log.debug("Eccezione (tipo:"+response.getException().getClass().getName()+") con chiave ["+keyCache+"] (method:getServiceBinding) nel registro["+nomeRegistro+"] in cache.");
  4052.                         throw (Exception) response.getException();
  4053.                     }else{
  4054.                         this.log.error("In cache non e' presente ne un oggetto ne un'eccezione.");
  4055.                     }
  4056.                 }
  4057.             }

  4059.             // Effettuo le query nella mia gerarchia di registri.
  4060.             this.log.debug("oggetto con chiave ["+keyCache+"] (method:getServiceBinding) nel registro["+nomeRegistro+"] non in cache, ricerco nel registro...");
  4061.             try{
  4062.                 obj = getServiceBindingEngine(idService, nomeRegistro,connectionPdD);
  4063.             }catch(DriverRegistroServiziNotFound e){
  4064.                 dNotFound = e;
  4065.             }

  4067.             // Aggiungo la risposta in cache (se esiste una cache)  
  4068.             // Se ho una eccezione aggiungo in cache solo una not found
  4069.             if( this.cache!=null ){     
  4070.                 if(dNotFound!=null){
  4071.                     this.log.info("Aggiungo eccezione ["+keyCache+"] in cache");
  4072.                 }else if(obj!=null){
  4073.                     this.log.info("Aggiungo oggetto ["+keyCache+"] in cache");
  4074.                 }else{
  4075.                     throw new Exception("Metodo (getServiceBinding) nel registro["+nomeRegistro+"] ha ritornato un valore null");
  4076.                 }
  4077.                 try{    
  4078.                     org.openspcoop2.utils.cache.CacheResponse responseCache = new org.openspcoop2.utils.cache.CacheResponse();
  4079.                     if(dNotFound!=null){
  4080.                         responseCache.setException(dNotFound);
  4081.                     }else{
  4082.                         responseCache.setObject(obj);
  4083.                     }
  4084.                     this.cache.put(keyCache,responseCache);
  4085.                 }catch(UtilsException e){
  4086.                     this.log.error("Errore durante l'inserimento in cache ["+keyCache+"]: "+e.getMessage());
  4087.                 }
  4088.             }

  4090.         }catch(DriverRegistroServiziException e){
  4091.             throw e;
  4092.         }catch(DriverRegistroServiziNotFound e){
  4093.             throw e;
  4094.         }
  4095.         catch(Exception e){
  4096.             if(notFoundClassName.equals(e.getClass().getName()))
  4097.                 throw (DriverRegistroServiziNotFound) e;
  4098.             else
  4099.                 throw new DriverRegistroServiziException("RegistroServizi, Algoritmo di Cache fallito: "+e.getMessage(),e);
  4100.         }finally {
  4101.             semaphore_getServiceBindingCache.release(lock, "getServiceBindingCache");
  4102.         }

  4104.         if(dNotFound!=null){
  4105.             throw dNotFound;
  4106.         }else
  4107.             return obj;
  4108.     }
  4109.     
  4110.     private org.openspcoop2.core.registry.constants.ServiceBinding getServiceBindingEngine(IDServizio idService, String nomeRegistro,Connection connectionPdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  4111.         _ASWrapperDati asWrapper = this.buildASWrapperDati(nomeRegistro, idService, connectionPdD,false);
  4112.         return asWrapper.as.getServiceBinding();
  4113.     }
  4114.     
  4115.     
  4116.     
  4117.     
  4118.     
  4119.     
  4120.     private _ASWrapperDati buildASWrapperDati(String nomeRegistro, IDServizio idService, Connection connectionPdD, boolean readDatiRegistro) throws DriverRegistroServiziNotFound, DriverRegistroServiziException {
  4121.             // Logger log, IDServizio idService, Connection connectionPdD, IDAccordoFactory idAccordoFactory) {
  4122.         
  4123.         _ASWrapperDati asWrapper = new _ASWrapperDati();
  4124.         
  4125.         if(nomeRegistro!=null){
  4126.             this.log.debug("Cerco wsdl nel registro ["+nomeRegistro+"]");
  4127.             try{
  4128.                 String uriServizio = IDServizioFactory.getInstance().getUriFromIDServizio(idService);
  4129.                 
  4130.                 //org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.driverRegistroServizi.get(nomeRegistro);
  4131.                 org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.getDriver(connectionPdD, nomeRegistro);
  4132.                 this.log.debug("invocazione metodo getWSDLAccordoServizio (search servizio)...");
  4133.                 // ricerca servizio richiesto
  4134.                 try{
  4135.                     if(driver instanceof DriverRegistroServiziDB)
  4136.                         asWrapper.servizio = ((DriverRegistroServiziDB)driver).getAccordoServizioParteSpecifica(idService,true); // leggo contenuto allegati
  4137.                     else
  4138.                         asWrapper.servizio = driver.getAccordoServizioParteSpecifica(idService);    
  4139.                 }catch(DriverRegistroServiziNotFound e){
  4140.                     // ignore
  4141.                 }
  4142.                 if(asWrapper.servizio == null){
  4143.                     throw new DriverRegistroServiziNotFound("Servizio ["+uriServizio+"] non definito");
  4144.                 }
  4145.                 IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromUri(asWrapper.servizio.getAccordoServizioParteComune());
  4146.                 this.log.debug("invocazione metodo getWSDLAccordoServizio (search accordo)...");
  4147.                 if(driver instanceof DriverRegistroServiziDB)
  4148.                     asWrapper.as = ((DriverRegistroServiziDB)driver).getAccordoServizioParteComune(idAccordo,true, readDatiRegistro); // leggo contenuto allegati
  4149.                 else
  4150.                     asWrapper.as = driver.getAccordoServizioParteComune(idAccordo);
  4151.                 if (asWrapper.as == null){
  4152.                     throw new DriverRegistroServiziNotFound("Accordo di servizio ["+idAccordo+"] associato al servizio ["+uriServizio+"] non presente nel registro");
  4153.                 }
  4154.                 if(asWrapper.servizio.getPortType()!=null && ("".equals(asWrapper.servizio.getPortType())==false)){
  4155.                     // verifico presenza portType in accordo di servizio
  4156.                     boolean findPortType = false;
  4157.                     for(int l=0;l<asWrapper.as.sizePortTypeList();l++){
  4158.                         if(asWrapper.servizio.getPortType().equals(asWrapper.as.getPortType(l).getNome())){
  4159.                             findPortType = true;
  4160.                             break;
  4161.                         }
  4162.                     }
  4163.                     if(findPortType==false){
  4164.                         throw new DriverRegistroServiziNotFound("PortType["+asWrapper.servizio.getPortType()+"] associato al servizio ["+uriServizio+"] non presente nell'Accordo di servizio ["+idAccordo+"]");
  4165.                     }
  4166.                 }

  4168.                 // trovato!
  4169.                 asWrapper.registroServiziDB = (driver instanceof DriverRegistroServiziDB);
  4170.                 
  4171.             }catch(DriverRegistroServiziNotFound e){
  4172.                 // Non presente
  4173.                 this.log.debug("Ricerca nel registro non riuscita (metodo getWSDLAccordoServizio): "+e.getMessage());
  4174.                 throw e;
  4175.             }
  4176.             catch(Exception e){
  4177.                 // Non presente
  4178.                 this.log.debug("Ricerca nel registro ["+nomeRegistro+"] non riuscita, "+e.getMessage(),e);
  4179.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  4180.             }

  4182.         }else{
  4183.             this.log.debug("Cerco nella mia gerarchia di registri");
  4184.             StringBuilder notFoundProblem = new StringBuilder();
  4185.             StringBuilder exceptionProblem = new StringBuilder();
  4186.             boolean find = false;
  4187.             for (String nomeRegInLista : this.driverRegistroServizi.keySet()) {
  4188.                 this.log.debug("Cerco nel registro con nome["+nomeRegInLista+"]");
  4189.                 try{
  4190.                     String uriServizio = IDServizioFactory.getInstance().getUriFromIDServizio(idService);
  4191.                     
  4192.                     //org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.driverRegistroServizi.get(nomeRegInLista);
  4193.                     org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet driver = this.getDriver(connectionPdD, nomeRegInLista);
  4194.                     this.log.debug("invocazione metodo getWSDLAccordoServizio (search servizio) nel registro["+nomeRegInLista+"]...");
  4195.                     // ricerca servizio richiesto
  4196.                     try{
  4197.                         if(driver instanceof DriverRegistroServiziDB)
  4198.                             asWrapper.servizio = ((DriverRegistroServiziDB)driver).getAccordoServizioParteSpecifica(idService,true); // leggo contenuto allegati
  4199.                         else
  4200.                             asWrapper.servizio = driver.getAccordoServizioParteSpecifica(idService);    
  4201.                     }catch(DriverRegistroServiziNotFound e){
  4202.                         // ignore
  4203.                     }
  4204.                     if(asWrapper.servizio == null){
  4205.                         throw new DriverRegistroServiziNotFound("Servizio ["+uriServizio+"] non definito");
  4206.                     }
  4207.                     IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromUri(asWrapper.servizio.getAccordoServizioParteComune());
  4208.                     this.log.debug("invocazione metodo getWSDLAccordoServizio (search accordo) nel registro["+nomeRegInLista+"]...");
  4209.                     if(driver instanceof DriverRegistroServiziDB)
  4210.                         asWrapper.as = ((DriverRegistroServiziDB)driver).getAccordoServizioParteComune(idAccordo,true,readDatiRegistro); // leggo contenuto allegati
  4211.                     else
  4212.                         asWrapper.as = driver.getAccordoServizioParteComune(idAccordo);
  4213.                     if (asWrapper.as == null){
  4214.                         throw new DriverRegistroServiziNotFound("Accordo di servizio ["+idAccordo+"] associato al servizio ["+uriServizio+"] non presente nel registro");
  4215.                     }
  4216.                     if(asWrapper.servizio.getPortType()!=null && ("".equals(asWrapper.servizio.getPortType())==false)){
  4217.                         // verifico presenza portType in accordo di servizio
  4218.                         boolean findPortType = false;
  4219.                         for(int l=0;l<asWrapper.as.sizePortTypeList();l++){
  4220.                             if(asWrapper.servizio.getPortType().equals(asWrapper.as.getPortType(l).getNome())){
  4221.                                 findPortType = true;
  4222.                                 break;
  4223.                             }
  4224.                         }
  4225.                         if(findPortType==false){
  4226.                             throw new DriverRegistroServiziNotFound("PortType["+asWrapper.servizio.getPortType()+"] associato al servizio ["+uriServizio+"] non presente nell'Accordo di servizio ["+idAccordo+"]");
  4227.                         }
  4228.                     }
  4229.                     
  4230.                     // trovato!
  4231.                     asWrapper.registroServiziDB = (driver instanceof DriverRegistroServiziDB);
  4232.                     find=true;

  4234.                 }catch(DriverRegistroServiziNotFound ed){
  4235.                     // Non presente
  4236.                     this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita (metodo getWSDLAccordoServizio): "+ed.getMessage());
  4237.                     notFoundProblem.append("\nRegistro["+nomeRegInLista+"], ricerca fallita: "+ed.getMessage());
  4238.                 }catch(Exception e){
  4239.                     // Non presente
  4240.                     this.log.debug("Ricerca nel registro ["+nomeRegInLista+"] non riuscita, "+e.getMessage(),e);
  4241.                     if(this.raggiungibilitaTotale)
  4242.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  4243.                     else
  4244.                         exceptionProblem.append("\nRegistro["+nomeRegInLista+"], accesso non riuscito: "+e.getMessage());
  4245.                 }
  4246.                 if(find)
  4247.                     break;
  4248.             }

  4250.             this.log.debug("invocazione metodo getWSDLAccordoServizio completata.");
  4251.             if(find==false){
  4252.                 if(exceptionProblem.length()>0 && notFoundProblem.length()>0){
  4253.                     throw new DriverRegistroServiziException("getWSDLAccordoServizio:"+exceptionProblem.toString()+notFoundProblem.toString());
  4254.                 }else if(exceptionProblem.length()>0){
  4255.                     throw new DriverRegistroServiziException("getWSDLAccordoServizio:"+exceptionProblem.toString());
  4256.                 }else if(notFoundProblem.length()>0){
  4257.                     throw new DriverRegistroServiziNotFound("getWSDLAccordoServizio:"+notFoundProblem.toString());
  4258.                 }else{
  4259.                     throw new DriverRegistroServiziException("getWSDLAccordoServizio: ricerca non riuscita in tutti i registri");
  4260.                 }
  4261.             }
  4262.         }
  4263.         
  4264.         return asWrapper;
  4265.     }
  4266.     
  4267.     
  4268.     
  4269.     
  4270.     
  4271.     
  4272.     
  4273.     public Serializable pushGenericObject(String keyObject, Serializable object) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  4274.         if(this.cache!=null){
  4275.             return this._pushGenericObject(keyObject, object);
  4276.         }
  4277.         return object;
  4278.     }
  4279.     
  4280.     private static org.openspcoop2.utils.Semaphore semaphore_pushGenericObject = new org.openspcoop2.utils.Semaphore("RegistroServizi_GenericObject");
  4281.     private Serializable _pushGenericObject(String keyObject, Serializable object) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  4282.         
  4283.         SemaphoreLock lock = semaphore_pushGenericObject.acquireThrowRuntime("_pushGenericObject");
  4284.         try {
  4285.         
  4286.             // Raccolta dati
  4287.             if(keyObject == null)
  4288.                 throw new DriverRegistroServiziException("[getGenericObject]: Parametro non definito"); 
  4289.             
  4290.             // se e' attiva una cache provo ad utilizzarla per vedere se un altro thread lo ha già aggiunto
  4291.             String key = null;  
  4292.             key = "getGenericObject_" + keyObject;
  4293.             org.openspcoop2.utils.cache.CacheResponse response = 
  4294.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  4295.             if(response != null){
  4296.                 if(response.getException()!=null){
  4297.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  4298.                         throw (DriverRegistroServiziNotFound) response.getException();
  4299.                     else
  4300.                         throw (DriverRegistroServiziException) response.getException();
  4301.                 }else{
  4302.                     return ((Serializable) response.getObject());
  4303.                 }
  4304.             }
  4305.             
  4306.             // Aggiungo la risposta in cache
  4307.             try{    
  4308.                 org.openspcoop2.utils.cache.CacheResponse responseCache = new org.openspcoop2.utils.cache.CacheResponse();
  4309.                 responseCache.setObject(object);
  4310.                 this.cache.put(key,responseCache);
  4311.             }catch(UtilsException e){
  4312.                 this.log.error("Errore durante l'inserimento in cache ["+key+"]: "+e.getMessage());
  4313.             }
  4314.             
  4315.             return object; 
  4316.             
  4317.         }finally {
  4318.             semaphore_pushGenericObject.release(lock, "_pushGenericObject");
  4319.         }
  4320.         
  4321.     }
  4322.     
  4323.     public Serializable getGenericObject(String keyObject) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  4325.         // Raccolta dati
  4326.         if(keyObject == null)
  4327.             throw new DriverRegistroServiziException("[getGenericObject]: Parametro non definito"); 
  4328.         
  4329.         // se e' attiva una cache provo ad utilizzarla
  4330.         String key = null;  
  4331.         if(this.cache!=null){
  4332.             key = "getGenericObject_" + keyObject;
  4333.             org.openspcoop2.utils.cache.CacheResponse response = 
  4334.                 (org.openspcoop2.utils.cache.CacheResponse) this.cache.get(key);
  4335.             if(response != null){
  4336.                 if(response.getException()!=null){
  4337.                     if(notFoundClassName.equals(response.getException().getClass().getName()))
  4338.                         throw (DriverRegistroServiziNotFound) response.getException();
  4339.                     else
  4340.                         throw (DriverRegistroServiziException) response.getException();
  4341.                 }else{
  4342.                     return ((Serializable) response.getObject());
  4343.                 }
  4344.             }
  4345.         }

  4347.         throw new DriverRegistroServiziNotFound("GenericObject with key ["+keyObject+"] not found");

  4349.     }

  4351. }

  4353. class _ASWrapperDati {
  4354.     
  4355.     // Effettuo le query nella mia gerarchia di registri.
  4356.     org.openspcoop2.core.registry.AccordoServizioParteSpecifica servizio = null;
  4357.     org.openspcoop2.core.registry.AccordoServizioParteComune as = null;

  4359.     //Recupero la classe specificata dal parametro passato
  4360.     boolean registroServiziDB = false;
  4361.     
  4362.     
  4363. }
Created with JaCoCo 0.8.8.202204050719