ServiziApplicativiUtilities.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.web.ctrlstat.servlet.sa;

  23. import java.util.ArrayList;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.openspcoop2.core.commons.ErrorsHandlerCostant;
  29. import org.openspcoop2.core.commons.Liste;
  30. import org.openspcoop2.core.config.Connettore;
  31. import org.openspcoop2.core.config.InvocazioneServizio;
  32. import org.openspcoop2.core.config.ServizioApplicativo;
  33. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  34. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  35. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  36. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  37. import org.openspcoop2.core.constants.TipiConnettore;
  38. import org.openspcoop2.core.id.IDServizioApplicativo;
  39. import org.openspcoop2.core.id.IDSoggetto;
  40. import org.openspcoop2.core.registry.Soggetto;
  41. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  42. import org.openspcoop2.protocol.engine.utils.DBOggettiInUsoUtils;
  43. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  44. import org.openspcoop2.web.ctrlstat.servlet.pdd.PddCore;
  45. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  46. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCostanti;

  48. /**
  49.  * ServiziApplicativiUtilities
  50.  * 
  51.  * @author Andrea Poli (apoli@link.it)
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  * 
  55.  */
  56. public class ServiziApplicativiUtilities {
  57.     
  58.     public static List<Object> getOggettiDaAggiornare(ServiziApplicativiCore saCore,
  59.             IDServizioApplicativo oldIdServizioApplicativo,
  60.             ServizioApplicativo sa) throws Exception{
  61.         
  62.         // Oggetti da modificare (per riflettere la modifica sul connettore)
  63.         ServiziApplicativiUpdateUtilities saUpdateUtilities = 
  64.                 new ServiziApplicativiUpdateUtilities(saCore, oldIdServizioApplicativo, sa);
  65.         
  66.         // ServizioApplicativo
  67.         // aggiungo il sa da aggiornare
  68.         saUpdateUtilities.addServizioApplicativo();
  69.         
  70.         // RateLimiting
  71.         saUpdateUtilities.checkRateLimiting();
  72.         
  73.         return saUpdateUtilities.getOggettiDaAggiornare();
  74.     }
  75.     
  76.     
  77.     public static boolean deleteServizioApplicativo(ServizioApplicativo sa, String userLogin, ServiziApplicativiCore saCore, ServiziApplicativiHelper saHelper, StringBuilder inUsoMessage, String newLine) throws Exception {
  78.         
  79.         IDServizioApplicativo idServizioApplicativo = new IDServizioApplicativo();
  80.         idServizioApplicativo.setNome(sa.getNome());
  81.         idServizioApplicativo.setIdSoggettoProprietario(new IDSoggetto(sa.getTipoSoggettoProprietario(), sa.getNomeSoggettoProprietario()));
  82.         
  83.         // Controllo che il sil non sia in uso
  84.         Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  85.         boolean normalizeObjectIds = !saHelper.isModalitaCompleta();
  86.         boolean verificaRuoli = false;
  87.         boolean saInUso  = saCore.isServizioApplicativoInUso(idServizioApplicativo, whereIsInUso, saCore.isRegistroServiziLocale(), normalizeObjectIds, verificaRuoli);
  88.         
  89.         if (saInUso) {
  90.             
  91.             inUsoMessage.append(DBOggettiInUsoUtils.toString(idServizioApplicativo, whereIsInUso, true, newLine,normalizeObjectIds));
  92.             inUsoMessage.append(newLine);

  94.         } else {

  96.             // Elimino il sil
  97.             saCore.performDeleteOperation(userLogin, saHelper.smista(), sa);
  98.             
  99.             return true;
  100.         }
  101.         
  102.         return false;
  103.         
  104.     }
  105.     
  106.     public static ServiziApplicativiGeneralInfo getGeneralInfo(boolean useIdSogg, String provider, List<String> listaTipiProtocollo,
  107.             ServiziApplicativiCore saCore, ServiziApplicativiHelper saHelper, String superUser, boolean singlePdD,
  108.             String soggettoMultitenantSelezionato, String dominio) throws Exception {
  109.         
  110.         SoggettiCore soggettiCore = new SoggettiCore(saCore);
  111.         PddCore pddCore = new PddCore(saCore);
  112.         
  113.         String[] soggettiList = null;
  114.         String[] soggettiListLabel = null;
  115.         
  116.         String tipoProtocollo = null;
  117.         String tipoENomeSoggetto = "";
  118.         IDSoggetto idSoggetto = null;
  119.         if(useIdSogg) {
  120.             org.openspcoop2.core.config.Soggetto soggetto = soggettiCore.getSoggetto(Long.parseLong(provider)); 
  121.             if(tipoProtocollo == null){
  122.                 tipoProtocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(soggetto.getTipo());
  123.             }
  124.             tipoENomeSoggetto = saHelper.getLabelNomeSoggetto(tipoProtocollo, soggetto.getTipo() , soggetto.getNome());
  125.             idSoggetto = new IDSoggetto(soggetto.getTipo() , soggetto.getNome());
  126.             
  127.             soggettiList = new String[1];
  128.             soggettiList[0] = soggetto.getId().toString();
  129.             soggettiListLabel = new String[1];
  130.             soggettiListLabel[0] =saHelper.getLabelNomeSoggetto(tipoProtocollo, soggetto.getTipo() , soggetto.getNome());
  131.         }
  132.         else {
  133.             
  134.             long idProvider = -1;
  135.             try {
  136.                 if(provider!=null) {
  137.                     idProvider = Long.parseLong(provider);
  138.                 }
  139.             }catch(Exception e) {
  140.                 // ignore
  141.             }
  142.             
  143.             tipoProtocollo = saHelper.getParameter(ServiziApplicativiCostanti.PARAMETRO_SERVIZI_APPLICATIVI_PROTOCOLLO);
  144.             if(tipoProtocollo == null){
  145.                 tipoProtocollo = saCore.getProtocolloDefault(saHelper.getRequest(), saHelper.getSession(), listaTipiProtocollo);
  146.             }
  147.         
  148.             boolean filtraSoggettiEsterni = false;
  149.             boolean isSupportatoAutenticazioneApplicativiEsterni = saCore.isSupportatoAutenticazioneApplicativiEsterniErogazione(tipoProtocollo);
  150.             if(isSupportatoAutenticazioneApplicativiEsterni) {
  151.                 filtraSoggettiEsterni = SoggettiCostanti.SOGGETTO_DOMINIO_ESTERNO_VALUE.equals(dominio);
  152.             }
  153.                 
  154.             List<String> tipiSoggettiCompatibiliGestitiProtocollo = soggettiCore.getTipiSoggettiGestitiProtocollo(tipoProtocollo);
  155.             long providerTmp = -1;
  156.             
  157.             ConsoleSearch searchSoggetti = new ConsoleSearch(true);
  158.             saHelper.setFilterSelectedProtocol(searchSoggetti, Liste.SOGGETTI);
  159.             
  160.             if(saCore.isRegistroServiziLocale()){
  161.                 List<Soggetto> list = null;
  162.                 if(!filtraSoggettiEsterni && soggettoMultitenantSelezionato!=null && !"".equals(soggettoMultitenantSelezionato)) {
  163.                     IDSoggetto idSoggettoSelezionato = soggettiCore.convertSoggettoSelezionatoToID(soggettoMultitenantSelezionato);
  164.                     list = new ArrayList<>();
  165.                     try {
  166.                         list.add(soggettiCore.getSoggettoRegistro(idSoggettoSelezionato));
  167.                     }catch(DriverRegistroServiziNotFound notFound) {}
  168.                 }
  169.                 else {
  170.                     if(saCore.isVisioneOggettiGlobale(superUser)){
  171.                         list = soggettiCore.soggettiRegistroList(null,searchSoggetti);
  172.                     }else{
  173.                         list = soggettiCore.soggettiRegistroList(superUser,searchSoggetti); 
  174.                     }
  175.                 }
  176.                 
  177.                 // Filtro per pdd esterne
  178.                 if(singlePdD){
  179.                     List<Soggetto> listFiltrata = new ArrayList<Soggetto>();
  180.                     for (Soggetto soggetto : list) {
  181.                         boolean pddEsterna = pddCore.isPddEsterna(soggetto.getPortaDominio());
  182.                         if(filtraSoggettiEsterni) {
  183.                             if(pddEsterna){
  184.                                 listFiltrata.add(soggetto);
  185.                                 if(soggetto.getId().longValue()==idProvider) {
  186.                                     providerTmp = idProvider;
  187.                                 }
  188.                             }
  189.                         }
  190.                         else {
  191.                             if(!pddEsterna){
  192.                                 listFiltrata.add(soggetto);
  193.                                 if(soggetto.getId().longValue()==idProvider) {
  194.                                     providerTmp = idProvider;
  195.                                 }
  196.                             }
  197.                         }
  198.                     }
  199.                     list = listFiltrata;
  200.                 }
  201.                 if (list.size() > 0) {
  202.                     List<Soggetto> listFiltrataCompatibileProtocollo =  new ArrayList<Soggetto>();
  203.                     for (Soggetto soggetto : list) {
  204.                         if(tipiSoggettiCompatibiliGestitiProtocollo.contains(soggetto.getTipo())){
  205.                             listFiltrataCompatibileProtocollo.add(soggetto);
  206.                             if(providerTmp < 0 || providerTmp == soggetto.getId().longValue()) {
  207.                                 providerTmp = soggetto.getId();
  208.                                 idSoggetto = new IDSoggetto(soggetto.getTipo() , soggetto.getNome());
  209.                             }
  210.                         }
  211.                     }
  212.                     if (listFiltrataCompatibileProtocollo.size() > 0) {
  213.                         soggettiList = new String[listFiltrataCompatibileProtocollo.size()];
  214.                         soggettiListLabel = new String[listFiltrataCompatibileProtocollo.size()];
  215.                         int i = 0;
  216.                         for (Soggetto soggetto : listFiltrataCompatibileProtocollo) {
  217.                             soggettiList[i] = soggetto.getId().toString();
  218.                             soggettiListLabel[i] =saHelper.getLabelNomeSoggetto(tipoProtocollo, soggetto.getTipo() , soggetto.getNome());
  219.                             i++;
  220.                         }
  221.                     }
  222.                 }
  223.             }
  224.             else{
  225.                 List<org.openspcoop2.core.config.Soggetto> list = null;
  226.                 if(soggettoMultitenantSelezionato!=null && !"".equals(soggettoMultitenantSelezionato)) {
  227.                     IDSoggetto idSoggettoSelezionato = soggettiCore.convertSoggettoSelezionatoToID(soggettoMultitenantSelezionato);
  228.                     list = new ArrayList<>();
  229.                     try {
  230.                         list.add(soggettiCore.getSoggetto(idSoggettoSelezionato));
  231.                     }catch(DriverConfigurazioneNotFound notFound) {}
  232.                 }
  233.                 else {
  234.                     if(saCore.isVisioneOggettiGlobale(superUser)){
  235.                         list = soggettiCore.soggettiList(null,searchSoggetti);
  236.                     }else{
  237.                         list = soggettiCore.soggettiList(superUser,searchSoggetti); 
  238.                     }
  239.                 }
  240.                 
  241.                 List<org.openspcoop2.core.config.Soggetto> listFiltrataCompatibileProtocollo =  new ArrayList<org.openspcoop2.core.config.Soggetto>();
  242.                 for (org.openspcoop2.core.config.Soggetto soggetto : list) {
  243.                     if(tipiSoggettiCompatibiliGestitiProtocollo.contains(soggetto.getTipo())){
  244.                         listFiltrataCompatibileProtocollo.add(soggetto);
  245.                         if(providerTmp < 0) {
  246.                             providerTmp = soggetto.getId();
  247.                             idSoggetto = new IDSoggetto(soggetto.getTipo() , soggetto.getNome());
  248.                         }
  249.                     }
  250.                 }
  251.                 
  252.                 if (listFiltrataCompatibileProtocollo.size() > 0) {
  253.                     soggettiList = new String[listFiltrataCompatibileProtocollo.size()];
  254.                     soggettiListLabel = new String[listFiltrataCompatibileProtocollo.size()];
  255.                     int i = 0;
  256.                     for (org.openspcoop2.core.config.Soggetto soggetto : listFiltrataCompatibileProtocollo) {
  257.                         soggettiList[i] = soggetto.getId().toString();
  258.                         soggettiListLabel[i] =saHelper.getLabelNomeSoggetto(tipoProtocollo, soggetto.getTipo() , soggetto.getNome());
  259.                         i++;
  260.                     }
  261.                 }
  262.             }
  263.             
  264.             if(provider == null){
  265.                 provider = providerTmp +"";
  266.             }
  267.         }
  268.         
  269.         ServiziApplicativiGeneralInfo saGeneralInfo = new ServiziApplicativiGeneralInfo();
  270.         saGeneralInfo.setSoggettiList(soggettiList);
  271.         saGeneralInfo.setSoggettiListLabel(soggettiListLabel);
  272.         saGeneralInfo.setTipoENomeSoggetto(tipoENomeSoggetto);
  273.         saGeneralInfo.setTipoProtocollo(tipoProtocollo);
  274.         saGeneralInfo.setProvider(provider);
  275.         saGeneralInfo.setIdSoggetto(idSoggetto);
  276.         return saGeneralInfo;
  277.     }
  278.     
  279.     public static void checkStatoConnettore(ServiziApplicativiCore saCore, ServizioApplicativo sa, Connettore connis, StringBuilder inUsoMessage, String newLine) throws DriverConfigurazioneException {
  280.         InvocazioneServizio invServizio = sa.getInvocazioneServizio();
  281.         StatoFunzionalita getMessage = invServizio != null ? invServizio.getGetMessage() : null;
  282.         if (TipiConnettore.DISABILITATO.getNome().equals(connis.getTipo()) && CostantiConfigurazione.DISABILITATO.equals(getMessage)) {
  283.             Map<ErrorsHandlerCostant, String> whereIsInUso = new HashMap<ErrorsHandlerCostant, String>();
  284.             if (saCore.isServizioApplicativoInUsoComeErogatore(sa, whereIsInUso)) {

  286.                 // se in uso in porte applicative allora impossibile
  287.                 // disabilitare connettore o getmessage
  288.                 if (whereIsInUso.containsKey(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE)) {
  289.                     inUsoMessage.append("Impossibile disabilitare il GetMessage o il Connettore in quanto il Servizio Applicativo [" + 
  290.                             sa.getNome() + "]"+ newLine + " รจ in uso in Porta Applicative " + whereIsInUso.get(ErrorsHandlerCostant.IN_USO_IN_PORTE_APPLICATIVE));
  291.                     return;
  292.                 }

  294.             }
  295.         }
  296.     }
  297. }
Created with JaCoCo 0.8.8.202204050719