change test file

monitor.py

@@ -59,43 +59,6 @@ def write_redis(device_id,cid,card):
     elif card == "user_post":
         tractate_write(device_id, cid)
 
-def tractate_write(device_id,cid):
-    # try:
-    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
-    sql = "select b.id from src_mimas_prod_api_tractate_tag a left join src_zhengxing_api_tag b " \
-          "on a.tag_id = b.id where b.tag_type = '3' and a.tractate_id = {}".format(cid)
-    cursor = db.cursor()
-    cursor.execute(sql)
-    result = cursor.fetchall()
-    if len(result) > 0:
-        tags = result[0][0]
-        if tags is not None:
-            sql = "select a.id from src_mimas_prod_api_tractate a left join src_mimas_prod_api_tractate_tag b " \
-                  "on a.id=b.tractate_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \
-                  "where a.is_online = 1 and c.id = {} and c.tag_type = '3'".format(tags)
-            cursor.execute(sql)
-            result = cursor.fetchall()
-            db.close()
-            cids = [str(i[0]) for i in result]
-            if len(cids) != 0:
-
-                r = redis.Redis(host="172.16.40.135", port=5379, password="")
-                key = str(device_id) + "_dislike_tractate"
-                if r.exists(key):
-                    value = json.loads(r.get(key)).split(",")
-                    value.extend(cids)
-                    value = ",".join([str(i) for i in set(value)])
-                    cids = json.dumps(value)
-                    r.set(key, cids)
-                    print("存在")
-                else:
-                    r.set(key,json.dumps(",".join(cids)))
-                    r.expire(key, 7*24*60*60)
-    #     return "tractate good"
-    #
-    # except Exception as e:
-    #     print("tractate insert redis fail")
-    #     print(e)
 
 def answer_write(device_id,cid):
     try:
@@ -192,7 +155,7 @@ def diary_write(device_id,cid):
                 r = redis.Redis(host="172.16.40.135", port=5379, password="")
                 key = str(device_id) + "_dislike_diary"
                 if r.exists(key):
-                    value = json.loads(r.get(key))
+                    value = eval(r.get(key)).split(",")
                     value.extend(cids)
                     cids = json.dumps(list(set(value)))
                     r.set(key, json.dumps(cids))
@@ -223,6 +186,44 @@ def diary_write(device_id,cid):
 # ssc.awaitTermination()
 
 # print(tractate_write("hello","10078"))
+def tractate_write(device_id,cid):
+    # try:
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
+    sql = "select b.id from src_mimas_prod_api_tractate_tag a left join src_zhengxing_api_tag b " \
+          "on a.tag_id = b.id where b.tag_type = '3' and a.tractate_id = {}".format(cid)
+    cursor = db.cursor()
+    cursor.execute(sql)
+    result = cursor.fetchall()
+    if len(result) > 0:
+        tags = result[0][0]
+        if tags is not None:
+            sql = "select a.id from src_mimas_prod_api_tractate a left join src_mimas_prod_api_tractate_tag b " \
+                  "on a.id=b.tractate_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \
+                  "where a.is_online = 1 and c.id = {} and c.tag_type = '3'".format(tags)
+            cursor.execute(sql)
+            result = cursor.fetchall()
+            db.close()
+            cids = [str(i[0]) for i in result]
+            if len(cids) != 0:
+
+                r = redis.Redis(host="172.16.40.135", port=5379, password="")
+                key = str(device_id) + "_dislike_tractate"
+                if r.exists(key):
+                    value = r.get(key).split(b",")
+                    value.extend(cids)
+                    value = ",".join([str(i) for i in set(value)])
+                    cids = json.dumps(value)
+                    r.set(key, cids)
+                    print("存在")
+                else:
+                    r.set(key,json.dumps(",".join(cids)))
+                    r.expire(key, 7*24*60*60)
+    #     return "tractate good"
+    #
+    # except Exception as e:
+    #     print("tractate insert redis fail")
+    #     print(e)
+
 print(tractate_write("hello","10078"))