2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Modifications Copyright (C) 2018 IBM.
8 * ================================================================================
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
20 * ============LICENSE_END=========================================================
23 package org.onap.so.adapters.requestsdb;
25 import java.sql.Timestamp;
26 import javax.jws.WebService;
27 import javax.transaction.Transactional;
28 import org.onap.so.adapters.requestsdb.exceptions.MsoRequestsDbException;
29 import org.onap.so.db.request.beans.InfraActiveRequests;
30 import org.onap.so.db.request.beans.OperationStatus;
31 import org.onap.so.db.request.beans.ResourceOperationStatus;
32 import org.onap.so.db.request.beans.ResourceOperationStatusId;
33 import org.onap.so.db.request.beans.SiteStatus;
34 import org.onap.so.db.request.data.repository.InfraActiveRequestsRepository;
35 import org.onap.so.db.request.data.repository.OperationStatusRepository;
36 import org.onap.so.db.request.data.repository.ResourceOperationStatusRepository;
37 import org.onap.so.db.request.data.repository.SiteStatusRepository;
38 import org.onap.so.logger.MsoLogger;
39 import org.onap.so.requestsdb.RequestsDbConstant;
40 import org.onap.so.utils.UUIDChecker;
41 import org.springframework.beans.factory.annotation.Autowired;
42 import org.springframework.context.annotation.Primary;
43 import org.springframework.stereotype.Component;
45 @WebService(serviceName = "RequestsDbAdapter", endpointInterface = "org.onap.so.adapters.requestsdb.MsoRequestsDbAdapter", targetNamespace = "http://org.onap.so/requestsdb")
48 public class MsoRequestsDbAdapterImpl implements MsoRequestsDbAdapter {
50 private static MsoLogger logger = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA, MsoRequestsDbAdapterImpl.class);
53 private InfraActiveRequestsRepository infraActive;
56 private SiteStatusRepository siteRepo;
59 private OperationStatusRepository operationStatusRepository;
62 private ResourceOperationStatusRepository resourceOperationStatusRepository;
66 public void updateInfraRequest(String requestId, String lastModifiedBy, String statusMessage, String responseBody,
67 RequestStatusType requestStatus, String progress, String vnfOutputs, String serviceInstanceId,
68 String networkId, String vnfId, String vfModuleId, String volumeGroupId, String serviceInstanceName,
69 String configurationId, String configurationName, String vfModuleName) throws MsoRequestsDbException {
71 InfraActiveRequests request = infraActive.findOneByRequestIdOrClientRequestId(requestId, requestId);
72 if (request == null) {
73 String error = "Entity not found. Unable to retrieve MSO Infra Requests DB for Request ID " + requestId;
74 throw new MsoRequestsDbException(error);
76 if (statusMessage != null) {
77 request.setStatusMessage(statusMessage);
79 if (responseBody != null) {
80 request.setResponseBody(responseBody);
82 if (requestStatus != null) {
83 request.setRequestStatus(requestStatus.toString());
85 if (progress != null) {
86 setProgress(progress, request);
88 if (vnfOutputs != null) {
89 request.setVnfOutputs(vnfOutputs);
91 if (serviceInstanceId != null) {
92 request.setServiceInstanceId(serviceInstanceId);
94 if (networkId != null) {
95 request.setNetworkId(networkId);
98 request.setVnfId(vnfId);
100 if (vfModuleId != null) {
101 request.setVfModuleId(vfModuleId);
103 if (volumeGroupId != null) {
104 request.setVolumeGroupId(volumeGroupId);
106 if (serviceInstanceName != null) {
107 request.setServiceInstanceName(serviceInstanceName);
109 if (vfModuleName != null) {
110 request.setVfModuleName(vfModuleName);
112 if (configurationId != null) {
113 request.setConfigurationId(configurationId);
115 if (configurationName != null) {
116 request.setConfigurationName(configurationName);
118 if (requestStatus == RequestStatusType.COMPLETE || requestStatus == RequestStatusType.FAILED) {
119 Timestamp nowTimeStamp = new Timestamp(System.currentTimeMillis());
120 request.setEndTime(nowTimeStamp);
122 request.setLastModifiedBy(lastModifiedBy);
123 infraActive.save(request);
124 } catch (Exception e) {
125 String error = "Error retrieving MSO Infra Requests DB for Request ID " + requestId;
126 logger.error(error, e);
127 throw new MsoRequestsDbException(error, MsoLogger.ErrorCode.BusinessProcesssError, e);
131 private void setProgress(String progress, InfraActiveRequests request) {
133 request.setProgress(Long.parseLong(progress));
134 } catch (NumberFormatException e) {
135 logger.warnSimple("UpdateInfraRequest", "Invalid value sent for progress");
141 public InfraActiveRequests getInfraRequest(String requestId) throws MsoRequestsDbException {
142 logger.debug("Call to MSO Infra RequestsDb adapter get method with request Id: " + requestId);
143 InfraActiveRequests request = null;
145 request = infraActive.findOneByRequestIdOrClientRequestId(requestId, requestId);
146 if (request == null) {
147 String error = "Entity not found. Unable to retrieve MSO Infra Requests DB for Request ID " + requestId;
148 throw new MsoRequestsDbException(error);
150 } catch (Exception e) {
151 String error = "Error retrieving MSO Infra Requests DB for Request ID " + requestId;
152 logger.error(error,e);
153 throw new MsoRequestsDbException(error,MsoLogger.ErrorCode.BusinessProcesssError , e);
159 * Get SiteStatus by SiteName.
162 * The unique name of the site
163 * @return Status of that site
167 public boolean getSiteStatus(String siteName) {
168 UUIDChecker.generateUUID(logger);
169 SiteStatus siteStatus;
170 logger.debug("Request database - get Site Status with Site name:" + siteName);
171 siteStatus = siteRepo.findOneBySiteName(siteName);
172 if (siteStatus == null) {
173 // if not exist in DB, it means the site is not disabled, thus
177 return siteStatus.getStatus();
182 * update operation status <br>
186 * @param operationType
189 * @param operationContent
192 * @throws MsoRequestsDbException
193 * @since ONAP Amsterdam Release
197 public void updateServiceOperationStatus(String serviceId, String operationId, String operationType, String userId,
198 String result, String operationContent, String progress, String reason) throws MsoRequestsDbException {
199 OperationStatus operStatus = operationStatusRepository.findOneByServiceIdAndOperationId(serviceId, operationId);
200 if (operStatus == null) {
201 String error = "Entity not found. Unable to retrieve OperationStatus Object ServiceId: " + serviceId + " operationId: "
204 throw new MsoRequestsDbException(error,MsoLogger.ErrorCode.BusinessProcesssError);
207 operStatus.setUserId(userId);
208 operStatus.setOperation(operationType);
209 operStatus.setReason(reason);
210 operStatus.setProgress(progress);
211 operStatus.setResult(result);
212 operStatus.setOperationContent(operationContent);
213 operStatus.setResult(result);
214 operationStatusRepository.save(operStatus);
218 * init the operation status of all the resources <br>
224 * @param operationType
226 * @param resourceTemplateUUIDs
227 * the resources, the UUID is split by ":"
228 * @throws MsoRequestsDbException
229 * @since ONAP Amsterdam Release
233 public void initResourceOperationStatus(String serviceId, String operationId, String operationType,
234 String resourceTemplateUUIDs) throws MsoRequestsDbException {
235 String[] resourceLst = resourceTemplateUUIDs.split(":");
236 for (String resource : resourceLst) {
237 if ("".equals(resource)) {
240 ResourceOperationStatus resourceStatus = new ResourceOperationStatus();
241 resourceStatus.setOperationId(operationId);
242 resourceStatus.setServiceId(serviceId);
243 resourceStatus.setResourceTemplateUUID(resource);
244 resourceStatus.setOperType(operationType);
245 resourceStatus.setStatus(RequestsDbConstant.Status.PROCESSING);
246 resourceStatus.setStatusDescription("Waiting for start");
247 resourceOperationStatusRepository.save(resourceStatus);
253 * get resource operation status <br>
257 * @param resourceTemplateUUID
259 * @throws MsoRequestsDbException
260 * @since ONAP Amsterdam Release
263 public ResourceOperationStatus getResourceOperationStatus(String serviceId, String operationId,
264 String resourceTemplateUUID) throws MsoRequestsDbException {
266 return resourceOperationStatusRepository
267 .findOne(new ResourceOperationStatusId(serviceId, operationId, resourceTemplateUUID));
271 * update resource operation status <br>
275 * @param resourceTemplateUUID
276 * @param operationType
277 * @param resourceInstanceID
282 * @param statusDescription
283 * @throws MsoRequestsDbException
284 * @since ONAP Amsterdam Release
287 public void updateResourceOperationStatus(String serviceId, String operationId, String resourceTemplateUUID,
288 String operationType, String resourceInstanceID, String jobId, String status, String progress,
289 String errorCode, String statusDescription) throws MsoRequestsDbException {
290 ResourceOperationStatus resStatus = new ResourceOperationStatus();
291 resStatus.setServiceId(serviceId);
292 resStatus.setOperationId(operationId);
293 resStatus.setResourceTemplateUUID(resourceTemplateUUID);
294 resStatus.setOperType(operationType);
295 resStatus.setResourceInstanceID(resourceInstanceID);
296 resStatus.setJobId(jobId);
297 resStatus.setStatus(status);
298 resStatus.setProgress(progress);
299 resStatus.setErrorCode(errorCode);
300 resStatus.setStatusDescription(statusDescription);
301 resourceOperationStatusRepository.save(resStatus);