1.添加面试官

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='')

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