From c163d02176de7d62ad4e9c87e9ee3e370ecb2841 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E4=BC=9F?= <250213850@qq.com>
Date: Wed, 20 Jul 2022 11:44:52 +0800
Subject: [PATCH] =?UTF-8?q?1.=E4=BC=98=E5=8C=96=E8=81=8C=E4=BD=8D=E6=98=BE?=
 =?UTF-8?q?=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 api/api_v1/endpoints/interview.py | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py
index af1e539..4ba4127 100644
--- a/api/api_v1/endpoints/interview.py
+++ b/api/api_v1/endpoints/interview.py
@@ -278,23 +278,30 @@ async def interview_insert(
 async def event_edit(
         request: Request,
         data_in: schemas.Jobs = None,
-        db: AsyncIOMotorDatabase = Depends(get_database)
+        db: AsyncIOMotorDatabase = Depends(get_database),
+        ckdb: CKDrive = Depends(get_ck_db)
 ) -> schemas.Msg:
     """获取职位名称"""
     # 获取对应条件的职位
     res = await crud.jobs.all_fields(db, data_in)
     # 获取职位数量
     num = len(res)
-
     job = []
     for i in res:
         # 获取职位名称
         job_list = []
         job_list.append(i['job_id'])
+        # 查询对应职位id入职多少人
+        sql = f"""
+        select count(job_id) from HR.resumes where job_id = '{i['job_id']}' and interview_stage = 7
+        """
+        num=await ckdb.execute(sql)
+
         job_list.append(i['job_name'])
         job_list.append(i['job_sector'])
         job_list.append(i['principal'])
         job_list.append(i['owner_name'])
+        job_list.append(num)
         job_list.append(i['job_num'])
         job.append(job_list)
     data = {