修改监控阈值

common/cutils.py

@@ -45,12 +45,19 @@ def mk_error_message(error_editor, error_answer, message_id, url=wechaturl):
     requests.post(url, json=data)
 
 
-def task_count(semantics_task_count, ideology_task_count, validate_logic_task_count, knowledge_task_count,dochub_task_count,dochub_file_process_over10minutes_count,
+def task_count(semantics_task_count, ideology_task_count, validate_logic_task_count, knowledge_task_count,dochub_task_count,dochub_file_process_over10minutes_count,english_precedent_task,
                url=wechaturl):
     data = {
         "msgtype": "markdown",
         "markdown": {
-            "content": f"审校任务排队情况<font color=\"warning\">异常</font>，请相关同事注意。\n>语义任务:<font color=\"comment\">{semantics_task_count}</font>\n内容风险任务:<font color=\"comment\">{ideology_task_count}</font>\n逻辑检查任务:<font color=\"comment\">{validate_logic_task_count}</font>\n知识性差错任务:<font color=\"comment\">{knowledge_task_count}</font>\n文档解析批注任务:<font color=\"comment\">{dochub_task_count}</font> \n文档解析超过10分钟的文件数:<font color=\"comment\">{dochub_file_process_over10minutes_count}</font> "
+            "content": f"审校任务排队情况<font color=\"warning\">异常</font>，请相关同事注意。"
+                       f"\n>语义任务:<font color=\"comment\">{semantics_task_count}</font>"
+                       f"\n内容风险任务:<font color=\"comment\">{ideology_task_count}</font>"
+                       f"\n逻辑检查任务:<font color=\"comment\">{validate_logic_task_count}</font>"
+                       f"\n知识性差错任务:<font color=\"comment\">{knowledge_task_count}</font>"
+                       f"\n文档解析批注任务:<font color=\"comment\">{dochub_task_count}</font>"
+                       f" \n文档解析超过10分钟的文件数:<font color=\"comment\">{dochub_file_process_over10minutes_count}</font> "
+                       f"\n>英语任务:<font color=\"comment\">{english_precedent_task}</font> "
         }
     }
     requests.post(url, json=data)
@@ -77,6 +84,9 @@ def aireview_task():
         "select count(*) from aireview.semantics_task where create_time >date(now()) and status = 0;")
     ideology_task_count = DButils_aireview().select_sql("select count(*) from aireview.ideology_task where "
                                                         "create_time >date(now()) and status = 0;")
+    # 英语任务
+    english_precedent_task = DButils_aireview().select_sql(
+        "select count(*)  from aireview.english_precedent_task ept  where create_time >CURDATE() and status =0;")
 
     validate_logic_task_count = DButils_aireview().select_sql(
         "select count(*) from  aireview.validate_logic_task  where create_time >date(now()) and status =0;")
@@ -86,6 +96,6 @@ def aireview_task():
         "select count(*) from document_record where status  in (0,1) and create_time >=CURDATE();")
     dochub_file_process_over10minutes_count = DButils_dochub().select_sql(
         "SELECT COUNT(*) FROM document_record WHERE status IN (1) AND create_time >= CURDATE() AND TIMESTAMPDIFF(MINUTE, create_time, update_time) > 30;")
-    if semantics_task_count[0][0] > 60000 or ideology_task_count[0][0] > 20000 or validate_logic_task_count[0][0]>20000 or knowledge_task_count[0][0]>20000 or dochub_task_count[0][0]>500 or dochub_file_process_over10minutes_count[0][0]>0:
-        task_count(semantics_task_count[0][0], ideology_task_count[0][0],validate_logic_task_count[0][0],knowledge_task_count[0][0], dochub_task_count[0][0], dochub_file_process_over10minutes_count[0][0], url=aireview_task_url)
+    if semantics_task_count[0][0] > 60000 or ideology_task_count[0][0] > 20000 or validate_logic_task_count[0][0]>20000 or knowledge_task_count[0][0]>20000 or dochub_task_count[0][0]>500 or dochub_file_process_over10minutes_count[0][0]>0 or english_precedent_task[0][0]>0:
+        task_count(semantics_task_count[0][0], ideology_task_count[0][0],validate_logic_task_count[0][0],knowledge_task_count[0][0], dochub_task_count[0][0], dochub_file_process_over10minutes_count[0][0], english_precedent_task[0][0], url=aireview_task_url)