PorteApplicativeAbilitazione.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.pa;

  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.PortaApplicativa;
  38. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  39. import org.openspcoop2.core.id.IDPortaApplicativa;
  40. import org.openspcoop2.core.id.IDServizio;
  41. import org.openspcoop2.core.mapping.MappingErogazionePortaApplicativa;
  42. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  43. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  44. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  45. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  46. import org.openspcoop2.message.constants.ServiceBinding;
  47. import org.openspcoop2.pdd.core.jmx.JMXUtils;
  48. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  49. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  50. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  51. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  52. import org.openspcoop2.web.ctrlstat.servlet.apc.AccordiServizioParteComuneCore;
  53. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
  54. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaHelper;
  55. import org.openspcoop2.web.ctrlstat.servlet.aps.erogazioni.ErogazioniHelper;
  56. import org.openspcoop2.web.lib.mvc.Costanti;
  57. import org.openspcoop2.web.lib.mvc.ForwardParams;
  58. import org.openspcoop2.web.lib.mvc.GeneralData;
  59. import org.openspcoop2.web.lib.mvc.MessageType;
  60. import org.openspcoop2.web.lib.mvc.PageData;
  61. import org.openspcoop2.web.lib.mvc.ServletUtils;
  62. import org.openspcoop2.web.lib.mvc.TipoOperazione;
  63. import org.openspcoop2.web.lib.users.dao.PermessiUtente;

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

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

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

  82.         // Inizializzo PageData
  83.         PageData pd = new PageData();

  85.         GeneralHelper generalHelper = new GeneralHelper(session);

  87.         // Inizializzo GeneralData
  88.         GeneralData gd = generalHelper.initGeneralData(request);

  90.         try {
  91.             PorteApplicativeHelper porteApplicativeHelper = new PorteApplicativeHelper(request, pd, session);
  92.             
  93.             // prelevo il flag che mi dice da quale pagina ho acceduto la sezione delle porte applicative
  94.             Integer parentPA = ServletUtils.getIntegerAttributeFromSession(PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT, session, request);
  95.             if(parentPA == null) parentPA = PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_NONE;
  96.             
  97.             String changeAbilitato = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ABILITA);
  98.             String nomePorta = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_NOME_PORTA);
  99.             String idPorta = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID);
  100.             String idsogg = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_SOGGETTO);
  101.             int soggInt = Integer.parseInt(idsogg);
  102.             String idAsps = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_ASPS);
  103.             if(idAsps == null)
  104.                 idAsps = "";
  105.             
  106.             String idTab = porteApplicativeHelper.getParameter(CostantiControlStation.PARAMETRO_ID_TAB);
  107.             if(!porteApplicativeHelper.isModalitaCompleta() && StringUtils.isNotEmpty(idTab)) {
  108.                 ServletUtils.setObjectIntoSession(request, session, idTab, CostantiControlStation.PARAMETRO_ID_TAB);
  109.             }
  110.             
  111.             String fromAPIPageInfo = porteApplicativeHelper.getParameter(CostantiControlStation.PARAMETRO_API_PAGE_INFO);
  112.             boolean fromApi = Costanti.CHECK_BOX_ENABLED_TRUE.equalsIgnoreCase(fromAPIPageInfo);
  113.             
  114.             String actionConferma = porteApplicativeHelper.getParameter(Costanti.PARAMETRO_ACTION_CONFIRM);
  115.             
  116.             // check su oldNomePD
  117.             PageData pdOld =  ServletUtils.getPageDataFromSession(request, session);
  118.             String oldNomePA = pdOld.getHidden(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_OLD_NOME_PA);
  119.             oldNomePA = (((oldNomePA != null) && !oldNomePA.equals("")) ? oldNomePA : nomePorta);
  120.             
  121.             // Preparo il menu
  122.             porteApplicativeHelper.makeMenu();

  124.             PorteApplicativeCore porteApplicativeCore = new PorteApplicativeCore();
  125.             AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(porteApplicativeCore);
  126.             AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore(porteApplicativeCore);

  128.             // Prendo la porta applicativa
  129.             PortaApplicativa pa = porteApplicativeCore.getPortaApplicativa(Integer.parseInt(idPorta));
  130.             
  131.             AccordoServizioParteSpecifica asps = apsCore.getAccordoServizioParteSpecifica(Integer.parseInt(idAsps));
  132.             AccordoServizioParteComuneSintetico aspc = apcCore.getAccordoServizioSintetico(IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune()));
  133.             ServiceBinding serviceBinding = apcCore.toMessageServiceBinding(aspc.getServiceBinding());
  134.             
  135.             // in progress segnalo l'azione che si sta effettuando
  136.             if(actionConferma == null) {
  137.                 String messaggio = porteApplicativeHelper.getMessaggioConfermaModificaRegolaMappingErogazionePortaApplicativa(fromApi, pa, serviceBinding, ServletUtils.isCheckBoxEnabled(changeAbilitato), true,true);

  139.                 pd.setMessage(messaggio, MessageType.CONFIRM);
  140.                 
  141.                 String[][] bottoni = { 
  142.                         { Costanti.LABEL_MONITOR_BUTTON_ANNULLA, 
  143.                             Costanti.LABEL_MONITOR_BUTTON_ANNULLA_CONFERMA_PREFIX +
  144.                             Costanti.LABEL_MONITOR_BUTTON_ANNULLA_CONFERMA_SUFFIX
  145.                             
  146.                         },
  147.                         { Costanti.LABEL_MONITOR_BUTTON_CONFERMA,
  148.                             Costanti.LABEL_MONITOR_BUTTON_ESEGUI_OPERAZIONE_CONFERMA_PREFIX +
  149.                             Costanti.LABEL_MONITOR_BUTTON_ESEGUI_OPERAZIONE_CONFERMA_SUFFIX }};

  151.                 pd.setBottoni(bottoni );
  152.             } 

  154.             // se ho confermato effettuo la modifica altrimenti torno direttamente alla lista
  155.             if(actionConferma != null && actionConferma.equals(Costanti.PARAMETRO_ACTION_CONFIRM_VALUE_OK)) {
  156.                 // Prendo la porta applicativa
  157.                 pa = porteApplicativeCore.getPortaApplicativa(Integer.parseInt(idPorta));
  158.                 // Modifico i dati della porta applicativa nel db
  159.                 pa.setNome(nomePorta);
  160.                 IDPortaApplicativa oldIDPortaApplicativaForUpdate = new IDPortaApplicativa();
  161.                 oldIDPortaApplicativaForUpdate.setNome(oldNomePA);
  162.                 pa.setOldIDPortaApplicativaForUpdate(oldIDPortaApplicativaForUpdate);
  163.                 
  164.                  // cambio solo la modalita'
  165.                 if(ServletUtils.isCheckBoxEnabled(changeAbilitato)) {
  166.                     pa.setStato(StatoFunzionalita.ABILITATO);
  167.                 }
  168.                 else{
  169.                     pa.setStato(StatoFunzionalita.DISABILITATO);
  170.                 }
  171.                 
  172.                 String userLogin = ServletUtils.getUserLoginFromSession(session);
  173.     
  174.                 porteApplicativeCore.performUpdateOperation(userLogin, porteApplicativeHelper.smista(), pa);
  175.                 
  176.                 List<String> aliasJmx = porteApplicativeCore.getJmxPdDAliases();
  177.                 if(aliasJmx!=null && !aliasJmx.isEmpty()) {
  178.                     for (String alias : aliasJmx) {
  179.                         String metodo = StatoFunzionalita.ABILITATO.equals(pa.getStato()) ? 
  180.                                 porteApplicativeCore.getJmxPdDConfigurazioneSistemaNomeMetodoEnablePortaApplicativa(alias) :
  181.                                 porteApplicativeCore.getJmxPdDConfigurazioneSistemaNomeMetodoDisablePortaApplicativa(alias);
  182.                         try{
  183.                             String stato = porteApplicativeCore.getInvoker().invokeJMXMethod(alias, 
  184.                                     porteApplicativeCore.getJmxPdDConfigurazioneSistemaType(alias),
  185.                                     porteApplicativeCore.getJmxPdDConfigurazioneSistemaNomeRisorsaConfigurazionePdD(alias), 
  186.                                     metodo, 
  187.                                     pa.getNome());
  188.                             if(stato==null) {
  189.                                 throw new ServletException("Aggiornamento fallito");
  190.                             }
  191.                             if(
  192.                                 !(
  193.                                     JMXUtils.MSG_OPERAZIONE_EFFETTUATA_SUCCESSO.equals(stato)
  194.                                     ||
  195.                                     (stato!=null && stato.startsWith(JMXUtils.MSG_OPERAZIONE_EFFETTUATA_SUCCESSO_PREFIX))
  196.                                 )
  197.                             ){
  198.                                 throw new ServletException(stato);
  199.                             }
  200.                         }catch(Exception e){
  201.                             String msgErrore = "Errore durante l'aggiornamento dello stato della PortaApplicativa '"+pa.getNome()+"' via jmx (jmxMethod '"+metodo+"') (node:"+alias+"): "+e.getMessage();
  202.                             ControlStationCore.logError(msgErrore, e);
  203.                         }
  204.                     }
  205.                 }
  206.             }
  207.             // Preparo la lista
  208.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);


  211.             List<PortaApplicativa> lista = null;
  212.             int idLista = -1;
  213.             
  214.         
  215.             switch (parentPA) {
  216.             case PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_CONFIGURAZIONE:
  217.                 
  218.                 if(fromApi) {
  219.                     ErogazioniHelper apsHelper = new ErogazioniHelper(request, pd, session);
  220.                     apsHelper.prepareErogazioneChange(TipoOperazione.CHANGE, asps, null);   
  221.                 }
  222.                 else {
  223.                 
  224.                     boolean datiInvocazione = ServletUtils.isCheckBoxEnabled(porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_CONFIGURAZIONE_DATI_INVOCAZIONE));
  225.                     if(datiInvocazione) {
  226.                         idLista = Liste.SERVIZI;
  227.                         ricerca = porteApplicativeHelper.checkSearchParameters(idLista, ricerca);
  228.                         boolean [] permessi = new boolean[2];
  229.                         PermessiUtente pu = ServletUtils.getUserFromSession(request, session).getPermessi();
  230.                         permessi[0] = pu.isServizi();
  231.                         permessi[1] = pu.isAccordiCooperazione();
  232.                         List<AccordoServizioParteSpecifica> listaS = null;
  233.                         String superUser   = ServletUtils.getUserLoginFromSession(session);
  234.                         if(apsCore.isVisioneOggettiGlobale(superUser)){
  235.                             listaS = apsCore.soggettiServizioList(null, ricerca,permessi,session, request);
  236.                         }else{
  237.                             listaS = apsCore.soggettiServizioList(superUser, ricerca,permessi,session, request);
  238.                         }
  239.                         AccordiServizioParteSpecificaHelper apsHelper = new AccordiServizioParteSpecificaHelper(request, pd, session);
  240.                         apsHelper.prepareServiziList(ricerca, listaS);
  241.                     }
  242.                     else {          
  243.                         idLista = Liste.CONFIGURAZIONE_EROGAZIONE;
  244.                         ricerca = porteApplicativeHelper.checkSearchParameters(idLista, ricerca);
  245.                         IDServizio idServizio2 = IDServizioFactory.getInstance().getIDServizioFromAccordo(asps); 
  246.                         Long idSoggetto = asps.getIdSoggetto() != null ? asps.getIdSoggetto() : -1L;
  247.                         List<MappingErogazionePortaApplicativa> lista2 = apsCore.mappingServiziPorteAppList(idServizio2,asps.getId(),ricerca);
  248.                         AccordiServizioParteSpecificaHelper apsHelper = new AccordiServizioParteSpecificaHelper(request, pd, session);
  249.                         apsHelper.prepareServiziConfigurazioneList(lista2, idAsps, idSoggetto+"", ricerca);
  250.                     }
  251.                     
  252.                 }
  253.                     
  254.                 break;
  255.             case PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_SOGGETTO:
  256.                 idLista = Liste.PORTE_APPLICATIVE_BY_SOGGETTO;
  257.                 ricerca = porteApplicativeHelper.checkSearchParameters(idLista, ricerca);
  258.                 lista = porteApplicativeCore.porteAppList(soggInt, ricerca);
  259.                 porteApplicativeHelper.preparePorteAppList(ricerca, lista,idLista);
  260.                 break;
  261.             case PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_NONE:
  262.             default:
  263.                 idLista = Liste.PORTE_APPLICATIVE;
  264.                 ricerca = porteApplicativeHelper.checkSearchParameters(idLista, ricerca);
  265.                 lista = porteApplicativeCore.porteAppList(null, ricerca);
  266.                 porteApplicativeHelper.preparePorteAppList(ricerca, lista,idLista);
  267.                 break;
  268.             }

  270.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  271.             
  272.             ForwardParams fwP = porteApplicativeHelper.isModalitaCompleta() ? ForwardParams.OTHER("") : PorteApplicativeCostanti.TIPO_OPERAZIONE_CONFIGURAZIONE;
  273.             // Forward control to the specified success URI
  274.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_ABILITAZIONE, fwP);
  275.         } catch (Exception e) {
  276.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  277.                     PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_ABILITAZIONE,
  278.                     ForwardParams.OTHER(""));

  280.         } 
  281.     }
  282. }
Created with JaCoCo 0.8.8.202204050719