Traccia.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.  */


  22. package org.openspcoop2.protocol.sdk.tracciamento;

  24. import java.io.ByteArrayOutputStream;
  25. import java.util.ArrayList;
  26. import java.util.Date;
  27. import java.util.HashMap;
  28. import java.util.List;
  29. import java.util.Map;

  31. import org.openspcoop2.core.constants.Costanti;
  32. import org.openspcoop2.core.constants.TipoPdD;
  33. import org.openspcoop2.core.id.IDSoggetto;
  34. import org.openspcoop2.core.tracciamento.Allegati;
  35. import org.openspcoop2.core.tracciamento.Dominio;
  36. import org.openspcoop2.core.tracciamento.DominioSoggetto;
  37. import org.openspcoop2.core.tracciamento.Proprieta;
  38. import org.openspcoop2.core.tracciamento.Protocollo;
  39. import org.openspcoop2.core.tracciamento.TracciaEsitoElaborazione;
  40. import org.openspcoop2.core.tracciamento.constants.TipoEsitoElaborazione;
  41. import org.openspcoop2.protocol.sdk.Allegato;
  42. import org.openspcoop2.protocol.sdk.Busta;
  43. import org.openspcoop2.protocol.sdk.BustaRawContent;
  44. import org.openspcoop2.protocol.sdk.constants.EsitoElaborazioneMessaggioTracciatura;
  45. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;

  47. /**
  48.  * Bean Contenente le informazioni relative alle tracce
  49.  * 
  50.  * @author Stefano Corallo (corallo@link.it)
  51.  * @author Nardi Lorenzo
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  */

  56. public class Traccia implements java.io.Serializable {

  58.     /**
  59.      * serialVersionUID
  60.      */
  61.     private static final long serialVersionUID = 1L;
  62.     
  63.     // indicazione store
  64.     private boolean stored = false;
  65.     
  66.     // Busta
  67.     protected Busta busta;
  68.     private byte[] bustaInByte;
  69.     private BustaRawContent<?> bustaRawContent;

  71.     // properties
  72.     protected Map<String, String> properties = new HashMap<>();
  73.     
  74.     // protocollo
  75.     private String protocollo;
  76.     
  77.     // traccia
  78.     private org.openspcoop2.core.tracciamento.Traccia traccia;
  79.     
  80.     // lista allegati
  81.     private List<Allegato> allegati = new ArrayList<>();
  82.     
  83.     
  84.     public Traccia() {
  85.         this.traccia =  new org.openspcoop2.core.tracciamento.Traccia();
  86.     }
  87.     public Traccia(org.openspcoop2.core.tracciamento.Traccia traccia) {
  88.         
  89.         this.traccia = traccia;
  90.         
  91.         // protocollo
  92.         if(traccia.getBusta()!=null && traccia.getBusta().getProtocollo()!=null){
  93.             this.protocollo = traccia.getBusta().getProtocollo().getIdentificativo();
  94.         }
  95.         
  96.         // busta
  97.         if(traccia.getBusta()!=null){
  98.             this.busta = new Busta(traccia.getBusta());
  99.         }
  100.         
  101.         // allegati
  102.         if(traccia.getAllegati()!=null && traccia.getAllegati().sizeAllegatoList()>0)
  103.         for (org.openspcoop2.core.tracciamento.Allegato allegato : traccia.getAllegati().getAllegatoList()) {
  104.             this.addAllegato(new Allegato(allegato),false);
  105.         }
  106.     }
  107.     
  108.     
  109.     
  110.     // stored
  111.     
  112.     public boolean isStored() {
  113.         return this.stored;
  114.     }
  115.     public void setStored(boolean stored) {
  116.         this.stored = stored;
  117.     }
  118.     
  119.     
  120.     
  121.     // base
  122.     
  123.     public org.openspcoop2.core.tracciamento.Traccia getTraccia() {
  124.         return this.traccia;
  125.     }
  126.     public void setTraccia(org.openspcoop2.core.tracciamento.Traccia traccia) {
  127.         this.traccia = traccia;
  128.         
  129.         // protocollo
  130.         if(traccia.getBusta()!=null && traccia.getBusta().getProtocollo()!=null){
  131.             this.protocollo = traccia.getBusta().getProtocollo().getIdentificativo();
  132.         }
  133.         
  134.         // allegati
  135.         if(traccia.getAllegati()!=null && traccia.getAllegati().sizeAllegatoList()>0)
  136.         for (org.openspcoop2.core.tracciamento.Allegato allegato : traccia.getAllegati().getAllegatoList()) {
  137.             this.addAllegato(new Allegato(allegato),false);
  138.         }
  139.     }
  140.     
  141.     
  142.     
  143.     // id  [Wrapper]
  144.     
  145.     public Long getId() {
  146.         return this.traccia.getId();
  147.     }
  148.     public void setId(Long id) {
  149.         this.traccia.setId(id);
  150.     }
  151.     
  152.     
  153.     
  154.     // idTransazione [Wrapper]
  155.     
  156.     public String getIdTransazione() {
  157.         return this.traccia.getIdTransazione();
  158.     }
  159.     public void setIdTransazione(String idTransazione) {
  160.         this.traccia.setIdTransazione(idTransazione);
  161.     }
  162.     
  163.     
  164.     
  165.     // data [Wrapper]
  166.     
  167.     public Date getGdo() {
  168.         return this.traccia.getOraRegistrazione();
  169.     }
  170.     public void setGdo(Date value) {
  171.         this.traccia.setOraRegistrazione(value);
  172.     }
  173.     
  174.     
  175.     // dominio [wrapper]
  176.     
  177.     public IDSoggetto getIdSoggetto() {
  178.         IDSoggetto idSoggetto = null;
  179.         if(this.traccia.getDominio()!=null){
  180.             if(this.traccia.getDominio().getSoggetto()!=null){
  181.                 if(idSoggetto==null){
  182.                     idSoggetto = new IDSoggetto();
  183.                 }
  184.                 idSoggetto.setTipo(this.traccia.getDominio().getSoggetto().getTipo());
  185.                 idSoggetto.setNome(this.traccia.getDominio().getSoggetto().getBase());
  186.             }
  187.             if(this.traccia.getDominio().getIdentificativoPorta()!=null){
  188.                 if(idSoggetto==null){
  189.                     idSoggetto = new IDSoggetto();
  190.                 }
  191.                 idSoggetto.setCodicePorta(this.traccia.getDominio().getIdentificativoPorta());
  192.             }
  193.         }
  194.         return idSoggetto;
  195.     }
  196.     public void setIdSoggetto(IDSoggetto value) {
  197.         if(value!=null && (value.getTipo()!=null || value.getNome()!=null || value.getCodicePorta()!=null)){
  198.             if(value.getTipo()!=null || value.getNome()!=null){
  199.                 if(this.traccia.getDominio()==null){
  200.                     this.traccia.setDominio(new Dominio());
  201.                 }
  202.                 if(this.traccia.getDominio().getSoggetto()==null){
  203.                     this.traccia.getDominio().setSoggetto(new DominioSoggetto());
  204.                 }
  205.                 this.traccia.getDominio().getSoggetto().setTipo(value.getTipo());
  206.                 this.traccia.getDominio().getSoggetto().setBase(value.getNome());
  207.             }
  208.             else{
  209.                 if(this.traccia.getDominio()!=null){
  210.                     this.traccia.getDominio().setSoggetto(null);
  211.                 }
  212.             }
  213.             
  214.             if(value.getCodicePorta()!=null){
  215.                 if(this.traccia.getDominio()==null){
  216.                     this.traccia.setDominio(new Dominio());
  217.                 }
  218.                 this.traccia.getDominio().setIdentificativoPorta(value.getCodicePorta());
  219.             }
  220.             else{
  221.                 if(this.traccia.getDominio()!=null){
  222.                     this.traccia.getDominio().setIdentificativoPorta(null);
  223.                 }
  224.             }
  225.         }
  226.         else{
  227.             if(this.traccia.getDominio()!=null){
  228.                 if(this.traccia.getDominio().getFunzione()==null){
  229.                     this.traccia.setDominio(null);
  230.                 }
  231.                 else{
  232.                     this.traccia.getDominio().setIdentificativoPorta(null);
  233.                     this.traccia.getDominio().setSoggetto(null);
  234.                 }
  235.             }
  236.         }
  237.     }
  238.     public TipoPdD getTipoPdD() {
  239.         if(this.traccia.getDominio()!=null && this.traccia.getDominio().getFunzione()!=null){
  240.             switch (this.traccia.getDominio().getFunzione()) {
  241.             case PORTA_DELEGATA:
  242.                 return TipoPdD.DELEGATA;
  243.             case PORTA_APPLICATIVA:
  244.                 return TipoPdD.APPLICATIVA;
  245.             case INTEGRATION_MANAGER:
  246.                 return TipoPdD.INTEGRATION_MANAGER;
  247.             case ROUTER:
  248.                 return TipoPdD.ROUTER;
  249.             }
  250.         }
  251.         return null;
  252.     }
  253.     public void setTipoPdD(TipoPdD tipoPdD) {
  254.         if(tipoPdD!=null){
  255.             if(this.traccia.getDominio()==null){
  256.                 this.traccia.setDominio(new Dominio());
  257.             }
  258.             switch (tipoPdD) {
  259.             case DELEGATA:
  260.                 this.traccia.getDominio().setFunzione(org.openspcoop2.core.tracciamento.constants.TipoPdD.PORTA_DELEGATA);
  261.                 break;
  262.             case APPLICATIVA:
  263.                 this.traccia.getDominio().setFunzione(org.openspcoop2.core.tracciamento.constants.TipoPdD.PORTA_APPLICATIVA);
  264.                 break;
  265.             case INTEGRATION_MANAGER:
  266.                 this.traccia.getDominio().setFunzione(org.openspcoop2.core.tracciamento.constants.TipoPdD.INTEGRATION_MANAGER);
  267.                 break;
  268.             case ROUTER:
  269.                 this.traccia.getDominio().setFunzione(org.openspcoop2.core.tracciamento.constants.TipoPdD.ROUTER);
  270.                 break;
  271.             }
  272.         }
  273.         else{
  274.             if(this.traccia.getDominio()!=null){
  275.                 if(this.traccia.getDominio().getIdentificativoPorta()==null && this.traccia.getDominio().getSoggetto()==null){
  276.                     this.traccia.setDominio(null);
  277.                 }
  278.                 else{
  279.                     this.traccia.getDominio().setFunzione(null);
  280.                 }
  281.             }
  282.         }
  283.     }
  284.     
  285.     
  286.     // tipoTraccia [wrapper]
  287.     
  288.     public RuoloMessaggio getTipoMessaggio() {
  289.         if(this.traccia.getTipo()!=null){
  290.             switch (this.traccia.getTipo()) {
  291.             case RICHIESTA:
  292.                 return RuoloMessaggio.RICHIESTA;
  293.             case RISPOSTA:
  294.                 return RuoloMessaggio.RISPOSTA;
  295.             }
  296.         }
  297.         return null;
  298.     }
  299.     public void setTipoMessaggio(RuoloMessaggio value) {
  300.         if(value!=null){
  301.             switch (value) {
  302.             case RICHIESTA:
  303.                 this.traccia.setTipo(org.openspcoop2.core.tracciamento.constants.TipoTraccia.RICHIESTA);
  304.                 break;
  305.             case RISPOSTA:
  306.                 this.traccia.setTipo(org.openspcoop2.core.tracciamento.constants.TipoTraccia.RISPOSTA);
  307.                 break;
  308.             }
  309.         }
  310.     }

  312.     
  313.     
  314.     // Busta
  315.     
  316.     public Busta getBusta() {
  317.         return this.busta;
  318.     }
  319.     public void setBusta(Busta value) {
  320.         this.busta = value!=null ? value.newInstance() : null;
  321.         if(value!=null)
  322.             this.traccia.setBusta(value.getBusta());
  323.         else
  324.             this.traccia.setBusta(null);
  325.     }
  326.     public byte[] getBustaAsByteArray() {
  327.         return this.bustaInByte;
  328.     }
  329.     public void setBustaAsByteArray(byte[] bustaInByte) {
  330.         this.bustaInByte = bustaInByte;
  331.     }
  332.     public BustaRawContent<?> getBustaAsRawContent() {
  333.         return this.bustaRawContent;
  334.     }
  335.     public void setBustaAsRawContent(BustaRawContent<?> bustaElement) {
  336.         this.bustaRawContent = bustaElement;
  337.     }
  338.     // [wrapper]
  339.     public String getBustaAsString() {
  340.         return this.traccia.getBustaRaw();
  341.     }
  342.     public void setBustaAsString(String bustaAsString) {
  343.         this.traccia.setBustaRaw(bustaAsString);
  344.     }
  345.     
  346.     
  347.     // correlazione [wrapper]
  348.     
  349.     public String getCorrelazioneApplicativa() {
  350.         return this.traccia.getIdentificativoCorrelazioneRichiesta();
  351.     }
  352.     public void setCorrelazioneApplicativa(String value) {
  353.         this.traccia.setIdentificativoCorrelazioneRichiesta(value);
  354.     }
  355.     
  356.     public String getCorrelazioneApplicativaRisposta() {
  357.         return this.traccia.getIdentificativoCorrelazioneRisposta();
  358.     }
  359.     public void setCorrelazioneApplicativaRisposta(String value) {
  360.         this.traccia.setIdentificativoCorrelazioneRisposta(value);
  361.     }
  362.     
  363.     
  364.     
  365.     // location [wrapper]
  366.     
  367.     public String getLocation() {
  368.         return this.traccia.getLocation();
  369.     }
  370.     public void setLocation(String value) {
  371.         this.traccia.setLocation(value);
  372.     }
  373.     
  374.     


  377.     // properties
  378.     public void addPropertyInBusta(String key,String value){
  379.         if(this.traccia.getBusta()==null){
  380.             this.traccia.setBusta(new org.openspcoop2.core.tracciamento.Busta());
  381.         }
  382.         if(this.traccia.getBusta().getProtocollo()==null){
  383.             this.traccia.getBusta().setProtocollo(new Protocollo());
  384.         }
  385.         if(this.traccia.getBusta().getProtocollo().getProprietaList()==null){
  386.             this.traccia.getBusta().getProtocollo().setProprietaList(new ArrayList<Proprieta>());
  387.         }
  388.         boolean exists = false;
  389.         for (int i = 0; i < this.traccia.getBusta().getProtocollo().sizeProprietaList(); i++) {
  390.             Proprieta p = this.traccia.getBusta().getProtocollo().getProprieta(i);
  391.             if(key.equals(p.getNome())){
  392.                 exists = true;
  393.                 break;
  394.             }
  395.         }
  396.         if(!exists){
  397.             Proprieta proprieta = new Proprieta();
  398.             proprieta.setNome(key);
  399.             proprieta.setValore(value);
  400.             this.traccia.getBusta().getProtocollo().addProprieta(proprieta);
  401.         }
  402.     }
  403.     public void addProperty(String key,String value){
  404.         this.properties.put(key,value);
  405.     }  
  406.     public int sizeProperties(){
  407.         return this.properties.size();
  408.     }
  409.     public String getProperty(String key){
  410.         String value = this.properties.get(key);
  411.         if(value==null || "".equals(value)){
  412.             if(Costanti.ID_TRANSAZIONE.getValue().equals(key)){
  413.                 if(this.traccia.getBusta()!=null && this.traccia.getBusta().getProtocollo()!=null && 
  414.                         this.traccia.getBusta().getProtocollo().getProprietaList()!=null){
  415.                     for (int i = 0; i < this.traccia.getBusta().getProtocollo().sizeProprietaList(); i++) {
  416.                         Proprieta p = this.traccia.getBusta().getProtocollo().getProprieta(i);
  417.                         if(Costanti.ID_TRANSAZIONE.getValue().equals(p.getNome())){
  418.                             return p.getValore();
  419.                         }
  420.                     }
  421.                 }
  422.             }
  423.         }
  424.         return value;
  425.     }
  426.     public String removeProperty(String key){
  427.         return this.properties.remove(key);
  428.     }
  429.     public String[] getPropertiesValues() {
  430.         return this.properties.values().toArray(new String[this.properties.size()]);
  431.     }
  432.     public String[] getPropertiesNames() {
  433.         return this.properties.keySet().toArray(new String[this.properties.size()]);
  434.     }
  435.     public void setProperties(Map<String, String> params) {
  436.         this.properties = params;
  437.     }
  438.     public Map<String, String> getProperties() {
  439.         return this.properties;
  440.     }
  441.     
  442.     
  443.     // protocollo
  444.     public String getProtocollo() {
  445.         return this.protocollo;
  446.     }
  447.     public void setProtocollo(String protocollo) {
  448.         this.protocollo = protocollo;
  449.     }
  450.     
  451.     
  452.     // esito [Wrapper]
  453.     public EsitoElaborazioneMessaggioTracciato getEsitoElaborazioneMessaggioTracciato() {
  454.         if(this.traccia.getEsitoElaborazione()!=null){
  455.             EsitoElaborazioneMessaggioTracciato esito = new EsitoElaborazioneMessaggioTracciato();
  456.             esito.setDettaglio(this.traccia.getEsitoElaborazione().getDettaglio());
  457.             if(this.traccia.getEsitoElaborazione().getTipo()!=null){
  458.                 switch (this.traccia.getEsitoElaborazione().getTipo()) {
  459.                 case INVIATO:
  460.                     esito.setEsito(EsitoElaborazioneMessaggioTracciatura.INVIATO);
  461.                     break;
  462.                 case RICEVUTO:
  463.                     esito.setEsito(EsitoElaborazioneMessaggioTracciatura.RICEVUTO);
  464.                     break;
  465.                 case ERRORE:
  466.                     esito.setEsito(EsitoElaborazioneMessaggioTracciatura.ERRORE);
  467.                     break;
  468.                 }
  469.             }
  470.             return esito;
  471.         }
  472.         return null;
  473.     }
  474.     public void setEsitoElaborazioneMessaggioTracciato(
  475.             EsitoElaborazioneMessaggioTracciato esitoElaborazioneMessaggioTracciato) {
  476.         if(esitoElaborazioneMessaggioTracciato==null){
  477.             return;
  478.         }
  479.         if(this.traccia.getEsitoElaborazione()==null){
  480.             this.traccia.setEsitoElaborazione(new TracciaEsitoElaborazione());
  481.         }
  482.         this.traccia.getEsitoElaborazione().setDettaglio(esitoElaborazioneMessaggioTracciato.getDettaglio());
  483.         if(esitoElaborazioneMessaggioTracciato.getEsito()!=null){
  484.             switch (esitoElaborazioneMessaggioTracciato.getEsito()) {
  485.             case INVIATO:
  486.                 this.traccia.getEsitoElaborazione().setTipo(TipoEsitoElaborazione.INVIATO);
  487.                 break;
  488.             case RICEVUTO:
  489.                 this.traccia.getEsitoElaborazione().setTipo(TipoEsitoElaborazione.RICEVUTO);
  490.                 break;
  491.             case ERRORE:
  492.                 this.traccia.getEsitoElaborazione().setTipo(TipoEsitoElaborazione.ERRORE);
  493.                 break;
  494.             }
  495.         }
  496.     }
  497.     
  498.     
  499.     // allegati [wrapped]
  500.     public List<Allegato> getListaAllegati() {
  501.         return this.allegati;
  502.     }
  503.     public int sizeListaAllegati() {
  504.         return this.allegati.size();
  505.     }
  506.     public void addAllegato(Allegato a) {
  507.         this.addAllegato(a, true);
  508.     }
  509.     private void addAllegato(Allegato a, boolean addCore) {
  510.         this.allegati.add(a);
  511.         if(addCore){
  512.             if(this.traccia.getAllegati()==null){
  513.                 this.traccia.setAllegati(new Allegati());
  514.             }
  515.             this.traccia.getAllegati().addAllegato(a.getAllegato());
  516.         }
  517.     }
  518.     public Allegato getAllegato(int index) {
  519.         return this.allegati.get(index);
  520.     }
  521.     public Allegato removeAllegato(int index) {
  522.         this.traccia.getAllegati().removeAllegato(index);
  523.         return this.allegati.remove(index);
  524.     }
  525.     protected void setListaAllegati(List<Allegato> listaAllegati) {
  526.         this.allegati = listaAllegati;
  527.     }
  528.     
  529.     
  530.     
  531.     
  532.     public Traccia newInstance(){
  533.         
  534.         // Non uso il base clone per far si che venga usato il costruttore new String()
  535.         
  536.         Traccia clone = new Traccia();
  537.         
  538.         // id
  539.         clone.setId(this.getId()!=null ? Long.valueOf(this.getId()+"") : null);
  540.         
  541.         // data
  542.         clone.setGdo(this.getGdo()!=null ? new Date(this.getGdo().getTime()) : null);
  543.         
  544.         // dominio
  545.         clone.setIdSoggetto(this.getIdSoggetto()!=null ? this.getIdSoggetto().clone() : null);
  546.         clone.setTipoPdD(this.getTipoPdD());
  547.         
  548.         // tipoTraccia
  549.         clone.setTipoMessaggio(this.getTipoMessaggio());
  550.         
  551.         // busta
  552.         clone.setBusta(this.getBusta()!=null ? this.getBusta().newInstance() : null);
  553.         ByteArrayOutputStream bout = null;
  554.         if(this.getBustaAsByteArray()!=null){
  555.             bout = new ByteArrayOutputStream();
  556.             try{
  557.                 bout.write(this.getBustaAsByteArray());
  558.                 bout.flush();
  559.                 bout.close();
  560.             }catch(Exception e){
  561.                 throw new RuntimeException(e.getMessage(),e);
  562.             }
  563.             clone.setBustaAsByteArray(bout.toByteArray());
  564.         }
  565.         clone.setBustaAsRawContent(this.getBustaAsRawContent()); // non clonato, vedere se si trova un modo efficiente se serve
  566.         clone.setBustaAsString(this.getBustaAsString()!=null ? new String(this.getBustaAsString()) : null);
  567.         
  568.         // correlazione
  569.         clone.setCorrelazioneApplicativa(this.getCorrelazioneApplicativa()!=null ? new String(this.getCorrelazioneApplicativa()) : null);
  570.         clone.setCorrelazioneApplicativaRisposta(this.getCorrelazioneApplicativaRisposta()!=null ? new String(this.getCorrelazioneApplicativaRisposta()) : null);
  571.         
  572.         // location
  573.         clone.setLocation(this.getLocation()!=null ? new String(this.getLocation()) : null);
  574.         
  575.         // esito
  576.         clone.setEsitoElaborazioneMessaggioTracciato(this.getEsitoElaborazioneMessaggioTracciato()!=null ? this.getEsitoElaborazioneMessaggioTracciato().clone() : null);
  577.         
  578.         // properties
  579.         if(this.properties!=null && this.properties.size()>0){
  580.             for (String key : this.properties.keySet()) {
  581.                 String value = this.properties.get(key);
  582.                 if(key!=null && value!=null){
  583.                     clone.addProperty(new String(key), new String(value));
  584.                 }
  585.             }
  586.         }
  587.         
  588.         // protocollo
  589.         clone.setProtocollo(this.protocollo!=null ? new String(this.protocollo) : null);
  590.         
  591.         // allegati
  592.         for(int i=0; i<this.sizeListaAllegati(); i++){
  593.             clone.addAllegato(this.getAllegato(i).clone());
  594.         }
  595.         
  596.         return clone;
  597.     }
  598. }
Created with JaCoCo 0.8.8.202204050719