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
|
/**
* Copyright (c) 2018 Orange
*
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
*/
package org.onap.nbi.apis.serviceorder.workflow;
import org.onap.nbi.apis.serviceorder.SoClient;
import org.onap.nbi.apis.serviceorder.model.ActionType;
import org.onap.nbi.apis.serviceorder.model.ServiceOrder;
import org.onap.nbi.apis.serviceorder.model.ServiceOrderItem;
import org.onap.nbi.apis.serviceorder.model.ServiceStateType;
import org.onap.nbi.apis.serviceorder.model.StateType;
import org.onap.nbi.apis.serviceorder.model.consumer.GetE2ERequestStatusResponse;
import org.onap.nbi.apis.serviceorder.model.consumer.GetRequestStatusResponse;
import org.onap.nbi.apis.serviceorder.model.consumer.RequestState;
import org.onap.nbi.apis.serviceorder.service.ServiceOrderService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class SOGetStatusManager {
private static final Logger LOGGER = LoggerFactory.getLogger(SOGetStatusManager.class);
@Autowired
private ServiceOrderService serviceOrderService;
@Autowired
private SoClient soClient;
public void pollRequestStatus(ServiceOrder serviceOrder, ServiceOrderItem serviceOrderItem, boolean e2eService) {
if (e2eService) {
pollE2ESoRequestStatus(serviceOrder, serviceOrderItem);
} else {
pollSoRequestStatus(serviceOrder, serviceOrderItem);
}
}
/**
* * @param orderItem
*/
private void pollSoRequestStatus(ServiceOrder serviceOrder, ServiceOrderItem orderItem) {
String requestId = orderItem.getRequestId();
GetRequestStatusResponse response = null;
response = soClient.callGetRequestStatus(requestId);
if (response != null) {
orderItem.setPercentProgress(String.valueOf(response.getRequest().getRequestStatus().getPercentProgress()));
if (response.getRequest().getRequestStatus().getPercentProgress() != 100) {
LOGGER.debug("orderitem id {} still in progress from so", orderItem.getId());
} else if (RequestState.COMPLETE != response.getRequest().getRequestStatus().getRequestState()) {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem, StateType.FAILED);
LOGGER.debug("orderitem id {} failed, response from request status {}", orderItem.getId(),
response.getRequest().getRequestStatus().getRequestState());
} else {
boolean e2eService = false;
updateOrderItemIfStatusCompleted(serviceOrder, orderItem, e2eService);
LOGGER.debug("orderitem id {} completed");
}
} else {
LOGGER.debug("orderitem id {} still in progress from so", orderItem.getId());
}
}
private void updateOrderItemIfStatusCompleted(ServiceOrder serviceOrder, ServiceOrderItem orderItem,boolean e2eService) {
boolean serviceActivationReq = orderItem.getService().getServiceState() == ServiceStateType.ACTIVE ||
orderItem.getService().getServiceState() == ServiceStateType.INACTIVE;
if (orderItem.getAction() != ActionType.MODIFY) {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem, StateType.COMPLETED);
}else if(orderItem.getAction() == ActionType.MODIFY && serviceActivationReq && e2eService) {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem, StateType.COMPLETED);
}else {
if (StateType.INPROGRESS_MODIFY_REQUEST_CREATE_SEND == orderItem.getState()) {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem, StateType.COMPLETED);
} else {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem,
StateType.INPROGRESS_MODIFY_ITEM_TO_CREATE);
}
}
}
private void pollE2ESoRequestStatus(ServiceOrder serviceOrder, ServiceOrderItem orderItem) {
String operationId = orderItem.getRequestId();
String serviceId = orderItem.getService().getId();
GetE2ERequestStatusResponse response = null;
final String ERROR = "error";
final String FINISHED = "finished";
final String PROCESSING = "processing";
String result = null;
response = soClient.callE2EGetRequestStatus(operationId, serviceId);
if (response != null) {
orderItem.setPercentProgress(response.getOperation().getProgress());
result = response.getOperation().getResult();
if (PROCESSING.equals(result)) {
LOGGER.debug("orderitem id {} still in progress from so", orderItem.getId());
} else if (ERROR.equals(result)) {
serviceOrderService.updateOrderItemState(serviceOrder, orderItem, StateType.FAILED);
LOGGER.debug("orderitem id {} failed, response from request status {}", orderItem.getId(),
response.getOperation().getResult());
} else if (FINISHED.equals(result)) {
boolean e2eService = true;
updateOrderItemIfStatusCompleted(serviceOrder, orderItem,e2eService);
LOGGER.debug("orderitem id {} completed");
}
} else {
LOGGER.debug("orderitem id {} still in progress from so", orderItem.getId());
}
}
}
|
