From fe891f627a483eb6298f12eca60cf7f274e31c88 Mon Sep 17 00:00:00 2001 From: cuilei <ray_tsu1@163.com> Date: 星期三, 20 八月 2025 16:54:43 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java | 89 +++++++++++++++++++++++++++++++++----------- 1 files changed, 67 insertions(+), 22 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..9732f55 100644 --- a/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java +++ b/src/main/java/org/jeecg/modules/wms/controller/WMSTestController.java @@ -5,43 +5,88 @@ import lombok.extern.slf4j.Slf4j; import org.apache.cxf.jaxws.JaxWsProxyFactoryBean; 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.springframework.beans.factory.annotation.Value; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.jeecg.modules.wms.dto.WSResponse; +import org.jeecg.modules.wms.request.*; +import org.jeecg.modules.wms.service.MESWebServiceSoap; +import org.jeecg.modules.wms.service.WMSWebServiceClient; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; +import java.util.Map; @Api(tags = "WMS闆嗘垚娴嬭瘯") @RestController @RequestMapping("/wms/client") @Slf4j public class WMSTestController { - @Value("${webservice.url}") - private String url; + @Autowired + private WMSWebServiceClient webServiceClient; + + private final static String localUrl = "http://localhost:9989/ebservice/ReceiveWMSScanItemList?wsdl"; + @ApiOperation(value = "WMS闆嗘垚娴嬭瘯-鎺ユ敹WMS绉诲簱缁撴灉", notes = "WMS闆嗘垚娴嬭瘯-鎺ユ敹WMS绉诲簱缁撴灉") @PostMapping("/testReceiveWMSScanItemList") - public Result<?> testReceiveWMSScanItemList() { + public Result<?> testReceiveWMSScanItemList(@RequestBody List<WMSWebServiceSendItem> list) { 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(); + request.setWmsWebServiceSendItemList(list); + 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.getWebServiceSoap(); + // 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); + Map<String, Object> stringObjectMap = webServiceClient.helloWorld(); + return Result.ok(stringObjectMap); + } + + @ApiOperation(value = "WMS闆嗘垚娴嬭瘯-鐗╂枡鎷夊姩", notes = "WMS闆嗘垚娴嬭瘯-鐗╂枡鎷夊姩") + @PostMapping("/receiveReservation") + public Result<?> receiveReservation(@RequestBody WebReservationOrder request) { + Map<String, Object> stringObjectMap = webServiceClient.receiveReservation(request); + return Result.ok(stringObjectMap); + + } + + @ApiOperation(value = "WMS闆嗘垚娴嬭瘯-绉诲簱鐢宠", notes = "WMS闆嗘垚娴嬭瘯-绉诲簱鐢宠") + @PostMapping("/receiveMESScanItemList") + public Result<?> receiveMESScanItemList(@RequestBody List<WebServiceSendItem> webServiceSendItem) { + ArrayOfWebServiceSendItem request = new ArrayOfWebServiceSendItem(); + request.setWebServiceSendItem(webServiceSendItem); + Map<String, Object> stringObjectMap = webServiceClient.receiveMESScanItemList(request); + return Result.ok(stringObjectMap); + } + + @ApiOperation(value = "WMS闆嗘垚娴嬭瘯-绉诲簱鐢宠鎾ら攢", notes = "WMS闆嗘垚娴嬭瘯-绉诲簱鐢宠鎾ら攢") + @PostMapping("/deliOrderDelete") + public Result<?> deliOrderDelete(@RequestParam String sFactoryCode, @RequestParam String sStockRecord) { + Map<String, Object> stringObjectMap = webServiceClient.deliOrderDelete(sFactoryCode, sStockRecord); + return Result.ok(stringObjectMap); + } + } -- Gitblit v1.9.3