TransactionServiceLibrary.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.monitor.engine.config;

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

  28. import javax.xml.soap.SOAPEnvelope;

  30. import org.openspcoop2.core.commons.dao.DAOFactory;
  31. import org.openspcoop2.core.transazioni.DumpContenuto;
  32. import org.openspcoop2.core.transazioni.DumpMessaggio;
  33. import org.openspcoop2.core.transazioni.Transazione;
  34. import org.openspcoop2.message.OpenSPCoop2Message;
  35. import org.openspcoop2.message.constants.MessageType;
  36. import org.openspcoop2.message.xml.MessageDynamicNamespaceContextFactory;
  37. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazione;
  38. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin;
  39. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto;
  40. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato;
  41. import org.openspcoop2.monitor.engine.config.transazioni.constants.PosizioneMascheramento;
  42. import org.openspcoop2.monitor.engine.config.transazioni.constants.TipoControllo;
  43. import org.openspcoop2.monitor.engine.config.transazioni.constants.TipoMascheramento;
  44. import org.openspcoop2.monitor.engine.dynamic.DynamicFactory;
  45. import org.openspcoop2.monitor.engine.dynamic.IDynamicLoader;
  46. import org.openspcoop2.monitor.engine.transaction.TransactionContentUtils;
  47. import org.openspcoop2.monitor.engine.transaction.TransactionManager;
  48. import org.openspcoop2.monitor.sdk.plugins.ITransactionProcessing;
  49. import org.openspcoop2.monitor.sdk.transaction.Transaction;
  50. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  51. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  52. import org.openspcoop2.protocol.sdk.tracciamento.TracciamentoException;
  53. import org.openspcoop2.utils.regexp.RegularExpressionEngine;
  54. import org.openspcoop2.utils.xml.AbstractXPathExpressionEngine;
  55. import org.openspcoop2.utils.xml.DynamicNamespaceContext;
  56. import org.openspcoop2.utils.xml.XPathException;
  57. import org.openspcoop2.utils.xml.XPathNotFoundException;
  58. import org.openspcoop2.utils.xml.XPathNotValidException;
  59. import org.openspcoop2.utils.xml.XPathReturnType;
  60. import org.slf4j.Logger;
  61. import org.w3c.dom.NodeList;

  63. /**
  64.  * TransactionServiceLibrary
  65.  *
  66.  * @author Poli Andrea (apoli@link.it)
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */
  70. public class TransactionServiceLibrary implements Serializable {

  72.     /**
  73.      * 
  74.      */
  75.     private static final long serialVersionUID = 1L;

  77.     private BasicServiceLibrary basicServiceLibrary;
  78.     private ConfigurazioneTransazione transactionActionLibrary;
  79.     private ConfigurazioneTransazione transactionActionAllLibrary;

  81.     public BasicServiceLibrary getBasicServiceLibrary() {
  82.         return this.basicServiceLibrary;
  83.     }
  84.     public void setBasicServiceLibrary(BasicServiceLibrary basicServiceLibrary) {
  85.         this.basicServiceLibrary = basicServiceLibrary;
  86.     }
  87.     public ConfigurazioneTransazione getTransactionActionLibrary() {
  88.         return this.transactionActionLibrary;
  89.     }
  90.     public void setTransactionActionLibrary(
  91.             ConfigurazioneTransazione transactionActionLibrary) {
  92.         this.transactionActionLibrary = transactionActionLibrary;
  93.     }
  94.     public ConfigurazioneTransazione getTransactionActionAllLibrary() {
  95.         return this.transactionActionAllLibrary;
  96.     }
  97.     public void setTransactionActionAllLibrary(
  98.             ConfigurazioneTransazione transactionActionAllLibrary) {
  99.         this.transactionActionAllLibrary = transactionActionAllLibrary;
  100.     }





  106.     // ****** STATI E RISORSE *************** 

  108.     public TransactionInfo readStatoAndResources(OpenSPCoop2Message msg, MessageDynamicNamespaceContextFactory dncFactory,
  109.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log, boolean isRichiesta,
  110.             String idTransazione) throws Exception{
  111.         TransactionInfo transactionInfo = new TransactionInfo();
  112.         this._readStatoAndResources(null, msg, dncFactory, xpathEngine, debug, log, isRichiesta, idTransazione, true, true,
  113.                 transactionInfo);
  114.         return transactionInfo;
  115.     }
  116.     public TransactionInfo readStato(OpenSPCoop2Message msg, MessageDynamicNamespaceContextFactory dncFactory,
  117.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log, boolean isRichiesta,
  118.             String idTransazione) throws Exception{
  119.         TransactionInfo transactionInfo = new TransactionInfo();
  120.         this._readStatoAndResources(null,  msg, dncFactory, xpathEngine, debug, log, isRichiesta, idTransazione, true, false,
  121.                 transactionInfo);
  122.         return transactionInfo;
  123.     }
  124.     public TransactionInfo readResources(OpenSPCoop2Message msg, MessageDynamicNamespaceContextFactory dncFactory,
  125.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log, boolean isRichiesta,
  126.             String idTransazione, String stato) throws Exception{
  127.         TransactionInfo transactionInfo = new TransactionInfo();
  128.         transactionInfo.setStato(stato);
  129.         this._readStatoAndResources(null,  msg, dncFactory, xpathEngine, debug, log, isRichiesta, idTransazione, false, true,
  130.                 transactionInfo);
  131.         return transactionInfo;
  132.     }
  133.     private void _readStatoAndResources(SOAPEnvelope soapEnvelope,OpenSPCoop2Message msg, 
  134.             MessageDynamicNamespaceContextFactory dncFactory,
  135.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log, boolean isRichiesta,
  136.             String idTransazione, boolean readStato, boolean readResources,
  137.             TransactionInfo transactionInfo) throws Exception{
  138.         // Ottengo SOAPEnvelope
  139.         DynamicNamespaceContext dnc = null;

  141.         if(readStato){
  142.             // ** Esamino gli stati della transazione se la transazione attuale non ha gia assegnato uno stato **
  143.             if(transactionInfo.getStato()==null){
  144.                 // Provo prima ad utilizzare lo stato definito in una azione specifica
  145.                 if(this.getTransactionActionLibrary()!=null){
  146.                     if(this.getTransactionActionLibrary().sizeConfigurazioneTransazioneStatoList()>0){
  147.                         if(soapEnvelope==null){
  148.                             soapEnvelope = msg.castAsSoap().getSOAPPart().getEnvelope();
  149.                         }
  150.                         if(dnc==null){
  151.                             if(MessageType.SOAP_11.equals(msg.getMessageType())){
  152.                                 dnc = dncFactory.getNamespaceContextFromSoapEnvelope11(soapEnvelope);
  153.                             }
  154.                             else{
  155.                                 dnc = dncFactory.getNamespaceContextFromSoapEnvelope12(soapEnvelope);
  156.                             }
  157.                         }
  158.                     }
  159.                     this.updateTransactionState(this.getTransactionActionLibrary().getConfigurazioneTransazioneStatoList(), 
  160.                             isRichiesta, soapEnvelope, msg, dnc, 
  161.                             idTransazione, xpathEngine, debug, log, transactionInfo);
  162.                 }
  163.                 // Provo poi ad utilizzare gli stati associati all'azione '*'
  164.                 if(transactionInfo.getStato()==null){
  165.                     if(this.getTransactionActionAllLibrary()!=null){
  166.                         if(this.getTransactionActionAllLibrary().sizeConfigurazioneTransazioneStatoList()>0){
  167.                             if(soapEnvelope==null){
  168.                                 soapEnvelope = msg.castAsSoap().getSOAPPart().getEnvelope();
  169.                             }
  170.                             if(dnc==null){
  171.                                 if(MessageType.SOAP_11.equals(msg.getMessageType())){
  172.                                     dnc = dncFactory.getNamespaceContextFromSoapEnvelope11(soapEnvelope);
  173.                                 }
  174.                                 else{
  175.                                     dnc = dncFactory.getNamespaceContextFromSoapEnvelope12(soapEnvelope);
  176.                                 }
  177.                             }
  178.                         }
  179.                         updateTransactionState(this.getTransactionActionAllLibrary().getConfigurazioneTransazioneStatoList(), 
  180.                                 isRichiesta, soapEnvelope, msg, dnc, 
  181.                                 idTransazione, xpathEngine, debug, log, transactionInfo);
  182.                     }
  183.                 }
  184.             }
  185.         }
  186.         
  187.         
  188.         if(readResources){

  190.             // elaboro risorse
  191.             List<ConfigurazioneTransazioneRisorsaContenuto> risorse = this.mergeServiceActionTransactionLibrary_resources();
  192.     
  193.             // XPATH
  194.             Map<String, String> notFoundRules = new HashMap<>();
  195.             Map<String, String> dirtyRules = new HashMap<>();
  196.             if(risorse.size()>0){
  197.     
  198.                 if(soapEnvelope==null){
  199.                     soapEnvelope = msg.castAsSoap().getSOAPPart().getEnvelope();
  200.                 }
  201.                 if(dnc==null){
  202.                     if(MessageType.SOAP_11.equals(msg.getMessageType())){
  203.                         dnc = dncFactory.getNamespaceContextFromSoapEnvelope11(soapEnvelope);
  204.                     }
  205.                     else{
  206.                         dnc = dncFactory.getNamespaceContextFromSoapEnvelope12(soapEnvelope);
  207.                     }
  208.                 }
  209.                 // NOTA!!!! I Fault devono essere analizzati, puo' darsi che gli stati o le risorse (errore) le debba estrarre da un SoapFault.
  210.                 //if(dnc.isSoapFault()){
  211.                 //  return; // non devo analizzare i soap fault.
  212.                 //}
  213.     
  214.                 List<TransactionResource> contenuti = this.recuperaContenuti(isRichiesta, transactionInfo.getStato(), soapEnvelope, dnc, risorse, notFoundRules, dirtyRules,
  215.                         xpathEngine, debug, log);
  216.                 if(contenuti!=null){
  217.                     for (int i = 0; i < contenuti.size(); i++) {
  218.                         transactionInfo.getRisorse().add(contenuti.get(i));
  219.                     }
  220.                 }
  221.     
  222.             }
  223.     
  224.             //controllo se ci sono regole non trovate e/o "sporche"
  225.     
  226.             if(debug){
  227.                 StringBuilder sbNotFound = new StringBuilder();
  228.                 if(notFoundRules.size()>0){
  229.                     sbNotFound.append("Regole non trovate:");
  230.                     for (String k : notFoundRules.keySet()) {
  231.                         sbNotFound.append("\n["+(k)+"]");
  232.                     }
  233.                 }
  234.                 log.debug(sbNotFound.toString());
  235.             }
  236.     
  237.             StringBuilder sb = new StringBuilder();
  238.             if(dirtyRules.size()>0){
  239.                 sb.append("\nRegole non valide:");
  240.                 for (String k : dirtyRules.keySet()) {
  241.                     String val = "\n["+k+"-"+(dirtyRules.get(k))+"]";
  242.                     sb.append(val);
  243.     
  244.                 }
  245.             }
  246.     
  247.             if(sb.length()>0){
  248.                 throw new TracciamentoException(sb.toString());
  249.             }           
  250.         }
  251.     }

  253.     private void updateTransactionState(List<ConfigurazioneTransazioneStato> transactionStates,boolean richiesta,
  254.             SOAPEnvelope soapEnvelope,OpenSPCoop2Message msg,DynamicNamespaceContext dnc,String idTransazione,
  255.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log,
  256.             TransactionInfo transactionInfo) throws Exception{
  257.         for (int i = 0; i < transactionStates.size(); i++) {
  258.             ConfigurazioneTransazioneStato stato = transactionStates.get(i);
  259.             
  260.             if(stato.isEnabled()==false){
  261.                 continue;
  262.             }
  263.             
  264.             // controllo su richiesta/risposta
  265.             boolean matchTipoMessaggio = false;
  266.             if(richiesta){
  267.                 matchTipoMessaggio = org.openspcoop2.monitor.engine.config.transazioni.constants.TipoMessaggio.RICHIESTA.equals(stato.getTipoMessaggio());
  268.             }else{
  269.                 matchTipoMessaggio = org.openspcoop2.monitor.engine.config.transazioni.constants.TipoMessaggio.RISPOSTA.equals(stato.getTipoMessaggio());
  270.             }
  271.             if(!matchTipoMessaggio){
  272.                 continue; 
  273.             }
  274.         
  275.             // NOTA!!!! I Fault devono essere analizzati, puo' darsi che gli stati o le risorse (errore) le debba estrarre da un SoapFault.
  276.             //if(dnc.isSoapFault()){
  277.             //  return; // non devo analizzare i soap fault.
  278.             //}
  279.             
  280.             if(TipoControllo.EXIST.equals(stato.getTipoControllo())){
  281.                 Object oString = null;
  282.                 try{
  283.                     oString = xpathEngine.getMatchPattern(soapEnvelope, dnc, stato.getXpath(), XPathReturnType.STRING);
  284.                 }catch (XPathNotFoundException nfe) {
  285.                     if(debug)
  286.                         log.debug("Stato ["+stato.getNome()+"] con tipoControllo["+stato.getTipoControllo()+"] (xpath:"+stato.getXpath()+") non riscontrato per la trasazione ["+idTransazione+"]: "+nfe.getMessage());
  287.                 }
  288.                 if(oString!=null){
  289.                     if(debug)
  290.                         log.info("Trovato stato ["+stato.getNome()+"] con tipoControllo["+stato.getTipoControllo()+"] (xpath:"+stato.getXpath()+") per la trasazione ["+idTransazione+"]");
  291.                     transactionInfo.setStato(stato.getNome());
  292.                     break;
  293.                 }
  294.             }
  295.             else{
  296.                 String oString = null;
  297.                 try{
  298.                     oString = (String) xpathEngine.getMatchPattern(soapEnvelope, dnc, stato.getXpath(), XPathReturnType.STRING);
  299.                 }catch (XPathNotFoundException nfe) {
  300.                     if(debug)
  301.                         log.debug("Stato ["+stato.getNome()+"] con tipoControllo["+stato.getTipoControllo()+"] (xpath:"+stato.getXpath()+") non riscontrato per la trasazione ["+idTransazione+"]: "+nfe.getMessage());
  302.                 }
  303.                 if(oString!=null){
  304.                     if(TipoControllo.EQUALS.equals(stato.getTipoControllo())){
  305.                         if(oString.equals(stato.getValore())){
  306.                             if(debug)
  307.                                 log.info("Trovato stato ["+stato.getNome()+"] per trasazione ["+idTransazione+"]");
  308.                             transactionInfo.setStato(stato.getNome());
  309.                             break;
  310.                         }
  311.                     }else if(TipoControllo.MATCH.equals(stato.getTipoControllo())){
  312.                         if(RegularExpressionEngine.isMatch(oString, stato.getValore())){
  313.                             if(debug)
  314.                                 log.info("Trovato stato ["+stato.getNome()+"] con tipoControllo["+stato.getTipoControllo()+"] (xpath:"+stato.getXpath()+") per la trasazione ["+idTransazione+"]");
  315.                             transactionInfo.setStato(stato.getNome());
  316.                             break;
  317.                         }
  318.                     }
  319.                 }       
  320.             }
  321.         }
  322.     }
  323.     
  324.     private List<TransactionResource> recuperaContenuti(boolean richiesta,String stato,SOAPEnvelope soapEnvelope,DynamicNamespaceContext dnc,
  325.             List<ConfigurazioneTransazioneRisorsaContenuto> risorse, Map<String, String> rulesNotFuond, Map<String, String> dirtyRules,
  326.             AbstractXPathExpressionEngine xpathEngine, boolean debug, Logger log) throws Exception {
  327.         
  328.         List<TransactionResource> res = new ArrayList<TransactionResource>();
  329.         
  330.         if(dnc.isSoapBodyEmpty()){
  331.             return res;
  332.         }
  333.         
  334.         for (int i = 0; i < risorse.size(); i++) {
  335.             
  336.             ConfigurazioneTransazioneRisorsaContenuto risorsa = risorse.get(i);
  337.             
  338.             // check tipo messaggio
  339.             boolean matchTipoMessaggio = false;
  340.             if(richiesta){
  341.                 matchTipoMessaggio = org.openspcoop2.monitor.engine.config.transazioni.constants.TipoMessaggio.RICHIESTA.equals(risorsa.getTipoMessaggio());
  342.             }else{
  343.                 matchTipoMessaggio = org.openspcoop2.monitor.engine.config.transazioni.constants.TipoMessaggio.RISPOSTA.equals(risorsa.getTipoMessaggio());
  344.             }
  345.             if(!matchTipoMessaggio){
  346.                 continue;  // messaggio non compatibile con lo stato
  347.             }
  348.             
  349.             // check stato
  350.             if(stato!=null){
  351.                 if(risorsa.getIdConfigurazioneTransazioneStato()!=null){
  352.                     String statoRichiestoDallaRisorsa = risorsa.getIdConfigurazioneTransazioneStato().getStato();
  353.                     if(statoRichiestoDallaRisorsa!=null && !"*".equals(statoRichiestoDallaRisorsa)){
  354.                         // check che la risorsa in questione sia compatibili con lo stato che sto esaminando
  355.                         if(!stato.equals(statoRichiestoDallaRisorsa)){
  356.                             continue; // risorsa non compatibile con lo stato
  357.                         }
  358.                     }   
  359.                 }
  360.             }
  361.             else{
  362.                 // lo stato associato alla transazione è null.
  363.                 // se nella risorsa è richiesto uno stato specifico non devo proseguire
  364.                 if(risorsa.getIdConfigurazioneTransazioneStato()!=null){
  365.                     String statoRichiestoDallaRisorsa = risorsa.getIdConfigurazioneTransazioneStato().getStato();
  366.                     if(statoRichiestoDallaRisorsa!=null && !"*".equals(statoRichiestoDallaRisorsa)){
  367.                         continue; // risorsa non compatibile con lo stato
  368.                     }   
  369.                 }
  370.             }
  371.             
  372.             String nomeProprieta = risorsa.getNome();
  373.             String percorsoProprieta = risorsa.getXpath();
  374.             try{
  375.                 // NOTA!!!! I Fault devono essere analizzati, puo' darsi che gli stati o le risorse (errore) le debba estrarre da un SoapFault.
  376.                 //if(dnc.isSoapFault()){
  377.                 //  non e' possibile raccogliere proprieta' se abbiamo un soap fault
  378.                 //  continue;
  379.                 //}
  380.                 
  381.                 // Provo a cercarlo prima come Node
  382.                 NodeList nodeList = null;
  383.                 Exception exceptionNodeSet = null;
  384.                 String risultato = null;
  385.                 try{
  386.                     nodeList = (NodeList) xpathEngine.getMatchPattern(soapEnvelope, dnc, percorsoProprieta,XPathReturnType.NODESET);
  387.                     if(nodeList!=null){
  388.                         risultato = xpathEngine.toString(nodeList);
  389.                     }
  390.                 }catch(Exception e){
  391.                     exceptionNodeSet = e;
  392.                 }
  393.                 
  394.                 // Se non l'ho trovato provo a cercarlo come string (es. il metodo sopra serve per avere l'xml, ma fallisce in caso di concat, in caso di errori di concat_openspcoop....)
  395.                 // Insomma il caso dell'xml sopra e' quello speciale, che pero' deve essere eseguito prima, perche' altrimenti il caso string sotto funziona sempre, e quindi non si ottiene mai l'xml.
  396.                 if(risultato==null || "".equals(risultato)){
  397.                     try{
  398.                         risultato = xpathEngine.getStringMatchPattern(soapEnvelope, dnc, percorsoProprieta);
  399.                     }catch(Exception e){
  400.                         if(exceptionNodeSet!=null){
  401.                             log.error("Errore avvenuto durante la getStringMatchPattern("+percorsoProprieta
  402.                                     +") ("+e.getMessage()+") invocata in seguito all'errore dell'invocazione getMatchPattern("+
  403.                                     percorsoProprieta+",NODESET): "+exceptionNodeSet.getMessage(),exceptionNodeSet);
  404.                         }
  405.                         // lancio questo errore.
  406.                         if(e instanceof XPathNotFoundException){
  407.                             throw (XPathNotFoundException) e;
  408.                         }else if(e instanceof XPathNotValidException){
  409.                             throw (XPathNotValidException) e;
  410.                         }else if(e instanceof XPathException){
  411.                             throw (XPathException) e;
  412.                         }else{
  413.                             throw e;
  414.                         }
  415.                     }
  416.                 }
  417.                 
  418.                 if(risultato == null || "".equals(risultato)){
  419.                     if(exceptionNodeSet!=null){
  420.                         log.error("Non sono stati trovati risultati tramite l'invocazione del metodo getStringMatchPattern("+percorsoProprieta
  421.                                 +") invocato in seguito all'errore dell'invocazione getMatchPattern("+
  422.                                 percorsoProprieta+",NODESET): "+exceptionNodeSet.getMessage(),exceptionNodeSet);
  423.                     }
  424.                     rulesNotFuond.put(nomeProprieta,percorsoProprieta);
  425.                 }else{
  426.                     // TROVATO DA AGGIUNGERE AL DATABASE!
  427.                     //res.put(nomeProprieta+" - "+ percorsoProprieta, risultato);
  428.                     TransactionResource risorsaCalcolata = new TransactionResource();
  429.                     if(richiesta)
  430.                         risorsaCalcolata.setTipoMessaggio(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RICHIESTA_INGRESSO);
  431.                     else
  432.                         risorsaCalcolata.setTipoMessaggio(org.openspcoop2.core.transazioni.constants.TipoMessaggio.RISPOSTA_INGRESSO);
  433.                     risorsaCalcolata.setNome(nomeProprieta);
  434.                     risorsaCalcolata.setValore(risultato);
  435.                     res.add(risorsaCalcolata);
  436.                     if(debug){
  437.                         log.debug(nomeProprieta+" - "+ percorsoProprieta +" : "+risultato);
  438.                     }
  439.                 }
  440.                 
  441.             }catch (XPathNotFoundException nfe) {
  442.                 // not found rule
  443.                 rulesNotFuond.put(nomeProprieta,nfe.getMessage());
  444.             }catch (XPathNotValidException re) {
  445.                 // dirty rule
  446.                 log.error("Errore di validazione della query XPath ["+percorsoProprieta+"] durante la valutazione della proprieta ["+nomeProprieta+"]: "+re.getMessage(),re);
  447.                 dirtyRules.put(nomeProprieta,re.getMessage());
  448.             }catch (XPathException re) {
  449.                 // dirty rule
  450.                 log.error("Errore durante la valutazione della proprieta ["+nomeProprieta+"] query XPath ["+percorsoProprieta+"]: "+re.getMessage(),re);
  451.                 dirtyRules.put(nomeProprieta,re.getMessage());
  452.             }catch(Exception e){
  453.                 throw new Exception("Errore generico durante la valutazione della proprieta ["+nomeProprieta+"] query XPath ["+percorsoProprieta+"]: "+e.getMessage(),e);
  454.             }
  455.         }
  456.         
  457.         return res;
  458.     }
  459.     
  460.     
  461.     


  464.     // ****** SDK BEFORE SAVE ON DATABASE*************** 

  466.     public boolean processResourcesBeforeSaveOnDatabase(Transazione transazione,
  467.             Traccia tracciaRichiesta, Traccia tracciaRisposta,
  468.             List<MsgDiagnostico> msgDiagnostici,
  469.             DumpMessaggio dumpMessaggioRichiestaIngresso, DumpMessaggio dumpMessaggioRichiestaUscita,
  470.             DumpMessaggio dumpMessaggioRispostaIngresso, DumpMessaggio dumpMessaggioRispostaUscita, 
  471.             String stato,
  472.             Logger log, DAOFactory daoFactory) throws Exception{
  473.         return this.processResourcesBeforeSaveOnDatabase(transazione,
  474.                 tracciaRichiesta,tracciaRisposta,
  475.                 msgDiagnostici,
  476.                 dumpMessaggioRichiestaIngresso, dumpMessaggioRichiestaUscita,
  477.                 dumpMessaggioRispostaIngresso, dumpMessaggioRispostaUscita,
  478.                 stato, 
  479.                 this.mergeServiceActionTransactionLibrary_resources(),
  480.                 this.mergeServiceActionTransactionLibrary_sdkPlugins(log),
  481.                 log,daoFactory);
  482.     }
  483.     public boolean processResourcesBeforeSaveOnDatabase(
  484.             Transazione transazione,Traccia tracciaRichiesta, Traccia tracciaRisposta,
  485.             List<MsgDiagnostico> msgDiagnostici,
  486.             DumpMessaggio dumpMessaggioRichiestaIngresso, DumpMessaggio dumpMessaggioRichiestaUscita,
  487.             DumpMessaggio dumpMessaggioRispostaIngresso, DumpMessaggio dumpMessaggioRispostaUscita, 
  488.             String stato, 
  489.             List<ConfigurazioneTransazioneRisorsaContenuto> listRisorseContenuto,
  490.             List<ITransactionProcessing> listTransactionProcessing,
  491.             Logger log, DAOFactory daoFactory) throws Exception{

  493.         boolean updated = this.updateDumpMessaggio(dumpMessaggioRichiestaIngresso, listRisorseContenuto, stato) &&
  494.                 this.updateDumpMessaggio(dumpMessaggioRichiestaUscita, listRisorseContenuto, stato) &&
  495.                 this.updateDumpMessaggio(dumpMessaggioRispostaIngresso, listRisorseContenuto, stato) &&
  496.                 this.updateDumpMessaggio(dumpMessaggioRispostaUscita, listRisorseContenuto, stato);


  499.         // SDK
  500.         if(listTransactionProcessing!=null && listTransactionProcessing.size()>0){

  502.             Transaction transactionSDK = new Transaction(log,daoFactory,transazione, 
  503.                     tracciaRichiesta, tracciaRisposta,
  504.                     msgDiagnostici);
  505.             if(dumpMessaggioRichiestaIngresso!=null){
  506.                 TransactionManager.setContentResourcesInTransaction(transactionSDK, dumpMessaggioRichiestaIngresso);
  507.             }
  508.             if(dumpMessaggioRichiestaUscita!=null){
  509.                 TransactionManager.setContentResourcesInTransaction(transactionSDK, dumpMessaggioRichiestaUscita);
  510.             }
  511.             if(dumpMessaggioRispostaIngresso!=null){
  512.                 TransactionManager.setContentResourcesInTransaction(transactionSDK, dumpMessaggioRispostaIngresso);
  513.             }
  514.             if(dumpMessaggioRispostaUscita!=null){
  515.                 TransactionManager.setContentResourcesInTransaction(transactionSDK, dumpMessaggioRispostaUscita);
  516.             }

  518.             for (ITransactionProcessing iTransactionProcessing : listTransactionProcessing) {
  519.                 iTransactionProcessing.processRealTimeResourcesBeforeSaveOnDatabase(transactionSDK);
  520.             }

  522.             if(dumpMessaggioRichiestaIngresso!=null){
  523.                 if (TransactionManager.updateResources(dumpMessaggioRichiestaIngresso, transactionSDK)){
  524.                     updated = true;
  525.                 }
  526.             }
  527.             if(dumpMessaggioRichiestaUscita!=null){
  528.                 if (TransactionManager.updateResources(dumpMessaggioRichiestaUscita, transactionSDK)){
  529.                     updated = true;
  530.                 }
  531.             }
  532.             if(dumpMessaggioRispostaIngresso!=null){
  533.                 if (TransactionManager.updateResources(dumpMessaggioRispostaIngresso, transactionSDK)){
  534.                     updated = true;
  535.                 }
  536.             }
  537.             if(dumpMessaggioRispostaUscita!=null){
  538.                 if (TransactionManager.updateResources(dumpMessaggioRispostaUscita, transactionSDK)){
  539.                     updated = true;
  540.                 }
  541.             }
  542.         }

  544.         return updated;
  545.     }

  547.     private boolean updateDumpMessaggio(DumpMessaggio dumpMessaggio, List<ConfigurazioneTransazioneRisorsaContenuto> listRisorseContenuto, String stato) throws Exception{

  549.         boolean updated = false;

  551.         if(dumpMessaggio!=null){

  553.             // Risorse contenuto (configurate via govwayMonitor)
  554.             if(dumpMessaggio.sizeContenutoList()>0){
  555.                 for (DumpContenuto dumpContenuto : dumpMessaggio.getContenutoList()) {

  557.                     for (ConfigurazioneTransazioneRisorsaContenuto configurazioneTransazioneRisorsaContenuto : listRisorseContenuto) {

  559.                         if(configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato()!=null && 
  560.                                 configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato()!=null &&
  561.                                 !"".equals(configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato())){
  562.                             if(!configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato().equals(stato)){
  563.                                 continue;
  564.                             }
  565.                         }

  567.                         if(configurazioneTransazioneRisorsaContenuto.getTipoMessaggio().toString().equals(dumpMessaggio.getTipoMessaggio().toString()) &&
  568.                                 configurazioneTransazioneRisorsaContenuto.getNome().equals(dumpContenuto.getNome())){

  570.                             // mascheramento
  571.                             if(configurazioneTransazioneRisorsaContenuto.getAbilitaAnonimizzazione()!=null &&
  572.                                     configurazioneTransazioneRisorsaContenuto.getAbilitaAnonimizzazione() == 1){

  574.                                 if(TipoMascheramento.FISICO.equals(configurazioneTransazioneRisorsaContenuto.getTipoMascheramento())){
  575.                                     TransactionContentUtils.setDumpContenutoValue(dumpContenuto, 
  576.                                             this.mascheramento(configurazioneTransazioneRisorsaContenuto.getCarattereMaschera(), 
  577.                                                     configurazioneTransazioneRisorsaContenuto.getPosizionamentoMaschera(), 
  578.                                                     configurazioneTransazioneRisorsaContenuto.getNumeroCaratteriMaschera(), 
  579.                                                     TransactionContentUtils.getDumpContenutoValue(dumpContenuto)));
  580.                                     updated = true;
  581.                                 }

  583.                             }

  585.                             // compressione
  586.                             if(configurazioneTransazioneRisorsaContenuto.getAbilitaCompressione()!=null &&
  587.                                     configurazioneTransazioneRisorsaContenuto.getAbilitaCompressione() == 1){
  588.                                 TransactionContentUtils.compress(dumpContenuto, configurazioneTransazioneRisorsaContenuto.getTipoCompressione());
  589.                                 updated = true;
  590.                             }

  592.                             break;
  593.                         }
  594.                     }

  596.                 }
  597.             }
  598.         }

  600.         return updated;
  601.     }


  604.     







  612.     // ****** SDK AFTER READ FROM DATABASE*************** 

  614.     public boolean processResourcesAfterReadFromDatabase(Transazione transazione,DumpMessaggio dumpMessaggio,String stato,
  615.             Logger log, DAOFactory daoFactory) throws Exception{
  616.         return this.processResourcesAfterReadFromDatabase(transazione,dumpMessaggio, stato, 
  617.                 this.mergeServiceActionTransactionLibrary_resources(),
  618.                 this.mergeServiceActionTransactionLibrary_sdkPlugins(log),
  619.                 log,daoFactory);
  620.     }
  621.     public boolean processResourcesAfterReadFromDatabase(Transazione transazione,DumpMessaggio dumpMessaggio,String stato, 
  622.             List<ConfigurazioneTransazioneRisorsaContenuto> list,
  623.             List<ITransactionProcessing> listTransactionProcessing,
  624.             Logger log, DAOFactory daoFactory) throws Exception{


  627.         boolean updated = false;

  629.         if(dumpMessaggio!=null){

  631.             // Risorse contenuto (configurate via govwayMonitor)
  632.             if(dumpMessaggio.sizeContenutoList()>0){
  633.                 for (DumpContenuto dumpContenuto : dumpMessaggio.getContenutoList()) {

  635.                     for (ConfigurazioneTransazioneRisorsaContenuto configurazioneTransazioneRisorsaContenuto : list) {

  637.                         if(configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato()!=null && 
  638.                                 configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato()!=null &&
  639.                                 !"".equals(configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato())){
  640.                             if(!configurazioneTransazioneRisorsaContenuto.getIdConfigurazioneTransazioneStato().getStato().equals(stato)){
  641.                                 continue;
  642.                             }
  643.                         }

  645.                         if(configurazioneTransazioneRisorsaContenuto.getTipoMessaggio().toString().equals(dumpMessaggio.getTipoMessaggio().toString()) &&
  646.                                 configurazioneTransazioneRisorsaContenuto.getNome().equals(dumpContenuto.getNome())){

  648.                             // de-compressione
  649.                             if(configurazioneTransazioneRisorsaContenuto.getAbilitaCompressione()!=null &&
  650.                                     configurazioneTransazioneRisorsaContenuto.getAbilitaCompressione() == 1){
  651.                                 TransactionContentUtils.decompress(dumpContenuto, configurazioneTransazioneRisorsaContenuto.getTipoCompressione());
  652.                                 updated = true;
  653.                             }

  655.                             // de-mascheramento
  656.                             if(configurazioneTransazioneRisorsaContenuto.getAbilitaAnonimizzazione()!=null &&
  657.                                     configurazioneTransazioneRisorsaContenuto.getAbilitaAnonimizzazione() == 1){
  658.                                 if(TipoMascheramento.LOGICO.equals(configurazioneTransazioneRisorsaContenuto.getTipoMascheramento())){
  659.                                     TransactionContentUtils.setDumpContenutoValue(dumpContenuto, 
  660.                                             this.mascheramento(configurazioneTransazioneRisorsaContenuto.getCarattereMaschera(), 
  661.                                             configurazioneTransazioneRisorsaContenuto.getPosizionamentoMaschera(), 
  662.                                             configurazioneTransazioneRisorsaContenuto.getNumeroCaratteriMaschera(), 
  663.                                             TransactionContentUtils.getDumpContenutoValue(dumpContenuto)));
  664.                                     updated = true;
  665.                                 }
  666.                             }

  668.                             break;
  669.                         }
  670.                     }

  672.                 }
  673.             }

  675.             // SDK
  676.             if(listTransactionProcessing!=null && listTransactionProcessing.size()>0){

  678.                 Transaction transactionSDK = new Transaction(log,daoFactory,transazione);
  679.                 TransactionManager.setContentResourcesInTransaction(transactionSDK, dumpMessaggio);

  681.                 for (ITransactionProcessing iTransactionProcessing : listTransactionProcessing) {
  682.                     iTransactionProcessing.processRealTimeResourcesAfterReadFromDatabase(transactionSDK);
  683.                 }

  685.                 if (TransactionManager.updateResources(dumpMessaggio, transactionSDK)){
  686.                     updated = true;
  687.                 }

  689.             }
  690.         }

  692.         return updated;

  694.     }






  701.     // ****** UTILS *************** 

  703.     @Override
  704.     public String toString(){
  705.         StringBuilder bf = new StringBuilder();

  707.         if(this.basicServiceLibrary==null){
  708.             bf.append("BasicServiceLibrary: notDefined");
  709.             bf.append("\n");
  710.         }
  711.         else{
  712.             bf.append(this.basicServiceLibrary.toString());
  713.         }

  715.         bf.append("TransactionActionLibrary: ");
  716.         if(this.getTransactionActionLibrary()!=null){
  717.             bf.append("presente size-plugins[").
  718.             append(this.getTransactionActionLibrary().sizeConfigurazioneTransazionePluginList()).
  719.             append("] plugins[").
  720.             append(this.getTransactionActionLibrary().getConfigurazioneTransazionePluginList()).
  721.             append(" size-stati[").
  722.             append(this.getTransactionActionLibrary().sizeConfigurazioneTransazioneStatoList()).
  723.             append("] stati[").
  724.             append(this.getTransactionActionLibrary().getConfigurazioneTransazioneStatoList()).
  725.             append("] size-risorse[").
  726.             append(this.getTransactionActionLibrary().sizeConfigurazioneTransazioneRisorsaContenutoList()).
  727.             append("] risorse[").
  728.             append(this.getTransactionActionLibrary().getConfigurazioneTransazioneRisorsaContenutoList()).
  729.             append("] enabled[").
  730.             append(this.getTransactionActionLibrary().isEnabled()).
  731.             append("]");
  732.         }else{
  733.             bf.append("-");
  734.         }
  735.         bf.append("\n");

  737.         bf.append("TransactionActionAllLibrary: ");
  738.         if(this.getTransactionActionAllLibrary()!=null){
  739.             bf.append("presente size-plugins[").
  740.             append(this.getTransactionActionAllLibrary().sizeConfigurazioneTransazionePluginList()).
  741.             append("] plugins[").
  742.             append(this.getTransactionActionAllLibrary().getConfigurazioneTransazionePluginList()).
  743.             append("presente size-stati[").
  744.             append(this.getTransactionActionAllLibrary().sizeConfigurazioneTransazioneStatoList()).
  745.             append("] stati[").
  746.             append(this.getTransactionActionAllLibrary().getConfigurazioneTransazioneStatoList()).
  747.             append("] size-risorse[").
  748.             append(this.getTransactionActionAllLibrary().sizeConfigurazioneTransazioneRisorsaContenutoList()).
  749.             append("] risorse[").
  750.             append(this.getTransactionActionAllLibrary().getConfigurazioneTransazioneRisorsaContenutoList()).
  751.             append("] enabled[").
  752.             append(this.getTransactionActionAllLibrary().isEnabled()).
  753.             append("]");
  754.         }else{
  755.             bf.append("-");
  756.         }
  757.         bf.append("\n");


  760.         return bf.toString();
  761.     }

  763.     public List<ConfigurazioneTransazioneStato> mergeServiceActionTransactionLibrary_states() throws Exception{

  765.         List<ConfigurazioneTransazioneStato> list = new ArrayList<ConfigurazioneTransazioneStato>();
  766.         List<String> idStati = new ArrayList<>();

  768.         // Leggo le risorse associate all'azione specifica
  769.         if(this.transactionActionLibrary!=null && this.transactionActionLibrary.sizeConfigurazioneTransazioneStatoList()>0){
  770.             for (ConfigurazioneTransazioneStato configurazioneTransazioneStato : this.transactionActionLibrary.getConfigurazioneTransazioneStatoList()) {
  771.                 if(configurazioneTransazioneStato.isEnabled()){
  772.                     list.add(configurazioneTransazioneStato);
  773.                     idStati.add(configurazioneTransazioneStato.getNome());
  774.                 }
  775.             }
  776.         }

  778.         // Leggo le risorse associate all'azione '*'
  779.         if(this.transactionActionAllLibrary!=null && this.transactionActionAllLibrary.sizeConfigurazioneTransazioneStatoList()>0){
  780.             for (ConfigurazioneTransazioneStato configurazioneTransazioneStato : this.transactionActionAllLibrary.getConfigurazioneTransazioneStatoList()) {
  781.                 if(configurazioneTransazioneStato.isEnabled()){
  782.                     String idStato = configurazioneTransazioneStato.getNome();
  783.                     if(idStati.contains(idStato)==false){
  784.     
  785.                         // inserisco solo gli stati il cui nome non siano gia stati utilizzati nell'azione specifica
  786.     
  787.                         list.add(configurazioneTransazioneStato);
  788.                         idStati.add(idStato);
  789.                     }
  790.                 }
  791.             }
  792.         }

  794.         return list;
  795.     }

  797.     public List<ConfigurazioneTransazioneRisorsaContenuto> mergeServiceActionTransactionLibrary_resources() throws Exception{

  799.         List<ConfigurazioneTransazioneRisorsaContenuto> list = new ArrayList<ConfigurazioneTransazioneRisorsaContenuto>();
  800.         List<String> idRisorse = new ArrayList<>();

  802.         // Leggo le risorse associate all'azione specifica
  803.         if(this.transactionActionLibrary!=null && this.transactionActionLibrary.sizeConfigurazioneTransazioneRisorsaContenutoList()>0){
  804.             for (ConfigurazioneTransazioneRisorsaContenuto configurazioneTransazioneRisorsaContenuto : this.transactionActionLibrary.getConfigurazioneTransazioneRisorsaContenutoList()) {
  805.                 if(configurazioneTransazioneRisorsaContenuto.isEnabled()){
  806.                     list.add(configurazioneTransazioneRisorsaContenuto);
  807.                     //idRisorse.add(configurazioneTransazioneRisorsaContenuto.getNome()+"_"+configurazioneTransazioneRisorsaContenuto.getTipoMessaggio().name());
  808.                     idRisorse.add(configurazioneTransazioneRisorsaContenuto.getNome()); // è stato definito lo unique sul nome
  809.                 }
  810.             }
  811.         }

  813.         // Leggo le risorse associate all'azione '*'
  814.         if(this.transactionActionAllLibrary!=null && this.transactionActionAllLibrary.sizeConfigurazioneTransazioneRisorsaContenutoList()>0){
  815.             for (ConfigurazioneTransazioneRisorsaContenuto configurazioneTransazioneRisorsaContenuto : this.transactionActionAllLibrary.getConfigurazioneTransazioneRisorsaContenutoList()) {
  816.                 if(configurazioneTransazioneRisorsaContenuto.isEnabled()){
  817.                     //String idRisorsa = configurazioneTransazioneRisorsaContenuto.getNome()+"_"+configurazioneTransazioneRisorsaContenuto.getTipoMessaggio().name();
  818.                     String idRisorsa = configurazioneTransazioneRisorsaContenuto.getNome(); // è stato definito lo unique sul nome
  819.                     if(idRisorse.contains(idRisorsa)==false){
  820.     
  821.                         // inserisco solo le risorse il cui nome e tipo non siano gia stati utilizzati nell'azione specifica
  822.     
  823.                         list.add(configurazioneTransazioneRisorsaContenuto);
  824.                         idRisorse.add(idRisorsa);
  825.                     }
  826.                 }
  827.             }
  828.         }

  830.         return list;
  831.     }

  833.     public List<ITransactionProcessing> mergeServiceActionTransactionLibrary_sdkPlugins(Logger log) throws Exception{

  835.         List<ITransactionProcessing> list = new ArrayList<ITransactionProcessing>();
  836.         List<String> idRisorse = new ArrayList<>();

  838.         // Leggo le risorse associate all'azione specifica
  839.         if(this.transactionActionLibrary!=null && this.transactionActionLibrary.getEnabled() 
  840.                 && this.transactionActionLibrary.getConfigurazioneTransazionePluginList()!=null &&
  841.                         this.transactionActionLibrary.getConfigurazioneTransazionePluginList().size()>0){
  842.             for (ConfigurazioneTransazionePlugin configTransazionePlugin : this.transactionActionLibrary.getConfigurazioneTransazionePluginList()) {
  843.                 if(configTransazionePlugin.isEnabled()){
  844.                     String className = configTransazionePlugin.getPlugin().getClassName();
  845.                     if(idRisorse.contains(className)==false){
  846.                         IDynamicLoader loader = DynamicFactory.getInstance().newDynamicLoader(configTransazionePlugin.getPlugin().getTipoPlugin(), configTransazionePlugin.getPlugin().getTipo(),
  847.                                 className, log);
  848.                         ITransactionProcessing transactionProcessor = (ITransactionProcessing) loader.newInstance();
  849.                         idRisorse.add(className);
  850.                         list.add(transactionProcessor);
  851.                     }   
  852.                 }
  853.             }
  854.         }

  856.         // Leggo le risorse associate all'azione '*'
  857.         if(this.transactionActionAllLibrary!=null && this.transactionActionAllLibrary.getEnabled() 
  858.                 && this.transactionActionAllLibrary.getConfigurazioneTransazionePluginList()!=null &&
  859.                         this.transactionActionAllLibrary.getConfigurazioneTransazionePluginList().size()>0){
  860.             for (ConfigurazioneTransazionePlugin configTransazionePlugin : this.transactionActionAllLibrary.getConfigurazioneTransazionePluginList()) {
  861.                 if(configTransazionePlugin.isEnabled()){
  862.                     String className = configTransazionePlugin.getPlugin().getClassName();
  863.                     if(idRisorse.contains(className)==false){
  864.                         IDynamicLoader loader = DynamicFactory.getInstance().newDynamicLoader(configTransazionePlugin.getPlugin().getTipoPlugin(), configTransazionePlugin.getPlugin().getTipo(),
  865.                                 className, log);
  866.                         ITransactionProcessing transactionProcessor = (ITransactionProcessing) loader.newInstance();
  867.                         idRisorse.add(className);
  868.                         list.add(transactionProcessor);
  869.                     }
  870.                 }
  871.             }
  872.         }

  874.         return list;
  875.     }

  877.     private String mascheramento(char carattereMascheramento, PosizioneMascheramento posizioneMascheramento, int numero, String originale){
  878.         StringBuilder bf = new StringBuilder();
  879.         if(originale.length()<=numero || numero<=0  ){
  880.             for (int i = 0; i < originale.length(); i++) {
  881.                 bf.append(carattereMascheramento);      
  882.             }
  883.         }
  884.         else{
  885.             if(PosizioneMascheramento.PRIMI.equals(posizioneMascheramento)){
  886.                 int i=0;
  887.                 for (; i < numero; i++) {
  888.                     bf.append(carattereMascheramento);      
  889.                 }
  890.                 for (; i < originale.length(); i++) {
  891.                     bf.append(originale.charAt(i));     
  892.                 }
  893.             }
  894.             else{
  895.                 int i=0;
  896.                 for (; i < (originale.length()-numero); i++) {
  897.                     bf.append(originale.charAt(i));     
  898.                 }
  899.                 for (; i < originale.length(); i++) {
  900.                     bf.append(carattereMascheramento);      
  901.                 }
  902.             }
  903.         }
  904.         return bf.toString();
  905.     }
  906. }
Created with JaCoCo 0.8.8.202204050719