TransactionDriverTracciamento.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;


  24. import java.sql.Connection;
  25. import java.sql.DriverManager;
  26. import java.sql.SQLException;
  27. import java.sql.Timestamp;
  28. import java.util.ArrayList;
  29. import java.util.Date;
  30. import java.util.HashMap;
  31. import java.util.List;
  32. import java.util.Map;
  33. import java.util.Properties;

  35. import javax.naming.InitialContext;
  36. import javax.sql.DataSource;

  38. import org.apache.commons.lang.StringUtils;
  39. import org.openspcoop2.core.commons.CoreException;
  40. import org.openspcoop2.core.commons.dao.DAOFactory;
  41. import org.openspcoop2.core.constants.CostantiDB;
  42. import org.openspcoop2.core.constants.TipoPdD;
  43. import org.openspcoop2.core.id.IDServizioApplicativo;
  44. import org.openspcoop2.core.id.IDSoggetto;
  45. import org.openspcoop2.core.transazioni.CredenzialeMittente;
  46. import org.openspcoop2.core.transazioni.Transazione;
  47. import org.openspcoop2.core.transazioni.dao.IDBCredenzialeMittenteServiceSearch;
  48. import org.openspcoop2.core.transazioni.dao.ITransazioneServiceSearch;
  49. import org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager;
  50. import org.openspcoop2.core.transazioni.utils.CredenzialiMittente;
  51. import org.openspcoop2.core.transazioni.utils.ProjectInfo;
  52. import org.openspcoop2.core.transazioni.utils.PropertiesSerializator;
  53. import org.openspcoop2.core.transazioni.utils.credenziali.CredenzialeTokenClient;
  54. import org.openspcoop2.generic_project.beans.IField;
  55. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  56. import org.openspcoop2.generic_project.exception.ExpressionException;
  57. import org.openspcoop2.generic_project.exception.ExpressionNotImplementedException;
  58. import org.openspcoop2.generic_project.exception.MultipleResultException;
  59. import org.openspcoop2.generic_project.exception.NotFoundException;
  60. import org.openspcoop2.generic_project.exception.NotImplementedException;
  61. import org.openspcoop2.generic_project.exception.ServiceException;
  62. import org.openspcoop2.generic_project.expression.IExpression;
  63. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  64. import org.openspcoop2.generic_project.expression.SortOrder;
  65. import org.openspcoop2.pdd.core.transazioni.DateUtility;
  66. import org.openspcoop2.pdd.logger.record.AbstractDatoRicostruzione;
  67. import org.openspcoop2.pdd.logger.traccia.CostantiMappingTracciamento;
  68. import org.openspcoop2.pdd.logger.traccia.InformazioniRecordTraccia;
  69. import org.openspcoop2.pdd.logger.traccia.MappingRicostruzioneTraccia;
  70. import org.openspcoop2.pdd.logger.traccia.PopolamentoTracciaUtils;
  71. import org.openspcoop2.protocol.basic.BasicComponentFactory;
  72. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  73. import org.openspcoop2.protocol.sdk.Busta;
  74. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  75. import org.openspcoop2.protocol.sdk.ProtocolException;
  76. import org.openspcoop2.protocol.sdk.Riscontro;
  77. import org.openspcoop2.protocol.sdk.Trasmissione;
  78. import org.openspcoop2.protocol.sdk.builder.IBustaBuilder;
  79. import org.openspcoop2.protocol.sdk.constants.EsitoElaborazioneMessaggioTracciatura;
  80. import org.openspcoop2.protocol.sdk.constants.Inoltro;
  81. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  82. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  83. import org.openspcoop2.protocol.sdk.constants.TipoOraRegistrazione;
  84. import org.openspcoop2.protocol.sdk.tracciamento.DriverTracciamentoException;
  85. import org.openspcoop2.protocol.sdk.tracciamento.DriverTracciamentoNotFoundException;
  86. import org.openspcoop2.protocol.sdk.tracciamento.EsitoElaborazioneMessaggioTracciato;
  87. import org.openspcoop2.protocol.sdk.tracciamento.FiltroRicercaTracce;
  88. import org.openspcoop2.protocol.sdk.tracciamento.FiltroRicercaTracceConPaginazione;
  89. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaDriver;
  90. import org.openspcoop2.protocol.sdk.tracciamento.InformazioniProtocollo;
  91. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  92. import org.openspcoop2.utils.LoggerWrapperFactory;
  93. import org.openspcoop2.utils.TipiDatabase;
  94. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  95. import org.slf4j.Logger;

  97. /**     
  98.  * TransactionDriverTracciamento
  99.  *
  100.  * @author Poli Andrea (poli@link.it)
  101.  * @author $Author$
  102.  * @version $Rev$, $Date$
  103.  */
  104. public class TransactionDriverTracciamento implements ITracciaDriver {

  106.     private static final String TIPO_DB_NON_GESTITO = "Tipo database non gestito";
  107.     private static final String NON_IMPLEMENTATO = "Metodo non implementato";


  110.     /** 
  111.      * DataSource
  112.      */
  113.     DataSource datasource = null;
  114.     
  115.     /** 
  116.      * Connessione
  117.      */
  118.     Connection connection = null;
  119.     boolean connectionOpenViaJDBCInCostructor = false;

  121.     /**
  122.      * SQLQueryObject
  123.      */
  124.     String tipoDatabase = null;

  126.     /** Driver Tracciamento originale */
  127.     DriverTracciamento driverTracciamento = null;

  129.     /** DAO Factory */
  130.     DAOFactory daoFactory = null;
  131.     
  132.     /** Logger utilizzato per info. */
  133.     private Logger log = null;
  134.     private void logDebug(String msg) {
  135.         if(this.log!=null) {
  136.             this.log.debug(msg);
  137.         }
  138.     }

  140.     public TransactionDriverTracciamento(String nomeDataSource, String tipoDatabase, Properties prop) throws DriverTracciamentoException {
  141.         this(nomeDataSource,tipoDatabase,prop,null);
  142.     }

  144.     public TransactionDriverTracciamento(String nomeDataSource, String tipoDatabase, Properties prop, Logger log) throws DriverTracciamentoException {
  145.         // Logger
  146.         try {
  147.             if(log==null)
  148.                 this.log = LoggerWrapperFactory.getLogger(org.openspcoop2.protocol.basic.Costanti.LOGANALIZER_DRIVER_DB_LOGGER);
  149.             else
  150.                 this.log = log;
  151.         } catch (Exception e) {
  152.             throw new DriverTracciamentoException("(ds jndiName) Errore durante l'inizializzazione del logger: "+e.getMessage(),e);
  153.         }

  155.         // Datasource
  156.         try {
  157.             InitialContext initCtx = new InitialContext(prop);
  158.             this.datasource = (DataSource) initCtx.lookup(nomeDataSource);
  159.             if (this.datasource == null)
  160.                 throw new DriverTracciamentoException ("datasource is null");

  162.             initCtx.close();
  163.         } catch (Exception e) {
  164.             throw new DriverTracciamentoException("(ds jndiName) Errore durante la ricerca del datasource: "+e.getMessage(),e);
  165.         }

  167.         // ISQLQueryObject
  168.         try {
  169.             if (TipiDatabase.isAMember(tipoDatabase)) {
  170.                 this.tipoDatabase = tipoDatabase;               
  171.             } else {
  172.                 throw new DriverTracciamentoException(TIPO_DB_NON_GESTITO);
  173.             }
  174.         } catch (Exception e) {
  175.             throw new DriverTracciamentoException("(ds jndiName) Errore durante la ricerca del SQLQueryObject: "+e.getMessage(),e);
  176.         }

  178.         // Driver tracciamento
  179.         try{
  180.             this.driverTracciamento = new DriverTracciamento(nomeDataSource, tipoDatabase, prop, log);
  181.         } catch (Exception e) {
  182.             throw new DriverTracciamentoException("(ds jndiName) Errore durante l'inizializzazione del driver delle tracce: "+e.getMessage(),e);
  183.         }
  184.         
  185.         // DAO Factory
  186.         try{
  187.             this.daoFactory = DAOFactory.getInstance(log);
  188.         }catch (Exception e) {
  189.             throw new DriverTracciamentoException("(ds jndiName) Errore durante l'inizializzazione del dao factory: "+e.getMessage(),e);
  190.         }
  191.     }
  192.     
  193.     public TransactionDriverTracciamento(DataSource dataSourceObject, String tipoDatabase) throws DriverTracciamentoException {
  194.         this(dataSourceObject,tipoDatabase,null);
  195.     }

  197.     public TransactionDriverTracciamento(DataSource dataSourceObject, String tipoDatabase, Logger log) throws DriverTracciamentoException {
  198.         // Logger
  199.         try {
  200.             if(log==null)
  201.                 this.log = LoggerWrapperFactory.getLogger(org.openspcoop2.protocol.basic.Costanti.LOGANALIZER_DRIVER_DB_LOGGER);
  202.             else
  203.                 this.log = log;
  204.         } catch (Exception e) {
  205.             throw new DriverTracciamentoException("(ds) Errore durante l'inizializzazione del logger: "+e.getMessage(),e);
  206.         }

  208.         // Datasource
  209.         try {
  210.             this.datasource = dataSourceObject;
  211.             if (this.datasource == null)
  212.                 throw new DriverTracciamentoException ("datasource is null");
  213.         } catch (Exception e) {
  214.             throw new DriverTracciamentoException("(ds) Errore durante la ricerca del datasource: "+e.getMessage(),e);
  215.         }

  217.         // ISQLQueryObject
  218.         try {
  219.             if (TipiDatabase.isAMember(tipoDatabase)) {
  220.                 this.tipoDatabase = tipoDatabase;               
  221.             } else {
  222.                 throw new DriverTracciamentoException(TIPO_DB_NON_GESTITO);
  223.             }
  224.         } catch (Exception e) {
  225.             throw new DriverTracciamentoException("(ds) Errore durante la ricerca del SQLQueryObject: "+e.getMessage(),e);
  226.         }

  228.         // Driver tracciamento
  229.         try{
  230.             this.driverTracciamento = new DriverTracciamento(this.datasource, tipoDatabase, log);
  231.         } catch (Exception e) {
  232.             throw new DriverTracciamentoException("(ds) Errore durante l'inizializzazione del driver delle tracce: "+e.getMessage(),e);
  233.         }   
  234.         
  235.         // DAO Factory
  236.         try{
  237.             this.daoFactory = DAOFactory.getInstance(log);
  238.         }catch (Exception e) {
  239.             throw new DriverTracciamentoException("(ds) Errore durante l'inizializzazione del dao factory: "+e.getMessage(),e);
  240.         }
  241.     }
  242.     
  243.     
  244.     public TransactionDriverTracciamento(Connection connection, String tipoDatabase) throws DriverTracciamentoException {
  245.         this(connection,tipoDatabase,null);
  246.     }

  248.     public TransactionDriverTracciamento(Connection connection, String tipoDatabase, Logger log) throws DriverTracciamentoException {
  249.         // Logger
  250.         try {
  251.             if(log==null)
  252.                 this.log = LoggerWrapperFactory.getLogger(org.openspcoop2.protocol.basic.Costanti.LOGANALIZER_DRIVER_DB_LOGGER);
  253.             else
  254.                 this.log = log;
  255.         } catch (Exception e) {
  256.             throw new DriverTracciamentoException("(connection) Errore durante l'inizializzazione del logger: "+e.getMessage(),e);
  257.         }

  259.         // connection
  260.         this.connection = connection;

  262.         // ISQLQueryObject
  263.         try {
  264.             if (TipiDatabase.isAMember(tipoDatabase)) {
  265.                 this.tipoDatabase = tipoDatabase;               
  266.             } else {
  267.                 throw new DriverTracciamentoException(TIPO_DB_NON_GESTITO);
  268.             }
  269.         } catch (Exception e) {
  270.             throw new DriverTracciamentoException("(connection) Errore durante la ricerca del SQLQueryObject: "+e.getMessage(),e);
  271.         }

  273.         // Driver tracciamento
  274.         try{
  275.             this.driverTracciamento = new DriverTracciamento(this.connection, tipoDatabase, log);
  276.         } catch (Exception e) {
  277.             throw new DriverTracciamentoException("(connection) Errore durante l'inizializzazione del driver delle tracce: "+e.getMessage(),e);
  278.         }   
  279.         
  280.         // DAO Factory
  281.         try{
  282.             this.daoFactory = DAOFactory.getInstance(log);
  283.         }catch (Exception e) {
  284.             throw new DriverTracciamentoException("(connection) Errore durante l'inizializzazione del dao factory: "+e.getMessage(),e);
  285.         }
  286.     }
  287.     
  288.     
  289.     public TransactionDriverTracciamento(String urlJDBC,String driverJDBC,
  290.             String username,String password, String tipoDatabase) throws DriverTracciamentoException {
  291.         this(urlJDBC,driverJDBC,username,password,tipoDatabase,null);
  292.     }

  294.     public TransactionDriverTracciamento(String urlJDBC,String driverJDBC,
  295.             String username,String password, String tipoDatabase, Logger log) throws DriverTracciamentoException {
  296.         // Logger
  297.         try {
  298.             if(log==null)
  299.                 this.log = LoggerWrapperFactory.getLogger(org.openspcoop2.protocol.basic.Costanti.LOGANALIZER_DRIVER_DB_LOGGER);
  300.             else
  301.                 this.log = log;
  302.         } catch (Exception e) {
  303.             throw new DriverTracciamentoException("(connection url) Errore durante l'inizializzazione del logger: "+e.getMessage(),e);
  304.         }

  306.         // connection
  307.         try {
  308.             Class.forName(driverJDBC);
  309.             
  310.             if(username!=null){
  311.                 this.connection = DriverManager.getConnection(urlJDBC,username,password);
  312.             }else{
  313.                 this.connection = DriverManager.getConnection(urlJDBC);
  314.             }
  315.             this.connectionOpenViaJDBCInCostructor = true;
  316.             
  317.         } catch (Exception e) {
  318.             throw new DriverTracciamentoException("(connection url) Errore durante l'inizializzazione della connessione: "+e.getMessage(),e);
  319.         }

  321.         // ISQLQueryObject
  322.         try {
  323.             if (TipiDatabase.isAMember(tipoDatabase)) {
  324.                 this.tipoDatabase = tipoDatabase;               
  325.             } else {
  326.                 throw new DriverTracciamentoException(TIPO_DB_NON_GESTITO);
  327.             }
  328.         } catch (Exception e) {
  329.             throw new DriverTracciamentoException("(connection url) Errore durante la ricerca del SQLQueryObject: "+e.getMessage(),e);
  330.         }

  332.         // Driver tracciamento
  333.         try{
  334.             this.driverTracciamento = new DriverTracciamento(this.connection, tipoDatabase, log);
  335.         } catch (Exception e) {
  336.             throw new DriverTracciamentoException("(connection url) Errore durante l'inizializzazione del driver delle tracce: "+e.getMessage(),e);
  337.         }   
  338.         
  339.         // DAO Factory
  340.         try{
  341.             this.daoFactory = DAOFactory.getInstance(log);
  342.         }catch (Exception e) {
  343.             throw new DriverTracciamentoException("(connection url) Errore durante l'inizializzazione del dao factory: "+e.getMessage(),e);
  344.         }
  345.     }
  346.     
  347.     
  348.     
  349.     @Override
  350.     public IProtocolFactory<?> getProtocolFactory() {
  351.         return null;
  352.     }

  354.     private Connection getConnection() throws SQLException {
  355.         Connection con = null;
  356.         if(this.connection!=null){
  357.             con = this.connection;
  358.         }else{
  359.             con = this.datasource.getConnection();
  360.         }
  361.         return  con;
  362.     }
  363.     private void checkConnection(Connection con) throws DriverTracciamentoException {
  364.         if(con==null)
  365.             throw new DriverTracciamentoException("Connection non ottenuta");
  366.     }
  367.     private void closeConnection(Connection con) {
  368.         if(this.connection==null){
  369.             try{
  370.                 JDBCUtilities.closeConnection(BasicComponentFactory.getCheckLogger(), con, BasicComponentFactory.isCheckAutocommit(), BasicComponentFactory.isCheckIsClosed());
  371.             }catch(Exception e){
  372.                 // close
  373.             }
  374.         }
  375.     }
  376.     
  377.     @Override
  378.     public int countTracce(FiltroRicercaTracce filtro)
  379.             throws DriverTracciamentoException {

  381.         Connection con = null;
  382.         JDBCServiceManager transazioniServiceManager = null;
  383.         long transazioniTrovate = 0;
  384.         try{
  385.             con = getConnection();
  386.             checkConnection(con);
  387.                         
  388.             transazioniServiceManager = 
  389.                     (JDBCServiceManager) this.daoFactory.getServiceManager(new ProjectInfo(), con, true);
  390.             
  391.             ITransazioneServiceSearch transazioneServiceSearch = transazioniServiceManager.getTransazioneServiceSearch();
  392.                         
  393.             IExpression expression = this.newExpressionEngine(transazioneServiceSearch, filtro);
  394.             NonNegativeNumber nn = transazioneServiceSearch.count(expression);
  395.             if(nn!=null){
  396.                 transazioniTrovate = nn.longValue();
  397.             }           
  398.         }catch(Exception e){
  399.             throw new DriverTracciamentoException("Riscontrato errore durante la lettura (count) dei dati (Filtro:"+filtro.toString()+"): "+e.getMessage(),e);
  400.         }finally{
  401.             try{
  402.                 if(transazioniServiceManager!=null) {
  403.                     transazioniServiceManager.close();
  404.                 }
  405.             }catch(Exception e){
  406.                 // close
  407.             }
  408.             closeConnection(con);
  409.         }
  410.             
  411.         int offset = 0;
  412.         int limit = 25;
  413.         int count = 0;
  414.         FiltroRicercaTracceConPaginazione filtroPaginato = new FiltroRicercaTracceConPaginazione(filtro);
  415.         filtroPaginato.setOffset(offset);
  416.         filtroPaginato.setLimit(limit);
  417.         List<Traccia> list = null;
  418.         try{
  419.             list = this.getTracceEngine(filtroPaginato);
  420.             while(offset<transazioniTrovate){
  421.                 count = count + list.size();
  422.                 offset = offset + limit; // analizzo 25 transazioni alla volta, le quali possono avere all'interno 0/1/2 tracce
  423.                 filtroPaginato.setOffset(offset);
  424.                 list = this.getTracceEngine(filtroPaginato);
  425.             }
  426.         }catch(DriverTracciamentoNotFoundException notFound){
  427.             // ignore
  428.         }
  429.         return count;
  430.     }

  432.     @Override
  433.     public List<Traccia> getTracce(FiltroRicercaTracceConPaginazione filtro)
  434.             throws DriverTracciamentoException,
  435.             DriverTracciamentoNotFoundException {
  436.         
  437.         if(filtro.getOffset()>0){
  438.             throw new DriverTracciamentoException("Metodo non implementato in questa versione (Offset >0 non è ricostruibile)");
  439.         }
  440.         
  441.         List<Traccia> list = this.getTracceEngine(filtro);
  442.         if(filtro.getLimit()>0 && list.size()>filtro.getLimit()){
  443.             List<Traccia> listWithFilter = new ArrayList<>();
  444.             for (int i = 0; i < 25; i++) {
  445.                 listWithFilter.add(list.get(i));
  446.             }
  447.             return listWithFilter;
  448.         }
  449.         else{
  450.             return list;
  451.         }
  452.     }
  453.     private void addTracciaSafe(List<Traccia> tracce, RuoloMessaggio ruolo, Connection con, Map<String, String> propertiesRicerca, FiltroRicercaTracceConPaginazione filtro) throws DriverTracciamentoException {
  454.         try{
  455.             tracce.add(this.getTracciaByPropertiesEngine(con, propertiesRicerca, ruolo,
  456.                     filtro.getMinDate(), filtro.getMaxDate()));
  457.         }catch(DriverTracciamentoNotFoundException dNotFound){
  458.             // ignore
  459.         }
  460.     }
  461.     private List<Traccia> getTracceEngine(FiltroRicercaTracceConPaginazione filtro)
  462.             throws DriverTracciamentoException,
  463.             DriverTracciamentoNotFoundException {
  464.         
  465.         Connection con = null;

  467.         JDBCServiceManager transazioniServiceManager = null;
  468.         try{
  469.             con = getConnection();
  470.             checkConnection(con);
  471.                         
  472.             transazioniServiceManager = 
  473.                     (JDBCServiceManager) this.daoFactory.getServiceManager(new ProjectInfo(), con, true);
  474.             
  475.             ITransazioneServiceSearch transazioneServiceSearch = transazioniServiceManager.getTransazioneServiceSearch();
  476.                         
  477.             IPaginatedExpression expression = this.newPaginatedExpressionEngine(transazioneServiceSearch, filtro);
  478.                         
  479.             List<Map<String, Object>> lstTransazioni = transazioneServiceSearch.select(expression, Transazione.model().ID_TRANSAZIONE, 
  480.                     Transazione.model().ID_MESSAGGIO_RICHIESTA,Transazione.model().ID_MESSAGGIO_RISPOSTA);
  481.             
  482.             List<Traccia> tracce = new ArrayList<>();

  484.             for(Map<String, Object> transazioneMap : lstTransazioni) {
  485.                 
  486.                 // **** Lettura da database ****
  487.                 
  488.                 String idTransazione = (String) transazioneMap.get(Transazione.model().ID_TRANSAZIONE.getFieldName());
  489.                 
  490.                 Object oIdBustaRichiesta = transazioneMap.get(Transazione.model().ID_MESSAGGIO_RICHIESTA.getFieldName());
  491.                 String idBustaRichiesta = (oIdBustaRichiesta instanceof String) ? (String) oIdBustaRichiesta : null;
  492.                 
  493.                 Object oIdBustaRisposta = transazioneMap.get(Transazione.model().ID_MESSAGGIO_RISPOSTA.getFieldName());
  494.                 String idBustaRisposta = (oIdBustaRisposta instanceof String)  ? (String) oIdBustaRisposta : null;
  495.                 
  496.                 Map<String, String> propertiesRicerca = new HashMap<>();
  497.                 propertiesRicerca.put(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE, idTransazione);
  498.                 
  499.                 if(filtro.getIdBusta()!=null){
  500.                     if(filtro.getTipoTraccia()==null){
  501.                         if(filtro.getIdBusta().equals(idBustaRichiesta)){
  502.                             addTracciaSafe(tracce, RuoloMessaggio.RICHIESTA, con, propertiesRicerca, filtro);
  503.                         }else if(filtro.getIdBusta().equals(idBustaRisposta)){
  504.                             addTracciaSafe(tracce, RuoloMessaggio.RISPOSTA, con, propertiesRicerca, filtro);
  505.                         }
  506.                     }
  507.                     else{
  508.                         switch (filtro.getTipoTraccia()) {
  509.                         case RICHIESTA:
  510.                             addTracciaSafe(tracce, RuoloMessaggio.RICHIESTA, con, propertiesRicerca, filtro);
  511.                             break;
  512.                         case RISPOSTA:
  513.                             addTracciaSafe(tracce, RuoloMessaggio.RISPOSTA, con, propertiesRicerca, filtro);
  514.                             break;
  515.                         default:
  516.                             break;
  517.                         }
  518.                     }
  519.                 }
  520.                 else if(filtro.getIdBustaRichiesta()!=null || filtro.getIdBustaRisposta()!=null){
  521.                     if(filtro.getIdBustaRichiesta()!=null){
  522.                         addTracciaSafe(tracce, RuoloMessaggio.RICHIESTA, con, propertiesRicerca, filtro);
  523.                     }
  524.                     if(filtro.getIdBustaRisposta()!=null){
  525.                         addTracciaSafe(tracce, RuoloMessaggio.RISPOSTA, con, propertiesRicerca, filtro);
  526.                     }
  527.                 }
  528.                 else if(filtro.getRiferimentoMessaggio()!=null){
  529.                     addTracciaSafe(tracce, RuoloMessaggio.RISPOSTA, con, propertiesRicerca, filtro);
  530.                 }
  531.                 else{
  532.                     // aggiungo sia richiesta che risposta se presenti
  533.                     addTracciaSafe(tracce, RuoloMessaggio.RICHIESTA, con, propertiesRicerca, filtro);
  534.                     addTracciaSafe(tracce, RuoloMessaggio.RISPOSTA, con, propertiesRicerca, filtro);
  535.                 }               
  536.             }
  537.             
  538.             if(tracce.isEmpty()){
  539.                 throw new DriverTracciamentoNotFoundException("Tracce non trovate che rispettano il filtro di ricerca (Filtro:"+filtro.toString()+")");
  540.             }
  541.             else{
  542.                 return tracce;
  543.             }
  544.                 
  545.         }catch(DriverTracciamentoNotFoundException e){
  546.             throw e;
  547.         }catch(NotFoundException e){
  548.             throw new DriverTracciamentoNotFoundException(e.getMessage(),e);
  549.         }catch(Exception e){
  550.             throw new DriverTracciamentoException("Riscontrato errore durante la lettura dei dati (Filtro:"+filtro.toString()+"): "+e.getMessage(),e);
  551.         }finally{
  552.             try{
  553.                 if(transazioniServiceManager!=null) {
  554.                     transazioniServiceManager.close();
  555.                 }
  556.             }catch(Exception e){
  557.                 // close
  558.             }
  559.             closeConnection(con);
  560.         }
  561.         
  562.     }
  563.     
  564.     private IExpression newExpressionEngine(ITransazioneServiceSearch transazioneServiceSearch,FiltroRicercaTracce filtro) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException {
  565.         IExpression expression = transazioneServiceSearch.newExpression();
  566.         
  567.         if(filtro.getMaxDate()!=null){
  568.             expression.lessEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, filtro.getMaxDate());
  569.         }
  570.         if(filtro.getMinDate()!=null){
  571.             expression.greaterEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, filtro.getMinDate());
  572.         }
  573.         if(filtro.getTipoPdD()!=null){
  574.             expression.equals(Transazione.model().PDD_RUOLO, filtro.getTipoPdD().getTipo());
  575.         }
  576.         if(filtro.getDominio()!=null){
  577.             if(filtro.getDominio().getCodicePorta()!=null){
  578.                 expression.equals(Transazione.model().PDD_CODICE, filtro.getDominio().getCodicePorta());
  579.             }
  580.             if(filtro.getDominio().getTipo()!=null){
  581.                 expression.equals(Transazione.model().PDD_TIPO_SOGGETTO, filtro.getDominio().getTipo());
  582.             }
  583.             if(filtro.getDominio().getNome()!=null){
  584.                 expression.equals(Transazione.model().PDD_NOME_SOGGETTO, filtro.getDominio().getNome());
  585.             }
  586.         }
  587.         
  588.         boolean isOttimizzazioniTransazioniIdProtocolloDateInCampiSeparati = true; // static info
  589.         
  590.         if(filtro.getIdBusta()!=null){
  591.             IExpression expressionIdBusta = transazioneServiceSearch.newExpression();
  592.             if(isOttimizzazioniTransazioniIdProtocolloDateInCampiSeparati){
  593.                 
  594.                 if(filtro.getProtocollo()==null){
  595.                     throw new ServiceException("Se nel filtro viene impostato l'id della busta, ed è attiva l'opzione della comprensione delle date interne agli id, deve essere specificato nel filtro anche il protocollo");
  596.                 }
  597.                 IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(filtro.getProtocollo());
  598.                 IBustaBuilder<?> protocolBustaBuilder = protocolFactory.createBustaBuilder(null);
  599.                 
  600.                 Timestamp tIdBusta = DateUtility.getTimestampIntoIdProtocollo(this.log,protocolBustaBuilder,filtro.getIdBusta());
  601.                 if(tIdBusta==null){
  602.                     if(filtro.getTipoTraccia()==null){
  603.                         expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta());
  604.                         expressionIdBusta.or();
  605.                         expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  606.                     }
  607.                     else{
  608.                         switch (filtro.getTipoTraccia()) {
  609.                         case RICHIESTA:
  610.                             expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta());
  611.                             break;
  612.                         case RISPOSTA:
  613.                             expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  614.                             break;
  615.                         default:
  616.                             break;
  617.                         }
  618.                     }
  619.                 }else{
  620.                     IExpression expressionRichiesta = transazioneServiceSearch.newExpression();
  621.                     IExpression expressionRisposta = transazioneServiceSearch.newExpression();
  622.                     
  623.                     if(filtro.getTipoTraccia()==null){
  624.                         expressionRichiesta.equals(Transazione.model().DATA_ID_MSG_RICHIESTA, tIdBusta).and().equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta());
  625.                         expressionRisposta.equals(Transazione.model().DATA_ID_MSG_RISPOSTA, tIdBusta).and().equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  626.                         expressionIdBusta.or(expressionRichiesta, expressionRisposta);
  627.                     }
  628.                     else{
  629.                         switch (filtro.getTipoTraccia()) {
  630.                         case RICHIESTA:
  631.                             expressionIdBusta.equals(Transazione.model().DATA_ID_MSG_RICHIESTA, tIdBusta).and().equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta());
  632.                             break;
  633.                         case RISPOSTA:
  634.                             expressionIdBusta.equals(Transazione.model().DATA_ID_MSG_RISPOSTA, tIdBusta).and().equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  635.                             break;
  636.                         default:
  637.                             break;
  638.                         }
  639.                     }
  640.                 }
  641.             }else{
  642.                 if(filtro.getTipoTraccia()==null){
  643.                     expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta()).
  644.                         or().
  645.                         equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  646.                 }
  647.                 else{
  648.                     switch (filtro.getTipoTraccia()) {
  649.                     case RICHIESTA:
  650.                         expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBusta());
  651.                         break;
  652.                     case RISPOSTA:
  653.                         expressionIdBusta.equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBusta());
  654.                         break;
  655.                     default:
  656.                         break;
  657.                     }
  658.                 }
  659.             }
  660.             expression.and(expressionIdBusta);
  661.         }
  662.         
  663.         if(filtro.getIdBustaRichiesta()!=null){
  664.             if(isOttimizzazioniTransazioniIdProtocolloDateInCampiSeparati){
  665.                 
  666.                 if(filtro.getProtocollo()==null){
  667.                     throw new ServiceException("Se nel filtro viene impostato l'identificativo di richiesta della busta, ed è attiva l'opzione della comprensione delle date interne agli id, deve essere specificato nel filtro anche il protocollo");
  668.                 }
  669.                 IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(filtro.getProtocollo());
  670.                 IBustaBuilder<?> protocolBustaBuilder = protocolFactory.createBustaBuilder(null);
  671.                 
  672.                 Timestamp tIdBusta = DateUtility.getTimestampIntoIdProtocollo(this.log,protocolBustaBuilder,filtro.getIdBustaRichiesta());
  673.                 if(tIdBusta==null){
  674.                     expression.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBustaRichiesta());
  675.                 }else{
  676.                     IExpression expressionIdBusta = transazioneServiceSearch.newExpression();
  677.                     expressionIdBusta.equals(Transazione.model().DATA_ID_MSG_RICHIESTA, tIdBusta).and().
  678.                         equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBustaRichiesta());
  679.                     expression.and(expressionIdBusta);
  680.                 }
  681.             }else{
  682.                 expression.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getIdBustaRichiesta());
  683.             }
  684.         }
  685.         
  686.         if(filtro.getIdBustaRisposta()!=null){
  687.             if(isOttimizzazioniTransazioniIdProtocolloDateInCampiSeparati){
  688.                 
  689.                 if(filtro.getProtocollo()==null){
  690.                     throw new ServiceException("Se nel filtro viene impostato l'identificativo di risposta della busta, ed è attiva l'opzione della comprensione delle date interne agli id, deve essere specificato nel filtro anche il protocollo");
  691.                 }
  692.                 IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(filtro.getProtocollo());
  693.                 IBustaBuilder<?> protocolBustaBuilder = protocolFactory.createBustaBuilder(null);
  694.                 
  695.                 Timestamp tIdBusta = DateUtility.getTimestampIntoIdProtocollo(this.log,protocolBustaBuilder,filtro.getIdBustaRisposta());
  696.                 if(tIdBusta==null){
  697.                     expression.equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBustaRisposta());
  698.                 }else{
  699.                     IExpression expressionIdBusta = transazioneServiceSearch.newExpression();
  700.                     expressionIdBusta.equals(Transazione.model().DATA_ID_MSG_RISPOSTA, tIdBusta).and().
  701.                         equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBustaRisposta());
  702.                     expression.and(expressionIdBusta);
  703.                 }
  704.             }else{
  705.                 expression.equals(Transazione.model().ID_MESSAGGIO_RISPOSTA, filtro.getIdBustaRisposta());
  706.             }
  707.         }
  708.         
  709.         if(filtro.getRiferimentoMessaggio()!=null){
  710.             if(isOttimizzazioniTransazioniIdProtocolloDateInCampiSeparati){
  711.                 
  712.                 if(filtro.getProtocollo()==null){
  713.                     throw new ServiceException("Se nel filtro viene impostato il riferimento messaggio della busta, ed è attiva l'opzione della comprensione delle date interne agli id, deve essere specificato nel filtro anche il protocollo");
  714.                 }
  715.                 IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(filtro.getProtocollo());
  716.                 IBustaBuilder<?> protocolBustaBuilder = protocolFactory.createBustaBuilder(null);
  717.                 
  718.                 Timestamp tRifMessaggio = DateUtility.getTimestampIntoIdProtocollo(this.log,protocolBustaBuilder,filtro.getRiferimentoMessaggio());
  719.                 if(tRifMessaggio==null){
  720.                     expression.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getRiferimentoMessaggio());
  721.                 }else{
  722.                     IExpression expressionRiferimento = transazioneServiceSearch.newExpression();
  723.                     expressionRiferimento.equals(Transazione.model().DATA_ID_MSG_RICHIESTA, tRifMessaggio).and().equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getRiferimentoMessaggio());
  724.                     expression.and(expressionRiferimento);
  725.                 }
  726.             }else{
  727.                 expression.equals(Transazione.model().ID_MESSAGGIO_RICHIESTA, filtro.getRiferimentoMessaggio());
  728.             }
  729.         }

  731.         if(filtro.getInformazioniProtocollo()!=null){
  732.             InformazioniProtocollo info = filtro.getInformazioniProtocollo();
  733.             if(info.getMittente()!=null){
  734.                 if(info.getMittente().getTipo()!=null){
  735.                     expression.equals(Transazione.model().TIPO_SOGGETTO_FRUITORE, info.getMittente().getTipo());
  736.                 }
  737.                 if(info.getMittente().getNome()!=null){
  738.                     expression.equals(Transazione.model().NOME_SOGGETTO_FRUITORE, info.getMittente().getNome());
  739.                 }
  740.                 if(info.getMittente().getCodicePorta()!=null){
  741.                     expression.equals(Transazione.model().IDPORTA_SOGGETTO_FRUITORE, info.getMittente().getCodicePorta());
  742.                 }
  743.             }
  744.             if(info.getDestinatario()!=null){
  745.                 if(info.getDestinatario().getTipo()!=null){
  746.                     expression.equals(Transazione.model().TIPO_SOGGETTO_EROGATORE, info.getDestinatario().getTipo());
  747.                 }
  748.                 if(info.getDestinatario().getNome()!=null){
  749.                     expression.equals(Transazione.model().NOME_SOGGETTO_EROGATORE, info.getDestinatario().getNome());
  750.                 }
  751.                 if(info.getDestinatario().getCodicePorta()!=null){
  752.                     expression.equals(Transazione.model().IDPORTA_SOGGETTO_EROGATORE, info.getDestinatario().getCodicePorta());
  753.                 }
  754.             }
  755.             if(info.getTipoServizio()!=null){
  756.                 expression.equals(Transazione.model().TIPO_SERVIZIO, info.getTipoServizio());
  757.             }
  758.             if(info.getServizio()!=null){
  759.                 expression.equals(Transazione.model().NOME_SERVIZIO, info.getServizio());
  760.             }
  761.             if(info.getAzione()!=null){
  762.                 expression.equals(Transazione.model().AZIONE, info.getAzione());
  763.             }
  764.             if(info.getProfiloCollaborazioneEngine()!=null){
  765.                 expression.equals(Transazione.model().PROFILO_COLLABORAZIONE_OP_2, info.getProfiloCollaborazioneEngine().getEngineValue());
  766.             }
  767.             if(info.getProfiloCollaborazioneProtocollo()!=null){
  768.                 expression.equals(Transazione.model().PROFILO_COLLABORAZIONE_PROT, info.getProfiloCollaborazioneProtocollo());
  769.             }
  770.         }

  772.         // Correlazione Applicativa Richiesta / Risposta: 
  773.         // - se vengono forniti entrambi i campi, li controllo entrambi (in AND o OR a seconda del parametro isIdCorrelazioneApplicativaOrMatch)
  774.         // - se viene fornito uno solo dei campi viene aggiunto in maniera canonica
  775.         
  776.         if(filtro.getIdCorrelazioneApplicativa() != null && filtro.getIdCorrelazioneApplicativaRisposta() != null){
  777.             
  778.             IExpression correlazioneExpression = transazioneServiceSearch.newExpression();
  779.             
  780.             correlazioneExpression.equals(Transazione.model().ID_CORRELAZIONE_APPLICATIVA, filtro.getIdCorrelazioneApplicativa());
  781.             if(filtro.isIdCorrelazioneApplicativaOrMatch()) {
  782.                 correlazioneExpression.or();
  783.             } else {
  784.                 correlazioneExpression.and();
  785.             }
  786.             correlazioneExpression.equals(Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA, filtro.getIdCorrelazioneApplicativaRisposta());

  788.             expression.and(correlazioneExpression);
  789.             
  790.         }   else if(filtro.getIdCorrelazioneApplicativa() != null){
  791.             expression.equals(Transazione.model().ID_CORRELAZIONE_APPLICATIVA, filtro.getIdCorrelazioneApplicativa());
  792.         }   else if(filtro.getIdCorrelazioneApplicativaRisposta() != null){
  793.             expression.equals(Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA, filtro.getIdCorrelazioneApplicativaRisposta());
  794.         }
  795.         
  796.         if(filtro.getServizioApplicativoFruitore()!=null){
  797.             expression.equals(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE, filtro.getServizioApplicativoFruitore());
  798.         }
  799.         if(filtro.getServizioApplicativoErogatore()!=null){
  800.             expression.equals(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE, filtro.getServizioApplicativoErogatore());
  801.         }

  803.         if(filtro.getProtocollo()!=null){
  804.             expression.equals(Transazione.model().PROTOCOLLO, filtro.getProtocollo());
  805.         }
  806.         
  807.         return expression;
  808.     }
  809.     private IPaginatedExpression newPaginatedExpressionEngine(ITransazioneServiceSearch transazioneServiceSearch,FiltroRicercaTracceConPaginazione filtro) throws ServiceException, NotImplementedException, ExpressionNotImplementedException, ExpressionException, ProtocolException {
  810.         IPaginatedExpression expression = transazioneServiceSearch.toPaginatedExpression(this.newExpressionEngine(transazioneServiceSearch, filtro));
  811.         
  812.         expression.sortOrder(filtro.isAsc() ? SortOrder.ASC : SortOrder.DESC);
  813.         expression.addOrder(Transazione.model().DATA_INGRESSO_RICHIESTA);
  814.         
  815.         expression.offset(filtro.getOffset());
  816.         if(filtro.getLimit()>0)
  817.             expression.limit(filtro.getLimit());
  818.         
  819.         return expression;
  820.     }

  822.     @Override
  823.     public int deleteTracce(FiltroRicercaTracce filter)
  824.             throws DriverTracciamentoException {
  825.         throw new DriverTracciamentoException(NON_IMPLEMENTATO);
  826.     }

  828.     @Override
  829.     public Traccia getTraccia(String idBusta, IDSoggetto codicePorta)
  830.             throws DriverTracciamentoException,
  831.             DriverTracciamentoNotFoundException {
  832.         throw new DriverTracciamentoException(NON_IMPLEMENTATO);
  833.     }

  835.     @Override
  836.     public Traccia getTraccia(String idBusta, IDSoggetto codicePorta,
  837.             boolean ricercaIdBustaComeRiferimentoMessaggio)
  838.             throws DriverTracciamentoException,
  839.             DriverTracciamentoNotFoundException {
  840.         throw new DriverTracciamentoException(NON_IMPLEMENTATO);
  841.     }

  843.     @Override
  844.     public Traccia getTraccia(RuoloMessaggio tipoTraccia,
  845.             Map<String, String> propertiesRicerca)
  846.             throws DriverTracciamentoException,
  847.             DriverTracciamentoNotFoundException {
  848.         try{
  849.             Traccia tr = getTracciaByPropertiesEngine(null, propertiesRicerca, tipoTraccia,
  850.                     null, null);            
  851.             if(tr==null){
  852.                 throw new DriverTracciamentoNotFoundException("NotFound");
  853.             }
  854.             return tr;
  855.             
  856.         }catch(DriverTracciamentoNotFoundException e){
  857.             throw e;
  858.         }catch(Exception e){
  859.             throw new DriverTracciamentoException(e.getMessage(),e);
  860.         }
  861.     }
  862.     
  863.     @Override
  864.     public Traccia getTraccia(String idTransazione, RuoloMessaggio tipoTraccia)
  865.             throws DriverTracciamentoException, DriverTracciamentoNotFoundException {
  866.         
  867.         Map<String, String> propertiesRicerca = new HashMap<>();
  868.         propertiesRicerca.put(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE, idTransazione);
  869.         return this.getTraccia(tipoTraccia, propertiesRicerca);
  870.         
  871.     }
  872.     
  873.     
  874.     
  875.     /* ******* RISORSE INTERNE ********** */
  876.     
  877.     @Override
  878.     public void close() throws DriverTracciamentoException {
  879.         try{
  880.             if(this.driverTracciamento!=null){
  881.                 this.driverTracciamento.close();
  882.             }
  883.         }finally{
  884.             try{
  885.                 if(this.connectionOpenViaJDBCInCostructor &&
  886.                     this.connection!=null && !this.connection.isClosed()){
  887.                     JDBCUtilities.closeConnection(BasicComponentFactory.getCheckLogger(), this.connection, BasicComponentFactory.isCheckAutocommit(), BasicComponentFactory.isCheckIsClosed());
  888.                 }
  889.             }catch(Exception e){
  890.                 if(this.log!=null) {
  891.                     this.log.error("Close connection failure: "+e.getMessage(),e);
  892.                 }
  893.                 /**throw new DriverTracciamentoException(e.getMessage(),e);*/
  894.             }
  895.         }
  896.     }
  897.     
  898.     
  899.     
  900.     private static final long ID_TRACCIA_RICOSTRUITA = -2;  // viene usato il valore -2 per indicare che si tratta di una traccia ricostruita (per funzionare dove viene usato org.openspcoop2.protocol.basic.tracciamento.DriverTracciamento.IDTRACCIA)
  901.     private static final String ID_TRACCIA_RICOSTRUITA_AS_STRING = ID_TRACCIA_RICOSTRUITA + ""; 
  902.     
  903.     private Connection close(Connection con) {
  904.         try{
  905.             if(con!=null) {
  906.                 JDBCUtilities.closeConnection(BasicComponentFactory.getCheckLogger(), con, BasicComponentFactory.isCheckAutocommit(), BasicComponentFactory.isCheckIsClosed());
  907.                 con = null;
  908.             }
  909.         }catch(Exception e){
  910.             // close
  911.         }
  912.         return con;
  913.     }
  914.     private JDBCServiceManager close(JDBCServiceManager transazioniServiceManager) {
  915.         try{
  916.             if(transazioniServiceManager!=null) {
  917.                 transazioniServiceManager.close();
  918.                 transazioniServiceManager = null;
  919.             }
  920.         }catch(Exception e){
  921.             // ignore
  922.         }
  923.         return transazioniServiceManager;
  924.     }
  925.     
  926.     private Traccia getTracciaByPropertiesEngine(
  927.             Connection conDB,
  928.             Map<String, String> propertiesRicerca,
  929.             RuoloMessaggio tipoTraccia,
  930.             Date minDate,
  931.             Date maxDate)
  932.             throws DriverTracciamentoException,
  933.             DriverTracciamentoNotFoundException {
  934.         
  935.         String idTransazione = propertiesRicerca.get(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE);
  936.         if(idTransazione==null){
  937.             throw new DriverTracciamentoException("Identificativo di transazione non fornito");
  938.         }
  939.         String idTraccia = propertiesRicerca.get(org.openspcoop2.protocol.basic.tracciamento.TracciaDriver.IDTRACCIA);
  940.         boolean removeIdTraccia = false;
  941.         if(idTraccia!=null && ID_TRACCIA_RICOSTRUITA_AS_STRING.equals(idTraccia)){
  942.             propertiesRicerca.remove(org.openspcoop2.protocol.basic.tracciamento.TracciaDriver.IDTRACCIA);
  943.             removeIdTraccia = true;
  944.         }
  945.         
  946.         Connection con = null;
  947.         boolean closeConnection = true;
  948.         JDBCServiceManager transazioniServiceManager = null;
  949.         try{
  950.             if(conDB!=null){
  951.                 con = conDB;
  952.                 closeConnection = false;
  953.             }else{
  954.                 if(this.connection!=null){
  955.                     con = this.connection;
  956.                     closeConnection = false;
  957.                 }else{
  958.                     con = this.datasource.getConnection();
  959.                 }
  960.             }
  961.             if(con==null)
  962.                 throw new DriverTracciamentoException("Connection non ottenuta");
  963.             
  964.             transazioniServiceManager = 
  965.                     (JDBCServiceManager) this.daoFactory.getServiceManager(new ProjectInfo(), con, true);
  966.             
  967.             
  968.             // Informazioni salvataggio tracce
  969.             CredenzialiMittente credentialsFiller = new CredenzialiMittente();
  970.             InformazioniRecordTraccia informazioniSalvataggioTraccia = getInformazioniSalvataggioTraccia(transazioniServiceManager, idTransazione, tipoTraccia, credentialsFiller,
  971.                     minDate,
  972.                     maxDate);
  973.             
  974.             // Non vi sono informazioni eventuali sulla simulazione. Provo a recuperarla direttamente
  975.             if(informazioniSalvataggioTraccia==null){
  976.                 
  977.                 // per evitare deadlock di connessioni
  978.                 transazioniServiceManager = close(transazioniServiceManager);
  979.                 if(closeConnection){
  980.                     con = close(con);
  981.                 }
  982.                 
  983.                 Traccia traccia = this.driverTracciamento.getTraccia(tipoTraccia, propertiesRicerca);
  984.                 // set Properties
  985.                 setPropertiesEngine(traccia, propertiesRicerca, idTransazione);
  986.                 return traccia;
  987.             }
  988.             
  989.             // Non era stata emessa una traccia di richiesta per la transazione
  990.             if(!informazioniSalvataggioTraccia.isPresente()){
  991.                 throw new DriverTracciamentoNotFoundException("non presente");
  992.             }
  993.             
  994.             // La traccia era stata interamente salvata nel database delle tracce, poiche' non possedeva tutti i valori ricostruibili automaticamente
  995.             if(!informazioniSalvataggioTraccia.isRicostruibile()){
  996.                 
  997.                 // per evitare deadlock di connessioni
  998.                 transazioniServiceManager = close(transazioniServiceManager);
  999.                 if(closeConnection){
  1000.                     close(con);
  1001.                 }
  1002.                 
  1003.                 Traccia traccia = this.driverTracciamento.getTraccia(tipoTraccia, propertiesRicerca);
  1004.                 // set Properties
  1005.                 setPropertiesEngine(traccia, propertiesRicerca, idTransazione);
  1006.                 return traccia;
  1007.             }
  1008.             
  1009.             // Recupero transazione
  1010.             ITransazioneServiceSearch transazioneServiceSearch = transazioniServiceManager.getTransazioneServiceSearch();
  1011.             Transazione transazione = null;
  1012.             if(maxDate!=null && minDate!=null){
  1013.                 // ottimizzazione per partizioni
  1014.                 IPaginatedExpression exprGetIdTransazione = transazioneServiceSearch.newPaginatedExpression();
  1015.                 if(maxDate!=null){
  1016.                     exprGetIdTransazione.lessEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, maxDate);
  1017.                 }
  1018.                 if(minDate!=null){
  1019.                     exprGetIdTransazione.greaterEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, minDate);
  1020.                 }
  1021.                 exprGetIdTransazione.equals(Transazione.model().ID_TRANSAZIONE,idTransazione);
  1022.                 /**transazione = transazioneServiceSearch.find(exprGetIdTransazione);*/
  1023.                 // NOTA: findAll più efficiente
  1024.                 List<Transazione> transazioni = transazioneServiceSearch.findAll(exprGetIdTransazione);
  1025.                 if(transazioni==null || transazioni.isEmpty()) {
  1026.                     throw new DriverTracciamentoNotFoundException("Transazione con id '"+idTransazione+"' non trovata minDate:"+minDate+" maxDate:"+maxDate+"");
  1027.                 }
  1028.                 transazione = transazioni.get(0);
  1029.                 if(transazione == null) {
  1030.                     throw new DriverTracciamentoNotFoundException("Transazione con id '"+idTransazione+"' minDate:"+minDate+" maxDate:"+maxDate+" ritornata null?");
  1031.                 }           
  1032.             }
  1033.             else {
  1034.                 transazione = transazioneServiceSearch.get(idTransazione);
  1035.             }
  1036.             
  1037.             // Costruzione traccia
  1038.             Traccia traccia = this.buildTraccia(tipoTraccia, transazione, credentialsFiller.getTokenClientId(), informazioniSalvataggioTraccia);
  1039.             // set Properties
  1040.             setPropertiesEngine(traccia, propertiesRicerca, idTransazione);
  1041.             return traccia;
  1042.                                 
  1043.         }catch(DriverTracciamentoNotFoundException e){
  1044.             throw e;
  1045.         }catch(Exception e){
  1046.             throw new DriverTracciamentoException("Riscontrato errore durante la lettura dei dati (Transazione:"+idTransazione+"): "+e.getMessage(),e);
  1047.         }finally{
  1048.             close(transazioniServiceManager);
  1049.             if(closeConnection){
  1050.                 close(con);
  1051.             }
  1052.             if(removeIdTraccia){
  1053.                 propertiesRicerca.put(org.openspcoop2.protocol.basic.tracciamento.TracciaDriver.IDTRACCIA,idTraccia);
  1054.             }
  1055.         }
  1056.         
  1057.     }
  1058.     private void setPropertiesEngine(Traccia traccia, Map<String, String> propertiesRicerca, String idTransazione){
  1059.         // set Properties
  1060.         if(traccia.getProperties()==null){
  1061.             traccia.setProperties(new HashMap<>());
  1062.         }
  1063.         if(propertiesRicerca!=null && propertiesRicerca.size()>0){
  1064.             traccia.getProperties().putAll(propertiesRicerca);
  1065.         }
  1066.         if(!traccia.getProperties().containsKey(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE)){
  1067.             traccia.getProperties().put(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE, idTransazione);
  1068.         }
  1069.         if(!traccia.getProperties().containsKey(org.openspcoop2.protocol.basic.tracciamento.TracciaDriver.IDTRACCIA)){
  1070.             traccia.getProperties().put(org.openspcoop2.protocol.basic.tracciamento.TracciaDriver.IDTRACCIA, ID_TRACCIA_RICOSTRUITA_AS_STRING); 
  1071.         }
  1072.     }

  1074.     private Traccia buildTraccia(RuoloMessaggio tipoTraccia, Transazione transazione, CredenzialeMittente credenzialeClientId, InformazioniRecordTraccia infoSalvataggioTraccia) throws CoreException {
  1075.         
  1076.         Traccia traccia = new Traccia();
  1077.         
  1078.         Object oGdo = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_DATA_REGISTRAZIONE).getDato();
  1079.         traccia.setGdo(oGdo!=null ? (Date)oGdo : null);
  1080.         
  1081.         IDSoggetto idSoggetto = null;
  1082.         if(transazione.getPddCodice()!=null || transazione.getPddTipoSoggetto()!=null || transazione.getPddNomeSoggetto()!=null){
  1083.             idSoggetto = new IDSoggetto(transazione.getPddTipoSoggetto(), transazione.getPddNomeSoggetto(), transazione.getPddCodice());
  1084.         }
  1085.         traccia.setIdSoggetto(idSoggetto);
  1086.         
  1087.         switch (transazione.getPddRuolo()) {
  1088.         case APPLICATIVA:
  1089.             traccia.setTipoPdD(TipoPdD.APPLICATIVA);    
  1090.             break;
  1091.         case DELEGATA:
  1092.             traccia.setTipoPdD(TipoPdD.DELEGATA);   
  1093.             break;
  1094.         case INTEGRATION_MANAGER:
  1095.             traccia.setTipoPdD(TipoPdD.INTEGRATION_MANAGER);    
  1096.             break;
  1097.         case ROUTER:
  1098.             traccia.setTipoPdD(TipoPdD.ROUTER); 
  1099.             break;
  1100.         default:
  1101.             break;
  1102.         }
  1103.         
  1104.         traccia.setTipoMessaggio(tipoTraccia);

  1106.         traccia.setBusta(this.buildBusta(tipoTraccia, transazione, credenzialeClientId, infoSalvataggioTraccia ));
  1107.         
  1108.         if(tipoTraccia.equals(RuoloMessaggio.RICHIESTA)) {
  1109.             traccia.setBustaAsString(transazione.getHeaderProtocolloRichiesta());
  1110.         } else {
  1111.             traccia.setBustaAsString(transazione.getHeaderProtocolloRisposta());
  1112.         }
  1113.         
  1114.         traccia.setCorrelazioneApplicativa(transazione.getIdCorrelazioneApplicativa());
  1115.         traccia.setCorrelazioneApplicativaRisposta(transazione.getIdCorrelazioneApplicativaRisposta());
  1116.         
  1117.         if(tipoTraccia.equals(RuoloMessaggio.RICHIESTA)) {
  1118.             traccia.setLocation(transazione.getLocationRichiesta());
  1119.         } else {
  1120.             traccia.setLocation(transazione.getLocationRisposta());
  1121.         }
  1122.         
  1123.         traccia.setProtocollo(transazione.getProtocollo());
  1124.         
  1125.         EsitoElaborazioneMessaggioTracciato esito = new EsitoElaborazioneMessaggioTracciato();
  1126.         Object oEsito = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_ESITO_TRACCIA).getDato();
  1127.         if(oEsito!=null){
  1128.             Character esitoChar = (Character) oEsito;
  1129.             if(CostantiMappingTracciamento.TRACCIA_BUSTA_ESITO_TRACCIA_INVIATA == esitoChar ){
  1130.                 esito.setEsito(EsitoElaborazioneMessaggioTracciatura.INVIATO);
  1131.             }
  1132.             else if(CostantiMappingTracciamento.TRACCIA_BUSTA_ESITO_TRACCIA_RICEVUTA == esitoChar ){
  1133.                 esito.setEsito(EsitoElaborazioneMessaggioTracciatura.RICEVUTO);
  1134.             }
  1135.             else if(CostantiMappingTracciamento.TRACCIA_BUSTA_ESITO_TRACCIA_ERRORE == esitoChar ){
  1136.                 esito.setEsito(EsitoElaborazioneMessaggioTracciatura.ERRORE);
  1137.             }
  1138.         }
  1139.         if(esito.getEsito()!=null && esito.getEsito().equals(EsitoElaborazioneMessaggioTracciatura.ERRORE) && 
  1140.                 TipoPdD.DELEGATA.equals(traccia.getTipoPdD())) {
  1141.             esito.setDettaglio(transazione.getFaultCooperazione());
  1142.         }
  1143.         
  1144.         traccia.setEsitoElaborazioneMessaggioTracciato(esito);
  1145.         
  1146.         return traccia;
  1147.     }
  1148.     
  1149.     private Busta buildBusta(RuoloMessaggio tipoTraccia, Transazione transazione, CredenzialeMittente credenzialeClientId, 
  1150.             InformazioniRecordTraccia infoSalvataggioTraccia) throws CoreException {
  1151.         
  1152.         boolean richiesta = tipoTraccia.equals(RuoloMessaggio.RICHIESTA);
  1153.         
  1154.         IDSoggetto mittente = PopolamentoTracciaUtils.getIdSoggettoMittente(transazione, richiesta);
  1155.         IDSoggetto destinatario = PopolamentoTracciaUtils.getIdSoggettoDestinatario(transazione, richiesta);
  1156.         
  1157.         
  1158.         Busta busta = new Busta(transazione.getProtocollo());
  1159.         
  1160.         busta.setMittente(mittente.getNome());
  1161.         busta.setTipoMittente(mittente.getTipo());
  1162.         busta.setIdentificativoPortaMittente(mittente.getCodicePorta());
  1163.         busta.setIndirizzoMittente(richiesta ? transazione.getIndirizzoSoggettoFruitore() :  transazione.getIndirizzoSoggettoErogatore());
  1164.         
  1165.         busta.setDestinatario(destinatario.getNome());
  1166.         busta.setTipoDestinatario(destinatario.getTipo());
  1167.         busta.setIdentificativoPortaDestinatario(destinatario.getCodicePorta());
  1168.         busta.setIndirizzoDestinatario(richiesta ? transazione.getIndirizzoSoggettoErogatore() :  transazione.getIndirizzoSoggettoFruitore());
  1169.         
  1170.         boolean applicativoToken = false;
  1171.         
  1172.         if(credenzialeClientId!=null) {
  1173.             AbstractDatoRicostruzione<?> dato = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SOGGETTO_APPLICATIVO_TOKEN);
  1174.             Object tracciaBustaSoggettoApplicativoToken = null;
  1175.             if(dato!=null) {
  1176.                 tracciaBustaSoggettoApplicativoToken = dato.getDato();
  1177.             }
  1178.             if(tracciaBustaSoggettoApplicativoToken != null) {
  1179.                 boolean soggettoApplicativoToken = ((Character)tracciaBustaSoggettoApplicativoToken) == CostantiMappingTracciamento.TRACCIA_BUSTA_SOGGETTO_APPLICATIVO_TOKEN_TRUE;
  1180.                 if(soggettoApplicativoToken) {
  1181.                     IDServizioApplicativo idApplicativoToken = null;
  1182.                     if(credenzialeClientId!=null && credenzialeClientId.getCredenziale()!=null) {
  1183.                         try {
  1184.                             idApplicativoToken = CredenzialeTokenClient.convertApplicationDBValueToOriginal(credenzialeClientId.getCredenziale());
  1185.                         }catch(Exception e) {
  1186.                             // ignore
  1187.                         }
  1188.                     }
  1189.                     if(idApplicativoToken!=null && idApplicativoToken.getIdSoggettoProprietario()!=null) {
  1190.                         if(RuoloMessaggio.RICHIESTA.equals(tipoTraccia)) {
  1191.                             busta.setMittente(idApplicativoToken.getIdSoggettoProprietario().getNome());
  1192.                             busta.setTipoMittente(idApplicativoToken.getIdSoggettoProprietario().getTipo());
  1193.                             busta.setIdentificativoPortaMittente(null);
  1194.                             busta.setIndirizzoMittente(null);
  1195.                             applicativoToken=true;
  1196.                         }
  1197.                         else {
  1198.                             busta.setDestinatario(idApplicativoToken.getIdSoggettoProprietario().getNome());
  1199.                             busta.setTipoDestinatario(idApplicativoToken.getIdSoggettoProprietario().getTipo());
  1200.                             busta.setIdentificativoPortaDestinatario(null);
  1201.                             busta.setIndirizzoDestinatario(null);
  1202.                             applicativoToken=true;
  1203.                         }
  1204.                     }
  1205.                 }
  1206.             }
  1207.         }
  1208.         
  1209.         busta.setProfiloDiCollaborazione(ProfiloDiCollaborazione.toProfiloDiCollaborazione(transazione.getProfiloCollaborazioneOp2()));
  1210.         busta.setProfiloDiCollaborazioneValue(transazione.getProfiloCollaborazioneProt());
  1211.         
  1212.         Object oServizioCorrelatoPresente = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SERVIZIO_CORRELATO_PRESENTE).getDato();

  1214.         if(((Character)oServizioCorrelatoPresente).equals(CostantiMappingTracciamento.TRACCIA_BUSTA_SERVIZIO_CORRELATO_PRESENTE_TRUE)) {
  1215.             busta.setServizioCorrelato(transazione.getNomeServizioCorrelato());
  1216.             busta.setTipoServizioCorrelato(transazione.getTipoServizioCorrelato());
  1217.         }
  1218.         
  1219.         busta.setCollaborazione(transazione.getIdCollaborazione());
  1220.         
  1221.         busta.setServizio(transazione.getNomeServizio());
  1222.         busta.setTipoServizio(transazione.getTipoServizio());
  1223.         busta.setVersioneServizio(transazione.getVersioneServizio());
  1224.         
  1225.         busta.setAzione(transazione.getAzione());
  1226.         
  1227.         
  1228.         if(RuoloMessaggio.RICHIESTA.equals(tipoTraccia)){
  1229.             busta.setID(transazione.getIdMessaggioRichiesta());
  1230.         }else{
  1231.             busta.setID(transazione.getIdMessaggioRisposta());
  1232.         }
  1233.         
  1234.         Object oRiferimentoMessaggio = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_RIFERIMENTO_MESSAGGIO).getDato();
  1235.         if(oRiferimentoMessaggio!=null){
  1236.             char riferimento = ((Character)oRiferimentoMessaggio);
  1237.             String riferimentoMessaggio;
  1238.             if(CostantiMappingTracciamento.TRACCIA_BUSTA_RIFERIMENTO_MESSAGGIO_ID_MESSAGGIO_RICHIESTA == riferimento) {
  1239.                 riferimentoMessaggio = transazione.getIdMessaggioRichiesta();
  1240.             } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_RIFERIMENTO_MESSAGGIO_ID_MESSAGGIO_RISPOSTA == riferimento) {
  1241.                 riferimentoMessaggio = transazione.getIdMessaggioRisposta();
  1242.             } else {
  1243.                 riferimentoMessaggio = transazione.getIdAsincrono();
  1244.             }
  1245.             
  1246.             busta.setRiferimentoMessaggio(riferimentoMessaggio);
  1247.         }
  1248.         
  1249.         Object oOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_ORA_REGISTRAZIONE).getDato();
  1250.         busta.setOraRegistrazione(oOraRegistrazione!=null ? (Date)oOraRegistrazione : null);
  1251.         
  1252.         Object oTipoOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_TIPO_ORA_REGISTRAZIONE_BY_OPENSPCOOP).getDato();
  1253.         TipoOraRegistrazione tipoOraRegistrazione=null;
  1254.         if(oTipoOraRegistrazione!=null){
  1255.             char tipo = ((Character)oTipoOraRegistrazione);
  1256.             if(CostantiMappingTracciamento.TIPO_ORA_REGISTRAZIONE_BY_OPENSPCOOP_SCONOSCIUTO == tipo){
  1257.                 tipoOraRegistrazione = TipoOraRegistrazione.UNKNOWN;
  1258.             }
  1259.             else if(CostantiMappingTracciamento.TIPO_ORA_REGISTRAZIONE_BY_OPENSPCOOP_SINCRONIZZATO == tipo){
  1260.                 tipoOraRegistrazione = TipoOraRegistrazione.SINCRONIZZATO;
  1261.             }
  1262.             else if(CostantiMappingTracciamento.TIPO_ORA_REGISTRAZIONE_BY_OPENSPCOOP_LOCALE == tipo){
  1263.                 tipoOraRegistrazione = TipoOraRegistrazione.LOCALE;
  1264.             }
  1265.         }
  1266.         Object oTipoOraRegistrazioneValue = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_TIPO_ORA_REGISTRAZIONE_BY_PROTOCOLLO).getDato();
  1267.         busta.setTipoOraRegistrazione(tipoOraRegistrazione, 
  1268.                 oTipoOraRegistrazioneValue!=null ? (String)oTipoOraRegistrazioneValue : null);
  1269.         

  1271.         Object oScadenza = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SCADENZA).getDato();
  1272.         if(oScadenza != null) {
  1273.             busta.setScadenza((Date) oScadenza);
  1274.         }

  1276.         Object oConfermaRicezione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_CONFERMA_RICHIESTA).getDato();
  1277.         
  1278.         if(oConfermaRicezione != null) {
  1279.             busta.setConfermaRicezione(((Character)oConfermaRicezione) == CostantiMappingTracciamento.TRACCIA_BUSTA_CONFERMA_RICHIESTA_TRUE);
  1280.         }

  1282.         Object oInoltro = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_FILTRO_DUPLICATI_CODE).getDato();
  1283.         Inoltro inoltro = null;
  1284.         
  1285.         if(oInoltro != null) {
  1286.             char value = ((Character)oInoltro);
  1287.             if(CostantiMappingTracciamento.TRACCIA_FILTRO_DUPLICATI_CODE_ALPIUUNAVOLTA == value) {
  1288.                 inoltro = Inoltro.SENZA_DUPLICATI;
  1289.             } else if(CostantiMappingTracciamento.TRACCIA_FILTRO_DUPLICATI_CODE_PIUDIUNAVOLTA == value) {
  1290.                 inoltro = Inoltro.CON_DUPLICATI;
  1291.             } else {
  1292.                 inoltro = Inoltro.UNKNOWN;
  1293.             }
  1294.             
  1295.         }
  1296.         
  1297.         Object oInoltroValue = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_FILTRO_DUPLICATI).getDato();
  1298.         busta.setInoltro(inoltro, oInoltroValue != null ? (String)oInoltroValue : null);

  1300.         Object oSequenza = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SEQUENZA).getDato();
  1301.         if(oSequenza != null) {
  1302.             busta.setSequenza(Long.valueOf((String)oSequenza));
  1303.         }
  1304.         
  1305.         busta.setServizioApplicativoFruitore(transazione.getServizioApplicativoFruitore());
  1306.         busta.setServizioApplicativoErogatore(transazione.getServizioApplicativoErogatore());
  1307.         
  1308.         busta.setProtocollo(transazione.getProtocollo());

  1310.         busta.setDigest(richiesta ? transazione.getDigestRichiesta() : transazione.getDigestRisposta());
  1311.         
  1312.         String properties = richiesta ? transazione.getProtocolloExtInfoRichiesta() : transazione.getProtocolloExtInfoRisposta();
  1313.         Map<String, List<String>> bustaProperties = PropertiesSerializator.convertoFromDBColumnValue(properties);
  1314.         if(bustaProperties!=null && bustaProperties.size()>0){
  1315.             for (Map.Entry<String,List<String>> entry : bustaProperties.entrySet()) {
  1316.                 String key = entry.getKey();
  1317.                 List<String> values = bustaProperties.get(key);
  1318.                 if(values!=null && !values.isEmpty()) {
  1319.                     for (String value : values) {
  1320.                         busta.addProperty(key, value);  
  1321.                     }
  1322.                 }
  1323.             }
  1324.         }

  1326.         Object oRiscontroOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_RISCONTRO_ORA_REGISTRAZIONE).getDato();
  1327.         Object oRiscontroTipoOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_RISCONTRO_TIPO_ORA_REGISTRAZIONE).getDato();
  1328.         Object oRiscontroTipoOraRegistrazioneCode = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_RISCONTRO_TIPO_ORA_REGISTRAZIONE_CODE).getDato();

  1330.         if(oRiscontroOraRegistrazione != null && oRiscontroTipoOraRegistrazione != null && oRiscontroTipoOraRegistrazioneCode != null) {
  1331.             
  1332.             Riscontro riscontro = new Riscontro();
  1333.             riscontro.setID(transazione.getIdMessaggioRichiesta());
  1334.             riscontro.setOraRegistrazione((Date)oRiscontroOraRegistrazione);
  1335.             
  1336.             char value = ((Character)oRiscontroTipoOraRegistrazioneCode);
  1337.             if(CostantiMappingTracciamento.TRACCIA_BUSTA_RISCONTRO_TIPO_ORA_REGISTRAZIONE_CODE_LOCALE == value) {
  1338.                 riscontro.setTipoOraRegistrazione(TipoOraRegistrazione.LOCALE);
  1339.             } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_RISCONTRO_TIPO_ORA_REGISTRAZIONE_CODE_SINCRONIZZATO == value) {
  1340.                 riscontro.setTipoOraRegistrazione(TipoOraRegistrazione.SINCRONIZZATO);
  1341.             } else {
  1342.                 riscontro.setTipoOraRegistrazione(TipoOraRegistrazione.UNKNOWN);
  1343.             }
  1344.             
  1345.             riscontro.setTipoOraRegistrazioneValue((String)oRiscontroTipoOraRegistrazione);
  1346.             
  1347.             busta.addRiscontro(riscontro);
  1348.         }
  1349.         
  1350.         if(!applicativoToken) {
  1351.         
  1352.             Object oPrimaTrasmissioneOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_ORA_REGISTRAZIONE).getDato();
  1353.             Object oPrimaTrasmissioneTipoOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE).getDato();
  1354.             Object oPrimaTrasmissioneTipoOraRegistrazioneCode = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE_CODE).getDato();
  1355.     
  1356.             if(oPrimaTrasmissioneOraRegistrazione != null && oPrimaTrasmissioneTipoOraRegistrazione != null && oPrimaTrasmissioneTipoOraRegistrazioneCode != null) {
  1357.                 
  1358.                 Trasmissione trasmissione = new Trasmissione();
  1359.                 trasmissione.setOraRegistrazione((Date)oPrimaTrasmissioneOraRegistrazione);
  1360.                 
  1361.                 boolean trasmissioneNormale = true;
  1362.                 char value = ((Character)oPrimaTrasmissioneTipoOraRegistrazioneCode);
  1363.                 if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_NORMALE_TIPO_ORA_REGISTRAZIONE_CODE_LOCALE == value) {
  1364.                     trasmissione.setTempo(TipoOraRegistrazione.LOCALE);
  1365.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_NORMALE_TIPO_ORA_REGISTRAZIONE_CODE_SINCRONIZZATO == value) {
  1366.                     trasmissione.setTempo(TipoOraRegistrazione.SINCRONIZZATO);
  1367.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_NORMALE_TIPO_ORA_REGISTRAZIONE_CODE_SCONOSCIUTO == value) {
  1368.                     trasmissione.setTempo(TipoOraRegistrazione.UNKNOWN);
  1369.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_INVERTITA_TIPO_ORA_REGISTRAZIONE_CODE_LOCALE == value) {
  1370.                     trasmissione.setTempo(TipoOraRegistrazione.LOCALE);
  1371.                     trasmissioneNormale = false;
  1372.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_INVERTITA_TIPO_ORA_REGISTRAZIONE_CODE_SINCRONIZZATO == value) {
  1373.                     trasmissione.setTempo(TipoOraRegistrazione.SINCRONIZZATO);
  1374.                     trasmissioneNormale = false;
  1375.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_PRIMA_TRASMISSIONE_INVERTITA_TIPO_ORA_REGISTRAZIONE_CODE_SCONOSCIUTO == value) {
  1376.                     trasmissione.setTempo(TipoOraRegistrazione.UNKNOWN);
  1377.                     trasmissioneNormale = false;
  1378.                 } else {
  1379.                     trasmissione.setTempo(TipoOraRegistrazione.UNKNOWN);
  1380.                 }
  1381.                 
  1382.                 trasmissione.setTempoValue((String)oPrimaTrasmissioneTipoOraRegistrazione);
  1383.                 
  1384.                 if(trasmissioneNormale){
  1385.                     trasmissione.setOrigine(mittente.getNome());
  1386.                     trasmissione.setTipoOrigine(mittente.getTipo());
  1387.                     trasmissione.setIdentificativoPortaOrigine(mittente.getCodicePorta());
  1388.                     trasmissione.setIndirizzoOrigine(busta.getIndirizzoMittente());
  1389.                     
  1390.                     trasmissione.setDestinazione(destinatario.getNome());
  1391.                     trasmissione.setTipoDestinazione(destinatario.getTipo());
  1392.                     trasmissione.setIdentificativoPortaDestinazione(destinatario.getCodicePorta());
  1393.                     trasmissione.setIndirizzoDestinazione(busta.getIndirizzoDestinatario());
  1394.                 }
  1395.                 else{
  1396.                     trasmissione.setOrigine(destinatario.getNome());
  1397.                     trasmissione.setTipoOrigine(destinatario.getTipo());
  1398.                     trasmissione.setIdentificativoPortaOrigine(destinatario.getCodicePorta());
  1399.                     trasmissione.setIndirizzoOrigine(busta.getIndirizzoDestinatario());
  1400.                     
  1401.                     trasmissione.setDestinazione(mittente.getNome());
  1402.                     trasmissione.setTipoDestinazione(mittente.getTipo());
  1403.                     trasmissione.setIdentificativoPortaDestinazione(mittente.getCodicePorta());
  1404.                     trasmissione.setIndirizzoDestinazione(busta.getIndirizzoMittente());
  1405.                 }
  1406.                 
  1407.                 busta.addTrasmissione(trasmissione);
  1408.                 
  1409.             }       
  1410.             
  1411.             Object oSecondaTrasmissioneOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SECONDA_TRASMISSIONE_ORA_REGISTRAZIONE).getDato();
  1412.             Object oSecondaTrasmissioneTipoOraRegistrazione = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SECONDA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE).getDato();
  1413.             Object oSecondaTrasmissioneTipoOraRegistrazioneCode = infoSalvataggioTraccia.getDato(MappingRicostruzioneTraccia.TRACCIA_BUSTA_SECONDA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE_CODE).getDato();
  1414.     
  1415.             if(oSecondaTrasmissioneOraRegistrazione != null && oSecondaTrasmissioneTipoOraRegistrazione != null && oSecondaTrasmissioneTipoOraRegistrazioneCode != null) {
  1416.                 
  1417.                 Trasmissione trasmissione = new Trasmissione();
  1418.                 trasmissione.setOraRegistrazione((Date)oSecondaTrasmissioneOraRegistrazione);
  1419.                 
  1420.                 char value = ((Character)oSecondaTrasmissioneTipoOraRegistrazioneCode);
  1421.                 if(CostantiMappingTracciamento.TRACCIA_BUSTA_SECONDA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE_CODE_LOCALE == value) {
  1422.                     trasmissione.setTempo(TipoOraRegistrazione.LOCALE);
  1423.                 } else if(CostantiMappingTracciamento.TRACCIA_BUSTA_SECONDA_TRASMISSIONE_TIPO_ORA_REGISTRAZIONE_CODE_SINCRONIZZATO == value) {
  1424.                     trasmissione.setTempo(TipoOraRegistrazione.SINCRONIZZATO);
  1425.                 } else {
  1426.                     trasmissione.setTempo(TipoOraRegistrazione.UNKNOWN);
  1427.                 }
  1428.                 
  1429.                 trasmissione.setTempoValue((String)oSecondaTrasmissioneTipoOraRegistrazione);
  1430.                 
  1431.                 trasmissione.setOrigine(destinatario.getNome());
  1432.                 trasmissione.setTipoOrigine(destinatario.getTipo());
  1433.                 trasmissione.setIdentificativoPortaOrigine(destinatario.getCodicePorta());
  1434.                 trasmissione.setIndirizzoOrigine(busta.getIndirizzoDestinatario());
  1435.                 
  1436.                 trasmissione.setDestinazione(mittente.getNome());
  1437.                 trasmissione.setTipoDestinazione(mittente.getTipo());
  1438.                 trasmissione.setIdentificativoPortaDestinazione(mittente.getCodicePorta());
  1439.                 trasmissione.setIndirizzoDestinazione(busta.getIndirizzoMittente());
  1440.                 
  1441.                 busta.addTrasmissione(trasmissione);
  1442.                 
  1443.             }       
  1444.         }
  1445.         
  1446.         
  1447.         return busta;
  1448.         
  1449.     }
  1450.     
  1451.     
  1452.     private InformazioniRecordTraccia getInformazioniSalvataggioTraccia(
  1453.             JDBCServiceManager transazioniServiceManager,
  1454.             String idTransazione, RuoloMessaggio tipoTraccia,
  1455.             CredenzialiMittente credentialsFiller,
  1456.             Date minDate,
  1457.             Date maxDate) throws DriverTracciamentoException{

  1459.         try{
  1460.             
  1461.             ITransazioneServiceSearch transazioneServiceSearch = transazioniServiceManager.getTransazioneServiceSearch();
  1462.             
  1463.             IPaginatedExpression pagExpr = transazioneServiceSearch.newPaginatedExpression();
  1464.             if(maxDate!=null){
  1465.                 pagExpr.lessEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, maxDate); // ottimizzazione partizioni
  1466.             }
  1467.             if(minDate!=null){
  1468.                 pagExpr.greaterEquals(Transazione.model().DATA_INGRESSO_RICHIESTA, minDate); // ottimizzazione partizioni
  1469.             }
  1470.             pagExpr.equals(Transazione.model().ID_TRANSAZIONE,idTransazione);
  1471.             
  1472.             List<Map<String,Object>> selectField = null;
  1473.             if(RuoloMessaggio.RICHIESTA.equals(tipoTraccia)){
  1474.                 selectField = transazioneServiceSearch.select(pagExpr, Transazione.model().TRACCIA_RICHIESTA,
  1475.                         Transazione.model().TOKEN_CLIENT_ID);
  1476.             }else{
  1477.                 selectField = transazioneServiceSearch.select(pagExpr, Transazione.model().TRACCIA_RISPOSTA,
  1478.                         Transazione.model().TOKEN_CLIENT_ID);
  1479.             }
  1480.             
  1481.             if(selectField==null || selectField.isEmpty()){
  1482.                 throw new DriverTracciamentoException("Recupero informazioni per ricostruire la traccia [isRichiesta:"+
  1483.                         tipoTraccia+"] non riuscito. Transazione con ID["+
  1484.                         idTransazione+"] non presente?");
  1485.             }
  1486.             if(selectField.size()>1){
  1487.                 throw new DriverTracciamentoException("Recupero informazioni per ricostruire la traccia [isRichiesta:"+
  1488.                         tipoTraccia+"] non riuscito. Trovata piu' di una Transazione con ID["+
  1489.                         idTransazione+"]?");
  1490.             }
  1491.             
  1492.             Map<String,Object> dbValue = selectField.get(0);
  1493.             
  1494.             String dbValueTraccia =null;
  1495.             if(RuoloMessaggio.RICHIESTA.equals(tipoTraccia)){
  1496.                 dbValueTraccia = this.readValue(dbValue, Transazione.model().TRACCIA_RICHIESTA, idTransazione);
  1497.             }
  1498.             else {
  1499.                 dbValueTraccia = this.readValue(dbValue, Transazione.model().TRACCIA_RISPOSTA, idTransazione);
  1500.             }
  1501.             if(dbValueTraccia==null){
  1502.                 return null;
  1503.             }
  1504.             
  1505.             InformazioniRecordTraccia info = InformazioniRecordTraccia.convertoFromDBColumnValue(dbValueTraccia);
  1506.             this.logDebug("RECUPERO ["+info.toString()+"]");
  1507.             
  1508.             
  1509.             if(credentialsFiller!=null) {
  1510.                 String dbValueTokenClientId = this.readValue(dbValue, Transazione.model().TOKEN_CLIENT_ID, idTransazione);
  1511.                 if(dbValueTokenClientId!=null && StringUtils.isNotEmpty(dbValueTokenClientId)) {
  1512.                     CredenzialeMittente credenzialeClientId = getCredenzialeMittente(transazioniServiceManager, dbValueTokenClientId, idTransazione);
  1513.                     credentialsFiller.setTokenClientId(credenzialeClientId);
  1514.                 }
  1515.             }
  1516.             
  1517.             
  1518.             return info;
  1519.                 
  1520.         }catch(Exception e){
  1521.             throw new DriverTracciamentoException("Riscontrato errore durante la lettura dei dati (Transazione:"+idTransazione+"): "+e.getMessage(),e);
  1522.         }
  1523.     }
  1524.     
  1525.     private CredenzialeMittente getCredenzialeMittente(JDBCServiceManager transazioniServiceManager, String dbValueTokenClientId, String idTransazione) throws ServiceException, NotImplementedException, MultipleResultException{
  1526.         CredenzialeMittente credenzialeClientId = null;
  1527.         long id = -1;
  1528.         try {
  1529.             IDBCredenzialeMittenteServiceSearch credenzialeMittenteServiceSearch = (IDBCredenzialeMittenteServiceSearch) transazioniServiceManager.getCredenzialeMittenteServiceSearch();
  1530.             id = Long.parseLong(dbValueTokenClientId);
  1531.             credenzialeClientId = credenzialeMittenteServiceSearch.get(id);
  1532.             this.logDebug("RECUPERATO CLIENT ID ["+credenzialeClientId+"] per id ["+idTransazione+"]");
  1533.         }catch(NotFoundException notFound) {
  1534.             credenzialeClientId = new CredenzialeMittente();
  1535.             credenzialeClientId.setId(id);
  1536.             credenzialeClientId.setCredenziale("Informazione non disponibile");
  1537.         }
  1538.         return credenzialeClientId;
  1539.     }
  1540.     
  1541.     private String readValue(Map<String,Object> dbValue, IField field, String idTransazione) throws DriverTracciamentoException{
  1542.         Object objectDBValue = dbValue.get(field.getFieldName());
  1543.         String dbValueAsString = null;
  1544.         if((objectDBValue instanceof org.apache.commons.lang.ObjectUtils.Null)){
  1545.             objectDBValue = null;
  1546.         }
  1547.         if(objectDBValue!=null){
  1548.             if( ! (objectDBValue instanceof String)){
  1549.                 throw new DriverTracciamentoException("Recupero informazioni per ricostruire la traccia non riuscito. Trovato campo '"+field.getFieldName()
  1550.                 +"' di tipo ["+objectDBValue.getClass().getName()
  1551.                 +"] differente da quello atteso ["+String.class.getName()+"] per la Transazione con ID["+
  1552.                 idTransazione+"]?");
  1553.             }
  1554.             else{
  1555.                 dbValueAsString = (String) objectDBValue;
  1556.             }
  1557.         }
  1558.         return dbValueAsString;
  1559.     }

  1561. }
Created with JaCoCo 0.8.8.202204050719