UtilitiesMappingFruizioneErogazione.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.archive;

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

  28. import org.openspcoop2.core.config.PortaApplicativa;
  29. import org.openspcoop2.core.config.PortaApplicativaServizioApplicativo;
  30. import org.openspcoop2.core.config.PortaDelegata;
  31. import org.openspcoop2.core.config.constants.PortaApplicativaAzioneIdentificazione;
  32. import org.openspcoop2.core.config.constants.PortaDelegataAzioneIdentificazione;
  33. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  34. import org.openspcoop2.core.config.driver.FiltroRicercaPorteApplicative;
  35. import org.openspcoop2.core.config.driver.FiltroRicercaPorteDelegate;
  36. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  37. import org.openspcoop2.core.constants.Costanti;
  38. import org.openspcoop2.core.id.IDAccordo;
  39. import org.openspcoop2.core.id.IDPortaApplicativa;
  40. import org.openspcoop2.core.id.IDPortaDelegata;
  41. import org.openspcoop2.core.id.IDServizio;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.mapping.DBMappingUtils;
  44. import org.openspcoop2.core.mapping.Implementation;
  45. import org.openspcoop2.core.mapping.ImplementationUtils;
  46. import org.openspcoop2.core.mapping.MappingErogazionePortaApplicativa;
  47. import org.openspcoop2.core.mapping.MappingFruizionePortaDelegata;
  48. import org.openspcoop2.core.mapping.SubscriptionUtils;
  49. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  50. import org.openspcoop2.core.registry.constants.PddTipologia;
  51. import org.openspcoop2.core.registry.constants.ServiceBinding;
  52. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  53. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  54. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  55. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  56. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  57. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  58. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  59. import org.openspcoop2.core.registry.utils.RegistroServiziUtils;
  60. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  61. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  62. import org.openspcoop2.protocol.sdk.ProtocolException;
  63. import org.openspcoop2.protocol.sdk.config.ProtocolSubscription;
  64. import org.slf4j.Logger;


  67. /**
  68.  *  UtilitiesMappingFruizionePD
  69.  *
  70.  * @author Poli Andrea (apoli@link.it)
  71.  * @author $Author$
  72.  * @version $Rev$, $Date$
  73.  */
  74. public class UtilitiesMappingFruizioneErogazione  {

  76.     private DriverConfigurazioneDB driverConfigurazione;
  77.     private DriverRegistroServiziDB driverRegistroServizi;
  78.     private Logger log;
  79.     
  80.     public UtilitiesMappingFruizioneErogazione(DriverConfigurazioneDB driverConfigurazione,
  81.             DriverRegistroServiziDB driverRegistroServizi,
  82.             Logger log){
  83.         this.driverConfigurazione = driverConfigurazione;
  84.         this.driverRegistroServizi = driverRegistroServizi;
  85.         this.log = log;
  86.     }
  87.     
  88.     public void initMappingFruizione() throws ProtocolException {
  89.         this._initMapping(false);
  90.     }
  91.     public void initMappingErogazione() throws ProtocolException {
  92.         this._initMapping(true);
  93.     }
  94.     private void _initMapping(boolean erogazione) throws ProtocolException {
  95.         
  96.         try {

  98.             List<String> tipiPdd = new ArrayList<>();
  99.             tipiPdd.add(PddTipologia.OPERATIVO.toString());
  100.             tipiPdd.add(PddTipologia.NONOPERATIVO.toString());
  101.             
  102.             for (String tipoPdd : tipiPdd) {
  103.                 
  104.                 this.log.debug("Pdd (tipo:"+tipoPdd+") ricerca in corso...");
  105.                 FiltroRicerca filtroPdd = new FiltroRicerca();
  106.                 filtroPdd.setTipo(tipoPdd);
  107.                 List<String> listPdD = null;
  108.                 try{
  109.                     listPdD = this.driverRegistroServizi.getAllIdPorteDominio(filtroPdd);
  110.                 }catch(DriverRegistroServiziNotFound notFound){}
  111.                 if(listPdD==null){
  112.                     listPdD = new ArrayList<>();
  113.                 }
  114.                 this.log.debug("Pdd (tipo:"+tipoPdd+") trovate: "+listPdD.size());
  115.                 
  116.                 if(listPdD.size()>0){
  117.                     
  118.                     for (String nomePdd : listPdD) {
  119.                         
  120.                         this.log.debug("Soggetti (pdd:"+nomePdd+") ricerca in corso...");
  121.                         FiltroRicercaSoggetti filtroSoggetti = new FiltroRicercaSoggetti();
  122.                         filtroSoggetti.setNomePdd(nomePdd);
  123.                         List<IDSoggetto> listSoggetti = null;
  124.                         try{
  125.                             listSoggetti = this.driverRegistroServizi.getAllIdSoggetti(filtroSoggetti);
  126.                         }catch(DriverRegistroServiziNotFound notFound){}
  127.                         if(listSoggetti==null){
  128.                             listSoggetti = new ArrayList<>();
  129.                         }
  130.                         this.log.debug("Soggetti (pdd:"+nomePdd+") trovati: "+listSoggetti.size());
  131.                         
  132.                         if(listSoggetti.size()>0){
  133.                         
  134.                             for (IDSoggetto idSoggetto : listSoggetti) {
  135.                                 
  136.                                 if(erogazione){
  137.                                 
  138.                                     // erogazione
  139.                                     
  140.                                     this.log.debug("Servizi (soggetto:"+idSoggetto+") ricerca in corso...");
  141.                                     FiltroRicercaServizi filtroServizi = new FiltroRicercaServizi();
  142.                                     filtroServizi.setTipoSoggettoErogatore(idSoggetto.getTipo());
  143.                                     filtroServizi.setNomeSoggettoErogatore(idSoggetto.getNome());
  144.                                     List<IDServizio> listServizi = null;
  145.                                     try{
  146.                                         listServizi = this.driverRegistroServizi.getAllIdServizi(filtroServizi);
  147.                                     }catch(DriverRegistroServiziNotFound notFound){}
  148.                                     if(listServizi==null){
  149.                                         listServizi = new ArrayList<>();
  150.                                     }
  151.                                     this.log.debug("Servizi (soggetto:"+idSoggetto+") trovati: "+listServizi.size());
  152.                                     
  153.                                     if(listServizi.size()>0){
  154.                                         
  155.                                         for (IDServizio idServizio : listServizi) {
  156.                                                 
  157.                                             // Devo controllare il mapping per ogni porta applicativa
  158. //                                          Connection con = null;
  159. //                                          try{
  160. //                                              con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.existsIDPortaApplicativaAssociata");
  161. //                                              if(DBMappingUtils.existsIDPortaApplicativaAssociata(idServizio, con, this.driverRegistroServizi.getTipoDB())){
  162. //                                                  this.log.debug("PortaApplicativa (soggetto:"+idSoggetto+" servizio:"+
  163. //                                                          idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") mapping già esistente");
  164. //                                                  continue;
  165. //                                              }
  166. //                                          }finally{
  167. //                                              try{
  168. //                                                  this.driverRegistroServizi.releaseConnection(con);
  169. //                                              }catch(Throwable t){}
  170. //                                          }
  171.                                             
  172.                                             this.log.debug("PorteApplicative (soggetto:"+idSoggetto+" servizio:"+
  173.                                                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") ricerca in corso...");
  174.                                             FiltroRicercaPorteApplicative filtroPA = new FiltroRicercaPorteApplicative();
  175.                                             filtroPA.setTipoServizio(idServizio.getTipo());
  176.                                             filtroPA.setNomeServizio(idServizio.getNome());
  177.                                             filtroPA.setVersioneServizio(idServizio.getVersione());
  178.                                             filtroPA.setTipoSoggetto(idSoggetto.getTipo());
  179.                                             filtroPA.setNomeSoggetto(idSoggetto.getNome());
  180.                                             List<IDPortaApplicativa> listPA = null;
  181.                                             try{
  182.                                                 listPA = this.driverConfigurazione.getAllIdPorteApplicative(filtroPA);
  183.                                             }catch(DriverConfigurazioneNotFound notFound){}
  184.                                             if(listPA==null){
  185.                                                 listPA = new ArrayList<>();
  186.                                             }
  187.                                             this.log.debug("PorteApplicative (soggetto:"+idSoggetto+" servizio:"+
  188.                                                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") trovate: "+listPA.size());
  189.                                             
  190.                                             _gestioneMappingErogazionePA(listPA, idServizio, idSoggetto);
  191.                                         }
  192.                                         
  193.                                     }
  194.                                 }
  195.                                 else{
  196.                                     
  197.                                     // fruizione
  198.                                     
  199.                                     this.log.debug("Servizi (fruitore:"+idSoggetto+") ricerca in corso...");
  200.                                     FiltroRicercaServizi filtroServizi = new FiltroRicercaServizi();
  201.                                     filtroServizi.setTipoSoggettoFruitore(idSoggetto.getTipo());
  202.                                     filtroServizi.setNomeSoggettoFruitore(idSoggetto.getNome());
  203.                                     List<IDServizio> listServizi = null;
  204.                                     try{
  205.                                         listServizi = this.driverRegistroServizi.getAllIdServizi(filtroServizi);
  206.                                     }catch(DriverRegistroServiziNotFound notFound){}
  207.                                     if(listServizi==null){
  208.                                         listServizi = new ArrayList<>();
  209.                                     }
  210.                                     this.log.debug("Servizi (fruitore:"+idSoggetto+") trovati: "+listServizi.size());
  211.                                     
  212.                                     if(listServizi.size()>0){
  213.                                         
  214.                                         for (IDServizio idServizio : listServizi) {
  215.                                         
  216.                                             // Devo controllare il mapping per ogni porta delegata
  217. //                                          Connection con = null;
  218. //                                          try{
  219. //                                              con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.existsIDPortaDelegataAssociata");       
  220. //                                              if(DBMappingUtils.existsIDPortaDelegataAssociata(idServizio, idSoggetto, con, this.driverRegistroServizi.getTipoDB())){
  221. //                                                  this.log.debug("PortaDelegata (soggetto-fruitore:"+idSoggetto+
  222. //                                                          " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  223. //                                                          idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") mapping già esistente");
  224. //                                                  continue;
  225. //                                              }
  226. //                                          }finally{
  227. //                                              try{
  228. //                                                  this.driverRegistroServizi.releaseConnection(con);
  229. //                                              }catch(Throwable t){}
  230. //                                          }
  231.                                             
  232.                                             this.log.debug("PorteDelegate (soggetto-fruitore:"+idSoggetto+
  233.                                                         " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  234.                                                         idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") ricerca in corso...");
  235.                                             FiltroRicercaPorteDelegate filtroPD = new FiltroRicercaPorteDelegate();
  236.                                             filtroPD.setTipoSoggetto(idSoggetto.getTipo());
  237.                                             filtroPD.setNomeSoggetto(idSoggetto.getNome());
  238.                                             filtroPD.setTipoSoggettoErogatore(idServizio.getSoggettoErogatore().getTipo());
  239.                                             filtroPD.setNomeSoggettoErogatore(idServizio.getSoggettoErogatore().getNome());
  240.                                             filtroPD.setTipoServizio(idServizio.getTipo());
  241.                                             filtroPD.setNomeServizio(idServizio.getNome());
  242.                                             filtroPD.setVersioneServizio(idServizio.getVersione());
  243.                                             List<IDPortaDelegata> listPD = null;
  244.                                             try{
  245.                                                 listPD = this.driverConfigurazione.getAllIdPorteDelegate(filtroPD);
  246.                                             }catch(DriverConfigurazioneNotFound notFound){}
  247.                                             if(listPD==null){
  248.                                                 listPD = new ArrayList<>();
  249.                                             }
  250.                                             this.log.debug("PorteDelegate (soggetto-fruitore:"+idSoggetto+
  251.                                                         " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  252.                                                         idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") trovate: "+listPD.size());
  253.                                         
  254.                                             this._gestioneMappingFruizionePD(listPD, idServizio, idSoggetto);
  255.                                         }
  256.                                     }
  257.                                     
  258.                                 }
  259.                             }
  260.                             
  261.                         }
  262.                     }
  263.                     
  264.                 }
  265.     
  266.             }           
  267.             

  269.         } catch (Throwable se) {
  270.             throw new ProtocolException(se.getMessage(),se);
  271.         } 
  272.         
  273.     }
  274.     
  275.     public void gestioneMappingErogazionePAbyId(List<IDPortaApplicativa> listPA) throws Exception {
  276.         if(listPA==null || listPA.isEmpty()) {
  277.             return;
  278.         }
  279.         for (IDPortaApplicativa idPortaApplicativa : listPA) {
  280.             
  281.             PortaApplicativa pa = null;
  282.             IDSoggetto idSoggetto = null;
  283.             IDServizio idServizio = null;
  284.             Connection con = null;
  285.             try{
  286.                 con = this.driverConfigurazione.getConnection("UtilitiesMappingFruizioneErogazione.gestioneMappingErogazionePA");
  287.                 try {
  288.                     pa = this.driverConfigurazione.getPortaApplicativa(idPortaApplicativa);
  289.                     idSoggetto = new IDSoggetto(pa.getTipoSoggettoProprietario(), pa.getNomeSoggettoProprietario());
  290.                     idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(pa.getServizio().getTipo(), pa.getServizio().getNome(), 
  291.                             idSoggetto, pa.getServizio().getVersione());
  292.                 }catch(Exception e) {
  293.                     this.log.error("Errore durante il recupero della porta applicativa con id ["+idPortaApplicativa+"]: "+e.getMessage(),e);
  294.                     continue;
  295.                 }
  296.             }finally{
  297.                 try{
  298.                     this.driverConfigurazione.releaseConnection(con);
  299.                 }catch(Throwable t){}
  300.             }
  301.             
  302.             List<IDPortaApplicativa> listPA_unique = new ArrayList<>();
  303.             listPA_unique.add(idPortaApplicativa);
  304.             
  305.             this._gestioneMappingErogazionePA(listPA_unique, idServizio, idSoggetto);
  306.             
  307.         }
  308.     }
  309.     
  310.     public void gestioneMappingErogazionePA(List<PortaApplicativa> listPA) throws Exception {
  311.         if(listPA==null || listPA.isEmpty()) {
  312.             return;
  313.         }
  314.         for (PortaApplicativa pa : listPA) {
  315.             
  316.             IDSoggetto idSoggetto = null;
  317.             IDServizio idServizio = null;
  318.             IDPortaApplicativa idPortaApplicativa = null;
  319.             try {
  320.                 idSoggetto = new IDSoggetto(pa.getTipoSoggettoProprietario(), pa.getNomeSoggettoProprietario());
  321.                 idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(pa.getServizio().getTipo(), pa.getServizio().getNome(), 
  322.                         idSoggetto, pa.getServizio().getVersione());
  323.                 idPortaApplicativa = new IDPortaApplicativa();
  324.                 idPortaApplicativa.setNome(pa.getNome());
  325.             }catch(Exception e) {
  326.                 this.log.error("Errore durante la lettura dei dati della porta applicativa ["+pa.getNome()+"]: "+e.getMessage(),e);
  327.                 continue;
  328.             }
  329.             
  330.             List<IDPortaApplicativa> listPA_unique = new ArrayList<>();
  331.             listPA_unique.add(idPortaApplicativa);
  332.             
  333.             this._gestioneMappingErogazionePA(listPA_unique, idServizio, idSoggetto);
  334.             
  335.         }
  336.     }
  337.     
  338.     public void gestioneMappingFruizionePDbyId(List<IDPortaDelegata> listPD) throws Exception {
  339.         if(listPD==null || listPD.isEmpty()) {
  340.             return;
  341.         }
  342.         for (IDPortaDelegata idPortaDelegata : listPD) {
  343.             
  344.             PortaDelegata pd = null;
  345.             IDSoggetto idSoggetto = null;
  346.             IDServizio idServizio = null;
  347.             Connection con = null;
  348.             try{
  349.                 con = this.driverConfigurazione.getConnection("UtilitiesMappingFruizioneErogazione.gestioneMappingFruizionePD");
  350.                 try {
  351.                     pd = this.driverConfigurazione.getPortaDelegata(idPortaDelegata);
  352.                     idSoggetto = new IDSoggetto(pd.getTipoSoggettoProprietario(), pd.getNomeSoggettoProprietario());
  353.                     idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(pd.getServizio().getTipo(), pd.getServizio().getNome(), 
  354.                             new IDSoggetto(pd.getSoggettoErogatore().getTipo(),pd.getSoggettoErogatore().getNome()), pd.getServizio().getVersione());
  355.                 }catch(Exception e) {
  356.                     this.log.error("Errore durante il recupero della porta applicativa con id ["+idPortaDelegata+"]: "+e.getMessage(),e);
  357.                     continue;
  358.                 }
  359.             }finally{
  360.                 try{
  361.                     this.driverConfigurazione.releaseConnection(con);
  362.                 }catch(Throwable t){}
  363.             }
  364.             
  365.             List<IDPortaDelegata> listPD_unique = new ArrayList<>();
  366.             listPD_unique.add(idPortaDelegata);
  367.             
  368.             this._gestioneMappingFruizionePD(listPD_unique, idServizio, idSoggetto);
  369.             
  370.         }
  371.     }
  372.     
  373.     public void gestioneMappingFruizionePD(List<PortaDelegata> listPD) throws Exception {
  374.         if(listPD==null || listPD.isEmpty()) {
  375.             return;
  376.         }
  377.         for (PortaDelegata pd : listPD) {
  378.             
  379.             IDSoggetto idSoggetto = null;
  380.             IDServizio idServizio = null;
  381.             IDPortaDelegata idPortaDelegata = null;
  382.             try {
  383.                 idSoggetto = new IDSoggetto(pd.getTipoSoggettoProprietario(), pd.getNomeSoggettoProprietario());
  384.                 idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(pd.getServizio().getTipo(), pd.getServizio().getNome(), 
  385.                         new IDSoggetto(pd.getSoggettoErogatore().getTipo(),pd.getSoggettoErogatore().getNome()), pd.getServizio().getVersione());
  386.                 idPortaDelegata = new IDPortaDelegata();
  387.                 idPortaDelegata.setNome(pd.getNome());
  388.             }catch(Exception e) {
  389.                 this.log.error("Errore durante la lettura dei dati della porta delegata ["+pd.getNome()+"]: "+e.getMessage(),e);
  390.                 continue;
  391.             }
  392.             
  393.             List<IDPortaDelegata> listPD_unique = new ArrayList<>();
  394.             listPD_unique.add(idPortaDelegata);
  395.             
  396.             this._gestioneMappingFruizionePD(listPD_unique, idServizio, idSoggetto);
  397.             
  398.         }
  399.     }
  400.     
  401.     private void _gestioneMappingErogazionePA(List<IDPortaApplicativa> listPA, IDServizio idServizio, IDSoggetto idSoggetto) throws Exception {
  402.         
  403.         if(listPA==null || listPA.isEmpty()) {
  404.             return;
  405.         }
  406.         
  407.         String nomePortaDefault = null;
  408.         HashMap<String, IDPortaApplicativa> mapPorte = new HashMap<>(); 
  409.         HashMap<IDPortaApplicativa, PortaApplicativa> listPAModificare = new  HashMap<>(); 
  410.         for (IDPortaApplicativa idPortaApplicativa : listPA) {
  411.             
  412.             Connection con = null;
  413.             try{
  414.                 con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.existsIDPortaApplicativaAssociata");
  415.                 if(DBMappingUtils.existsMappingErogazione(idServizio, idPortaApplicativa, con, this.driverRegistroServizi.getTipoDB())){
  416.                     this.log.debug("PortaApplicativa '"+idPortaApplicativa.getNome()+"' (soggetto:"+idSoggetto+" servizio:"+
  417.                             idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") mapping già esistente");
  418.                     continue;
  419.                 }
  420.             }finally{
  421.                 try{
  422.                     this.driverRegistroServizi.releaseConnection(con);
  423.                 }catch(Exception t){
  424.                     // ignore
  425.                 }
  426.             }
  427.             
  428.             String nomeMapping = null;
  429.             boolean isDefault = false;
  430.             PortaApplicativa pa = this.driverConfigurazione.getPortaApplicativa(idPortaApplicativa);
  431.             if(ImplementationUtils.isPortaApplicativaUtilizzabileComeDefault(pa)) {
  432.                 nomeMapping = ImplementationUtils.getDefaultMappingName();
  433.                 isDefault = true;
  434.                 if(nomePortaDefault!=null) {
  435.                     // già trovato una pa di default, questa non la considero
  436.                     this.log.debug("PortaApplicativa '"+idPortaApplicativa.getNome()+"' ignorata (soggetto:"+idSoggetto+" servizio:"+
  437.                             idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+"): mapping di default già esistente nella pa con nome ["+nomePortaDefault+"]");
  438.                     continue;
  439.                 }
  440.                 else {
  441.                     nomePortaDefault = idPortaApplicativa.getNome();
  442.                 }
  443.             }
  444.             else {
  445.                 if(PortaApplicativaAzioneIdentificazione.DELEGATED_BY.equals(pa.getAzione().getIdentificazione())) {
  446.                     // gia' nel nuovo formato devo solo creare il mapping che per qualche motivo si è perso
  447.                     if(pa.getAzione().sizeAzioneDelegataList()<=0) {
  448.                         this.log.error("Trovata porta applicativa "+pa.getNome()+"] con un'identificazione dell'azione delegata senza pero' possedere azioni delegate");
  449.                         continue;
  450.                     }
  451.                     else {
  452.                         String nomeAzione = pa.getAzione().getAzioneDelegata(0); // utilizzo un'azione a caso.
  453.                         nomeMapping = nomeAzione;
  454.                     }
  455.                 }
  456.                 else {
  457.                     String nomeAzione = pa.getAzione().getNome();
  458.                     if(mapPorte.containsKey(nomeAzione)) {
  459.                         // già trovato una pa che gestisce l'azione
  460.                         this.log.debug("PortaApplicativa '"+idPortaApplicativa.getNome()+"' ignorata (soggetto:"+idSoggetto+" servizio:"+
  461.                                 idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+"): mapping per l'azione '"+nomeAzione+"' già esistente nella pa con nome ["+mapPorte.get(nomeAzione)+"]");
  462.                         continue;
  463.                     }
  464.                     else {
  465.                         mapPorte.put(nomeAzione, idPortaApplicativa);
  466.                     }
  467.                     nomeMapping = nomeAzione;
  468.                     
  469.                     // modifico porta applicativa adeguandola alla nuova specifica
  470.                     ImplementationUtils.setAzioneDelegate(pa, 
  471.                             null, // nome porta delegante lo imposto dopo aver trovato la porta di default. 
  472.                             pa.getAzione().getNome());
  473.                     
  474.                     listPAModificare.put(idPortaApplicativa, pa);
  475.                 }
  476.             }
  477.             this.log.debug("Creazione Mapping Erogazione (default:"+isDefault+" nome:"+nomeMapping+") soggetto:"+idSoggetto+" servizio:"+
  478.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" con pa:"+idPortaApplicativa.getNome()+" in corso...");
  479.             con = null;
  480.             try{
  481.                 con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.createMappingErogazione");
  482.                 
  483.                 DBMappingUtils.createMappingErogazione(nomeMapping, isDefault ? Costanti.MAPPING_EROGAZIONE_PA_DESCRIZIONE_DEFAULT : nomeMapping,
  484.                         isDefault, idServizio, idPortaApplicativa, con, this.driverRegistroServizi.getTipoDB());
  485.             }finally{
  486.                 try{
  487.                     if(this.driverRegistroServizi.isAtomica()) {
  488.                         if(con!=null) {
  489.                             con.commit();
  490.                         }
  491.                     }
  492.                 }catch(Throwable t){
  493.                     // ignore
  494.                 }
  495.                 try{
  496.                     this.driverRegistroServizi.releaseConnection(con);
  497.                 }catch(Throwable t){
  498.                     // ignore
  499.                 }
  500.             }
  501.             this.log.debug("Creazione Mapping Erogazione (default:"+isDefault+" nome:"+nomeMapping+") soggetto:"+idSoggetto+" servizio:"+
  502.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" con pa:"+idPortaApplicativa.getNome()+" effettuata con successo");
  503.             
  504.         }
  505.         
  506.         if(listPAModificare.size()>0) {
  507.             for (IDPortaApplicativa idPortaApplicativa : listPAModificare.keySet()) {
  508.                 PortaApplicativa pa = listPAModificare.get(idPortaApplicativa);
  509.                 
  510.                 if(nomePortaDefault==null) {
  511.                     // Creo una porta applicativa automaticamente simile a quella delegatedBy
  512.                     
  513.                     org.openspcoop2.message.constants.ServiceBinding serviceBinding = readServiceBinding(idServizio);
  514.                     IProtocolFactory<?> p = ProtocolFactoryManager.getInstance().getProtocolFactoryByServiceType(idServizio.getTipo());
  515.                     Implementation implementation = p.createProtocolIntegrationConfiguration().createDefaultImplementation(serviceBinding, idServizio);
  516.                     PortaApplicativa paDefault = implementation.getPortaApplicativa();
  517.                     
  518.                     // associo sa erogatore della pa di partenza
  519.                     if(pa.sizeServizioApplicativoList()>0) {
  520.                         for (PortaApplicativaServizioApplicativo paSA : pa.getServizioApplicativoList()) {
  521.                             paDefault.addServizioApplicativo(paSA);
  522.                         }
  523.                     }
  524.                     
  525.                     MappingErogazionePortaApplicativa mapping = implementation.getMapping();
  526.                     IDPortaApplicativa idPADefault = mapping.getIdPortaApplicativa();
  527.                     nomePortaDefault = idPADefault.getNome();
  528.                     if(this.driverConfigurazione.existsPortaApplicativa(idPADefault) == false) {
  529.                         // creo porta applicativa standard
  530.                         this.log.info("Porta applicativa ["+pa.getNome()+"] del Soggetto "+pa.getTipoSoggettoProprietario()+"/"+pa.getNomeSoggettoProprietario()+" creazione delegante ["+paDefault.getNome()+"] in corso...");
  531.                         this.driverConfigurazione.createPortaApplicativa(paDefault);
  532.                         this.log.info("Porta applicativa ["+pa.getNome()+"] del Soggetto "+pa.getTipoSoggettoProprietario()+"/"+pa.getNomeSoggettoProprietario()+" creazione delegante ["+paDefault.getNome()+"].");
  533.                     }
  534.                     
  535.                     Connection con = null;
  536.                     try{
  537.                         con = this.driverConfigurazione.getConnection("UtilitiesMappingFruizioneErogazione.createMappingErogazione");
  538.                         this.log.info("Creazione mapping di erogazione di default (nome:"+mapping.getNome()+" default:"+mapping.isDefault()+") tra Porta Applicativa ["+paDefault.getNome()+"] e servizio ["+idServizio+"] creazione delegante in corso...");
  539.                         DBMappingUtils.createMappingErogazione(mapping.getNome(),mapping.getDescrizione(),  mapping.isDefault(), idServizio, idPADefault, con, this.driverConfigurazione.getTipoDB());
  540.                         this.log.info("Creazione mapping di erogazione di default (nome:"+mapping.getNome()+" default:"+mapping.isDefault()+") tra Porta Applicativa ["+paDefault.getNome()+"] e servizio ["+idServizio+"] creato delegante.");
  541.                     }finally{
  542.                         try{
  543.                             this.driverRegistroServizi.releaseConnection(con);
  544.                         }catch(Throwable t){}
  545.                     }
  546.                 }
  547.                 
  548.                 pa.getAzione().setNomePortaDelegante(nomePortaDefault);
  549.                 
  550.                 // comunque devo aggiornare i dati per delegatedBy (anche se nomePortaDefault is null)
  551.                 
  552.                 this.log.debug("Aggiornamento Porta Applicativa '"+idPortaApplicativa+"' per  Mapping Erogazione soggetto:"+idSoggetto+" servizio:"+
  553.                         idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" per impostare nome delegate '"+nomePortaDefault+"' in corso...");
  554.                 this.driverConfigurazione.updatePortaApplicativa(pa);
  555.                 this.log.debug("Aggiornamento Porta Applicativa '"+idPortaApplicativa+"' per  Mapping Erogazione soggetto:"+idSoggetto+" servizio:"+
  556.                         idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" per impostare nome delegate '"+nomePortaDefault+"' effettuata con successo");
  557.                 
  558.             }
  559.         }
  560.     }
  561.     
  562.     private void _gestioneMappingFruizionePD(List<IDPortaDelegata> listPD, IDServizio idServizio, IDSoggetto idSoggetto) throws Exception {
  563.         String nomePortaDefault = null;
  564.         HashMap<String, IDPortaDelegata> mapPorte = new HashMap<>(); 
  565.         HashMap<IDPortaDelegata, PortaDelegata> listPDModificare = new  HashMap<>(); 
  566.         for (IDPortaDelegata idPortaDelegata : listPD) {
  567.             
  568.             Connection con = null;
  569.             try{
  570.                 con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.existsIDPortaDelegataAssociata");
  571.                 if(DBMappingUtils.existsMappingFruizione(idServizio, idSoggetto, idPortaDelegata, con, this.driverRegistroServizi.getTipoDB())){
  572.                     this.log.debug("PortaDelegata '"+idPortaDelegata.getNome()+"' (soggetto-fruitore:"+idSoggetto+
  573.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  574.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+") mapping già esistente");
  575.                     continue;
  576.                 }
  577.             }finally{
  578.                 try{
  579.                     this.driverRegistroServizi.releaseConnection(con);
  580.                 }catch(Exception t){
  581.                     // ignore
  582.                 }
  583.             }
  584.             
  585.             String nomeMapping = null;
  586.             boolean isDefault = false;
  587.             PortaDelegata pd = this.driverConfigurazione.getPortaDelegata(idPortaDelegata);
  588.             if(SubscriptionUtils.isPortaDelegataUtilizzabileComeDefault(pd)) {
  589.                 nomeMapping = SubscriptionUtils.getDefaultMappingName();
  590.                 isDefault = true;
  591.                 if(nomePortaDefault!=null) {
  592.                     // già trovato una pa di default, questa non la considero
  593.                     this.log.debug("PortaDelegata '"+idPortaDelegata.getNome()+"' ignorata (soggetto-fruitore:"+idSoggetto+
  594.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  595.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+"): mapping di default già esistente nella pd con nome ["+nomePortaDefault+"]");
  596.                     continue;
  597.                 }
  598.                 else {
  599.                     nomePortaDefault = idPortaDelegata.getNome();
  600.                 }
  601.             }
  602.             else {
  603.                 if(PortaDelegataAzioneIdentificazione.DELEGATED_BY.equals(pd.getAzione().getIdentificazione())) {
  604.                     // gia' nel nuovo formato devo solo creare il mapping che per qualche motivo si è perso
  605.                     if(pd.getAzione().sizeAzioneDelegataList()<=0) {
  606.                         this.log.error("Trovata porta delegata "+pd.getNome()+"] con un'identificazione dell'azione delegata senza pero' possedere azioni delegate");
  607.                         continue;
  608.                     }
  609.                     else {
  610.                         String nomeAzione = pd.getAzione().getAzioneDelegata(0); // utilizzo un'azione a caso.
  611.                         nomeMapping = nomeAzione;
  612.                     }
  613.                 }
  614.                 else {
  615.                     String nomeAzione = pd.getAzione().getNome();
  616.                     if(mapPorte.containsKey(nomeAzione)) {
  617.                         // già trovato una pa che gestisce l'azione
  618.                         this.log.debug("PortaDelegata '"+idPortaDelegata.getNome()+"' ignorata (soggetto-fruitore:"+idSoggetto+
  619.                         " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  620.                         idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+"): mapping per l'azione '"+nomeAzione+"' già esistente nella pa con nome ["+mapPorte.get(nomeAzione)+"]");
  621.                         continue;
  622.                     }
  623.                     else {
  624.                         mapPorte.put(nomeAzione, idPortaDelegata);
  625.                     }
  626.                     nomeMapping = nomeAzione;
  627.                     
  628.                     // modifico porta applicativa adeguandola alla nuova specifica
  629.                     SubscriptionUtils.setAzioneDelegate(pd, 
  630.                             null, // nome porta delegante lo imposto dopo aver trovato la porta di default. 
  631.                             pd.getAzione().getNome());
  632.                     
  633.                     listPDModificare.put(idPortaDelegata, pd);
  634.                 }
  635.             }
  636.             this.log.debug("Creazione Mapping Fruizione soggetto-fruitore:"+idSoggetto+
  637.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  638.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" con pd:"+idPortaDelegata.getNome()+" in corso...");
  639.             con = null;
  640.             try{
  641.                 con = this.driverRegistroServizi.getConnection("UtilitiesMappingFruizioneErogazione.createMappingFruizione");
  642.                 
  643.                 DBMappingUtils.createMappingFruizione(nomeMapping, isDefault ? Costanti.MAPPING_FRUIZIONE_PD_DESCRIZIONE_DEFAULT : nomeMapping,
  644.                         isDefault, idServizio, idSoggetto, idPortaDelegata, con, this.driverRegistroServizi.getTipoDB());
  645.             }finally{
  646.                 try{
  647.                     if(this.driverRegistroServizi.isAtomica()) {
  648.                         if(con!=null) {
  649.                             con.commit();
  650.                         }
  651.                     }
  652.                 }catch(Throwable t){}
  653.                 try{
  654.                     this.driverRegistroServizi.releaseConnection(con);
  655.                 }catch(Throwable t){}
  656.             }
  657.             this.log.debug("Creazione Mapping Fruizione soggetto-fruitore:"+idSoggetto+
  658.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  659.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" con pd:"+idPortaDelegata.getNome()+" effettuata con successo");
  660.         }
  661.         
  662.         if(listPDModificare.size()>0) {
  663.             for (IDPortaDelegata idPortaDelegata : listPDModificare.keySet()) {
  664.                 PortaDelegata pd = listPDModificare.get(idPortaDelegata);
  665.                 
  666.                 if(nomePortaDefault==null) {
  667.                     
  668.                     IDSoggetto idFruitore = new IDSoggetto(pd.getTipoSoggettoProprietario(), pd.getNomeSoggettoProprietario());
  669.                     org.openspcoop2.message.constants.ServiceBinding serviceBinding = readServiceBinding(idServizio);
  670.                     IProtocolFactory<?> p = ProtocolFactoryManager.getInstance().getProtocolFactoryByServiceType(idServizio.getTipo());
  671.                     ProtocolSubscription subcription = p.createProtocolIntegrationConfiguration().createDefaultSubscription(serviceBinding, idFruitore, idServizio);
  672.                     PortaDelegata pdDefault = subcription.getPortaDelegata();
  673.                     MappingFruizionePortaDelegata mapping = subcription.getMapping();
  674.                     IDPortaDelegata idPDDefault = mapping.getIdPortaDelegata();
  675.                     nomePortaDefault = idPDDefault.getNome();
  676.                     if(this.driverConfigurazione.existsPortaDelegata(idPDDefault) == false) {
  677.                         // creo porta delegata standard
  678.                         this.log.info("Porta delegata ["+pd.getNome()+"] del Soggetto "+pd.getTipoSoggettoProprietario()+"/"+pd.getNomeSoggettoProprietario()+" creazione delegante ["+pdDefault.getNome()+"] in corso...");
  679.                         this.driverConfigurazione.createPortaDelegata(pdDefault);
  680.                         this.log.info("Porta delegata ["+pd.getNome()+"] del Soggetto "+pd.getTipoSoggettoProprietario()+"/"+pd.getNomeSoggettoProprietario()+" creazione delegante ["+pdDefault.getNome()+"].");
  681.                     }
  682.                     
  683.                     Connection con = null;
  684.                     try{
  685.                         con = this.driverConfigurazione.getConnection("UtilitiesMappingFruizioneErogazione.createMappingFruizione");
  686.                         this.log.info("Creazione mapping di fruizione di default (nome:"+mapping.getNome()+" default:"+mapping.isDefault()+") tra Porta delegata ["+pdDefault.getNome()+"], fruitore ["+idFruitore+"] e servizio ["+idServizio+"] creazione delegante in corso...");
  687.                         DBMappingUtils.createMappingFruizione(mapping.getNome(), mapping.getDescrizione(), mapping.isDefault(), idServizio, idFruitore, idPDDefault, con, this.driverConfigurazione.getTipoDB());
  688.                         this.log.info("Creazione mapping di fruizione di default (nome:"+mapping.getNome()+" default:"+mapping.isDefault()+") tra Porta delegata ["+pdDefault.getNome()+"], fruitore ["+idFruitore+"] e servizio ["+idServizio+"] creato delegante.");
  689.                     }finally{
  690.                         try{
  691.                             this.driverRegistroServizi.releaseConnection(con);
  692.                         }catch(Exception t){
  693.                             // ignore
  694.                         }
  695.                     }
  696.                 }
  697.                 
  698.                 pd.getAzione().setNomePortaDelegante(nomePortaDefault);
  699.                 
  700.                 // comunque devo aggiornare i dati per delegatedBy (anche se nomePortaDefault is null)
  701.                 
  702.                 this.log.debug("Aggiornamento Porta Delegata '"+idPortaDelegata+"' per  Mapping Fruizione soggetto-fruitore:"+idSoggetto+
  703.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  704.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" per impostare nome delegate '"+nomePortaDefault+"' in corso...");
  705.                 this.driverConfigurazione.updatePortaDelegata(pd);
  706.                 this.log.debug("Aggiornamento Porta Delegata '"+idPortaDelegata+"' per  Mapping Fruizione soggetto-fruitore:"+idSoggetto+
  707.                     " soggetto-erogatore:"+idServizio.getSoggettoErogatore()+" servizio:"+
  708.                     idServizio.getTipo()+"/"+idServizio.getNome()+" v"+idServizio.getVersione()+" per impostare nome delegate '"+nomePortaDefault+"' effettuata con successo");
  709.                 
  710.             }
  711.         }
  712.     }
  713.     
  714.     private org.openspcoop2.message.constants.ServiceBinding readServiceBinding(IDServizio idServizio) throws ProtocolException{
  715.         try {
  716.             AccordoServizioParteSpecifica asps = this.driverRegistroServizi.getAccordoServizioParteSpecifica(idServizio, false);
  717.             IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune());
  718.             ServiceBinding sb = this.driverRegistroServizi.getAccordoServizioParteComune(idAccordo).getServiceBinding();
  719.             return RegistroServiziUtils.convertToMessage(sb);
  720.         } catch (Throwable se) {
  721.             throw new ProtocolException("Servizio ["+idServizio+"] non trovato: "+se.getMessage(),se);
  722.         } 
  723.     }
  724.     
  725. }
Created with JaCoCo 0.8.8.202204050719