XMLUtils.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.  */



  23. package it.cnipa.collprofiles.driver;

  25. import java.io.ByteArrayInputStream;
  26. import java.io.ByteArrayOutputStream;
  27. import java.io.File;
  28. import java.io.FileInputStream;
  29. import java.io.InputStream;
  30. import java.io.OutputStream;
  31. import java.util.ArrayList;
  32. import java.util.HashMap;
  33. import java.util.List;
  34. import java.util.Map;

  36. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  37. import org.openspcoop2.core.registry.Operation;
  38. import org.openspcoop2.core.registry.PortType;
  39. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  40. import org.openspcoop2.core.registry.constants.ProfiloCollaborazione;
  41. import org.openspcoop2.core.registry.constants.StatoFunzionalita;
  42. import org.openspcoop2.core.registry.wsdl.RegistroOpenSPCoopUtilities;
  43. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  44. import org.openspcoop2.utils.wsdl.DefinitionWrapper;
  45. import org.openspcoop2.utils.xml.AbstractXMLUtils;
  46. import org.openspcoop2.utils.xml.JaxbUtils;
  47. import org.openspcoop2.utils.xml.ValidatoreXSD;
  48. import org.slf4j.Logger;
  49. import org.w3c.dom.Attr;
  50. import org.w3c.dom.Document;
  51. import org.w3c.dom.Element;
  52. import org.w3c.dom.NamedNodeMap;
  53. import org.w3c.dom.Node;

  55. import it.cnipa.collprofiles.EgovDecllElement;
  56. import it.cnipa.collprofiles.OperationListType;
  57. import it.cnipa.collprofiles.OperationType;
  58. import it.cnipa.collprofiles.constants.ProfiloDiCollaborazioneType;
  59. import it.gov.spcoop.sica.manifest.driver.TipiDocumentoSemiformale;


  62. /**
  63.  * Classe utilizzata per lavorare sul documento semiformale che contiene le informazioni eGov dei servizi di un accordo
  64.  *
  65.  *
  66.  * @author Poli Andrea (apoli@link.it)
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */

  71. public class XMLUtils  {

  73.     /** Validatore XSD */
  74.     static ValidatoreXSD validatoreXSD = null;
  75.     public static synchronized ValidatoreXSD getValidatoreXSD(Logger log) throws Exception{
  76.         if(XMLUtils.validatoreXSD==null){
  77.             XMLUtils.validatoreXSD = new ValidatoreXSD(log,XMLUtils.class.getResourceAsStream("/SpecificaSemiformaleEGov.xsd"));
  78.         }
  79.         return XMLUtils.validatoreXSD;
  80.     }
  81.     public static boolean validate(EgovDecllElement egov,StringBuilder motivoErroreValidazione){
  82.         
  83.         int size = motivoErroreValidazione.length();
  84.         
  85.         if(egov.getEGovVersion()==null){
  86.             motivoErroreValidazione.append("VersioneEGov non definita\n");
  87.         }
  88.         if(egov.getRifDefinizioneInterfaccia()==null){
  89.             motivoErroreValidazione.append("RifInterfaccia non definita\n");
  90.         }
  91.         
  92.         OperationListType operations = egov.getOperationList();
  93.         if(operations == null){
  94.             motivoErroreValidazione.append("OperationListType non presente\n");
  95.         }else{
  96.             if(operations.sizeOperationList()<=0){
  97.                 motivoErroreValidazione.append("OperationListType vuota\n");
  98.             }
  99.             for(int i=0; i<operations.sizeOperationList(); i++){
  100.                 OperationType op = operations.getOperation(i);
  101.                 if(op.getServizio()==null){
  102.                     motivoErroreValidazione.append("OperationList["+i+"] senza il servizio\n");
  103.                 }
  104.                 if(op.getOperazione()==null){
  105.                     motivoErroreValidazione.append("OperationList["+i+"] senza l'operation\n");
  106.                 }
  107.                 if(op.getProfiloDiCollaborazione()==null){
  108.                     motivoErroreValidazione.append("OperationList["+i+"] senza un profilo di collaborazione\n");
  109.                 }
  110.                 if(ProfiloDiCollaborazioneType.ONE_WAY.equals(op.getProfiloDiCollaborazione())==false && 
  111.                         ProfiloDiCollaborazioneType.SINCRONO.equals(op.getProfiloDiCollaborazione())==false &&
  112.                                 ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(op.getProfiloDiCollaborazione())==false &&
  113.                                         ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(op.getProfiloDiCollaborazione())==false ){
  114.                     motivoErroreValidazione.append("OperationList["+i+"] con un profilo di collaborazione non conosciuto ("+op.getProfiloDiCollaborazione()+")\n");
  115.                 }
  116.             }
  117.         }
  118.         
  119.         if(motivoErroreValidazione.length()!=size)
  120.             return false;
  121.         else
  122.             return true;

  124.     }
  125.     
  126.     
  127.     
  128.     
  129.     /* ----- Unmarshall ----- */
  130.     
  131.     /**
  132.      * Ritorna la rappresentazione java
  133.      * 
  134.      * @param m byte[]
  135.      * @return EgovDeclType
  136.      * @throws XMLUtilsException
  137.      */
  138.     public static EgovDecllElement getDichiarazioneEGov(Logger log,byte[] m,boolean acceptChildUnqualified) throws XMLUtilsException{
  139.         ByteArrayInputStream bin = null;
  140.         try{
  141.             bin = new ByteArrayInputStream(m);
  142.             return XMLUtils.getDichiarazioneEGov(log,bin,acceptChildUnqualified);
  143.         }catch(Exception e){
  144.             throw new XMLUtilsException(e.getMessage(),e);
  145.         }finally{
  146.             try{
  147.                 if(bin!=null)
  148.                     bin.close();
  149.             }catch(Exception eClose){
  150.                 // close
  151.             }
  152.         }
  153.     }
  154.     
  155.     /**
  156.      * Ritorna la rappresentazione java
  157.      * 
  158.      * @param m File
  159.      * @return EgovDeclType
  160.      * @throws XMLUtilsException
  161.      */
  162.     public static EgovDecllElement getDichiarazioneEGov(Logger log,File m,boolean acceptChildUnqualified) throws XMLUtilsException{
  163.         FileInputStream fin = null;
  164.         try{
  165.             fin = new FileInputStream(m);
  166.             return XMLUtils.getDichiarazioneEGov(log,fin,acceptChildUnqualified);
  167.         }catch(Exception e){
  168.             throw new XMLUtilsException(e.getMessage(),e);
  169.         }finally{
  170.             try{
  171.                 if(fin!=null)
  172.                     fin.close();
  173.             }catch(Exception eClose){
  174.                 // close
  175.             }
  176.         }
  177.     }
  178.     
  179.     /**
  180.      * Ritorna la rappresentazione java
  181.      * 
  182.      * @param m String
  183.      * @return EgovDeclType
  184.      * @throws XMLUtilsException
  185.      */
  186.     public static EgovDecllElement getDichiarazioneEGov(Logger log,String m,boolean acceptChildUnqualified) throws XMLUtilsException{
  187.         return XMLUtils.getDichiarazioneEGov(log,m.getBytes(),acceptChildUnqualified);
  188.     }
  189.     
  190.     /**
  191.      * Ritorna la rappresentazione java
  192.      * 
  193.      * @param m InputStream
  194.      * @return EgovDeclType
  195.      * @throws XMLUtilsException
  196.      */
  197.     public static EgovDecllElement getDichiarazioneEGov(Logger log,InputStream m,boolean acceptChildUnqualified) throws XMLUtilsException{
  198.         try{
  199.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  200.             byte[]reads = new byte[1024];
  201.             int letti = 0;
  202.             while( (letti=m.read(reads)) != -1){
  203.                 bout.write(reads, 0, letti);
  204.             }
  205.             bout.flush();
  206.             bout.close();
  207.             byte [] xml = bout.toByteArray();
  208.             
  209.             // Modifico namespace spcoop.gov.it in  www.cnipa.it
  210.             // Altrimenti la validazione XSD fallisce.
  211.             // Viene effettuato questa trasformazione per accettare comunque gli xml con il namespace spcoop.gov.it
  212.             if(XMLUtils.isProfiloCollaborazioneEGOV_NamespaceSPCoopGovIT(xml)){
  213.                 xml = bout.toString().replaceAll("spcoop\\.gov\\.it","www.cnipa.it").getBytes();
  214.             }
  215.             
  216.             // il Client SICA permette di costruire XML che possiedono un prefix nel root element,
  217.             // ma negli elementi interni tale prefix non viene utilizzato.
  218.             // Es:
  219.             // <tns:egovDecllElement xmlns:tns="http://spcoop.gov.it/collProfiles" ...>
  220.             //      <e-govVersion>....
  221.             // Questo XML non e' validabile rispetto all'XSD poiche' e-govVersion non e' qualificato.
  222.             if(acceptChildUnqualified){
  223.                 xml = XMLUtils.unescapeXMLMalformatoChildElements(xml);
  224.             }
  225.             
  226.             // Validazione XSD
  227.             ByteArrayInputStream binValidazione = new ByteArrayInputStream(xml);
  228.             ValidatoreXSD validatoreXSD = XMLUtils.getValidatoreXSD(log);
  229.             validatoreXSD.valida(binValidazione);
  230.             
  231.             // trasformazione in oggetto EgovDecllElement
  232.             ByteArrayInputStream binTrasformazione = new ByteArrayInputStream(xml);
  233.             return (EgovDecllElement) JaxbUtils.xmlToObj(binTrasformazione, EgovDecllElement.class);
  234.             
  235.         }catch(Exception e){
  236.             throw new XMLUtilsException(e.getMessage(),e);
  237.         }
  238.     }
  239.     
  240.     private static byte [] unescapeXMLMalformatoChildElements(byte [] xml){
  241.         try{
  242.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  243.             Document docXML = xmlUtils.newDocument(xml);
  244.             Element elemXML = docXML.getDocumentElement();
  245.             String prefixRootElement = elemXML.getPrefix();
  246.             String prefixChildElementEgovVersione = null;
  247.             for(int i=0; i< elemXML.getChildNodes().getLength(); i++){
  248.                 Node child = elemXML.getChildNodes().item(i);
  249.                 if(Costanti.CHILD_ELEMENT_EGOV_VERSIONE_LOCAL_NAME.equals(child.getLocalName())){
  250.                     prefixChildElementEgovVersione = child.getPrefix();
  251.                 }
  252.             }
  253.             if(prefixRootElement!=null && prefixChildElementEgovVersione==null){
  254.                 String xmlS = new String(xml);
  255.                 xmlS = xmlS.replace("<"+prefixRootElement+":"+Costanti.ROOT_LOCAL_NAME,"<"+Costanti.ROOT_LOCAL_NAME);
  256.                 //xmlS = xmlS.replace("xmlns:wscp=\"http://spcoop.gov.it/sica/wscp\" xmlns","xmlns");
  257.                 xmlS = xmlS.replace("xmlns:"+prefixRootElement,"xmlns");
  258.                 xmlS = xmlS.replace("</"+prefixRootElement+":"+Costanti.ROOT_LOCAL_NAME,"</"+Costanti.ROOT_LOCAL_NAME);
  259.                 xml = xmlS.getBytes();
  260.             }
  261.             
  262.             return xml;
  263.         }catch(Exception e){
  264.             return xml; // ritorno xml senza trasformazioni
  265.         }
  266.     }
  267.     
  268.     
  269.     
  270.     
  271.     /* ----- Marshall Manifest dell'accordo di servizio ----- */
  272.     public static void generateDichiarazioneEGov(EgovDecllElement manifest,File out,boolean namespaceCnipa) throws XMLUtilsException{
  273.         try{
  274.             StringBuilder risultatoValidazione = new StringBuilder();
  275.             if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  276.                 throw new Exception(risultatoValidazione.toString());
  277.             }
  278.             JaxbUtils.objToXml(out.getName(),XMLUtils.generateDichiarazioneEGov_engine(manifest, namespaceCnipa));
  279.         }catch(Exception e){
  280.             throw new XMLUtilsException(e.getMessage(),e);
  281.         }
  282.     }
  283.     
  284.     public static void generateDichiarazioneEGov(EgovDecllElement manifest,String fileName,boolean namespaceCnipa) throws XMLUtilsException{
  285.         try{
  286.             StringBuilder risultatoValidazione = new StringBuilder();
  287.             if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  288.                 throw new Exception(risultatoValidazione.toString());
  289.             }
  290.             JaxbUtils.objToXml(fileName,XMLUtils.generateDichiarazioneEGov_engine(manifest, namespaceCnipa));
  291.         }catch(Exception e){
  292.             throw new XMLUtilsException(e.getMessage(),e);
  293.         }
  294.     }
  295.     
  296.     public static byte[] generateDichiarazioneEGov(EgovDecllElement manifest,boolean namespaceCnipa) throws XMLUtilsException{
  297.         try{
  298.             StringBuilder risultatoValidazione = new StringBuilder();
  299.             if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  300.                 throw new Exception(risultatoValidazione.toString());
  301.             }
  302.             return XMLUtils.generateDichiarazioneEGov_engine(manifest, namespaceCnipa);
  303.         }catch(Exception e){
  304.             throw new XMLUtilsException(e.getMessage(),e);
  305.         }
  306.     }

  308.     public static void generateDichiarazioneEGov(EgovDecllElement manifest,OutputStream out,boolean namespaceCnipa) throws XMLUtilsException{
  309.         try{
  310.             StringBuilder risultatoValidazione = new StringBuilder();
  311.             if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  312.                 throw new Exception(risultatoValidazione.toString());
  313.             }
  314.             out.write(XMLUtils.generateDichiarazioneEGov_engine(manifest, namespaceCnipa));
  315.             out.flush();
  316.             out.close();
  317.         }catch(Exception e){
  318.             throw new XMLUtilsException(e.getMessage(),e);
  319.         }
  320.     }
  321.     
  322.     private static byte[] generateDichiarazioneEGov_engine(EgovDecllElement manifest,boolean namespaceCnipa) throws XMLUtilsException{
  323.         try{
  324.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  325.             JaxbUtils.objToXml(bout, EgovDecllElement.class, manifest);
  326.             byte[] dichiarazione = bout.toByteArray();
  327.             if(namespaceCnipa==false){
  328.                 // Modifico namespace www.cnipa.it in spcoop.gov.it
  329.                 dichiarazione = bout.toString().replaceAll("www\\.cnipa\\.it", "spcoop.gov.it").getBytes();
  330.             }
  331.             return dichiarazione;
  332.         }catch(Exception e){
  333.             throw new XMLUtilsException(e.getMessage(),e);
  334.         }
  335.     }
  336.     
  337.     
  338.     
  339.     
  340.     
  341.     
  342.     
  343.     public static boolean isProfiloCollaborazioneEGOV(byte [] doc){
  344.         try{
  345.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  346.             Document docXML = xmlUtils.newDocument(doc);
  347.             Element elemXML = docXML.getDocumentElement();
  348.             //System.out.println("LOCAL["+Costanti.ROOT_LOCAL_NAME+"]vs["+elemXML.getLocalName()+"]  NAMESPACE["+Costanti.TARGET_NAMESPACE+"]vs["+elemXML.getNamespaceURI()+"]");
  349.             if(Costanti.ROOT_LOCAL_NAME.equals(elemXML.getLocalName()) && 
  350.                     ( Costanti.TARGET_NAMESPACE.equals(elemXML.getNamespaceURI()) || Costanti.TARGET_NAMESPACE_SPCOOP_GOV_IT.equals(elemXML.getNamespaceURI()) ) 
  351.                 ){
  352.                 return true;
  353.             }
  354.             else{
  355.                 return false;
  356.             }
  357.         }catch(Exception e){
  358.             //System.out.println("NON e' un DOCUMENTO VALIDO: "+e.getMessage());
  359.             return false;
  360.         }
  361.     }
  362.     
  363.     private static boolean isProfiloCollaborazioneEGOV_NamespaceSPCoopGovIT(byte [] doc){
  364.         try{
  365.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  366.             Document docXML = xmlUtils.newDocument(doc);
  367.             Element elemXML = docXML.getDocumentElement();
  368.             //System.out.println("LOCAL["+Costanti.ROOT_LOCAL_NAME+"]vs["+elemXML.getLocalName()+"]  NAMESPACE["+Costanti.TARGET_NAMESPACE+"]vs["+elemXML.getNamespaceURI()+"]");
  369.             if(Costanti.ROOT_LOCAL_NAME.equals(elemXML.getLocalName()) && 
  370.                     Costanti.TARGET_NAMESPACE_SPCOOP_GOV_IT.equals(elemXML.getNamespaceURI())  
  371.                 ){
  372.                 return true;
  373.             }
  374.             else{
  375.                 return false;
  376.             }
  377.         }catch(Exception e){
  378.             //System.out.println("NON e' un DOCUMENTO VALIDO: "+e.getMessage());
  379.             return false;
  380.         }
  381.     }
  382.     
  383.     private static String readNomeSPCoop(String QName,Map<String, String> mapPrefixNamespaces) throws XMLUtilsException{
  384.         if(QName==null){
  385.             return null; // per correlati
  386.         }
  387.         else{
  388.             if(QName.contains(":")){
  389.                 String [] split = QName.split(":");
  390.                 if(split.length!=2){
  391.                      throw new XMLUtilsException("QName ["+QName+"] non valido");
  392.                 }
  393.                 String prefix = split[0].trim();
  394.                 String nomeSPCoop = split[1].trim();
  395.                 if(mapPrefixNamespaces.containsKey(prefix)){
  396.                     //System.out.println("EFFETTUATO MAPPING IN: "+nomeSPCoop+" da ["+QName+"] del namespace ["+mapPrefixNamespaces.get(prefix)+"]");
  397.                     return nomeSPCoop;
  398.                 }else{
  399.                     throw new XMLUtilsException("QName ["+QName+"] non valido, prefix ["+prefix+"] non associato a nessun namespace");
  400.                 }
  401.             }else{
  402.                 return QName;
  403.             }
  404.         }
  405.     }
  406.     
  407.     public static void mapProfiloCollaborazioneEGOVIntoAS(Logger log,byte [] doc,AccordoServizioParteComune as,boolean acceptChildUnqualified) throws XMLUtilsException{
  408.         
  409.         // SpecificaSemiformale
  410.         EgovDecllElement egov = null;
  411.         try{
  412.             egov = XMLUtils.getDichiarazioneEGov(log,doc,acceptChildUnqualified);
  413.         }catch(Exception e){
  414.             throw new XMLUtilsException("Documento con informazione egov non leggibile: "+e.getMessage(),e);
  415.         }
  416.         // Lettura specifica come document
  417.         Map<String, String> mapPrefixNamespaces = new HashMap<>();
  418.         try{
  419.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  420.             Document docXML = xmlUtils.newDocument(doc);
  421.             Element elemXML = docXML.getDocumentElement();
  422.             NamedNodeMap map = elemXML.getAttributes();
  423.             for(int i=0;i<map.getLength();i++){
  424.                 Object o = map.item(i);
  425.                 if(o instanceof Attr){
  426.                     Attr attr = (Attr) o;
  427.                     String prefix = "";
  428.                     if(attr.getPrefix()!=null){
  429.                         prefix = attr.getLocalName(); // il prefisso sara' xmlns
  430.                     }
  431.                     mapPrefixNamespaces.put(prefix, attr.getValue());
  432.                 }
  433.             }
  434.         }catch(Exception e){
  435.             throw new XMLUtilsException("Documento XML con informazione egov non leggibile: "+e.getMessage(),e);
  436.         }
  437.                 
  438.         Map<String, PortType> servizi = new HashMap<String, PortType>();
  439.         OperationListType list = egov.getOperationList();
  440.         for(int h=0; h<list.sizeOperationList(); h++){
  441.             OperationType operationType =  list.getOperation(h);
  442.             String nomeAzione = XMLUtils.readNomeSPCoop(operationType.getOperazione(),mapPrefixNamespaces);
  443.             String nomeServizio = XMLUtils.readNomeSPCoop(operationType.getServizio(),mapPrefixNamespaces);
  444.             String nomeAzioneCorrelata = XMLUtils.readNomeSPCoop(operationType.getOperazioneCorrelata(),mapPrefixNamespaces);
  445.             String nomeServizioCorrelato = XMLUtils.readNomeSPCoop(operationType.getServizioCorrelato(),mapPrefixNamespaces);
  446.             ProfiloDiCollaborazioneType profiloCollaborazione = operationType.getProfiloDiCollaborazione();
  447.             
  448.             PortType pt = null;
  449.             if(servizi.containsKey(nomeServizio)){
  450.                 pt = servizi.remove(nomeServizio);
  451.             }else{
  452.                 pt = new PortType();
  453.                 pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  454.                 pt.setFiltroDuplicati(StatoFunzionalita.ABILITATO); // secondo le ultime linee guida
  455.                 if(ProfiloDiCollaborazioneType.ONE_WAY.equals(profiloCollaborazione))
  456.                     pt.setProfiloCollaborazione(CostantiRegistroServizi.ONEWAY);
  457.                 else if(ProfiloDiCollaborazioneType.SINCRONO.equals(profiloCollaborazione))
  458.                     pt.setProfiloCollaborazione(CostantiRegistroServizi.SINCRONO);
  459.                 else if(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(profiloCollaborazione))
  460.                     pt.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_SIMMETRICO);
  461.                 else if(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazione))
  462.                     pt.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO);
  463.                 else
  464.                     throw new XMLUtilsException("Profilo di collaborazione non valido ["+profiloCollaborazione+"]");
  465.                 pt.setNome(nomeServizio);
  466.             }
  467.             Operation azione = new Operation();
  468.             azione.setNome(nomeAzione);
  469.             azione.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  470.             azione.setFiltroDuplicati(StatoFunzionalita.ABILITATO); // secondo le ultime linee guida
  471.             if(ProfiloDiCollaborazioneType.ONE_WAY.equals(profiloCollaborazione))
  472.                 azione.setProfiloCollaborazione(CostantiRegistroServizi.ONEWAY);
  473.             else if(ProfiloDiCollaborazioneType.SINCRONO.equals(profiloCollaborazione))
  474.                 azione.setProfiloCollaborazione(CostantiRegistroServizi.SINCRONO);
  475.             else if(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(profiloCollaborazione))
  476.                 azione.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_SIMMETRICO);
  477.             else if(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazione))
  478.                 azione.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO);
  479.             else
  480.                 throw new XMLUtilsException("Profilo di collaborazione non valido ["+profiloCollaborazione+"]");
  481.             pt.addAzione(azione);
  482.             servizi.put(nomeServizio, pt);
  483.             
  484.             if(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(profiloCollaborazione) || 
  485.                     ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazione) ){
  486.                 
  487.                 if(nomeAzioneCorrelata==null){
  488.                     continue;
  489.                 }
  490.                 
  491.                 String servizio = nomeServizioCorrelato;
  492.                 if(servizio==null)
  493.                     servizio= nomeServizio;
  494.                 
  495.                 PortType ptCorrelato = null;
  496.                 if(servizi.containsKey(servizio)){
  497.                     ptCorrelato = servizi.remove(servizio);
  498.                 }else{
  499.                     ptCorrelato = new PortType();
  500.                     ptCorrelato.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  501.                     ptCorrelato.setFiltroDuplicati(StatoFunzionalita.ABILITATO); // secondo le ultime linee guida
  502.                     if(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(profiloCollaborazione))
  503.                         ptCorrelato.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_SIMMETRICO);
  504.                     else if(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazione))
  505.                         ptCorrelato.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO);
  506.                     ptCorrelato.setNome(servizio);
  507.                 }
  508.                 Operation azioneCorrelata = new Operation();
  509.                 azioneCorrelata.setNome(nomeAzioneCorrelata);
  510.                 azioneCorrelata.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  511.                 azioneCorrelata.setFiltroDuplicati(StatoFunzionalita.ABILITATO); // secondo le ultime linee guida
  512.                 if(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO.equals(profiloCollaborazione))
  513.                     azioneCorrelata.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_SIMMETRICO);
  514.                 else if(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO.equals(profiloCollaborazione))
  515.                     azioneCorrelata.setProfiloCollaborazione(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO);
  516.                 if(nomeServizio!=null)
  517.                     azioneCorrelata.setCorrelataServizio(nomeServizio);
  518.                 azioneCorrelata.setCorrelata(nomeAzione);
  519.                 ptCorrelato.addAzione(azioneCorrelata);
  520.                 
  521.                 servizi.put(servizio, ptCorrelato);
  522.             }
  523.         }
  524.         
  525.         if(servizi!=null && !servizi.isEmpty()) {
  526.             for (String pt : servizi.keySet()) {
  527.                 as.addPortType(servizi.get(pt));
  528.             }
  529.         }

  531.     }
  532.     
  533.     
  534.     
  535.     
  536.     
  537.     
  538.     
  539.     
  540.     
  541.     public static it.gov.spcoop.sica.manifest.DocumentoSemiformale generaDocumentoSemiformale(AccordoServizioParteComune as,
  542.             it.gov.spcoop.sica.dao.AccordoServizioParteComune accServParteComuneSICA,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  543.         it.gov.spcoop.sica.manifest.DocumentoSemiformale docSemiformalePerManifest = XMLUtils.generaDocumentoSemiformalePerManifesto();
  544.         it.gov.spcoop.sica.dao.Documento docSICA = XMLUtils.generaDocumentoSemiformale(as,namespaceCnipa,nomiSPCoopQualified);
  545.         accServParteComuneSICA.addSpecificaSemiformale(docSICA);
  546.         return docSemiformalePerManifest;
  547.     }
  548.     public static it.gov.spcoop.sica.manifest.DocumentoSemiformale generaDocumentoSemiformale(AccordoServizioParteComune as,
  549.             it.gov.spcoop.sica.dao.AccordoServizioComposto accServCompostoSICA,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  550.         it.gov.spcoop.sica.manifest.DocumentoSemiformale docSemiformalePerManifest = XMLUtils.generaDocumentoSemiformalePerManifesto();
  551.         it.gov.spcoop.sica.dao.Documento docSICA = XMLUtils.generaDocumentoSemiformale(as,namespaceCnipa,nomiSPCoopQualified);
  552.         accServCompostoSICA.addSpecificaSemiformale(docSICA);
  553.         return docSemiformalePerManifest;
  554.     }
  555.     private static it.gov.spcoop.sica.manifest.DocumentoSemiformale generaDocumentoSemiformalePerManifesto() throws XMLUtilsException{
  556.         it.gov.spcoop.sica.manifest.DocumentoSemiformale docSemiformale = new it.gov.spcoop.sica.manifest.DocumentoSemiformale();
  557.         docSemiformale.setTipo(TipiDocumentoSemiformale.XML.toString());
  558.         docSemiformale.setBase(it.cnipa.collprofiles.driver.Costanti.SPECIFICA_SEMIFORMALE_INFORMAZIONI_EGOV);
  559.         return docSemiformale;
  560.     }
  561.     private static it.gov.spcoop.sica.dao.Documento generaDocumentoSemiformale(AccordoServizioParteComune as,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  562.         it.gov.spcoop.sica.dao.Documento docSICA = new it.gov.spcoop.sica.dao.Documento();
  563.         docSICA.setTipo(TipiDocumentoSemiformale.XML.toString());
  564.         docSICA.setNome(it.cnipa.collprofiles.driver.Costanti.SPECIFICA_SEMIFORMALE_INFORMAZIONI_EGOV);
  565.         try{
  566.             byte[] dichiarazioneEGov = XMLUtils.generaDocumentoEGov(as, namespaceCnipa, nomiSPCoopQualified);
  567.             docSICA.setContenuto(dichiarazioneEGov);
  568.         }catch(Exception e){
  569.             throw new XMLUtilsException("Generazione dichiarazione eGov fallita: "+e.getMessage(),e);
  570.         }
  571.         return docSICA;
  572.     }
  573.     
  574.     public static String generaGenericoDocumento(AccordoServizioParteComune as,
  575.             it.gov.spcoop.sica.dao.AccordoServizioParteComune accServParteComuneSICA,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  576.         String genericoDocumentoPerManifest =  XMLUtils.generaGenericoDocumentoPerManifesto();
  577.         it.gov.spcoop.sica.dao.Documento docSICA = XMLUtils.generaGenericoDocumento(as,namespaceCnipa,nomiSPCoopQualified);
  578.         accServParteComuneSICA.addAllegato(docSICA);    
  579.         return genericoDocumentoPerManifest;
  580.     }
  581.     public static String generaGenericoDocumento(AccordoServizioParteComune as,
  582.             it.gov.spcoop.sica.dao.AccordoServizioComposto accServCompostoSICA,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  583.         String genericoDocumentoPerManifest =  XMLUtils.generaGenericoDocumentoPerManifesto();
  584.         it.gov.spcoop.sica.dao.Documento docSICA = XMLUtils.generaGenericoDocumento(as,namespaceCnipa,nomiSPCoopQualified);
  585.         accServCompostoSICA.addAllegato(docSICA);   
  586.         return genericoDocumentoPerManifest;
  587.     }
  588.     private static String generaGenericoDocumentoPerManifesto() throws XMLUtilsException{
  589.         return it.cnipa.collprofiles.driver.Costanti.SPECIFICA_SEMIFORMALE_INFORMAZIONI_EGOV;
  590.     }
  591.     private static it.gov.spcoop.sica.dao.Documento generaGenericoDocumento(AccordoServizioParteComune as,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  592.         it.gov.spcoop.sica.dao.Documento docSICA = new it.gov.spcoop.sica.dao.Documento();
  593.         docSICA.setTipo(TipiDocumentoSemiformale.XML.toString());
  594.         docSICA.setNome(it.cnipa.collprofiles.driver.Costanti.SPECIFICA_SEMIFORMALE_INFORMAZIONI_EGOV);
  595.         try{
  596.             byte[] dichiarazioneEGov = XMLUtils.generaDocumentoEGov(as, namespaceCnipa, nomiSPCoopQualified);
  597.             docSICA.setContenuto(dichiarazioneEGov);
  598.         }catch(Exception e){
  599.             throw new XMLUtilsException("Generazione dichiarazione eGov fallita: "+e.getMessage(),e);
  600.         }
  601.         return docSICA;
  602.     }
  603.     
  604.     private static byte[] generaDocumentoEGov(AccordoServizioParteComune as,boolean namespaceCnipa,boolean nomiSPCoopQualified) throws XMLUtilsException{
  605.         String prefissoNomiSPCoop = "";
  606.         String namespaceQualified = null;
  607.         if(nomiSPCoopQualified){
  608.             try{
  609.                 byte[] wsdlConcettuale = as.getByteWsdlConcettuale();
  610.                 if(wsdlConcettuale!=null){
  611.                     OpenSPCoop2MessageFactory defaultFactory = OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  612.                     RegistroOpenSPCoopUtilities wsdlUtility = new RegistroOpenSPCoopUtilities(defaultFactory, null);
  613.                     wsdlConcettuale = wsdlUtility.eliminaImportASParteComune(wsdlConcettuale);
  614.                     DefinitionWrapper wsdl = new DefinitionWrapper(wsdlConcettuale,org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT);
  615.                     String targetNamespace = wsdl.getTargetNamespace();
  616.                     String prefix = null;
  617.                     if(targetNamespace!=null){
  618.                         prefix = wsdl.getPrefix(targetNamespace);
  619.                         if(prefix==null)
  620.                             prefix = "tnsService";
  621.                     }
  622.                     if(targetNamespace!=null){
  623.                         prefissoNomiSPCoop = prefix+":";
  624.                         namespaceQualified = "xmlns"+":"+prefix+"=\""+targetNamespace+"\"";
  625.                     }
  626.                 }
  627.             }catch(Exception e){
  628.                 // errore non importantissimo. Se non vi e' un corretto wsdl, non viene utilizzato un prefisso per i nomi spcoop
  629.                 System.out.println("errore durante la lettura del target namespace del wsdl: "+e.getMessage());
  630.             }
  631.         }
  632.         byte[] dichiarazioneEGov = XMLUtils.generateDichiarazioneEGov(XMLUtils.generaProfiloCollaborazioneEGOV(as,prefissoNomiSPCoop),namespaceCnipa);
  633.         if(nomiSPCoopQualified && namespaceQualified!=null){
  634.             dichiarazioneEGov = new String(dichiarazioneEGov).replaceFirst(Costanti.ROOT_LOCAL_NAME, Costanti.ROOT_LOCAL_NAME+" "+namespaceQualified).getBytes();
  635.         }
  636.         return dichiarazioneEGov;
  637.     }
  638.     
  639.     private static EgovDecllElement generaProfiloCollaborazioneEGOV(AccordoServizioParteComune as,String prefissoNomiSPCoop) throws XMLUtilsException{
  640.         
  641.         if(as.sizePortTypeList()>0){
  642.             EgovDecllElement egov = new EgovDecllElement();
  643.             
  644.             egov.setEGovVersion(it.cnipa.collprofiles.driver.Costanti.VERSIONE_BUSTA);
  645.             try {
  646.                 java.net.URI uri = new java.net.URI(as.getNome());
  647.                 egov.setRifDefinizioneInterfaccia(uri);
  648.             }catch(Exception e) {
  649.                 throw new XMLUtilsException(e.getMessage(),e);
  650.             }
  651.             
  652.             OperationListType operations = new OperationListType();
  653.             
  654.             List<OperationType> operationsSICA_asincrone_nonAncoraInserite = new ArrayList<OperationType>();
  655.                     
  656.             for(int i=0; i<as.sizePortTypeList(); i++){
  657.                 
  658.                 PortType pt = as.getPortType(i);
  659.                 String nomeServizio = prefissoNomiSPCoop+pt.getNome();
  660.                 
  661.                 for(int j=0; j<pt.sizeAzioneList(); j++){
  662.                     
  663.                     Operation op = pt.getAzione(j);
  664.                     
  665.                     String nomeAzione = prefissoNomiSPCoop+op.getNome();
  666.                     String nomeAzioneCorrelata = op.getCorrelata();
  667.                     if(nomeAzioneCorrelata!=null)
  668.                         nomeAzioneCorrelata=prefissoNomiSPCoop+nomeAzioneCorrelata;
  669.                     String nomeServizioCorrelato = op.getCorrelataServizio();
  670.                     if(nomeServizioCorrelato!=null)
  671.                         nomeServizioCorrelato=prefissoNomiSPCoop+nomeServizioCorrelato;
  672.             
  673.                     ProfiloCollaborazione profilo = null;
  674.                     if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(op.getProfAzione())){
  675.                         profilo = op.getProfiloCollaborazione();
  676.                     }else{
  677.                         profilo = pt.getProfiloCollaborazione();
  678.                     }
  679.                     if(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO.equals(profilo) ||  CostantiRegistroServizi.ASINCRONO_SIMMETRICO.equals(profilo)){
  680.                         
  681.                         // Nel profilo asincrono asimmetrico il registro dei servizi di openspcoop dispone delle informazioni
  682.                         // necessarie per la correlazione.
  683.                         // Per l'asincrono simmetrico invece no.
  684.                         // Comunque anche per l'asincrono asimmetrico dove vengono usati due servizi correlati tale fatto non succede.
  685.                         // Questo aspetto viene gestito come segue:
  686.                         // Se l'operation e' null, viene tenuta in memoria tale operation (asincrona senza correlazione)
  687.                         // Se poi e' presente un'altra azione che contiene la correlazione, tale operation non sara' inserita.
  688.                         
  689.                         if(nomeAzioneCorrelata==null){
  690.                             
  691.                             // Vedo dopo se aggiungerlo
  692.                             
  693.                             OperationType opSICA = new OperationType();
  694.                             opSICA.setOperazione(nomeAzione); 
  695.                             if(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO.equals(profilo))
  696.                                 opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO);
  697.                             else if(CostantiRegistroServizi.ASINCRONO_SIMMETRICO.equals(profilo))
  698.                                 opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO);
  699.                             opSICA.setServizio(nomeServizio);
  700.                             operationsSICA_asincrone_nonAncoraInserite.add(opSICA);
  701.                         }else{
  702.                             
  703.                             // Operazione asincrono con info correlata
  704.                             
  705.                             OperationType opSICA = new OperationType();
  706.                             opSICA.setOperazione(nomeAzioneCorrelata);
  707.                             opSICA.setOperazioneCorrelata(nomeAzione);
  708.                             if(CostantiRegistroServizi.ASINCRONO_ASIMMETRICO.equals(profilo))
  709.                                 opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.ASINCRONO_ASIMMETRICO);
  710.                             else if(CostantiRegistroServizi.ASINCRONO_SIMMETRICO.equals(profilo))
  711.                                 opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.ASINCRONO_SIMMETRICO);
  712.                             if(nomeServizioCorrelato!=null)
  713.                                 opSICA.setServizio(nomeServizioCorrelato);
  714.                             else
  715.                                 opSICA.setServizio(nomeServizio);
  716.                             opSICA.setServizioCorrelato(nomeServizio);
  717.                             operations.addOperation(opSICA);
  718.                         }
  719.                     }else{
  720.                         OperationType opSICA = new OperationType();
  721.                         opSICA.setOperazione(nomeAzione); 
  722.                         if(CostantiRegistroServizi.ONEWAY.equals(profilo))
  723.                             opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.ONE_WAY);
  724.                         else if(CostantiRegistroServizi.SINCRONO.equals(profilo))
  725.                             opSICA.setProfiloDiCollaborazione(ProfiloDiCollaborazioneType.SINCRONO);
  726.                         opSICA.setServizio(nomeServizio);
  727.                         operations.addOperation(opSICA);
  728.                     }
  729.                     
  730.                 }
  731.             }
  732.             
  733.             
  734.             // check operazioni non ancora inserite
  735.             while(operationsSICA_asincrone_nonAncoraInserite.size()>0){
  736.                 OperationType opSICA = operationsSICA_asincrone_nonAncoraInserite.remove(0);
  737.                 boolean find = false;
  738.                 for(int i=0;i<operations.sizeOperationList();i++){
  739.                     if(opSICA.getServizio().equals(operations.getOperation(i).getServizio()) &&
  740.                             opSICA.getOperazione().equals(operations.getOperation(i).getOperazione()) ){
  741.                         find =  true;
  742.                         break;
  743.                     }
  744.                 }
  745.                 if(find==false){
  746.                     operations.addOperation(opSICA);
  747.                 }
  748.             }
  749.             
  750.             
  751.             egov.setOperationList(operations);
  752.             
  753.             return egov;
  754.         }
  755.         else {
  756.             throw new  XMLUtilsException("PortTypes non definiti per l'accordo di servizio");
  757.         }
  758.     }
  759. }
Created with JaCoCo 0.8.8.202204050719