111

tjx

2025-10-24 dfca73284ec549bf83a2c7d59b37cdcdb44800e0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
package com.gs.xiaomi.service;
 
 
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;
import okhttp3.*;
import org.springframework.stereotype.Service;
 
import javax.xml.bind.JAXBContext;
import javax.xml.bind.Unmarshaller;
import java.io.StringReader;
import java.util.concurrent.TimeUnit;
 
@Service
public class SoapApiService {
 
 
    private final OkHttpClient client;
 
    public SoapApiService() {
        this.client = new OkHttpClient.Builder().connectTimeout(3000, TimeUnit.SECONDS) // Set connection timeout
                .readTimeout(90, TimeUnit.SECONDS)    // Set read timeout
                .build();
    }
 
    public SoapApiResponse<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);
            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");
            }
 
            JAXBContext context = JAXBContext.newInstance(BizDocumentResult.class);
            Unmarshaller unmarshaller = context.createUnmarshaller();
            BizDocumentResult result = (BizDocumentResult) unmarshaller.unmarshal(new StringReader(innerXml));
 
            return SoapApiResponse.success(evCode, result);
        } 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("Content-Type", "application/xml")
                .addHeader("Authorization", "Basic " + auth)
                .addHeader("Accept", "*/*")
                .addHeader("Connection", "keep-alive")
                .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 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;", ">")
                .replace("&lt;", "<")
                .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();
    }
}