ADD UT for ns_vnfs Issue-ID: VFC-1429 Signed-off-by: zhuerlei <zhu.erlei@zte.com.cn>

Change-Id: I9f8cb9d8ee6d836f1f10769d75dcc95967d80b21
Signed-off-by: erlei <zhu.erlei@zte.com.cn>

4 files changed, 1087 insertions, 17 deletions

diff --git a/lcm/ns_vnfs/biz/handle_notification.py b/lcm/ns_vnfs/biz/handle_notification.py
index 010ca3fa..a66946da 100644
--- a/lcm/ns_vnfs/biz/handle_notification.py
+++ b/lcm/ns_vnfs/biz/handle_notification.py
@@ -118,7 +118,7 @@ class HandleVnfLcmOocNotification(object):
 
     def update_Cp(self):
         for cp in self.affectedCps:
-            virtualLinkInstanceId = ignore_case_get(cp, 'id')
+            # virtualLinkInstanceId = ignore_case_get(cp, 'id')
             ownertype = 0
             ownerid = self.vnf_instid
             for extLinkPorts in ignore_case_get(cp, 'extLinkPorts'):
@@ -147,8 +147,7 @@ class HandleVnfLcmOocNotification(object):
                     relatedportId = portid
 
                 CPInstModel(cpinstanceid=cpInstanceId, cpdid=cpdId, ownertype=ownertype, ownerid=ownerid,
-                            vlinstanceid=virtualLinkInstanceId, relatedtype=2, relatedport=relatedportId,
-                            status='active').save()
+                            relatedtype=2, relatedport=relatedportId, status='active').save()
 
     def update_Storage(self):
         pass
diff --git a/lcm/ns_vnfs/biz/notify_lcm.py b/lcm/ns_vnfs/biz/notify_lcm.py
index 3119e0db..c5bff6c4 100644
--- a/lcm/ns_vnfs/biz/notify_lcm.py
+++ b/lcm/ns_vnfs/biz/notify_lcm.py
@@ -83,18 +83,18 @@ class NotifyLcm(object):
             vmId = ignore_case_get(vnfc, 'vmId')
             vmName = ignore_case_get(vnfc, 'vmName')
 
-            if changeType == 'added':
+            if changeType == 'ADDED':
                 VNFCInstModel(vnfcinstanceid=vnfcInstanceId, vduid=vduId,
                               nfinstid=self.vnf_instid, vmid=vmId).save()
                 VmInstModel(vmid=vmId, vimid=vimId, resouceid=vmId, insttype=INST_TYPE.VNF,
                             instid=self.vnf_instid, vmname=vmName, hostid='1').save()
                 if REPORT_TO_AAI:
                     self.create_vserver_in_aai(vimId, vmId, vmName)
-            elif changeType == 'removed':
+            elif changeType == 'REMOVED':
                 if REPORT_TO_AAI:
                     self.delete_vserver_in_aai(vimId, vmId, vmName)
                 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).delete()
-            elif changeType == 'modified':
+            elif changeType == 'MODIFIED':
                 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).update(vduid=vduId,
                                                                                    nfinstid=self.vnf_instid,
                                                                                    vmid=vmId)
@@ -141,12 +141,12 @@ class NotifyLcm(object):
 
             ownerId = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
 
-            if changeType == 'added':
+            if changeType == 'ADDED':
                 VLInstModel(vlinstanceid=vlInstanceId, vldid=vldid, vlinstancename=resourceName, ownertype=0,
                             ownerid=ownerId, relatednetworkid=resourceId, vltype=0).save()
-            elif changeType == 'removed':
+            elif changeType == 'REMOVED':
                 VLInstModel.objects.filter(vlinstanceid=vlInstanceId).delete()
-            elif changeType == 'modified':
+            elif changeType == 'MODIFIED':
                 VLInstModel.objects.filter(vlinstanceid=vlInstanceId)\
                     .update(vldid=vldid, vlinstancename=resourceName, ownertype=0, ownerid=ownerId,
                             relatednetworkid=resourceId, vltype=0)
@@ -155,7 +155,7 @@ class NotifyLcm(object):
 
     def update_Cp(self):
         for cp in self.affectedCp:
-            virtualLinkInstanceId = ignore_case_get(cp, 'virtualLinkInstanceId')
+            # virtualLinkInstanceId = ignore_case_get(cp, 'virtualLinkInstanceId')
             ownertype = ignore_case_get(cp, 'ownerType')
             if not ownertype:
                 ownertype = 0
@@ -181,15 +181,14 @@ class NotifyLcm(object):
                               sfcencapsulation='gre', direction='unknown', tenant=tenant).save()
                 relatedportId = portid
 
-            if changeType == 'added':
+            if changeType == 'ADDED':
                 CPInstModel(cpinstanceid=cpInstanceId, cpdid=cpdId, ownertype=ownertype, ownerid=ownerid,
                             relatedtype=2, relatedport=relatedportId, status='active').save()
-            elif changeType == 'removed':
+            elif changeType == 'REMOVED':
                 CPInstModel.objects.filter(cpinstanceid=cpInstanceId).delete()
-            elif changeType == 'changed':
+            elif changeType == 'MODIFIED':
                 CPInstModel.objects.filter(cpinstanceid=cpInstanceId).update(cpdid=cpdId, ownertype=ownertype,
                                                                              ownerid=ownerid,
-                                                                             vlinstanceid=virtualLinkInstanceId,
                                                                              relatedtype=2, relatedport=relatedportId)
             else:
                 self.exception('affectedVl struct error: changeType not in {added,removed,modified}')
