Commit 93d172bd authored by 张彦钊's avatar 张彦钊

change test file

parent 1854ec70
...@@ -69,12 +69,11 @@ def write_redis(device_id,cid_list): ...@@ -69,12 +69,11 @@ def write_redis(device_id,cid_list):
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
tags = result[0][0] tags = result[0][0]
return tags if tags is not None:
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 = {} and c.tag_type = '3'".format(tags)
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
cids = list(set([i[0] for i in result])) cids = list(set([i[0] for i in result]))
...@@ -89,7 +88,7 @@ def write_redis(device_id,cid_list): ...@@ -89,7 +88,7 @@ def write_redis(device_id,cid_list):
r.set(key, json.dumps(cids)) r.set(key, json.dumps(cids))
else: else:
r.set(key, json.dumps(cids)) r.set(key, json.dumps(cids))
r.expire(key, 7*24*60*60) r.expire(key, 60*60)
except Exception as e: except Exception as e:
print("insert redis fail") print("insert redis fail")
......
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