diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index aedcc4c..59a4178 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -1964,6 +1964,26 @@ async def add_interviewee( hr_user = data_in.hr_user hr_user.extend(data_in.user_id) send_dates(send, hr_user) + find_sql = f""" + select uid,name,interview_name,hr_name,star_time,interview_sign,job_id,job_names,mail from HR.resumes where uid = '{data_in.uid}' + """ + df = await ckdb.query_dataframe(find_sql) + # 存份面试数据到mongodb + now_time = str(datetime.now()).split('.')[0] + await crud.interview_record.insert_record(db, schemas.interview_record(uid=df['uid'][0], # 唯一id + name=df['name'][0], # 求职者姓名 + interview_name=df['interview_name'][0], + # 面试官姓名 + hr_name=df['hr_name'][0], # hr姓名 + star_time=df['star_time'][0], # 开始面试时间 + interview_sign=0, # 签到状态 + job_id=df['job_id'][0], # 我们自己招聘的职位id + job_names=df['job_names'][0], # 我们自己招聘的职位名 + times=now_time, # 创建数据日期 + read_status=0, # 读取状态 + type='interview' # 记录的类型 + )) + return schemas.Msg(code=200, msg='ok', data='')