Commit 7493d3ee authored by 张彦钊's avatar 张彦钊

change test file

parent 52ddf961
......@@ -100,6 +100,45 @@ def tractate_write(device_id, cid):
print(e)
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 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_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()
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_answer"
if r.exists(key):
value = eval(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("cunza")
else:
r.set(key, json.dumps(",".join(cids)))
r.expire(key, 7 * 24 * 60 * 60)
except Exception as e:
print("answer insert redis fail")
print(e)
def question_write(device_id,cid):
......@@ -110,28 +149,32 @@ def question_write(device_id,cid):
cursor = db.cursor()
cursor.execute(sql)
result = cursor.fetchall()
tags = result[0][0]
if tags is not None:
sql = "select a.id from src_mimas_prod_api_question a left join src_mimas_prod_api_questiontag b " \
"on a.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()
db.close()
cids = list(set([i[0] for i in result]))
if len(cids) != 0:
if len(result) > 0:
tags = result[0][0]
if tags is not None:
sql = "select a.id from src_mimas_prod_api_question a left join src_mimas_prod_api_questiontag b " \
"on a.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()
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_question"
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 "question good"
r = redis.Redis(host="172.16.40.135", port=5379, password="")
key = str(device_id) + "_dislike_question"
if r.exists(key):
value = eval(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("cuznai")
else:
r.set(key, json.dumps(",".join(cids)))
r.expire(key, 7 * 24 * 60 * 60)
return "question good"
except Exception as e:
print("question insert redis fail")
......@@ -192,46 +235,9 @@ def diary_write(device_id,cid):
# ssc.awaitTermination()
# print(tractate_write("hello","10078"))
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 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_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()
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_answer"
if r.exists(key):
value = eval(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("cunza")
else:
r.set(key, json.dumps(",".join(cids)))
r.expire(key, 7 * 24 * 60 * 60)
except Exception as e:
print("answer insert redis fail")
print(e)
print(answer_write("hello","656482"))
print(question_write("hello",94638))
print(question_write("hello","94640"))
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