tjx
2025-10-29 2959ba9af1df12206e0f763d42a0dba7afb2c5d7
src/main/java/com/gs/xiaomi/service/SoapApiService.java
@@ -3,6 +3,7 @@
import com.gs.xiaomi.config.DataAcquisitionConfiguration;
import com.gs.xiaomi.dto.BizDocumentResult;
import com.gs.xiaomi.dto.SoapApiResponse;
import com.gs.xiaomi.dto.ZfmWsApiRequest;
import com.gs.xiaomi.util.SoapXmlBuilder;
import com.gs.xiaomi.util.X5StringUtils;
@@ -26,7 +27,7 @@
                .build();
    }
    public BizDocumentResult callAndParse(String url, ZfmWsApiRequest request) throws Exception {
    public SoapApiResponse<BizDocumentResult> callAndParse(String url, ZfmWsApiRequest request) throws Exception {
        String soapXml = SoapXmlBuilder.build(request);
        Response response = sendRequest(url, soapXml);
@@ -34,18 +35,24 @@
            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);
            if (!"Y".equalsIgnoreCase(evCode)) {
                // 从 decodedXml 中提取错误提示信息
            String evMessage = extractEvMessage(decodedXml);
            return SoapApiResponse.fail(evCode, evMessage != null ? evMessage : "SOAP业务处理失败, EV_CODE: " + evCode);
            }
            String innerXml = extractCdata(decodedXml);
            if (innerXml == null) throw new RuntimeException("No CDATA <document> found in response");
            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));
            BizDocumentResult result = (BizDocumentResult) unmarshaller.unmarshal(new StringReader(innerXml));
            return SoapApiResponse.success(evCode, result);
        } else {
            throw new RuntimeException("SOAP request failed: " + response.code() + " - " + response.message());
        }
@@ -77,6 +84,28 @@
        return xml.substring(start + 9, end).trim();
    }
    private String extractEvMessage(String xml) {
        String value = extractTagValue(xml, "ev_message");
        if (value != null) {
            return value;
        }
        return extractTagValue(xml, "EV_MESSAGE");
    }
    private String extractTagValue(String xml, String tagName) {
        if (xml == null || tagName == null) {
            return null;
        }
        String openTag = "<" + tagName + ">";
        String closeTag = "</" + tagName + ">";
        int start = xml.indexOf(openTag);
        int end = xml.indexOf(closeTag, start);
        if (start == -1 || end == -1) {
            return null;
        }
        return xml.substring(start + openTag.length(), end).trim();
    }
    private String decodeXmlEntities(String xml) {
        return xml.replace("&#60;", "<")
                .replace("&#62;", ">")