modify home_auery

search/utils/topic.py

@@ -122,7 +122,7 @@ class TopicUtils(object):
     @classmethod
     def get_recommend_topic_ids(cls,user_id,tag_id,offset,size,single_size,query=None,query_type=TopicPageType.FIND_PAGE,
                                 filter_topic_id_list=[],test_score=False,must_topic_id_list=[],recommend_tag_list=[],
-                                user_similar_score_list=[],index_type="topic",routing=None,attention_tag_list=[],linucb_user_id_list = []):
+                                user_similar_score_list=[],index_type="topic",routing=None,attention_tag_list=[],linucb_user_id_list = [],disable_collpase=False):
         """
         :remark:获取首页推荐帖子列表
         :param user_id:
@@ -300,9 +300,10 @@ class TopicUtils(object):
                         {"term": {"is_operation_home_recommend": True}}
                     ]
             q["query"]["function_score"] = query_function_score
-            q["collapse"] = {
-                "field": "user_id"
-            }
+            if not disable_collpase:
+                q["collapse"] = {
+                    "field": "user_id"
+                }
             # "includes": ["id", "pictorial_id", "offline_score", "user_id", "edit_tag_list"]
             q["_source"] = {
                 "includes": ["id"]

search/views/topic.py

@@ -46,7 +46,7 @@ def get_discover_page_topic_ids(user_id, device_id, size, query_type=TopicPageTy
 
 
 def get_home_recommend_topic_ids(user_id, device_id, tag_id, offset, size, query=None,
-                                 query_type=TopicPageType.HOME_RECOMMEND,promote_topic_list = []):
+                                 query_type=TopicPageType.HOME_RECOMMEND,promote_topic_list = [],disable_collpase=False):
     try:
         if query is None:
             if user_id>0:
@@ -122,7 +122,7 @@ def get_home_recommend_topic_ids(user_id, device_id, tag_id, offset, size, query
         rank_topic_id_list = TopicUtils.get_recommend_topic_ids(user_id=user_id, tag_id=tag_id, offset=0, size=size,
                                                            single_size=size,query=query, query_type=query_type,
                                                            filter_topic_id_list=have_read_topic_id_list,
-                                                           index_type="topic-high-star",routing="4,5,6",attention_tag_list=attention_tag_list,linucb_user_id_list=recommend_topic_user_list)
+                                                           index_type="topic-high-star",routing="4,5,6",attention_tag_list=attention_tag_list,linucb_user_id_list=recommend_topic_user_list,disable_collpase=disable_collpase)
 
         # if len(recommend_topic_list) == 6 and query is None:
         #     if (size < 11):
@@ -253,6 +253,10 @@ def home_query(device_id="", tag_id=-1, user_id=-1, query="", offset=0, size=10)
             device_id = ""
 
         recommend_topic_list, rank_topic_id_list = get_home_recommend_topic_ids(user_id, device_id, tag_id, offset=offset, size=size, query=query)
+        if len(rank_topic_id_list)>0 and len(rank_topic_id_list)<size:
+            recommend_topic_list, rank_topic_id_list = get_home_recommend_topic_ids(user_id, device_id, tag_id,
+                                                                                    offset=offset, size=size,
+                                                                                    query=query,disable_collpase=True)
         return {"recommend_topic_ids": rank_topic_id_list}
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())