DBOggettiInUsoUtils_accordiCooperazione.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.id.IDAccordoCooperazione;
  35. import org.openspcoop2.core.id.IDSoggetto;
  36. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  37. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  38. import org.openspcoop2.utils.UtilsException;
  39. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  40. import org.openspcoop2.utils.sql.ISQLQueryObject;
  41. import org.openspcoop2.utils.sql.SQLObjectFactory;

  43. /**
  44.  * DBOggettiInUsoUtils_accordiCooperazione
  45.  * 
  46.  * @author Andrea Poli (apoli@link.it)
  47.  * @author $Author$
  48.  * @version $Rev$, $Date$
  49.  * 
  50.  */
  51. public class DBOggettiInUsoUtils_accordiCooperazione {

  53.     protected static boolean isAccordoCooperazioneInUso(Connection con, String tipoDB, IDAccordoCooperazione idAccordo, 
  54.             Map<ErrorsHandlerCostant,List<String>> whereIsInUso, boolean normalizeObjectIds) throws UtilsException {
  55.         String nomeMetodo = "isAccordoCooperazioneInUso";

  57.         PreparedStatement stmt = null;
  58.         ResultSet risultato = null;
  59.         PreparedStatement stmt2 = null;
  60.         ResultSet risultato2 = null;
  61.         String queryString;
  62.         try {
  63.             boolean isInUso = false;


  66.             long idAccordoServizioParteComune = DBUtils.getIdAccordoCooperazione(idAccordo, con, tipoDB);
  67.             if(idAccordoServizioParteComune<=0){
  68.                 throw new UtilsException("Accordi di Cooperazione con id ["+idAccordo.toString()+"] non trovato");
  69.             }

  71.             List<String> accordi_list = whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_ACCORDI);

  73.             if (accordi_list == null) {
  74.                 accordi_list = new ArrayList<>();
  75.                 whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_ACCORDI, accordi_list);
  76.             }

  78.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDB);
  79.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  80.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  81.             sqlQueryObject.addSelectField("*");
  82.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo_cooperazione = ?");
  83.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo = "+CostantiDB.ACCORDI+".id");
  84.             sqlQueryObject.setANDLogicOperator(true);
  85.             queryString = sqlQueryObject.createSQLQuery();
  86.             stmt = con.prepareStatement(queryString);
  87.             stmt.setLong(1, idAccordoServizioParteComune);
  88.             risultato = stmt.executeQuery();
  89.             while (risultato.next()){
  90.                 isInUso=true;
  91.                 
  92.                 String nomeAccordo = risultato.getString("nome");
  93.                 int versione = risultato.getInt("versione");
  94.                 long idReferente = risultato.getLong("id_referente");
  95.                 IDSoggetto idReferenteObject = null;
  96.                 
  97.                 if(idReferente>0){

  99.                     ISQLQueryObject sqlQueryObjectReferente = SQLObjectFactory.createSQLQueryObject(tipoDB);
  100.                     sqlQueryObjectReferente.addFromTable(CostantiDB.SOGGETTI);
  101.                     sqlQueryObjectReferente.addSelectField("*");
  102.                     sqlQueryObjectReferente.addWhereCondition("id=?");
  103.                     sqlQueryObjectReferente.setANDLogicOperator(true);
  104.                     String queryStringReferente = sqlQueryObjectReferente.createSQLQuery();
  105.                     stmt2 = con.prepareStatement(queryStringReferente);
  106.                     stmt2.setLong(1, idReferente);
  107.                     risultato2 = stmt2.executeQuery();
  108.                     if(risultato2.next()){
  109.                         idReferenteObject = new IDSoggetto();
  110.                         idReferenteObject.setTipo(risultato2.getString("tipo_soggetto"));
  111.                         idReferenteObject.setNome(risultato2.getString("nome_soggetto"));
  112.                     }
  113.                     risultato2.close(); risultato2=null;
  114.                     stmt2.close(); stmt2=null;

  116.                 }
  117.                 
  118.                 if(normalizeObjectIds && idReferenteObject!=null) {
  119.                     String protocollo = ProtocolFactoryManager.getInstance().getProtocolByOrganizationType(idReferenteObject.getTipo());
  120.                     IDAccordoCooperazione idAccordoCooperazione = IDAccordoCooperazioneFactory.getInstance().getIDAccordoFromValues(nomeAccordo, idReferenteObject, versione); 
  121.                     accordi_list.add(DBOggettiInUsoUtils.getProtocolPrefix(protocollo)+NamingUtils.getLabelAccordoCooperazione(protocollo, idAccordoCooperazione));
  122.                 }
  123.                 else {

  125.                     StringBuilder bf = new StringBuilder();

  127.                     bf.append(idReferenteObject!=null ? idReferenteObject.getTipo() : "?");
  128.                     bf.append("/");
  129.                     bf.append(idReferenteObject!=null ? idReferenteObject.getNome() : "?");
  130.                     bf.append(":");
  131.                     
  132.                     bf.append(nomeAccordo);
  133.     
  134.                     if(idReferente>0){
  135.                         bf.append(":");
  136.                         bf.append(versione);
  137.                     }
  138.     
  139.                     accordi_list.add(bf.toString());
  140.                 }
  141.                 
  142.             }
  143.             risultato.close();
  144.             stmt.close();


  147.             return isInUso;

  149.         } catch (Exception se) {

  151.             throw new UtilsException("[DBOggettiInUsoUtils::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  152.         } finally {
  153.             //Chiudo statement and resultset
  154.             JDBCUtilities.closeResources(risultato, stmt);
  155.             JDBCUtilities.closeResources(risultato2, stmt2);
  156.         }
  157.     }

  159.     protected static String toString(IDAccordoCooperazione idAccordo, Map<ErrorsHandlerCostant, List<String>> whereIsInUso, boolean prefix, String separator, boolean normalizeObjectIds){

  161.         StringBuilder bf = new StringBuilder();
  162.         if(normalizeObjectIds && idAccordo.getSoggettoReferente()!=null) {
  163.             try {
  164.                 String protocollo = ProtocolFactoryManager.getInstance().getProtocolByOrganizationType(idAccordo.getSoggettoReferente().getTipo());
  165.                 String labelAccordo = DBOggettiInUsoUtils.getProtocolPrefix(protocollo)+NamingUtils.getLabelAccordoCooperazione(protocollo, idAccordo);
  166.                 bf.append(labelAccordo);
  167.             }catch(Exception e) {
  168.                 bf.append(idAccordo.toString());
  169.             }
  170.         }
  171.         else {
  172.             bf.append(idAccordo.toString());
  173.         }

  175.         Set<ErrorsHandlerCostant> keys = whereIsInUso.keySet();
  176.         String msg = "Accordo Cooperazione '"+bf.toString() + "' non eliminabile perch&egrave; :"+separator;
  177.         if(prefix==false){
  178.             msg = "";
  179.         }
  180.         String separatorCategorie = "";
  181.         if(whereIsInUso.size()>1) {
  182.             separatorCategorie = separator;
  183.         }
  184.         for (ErrorsHandlerCostant key : keys) {
  185.             List<String> messages = whereIsInUso.get(key);

  187.             if ( messages!=null && messages.size() > 0) {
  188.                 msg += separatorCategorie;
  189.             }
  190.             
  191.             switch (key) {
  192.             case IN_USO_IN_ACCORDI:
  193.                 if ( messages!=null && messages.size() > 0) {
  194.                     msg += "riferito da API (Servizi Composti): " + DBOggettiInUsoUtils.formatList(messages,separator) + separator;
  195.                 }
  196.                 break;
  197.             default:
  198.                 msg += "utilizzato in oggetto non codificato ("+key+")"+separator;
  199.                 break;
  200.             }

  202.         }// chiudo for

  204.         return msg;
  205.     }

  207. }
Created with JaCoCo 0.8.8.202204050719