UtilitiesIntegrazioneBC.java
/*
* GovWay - A customizable API Gateway
* https://govway.org
*
* Copyright (c) 2005-2024 Link.it srl (https://link.it).
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 3, as published by
* the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
package org.openspcoop2.pdd.core.integrazione.backward_compatibility;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.xml.namespace.QName;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPHeaderElement;
import org.apache.commons.lang.StringUtils;
import org.openspcoop2.core.constants.CostantiLabel;
import org.openspcoop2.core.id.IDServizio;
import org.openspcoop2.core.id.IDSoggetto;
import org.openspcoop2.message.OpenSPCoop2MessageFactory;
import org.openspcoop2.message.OpenSPCoop2SoapMessage;
import org.openspcoop2.message.constants.MessageType;
import org.openspcoop2.message.exception.MessageNotSupportedException;
import org.openspcoop2.message.soap.SoapUtils;
import org.openspcoop2.message.xml.ValidatoreXSD;
import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
import org.openspcoop2.pdd.core.CostantiPdD;
import org.openspcoop2.pdd.core.PdDContext;
import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazione;
import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazioneBusta;
import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazioneException;
import org.openspcoop2.pdd.core.integrazione.UtilitiesIntegrazione;
import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
import org.openspcoop2.utils.MapKey;
import org.openspcoop2.utils.transport.TransportUtils;
import org.openspcoop2.utils.transport.http.HttpConstants;
import org.openspcoop2.utils.xml.XSDResourceResolver;
import org.slf4j.Logger;
/**
* Classe contenenti utilities per le integrazioni.
*
* @author Poli Andrea (apoli@link.it)
* @author $Author$
* @version $Rev$, $Date$
*/
public class UtilitiesIntegrazioneBC {
/** Costante che indica il valore dell'header X che indica la versione della PdD*/
public static final String OPENSPCOOP2_HEADER_HTTP_X_PDD = "X-OpenSPCoop2-Pdd";
/** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP2_HEADER_HTTP_X_PDD_DETAILS = "X-OpenSPCoop2-PddDetails";
/** Costante che indica il valore dell'header X che indica la versione della PdD*/
public static final String OPENSPCOOP2_URL_BASED_PDD = "OpenSPCoop2Pdd";
/** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP2_URL_BASED_PDD_DETAILS = "OpenSPCoop2PddDetails";
/** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica la versione della PdD*/
public static final String OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION = "OpenSPCoop2Pdd";
/** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS = "OpenSPCoop2PddDetails";
/** Costante che indica il valore dell'header X che indica la versione della PdD*/
public static final String OPENSPCOOP1_HEADER_HTTP_X_PDD = "X-SPCoop-Pdd";
/** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP1_HEADER_HTTP_X_PDD_DETAILS = "X-SPCoop-PddDetails";
/** Costante che indica il valore dell'header X che indica la versione della PdD*/
public static final String OPENSPCOOP1_URL_BASED_PDD = "SPCoopPdd";
/** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP1_URL_BASED_PDD_DETAILS = "SPCoopDettagliPdd";
/** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica la versione della PdD*/
public static final String OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION = "SPCoopPdd";
/** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica il dettaglio della versione della PdD*/
public static final String OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS = "SPCoopPddDetails";
// ***** STATIC *****
private static final boolean PORTA_DELEGATA = true;
private static final boolean PORTA_APPLICATIVA = false;
private static final boolean REQUEST = true;
private static final boolean RESPONSE = false;
public static final boolean OPENSPCOOP_V2 = true;
public static final boolean OPENSPCOOP_V1 = false;
public static final boolean X_PREFIX = true;
public static final boolean NOT_X_PREFIX = false;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op2_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op2 = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op1_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op1 = null;
public static UtilitiesIntegrazioneBC getInstancePDRequest(Logger log, boolean openspcoop2, boolean x_prefix){
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2;
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1;
}
}
}
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op2_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op2 = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op1_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op1 = null;
public static UtilitiesIntegrazioneBC getInstancePDResponse(Logger log, boolean openspcoop2, boolean x_prefix){
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2;
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1;
}
}
}
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op2_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op2 = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op1_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op1 = null;
public static UtilitiesIntegrazioneBC getInstancePARequest(Logger log, boolean openspcoop2, boolean x_prefix){
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2;
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1;
}
}
}
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op2_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op2 = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op1_xPrefix = null;
private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op1 = null;
public static UtilitiesIntegrazioneBC getInstancePAResponse(Logger log, boolean openspcoop2, boolean x_prefix){
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2;
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix;
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1==null){
// spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
synchronized (UtilitiesIntegrazioneBC.class) {
UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
}
}
return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1;
}
}
}
private static synchronized void initialize(Logger log,boolean portaDelegata, boolean request, boolean openspcoop2, boolean x_prefix){
if(portaDelegata) {
if(request) {
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
}
else {
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
}
}
else {
if(request) {
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
}
else {
if(openspcoop2) {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
else {
if(x_prefix) {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
else {
if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1==null){
UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
}
}
}
}
}
}
// ***** INSTANCE *****
private List<MapKey<String>> keywordsIntegrazione = null;
private Map<MapKey<String>, String> keyValueIntegrazioneTrasporto = null;
private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneTrasporto = null;
private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneTrasporto = null;
private Map<MapKey<String>, String> keyValueIntegrazioneUrlBased = null;
private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneUrlBased = null;
private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneUrlBased = null;
private Map<MapKey<String>, String> keyValueIntegrazioneSoap = null;
private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneSoap = null;
private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneSoap = null;
private OpenSPCoop2Properties openspcoopProperties = null;
private Map<String, ValidatoreXSD> validatoreXSD_soap11_map = new HashMap<String, ValidatoreXSD>();
private Map<String, ValidatoreXSD> validatoreXSD_soap12_map = new HashMap<String, ValidatoreXSD>();
private Map<String, String> govway2openspcoop_Mapping_trasparente_soggetto = null;
private Map<String, String> govway2openspcoop_Mapping_trasparente_servizio = null;
private Map<String, String> govway2openspcoop_Mapping_spcoop_soggetto = null;
private Map<String, String> govway2openspcoop_Mapping_spcoop_servizio = null;
private Map<String, String> govway2openspcoop_Mapping_sdi_soggetto = null;
private Map<String, String> govway2openspcoop_Mapping_sdi_servizio = null;
private Map<String, String> openspcoop2govway_Mapping_trasparente_soggetto = null;
private Map<String, String> openspcoop2govway_Mapping_trasparente_servizio = null;
private Map<String, String> openspcoop2govway_Mapping_spcoop_soggetto = null;
private Map<String, String> openspcoop2govway_Mapping_spcoop_servizio = null;
private Map<String, String> openspcoop2govway_Mapping_sdi_soggetto = null;
private Map<String, String> openspcoop2govway_Mapping_sdi_servizio = null;
private boolean request;
private boolean openspcoop2;
private boolean x_prefix;
private Logger log;
private UtilitiesIntegrazioneBC(Logger log, boolean portaDelegata, boolean request, boolean openspcoop2, boolean x_prefix){
this.log = log;
this.openspcoopProperties = OpenSPCoop2Properties.getInstance();
this.request = request;
this.openspcoop2 = openspcoop2;
this.x_prefix = x_prefix;
this.keywordsIntegrazione = this.openspcoopProperties.getKeywordsIntegrazione();
this.keywordsIntegrazione.remove(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO);
if(!this.openspcoop2) {
this.keywordsIntegrazione.remove(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE);
}
if(this.openspcoop2) {
this.keyValueIntegrazioneTrasporto = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneTrasporto_backwardCompatibility_openspcoop2();
}
else {
this.keyValueIntegrazioneTrasporto = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneTrasporto_backwardCompatibility_openspcoop1();
}
try{
if(portaDelegata) {
this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneTrasporto(request);
this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneTrasporto();
}
else {
this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneTrasporto(request);
this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneTrasporto();
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
if(this.openspcoop2) {
this.keyValueIntegrazioneUrlBased = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneUrlBased_backwardCompatibility_openspcoop2();
}
else {
this.keyValueIntegrazioneUrlBased = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneUrlBased_backwardCompatibility_openspcoop1();
}
try{
if(portaDelegata) {
this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneUrlBased();
this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneUrlBased();
}
else {
this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneUrlBased();
this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneUrlBased();
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
if(this.openspcoop2) {
this.keyValueIntegrazioneSoap = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneSoap_backwardCompatibility_openspcoop2();
}
else {
this.keyValueIntegrazioneSoap = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneSoap_backwardCompatibility_openspcoop1();
}
try{
if(portaDelegata) {
this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneSoap(request);
this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneSoap();
}
else {
this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneSoap(request);
this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneSoap();
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_trasparente_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_trasparente_soggetto();
if(this.govway2openspcoop_Mapping_trasparente_soggetto!=null && !this.govway2openspcoop_Mapping_trasparente_soggetto.isEmpty()) {
this.openspcoop2govway_Mapping_trasparente_soggetto = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_trasparente_soggetto.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_trasparente_soggetto.get(govway);
this.openspcoop2govway_Mapping_trasparente_soggetto.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_trasparente_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_trasparente_servizio();
if(this.govway2openspcoop_Mapping_trasparente_servizio!=null && !this.govway2openspcoop_Mapping_trasparente_servizio.isEmpty()) {
this.openspcoop2govway_Mapping_trasparente_servizio = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_trasparente_servizio.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_trasparente_servizio.get(govway);
this.openspcoop2govway_Mapping_trasparente_servizio.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_spcoop_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_spcoop_soggetto();
if(this.govway2openspcoop_Mapping_spcoop_soggetto!=null && !this.govway2openspcoop_Mapping_spcoop_soggetto.isEmpty()) {
this.openspcoop2govway_Mapping_spcoop_soggetto = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_spcoop_soggetto.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_spcoop_soggetto.get(govway);
this.openspcoop2govway_Mapping_spcoop_soggetto.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_spcoop_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_spcoop_servizio();
if(this.govway2openspcoop_Mapping_spcoop_servizio!=null && !this.govway2openspcoop_Mapping_spcoop_servizio.isEmpty()) {
this.openspcoop2govway_Mapping_spcoop_servizio = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_spcoop_servizio.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_spcoop_servizio.get(govway);
this.openspcoop2govway_Mapping_spcoop_servizio.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_sdi_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_sdi_soggetto();
if(this.govway2openspcoop_Mapping_sdi_soggetto!=null && !this.govway2openspcoop_Mapping_sdi_soggetto.isEmpty()) {
this.openspcoop2govway_Mapping_sdi_soggetto = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_sdi_soggetto.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_sdi_soggetto.get(govway);
this.openspcoop2govway_Mapping_sdi_soggetto.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
try {
this.govway2openspcoop_Mapping_sdi_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_sdi_servizio();
if(this.govway2openspcoop_Mapping_sdi_servizio!=null && !this.govway2openspcoop_Mapping_sdi_servizio.isEmpty()) {
this.openspcoop2govway_Mapping_sdi_servizio = new HashMap<>();
for (String govway : this.govway2openspcoop_Mapping_sdi_servizio.keySet()) {
String openspcoop = this.govway2openspcoop_Mapping_sdi_servizio.get(govway);
this.openspcoop2govway_Mapping_sdi_servizio.put(openspcoop, govway);
}
}
}catch(Exception e){
log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
}
}
private synchronized void initValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
String key = messageFactory.getClass().getName();
if(this.openspcoop2) {
if(!this.validatoreXSD_soap11_map.containsKey(key)) {
try{
XSDResourceResolver xsdResourceResolver_soap11 = new XSDResourceResolver();
xsdResourceResolver_soap11.addResource("soapEnvelope.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope.xsd"));
this.validatoreXSD_soap11_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap11,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap11_openspcoop2.xsd")));
}catch(Exception e){
this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap11: "+e.getMessage(),e);
}
}
if(!this.validatoreXSD_soap12_map.containsKey(key)) {
try{
XSDResourceResolver xsdResourceResolver_soap12 = new XSDResourceResolver();
xsdResourceResolver_soap12.addResource("soapEnvelope12.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope12.xsd"));
xsdResourceResolver_soap12.addResource("xml.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/xml.xsd"));
this.validatoreXSD_soap12_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap12,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap12_openspcoop2.xsd")));
}catch(Exception e){
this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap12: "+e.getMessage(),e);
}
}
}
else {
if(!this.validatoreXSD_soap11_map.containsKey(key)) {
try{
XSDResourceResolver xsdResourceResolver_soap11 = new XSDResourceResolver();
xsdResourceResolver_soap11.addResource("soapEnvelope.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope.xsd"));
this.validatoreXSD_soap11_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap11,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap11_openspcoop1.xsd")));
}catch(Exception e){
this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap11: "+e.getMessage(),e);
}
}
}
}
private void checkInitValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
String key = messageFactory.getClass().getName();
if(this.openspcoop2) {
if(!this.validatoreXSD_soap11_map.containsKey(key)) {
initValidatoreXSD(messageFactory);
}
if(!this.validatoreXSD_soap12_map.containsKey(key)) {
initValidatoreXSD(messageFactory);
}
}
else {
if(!this.validatoreXSD_soap11_map.containsKey(key)) {
initValidatoreXSD(messageFactory);
}
}
}
private ValidatoreXSD getValidatoreXSD(boolean soap12, OpenSPCoop2MessageFactory messageFactory) {
checkInitValidatoreXSD(messageFactory);
String key = messageFactory.getClass().getName();
if(this.openspcoop2) {
if(soap12) {
return this.validatoreXSD_soap12_map.get(key);
}
else {
return this.validatoreXSD_soap11_map.get(key);
}
}
else {
return this.validatoreXSD_soap11_map.get(key);
}
}
private String normalizeX_(String hdr) {
if(!this.x_prefix) {
if(hdr.toLowerCase().startsWith("x-") && hdr.length()>2) {
hdr = hdr.substring(2);
}
}
return hdr;
}
private String normalizeOpenSPCoop2GovWay_tipoSoggetto(String tipoSoggetto, String protocollo) {
String tipo = null;
if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_trasparente_soggetto!=null) {
tipo = this.openspcoop2govway_Mapping_trasparente_soggetto.get(tipoSoggetto);
}
else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_spcoop_soggetto!=null) {
tipo = this.openspcoop2govway_Mapping_spcoop_soggetto.get(tipoSoggetto);
}
else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_sdi_soggetto!=null) {
tipo = this.openspcoop2govway_Mapping_sdi_soggetto.get(tipoSoggetto);
}
if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
return tipo;
}
return tipoSoggetto;
}
private String normalizeOpenSPCoop2GovWay_tipoServizio(String tipoServizio, String protocollo) {
String tipo = null;
if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_trasparente_servizio!=null) {
tipo = this.openspcoop2govway_Mapping_trasparente_servizio.get(tipoServizio);
}
else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_spcoop_servizio!=null) {
tipo = this.openspcoop2govway_Mapping_spcoop_servizio.get(tipoServizio);
}
else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_sdi_servizio!=null) {
tipo = this.openspcoop2govway_Mapping_sdi_servizio.get(tipoServizio);
}
if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
return tipo;
}
return tipoServizio;
}
private String normalizeGovWay2OpenSPCoop_tipoSoggetto(String tipoSoggetto, String protocollo) {
String tipo = null;
if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_trasparente_soggetto!=null) {
tipo = this.govway2openspcoop_Mapping_trasparente_soggetto.get(tipoSoggetto);
}
else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_spcoop_soggetto!=null) {
tipo = this.govway2openspcoop_Mapping_spcoop_soggetto.get(tipoSoggetto);
}
else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_sdi_soggetto!=null) {
tipo = this.govway2openspcoop_Mapping_sdi_soggetto.get(tipoSoggetto);
}
if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
return tipo;
}
return tipoSoggetto;
}
private String normalizeGovWay2OpenSPCoop_tipoServizio(String tipoServizio, String protocollo) {
String tipo = null;
if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_trasparente_servizio!=null) {
tipo = this.govway2openspcoop_Mapping_trasparente_servizio.get(tipoServizio);
}
else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_spcoop_servizio!=null) {
tipo = this.govway2openspcoop_Mapping_spcoop_servizio.get(tipoServizio);
}
else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_sdi_servizio!=null) {
tipo = this.govway2openspcoop_Mapping_sdi_servizio.get(tipoServizio);
}
if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
return tipo;
}
return tipoServizio;
}
public void readTransportProperties(Map<String, List<String>> prop,
HeaderIntegrazione integrazione,
String protocollo) throws HeaderIntegrazioneException{
try{
if(prop!=null && integrazione!=null){
// Ricerca tra l'header del trasporto
Iterator<String> it = prop.keySet().iterator();
while (it.hasNext()) {
String key = (String) it.next();
if(key!=null){
for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
String header = normalizeX_((String)this.keyValueIntegrazioneTrasporto.get(keywordIntegrazione));
if(key.equalsIgnoreCase(header)) {
if(this.keyReadEnabled_HeaderIntegrazioneTrasporto.get(keywordIntegrazione)) {
// Busta
if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
integrazione.getBusta().setTipoMittente(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
integrazione.getBusta().setTipoDestinatario(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoServizio(tipo, protocollo);
integrazione.getBusta().setTipoServizio(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));
}
// else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
// String v = TransportUtils.getFirstValue(prop,key);
// try{
// if(v!=null) {
// integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
// }
// }catch(Exception e){
// throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
// }
// }
else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));
}
// id e servizio applicativo
else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));
}
else if(this.openspcoop2 && CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));
}
}
break;
}
}
}
}
}
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
}
}
public void readUrlProperties(Map<String, List<String>> prop,
HeaderIntegrazione integrazione,
String protocollo) throws HeaderIntegrazioneException{
try{
if(prop!=null && integrazione!=null){
// Ricerca tra le proprieta' dell'url
Iterator<String> it = prop.keySet().iterator();
while (it.hasNext()) {
String key = (String) it.next();
if(key!=null){
for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
if(key.equalsIgnoreCase((String)this.keyValueIntegrazioneUrlBased.get(keywordIntegrazione))) {
if(this.keyReadEnabled_HeaderIntegrazioneUrlBased.get(keywordIntegrazione)) {
// Busta
if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
integrazione.getBusta().setTipoMittente(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
integrazione.getBusta().setTipoDestinatario(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
String tipo = TransportUtils.getFirstValue(prop,key);
String normalized = normalizeOpenSPCoop2GovWay_tipoServizio(tipo, protocollo);
integrazione.getBusta().setTipoServizio(normalized);
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));
}
// else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
// String v = TransportUtils.getFirstValue(prop,key);
// try{
// if(v!=null) {
// integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
// }
// }catch(Exception e){
// throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
// }
// }
else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));
}
// id e servizio applicativo
else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));
}
else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));
}
else if(this.openspcoop2 && CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));
}
}
break;
}
}
}
}
}
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
}
}
public void setUrlProperties(HeaderIntegrazione integrazione,
Map<String, List<String>> properties,
Map<String, String> protocolInfos,
String protocollo) throws HeaderIntegrazioneException{
try{
if(properties!=null && integrazione!=null){
if(integrazione.getBusta()!=null){
if(integrazione.getBusta().getTipoMittente()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
String tipo = integrazione.getBusta().getTipoMittente();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), normalized);
}
}
if(integrazione.getBusta().getMittente()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
}
}
if(integrazione.getBusta().getTipoDestinatario()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
String tipo = integrazione.getBusta().getTipoDestinatario();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), normalized);
}
}
if(integrazione.getBusta().getDestinatario()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
}
}
if(integrazione.getBusta().getTipoServizio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
String tipo = integrazione.getBusta().getTipoServizio();
String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), normalized);
}
}
if(integrazione.getBusta().getServizio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
}
}
// if(integrazione.getBusta().getVersioneServizio()!=null) {
// if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
// TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
// }
// }
if(integrazione.getBusta().getAzione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
}
}
if(integrazione.getBusta().getID()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
}
}
if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
}
}
if(integrazione.getBusta().getIdCollaborazione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
}
}
}
if(integrazione.getIdApplicativo()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
}
}
if(integrazione.getServizioApplicativo()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
}
}
if(this.openspcoop2 && integrazione.getIdTransazione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
}
}
}
if(properties!=null){
// TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD,URLEncoder.encode(this.openspcoopProperties.getHttpServer(),"UTF-8"));
// if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
// TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD_DETAILS,URLEncoder.encode(this.openspcoopProperties.getHttpXPdDDetails(),"UTF-8"));
// }
// Non deve essere effettuato a questo livello l'URLEncoder altrimenti si ottiene una doppia codifica, essendo poi fatta anche per tutti i valori in ConnettoreUtils.
if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
if(this.openspcoop2) {
TransportUtils.setParameter(properties,OPENSPCOOP2_URL_BASED_PDD,this.openspcoopProperties.getHttpServer());
if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
TransportUtils.setParameter(properties,OPENSPCOOP2_URL_BASED_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
}
}
else {
TransportUtils.setParameter(properties,OPENSPCOOP1_URL_BASED_PDD,this.openspcoopProperties.getHttpServer());
if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
TransportUtils.setParameter(properties,OPENSPCOOP1_URL_BASED_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
}
}
}
if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
// protocol info
if(protocolInfos!=null && protocolInfos.size()>0){
String prefixProtocolInfo = this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
while (itProtocolInfos.hasNext()) {
String name = (String) itProtocolInfos.next();
String value = protocolInfos.get(name);
String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
TransportUtils.setParameter(properties,nameWithPrefix,value);
}
}
}
}
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
}
}
public void setInfoProductTransportProperties(Map<String, List<String>> properties,
String protocollo) throws HeaderIntegrazioneException{
setTransportProperties(null, properties, null,
protocollo);
}
public void setTransportProperties(HeaderIntegrazione integrazione,
Map<String, List<String>> properties,
Map<String, String> protocolInfos,
String protocollo) throws HeaderIntegrazioneException{
try{
if(properties!=null && integrazione!=null){
if(integrazione.getBusta()!=null){
if(integrazione.getBusta().getTipoMittente()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
String tipo = integrazione.getBusta().getTipoMittente();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)), normalized);
}
}
if(integrazione.getBusta().getMittente()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)), integrazione.getBusta().getMittente());
}
}
if(integrazione.getBusta().getTipoDestinatario()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
String tipo = integrazione.getBusta().getTipoDestinatario();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)), normalized);
}
}
if(integrazione.getBusta().getDestinatario()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)), integrazione.getBusta().getDestinatario());
}
}
if(integrazione.getBusta().getTipoServizio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
String tipo = integrazione.getBusta().getTipoServizio();
String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)), normalized);
}
}
if(integrazione.getBusta().getServizio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)), integrazione.getBusta().getServizio());
}
}
// if(integrazione.getBusta().getVersioneServizio()!=null) {
// if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
// TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.getProperty(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)), integrazione.getBusta().getVersioneServizio().intValue()+"");
// }
// }
if(integrazione.getBusta().getAzione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)), integrazione.getBusta().getAzione());
}
}
if(integrazione.getBusta().getID()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)), integrazione.getBusta().getID());
}
}
if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)), integrazione.getBusta().getRiferimentoMessaggio());
}
}
if(integrazione.getBusta().getIdCollaborazione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)), integrazione.getBusta().getIdCollaborazione());
}
}
}
if(integrazione.getIdApplicativo()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)), integrazione.getIdApplicativo());
}
}
if(integrazione.getServizioApplicativo()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)), integrazione.getServizioApplicativo());
}
}
if(this.openspcoop2 && integrazione.getIdTransazione()!=null) {
if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)), integrazione.getIdTransazione());
}
}
}
if(properties!=null){
boolean infoProduct = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO);
if(infoProduct) {
String hdrPdd = null;
String hdrPddDetails = null;
if(this.openspcoop2) {
hdrPdd = normalizeX_(OPENSPCOOP2_HEADER_HTTP_X_PDD);
hdrPddDetails = normalizeX_(OPENSPCOOP2_HEADER_HTTP_X_PDD_DETAILS);
}
else {
hdrPdd = normalizeX_(OPENSPCOOP1_HEADER_HTTP_X_PDD);
hdrPddDetails = normalizeX_(OPENSPCOOP1_HEADER_HTTP_X_PDD_DETAILS);
}
if(properties.containsKey(hdrPdd)==false) {
TransportUtils.setParameter(properties,hdrPdd,this.openspcoopProperties.getHttpServer());
}
if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
if(properties.containsKey(hdrPddDetails)==false) {
TransportUtils.setParameter(properties,hdrPddDetails,this.openspcoopProperties.getHttpXPdDDetails());
}
}
}
boolean userAgent = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_USER_AGENT);
if(userAgent) {
if(this.request) {
if(properties.containsKey(HttpConstants.USER_AGENT)==false) {
TransportUtils.setParameter(properties,HttpConstants.USER_AGENT,this.openspcoopProperties.getHttpUserAgent());
}
}
else {
if(properties.containsKey(HttpConstants.SERVER)==false) {
TransportUtils.setParameter(properties,HttpConstants.SERVER,this.openspcoopProperties.getHttpUserAgent());
}
}
}
if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
if(protocolInfos!=null && protocolInfos.size()>0){
String prefixProtocolInfo = this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
while (itProtocolInfos.hasNext()) {
String name = (String) itProtocolInfos.next();
String value = protocolInfos.get(name);
String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
TransportUtils.setParameter(properties,normalizeX_(nameWithPrefix),value);
}
}
}
}
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
}
}
public void readHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
String actorIntegrazione,
String protocollo) throws HeaderIntegrazioneException{
try{
if(actorIntegrazione==null)
throw new Exception("Actor non definito");
SOAPHeader header = message.getSOAPHeader();
if(header==null){
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
return;
}
SOAPHeaderElement headerElement = null;
java.util.Iterator<?> it = header.examineAllHeaderElements();
while( it.hasNext() ){
// Test Header Element
headerElement = (SOAPHeaderElement) it.next();
//Controllo Actor
String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
if( actorIntegrazione.equals(actorCheck) ){
break;
}else{
headerElement = null;
}
}
if(headerElement==null){
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
return;
}
// validazione XSD
if(MessageType.SOAP_11.equals(message.getMessageType())){
ValidatoreXSD validatoreXSD_soap11 = getValidatoreXSD(false, message.getFactory());
if(validatoreXSD_soap11==null)
throw new Exception("Validatore XSD (Soap11) non istanziato");
validatoreXSD_soap11.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
}
else if(MessageType.SOAP_12.equals(message.getMessageType())){
if(!this.openspcoop2) {
throw new HeaderIntegrazioneException("SOAP12 non supportato");
}
ValidatoreXSD validatoreXSD_soap12 = getValidatoreXSD(true, message.getFactory());
if(validatoreXSD_soap12==null)
throw new Exception("Validatore XSD (Soap12) non istanziato");
validatoreXSD_soap12.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
}
else{
throw MessageNotSupportedException.newMessageNotSupportedException(message.getMessageType());
}
// Ricerca tra gli attributi dell'header SOAP
String tipoMittente = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
tipoMittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE));
tipoMittente = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipoMittente, protocollo);
}
}catch(Exception e){}
if(tipoMittente!=null && tipoMittente.compareTo("")!=0)
integrazione.getBusta().setTipoMittente(tipoMittente);
String mittente = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
mittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE));
}
}catch(Exception e){}
if(mittente!=null && mittente.compareTo("")!=0)
integrazione.getBusta().setMittente(mittente);
String tipoDestinatario = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
tipoDestinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO));
tipoDestinatario = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipoDestinatario, protocollo);
}
}catch(Exception e){}
if(tipoDestinatario!=null && tipoDestinatario.compareTo("")!=0)
integrazione.getBusta().setTipoDestinatario(tipoDestinatario);
String destinatario = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
destinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO));
}
}catch(Exception e){}
if(destinatario!=null && destinatario.compareTo("")!=0)
integrazione.getBusta().setDestinatario(destinatario);
String tipoServizio = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
tipoServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO));
tipoServizio = normalizeOpenSPCoop2GovWay_tipoServizio(tipoServizio, protocollo);
}
}catch(Exception e){}
if(tipoServizio!=null && tipoServizio.compareTo("")!=0)
integrazione.getBusta().setTipoServizio(tipoServizio);
String servizio = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
servizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO));
}
}catch(Exception e){}
if(servizio!=null && servizio.compareTo("")!=0)
integrazione.getBusta().setServizio(servizio);
// String versioneServizio = null;
// try{
// if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
// versioneServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO));
// }
// }catch(Exception e){}
// if(versioneServizio!=null && versioneServizio.compareTo("")!=0){
// try{
// integrazione.getBusta().setVersioneServizio(Integer.parseInt(versioneServizio));
// }catch(Exception e){
// throw new Exception("Formato versione ["+versioneServizio+"] non corretto: "+e.getMessage(),e);
// }
// }
String azione= null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
azione= headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE));
}
}catch(Exception e){}
if(azione!=null && azione.compareTo("")!=0)
integrazione.getBusta().setAzione(azione);
String idBusta = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
idBusta = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO));
}
}catch(Exception e){}
if(idBusta!=null && idBusta.compareTo("")!=0)
integrazione.getBusta().setID(idBusta);
String riferimentoMessaggio = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
riferimentoMessaggio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO));
}
}catch(Exception e){}
if(riferimentoMessaggio!=null && riferimentoMessaggio.compareTo("")!=0)
integrazione.getBusta().setRiferimentoMessaggio(riferimentoMessaggio);
String collaborazione = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
collaborazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE));
}
}catch(Exception e){}
if(collaborazione!=null && collaborazione.compareTo("")!=0)
integrazione.getBusta().setIdCollaborazione(collaborazione);
String idApplicativo = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
idApplicativo = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO));
}
}catch(Exception e){}
if(idApplicativo!=null && idApplicativo.compareTo("")!=0)
integrazione.setIdApplicativo(idApplicativo);
String sa = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
sa = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO));
}
}catch(Exception e){}
if(sa!=null && sa.compareTo("")!=0)
integrazione.setServizioApplicativo(sa);
if(this.openspcoop2) {
String idTransazione = null;
try{
if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
idTransazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE));
}
}catch(Exception e){}
if(idTransazione!=null && idTransazione.compareTo("")!=0)
integrazione.setIdTransazione(idTransazione);
}
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header soap non riuscita: "+e.getMessage(),e);
}
}
public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
String idBusta,String servizioApplicativo,
String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
String actorIntegrazione,String nomeElemento,String prefix,String namespace,
String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
Map<String, String> protocolInfos,
String protocollo) throws Exception{
updateHeader(message, soggettoFruitore, idServizio, idBusta, null,
servizioApplicativo, correlazioneApplicativa, riferimentoCorrelazioneApplicativaRichiesta, idTransazione,
actorIntegrazione, nomeElemento, prefix, namespace,
proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
protocollo);
}
public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
String idBusta,String idBustaRisposta,String servizioApplicativo,
String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
String actorIntegrazione,String nomeElemento,String prefix,String namespace,
String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
Map<String, String> protocolInfos,
String protocollo) throws Exception{
HeaderIntegrazione integrazione = new HeaderIntegrazione(idTransazione);
integrazione.setIdApplicativo(correlazioneApplicativa);
integrazione.setServizioApplicativo(servizioApplicativo);
HeaderIntegrazioneBusta busta = new HeaderIntegrazioneBusta();
busta.setTipoMittente(soggettoFruitore.getTipo());
busta.setMittente(soggettoFruitore.getNome());
busta.setTipoDestinatario(idServizio.getSoggettoErogatore().getTipo());
busta.setDestinatario(idServizio.getSoggettoErogatore().getNome());
busta.setTipoServizio(idServizio.getTipo());
busta.setServizio(idServizio.getNome());
busta.setVersioneServizio(idServizio.getVersione());
busta.setAzione(idServizio.getAzione());
if(idBustaRisposta==null){
busta.setID(idBusta);
}
else{
busta.setID(idBustaRisposta);
busta.setRiferimentoMessaggio(idBusta);
}
integrazione.setBusta(busta);
this.updateHeader(message, integrazione, actorIntegrazione, nomeElemento, prefix, namespace,
proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
protocollo);
}
public void updateHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
String actorIntegrazione,String nomeElemento,String prefix,String namespace,
String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
Map<String, String> protocolInfos,
String protocollo) throws Exception{
if(actorIntegrazione==null)
throw new Exception("Actor non definito");
SOAPHeader header = message.getSOAPHeader();
SOAPHeaderElement headerIntegrazione = null;
if(header==null){
// Creo soap header
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente: add soapHeader");
header = message.getSOAPPart().getEnvelope().addHeader();
}else{
// cerco soap di integrazione
java.util.Iterator<?> it = header.examineAllHeaderElements();
while( it.hasNext() ){
// Test Header Element
headerIntegrazione = (SOAPHeaderElement) it.next();
//Controllo Actor
String actorCheck = SoapUtils.getSoapActor(headerIntegrazione, message.getMessageType());
if( actorIntegrazione.equals(actorCheck) ){
break;
}else{
headerIntegrazione = null;
}
}
if(headerIntegrazione==null){
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente, lo creo");
}
}
List<SOAPElement> v = new ArrayList<SOAPElement>(); // mantengo eventuali message element presenti
if(headerIntegrazione!=null){
java.util.Iterator<?> it = headerIntegrazione.getChildElements();
if(it.hasNext()){
SOAPElement tmp = (SOAPElement) it.next();
//System.out.println("CONSERVO MSG ELEMENT["+tmp.getLocalName()+"]");
v.add(tmp);
}
header.removeChild(headerIntegrazione);
}
// creo header da nuovo
SOAPHeaderElement headerIntegrazioneNEW = this.buildHeader(integrazione, nomeElemento, prefix, namespace,
actorIntegrazione, message,
proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
protocollo);
// Riaggiungo eventuali elementi interni
while(v.size()>0){
SOAPElement tmp = v.remove(0);
//System.out.println("RIAGGIUNGO MSG ELEMENT["+tmp.getLocalName()+"]");
headerIntegrazioneNEW.addChildElement(tmp);
}
//System.out.println("OTTENGO ["+headerIntegrazioneNEW.getAsString()+"]");
// aggiungo header element al SOAP Header
//header.addChildElement(headerIntegrazioneNEW);
message.addHeaderElement(header, headerIntegrazioneNEW);
}
public SOAPHeaderElement buildHeader(HeaderIntegrazione integrazione,String nomeElemento,
String prefix,String namespace, String actor,
OpenSPCoop2SoapMessage m,
String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
Map<String, String> protocolInfos,
String protocollo) throws HeaderIntegrazioneException{
try{
SOAPHeader soapHeader = m.getSOAPHeader();
if(soapHeader==null){
soapHeader = m.getSOAPPart().getEnvelope().addHeader();
}
SOAPHeaderElement header = m.newSOAPHeaderElement(soapHeader, new QName(namespace,nomeElemento,prefix));
header.setActor(actor);
header.setMustUnderstand(false);
setAttributes(integrazione,header,protocollo);
if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
if(protocolInfos!=null && protocolInfos.size()>0){
String prefixProtocolInfo = this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
while (itProtocolInfos.hasNext()) {
String name = (String) itProtocolInfos.next();
String value = protocolInfos.get(name);
String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
SOAPElement element = header.addChildElement(new QName(namespace,proprietaProtocolloNomeElemento,prefix));
element.setTextContent(value);
@SuppressWarnings("unused")
SOAPElement attribute = element.addAttribute(new QName(proprietaProtocolloNomeTipoElemento),nameWithPrefix);
}
}
}
return header;
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione dell'header soap non riuscita: "+e.getMessage(),e);
}
}
public void setAttributes(HeaderIntegrazione integrazione, SOAPHeaderElement header, String protocollo){
if(integrazione.getBusta()!=null){
if(integrazione.getBusta().getTipoMittente()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
String tipo = integrazione.getBusta().getTipoMittente();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), normalized);
}
}
if(integrazione.getBusta().getMittente()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
}
}
if(integrazione.getBusta().getTipoDestinatario()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
String tipo = integrazione.getBusta().getTipoDestinatario();
String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), normalized);
}
}
if(integrazione.getBusta().getDestinatario()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
}
}
if(integrazione.getBusta().getTipoServizio()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
String tipo = integrazione.getBusta().getTipoServizio();
String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), normalized);
}
}
if(integrazione.getBusta().getServizio()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
}
}
// if(integrazione.getBusta().getVersioneServizio()!=null){
// if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
// header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
// }
// }
if(integrazione.getBusta().getAzione()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
}
}
if(integrazione.getBusta().getID()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
}
}
if(integrazione.getBusta().getRiferimentoMessaggio()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
}
}
if(integrazione.getBusta().getIdCollaborazione()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
}
}
}
if(integrazione.getIdApplicativo()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
}
}
if(integrazione.getServizioApplicativo()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
}
}
if(this.openspcoop2 && integrazione.getIdTransazione()!=null){
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
}
}
if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
if(this.openspcoop2) {
header.setAttribute(OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDVersione());
if(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails())){
header.setAttribute(OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails());
}
}
else {
header.setAttribute(OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDVersione());
if(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails())){
header.setAttribute(OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails());
}
}
}
}
public void deleteHeader(OpenSPCoop2SoapMessage message,String actorIntegrazione) throws HeaderIntegrazioneException{
try{
if(actorIntegrazione==null)
throw new Exception("Actor non definito");
SOAPHeader header = message.getSOAPHeader();
if(header==null){
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
return;
}
SOAPHeaderElement headerElement = null;
java.util.Iterator<?> it = header.examineAllHeaderElements();
while( it.hasNext() ){
// Test Header Element
headerElement = (SOAPHeaderElement) it.next();
//Controllo Actor
String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
if( actorIntegrazione.equals(actorCheck) ){
break;
}else{
headerElement = null;
}
}
if(headerElement==null){
OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
return;
}
header.removeChild(headerElement);
}catch(Exception e){
throw new HeaderIntegrazioneException("UtilitiesIntegrazione, eliminazione dell'header soap non riuscita: "+e.getMessage(),e);
}
}
public static String getIdTransazione(PdDContext context){
return UtilitiesIntegrazione.getIdTransazione(context);
}
}