PorteApplicativeTrasformazioniRispostaAdd.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.  */
  20. package org.openspcoop2.web.ctrlstat.servlet.pa;

  22. import java.util.ArrayList;
  23. import java.util.Arrays;
  24. import java.util.List;

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

  30. import org.apache.commons.lang.StringUtils;
  31. import org.apache.struts.action.Action;
  32. import org.apache.struts.action.ActionForm;
  33. import org.apache.struts.action.ActionForward;
  34. import org.apache.struts.action.ActionMapping;
  35. import org.openspcoop2.core.commons.Liste;
  36. import org.openspcoop2.core.config.PortaApplicativa;
  37. import org.openspcoop2.core.config.TrasformazioneRegola;
  38. import org.openspcoop2.core.config.TrasformazioneRegolaApplicabilitaRisposta;
  39. import org.openspcoop2.core.config.TrasformazioneRegolaRisposta;
  40. import org.openspcoop2.core.config.Trasformazioni;
  41. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  42. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  43. import org.openspcoop2.message.constants.ServiceBinding;
  44. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  45. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  46. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  47. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  48. import org.openspcoop2.web.ctrlstat.servlet.apc.AccordiServizioParteComuneCore;
  49. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
  50. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  51. import org.openspcoop2.web.lib.mvc.DataElement;
  52. import org.openspcoop2.web.lib.mvc.ForwardParams;
  53. import org.openspcoop2.web.lib.mvc.GeneralData;
  54. import org.openspcoop2.web.lib.mvc.PageData;
  55. import org.openspcoop2.web.lib.mvc.Parameter;
  56. import org.openspcoop2.web.lib.mvc.ServletUtils;
  57. import org.openspcoop2.web.lib.mvc.TipoOperazione;

  59. /**
  60.  * PorteApplicativeTrasformazioniRispostaAdd
  61.  * 
  62.  * @author Giuliano Pintori (pintori@link.it)
  63.  * @author $Author$
  64.  * @version $Rev$, $Date$
  65.  * 
  66.  */
  67. public class PorteApplicativeTrasformazioniRispostaAdd extends Action {

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

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

  74.         // Inizializzo PageData
  75.         PageData pd = new PageData();

  77.         GeneralHelper generalHelper = new GeneralHelper(session);

  79.         String userLogin = ServletUtils.getUserLoginFromSession(session);   
  80.         // Inizializzo GeneralData
  81.         GeneralData gd = generalHelper.initGeneralData(request);

  83.         try {
  84.             PorteApplicativeHelper porteApplicativeHelper = new PorteApplicativeHelper(request, pd, session);
  85.             // prelevo il flag che mi dice da quale pagina ho acceduto la sezione delle porte applicative
  86.             Integer parentPA = ServletUtils.getIntegerAttributeFromSession(PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT, session, request);
  87.             if(parentPA == null) parentPA = PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_NONE;
  88.             
  89.             String idPorta = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID);
  90.             int idInt = Integer.parseInt(idPorta);
  91.             String idsogg = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_SOGGETTO);
  92.             String idAsps = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_ASPS);
  93.             if(idAsps == null) 
  94.                 idAsps = "";
  95.             String idTrasformazioneS = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_TRASFORMAZIONE);
  96.             long idTrasformazione = Long.parseLong(idTrasformazioneS);
  97.             
  98.             String nomeRisposta = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_NOME);
  99.             
  100.             String returnCode = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_STATUS);
  101.             if(returnCode == null)
  102.                 returnCode = CostantiControlStation.VALUE_PARAMETRO_CONFIGURAZIONE_RETURN_CODE_QUALSIASI;
  103.             
  104.             String statusMin = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_STATUS_MIN);
  105.             if(statusMin == null)
  106.                 statusMin = "";
  107.             String statusMax = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_STATUS_MAX);
  108.             if(statusMax == null)
  109.                 statusMax = "";
  110.             
  111.             String pattern = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_PATTERN);
  112.             String contentType = porteApplicativeHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_CT);
  113.             
  114.             

  116.             PorteApplicativeCore porteApplicativeCore = new PorteApplicativeCore();
  117.             AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(porteApplicativeCore);
  118.             AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore(porteApplicativeCore);
  119.             SoggettiCore soggettiCore = new SoggettiCore(porteApplicativeCore);
  120.                         
  121.             // Preparo il menu
  122.             porteApplicativeHelper.makeMenu();

  124.             // Prendo nome della porta applicativa
  125.             PortaApplicativa pa = porteApplicativeCore.getPortaApplicativa(idInt);
  126.             String nomePorta = pa.getNome();
  127.             String protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(pa.getTipoSoggettoProprietario());
  128.             
  129.             Trasformazioni trasformazioni = pa.getTrasformazioni();
  130.             TrasformazioneRegola regola = null;
  131.             for (int j = 0; j < trasformazioni.sizeRegolaList(); j++) {
  132.                 TrasformazioneRegola regolaTmp = trasformazioni.getRegola(j);
  133.                 if (regolaTmp.getId().longValue() == idTrasformazione) {
  134.                     regola = regolaTmp;
  135.                     break;
  136.                 }
  137.             }
  138.             if(regola==null) {
  139.                 throw new Exception("TrasformazioneRegola con id '"+idTrasformazione+"' non trovata");
  140.             }
  141.             
  142.             AccordoServizioParteSpecifica asps = apsCore.getAccordoServizioParteSpecifica(Integer.parseInt(idAsps));
  143.             AccordoServizioParteComuneSintetico apc = apcCore.getAccordoServizioSintetico(asps.getIdAccordo()); 
  144.             ServiceBinding serviceBinding = apcCore.toMessageServiceBinding(apc.getServiceBinding());
  145.             
  146.             String nomeTrasformazione = regola.getNome();
  147.             Parameter pIdTrasformazione = new Parameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_TRASFORMAZIONE, idTrasformazione+"");
  148.             
  149.             String postBackElementName = porteApplicativeHelper.getPostBackElementName();
  150.             
  151.             // se ho modificato il soggetto ricalcolo il servizio e il service binding
  152.             if (postBackElementName != null &&
  153.                 postBackElementName.equals(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_APPLICABILITA_STATUS)) {
  154.                 statusMin = "";
  155.                 statusMax = "";
  156.             }

  158.             List<Parameter> lstParam = porteApplicativeHelper.getTitoloPA(parentPA, idsogg, idAsps);

  160.             String labelPerPorta = null;
  161.             if(parentPA!=null && (parentPA.intValue() == PorteApplicativeCostanti.ATTRIBUTO_PORTE_APPLICATIVE_PARENT_CONFIGURAZIONE)) {
  162.                 labelPerPorta = porteApplicativeCore.getLabelRegolaMappingErogazionePortaApplicativa(
  163.                         PorteApplicativeCostanti.LABEL_PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_DI,
  164.                         PorteApplicativeCostanti.LABEL_PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI,
  165.                         pa);
  166.             }
  167.             else {
  168.                 labelPerPorta = PorteApplicativeCostanti.LABEL_PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_DI+nomePorta;
  169.             }

  171.             lstParam.add(new Parameter(labelPerPorta,
  172.                     PorteApplicativeCostanti.SERVLET_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_LIST,
  173.                     new Parameter( PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID, idPorta),
  174.                     new Parameter( PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_SOGGETTO, idsogg),
  175.                     new Parameter( PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_ASPS, idAsps)
  176.                     ));
  177.             
  178.             lstParam.add(new Parameter(nomeTrasformazione, PorteApplicativeCostanti.SERVLET_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_CHANGE, 
  179.                     new Parameter( PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID, idPorta),
  180.                     new Parameter( PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_SOGGETTO, idsogg),
  181.                     new Parameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_ASPS, idAsps), pIdTrasformazione));
  182.             
  183.             String labelPag = PorteApplicativeCostanti.LABEL_PARAMETRO_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE;
  184.             
  185.             List<Parameter> parametriInvocazioneServletTrasformazioniRisposta = new ArrayList<>();
  186.             parametriInvocazioneServletTrasformazioniRisposta.add(new Parameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID, idPorta));
  187.             parametriInvocazioneServletTrasformazioniRisposta.add(new Parameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_SOGGETTO, idsogg));
  188.             parametriInvocazioneServletTrasformazioniRisposta.add(new Parameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_ID_ASPS, idAsps));
  189.             parametriInvocazioneServletTrasformazioniRisposta.add(pIdTrasformazione);
  190.             
  191.             lstParam.add(new Parameter(labelPag,PorteApplicativeCostanti.SERVLET_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA_LIST,parametriInvocazioneServletTrasformazioniRisposta));
  192.             
  193.             lstParam.add(ServletUtils.getParameterAggiungi());

  195.             ServletUtils.setPageDataTitle(pd, lstParam);

  197.             // Se nomehid = null, devo visualizzare la pagina per l'inserimento
  198.             // dati
  199.             if (porteApplicativeHelper.isEditModeInProgress()) {
  200.                 // preparo i campi
  201.                 List<DataElement> dati = new ArrayList<>();
  202.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  203.                 
  204.                 dati = porteApplicativeHelper.addTrasformazioneRispostaToDatiOpAdd(protocollo, dati, idTrasformazioneS, 
  205.                         apc.getServiceBinding(),
  206.                         nomeRisposta, returnCode, statusMin, statusMax, pattern, contentType);
  207.                 
  208.                 dati = porteApplicativeHelper.addHiddenFieldsToDati(TipoOperazione.ADD, idPorta, idsogg, idPorta,idAsps,  dati);
  209.                 
  210.                 pd.setDati(dati);

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

  214.                 return ServletUtils.getStrutsForwardEditModeInProgress(mapping, PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA, ForwardParams.ADD());
  215.             }
  216.             
  217.             
  218.             boolean isOk = porteApplicativeHelper.trasformazioniRispostaCheckData(TipoOperazione.ADD, regola, null,
  219.                     serviceBinding);
  220.             
  221.             if(isOk) {
  222.                 // quando un parametro viene inviato come vuoto, sul db viene messo null, gestisco il caso
  223.                 Integer statusMinDBCheck = StringUtils.isNotEmpty(statusMin) ? Integer.parseInt(statusMin) : null;
  224.                 Integer statusMaxDBCheck = StringUtils.isNotEmpty(statusMax) ? Integer.parseInt(statusMax) : null;
  225.                 if(returnCode.equals(CostantiControlStation.VALUE_PARAMETRO_CONFIGURAZIONE_RETURN_CODE_ESATTO))
  226.                     statusMaxDBCheck = statusMinDBCheck;
  227.                 String patternDBCheck = StringUtils.isNotEmpty(pattern) ? pattern : null;
  228.                 String contentTypeDBCheck = StringUtils.isNotEmpty(contentType) ? contentType : null;
  229.                 boolean giaRegistrato = porteApplicativeCore.existsTrasformazioneRisposta(Long.parseLong(idPorta), idTrasformazione, statusMinDBCheck, statusMaxDBCheck, patternDBCheck, contentTypeDBCheck);
  230.                 if (giaRegistrato) {
  231.                     pd.setMessage(CostantiControlStation.MESSAGGIO_ERRORE_REGOLA_TRASFORMAZIONE_APPLICABILITA_DUPLICATA);
  232.                     isOk = false;
  233.                 }
  234.                 if (isOk) {
  235.                     giaRegistrato = porteApplicativeCore.existsTrasformazioneRisposta(Long.parseLong(idPorta), idTrasformazione, nomeRisposta);
  236.                     if (giaRegistrato) {
  237.                         pd.setMessage(CostantiControlStation.MESSAGGIO_ERRORE_REGOLA_TRASFORMAZIONE_APPLICABILITA_NOME);
  238.                         isOk = false;
  239.                     }
  240.                 }
  241.             }
  242.             
  243.             if (!isOk) {

  245.                 // preparo i campi
  246.                 List<DataElement> dati = new ArrayList<>();

  248.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  249.                 
  250.                 dati = porteApplicativeHelper.addTrasformazioneRispostaToDatiOpAdd(protocollo, dati, idTrasformazioneS, 
  251.                         apc.getServiceBinding(),
  252.                         nomeRisposta, returnCode, statusMin, statusMax, pattern, contentType);
  253.                 
  254.                 dati = porteApplicativeHelper.addHiddenFieldsToDati(TipoOperazione.ADD, idPorta, idsogg, idPorta,idAsps,  dati);
  255.                 
  256.                 pd.setDati(dati);

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

  260.                 return ServletUtils.getStrutsForwardEditModeCheckError(mapping, PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA, ForwardParams.ADD());
  261.             }
  262.             
  263.             // salvataggio nuova regola
  264.             for (int j = 0; j < trasformazioni.sizeRegolaList(); j++) {
  265.                 TrasformazioneRegola regolaTmp = trasformazioni.getRegola(j);
  266.                 if (regolaTmp.getId().longValue() == idTrasformazione) {
  267.                     regola = regolaTmp;
  268.                     break;
  269.                 }
  270.             }
  271.             
  272.             TrasformazioneRegolaRisposta risposta = new TrasformazioneRegolaRisposta();

  274.             // calcolo prossima posizione
  275.             int posizione = 1;
  276.             for (TrasformazioneRegolaRisposta check : regola.getRispostaList()) {
  277.                 if(check.getPosizione()>=posizione) {
  278.                     posizione = check.getPosizione()+1;
  279.                 }
  280.             }
  281.             
  282.             risposta.setNome(nomeRisposta);
  283.             risposta.setPosizione(posizione);
  284.             
  285.             TrasformazioneRegolaApplicabilitaRisposta applicabilita = new TrasformazioneRegolaApplicabilitaRisposta();
  286.             
  287.             if(returnCode.equals(CostantiControlStation.VALUE_PARAMETRO_CONFIGURAZIONE_RETURN_CODE_QUALSIASI)) {
  288.                 applicabilita.setReturnCodeMin(null);
  289.                 applicabilita.setReturnCodeMax(null);
  290.             } else if(returnCode.equals(CostantiControlStation.VALUE_PARAMETRO_CONFIGURAZIONE_RETURN_CODE_ESATTO)) {
  291.                 applicabilita.setReturnCodeMin(StringUtils.isNotEmpty(statusMin) ? Integer.parseInt(statusMin) : null);
  292.                 applicabilita.setReturnCodeMax(StringUtils.isNotEmpty(statusMin) ? Integer.parseInt(statusMin) : null);
  293.             } else { // intervallo
  294.                 applicabilita.setReturnCodeMin(StringUtils.isNotEmpty(statusMin) ? Integer.parseInt(statusMin) : null);
  295.                 applicabilita.setReturnCodeMax(StringUtils.isNotEmpty(statusMax) ? Integer.parseInt(statusMax) : null);
  296.             }
  297.             
  298.             applicabilita.setPattern(pattern);
  299.             if(contentType != null) {
  300.                 applicabilita.getContentTypeList().addAll(Arrays.asList(contentType.split(",")));
  301.             }
  302.             
  303.             
  304.             risposta.setApplicabilita(applicabilita);
  305.             regola.addRisposta(risposta );
  306.             porteApplicativeCore.performUpdateOperation(userLogin, porteApplicativeHelper.smista(), pa);
  307.             
  308.             // ricaricare id trasformazione
  309.             pa = porteApplicativeCore.getPortaApplicativa(Long.parseLong(idPorta));

  311.             TrasformazioneRegola trasformazioneAggiornata = porteApplicativeCore.getTrasformazione(pa.getId(), regola.getNome());
  312.             
  313.             // Preparo la lista
  314.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);
  315.             
  316.             int idLista = Liste.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE; 
  317.             
  318.             ricerca = porteApplicativeHelper.checkSearchParameters(idLista, ricerca);

  320.             List<TrasformazioneRegolaRisposta> lista = porteApplicativeCore.porteAppTrasformazioniRispostaList(Long.parseLong(idPorta), trasformazioneAggiornata.getId(), ricerca);
  321.             
  322.             porteApplicativeHelper.preparePorteAppTrasformazioniRispostaList(nomePorta, trasformazioneAggiornata.getId(), ricerca, lista); 
  323.                         
  324.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);

  326.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA, ForwardParams.ADD());


  329.         } catch (Exception e) {
  330.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, PorteApplicativeCostanti.OBJECT_NAME_PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTA, ForwardParams.ADD());
  331.         } 
  332.     }
  333. }
Created with JaCoCo 0.8.8.202204050719