XMLDataConverter.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.core.registry.driver.utils;

  25. import java.io.ByteArrayInputStream;
  26. import java.io.ByteArrayOutputStream;
  27. import java.io.File;
  28. import java.io.FileInputStream;
  29. import java.io.InputStream;
  30. import java.net.HttpURLConnection;
  31. import java.net.URL;
  32. import java.net.URLConnection;
  33. import java.sql.Connection;
  34. import java.util.ArrayList;
  35. import java.util.List;
  36. import java.util.Properties;

  38. import javax.net.ssl.KeyManagerFactory;
  39. import javax.net.ssl.TrustManagerFactory;

  41. import org.openspcoop2.core.commons.ProtocolFactoryReflectionUtils;
  42. import org.openspcoop2.core.config.AccessoRegistroRegistro;
  43. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  44. import org.openspcoop2.core.constants.CostantiDB;
  45. import org.openspcoop2.core.constants.TipiConnettore;
  46. import org.openspcoop2.core.id.IDAccordo;
  47. import org.openspcoop2.core.id.IDAccordoCooperazione;
  48. import org.openspcoop2.core.id.IDGruppo;
  49. import org.openspcoop2.core.id.IDRuolo;
  50. import org.openspcoop2.core.id.IDScope;
  51. import org.openspcoop2.core.id.IDServizio;
  52. import org.openspcoop2.core.id.IDSoggetto;
  53. import org.openspcoop2.core.mapping.DBMappingUtils;
  54. import org.openspcoop2.core.registry.AccordoCooperazione;
  55. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  56. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  57. import org.openspcoop2.core.registry.Azione;
  58. import org.openspcoop2.core.registry.ConfigurazioneServizio;
  59. import org.openspcoop2.core.registry.Connettore;
  60. import org.openspcoop2.core.registry.Fruitore;
  61. import org.openspcoop2.core.registry.Gruppo;
  62. import org.openspcoop2.core.registry.Operation;
  63. import org.openspcoop2.core.registry.PortType;
  64. import org.openspcoop2.core.registry.PortaDominio;
  65. import org.openspcoop2.core.registry.Property;
  66. import org.openspcoop2.core.registry.ProtocolProperty;
  67. import org.openspcoop2.core.registry.RegistroServizi;
  68. import org.openspcoop2.core.registry.Resource;
  69. import org.openspcoop2.core.registry.Ruolo;
  70. import org.openspcoop2.core.registry.Scope;
  71. import org.openspcoop2.core.registry.Soggetto;
  72. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  73. import org.openspcoop2.core.registry.constants.PddTipologia;
  74. import org.openspcoop2.core.registry.constants.ProfiloCollaborazione;
  75. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  76. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  77. import org.openspcoop2.core.registry.constants.ServiceBinding;
  78. import org.openspcoop2.core.registry.constants.StatiAccordo;
  79. import org.openspcoop2.core.registry.constants.StatoFunzionalita;
  80. import org.openspcoop2.core.registry.driver.BeanUtilities;
  81. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  82. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  83. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  84. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  85. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziCRUD;
  86. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  87. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  88. import org.openspcoop2.core.registry.driver.uddi.DriverRegistroServiziUDDI;
  89. import org.openspcoop2.core.registry.driver.web.DriverRegistroServiziWEB;
  90. import org.openspcoop2.core.registry.driver.xml.DriverRegistroServiziXML;
  91. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  92. import org.openspcoop2.message.xml.ValidatoreXSD;
  93. import org.openspcoop2.utils.CopyStream;
  94. import org.openspcoop2.utils.LoggerWrapperFactory;
  95. import org.openspcoop2.utils.certificate.KeystoreType;
  96. import org.openspcoop2.utils.transport.http.HttpUtilities;
  97. import org.slf4j.Logger;

  99. /**
  100.  * Classe utilizzata per convertire dati presenti in un file XML in un altra risorsa che implementa l'interfaccia CRUD.
  101.  *
  102.  * @author Poli Andrea (apoli@link.it)
  103.  * @author $Author$
  104.  * @version $Rev$, $Date$
  105.  */
  106. public class XMLDataConverter {

  108.     /** GestoreCRUD */
  109.     private IDriverRegistroServiziCRUD gestoreCRUD = null;
  110.     /** 'Root' del servizio dei registri OpenSPCoop. */
  111.     private org.openspcoop2.core.registry.RegistroServizi sorgenteRegistro;
  112.     /** Logger */
  113.     private Logger log = null;
  114.     /** Logger alternativo per i driver */
  115.     private Logger logDriver = null;
  116.     /** SuperUser */
  117.     private String superUser = null;
  118.     /** Tipo del backend di destinazione */
  119.     private String tipoBEDestinazione;
  120.     
  121.     // Factory
  122.     private IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();
  123.     private IDAccordoCooperazioneFactory idAccordoCooperazioneFactory = IDAccordoCooperazioneFactory.getInstance();
  124.     private IDServizioFactory idServizioFactory = IDServizioFactory.getInstance();

  126.     
  127.     public XMLDataConverter(String sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  128.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,null,null);
  129.     }
  130.     public XMLDataConverter(String sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  131.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,null);
  132.     }
  133.     public XMLDataConverter(String sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  134.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,logDriver);
  135.     }
  136.     
  137.     public XMLDataConverter(byte[] sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  138.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,null,null);
  139.     }
  140.     public XMLDataConverter(byte[] sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  141.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,null);
  142.     }
  143.     public XMLDataConverter(byte[] sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  144.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,logDriver);
  145.     }
  146.     
  147.     public XMLDataConverter(InputStream sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  148.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,null,null);
  149.     }
  150.     public XMLDataConverter(InputStream sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  151.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,null);
  152.     }
  153.     public XMLDataConverter(InputStream sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  154.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,logDriver);
  155.     }
  156.     
  157.     public XMLDataConverter(File sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  158.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,null,null);
  159.     }
  160.     public XMLDataConverter(File sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  161.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,null);
  162.     }
  163.     public XMLDataConverter(File sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  164.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,logDriver);
  165.     }
  166.     
  167.     public XMLDataConverter(RegistroServizi sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  168.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,null,null);
  169.     }
  170.     public XMLDataConverter(RegistroServizi sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  171.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,null);
  172.     }
  173.     public XMLDataConverter(RegistroServizi sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  174.         XMLDataConverterSetup(sorgente,destinazione,superUser,protocolloDefault,log,logDriver);
  175.     }
  176.     
  177.     private void XMLDataConverterSetup(Object sorgente,AccessoRegistroRegistro destinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  178.     
  179.         if(log == null)
  180.             this.log = LoggerWrapperFactory.getLogger(XMLDataConverter.class);
  181.         else
  182.             this.log = log;
  183.         this.logDriver = logDriver;
  184.         
  185.         if(destinazione==null)
  186.             throw new DriverRegistroServiziException("GestoreCRUD non definito");
  187.         
  188.         this.tipoBEDestinazione = destinazione.getTipo().toString();
  189.         this.superUser = superUser;
  190.         
  191.         // Istanziazione sorgente
  192.         try{
  193.             if(sorgente instanceof RegistroServizi) {
  194.                 this.sorgenteRegistro = (RegistroServizi) sorgente;
  195.             }
  196.             else if(sorgente instanceof String){
  197.                 createSorgente((String)sorgente);
  198.                 // Calcolo directory padre
  199.                 try{
  200.                     File f = new File((String)sorgente);
  201.                     if(f.getParentFile()!=null){
  202.                         this.parentFile = f.getParentFile();
  203.                     }
  204.                 }catch(Exception e){
  205.                     // ignore
  206.                 }
  207.             }
  208.             else if (sorgente instanceof byte[]){
  209.                 createSorgente((byte[])sorgente);
  210.             }else if (sorgente instanceof InputStream){
  211.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  212.                 InputStream is = (InputStream) sorgente;
  213. //              int letti = 0;
  214. //              byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  215. //              while( (letti=is.read(reads)) != -1 ){
  216. //                  bout.write(reads,0,letti);  
  217. //              }
  218.                 CopyStream.copy(is, bout);
  219.                 bout.flush();
  220.                 bout.close();
  221.                 createSorgente(bout.toByteArray());
  222.             }else if (sorgente instanceof File){
  223.                 createSorgente(((File)sorgente).getAbsolutePath());
  224.                 // Calcolo directory padre
  225.                 try{
  226.                     File f = (File)sorgente;
  227.                     if(f.getParentFile()!=null){
  228.                         this.parentFile = f.getParentFile();
  229.                     }
  230.                 }catch(Exception e){
  231.                     // ignore
  232.                 }
  233.             }
  234.         }catch(DriverRegistroServiziException d){
  235.             throw d;
  236.         }catch(Exception e){
  237.             throw new DriverRegistroServiziException("Creazione sorgente ["+sorgente.getClass().getName()+"] non riuscita: "+e.getMessage(),e);
  238.         }
  239.         
  240.         // Istanziazione CRUD
  241.         try{
  242.             if(CostantiConfigurazione.REGISTRO_DB.equals(destinazione.getTipo())){
  243.                 if(destinazione.getLocation()==null)
  244.                     throw new Exception("Location (DataSource) non definita");
  245.                 if(destinazione.getTipoDatabase()==null)
  246.                     throw new Exception("TipoDatabase (DataSource) non definita");
  247.                 if(destinazione.getGenericPropertiesMap()==null)
  248.                     throw new Exception("Contesto di localizzazione del datasource non definito in GenericProperties");
  249.                 java.util.Properties properties = new Properties();
  250.                 properties.putAll(destinazione.getGenericPropertiesMap());
  251.                 this.gestoreCRUD = new DriverRegistroServiziDB(destinazione.getLocation(),properties,this.logDriver,destinazione.getTipoDatabase());
  252.                 if(((DriverRegistroServiziDB)this.gestoreCRUD).create)
  253.                     this.log.info("Inizializzato Registro dei Servizi DB");
  254.                 else
  255.                     throw new Exception("RegistroServizi DB non inizializzato");
  256.             }
  257.             else if(CostantiConfigurazione.REGISTRO_UDDI.equals(destinazione.getTipo())){
  258.                 if(destinazione.getLocation()==null)
  259.                     throw new Exception("Location (InquiryURL) non definita");
  260.                 if(destinazione.getGenericPropertiesMap()==null)
  261.                     throw new Exception("PublishURL/UrlPrefix/PathPrefix non definita in GenericProperties");
  262.                 if(destinazione.getGenericPropertiesMap().size()!=3)
  263.                     throw new Exception("PublishURL/UrlPrefix/PathPrefix non definita in GenericProperties (size:"+destinazione.getGenericPropertiesMap().size()+")");
  264.                 if((destinazione.getGenericPropertiesMap().get("publishUrl") instanceof String) == false)
  265.                     throw new Exception("PublishURL definita in GenericProperties non e' un oggetto String");
  266.                 if((destinazione.getGenericPropertiesMap().get("urlPrefix") instanceof String) == false)
  267.                     throw new Exception("UrlPrefix definita in GenericProperties non e' un oggetto String");
  268.                 if((destinazione.getGenericPropertiesMap().get("pathPrefix") instanceof String) == false)
  269.                     throw new Exception("PathPrefix definita in GenericProperties non e' un oggetto String");
  270.                 this.gestoreCRUD = new DriverRegistroServiziUDDI(destinazione.getLocation(),
  271.                         destinazione.getGenericPropertiesMap().get("publishUrl"),
  272.                         destinazione.getUser(),destinazione.getPassword(),
  273.                         destinazione.getGenericPropertiesMap().get("urlPrefix"),
  274.                         destinazione.getGenericPropertiesMap().get("pathPrefix"),
  275.                         this.logDriver);
  276.                 if(((DriverRegistroServiziUDDI)this.gestoreCRUD).create)
  277.                     this.log.info("Inizializzato Registro dei Servizi UDDI");
  278.                 else
  279.                     throw new Exception("RegistroServizi UDDI non inizializzato");
  280.             }
  281.             else if(CostantiConfigurazione.REGISTRO_WEB.equals(destinazione.getTipo())){
  282.                 if(destinazione.getLocation()==null)
  283.                     throw new Exception("Location (UrlPrefix) non definita");
  284.                 if(destinazione.getGenericPropertiesMap()==null)
  285.                     throw new Exception("PathPrefix non definita in GenericProperties");
  286.                 if(destinazione.getGenericPropertiesMap().size()!=1)
  287.                     throw new Exception("PathPrefix non definita in GenericProperties (size:"+destinazione.getGenericPropertiesMap().size()+")");
  288.                 if((destinazione.getGenericPropertiesMap().get("pathPrefix") instanceof String) == false)
  289.                     throw new Exception("PathPrefix definita in GenericProperties non e' un oggetto String");
  290.                 this.gestoreCRUD = new DriverRegistroServiziWEB(destinazione.getLocation(),
  291.                         destinazione.getGenericPropertiesMap().get("pathPrefix"),
  292.                         this.logDriver);
  293.                 this.log.info("Inizializzato Registro dei Servizi WEB");
  294.                 if(((DriverRegistroServiziWEB)this.gestoreCRUD).create)
  295.                     this.log.info("Inizializzato Registro dei Servizi WEB");
  296.                 else
  297.                     throw new Exception("RegistroServizi WEB non inizializzato");
  298.         
  299.             }else{
  300.                 throw new Exception("Tipo di registro CRUD non gestito: "+destinazione.getTipo());
  301.             }
  302.         }catch(Exception e){
  303.             throw new DriverRegistroServiziException("Errore durante l'istanziazione del driver di CRUD: "+e.getMessage(),e);
  304.         }
  305.         
  306.         // Protocol initialize
  307.         try {
  308.             ProtocolFactoryReflectionUtils.initializeProtocolManager(protocolloDefault, this.log);
  309.         }catch(Exception e){
  310.             throw new DriverRegistroServiziException("Errore durante l'istanziazione del driver di CRUD: "+e.getMessage(),e);
  311.         }
  312.         
  313.         
  314.     }
  315.     
  316.     
  317.     public XMLDataConverter(String sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  318.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,null,null);
  319.     }
  320.     public XMLDataConverter(String sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  321.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,null);
  322.     }
  323.     public XMLDataConverter(String sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  324.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,logDriver);
  325.     }
  326.     
  327.     public XMLDataConverter(byte[] sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  328.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,null,null);
  329.     }
  330.     public XMLDataConverter(byte[] sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  331.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,null);
  332.     }
  333.     public XMLDataConverter(byte[] sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  334.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,logDriver);
  335.     }
  336.     
  337.     public XMLDataConverter(InputStream sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  338.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,null,null);
  339.     }
  340.     public XMLDataConverter(InputStream sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  341.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,null);
  342.     }
  343.     public XMLDataConverter(InputStream sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  344.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,logDriver);
  345.     }
  346.     
  347.     public XMLDataConverter(File sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  348.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,null,null);
  349.     }
  350.     public XMLDataConverter(File sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  351.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,null);
  352.     }
  353.     public XMLDataConverter(File sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  354.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,logDriver);
  355.     }
  356.     
  357.     public XMLDataConverter(RegistroServizi sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  358.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,null,null);
  359.     }
  360.     public XMLDataConverter(RegistroServizi sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  361.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,null);
  362.     }
  363.     public XMLDataConverter(RegistroServizi sorgente,IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  364.         XMLDataConverterSetup(sorgente,gestoreCRUD, tipoDestinazione,superUser,protocolloDefault,log,logDriver);
  365.     }
  366.     
  367.     private void XMLDataConverterSetup(Object sorgente, IDriverRegistroServiziCRUD gestoreCRUD, String tipoDestinazione,
  368.             String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  369.         
  370.         if(log == null)
  371.             this.log = LoggerWrapperFactory.getLogger(XMLDataConverter.class);
  372.         else
  373.             this.log = log;
  374.         this.logDriver = logDriver;
  375.         
  376.         if(gestoreCRUD==null)
  377.             throw new DriverRegistroServiziException("GestoreCRUD non definito");
  378.         
  379.         this.tipoBEDestinazione = tipoDestinazione;
  380.         this.superUser = superUser;
  381.         
  382.         // Istanziazione sorgente
  383.         try{
  384.             if(sorgente instanceof RegistroServizi) {
  385.                 this.sorgenteRegistro = (RegistroServizi) sorgente;
  386.             }
  387.             else if(sorgente instanceof String){
  388.                 createSorgente((String)sorgente);
  389.                 // Calcolo directory padre
  390.                 try{
  391.                     File f = new File((String)sorgente);
  392.                     if(f.getParentFile()!=null){
  393.                         this.parentFile = f.getParentFile();
  394.                     }
  395.                 }catch(Exception e){
  396.                     // ignore
  397.                 }
  398.             }
  399.             else if (sorgente instanceof byte[]){
  400.                 createSorgente((byte[])sorgente);
  401.             }else if (sorgente instanceof InputStream){
  402.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  403.                 InputStream is = (InputStream) sorgente;
  404. //              int letti = 0;
  405. //              byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  406. //              while( (letti=is.read(reads)) != -1 ){
  407. //                  bout.write(reads,0,letti);  
  408. //              }
  409.                 CopyStream.copy(is, bout);
  410.                 bout.flush();
  411.                 bout.close();
  412.                 createSorgente(bout.toByteArray());
  413.             }else if (sorgente instanceof File){
  414.                 createSorgente(((File)sorgente).getAbsolutePath());
  415.                 // Calcolo directory padre
  416.                 try{
  417.                     File f = (File)sorgente;
  418.                     if(f.getParentFile()!=null){
  419.                         this.parentFile = f.getParentFile();
  420.                     }
  421.                 }catch(Exception e){
  422.                     // ignore
  423.                 }
  424.             }
  425.         }catch(DriverRegistroServiziException d){
  426.             throw d;
  427.         }catch(Exception e){
  428.             throw new DriverRegistroServiziException("Creazione sorgente ["+sorgente.getClass().getName()+"] non riuscita: "+e.getMessage(),e);
  429.         }
  430.         
  431.         // Istanziazione CRUD
  432.         this.gestoreCRUD = gestoreCRUD;
  433.         
  434.         // Protocol initialize
  435.         try {
  436.             ProtocolFactoryReflectionUtils.initializeProtocolManager(protocolloDefault, this.log);
  437.         }catch(Exception e){
  438.             throw new DriverRegistroServiziException("Errore durante l'istanziazione del driver di CRUD: "+e.getMessage(),e);
  439.         }
  440.         
  441.         
  442.     }
  443.     
  444.     
  445.     
  446.     public XMLDataConverter(String sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  447.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,null,null);
  448.     }
  449.     public XMLDataConverter(String sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  450.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,null);
  451.     }
  452.     public XMLDataConverter(String sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  453.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  454.     }
  455.     
  456.     public XMLDataConverter(byte[] sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  457.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,null,null);
  458.     }
  459.     public XMLDataConverter(byte[] sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  460.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,null);
  461.     }
  462.     public XMLDataConverter(byte[] sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  463.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  464.     }
  465.     
  466.     public XMLDataConverter(InputStream sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  467.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,null,null);
  468.     }
  469.     public XMLDataConverter(InputStream sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  470.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,null);
  471.     }
  472.     public XMLDataConverter(InputStream sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  473.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  474.     }
  475.     
  476.     public XMLDataConverter(File sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  477.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,null,null);
  478.     }
  479.     public XMLDataConverter(File sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  480.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,null);
  481.     }
  482.     public XMLDataConverter(File sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  483.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  484.     }
  485.     
  486.     public XMLDataConverter(RegistroServizi sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault) throws DriverRegistroServiziException{
  487.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,null,null);
  488.     }
  489.     public XMLDataConverter(RegistroServizi sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log) throws DriverRegistroServiziException{
  490.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,null);
  491.     }
  492.     public XMLDataConverter(RegistroServizi sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  493.         XMLDataConverterSetup(sorgente,connection,tipoDatabase,superUser,protocolloDefault,log,logDriver);
  494.     }
  495.     
  496.     private File parentFile = null;

  498.     private void XMLDataConverterSetup(Object sorgente,Connection connection,String tipoDatabase,String superUser,String protocolloDefault,Logger log,Logger logDriver) throws DriverRegistroServiziException{
  499.     
  500.         if(log == null)
  501.             this.log = LoggerWrapperFactory.getLogger(XMLDataConverter.class);
  502.         else
  503.             this.log = log;
  504.         this.logDriver = logDriver;
  505.         
  506.         this.superUser = superUser;
  507.         this.tipoBEDestinazione = CostantiConfigurazione.REGISTRO_DB.toString();
  508.         
  509.         // Istanziazione sorgente
  510.         try{
  511.             if(sorgente instanceof RegistroServizi) {
  512.                 this.sorgenteRegistro = (RegistroServizi) sorgente;
  513.             }
  514.             else if(sorgente instanceof String){
  515.                 createSorgente((String)sorgente);
  516.                 // Calcolo directory padre
  517.                 try{
  518.                     File f = new File((String)sorgente);
  519.                     if(f.getParentFile()!=null){
  520.                         this.parentFile = f.getParentFile();
  521.                     }
  522.                 }catch(Exception e){
  523.                     // ignore
  524.                 }
  525.             }
  526.             else if (sorgente instanceof byte[]){
  527.                 createSorgente((byte[])sorgente);
  528.             }else if (sorgente instanceof InputStream){
  529.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  530.                 InputStream is = (InputStream) sorgente;
  531. //              int letti = 0;
  532. //              byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  533. //              while( (letti=is.read(reads)) != -1 ){
  534. //                  bout.write(reads,0,letti);  
  535. //              }
  536.                 CopyStream.copy(is, bout);
  537.                 bout.flush();
  538.                 bout.close();
  539.                 createSorgente(bout.toByteArray());
  540.             }else if (sorgente instanceof File){
  541.                 createSorgente(((File)sorgente).getAbsolutePath());
  542.                 // Calcolo directory padre
  543.                 try{
  544.                     File f = (File)sorgente;
  545.                     if(f.getParentFile()!=null){
  546.                         this.parentFile = f.getParentFile();
  547.                     }
  548.                 }catch(Exception e){
  549.                     // ignore
  550.                 }
  551.             }
  552.         }catch(DriverRegistroServiziException d){
  553.             throw d;
  554.         }catch(Exception e){
  555.             throw new DriverRegistroServiziException("Creazione sorgente ["+sorgente.getClass().getName()+"] non riuscita: "+e.getMessage(),e);
  556.         }
  557.         
  558.         // Istanziazione CRUD in version DB
  559.         try{
  560.             this.gestoreCRUD = new DriverRegistroServiziDB(connection,this.logDriver,tipoDatabase);
  561.             if(((DriverRegistroServiziDB)this.gestoreCRUD).create)
  562.                 this.log.info("Inizializzato Configurazione DB");
  563.             else
  564.                 throw new Exception("Configurazione DB non inizializzato");
  565.         }catch(Exception e){
  566.             throw new DriverRegistroServiziException("Errore durante l'istanziazione del driver di CRUD: "+e.getMessage(),e);
  567.         }
  568.         
  569.         // Protocol initialize
  570.         try {
  571.             ProtocolFactoryReflectionUtils.initializeProtocolManager(protocolloDefault, this.log);
  572.         }catch(Exception e){
  573.             throw new DriverRegistroServiziException("Errore durante l'istanziazione del driver di CRUD: "+e.getMessage(),e);
  574.         }
  575.     }
  576.     
  577.     
  578.     
  579.     
  580.     private void createSorgente(String sorgente)throws DriverRegistroServiziException{
  581.         // Istanziazione Sorgente
  582.         if(sorgente==null)
  583.             throw new DriverRegistroServiziException("Sorgente non definita");
  584.         
  585.         // ValidatoreXSD
  586.         ValidatoreXSD validatoreRegistro = null;
  587.         try{
  588.             validatoreRegistro = new ValidatoreXSD(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.log,DriverRegistroServiziXML.class.getResourceAsStream("/registroServizi.xsd"));
  589.         }catch (Exception e) {
  590.             throw new DriverRegistroServiziException("Riscontrato errore durante l'inizializzazione dello schema del Registro dei Servizi di OpenSPCoop: "+e.getMessage());
  591.         }
  592.         FileInputStream fXML = null;
  593.         try{
  594.             if(sorgente.startsWith("http://") || sorgente.startsWith("file://")){
  595.                 validatoreRegistro.valida(sorgente);  
  596.             }else{
  597.                 fXML = new FileInputStream(sorgente);
  598.                 validatoreRegistro.valida(fXML);
  599.             }
  600.         }catch (Exception e) {
  601.             throw new DriverRegistroServiziException("Riscontrato errore durante la validazione XSD del Registro dei Servizi XML di OpenSPCoop: "+e.getMessage());
  602.         }finally{
  603.             if(fXML!=null){
  604.                 try{
  605.                     fXML.close();
  606.                 }catch(Exception e){
  607.                     // close
  608.                 }
  609.             }
  610.         }
  611.         
  612.         try{
  613.             InputStream iStream = null;
  614.             HttpURLConnection httpConn = null;
  615.             if(sorgente.startsWith("http://") || sorgente.startsWith("file://")){
  616.                 try{ 
  617.                     URL url = new URL(sorgente);
  618.                     URLConnection connection = url.openConnection();
  619.                     httpConn = (HttpURLConnection) connection;
  620.                     httpConn.setRequestMethod("GET");
  621.                     httpConn.setDoOutput(true);
  622.                     httpConn.setDoInput(true);
  623.                     iStream = httpConn.getInputStream();
  624.                 }catch(Exception e) {
  625.                     try{  
  626. //                      if(iStream!=null)
  627. //                          iStream.close();
  628.                         if(httpConn !=null)
  629.                             httpConn.disconnect();
  630.                     } catch(Exception ef) {
  631.                         // ignore
  632.                     }
  633.                     throw new DriverRegistroServiziException("Riscontrato errore durante la creazione dell'inputStream del registro dei servizi (HTTP) : \n\n"+e.getMessage());
  634.                 }
  635.             }else{
  636.                 try{  
  637.                     iStream = new FileInputStream(sorgente);
  638.                 }catch(java.io.FileNotFoundException e) {
  639.                     throw new DriverRegistroServiziException("Riscontrato errore durante la creazione dell'inputStream del registro dei servizi (FILE) : \n\n"+e.getMessage());
  640.                 }
  641.             }



  645.             /* ---- Unmarshall del file di configurazione ---- */
  646.             try{  
  647.                 org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  648.                 this.sorgenteRegistro = deserializer.readRegistroServizi(iStream);
  649.             } catch(Exception e) {
  650.                 try{  
  651.                     if(iStream!=null)
  652.                         iStream.close();
  653.                     if(httpConn !=null)
  654.                         httpConn.disconnect();
  655.                 } catch(Exception ef) {
  656.                     // ignore
  657.                 }
  658.                 throw new DriverRegistroServiziException("Riscontrato errore durante l'unmarshall del file di configurazione: "+e.getMessage());
  659.             }

  661.             try{  
  662.                 // Chiusura dello Stream
  663.                 if(iStream!=null)
  664.                     iStream.close();
  665.                 // Chiusura dell'eventuale connessione HTTP
  666.                 if(httpConn !=null)
  667.                     httpConn.disconnect();
  668.             } catch(Exception e) {
  669.                 throw new DriverRegistroServiziException("Riscontrato errore durante la chiusura dell'Input Stream: "+e.getMessage());
  670.             }
  671.             
  672.         } catch(Exception e) {
  673.             throw new DriverRegistroServiziException("Riscontrato errore durante l'istanziazione del registro: "+e.getMessage(),e);
  674.         }
  675.     }
  676.     
  677.     
  678.     private void createSorgente(byte[] sorgente)throws DriverRegistroServiziException{
  679.         // Istanziazione Sorgente
  680.         if(sorgente==null)
  681.             throw new DriverRegistroServiziException("Sorgente non definita");
  682.         
  683.         // ValidatoreXSD
  684.         ValidatoreXSD validatoreRegistro = null;
  685.         try{
  686.             validatoreRegistro = new ValidatoreXSD(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.log,DriverRegistroServiziXML.class.getResourceAsStream("/registroServizi.xsd"));
  687.         }catch (Exception e) {
  688.             throw new DriverRegistroServiziException("Riscontrato errore durante l'inizializzazione dello schema del Registro dei Servizi di OpenSPCoop: "+e.getMessage());
  689.         }
  690.         try{
  691.             validatoreRegistro.valida(new ByteArrayInputStream(sorgente));
  692.         }catch (Exception e) {
  693.             throw new DriverRegistroServiziException("Riscontrato errore durante la validazione XSD del Registro dei Servizi XML di OpenSPCoop: "+e.getMessage());
  694.         }
  695.         
  696.         try{
  697.             InputStream iStream = null;
  698.             try{  
  699.                 iStream = new ByteArrayInputStream(sorgente);
  700.             }catch(Exception e) {
  701. //              try{  
  702. //                  if(iStream!=null)
  703. //                      iStream.close();
  704. //              } catch(java.io.IOException ef) {
  705. //                  // close
  706. //              }
  707.                 throw new DriverRegistroServiziException("Riscontrato errore durante la creazione dell'inputStreamReader del registro dei servizi : \n\n"+e.getMessage());
  708.             }


  711.             /* ---- Unmarshall del file di configurazione ---- */
  712.             try{  
  713.                 org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  714.                 this.sorgenteRegistro = deserializer.readRegistroServizi(iStream);
  715.             } catch(Exception e) {
  716.                 try{  
  717.                     if(iStream!=null)
  718.                         iStream.close();
  719.                 } catch(Exception ef) {
  720.                     // close
  721.                 }
  722.                 throw new DriverRegistroServiziException("Riscontrato errore durante l'unmarshall del file di configurazione: "+e.getMessage());
  723.             }

  725.             try{  
  726.                 // Chiusura dello Stream
  727.                 if(iStream!=null)
  728.                     iStream.close();
  729.             } catch(Exception e) {
  730.                 throw new DriverRegistroServiziException("Riscontrato errore durante la chiusura dell'Input Stream: "+e.getMessage());
  731.             }
  732.             
  733.         } catch(Exception e) {
  734.             throw new DriverRegistroServiziException("Riscontrato errore durante l'istanziazione del registro: "+e.getMessage(),e);
  735.         }
  736.     }
  737.     
  738.     
  739.     
  740.     
  741.     
  742.     
  743.     public void convertXML(boolean reset, boolean mantieniFruitoriEsistenti,boolean aggiornamentoSoggetti,StatiAccordo statoAccordo) throws DriverRegistroServiziException{
  744.         convertXML(reset,new PdDConfig(),mantieniFruitoriEsistenti,aggiornamentoSoggetti,statoAccordo);
  745.     }
  746.     public void convertXML(boolean reset, boolean mantieniFruitoriEsistenti,boolean aggiornamentoSoggetti,StatiAccordo statoAccordo, boolean updateEnabled) throws DriverRegistroServiziException{
  747.         convertXML(reset,new PdDConfig(),mantieniFruitoriEsistenti,aggiornamentoSoggetti,statoAccordo,updateEnabled);
  748.     }
  749.     
  750.     // pddEsterne da impostare solo nel caso di conversione per govwayConsole
  751.     public void convertXML(boolean reset, PdDConfig pddConfig, boolean mantieniFruitoriEsistenti,boolean aggiornamentoSoggetti,StatiAccordo statoAccordo) throws DriverRegistroServiziException{
  752.         this.convertXML(reset, pddConfig, mantieniFruitoriEsistenti, aggiornamentoSoggetti, statoAccordo, true);
  753.     }
  754.     public void convertXML(boolean reset, PdDConfig pddConfig, boolean mantieniFruitoriEsistenti,boolean aggiornamentoSoggetti,StatiAccordo statoAccordo, boolean updateEnabled) throws DriverRegistroServiziException{
  755.         
  756.         // Reset
  757.         if(reset){
  758.             try{
  759.                 this.log.info("RegistroServizi, reset in corso...");
  760.                 this.gestoreCRUD.reset();
  761.                 this.log.info("RegistroServizi, reset effettuato.");
  762.             }catch(Exception e){
  763.                 e.printStackTrace(System.err);
  764.                 throw new DriverRegistroServiziException("Reset del RegistroServizi non riuscita: "+e.getMessage(),e);
  765.             }
  766.         }
  767.         
  768.             
  769.         // Porte di Dominio
  770.         try{
  771.             
  772.             for(int i=0; i<this.sorgenteRegistro.sizePortaDominioList(); i++){
  773.                 PortaDominio pdd = this.sorgenteRegistro.getPortaDominio(i);
  774.                 pdd.setSuperUser(this.superUser);
  775.                 impostaInformazioniRegistroDB_PortaDominio(pdd);
  776.                 
  777.                 if( (reset==false) && this.gestoreCRUD.existsPortaDominio(pdd.getNome())){
  778.                     if(updateEnabled) {
  779.                         this.log.info("Porta di Dominio "+pdd.getNome()+" aggiornamento in corso...");
  780.                         this.gestoreCRUD.updatePortaDominio(pdd);
  781.                         this.log.info("Porta di Dominio "+pdd.getNome()+" aggiornata.");
  782.                     }
  783.                     else {
  784.                         this.log.info("Porta di Dominio "+pdd.getNome()+" non aggiornata (aggiornamento disabilitato).");
  785.                     }
  786.                 }else{
  787.                     this.log.info("Porta di Dominio "+pdd.getNome()+" creazione in corso...");
  788.                     this.gestoreCRUD.createPortaDominio(pdd);
  789.                     this.log.info("Porta di Dominio "+pdd.getNome()+" creata.");                
  790.                 }
  791.                 
  792.                 if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione) && pddConfig.getPddOperativaCtrlstatSinglePdd()!=null){
  793.                     impostaInformazioniRegistroDB_PortaDominio_update(pdd, pddConfig.getPddOperativaCtrlstatSinglePdd(), 
  794.                             this.log, ((DriverRegistroServiziDB)this.gestoreCRUD), pddConfig.getTipoPdd());
  795.                 }   

  797.             }
  798.             
  799.         }catch(Exception e){
  800.             e.printStackTrace(System.err);
  801.             throw new DriverRegistroServiziException("Errore durante la conversione XML delle porte di dominio: "+e.getMessage(),e);
  802.         }
  803.         
  804.         
  805.         
  806.         
  807.         
  808.         
  809.         // Gruppi
  810.         try{
  811.             
  812.             for(int i=0; i<this.sorgenteRegistro.sizeGruppoList(); i++){
  813.                 Gruppo gruppo = this.sorgenteRegistro.getGruppo(i);
  814.                 gruppo.setSuperUser(this.superUser);
  815.                 impostaInformazioniRegistroDB_Gruppo(gruppo);
  816.                 
  817.                 IDGruppo idGruppo = new IDGruppo(gruppo.getNome());
  818.                 if( (reset==false) && this.gestoreCRUD.existsGruppo(idGruppo)){
  819.                     if(updateEnabled) {
  820.                         this.log.info("Gruppo "+gruppo.getNome()+" aggiornamento in corso...");
  821.                         this.gestoreCRUD.updateGruppo(gruppo);
  822.                         this.log.info("Gruppo "+gruppo.getNome()+" aggiornato.");
  823.                     }
  824.                     else {
  825.                         this.log.info("Gruppo "+gruppo.getNome()+" non aggiornato (aggiornamento disabilitato).");
  826.                     }
  827.                 }else{
  828.                     this.log.info("Gruppo "+gruppo.getNome()+" creazione in corso...");
  829.                     this.gestoreCRUD.createGruppo(gruppo);
  830.                     this.log.info("Gruppo "+gruppo.getNome()+" creato.");               
  831.                 }
  832.                 
  833.             }
  834.             
  835.         }catch(Exception e){
  836.             e.printStackTrace(System.err);
  837.             throw new DriverRegistroServiziException("Errore durante la conversione XML dei gruppi: "+e.getMessage(),e);
  838.         }
  839.         
  840.         
  841.         
  842.         
  843.         
  844.         // Ruoli
  845.         try{
  846.             
  847.             for(int i=0; i<this.sorgenteRegistro.sizeRuoloList(); i++){
  848.                 Ruolo ruolo = this.sorgenteRegistro.getRuolo(i);
  849.                 ruolo.setSuperUser(this.superUser);
  850.                 impostaInformazioniRegistroDB_Ruolo(ruolo);
  851.                 
  852.                 IDRuolo idRuolo = new IDRuolo(ruolo.getNome());
  853.                 if( (reset==false) && this.gestoreCRUD.existsRuolo(idRuolo)){
  854.                     if(updateEnabled) {
  855.                         this.log.info("Ruolo "+ruolo.getNome()+" aggiornamento in corso...");
  856.                         this.gestoreCRUD.updateRuolo(ruolo);
  857.                         this.log.info("Ruolo "+ruolo.getNome()+" aggiornato.");
  858.                     }
  859.                     else {
  860.                         this.log.info("Ruolo "+ruolo.getNome()+" non aggiornato (aggiornamento disabilitato).");
  861.                     }
  862.                 }else{
  863.                     this.log.info("Ruolo "+ruolo.getNome()+" creazione in corso...");
  864.                     this.gestoreCRUD.createRuolo(ruolo);
  865.                     this.log.info("Ruolo "+ruolo.getNome()+" creato.");             
  866.                 }
  867.                 
  868.             }
  869.             
  870.         }catch(Exception e){
  871.             e.printStackTrace(System.err);
  872.             throw new DriverRegistroServiziException("Errore durante la conversione XML dei ruoli: "+e.getMessage(),e);
  873.         }
  874.         
  875.         
  876.         
  877.         
  878.         
  879.         
  880.         // Scope
  881.         try{
  882.             
  883.             for(int i=0; i<this.sorgenteRegistro.sizeScopeList(); i++){
  884.                 Scope scope = this.sorgenteRegistro.getScope(i);
  885.                 scope.setSuperUser(this.superUser);
  886.                 impostaInformazioniRegistroDB_Scope(scope);
  887.                 
  888.                 IDScope idScope = new IDScope(scope.getNome());
  889.                 if( (reset==false) && this.gestoreCRUD.existsScope(idScope)){
  890.                     if(updateEnabled) {
  891.                         this.log.info("Scope "+scope.getNome()+" aggiornamento in corso...");
  892.                         this.gestoreCRUD.updateScope(scope);
  893.                         this.log.info("Scope "+scope.getNome()+" aggiornato.");
  894.                     }
  895.                     else {
  896.                         this.log.info("Scope "+scope.getNome()+" non aggiornato (aggiornamento disabilitato).");
  897.                     }
  898.                 }else{
  899.                     this.log.info("Scope "+scope.getNome()+" creazione in corso...");
  900.                     this.gestoreCRUD.createScope(scope);
  901.                     this.log.info("Scope "+scope.getNome()+" creato.");             
  902.                 }
  903.                 
  904.             }
  905.             
  906.         }catch(Exception e){
  907.             e.printStackTrace(System.err);
  908.             throw new DriverRegistroServiziException("Errore durante la conversione XML degli scope: "+e.getMessage(),e);
  909.         }
  910.                 
  911.         
  912.         
  913.         

  915.         // Soggetto
  916.         try{
  917.             
  918.             for(int i=0; i<this.sorgenteRegistro.sizeSoggettoList(); i++){
  919.                 Soggetto soggetto = this.sorgenteRegistro.getSoggetto(i);
  920.                 this.gestioneSoggetto(soggetto, reset, aggiornamentoSoggetti,pddConfig.getPddOperativaCtrlstatSinglePdd(), updateEnabled);
  921.             }
  922.             
  923.         }catch(Exception e){
  924.             e.printStackTrace(System.err);
  925.             throw new DriverRegistroServiziException("Errore durante la conversione XML dei soggetti: "+e.getMessage(),e);
  926.         }
  927.         
  928.         
  929.         // Accordi Cooperazione
  930.         try{
  931.             for(int i=0; i<this.sorgenteRegistro.sizeAccordoCooperazioneList(); i++){
  932.                 AccordoCooperazione ac = this.sorgenteRegistro.getAccordoCooperazione(i);
  933.                 
  934.                 // stato package
  935.                 if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  936.                     ac.setStatoPackage(statoAccordo.toString());
  937.                 }
  938.                 
  939.                 this.gestioneAccordoCooperazione(ac, reset, updateEnabled);
  940.             }
  941.             
  942.         }catch(Exception e){
  943.             e.printStackTrace(System.err);
  944.             throw new DriverRegistroServiziException("Errore durante la conversione XML degli accordi di cooperazione: "+e.getMessage(),e);
  945.         }
  946.         
  947.         
  948.         // Accordi Servizio Parte Comune
  949.         List<AccordoServizioParteComune> accordiServizioComposti = new ArrayList<AccordoServizioParteComune>();
  950.         List<String> accordiServizioCompostiID = new ArrayList<>();
  951.         try{
  952.             for(int i=0; i<this.sorgenteRegistro.sizeAccordoServizioParteComuneList(); i++){
  953.                 AccordoServizioParteComune as = this.sorgenteRegistro.getAccordoServizioParteComune(i);
  954.                 
  955.                 // stato package
  956.                 if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  957.                     as.setStatoPackage(statoAccordo.toString());
  958.                 }
  959.                 
  960.                 if(as.getServizioComposto()==null){
  961.                     this.gestioneAccordoServizioParteComune(as, reset, updateEnabled);
  962.                 }else{
  963.                     String idAccordoServizioComposto = this.idAccordoFactory.getUriFromAccordo(as);
  964.                     this.log.debug("AccordoServizio ["+idAccordoServizioComposto+"] e' un accordo di servizio composto, verra posticipata la gestione dopo la creazione dei servizi");
  965.                     accordiServizioComposti.add(as);
  966.                     accordiServizioCompostiID.add(idAccordoServizioComposto);
  967.                 }
  968.             }
  969.             
  970.         }catch(Exception e){
  971.             e.printStackTrace(System.err);
  972.             throw new DriverRegistroServiziException("Errore durante la conversione XML degli accordi: "+e.getMessage(),e);
  973.         }
  974.         
  975.         
  976.         // Accordo Servizio Parte Specifica
  977.         List<AccordoServizioParteSpecifica> servizioComposti = new ArrayList<AccordoServizioParteSpecifica>();
  978.         List<Soggetto> servizioComposti_Soggetti = new ArrayList<Soggetto>();
  979.         try{
  980.             
  981.             for(int i=0; i<this.sorgenteRegistro.sizeSoggettoList(); i++){
  982.                 Soggetto soggetto = this.sorgenteRegistro.getSoggetto(i);
  983.                 for(int j=0; j<soggetto.sizeAccordoServizioParteSpecificaList(); j++){
  984.                     AccordoServizioParteSpecifica servizio = soggetto.getAccordoServizioParteSpecifica(j);
  985.                     
  986.                     // stato package
  987.                     if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  988.                         servizio.setStatoPackage(statoAccordo.toString());
  989.                     }
  990.                     // accordo parte specifica
  991.                     if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  992.                         if(servizio.getVersione()==null){
  993.                             servizio.setVersione(1);
  994.                         }
  995.                     }
  996.                     
  997.                     boolean servizioComposto = accordiServizioCompostiID.contains(servizio.getAccordoServizioParteComune());
  998.                     if(!servizioComposto){
  999.                         this.gestioneServizio(servizio, soggetto, reset, mantieniFruitoriEsistenti,statoAccordo, updateEnabled);
  1000.                     }else{
  1001.                         String uri = this.idServizioFactory.getUriFromAccordo(servizio);
  1002.                         this.log.debug("Servizio ["+uri+"] e' un servizio composto, verra posticipata la gestione dopo la creazione degli accordi di servizio composti");
  1003.                         servizioComposti.add(servizio);
  1004.                         servizioComposti_Soggetti.add(soggetto);
  1005.                     }
  1006.                 }
  1007.             }
  1008.             
  1009.         }catch(Exception e){
  1010.             e.printStackTrace(System.err);
  1011.             throw new DriverRegistroServiziException("Errore durante la conversione XML dei servizi: "+e.getMessage(),e);
  1012.         }
  1013.         
  1014.         // Accordi Servizio Composti
  1015.         try{
  1016.             while(accordiServizioComposti.size()>0){
  1017.                 AccordoServizioParteComune as = accordiServizioComposti.remove(0);
  1018.                 this.gestioneAccordoServizioParteComune(as, reset, updateEnabled);
  1019.             }
  1020.         }catch(Exception e){
  1021.             e.printStackTrace(System.err);
  1022.             throw new DriverRegistroServiziException("Errore durante la conversione XML degli accordi di servizio composti: "+e.getMessage(),e);
  1023.         }
  1024.         
  1025.         // Servizi di  Accordi Servizio Composti
  1026.         try{
  1027.             while(servizioComposti.size()>0){
  1028.                 AccordoServizioParteSpecifica servizio = servizioComposti.remove(0);
  1029.                 Soggetto soggetto = servizioComposti_Soggetti.remove(0);
  1030.                 this.gestioneServizio(servizio, soggetto, reset, mantieniFruitoriEsistenti,statoAccordo, updateEnabled);
  1031.             }
  1032.         }catch(Exception e){
  1033.             e.printStackTrace(System.err);
  1034.             throw new DriverRegistroServiziException("Errore durante la conversione XML dei servizi degli accordi di servizio composti: "+e.getMessage(),e);
  1035.         }
  1036.         
  1037.     }
  1038.     
  1039.     public static void impostaInformazioniRegistroDB_PortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  1040.         if(pdd.getImplementazione()==null)
  1041.             pdd.setImplementazione("standard");
  1042.     }
  1043.     
  1044.     public static void impostaInformazioniRegistroDB_PortaDominio_update(PortaDominio pdd,
  1045.             String nomePddOperativaCtrlstatSinglePdD,Logger log,DriverRegistroServiziDB driverRegistroServiziDB,String tipoPdd) throws DriverRegistroServiziException{
  1046.         if(pdd.getNome().equals(nomePddOperativaCtrlstatSinglePdD)){
  1047.             log.info("Porta di Dominio "+pdd.getNome()+" aggiornamento tipo["+PddTipologia.OPERATIVO.toString()+"] in corso...");
  1048.             driverRegistroServiziDB.updateTipoPortaDominio(pdd.getNome(), PddTipologia.OPERATIVO.toString());
  1049.             log.info("Porta di Dominio "+pdd.getNome()+" aggiornata con tipo "+PddTipologia.OPERATIVO.toString()+".");
  1050.         }else{
  1051.             log.info("Porta di Dominio "+pdd.getNome()+" aggiornamento tipo["+PddTipologia.ESTERNO.toString()+"] in corso...");
  1052.             driverRegistroServiziDB.updateTipoPortaDominio(pdd.getNome(), tipoPdd);
  1053.             log.info("Porta di Dominio "+pdd.getNome()+" aggiornata con tipo "+PddTipologia.ESTERNO.toString()+".");
  1054.         }
  1055.     }
  1056.     
  1057.     public static void impostaInformazioniRegistroDB_Gruppo(Gruppo gruppo) throws DriverRegistroServiziException{

  1059.     }
  1060.     
  1061.     public static void impostaInformazioniRegistroDB_Ruolo(Ruolo ruolo) throws DriverRegistroServiziException{

  1063.     }
  1064.     
  1065.     public static void impostaInformazioniRegistroDB_Scope(Scope scope) throws DriverRegistroServiziException{

  1067.     }
  1068.     
  1069.     
  1070.     
  1071.     private static void mantieniFruitori(AccordoServizioParteSpecifica old,AccordoServizioParteSpecifica servizio){
  1072.         for(int fr=0; fr<old.sizeFruitoreList(); fr++){
  1073.             boolean find = false;
  1074.             for(int frNew =0; frNew < servizio.sizeFruitoreList(); frNew++){
  1075.                 if(servizio.getFruitore(frNew).getTipo().equals(old.getFruitore(fr).getTipo()) &&
  1076.                         servizio.getFruitore(frNew).getNome().equals(old.getFruitore(fr).getNome()) ){
  1077.                     find = true;
  1078.                     break;
  1079.                 }
  1080.             }
  1081.             if(!find){
  1082.                 servizio.addFruitore(old.getFruitore(fr));
  1083.             }
  1084.         }
  1085.     }
  1086.     
  1087.     public static void aggiornatoStatoFruitori(AccordoServizioParteSpecifica servizio,StatiAccordo statoAccordo){
  1088.         for(int i =0; i < servizio.sizeFruitoreList(); i++){
  1089.             servizio.getFruitore(i).setStatoPackage(statoAccordo.toString());
  1090.         }
  1091.     }
  1092.     
  1093.     public void delete(boolean deleteSoggetti, boolean deleteMappingErogazioneFruizione) throws DriverRegistroServiziException{
  1094.         
  1095.         // Servizi
  1096.         try{
  1097.             
  1098.             for(int i=0; i<this.sorgenteRegistro.sizeSoggettoList(); i++){
  1099.                 Soggetto soggetto = this.sorgenteRegistro.getSoggetto(i);
  1100.                 for(int j=0; j<soggetto.sizeAccordoServizioParteSpecificaList(); j++){
  1101.                     AccordoServizioParteSpecifica servizio = soggetto.getAccordoServizioParteSpecifica(j);
  1102.                     servizio.setTipoSoggettoErogatore(soggetto.getTipo());
  1103.                     servizio.setNomeSoggettoErogatore(soggetto.getNome());
  1104.                     IDServizio idServizio = this.idServizioFactory.getIDServizioFromAccordo(servizio);
  1105.                     String uri = this.idServizioFactory.getUriFromAccordo(servizio);
  1106.                     
  1107.                     if(deleteMappingErogazioneFruizione && this.gestoreCRUD instanceof DriverRegistroServiziDB) {
  1108.                         DriverRegistroServiziDB driver = (DriverRegistroServiziDB) this.gestoreCRUD;
  1109.                         Connection con = null;
  1110.                         try {
  1111.                             con = driver.getConnection("XMLDataConverter.mappingErogazioneFruizione");
  1112.                             if(con.getAutoCommit()) {
  1113.                                 con.setAutoCommit(false);
  1114.                             }
  1115.                             this.log.info("Servizio "+uri+" (mappingErogazione) eliminazione in corso...");                         
  1116.                             if(this.gestoreCRUD.existsAccordoServizioParteSpecifica(idServizio)){
  1117.                                 // elimino anche tutti i mapping fruitori
  1118.                                 AccordoServizioParteSpecifica dbImage = driver.getAccordoServizioParteSpecifica(idServizio);
  1119.                                 for (Fruitore fruitore : dbImage.getFruitoreList()) {
  1120.                                     IDSoggetto idFruitore = new IDSoggetto(fruitore.getTipo(), fruitore.getNome());
  1121.                                     if(DBMappingUtils.existsIDPorteDelegateAssociate(idServizio, idFruitore, con, driver.getTipoDB())) {
  1122.                                         DBMappingUtils.deleteMappingFruizione(idServizio, idFruitore, true, con, driver.getTipoDB()); // elimina anche le porte delegate
  1123.                                     }
  1124.                                 }
  1125.                             }
  1126.                             if(DBMappingUtils.existsIDPorteApplicativeAssociate(idServizio, con, driver.getTipoDB())) {
  1127.                                 DBMappingUtils.deleteMappingErogazione(idServizio, true, con, driver.getTipoDB()); // elimina anche le porte applicative
  1128.                             }
  1129.                             this.log.info("Servizio "+uri+" (mappingErogazione) eliminazione completata");
  1130.                         }
  1131.                         finally {
  1132.                             try {
  1133.                                 if(con!=null) {
  1134.                                     con.commit();
  1135.                                 }
  1136.                             }catch(Exception t) {
  1137.                                 // ignore
  1138.                             }
  1139.                             try {
  1140.                                 if(con!=null) {
  1141.                                     con.setAutoCommit(true);
  1142.                                 }
  1143.                             }catch(Exception t) {
  1144.                                 // ignore
  1145.                             }
  1146.                             driver.releaseConnection(con);
  1147.                         }
  1148.                     }
  1149.                     
  1150.                     this.log.info("Servizio "+uri+" eliminazione in corso...");
  1151.                     if(this.gestoreCRUD.existsAccordoServizioParteSpecifica(idServizio)){
  1152.                         this.gestoreCRUD.deleteAccordoServizioParteSpecifica(((IDriverRegistroServiziGet)this.gestoreCRUD).getAccordoServizioParteSpecifica(idServizio));
  1153.                     }
  1154.                     this.log.info("Servizio "+uri+" eliminato.");
  1155.                 }
  1156.             }
  1157.             
  1158.         }catch(Exception e){
  1159.             e.printStackTrace(System.err);
  1160.             throw new DriverRegistroServiziException("Errore durante l'eliminazione dei servizi: "+e.getMessage(),e);
  1161.         }
  1162.         
  1163.             
  1164.         
  1165.         
  1166.         // Accordi Servizio
  1167.         List<AccordoServizioParteComune> asServiziNonComposti = new ArrayList<AccordoServizioParteComune>();
  1168.         try{
  1169.             for(int i=0; i<this.sorgenteRegistro.sizeAccordoServizioParteComuneList(); i++){
  1170.                 AccordoServizioParteComune as = this.sorgenteRegistro.getAccordoServizioParteComune(i);
  1171.                 if(as.getServizioComposto()==null){
  1172.                     asServiziNonComposti.add(as);
  1173.                 }
  1174.                 else{
  1175.                     this.log.info("Accordo di Servizio Composto "+this.idAccordoFactory.getUriFromAccordo(as)+" eliminazione in corso...");
  1176.                     if( this.gestoreCRUD.existsAccordoServizioParteComune(this.idAccordoFactory.getIDAccordoFromAccordo(as))){
  1177.                         this.gestoreCRUD.deleteAccordoServizioParteComune(((IDriverRegistroServiziGet)this.gestoreCRUD).getAccordoServizioParteComune(this.idAccordoFactory.getIDAccordoFromAccordo(as)));
  1178.                     }
  1179.                     this.log.info("Accordo di Servizio Composto "+this.idAccordoFactory.getUriFromAccordo(as)+" eliminato");
  1180.                 }
  1181.             }
  1182.             
  1183.             while(asServiziNonComposti.size()>0){
  1184.                 AccordoServizioParteComune as =  asServiziNonComposti.remove(0);
  1185.                 this.log.info("Accordo di Servizio "+this.idAccordoFactory.getUriFromAccordo(as)+" eliminazione in corso...");
  1186.                 if( this.gestoreCRUD.existsAccordoServizioParteComune(this.idAccordoFactory.getIDAccordoFromAccordo(as))){
  1187.                     this.gestoreCRUD.deleteAccordoServizioParteComune(((IDriverRegistroServiziGet)this.gestoreCRUD).getAccordoServizioParteComune(this.idAccordoFactory.getIDAccordoFromAccordo(as)));
  1188.                 }
  1189.                 this.log.info("Accordo di Servizio "+this.idAccordoFactory.getUriFromAccordo(as)+" eliminato");
  1190.             }
  1191.             
  1192.         }catch(Exception e){
  1193.             e.printStackTrace(System.err);
  1194.             throw new DriverRegistroServiziException("Errore durante l'eliminazione degli accordi: "+e.getMessage(),e);
  1195.         }
  1196.         
  1197.         
  1198.         
  1199.         
  1200.         // Accordi Cooperazione
  1201.         try{
  1202.             for(int i=0; i<this.sorgenteRegistro.sizeAccordoCooperazioneList(); i++){
  1203.                 AccordoCooperazione ac = this.sorgenteRegistro.getAccordoCooperazione(i);
  1204.                 this.log.info("Accordo di Cooperazione "+this.idAccordoCooperazioneFactory.getUriFromAccordo(ac)+" eliminazione in corso...");
  1205.                 if( this.gestoreCRUD.existsAccordoCooperazione(this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(ac))){
  1206.                     this.gestoreCRUD.deleteAccordoCooperazione(((IDriverRegistroServiziGet)this.gestoreCRUD).getAccordoCooperazione(this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(ac)));
  1207.                 }
  1208.                 this.log.info("Accordo di Cooperazione "+this.idAccordoCooperazioneFactory.getUriFromAccordo(ac)+" eliminato");
  1209.             }
  1210.             
  1211.         }catch(Exception e){
  1212.             e.printStackTrace(System.err);
  1213.             throw new DriverRegistroServiziException("Errore durante l'eliminazione degli accordi di cooperazione: "+e.getMessage(),e);
  1214.         }
  1215.         
  1216.         
  1217.         if(deleteSoggetti){
  1218.             
  1219.             // Soggetto
  1220.             try{
  1221.                 
  1222.                 for(int i=0; i<this.sorgenteRegistro.sizeSoggettoList(); i++){
  1223.                     Soggetto soggetto = this.sorgenteRegistro.getSoggetto(i);
  1224.                     IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome());
  1225.                     this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" eliminazione in corso...");
  1226.                     if( this.gestoreCRUD.existsSoggetto(idSoggetto)){
  1227.                         this.gestoreCRUD.deleteSoggetto(((IDriverRegistroServiziGet)this.gestoreCRUD).getSoggetto(idSoggetto));
  1228.                     }
  1229.                     this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" eliminato.");
  1230.                 }
  1231.                 
  1232.             }catch(Exception e){
  1233.                 e.printStackTrace(System.err);
  1234.                 throw new DriverRegistroServiziException("Errore durante l'eliminazione dei soggetti: "+e.getMessage(),e);
  1235.             }
  1236.             
  1237.             
  1238.             // Porte di Dominio
  1239.             try{
  1240.                 
  1241.                 for(int i=0; i<this.sorgenteRegistro.sizePortaDominioList(); i++){
  1242.                     PortaDominio pdd = this.sorgenteRegistro.getPortaDominio(i);
  1243.                     this.log.info("Porta di Dominio "+pdd.getNome()+" eliminazione in corso...");
  1244.                     if( this.gestoreCRUD.existsPortaDominio(pdd.getNome())){
  1245.                         this.gestoreCRUD.deletePortaDominio(((IDriverRegistroServiziGet)this.gestoreCRUD).getPortaDominio(pdd.getNome()));
  1246.                     }
  1247.                     this.log.info("Porta di Dominio "+pdd.getNome()+" eliminata.");
  1248.                 }
  1249.                 
  1250.             }catch(Exception e){
  1251.                 e.printStackTrace(System.err);
  1252.                 throw new DriverRegistroServiziException("Errore durante l'eliminazione delle porte di dominio: "+e.getMessage(),e);
  1253.             }
  1254.             
  1255.         }
  1256.             
  1257.     }
  1258.     
  1259.     
  1260.     private byte [] gestioneBytesDocumenti_Wsdl_Wsbl(String documento) throws Exception{
  1261.         ByteArrayOutputStream bout = new ByteArrayOutputStream();
  1262.         if(documento!=null && (documento.equals("http://undefined")==false) ){
  1263.             if(documento.startsWith("http://") || documento.startsWith("file://")){
  1264.                 byte[] file = HttpUtilities.requestHTTPFile(documento);
  1265.                 if(file==null)
  1266.                     throw new Exception("byte[] is null");
  1267.                 else
  1268.                     bout.write(file);
  1269.             }else{
  1270.                 File f = new File(documento);
  1271.                 if(f.exists()){
  1272.                     FileInputStream file = null;
  1273.                     try{
  1274.                         file = new FileInputStream(f);
  1275. //                      byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  1276. //                      int letti = 0;
  1277. //                      while( (letti=file.read(reads)) >=0 ){
  1278. //                          bout.write(reads,0,letti);
  1279. //                      }
  1280.                         CopyStream.copy(file, bout);
  1281.                     }finally{
  1282.                         try{
  1283.                             if(file!=null){
  1284.                                 file.close();
  1285.                             }
  1286.                         }catch(Exception eClose){
  1287.                             // close
  1288.                         }
  1289.                     }
  1290.                 }
  1291.                 else if(this.parentFile!=null){
  1292.                     File fWithParent = new File(this.parentFile,documento);
  1293.                     if(fWithParent.exists()){
  1294.                         FileInputStream file = null;
  1295.                         try{
  1296.                             file = new FileInputStream(fWithParent);
  1297. //                          byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  1298. //                          int letti = 0;
  1299. //                          while( (letti=file.read(reads)) >=0 ){
  1300. //                              bout.write(reads,0,letti);
  1301. //                          }
  1302.                             CopyStream.copy(file, bout);
  1303.                         }finally{
  1304.                             try{
  1305.                                 if(file!=null){
  1306.                                     file.close();
  1307.                                 }
  1308.                             }catch(Exception eClose){
  1309.                                 // close
  1310.                             }
  1311.                         }   
  1312.                     }
  1313.                 }
  1314.                 else{
  1315.                     throw new Exception("File ["+documento+"] non esistente");
  1316.                 }
  1317.             }
  1318.             bout.flush();
  1319.             bout.close();
  1320.             if(bout.size()>0){
  1321.                 return bout.toByteArray();
  1322.             }   
  1323.         }
  1324.         return null;
  1325.     }
  1326.     
  1327.     
  1328.     private void initializeWSDLBytes(AccordoServizioParteComune as) throws DriverRegistroServiziException{
  1329.         
  1330.         String uriAS = this.idAccordoFactory.getUriFromAccordo(as);
  1331.     
  1332.         if(as.getWsdlDefinitorio()!=null){
  1333.             try{
  1334.                 as.setByteWsdlDefinitorio(gestioneBytesDocumenti_Wsdl_Wsbl(as.getWsdlDefinitorio()));
  1335.             }catch(Exception e){
  1336.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura wsdl definitorio ["+as.getWsdlDefinitorio()+"] non riuscita:",e);
  1337.             }   
  1338.         }
  1339.         if(as.getWsdlConcettuale()!=null){
  1340.             try{
  1341.                 as.setByteWsdlConcettuale(gestioneBytesDocumenti_Wsdl_Wsbl(as.getWsdlConcettuale()));
  1342.             }catch(Exception e){
  1343.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura wsdl concettuale ["+as.getWsdlConcettuale()+"] non riuscita:",e);
  1344.             }   
  1345.         }
  1346.         if(as.getWsdlLogicoErogatore()!=null){
  1347.             try{
  1348.                 as.setByteWsdlLogicoErogatore(gestioneBytesDocumenti_Wsdl_Wsbl(as.getWsdlLogicoErogatore()));
  1349.             }catch(Exception e){
  1350.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura wsdl logico erogatore ["+as.getWsdlLogicoErogatore()+"] non riuscita:",e);
  1351.             }   
  1352.         }
  1353.         if(as.getWsdlLogicoFruitore()!=null){
  1354.             try{
  1355.                 as.setByteWsdlLogicoFruitore(gestioneBytesDocumenti_Wsdl_Wsbl(as.getWsdlLogicoFruitore()));
  1356.             }catch(Exception e){
  1357.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura wsdl logico fruitore ["+as.getWsdlLogicoFruitore()+"] non riuscita:",e);
  1358.             }   
  1359.         }
  1360.         
  1361.         if(as.getSpecificaConversazioneConcettuale()!=null){
  1362.             try{
  1363.                 as.setByteSpecificaConversazioneConcettuale(gestioneBytesDocumenti_Wsdl_Wsbl(as.getSpecificaConversazioneConcettuale()));
  1364.             }catch(Exception e){
  1365.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura specifica conversazione concettuale ["+as.getSpecificaConversazioneConcettuale()+"] non riuscita:",e);
  1366.             }   
  1367.         }
  1368.         if(as.getSpecificaConversazioneErogatore()!=null){
  1369.             try{
  1370.                 as.setByteSpecificaConversazioneErogatore(gestioneBytesDocumenti_Wsdl_Wsbl(as.getSpecificaConversazioneErogatore()));
  1371.             }catch(Exception e){
  1372.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura specifica conversazione erogatore ["+as.getSpecificaConversazioneErogatore()+"] non riuscita:",e);
  1373.             }   
  1374.         }
  1375.         if(as.getSpecificaConversazioneFruitore()!=null){
  1376.             try{
  1377.                 as.setByteSpecificaConversazioneFruitore(gestioneBytesDocumenti_Wsdl_Wsbl(as.getSpecificaConversazioneFruitore()));
  1378.             }catch(Exception e){
  1379.                 this.log.warn("Accordo di Servizio "+uriAS+", lettura specifica conversazione fruitore ["+as.getSpecificaConversazioneFruitore()+"] non riuscita:",e);
  1380.             }   
  1381.         }
  1382.     }
  1383.     
  1384.     
  1385.     private void initializeWSDLBytes(AccordoServizioParteSpecifica s){
  1386.         if(s.getWsdlImplementativoErogatore()!=null){
  1387.             try{
  1388.                 s.setByteWsdlImplementativoErogatore(gestioneBytesDocumenti_Wsdl_Wsbl(s.getWsdlImplementativoErogatore()));
  1389.             }catch(Exception e){
  1390.                 String uri = null;
  1391.                 try{
  1392.                     uri = this.idServizioFactory.getUriFromAccordo(s);
  1393.                 }catch(Exception eInternal){
  1394.                     throw new RuntimeException(eInternal);
  1395.                 }
  1396.                 this.log.warn("Servizio "+uri+", lettura wsdl implementativo erogatore ["+s.getWsdlImplementativoErogatore()+"] non riuscita:",e);
  1397.             }
  1398.         }
  1399.         if(s.getWsdlImplementativoFruitore()!=null){
  1400.             try{
  1401.                 s.setByteWsdlImplementativoFruitore(gestioneBytesDocumenti_Wsdl_Wsbl(s.getWsdlImplementativoFruitore()));
  1402.             }catch(Exception e){
  1403.                 String uri = null;
  1404.                 try{
  1405.                     uri = this.idServizioFactory.getUriFromAccordo(s);
  1406.                 }catch(Exception eInternal){
  1407.                     throw new RuntimeException(eInternal);
  1408.                 }
  1409.                 this.log.warn("Servizio "+uri+", lettura wsdl implementativo fruitore ["+s.getWsdlImplementativoFruitore()+"] non riuscita:",e);
  1410.             }   
  1411.         }
  1412.     }

  1414.     
  1415.     private byte[] readDocumento(String fileName) throws DriverRegistroServiziException{
  1416.         
  1417.         ByteArrayOutputStream bout = new ByteArrayOutputStream();
  1418.         try{
  1419.             if(fileName.startsWith("http://") || fileName.startsWith("file://")){
  1420.                 byte[] file = HttpUtilities.requestHTTPFile(fileName);
  1421.                 if(file==null)
  1422.                     throw new Exception("byte[] is null");
  1423.                 else
  1424.                     bout.write(file);
  1425.             }else{
  1426.                 File f = new File(fileName);
  1427.                 if(f.exists()){
  1428.                     FileInputStream file = null;
  1429.                     try{
  1430.                         file = new FileInputStream(f);
  1431. //                      byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  1432. //                      int letti = 0;
  1433. //                      while( (letti=file.read(reads)) >=0 ){
  1434. //                          bout.write(reads,0,letti);
  1435. //                      }
  1436.                         CopyStream.copy(file, bout);
  1437.                     }finally{
  1438.                         try{
  1439.                             if(file!=null){
  1440.                                 file.close();
  1441.                             }
  1442.                         }catch(Exception eClose){
  1443.                             // close
  1444.                         }
  1445.                     }       
  1446.                 }
  1447.                 else if(this.parentFile!=null){
  1448.                     File fWithParent = new File(this.parentFile,fileName);
  1449.                     if(fWithParent.exists()){
  1450.                         FileInputStream file = null;
  1451.                         try{
  1452.                             file = new FileInputStream(fWithParent);
  1453. //                          byte [] reads = new byte[Utilities.DIMENSIONE_BUFFER];
  1454. //                          int letti = 0;
  1455. //                          while( (letti=file.read(reads)) >=0 ){
  1456. //                              bout.write(reads,0,letti);
  1457. //                          }
  1458.                             CopyStream.copy(file, bout);
  1459.                         }finally{
  1460.                             try{
  1461.                                 if(file!=null){
  1462.                                     file.close();
  1463.                                 }
  1464.                             }catch(Exception eClose){
  1465.                                 // close
  1466.                             }
  1467.                         }   
  1468.                     }
  1469.                 }
  1470.                 else{
  1471.                     throw new Exception("File ["+fileName+"] non esistente");
  1472.                 }
  1473.             }
  1474.             bout.flush();
  1475.             bout.close();
  1476.             if(bout.size()>0){
  1477.                 return bout.toByteArray();
  1478.             }
  1479.             
  1480.         }catch(Exception e){
  1481.             this.log.warn("File "+fileName+", lettura documento non riuscita:",e);
  1482.         }   
  1483.         
  1484.         throw new DriverRegistroServiziException("Contenuto non letto?? File ["+fileName+"]");
  1485.     }
  1486.     
  1487.     private String getNomeFile(String fileName){
  1488.         String name = null;
  1489.         if(fileName.startsWith("http://")){
  1490.             int index = fileName.lastIndexOf("/");
  1491.             name = fileName.substring(index+1, fileName.length());
  1492.         }
  1493.         else {
  1494.             File f = new File(fileName);
  1495.             name = f.getName();
  1496.         }
  1497.         return name;
  1498.     }
  1499.     
  1500.     private static void gestioneDefaultConnettoreHTTP(Connettore connettore){
  1501.         if(connettore.getProperties()!=null){
  1502.             if(connettore.getProperties().containsKey(CostantiDB.CONNETTORE_HTTPS_TRUST_STORE_TYPE)==false){
  1503.                 Property cp = new Property();
  1504.                 cp.setNome(CostantiDB.CONNETTORE_HTTPS_TRUST_STORE_TYPE);
  1505.                 cp.setValore(KeystoreType.JKS.getNome()); // default
  1506.                 connettore.addProperty(cp);
  1507.             }
  1508.             if(connettore.getProperties().containsKey(CostantiDB.CONNETTORE_HTTPS_TRUST_MANAGEMENT_ALGORITM)==false){
  1509.                 Property cp = new Property();
  1510.                 cp.setNome(CostantiDB.CONNETTORE_HTTPS_TRUST_MANAGEMENT_ALGORITM);
  1511.                 cp.setValore(TrustManagerFactory.getDefaultAlgorithm()); // default
  1512.                 connettore.addProperty(cp);
  1513.             }
  1514.             if(connettore.getProperties().containsKey(CostantiDB.CONNETTORE_HTTPS_KEY_STORE_LOCATION)){
  1515.                 if(connettore.getProperties().containsKey(CostantiDB.CONNETTORE_HTTPS_KEY_STORE_TYPE)==false){
  1516.                     Property cp = new Property();
  1517.                     cp.setNome(CostantiDB.CONNETTORE_HTTPS_KEY_STORE_TYPE);
  1518.                     cp.setValore(KeystoreType.JKS.getNome()); // default
  1519.                     connettore.addProperty(cp);
  1520.                 }
  1521.                 if(connettore.getProperties().containsKey(CostantiDB.CONNETTORE_HTTPS_KEY_MANAGEMENT_ALGORITM)==false){
  1522.                     Property cp = new Property();
  1523.                     cp.setNome(CostantiDB.CONNETTORE_HTTPS_KEY_MANAGEMENT_ALGORITM);
  1524.                     cp.setValore(KeyManagerFactory.getDefaultAlgorithm()); // default
  1525.                     connettore.addProperty(cp);
  1526.                 }
  1527.             }   
  1528.         }
  1529.     }
  1530.     
  1531.     public static void impostaInformazioniRegistroDB_Soggetto(Soggetto soggetto,String pddOperativaCtrlstatSinglePdd) throws DriverRegistroServiziException{
  1532.         if(soggetto.getConnettore()!=null){
  1533.             // I nomi vengono autogenerati dal driver
  1534.             soggetto.getConnettore().setNome(null);
  1535.             // I tipi diversi da disabilitato,http,jms,null,nullEcho sono custom
  1536.             String tipoConnettore = soggetto.getConnettore().getTipo();
  1537.             if ( !TipiConnettore.JMS.getNome().equals(tipoConnettore) && !TipiConnettore.HTTP.getNome().equals(tipoConnettore) &&
  1538.                  !TipiConnettore.DISABILITATO.getNome().equals(tipoConnettore) && !TipiConnettore.NULL.getNome().equals(tipoConnettore) &&
  1539.                  !TipiConnettore.NULLECHO.getNome().equals(tipoConnettore) ){
  1540.                 soggetto.getConnettore().setCustom(true);
  1541.             }
  1542.             // Gestione default per connettore https
  1543.             if(TipiConnettore.HTTPS.getNome().equals(tipoConnettore)){
  1544.                 gestioneDefaultConnettoreHTTP(soggetto.getConnettore());
  1545.             }
  1546.         }
  1547.         IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome());
  1548.         if( (soggetto.getIdentificativoPorta()==null) || ("".equals(soggetto.getIdentificativoPorta())) ) {
  1549.             try {
  1550.                 soggetto.setIdentificativoPorta(ProtocolFactoryReflectionUtils.getIdentificativoPortaDefault(idSoggetto));
  1551.             }catch(Exception e) {
  1552.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  1553.             }
  1554.         }
  1555.         if( (soggetto.getCodiceIpa() == null) || ("".equals(soggetto.getCodiceIpa())) ){
  1556.             try {
  1557.                 soggetto.setCodiceIpa(ProtocolFactoryReflectionUtils.getCodiceIPADefault(idSoggetto));
  1558.             }catch(Exception e) {
  1559.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  1560.             }
  1561.         }
  1562.             
  1563.         if(pddOperativaCtrlstatSinglePdd!=null && soggetto.getPortaDominio()==null){
  1564.             soggetto.setPortaDominio(pddOperativaCtrlstatSinglePdd);
  1565.         }
  1566.     }
  1567.     public static void impostaInformazioniRegistroDB_Soggetto_update(Soggetto soggetto,Soggetto old){
  1568.         soggetto.setId(old.getId());
  1569.         if(soggetto.getConnettore()==null){
  1570.             soggetto.setConnettore(old.getConnettore());
  1571.         }else{
  1572.             soggetto.getConnettore().setId(old.getConnettore().getId());
  1573.             soggetto.getConnettore().setNome(old.getConnettore().getNome());
  1574.         }
  1575.     }
  1576.     
  1577.     private void gestioneSoggetto(Soggetto soggetto,boolean reset,boolean aggiornamentoSoggetti,String pddOperativaCtrlstatSinglePdd, boolean updateEnabled) throws Exception{
  1578.         soggetto.setSuperUser(this.superUser);
  1579.         IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome());
  1580.         
  1581.         if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  1582.             impostaInformazioniRegistroDB_Soggetto(soggetto,pddOperativaCtrlstatSinglePdd);
  1583.         }
  1584.         
  1585.         // protocol properties: bytes
  1586.         if(soggetto.sizeProtocolPropertyList()>0) {
  1587.             for (ProtocolProperty pp : soggetto.getProtocolPropertyList()) {
  1588.                 if(pp.getFile()!=null) {
  1589.                     pp.setByteFile(this.readDocumento(pp.getFile()));
  1590.                 }
  1591.             }
  1592.         }
  1593.         
  1594.         if( (reset==false) && this.gestoreCRUD.existsSoggetto(idSoggetto)){
  1595.             if(aggiornamentoSoggetti){
  1596.                 if(updateEnabled) {
  1597.                     this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" aggiornamento in corso...");
  1598.                     Soggetto old = ((IDriverRegistroServiziGet)this.gestoreCRUD).getSoggetto(idSoggetto);
  1599.                     impostaInformazioniRegistroDB_Soggetto_update(soggetto, old);
  1600.                     this.gestoreCRUD.updateSoggetto(soggetto);
  1601.                     this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" aggiornato.");
  1602.                 }
  1603.                 else {
  1604.                     this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" non aggiornato (aggiornamento disabilitato).");
  1605.                 }
  1606.             }
  1607.         }else{
  1608.             this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" creazione in corso...");
  1609.             this.gestoreCRUD.createSoggetto(soggetto);
  1610.             this.log.info("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome()+" creato.");
  1611.         }
  1612.     }
  1613.     
  1614.     private void gestioneAccordoCooperazione(AccordoCooperazione ac,boolean reset, boolean updateEnabled) throws Exception {
  1615.         ac.setSuperUser(this.superUser);
  1616.         // bytes
  1617.         for(int k=0; k<ac.sizeAllegatoList();k++){
  1618.             String fileName = ac.getAllegato(k).getFile();
  1619.             String name = getNomeFile(fileName);
  1620.             
  1621.             ac.getAllegato(k).setByteContenuto(this.readDocumento(fileName));
  1622.             ac.getAllegato(k).setFile(name);
  1623.             ac.getAllegato(k).setRuolo(RuoliDocumento.allegato.toString());
  1624.             ac.getAllegato(k).setTipoProprietarioDocumento(ProprietariDocumento.accordoCooperazione.toString());
  1625.         }
  1626.         for(int k=0; k<ac.sizeSpecificaSemiformaleList();k++){
  1627.             String fileName = ac.getSpecificaSemiformale(k).getFile();
  1628.             String name = getNomeFile(fileName);
  1629.             
  1630.             ac.getSpecificaSemiformale(k).setByteContenuto(this.readDocumento(fileName));
  1631.             ac.getSpecificaSemiformale(k).setFile(name);
  1632.             ac.getSpecificaSemiformale(k).setRuolo(RuoliDocumento.specificaSemiformale.toString());
  1633.             ac.getSpecificaSemiformale(k).setTipoProprietarioDocumento(ProprietariDocumento.accordoCooperazione.toString());
  1634.         }
  1635.         // protocol properties: bytes
  1636.         if(ac.sizeProtocolPropertyList()>0) {
  1637.             for (ProtocolProperty pp : ac.getProtocolPropertyList()) {
  1638.                 if(pp.getFile()!=null) {
  1639.                     pp.setByteFile(this.readDocumento(pp.getFile()));
  1640.                 }
  1641.             }
  1642.         }
  1643.         IDAccordoCooperazione idAccordo = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(ac);
  1644.         String uriAC = this.idAccordoCooperazioneFactory.getUriFromIDAccordo(idAccordo);
  1645.         if( (reset==false) && this.gestoreCRUD.existsAccordoCooperazione(idAccordo)){
  1646.             if(updateEnabled) {
  1647.                 this.log.info("Accordo di Cooperazione "+uriAC+" aggiornamento in corso...");
  1648.                 this.gestoreCRUD.updateAccordoCooperazione(ac);
  1649.                 this.log.info("Accordo di Cooperazione "+uriAC+" aggiornato.");
  1650.             }
  1651.             else {
  1652.                 this.log.info("Accordo di Cooperazione "+uriAC+" non aggiornato (aggiornamento disabilitato).");
  1653.             }
  1654.         }else{
  1655.             this.log.info("Accordo di Cooperazione "+uriAC+" creazione in corso...");
  1656.             this.gestoreCRUD.createAccordoCooperazione(ac);
  1657.             this.log.info("Accordo di Cooperazione "+uriAC+" creato.");
  1658.         }
  1659.     }
  1660.     
  1661.     public static boolean equals(StatoFunzionalita arg1, StatoFunzionalita arg2) {
  1662.         if(arg1==null) {
  1663.             return arg2==null;
  1664.         }
  1665.         else {
  1666.             return arg1.equals(arg2);
  1667.         }
  1668.     }
  1669.     
  1670.     public static void impostaInformazioniRegistroDB_AccordoServizioParteComune(AccordoServizioParteComune as){
  1671.         
  1672.         // Devono essere impostati i comportamenti per la ridefinizione delle azioni
  1673.         for(int k=0; k<as.sizeAzioneList();k++){
  1674.             if(
  1675.                     (as.getAzione(k).getProfiloCollaborazione()!=null && !as.getAzione(k).getProfiloCollaborazione().equals(as.getProfiloCollaborazione())) ||
  1676.                     !equals(as.getAzione(k).getConfermaRicezione(),as.getConfermaRicezione()) ||
  1677.                     !equals(as.getAzione(k).getConsegnaInOrdine(),as.getConsegnaInOrdine()) ||
  1678.                     !equals(as.getAzione(k).getFiltroDuplicati(),as.getFiltroDuplicati()) ||
  1679.                     !equals(as.getAzione(k).getIdCollaborazione(),as.getIdCollaborazione()) ||
  1680.                     !equals(as.getAzione(k).getIdRiferimentoRichiesta(),as.getIdRiferimentoRichiesta()) ||
  1681.                     (as.getAzione(k).getScadenza()!=null && !as.getAzione(k).getScadenza().equals(as.getScadenza()))
  1682.                     ) {
  1683.                 as.getAzione(k).setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1684.             }else{
  1685.                 as.getAzione(k).setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1686.                 as.getAzione(k).setProfiloCollaborazione(as.getProfiloCollaborazione());
  1687.                 as.getAzione(k).setConfermaRicezione(as.getConfermaRicezione());
  1688.                 as.getAzione(k).setConsegnaInOrdine(as.getConsegnaInOrdine());
  1689.                 as.getAzione(k).setFiltroDuplicati(as.getFiltroDuplicati());
  1690.                 as.getAzione(k).setIdCollaborazione(as.getIdCollaborazione());
  1691.                 as.getAzione(k).setIdRiferimentoRichiesta(as.getIdRiferimentoRichiesta());
  1692.                 as.getAzione(k).setScadenza(as.getScadenza());
  1693.             }
  1694.         }
  1695.         // Devono essere impostati i comportamenti per la ridefinizione dei port-types e delle azioni dei port-types
  1696.         for(int k=0; k<as.sizePortTypeList();k++){
  1697.             PortType pt = as.getPortType(k);
  1698.             if(
  1699.                     (pt.getProfiloCollaborazione()!=null && !pt.getProfiloCollaborazione().equals(as.getProfiloCollaborazione())) ||
  1700.                     !equals(pt.getConfermaRicezione(),as.getConfermaRicezione()) ||
  1701.                     !equals(pt.getConsegnaInOrdine(),as.getConsegnaInOrdine()) ||
  1702.                     !equals(pt.getFiltroDuplicati(),as.getFiltroDuplicati()) ||
  1703.                     !equals(pt.getIdCollaborazione(),as.getIdCollaborazione()) ||
  1704.                     !equals(pt.getIdRiferimentoRichiesta(),as.getIdRiferimentoRichiesta()) ||
  1705.                     (pt.getScadenza()!=null && !pt.getScadenza().equals(as.getScadenza()))
  1706.                     ) {
  1707.                 pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1708.             }else{
  1709.                 pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1710.                 pt.setProfiloCollaborazione(as.getProfiloCollaborazione());
  1711.                 pt.setConfermaRicezione(as.getConfermaRicezione());
  1712.                 pt.setConsegnaInOrdine(as.getConsegnaInOrdine());
  1713.                 pt.setFiltroDuplicati(as.getFiltroDuplicati());
  1714.                 pt.setIdCollaborazione(as.getIdCollaborazione());
  1715.                 pt.setIdRiferimentoRichiesta(as.getIdRiferimentoRichiesta());
  1716.                 pt.setScadenza(as.getScadenza());
  1717.             }
  1718.             
  1719.             for(int l=0; l<pt.sizeAzioneList();l++){
  1720.                 Operation op = pt.getAzione(l);
  1721.                 
  1722.                 boolean ridefinitoProfiloAzioneParametri = false;
  1723.                 ProfiloCollaborazione profiloDefault = null;
  1724.                 String scadenzaDefault = null;
  1725.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(pt.getProfiloPT())) {
  1726.                     ridefinitoProfiloAzioneParametri = 
  1727.                             !equals(op.getConfermaRicezione(),pt.getConfermaRicezione()) ||
  1728.                             !equals(op.getConsegnaInOrdine(),pt.getConsegnaInOrdine()) ||
  1729.                             !equals(op.getFiltroDuplicati(),pt.getFiltroDuplicati()) ||
  1730.                             !equals(op.getIdCollaborazione(),pt.getIdCollaborazione()) ||
  1731.                             !equals(op.getIdRiferimentoRichiesta(),pt.getIdRiferimentoRichiesta());
  1732.                     profiloDefault = pt.getProfiloCollaborazione();
  1733.                     scadenzaDefault = pt.getScadenza();
  1734.                 }
  1735.                 else {
  1736.                     ridefinitoProfiloAzioneParametri = 
  1737.                             !equals(op.getConfermaRicezione(),as.getConfermaRicezione()) ||
  1738.                             !equals(op.getConsegnaInOrdine(),as.getConsegnaInOrdine()) ||
  1739.                             !equals(op.getFiltroDuplicati(),as.getFiltroDuplicati()) ||
  1740.                             !equals(op.getIdCollaborazione(),as.getIdCollaborazione()) ||
  1741.                             !equals(op.getIdRiferimentoRichiesta(),as.getIdRiferimentoRichiesta());
  1742.                     profiloDefault = as.getProfiloCollaborazione();
  1743.                     scadenzaDefault = as.getScadenza();
  1744.                 }
  1745.                 
  1746.                 if( (op.getProfiloCollaborazione()!=null && !op.getProfiloCollaborazione().equals(profiloDefault)) ||
  1747.                         ridefinitoProfiloAzioneParametri ||
  1748.                         (op.getScadenza()!=null && !op.getScadenza().equals(scadenzaDefault))
  1749.                         ) {
  1750.                     op.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1751.                 }else{
  1752.                     op.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1753.                     
  1754.                     if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(pt.getProfiloPT())) {
  1755.                         op.setProfiloCollaborazione(pt.getProfiloCollaborazione());
  1756.                         op.setConfermaRicezione(pt.getConfermaRicezione());
  1757.                         op.setConsegnaInOrdine(pt.getConsegnaInOrdine());
  1758.                         op.setFiltroDuplicati(pt.getFiltroDuplicati());
  1759.                         op.setIdCollaborazione(pt.getIdCollaborazione());
  1760.                         op.setIdRiferimentoRichiesta(pt.getIdRiferimentoRichiesta());
  1761.                         op.setScadenza(pt.getScadenza());
  1762.                     }
  1763.                     else {
  1764.                         op.setProfiloCollaborazione(as.getProfiloCollaborazione());
  1765.                         op.setConfermaRicezione(as.getConfermaRicezione());
  1766.                         op.setConsegnaInOrdine(as.getConsegnaInOrdine());
  1767.                         op.setFiltroDuplicati(as.getFiltroDuplicati());
  1768.                         op.setIdCollaborazione(as.getIdCollaborazione());
  1769.                         op.setIdRiferimentoRichiesta(as.getIdRiferimentoRichiesta());
  1770.                         op.setScadenza(as.getScadenza());
  1771.                     }
  1772.                 }
  1773.                 

  1775.             }
  1776.         }
  1777.         // Devono essere impostati i comportamenti per la ridefinizione delle azioni
  1778.         for(int k=0; k<as.sizeResourceList();k++){
  1779.             if(
  1780.                     //(as.getResource(k).getProfiloCollaborazione()!=null && !as.getResource(k).getProfiloCollaborazione().equals(as.getProfiloCollaborazione())) ||
  1781.                     !equals(as.getResource(k).getConfermaRicezione(),as.getConfermaRicezione()) ||
  1782.                     !equals(as.getResource(k).getConsegnaInOrdine(),as.getConsegnaInOrdine()) ||
  1783.                     !equals(as.getResource(k).getFiltroDuplicati(),as.getFiltroDuplicati()) ||
  1784.                     !equals(as.getResource(k).getIdCollaborazione(),as.getIdCollaborazione()) ||
  1785.                     !equals(as.getResource(k).getIdRiferimentoRichiesta(),as.getIdRiferimentoRichiesta()) ||
  1786.                     (as.getResource(k).getScadenza()!=null && !as.getResource(k).getScadenza().equals(as.getScadenza()))
  1787.                     ) {
  1788.                 as.getResource(k).setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1789.             }else{
  1790.                 as.getResource(k).setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1791.                 //as.getResource(k).setProfiloCollaborazione(as.getProfiloCollaborazione());
  1792.                 as.getResource(k).setConfermaRicezione(as.getConfermaRicezione());
  1793.                 as.getResource(k).setConsegnaInOrdine(as.getConsegnaInOrdine());
  1794.                 as.getResource(k).setFiltroDuplicati(as.getFiltroDuplicati());
  1795.                 as.getResource(k).setIdCollaborazione(as.getIdCollaborazione());
  1796.                 as.getResource(k).setIdRiferimentoRichiesta(as.getIdRiferimentoRichiesta());
  1797.                 as.getResource(k).setScadenza(as.getScadenza());
  1798.             }           
  1799.         }
  1800.     }
  1801.     
  1802.     private void gestioneAccordoServizioParteComune(AccordoServizioParteComune as,boolean reset, boolean updateEnabled) throws Exception{
  1803.         as.setSuperUser(this.superUser);
  1804.         if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  1805.             impostaInformazioniRegistroDB_AccordoServizioParteComune(as);
  1806.         }
  1807.         // bytes
  1808.         this.initializeWSDLBytes(as);
  1809.         for(int k=0; k<as.sizeAllegatoList();k++){
  1810.             String fileName = as.getAllegato(k).getFile();
  1811.             String name = getNomeFile(fileName);
  1812.             
  1813.             as.getAllegato(k).setByteContenuto(this.readDocumento(fileName));
  1814.             as.getAllegato(k).setFile(name);
  1815.             as.getAllegato(k).setRuolo(RuoliDocumento.allegato.toString());
  1816.             as.getAllegato(k).setTipoProprietarioDocumento(ProprietariDocumento.accordoServizio.toString());
  1817.         }
  1818.         for(int k=0; k<as.sizeSpecificaSemiformaleList();k++){
  1819.             String fileName = as.getSpecificaSemiformale(k).getFile();
  1820.             String name = getNomeFile(fileName);
  1821.             
  1822.             as.getSpecificaSemiformale(k).setByteContenuto(this.readDocumento(fileName));
  1823.             as.getSpecificaSemiformale(k).setFile(name);
  1824.             as.getSpecificaSemiformale(k).setRuolo(RuoliDocumento.specificaSemiformale.toString());
  1825.             as.getSpecificaSemiformale(k).setTipoProprietarioDocumento(ProprietariDocumento.accordoServizio.toString());
  1826.         }
  1827.         if(as.getServizioComposto()!=null){
  1828.             for(int k=0; k<as.getServizioComposto().sizeSpecificaCoordinamentoList();k++){
  1829.                 String fileName = as.getServizioComposto().getSpecificaCoordinamento(k).getFile();
  1830.                 String name = getNomeFile(fileName);
  1831.                 
  1832.                 as.getServizioComposto().getSpecificaCoordinamento(k).setByteContenuto(this.readDocumento(fileName));
  1833.                 as.getServizioComposto().getSpecificaCoordinamento(k).setFile(name);
  1834.                 as.getServizioComposto().getSpecificaCoordinamento(k).setRuolo(RuoliDocumento.specificaCoordinamento.toString());
  1835.                 as.getServizioComposto().getSpecificaCoordinamento(k).setTipoProprietarioDocumento(ProprietariDocumento.accordoServizio.toString());
  1836.             }
  1837.         }
  1838.         // protocol properties: bytes
  1839.         if(as.sizeProtocolPropertyList()>0) {
  1840.             for (ProtocolProperty pp : as.getProtocolPropertyList()) {
  1841.                 if(pp.getFile()!=null) {
  1842.                     pp.setByteFile(this.readDocumento(pp.getFile()));
  1843.                 }
  1844.             }
  1845.             if(as.sizeAzioneList()>0) {
  1846.                 for (Azione azione : as.getAzioneList()) {
  1847.                     for (ProtocolProperty pp : azione.getProtocolPropertyList()) {
  1848.                         if(pp.getFile()!=null) {
  1849.                             pp.setByteFile(this.readDocumento(pp.getFile()));
  1850.                         }
  1851.                     }
  1852.                 }
  1853.             }
  1854.             if(as.sizePortTypeList()>0) {
  1855.                 for (PortType pt : as.getPortTypeList()) {
  1856.                     for (ProtocolProperty pp : pt.getProtocolPropertyList()) {
  1857.                         if(pp.getFile()!=null) {
  1858.                             pp.setByteFile(this.readDocumento(pp.getFile()));
  1859.                         }
  1860.                     }
  1861.                     if(pt.sizeAzioneList()>0) {
  1862.                         for (Operation azione : pt.getAzioneList()) {
  1863.                             for (ProtocolProperty pp : azione.getProtocolPropertyList()) {
  1864.                                 if(pp.getFile()!=null) {
  1865.                                     pp.setByteFile(this.readDocumento(pp.getFile()));
  1866.                                 }
  1867.                             }
  1868.                         }
  1869.                     }
  1870.                 }
  1871.             }
  1872.             if(as.sizeResourceList()>0) {
  1873.                 for (Resource resource : as.getResourceList()) {
  1874.                     if(resource.getPath()!=null && !"".equals(resource.getPath())) {
  1875.                         String pathNormalizzato = null;
  1876.                         pathNormalizzato = resource.getPath().trim();
  1877.                         if(!pathNormalizzato.startsWith("/"))
  1878.                             pathNormalizzato = "/" + pathNormalizzato;
  1879.                         resource.setPath(pathNormalizzato);
  1880.                     }
  1881.                     for (ProtocolProperty pp : resource.getProtocolPropertyList()) {
  1882.                         if(pp.getFile()!=null) {
  1883.                             pp.setByteFile(this.readDocumento(pp.getFile()));
  1884.                         }
  1885.                     }
  1886.                 }
  1887.             }
  1888.         }
  1889.         if(ServiceBinding.SOAP.equals(as.getServiceBinding())) {
  1890.             if(as.getFormatoSpecifica()==null) {
  1891.                 as.setFormatoSpecifica(CostantiRegistroServizi.DEFAULT_VALUE_INTERFACE_TYPE_SOAP);
  1892.             }
  1893.         }else {
  1894.             if(as.getFormatoSpecifica()==null) {
  1895.                 as.setFormatoSpecifica(CostantiRegistroServizi.DEFAULT_VALUE_INTERFACE_TYPE_REST);
  1896.             }
  1897.         }
  1898.     
  1899.         IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromValues(as.getNome(),BeanUtilities.getSoggettoReferenteID(as.getSoggettoReferente()),as.getVersione());
  1900.         String uriAS = this.idAccordoFactory.getUriFromIDAccordo(idAccordo);
  1901.         if( (reset==false) && this.gestoreCRUD.existsAccordoServizioParteComune(idAccordo)){
  1902.             if(updateEnabled) {
  1903.                 this.log.info("Accordo di Servizio "+uriAS+" aggiornamento in corso...");
  1904.                 this.gestoreCRUD.updateAccordoServizioParteComune(as);
  1905.                 this.log.info("Accordo di Servizio "+uriAS+" aggiornato.");
  1906.             }
  1907.             else {
  1908.                 this.log.info("Accordo di Servizio "+uriAS+" non aggiornato (aggiornamento disabilitato).");
  1909.             }
  1910.         }else{
  1911.             this.log.info("Accordo di Servizio "+uriAS+" creazione in corso...");
  1912.             this.gestoreCRUD.createAccordoServizioParteComune(as);
  1913.             this.log.info("Accordo di Servizio "+uriAS+" creato.");
  1914.         }
  1915.     }
  1916.     
  1917.     public static void impostaInformazioniRegistroDB_AccordoServizioParteSpecifica_Fruitore(Fruitore fruitore){
  1918.         if(fruitore.getConnettore()!=null){
  1919.             // I nomi vengono autogenerati dal driver
  1920.             fruitore.getConnettore().setNome(null);
  1921.             // I tipi diversi da disabilitato,http,jms,null,nullEcho sono custom
  1922.             String tipoConnettore = fruitore.getConnettore().getTipo();
  1923.             if ( !TipiConnettore.JMS.getNome().equals(tipoConnettore) && !TipiConnettore.HTTP.getNome().equals(tipoConnettore) &&
  1924.                  !TipiConnettore.DISABILITATO.getNome().equals(tipoConnettore) && !TipiConnettore.NULL.getNome().equals(tipoConnettore) &&
  1925.                  !TipiConnettore.NULLECHO.getNome().equals(tipoConnettore) ){
  1926.                 fruitore.getConnettore().setCustom(true);
  1927.             }
  1928.             // Gestione default per connettore https
  1929.             if(TipiConnettore.HTTPS.getNome().equals(tipoConnettore)){
  1930.                 gestioneDefaultConnettoreHTTP(fruitore.getConnettore());
  1931.             }
  1932.         }
  1933.         if(fruitore.getConfigurazioneAzioneList()!=null && fruitore.sizeConfigurazioneAzioneList()>0) {
  1934.             for (int i = 0; i < fruitore.sizeConfigurazioneAzioneList(); i++) {
  1935.                 if(fruitore.getConfigurazioneAzione(i).getConnettore()!=null) {
  1936.                     // I nomi vengono autogenerati dal driver
  1937.                     fruitore.getConfigurazioneAzione(i).getConnettore().setNome(null);
  1938.                     // I tipi diversi da disabilitato,http,jms,null,nullEcho sono custom
  1939.                     String tipoConnettore = fruitore.getConfigurazioneAzione(i).getConnettore().getTipo();
  1940.                     if ( !TipiConnettore.JMS.getNome().equals(tipoConnettore) && !TipiConnettore.HTTP.getNome().equals(tipoConnettore) &&
  1941.                          !TipiConnettore.DISABILITATO.getNome().equals(tipoConnettore) && !TipiConnettore.NULL.getNome().equals(tipoConnettore) &&
  1942.                          !TipiConnettore.NULLECHO.getNome().equals(tipoConnettore) ){
  1943.                         fruitore.getConfigurazioneAzione(i).getConnettore().setCustom(true);
  1944.                     }
  1945.                     // Gestione default per connettore https
  1946.                     if(TipiConnettore.HTTPS.getNome().equals(tipoConnettore)){
  1947.                         gestioneDefaultConnettoreHTTP(fruitore.getConfigurazioneAzione(i).getConnettore());
  1948.                     }
  1949.                 }
  1950.             }
  1951.         }
  1952.     }
  1953.     public static void impostaInformazioniRegistroDB_AccordoServizioParteSpecifica(AccordoServizioParteSpecifica servizio){
  1954.         if(servizio.getConfigurazioneServizio()!=null && servizio.getConfigurazioneServizio().getConnettore()!=null){
  1955.             // I nomi vengono autogenerati dal driver
  1956.             servizio.getConfigurazioneServizio().getConnettore().setNome(null);
  1957.             // I tipi diversi da disabilitato,http,jms,null,nullEcho sono custom
  1958.             String tipoConnettore = servizio.getConfigurazioneServizio().getConnettore().getTipo();
  1959.             if ( !TipiConnettore.JMS.getNome().equals(tipoConnettore) && !TipiConnettore.HTTP.getNome().equals(tipoConnettore) &&
  1960.                  !TipiConnettore.DISABILITATO.getNome().equals(tipoConnettore) && !TipiConnettore.NULL.getNome().equals(tipoConnettore) &&
  1961.                  !TipiConnettore.NULLECHO.getNome().equals(tipoConnettore) ){
  1962.                 servizio.getConfigurazioneServizio().getConnettore().setCustom(true);
  1963.             }
  1964.             // Gestione default per connettore https
  1965.             if(TipiConnettore.HTTPS.getNome().equals(tipoConnettore)){
  1966.                 gestioneDefaultConnettoreHTTP(servizio.getConfigurazioneServizio().getConnettore());
  1967.             }
  1968.         }
  1969.         for(int k=0; k< servizio.sizeFruitoreList();k++){
  1970.             if(servizio.getFruitore(k).getConnettore()!=null){
  1971.                 impostaInformazioniRegistroDB_AccordoServizioParteSpecifica_Fruitore(servizio.getFruitore(k));
  1972.             }
  1973.         }
  1974.         if(servizio.getConfigurazioneServizio()!=null){
  1975.             for(int k=0; k< servizio.getConfigurazioneServizio().sizeConfigurazioneAzioneList();k++){
  1976.                 if(servizio.getConfigurazioneServizio().getConfigurazioneAzione(k).getConnettore()!=null){
  1977.                     // I nomi vengono autogenerati dal driver
  1978.                     servizio.getConfigurazioneServizio().getConfigurazioneAzione(k).getConnettore().setNome(null);
  1979.                     // I tipi diversi da disabilitato,http,jms,null,nullEcho sono custom
  1980.                     String tipoConnettore = servizio.getConfigurazioneServizio().getConfigurazioneAzione(k).getConnettore().getTipo();
  1981.                     if ( !TipiConnettore.JMS.getNome().equals(tipoConnettore) && !TipiConnettore.HTTP.getNome().equals(tipoConnettore) &&
  1982.                          !TipiConnettore.DISABILITATO.getNome().equals(tipoConnettore) && !TipiConnettore.NULL.getNome().equals(tipoConnettore) &&
  1983.                          !TipiConnettore.NULLECHO.getNome().equals(tipoConnettore) ){
  1984.                         servizio.getConfigurazioneServizio().getConfigurazioneAzione(k).getConnettore().setCustom(true);
  1985.                     }
  1986.                     // Gestione default per connettore https
  1987.                     if(TipiConnettore.HTTPS.getNome().equals(tipoConnettore)){
  1988.                         gestioneDefaultConnettoreHTTP(servizio.getConfigurazioneServizio().getConfigurazioneAzione(k).getConnettore());
  1989.                     }
  1990.                 }
  1991.             }
  1992.         }
  1993.     }
  1994.     
  1995.     public static void impostaInformazioniRegistro_AccordoServizioParteSpecifica_update(AccordoServizioParteSpecifica servizio,AccordoServizioParteSpecifica old,
  1996.             boolean mantieniFruitoriEsistenti){
  1997.         if(old.getConfigurazioneServizio()!=null && old.getConfigurazioneServizio().getConnettore()!=null){
  1998.             if(servizio.getConfigurazioneServizio()==null || servizio.getConfigurazioneServizio().getConnettore()==null){
  1999.                 if(servizio.getConfigurazioneServizio()==null){
  2000.                     servizio.setConfigurazioneServizio(new ConfigurazioneServizio());
  2001.                 }
  2002.                 servizio.getConfigurazioneServizio().setConnettore(old.getConfigurazioneServizio().getConnettore());
  2003.             }else{
  2004.                 servizio.getConfigurazioneServizio().getConnettore().setId(old.getConfigurazioneServizio().getConnettore().getId());
  2005.                 servizio.getConfigurazioneServizio().getConnettore().setNome(old.getConfigurazioneServizio().getConnettore().getNome());
  2006.             }
  2007.         }
  2008.         if(mantieniFruitoriEsistenti){
  2009.             mantieniFruitori(old, servizio);
  2010.         }
  2011.         if(servizio.sizeFruitoreList()>0){
  2012.             for (int i = 0; i < servizio.sizeFruitoreList(); i++) {
  2013.                 Fruitore fruitore = servizio.getFruitore(i);
  2014.                 // cerco fruitore nella vecchia immagine
  2015.                 for (int j = 0; j < old.sizeFruitoreList(); j++) {
  2016.                     Fruitore oldFruitore = old.getFruitore(j);
  2017.                     if(oldFruitore.getTipo().equals(fruitore.getTipo()) &&
  2018.                             oldFruitore.getNome().equals(fruitore.getNome())){
  2019.                         if(fruitore.getConnettore()==null){
  2020.                             fruitore.setConnettore(oldFruitore.getConnettore());
  2021.                         }else{
  2022.                             fruitore.getConnettore().setId(oldFruitore.getConnettore().getId());
  2023.                             fruitore.getConnettore().setNome(oldFruitore.getConnettore().getNome());
  2024.                         }       
  2025.                     }
  2026.                 }
  2027.             }
  2028.         }
  2029.     }
  2030.     
  2031.     private void gestioneServizio(AccordoServizioParteSpecifica servizio,Soggetto soggetto,boolean reset,
  2032.             boolean mantieniFruitoriEsistenti,StatiAccordo statoAccordo, boolean updateEnabled) throws Exception{
  2033.         servizio.setSuperUser(this.superUser);
  2034.         servizio.setTipoSoggettoErogatore(soggetto.getTipo());
  2035.         servizio.setNomeSoggettoErogatore(soggetto.getNome());
  2036.         if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  2037.             impostaInformazioniRegistroDB_AccordoServizioParteSpecifica(servizio);
  2038.         }
  2039.         // bytes
  2040.         this.initializeWSDLBytes(servizio);
  2041.         for(int k=0; k<servizio.sizeAllegatoList();k++){
  2042.             String fileName = servizio.getAllegato(k).getFile();
  2043.             String name = getNomeFile(fileName);
  2044.             
  2045.             servizio.getAllegato(k).setByteContenuto(this.readDocumento(fileName));
  2046.             servizio.getAllegato(k).setFile(name);
  2047.             servizio.getAllegato(k).setRuolo(RuoliDocumento.allegato.toString());
  2048.             servizio.getAllegato(k).setTipoProprietarioDocumento(ProprietariDocumento.servizio.toString());
  2049.         }
  2050.         for(int k=0; k<servizio.sizeSpecificaSemiformaleList();k++){
  2051.             String fileName = servizio.getSpecificaSemiformale(k).getFile();
  2052.             String name = getNomeFile(fileName);
  2053.             
  2054.             servizio.getSpecificaSemiformale(k).setByteContenuto(this.readDocumento(fileName));
  2055.             servizio.getSpecificaSemiformale(k).setFile(name);
  2056.             servizio.getSpecificaSemiformale(k).setRuolo(RuoliDocumento.specificaSemiformale.toString());
  2057.             servizio.getSpecificaSemiformale(k).setTipoProprietarioDocumento(ProprietariDocumento.servizio.toString());
  2058.         }
  2059.         for(int k=0; k<servizio.sizeSpecificaLivelloServizioList();k++){
  2060.             String fileName = servizio.getSpecificaLivelloServizio(k).getFile();
  2061.             String name = getNomeFile(fileName);
  2062.             
  2063.             servizio.getSpecificaLivelloServizio(k).setByteContenuto(this.readDocumento(fileName));
  2064.             servizio.getSpecificaLivelloServizio(k).setFile(name);
  2065.             servizio.getSpecificaLivelloServizio(k).setRuolo(RuoliDocumento.specificaLivelloServizio.toString());
  2066.             servizio.getSpecificaLivelloServizio(k).setTipoProprietarioDocumento(ProprietariDocumento.servizio.toString());
  2067.         }
  2068.         for(int k=0; k<servizio.sizeSpecificaSicurezzaList();k++){
  2069.             String fileName = servizio.getSpecificaSicurezza(k).getFile();
  2070.             String name = getNomeFile(fileName);
  2071.             
  2072.             servizio.getSpecificaSicurezza(k).setByteContenuto(this.readDocumento(fileName));
  2073.             servizio.getSpecificaSicurezza(k).setFile(name);
  2074.             servizio.getSpecificaSicurezza(k).setRuolo(RuoliDocumento.specificaSicurezza.toString());
  2075.             servizio.getSpecificaSicurezza(k).setTipoProprietarioDocumento(ProprietariDocumento.servizio.toString());
  2076.         }
  2077.         // protocol properties: bytes
  2078.         if(servizio.sizeProtocolPropertyList()>0) {
  2079.             for (ProtocolProperty pp : servizio.getProtocolPropertyList()) {
  2080.                 if(pp.getFile()!=null) {
  2081.                     pp.setByteFile(this.readDocumento(pp.getFile()));
  2082.                 }
  2083.             }
  2084.             if(servizio.sizeFruitoreList()>0) {
  2085.                 for (Fruitore fruitore : servizio.getFruitoreList()) {
  2086.                     if(fruitore.sizeProtocolPropertyList()>0) {
  2087.                         for (ProtocolProperty pp : fruitore.getProtocolPropertyList()) {
  2088.                             if(pp.getFile()!=null) {
  2089.                                 pp.setByteFile(this.readDocumento(pp.getFile()));
  2090.                             }
  2091.                         }
  2092.                     }
  2093.                 }
  2094.             }
  2095.         }
  2096.         
  2097.         IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome());
  2098.         IDServizio idServizio = this.idServizioFactory.getIDServizioFromValues(servizio.getTipo(), servizio.getNome(), idSoggetto, servizio.getVersione());
  2099.         String uri = this.idServizioFactory.getUriFromIDServizio(idServizio);
  2100.         if( (reset==false) && (this.gestoreCRUD.existsAccordoServizioParteSpecifica(idServizio)) ){
  2101.             if(updateEnabled) {
  2102.                 this.log.info("Servizio "+uri+" aggiornamento in corso...");
  2103.                 
  2104.                 AccordoServizioParteSpecifica old = ((IDriverRegistroServiziGet)this.gestoreCRUD).getAccordoServizioParteSpecifica(idServizio);
  2105.                 impostaInformazioniRegistro_AccordoServizioParteSpecifica_update(servizio, old, mantieniFruitoriEsistenti);
  2106.                 
  2107.                 // stato package
  2108.                 if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  2109.                     aggiornatoStatoFruitori(servizio, statoAccordo);
  2110.                 }
  2111.                 this.gestoreCRUD.updateAccordoServizioParteSpecifica(servizio);
  2112.                 
  2113.                 this.log.info("Servizio "+uri+" aggiornato.");
  2114.             }
  2115.             else {
  2116.                 this.log.info("Servizio "+uri+" non aggiornato (aggiornamento disabilitato).");
  2117.             }
  2118.         }else{
  2119.             this.log.info("Servizio "+uri+" creazione in corso...");
  2120.             // stato package
  2121.             if(CostantiConfigurazione.REGISTRO_DB.equals(this.tipoBEDestinazione)){
  2122.                 aggiornatoStatoFruitori(servizio, statoAccordo);
  2123.             }
  2124.             this.gestoreCRUD.createAccordoServizioParteSpecifica(servizio);
  2125.             this.log.info("Servizio "+uri+" creato.");
  2126.         }
  2127.     }
  2128.     
  2129.     

  2131. }
Created with JaCoCo 0.8.8.202204050719