UtilitiesIntegrazioneBC.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.pdd.core.integrazione.backward_compatibility;


  26. import java.util.ArrayList;
  27. import java.util.HashMap;
  28. import java.util.Iterator;
  29. import java.util.List;
  30. import java.util.Map;

  32. import javax.xml.namespace.QName;
  33. import javax.xml.soap.SOAPElement;
  34. import javax.xml.soap.SOAPHeader;
  35. import javax.xml.soap.SOAPHeaderElement;

  37. import org.apache.commons.lang.StringUtils;
  38. import org.openspcoop2.core.constants.CostantiLabel;
  39. import org.openspcoop2.core.id.IDServizio;
  40. import org.openspcoop2.core.id.IDSoggetto;
  41. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  42. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  43. import org.openspcoop2.message.constants.MessageType;
  44. import org.openspcoop2.message.exception.MessageNotSupportedException;
  45. import org.openspcoop2.message.soap.SoapUtils;
  46. import org.openspcoop2.message.xml.ValidatoreXSD;
  47. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  48. import org.openspcoop2.pdd.core.CostantiPdD;
  49. import org.openspcoop2.pdd.core.PdDContext;
  50. import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazione;
  51. import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazioneBusta;
  52. import org.openspcoop2.pdd.core.integrazione.HeaderIntegrazioneException;
  53. import org.openspcoop2.pdd.core.integrazione.UtilitiesIntegrazione;
  54. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  55. import org.openspcoop2.utils.MapKey;
  56. import org.openspcoop2.utils.transport.TransportUtils;
  57. import org.openspcoop2.utils.transport.http.HttpConstants;
  58. import org.openspcoop2.utils.xml.XSDResourceResolver;
  59. import org.slf4j.Logger;


  62. /**
  63.  * Classe contenenti utilities per le integrazioni.
  64.  *
  65.  * @author Poli Andrea (apoli@link.it)
  66.  * @author $Author$
  67.  * @version $Rev$, $Date$
  68.  */
  69. public class UtilitiesIntegrazioneBC {

  71.     /** Costante che indica il valore dell'header X che indica la versione della PdD*/
  72.     public static final String OPENSPCOOP2_HEADER_HTTP_X_PDD = "X-OpenSPCoop2-Pdd";
  73.     /** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
  74.     public static final String OPENSPCOOP2_HEADER_HTTP_X_PDD_DETAILS = "X-OpenSPCoop2-PddDetails";
  75.     
  76.     /** Costante che indica il valore dell'header X che indica la versione della PdD*/
  77.     public static final String OPENSPCOOP2_URL_BASED_PDD = "OpenSPCoop2Pdd";
  78.     /** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
  79.     public static final String OPENSPCOOP2_URL_BASED_PDD_DETAILS = "OpenSPCoop2PddDetails";
  80.     
  81.     /** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica la versione della PdD*/
  82.     public static final String OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION = "OpenSPCoop2Pdd";
  83.     /** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica il dettaglio della versione della PdD*/
  84.     public static final String OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS = "OpenSPCoop2PddDetails";
  85.     
  86.     
  87.     
  88.     /** Costante che indica il valore dell'header X che indica la versione della PdD*/
  89.     public static final String OPENSPCOOP1_HEADER_HTTP_X_PDD = "X-SPCoop-Pdd";
  90.     /** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
  91.     public static final String OPENSPCOOP1_HEADER_HTTP_X_PDD_DETAILS = "X-SPCoop-PddDetails";
  92.     
  93.     /** Costante che indica il valore dell'header X che indica la versione della PdD*/
  94.     public static final String OPENSPCOOP1_URL_BASED_PDD = "SPCoopPdd";
  95.     /** Costante che indica il valore dell'header X che indica il dettaglio della versione della PdD*/
  96.     public static final String OPENSPCOOP1_URL_BASED_PDD_DETAILS = "SPCoopDettagliPdd";
  97.     
  98.     /** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica la versione della PdD*/
  99.     public static final String OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION = "SPCoopPdd";
  100.     /** Costante che indica il valore dell'attributo dell'header di integrazione SOAP proprietario di OpenSPCoop che indica il dettaglio della versione della PdD*/
  101.     public static final String OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS = "SPCoopPddDetails";
  102.     

  104.     

  106.     // ***** STATIC *****

  108.     private static final boolean PORTA_DELEGATA = true;
  109.     private static final boolean PORTA_APPLICATIVA = false;
  110.     private static final boolean REQUEST = true;
  111.     private static final boolean RESPONSE = false;
  112.     public static final boolean OPENSPCOOP_V2 = true;
  113.     public static final boolean OPENSPCOOP_V1 = false;
  114.     public static final boolean X_PREFIX = true;
  115.     public static final boolean NOT_X_PREFIX = false;
  116.     
  117.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op2_xPrefix = null;
  118.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op2 = null;
  119.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op1_xPrefix = null;
  120.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDRequest_op1 = null;
  121.     public static UtilitiesIntegrazioneBC getInstancePDRequest(Logger log, boolean openspcoop2, boolean x_prefix){
  122.         if(openspcoop2) {
  123.             if(x_prefix) {
  124.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix==null){
  125.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  126.                     synchronized (UtilitiesIntegrazioneBC.class) {
  127.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
  128.                     }
  129.                 }
  130.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix;
  131.             }
  132.             else {
  133.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2==null){
  134.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  135.                     synchronized (UtilitiesIntegrazioneBC.class) {
  136.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
  137.                     }
  138.                 }
  139.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2;
  140.             }
  141.         }
  142.         else {
  143.             if(x_prefix) {
  144.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix==null){
  145.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  146.                     synchronized (UtilitiesIntegrazioneBC.class) {
  147.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
  148.                     }
  149.                 }
  150.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix;
  151.             }
  152.             else {
  153.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1==null){
  154.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  155.                     synchronized (UtilitiesIntegrazioneBC.class) {
  156.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,REQUEST, openspcoop2, x_prefix);
  157.                     }
  158.                 }
  159.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1;
  160.             }
  161.         }
  162.     }
  163.     
  164.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op2_xPrefix = null;
  165.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op2 = null;
  166.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op1_xPrefix = null;
  167.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePDResponse_op1 = null;
  168.     public static UtilitiesIntegrazioneBC getInstancePDResponse(Logger log, boolean openspcoop2, boolean x_prefix){
  169.         if(openspcoop2) {
  170.             if(x_prefix) {
  171.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix==null){
  172.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  173.                     synchronized (UtilitiesIntegrazioneBC.class) {
  174.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
  175.                     }
  176.                 }
  177.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix;
  178.             }
  179.             else {
  180.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2==null){
  181.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  182.                     synchronized (UtilitiesIntegrazioneBC.class) {
  183.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
  184.                     }
  185.                 }
  186.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2;
  187.             }
  188.         }
  189.         else {
  190.             if(x_prefix) {
  191.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix==null){
  192.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  193.                     synchronized (UtilitiesIntegrazioneBC.class) {
  194.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
  195.                     }
  196.                 }
  197.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix;
  198.             }
  199.             else {
  200.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1==null){
  201.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  202.                     synchronized (UtilitiesIntegrazioneBC.class) {
  203.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_DELEGATA,RESPONSE, openspcoop2, x_prefix);
  204.                     }
  205.                 }
  206.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1;
  207.             }
  208.         }
  209.     }
  210.     
  211.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op2_xPrefix = null;
  212.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op2 = null;
  213.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op1_xPrefix = null;
  214.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePARequest_op1 = null;
  215.     public static UtilitiesIntegrazioneBC getInstancePARequest(Logger log, boolean openspcoop2, boolean x_prefix){
  216.         if(openspcoop2) {
  217.             if(x_prefix) {
  218.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix==null){
  219.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  220.                     synchronized (UtilitiesIntegrazioneBC.class) {
  221.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
  222.                     }
  223.                 }
  224.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix;
  225.             }
  226.             else {
  227.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2==null){
  228.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  229.                     synchronized (UtilitiesIntegrazioneBC.class) {
  230.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
  231.                     }
  232.                 }
  233.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2;
  234.             }
  235.         }
  236.         else {
  237.             if(x_prefix) {
  238.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix==null){
  239.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  240.                     synchronized (UtilitiesIntegrazioneBC.class) {
  241.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
  242.                     }
  243.                 }
  244.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix;
  245.             }
  246.             else {
  247.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1==null){
  248.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  249.                     synchronized (UtilitiesIntegrazioneBC.class) {
  250.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,REQUEST, openspcoop2, x_prefix);
  251.                     }
  252.                 }
  253.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1;
  254.             }
  255.         }
  256.     }
  257.     
  258.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op2_xPrefix = null;
  259.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op2 = null;
  260.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op1_xPrefix = null;
  261.     private static UtilitiesIntegrazioneBC utilitiesIntegrazionePAResponse_op1 = null;
  262.     public static UtilitiesIntegrazioneBC getInstancePAResponse(Logger log, boolean openspcoop2, boolean x_prefix){
  263.         if(openspcoop2) {
  264.             if(x_prefix) {
  265.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix==null){
  266.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  267.                     synchronized (UtilitiesIntegrazioneBC.class) {
  268.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
  269.                     }
  270.                 }
  271.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix;
  272.             }
  273.             else {
  274.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2==null){
  275.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  276.                     synchronized (UtilitiesIntegrazioneBC.class) {
  277.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
  278.                     }
  279.                 }
  280.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2;
  281.             }
  282.         }
  283.         else {
  284.             if(x_prefix) {
  285.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix==null){
  286.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  287.                     synchronized (UtilitiesIntegrazioneBC.class) {
  288.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
  289.                     }
  290.                 }
  291.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix;
  292.             }
  293.             else {
  294.                 if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1==null){
  295.                     // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  296.                     synchronized (UtilitiesIntegrazioneBC.class) {
  297.                         UtilitiesIntegrazioneBC.initialize(log,PORTA_APPLICATIVA,RESPONSE, openspcoop2, x_prefix);
  298.                     }
  299.                 }
  300.                 return UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1;
  301.             }
  302.         }
  303.     }



  307.     private static synchronized void initialize(Logger log,boolean portaDelegata, boolean request, boolean openspcoop2, boolean x_prefix){
  308.         if(portaDelegata) {
  309.             if(request) {
  310.                 if(openspcoop2) {
  311.                     if(x_prefix) {
  312.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix==null){
  313.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  314.                         }
  315.                     }
  316.                     else {
  317.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2==null){
  318.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  319.                         }
  320.                     }
  321.                 }
  322.                 else {
  323.                     if(x_prefix) {
  324.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix==null){
  325.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  326.                         }
  327.                     }
  328.                     else {
  329.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1==null){
  330.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDRequest_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  331.                         }
  332.                     }
  333.                 }
  334.             }
  335.             else {
  336.                 if(openspcoop2) {
  337.                     if(x_prefix) {
  338.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix==null){
  339.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  340.                         }
  341.                     }
  342.                     else {
  343.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2==null){
  344.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  345.                         }
  346.                     }
  347.                 }
  348.                 else {
  349.                     if(x_prefix) {
  350.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix==null){
  351.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  352.                         }
  353.                     }
  354.                     else {
  355.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1==null){
  356.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePDResponse_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  357.                         }
  358.                     }
  359.                 }
  360.             }
  361.         }
  362.         else {
  363.             if(request) {
  364.                 if(openspcoop2) {
  365.                     if(x_prefix) {
  366.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix==null){
  367.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  368.                         }
  369.                     }
  370.                     else {
  371.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2==null){
  372.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  373.                         }
  374.                     }
  375.                 }
  376.                 else {
  377.                     if(x_prefix) {
  378.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix==null){
  379.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  380.                         }
  381.                     }
  382.                     else {
  383.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1==null){
  384.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePARequest_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  385.                         }
  386.                     }
  387.                 }
  388.             }
  389.             else {
  390.                 if(openspcoop2) {
  391.                     if(x_prefix) {
  392.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix==null){
  393.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  394.                         }
  395.                     }
  396.                     else {
  397.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2==null){
  398.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op2 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  399.                         }
  400.                     }
  401.                 }
  402.                 else {
  403.                     if(x_prefix) {
  404.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix==null){
  405.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1_xPrefix = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  406.                         }
  407.                     }
  408.                     else {
  409.                         if(UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1==null){
  410.                             UtilitiesIntegrazioneBC.utilitiesIntegrazionePAResponse_op1 = new UtilitiesIntegrazioneBC(log, portaDelegata, request, openspcoop2, x_prefix);
  411.                         }
  412.                     }
  413.                 }
  414.             }
  415.         }
  416.     }

  418.     
  419.     
  420.     
  421.     // ***** INSTANCE *****

  423.     private List<MapKey<String>> keywordsIntegrazione = null;
  424.     
  425.     private Map<MapKey<String>, String> keyValueIntegrazioneTrasporto = null;
  426.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneTrasporto = null;
  427.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneTrasporto = null;
  428.     
  429.     private Map<MapKey<String>, String> keyValueIntegrazioneUrlBased = null;
  430.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneUrlBased = null;
  431.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneUrlBased = null;
  432.     
  433.     private Map<MapKey<String>, String> keyValueIntegrazioneSoap = null;
  434.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneSoap = null;
  435.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneSoap = null;
  436.     
  437.     private OpenSPCoop2Properties openspcoopProperties = null;
  438.     private Map<String, ValidatoreXSD> validatoreXSD_soap11_map = new HashMap<String, ValidatoreXSD>();
  439.     private Map<String, ValidatoreXSD> validatoreXSD_soap12_map = new HashMap<String, ValidatoreXSD>();
  440.     
  441.     private Map<String, String> govway2openspcoop_Mapping_trasparente_soggetto = null;
  442.     private Map<String, String> govway2openspcoop_Mapping_trasparente_servizio = null;
  443.     private Map<String, String> govway2openspcoop_Mapping_spcoop_soggetto = null;
  444.     private Map<String, String> govway2openspcoop_Mapping_spcoop_servizio = null;
  445.     private Map<String, String> govway2openspcoop_Mapping_sdi_soggetto = null;
  446.     private Map<String, String> govway2openspcoop_Mapping_sdi_servizio = null;
  447.     
  448.     private Map<String, String> openspcoop2govway_Mapping_trasparente_soggetto = null;
  449.     private Map<String, String> openspcoop2govway_Mapping_trasparente_servizio = null;
  450.     private Map<String, String> openspcoop2govway_Mapping_spcoop_soggetto = null;
  451.     private Map<String, String> openspcoop2govway_Mapping_spcoop_servizio = null;
  452.     private Map<String, String> openspcoop2govway_Mapping_sdi_soggetto = null;
  453.     private Map<String, String> openspcoop2govway_Mapping_sdi_servizio = null;
  454.     
  455.     private boolean request;
  456.     private boolean openspcoop2;
  457.     private boolean x_prefix;
  458.     
  459.     private Logger log;
  460.     
  461.     private UtilitiesIntegrazioneBC(Logger log, boolean portaDelegata, boolean request, boolean openspcoop2, boolean x_prefix){
  462.         
  463.         this.log = log;
  464.         
  465.         this.openspcoopProperties = OpenSPCoop2Properties.getInstance();
  466.         
  467.         this.request = request;
  468.         this.openspcoop2 = openspcoop2;
  469.         this.x_prefix = x_prefix;
  470.         
  471.         this.keywordsIntegrazione = this.openspcoopProperties.getKeywordsIntegrazione();
  472.         this.keywordsIntegrazione.remove(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO);
  473.         if(!this.openspcoop2) {
  474.             this.keywordsIntegrazione.remove(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE);
  475.         }
  476.         
  477.         if(this.openspcoop2) {
  478.             this.keyValueIntegrazioneTrasporto = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneTrasporto_backwardCompatibility_openspcoop2();
  479.         }
  480.         else {
  481.             this.keyValueIntegrazioneTrasporto = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneTrasporto_backwardCompatibility_openspcoop1();
  482.         }
  483.         try{
  484.             if(portaDelegata) {
  485.                 this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneTrasporto(request);
  486.                 this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneTrasporto();
  487.             }
  488.             else {
  489.                 this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneTrasporto(request);
  490.                 this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneTrasporto();
  491.             }
  492.         }catch(Exception e){
  493.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  494.         }
  495.         
  496.         if(this.openspcoop2) {
  497.             this.keyValueIntegrazioneUrlBased = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneUrlBased_backwardCompatibility_openspcoop2();
  498.         }
  499.         else {
  500.             this.keyValueIntegrazioneUrlBased = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneUrlBased_backwardCompatibility_openspcoop1();
  501.         }
  502.         try{
  503.             if(portaDelegata) {
  504.                 this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneUrlBased();
  505.                 this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneUrlBased();
  506.             }
  507.             else {
  508.                 this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneUrlBased();
  509.                 this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneUrlBased();
  510.             }
  511.         }catch(Exception e){
  512.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  513.         }
  514.         
  515.         if(this.openspcoop2) {
  516.             this.keyValueIntegrazioneSoap = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneSoap_backwardCompatibility_openspcoop2();
  517.         }
  518.         else {
  519.             this.keyValueIntegrazioneSoap = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneSoap_backwardCompatibility_openspcoop1();
  520.         }
  521.         try{
  522.             if(portaDelegata) {
  523.                 this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneSoap(request);
  524.                 this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneSoap();
  525.             }
  526.             else {
  527.                 this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneSoap(request);
  528.                 this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneSoap();
  529.             }
  530.         }catch(Exception e){
  531.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  532.         }
  533.         
  534.         try {
  535.             this.govway2openspcoop_Mapping_trasparente_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_trasparente_soggetto();
  536.             if(this.govway2openspcoop_Mapping_trasparente_soggetto!=null && !this.govway2openspcoop_Mapping_trasparente_soggetto.isEmpty()) {
  537.                 this.openspcoop2govway_Mapping_trasparente_soggetto = new HashMap<>();
  538.                 for (String govway : this.govway2openspcoop_Mapping_trasparente_soggetto.keySet()) {
  539.                     String openspcoop = this.govway2openspcoop_Mapping_trasparente_soggetto.get(govway);
  540.                     this.openspcoop2govway_Mapping_trasparente_soggetto.put(openspcoop, govway);
  541.                 }
  542.             }
  543.         }catch(Exception e){
  544.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  545.         }
  546.         try {
  547.             this.govway2openspcoop_Mapping_trasparente_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_trasparente_servizio();
  548.             if(this.govway2openspcoop_Mapping_trasparente_servizio!=null && !this.govway2openspcoop_Mapping_trasparente_servizio.isEmpty()) {
  549.                 this.openspcoop2govway_Mapping_trasparente_servizio = new HashMap<>();
  550.                 for (String govway : this.govway2openspcoop_Mapping_trasparente_servizio.keySet()) {
  551.                     String openspcoop = this.govway2openspcoop_Mapping_trasparente_servizio.get(govway);
  552.                     this.openspcoop2govway_Mapping_trasparente_servizio.put(openspcoop, govway);
  553.                 }
  554.             }
  555.         }catch(Exception e){
  556.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  557.         }
  558.         
  559.         try {
  560.             this.govway2openspcoop_Mapping_spcoop_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_spcoop_soggetto();
  561.             if(this.govway2openspcoop_Mapping_spcoop_soggetto!=null && !this.govway2openspcoop_Mapping_spcoop_soggetto.isEmpty()) {
  562.                 this.openspcoop2govway_Mapping_spcoop_soggetto = new HashMap<>();
  563.                 for (String govway : this.govway2openspcoop_Mapping_spcoop_soggetto.keySet()) {
  564.                     String openspcoop = this.govway2openspcoop_Mapping_spcoop_soggetto.get(govway);
  565.                     this.openspcoop2govway_Mapping_spcoop_soggetto.put(openspcoop, govway);
  566.                 }
  567.             }
  568.         }catch(Exception e){
  569.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  570.         }
  571.         try {
  572.             this.govway2openspcoop_Mapping_spcoop_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_spcoop_servizio();
  573.             if(this.govway2openspcoop_Mapping_spcoop_servizio!=null && !this.govway2openspcoop_Mapping_spcoop_servizio.isEmpty()) {
  574.                 this.openspcoop2govway_Mapping_spcoop_servizio = new HashMap<>();
  575.                 for (String govway : this.govway2openspcoop_Mapping_spcoop_servizio.keySet()) {
  576.                     String openspcoop = this.govway2openspcoop_Mapping_spcoop_servizio.get(govway);
  577.                     this.openspcoop2govway_Mapping_spcoop_servizio.put(openspcoop, govway);
  578.                 }
  579.             }
  580.         }catch(Exception e){
  581.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  582.         }
  583.         
  584.         try {
  585.             this.govway2openspcoop_Mapping_sdi_soggetto = this.openspcoopProperties.getNewOldMapping_backward_compatibility_sdi_soggetto();
  586.             if(this.govway2openspcoop_Mapping_sdi_soggetto!=null && !this.govway2openspcoop_Mapping_sdi_soggetto.isEmpty()) {
  587.                 this.openspcoop2govway_Mapping_sdi_soggetto = new HashMap<>();
  588.                 for (String govway : this.govway2openspcoop_Mapping_sdi_soggetto.keySet()) {
  589.                     String openspcoop = this.govway2openspcoop_Mapping_sdi_soggetto.get(govway);
  590.                     this.openspcoop2govway_Mapping_sdi_soggetto.put(openspcoop, govway);
  591.                 }
  592.             }
  593.         }catch(Exception e){
  594.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  595.         }
  596.         try {
  597.             this.govway2openspcoop_Mapping_sdi_servizio = this.openspcoopProperties.getNewOldMapping_backward_compatibility_sdi_servizio();
  598.             if(this.govway2openspcoop_Mapping_sdi_servizio!=null && !this.govway2openspcoop_Mapping_sdi_servizio.isEmpty()) {
  599.                 this.openspcoop2govway_Mapping_sdi_servizio = new HashMap<>();
  600.                 for (String govway : this.govway2openspcoop_Mapping_sdi_servizio.keySet()) {
  601.                     String openspcoop = this.govway2openspcoop_Mapping_sdi_servizio.get(govway);
  602.                     this.openspcoop2govway_Mapping_sdi_servizio.put(openspcoop, govway);
  603.                 }
  604.             }
  605.         }catch(Exception e){
  606.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  607.         }
  608.         
  609.     }
  610.     
  611.     private synchronized void initValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
  612.         String key = messageFactory.getClass().getName();
  613.         if(this.openspcoop2) {
  614.             
  615.             if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  616.                 try{
  617.                     XSDResourceResolver xsdResourceResolver_soap11 = new XSDResourceResolver();
  618.                     xsdResourceResolver_soap11.addResource("soapEnvelope.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope.xsd"));
  619.                     this.validatoreXSD_soap11_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap11,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap11_openspcoop2.xsd")));
  620.                 }catch(Exception e){
  621.                     this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap11: "+e.getMessage(),e);
  622.                 }
  623.             }
  624.             
  625.             if(!this.validatoreXSD_soap12_map.containsKey(key)) {
  626.                 try{
  627.                     XSDResourceResolver xsdResourceResolver_soap12 = new XSDResourceResolver();
  628.                     xsdResourceResolver_soap12.addResource("soapEnvelope12.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope12.xsd"));
  629.                     xsdResourceResolver_soap12.addResource("xml.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/xml.xsd"));
  630.                     this.validatoreXSD_soap12_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap12,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap12_openspcoop2.xsd")));
  631.                 }catch(Exception e){
  632.                     this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap12: "+e.getMessage(),e);
  633.                 }
  634.             }
  635.         }
  636.         else {
  637.             
  638.             if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  639.                 try{
  640.                     XSDResourceResolver xsdResourceResolver_soap11 = new XSDResourceResolver();
  641.                     xsdResourceResolver_soap11.addResource("soapEnvelope.xsd", UtilitiesIntegrazioneBC.class.getResourceAsStream("/soapEnvelope.xsd"));
  642.                     this.validatoreXSD_soap11_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap11,UtilitiesIntegrazioneBC.class.getResourceAsStream("/integrazione_soap11_openspcoop1.xsd")));
  643.                 }catch(Exception e){
  644.                     this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap11: "+e.getMessage(),e);
  645.                 }
  646.             }
  647.             
  648.         }
  649.     }
  650.     private void checkInitValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
  651.         String key = messageFactory.getClass().getName();
  652.         if(this.openspcoop2) {
  653.             if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  654.                 initValidatoreXSD(messageFactory);
  655.             }
  656.             if(!this.validatoreXSD_soap12_map.containsKey(key)) {
  657.                 initValidatoreXSD(messageFactory);
  658.             }
  659.         }
  660.         else {
  661.             if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  662.                 initValidatoreXSD(messageFactory);
  663.             }
  664.             
  665.         }
  666.     }
  667.     private ValidatoreXSD getValidatoreXSD(boolean soap12, OpenSPCoop2MessageFactory messageFactory) {
  668.         
  669.         checkInitValidatoreXSD(messageFactory);
  670.         
  671.         String key = messageFactory.getClass().getName();
  672.         if(this.openspcoop2) {
  673.             if(soap12) {
  674.                 return this.validatoreXSD_soap12_map.get(key);
  675.             }
  676.             else {
  677.                 return this.validatoreXSD_soap11_map.get(key);
  678.             }
  679.         }
  680.         else {
  681.             return this.validatoreXSD_soap11_map.get(key);
  682.         }
  683.         
  684.     }
  685.     
  686.     private String normalizeX_(String hdr) {
  687.         if(!this.x_prefix) {
  688.             if(hdr.toLowerCase().startsWith("x-") && hdr.length()>2) {
  689.                 hdr = hdr.substring(2);
  690.             }
  691.         }
  692.         return hdr;
  693.     }
  694.     
  695.     private String normalizeOpenSPCoop2GovWay_tipoSoggetto(String tipoSoggetto, String protocollo) {
  696.         String tipo = null;
  697.         if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_trasparente_soggetto!=null) {
  698.             tipo = this.openspcoop2govway_Mapping_trasparente_soggetto.get(tipoSoggetto);
  699.         }
  700.         else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_spcoop_soggetto!=null) {
  701.             tipo = this.openspcoop2govway_Mapping_spcoop_soggetto.get(tipoSoggetto);
  702.         }
  703.         else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_sdi_soggetto!=null) {
  704.             tipo = this.openspcoop2govway_Mapping_sdi_soggetto.get(tipoSoggetto);
  705.         }
  706.         if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
  707.             return tipo;
  708.         }
  709.         return tipoSoggetto;
  710.     }
  711.     private String normalizeOpenSPCoop2GovWay_tipoServizio(String tipoServizio, String protocollo) {
  712.         String tipo = null;
  713.         if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_trasparente_servizio!=null) {
  714.             tipo = this.openspcoop2govway_Mapping_trasparente_servizio.get(tipoServizio);
  715.         }
  716.         else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_spcoop_servizio!=null) {
  717.             tipo = this.openspcoop2govway_Mapping_spcoop_servizio.get(tipoServizio);
  718.         }
  719.         else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.openspcoop2govway_Mapping_sdi_servizio!=null) {
  720.             tipo = this.openspcoop2govway_Mapping_sdi_servizio.get(tipoServizio);
  721.         }
  722.         if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
  723.             return tipo;
  724.         }
  725.         return tipoServizio;
  726.     }
  727.     
  728.     private String normalizeGovWay2OpenSPCoop_tipoSoggetto(String tipoSoggetto, String protocollo) {
  729.         String tipo = null;
  730.         if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_trasparente_soggetto!=null) {
  731.             tipo = this.govway2openspcoop_Mapping_trasparente_soggetto.get(tipoSoggetto);
  732.         }
  733.         else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_spcoop_soggetto!=null) {
  734.             tipo = this.govway2openspcoop_Mapping_spcoop_soggetto.get(tipoSoggetto);
  735.         }
  736.         else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_sdi_soggetto!=null) {
  737.             tipo = this.govway2openspcoop_Mapping_sdi_soggetto.get(tipoSoggetto);
  738.         }
  739.         if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
  740.             return tipo;
  741.         }
  742.         return tipoSoggetto;
  743.     }
  744.     private String normalizeGovWay2OpenSPCoop_tipoServizio(String tipoServizio, String protocollo) {
  745.         String tipo = null;
  746.         if(protocollo!=null && CostantiLabel.TRASPARENTE_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_trasparente_servizio!=null) {
  747.             tipo = this.govway2openspcoop_Mapping_trasparente_servizio.get(tipoServizio);
  748.         }
  749.         else if(protocollo!=null && CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_spcoop_servizio!=null) {
  750.             tipo = this.govway2openspcoop_Mapping_spcoop_servizio.get(tipoServizio);
  751.         }
  752.         else if(protocollo!=null && CostantiLabel.SDI_PROTOCOL_NAME.equals(protocollo) && this.govway2openspcoop_Mapping_sdi_servizio!=null) {
  753.             tipo = this.govway2openspcoop_Mapping_sdi_servizio.get(tipoServizio);
  754.         }
  755.         if(tipo!=null && StringUtils.isNotEmpty(tipo)) {
  756.             return tipo;
  757.         }
  758.         return tipoServizio;
  759.     }
  760.     
  761.     public void readTransportProperties(Map<String, List<String>> prop,
  762.             HeaderIntegrazione integrazione,
  763.             String protocollo) throws HeaderIntegrazioneException{
  764.         try{
  765.             if(prop!=null && integrazione!=null){
  766.                                 
  767.                 // Ricerca tra l'header del trasporto
  768.                 Iterator<String> it = prop.keySet().iterator();
  769.                 while (it.hasNext()) {
  770.                     String key = (String) it.next();
  771.                     
  772.                     if(key!=null){
  773.                         
  774.                         for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
  775.                             String header = normalizeX_((String)this.keyValueIntegrazioneTrasporto.get(keywordIntegrazione));
  776.                             if(key.equalsIgnoreCase(header)) {
  777.                                 
  778.                                 if(this.keyReadEnabled_HeaderIntegrazioneTrasporto.get(keywordIntegrazione)) {
  779.                                 
  780.                                     // Busta
  781.                                     if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
  782.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  783.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
  784.                                         integrazione.getBusta().setTipoMittente(normalized);    
  785.                                     }
  786.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
  787.                                         integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));    
  788.                                     }
  789.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
  790.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  791.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
  792.                                         integrazione.getBusta().setTipoDestinatario(normalized);    
  793.                                     }
  794.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
  795.                                         integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));    
  796.                                     }
  797.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
  798.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  799.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoServizio(tipo, protocollo);
  800.                                         integrazione.getBusta().setTipoServizio(normalized);    
  801.                                     }
  802.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
  803.                                         integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));    
  804.                                     }
  805. //                                  else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
  806. //                                      String v = TransportUtils.getFirstValue(prop,key);
  807. //                                      try{
  808. //                                          if(v!=null) {
  809. //                                              integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
  810. //                                          }
  811. //                                      }catch(Exception e){
  812. //                                          throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
  813. //                                      }
  814. //                                  }
  815.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
  816.                                         integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));  
  817.                                     }
  818.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
  819.                                         integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));  
  820.                                     }
  821.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
  822.                                         integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));    
  823.                                     }
  824.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
  825.                                         integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));    
  826.                                     }
  827.                                     
  828.                                     // id e servizio applicativo
  829.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
  830.                                         integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));  
  831.                                     }
  832.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
  833.                                         integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));    
  834.                                     }
  835.                                     else if(this.openspcoop2 && CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
  836.                                         integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));  
  837.                                     }
  838.                                 }
  839.                                 break;
  840.                             }
  841.                         }
  842.                         
  843.                     }
  844.                 }
  845.             }
  846.         }catch(Exception e){
  847.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
  848.         }
  849.     }
  850.     
  851.     public void readUrlProperties(Map<String, List<String>> prop,
  852.             HeaderIntegrazione integrazione,
  853.             String protocollo) throws HeaderIntegrazioneException{
  854.         try{
  855.             if(prop!=null && integrazione!=null){
  856.             
  857.                 // Ricerca tra le proprieta' dell'url
  858.                 Iterator<String> it = prop.keySet().iterator();
  859.                 while (it.hasNext()) {
  860.                     String key = (String) it.next();

  862.                     if(key!=null){
  863.                         
  864.                         for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
  865.                             if(key.equalsIgnoreCase((String)this.keyValueIntegrazioneUrlBased.get(keywordIntegrazione))) {
  866.                                 
  867.                                 if(this.keyReadEnabled_HeaderIntegrazioneUrlBased.get(keywordIntegrazione)) {
  868.                                 
  869.                                     // Busta
  870.                                     if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
  871.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  872.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
  873.                                         integrazione.getBusta().setTipoMittente(normalized);    
  874.                                     }
  875.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
  876.                                         integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));    
  877.                                     }
  878.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
  879.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  880.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipo, protocollo);
  881.                                         integrazione.getBusta().setTipoDestinatario(normalized);    
  882.                                     }
  883.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
  884.                                         integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));    
  885.                                     }
  886.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
  887.                                         String tipo = TransportUtils.getFirstValue(prop,key);
  888.                                         String normalized = normalizeOpenSPCoop2GovWay_tipoServizio(tipo, protocollo);
  889.                                         integrazione.getBusta().setTipoServizio(normalized);    
  890.                                     }
  891.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
  892.                                         integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));    
  893.                                     }
  894. //                                  else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
  895. //                                      String v = TransportUtils.getFirstValue(prop,key);
  896. //                                      try{
  897. //                                          if(v!=null) {
  898. //                                              integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
  899. //                                          }
  900. //                                      }catch(Exception e){
  901. //                                          throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
  902. //                                      }
  903. //                                  }
  904.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
  905.                                         integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));  
  906.                                     }
  907.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
  908.                                         integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));  
  909.                                     }
  910.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
  911.                                         integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));    
  912.                                     }
  913.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
  914.                                         integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));    
  915.                                     }
  916.                                     
  917.                                     // id e servizio applicativo
  918.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
  919.                                         integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));  
  920.                                     }
  921.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
  922.                                         integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));    
  923.                                     }
  924.                                     else if(this.openspcoop2 && CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
  925.                                         integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));  
  926.                                     }
  927.                                 }
  928.                                 break;
  929.                             }
  930.                         }
  931.                         
  932.                     }
  933.                 }
  934.             }
  935.         }catch(Exception e){
  936.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
  937.         }
  938.     }
  939.     


  942.     public void setUrlProperties(HeaderIntegrazione integrazione,
  943.             Map<String, List<String>> properties,
  944.             Map<String, String> protocolInfos,
  945.             String protocollo) throws HeaderIntegrazioneException{

  947.         try{
  948.             if(properties!=null && integrazione!=null){
  949.                 if(integrazione.getBusta()!=null){              
  950.                     if(integrazione.getBusta().getTipoMittente()!=null) {
  951.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  952.                             String tipo = integrazione.getBusta().getTipoMittente();
  953.                             String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  954.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), normalized);
  955.                         }
  956.                     }
  957.                     if(integrazione.getBusta().getMittente()!=null) {
  958.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  959.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
  960.                         }
  961.                     }
  962.                     if(integrazione.getBusta().getTipoDestinatario()!=null) {
  963.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  964.                             String tipo = integrazione.getBusta().getTipoDestinatario();
  965.                             String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  966.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), normalized);
  967.                         }
  968.                     }
  969.                     if(integrazione.getBusta().getDestinatario()!=null) {
  970.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  971.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
  972.                         }
  973.                     }
  974.                     if(integrazione.getBusta().getTipoServizio()!=null) {
  975.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  976.                             String tipo = integrazione.getBusta().getTipoServizio();
  977.                             String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
  978.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), normalized);
  979.                         }
  980.                     }
  981.                     if(integrazione.getBusta().getServizio()!=null) {
  982.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  983.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
  984.                         }
  985.                     }
  986. //                  if(integrazione.getBusta().getVersioneServizio()!=null) {
  987. //                      if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  988. //                          TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
  989. //                      }
  990. //                  }
  991.                     if(integrazione.getBusta().getAzione()!=null) {
  992.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  993.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
  994.                         }
  995.                     }
  996.                     if(integrazione.getBusta().getID()!=null) {
  997.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  998.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
  999.                         }
  1000.                     }
  1001.                     if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
  1002.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  1003.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
  1004.                         }
  1005.                     }
  1006.                     if(integrazione.getBusta().getIdCollaborazione()!=null) {
  1007.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1008.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
  1009.                         }
  1010.                     }
  1011.                 }
  1012.                 if(integrazione.getIdApplicativo()!=null) {
  1013.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1014.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
  1015.                     }
  1016.                 }
  1017.                 if(integrazione.getServizioApplicativo()!=null) {
  1018.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1019.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
  1020.                     }
  1021.                 }
  1022.                 if(this.openspcoop2 && integrazione.getIdTransazione()!=null) {
  1023.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1024.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
  1025.                     }
  1026.                 }
  1027.             }
  1028.             if(properties!=null){
  1029. //              TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD,URLEncoder.encode(this.openspcoopProperties.getHttpServer(),"UTF-8"));
  1030. //              if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  1031. //                  TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD_DETAILS,URLEncoder.encode(this.openspcoopProperties.getHttpXPdDDetails(),"UTF-8"));
  1032. //              }
  1033.                 // 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.
  1034.                 
  1035.                 if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
  1036.                     if(this.openspcoop2) {
  1037.                         TransportUtils.setParameter(properties,OPENSPCOOP2_URL_BASED_PDD,this.openspcoopProperties.getHttpServer());
  1038.                         if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  1039.                             TransportUtils.setParameter(properties,OPENSPCOOP2_URL_BASED_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
  1040.                         }
  1041.                     }
  1042.                     else {
  1043.                         TransportUtils.setParameter(properties,OPENSPCOOP1_URL_BASED_PDD,this.openspcoopProperties.getHttpServer());
  1044.                         if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  1045.                             TransportUtils.setParameter(properties,OPENSPCOOP1_URL_BASED_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
  1046.                         }
  1047.                     }
  1048.                 }

  1050.                 if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  1051.                     // protocol info
  1052.                     if(protocolInfos!=null && protocolInfos.size()>0){
  1053.                         
  1054.                         String prefixProtocolInfo = this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
  1055.                         
  1056.                         Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  1057.                         while (itProtocolInfos.hasNext()) {
  1058.                             String name = (String) itProtocolInfos.next();
  1059.                             String value = protocolInfos.get(name);
  1060.                             String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  1061.                             TransportUtils.setParameter(properties,nameWithPrefix,value);
  1062.                         }
  1063.                     }
  1064.                 }
  1065.             }
  1066.             
  1067.         }catch(Exception e){
  1068.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
  1069.         }
  1070.     }
  1071.     
  1072.     public void setInfoProductTransportProperties(Map<String, List<String>> properties,
  1073.             String protocollo) throws HeaderIntegrazioneException{
  1074.         setTransportProperties(null, properties, null,
  1075.                 protocollo);
  1076.     }
  1077.     public void setTransportProperties(HeaderIntegrazione integrazione,
  1078.             Map<String, List<String>> properties,
  1079.             Map<String, String> protocolInfos,
  1080.             String protocollo) throws HeaderIntegrazioneException{

  1082.         try{
  1083.             if(properties!=null && integrazione!=null){
  1084.                 if(integrazione.getBusta()!=null){
  1085.                     if(integrazione.getBusta().getTipoMittente()!=null) {
  1086.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  1087.                             String tipo = integrazione.getBusta().getTipoMittente();
  1088.                             String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  1089.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)), normalized);
  1090.                         }
  1091.                     }
  1092.                     if(integrazione.getBusta().getMittente()!=null) {
  1093.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  1094.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)), integrazione.getBusta().getMittente());
  1095.                         }
  1096.                     }
  1097.                     if(integrazione.getBusta().getTipoDestinatario()!=null) {
  1098.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  1099.                             String tipo = integrazione.getBusta().getTipoDestinatario();
  1100.                             String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  1101.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)), normalized);
  1102.                         }
  1103.                     }
  1104.                     if(integrazione.getBusta().getDestinatario()!=null) {
  1105.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  1106.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)), integrazione.getBusta().getDestinatario());
  1107.                         }
  1108.                     }
  1109.                     if(integrazione.getBusta().getTipoServizio()!=null) {
  1110.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  1111.                             String tipo = integrazione.getBusta().getTipoServizio();
  1112.                             String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
  1113.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)), normalized);
  1114.                         }
  1115.                     }
  1116.                     if(integrazione.getBusta().getServizio()!=null) {
  1117.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  1118.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)), integrazione.getBusta().getServizio());
  1119.                         }
  1120.                     }
  1121. //                  if(integrazione.getBusta().getVersioneServizio()!=null) {
  1122. //                      if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  1123. //                          TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.getProperty(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)), integrazione.getBusta().getVersioneServizio().intValue()+"");
  1124. //                      }
  1125. //                  }
  1126.                     if(integrazione.getBusta().getAzione()!=null) {
  1127.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  1128.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)), integrazione.getBusta().getAzione());
  1129.                         }
  1130.                     }
  1131.                     if(integrazione.getBusta().getID()!=null) {
  1132.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  1133.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)), integrazione.getBusta().getID());
  1134.                         }
  1135.                     }
  1136.                     if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
  1137.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  1138.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)), integrazione.getBusta().getRiferimentoMessaggio());
  1139.                         }
  1140.                     }
  1141.                     if(integrazione.getBusta().getIdCollaborazione()!=null) {
  1142.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1143.                             TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)), integrazione.getBusta().getIdCollaborazione());
  1144.                         }
  1145.                     }
  1146.                 }
  1147.                 if(integrazione.getIdApplicativo()!=null) {
  1148.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1149.                         TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)), integrazione.getIdApplicativo());
  1150.                     }
  1151.                 }
  1152.                 if(integrazione.getServizioApplicativo()!=null) {
  1153.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1154.                         TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)), integrazione.getServizioApplicativo());
  1155.                     }
  1156.                 }
  1157.                 if(this.openspcoop2 && integrazione.getIdTransazione()!=null) {
  1158.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1159.                         TransportUtils.setParameter(properties,normalizeX_(this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)), integrazione.getIdTransazione());
  1160.                     }
  1161.                 }
  1162.             }
  1163.             if(properties!=null){
  1164.                 
  1165.                 boolean infoProduct = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO);
  1166.                 if(infoProduct) {
  1167.                     String hdrPdd = null;
  1168.                     String hdrPddDetails = null;
  1169.                     if(this.openspcoop2) {
  1170.                         hdrPdd = normalizeX_(OPENSPCOOP2_HEADER_HTTP_X_PDD);
  1171.                         hdrPddDetails = normalizeX_(OPENSPCOOP2_HEADER_HTTP_X_PDD_DETAILS);
  1172.                     }
  1173.                     else {
  1174.                         hdrPdd = normalizeX_(OPENSPCOOP1_HEADER_HTTP_X_PDD);
  1175.                         hdrPddDetails = normalizeX_(OPENSPCOOP1_HEADER_HTTP_X_PDD_DETAILS);
  1176.                     }
  1177.                     if(properties.containsKey(hdrPdd)==false) {
  1178.                         TransportUtils.setParameter(properties,hdrPdd,this.openspcoopProperties.getHttpServer());
  1179.                     }
  1180.                     if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  1181.                         if(properties.containsKey(hdrPddDetails)==false) {
  1182.                             TransportUtils.setParameter(properties,hdrPddDetails,this.openspcoopProperties.getHttpXPdDDetails());
  1183.                         }
  1184.                     }
  1185.                 }
  1186.                 
  1187.                 boolean userAgent = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_USER_AGENT);
  1188.                 if(userAgent) {
  1189.                     if(this.request) {
  1190.                         if(properties.containsKey(HttpConstants.USER_AGENT)==false) {
  1191.                             TransportUtils.setParameter(properties,HttpConstants.USER_AGENT,this.openspcoopProperties.getHttpUserAgent());
  1192.                         }
  1193.                     }
  1194.                     else {
  1195.                         if(properties.containsKey(HttpConstants.SERVER)==false) {
  1196.                             TransportUtils.setParameter(properties,HttpConstants.SERVER,this.openspcoopProperties.getHttpUserAgent());
  1197.                         }
  1198.                     }
  1199.                 }
  1200.                 
  1201.                 if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  1202.                     if(protocolInfos!=null && protocolInfos.size()>0){
  1203.                         
  1204.                         String prefixProtocolInfo = this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);

  1206.                         Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  1207.                         while (itProtocolInfos.hasNext()) {
  1208.                             String name = (String) itProtocolInfos.next();
  1209.                             String value = protocolInfos.get(name);
  1210.                             String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  1211.                             TransportUtils.setParameter(properties,normalizeX_(nameWithPrefix),value);
  1212.                         }
  1213.                     }
  1214.                 }
  1215.                 
  1216.             }
  1217.         }catch(Exception e){
  1218.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
  1219.         }
  1220.     }
  1221.     
  1222.     

  1224.     public void readHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
  1225.             String actorIntegrazione,
  1226.             String protocollo) throws HeaderIntegrazioneException{
  1227.         
  1228.         
  1229.         try{            
  1230.             if(actorIntegrazione==null)
  1231.                 throw new Exception("Actor non definito");
  1232.             SOAPHeader header = message.getSOAPHeader();
  1233.             if(header==null){
  1234.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  1235.                 return;
  1236.             }
  1237.             SOAPHeaderElement headerElement = null;
  1238.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  1239.             while( it.hasNext()  ){
  1240.                 // Test Header Element
  1241.                 headerElement = (SOAPHeaderElement) it.next();
  1242.                 //Controllo Actor
  1243.                 String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
  1244.                 if( actorIntegrazione.equals(actorCheck) ){
  1245.                     break;
  1246.                 }else{
  1247.                     headerElement = null;
  1248.                 }
  1249.             }
  1250.             if(headerElement==null){
  1251.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
  1252.                 return;
  1253.             }
  1254.             
  1255.             // validazione XSD
  1256.             if(MessageType.SOAP_11.equals(message.getMessageType())){
  1257.                 ValidatoreXSD validatoreXSD_soap11 = getValidatoreXSD(false, message.getFactory());
  1258.                 if(validatoreXSD_soap11==null)
  1259.                     throw new Exception("Validatore XSD (Soap11) non istanziato");
  1260.                 validatoreXSD_soap11.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
  1261.             }
  1262.             else if(MessageType.SOAP_12.equals(message.getMessageType())){
  1263.                 if(!this.openspcoop2) {
  1264.                     throw new HeaderIntegrazioneException("SOAP12 non supportato");
  1265.                 }
  1266.                 ValidatoreXSD validatoreXSD_soap12 = getValidatoreXSD(true, message.getFactory());
  1267.                 if(validatoreXSD_soap12==null)
  1268.                     throw new Exception("Validatore XSD (Soap12) non istanziato");
  1269.                 validatoreXSD_soap12.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
  1270.             }
  1271.             else{
  1272.                 throw MessageNotSupportedException.newMessageNotSupportedException(message.getMessageType());
  1273.             }

  1275.             
  1276.             // Ricerca tra gli attributi dell'header SOAP
  1277.             String tipoMittente = null;
  1278.             try{
  1279.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  1280.                     tipoMittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE));
  1281.                     tipoMittente = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipoMittente, protocollo);
  1282.                 }
  1283.             }catch(Exception e){}
  1284.             if(tipoMittente!=null && tipoMittente.compareTo("")!=0)
  1285.                 integrazione.getBusta().setTipoMittente(tipoMittente);
  1286.             
  1287.             String mittente = null;
  1288.             try{
  1289.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  1290.                     mittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE));
  1291.                 }
  1292.             }catch(Exception e){}
  1293.             if(mittente!=null && mittente.compareTo("")!=0)
  1294.                 integrazione.getBusta().setMittente(mittente);
  1295.             
  1296.             String tipoDestinatario = null;
  1297.             try{
  1298.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  1299.                     tipoDestinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO));
  1300.                     tipoDestinatario = normalizeOpenSPCoop2GovWay_tipoSoggetto(tipoDestinatario, protocollo);
  1301.                 }
  1302.             }catch(Exception e){}
  1303.             if(tipoDestinatario!=null && tipoDestinatario.compareTo("")!=0)
  1304.                 integrazione.getBusta().setTipoDestinatario(tipoDestinatario);
  1305.             
  1306.             String destinatario = null;
  1307.             try{
  1308.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  1309.                     destinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO));
  1310.                 }
  1311.             }catch(Exception e){}
  1312.             if(destinatario!=null && destinatario.compareTo("")!=0)
  1313.                 integrazione.getBusta().setDestinatario(destinatario);

  1315.             String tipoServizio = null;
  1316.             try{
  1317.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  1318.                     tipoServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO));
  1319.                     tipoServizio = normalizeOpenSPCoop2GovWay_tipoServizio(tipoServizio, protocollo);
  1320.                 }
  1321.             }catch(Exception e){}
  1322.             if(tipoServizio!=null && tipoServizio.compareTo("")!=0)
  1323.                 integrazione.getBusta().setTipoServizio(tipoServizio);
  1324.             
  1325.             String servizio = null;
  1326.             try{
  1327.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  1328.                     servizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO));
  1329.                 }
  1330.             }catch(Exception e){}
  1331.             if(servizio!=null && servizio.compareTo("")!=0)
  1332.                 integrazione.getBusta().setServizio(servizio);
  1333.             
  1334. //          String versioneServizio = null;
  1335. //          try{
  1336. //              if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  1337. //                  versioneServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO));
  1338. //              }
  1339. //          }catch(Exception e){}
  1340. //          if(versioneServizio!=null && versioneServizio.compareTo("")!=0){
  1341. //              try{
  1342. //                  integrazione.getBusta().setVersioneServizio(Integer.parseInt(versioneServizio));
  1343. //              }catch(Exception e){
  1344. //                  throw new Exception("Formato versione ["+versioneServizio+"] non corretto: "+e.getMessage(),e);
  1345. //              }
  1346. //          }

  1348.             String azione= null;
  1349.             try{
  1350.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  1351.                     azione= headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE));
  1352.                 }
  1353.             }catch(Exception e){}
  1354.             if(azione!=null && azione.compareTo("")!=0)
  1355.                 integrazione.getBusta().setAzione(azione);

  1357.             String idBusta = null;
  1358.             try{
  1359.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  1360.                     idBusta = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO));
  1361.                 }
  1362.             }catch(Exception e){}
  1363.             if(idBusta!=null && idBusta.compareTo("")!=0)
  1364.                 integrazione.getBusta().setID(idBusta);

  1366.             String riferimentoMessaggio = null;
  1367.             try{
  1368.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  1369.                     riferimentoMessaggio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO));
  1370.                 }
  1371.             }catch(Exception e){}
  1372.             if(riferimentoMessaggio!=null && riferimentoMessaggio.compareTo("")!=0)
  1373.                 integrazione.getBusta().setRiferimentoMessaggio(riferimentoMessaggio);

  1375.             String collaborazione = null;
  1376.             try{
  1377.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1378.                     collaborazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE));
  1379.                 }
  1380.             }catch(Exception e){}
  1381.             if(collaborazione!=null && collaborazione.compareTo("")!=0)
  1382.                 integrazione.getBusta().setIdCollaborazione(collaborazione);

  1384.             String idApplicativo = null;
  1385.             try{
  1386.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1387.                     idApplicativo = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO));
  1388.                 }
  1389.             }catch(Exception e){}
  1390.             if(idApplicativo!=null && idApplicativo.compareTo("")!=0)
  1391.                 integrazione.setIdApplicativo(idApplicativo);

  1393.             String sa = null;
  1394.             try{
  1395.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1396.                     sa = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO));
  1397.                 }
  1398.             }catch(Exception e){}
  1399.             if(sa!=null && sa.compareTo("")!=0)
  1400.                 integrazione.setServizioApplicativo(sa);
  1401.             
  1402.             if(this.openspcoop2) {
  1403.                 String idTransazione = null;
  1404.                 try{
  1405.                     if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1406.                         idTransazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE));
  1407.                     }
  1408.                 }catch(Exception e){}
  1409.                 if(idTransazione!=null && idTransazione.compareTo("")!=0)
  1410.                     integrazione.setIdTransazione(idTransazione);
  1411.             }
  1412.             
  1413.         }catch(Exception e){
  1414.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header soap non riuscita: "+e.getMessage(),e);
  1415.         }
  1416.     }

  1418.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  1419.             String idBusta,String servizioApplicativo,
  1420.             String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
  1421.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1422.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1423.             Map<String, String> protocolInfos,
  1424.             String protocollo) throws Exception{
  1425.         updateHeader(message, soggettoFruitore, idServizio, idBusta, null, 
  1426.                 servizioApplicativo, correlazioneApplicativa, riferimentoCorrelazioneApplicativaRichiesta, idTransazione,
  1427.                 actorIntegrazione, nomeElemento, prefix, namespace, 
  1428.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
  1429.                 protocollo);
  1430.     }
  1431.     
  1432.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  1433.             String idBusta,String idBustaRisposta,String servizioApplicativo,
  1434.             String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
  1435.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1436.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1437.             Map<String, String> protocolInfos,
  1438.             String protocollo) throws Exception{
  1439.         
  1440.         HeaderIntegrazione integrazione = new HeaderIntegrazione(idTransazione);
  1441.         integrazione.setIdApplicativo(correlazioneApplicativa);
  1442.         integrazione.setServizioApplicativo(servizioApplicativo);
  1443.         HeaderIntegrazioneBusta busta = new HeaderIntegrazioneBusta();
  1444.         busta.setTipoMittente(soggettoFruitore.getTipo());
  1445.         busta.setMittente(soggettoFruitore.getNome());
  1446.         busta.setTipoDestinatario(idServizio.getSoggettoErogatore().getTipo());
  1447.         busta.setDestinatario(idServizio.getSoggettoErogatore().getNome());
  1448.         busta.setTipoServizio(idServizio.getTipo());
  1449.         busta.setServizio(idServizio.getNome());
  1450.         busta.setVersioneServizio(idServizio.getVersione());
  1451.         busta.setAzione(idServizio.getAzione());
  1452.         if(idBustaRisposta==null){
  1453.             busta.setID(idBusta);
  1454.         }
  1455.         else{
  1456.             busta.setID(idBustaRisposta);
  1457.             busta.setRiferimentoMessaggio(idBusta);
  1458.         }
  1459.         integrazione.setBusta(busta);
  1460.         
  1461.         this.updateHeader(message, integrazione, actorIntegrazione, nomeElemento, prefix, namespace, 
  1462.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
  1463.                 protocollo);
  1464.     }
  1465.         
  1466.     public void updateHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
  1467.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1468.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1469.             Map<String, String> protocolInfos,
  1470.             String protocollo) throws Exception{
  1471.         
  1472.         if(actorIntegrazione==null)
  1473.             throw new Exception("Actor non definito");
  1474.         SOAPHeader header = message.getSOAPHeader();
  1475.         SOAPHeaderElement headerIntegrazione = null;
  1476.         if(header==null){
  1477.             
  1478.             // Creo soap header
  1479.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente: add soapHeader");
  1480.             header = message.getSOAPPart().getEnvelope().addHeader();
  1481.             
  1482.         }else{

  1484.             // cerco soap di integrazione
  1485.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  1486.             while( it.hasNext()  ){
  1487.                 // Test Header Element
  1488.                 headerIntegrazione = (SOAPHeaderElement) it.next();
  1489.                 //Controllo Actor
  1490.                 String actorCheck = SoapUtils.getSoapActor(headerIntegrazione, message.getMessageType());
  1491.                 if( actorIntegrazione.equals(actorCheck) ){
  1492.                     break;
  1493.                 }else{
  1494.                     headerIntegrazione = null;
  1495.                 }
  1496.             }
  1497.             if(headerIntegrazione==null){
  1498.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente, lo creo");
  1499.             }
  1500.         }

  1502.         List<SOAPElement> v = new ArrayList<SOAPElement>(); // mantengo eventuali message element presenti
  1503.         if(headerIntegrazione!=null){
  1504.             
  1505.             java.util.Iterator<?> it = headerIntegrazione.getChildElements();
  1506.             if(it.hasNext()){
  1507.                 SOAPElement tmp = (SOAPElement) it.next();
  1508.                 //System.out.println("CONSERVO MSG ELEMENT["+tmp.getLocalName()+"]");
  1509.                 v.add(tmp);
  1510.             }
  1511.              
  1512.             header.removeChild(headerIntegrazione);
  1513.         }
  1514.         
  1515.         // creo header da nuovo
  1516.         SOAPHeaderElement headerIntegrazioneNEW = this.buildHeader(integrazione, nomeElemento, prefix, namespace, 
  1517.                 actorIntegrazione, message, 
  1518.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos,
  1519.                 protocollo);    
  1520.         
  1521.         // Riaggiungo eventuali elementi interni
  1522.         while(v.size()>0){
  1523.             SOAPElement tmp = v.remove(0);
  1524.             //System.out.println("RIAGGIUNGO MSG ELEMENT["+tmp.getLocalName()+"]");
  1525.             headerIntegrazioneNEW.addChildElement(tmp);
  1526.         }
  1527.         
  1528.         //System.out.println("OTTENGO ["+headerIntegrazioneNEW.getAsString()+"]");
  1529.         
  1530.         // aggiungo header element al SOAP Header
  1531.         //header.addChildElement(headerIntegrazioneNEW);
  1532.         message.addHeaderElement(header, headerIntegrazioneNEW);

  1534.     }
  1535.     
  1536.     public SOAPHeaderElement buildHeader(HeaderIntegrazione integrazione,String nomeElemento,
  1537.             String prefix,String namespace, String actor, 
  1538.             OpenSPCoop2SoapMessage m,
  1539.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1540.             Map<String, String> protocolInfos,
  1541.             String protocollo) throws HeaderIntegrazioneException{

  1543.         try{
  1544.             SOAPHeader soapHeader = m.getSOAPHeader();
  1545.             if(soapHeader==null){
  1546.                 soapHeader = m.getSOAPPart().getEnvelope().addHeader();
  1547.             }
  1548.             SOAPHeaderElement header = m.newSOAPHeaderElement(soapHeader, new QName(namespace,nomeElemento,prefix));

  1550.             header.setActor(actor);
  1551.             header.setMustUnderstand(false);
  1552.             
  1553.             setAttributes(integrazione,header,protocollo);
  1554.             
  1555.             if(this.openspcoop2 && this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  1556.                 if(protocolInfos!=null && protocolInfos.size()>0){
  1557.                     
  1558.                     String prefixProtocolInfo = this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
  1559.                     
  1560.                     Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  1561.                     while (itProtocolInfos.hasNext()) {
  1562.                         String name = (String) itProtocolInfos.next();
  1563.                         String value = protocolInfos.get(name);
  1564.                         String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  1565.                         SOAPElement element = header.addChildElement(new QName(namespace,proprietaProtocolloNomeElemento,prefix));
  1566.                         element.setTextContent(value);
  1567.                         @SuppressWarnings("unused")
  1568.                         SOAPElement attribute = element.addAttribute(new QName(proprietaProtocolloNomeTipoElemento),nameWithPrefix);
  1569.                     }
  1570.                 }
  1571.             }
  1572.             
  1573.             return header;

  1575.         }catch(Exception e){
  1576.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione dell'header soap non riuscita: "+e.getMessage(),e);
  1577.         }
  1578.     }
  1579.     
  1580.     
  1581.     public void setAttributes(HeaderIntegrazione integrazione, SOAPHeaderElement header, String protocollo){
  1582.         if(integrazione.getBusta()!=null){

  1584.             if(integrazione.getBusta().getTipoMittente()!=null){
  1585.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  1586.                     String tipo = integrazione.getBusta().getTipoMittente();
  1587.                     String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  1588.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), normalized);
  1589.                 }
  1590.             }
  1591.             if(integrazione.getBusta().getMittente()!=null){
  1592.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  1593.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
  1594.                 }
  1595.             }

  1597.             if(integrazione.getBusta().getTipoDestinatario()!=null){
  1598.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  1599.                     String tipo = integrazione.getBusta().getTipoDestinatario();
  1600.                     String normalized = normalizeGovWay2OpenSPCoop_tipoSoggetto(tipo, protocollo);
  1601.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), normalized);
  1602.                 }
  1603.             }
  1604.             if(integrazione.getBusta().getDestinatario()!=null){
  1605.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  1606.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
  1607.                 }
  1608.             }

  1610.             if(integrazione.getBusta().getTipoServizio()!=null){
  1611.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  1612.                     String tipo = integrazione.getBusta().getTipoServizio();
  1613.                     String normalized = normalizeGovWay2OpenSPCoop_tipoServizio(tipo, protocollo);
  1614.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), normalized);
  1615.                 }
  1616.             }
  1617.             if(integrazione.getBusta().getServizio()!=null){
  1618.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  1619.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
  1620.                 }
  1621.             }
  1622. //          if(integrazione.getBusta().getVersioneServizio()!=null){
  1623. //              if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  1624. //                  header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
  1625. //              }
  1626. //          }

  1628.             if(integrazione.getBusta().getAzione()!=null){
  1629.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  1630.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
  1631.                 }
  1632.             }

  1634.             if(integrazione.getBusta().getID()!=null){
  1635.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  1636.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
  1637.                 }
  1638.             }

  1640.             if(integrazione.getBusta().getRiferimentoMessaggio()!=null){
  1641.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  1642.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
  1643.                 }
  1644.             }

  1646.             if(integrazione.getBusta().getIdCollaborazione()!=null){
  1647.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1648.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
  1649.                 }
  1650.             }
  1651.         }

  1653.         if(integrazione.getIdApplicativo()!=null){
  1654.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1655.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
  1656.             }
  1657.         }
  1658.         
  1659.         if(integrazione.getServizioApplicativo()!=null){
  1660.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1661.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
  1662.             }
  1663.         }
  1664.         
  1665.         if(this.openspcoop2 && integrazione.getIdTransazione()!=null){
  1666.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1667.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
  1668.             }
  1669.         }
  1670.         
  1671.         if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
  1672.             
  1673.             if(this.openspcoop2) {
  1674.                 header.setAttribute(OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDVersione());
  1675.                 if(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails())){
  1676.                     header.setAttribute(OPENSPCOOP2_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails());
  1677.                 }
  1678.             }
  1679.             else {
  1680.                 header.setAttribute(OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_VERSION, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDVersione());
  1681.                 if(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails())){
  1682.                     header.setAttribute(OPENSPCOOP1_HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails());
  1683.                 }
  1684.             }
  1685.             
  1686.         }

  1688.     }
  1689.     
  1690.     
  1691.     public void deleteHeader(OpenSPCoop2SoapMessage message,String actorIntegrazione) throws HeaderIntegrazioneException{

  1693.         try{

  1695.             if(actorIntegrazione==null)
  1696.                 throw new Exception("Actor non definito");
  1697.             SOAPHeader header = message.getSOAPHeader();
  1698.             if(header==null){
  1699.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  1700.                 return;
  1701.             }
  1702.             SOAPHeaderElement headerElement = null;
  1703.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  1704.             while( it.hasNext()  ){
  1705.                 // Test Header Element
  1706.                 headerElement = (SOAPHeaderElement) it.next();
  1707.                 //Controllo Actor
  1708.                 String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
  1709.                 if( actorIntegrazione.equals(actorCheck) ){
  1710.                     break;
  1711.                 }else{
  1712.                     headerElement = null;
  1713.                 }
  1714.             }
  1715.             if(headerElement==null){
  1716.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
  1717.                 return;
  1718.             }
  1719.             
  1720.             header.removeChild(headerElement);
  1721.             
  1722.         }catch(Exception e){
  1723.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, eliminazione dell'header soap non riuscita: "+e.getMessage(),e);
  1724.         }
  1725.     }
  1726.     
  1727.     public static String getIdTransazione(PdDContext context){
  1728.         return UtilitiesIntegrazione.getIdTransazione(context);
  1729.     }
  1730. }
Created with JaCoCo 0.8.8.202204050719