diff --git a/lcm/ns_vnfs/biz/verify_vnfs.py b/lcm/ns_vnfs/biz/verify_vnfs.py
index 386af337..c85f32fb 100644
--- a/lcm/ns_vnfs/biz/verify_vnfs.py
+++ b/lcm/ns_vnfs/biz/verify_vnfs.py
@@ -104,7 +104,7 @@ class VerifyVnfs(threading.Thread):
         if ret[0] != 0:
             raise NSLCMException("Failed to get func test result: %s" % ret[1])
         rsp_result_data = json.JSONDecoder().decode(ret[1])
-        logger.info("Func test(%s) result: %s", rsp_result_data)
+        logger.info("Func test(%s) result: %s", "do_func_test", rsp_result_data)
         self.update_job(80, "Vnf function test success.")
 
     def do_term_vnf(self):
diff --git a/lcm/ns_vnfs/tests/tests.py b/lcm/ns_vnfs/tests/tests.py
index 963ac245..b4c60cfc 100644
--- a/lcm/ns_vnfs/tests/tests.py
+++ b/lcm/ns_vnfs/tests/tests.py
@@ -20,7 +20,7 @@ from django.test import TestCase, Client
 from rest_framework import status
 
 from lcm.pub.database.models import VLInstModel, NfInstModel, JobModel, NSInstModel, VmInstModel, \
-    OOFDataModel, VNFCInstModel
+    OOFDataModel, VNFCInstModel, PortInstModel, CPInstModel
 from lcm.pub.exceptions import NSLCMException
 from lcm.pub.utils import restcall
 from lcm.jobs.enum import JOB_MODEL_STATUS, JOB_TYPE, JOB_ACTION, JOB_PROGRESS
@@ -32,7 +32,8 @@ from lcm.ns_vnfs.biz.heal_vnfs import NFHealService
 from lcm.ns_vnfs.biz.scale_vnfs import NFManualScaleService
 from lcm.ns_vnfs.biz.subscribe import SubscriptionDeletion
 from lcm.ns_vnfs.biz.terminate_nfs import TerminateVnfs
-from lcm.ns_vnfs.enum import VNF_STATUS, LIFE_CYCLE_OPERATION, RESOURCE_CHANGE_TYPE
+from lcm.ns_vnfs.enum import VNF_STATUS, LIFE_CYCLE_OPERATION, RESOURCE_CHANGE_TYPE, VNFC_CHANGE_TYPE, INST_TYPE, \
+    NETWORK_RESOURCE_TYPE
 from lcm.ns_vnfs.biz.place_vnfs import PlaceVnfs
 from lcm.pub.msapi import resmgr
 from lcm.ns_vnfs.tests.test_data import vnfm_info, vim_info, vnf_place_request
@@ -40,7 +41,12 @@ from lcm.ns_vnfs.tests.test_data import nf_package_info, nsd_model_dict, subscri
 from lcm.ns_vnfs.biz.create_vnfs import CreateVnfs
 from lcm.ns_vnfs.biz import create_vnfs
 from lcm.ns_vnfs.biz.grant_vnfs import GrantVnfs
+from lcm.ns_vnfs.biz.update_vnfs import NFOperateService
+from lcm.ns_vnfs.biz.verify_vnfs import VerifyVnfs
 from lcm.ns.enum import OWNER_TYPE
+from lcm.ns_vnfs.biz.handle_notification import HandleVnfLcmOocNotification, HandleVnfIdentifierCreationNotification, \
+    HandleVnfIdentifierDeletionNotification
+from lcm.ns_vnfs.biz.notify_lcm import NotifyLcm
 
 
 class TestGetVnfViews(TestCase):
@@ -1285,3 +1291,1069 @@ class TestCreateVnfViews(TestCase):
         CreateVnfs(data, nf_inst_id, job_id).send_homing_request_to_OOF()
         ret = OOFDataModel.objects.filter(request_id="1234", transaction_id="1234")
         self.assertIsNotNone(ret)
