From 49265f3098deb87070d1f93588f96b715f72fdcb Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期六, 16 八月 2025 09:34:55 +0800
Subject: [PATCH] art: 增加 MESObjectFactory 类

---
 src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java |   56 ++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 46 insertions(+), 10 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 71e1995..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,11 +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.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;
@@ -20,18 +27,47 @@
 public class WMSTestController {
     @Value("${webservice.url}")
     private String url;
-    @Value("${webservice.namespace}")
-    private String namespace;
+    @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(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