import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Override
public void doWithMessage(WebServiceMessage request) throws IOException, TransformerException {
	callback.doWithMessage(request);

	SaajSoapMessage message = (SaajSoapMessage) request;
	SOAPMessage mes = message.getSaajMessage();

	try {
		SOAPBody body = mes.getSOAPBody();

		SOAPElement queryEle = (SOAPElement) body.getChildElements().next();
		SOAPElement kehaEle = (SOAPElement) queryEle.getChildElements().next();

		java.util.Iterator kehaChilds = kehaEle.getChildElements();
		while (kehaChilds.hasNext()) {
			Object nextEle = kehaChilds.next();
			if (nextEle instanceof SOAPElement) {
				addType((SOAPElement) nextEle);
			}
		}
	} catch(Exception ex) {
		ex.printStackTrace();
	}
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  callback.doWithMessage(message);
  try {
    SaajSoapMessage saajMessage = (SaajSoapMessage) message;
    SOAPMessage soapmess = saajMessage.getSaajMessage();
    SOAPEnvelope env = soapmess.getSOAPPart().getEnvelope();
    env.addNamespaceDeclaration("xro", "http://x-road.ee/xsd/x-road.xsd");
    Iterator headers = env.getHeader().getChildElements();
    while (headers.hasNext()) {
      SOAPElement header = (SOAPElement) headers.next();
      if (header.getNamespaceURI().equalsIgnoreCase("http://x-rd.net/xsd/xroad.xsd")) {
        String localHeaderName = header.getLocalName();
        QName qName = new QName("http://x-road.ee/xsd/x-road.xsd", localHeaderName, "xro");
        header.setElementQName(qName);
      }
    }
  } catch (SOAPException e) {
    throw new RuntimeException(e);
  }

}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
    callback.doWithMessage(message);
    try {
        SaajSoapMessage saajMsg = (SaajSoapMessage) message;
        SOAPMessage soapMsg = saajMsg.getSaajMessage();
        SOAPEnvelope env = soapMsg.getSOAPPart().getEnvelope();
        env.addNamespaceDeclaration(ns, nsV31Uri);

        Iterator headers = env.getHeader().getChildElements();
        while (headers.hasNext()) {
            SOAPElement header = (SOAPElement) headers.next();
            if (header.getNamespaceURI().equalsIgnoreCase(nsV30Uri)) {
                QName qName = new QName(nsV31Uri, header.getLocalName(), ns);
                header.setElementQName(qName);
            }
        }

        formatDate(saajMsg, startDate);
        formatDate(saajMsg, endDate);
    } catch (SOAPException e) {
        throw new RuntimeException(e);
    }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
