store data and notify when refresh

src/smf_app/smf_app.cpp

@@ -82,7 +82,7 @@ extern smf_config smf_cfg;
 smf_n4* smf_n4_inst   = nullptr;
 smf_sbi* smf_sbi_inst = nullptr;
 extern itti_mw* itti_inst;
-
+static int nf_num = 0;
 void smf_app_task(void*);
 
 //------------------------------------------------------------------------------
@@ -1324,34 +1324,50 @@ bool smf_app::handle_nf_status_notification(
   json_data["time"] = buffer;
   my_json json_data_arr = nlohmann::json::array();
   json_data_arr.push_back(json_data);
-  nf_status_arr_len = nf_status_json_arr.dump().length();
-  for (int i = 0; i < nf_status_arr_len;i++)
+  int number=0;
+  for (int i = 0; i <= nf_num;i++)
   {
-    if(nf_status_arr_len==0)
+    if(nf_num == 0)
     {
+      nf_num++;
+      Logger::smf_app().error("nf_num_first %d",nf_num);
       nf_status_json_arr.push_back(json_data);
+      break;
     }
     else
     {
-      if(nf_status_json_arr[i]["nfType"].compare(json_data["nfType"].c_str())==0)
+      if(i == nf_num)break;
+      if(nf_status_json_arr[i]["nfType"].dump().compare(json_data["nfType"].dump().c_str())==0)
       {
-        nf_status_json_arr[i]["nfInstanceName"]=json_data["nfInstanceName"].c_str();
-        nf_status_json_arr[i]["nfEvent"]=json_data["nfEvent"].c_str();
-        nf_status_json_arr[i]["nfStatus"]=json_data["nfStatus"].c_str();
-        nf_status_json_arr[i]["nfInstanceId"]=json_data["nfInstanceId"].c_str();
-        nf_status_json_arr[i]["ipv4Addresses"]=json_data["ipv4Addresses"].c_str();
+	Logger::smf_app().error("the nftype is exist");
+        nf_status_json_arr[i]["nfInstanceName"]=json_data["nfInstanceName"].dump().c_str();
+        nf_status_json_arr[i]["nfEvent"]=json_data["nfEvent"].dump().c_str();
+        nf_status_json_arr[i]["nfStatus"]=json_data["nfStatus"].dump().c_str();
+        nf_status_json_arr[i]["nfInstanceId"]=json_data["nfInstanceId"].dump().c_str();
+        nf_status_json_arr[i]["ipv4Addresses"]=json_data["ipv4Addresses"].dump().c_str();
+	nf_status_json_arr[i]["time"]=json_data["time"].dump().c_str();
       }
       else
       {
-        nf_status_json_arr.push_back(json_data);
+	if(number == nf_num-1)
+	{
+	 nf_num=nf_num+1;
+         nf_status_json_arr.push_back(json_data);
+	}
+	number=number+1;
       }
     }
+    Logger::smf_app().error("nf_num %d",nf_num);
     Logger::smf_app().error(
         " nf_status_json_arr [%d] %s \n", i,
         nf_status_json_arr[i].dump().c_str());
   }
-  nf_status_json_arr.push_back(json_data);
+  Logger::smf_app().error("nf_num %d",nf_num);
+  //nf_status_json_arr.push_back(json_data);
   nf_status_arr_len = nf_status_json_arr.dump().length();
+  Logger::smf_app().error(
+		        "nf_status_json_data %s \n",nf_status_json_arr.dump().c_str());
+  memset(nf_status_arr,'\0',1000);
   memcpy(nf_status_arr,nf_status_json_arr.dump().c_str(),nf_status_arr_len);
   Logger::smf_app().error(
       "json_data %s \n",json_data_arr.dump().c_str());