DriverRegistroServiziDB_accordiLIB.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 static org.openspcoop2.core.constants.CostantiDB.CREATE;
  26. import static org.openspcoop2.core.constants.CostantiDB.DELETE;
  27. import static org.openspcoop2.core.constants.CostantiDB.UPDATE;

  29. import java.sql.Connection;
  30. import java.sql.PreparedStatement;
  31. import java.sql.ResultSet;
  32. import java.sql.SQLException;
  33. import java.sql.Timestamp;
  34. import java.util.ArrayList;
  35. import java.util.List;

  37. import org.openspcoop2.core.byok.IDriverBYOK;
  38. import org.openspcoop2.core.commons.DBUtils;
  39. import org.openspcoop2.core.constants.CostantiDB;
  40. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  41. import org.openspcoop2.core.id.IDAccordo;
  42. import org.openspcoop2.core.id.IDGruppo;
  43. import org.openspcoop2.core.id.IDSoggetto;
  44. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  45. import org.openspcoop2.core.registry.Azione;
  46. import org.openspcoop2.core.registry.Documento;
  47. import org.openspcoop2.core.registry.GruppoAccordo;
  48. import org.openspcoop2.core.registry.PortType;
  49. import org.openspcoop2.core.registry.Resource;
  50. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  51. import org.openspcoop2.core.registry.constants.FormatoSpecifica;
  52. import org.openspcoop2.core.registry.constants.MessageType;
  53. import org.openspcoop2.core.registry.constants.ProfiloCollaborazione;
  54. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  55. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  56. import org.openspcoop2.core.registry.constants.ServiceBinding;
  57. import org.openspcoop2.core.registry.constants.StatoFunzionalita;
  58. import org.openspcoop2.core.registry.driver.BeanUtilities;
  59. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  60. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  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;
  65. import org.slf4j.Logger;

  67. /**
  68.  * Classe utilizzata per effettuare query ad un registro dei servizi openspcoop
  69.  * formato db.
  70.  * 
  71.  * 
  72.  * @author Sandra Giangrandi (sandra@link.it)
  73.  * @author Stefano Corallo (corallo@link.it)
  74.  * @author $Author$
  75.  * @version $Rev$, $Date$
  76.  */
  77. public class DriverRegistroServiziDB_accordiLIB {
  78.     
  79.     private DriverRegistroServiziDB_accordiLIB() {}
  80.     
  81.     private static final String ACCORDO_DIVERSO_NULL = "L'accordo non può essere null.";
  82.     private static final String NOME_ACCORDO_NON_VALIDO = "Il nome dell'accordo non è valido.";
  83.     
  84.     private static void logDebug(Logger log, String msg) {
  85.         if(log!=null) {
  86.             log.debug(msg);
  87.         }
  88.     }
  89.     
  90.     private static void logError(Logger log, String msg, Exception e) {
  91.         if(log!=null) {
  92.             log.error(msg,e);
  93.         }
  94.     }
  95.     
  96.     public static void createAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio, 
  97.             Connection con, String tabellaSoggetti, Logger log, IDAccordoFactory idAccordoFactory, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {

  99.         if (accordoServizio == null)
  100.             throw new DriverRegistroServiziException(ACCORDO_DIVERSO_NULL);

  102.         String nome = accordoServizio.getNome();
  103.         if (nome == null || nome.equals(""))
  104.             throw new DriverRegistroServiziException(NOME_ACCORDO_NON_VALIDO);

  106.         ServiceBinding serviceBinding = accordoServizio.getServiceBinding();
  107.         MessageType messageType = accordoServizio.getMessageType();
  108.         
  109.         StatoFunzionalita confermaRicezione = accordoServizio.getConfermaRicezione();
  110.         StatoFunzionalita conegnaInOrdine = accordoServizio.getConsegnaInOrdine();
  111.         String descrizione = accordoServizio.getDescrizione();
  112.         StatoFunzionalita filtroDuplicati = accordoServizio.getFiltroDuplicati();
  113.         StatoFunzionalita identificativoCollaborazione = accordoServizio.getIdCollaborazione();
  114.         StatoFunzionalita identificativoRiferimentoRichiesta = accordoServizio.getIdRiferimentoRichiesta();

  116.         ProfiloCollaborazione profiloCollaborazione = accordoServizio.getProfiloCollaborazione();
  117.         String scadenza = accordoServizio.getScadenza();
  118.         boolean utilizzioSenzaAzione = accordoServizio.getUtilizzoSenzaAzione();
  119.         String wsdlConcettuale = (accordoServizio.getByteWsdlConcettuale()!=null ? new String(accordoServizio.getByteWsdlConcettuale()) : null);
  120.         String wsdlDefinitorio = (accordoServizio.getByteWsdlDefinitorio()!=null ? new String(accordoServizio.getByteWsdlDefinitorio()) : null);
  121.         String wsdlLogicoErogatore = (accordoServizio.getByteWsdlLogicoErogatore()!=null ? new String(accordoServizio.getByteWsdlLogicoErogatore()) : null);
  122.         String wsdlLogicoFruitore = (accordoServizio.getByteWsdlLogicoFruitore()!=null ? new String(accordoServizio.getByteWsdlLogicoFruitore()) : null);
  123.         String conversazioneConcettuale = (accordoServizio.getByteSpecificaConversazioneConcettuale()!=null ? new String(accordoServizio.getByteSpecificaConversazioneConcettuale()) : null);
  124.         String conversazioneErogatore = (accordoServizio.getByteSpecificaConversazioneErogatore()!=null ? new String(accordoServizio.getByteSpecificaConversazioneErogatore()) : null);
  125.         String conversazioneFruitore = (accordoServizio.getByteSpecificaConversazioneFruitore()!=null ? new String(accordoServizio.getByteSpecificaConversazioneFruitore()) : null);
  126.         String superUser = accordoServizio.getSuperUser();

  128.         FormatoSpecifica formatoSpecifica = accordoServizio.getFormatoSpecifica();
  129.         wsdlConcettuale = wsdlConcettuale!=null && !"".equals(wsdlConcettuale.trim().replace("\n", "")) ? wsdlConcettuale : null;
  130.         wsdlDefinitorio = wsdlDefinitorio!=null && !"".equals(wsdlDefinitorio.trim().replace("\n", "")) ? wsdlDefinitorio : null;
  131.         wsdlLogicoErogatore = wsdlLogicoErogatore!=null && !"".equals(wsdlLogicoErogatore.trim().replace("\n", "")) ? wsdlLogicoErogatore : null;
  132.         wsdlLogicoFruitore = wsdlLogicoFruitore!=null && !"".equals(wsdlLogicoFruitore.trim().replace("\n", "")) ? wsdlLogicoFruitore : null;
  133.         conversazioneConcettuale = conversazioneConcettuale!=null && !"".equals(conversazioneConcettuale.trim().replace("\n", "")) ? conversazioneConcettuale : null;
  134.         conversazioneErogatore = conversazioneErogatore!=null && !"".equals(conversazioneErogatore.trim().replace("\n", "")) ? conversazioneErogatore : null;
  135.         conversazioneFruitore = conversazioneFruitore!=null && !"".equals(conversazioneFruitore.trim().replace("\n", "")) ? conversazioneFruitore : null;

  137.         String utenteRichiedente = null;
  138.         if(accordoServizio.getProprietaOggetto()!=null && accordoServizio.getProprietaOggetto().getUtenteRichiedente()!=null) {
  139.             utenteRichiedente = accordoServizio.getProprietaOggetto().getUtenteRichiedente();
  140.         }
  141.         else {
  142.             utenteRichiedente = superUser;
  143.         }
  144.         
  145.         Timestamp dataCreazione = null;
  146.         if(accordoServizio.getProprietaOggetto()!=null && accordoServizio.getProprietaOggetto().getDataCreazione()!=null) {
  147.             dataCreazione = new Timestamp(accordoServizio.getProprietaOggetto().getDataCreazione().getTime());
  148.         }
  149.         else if(accordoServizio.getOraRegistrazione()!=null){
  150.             dataCreazione = new Timestamp(accordoServizio.getOraRegistrazione().getTime());
  151.         }
  152.         else {
  153.             dataCreazione = DateManager.getTimestamp();
  154.         }
  155.         
  156.         String sqlQuery = "";

  158.         PreparedStatement stm = null;
  159.         
  160.         try {
  161.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  162.             sqlQueryObject.addInsertTable(CostantiDB.ACCORDI);
  163.             sqlQueryObject.addInsertField("service_binding", "?");
  164.             sqlQueryObject.addInsertField("message_type", "?");
  165.             sqlQueryObject.addInsertField("conferma_ricezione", "?");
  166.             sqlQueryObject.addInsertField("consegna_in_ordine", "?");
  167.             sqlQueryObject.addInsertField("descrizione", "?");
  168.             sqlQueryObject.addInsertField("filtro_duplicati", "?");
  169.             sqlQueryObject.addInsertField("identificativo_collaborazione", "?");
  170.             sqlQueryObject.addInsertField("id_riferimento_richiesta", "?");
  171.             sqlQueryObject.addInsertField("nome", "?");
  172.             sqlQueryObject.addInsertField("profilo_collaborazione", "?");
  173.             sqlQueryObject.addInsertField("scadenza", "?");
  174.             sqlQueryObject.addInsertField("formato_specifica", "?");
  175.             sqlQueryObject.addInsertField("wsdl_concettuale", "?");
  176.             sqlQueryObject.addInsertField("wsdl_definitorio", "?");
  177.             sqlQueryObject.addInsertField("wsdl_logico_erogatore", "?");
  178.             sqlQueryObject.addInsertField("wsdl_logico_fruitore", "?");
  179.             sqlQueryObject.addInsertField("spec_conv_concettuale", "?");
  180.             sqlQueryObject.addInsertField("spec_conv_erogatore", "?");
  181.             sqlQueryObject.addInsertField("spec_conv_fruitore", "?");
  182.             sqlQueryObject.addInsertField("superuser", "?");
  183.             sqlQueryObject.addInsertField("utilizzo_senza_azione", "?");
  184.             sqlQueryObject.addInsertField("privato", "?");
  185.             if(accordoServizio.getStatoPackage()!=null)
  186.                 sqlQueryObject.addInsertField("stato", "?");
  187.             sqlQueryObject.addInsertField("canale", "?");
  188.             if(accordoServizio.getSoggettoReferente()!=null)
  189.                 sqlQueryObject.addInsertField("id_referente", "?");
  190.             sqlQueryObject.addInsertField("versione", "?");
  191.             if(accordoServizio.getOraRegistrazione()!=null)
  192.                 sqlQueryObject.addInsertField("ora_registrazione", "?");
  193.             if(utenteRichiedente!=null) {
  194.                 sqlQueryObject.addInsertField(CostantiDB.PROPRIETA_OGGETTO_UTENTE_RICHIEDENTE, "?");
  195.             }
  196.             if(dataCreazione!=null) {
  197.                 sqlQueryObject.addInsertField(CostantiDB.PROPRIETA_OGGETTO_DATA_CREAZIONE, "?");
  198.             }
  199.             sqlQuery = sqlQueryObject.createSQLInsert();
  200.             stm = con.prepareStatement(sqlQuery);
  201.             int index = 1;
  202.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(serviceBinding));
  203.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(messageType));
  204.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(confermaRicezione));
  205.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(conegnaInOrdine));
  206.             stm.setString(index++, descrizione);
  207.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(filtroDuplicati));
  208.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(identificativoCollaborazione));
  209.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(identificativoRiferimentoRichiesta));
  210.             stm.setString(index++, nome);
  211.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(profiloCollaborazione));
  212.             stm.setString(index++, scadenza);
  213.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(formatoSpecifica));
  214.             stm.setString(index++, wsdlConcettuale!=null && !wsdlConcettuale.trim().equals("") ? wsdlConcettuale : null);
  215.             stm.setString(index++, wsdlDefinitorio!=null && !wsdlDefinitorio.trim().equals("") ? wsdlDefinitorio : null );
  216.             stm.setString(index++ ,wsdlLogicoErogatore!=null && !wsdlLogicoErogatore.trim().equals("") ? wsdlLogicoErogatore : null );
  217.             stm.setString(index++, wsdlLogicoFruitore!=null && !wsdlLogicoFruitore.trim().equals("") ? wsdlLogicoFruitore : null );
  218.             stm.setString(index++, conversazioneConcettuale!=null && !conversazioneConcettuale.trim().equals("") ? conversazioneConcettuale : null);
  219.             stm.setString(index++ ,conversazioneErogatore!=null && !conversazioneErogatore.trim().equals("") ? conversazioneErogatore : null );
  220.             stm.setString(index++, conversazioneFruitore!=null && !conversazioneFruitore.trim().equals("") ? conversazioneFruitore : null );
  221.             stm.setString(index++, superUser);
  222.             stm.setInt(index++, utilizzioSenzaAzione ? CostantiDB.TRUE : CostantiDB.FALSE);
  223.             if (accordoServizio.getPrivato()!=null && accordoServizio.getPrivato())
  224.                 stm.setInt(index++, 1);
  225.             else
  226.                 stm.setInt(index++, 0);
  227.             if(accordoServizio.getStatoPackage()!=null){
  228.                 stm.setString(index, accordoServizio.getStatoPackage());
  229.                 index++;
  230.             }
  231.             stm.setString(index, accordoServizio.getCanale());
  232.             index++;
  233.             
  234.             long idReferente = -1;
  235.             if(accordoServizio.getSoggettoReferente()!=null){
  236.                 idReferente = DBUtils.getIdSoggetto(accordoServizio.getSoggettoReferente().getNome(), accordoServizio.getSoggettoReferente().getTipo(), con, DriverRegistroServiziDB_LIB.tipoDB, tabellaSoggetti);
  237.                 if(idReferente<=0){
  238.                     throw new DriverRegistroServiziException("Soggetto Referente ["+accordoServizio.getSoggettoReferente().getTipo()+"/"+accordoServizio.getSoggettoReferente().getNome()+"] non trovato");
  239.                 }
  240.                 stm.setLong(index, idReferente);
  241.                 index++;
  242.             }

  244.             stm.setInt(index, accordoServizio.getVersione());
  245.             index++;

  247.             if(accordoServizio.getOraRegistrazione()!=null){
  248.                 stm.setTimestamp(index, new Timestamp(accordoServizio.getOraRegistrazione().getTime()));
  249.                 index++;
  250.             }
  251.             
  252.             if(utenteRichiedente!=null) {
  253.                 stm.setString(index, utenteRichiedente);
  254.                 index++;
  255.             }
  256.             
  257.             if(dataCreazione!=null) {
  258.                 stm.setTimestamp(index, dataCreazione);
  259.                 index++;
  260.             }

  262.             String msgDebug = "inserisco accordoServizio : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, 
  263.                     serviceBinding, messageType,
  264.                     confermaRicezione, conegnaInOrdine, descrizione, 
  265.                     filtroDuplicati, identificativoCollaborazione, identificativoRiferimentoRichiesta, nome, profiloCollaborazione, scadenza, 
  266.                     wsdlConcettuale, wsdlDefinitorio, wsdlLogicoErogatore, wsdlLogicoFruitore, 
  267.                     conversazioneConcettuale, conversazioneErogatore, conversazioneFruitore,
  268.                     superUser, accordoServizio.getUtilizzoSenzaAzione(), 
  269.                     (accordoServizio.getPrivato()!=null && accordoServizio.getPrivato()));
  270.             log.debug(msgDebug);

  272.             // eseguo la query
  273.             stm.executeUpdate();
  274.             stm.close();
  275.             // recupero l-id dell'accordo appena inserito
  276.             IDSoggetto soggettoReferente = null;
  277.             if(accordoServizio.getSoggettoReferente()!=null){
  278.                 soggettoReferente = new IDSoggetto(accordoServizio.getSoggettoReferente().getTipo(),accordoServizio.getSoggettoReferente().getNome());
  279.             }
  280.             IDAccordo idAccordoObject = idAccordoFactory.getIDAccordoFromValues(accordoServizio.getNome(),soggettoReferente,accordoServizio.getVersione());
  281.             long idAccordo = DBUtils.getIdAccordoServizioParteComune(idAccordoObject, con, DriverRegistroServiziDB_LIB.tipoDB);
  282.             if (idAccordo<=0) {
  283.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizio] non riesco a trovare l'id del'Accordo inserito");
  284.             }
  285.             accordoServizio.setId(idAccordo);
  286.             // aggiungo le eventuali azioni che c-erano
  287.             
  288.             Azione azione = null;
  289.             for (int i = 0; i < accordoServizio.sizeAzioneList(); i++) {
  290.                 azione = accordoServizio.getAzione(i);
  291.                 DriverRegistroServiziDB_accordiSoapLIB.CRUDAzione(CostantiDB.CREATE,accordoServizio, azione, con, idAccordo, driverBYOK);

  293.             }
  294.             logDebug(log, "inserite " + accordoServizio.sizeAzioneList() + " azioni relative all'accordo :" + nome + " id :" + idAccordo);

  296.             PortType pt = null;
  297.             for (int i = 0; i < accordoServizio.sizePortTypeList(); i++) {
  298.                 pt = accordoServizio.getPortType(i);
  299.                 DriverRegistroServiziDB_accordiSoapLIB.CRUDPortType(CostantiDB.CREATE,accordoServizio,pt, con, idAccordo, driverBYOK);
  300.             }
  301.             logDebug(log, "inserite " + accordoServizio.sizePortTypeList() + " porttype relative all'accordo :" + nome + " id :" + idAccordo);

  303.             Resource resource = null;
  304.             for (int i = 0; i < accordoServizio.sizeResourceList(); i++) {
  305.                 resource = accordoServizio.getResource(i);
  306.                 DriverRegistroServiziDB_accordiRestLIB.CRUDResource(CostantiDB.CREATE,accordoServizio,resource, con, idAccordo, driverBYOK);
  307.             }
  308.             logDebug(log, "inserite " + accordoServizio.sizeResourceList() + " resources relative all'accordo :" + nome + " id :" + idAccordo);
  309.             
  310.             // Gruppi
  311.             if(accordoServizio.getGruppi()!=null && accordoServizio.getGruppi().sizeGruppoList()>0) {
  312.                 for (int i = 0; i < accordoServizio.getGruppi().sizeGruppoList(); i++) {
  313.                     GruppoAccordo gruppo = accordoServizio.getGruppi().getGruppo(i);
  314.                     DriverRegistroServiziDB_accordiLIB.CRUDAccordoGruppo(CostantiDB.CREATE,accordoServizio, gruppo, con, idAccordo);
  315.                 }
  316.                 logDebug(log, "inserite " + accordoServizio.sizeAzioneList() + " gruppi relative all'accordo :" + nome + " id :" + idAccordo);
  317.             }
  318.             
  319.             // Accordo servizio composto
  320.             if(accordoServizio.getServizioComposto()!=null){
  321.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.CREATE, 
  322.                         accordoServizio.getServizioComposto(), con, idAccordo);
  323.             }


  326.             // Documenti generici accordo di servizio
  327.             List<Documento> documenti = new ArrayList<>();
  328.             // Allegati
  329.             for(int i=0; i<accordoServizio.sizeAllegatoList(); i++){
  330.                 Documento doc = accordoServizio.getAllegato(i);
  331.                 doc.setRuolo(RuoliDocumento.allegato.toString());
  332.                 documenti.add(doc);
  333.             }
  334.             // Specifiche Semiformali
  335.             for(int i=0; i<accordoServizio.sizeSpecificaSemiformaleList(); i++){
  336.                 Documento doc = accordoServizio.getSpecificaSemiformale(i);
  337.                 doc.setRuolo(RuoliDocumento.specificaSemiformale.toString());
  338.                 documenti.add(doc);
  339.             }
  340.             // Specifiche Coordinamento
  341.             if(accordoServizio.getServizioComposto()!=null){
  342.                 for(int i=0; i<accordoServizio.getServizioComposto().sizeSpecificaCoordinamentoList(); i++){
  343.                     Documento doc = accordoServizio.getServizioComposto().getSpecificaCoordinamento(i);
  344.                     doc.setRuolo(RuoliDocumento.specificaCoordinamento.toString());
  345.                     documenti.add(doc);
  346.                 }
  347.             }
  348.             // CRUD
  349.             DriverRegistroServiziDB_documentiLIB.CRUDDocumento(CostantiDB.CREATE, documenti, idAccordo, ProprietariDocumento.accordoServizio, con, DriverRegistroServiziDB_LIB.tipoDB);
  350.             
  351.             // ProtocolProperties
  352.             DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.CREATE, accordoServizio.getProtocolPropertyList(), 
  353.                     idAccordo, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_COMUNE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  354.             

  356.         } catch (SQLException se) {
  357.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteComune] SQLException [" + se.getMessage() + "].",se);
  358.         } catch (DriverRegistroServiziException e) {
  359.             throw new DriverRegistroServiziException(e.getMessage(),e);
  360.         }catch (Exception e) {
  361.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoServizioParteComune] Exception [" + e.getMessage() + "].",e);
  362.         }finally {
  363.             JDBCUtilities.closeResources(stm);
  364.         }

  366.     }
  367.     
  368.     
  369.     
  370.     public static void updateAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio, 
  371.             Connection con, String tabellaSoggetti, Logger log, IDAccordoFactory idAccordoFactory, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {

  373.         if (accordoServizio == null)
  374.             throw new DriverRegistroServiziException(ACCORDO_DIVERSO_NULL);

  376.         String nome = accordoServizio.getNome();
  377.         if (nome == null || nome.equals(""))
  378.             throw new DriverRegistroServiziException(NOME_ACCORDO_NON_VALIDO);

  380.         PreparedStatement stm = null;
  381.         ResultSet rs =null;
  382.         String sqlQuery = "";

  384.         ServiceBinding serviceBinding = accordoServizio.getServiceBinding();
  385.         MessageType messageType = accordoServizio.getMessageType();
  386.         
  387.         StatoFunzionalita confermaRicezione = accordoServizio.getConfermaRicezione();
  388.         StatoFunzionalita conegnaInOrdine = accordoServizio.getConsegnaInOrdine();
  389.         String descrizione = accordoServizio.getDescrizione();
  390.         StatoFunzionalita filtroDuplicati = accordoServizio.getFiltroDuplicati();
  391.         StatoFunzionalita identificativoCollaborazione = accordoServizio.getIdCollaborazione();
  392.         StatoFunzionalita identificativoRiferimentoRichiesta = accordoServizio.getIdRiferimentoRichiesta();

  394.         ProfiloCollaborazione profiloCollaborazione = accordoServizio.getProfiloCollaborazione();
  395.         String scadenza = accordoServizio.getScadenza();
  396.         boolean utilizzioSenzaAzione = accordoServizio.getUtilizzoSenzaAzione();

  398.         FormatoSpecifica formatoSpecifica = accordoServizio.getFormatoSpecifica();
  399.         
  400.         String wsdlConcettuale = (accordoServizio.getByteWsdlConcettuale()!=null ? new String(accordoServizio.getByteWsdlConcettuale()) : null);
  401.         String wsdlDefinitorio = (accordoServizio.getByteWsdlDefinitorio()!=null ? new String(accordoServizio.getByteWsdlDefinitorio()) : null);
  402.         String wsdlLogicoErogatore = (accordoServizio.getByteWsdlLogicoErogatore()!=null ? new String(accordoServizio.getByteWsdlLogicoErogatore()) : null);
  403.         String wsdlLogicoFruitore = (accordoServizio.getByteWsdlLogicoFruitore()!=null ? new String(accordoServizio.getByteWsdlLogicoFruitore()) : null);
  404.         String conversazioneConcettuale = (accordoServizio.getByteSpecificaConversazioneConcettuale()!=null ? new String(accordoServizio.getByteSpecificaConversazioneConcettuale()) : null);
  405.         String conversazioneErogatore = (accordoServizio.getByteSpecificaConversazioneErogatore()!=null ? new String(accordoServizio.getByteSpecificaConversazioneErogatore()) : null);
  406.         String conversazioneFruitore = (accordoServizio.getByteSpecificaConversazioneFruitore()!=null ? new String(accordoServizio.getByteSpecificaConversazioneFruitore()) : null);
  407.         String superUser = accordoServizio.getSuperUser();

  409.         wsdlConcettuale = wsdlConcettuale!=null && !"".equals(wsdlConcettuale.trim().replace("\n", "")) ? wsdlConcettuale : null;
  410.         wsdlDefinitorio = wsdlDefinitorio!=null && !"".equals(wsdlDefinitorio.trim().replace("\n", "")) ? wsdlDefinitorio : null;
  411.         wsdlLogicoErogatore = wsdlLogicoErogatore!=null && !"".equals(wsdlLogicoErogatore.trim().replace("\n", "")) ? wsdlLogicoErogatore : null;
  412.         wsdlLogicoFruitore = wsdlLogicoFruitore!=null && !"".equals(wsdlLogicoFruitore.trim().replace("\n", "")) ? wsdlLogicoFruitore : null;
  413.         conversazioneConcettuale = conversazioneConcettuale!=null && !"".equals(conversazioneConcettuale.trim().replace("\n", "")) ? conversazioneConcettuale : null;
  414.         conversazioneErogatore = conversazioneErogatore!=null && !"".equals(conversazioneErogatore.trim().replace("\n", "")) ? conversazioneErogatore : null;
  415.         conversazioneFruitore = conversazioneFruitore!=null && !"".equals(conversazioneFruitore.trim().replace("\n", "")) ? conversazioneFruitore : null;

  417.         try {

  419.             IDAccordo idAccordoAttualeInseritoDB = null;
  420.             if(accordoServizio.getOldIDAccordoForUpdate()!=null){
  421.                 idAccordoAttualeInseritoDB = accordoServizio.getOldIDAccordoForUpdate();
  422.             }else{
  423.                 idAccordoAttualeInseritoDB = idAccordoFactory.getIDAccordoFromAccordo(accordoServizio);
  424.             }

  426.             long idAccordoLong = -1;
  427.             try{
  428.                 idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordoAttualeInseritoDB, con,DriverRegistroServiziDB_LIB.tipoDB);
  429.             }catch(Exception e){
  430.                 if(accordoServizio.getOldIDAccordoForUpdate()!=null){
  431.                     // Provo con soggetto attuale
  432.                     if(accordoServizio.getSoggettoReferente()!=null){
  433.                         idAccordoAttualeInseritoDB = idAccordoFactory.getIDAccordoFromValues(idAccordoAttualeInseritoDB.getNome(),
  434.                                 new IDSoggetto(accordoServizio.getSoggettoReferente().getTipo(),
  435.                                         accordoServizio.getSoggettoReferente().getNome()),
  436.                                         idAccordoAttualeInseritoDB.getVersione());
  437.                     }else{
  438.                         idAccordoAttualeInseritoDB = idAccordoFactory.getIDAccordoFromValues(idAccordoAttualeInseritoDB.getNome(),null,
  439.                                 idAccordoAttualeInseritoDB.getVersione());
  440.                     }
  441.                     idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordoAttualeInseritoDB, con,DriverRegistroServiziDB_LIB.tipoDB);
  442.                 }else{
  443.                     throw e;
  444.                 }
  445.             }
  446.             if (idAccordoLong <= 0)
  447.                 throw new DriverRegistroServiziException("Impossibile recuperare l'id dell'Accordo di Servizio : " + nome);

  449.             String utenteUltimaModifica = null;
  450.             if(accordoServizio.getProprietaOggetto()!=null && accordoServizio.getProprietaOggetto().getUtenteUltimaModifica()!=null) {
  451.                 utenteUltimaModifica = accordoServizio.getProprietaOggetto().getUtenteUltimaModifica();
  452.             }
  453.             else {
  454.                 utenteUltimaModifica = superUser;
  455.             }
  456.             
  457.             Timestamp dataUltimaModifica = null;
  458.             if(accordoServizio.getProprietaOggetto()!=null && accordoServizio.getProprietaOggetto().getDataUltimaModifica()!=null) {
  459.                 dataUltimaModifica = new Timestamp(accordoServizio.getProprietaOggetto().getDataUltimaModifica().getTime());
  460.             }
  461.             else {
  462.                 dataUltimaModifica = DateManager.getTimestamp();
  463.             }
  464.             
  465.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  466.             sqlQueryObject.addUpdateTable(CostantiDB.ACCORDI);
  467.             sqlQueryObject.addUpdateField("service_binding", "?");
  468.             sqlQueryObject.addUpdateField("message_type", "?");
  469.             sqlQueryObject.addUpdateField("conferma_ricezione", "?");
  470.             sqlQueryObject.addUpdateField("consegna_in_ordine", "?");
  471.             sqlQueryObject.addUpdateField("descrizione", "?");
  472.             sqlQueryObject.addUpdateField("filtro_duplicati", "?");
  473.             sqlQueryObject.addUpdateField("identificativo_collaborazione", "?");
  474.             sqlQueryObject.addUpdateField("id_riferimento_richiesta", "?");
  475.             sqlQueryObject.addUpdateField("nome", "?");
  476.             sqlQueryObject.addUpdateField("profilo_collaborazione", "?");
  477.             sqlQueryObject.addUpdateField("scadenza", "?");
  478.             sqlQueryObject.addUpdateField("formato_specifica", "?");
  479.             sqlQueryObject.addUpdateField("wsdl_concettuale", "?");
  480.             sqlQueryObject.addUpdateField("wsdl_definitorio", "?");
  481.             sqlQueryObject.addUpdateField("wsdl_logico_erogatore", "?");
  482.             sqlQueryObject.addUpdateField("wsdl_logico_fruitore", "?");
  483.             sqlQueryObject.addUpdateField("spec_conv_concettuale", "?");
  484.             sqlQueryObject.addUpdateField("spec_conv_erogatore", "?");
  485.             sqlQueryObject.addUpdateField("spec_conv_fruitore", "?");
  486.             sqlQueryObject.addUpdateField("superuser", "?");
  487.             sqlQueryObject.addUpdateField("utilizzo_senza_azione", "?");
  488.             sqlQueryObject.addUpdateField("privato", "?");

  490.             if(accordoServizio.getStatoPackage()!=null){
  491.                 sqlQueryObject.addUpdateField("stato", "?");
  492.             }

  494.             sqlQueryObject.addUpdateField("canale", "?");
  495.             
  496.             if(accordoServizio.getOraRegistrazione()!=null)
  497.                 sqlQueryObject.addUpdateField("ora_registrazione", "?");

  499.             sqlQueryObject.addUpdateField("id_referente", "?");
  500.             sqlQueryObject.addUpdateField("versione", "?");
  501.             
  502.             if(utenteUltimaModifica!=null) {
  503.                 sqlQueryObject.addUpdateField(CostantiDB.PROPRIETA_OGGETTO_UTENTE_ULTIMA_MODIFICA, "?");
  504.             }
  505.             if(dataUltimaModifica!=null) {
  506.                 sqlQueryObject.addUpdateField(CostantiDB.PROPRIETA_OGGETTO_DATA_ULTIMA_MODIFICA, "?");
  507.             }

  509.             sqlQueryObject.addWhereCondition("id=?");
  510.             sqlQuery = sqlQueryObject.createSQLUpdate();

  512.             stm = con.prepareStatement(sqlQuery);
  513.             int index = 1;
  514.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(serviceBinding));
  515.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(messageType));
  516.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(confermaRicezione));
  517.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(conegnaInOrdine));
  518.             stm.setString(index++, descrizione);
  519.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(filtroDuplicati));
  520.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(identificativoCollaborazione));
  521.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(identificativoRiferimentoRichiesta));
  522.             stm.setString(index++, nome);
  523.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(profiloCollaborazione));
  524.             stm.setString(index++, scadenza);
  525.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(formatoSpecifica));
  526.             stm.setString(index++, wsdlConcettuale);
  527.             stm.setString(index++, wsdlDefinitorio);
  528.             stm.setString(index++, wsdlLogicoErogatore);
  529.             stm.setString(index++, wsdlLogicoFruitore);
  530.             stm.setString(index++, conversazioneConcettuale);
  531.             stm.setString(index++, conversazioneErogatore);
  532.             stm.setString(index++, conversazioneFruitore);
  533.             stm.setString(index++, superUser);
  534.             stm.setInt(index++, utilizzioSenzaAzione ? CostantiDB.TRUE : CostantiDB.FALSE);
  535.             if(accordoServizio.getPrivato()!=null && accordoServizio.getPrivato())
  536.                 stm.setInt(index++, 1);
  537.             else
  538.                 stm.setInt(index++, 0);

  540.             if(accordoServizio.getStatoPackage()!=null){
  541.                 stm.setString(index++, accordoServizio.getStatoPackage());
  542.             }

  544.             stm.setString(index++, accordoServizio.getCanale());
  545.             
  546.             if(accordoServizio.getOraRegistrazione()!=null){
  547.                 stm.setTimestamp(index++, new Timestamp(accordoServizio.getOraRegistrazione().getTime()));
  548.             }

  550.             if(accordoServizio.getSoggettoReferente()!=null) {
  551.                 long idSRef = DBUtils.getIdSoggetto(accordoServizio.getSoggettoReferente().getNome(), 
  552.                         accordoServizio.getSoggettoReferente().getTipo(), con, DriverRegistroServiziDB_LIB.tipoDB,tabellaSoggetti);
  553.                 stm.setLong(index++, idSRef);
  554.             }else{
  555.                 stm.setLong(index++, CostantiRegistroServizi.SOGGETTO_REFERENTE_DEFAULT);
  556.             }
  557.             stm.setInt(index++, accordoServizio.getVersione());

  559.             if(utenteUltimaModifica!=null) {
  560.                 stm.setString(index++, utenteUltimaModifica);
  561.             }
  562.             
  563.             if(dataUltimaModifica!=null) {
  564.                 stm.setTimestamp(index++, dataUltimaModifica);
  565.             }
  566.             
  567.             stm.setLong(index++, idAccordoLong);

  569.             String msgDebug = "update accordoServizio : " + 
  570.                     DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, 
  571.                             serviceBinding, messageType,
  572.                             confermaRicezione, conegnaInOrdine, descrizione, 
  573.                             filtroDuplicati, identificativoCollaborazione, identificativoRiferimentoRichiesta, nome, profiloCollaborazione, scadenza, 
  574.                             wsdlConcettuale, wsdlDefinitorio, wsdlLogicoErogatore, wsdlLogicoFruitore, 
  575.                             conversazioneConcettuale, conversazioneErogatore, conversazioneFruitore,
  576.                             superUser,utilizzioSenzaAzione, idAccordoLong);
  577.             logDebug(log, msgDebug);

  579.             stm.executeUpdate();
  580.             stm.close();

  582.             //aggiorno le azioni
  583.             //possibile ottimizzazione
  584.             //la lista contiene tutte e sole le azioni necessarie
  585.             //prima cancello le azioni e poi reinserisco quelle nuove
  586.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  587.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_AZIONI);
  588.             sqlQueryObject.addWhereCondition("id_accordo=?");
  589.             String updateString = sqlQueryObject.createSQLDelete();
  590.             stm = con.prepareStatement(updateString);
  591.             stm.setLong(1, idAccordoLong);
  592.             int n=stm.executeUpdate();
  593.             stm.close();
  594.             logDebug(log, "Cancellate "+n+" azioni associate all'accordo "+idAccordoLong);

  596.             for (int i = 0; i < accordoServizio.sizeAzioneList(); i++) {
  597.                 Azione azione = accordoServizio.getAzione(i);
  598.                 String profiloAzione = azione.getProfAzione();
  599.                 //se profilo azione = default allora utilizzo il profilo collaborazione dell'accordo
  600.                 if(profiloAzione!=null && profiloAzione.equals(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT))
  601.                 {
  602.                     azione.setProfiloCollaborazione(profiloCollaborazione);
  603.                 }
  604.                 DriverRegistroServiziDB_accordiSoapLIB.CRUDAzione(CostantiDB.CREATE, accordoServizio,azione, con, idAccordoLong, driverBYOK);
  605.             }
  606.             logDebug(log, "Inserite "+accordoServizio.sizeAzioneList()+" azioni associate all'accordo "+idAccordoLong);

  608.             //aggiorno i port type
  609.             //la lista contiene tutte e soli i port type necessari
  610.             //prima cancello i port type e poi reinserisco quelle nuove

  612.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  613.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  614.             sqlQueryObject.addSelectField("id");
  615.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  616.             sqlQuery = sqlQueryObject.createSQLQuery();
  617.             stm=con.prepareStatement(sqlQuery);
  618.             stm.setLong(1, idAccordoLong);
  619.             rs=stm.executeQuery();
  620.             List<Long> idPT = new ArrayList<>();
  621.             while(rs.next()){
  622.                 idPT.add(rs.getLong("id"));
  623.             }
  624.             rs.close();
  625.             stm.close();
  626.             logDebug(log, "Trovati "+idPT.size()+" port type...");

  628.             while(!idPT.isEmpty()){
  629.                 Long idPortType = idPT.remove(0);

  631.                 // Seleziono id port type azione
  632.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  633.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  634.                 sqlQueryObject.addSelectField("id");
  635.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  636.                 sqlQueryObject.setANDLogicOperator(true);
  637.                 sqlQuery = sqlQueryObject.createSQLQuery();
  638.                 stm=con.prepareStatement(sqlQuery);
  639.                 stm.setLong(1, idPortType);
  640.                 rs=stm.executeQuery();
  641.                 List<Long> idPTAzione = new ArrayList<>();
  642.                 while(rs.next()){
  643.                     idPTAzione.add(rs.getLong("id"));
  644.                 }
  645.                 rs.close();
  646.                 stm.close();

  648.                 logDebug(log, "Trovati "+idPTAzione.size()+" port type azioni...");

  650.                 // Elimino i messages
  651.                 while(!idPTAzione.isEmpty()){
  652.                     Long idPortTypeAzione = idPTAzione.remove(0);
  653.                     logDebug(log, "Eliminazione message con id["+idPortTypeAzione+"]...");
  654.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  655.                     sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  656.                     sqlQueryObject.addWhereCondition("id_port_type_azione=?");
  657.                     sqlQueryObject.setANDLogicOperator(true);
  658.                     sqlQuery = sqlQueryObject.createSQLDelete();
  659.                     stm=con.prepareStatement(sqlQuery);
  660.                     stm.setLong(1, idPortTypeAzione);
  661.                     n=stm.executeUpdate();
  662.                     stm.close();
  663.                     logDebug(log, "Cancellate "+n+" messages di un'azione con id["+idPortTypeAzione+"] del port type ["+idPortType+"] associate all'accordo "+idAccordoLong);
  664.                 }

  666.                 logDebug(log, "Elimino port type azione del port types ["+idPortType+"]...");

  668.                 // Elimino port types azioni
  669.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  670.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  671.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  672.                 sqlQueryObject.setANDLogicOperator(true);
  673.                 sqlQuery = sqlQueryObject.createSQLDelete();
  674.                 stm=con.prepareStatement(sqlQuery);
  675.                 stm.setLong(1, idPortType);
  676.                 n=stm.executeUpdate();
  677.                 stm.close();
  678.                 logDebug(log, "Cancellate "+n+" azioni del port type ["+idPortType+"] associate all'accordo "+idAccordoLong);
  679.             }

  681.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  682.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE);
  683.             sqlQueryObject.addWhereCondition("id_accordo=?");
  684.             sqlQueryObject.setANDLogicOperator(true);
  685.             sqlQuery = sqlQueryObject.createSQLDelete();
  686.             stm=con.prepareStatement(sqlQuery);
  687.             stm.setLong(1, idAccordoLong);
  688.             n=stm.executeUpdate();
  689.             stm.close();
  690.             logDebug(log, "Cancellate "+n+" port type associate all'accordo "+idAccordoLong);

  692.             PortType pt = null;
  693.             for (int i = 0; i < accordoServizio.sizePortTypeList(); i++) {
  694.                 pt = accordoServizio.getPortType(i);
  695.                 DriverRegistroServiziDB_accordiSoapLIB.CRUDPortType(CostantiDB.CREATE,accordoServizio,pt, con, idAccordoLong, driverBYOK);
  696.             }
  697.             logDebug(log, "inserite " + accordoServizio.sizePortTypeList() + " porttype relative all'accordo :" + nome + " id :" + idAccordoLong);

  699.             // risorse
  700.             //la lista contiene tutte e sole le risorse necessarie
  701.             //prima cancello le risorse e poi reinserisco quelle nuove
  702.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  703.             sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  704.             sqlQueryObject.addSelectField("id");
  705.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  706.             sqlQuery = sqlQueryObject.createSQLQuery();
  707.             stm=con.prepareStatement(sqlQuery);
  708.             stm.setLong(1, idAccordoLong);
  709.             rs=stm.executeQuery();
  710.             List<Long> idResources = new ArrayList<>();
  711.             while(rs.next()){
  712.                 idResources.add(rs.getLong("id"));
  713.             }
  714.             rs.close();
  715.             stm.close();
  716.     
  717.             n=0;
  718.             while(!idResources.isEmpty()){
  719.                 Long idR = idResources.remove(0);
  720.                 Resource resource = new Resource();
  721.                 resource.setId(idR);
  722.                 n = n + DriverRegistroServiziDB_accordiRestLIB.CRUDResource(CostantiDB.DELETE, accordoServizio, resource, con, idAccordoLong, driverBYOK);
  723.             }
  724.             logDebug(log, "Cancellate "+n+" resources associate all'accordo :" + nome + " id :" + idAccordoLong);
  725.             
  726.             Resource resource = null;
  727.             for (int i = 0; i < accordoServizio.sizeResourceList(); i++) {
  728.                 resource = accordoServizio.getResource(i);
  729.                 DriverRegistroServiziDB_accordiRestLIB.CRUDResource(CostantiDB.CREATE,accordoServizio,resource, con, idAccordoLong, driverBYOK);
  730.             }
  731.             logDebug(log, "inserite " + accordoServizio.sizeResourceList() + " resources relative all'accordo :" + nome + " id :" + idAccordoLong);
  732.             
  733.             
  734.             
  735.             // Gruppi
  736.             //la lista contiene tutte e sole le risorse necessarie
  737.             //prima cancello le risorse e poi reinserisco quelle nuove
  738.             
  739.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  740.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  741.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  742.             sqlQueryObject.addSelectAliasField(CostantiDB.GRUPPI, "id", "identificativoGruppo");
  743.             sqlQueryObject.addSelectAliasField(CostantiDB.GRUPPI, "nome", "nomeGruppo");
  744.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_gruppo = "+CostantiDB.GRUPPI+".id");
  745.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_accordo = ?");
  746.             sqlQueryObject.setANDLogicOperator(true);
  747.             sqlQuery = sqlQueryObject.createSQLQuery();
  748.             stm=con.prepareStatement(sqlQuery);
  749.             stm.setLong(1, idAccordoLong);
  750.             rs=stm.executeQuery();
  751.             List<GruppoAccordo> gruppi = new ArrayList<>();
  752.             while(rs.next()){
  753.                 GruppoAccordo gruppo = new GruppoAccordo();
  754.                 gruppo.setNome(rs.getString("nomeGruppo"));
  755.                 gruppo.setId(rs.getLong("identificativoGruppo"));
  756.                 gruppi.add(gruppo);
  757.             }
  758.             rs.close();
  759.             stm.close();
  760.     
  761.             while(!gruppi.isEmpty()){
  762.                 GruppoAccordo gruppo = gruppi.remove(0);
  763.                 DriverRegistroServiziDB_accordiLIB.CRUDAccordoGruppo(CostantiDB.DELETE, accordoServizio, gruppo, con, idAccordoLong);
  764.             }
  765.             logDebug(log, "Cancellate "+n+" resources associate all'accordo :" + nome + " id :" + idAccordoLong);
  766.             
  767.             if(accordoServizio.getGruppi()!=null && accordoServizio.getGruppi().sizeGruppoList()>0) {
  768.                 for (int i = 0; i < accordoServizio.getGruppi().sizeGruppoList(); i++) {
  769.                     GruppoAccordo gruppo = accordoServizio.getGruppi().getGruppo(i);
  770.                     DriverRegistroServiziDB_accordiLIB.CRUDAccordoGruppo(CostantiDB.CREATE,accordoServizio, gruppo, con, idAccordoLong);
  771.                 }
  772.                 logDebug(log, "inserite " + accordoServizio.sizeAzioneList() + " gruppi relative all'accordo :" + nome + " id :" + idAccordoLong);
  773.             }
  774.             
  775.             
  776.             
  777.             // Accordo servizio composto
  778.             if(accordoServizio.getServizioComposto()!=null){
  779.                 // Elimino eventualmente se prima era presente
  780.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.DELETE, 
  781.                         null, con, idAccordoLong);

  783.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.CREATE, 
  784.                         accordoServizio.getServizioComposto(), con, idAccordoLong);
  785.             }else{
  786.                 // Elimino eventualmente se prima era presente
  787.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.DELETE, 
  788.                         null, con, idAccordoLong);
  789.             }


  792.             // Documenti generici accordo di servizio
  793.             List<Documento> documenti = new ArrayList<Documento>();
  794.             // Allegati
  795.             for(int i=0; i<accordoServizio.sizeAllegatoList(); i++){
  796.                 Documento doc = accordoServizio.getAllegato(i);
  797.                 doc.setRuolo(RuoliDocumento.allegato.toString());
  798.                 documenti.add(doc);
  799.             }
  800.             // Specifiche Semiformali
  801.             for(int i=0; i<accordoServizio.sizeSpecificaSemiformaleList(); i++){
  802.                 Documento doc = accordoServizio.getSpecificaSemiformale(i);
  803.                 doc.setRuolo(RuoliDocumento.specificaSemiformale.toString());
  804.                 documenti.add(doc);
  805.             }
  806.             // Specifiche Coordinamento
  807.             if(accordoServizio.getServizioComposto()!=null){
  808.                 for(int i=0; i<accordoServizio.getServizioComposto().sizeSpecificaCoordinamentoList(); i++){
  809.                     Documento doc = accordoServizio.getServizioComposto().getSpecificaCoordinamento(i);
  810.                     doc.setRuolo(RuoliDocumento.specificaCoordinamento.toString());
  811.                     documenti.add(doc);
  812.                 }
  813.             }

  815.             // CRUD
  816.             DriverRegistroServiziDB_documentiLIB.CRUDDocumento(CostantiDB.UPDATE, documenti, idAccordoLong, ProprietariDocumento.accordoServizio, con, DriverRegistroServiziDB_LIB.tipoDB);

  818.             
  819.             // ProtocolProperties
  820.             DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.UPDATE, accordoServizio.getProtocolPropertyList(), 
  821.                     idAccordoLong, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_COMUNE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  822.             
  823.             
  824.         }catch (SQLException se) {
  825.             logError(log, se.getMessage(),se);
  826.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizio] SQLException [" + se.getMessage() + "].",se);
  827.         } 
  828.         catch (Exception se) {
  829.             logError(log, se.getMessage(),se);
  830.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoServizio] Exception [" + se.getMessage() + "].",se);
  831.         }finally {
  832.             JDBCUtilities.closeResources(rs, stm);
  833.         }

  835.     }
  836.     
  837.     
  838.     
  839.     public static long CRUDAccordoGruppo(int type, AccordoServizioParteComune as,GruppoAccordo gruppo, Connection con, long idAccordo) throws DriverRegistroServiziException {
  840.         PreparedStatement updateStmt = null;
  841.         String updateQuery;
  842.         long n = 0;
  843.         if (idAccordo <= 0)
  844.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAccordoGruppo] ID Accordo non valido.");
  845.         
  846.         try {
  847.             
  848.             IDGruppo idGruppo = new IDGruppo(gruppo.getNome());
  849.             long idGruppoLong = DBUtils.getIdGruppo(idGruppo, con, DriverRegistroServiziDB_LIB.tipoDB);
  850.             if(idGruppoLong<=0) {
  851.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAccordoGruppo] Gruppo con nome '"+idGruppo.getNome()+"' non esistente.");
  852.             }
  853.             
  854.             switch (type) {
  855.             case CREATE:
  856.                                 
  857.                 // create
  858.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  859.                 sqlQueryObject.addInsertTable(CostantiDB.ACCORDI_GRUPPI);
  860.                 sqlQueryObject.addInsertField("id_accordo", "?");
  861.                 sqlQueryObject.addInsertField("id_gruppo", "?");
  862.                 updateQuery = sqlQueryObject.createSQLInsert();
  863.                 updateStmt = con.prepareStatement(updateQuery);
  864.                 int index = 1;
  865.                 updateStmt.setLong(index++, idAccordo);
  866.                 updateStmt.setLong(index++, idGruppoLong);

  868.                 DriverRegistroServiziDB_LIB.logDebug("CRUDAccordoGruppo CREATE :\n"+
  869.                         DriverRegistroServiziDB_LIB.formatSQLString(updateQuery,idAccordo,idGruppoLong));
  870.                 n = updateStmt.executeUpdate();
  871.                 updateStmt.close();
  872.                 DriverRegistroServiziDB_LIB.logDebug("CRUDAccordoGruppo type = " + type + " row affected =" + n);

  874.                 break;

  876.             case UPDATE:
  877.                 
  878.                 throw new DriverRegistroServiziException("Non supportato");

  880.             case DELETE:
  881.                 // delete

  883.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  884.                 sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_GRUPPI);
  885.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  886.                 sqlQueryObject.addWhereCondition("id_gruppo=?");
  887.                 sqlQueryObject.setANDLogicOperator(true);
  888.                 String sqlQuery = sqlQueryObject.createSQLDelete();
  889.                 updateStmt = con.prepareStatement(sqlQuery);
  890.                 index = 1;
  891.                 updateStmt.setLong(index++, idAccordo);
  892.                 updateStmt.setLong(index++, idGruppoLong);
  893.                 n=updateStmt.executeUpdate();
  894.                 updateStmt.close();
  895.                 DriverRegistroServiziDB_LIB.logDebug("CRUDAccordoGruppo type = " + type + " row affected =" + n);
  896.                 
  897.                 break;
  898.             }

  900.             return n;

  902.         } catch (SQLException se) {
  903.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAccordoGruppo] SQLException : " + se.getMessage(),se);
  904.         } catch (Exception se) {
  905.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAccordoGruppo] Exception : " + se.getMessage(),se);
  906.         } finally {
  907.             JDBCUtilities.closeResources(updateStmt);
  908.         }
  909.     }
  910.     
  911.     

  913.     
  914.     public static ISQLQueryObject getSQLRicercaAccordiValidi() throws Exception{
  915.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  916.         
  917.         sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  918.         
  919.         sqlQueryObject.addWhereExistsCondition(false, DriverRegistroServiziDB_accordiLIB.getSQLRicercaServiziValidi(CostantiDB.ACCORDI+".id",false));
  920.         
  921.         return sqlQueryObject;
  922.     }
  923.     
  924.     /**
  925.      * 
  926.      * @return Ritorna l' ISQLQueryObject con ? settato come id accordo, in modo da poterlo usare con il setParameter dello statement
  927.      * @throws Exception
  928.      */
  929.     
  930.     public static ISQLQueryObject getSQLRicercaServiziValidiByIdAccordo(boolean isErogazione) throws Exception{
  931.         return DriverRegistroServiziDB_accordiLIB.getSQLRicercaServiziValidi("?",isErogazione);
  932.     }
  933.     
  934.     private static ISQLQueryObject getSQLRicercaServiziValidi(String idAccordo,boolean isErogazione) throws Exception{
  935.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  936.         
  937.         // select * from port_type where
  938.         sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  939.         // port_type.id_accordo=8 
  940.         sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo="+idAccordo);
  941.         //  (EXISTS (select * from port_type_azioni where port_type_azioni.id_port_type=port_type.id))  
  942.         ISQLQueryObject sqlQueryObjectExistsAlmenoUnAzione = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  943.         sqlQueryObjectExistsAlmenoUnAzione.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  944.         sqlQueryObjectExistsAlmenoUnAzione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  945.         sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectExistsAlmenoUnAzione);
  946.         // Gestione profili di collaborazione
  947.         ISQLQueryObject sqlQueryServiziValidi = DriverRegistroServiziDB_accordiLIB.getSQLIndividuazioneServiziValidi(DriverRegistroServiziDB_LIB.tipoDB,isErogazione);
  948.         sqlQueryObject.addWhereCondition("( "+sqlQueryServiziValidi.createSQLConditions()+" )");
  949.         // And tra le condizioni
  950.         sqlQueryObject.setANDLogicOperator(true);
  951.         return sqlQueryObject;
  952.     }
  953.     
  954.     public static ISQLQueryObject getSQLIndividuazioneServiziValidi(String tipoDatabase,boolean isErogazione) throws Exception{
  955.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  956.         
  957.         
  958.         // (port_type.profilo_collaborazione='oneway') 
  959.         sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".profilo_collaborazione='oneway'");
  960.         
  961.         
  962.         // (port_type.profilo_collaborazione='sincrono') 
  963.         sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".profilo_collaborazione='sincrono'");
  964.         
  965.         
  966.         // (      
  967.         //    port_type.profilo_collaborazione='asincronoAsimmetrico' AND 
  968.         //        
  969.         //    EXISTS (select * from port_type_azioni where port_type_azioni.id_port_type=port_type.id AND 
  970.         //                                                 port_type_azioni.correlata_servizio is null AND
  971.         //                                                 port_type_azioni.correlata is null
  972.         //            ) AND
  973.         //
  974.         //    EXISTS (select * from port_type_azioni where port_type_azioni.id_port_type=port_type.id AND 
  975.         //                                                 port_type_azioni.correlata_servizio is not null AND
  976.         //                                                 port_type_azioni.correlata_servizio=port_type.nome AND
  977.         //                                                 port_type_azioni.correlata is not null AND
  978.         //                                                 port_type_azioni.correlata IN (
  979.         //                                                      select nome from port_type_azioni where port_type_azioni.id_port_type=port_type.id)
  980.         //                                                 )
  981.         //           )
  982.         // )
  983.         ISQLQueryObject sqlQueryObjectExistsAsinAsimRichiesta = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  984.         sqlQueryObjectExistsAsinAsimRichiesta.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  985.         sqlQueryObjectExistsAsinAsimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  986.         sqlQueryObjectExistsAsinAsimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is null");
  987.         sqlQueryObjectExistsAsinAsimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata is null");
  988.         sqlQueryObjectExistsAsinAsimRichiesta.setANDLogicOperator(true);
  989.         
  990.         ISQLQueryObject sqlQueryObjectExistsAsinAsimRisposta = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  991.         sqlQueryObjectExistsAsinAsimRisposta.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  992.         sqlQueryObjectExistsAsinAsimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  993.         sqlQueryObjectExistsAsinAsimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is not null");
  994.         sqlQueryObjectExistsAsinAsimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio="+CostantiDB.PORT_TYPE+".nome");
  995.         sqlQueryObjectExistsAsinAsimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata is not null");
  996.         ISQLQueryObject sqlQueryObjectExistsAsinAsimRispostaCheckCorrelata = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  997.         sqlQueryObjectExistsAsinAsimRispostaCheckCorrelata.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  998.         sqlQueryObjectExistsAsinAsimRispostaCheckCorrelata.addSelectField(CostantiDB.PORT_TYPE_AZIONI, "nome");
  999.         sqlQueryObjectExistsAsinAsimRispostaCheckCorrelata.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  1000.         sqlQueryObjectExistsAsinAsimRisposta.addWhereINSelectSQLCondition(false, CostantiDB.PORT_TYPE_AZIONI+".correlata", sqlQueryObjectExistsAsinAsimRispostaCheckCorrelata);
  1001.         sqlQueryObjectExistsAsinAsimRisposta.setANDLogicOperator(true);
  1002.     
  1003.         sqlQueryObject.addWhereCondition(true, 
  1004.                 CostantiDB.PORT_TYPE+".profilo_collaborazione='asincronoAsimmetrico'",
  1005.                 sqlQueryObject.getWhereExistsCondition(false, sqlQueryObjectExistsAsinAsimRichiesta),
  1006.                 sqlQueryObject.getWhereExistsCondition(false,sqlQueryObjectExistsAsinAsimRisposta));    
  1007.         
  1008.         
  1009.         
  1010.         /** (
  1011.         //   port_type.profilo_collaborazione='asincronoSimmetrico' AND
  1012.         //
  1013.         //   EXISTS (select * from port_type_azioni where port_type_azioni.id_port_type=port_type.id AND 
  1014.         //                                               port_type_azioni.correlata is null AND 
  1015.         //                                               port_type_azioni.correlata_servizio is null
  1016.         //          ) AND
  1017.         //
  1018.         //   EXISTS (select * from port_type as ptRicerca2,port_type_azioni where 
  1019.         //                                    ptRicerca2.id_accordo=port_type.id_accordo AND 
  1020.         //                                    ptRicerca2.profilo_collaborazione='asincronoSimmetrico' AND
  1021.         //                                    ptRicerca2.nome <> port_type.nome AND
  1022.         //                                    port_type_azioni.id_port_type=ptRicerca2.id AND
  1023.         //                                    port_type_azioni.correlata_servizio is not null AND
  1024.         //                                    port_type_azioni.correlata_servizio=port_type.nome AND
  1025.         //                                    port_type_azioni.correlata is not null AND
  1026.         //                                    port_type_azioni.correlata IN (
  1027.         //                                        select nome from port_type_azioni where port_type_azioni.id_port_type=port_type.id
  1028.         //                                    )
  1029.         //           )
  1030.         // )*/
  1031.         
  1032.         ISQLQueryObject sqlQueryObjectExistsAsinSimRichiesta = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  1033.         sqlQueryObjectExistsAsinSimRichiesta.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1034.         sqlQueryObjectExistsAsinSimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  1035.         sqlQueryObjectExistsAsinSimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is null");
  1036.         sqlQueryObjectExistsAsinSimRichiesta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata is null");
  1037.         sqlQueryObjectExistsAsinSimRichiesta.setANDLogicOperator(true);
  1038.         
  1039.         ISQLQueryObject sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  1040.         String portTypeAliasRicerca = "ptRicerca2";
  1041.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addFromTable(CostantiDB.PORT_TYPE+" as "+portTypeAliasRicerca);
  1042.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1043.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(portTypeAliasRicerca+".id_accordo="+CostantiDB.PORT_TYPE+".id_accordo");
  1044.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(portTypeAliasRicerca+".profilo_collaborazione='asincronoSimmetrico'");
  1045.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(portTypeAliasRicerca+".nome <> "+CostantiDB.PORT_TYPE+".nome");
  1046.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+portTypeAliasRicerca+".id");
  1047.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is not null");
  1048.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio="+CostantiDB.PORT_TYPE+".nome");
  1049.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata is not null");
  1050.         ISQLQueryObject sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazioneCheckAzione = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  1051.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazioneCheckAzione.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1052.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazioneCheckAzione.addSelectField(CostantiDB.PORT_TYPE_AZIONI, "nome");
  1053.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazioneCheckAzione.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  1054.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.addWhereINSelectSQLCondition(false, CostantiDB.PORT_TYPE_AZIONI+".correlata", sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazioneCheckAzione);
  1055.         sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione.setANDLogicOperator(true);
  1056.             
  1057.         sqlQueryObject.addWhereCondition(true, 
  1058.                 CostantiDB.PORT_TYPE+".profilo_collaborazione='asincronoSimmetrico'",
  1059.                 sqlQueryObject.getWhereExistsCondition(false, sqlQueryObjectExistsAsinSimRichiesta),
  1060.                 sqlQueryObject.getWhereExistsCondition(false,sqlQueryObjectExistsAsinSimRichiestaCheckCorrelazione));
  1061.         
  1062.         
  1063.         
  1064.         /** (
  1065.         //    port_type.profilo_collaborazione='asincronoSimmetrico' AND
  1066.         //
  1067.         //    EXISTS (select * from port_type_azioni where port_type_azioni.id_port_type=port_type.id AND 
  1068.         //                                                 port_type_azioni.correlata is not null AND 
  1069.         //                                                 port_type_azioni.correlata_servizio is not null AND
  1070.         //                                                 EXISTS (select * from port_type as ptRicerca2,port_type_azioni ptAzioniRicerca2 where 
  1071.         //                                                          ptRicerca2.id_accordo=port_type.id_accordo AND 
  1072.         //                                                          ptRicerca2.profilo_collaborazione='asincronoSimmetrico' AND
  1073.         //                                                          ptRicerca2.nome <> port_type.nome AND
  1074.         //                                                          ptAzioniRicerca2.id_port_type=ptRicerca2.id AND
  1075.         //                                                          ptAzioniRicerca2.correlata_servizio is null AND
  1076.         //                                                          ptRicerca2.nome=port_type_azioni.correlata_servizio AND
  1077.         //                                                          ptAzioniRicerca2.correlata is null AND
  1078.         //                                                          ptAzioniRicerca2.nome=port_type_azioni.correlata
  1079.         //                                                  )
  1080.         //           ) 
  1081.         // )*/
  1082.         if(!isErogazione){
  1083.             ISQLQueryObject sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  1084.             String portTypeAliasRicercaAs = "ptRicerca2";
  1085.             String portTypeAzioniAliasRicercaAs = "ptAzioniRicerca2";
  1086.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addFromTable(CostantiDB.PORT_TYPE+" as "+portTypeAliasRicercaAs);
  1087.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addFromTable(CostantiDB.PORT_TYPE_AZIONI+" as "+portTypeAzioniAliasRicercaAs);
  1088.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAliasRicercaAs+".id_accordo="+CostantiDB.PORT_TYPE+".id_accordo");
  1089.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAliasRicercaAs+".profilo_collaborazione='asincronoSimmetrico'");
  1090.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAliasRicercaAs+".nome <> "+CostantiDB.PORT_TYPE+".nome");
  1091.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAzioniAliasRicercaAs+".id_port_type="+portTypeAliasRicercaAs+".id");
  1092.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAzioniAliasRicercaAs+".correlata_servizio is null");
  1093.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAliasRicercaAs+".nome="+CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio");
  1094.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAzioniAliasRicercaAs+".correlata is null");
  1095.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.addWhereCondition(portTypeAzioniAliasRicercaAs+".nome="+CostantiDB.PORT_TYPE_AZIONI+".correlata");
  1096.             
  1097.             sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione.setANDLogicOperator(true);
  1098.             
  1099.             ISQLQueryObject sqlQueryObjectExistsAsinSimRisposta = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  1100.             sqlQueryObjectExistsAsinSimRisposta.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1101.             sqlQueryObjectExistsAsinSimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type="+CostantiDB.PORT_TYPE+".id");
  1102.             sqlQueryObjectExistsAsinSimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata is not null");
  1103.             sqlQueryObjectExistsAsinSimRisposta.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is not null");
  1104.             sqlQueryObjectExistsAsinSimRisposta.addWhereExistsCondition(false, sqlQueryObjectExistsAsinSimRispostaCheckCorrelazione);
  1105.             sqlQueryObjectExistsAsinSimRisposta.setANDLogicOperator(true);
  1106.             
  1107.             sqlQueryObject.addWhereCondition(true, 
  1108.                     CostantiDB.PORT_TYPE+".profilo_collaborazione='asincronoSimmetrico'",
  1109.                     sqlQueryObject.getWhereExistsCondition(false, sqlQueryObjectExistsAsinSimRisposta));
  1110.         }
  1111.                 
  1112.         
  1113.         // OR tra le condizioni
  1114.         sqlQueryObject.setANDLogicOperator(false);
  1115.         
  1116.         return sqlQueryObject;   
  1117.              
  1118.     }
  1119.     
  1120.     
  1121.     
  1122.     public static void deleteAccordoServizioParteComune(org.openspcoop2.core.registry.AccordoServizioParteComune accordoServizio, 
  1123.             Connection con, String tabellaSoggetti, Logger log, IDAccordoFactory idAccordoFactory, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {

  1125.         if(tabellaSoggetti!=null) {
  1126.             // nop
  1127.         }
  1128.         
  1129.         if (accordoServizio == null)
  1130.             throw new DriverRegistroServiziException(ACCORDO_DIVERSO_NULL);

  1132.         String nome = accordoServizio.getNome();
  1133.         if (nome == null || nome.equals(""))
  1134.             throw new DriverRegistroServiziException(NOME_ACCORDO_NON_VALIDO);

  1136.         PreparedStatement stm = null;
  1137.         ResultSet rs = null;
  1138.         String sqlQuery = "";

  1140.         

  1142.         try {

  1144.             IDAccordo idAccordo = idAccordoFactory.getIDAccordoFromValues(nome,BeanUtilities.getSoggettoReferenteID(accordoServizio.getSoggettoReferente()),accordoServizio.getVersione());
  1145.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordo, con, DriverRegistroServiziDB_LIB.tipoDB);
  1146.             if (idAccordoLong <= 0)
  1147.                 throw new DriverRegistroServiziException("Impossibile recuperare l'id dell'Accordo di Servizio : " + nome);

  1149.             // elimino tutte le azioni correlate con questo accordo
  1150.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1151.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_AZIONI);
  1152.             sqlQueryObject.addWhereCondition("id_accordo=?");
  1153.             String updateString = sqlQueryObject.createSQLDelete();
  1154.             stm = con.prepareStatement(updateString);
  1155.             stm.setLong(1, idAccordoLong);
  1156.             logDebug(log, "delete azioni :" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  1157.             int n=stm.executeUpdate();
  1158.             stm.close();
  1159.             logDebug(log, "cancellate " + n + " azioni.");

  1161.             
  1162.             // elimino tutte i port type e struttura interna
  1163.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1164.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1165.             sqlQueryObject.addSelectField("id");
  1166.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  1167.             sqlQuery = sqlQueryObject.createSQLQuery();
  1168.             stm=con.prepareStatement(sqlQuery);
  1169.             stm.setLong(1, idAccordoLong);
  1170.             rs=stm.executeQuery();
  1171.             List<Long> idPT = new ArrayList<>();
  1172.             while(rs.next()){
  1173.                 idPT.add(rs.getLong("id"));
  1174.             }
  1175.             rs.close();
  1176.             stm.close();

  1178.             while(!idPT.isEmpty()){
  1179.                 Long idPortType = idPT.remove(0);

  1181.                 // gestione operation_messages
  1182.                 List<Long> idPortTypeAzioni = new ArrayList<>();
  1183.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1184.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1185.                 sqlQueryObject.addSelectField("id");
  1186.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  1187.                 sqlQuery = sqlQueryObject.createSQLQuery();
  1188.                 stm=con.prepareStatement(sqlQuery);
  1189.                 stm.setLong(1, idPortType);
  1190.                 rs=stm.executeQuery();
  1191.                 while(rs.next()){
  1192.                     idPortTypeAzioni.add(rs.getLong("id"));
  1193.                 }
  1194.                 rs.close();
  1195.                 stm.close();

  1197.                 while(!idPortTypeAzioni.isEmpty()){
  1198.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1199.                     sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  1200.                     sqlQueryObject.addWhereCondition("id_port_type_azione=?");
  1201.                     sqlQueryObject.setANDLogicOperator(true);
  1202.                     sqlQuery = sqlQueryObject.createSQLDelete();
  1203.                     stm=con.prepareStatement(sqlQuery);
  1204.                     stm.setLong(1, idPortTypeAzioni.remove(0));
  1205.                     n=stm.executeUpdate();
  1206.                     stm.close();
  1207.                 }

  1209.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1210.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  1211.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  1212.                 sqlQueryObject.setANDLogicOperator(true);
  1213.                 sqlQuery = sqlQueryObject.createSQLDelete();
  1214.                 stm=con.prepareStatement(sqlQuery);
  1215.                 stm.setLong(1, idPortType);
  1216.                 n=stm.executeUpdate();
  1217.                 stm.close();
  1218.                 logDebug(log, "Cancellate "+n+" azioni del port type ["+idPortType+"] associate all'accordo "+idAccordoLong);
  1219.             }

  1221.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1222.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE);
  1223.             sqlQueryObject.addWhereCondition("id_accordo=?");
  1224.             sqlQueryObject.setANDLogicOperator(true);
  1225.             sqlQuery = sqlQueryObject.createSQLDelete();
  1226.             stm=con.prepareStatement(sqlQuery);
  1227.             stm.setLong(1, idAccordoLong);
  1228.             n=stm.executeUpdate();
  1229.             stm.close();
  1230.             logDebug(log, "Cancellate "+n+" port type associate all'accordo "+idAccordoLong);

  1232.             
  1233.             
  1234.             // Risorse
  1235.             // elimino tutte le risorse api comprese di struttura interna
  1236.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1237.             sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  1238.             sqlQueryObject.addSelectField("id");
  1239.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  1240.             sqlQuery = sqlQueryObject.createSQLQuery();
  1241.             stm=con.prepareStatement(sqlQuery);
  1242.             stm.setLong(1, idAccordoLong);
  1243.             rs=stm.executeQuery();
  1244.             List<Long> idResources = new ArrayList<>();
  1245.             while(rs.next()){
  1246.                 idResources.add(rs.getLong("id"));
  1247.             }
  1248.             rs.close();
  1249.             stm.close();
  1250.     
  1251.             while(!idResources.isEmpty()){
  1252.                 Long idR = idResources.remove(0);
  1253.                 Resource resource = new Resource();
  1254.                 resource.setId(idR);
  1255.                 DriverRegistroServiziDB_accordiRestLIB.CRUDResource(CostantiDB.DELETE, accordoServizio, resource, con, idAccordoLong, driverBYOK);
  1256.             }
  1257.             
  1258.             
  1259.             // Gruppi
  1260.             //la lista contiene tutte e sole le risorse necessarie
  1261.             //prima cancello le risorse e poi reinserisco quelle nuove
  1262.             
  1263.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1264.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  1265.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  1266.             sqlQueryObject.addSelectAliasField(CostantiDB.GRUPPI, "id", "identificativoGruppo");
  1267.             sqlQueryObject.addSelectAliasField(CostantiDB.GRUPPI, "nome", "nomeGruppo");
  1268.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_gruppo = "+CostantiDB.GRUPPI+".id");
  1269.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_accordo = ?");
  1270.             sqlQueryObject.setANDLogicOperator(true);
  1271.             sqlQuery = sqlQueryObject.createSQLQuery();
  1272.             stm=con.prepareStatement(sqlQuery);
  1273.             stm.setLong(1, idAccordoLong);
  1274.             rs=stm.executeQuery();
  1275.             List<GruppoAccordo> gruppi = new ArrayList<>();
  1276.             while(rs.next()){
  1277.                 GruppoAccordo gruppo = new GruppoAccordo();
  1278.                 gruppo.setNome(rs.getString("nomeGruppo"));
  1279.                 gruppo.setId(rs.getLong("identificativoGruppo"));
  1280.                 gruppi.add(gruppo);
  1281.             }
  1282.             rs.close();
  1283.             stm.close();
  1284.     
  1285.             while(!gruppi.isEmpty()){
  1286.                 GruppoAccordo gruppo = gruppi.remove(0);
  1287.                 DriverRegistroServiziDB_accordiLIB.CRUDAccordoGruppo(CostantiDB.DELETE, accordoServizio, gruppo, con, idAccordoLong);
  1288.             }
  1289.             logDebug(log, "Cancellate "+n+" resources associate all'accordo :" + nome + " id :" + idAccordoLong);
  1290.             
  1291.             
  1292.             
  1293.             // Documenti generici accordo di servizio
  1294.             // Allegati
  1295.             // Specifiche Semiformali
  1296.             // Speficiche Coordinamento
  1297.             DriverRegistroServiziDB_documentiLIB.CRUDDocumento(CostantiDB.DELETE, null, idAccordoLong, ProprietariDocumento.accordoServizio, con, DriverRegistroServiziDB_LIB.tipoDB);


  1300.             // Accordo servizio composto
  1301.             if(accordoServizio.getServizioComposto()!=null){
  1302.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.DELETE, 
  1303.                         accordoServizio.getServizioComposto(), con, idAccordoLong);
  1304.             }else{
  1305.                 DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoServizioParteComuneServizioComposto(CostantiDB.DELETE, 
  1306.                         null, con, idAccordoLong);
  1307.             }

  1309.             
  1310.             // ProtocolProperties
  1311.             DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.DELETE, null, 
  1312.                     idAccordoLong, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_COMUNE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  1313.             

  1315.             // elimino accordoservizio
  1316.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  1317.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI);
  1318.             sqlQueryObject.addWhereCondition("id=?");
  1319.             updateString = sqlQueryObject.createSQLDelete();
  1320.             stm = con.prepareStatement(updateString);
  1321.             stm.setLong(1, idAccordoLong);
  1322.             logDebug(log, "delete accordoServizio :" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  1323.             stm.executeUpdate();
  1324.             stm.close();


  1327.         } catch (SQLException se) {
  1328.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizio] SQLException [" + se.getMessage() + "].",se);
  1329.         } catch (Exception se) {
  1330.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoServizio] Exception [" + se.getMessage() + "].",se);
  1331.         }finally {
  1332.             JDBCUtilities.closeResources(rs, stm);
  1333.         }
  1334.     }
  1335.     
  1336. }
Created with JaCoCo 0.8.8.202204050719