SDIValidatoreServizioRiceviNotifica.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.validator;

  22. import java.io.ByteArrayInputStream;
  23. import java.util.Iterator;
  24. import java.util.List;

  26. import javax.xml.namespace.QName;
  27. import javax.xml.soap.AttachmentPart;
  28. import javax.xml.soap.SOAPElement;

  30. import org.openspcoop2.message.OpenSPCoop2Message;
  31. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  32. import org.openspcoop2.message.soap.SoapUtils;
  33. import org.openspcoop2.message.soap.mtom.MTOMUtilities;
  34. import org.openspcoop2.protocol.sdi.config.SDIProperties;
  35. import org.openspcoop2.protocol.sdi.constants.SDICostanti;
  36. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviNotifica;
  37. import org.openspcoop2.protocol.sdi.utils.SDICompatibilitaNamespaceErrati;
  38. import org.openspcoop2.protocol.sdk.Busta;
  39. import org.openspcoop2.protocol.sdk.Eccezione;
  40. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  41. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  42. import org.openspcoop2.utils.Utilities;
  43. import org.openspcoop2.utils.io.Base64Utilities;
  44. import org.openspcoop2.utils.xml.AbstractValidatoreXSD;
  45. import org.w3c.dom.Element;

  47. import it.gov.fatturapa.sdi.messaggi.v1_0.NotificaEsitoCommittenteType;
  48. import it.gov.fatturapa.sdi.messaggi.v1_0.ScartoEsitoCommittenteType;
  49. import it.gov.fatturapa.sdi.messaggi.v1_0.constants.TipiMessaggi;
  50. import it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.constants.EsitoNotificaType;
  51. import it.gov.fatturapa.sdi.ws.ricezione.v1_0.types.utils.ProjectInfo;

  53. /**
  54.  * SDIValidatoreServizioRiceviNotifica
  55.  * 
  56.  * @author Andrea Poli (apoli@link.it)
  57.  * @author $Author$
  58.  * @version $Rev$, $Date$
  59.  */
  60. public class SDIValidatoreServizioRiceviNotifica {

  62.     private SDIValidazioneSintattica sdiValidazioneSintattica;
  63.     private SDIValidazioneSemantica sdiValidazioneSemantica;
  64.     private OpenSPCoop2Message msg;
  65.     private OpenSPCoop2MessageFactory messageFactory;
  66.     private boolean isRichiesta;
  67.     private SOAPElement sdiMessage;
  68.     private String namespace;
  69.     private Busta busta;
  70.         
  71.     
  72.     public SDIValidatoreServizioRiceviNotifica(SDIValidazioneSintattica sdiValidazioneSintattica,
  73.             OpenSPCoop2Message msg,boolean isRichiesta,
  74.             SOAPElement sdiMessage,Busta busta){
  75.         this.sdiValidazioneSintattica = sdiValidazioneSintattica;
  76.         this.msg = msg;
  77.         this.messageFactory = this.msg!=null ? this.msg.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  78.         this.isRichiesta = isRichiesta;
  79.         this.sdiMessage = sdiMessage;
  80.         this.namespace = ProjectInfo.getInstance().getProjectNamespace();
  81.         this.busta = busta;
  82.     }
  83.     public SDIValidatoreServizioRiceviNotifica(SDIValidazioneSemantica sdiValidazioneSemantica,
  84.             OpenSPCoop2Message msg,boolean isRichiesta,
  85.             SOAPElement sdiMessage,Busta busta){
  86.         this.sdiValidazioneSemantica = sdiValidazioneSemantica;
  87.         this.msg = msg;
  88.         this.messageFactory = this.msg!=null ? this.msg.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  89.         this.isRichiesta = isRichiesta;
  90.         this.sdiMessage = sdiMessage;
  91.         this.namespace = SDICostantiServizioRiceviNotifica.SDI_SERVIZIO_RICEVI_NOTIFICA_NAMESPACE;
  92.         this.busta = busta;
  93.     }
  94.     
  95.     private boolean checkServiceNamespace() throws Exception{
  96.         if(this.namespace.equals(this.sdiMessage.getNamespaceURI())==false){
  97.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  98.                     "Namespace ["+this.sdiMessage.getNamespaceURI()+"] differente da quello atteso ["+this.namespace+"]"));
  99.             return false;   
  100.         }
  101.         return true;
  102.     }
  103.     
  104.     
  105.     
  106.     /* ***** validaNotificaEsito ***** */
  107.         
  108.     public void validaNotificaEsito() throws Exception{
  109.         
  110.         if(checkServiceNamespace()==false){
  111.             return;
  112.         }
  113.         
  114.         if(this.sdiValidazioneSintattica!=null){
  115.             if(this.isRichiesta){
  116.                 this._validazioneSintattica_NotificaEsito_richiesta();
  117.             }
  118.             else{
  119.                 this._validazioneSintattica_NotificaEsito_risposta();
  120.             }
  121.         }
  122.         else{
  123.             if(this.isRichiesta){
  124.                 this._validazioneSemantica_NotificaEsito_richiesta();
  125.             }
  126.             else{
  127.                 this._validazioneSemantica_NotificaEsito_risposta();
  128.             }
  129.         }
  130.         
  131.     }
  132.     private void _validazioneSintattica_NotificaEsito_richiesta() throws Exception{
  133.         
  134.         if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ROOT_ELEMENT.equals(this.sdiMessage.getLocalName())==false){
  135.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  136.                     "LocalName ["+this.sdiMessage.getLocalName()+"] differente da quello atteso ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ROOT_ELEMENT+"]"));
  137.             return; 
  138.         }
  139.         
  140.         List<SOAPElement> elementChilds = SoapUtils.getNotEmptyChildSOAPElement(this.sdiMessage);
  141.         if(elementChilds==null || elementChilds.size()<=0){
  142.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  143.                     "RootElement [{"+this.namespace+"}"+this.sdiMessage.getLocalName()+"] non contiene elementi"));
  144.             return; 
  145.         }
  146.         
  147.         String identificativoSdI = null;
  148.         String nomeFile = null;
  149.         Boolean fileRead = null;
  150.         for (int i = 0; i < elementChilds.size(); i++) {
  151.             SOAPElement child = elementChilds.get(i);
  152.     
  153.             if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_IDENTIFICATIVO_SDI.equals(child.getLocalName())){
  154.                 if(identificativoSdI!=null){
  155.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  156.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_PRESENTE_PIU_VOLTE));
  157.                     return; 
  158.                 }
  159.                 if(child.getTextContent()==null){
  160.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  161.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_VALORIZZATO));
  162.                     return; 
  163.                 }
  164.                 identificativoSdI = child.getTextContent();
  165.             }
  166.             else if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_NOME_FILE.equals(child.getLocalName())){
  167.                 if(nomeFile!=null){
  168.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  169.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  170.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_NOME_FILE+"] presente piu' volte"));
  171.                     return; 
  172.                 }
  173.                 if(child.getTextContent()==null){
  174.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  175.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  176.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_NOME_FILE+"] non valorizzato"));
  177.                     return; 
  178.                 }
  179.                 nomeFile = child.getTextContent();
  180.             }
  181.             else if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE.equals(child.getLocalName())){
  182.                 if(fileRead!=null){
  183.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  184.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  185.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] presente piu' volte"));
  186.                     return; 
  187.                 }
  188.                 // Il contenuto viene gestito nella validazione semantica (poiche' deve essere applicata la sicurezza per la firma)
  189.                 fileRead = true;
  190.             }
  191.             else{
  192.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  193.                         "Element ["+child.getLocalName()+"] sconosciuto"));
  194.                 return; 
  195.             }
  196.             
  197.             if(child.getNamespaceURI()!=null){
  198.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  199.                         "Element ["+child.getLocalName()+"] appartiene al namespace ("+child.getNamespaceURI()+"). Era atteso un elemento senza namespace"));
  200.                 return; 
  201.             }
  202.         }
  203.         if(identificativoSdI==null){
  204.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  205.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_PRESENTE));
  206.             return; 
  207.         }
  208.         if(nomeFile==null){
  209.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  210.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  211.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_NOME_FILE+"] non presente"));
  212.             return; 
  213.         }
  214.         if(fileRead==null){
  215.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  216.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  217.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] non presente"));
  218.             return; 
  219.         }
  220.         
  221.         // nomeFile
  222.         try{
  223.             SDIValidatoreNomeFile.validaNomeFileMessaggi(nomeFile, TipiMessaggi.EC);
  224.         }catch(Exception e){
  225.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  226.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  227.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_NOME_FILE+"] non valido: "+e.getMessage(),e,
  228.                             !this.sdiValidazioneSintattica.sdiProperties.isEnableValidazioneNomeFile()));
  229.             if(this.sdiValidazioneSintattica.sdiProperties.isEnableValidazioneNomeFile()){
  230.                 return; 
  231.             }
  232.         }
  233.         
  234.         // setto i valori sdi nella busta
  235.         this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, identificativoSdI);
  236.         this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_NOME_FILE, nomeFile);
  237.         
  238.         
  239.     }
  240.     
  241.     private void _validazioneSemantica_NotificaEsito_richiesta() throws Exception{
  242.         
  243.         // NOTA: Il contenuto viene gestito nella validazione semantica (poiche' deve essere applicata la sicurezza per la firma)
  244.         
  245.         /* **** ESITO COMMITTENTE **** */
  246.         
  247.         byte[] esito = null;
  248.         try{
  249.             // la validazione sintattica garantisce la presenza
  250.             QName qnameEsito = new QName(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE);
  251.             Iterator<?> nodeEsitoIt = this.sdiMessage.getChildElements(qnameEsito);
  252.             SOAPElement nodeEsito = (SOAPElement) nodeEsitoIt.next();
  253.             
  254.             Element xomReference = MTOMUtilities.getIfExistsXomReference(this.messageFactory, nodeEsito);
  255.             if(xomReference!=null){
  256.                 try{
  257.                     String cid = MTOMUtilities.getCidXomReference(xomReference);
  258.                     if(cid==null){
  259.                         throw new Exception("XomReference without cid reference");
  260.                     }
  261.                     AttachmentPart ap = MTOMUtilities.getAttachmentPart(this.msg, cid);
  262.                     esito = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  263.                     if(esito==null || esito.length<=0){
  264.                         throw new Exception("Contenuto non presente");
  265.                     }
  266.                 }catch(Exception e){
  267.                     this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  268.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  269.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] non valorizzato correttamente: "+e.getMessage(),e));
  270.                     return; 
  271.                 }
  272.             }else{
  273.                 if(nodeEsito.getTextContent()==null){
  274.                     this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  275.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  276.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] non valorizzato"));
  277.                     return; 
  278.                 }
  279.                 String base64Metadati = nodeEsito.getTextContent();
  280.                 if(base64Metadati==null || "".equals(base64Metadati)){
  281.                     throw new Exception("Codifica Base64 non presente");
  282.                 }
  283.                 try{
  284.                     esito = Base64Utilities.decode(base64Metadati);
  285.                 }catch(Exception e){
  286.                     // un errore non dovrebbe mai capitare, la validazione sintattica garantisce la presenza
  287.                     this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  288.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  289.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] decodifica base64 non riuscita: "+e.getMessage(),e));
  290.                     return; 
  291.                 }
  292.             }
  293.             
  294.             
  295.         }catch(Exception e){
  296.             // un errore non dovrebbe mai capitare, la validazione sintattica garantisce la presenza
  297.             this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  298.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  299.                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] non accessibile: "+e.getMessage(),e));
  300.             return; 
  301.         }
  302.         this._validazioneEsito(esito,this.sdiValidazioneSemantica.sdiProperties,this.sdiValidazioneSemantica.erroriValidazione,
  303.                 this.sdiValidazioneSemantica.validazioneUtils,this.sdiValidazioneSemantica.getProtocolFactory());
  304.         
  305.     }
  306.     
  307.     private void _validazioneEsito(byte[] esitoDoc, SDIProperties sdiProperties, 
  308.             List<Eccezione> eccezioniValidazione, SDIValidazioneUtils validazioneUtils, IProtocolFactory<?> protocolFactory) throws Exception{
  309.     
  310.         boolean forceEccezioneLivelloInfo = false;
  311.         if(sdiProperties.isEnableAccessoMessaggi() == false) {
  312.             return;
  313.         }
  314.         else if(sdiProperties.isEnableAccessoMessaggiWarningMode()) {
  315.             forceEccezioneLivelloInfo = true;
  316.         }
  317.         
  318.         byte[] esito = esitoDoc;
  319.         if(sdiProperties.isEnableValidazioneMessaggiCompatibilitaNamespaceSenzaGov()){
  320.             esito = SDICompatibilitaNamespaceErrati.convertiXmlNamespaceSenzaGov(protocolFactory.getLogger(), esito);
  321.         }
  322.         
  323.         // validazione XSD file
  324.         if(sdiProperties.isEnableValidazioneXsdMessaggi()){
  325.             try{
  326.                 AbstractValidatoreXSD validatore = 
  327.                         it.gov.fatturapa.sdi.messaggi.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(protocolFactory.getLogger());
  328.                 validatore.valida(new ByteArrayInputStream(esito));
  329.             }catch(Exception e){
  330.                 eccezioniValidazione.add(
  331.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  332.                                 "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] contiene un file Notifica di Esito Committente non valido rispetto allo schema XSD: "+
  333.                                         e.getMessage(),e,forceEccezioneLivelloInfo));
  334.                 return; // esco anche in caso di forceEccezioneLivelloInfo poiche' i messaggi non sono ben formati e non ha senso andare avanti
  335.             }
  336.         }
  337.         
  338.         // Lettura
  339.         NotificaEsitoCommittenteType esitoObject = null;
  340.         try{
  341.             it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer deserializer =
  342.                     new it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer();
  343.             esitoObject = deserializer.readNotificaEsitoCommittenteType(esito);
  344.         }catch(Exception e){
  345.             eccezioniValidazione.add(
  346.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  347.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RICHIESTA_ELEMENT_FILE+"] contiene un file Notifica di Esito Committente non valido: "+
  348.                                     e.getMessage(),e, forceEccezioneLivelloInfo));
  349.             return; // esco anche in caso di forceEccezioneLivelloInfo poiche' i messaggi non sono ben formati e non ha senso andare avanti
  350.         }
  351.         
  352.         // Esito.IdentificativoSdI
  353.         if(esitoObject.getIdentificativoSdI()!=null){
  354.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, esitoObject.getIdentificativoSdI().toString());
  355.         }
  356.         
  357.         // Esito.RiferimentoFattura
  358.         if(esitoObject.getRiferimentoFattura()!=null){
  359.             if(esitoObject.getRiferimentoFattura().getAnnoFattura()!=null){
  360.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_ANNO, esitoObject.getRiferimentoFattura().getAnnoFattura().toString());
  361.             }
  362.             if(esitoObject.getRiferimentoFattura().getNumeroFattura()!=null){
  363.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_NUMERO, esitoObject.getRiferimentoFattura().getNumeroFattura());
  364.             }
  365.             if(esitoObject.getRiferimentoFattura().getPosizioneFattura()!=null){
  366.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_POSIZIONE, esitoObject.getRiferimentoFattura().getPosizioneFattura().toString());
  367.             }
  368.         }
  369.         
  370.         // Esito.Esito
  371.         if(esitoObject.getEsito()!=null){
  372.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_ESITO, esitoObject.getEsito().name());
  373.         }
  374.                 
  375.         // Esito.Descrizione
  376.         if(esitoObject.getDescrizione()!=null){
  377.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_DESCRIZIONE, esitoObject.getDescrizione());
  378.         }
  379.         
  380.         // Esito.MessageId
  381.         if(esitoObject.getMessageIdCommittente()!=null){
  382.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_MESSAGE_ID_COMMITTENTE, esitoObject.getMessageIdCommittente());
  383.         }
  384.         
  385.     }
  386.     
  387.     
  388.     
  389.     
  390.     private void _validazioneSintattica_NotificaEsito_risposta() throws Exception{
  391.         
  392.         if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ROOT_ELEMENT.equals(this.sdiMessage.getLocalName())==false){
  393.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  394.                     "LocalName ["+this.sdiMessage.getLocalName()+"] differente da quello atteso ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ROOT_ELEMENT+"]"));
  395.             return; 
  396.         }
  397.         
  398.         List<SOAPElement> elementChilds = SoapUtils.getNotEmptyChildSOAPElement(this.sdiMessage);
  399.         if(elementChilds==null || elementChilds.size()<=0){
  400.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  401.                     "RootElement [{"+this.namespace+"}"+this.sdiMessage.getLocalName()+"] non contiene elementi"));
  402.             return; 
  403.         }
  404.         
  405.         String esito = null;
  406.         Boolean scartoElementRead = null;
  407.         String nomeFileScartoEsito = null;
  408.         Boolean scartoEsitoRead = null;
  409.         for (int i = 0; i < elementChilds.size(); i++) {
  410.             SOAPElement child = elementChilds.get(i);
  411.     
  412.             if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_ESITO.equals(child.getLocalName())){
  413.                 if(esito!=null){
  414.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  415.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  416.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_ESITO+"] presente piu' volte"));
  417.                     return; 
  418.                 }
  419.                 if(child.getTextContent()==null){
  420.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  421.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  422.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_ESITO+"] non valorizzato"));
  423.                     return; 
  424.                 }
  425.                 esito = child.getTextContent();
  426.             }
  427.             else if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO.equals(child.getLocalName())){
  428.                 if(scartoElementRead!=null){
  429.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  430.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  431.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] presente piu' volte"));
  432.                     return; 
  433.                 }
  434.                 scartoElementRead = true;
  435.                 
  436.                 List<SOAPElement> elementScartoChilds = SoapUtils.getNotEmptyChildSOAPElement(child);
  437.                 if(elementScartoChilds==null || elementScartoChilds.size()<=0){
  438.                     this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  439.                             validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  440.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] non contiene elementi"));
  441.                     return; 
  442.                 }
  443.                 for (int j = 0; j < elementScartoChilds.size(); j++) {
  444.                     SOAPElement scartoChild = elementScartoChilds.get(j);
  445.                 
  446.                     if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_NOME_FILE.equals(scartoChild.getLocalName())){
  447.                         if(nomeFileScartoEsito!=null){
  448.                             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  449.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  450.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_NOME_FILE+"] presente piu' volte"));
  451.                             return; 
  452.                         }
  453.                         if(scartoChild.getTextContent()==null){
  454.                             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  455.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  456.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_NOME_FILE+"] non valorizzato"));
  457.                             return; 
  458.                         }
  459.                         nomeFileScartoEsito = scartoChild.getTextContent();
  460.                     }
  461.                     else if(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE.equals(scartoChild.getLocalName())){
  462.                         if(scartoEsitoRead!=null){
  463.                             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  464.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  465.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE+"] presente piu' volte"));
  466.                             return; 
  467.                         }
  468.                         // Il contenuto viene gestito nella validazione semantica (poiche' deve essere applicata la sicurezza per la firma)
  469.                         scartoEsitoRead = true;
  470.                     }
  471.                 }
  472.                 
  473.             }
  474.             else{
  475.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  476.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  477.                         "Element ["+child.getLocalName()+"] sconosciuto"));
  478.                 return; 
  479.             }
  480.             
  481.             if(child.getNamespaceURI()!=null){
  482.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  483.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  484.                         "Element ["+child.getLocalName()+"] appartiene al namespace ("+child.getNamespaceURI()+"). Era atteso un elemento senza namespace"));
  485.                 return; 
  486.             }
  487.         }
  488.         
  489.         // esito
  490.         if(esito==null){
  491.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  492.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  493.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_ESITO+"] non presente"));
  494.             return; 
  495.         }
  496.         try{
  497.             if(!EsitoNotificaType.ES00.name().equals(esito) && 
  498.                     !EsitoNotificaType.ES01.name().equals(esito) && 
  499.                     !EsitoNotificaType.ES02.name().equals(esito) ){
  500.                 throw new Exception("Valore ["+esito+"] differente dai valori attesi: ["+EsitoNotificaType.ES00.name()+","+EsitoNotificaType.ES01.name()+","+EsitoNotificaType.ES02.name()+"]");
  501.             }
  502.         }catch(Exception e){
  503.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  504.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  505.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_ESITO+"] non valido: "+e.getMessage(),e));
  506.             return; 
  507.         }
  508.         
  509.         // scartoEsito (presente solo se ES00 = NOTIFICA NON ACCETTATA)
  510.         if(EsitoNotificaType.ES00.name().equals(esito)){
  511.             if(scartoEsitoRead==null){
  512.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  513.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  514.                                 "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] non presente (richiesto dallo stato "+EsitoNotificaType.ES00.name()+")"));
  515.                 return; 
  516.             }
  517.             
  518.             // nomeFile
  519.             try{
  520.                 SDIValidatoreNomeFile.validaNomeFileMessaggi(nomeFileScartoEsito, TipiMessaggi.SE);
  521.             }catch(Exception e){
  522.                 this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  523.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  524.                                 "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_NOME_FILE+"] non valido: "+e.getMessage(),e,
  525.                                 !this.sdiValidazioneSintattica.sdiProperties.isEnableValidazioneNomeFile()));
  526.                 if(this.sdiValidazioneSintattica.sdiProperties.isEnableValidazioneNomeFile()){
  527.                     return; 
  528.                 }
  529.             }
  530.             
  531.         }
  532.         
  533.         // ES02 = SERVIZIO NON DISPONIBILE
  534.         else if(EsitoNotificaType.ES02.name().equals(esito)){
  535.             this.sdiValidazioneSintattica.erroriValidazione.add(this.sdiValidazioneSintattica.
  536.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  537.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] indica un ES02 - Sistema non Disponibile del SdI"));
  538.             return; 
  539.         }
  540.                 
  541.         // setto i valori sdi nella busta
  542.         this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_ESITO_NOTIFICA, esito);
  543.         
  544.         
  545.     }
  546.     
  547.     private void _validazioneSemantica_NotificaEsito_risposta() throws Exception{
  548.         
  549.         // NOTA: Il contenuto viene gestito nella validazione semantica (poiche' deve essere applicata la sicurezza per la firma)
  550.         
  551.         /* **** SCARTO ESITO COMMITTENTE **** */
  552.         
  553.         byte[] scartoEsito = null;
  554.         try{
  555.             // la validazione sintattica garantisce la presenza se richiesta
  556.             QName qnameEsito = new QName(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO);
  557.             Iterator<?> nodeEsitoIt = this.sdiMessage.getChildElements(qnameEsito);
  558.             SOAPElement nodeEsito = null;
  559.             if(nodeEsitoIt!=null){
  560.                 Object o = null;
  561.                 try{
  562.                     o = nodeEsitoIt.next();
  563.                 }catch(Exception e){
  564.                     // ignore
  565.                 }
  566.                 if(o!=null){
  567.                     nodeEsito = (SOAPElement) o;
  568.                 }
  569.             }
  570.             
  571.             if(nodeEsito!=null){

  573.                 QName qnameEsitoFile = new QName(SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE);
  574.                 Iterator<?> nodeEsitoFileIt = nodeEsito.getChildElements(qnameEsitoFile);
  575.                 SOAPElement nodeEsitoFile = null;
  576.                 if(nodeEsitoFileIt!=null){
  577.                     Object o = null;
  578.                     try{
  579.                         o = nodeEsitoFileIt.next();
  580.                     }catch(Exception e){
  581.                         // ignore
  582.                     }
  583.                     if(o!=null){
  584.                         nodeEsitoFile = (SOAPElement) o;
  585.                     }
  586.                 }
  587.                 
  588.                 if(nodeEsitoFile!=null){
  589.                     Element xomReference = MTOMUtilities.getIfExistsXomReference(this.messageFactory, nodeEsitoFile);
  590.                     if(xomReference!=null){
  591.                         try{
  592.                             String cid = MTOMUtilities.getCidXomReference(xomReference);
  593.                             if(cid==null){
  594.                                 throw new Exception("XomReference without cid reference");
  595.                             }
  596.                             AttachmentPart ap = MTOMUtilities.getAttachmentPart(this.msg, cid);
  597.                             scartoEsito = Utilities.getAsByteArray(ap.getDataHandler().getInputStream());
  598.                             if(scartoEsito==null || scartoEsito.length<=0){
  599.                                 throw new Exception("Contenuto non presente");
  600.                             }
  601.                         }catch(Exception e){
  602.                             this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  603.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  604.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE+"] non valorizzato correttamente: "+e.getMessage(),e));
  605.                             return; 
  606.                         }
  607.                     }else{
  608.                         if(nodeEsitoFile.getTextContent()==null){
  609.                             this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  610.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  611.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE+"] non valorizzato"));
  612.                             return; 
  613.                         }
  614.                         String base64Metadati = nodeEsitoFile.getTextContent();
  615.                         if(base64Metadati==null || "".equals(base64Metadati)){
  616.                             throw new Exception("Codifica Base64 non presente");
  617.                         }
  618.                         try{
  619.                             scartoEsito = Base64Utilities.decode(base64Metadati);
  620.                         }catch(Exception e){
  621.                             // un errore non dovrebbe mai capitare, la validazione sintattica garantisce la presenza
  622.                             this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  623.                                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  624.                                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE+"] decodifica base64 non riuscita: "+e.getMessage(),e));
  625.                             return; 
  626.                         }
  627.                     }
  628.                 }
  629.                 
  630.             }
  631.                         
  632.         }catch(Exception e){
  633.             // un errore non dovrebbe mai capitare, la validazione sintattica garantisce la presenza
  634.             this.sdiValidazioneSemantica.erroriValidazione.add(this.sdiValidazioneSemantica.
  635.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  636.                     "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO_FILE+"] non accessibile: "+e.getMessage(),e));
  637.             return; 
  638.         }
  639.         if(scartoEsito!=null){
  640.             this._validazioneScartoEsito(scartoEsito,this.sdiValidazioneSemantica.sdiProperties,this.sdiValidazioneSemantica.erroriValidazione,
  641.                     this.sdiValidazioneSemantica.validazioneUtils,this.sdiValidazioneSemantica.getProtocolFactory());
  642.         }
  643.         
  644.         
  645.     }
  646.     
  647.     private void _validazioneScartoEsito(byte[] esitoDoc, SDIProperties sdiProperties, 
  648.             List<Eccezione> eccezioniValidazione, SDIValidazioneUtils validazioneUtils, IProtocolFactory<?> protocolFactory) throws Exception{
  649.     
  650.         boolean forceEccezioneLivelloInfo = false;
  651.         if(sdiProperties.isEnableAccessoMessaggi() == false) {
  652.             return;
  653.         }
  654.         else if(sdiProperties.isEnableAccessoMessaggiWarningMode()) {
  655.             forceEccezioneLivelloInfo = true;
  656.         }
  657.         
  658.         byte[] esito = esitoDoc;
  659.         if(sdiProperties.isEnableValidazioneMessaggiCompatibilitaNamespaceSenzaGov()){
  660.             esito = SDICompatibilitaNamespaceErrati.convertiXmlNamespaceSenzaGov(protocolFactory.getLogger(), esito);
  661.         }
  662.         
  663.         // validazione XSD file
  664.         if(sdiProperties.isEnableValidazioneXsdMessaggi()){
  665.             try{
  666.                 AbstractValidatoreXSD validatore = 
  667.                         it.gov.fatturapa.sdi.messaggi.v1_0.utils.XSDValidatorWithSignature.getOpenSPCoop2MessageXSDValidator(protocolFactory.getLogger());
  668.                 validatore.valida(new ByteArrayInputStream(esito));
  669.             }catch(Exception e){
  670.                 eccezioniValidazione.add(
  671.                         validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  672.                                 "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] contiene un file Notifica di Scarto Esito Committente non valido rispetto allo schema XSD: "+
  673.                                         e.getMessage(),e, forceEccezioneLivelloInfo));
  674.                 return; // esco anche in caso di forceEccezioneLivelloInfo poiche' i messaggi non sono ben formati e non ha senso andare avanti
  675.             }
  676.         }
  677.         
  678.         // Lettura
  679.         ScartoEsitoCommittenteType scartoEsitoObject = null;
  680.         try{
  681.             it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer deserializer =
  682.                     new it.gov.fatturapa.sdi.messaggi.v1_0.utils.serializer.JaxbDeserializer();
  683.             scartoEsitoObject = deserializer.readScartoEsitoCommittenteType(esito);
  684.             if(sdiProperties.isSaveMessaggiInContext()){
  685.                 this.msg.addContextProperty(SDICostanti.SDI_MESSAGE_CONTEXT_MESSAGGIO_SERVIZIO_SDI, scartoEsitoObject);
  686.             }
  687.         }catch(Exception e){
  688.             eccezioniValidazione.add(
  689.                     validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_CORPO_NON_CORRETTO,
  690.                             "Elemento ["+SDICostantiServizioRiceviNotifica.NOTIFICA_ESITO_RISPOSTA_ELEMENT_SCARTO_ESITO+"] contiene un file Notifica di Scarto Esito Committente non valido: "+
  691.                                     e.getMessage(),e, forceEccezioneLivelloInfo));
  692.             return; // esco anche in caso di forceEccezioneLivelloInfo poiche' i messaggi non sono ben formati e non ha senso andare avanti
  693.         }
  694.         
  695.         // Esito.IdentificativoSdI
  696.         if(scartoEsitoObject.getIdentificativoSdI()!=null){
  697.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_IDENTIFICATIVO_SDI, scartoEsitoObject.getIdentificativoSdI().toString());
  698.         }
  699.         
  700.         // Esito.RiferimentoFattura
  701.         if(scartoEsitoObject.getRiferimentoFattura()!=null){
  702.             if(scartoEsitoObject.getRiferimentoFattura().getAnnoFattura()!=null){
  703.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_ANNO, scartoEsitoObject.getRiferimentoFattura().getAnnoFattura().toString());
  704.             }
  705.             if(scartoEsitoObject.getRiferimentoFattura().getNumeroFattura()!=null){
  706.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_NUMERO, scartoEsitoObject.getRiferimentoFattura().getNumeroFattura());
  707.             }
  708.             if(scartoEsitoObject.getRiferimentoFattura().getPosizioneFattura()!=null){
  709.                 this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_RIFERIMENTO_FATTURA_POSIZIONE, scartoEsitoObject.getRiferimentoFattura().getPosizioneFattura().toString());
  710.             }
  711.         }
  712.         
  713.         // Esito.Scarto
  714.         if(scartoEsitoObject.getScarto()!=null){
  715.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_SCARTO, scartoEsitoObject.getScarto().name());
  716.         }
  717.                         
  718.         // Esito.MessageId
  719.         if(scartoEsitoObject.getMessageId()!=null){
  720.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_MESSAGE_ID, scartoEsitoObject.getMessageId());
  721.         }
  722.         if(scartoEsitoObject.getMessageIdCommittente()!=null){
  723.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_MESSAGE_ID_COMMITTENTE, scartoEsitoObject.getMessageIdCommittente());
  724.         }
  725.         
  726.         // Esito.Note
  727.         if(scartoEsitoObject.getNote()!=null){
  728.             this.busta.addProperty(SDICostanti.SDI_BUSTA_EXT_NOTE, scartoEsitoObject.getNote());
  729.         }
  730.         
  731.     }
  732.     
  733. }
Created with JaCoCo 0.8.8.202204050719