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