AccordiServizioParteComuneResourcesRepresentationAdd.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.apc;

  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.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.registry.AccordoServizioParteComune;
  37. import org.openspcoop2.core.registry.IdSoggetto;
  38. import org.openspcoop2.core.registry.Resource;
  39. import org.openspcoop2.core.registry.ResourceRepresentation;
  40. import org.openspcoop2.core.registry.ResourceRepresentationJson;
  41. import org.openspcoop2.core.registry.ResourceRepresentationXml;
  42. import org.openspcoop2.core.registry.ResourceRequest;
  43. import org.openspcoop2.core.registry.ResourceResponse;
  44. import org.openspcoop2.core.registry.constants.RepresentationType;
  45. import org.openspcoop2.core.registry.constants.RepresentationXmlType;
  46. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  47. import org.openspcoop2.message.constants.MessageType;
  48. import org.openspcoop2.message.constants.ServiceBinding;
  49. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  50. import org.openspcoop2.protocol.engine.utils.NamingUtils;
  51. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  52. import org.openspcoop2.utils.rest.api.ApiResponse;
  53. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  54. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  55. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  56. import org.openspcoop2.web.ctrlstat.servlet.apc.api.ApiCostanti;
  57. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  58. import org.openspcoop2.web.lib.mvc.Costanti;
  59. import org.openspcoop2.web.lib.mvc.DataElement;
  60. import org.openspcoop2.web.lib.mvc.ForwardParams;
  61. import org.openspcoop2.web.lib.mvc.GeneralData;
  62. import org.openspcoop2.web.lib.mvc.PageData;
  63. import org.openspcoop2.web.lib.mvc.Parameter;
  64. import org.openspcoop2.web.lib.mvc.ServletUtils;
  65. import org.openspcoop2.web.lib.mvc.TipoOperazione;

  67. /**
  68.  * AccordiServizioParteComuneResourcesRepresentationAdd
  69.  * 
  70.  * @author Andrea Poli (apoli@link.it)
  71.  * @author $Author$
  72.  * @version $Rev$, $Date$
  73.  * 
  74.  */
  75. public final class AccordiServizioParteComuneResourcesRepresentationAdd 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.         String userLogin = ServletUtils.getUserLoginFromSession(session);

  92.         IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();

  94.         // Parametri relativi al tipo operazione
  95.         TipoOperazione tipoOp = TipoOperazione.ADD; 

  97.         try {
  98.             AccordiServizioParteComuneCore apcCore = new AccordiServizioParteComuneCore();
  99.             SoggettiCore soggettiCore = new SoggettiCore(apcCore);

  101.             AccordiServizioParteComuneHelper apcHelper = new AccordiServizioParteComuneHelper(request, pd, session);

  103.             String editMode = apcHelper.getParameter(Costanti.DATA_ELEMENT_EDIT_MODE_NAME);

  105.             String id = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_ID);
  106.             long idAccordoLong = Long.parseLong(id);
  107.             String nomeRisorsa = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_NOME);
  108.             if (nomeRisorsa == null) {
  109.                 nomeRisorsa = "";
  110.             }
  111.             String statusS = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_RESPONSE_STATUS);
  112.             Integer status = null;
  113.             try {
  114.                 if(statusS!=null)
  115.                     status = Integer.parseInt(statusS);
  116.             } catch(Exception e) {
  117.                 // ignore
  118.             }
  119.             String isReq = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCE_REQUEST);
  120.             boolean isRequest = ServletUtils.isCheckBoxEnabled(isReq);
  121.             
  122.             String descr = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_DESCRIZIONE);
  123.             if (descr == null) {
  124.                 descr = "";
  125.             }

  127.             String messageProcessorS = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_MESSAGE_TYPE);
  128.             MessageType messageType = (StringUtils.isNotEmpty(messageProcessorS) && !messageProcessorS.equals(AccordiServizioParteComuneCostanti.DEFAULT_VALUE_PARAMETRO_APC_MESSAGE_TYPE_DEFAULT)) ? MessageType.valueOf(messageProcessorS) : null;
  129.             String mediaType = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_MEDIA_TYPE);
  130.             String tipoS = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_TIPO);
  131.             RepresentationType tipo = (StringUtils.isNotEmpty(tipoS) && !messageProcessorS.equals(AccordiServizioParteComuneCostanti.DEFAULT_VALUE_PARAMETRO_APC_RESOURCES_REPRESENTATION_TIPO_NON_DEFINITO)) ? RepresentationType.toEnumConstant(tipoS) : null;
  132.             String nome = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_NOME);
  133.             String tipoJson = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_JSON_TYPE);
  134.             String namespaceXml = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_XML_NAMESPACE);
  135.             String nomeXml = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_XML_NAME);
  136.             String xmlTypeS = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_REPRESENTATION_XML_TIPO);
  137.             RepresentationXmlType xmlType =  StringUtils.isNotEmpty(xmlTypeS) ? RepresentationXmlType.toEnumConstant(xmlTypeS) : null;
  138.             String tipoAccordo = apcHelper.getParameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO);
  139.             if("".equals(tipoAccordo))
  140.                 tipoAccordo = null;

  142.             // Preparo il menu
  143.             apcHelper.makeMenu();

  145.             // Prendo il nome
  146.             AccordoServizioParteComune as = apcCore.getAccordoServizioFull(idAccordoLong);
  147.             String uriAS = idAccordoFactory.getUriFromAccordo(as);
  148.             String labelASTitle = apcHelper.getLabelIdAccordo(as); 
  149.             String protocollo = null;
  150.             //calcolo del protocollo implementato dall'accordo
  151.             IdSoggetto soggettoReferente = as.getSoggettoReferente();
  152.             String tipoSoggettoReferente = soggettoReferente.getTipo();
  153.             protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(tipoSoggettoReferente);
  154.             
  155.             IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(protocollo);
  156.             
  157.             ServiceBinding serviceBinding = null;
  158.             //calcolo del serviceBinding dall'accordo
  159.             serviceBinding = apcCore.toMessageServiceBinding(as.getServiceBinding());

  161.             Resource risorsa = null;
  162.             for (int j = 0; j < as.sizeResourceList(); j++) {
  163.                 risorsa = as.getResource(j);
  164.                 if (nomeRisorsa.equals(risorsa.getNome())) {
  165.                     break;
  166.                 }
  167.             }
  168.             
  169.             if(risorsa==null) {
  170.                 throw new Exception("Risorsa con nome '"+nomeRisorsa+"' non trovata nell'accordo con id '"+idAccordoLong+"'");
  171.             }
  172.             
  173.             Long idResponse = null;
  174.             Long idResource = null;
  175.             ResourceRequest resourceRequest = null;
  176.             ResourceResponse resourceResponse = null;
  177.             if(isRequest) {
  178.                 resourceRequest = risorsa.getRequest();
  179.                 idResource = risorsa.getId();
  180.             } else {
  181.                 if(risorsa.getResponseList() != null) {
  182.                     for (int i = 0; i < risorsa.getResponseList().size(); i++) {
  183.                         resourceResponse = risorsa.getResponse(i);
  184.                         if (resourceResponse.getStatus() == status) {
  185.                             idResponse = resourceResponse.getId();
  186.                             break;
  187.                         }
  188.                     }
  189.                 }
  190.             }
  191.             
  192.             Parameter pTipoAccordo = AccordiServizioParteComuneUtilities.getParametroAccordoServizio(tipoAccordo);
  193.             Parameter pIdAccordo = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_ID, id);
  194.             Parameter pNomeAccordo = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_NOME, uriAS);
  195.             Parameter pNomeRisorsa = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_NOME, risorsa.getNome());
  196.             Parameter pIsRequest = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCE_REQUEST, isRequest+"");
  197.             Parameter pIdRisorsa = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_ID, risorsa.getId()+"");
  198.             Parameter pResponseStatus = new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_RESOURCES_RESPONSE_STATUS, statusS);
  199.             Boolean isModalitaVistaApiCustom = ServletUtils.getBooleanAttributeFromSession(ApiCostanti.SESSION_ATTRIBUTE_VISTA_APC_API, session, request, false).getValue();
  200.             List<Parameter> listaParams = apcHelper.getTitoloApc(TipoOperazione.ADD, as, tipoAccordo, labelASTitle, null, false);
  201.             
  202.             String labelRisorse = (isModalitaVistaApiCustom!=null && isModalitaVistaApiCustom.booleanValue()) ? AccordiServizioParteComuneCostanti.LABEL_RISORSE : AccordiServizioParteComuneCostanti.LABEL_RISORSE + " di " + labelASTitle;
  203.             
  204.             listaParams.add(new Parameter(labelRisorse, AccordiServizioParteComuneCostanti.SERVLET_NAME_APC_RESOURCES_LIST, pIdAccordo, pNomeAccordo, pTipoAccordo));
  205.             
  206.             String labelRisorsa = NamingUtils.getLabelResource(risorsa); 
  207.             listaParams.add(new Parameter(labelRisorsa, AccordiServizioParteComuneCostanti.SERVLET_NAME_APC_RESOURCES_CHANGE, pIdAccordo, pNomeAccordo, pTipoAccordo,pIdRisorsa));
  208.             
  209.             if(!isRequest) {
  210.                 String labelResponse = AccordiServizioParteComuneCostanti.LABEL_RISPOSTE;
  211.                 listaParams.add(new Parameter(labelResponse, AccordiServizioParteComuneCostanti.SERVLET_NAME_APC_RESOURCES_RISPOSTE_LIST, pIdAccordo, pNomeAccordo, pTipoAccordo,pNomeRisorsa));
  212.                 
  213.                 String labelRisposta = AccordiServizioParteComuneCostanti.LABEL_PARAMETRO_APC_RESOURCES_RESPONSE_STATUS +" "+
  214.                         (ApiResponse.isDefaultHttpReturnCode(status)? AccordiServizioParteComuneCostanti.LABEL_PARAMETRO_APC_RESOURCES_RESPONSE_STATUS_DEFAULT : statusS);
  215.                 
  216.                 listaParams.add(new Parameter(labelRisposta, AccordiServizioParteComuneCostanti.SERVLET_NAME_APC_RESOURCES_RISPOSTE_CHANGE, pIdAccordo, pTipoAccordo, pNomeAccordo, pNomeRisorsa,pResponseStatus));
  217.             }
  218.             
  219.             String labelRepresentation = AccordiServizioParteComuneCostanti.LABEL_REPRESENTATION;
  220.             
  221.             listaParams.add(new Parameter(labelRepresentation, AccordiServizioParteComuneCostanti.SERVLET_NAME_APC_RESOURCES_REPRESENTATIONS_LIST, pIdAccordo, pNomeAccordo, pTipoAccordo,pNomeRisorsa,pIsRequest, pResponseStatus));
  222.             listaParams.add(new Parameter(Costanti.PAGE_DATA_TITLE_LABEL_AGGIUNGI, null));
  223.             
  224.             // Se idhid = null, devo visualizzare la pagina per l'inserimento
  225.             // dati
  226.             if(ServletUtils.isEditModeInProgress(editMode)){
  227.                 // setto la barra del titolo
  228.                 ServletUtils.setPageDataTitle(pd,listaParams); 
  229.                 
  230.                 if(mediaType == null) {
  231.                     nome = "";
  232.                     descr = "";
  233.                     tipoJson = "";
  234.                     namespaceXml = "";
  235.                     nomeXml = "";
  236.                     xmlType = RepresentationXmlType.ELEMENT;
  237.                     // default non definito
  238.                     tipo = null;
  239.                 }

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

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

  246.                 dati = apcHelper.addAccordiResourceRepresentationToDati(tipoOp, dati, id, as.getStatoPackage(),tipoAccordo,protocollo, 
  247.                         protocolFactory,serviceBinding, nomeRisorsa, isRequest, statusS, null, mediaType, nome, descr, messageType, tipo, tipoJson, nomeXml, namespaceXml, xmlType);
  248.                 
  249.                 pd.setDati(dati);

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

  253.                 return ServletUtils.getStrutsForwardEditModeInProgress(mapping, AccordiServizioParteComuneCostanti.OBJECT_NAME_APC_RESOURCES_REPRESENTATIONS, ForwardParams.ADD());
  254.             }
  255.             
  256.             // Controlli sui campi immessi
  257.             boolean isOk = apcHelper.accordiResourceRepresentationCheckData(tipoOp, id, nomeRisorsa, isRequest, statusS, mediaType, nome, descr, messageType, tipo, tipoJson, nomeXml, namespaceXml, xmlType, idResource,idResponse,null);

  259.             if (!isOk) {

  261.                 // setto la barra del titolo
  262.                 ServletUtils.setPageDataTitle(pd, listaParams);

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

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

  269.                 dati = apcHelper.addAccordiResourceRepresentationToDati(tipoOp, dati, id, as.getStatoPackage(),tipoAccordo,protocollo, 
  270.                         protocolFactory,serviceBinding, nomeRisorsa, isRequest, statusS, null, mediaType, nome, descr,  messageType, tipo, tipoJson, nomeXml, namespaceXml, xmlType);
  271.                 pd.setDati(dati);

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

  275.                 return ServletUtils.getStrutsForwardEditModeCheckError(mapping, AccordiServizioParteComuneCostanti.OBJECT_NAME_APC_RESOURCES_REPRESENTATIONS, ForwardParams.ADD());
  276.             }

  278.             // Inserisco la risorsa nel db
  279.             ResourceRepresentation newRepresentation = new ResourceRepresentation();
  280.             newRepresentation.setMessageType(apcCore.fromMessageMessageType(messageType));
  281.             newRepresentation.setDescrizione(descr);

  283.             newRepresentation.setNome(nome);
  284.             newRepresentation.setMediaType(mediaType);
  285.             newRepresentation.setRepresentationType(tipo); 
  286.             if(tipo !=null) {
  287.                 switch (tipo) {
  288.                 case JSON:
  289.                     ResourceRepresentationJson json = new ResourceRepresentationJson();
  290.                     json.setTipo(tipoJson);
  291.                     newRepresentation.setJson(json);
  292.                     break;
  293.                 case XML:
  294.                     ResourceRepresentationXml xml = new ResourceRepresentationXml();
  295.                     xml.setXmlType(xmlType);
  296.                     xml.setNome(nomeXml);
  297.                     xml.setNamespace(namespaceXml);
  298.                     newRepresentation.setXml(xml);
  299.                     break;
  300.                 default:
  301.                     break;
  302.                 }
  303.             }
  304.             
  305.             if(isRequest) {
  306.                 if(resourceRequest == null)
  307.                     resourceRequest = new ResourceRequest();
  308.                 
  309.                 resourceRequest.addRepresentation(newRepresentation);
  310.             } else {
  311.                 resourceResponse.addRepresentation(newRepresentation);
  312.             }
  313.             
  314.             // effettuo le operazioni
  315.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);
  316.             
  317.             // Preparo la lista
  318.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);
  319.             
  320.             // Devo rileggere l'accordo dal db, perche' altrimenti
  321.             // manca l'id delle risorse
  322.             as = apcCore.getAccordoServizioFull(idAccordoLong);
  323.             
  324.             risorsa = null;
  325.             for (int j = 0; j < as.sizeResourceList(); j++) {
  326.                 risorsa = as.getResource(j);
  327.                 if (nomeRisorsa.equals(risorsa.getNome())) {
  328.                     break;
  329.                 }
  330.             }
  331.             
  332.             if(risorsa==null) {
  333.                 throw new Exception("Risorsa con nome '"+nomeRisorsa+"' non trovata nell'accordo con id '"+idAccordoLong+"'");
  334.             }
  335.             
  336.             idResponse = null;
  337.             idResource = null;
  338.             resourceRequest = null;
  339.             resourceResponse = null;
  340.             if(isRequest) {
  341.                 resourceRequest = risorsa.getRequest();
  342.                 idResource = risorsa.getId();
  343.             } else {
  344.                 if(risorsa.getResponseList() != null) {
  345.                     for (int i = 0; i < risorsa.getResponseList().size(); i++) {
  346.                         resourceResponse = risorsa.getResponse(i);
  347.                         if (resourceResponse.getStatus() == status) {
  348.                             idResponse = resourceResponse.getId();
  349.                             break;
  350.                         }
  351.                     }
  352.                 }
  353.             }

  355.             List<ResourceRepresentation> lista = apcCore.accordiResourceRepresentationsList(idResource, isRequest, idResponse, ricerca);

  357.             apcHelper.prepareAccordiResourcesRepresentationsList(id, as, lista, ricerca, tipoAccordo, isRequest, risorsa, resourceRequest, resourceResponse);

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

  361.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, AccordiServizioParteComuneCostanti.OBJECT_NAME_APC_RESOURCES_REPRESENTATIONS, ForwardParams.ADD());

  363.         } catch (Exception e) {
  364.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  365.                     AccordiServizioParteComuneCostanti.OBJECT_NAME_APC_RESOURCES_REPRESENTATIONS, ForwardParams.ADD());
  366.         }
  367.     }
  368. }
Created with JaCoCo 0.8.8.202204050719