SDISbustamento.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.protocol.sdi.builder;

  22. import java.util.Iterator;
  23. import java.util.List;

  25. import javax.xml.soap.AttachmentPart;
  26. import javax.xml.soap.MimeHeaders;
  27. import javax.xml.soap.SOAPBody;
  28. import javax.xml.soap.SOAPElement;

  30. import org.openspcoop2.message.OpenSPCoop2Message;
  31. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  32. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  33. import org.openspcoop2.message.exception.MessageException;
  34. import org.openspcoop2.message.exception.MessageNotSupportedException;
  35. import org.openspcoop2.message.soap.DumpSoapMessageUtils;
  36. import org.openspcoop2.message.soap.SoapUtils;
  37. import org.openspcoop2.message.soap.TunnelSoapUtils;
  38. import org.openspcoop2.message.soap.mtom.MTOMUtilities;
  39. import org.openspcoop2.message.utils.MessageUtilities;
  40. import org.openspcoop2.protocol.sdi.config.SDIProperties;
  41. import org.openspcoop2.protocol.sdi.constants.SDICostanti;
  42. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviNotifica;
  43. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRicezioneFatture;
  44. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioTrasmissioneFatture;
  45. import org.openspcoop2.protocol.sdi.utils.SDIUtils;
  46. import org.openspcoop2.protocol.sdk.Busta;
  47. import org.openspcoop2.protocol.sdk.ProtocolException;
  48. import org.openspcoop2.utils.Utilities;
  49. import org.openspcoop2.utils.dch.MailcapActivationReader;
  50. import org.openspcoop2.utils.io.Base64Utilities;
  51. import org.openspcoop2.utils.transport.http.HttpConstants;
  52. import org.w3c.dom.Element;
  53. import org.w3c.dom.Node;

  55. import it.gov.fatturapa.sdi.messaggi.v1_0.constants.TipiMessaggi;
  56. import it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.constants.EsitoNotificaType;

  58. /**
  59.  * SDISbustamento
  60.  * 
  61.  * @author Andrea Poli (apoli@link.it)
  62.  * @author $Author$
  63.  * @version $Rev$, $Date$
  64.  */
  65. public class SDISbustamento {

  67.     private SDIBustaBuilder bustaBuilder = null;
  68.     @SuppressWarnings("unused")
  69.     public SDISbustamento(SDIBustaBuilder bustaBuilder){
  70.         this.bustaBuilder = bustaBuilder;
  71.     }
  72.     
  73.     public SOAPElement sbustamentoRisposta_ServizioSdIRiceviFile_AzioneRiceviFile(Busta busta,OpenSPCoop2Message msgParam) throws ProtocolException{
  74.         try{
  75.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  76.             
  77.             SOAPElement element = null;
  78.                         
  79.             SOAPBody soapBody = msg.getSOAPBody();
  80.             
  81.             // estraggo header
  82.             element = SDIUtils.readHeader(msg);
  83.                     
  84.             // detach body
  85.             soapBody.removeContents();
  86.             
  87.             // se sono presenti degli attachments li elimino
  88.             if(msg.countAttachments()>0){
  89.                 msg.removeAllAttachments();
  90.             }
  91.             
  92.             // imposto content type
  93.             msg.setContentType(MessageUtilities.getDefaultContentType(msg.getMessageType()));
  94.             
  95.             return element;
  96.             
  97.         }catch(Exception e){
  98.             throw new ProtocolException(e.getMessage(),e);
  99.         }
  100.     }
  101.     
  102.     public SOAPElement sbustamentoRichiesta_ServizioRicezioneFatture_AzioneRiceviFatture(Busta busta,OpenSPCoop2Message msgParam) throws ProtocolException{
  103.         
  104.         try{
  105.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  106.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  107.             
  108.             SOAPElement element = null;
  109.             Object ctxFatturaPA = msg.removeContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_FATTURA);
  110.             String versioneFattura = busta.getProperty(SDICostanti.SDI_BUSTA_EXT_VERSIONE_FATTURA_PA);
  111.                         
  112.             SOAPBody soapBody = msg.getSOAPBody();
  113.             
  114.             // estraggo header
  115.             element = SDIUtils.readHeader(msg);
  116.             
  117.             // Leggo fattura
  118.             byte [] xmlFattura = null;
  119.             boolean p7m = false;
  120.             if(ctxFatturaPA!=null){
  121.                 
  122.                 //System.out.println("OTTIMIZZATO");
  123.                 if(SDICostanti.SDI_VERSIONE_FATTURA_PA_10.equals(versioneFattura)){
  124.                     it.gov.fatturapa.sdi.fatturapa.v1_0.FatturaElettronicaType fattura = (it.gov.fatturapa.sdi.fatturapa.v1_0.FatturaElettronicaType) ctxFatturaPA;
  125.                     it.gov.fatturapa.sdi.fatturapa.v1_0.ObjectFactory of = new it.gov.fatturapa.sdi.fatturapa.v1_0.ObjectFactory();
  126.                     it.gov.fatturapa.sdi.fatturapa.v1_0.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.fatturapa.v1_0.utils.serializer.JaxbSerializer();
  127.                     xmlFattura = serializer.toByteArray(of.createFatturaElettronica(fattura));
  128.                 }
  129.                 else if(SDICostanti.SDI_VERSIONE_FATTURA_PA_11.equals(versioneFattura)){
  130.                     it.gov.fatturapa.sdi.fatturapa.v1_1.FatturaElettronicaType fattura = (it.gov.fatturapa.sdi.fatturapa.v1_1.FatturaElettronicaType) ctxFatturaPA;
  131.                     it.gov.fatturapa.sdi.fatturapa.v1_1.ObjectFactory of = new it.gov.fatturapa.sdi.fatturapa.v1_1.ObjectFactory();
  132.                     it.gov.fatturapa.sdi.fatturapa.v1_1.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.fatturapa.v1_1.utils.serializer.JaxbSerializer();
  133.                     xmlFattura = serializer.toByteArray(of.createFatturaElettronica(fattura));
  134.                 }
  135.                 else if(SDICostanti.SDI_VERSIONE_FATTURA_SEMPLIFICATA_10.equals(versioneFattura)){
  136.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.FatturaElettronicaType fattura = (it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.FatturaElettronicaType) ctxFatturaPA;
  137.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.ObjectFactory of = new it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.ObjectFactory();
  138.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.utils.serializer.JaxbSerializer serializer = new it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.utils.serializer.JaxbSerializer();
  139.                     xmlFattura = serializer.toByteArray(of.createFatturaElettronicaSemplificata(fattura));
  140.                 }
  141.                 else{
  142.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.FatturaElettronicaType fattura = (it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.FatturaElettronicaType) ctxFatturaPA;
  143.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.ObjectFactory of = new it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.ObjectFactory();
  144.                     it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.utils.serializer.JaxbSerializer serializer = new it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.utils.serializer.JaxbSerializer();
  145.                     xmlFattura = serializer.toByteArray(of.createFatturaElettronica(fattura));
  146.                 }
  147.                 
  148.             }else{
  149.                 
  150.                 //System.out.println("NON OTTIMIZZATO");
  151.                 Element elementBody = SoapUtils.getNotEmptyFirstChildSOAPElement(soapBody);
  152.                 List<Node> childs = SoapUtils.getNotEmptyChildNodes(messageFactory, elementBody, false);
  153.                 for (int i = 0; i < childs.size(); i++) {
  154.                     Node child = childs.get(i);
  155.                     if(SDICostantiServizioRicezioneFatture.RICEVI_FATTURE_RICHIESTA_ELEMENT_FILE.equals(child.getLocalName())){
  156.                         Element e = MTOMUtilities.getIfExistsXomReference(messageFactory, (Element)child);
  157.                         if(e!=null){
  158.                             //System.out.println("NON OTTIMIZZATO MTOM");
  159.                             // mtom
  160.                             AttachmentPart ap = this.getAttachmentPart(msg, e);
  161.                             if(ap!=null) {
  162.                                 xmlFattura = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  163.                             }
  164.                         }else{
  165.                             //System.out.println("NON OTTIMIZZATO NO MTOM");
  166.                             // no mtom
  167.                             xmlFattura = Base64Utilities.decode(child.getTextContent());
  168.                         }
  169.                     }
  170.                 }
  171.                 
  172.                 // Se la fattura e' un P7M non e' un xml.
  173.                 // Il formato viene compreso durante la validazione sintattica
  174.                 Object formato = busta.getProperty(SDICostanti.SDI_BUSTA_EXT_FORMATO_ARCHIVIO_INVIO_FATTURA);
  175.                 if(formato!=null && ((String)formato).equals(SDICostanti.SDI_TIPO_FATTURA_P7M) ){
  176.                     p7m = true;
  177.                 }
  178.             }
  179.             
  180.                     
  181.             // detach body
  182.             soapBody.removeContents();
  183.             
  184.             // se sono presenti degli attachments li elimino
  185.             if(msg.countAttachments()>0){
  186.                 msg.removeAllAttachments();
  187.             }
  188.                 
  189.             // imposto content type
  190.             msg.setContentType(MessageUtilities.getDefaultContentType(msg.getMessageType()));
  191.             
  192.             // add Fattura as body
  193.             if(p7m){
  194.                 org.openspcoop2.utils.mime.MimeTypes mimeTypes = org.openspcoop2.utils.mime.MimeTypes.getInstance();
  195.                 TunnelSoapUtils.
  196.                     imbustamentoMessaggioConAttachment(msg,xmlFattura,HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP,
  197.                             MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP),
  198.                             mimeTypes.getMimeType(SDICostanti.SDI_TIPO_FATTURA_P7M), SDICostanti.SDI_PROTOCOL_NAMESPACE);
  199.                 
  200.                 // Serve per forzare il tunnel SOAP che altrimenti non viene abilitato ('tunnel openspcoop2') 
  201.                 DumpSoapMessageUtils.dumpMessage(msg, true);

  203.             }else{
  204.                 //soapBody.addChildElement(SoapUtils.getSoapFactory(msg.getMessageType()).createElement(this.xmlUtils.newElement(xmlFattura)));
  205.                 // Bug Fix: OP-752
  206.                 
  207.                 // USO Comunque il tunnel SOAP altrimenti l'xml viene modificato e la firma non e' piu' valida
  208.                 // Uso esattamente il codice sopra utilizzando pero' come content type text/xml:
  209.                 TunnelSoapUtils.
  210.                 imbustamentoMessaggioConAttachment(msg,xmlFattura,HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP,
  211.                         MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP),
  212.                         HttpConstants.CONTENT_TYPE_TEXT_XML, SDICostanti.SDI_PROTOCOL_NAMESPACE);
  213.             
  214.                 // Serve per forzare il tunnel SOAP che altrimenti non viene abilitato ('tunnel openspcoop2') 
  215.                 DumpSoapMessageUtils.dumpMessage(msg, true);
  216.             }
  217.             
  218.             
  219.             return element;
  220.             
  221.         }catch(Exception e){
  222.             throw new ProtocolException(e.getMessage(),e);
  223.         }
  224.         
  225.     }
  226.     
  227.     public SOAPElement sbustamentoRisposta_ServizioSdIRiceviNotifica_AzioneNotificaEsito(Busta busta,OpenSPCoop2Message msgParam) throws ProtocolException{
  228.         try{
  229.             
  230.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  231.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  232.             
  233.             SOAPElement element = null;
  234.             Object ctxNotificaScartoEsitoCommittente = msg.removeContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_MESSAGGIO_SERVIZIO_SDI);
  235.                         
  236.             SOAPBody soapBody = msg.getSOAPBody();
  237.             
  238.             // estraggo header
  239.             element = SDIUtils.readHeader(msg);
  240.             
  241.             // Leggo se presente una notifica scarto esito committente
  242.             byte [] xmlNotificaScartoEsitoCommittente = null;
  243.             if(ctxNotificaScartoEsitoCommittente!=null){
  244.                 //System.out.println("OTTIMIZZATO");
  245.                 it.gov.fatturapa.sdi.messaggi.v1_0.ScartoEsitoCommittenteType scarto = (it.gov.fatturapa.sdi.messaggi.v1_0.ScartoEsitoCommittenteType) ctxNotificaScartoEsitoCommittente;
  246.                 it.gov.fatturapa.sdi.messaggi.v1_0.ObjectFactory of = new it.gov.fatturapa.sdi.messaggi.v1_0.ObjectFactory();
  247.                 it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbSerializer();
  248.                 xmlNotificaScartoEsitoCommittente = serializer.toByteArray(of.createScartoEsitoCommittente(scarto));
  249.                 
  250.             }else{
  251.                 
  252.                 //System.out.println("NON OTTIMIZZATO");
  253.                 Element elementBody = SoapUtils.getNotEmptyFirstChildSOAPElement(soapBody);
  254.                 List<Node> childs = SoapUtils.getNotEmptyChildNodes(messageFactory, elementBody, false);
  255.                 for (int i = 0; i < childs.size(); i++) {
  256.                     Node child = childs.get(i);
  257.                     if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO.equals(child.getLocalName())){
  258.                         
  259.                         List<Node> elementScartoChilds = SoapUtils.getNotEmptyChildNodes(messageFactory, child, false);
  260.                         if(elementScartoChilds!=null){
  261.                             for (int j = 0; j < elementScartoChilds.size(); j++) {
  262.                                 Node scartoChild = elementScartoChilds.get(j);
  263.                         
  264.                                 if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE.equals(scartoChild.getLocalName())){
  265.                                     
  266.                                     Element e = MTOMUtilities.getIfExistsXomReference(messageFactory, (Element)scartoChild);
  267.                                     if(e!=null){
  268.                                         //System.out.println("NON OTTIMIZZATO MTOM");
  269.                                         // mtom
  270.                                         AttachmentPart ap = this.getAttachmentPart(msg, e);
  271.                                         if(ap!=null) {
  272.                                             xmlNotificaScartoEsitoCommittente = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  273.                                         }
  274.                                     }else{
  275.                                         //System.out.println("NON OTTIMIZZATO NO MTOM");
  276.                                         // no mtom
  277.                                         xmlNotificaScartoEsitoCommittente = Base64Utilities.decode(scartoChild.getTextContent());
  278.                                     }
  279.                                     
  280.                                 }
  281.                             }
  282.                         }
  283.                         
  284.                     }
  285.                 }
  286.             }
  287.                     
  288.             // detach body
  289.             soapBody.removeContents();
  290.             
  291.             // se sono presenti degli attachments li elimino
  292.             if(msg.countAttachments()>0){
  293.                 msg.removeAllAttachments();
  294.             }
  295.             
  296.             // imposto content type
  297.             msg.setContentType(MessageUtilities.getDefaultContentType(msg.getMessageType()));
  298.             
  299.             // se esiste uno scarto committente lo aggiungo come body
  300.             if(xmlNotificaScartoEsitoCommittente!=null){
  301.                 //soapBody.addChildElement(SoapUtils.getSoapFactory(msg.getMessageType()).createElement(this.xmlUtils.newElement(xmlNotificaScartoEsitoCommittente)));
  302.                 // Bug Fix: OP-752
  303.                 
  304.                 // USO Comunque il tunnel SOAP altrimenti l'xml viene modificato e la firma non e' piu' valida
  305.                 // Uso esattamente il codice sopra utilizzando pero' come content type text/xml:
  306.                 TunnelSoapUtils.
  307.                 imbustamentoMessaggioConAttachment(msg,xmlNotificaScartoEsitoCommittente,HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP,
  308.                         MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP),
  309.                         HttpConstants.CONTENT_TYPE_TEXT_XML, SDICostanti.SDI_PROTOCOL_NAMESPACE);
  310.             
  311.                 // Serve per forzare il tunnel SOAP che altrimenti non viene abilitato ('tunnel openspcoop2') 
  312.                 DumpSoapMessageUtils.dumpMessage(msg, true);
  313.             }
  314.             
  315.             // se lo sdi ha restituito un esito non ok imposto 500 come codice di trasporto verso il client
  316.             String esitoNotifica = busta.getProperty(SDICostanti.SDI_BUSTA_EXT_ESITO_NOTIFICA);
  317.             // ES01 = NOTIFICA ACCETTATA
  318.             if(EsitoNotificaType.ES01.name().equals(esitoNotifica)){
  319.                 msg.setForcedResponseCode("202");
  320.             }
  321.             else{
  322.                 // ES00 = NOTIFICA NON ACCETTATA
  323.                 if(EsitoNotificaType.ES00.name().equals(esitoNotifica)){
  324.                     msg.setForcedResponseCode("200");
  325.                 }
  326.             }
  327.             
  328.             return element;
  329.             
  330.         }catch(Exception e){
  331.             throw new ProtocolException(e.getMessage(),e);
  332.         }
  333.     }
  334.     
  335.     
  336.     
  337.     public SOAPElement sbustamentoRichiesta_ServizioTrasmissioneFatture_Notifiche(TipiMessaggi tipoMessaggio, Busta busta,OpenSPCoop2Message msgParam) throws ProtocolException{
  338.         
  339.         try{
  340.         
  341.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  342.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  343.             
  344.             SOAPElement element = null;
  345.             Object ctxMessaggio = msg.removeContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_MESSAGGIO_SERVIZIO_SDI);
  346.                         
  347.             SOAPBody soapBody = msg.getSOAPBody();
  348.             
  349.             // estraggo header
  350.             element = SDIUtils.readHeader(msg);
  351.             
  352.             // Leggo fattura
  353.             byte [] xmlNotifica = null;
  354.             byte [] zip = null;
  355.             if(ctxMessaggio!=null){
  356.                 
  357.                 //System.out.println("OTTIMIZZATO");
  358.                 
  359.                 it.gov.fatturapa.sdi.messaggi.v1_0.ObjectFactory of = new it.gov.fatturapa.sdi.messaggi.v1_0.ObjectFactory();
  360.                 it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbSerializer();
  361.                             
  362.                 switch (tipoMessaggio) {
  363.                 case RC:
  364.                     it.gov.fatturapa.sdi.messaggi.v1_0.RicevutaConsegnaType rc = (it.gov.fatturapa.sdi.messaggi.v1_0.RicevutaConsegnaType) ctxMessaggio;
  365.                     xmlNotifica = serializer.toByteArray(of.createRicevutaConsegna(rc));
  366.                     break;
  367.                     
  368.                 case MC:
  369.                     it.gov.fatturapa.sdi.messaggi.v1_0.NotificaMancataConsegnaType mc = (it.gov.fatturapa.sdi.messaggi.v1_0.NotificaMancataConsegnaType) ctxMessaggio;
  370.                     xmlNotifica = serializer.toByteArray(of.createNotificaMancataConsegna(mc));
  371.                     break;
  372.                     
  373.                 case NS:
  374.                     it.gov.fatturapa.sdi.messaggi.v1_0.NotificaScartoType ns = (it.gov.fatturapa.sdi.messaggi.v1_0.NotificaScartoType) ctxMessaggio;
  375.                     xmlNotifica = serializer.toByteArray(of.createNotificaScarto(ns));
  376.                     break;
  377.                     
  378.                 case NE:
  379.                     it.gov.fatturapa.sdi.messaggi.v1_0.NotificaEsitoType ne = (it.gov.fatturapa.sdi.messaggi.v1_0.NotificaEsitoType) ctxMessaggio;
  380.                     xmlNotifica = serializer.toByteArray(of.createNotificaEsito(ne));
  381.                     break;
  382.                     
  383.                 case DT:
  384.                     it.gov.fatturapa.sdi.messaggi.v1_0.NotificaDecorrenzaTerminiType dt = (it.gov.fatturapa.sdi.messaggi.v1_0.NotificaDecorrenzaTerminiType) ctxMessaggio;
  385.                     xmlNotifica = serializer.toByteArray(of.createNotificaDecorrenzaTermini(dt));
  386.                     break;
  387.                     
  388.                 case AT:
  389.                     it.gov.fatturapa.sdi.messaggi.v1_0.AttestazioneTrasmissioneFatturaType at = (it.gov.fatturapa.sdi.messaggi.v1_0.AttestazioneTrasmissioneFatturaType) ctxMessaggio;
  390.                     xmlNotifica = serializer.toByteArray(of.createAttestazioneTrasmissioneFattura(at));
  391.                     break;

  393.                 default:
  394.                     break;
  395.                 }
  396.                 
  397.             }else{
  398.                 
  399.                 if(TipiMessaggi.AT.equals(tipoMessaggio) && SDIProperties.getInstance(this.bustaBuilder.getLog()).isEnableAccessoMessaggi()){
  400.                     
  401.                     Object oZip = msg.removeContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_AT_ARCHIVIO_ZIP);
  402.                     if(oZip!=null){
  403.                         zip = (byte[]) oZip;
  404.                     }
  405.                     else{
  406.                         Object oXml = msg.removeContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_AT_ARCHIVIO_XML);
  407.                         if(oXml!=null){
  408.                             xmlNotifica = (byte[]) oXml;
  409.                         }
  410.                         else{
  411.                             throw new Exception("Contenuto della notifica di Attestazione Trasmissione per Impossibilità di Recapito");
  412.                         }
  413.                     }
  414.                     
  415.                 }
  416.                 else{
  417.                     //System.out.println("NON OTTIMIZZATO");
  418.                     Element elementBody = SoapUtils.getNotEmptyFirstChildSOAPElement(soapBody);
  419.                     List<Node> childs = SoapUtils.getNotEmptyChildNodes(messageFactory, elementBody, false);
  420.                     for (int i = 0; i < childs.size(); i++) {
  421.                         Node child = childs.get(i);
  422.                         if(SDICostantiServizioTrasmissioneFatture.FILE_SDI_TYPE_CONSEGNA_RICHIESTA_ELEMENT_FILE.equals(child.getLocalName())){
  423.                             Element e = MTOMUtilities.getIfExistsXomReference(messageFactory, (Element)child);
  424.                             if(e!=null){
  425.                                 //System.out.println("NON OTTIMIZZATO MTOM");
  426.                                 // mtom
  427.                                 AttachmentPart ap = this.getAttachmentPart(msg, e);
  428.                                 if(ap!=null) {
  429.                                     xmlNotifica = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  430.                                 }
  431.                             }else{
  432.                                 //System.out.println("NON OTTIMIZZATO NO MTOM");
  433.                                 // no mtom
  434.                                 xmlNotifica = Base64Utilities.decode(child.getTextContent());
  435.                             }
  436.                         }
  437.                     }
  438.                     
  439.                     if(TipiMessaggi.AT.equals(tipoMessaggio)) {
  440.                         // xmlNotifica contiene uno zip file poiche' non l'ho trattato
  441.                         zip = xmlNotifica;
  442.                     }
  443.                 }
  444.             }
  445.             
  446.                     
  447.             // detach body
  448.             soapBody.removeContents();
  449.             
  450.             // se sono presenti degli attachments li elimino
  451.             if(msg.countAttachments()>0){
  452.                 msg.removeAllAttachments();
  453.             }
  454.             
  455.             // imposto content type
  456.             msg.setContentType(MessageUtilities.getDefaultContentType(msg.getMessageType()));
  457.             
  458.             // add Fattura as body
  459.             if(zip!=null){
  460.                 TunnelSoapUtils.
  461.                     imbustamentoMessaggioConAttachment(msg,zip,HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP,
  462.                             MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP),
  463.                             HttpConstants.CONTENT_TYPE_ZIP, SDICostanti.SDI_PROTOCOL_NAMESPACE);
  464.                 
  465.                 // Serve per forzare il tunnel SOAP che altrimenti non viene abilitato ('tunnel openspcoop2') 
  466.                 DumpSoapMessageUtils.dumpMessage(msg, true);

  468.             }else{
  469.                 //soapBody.addChildElement(SoapUtils.getSoapFactory(msg.getMessageType()).createElement(this.xmlUtils.newElement(xmlNotifica)));
  470.                 // Bug Fix: OP-752
  471.                 
  472.                 // USO Comunque il tunnel SOAP altrimenti l'xml viene modificato e la firma non e' piu' valida
  473.                 // Uso esattamente il codice sopra utilizzando pero' come content type text/xml:
  474.                 TunnelSoapUtils.
  475.                 imbustamentoMessaggioConAttachment(msg,xmlNotifica,HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP,
  476.                         MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_OPENSPCOOP2_TUNNEL_SOAP),
  477.                         HttpConstants.CONTENT_TYPE_TEXT_XML, SDICostanti.SDI_PROTOCOL_NAMESPACE);
  478.             
  479.                 // Serve per forzare il tunnel SOAP che altrimenti non viene abilitato ('tunnel openspcoop2') 
  480.                 DumpSoapMessageUtils.dumpMessage(msg, true);
  481.             }
  482.                 
  483.             return element;
  484.             
  485.         }catch(Exception e){
  486.             throw new ProtocolException(e.getMessage(),e);
  487.         }
  488.         
  489.     }
  490.     
  491.     
  492.     private AttachmentPart getAttachmentPart(OpenSPCoop2SoapMessage msg,Element e) throws MessageException, MessageNotSupportedException{
  493.         String contentId = MTOMUtilities.getCidXomReference(e);
  494.         MimeHeaders mhs = new MimeHeaders();
  495.         mhs.addHeader(HttpConstants.CONTENT_ID, contentId);
  496.         Iterator<?> itAttachments = msg.getAttachments(mhs);
  497.         if(itAttachments == null || itAttachments.hasNext()==false){
  498.             throw new MessageException("Found XOM Reference with attribute ["+
  499.                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but the message hasn't attachments");
  500.         }
  501.         AttachmentPart ap = null;
  502.         while (itAttachments.hasNext()) {
  503.             if(ap!=null){
  504.                 throw new MessageException("Found XOM Reference with attribute ["+
  505.                         org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but exists more than one attachment with same id");
  506.             }
  507.             ap = (AttachmentPart) itAttachments.next();
  508.         }
  509.         return ap;
  510.     }
  511. }
Created with JaCoCo 0.8.8.202204050719