change test file

monitor.py

@@ -60,45 +60,48 @@ def write_redis(device_id,cid,card):
         tractate_write(device_id, cid)
 
 
-
-
-def answer_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 c.id from src_mimas_prod_api_answer a left join src_mimas_prod_api_questiontag b " \
-              "on a.question_id = b.question_id left join src_zhengxing_api_tag c " \
-              "on b.tag_id = c.id where c.tag_type = '3' and a.id = {}".format(cid)
+        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_answer a left join src_mimas_prod_api_questiontag b " \
-                      "on a.question_id = b.question_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \
+                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 = [i[0] for i in result]
+                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_answer"
+                    key = str(device_id) + "_dislike_tractate"
                     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))
+                        value = ",".join([str(i) for i in set(value)])
+                        cids = json.dumps(value)
+                        r.set(key, cids)
+                        print("cunza")
+
                     else:
-                        r.set(key, json.dumps(cids))
-                        r.expire(key, 7*24*60*60)
+                        r.set(key, json.dumps(",".join(cids)))
+                        r.expire(key, 7 * 24 * 60 * 60)
 
 
     except Exception as e:
-        print("answer insert redis fail")
+        print("tractate insert redis fail")
         print(e)
 
 
+
+
 def question_write(device_id,cid):
     try:
         db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
@@ -189,20 +192,20 @@ def diary_write(device_id,cid):
 # ssc.awaitTermination()
 
 # print(tractate_write("hello","10078"))
-
-def tractate_write(device_id, cid):
+def answer_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)
+        sql = "select c.id from src_mimas_prod_api_answer a left join src_mimas_prod_api_questiontag b " \
+              "on a.question_id = b.question_id left join src_zhengxing_api_tag c " \
+              "on b.tag_id = c.id where c.tag_type = '3' and a.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 " \
+                sql = "select a.id from src_mimas_prod_api_answer a left join src_mimas_prod_api_questiontag b " \
+                      "on a.question_id = b.question_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()
@@ -211,7 +214,7 @@ def tractate_write(device_id, cid):
                 if len(cids) != 0:
 
                     r = redis.Redis(host="172.16.40.135", port=5379, password="")
-                    key = str(device_id) + "_dislike_tractate"
+                    key = str(device_id) + "_dislike_answer"
                     if r.exists(key):
                         value = eval(r.get(key)).split(",")
                         value.extend(cids)
@@ -226,8 +229,9 @@ def tractate_write(device_id, cid):
 
 
     except Exception as e:
-        print("tractate insert redis fail")
+        print("answer insert redis fail")
         print(e)
-print(tractate_write("hello",10078))
+
+print(anwer_write("hello",656482))