Commit a8fb75cb authored by 张彦钊's avatar 张彦钊

change test file

parent 7311c602
...@@ -78,14 +78,18 @@ def write_redis(device_id,cid_list): ...@@ -78,14 +78,18 @@ def write_redis(device_id,cid_list):
"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()
cids = list(set([i[0] for i in result])) if result is not None:
r = redis.StrictRedis.from_url('redis://:ReDis!GmTx*0aN6@172.16.40.133:6379') cids = list(set([i[0] for i in result]))
key = str(device_id) + "_dislike" r = redis.StrictRedis.from_url('redis://:ReDis!GmTx*0aN6@172.16.40.133:6379')
if r.exists(key): key = str(device_id) + "_dislike"
cids = json.dumps(list(set(eval(r.get(key)).extend(cids)))) if r.exists(key):
r.set(key, json.dumps(cids)) value = eval(r.get(key))
value.extend(cids)
cids = json.dumps(list(set(value)))
r.set(key, json.dumps(cids))
else:
r.set(key, json.dumps(cids))
r.expire(key, 7*24*60*60)
except Exception as e: except Exception as e:
print("insert redis fail") print("insert redis fail")
print(e) print(e)
......
...@@ -60,7 +60,7 @@ def write_redis(device_id,cid_list): ...@@ -60,7 +60,7 @@ def write_redis(device_id,cid_list):
if result is not None: if result is not None:
cids = list(set([i[0] for i in result])) cids = list(set([i[0] for i in result]))
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" key = str(device_id) + "_dislike_diary"
if r.exists(key): if r.exists(key):
value = eval(r.get(key)) value = eval(r.get(key))
value.extend(cids) value.extend(cids)
......
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