modify

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=[]):
+                                user_similar_score_list=[],index_type="topic"):
         """
         :需增加打散逻辑
         :remark:获取首页推荐帖子列表
@@ -321,7 +321,7 @@ class TopicUtils(object):
                 },
                 "_score"
             ]
-            result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="topic", query_body=q,
+            result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name=index_type, query_body=q,
                                                        offset=offset, size=size)
 
             topic_id_list = list()

search/views/topic.py

@@ -84,7 +84,7 @@ def get_home_recommend_topic_ids(user_id, device_id, tag_id, offset, size, query
                                                            single_size=size,query=query, query_type=query_type,
                                                            filter_topic_id_list=have_read_topic_id_list,
                                                            recommend_tag_list=recommend_tag_list,
-                                                           user_similar_score_list=user_similar_score_redis_list)
+                                                           user_similar_score_list=user_similar_score_redis_list,index_type="topic-high-star")
         have_read_group_id_set = set()
         have_read_user_id_set = set()
         unread_topic_id_dict = dict()