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

报表

Browse Source
This commit is contained in:
Àî×ÚÕñ 2022-09-02 10:01:34 +08:00
parent 640a66688a
commit 383a2bd26b
1 changed files with 64 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -101,7 +101,7 @@ async def man_mass_form(
'其他': [], '其他': [],
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data=None) return schemas.Msg(code=200, msg='无数据', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -235,16 +235,16 @@ async def man_gander_form(
'女': [] '女': []
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -286,16 +286,16 @@ async def man_age_form(
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -343,16 +343,16 @@ async def man_education_form(
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -399,16 +399,16 @@ async def man_work_exp_form(
'20-40': [] '20-40': []
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -450,16 +450,16 @@ async def man_account_form(
account = { account = {
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -496,16 +496,16 @@ async def man_school_form(
school = { school = {
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -542,16 +542,16 @@ async def man_work_for_form(
work_for = { work_for = {
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -596,16 +596,16 @@ async def man_owner_name_form(
'58同城': [] '58同城': []
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -648,16 +648,16 @@ async def man_job_name_form(
job_name = { job_name = {
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -707,16 +707,16 @@ async def man_school_type_form(
'其他': [], '其他': [],
} }
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 处理数据 # 处理数据
for interview_data in data.values(): for interview_data in data.values():
@ -753,16 +753,16 @@ async def man_info_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
for key, interview_data in data.items(): for key, interview_data in data.items():
i_work_list = interview_data.get('work_list', '') i_work_list = interview_data.get('work_list', '')
@ -852,16 +852,16 @@ async def every_stage_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
for ck_data in data.values(): for ck_data in data.values():
# 职位id不存在跳过 # 职位id不存在跳过
@ -902,16 +902,16 @@ async def hr_works_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
res_msg = {} res_msg = {}
job_name_sector = {} job_name_sector = {}
@ -1052,16 +1052,16 @@ async def stage_success_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
for ck_data in data.values(): for ck_data in data.values():
# 职位id不存在跳过 # 职位id不存在跳过
@ -1138,16 +1138,16 @@ async def interview_funnel_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
res_msg = { res_msg = {
'初筛': 0, '初筛': 0,
@ -1194,16 +1194,16 @@ async def owner_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 简历渠道 # 简历渠道
owner_dict = {1: '前程无忧', 2: '人才库', 3: '智联招聘', 4: 'Boss直聘', 5: '58同城', 6: '拉勾'} owner_dict = {1: '前程无忧', 2: '人才库', 3: '智联招聘', 4: 'Boss直聘', 5: '58同城', 6: '拉勾'}
@ -1282,16 +1282,16 @@ async def owner_effect(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 简历渠道 # 简历渠道
owner_dict = {1: '前程无忧', 2: '人才库', 3: '智联招聘', 4: 'Boss直聘', 5: '58同城', 6: '拉勾'} owner_dict = {1: '前程无忧', 2: '人才库', 3: '智联招聘', 4: 'Boss直聘', 5: '58同城', 6: '拉勾'}
@ -1370,16 +1370,16 @@ async def interview_trend_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
sdate = res['sdate'] sdate = res['sdate']
edate = res['edate'] edate = res['edate']
@ -1425,16 +1425,16 @@ async def year_trend_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
sdate = res['sdate'] sdate = res['sdate']
edate = res['edate'] edate = res['edate']
@ -1502,16 +1502,16 @@ async def year_job_form(
sql = res['sql'] sql = res['sql']
data = await ck_db.execute(sql) data = await ck_db.execute(sql)
if not data: if not data:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
# 取出job和部门 # 取出job和部门
job_ids = set([j_data['job_id'] for j_data in data.values()]) job_ids = set([j_data['job_id'] for j_data in data.values()])
@ -1594,16 +1594,16 @@ async def year_in_out(
data_in = await ck_db.execute(sql_in) data_in = await ck_db.execute(sql_in)
data_out = await ck_db.execute(sql_out) data_out = await ck_db.execute(sql_out)
if not data_in and data_out: if not data_in and data_out:
return schemas.Msg(code=-9, msg='无数据', data={}) return schemas.Msg(code=200, msg='无数据', data={})
# 获取报表相关参数 # 获取报表相关参数
table_id = interview.data_in.get('table_id', '') table_id = interview.data_in.get('table_id', '')
if not table_id: if not table_id:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
table_data = await crud.api_interview_tables.get_one_table(db, table_id) table_data = await crud.api_interview_tables.get_one_table(db, table_id)
if not table_data: if not table_data:
return schemas.Msg(code=-9, msg='报表数据错误', data={}) return schemas.Msg(code=200, msg='报表数据错误', data={})
sdate = res['sdate'] sdate = res['sdate']
edate = res['edate'] edate = res['edate']