diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index 75130ce..fb1a3a3 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -1903,16 +1903,16 @@ async def send_interviewee( ckdb: CKDrive = Depends(get_ck_db), current_user: schemas.UserDB = Depends(deps.get_current_user) ) -> schemas.Msg: - """一键推送给用人部门""" - up_da = data_in.push - up_list = await crud.user.get_users(db, up_da) - up_da_str = ','.join(up_da) - interview_name = [i['name'] for i in up_list] # 分配的面试官的名字 - interview_str = ','.join(interview_name) + """推送给用人经理""" sql = f""" - ALTER TABLE HR.resumes update interview_name = '{interview_str}',interview_id = '{up_da_str}' WHERE uid = '{data_in.uid}' + select job_id,name,job_names from HR.resumes where uid = '{data_in.uid}' limit 1 """ - await ckdb.execute(sql) # 初次分配面试官 + res=await ckdb.execute(sql) + job_id=res[0]['job_id'] + user=await crud.jobs.find_job(db,job_id) + user_list=[i['user_id'] for i in user['hr_name']] + send=f"""【推荐通知】\n{current_user.name}给你推荐了一位面试者\n面试者姓名:{res[0]['name']}\岗位:{res[0]['job_names']}""" + send_dates(send, user_list) return schemas.Msg(code=200, msg='ok', data='') @@ -2072,3 +2072,22 @@ async def interview_stage_nu( res_data['offer'] = res[0]['value'] return schemas.Msg(code=200, msg='ok', data=res_data) + + +@router.post("/interview_finds") +async def interview_find( + request: Request, + interview: InterviewDo = Depends(InterviewDo), + db: CKDrive = Depends(get_ck_db), + current_user: schemas.UserDB = Depends(deps.get_current_user) +) -> schemas.Msg: + """ interview面试数据查询 """ + await interview.init() + res = interview.find_interview_sql() + sql = res['sql'] + data = await db.execute(sql) + if not data: + return schemas.Msg(code=200, msg='无数据', data=[]) + # 格式化数据 + res_data = len(data) + return schemas.Msg(code=200, msg='ok', data=res_data) diff --git a/schemas/interview_plan.py b/schemas/interview_plan.py index f8a0f74..4291186 100644 --- a/schemas/interview_plan.py +++ b/schemas/interview_plan.py @@ -141,9 +141,8 @@ class ExtendendOAuth(OAuth2PasswordRequestForm): class send_in(BaseModel): uid: str # 求职者uid - push: List[str] # 推送 - content: str # 备注内容 - bcc: List[str] # 抄送 + + class add_inter(BaseModel):