SPCoopImbustamento.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */



  23. package org.openspcoop2.protocol.spcoop.builder;

  25. import java.text.SimpleDateFormat;
  26. import java.util.Date;
  27. import java.util.Iterator;
  28. import java.util.List;

  30. import javax.activation.DataHandler;
  31. import javax.xml.namespace.QName;
  32. import javax.xml.soap.AttachmentPart;
  33. import javax.xml.soap.SOAPElement;
  34. import javax.xml.soap.SOAPHeader;
  35. import javax.xml.soap.SOAPHeaderElement;

  37. import org.openspcoop2.core.id.IDSoggetto;
  38. import org.openspcoop2.message.OpenSPCoop2Message;
  39. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  40. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  41. import org.openspcoop2.message.constants.MessageRole;
  42. import org.openspcoop2.message.constants.MessageType;
  43. import org.openspcoop2.message.soap.SoapUtils;
  44. import org.openspcoop2.message.soap.TunnelSoapUtils;
  45. import org.openspcoop2.pdd.config.DynamicClusterManager;
  46. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  47. import org.openspcoop2.protocol.sdk.Busta;
  48. import org.openspcoop2.protocol.sdk.ConfigurazionePdD;
  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.Riscontro;
  53. import org.openspcoop2.protocol.sdk.Trasmissione;
  54. import org.openspcoop2.protocol.sdk.builder.ProprietaManifestAttachments;
  55. import org.openspcoop2.protocol.sdk.config.IProtocolManager;
  56. import org.openspcoop2.protocol.sdk.config.ITraduttore;
  57. import org.openspcoop2.protocol.sdk.constants.Inoltro;
  58. import org.openspcoop2.protocol.sdk.constants.LivelloRilevanza;
  59. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  60. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  61. import org.openspcoop2.protocol.sdk.constants.TipoOraRegistrazione;
  62. import org.openspcoop2.protocol.sdk.state.IState;
  63. import org.openspcoop2.protocol.sdk.validator.ProprietaValidazione;
  64. import org.openspcoop2.protocol.spcoop.SPCoopBustaRawContent;
  65. import org.openspcoop2.protocol.spcoop.config.SPCoopProperties;
  66. import org.openspcoop2.protocol.spcoop.constants.SPCoopCostanti;
  67. import org.openspcoop2.protocol.spcoop.utils.SPCoopUtils;
  68. import org.openspcoop2.protocol.spcoop.validator.SPCoopValidazioneSemantica;
  69. import org.openspcoop2.protocol.spcoop.validator.SPCoopValidazioneSintattica;
  70. import org.openspcoop2.protocol.utils.IDSerialGenerator;
  71. import org.openspcoop2.utils.Utilities;
  72. import org.openspcoop2.utils.date.DateManager;
  73. import org.openspcoop2.utils.date.DateUtils;
  74. import org.openspcoop2.utils.dch.InputStreamDataSource;
  75. import org.openspcoop2.utils.dch.MailcapActivationReader;
  76. import org.openspcoop2.utils.id.serial.IDSerialGeneratorParameter;
  77. import org.openspcoop2.utils.id.serial.IDSerialGeneratorType;
  78. import org.openspcoop2.utils.transport.http.HttpConstants;
  79. import org.slf4j.Logger;
  80. import org.w3c.dom.Node;


  83. /**
  84.  * Classe utilizzata per costruire una Busta eGov, o parti di essa.
  85.  *
  86.  *
  87.  * @author Poli Andrea (apoli@link.it)
  88.  * @author Tronci Fabio (tronci@link.it)
  89.  * @author Lorenzo Nardi (nardi@link.it)
  90.  * @author $Author$
  91.  * @version $Rev$, $Date$
  92.  */

  94. public class SPCoopImbustamento {
  95.     
  96.     private IProtocolFactory<SOAPHeaderElement> factory;
  97.     private Logger log;
  98.     private SPCoopProperties spcoopProperties = null;
  99.     //private List<String> tipiSoggetti = null;
  100.     //private List<String> tipiServizi = null;
  101.     private SPCoopValidazioneSemantica validazioneSemantica = null;
  102.     private SPCoopValidazioneSintattica validazioneSintattica = null;
  103.     @SuppressWarnings("unused")
  104.     private ITraduttore traduttore = null;
  105.     private IProtocolManager protocolManager = null;
  106.     private IState state;

  108.     public SPCoopImbustamento(IProtocolFactory<SOAPHeaderElement> factory, IState state) throws ProtocolException{
  109.         this.factory = factory;
  110.         this.log = factory.getLogger();
  111.         this.spcoopProperties = SPCoopProperties.getInstance(this.log);
  112.         
  113.         //this.tipiSoggetti = this.factory.createProtocolConfiguration().getTipiSoggetti();
  114.         //this.tipiServizi = this.factory.createProtocolConfiguration().getTipiServizi(ServiceBinding.SOAP);
  115.         
  116.         this.state = state;
  117.         
  118.         this.validazioneSemantica = (SPCoopValidazioneSemantica) this.factory.createValidazioneSemantica(this.state);
  119.         this.validazioneSintattica = (SPCoopValidazioneSintattica) this.factory.createValidazioneSintattica(this.state);
  120.         
  121.         this.traduttore = this.factory.createTraduttore();
  122.         
  123.         this.protocolManager = this.factory.createProtocolManager();
  124.     }
  125.     
  126.     public IProtocolFactory<SOAPHeaderElement> getProtocolFactory() {
  127.         return this.factory;
  128.     }  
  129.     
  130.     
  131.     /** MAX_SERIALE */
  132.     protected static int maxSeriale = 0;
  133.     /** LunghezzaPrefisso */
  134.     private static int prefixLenght = 0;

  136.     // Usato in qualsiasi tipo di identificativo
  137.     private void initSerialCounter(int prefixSeriale, int cifre){
  138.         if(SPCoopImbustamento.maxSeriale==0){
  139.             _initSerialCounter(prefixSeriale, cifre);
  140.         }
  141.     }
  142.     private static synchronized void _initSerialCounter(int prefixSeriale, int cifre){
  143.         // Imposto il MAX_SERIAL_VALUE
  144.         if(SPCoopImbustamento.maxSeriale==0){
  145.             if(prefixSeriale==-1){
  146.                 SPCoopImbustamento.maxSeriale = SPCoopCostanti.MAX_VALUE_ID_EGOV_COUNTER;
  147.                 SPCoopImbustamento.prefixLenght = 0;
  148.             }else if(prefixSeriale<10 && 
  149.                     cifre<2){ // altrimenti devo sempre aggiungere uno 0 davanti
  150.                 SPCoopImbustamento.maxSeriale = SPCoopCostanti.MAX_VALUE_ID_EGOV_COUNTER_PREFIX_1;
  151.                 SPCoopImbustamento.prefixLenght = 1;
  152.             }else{
  153.                 SPCoopImbustamento.maxSeriale = SPCoopCostanti.MAX_VALUE_ID_EGOV_COUNTER_PREFIX_2;
  154.                 SPCoopImbustamento.prefixLenght = 2;
  155.             }
  156.         }
  157.     }
  158.     
  159.     
  160.     /* ********  Metodi per la costruzione di parti della busta SPCoop  ******** */ 
  161.     
  162.     /**
  163.      * Metodo che si occupa di costruire una stringa formata da un identificativo
  164.      * conforme alla specifica eGov.
  165.      * L'identificativo e' formato da :
  166.      * codAmministrazione_codPortaDominio_num.progressivo_data_ora
  167.      * <p>
  168.      * Il codice Amministrazione e' preso da <var>destinatario</var>.
  169.      * Il codice della Porta di Dominio e' preso da <var>idPD</var>.
  170.      * Le altre informazioni sono costruite dal metodo, che si occupa
  171.      * di assemblarle in una unica stringa e di ritornarla.
  172.      *
  173.      * @param idSoggetto identificativo del soggetto
  174.      * @param idTransazione identificativo della transazione
  175.      * @param ruoloMessaggio Indicazione se si tratta della richiesta
  176.      * @return un oggetto String contenente l'identificativo secondo specifica eGov.
  177.      * 
  178.      */
  179.     public String buildID(IDSoggetto idSoggetto, String idTransazione, RuoloMessaggio ruoloMessaggio) throws ProtocolException {

  181.         
  182.         String idPD = idSoggetto.getCodicePorta();
  183.         String codAmm = idSoggetto.getNome();
  184.         
  185.         if(idPD == null || codAmm == null){
  186.             this.log.error("Creazione ID eGov non riuscita: alcuni parametri di creazione null idPD["+idPD+"] codAmm["+codAmm+"]");
  187.             throw new ProtocolException("Creazione ID eGov non riuscita: alcuni parametri di creazione null idPD["+idPD+"] codAmm["+codAmm+"]");
  188.         }
  189.         
  190.         Integer prefix = null;
  191.         DynamicClusterManager dynamicClusterManager = null;
  192.         OpenSPCoop2Properties openSPCoop2Properties = OpenSPCoop2Properties.getInstance();
  193.         if(openSPCoop2Properties.isClusterDinamico()) {
  194.             try {
  195.                 dynamicClusterManager = DynamicClusterManager.getInstance();
  196.                 prefix = dynamicClusterManager.getIdentificativoNumerico();
  197.             }catch(Exception e) {
  198.                 throw new ProtocolException("Creazione ID eGov non riuscita; identificativo numerico del cluster dinamico non ottenibile: "+e.getMessage(), e);
  199.             }
  200.         }
  201.         else {
  202.             String prefixS =openSPCoop2Properties.getClusterIdNumerico();
  203.             if(prefixS!=null) {
  204.                 prefix = Integer.valueOf(prefixS);
  205.             }
  206.         }
  207.         
  208.         int cifre = -1; 
  209.         if(prefix!=null) {
  210.             if(openSPCoop2Properties.isClusterDinamico()) {
  211.                 try {
  212.                     cifre = openSPCoop2Properties.getClusterDinamicoIdNumericoCifre(dynamicClusterManager.isRateLimitingGestioneCluster());
  213.                 }catch(Exception e) {
  214.                     String msg = "Comprensione numero cifre per id non riuscita (DynamicClusterManager-RL:"+dynamicClusterManager.isRateLimitingGestioneCluster()+"): "+e.getMessage();
  215.                     this.log.debug(msg);
  216.                     cifre = (prefix.intValue()+"").length();
  217.                 }
  218.             }
  219.             else {
  220.                 try {
  221.                     cifre = openSPCoop2Properties.getClusterDinamicoIdNumericoCifre(false);
  222.                 }catch(Exception e) {
  223.                     String msg = "Comprensione numero cifre per id non riuscita: "+e.getMessage();
  224.                     this.log.debug(msg);
  225.                     cifre = (prefix.intValue()+"").length();
  226.                 }
  227.             }
  228.         }
  229.         
  230.         initSerialCounter(prefix==null ? -1 : prefix, cifre);

  232.         IDSerialGenerator serialGenerator = null;
  233.         IDSerialGeneratorParameter serialGeneratorParameter = null;
  234.         if( SPCoopCostanti.IDENTIFICATIVO_EGOV_SERIALE_STATIC.equals(this.spcoopProperties.getTipoSeriale_IdentificativoBusta())==false ){
  235.             
  236.             ConfigurazionePdD config = this.factory.getConfigurazionePdD();
  237.             
  238.             serialGenerator = new IDSerialGenerator(config.getLog(),this.state,config.getTipoDatabase());
  239.             
  240.             serialGeneratorParameter = new IDSerialGeneratorParameter(this.factory.getProtocol());
  241.             serialGeneratorParameter.setSerializableTimeWaitMs(config.getAttesaAttivaJDBC());
  242.             serialGeneratorParameter.setSerializableNextIntervalTimeMs(config.getCheckIntervalJDBC());
  243.             serialGeneratorParameter.setTipo(IDSerialGeneratorType.NUMERIC);
  244.             serialGeneratorParameter.setMaxValue(Long.valueOf(SPCoopImbustamento.maxSeriale));
  245.             serialGeneratorParameter.setWrap(true);
  246.         }
  247.         
  248.         try{
  249.         
  250.             long counter = -1;
  251.             
  252.             Date now=DateManager.getDate();
  253.             // Date nel formato yyyy-MM-dd_hh:mm
  254.             SimpleDateFormat dateformat = DateUtils.getSimpleDateFormatMinute();
  255.             String dataIdentificativo = dateformat.format(now);
  256.             
  257.             
  258.             StringBuilder bf = new StringBuilder();
  259.             bf.append(codAmm);
  260.             bf.append('_');
  261.             bf.append(idPD);
  262.             bf.append('_');
  263.     
  264.             if ( SPCoopCostanti.IDENTIFICATIVO_EGOV_SERIALE_MYSQL.equals(this.spcoopProperties.getTipoSeriale_IdentificativoBusta()) ) {

  266.                 if(serialGeneratorParameter!=null) {
  267.                     serialGeneratorParameter.setTipo(IDSerialGeneratorType.MYSQL);
  268.                 }
  269.                 
  270.                 if(serialGenerator==null) {
  271.                     throw new Exception("SerialGenerator undefined");
  272.                 }
  273.                 
  274.                 counter = serialGenerator.buildIDAsNumber(serialGeneratorParameter);
  275.     
  276.             } else if(SPCoopCostanti.IDENTIFICATIVO_EGOV_SERIALE_STATIC.equals(this.spcoopProperties.getTipoSeriale_IdentificativoBusta())
  277.                     ||
  278.                     SPCoopCostanti.IDENTIFICATIVO_EGOV_SERIALE_DYNAMIC.equals(this.spcoopProperties.getTipoSeriale_IdentificativoBusta())){
  279.     
  280.                 counter = SPCoopStaticCounter.getNextSerialCounter(now, dataIdentificativo, codAmm, idPD);
  281.                     
  282.             } else {
  283.     
  284.                 if(serialGenerator==null) {
  285.                     throw new Exception("SerialGenerator undefined");
  286.                 }
  287.                 
  288.                 counter = serialGenerator.buildIDAsNumber(serialGeneratorParameter);
  289.     
  290.             }
  291.     
  292.             if(prefix!=null){
  293.                 int paddingPrefix = SPCoopImbustamento.prefixLenght - (prefix.intValue()+"").length();
  294.                 int iP=0;
  295.                 for(;iP<paddingPrefix;iP++)
  296.                     bf.append('0');
  297.                 bf.append(prefix.intValue());
  298.             }
  299.             
  300.             String c = Long.toString(counter);
  301.             int padding= SPCoopCostanti.CIFRE_SERIALI_ID_EGOV - SPCoopImbustamento.prefixLenght - c.length();
  302.             int i=0;
  303.             for(;i<padding;i++)
  304.                 bf.append('0');
  305.             bf.append(c);
  306.         
  307.             bf.append('_');
  308.     
  309.             bf.append(dataIdentificativo);
  310.     
  311.             return bf.toString();
  312.         
  313.         }catch (Exception e){
  314.             throw new ProtocolException(e.getMessage(),e);
  315.         }

  317.     }

















  335.     /* ----------------  Metodi per la costruzione di una busta eGov  -------------------- */

  337.     /**
  338.      * Metodo che si occupa di costruire un elemento SOAPElement
  339.      * contenente l'elemento 'Intestazione' definito nella specifica eGov 
  340.      * 'http://www.cnipa.it/schemas/2003/eGovIT/Busta1_0/'.
  341.      * <p>
  342.      * Gli elementi eGov da creare, all'interno dell'header 'Intestazione' sono prelevati
  343.      * dall'oggetto <var>eGov</var> di tipo {@link Busta}.
  344.      *
  345.      * @param eGov contiene le funzionalita' eGov da inserire nell'header.
  346.      * @return il SOAPElement 'eGov_IT:Intestazione'  se la costruzione ha successo, null altrimenti.
  347.      * 
  348.      */
  349.     public SOAPHeaderElement build_eGovHeader(OpenSPCoop2Message msg, Busta eGov) throws ProtocolException{ 
  350.         return build_eGovHeader(msg,eGov, true, false);
  351.     }
  352.     public SOAPHeaderElement build_eGovHeader(OpenSPCoop2Message msg,Busta eGov,boolean verificaPresenzaElementiObbligatori) throws ProtocolException{ 
  353.         return build_eGovHeader(msg,eGov, verificaPresenzaElementiObbligatori, false);
  354.     }
  355.     public SOAPHeaderElement build_eGovHeader(OpenSPCoop2Message msg,Busta eGov,boolean verificaPresenzaElementiObbligatori,boolean forzaValidazioneXSDElementiDisabilitata) throws ProtocolException{ 
  356.         try{

  358.             OpenSPCoop2SoapMessage soapMsg = null;
  359.             if(msg==null){
  360.                 OpenSPCoop2MessageFactory mf = OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  361.                 soapMsg = mf.createEmptyMessage(MessageType.SOAP_11,MessageRole.NONE).castAsSoap();
  362.             }
  363.             else{
  364.                 soapMsg = msg.castAsSoap();
  365.             }
  366.                 
  367.                 
  368.             SOAPHeader hdr = soapMsg.getSOAPHeader();
  369.             if(hdr==null){
  370.                 hdr = soapMsg.getSOAPPart().getEnvelope().addHeader(); 
  371.             }
  372.             QName name = new QName(SPCoopCostanti.NAMESPACE_EGOV, "Intestazione",SPCoopCostanti.PREFIX_EGOV);
  373.             SOAPHeaderElement eGovHeader = soapMsg.newSOAPHeaderElement(hdr, name);
  374.                         
  375.             
  376.             
  377.             eGovHeader.setActor(SPCoopCostanti.ACTOR_EGOV);
  378.             eGovHeader.setMustUnderstand(true);
  379.             if(this.spcoopProperties.isAddPrefixSOAPENV()) {
  380.                 eGovHeader.addNamespaceDeclaration("SOAP_ENV","http://schemas.xmlsoap.org/soap/envelope/");
  381.             }

  383.             // Costruzione IntestazioneMessaggio
  384.             SOAPElement eGovIntestazioneMsg = eGovHeader.addChildElement("IntestazioneMessaggio",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  385.             // Mittente
  386.             if(verificaPresenzaElementiObbligatori){
  387.                 if(eGov.getMittente()==null){
  388.                     throw new ProtocolException("Mittente e' un elemento obbligatorio, e non e' stato definito");
  389.                 }
  390.                 if(eGov.getTipoMittente()==null){
  391.                     throw new ProtocolException("TipoMittente e' un attributo obbligatorio, e non e' stato definito");
  392.                 }
  393.             }
  394.             SOAPElement eGovMitt = eGovIntestazioneMsg.addChildElement("Mittente",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  395.             SOAPElement eGovIDParteMitt = eGovMitt.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  396.             if(eGov.getMittente()!=null){
  397.                 eGovIDParteMitt.setValue(eGov.getMittente());
  398.             }
  399.             if(eGov.getTipoMittente()!=null){
  400.                 String tipoMittenteProtocollo = null;
  401.                 try {
  402.                     tipoMittenteProtocollo = this.traduttore.toProtocolOrganizationType(eGov.getTipoMittente());
  403.                 }catch(Exception e) {
  404.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  405.                         throw e;
  406.                     }
  407.                     else {
  408.                         tipoMittenteProtocollo = eGov.getTipoMittente(); // per serializzare errori
  409.                         this.log.warn("Produco busta con un tipo mittente non corretto: '"+tipoMittenteProtocollo+"'");
  410.                     }
  411.                 }
  412.                 eGovIDParteMitt.setAttribute("tipo",tipoMittenteProtocollo);
  413.             }
  414.             if(eGov.getIndirizzoMittente() != null){
  415.                 eGovIDParteMitt.setAttribute("indirizzoTelematico",eGov.getIndirizzoMittente());
  416.             }


  419.             // Destinatario
  420.             if(verificaPresenzaElementiObbligatori){
  421.                 if(eGov.getDestinatario()==null){
  422.                     throw new ProtocolException("Destinatario e' un elemento obbligatorio, e non e' stato definito");
  423.                 }
  424.                 if(eGov.getTipoDestinatario()==null){
  425.                     throw new ProtocolException("TipoDestinatario e' un attributo obbligatorio, e non e' stato definito");
  426.                 }
  427.             }
  428.             SOAPElement eGovDest = eGovIntestazioneMsg.addChildElement("Destinatario",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  429.             SOAPElement eGovIDParteDest = eGovDest.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  430.             if(eGov.getDestinatario()!=null){
  431.                 eGovIDParteDest.setValue(eGov.getDestinatario());
  432.             }
  433.             if(eGov.getTipoDestinatario()!=null){
  434.                 String tipoDestinatarioProtocollo = null;
  435.                 try {
  436.                     tipoDestinatarioProtocollo = this.traduttore.toProtocolOrganizationType(eGov.getTipoDestinatario());
  437.                 }catch(Exception e) {
  438.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  439.                         throw e;
  440.                     }
  441.                     else {
  442.                         tipoDestinatarioProtocollo = eGov.getTipoDestinatario(); // per serializzare errori
  443.                         this.log.warn("Produco busta con un tipo destinatario non corretto: '"+tipoDestinatarioProtocollo+"'");
  444.                     }
  445.                 }
  446.                 eGovIDParteDest.setAttribute("tipo",tipoDestinatarioProtocollo);
  447.             }
  448.             if(eGov.getIndirizzoDestinatario() != null){
  449.                 eGovIDParteDest.setAttribute("indirizzoTelematico",eGov.getIndirizzoDestinatario());
  450.             }

  452.             // Profilo di Collaborazione
  453.             if(eGov.getProfiloDiCollaborazione() != null){
  454.                 
  455.                 boolean generazioneElemento = true;
  456.                 if(!forzaValidazioneXSDElementiDisabilitata){
  457.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  458.                         if( !(
  459.                                 ProfiloDiCollaborazione.ONEWAY.equals(eGov.getProfiloDiCollaborazione()) || 
  460.                                 ProfiloDiCollaborazione.SINCRONO.equals(eGov.getProfiloDiCollaborazione()) || 
  461.                                 ProfiloDiCollaborazione.ASINCRONO_SIMMETRICO.equals(eGov.getProfiloDiCollaborazione()) || 
  462.                                 ProfiloDiCollaborazione.ASINCRONO_ASIMMETRICO.equals(eGov.getProfiloDiCollaborazione())
  463.                             ) 
  464.                         ){
  465.                             generazioneElemento = false;
  466.                         }
  467.                     }           
  468.                 }           
  469.                 
  470.                 if(generazioneElemento){
  471.                     
  472.                     SOAPElement eGovProfCollaborazione = eGovIntestazioneMsg.addChildElement("ProfiloCollaborazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  473.                     switch (eGov.getProfiloDiCollaborazione()) {
  474.                     case ONEWAY:
  475.                         eGovProfCollaborazione.setValue(SPCoopCostanti.PROFILO_COLLABORAZIONE_ONEWAY);
  476.                         break;
  477.                     case SINCRONO:
  478.                         eGovProfCollaborazione.setValue(SPCoopCostanti.PROFILO_COLLABORAZIONE_SINCRONO);
  479.                         break;
  480.                     case ASINCRONO_SIMMETRICO:
  481.                         eGovProfCollaborazione.setValue(SPCoopCostanti.PROFILO_COLLABORAZIONE_ASINCRONO_SIMMETRICO);
  482.                         break;
  483.                     case ASINCRONO_ASIMMETRICO:
  484.                         eGovProfCollaborazione.setValue(SPCoopCostanti.PROFILO_COLLABORAZIONE_ASINCRONO_ASIMMETRICO);
  485.                         break;
  486.                     default:
  487.                         eGovProfCollaborazione.setValue(eGov.getProfiloDiCollaborazioneValue());
  488.                         break;
  489.                     }
  490.                     
  491.                     if(eGov.getServizioCorrelato() != null){
  492.                         eGovProfCollaborazione.setAttribute("servizioCorrelato",eGov.getServizioCorrelato());
  493.                     }
  494.                     
  495.                     if(eGov.getTipoServizioCorrelato() != null){
  496.                         
  497.                         boolean generazioneAttributo = true;
  498.                         if(!forzaValidazioneXSDElementiDisabilitata){
  499.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  500.                                 //generazioneAttributo = this.tipiServizi.contains(eGov.getTipoServizioCorrelato());
  501.                                 try {
  502.                                     this.traduttore.toProtocolServiceType(eGov.getTipoServizioCorrelato());
  503.                                 }catch(Exception e) {
  504.                                     generazioneAttributo = false;
  505.                                 }
  506.                             }
  507.                         }
  508.                         if(generazioneAttributo){
  509.                             eGovProfCollaborazione.setAttribute("tipo",this.traduttore.toProtocolServiceType(eGov.getTipoServizioCorrelato()));
  510.                         }
  511.                     }
  512.                 }
  513.             }       

  515.             // Collaborazione
  516.             if(eGov.getCollaborazione() != null){
  517.                 boolean generazioneElemento = true;
  518.                 if(!forzaValidazioneXSDElementiDisabilitata){
  519.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  520.                         ProprietaValidazione proprietaValidazione = new ProprietaValidazione();
  521.                         proprietaValidazione.setValidazioneIDCompleta(false);
  522.                         generazioneElemento = this.validazioneSemantica.validazioneID(eGov.getCollaborazione(), null,proprietaValidazione);
  523.                     }
  524.                 }
  525.                 if(generazioneElemento){
  526.                     SOAPElement eGovCollaborazione = eGovIntestazioneMsg.addChildElement("Collaborazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  527.                     eGovCollaborazione.setValue(eGov.getCollaborazione());
  528.                 }
  529.             }

  531.             // Servizio
  532.             if(eGov.getServizio() != null){
  533.                 SOAPElement eGovServizio = eGovIntestazioneMsg.addChildElement("Servizio",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  534.                 eGovServizio.setValue(eGov.getServizio());
  535.                 if(eGov.getTipoServizio() != null){
  536.                     String tipoServizio = null;
  537.                     try {
  538.                         tipoServizio = this.traduttore.toProtocolServiceType(eGov.getTipoServizio());
  539.                     }catch(Exception e) {
  540.                         if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  541.                             throw e;
  542.                         }
  543.                         else {
  544.                             tipoServizio = eGov.getTipoServizio(); // per serializzare errori
  545.                             this.log.warn("Produco busta con un tipo servizio non corretto: '"+tipoServizio+"'");
  546.                         }
  547.                     }
  548.                     eGovServizio.setAttribute("tipo",tipoServizio);
  549.                 }
  550.             }

  552.             // Azione
  553.             if(eGov.getAzione() != null){
  554.                 SOAPElement eGovAzione = eGovIntestazioneMsg.addChildElement("Azione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  555.                 eGovAzione.setValue(eGov.getAzione()); 
  556.             }

  558.             // Messaggio
  559.             SOAPElement eGovMessaggio = eGovIntestazioneMsg.addChildElement("Messaggio",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  560.             
  561.             // Messaggio.Identificatore
  562.             if(eGov.getID() != null){
  563.                 boolean generazioneElemento = true;
  564.                 if(!forzaValidazioneXSDElementiDisabilitata){
  565.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  566.                         generazioneElemento = this.validazioneSemantica.validazioneID_engine(eGov.getID());
  567.                     }
  568.                 }
  569.                 if(generazioneElemento){
  570.                     SOAPElement eGovIDMsg = eGovMessaggio.addChildElement("Identificatore",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  571.                     if(eGov.getID() != null)
  572.                         eGovIDMsg.setValue(eGov.getID());
  573.                 }else{
  574.                     throw new ProtocolException("Identificatore e' un elemento obbligatorio, e il valore non e' utilizzabile rispetto all'xsd ("+eGov.getID()+")");
  575.                 }
  576.             }else{
  577.                 if(verificaPresenzaElementiObbligatori){
  578.                     throw new ProtocolException("Identificatore e' un elemento obbligatorio, e non e' stato definito");
  579.                 }
  580.             }   
  581.             
  582.             // Messaggio.OraRegistrazione
  583.             SOAPElement eGovOraRegistrazione = eGovMessaggio.addChildElement("OraRegistrazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  584.             if(eGov.getOraRegistrazione() == null){
  585.                 if(verificaPresenzaElementiObbligatori){
  586.                     throw new ProtocolException("OraRegistrazione e' un elemento obbligatorio, e non e' stato definito");
  587.                 }
  588.             }
  589.             if(eGov.getOraRegistrazione() != null){
  590.                 eGovOraRegistrazione.setValue(SPCoopUtils.getDate_eGovFormat(eGov.getOraRegistrazione()));
  591.             }
  592.             if(eGov.getTipoOraRegistrazione()!=null){
  593.                 boolean generazioneAttributo = true;
  594.                 if(!forzaValidazioneXSDElementiDisabilitata){
  595.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  596.                         generazioneAttributo = ( TipoOraRegistrazione.LOCALE.equals(eGov.getTipoOraRegistrazione()) || TipoOraRegistrazione.SINCRONIZZATO.equals(eGov.getTipoOraRegistrazione()) );
  597.                     }
  598.                 }
  599.                 if(generazioneAttributo){
  600.                     if(TipoOraRegistrazione.LOCALE.equals(eGov.getTipoOraRegistrazione()))
  601.                         eGovOraRegistrazione.setAttribute("tempo", SPCoopCostanti.TIPO_TEMPO_LOCALE);
  602.                     else if(TipoOraRegistrazione.SINCRONIZZATO.equals(eGov.getTipoOraRegistrazione()))
  603.                         eGovOraRegistrazione.setAttribute("tempo", SPCoopCostanti.TIPO_TEMPO_SPC);
  604.                     else 
  605.                         eGovOraRegistrazione.setAttribute("tempo", eGov.getTipoOraRegistrazioneValue());
  606.                 }
  607.                 else{
  608.                     throw new ProtocolException("TipoOraRegistrazione e' un elemento obbligatorio, e il valore non e' utilizzabile rispetto all'xsd ("+eGov.getTipoOraRegistrazioneValue()+")");
  609.                 }
  610.             }
  611.             else{
  612.                 eGovOraRegistrazione.setAttribute("tempo", SPCoopCostanti.TIPO_TEMPO_SPC); // default
  613.             }
  614.             
  615.             // Messaggio.RiferimentoMessaggio
  616.             if(eGov.getRiferimentoMessaggio() != null){
  617.                 boolean generazioneElemento = true;
  618.                 if(!forzaValidazioneXSDElementiDisabilitata){
  619.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  620.                         generazioneElemento = this.validazioneSemantica.validazioneID_engine(eGov.getRiferimentoMessaggio());
  621.                     }
  622.                 }
  623.                 if(generazioneElemento){
  624.                     SOAPElement eGovRifMsg = eGovMessaggio.addChildElement("RiferimentoMessaggio",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  625.                     eGovRifMsg.setValue(eGov.getRiferimentoMessaggio());
  626.                 }
  627.             }
  628.             
  629.             // Messaggio.Scadenza
  630.             if(eGov.getScadenza() != null){
  631.                 SOAPElement eGovScadenza = eGovMessaggio.addChildElement("Scadenza",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  632.                 eGovScadenza.setValue(SPCoopUtils.getDate_eGovFormat(eGov.getScadenza()));
  633.             }

  635.             // Profilo di Trasmissione
  636.             SOAPElement eGovProfTrasmissione = eGovIntestazioneMsg.addChildElement("ProfiloTrasmissione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  637.             if(eGov.getInoltro() != null) {
  638.                 boolean generazioneElemento = true;
  639.                 if(!forzaValidazioneXSDElementiDisabilitata){
  640.                     if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  641.                         generazioneElemento = ( Inoltro.CON_DUPLICATI.equals(eGov.getInoltro()) || Inoltro.SENZA_DUPLICATI.equals(eGov.getInoltro()) );
  642.                     }
  643.                 }
  644.                 if(generazioneElemento){
  645.                     if(Inoltro.CON_DUPLICATI.equals(eGov.getInoltro()))
  646.                         eGovProfTrasmissione.setAttribute("inoltro", SPCoopCostanti.PROFILO_TRASMISSIONE_CON_DUPLICATI);
  647.                     else if(Inoltro.SENZA_DUPLICATI.equals(eGov.getInoltro()))
  648.                         eGovProfTrasmissione.setAttribute("inoltro", SPCoopCostanti.PROFILO_TRASMISSIONE_SENZA_DUPLICATI);
  649.                     else 
  650.                         eGovProfTrasmissione.setAttribute("inoltro", eGov.getInoltroValue());
  651.                 }
  652.             }
  653.             String crValue = "false";
  654.             if(eGov.isConfermaRicezione())
  655.                 crValue="true";
  656.             eGovProfTrasmissione.setAttribute("confermaRicezione",crValue);



  660.             // Sequenza
  661.             if(eGov.getSequenza() != -1){
  662.                 SOAPElement eGovSequenza = eGovIntestazioneMsg.addChildElement("Sequenza",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  663.                 StringBuilder bf = new StringBuilder();
  664.                 String sequenza = Long.toString(eGov.getSequenza());
  665.                 int padding= 7 - sequenza.length();
  666.                 int i=0;
  667.                 for(;i<padding;i++)
  668.                     bf.append('0');
  669.                 bf.append(sequenza);
  670.                 eGovSequenza.setAttribute("numeroProgressivo",bf.toString());
  671.             }





  677.             // Costruzione Lista Riscontri
  678.             if(eGov.sizeListaRiscontri() > 0){
  679.                 SOAPElement eGovListaRiscontri = eGovHeader.addChildElement("ListaRiscontri",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  680.                 for(int i=0; i<eGov.sizeListaRiscontri();i++){
  681.                     Riscontro ris = eGov.getRiscontro(i);

  683.                     SOAPElement Riscontro = eGovListaRiscontri.addChildElement("Riscontro",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  684.                     if(ris.getID() != null) {
  685.                         boolean generazioneElemento = true;
  686.                         if(!forzaValidazioneXSDElementiDisabilitata){
  687.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  688.                                 generazioneElemento = this.validazioneSemantica.validazioneID_engine(ris.getID());
  689.                             }
  690.                         }
  691.                         if(generazioneElemento){
  692.                             SOAPElement id = Riscontro.addChildElement("Identificatore",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  693.                             id.setValue(ris.getID());
  694.                         }else{
  695.                             throw new ProtocolException("Identificatore e' un elemento obbligatorio in un Riscontro, e il valore non e' utilizzabile rispetto all'xsd ("+ris.getID()+")");
  696.                         }
  697.                     }
  698.                     else{
  699.                         if(verificaPresenzaElementiObbligatori){
  700.                             throw new ProtocolException("Identificatore e' un elemento obbligatorio in un Riscontro, e non e' stato definito");
  701.                         }
  702.                     }

  704.                     if(ris.getOraRegistrazione() != null) {
  705.                         SOAPElement ora = Riscontro.addChildElement("OraRegistrazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  706.                         ora.setValue(SPCoopUtils.getDate_eGovFormat(ris.getOraRegistrazione()));
  707.                         if(ris.getTipoOraRegistrazione()!=null){
  708.                             boolean generazioneAttributo = true;
  709.                             if(!forzaValidazioneXSDElementiDisabilitata){
  710.                                 if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  711.                                     generazioneAttributo = ( TipoOraRegistrazione.LOCALE.equals(ris.getTipoOraRegistrazione()) || TipoOraRegistrazione.SINCRONIZZATO.equals(ris.getTipoOraRegistrazione()) );
  712.                                 }
  713.                             }
  714.                             if(generazioneAttributo){
  715.                                 if(TipoOraRegistrazione.LOCALE.equals(ris.getTipoOraRegistrazione()))
  716.                                     ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_LOCALE);
  717.                                 else
  718.                                     ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_SPC);
  719.                             }
  720.                             else{
  721.                                 throw new ProtocolException("TipoOraRegistrazione e' un attributo obbligatorio in un Riscontro, e il valore non e' utilizzabile rispetto all'xsd ("+ris.getTipoOraRegistrazioneValue(this.factory)+")");
  722.                             }
  723.                         }
  724.                         else{
  725.                             ora.setAttribute("tempo", SPCoopCostanti.TIPO_TEMPO_SPC);
  726.                         }
  727.                     }
  728.                     else{
  729.                         if(verificaPresenzaElementiObbligatori){
  730.                             throw new ProtocolException("OraRegistrazione e' un elemento obbligatorio in un Riscontro, e non e' stato definito");
  731.                         }
  732.                     }

  734.                 }
  735.             }


  738.             // Costruzione Lista Trasmissioni
  739.             if(eGov.sizeListaTrasmissioni() > 0){

  741.                 boolean addFirstElement = false;
  742.                 SOAPElement eGovListaTrasmissioni = null;

  744.                 for(int i=0; i<eGov.sizeListaTrasmissioni();i++){

  746.                     Trasmissione tr = eGov.getTrasmissione(i);

  748.                     if(tr.getOrigine() != null && tr.getTipoOrigine() != null &&
  749.                             tr.getDestinazione() != null && tr.getTipoDestinazione() != null &&
  750.                             tr.getOraRegistrazione() != null && tr.getTempo()!= null){

  752.                         if(addFirstElement==false){
  753.                             eGovListaTrasmissioni = eGovHeader.addChildElement("ListaTrasmissioni",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  754.                             addFirstElement = true;
  755.                         }

  757.                         SOAPElement Trasmissione = eGovListaTrasmissioni.addChildElement("Trasmissione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);

  759.                         SOAPElement orig = Trasmissione.addChildElement("Origine",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  760.                         SOAPElement IDParteOrigine = orig.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  761.                         IDParteOrigine.setValue(tr.getOrigine());
  762.                         String tipoOrigine = null;
  763.                         try {
  764.                             tipoOrigine = this.traduttore.toProtocolOrganizationType(tr.getTipoOrigine());
  765.                         }catch(Exception e) {
  766.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  767.                                 throw e;
  768.                             }
  769.                             else {
  770.                                 tipoOrigine = tr.getTipoOrigine(); // per serializzare errori
  771.                                 this.log.warn("Produco busta con un tipo origine nella lista trasmissione non corretto: '"+tipoOrigine+"'");
  772.                             }
  773.                         }
  774.                         IDParteOrigine.setAttribute("tipo",tipoOrigine);
  775.                         if(tr.getIndirizzoOrigine() != null){
  776.                             IDParteOrigine.setAttribute("indirizzoTelematico",tr.getIndirizzoOrigine());
  777.                         }

  779.                         SOAPElement dest = Trasmissione.addChildElement("Destinazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  780.                         SOAPElement IDParteDest = dest.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  781.                         IDParteDest.setValue(tr.getDestinazione());
  782.                         String tipoDestinazione = null;
  783.                         try {
  784.                             tipoDestinazione = this.traduttore.toProtocolOrganizationType(tr.getTipoDestinazione());
  785.                         }catch(Exception e) {
  786.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  787.                                 throw e;
  788.                             }
  789.                             else {
  790.                                 tipoDestinazione = tr.getTipoDestinazione(); // per serializzare errori
  791.                                 this.log.warn("Produco busta con un tipo destinazione nella lista trasmissione non corretto: '"+tipoDestinazione+"'");
  792.                             }
  793.                         }
  794.                         IDParteDest.setAttribute("tipo",tipoDestinazione);
  795.                         if(tr.getIndirizzoDestinazione() != null){
  796.                             IDParteDest.setAttribute("indirizzoTelematico",tr.getIndirizzoDestinazione());
  797.                         }

  799.                         SOAPElement ora = Trasmissione.addChildElement("OraRegistrazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  800.                         ora.setValue(SPCoopUtils.getDate_eGovFormat(tr.getOraRegistrazione()));
  801.                         boolean generazioneAttributo = true;
  802.                         if(!forzaValidazioneXSDElementiDisabilitata){
  803.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  804.                                 generazioneAttributo = ( TipoOraRegistrazione.LOCALE.equals(tr.getTempo()) || TipoOraRegistrazione.SINCRONIZZATO.equals(tr.getTempo()) );
  805.                             }
  806.                         }
  807.                         if(generazioneAttributo){
  808.                             if(TipoOraRegistrazione.LOCALE.equals(tr.getTempo()))
  809.                                 ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_LOCALE);
  810.                             else
  811.                                 ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_SPC);
  812.                         }
  813.                         else{
  814.                             throw new ProtocolException("Tempo e' un attributo obbligatorio in una trasmissione, e il valore non e' utilizzabile rispetto all'xsd ("+tr.getTempoValue(this.factory)+")");
  815.                         }
  816.                     }
  817.                 }
  818.             }


  821.             // Costruzione Lista Eccezioni
  822.             if(eGov.sizeListaEccezioni() > 0){
  823.                 SOAPElement eGovListaEccezioni = eGovHeader.addChildElement("ListaEccezioni",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  824.                 for(int i=0; i<eGov.sizeListaEccezioni();i++){
  825.                     Eccezione ecc = eGov.getEccezione(i);

  827.                     SOAPElement eccezione = eGovListaEccezioni.addChildElement("Eccezione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  828.                     if(ecc.getContestoCodifica() != null) {
  829.                         eccezione.setAttribute("contestoCodifica",ecc.getContestoCodificaValue(this.factory));
  830.                     }
  831.                     else{
  832.                         if(verificaPresenzaElementiObbligatori){
  833.                             throw new ProtocolException("ContestoCodifica e' un attributo obbligatorio in una eccezione, e non e' stato definito");
  834.                         }
  835.                     }

  837.                     if(ecc.getCodiceEccezione() != null) {
  838.                         boolean generazioneAttributo = true;
  839.                         if(!forzaValidazioneXSDElementiDisabilitata){
  840.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  841.                                 generazioneAttributo = this.validazioneSintattica.validazioneCodiceEccezione(ecc.getCodiceEccezione());
  842.                             }
  843.                         }
  844.                         if(generazioneAttributo){
  845.                             eccezione.setAttribute("codiceEccezione",ecc.getCodiceEccezioneValue(this.factory));
  846.                         }
  847.                         else{
  848.                             throw new ProtocolException("CodiceEccezione e' un attributo obbligatorio in una eccezione, e il valore non e' utilizzabile rispetto all'xsd ("+ecc.getCodiceEccezione()+")");
  849.                         }
  850.                     }
  851.                     else{
  852.                         if(verificaPresenzaElementiObbligatori){
  853.                             throw new ProtocolException("CodiceEccezione e' un attributo obbligatorio in una eccezione, e non e' stato definito");
  854.                         }
  855.                     }


  858.                     if(ecc.getRilevanza() != null) {
  859.                         boolean generazioneAttributo = true;
  860.                         if(!forzaValidazioneXSDElementiDisabilitata){
  861.                             if(this.protocolManager.isGenerazioneElementiNonValidabiliRispettoXSD()==false){
  862.                                 generazioneAttributo = ( LivelloRilevanza.DEBUG.equals(ecc.getRilevanza()) || 
  863.                                         LivelloRilevanza.ERROR.equals(ecc.getRilevanza()) || 
  864.                                         LivelloRilevanza.FATAL.equals(ecc.getRilevanza()) || 
  865.                                         LivelloRilevanza.INFO.equals(ecc.getRilevanza()) || 
  866.                                         LivelloRilevanza.WARN.equals(ecc.getRilevanza()) );
  867.                             }
  868.                         }
  869.                         if(generazioneAttributo){
  870.                             eccezione.setAttribute("rilevanza",this.traduttore.toString(ecc.getRilevanza()));
  871.                         }
  872.                         else{
  873.                             throw new ProtocolException("Rilevanza e' un attributo obbligatorio in una eccezione, e il valore non e' utilizzabile rispetto all'xsd ("+ecc.getRilevanza()+")");
  874.                         }
  875.                     }
  876.                     else{
  877.                         if(verificaPresenzaElementiObbligatori){
  878.                             throw new ProtocolException("Rilevanza e' un attributo obbligatorio in una eccezione, e non e' stato definito");
  879.                         }
  880.                     }

  882.                     if(ecc.getDescrizione(this.factory) != null) {
  883.                         eccezione.setAttribute("posizione",ecc.getDescrizione(this.factory));
  884.                     }
  885.                     else{
  886.                         if(verificaPresenzaElementiObbligatori){
  887.                             throw new ProtocolException("Posizione e' un attributo obbligatorio in una eccezione, e non e' stato definito");
  888.                         }
  889.                     }
  890.                     
  891.                 }
  892.             }

  894.             return eGovHeader;      
  895.         } catch(Exception e) {
  896.             this.log.error("Creazione busta eGov non riuscita: "+e.getMessage(),e);
  897.             throw new ProtocolException("Creazione busta eGov non riuscita: "+e.getMessage(),e);
  898.         }   
  899.     }



  903.     private String normalizeIdRefManifest(String contentId) {
  904.         StringBuilder bf = new StringBuilder();
  905.         if(this.spcoopProperties.isGenerateManifestAttachmentsIdWithBrackets()) {
  906.             if(contentId.startsWith("<")==false) {
  907.                 bf.append("<");
  908.             }
  909.             bf.append(contentId);
  910.             if(contentId.endsWith(">")==false) {
  911.                 bf.append(">");
  912.             }
  913.         }
  914.         else {
  915.             int start = 0;
  916.             int end = contentId.length();
  917.             if(contentId.startsWith("<")) {
  918.                 start = 1;
  919.             }
  920.             if(contentId.endsWith(">")) {
  921.                 end = contentId.length()-1;
  922.             }
  923.             bf.append(contentId.substring(start,end));
  924.         }
  925.         return bf.toString();
  926.     }

  928.     /**
  929.      * Metodo che si occupa di costruire un Manifest per gli Attachments 
  930.      * definito nella specifica eGov 
  931.      * 'http://www.cnipa.it/schemas/2003/eGovIT/Busta1_0/'.
  932.      * <p>
  933.      * Gli attachments da linkare, all'interno del Manifesto sono prelevati
  934.      * dall'oggetto <var>msg</var>.
  935.      *
  936.      * @param msg Messaggio su cui creare il manifesto
  937.      * @param ruoloMessaggio Tipo di Busta
  938.      * 
  939.      */
  940.     public OpenSPCoop2Message build_eGovManifest(OpenSPCoop2Message msg,RuoloMessaggio ruoloMessaggio,
  941.             ProprietaManifestAttachments proprietaManifestAttachments) throws ProtocolException{ 
  942.         try{

  944.             // Descrizione
  945.             SOAPElement descrizione = msg.getFactory().createEmptyMessage(MessageType.SOAP_11,MessageRole.NONE).castAsSoap().
  946.                     getSOAPBody().addChildElement(new QName(SPCoopCostanti.NAMESPACE_EGOV, "Descrizione",SPCoopCostanti.PREFIX_EGOV));
  947.             
  948.             OpenSPCoop2SoapMessage soapMsg = msg.castAsSoap(); 

  950.             // Attachments
  951.             java.util.Iterator<?> iter = soapMsg.getAttachments();
  952.             int attach = 1;
  953.             while( iter.hasNext() ){
  954.                 Utilities.printFreeMemory("Imbustamento - Costruzione manifest att " + attach);
  955.                 AttachmentPart p = (AttachmentPart) iter.next();
  956.                 String contentID = p.getContentId();
  957.                 String contentLocation = p.getContentLocation();
  958.                 //String fileName = p.getAttachmentFile();
  959.                 String contentType = p.getContentType();
  960.                 // Costruzione DescrizioneMessaggio
  961.                 SOAPElement descrizioneMessaggio =  descrizione.addChildElement(SPCoopCostanti.LOCAL_NAME_MANIFEST_EGOV_DESCRIZIONE_MESSAGGIO,
  962.                         SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  963.                 // Costruzione Riferimento
  964.                 SOAPElement riferimento =  descrizioneMessaggio.addChildElement("Riferimento",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  965.                 
  966.                 //Name href = sf.createName("href",Costanti.PREFIX_EGOV,Costanti.NAMESPACE_EGOV); 
  967.                 
  968.                 if(contentID!=null){
  969.                     riferimento.setAttribute("href","cid:"+normalizeIdRefManifest(contentID)); // xsd:anyURI
  970.                 }
  971.                 else{
  972.                     riferimento.setAttribute("href",contentLocation); // xsd:anyURI
  973.                 }

  975.                 //Name role = sf.createName("role",Costanti.PREFIX_EGOV,Costanti.NAMESPACE_EGOV); 
  976.                 
  977.                 if(attach==1 && proprietaManifestAttachments.isScartaBody()){
  978.                     
  979.                     if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)){
  980.                         riferimento.setAttribute("role",this.spcoopProperties.getRoleRichiestaManifest()); // xsd:string
  981.                     }
  982.                     else{
  983.                         riferimento.setAttribute("role",this.spcoopProperties.getRoleRispostaManifest()); // xsd:string
  984.                     }
  985.                 }
  986.                 else{
  987.                     riferimento.setAttribute("role",this.spcoopProperties.getRoleAllegatoManifest()); // xsd:string
  988.                 }
  989.                 // Obbligatorio il namespace
  990.                 
  991.                 // ??? riferimento.setAttribute(Costanti.NAMESPACE_EGOV,"id","attachment"+attach); // xsd:ID
  992.                 QName id = new QName(SPCoopCostanti.NAMESPACE_EGOV,"id",SPCoopCostanti.PREFIX_EGOV); 
  993.                 riferimento.addAttribute(id,"attachment"+attach); // xsd:ID
  994.                 // Costruzione Schema
  995.                 SOAPElement schema = riferimento.addChildElement("Schema",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  996.                 schema.setAttribute("posizione",contentType); //xsd:anyURI
  997.                 // Costruzione Titolo
  998.                 SOAPElement titolo = riferimento.addChildElement("Titolo",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  999.                 titolo.setAttribute("Lingua","it"); //xsd:language
  1000.                 //if(fileName!=null)
  1001.                 //  titolo.setValue(fileName); // xsd:string
  1002.                 //else
  1003.                 if(attach==1 && proprietaManifestAttachments.isScartaBody()){
  1004.                     if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio))
  1005.                         titolo.setValue(this.spcoopProperties.getRoleRichiestaManifest()); // xsd:string
  1006.                     else
  1007.                         titolo.setValue(this.spcoopProperties.getRoleRispostaManifest()); // xsd:string
  1008.                 }else{
  1009.                     titolo.setValue("attachment"+attach); // xsd:string
  1010.                 }
  1011.                 attach++;
  1012.             }
  1013.             

  1015.             // Body into Attachments
  1016.             if(proprietaManifestAttachments.isScartaBody() == false){
  1017.                 Utilities.printFreeMemory("Imbustamento - Scarta Body");
  1018.                 byte [] body = TunnelSoapUtils.sbustamentoSOAPEnvelope(soapMsg.getFactory(), soapMsg.getSOAPPart().getEnvelope());
  1019.                 AttachmentPart ap = null;
  1020.                 //ByteArrayInputStream isContent = new ByteArrayInputStream(body);
  1021.                 //ap.setContent(isContent,"text/xml; charset=UTF-8");
  1022. //                  String xmlBody = new String(body);
  1023.                 //xmlBody = StringEscapeUtils.unescapeXml(xmlBody);
  1024. //                  Reader stringReader = new StringReader(xmlBody);
  1025.                 //Source streamSource = new javax.xml.transform.stream.StreamSource(new java.io.ByteArrayInputStream(body)); FIX: StreamSource instances may only be used once.
  1026.                 //System.out.println("BODY IS :["+new String(body)+"] ["+body.length+"]");
  1027.                 boolean bodyWithMultiRootElement = false;
  1028.                 if(body==null || body.length==0){
  1029.                     body = SPCoopCostanti.XML_MANIFEST_EGOV_EMPTY_BODY.getBytes();
  1030.                     //System.out.println("PATCH ["+new String(body)+"]");
  1031.                 }
  1032.                 else{
  1033.                     List<Node> listNode = SoapUtils.getNotEmptyChildNodes(soapMsg.getFactory(), soapMsg.getSOAPPart().getEnvelope().getBody(), false);
  1034.                     if(listNode!=null && listNode.size()>1){
  1035.                         //System.out.println("MULTI ELEMENT: "+listNode.size());
  1036.                         bodyWithMultiRootElement = true;
  1037.                     }
  1038.                 }
  1039.                 if(bodyWithMultiRootElement){
  1040.                     //System.out.println("OCTECT");
  1041.                     InputStreamDataSource isSource = new InputStreamDataSource("ManifestEGov", HttpConstants.CONTENT_TYPE_APPLICATION_OCTET_STREAM, body);
  1042.                     ap = soapMsg.createAttachmentPart(new DataHandler(isSource));
  1043.                 }else{
  1044.                     if(MailcapActivationReader.existsDataContentHandler(HttpConstants.CONTENT_TYPE_TEXT_XML)){
  1045.                         ap = soapMsg.createAttachmentPart();
  1046.                         soapMsg.updateAttachmentPart(ap, body, HttpConstants.CONTENT_TYPE_TEXT_XML);
  1047.                     }
  1048.                     else {
  1049.                         InputStreamDataSource isSource = new InputStreamDataSource("ManifestEGov", HttpConstants.CONTENT_TYPE_TEXT_XML, body);
  1050.                         ap = soapMsg.createAttachmentPart(new DataHandler(isSource));
  1051.                     }
  1052.                 }
  1053.                 ap.setContentId(soapMsg.createContentID(SPCoopCostanti.NAMESPACE_EGOV));
  1054.                 //ap.setContentLocation("provaOpenSPCoop"); // Test Sbustamento con ContentLocation
  1055.                 soapMsg.addAttachmentPart(ap);
  1056.                 //isContent.close();
  1057.                 // add OriginalMsg in Manifest
  1058.                 // Costruzione DescrizioneMessaggio
  1059.                 SOAPElement descrizioneMessaggio = descrizione.addChildElement(SPCoopCostanti.LOCAL_NAME_MANIFEST_EGOV_DESCRIZIONE_MESSAGGIO,
  1060.                         SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1061.                 // Costruzione Riferimento
  1062.                 SOAPElement riferimento = descrizioneMessaggio.addChildElement("Riferimento",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1063.                 riferimento.setAttribute("href","cid:" + normalizeIdRefManifest(ap.getContentId())); // xsd:anyURI
  1064.                 //riferimento.setAttribute("href",ap.getContentLocation()); // xsd:anyURI // Test Sbustamento con ContentLocation
  1065.                 if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)){
  1066.                     riferimento.setAttribute("role",this.spcoopProperties.getRoleRichiestaManifest()); // xsd:string
  1067.                 }
  1068.                 else{
  1069.                     riferimento.setAttribute("role",this.spcoopProperties.getRoleRispostaManifest()); // xsd:string
  1070.                 }
  1071.                 // Obbligatorio il namespace
  1072.                 //riferimento.setAttribute(Costanti.NAMESPACE_EGOV,"id","attachment"+attach); // xsd:ID
  1073.                 QName id = new QName(SPCoopCostanti.NAMESPACE_EGOV,"id",SPCoopCostanti.PREFIX_EGOV); 
  1074.                 riferimento.addAttribute(id,"attachment"+attach); // xsd:ID
  1075.                 // Costruzione Schema
  1076.                 SOAPElement schema = riferimento.addChildElement("Schema",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1077.                 schema.setAttribute("posizione",ap.getContentType()); //xsd:anyURI
  1078.                 // Costruzione Titolo
  1079.                 SOAPElement titolo = riferimento.addChildElement("Titolo",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1080.                 titolo.setAttribute("Lingua","it"); //xsd:language
  1081.                 if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio))
  1082.                     titolo.setValue(this.spcoopProperties.getRoleRichiestaManifest()); // xsd:string
  1083.                 else
  1084.                     titolo.setValue(this.spcoopProperties.getRoleRispostaManifest()); // xsd:string

  1086.             }
  1087.             Utilities.printFreeMemory("Imbustamento - Add Manifest in Body");
  1088.             // Add Manifest in Body
  1089.             soapMsg.getSOAPBody().removeContents();
  1090.             soapMsg.getSOAPBody().addChildElement(descrizione);


  1093.             return msg;

  1095.         } catch(Exception e) {
  1096.             this.log.error("Creazione Manifest degli attachments non riuscita: "+e.getMessage(),e);
  1097.             throw new ProtocolException("Creazione Manifest degli attachments non riuscita: "+e.getMessage(),e);
  1098.         }   
  1099.     }


  1102.     public void imbustamentoEGov(OpenSPCoop2Message msg,Busta busta,ProprietaManifestAttachments proprietaManifestAttachments) throws ProtocolException{    
  1103.         this.imbustamentoEGov(msg, busta, RuoloMessaggio.RISPOSTA, proprietaManifestAttachments);
  1104.     }


  1107.     public SOAPHeaderElement imbustamentoEGov(OpenSPCoop2Message msg,Busta busta,
  1108.             RuoloMessaggio ruoloMessaggio,
  1109.             ProprietaManifestAttachments proprietaManifestAttachments) throws ProtocolException{    

  1111.         try{
  1112.             // add header eGov
  1113.             Utilities.printFreeMemory("Imbustamento - Creazione header eGov");
  1114.             SOAPHeaderElement headerEGovElement = (SOAPHeaderElement) this.build_eGovHeader(msg, busta);
  1115.             Utilities.printFreeMemory("Imbustamento - imbustamento");
  1116.             this.imbustamentoEGov(msg, headerEGovElement, ruoloMessaggio, proprietaManifestAttachments);
  1117.             return headerEGovElement;
  1118.         }catch(Exception e){
  1119.             this.log.error("ImbustamentoEGov non riuscito: "+e.getMessage(),e);
  1120.             throw new ProtocolException("ImbustamentoEGov non riuscito: "+e.getMessage(),e);
  1121.         }
  1122.     }

  1124.     public SOAPHeaderElement imbustamentoEGov(OpenSPCoop2Message msg, SOAPHeaderElement headerEGovElement,
  1125.             RuoloMessaggio ruoloMessaggio,
  1126.             ProprietaManifestAttachments proprietaManifestAttachments) throws ProtocolException{    

  1128.         try{
  1129.             OpenSPCoop2SoapMessage soapMsg = msg.castAsSoap();
  1130.             
  1131.             SOAPHeader hdr = soapMsg.getSOAPHeader();
  1132.             if(hdr==null){
  1133.                 hdr = soapMsg.getSOAPPart().getEnvelope().addHeader(); 
  1134.             }

  1136.             soapMsg.addHeaderElement(hdr, headerEGovElement);
  1137.             Utilities.printFreeMemory("Imbustamento -Header Aggiunto");
  1138.             // Gestione Manifest
  1139.             
  1140.             if (proprietaManifestAttachments!=null && proprietaManifestAttachments.isGestioneManifest() && soapMsg.countAttachments()>0) {
  1141.                 Utilities.printFreeMemory("Imbustamento - Gestione Manifest");
  1142.                 this.build_eGovManifest(msg,ruoloMessaggio,proprietaManifestAttachments);
  1143.             }
  1144.             
  1145.             //System.out.println("MSG:");
  1146.             //msg.writeTo(System.out);
  1147.             
  1148.             return headerEGovElement;
  1149.             
  1150.         }catch(Exception e){
  1151.             this.log.error("ImbustamentoEGov non riuscito: "+e.getMessage(),e);
  1152.             throw new ProtocolException("ImbustamentoEGov non riuscito: "+e.getMessage(),e);
  1153.         }
  1154.     }


  1157.     /**
  1158.      * Metodo che si occupa di costruire un elemento Trasmissione
  1159.      *
  1160.      * @param trasmissione Trasmissione
  1161.      * 
  1162.      */
  1163.     public void build_trasmissione(Trasmissione trasmissione,SOAPElement listaTrasmissioni) throws ProtocolException{ 
  1164.         try{

  1166.             SOAPElement trasmissioneNode = listaTrasmissioni.addChildElement("Trasmissione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);

  1168.             SOAPElement orig = trasmissioneNode.addChildElement("Origine",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1169.             SOAPElement IDParteOrigine = orig.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1170.             IDParteOrigine.setValue(trasmissione.getOrigine());
  1171.             IDParteOrigine.setAttribute("tipo",trasmissione.getTipoOrigine());
  1172.             if(trasmissione.getIndirizzoOrigine() != null){
  1173.                 IDParteOrigine.setAttribute("indirizzoTelematico",trasmissione.getIndirizzoOrigine());
  1174.             }

  1176.             SOAPElement dest = trasmissioneNode.addChildElement("Destinazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1177.             SOAPElement IDParteDest = dest.addChildElement("IdentificativoParte",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1178.             IDParteDest.setValue(trasmissione.getDestinazione());
  1179.             IDParteDest.setAttribute("tipo",trasmissione.getTipoDestinazione());
  1180.             if(trasmissione.getIndirizzoDestinazione() != null){
  1181.                 IDParteDest.setAttribute("indirizzoTelematico",trasmissione.getIndirizzoDestinazione());
  1182.             }

  1184.             SOAPElement ora = trasmissioneNode.addChildElement("OraRegistrazione",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1185.             ora.setValue(SPCoopUtils.getDate_eGovFormat(trasmissione.getOraRegistrazione()));
  1186.             if(TipoOraRegistrazione.LOCALE.equals(trasmissione.getTempo()))
  1187.                 ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_LOCALE);
  1188.             else if(TipoOraRegistrazione.SINCRONIZZATO.equals(trasmissione.getTempo()))
  1189.                 ora.setAttribute("tempo",SPCoopCostanti.TIPO_TEMPO_SPC);
  1190.             else
  1191.                 ora.setAttribute("tempo",trasmissione.getTempoValue(this.factory));

  1193.         } catch(Exception e) {
  1194.             this.log.error("Creazione trasmissione non riuscita: "+e.getMessage(),e);
  1195.             throw new ProtocolException("Creazione trasmissione non riuscita: "+e.getMessage(),e);
  1196.         }   
  1197.     }


  1200.     public SOAPHeaderElement addTrasmissione(OpenSPCoop2Message message,Trasmissione trasmissione,boolean readQualifiedAttribute)throws ProtocolException{
  1201.         SOAPHeaderElement eGovHeaderOLD = null;
  1202.         SOAPHeaderElement eGovHeaderNEW = null;
  1203.         try{
  1204.             
  1205.             SPCoopBustaRawContent bustaElement = this.validazioneSintattica.getHeaderEGov(message.castAsSoap(),readQualifiedAttribute);
  1206.             if(bustaElement==null){
  1207.                 throw new ProtocolException("Header eGov non esistente");
  1208.             }
  1209.             eGovHeaderOLD = bustaElement.getElement();
  1210.             if(eGovHeaderOLD==null){
  1211.                 throw new ProtocolException("Header eGov non esistente");
  1212.             }

  1214.             OpenSPCoop2SoapMessage soapMsg = message.castAsSoap();
  1215.             
  1216.             // Creo nuovo header egov
  1217.             eGovHeaderNEW = 
  1218.                     message.getFactory().createEmptyMessage(MessageType.SOAP_11,MessageRole.NONE).castAsSoap().
  1219.                     getSOAPHeader().addHeaderElement(
  1220.                         new QName(eGovHeaderOLD.getNamespaceURI(),eGovHeaderOLD.getLocalName(),eGovHeaderOLD.getPrefix()));
  1221.             
  1222.             eGovHeaderNEW.setActor(eGovHeaderOLD.getActor());
  1223.             eGovHeaderNEW.setMustUnderstand(eGovHeaderOLD.getMustUnderstand());
  1224.             // Aggiungo dichiarazioni di namespaces
  1225.             java.util.Iterator<?> namespaces = eGovHeaderOLD.getNamespacePrefixes();
  1226.             while(namespaces.hasNext()){
  1227.                 String mNamespace = (String) namespaces.next();
  1228.                 eGovHeaderNEW.addNamespaceDeclaration(mNamespace, eGovHeaderOLD.getNamespaceURI(mNamespace));
  1229.             }
  1230.             // Aggiungo attributi presenti nel vecchio nel nuovo
  1231.             java.util.Iterator<?> attributes = eGovHeaderOLD.getAllAttributes();
  1232.             while(attributes.hasNext()){
  1233.                 javax.xml.soap.Name mAttribute = (javax.xml.soap.Name) attributes.next();
  1234.                 eGovHeaderNEW.addAttribute(mAttribute, eGovHeaderOLD.getAttributeValue(mAttribute));
  1235.             }
  1236.             // Aggiungo figli presenti nel vecchio, nel nuovo
  1237.             java.util.Iterator<?> child = eGovHeaderOLD.getChildElements();
  1238.             while(child.hasNext()){
  1239.                 Object oChild = child.next();
  1240.                 if(oChild instanceof SOAPElement){
  1241.                     SOAPElement mChild = (SOAPElement) oChild;
  1242.                     eGovHeaderNEW.addChildElement(mChild);
  1243.                 }
  1244.             }
  1245.             // Cerco eventuale lista trasmissioni
  1246.             child = eGovHeaderNEW.getChildElements();
  1247.             SOAPElement listaTrasmissioni = null;
  1248.             while(child.hasNext()){
  1249.                 SOAPElement mChild = (SOAPElement) child.next();
  1250.                 if("ListaTrasmissioni".equals(mChild.getLocalName())){
  1251.                     listaTrasmissioni = mChild;
  1252.                     break;
  1253.                 }
  1254.             }
  1255.             if(listaTrasmissioni==null){
  1256.                 listaTrasmissioni = eGovHeaderNEW.addChildElement("ListaTrasmissioni",SPCoopCostanti.PREFIX_EGOV,SPCoopCostanti.NAMESPACE_EGOV);
  1257.             }
  1258.             // Aggiungo nuova trasmissione
  1259.             this.build_trasmissione(trasmissione, listaTrasmissioni);


  1262.             // NOTA: ho dovuto effettuare una eliminazione, e una ri-creazione, perche' non e' possibile modificare un HeaderElement
  1263.             // Rimozione header egov
  1264.             soapMsg.getSOAPHeader().removeChild(eGovHeaderOLD);

  1266.             // Imbustamento nuovo header
  1267.             return this.imbustamentoEGov(message, eGovHeaderNEW, RuoloMessaggio.RISPOSTA, null);

  1269.         } catch(Exception e) {
  1270.             this.log.error("addTrasmissione non riuscita: "+e.getMessage(),e);
  1271.             throw new ProtocolException("addTrasmissione non riuscita: "+e.getMessage(),e);
  1272.         }   
  1273.         finally{
  1274.             // *** GB ***
  1275.             if(this.validazioneSintattica!=null){
  1276.                 this.validazioneSintattica.setHeaderSOAP(null);
  1277.             }
  1278.             eGovHeaderOLD = null;
  1279.             eGovHeaderNEW = null;
  1280.             // *** GB ***
  1281.         }
  1282.     }




  1287.     

  1289.     public SOAPHeaderElement imbustamento(OpenSPCoop2Message msg, Busta busta,
  1290.             RuoloMessaggio ruoloMessaggio,
  1291.             ProprietaManifestAttachments proprietaManifestAttachments)
  1292.             throws ProtocolException {
  1293.         if(busta.getProfiloDiCollaborazione() != null) {
  1294.             switch (busta.getProfiloDiCollaborazione()) {
  1295.             case ONEWAY:
  1296.                 busta.setProfiloDiCollaborazione(ProfiloDiCollaborazione.ONEWAY, SPCoopCostanti.PROFILO_COLLABORAZIONE_ONEWAY);
  1297.                 break;
  1298.             case SINCRONO:
  1299.                 busta.setProfiloDiCollaborazione(ProfiloDiCollaborazione.SINCRONO, SPCoopCostanti.PROFILO_COLLABORAZIONE_SINCRONO);
  1300.                 break;
  1301.             case ASINCRONO_ASIMMETRICO:
  1302.                 busta.setProfiloDiCollaborazione(ProfiloDiCollaborazione.ASINCRONO_ASIMMETRICO, SPCoopCostanti.PROFILO_COLLABORAZIONE_ASINCRONO_ASIMMETRICO);
  1303.                 break;
  1304.             case ASINCRONO_SIMMETRICO:
  1305.                 busta.setProfiloDiCollaborazione(ProfiloDiCollaborazione.ASINCRONO_SIMMETRICO, SPCoopCostanti.PROFILO_COLLABORAZIONE_ASINCRONO_SIMMETRICO);
  1306.                 break;
  1307.             case UNKNOWN:
  1308.                 break;
  1309.             }
  1310.         }
  1311.         
  1312.         if(busta.getTipoOraRegistrazione() != null) {
  1313.             switch (busta.getTipoOraRegistrazione()) {
  1314.             case LOCALE:
  1315.                 busta.setTipoOraRegistrazione(TipoOraRegistrazione.LOCALE,SPCoopCostanti.TIPO_TEMPO_LOCALE);
  1316.                 break;
  1317.             case SINCRONIZZATO:
  1318.                 busta.setTipoOraRegistrazione(TipoOraRegistrazione.SINCRONIZZATO,SPCoopCostanti.TIPO_TEMPO_SPC);
  1319.                 break;
  1320.             case UNKNOWN:
  1321.                 break;
  1322.             }
  1323.         }
  1324.         
  1325.         if(busta.getInoltro() != null) {
  1326.             switch (busta.getInoltro()) {
  1327.             case CON_DUPLICATI:
  1328.                 busta.setInoltro(Inoltro.CON_DUPLICATI, SPCoopCostanti.PROFILO_TRASMISSIONE_CON_DUPLICATI);
  1329.                 break;
  1330.             case SENZA_DUPLICATI:
  1331.                 busta.setInoltro(Inoltro.SENZA_DUPLICATI, SPCoopCostanti.PROFILO_TRASMISSIONE_SENZA_DUPLICATI);
  1332.                 break;
  1333.             case UNKNOWN:
  1334.                 break;
  1335.             }
  1336.         }
  1337.         
  1338.         Iterator<Riscontro> riscontri = busta.getListaRiscontri().iterator();
  1339.         while(riscontri.hasNext()){
  1340.             Riscontro riscontro = riscontri.next();
  1341.             if(riscontro.getTipoOraRegistrazione() == null) continue;
  1342.             if(riscontro.getTipoOraRegistrazione().equals(TipoOraRegistrazione.LOCALE)) 
  1343.                 riscontro.setTipoOraRegistrazioneValue(SPCoopCostanti.TIPO_TEMPO_LOCALE);
  1344.             if(riscontro.getTipoOraRegistrazione().equals(TipoOraRegistrazione.SINCRONIZZATO)) 
  1345.                 riscontro.setTipoOraRegistrazioneValue(SPCoopCostanti.TIPO_TEMPO_SPC);
  1346.         }
  1347.         
  1348.         Iterator<Trasmissione> trasmissioni = busta.getListaTrasmissioni().iterator();
  1349.         while(trasmissioni.hasNext()){
  1350.             Trasmissione trasmissione = trasmissioni.next();
  1351.             if(trasmissione.getTempo() == null) continue;
  1352.             
  1353.             if(trasmissione.getTempo().equals(TipoOraRegistrazione.LOCALE)) 
  1354.                 trasmissione.setTempoValue(SPCoopCostanti.TIPO_TEMPO_LOCALE);
  1355.             else  
  1356.                 trasmissione.setTempoValue(SPCoopCostanti.TIPO_TEMPO_SPC);
  1357.              
  1358.         }
  1359.             
  1360.         return this.imbustamentoEGov(msg, busta, ruoloMessaggio, proprietaManifestAttachments);
  1361.     }

  1363.     public SOAPHeaderElement addTrasmissione(OpenSPCoop2Message message,
  1364.             Trasmissione trasmissione) throws ProtocolException {
  1365.         return this.addTrasmissione(message, trasmissione, false);
  1366.     }

  1368. }




Created with JaCoCo 0.8.8.202204050719