OpenSPCoop2DBConfigurationUtility.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.pdd.config;

  25. import java.io.FileInputStream;
  26. import java.sql.Connection;
  27. import java.sql.DriverManager;
  28. import java.util.ArrayList;
  29. import java.util.List;

  31. import org.openspcoop2.core.commons.CoreException;
  32. import org.openspcoop2.core.config.PortaApplicativa;
  33. import org.openspcoop2.core.config.PortaDelegata;
  34. import org.openspcoop2.core.config.ServizioApplicativo;
  35. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  36. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  37. import org.openspcoop2.core.id.IDAccordo;
  38. import org.openspcoop2.core.id.IDPortaApplicativa;
  39. import org.openspcoop2.core.id.IDServizio;
  40. import org.openspcoop2.core.id.IDServizioApplicativo;
  41. import org.openspcoop2.core.id.IDSoggetto;
  42. import org.openspcoop2.core.mapping.DBMappingUtils;
  43. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  44. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  45. import org.openspcoop2.core.registry.Fruitore;
  46. import org.openspcoop2.core.registry.IdSoggetto;
  47. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  48. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  49. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  50. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  51. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  52. import org.openspcoop2.utils.LoggerWrapperFactory;
  53. import org.openspcoop2.utils.Utilities;
  54. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  55. import org.openspcoop2.utils.resources.GestoreJNDI;
  56. import org.openspcoop2.utils.resources.Loader;
  57. import org.slf4j.Logger;

  59. /**
  60.  * Inizializza una configurazione
  61.  * 
  62.  * @author Andrea Poli (apoli@link.it)
  63.  * @author $Author$
  64.  * @version $Rev$, $Date$
  65.  */

  67. public class OpenSPCoop2DBConfigurationUtility {

  69.     private static final String TIPOLOGIA_ELIMINAZIONE_FRUIZIONE = "fruizione";
  70.     private static final String TIPOLOGIA_ELIMINAZIONE_EROGAZIONE = "erogazione";

  72.     private static void logError(Logger log,String msg, Exception e) {
  73.         if(log!=null) {
  74.             log.error(msg, e);
  75.         }
  76.     }
  77.     private static void logDebug(Logger log,String msg) {
  78.         if(log!=null) {
  79.             log.debug(msg);
  80.         }
  81.     }
  82.     
  83.     public static void main(String[] args) throws Exception {

  85.         
  86.                                        
  87.         if (args.length  < 4) {
  88.             String errorMsg = "ERROR, Usage:  java OpenSPCoop2DBConfigurationUtility proprietaAccessoDatabase tipologiaEliminazione(fruzione/erogazione) servizio(tipo/nome) soggettoErogatoreServizio(tipo/nome o *) fruitore(SOLO se tipologia=fruizione) [Logger]";
  89.             System.err.println(errorMsg);
  90.             throw new CoreException(errorMsg);
  91.         }

  93.         // proprietaAccessoDatabase
  94.         if(args[0]==null){
  95.             throw new CoreException("Proprieta' per la configurazione dell'accesso al database non fornite");
  96.         }
  97.         String proprietaAccessoDatabase = args[0].trim();
  98.         
  99.         // tipologiaEliminazione
  100.         if(args[1]==null){
  101.             throw new CoreException("Tipo di eliminazione non indicata");
  102.         }
  103.         String tipologiaEliminazione = args[1].trim();
  104.         if( !OpenSPCoop2DBConfigurationUtility.TIPOLOGIA_ELIMINAZIONE_EROGAZIONE.equals(tipologiaEliminazione) && !OpenSPCoop2DBConfigurationUtility.TIPOLOGIA_ELIMINAZIONE_FRUIZIONE.equals(tipologiaEliminazione) ){
  105.             throw new CoreException("Tipo di eliminazione non gestito");
  106.         }
  107.         
  108.         // dati del servizio
  109.         if(args[2]==null){
  110.             throw new Exception("Servizio da eliminare non indicato");
  111.         }
  112.         String tipoNomeServizio = args[2].trim();
  113.         if(tipoNomeServizio.contains("/")==false){
  114.             throw new Exception("Servizio da eliminare non indicato correttamente, atteso: tipo/nome");
  115.         }
  116.         String tipoServizio = null;
  117.         String nomeServizio = null;
  118.         try{
  119.             tipoServizio = tipoNomeServizio.split("/")[0].trim();
  120.             nomeServizio = tipoNomeServizio.split("/")[1].trim();
  121.         }catch(Exception e){
  122.             throw new CoreException("Servizio da eliminare non indicato correttamente, atteso: tipo/nome , errore: "+e.getMessage(),e);
  123.         }
  124.         
  125.         // dati del soggetto erogatore
  126.         if(args[3]==null){
  127.             throw new CoreException("Soggetto da eliminare non indicato");
  128.         }
  129.         String tipoNomeSoggetto = args[3].trim();
  130.         String tipoSoggettoErogatore = null;
  131.         String nomeSoggettoErogatore = null;
  132.         if("*".equals(tipoNomeSoggetto)){
  133.             // voglio qualsiasi servizio
  134.         }
  135.         else if(!tipoNomeSoggetto.contains("/")){
  136.             throw new CoreException("Soggetto erogatore del servizio da eliminare non indicato correttamente, atteso: tipo/nome");
  137.         }
  138.         else{
  139.             try{
  140.                 tipoSoggettoErogatore = tipoNomeSoggetto.split("/")[0].trim();
  141.                 nomeSoggettoErogatore = tipoNomeSoggetto.split("/")[1].trim();
  142.             }catch(Exception e){
  143.                 throw new CoreException("Soggetto erogatore del servizio da eliminare non indicato correttamente, atteso: tipo/nome , errore: "+e.getMessage(),e);
  144.             }
  145.         }
  146.         
  147.         int logIndex = 4;
  148.         
  149.         // dati del fruitore se tipologia = fruizione
  150.         String tipoSoggettoFruitore = null;
  151.         String nomeSoggettoFruitore = null;
  152.         if(OpenSPCoop2DBConfigurationUtility.TIPOLOGIA_ELIMINAZIONE_FRUIZIONE.equals(tipologiaEliminazione)){
  153.             logIndex++;
  154.             String tipoNomeSoggettoFruitore = args[4].trim();
  155.             if(tipoNomeSoggettoFruitore==null){
  156.                 throw new CoreException("Soggetto fruitore da eliminare non indicato");
  157.             }
  158.             else if(tipoNomeSoggettoFruitore.contains("/")==false){
  159.                 throw new CoreException("Soggetto fruitore da eliminare non indicato correttamente, atteso: tipo/nome");
  160.             }
  161.             try{
  162.                 tipoSoggettoFruitore = tipoNomeSoggettoFruitore.split("/")[0].trim();
  163.                 nomeSoggettoFruitore = tipoNomeSoggettoFruitore.split("/")[1].trim();
  164.             }catch(Exception e){
  165.                 throw new CoreException("Soggetto fruitore da eliminare non indicato correttamente, atteso: tipo/nome , errore: "+e.getMessage(),e);
  166.             }
  167.         }
  168.         
  169.         // Inizializzo logger
  170.         try{
  171.             if(args.length==(logIndex+1)){
  172.                 LoggerWrapperFactory.setLogConfiguration(args[logIndex]);
  173.             }else{
  174.                 LoggerWrapperFactory.setLogConfiguration(OpenSPCoop2DBConfigurationUtility.class.getResource("/console.log4j2.properties"));
  175.             }
  176.         }catch(Exception e) {
  177.             String errorMsg = "Errore durante il caricamento del file di log args"+logIndex+"["+args[logIndex]+"] : "+e.getMessage();
  178.             System.err.println(errorMsg);
  179.             throw new CoreException(errorMsg);
  180.         }   
  181.         Logger log = LoggerWrapperFactory.getLogger("gestoreEliminazioneServizio");
  182.         
  183.         // Inizializzo file di properties contenente le configurazioni per l'accesso al database
  184.         java.util.Properties reader = new java.util.Properties();
  185.         try{
  186.             try(FileInputStream fin = new FileInputStream(proprietaAccessoDatabase)){
  187.                 reader.load(fin);
  188.             }
  189.         }catch(java.io.IOException e) {
  190.             String errorMsg = "Errore durante il caricamento del file di properties ["+proprietaAccessoDatabase+"] : "+e.getMessage();
  191.             logError(log,errorMsg,e);
  192.             throw new CoreException(errorMsg,e);
  193.         }
  194.         
  195.         
  196.         // Indicazione se siamo in un caso di ControlStation
  197.         String govwayConsole = reader.getProperty("openspcoop2.govwayConsole");
  198.         String tipoDatabase = null;
  199.         boolean govwayConsoleMode = false;
  200.         if(govwayConsole!=null){
  201.             govwayConsoleMode = Boolean.parseBoolean(govwayConsole.trim());
  202.         }
  203.         
  204.         
  205.         

  207.         
  208.         // **** Raccolta proprieta' per accesso a configurazione *******
  209.         
  210.         Connection connectionConfigurazione = null;
  211.         DriverConfigurazioneDB driverConfigurazione = null;
  212.         try{
  213.             
  214.             
  215.             String connection = null;
  216.             String username = null;
  217.             String password = null;
  218.             String driver =  null;
  219.             boolean condivisioneDBRegservPddValue = false;
  220.                         
  221.             // Database
  222.             tipoDatabase = reader.getProperty("openspcoop2.configurazione.db.tipo");
  223.             if(tipoDatabase==null){
  224.                 throw new CoreException("Non e' stato definito il tipo di database per la configurazione");
  225.             }else{
  226.                 tipoDatabase = tipoDatabase.trim();
  227.             }
  228.             
  229.             String condivisioneDBRegservPdd = reader.getProperty("openspcoop2.configurazione.db.condivisioneDBRegserv");
  230.             try{
  231.                 condivisioneDBRegservPddValue = Boolean.parseBoolean(condivisioneDBRegservPdd.trim());
  232.             }catch(Exception e){
  233.                 throw new CoreException("Non e' stato definita o e' definita non correttamente la proprieta' [openspcoop2.configurazione.db.condivisioneDBRegserv]: "+e.getMessage());
  234.             }
  235.             
  236.             String dataSource = reader.getProperty("openspcoop2.configurazione.db.dataSource");
  237.             
  238.             if(dataSource!=null){
  239.                 dataSource = dataSource.trim();
  240.                 java.util.Properties context = Utilities.readProperties("openspcoop2.configurazione.db.context.",reader);
  241.                 
  242.                 GestoreJNDI gestoreJNDI = new GestoreJNDI(context);
  243.                 javax.sql.DataSource ds = (javax.sql.DataSource) gestoreJNDI.lookup(dataSource);
  244.                 connectionConfigurazione = ds.getConnection();
  245.                         
  246.             }else{
  247.                 connection = reader.getProperty("openspcoop2.configurazione.db.url");
  248.                 if(connection==null){
  249.                     throw new CoreException("Non e' stata definita una destinazione ne attraverso un datasource, ne attraverso una connessione diretta");
  250.                 }
  251.                 connection = connection.trim();
  252.                 driver = reader.getProperty("openspcoop2.configurazione.db.driver");
  253.                 if(driver==null){
  254.                     throw new CoreException("Connessione diretta: non e' stato definito il Driver");
  255.                 }
  256.                 driver = driver.trim();
  257.                 username = reader.getProperty("openspcoop2.configurazione.db.user");
  258.                 password = reader.getProperty("openspcoop2.configurazione.db.password");
  259.                 if(username!=null){
  260.                     username = username.trim();
  261.                 }
  262.                 if(password!=null){
  263.                     password = password.trim();
  264.                 }
  265.                 
  266.                 Loader.getInstance().newInstance(driver);
  267.                 if(username!=null && password!=null){
  268.                     connectionConfigurazione = DriverManager.getConnection(connection,username,password);
  269.                 }else{
  270.                     connectionConfigurazione = DriverManager.getConnection(connection);
  271.                 }
  272.             }

  274.             driverConfigurazione = new DriverConfigurazioneDB(connectionConfigurazione, null, tipoDatabase, condivisioneDBRegservPddValue);
  275.             
  276.         }catch(Exception e) {
  277.             String errorMsg = "Errore durante la lettura del file di properties ["+args[1]+"] : "+e.getMessage();
  278.             logError(log,errorMsg,e);
  279.             throw new CoreException(errorMsg,e);
  280.         }
  281.         
  282.         
  283.         
  284.         // **** Raccolta proprieta' per accesso a registroServizi *******
  285.         
  286.         Connection connectionRegistroServizi = null;
  287.         DriverRegistroServiziDB driverRegistroServizi = null;
  288.         try{
  289.             
  290.             
  291.             String connection = null;
  292.             String username = null;
  293.             String password = null;
  294.             String driver =  null;
  295.                         
  296.             // Database
  297.             tipoDatabase = reader.getProperty("openspcoop2.registroServizi.db.tipo");
  298.             if(tipoDatabase==null){
  299.                 throw new CoreException("Non e' stato definito il tipo di database per la configurazione");
  300.             }else{
  301.                 tipoDatabase = tipoDatabase.trim();
  302.             }
  303.             
  304.             String dataSource = reader.getProperty("openspcoop2.registroServizi.db.dataSource");
  305.             
  306.             if(dataSource!=null){
  307.                 dataSource = dataSource.trim();
  308.                 java.util.Properties context = Utilities.readProperties("openspcoop2.registroServizi.db.context.",reader);
  309.                 
  310.                 // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  311.                 if(!govwayConsoleMode){
  312.                     GestoreJNDI gestoreJNDI = new GestoreJNDI(context);
  313.                     javax.sql.DataSource ds = (javax.sql.DataSource) gestoreJNDI.lookup(dataSource);
  314.                     connectionRegistroServizi = ds.getConnection();
  315.                 }
  316.                         
  317.             }else{
  318.                 connection = reader.getProperty("openspcoop2.registroServizi.db.url");
  319.                 if(connection==null){
  320.                     throw new CoreException("Non e' stata definita una destinazione ne attraverso un datasource, ne attraverso una connessione diretta");
  321.                 }
  322.                 connection = connection.trim();
  323.                 driver = reader.getProperty("openspcoop2.registroServizi.db.driver");
  324.                 if(driver==null){
  325.                     throw new CoreException("Connessione diretta: non e' stato definito il Driver");
  326.                 }
  327.                 driver = driver.trim();
  328.                 username = reader.getProperty("openspcoop2.registroServizi.db.user");
  329.                 password = reader.getProperty("openspcoop2.registroServizi.db.password");
  330.                 if(username!=null){
  331.                     username = username.trim();
  332.                 }
  333.                 if(password!=null){
  334.                     password = password.trim();
  335.                 }
  336.                 
  337.                 // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  338.                 if(!govwayConsoleMode){
  339.                     Loader.getInstance().newInstance(driver);
  340.                     if(username!=null && password!=null){
  341.                         connectionRegistroServizi = DriverManager.getConnection(connection,username,password);
  342.                     }else{
  343.                         connectionRegistroServizi = DriverManager.getConnection(connection);
  344.                     }
  345.                 }
  346.             }

  348.             if(govwayConsoleMode){
  349.                 driverRegistroServizi = new DriverRegistroServiziDB(connectionConfigurazione, null, tipoDatabase);
  350.             }else{
  351.                 driverRegistroServizi = new DriverRegistroServiziDB(connectionRegistroServizi, null, tipoDatabase);
  352.             }
  353.             
  354.         }catch(Exception e) {
  355.             String errorMsg = "Errore durante la lettura del file di properties ["+args[1]+"] : "+e.getMessage();
  356.             logError(log,errorMsg,e);
  357.             throw new CoreException(errorMsg,e);
  358.         }
  359.         
  360.         
  361.         
  362.         
  363.         
  364.         
  365.         
  366.         try{
  367.             
  368.             logDebug(log,"Imposto auto-commit a false");
  369.             connectionConfigurazione.setAutoCommit(false);
  370.             // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  371.             if(!govwayConsoleMode){
  372.                 connectionRegistroServizi.setAutoCommit(false);
  373.             }else{
  374.                 connectionRegistroServizi = connectionConfigurazione;
  375.             }
  376.             
  377.             
  378.             // Ricerca id Servizi da eliminare.
  379.             FiltroRicercaServizi filtroRicercaServizio = new FiltroRicercaServizi();
  380.             filtroRicercaServizio.setTipo(tipoServizio);
  381.             filtroRicercaServizio.setNome(nomeServizio);
  382.             if(tipoSoggettoErogatore!=null && nomeSoggettoErogatore!=null){
  383.                 filtroRicercaServizio.setTipoSoggettoErogatore(tipoSoggettoErogatore);
  384.                 filtroRicercaServizio.setNomeSoggettoErogatore(nomeSoggettoErogatore);
  385.             }
  386.             List<IDServizio> idServizi = new ArrayList<>();
  387.             try{
  388.                 List<IDServizio> idServizio = driverRegistroServizi.getAllIdServizi(filtroRicercaServizio);
  389.                 if(idServizio!=null){
  390.                     for (int i = 0; i < idServizio.size(); i++) {
  391.                         idServizi.add(idServizio.get(i));
  392.                     }
  393.                 }
  394.             }catch(DriverRegistroServiziNotFound notFound){
  395.                 logDebug(log,"Ricerca di servizi con filtro ["+filtroRicercaServizio.toString()+"] non ha prodotto risultati: "+notFound.getMessage());
  396.             }
  397.             
  398.             logDebug(log,"Totale servizi da eliminare con tipologia ["+tipologiaEliminazione+"] : "+idServizi.size());
  399.             
  400.             
  401.             // Scorro tutti i servizi trovati
  402.             while(!idServizi.isEmpty()){
  403.                 
  404.                 IDServizio idServizio = idServizi.remove(0);
  405.                 logDebug(log,"Gestione eliminazione servizio ["+idServizio.toString()+"] ...");
  406.                 AccordoServizioParteSpecifica asps = driverRegistroServizi.getAccordoServizioParteSpecifica(idServizio);
  407.                 @SuppressWarnings("unused")
  408.                 IDSoggetto soggettoErogatore = new IDSoggetto(asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore());
  409.                 logDebug(log,"\t dati servizio SoggettoErogatore["+asps.getTipoSoggettoErogatore()+"/"+asps.getNomeSoggettoErogatore()+"] Tipologia["+asps.getTipologiaServizio().toString()+"] ...");
  410.                                 
  411.                 if(OpenSPCoop2DBConfigurationUtility.TIPOLOGIA_ELIMINAZIONE_FRUIZIONE.equals(tipologiaEliminazione)){
  412.                     
  413.                     logDebug(log,"\t dati Fruitore da eliminare ["+tipoSoggettoFruitore+"/"+nomeSoggettoFruitore+"]");
  414.                     IDSoggetto soggettoFruitore = new IDSoggetto(tipoSoggettoFruitore,nomeSoggettoFruitore);
  415.                     /**org.openspcoop2.core.config.Soggetto soggettoConfig = driverConfigurazione.getSoggetto(soggettoFruitore);*/
  416.                     
  417.                     // FRUITORE DAL SERVIZIO (+ mapping fruizioni)
  418.                     if(govwayConsoleMode){
  419.                         logDebug(log,"\t- eliminazione mapping fruizioni ...");
  420.                         DBMappingUtils.deleteMappingFruizione(idServizio, soggettoFruitore, connectionConfigurazione, tipoDatabase);
  421.                         logDebug(log,"\t- eliminazione mapping fruizioni effettuata");
  422.                     }
  423.                     
  424.                     logDebug(log,"\t- eliminazione fruizione dal servizio ...");
  425.                     for (int i = 0; i < asps.sizeFruitoreList(); i++) {
  426.                         Fruitore fr = asps.getFruitore(i);
  427.                         if(fr.getTipo().equals(tipoSoggettoFruitore) && fr.getNome().equals(nomeSoggettoFruitore)){
  428.                             asps.removeFruitore(i);
  429.                             break;
  430.                         }
  431.                     }
  432.                     driverRegistroServizi.updateAccordoServizioParteSpecifica(asps);
  433.                     logDebug(log,"\t- eliminazione fruizione dal servizio effettuata");
  434.                     
  435.                     
  436.                     // PORTE DELEGATE CON TALE SERVIZIO e con tale fruitore
  437.                     List<String> nomiServiziApplicativi = new ArrayList<>();
  438.                     List<PortaDelegata> listaPorteDelegate = 
  439.                         driverConfigurazione.getPorteDelegateWithServizio(asps.getId(), asps.getTipo(), asps.getNome(), asps.getVersione(),
  440.                                 asps.getIdSoggetto(), asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore());
  441.                     List<PortaDelegata> listaPorteDelegateFruitoreDaEliminare = new ArrayList<>();
  442.                     while(!listaPorteDelegate.isEmpty()){
  443.                         PortaDelegata pd = listaPorteDelegate.remove(0);
  444.                         if(pd.getTipoSoggettoProprietario().equals(tipoSoggettoFruitore) && pd.getNomeSoggettoProprietario().equals(nomeSoggettoFruitore)){
  445.                             listaPorteDelegateFruitoreDaEliminare.add(pd);
  446.                         }
  447.                     }
  448.                     logDebug(log,"\t- eliminazione porte delegate ("+listaPorteDelegateFruitoreDaEliminare.size()+") ...");
  449.                     while(!listaPorteDelegateFruitoreDaEliminare.isEmpty()){
  450.                         PortaDelegata pd = listaPorteDelegateFruitoreDaEliminare.remove(0);
  451.                         logDebug(log,"\t\t. porta delegata ("+pd.getNome()+") ...");
  452.                         for (int i = 0; i < pd.sizeServizioApplicativoList(); i++) {
  453.                             String sa = pd.getServizioApplicativo(i).getNome();
  454.                             if(!nomiServiziApplicativi.contains(sa)){
  455.                                 nomiServiziApplicativi.add(sa);
  456.                             }
  457.                         }
  458.                         driverConfigurazione.deletePortaDelegata(pd);
  459.                         logDebug(log,"\t\t. porta delegata ("+pd.getNome()+") eliminata");
  460.                     }
  461.                     logDebug(log,"\t- eliminazione porte delegate effettuata");
  462.                     
  463.                     
  464.                     // SERVIZI APPLICATIVI
  465.                     logDebug(log,"\t- eliminazione servizi applicativi ("+nomiServiziApplicativi.size()+") ...");
  466.                     while(!nomiServiziApplicativi.isEmpty()){
  467.                         String nomeSA = nomiServiziApplicativi.remove(0);
  468.                         logDebug(log,"\t\t. servizio applicativo ("+nomeSA+") ...");
  469.                         IDServizioApplicativo idSA = new IDServizioApplicativo();
  470.                         idSA.setIdSoggettoProprietario(soggettoFruitore);
  471.                         idSA.setNome(nomeSA);
  472.                         ServizioApplicativo sa = driverConfigurazione.getServizioApplicativo(idSA);
  473.                         driverConfigurazione.deleteServizioApplicativo(sa);
  474.                         logDebug(log,"\t\t. servizio applicativo ("+nomeSA+") eliminato");
  475.                     }
  476.                     logDebug(log,"\t- eliminazione servizi applicativi effettuata");
  477.                     
  478.                 }
  479.                 else{
  480.                     
  481.                     // FRUITORI (+ mapping fruizioni)
  482.                     if(govwayConsoleMode){
  483.                         for (int i = 0; i < asps.sizeFruitoreList(); i++) {
  484.                             Fruitore fr = asps.getFruitore(i);
  485.                             IDSoggetto soggettoFruitore = new IDSoggetto(fr.getTipo(),fr.getNome());
  486.                             logDebug(log,"\t- eliminazione mapping fruizioni ...");
  487.                             DBMappingUtils.deleteMappingFruizione(idServizio, soggettoFruitore, connectionConfigurazione, tipoDatabase);
  488.                             logDebug(log,"\t- eliminazione mapping fruizioni effettuata");
  489.                         }
  490.                     }
  491.                         
  492.                                                     
  493.                     // PORTE DELEGATE
  494.                     List<IDServizioApplicativo> nomiServiziApplicativi = new ArrayList<>();
  495.                     List<PortaDelegata> listaPorteDelegate = 
  496.                         driverConfigurazione.getPorteDelegateWithServizio(asps.getId(), asps.getTipo(), asps.getNome(), asps.getVersione(),
  497.                                 asps.getIdSoggetto(), asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore());
  498.                     logDebug(log,"\t- eliminazione porte delegate ("+listaPorteDelegate.size()+") ...");
  499.                     while(!listaPorteDelegate.isEmpty()){
  500.                         PortaDelegata pd = listaPorteDelegate.remove(0);
  501.                         logDebug(log,"\t\t. porta delegata ("+pd.getNome()+") ...");
  502.                         for (int i = 0; i < pd.sizeServizioApplicativoList(); i++) {
  503.                             String sa = pd.getServizioApplicativo(i).getNome();
  504.                             IDServizioApplicativo idServizioApplicativo = new IDServizioApplicativo();
  505.                             idServizioApplicativo.setNome(sa);
  506.                             idServizioApplicativo.setIdSoggettoProprietario(new IDSoggetto(pd.getTipoSoggettoProprietario(), pd.getNomeSoggettoProprietario()));
  507.                             if(!nomiServiziApplicativi.contains(idServizioApplicativo)){
  508.                                 nomiServiziApplicativi.add(idServizioApplicativo);
  509.                             }
  510.                         }
  511.                         driverConfigurazione.deletePortaDelegata(pd);
  512.                         logDebug(log,"\t\t. porta delegata ("+pd.getNome()+") eliminata");
  513.                     }
  514.                     logDebug(log,"\t- eliminazione porte delegate effettuata");
  515.                     
  516.                     
  517.                     // PORTE APPLICATIVE
  518.                     List<PortaApplicativa> listaPorteApplicative = 
  519.                         driverConfigurazione.getPorteApplicativeWithServizio(asps.getId(), asps.getTipo(), asps.getNome(), asps.getVersione(),
  520.                                 asps.getIdSoggetto(), asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore());
  521.                     logDebug(log,"\t- eliminazione porte applicative ("+listaPorteApplicative.size()+") ...");
  522.                     while(!listaPorteApplicative.isEmpty()){
  523.                         PortaApplicativa pa = listaPorteApplicative.remove(0);
  524.                         IDPortaApplicativa idpa = new IDPortaApplicativa();
  525.                         idpa.setNome(pa.getNome());
  526.                         pa = driverConfigurazione.getPortaApplicativa(idpa); // Leggo tutti i valori (Bug del metodo getPorteApplicativeWithServizio)
  527.                         logDebug(log,"\t\t. porta applicativa ("+pa.getNome()+") ...");
  528.                         for (int i = 0; i < pa.sizeServizioApplicativoList(); i++) {
  529.                             String sa = pa.getServizioApplicativo(i).getNome();
  530.                             IDServizioApplicativo idServizioApplicativo = new IDServizioApplicativo();
  531.                             idServizioApplicativo.setNome(sa);
  532.                             idServizioApplicativo.setIdSoggettoProprietario(new IDSoggetto(pa.getTipoSoggettoProprietario(), pa.getNomeSoggettoProprietario()));
  533.                             if(!nomiServiziApplicativi.contains(idServizioApplicativo)){
  534.                                 nomiServiziApplicativi.add(idServizioApplicativo);
  535.                             }
  536.                         }
  537.                         driverConfigurazione.deletePortaApplicativa(pa);
  538.                         logDebug(log,"\t\t. porta applicativa ("+pa.getNome()+") eliminata");
  539.                     }
  540.                     logDebug(log,"\t- eliminazione porte applicative effettuata");
  541.                     
  542.                     
  543.                     // SERVIZI APPLICATIVI
  544.                     logDebug(log,"\t- eliminazione servizi applicativi ("+nomiServiziApplicativi.size()+") ...");
  545.                     while(!nomiServiziApplicativi.isEmpty()){
  546.                         IDServizioApplicativo idSA = nomiServiziApplicativi.remove(0);
  547.                         logDebug(log,"\t\t. servizio applicativo ("+idSA.toString()+") ...");
  548.                         try{
  549.                             ServizioApplicativo sa = driverConfigurazione.getServizioApplicativo(idSA);
  550.                             driverConfigurazione.deleteServizioApplicativo(sa);
  551.                             logDebug(log,"\t\t. servizio applicativo ("+idSA.toString()+") eliminato");
  552.                         }catch(DriverConfigurazioneNotFound notFound){
  553.                             logDebug(log,"\t\t. servizio applicativo ("+idSA.toString()+") non esiste (puo' darsi che veniva riferito da piu' oggetti, e sia gia' stato eliminato)");
  554.                         }
  555.                     }
  556.                     logDebug(log,"\t- eliminazione servizi applicativi effettuata");

  558.                     
  559.                     
  560.                     // SERVIZI (mapping erogazioni)
  561.                     if(govwayConsoleMode){
  562.                         logDebug(log,"\t- eliminazione mapping erogazione ...");
  563.                         DBMappingUtils.deleteMappingErogazione(idServizio, connectionConfigurazione, tipoDatabase);
  564.                         logDebug(log,"\t- eliminazione mapping erogazione effettuata");
  565.                     }
  566.                     
  567.                     
  568.                     // SERVIZI 
  569.                     logDebug(log,"\t- eliminazione servizio ...");
  570.                     driverRegistroServizi.deleteAccordoServizioParteSpecifica(asps);
  571.                     logDebug(log,"\t- eliminazione servizio effettuata");
  572.                     
  573.                     
  574.                     // ACCORDI (SE NON VI SONO ALTRI SERVIZI CHE LO IMPLEMENTANO)
  575.                     logDebug(log,"\t- eliminazione accordo parte comune ...");
  576.                     FiltroRicercaServizi filtroAltriServizi = new FiltroRicercaServizi();
  577.                     IDAccordo idAccordoParteComune = IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune());
  578.                     filtroAltriServizi.setIdAccordoServizioParteComune(idAccordoParteComune);
  579.                     boolean existsAltriServizi = false;
  580.                     StringBuilder bfAltriServizi = new StringBuilder();
  581.                     try{
  582.                         List<IDServizio> others = driverRegistroServizi.getAllIdServizi(filtroAltriServizi);
  583.                         if(others!=null && !others.isEmpty()){
  584.                             existsAltriServizi = true;
  585.                             for (int i = 0; i < others.size(); i++) {
  586.                                 if(bfAltriServizi.length()>0){
  587.                                     bfAltriServizi.append(",");
  588.                                 }
  589.                                 bfAltriServizi.append(others.get(i).toString());
  590.                             }
  591.                         }
  592.                     }catch(DriverRegistroServiziNotFound notFound){}
  593.                     if(!existsAltriServizi){
  594.                         AccordoServizioParteComune as = new AccordoServizioParteComune();
  595.                         as.setNome(idAccordoParteComune.getNome());
  596.                         as.setVersione(idAccordoParteComune.getVersione());
  597.                         if(idAccordoParteComune.getSoggettoReferente()!=null){
  598.                             IdSoggetto asr = new IdSoggetto();
  599.                             asr.setTipo(idAccordoParteComune.getSoggettoReferente().getTipo());
  600.                             asr.setNome(idAccordoParteComune.getSoggettoReferente().getNome());
  601.                             as.setSoggettoReferente(asr);
  602.                         }
  603.                         driverRegistroServizi.deleteAccordoServizioParteComune(as);
  604.                         logDebug(log,"\t- eliminazione accordo parte comune effettuata");
  605.                     }
  606.                     else{
  607.                         logDebug(log,"\t- eliminazione accordo parte comune non effettuata poiche' implementato da altri servizi: "+bfAltriServizi.toString());
  608.                     }
  609.                     
  610.                 }
  611.                 
  612.                 logDebug(log,"Gestione eliminazione servizio ["+idServizio.toString()+"] completata");
  613.             }
  614.             
  615.         
  616.             
  617.             
  618.             logDebug(log,"Commit...");
  619.             connectionConfigurazione.commit();
  620.             // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  621.             if(!govwayConsoleMode){
  622.                 connectionRegistroServizi.commit();
  623.             }
  624.             logDebug(log,"Commit effettuato");
  625.             
  626.         }catch(Exception e){
  627.             try{
  628.                 connectionConfigurazione.rollback();
  629.             }catch(Exception eRollback){}
  630.             try{
  631.                 // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  632.                 if(!govwayConsoleMode){
  633.                     connectionRegistroServizi.rollback();
  634.                 }
  635.             }catch(Exception eRollback){}
  636.             String errorMsg = "Errore avvenuto durante l'eliminazione: "+e.getMessage(); 
  637.             logError(log,errorMsg,e);
  638.             throw new CoreException(errorMsg,e);
  639.         }finally{
  640.             try{
  641.                 connectionConfigurazione.setAutoCommit(true);
  642.             }catch(Exception e){
  643.                 // ignore
  644.             }
  645.             try{
  646.                 // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  647.                 if(!govwayConsoleMode){
  648.                     connectionRegistroServizi.setAutoCommit(true);
  649.                 }
  650.             }catch(Exception e){
  651.                 // ignore
  652.             }
  653.             try{
  654.                 Logger logR = OpenSPCoop2Logger.getLoggerOpenSPCoopResources()!=null ? OpenSPCoop2Logger.getLoggerOpenSPCoopResources() : LoggerWrapperFactory.getLogger(DBConsegnePreseInCaricoManager.class);
  655.                 boolean checkAutocommit = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckAutocommit();
  656.                 boolean checkIsClosed = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckIsClosed();
  657.                 JDBCUtilities.closeConnection(logR, connectionConfigurazione, checkAutocommit, checkIsClosed);
  658.             }catch(Exception e){
  659.                 // ignore
  660.             }
  661.             try{
  662.                 // NOTA: Se sono in govwayConsoleMode devo usare SOLO 1 connessione (uso quella della configurazione)
  663.                 if(!govwayConsoleMode){
  664.                     Logger logR = OpenSPCoop2Logger.getLoggerOpenSPCoopResources()!=null ? OpenSPCoop2Logger.getLoggerOpenSPCoopResources() : LoggerWrapperFactory.getLogger(DBConsegnePreseInCaricoManager.class);
  665.                     boolean checkAutocommit = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckAutocommit();
  666.                     boolean checkIsClosed = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckIsClosed();
  667.                     JDBCUtilities.closeConnection(logR, connectionRegistroServizi, checkAutocommit, checkIsClosed);
  668.                 }
  669.             }catch(Exception e){
  670.                 // ignore
  671.             }
  672.         }
  673.         
  674.     }
  675.     

  677. }
Created with JaCoCo 0.8.8.202204050719