Commit 998ba8e0 authored by lixiaofang's avatar lixiaofang

add

parents d7f0179c b60b9dc3
...@@ -266,7 +266,7 @@ class TopicUtils(object): ...@@ -266,7 +266,7 @@ class TopicUtils(object):
q["_source"] = { q["_source"] = {
"includes": ["id", "highlight", "description"] "includes": ["id", "highlight", "description"]
} }
topic_id_list = list()
if query is None: if query is None:
if user_id and user_id > 0: if user_id and user_id > 0:
redis_key_prefix = "physical:user_similar:participant_user_id:" redis_key_prefix = "physical:user_similar:participant_user_id:"
...@@ -450,9 +450,9 @@ class TopicUtils(object): ...@@ -450,9 +450,9 @@ class TopicUtils(object):
result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name=index_type, query_body=q, result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name=index_type, query_body=q,
offset=offset, size=size, routing=routing) offset=offset, size=size, routing=routing)
for item in result_dict["hits"]: for item in result_dict["hits"]:
topic_id_list.append({"id": item["_source"]["id"], "highlight": item["highlight"]}) topic_id_list.append({"id": item["_source"]["id"], "highlight": item["highlight"]})
return topic_id_list return topic_id_list
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
......
...@@ -183,11 +183,13 @@ def get_home_recommend_topic_ids(user_id, device_id, tag_id, offset, size, query ...@@ -183,11 +183,13 @@ def get_home_recommend_topic_ids(user_id, device_id, tag_id, offset, size, query
# topic_id_list.extend(recommend_topic_list[3:6]) # topic_id_list.extend(recommend_topic_list[3:6])
# else: # else:
# topic_id_list.extend(rank_topic_id_list) # topic_id_list.extend(rank_topic_id_list)
if query is None: if query is None:
have_read_topic_id_list.extend(item["id"] for item in rank_topic_id_list) have_read_topic_id_list.extend(rank_topic_id_list)
else: else:
have_read_topic_id_list.extend(rank_topic_id_list) have_read_topic_id_list.extend(item["id"] for item in rank_topic_id_list)
if len(have_read_topic_id_list) > 30000: if len(have_read_topic_id_list) > 30000:
cut_len = len(have_read_topic_id_list) - 30000 cut_len = len(have_read_topic_id_list) - 30000
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment