测试接口

啊鑫

2025-04-10 11806f176873ad969294d973209aeeffe6f69194

 src/main/java/com/gs/xiaomi/service/SoapApiService.java

@@ -1,9 +1,11 @@
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;

@@ -23,10 +25,15 @@
        if (response.isSuccessful() && response.body() != null) {
            String bodyStr = response.body().string();

            String innerXml = extractCdata(bodyStr);
            if (innerXml == null) throw new RuntimeException("No CDATA <document> found in response");
            String evCode = extractEvCode(bodyStr);
            if (!"Y".equalsIgnoreCase(evCode)) {
                throw new RuntimeException("SOAP business failed, EV_CODE: " + evCode);
            }

            String decodedXml = decodeXmlEntities(innerXml);
            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();
@@ -40,12 +47,15 @@
        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 UkZDWkpYSUFPQlU6cHBCOVIhSGU=")
                .addHeader("Authorization", "Basic " + auth)
                .addHeader("Accept", "*/*")
                .addHeader("Host", "mipoq.p.mi.com")
                .addHeader("Connection", "keep-alive")
@@ -55,11 +65,11 @@
        return client.newCall(request).execute();
    }

    private String extractCdata(String xml) {
        int cdataStart = xml.indexOf("<![CDATA[");
        int cdataEnd = xml.indexOf("]]>", cdataStart);
        if (cdataStart == -1 || cdataEnd == -1) return null;
        return xml.substring(cdataStart + 9, cdataEnd).trim();
    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) {
@@ -69,4 +79,11 @@
                .replace("&gt;", ">")
                .replace("&amp;", "&");
    }

    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();
    }
}