diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 13c03d5..551c740 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -270,20 +270,19 @@ 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) + interviews = interview.data.get('interview_stage', 0) # 简历阶段 + if interview.data_in.get('interview_stage', '') == 11 and interviews > 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(',') + interview_stage = interview_stage_dict[interviews] # 映射简历阶段 + 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)