diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 551c740..9b16f02 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -270,7 +270,7 @@ async def interview_update( data = await db.execute(sql) # except: # return schemas.Msg(code=-9, msg='数据有误', data=None) - interviews = interview.data.get('interview_stage', 0) # 简历阶段 + 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 @@ -1743,3 +1743,21 @@ async def send_interviewee( """ await ckdb.execute(sql) # 初次分配面试官 return schemas.Msg(code=200, msg='ok', data='') + + +@router.post("/add_interviewee") +async def add_interviewee( + request: Request, + data_in: schemas.add_inter, + ckdb: CKDrive = Depends(get_ck_db), + current_user: schemas.UserDB = Depends(deps.get_current_user) +) -> schemas.Msg: + name = await crud.user.get_users(data_in.user_id) + name_list=[i['name'] for i in name] + interview_name=','.join(name_list) + userid=','.join(data_in.user_id) + sql=f""" + ALTER TABLE HR.resumes update interview_name = '{interview_name}',interview_id = '{userid}' WHERE uid = '{data_in.uid}' + """ + await ckdb.execute(sql) + return schemas.Msg(code=200, msg='ok', data='') diff --git a/schemas/interview_plan.py b/schemas/interview_plan.py index 115eb86..2774463 100644 --- a/schemas/interview_plan.py +++ b/schemas/interview_plan.py @@ -144,3 +144,8 @@ class send_in(BaseModel): push: List[str] # 推送 content: str # 备注内容 bcc: List[str] # 抄送 + + +class add_inter(BaseModel): + uid: str # 求职者uid + user_id: List[str] # 面试官的钉钉id