diff --git a/api/api_v1/endpoints/forms.py b/api/api_v1/endpoints/forms.py index 348afed..eecffe8 100644 --- a/api/api_v1/endpoints/forms.py +++ b/api/api_v1/endpoints/forms.py @@ -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()