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

  22. import java.util.ArrayList;
  23. import java.util.HashMap;
  24. import java.util.Iterator;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.openspcoop2.core.commons.ErrorsHandlerCostant;
  29. import org.openspcoop2.core.id.IDAccordo;
  30. import org.openspcoop2.core.id.IDPortType;
  31. import org.openspcoop2.core.id.IDPortTypeAzione;
  32. import org.openspcoop2.core.id.IDResource;
  33. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  34. import org.openspcoop2.core.registry.AccordoServizioParteComuneServizioComposto;
  35. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  36. import org.openspcoop2.core.registry.Documento;
  37. import org.openspcoop2.core.registry.Operation;
  38. import org.openspcoop2.core.registry.PortType;
  39. import org.openspcoop2.core.registry.ProtocolProperty;
  40. import org.openspcoop2.core.registry.Resource;
  41. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  42. import org.openspcoop2.core.registry.constants.FormatoSpecifica;
  43. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  44. import org.openspcoop2.core.registry.constants.StatiAccordo;
  45. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  46. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  47. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  48. import org.openspcoop2.core.registry.driver.FiltroRicercaProtocolPropertyRegistry;
  49. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  50. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  51. import org.openspcoop2.core.registry.driver.ValidazioneStatoPackageException;
  52. import org.openspcoop2.core.registry.driver.db.IDAccordoDB;
  53. import org.openspcoop2.protocol.engine.constants.Costanti;
  54. import org.openspcoop2.protocol.engine.utils.DBOggettiInUsoUtils;
  55. import org.openspcoop2.protocol.engine.utils.NamingUtils;
  56. import org.openspcoop2.protocol.manifest.constants.InterfaceType;
  57. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  58. import org.openspcoop2.web.ctrlstat.servlet.aps.AccordiServizioParteSpecificaCore;
  59. import org.openspcoop2.web.ctrlstat.servlet.archivi.ArchiviCore;
  60. import org.openspcoop2.web.lib.mvc.Parameter;


  63. /**
  64.  * AccordiServizioParteComuneUtilities
  65.  *
  66.  * @author Poli Andrea (apoli@link.it)
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */
  70. public class AccordiServizioParteComuneUtilities {

  72.     public static void findOggettiDaAggiornare(IDAccordo idAccordoOLD, AccordoServizioParteComune as, AccordiServizioParteComuneCore apcCore, List<Object> listOggettiDaAggiornare) throws Exception {
  73.         
  74.         AccordiServizioParteSpecificaCore apsCore = new AccordiServizioParteSpecificaCore(apcCore);
  75.         
  76.         IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();
  77.         
  78.         String newURI = idAccordoFactory.getUriFromAccordo(as);

  80.         // Cerco i servizi in cui devo cambiare la URI dell'accordo
  81.         List<AccordoServizioParteSpecifica> servizi = apsCore.serviziByAccordoFilterList(idAccordoOLD);
  82.         if(servizi!=null){
  83.             while(servizi.size()>0){
  84.                 AccordoServizioParteSpecifica s = servizi.remove(0);
  85.                 s.setAccordoServizioParteComune(newURI);
  86.                 listOggettiDaAggiornare.add(s);
  87.             }
  88.         }
  89.         
  90.         if(Costanti.MODIPA_PROTOCOL_NAME.equals(idAccordoOLD.getSoggettoReferente().getTipo())) {
  91.             
  92.             String oldURI = idAccordoFactory.getUriFromIDAccordo(idAccordoOLD);
  93.             
  94.             Map<String, AccordoServizioParteComune> map = new HashMap<String, AccordoServizioParteComune>();
  95.             
  96.             if(org.openspcoop2.core.registry.constants.ServiceBinding.REST.equals(as.getServiceBinding())) {
  97.                 FiltroRicercaResources filtroRicerca = new FiltroRicercaResources();
  98.                 FiltroRicercaProtocolPropertyRegistry filtroRPP = new FiltroRicercaProtocolPropertyRegistry();
  99.                 filtroRPP.setName(org.openspcoop2.protocol.engine.constants.Costanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA);
  100.                 filtroRPP.setValueAsString(oldURI);
  101.                 filtroRicerca.addProtocolPropertyResource(filtroRPP);
  102.                 List<IDResource> list = null;
  103.                 try {
  104.                     list = apcCore.getAllIdResource(filtroRicerca);
  105.                 }catch(DriverRegistroServiziNotFound notFound) {}
  106.                 if(list!=null && !list.isEmpty()) {
  107.                     for (IDResource idResource : list) {
  108.                         
  109.                         AccordoServizioParteComune aspc = null;
  110.                         String uri = idAccordoFactory.getUriFromIDAccordo(idResource.getIdAccordo());
  111.                         boolean forceAdd = false;
  112.                         if(map.containsKey(uri)) {
  113.                             aspc = map.remove(uri);
  114.                             forceAdd = true;
  115.                         }
  116.                         else {
  117.                             if(idResource.getIdAccordo().equals(idAccordoOLD)) {
  118.                                 // è quello che sto modificando
  119.                                 aspc = as;
  120.                             }
  121.                             else {
  122.                                 aspc = apcCore.getAccordoServizioFull(idResource.getIdAccordo());
  123.                             }
  124.                         }
  125.                         boolean find = false;
  126.                         if(aspc.sizeResourceList()>0) {
  127.                             for (Resource res : aspc.getResourceList()) {
  128.                                 if(res.getNome().equals(idResource.getNome())) {
  129.                                     if(res.sizeProtocolPropertyList()>0) {
  130.                                         for (ProtocolProperty pp : res.getProtocolPropertyList()) {
  131.                                             if(org.openspcoop2.protocol.engine.constants.Costanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA.equals(pp.getName())) {
  132.                                                 pp.setValue(newURI);
  133.                                                 find = true;
  134.                                                 break;
  135.                                             }
  136.                                         }
  137.                                     }
  138.                                     break;
  139.                                 }
  140.                             }
  141.                         }
  142.                         if((!idResource.getIdAccordo().equals(idAccordoOLD)) && (forceAdd || find)) {
  143.                             map.put(uri, aspc);
  144.                         }
  145.                     }
  146.                 }
  147.             }
  148.             else {
  149.                 FiltroRicercaOperations filtroRicerca = new FiltroRicercaOperations();
  150.                 FiltroRicercaProtocolPropertyRegistry filtroRPP = new FiltroRicercaProtocolPropertyRegistry();
  151.                 filtroRPP.setName(org.openspcoop2.protocol.engine.constants.Costanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA);
  152.                 filtroRPP.setValueAsString(oldURI);
  153.                 filtroRicerca.addProtocolPropertyAzione(filtroRPP);
  154.                 List<IDPortTypeAzione> list = null;
  155.                 try {
  156.                     list = apcCore.getAllIdOperation(filtroRicerca);
  157.                 }catch(DriverRegistroServiziNotFound notFound) {}
  158.                 if(list!=null && !list.isEmpty()) {
  159.                     for (IDPortTypeAzione idAzione : list) {
  160.                         
  161.                         AccordoServizioParteComune aspc = null;
  162.                         String uri = idAccordoFactory.getUriFromIDAccordo(idAzione.getIdPortType().getIdAccordo());
  163.                         boolean forceAdd = false;
  164.                         if(map.containsKey(uri)) {
  165.                             aspc = map.remove(uri);
  166.                             forceAdd = true;
  167.                         }
  168.                         else {
  169.                             if(idAzione.getIdPortType().getIdAccordo().equals(idAccordoOLD)) {
  170.                                 // è quello che sto modificando
  171.                                 aspc = as;
  172.                             }
  173.                             else {
  174.                                 aspc = apcCore.getAccordoServizioFull(idAzione.getIdPortType().getIdAccordo());
  175.                             }
  176.                         }
  177.                         boolean find = false;
  178.                         if(aspc.sizePortTypeList()>0) {
  179.                             for (PortType portType : aspc.getPortTypeList()) {
  180.                                 if(portType.getNome().contentEquals(idAzione.getIdPortType().getNome())) {
  181.                                     if(portType.sizeAzioneList()>0) {
  182.                                         for (Operation op : portType.getAzioneList()) {
  183.                                             if(op.getNome().equals(idAzione.getNome())) {
  184.                                                 if(op.sizeProtocolPropertyList()>0) {
  185.                                                     for (ProtocolProperty pp : op.getProtocolPropertyList()) {
  186.                                                         if(org.openspcoop2.protocol.engine.constants.Costanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA.equals(pp.getName())) {
  187.                                                             pp.setValue(newURI);
  188.                                                             find = true;
  189.                                                             break;
  190.                                                         }
  191.                                                     }
  192.                                                 }
  193.                                                 break;
  194.                                             }
  195.                                         }
  196.                                     }
  197.                                     break;
  198.                                 }
  199.                             }
  200.                         }
  201.                         if((!idAzione.getIdPortType().getIdAccordo().equals(idAccordoOLD)) && (forceAdd || find)) {
  202.                             map.put(uri, aspc);
  203.                         }
  204.                         
  205.                     }
  206.                 }
  207.             }
  208.             
  209.             if(!map.isEmpty()) {
  210.                 listOggettiDaAggiornare.addAll( map.values() );
  211.             }
  212.             
  213.         }
  214.     }
  215.     
  216.     public static boolean deleteAccordoServizioParteComune(AccordoServizioParteComune as, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, StringBuilder inUsoMessage, String newLine) throws Exception {
  217.         
  218.         HashMap<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  219.         
  220.         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromAccordo(as);

  222.         boolean normalizeObjectIds = !apcHelper.isModalitaCompleta();
  223.         if (apcCore.isAccordoInUso(as, whereIsInUso, normalizeObjectIds)) {// accordo in uso
  224.             inUsoMessage.append(DBOggettiInUsoUtils.toString(idAccordo, whereIsInUso, true, newLine, normalizeObjectIds));
  225.             inUsoMessage.append(newLine);
  226.         } else {// accordo non in uso
  227.             apcCore.performDeleteOperation(userLogin, apcHelper.smista(), as);
  228.             return true;
  229.         }
  230.         
  231.         return false;
  232.     }
  233.     
  234.     public static boolean deleteResource(AccordoServizioParteComune as, IDResource idResource, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, StringBuilder inUsoMessage, String newLine) throws Exception {
  235.         HashMap<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  236.         boolean normalizeObjectIds = !apcHelper.isModalitaCompleta();
  237.         boolean risorsaInUso = apcCore.isRisorsaInUso(idResource,whereIsInUso,normalizeObjectIds);
  238.         
  239.         boolean modificaAS_effettuata = false;
  240.         
  241.         if (risorsaInUso) {
  242.             
  243.             // traduco nomeRisorsa in path
  244.             String methodPath = null;
  245.             for (int j = 0; j < as.sizeResourceList(); j++) {
  246.                 Resource risorsa = as.getResource(j);
  247.                 if (idResource.getNome().equals(risorsa.getNome())) {
  248.                     methodPath = NamingUtils.getLabelResource(risorsa);
  249.                     break;
  250.                 }
  251.             }
  252.             if(methodPath==null) {
  253.                 methodPath = idResource.getNome();
  254.             }
  255.             
  256.             inUsoMessage.append(DBOggettiInUsoUtils.toString(idResource, methodPath, whereIsInUso, true, newLine));
  257.             inUsoMessage.append(newLine);

  259.         } else {
  260.             // Effettuo eliminazione
  261.             for (int j = 0; j < as.sizeResourceList(); j++) {
  262.                 Resource risorsa = as.getResource(j);
  263.                 if (idResource.getNome().equals(risorsa.getNome())) {
  264.                     modificaAS_effettuata = true;
  265.                     as.removeResource(j);
  266.                     break;
  267.                 }
  268.             }
  269.         }
  270.         
  271.         return modificaAS_effettuata;
  272.     }
  273.     
  274.     public static void deleteAccordoServizioParteComuneRisorse(AccordoServizioParteComune as, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, 
  275.             StringBuilder inUsoMessage, String newLine, List<String> resourcesToRemove) throws Exception {

  277.         boolean modificaAS_effettuata = false;
  278.         
  279.         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromAccordo(as);
  280.                 
  281.         for (int i = 0; i < resourcesToRemove.size(); i++) {
  282.             String nomeRisorsa = resourcesToRemove.get(i);
  283.             IDResource idRisorsa = new IDResource();
  284.             idRisorsa.setNome(nomeRisorsa);
  285.             idRisorsa.setIdAccordo(idAccordo);
  286.             
  287.             boolean modificato = AccordiServizioParteComuneUtilities.deleteResource(as, idRisorsa, userLogin, apcCore, apcHelper, inUsoMessage, newLine);
  288.             if(modificato) {
  289.                 modificaAS_effettuata = true;
  290.             }
  291.             
  292.         }// chiudo for
  293.         if(modificaAS_effettuata) {
  294.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);
  295.         }
  296.     }
  297.     
  298.     public static boolean deletePortType(AccordoServizioParteComune as, IDPortType idPortType, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, StringBuilder inUsoMessage, String newLine) throws Exception {
  299.         HashMap<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  300.         boolean normalizeObjectIds = !apcHelper.isModalitaCompleta();
  301.         boolean portTypeInUso = apcCore.isPortTypeInUso(idPortType,whereIsInUso,normalizeObjectIds);
  302.         
  303.         boolean modificaAS_effettuata = false;
  304.         
  305.         if (portTypeInUso) {
  306.             inUsoMessage.append(DBOggettiInUsoUtils.toString(idPortType, whereIsInUso, true, newLine));
  307.             inUsoMessage.append(newLine);

  309.         } else {
  310.             // Effettuo eliminazione
  311.             for (int j = 0; j < as.sizePortTypeList(); j++) {
  312.                 PortType pt = as.getPortType(j);
  313.                 if (idPortType.getNome().equals(pt.getNome())) {
  314.                     modificaAS_effettuata = true;
  315.                     as.removePortType(j);
  316.                     break;
  317.                 }
  318.             }
  319.         }
  320.         
  321.         return modificaAS_effettuata;
  322.     }
  323.     
  324.     public static void deleteAccordoServizioParteComunePortTypes(AccordoServizioParteComune as, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, 
  325.             StringBuilder inUsoMessage, String newLine, List<String> ptsToRemove) throws Exception {
  326.         
  327.         boolean modificaAS_effettuata = false;
  328.         
  329.         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromAccordo(as);
  330.                 
  331.         for (int i = 0; i < ptsToRemove.size(); i++) {
  332.             String nomePT = ptsToRemove.get(i);
  333.             
  334.             IDPortType idPT = new IDPortType();
  335.             idPT.setNome(nomePT);
  336.             idPT.setIdAccordo(idAccordo);
  337.                         
  338.             boolean modificato = AccordiServizioParteComuneUtilities.deletePortType(as, idPT, userLogin, apcCore, apcHelper, inUsoMessage, newLine);
  339.             if(modificato) {
  340.                 modificaAS_effettuata = true;
  341.             }
  342.             
  343.         }// chiudo for
  344.         if(modificaAS_effettuata) {
  345.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);
  346.         }
  347.         
  348.     }
  349.     
  350.     public static boolean deleteOperazione(PortType pt, IDPortTypeAzione idOperazione, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, StringBuilder inUsoMessage, String newLine) throws Exception {
  351.         HashMap<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  352.         boolean normalizeObjectIds = !apcHelper.isModalitaCompleta();
  353.         boolean operazioneInUso = apcCore.isOperazioneInUso(idOperazione,whereIsInUso,normalizeObjectIds);
  354.         
  355.         boolean modificaAS_effettuata = false;
  356.         
  357.         if (operazioneInUso) {
  358.             inUsoMessage.append(DBOggettiInUsoUtils.toString(idOperazione, whereIsInUso, true, newLine));
  359.             inUsoMessage.append(newLine);

  361.         } else {
  362.             // Effettuo eliminazione
  363.             for (int j = 0; j < pt.sizeAzioneList(); j++) {
  364.                 Operation op = pt.getAzione(j);
  365.                 if (idOperazione.getNome().equals(op.getNome())) {
  366.                     modificaAS_effettuata = true;
  367.                     pt.removeAzione(j);
  368.                     break;
  369.                 }
  370.             }
  371.         }
  372.         
  373.         return modificaAS_effettuata;
  374.     }
  375.     
  376.     
  377.     public static void deleteAccordoServizioParteComuneOperations(AccordoServizioParteComune as, String userLogin, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, 
  378.             StringBuilder inUsoMessage, String newLine, PortType pt, List<String> optsToRemove) throws Exception {
  379.     
  380.         boolean modificaAS_effettuata = false;
  381.         
  382.         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromAccordo(as);
  383.         IDPortType idPortType = new IDPortType();
  384.         idPortType.setNome(pt.getNome());
  385.         idPortType.setIdAccordo(idAccordo);
  386.         
  387.         for (int i = 0; i < optsToRemove.size(); i++) {
  388.             String nomeop = optsToRemove.get(i);
  389.             
  390.             IDPortTypeAzione idOperazione = new IDPortTypeAzione();
  391.             idOperazione.setNome(nomeop);
  392.             idOperazione.setIdPortType(idPortType);
  393.             
  394.             boolean modificato = AccordiServizioParteComuneUtilities.deleteOperazione(pt, idOperazione, userLogin, apcCore, apcHelper, inUsoMessage, newLine);
  395.             if(modificato) {
  396.                 modificaAS_effettuata = true;
  397.             }
  398.             
  399.         }// chiudo for
  400.         if(modificaAS_effettuata) {
  401.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), pt);
  402.         }
  403.                 
  404.     }
  405.     
  406.     @SuppressWarnings("incomplete-switch")
  407.     public static void updateAccordoServizioParteComuneAllegati(AccordoServizioParteComune as,Documento doc, Documento docNew) {
  408.         switch (RuoliDocumento.valueOf(doc.getRuolo())) {
  409.             case allegato:
  410.                 //rimuovo il vecchio doc dalla lista
  411.                 for (int i = 0; i < as.sizeAllegatoList(); i++) {
  412.                     Documento documento = as.getAllegato(i);                        
  413.                     if(documento.getId().equals(doc.getId()))
  414.                         as.removeAllegato(i);
  415.                 }
  416.                 //aggiungo il nuovo
  417.                 as.addAllegato(docNew);
  418.                 
  419.                 break;
  420.     
  421.             case specificaSemiformale:
  422.                 
  423.                 for (int i = 0; i < as.sizeSpecificaSemiformaleList(); i++) {
  424.                     Documento documento = as.getSpecificaSemiformale(i);                        
  425.                     if(documento.getId().equals(doc.getId())){
  426.                         as.removeSpecificaSemiformale(i);
  427.                         break;
  428.                     }
  429.                 }
  430.                 //aggiungo il nuovo
  431.                 as.addSpecificaSemiformale(docNew);
  432.                 break;
  433.                 
  434.             case specificaCoordinamento:
  435.                 AccordoServizioParteComuneServizioComposto assc = as.getServizioComposto();
  436.                 for (int i = 0; i < assc.sizeSpecificaCoordinamentoList(); i++) {
  437.                     Documento documento = assc.getSpecificaCoordinamento(i);                        
  438.                     if(documento.getId().equals(doc.getId())){
  439.                         assc.removeSpecificaCoordinamento(i);
  440.                         break;
  441.                     }
  442.                 }
  443.                 assc.addSpecificaCoordinamento(docNew);
  444.                 as.setServizioComposto(assc);
  445.                 break;
  446.         }
  447.     }
  448.     
  449.     public static void deleteAccordoServizioParteComuneAllegati(AccordoServizioParteComune as, String userLogin, 
  450.             AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper, 
  451.             List<Long> idAllegati) throws Exception {
  452.         
  453.         ArchiviCore archiviCore = new ArchiviCore(apcCore);
  454.         
  455.         for (int i = 0; i < idAllegati.size(); i++) {
  456.             long idAllegato = idAllegati.get(i);
  457.             
  458.             Documento doc = archiviCore.getDocumento(idAllegato, false);
  459.             
  460.             switch (RuoliDocumento.valueOf(doc.getRuolo())) {
  461.                 case allegato:
  462.                     //rimuovo il vecchio doc dalla lista
  463.                     for (int j = 0; j < as.sizeAllegatoList(); j++) {
  464.                         Documento documento = as.getAllegato(j);                        
  465.                         if(documento.getFile().equals(doc.getFile()))
  466.                             as.removeAllegato(j);
  467.                     }
  468.                     
  469.                     break;

  471.                 case specificaSemiformale:
  472.                     
  473.                     for (int j = 0; j < as.sizeSpecificaSemiformaleList(); j++) {
  474.                         Documento documento = as.getSpecificaSemiformale(j);                        
  475.                         if(documento.getFile().equals(doc.getFile()))
  476.                             as.removeSpecificaSemiformale(j);
  477.                     }
  478.                     break;
  479.                 
  480.                 case specificaCoordinamento:
  481.                     if(as.getServizioComposto()!=null){
  482.                         for (int j = 0; j < as.getServizioComposto().sizeSpecificaCoordinamentoList(); j++) {
  483.                             Documento documento = as.getServizioComposto().getSpecificaCoordinamento(j);                        
  484.                             if(documento.getFile().equals(doc.getFile()))
  485.                                 as.getServizioComposto().removeSpecificaCoordinamento(j);
  486.                         }
  487.                     }
  488.                     break;
  489.                 case specificaLivelloServizio:
  490.                     break;
  491.                 case specificaSicurezza:
  492.                     break;
  493.             }
  494.             
  495.         }

  497.         // effettuo le operazioni
  498.         apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);
  499.         
  500.     }
  501.     
  502.     public static String getTerminologiaAccordoServizio(String tipo){
  503.         String termine = null;
  504.         if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE.equals(tipo)){
  505.             termine=AccordiServizioParteComuneCostanti.LABEL_APC;
  506.         }
  507.         else{
  508.             termine=AccordiServizioParteComuneCostanti.LABEL_ASC;
  509.         }
  510.         return termine;
  511.     }

  513.     @Deprecated
  514.     public static String getParametroAccordoServizio(String tipo,String appendChar){
  515.         String parametro = "";
  516.         if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE.equals(tipo)){
  517.             parametro = appendChar+AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO+"="+AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE;
  518.         }
  519.         else{
  520.             parametro = appendChar+AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO+"="+AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_SERVIZIO_COMPOSTO;
  521.         }
  522.         return parametro;
  523.     }
  524.     public static Parameter getParametroAccordoServizio(AccordoServizioParteComune apc){
  525.         if(apc.getServizioComposto()!=null){
  526.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  527.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_SERVIZIO_COMPOSTO);
  528.         }else
  529.         {
  530.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  531.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE);
  532.         }
  533.     }
  534.     public static Parameter getParametroAccordoServizio(AccordoServizioParteComuneSintetico apc){
  535.         if(apc.getServizioComposto()!=null){
  536.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  537.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_SERVIZIO_COMPOSTO);
  538.         }else
  539.         {
  540.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  541.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE);
  542.         }
  543.     }

  545.     public static Parameter getParametroAccordoServizio(String tipo){
  546.         if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE.equals(tipo)){
  547.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  548.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE);
  549.         }
  550.         else{
  551.             return new Parameter(AccordiServizioParteComuneCostanti.PARAMETRO_APC_TIPO_ACCORDO,
  552.                     AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_SERVIZIO_COMPOSTO);
  553.         }
  554.     }

  556.     public static boolean showInformazioniServiziComponenti(String tipo){
  557.         boolean value = true;
  558.         if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE.equals(tipo)){
  559.             value = false;
  560.         }
  561.         return value;
  562.     }

  564.     public static boolean showFlagServizioComposto(){
  565.         return false;
  566.     }

  568.     public static List<AccordoServizioParteComuneSintetico> accordiList(AccordiServizioParteComuneCore core,String userLogin,ConsoleSearch ricerca,String tipoAccordo) throws DriverRegistroServiziException{
  569.         List<AccordoServizioParteComuneSintetico> lista = null;
  570.         if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_PARTE_COMUNE.equals(tipoAccordo)){
  571.             if(core.isVisioneOggettiGlobale(userLogin)){
  572.                 lista = core.accordiServizioParteComuneList(null, ricerca);
  573.             }else{
  574.                 lista = core.accordiServizioParteComuneList(userLogin, ricerca);
  575.             }
  576.         }
  577.         else if(AccordiServizioParteComuneCostanti.PARAMETRO_VALORE_APC_TIPO_ACCORDO_SERVIZIO_COMPOSTO.equals(tipoAccordo)){
  578.             if(core.isVisioneOggettiGlobale(userLogin)){
  579.                 lista = core.accordiServizioCompostiList(null, ricerca);
  580.             }else{
  581.                 lista = core.accordiServizioCompostiList(userLogin, ricerca);
  582.             }
  583.         }
  584.         else {
  585.             if(core.isVisioneOggettiGlobale(userLogin)){
  586.                 lista = core.accordiList(null, ricerca);
  587.             }else{
  588.                 lista = core.accordiList(userLogin, ricerca);
  589.             }
  590.         }
  591.         return lista;
  592.     }

  594.     public static List<AccordoServizioParteComuneSintetico> accordiListFromPermessiUtente(AccordiServizioParteComuneCore core,String userLogin,ConsoleSearch ricerca,boolean[] permessiUtente) throws DriverRegistroServiziException{
  595.         List<AccordoServizioParteComuneSintetico> lista = null;
  596.         if(permessiUtente != null){
  597.             if(permessiUtente[0] && !permessiUtente[1]){
  598.                 if(core.isVisioneOggettiGlobale(userLogin)){
  599.                     lista = core.accordiServizioParteComuneList(null, ricerca);
  600.                 }else{
  601.                     lista = core.accordiServizioParteComuneList(userLogin, ricerca);
  602.                 }

  604.                 return lista;
  605.             }

  607.             if(!permessiUtente[0] && permessiUtente[1]){
  608.                 if(core.isVisioneOggettiGlobale(userLogin)){
  609.                     lista = core.accordiServizioCompostiList(null, ricerca);
  610.                 }else{
  611.                     lista = core.accordiServizioCompostiList(userLogin, ricerca);
  612.                 }

  614.                 return lista;
  615.             }
  616.         }


  619.         if(core.isVisioneOggettiGlobale(userLogin)){
  620.             lista = core.accordiList(null, ricerca);
  621.         }else{
  622.             lista = core.accordiList(userLogin, ricerca);
  623.         }

  625.         return lista;
  626.     }
  627.     
  628.     public static List<IDAccordoDB> idAccordiListFromPermessiUtente(AccordiServizioParteComuneCore core,String userLogin,ConsoleSearch ricerca,boolean[] permessiUtente, 
  629.             boolean soloAccordiConsistentiRest, boolean soloAccordiConsistentiSoap) throws DriverRegistroServiziException{
  630.         List<IDAccordoDB> lista = null;
  631.         if(permessiUtente != null){
  632.             if(permessiUtente[0] && !permessiUtente[1]){
  633.                 if(core.isVisioneOggettiGlobale(userLogin)){
  634.                     lista = core.idAccordiServizioParteComuneList(null, ricerca, 
  635.                             soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  636.                 }else{
  637.                     lista = core.idAccordiServizioParteComuneList(userLogin, ricerca, 
  638.                             soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  639.                 }

  641.                 return lista;
  642.             }

  644.             if(!permessiUtente[0] && permessiUtente[1]){
  645.                 if(core.isVisioneOggettiGlobale(userLogin)){
  646.                     lista = core.idAccordiServizioCompostiList(null, ricerca, 
  647.                             soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  648.                 }else{
  649.                     lista = core.idAccordiServizioCompostiList(userLogin, ricerca, 
  650.                             soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  651.                 }

  653.                 return lista;
  654.             }
  655.         }


  658.         if(core.isVisioneOggettiGlobale(userLogin)){
  659.             lista = core.idAccordiList(null, ricerca, 
  660.                     soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  661.         }else{
  662.             lista = core.idAccordiList(userLogin, ricerca, 
  663.                     soloAccordiConsistentiRest, soloAccordiConsistentiSoap);
  664.         }

  666.         return lista;
  667.     }

  669.     public static ArrayList<String> selectPortTypeAsincroni(AccordoServizioParteComune as,String profcollop,String nomept){
  670.         // Recupero i servizi dell'accordo con lo stesso profilo di collaborazione
  671.         ArrayList<String> servCorrUniche = null;
  672.         //List<PortType> getServCorrList = core.accordiPorttypeList(idInt, null, new Search(true));
  673.         List<PortType> getServCorrList = new ArrayList<PortType>();
  674.         for(int k=0;k<as.sizePortTypeList();k++){
  675.             getServCorrList.add(as.getPortType(k));
  676.         }

  678.         if (!getServCorrList.isEmpty()) {
  679.             servCorrUniche = new ArrayList<>();
  680.             servCorrUniche.add("-");
  681.             for (Iterator<PortType> iterator = getServCorrList.iterator(); iterator.hasNext();) {
  682.                 PortType myPT = iterator.next();
  683.                 // Devono possedere almeno un'azione
  684.                 if(myPT.sizeAzioneList()<=0)
  685.                     continue;
  686.                 // Devono possedere almeno un'azione con profilo di collaborazione uguale a quello selezionato 
  687.                 List<Operation> opList = new ArrayList<>();
  688.                 for(int j=0; j<myPT.sizeAzioneList();j++){
  689.                     Operation op = myPT.getAzione(j);
  690.                     // ridefinito sull'azione
  691.                     if(AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(op.getProfAzione()) && 
  692.                             (op.getProfiloCollaborazione()!=null && op.getProfiloCollaborazione().equals(profcollop))
  693.                             ){
  694.                         opList.add(op);
  695.                     }
  696.                     // ereditato dal port type
  697.                     else if (AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(op.getProfAzione()) && 
  698.                             AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(myPT.getProfiloPT()) && 
  699.                             (myPT.getProfiloCollaborazione()!=null && myPT.getProfiloCollaborazione().equals(profcollop))
  700.                             ){
  701.                         opList.add(op);
  702.                     }
  703.                     // ereditato dall'accordo di servizio
  704.                     else if (AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(op.getProfAzione()) && 
  705.                             AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(myPT.getProfiloPT()) && 
  706.                             (as.getProfiloCollaborazione()!=null && as.getProfiloCollaborazione().equals(profcollop))
  707.                             ){
  708.                         opList.add(op);
  709.                     }
  710.                     // profilo non matcha quello atteso
  711.                     else{
  712.                         continue;
  713.                     }
  714.                 }
  715.                 if(opList.size()<=0){
  716.                     continue;
  717.                 }
  718.                 if (!nomept.equals(myPT.getNome())) {
  719.                     servCorrUniche.add(myPT.getNome());
  720.                 }
  721.             }
  722.         }

  724.         if (servCorrUniche != null && servCorrUniche.size() > 0)
  725.             return servCorrUniche;
  726.         else
  727.             return null;
  728.     }

  730.     public static Map<String, List<Operation>> selectPortTypeOperationsListAsincrone(AccordoServizioParteComune as,String profcollop,String nomept){
  731.         //List<PortType> getServCorrList = core.accordiPorttypeList(idInt, null, new Search(true));
  732.         List<PortType> getServCorrList = new ArrayList<PortType>();
  733.         for(int k=0;k<as.sizePortTypeList();k++){
  734.             getServCorrList.add(as.getPortType(k));
  735.         }
  736.         Map<String, List<Operation>> operationsListSelezionate = new HashMap<>();

  738.         if (!getServCorrList.isEmpty()) {
  739.             for (Iterator<PortType> iterator = getServCorrList.iterator(); iterator.hasNext();) {
  740.                 PortType myPT = iterator.next();
  741.                 // Devono possedere almeno un'azione
  742.                 if(myPT.sizeAzioneList()<=0)
  743.                     continue;
  744.                 // Devono possedere almeno un'azione con profilo di collaborazione uguale a quello selezionato 
  745.                 List<Operation> opList = new ArrayList<>();
  746.                 for(int j=0; j<myPT.sizeAzioneList();j++){
  747.                     Operation op = myPT.getAzione(j);
  748.                     // ridefinito sull'azione
  749.                     if(AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(op.getProfAzione()) && 
  750.                             (op.getProfiloCollaborazione()!=null && op.getProfiloCollaborazione().equals(profcollop))
  751.                             ){
  752.                         opList.add(op);
  753.                     }
  754.                     // ereditato dal port type
  755.                     else if (AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(op.getProfAzione()) && 
  756.                             AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(myPT.getProfiloPT()) && 
  757.                             (myPT.getProfiloCollaborazione()!=null && myPT.getProfiloCollaborazione().equals(profcollop))
  758.                             ){
  759.                         opList.add(op);
  760.                     }
  761.                     // ereditato dall'accordo di servizio
  762.                     else if (AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(op.getProfAzione()) && 
  763.                             AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.equals(myPT.getProfiloPT()) &&
  764.                             (as.getProfiloCollaborazione()!=null && as.getProfiloCollaborazione().equals(profcollop))
  765.                             ){
  766.                         opList.add(op);
  767.                     }
  768.                     // profilo non matcha quello atteso
  769.                     else{
  770.                         continue;
  771.                     }
  772.                 }
  773.                 if(opList.size()<=0){
  774.                     continue;
  775.                 }
  776.                 if (!nomept.equals(myPT.getNome())) {
  777.                     operationsListSelezionate.put(myPT.getNome(), opList);
  778.                 }
  779.                 else{
  780.                     operationsListSelezionate.put("-", opList);
  781.                 }
  782.             }
  783.         }

  785.         return operationsListSelezionate;
  786.     }

  788.     public static ArrayList<String> selectOperationAsincrone(AccordoServizioParteComune as,String servcorr,String profProtocollo,
  789.             String profcollop,PortType pt,String nomeop,AccordiServizioParteComuneCore core, Map<String, List<Operation>> operationsListSelezionate)throws DriverRegistroServiziException{
  790.         // Se è stato selezionato un servizio,
  791.         // recupero le azioni del servizio
  792.         // che non sono già state correlate
  793.         //
  794.         // Se non è stato selezionato un servizio:
  795.         // - se il profilo dell'azione è
  796.         //   asincronoAsimmetrico, recupero le
  797.         //   azioni del servizio con profilo
  798.         //   asincronoAsimmetrico che non sono già
  799.         //   state correlate
  800.         // - se il profilo dell'azione è
  801.         //   asincronoSimmetrico, non permetto
  802.         //   di scegliere un'azione correlata
  803.         ArrayList<String> aziCorrUniche = null;
  804.         List<Operation> getAziCorrList = null;
  805.         PortType ptSel = null;
  806.         if (!servcorr.equals("-")) {
  807.             // Prendo il servizio selezionato
  808.             for (int j = 0; j < as.sizePortTypeList(); j++) {
  809.                 ptSel = as.getPortType(j);
  810.                 if (servcorr.equals(ptSel.getNome()))
  811.                     break;
  812.             }
  813.             //getAziCorrList = core.accordiPorttypeOperationList(ptSel.getId().intValue(), ptSel.getProfiloCollaborazione(), new Search(true));*/
  814.             getAziCorrList = operationsListSelezionate.get(servcorr);
  815.         } else {
  816.             
  817.             boolean calcolaLista = false;
  818.             if(AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(profProtocollo) && profcollop.equals("asincronoAsimmetrico")) {
  819.                 calcolaLista = true;
  820.             }
  821.             else if(AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_DEFAULT.contentEquals(profProtocollo)) {
  822.                 if(AccordiServizioParteComuneCostanti.INFORMAZIONI_PROTOCOLLO_MODALITA_RIDEFINITO.equals(pt.getProfiloPT())) {
  823.                     if(pt.getProfiloCollaborazione()!=null) {
  824.                         calcolaLista = "asincronoAsimmetrico".equals(pt.getProfiloCollaborazione().getValue());
  825.                     }
  826.                 }
  827.                 else {
  828.                     if(as.getProfiloCollaborazione()!=null) {
  829.                         calcolaLista = "asincronoAsimmetrico".equals(as.getProfiloCollaborazione().getValue());
  830.                     }
  831.                 }
  832.             }
  833.             if (calcolaLista){
  834.                 //getAziCorrList = core.accordiPorttypeOperationList(pt.getId().intValue(), "asincronoAsimmetrico", new Search(true));
  835.                 getAziCorrList = operationsListSelezionate.get(servcorr);
  836.                 ptSel = pt;
  837.             }
  838.         }

  840.         if (getAziCorrList != null && getAziCorrList.size() > 0) {
  841.             aziCorrUniche = new ArrayList<>();
  842.             aziCorrUniche.add("-");
  843.             for (Iterator<Operation> iterator = getAziCorrList.iterator(); iterator.hasNext();) {
  844.                 Operation operation = iterator.next();
  845.                 // Se sto utilizzando lo stesso port type, non devo inserire le azioni con il mio nome 
  846.                 if (servcorr.equals("-") && nomeop.equals(operation.getNome())) {
  847.                     continue;
  848.                 }
  849.                 // Non devo inserire le azioni gia correlate une alle altre.
  850.                 // Devo quindi verificare se l'azione suddetta 'operation.getNome' risulta gia' correlata, oppure e' utilizzata come correlata
  851.                 if (ptSel!=null && !core.isOperationCorrelata(ptSel.getNome(), ptSel.getId(), operation.getNome(), operation.getId())) {
  852.                     aziCorrUniche.add(operation.getNome());
  853.                 }
  854.             }
  855.         }

  857.         if (aziCorrUniche != null && aziCorrUniche.size() > 0)
  858.             return aziCorrUniche;
  859.         else
  860.             return null;
  861.     }

  863.     public static void mapppingAutomaticoInterfaccia(AccordoServizioParteComune as, AccordiServizioParteComuneCore apcCore,
  864.             boolean enableAutoMapping, boolean validazioneDocumenti, boolean enableAutoMapping_estraiXsdSchemiFromWsdlTypes, boolean facilityUnicoWSDL_interfacciaStandard,
  865.             String tipoProtocollo, 
  866.             InterfaceType interfaceType) throws Exception{
  867.         if(as.getByteWsdlConcettuale() != null || as.getByteWsdlLogicoErogatore() != null || as.getByteWsdlLogicoFruitore() != null) {
  868.             apcCore.mappingAutomatico(tipoProtocollo, as, validazioneDocumenti);
  869.             if(enableAutoMapping_estraiXsdSchemiFromWsdlTypes && InterfaceType.WSDL_11.equals(interfaceType)){
  870.                 Map<String, byte[]> schemiAggiuntiInQuestaOperazione = new HashMap<String, byte[]>();
  871.                 if(as.getByteWsdlConcettuale() != null){ 
  872.                     apcCore.estraiSchemiFromWSDLTypesAsAllegati(as, as.getByteWsdlConcettuale(),AccordiServizioParteComuneCostanti.TIPO_WSDL_CONCETTUALE, schemiAggiuntiInQuestaOperazione);
  873.                 }
  874.                 if(facilityUnicoWSDL_interfacciaStandard){
  875.                     // è stato utilizzato il concettuale. Lo riporto nel logico
  876.                     if(as.getByteWsdlConcettuale()!=null){
  877.                         as.setByteWsdlLogicoErogatore(as.getByteWsdlConcettuale());
  878.                     }
  879.                 }
  880.                 else{
  881.                     if(as.getByteWsdlLogicoErogatore() != null){
  882.                         apcCore.estraiSchemiFromWSDLTypesAsAllegati(as, as.getByteWsdlLogicoErogatore(),AccordiServizioParteComuneCostanti.TIPO_WSDL_EROGATORE, schemiAggiuntiInQuestaOperazione);
  883.                     }
  884.                     if(as.getByteWsdlLogicoFruitore() != null){
  885.                         apcCore.estraiSchemiFromWSDLTypesAsAllegati(as, as.getByteWsdlLogicoFruitore(),AccordiServizioParteComuneCostanti.TIPO_WSDL_FRUITORE, schemiAggiuntiInQuestaOperazione);
  886.                     }
  887.                 }
  888.             }
  889.             try{
  890.                 // Se ho fatto il mapping controllo la validita' di quanto prodotto
  891.                 as.setStatoPackage(StatiAccordo.operativo.toString());
  892.                 boolean utilizzoAzioniDiretteInAccordoAbilitato = apcCore.isShowAccordiColonnaAzioni();
  893.                 apcCore.validaStatoAccordoServizio(as, utilizzoAzioniDiretteInAccordoAbilitato, false);
  894.             }catch(ValidazioneStatoPackageException validazioneException){
  895.                 // Se l'automapping non ha prodotto ne porttype ne operatin rimetto lo stato a bozza
  896.                 as.setStatoPackage(StatiAccordo.bozza.toString());
  897.             }
  898.         }
  899.     }
  900.     
  901.     public static boolean createPortTypeOperation(boolean enableAutoMapping, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper,
  902.             AccordoServizioParteComune as, PortType pt, String userLogin) throws Exception{
  903.         boolean updateAccordo = false;
  904.         try{
  905.             if(enableAutoMapping) {
  906.                 if(StatiAccordo.bozza.toString().equals(as.getStatoPackage())) {
  907.                     // Se ho aggiunto la prima operazione
  908.                     if(pt.sizeAzioneList()==1) {
  909.                         as.setStatoPackage(StatiAccordo.operativo.toString());
  910.                         boolean utilizzoAzioniDiretteInAccordoAbilitato = apcCore.isShowAccordiColonnaAzioni();
  911.                         apcCore.validaStatoAccordoServizio(as, utilizzoAzioniDiretteInAccordoAbilitato, false);
  912.                         updateAccordo = true;
  913.                     }
  914.                 }
  915.             }
  916.         }catch(ValidazioneStatoPackageException validazioneException){
  917.         }
  918.         
  919.         if(updateAccordo) {         
  920.             // effettuo le operazioni
  921.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);          
  922.         }       
  923.         else {              
  924.             // effettuo le operazioni
  925.             apcCore.performUpdateOperation(userLogin, apcHelper.smista(), pt);              
  926.         }
  927.         return updateAccordo;
  928.     }
  929.     
  930.     public static void createResource(boolean enableAutoMapping, AccordiServizioParteComuneCore apcCore, AccordiServizioParteComuneHelper apcHelper,
  931.             AccordoServizioParteComune as, String userLogin) throws Exception{
  932.     
  933.         try{
  934.             if(enableAutoMapping) {
  935.                 if(StatiAccordo.bozza.toString().equals(as.getStatoPackage())) {
  936.                     // Se ho aggiunto la prima risorsa
  937.                     if(as.sizeResourceList()==1) {
  938.                         as.setStatoPackage(StatiAccordo.operativo.toString());
  939.                         boolean utilizzoAzioniDiretteInAccordoAbilitato = apcCore.isShowAccordiColonnaAzioni();
  940.                         apcCore.validaStatoAccordoServizio(as, utilizzoAzioniDiretteInAccordoAbilitato, false);
  941.                     }
  942.                 }
  943.             }
  944.         }catch(ValidazioneStatoPackageException validazioneException){
  945.             // Se l'automapping non ha prodotto ne porttype ne operatin rimetto lo stato a bozza
  946.             as.setStatoPackage(StatiAccordo.bozza.toString());
  947.         }
  948.         
  949.         // effettuo le operazioni
  950.         apcCore.performUpdateOperation(userLogin, apcHelper.smista(), as);
  951.         
  952.     }
  953.     
  954.     public static void updateInterfacciaAccordoServizioParteComune(String tipoParam, String wsdlS, AccordoServizioParteComune as,
  955.             boolean enableAutoMapping, boolean validazioneDocumenti, boolean enableAutoMapping_estraiXsdSchemiFromWsdlTypes, boolean facilityUnicoWSDL_interfacciaStandard,
  956.             String tipoProtocollo, 
  957.             AccordiServizioParteComuneCore apcCore,
  958.             boolean aggiornaEsistenti, boolean eliminaNonPresentiNuovaInterfaccia,
  959.             List<IDResource> risorseEliminate,List<IDPortType> portTypeEliminati, List<IDPortTypeAzione> operationEliminate) throws Exception {
  960.         
  961.         FormatoSpecifica formato = null;
  962.         byte [] wsdlBytes = null;
  963.         if(as!=null) {
  964.             formato = as.getFormatoSpecifica();
  965.         }
  966.         if(wsdlS!=null) {
  967.             wsdlBytes = apcCore.getInterfaceAsByteArray(formato, wsdlS);
  968.         }
  969.         
  970.         // il wsdl definitorio rimane fuori dal nuovo comportamento quindi il flusso della pagina continua come prima
  971.         if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_DEFINITORIO)) {
  972.             as.setByteWsdlDefinitorio(wsdlBytes);
  973.         }
  974.         else {
  975.             // se sono state definiti dei port type ed e' la prima volta che ho passato i controlli 
  976.             //Informo l'utente che potrebbe sovrascrivere i servizi definiti tramite l'aggiornamento del wsdl
  977.             // Questa Modalita' e' controllata tramite la proprieta' isenabledAutoMappingWsdlIntoAccordo
  978.             // e se non e' un reset
  979.             if(enableAutoMapping){
  980.                 
  981.                 if( wsdlBytes!=null ){
  982.                     AccordoServizioParteComune asNuovo = new AccordoServizioParteComune();
  983.                     asNuovo.setFormatoSpecifica(as.getFormatoSpecifica());
  984.                     asNuovo.setServiceBinding(as.getServiceBinding());

  986.                     boolean fillXsd = false;
  987.                     String tipo = null;
  988.                     
  989.                     // decodifico quale wsdl/wsbl sto aggiornando
  990.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_CONCETTUALE)) {
  991.                         as.setByteWsdlConcettuale(wsdlBytes);

  993.                         asNuovo.setByteSpecificaConversazioneConcettuale(as.getByteSpecificaConversazioneConcettuale());
  994.                         asNuovo.setByteSpecificaConversazioneErogatore(as.getByteSpecificaConversazioneErogatore());
  995.                         asNuovo.setByteSpecificaConversazioneFruitore(as.getByteSpecificaConversazioneFruitore());
  996.                         asNuovo.setByteWsdlConcettuale(wsdlBytes);
  997.                         
  998.                         fillXsd = true;
  999.                         tipo=AccordiServizioParteComuneCostanti.TIPO_WSDL_CONCETTUALE;
  1000.                     }
  1001.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_EROGATORE)) {
  1002.                         as.setByteWsdlLogicoErogatore(wsdlBytes);

  1004.                         asNuovo.setByteSpecificaConversazioneConcettuale(as.getByteSpecificaConversazioneConcettuale());
  1005.                         asNuovo.setByteSpecificaConversazioneErogatore(as.getByteSpecificaConversazioneErogatore());
  1006.                         asNuovo.setByteSpecificaConversazioneFruitore(as.getByteSpecificaConversazioneFruitore());
  1007.                         asNuovo.setByteWsdlLogicoErogatore(wsdlBytes);
  1008.                         
  1009.                         fillXsd = true;
  1010.                         if(facilityUnicoWSDL_interfacciaStandard){
  1011.                             tipo=AccordiServizioParteComuneCostanti.TIPO_WSDL_CONCETTUALE;
  1012.                         }
  1013.                         else{
  1014.                             tipo=AccordiServizioParteComuneCostanti.TIPO_WSDL_EROGATORE;
  1015.                         }
  1016.                         
  1017.                     }
  1018.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_FRUITORE)) {
  1019.                         as.setByteWsdlLogicoFruitore(wsdlBytes);

  1021.                         asNuovo.setByteSpecificaConversazioneConcettuale(as.getByteSpecificaConversazioneConcettuale());
  1022.                         asNuovo.setByteSpecificaConversazioneErogatore(as.getByteSpecificaConversazioneErogatore());
  1023.                         asNuovo.setByteSpecificaConversazioneFruitore(as.getByteSpecificaConversazioneFruitore());
  1024.                         asNuovo.setByteWsdlLogicoFruitore(wsdlBytes);
  1025.                         
  1026.                         fillXsd = true;
  1027.                         tipo=AccordiServizioParteComuneCostanti.TIPO_WSDL_FRUITORE;
  1028.                     }
  1029.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_CONCETTUALE)) {
  1030.                         as.setByteSpecificaConversazioneConcettuale(wsdlBytes);

  1032.                         asNuovo.setByteSpecificaConversazioneConcettuale(wsdlBytes);
  1033.                         asNuovo.setByteWsdlConcettuale(as.getByteWsdlConcettuale());
  1034.                         asNuovo.setByteWsdlLogicoErogatore(as.getByteWsdlLogicoErogatore());
  1035.                         asNuovo.setByteWsdlLogicoFruitore(as.getByteWsdlLogicoFruitore());
  1036.                     }
  1037.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_EROGATORE)) {
  1038.                         as.setByteSpecificaConversazioneErogatore(wsdlBytes);

  1040.                         asNuovo.setByteSpecificaConversazioneErogatore(wsdlBytes);
  1041.                         asNuovo.setByteWsdlConcettuale(as.getByteWsdlConcettuale());
  1042.                         asNuovo.setByteWsdlLogicoErogatore(as.getByteWsdlLogicoErogatore());
  1043.                         asNuovo.setByteWsdlLogicoFruitore(as.getByteWsdlLogicoFruitore());
  1044.                     }
  1045.                     if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_FRUITORE)) {
  1046.                         as.setByteSpecificaConversazioneFruitore(wsdlBytes);

  1048.                         asNuovo.setByteSpecificaConversazioneFruitore(wsdlBytes);
  1049.                         asNuovo.setByteWsdlConcettuale(as.getByteWsdlConcettuale());
  1050.                         asNuovo.setByteWsdlLogicoErogatore(as.getByteWsdlLogicoErogatore());
  1051.                         asNuovo.setByteWsdlLogicoFruitore(as.getByteWsdlLogicoFruitore());
  1052.                     }

  1054.                     // Genero la nuova definizione
  1055.                     apcCore.mappingAutomatico(tipoProtocollo, asNuovo, validazioneDocumenti);

  1057.                     // se l'aggiornamento ha creato nuovi oggetti o aggiornato i vecchi aggiorno la configurazione
  1058.                     if(org.openspcoop2.core.registry.constants.ServiceBinding.REST.equals(as.getServiceBinding())) {
  1059.                         apcCore.popolaResourceDaUnAltroASPC(as,asNuovo,
  1060.                                 aggiornaEsistenti, eliminaNonPresentiNuovaInterfaccia, risorseEliminate);
  1061.                     }
  1062.                     else {
  1063.                         apcCore.popolaPorttypeOperationDaUnAltroASPC(as,asNuovo,
  1064.                                 aggiornaEsistenti, eliminaNonPresentiNuovaInterfaccia,
  1065.                                 portTypeEliminati, operationEliminate);
  1066.                     }
  1067.                     
  1068.                     // popolo gli allegati
  1069.                     if(fillXsd && enableAutoMapping_estraiXsdSchemiFromWsdlTypes && FormatoSpecifica.WSDL_11.equals(as.getFormatoSpecifica())){
  1070.                         apcCore.estraiSchemiFromWSDLTypesAsAllegati(as, wsdlBytes, tipo, new HashMap<String, byte[]> ());
  1071.                         if(facilityUnicoWSDL_interfacciaStandard){
  1072.                             // è stato utilizzato il concettuale. Lo riporto nel logico
  1073.                             as.setByteWsdlLogicoErogatore(as.getByteWsdlConcettuale());
  1074.                         }
  1075.                     }
  1076.                     
  1077.                     try{
  1078.                         if(StatiAccordo.bozza.toString().equals(as.getStatoPackage())) {
  1079.                             // Se ho fatto il mapping controllo la validita' di quanto prodotto
  1080.                             as.setStatoPackage(StatiAccordo.operativo.toString());
  1081.                             boolean utilizzoAzioniDiretteInAccordoAbilitato = apcCore.isShowAccordiColonnaAzioni();
  1082.                             apcCore.validaStatoAccordoServizio(as, utilizzoAzioniDiretteInAccordoAbilitato, false);
  1083.                         }
  1084.                     }catch(ValidazioneStatoPackageException validazioneException){
  1085.                         // Se l'automapping non ha prodotto ne porttype ne operatin rimetto lo stato a bozza
  1086.                         as.setStatoPackage(StatiAccordo.bozza.toString());
  1087.                     }
  1088.                     
  1089.                 }
  1090.             }else {
  1091.                 // vecchio comportamento sovrascrivo i wsdl
  1092.                 // Modifico i dati del wsdl dell'accordo nel db
  1093.                 // anche in caso di reset del wsdl

  1095.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_CONCETTUALE)) {
  1096.                     as.setByteWsdlConcettuale(wsdlBytes);
  1097.                 }
  1098.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_EROGATORE)) {
  1099.                     as.setByteWsdlLogicoErogatore(wsdlBytes);
  1100.                 }
  1101.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_WSDL_FRUITORE)) {
  1102.                     as.setByteWsdlLogicoFruitore(wsdlBytes);
  1103.                 }
  1104.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_CONCETTUALE)) {
  1105.                     as.setByteSpecificaConversazioneConcettuale(wsdlBytes);
  1106.                 }
  1107.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_EROGATORE)) {
  1108.                     as.setByteSpecificaConversazioneErogatore(wsdlBytes);
  1109.                 }
  1110.                 if (tipoParam.equals(AccordiServizioParteComuneCostanti.PARAMETRO_APC_SPECIFICA_CONVERSAZIONE_FRUITORE)) {
  1111.                     as.setByteSpecificaConversazioneFruitore(wsdlBytes);
  1112.                 }

  1114.             } 
  1115.         }

  1117.         // Se un utente ha impostato solo il logico erogatore (avviene automaticamente nel caso non venga visualizzato il campo concettuale)
  1118.         // imposto lo stesso wsdl anche per il concettuale. Tanto Rappresenta la stessa informazione, ma e' utile per lo stato dell'accordo
  1119.         if(as!=null && as.getByteWsdlLogicoErogatore()!=null && as.getByteWsdlLogicoFruitore()==null && as.getByteWsdlConcettuale()==null){
  1120.             as.setByteWsdlConcettuale(as.getByteWsdlLogicoErogatore());
  1121.         }
  1122.     }
  1123. }
Created with JaCoCo 0.8.8.202204050719