Skip to content

F
ffm-baseline
Commit 61f9e37d authored by 张彦钊's avatar 张彦钊
Browse files
Options

change test file

parent 5a66517c
Hide whitespace changes
Inline Side-by-side
Showing with 60 additions and 57 deletions
monitor.py
View file @ 61f9e37d
...@@ -60,6 +60,8 @@ def write_redis(device_id,cid,card): ...@@ -60,6 +60,8 @@ def write_redis(device_id,cid,card):
tractate_write(device_id, cid) tractate_write(device_id, cid)
def answer_write(device_id,cid): def answer_write(device_id,cid):
try: try:
db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle') db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
...@@ -69,27 +71,28 @@ def answer_write(device_id,cid): ...@@ -69,27 +71,28 @@ def answer_write(device_id,cid):
cursor = db.cursor() cursor = db.cursor()
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
tags = result[0][0] if len(result) > 0:
if tags is not None: tags = result[0][0]
sql = "select a.id from src_mimas_prod_api_answer a left join src_mimas_prod_api_questiontag b " \ if tags is not None:
"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_answer a left join src_mimas_prod_api_questiontag b " \
"where a.is_online = 1 and c.id = {} and c.tag_type = '3'".format(tags) "on a.question_id = b.question_id left join src_zhengxing_api_tag c on b.tag_id=c.id " \
cursor.execute(sql) "where a.is_online = 1 and c.id = {} and c.tag_type = '3'".format(tags)
result = cursor.fetchall() cursor.execute(sql)
db.close() result = cursor.fetchall()
cids = list(set([i[0] for i in result])) db.close()
if len(cids) != 0: cids = [i[0] for i in result]
r = redis.Redis(host="172.16.40.135", port=5379, password="") if len(cids) != 0:
key = str(device_id) + "_dislike_answer" r = redis.Redis(host="172.16.40.135", port=5379, password="")
if r.exists(key): key = str(device_id) + "_dislike_answer"
value = json.loads(r.get(key)) if r.exists(key):
value.extend(cids) value = json.loads(r.get(key))
cids = json.dumps(list(set(value))) value.extend(cids)
r.set(key, json.dumps(cids)) cids = json.dumps(list(set(value)))
else: r.set(key, json.dumps(cids))
r.set(key, json.dumps(cids)) else:
r.expire(key, 7*24*60*60) r.set(key, json.dumps(cids))
return "answer good" r.expire(key, 7*24*60*60)
except Exception as e: except Exception as e:
print("answer insert redis fail") print("answer insert redis fail")
...@@ -186,44 +189,44 @@ def diary_write(device_id,cid): ...@@ -186,44 +189,44 @@ def diary_write(device_id,cid):
# ssc.awaitTermination() # ssc.awaitTermination()
# print(tractate_write("hello","10078")) # 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="") def tractate_write(device_id, cid):
key = str(device_id) + "_dislike_tractate" try:
if r.exists(key): db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
value = eval(r.get(key)).split(",") sql = "select b.id from src_mimas_prod_api_tractate_tag a left join src_zhengxing_api_tag b " \
value.extend(cids) "on a.tag_id = b.id where b.tag_type = '3' and a.tractate_id = {}".format(cid)
value = ",".join([str(i) for i in set(value)]) cursor = db.cursor()
cids = json.dumps(value) cursor.execute(sql)
r.set(key, cids) result = cursor.fetchall()
print("存在") if len(result) > 0:
else: tags = result[0][0]
r.set(key, json.dumps(",".join(cids))) if tags is not None:
r.expire(key, 7 * 24 * 60 * 60) sql = "select a.id from src_mimas_prod_api_tractate a left join src_mimas_prod_api_tractate_tag b " \
# return "tractate good" "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)
# except Exception as e: cursor.execute(sql)
# print("tractate insert redis fail") result = cursor.fetchall()
# print(e) 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 = eval(r.get(key)).split(",")
value.extend(cids)
value = ",".join([str(i) for i in set(value)])
print("cunzai")
r.set(key, value)
else:
r.set(key, ",".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)) print(tractate_write("hello",10078))
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