SDIValidazioneUtils.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.  */
  20. package org.openspcoop2.protocol.sdi.validator;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;
  27. import java.util.Properties;

  29. import org.openspcoop2.message.OpenSPCoop2Message;
  30. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  31. import org.openspcoop2.protocol.basic.ProtocolliRegistrati;
  32. import org.openspcoop2.protocol.basic.tracciamento.TracciaDriver;
  33. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  34. import org.openspcoop2.protocol.sdi.config.SDIProperties;
  35. import org.openspcoop2.protocol.sdi.constants.SDICostanti;
  36. import org.openspcoop2.protocol.sdk.Busta;
  37. import org.openspcoop2.protocol.sdk.Eccezione;
  38. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  39. import org.openspcoop2.protocol.sdk.ProtocolException;
  40. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  41. import org.openspcoop2.protocol.sdk.constants.LivelloRilevanza;
  42. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  43. import org.openspcoop2.protocol.sdk.state.IState;
  44. import org.openspcoop2.protocol.sdk.state.StateMessage;
  45. import org.openspcoop2.protocol.sdk.tracciamento.DriverTracciamentoNotFoundException;
  46. import org.openspcoop2.protocol.sdk.tracciamento.FiltroRicercaTracceConPaginazione;
  47. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaDriver;
  48. import org.openspcoop2.protocol.sdk.tracciamento.InformazioniProtocollo;
  49. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  50. import org.openspcoop2.utils.transport.TransportUtils;

  52. /**
  53.  * SDIValidazioneUtils
  54.  * 
  55.  * @author Andrea Poli (apoli@link.it)
  56.  * @author $Author$
  57.  * @version $Rev$, $Date$
  58.  */
  59. public class SDIValidazioneUtils {

  61.     private IProtocolFactory<?> protocolFactory;
  62.     private SDIProperties sdiProperties;
  63.     private ITracciaDriver _tracciaDriver;
  64.     
  65.     public SDIValidazioneUtils(IProtocolFactory<?> protocolFactory) throws ProtocolException{
  66.         this.protocolFactory = protocolFactory;
  67.         this.sdiProperties = SDIProperties.getInstance(protocolFactory.getLogger());
  68.     }
  69.     private ITracciaDriver getDriverTracciamento() throws ProtocolException {
  70.         if(this._tracciaDriver==null) {
  71.             this._initDriverTracciamento();
  72.         }
  73.         return this._tracciaDriver;
  74.     }
  75.     private synchronized void _initDriverTracciamento() throws ProtocolException {
  76.         if(this._tracciaDriver==null) {
  77.             this._tracciaDriver = newDriverTracciamento(null);
  78.         }
  79.     }
  80.     private ITracciaDriver getDriverTracciamento(Connection con) throws ProtocolException {
  81.         if(con!=null) {
  82.             return newDriverTracciamento(con);
  83.         }
  84.         else {
  85.             return getDriverTracciamento();
  86.         }
  87.     }
  88.     private TracciaDriver newDriverTracciamento(Connection con) throws ProtocolException {
  89.         if(this.sdiProperties.isTracciamentoRequiredFromConfiguration()) {
  90.             try {
  91.                 ProtocolliRegistrati pRegistrati = new ProtocolliRegistrati(ProtocolFactoryManager.getInstance().getProtocolFactories());
  92.                 
  93.                 String tipoDatabase = this.sdiProperties.getTracciamentoTipoDatabase();
  94.                 if(tipoDatabase==null) {
  95.                     tipoDatabase = OpenSPCoop2Properties.getInstance().getDatabaseType();
  96.                 }
  97.             
  98.                 ITracciaDriver tracciaDriver = this.protocolFactory.createTracciaDriver();
  99.                 if(tracciaDriver instanceof TracciaDriver) {
  100.                 
  101.                     TracciaDriver tracciaDriverBasic = (TracciaDriver) tracciaDriver;
  102.                     
  103.                     if(con==null) {
  104.                         String datasource = this.sdiProperties.getTracciamentoDatasource();
  105.                         Properties datasourceJndiContext = this.sdiProperties.getTracciamentoDatasource_jndiContext();
  106.                         tracciaDriverBasic.init(pRegistrati, datasource, tipoDatabase, datasourceJndiContext, this.protocolFactory.getLogger());
  107.                     }
  108.                     else {
  109.                         tracciaDriverBasic.init(pRegistrati, con, tipoDatabase, this.protocolFactory.getLogger());
  110.                     }
  111.                     
  112.                     return tracciaDriverBasic;
  113.                     
  114.                 }
  115.                 else {
  116.                     throw new Exception("Unexpected traccciamento driver '"+this._tracciaDriver.getClass().getName()+"'");
  117.                 }
  118.                 
  119.             }catch(Exception e) {
  120.                 throw new ProtocolException(e.getMessage(),e);
  121.             }
  122.         }
  123.         return null;
  124.     }
  125.     
  126.     
  127.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore) throws ProtocolException{
  128.         return Eccezione.getEccezioneValidazione(codiceErrore,null, this.protocolFactory);
  129.     }
  130.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore,String descrizioneErrore) throws ProtocolException{
  131.         return Eccezione.getEccezioneValidazione(codiceErrore, descrizioneErrore, this.protocolFactory);
  132.     }
  133.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore,String descrizioneErrore, Throwable e) throws ProtocolException{
  134.         if(this.protocolFactory!=null && this.protocolFactory.getLogger()!=null)
  135.             this.protocolFactory.getLogger().error(descrizioneErrore,e);
  136.         return Eccezione.getEccezioneValidazione(codiceErrore, descrizioneErrore, this.protocolFactory);
  137.     }
  138.     
  139.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore,boolean info) throws ProtocolException{
  140.         Eccezione ecc = Eccezione.getEccezioneValidazione(codiceErrore,null, this.protocolFactory);
  141.         if(info){
  142.             ecc.setRilevanza(LivelloRilevanza.INFO);
  143.         }
  144.         return ecc;
  145.     }
  146.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore,String descrizioneErrore,boolean info) throws ProtocolException{
  147.         Eccezione ecc =  Eccezione.getEccezioneValidazione(codiceErrore, descrizioneErrore, this.protocolFactory);
  148.         if(info){
  149.             ecc.setRilevanza(LivelloRilevanza.INFO);
  150.         }
  151.         return ecc;
  152.     }
  153.     public Eccezione newEccezioneValidazione(CodiceErroreCooperazione codiceErrore,String descrizioneErrore, Throwable e,boolean info) throws ProtocolException{
  154.         if(this.protocolFactory!=null && this.protocolFactory.getLogger()!=null)
  155.             this.protocolFactory.getLogger().error(descrizioneErrore,e);
  156.         Eccezione ecc =  Eccezione.getEccezioneValidazione(codiceErrore, descrizioneErrore, this.protocolFactory);
  157.         if(info){
  158.             ecc.setRilevanza(LivelloRilevanza.INFO);
  159.         }
  160.         return ecc;
  161.     }
  162.     
  163.     public Eccezione newEccezioneProcessamento(CodiceErroreCooperazione codiceErrore) throws ProtocolException{
  164.         return Eccezione.getEccezioneProcessamento(codiceErrore,null, this.protocolFactory);
  165.     }
  166.     public Eccezione newEccezioneProcessamento(CodiceErroreCooperazione codiceErrore,String descrizioneErrore) throws ProtocolException{
  167.         return Eccezione.getEccezioneProcessamento(codiceErrore, descrizioneErrore, this.protocolFactory);
  168.     }
  169.     public Eccezione newEccezioneProcessamento(CodiceErroreCooperazione codiceErrore,String descrizioneErrore, Throwable e) throws ProtocolException{
  170.         if(this.protocolFactory!=null && this.protocolFactory.getLogger()!=null)
  171.             this.protocolFactory.getLogger().error(descrizioneErrore,e);
  172.         return Eccezione.getEccezioneProcessamento(codiceErrore, descrizioneErrore, this.protocolFactory);
  173.     }
  174.     
  175.     
  176.     
  177.     public void addHeaderIdentificativoSdiMessaggio(OpenSPCoop2Message msg, String idSdi, String idSdiRiferimentoArchivio) {
  178.         
  179.         if(msg==null) {
  180.             return;
  181.         }
  182.         if(msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getHeaders()==null) {
  183.             return;
  184.         }
  185.         
  186.         if(idSdi==null) {
  187.             return;
  188.         }
  189.         if(idSdiRiferimentoArchivio!=null) {
  190.             TransportUtils.addHeader(msg.getTransportRequestContext().getHeaders(),SDICostanti.SDI_HEADER_ID_CORRELAZIONE,idSdi + " "+idSdiRiferimentoArchivio);
  191.         }
  192.         else {
  193.             TransportUtils.addHeader(msg.getTransportRequestContext().getHeaders(),SDICostanti.SDI_HEADER_ID_CORRELAZIONE,idSdi);
  194.         }

  196.     }
  197.     
  198.     public void readInformazioniFatturaRiferita(Busta busta, String identificativoSdI,
  199.             String servizio, String azione,
  200.             boolean applicativoMittente, boolean fatturazioneAttiva,
  201.             IState state) throws ProtocolException {
  202.         
  203.         Connection con = null;
  204.         if(state!=null) {
  205.             if(state instanceof StateMessage) {
  206.                 StateMessage s = (StateMessage) state;
  207.                 try {
  208.                     if(s.getConnectionDB()!=null && !s.getConnectionDB().isClosed()) {
  209.                         con = s.getConnectionDB();
  210.                     }
  211.                 }catch(Exception e) {} // ignore
  212.             }
  213.         }
  214.         
  215.         ITracciaDriver tracciaDriver = this.getDriverTracciamento(con);
  216.         if(tracciaDriver==null) {
  217.             throw new ProtocolException("Accesso al database delle tracce non attivo");
  218.         }
  219.         
  220.         Traccia traccia = null;
  221.         if(fatturazioneAttiva) {
  222.         
  223.             // L'identificativo SDI si trova nella risposta per la fatturazione attiva. Tutte le altre informazioni nella richiesta.
  224.             Traccia tracciaRisposta = null;
  225.             FiltroRicercaTracceConPaginazione filtro = new FiltroRicercaTracceConPaginazione();
  226.             filtro.setTipoTraccia(RuoloMessaggio.RISPOSTA);
  227.             filtro.setInformazioniProtocollo(new InformazioniProtocollo());
  228.             filtro.getInformazioniProtocollo().setServizio(servizio);
  229.             filtro.getInformazioniProtocollo().setAzione(azione);
  230.             filtro.getInformazioniProtocollo().addProprietaProtocollo(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, identificativoSdI);
  231.             filtro.setAsc(false);
  232.             filtro.setLimit(1);
  233.             List<Traccia> list = null;
  234.             try {
  235.                 list = tracciaDriver.getTracce(filtro);
  236.             }catch(DriverTracciamentoNotFoundException notFound) {}
  237.             catch(Exception e) {
  238.                 throw new ProtocolException(e.getMessage(),e);
  239.             }
  240.             if(list!=null && !list.isEmpty()) {
  241.                 tracciaRisposta = list.get(0);
  242.             }
  243.             
  244.             if(tracciaRisposta!=null && tracciaRisposta.getIdTransazione()!=null) {
  245.                 try {
  246.                     traccia = tracciaDriver.getTraccia(tracciaRisposta.getIdTransazione(), RuoloMessaggio.RICHIESTA);
  247.                 }catch(DriverTracciamentoNotFoundException notFound) {}
  248.                 catch(Exception e) {
  249.                     throw new ProtocolException(e.getMessage(),e);
  250.                 }
  251.                 
  252.                 // e' solo l'identificativo SDI e c'รจ gia.
  253. //              if(traccia!=null) {
  254. //                  // riporto all'interno dell'oggetto le informazioni mancanti presenti sulla risposta
  255. //                  if(tracciaRisposta.getBusta()!=null && tracciaRisposta.getBusta().sizeProperties()>0) {
  256. //                      
  257. //                      String identificativoSDI = tracciaRisposta.getBusta().getProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI);
  258. //                      if(identificativoSDI!=null && !"".equals(identificativoSDI)) {
  259. //                          traccia.getProperties().put(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, identificativoSDI);
  260. //                      }
  261. //                      
  262. //                  }
  263. //              }
  264.             }
  265.             
  266.             
  267.         }
  268.         else {
  269.             FiltroRicercaTracceConPaginazione filtro = new FiltroRicercaTracceConPaginazione();
  270.             filtro.setTipoTraccia(RuoloMessaggio.RICHIESTA);
  271.             filtro.setInformazioniProtocollo(new InformazioniProtocollo());
  272.             filtro.getInformazioniProtocollo().setServizio(servizio);
  273.             filtro.getInformazioniProtocollo().setAzione(azione);
  274.             filtro.getInformazioniProtocollo().addProprietaProtocollo(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, identificativoSdI);
  275.             filtro.setAsc(false);
  276.             filtro.setLimit(1);
  277.             List<Traccia> list = null;
  278.             try {
  279.                 list = tracciaDriver.getTracce(filtro);
  280.             }catch(DriverTracciamentoNotFoundException notFound) {}
  281.             catch(Exception e) {
  282.                 throw new ProtocolException(e.getMessage(),e);
  283.             }
  284.             if(list!=null && !list.isEmpty()) {
  285.                 traccia = list.get(0); // solo nella fatturazione passiva ne potra' esistere piu' di una in seguito a piu' tentativi di consegna. Le informazioni (raccolte sottostante, escluse gli id messaggi) saranno comunque le stesse. 
  286.             }
  287.         }
  288.         if(traccia!=null) {

  290.             if(applicativoMittente) {
  291.                 if(traccia.getBusta()!=null && traccia.getBusta().getServizioApplicativoFruitore()!=null &&
  292.                         !"".equals(traccia.getBusta().getServizioApplicativoFruitore())) {
  293.                     if(busta.getServizioApplicativoFruitore()==null) {
  294.                         busta.addProperty(SDICostanti.SDI_BUSTA_APPLICATIVO_MITTENTE_FATTURA,traccia.getBusta().getServizioApplicativoFruitore());
  295.                     }
  296.                 }
  297.             }
  298.             
  299.             if(traccia.getBusta()!=null && traccia.getBusta().sizeProperties()>0) {
  300.                 
  301.                 String [] names = traccia.getBusta().getPropertiesNames();
  302.                 
  303.                 if(names!=null && names.length>0) {
  304.                     List<String> nomiDaRiportare = new ArrayList<>();
  305.                     nomiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_CODICE_DESTINATARIO);
  306.                     nomiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_NOME_FILE_METADATI);
  307.                     nomiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_SOGGETTO_EMITTENTE);
  308.                     
  309.                     Map<String, String> nomiDaRiportareDiversamente = new HashMap<>();
  310.                     nomiDaRiportareDiversamente.put(SDICostanti.SDI_BUSTA_EXT_NOME_FILE, SDICostanti.SDI_BUSTA_EXT_NOME_FILE_FATTURA);
  311.                     
  312.                     List<String> prefissiDaRiportare = new ArrayList<>();
  313.                     prefissiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_PREFIX_);
  314.                     prefissiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_PREFIX_);
  315.                     prefissiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_CEDENTE_PRESTATORE_PREFIX_);
  316.                     prefissiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_CESSIONARIO_COMMITTENTE_PREFIX_);
  317.                     prefissiDaRiportare.add(SDICostanti.SDI_BUSTA_EXT_TERZO_INTERMEDIARIO_O_SOGGETTO_EMITTENTE_PREFIX_);
  318.                     
  319.                     for (int i = 0; i < names.length; i++) {
  320.                         
  321.                         String checkNome = names[i];
  322.                         if(checkNome==null || "".equals(checkNome)) {
  323.                             continue;
  324.                         }
  325.                         String checkValue = traccia.getBusta().getProperty(checkNome);
  326.                         if(checkValue==null || "".equals(checkValue)) {
  327.                             continue;
  328.                         }
  329.                         
  330.                         if(!nomiDaRiportare.isEmpty()) {
  331.                             for (String nome : nomiDaRiportare) {
  332.                                 if(checkNome.equals(nome)) {
  333.                                     if(!busta.existsProperty(checkNome)) {
  334.                                         busta.addProperty(checkNome, checkValue);
  335.                                     }
  336.                                 }
  337.                             }
  338.                         }
  339.                         
  340.                         if(!nomiDaRiportareDiversamente.isEmpty()) {
  341.                             for (String nome : nomiDaRiportareDiversamente.keySet()) {
  342.                                 if(checkNome.equals(nome)) {
  343.                                     if(!busta.existsProperty(checkNome)) {
  344.                                         busta.addProperty(nomiDaRiportareDiversamente.get(checkNome), checkValue);
  345.                                     }
  346.                                 }
  347.                             }
  348.                         }
  349.                         
  350.                         if(!prefissiDaRiportare.isEmpty()) {
  351.                             for (String prefix : prefissiDaRiportare) {
  352.                                 if(checkNome.startsWith(prefix)) {
  353.                                     if(!busta.existsProperty(checkNome)) {
  354.                                         busta.addProperty(checkNome, checkValue);
  355.                                     }
  356.                                 }
  357.                             }
  358.                         }
  359.                         
  360.                     }
  361.                 }
  362.                 
  363.             }
  364.         }

  366.     }
  367. }
Created with JaCoCo 0.8.8.202204050719