ConnettorePropAdd.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.connettori;

  24. import java.util.ArrayList;
  25. import java.util.List;

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

  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.config.InvocazioneServizio;
  36. import org.openspcoop2.core.config.RispostaAsincrona;
  37. import org.openspcoop2.core.config.ServizioApplicativo;
  38. import org.openspcoop2.core.constants.CostantiConnettori;
  39. import org.openspcoop2.core.constants.CostantiDB;
  40. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  41. import org.openspcoop2.core.registry.Connettore;
  42. import org.openspcoop2.core.registry.Fruitore;
  43. import org.openspcoop2.core.registry.Property;
  44. import org.openspcoop2.core.registry.Soggetto;
  45. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  46. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  47. import org.openspcoop2.web.ctrlstat.dao.SoggettoCtrlStat;
  48. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  49. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
  50. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCostanti;
  51. import org.openspcoop2.web.ctrlstat.servlet.pa.PorteApplicativeCostanti;
  52. import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCore;
  53. import org.openspcoop2.web.ctrlstat.servlet.sa.ServiziApplicativiCostanti;
  54. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  55. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCostanti;
  56. import org.openspcoop2.web.lib.mvc.DataElement;
  57. import org.openspcoop2.web.lib.mvc.ForwardParams;
  58. import org.openspcoop2.web.lib.mvc.GeneralData;
  59. import org.openspcoop2.web.lib.mvc.PageData;
  60. import org.openspcoop2.web.lib.mvc.ServletUtils;
  61. import org.openspcoop2.web.lib.mvc.TipoOperazione;

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

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

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

  80.         GeneralHelper generalHelper = new GeneralHelper(session);

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

  85.         // Inizializzo GeneralData
  86.         GeneralData gd = generalHelper.initGeneralData(request);

  88.         try {
  89.             ConnettoriHelper connettoriHelper = new ConnettoriHelper(request, pd, session);

  91.             String servlet = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_SERVLET);
  92.             String id = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_ID);
  93.             String nomeprov = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_NOME_SOGGETTO);
  94.             String tipoprov = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_TIPO_SOGGETTO);
  95.             String nomeservizio = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_NOME_SERVIZIO);
  96.             String tiposervizio = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_TIPO_SERVIZIO);
  97.             String versioneservizio = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_VERSIONE_SERVIZIO);
  98.             String myId = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_MY_ID);
  99.             String correlato = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_CORRELATO);
  100.             String idSoggErogatore = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_ID_SOGGETTO_EROGATORE);
  101.             String nomeservizioApplicativo = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_NOME_SERVIZIO_APPLICATIVO);
  102.             String idsil = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_ID_SERVIZIO_APPLICATIVO);

  104.             String nome = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_NOME);
  105.             String valore = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_VALORE);

  107.             String provider = connettoriHelper.getParameter(ServiziApplicativiCostanti.PARAMETRO_SERVIZI_APPLICATIVI_PROVIDER);
  108.             
  109.             String tipoAccordo = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_TIPO_ACCORDO);
  110.             if("".equals(tipoAccordo))
  111.                 tipoAccordo = null;
  112.             
  113.             String idPorta = connettoriHelper.getParameter(ConnettoriCostanti.PARAMETRO_CONNETTORE_CUSTOM_ID_PORTA);
  114.             if(idPorta == null)
  115.                 idPorta = "";
  116.             
  117.             String accessoDaAPSParametro = connettoriHelper.getParameter(PorteApplicativeCostanti.PARAMETRO_PORTE_APPLICATIVE_CONNETTORE_DA_LISTA_APS);
  118.             if(accessoDaAPSParametro == null)
  119.                 accessoDaAPSParametro = "";
  120.             
  121.             String azioneConnettoreIdPorta = connettoriHelper.getParameter(AccordiServizioParteSpecificaCostanti.PARAMETRO_APS_FRUITORE_VIEW_CONNETTORE_MAPPING_AZIONE_ID_PORTA);
  122.             if(azioneConnettoreIdPorta==null) {
  123.                 azioneConnettoreIdPorta="";
  124.             }
  125.             
  126.             ConnettoriCore connettoriCore = new ConnettoriCore();
  127.             SoggettiCore soggettiCore = new SoggettiCore(connettoriCore);
  128.             ServiziApplicativiCore saCore = new ServiziApplicativiCore(connettoriCore);
  129.             AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(connettoriCore);

  131.             // Preparo il menu
  132.             connettoriHelper.makeMenu();

  134.             // Se idhid = null, devo visualizzare la pagina per l'inserimento
  135.             // dati
  136.             if(connettoriHelper.isEditModeInProgress()){
  137.                 
  138.                 // setto la barra del titolo
  139.                 connettoriHelper.setTitleProprietaConnettoriCustom(pd, TipoOperazione.ADD, servlet, id, nomeprov, tipoprov, nomeservizio, tiposervizio, 
  140.                         myId, correlato, idSoggErogatore, nomeservizioApplicativo, idsil, tipoAccordo, provider,idPorta);
  141.                 
  142.                 // preparo i campi
  143.                 List<DataElement> dati = new ArrayList<>();
  144.                 
  145.                 dati.add(ServletUtils.getDataElementForEditModeFinished());

  147.                 ConnettoreCustomUtils.addProprietaConnettoriCustom(dati, nome, valore, servlet, id, nomeprov, tipoprov, nomeservizio, tiposervizio, versioneservizio,
  148.                         myId, correlato, idSoggErogatore, nomeservizioApplicativo, idsil, tipoAccordo, provider,accessoDaAPSParametro, idPorta, azioneConnettoreIdPorta);
  149.                 
  150.                 pd.setDati(dati);

  152.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  153.                 
  154.                 return ServletUtils.getStrutsForwardEditModeInProgress(mapping, ConnettoriCostanti.OBJECT_NAME_CONNETTORI_CUSTOM_PROPERTIES, ForwardParams.ADD());
  155.             }

  157.             // Controlli sui campi immessi
  158.             boolean isOk = connettoriHelper.connettorePropCheckData();
  159.             if (!isOk) {
  160.                 
  161.                 // setto la barra del titolo
  162.                 connettoriHelper.setTitleProprietaConnettoriCustom(pd, TipoOperazione.ADD, servlet, id, nomeprov, tipoprov, nomeservizio, tiposervizio, 
  163.                         myId, correlato, idSoggErogatore, nomeservizioApplicativo, idsil, tipoAccordo, provider,idPorta);
  164.                 
  165.                 // preparo i campi
  166.                 List<DataElement> dati = new ArrayList<>();

  168.                 dati.add(ServletUtils.getDataElementForEditModeFinished());

  170.                 ConnettoreCustomUtils.addProprietaConnettoriCustom(dati, nome, valore, servlet, id, nomeprov, tipoprov, nomeservizio, tiposervizio, versioneservizio,
  171.                         myId, correlato, idSoggErogatore, nomeservizioApplicativo, idsil, tipoAccordo, provider,accessoDaAPSParametro, idPorta, azioneConnettoreIdPorta);
  172.                 
  173.                 pd.setDati(dati);

  175.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  176.                 
  177.                 return ServletUtils.getStrutsForwardEditModeCheckError(mapping, ConnettoriCostanti.OBJECT_NAME_CONNETTORI_CUSTOM_PROPERTIES, ForwardParams.ADD());
  178.             }

  180.             // Aggiorno il connettore nel db
  181.             String userLogin = ServletUtils.getUserLoginFromSession(session);
  182.             
  183.             String saveNomeFru = "";
  184.             String saveTipoFru = "";
  185.             if (servlet.equals(AccordiServizioParteSpecificaCostanti.SERVLET_NAME_APS_CHANGE)) {
  186.                 AccordoServizioParteSpecifica asps = apsCore.getAccordoServizioParteSpecifica(Long.parseLong(id));
  187.                 Connettore connettore = asps.getConfigurazioneServizio().getConnettore();
  188.                 connettore.setCustom(true);
  189.                 Property cp = new Property();
  190.                 cp.setNome(nome);
  191.                 cp.setValore(valore);
  192.                 connettore.addProperty(cp);
  193.                 asps.getConfigurazioneServizio().setConnettore(connettore);
  194.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), asps);
  195.             }
  196.             else if (servlet.equals(AccordiServizioParteSpecificaCostanti.SERVLET_NAME_APS_FRUITORI_CHANGE)) {
  197.                 int idServizioInt = Integer.parseInt(id);
  198.                 AccordoServizioParteSpecifica serviziosp = apsCore.getAccordoServizioParteSpecifica(idServizioInt);
  199.                 int idServizioFruitoreInt = Integer.parseInt(myId);
  200.                 Fruitore servFru = apsCore.getServizioFruitore(idServizioFruitoreInt);
  201.                 // Elimino il vecchio fruitore ed aggiungo il nuovo
  202.                 for (int i = 0; i < serviziosp.sizeFruitoreList(); i++) {
  203.                     Fruitore tmpFru = serviziosp.getFruitore(i);
  204.                     if (tmpFru.getId().longValue() == servFru.getId().longValue()) {
  205.                         serviziosp.removeFruitore(i);
  206.                         break;
  207.                     }
  208.                 }
  209.                 Connettore connettore = servFru.getConnettore();
  210.                 connettore.setCustom(true);
  211.                 Property cp = new Property();
  212.                 cp.setNome(nome);
  213.                 cp.setValore(valore);
  214.                 connettore.addProperty(cp);
  215.                 servFru.setConnettore(connettore);
  216.                 serviziosp.addFruitore(servFru);
  217.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), serviziosp);
  218.                 // Mi salvo i dati per identificare il fruitore
  219.                 saveNomeFru = servFru.getNome();
  220.                 saveTipoFru = servFru.getTipo();
  221.             }
  222.             else if (servlet.equals(ServiziApplicativiCostanti.SERVLET_NAME_SERVIZI_APPLICATIVI_ENDPOINT)) {
  223.                 int idSilInt = Integer.parseInt(idsil);
  224.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  225.                 InvocazioneServizio is = sa.getInvocazioneServizio();
  226.                 org.openspcoop2.core.config.Connettore connettore = is.getConnettore();
  227.                 connettore.setCustom(true);
  228.                 org.openspcoop2.core.config.Property cp =
  229.                     new org.openspcoop2.core.config.Property();
  230.                 cp.setNome(nome);
  231.                 cp.setValore(valore);
  232.                 connettore.addProperty(cp);
  233.                 is.setConnettore(connettore);
  234.                 sa.setInvocazioneServizio(is);
  235.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), sa);
  236.             }
  237.             else if (servlet.equals(ServiziApplicativiCostanti.SERVLET_NAME_SERVIZI_APPLICATIVI_ENDPOINT_RISPOSTA)) {
  238.                 int idSilInt = Integer.parseInt(idsil);
  239.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  240.                 RispostaAsincrona ra = sa.getRispostaAsincrona();
  241.                 org.openspcoop2.core.config.Connettore connettore = ra.getConnettore();
  242.                 connettore.setCustom(true);
  243.                 org.openspcoop2.core.config.Property cp =
  244.                     new org.openspcoop2.core.config.Property();
  245.                 cp.setNome(nome);
  246.                 cp.setValore(valore);
  247.                 connettore.addProperty(cp);
  248.                 ra.setConnettore(connettore);
  249.                 sa.setRispostaAsincrona(ra);
  250.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), sa);
  251.             }
  252.             else if (servlet.equals(PorteApplicativeCostanti.SERVLET_NAME_PORTE_APPLICATIVE_CONNETTORI_MULTIPLI_CHANGE)) {
  253.                 int idSilInt = Integer.parseInt(idsil);
  254.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  255.                 InvocazioneServizio is = sa.getInvocazioneServizio();
  256.                 org.openspcoop2.core.config.Connettore connettore = is.getConnettore();
  257.                 connettore.setCustom(true);
  258.                 org.openspcoop2.core.config.Property cp =
  259.                     new org.openspcoop2.core.config.Property();
  260.                 cp.setNome(nome);
  261.                 cp.setValore(valore);
  262.                 connettore.addProperty(cp);
  263.                 is.setConnettore(connettore);
  264.                 sa.setInvocazioneServizio(is);
  265.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), sa);
  266.             }
  267.             else if (servlet.equals(SoggettiCostanti.SERVLET_NAME_SOGGETTI_ENDPOINT)) {
  268.                 int idInt = Integer.parseInt(id);
  269.                 SoggettoCtrlStat scs = soggettiCore.getSoggettoCtrlStat(idInt);
  270.                 Soggetto ss = scs.getSoggettoReg();
  271.                 org.openspcoop2.core.config.Soggetto ssconf = scs.getSoggettoConf();
  272.                 Connettore connettore = ss.getConnettore();
  273.                 connettore.setCustom(true);
  274.                 Property cp = new Property();
  275.                 cp.setNome(nome);
  276.                 cp.setValore(valore);
  277.                 connettore.addProperty(cp);
  278.                 ss.setConnettore(connettore);
  279.                 SoggettoCtrlStat newCsc = new SoggettoCtrlStat(ss, ssconf);
  280.                 connettoriCore.performUpdateOperation(userLogin, connettoriHelper.smista(), newCsc);
  281.             }

  283.             // Preparo la lista
  284.             Connettore connettore = null;
  285.             org.openspcoop2.core.config.Connettore connettoreC = null;
  286.             int newMyId = 0;
  287.             if (servlet.equals(AccordiServizioParteSpecificaCostanti.SERVLET_NAME_APS_CHANGE)) {
  288.                 AccordoServizioParteSpecifica servizio = apsCore.getAccordoServizioParteSpecifica(Long.parseLong(id));
  289.                 connettore = servizio.getConfigurazioneServizio().getConnettore();
  290.             }
  291.             else if (servlet.equals(AccordiServizioParteSpecificaCostanti.SERVLET_NAME_APS_FRUITORI_CHANGE)) {
  292.                 long idServizioLong = Long.parseLong(id);
  293.                 AccordoServizioParteSpecifica serviziosp = apsCore.getAccordoServizioParteSpecifica(idServizioLong);
  294.                 for (int i = 0; i < serviziosp.sizeFruitoreList(); i++) {
  295.                     Fruitore tmpFru = serviziosp.getFruitore(i);
  296.                     if (saveNomeFru.equals(tmpFru.getNome()) &&
  297.                             saveTipoFru.equals(tmpFru.getTipo())) {
  298.                         newMyId = tmpFru.getId().intValue();
  299.                         break;
  300.                     }
  301.                 }
  302.                 Fruitore servFru = apsCore.getServizioFruitore(newMyId);
  303.                 connettore = servFru.getConnettore();
  304.             }
  305.             else if (servlet.equals(ServiziApplicativiCostanti.SERVLET_NAME_SERVIZI_APPLICATIVI_ENDPOINT)) {
  306.                 int idSilInt = Integer.parseInt(idsil);
  307.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  308.                 InvocazioneServizio is = sa.getInvocazioneServizio();
  309.                 connettoreC = is.getConnettore();
  310.             }
  311.             else if (servlet.equals(ServiziApplicativiCostanti.SERVLET_NAME_SERVIZI_APPLICATIVI_ENDPOINT_RISPOSTA)) {
  312.                 int idSilInt = Integer.parseInt(idsil);
  313.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  314.                 RispostaAsincrona ra = sa.getRispostaAsincrona();
  315.                 connettoreC = ra.getConnettore();
  316.             }
  317.             else if (servlet.equals(PorteApplicativeCostanti.SERVLET_NAME_PORTE_APPLICATIVE_CONNETTORI_MULTIPLI_CHANGE)) {
  318.                 int idSilInt = Integer.parseInt(idsil);
  319.                 ServizioApplicativo sa = saCore.getServizioApplicativo(idSilInt);
  320.                 InvocazioneServizio is = sa.getInvocazioneServizio();
  321.                 connettoreC = is.getConnettore();
  322.             }
  323.             else if (servlet.equals(SoggettiCostanti.SERVLET_NAME_SOGGETTI_ENDPOINT)) {
  324.                 int idInt = Integer.parseInt(id);
  325.                 SoggettoCtrlStat scs = soggettiCore.getSoggettoCtrlStat(idInt);
  326.                 Soggetto ss = scs.getSoggettoReg();
  327.                 connettore = ss.getConnettore();
  328.             }
  329.             
  330.             List<Object> lista = new ArrayList<>();
  331.             if (connettore != null) {
  332.                 for (int i = 0; i<connettore.sizePropertyList(); i++){
  333.                     if(!CostantiDB.CONNETTORE_DEBUG.equals(connettore.getProperty(i).getNome())  &&
  334.                             !connettore.getProperty(i).getNome().startsWith(CostantiConnettori.CONNETTORE_EXTENDED_PREFIX)){
  335.                         lista.add(connettore.getProperty(i));
  336.                     }
  337.                 }
  338.             }
  339.             if (connettoreC != null) {
  340.                 for (int i = 0; i<connettoreC.sizePropertyList(); i++){
  341.                     if(!CostantiDB.CONNETTORE_DEBUG.equals(connettoreC.getProperty(i).getNome())  &&
  342.                             !connettoreC.getProperty(i).getNome().startsWith(CostantiConnettori.CONNETTORE_EXTENDED_PREFIX)){
  343.                         lista.add(connettoreC.getProperty(i));
  344.                     }
  345.                 }
  346.             }

  348.             connettoriHelper.prepareConnettorePropList(lista, new ConsoleSearch(true), newMyId, tipoAccordo);

  350.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  351.             
  352.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, ConnettoriCostanti.OBJECT_NAME_CONNETTORI_CUSTOM_PROPERTIES, ForwardParams.ADD());
  353.             
  354.         } catch (Exception e) {
  355.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  356.                     ConnettoriCostanti.OBJECT_NAME_CONNETTORI_CUSTOM_PROPERTIES, ForwardParams.ADD());
  357.         } 
  358.     }
  359. }
Created with JaCoCo 0.8.8.202204050719