refactor ns heal view code

refactor ns heal view code

Change-Id: I342e21dd773f71f8c2ade33d64044a3f78da2486
Issue-ID: VFC-1431
Signed-off-by: maopengzhang <zhang.maopeng1@zte.com.cn>

diff --git a/lcm/ns/views/sol/heal_ns_view.py b/lcm/ns/views/sol/heal_ns_view.py
index 6dfef8d..58418bd 100644 (file)
--- a/lcm/ns/views/sol/heal_ns_view.py
+++ b/lcm/ns/views/sol/heal_ns_view.py
@@ -12,18 +12,19 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import logging
+
+from .common import view_safe_call_with_log
 from drf_yasg.utils import swagger_auto_schema
-from rest_framework import status
-from rest_framework.response import Response
-from rest_framework.views import APIView
 from lcm.ns.biz.ns_heal import NSHealService
-from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer
-from lcm.pub.exceptions import BadRequestException
-from lcm.pub.utils.jobutil import JobUtil
-from lcm.pub.enum import JOB_TYPE
 from lcm.ns.const import NS_OCC_BASE_URI
+from lcm.pub.enum import JOB_TYPE
+from lcm.pub.exceptions import BadRequestException
+from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer
 from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer
-from .common import view_safe_call_with_log
+from lcm.pub.utils.jobutil import JobUtil
+from rest_framework import status
+from rest_framework.response import Response
+from rest_framework.views import APIView
 
 logger = logging.getLogger(__name__)
 
@@ -38,19 +39,17 @@ class HealNSView(APIView):
     )
     @view_safe_call_with_log(logger=logger)
     def post(self, request, ns_instance_id):
-        logger.debug("Enter HealNSView::post %s", request.data)
-        logger.debug("Enter HealNSView:: %s", ns_instance_id)
+        logger.debug("Enter HealNSView::post nsInstanceId:%s, request.data:%s" % (ns_instance_id, request.data))
         req_serializer = HealNsReqSerializer(data=request.data)
         if not req_serializer.is_valid():
-            logger.debug("request.data is not valid,error: %s" % req_serializer.errors)
+            logger.error("request.data is not valid,error: %s" % req_serializer.errors)
             raise BadRequestException(req_serializer.errors)
 
-        job_id = JobUtil.create_job("VNF", JOB_TYPE.HEAL_VNF, ns_instance_id)
-
-        nsHealService = NSHealService(ns_instance_id, request.data, job_id)
-        nsHealService.start()
+        job_id = JobUtil.create_job("NS", JOB_TYPE.HEAL_NS, ns_instance_id)
+        ns_heal_service = NSHealService(ns_instance_id, request.data, job_id)
+        ns_heal_service.start()
         response = Response(data={}, status=status.HTTP_202_ACCEPTED)
-        logger.debug("Location: %s" % nsHealService.occ_id)
-        response["Location"] = NS_OCC_BASE_URI % nsHealService.occ_id
+        logger.debug("Location: %s" % ns_heal_service.occ_id)
+        response["Location"] = NS_OCC_BASE_URI % ns_heal_service.occ_id
         logger.debug("Leave NSHealView")
         return response

diff --git a/lcm/pub/enum.py b/lcm/pub/enum.py
index 0a667a5..40fcdc3 100644 (file)
--- a/lcm/pub/enum.py
+++ b/lcm/pub/enum.py
@@ -30,9 +30,10 @@ JOB_TYPE = enum(
     HEAL_VNF="heal vnf",
     GRANT_VNF="grant vnf",
     MANUAL_SCALE_VNF="manual scale vnf",
-    TERMINATE_NS="terminate ns",
     TERMINATE_VNF="terminate vnf",
-    UPDATE_NS="update ns"
+    TERMINATE_NS="terminate ns",
+    UPDATE_NS="update ns",
+    HEAL_NS='heal ns'
 )
 JOB_PROGRESS = enum(
     ERROR=255,