1
public String sendWebServiceApi(String method, String xml, String message) {
2
        StopWatch stopWatch = new StopWatch();
3
        try {
4
            stopWatch.start();
5
            //  获取接口密钥
6
            String ztbKey = ConstantContextHolder.getSysConfig("ZTB_KEY", String.class, true);
7
            //  获取接口地址
8
            String ztbWebServiceUrl = ConstantContextHolder.getSysConfigWithDefault("ZTB_WEB_SERVICE_URL", String.class, "<http://127.0.0.1/WebService.asmx?wsdl>");
9
            //  获取是否开启请求超时
10
            String ztbWebHttpTimeOut = ConstantContextHolder.getSysConfigWithDefault("ZTB_WEB_REQUEST_TIME_OUT", String.class, "N");
11
            //  获取请求超时时间
12
            Integer ztbWebRequestTimeOutTime = ConstantContextHolder.getSysConfigWithDefault("ZTB_WEB_REQUEST_TIME_OUT_TIME", Integer.class, 3);
13
            //  获取请求超时时间
14
            Integer ztbWebConnectionTimeOutTime = ConstantContextHolder.getSysConfigWithDefault("ZTB_WEB_CONNECTION_TIME_OUT_TIME", Integer.class, 3);
15

16
            // 创建根元素
17
            Element root = new Element("Request_Packet");
18

19
            // 创建并添加Header元素
20
            Element header = new Element("Header");
21
            header.addContent(new Element("Key").setText(ztbKey));
22
            header.addContent(new Element("from").setText("请求者"));
23
            header.addContent(new Element("instruct").setText(method));
24

25
            // 添加Header到根元素
26
            root.addContent(header);
27

28
            // 创建Content元素并添加CDATA内容
29
            Element content = new Element("Content");
30
            content.addContent(new CDATA(xml));
31

32
            // 添加Content到根元素
33
            root.addContent(content);
34

35
            // 将根元素转换为XML文档
36
            Document document = new Document(root);
37

38
            // 使用XMLOutputter输出XML字符串
39
            XMLOutputter xmlOutput = new XMLOutputter();
40
            // 格式化输出
41
            xmlOutput.setFormat(Format.getPrettyFormat());
42
            String xmlString = xmlOutput.outputString(document);
43

44
            JaxWsDynamicClientFactory dynamicClient = JaxWsDynamicClientFactory.newInstance();
45
            Object[] objectArray;
46
            try (Client client = dynamicClient.createClient(ztbWebServiceUrl)) {
47
                // 设置超时单位为毫秒
48
                HTTPConduit conduit = (HTTPConduit) client.getConduit();
49
                HTTPClientPolicy policy = new HTTPClientPolicy();
50
                policy.setConnectionTimeout((1000 * 60) * ztbWebConnectionTimeOutTime);
51
                policy.setAllowChunking(false);
52
                policy.setReceiveTimeout((1000 * 60) * ztbWebRequestTimeOutTime);
53
                conduit.setClient(policy);
54
                // 强制设置URL，确保端口号没有丢失
55
                // conduit.getTarget().getAddress().setValue("<http://127.0.0.1/WebService.asmx>");
56
                objectArray = client.invoke("ProcessData", xmlString);
57
            }
58
            stopWatch.stop();
59
            log.error("sendWebServiceApi - 执行请求耗时: {} 秒", stopWatch.getTotalTimeSeconds());
60
            log.info("请求返回结果: {}", objectArray[0].toString());
61
            return formatXml(objectArray[0].toString());
62
        } catch (Exception e) {
63
            stopWatch.stop();
64
            log.error("WebService接口异常 - 执行请求耗时: {} 秒", stopWatch.getTotalTimeSeconds());
65
            log.error("WebService接口异常, {}, {},", message, e.getMessage(), e);
66
            return null;
67
        }
68
    }