SDIImbustamento.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.io.ByteArrayInputStream;
  23. import java.math.BigInteger;
  24. import java.util.ArrayList;
  25. import java.util.List;

  27. import javax.xml.soap.AttachmentPart;
  28. import javax.xml.soap.SOAPBody;
  29. import javax.xml.soap.SOAPElement;
  30. import javax.xml.soap.SOAPPart;

  32. import org.openspcoop2.message.OpenSPCoop2Message;
  33. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  34. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  35. import org.openspcoop2.message.constants.Costanti;
  36. import org.openspcoop2.message.soap.SoapUtils;
  37. import org.openspcoop2.message.utils.MessageUtilities;
  38. import org.openspcoop2.message.xml.MessageXMLUtils;
  39. import org.openspcoop2.protocol.sdi.config.SDIProperties;
  40. import org.openspcoop2.protocol.sdi.config.SDITraduttore;
  41. import org.openspcoop2.protocol.sdi.constants.SDICostanti;
  42. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviFile;
  43. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviNotifica;
  44. import org.openspcoop2.protocol.sdi.utils.SDICompatibilitaNamespaceErrati;
  45. import org.openspcoop2.protocol.sdi.utils.SDIFatturaUtils;
  46. import org.openspcoop2.protocol.sdi.utils.SDIUtils;
  47. import org.openspcoop2.protocol.sdi.validator.SDIValidazioneUtils;
  48. import org.openspcoop2.protocol.sdk.Busta;
  49. import org.openspcoop2.protocol.sdk.Eccezione;
  50. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  51. import org.openspcoop2.protocol.sdk.ProtocolException;
  52. import org.openspcoop2.protocol.sdk.state.IState;
  53. import org.openspcoop2.utils.Utilities;
  54. import org.openspcoop2.utils.xml.AbstractValidatoreXSD;

  56. import it.gov.fatturapa.sdi.messaggi.v1_0.constants.TipiMessaggi;

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

  67.     private SDIBustaBuilder bustaBuilder = null;
  68.     private SDIValidazioneUtils sdiUtils = null;
  69.     private SDITraduttore sdiTraduttore = null;
  70.     private SDIProperties sdiProperties = null;
  71.     public SDIImbustamento(SDIBustaBuilder bustaBuilder) throws ProtocolException{
  72.         this.bustaBuilder = bustaBuilder;
  73.         this.sdiUtils = new SDIValidazioneUtils(bustaBuilder.getProtocolFactory());
  74.         this.sdiTraduttore = (SDITraduttore) bustaBuilder.getProtocolFactory().createTraduttore();
  75.         this.sdiProperties = SDIProperties.getInstance(bustaBuilder.getProtocolFactory().getLogger());
  76.     }
  77.     
  78.     public SOAPElement creaRichiesta_ServizioSdIRiceviFile_AzioneRiceviFile(IProtocolFactory<?> protocolFactory, IState state, Busta busta, OpenSPCoop2Message msgParam) throws ProtocolException{
  79.         
  80.         try{
  81.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  82.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  83.             MessageXMLUtils xmlUtils = MessageXMLUtils.getInstance(messageFactory);
  84.                     
  85.             // create body
  86.             SOAPPart soapPart = msg.getSOAPPart();
  87.             SOAPBody soapBody = msg.getSOAPBody();
  88.             if(soapBody==null){
  89.                 soapBody = soapPart.getEnvelope().addBody();
  90.             }
  91.             
  92.         
  93.             // !!NOTA!! : Per comprendere cosa sia presente nel soapBody e negli attachments vedere org.openspcoop2.protocol.sdi.utils.PreInRequestHandler
  94.             
  95.             
  96.             // childElement
  97.             List<SOAPElement> childs = SoapUtils.getNotEmptyChildSOAPElement(soapBody);
  98.             if(childs==null || childs.size()<=0){
  99.                 throw new Exception("FatturaPA non presente");
  100.             }
  101.             if(childs.size()>1){
  102.                 throw new Exception("Sono presenti piu' elementi xml. Deve essere fornita una singola FatturaPA (o file ZIP)");
  103.             }
  104.             SOAPElement fatturaSOAPElement = childs.get(0);
  105.             
  106.             
  107.             
  108.             // tipoInvioFattura
  109.             String tipoInvioFattura = null;
  110.             byte[] fatturaAllegata = null;
  111.             String idPaese = null;
  112.             String idCodice = null;
  113.             String versioneFattura = null;
  114.             if(Costanti.SOAP_TUNNEL_NAMESPACE.equals(fatturaSOAPElement.getNamespaceURI())){
  115.                 
  116.                 // Grazie alla classe org.openspcoop2.protocol.sdi.utils.PreInRequestHandler entreremo qua nel caso ZIP o P7M
  117.                 
  118.                 // versioneFattura
  119.                 if(msg.getTransportRequestContext()!=null){
  120.                     versioneFattura =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_VERSIONE_FATTURA);
  121.                     if(versioneFattura==null){
  122.                         versioneFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_VERSIONE_FATTURA_1);
  123.                     }
  124.                     if(versioneFattura==null){
  125.                         versioneFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_VERSIONE_FATTURA_2);
  126.                     }
  127.                 }
  128.                 if(versioneFattura==null){
  129.                     throw new Exception("Versione non fornita (indicare una delle seguenti versioni: "+SDICostanti.SDI_VERSIONI_FATTURA+")");
  130.                 }
  131.                 versioneFattura = versioneFattura.trim().toUpperCase();
  132.                 if(SDICostanti.SDI_VERSIONI_FATTURA.contains(versioneFattura)==false){
  133.                     throw new Exception("Versione fornita ["+versioneFattura+"] non supportata (indicare una delle seguenti versioni: "+SDICostanti.SDI_VERSIONI_FATTURA+")");
  134.                 }
  135.                                 
  136.                 // nomeFileFattura
  137.                 String tipoFileFattura = null;
  138.                 if(msg.getTransportRequestContext()!=null){
  139.                     tipoFileFattura =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_TIPO_FILE);
  140.                     if(tipoFileFattura==null){
  141.                         tipoFileFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_TIPO_FILE_1);
  142.                     }
  143.                     if(tipoFileFattura==null){
  144.                         tipoFileFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_TIPO_FILE_2);
  145.                     }
  146.                 }
  147.                 if(tipoFileFattura==null){
  148.                     //throw new Exception("TipoFileFattura non fornito");
  149.                     // Bug Fix: OP-752
  150.                     // forzo xml che gestiro' comunque come attachment
  151.                     tipoFileFattura = SDICostanti.SDI_TIPO_FATTURA_XML;
  152.                 }
  153.                 if(SDICostanti.SDI_TIPO_FATTURA_XML.equalsIgnoreCase(tipoFileFattura)){
  154.                     tipoInvioFattura = SDICostanti.SDI_TIPO_FATTURA_XML;
  155.                 }
  156.                 else if(SDICostanti.SDI_TIPO_FATTURA_ZIP.equalsIgnoreCase(tipoFileFattura)){
  157.                     tipoInvioFattura = SDICostanti.SDI_TIPO_FATTURA_ZIP;
  158.                 }
  159.                 else if(SDICostanti.SDI_TIPO_FATTURA_P7M.equalsIgnoreCase(tipoFileFattura)){
  160.                     tipoInvioFattura = SDICostanti.SDI_TIPO_FATTURA_P7M;
  161.                 }
  162.                 else{
  163.                     throw new Exception("TipoFileFattura fornito non supportato: "+tipoInvioFattura);
  164.                 }
  165.                 
  166.                 // idPaese
  167.                 if(msg.getTransportRequestContext()!=null){
  168.                     idPaese =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_ID_PAESE);
  169.                     if(idPaese==null){
  170.                         idPaese =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_ID_PAESE_1);
  171.                     }
  172.                     if(idPaese==null){
  173.                         idPaese =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_ID_PAESE_2);
  174.                     }
  175.                 }
  176.                 if(idPaese==null){
  177.                     if(!SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  178.                         throw new Exception("IdPaese non fornito");
  179.                     }
  180.                 }
  181.                 
  182.                 // idCodice
  183.                 if(msg.getTransportRequestContext()!=null){
  184.                     idCodice =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_ID_CODICE);
  185.                     if(idCodice==null){
  186.                         idCodice =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_ID_CODICE_1);
  187.                     }
  188.                     if(idCodice==null){
  189.                         idCodice =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_ID_CODICE_2);
  190.                     }
  191.                 }
  192.                 if(idCodice==null){
  193.                     if(!SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  194.                         throw new Exception("IdCodice non fornito");
  195.                     }
  196.                 }
  197.                 
  198.                 if(msg.countAttachments()<=0){
  199.                     throw new Exception("Atteso fattura come attachment");
  200.                 }
  201.                 AttachmentPart ap = (AttachmentPart) msg.getAttachments().next();
  202.                 fatturaAllegata = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  203.             }
  204.             else{
  205.                 
  206.                 tipoInvioFattura = SDICostanti.SDI_TIPO_FATTURA_XML;
  207.                 
  208.                 // versioneFattura
  209.                 if(msg.getTransportRequestContext()!=null){
  210.                     versioneFattura =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_VERSIONE_FATTURA);
  211.                     if(versioneFattura==null){
  212.                         versioneFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_VERSIONE_FATTURA_1);
  213.                     }
  214.                     if(versioneFattura==null){
  215.                         versioneFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_VERSIONE_FATTURA_2);
  216.                     }
  217.                 }
  218.                 if(versioneFattura==null){
  219.                     if(it.gov.fatturapa.sdi.fatturapa.v1_0.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  220.                         versioneFattura = SDICostanti.SDI_VERSIONE_FATTURA_PA_10;
  221.                     }
  222.                     else if(it.gov.fatturapa.sdi.fatturapa.v1_1.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  223.                         versioneFattura = SDICostanti.SDI_VERSIONE_FATTURA_PA_11;
  224.                     }
  225.                     else if(it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  226.                         versioneFattura = SDICostanti.SDI_VERSIONE_FATTURA_SEMPLIFICATA_10;
  227.                     }
  228.                     else{
  229.                         // non e' possibile capire la versione dal namespace, la versione 1.2 contiene due versioni interne, una per private ed una per PA
  230.                         throw new Exception("Versione non fornita (indicare una delle seguenti versioni: "+SDICostanti.SDI_VERSIONI_FATTURA+")");
  231.                     }
  232.                 }
  233.                 else{
  234.                     if(SDICostanti.SDI_VERSIONI_FATTURA.contains(versioneFattura)==false){
  235.                         throw new Exception("Versione fornita ["+versioneFattura+"] non supportata (indicare una delle seguenti versioni: "+SDICostanti.SDI_VERSIONI_FATTURA+")");
  236.                     }
  237.                     // check in accordo alla versione
  238.                     if(SDICostanti.SDI_VERSIONE_FATTURA_PA_10.equals(versioneFattura)){
  239.                         if(!it.gov.fatturapa.sdi.fatturapa.v1_0.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  240.                             throw new Exception("Versione fornita ["+versioneFattura+"] non è utilizzabile con la fattura fornita che appartiene ad una differente versione di namespace ["+fatturaSOAPElement.getNamespaceURI()+"]");
  241.                         }
  242.                     }
  243.                     else if(SDICostanti.SDI_VERSIONE_FATTURA_PA_11.equals(versioneFattura)){
  244.                         if(!it.gov.fatturapa.sdi.fatturapa.v1_1.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  245.                             throw new Exception("Versione fornita ["+versioneFattura+"] non è utilizzabile con la fattura fornita che appartiene ad una differente versione di namespace ["+fatturaSOAPElement.getNamespaceURI()+"]");
  246.                         }
  247.                     }
  248.                     else if(SDICostanti.SDI_VERSIONE_FATTURA_SEMPLIFICATA_10.equals(versioneFattura)){
  249.                         if(!it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  250.                             throw new Exception("Versione fornita ["+versioneFattura+"] non è utilizzabile con la fattura fornita che appartiene ad una differente versione di namespace ["+fatturaSOAPElement.getNamespaceURI()+"]");
  251.                         }
  252.                     }
  253.                     else{
  254.                         if(!it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.utils.ProjectInfo.getInstance().getProjectNamespace().equals(fatturaSOAPElement.getNamespaceURI())){
  255.                             throw new Exception("Versione fornita ["+versioneFattura+"] non è utilizzabile con la fattura fornita che appartiene ad una differente versione di namespace ["+fatturaSOAPElement.getNamespaceURI()+"]");
  256.                         }
  257.                     }
  258.                 }
  259.                 
  260.             }
  261.             
  262.             // NomeFileFattura da spedire
  263.             String nomeFileFatturaDaSpedire = null;
  264.             boolean readNomeFromTrasporto = false;
  265.             if( (!this.sdiProperties.isEnable_fatturazioneAttiva_generazioneNomeFileFattura()) || this.sdiProperties.isEnable_fatturazioneAttiva_generazioneNomeFileFatturaOpzionale()) {
  266.                 readNomeFromTrasporto = true;
  267.             }
  268.             if(readNomeFromTrasporto) {
  269.                 if(msg.getTransportRequestContext()!=null){
  270.                     nomeFileFatturaDaSpedire =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_URLBASED_NOME_FILE);
  271.                     if(nomeFileFatturaDaSpedire==null){
  272.                         nomeFileFatturaDaSpedire =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_NOME_FILE_1);
  273.                     }
  274.                     if(nomeFileFatturaDaSpedire==null){
  275.                         nomeFileFatturaDaSpedire =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviFile.RICEVI_FILE_INTEGRAZIONE_TRASPORTO_NOME_FILE_2);
  276.                     }
  277.                 }
  278.                 if(nomeFileFatturaDaSpedire==null && (!this.sdiProperties.isEnable_fatturazioneAttiva_generazioneNomeFileFattura()) ){
  279.                     throw new Exception("Nome file fattura non fornito");
  280.                 }
  281.             }
  282.             
  283.             
  284.             // Add Property in Busta
  285.             busta.addProperty(SDICostanti.SDI_BUSTA_EXT_FORMATO_ARCHIVIO_INVIO_FATTURA, tipoInvioFattura);
  286.             busta.addProperty(SDICostanti.SDI_BUSTA_EXT_VERSIONE_FATTURA_PA, versioneFattura);
  287.             

  289.             
  290.             // Leggo Fattura
  291.             byte[]fatturaBytes = fatturaAllegata;
  292.             if(fatturaBytes==null && SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  293.                 try{
  294.                     fatturaBytes = xmlUtils.toByteArray(fatturaSOAPElement);
  295.                 }catch(Exception e){
  296.                     throw new Exception("Fattura non valida: "+e.getMessage(),e);
  297.                 }
  298.             }
  299.             
  300.             
  301.             
  302.             // effettuo validazione del messaggio ricevuto
  303.             if(this.sdiProperties.isEnableValidazioneXsdFatturaDaInviare()){
  304.                 AbstractValidatoreXSD validatore = null;
  305.                 try{            
  306.                     if(SDICostanti.SDI_VERSIONE_FATTURA_PA_10.equals(versioneFattura)){
  307.                         validatore = it.gov.fatturapa.sdi.fatturapa.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  308.                     }
  309.                     else if(SDICostanti.SDI_VERSIONE_FATTURA_PA_11.equals(versioneFattura)){
  310.                         validatore = it.gov.fatturapa.sdi.fatturapa.v1_1.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  311.                     }
  312.                     else if(SDICostanti.SDI_VERSIONE_FATTURA_SEMPLIFICATA_10.equals(versioneFattura)){
  313.                         validatore = it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  314.                     }
  315.                     else{
  316.                         validatore = it.gov.agenziaentrate.ivaservizi.docs.xsd.fatture.v1_2.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  317.                     }
  318.                 }catch(Exception e){
  319.                     throw new Exception("Inizializzazione schema per validazione fattura non riuscita: "+e.getMessage(),e);
  320.                 }
  321.                 if(SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  322.                     try{
  323.                         // Fix Validazione versione
  324.                         // axiom non funziona
  325.     //                  Attr attr = fatturaSOAPElement.getAttributeNode("versione");
  326.     //                  if(attr!=null){
  327.     //                      fatturaSOAPElement.removeAttributeNode(attr);
  328.     //                      Node nAttr = soapPart.createAttributeNS(null, "versione");
  329.     //                      nAttr.setNodeValue(attr.getNodeValue());
  330.     //                      if(fatturaSOAPElement.getAttributes()!=null){
  331.     //                          fatturaSOAPElement.getAttributes().setNamedItem(nAttr);
  332.     //                      }
  333.     //                  }
  334.     //                  validatore.valida(fatturaSOAPElement);
  335.                         
  336.                         validatore.valida(new ByteArrayInputStream(fatturaBytes));
  337.                         
  338.                     }catch(Exception e){
  339.                         throw new Exception("Fattura non valida: "+e.getMessage(),e);
  340.                     }
  341.                 }else{
  342.                     // TODO: capirlo aprendo lo zip o ignorarlo per p7m
  343.                 }
  344.             }
  345.             
  346.             
  347.             // Leggo Fattura
  348.             if(SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  349.                 try{
  350.                     List<Eccezione> erroriValidazione = new ArrayList<>();
  351.                     boolean forceDisableValidazioneXsd = true; // la validazione se abilitata e' stata fatta prima
  352.                     SDIFatturaUtils.validazioneFattura(fatturaBytes,this.sdiProperties,
  353.                             erroriValidazione,
  354.                             this.sdiUtils,protocolFactory,
  355.                             busta,msg,false,false,forceDisableValidazioneXsd);
  356.                     if(erroriValidazione!=null && erroriValidazione.size()>0){
  357.                         StringBuilder bf = new StringBuilder();
  358.                         for(int k=0; k<erroriValidazione.size();k++){
  359.                             Eccezione error = erroriValidazione.get(k);
  360.                             try{
  361.                                 bf.append("Processamento["+this.sdiTraduttore.toString(error.getCodiceEccezione(),error.getSubCodiceEccezione())+
  362.                                         "] "+error.getDescrizione(protocolFactory)+"\n");
  363.                             }catch(Exception e){
  364.                                 protocolFactory.getLogger().error("getDescrizione Error:"+e.getMessage(),e);
  365.                             }
  366.                         }
  367.                         throw new Exception(bf.toString());
  368.                     }
  369.                 }catch(Exception e){
  370.                     throw new Exception("Fattura non valida: "+e.getMessage(),e);
  371.                 }
  372.             }else{
  373.                 // TODO: capirlo aprendo lo zip o ignorarlo per p7m
  374.             }
  375.             
  376.             
  377.             // Costruisco Messaggio Protocollo
  378.             it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.ObjectFactory of = new it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.ObjectFactory();
  379.             it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.FileSdIBaseType fileSdi = new it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.FileSdIBaseType();
  380.             fileSdi.setFile(fatturaBytes);
  381.             if(nomeFileFatturaDaSpedire==null && this.sdiProperties.isEnable_fatturazioneAttiva_generazioneNomeFileFattura()) {
  382.                 if(SDICostanti.SDI_TIPO_FATTURA_XML.equals(tipoInvioFattura)){
  383.                     fileSdi.setNomeFile(SDIUtils.getNomeFileFattura(protocolFactory, state, 
  384.                             idPaese!=null ? idPaese : busta.getProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_PAESE),
  385.                             idCodice!=null ? idCodice : busta.getProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_CODICE),
  386.                             tipoInvioFattura));
  387.                 }else{
  388.                     fileSdi.setNomeFile(SDIUtils.getNomeFileFattura(protocolFactory, state, 
  389.                             idPaese,
  390.                             idCodice,
  391.                             tipoInvioFattura));
  392.                 }
  393.             }
  394.             else {
  395.                 if(nomeFileFatturaDaSpedire==null) {
  396.                     throw new Exception("Nome file fattura non fornito");
  397.                 }
  398.                 fileSdi.setNomeFile(nomeFileFatturaDaSpedire);
  399.             }
  400.             if(idPaese!=null && !"".equals(idPaese)) {
  401.                 if(!busta.existsProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_PAESE)) {
  402.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_PAESE, idPaese);
  403.                 }
  404.             }
  405.             if(idCodice!=null && !"".equals(idCodice)) {
  406.                 if(!busta.existsProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_CODICE)) {
  407.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_TRASMITTENTE_ID_CODICE, idCodice);
  408.                 }
  409.             }
  410.             
  411.             // detach body
  412.             soapBody.removeContents();
  413.             
  414.             // se sono presenti degli attachments li elimino
  415.             if(msg.countAttachments()>0){
  416.                 msg.removeAllAttachments();
  417.             }
  418.             
  419.             // add MessaggioProtocollo
  420.             it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.ws.trasmissione.v1_0.types.utils.serializer.JaxbSerializer();
  421.             String xmlRichiesta = serializer.toString(of.createFileSdIAccoglienza(fileSdi));
  422.             SOAPElement element = SoapUtils.getSoapFactory(messageFactory, msg.getMessageType()).createElement(xmlUtils.newElement(xmlRichiesta.getBytes()));
  423.             soapBody.addChildElement(element);
  424.             
  425.             // salvo nomeFile
  426.             busta.addProperty(SDICostanti.SDI_BUSTA_EXT_NOME_FILE, fileSdi.getNomeFile());
  427.             
  428.             // soapAction
  429.             msg.setSoapAction(SDICostantiServizioRiceviFile.SDI_SOAP_ACTION_SERVIZIO_RICEVI_FILE_AZIONE_RICEVI_FILE);
  430.             
  431.             return SDIUtils.readHeader(msg); // l'header ritornato viene usato solo per il tracciamento e cosi' facendo viene ripulito
  432.             
  433.         }catch(Exception e){
  434.             throw new ProtocolException(e.getMessage(),e);
  435.         }
  436.         
  437.     }
  438.     
  439.     public SOAPElement creaRisposta_ServizioRicezioneFatture_AzioneRiceviFatture(IProtocolFactory<?> protocolFactory, IState state, Busta busta, OpenSPCoop2Message msgParam) throws ProtocolException{
  440.         
  441.         try{
  442.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  443.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  444.             MessageXMLUtils xmlUtils = MessageXMLUtils.getInstance(messageFactory);
  445.             
  446.             // create body
  447.             SOAPPart soapPart = msg.getSOAPPart();
  448.             SOAPBody soapBody = msg.getSOAPBody();
  449.             if(soapBody==null){
  450.                 soapBody = soapPart.getEnvelope().addBody();
  451.             }
  452.             else{
  453.                 if(soapBody.hasFault()){
  454.                     return null; // vi e' stato un errore in fase di consegna
  455.                 }
  456.             }
  457.             
  458.             // detach body
  459.             soapBody.removeContents();
  460.             
  461.             // se sono presenti degli attachments li elimino
  462.             if(msg.countAttachments()>0){
  463.                 msg.removeAllAttachments();
  464.             }
  465.             
  466.             // imposto content type
  467.             msg.setContentType(MessageUtilities.getDefaultContentType(msg.getMessageType()));
  468.             
  469.             // add MessaggioProtocollo
  470.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.ObjectFactory of = new it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.ObjectFactory();
  471.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.RispostaRiceviFattureType rispostaRiceviFatture = of.createRispostaRiceviFattureType();
  472.             rispostaRiceviFatture.setEsito(it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.constants.EsitoRicezioneType.ER01);
  473.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.utils.serializer.JaxbSerializer();
  474.             String xmlRisposta = serializer.toString(of.createRispostaRiceviFatture(rispostaRiceviFatture));
  475.             SOAPElement element = SoapUtils.getSoapFactory(messageFactory, msg.getMessageType()).createElement(xmlUtils.newElement(xmlRisposta.getBytes()));
  476.             soapBody.addChildElement(element);
  477.             
  478.             return element; // non vi sono base64
  479.                         
  480.         }catch(Exception e){
  481.             throw new ProtocolException(e.getMessage(),e);
  482.         }
  483.         
  484.     }
  485.     
  486.     public SOAPElement creaRichiesta_ServizioSdIRiceviNotifica_AzioneNotificaEsito(IProtocolFactory<?> protocolFactory, IState state, Busta busta, OpenSPCoop2Message msgParam,
  487.             boolean isEnableGenerazioneMessaggiCompatibilitaNamespaceSenzaGov,
  488.             boolean isEnableValidazioneMessaggiCompatibilitaNamespaceSenzaGov) throws ProtocolException{
  489.         
  490.         try{
  491.             OpenSPCoop2SoapMessage msg = msgParam.castAsSoap();
  492.             OpenSPCoop2MessageFactory messageFactory = msgParam.getFactory();
  493.             MessageXMLUtils xmlUtils = MessageXMLUtils.getInstance(messageFactory);
  494.         
  495.             // create body
  496.             SOAPPart soapPart = msg.getSOAPPart();
  497.             SOAPBody soapBody = msg.getSOAPBody();
  498.             if(soapBody==null){
  499.                 soapBody = soapPart.getEnvelope().addBody();
  500.             }
  501.             
  502.             // nomeFileFattura
  503.             String nomeFileFattura = null;
  504.             if(msg.getTransportRequestContext()!=null){
  505.                 nomeFileFattura =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_URLBASED_NOME_FILE);
  506.                 if(nomeFileFattura==null){
  507.                     nomeFileFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_TRASPORTO_NOME_FILE_1);
  508.                 }
  509.                 if(nomeFileFattura==null){
  510.                     nomeFileFattura =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_TRASPORTO_NOME_FILE_2);
  511.                 }
  512.             }
  513.             if(nomeFileFattura==null){
  514.                 if(this.sdiProperties.isEnable_fatturazionePassiva_generazioneNomeFileEsito()) {
  515.                     throw new Exception("Nome File Fattura non fornito");
  516.                 }
  517.                 else {
  518.                     throw new Exception("Nome File Esito non fornito");
  519.                 }
  520.             }
  521.             
  522.             // identificativoSdi
  523.             String identificativoSdi = null;
  524.             String tmpIdentificativoSdi = null;
  525.             if(msg.getTransportRequestContext()!=null){
  526.                 tmpIdentificativoSdi =  msg.getTransportRequestContext().getParameterFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_URLBASED_IDENTIFICATIVO_SDI);
  527.                 if(tmpIdentificativoSdi==null){
  528.                     tmpIdentificativoSdi =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_TRASPORTO_IDENTIFICATIVO_SDI_1);
  529.                 }
  530.                 if(tmpIdentificativoSdi==null){
  531.                     tmpIdentificativoSdi =  msg.getTransportRequestContext().getHeaderFirstValue(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_INTEGRAZIONE_TRASPORTO_IDENTIFICATIVO_SDI_2);
  532.                 }
  533.             }
  534.             boolean accessoNotificaDaInviare = this.sdiProperties.isEnableAccessoNotificaDaInviare();
  535.             if(tmpIdentificativoSdi==null && !accessoNotificaDaInviare){
  536.                 throw new Exception("IdentificativoSdi non fornito");
  537.             }
  538.             if(tmpIdentificativoSdi!=null) {
  539.                 try {
  540.                     if(this.sdiProperties.isEnable_InputIdSDIValidationAsBigInteger_NotificaDaInviare()) {
  541.                         BigInteger bigInteger = new BigInteger(tmpIdentificativoSdi);
  542.                         String s = bigInteger.toString();
  543.                         if(s!=null) {
  544.                             // validazione superata
  545.                         }
  546.                     }
  547.                     identificativoSdi = tmpIdentificativoSdi;
  548.                 }catch(Exception e) {
  549.                     throw new Exception("IdentificativoSdi fornito non possiede un valore valido: "+e.getMessage());
  550.                 }
  551.             }
  552.             
  553.             // childElement
  554.             List<SOAPElement> childs = SoapUtils.getNotEmptyChildSOAPElement(soapBody);
  555.             if(childs==null || childs.size()<=0){
  556.                 throw new Exception("Notifica di Esito Committente non presente");
  557.             }
  558.             if(childs.size()>1){
  559.                 throw new Exception("Sono presenti piu' elementi xml. Deve essere fornita una singola Notifica di Esito Committente");
  560.             }
  561.             SOAPElement notificaEsitoCommittenteSOAPElement = childs.get(0);
  562.             
  563.             byte[]notificaEsitoCommittenteBytes = null;
  564.             if(Costanti.SOAP_TUNNEL_NAMESPACE.equals(notificaEsitoCommittenteSOAPElement.getNamespaceURI())){
  565.                 if(msg.countAttachments()<=0){
  566.                     throw new Exception("Attesa notifica come attachment");
  567.                 }
  568.                 AttachmentPart ap = (AttachmentPart) msg.getAttachments().next();
  569.                 notificaEsitoCommittenteBytes = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  570.             }
  571.             else {
  572.                 notificaEsitoCommittenteBytes = xmlUtils.toByteArray(notificaEsitoCommittenteSOAPElement);
  573.             }
  574.             // effettuo validazione del messaggio ricevuto
  575.             byte [] notificaEsitoCommittenteBytesCompatibilitaSenzaGov = notificaEsitoCommittenteBytes;
  576.             try{
  577.                 // Fix Validazione versione
  578. //              Attr attr = notificaEsitoCommittenteSOAPElement.getAttributeNode("versione");
  579. //              if(attr!=null){
  580. //                  notificaEsitoCommittenteSOAPElement.removeAttributeNode(attr);
  581. //                  Node nAttr = soapPart.createAttributeNS(null, "versione");
  582. //                  nAttr.setNodeValue(attr.getNodeValue());
  583. //                  if(notificaEsitoCommittenteSOAPElement.getAttributes()!=null){
  584. //                      notificaEsitoCommittenteSOAPElement.getAttributes().setNamedItem(nAttr);
  585. //                  }
  586. //              }               
  587. //              AbstractValidatoreXSD validatore = it.gov.fatturapa.sdi.messaggi.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  588. //              validatore.valida(notificaEsitoCommittenteSOAPElement);
  589.                 
  590.                 // effettuo validazione con bytes, per ovviare al problema del namespace 'gov'
  591.                 if(isEnableValidazioneMessaggiCompatibilitaNamespaceSenzaGov){
  592.                     notificaEsitoCommittenteBytesCompatibilitaSenzaGov = SDICompatibilitaNamespaceErrati.convertiXmlNamespaceSenzaGov(protocolFactory.getLogger(), notificaEsitoCommittenteBytes);
  593.                 }
  594.                 
  595.                 // validazione
  596.                 if(this.sdiProperties.isEnableValidazioneXsdNotificaDaInviare()){
  597.                     AbstractValidatoreXSD validatore = it.gov.fatturapa.sdi.messaggi.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(this.bustaBuilder.getProtocolFactory().getLogger());
  598.                     validatore.valida(new ByteArrayInputStream(notificaEsitoCommittenteBytesCompatibilitaSenzaGov));
  599.                 }
  600.                 
  601.             }catch(Exception e){
  602.                 throw new Exception("Notifica di Esito Committente non valida: "+e.getMessage(),e);
  603.             }
  604.             
  605.             // Leggo NotificaEsitoCommittente
  606.             it.gov.fatturapa.sdi.messaggi.v1_0.NotificaEsitoCommittenteType notificaEsitoCommittente = null;
  607.             if(accessoNotificaDaInviare) {
  608.                 try{
  609.                     // fatto prima in validazion: notificaEsitoCommittenteBytes = this.xmlUtils.toByteArray(notificaEsitoCommittenteSOAPElement);
  610.                     it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer deserializer = new 
  611.                             it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer();
  612.                     notificaEsitoCommittente = deserializer.readNotificaEsitoCommittenteType(notificaEsitoCommittenteBytesCompatibilitaSenzaGov);
  613.                 }catch(Exception e){
  614.                     throw new Exception("Notifica di Esito Committente non valida: "+e.getMessage(),e);
  615.                 }
  616.             
  617.             
  618.                 // Aggiunto info alla busta
  619.                 
  620.                 // Esito.IdentificativoSdI
  621.                 if(notificaEsitoCommittente.getIdentificativoSdI()!=null){
  622.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, notificaEsitoCommittente.getIdentificativoSdI().toString());
  623.                     identificativoSdi = notificaEsitoCommittente.getIdentificativoSdI();
  624.                 }           
  625.                 // Esito.RiferimentoFattura
  626.                 if(notificaEsitoCommittente.getRiferimentoFattura()!=null){
  627.                     if(notificaEsitoCommittente.getRiferimentoFattura().getAnnoFattura()!=null){
  628.                         busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_ANNO, notificaEsitoCommittente.getRiferimentoFattura().getAnnoFattura().toString());
  629.                     }
  630.                     if(notificaEsitoCommittente.getRiferimentoFattura().getNumeroFattura()!=null){
  631.                         busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_NUMERO, notificaEsitoCommittente.getRiferimentoFattura().getNumeroFattura());
  632.                     }
  633.                     if(notificaEsitoCommittente.getRiferimentoFattura().getPosizioneFattura()!=null){
  634.                         busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_POSIZIONE, notificaEsitoCommittente.getRiferimentoFattura().getPosizioneFattura().toString());
  635.                     }
  636.                 }           
  637.                 // Esito.Esito
  638.                 if(notificaEsitoCommittente.getEsito()!=null){
  639.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_ESITO, notificaEsitoCommittente.getEsito().name());
  640.                 }               
  641.                 // Esito.Descrizione
  642.                 if(notificaEsitoCommittente.getDescrizione()!=null){
  643.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_DESCRIZIONE, notificaEsitoCommittente.getDescrizione());
  644.                 }   
  645.                 // Esito.MessageId
  646.                 if(notificaEsitoCommittente.getMessageIdCommittente()!=null){
  647.                     busta.addProperty(SDICostanti.SDI_BUSTA_EXT_MESSAGE_ID_COMMITTENTE, notificaEsitoCommittente.getMessageIdCommittente());
  648.                 }
  649.                 
  650.                 if(identificativoSdi==null){
  651.                     throw new Exception("IdentificativoSdi non fornito nella notifica da inviare");
  652.                 }
  653.             }
  654.                     
  655.             
  656.             // Costruisco Messaggio Protocollo
  657.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.ObjectFactory of = new it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.ObjectFactory();
  658.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.FileSdIType fileSdi = new it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.FileSdIType();
  659.             byte [] fileSent = notificaEsitoCommittenteBytes;
  660.             if(isEnableGenerazioneMessaggiCompatibilitaNamespaceSenzaGov){
  661.                 fileSent = SDICompatibilitaNamespaceErrati.produciXmlNamespaceSenzaGov(protocolFactory.getLogger(), fileSent);
  662.             }
  663.             fileSdi.setFile(fileSent);
  664.             fileSdi.setIdentificativoSdI(identificativoSdi);
  665.             if(this.sdiProperties.isEnable_fatturazionePassiva_generazioneNomeFileEsito()) {
  666.                 // Se è abilitata la genereazione del nome dell'esito su GovWay, il client DEVE fornire il nome della fattura originale su cui manda l'esito
  667.                 busta.addProperty(SDICostanti.SDI_BUSTA_EXT_NOME_FILE_FATTURA, nomeFileFattura);
  668.                 fileSdi.setNomeFile(SDIUtils.getNomeFileMessaggi(protocolFactory, state, nomeFileFattura, TipiMessaggi.EC));
  669.             }
  670.             else {
  671.                 // Se non è abilitata la genereazione del nome dell'esito su GovWay, il client DEVE fornire il nome del file corrispondente all'esito.
  672.                 fileSdi.setNomeFile(nomeFileFattura);
  673.             }
  674.             
  675.             // salvo informazioni
  676.             busta.addProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, identificativoSdi+"");
  677.             busta.addProperty(SDICostanti.SDI_BUSTA_EXT_NOME_FILE, fileSdi.getNomeFile());
  678.             
  679.             // detach body
  680.             soapBody.removeContents();
  681.             
  682.             // se sono presenti degli attachments li elimino
  683.             if(msg.countAttachments()>0){
  684.                 msg.removeAllAttachments();
  685.             }
  686.             
  687.             // add MessaggioProtocollo
  688.             it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.utils.serializer.JaxbSerializer serializer = new it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.utils.serializer.JaxbSerializer();
  689.             String xmlRichiesta = serializer.toString(of.createFileSdI(fileSdi));
  690.             SOAPElement element = SoapUtils.getSoapFactory(messageFactory, msg.getMessageType()).createElement(xmlUtils.newElement(xmlRichiesta.getBytes()));
  691.             soapBody.addChildElement(element);
  692.             
  693.             // soapAction
  694.             msg.setSoapAction(SDICostantiServizioRiceviNotifica.SDI_SOAP_ACTION_SERVIZIO_NOTIFICA_ESITO_AZIONE_NOTIFICA_ESITO);
  695.                 
  696.             return SDIUtils.readHeader(msg); // l'header ritornato viene usato solo per il tracciamento e cosi' facendo viene ripulito
  697.             
  698.         }catch(Exception e){
  699.             throw new ProtocolException(e.getMessage(),e);
  700.         }
  701.         
  702.     }
  703. }
Created with JaCoCo 0.8.8.202204050719