Fix AAI Relationship read failed in delete flow

[so.git] / bpmn / MSOInfrastructureBPMN / src / main / groovy / org / openecomp / mso / bpmn / infrastructure / scripts / DeleteCustomE2EServiceInstance.groovy

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteCustomE2EServiceInstance.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteCustomE2EServiceInstance.groovy
index af63176..88eccf0 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteCustomE2EServiceInstance.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteCustomE2EServiceInstance.groovy
@@ -64,7 +64,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                execution.setVariable("prefix",Prefix)\r
                String msg = ""\r
                \r
-               utils.log("DEBUG", " *** preProcessRequest Request *** ", isDebugEnabled)\r
+               utils.log("INFO", " *** preProcessRequest Request *** ", isDebugEnabled)\r
 \r
                try {\r
                        // check for incoming json message/input\r
@@ -74,7 +74,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
 \r
                        String requestId = execution.getVariable("mso-request-id")\r
                        execution.setVariable("msoRequestId", requestId)\r
-                       utils.log("DEBUG", "Input Request:" + siRequest + " reqId:" + requestId, isDebugEnabled)\r
+                       utils.log("INFO", "Input Request:" + siRequest + " reqId:" + requestId, isDebugEnabled)\r
                        \r
                        String serviceInstanceId = execution.getVariable("serviceInstanceId")\r
                        if (isBlank(serviceInstanceId)) {\r
@@ -85,7 +85,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        String serviceType = execution.getVariable("serviceType")\r
                        if (isBlank(serviceType)) {\r
                                msg = "Input serviceType' is null"\r
-                               utils.log("DEBUG", msg, isDebugEnabled)\r
+                               utils.log("INFO", msg, isDebugEnabled)\r
                        } else {\r
                                execution.setVariable("serviceType", serviceType)\r
                        }\r
@@ -94,7 +94,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        String globalSubscriberId = jsonUtil.getJsonValue(siRequest, "globalSubscriberId")\r
                        if (isBlank(globalSubscriberId)) {\r
                                msg = "Input globalSubscriberId' is null"\r
-                               utils.log("DEBUG", msg, isDebugEnabled)\r
+                               utils.log("INFO", msg, isDebugEnabled)\r
                        } else {\r
                                execution.setVariable("globalSubscriberId", globalSubscriberId)\r
                        }\r
@@ -112,34 +112,34 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        throw e;\r
                } catch (Exception ex){\r
                        msg = "Exception in preProcessRequest " + ex.getMessage()\r
-                       utils.log("DEBUG", msg, isDebugEnabled)\r
+                       utils.log("INFO", msg, isDebugEnabled)\r
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)\r
                }\r
-               utils.log("DEBUG"," ***** Exit preProcessRequest *****",  isDebugEnabled)\r
+               utils.log("INFO"," ***** Exit preProcessRequest *****",  isDebugEnabled)\r
        }\r
 \r
        public void sendSyncResponse (Execution execution) {\r
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
-               utils.log("DEBUG", " *** sendSyncResponse  *** ", isDebugEnabled)\r
+               utils.log("INFO", " *** sendSyncResponse  *** ", isDebugEnabled)\r
 \r
                try {\r
                        String operationId = execution.getVariable("operationId")\r
                        \r
                        // RESTResponse (for API Handler (APIH) Reply Task) :  :  \r
                        String syncResponse = """{"operationId":"${operationId}"}""".trim()\r
-                       utils.log("DEBUG", " sendSynchResponse: xmlSyncResponse - " + "\n" + syncResponse, isDebugEnabled)\r
+                       utils.log("INFO", " sendSynchResponse: xmlSyncResponse - " + "\n" + syncResponse, isDebugEnabled)\r
                        sendWorkflowResponse(execution, 202, syncResponse)\r
 \r
                } catch (Exception ex) {\r
                        String msg  = "Exception in sendSyncResponse: " + ex.getMessage()\r
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)\r
                }\r
