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


  22. package org.openspcoop2.web.ctrlstat.servlet.pd;

  24. import java.util.List;

  26. import javax.servlet.ServletException;
  27. import javax.servlet.http.HttpServletRequest;
  28. import javax.servlet.http.HttpServletResponse;
  29. import javax.servlet.http.HttpSession;

  31. import org.apache.commons.lang.StringUtils;
  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.commons.Liste;
  37. import org.openspcoop2.core.config.PortaDelegata;
  38. import org.openspcoop2.core.config.PortaDelegataServizio;
  39. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  40. import org.openspcoop2.core.id.IDPortaDelegata;
  41. import org.openspcoop2.core.id.IDServizio;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.mapping.MappingFruizionePortaDelegata;
  44. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  45. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  46. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  47. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  48. import org.openspcoop2.message.constants.ServiceBinding;
  49. import org.openspcoop2.pdd.core.jmx.JMXUtils;
  50. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  51. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  52. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  53. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  54. import org.openspcoop2.web.ctrlstat.servlet.apc.AccordiServizioParteComuneCore;
  55. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
  56. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaHelper;
  57. import org.openspcoop2.web.ctrlstat.servlet.aps.erogazioni.ErogazioniHelper;
  58. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  59. import org.openspcoop2.web.lib.mvc.Costanti;
  60. import org.openspcoop2.web.lib.mvc.ForwardParams;
  61. import org.openspcoop2.web.lib.mvc.GeneralData;
  62. import org.openspcoop2.web.lib.mvc.MessageType;
  63. import org.openspcoop2.web.lib.mvc.PageData;
  64. import org.openspcoop2.web.lib.mvc.ServletUtils;
  65. import org.openspcoop2.web.lib.mvc.TipoOperazione;

  67. /**
  68.  * porteDelegateChange
  69.  * 
  70.  * @author Andrea Poli (apoli@link.it)
  71.  * @author Stefano Corallo (corallo@link.it)
  72.  * @author Sandra Giangrandi (sandra@link.it)
  73.  * @author $Author$
  74.  * @version $Rev$, $Date$
  75.  * 
  76.  */
  77. public final class PorteDelegateAbilitazione extends Action {

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

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

  84.         // Inizializzo PageData
  85.         PageData pd = new PageData();

  87.         GeneralHelper generalHelper = new GeneralHelper(session);

  89.         // Inizializzo GeneralData
  90.         GeneralData gd = generalHelper.initGeneralData(request);

  92.         try {
  93.             
  94.             PorteDelegateHelper porteDelegateHelper = new PorteDelegateHelper(request, pd, session);
  95.             // prelevo il flag che mi dice da quale pagina ho acceduto la sezione delle porte delegate
  96.             Integer parentPD = ServletUtils.getIntegerAttributeFromSession(PorteDelegateCostanti.ATTRIBUTO_PORTE_DELEGATE_PARENT, session, request);
  97.             if(parentPD == null) parentPD = PorteDelegateCostanti.ATTRIBUTO_PORTE_DELEGATE_PARENT_NONE;
  98.             
  99.             String changeAbilitato = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_ABILITA);
  100. //          String idPorta = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_ID);
  101.             String nomePorta = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_NOME_PORTA);
  102.             String idsogg = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_ID_SOGGETTO);
  103.             int soggInt = Integer.parseInt(idsogg);
  104.             String idAsps = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_ID_ASPS);
  105.             if(idAsps == null)
  106.                 idAsps = "";
  107.             
  108.             String idFruizione = porteDelegateHelper.getParameter(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_ID_FRUIZIONE);
  109.             if(idFruizione == null)
  110.                 idFruizione = "";
  111.             
  112.             String actionConferma = porteDelegateHelper.getParameter(Costanti.PARAMETRO_ACTION_CONFIRM);
  113.             
  114.             String idTab = porteDelegateHelper.getParameter(CostantiControlStation.PARAMETRO_ID_TAB);
  115.             if(!porteDelegateHelper.isModalitaCompleta() && StringUtils.isNotEmpty(idTab)) {
  116.                 ServletUtils.setObjectIntoSession(request, session, idTab, CostantiControlStation.PARAMETRO_ID_TAB);
  117.             }
  118.             
  119.             String fromAPIPageInfo = porteDelegateHelper.getParameter(CostantiControlStation.PARAMETRO_API_PAGE_INFO);
  120.             boolean fromApi = Costanti.CHECK_BOX_ENABLED_TRUE.equalsIgnoreCase(fromAPIPageInfo);
  121.             
  122.             // check su oldNomePD
  123.             PageData pdOld =  ServletUtils.getPageDataFromSession(request, session);
  124.             String oldNomePD = pdOld.getHidden(PorteDelegateCostanti.PARAMETRO_PORTE_DELEGATE_OLD_NOME_PD);
  125.             oldNomePD = (((oldNomePD != null) && !oldNomePD.equals("")) ? oldNomePD : nomePorta);
  126.             // Preparo il menu
  127.             porteDelegateHelper.makeMenu();

  129.             // Prendo nome e tipo del soggetto
  130.             PorteDelegateCore porteDelegateCore = new PorteDelegateCore();
  131.             SoggettiCore soggettiCore = new SoggettiCore(porteDelegateCore);
  132.             AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore(porteDelegateCore);
  133.             AccordiServizioParteSpecificaCore aspsCore = new AccordiServizioParteSpecificaCore(porteDelegateCore);
  134.             
  135.             IDSoggetto idSoggettoFruitore = null;
  136.             if(porteDelegateCore.isRegistroServiziLocale()){
  137.                 org.openspcoop2.core.registry.Soggetto soggetto = soggettiCore.getSoggettoRegistro(soggInt);
  138.                 idSoggettoFruitore = new IDSoggetto(soggetto.getTipo(), soggetto.getNome());
  139.             }else{
  140.                 org.openspcoop2.core.config.Soggetto soggetto = soggettiCore.getSoggetto(soggInt);
  141.                 idSoggettoFruitore = new IDSoggetto(soggetto.getTipo(), soggetto.getNome());
  142.             }

  144.             // Prendo la porta delegata
  145.             IDPortaDelegata idpd = new IDPortaDelegata();
  146.             idpd.setNome(oldNomePD);
  147.             PortaDelegata oldPD = porteDelegateCore.getPortaDelegata(idpd);
  148.             
  149.             Long idAspsLong = -1L;
  150.             if(idAsps.equals("")) {
  151.                 PortaDelegataServizio servizio2 = oldPD.getServizio();
  152.                 idAspsLong = servizio2.getId();
  153.             } else {
  154.                 idAspsLong = Long.parseLong(idAsps);
  155.             }
  156.             
  157.             AccordoServizioParteSpecifica asps = aspsCore.getAccordoServizioParteSpecifica(idAspsLong);
  158.             AccordoServizioParteComuneSintetico aspc = apcCore.getAccordoServizioSintetico(IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune()));
  159.             ServiceBinding serviceBinding = apcCore.toMessageServiceBinding(aspc.getServiceBinding());
  160.             
  161.             // in progress segnalo l'azione che si sta effettuando
  162.             if(actionConferma == null) {
  163.                 String messaggio = porteDelegateHelper.getMessaggioConfermaModificaRegolaMappingFruizionePortaDelegata(fromApi, oldPD,serviceBinding,ServletUtils.isCheckBoxEnabled(changeAbilitato), true, true);
  164.                 
  165.                 pd.setMessage(messaggio, MessageType.CONFIRM);
  166.                 
  167.                 String[][] bottoni = { 
  168.                         { Costanti.LABEL_MONITOR_BUTTON_ANNULLA, 
  169.                             Costanti.LABEL_MONITOR_BUTTON_ANNULLA_CONFERMA_PREFIX +
  170.                             Costanti.LABEL_MONITOR_BUTTON_ANNULLA_CONFERMA_SUFFIX
  171.                             
  172.                         },
  173.                         { Costanti.LABEL_MONITOR_BUTTON_CONFERMA,
  174.                             Costanti.LABEL_MONITOR_BUTTON_ESEGUI_OPERAZIONE_CONFERMA_PREFIX +
  175.                             Costanti.LABEL_MONITOR_BUTTON_ESEGUI_OPERAZIONE_CONFERMA_SUFFIX }};

  177.                 pd.setBottoni(bottoni);
  178.                 
  179.             } 

  181.             // se ho confermato effettuo la modifica altrimenti torno direttamente alla lista
  182.             if(actionConferma != null && actionConferma.equals(Costanti.PARAMETRO_ACTION_CONFIRM_VALUE_OK)) {
  183.                 long idPA = oldPD.getId();
  184.                 PortaDelegata portaDelegata = (PortaDelegata) oldPD.clone();// new
  185.                 portaDelegata.setId(idPA);
  186.                 portaDelegata.setNome(nomePorta);
  187.                 
  188.                 // cambio solo la modalita'
  189.                 if(ServletUtils.isCheckBoxEnabled(changeAbilitato)) {
  190.                     portaDelegata.setStato(StatoFunzionalita.ABILITATO);
  191.                 }
  192.                 else{
  193.                     portaDelegata.setStato(StatoFunzionalita.DISABILITATO);
  194.                 }
  195.                 String userLogin = ServletUtils.getUserLoginFromSession(session);
  196.                 porteDelegateCore.performUpdateOperation(userLogin, porteDelegateHelper.smista(), portaDelegata);
  197.                 
  198.                 List<String> aliasJmx = porteDelegateCore.getJmxPdDAliases();
  199.                 if(aliasJmx!=null && !aliasJmx.isEmpty()) {
  200.                     for (String alias : aliasJmx) {
  201.                         String metodo = StatoFunzionalita.ABILITATO.equals(portaDelegata.getStato()) ? 
  202.                                 porteDelegateCore.getJmxPdDConfigurazioneSistemaNomeMetodoEnablePortaDelegata(alias) :
  203.                                     porteDelegateCore.getJmxPdDConfigurazioneSistemaNomeMetodoDisablePortaDelegata(alias);
  204.                         try{
  205.                             String stato = porteDelegateCore.getInvoker().invokeJMXMethod(alias, 
  206.                                     porteDelegateCore.getJmxPdDConfigurazioneSistemaType(alias),
  207.                                     porteDelegateCore.getJmxPdDConfigurazioneSistemaNomeRisorsaConfigurazionePdD(alias), 
  208.                                     metodo, 
  209.                                     portaDelegata.getNome());
  210.                             if(stato==null) {
  211.                                 throw new ServletException("Aggiornamento fallito");
  212.                             }
  213.                             if(
  214.                                     !(
  215.                                         JMXUtils.MSG_OPERAZIONE_EFFETTUATA_SUCCESSO.equals(stato)
  216.                                         ||
  217.                                         (stato!=null && stato.startsWith(JMXUtils.MSG_OPERAZIONE_EFFETTUATA_SUCCESSO_PREFIX))
  218.                                     )
  219.                                 ){
  220.                                 throw new ServletException(stato);
  221.                             }
  222.                         }catch(Exception e){
  223.                             String msgErrore = "Errore durante l'aggiornamento dello stato della PortaDelegata '"+portaDelegata.getNome()+"' via jmx (jmxMethod '"+metodo+"') (node:"+alias+"): "+e.getMessage();
  224.                             ControlStationCore.logError(msgErrore, e);
  225.                         }
  226.                     }
  227.                 }
  228.             }
  229.             // Preparo la lista
  230.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);


  233.             int idLista = -1;
  234.             List<PortaDelegata> lista = null;
  235.             
  236.             switch (parentPD) {
  237.             case PorteDelegateCostanti.ATTRIBUTO_PORTE_DELEGATE_PARENT_CONFIGURAZIONE:
  238.                 if(fromApi) {
  239.                     ErogazioniHelper apsHelper = new ErogazioniHelper(request, pd, session);
  240.                     apsHelper.prepareErogazioneChange(TipoOperazione.CHANGE, asps, idSoggettoFruitore); 
  241.                 }
  242.                 else {
  243.                     idLista = Liste.CONFIGURAZIONE_FRUIZIONE;
  244.                     ricerca = porteDelegateHelper.checkSearchParameters(idLista, ricerca);
  245.                     IDServizio idServizio2 = IDServizioFactory.getInstance().getIDServizioFromAccordo(asps); 
  246.                     
  247.                     List<MappingFruizionePortaDelegata> listaMapping = aspsCore.serviziFruitoriMappingList((long) Integer.parseInt(idFruizione), idSoggettoFruitore, idServizio2, ricerca);
  248.                     AccordiServizioParteSpecificaHelper apsHelper = new AccordiServizioParteSpecificaHelper(request, pd, session);
  249.                     apsHelper.serviziFruitoriMappingList(listaMapping, idAsps, idsogg, idSoggettoFruitore, idFruizione, ricerca); 
  250.                 }               
  251.                 break;
  252.             case PorteDelegateCostanti.ATTRIBUTO_PORTE_DELEGATE_PARENT_SOGGETTO:
  253.                 idLista = Liste.PORTE_DELEGATE_BY_SOGGETTO;
  254.                 ricerca = porteDelegateHelper.checkSearchParameters(idLista, ricerca);
  255.                 lista = porteDelegateCore.porteDelegateList(soggInt, ricerca);
  256.                 porteDelegateHelper.preparePorteDelegateList(ricerca, lista,idLista);
  257.                 break;
  258.             case PorteDelegateCostanti.ATTRIBUTO_PORTE_DELEGATE_PARENT_NONE:
  259.             default:
  260.                 idLista = Liste.PORTE_DELEGATE;
  261.                 ricerca = porteDelegateHelper.checkSearchParameters(idLista, ricerca);
  262.                 lista = porteDelegateCore.porteDelegateList(null, ricerca);
  263.                 porteDelegateHelper.preparePorteDelegateList(ricerca, lista,idLista);
  264.                 break;
  265.             }

  267.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  268.             
  269.             ForwardParams fwP = porteDelegateHelper.isModalitaCompleta() ? ForwardParams.OTHER("") : PorteDelegateCostanti.TIPO_OPERAZIONE_CONFIGURAZIONE;
  270.             // Forward control to the specified success URI
  271.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, PorteDelegateCostanti.OBJECT_NAME_PORTE_DELEGATE_ABILITAZIONE,fwP);

  273.         } catch (Exception e) {
  274.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  275.                     PorteDelegateCostanti.OBJECT_NAME_PORTE_DELEGATE_ABILITAZIONE, 
  276.                     ForwardParams.OTHER(""));
  277.         }  
  278.     }
  279. }
Created with JaCoCo 0.8.8.202204050719