项目初始化

datax-modules/data-market-service-parent/data-market-service-integration/src/main/java/cn/datax/service/data/market/integration/service/impl/ServiceExecuteServiceImpl.java

@@ -84,22 +84,22 @@ public class ServiceExecuteServiceImpl implements ServiceExecuteService {
             }
             // http服务
             HttpMethod httpMethod = HttpMethod.GET;
-            if (ReqMethod.POST.getDesc().equals(serviceIntegrationEntity.getServiceHttpMethod())) {
+            if (ReqMethod.POST.getDesc().equals(serviceIntegrationEntity.getHttpService().getHttpMethod())) {
                 httpMethod = HttpMethod.POST;
             }
             HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(params, headers);
             try {
-                response = restTemplate.exchange(serviceIntegrationEntity.getServiceUrl(), httpMethod, httpEntity, String.class);
+                response = restTemplate.exchange(serviceIntegrationEntity.getHttpService().getUrl(), httpMethod, httpEntity, String.class);
             } catch (Exception e) {
                 throw new DataException(e.getMessage());
             }
         } else if (ServiceType.WEBSERVICE.getKey().equals(serviceIntegrationEntity.getServiceType())) {
             // webservice服务
-            headers.add("SOAPAction", serviceIntegrationEntity.getServiceTargetNamespace() + serviceIntegrationEntity.getServiceMethod());
+            headers.add("SOAPAction", serviceIntegrationEntity.getWebService().getTargetNamespace() + serviceIntegrationEntity.getWebService().getMethod());
             headers.add("Content-Type", "text/xml;charset=UTF-8");
             HttpEntity<String> entity = new HttpEntity<>(execute.getSoap(), headers);
             try {
-                response = restTemplate.exchange(serviceIntegrationEntity.getServiceWsdl(), HttpMethod.POST, entity, String.class);
+                response = restTemplate.exchange(serviceIntegrationEntity.getWebService().getWsdl(), HttpMethod.POST, entity, String.class);
             } catch (Exception e) {
                 throw new DataException(e.getMessage());
             }