leguadmin/prs_server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

报表

Browse Source
This commit is contained in:
Àî×ÚÕñ 2022-08-31 16:38:23 +08:00
parent 1e43b15cfb
commit a1314b6657
1 changed files with 27 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
api/api_v1/endpoints/forms.py
View File

@ -6,6 +6,7 @@ from copy import deepcopy
from fastapi import APIRouter, Depends, Request, File, UploadFile
from motor.motor_asyncio import AsyncIOMotorDatabase
from api import deps
from utils.dingding import get_redis_alluid, send_dates
from utils.jianli import get_resume
from utils.func import get_every_days, get_every_weeks, get_every_months
@ -27,6 +28,7 @@ async def man_mass_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 候选人质量报表 """
await interview.init()
@ -219,6 +221,7 @@ async def man_info_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 候选人明细报表 """
await interview.init()
@ -236,7 +239,11 @@ async def man_info_form(
data[key]['work_for'] = i_work_for
continue
data[key]['work_for'] = ''
return schemas.Msg(code=200, msg='ok', data=data)
new_data = [v for k, v in data.items()]
res_msg = {
'info': new_data
}
return schemas.Msg(code=200, msg='ok', data=res_msg)
# 职位阶段数据报表
@ -245,7 +252,8 @@ async def every_stage_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db),
db: AsyncIOMotorDatabase = Depends(get_database)
db: AsyncIOMotorDatabase = Depends(get_database),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 职位阶段数据报表 """
all_jobs = await crud.jobs.all_some_field(db)
@ -300,7 +308,8 @@ async def hr_works_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db),
db: AsyncIOMotorDatabase = Depends(get_database)
db: AsyncIOMotorDatabase = Depends(get_database),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" hr工作量报表 """
await interview.init()
@ -415,7 +424,8 @@ async def stage_success_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db),
db: AsyncIOMotorDatabase = Depends(get_database)
db: AsyncIOMotorDatabase = Depends(get_database),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 职位阶段通过率报表 """
all_jobs = await crud.jobs.all_some_field(db)
@ -505,7 +515,8 @@ async def stage_success_form(
async def interview_funnel_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db)
ck_db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 招聘漏斗报表 """
await interview.init()
@ -546,6 +557,7 @@ async def owner_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 渠道质量报表 """
await interview.init()
@ -619,7 +631,8 @@ async def owner_effect(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db),
db: AsyncIOMotorDatabase = Depends(get_database)
db: AsyncIOMotorDatabase = Depends(get_database),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 渠道效果报表 """
await interview.init()
@ -691,7 +704,8 @@ async def owner_effect(
async def interview_trend_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db)
ck_db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 招聘趋势分析报表 """
await interview.init()
@ -731,7 +745,8 @@ async def interview_trend_form(
async def year_trend_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db)
ck_db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 招聘趋势分析报表 """
await interview.init()
@ -794,7 +809,8 @@ async def year_job_form(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db),
db: AsyncIOMotorDatabase = Depends(get_database)
db: AsyncIOMotorDatabase = Depends(get_database),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 岗位招聘数据分析报表 """
await interview.init()
@ -868,7 +884,8 @@ async def year_job_form(
async def year_in_out(
request: Request,
interview: InterviewDo = Depends(InterviewDo),
ck_db: CKDrive = Depends(get_ck_db)
ck_db: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user)
) -> schemas.Msg:
""" 年度入离职数据报表 """
await interview.init()