fix a bug and ...

Change-Id: Id5dfae04cffa98705a5d99f9cf7d7552de5b8418
Issue-ID: SO-88
Signed-off-by: Zhuoyao Huang <10112215@zte.com.cn>
Discription: fix a bug and commit underlay vpn achieved by yang decoder

5 files changed, 184 insertions, 9 deletions

diff --git a/bpmn/MSOInfrastructureBPMN/pom.xml b/bpmn/MSOInfrastructureBPMN/pom.xml
index d57b1cfd7c..be03cb44f5 100644
--- a/bpmn/MSOInfrastructureBPMN/pom.xml
+++ b/bpmn/MSOInfrastructureBPMN/pom.xml
@@ -414,11 +414,11 @@
 		</dependency>

 

 		<!--for yang tools-->

-<!--		<dependency>

+		<dependency>

 			<groupId>org.openecomp.so</groupId>

 			<artifactId>common</artifactId>

 			<version>1.1.0-SNAPSHOT</version>

-		</dependency>-->

+		</dependency>

 

 		<dependency>

 			<groupId>org.onap.sdnc.northbound</groupId>

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskEntityImpl.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskEntityImpl.java
index a387756d7c..3cb5cd9fb1 100644
--- a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskEntityImpl.java
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskEntityImpl.java
@@ -32,7 +32,7 @@ public class SdncVlOperationTaskEntityImpl extends AbstractSdncVlOperationTask {
         if (!responseCode.equals("200")) {
             String processKey = getProcessKey(execution);
             int errorCode = Integer.valueOf(responseCode);
-            String errorMessage = output.getOutput().getEsponseMessage();
+            String errorMessage = output.getOutput().getResponseMessage();
             WorkflowException workflowException = new WorkflowException(processKey, errorCode, errorMessage);
             execution.setVariable("SDNCA_SuccessIndicator", workflowException);
             updateProgress(execution, RequestsDbConstant.Status.ERROR, String.valueOf(errorCode), null, errorMessage);
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskYangToolsImpl.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskYangToolsImpl.java
new file mode 100644
index 0000000000..0665a257aa
--- /dev/null
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncVlOperationTaskYangToolsImpl.java
@@ -0,0 +1,49 @@
+package org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask;
+
+import okhttp3.RequestBody;
+import okhttp3.ResponseBody;
+import org.camunda.bpm.engine.delegate.DelegateExecution;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.NetworkTopologyOperationOutput;
+import org.opendaylight.yangtools.yang.binding.DataObject;
+import org.openecomp.mso.bpmn.core.WorkflowException;
+import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.GenericResourceApi;
+import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.builder.NetworkTopologyRequestBodyBuilder;
+import org.openecomp.mso.requestsdb.RequestsDbConstant;
+import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService;
+import org.openecomp.mso.yangDecoder.transform.impl.TransfromJava2StringFactory;
+
+import java.util.Map;
+
+/**
+ * Created by 10112215 on 2017/9/20.
+ */
+public class SdncVlOperationTaskYangToolsImpl extends AbstractSdncVlOperationTask {
+
+    public void sendRestrequestAndHandleResponse(DelegateExecution execution,
+                                                 Map<String, String> inputs,
+                                                 GenericResourceApi genericResourceApiClient) throws Exception {
+        updateProgress(execution, null, null, "40", "sendRestrequestAndHandleResponse begin!");
+        NetworkTopologyRequestBodyBuilder builder = new NetworkTopologyRequestBodyBuilder();
+        RequestBody body = builder.build(inputs);
+        updateProgress(execution, null, null, "50", "RequestBody build finished!");
+        ResponseBody responseBody = genericResourceApiClient.postNetworkTopologyPeration(body).execute().body();
+        updateProgress(execution, null, null, "90", "sendRestrequestAndHandleResponse finished!");
+        saveResponse(execution, responseBody);
+    }
+
+    private void saveResponse(DelegateExecution execution, ResponseBody responseBody) throws Exception {
+        ITransformJava2StringService java2jsonService = TransfromJava2StringFactory.getJava2jsonService();
+        NetworkTopologyOperationOutput output = (NetworkTopologyOperationOutput) java2jsonService.
+                transformRpcDataObjectFromString(NetworkTopologyRequestBodyBuilder.URI_PATH, responseBody.string());
+        String responseCode = output.getResponseCode();
+        if (!responseCode.equals("200")) {
+            String processKey = getProcessKey(execution);
+            int errorCode = Integer.valueOf(responseCode);
+            String errorMessage = output.getResponseMessage();
+            WorkflowException workflowException = new WorkflowException(processKey, errorCode, errorMessage);
+            execution.setVariable("SDNCA_SuccessIndicator", workflowException);
+            updateProgress(execution, RequestsDbConstant.Status.ERROR, String.valueOf(errorCode), null, errorMessage);
+            throw new Exception("");
+        }
+    }
+}
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/NetworkTopologyRequestBodyBuilder.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/NetworkTopologyRequestBodyBuilder.java
new file mode 100644
index 0000000000..8fc70ca0e3
--- /dev/null
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/NetworkTopologyRequestBodyBuilder.java
@@ -0,0 +1,126 @@
+package org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.builder;
+
+import okhttp3.RequestBody;
+import org.apache.commons.lang3.StringUtils;
+import org.json.JSONObject;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.NetworkTopologyOperationInput;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.NetworkTopologyOperationInputBuilder;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.network.request.input.NetworkRequestInputBuilder;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.network.request.input.network.request.input.NetworkInputParametersBuilder;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.param.Param;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.param.ParamBuilder;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.param.ParamKey;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.request.information.RequestInformation;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.request.information.RequestInformationBuilder;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.sdnc.request.header.SdncRequestHeader;
+import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.sdnc.request.header.SdncRequestHeaderBuilder;
+import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService;
+import org.openecomp.mso.yangDecoder.transform.impl.TransfromJava2StringFactory;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by 10112215 on 2017/9/20.
+ */
+public class NetworkTopologyRequestBodyBuilder implements AbstractBuilder<Map<String, String>, RequestBody> {
+
+    public static final String URI_PATH = "GENERIC-RESOURCE-API:network-topology-operation";
+    public static final SdncRequestHeader.SvcAction SVC_DEFAULT_ACTION = SdncRequestHeader.SvcAction.Create;
+    public static final String SVC_REQUEST_ID = "MSO";
+    public static final String SDC_ACTION = "SDC_ACTION";
+    public static final RequestInformation.RequestAction REQUEST_ACTION = RequestInformation.RequestAction.CreateNetworkInstance;
+    protected static ITransformJava2StringService java2jsonService;
+
+    static
+    {
+        try {
+            java2jsonService = TransfromJava2StringFactory.getJava2jsonService();
+        } catch (Exception e) {
+            e.printStackTrace();
+            java2jsonService = null;
+        }
+    }
+
+    @Override
+    public RequestBody build(Map<String, String> input) throws Exception {
+        NetworkTopologyOperationInput sdncInput = getSdncInput(input);
+        RequestBody body = getRequestBody(sdncInput);
+        return body;
+    }
+
+    protected String getJsonInput(NetworkTopologyOperationInput sdncInput) throws Exception {
+        return java2jsonService.transformRpcDataObjectToString(URI_PATH, sdncInput);
+    }
+
+    private RequestBody getRequestBody(NetworkTopologyOperationInput sdncInput) throws Exception {
+        String jsonString = getJsonInput(sdncInput);
+        String json = (new JSONObject(jsonString)).toString();
+        return RequestBody.create(okhttp3.MediaType.parse("application/json; charset=utf-8"),json);
+    }
+
+    protected NetworkTopologyOperationInput getSdncInput(Map<String, String> inputs) {
+        NetworkTopologyOperationInputBuilder networkTopologyOperationInputBuilder = new NetworkTopologyOperationInputBuilder();
+        {
+            loadSdncRequestHeader(inputs, networkTopologyOperationInputBuilder);
+            loadRequestInformation(networkTopologyOperationInputBuilder);
+            loadNetworkInputParameters(inputs, networkTopologyOperationInputBuilder);
+        }
+        return networkTopologyOperationInputBuilder.build();
+    }
+
+    private void loadNetworkInputParameters(Map<String, String> inputs, NetworkTopologyOperationInputBuilder networkTopologyOperationInputBuilder) {
+        NetworkRequestInputBuilder networkRequestInputBuilder = new NetworkRequestInputBuilder();
+        {
+            NetworkInputParametersBuilder networkInputParametersBuilder = new NetworkInputParametersBuilder();
+            {
+                List<Param> paramList = getParamList(inputs);
+                networkInputParametersBuilder.setParam(paramList);
+            }
+            networkRequestInputBuilder.setNetworkInputParameters(networkInputParametersBuilder.build());
+        }
+        networkTopologyOperationInputBuilder.setNetworkRequestInput(networkRequestInputBuilder.build());
+    }
+
+    private void loadRequestInformation(NetworkTopologyOperationInputBuilder networkTopologyOperationInputBuilder) {
+        RequestInformationBuilder requestInformationBuilder = new RequestInformationBuilder();
+        {
+            requestInformationBuilder.setRequestId(SVC_REQUEST_ID);
+            requestInformationBuilder.setRequestAction(REQUEST_ACTION);
+        }
+        networkTopologyOperationInputBuilder.setRequestInformation(requestInformationBuilder.build());
+    }
+
+    private void loadSdncRequestHeader(Map<String, String> inputs, NetworkTopologyOperationInputBuilder networkTopologyOperationInputBuilder) {
+        SdncRequestHeaderBuilder sdncRequestHeaderBuilder = new SdncRequestHeaderBuilder();
+        {
+            sdncRequestHeaderBuilder.setSvcRequestId(SVC_REQUEST_ID);
+            SdncRequestHeader.SvcAction svcAction = SVC_DEFAULT_ACTION;
+            String action = inputs.get(SDC_ACTION);
+            if (!StringUtils.isBlank(action)) {
+                if (action.toLowerCase().contains("delete")) {
+                    svcAction = SdncRequestHeader.SvcAction.Delete;
+                } else if (action.toLowerCase().contains("create")) {
+                    svcAction = SdncRequestHeader.SvcAction.Create;
+                }
+            }
+            sdncRequestHeaderBuilder.setSvcAction(svcAction);
+        }
+        networkTopologyOperationInputBuilder.setSdncRequestHeader(sdncRequestHeaderBuilder.build());
+    }
+
+    private List<Param> getParamList(Map<String, String> inputs) {
+        List<Param> paramList = new ArrayList<>();
+        if (inputs != null && !inputs.isEmpty()) {
+            inputs.keySet().forEach(key -> {
+                ParamBuilder paramBuilder = new ParamBuilder();
+                paramBuilder.setName(key);
+                paramBuilder.setValue(inputs.get(key));
+                paramBuilder.setKey(new ParamKey(key));
+                paramList.add(paramBuilder.build());
+            });
+        }
+        return paramList;
+    }
+}
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/entity/OutputEntity.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/entity/OutputEntity.java
index 48fb9f1594..a52919d0fd 100644
--- a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/entity/OutputEntity.java
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/entity/OutputEntity.java
@@ -12,8 +12,8 @@ public class OutputEntity {
     @JsonProperty("response-code")
     private String responseCode;
 
-    @JsonProperty("esponse-message")
-    private String esponseMessage;
+    @JsonProperty("response-message")
+    private String responseMessage;
 
     @JsonProperty("ack-final-indicator")
     private String ackFinalIndicator;
@@ -40,12 +40,12 @@ public class OutputEntity {
         this.responseCode = responseCode;
     }
 
-    public String getEsponseMessage() {
-        return esponseMessage;
+    public String getResponseMessage() {
+        return responseMessage;
     }
 
-    public void setEsponseMessage(String esponseMessage) {
-        this.esponseMessage = esponseMessage;
+    public void setResponseMessage(String responseMessage) {
+        this.responseMessage = responseMessage;
     }
 
     public String getAckFinalIndicator() {