ConfigurazionePdD_allarmi.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.config;

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

  27. import org.openspcoop2.core.allarmi.Allarme;
  28. import org.openspcoop2.core.allarmi.AllarmeParametro;
  29. import org.openspcoop2.core.allarmi.IdAllarme;
  30. import org.openspcoop2.core.allarmi.constants.RuoloPorta;
  31. import org.openspcoop2.core.allarmi.constants.StatoAllarme;
  32. import org.openspcoop2.core.allarmi.dao.IAllarmeServiceSearch;
  33. import org.openspcoop2.core.allarmi.utils.AllarmiConverterUtils;
  34. import org.openspcoop2.core.allarmi.utils.FiltroRicercaAllarmi;
  35. import org.openspcoop2.core.commons.dao.DAOFactory;
  36. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  37. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  38. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  39. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  40. import org.openspcoop2.generic_project.exception.NotFoundException;
  41. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  42. import org.openspcoop2.generic_project.expression.LikeMode;
  43. import org.openspcoop2.generic_project.expression.SortOrder;
  44. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  45. import org.openspcoop2.monitor.engine.alarm.AlarmImpl;
  46. import org.openspcoop2.monitor.engine.alarm.AlarmManager;
  47. import org.openspcoop2.monitor.sdk.alarm.AlarmStatus;
  48. import org.openspcoop2.monitor.sdk.alarm.IAlarm;
  49. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;

  51. /**     
  52.  * ConfigurazionePdD_controlloTraffico
  53.  *
  54.  * @author Poli Andrea (poli@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class ConfigurazionePdD_allarmi extends AbstractConfigurazionePdDConnectionResourceManager {

  60.     private ServiceManagerProperties smp;
  61.     
  62.     public ConfigurazionePdD_allarmi(OpenSPCoop2Properties openspcoopProperties, DriverConfigurazioneDB driver, boolean useConnectionPdD) {
  63.         super(openspcoopProperties, driver, useConnectionPdD, OpenSPCoop2Logger.getLoggerOpenSPCoopAllarmiSql(openspcoopProperties.isAllarmiDebug()));
  64.             
  65.         this.smp = new ServiceManagerProperties();
  66.         this.smp.setShowSql(this.openspcoopProperties.isAllarmiDebug());
  67.         this.smp.setDatabaseType(this.driver.getTipoDB());
  68.     }
  69.     
  70.     public Allarme getAllarme(Connection connectionPdD, String nomeAllarme) throws DriverConfigurazioneException, DriverConfigurazioneNotFound {
  71.         
  72.         Allarme allarme = null;
  73.         
  74.         ConfigurazionePdDConnectionResource cr = null;
  75.         try{
  76.             cr = this.getConnection(connectionPdD, "Allarmi.searchAllarmi");
  77.             org.openspcoop2.core.allarmi.dao.IServiceManager sm = 
  78.                     (org.openspcoop2.core.allarmi.dao.IServiceManager) DAOFactory.getInstance(this.log).
  79.                     getServiceManager(org.openspcoop2.core.allarmi.utils.ProjectInfo.getInstance(),
  80.                             cr.connectionDB,this.smp,this.log);
  81.         
  82.             IdAllarme id = new IdAllarme();
  83.             id.setNome(nomeAllarme);
  84.             allarme = sm.getAllarmeServiceSearch().get(id);
  85.                         
  86.         }
  87.         catch(NotFoundException e){
  88.             String errorMsg = "Allarme '"+nomeAllarme+"' non trovato";
  89.             this.log.debug(errorMsg,e);
  90.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  91.         }
  92.         catch(Exception e){
  93.             String errorMsg = "Errore durante la ricerca dell'allarme '"+nomeAllarme+"': "+e.getMessage();
  94.             this.log.error(errorMsg,e);
  95.             throw new DriverConfigurazioneException(errorMsg,e);
  96.         }
  97.         finally {
  98.             this.releaseConnection(cr);
  99.         }

  101.         if(allarme!=null) {
  102.             return allarme;
  103.         }
  104.         throw new DriverConfigurazioneNotFound("Allarme '"+nomeAllarme+"' non trovato");
  105.     }
  106.     
  107.     
  108.     public List<Allarme> searchAllarmi(Connection connectionPdD, FiltroRicercaAllarmi filtroRicerca) throws DriverConfigurazioneException, DriverConfigurazioneNotFound {
  109.         
  110.         List<Allarme> list = new ArrayList<Allarme>();
  111.                 
  112.         ConfigurazionePdDConnectionResource cr = null;
  113.         try{
  114.             cr = this.getConnection(connectionPdD, "Allarmi.searchAllarmi");
  115.             org.openspcoop2.core.allarmi.dao.IServiceManager sm = 
  116.                     (org.openspcoop2.core.allarmi.dao.IServiceManager) DAOFactory.getInstance(this.log).
  117.                     getServiceManager(org.openspcoop2.core.allarmi.utils.ProjectInfo.getInstance(),
  118.                             cr.connectionDB,this.smp,this.log);
  119.             
  120.             String tipo = filtroRicerca.getTipo();
  121.             if(tipo==null || "".equals(tipo)) {
  122.                 throw new Exception("Tipo allarme non fornito");
  123.             }
  124.             
  125.             String idParametroCluster = filtroRicerca.getIdParametroCluster();
  126.             String idCluster = filtroRicerca.getIdCluster(); 
  127.             boolean idClusterOpzionale = filtroRicerca.isIdClusterOpzionale();
  128.             
  129.             String idParametro = filtroRicerca.getIdParametro();
  130.             String valoreParametro = filtroRicerca.getValoreParametro();
  131.             
  132.             boolean recuperaSoloAllarmiInStatoDiversoDaOk = filtroRicerca.isRecuperaSoloAllarmiInStatoDiversoDaOk();
  133.         
  134.             Boolean globale = filtroRicerca.getGlobale();
  135.             RuoloPorta ruoloPorta = null;
  136.             String nomePorta = null;
  137.             if(globale!=null && !globale) {
  138.                 ruoloPorta = filtroRicerca.getRuoloPorta();
  139.                 nomePorta = filtroRicerca.getNomePorta();
  140.             }
  141.             
  142.             IAllarmeServiceSearch allarmeServiceSearch = sm.getAllarmeServiceSearch();
  143.         
  144.             IPaginatedExpression expr = allarmeServiceSearch.newPaginatedExpression();
  145.             expr.limit(1000); // numero eccessivo
  146.             expr.addOrder(Allarme.model().NOME, SortOrder.ASC);
  147.             expr.and();
  148.             expr.equals(Allarme.model().TIPO, tipo);
  149.             expr.equals(Allarme.model().ENABLED, 1);
  150.             
  151.             if(globale!=null) {
  152.                 if(globale) {
  153.                     expr.isNull(Allarme.model().FILTRO.NOME_PORTA);
  154.                 }
  155.                 else {
  156.                     expr.equals(Allarme.model().FILTRO.RUOLO_PORTA, ruoloPorta.getValue()).and().equals(Allarme.model().FILTRO.NOME_PORTA, nomePorta);
  157.                 }
  158.             }
  159.             
  160.             if(recuperaSoloAllarmiInStatoDiversoDaOk) {
  161.                 expr.notEquals(Allarme.model().STATO, AllarmiConverterUtils.toIntegerValue(StatoAllarme.OK));
  162.             }
  163.             
  164.             // AVENDO DUE PARAMETRI IN GIOCO, LA QUERY VIENE SBAGLIATA. DOVREI GENERARE DUE JOIN CON DIFFERENTE ALIAS
  165.             // IL CONTROLLO DEL CLUSTER LO FACCIO APPLICATIVO (tanto sono un numero limitato)
  166.     //      if(idParametroCluster!=null) {
  167.     //          expr.equals(ConfigurazioneAllarme.model().CONFIGURAZIONE_ALLARME_PARAMETRO.ID_PARAMETRO, idParametroCluster);
  168.     //          if(idCluster!=null) {
  169.     //              expr.like(ConfigurazioneAllarme.model().CONFIGURAZIONE_ALLARME_PARAMETRO.VALORE, idCluster,LikeMode.EXACT);
  170.     //          }
  171.     //          else {
  172.     //              expr.isNull(ConfigurazioneAllarme.model().CONFIGURAZIONE_ALLARME_PARAMETRO.VALORE);
  173.     //          }
  174.     //      }
  175.             if(idParametro!=null) {
  176.                 expr.equals(Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO, idParametro);
  177.                 if(valoreParametro!=null) {
  178.                     expr.like(Allarme.model().ALLARME_PARAMETRO.VALORE, valoreParametro,LikeMode.EXACT);
  179.                 }
  180.                 else {
  181.                     expr.isNull(Allarme.model().ALLARME_PARAMETRO.VALORE);
  182.                 }
  183.             }
  184.             
  185.             List<Allarme> l = allarmeServiceSearch.findAll(expr);
  186.             if(l!=null && l.size()>0){
  187.                 for (Allarme configurazioneAllarme : l) {
  188.                     boolean add = true;
  189.                     if(idParametroCluster!=null) {
  190.                         for (AllarmeParametro configurazioneAllarmeParametro : configurazioneAllarme.getAllarmeParametroList()) {
  191.                             if(idParametroCluster.equals(configurazioneAllarmeParametro.getIdParametro())) {
  192.                                 if(idCluster!=null) {
  193.                                     if(idCluster.equals(configurazioneAllarmeParametro.getValore())==false) {
  194.                                         if(idClusterOpzionale) {
  195.                                             if(configurazioneAllarmeParametro.getValore()!=null && 
  196.                                                     !"".equals(configurazioneAllarmeParametro.getValore()) && 
  197.                                                     !CostantiConfigurazione.CLUSTER_ID_NON_DEFINITO.equals(configurazioneAllarmeParametro.getValore())) {
  198.                                                 add=false;
  199.                                             }
  200.                                         }
  201.                                         else {
  202.                                             add=false;
  203.                                         }
  204.                                     }
  205.                                 }
  206.                                 else {
  207.                                     if(idClusterOpzionale) {
  208.                                         if(configurazioneAllarmeParametro.getValore()!=null && 
  209.                                                 !"".equals(configurazioneAllarmeParametro.getValore()) && 
  210.                                                 !CostantiConfigurazione.CLUSTER_ID_NON_DEFINITO.equals(configurazioneAllarmeParametro.getValore())) {
  211.                                             add=false;
  212.                                         }
  213.                                     }
  214.                                     else {
  215.                                         add=false;
  216.                                     }
  217.                                 }
  218.                                 break;
  219.                             }
  220.                         }
  221.                     }
  222.                     if(add) {
  223.                         list.add(configurazioneAllarme);
  224.                     }
  225.                 }
  226.             }
  227.         }
  228.         catch(Exception e){
  229.             String errorMsg = "Errore durante la ricerca degli allarmi: "+e.getMessage();
  230.             this.log.error(errorMsg,e);
  231.             throw new DriverConfigurazioneException(errorMsg,e);
  232.         }
  233.         finally {
  234.             this.releaseConnection(cr);
  235.         }

  237.         if(list!=null && !list.isEmpty()) {
  238.             return list;
  239.         }
  240.         throw new DriverConfigurazioneNotFound("Allarmi non trovati");
  241.     }

  243.     
  244.     public List<IAlarm> instanceAllarmi(Connection connectionPdD, List<Allarme> listAllarmi) throws DriverConfigurazioneException {
  245.         
  246.         ConfigurazionePdDConnectionResource cr = null;
  247.         try{
  248.             cr = this.getConnection(connectionPdD, "Allarmi.instanceAllarmi");
  249.             DAOFactory daoFactory = DAOFactory.getInstance(this.log);
  250.             org.openspcoop2.core.plugins.dao.IServiceManager smPlugins = 
  251.                     (org.openspcoop2.core.plugins.dao.IServiceManager) daoFactory.
  252.                     getServiceManager(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  253.                             cr.connectionDB,this.smp,this.log);
  254.             
  255.             if(listAllarmi==null || listAllarmi.isEmpty()) {
  256.                 throw new Exception("Non sono stati forniti allarmi da istanziare");
  257.             }
  258.             
  259.             List<IAlarm> list = new ArrayList<IAlarm>();
  260.             for (Allarme allarme : listAllarmi) {
  261.                 list.add(AlarmManager.getAlarm(allarme, this.log, daoFactory, smPlugins));
  262.             }
  263.             
  264.             return list;
  265.         }
  266.         catch(Exception e){
  267.             String errorMsg = "Errore durante l'istanziazione degli allarmi: "+e.getMessage();
  268.             this.log.error(errorMsg,e);
  269.             throw new DriverConfigurazioneException(errorMsg,e);
  270.         }
  271.         finally {
  272.             this.releaseConnection(cr);
  273.         }

  275.     }
  276.     
  277.     public boolean changeStatus(Connection connectionPdD,  AlarmImpl alarm, AlarmStatus nuovoStatoAllarme) throws DriverConfigurazioneException {
  278.         return _changeStatus(connectionPdD, alarm, nuovoStatoAllarme);
  279.     }
  280.     public boolean changeStatus(Connection connectionPdD,  IAlarm alarm, AlarmStatus nuovoStatoAllarme) throws DriverConfigurazioneException {
  281.         return _changeStatus(connectionPdD, alarm, nuovoStatoAllarme);
  282.     }
  283.     private boolean _changeStatus(Connection connectionPdD,  IAlarm alarm, AlarmStatus nuovoStatoAllarme) throws DriverConfigurazioneException {
  284.         ConfigurazionePdDConnectionResource cr = null;
  285.         try{
  286.             cr = this.getConnection(connectionPdD, "Allarmi.changeStato");
  287.                 
  288.             if(alarm instanceof AlarmImpl) {
  289.                 ((AlarmImpl)alarm).changeStatus(this.log, cr.connectionDB, this.smp,nuovoStatoAllarme);
  290.             }
  291.             else {
  292.                 alarm.changeStatus(nuovoStatoAllarme);
  293.             }
  294.             return true; // serve solo per passare dai metodi "cache" della configurazione; il valore true/false non viene usato
  295.         }
  296.         catch(Exception e){
  297.             String errorMsg = "Errore durante update stato degli allarmi: "+e.getMessage();
  298.             this.log.error(errorMsg,e);
  299.             throw new DriverConfigurazioneException(errorMsg,e);
  300.         }
  301.         finally {
  302.             this.releaseConnection(cr);
  303.         }
  304.     }
  305.     
  306.     
  307. }
Created with JaCoCo 0.8.8.202204050719