liusheng
2 天以前 23f78d642951675437de226332621b1195a505c6
代码提交
已添加3个文件
66 ■■■■■ 文件已修改
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/webservice/WebServiceClient.java 60 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
jh-module-ecg/jh-module-ecg-biz/src/main/resources/application.yml 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
jh-module-webservice/pom.xml 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/webservice/WebServiceClient.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,60 @@
package cn.lihu.jh.module.ecg.webservice;
import cn.lihu.jh.module.ecg.webservice.ws.JHFWreq;
import cn.lihu.jh.module.ecg.webservice.ws._0020SAMPLEBS_0020;
import cn.lihu.jh.module.ecg.webservice.ws._0020SAMPLEBS_0020Soap;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.xml.ws.BindingProvider;
import java.net.URL;
/**
 * WebService客户端
 */
@Slf4j
@Component
public class WebServiceClient {
    private static final String WSDL_URL = "http://10.0.4.36/ZHIP/Service/ZHIP.JHFWTYRK.BS.JHFWTYRK.cls?wsdl";
    private static final String ENDPOINT_URL = "http://10.0.4.36/ZHIP/Service/ZHIP.JHFWTYRK.BS.JHFWTYRK.cls";
    /**
     * è°ƒç”¨JHFWTYRK服务
     *
     * @param action æ“ä½œç±»åž‹
     * @param rdn è¯·æ±‚标识
     * @param message æ¶ˆæ¯å†…容
     * @return å“åº”结果
     */
    public String callJHFWTYRK(String action, String rdn, String message) {
        try {
            // åˆ›å»ºæœåŠ¡å®žä¾‹
            _0020SAMPLEBS_0020 service = new _0020SAMPLEBS_0020(new URL(WSDL_URL));
            _0020SAMPLEBS_0020Soap port = service.get_0020SAMPLEBS_0020Soap();
            // è®¾ç½®ç«¯ç‚¹åœ°å€
            BindingProvider bindingProvider = (BindingProvider) port;
            bindingProvider.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, ENDPOINT_URL);
            // è®¾ç½®è¶…时时间(可选)
            bindingProvider.getRequestContext().put("javax.xml.ws.client.connectionTimeout", "30000");
            bindingProvider.getRequestContext().put("javax.xml.ws.client.receiveTimeout", "30000");
            // æž„建请求参数
            JHFWreq req = new JHFWreq();
            req.setAction(action);
            req.setRdn(rdn);
            req.setMessage(message);
            // è°ƒç”¨æœåŠ¡
            String response = port.jhfwtyrk(req);
            log.info("JHFWTYRK调用成功,响应结果:{}", response);
            return response;
        } catch (Exception e) {
            log.error("JHFWTYRK调用失败", e);
            throw new RuntimeException("调用JHFWTYRK服务失败", e);
        }
    }
}
jh-module-ecg/jh-module-ecg-biz/src/main/resources/application.yml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,5 @@
cxf:
  path: /webservice
  servlet:
    init:
      service-list-path: /services
jh-module-webservice/pom.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1 @@