private void formatDate(SaajSoapMessage saajMsg, Date date) throws TransformerException {
    if (date == null) {
        return;
    }
    SOAPPart soapPart = saajMsg.getSaajMessage().getSOAPPart();
    Source source = new DOMSource(soapPart);
    StringResult stringResult = new StringResult();
    TransformerFactory.newInstance().newTransformer().transform(source, stringResult);
    try {
        String from = dateWithTimezone.format(date);
        String to = dateWithoutTimezone.format(date);
        String content = StringUtils.replace(stringResult.toString(), from, to);
        soapPart.setContent(new StringSource(content));
    } catch (Exception e) {
        throw new TransformerException(e);
    }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
/**
 * Substitutes all occurences of some given string inside the given {@link WebServiceMessage} with another value.
 *
 * @param message message to substitute in
 * @param from the value to substitute
 * @param to the value to substitute with
 * @throws TransformerException
 */
public static void substitute(WebServiceMessage message, String from, String to) throws TransformerException {
  SaajSoapMessage saajSoapMessage = (SaajSoapMessage) message;
  SOAPPart soapPart = saajSoapMessage.getSaajMessage().getSOAPPart();

  Source source = new DOMSource(soapPart);
  StringResult stringResult = new StringResult();

  TransformerFactory.newInstance().newTransformer().transform(source, stringResult);

  String content = stringResult.toString().replaceAll(from, to);

  try {
    soapPart.setContent(new StringSource(content));
  } catch (SOAPException e) {
    throw new TransformerException(e);
  }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public void doWithMessage(WebServiceMessage message) {
  SaajSoapMessage saajMessage = (SaajSoapMessage) message;
  try {
    // Add attachments
    if (attachments != null) {
      for (XRoadAttachment attachment : attachments) {
        saajMessage.addAttachment("<" + attachment.getCid() + ">", attachment, attachment.getContentType());
      }
    }
    SOAPMessage soapmess = saajMessage.getSaajMessage();
    SOAPEnvelope env = soapmess.getSOAPPart().getEnvelope();

    protocolVersionStrategy.addNamespaces(env);
    protocolVersionStrategy.addXTeeHeaderElements(env, serviceConfiguration);
  } catch (SOAPException e) {
    throw new RuntimeException(e);
  }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
private boolean logMessage(MessageContext mc, MessageType messageType) {
  if (log.isDebugEnabled()) {
    WebServiceMessage message = MessageType.REQUEST.equals(messageType) ? mc.getRequest() : mc.getResponse();

    if (message instanceof SaajSoapMessage) {
      OutputStream out = new ByteArrayOutputStream();
      try {
        ((SaajSoapMessage) message).writeTo(out);
        log.debug(messageType + " message follows:\n" + out.toString());
      } catch (Exception e) {
        throw new RuntimeException(e);
      }
    }
  }

  return true;
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Test
public void testExtractDataBase64PEMFormat() throws IOException, SOAPException {
    // xml elements in a single row, but base64binary part on different rows (PEM format)
    XRoadMessage message1 = EXTRACTOR.extractData(new SaajSoapMessage(getMessageFromString("extractor/EarestFail1.xml")));
    assertEquals(RESULT_PEM_FORMAT, message1.getContent().toString());

    // manually formated file with whitespaces between elements without new row (base64binary in PEM format)
    XRoadMessage message2 = EXTRACTOR.extractData(new SaajSoapMessage(getMessageFromString("extractor/EarestFail2.xml")));
    assertEquals(RESULT_PEM_FORMAT, message2.getContent().toString());

    // menually formated file without whitespaces between elements and without new row (base64binary in PEM format)
    XRoadMessage message3 = EXTRACTOR.extractData(new SaajSoapMessage(getMessageFromString("extractor/EarestFail3.xml")));
    assertEquals(RESULT_PEM_FORMAT, message3.getContent().toString());

    // menually formated file with whitespaces between elements and without new row (base64binary in PEM format)
    XRoadMessage message5 = EXTRACTOR.extractData(new SaajSoapMessage(getMessageFromString("extractor/EarestFail5.xml")));
    assertEquals(RESULT_PEM_FORMAT, message5.getContent().toString());
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
/**
 * Gets original SOAP envelope.
 *
 * @param exchange the exchange
 * @return envelope as string or {@code null} if input message isn't Spring web service message
 */
@Nullable
public static String getSOAPEnvelope(Exchange exchange) {
    if (! (exchange.getIn() instanceof SpringWebserviceMessage)) {
        return null;
    }

    try {
        TransformerFactory tranFactory = TransformerFactory.newInstance();
        Transformer aTransformer = tranFactory.newTransformer();

        SpringWebserviceMessage inMsg = (SpringWebserviceMessage) exchange.getIn();
        Source source = ((SaajSoapMessage) inMsg.getWebServiceMessage()).getEnvelope().getSource();

        StringResult strRes = new StringResult();
        aTransformer.transform(source, strRes);

        return strRes.toString();
    } catch (Exception ex) {
        throw new IllegalStateException("Error occurred during conversion SOAP envelope to string", ex);
    }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Override
public boolean handleRequest(MessageContext messageContext, Object endpoint)
        throws IOException, SAXException, TransformerException {

    // validate payload
    boolean reqValResult = super.handleRequest(messageContext, endpoint);

    // validate header
    if (reqValResult && validateHeader && !ignoreRequest(messageContext)) {
        SaajSoapMessage soapMessage = (SaajSoapMessage) messageContext.getRequest();
        SoapHeader soapHeader = soapMessage.getSoapHeader();

        ValidationIntegrationException[] errors = validateHeader(soapHeader);
        if (!ObjectUtils.isEmpty(errors)) {
            return handleHeaderValidationErrors(messageContext, errors);
        } else if (logger.isDebugEnabled()) {
            logger.debug("Request header validated");
        }
    }

    return reqValResult;
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Override
public void doWithMessage(WebServiceMessage request) throws IOException, TransformerException {
  SaajSoapMessage message = (SaajSoapMessage) request;
  SOAPMessage mes = message.getSaajMessage();

  try {
    mes.getSOAPPart().getEnvelope().addNamespaceDeclaration(StandardXRoadConsumer.ROOT_NS,
                                                            metadata.getRequestElementNs());
    getMarshaller().marshal(object, new DOMResult(mes.getSOAPBody()));
  } catch (SOAPException e) {
    throw new RuntimeException("Invalid SOAP message");
  }
  callback.doWithMessage(request);
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Override
public boolean handleResponse(MessageContext messageContext, Object o) throws Exception {

    WebServiceMessage response = messageContext.getResponse();

    SaajSoapMessage saajSoapMessage = (SaajSoapMessage) response;
    SOAPMessage soapMessage = saajSoapMessage.getSaajMessage();
    SOAPPart soapPart = soapMessage.getSOAPPart();
    SOAPEnvelope envelope = soapPart.getEnvelope();
    SOAPBody body = envelope.getBody();
    Iterator responses = body.getChildElements(new QName(
            "http://xroad.vrk.fi/xroad-catalog-lister",
            "GetWsdlResponse"));
    while (responses.hasNext()) {
        Node wsdlResponse = (Node) responses.next();
        NodeList children = wsdlResponse.getChildNodes();
        for (int i = 0; i < children.getLength(); i++) {
            Node child = children.item(i);
            if (child.getLocalName().equals("wsdl")) {
                CDATASection cdat = soapPart.createCDATASection(child.getFirstChild().getNodeValue());
                child.removeChild(child.getFirstChild());
                child.appendChild(cdat);
            }
        }
    }
    return true;
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
/**
 * Test method for
 * {@link py.una.pol.karaku.services.client.KarakuFaultMessageResolver#resolveFault(org.springframework.ws.WebServiceMessage)}
 * .
 */
@Test
public void testResolveFault_HTTPException() throws Exception {

	Jaxb2Marshaller marshaller = new Jaxb2Marshaller();
	marshaller.setClassesToBeBound(HTTPExceptionDTO.class);

	KarakuFaultMessageResolver resolver = new KarakuFaultMessageResolver(
			marshaller);
	// @formatter:off
	SOAPMessage message = getFromString(""
			+ "<SOAP-ENV:Envelope xmlns:SOAP-ENV=\"http://schemas.xmlsoap.org/soap/envelope/\"> " +
			"   <SOAP-ENV:Header/> " +
			"   <SOAP-ENV:Body> " +
			"      <SOAP-ENV:Fault> " +
			"         <faultcode>SOAP-ENV:Client</faultcode> " +
			"         <faultstring xml:lang=\"en\">Invalid request</faultstring> " +
			"         <detail> " +
			"            <ns4:HTTPException xmlns:ns4=\"http://sigh.med.una.py/2013/schemas/base\"> " +
			"               <code>1</code>" +
			"               <summary>2</summary>" +
			"            </ns4:HTTPException>" +
			"         </detail>" +
			"      </SOAP-ENV:Fault>" +
			"   </SOAP-ENV:Body>" +
			"</SOAP-ENV:Envelope>");
	// @formatter:on

	SaajSoapMessage ssm = new SaajSoapMessage(message);
	try {
		resolver.resolveFault(ssm);
		fail();
	} catch (HTTPException exception) {
		assertEquals("1", exception.getCode());
		assertEquals("2", exception.getShortDescription());
	}
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
@Test
public void testResolvXteFault_NormalException() throws Exception {

	Jaxb2Marshaller marshaller = new Jaxb2Marshaller();
	marshaller.setClassesToBeBound(HTTPExceptionDTO.class);

	KarakuFaultMessageResolver resolver = new KarakuFaultMessageResolver(
			marshaller);
	// @formatter:off
	SOAPMessage message = getFromString(""
			+ "<SOAP-ENV:Envelope xmlns:SOAP-ENV=\"http://schemas.xmlsoap.org/soap/envelope/\"> " +
			"   <SOAP-ENV:Header/> " +
			"   <SOAP-ENV:Body> " +
			"      <SOAP-ENV:Fault> " +
			"         <faultcode>SOAP-ENV:Client</faultcode> " +
			"         <faultstring xml:lang=\"en\">Invalid request</faultstring> " +
			"      </SOAP-ENV:Fault>" +
			"   </SOAP-ENV:Body>" +
			"</SOAP-ENV:Envelope>");
	// @formatter:on

	SaajSoapMessage ssm = new SaajSoapMessage(message);
	try {
		resolver.resolveFault(ssm);
		fail();
	} catch (SoapFaultClientException exception) {
		assertEquals("Client", exception.getFaultCode().getLocalPart());
		assertEquals("Invalid request", exception.getFaultStringOrReason());
	}
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public void doWithMessage(WebServiceMessage message) throws IOException, TransformerException {
  try {
    SaajSoapMessage saajMessage = (SaajSoapMessage) message;
    SOAPMessage soapmess = saajMessage.getSaajMessage();
    SOAPEnvelope env = soapmess.getSOAPPart().getEnvelope();
    env.addNamespaceDeclaration("eto", "http://producers.etoimik.xtee.riik.ee/producer/etoimik");
  } catch (SOAPException e) {
    throw new RuntimeException(e);
  }
  callback.doWithMessage(message);
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
/**
 * Execute any number of operations on the supplied <code>message</code>.
 *
 * @param message the message
 * @throws IOException          in case of I/O errors
 * @throws TransformerException in case of transformation errors
 */
public void doWithMessage(WebServiceMessage message) {
  SaajSoapMessage ssm = (SaajSoapMessage) message;
  SOAPMessage sm = ssm.getSaajMessage();
  try {
    ProcessingContext context = this._processor.createProcessingContext(sm);
    SOAPMessage secureM = this._processor.secureOutboundMessage(context);
    ssm.setSaajMessage(secureM);
  } catch (Exception e) {
    e.printStackTrace();
  }
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
private String transform(WebServiceMessage message) {
	SaajSoapMessage saajSoapMessage = ((SaajSoapMessage) message);
	StringResult stringResult = new StringResult();
	try {
		transformer.transform(new DOMSource(saajSoapMessage.getDocument()), stringResult);
	} catch (TransformerException e) {
		throw new RuntimeException(e);
	}
	return stringResult.toString();
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
private WebServiceTemplate createAndConfigureWebServiceTemplate(final SaajSoapMessage responseMessage,
		QName webServiceIdentifier, HttpServletRequest httpServletRequest) {
	WebServiceTemplate webServiceTemplate = new WebServiceTemplate(webServiceMessageFactory) {
		@Override
		protected Object handleError(WebServiceConnection connection, WebServiceMessage request) throws IOException {
			HttpResponse httpResponse = ((HttpComponentsConnection) connection).getHttpResponse();
			String statusAndCode = httpResponse.getStatusLine().getReasonPhrase() + " - "
					+ httpResponse.getStatusLine().getStatusCode();
			Charset charset = httpResponse.getEntity().getContentEncoding() != null
					&& httpResponse.getEntity().getContentEncoding().getValue() != null ? Charset
					.forName(httpResponse.getEntity().getContentEncoding().getValue()) : Charset.defaultCharset();
			String response = httpResponse.getEntity() != null ? StreamUtils.copyToString(httpResponse.getEntity()
					.getContent(), charset) : "N/A";
			throw new WebServiceTransportException("[Status: " + statusAndCode + "] [Reponse " + response + "]");
		}
	};
	webServiceTemplate.setMessageSender(createAndInitWebServiceMessageSender(webServiceIdentifier));
	// In case the target endpoint returns a clean SoapFault, the normal response callback is abandoned and the
	// FaulMessageResolver is invoked. In this case we want to return the fault unaltered to the client, so we set
	// it here as the response.
	webServiceTemplate.setFaultMessageResolver(new FaultMessageResolver() {
		@Override
		public void resolveFault(WebServiceMessage message) throws IOException {
			responseMessage.setSaajMessage(((SaajSoapMessage) message).getSaajMessage());
		}
	});

	List<ClientInterceptor> interceptors = new ArrayList<>();
	interceptors.add(new HttpRequestHeaderTransfererInterceptor(HttpRequestHeaderTransfererInterceptor
			.extractHeaders(httpServletRequest)));

	if (config.getCustomClientInterceptors(webServiceIdentifier) != null) {
		interceptors.addAll(config.getCustomClientInterceptors(webServiceIdentifier));
	}

	LOG.debug("Using interceptors:" + Arrays.toString(ClassUtils.toClass(interceptors.toArray())));

	webServiceTemplate.setInterceptors(interceptors.toArray(new ClientInterceptor[0]));
	return webServiceTemplate;
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public XRoadMessage<GetSendStatusResponseTypeUnencoded> extractData(WebServiceMessage message) throws IOException, TransformerException {
    Attachment attachment = (Attachment) ((SaajSoapMessage) message).getAttachments().next();
    String xml = new String(unzipAndDecode(attachment.getInputStream()), DVK_MESSAGE_CHARSET);
    final GetSendStatusResponseTypeUnencoded content = getTypeFromXml(addCorrectNamespaces(xml), GetSendStatusResponseTypeUnencoded.class);
    return new XmlBeansXRoadMessage<GetSendStatusResponseTypeUnencoded>(content);
}
 

import org.springframework.ws.soap.saaj.SaajSoapMessage; //导入依赖的package包/类
public static SOAPMessage extractSoapMessage(WebServiceMessage webServiceMessage) {
  return ((SaajSoapMessage) webServiceMessage).getSaajMessage();
}