1.淘汰时发送通知给面试官

api/api_v1/endpoints/interview.py

@@ -270,6 +270,20 @@ async def interview_update(
     data = await db.execute(sql)
     # except:
     #     return schemas.Msg(code=-9, msg='数据有误', data=None)
+    if interview.data_in.get('interview_stage','') == 11: #淘汰的时候发送钉钉消息通知面试官该求职者被淘汰
+        interview_stage = interview_stage_dict[interview.data.get('interview_stage')]  # 映射简历阶段
+        if interview_stage > 2:
+            send_sql=f"""
+            select interview_id,name,job_names from HR.resumes where uid = '{interview.where.get('uid')}' limit 1
+            """
+            interview_id=await db.execute(send_sql)
+            userid_list=interview_id[0]['interview_id'].split(',')
+            why=pass_why_dict[interview.data_in.get('pass_why')]  # 映射淘汰原因
+            content=f"""
+            【淘汰通知】\n姓名：{interview_id[0]['name']}\n求职岗位：{interview_id[0]['job_names']}\n淘汰原因：{why}
+            \n具体淘汰原因：{interview.data_in.get('pass_text')}\n简历阶段：{interview_stage}\n操作人：{current_user.name}
+            """
+            send_dates(content,userid_list)
     return schemas.Msg(code=200, msg='ok', data=data)
 
 
@@ -745,7 +759,7 @@ async def find_criterion(
     # review,work_list,project_undergo,upgrade,come_time,now_money,work_in_time from HR.resumes WHERE uid = '{data_in.uid}'
     # """
     sql = f"""
-    select * from HR.resumes WHERE uid = '{data_in.uid}'
+    select * from HR.resumes WHERE uid = '{data_in.uid}' limit 1
     """
     df = await ckdb.query_dataframe(sql)
     data = {}

models/interview_zsgc.py

@@ -30,11 +30,13 @@ class InterviewDo:
         self.find_column = set()
         self.data_in = {}
         self.where = {}
+        self.data={}
 
     async def init(self, *args, **kwargs):
         self.find_column = self.query_in.find_column
         self.data_in = self.query_in.data_in
         self.where = self.query_in.interview_query
+        self.data=self.query_in.data
 
     def handler_filts(self, where):
         """

schemas/interview.py

@@ -22,3 +22,4 @@ class InterviewQuery(BaseModel):
     data_in: Any
     interview_query: dict = dict()  # 查询删选条件
     find_column: List[str] = None  # 显示列名
+    data:dict = dict()  # 不是必传的值