1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
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;
}
}
|
