DriverRegistroServiziDB_accordiDriver.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.db;

  25. import java.sql.Connection;
  26. import java.sql.Date;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;
  30. import java.util.ArrayList;
  31. import java.util.List;

  33. import org.openspcoop2.core.commons.DBUtils;
  34. import org.openspcoop2.core.commons.Filtri;
  35. import org.openspcoop2.core.commons.ISearch;
  36. import org.openspcoop2.core.commons.Liste;
  37. import org.openspcoop2.core.commons.SearchUtils;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  40. import org.openspcoop2.core.id.IDAccordo;
  41. import org.openspcoop2.core.id.IDServizio;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.registry.AccordoCooperazione;
  44. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  45. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  46. import org.openspcoop2.core.registry.Documento;
  47. import org.openspcoop2.core.registry.IdSoggetto;
  48. import org.openspcoop2.core.registry.Operation;
  49. import org.openspcoop2.core.registry.PortType;
  50. import org.openspcoop2.core.registry.ProtocolProperty;
  51. import org.openspcoop2.core.registry.Soggetto;
  52. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  53. import org.openspcoop2.core.registry.constants.ProfiloCollaborazione;
  54. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  55. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  56. import org.openspcoop2.core.registry.constants.ServiceBinding;
  57. import org.openspcoop2.core.registry.constants.StatiAccordo;
  58. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  59. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  60. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  61. import org.openspcoop2.core.registry.driver.ValidazioneStatoPackageException;
  62. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  63. import org.openspcoop2.utils.sql.ISQLQueryObject;
  64. import org.openspcoop2.utils.sql.SQLObjectFactory;

  66. /**
  67.  * DriverRegistroServiziDB_accordiDriver
  68.  * 
  69.  * 
  70.  * @author Sandra Giangrandi (sandra@link.it)
  71.  * @author Stefano Corallo (corallo@link.it)
  72.  * @author $Author$
  73.  * @version $Rev$, $Date$
  74.  */
  75. public class DriverRegistroServiziDB_accordiDriver {

  77.     private DriverRegistroServiziDB driver = null;
  78.     private DriverRegistroServiziDB_accordiSoapDriver driverSoap = null;
  79.     private DriverRegistroServiziDB_accordiRestDriver driverRest = null;
  80.     private DriverRegistroServiziDB_accordiGruppiDriver driverGruppi = null;
  81.     private DriverRegistroServiziDB_accordiServiziCompostiDriver driverAccordiServiziComposti = null;
  82.     
  83.     protected DriverRegistroServiziDB_accordiDriver(DriverRegistroServiziDB driver) {
  84.         this.driver = driver;
  85.         this.driverSoap = new DriverRegistroServiziDB_accordiSoapDriver(driver);
  86.         this.driverRest = new DriverRegistroServiziDB_accordiRestDriver(driver);
  87.         this.driverGruppi = new DriverRegistroServiziDB_accordiGruppiDriver(driver);
  88.         this.driverAccordiServiziComposti = new DriverRegistroServiziDB_accordiServiziCompostiDriver(driver);
  89.     }
  90.     

  92.     protected int getAccordoServizioParteComuneNextVersion(IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  93.         // conrollo consistenza
  94.         if (idAccordo == null)
  95.             throw new DriverRegistroServiziException("[getAccordoServizioParteComuneNextVersion] Parametro idAccordo is null");
  96.         if (idAccordo.getNome() == null)
  97.             throw new DriverRegistroServiziException("[getAccordoServizioParteComuneNextVersion] Parametro idAccordo.getNome is null");
  98.         if (idAccordo.getNome().trim().equals(""))
  99.             throw new DriverRegistroServiziException("[getAccordoServizioParteComuneNextVersion] Parametro idAccordo.getNome non e' definito");

  101.         this.driver.logDebug("richiesto getAccordoServizioParteComuneNextVersion: " + idAccordo.toString());

  103.         int nextVersion = -1;
  104.         Connection con = null;
  105.         try {
  106.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  107.             // prendo la connessione dal pool
  108.             if (this.driver.atomica)
  109.                 con = this.driver.getConnectionFromDatasource("getAccordoServizioParteComuneNextVersion(idAccordo)");
  110.             else
  111.                 con = this.driver.globalConnection;
  112.             
  113.             nextVersion = DBUtils.getAccordoServizioParteComuneNextVersion(idAccordo, con, this.driver.tipoDB);
  114.         }catch (Exception se) {
  115.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteComuneNextVersion] Exception :" + se.getMessage(),se);
  116.         } finally {
  117.             this.driver.closeConnection(con);
  118.         }
  119.         return nextVersion;
  120.     }
  121.     
  122.     protected org.openspcoop2.core.registry.AccordoServizioParteComune getAccordoServizioParteComune(IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  123.         return getAccordoServizioParteComune(idAccordo,false,false);
  124.     }
  125.     protected org.openspcoop2.core.registry.AccordoServizioParteComune getAccordoServizioParteComune(IDAccordo idAccordo,boolean readContenutoAllegati,boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  126.         // conrollo consistenza
  127.         if (idAccordo == null)
  128.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Parametro idAccordo is null");
  129.         if (idAccordo.getNome() == null)
  130.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Parametro idAccordo.getNome is null");
  131.         if (idAccordo.getNome().trim().equals(""))
  132.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Parametro idAccordo.getNome non e' definito");

  134.         this.driver.logDebug("richiesto getAccordoServizioParteComune: " + idAccordo.toString());

  136.         org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio = null;
  137.         Connection con = null;
  138.         PreparedStatement stm = null;
  139.         ResultSet rs = null;

  141.         try {

  143.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  144.             // prendo la connessione dal pool
  145.             if (this.driver.atomica)
  146.                 con = this.driver.getConnectionFromDatasource("getAccordoServizioParteComune(idAccordo)");
  147.             else
  148.                 con = this.driver.globalConnection;

  150.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordo, con, this.driver.tipoDB);
  151.             if(idAccordoLong<=0){
  152.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoServizioParteComune] Accordo non trovato (id:"+idAccordo+")");
  153.             }


  156.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  157.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  158.             sqlQueryObject.addSelectField("*");
  159.             sqlQueryObject.addWhereCondition("id = ?");
  160.             sqlQueryObject.setANDLogicOperator(true);
  161.             String sqlQuery = sqlQueryObject.createSQLQuery();



  165.             stm = con.prepareStatement(sqlQuery);

  167.             stm.setLong(1, idAccordoLong);


  170.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  171.             rs = stm.executeQuery();

  173.             if (rs.next()) {
  174.                 accordoServizio = new org.openspcoop2.core.registry.AccordoServizioParteComune();

  176.                 accordoServizio.setId(rs.getLong("id"));

  178.                 String tmp = rs.getString("nome");
  179.                 // se tmp==null oppure tmp=="" then setNome(null) else
  180.                 // setNome(tmp)
  181.                 accordoServizio.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  183.                 tmp = rs.getString("descrizione");
  184.                 accordoServizio.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  186.                 tmp = rs.getString("service_binding");
  187.                 accordoServizio.setServiceBinding(DriverRegistroServiziDB_LIB.getEnumServiceBinding((tmp == null || tmp.equals("")) ? null : tmp));
  188.                 
  189.                 tmp = rs.getString("message_type");
  190.                 accordoServizio.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  191.                 
  192.                 // controllare i vari casi di profcoll (one-way....)
  193.                 tmp = rs.getString("profilo_collaborazione");
  194.                 accordoServizio.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione((tmp == null || tmp.equals("")) ? null : tmp));
  195.                 if(accordoServizio.getProfiloCollaborazione()==null){
  196.                     // puo' essere null se e' stato ridefinito nei port type e nelle operation
  197.                     // inserisco comunque un default (usato anche nelle interfacce)
  198.                     accordoServizio.setProfiloCollaborazione(ProfiloCollaborazione.ONEWAY);
  199.                 }

  201.                 //      if (tmp == null || tmp.equals(""))
  202.                 //          accordoServizio.setProfiloCollaborazione(null);
  203.                 //      if (tmp.equals("oneway"))
  204.                 //          accordoServizio
  205.                 //              .setProfiloCollaborazione(CostantiRegistroServizi.ONEWAY);
  206.                 //      if (tmp.equals("sincrono"))
  207.                 //          accordoServizio
  208.                 //              .setProfiloCollaborazione(CostantiRegistroServizi.SINCRONO);
  209.                 //      if (tmp.equals("asincrono-simmetrico"))
  210.                 //          accordoServizio
  211.                 //              .setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_SIMMETRICO);
  212.                 //      if (tmp.equals("asincrono-asimmetrico"))
  213.                 //          accordoServizio
  214.                 //              .setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO);

  216.                 tmp = rs.getString("formato_specifica");
  217.                 accordoServizio.setFormatoSpecifica(DriverRegistroServiziDB_LIB.getEnumFormatoSpecifica((tmp == null || tmp.equals("")) ? null : tmp));
  218.                 
  219.                 tmp = rs.getString("wsdl_definitorio");
  220.                 accordoServizio.setByteWsdlDefinitorio(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  222.                 tmp = rs.getString("wsdl_concettuale");
  223.                 accordoServizio.setByteWsdlConcettuale(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  225.                 tmp = rs.getString("wsdl_logico_erogatore");
  226.                 accordoServizio.setByteWsdlLogicoErogatore(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  228.                 tmp = rs.getString("wsdl_logico_fruitore");
  229.                 accordoServizio.setByteWsdlLogicoFruitore(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  231.                 tmp = rs.getString("spec_conv_concettuale");
  232.                 accordoServizio.setByteSpecificaConversazioneConcettuale(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  234.                 tmp = rs.getString("spec_conv_erogatore");
  235.                 accordoServizio.setByteSpecificaConversazioneErogatore(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  237.                 tmp = rs.getString("spec_conv_fruitore");
  238.                 accordoServizio.setByteSpecificaConversazioneFruitore(((tmp == null || tmp.trim().equals("")) ? null : tmp.getBytes()));

  240.                 accordoServizio.setUtilizzoSenzaAzione(rs.getInt("utilizzo_senza_azione") == CostantiDB.TRUE ? true : false);

  242.                 tmp = rs.getString("filtro_duplicati");
  243.                 accordoServizio.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  245.                 tmp = rs.getString("conferma_ricezione");
  246.                 accordoServizio.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  248.                 tmp = rs.getString("identificativo_collaborazione");
  249.                 accordoServizio.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  250.                 
  251.                 tmp = rs.getString("id_riferimento_richiesta");
  252.                 accordoServizio.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  253.                 
  254.                 tmp = rs.getString("consegna_in_ordine");
  255.                 accordoServizio.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  256.                 
  257.                 tmp = rs.getString("scadenza");
  258.                 accordoServizio.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  260.                 tmp = rs.getString("superuser");
  261.                 accordoServizio.setSuperUser(((tmp == null || tmp.equals("")) ? null : tmp));

  263.                 if(rs.getInt("privato")==1)
  264.                     accordoServizio.setPrivato(true);
  265.                 else
  266.                     accordoServizio.setPrivato(false);

  268.                 // Ora Registrazione
  269.                 if(rs.getTimestamp("ora_registrazione")!=null){
  270.                     accordoServizio.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  271.                 }

  273.                 // Soggetto referente
  274.                 long idReferente = rs.getLong("id_referente");
  275.                 if(idReferente>0) {
  276.                     IDSoggetto soggettoReferente = null;
  277.                     try {
  278.                         soggettoReferente = this.driver.getIdSoggetto(idReferente,con);
  279.                         if(soggettoReferente==null){
  280.                             throw new DriverRegistroServiziNotFound ("non esiste");
  281.                         }
  282.                     }catch(DriverRegistroServiziNotFound notFound) {
  283.                         throw new Exception ("Soggetto referente ["+idReferente+"] dell'accordo non esiste");
  284.                     }
  285.                     IdSoggetto assr = new IdSoggetto();
  286.                     assr.setTipo(soggettoReferente.getTipo());
  287.                     assr.setNome(soggettoReferente.getNome());
  288.                     assr.setId(idReferente);
  289.                     accordoServizio.setSoggettoReferente(assr);
  290.                 }

  292.                 //Versione
  293.                 if(rs.getString("versione")!=null && !"".equals(rs.getString("versione")))
  294.                     accordoServizio.setVersione(rs.getInt("versione"));

  296.                 // Stato
  297.                 tmp = rs.getString("stato");
  298.                 accordoServizio.setStatoPackage(((tmp == null || tmp.equals("")) ? null : tmp));

  300.                 // Canali
  301.                 String canale = rs.getString("canale");
  302.                 accordoServizio.setCanale(canale);
  303.                 
  304.                 // Proprieta Oggetto
  305.                 accordoServizio.setProprietaOggetto(DriverRegistroServiziDB_utilsDriver.readProprietaOggetto(rs,false));
  306.                 
  307.                 rs.close();
  308.                 stm.close();


  311.                 // Aggiungo azione

  313.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  314.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  315.                 sqlQueryObject.addSelectField("*");
  316.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  317.                 sqlQueryObject.setANDLogicOperator(true);
  318.                 sqlQueryObject.addOrderBy("nome");
  319.                 sqlQueryObject.setSortType(true);
  320.                 sqlQuery = sqlQueryObject.createSQLQuery();

  322.                 stm = con.prepareStatement(sqlQuery);
  323.                 stm.setLong(1, idAccordoLong);

  325.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));

  327.                 rs = stm.executeQuery();

  329.                 org.openspcoop2.core.registry.Azione azione = null;
  330.                 while (rs.next()) {

  332.                     azione = new org.openspcoop2.core.registry.Azione();

  334.                     tmp = rs.getString("conferma_ricezione");
  335.                     azione.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  337.                     tmp = rs.getString("consegna_in_ordine");
  338.                     azione.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  340.                     tmp = rs.getString("filtro_duplicati");
  341.                     azione.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  343.                     tmp = rs.getString("identificativo_collaborazione");
  344.                     azione.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  346.                     tmp = rs.getString("id_riferimento_richiesta");
  347.                     azione.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  348.                     
  349.                     tmp = rs.getString("nome");
  350.                     azione.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  352.                     tmp = rs.getString("scadenza");
  353.                     azione.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  355.                     tmp = rs.getString("profilo_collaborazione");
  356.                     azione.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));

  358.                     tmp = rs.getString("correlata");
  359.                     azione.setCorrelata(((tmp == null || tmp.equals("")) ? null : tmp));

  361.                     tmp = rs.getString("profilo_azione");
  362.                     if (tmp == null || tmp.equals(""))
  363.                         azione.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  364.                     else
  365.                         azione.setProfAzione(tmp);

  367.                     long idAzione = rs.getLong("id");
  368.                     azione.setId(idAzione);

  370.                     
  371.                     // Protocol Properties
  372.                     try{
  373.                         List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(idAzione, ProprietariProtocolProperty.AZIONE_ACCORDO, con, 
  374.                                 this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  375.                         if(listPP!=null && !listPP.isEmpty()){
  376.                             for (ProtocolProperty protocolProperty : listPP) {
  377.                                 azione.addProtocolProperty(protocolProperty);
  378.                             }
  379.                         }
  380.                     }catch(DriverRegistroServiziNotFound dNotFound){
  381.                         // ignore
  382.                     }
  383.                     
  384.                     accordoServizio.addAzione(azione);

  386.                 }
  387.                 rs.close();
  388.                 stm.close();


  391.                 // read port type
  392.                 this.driverSoap.readPortTypes(accordoServizio,con);
  393.                 
  394.                 // read resources
  395.                 this.driverRest.readResources(accordoServizio,con,readDatiRegistro);
  396.                 
  397.                 // read gruppi
  398.                 this.driverGruppi.readAccordiGruppi(accordoServizio,con);

  400.                 // read AccordoServizioComposto
  401.                 this.driverAccordiServiziComposti.readAccordoServizioComposto(accordoServizio , con);


  404.                 // read Documenti generici: i bytes non vengono ritornati se readContenutoAllegati==false, utilizzare il metodo apposta per averli: 
  405.                 //                                               DriverRegistroServiziDB_LIB.getDocumento(id, readBytes, connection);
  406.                 try{
  407.                     List<?> allegati = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.allegato.toString(), idAccordoLong, 
  408.                             ProprietariDocumento.accordoServizio,readContenutoAllegati, con, this.driver.tipoDB);
  409.                     for(int i=0; i<allegati.size();i++){
  410.                         accordoServizio.addAllegato((Documento) allegati.get(i));
  411.                     }
  412.                 }catch(DriverRegistroServiziNotFound dNotFound){}
  413.                 try{
  414.                     List<?> specificheSemiformali = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaSemiformale.toString(), 
  415.                             idAccordoLong, ProprietariDocumento.accordoServizio,readContenutoAllegati, con, this.driver.tipoDB);
  416.                     for(int i=0; i<specificheSemiformali.size();i++){   
  417.                         accordoServizio.addSpecificaSemiformale((Documento) specificheSemiformali.get(i));
  418.                     }
  419.                 }catch(DriverRegistroServiziNotFound dNotFound){}
  420.                 if(accordoServizio.getServizioComposto()!=null){
  421.                     // read Documenti generici: i bytes non vengono ritornati se readContenutoAllegati==false, utilizzare il metodo apposta per averli: 
  422.                     /**                                               DriverRegistroServiziDB_LIB.getDocumento(id, readBytes, connection);*/
  423.                     try{
  424.                         List<?> specificheCoordinamento = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaCoordinamento.toString(), 
  425.                                 idAccordoLong, ProprietariDocumento.accordoServizio,readContenutoAllegati, con, this.driver.tipoDB);
  426.                         for(int i=0; i<specificheCoordinamento.size();i++){ 
  427.                             accordoServizio.getServizioComposto().addSpecificaCoordinamento((Documento) specificheCoordinamento.get(i));
  428.                         }
  429.                     }catch(DriverRegistroServiziNotFound dNotFound){}
  430.                 }

  432.                 
  433.                 // Protocol Properties
  434.                 try{
  435.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(idAccordoLong, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_COMUNE, con, 
  436.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  437.                     if(listPP!=null && !listPP.isEmpty()){
  438.                         for (ProtocolProperty protocolProperty : listPP) {
  439.                             accordoServizio.addProtocolProperty(protocolProperty);
  440.                         }
  441.                     }
  442.                 }catch(DriverRegistroServiziNotFound dNotFound){
  443.                     // ignore
  444.                 }
  445.                 
  446.                 
  447.             } else {
  448.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoServizioParteComune] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  449.             }


  452. /**         if(accordoServizio!=null){
  453. //              // nomiAzione setting 
  454. //              accordoServizio.setNomiAzione(accordoServizio.readNomiAzione());
  455. //          }*/
  456.             return accordoServizio;

  458.         }catch (DriverRegistroServiziNotFound e) {
  459.             throw e;
  460.         }catch (Exception se) {
  461.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteComune] Exception :" + se.getMessage(),se);
  462.         } finally {

  464.             JDBCUtilities.closeResources(rs, stm);

  466.             this.driver.closeConnection(con);

  468.         }
  469.     }
  470.     
  471.     
  472.     
  473.     
  474.     protected AccordoServizioParteComune getAccordoServizioParteComune(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  475.         return getAccordoServizioParteComune(id,false,false,null);
  476.     }
  477.     protected AccordoServizioParteComune getAccordoServizioParteComune(long id, boolean readContenutoAllegati,boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  478.         return getAccordoServizioParteComune(id,readContenutoAllegati,readDatiRegistro,null);
  479.     }
  480.     protected AccordoServizioParteComune getAccordoServizioParteComune(long id,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  481.         return getAccordoServizioParteComune(id,false,false,conParam);
  482.     }
  483.     protected AccordoServizioParteComune getAccordoServizioParteComune(long id, boolean readContenutoAllegati,boolean readDatiRegistro,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  484.         this.driver.logDebug("richiesto getAccordoServizio: " + id);
  485.         // conrollo consistenza
  486.         if (id <= 0)
  487.             return null;

  489.         Connection con = null;
  490.         PreparedStatement stm = null;
  491.         ResultSet rs = null;

  493.         IDAccordo idAccordo = null;
  494.         try {
  495.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  496.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  497.             sqlQueryObject.addSelectField("*");
  498.             sqlQueryObject.addWhereCondition("id = ?");
  499.             String sqlQuery = sqlQueryObject.createSQLQuery();

  501.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  502.             // prendo la connessione dal pool
  503.             if(conParam!=null){
  504.                 con = conParam;
  505.             }
  506.             else if (this.driver.atomica)
  507.                 con = this.driver.getConnectionFromDatasource("getAccordoServizioParteComune(longId)");
  508.             else
  509.                 con = this.driver.globalConnection;

  511.             stm = con.prepareStatement(sqlQuery);

  513.             stm.setLong(1, id);

  515.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  516.             rs = stm.executeQuery();


  519.             if (rs.next()) {

  521.                 IDSoggetto referente = null;
  522.                 long idReferente = rs.getLong("id_referente");
  523.                 if(idReferente>0){
  524.                     try {
  525.                         referente = this.driver.getIdSoggetto(idReferente,con);
  526.                         if(referente==null){
  527.                             throw new DriverRegistroServiziNotFound ("non esiste");
  528.                         }
  529.                     }catch(DriverRegistroServiziNotFound notFound) {
  530.                         throw new Exception ("Soggetto referente ["+idReferente+"] dell'accordo non esiste");
  531.                     }
  532.                 }

  534.                 idAccordo = this.driver.idAccordoFactory.getIDAccordoFromValues(rs.getString("nome"),referente,rs.getInt("versione"));

  536.             } else {
  537.                 rs.close();
  538.                 stm.close();
  539.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoServizio] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  540.             }

  542.             rs.close();
  543.             stm.close();

  545.         } catch (SQLException se) {
  546.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizio] SQLException :" + se.getMessage(),se);
  547.         }catch (DriverRegistroServiziNotFound e) {
  548.             throw e;
  549.         }catch (Exception se) {
  550.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizio] Exception :" + se.getMessage(),se);
  551.         } finally {

  553.             //Chiudo statement and resultset
  554.             JDBCUtilities.closeResources(rs, stm);

  556.             this.driver.closeConnection(conParam, con);

  558.         }

  560.         return this.getAccordoServizioParteComune(idAccordo, readContenutoAllegati, readDatiRegistro);
  561.     }
  562.     
  563.     
  564.     
  565.     
  566.     
  567.     protected List<AccordoServizioParteComune> accordiCompatibiliList(ISearch ricerca) throws DriverRegistroServiziException {
  568.         String nomeMetodo = "accordiCompatibiliList";
  569.         int idLista = Liste.ACCORDI;
  570.         int offset;
  571.         int limit;
  572.         String search;
  573.         String queryString;

  575.         limit = ricerca.getPageSize(idLista);
  576.         offset = ricerca.getIndexIniziale(idLista);
  577.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  578.         ricerca.getSearchString(idLista);

  580.         this.driver.logDebug("search : " + search);

  582.         Connection con = null;
  583.         PreparedStatement stmt = null;
  584.         ResultSet risultato = null;

  586.         ArrayList<AccordoServizioParteComune> lista = new ArrayList<AccordoServizioParteComune>();

  588.         if (this.driver.atomica) {
  589.             try {
  590.                 con = this.driver.getConnectionFromDatasource("accordiCompatibiliList");

  592.             } catch (Exception e) {
  593.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  595.             }

  597.         } else
  598.             con = this.driver.globalConnection;

  600.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  602.         try {

  604.             ISQLQueryObject sqlquery = DriverRegistroServiziDB_accordiLIB.getSQLRicercaAccordiValidi();
  605.             sqlquery.setANDLogicOperator(true);

  607.             ISQLQueryObject sqlQueryObjectSoggetti = null;
  608.             if (!search.equals("")) {
  609.                 sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  610.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  611.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "nome_soggetto");
  612.                 sqlQueryObjectSoggetti.addWhereCondition(true,
  613.                         sqlQueryObjectSoggetti.getWhereLikeCondition("nome_soggetto", search, true, true),
  614.                         CostantiDB.ACCORDI+".id_referente="+CostantiDB.SOGGETTI+".id");
  615.             }


  618.             if (!search.equals("")) {
  619.                 //query con search
  620.                 sqlquery.addSelectCountField("*", "cont");
  621.                 sqlquery.addWhereCondition(false, 
  622.                         sqlquery.getWhereLikeCondition("nome", search, true, true),
  623.                         sqlquery.getWhereLikeCondition("versione", search, true, true),
  624.                         sqlquery.getWhereExistsCondition(false, sqlQueryObjectSoggetti));
  625.                 queryString = sqlquery.createSQLQuery();
  626.             } else {
  627.                 sqlquery.addSelectCountField("*", "cont");
  628.                 queryString = sqlquery.createSQLQuery();
  629.             }

  631.             stmt = con.prepareStatement(queryString);
  632.             risultato = stmt.executeQuery();
  633.             if (risultato.next())
  634.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  635.             risultato.close();
  636.             stmt.close();

  638.             //resetto query
  639.             sqlquery = DriverRegistroServiziDB_accordiLIB.getSQLRicercaAccordiValidi();
  640.             sqlquery.setANDLogicOperator(true);
  641.             // ricavo le entries
  642.             if (limit == 0) // con limit
  643.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  644.             if (!search.equals("")) { // con search

  646.                 sqlquery.addSelectField("id");
  647.                 sqlquery.addSelectField("nome");
  648.                 sqlquery.addSelectField("descrizione");
  649.                 sqlquery.addSelectField("id_referente");
  650.                 sqlquery.addSelectField("versione");
  651.                 sqlquery.addSelectField("stato");
  652.                 sqlquery.addWhereCondition(false, 
  653.                         sqlquery.getWhereLikeCondition("nome", search, true, true),
  654.                         sqlquery.getWhereLikeCondition("versione", search, true, true),
  655.                         sqlquery.getWhereExistsCondition(false, sqlQueryObjectSoggetti));
  656.                 sqlquery.addOrderBy("nome");
  657.                 sqlquery.addOrderBy("versione");
  658.                 sqlquery.addOrderBy("id_referente");
  659.                 sqlquery.setSortType(true);
  660.                 sqlquery.setLimit(limit);
  661.                 sqlquery.setOffset(offset);
  662.                 queryString = sqlquery.createSQLQuery();
  663.             } else {
  664.                 // senza search
  665.                 sqlquery.addSelectField("id");
  666.                 sqlquery.addSelectField("nome");
  667.                 sqlquery.addSelectField("descrizione");
  668.                 sqlquery.addSelectField("id_referente");
  669.                 sqlquery.addSelectField("versione");
  670.                 sqlquery.addSelectField("stato");
  671.                 sqlquery.addOrderBy("nome");
  672.                 sqlquery.addOrderBy("versione");
  673.                 sqlquery.addOrderBy("id_referente");
  674.                 sqlquery.setSortType(true);
  675.                 sqlquery.setLimit(limit);
  676.                 sqlquery.setOffset(offset);
  677.                 queryString = sqlquery.createSQLQuery();
  678.             }


  681.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(queryString));

  683.             stmt = con.prepareStatement(queryString);
  684.             risultato = stmt.executeQuery();

  686.             AccordoServizioParteComune accordo = null;

  688.             while (risultato.next()) {

  690.                 accordo = new AccordoServizioParteComune();

  692.                 accordo.setId(risultato.getLong("id"));
  693.                 accordo.setNome(risultato.getString("nome"));
  694.                 accordo.setDescrizione(risultato.getString("descrizione"));
  695.                 accordo.setStatoPackage(risultato.getString("stato"));
  696.                 accordo.setVersione(risultato.getInt("versione"));

  698.                 // Soggetto referente
  699.                 long id_referente = risultato.getLong("id_referente");
  700.                 IDSoggetto soggettoReferente = null;
  701.                 if(id_referente>0){
  702.                     try {
  703.                         soggettoReferente = this.driver.getIdSoggetto(id_referente,con);
  704.                         if(soggettoReferente==null){
  705.                             throw new DriverRegistroServiziNotFound ("non esiste");
  706.                         }
  707.                     }catch(DriverRegistroServiziNotFound notFound) {
  708.                         throw new Exception ("Soggetto referente ["+id_referente+"] dell'accordo non esiste");
  709.                     }
  710.                     IdSoggetto assr = new IdSoggetto();
  711.                     assr.setTipo(soggettoReferente.getTipo());
  712.                     assr.setNome(soggettoReferente.getNome());
  713.                     accordo.setSoggettoReferente(assr);
  714.                 }
  715.                 
  716.                 lista.add(accordo);

  718.                 this.driverAccordiServiziComposti.readAccordoServizioComposto(accordo, con);

  720.             }


  723.         }catch (Exception se) {

  725.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  726.         } finally {

  728.             //Chiudo statement and resultset
  729.             JDBCUtilities.closeResources(risultato, stmt);
  730.             
  731.             this.driver.closeConnection(con);
  732.         }
  733.         return lista;
  734.     }
  735.     
  736.     
  737.     protected void createAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException {

  739.         Connection connection = null;
  740.         boolean error = false;

  742.         if (this.driver.atomica) {
  743.             try {
  744.                 connection = this.driver.getConnectionFromDatasource("createAccordoServizioParteComune");
  745.                 connection.setAutoCommit(false);
  746.             } catch (Exception e) {
  747.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::createAccordoServizioParteComune] Exception accedendo al datasource :" + e.getMessage(),e);

  749.             }

  751.         } else
  752.             connection = this.driver.globalConnection;

  754.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);

  756.         try {
  757.             DriverRegistroServiziDB_accordiLIB.createAccordoServizioParteComune(accordoServizio, connection, this.driver.tabellaSoggetti, this.driver.log, 
  758.                     this.driver.idAccordoFactory, this.driver.getDriverWrapBYOK());
  759.         } catch (DriverRegistroServiziException e) {
  760.             error = true;
  761.             throw e;
  762.         }catch (Exception e) {
  763.             error = true;
  764.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteComune] Exception [" + e.getMessage() + "].",e);
  765.         }finally {
  766.             this.driver.closeConnection(error, connection);
  767.         }

  769.     }
  770.     
  771.     protected void updateAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException {

  773.         Connection connection = null;
  774.         boolean error = false;

  776.         if (this.driver.atomica) {
  777.             try {
  778.                 connection = this.driver.getConnectionFromDatasource("updateAccordoServizioParteComune");
  779.                 connection.setAutoCommit(false);
  780.             } catch (Exception e) {
  781.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::createAccordoServizio] Exception accedendo al datasource :" + e.getMessage(),e);

  783.             }

  785.         } else
  786.             connection = this.driver.globalConnection;

  788.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);

  790.         try {
  791.             DriverRegistroServiziDB_accordiLIB.updateAccordoServizioParteComune(accordoServizio, connection, this.driver.tabellaSoggetti, this.driver.log, 
  792.                     this.driver.idAccordoFactory, this.driver.getDriverWrapBYOK());
  793.         }catch (DriverRegistroServiziException se) {
  794.             this.driver.log.error(se.getMessage(),se);
  795.             error = true;
  796.             throw se;
  797.         } 
  798.         catch (Exception se) {
  799.             this.driver.log.error(se.getMessage(),se);
  800.             error = true;
  801.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizio] Exception [" + se.getMessage() + "].",se);
  802.         }finally {
  803.             this.driver.closeConnection(error, connection);
  804.         }

  806.     }
  807.     

  809.     protected void deleteAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException {

  811.         Connection connection = null;
  812.         
  813.         boolean error = false;

  815.         if (this.driver.atomica) {
  816.             try {
  817.                 connection = this.driver.getConnectionFromDatasource("deleteAccordoServizioParteComune");
  818.                 connection.setAutoCommit(false);
  819.             } catch (Exception e) {
  820.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::deleteAccordoServizioParteComune] Exception accedendo al datasource :" + e.getMessage(),e);

  822.             }

  824.         } else
  825.             connection = this.driver.globalConnection;

  827.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);

  829.         try {

  831.             DriverRegistroServiziDB_accordiLIB.deleteAccordoServizioParteComune(accordoServizio, connection, this.driver.tabellaSoggetti, this.driver.log, 
  832.                     this.driver.idAccordoFactory, this.driver.getDriverWrapBYOK());

  834.         } catch (DriverRegistroServiziException se) {

  836.             error = true;
  837.             throw se;
  838.         } catch (Exception se) {

  840.             error = true;
  841.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizio] Exception [" + se.getMessage() + "].",se);
  842.         }finally {
  843.             this.driver.closeConnection(error, connection);
  844.         }
  845.     }
  846.     
  847.     
  848.     protected List<IDAccordoDB> idAccordiList(String superuser, ISearch ricerca, 
  849.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException {
  850.         return idAccordiListEngine(superuser,ricerca,false,false,
  851.                 soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  852.     }
  853.     protected List<IDAccordoDB> idAccordiServizioParteComuneList(String superuser, ISearch ricerca, 
  854.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException {
  855.         return idAccordiListEngine(superuser,ricerca,false,true,
  856.                 soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  857.     }
  858.     protected List<IDAccordoDB> idAccordiServizioCompostiList(String superuser, ISearch ricerca, 
  859.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException {
  860.         return idAccordiListEngine(superuser,ricerca,true,false,
  861.                 soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  862.     }
  863.     private List<IDAccordoDB> idAccordiListEngine(String superuser, ISearch ricerca,boolean excludeASParteComune,boolean excludeASComposti, 
  864.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException {
  865.         String nomeMetodo = "idAccordiList";
  866.         int idLista = Liste.ACCORDI;
  867.         int offset;
  868.         int limit;
  869.         String search;
  870.         String queryString;

  872.         limit = ricerca.getPageSize(idLista);
  873.         offset = ricerca.getIndexIniziale(idLista);
  874.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  875.         
  876.         String filterProtocollo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLO);
  877.         String filterProtocolli = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLI);
  878.         List<String> tipoSoggettiProtocollo = null;
  879.         try {
  880.             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filterProtocollo, filterProtocolli);
  881.         }catch(Exception e) {
  882.             throw new DriverRegistroServiziException(e.getMessage(),e);
  883.         }
  884.         boolean searchByTipoSoggetto = (tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0);
  885.         
  886.         String filterTipoAPI = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_SERVICE_BINDING);
  887.         
  888.         String filterStatoAccordo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_STATO_ACCORDO);
  889.         
  890.         String filterGruppo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_GRUPPO);

  892.         String filterCanale = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_CANALE);
  893.         boolean searchCanale = false;
  894.         boolean canaleDefault = false;
  895.         if(filterCanale!=null && !filterCanale.equals("")) {
  896.             searchCanale = true;
  897.             if(filterCanale.startsWith(Filtri.PREFIX_VALUE_CANALE_DEFAULT)) {
  898.                 filterCanale = filterCanale.substring(Filtri.PREFIX_VALUE_CANALE_DEFAULT.length());
  899.                 canaleDefault = true;
  900.             }
  901.         }
  902.         
  903.         this.driver.logDebug("search : " + search);
  904.         this.driver.logDebug("filterProtocollo : " + filterProtocollo);
  905.         this.driver.logDebug("filterProtocolli : " + filterProtocolli);
  906.         this.driver.logDebug("filterTipoAPI : " + filterTipoAPI);
  907.         this.driver.logDebug("filterStatoAccordo : " + filterStatoAccordo);
  908.         this.driver.logDebug("filterGruppo : " + filterGruppo);
  909.         this.driver.logDebug("filterCanale : " + filterCanale);

  911.         Connection con = null;
  912.         PreparedStatement stmt = null;
  913.         ResultSet risultato = null;

  915.         ArrayList<IDAccordoDB> lista = new ArrayList<IDAccordoDB>();

  917.         if (this.driver.atomica) {
  918.             try {
  919.                 con = this.driver.getConnectionFromDatasource("accordiListEngine");

  921.             } catch (Exception e) {
  922.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  924.             }

  926.         } else
  927.             con = this.driver.globalConnection;

  929.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  931.         try {

  933.             if(excludeASComposti && excludeASParteComune){
  934.                 throw new Exception("Non e' possibile invocare il metodo accordiListEngine con entrambi i parametri excludeASParteComune,excludeASComposti impostati al valore true");
  935.             }


  938.             ISQLQueryObject sqlQueryObjectExclude = null;
  939.             if(excludeASComposti || excludeASParteComune){
  940.                 sqlQueryObjectExclude = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  941.                 sqlQueryObjectExclude.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  942.                 sqlQueryObjectExclude.addSelectField(CostantiDB.ACCORDI_SERVIZI_COMPOSTO, "id_accordo");
  943.                 sqlQueryObjectExclude.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo="+CostantiDB.ACCORDI+".id");
  944.             }

  946.             ISQLQueryObject sqlQueryObjectExistsResource = null;
  947.             if(soloAccordiConsistentiRest) {
  948.                 sqlQueryObjectExistsResource = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  949.                 sqlQueryObjectExistsResource.addFromTable(CostantiDB.API_RESOURCES);
  950.                 sqlQueryObjectExistsResource.addSelectField(CostantiDB.API_RESOURCES, "id_accordo");
  951.                 sqlQueryObjectExistsResource.addWhereCondition(CostantiDB.API_RESOURCES+".id_accordo="+CostantiDB.ACCORDI+".id");
  952.                 sqlQueryObjectExistsResource.setANDLogicOperator(true);
  953.             }
  954.             
  955.             ISQLQueryObject sqlQueryObjectExistsPortTypeConAzioni = null;
  956.             if(soloAccordiConsistentiSoap){
  957.                 ISQLQueryObject sqlQueryObjectExistsPortTypeCheckAzioni = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  958.                 sqlQueryObjectExistsPortTypeCheckAzioni.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  959.                 sqlQueryObjectExistsPortTypeCheckAzioni.addSelectField(CostantiDB.PORT_TYPE_AZIONI, "id_port_type");
  960.                 sqlQueryObjectExistsPortTypeCheckAzioni.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  961.                 sqlQueryObjectExistsPortTypeCheckAzioni.setANDLogicOperator(true);
  962.                 
  963.                 sqlQueryObjectExistsPortTypeConAzioni = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  964.                 sqlQueryObjectExistsPortTypeConAzioni.addFromTable(CostantiDB.PORT_TYPE);
  965.                 sqlQueryObjectExistsPortTypeConAzioni.addSelectField(CostantiDB.PORT_TYPE, "id_accordo");
  966.                 sqlQueryObjectExistsPortTypeConAzioni.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo="+CostantiDB.ACCORDI+".id");
  967.                 sqlQueryObjectExistsPortTypeConAzioni.addWhereExistsCondition(false, sqlQueryObjectExistsPortTypeCheckAzioni);
  968.                 sqlQueryObjectExistsPortTypeConAzioni.setANDLogicOperator(true);
  969.             }
  970.             
  971.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  972.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  973.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  974.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente="+CostantiDB.SOGGETTI+".id");
  975.             sqlQueryObject.addSelectCountField("*", "cont");
  976.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  977.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".superuser = ?");
  978.             
  979.             //query con search
  980.             if (!search.equals("")) {
  981.                 sqlQueryObject.addWhereCondition(false, 
  982.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.ACCORDI+".nome", search, true, true));
  983.                         //sqlQueryObject.getWhereLikeCondition("versione", search, true, true), // la versione e' troppo, tutte hanno 1 ....
  984.                         //sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI+".nome_soggetto", search, true, true));  // fa confusone nei protocolli che non supportano il referente
  985.             }
  986.             if (searchByTipoSoggetto) {
  987.                 sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));       
  988.             }
  989.             
  990.             if(excludeASParteComune){
  991.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExclude);
  992.             }
  993.             if(excludeASComposti){
  994.                 sqlQueryObject.addWhereExistsCondition(true, sqlQueryObjectExclude);
  995.             }
  996.             
  997.             if(filterTipoAPI!=null && !filterTipoAPI.equals("")) {
  998.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".service_binding = ?");
  999.             }
  1000.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  1001.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".stato = ?");
  1002.             }
  1003.             if(filterGruppo!=null && !filterGruppo.equals("")) {
  1004.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  1005.                 sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  1006.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_accordo="+CostantiDB.ACCORDI+".id");
  1007.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_gruppo="+CostantiDB.GRUPPI+".id");
  1008.                 sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".nome = ?");
  1009.             }
  1010.             
  1011.             if(soloAccordiConsistentiRest && soloAccordiConsistentiSoap) {
  1012.                 sqlQueryObject.addWhereCondition(false, 
  1013.                         sqlQueryObjectExistsResource.getWhereExistsCondition(false, sqlQueryObjectExistsResource),
  1014.                         sqlQueryObjectExistsPortTypeConAzioni.getWhereExistsCondition(false, sqlQueryObjectExistsPortTypeConAzioni));
  1015.             }
  1016.             else if(soloAccordiConsistentiRest) {
  1017.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExistsResource);
  1018.             }
  1019.             else if(soloAccordiConsistentiSoap) {
  1020.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExistsPortTypeConAzioni);
  1021.             }
  1022.             
  1023.             if(searchCanale) {
  1024.                 if(canaleDefault) {
  1025.                     sqlQueryObject.addWhereCondition(false, CostantiDB.ACCORDI+".canale = ?", CostantiDB.ACCORDI+".canale is null");
  1026.                 }
  1027.                 else {
  1028.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".canale = ?");
  1029.                 }
  1030.             }
  1031.             
  1032.             sqlQueryObject.setANDLogicOperator(true);
  1033.             queryString = sqlQueryObject.createSQLQuery();
  1034.             stmt = con.prepareStatement(queryString);
  1035.             int index = 1;
  1036.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  1037.                 stmt.setString(index++, superuser);
  1038.             if(filterTipoAPI!=null && !filterTipoAPI.equals("")) {
  1039.                 stmt.setString(index++, filterTipoAPI);
  1040.             }
  1041.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  1042.                 stmt.setString(index++, filterStatoAccordo);
  1043.             }
  1044.             if(filterGruppo!=null && !filterGruppo.equals("")) {
  1045.                 stmt.setString(index++, filterGruppo);
  1046.             }
  1047.             if(searchCanale) {
  1048.                 stmt.setString(index++, filterCanale);
  1049.             }
  1050.             
  1051.             risultato = stmt.executeQuery();
  1052.             if (risultato.next())
  1053.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1054.             risultato.close();
  1055.             stmt.close();

  1057.             // ricavo le entries
  1058.             if (limit == 0) // con limit
  1059.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1060.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1061.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1062.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1063.             sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI, "id", "idAccordo");
  1064.             sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI, "nome", "nomeAccordo");
  1065.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI, "versione");
  1066.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI, "tipo_soggetto");
  1067.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI, "nome_soggetto");
  1068.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI, "id", "idSoggetto");
  1069.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente="+CostantiDB.SOGGETTI+".id");
  1070.             //sqlQueryObject.addSelectField("id_referente");
  1071.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  1072.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".superuser = ?");
  1073.             
  1074.             if (!search.equals("")) { // con search
  1075.                 sqlQueryObject.addWhereCondition(false, 
  1076.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.ACCORDI+".nome", search, true, true));
  1077.                 //sqlQueryObject.getWhereLikeCondition("versione", search, true, true), // la versione e' troppo, tutte hanno 1 ....
  1078.                 //sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI+".nome_soggetto", search, true, true));  // fa confusone nei protocolli che non supportano il referente
  1079.             }
  1080.             if (searchByTipoSoggetto) {
  1081.                 sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));       
  1082.             }

  1084.             if(excludeASParteComune){
  1085.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExclude);
  1086.             }
  1087.             if(excludeASComposti){
  1088.                 sqlQueryObject.addWhereExistsCondition(true, sqlQueryObjectExclude);
  1089.             }
  1090.             
  1091.             if(filterTipoAPI!=null && !filterTipoAPI.equals("")) { // con filter
  1092.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".service_binding = ?");
  1093.             }
  1094.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  1095.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".stato = ?");
  1096.             }
  1097.             if(filterGruppo!=null && !filterGruppo.equals("")) {
  1098.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  1099.                 sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  1100.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_accordo="+CostantiDB.ACCORDI+".id");
  1101.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_gruppo="+CostantiDB.GRUPPI+".id");
  1102.                 sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".nome = ?");
  1103.             }
  1104.                         
  1105.             if(soloAccordiConsistentiRest && soloAccordiConsistentiSoap) {
  1106.                 sqlQueryObject.addWhereCondition(false, 
  1107.                         sqlQueryObjectExistsResource.getWhereExistsCondition(false, sqlQueryObjectExistsResource),
  1108.                         sqlQueryObjectExistsPortTypeConAzioni.getWhereExistsCondition(false, sqlQueryObjectExistsPortTypeConAzioni));
  1109.             }
  1110.             else if(soloAccordiConsistentiRest) {
  1111.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExistsResource);
  1112.             }
  1113.             else if(soloAccordiConsistentiSoap) {
  1114.                 sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExistsPortTypeConAzioni);
  1115.             }
  1116.             
  1117.             if(searchCanale) {
  1118.                 if(canaleDefault) {
  1119.                     sqlQueryObject.addWhereCondition(false, CostantiDB.ACCORDI+".canale = ?", CostantiDB.ACCORDI+".canale is null");
  1120.                 }
  1121.                 else {
  1122.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".canale = ?");
  1123.                 }
  1124.             }
  1125.             
  1126.             sqlQueryObject.setANDLogicOperator(true);
  1127.             sqlQueryObject.addOrderBy("nomeAccordo");
  1128.             sqlQueryObject.addOrderBy("versione");
  1129.             sqlQueryObject.addOrderBy("nome_soggetto");
  1130.             sqlQueryObject.addOrderBy("tipo_soggetto");
  1131.             sqlQueryObject.setSortType(true);
  1132.             sqlQueryObject.setLimit(limit);
  1133.             sqlQueryObject.setOffset(offset);
  1134.             queryString = sqlQueryObject.createSQLQuery();

  1136.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(queryString));

  1138.             stmt = con.prepareStatement(queryString);
  1139.             index = 1;
  1140.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  1141.                 stmt.setString(index++, superuser);
  1142.             if(filterTipoAPI!=null && !filterTipoAPI.equals("")) {
  1143.                 stmt.setString(index++, filterTipoAPI);
  1144.             }
  1145.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  1146.                 stmt.setString(index++, filterStatoAccordo);
  1147.             }
  1148.             if(filterGruppo!=null && !filterGruppo.equals("")) {
  1149.                 stmt.setString(index++, filterGruppo);
  1150.             }
  1151.             if(searchCanale) {
  1152.                 stmt.setString(index++, filterCanale);
  1153.             }
  1154.             risultato = stmt.executeQuery();

  1156.             while (risultato.next()) {

  1158.                 IDSoggettoDB idSoggettoDB = new IDSoggettoDB(risultato.getString("tipo_soggetto"), risultato.getString("nome_soggetto"));
  1159.                 idSoggettoDB.setId(risultato.getLong("idSoggetto"));
  1160.                 
  1161.                 IDAccordoDB idAccordoDB = new IDAccordoDB(risultato.getString("nomeAccordo"), idSoggettoDB, risultato.getInt("versione"));
  1162.                 idAccordoDB.setId(risultato.getLong("idAccordo"));
  1163.                 
  1164.                 lista.add(idAccordoDB);

  1166.             }

  1168.             this.driver.logDebug("size lista :" + ((lista == null) ? null : lista.size()));

  1170.             return lista;

  1172.         } catch (Exception se) {

  1174.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1175.         } finally {

  1177.             //Chiudo statement and resultset
  1178.             JDBCUtilities.closeResources(risultato, stmt);

  1180.             this.driver.closeConnection(con);
  1181.         }
  1182.     }
  1183.     
  1184.     protected AccordoServizioParteComune[] getAllIdAccordiWithSoggettoReferente(IDSoggetto idsoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1186.         Connection con = null;
  1187.         PreparedStatement stm = null;
  1188.         ResultSet rs = null;

  1190.         this.driver.logDebug("getAllIdAccordiWithSoggettoReferente...");

  1192.         try {
  1193.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  1194.             // prendo la connessione dal pool
  1195.             if (this.driver.atomica)
  1196.                 con = this.driver.getConnectionFromDatasource("getAllIdAccordiWithSoggettoReferente");
  1197.             else
  1198.                 con = this.driver.globalConnection;

  1200.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1201.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1202.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1203.             sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI,"id","idAccordo");
  1204.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente="+CostantiDB.SOGGETTI+".id");
  1205.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto=?");
  1206.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto=?");
  1207.             sqlQueryObject.setANDLogicOperator(true);
  1208.             String sqlQuery = sqlQueryObject.createSQLQuery();
  1209.             this.driver.logDebug("eseguo query : " + sqlQuery );
  1210.             stm = con.prepareStatement(sqlQuery);
  1211.             stm.setString(1, idsoggetto.getTipo());
  1212.             stm.setString(2, idsoggetto.getNome());
  1213.             rs = stm.executeQuery();
  1214.             List<AccordoServizioParteComune> accordi = new ArrayList<AccordoServizioParteComune>();
  1215.             while (rs.next()) {
  1216.                 accordi.add(this.getAccordoServizioParteComune(rs.getLong("idAccordo")));
  1217.             }
  1218.             if(accordi.size()==0){
  1219.                 throw new DriverRegistroServiziNotFound("Accordi non trovati con soggetto referente ["+idsoggetto+"]");
  1220.             }else{
  1221.                 AccordoServizioParteComune [] res = new AccordoServizioParteComune[1];
  1222.                 return accordi.toArray(res);
  1223.             }
  1224.         }catch(DriverRegistroServiziNotFound de){
  1225.             throw de;
  1226.         }
  1227.         catch(Exception e){
  1228.             throw new DriverRegistroServiziException("getAllIdAccordiWithSoggettoReferente error",e);
  1229.         } finally {

  1231.             //Chiudo statement and resultset
  1232.             JDBCUtilities.closeResources(rs, stm);

  1234.             this.driver.closeConnection(con);

  1236.         }
  1237.     }
  1238.     
  1239.     
  1240.     protected IDAccordo getIdAccordoServizioParteComune(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1241.         return getIdAccordoServizioParteComune(id,null);
  1242.     }
  1243.     protected IDAccordo getIdAccordoServizioParteComune(long id,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1244.         this.driver.logDebug("richiesto getIdAccordoServizioParteComune: " + id);
  1245.         // conrollo consistenza
  1246.         if (id <= 0)
  1247.             return null;

  1249.         Connection con = null;
  1250.         PreparedStatement stm = null;
  1251.         ResultSet rs = null;

  1253.         IDAccordo idAccordo = null;
  1254.         try {
  1255.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1256.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1257.             sqlQueryObject.addSelectField("nome");
  1258.             sqlQueryObject.addSelectField("id_referente");
  1259.             sqlQueryObject.addSelectField("versione");
  1260.             sqlQueryObject.addWhereCondition("id = ?");
  1261.             String sqlQuery = sqlQueryObject.createSQLQuery();

  1263.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  1264.             // prendo la connessione dal pool
  1265.             if(conParam!=null){
  1266.                 con = conParam;
  1267.             }
  1268.             else if (this.driver.atomica)
  1269.                 con = this.driver.getConnectionFromDatasource("getIdAccordoServizioParteComune(longId)");
  1270.             else
  1271.                 con = this.driver.globalConnection;

  1273.             stm = con.prepareStatement(sqlQuery);

  1275.             stm.setLong(1, id);

  1277.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  1278.             rs = stm.executeQuery();


  1281.             if (rs.next()) {

  1283.                 IDSoggetto referente = null;
  1284.                 long idReferente = rs.getLong("id_referente");
  1285.                 if(idReferente>0){
  1286.                     referente = this.driver.getIdSoggetto(idReferente,con);
  1287.                     if(referente==null){
  1288.                         throw new Exception("Soggetto referente non presente?");
  1289.                     }
  1290.                 }

  1292.                 idAccordo = this.driver.idAccordoFactory.getIDAccordoFromValues(rs.getString("nome"),referente,rs.getInt("versione"));

  1294.             } else {
  1295.                 rs.close();
  1296.                 stm.close();
  1297.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getIdAccordoServizioParteComune] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  1298.             }

  1300.             rs.close();
  1301.             stm.close();

  1303.         } catch (SQLException se) {
  1304.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdAccordoServizioParteComune] SQLException :" + se.getMessage(),se);
  1305.         }catch (DriverRegistroServiziNotFound e) {
  1306.             throw e;
  1307.         }catch (Exception se) {
  1308.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdAccordoServizioParteComune] Exception :" + se.getMessage(),se);
  1309.         } finally {

  1311.             //Chiudo statement and resultset
  1312.             JDBCUtilities.closeResources(rs, stm);

  1314.             this.driver.closeConnection(conParam, con);

  1316.         }

  1318.         return idAccordo;
  1319.     }
  1320.     
  1321.     protected List<Documento> accordiAllegatiList(long idAccordo, ISearch ricerca) throws DriverRegistroServiziException {
  1322.         String nomeMetodo = "accordiAllegatiList";
  1323.         int idLista = Liste.ACCORDI_ALLEGATI;
  1324.         int offset;
  1325.         int limit;
  1326.         String search;
  1327.         String queryString;

  1329.         limit = ricerca.getPageSize(idLista);
  1330.         offset = ricerca.getIndexIniziale(idLista);
  1331.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1332.         ricerca.getSearchString(idLista);

  1334.         Connection con = null;
  1335.         PreparedStatement stmt = null;
  1336.         ResultSet risultato = null;

  1338.         ArrayList<Documento> lista = new ArrayList<Documento>();

  1340.         if (this.driver.atomica) {
  1341.             try {
  1342.                 con = this.driver.getConnectionFromDatasource("accordiAllegatiList");

  1344.             } catch (Exception e) {
  1345.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1347.             }

  1349.         } else
  1350.             con = this.driver.globalConnection;

  1352.         try {

  1354.             if (!search.equals("")) {
  1355.                 //query con search
  1356.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1357.                 sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  1358.                 sqlQueryObject.addSelectCountField("*", "cont");
  1359.                 sqlQueryObject.addWhereCondition("id_proprietario = ?");
  1360.                 sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  1361.                 sqlQueryObject.addWhereCondition(false, 
  1362.                         //sqlQueryObject.getWhereLikeCondition("ruolo",search,true,true),
  1363.                         sqlQueryObject.getWhereLikeCondition("nome",search,true,true));
  1364.                 sqlQueryObject.setANDLogicOperator(true);
  1365.                 queryString = sqlQueryObject.createSQLQuery();
  1366.             } else {
  1367.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1368.                 sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  1369.                 sqlQueryObject.addSelectCountField("*", "cont");
  1370.                 sqlQueryObject.addWhereCondition("id_proprietario = ?");
  1371.                 sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  1372.                 sqlQueryObject.setANDLogicOperator(true);
  1373.                 queryString = sqlQueryObject.createSQLQuery();
  1374.             }

  1376.             stmt = con.prepareStatement(queryString);
  1377.             stmt.setLong(1,idAccordo);
  1378.             stmt.setString(2, ProprietariDocumento.accordoServizio.toString());
  1379.             risultato = stmt.executeQuery();
  1380.             if (risultato.next())
  1381.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1382.             risultato.close();
  1383.             stmt.close();

  1385.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1386.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  1387.             sqlQueryObject.addSelectField("id");
  1388.             sqlQueryObject.addSelectField("nome");
  1389.             sqlQueryObject.addSelectField("ruolo");
  1390.             sqlQueryObject.addSelectField("id_proprietario");
  1391.             sqlQueryObject.addSelectField("tipo_proprietario");
  1392.             //where
  1393.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  1394.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");

  1396.             // ricavo le entries
  1397.             if (limit == 0) // con limit
  1398.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1400.             if (!search.equals("")) { // con search
  1401.                 sqlQueryObject.addWhereCondition(false, 
  1402.                         //sqlQueryObject.getWhereLikeCondition("ruolo",search,true,true),
  1403.                         sqlQueryObject.getWhereLikeCondition("nome",search,true,true));
  1404.             } 

  1406.             sqlQueryObject.setANDLogicOperator(true);
  1407.             sqlQueryObject.addOrderBy("nome");
  1408.             sqlQueryObject.setSortType(true);
  1409.             sqlQueryObject.setLimit(limit);
  1410.             sqlQueryObject.setOffset(offset);
  1411.             queryString = sqlQueryObject.createSQLQuery();

  1413.             stmt = con.prepareStatement(queryString);
  1414.             stmt.setLong(1, idAccordo);
  1415.             stmt.setString(2, ProprietariDocumento.accordoServizio.toString());
  1416.             risultato = stmt.executeQuery();

  1418.             while(risultato.next()){
  1419.                 Documento doc = DriverRegistroServiziDB_documentiLIB.getDocumento(risultato.getLong("id"),false, con, this.driver.tipoDB); 
  1420.                 lista.add(doc);
  1421.             }

  1423.             return lista;

  1425.         } catch (Exception se) {

  1427.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1428.         } finally {
  1429.             //Chiudo statement and resultset
  1430.             JDBCUtilities.closeResources(risultato, stmt);
  1431.             
  1432.             this.driver.closeConnection(con);
  1433.         }
  1434.     }
  1435.     
  1436.     protected List<IDServizio> getIdServiziWithAccordo(IDAccordo idAccordo,boolean checkPTisNull) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1437.         String nomeMetodo = "getIdServiziWithPortType";

  1439.         Connection con = null;
  1440.         PreparedStatement stmt = null;
  1441.         ResultSet rs = null;
  1442.         String queryString;

  1444.         if (this.driver.atomica) {
  1445.             try {
  1446.                 con = this.driver.getConnectionFromDatasource("getIdServiziWithAccordo");

  1448.             } catch (Exception e) {
  1449.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  1451.             }

  1453.         } else {
  1454.             con = this.driver.globalConnection;
  1455.         }

  1457.         this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);

  1459.         List<IDServizio> idServizi = new ArrayList<IDServizio>(); 
  1460.         try {

  1462.             //recupero idAccordo
  1463.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordo, con, this.driver.tipoDB);
  1464.             // Controllo che il pdd non sia in uso
  1465.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1466.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1467.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1468.             sqlQueryObject.addSelectField("nome_servizio");
  1469.             sqlQueryObject.addSelectField("tipo_servizio");
  1470.             sqlQueryObject.addSelectField("versione_servizio");
  1471.             sqlQueryObject.addSelectField("nome_soggetto");
  1472.             sqlQueryObject.addSelectField("tipo_soggetto");
  1473.             sqlQueryObject.setANDLogicOperator(true);
  1474.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo=?");
  1475.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  1476.             if(checkPTisNull){
  1477.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".port_type is null");
  1478.             }
  1479.             queryString = sqlQueryObject.createSQLQuery();
  1480.             stmt = con.prepareStatement(queryString);
  1481.             stmt.setLong(1, idAccordoLong);

  1483.             rs = stmt.executeQuery();
  1484.             while (rs.next()) {
  1485.                 IDSoggetto soggettoErogatore = new IDSoggetto(rs.getString("tipo_soggetto"), rs.getString("nome_soggetto"));
  1486.                 IDServizio idServizio = 
  1487.                         this.driver.idServizioFactory.getIDServizioFromValues(rs.getString("tipo_servizio"), 
  1488.                                 rs.getString("nome_servizio"), soggettoErogatore, rs.getInt("versione_servizio"));
  1489.                 idServizi.add(idServizio);
  1490.             }

  1492.             if(idServizi.size()<=0){
  1493.                 throw new DriverRegistroServiziNotFound("Servizi non trovato che implementano l'accordo di servizio "+idAccordo.toString());
  1494.             }
  1495.             else{
  1496.                 return idServizi;
  1497.             }

  1499.         }catch(DriverRegistroServiziNotFound dNot){
  1500.             throw dNot;
  1501.         }catch (Exception se) {
  1502.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1503.         } finally {
  1504.             // Chiudo statement and resultset
  1505.             JDBCUtilities.closeResources(rs, stmt);
  1506.             
  1507.             this.driver.closeConnection(con);
  1508.         }
  1509.     }
  1510.     
  1511.     
  1512.     protected void validaStatoAccordoServizio(AccordoServizioParteComune as,boolean utilizzoAzioniDiretteInAccordoAbilitato) throws ValidazioneStatoPackageException{

  1514.         ValidazioneStatoPackageException erroreValidazione =
  1515.                 new ValidazioneStatoPackageException("AccordoServizio",as.getStatoPackage(),null);

  1517.         try{

  1519.             // Controlli di visibilita
  1520.             if(as.getPrivato()==null || as.getPrivato()==false){
  1521.                 if(as.getSoggettoReferente()!=null){
  1522.                     IDSoggetto idS = new IDSoggetto(as.getSoggettoReferente().getTipo(),as.getSoggettoReferente().getNome());
  1523.                     try{
  1524.                         Soggetto s = this.driver.getSoggetto(idS);
  1525.                         if(s.getPrivato()!=null && s.getPrivato()){
  1526.                             erroreValidazione.addErroreValidazione("soggetto referente ["+idS+"] con visibilita' privata, in un accordo di servizio con visibilita' pubblica");
  1527.                         }
  1528.                     }catch(DriverRegistroServiziNotFound dNot){}
  1529.                 }
  1530.             }
  1531.             if(as.getServizioComposto()!=null){
  1532.                 if(as.getServizioComposto().getIdAccordoCooperazione()>0){
  1533.                     try{
  1534.                         AccordoCooperazione ac = this.driver.getAccordoCooperazione(as.getServizioComposto().getIdAccordoCooperazione());
  1535.                         if(as.getPrivato()==null || as.getPrivato()==false){
  1536.                             if(ac.getPrivato()!=null && ac.getPrivato()){
  1537.                                 erroreValidazione.addErroreValidazione("accordo di cooperazione ["+this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(ac)+"] con visibilita' privata, in un accordo di servizio con visibilita' pubblica");
  1538.                             }
  1539.                         }
  1540.                     }catch(DriverRegistroServiziNotFound dNot){}
  1541.                 }
  1542.                 if(as.getServizioComposto().sizeServizioComponenteList()>=2){
  1543.                     for(int i=0; i<as.getServizioComposto().sizeServizioComponenteList(); i++){
  1544.                         if(as.getServizioComposto().getServizioComponente(i).getId()>0){
  1545.                             try{
  1546.                                 AccordoServizioParteSpecifica sc = this.driver.getAccordoServizioParteSpecifica(as.getServizioComposto().getServizioComponente(i).getId());
  1547.                                 if(as.getPrivato()==null || as.getPrivato()==false){
  1548.                                     if(sc.getPrivato()!=null && sc.getPrivato()){
  1549.                                         String uriServizioComponente = this.driver.idServizioFactory.getUriFromAccordo(sc);
  1550.                                         erroreValidazione.addErroreValidazione("servizio componente ["+uriServizioComponente+"] con visibilita' privata, in un accordo di servizio con visibilita' pubblica");
  1551.                                     }
  1552.                                 }
  1553.                             }catch(DriverRegistroServiziNotFound dNot){}
  1554.                         }
  1555.                     }
  1556.                 }
  1557.             }

  1559.             if(ServiceBinding.SOAP.equals(as.getServiceBinding())) {

  1561.                 // Controlli di stato
  1562.                 if(StatiAccordo.bozza.toString().equals(as.getStatoPackage()) == false){
  1563.     
  1564.                     // Validazione necessaria sia ad uno stato operativo che finale
  1565.                     if(utilizzoAzioniDiretteInAccordoAbilitato==false){
  1566.                         if(as.sizePortTypeList()==0){
  1567.                             erroreValidazione.addErroreValidazione("non sono definiti Servizi");
  1568.                         }
  1569.                         for(int j=0; j<as.sizePortTypeList(); j++){
  1570.                             if(as.getPortType(j).sizeAzioneList()==0){
  1571.                                 erroreValidazione.addErroreValidazione("servizio["+as.getPortType(j).getNome()+"] non possiede azioni");
  1572.                             }
  1573.                         }
  1574.                     }else{
  1575.                         if(as.sizePortTypeList()==0 && as.sizeAzioneList()==0 && as.getUtilizzoSenzaAzione()==false){
  1576.                             erroreValidazione.addErroreValidazione("non sono definite ne Azioni (utilizzoSenzaAzione=false) ne Servizi");
  1577.                         }
  1578.                         if(as.sizePortTypeList()!=0){
  1579.                             for(int j=0; j<as.sizePortTypeList(); j++){
  1580.                                 if(as.getPortType(j).sizeAzioneList()==0){
  1581.                                     erroreValidazione.addErroreValidazione("servizio["+as.getPortType(j).getNome()+"] non possiede azioni");
  1582.                                 }
  1583.                             }
  1584.                         }
  1585.                         if(as.sizePortTypeList()!=0){
  1586.                             for(int j=0; j<as.sizePortTypeList(); j++){
  1587.                                 PortType pt = as.getPortType(j);
  1588.                                 for(int k=0;k<pt.sizeAzioneList();k++){
  1589.                                     Operation op = pt.getAzione(k);
  1590.                                     ProfiloCollaborazione profiloCollaborazioneOP = op.getProfiloCollaborazione();
  1591.                                     if(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT.equals(op.getProfAzione())){
  1592.                                         profiloCollaborazioneOP = pt.getProfiloCollaborazione();
  1593.                                         if(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT.equals(pt.getProfiloPT())){
  1594.                                             profiloCollaborazioneOP = as.getProfiloCollaborazione();
  1595.                                         }
  1596.                                     }
  1597.                                     if(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazioneOP) ||
  1598.                                             CostantiRegistroServizi.ASINCRONO_SIMMETRICO.equals(profiloCollaborazioneOP)    ){
  1599.                                         if(op.getCorrelata()==null){
  1600.                                             // Verifico che esista un altra azione correlata a questa.
  1601.                                             boolean trovataCorrelazione = false;
  1602.                                             for(int verificaPTIndex=0; verificaPTIndex<as.sizePortTypeList(); verificaPTIndex++){
  1603.                                                 PortType ptVerifica = as.getPortType(verificaPTIndex);
  1604.                                                 for(int verificaOPIndex=0; verificaOPIndex<ptVerifica.sizeAzioneList(); verificaOPIndex++){
  1605.                                                     Operation opVerifica = ptVerifica.getAzione(verificaOPIndex);
  1606.                                                     if(opVerifica.getCorrelata()!=null && opVerifica.getCorrelata().equals(op.getNome())){
  1607.                                                         // potenziale correlazione, verifico servizio
  1608.                                                         if(opVerifica.getCorrelataServizio()==null){
  1609.                                                             if(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazioneOP) && ptVerifica.getNome().equals(pt.getNome())){
  1610.                                                                 // la correlazione per l'asincrono asimmetrico puo' avvenire sullo stesso port type
  1611.                                                                 trovataCorrelazione = true;
  1612.                                                                 break;
  1613.                                                             }
  1614.                                                         }
  1615.                                                         else if(opVerifica.getCorrelataServizio().equals(pt.getNome())){
  1616.                                                             trovataCorrelazione = true;
  1617.                                                             break;
  1618.                                                         }
  1619.                                                     }
  1620.                                                 }
  1621.                                             }
  1622.                                             if(trovataCorrelazione==false){
  1623.                                                 erroreValidazione.addErroreValidazione("L'azione ["+op.getNome()+"] del servizio["+as.getPortType(j).getNome()+"] non risulta correlata da altre azioni");
  1624.                                             }
  1625.                                         }
  1626.                                     }
  1627.                                 }
  1628.                             }
  1629.                         }
  1630.                     }
  1631.     
  1632.                     if(StatiAccordo.finale.toString().equals(as.getStatoPackage())){
  1633.     
  1634.                         String wsdlConcettuale = (as.getByteWsdlConcettuale()!=null ? new String(as.getByteWsdlConcettuale()) : null);
  1635.                         String wsdlLogicoErogatore = (as.getByteWsdlLogicoErogatore()!=null ? new String(as.getByteWsdlLogicoErogatore()) : null);
  1636.                         wsdlConcettuale = wsdlConcettuale!=null && !"".equals(wsdlConcettuale.trim().replaceAll("\n", "")) ? wsdlConcettuale : null;
  1637.                         wsdlLogicoErogatore = wsdlLogicoErogatore!=null && !"".equals(wsdlLogicoErogatore.trim().replaceAll("\n", "")) ? wsdlLogicoErogatore : null;
  1638.     
  1639.                         if( wsdlConcettuale == null){
  1640.                             erroreValidazione.addErroreValidazione("interfaccia WSDL Concettuale non definita");
  1641.                         }
  1642.                         if( wsdlLogicoErogatore == null){
  1643.                             erroreValidazione.addErroreValidazione("interfaccia WSDL LogicoErogatore non definita");
  1644.                         }
  1645.     
  1646.                         if(as.getServizioComposto()!=null){
  1647.                             if(as.getServizioComposto().getIdAccordoCooperazione()<=0){
  1648.                                 erroreValidazione.addErroreValidazione("accordo di cooperazione (id) non definito");
  1649.                             }else{
  1650.                                 try{
  1651.                                     AccordoCooperazione ac = this.driver.getAccordoCooperazione(as.getServizioComposto().getIdAccordoCooperazione());
  1652.                                     if(StatiAccordo.finale.toString().equals(ac.getStatoPackage())==false){
  1653.                                         erroreValidazione.addErroreValidazione("accordo di cooperazione ["+this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(ac)+"] in uno stato non finale ["+ac.getStatoPackage()+"]");
  1654.                                     }
  1655.                                 }catch(DriverRegistroServiziNotFound dNot){
  1656.                                     erroreValidazione.addErroreValidazione("accordo di cooperazione non definito");
  1657.                                 }
  1658.                             }
  1659.     
  1660.                             if(as.getServizioComposto().sizeSpecificaCoordinamentoList()<=0){
  1661.                                 erroreValidazione.addErroreValidazione("specifica di coordinamento non definita");
  1662.                             }
  1663.     
  1664.     
  1665.                             if(as.getServizioComposto().sizeServizioComponenteList()<=0){
  1666.                                 erroreValidazione.addErroreValidazione("servizi componenti non definiti");  
  1667.                             }else{
  1668.                                 if(as.getServizioComposto().sizeServizioComponenteList()<2){
  1669.                                     erroreValidazione.addErroreValidazione("almeno 2 servizi componenti sono necessari per realizzare un servizio composto");   
  1670.                                 }else{
  1671.                                     for(int i=0; i<as.getServizioComposto().sizeServizioComponenteList(); i++){
  1672.                                         if(as.getServizioComposto().getServizioComponente(i).getIdServizioComponente()<=0){
  1673.                                             erroreValidazione.addErroreValidazione("servizio componente ["+i+"] (id) non definito");
  1674.                                         }else{
  1675.                                             try{
  1676.                                                 AccordoServizioParteSpecifica sc = this.driver.getAccordoServizioParteSpecifica(as.getServizioComposto().getServizioComponente(i).getIdServizioComponente());
  1677.                                                 if(StatiAccordo.finale.toString().equals(sc.getStatoPackage())==false){
  1678.                                                     String uriServizioComponente = this.driver.idServizioFactory.getUriFromAccordo(sc);
  1679.                                                     erroreValidazione.addErroreValidazione("servizio componente ["+uriServizioComponente+"] in uno stato non finale ["+sc.getStatoPackage()+"]");
  1680.                                                 }
  1681.                                             }catch(DriverRegistroServiziNotFound dNot){
  1682.                                                 erroreValidazione.addErroreValidazione("servizio componente ["+i+"] non definito");
  1683.                                             }
  1684.                                         }
  1685.                                     }
  1686.                                 }
  1687.                             }
  1688.                         }
  1689.     
  1690.                     }
  1691.     
  1692.                 }
  1693.             }
  1694.             else {
  1695.                 
  1696.                 // REST
  1697.                 
  1698.                 // Controlli di stato
  1699.                 if(StatiAccordo.bozza.toString().equals(as.getStatoPackage()) == false){
  1700.                     
  1701.                     if(as.sizeResourceList()==0){
  1702.                         erroreValidazione.addErroreValidazione("non sono definite alcune risorse");
  1703.                     }
  1704.                     
  1705.                 }
  1706.                 
  1707.                 if(StatiAccordo.finale.toString().equals(as.getStatoPackage())){
  1708.                     
  1709.                     String wsdlConcettuale = (as.getByteWsdlConcettuale()!=null ? new String(as.getByteWsdlConcettuale()) : null);
  1710.                     wsdlConcettuale = wsdlConcettuale!=null && !"".equals(wsdlConcettuale.trim().replaceAll("\n", "")) ? wsdlConcettuale : null;
  1711.                     
  1712.                     if( wsdlConcettuale == null){
  1713.                         erroreValidazione.addErroreValidazione("Specifica di interfaccia non definita");
  1714.                     }
  1715.                     
  1716.                 }
  1717.                 
  1718.             }

  1720.         }catch(Exception e){
  1721.             throw new ValidazioneStatoPackageException(e);
  1722.         }

  1724.         if(erroreValidazione.sizeErroriValidazione()>0){
  1725.             throw erroreValidazione;
  1726.         }
  1727.     }
  1728.     
  1729.     protected void controlloUnicitaImplementazioneAccordoPerSoggetto(String portType,
  1730.             IDSoggetto idSoggettoErogatore, long idSoggettoErogatoreLong, 
  1731.             IDAccordo idAccordoServizioParteComune, long idAccordoServizioParteComuneLong,
  1732.             IDServizio idAccordoServizioParteSpecifica, long idAccordoServizioParteSpecificaLong,
  1733.             boolean isUpdate,boolean isServizioCorrelato,
  1734.             boolean isAbilitatoControlloUnicitaImplementazioneAccordoPerSoggetto,
  1735.             boolean isAbilitatoControlloUnicitaImplementazionePortTypePerSoggetto) throws DriverRegistroServiziException{
  1736.         /*
  1737.          * Controllo che non esistano 2 servizi con stesso soggetto erogatore e accordo di servizio 
  1738.          * che siano entrambi correlati o non correlati. 
  1739.          * Al massimo possono esistere 2 servizi di uno stesso accordo erogati da uno stesso soggetto, 
  1740.          * purche' siano uno correlato e uno no. 
  1741.          * Se tipoOp = change, devo fare attenzione a non escludere il servizio selezionato che sto
  1742.          * cambiando 
  1743.          */

  1745.         String tmpServCorr = CostantiRegistroServizi.DISABILITATO.toString();
  1746.         if(isServizioCorrelato){
  1747.             tmpServCorr = CostantiRegistroServizi.ABILITATO.toString();
  1748.         }
  1749.         String s = "servizio";
  1750.         if (isServizioCorrelato) {
  1751.             s = "servizio correlato";
  1752.         }

  1754.         // se il servizio non definisce port type effettuo controllo che non
  1755.         // esistano 2 servizi con stesso soggetto,
  1756.         // accordo e servizio correlato
  1757.         if (portType == null || "-".equals(portType)) {

  1759.             if(isAbilitatoControlloUnicitaImplementazioneAccordoPerSoggetto){

  1761.                 // Controllo che non esistano 2 servizi con stesso soggetto,
  1762.                 // accordo e servizio correlato
  1763.                 // Se tipoOp = change, devo fare attenzione a non escludere il servizio selezionato

  1765.                 long idAccordoServizioParteSpecificaAlreadyExists = 
  1766.                         this.driver.getServizioWithSoggettoAccordoServCorr(idSoggettoErogatoreLong, idAccordoServizioParteComuneLong, 
  1767.                                 tmpServCorr);

  1769.                 boolean addError = ((!isUpdate) && (idAccordoServizioParteSpecificaAlreadyExists > 0));

  1771.                 boolean changeError = false;
  1772.                 if (isUpdate && (idAccordoServizioParteSpecificaAlreadyExists > 0)) {
  1773.                     changeError = (idAccordoServizioParteSpecificaLong != idAccordoServizioParteSpecificaAlreadyExists);
  1774.                 }

  1776.                 if (addError || changeError) {
  1777.                     throw new DriverRegistroServiziException("Esiste gi&agrave; un " + s + " del Soggetto "+idSoggettoErogatore+
  1778.                             " che implementa l'accordo selezionato ["+IDAccordoFactory.getInstance().getUriFromIDAccordo(idAccordoServizioParteComune)+"]");
  1779.                 }

  1781.             }

  1783.         } else {

  1785.             if(isAbilitatoControlloUnicitaImplementazionePortTypePerSoggetto){

  1787.                 // Controllo che non esistano 2 servizi con stesso soggetto,
  1788.                 // accordo e servizio correlato e port-type

  1790.                 long idAccordoServizioParteSpecificaAlreadyExists =  
  1791.                         this.driver.getServizioWithSoggettoAccordoServCorrPt(idSoggettoErogatoreLong, idAccordoServizioParteComuneLong, 
  1792.                                 tmpServCorr, portType);

  1794.                 boolean addError = ((!isUpdate) && (idAccordoServizioParteSpecificaAlreadyExists > 0));

  1796.                 boolean changeError = false;
  1797.                 if (isUpdate && (idAccordoServizioParteSpecificaAlreadyExists > 0)) {
  1798.                     changeError = (idAccordoServizioParteSpecificaLong != idAccordoServizioParteSpecificaAlreadyExists);
  1799.                 }

  1801.                 if (addError || changeError) {
  1802.                     throw new DriverRegistroServiziException("Esiste gi&agrave; un " + s + " del Soggetto "+idSoggettoErogatore+
  1803.                             " che implementa il servizio "+portType+" dell'accordo selezionato ["+IDAccordoFactory.getInstance().getUriFromIDAccordo(idAccordoServizioParteComune)+"]");
  1804.                 }

  1806.             }
  1807.         }
  1808.     }
  1809. }
Created with JaCoCo 0.8.8.202204050719