modify

search/utils/topic.py

@@ -72,13 +72,13 @@ class TopicUtils(object):
             return False
 
     @classmethod
-    def ___get_should_term_list(cls,ori_list):
+    def ___get_should_term_list(cls,ori_list,field_name="tag_list"):
         try:
             should_term_list = list()
             for term_id in ori_list:
                 term_dict = {
                     "term":{
-                        "tag_list":{"value":term_id}
+                        field_name:{"value":term_id}
                     }
                 }
                 should_term_list.append(term_dict)
@@ -123,9 +123,9 @@ class TopicUtils(object):
 
                 user_tag_list = result_dict["hits"][0]["_source"]["tag_list"]
 
-                attention_user_id_term_list = cls.___get_should_term_list(attention_chinese_user_id_list + attention_japan_user_id_list + attention_korea_user_id_list)
-                pick_user_id_term_list = cls.___get_should_term_list(pick_chinese_user_id_list + pick_japan_user_id_list + pick_korea_user_id_list)
-                same_group_user_id_term_list = cls.___get_should_term_list(same_group_chinese_user_id_list + same_group_japan_user_id_list + same_group_korea_user_id_list)
+                attention_user_id_term_list = cls.___get_should_term_list(attention_chinese_user_id_list + attention_japan_user_id_list + attention_korea_user_id_list,field_name="user_id")
+                pick_user_id_term_list = cls.___get_should_term_list(pick_chinese_user_id_list + pick_japan_user_id_list + pick_korea_user_id_list,field_name="user_id")
+                same_group_user_id_term_list = cls.___get_should_term_list(same_group_chinese_user_id_list + same_group_japan_user_id_list + same_group_korea_user_id_list,field_name="user_id")
 
             q = dict()
             q["query"] = dict()

search/utils/user.py

@@ -4,6 +4,7 @@
 import logging
 import traceback
 import json
+import time
 from libs.es import ESPerform
 
 
@@ -83,6 +84,7 @@ class UserUtils(object):
                 {
                     "gauss": {
                         "latest_topic_time_val": {
+                            "origin": int(time.time()),
                             "scale": "600",
                             "decay": 0.1
                         }

search/views/user.py

@@ -15,7 +15,7 @@ from search.utils.common import *
 @bind("physical/search/recommend_user")
 def recommend_user(self_user_id,interesting_user_id,offset=0,size=10):
     """
-    :remark 点关注推荐用户,缺少按时间排序策略
+    :remark 点关注推荐用户
     :param self_user_id:
     :param interesting_user_id:
     :param offset: