diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 4e70f1f..4eb2559 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -1885,6 +1885,13 @@ async def add_interviewee( WHERE uid = '{data_in.uid}' """ # 添加面试官和hr并自动进入下一阶段 await ckdb.execute(sql) + # 同步发送邮件通知被安排了面试 + find_sql=f"""select job_names,name from HR.resumes where uid = '{data_in.uid}' limit 1""" + df= await ckdb.query_dataframe(find_sql) + send=f"""【面试通知】\n以下{df['job_names'][0]}岗位将于{data_in.star_time}进行面试\n面试者:{df['name'][0]}\nHR:{hr_name}\n面试官:{interview_name}""" + hr_user=data_in.hr_user + hr_user.extend(data_in.user_id) + send_dates(send,hr_user) return schemas.Msg(code=200, msg='ok', data='')