1.优化面试阶段

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)

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):