Commit cb5b5624 authored by lixiaofang's avatar lixiaofang

add

parent cbdcc5e6
...@@ -63,20 +63,27 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0, ...@@ -63,20 +63,27 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0,
过滤近10天读过的数据 过滤近10天读过的数据
""" """
redis_key = "" redis_key = ""
have_read_pictorial_id_list = set() have_read_pictorial_id_list = list()
if device_id: if device_id:
redis_key = "physical:home_recommend_pictorial" + ":device_id:" + str(device_id) redis_key = "physical:home_recommend_pictorial" + ":device_id:" + str(device_id)
redis_question_val_list = redis_client.hgetall(redis_key) redis_question_val_list = redis_client.hgetall(redis_key)
logging.info("get redis_question_val_list:%s" % redis_question_val_list)
logging.info("get redis_question_val_list:%s" % type(redis_question_val_list))
for item in redis_question_val_list: for item in redis_question_val_list:
items = item.decode(encoding='utf-8') items = item.decode(encoding='utf-8')
logging.info("get items:%s" % items)
# 先删除10天前的 # 先删除10天前的
if items < str(yes_time): if items < str(yes_time):
redis_client.hdel(redis_key, item) redis_client.hdel(redis_key, item)
# 获取近10天的读过的榜单 # 获取近10天的读过的榜单
else: else:
value = redis_question_val_list.get(item, None).decode(encoding='utf-8') # value = redis_question_val_list.get(item, None).decode(encoding='utf-8')
value = json.loads(redis_question_val_list[item])
logging.info("get value:%s" % value)
if len(value):
for pictorial_id in value: for pictorial_id in value:
have_read_pictorial_id_list.add(pictorial_id) have_read_pictorial_id_list.append(pictorial_id)
logging.info("get have_read_tractate_id_list:%s" % have_read_pictorial_id_list) logging.info("get have_read_tractate_id_list:%s" % have_read_pictorial_id_list)
# 获取es链接对象 # 获取es链接对象
...@@ -99,7 +106,7 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0, ...@@ -99,7 +106,7 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0,
if redis_key: if redis_key:
for id in pictorial_ids_list: for id in pictorial_ids_list:
have_read_pictorial_id_list.append(id) have_read_pictorial_id_list.append(id)
redis_client.hset(redis_key, now, json.dumps(have_read_pictorial_id_list)) redis_client.hset(redis_key, now, json.dumps(list(have_read_pictorial_id_list)))
return {"pictorial_recommend_ids": pictorial_ids_list} return {"pictorial_recommend_ids": pictorial_ids_list}
...@@ -129,7 +136,7 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0, ...@@ -129,7 +136,7 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0,
if redis_key: if redis_key:
for id in pictorial_recommend_ids_list[offset:(offset + size)]: for id in pictorial_recommend_ids_list[offset:(offset + size)]:
have_read_pictorial_id_list.append(id) have_read_pictorial_id_list.append(id)
redis_client.hset(redis_key, now, json.dumps(have_read_pictorial_id_list)) redis_client.hset(redis_key, now, json.dumps(list(have_read_pictorial_id_list)))
return {"pictorial_recommend_ids": pictorial_recommend_ids_list[offset:(offset + size)]} return {"pictorial_recommend_ids": pictorial_recommend_ids_list[offset:(offset + size)]}
......
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