change test file

monitor.py

@@ -76,20 +76,21 @@ def write_redis(device_id,cid_list):
                   "and c.id = {} and c.tag_type = '3'".format(tags)
             cursor.execute(sql)
             result = cursor.fetchall()
-            return 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')
-            #     key = str(device_id) + "_dislike_diary"
-            #     if r.exists(key):
-            #         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, 60*60)
+            db.close()
+            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')
+                key = str(device_id) + "_dislike_diary"
+                if r.exists(key):
+                    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, 6)
+        return "good"
 
     except Exception as e:
         print("insert redis fail")