package com.gs.xiaomi.service;
|
|
|
import com.gs.xiaomi.config.DataAcquisitionConfiguration;
|
import com.gs.xiaomi.dto.BizDocumentResult;
|
import com.gs.xiaomi.dto.ZfmWsApiRequest;
|
import com.gs.xiaomi.util.SoapXmlBuilder;
|
import com.gs.xiaomi.util.X5StringUtils;
|
import okhttp3.*;
|
import org.springframework.stereotype.Service;
|
|
import javax.xml.bind.JAXBContext;
|
import javax.xml.bind.Unmarshaller;
|
import java.io.StringReader;
|
|
@Service
|
public class SoapApiService {
|
|
private static final OkHttpClient client = new OkHttpClient.Builder().build();
|
|
public BizDocumentResult callAndParse(String url, ZfmWsApiRequest request) throws Exception {
|
String soapXml = SoapXmlBuilder.build(request);
|
Response response = sendRequest(url, soapXml);
|
|
if (response.isSuccessful() && response.body() != null) {
|
String bodyStr = response.body().string();
|
|
String evCode = extractEvCode(bodyStr);
|
if (!"Y".equalsIgnoreCase(evCode)) {
|
throw new RuntimeException("SOAP business failed, EV_CODE: " + evCode);
|
}
|
|
String decodedXml = decodeXmlEntities(bodyStr);
|
|
String innerXml = extractCdata(decodedXml);
|
if (innerXml == null) throw new RuntimeException("No CDATA <document> found in response");
|
|
JAXBContext context = JAXBContext.newInstance(BizDocumentResult.class);
|
Unmarshaller unmarshaller = context.createUnmarshaller();
|
return (BizDocumentResult) unmarshaller.unmarshal(new StringReader(innerXml));
|
} else {
|
throw new RuntimeException("SOAP request failed: " + response.code() + " - " + response.message());
|
}
|
}
|
|
private Response sendRequest(String url, String soapXml) throws Exception {
|
MediaType mediaType = MediaType.parse("application/xml");
|
RequestBody body = RequestBody.create(mediaType, soapXml);
|
|
String s = DataAcquisitionConfiguration.USER_NAME + ":" + DataAcquisitionConfiguration.PWD;
|
String auth = X5StringUtils.encodeBase64(s);
|
|
Request request = new Request.Builder()
|
.url(url)
|
.method("POST", body)
|
// .addHeader("User-Agent", "Apifox/1.0.0 (https://apifox.com)")
|
.addHeader("Content-Type", "application/xml")
|
.addHeader("Authorization", "Basic " + auth)
|
.addHeader("Accept", "*/*")
|
// .addHeader("Host", "mipoq.p.mi.com")
|
.addHeader("Connection", "keep-alive")
|
// .addHeader("Cookie", "saplb_*=(J2EE4281420)4281450; MYSAPSSO2=AjExMDAgABJwb3J0YWw6UkZDWkpYSUFPQlWIAAdkZWZhdWx0AQALUkZDWkpYSUFPQlUCAAMwMDADAANQT1EEAAwyMDI1MDQwOTAwMTcFAAQAAAAICgALUkZDWkpYSUFPQlX%2FAQUwggEBBgkqhkiG9w0BBwKggfMwgfACAQExCzAJBgUrDgMCGgUAMAsGCSqGSIb3DQEHATGB0DCBzQIBATAiMB0xDDAKBgNVBAMTA1BPUTENMAsGA1UECxMESjJFRQIBADAJBgUrDgMCGgUAoF0wGAYJKoZIhvcNAQkDMQsGCSqGSIb3DQEHATAcBgkqhkiG9w0BCQUxDxcNMjUwNDA5MDAxNzU2WjAjBgkqhkiG9w0BCQQxFgQUvvJ1HSnOLckboGYaMR9Wiaem6z4wCQYHKoZIzjgEAwQvMC0CFQDKLPrpUC19VM2gcslWaHAnh7dfxQIUNs2dTxwGcKdNU%2FdAQPs4f08yaw4%3D; JSESSIONID=_6bPldDq9mFJPXEd11bc-GvrWMAVlgFqVEEA_SAPF-GrpRbcuqxMK_gShBYGdmdp; JSESSIONMARKID=QPmRVwktCDxMazp0fUbEMC40LWvmuqOMUbIGpUQQA")
|
.build();
|
|
return client.newCall(request).execute();
|
}
|
|
private String extractEvCode(String xml) {
|
int start = xml.indexOf("<EV_CODE>");
|
int end = xml.indexOf("</EV_CODE>", start);
|
if (start == -1 || end == -1) return null;
|
return xml.substring(start + 9, end).trim();
|
}
|
|
private String decodeXmlEntities(String xml) {
|
return xml.replace("<", "<")
|
.replace(">", ">")
|
.replace("<", "<")
|
.replace(">", ">")
|
.replace("&", "&");
|
}
|
|
private String extractCdata(String xml) {
|
int cdataStart = xml.indexOf("<EV_RESULT>");
|
int cdataEnd = xml.indexOf("</EV_RESULT>", cdataStart);
|
if (cdataStart == -1 || cdataEnd == -1) return null;
|
return xml.substring(cdataStart + 11, cdataEnd).trim();
|
}
|
}
|