Commit d99c718e by 之约

修改查询sql

parent 8579ad88
...@@ -34,15 +34,12 @@ def ws_error(minute, error_answer_list=error_answer): ...@@ -34,15 +34,12 @@ def ws_error(minute, error_answer_list=error_answer):
print("开始") print("开始")
data = DButils().select_sql( data = DButils().select_sql(
f"select emp_id,content,id from aicaptain.message_record mr WHERE create_time > NOW() - INTERVAL {minute} minute " f"select emp_id,content,id from aicaptain.message_record mr WHERE create_time > NOW() - INTERVAL {minute} minute "
f"and msg_type != 1 and inquiry_msg_meta_id !=0; ") f"and msg_type != 1 ; ")
for i in range(len(data)): for i in range(len(data)):
for n in error_answer_list: for n in error_answer_list:
if n in data[i][1]: if n in data[i][1]:
json_data = json.loads(data[i][1])
content = json_data['msgContentList'][0]['content']
print(content)
editor = DButils().select_sql( editor = DButils().select_sql(
f"select name from aicaptain.job where id= (SELECT job_id FROM aicaptain.employee WHERE " f"select name from aicaptain.job where id= (SELECT job_id FROM aicaptain.employee WHERE "
f" id= {data[i][0]} ); ") f" id= {data[i][0]} ); ")
mk_error_message(editor[0][0], content, data[i][2]) mk_error_message(editor[0][0], n, data[i][2])
print("结束") print("结束")
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