DBOggettiInUsoUtils_ruoli.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.  */

  21. package org.openspcoop2.protocol.engine.utils;

  23. import java.sql.Connection;
  24. import java.sql.PreparedStatement;
  25. import java.sql.ResultSet;
  26. import java.util.ArrayList;
  27. import java.util.List;
  28. import java.util.Map;
  29. import java.util.Set;

  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.commons.ErrorsHandlerCostant;
  33. import org.openspcoop2.core.constants.CostantiDB;
  34. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  35. import org.openspcoop2.core.id.IDPortaApplicativa;
  36. import org.openspcoop2.core.id.IDRuolo;
  37. import org.openspcoop2.core.id.IDServizio;
  38. import org.openspcoop2.core.id.IDSoggetto;
  39. import org.openspcoop2.core.mapping.DBMappingUtils;
  40. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  41. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  42. import org.openspcoop2.utils.UtilsException;
  43. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  44. import org.openspcoop2.utils.sql.ISQLQueryObject;
  45. import org.openspcoop2.utils.sql.SQLObjectFactory;

  47. /**
  48.  * DBOggettiInUsoUtils_ruoli
  49.  * 
  50.  * @author Andrea Poli (apoli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  * 
  54.  */
  55. public class DBOggettiInUsoUtils_ruoli {

  57.     protected static boolean isRuoloConfigInUso(Connection con, String tipoDB, IDRuolo idRuolo, Map<ErrorsHandlerCostant, 
  58.             List<String>> whereIsInUso, boolean normalizeObjectIds) throws UtilsException {
  59.         return isRuoloInUsoEngine(con,tipoDB,idRuolo,false,true,whereIsInUso,normalizeObjectIds);
  60.     }
  61.     protected static boolean isRuoloRegistryInUso(Connection con, String tipoDB, IDRuolo idRuolo, Map<ErrorsHandlerCostant, 
  62.             List<String>> whereIsInUso, boolean normalizeObjectIds) throws UtilsException {
  63.         return isRuoloInUsoEngine(con,tipoDB,idRuolo,true,false,whereIsInUso,normalizeObjectIds);
  64.     }
  65.     protected static boolean isRuoloInUso(Connection con, String tipoDB, IDRuolo idRuolo, Map<ErrorsHandlerCostant, 
  66.             List<String>> whereIsInUso, boolean normalizeObjectIds) throws UtilsException {
  67.         return isRuoloInUsoEngine(con,tipoDB,idRuolo,true,true,whereIsInUso,normalizeObjectIds);
  68.     }
  69.     private static boolean isRuoloInUsoEngine(Connection con, String tipoDB, IDRuolo idRuolo, boolean registry, boolean config, Map<ErrorsHandlerCostant, 
  70.             List<String>> whereIsInUso, boolean normalizeObjectIds) throws UtilsException {
  71.         String nomeMetodo = "_isRuoloInUso";

  73.         PreparedStatement stmt = null;
  74.         ResultSet risultato = null;
  75.         String queryString;

  77.         try {

  79.             long idR = DBUtils.getIdRuolo(idRuolo, con, tipoDB);
  80.             
  81.             boolean isInUso = false;
  82.             
  83.             List<String> soggettiList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_SOGGETTI);
  84.             List<String> serviziApplicativiList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_SERVIZI_APPLICATIVI);
  85.             List<String> porteApplicativeList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE);
  86.             List<String> porteApplicativeModiList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE_MODI);
  87.             List<String> porteDelegateList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_PORTE_DELEGATE);
  88.             List<String> mappingErogazionePAList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_MAPPING_EROGAZIONE_PA);
  89.             List<String> mappingErogazionePAModiList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_MAPPING_EROGAZIONE_PA_MODI);
  90.             List<String> mappingFruizionePDList = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_MAPPING_FRUIZIONE_PD);
  91.             List<String> porteApplicativeTokenList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_PA);
  92.             List<String> porteApplicativeTokenModiList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_PA_MODI);
  93.             List<String> porteDelegateTokenList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_PD);
  94.             List<String> mappingErogazioneTokenPAList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PA);
  95.             List<String> mappingErogazioneTokenPAModiList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PA_MODI);
  96.             List<String> mappingFruizioneTokenPDList = whereIsInUso.get(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PD);
  97.             List<String> ctList = whereIsInUso.get(ErrorsHandlerCostant.CONTROLLO_TRAFFICO);
  98.             List<String> allarmeList = whereIsInUso.get(ErrorsHandlerCostant.ALLARMI);
  99.             List<String> modiSignalHubList = whereIsInUso.get(ErrorsHandlerCostant.IS_RIFERITA_MODI_SIGNAL_HUB);
  100.             
  101.             if (soggettiList == null) {
  102.                 soggettiList = new ArrayList<>();
  103.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_SOGGETTI, soggettiList);
  104.             }
  105.             if (serviziApplicativiList == null) {
  106.                 serviziApplicativiList = new ArrayList<>();
  107.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_SERVIZI_APPLICATIVI, serviziApplicativiList);
  108.             }
  109.             
  110.             if (porteApplicativeList == null) {
  111.                 porteApplicativeList = new ArrayList<>();
  112.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE, porteApplicativeList);
  113.             }
  114.             if (porteApplicativeModiList == null) {
  115.                 porteApplicativeModiList = new ArrayList<>();
  116.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE_MODI, porteApplicativeModiList);
  117.             }
  118.             if (porteDelegateList == null) {
  119.                 porteDelegateList = new ArrayList<>();
  120.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_PORTE_DELEGATE, porteDelegateList);
  121.             }
  122.             if (mappingErogazionePAList == null) {
  123.                 mappingErogazionePAList = new ArrayList<>();
  124.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_MAPPING_EROGAZIONE_PA, mappingErogazionePAList);
  125.             }
  126.             if (mappingErogazionePAModiList == null) {
  127.                 mappingErogazionePAModiList = new ArrayList<>();
  128.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_MAPPING_EROGAZIONE_PA_MODI, mappingErogazionePAModiList);
  129.             }
  130.             if (mappingFruizionePDList == null) {
  131.                 mappingFruizionePDList = new ArrayList<>();
  132.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_MAPPING_FRUIZIONE_PD, mappingFruizionePDList);
  133.             }
  134.             
  135.             if (porteApplicativeTokenList == null) {
  136.                 porteApplicativeTokenList = new ArrayList<>();
  137.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_PA, porteApplicativeTokenList);
  138.             }
  139.             if (porteApplicativeTokenModiList == null) {
  140.                 porteApplicativeTokenModiList = new ArrayList<>();
  141.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_PA_MODI, porteApplicativeTokenModiList);
  142.             }
  143.             if (porteDelegateTokenList == null) {
  144.                 porteDelegateTokenList = new ArrayList<>();
  145.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_PD, porteDelegateTokenList);
  146.             }
  147.             if (mappingErogazioneTokenPAList == null) {
  148.                 mappingErogazioneTokenPAList = new ArrayList<>();
  149.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PA, mappingErogazioneTokenPAList);
  150.             }
  151.             if (mappingErogazioneTokenPAModiList == null) {
  152.                 mappingErogazioneTokenPAModiList = new ArrayList<>();
  153.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PA_MODI, mappingErogazioneTokenPAModiList);
  154.             }
  155.             if (mappingFruizioneTokenPDList == null) {
  156.                 mappingFruizioneTokenPDList = new ArrayList<>();
  157.                 whereIsInUso.put(ErrorsHandlerCostant.RUOLI_TOKEN_MAPPING_PD, mappingFruizioneTokenPDList);
  158.             }
  159.             
  160.             if (ctList == null) {
  161.                 ctList = new ArrayList<>();
  162.                 whereIsInUso.put(ErrorsHandlerCostant.CONTROLLO_TRAFFICO, ctList);
  163.             }
  164.             if (allarmeList == null) {
  165.                 allarmeList = new ArrayList<>();
  166.                 whereIsInUso.put(ErrorsHandlerCostant.ALLARMI, allarmeList);
  167.             }
  168.             
  169.             if (modiSignalHubList == null) {
  170.                 modiSignalHubList = new ArrayList<>();
  171.                 whereIsInUso.put(ErrorsHandlerCostant.IS_RIFERITA_MODI_SIGNAL_HUB, modiSignalHubList);
  172.             }
  173.             
  174.             
  175.             // Controllo che il ruolo non sia in uso nei soggetti
  176.             if(registry){
  177.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  178.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_RUOLI);
  179.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  180.                 sqlQueryObject.addSelectField("tipo_soggetto");
  181.                 sqlQueryObject.addSelectField("nome_soggetto");
  182.                 sqlQueryObject.setANDLogicOperator(true);
  183.                 sqlQueryObject.setSelectDistinct(true);
  184.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI_RUOLI+".id_ruolo = ?");
  185.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI_RUOLI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  186.                 queryString = sqlQueryObject.createSQLQuery();
  187.                 stmt = con.prepareStatement(queryString);
  188.                 stmt.setLong(1, idR);
  189.                 risultato = stmt.executeQuery();
  190.                 while (risultato.next()) {
  191.                     String tipoSoggetto = risultato.getString("tipo_soggetto");
  192.                     String nomeSoggetto = risultato.getString("nome_soggetto");
  193.                     IDSoggetto idSoggetto = new IDSoggetto(tipoSoggetto, nomeSoggetto);
  194.                     if(normalizeObjectIds) {
  195.                         String protocollo = ProtocolFactoryManager.getInstance().getProtocolByOrganizationType(tipoSoggetto);
  196.                         soggettiList.add(DBOggettiInUsoUtils.getProtocolPrefix(protocollo)+NamingUtils.getLabelSoggetto(protocollo, idSoggetto));
  197.                     }
  198.                     else {
  199.                         soggettiList.add(tipoSoggetto + "/" + nomeSoggetto);    
  200.                     }
  201.                     isInUso = true;
  202.                 }
  203.                 risultato.close();
  204.                 stmt.close();

  206.             }
  207.             
  208.             // Controllo che il ruolo non sia in uso nei serviziApplicativi
  209.             if(config){
  210.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  211.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI_RUOLI);
  212.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  213.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  214.                 sqlQueryObject.addSelectField("tipo_soggetto");
  215.                 sqlQueryObject.addSelectField("nome_soggetto");
  216.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_APPLICATIVI+".nome");
  217.                 sqlQueryObject.setANDLogicOperator(true);
  218.                 sqlQueryObject.setSelectDistinct(true);
  219.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI_RUOLI+".ruolo = ?");
  220.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI_RUOLI+".id_servizio_applicativo = "+CostantiDB.SERVIZI_APPLICATIVI+".id");
  221.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  222.                 queryString = sqlQueryObject.createSQLQuery();
  223.                 stmt = con.prepareStatement(queryString);
  224.                 stmt.setString(1, idRuolo.getNome());
  225.                 risultato = stmt.executeQuery();
  226.                 while (risultato.next()) {
  227.                     String tipoSoggetto = risultato.getString("tipo_soggetto");
  228.                     String nomeSoggetto = risultato.getString("nome_soggetto");
  229.                     String nome = risultato.getString("nome");
  230.                     IDSoggetto idSoggetto = new IDSoggetto(tipoSoggetto, nomeSoggetto);
  231.                     if(normalizeObjectIds) {
  232.                         String protocollo = ProtocolFactoryManager.getInstance().getProtocolByOrganizationType(tipoSoggetto);
  233.                         serviziApplicativiList.add(DBOggettiInUsoUtils.getProtocolPrefix(protocollo)+nome+DBOggettiInUsoUtils.getSubjectSuffix(protocollo, idSoggetto));
  234.                     }
  235.                     else {
  236.                         serviziApplicativiList.add(tipoSoggetto + "/" + nomeSoggetto+"_"+nome);
  237.                     }
  238.                     isInUso = true;
  239.                 }
  240.                 risultato.close();
  241.                 stmt.close();
  242.             }
  243.             
  244.             // Controllo che il ruolo non sia in uso nelle porte applicative
  245.             if(config){
  246.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  247.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_RUOLI);
  248.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  249.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  250.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE+".nome_porta");
  251.                 sqlQueryObject.setANDLogicOperator(true);
  252.                 sqlQueryObject.setSelectDistinct(true);
  253.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_RUOLI+".ruolo = ?");
  254.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_RUOLI+".id_porta = "+CostantiDB.PORTE_APPLICATIVE+".id");
  255.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  256.                 queryString = sqlQueryObject.createSQLQuery();
  257.                 stmt = con.prepareStatement(queryString);
  258.                 stmt.setString(1, idRuolo.getNome());
  259.                 risultato = stmt.executeQuery();
  260.                 while (risultato.next()) {
  261.                     String nome = risultato.getString("nome_porta");
  262.                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaApplicativa(nome, tipoDB, con, normalizeObjectIds);
  263.                     if(resultPorta.mapping) {
  264.                         if(resultPorta.erogazioneModi)
  265.                             mappingErogazionePAModiList.add(resultPorta.label);
  266.                         else
  267.                             mappingErogazionePAList.add(resultPorta.label);
  268.                     }
  269.                     else {
  270.                         if(resultPorta.erogazioneModi)
  271.                             porteApplicativeModiList.add(resultPorta.label);
  272.                         else
  273.                             porteApplicativeList.add(resultPorta.label);
  274.                     }
  275.                     isInUso = true;
  276.                 }
  277.                 risultato.close();
  278.                 stmt.close();
  279.             }
  280.             
  281.             // Controllo che il ruolo non sia in uso nelle porte applicative (token)
  282.             if(config){
  283.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  284.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI);
  285.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  286.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  287.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE+".nome_porta");
  288.                 sqlQueryObject.setANDLogicOperator(true);
  289.                 sqlQueryObject.setSelectDistinct(true);
  290.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI+".ruolo = ?");
  291.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI+".id_porta = "+CostantiDB.PORTE_APPLICATIVE+".id");
  292.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  293.                 queryString = sqlQueryObject.createSQLQuery();
  294.                 stmt = con.prepareStatement(queryString);
  295.                 stmt.setString(1, idRuolo.getNome());
  296.                 risultato = stmt.executeQuery();
  297.                 while (risultato.next()) {
  298.                     String nome = risultato.getString("nome_porta");
  299.                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaApplicativa(nome, tipoDB, con, normalizeObjectIds);
  300.                     if(resultPorta.mapping) {
  301.                         if(resultPorta.erogazioneModi)
  302.                             mappingErogazioneTokenPAModiList.add(resultPorta.label);
  303.                         else
  304.                             mappingErogazioneTokenPAList.add(resultPorta.label);
  305.                     }
  306.                     else {
  307.                         if(resultPorta.erogazioneModi)
  308.                             porteApplicativeTokenModiList.add(resultPorta.label);
  309.                         else
  310.                             porteApplicativeTokenList.add(resultPorta.label);
  311.                     }
  312.                     isInUso = true;
  313.                 }
  314.                 risultato.close();
  315.                 stmt.close();
  316.             }
  317.             
  318.             // Controllo che il ruolo non sia in uso nelle porte delegate
  319.             if(config){
  320.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  321.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_RUOLI);
  322.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  323.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  324.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE+".nome_porta");
  325.                 sqlQueryObject.setANDLogicOperator(true);
  326.                 sqlQueryObject.setSelectDistinct(true);
  327.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE_RUOLI+".ruolo = ?");
  328.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE_RUOLI+".id_porta = "+CostantiDB.PORTE_DELEGATE+".id");
  329.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  330.                 queryString = sqlQueryObject.createSQLQuery();
  331.                 stmt = con.prepareStatement(queryString);
  332.                 stmt.setString(1, idRuolo.getNome());
  333.                 risultato = stmt.executeQuery();
  334.                 while (risultato.next()) {
  335.                     String nome = risultato.getString("nome_porta");
  336.                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaDelegata(nome, tipoDB, con, normalizeObjectIds);
  337.                     if(resultPorta.mapping) {
  338.                         mappingFruizionePDList.add(resultPorta.label);
  339.                     }
  340.                     else {
  341.                         porteDelegateList.add(resultPorta.label);
  342.                     }
  343.                     isInUso = true;
  344.                 }
  345.                 risultato.close();
  346.                 stmt.close();
  347.             }
  348.             
  349.             // Controllo che il ruolo non sia in uso nelle porte delegate (token)
  350.             if(config){
  351.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  352.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI);
  353.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  354.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  355.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE+".nome_porta");
  356.                 sqlQueryObject.setANDLogicOperator(true);
  357.                 sqlQueryObject.setSelectDistinct(true);
  358.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI+".ruolo = ?");
  359.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI+".id_porta = "+CostantiDB.PORTE_DELEGATE+".id");
  360.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  361.                 queryString = sqlQueryObject.createSQLQuery();
  362.                 stmt = con.prepareStatement(queryString);
  363.                 stmt.setString(1, idRuolo.getNome());
  364.                 risultato = stmt.executeQuery();
  365.                 while (risultato.next()) {
  366.                     String nome = risultato.getString("nome_porta");
  367.                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaDelegata(nome, tipoDB, con, normalizeObjectIds);
  368.                     if(resultPorta.mapping) {
  369.                         mappingFruizioneTokenPDList.add(resultPorta.label);
  370.                     }
  371.                     else {
  372.                         porteDelegateTokenList.add(resultPorta.label);
  373.                     }
  374.                     isInUso = true;
  375.                 }
  376.                 risultato.close();
  377.                 stmt.close();
  378.             }
  379.             
  380.             // Controllo che il soggetto non sia associato a policy di controllo del traffico o allarmi
  381.             if(config){
  382.                 
  383.                 int max = 2;
  384.                 if(!CostantiDB.isAllarmiEnabled()) {
  385.                     max=1;
  386.                 }
  387.                 
  388.                 for (int i = 0; i < max; i++) {
  389.                     
  390.                     String tabella = CostantiDB.CONTROLLO_TRAFFICO_ACTIVE_POLICY;
  391.                     String identificativoColumn = "active_policy_id";
  392.                     String aliasColumn = "policy_alias";
  393.                     List<String> list = ctList;
  394.                     String oggetto = "Policy";
  395.                     if(i==1) {
  396.                         tabella = CostantiDB.ALLARMI;
  397.                         identificativoColumn = "nome";
  398.                         aliasColumn = "alias";
  399.                         list = allarmeList;
  400.                         oggetto = "Allarme";
  401.                     }
  402.                 
  403.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  404.                     sqlQueryObject.addFromTable(tabella);
  405.                     sqlQueryObject.addSelectField(identificativoColumn);
  406.                     sqlQueryObject.addSelectField(aliasColumn);
  407.                     sqlQueryObject.addSelectField("filtro_ruolo");
  408.                     sqlQueryObject.addSelectField("filtro_porta");
  409.                     sqlQueryObject.setANDLogicOperator(false); // OR
  410.                     sqlQueryObject.addWhereCondition(true, 
  411.                             tabella+".filtro_ruolo_fruitore = ?");
  412.                     sqlQueryObject.addWhereCondition(true, 
  413.                             tabella+".filtro_ruolo_erogatore = ?");
  414.                     queryString = sqlQueryObject.createSQLQuery();
  415.                     sqlQueryObject.addOrderBy("filtro_ruolo");
  416.                     sqlQueryObject.addOrderBy("filtro_porta");
  417.                     stmt = con.prepareStatement(queryString);
  418.                     int index = 1;
  419.                     stmt.setString(index++, idRuolo.getNome());
  420.                     stmt.setString(index++, idRuolo.getNome());
  421.                     risultato = stmt.executeQuery();
  422.                     while (risultato.next()) {
  423.                         
  424.                         String alias = risultato.getString(aliasColumn);
  425.                         if(alias== null || "".equals(alias)) {
  426.                             alias = risultato.getString(identificativoColumn);
  427.                         }
  428.                         
  429.                         String nomePorta = risultato.getString("filtro_porta");
  430.                         String filtroRuolo = risultato.getString("filtro_ruolo");
  431.                         if(nomePorta!=null) {
  432.                             String tipo = null;
  433.                             String label = null;
  434.                             if("delegata".equals(filtroRuolo)) {
  435.                                 try {
  436.                                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaDelegata(nomePorta, tipoDB, con, normalizeObjectIds);
  437.                                     if(resultPorta.mapping) {
  438.                                         label = "Fruizione di Servizio "+ resultPorta.label;
  439.                                     }
  440.                                 }catch(Exception e) {
  441.                                     tipo = "Outbound";
  442.                                 }
  443.                             }
  444.                             else if("applicativa".equals(filtroRuolo)) {
  445.                                 try {
  446.                                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaApplicativa(nomePorta, tipoDB, con, normalizeObjectIds);
  447.                                     if(resultPorta.mapping) {
  448.                                         label = "Erogazione di Servizio "+ resultPorta.label;
  449.                                     }
  450.                                 }catch(Exception e) {
  451.                                     tipo = "Inbound";
  452.                                 }
  453.                             }
  454.                             else {
  455.                                 tipo = filtroRuolo;
  456.                             }
  457.                             if(label==null) {
  458.                                 list.add(oggetto+" '"+alias+"' attiva nella porta '"+tipo+"' '"+nomePorta+"' ");
  459.                             }
  460.                             else {
  461.                                 list.add(oggetto+" '"+alias+"' attiva nella "+label);
  462.                             }
  463.                         }
  464.                         else {
  465.                             list.add(oggetto+" '"+alias+"'");
  466.                         }
  467.         
  468.                         isInUso = true;
  469.                     }
  470.                     risultato.close();
  471.                     stmt.close();
  472.                     
  473.                 }
  474.                 
  475.             }
  476.             
  477.             
  478.             // ** Controllo che non sia riferito dalla configurazione SignalHub **      
  479.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  480.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  481.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  482.             sqlQueryObject.addFromTable(CostantiDB.PROTOCOL_PROPERTIES);
  483.             sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI,"tipo_servizio","tipoServizio");
  484.             sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI,"nome_servizio","nomeServizio");
  485.             sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI,"versione_servizio","versioneServizio");
  486.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI,"tipo_soggetto","tipoSoggetto");
  487.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI,"nome_soggetto","nomeSoggetto");
  488.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  489.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id = " + CostantiDB.PROTOCOL_PROPERTIES + ".id_proprietario");
  490.             sqlQueryObject.addWhereCondition(CostantiDB.PROTOCOL_PROPERTIES + ".tipo_proprietario=?");
  491.             sqlQueryObject.addWhereCondition(CostantiDB.PROTOCOL_PROPERTIES + ".name=?");
  492.             sqlQueryObject.addWhereCondition(CostantiDB.PROTOCOL_PROPERTIES + ".value_string=?");
  493.             sqlQueryObject.setANDLogicOperator(true);
  494.             queryString = sqlQueryObject.createSQLQuery();
  495.             stmt = con.prepareStatement(queryString);
  496.             int index = 1;
  497.             stmt.setString(index++, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_SPECIFICA.name());
  498.             stmt.setString(index++, CostantiDB.MODIPA_API_IMPL_INFO_SIGNAL_HUB_PUBLISHER_ROLE_ID);
  499.             stmt.setString(index++, idRuolo.getNome());
  500.             risultato = stmt.executeQuery();
  501.             while(risultato.next()) {
  502.                 
  503.                 IDServizio idS = IDServizioFactory.getInstance().getIDServizioFromValues(risultato.getString("tipoServizio"), risultato.getString("nomeServizio"), 
  504.                         risultato.getString("tipoSoggetto"), risultato.getString("nomeSoggetto"), 
  505.                         risultato.getInt("versioneServizio"));
  506.                 
  507.                 // trovata
  508.                 IDPortaApplicativa idPA = DBMappingUtils.getIDPortaApplicativaAssociataDefault(idS, con, tipoDB);
  509.                 if(idPA!=null) {
  510.                     ResultPorta resultPorta = DBOggettiInUsoUtils.formatPortaApplicativa(idPA.getNome(), tipoDB, con, normalizeObjectIds);
  511.                     modiSignalHubList.add(resultPorta.label);
  512.                 }
  513.                 else {
  514.                     modiSignalHubList.add(idS.toString());
  515.                 }
  516.                 
  517.                 isInUso = true;
  518.                 
  519.             }
  520.             risultato.close();
  521.             stmt.close();
  522.             
  523.             
  524.             return isInUso;

  526.         } catch (Exception se) {
  527.             throw new UtilsException("[DBOggettiInUsoUtils::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  528.         } finally {
  529.             // Chiudo statement and resultset
  530.             JDBCUtilities.closeResources(risultato, stmt);
  531.         }
  532.     }


  535.     protected static String toString(IDRuolo idRuolo, Map<ErrorsHandlerCostant, List<String>> whereIsInUso, boolean prefix, String separator){
  536.         return toString(idRuolo, whereIsInUso, prefix, separator," non eliminabile perch&egrave; :");
  537.     }
  538.     protected static String toString(IDRuolo idRuolo, Map<ErrorsHandlerCostant, List<String>> whereIsInUso, boolean prefix, String separator, String intestazione){
  539.         Set<ErrorsHandlerCostant> keys = whereIsInUso.keySet();
  540.         StringBuilder msgBuilder = new StringBuilder("Ruolo '"+idRuolo.getNome()+"'" + intestazione+separator);
  541.         if(!prefix){
  542.             msgBuilder = new StringBuilder("");
  543.         }
  544.         String separatorCategorie = "";
  545.         if(whereIsInUso.size()>1) {
  546.             separatorCategorie = separator;
  547.         }
  548.         for (ErrorsHandlerCostant key : keys) {
  549.             List<String> messages = whereIsInUso.get(key);

  551.             if ( messages!=null && !messages.isEmpty()) {
  552.                 msgBuilder.append(separatorCategorie);
  553.             }
  554.             
  555.             switch (key) {
  556.             case IN_USO_IN_SOGGETTI:
  557.                 if ( messages!=null && !messages.isEmpty()) {
  558.                     msgBuilder.append("utilizzato nei Soggetti: " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  559.                 }
  560.                 break;
  561.             case IN_USO_IN_SERVIZI_APPLICATIVI:
  562.                 if ( messages!=null && !messages.isEmpty()) {
  563.                     msgBuilder.append("utilizzato negli Applicativi: " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  564.                 }
  565.                 break;
  566.                 
  567.             case IN_USO_IN_PORTE_APPLICATIVE:
  568.                 if ( messages!=null && !messages.isEmpty()) {
  569.                     msgBuilder.append("utilizzato nelle Porte Inbound (Controllo Accessi - Autorizzazione Trasporto): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  570.                 }
  571.                 break;
  572.             case IN_USO_IN_PORTE_APPLICATIVE_MODI:
  573.                 if ( messages!=null && !messages.isEmpty()) {
  574.                     msgBuilder.append("utilizzato nelle Porte Inbound (Controllo Accessi - Autorizzazione Canale): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  575.                 }
  576.                 break;
  577.             case IN_USO_IN_PORTE_DELEGATE:
  578.                 if ( messages!=null && !messages.isEmpty()) {
  579.                     msgBuilder.append("utilizzato nelle Porte Outbound (Controllo Accessi - Autorizzazione Trasporto): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  580.                 }
  581.                 break;
  582.             case IN_USO_IN_MAPPING_EROGAZIONE_PA:
  583.                 if ( messages!=null && !messages.isEmpty()) {
  584.                     msgBuilder.append("utilizzato nelle Erogazioni (Controllo Accessi - Autorizzazione Trasporto): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  585.                 }
  586.                 break;
  587.             case IN_USO_IN_MAPPING_EROGAZIONE_PA_MODI:
  588.                 if ( messages!=null && !messages.isEmpty()) {
  589.                     msgBuilder.append("utilizzato nelle Erogazioni (Controllo Accessi - Autorizzazione Canale): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  590.                 }
  591.                 break;
  592.             case IN_USO_IN_MAPPING_FRUIZIONE_PD:
  593.                 if ( messages!=null && !messages.isEmpty()) {
  594.                     msgBuilder.append("utilizzato nelle Fruizioni (Controllo Accessi - Autorizzazione Trasporto): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  595.                 }
  596.                 break;
  597.                 
  598.             case RUOLI_TOKEN_PA:
  599.                 if ( messages!=null && !messages.isEmpty()) {
  600.                     msgBuilder.append("utilizzato nelle Porte Inbound (Controllo Accessi - Autorizzazione Token): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  601.                 }
  602.                 break;
  603.             case RUOLI_TOKEN_PA_MODI:
  604.                 if ( messages!=null && !messages.isEmpty()) {
  605.                     msgBuilder.append("utilizzato nelle Porte Inbound (Controllo Accessi - Autorizzazione Messaggio): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  606.                 }
  607.                 break;
  608.             case RUOLI_TOKEN_PD:
  609.                 if ( messages!=null && !messages.isEmpty()) {
  610.                     msgBuilder.append("utilizzato nelle Porte Outbound (Controllo Accessi - Autorizzazione Token): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  611.                 }
  612.                 break;
  613.             case RUOLI_TOKEN_MAPPING_PA:
  614.                 if ( messages!=null && !messages.isEmpty()) {
  615.                     msgBuilder.append("utilizzato nelle Erogazioni (Controllo Accessi - Autorizzazione Token): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  616.                 }
  617.                 break;
  618.             case RUOLI_TOKEN_MAPPING_PA_MODI:
  619.                 if ( messages!=null && !messages.isEmpty()) {
  620.                     msgBuilder.append("utilizzato nelle Erogazioni (Controllo Accessi - Autorizzazione Messaggio): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  621.                 }
  622.                 break;
  623.             case RUOLI_TOKEN_MAPPING_PD:
  624.                 if ( messages!=null && !messages.isEmpty()) {
  625.                     msgBuilder.append("utilizzato nelle Fruizioni (Controllo Accessi - Autorizzazione Token): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  626.                 }
  627.                 break;
  628.                 
  629.             case CONTROLLO_TRAFFICO:
  630.                 if ( messages!=null && !messages.isEmpty()) {
  631.                     msgBuilder.append("utilizzato in Policy di Rate Limiting: " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  632.                 }
  633.                 break;
  634.             case ALLARMI:
  635.                 if ( messages!=null && !messages.isEmpty()) {
  636.                     msgBuilder.append("utilizzato in Allarmi: " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  637.                 }
  638.                 break;
  639.                 
  640.             case IS_RIFERITA_MODI_SIGNAL_HUB:
  641.                 if ( messages!=null && !messages.isEmpty() ) {
  642.                     msgBuilder.append("riferito nella configurazione 'SignalHub' dell'erogazione: " + DBOggettiInUsoUtils.formatList(messages,separator) + separator);
  643.                 }
  644.                 break;              
  645.                 
  646.             default:
  647.                 msgBuilder.append("utilizzato in oggetto non codificato ("+key+")"+separator);
  648.                 break;
  649.             }

  651.         }// chiudo for

  653.         return msgBuilder.toString();
  654.     }

  656.     
  657. }
Created with JaCoCo 0.8.8.202204050719