diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 44e395e..13c03d5 100644 --- a/api/api_v1/endpoints/interview.py +++ b/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 = {} diff --git a/models/interview_zsgc.py b/models/interview_zsgc.py index e9e07f2..422840f 100644 --- a/models/interview_zsgc.py +++ b/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): """ diff --git a/schemas/interview.py b/schemas/interview.py index 3f73d56..ac1fdde 100644 --- a/schemas/interview.py +++ b/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() # 不是必传的值