GestoreTransazioniStateful.java

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

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.commons.dao.DAOFactory;
  28. import org.openspcoop2.core.config.OpenspcoopAppender;
  29. import org.openspcoop2.core.config.Property;
  30. import org.openspcoop2.core.config.utils.OpenSPCoopAppenderUtilities;
  31. import org.openspcoop2.core.transazioni.Transazione;
  32. import org.openspcoop2.core.transazioni.constants.RuoloTransazione;
  33. import org.openspcoop2.core.transazioni.dao.ITransazioneService;
  34. import org.openspcoop2.generic_project.beans.UpdateField;
  35. import org.openspcoop2.generic_project.exception.NotFoundException;
  36. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  37. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  38. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  39. import org.openspcoop2.protocol.sdk.diagnostica.IDiagnosticProducer;
  40. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  41. import org.openspcoop2.protocol.sdk.dump.IDumpProducer;
  42. import org.openspcoop2.protocol.sdk.dump.Messaggio;
  43. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaProducer;
  44. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  45. import org.openspcoop2.protocol.utils.EsitiProperties;
  46. import org.slf4j.Logger;


  49. /**     
  50.  * GestoreTransazioniStateful
  51.  *
  52.  * @author Poli Andrea (poli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class GestoreTransazioniStateful {

  58.     private Logger log = null;
  59.     private Logger logSql = null;
  60. //  private String datasource = null;
  61.     private String tipoDatabase = null;
  62.     private boolean debug = false;
  63.     
  64.     private ITracciaProducer tracciamentoOpenSPCoopAppender = null;
  65.     private IDiagnosticProducer msgDiagnosticiOpenSPCoopAppender = null;
  66.     private IDumpProducer dumpOpenSPCoopAppender = null;
  67.     private boolean transazioniRegistrazioneDumpHeadersCompactEnabled = false;
  68.     
  69.     public GestoreTransazioniStateful(Logger log,Logger logSql,
  70.             //String dataSource,
  71.             String tipoDatabase,boolean debug) throws Exception{
  72.         
  73.         this.log = log;
  74.         this.logSql = logSql;
  75.         this.tipoDatabase = tipoDatabase;
  76. //      this.datasource = dataSource;
  77.         this.debug = debug;
  78.             
  79.         boolean usePdDConnection = true;
  80.         
  81.         try{
  82.             
  83.             // Init
  84.             this.tracciamentoOpenSPCoopAppender = new org.openspcoop2.pdd.logger.TracciamentoOpenSPCoopProtocolAppender();
  85.             OpenspcoopAppender tracciamentoOpenSPCoopAppender = new OpenspcoopAppender();
  86.             tracciamentoOpenSPCoopAppender.setTipo("__gestoreTransazioniStateful");
  87.             List<Property> tracciamentoOpenSPCoopAppenderProperties = new ArrayList<Property>();

  89.             // Verra poi utilizzata la connessione ottenuta ogni volta che il timer viene eseguito, infatti si usa usePdDConnection
  90.             OpenSPCoopAppenderUtilities.addParameters(this.logSql, tracciamentoOpenSPCoopAppenderProperties, 
  91.                     null, // nessun datasource
  92.                     null, null, null, null,  // nessuna connection
  93.                     this.tipoDatabase,
  94.                     usePdDConnection, // viene usata la connessione della PdD 
  95.                     this.debug
  96.                     );
  97.             OpenSPCoopAppenderUtilities.addCheckProperties(tracciamentoOpenSPCoopAppenderProperties, false);

  99.             tracciamentoOpenSPCoopAppender.setPropertyList(tracciamentoOpenSPCoopAppenderProperties);
  100.             this.tracciamentoOpenSPCoopAppender.initializeAppender(tracciamentoOpenSPCoopAppender);
  101.             this.tracciamentoOpenSPCoopAppender.isAlive();
  102.             
  103.         }catch(Exception e){
  104.             throw new Exception("Errore durante l'inizializzazione del TracciamentoAppender: "+e.getMessage(),e);
  105.         } 
  106.         
  107.         try{
  108.             
  109.             // Init
  110.             this.msgDiagnosticiOpenSPCoopAppender = new org.openspcoop2.pdd.logger.MsgDiagnosticoOpenSPCoopProtocolAppender();
  111.             OpenspcoopAppender diagnosticoOpenSPCoopAppender = new OpenspcoopAppender();
  112.             diagnosticoOpenSPCoopAppender.setTipo("__gestoreTransazioniStateful");
  113.             List<Property> diagnosticoOpenSPCoopAppenderProperties = new ArrayList<Property>();

  115.             // Verra poi utilizzata la connessione ottenuta ogni volta che il timer viene eseguito, infatti si usa usePdDConnection
  116.             OpenSPCoopAppenderUtilities.addParameters(this.logSql, diagnosticoOpenSPCoopAppenderProperties, 
  117.                     null, // nessun datasource
  118.                     null, null, null, null,  // nessuna connection
  119.                     this.tipoDatabase,
  120.                     usePdDConnection, // viene usata la connessione della PdD
  121.                     this.debug
  122.                     );
  123.             OpenSPCoopAppenderUtilities.addCheckProperties(diagnosticoOpenSPCoopAppenderProperties, false);

  125.             diagnosticoOpenSPCoopAppender.setPropertyList(diagnosticoOpenSPCoopAppenderProperties);
  126.             this.msgDiagnosticiOpenSPCoopAppender.initializeAppender(diagnosticoOpenSPCoopAppender);
  127.             this.msgDiagnosticiOpenSPCoopAppender.isAlive();
  128.             
  129.         }catch(Exception e){
  130.             throw new Exception("Errore durante l'inizializzazione del DiagnosticoAppender: "+e.getMessage(),e);
  131.         } 
  132.         
  133.         try{
  134.             
  135.             // Init
  136.             this.dumpOpenSPCoopAppender = new org.openspcoop2.pdd.logger.DumpOpenSPCoopProtocolAppender();
  137.             OpenspcoopAppender dumpOpenSPCoopAppender = new OpenspcoopAppender();
  138.             dumpOpenSPCoopAppender.setTipo("__gestoreTransazioniStateful");
  139.             List<Property> dumpOpenSPCoopAppenderProperties = new ArrayList<Property>();

  141.             // Verra poi utilizzata la connessione ottenuta ogni volta che il timer viene eseguito, infatti si usa usePdDConnection
  142.             OpenSPCoopAppenderUtilities.addParameters(this.logSql, dumpOpenSPCoopAppenderProperties, 
  143.                     null, // nessun datasource
  144.                     null, null, null, null,  // nessuna connection
  145.                     this.tipoDatabase,
  146.                     usePdDConnection, // viene usata la connessione della PdD
  147.                     this.debug
  148.                     );
  149.             OpenSPCoopAppenderUtilities.addCheckProperties(dumpOpenSPCoopAppenderProperties, false);

  151.             dumpOpenSPCoopAppender.setPropertyList(dumpOpenSPCoopAppenderProperties);
  152.             this.dumpOpenSPCoopAppender.initializeAppender(dumpOpenSPCoopAppender);
  153.             this.dumpOpenSPCoopAppender.isAlive();
  154.             
  155.             // Indicazioni sulle modalita' di salvataggio degli header del dump
  156.             this.transazioniRegistrazioneDumpHeadersCompactEnabled = OpenSPCoop2Properties.getInstance().isTransazioniRegistrazioneDumpHeadersCompactEnabled();
  157.             
  158.         }catch(Exception e){
  159.             throw new Exception("Errore durante l'inizializzazione del DumpAppender: "+e.getMessage(),e);
  160.         } 

  162.     }
  163.     
  164.     
  165.     public void verificaOggettiPresentiRepository(DAOFactory daoFactory,  ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni,
  166.             Logger daoFactoryLoggerTransazioni, Connection con) throws Exception{
  167.         
  168.         
  169.         try{
  170.             if(this.debug)
  171.                 this.log.debug("\n\n****************************************************************************************************");
  172.             boolean autoCommit = false;
  173.             con.setAutoCommit(autoCommit);
  174.         
  175.             
  176.             org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager jdbcServiceManager =
  177.                     (org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager) daoFactory.getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(), 
  178.                             con, autoCommit,
  179.                             daoFactoryServiceManagerPropertiesTransazioni, daoFactoryLoggerTransazioni);
  180.             jdbcServiceManager.getJdbcProperties().setShowSql(this.debug);
  181.             ITransazioneService transazioneService = jdbcServiceManager.getTransazioneService();
  182.             
  183.             int size = RepositoryGestioneStateful.size();
  184.             if(this.debug)
  185.                 this.log.debug("Trovati "+size+" elementi da gestire");
  186.             while(size>0){
  187.                 
  188.                 StatefulObject so = RepositoryGestioneStateful.removeObject();
  189.                 try{
  190.                     
  191.                     String type = "";
  192.                     if(so.getType()!=null){
  193.                         type = so.getType().toString();
  194.                     }
  195.                     String className = "";
  196.                     if(so.getObject()!=null){
  197.                         type = so.getObject().getClass().getName();
  198.                     }
  199.                     String idTransazione = "";
  200.                     if(so.getObject()!=null){
  201.                         idTransazione = so.getIdTransazione();
  202.                     }
  203.                     
  204.                     if(so.getIdTransazione()==null){
  205.                         throw new Exception("Oggetto presente nel repository (Tipo:"+type+")(Class:"+className+") senza associato un id di transazione");
  206.                     }
  207.                     if(so.getType()==null){
  208.                         throw new Exception("Oggetto presente nel repository (ID:"+idTransazione+")(Class:"+className+") senza associato un tipo");
  209.                     }
  210.                     if(so.getObject()==null){
  211.                         throw new Exception("Oggetto presente nel repository (ID:"+idTransazione+")(Tipo:"+type+") senza un valore");
  212.                     }
  213.                     
  214.                     if(this.debug)
  215.                         this.log.debug("-------------- "+so.getType().toString()+"/"+so.getObject().getClass().getName()+"/"+so.getIdTransazione()+" --------------");
  216.                     
  217.                     TransactionDB transactionDB = readTransazione(transazioneService, so.getIdTransazione());
  218.                     if(transactionDB==null){
  219.                         // Transazione non ancora inserita nel database dal modulo PostOutResponseHandler
  220.                         if(this.debug)
  221.                             this.log.debug("Transazione non ancora presente, reinserisco nel repository");
  222.                         RepositoryGestioneStateful.addObject(so);
  223.                         continue;
  224.                     }
  225.                     
  226.                     gestioneStatefulObject(transazioneService, con, so, transactionDB,true);
  227.                     
  228.                     con.commit();
  229.                     if(this.debug)
  230.                         this.log.debug("Commit eseguito con successo");
  231.                     
  232.                 }catch(Exception e){
  233.                     try{
  234.                         if(this.debug)
  235.                             this.log.debug("Errore durante la gestione dell'oggetto (reinserisco nel repository): "+e.getMessage());
  236.                         RepositoryGestioneStateful.addObject(so);
  237.                         con.rollback();
  238.                     }catch(Exception eRollback){}
  239.                     throw e;
  240.                 }finally{
  241.                     size--;
  242.                 }
  243.             }
  244.                                     
  245.             
  246.         }finally{
  247.             try{
  248.                 con.setAutoCommit(true);
  249.             }catch(Exception eRollback){
  250.                 // ignore
  251.             }
  252.         }
  253.         
  254.     }
  255.     
  256.     public void gestioneStatefulObject(ITransazioneService transazioneService,Connection con,StatefulObject so) throws Exception{
  257.         gestioneStatefulObject(transazioneService, con, so, null,false);
  258.     }
  259.     public void gestioneStatefulObject(ITransazioneService transazioneService,Connection con,StatefulObject so,TransactionDB transactionDB) throws Exception{
  260.         gestioneStatefulObject(transazioneService, con, so, transactionDB,false);
  261.     }
  262.     private void gestioneStatefulObject(ITransazioneService transazioneService,Connection con,StatefulObject so,TransactionDB transactionDB,boolean thread) throws Exception{
  263.         
  264.         String tipoGestione = "[Thread] ";
  265.         if(!thread)
  266.             tipoGestione = "[GestioneDiretta] ";
  267.         
  268.         switch (so.getType()) {
  269.         case MSGDIAGNOSTICO:
  270.             
  271.             this.msgDiagnosticiOpenSPCoopAppender.log(con,(MsgDiagnostico)so.getObject());      
  272.             if(this.debug)
  273.                 this.log.debug(tipoGestione+"MsgDiagnostico inserito nel database");
  274.             
  275.             break;
  276.         
  277.         case TRACCIA:
  278.             
  279.             Traccia traccia = (Traccia) so.getObject();
  280.             this.tracciamentoOpenSPCoopAppender.log(con, traccia);
  281.             if(this.debug)
  282.                 this.log.debug(tipoGestione+"Traccia ("+traccia.getTipoMessaggio()+") inserita nel database");
  283.             
  284.             break;
  285.             
  286.         case MESSAGGIO:
  287.             
  288.             this.dumpOpenSPCoopAppender.dump(con, (Messaggio)so.getObject(), this.transazioniRegistrazioneDumpHeadersCompactEnabled);       
  289.             if(this.debug)
  290.                 this.log.debug(tipoGestione+"DumpMessaggio inserito nel database");
  291.             
  292.             break;
  293.             
  294. //      case DATA_USCITA_RICHIESTA:
  295. //          
  296. //          updateDataUscitaRichiesta(transazioneService, (Date)so.getObject(), so.getIdTransazione());
  297. //          if(this.debug)
  298. //              this.log.debug(tipoGestione+"Informazione sulla data di uscita della richiesta aggiornata");
  299. //          
  300. //          break;
  301. //          
  302. //      case DATA_INGRESSO_RISPOSTA:
  303. //          
  304. //          updateDataIngressoRisposta(transazioneService, (Date)so.getObject(), so.getIdTransazione());
  305. //          if(this.debug)
  306. //              this.log.debug(tipoGestione+"Informazione sulla data di ingresso della risposta aggiornata");
  307. //          
  308. //          break;
  309. //          
  310. //      case DIMENSIONE_USCITA_RICHIESTA:
  311. //          
  312. //          updateDimensioneUscitaRichiesta(transazioneService, (Long)so.getObject(), so.getIdTransazione());
  313. //          if(this.debug)
  314. //              this.log.debug(tipoGestione+"Informazione sulla dimensione di uscita della richiesta aggiornata");
  315. //          
  316. //          break;
  317. //          
  318. //      case DIMENSIONE_INGRESSO_RISPOSTA:
  319. //          
  320. //          updateDimensioneIngressoRisposta(transazioneService, (Long)so.getObject(), so.getIdTransazione());
  321. //          if(this.debug)
  322. //              this.log.debug(tipoGestione+"Informazione sulla dimensione di ingresso della risposta aggiornata");
  323. //          
  324. //          break;
  325. //          
  326. //      case LOCATION:
  327. //          
  328. //          updateLocationConnettore(transazioneService, (String)so.getObject(), so.getIdTransazione());
  329. //          if(this.debug)
  330. //              this.log.debug(tipoGestione+"Informazione sulla location aggiornata");
  331. //          
  332. //          break;
  333. //          
  334. //      case TIPO_CONNETTORE:
  335. //          
  336. //          updateTipoConnettore(transazioneService, (String)so.getObject(), so.getIdTransazione());
  337. //          if(this.debug)
  338. //              this.log.debug(tipoGestione+"Informazione sul tipo di connettore aggiornata");
  339. //          
  340. //          break;
  341. //          
  342. //      case CODICE_TRASPORTO_RICHIESTA:
  343. //          
  344. //          updateCodiceTrasportoRichiesta(transazioneService, (String)so.getObject(), so.getIdTransazione());
  345. //          if(this.debug)
  346. //              this.log.debug(tipoGestione+"Informazione sul codice di trasporto aggiornata");
  347. //          
  348. //          break;
  349. //          
  350. //      case SCENARIO_COOPERAZIONE:
  351. //          
  352. //          updateScenarioDiCooperazione(transazioneService, (String)so.getObject(), so.getIdTransazione());
  353. //          if(this.debug)
  354. //              this.log.debug(tipoGestione+"Informazione sullo scenario di cooperazione aggiornata");
  355. //          
  356. //          break;
  357.             
  358.         case OUT_REQUEST_STATEFUL_OBJECT:
  359.             
  360.             updateOutRequestStatefulObject(transazioneService, (OutRequestStatefulObject)so.getObject(), so.getIdTransazione());
  361.             if(this.debug)
  362.                 this.log.debug(tipoGestione+"Informazione emesse dall'out request handler aggiornate");
  363.             
  364.             break;
  365.         
  366.         case IN_RESPONSE_STATEFUL_OBJECT:
  367.             
  368.             updateInResponseStatefulObject(transazioneService, (InResponseStatefulObject)so.getObject(), so.getIdTransazione());
  369.             if(this.debug)
  370.                 this.log.debug(tipoGestione+"Informazione emesse dall'in response handler aggiornate");
  371.             
  372.             break;
  373.         }
  374.     }
  375.     
  376.     
  377.     public TransactionDB readTransazione(ITransazioneService transazioneService,String idTransazione) throws Exception{
  378.         
  379.         IPaginatedExpression expression = transazioneService.newPaginatedExpression();
  380.         expression.equals(Transazione.model().ID_TRANSAZIONE, idTransazione);
  381.         
  382.         List<Map<String, Object>> result = null;
  383.         try{
  384.             result = transazioneService.select(expression,
  385.                     Transazione.model().PROTOCOLLO,Transazione.model().ESITO, Transazione.model().ESITO_CONTESTO);
  386.             if(result==null || result.size()<=0){
  387.                 if(this.debug){
  388.                     this.log.debug("Transazione con id ["+idTransazione+"] non trovata");
  389.                 }
  390.                 return null;
  391.             }
  392.         }catch(NotFoundException notFound){
  393.             if(this.debug){
  394.                 this.log.debug("Transazione con id ["+idTransazione+"] non trovata (DriverNotFound): "+notFound.getMessage());
  395.             }
  396.             return null;
  397.         }
  398.         if(result.size()>1){
  399.             if(this.debug){
  400.                 this.log.debug("Trovata piu' di una Transazione con id ["+idTransazione+"]");
  401.             }
  402.         }
  403.         Map<String, Object> map = result.remove(0);
  404.         
  405.         TransactionDB tr = new TransactionDB();
  406.         tr.setIdTransazione(idTransazione);
  407.                 
  408.         Object oProtocollo = map.get(Transazione.model().PROTOCOLLO.getFieldName());
  409.         if(oProtocollo==null || !(oProtocollo instanceof String) ){
  410.             throw new Exception("Salvata transazione senza protocollo ["+oProtocollo+"]");
  411.         }
  412.         String protocollo = (String) oProtocollo;
  413.         
  414.         Object oEsito = map.get(Transazione.model().ESITO.getFieldName());
  415.         if(oEsito==null || !(oEsito instanceof Integer) ){
  416.             throw new Exception("Salvata transazione senza esito ["+oEsito+"]");
  417.         }
  418.         Integer esito = (Integer) oEsito;
  419.         
  420.         Object oEsitoContesto = map.get(Transazione.model().ESITO_CONTESTO.getFieldName());
  421.         if(oEsitoContesto==null || !(oEsitoContesto instanceof String) ){
  422.             throw new Exception("Salvata transazione senza esito contesto ["+oEsitoContesto+"]");
  423.         }
  424.         String esitoContesto = (String) oEsitoContesto;
  425.         
  426.         tr.setEsitoTransazione(EsitiProperties.getInstanceFromProtocolName(this.log,protocollo).convertToEsitoTransazione(esito, esitoContesto));
  427.         
  428.         if(this.debug){
  429.             this.log.debug("Trovata transazione");
  430.         }
  431.         return tr;
  432.         
  433.     }
  434.     
  435.     
  436. //  private void updateDataUscitaRichiesta(ITransazioneService transazioneService,Date data,String idTransazione) throws Exception{
  437. //      
  438. //      UpdateField updateField = new UpdateField(Transazione.model().DATA_USCITA_RICHIESTA, data);
  439. //      transazioneService.updateFields(idTransazione, updateField);
  440. //      
  441. //  }
  442. //  
  443. //  private void updateDataIngressoRisposta(ITransazioneService transazioneService,Date data,String idTransazione) throws Exception{
  444. //      
  445. //      UpdateField updateField = new UpdateField(Transazione.model().DATA_INGRESSO_RISPOSTA, data);
  446. //      transazioneService.updateFields(idTransazione, updateField);
  447. //      
  448. //  }
  449. //  
  450. //  private void updateDimensioneUscitaRichiesta(ITransazioneService transazioneService,Long dimensione,String idTransazione) throws Exception{
  451. //      
  452. //      UpdateField updateField = new UpdateField(Transazione.model().RICHIESTA_USCITA_BYTES, dimensione);
  453. //      transazioneService.updateFields(idTransazione, updateField);
  454. //  
  455. //  }
  456. //  
  457. //  private void updateDimensioneIngressoRisposta(ITransazioneService transazioneService,Long dimensione,String idTransazione) throws Exception{
  458. //      
  459. //      UpdateField updateField = new UpdateField(Transazione.model().RISPOSTA_INGRESSO_BYTES, dimensione);
  460. //      transazioneService.updateFields(idTransazione, updateField);
  461. //      
  462. //  }
  463. //  
  464. //  private void updateLocationConnettore(ITransazioneService transazioneService,String value,String idTransazione) throws Exception{
  465. //      
  466. //      UpdateField updateField = new UpdateField(Transazione.model().LOCATION_CONNETTORE, value);
  467. //      transazioneService.updateFields(idTransazione, updateField);
  468. //      
  469. //  }
  470. //  
  471. //  private void updateTipoConnettore(ITransazioneService transazioneService,String value,String idTransazione) throws Exception{
  472. //      
  473. //      // TODO leggere le attuali informazioni e aggiornarle
  474. //      
  475. //  }
  476. //  
  477. //  private void updateCodiceTrasportoRichiesta(ITransazioneService transazioneService,String value,String idTransazione) throws Exception{
  478. //      
  479. //      // TODO leggere le attuali informazioni e aggiornarle
  480. //      
  481. //  }
  482. //  
  483. //  
  484. //  private void updateScenarioDiCooperazione(ITransazioneService transazioneService,String value,String idTransazione) throws Exception{
  485. //      
  486. //      UpdateField updateField = new UpdateField(Transazione.model().RUOLO_TRANSAZIONE, value);
  487. //      transazioneService.updateFields(idTransazione, updateField);
  488. //      
  489. //  }
  490.     
  491.     private void updateOutRequestStatefulObject(ITransazioneService transazioneService,OutRequestStatefulObject object,String idTransazione) throws Exception{
  492.         
  493.         List<UpdateField> updateFields = new ArrayList<UpdateField>();
  494.         
  495.         if(object.getDataUscitaRichiesta()!=null){
  496.             UpdateField updateField = new UpdateField(Transazione.model().DATA_USCITA_RICHIESTA, object.getDataUscitaRichiesta());
  497.             updateFields.add(updateField);
  498.         }
  499.                     
  500.         RuoloTransazione ruolo = null;
  501.         if(object.getScenarioCooperazione()!=null){
  502.             ruolo = RuoloTransazione.getEnumConstantFromOpenSPCoopValue(object.getScenarioCooperazione());
  503.             UpdateField updateField = new UpdateField(Transazione.model().RUOLO_TRANSAZIONE, ruolo.getValoreAsInt());
  504.             updateFields.add(updateField);
  505.         }
  506.         
  507.         if(object.getLocation()!=null){
  508.             UpdateField updateField = new UpdateField(Transazione.model().LOCATION_CONNETTORE, object.getLocation());
  509.             updateFields.add(updateField);
  510.         }
  511.         
  512.         if(object.getTipoConnettore()!=null){
  513.             // TODO leggere le attuali informazioni e aggiornarle
  514.         }
  515.         
  516.         if(object.getServiziApplicativiErogatore()!=null && object.getServiziApplicativiErogatore().size()>0){
  517.             StringBuilder sa_erogatori = new StringBuilder();
  518.             for (int i=0; i<object.getServiziApplicativiErogatore().size(); i++) {
  519.                 if (i>0){
  520.                     sa_erogatori.append(",");
  521.                 }
  522.                 sa_erogatori.append( object.getServiziApplicativiErogatore().get(i) );
  523.             }
  524.             UpdateField updateField = new UpdateField(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE, sa_erogatori.toString());
  525.             updateFields.add(updateField);
  526.         }
  527.         
  528.         if(object.getEventiGestione()!=null && object.getEventiGestione().size()>0){
  529.             
  530.             StringBuilder bf = new StringBuilder();
  531.             for (String s : object.getEventiGestione()) {
  532.                 if(bf.length()>0){
  533.                     bf.append(",");
  534.                 }
  535.                 bf.append(s);
  536.             }
  537.             
  538.             String attuale = null;
  539.             try{
  540.                 IPaginatedExpression expression = transazioneService.newPaginatedExpression();
  541.                 expression.equals(Transazione.model().ID_TRANSAZIONE, idTransazione);
  542.                 List<Object> list = transazioneService.select(expression, Transazione.model().EVENTI_GESTIONE);
  543.                 if(list!=null && list.size()>0){
  544.                     Object o = list.get(0);
  545.                     if(o!=null && o instanceof String){
  546.                         attuale = (String) o;
  547.                     }
  548.                 }
  549.             }catch(NotFoundException notFound){}

  551.             if(attuale!=null){
  552.                 attuale = attuale + ",";
  553.                 attuale = attuale + bf.toString();
  554.             }
  555.             else{
  556.                 attuale = bf.toString();
  557.             }
  558.             
  559.             UpdateField updateField = new UpdateField(Transazione.model().EVENTI_GESTIONE, attuale);
  560.             updateFields.add(updateField);
  561.         }
  562.         
  563.         if(updateFields.size()>0)
  564.             transazioneService.updateFields(idTransazione, updateFields.toArray(new UpdateField[1]));
  565.         
  566.     }
  567.     
  568.     
  569.     private void updateInResponseStatefulObject(ITransazioneService transazioneService,InResponseStatefulObject object,String idTransazione) throws Exception{
  570.         
  571.         List<UpdateField> updateFields = new ArrayList<UpdateField>();
  572.         
  573.         if(object.getDataRichiestaInoltrata()!=null){
  574.             UpdateField updateField = new UpdateField(Transazione.model().DATA_USCITA_RICHIESTA_STREAM, object.getDataRichiestaInoltrata());
  575.             updateFields.add(updateField);
  576.         }
  577.         
  578.         if(object.getDataAccettazioneRisposta()!=null){
  579.             UpdateField updateField = new UpdateField(Transazione.model().DATA_ACCETTAZIONE_RISPOSTA, object.getDataAccettazioneRisposta());
  580.             updateFields.add(updateField);
  581.         }
  582.         
  583.         if(object.getDataIngressoRisposta()!=null){
  584.             UpdateField updateField = new UpdateField(Transazione.model().DATA_INGRESSO_RISPOSTA, object.getDataIngressoRisposta());
  585.             updateFields.add(updateField);
  586.         }
  587.         
  588.         if(object.getDataUscitaRichiesta()!=null){
  589.             UpdateField updateField = new UpdateField(Transazione.model().DATA_USCITA_RICHIESTA, object.getDataUscitaRichiesta());
  590.             updateFields.add(updateField);
  591.         }
  592.         
  593.         if(object.getLocation()!=null){
  594.             UpdateField updateField = new UpdateField(Transazione.model().LOCATION_CONNETTORE, object.getLocation());
  595.             updateFields.add(updateField);
  596.         }
  597.         
  598.         if(object.getReturnCode()!=null){
  599.             // TODO leggere le attuali informazioni e aggiornarle
  600.         }
  601.         
  602.         if(object.getFaultIntegrazione()!=null){
  603.             UpdateField updateField = new UpdateField(Transazione.model().FAULT_INTEGRAZIONE, object.getFaultIntegrazione());
  604.             updateFields.add(updateField);
  605.         }
  606.         
  607.         if(object.getFormatoFaultIntegrazione()!=null){
  608.             UpdateField updateField = new UpdateField(Transazione.model().FORMATO_FAULT_INTEGRAZIONE, object.getFormatoFaultIntegrazione());
  609.             updateFields.add(updateField);
  610.         }
  611.         
  612.         if(object.getFaultCooperazione()!=null){
  613.             UpdateField updateField = new UpdateField(Transazione.model().FAULT_COOPERAZIONE, object.getFaultCooperazione());
  614.             updateFields.add(updateField);
  615.         }
  616.         
  617.         if(object.getFormatoFaultCooperazione()!=null){
  618.             UpdateField updateField = new UpdateField(Transazione.model().FORMATO_FAULT_COOPERAZIONE, object.getFormatoFaultCooperazione());
  619.             updateFields.add(updateField);
  620.         }
  621.         
  622.         if(object.getEventiGestione()!=null && object.getEventiGestione().size()>0){
  623.             
  624.             StringBuilder bf = new StringBuilder();
  625.             for (String s : object.getEventiGestione()) {
  626.                 if(bf.length()>0){
  627.                     bf.append(",");
  628.                 }
  629.                 bf.append(s);
  630.             }
  631.             
  632.             String attuale = null;
  633.             try{
  634.                 IPaginatedExpression expression = transazioneService.newPaginatedExpression();
  635.                 expression.equals(Transazione.model().ID_TRANSAZIONE, idTransazione);
  636.                 List<Object> list = transazioneService.select(expression, Transazione.model().EVENTI_GESTIONE);
  637.                 if(list!=null && list.size()>0){
  638.                     Object o = list.get(0);
  639.                     if(o!=null && o instanceof String){
  640.                         attuale = (String) o;
  641.                     }
  642.                 }
  643.             }catch(NotFoundException notFound){}

  645.             if(attuale!=null){
  646.                 attuale = attuale + ",";
  647.                 attuale = attuale + bf.toString();
  648.             }
  649.             else{
  650.                 attuale = bf.toString();
  651.             }
  652.             
  653.             UpdateField updateField = new UpdateField(Transazione.model().EVENTI_GESTIONE, attuale);
  654.             updateFields.add(updateField);
  655.         }
  656.         
  657.         if(updateFields.size()>0)
  658.             transazioneService.updateFields(idTransazione, updateFields.toArray(new UpdateField[1]));
  659.         
  660.     }
  661.     
  662.     
  663. }
Created with JaCoCo 0.8.8.202204050719