Commit 3b6dcb48 authored by 张彦钊's avatar 张彦钊

change test file

parent 2964ea04
...@@ -69,15 +69,17 @@ def write_redis(device_id,cid_list): ...@@ -69,15 +69,17 @@ def write_redis(device_id,cid_list):
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
tags = list(set([i[0] for i in result])) tags = list(set([i[0] for i in result]))
if tags is not None: return tags
if len(tags) != 0:
sql = "select a.id from src_mimas_prod_api_diary a left join src_mimas_prod_api_diary_tags b " \ sql = "select a.id from src_mimas_prod_api_diary a left join src_mimas_prod_api_diary_tags b " \
"on a.id=b.diary_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \ "on a.id=b.diary_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \
"where a.is_online = 1 and a.content_level >= '3' " \ "where a.is_online = 1 and a.content_level >= '3' " \
"and c.id in {} and c.tag_type = '3'".format(tuple(tags)) "and c.id in {} and c.tag_type = '3'".format(tuple(tags))
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
if result is not None:
cids = list(set([i[0] for i in result])) cids = list(set([i[0] for i in result]))
if len(cids) != 0:
r = redis.StrictRedis.from_url('redis://:ReDis!GmTx*0aN6@172.16.40.133:6379') r = redis.StrictRedis.from_url('redis://:ReDis!GmTx*0aN6@172.16.40.133:6379')
key = str(device_id) + "_dislike_diary" key = str(device_id) + "_dislike_diary"
if r.exists(key): if r.exists(key):
...@@ -88,7 +90,7 @@ def write_redis(device_id,cid_list): ...@@ -88,7 +90,7 @@ def write_redis(device_id,cid_list):
else: else:
r.set(key, json.dumps(cids)) r.set(key, json.dumps(cids))
r.expire(key, 7*24*60*60) r.expire(key, 7*24*60*60)
return "good"
except Exception as e: except Exception as e:
print("insert redis fail") print("insert redis fail")
print(e) print(e)
......
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