FSRecoveryTransazioniApplicativoServerImpl.java

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

  22. import java.io.File;
  23. import java.sql.Connection;

  25. import org.openspcoop2.core.commons.dao.DAOFactory;
  26. import org.openspcoop2.core.transazioni.TransazioneApplicativoServer;
  27. import org.openspcoop2.core.transazioni.utils.TransactionServerUtils;
  28. import org.openspcoop2.core.transazioni.utils.serializer.JaxbDeserializer;
  29. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  30. import org.openspcoop2.protocol.sdk.constants.EsitoTransazioneName;
  31. import org.openspcoop2.protocol.utils.EsitiProperties;
  32. import org.openspcoop2.utils.UtilsException;
  33. import org.openspcoop2.utils.UtilsMultiException;
  34. import org.slf4j.Logger;

  36. /**
  37.  * FSRecoveryTransazioniImpl
  38.  *
  39.  * @author Poli Andrea (apoli@link.it)
  40.  * @author $Author$
  41.  * @version $Rev$, $Date$
  42.  */
  43. public class FSRecoveryTransazioniApplicativoServerImpl extends AbstractFSRecovery {
  44.     private org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM;
  45.     private DAOFactory daoFactory;
  46.     private Logger daoFactoryLogger;
  47.     private ServiceManagerProperties daoFactoryServiceManagerProperties;
  48.     private long gestioneSerializableDBAttesaAttiva;
  49.     private int gestioneSerializableDBCheckInterval;
  50.     
  51.     public FSRecoveryTransazioniApplicativoServerImpl( 
  52.             Logger log,
  53.             boolean debug,
  54.             DAOFactory daoFactory, Logger daoFactoryLogger, ServiceManagerProperties daoFactoryServiceManagerProperties,
  55.             long gestioneSerializableDBAttesaAttiva, int gestioneSerializableDBCheckInterval,
  56.             org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM, 
  57.             File directory, File directoryDLQ,
  58.             int tentativi,
  59.             long msAttesaProcessingFile) {
  60.         super(log, debug, directory, directoryDLQ, tentativi, msAttesaProcessingFile);
  61.         
  62.         this.transazioniSM = transazioniSM;
  63.         this.daoFactory = daoFactory;
  64.         this.daoFactoryLogger = daoFactoryLogger;
  65.         this.daoFactoryServiceManagerProperties = daoFactoryServiceManagerProperties;
  66.         this.gestioneSerializableDBAttesaAttiva = gestioneSerializableDBAttesaAttiva;
  67.         this.gestioneSerializableDBCheckInterval = gestioneSerializableDBCheckInterval;
  68.     }

  70.     @Override
  71.     public void process(Connection connection) {
  72.         this.log.info("Recovery TransazioneServerApplicativo ...");
  73.         super.process(connection);
  74.         this.log.info("Recovery TransazioneServerApplicativo completato");
  75.     }
  76.     
  77.     @Override
  78.     public void insertObject(File file, Connection connection) throws UtilsException, UtilsMultiException {
  79.         JaxbDeserializer deserializer = new JaxbDeserializer();
  80.         boolean ripristinato = false;
  81.         TransazioneApplicativoServer transazioneApplicativoServer = null;
  82.         try {
  83.             transazioneApplicativoServer = deserializer.readTransazioneApplicativoServer(file);
  84.             ripristinato = TransactionServerUtils.recover(this.transazioniSM.getTransazioneApplicativoServerService(), transazioneApplicativoServer);
  85.         }catch(Exception e) {
  86.             throw new UtilsException(e.getMessage(),e);
  87.         }
  88.         if(ripristinato) {
  89.             
  90.             int esitoConsegnaMultipla = -1;
  91.             int esitoConsegnaMultiplaInCorso = -1;
  92.             int esitoConsegnaMultiplaFallita = -1;
  93.             int esitoConsegnaMultiplaCompletata = -1;
  94.             int ok = -1;
  95.             int esitoIntegrationManagerSingolo = -1;
  96.             boolean esitiLetti = false;
  97.             try {
  98.                 EsitiProperties esitiProperties = EsitiProperties.getInstanceFromProtocolName(this.log, transazioneApplicativoServer.getProtocollo());
  99.                 esitoConsegnaMultipla = esitiProperties.convertoToCode(EsitoTransazioneName.CONSEGNA_MULTIPLA);
  100.                 esitoConsegnaMultiplaInCorso = esitiProperties.convertoToCode(EsitoTransazioneName.CONSEGNA_MULTIPLA_IN_CORSO);
  101.                 esitoConsegnaMultiplaFallita = esitiProperties.convertoToCode(EsitoTransazioneName.CONSEGNA_MULTIPLA_FALLITA);
  102.                 esitoConsegnaMultiplaCompletata = esitiProperties.convertoToCode(EsitoTransazioneName.CONSEGNA_MULTIPLA_COMPLETATA);
  103.                 ok = esitiProperties.convertoToCode(EsitoTransazioneName.OK);
  104.                 esitoIntegrationManagerSingolo = esitiProperties.convertoToCode(EsitoTransazioneName.MESSAGE_BOX);
  105.                 esitiLetti = true;          
  106.             }catch(Exception er) {
  107.                 // errore che non dovrebbe succedere
  108.                 String msg = "Errore durante l'aggiornamento delle transazione relativamente all'informazione del server '"+transazioneApplicativoServer.getServizioApplicativoErogatore()+"': (readEsiti) " + er.getMessage();
  109.                 this.log.error("["+transazioneApplicativoServer.getIdTransazione()+"] "+msg,er);
  110.             }
  111.             
  112.             if(esitiLetti) {
  113.                 
  114.                 try{
  115.                 
  116.                     boolean autoCommit = false;
  117.                     try {
  118.                         connection.setAutoCommit(autoCommit);
  119.                     }catch(Exception e) {
  120.                         throw new UtilsException(e.getMessage(),e);
  121.                     }
  122.                     
  123.                     @SuppressWarnings("unused")
  124.                     boolean isMessaggioConsegnato = false;
  125.                     boolean possibileTerminazioneSingleIntegrationManagerMessage = false;
  126.                     boolean consegnaInErrore = false;
  127.                     // consegna terminata
  128.                     if(transazioneApplicativoServer.isConsegnaTerminata()) {
  129.                         isMessaggioConsegnato = true;
  130.                     }
  131.                     else if(transazioneApplicativoServer.getDataEliminazioneIm()!=null ||
  132.                             transazioneApplicativoServer.getDataMessaggioScaduto()!=null) {
  133.                         isMessaggioConsegnato = true;
  134.                         possibileTerminazioneSingleIntegrationManagerMessage = true;
  135.                     }
  136.                     else if(transazioneApplicativoServer.isConsegnaTrasparente() && transazioneApplicativoServer.getNumeroTentativi()>0) {
  137.                         // !transazioneApplicativoServer.isConsegnaTerminata() altrimenti entrava nel primo if
  138.                         consegnaInErrore = true;
  139.                     }
  140.                     
  141.                     // Grazie all'istruzione sopra 'boolean ripristinato = TransactionServerUtils.recover' entro nell'if solo se la consegna e' quella terminata
  142.                     /**if(isMessaggioConsegnato) {*/ 
  143.                     TransactionServerUtils.safeAggiornaInformazioneConsegnaTerminata(transazioneApplicativoServer, connection, 
  144.                             this.daoFactoryServiceManagerProperties.getDatabaseType(), this.log,
  145.                             this.daoFactory,this.daoFactoryLogger,this.daoFactoryServiceManagerProperties,
  146.                             this.debug,
  147.                             esitoConsegnaMultipla, esitoConsegnaMultiplaInCorso, esitoConsegnaMultiplaFallita, esitoConsegnaMultiplaCompletata, ok,
  148.                             esitoIntegrationManagerSingolo, possibileTerminazioneSingleIntegrationManagerMessage, consegnaInErrore,
  149.                             this.gestioneSerializableDBAttesaAttiva,this.gestioneSerializableDBCheckInterval,
  150.                             null);
  151.                     /**}*/
  152.                     
  153.                 }finally{
  154.                     
  155.                     try{
  156.                         connection.setAutoCommit(true);
  157.                     }catch(Exception eRollback){
  158.                         // ignore
  159.                     }
  160.                 }
  161.             }

  163.         }
  164.     }


  167. }
Created with JaCoCo 0.8.8.202204050719