Commit e37df867 authored by 段英荣's avatar 段英荣

modify

parent f6979551
......@@ -22,6 +22,7 @@ def pick_celebrity(user_id,pick_id,offset=0,size=10):
if user_id != -1:
try:
offset = 0
redis_celebrity_info = redis_client.get(redis_key)
if redis_celebrity_info:
have_read_pick_celebrity_ids = json.loads(redis_celebrity_info)
......@@ -29,7 +30,7 @@ def pick_celebrity(user_id,pick_id,offset=0,size=10):
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
pass
recommend_pick_celebrity_list = PickUtils.get_recommend_celebrity_id_list(pick_id,have_read_pick_celebrity_ids,0,size)
recommend_pick_celebrity_list = PickUtils.get_recommend_celebrity_id_list(pick_id,have_read_pick_celebrity_ids,offset,size)
if len(recommend_pick_celebrity_list)>0 and user_id!=-1:
total_read_celebrity_ids = have_read_pick_celebrity_ids + recommend_pick_celebrity_list
......@@ -54,6 +55,7 @@ def pick_topic(user_id,pick_id,offset=0,size=10):
if user_id != -1:
try:
offset = 0
redis_celebrity_info = redis_client.get(redis_key)
if redis_celebrity_info:
have_read_pick_topic_ids = json.loads(redis_celebrity_info)
......@@ -105,7 +107,7 @@ def pick_topic(user_id,pick_id,offset=0,size=10):
q["_source"] = {
"include":["id"]
}
result_dict = ESPerform.get_search_results(ESPerform.get_cli(),sub_index_name="topic",query_body=q,offset=0,size=size)
result_dict = ESPerform.get_search_results(ESPerform.get_cli(),sub_index_name="topic",query_body=q,offset=offset,size=size)
recommend_pick_topic_list = []
if len(result_dict["hits"]) > 0:
......
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