From 959e5318189e66ad58d07c5bb94789c815b4d2e9 Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期六, 16 八月 2025 11:42:37 +0800
Subject: [PATCH] art: WebService服务端相关代码修改
---
src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java | 56 +++++++++++++++++++++++++++++++++++++++++---------------
1 files changed, 41 insertions(+), 15 deletions(-)
diff --git a/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java b/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java
index 5aa73af..08d60e0 100644
--- a/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java
+++ b/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java
@@ -3,12 +3,18 @@
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
+import org.apache.cxf.endpoint.Client;
+import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
+import org.apache.cxf.transport.http.HTTPConduit;
+import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.jeecg.common.api.vo.Result;
-import org.jeecg.modules.wms.dto.ReceiveMESScanItemListResponse;
-import org.jeecg.modules.wms.request.ReceiveMESScanItemList;
-import org.jeecg.modules.wms.service.ReceiveWMSScanItemListService;
-import org.jeecg.modules.wms.service.WMSWebService;
+import org.jeecg.modules.wms.WMSWebService;
+import org.jeecg.modules.wms.dto.WSResponse;
+import org.jeecg.modules.wms.request.ReceiveWMSScanItemList;
+import org.jeecg.modules.wms.service.MESWebServiceSoap;
+import org.jeecg.modules.wms.service.WebServiceSoap;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -21,27 +27,47 @@
public class WMSTestController {
@Value("${webservice.url}")
private String url;
+ @Autowired
+ private WMSWebService webService;
+
+ private final static String localUrl = "http://localhost:9989/jeecg-boot/webservice/ReceiveWMSScanItemList?wsdl";
+
@ApiOperation(value = "WMS闆嗘垚娴嬭瘯-鎺ユ敹WMS绉诲簱缁撴灉", notes = "WMS闆嗘垚娴嬭瘯-鎺ユ敹WMS绉诲簱缁撴灉")
@PostMapping("/testReceiveWMSScanItemList")
public Result<?> testReceiveWMSScanItemList() {
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
- factory.setAddress(url);
- factory.setServiceClass(ReceiveWMSScanItemListService.class);
- ReceiveWMSScanItemListService service = (ReceiveWMSScanItemListService) factory.create();
- ReceiveMESScanItemList request = new ReceiveMESScanItemList();
- ReceiveMESScanItemListResponse response = service.receiveWMSScanItemList(request);
+ factory.setAddress(localUrl);
+ factory.setServiceClass(MESWebServiceSoap.class);
+ MESWebServiceSoap service = (MESWebServiceSoap) factory.create();
+ ReceiveWMSScanItemList request = new ReceiveWMSScanItemList();
+ WSResponse response = service.receiveWMSScanItemList(request);
return Result.ok(response);
}
@ApiOperation(value = "WMS闆嗘垚娴嬭瘯-HelloWord娴嬭瘯", notes = "WMS闆嗘垚娴嬭瘯-HelloWord娴嬭瘯")
@PostMapping("/testHelloWorld")
public Result<?> testHelloWorld() {
- JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
- factory.setAddress(url);
- factory.setServiceClass(WMSWebService.class);
- WMSWebService service = (WMSWebService) factory.create();
- String response = service.helloWorld();
- return Result.ok(response);
+// JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
+// factory.setAddress(url);
+// factory.setServiceClass(WebServiceSoap.class);
+// WebServiceSoap service = (WebServiceSoap) factory.create();
+// String response = service.helloWorld();
+// return Result.ok(response);
+ WebServiceSoap port = webService.getWebServiceSoap12();
+ // 2. 鑾峰彇 CXF 搴曞眰 Client 瀵硅薄
+ Client client = ClientProxy.getClient(port);
+
+ // 3. 鑾峰彇 HTTPConduit 骞惰缃秴鏃�
+ HTTPConduit http = (HTTPConduit) client.getConduit();
+ HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
+
+ httpClientPolicy.setConnectionTimeout(10 * 1000); // 杩炴帴瓒呮椂 10 绉�
+ httpClientPolicy.setReceiveTimeout(300 * 1000); // 璇诲彇瓒呮椂 60 绉掞紙閲嶇偣锛侊級
+
+ http.setClient(httpClientPolicy);
+ String result = port.helloWorld();
+ return Result.ok(result);
+
}
}
--
Gitblit v1.9.3