ConfigurazioneAllarmiChange.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.web.ctrlstat.servlet.config;

  23. import java.text.MessageFormat;
  24. import java.util.ArrayList;
  25. import java.util.Date;
  26. import java.util.List;

  28. import javax.servlet.http.HttpServletRequest;
  29. import javax.servlet.http.HttpServletResponse;
  30. import javax.servlet.http.HttpSession;

  32. import org.apache.struts.action.Action;
  33. import org.apache.struts.action.ActionForm;
  34. import org.apache.struts.action.ActionForward;
  35. import org.apache.struts.action.ActionMapping;
  36. import org.openspcoop2.core.allarmi.AllarmeHistory;
  37. import org.openspcoop2.core.allarmi.AllarmeParametro;
  38. import org.openspcoop2.core.allarmi.constants.RuoloPorta;
  39. import org.openspcoop2.core.allarmi.constants.StatoAllarme;
  40. import org.openspcoop2.core.allarmi.constants.TipoAllarme;
  41. import org.openspcoop2.core.allarmi.utils.AllarmiConverterUtils;
  42. import org.openspcoop2.core.commons.Filtri;
  43. import org.openspcoop2.core.commons.Liste;
  44. import org.openspcoop2.core.config.PortaApplicativa;
  45. import org.openspcoop2.core.config.PortaDelegata;
  46. import org.openspcoop2.core.id.IDPortaApplicativa;
  47. import org.openspcoop2.core.id.IDPortaDelegata;
  48. import org.openspcoop2.core.plugins.Plugin;
  49. import org.openspcoop2.core.plugins.constants.TipoPlugin;
  50. import org.openspcoop2.message.constants.ServiceBinding;
  51. import org.openspcoop2.monitor.engine.alarm.AlarmEngineConfig;
  52. import org.openspcoop2.monitor.engine.alarm.utils.AllarmiUtils;
  53. import org.openspcoop2.monitor.engine.alarm.wrapper.ConfigurazioneAllarmeBean;
  54. import org.openspcoop2.monitor.engine.dynamic.DynamicFactory;
  55. import org.openspcoop2.monitor.engine.dynamic.IDynamicLoader;
  56. import org.openspcoop2.monitor.sdk.condition.Context;
  57. import org.openspcoop2.monitor.sdk.plugins.IAlarmProcessing;
  58. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  59. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  60. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  61. import org.openspcoop2.web.ctrlstat.servlet.pa.PorteApplicativeCore;
  62. import org.openspcoop2.web.ctrlstat.servlet.pd.PorteDelegateCore;
  63. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  64. import org.openspcoop2.web.lib.mvc.DataElement;
  65. import org.openspcoop2.web.lib.mvc.ForwardParams;
  66. import org.openspcoop2.web.lib.mvc.GeneralData;
  67. import org.openspcoop2.web.lib.mvc.PageData;
  68. import org.openspcoop2.web.lib.mvc.Parameter;
  69. import org.openspcoop2.web.lib.mvc.ServletUtils;
  70. import org.openspcoop2.web.lib.mvc.TipoOperazione;

  72. /**     
  73.  * ConfigurazioneAllarmiChange
  74.  *
  75.  * @author Pintori Giuliano (pintori@link.it)
  76.  * @author $Author$
  77.  * @version $Rev$, $Date$
  78.  */
  79. public class ConfigurazioneAllarmiChange extends Action {

  81.     @Override
  82.     public ActionForward execute(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

  84.         HttpSession session = request.getSession(true);

  86.         // Inizializzo PageData
  87.         PageData pd = new PageData();

  89.         GeneralHelper generalHelper = new GeneralHelper(session);

  91.         // Inizializzo GeneralData
  92.         GeneralData gd = generalHelper.initGeneralData(request);

  94.         String userLogin = ServletUtils.getUserLoginFromSession(session);   
  95.         
  96.         TipoOperazione tipoOperazione = TipoOperazione.CHANGE;
  97.         
  98.         String pluginSelectedExceptionMessage = null;

  100.         try {
  101.             StringBuilder sbParsingError = new StringBuilder();
  102.             
  103.             ConfigurazioneHelper confHelper = new ConfigurazioneHelper(request, pd, session);
  104.             
  105.             // controllo primo accesso
  106.             boolean first = confHelper.isFirstTimeFromHttpParameters(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_FIRST_TIME);
  107.             
  108.             String idAllarmeS = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_ID_ALLARME);
  109.             
  110.             String ruoloPortaParam = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_RUOLO_PORTA);
  111.             RuoloPorta ruoloPorta = null;
  112.             if(ruoloPortaParam!=null) {
  113.                 ruoloPorta = RuoloPorta.toEnumConstant(ruoloPortaParam);
  114.             }
  115.             String nomePorta = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_NOME_PORTA);
  116.             ServiceBinding serviceBinding = null;
  117.             String serviceBindingParam = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_SERVICE_BINDING);
  118.             if(serviceBindingParam!=null && !"".equals(serviceBindingParam)) {
  119.                 serviceBinding = ServiceBinding.valueOf(serviceBindingParam);
  120.             }
  121.             String nomePlugin = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_PLUGIN);
  122.             
  123.             ConfigurazioneCore confCore = new ConfigurazioneCore();
  124.             SoggettiCore soggettiCore = new SoggettiCore(confCore);
  125.             PorteDelegateCore pdCore = new PorteDelegateCore(confCore);
  126.             PorteApplicativeCore paCore = new PorteApplicativeCore(confCore);
  127.             
  128.             AlarmEngineConfig alarmEngineConfig = confCore.getAllarmiConfig();
  129.             
  130.             Long idAllarme = Long.parseLong(idAllarmeS);
  131.             ConfigurazioneAllarmeBean allarme = confCore.getAllarme(idAllarme);
  132.             Integer oldEnabled = allarme.getEnabled();
  133.             List<org.openspcoop2.monitor.sdk.parameters.Parameter<?>> parameters = null;
  134.             if(first) {
  135.                 confHelper.savePluginIntoSession(request, session, allarme.getPlugin());
  136.                 Context context = confHelper.createAlarmContext(allarme, parameters);
  137.                 parameters = confCore.getParameters(allarme, context);
  138.                 confHelper.saveParametriIntoSession(request, session, parameters);
  139.             }

  141.             parameters = confHelper.readParametriFromSession(request, session);
  142.             
  143.             String applicabilita = Filtri.FILTRO_APPLICABILITA_VALORE_CONFIGURAZIONE;
  144.             if(ruoloPorta!=null) {
  145.                 if(RuoloPorta.DELEGATA.equals(ruoloPorta)) {
  146.                     applicabilita = Filtri.FILTRO_APPLICABILITA_VALORE_FRUIZIONE;
  147.                 }
  148.                 else {
  149.                     applicabilita = Filtri.FILTRO_APPLICABILITA_VALORE_EROGAZIONE;
  150.                 }
  151.             }
  152.             
  153.             List<Plugin> listaPlugin = confCore.pluginsAllarmiList(applicabilita, true);
  154.             int numeroPluginRegistrati = listaPlugin.size();
  155.             
  156.             Plugin plugin = confHelper.readPluginFromSession(request, session);
  157.             allarme.setPlugin(plugin);
  158.             
  159.             // Dati Attivazione
  160.             String errorAttivazione = confHelper.readAllarmeFromRequest(tipoOperazione, first, allarme, alarmEngineConfig, plugin, parameters); 
  161.             if(errorAttivazione!=null){
  162.                 confHelper.addParsingError(sbParsingError,errorAttivazione); 
  163.             }
  164.             
  165.             if(ruoloPorta!=null) {
  166.                 
  167.                 String protocollo = null;
  168.                 String tipoSoggettoProprietario = null;
  169.                 String nomeSoggettoProprietario = null;
  170.                 if(RuoloPorta.DELEGATA.equals(ruoloPorta)) {
  171.                     IDPortaDelegata idPD = new IDPortaDelegata();
  172.                     idPD.setNome(nomePorta);
  173.                     PortaDelegata porta = pdCore.getPortaDelegata(idPD);
  174.                     protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(porta.getTipoSoggettoProprietario());
  175.                     // il tipo e nome serve per l'applicativo fruitore
  176.                     tipoSoggettoProprietario = porta.getTipoSoggettoProprietario();
  177.                     nomeSoggettoProprietario = porta.getNomeSoggettoProprietario();
  178.                 }
  179.                 else {
  180.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  181.                     idPA.setNome(nomePorta);
  182.                     PortaApplicativa porta = paCore.getPortaApplicativa(idPA);
  183.                     protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(porta.getTipoSoggettoProprietario());
  184.                 }
  185.                 
  186.                 allarme.getFiltro().setEnabled(true);
  187.                 allarme.getFiltro().setProtocollo(protocollo);
  188.                 allarme.getFiltro().setRuoloPorta(ruoloPorta);
  189.                 allarme.getFiltro().setNomePorta(nomePorta);
  190.                 if(RuoloPorta.DELEGATA.equals(ruoloPorta)) {
  191.                     allarme.getFiltro().setTipoFruitore(tipoSoggettoProprietario);
  192.                     allarme.getFiltro().setNomeFruitore(nomeSoggettoProprietario);
  193.                 }
  194.                 
  195.             }
  196.             
  197.             
  198.             // Preparo il menu
  199.             confHelper.makeMenu();
  200.             
  201.             String postBackElementName = confHelper.getPostBackElementName();
  202.             if (postBackElementName != null) {
  203.                 // selezione del plugin
  204.                 if(postBackElementName.equals(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_PLUGIN)) {
  205.                     if(nomePlugin.equals(ConfigurazioneCostanti.DEFAULT_VALUE_NESSUNO)) {
  206.                         allarme.setNome(null);
  207.                         allarme.setTipoAllarme(null);
  208.                         allarme.setPlugin(null);
  209.                         parameters=null;
  210.                         
  211.                         confHelper.removeParametriFromSession(request, session);
  212.                         confHelper.removePluginFromSession(request, session);
  213.                     } else {
  214.                         for (Plugin pluginBean : listaPlugin) {
  215.                             String key = pluginBean.getLabel() + ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_PLUGIN_NOME_SEP + pluginBean.getClassName();
  216.                             if(key.equals(nomePlugin)) {
  217.                                 plugin = pluginBean;
  218.                                 break;
  219.                             }
  220.                         }
  221.                         
  222.                         
  223.                         allarme.setPlugin(plugin);
  224.                         parameters=null;
  225.                         
  226.                         if(allarme.getPlugin() != null) {
  227.                             allarme.setNome(allarme.getPlugin().getLabel());
  228.                             allarme.setTipo(allarme.getPlugin().getTipo());
  229.                             try{
  230.                                 Context context = confHelper.createAlarmContext(allarme, parameters);   
  231.                                 allarme.setNome(allarme.getNome());
  232.                                 IDynamicLoader dl = DynamicFactory.getInstance().newDynamicLoader(TipoPlugin.ALLARME, allarme.getPlugin().getTipo(), allarme.getPlugin().getClassName(), ControlStationCore.getLog());
  233.                                 IAlarmProcessing alarm = (IAlarmProcessing) dl.newInstance();
  234.                                 switch (alarm.getAlarmType()) {
  235.                                 case ACTIVE:
  236.                                     allarme.setTipoAllarme(TipoAllarme.ATTIVO);
  237.                                     break;
  238.                                 case PASSIVE:
  239.                                     allarme.setTipoAllarme(TipoAllarme.PASSIVO);
  240.                                     break;
  241.                                 }
  242.                                             
  243.                                 parameters = confCore.getParameters(allarme, context);
  244.                                                                 
  245.                                 confHelper.saveParametriIntoSession(request, session, parameters);
  246.                                 confHelper.savePluginIntoSession(request, session, allarme.getPlugin());
  247.                             }catch(Exception e){
  248.                                 ControlStationCore.getLog().error(e.getMessage(), e);
  249.                                 allarme.setNome(null);
  250.                                 allarme.setTipoAllarme(null);
  251.                                 allarme.setPlugin(null);
  252.                                 allarme.setTipo(null);
  253.                                 parameters=null;
  254.                                 pluginSelectedExceptionMessage = e.getMessage();
  255.                                 confHelper.removeParametriFromSession(request, session);
  256.                                 confHelper.removePluginFromSession(request, session);
  257.                             }
  258.                         }
  259.                     }
  260.                 }
  261.             }
  262.             
  263.             List<Parameter> lstParamSession = new ArrayList<>();

  265.             Parameter parRuoloPorta = null;
  266.             if(ruoloPorta!=null) {
  267.                 parRuoloPorta = new Parameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_RUOLO_PORTA, ruoloPorta.getValue());
  268.                 lstParamSession.add(parRuoloPorta);
  269.             }
  270.             Parameter parNomePorta = null;
  271.             if(nomePorta!=null) {
  272.                 parNomePorta = new Parameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_NOME_PORTA, nomePorta);
  273.                 lstParamSession.add(parNomePorta);
  274.             }
  275.             Parameter parServiceBinding = null;
  276.             if(serviceBinding!=null) {
  277.                 parServiceBinding = new Parameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_SERVICE_BINDING, serviceBinding.name());
  278.                 lstParamSession.add(parServiceBinding);
  279.             }
  280.             
  281.             List<Parameter> lstParamPorta = null;
  282.             if(ruoloPorta!=null) {
  283.                 lstParamPorta = confHelper.getTitleListAllarmi(ruoloPorta, nomePorta, serviceBinding, allarme.getAlias());
  284.             }
  285.             
  286.             // setto la barra del titolo
  287.             List<Parameter> lstParam = null;
  288.             if(lstParamPorta!=null) {
  289.                 lstParam = lstParamPorta;
  290.             }
  291.             else {
  292.                 lstParam  = new ArrayList<>();
  293.                 
  294.                 if(lstParamSession.size() > 0) {
  295.                     lstParam.add(new Parameter(ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_ALLARMI, 
  296.                         ConfigurazioneCostanti.SERVLET_NAME_CONFIGURAZIONE_ALLARMI_LIST, lstParamSession.toArray(new Parameter[lstParamSession.size()])));
  297.                 } else {
  298.                     lstParam.add(new Parameter(ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_ALLARMI, 
  299.                         ConfigurazioneCostanti.SERVLET_NAME_CONFIGURAZIONE_ALLARMI_LIST));
  300.                 }
  301.                 lstParam.add(new Parameter(allarme.getAlias(), null));
  302.             }
  303.             
  304.             // Se tipo = null, devo visualizzare la pagina per l'inserimento
  305.             // dati
  306.             if (confHelper.isEditModeInProgress()) {
  307.                 ServletUtils.setPageDataTitle(pd, lstParam);
  308.                 
  309.                 // preparo i campi
  310.                 List<DataElement> dati = new ArrayList<>();
  311.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  312.                 
  313.                 confHelper.addAllarmeToDati(dati, tipoOperazione, allarme, alarmEngineConfig, listaPlugin, parameters, ruoloPorta, nomePorta, serviceBinding); 
  314.                 
  315.                 // Set First is false
  316.                 confHelper.addToDatiFirstTimeDisabled(dati,ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_FIRST_TIME);
  317.                 
  318.                 if(pluginSelectedExceptionMessage != null) {
  319.                     pd.setMessage(pluginSelectedExceptionMessage);
  320.                 }
  321.                 
  322.                 pd.setDati(dati);

  324.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);

  326.                 return ServletUtils.getStrutsForwardEditModeInProgress(mapping, ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_ALLARMI, ForwardParams.CHANGE());
  327.             }
  328.                 
  329.             // Controlli sui campi immessi
  330.             boolean isOk = confHelper.allarmeCheckData(sbParsingError, tipoOperazione, null, allarme, numeroPluginRegistrati, parameters); 
  331.             if (!isOk) {
  332.                 ServletUtils.setPageDataTitle(pd, lstParam);
  333.                 
  334.                 // preparo i campi
  335.                 List<DataElement> dati = new ArrayList<>();
  336.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  337.                 
  338.                 confHelper.addAllarmeToDati(dati, tipoOperazione, allarme, alarmEngineConfig, listaPlugin, parameters, ruoloPorta, nomePorta, serviceBinding);
  339.                 
  340.                 // Set First is false
  341.                 confHelper.addToDatiFirstTimeDisabled(dati,ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_ALLARMI_FIRST_TIME);
  342.                 
  343.                 pd.setDati(dati);

  345.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  346.                 
  347.                 return ServletUtils.getStrutsForwardEditModeCheckError(mapping, 
  348.                         ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_ALLARMI, 
  349.                         ForwardParams.CHANGE());
  350.             }
  351.                 
  352.             // salvataggio dei parametri
  353.             if(parameters!=null && !parameters.isEmpty()) {
  354.                 for (org.openspcoop2.monitor.sdk.parameters.Parameter<?> par : parameters) {
  355.                     boolean found = false;
  356.                     for (AllarmeParametro parDB : allarme.getAllarmeParametroList()) {
  357.                         if(parDB.getIdParametro().equals(par.getId())){
  358.                             parDB.setValore(par.getValueAsString());
  359.                             found = true;
  360.                             break;
  361.                         }
  362.                     }
  363.                     if(!found){
  364.                         AllarmeParametro parDB = new AllarmeParametro();
  365.                         parDB.setIdParametro(par.getId());
  366.                         parDB.setValore(par.getValueAsString());
  367.                         allarme.addAllarmeParametro(parDB);
  368.                     }
  369.                 }
  370.             }
  371.             
  372.             // data modifica
  373.             allarme.setLasttimestampUpdate(new Date());
  374.             
  375.             boolean modificatoInformazioniHistory = false;
  376.             boolean modificatoStato = false;
  377.             boolean modificatoAckwoldegment = false;
  378.             ConfigurazioneAllarmeBean oldConfigurazioneAllarme = confCore.getAllarme(idAllarme);
  379.             // se ho modificato l'abilitato devo registrare la modifica nella tabella history
  380.             if(allarme.getEnabled().intValue() != oldEnabled.intValue()) {
  381.                 modificatoInformazioniHistory = true;
  382.                 
  383.                 if(allarme.getEnabled().intValue() == 0) {
  384.                     // se disabilito resetto lo stato per quando lo riabilito
  385.                     allarme.setStato(AllarmiConverterUtils.toIntegerValue(StatoAllarme.OK));
  386.                     allarme.setDettaglioStato(null);
  387.                 }
  388.             }
  389.             
  390.             // insert sul db
  391.             confCore.performUpdateOperation(userLogin, confHelper.smista(), allarme);
  392.             
  393.             if(modificatoInformazioniHistory && alarmEngineConfig.isHistoryEnabled()) {
  394.                 // registro la modifica
  395.                 AllarmeHistory history = ConfigurazioneUtilities.createAllarmeHistory(oldConfigurazioneAllarme, userLogin);
  396.                 confCore.performCreateOperation(userLogin, confHelper.smista(), history);
  397.             }
  398.             
  399.             /* ******** GESTIONE AVVIO THREAD NEL CASO DI ATTIVO *************** */
  400.             try {
  401.                 AllarmiUtils.notifyStateActiveThread(false, modificatoStato, modificatoAckwoldegment, oldConfigurazioneAllarme, allarme, ControlStationCore.getLog(), alarmEngineConfig);
  402.             } catch(Exception e) {
  403.                 String errorMsg = MessageFormat.format(ConfigurazioneCostanti.MESSAGGIO_ERRORE_ALLARME_SALVATO_NOTIFICA_FALLITA, allarme.getAlias(),e.getMessage());
  404.                 ControlStationCore.getLog().error(errorMsg, e);
  405.                 pd.setMessage(errorMsg);
  406.             }
  407.                 
  408.             // Preparo la lista
  409.             int idLista = Liste.CONFIGURAZIONE_ALLARMI;
  410.             
  411.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);
  412.             
  413.             ricerca = confHelper.checkSearchParameters(idLista, ricerca);

  415.             List<ConfigurazioneAllarmeBean> lista = confCore.allarmiList(ricerca, ruoloPorta, nomePorta); 
  416.             
  417.             confHelper.prepareAllarmiList(ricerca, lista, ruoloPorta, nomePorta, serviceBinding);
  418.             
  419.             // salvo l'oggetto ricerca nella sessione
  420.             ServletUtils.setSearchObjectIntoSession(request, session, ricerca);
  421.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  422.             
  423.             // Forward control to the specified success URI
  424.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_ALLARMI, ForwardParams.CHANGE());
  425.         } catch (Exception e) {
  426.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  427.                     ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_ALLARMI, ForwardParams.CHANGE());
  428.         }  
  429.     }
  430. }          
Created with JaCoCo 0.8.8.202204050719