2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.mso.adapters.requestsdb;
23 import java.sql.Timestamp;
24 import java.util.List;
26 import javax.jws.WebService;
28 import org.openecomp.mso.requestsdb.SiteStatus;
29 import org.openecomp.mso.utils.UUIDChecker;
30 import org.hibernate.HibernateException;
31 import org.hibernate.Query;
32 import org.hibernate.Session;
34 import org.openecomp.mso.adapters.requestsdb.exceptions.MsoRequestsDbException;
35 import org.openecomp.mso.logger.MessageEnum;
36 import org.openecomp.mso.logger.MsoLogger;
37 import org.openecomp.mso.requestsdb.HibernateUtil;
38 import org.openecomp.mso.requestsdb.InfraActiveRequests;
40 @WebService(serviceName = "RequestsDbAdapter", endpointInterface = "org.openecomp.mso.adapters.requestsdb.MsoRequestsDbAdapter", targetNamespace = "http://com.att.mso/requestsdb")
41 public class MsoRequestsDbAdapterImpl implements MsoRequestsDbAdapter {
43 private static MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.RA);
46 public void updateInfraRequest (String requestId,
47 String lastModifiedBy,
50 RequestStatusType requestStatus,
53 String serviceInstanceId,
57 String volumeGroupId) throws MsoRequestsDbException {
58 MsoLogger.setLogContext (requestId, null);
59 Session session = HibernateUtil.getSessionFactory ().openSession ();
61 long startTime = System.currentTimeMillis ();
63 session.beginTransaction ();
64 String queryString = "update InfraActiveRequests set ";
65 if (statusMessage != null) {
66 queryString += "statusMessage = :statusMessage, ";
68 if (responseBody != null) {
69 queryString += "responseBody = :responseBody, ";
71 if (requestStatus != null) {
72 queryString += "requestStatus = :requestStatus, ";
74 if (progress != null) {
75 queryString += "progress = :progress, ";
77 if (vnfOutputs != null) {
78 queryString += "vnfOutputs = :vnfOutputs, ";
80 if (serviceInstanceId != null) {
81 queryString += "serviceInstanceId = :serviceInstanceId, ";
83 if (networkId != null) {
84 queryString += "networkId = :networkId, ";
87 queryString += "vnfId = :vnfId, ";
89 if (vfModuleId != null) {
90 queryString += "vfModuleId = :vfModuleId, ";
92 if (volumeGroupId != null) {
93 queryString += "volumeGroupId = :volumeGroupId, ";
95 if (requestStatus == RequestStatusType.COMPLETE || requestStatus == RequestStatusType.FAILED) {
96 queryString += "endTime = :endTime, ";
98 queryString += "modifyTime = :modifyTime, ";
100 queryString += "lastModifiedBy = :lastModifiedBy where requestId = :requestId OR clientRequestId = :requestId";
102 LOGGER.debug("Executing update: " + queryString);
104 Query query = session.createQuery (queryString);
105 query.setParameter ("requestId", requestId);
106 if (statusMessage != null) {
107 query.setParameter ("statusMessage", statusMessage);
108 LOGGER.debug ("StatusMessage in updateInfraRequest is set to: " + statusMessage);
110 if (responseBody != null) {
111 query.setParameter ("responseBody", responseBody);
112 LOGGER.debug ("ResponseBody in updateInfraRequest is set to: " + responseBody);
114 if (requestStatus != null) {
115 query.setParameter ("requestStatus", requestStatus.toString ());
116 LOGGER.debug ("RequestStatus in updateInfraRequest is set to: " + requestStatus.toString());
119 if (progress != null) {
120 query.setParameter ("progress", Long.parseLong (progress));
121 LOGGER.debug ("Progress in updateInfraRequest is set to: " + progress);
123 if (vnfOutputs != null) {
124 query.setParameter ("vnfOutputs", vnfOutputs);
125 LOGGER.debug ("VnfOutputs in updateInfraRequest is set to: " + vnfOutputs);
127 if (serviceInstanceId != null) {
128 query.setParameter ("serviceInstanceId", serviceInstanceId);
129 LOGGER.debug ("ServiceInstanceId in updateInfraRequest is set to: " + serviceInstanceId);
131 if (networkId != null) {
132 query.setParameter ("networkId", networkId);
133 LOGGER.debug ("NetworkId in updateInfraRequest is set to: " + networkId);
136 query.setParameter ("vnfId", vnfId);
137 LOGGER.debug ("VnfId in updateInfraRequest is set to: " + vnfId);
139 if (vfModuleId != null) {
140 query.setParameter ("vfModuleId", vfModuleId);
141 LOGGER.debug ("vfModuleId in updateInfraRequest is set to: " + vfModuleId);
143 if (volumeGroupId != null) {
144 query.setParameter ("volumeGroupId", volumeGroupId);
145 LOGGER.debug ("VolumeGroupId in updateInfraRequest is set to: " + volumeGroupId);
147 Timestamp nowTimeStamp = new Timestamp (System.currentTimeMillis ());
148 if (requestStatus == RequestStatusType.COMPLETE || requestStatus == RequestStatusType.FAILED) {
149 query.setParameter ("endTime", nowTimeStamp);
150 LOGGER.debug ("EndTime in updateInfraRequest is set to: " + nowTimeStamp);
152 query.setParameter ("modifyTime", nowTimeStamp);
153 LOGGER.debug ("ModifyTime in updateInfraRequest is set to: " + nowTimeStamp);
155 query.setParameter ("lastModifiedBy", lastModifiedBy);
156 LOGGER.debug ("LastModifiedBy in updateInfraRequest is set to: " + lastModifiedBy);
157 result = query.executeUpdate ();
158 checkIfExists (result, requestId, startTime);
159 session.getTransaction ().commit ();
160 } catch (HibernateException e) {
161 String error = "Unable to update MSO Requests DB: " + e.getMessage ();
162 LOGGER.error (MessageEnum.RA_CANT_UPDATE_REQUEST, "infra request parameters", requestId, "", "", MsoLogger.ErrorCode.BusinessProcesssError, "HibernateException - " + error, e);
163 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError, error);
164 throw new MsoRequestsDbException (error, e);
166 if (session != null && session.isOpen ()) {
170 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successful");
174 private void checkIfExists (int result, String requestId, long startTime) throws MsoRequestsDbException {
176 String error = "Request ID does not exist in MSO Requests DB: " + requestId;
177 LOGGER.error (MessageEnum.RA_DB_REQUEST_NOT_EXIST, requestId, "", "", MsoLogger.ErrorCode.DataError, error);
178 throw new MsoRequestsDbException (error);
184 public InfraActiveRequests getInfraRequest (String requestId) throws MsoRequestsDbException {
185 long startTime = System.currentTimeMillis ();
186 MsoLogger.setLogContext (requestId, null);
187 Session session = HibernateUtil.getSessionFactory ().openSession ();
189 LOGGER.debug ("Call to MSO Infra RequestsDb adapter get method with request Id: " + requestId);
191 InfraActiveRequests request = null;
193 session.beginTransaction ();
194 Query query = session.createQuery ("FROM InfraActiveRequests where requestId = :requestId OR clientRequestId = :requestId");
195 query.setParameter ("requestId", requestId);
196 request = (InfraActiveRequests) query.uniqueResult();
197 } catch (HibernateException e) {
198 String error = "Unable to retrieve MSO Infra Requests DB for Request ID "
200 LOGGER.error (MessageEnum.RA_DB_REQUEST_NOT_EXIST, "Get Infra request", requestId, "", "", MsoLogger.ErrorCode.BusinessProcesssError, "HibernateException - " + error, e);
201 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError, error);
202 throw new MsoRequestsDbException (error, e);
204 if (session != null && session.isOpen ()) {
208 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successful");
214 * Get SiteStatus by SiteName.
216 * @param siteName The unique name of the site
217 * @return Status of that site
219 public boolean getSiteStatus (String siteName) {
220 UUIDChecker.generateUUID (LOGGER);
221 Session session = HibernateUtil.getSessionFactory ().openSession ();
223 long startTime = System.currentTimeMillis ();
224 SiteStatus siteStatus = null;
225 LOGGER.debug ("Request database - get Site Status with Site name:" + siteName);
227 String hql = "FROM SiteStatus WHERE siteName = :site_name";
228 Query query = session.createQuery (hql);
229 query.setParameter ("site_name", siteName);
231 siteStatus = (SiteStatus) query.uniqueResult ();
233 if (session != null && session.isOpen ()) {
237 if (siteStatus == null) {
238 // if not exist in DB, it means the site is not disabled, thus return true
239 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successful");
242 LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successful");
243 return siteStatus.getStatus();