Skip to content

W
wsmonitor_sql
Commit 2be2b126 by 宋鹏博
Options

添加@逻辑

parent ff00cfca
Showing with 62 additions and 31 deletions
common/cutils.py
...@@ -34,20 +34,23 @@ def error_message(text, url=wechaturl, mobile_list=16638842134): ...@@ -34,20 +34,23 @@ def error_message(text, url=wechaturl, mobile_list=16638842134):
# 发送mkdown格式微信消息 # 发送mkdown格式微信消息
def mk_error_message(error_editor, error_answer, message_id, url=wechaturl): def mk_error_message(error_editor, error_answer, message_id, url=wechaturl):
if error_editor == "AI审校团队" or error_editor == "AI预审编辑": data = {
data = { "msgtype": "markdown",
"msgtype": "markdown", "markdown": {
"markdown": { "content": f"ws推送<font color=\"warning\">异常</font>，请相关同事注意。\n>问题编辑:<font color=\"comment\">{error_editor}</font>\n>消息id:<font color=\"comment\">{message_id}</font>\n>返回消息:<font color=\"comment\">{error_answer}</font> "
"content": f"ws推送<font color=\"warning\">异常</font>，请相关同事注意。\n>问题编辑:<font color=\"comment\">{error_editor}@宋鹏博</font>\n>消息id:<font color=\"comment\">{message_id}</font>\n>返回消息:<font color=\"comment\">{error_answer}</font> "
}
} }
else: }
data = { requests.post(url, json=data)
"msgtype": "markdown",
"markdown": {
"content": f"ws推送<font color=\"warning\">异常</font>，请相关同事注意。\n>问题编辑:<font color=\"comment\">{error_editor}</font>\n>消息id:<font color=\"comment\">{message_id}</font>\n>返回消息:<font color=\"comment\">{error_answer}</font> " def mk_error_aireview_message(error_editor, error_answer, message_id, biz_id, url=wechaturl):
} data = {
"msgtype": "markdown",
"markdown": {
"content": f"ws推送<font color=\"warning\">异常</font>，请相关同事注意。\n>问题编辑:<font color=\"comment\">{error_editor}</font>\n>消息id:<font color=\"comment\">{message_id}</font>\n>返回消息:<font color=\"comment\">{error_answer}</font>\n>biz_id:<font color=\"comment\">{biz_id}</font> ",
"mentioned_mobile_list": ["16638842134", "@宋鹏博"]
} }
}
requests.post(url, json=data) requests.post(url, json=data)
...@@ -63,15 +66,33 @@ def ws_error(minute, error_answer_list=error_answer): ...@@ -63,15 +66,33 @@ def ws_error(minute, error_answer_list=error_answer):
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], n, data[i][2]) if editor[0][0] in ["AI审校团队", "AI预审编辑"]:
if "true" or "false" in data[0][1]:
dirt = data[0][1].replace("true", "True").replace("false", "False")
d = ast.literal_eval(dirt)
biz_id = d.get("msgContentList")[1].get("data").get("reviewReportRecordId")
mk_error_aireview_message(editor[0][0], n, data[i][2], biz_id)
else:
mk_error_message(editor[0][0], n, data[i][2])
print("结束") print("结束")
if __name__ == '__main__': if __name__ == '__main__':
error_answer_list = ["无法回答此类问题，请换个话题吧", "二维码创建失败", "意图下发失败", "文件处理失败", "生成失败",
"润色任务失败", "网络异常", "获取书评助理结果失败", "审校失败", "图书生成报告失败",
"对不起，我暂时无法回答这个问题"]
data = DButils().select_sql( data = DButils().select_sql(
f"select emp_id,content,id from aicaptain.message_record mr WHERE create_time > NOW() - INTERVAL 100 minute " f"select emp_id,content,id from aicaptain.message_record mr WHERE id=1900420961792245760 "
f"and id=1895017692240617472 limit 1; ") f"and msg_type != 1 ; ")
if "true" or "false" in data[0][1]: print(data)
dirt = data[0][1].replace("true", "True").replace("false", "False") for i in range(len(data)):
d = ast.literal_eval(dirt) for n in error_answer_list:
print(d.get("msgContentList")[1].get("data").get("reviewReportRecordId")) if n in data[i][1]:
editor = DButils().select_sql(
f"select name from aicaptain.job where id= (SELECT job_id FROM aicaptain.employee WHERE "
f" id= {data[i][0]} ); ")
if editor[0][0] == "AI审校团队" or editor[0][0] == "AI预审编辑":
if "true" or "false" in data[0][1]:
dirt = data[0][1].replace("true", "True").replace("false", "False")
d = ast.literal_eval(dirt)
biz_id = d.get("msgContentList")[1].get("data").get("reviewReportRecordId")
config.py
import os
# 测试环境数据库 # 测试环境数据库
# host = "122.112.227.235" host = "122.112.227.235"
# user = "userop" user = "userop"
# database_pwd = "0#ztXqUzECGen8E" database_pwd = "0#ztXqUzECGen8E"
# database = "aireview" database = "aireview"
# port = 3306 port = 3306
# 生产环境aireview数据库 # 生产环境aireview数据库
# host = "192.168.8.234" # host = "192.168.8.234"
# user = "aireview110" # user = "aireview110"
...@@ -11,15 +13,21 @@ ...@@ -11,15 +13,21 @@
# database = "aireview" # database = "aireview"
# port = 3306 # port = 3306
# 生产环境aicaption数据库 # 生产环境aicaption数据库
host = "192.168.8.234" # host = "192.168.8.234"
user = "aicaptain110" # user = "aicaptain110"
database_pwd = "ABs4B79c" # database_pwd = "ABs4B79c"
database = "aicaptain" # database = "aicaptain"
port = 3306 # port = 3306
# 微信机器人url # 微信机器人url
wechaturl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=5a4fa3ba-9974-44d3-9c1e-2428f77f8087" wechaturl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=5a4fa3ba-9974-44d3-9c1e-2428f77f8087"
# 问题词 # 问题词
error_answer = ["无法回答此类问题，请换个话题吧","二维码创建失败","意图下发失败","文件处理失败","生成失败","润色任务失败","网络异常","获取书评助理结果失败","审校失败","图书生成报告失败","对不起，我暂时无法回答这个问题"] error_answer = ["无法回答此类问题，请换个话题吧", "二维码创建失败", "意图下发失败", "文件处理失败", "生成失败",
"润色任务失败", "网络异常", "获取书评助理结果失败", "审校失败", "图书生成报告失败",
"对不起，我暂时无法回答这个问题"]
# 文件路径设置
file_path = os.path.dirname(__file__)
data/data.json 0 → 100644
"{\"empId\":16583,\"isChat\":0,\"messageMetaId\":4635342746807116,\"hasSend\":true,\"inquiryMsgMetaId\":4635342746807116,\"msgRemoteId\":\"4635342746807115\",\"msgContentList\":[{\"content\":\"\u4e2d\u6587\u811a\u672c.docx\u9884\u5ba1\u5df2\u5b8c\u6210\",\"notShow\":true,\"contentType\":\"Text\",\"classType\":\"TextMsgTypeDTO\"},{\"data\":{\"reportContent\":\"\u4e2d\u6587\u811a\u672c.docx\u751f\u6210\u5931\u8d25\\n\u9884\u5ba1\u5931\u8d25\",\"title\":\"\u4e2d\u6587\u811a\u672c\",\"reviewReportRecordId\":\"11727\",\"assistantCodes\":\"preliminarytrial\",\"status\":\"-2\"},\"dataCode\":\"YUSHEN\",\"contentType\":\"Data\",\"classType\":\"DataMsgTypeDTO\"}],\"messageRecordId\":1895017692240617472,\"hasPolish\":0,\"hasTask\":1,\"createTime\":1740642400215,\"costTime\":17306215,\"adviserId\":1002164,\"hasRegenerate\":0,\"abilityId\":105,\"contentType\":\"Json\"}"
\ No newline at end of file
start.py
from common.cutils import ws_error from common.cutils import ws_error
ws_error(10) ws_error(15)
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