DriverRegistroServiziDB_accordiParteSpecificaDriver.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.sql.Timestamp;
  31. import java.util.ArrayList;
  32. import java.util.List;

  34. import org.openspcoop2.core.commons.DBUtils;
  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  37. import org.openspcoop2.core.id.IDAccordo;
  38. import org.openspcoop2.core.id.IDFruizione;
  39. import org.openspcoop2.core.id.IDServizio;
  40. import org.openspcoop2.core.id.IDSoggetto;
  41. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  42. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  43. import org.openspcoop2.core.registry.ConfigurazioneServizio;
  44. import org.openspcoop2.core.registry.ConfigurazioneServizioAzione;
  45. import org.openspcoop2.core.registry.Documento;
  46. import org.openspcoop2.core.registry.Fruitore;
  47. import org.openspcoop2.core.registry.ProtocolProperty;
  48. import org.openspcoop2.core.registry.Soggetto;
  49. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  50. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  51. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  52. import org.openspcoop2.core.registry.constants.ServiceBinding;
  53. import org.openspcoop2.core.registry.constants.StatiAccordo;
  54. import org.openspcoop2.core.registry.constants.StatoFunzionalita;
  55. import org.openspcoop2.core.registry.constants.TipologiaServizio;
  56. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  57. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  58. import org.openspcoop2.core.registry.driver.FiltroRicercaFruizioniServizio;
  59. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  60. import org.openspcoop2.core.registry.driver.ValidazioneStatoPackageException;
  61. import org.openspcoop2.utils.date.DateManager;
  62. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  63. import org.openspcoop2.utils.sql.ISQLQueryObject;
  64. import org.openspcoop2.utils.sql.SQLObjectFactory;

  66. /**
  67.  * DriverRegistroServiziDB_accordiParteSpecificaDriver
  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_accordiParteSpecificaDriver {

  77.     private DriverRegistroServiziDB driver = null;
  78.     private DriverRegistroServiziDB_protocolPropertiesDriver protocolPropertiesDriver = null;
  79.     
  80.     protected DriverRegistroServiziDB_accordiParteSpecificaDriver(DriverRegistroServiziDB driver) {
  81.         this.driver = driver;
  82.         this.protocolPropertiesDriver = new DriverRegistroServiziDB_protocolPropertiesDriver(driver);
  83.     }
  84.     
  85.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  86.         return this.getAccordoServizioParteSpecifica(idServizio,false,null);
  87.     }
  88.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio,Connection con) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  89.         return this.getAccordoServizioParteSpecifica(idServizio,false,con);
  90.     }
  91.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio,boolean readContenutoAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  92.         return this.getAccordoServizioParteSpecifica(idServizio, readContenutoAllegati, null);
  93.     }
  94.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio,boolean readContenutoAllegati,Connection con) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  95.         // questo e' il tipo 1 cioe Servizio con parametro IDService
  96.         AccordoServizioParteSpecifica servizio = getAccordoServizioParteSpecifica(idServizio,null, null,readContenutoAllegati,con);
  97.         return servizio;
  98.     }

  100.     
  101.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto,IDAccordo idAccordoServizioParteComune) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  102.         return this.getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto,idAccordoServizioParteComune,false,null);
  103.     }
  104.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto,IDAccordo idAccordoServizioParteComune,Connection con) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  105.         return this.getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto,idAccordoServizioParteComune,false,con);
  106.     }
  107.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto,IDAccordo idAccordoServizioParteComune,boolean readContenutoAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  108.         return this.getAccordoServizioParteSpecifica_ServizioCorrelato(idSoggetto,idAccordoServizioParteComune, readContenutoAllegati, null);
  109.     }
  110.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto,IDAccordo idAccordoServizioParteComune,boolean readContenutoAllegati,Connection con) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  111.         // questo e' il tipo 2 
  112.         AccordoServizioParteSpecifica servizio = getAccordoServizioParteSpecifica(null,idSoggetto, idAccordoServizioParteComune,readContenutoAllegati,con);
  113.         return servizio;
  114.     }

  116.     protected List<IDServizio> getAllIdServizi(FiltroRicercaServizi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  117.         
  118.         List<IDServizio> list = new ArrayList<>();
  119.         _fillAllIdServiziEngine("getAllIdServizi", filtroRicerca, list);
  120.         return list;
  121.         
  122.     }
  123.     
  124.     protected List<IDFruizione> getAllIdFruizioniServizio(
  125.             FiltroRicercaFruizioniServizio filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  126.     
  127.         List<IDFruizione> list = new ArrayList<IDFruizione>();
  128.         _fillAllIdServiziEngine("getAllIdFruizioniServizio", filtroRicerca, list);
  129.         return list;
  130.         
  131.     }
  132.     
  133.     @SuppressWarnings("unchecked")
  134.     protected <T> void _fillAllIdServiziEngine(String nomeMetodo, 
  135.             FiltroRicercaServizi filtroRicerca,
  136.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  138.         Connection con = null;
  139.         PreparedStatement stm = null;
  140.         ResultSet rs = null;

  142.         FiltroRicercaFruizioniServizio filtroFruizioni = null;
  143.         if(filtroRicerca instanceof FiltroRicercaFruizioniServizio){
  144.             filtroFruizioni = (FiltroRicercaFruizioniServizio) filtroRicerca;
  145.         }
  146.         
  147.         this.driver.logDebug(nomeMetodo+" ...");

  149.         try {
  150.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  151.             // prendo la connessione dal pool
  152.             if (this.driver.atomica)
  153.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  154.             else
  155.                 con = this.driver.globalConnection;

  157.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);

  159.             String aliasFruitore = "fruitore";
  160.             String aliasErogatore = "erogatore";
  161.             
  162.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  163.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI,aliasErogatore);
  164.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  165.             
  166.             boolean setFruitore = false;
  167.             if(filtroFruizioni!=null){
  168.                 setFruitore = true;
  169.             }
  170.             if(!setFruitore && filtroRicerca!=null){
  171.                 if(filtroRicerca.getTipoSoggettoFruitore()!=null || filtroRicerca.getNomeSoggettoFruitore()!=null){
  172.                     setFruitore = true;
  173.                 }
  174.             }
  175.             if(setFruitore){
  176.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI,aliasFruitore);
  177.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  178.             }

  180.             String aliasTipoSoggettoErogatore = "tipo_soggetto_erogatore";
  181.             String aliasNomeSoggettoErogatore = "nome_soggetto_erogatore";
  182.             sqlQueryObject.addSelectAliasField(aliasErogatore, "tipo_soggetto", aliasTipoSoggettoErogatore);
  183.             sqlQueryObject.addSelectAliasField(aliasErogatore, "nome_soggetto", aliasNomeSoggettoErogatore);
  184.             sqlQueryObject.addSelectField("tipo_servizio");
  185.             sqlQueryObject.addSelectField("nome_servizio");
  186.             sqlQueryObject.addSelectField("versione_servizio");
  187.             sqlQueryObject.addSelectField("id_referente");
  188.             sqlQueryObject.addSelectField("nome");
  189.             sqlQueryObject.addSelectField("versione");
  190.             sqlQueryObject.addSelectField("servizio_correlato");
  191.             String aliasTipoSoggettoFruitore = "tipo_soggetto_fruitore";
  192.             String aliasNomeSoggettoFruitore = "nome_soggetto_fruitore";
  193.             if(setFruitore){
  194.                 sqlQueryObject.addSelectAliasField(aliasFruitore, "tipo_soggetto", aliasTipoSoggettoFruitore);
  195.                 sqlQueryObject.addSelectAliasField(aliasFruitore, "nome_soggetto", aliasNomeSoggettoFruitore);
  196.             }
  197.             sqlQueryObject.setSelectDistinct(true);
  198.             
  199.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto = "+aliasErogatore+".id");
  200.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo = "+CostantiDB.ACCORDI+".id");

  202.             if(setFruitore){
  203.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_servizio = "+CostantiDB.SERVIZI+".id");
  204.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_soggetto = "+aliasFruitore+".id");
  205.             }

  207.             if(filtroRicerca!=null){
  208.                 // Filtro By Data
  209.                 if(filtroRicerca.getMinDate()!=null)
  210.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".ora_registrazione > ?");
  211.                 if(filtroRicerca.getMaxDate()!=null)
  212.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".ora_registrazione < ?");
  213.                 if(filtroRicerca.getTipo()!=null)
  214.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".tipo_servizio = ?");
  215.                 if(filtroRicerca.getNome()!=null)
  216.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".nome_servizio = ?");
  217.                 if(filtroRicerca.getVersione()!=null)
  218.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".versione_servizio = ?");
  219.                 if(filtroRicerca.getPortType()!=null)
  220.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".port_type = ?");
  221.                 if(filtroRicerca.getTipologia()!=null)
  222.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".servizio_correlato = ?");
  223.                 if(filtroRicerca.getTipoSoggettoErogatore()!=null)
  224.                     sqlQueryObject.addWhereCondition(aliasErogatore+".tipo_soggetto = ?");
  225.                 if(filtroRicerca.getNomeSoggettoErogatore()!=null)
  226.                     sqlQueryObject.addWhereCondition(aliasErogatore+".nome_soggetto = ?");
  227.                 if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  228.                     IDAccordo idAccordo = filtroRicerca.getIdAccordoServizioParteComune();
  229.                     if(idAccordo.getNome()!=null){
  230.                         sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".nome = ?");
  231.                     }
  232.                     if(idAccordo.getSoggettoReferente()!=null){
  233.                         sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente = ?");
  234.                     }
  235.                     if(idAccordo.getVersione()!=null){
  236.                         sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".versione = ?");
  237.                     }
  238.                 }
  239.                 if(filtroRicerca.getTipoSoggettoFruitore()!=null)
  240.                     sqlQueryObject.addWhereCondition(aliasFruitore+".tipo_soggetto = ?");
  241.                 if(filtroRicerca.getNomeSoggettoFruitore()!=null)
  242.                     sqlQueryObject.addWhereCondition(aliasFruitore+".nome_soggetto = ?");
  243.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroRicerca, CostantiDB.SERVIZI);
  244.             }
  245.             
  246.             if(filtroFruizioni!=null){
  247.                 if(filtroFruizioni.getTipoSoggettoFruitore()!=null)
  248.                     sqlQueryObject.addWhereCondition(aliasFruitore+".tipo_soggetto = ?");
  249.                 if(filtroFruizioni.getNomeSoggettoFruitore()!=null)
  250.                     sqlQueryObject.addWhereCondition(aliasFruitore+".nome_soggetto = ?");
  251.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroFruizioni, CostantiDB.SERVIZI_FRUITORI);
  252.             }

  254.             sqlQueryObject.setSelectDistinct(true);
  255.             sqlQueryObject.setANDLogicOperator(true);
  256.             String sqlQuery = sqlQueryObject.createSQLQuery();
  257.             this.driver.logDebug("eseguo query : " + sqlQuery );
  258.             stm = con.prepareStatement(sqlQuery);
  259.             int indexStmt = 1;
  260.             if(filtroRicerca!=null){
  261.                 if(filtroRicerca.getMinDate()!=null){
  262.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  263.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  264.                     indexStmt++;
  265.                 }
  266.                 if(filtroRicerca.getMaxDate()!=null){
  267.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  268.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  269.                     indexStmt++;
  270.                 }   
  271.                 if(filtroRicerca.getTipo()!=null){
  272.                     this.driver.logDebug("tipoServizio stmt.setString("+filtroRicerca.getTipo()+")");
  273.                     stm.setString(indexStmt, filtroRicerca.getTipo());
  274.                     indexStmt++;
  275.                 }
  276.                 if(filtroRicerca.getNome()!=null){
  277.                     this.driver.logDebug("nomeServizio stmt.setString("+filtroRicerca.getNome()+")");
  278.                     stm.setString(indexStmt, filtroRicerca.getNome());
  279.                     indexStmt++;
  280.                 }
  281.                 if(filtroRicerca.getVersione()!=null){
  282.                     this.driver.logDebug("versioneServizio stmt.setString("+filtroRicerca.getVersione()+")");
  283.                     stm.setInt(indexStmt, filtroRicerca.getVersione());
  284.                     indexStmt++;
  285.                 }
  286.                 if(filtroRicerca.getPortType()!=null){
  287.                     this.driver.logDebug("portType stmt.setString("+filtroRicerca.getPortType()+")");
  288.                     stm.setString(indexStmt, filtroRicerca.getPortType());
  289.                     indexStmt++;
  290.                 }
  291.                 if(filtroRicerca.getTipologia()!=null){
  292.                     StatoFunzionalita servizioCorrelato = (org.openspcoop2.core.constants.TipologiaServizio.CORRELATO.equals(filtroRicerca.getTipologia()) ? CostantiRegistroServizi.ABILITATO : CostantiRegistroServizi.DISABILITATO);
  293.                     this.driver.logDebug("tipologiaServizio stmt.setString("+servizioCorrelato.getValue()+") original:["+filtroRicerca.getTipologia()+"]");
  294.                     stm.setString(indexStmt, servizioCorrelato.getValue());
  295.                     indexStmt++;
  296.                 }
  297.                 if(filtroRicerca.getTipologia()!=null){
  298.                     if(org.openspcoop2.core.constants.TipologiaServizio.CORRELATO.equals(filtroRicerca.getTipologia())){
  299.                         this.driver.logDebug("tipologiaServizio stmt.setString("+CostantiRegistroServizi.ABILITATO.toString()+")");
  300.                         stm.setString(indexStmt, CostantiRegistroServizi.ABILITATO.toString());
  301.                     }
  302.                     else{
  303.                         this.driver.logDebug("tipologiaServizio stmt.setString("+CostantiRegistroServizi.DISABILITATO.toString()+")");
  304.                         stm.setString(indexStmt, CostantiRegistroServizi.DISABILITATO.toString());
  305.                     }
  306.                     indexStmt++;
  307.                 }
  308.                 if(filtroRicerca.getTipoSoggettoErogatore()!=null){
  309.                     this.driver.logDebug("tipoSoggettoErogatore stmt.setString("+filtroRicerca.getTipoSoggettoErogatore()+")");
  310.                     stm.setString(indexStmt, filtroRicerca.getTipoSoggettoErogatore());
  311.                     indexStmt++;
  312.                 }
  313.                 if(filtroRicerca.getNomeSoggettoErogatore()!=null){
  314.                     this.driver.logDebug("nomeSoggettoErogatore stmt.setString("+filtroRicerca.getNomeSoggettoErogatore()+")");
  315.                     stm.setString(indexStmt, filtroRicerca.getNomeSoggettoErogatore());
  316.                     indexStmt++;
  317.                 }
  318.                 if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  319.                     IDAccordo idAccordo = filtroRicerca.getIdAccordoServizioParteComune();
  320.                     if(idAccordo.getNome()!=null){
  321.                         this.driver.logDebug("nomeAccordo stmt.setString("+idAccordo.getNome()+")");
  322.                         stm.setString(indexStmt, idAccordo.getNome());
  323.                         indexStmt++;
  324.                     }
  325.                     if(idAccordo.getSoggettoReferente()!=null){
  326.                         long idSoggettoReferente = DBUtils.getIdSoggetto(idAccordo.getSoggettoReferente().getNome(), idAccordo.getSoggettoReferente().getTipo(), con, this.driver.tipoDB,this.driver.tabellaSoggetti);
  327.                         if(idSoggettoReferente<=0){
  328.                             throw new Exception("Soggetto referente ["+idAccordo.getSoggettoReferente().toString()+"] non trovato");
  329.                         }
  330.                         this.driver.logDebug("idReferenteAccordi stmt.setLong("+idSoggettoReferente+")");
  331.                         stm.setLong(indexStmt, idSoggettoReferente);
  332.                         indexStmt++;
  333.                     }
  334.                     if(idAccordo.getVersione()!=null){
  335.                         this.driver.logDebug("versioneAccordo stmt.setString("+idAccordo.getVersione()+")");
  336.                         stm.setInt(indexStmt, idAccordo.getVersione());
  337.                         indexStmt++;
  338.                     }
  339.                 }
  340.                 if(filtroRicerca.getTipoSoggettoFruitore()!=null){
  341.                     this.driver.logDebug("tipoSoggettoFruitore stmt.setString("+filtroRicerca.getTipoSoggettoFruitore()+")");
  342.                     stm.setString(indexStmt, filtroRicerca.getTipoSoggettoFruitore());
  343.                     indexStmt++;
  344.                 }
  345.                 if(filtroRicerca.getNomeSoggettoFruitore()!=null){
  346.                     this.driver.logDebug("nomeSoggettoFruitore stmt.setString("+filtroRicerca.getNomeSoggettoFruitore()+")");
  347.                     stm.setString(indexStmt, filtroRicerca.getNomeSoggettoFruitore());
  348.                     indexStmt++;
  349.                 }
  350.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroRicerca, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_SPECIFICA);
  351.             }
  352.             
  353.             if(filtroFruizioni!=null){
  354.                 if(filtroFruizioni.getTipoSoggettoFruitore()!=null){
  355.                     this.driver.logDebug("tipoSoggettoFruitore stmt.setString("+filtroFruizioni.getTipoSoggettoFruitore()+")");
  356.                     stm.setString(indexStmt, filtroFruizioni.getTipoSoggettoFruitore());
  357.                     indexStmt++;
  358.                 }
  359.                 if(filtroFruizioni.getNomeSoggettoFruitore()!=null){
  360.                     this.driver.logDebug("nomeSoggettoFruitore stmt.setString("+filtroFruizioni.getNomeSoggettoFruitore()+")");
  361.                     stm.setString(indexStmt, filtroFruizioni.getNomeSoggettoFruitore());
  362.                     indexStmt++;
  363.                 }
  364.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroFruizioni, ProprietariProtocolProperty.FRUITORE);
  365.             }
  366.             
  367.             rs = stm.executeQuery();
  368.             while (rs.next()) {
  369.                 IDSoggetto idSoggettoErogatore = new IDSoggetto(rs.getString(aliasTipoSoggettoErogatore),rs.getString(aliasNomeSoggettoErogatore));
  370.                 IDServizio idServ = this.driver.idServizioFactory.getIDServizioFromValues(rs.getString("tipo_servizio"),rs.getString("nome_servizio"), 
  371.                         idSoggettoErogatore, rs.getInt("versione_servizio"));

  373.                 // uriAccordoServizio
  374.                 IDSoggetto soggettoReferente = null;
  375.                 long idSoggettoReferente = rs.getLong("id_referente");
  376.                 if(idSoggettoReferente>0){
  377.                     try {
  378.                         soggettoReferente = this.driver.getIdSoggetto(idSoggettoReferente,con);
  379.                         if(soggettoReferente==null){
  380.                             throw new DriverRegistroServiziNotFound ("non esiste");
  381.                         }
  382.                     }catch(DriverRegistroServiziNotFound notFound) {
  383.                         try {
  384.                             throw new Exception ("Soggetto referente ["+idSoggettoReferente+"] dell'accordo non esiste");
  385.                         }finally {
  386.                             try{
  387.                                 if(rs!=null) 
  388.                                     rs.close();
  389.                             }catch (Exception e) {
  390.                                 //ignore
  391.                             }
  392.                             try{
  393.                                 if(stm!=null) 
  394.                                     stm.close();
  395.                             }catch (Exception e) {
  396.                                 //ignore
  397.                             }
  398.                         }
  399.                     }
  400.                 }
  401.                 IDAccordo idAccordo = this.driver.idAccordoFactory.getIDAccordoFromValues(rs.getString("nome"),soggettoReferente,rs.getInt("versione"));
  402.                 idServ.setUriAccordoServizioParteComune(this.driver.idAccordoFactory.getUriFromIDAccordo(idAccordo));

  404.                 String servizioCorrelato = rs.getString("servizio_correlato");
  405.                 if(CostantiRegistroServizi.ABILITATO.toString().equals(servizioCorrelato) || TipologiaServizio.CORRELATO.toString().equals(servizioCorrelato))
  406.                     idServ.setTipologia(org.openspcoop2.core.constants.TipologiaServizio.CORRELATO);
  407.                 else
  408.                     idServ.setTipologia(org.openspcoop2.core.constants.TipologiaServizio.NORMALE);
  409.                 
  410.                 if(filtroFruizioni!=null){
  411.                     IDFruizione idFruizione = new IDFruizione();
  412.                     idFruizione.setIdServizio(idServ);
  413.                     idFruizione.setIdFruitore(new IDSoggetto(rs.getString("tipo_soggetto_fruitore"),rs.getString("nome_soggetto_fruitore")));
  414.                     listReturn.add((T)idFruizione);
  415.                 }
  416.                 else{
  417.                     listReturn.add((T)idServ);
  418.                 }
  419.             }
  420.             if(listReturn.isEmpty()){
  421.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  422.                 if(filtroFruizioni!=null){
  423.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroFruizioni.toString());
  424.                 }
  425.                 else if(filtroRicerca!=null){
  426.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicerca.toString());
  427.                 }
  428.                 else
  429.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  430.             }
  431.         }catch(DriverRegistroServiziNotFound de){
  432.             throw de;
  433.         }
  434.         catch(Exception e){
  435.             throw new DriverRegistroServiziException(nomeMetodo+" error",e);
  436.         } finally {

  438.             //Chiudo statement and resultset
  439.             JDBCUtilities.closeResources(rs, stm);

  441.             this.driver.closeConnection(con);

  443.         }
  444.     }

  446.     protected IDServizio[] getAllIdServiziWithSoggettoErogatore(Long idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  447.         String operazione = "getAllIdServiziWithSoggettoErogatore";

  449.         Connection con = null;
  450.         PreparedStatement stm = null;
  451.         ResultSet rs = null;

  453.         this.driver.logDebug(operazione+"...");

  455.         try {
  456.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  457.             // prendo la connessione dal pool
  458.             if (this.driver.atomica)
  459.                 con = this.driver.getConnectionFromDatasource("getAllIdServiziWithSoggettoErogatore");
  460.             else
  461.                 con = this.driver.globalConnection;

  463.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);

  465.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  466.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);

  468.             sqlQueryObject.addSelectField("*");
  469.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  470.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".id = ?");

  472.             sqlQueryObject.setANDLogicOperator(true);
  473.             String sqlQuery = sqlQueryObject.createSQLQuery();
  474.             this.driver.logDebug("eseguo query : " + sqlQuery );
  475.             stm = con.prepareStatement(sqlQuery);
  476.             stm.setLong(1, idSoggetto);
  477.             rs = stm.executeQuery();
  478.             List<IDServizio> idServizi = new ArrayList<>();
  479.             while (rs.next()) {
  480.                 IDSoggetto idSoggettoErogatore = new IDSoggetto(rs.getString("tipo_soggetto"),rs.getString("nome_soggetto"));
  481.                 IDServizio idServ = this.driver.idServizioFactory.getIDServizioFromValues(rs.getString("tipo_servizio"),rs.getString("nome_servizio"), 
  482.                         idSoggettoErogatore, rs.getInt("versione_servizio"));
  483.                 idServizi.add(idServ);
  484.             }
  485.             if(idServizi.isEmpty()){
  486.                 throw new DriverRegistroServiziNotFound("Servizi non trovati per il soggetto con id: "+idSoggetto);
  487.             }else{
  488.                 IDServizio[] res = new IDServizio[1];
  489.                 return idServizi.toArray(res);
  490.             }
  491.         }catch(DriverRegistroServiziNotFound de){
  492.             throw de;
  493.         }
  494.         catch(Exception e){
  495.             throw new DriverRegistroServiziException(operazione+" error",e);
  496.         } finally {

  498.             //Chiudo statement and resultset
  499.             JDBCUtilities.closeResources(rs, stm);

  501.             this.driver.closeConnection(con);

  503.         }
  504.     }

  506.     protected void createAccordoServizioParteSpecifica(AccordoServizioParteSpecifica accordoServizioParteSpecifica) throws DriverRegistroServiziException {
  507.         if (accordoServizioParteSpecifica == null)
  508.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteSpecifica] Parametro non valido.");

  510.         Connection con = null;
  511.         boolean error = false;

  513.         if (this.driver.atomica) {
  514.             try {
  515.                 con = this.driver.getConnectionFromDatasource("createAccordoServizioParteSpecifica");
  516.                 con.setAutoCommit(false);
  517.             } catch (Exception e) {
  518.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteSpecifica] Exception accedendo al datasource :" + e.getMessage(),e);

  520.             }

  522.         } else
  523.             con = this.driver.globalConnection;

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

  527.         try {
  528.             this.driver.logDebug("CRUDServizio tupe=1");
  529.             // CREATE
  530.             DriverRegistroServiziDB_accordiParteSpecificaLIB.CRUDAccordoServizioParteSpecifica(1, accordoServizioParteSpecifica, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  532.         } catch (Exception qe) {
  533.             error = true;
  534.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteSpecifica] Errore durante la creazione del servizio : " + qe.getMessage(), qe);
  535.         } finally {

  537.             this.driver.closeConnection(error,con);
  538.         }
  539.     }

  541.     protected boolean existsAccordoServizioParteSpecifica(IDServizio idServizio) throws DriverRegistroServiziException {

  543.         if (idServizio == null)
  544.             throw new DriverRegistroServiziException("IDServizio non valido.");

  546.         IDSoggetto erogatore = idServizio.getSoggettoErogatore();
  547.         if (erogatore == null)
  548.             throw new DriverRegistroServiziException("Soggetto Erogatore non valido.");

  550.         String nomeServizio = idServizio.getNome();
  551.         String tipoServizio = idServizio.getTipo();
  552.         Integer versioneServizio = idServizio.getVersione();
  553.         String nomeProprietario = erogatore.getNome();
  554.         String tipoProprietario = erogatore.getTipo();

  556.         Connection con = null;

  558.         if (this.driver.atomica) {
  559.             try {
  560.                 con = this.driver.getConnectionFromDatasource("existsAccordoServizioParteSpecifica");
  561.             } catch (Exception e) {
  562.                 throw new DriverRegistroServiziException("Exception accedendo al datasource :" + e.getMessage(), e);

  564.             }

  566.         } else
  567.             con = this.driver.globalConnection;

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

  571.         try {
  572.             long idS = DBUtils.getIdServizio(nomeServizio, tipoServizio, versioneServizio, nomeProprietario, tipoProprietario, con, false,this.driver.tipoDB);
  573.             return idS > 0;
  574.         } catch (Exception qe) {
  575.             throw new DriverRegistroServiziException("Errore durante existsAccordoServizioParteSpecifica : " + qe.getMessage(), qe);
  576.         } finally {

  578.             this.driver.closeConnection(con);
  579.         }
  580.     }

  582.     protected boolean existsAccordoServizioParteSpecifica(long idServizio) throws DriverRegistroServiziException {
  583.         boolean exist = false;
  584.         Connection con = null;
  585.         PreparedStatement stm = null;
  586.         ResultSet rs = null;
  587.         if (this.driver.atomica) {
  588.             try {
  589.                 con = this.driver.getConnectionFromDatasource("existsAccordoServizioParteSpecifica(longId)");
  590.             } catch (Exception e) {
  591.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsAccordoServizioParteSpecifica] Exception accedendo al datasource :" + e.getMessage(),e);

  593.             }

  595.         } else
  596.             con = this.driver.globalConnection;

  598.         try {
  599.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  600.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  601.             sqlQueryObject.addSelectField("*");
  602.             sqlQueryObject.addWhereCondition("id = ?");
  603.             String sqlQuery = sqlQueryObject.createSQLQuery();
  604.             stm = con.prepareStatement(sqlQuery);
  605.             stm.setLong(1, idServizio);
  606.             rs = stm.executeQuery();
  607.             if (rs.next())
  608.                 exist = true;
  609.             rs.close();
  610.             stm.close();

  612.         } catch (Exception e) {
  613.             exist = false;
  614.             this.driver.log.error("Errore durante verifica esistenza servizio :", e);
  615.         } finally {
  616.             //Chiudo statement and resultset
  617.             JDBCUtilities.closeResources(rs, stm);
  618.             
  619.             this.driver.closeConnection(con);
  620.         }

  622.         return exist;
  623.     }


  626.     protected long getServizioWithSoggettoAccordoServCorr(long idSoggetto, long idAccordo, String servizioCorrelato) throws DriverRegistroServiziException {
  627.         return getEngineServizioWithSoggettoAccordoServCorrPT(idSoggetto, idAccordo, servizioCorrelato, null);
  628.     }

  630.     /**
  631.      * Verifica l'esistenza di un servizio con un certo soggetto e port-type
  632.      * accordo e servizio correlato
  633.      */
  634.     private long getEngineServizioWithSoggettoAccordoServCorrPT(long idSoggetto, long idAccordo, String servizioCorrelato,String portType) throws DriverRegistroServiziException {

  636.         long idServ = 0;
  637.         Connection connection;
  638.         PreparedStatement stm = null;
  639.         ResultSet rs = null;
  640.         if (this.driver.atomica) {
  641.             try {
  642.                 connection = this.driver.getConnectionFromDatasource("getEngineServizioWithSoggettoAccordoServCorrPT");
  643.             } catch (Exception e) {
  644.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getServizioWithSoggettoAccordoServCorr] Exception accedendo al datasource :" + e.getMessage(),e);

  646.             }

  648.         } else
  649.             connection = this.driver.globalConnection;

  651.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  652.         try {
  653.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  654.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  655.             sqlQueryObject.addSelectField("*");
  656.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  657.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  658.             sqlQueryObject.addWhereCondition("servizio_correlato = ?");

  660.             if(portType!=null) sqlQueryObject.addWhereCondition("port_type = ?");
  661.             else sqlQueryObject.addWhereCondition("port_type is null");

  663.             sqlQueryObject.setANDLogicOperator(true);
  664.             String sqlQuery = sqlQueryObject.createSQLQuery();
  665.             stm = connection.prepareStatement(sqlQuery);
  666.             stm.setLong(1, idSoggetto);
  667.             stm.setLong(2, idAccordo);
  668.             stm.setString(3, servizioCorrelato);
  669.             if(portType!=null) stm.setString(4, portType);
  670.             rs = stm.executeQuery();
  671.             if (rs.next())
  672.                 idServ = rs.getLong("id");
  673.             rs.close();
  674.             stm.close();
  675.         } catch (Exception e) {
  676.             throw new DriverRegistroServiziException(e.getMessage(),e);
  677.         } finally {

  679.             //Chiudo statement and resultset
  680.             JDBCUtilities.closeResources(rs, stm);

  682.             this.driver.closeConnection(connection);
  683.         }

  685.         return idServ;
  686.     }

  688.     protected long getServizioWithSoggettoAccordoServCorrPt(long idSoggetto, long idAccordo, String servizioCorrelato,String portType) throws DriverRegistroServiziException {
  689.         return getEngineServizioWithSoggettoAccordoServCorrPT(idSoggetto, idAccordo, servizioCorrelato, portType);
  690.     }

  692.     

  694.     protected void updateAccordoServizioParteSpecifica(AccordoServizioParteSpecifica servizio) throws DriverRegistroServiziException {
  695.         if (servizio == null)
  696.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizioParteSpecifica] Parametro non valido.");
  697.         Connection con = null;
  698.         boolean error = false;

  700.         if (this.driver.atomica) {
  701.             try {
  702.                 con = this.driver.getConnectionFromDatasource("updateAccordoServizioParteSpecifica");
  703.                 con.setAutoCommit(false);
  704.             } catch (Exception e) {
  705.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizioParteSpecifica] Exception accedendo al datasource :" + e.getMessage(),e);

  707.             }

  709.         } else
  710.             con = this.driver.globalConnection;

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

  714.         try {

  716.             // UPDATE
  717.             DriverRegistroServiziDB_accordiParteSpecificaLIB.CRUDAccordoServizioParteSpecifica(2, servizio, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  719.         } catch (Exception qe) {
  720.             error = true;
  721.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizioParteSpecifica] Errore durante l'update del servizio : " + qe.getMessage(),qe);
  722.         } finally {

  724.             this.driver.closeConnection(error,con);
  725.         }
  726.     }

  728.     protected void deleteAccordoServizioParteSpecifica(AccordoServizioParteSpecifica servizio) throws DriverRegistroServiziException {
  729.         if (servizio == null)
  730.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizioParteSpecifica] Parametro non valido.");

  732.         Connection con = null;
  733.         boolean error = false;

  735.         if (this.driver.atomica) {
  736.             try {
  737.                 con = this.driver.getConnectionFromDatasource("deleteAccordoServizioParteSpecifica");
  738.                 con.setAutoCommit(false);
  739.             } catch (Exception e) {
  740.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizioParteSpecifica] Exception accedendo al datasource :" + e.getMessage(),e);

  742.             }

  744.         } else
  745.             con = this.driver.globalConnection;

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

  749.         try {
  750.             this.driver.logDebug("CRUDServizio type = 3");
  751.             // creo soggetto
  752.             DriverRegistroServiziDB_accordiParteSpecificaLIB.CRUDAccordoServizioParteSpecifica(3, servizio, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  754.         } catch (Exception qe) {
  755.             error = true;
  756.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizioParteSpecifica] Errore durante la delete del servizio : " + qe.getMessage(),qe);
  757.         } finally {

  759.             this.driver.closeConnection(error,con);
  760.         }
  761.     }

  763.     protected boolean existsSoggettoServiziWithoutConnettore(long idSoggetto) throws DriverRegistroServiziException {
  764.         if (idSoggetto <= 0)
  765.             throw new DriverRegistroServiziException("idSoggetto non valido.");

  767.         Connection con = null;
  768.         PreparedStatement stm = null;
  769.         ResultSet rs = null;
  770.         boolean trovatoServ = false;

  772.         if (this.driver.atomica) {
  773.             try {
  774.                 con = this.driver.getConnectionFromDatasource("existsSoggettoServiziWithoutConnettore");
  775.             } catch (Exception e) {
  776.                 throw new DriverRegistroServiziException("Exception accedendo al datasource :" + e.getMessage(), e);

  778.             }

  780.         } else
  781.             con = this.driver.globalConnection;

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

  785.         try {
  786.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  787.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  788.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI);
  789.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  790.             sqlQueryObject.addSelectField("*");
  791.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id_connettore = " + CostantiDB.CONNETTORI + ".id");
  792.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  793.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  794.             sqlQueryObject.addWhereCondition("endpointtype = ?");
  795.             sqlQueryObject.setANDLogicOperator(true);
  796.             String sqlQuery = sqlQueryObject.createSQLQuery();
  797.             stm = con.prepareStatement(sqlQuery);
  798.             stm.setLong(1, idSoggetto);
  799.             stm.setString(2, DriverRegistroServiziDB_LIB.getValue(CostantiRegistroServizi.DISABILITATO));
  800.             rs = stm.executeQuery();
  801.             if (rs.next())
  802.                 trovatoServ = true;

  804.             return trovatoServ;
  805.         } catch (Exception qe) {
  806.             throw new DriverRegistroServiziException("Errore durante existsSoggettoServiziWithoutConnettore: " + qe.getMessage(), qe);
  807.         } finally {

  809.             //Chiudo statement and resultset
  810.             JDBCUtilities.closeResources(rs, stm);
  811.             
  812.             this.driver.closeConnection(con);
  813.         }
  814.     }
  815.     
  816.     
  817.     
  818.     private AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio, 
  819.             IDSoggetto idSoggetto, IDAccordo idAccordoServizioParteComune,
  820.             boolean readContenutoAllegati,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {

  822.         AccordoServizioParteSpecifica accordoServizioParteSpecifica = null;

  824.         Connection con = null;
  825.         PreparedStatement stm = null;
  826.         ResultSet rs = null;
  827.         PreparedStatement stm1 = null;
  828.         ResultSet rs1 = null;

  830.         if(idServizio!=null){
  831.             this.driver.logDebug("chiamato getAccordoServizioParteSpecifica (IDServizio)");
  832.             // in questi casi idService non deve essere null
  833.             // faccio i controlli vari
  834.             if (idServizio == null || idServizio.getNome() == null || idServizio.getNome().trim().equals("") || 
  835.                 idServizio.getTipo() == null || idServizio.getTipo().trim().equals("") || 
  836.                 idServizio.getVersione() == null ||
  837.                 idServizio.getSoggettoErogatore() == null || idServizio.getSoggettoErogatore().getNome() == null || idServizio.getSoggettoErogatore().getNome().trim().equals("") || idServizio.getSoggettoErogatore().getTipo() == null || idServizio.getSoggettoErogatore().getTipo().trim().equals(""))
  838.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] : errore nei parametri d'ingresso (IDServizio)");
  839.         }
  840.         else{
  841.             this.driver.logDebug("chiamato getAccordoServizioParteSpecifica (IDSoggetto e IDAccordo)");
  842.             // in questo caso idSoggetto non deve essere null e anche
  843.             // nomeAccordo
  844.             if (idAccordoServizioParteComune == null || idAccordoServizioParteComune.getNome()==null || idAccordoServizioParteComune.getNome().trim().equals("") || idSoggetto == null || idSoggetto.getNome() == null || idSoggetto.getNome().trim().equals("") || idSoggetto.getTipo() == null || idSoggetto.getTipo().trim().equals(""))
  845.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] : errore nei parametri d'ingresso (IDSoggetto e IDAccordo)");
  846.         
  847.         }

  849.         if(conParam!=null){
  850.             con = conParam;
  851.         }
  852.         else if (this.driver.atomica) {
  853.             try {
  854.                 con = this.driver.getConnectionFromDatasource("getAccordoServizioParteSpecifica");
  855.             } catch (Exception e) {
  856.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] Exception accedendo al datasource :" + e.getMessage(),e);

  858.             }

  860.         } else
  861.             con = this.driver.globalConnection;

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

  865.         try {

  867.             accordoServizioParteSpecifica = new AccordoServizioParteSpecifica();


  870.             String nomeSoggEr = null;
  871.             String tipoSoggEr = null;
  872.             long longIdAccordoServizioParteComune = 0;
  873.             String nomeServizio = null;
  874.             String tipoServizio = null;
  875.             Integer versioneServizio = null;
  876.             String superUser = null;
  877.             long idSoggErogatore = 0;
  878.             long longIdAccordoServizioParteSpecifica = 0;


  881.             // se tipo 1 utilizzo idServio per recuperare qualche parametro
  882.             if(idServizio!=null){
  883.                 nomeServizio = idServizio.getNome();
  884.                 tipoServizio = idServizio.getTipo();
  885.                 versioneServizio = idServizio.getVersione();

  887.                 // nome e tipo soggetto erogatore
  888.                 nomeSoggEr = idServizio.getSoggettoErogatore().getNome();
  889.                 tipoSoggEr = idServizio.getSoggettoErogatore().getTipo();

  891.                 // Prendo l'id del soggetto

  893.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  894.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  895.                 sqlQueryObject.addSelectField("*");
  896.                 sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  897.                 sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  898.                 sqlQueryObject.setANDLogicOperator(true);
  899.                 String sqlQuery = sqlQueryObject.createSQLQuery();
  900.                 stm = con.prepareStatement(sqlQuery);
  901.                 stm.setString(1, nomeSoggEr);
  902.                 stm.setString(2, tipoSoggEr);

  904.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, nomeSoggEr, tipoSoggEr));

  906.                 rs = stm.executeQuery();
  907.                 if (rs.next()) {
  908.                     idSoggErogatore = rs.getLong("id");
  909.                 }
  910.                 rs.close();
  911.                 stm.close();
  912.             }

  914.             else{

  916.                 // In questo caso non ho IDService ma IDSoggetto
  917.                 // quindi prendo il nome del soggetto erogatore e il tipo da
  918.                 // idSoggetto
  919.                 nomeSoggEr = idSoggetto.getNome();
  920.                 tipoSoggEr = idSoggetto.getTipo();

  922.                 // per settare il nome del servizio devo accedere al db
  923.                 // tramite id del soggetto erogatore e id dell-accordo (che lo
  924.                 // recupero tramite il nomeAccordo passato come parametro)
  925.                 longIdAccordoServizioParteComune = DBUtils.getIdAccordoServizioParteComune(idAccordoServizioParteComune, con, this.driver.tipoDB);

  927.                 // Prendo l'id del soggetto
  928.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  929.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  930.                 sqlQueryObject.addSelectField("*");
  931.                 sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  932.                 sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  933.                 sqlQueryObject.setANDLogicOperator(true);
  934.                 String sqlQuery = sqlQueryObject.createSQLQuery();
  935.                 stm = con.prepareStatement(sqlQuery);
  936.                 stm.setString(1, nomeSoggEr);
  937.                 stm.setString(2, tipoSoggEr);

  939.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, nomeSoggEr, tipoSoggEr));
  940.                 rs = stm.executeQuery();
  941.                 if (rs.next()) {
  942.                     idSoggErogatore = rs.getLong("id");
  943.                 }
  944.                 rs.close();
  945.                 stm.close();

  947.                 // ora che ho l'id recupero nome-servizio e tipo-servizio dalla
  948.                 // tabella
  949.                 // regserv_servizi acceduta tramite id-soggetto e id-accordo
  950.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  951.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  952.                 sqlQueryObject.addSelectField("*");
  953.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  954.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  955.                 sqlQueryObject.addWhereCondition("servizio_correlato = ?");
  956.                 sqlQueryObject.setANDLogicOperator(true);
  957.                 sqlQuery = sqlQueryObject.createSQLQuery();
  958.                 stm = con.prepareStatement(sqlQuery);
  959.                 stm.setLong(1, idSoggErogatore);
  960.                 stm.setLong(2, longIdAccordoServizioParteComune);
  961.                 stm.setString(3, DriverRegistroServiziDB_LIB.getValue(CostantiRegistroServizi.ABILITATO));
  962.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggErogatore, longIdAccordoServizioParteComune, CostantiRegistroServizi.ABILITATO));
  963.                 rs = stm.executeQuery();
  964.                 if (rs.next()) {
  965.                     nomeServizio = rs.getString("nome_servizio");
  966.                     tipoServizio = rs.getString("tipo_servizio");
  967.                     versioneServizio = rs.getInt("versione_servizio");
  968.                     superUser = rs.getString("superuser");

  970.                 }
  971.                 rs.close();
  972.                 stm.close();
  973.             }

  975.             // Prendo l'id del servizio
  976.             long idConnettore = 0;
  977.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  978.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  979.             sqlQueryObject.addSelectField("*");
  980.             sqlQueryObject.addWhereCondition("nome_servizio = ?");
  981.             sqlQueryObject.addWhereCondition("tipo_servizio = ?");
  982.             sqlQueryObject.addWhereCondition("versione_servizio = ?");
  983.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  984.             sqlQueryObject.setANDLogicOperator(true);
  985.             String sqlQuery = sqlQueryObject.createSQLQuery();
  986.             stm = con.prepareStatement(sqlQuery);
  987.             stm.setString(1, nomeServizio);
  988.             stm.setString(2, tipoServizio);
  989.             if(versioneServizio!=null) {
  990.                 stm.setInt(3, versioneServizio);
  991.             }
  992.             else {
  993.                 stm.setInt(3, 1); // default
  994.             }
  995.             stm.setLong(4, idSoggErogatore);

  997.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, nomeServizio, tipoServizio, versioneServizio, idSoggErogatore));
  998.             rs = stm.executeQuery();
  999.             if (rs.next()) {
  1000.                 longIdAccordoServizioParteSpecifica = rs.getLong("id");
  1001.                 idConnettore = rs.getLong("id_connettore");
  1002.                 longIdAccordoServizioParteComune = rs.getLong("id_accordo");
  1003.                 superUser = rs.getString("superuser");
  1004.                 accordoServizioParteSpecifica.setId(longIdAccordoServizioParteSpecifica);
  1005.                 accordoServizioParteSpecifica.setIdAccordo(longIdAccordoServizioParteComune);

  1007.                 // setNome servizio
  1008.                 accordoServizioParteSpecifica.setNome(rs.getString("nome_servizio"));
  1009.                 // setTipo servizio
  1010.                 accordoServizioParteSpecifica.setTipo(rs.getString("tipo_servizio"));
  1011.                 // versione
  1012.                 accordoServizioParteSpecifica.setVersione(rs.getInt("versione_servizio"));

  1014.                 accordoServizioParteSpecifica.setConfigurazioneServizio(new ConfigurazioneServizio());
  1015.                 
  1016.                 //setto connettore
  1017.                 accordoServizioParteSpecifica.getConfigurazioneServizio().setConnettore(this.driver.getConnettore(idConnettore, con));
  1018.                 // setWsdlImplementativoErogatore
  1019.                 String wsdlimpler = rs.getString("wsdl_implementativo_erogatore");
  1020.                 accordoServizioParteSpecifica.setByteWsdlImplementativoErogatore((wsdlimpler != null && !wsdlimpler.trim().equals("")) ? wsdlimpler.trim().getBytes() : null);
  1021.                 // setWddlImplementativoFruitore
  1022.                 String wsdlimplfru = rs.getString("wsdl_implementativo_fruitore");
  1023.                 accordoServizioParteSpecifica.setByteWsdlImplementativoFruitore((wsdlimplfru != null && !wsdlimplfru.trim().equals("")) ? wsdlimplfru.trim().getBytes() : null);

  1025.                 // Setto informazione sul servizio correlato
  1026.                 String servizioCorrelato = rs.getString("servizio_correlato");
  1027.                 if(CostantiRegistroServizi.ABILITATO.toString().equals(servizioCorrelato) || TipologiaServizio.CORRELATO.toString().equals(servizioCorrelato))
  1028.                     accordoServizioParteSpecifica.setTipologiaServizio(TipologiaServizio.CORRELATO);
  1029.                 else
  1030.                     accordoServizioParteSpecifica.setTipologiaServizio(TipologiaServizio.NORMALE);

  1032.                 //setto erogatore servizio
  1033.                 accordoServizioParteSpecifica.setTipoSoggettoErogatore(tipoSoggEr);
  1034.                 accordoServizioParteSpecifica.setNomeSoggettoErogatore(nomeSoggEr);
  1035.                 accordoServizioParteSpecifica.setIdSoggetto(idSoggErogatore);

  1037.                 if(rs.getInt("privato")==CostantiDB.TRUE)
  1038.                     accordoServizioParteSpecifica.setPrivato(true);
  1039.                 else
  1040.                     accordoServizioParteSpecifica.setPrivato(false);

  1042.                 // Ora Registrazione
  1043.                 if(rs.getTimestamp("ora_registrazione")!=null){
  1044.                     accordoServizioParteSpecifica.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  1045.                 }

  1047.                 // porttype
  1048.                 String tmp = rs.getString("port_type");
  1049.                 if(tmp!=null && (!"".equals(tmp)))
  1050.                     accordoServizioParteSpecifica.setPortType(tmp);

  1052.                 // Profilo 
  1053.                 String profilo = rs.getString("profilo");
  1054.                 if(profilo!=null){
  1055.                     profilo = profilo.trim();
  1056.                     accordoServizioParteSpecifica.setVersioneProtocollo(profilo);
  1057.                 }

  1059.                 accordoServizioParteSpecifica.setSuperUser(superUser);

  1061.                 // Descrizione
  1062.                 accordoServizioParteSpecifica.setDescrizione(rs.getString("descrizione"));

  1064.                 // Stato Documento
  1065.                 accordoServizioParteSpecifica.setStatoPackage(rs.getString("stato"));

  1067.                 // MessageType
  1068.                 tmp = rs.getString("message_type");
  1069.                 accordoServizioParteSpecifica.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  1070.                 
  1071.                 // Proprieta Oggetto
  1072.                 accordoServizioParteSpecifica.setProprietaOggetto(DriverRegistroServiziDB_utilsDriver.readProprietaOggetto(rs,false));
  1073.                 
  1074.             }else{
  1075.                 throw new DriverRegistroServiziNotFound("Servizio ["+tipoServizio+"/"+nomeServizio+":"+versioneServizio+"] erogato dal soggetto ["+tipoSoggEr+"/"+nomeSoggEr+"] non esiste");
  1076.             }
  1077.             rs.close();
  1078.             stm.close();
  1079.             long idSoggFruitore = 0;
  1080.             Fruitore fruitore = null;

  1082.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1083.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  1084.             sqlQueryObject.addSelectField("*");
  1085.             sqlQueryObject.addWhereCondition("id_servizio = ?");
  1086.             sqlQuery = sqlQueryObject.createSQLQuery();
  1087.             stm = con.prepareStatement(sqlQuery);
  1088.             stm.setLong(1, longIdAccordoServizioParteSpecifica);

  1090.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, longIdAccordoServizioParteSpecifica));
  1091.             rs = stm.executeQuery();

  1093.             while (rs.next()) {
  1094.                 fruitore = new Fruitore();

  1096.                 idSoggFruitore = rs.getLong("id_soggetto"); // recupero id del
  1097.                 // soggetto fruitore
  1098.                 // del servizio
  1099.                 idConnettore = rs.getLong("id_connettore"); // recuper id del
  1100.                 // connettore

  1102.                 fruitore.setConnettore(this.driver.getConnettore(idConnettore, con));

  1104.                 String wsdlimpler = rs.getString("wsdl_implementativo_erogatore");
  1105.                 fruitore.setByteWsdlImplementativoErogatore(wsdlimpler!=null && !wsdlimpler.trim().equals("") ? wsdlimpler.getBytes() : null );
  1106.                 String wsdlimplfru = rs.getString("wsdl_implementativo_fruitore");
  1107.                 fruitore.setByteWsdlImplementativoFruitore(wsdlimplfru!=null && !wsdlimplfru.trim().equals("") ? wsdlimplfru.getBytes() : null);

  1109.                 // Ora Registrazione
  1110.                 if(rs.getTimestamp("ora_registrazione")!=null){
  1111.                     fruitore.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  1112.                 }

  1114.                 // Stato Documento
  1115.                 fruitore.setStatoPackage(rs.getString("stato"));

  1117.                 // Descrizione
  1118.                 fruitore.setDescrizione(rs.getString("descrizione"));
  1119.                 
  1120.                 // Proprieta Oggetto
  1121.                 fruitore.setProprietaOggetto(DriverRegistroServiziDB_utilsDriver.readProprietaOggetto(rs,false));
  1122.                 
  1123.                 // recupero informazioni del soggetto fruitore
  1124.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1125.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1126.                 sqlQueryObject.addSelectField("*");
  1127.                 sqlQueryObject.addWhereCondition("id = ?");
  1128.                 sqlQuery = sqlQueryObject.createSQLQuery();
  1129.                 stm1 = con.prepareStatement(sqlQuery);
  1130.                 stm1.setLong(1, idSoggFruitore);
  1131.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggFruitore));
  1132.                 rs1 = stm1.executeQuery();

  1134.                 if (rs1.next()) {
  1135.                     fruitore.setNome(rs1.getString("nome_soggetto"));
  1136.                     fruitore.setTipo(rs1.getString("tipo_soggetto"));
  1137.                 } else {
  1138.                     throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] Non ho trovato i dati del soggetto fruitore necessario eseguendo: \n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggFruitore));
  1139.                 }
  1140.                 rs1.close();
  1141.                 stm1.close();

  1143.                 // aggiungo il fruitore al servizio da restituire
  1144.                 fruitore.setId(rs.getLong("id"));
  1145.                 
  1146.                 
  1147.                 // Protocol Properties
  1148.                 try{
  1149.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(fruitore.getId(), ProprietariProtocolProperty.FRUITORE, con, 
  1150.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  1151.                     if(listPP!=null && !listPP.isEmpty()){
  1152.                         for (ProtocolProperty protocolProperty : listPP) {
  1153.                             fruitore.addProtocolProperty(protocolProperty);
  1154.                         }
  1155.                     }
  1156.                 }catch(DriverRegistroServiziNotFound dNotFound){
  1157.                     // ignore
  1158.                 }
  1159.                 
  1160.                 
  1161.                 accordoServizioParteSpecifica.addFruitore(fruitore);

  1163.             }
  1164.             rs.close();
  1165.             stm.close();
  1166.             
  1167.             if(accordoServizioParteSpecifica.sizeFruitoreList()>0) {
  1168.                 for (Fruitore fruitoreLetto : accordoServizioParteSpecifica.getFruitoreList()) {
  1169.                     
  1170.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1171.                     sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI_AZIONI);
  1172.                     sqlQueryObject.addSelectField("*");
  1173.                     sqlQueryObject.addWhereCondition("id_fruizione = ?");
  1174.                     sqlQuery = sqlQueryObject.createSQLQuery();
  1175.                     stm = con.prepareStatement(sqlQuery);
  1176.                     stm.setLong(1, fruitoreLetto.getId());

  1178.                     this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, fruitoreLetto.getId()));
  1179.                     rs = stm.executeQuery();

  1181.                     while (rs.next()) {
  1182.                         ConfigurazioneServizioAzione conf = new ConfigurazioneServizioAzione();

  1184.                         idConnettore = rs.getLong("id_connettore"); // recuper id del
  1185.                         // connettore
  1186.                         conf.setConnettore(this.driver.getConnettore(idConnettore, con));

  1188.                         // aggiungo il fruitore al servizio da restituire
  1189.                         conf.setId(rs.getLong("id"));
  1190.                         fruitoreLetto.addConfigurazioneAzione(conf);

  1192.                     }
  1193.                     rs.close();
  1194.                     stm.close();
  1195.                     
  1196.                     
  1197.                     if(fruitoreLetto.sizeConfigurazioneAzioneList()>0) {
  1198.                         for (ConfigurazioneServizioAzione conf : fruitoreLetto.getConfigurazioneAzioneList()) {
  1199.                             
  1200.                             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1201.                             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI_AZIONE);
  1202.                             sqlQueryObject.addSelectField("*");
  1203.                             sqlQueryObject.addWhereCondition("id_fruizione_azioni = ?");
  1204.                             sqlQuery = sqlQueryObject.createSQLQuery();
  1205.                             stm = con.prepareStatement(sqlQuery);
  1206.                             stm.setLong(1, conf.getId());

  1208.                             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, conf.getId()));
  1209.                             rs = stm.executeQuery();

  1211.                             while (rs.next()) {
  1212.                                 
  1213.                                 conf.addAzione(rs.getString("nome_azione"));

  1215.                             }
  1216.                             rs.close();
  1217.                             stm.close();
  1218.                             
  1219.                         }
  1220.                     }
  1221.                 }
  1222.             }


  1225.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1226.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_AZIONI);
  1227.             sqlQueryObject.addSelectField("*");
  1228.             sqlQueryObject.addWhereCondition("id_servizio = ?");
  1229.             sqlQuery = sqlQueryObject.createSQLQuery();
  1230.             stm = con.prepareStatement(sqlQuery);
  1231.             stm.setLong(1, longIdAccordoServizioParteSpecifica);

  1233.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, longIdAccordoServizioParteSpecifica));
  1234.             rs = stm.executeQuery();

  1236.             while (rs.next()) {
  1237.                 ConfigurazioneServizioAzione conf = new ConfigurazioneServizioAzione();

  1239.                 idConnettore = rs.getLong("id_connettore"); // recuper id del
  1240.                 // connettore
  1241.                 conf.setConnettore(this.driver.getConnettore(idConnettore, con));

  1243.                 // aggiungo il fruitore al servizio da restituire
  1244.                 conf.setId(rs.getLong("id"));
  1245.                 accordoServizioParteSpecifica.getConfigurazioneServizio().addConfigurazioneAzione(conf);

  1247.             }
  1248.             rs.close();
  1249.             stm.close();
  1250.             
  1251.             
  1252.             if(accordoServizioParteSpecifica.getConfigurazioneServizio().sizeConfigurazioneAzioneList()>0) {
  1253.                 for (ConfigurazioneServizioAzione conf : accordoServizioParteSpecifica.getConfigurazioneServizio().getConfigurazioneAzioneList()) {
  1254.                     
  1255.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1256.                     sqlQueryObject.addFromTable(CostantiDB.SERVIZI_AZIONE);
  1257.                     sqlQueryObject.addSelectField("*");
  1258.                     sqlQueryObject.addWhereCondition("id_servizio_azioni = ?");
  1259.                     sqlQuery = sqlQueryObject.createSQLQuery();
  1260.                     stm = con.prepareStatement(sqlQuery);
  1261.                     stm.setLong(1, conf.getId());

  1263.                     this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, conf.getId()));
  1264.                     rs = stm.executeQuery();

  1266.                     while (rs.next()) {
  1267.                         
  1268.                         conf.addAzione(rs.getString("nome_azione"));

  1270.                     }
  1271.                     rs.close();
  1272.                     stm.close();
  1273.                     
  1274.                 }
  1275.             }


  1278.             // imposto uri accordo di servizio parte comune
  1279.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1280.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1281.             sqlQueryObject.addSelectField("*");
  1282.             sqlQueryObject.addWhereCondition("id = ?");
  1283.             sqlQuery = sqlQueryObject.createSQLQuery();
  1284.             stm = con.prepareStatement(sqlQuery);
  1285.             stm.setLong(1, longIdAccordoServizioParteComune);

  1287.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, longIdAccordoServizioParteComune));
  1288.             rs = stm.executeQuery();

  1290.             if (rs.next()) {
  1291.                 // setAccordoServizio
  1292.                 accordoServizioParteSpecifica.setIdAccordo(longIdAccordoServizioParteComune);

  1294.                 String tmp = rs.getString("nome");
  1295.                 int tmpVersione = rs.getInt("versione");
  1296.                 long id_referente = rs.getLong("id_referente");
  1297.                 IDSoggetto soggettoReferente = null;
  1298.                 if(id_referente>0){
  1299.                     try {
  1300.                         soggettoReferente = this.driver.getIdSoggetto(id_referente,con);
  1301.                         if(soggettoReferente==null){
  1302.                             throw new DriverRegistroServiziNotFound ("non esiste");
  1303.                         }
  1304.                     }catch(DriverRegistroServiziNotFound notFound) {
  1305.                         throw new Exception ("Soggetto referente ["+id_referente+"] dell'accordo non esiste");
  1306.                     }
  1307.                 }
  1308.                 accordoServizioParteSpecifica.setAccordoServizioParteComune(this.driver.idAccordoFactory.getUriFromValues(tmp, soggettoReferente, tmpVersione));


  1311.                 /** Non servono poiche' non presenti nel db dei servizi */
  1312.                 /*
  1313.                 // setFiltroduplicati
  1314.                 tmp = rs.getString("filtro_duplicati");
  1315.                 servizio.setFiltroDuplicati((tmp != null && !(tmp.trim().equals(""))) ? tmp : CostantiRegistroServizi.DISABILITATO);
  1316.                 // setConfermaRicezione
  1317.                 tmp = rs.getString("conferma_ricezione");
  1318.                 servizio.setConfermaRicezione((tmp != null && !(tmp.trim().equals(""))) ? tmp : CostantiRegistroServizi.DISABILITATO);
  1319.                 // setIdCollaborazione
  1320.                 tmp = rs.getString("identificativo_collaborazione");
  1321.                 servizio.setIdCollaborazione((tmp != null && !(tmp.trim().equals(""))) ? tmp : CostantiRegistroServizi.DISABILITATO);
  1322.                 // setIdRiferimentoRichiesta
  1323.                 tmp = rs.getString("id_riferimento_richiesta");
  1324.                 servizio.setIdRiferimentoRichiesta((tmp != null && !(tmp.trim().equals(""))) ? tmp : CostantiRegistroServizi.DISABILITATO);
  1325.                 // setConsegnaInOrdine
  1326.                 tmp = rs.getString("consegna_in_ordine");
  1327.                 servizio.setConsegnaInOrdine((tmp != null && !(tmp.trim().equals(""))) ? tmp : CostantiRegistroServizi.DISABILITATO);
  1328.                 // setScadenza
  1329.                 tmp = rs.getString("scadenza");
  1330.                 servizio.setScadenza((tmp != null && !(tmp.trim().equals(""))) ? tmp : null);
  1331.                  */
  1332.             }
  1333.             rs.close();
  1334.             stm.close();




  1339.             // read Documenti generici: i bytes non vengono ritornati se readContenutoAllegati==false, utilizzare il metodo apposta per averli: 
  1340.             //                                               DriverRegistroServiziDB_LIB.getDocumento(id, readBytes, connection);
  1341.             try{
  1342.                 List<?> allegati = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.allegato.toString(), longIdAccordoServizioParteSpecifica, 
  1343.                         ProprietariDocumento.servizio,readContenutoAllegati, con, this.driver.tipoDB);
  1344.                 for(int i=0; i<allegati.size();i++){
  1345.                     accordoServizioParteSpecifica.addAllegato((Documento) allegati.get(i));
  1346.                 }
  1347.             }catch(DriverRegistroServiziNotFound dNotFound){}
  1348.             try{
  1349.                 List<?> specificheSemiformali = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaSemiformale.toString(), 
  1350.                         longIdAccordoServizioParteSpecifica, ProprietariDocumento.servizio,readContenutoAllegati, con, this.driver.tipoDB);
  1351.                 for(int i=0; i<specificheSemiformali.size();i++){
  1352.                     accordoServizioParteSpecifica.addSpecificaSemiformale((Documento) specificheSemiformali.get(i));
  1353.                 }
  1354.             }catch(DriverRegistroServiziNotFound dNotFound){}
  1355.             try{
  1356.                 List<?> specificheLivelloServizio = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaLivelloServizio.toString(), 
  1357.                         longIdAccordoServizioParteSpecifica, ProprietariDocumento.servizio,readContenutoAllegati, con, this.driver.tipoDB);
  1358.                 for(int i=0; i<specificheLivelloServizio.size();i++){
  1359.                     accordoServizioParteSpecifica.addSpecificaLivelloServizio((Documento) specificheLivelloServizio.get(i));
  1360.                 }
  1361.             }catch(DriverRegistroServiziNotFound dNotFound){}
  1362.             try{
  1363.                 List<?> specificheSicurezza = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaSicurezza.toString(), 
  1364.                         longIdAccordoServizioParteSpecifica, ProprietariDocumento.servizio,readContenutoAllegati, con, this.driver.tipoDB);
  1365.                 for(int i=0; i<specificheSicurezza.size();i++){
  1366.                     accordoServizioParteSpecifica.addSpecificaSicurezza((Documento) specificheSicurezza.get(i));
  1367.                 }
  1368.             }catch(DriverRegistroServiziNotFound dNotFound){}

  1370.             
  1371.             
  1372.             
  1373.             // Protocol Properties
  1374.             try{
  1375.                 List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(longIdAccordoServizioParteSpecifica, 
  1376.                         ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_SPECIFICA, con, 
  1377.                         this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  1378.                 if(listPP!=null && !listPP.isEmpty()){
  1379.                     for (ProtocolProperty protocolProperty : listPP) {
  1380.                         accordoServizioParteSpecifica.addProtocolProperty(protocolProperty);
  1381.                     }
  1382.                 }
  1383.             }catch(DriverRegistroServiziNotFound dNotFound){
  1384.                 // ignore
  1385.             }   
  1386.             
  1387.             
  1388.             return accordoServizioParteSpecifica;

  1390.         } catch (DriverRegistroServiziNotFound e) {
  1391.             throw e;
  1392.         }catch (Exception se) {
  1393.             this.driver.logDebug("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] Exception:"+se.getMessage(),se);
  1394.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoServizioParteSpecifica] Exception:" + se.getMessage(),se);

  1396.         } finally {
  1397.             JDBCUtilities.closeResources(rs, stm);
  1398.             JDBCUtilities.closeResources(rs1, stm1);

  1400.             this.driver.closeConnection(conParam, con);
  1401.         }
  1402.     }
  1403.     
  1404.     
  1405.     
  1406.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(long idServizio) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1407.         return getAccordoServizioParteSpecifica(idServizio,null);
  1408.     }
  1409.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(long idServizio,boolean readContenutoAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1410.         return getAccordoServizioParteSpecifica(idServizio,null,readContenutoAllegati);
  1411.     }

  1413.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(long idServizio,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1414.         return getAccordoServizioParteSpecifica(idServizio, conParam,false);
  1415.     }
  1416.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(long idServizio,Connection conParam,boolean readContenutoAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {

  1418.         // conrollo consistenza
  1419.         if (idServizio <= 0)
  1420.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getServizio] L'id del servizio deve essere > 0.");

  1422.         Connection con = null;
  1423.         PreparedStatement stm = null;
  1424.         ResultSet rs = null;

  1426.         if(conParam!=null){
  1427.             con = conParam;
  1428.         }
  1429.         else if (this.driver.atomica) {
  1430.             try {
  1431.                 con = this.driver.getConnectionFromDatasource("getAccordoServizioParteSpecifica(longId)");

  1433.             } catch (Exception e) {
  1434.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getServizio] Exception accedendo al datasource :" + e.getMessage(),e);

  1436.             }

  1438.         } else
  1439.             con = this.driver.globalConnection;

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

  1443.         IDServizio idServizioObject = null;
  1444.         try {
  1445.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1446.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1447.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1448.             sqlQueryObject.addSelectField("tipo_servizio");
  1449.             sqlQueryObject.addSelectField("nome_servizio");
  1450.             sqlQueryObject.addSelectField("versione_servizio");
  1451.             sqlQueryObject.addSelectField("tipo_soggetto");
  1452.             sqlQueryObject.addSelectField("nome_soggetto");
  1453.             sqlQueryObject.addSelectField("servizio_correlato");
  1454.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id = ?");
  1455.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  1456.             sqlQueryObject.setANDLogicOperator(true);
  1457.             String sqlQuery = sqlQueryObject.createSQLQuery();

  1459.             stm = con.prepareStatement(sqlQuery);

  1461.             stm.setLong(1, idServizio);

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

  1465.             rs = stm.executeQuery();

  1467.             if (rs.next()) {
  1468.                 IDSoggetto soggettoErogatore = new IDSoggetto(rs.getString("tipo_soggetto"),rs.getString("nome_soggetto"));
  1469.                 idServizioObject = this.driver.idServizioFactory.getIDServizioFromValues(rs.getString("tipo_servizio"),rs.getString("nome_servizio"), soggettoErogatore, rs.getInt("versione_servizio"));
  1470.                 if(CostantiRegistroServizi.ABILITATO.toString().equals(rs.getString("servizio_correlato")) || 
  1471.                         TipologiaServizio.CORRELATO.toString().equals(rs.getString("servizio_correlato"))){
  1472.                     idServizioObject.setTipologia(org.openspcoop2.core.constants.TipologiaServizio.CORRELATO);
  1473.                 }
  1474.                 else{
  1475.                     idServizioObject.setTipologia(org.openspcoop2.core.constants.TipologiaServizio.NORMALE);
  1476.                 }

  1478.             }else{
  1479.                 throw new DriverRegistroServiziNotFound("Nessun Servizio trovato con id="+idServizio);
  1480.             }
  1481.             rs.close();
  1482.             stm.close();
  1483.         } catch (SQLException se) {
  1484.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getServizio] SqlException: " + se.getMessage(),se);
  1485.         } catch (DriverRegistroServiziNotFound nf) {
  1486.             throw nf;
  1487.         }catch (Exception se) {
  1488.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getServizio] Exception: " + se.getMessage(),se);
  1489.         } finally {

  1491.             //Chiudo statement and resultset
  1492.             JDBCUtilities.closeResources(rs, stm);

  1494.             this.driver.closeConnection(conParam, con);
  1495.         }

  1497.         return this.getAccordoServizioParteSpecifica(idServizioObject,readContenutoAllegati,conParam);

  1499.     }
  1500.     
  1501.     
  1502.     protected List<AccordoServizioParteSpecifica> serviziWithIdAccordoList(long idAccordo) throws DriverRegistroServiziException {
  1503.         String nomeMetodo = "serviziWithIdAccordoList";
  1504.         Connection con = null;
  1505.         PreparedStatement stmt=null;
  1506.         ResultSet risultato=null;
  1507.         ArrayList<AccordoServizioParteSpecifica> lista = new ArrayList<>();
  1508.         if (this.driver.atomica) {
  1509.             try {
  1510.                 con = this.driver.getConnectionFromDatasource("serviziWithIdAccordoList");
  1511.             } catch (Exception e) {
  1512.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1514.             }

  1516.         } else
  1517.             con = this.driver.globalConnection;

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

  1521.         try {

  1523.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1524.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1525.             sqlQueryObject.addSelectField("*");
  1526.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  1527.             String queryString = sqlQueryObject.createSQLQuery();
  1528.             stmt = con.prepareStatement(queryString);
  1529.             stmt.setLong(1, idAccordo);
  1530.             risultato = stmt.executeQuery();
  1531.             while (risultato.next()) {
  1532.                 AccordoServizioParteSpecifica serv = this.getAccordoServizioParteSpecifica(risultato.getLong("id"));
  1533.                 lista.add(serv);
  1534.             }

  1536.             return lista;

  1538.         } catch (Exception qe) {
  1539.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1540.         } finally {

  1542.             //Chiudo statement and resultset
  1543.             JDBCUtilities.closeResources(risultato, stmt);

  1545.             this.driver.closeConnection(con);
  1546.         }
  1547.     }
  1548.     
  1549.     protected List<IDSoggetto> getAllIdSoggettiErogatori(String tipoServizio,String nomeServizio,String uriAccordo,String nomePortType,String tipoSoggetto) throws DriverRegistroServiziException {
  1550.         String nomeMetodo = "getAllIdSoggettiErogatori";
  1551.         ArrayList<IDSoggetto> lista = new ArrayList<IDSoggetto>();
  1552.         Connection con = null;
  1553.         PreparedStatement stmt = null;
  1554.         ResultSet risultato = null;
  1555.         String queryString;

  1557.         try {

  1559.             if (this.driver.atomica) {
  1560.                 try {
  1561.                     con = this.driver.getConnectionFromDatasource("getAllIdSoggettiErogatori");

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

  1566.                 }

  1568.             } else {
  1569.                 con = this.driver.globalConnection;
  1570.             }

  1572.             this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);
  1573.             
  1574.             //recupero idAccordo
  1575.             IDAccordo idAccordo = this.driver.idAccordoFactory.getIDAccordoFromUri(uriAccordo);
  1576.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordo, con, this.driver.tipoDB);
  1577.             // Controllo che il pdd non sia in uso
  1578.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1579.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1580.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1581.             sqlQueryObject.setANDLogicOperator(true);
  1582.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI, "tipo_soggetto", "tipoSoggetto");
  1583.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI, "nome_soggetto", "nomeSoggetto");
  1584.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".id="+CostantiDB.SERVIZI+".id_soggetto");
  1585.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".tipo_servizio= ?");
  1586.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".nome_servizio= ?");
  1587.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo = ?");
  1588.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".port_type = ?");
  1589.             if(tipoSoggetto!=null) sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto = ?");
  1590.             queryString = sqlQueryObject.createSQLQuery();
  1591.             stmt = con.prepareStatement(queryString);
  1592.             stmt.setString(1, tipoServizio);
  1593.             stmt.setString(2, nomeServizio);
  1594.             stmt.setLong(3, idAccordoLong);
  1595.             stmt.setString(4, nomePortType);
  1596.             if(tipoSoggetto!=null) stmt.setString(5, tipoSoggetto);

  1598.             risultato = stmt.executeQuery();

  1600.             while (risultato.next()) {
  1601.                 String tipo_soggetto = risultato.getString("tipoSoggetto");
  1602.                 String nome_soggetto = risultato.getString("nomeSoggetto");
  1603.                 lista.add(new IDSoggetto(tipo_soggetto,nome_soggetto));
  1604.             }

  1606.             return lista;

  1608.         } catch (Exception se) {
  1609.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1610.         } finally {
  1611.             // Chiudo statement and resultset
  1612.             JDBCUtilities.closeResources(risultato, stmt);
  1613.             this.driver.closeConnection(con);
  1614.         }
  1615.     }
  1616.     
  1617.     
  1618.     protected void validaStatoAccordoServizioParteSpecifica(AccordoServizioParteSpecifica servizio, boolean gestioneWsdlImplementativo, boolean checkConnettore) throws ValidazioneStatoPackageException{

  1620.         ValidazioneStatoPackageException erroreValidazione =
  1621.                 new ValidazioneStatoPackageException("Servizio",servizio.getStatoPackage(),null);

  1623.         try{

  1625.             // Controlli di visibilita
  1626.             if(servizio.getPrivato()==null || servizio.getPrivato()==false){
  1627.                 IDSoggetto idS = new IDSoggetto(servizio.getTipoSoggettoErogatore(),servizio.getNomeSoggettoErogatore());
  1628.                 try{
  1629.                     Soggetto s = this.driver.getSoggetto(idS);
  1630.                     if(s.getPrivato()!=null && s.getPrivato()){
  1631.                         erroreValidazione.addErroreValidazione("soggetto erogatore ["+idS+"] con visibilita' privata, in un servizio con visibilita' pubblica");
  1632.                     }
  1633.                 }catch(DriverRegistroServiziNotFound dNot){}
  1634.                 try{
  1635.                     AccordoServizioParteComune as = this.driver.getAccordoServizioParteComune(this.driver.idAccordoFactory.getIDAccordoFromUri(servizio.getAccordoServizioParteComune()));
  1636.                     if(as.getPrivato()!=null && as.getPrivato()){
  1637.                         erroreValidazione.addErroreValidazione("accordo di servizio ["+servizio.getAccordoServizioParteComune()+"] con visibilita' privata, in un servizio con visibilita' pubblica");
  1638.                     }
  1639.                 }catch(DriverRegistroServiziNotFound dNot){}
  1640.             }   

  1642.             // Controlli di stato
  1643.             if(StatiAccordo.bozza.toString().equals(servizio.getStatoPackage()) == false){

  1645.                 if(StatiAccordo.operativo.toString().equals(servizio.getStatoPackage())){
  1646.                     try{
  1647.                         AccordoServizioParteComune as = this.driver.getAccordoServizioParteComune(this.driver.idAccordoFactory.getIDAccordoFromUri(servizio.getAccordoServizioParteComune()));
  1648.                         if(StatiAccordo.finale.toString().equals(as.getStatoPackage())==false && StatiAccordo.operativo.toString().equals(as.getStatoPackage())==false){
  1649.                             erroreValidazione.addErroreValidazione("accordo di servizio riferito ["+this.driver.idAccordoFactory.getUriFromAccordo(as)+"] possiede lo stato ["+as.getStatoPackage()+"]");
  1650.                         }
  1651.                     }catch(DriverRegistroServiziNotFound dNot){
  1652.                         erroreValidazione.addErroreValidazione("accordo di servizio non definito");
  1653.                     }
  1654.                 }
  1655.                 
  1656.                 else if(StatiAccordo.finale.toString().equals(servizio.getStatoPackage())){
  1657.                     AccordoServizioParteComune as = null;
  1658.                     try{
  1659.                         as = this.driver.getAccordoServizioParteComune(this.driver.idAccordoFactory.getIDAccordoFromUri(servizio.getAccordoServizioParteComune()));
  1660.                         if(StatiAccordo.finale.toString().equals(as.getStatoPackage())==false){
  1661.                             erroreValidazione.addErroreValidazione("accordo di servizio ["+this.driver.idAccordoFactory.getUriFromAccordo(as)+"] in uno stato non finale ["+as.getStatoPackage()+"]");
  1662.                         }
  1663.                     }catch(DriverRegistroServiziNotFound dNot){
  1664.                         erroreValidazione.addErroreValidazione("accordo di servizio non definito");
  1665.                     }

  1667.                     if(as!=null) {
  1668.                         if(ServiceBinding.SOAP.equals(as.getServiceBinding()) && gestioneWsdlImplementativo) {
  1669.                         
  1670.                             if(TipologiaServizio.CORRELATO.equals(servizio.getTipologiaServizio())){
  1671.                                 String wsdlImplementativoFruitore = (servizio.getByteWsdlImplementativoFruitore()!=null ? new String(servizio.getByteWsdlImplementativoFruitore()) : null);
  1672.                                 wsdlImplementativoFruitore = wsdlImplementativoFruitore!=null && !"".equals(wsdlImplementativoFruitore.trim().replaceAll("\n", "")) ? wsdlImplementativoFruitore : null;
  1673.                                 if( wsdlImplementativoFruitore == null){
  1674.                                     erroreValidazione.addErroreValidazione("WSDL Implementativo fruitore non definito");
  1675.                                 }
  1676.                             }else{
  1677.                                 String wsdlImplementativoErogatore = (servizio.getByteWsdlImplementativoErogatore()!=null ? new String(servizio.getByteWsdlImplementativoErogatore()) : null);
  1678.                                 wsdlImplementativoErogatore = wsdlImplementativoErogatore!=null && !"".equals(wsdlImplementativoErogatore.trim().replaceAll("\n", "")) ? wsdlImplementativoErogatore : null;
  1679.                                 if( wsdlImplementativoErogatore == null){
  1680.                                     erroreValidazione.addErroreValidazione("WSDL Implementativo erogatore non definito");
  1681.                                 }
  1682.                             }
  1683.                             
  1684.                         }
  1685.                     }


  1688.                     // check connettore: un servizio puo' essere finale con jms: il check sara' poi al momento dell'esportazione nei package cnipa
  1689.                     /*if(servizio.getConnettore()!=null && !CostantiDB.CONNETTORE_TIPO_DISABILITATO.equals(servizio.getConnettore().getTipo()) && 
  1690.                             !CostantiDB.CONNETTORE_TIPO_HTTP.equals(servizio.getConnettore().getTipo()) && !CostantiDB.CONNETTORE_TIPO_HTTPS.equals(servizio.getConnettore().getTipo())){
  1691.                         erroreValidazione.addErroreValidazione("Accordo di servizio parte specifica possiede un connettore ("+servizio.getConnettore().getTipo()+") non utilizzabile nella rete SPC");
  1692.                     }
  1693.                     else */
  1694.                     
  1695.                     if(checkConnettore) {
  1696.                         
  1697.                         if(servizio.getConfigurazioneServizio().getConnettore()==null || CostantiDB.CONNETTORE_TIPO_DISABILITATO.equals(servizio.getConfigurazioneServizio().getConnettore().getTipo())){
  1698.                             // check connettore del soggetto erogatore: un servizio puo' essere finale con jms: il check sara' poi al momento dell'esportazione nei package cnipa
  1699.                             Soggetto soggettoErogatore = this.driver.getSoggetto(new IDSoggetto(servizio.getTipoSoggettoErogatore(),servizio.getNomeSoggettoErogatore()));
  1700.                             /*if(soggettoErogatore.getConnettore()!=null && !CostantiDB.CONNETTORE_TIPO_DISABILITATO.equals(soggettoErogatore.getConnettore().getTipo()) && 
  1701.                                     !CostantiDB.CONNETTORE_TIPO_HTTP.equals(soggettoErogatore.getConnettore().getTipo()) && !CostantiDB.CONNETTORE_TIPO_HTTPS.equals(soggettoErogatore.getConnettore().getTipo())){
  1702.                                 erroreValidazione.addErroreValidazione("Accordo di servizio parte specifica non possiede un connettore e soggetto erogatore "+servizio.getTipoSoggettoErogatore()+"/"+servizio.getNomeSoggettoErogatore()+" possiede un connettore ("+soggettoErogatore.getConnettore().getTipo()+") non utilizzabile nella rete SPC");
  1703.                             }
  1704.                             else */
  1705.                             if(soggettoErogatore.getConnettore()==null || CostantiDB.CONNETTORE_TIPO_DISABILITATO.equals(soggettoErogatore.getConnettore().getTipo()) ){
  1706.                                 erroreValidazione.addErroreValidazione("Sia l'Accordo di servizio parte specifica che il soggetto erogatore non possiedono un connettore");
  1707.                             }
  1708.                         }
  1709.                     }
  1710.                 }

  1712.             }

  1714.         }catch(Exception e){
  1715.             throw new ValidazioneStatoPackageException(e);
  1716.         }

  1718.         if(erroreValidazione.sizeErroriValidazione()>0){
  1719.             throw erroreValidazione;
  1720.         }
  1721.     }

  1723.     
  1724.     
  1725.     
  1726.     
  1727.     
  1728.     protected void updateProprietaOggettoErogazione(IDServizio idServizioObject, String user) throws DriverRegistroServiziException {
  1729.         
  1730.         String nomeMetodo = "updateProprietaOggettoErogazione";
  1731.         Connection con = null;
  1732.         long idServizio = -1;
  1733.         try {
  1734.             if (this.driver.atomica) {
  1735.                 try {
  1736.                     con = this.driver.getConnectionFromDatasource(nomeMetodo);

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

  1741.                 }

  1743.             } else {
  1744.                 con = this.driver.globalConnection;
  1745.             }

  1747.             this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);
  1748.             
  1749.             idServizio = DBUtils.getIdAccordoServizioParteSpecifica(idServizioObject, con, DriverRegistroServiziDB_LIB.tipoDB);

  1751.             if(idServizio<=0) {
  1752.                 throw new DriverRegistroServiziException("Servizio con id '"+idServizioObject+"' non esistente");
  1753.             }
  1754.             
  1755.         } catch (Exception e) {
  1756.             DriverRegistroServiziDB_LIB.logError("Errore", e);
  1757.             throw new DriverRegistroServiziException(e);
  1758.         } finally {
  1759.             this.driver.closeConnection(con);
  1760.         }
  1761.         updateProprietaOggettoEngine(idServizio, user, CostantiDB.SERVIZI);
  1762.     }
  1763.     protected void updateProprietaOggettoErogazione(long idServizio, String user) throws DriverRegistroServiziException {
  1764.         updateProprietaOggettoEngine(idServizio, user, CostantiDB.SERVIZI);
  1765.     }
  1766.     protected void updateProprietaOggettoFruizione(IDServizio idServizioObject, IDSoggetto idFruitore, String user) throws DriverRegistroServiziException {
  1767.         
  1768.         String nomeMetodo = "updateProprietaOggettoFruizione";
  1769.         Connection con = null;
  1770.         long idFruizione = -1;
  1771.         try {
  1772.             if (this.driver.atomica) {
  1773.                 try {
  1774.                     con = this.driver.getConnectionFromDatasource(nomeMetodo);

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

  1779.                 }

  1781.             } else {
  1782.                 con = this.driver.globalConnection;
  1783.             }

  1785.             this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);
  1786.             
  1787.             idFruizione = DBUtils.getIdFruizioneServizio(idServizioObject, idFruitore, con, DriverRegistroServiziDB_LIB.tipoDB);

  1789.             if(idFruizione<=0) {
  1790.                 throw new DriverRegistroServiziException("Servizio con id '"+idServizioObject+"' non esistente");
  1791.             }
  1792.             
  1793.         } catch (Exception e) {
  1794.             DriverRegistroServiziDB_LIB.logError("Errore", e);
  1795.             throw new DriverRegistroServiziException(e);
  1796.         } finally {
  1797.             this.driver.closeConnection(con);
  1798.         }
  1799.         updateProprietaOggettoEngine(idFruizione, user, CostantiDB.SERVIZI_FRUITORI);
  1800.     }
  1801.     protected void updateProprietaOggettoFruizione(long idFruizione, String user) throws DriverRegistroServiziException {
  1802.         updateProprietaOggettoEngine(idFruizione, user, CostantiDB.SERVIZI_FRUITORI);
  1803.     }
  1804.     private void updateProprietaOggettoEngine(long id, String user, String tabella) throws DriverRegistroServiziException {
  1805.         
  1806.         String nomeMetodo = "updateProprietaOggetto_"+tabella;
  1807.         
  1808.         Connection con = null;
  1809.         PreparedStatement stm = null;
  1810.         try {
  1811.             if (this.driver.atomica) {
  1812.                 try {
  1813.                     con = this.driver.getConnectionFromDatasource(nomeMetodo);

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

  1818.                 }

  1820.             } else {
  1821.                 con = this.driver.globalConnection;
  1822.             }

  1824.             this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);
  1825.             
  1826.             ISQLQueryObject sqlQueryObjectUpdate = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1827.             sqlQueryObjectUpdate.addUpdateTable(tabella);
  1828.             sqlQueryObjectUpdate.addUpdateField(CostantiDB.PROPRIETA_OGGETTO_UTENTE_ULTIMA_MODIFICA, "?");
  1829.             sqlQueryObjectUpdate.addUpdateField(CostantiDB.PROPRIETA_OGGETTO_DATA_ULTIMA_MODIFICA, "?");
  1830.             sqlQueryObjectUpdate.addWhereCondition("id=?");
  1831.             String updateString = sqlQueryObjectUpdate.createSQLUpdate();
  1832.             stm = con.prepareStatement(updateString);
  1833.             int index = 1;
  1834.             stm.setString(index++, user);
  1835.             stm.setTimestamp(index++, DateManager.getTimestamp());
  1836.             stm.setLong(index, id);
  1837.             int n=stm.executeUpdate();
  1838.             stm.close();
  1839.             DriverRegistroServiziDB_LIB.logDebug("Aggiornata "+n+" entry per l'operazione di ultima modifica della tabella '"+tabella+"' con id: "+id);
  1840.         } catch (SQLException e) {
  1841.             DriverRegistroServiziDB_LIB.logError("Errore SQL", e);
  1842.             throw new DriverRegistroServiziException(e);
  1843.         }catch (Exception e) {
  1844.             DriverRegistroServiziDB_LIB.logError("Errore", e);
  1845.             throw new DriverRegistroServiziException(e);
  1846.         } finally {
  1847.             JDBCUtilities.closeResources(stm);

  1849.             this.driver.closeConnection(con);
  1850.         }
  1851.     }
  1852. }
Created with JaCoCo 0.8.8.202204050719