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




  24. package org.openspcoop2.pdd.timers;

  26. import java.sql.Connection;
  27. import java.util.ArrayList;
  28. import java.util.List;

  30. import javax.rmi.PortableRemoteObject;

  32. import org.openspcoop2.pdd.config.DBManager;
  33. import org.openspcoop2.pdd.config.DBStatisticheManager;
  34. import org.openspcoop2.pdd.config.DBTransazioniManager;
  35. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  36. import org.openspcoop2.pdd.config.Resource;
  37. import org.openspcoop2.pdd.core.GestoreMessaggi;
  38. import org.openspcoop2.utils.TipiDatabase;
  39. import org.openspcoop2.utils.id.serial.InfoStatistics;
  40. import org.openspcoop2.utils.resources.GestoreJNDI;
  41. import org.openspcoop2.utils.semaphore.Semaphore;
  42. import org.openspcoop2.utils.semaphore.SemaphoreConfiguration;
  43. import org.openspcoop2.utils.semaphore.SemaphoreMapping;
  44. import org.slf4j.Logger;

  46. /**
  47.  * Libreria contenente metodi utili per lo smistamento delle buste 
  48.  * all'interno dei moduli di openspcoop realizzati tramite servizi.
  49.  *
  50.  * @author Poli Andrea (apoli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */

  55. public class TimerUtils {
  56.     
  57.   
  58.    

  60.     /**
  61.      * Metodo che si occupa di ottenere il EJB utile alla gestione dei Riscontri Scaduti
  62.      *
  63.      * @return un EJB utile alla gestione dei riscontri scaduti {@link org.openspcoop2.pdd.timers.TimerGestoreBusteNonRiscontrate}.
  64.      * 
  65.      */
  66.     public static TimerGestoreBusteNonRiscontrate createTimerGestoreBusteNonRiscontrate() throws Exception {
  67.         
  68.         OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  69.             GestoreJNDI jndi = null;
  70.             if(properties.getJNDIContext_TimerEJB()==null)
  71.                 jndi = new GestoreJNDI();
  72.             else
  73.                 jndi = new GestoreJNDI(properties.getJNDIContext_TimerEJB());
  74.         
  75.             String nomeJNDI = properties.getJNDITimerEJBName().get(TimerGestoreBusteNonRiscontrate.ID_MODULO);
  76.             Object objref = jndi.lookup(nomeJNDI);
  77.             TimerGestoreBusteNonRiscontrateHome timerHome = 
  78.                 (TimerGestoreBusteNonRiscontrateHome) PortableRemoteObject.narrow(objref,TimerGestoreBusteNonRiscontrateHome.class);
  79.             TimerGestoreBusteNonRiscontrate timerDiServizio = timerHome.create();   
  80.         
  81.             return timerDiServizio;
  82.         
  83.         
  84.     }




  89.     /**
  90.      * Metodo che si occupa di ottenere il EJB utile alla gestione dei Messaggi
  91.      *
  92.      * @return un EJB utile alla gestione dei messaggi {@link org.openspcoop2.pdd.timers.TimerGestoreMessaggi}.
  93.      * 
  94.      */
  95.     public static TimerGestoreMessaggi createTimerGestoreMessaggi() throws Exception {
  96.        
  97.         OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  98.             GestoreJNDI jndi = null;
  99.             if(properties.getJNDIContext_TimerEJB()==null)
  100.                 jndi = new GestoreJNDI();
  101.             else
  102.                 jndi = new GestoreJNDI(properties.getJNDIContext_TimerEJB());
  103.             
  104.         String nomeJNDI = properties.getJNDITimerEJBName().get(TimerGestoreMessaggi.ID_MODULO);
  105.         Object objref = jndi.lookup(nomeJNDI);
  106.         TimerGestoreMessaggiHome timerHome = 
  107.         (TimerGestoreMessaggiHome) PortableRemoteObject.narrow(objref,TimerGestoreMessaggiHome.class);
  108.         TimerGestoreMessaggi timerDiServizio = timerHome.create();  
  109.  
  110.             return timerDiServizio;
  111.         
  112.        
  113.     }
  114.     
  115.     
  116.     /**
  117.      * Metodo che si occupa di ottenere il EJB utile alla gestione dei Messaggi anomali
  118.      *
  119.      * @return un EJB utile alla gestione dei messaggi {@link org.openspcoop2.pdd.timers.TimerGestorePuliziaMessaggiAnomali}.
  120.      * 
  121.      */
  122.     public static TimerGestorePuliziaMessaggiAnomali createTimerGestorePuliziaMessaggiAnomali() throws Exception {
  123.        
  124.         OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  125.         GestoreJNDI jndi = null;
  126.         if(properties.getJNDIContext_TimerEJB()==null)
  127.             jndi = new GestoreJNDI();
  128.         else
  129.             jndi = new GestoreJNDI(properties.getJNDIContext_TimerEJB());
  130.             
  131.         String nomeJNDI = properties.getJNDITimerEJBName().get(TimerGestorePuliziaMessaggiAnomali.ID_MODULO);
  132.         Object objref = jndi.lookup(nomeJNDI);
  133.         TimerGestorePuliziaMessaggiAnomaliHome timerHome = 
  134.         (TimerGestorePuliziaMessaggiAnomaliHome) PortableRemoteObject.narrow(objref,TimerGestorePuliziaMessaggiAnomaliHome.class);
  135.         TimerGestorePuliziaMessaggiAnomali timerDiServizio = timerHome.create();    
  136.  
  137.         return timerDiServizio;
  138.         
  139.        
  140.     }

  142.     
  143.     /**
  144.      * Metodo che si occupa di ottenere il EJB utile alla gestione delle buste
  145.      *
  146.      * @return un EJB utile alla gestione delle buste {@link org.openspcoop2.pdd.timers.TimerGestoreRepositoryBuste}.
  147.      * 
  148.      */
  149.     public static TimerGestoreRepositoryBuste createTimerGestoreRepositoryBuste() throws Exception {
  150.        
  151.             OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  152.             GestoreJNDI jndi = null;
  153.             if(properties.getJNDIContext_TimerEJB()==null)
  154.                 jndi = new GestoreJNDI();
  155.             else
  156.                 jndi = new GestoreJNDI(properties.getJNDIContext_TimerEJB());
  157.             String nomeJNDI = properties.getJNDITimerEJBName().get(TimerGestoreRepositoryBuste.ID_MODULO);
  158.             Object objref = jndi.lookup(nomeJNDI);
  159.             TimerGestoreRepositoryBusteHome timerHome = 
  160.                 (TimerGestoreRepositoryBusteHome) PortableRemoteObject.narrow(objref,TimerGestoreRepositoryBusteHome.class);
  161.             TimerGestoreRepositoryBuste timerDiServizio = timerHome.create();   
  162.  
  163.             return timerDiServizio;
  164.         
  165.     }
  166.     

  168.     public static boolean createEmptyLockTimers(OpenSPCoop2Properties propertiesReader, String ID_MODULO, Logger logCore, boolean logErrorConnection) {
  169.         return _lockTimers(propertiesReader, ID_MODULO, logCore, logErrorConnection, false);
  170.     }
  171.     public static void relaseLockTimers(OpenSPCoop2Properties propertiesReader, String ID_MODULO, Logger logCore, boolean logErrorConnection) {
  172.         _lockTimers(propertiesReader, ID_MODULO, logCore, logErrorConnection, true);
  173.     }
  174.     public static boolean _lockTimers(OpenSPCoop2Properties propertiesReader, String ID_MODULO, Logger logCore, boolean logErrorConnection, boolean release) {
  175.         
  176.         boolean ok = true;
  177.         
  178.         if(propertiesReader!=null && propertiesReader.isTimerLockByDatabase() && propertiesReader.getDatabaseType()!=null) {
  179.             
  180.             // RILASCIO LOCK SUL RUNTIME
  181.             
  182.             List<TipoLock> tipiStatistiche = new ArrayList<TipoLock>();
  183.             tipiStatistiche.add(TipoLock.GENERAZIONE_STATISTICHE_ORARIE);
  184.             tipiStatistiche.add(TipoLock.GENERAZIONE_STATISTICHE_GIORNALIERE);
  185.             tipiStatistiche.add(TipoLock.GENERAZIONE_STATISTICHE_SETTIMANALI);
  186.             tipiStatistiche.add(TipoLock.GENERAZIONE_STATISTICHE_MENSILI);
  187.             
  188.             List<TipoLock> tipiRuntime = new ArrayList<TipoLock>();
  189.             tipiRuntime.add(TipoLock.GESTIONE_BUSTE_NON_RISCONTRATE);
  190.             tipiRuntime.add(TipoLock.GESTIONE_CORRELAZIONE_APPLICATIVA);
  191.             tipiRuntime.add(TipoLock.GESTIONE_PULIZIA_MESSAGGI_ANOMALI);
  192.             if(propertiesReader.isMsgGiaInProcessamentoUseLock()) {
  193.                 tipiRuntime.add(TipoLock._getLockGestioneRepositoryMessaggi());
  194.             }
  195.             else {
  196.                 tipiRuntime.add(TipoLock.GESTIONE_PULIZIA_REPOSITORY_MESSAGGI);
  197.                 tipiRuntime.add(TipoLock.GESTIONE_PULIZIA_REPOSITORY_BUSTE);
  198.             }
  199.             if(propertiesReader.isStatisticheGenerazioneEnabled()){
  200.                 if(propertiesReader.isStatisticheUsePddRuntimeDatasource()) {
  201.                     tipiRuntime.addAll(tipiStatistiche);
  202.                 }
  203.             }

  205.             if(tipiRuntime!=null && tipiRuntime.size()>0) {
  206.                 Resource resource = null;
  207.                 DBManager dbManager = DBManager.getInstance();
  208.                 try {
  209.                     resource = dbManager.getResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, null, false);
  210.                     
  211.                     for (TipoLock tipoLock : tipiRuntime) {
  212.                         _lock(propertiesReader, (Connection)resource.getResource(), tipoLock, logCore, release);
  213.                     }
  214.                     
  215.                     if(propertiesReader.isServerJ2EE()!=null && propertiesReader.isServerJ2EE()==false){
  216.                         if(propertiesReader.isTimerConsegnaContenutiApplicativiAbilitato()){
  217.                             List<String> code = propertiesReader.getTimerConsegnaContenutiApplicativiCode();
  218.                             if(code!=null && !code.isEmpty()) {
  219.                                 for (String coda : code) {
  220.                                     boolean result = _lock(propertiesReader, (Connection)resource.getResource(), TimerLock.getIdLockConsegnaNotifica(coda), logCore, release);
  221.                                     if(!result) {
  222.                                         ok = false; // l'errore è registrato all'interno del metodo _lock
  223.                                     }
  224.                                 }
  225.                             }
  226.                         }
  227.                     }
  228.                     
  229.                 }catch(Exception e){
  230.                     ok = false;
  231.                     if(logErrorConnection) {
  232.                         logCore.error("Riscontrato errore durante il "+(release?"il rilascio":"la creazione")+" dei lock: "+e.getMessage(),e);
  233.                     }
  234.                     else {
  235.                         logCore.debug("Riscontrato errore durante il "+(release?"il rilascio":"la creazione")+" dei lock, in fase di shutdown: "+e.getMessage(),e);
  236.                     }
  237.                 }
  238.                 finally {
  239.                     if(dbManager!=null) {
  240.                         dbManager.releaseResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, resource, false);
  241.                     }
  242.                 }
  243.             }
  244.             
  245.             // RILASCIO LOCK STATISTICHE SE NON SONO SUL RUNTIME
  246.             if(propertiesReader.isStatisticheGenerazioneEnabled() && !propertiesReader.isStatisticheUsePddRuntimeDatasource()){
  247.                 
  248.                 if(tipiStatistiche!=null && tipiStatistiche.size()>0) {
  249.                     Resource resource = null;
  250.                     DBStatisticheManager dbStatisticheManager = null;
  251.                     DBTransazioniManager dbTransazioniManager = null;
  252.                     if(propertiesReader.isStatisticheUseTransazioniDatasource()) {
  253.                         dbTransazioniManager = DBTransazioniManager.getInstance();
  254.                     }
  255.                     else {
  256.                         dbStatisticheManager = DBStatisticheManager.getInstance();
  257.                     }
  258.                     try {
  259.                         if(dbTransazioniManager!=null) {
  260.                             resource = dbTransazioniManager.getResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, null, false);
  261.                         }
  262.                         else if(dbStatisticheManager!=null){
  263.                             resource = dbStatisticheManager.getResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, null, false);
  264.                         }
  265.                         
  266.                         for (TipoLock tipoLock : tipiStatistiche) {
  267.                             if(resource!=null) {
  268.                                 boolean result = _lock(propertiesReader, (Connection)resource.getResource(), tipoLock, logCore, release);
  269.                                 if(!result) {
  270.                                     ok = false; // l'errore è registrato all'interno del metodo _lock
  271.                                 }
  272.                             }
  273.                             else {
  274.                                 ok = false;
  275.                                 logCore.error("Timer Resource is null?");
  276.                             }
  277.                         }
  278.                     }catch(Exception e){
  279.                         ok = false;
  280.                         if(logErrorConnection) {
  281.                             logCore.error("Riscontrato errore durante il "+(release?"il rilascio":"la creazione")+" dei lock: "+e.getMessage(),e);
  282.                         }
  283.                         else {
  284.                             logCore.debug("Riscontrato errore durante il "+(release?"il rilascio":"la creazione")+" dei lock, in fase di shutdown: "+e.getMessage(),e);
  285.                         }
  286.                     }
  287.                     finally {
  288.                         if(dbTransazioniManager!=null) {
  289.                             dbTransazioniManager.releaseResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, resource, false);
  290.                         }
  291.                         else if(dbStatisticheManager!=null){
  292.                             dbStatisticheManager.releaseResource(propertiesReader.getIdentitaPortaDefaultWithoutProtocol(), ID_MODULO, resource, false);
  293.                         }
  294.                     }
  295.                 }
  296.                 
  297.             }
  298.         }
  299.         
  300.         return ok;
  301.     }
  302.     
  303.     private static boolean _lock(OpenSPCoop2Properties propertiesReader, Connection connection, TipoLock tipoLock, Logger logCore, boolean release) {
  304.         return _lock(propertiesReader,connection,tipoLock.getTipo(),logCore, release);
  305.     }
  306.     private static boolean _lock(OpenSPCoop2Properties propertiesReader, Connection connection, String idLock, Logger logCore, boolean release) {
  307.         boolean ok = true; 
  308.         try{
  309.             InfoStatistics semaphore_statistics = new InfoStatistics();
  310.             SemaphoreConfiguration config = GestoreMessaggi.newSemaphoreConfiguration(propertiesReader.getTimerConsegnaContenutiApplicativiLockMaxLife(), 
  311.                     propertiesReader.getTimerConsegnaContenutiApplicativiLockIdleTime());
  312.             //config.setSerializableLevel(true); // in modo da non avere il lock esclusivo sulla tabella e far funzionare anche se l'entry non esiste proprio
  313.             TipiDatabase databaseType = TipiDatabase.toEnumConstant(propertiesReader.getDatabaseType());
  314.             Semaphore semaphore = new Semaphore(semaphore_statistics, SemaphoreMapping.newInstance(idLock), 
  315.                     config, databaseType, logCore);
  316.             if(release) {
  317.                 boolean unlock = semaphore.releaseLock(connection, "Riavvio application server");
  318.                 logCore.debug("Lock di tipo '"+idLock+"' "+(unlock?"rilasciato" :"non rilasciato"));
  319.             }
  320.             else {
  321.                 boolean created = semaphore.createEmptyLock(connection, false);
  322.                 logCore.debug("Lock di tipo '"+idLock+"' "+(created?"creato" :"non creato"));
  323.             }
  324.         }catch(Exception e){
  325.             ok = false;
  326.             logCore.error("Riscontrato errore durante "+(release?"il rilascio":"la creazione")+" del lock di tipo '"+idLock+"': "+e.getMessage(),e);
  327.         }
  328.         return ok;
  329.     }
  330. }
Created with JaCoCo 0.8.8.202204050719