Converter.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */

  21. package org.openspcoop2.pdd.logger.traccia;

  23. import java.lang.reflect.Field;
  24. import java.util.ArrayList;
  25. import java.util.List;
  26. import java.util.Properties;

  28. import org.joda.time.DateTime;
  29. import org.openspcoop2.core.constants.CostantiLabel;
  30. import org.openspcoop2.core.id.IDServizioApplicativo;
  31. import org.openspcoop2.core.id.IDSoggetto;
  32. import org.openspcoop2.core.transazioni.DumpAllegato;
  33. import org.openspcoop2.core.transazioni.DumpContenuto;
  34. import org.openspcoop2.core.transazioni.DumpHeaderAllegato;
  35. import org.openspcoop2.core.transazioni.DumpHeaderTrasporto;
  36. import org.openspcoop2.core.transazioni.DumpMessaggio;
  37. import org.openspcoop2.core.transazioni.DumpMultipartHeader;
  38. import org.openspcoop2.core.transazioni.constants.PddRuolo;
  39. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  40. import org.openspcoop2.core.transazioni.utils.CredenzialiMittente;
  41. import org.openspcoop2.core.transazioni.utils.credenziali.CredenzialeTokenClient;
  42. import org.openspcoop2.message.constants.MessageType;
  43. import org.openspcoop2.pdd.logger.LogLevels;
  44. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  45. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  46. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  47. import org.openspcoop2.protocol.sdk.constants.TipoSerializzazione;
  48. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  49. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaSerializer;
  50. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  51. import org.openspcoop2.protocol.utils.EsitiProperties;
  52. import org.openspcoop2.utils.date.DateManager;
  53. import org.openspcoop2.utils.service.beans.Diagnostico;
  54. import org.openspcoop2.utils.service.beans.DiagnosticoSeveritaEnum;
  55. import org.openspcoop2.utils.service.beans.HttpMethodEnum;
  56. import org.openspcoop2.utils.service.beans.ProfiloCollaborazioneEnum;
  57. import org.openspcoop2.utils.service.beans.ProfiloEnum;
  58. import org.openspcoop2.utils.service.beans.Transazione;
  59. import org.openspcoop2.utils.service.beans.TransazioneBase;
  60. import org.openspcoop2.utils.service.beans.TransazioneContenutoMessaggio;
  61. import org.openspcoop2.utils.service.beans.TransazioneContenutoMessaggioHeader;
  62. import org.openspcoop2.utils.service.beans.TransazioneContestoEnum;
  63. import org.openspcoop2.utils.service.beans.TransazioneDettaglioMessaggio;
  64. import org.openspcoop2.utils.service.beans.TransazioneDettaglioRichiesta;
  65. import org.openspcoop2.utils.service.beans.TransazioneDettaglioRisposta;
  66. import org.openspcoop2.utils.service.beans.TransazioneEsito;
  67. import org.openspcoop2.utils.service.beans.TransazioneExt;
  68. import org.openspcoop2.utils.service.beans.TransazioneExtContenutoMessaggio;
  69. import org.openspcoop2.utils.service.beans.TransazioneExtContenutoMessaggioAllegato;
  70. import org.openspcoop2.utils.service.beans.TransazioneExtContenutoMessaggioBody;
  71. import org.openspcoop2.utils.service.beans.TransazioneExtContenutoMessaggioBodyMultipart;
  72. import org.openspcoop2.utils.service.beans.TransazioneExtContenutoMessaggioPorzioneBody;
  73. import org.openspcoop2.utils.service.beans.TransazioneExtDettaglioRichiesta;
  74. import org.openspcoop2.utils.service.beans.TransazioneExtDettaglioRisposta;
  75. import org.openspcoop2.utils.service.beans.TransazioneExtInformazioniApi;
  76. import org.openspcoop2.utils.service.beans.TransazioneExtInformazioniMittente;
  77. import org.openspcoop2.utils.service.beans.TransazioneExtInformazioniMittenteApplicativoToken;
  78. import org.openspcoop2.utils.service.beans.TransazioneExtInformazioniSoggetto;
  79. import org.openspcoop2.utils.service.beans.TransazioneExtInformazioniToken;
  80. import org.openspcoop2.utils.service.beans.TransazioneInformazioniApi;
  81. import org.openspcoop2.utils.service.beans.TransazioneInformazioniMittente;
  82. import org.openspcoop2.utils.service.beans.TransazioneMessaggioFormatoEnum;
  83. import org.openspcoop2.utils.service.beans.TransazioneRuoloEnum;
  84. import org.slf4j.Logger;

  86. /** 
  87.  * ConverterUtils
  88.  *
  89.  * @author Poli Andrea (apoli@link.it)
  90.  * @author $Author$
  91.  * @version $Rev$, $Date$
  92.  */
  93. public class Converter {

  95.     private Logger log;
  96.     private boolean throwInitProtocol= true;
  97.     
  98.     // configurazione
  99.     private boolean emittente = true;
  100.     private boolean dataEmissione = true;
  101.     private boolean id = true;
  102.     private boolean idConversazione = true;
  103.     private boolean ruolo = true;
  104.     private boolean esito = true;
  105.     private boolean messaggi_id = true;
  106.     private boolean messaggi_idApplicativo = true;
  107.     private boolean messaggi_data = true;
  108.     private boolean messaggi_contenuti = true;
  109.     private boolean richiesta_tipo = true;
  110.     private boolean richiesta_urlInvocazione = true;
  111.     private boolean risposta_esito = true;
  112.     private boolean risposta_fault = true;
  113.     private boolean risposta_errori = true;
  114.     private boolean api_erogatore = true;
  115.     private boolean api_nome = true;
  116.     private boolean api_versione = true;
  117.     private boolean api_operazione = true;
  118.     private boolean mittente_fruitore = true;
  119.     private boolean mittente_principal = true;
  120.     private boolean mittente_utente = true;
  121.     private boolean mittente_client = true;
  122.     private boolean mittente_indirizzoClient = true;
  123.     private boolean mittente_indirizzoClientInoltrato = true;
  124.     
  125.     // configurazione ext
  126.     private boolean profilo = true;
  127.     private boolean contesto = true;
  128.     private boolean idCluster = true;
  129.     private boolean emittenteExtraInfo = true;
  130.     private boolean stato = true;
  131.     private boolean messaggi_dimensione = true;
  132.     private boolean messaggi_dataAccettazione = true;
  133.     private boolean messaggi_duplicati = true;
  134.     private boolean messaggi_tracciaProtocollo = true;
  135.     private boolean richiesta_connettore = true;
  136.     private boolean diagnostici = true;
  137.     private boolean api_erogatoreExtraInfo = true;
  138.     private boolean api_tags = true;
  139.     private boolean api_tipo = true;
  140.     private boolean api_idAsincrono = true;
  141.     private boolean api_profiloCollaborazione = true;
  142.     private boolean mittente_fruitoreExtraInfo = true;
  143.     private boolean mittente_applicativo = true;
  144.     private boolean mittente_credenziali = true;
  145.     private boolean mittente_token = true;
  146.     private boolean mittente_tokenClaims = true;
  147.     private boolean mittente_applicativoToken = true;
  148.     
  149.     
  150.     
  151.     public Converter(Logger log) {
  152.         this.log = log;
  153.     } 
  154.     public Converter(Logger log, Properties pConf) throws TracciaException {
  155.         this.log = log;
  156.         
  157.         try {
  158.             Field [] fields = Converter.class.getDeclaredFields();
  159.             for (Field field : fields) {
  160.                 String fieldName = field.getName();
  161.                 fieldName = fieldName.replace("_", ".");
  162.                 if(pConf.containsKey(fieldName)) {
  163.                     String value = pConf.getProperty(fieldName);
  164.                     String bCN = boolean.class.getName()+"";
  165.                     if(bCN.equals(field.getType().getName())) {
  166.                         field.set(this, "true".equalsIgnoreCase(value));
  167.                     }else {
  168.                         field.set(this, value);
  169.                     }
  170.                 }
  171.             }
  172.         }catch(Exception e) {
  173.             throw new TracciaException(e.getMessage(),e);
  174.         }
  175.     } 
  176.     
  177.     
  178.     
  179.     
  180.     public Transazione toTransazione(org.openspcoop2.core.transazioni.Transazione transazioneDB, 
  181.             CredenzialiMittente credenzialiMittente, List<MsgDiagnostico> messaggiDiagnostici) throws Exception {
  182.         return  (Transazione) this._toTransazione(transazioneDB, credenzialiMittente, null, null, messaggiDiagnostici, false);
  183.     }
  184.     
  185.     public TransazioneExt toTransazioneExt(org.openspcoop2.core.transazioni.Transazione transazioneDB, 
  186.             CredenzialiMittente credenzialiMittente, Traccia tracciaRichiesta, Traccia tracciaRisposta, List<MsgDiagnostico> messaggiDiagnostici) throws Exception {
  187.         return  (TransazioneExt) this._toTransazione(transazioneDB, credenzialiMittente, tracciaRichiesta, tracciaRisposta, messaggiDiagnostici, true);
  188.     }
  189.     
  190.     private TransazioneBase _toTransazione(org.openspcoop2.core.transazioni.Transazione transazioneDB, 
  191.             CredenzialiMittente credenzialiMittente, Traccia tracciaRichiesta, Traccia tracciaRisposta, List<MsgDiagnostico> messaggiDiagnostici,
  192.             boolean extended) throws Exception {

  194.         List<String> errori = new ArrayList<>();
  195.         if((!extended || !this.diagnostici) && messaggiDiagnostici!=null && messaggiDiagnostici.size()>0) {
  196.             for (MsgDiagnostico diag : messaggiDiagnostici) {
  197.                 if(diag.getSeverita() <= LogLevels.SEVERITA_ERROR_INTEGRATION) {
  198.                     errori.add(diag.getMessaggio());
  199.                 }
  200.             }
  201.         }
  202.         
  203.         TransazioneBase transazione = null;
  204.         if(extended) {
  205.             transazione = new TransazioneExt();
  206.         }
  207.         else {
  208.             transazione = new Transazione();
  209.         }
  210.         
  211.         if(this.id) {
  212.             transazione.setIdTraccia(java.util.UUID.fromString(transazioneDB.getIdTransazione()));
  213.         }
  214.         if(this.dataEmissione) {
  215.             transazione.setDataEmissione(new DateTime(DateManager.getTimeMillis()));
  216.         }
  217.         if(this.idConversazione) {
  218.             transazione.setIdConversazione(transazioneDB.getIdCollaborazione());
  219.         }
  220.         
  221.         if(this.esito) {
  222.             TransazioneEsito esito = new TransazioneEsito();
  223.             esito.setCodice(transazioneDB.getEsito()+"");
  224.             try {
  225.                 EsitiProperties esitiProperties = EsitiProperties.getInstanceFromProtocolName(this.log, transazioneDB.getProtocollo());
  226.                 esito.setDescrizione(esitiProperties.getEsitoLabel(transazioneDB.getEsito()));
  227.             }catch(Throwable e) {
  228.                 if(this.throwInitProtocol) {
  229.                     throw e;
  230.                 }
  231.                 else {
  232.                     esito.setDescrizione("ok");
  233.                 }
  234.             }
  235.             transazione.setEsito(esito);
  236.         }
  237.         
  238.         TransazioneRuoloEnum ruoloTraccia = null;
  239.         if(PddRuolo.DELEGATA.equals(transazioneDB.getPddRuolo())){
  240.             ruoloTraccia = TransazioneRuoloEnum.FRUIZIONE;
  241.         }
  242.         else {
  243.             ruoloTraccia = TransazioneRuoloEnum.EROGAZIONE;
  244.         }
  245.         
  246.         IProtocolFactory<?> protocolFactory = null;
  247.         ITracciaSerializer tracciaSerializer = null;
  248.         if(extended) {
  249.             try {
  250.                 protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(transazioneDB.getProtocollo());
  251.                 if(protocolFactory.createProtocolConfiguration().isAbilitataGenerazioneTracce()) {
  252.                     tracciaSerializer = protocolFactory.createTracciaSerializer();
  253.                 }
  254.             }catch(Throwable e) {
  255.                 if(this.throwInitProtocol) {
  256.                     throw e;
  257.                 }
  258.             }
  259.             if(this.ruolo) {
  260.                 ((TransazioneExt)transazione).setRuolo(ruoloTraccia);
  261.             }
  262.             if(this.emittente) {
  263.                 if(transazioneDB.getPddNomeSoggetto()!=null) { // liste con dati dell'indice e basta, non c'è questo campo
  264.                     ((TransazioneExt)transazione).setEmittente(transazioneDB.getPddNomeSoggetto());
  265.                 }
  266.                 else if(PddRuolo.APPLICATIVA.equals(transazioneDB.getPddRuolo()) && transazioneDB.getNomeSoggettoErogatore()!=null) {
  267.                     ((TransazioneExt)transazione).setEmittente(transazioneDB.getNomeSoggettoErogatore());
  268.                 }
  269.                 else if(PddRuolo.DELEGATA.equals(transazioneDB.getPddRuolo()) && transazioneDB.getNomeSoggettoFruitore()!=null) {
  270.                     ((TransazioneExt)transazione).setEmittente(transazioneDB.getNomeSoggettoFruitore());
  271.                 }
  272.                 else {
  273.                     ((TransazioneExt)transazione).setEmittente(transazioneDB.getPddCodice());
  274.                 }
  275.             }
  276.             if(this.profilo) {
  277.                 ProfiloEnum profilo = ProfiloEnum.APIGATEWAY;
  278.                 if(transazioneDB.getProtocollo().equals(CostantiLabel.MODIPA_PROTOCOL_NAME)) {
  279.                     profilo = ProfiloEnum.MODIPA;
  280.                 }
  281.                 else if(transazioneDB.getProtocollo().equals(CostantiLabel.SPCOOP_PROTOCOL_NAME)) {
  282.                     profilo = ProfiloEnum.SPCOOP;
  283.                 }
  284.                 else if(transazioneDB.getProtocollo().equals(CostantiLabel.SDI_PROTOCOL_NAME)) {
  285.                     profilo = ProfiloEnum.FATTURAPA;
  286.                 }
  287.                 else if(transazioneDB.getProtocollo().equals(CostantiLabel.AS4_PROTOCOL_NAME)) {
  288.                     profilo = ProfiloEnum.EDELIVERY;
  289.                 }
  290.                 ((TransazioneExt)transazione).setProfilo(profilo);
  291.             }
  292.             if(this.contesto) {
  293.                 TransazioneContestoEnum contesto = TransazioneContestoEnum.STANDARD;
  294.                 if(transazioneDB.getEsitoContesto()!=null && !TransazioneContestoEnum.STANDARD.name().equalsIgnoreCase(transazioneDB.getEsitoContesto())) {
  295.                     contesto = TransazioneContestoEnum.SONDA;
  296.                 }
  297.                 ((TransazioneExt)transazione).setContesto(contesto);
  298.             }
  299.             if(this.idCluster) {
  300.                 ((TransazioneExt)transazione).setIdCluster(transazioneDB.getClusterId());
  301.             }
  302.             if(this.emittenteExtraInfo) {
  303.                 String tipoEmittente = transazioneDB.getPddTipoSoggetto(); // liste con dati dell'indice e basta, non c'è questo campo
  304.                 if(tipoEmittente==null) {
  305.                     if(PddRuolo.APPLICATIVA.equals(transazioneDB.getPddRuolo()) && transazioneDB.getTipoSoggettoErogatore()!=null) {
  306.                         tipoEmittente = transazioneDB.getTipoSoggettoErogatore();
  307.                     }
  308.                     else if(PddRuolo.DELEGATA.equals(transazioneDB.getPddRuolo()) && transazioneDB.getTipoSoggettoFruitore()!=null) {
  309.                         tipoEmittente = transazioneDB.getTipoSoggettoFruitore();
  310.                     }
  311.                     else {
  312.                         tipoEmittente = protocolFactory.createProtocolConfiguration().getTipoSoggettoDefault();
  313.                     }
  314.                 }
  315.                 ((TransazioneExt)transazione).setInformazioniEmittente(_newTransazioneSoggetto(tipoEmittente, transazioneDB.getPddCodice(), null));
  316.             }
  317.             if(this.stato) {
  318.                 ((TransazioneExt)transazione).setStato(transazioneDB.getStato());
  319.             }
  320.         }
  321.         else {
  322.             if(this.ruolo) {
  323.                 ((Transazione)transazione).setRuolo(ruoloTraccia);
  324.             }
  325.             if(this.emittente) {
  326.                 ((Transazione)transazione).setEmittente(transazioneDB.getPddNomeSoggetto());
  327.             }
  328.         }

  330.         TransazioneDettaglioMessaggio richiesta = null;
  331.         if(extended) {
  332.             richiesta = new TransazioneExtDettaglioRichiesta();
  333.         }
  334.         else {
  335.             richiesta = new TransazioneDettaglioRichiesta();
  336.         }
  337.         if(extended) {
  338.             if(this.messaggi_dimensione) {
  339.                 ((TransazioneExtDettaglioRichiesta)richiesta).setBytesIngresso(transazioneDB.getRichiestaIngressoBytes());
  340.                 ((TransazioneExtDettaglioRichiesta)richiesta).setBytesUscita(transazioneDB.getRichiestaUscitaBytes());
  341.             }
  342.             if(this.messaggi_dataAccettazione && transazioneDB.getDataAccettazioneRichiesta()!=null) {
  343.                 ((TransazioneExtDettaglioRichiesta)richiesta).setDataAccettazione(new DateTime(transazioneDB.getDataAccettazioneRichiesta().getTime()));
  344.             }
  345.         }
  346.         if(this.messaggi_id) {
  347.             richiesta.setId(transazioneDB.getIdMessaggioRichiesta());
  348.         }
  349.         if(this.messaggi_idApplicativo) {
  350.             richiesta.setIdApplicativo(transazioneDB.getIdCorrelazioneApplicativa());
  351.         }
  352.         if(extended) {
  353.             if(this.messaggi_data) {
  354.                 if(transazioneDB.getDataIngressoRichiesta()!=null) {
  355.                     ((TransazioneExtDettaglioRichiesta)richiesta).setDataRicezione(new DateTime(transazioneDB.getDataIngressoRichiesta().getTime()));
  356.                 }
  357.                 if(transazioneDB.getDataIngressoRichiestaStream()!=null) {
  358.                     ((TransazioneExtDettaglioRichiesta)richiesta).setDataRicezioneAcquisita(new DateTime(transazioneDB.getDataIngressoRichiestaStream().getTime()));
  359.                 }
  360.                 if(transazioneDB.getDataUscitaRichiesta()!=null) {
  361.                     ((TransazioneExtDettaglioRichiesta)richiesta).setDataConsegna(new DateTime(transazioneDB.getDataUscitaRichiesta().getTime()));
  362.                 }
  363.                 if(transazioneDB.getDataUscitaRichiestaStream()!=null) {
  364.                     ((TransazioneExtDettaglioRichiesta)richiesta).setDataConsegnaEffettuata(new DateTime(transazioneDB.getDataUscitaRichiestaStream().getTime()));
  365.                 }
  366.             }
  367.             if(this.richiesta_tipo && transazioneDB.getTipoRichiesta()!=null) {
  368.                 HttpMethodEnum methodEnum = HttpMethodEnum.fromValue(transazioneDB.getTipoRichiesta().toUpperCase());
  369.                 ((TransazioneExtDettaglioRichiesta)richiesta).setTipo(methodEnum);
  370.             }
  371.             if(this.richiesta_urlInvocazione) {
  372.                 ((TransazioneExtDettaglioRichiesta)richiesta).setUrlInvocazione(normalizeUrl(transazioneDB.getUrlInvocazione()));
  373.             }
  374.             if(this.richiesta_connettore) {
  375.                 ((TransazioneExtDettaglioRichiesta)richiesta).setConnettore(normalizeUrl(transazioneDB.getLocationConnettore()));
  376.             }
  377.             if(this.messaggi_duplicati) {
  378.                 ((TransazioneExtDettaglioRichiesta)richiesta).setDuplicatiMessaggio(transazioneDB.getDuplicatiRichiesta());
  379.             }
  380.             if(this.messaggi_tracciaProtocollo && tracciaSerializer!=null && tracciaRichiesta!=null) {
  381.                 ((TransazioneExtDettaglioRichiesta)richiesta).setTraccia(tracciaSerializer.toString(tracciaRichiesta, TipoSerializzazione.DEFAULT));
  382.             }
  383.             if(this.messaggi_contenuti) {
  384.                 ((TransazioneExtDettaglioRichiesta)richiesta).setContenutiIngresso(
  385.                         (TransazioneExtContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  386.                                 TipoMessaggio.RICHIESTA_INGRESSO, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO ,true));
  387.                 ((TransazioneExtDettaglioRichiesta)richiesta).setContenutiUscita(
  388.                         (TransazioneExtContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  389.                                 TipoMessaggio.RICHIESTA_USCITA, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO ,true));
  390.             }
  391.             ((TransazioneExt)transazione).setRichiesta((TransazioneExtDettaglioRichiesta) richiesta);
  392.         }
  393.         else {
  394.             if(this.messaggi_data) {
  395.                 if(transazioneDB.getDataIngressoRichiesta()!=null) {
  396.                     ((TransazioneDettaglioRichiesta)richiesta).setDataRicezione(new DateTime(transazioneDB.getDataIngressoRichiesta().getTime()));
  397.                 }
  398.                 if(transazioneDB.getDataUscitaRichiesta()!=null) {
  399.                     ((TransazioneDettaglioRichiesta)richiesta).setDataConsegna(new DateTime(transazioneDB.getDataUscitaRichiesta().getTime()));
  400.                 }
  401.             }
  402.             if(this.richiesta_tipo && transazioneDB.getTipoRichiesta()!=null) {
  403.                 HttpMethodEnum methodEnum = HttpMethodEnum.fromValue(transazioneDB.getTipoRichiesta().toUpperCase());
  404.                 ((TransazioneDettaglioRichiesta)richiesta).setTipo(methodEnum);
  405.             }
  406.             if(this.richiesta_urlInvocazione) {
  407.                 if(TransazioneRuoloEnum.FRUIZIONE.equals(ruoloTraccia)){
  408.                     ((TransazioneDettaglioRichiesta)richiesta).setUrlInvocazione(normalizeUrl(transazioneDB.getLocationConnettore()));
  409.                 }
  410.                 else {
  411.                     ((TransazioneDettaglioRichiesta)richiesta).setUrlInvocazione(normalizeUrl(transazioneDB.getUrlInvocazione()));
  412.                 }
  413.             }
  414.             if(this.messaggi_contenuti) {
  415.                 if(TransazioneRuoloEnum.FRUIZIONE.equals(ruoloTraccia)){
  416.                     ((TransazioneDettaglioRichiesta)richiesta).setContenuti(
  417.                             (TransazioneContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  418.                                     TipoMessaggio.RICHIESTA_USCITA, TipoMessaggio.RICHIESTA_USCITA_DUMP_BINARIO ,false));
  419.                 }
  420.                 else {
  421.                     ((TransazioneDettaglioRichiesta)richiesta).setContenuti(
  422.                             (TransazioneContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  423.                                     TipoMessaggio.RICHIESTA_INGRESSO, TipoMessaggio.RICHIESTA_INGRESSO_DUMP_BINARIO ,false));
  424.                 }
  425.             }
  426.             ((Transazione)transazione).setRichiesta((TransazioneDettaglioRichiesta) richiesta);
  427.         }
  428.         
  429.         TransazioneDettaglioMessaggio risposta = null;
  430.         if(extended) {
  431.             risposta = new TransazioneExtDettaglioRisposta();
  432.         }
  433.         else {
  434.             risposta = new TransazioneDettaglioRisposta();
  435.         }
  436.         if(extended) {
  437.             if(this.messaggi_dimensione) {
  438.                 ((TransazioneExtDettaglioRisposta)risposta).setBytesIngresso(transazioneDB.getRispostaIngressoBytes());
  439.                 ((TransazioneExtDettaglioRisposta)risposta).setBytesUscita(transazioneDB.getRispostaUscitaBytes());
  440.             }
  441.             if(this.messaggi_dataAccettazione && transazioneDB.getDataAccettazioneRisposta()!=null) {
  442.                 ((TransazioneExtDettaglioRisposta)risposta).setDataAccettazione(new DateTime(transazioneDB.getDataAccettazioneRisposta().getTime()));
  443.             }
  444.         }
  445.         if(this.messaggi_id) {
  446.             risposta.setId(transazioneDB.getIdMessaggioRisposta());
  447.         }
  448.         if(this.messaggi_idApplicativo) {
  449.             risposta.setIdApplicativo(transazioneDB.getIdCorrelazioneApplicativaRisposta());
  450.         }
  451.         if(extended) {
  452.             if(this.messaggi_data) {
  453.                 if(transazioneDB.getDataIngressoRisposta()!=null) {
  454.                     ((TransazioneExtDettaglioRisposta)risposta).setDataRicezione(new DateTime(transazioneDB.getDataIngressoRisposta().getTime()));
  455.                 }
  456.                 if(transazioneDB.getDataIngressoRispostaStream()!=null) {
  457.                     ((TransazioneExtDettaglioRisposta)risposta).setDataRicezioneAcquisita(new DateTime(transazioneDB.getDataIngressoRispostaStream().getTime()));
  458.                 }
  459.                 // inverto
  460.                 if(transazioneDB.getDataUscitaRisposta()!=null) {
  461.                     ((TransazioneExtDettaglioRisposta)risposta).setDataConsegnaEffettuata(new DateTime(transazioneDB.getDataUscitaRisposta().getTime()));
  462.                 }
  463.                 if(transazioneDB.getDataUscitaRispostaStream()!=null) {
  464.                     ((TransazioneExtDettaglioRisposta)risposta).setDataConsegna(new DateTime(transazioneDB.getDataUscitaRispostaStream().getTime()));
  465.                 }
  466.             }
  467.             if(this.risposta_esito) {
  468.                 ((TransazioneExtDettaglioRisposta)risposta).setEsitoConsegna(transazioneDB.getCodiceRispostaUscita());
  469.                 ((TransazioneExtDettaglioRisposta)risposta).setEsitoRicezione(transazioneDB.getCodiceRispostaIngresso());
  470.             }
  471.             if(this.messaggi_duplicati) {
  472.                 ((TransazioneExtDettaglioRisposta)risposta).setDuplicatiMessaggio(transazioneDB.getDuplicatiRisposta());
  473.             }
  474.             if(this.messaggi_tracciaProtocollo && tracciaSerializer!=null && tracciaRisposta!=null) {
  475.                 ((TransazioneExtDettaglioRisposta)risposta).setTraccia(tracciaSerializer.toString(tracciaRisposta, TipoSerializzazione.DEFAULT));
  476.             }
  477.             if(this.messaggi_contenuti) {
  478.                 ((TransazioneExtDettaglioRisposta)risposta).setContenutiIngresso(
  479.                         (TransazioneExtContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  480.                                 TipoMessaggio.RISPOSTA_INGRESSO, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO ,true));
  481.                 ((TransazioneExtDettaglioRisposta)risposta).setContenutiUscita(
  482.                         (TransazioneExtContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  483.                                 TipoMessaggio.RISPOSTA_USCITA, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO ,true));
  484.             }
  485.             if(this.risposta_fault) {
  486.                 if(TransazioneRuoloEnum.FRUIZIONE.equals(ruoloTraccia)){
  487.                     if(transazioneDB.getFaultCooperazione()!=null) {
  488.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultRicezione(transazioneDB.getFaultCooperazione().getBytes());
  489.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultRicezioneFormato(_convert(transazioneDB.getFormatoFaultCooperazione()));
  490.                     }
  491.                     if(transazioneDB.getFaultIntegrazione()!=null) {
  492.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultConsegna(transazioneDB.getFaultIntegrazione().getBytes());
  493.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultConsegnaFormato(_convert(transazioneDB.getFormatoFaultIntegrazione()));
  494.                     }
  495.                 }
  496.                 else {
  497.                     if(transazioneDB.getFaultCooperazione()!=null) {
  498.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultConsegna(transazioneDB.getFaultCooperazione().getBytes());
  499.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultConsegnaFormato(_convert(transazioneDB.getFormatoFaultCooperazione()));
  500.                     }
  501.                     if(transazioneDB.getFaultIntegrazione()!=null) {
  502.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultRicezione(transazioneDB.getFaultIntegrazione().getBytes());
  503.                         ((TransazioneExtDettaglioRisposta)risposta).setFaultRicezioneFormato(_convert(transazioneDB.getFormatoFaultIntegrazione()));
  504.                     }
  505.                 }
  506.             }
  507.             if(this.risposta_errori && !errori.isEmpty()) {
  508.                 ((TransazioneExtDettaglioRisposta)risposta).setDettagliErrore(new ArrayList<>());
  509.                 for (String errore : errori) {
  510.                     ((TransazioneExtDettaglioRisposta)risposta).getDettagliErrore().add(errore);
  511.                 }
  512.             }
  513.             ((TransazioneExt)transazione).setRisposta(((TransazioneExtDettaglioRisposta)risposta));
  514.         }
  515.         else {
  516.             if(this.messaggi_data) {
  517.                 if(transazioneDB.getDataIngressoRisposta()!=null) {
  518.                     ((TransazioneDettaglioRisposta)risposta).setDataRicezione(new DateTime(transazioneDB.getDataIngressoRisposta().getTime()));
  519.                 }
  520.                 if(transazioneDB.getDataUscitaRisposta()!=null) {
  521.                     ((TransazioneDettaglioRisposta)risposta).setDataConsegna(new DateTime(transazioneDB.getDataUscitaRisposta().getTime()));
  522.                 }
  523.             }
  524.             if(this.risposta_esito) {
  525.                 ((TransazioneDettaglioRisposta)risposta).setEsitoConsegna(transazioneDB.getCodiceRispostaUscita());
  526.                 ((TransazioneDettaglioRisposta)risposta).setEsitoRicezione(transazioneDB.getCodiceRispostaIngresso());
  527.             }
  528.             if(this.messaggi_contenuti) {
  529.                 if(TransazioneRuoloEnum.FRUIZIONE.equals(ruoloTraccia)){
  530.                     ((TransazioneDettaglioRisposta)risposta).setContenuti(
  531.                             (TransazioneContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  532.                                     TipoMessaggio.RISPOSTA_INGRESSO, TipoMessaggio.RISPOSTA_INGRESSO_DUMP_BINARIO ,false));
  533.                 }
  534.                 else {
  535.                     ((TransazioneDettaglioRisposta)risposta).setContenuti(
  536.                             (TransazioneContenutoMessaggio) newTransazioneContenutoMessaggio(transazioneDB, 
  537.                                     TipoMessaggio.RISPOSTA_USCITA, TipoMessaggio.RISPOSTA_USCITA_DUMP_BINARIO ,false));
  538.                 }
  539.             }
  540.             if(this.risposta_fault) {
  541.                 if(TransazioneRuoloEnum.FRUIZIONE.equals(ruoloTraccia)){
  542.                     if(transazioneDB.getFaultCooperazione()!=null) {
  543.                         ((TransazioneDettaglioRisposta)risposta).setFaultRicezione(transazioneDB.getFaultCooperazione().getBytes());
  544.                     }
  545.                     if(transazioneDB.getFaultIntegrazione()!=null) {
  546.                         ((TransazioneDettaglioRisposta)risposta).setFaultConsegna(transazioneDB.getFaultIntegrazione().getBytes());
  547.                     }
  548.                 }
  549.                 else {
  550.                     if(transazioneDB.getFaultCooperazione()!=null) {
  551.                         ((TransazioneDettaglioRisposta)risposta).setFaultConsegna(transazioneDB.getFaultCooperazione().getBytes());
  552.                     }
  553.                     if(transazioneDB.getFaultIntegrazione()!=null) {
  554.                         ((TransazioneDettaglioRisposta)risposta).setFaultRicezione(transazioneDB.getFaultIntegrazione().getBytes());
  555.                     }
  556.                 }
  557.             }
  558.             if(this.risposta_errori && !errori.isEmpty()) {
  559.                 ((TransazioneDettaglioRisposta)risposta).setDettagliErrore(new ArrayList<>());
  560.                 for (String errore : errori) {
  561.                     ((TransazioneDettaglioRisposta)risposta).getDettagliErrore().add(errore);
  562.                 }
  563.             }
  564.             ((Transazione)transazione).setRisposta(((TransazioneDettaglioRisposta)risposta));
  565.         }
  566.         
  567.         
  568.         
  569.         TransazioneInformazioniApi api = null;
  570.         if(extended) {
  571.             api = new TransazioneExtInformazioniApi();
  572.         }
  573.         else {
  574.             api = new TransazioneInformazioniApi();
  575.         }
  576.         if(extended) {
  577.             if(this.api_erogatoreExtraInfo) {
  578.                 if(transazioneDB.getNomeSoggettoErogatore()!=null && transazioneDB.getTipoSoggettoErogatore()!=null) {
  579.                     String idPorta = transazioneDB.getIdportaSoggettoErogatore();
  580.                     if(idPorta==null || "".equals(idPorta)) {
  581.                         idPorta = protocolFactory.createTraduttore().getIdentificativoPortaDefault(new IDSoggetto(transazioneDB.getTipoSoggettoErogatore(), transazioneDB.getNomeSoggettoErogatore()));
  582.                     }
  583.                     ((TransazioneExtInformazioniApi)api).setInformazioniErogatore(_newTransazioneSoggetto(transazioneDB.getTipoSoggettoErogatore(), 
  584.                             idPorta, transazioneDB.getIndirizzoSoggettoErogatore()));
  585.                 }
  586.             }
  587.             if(this.api_tipo) {
  588.                 ((TransazioneExtInformazioniApi)api).setTipo(transazioneDB.getTipoServizio());
  589.             }
  590.         }
  591.         if(this.api_erogatore) {
  592.             api.setErogatore(transazioneDB.getNomeSoggettoErogatore());
  593.         }
  594.         if(this.api_tags) {
  595.             if(transazioneDB.getGruppi()!=null && !"".equals(transazioneDB.getGruppi())) {
  596.                 String [] tmp = transazioneDB.getGruppi().split(",");
  597.                 if(tmp!=null && tmp.length>0) {
  598.                     ((TransazioneExtInformazioniApi)api).setTags(new ArrayList<>());
  599.                     for (String tag : tmp) {
  600.                         if(tag!=null && !"".equals(tag.trim())) {
  601.                             ((TransazioneExtInformazioniApi)api).addTagsItem(tag.trim());
  602.                         }
  603.                     }
  604.                 }
  605.             }
  606.         }
  607.         if(this.api_nome) {
  608.             api.setNome(transazioneDB.getNomeServizio());
  609.         }
  610.         if(this.api_versione) {
  611.             api.setVersione(transazioneDB.getVersioneServizio());
  612.         }
  613.         if(this.api_operazione) {
  614.             api.setOperazione(transazioneDB.getAzione());
  615.         }
  616.         if(extended) {
  617.             if(this.api_idAsincrono) {
  618.                 ((TransazioneExtInformazioniApi)api).setIdAsincrono(transazioneDB.getIdAsincrono());
  619.             }
  620.             if(this.api_profiloCollaborazione && transazioneDB.getProfiloCollaborazioneOp2()!=null) {
  621.                 ProfiloDiCollaborazione prof = ProfiloDiCollaborazione.toProfiloDiCollaborazione(transazioneDB.getProfiloCollaborazioneOp2());
  622.                 if(prof!=null) {
  623.                     switch (prof) {
  624.                     case ONEWAY:
  625.                         ((TransazioneExtInformazioniApi)api).setProfiloCollaborazione(ProfiloCollaborazioneEnum.ONEWAY);        
  626.                         break;
  627.                     case SINCRONO:
  628.                         ((TransazioneExtInformazioniApi)api).setProfiloCollaborazione(ProfiloCollaborazioneEnum.SINCRONO);      
  629.                         break;
  630.                     case ASINCRONO_SIMMETRICO:
  631.                         ((TransazioneExtInformazioniApi)api).setProfiloCollaborazione(ProfiloCollaborazioneEnum.ASINCRONOSIMMETRICO);       
  632.                         break;
  633.                     case ASINCRONO_ASIMMETRICO:
  634.                         ((TransazioneExtInformazioniApi)api).setProfiloCollaborazione(ProfiloCollaborazioneEnum.ASINCRONOASIMMETRICO);      
  635.                         break;
  636.                     case UNKNOWN:
  637.                         break;
  638.                     }
  639.                 }
  640.             }
  641.             ((TransazioneExt)transazione).setApi(((TransazioneExtInformazioniApi)api));
  642.         }
  643.         else {
  644.             ((Transazione)transazione).setApi(api);
  645.         }
  646.         
  647.         TransazioneInformazioniMittente mittente = null;
  648.         if(extended) {
  649.             mittente = new TransazioneExtInformazioniMittente();
  650.         }
  651.         else {
  652.             mittente = new TransazioneInformazioniMittente();
  653.         }
  654.         if(extended) {
  655.             if(this.mittente_fruitoreExtraInfo) {
  656.                 if(transazioneDB.getNomeSoggettoFruitore()!=null && transazioneDB.getTipoSoggettoFruitore()!=null) {
  657.                     String idPorta = transazioneDB.getIdportaSoggettoFruitore();
  658.                     if(idPorta==null || "".equals(idPorta)) {
  659.                         idPorta = protocolFactory.createTraduttore().getIdentificativoPortaDefault(new IDSoggetto(transazioneDB.getTipoSoggettoFruitore(), transazioneDB.getNomeSoggettoFruitore()));
  660.                     }
  661.                     ((TransazioneExtInformazioniMittente)mittente).setInformazioniFruitore(_newTransazioneSoggetto(transazioneDB.getTipoSoggettoFruitore(), 
  662.                             idPorta, transazioneDB.getIndirizzoSoggettoFruitore()));
  663.                 }
  664.             }
  665.             if(this.mittente_applicativo) {
  666.                 ((TransazioneExtInformazioniMittente)mittente).setApplicativo(transazioneDB.getServizioApplicativoFruitore());
  667.             }
  668.             if(this.mittente_credenziali) {
  669.                 ((TransazioneExtInformazioniMittente)mittente).setCredenziali(transazioneDB.getCredenziali());
  670.             }
  671.             if(this.mittente_applicativoToken && credenzialiMittente!=null && credenzialiMittente.getTokenClientId()!=null) {
  672.                 IDServizioApplicativo idSA = CredenzialeTokenClient.convertApplicationDBValueToOriginal(credenzialiMittente.getTokenClientId().getCredenziale());
  673.                 if(idSA!=null) {
  674.                     ((TransazioneExtInformazioniMittente)mittente).setApplicativoToken(new TransazioneExtInformazioniMittenteApplicativoToken());
  675.                     ((TransazioneExtInformazioniMittente)mittente).getApplicativoToken().setNome(idSA.getNome());
  676.                     ((TransazioneExtInformazioniMittente)mittente).getApplicativoToken().setSoggetto(idSA.getIdSoggettoProprietario().getNome());
  677.                     String idPorta = protocolFactory.createTraduttore().getIdentificativoPortaDefault(new IDSoggetto(idSA.getIdSoggettoProprietario().getTipo(), idSA.getIdSoggettoProprietario().getNome()));
  678.                     ((TransazioneExtInformazioniMittente)mittente).getApplicativoToken().setInformazioniSoggetto(_newTransazioneSoggetto(idSA.getIdSoggettoProprietario().getTipo(), 
  679.                             idPorta, null));
  680.                 }
  681.             }
  682.         }
  683.         if(this.mittente_principal && credenzialiMittente!=null && credenzialiMittente.getTrasporto()!=null) {
  684.             mittente.setPrincipal(credenzialiMittente.getTrasporto().getCredenziale());
  685.         }
  686.         if(this.mittente_fruitore) {
  687.             mittente.setFruitore(transazioneDB.getNomeSoggettoFruitore());
  688.         }
  689.         if(this.mittente_utente && credenzialiMittente!=null && credenzialiMittente.getTokenUsername()!=null) {
  690.             mittente.setUtente(credenzialiMittente.getTokenUsername().getCredenziale());
  691.         }
  692.         if(this.mittente_client && credenzialiMittente!=null && credenzialiMittente.getTokenClientId()!=null) {
  693.             mittente.setClient(CredenzialeTokenClient.convertClientIdDBValueToOriginal(credenzialiMittente.getTokenClientId().getCredenziale()));
  694.         }
  695.         if(this.mittente_indirizzoClient) {
  696.             mittente.setIndirizzoClient(transazioneDB.getSocketClientAddress());
  697.         }
  698.         if(this.mittente_indirizzoClientInoltrato) {
  699.             mittente.setIndirizzoClientInoltrato(transazioneDB.getTransportClientAddress());
  700.         }
  701.         
  702.         if(extended) {
  703.             if((this.mittente_tokenClaims && credenzialiMittente!=null) || (this.mittente_token && transazioneDB.getTokenInfo()!=null)) {
  704.                 TransazioneExtInformazioniToken informazioniToken = new TransazioneExtInformazioniToken();
  705.                 boolean add = false;
  706.                 if(this.mittente_tokenClaims && credenzialiMittente!=null) {
  707.                     if(credenzialiMittente.getTokenClientId()!=null) {
  708.                         informazioniToken.setClientId(CredenzialeTokenClient.convertClientIdDBValueToOriginal(credenzialiMittente.getTokenClientId().getCredenziale()));
  709.                         add=true;
  710.                     }
  711.                     if(credenzialiMittente.getTokenIssuer()!=null) {
  712.                         informazioniToken.setIssuer(credenzialiMittente.getTokenIssuer().getCredenziale());
  713.                         add=true;
  714.                     }
  715.                     if(credenzialiMittente.getTokenSubject()!=null) {
  716.                         informazioniToken.setSubject(credenzialiMittente.getTokenSubject().getCredenziale());
  717.                         add=true;
  718.                     }
  719.                     if(credenzialiMittente.getTokenUsername()!=null) {
  720.                         informazioniToken.setUsername(credenzialiMittente.getTokenUsername().getCredenziale());
  721.                         add=true;
  722.                     }
  723.                     if(credenzialiMittente.getTokenEMail()!=null) {
  724.                         informazioniToken.setMail(credenzialiMittente.getTokenEMail().getCredenziale());
  725.                         add=true;
  726.                     }
  727.                 }
  728.                 if (transazioneDB.getTokenPurposeId() != null) {
  729.                     informazioniToken.setPurposeId(transazioneDB.getTokenPurposeId());
  730.                     add=true;
  731.                 }
  732.                 if (transazioneDB.getTokenId() != null) {
  733.                     informazioniToken.setTokenId(transazioneDB.getTokenId());
  734.                     add=true;
  735.                 }
  736.                 if(add) {
  737.                     ((TransazioneExtInformazioniMittente)mittente).setInformazioniToken(informazioniToken);
  738.                 }
  739.                 if(this.mittente_token && transazioneDB.getTokenInfo()!=null) {
  740.                     ((TransazioneExtInformazioniMittente)mittente).setToken(transazioneDB.getTokenInfo().getBytes());
  741.                 }
  742.             }
  743.             ((TransazioneExt)transazione).setMittente((TransazioneExtInformazioniMittente)mittente);
  744.         }
  745.         else {
  746.             ((Transazione)transazione).setMittente(mittente);
  747.         }
  748.         
  749.         if(extended) {
  750.         
  751.             if(messaggiDiagnostici!=null && messaggiDiagnostici.size()>0) {
  752.             
  753.                 ((TransazioneExt)transazione).setDiagnostici(new ArrayList<>());
  754.                 
  755.                 for (MsgDiagnostico msgDiag : messaggiDiagnostici) {
  756.                     Diagnostico diag = new Diagnostico();
  757.                     diag.setCodice(msgDiag.getCodice());
  758.                     diag.setData(new DateTime(msgDiag.getGdo().getTime()));
  759.                     diag.setFunzione(msgDiag.getIdFunzione());
  760.                     diag.setMessaggio(msgDiag.getMessaggio());
  761.                     DiagnosticoSeveritaEnum severita = null;
  762.                     if(LogLevels.SEVERITA_FATAL == msgDiag.getSeverita()) {
  763.                         severita = DiagnosticoSeveritaEnum.FATAL;
  764.                     }
  765.                     else if(LogLevels.SEVERITA_ERROR_INTEGRATION == msgDiag.getSeverita() || LogLevels.SEVERITA_ERROR_PROTOCOL == msgDiag.getSeverita()) {
  766.                         severita = DiagnosticoSeveritaEnum.ERROR;
  767.                     }
  768.                     else if(LogLevels.SEVERITA_INFO_INTEGRATION == msgDiag.getSeverita() || LogLevels.SEVERITA_INFO_PROTOCOL == msgDiag.getSeverita()) {
  769.                         severita = DiagnosticoSeveritaEnum.INFO;
  770.                     }
  771.                     else if(LogLevels.SEVERITA_DEBUG_LOW == msgDiag.getSeverita() || LogLevels.SEVERITA_DEBUG_MEDIUM == msgDiag.getSeverita()) {
  772.                         severita = DiagnosticoSeveritaEnum.DEBUG;
  773.                     }
  774.                     else {
  775.                         severita = DiagnosticoSeveritaEnum.TRACE;
  776.                     }
  777.                     diag.setSeverita(severita);
  778.                     diag.setSeveritaCodice(msgDiag.getCodice());
  779.                     ((TransazioneExt)transazione).getDiagnostici().add(diag);
  780.                 }
  781.             
  782.             }
  783.             
  784.         }
  785.         
  786.         return transazione;

  788.     }
  789.     
  790.     private String normalizeUrl(String url) {
  791.         if(url!=null) {
  792.             if(url.startsWith("[") && url.contains("] ") && !url.endsWith("] ")) {
  793.                 return url.substring(url.indexOf("] ")+2);
  794.             }
  795.         }
  796.         return url;
  797.     }
  798.     
  799.     private TransazioneExtInformazioniSoggetto _newTransazioneSoggetto(String tipo, String codice, String indirizzo) {
  800.         TransazioneExtInformazioniSoggetto soggetto = new TransazioneExtInformazioniSoggetto();
  801.         soggetto.setTipo(tipo);
  802.         soggetto.setCodice(codice);
  803.         soggetto.setIndirizzo(indirizzo);
  804.         return soggetto;
  805.     }
  806.     
  807.     private TransazioneContenutoMessaggio newTransazioneContenutoMessaggio(org.openspcoop2.core.transazioni.Transazione transazioneDB, 
  808.             TipoMessaggio tipoMessaggioNormale, TipoMessaggio tipoMessaggioBinario, boolean extended) {
  809.         
  810.         DumpMessaggio dumpMessaggio = null;
  811.         if(transazioneDB.sizeDumpMessaggioList()>0) {
  812.             for (DumpMessaggio check : transazioneDB.getDumpMessaggioList()) {
  813.                 if(tipoMessaggioBinario.equals(check.getTipoMessaggio())) {
  814.                     dumpMessaggio = check;
  815.                     break;
  816.                 }
  817.             }
  818.             if(dumpMessaggio==null) {
  819.                 for (DumpMessaggio check : transazioneDB.getDumpMessaggioList()) {
  820.                     if(tipoMessaggioNormale.equals(check.getTipoMessaggio())) {
  821.                         dumpMessaggio = check;
  822.                         break;
  823.                     }
  824.                 }
  825.             }
  826.         }
  827.         if(dumpMessaggio==null) {
  828.             return null;
  829.         }       
  830.         
  831.         TransazioneContenutoMessaggio msg = null;
  832.         if(extended) {
  833.             msg = new TransazioneExtContenutoMessaggio();
  834.         }
  835.         else {
  836.             msg = new TransazioneContenutoMessaggio();
  837.         }
  838.         
  839.         msg.setBody(dumpMessaggio.getBody());
  840.         
  841.         if(dumpMessaggio.sizeHeaderTrasportoList()>0) {
  842.             msg.setHeaders(new ArrayList<>());
  843.             for (DumpHeaderTrasporto dumpHeaderTrasporto : dumpMessaggio.getHeaderTrasportoList()) {
  844.                 TransazioneContenutoMessaggioHeader hdr = new TransazioneContenutoMessaggioHeader();
  845.                 hdr.setNome(dumpHeaderTrasporto.getNome());
  846.                 hdr.setValore(dumpHeaderTrasporto.getValore());
  847.                 msg.getHeaders().add(hdr);
  848.             }
  849.         }
  850.         
  851.         if(extended) {
  852.             TransazioneExtContenutoMessaggioBody body = new TransazioneExtContenutoMessaggioBody();
  853.             body.setFormato(_convert(dumpMessaggio.getFormatoMessaggio()));
  854.             body.setContentType(dumpMessaggio.getContentType());
  855.             body.setContentLength(dumpMessaggio.getContentLength());
  856.             if(dumpMessaggio.getMultipartContentId()!=null || 
  857.                     dumpMessaggio.getMultipartContentLocation()!=null ||
  858.                     dumpMessaggio.getMultipartContentType()!=null ||
  859.                     dumpMessaggio.sizeMultipartHeaderList()>0) {
  860.                 TransazioneExtContenutoMessaggioBodyMultipart multipart = new TransazioneExtContenutoMessaggioBodyMultipart();
  861.                 multipart.setContentId(dumpMessaggio.getMultipartContentId());
  862.                 multipart.setContentType(dumpMessaggio.getMultipartContentType());
  863.                 multipart.setContentLocation(dumpMessaggio.getMultipartContentLocation());
  864.                 if(dumpMessaggio.sizeMultipartHeaderList()>0) {
  865.                     multipart.setHeaders(new ArrayList<>());
  866.                     for (DumpMultipartHeader dumpHeaderTrasporto : dumpMessaggio.getMultipartHeaderList()) {
  867.                         TransazioneContenutoMessaggioHeader hdr = new TransazioneContenutoMessaggioHeader();
  868.                         hdr.setNome(dumpHeaderTrasporto.getNome());
  869.                         hdr.setValore(dumpHeaderTrasporto.getValore());
  870.                         multipart.getHeaders().add(hdr);
  871.                     }
  872.                 }
  873.                 body.setMultipart(multipart);
  874.             }
  875.             if(dumpMessaggio.sizeContenutoList()>0) {
  876.                 body.setContenutiBody(new ArrayList<>());
  877.                 for (DumpContenuto contenuto : dumpMessaggio.getContenutoList()) {
  878.                     TransazioneExtContenutoMessaggioPorzioneBody r = new TransazioneExtContenutoMessaggioPorzioneBody();
  879.                     r.setNome(contenuto.getNome());
  880.                     r.setValore(contenuto.getValore());
  881.                     body.getContenutiBody().add(r);     
  882.                 }
  883.             }
  884.             ((TransazioneExtContenutoMessaggio)msg).setInformazioniBody(body);

  886.             if(dumpMessaggio.sizeAllegatoList()>0) {
  887.                 ((TransazioneExtContenutoMessaggio)msg).setAttachments(new ArrayList<>());
  888.                 for (DumpAllegato dumpAllegato : dumpMessaggio.getAllegatoList()) {
  889.                     TransazioneExtContenutoMessaggioAllegato attach = new TransazioneExtContenutoMessaggioAllegato();
  890.                     attach.setContentId(dumpAllegato.getContentId());
  891.                     attach.setContentType(dumpAllegato.getContentType());
  892.                     attach.setContentLocation(dumpAllegato.getContentLocation());
  893.                     attach.setContenuto(dumpAllegato.getAllegato());
  894.                     if(dumpAllegato.sizeHeaderList()>0) {
  895.                         dumpAllegato.setHeaderList(new ArrayList<>());
  896.                         for (DumpHeaderAllegato dumpHeaderAllegato : dumpAllegato.getHeaderList()) {
  897.                             TransazioneContenutoMessaggioHeader hdr = new TransazioneContenutoMessaggioHeader();
  898.                             hdr.setNome(dumpHeaderAllegato.getNome());
  899.                             hdr.setValore(dumpHeaderAllegato.getValore());
  900.                             attach.getHeaders().add(hdr);
  901.                         }
  902.                     }
  903.                     ((TransazioneExtContenutoMessaggio)msg).getAttachments().add(attach);
  904.                 }
  905.             }
  906.         }
  907.         

  909.         
  910.         return msg;
  911.     }
  912.     
  913.     private TransazioneMessaggioFormatoEnum _convert(String formato) {
  914.         if(formato==null) {
  915.             return null;
  916.         }
  917.         MessageType tipoMessaggio = null;
  918.         try {
  919.             tipoMessaggio = MessageType.valueOf(formato);
  920.         }catch(Throwable t) {}
  921.         if(tipoMessaggio==null) {
  922.             return null;
  923.         }
  924.         switch (tipoMessaggio) {
  925.         case SOAP_11:
  926.             return TransazioneMessaggioFormatoEnum.SOAP11;
  927.         case SOAP_12:
  928.             return TransazioneMessaggioFormatoEnum.SOAP12;
  929.         case JSON:
  930.             return TransazioneMessaggioFormatoEnum.JSON;
  931.         case XML:
  932.             return TransazioneMessaggioFormatoEnum.XML;
  933.         case BINARY:
  934.             return TransazioneMessaggioFormatoEnum.BINARY;
  935.         case MIME_MULTIPART:
  936.             return TransazioneMessaggioFormatoEnum.MULTIPART;
  937.         }
  938.         return null;
  939.     }
  940.     
  941.     
  942.     
  943.     // SETTER
  944.     
  945.     public void setLog(Logger log) {
  946.         this.log = log;
  947.     }


  950.     public void setThrowInitProtocol(boolean throwInitProtocol) {
  951.         this.throwInitProtocol = throwInitProtocol;
  952.     }


  955.     public void setEmittente(boolean emittente) {
  956.         this.emittente = emittente;
  957.     }


  960.     public void setDataEmissione(boolean dataEmissione) {
  961.         this.dataEmissione = dataEmissione;
  962.     }


  965.     public void setId(boolean id) {
  966.         this.id = id;
  967.     }


  970.     public void setIdConversazione(boolean idConversazione) {
  971.         this.idConversazione = idConversazione;
  972.     }


  975.     public void setRuolo(boolean ruolo) {
  976.         this.ruolo = ruolo;
  977.     }


  980.     public void setEsito(boolean esito) {
  981.         this.esito = esito;
  982.     }


  985.     public void setMessaggi_id(boolean messaggi_id) {
  986.         this.messaggi_id = messaggi_id;
  987.     }


  990.     public void setMessaggi_idApplicativo(boolean messaggi_idApplicativo) {
  991.         this.messaggi_idApplicativo = messaggi_idApplicativo;
  992.     }


  995.     public void setMessaggi_data(boolean messaggi_data) {
  996.         this.messaggi_data = messaggi_data;
  997.     }


  1000.     public void setMessaggi_contenuti(boolean messaggi_contenuti) {
  1001.         this.messaggi_contenuti = messaggi_contenuti;
  1002.     }


  1005.     public void setRichiesta_tipo(boolean richiesta_tipo) {
  1006.         this.richiesta_tipo = richiesta_tipo;
  1007.     }


  1010.     public void setRichiesta_urlInvocazione(boolean richiesta_urlInvocazione) {
  1011.         this.richiesta_urlInvocazione = richiesta_urlInvocazione;
  1012.     }


  1015.     public void setRisposta_esito(boolean risposta_esito) {
  1016.         this.risposta_esito = risposta_esito;
  1017.     }


  1020.     public void setRisposta_fault(boolean risposta_fault) {
  1021.         this.risposta_fault = risposta_fault;
  1022.     }


  1025.     public void setRisposta_errori(boolean risposta_errori) {
  1026.         this.risposta_errori = risposta_errori;
  1027.     }


  1030.     public void setApi_erogatore(boolean api_erogatore) {
  1031.         this.api_erogatore = api_erogatore;
  1032.     }


  1035.     public void setApi_nome(boolean api_nome) {
  1036.         this.api_nome = api_nome;
  1037.     }


  1040.     public void setApi_versione(boolean api_versione) {
  1041.         this.api_versione = api_versione;
  1042.     }


  1045.     public void setApi_operazione(boolean api_operazione) {
  1046.         this.api_operazione = api_operazione;
  1047.     }


  1050.     public void setMittente_fruitore(boolean mittente_fruitore) {
  1051.         this.mittente_fruitore = mittente_fruitore;
  1052.     }


  1055.     public void setMittente_principal(boolean mittente_principal) {
  1056.         this.mittente_principal = mittente_principal;
  1057.     }

  1059.     
  1060.     public void setMittente_utente(boolean mittente_utente) {
  1061.         this.mittente_utente = mittente_utente;
  1062.     }
  1063.     
  1064.     
  1065.     public void setMittente_client(boolean mittente_client) {
  1066.         this.mittente_client = mittente_client;
  1067.     }
  1068.     

  1070.     public void setMittente_indirizzoClient(boolean mittente_indirizzoClient) {
  1071.         this.mittente_indirizzoClient = mittente_indirizzoClient;
  1072.     }


  1075.     public void setMittente_indirizzoClientInoltrato(boolean mittente_indirizzoClientInoltrato) {
  1076.         this.mittente_indirizzoClientInoltrato = mittente_indirizzoClientInoltrato;
  1077.     }


  1080.     public void setProfilo(boolean profilo) {
  1081.         this.profilo = profilo;
  1082.     }


  1085.     public void setContesto(boolean contesto) {
  1086.         this.contesto = contesto;
  1087.     }


  1090.     public void setIdCluster(boolean idCluster) {
  1091.         this.idCluster = idCluster;
  1092.     }


  1095.     public void setEmittenteExtraInfo(boolean emittenteExtraInfo) {
  1096.         this.emittenteExtraInfo = emittenteExtraInfo;
  1097.     }


  1100.     public void setStato(boolean stato) {
  1101.         this.stato = stato;
  1102.     }


  1105.     public void setMessaggi_dimensione(boolean messaggi_dimensione) {
  1106.         this.messaggi_dimensione = messaggi_dimensione;
  1107.     }


  1110.     public void setMessaggi_dataAccettazione(boolean messaggi_dataAccettazione) {
  1111.         this.messaggi_dataAccettazione = messaggi_dataAccettazione;
  1112.     }


  1115.     public void setMessaggi_duplicati(boolean messaggi_duplicati) {
  1116.         this.messaggi_duplicati = messaggi_duplicati;
  1117.     }


  1120.     public void setMessaggi_tracciaProtocollo(boolean messaggi_tracciaProtocollo) {
  1121.         this.messaggi_tracciaProtocollo = messaggi_tracciaProtocollo;
  1122.     }


  1125.     public void setRichiesta_connettore(boolean richiesta_connettore) {
  1126.         this.richiesta_connettore = richiesta_connettore;
  1127.     }


  1130.     public void setDiagnostici(boolean diagnostici) {
  1131.         this.diagnostici = diagnostici;
  1132.     }


  1135.     public void setApi_erogatoreExtraInfo(boolean api_erogatoreExtraInfo) {
  1136.         this.api_erogatoreExtraInfo = api_erogatoreExtraInfo;
  1137.     }

  1139.     public void setApi_tags(boolean api_tags) {
  1140.         this.api_tags = api_tags;
  1141.     }

  1143.     public void setApi_tipo(boolean api_tipo) {
  1144.         this.api_tipo = api_tipo;
  1145.     }


  1148.     public void setApi_idAsincrono(boolean api_idAsincrono) {
  1149.         this.api_idAsincrono = api_idAsincrono;
  1150.     }


  1153.     public void setApi_profiloCollaborazione(boolean api_profiloCollaborazione) {
  1154.         this.api_profiloCollaborazione = api_profiloCollaborazione;
  1155.     }


  1158.     public void setMittente_fruitoreExtraInfo(boolean mittente_fruitoreExtraInfo) {
  1159.         this.mittente_fruitoreExtraInfo = mittente_fruitoreExtraInfo;
  1160.     }


  1163.     public void setMittente_applicativo(boolean mittente_applicativo) {
  1164.         this.mittente_applicativo = mittente_applicativo;
  1165.     }


  1168.     public void setMittente_credenziali(boolean mittente_credenziali) {
  1169.         this.mittente_credenziali = mittente_credenziali;
  1170.     }


  1173.     public void setMittente_token(boolean mittente_token) {
  1174.         this.mittente_token = mittente_token;
  1175.     }


  1178.     public void setMittente_tokenClaims(boolean mittente_tokenClaims) {
  1179.         this.mittente_tokenClaims = mittente_tokenClaims;
  1180.     }
  1181. }
Created with JaCoCo 0.8.8.202204050719