-               utils.log("DEBUG"," ***** Exit sendSyncResopnse *****",  isDebugEnabled)\r
+               utils.log("INFO"," ***** Exit sendSyncResopnse *****",  isDebugEnabled)\r
        }\r
        \r
        public void sendSyncError (Execution execution) {\r
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
-               utils.log("DEBUG", " *** sendSyncError *** ", isDebugEnabled)\r
+               utils.log("INFO", " *** sendSyncError *** ", isDebugEnabled)\r
 \r
                try {\r
                        String errorMessage = ""\r
@@ -160,14 +160,14 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        sendWorkflowResponse(execution, 500, buildworkflowException)\r
 \r
                } catch (Exception ex) {\r
-                       utils.log("DEBUG", " Sending Sync Error Activity Failed. " + "\n" + ex.getMessage(), isDebugEnabled)\r
+                       utils.log("INFO", " Sending Sync Error Activity Failed. " + "\n" + ex.getMessage(), isDebugEnabled)\r
                }\r
 \r
        }\r
        \r
        public void prepareCompletionRequest (Execution execution) {\r
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
-               utils.log("DEBUG", " *** prepareCompletion *** ", isDebugEnabled)\r
+               utils.log("INFO", " *** prepareCompletion *** ", isDebugEnabled)\r
 \r
                try {\r
                        String requestId = execution.getVariable("msoRequestId")\r
@@ -188,23 +188,23 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        String xmlMsoCompletionRequest = utils.formatXml(msoCompletionRequest)\r
 \r
                        execution.setVariable("completionRequest", xmlMsoCompletionRequest)\r
-                       utils.log("DEBUG", " Overall SUCCESS Response going to CompleteMsoProcess - " + "\n" + xmlMsoCompletionRequest, isDebugEnabled)\r
+                       utils.log("INFO", " Overall SUCCESS Response going to CompleteMsoProcess - " + "\n" + xmlMsoCompletionRequest, isDebugEnabled)\r
 \r
                } catch (Exception ex) {\r
                        String msg = " Exception in prepareCompletion:" + ex.getMessage()\r
-                       utils.log("DEBUG", msg, isDebugEnabled)\r
+                       utils.log("INFO", msg, isDebugEnabled)\r
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)\r
                }\r
-               utils.log("DEBUG", "*** Exit prepareCompletionRequest ***", isDebugEnabled)\r
+               utils.log("INFO", "*** Exit prepareCompletionRequest ***", isDebugEnabled)\r
        }\r
        \r
        public void prepareFalloutRequest(Execution execution){\r
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
-               utils.log("DEBUG", " *** prepareFalloutRequest *** ", isDebugEnabled)\r
+               utils.log("INFO", " *** prepareFalloutRequest *** ", isDebugEnabled)\r
 \r
                try {\r
                        WorkflowException wfex = execution.getVariable("WorkflowException")\r
-                       utils.log("DEBUG", " Input Workflow Exception: " + wfex.toString(), isDebugEnabled)\r
+                       utils.log("INFO", " Input Workflow Exception: " + wfex.toString(), isDebugEnabled)\r
                        String requestId = execution.getVariable("msoRequestId")\r
                        String source = execution.getVariable("source")\r
                        String requestInfo =\r
@@ -217,7 +217,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                        String falloutRequest = exceptionUtil.processMainflowsBPMNException(execution, requestInfo)\r
                        execution.setVariable("falloutRequest", falloutRequest)\r
                } catch (Exception ex) {\r
-                       utils.log("DEBUG", "Exception prepareFalloutRequest:" + ex.getMessage(), isDebugEnabled)\r
+                       utils.log("INFO", "Exception prepareFalloutRequest:" + ex.getMessage(), isDebugEnabled)\r
                        String errorException = "  Bpmn error encountered in CreateServiceInstance flow. FalloutHandlerRequest,  buildErrorResponse() - " + ex.getMessage()\r
                        String requestId = execution.getVariable("msoRequestId")\r
                        String falloutRequest =\r
@@ -237,7 +237,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
 \r
                        execution.setVariable("falloutRequest", falloutRequest)\r
                }\r
-               utils.log("DEBUG", "*** Exit prepareFalloutRequest ***", isDebugEnabled)\r
+               utils.log("INFO", "*** Exit prepareFalloutRequest ***", isDebugEnabled)\r
        }\r
        \r
 \r
@@ -249,7 +249,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                execution.setVariable("prefix", Prefix)\r
 \r
                try {\r
-                       utils.log("DEBUG", " ***** Inside prepareDBRequest of DeleteCustomE2EServiceInstance ***** ", isDebugEnabled)\r
+                       utils.log("INFO", " ***** Inside prepareDBRequest of DeleteCustomE2EServiceInstance ***** ", isDebugEnabled)\r
 \r
                        String requestId = execution.getVariable("DELSI_requestId")\r
                        String statusMessage = "E2E Service Instance successfully deleted."\r
@@ -290,7 +290,7 @@ public class DeleteCustomE2EServiceInstance extends AbstractServiceTaskProcessor
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
                execution.setVariable("prefix", Prefix)\r
 \r
-               utils.log("DEBUG", " ***** Inside prepareDBRequestError of DeleteCustomE2EServiceInstance ***** ", isDebugEnabled)\r
+               utils.log("INFO", " ***** Inside prepareDBRequestError of DeleteCustomE2EServiceInstance ***** ", isDebugEnabled)\r
 \r
                try {\r
                        String requestId = execution.getVariable("DELSI_requestId")\r