update rank

rank_service.py

@@ -80,47 +80,34 @@ def get_featurs(data, size, top_K, flow_pool_P, env_dict=None):
                 vid = vidKeys[i].replace(pre_str,"")
                 if video_static_info[i] :
                     per_video_staic = json.loads(video_static_info[i])
-                    if vid in feature_dict:
-                        vid_fea_info = feature_dict[vid]
-                        day_rov_list.append(per_video_staic[0])
-                        day_share_return_score_list.append(per_video_staic[1])
-                        day_share_score_list.append(per_video_staic[2])
-                        day_return_rate_list.append(per_video_staic[3])
-                        day_ctr_score_list.append(per_video_staic[4])
-                        day_view_users_list.append(per_video_staic[5])
-                        day_view_pv_list.append(per_video_staic[6])
-                        day_play_users_list.append(per_video_staic[7])
-                        day_play_pv_list.append(per_video_staic[8])
-                        day_share_users.append(per_video_staic[9])
-                        day_share_pv_list.append(per_video_staic[10])
-                        day_return_users_list.append(per_video_staic[11])
+                    day_rov_list.append(per_video_staic[0])
+                    day_share_return_score_list.append(per_video_staic[1])
+                    day_share_score_list.append(per_video_staic[2])
+                    day_return_rate_list.append(per_video_staic[3])
+                    day_ctr_score_list.append(per_video_staic[4])
+                    day_view_users_list.append(per_video_staic[5])
+                    day_view_pv_list.append(per_video_staic[6])
+                    day_play_users_list.append(per_video_staic[7])
+                    day_play_pv_list.append(per_video_staic[8])
+                    day_share_users.append(per_video_staic[9])
+                    day_share_pv_list.append(per_video_staic[10])
+                    day_return_users_list.append(per_video_staic[11])
+                else:
+                    insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_users_list,
+                                              day_return_rate_list, day_return_users_list, day_rov_list,
+                                              day_share_pv_list, day_share_return_score_list, day_share_score_list,
+                                              day_share_users, day_view_pv_list, day_view_users_list)
             except Exception:
-                day_rov_list.append(0.0)
-                day_share_return_score_list.append(0.0)
-                day_share_score_list.append(0.0)
-                day_return_rate_list.append(0.0)
-                day_ctr_score_list.append(0.0)
-                day_view_users_list.append(0)
-                day_view_pv_list.append(0)
-                day_play_users_list.append(0)
-                day_play_pv_list.append(0)
-                day_share_users.append(0)
-                day_share_pv_list.append(0)
-                day_return_users_list.append(0)
+                insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_users_list,
+                                          day_return_rate_list, day_return_users_list, day_rov_list,
+                                          day_share_pv_list, day_share_return_score_list, day_share_score_list,
+                                          day_share_users, day_view_pv_list, day_view_users_list)
     else:
         for i in range(len(recall_list)):
-            day_rov_list.append(0.0)
-            day_share_return_score_list.append(0.0)
-            day_share_score_list.append(0.0)
-            day_return_rate_list.append(0.0)
-            day_ctr_score_list.append(0.0)
-            day_view_users_list.append(0)
-            day_view_pv_list.append(0)
-            day_play_users_list.append(0)
-            day_play_pv_list.append(0)
-            day_share_users.append(0)
-            day_share_pv_list.append(0)
-            day_return_users_list.append(0)
+            insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_users_list,
+                                      day_return_rate_list, day_return_users_list, day_rov_list,
+                                      day_share_pv_list, day_share_return_score_list, day_share_score_list,
+                                      day_share_users, day_view_pv_list, day_view_users_list)
     feature_dict["mid_list"] = mid_list
     feature_dict["videoid_list"] = videoid_list
     feature_dict["apptype_list"]  = apptype_list
@@ -147,6 +134,24 @@ def get_featurs(data, size, top_K, flow_pool_P, env_dict=None):
     feature_dict["day_share_users_list"] = day_share_users
     return feature_dict, recall_list
 
+
+def insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_users_list, day_return_rate_list,
+                              day_return_users_list, day_rov_list, day_share_pv_list, day_share_return_score_list,
+                              day_share_score_list, day_share_users, day_view_pv_list, day_view_users_list):
+    day_rov_list.append(0.0)
+    day_share_return_score_list.append(0.0)
+    day_share_score_list.append(0.0)
+    day_return_rate_list.append(0.0)
+    day_ctr_score_list.append(0.0)
+    day_view_users_list.append(0)
+    day_view_pv_list.append(0)
+    day_play_users_list.append(0)
+    day_play_pv_list.append(0)
+    day_share_users.append(0)
+    day_share_pv_list.append(0)
+    day_return_users_list.append(0)
+
+
 def get_tf_serving_sores(feature_dict):
     #for k, v in feature_dict:
     inputs_data = {