+
+
+class TestUpdateVnfsViews(TestCase):
+    def setUp(self):
+        self.client = Client()
+        self.data = {
+            "terminationType": "forceful",
+            "gracefulTerminationTimeout": "600",
+            "additionalParams": ""
+        }
+        self.nf_inst_id = "test_update_vnf"
+        self.m_nf_inst_id = "test_update_vnf_m_nf_inst_id"
+        self.vnfm_inst_id = "test_update_vnf_vnfm_inst_id"
+        self.vnfd_model = {"metadata": {"vnfdId": "1"}}
+        NfInstModel.objects.all().delete()
+        NfInstModel.objects.create(nfinstid=self.nf_inst_id,
+                                   vnfm_inst_id=self.vnfm_inst_id,
+                                   status=VNF_STATUS.NULL,
+                                   mnfinstid=self.m_nf_inst_id,
+                                   vnfd_model=self.vnfd_model
+                                   )
+
+    def tearDown(self):
+        NfInstModel.objects.all().delete()
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_update_vnf_thread(self, mock_call_req, mock_sleep):
+        vnf_update_service = NFOperateService(self.nf_inst_id, self.data)
+        job_info = {
+            "jobId": vnf_update_service.job_id,
+            "responsedescriptor": {"status": JOB_MODEL_STATUS.FINISHED}
+        }
+        mock_vals = {
+            "/external-system/esr-vnfm-list/esr-vnfm/test_update_vnf_vnfm_inst_id?depth=all":
+                [0, json.JSONEncoder().encode(vnfm_info), "200"],
+            "/api/ztevnfmdriver/v1/test_update_vnf_vnfm_inst_id/vnfs/test_update_vnf_m_nf_inst_id/operate":
+                [0, json.JSONEncoder().encode({"jobId": vnf_update_service.job_id}), "200"],
+            "/api/ztevnfmdriver/v1/test_update_vnf_vnfm_inst_id/jobs/" + vnf_update_service.job_id + "?responseId=0":
+                [0, json.JSONEncoder().encode(job_info), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+        mock_call_req.side_effect = side_effect
+        vnf_update_service.run()
+        nfinst = NfInstModel.objects.get(nfinstid=self.nf_inst_id)
+        self.assertEqual(nfinst.status, VNF_STATUS.ACTIVE)
+        self.assertEqual(JobModel.objects.get(jobid=vnf_update_service.job_id).progress, JOB_PROGRESS.FINISHED)
+
+    def test_update_vnf_thread_when_no_nf(self):
+        NfInstModel.objects.all().delete()
+        vnf_update_service = NFOperateService(self.nf_inst_id, self.data)
+        vnf_update_service.run()
+        self.assertEqual(JobModel.objects.get(jobid=vnf_update_service.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_update_vnf_thread_when_nf_update_failed(self, mock_call_req, mock_sleep):
+        vnf_update_service = NFOperateService(self.nf_inst_id, self.data)
+        job_info = {
+            "jobId": vnf_update_service.job_id,
+            "responsedescriptor": {"status": JOB_MODEL_STATUS.ERROR}
+        }
+        mock_vals = {
+            "/external-system/esr-vnfm-list/esr-vnfm/test_update_vnf_vnfm_inst_id?depth=all":
+                [0, json.JSONEncoder().encode(vnfm_info), "200"],
+            "/api/ztevnfmdriver/v1/test_update_vnf_vnfm_inst_id/vnfs/test_update_vnf_m_nf_inst_id/operate":
+                [0, json.JSONEncoder().encode({"jobId": vnf_update_service.job_id}), "200"],
+            "/api/ztevnfmdriver/v1/test_update_vnf_vnfm_inst_id/jobs/" + vnf_update_service.job_id + "?responseId=0":
+                [0, json.JSONEncoder().encode(job_info), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        vnf_update_service.run()
+        nfinst = NfInstModel.objects.get(nfinstid=self.nf_inst_id)
+        self.assertEqual(nfinst.status, VNF_STATUS.UPDATING)
+        self.assertEqual(JobModel.objects.get(jobid=vnf_update_service.job_id).progress, JOB_PROGRESS.ERROR)
+
+
+class TestVerifyVnfsViews(TestCase):
+    def setUp(self):
+        self.client = Client()
+        self.url = "/api/nslcm/v1/vnfonboarding"
+        self.package_id = "test_verify_vnfs_package_id"
+        self.nf_inst_id = "test_verify_vnfs"
+        self.m_nf_inst_id = "test_verify_vnfs_m_nf_inst_id"
+        self.vnfm_inst_id = "test_verify_vnfs_vnfm_inst_id"
+        self.vnfd_model = {"metadata": {"vnfdId": "1"}}
+        self.data = {
+            "PackageID": self.package_id,
+        }
+        self.job_id = JobUtil.create_job(JOB_TYPE.VNF, "verify_vnfs", self.nf_inst_id)
+        NfInstModel.objects.all().delete()
+        NfInstModel.objects.create(package_id=self.package_id,
+                                   nfinstid=self.nf_inst_id,
+                                   vnfm_inst_id=self.vnfm_inst_id,
+                                   status=VNF_STATUS.NULL,
+                                   mnfinstid=self.m_nf_inst_id,
+                                   vnfd_model=self.vnfd_model
+                                   )
+
+    def tearDown(self):
+        NfInstModel.objects.all().delete()
+
+    @mock.patch.object(VerifyVnfs, "run")
+    def test_verify_vnfs_view(self, mock_run):
+        response = self.client.post(self.url, data=self.data)
+        self.assertEqual(status.HTTP_202_ACCEPTED, response.status_code)
+
+    def test_verify_vnfs_view_when_data_is_not_valid(self):
+        response = self.client.post(self.url, data={})
+        self.assertEqual(status.HTTP_409_CONFLICT, response.status_code)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [0, json.JSONEncoder().encode(job_info_task), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s/result" % "task_id":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.FINISHED)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_failed_to_call_vnf_onboarding(self, mock_call_req, mock_sleep):
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [1, json.JSONEncoder().encode({}), "200"]
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_on_boarding_failed_to_query_job(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [1, json.JSONEncoder().encode(job_info_1), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_on_boarding_job_does_not_exist(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_on_boarding_job_process_error(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": JOB_PROGRESS.ERROR,
+                "responseId": 1,
+                "statusDescription": "already onBoarded"
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [0, json.JSONEncoder().encode(job_info_task), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s/result" % "task_id":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.FINISHED)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_failed_to_call_inst_vnf(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [1, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_term_vnf_job_process_error(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": JOB_PROGRESS.ERROR,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_failed_to_call_func_test(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [1, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"]
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_func_test_failed_query_job(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [1, json.JSONEncoder().encode(job_info_task), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_func_test_job_does_not_exist(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [0, json.JSONEncoder().encode(job_info_task), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s/result" % "task_id":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_func_test_job_process_error(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.ERROR,
+                "progress": JOB_PROGRESS.ERROR,
+                "responseId": 1,
+                "statusDescription": "already onBoarded"
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [0, json.JSONEncoder().encode(job_info_task), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s/result" % "task_id":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.FINISHED)
+
+    @mock.patch.object(time, "sleep")
+    @mock.patch.object(restcall, "call_req")
+    def test_verify_vnfs_thread_when_do_func_test_failed_to_get_func_test_result(self, mock_call_req, mock_sleep):
+        job_info_1 = {
+            "jobId": "test_1",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_2 = {
+            "jobId": "test_2",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 0,
+                "statusDescription": ""
+            }
+        }
+        job_info_task = {
+            "jobId": "task_id",
+            "responseDescriptor": {
+                "status": JOB_MODEL_STATUS.FINISHED,
+                "progress": 100,
+                "responseId": 1,
+                "statusDescription": "already onBoarded"
+            }
+        }
+        mock_vals = {
+            "/api/nslcm/v1/vnfpackage":
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_1", 0):
+                [0, json.JSONEncoder().encode(job_info_1), "200"],
+            "/api/nslcm/v1/ns/ns_vnfs":
+                [0, json.JSONEncoder().encode({"jobId": "test_2", "vnfInstId": ""}), "200"],
+            "/api/nslcm/v1/jobs/%s?responseId=%s" % ("test_2", 0):
+                [0, json.JSONEncoder().encode(job_info_2), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks":
+                [0, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s?responseId=%s" % ("task_id", 0):
+                [0, json.JSONEncoder().encode(job_info_task), "200"],
+            "/openapi/vnfsdk/v1/functest/taskmanager/testtasks/%s/result" % "task_id":
+                [1, json.JSONEncoder().encode({"TaskID": "task_id"}), "200"],
+        }
+
+        def side_effect(*args):
+            return mock_vals[args[4]]
+
+        mock_call_req.side_effect = side_effect
+        VerifyVnfs(self.data, self.job_id).run()
+        self.assertEqual(JobModel.objects.get(jobid=self.job_id).progress, JOB_PROGRESS.ERROR)
+
+
+class TestLcmNotifyViews(TestCase):
+    def setUp(self):
+        self.client = Client()
+        self.data = {
+            "status": "START",
+            "operation": "Instantiate",
+            "jobId": "",
+            "vnfdmodule": "",
+            "affectedVnfc": [{"vnfcInstanceId": "vnfc_instance_id",
+                              "vduId": "vdu_id",
+                              "changeType": VNFC_CHANGE_TYPE.ADDED,
+                              "vimId": "vim_id",
+                              "vmId": "vm_id",
+                              "vmName": "vm_name"
+                              }],
+            "affectedVl": [{"vlInstanceId": "vl_instance_id",
+                            "vldId": "vld_id",
+                            "changeType": VNFC_CHANGE_TYPE.ADDED,
+                            "networkResource": {
+                                "resourceType": NETWORK_RESOURCE_TYPE.NETWORK,
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name"
+                            }
+                            }],
+            "affectedCp": [{"changeType": VNFC_CHANGE_TYPE.ADDED,
+                            "virtualLinkInstanceId": "virtual_link_instance_id",
+                            "cpInstanceId": "cp_instance_id",
+                            "cpdId": "cpd_id",
+                            "ownerType": 0,
+                            "ownerId": "owner_id",
+                            "portResource": {
+                                "vimId": "vim_id",
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name",
+                                "tenant": "tenant",
+                                "ipAddress": "ip_address",
+                                "macAddress": "mac_address",
+                                "instId": "inst_id"
+                            }
+                            }],
+            "affectedVirtualStorage": [{}]
+        }
+        self.nf_inst_id = "test_lcm_notify"
+        self.m_nf_inst_id = "test_lcm_notify_m_nf_inst_id"
+        self.vnfm_inst_id = "test_lcm_notify_vnfm_inst_id"
+        self.vnfd_model = {"metadata": {"vnfdId": "1"}}
+        self.url = "/api/nslcm/v1/ns/%s/vnfs/%s/Notify" % (self.m_nf_inst_id, self.vnfm_inst_id)
+        NfInstModel.objects.all().delete()
+        NfInstModel.objects.create(nfinstid=self.nf_inst_id,
+                                   vnfm_inst_id=self.vnfm_inst_id,
+                                   status=VNF_STATUS.NULL,
+                                   mnfinstid=self.m_nf_inst_id,
+                                   vnfd_model=self.vnfd_model
+                                   )
+
+    def tearDown(self):
+        NfInstModel.objects.all().delete()
+        VNFCInstModel.objects.all().delete()
+        VmInstModel.objects.all().delete()
+        VLInstModel.objects.all().delete()
+        PortInstModel.objects.all().delete()
+        CPInstModel.objects.all().delete()
+
+    def test_lcm_notify_view_when_change_type_is_added(self):
+        NotifyLcm(self.vnfm_inst_id, self.m_nf_inst_id, self.data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.get(vnfcinstanceid="vnfc_instance_id", vduid="vdu_id", vmid="vm_id",
+                                              nfinstid=self.nf_inst_id)
+        self.assertIsInstance(vnfc_inst, VNFCInstModel)
+        vm_inst = VmInstModel.objects.get(vmid="vm_id", vimid="vim_id", resouceid="vm_id", insttype=INST_TYPE.VNF,
+                                          instid=self.nf_inst_id, vmname="vm_name", hostid='1')
+        self.assertIsInstance(vm_inst, VmInstModel)
+        vl_inst = VLInstModel.objects.get(vlinstanceid="vl_instance_id", vldid="vld_id", vlinstancename="resource_name",
+                                          ownertype=0, ownerid=self.nf_inst_id, relatednetworkid="resource_id",
+                                          vltype=0)
+        self.assertIsInstance(vl_inst, VLInstModel)
+        port_inst = PortInstModel.objects.get(networkid='unknown', subnetworkid='unknown', vimid="vim_id",
+                                              resourceid="resource_id", name="resource_name", instid="inst_id",
+                                              cpinstanceid="cp_instance_id", bandwidth='unknown',
+                                              operationalstate='active', ipaddress="ip_address",
+                                              macaddress='mac_address', floatipaddress='unknown',
+                                              serviceipaddress='unknown', typevirtualnic='unknown',
+                                              sfcencapsulation='gre', direction='unknown', tenant="tenant")
+        self.assertIsInstance(port_inst, PortInstModel)
+        cp_inst = CPInstModel.objects.get(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0,
+                                          ownerid=self.nf_inst_id, relatedtype=2, status='active')
+        self.assertIsInstance(cp_inst, CPInstModel)
+
+    def test_lcm_notify_view__when_change_type_is_added_when_nf_not_exists(self):
+        NfInstModel.objects.all().delete()
+        data = {
+            "status": "START",
+            "operation": "Instantiate",
+            "jobId": "",
+            "vnfdmodule": "",
+        }
+        try:
+            NotifyLcm(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+            self.assertEqual(1, 0)
+        except Exception:
+            self.assertEqual(1, 1)
+
+    def test_lcm_notify_view_when_change_type_is_removeed(self):
+        VNFCInstModel.objects.create(vnfcinstanceid="vnfc_instance_id")
+        VLInstModel.objects.create(vlinstanceid="vl_instance_id", ownertype=0)
+        CPInstModel.objects.create(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0, ownerid=self.nf_inst_id,
+                                   relatedtype=2, relatedport="related_port", status="active")
+        data = {
+            "status": "START",
+            "operation": "Instantiate",
+            "jobId": "",
+            "vnfdmodule": "",
+            "affectedVnfc": [{"vnfcInstanceId": "vnfc_instance_id",
+                              "vduId": "vdu_id",
+                              "changeType": VNFC_CHANGE_TYPE.REMOVED,
+                              "vimId": "vim_id",
+                              "vmId": "vm_id",
+                              "vmName": "vm_name"
+                              }],
+            "affectedVl": [{"vlInstanceId": "vl_instance_id",
+                            "vldId": "vld_id",
+                            "changeType": VNFC_CHANGE_TYPE.REMOVED,
+                            "networkResource": {
+                                "resourceType": NETWORK_RESOURCE_TYPE.NETWORK,
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name"
+                            }
+                            }],
+            "affectedCp": [{"changeType": VNFC_CHANGE_TYPE.REMOVED,
+                            "virtualLinkInstanceId": "virtual_link_instance_id",
+                            "cpInstanceId": "cp_instance_id",
+                            "cpdId": "cpd_id",
+                            "ownerType": 0,
+                            "ownerId": "owner_id",
+                            "portResource": {
+                                "vimId": "vim_id",
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name",
+                                "tenant": "tenant",
+                                "ipAddress": "ip_address",
+                                "macAddress": "mac_address",
+                                "instId": "inst_id"
+                            }
+                            }],
+            "affectedVirtualStorage": [{}]
+        }
+        NotifyLcm(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.filter(vnfcinstanceid="vnfc_instance_id")
+        self.assertEqual(len(vnfc_inst), 0)
+        vl_inst = VLInstModel.objects.filter(vlinstanceid="vl_instance_id")
+        self.assertEqual(len(vl_inst), 0)
+        port_inst = PortInstModel.objects.get(networkid='unknown', subnetworkid='unknown', vimid="vim_id",
+                                              resourceid="resource_id", name="resource_name", instid="inst_id",
+                                              cpinstanceid="cp_instance_id", bandwidth='unknown',
+                                              operationalstate='active', ipaddress="ip_address",
+                                              macaddress='mac_address', floatipaddress='unknown',
+                                              serviceipaddress='unknown', typevirtualnic='unknown',
+                                              sfcencapsulation='gre', direction='unknown', tenant="tenant")
+        self.assertIsInstance(port_inst, PortInstModel)
+        cp_inst = CPInstModel.objects.filter(cpinstanceid="cp_instance_id")
+        self.assertEqual(len(cp_inst), 0)
+
+    def test_lcm_notify_view_when_change_type_is_modified(self):
+        VNFCInstModel.objects.create(vnfcinstanceid="vnfc_instance_id")
+        VLInstModel.objects.create(vlinstanceid="vl_instance_id", ownertype=0)
+        CPInstModel.objects.create(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0, ownerid=self.nf_inst_id,
+                                   relatedtype=2, relatedport="related_port")
+        data = {
+            "status": "START",
+            "operation": "Instantiate",
+            "jobId": "",
+            "vnfdmodule": "",
+            "affectedVnfc": [{"vnfcInstanceId": "vnfc_instance_id",
+                              "vduId": "vdu_id",
+                              "changeType": VNFC_CHANGE_TYPE.MODIFIED,
+                              "vimId": "vim_id",
+                              "vmId": "vm_id",
+                              "vmName": "vm_name"
+                              }],
+            "affectedVl": [{"vlInstanceId": "vl_instance_id",
+                            "vldId": "vld_id",
+                            "changeType": VNFC_CHANGE_TYPE.MODIFIED,
+                            "networkResource": {
+                                "resourceType": NETWORK_RESOURCE_TYPE.NETWORK,
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name"
+                            }
+                            }],
+            "affectedCp": [{"changeType": VNFC_CHANGE_TYPE.MODIFIED,
+                            "virtualLinkInstanceId": "virtual_link_instance_id",
+                            "cpInstanceId": "cp_instance_id",
+                            "cpdId": "cpd_id",
+                            "ownerType": 0,
+                            "ownerId": "owner_id",
+                            "portResource": {
+                                "vimId": "vim_id",
+                                "resourceId": "resource_id",
+                                "resourceName": "resource_name",
+                                "tenant": "tenant",
+                                "ipAddress": "ip_address",
+                                "macAddress": "mac_address",
+                                "instId": "inst_id"
+                            }
+                            }],
+            "affectedVirtualStorage": [{}]
+        }
+        NotifyLcm(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.get(vnfcinstanceid="vnfc_instance_id", vduid="vdu_id", vmid="vm_id",
+                                              nfinstid=self.nf_inst_id)
+        self.assertIsInstance(vnfc_inst, VNFCInstModel)
+        vl_inst = VLInstModel.objects.get(vlinstanceid="vl_instance_id", vldid="vld_id", vlinstancename="resource_name",
+                                          ownertype=0, ownerid=self.nf_inst_id, relatednetworkid="resource_id",
+                                          vltype=0)
+        self.assertIsInstance(vl_inst, VLInstModel)
+        port_inst = PortInstModel.objects.get(networkid='unknown', subnetworkid='unknown', vimid="vim_id",
+                                              resourceid="resource_id", name="resource_name", instid="inst_id",
+                                              cpinstanceid="cp_instance_id", bandwidth='unknown',
+                                              operationalstate='active', ipaddress="ip_address",
+                                              macaddress='mac_address', floatipaddress='unknown',
+                                              serviceipaddress='unknown', typevirtualnic='unknown',
+                                              sfcencapsulation='gre', direction='unknown', tenant="tenant")
+        self.assertIsInstance(port_inst, PortInstModel)
+        cp_inst = CPInstModel.objects.get(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0,
+                                          ownerid=self.nf_inst_id, relatedtype=2)
+        self.assertIsInstance(cp_inst, CPInstModel)
+
+
+class TestVnfNotifyView(TestCase):
+    def setUp(self):
+        self.client = Client()
+        self.nf_inst_id = "test_vnf_notify"
+        self.m_nf_inst_id = "test_vnf_notify_m_nf_inst_id"
+        self.vnfm_inst_id = "test_vnf_notify_vnfm_inst_id"
+        self.vnfd_model = {"metadata": {"vnfdId": "1"}}
+        self.url = "/api/nslcm/v2/ns/%s/vnfs/%s/Notify" % (self.vnfm_inst_id, self.m_nf_inst_id)
+        self.data = {
+            "id": "1111",
+            "notificationType": "VnfLcmOperationOccurrenceNotification",
+            "subscriptionId": "1111",
+            "timeStamp": "1111",
+            "notificationStatus": "START",
+            "operationState": "STARTING",
+            "vnfInstanceId": self.nf_inst_id,
+            "operation": "INSTANTIATE",
+            "isAutomaticInvocation": "1111",
+            "vnfLcmOpOccId": "1111",
+            "affectedVnfcs": [{"id": "vnfc_instance_id",
+                              "vduId": "vdu_id",
+                               "changeType": VNFC_CHANGE_TYPE.ADDED,
+                               "computeResource": {
+                                  "vimConnectionId": "vim_connection_id",
+                                  "resourceId": "resource_id"
+                               }
+                               }],
+            "affectedVirtualLinks": [{"id": "vl_instance_id",
+                                      "virtualLinkDescId": "virtual_link_desc_id",
+                                      "changeType": VNFC_CHANGE_TYPE.ADDED,
+                                      "networkResource": {
+                                          "vimLevelResourceType": "network",
+                                          "resourceId": "resource_id"
+                                      }}],
+            "changedExtConnectivity": [{"id": "virtual_link_instance_id",
+                                        "extLinkPorts": [{"cpInstanceId": "cp_instance_id",
+                                                          "id": "cpd_id",
+                                                          "resourceHandle": {
+                                                              "vimConnectionId": "vim_connection_id",
+                                                              "resourceId": "resource_id"
+                                                          }
+                                                          }],
+                                        }]
+        }
+        NfInstModel.objects.all().delete()
+        VNFCInstModel.objects.all().delete()
+        VmInstModel.objects.all().delete()
+        NfInstModel.objects.create(nfinstid=self.nf_inst_id,
+                                   vnfm_inst_id=self.vnfm_inst_id,
+                                   status=VNF_STATUS.NULL,
+                                   mnfinstid=self.m_nf_inst_id,
+                                   vnfd_model=self.vnfd_model
+                                   )
+
+    def tearDown(self):
+        NfInstModel.objects.all().delete()
+        VNFCInstModel.objects.all().delete()
+        VmInstModel.objects.all().delete()
+        VLInstModel.objects.all().delete()
+        PortInstModel.objects.all().delete()
+        CPInstModel.objects.all().delete()
+
+    def test_handle_vnf_lcm_ooc_notification_when_change_type_is_added(self):
+        HandleVnfLcmOocNotification(self.vnfm_inst_id, self.m_nf_inst_id, self.data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.get(vnfcinstanceid="vnfc_instance_id", vduid="vdu_id",
+                                              nfinstid=self.nf_inst_id, vmid="resource_id")
+        self.assertIsInstance(vnfc_inst, VNFCInstModel)
+        vm_inst = VmInstModel.objects.get(vmid="resource_id", vimid="vim_connection_id", resouceid="resource_id",
+                                          insttype=INST_TYPE.VNF, instid=self.nf_inst_id, vmname="resource_id",
+                                          hostid='1')
+        self.assertIsInstance(vm_inst, VmInstModel)
+        vl_inst = VLInstModel.objects.get(vlinstanceid="vl_instance_id", vldid="virtual_link_desc_id",
+                                          vlinstancename="resource_id", ownertype=0, ownerid=self.nf_inst_id,
+                                          relatednetworkid="resource_id", vltype=0)
+        self.assertIsInstance(vl_inst, VLInstModel)
+        port_inst = PortInstModel.objects.get(networkid='unknown', subnetworkid='unknown', vimid="vim_connection_id",
+                                              resourceid="resource_id", name="resource_id", instid="unknown",
+                                              cpinstanceid="cp_instance_id", bandwidth='unknown',
+                                              operationalstate='active', ipaddress="unkown", macaddress='unknown',
+                                              floatipaddress='unknown', serviceipaddress='unknown',
+                                              typevirtualnic='unknown', sfcencapsulation='gre', direction='unknown',
+                                              tenant="unkown")
+        self.assertIsInstance(port_inst, PortInstModel)
+        cp_inst = CPInstModel.objects.get(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0,
+                                          ownerid=self.nf_inst_id, relatedtype=2, status='active')
+        self.assertIsInstance(cp_inst, CPInstModel)
+
+    def test_handle_vnf_lcm_ooc_notification_when_change_type_is_added_when_nf_not_exists(self):
+        data = {
+            "id": "1111",
+            "notificationType": "VnfLcmOperationOccurrenceNotification",
+            "subscriptionId": "1111",
+            "timeStamp": "1111",
+            "notificationStatus": "START",
+            "operationState": "STARTING",
+            "vnfInstanceId": "nf_not_exists",
+            "operation": "INSTANTIATE",
+            "isAutomaticInvocation": "1111",
+            "vnfLcmOpOccId": "1111"
+        }
+        try:
+            HandleVnfLcmOocNotification(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+            self.assertEqual(1, 0)
+        except Exception:
+            self.assertEqual(1, 1)
+
+    def test_handle_vnf_lcm_ooc_notification_when_change_type_is_removed(self):
+        VNFCInstModel.objects.create(vnfcinstanceid="vnfc_instance_id")
+        VLInstModel.objects.create(vlinstanceid="vl_instance_id", ownertype=0)
+        data = {
+            "id": "1111",
+            "notificationType": "VnfLcmOperationOccurrenceNotification",
+            "subscriptionId": "1111",
+            "timeStamp": "1111",
+            "notificationStatus": "START",
+            "operationState": "STARTING",
+            "vnfInstanceId": self.nf_inst_id,
+            "operation": "INSTANTIATE",
+            "isAutomaticInvocation": "1111",
+            "vnfLcmOpOccId": "1111",
+            "affectedVnfcs": [{"id": "vnfc_instance_id",
+                               "vduId": "vdu_id",
+                               "changeType": VNFC_CHANGE_TYPE.REMOVED,
+                               "computeResource": {
+                                   "vimConnectionId": "vim_connection_id",
+                                   "resourceId": "resource_id"
+                               }}],
+            "affectedVirtualLinks": [{"id": "vl_instance_id",
+                                      "virtualLinkDescId": "virtual_link_desc_id",
+                                      "changeType": VNFC_CHANGE_TYPE.REMOVED,
+                                      "networkResource": {
+                                          "vimLevelResourceType": "network",
+                                          "resourceId": "resource_id"
+                                      }}]
+        }
+        HandleVnfLcmOocNotification(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.filter(vnfcinstanceid="vnfc_instance_id")
+        self.assertEqual(len(vnfc_inst), 0)
+        vl_inst = VLInstModel.objects.filter(vlinstanceid="vl_instance_id")
+        self.assertEqual(len(vl_inst), 0)
+
+    def test_handle_vnf_lcm_ooc_notification_when_change_type_is_modified(self):
+        VNFCInstModel.objects.create(vnfcinstanceid="vnfc_instance_id")
+        VLInstModel.objects.create(vlinstanceid="vl_instance_id", ownertype=0)
+        data = {
+            "id": "1111",
+            "notificationType": "VnfLcmOperationOccurrenceNotification",
+            "subscriptionId": "1111",
+            "timeStamp": "1111",
+            "notificationStatus": "START",
+            "operationState": "STARTING",
+            "vnfInstanceId": self.nf_inst_id,
+            "operation": "INSTANTIATE",
+            "isAutomaticInvocation": "1111",
+            "vnfLcmOpOccId": "1111",
+            "affectedVnfcs": [{"id": "vnfc_instance_id",
+                               "vduId": "vdu_id",
+                               "changeType": VNFC_CHANGE_TYPE.MODIFIED,
+                               "computeResource": {
+                                   "vimConnectionId": "vim_connection_id",
+                                   "resourceId": "resource_id"
+                               }}],
+            "affectedVirtualLinks": [{"id": "vl_instance_id",
+                                      "virtualLinkDescId": "virtual_link_desc_id",
+                                      "changeType": VNFC_CHANGE_TYPE.MODIFIED,
+                                      "networkResource": {
+                                          "vimLevelResourceType": "network",
+                                          "resourceId": "resource_id"
+                                      }}],
+            "changedExtConnectivity": [{"id": "virtual_link_instance_id",
+                                        "extLinkPorts": [{"cpInstanceId": "cp_instance_id",
+                                                          "id": "cpd_id",
+                                                          "resourceHandle": {
+                                                              "vimConnectionId": "vim_connection_id",
+                                                              "resourceId": "resource_id"
+                                                          }
+                                                          }],
+                                        }]
+        }
+        HandleVnfLcmOocNotification(self.vnfm_inst_id, self.m_nf_inst_id, data).do_biz()
+        vnfc_inst = VNFCInstModel.objects.get(vnfcinstanceid="vnfc_instance_id", vduid="vdu_id",
+                                              nfinstid=self.nf_inst_id, vmid="resource_id")
+        self.assertIsInstance(vnfc_inst, VNFCInstModel)
+        vl_inst = VLInstModel.objects.get(vlinstanceid="vl_instance_id", vldid="virtual_link_desc_id",
+                                          vlinstancename="resource_id", ownertype=0, ownerid=self.nf_inst_id,
+                                          relatednetworkid="resource_id", vltype=0)
+        self.assertIsInstance(vl_inst, VLInstModel)
+        port_inst = PortInstModel.objects.get(networkid='unknown', subnetworkid='unknown', vimid="vim_connection_id",
+                                              resourceid="resource_id", name="resource_id", instid="unknown",
+                                              cpinstanceid="cp_instance_id", bandwidth='unknown',
+                                              operationalstate='active', ipaddress="unkown", macaddress='unknown',
+                                              floatipaddress='unknown', serviceipaddress='unknown',
+                                              typevirtualnic='unknown', sfcencapsulation='gre', direction='unknown',
+                                              tenant="unkown")
+        self.assertIsInstance(port_inst, PortInstModel)
+        cp_inst = CPInstModel.objects.get(cpinstanceid="cp_instance_id", cpdid="cpd_id", ownertype=0,
+                                          ownerid=self.nf_inst_id, relatedtype=2, status='active')
+        self.assertIsInstance(cp_inst, CPInstModel)
+
+    def test_handle_vnf_identifier_creation_notification(self):
+        vnfm_id = "vnfm_id"
+        vnf_instance_id = "vnf_instance_id"
+        data = {
+            "timeStamp": "20190809",
+        }
+        HandleVnfIdentifierCreationNotification(vnfm_id, vnf_instance_id, data).do_biz()
+        nf_inst = NfInstModel.objects.get(mnfinstid=vnf_instance_id, vnfm_inst_id=vnfm_id, create_time="20190809")
+        self.assertIsInstance(nf_inst, NfInstModel)
+
+    def test_handle_vnf_identifier_deletion_notification(self):
+        nf_inst_id = "nf_inst_id"
+        vnfm_id = "vnfm_id"
+        vnf_instance_id = "vnf_instance_id"
+        NfInstModel.objects.create(nfinstid=nf_inst_id,
+                                   vnfm_inst_id=vnfm_id,
+                                   status=VNF_STATUS.NULL,
+                                   mnfinstid=vnf_instance_id,
+                                   vnfd_model=self.vnfd_model
+                                   )
+        data = {
+            "timeStamp": "20190809",
+        }
+        HandleVnfIdentifierDeletionNotification(vnfm_id, vnf_instance_id, data).do_biz()
+        nf_inst = NfInstModel.objects.filter(mnfinstid=vnf_instance_id, vnfm_inst_id=vnfm_id)
+        self.assertEqual(len(nf_inst), 0)
+
+    def test_handle_vnf_identifier_deletion_notification_when_nf_not_exists(self):
+        NfInstModel.objects.all().delete()
+        vnfm_id = "nf_not_exists"
+        vnf_instance_id = "nf_not_exists"
+        data = {
+            "timeStamp": "20190809",
+        }
+        try:
+            HandleVnfIdentifierDeletionNotification(vnfm_id, vnf_instance_id, data).do_biz()
+            self.assertEqual(1, 0)
+        except Exception:
+            self.assertEqual(1, 1)