change test file

monitor.py

@@ -60,40 +60,40 @@ def write_redis(device_id,cid,card):
         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 = list(set([i[0] for i in result]))
-            if len(cids) != 0:
+    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 = list(set([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))
+                        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)
+        return "tractate good"
 
-                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))
-                    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)
-    #     return "tractate good"
-    #
-    # except Exception as e:
-    #     print("tractate insert redis fail")
-    #     print(e)
+    except Exception as e:
+        print("tractate insert redis fail")
+        print(e)
 
 def answer_write(device_id,cid):
     try:
@@ -221,6 +221,6 @@ def diary_write(device_id,cid):
 # ssc.awaitTermination()
 
 # print(tractate_write("hello","10078"))
-print(tractate_write("hello","37975"))
+print(tractate_write("hello",6))