This commit is contained in:
P3ngSaM 2023-08-04 11:05:26 +08:00
parent a992af35c0
commit 788c188e0b
1 changed files with 12 additions and 12 deletions

View File

@ -37,7 +37,7 @@ def del_files(paths):
# 传入指标总分得出对应级别 -> 接口返回打分结果
@router.post("upload_model_excel", summary="新模型Excel上传", tags=["模型管理"])
@router.post("/upload_model_excel", summary="新模型Excel上传", tags=["模型管理"])
async def func(model_name: str = '中小商业企业信用模型', file: UploadFile = File(...),
mongo_db: MongoHelper = Depends(get_mongodb)):
contents = await file.read()
@ -46,7 +46,7 @@ async def func(model_name: str = '中小商业企业信用模型', file: UploadF
return {"message": "文件上传成功", "file_id": str(file_id)}
@router.post("download_model_excel", summary="新模型Excel下载", tags=["模型管理"])
@router.post("/download_model_excel", summary="新模型Excel下载", tags=["模型管理"])
async def func(model_name: str = '中小商业企业信用模型', mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='模型数据', cd={"模型名称": model_name})
if not result:
@ -61,7 +61,7 @@ async def func(model_name: str = '中小商业企业信用模型', mongo_db: Mon
return FileResponse(path, filename=file_name, media_type='application/octet-stream', background=task)
@router.post("save_model_excel", summary="保存修改后的模型excel", tags=["模型管理"])
@router.post("/save_model_excel", summary="保存修改后的模型excel", tags=["模型管理"])
async def func(model_name: str = '中小商业企业信用模型', file: UploadFile = File(...),
mongo_db: MongoHelper = Depends(get_mongodb)):
# 根据模型名称查询该模型是否存在
@ -81,7 +81,7 @@ async def func(model_name: str = '中小商业企业信用模型', file: UploadF
return {"message": "文件更新成功", "file_id": str(result.get('模型ID'))}
@router.post("new_process_file", summary="新建流程文件", tags=["流程文件管理"])
@router.post("/new_process_file", summary="新建流程文件", tags=["流程文件管理"])
def func(company: str = '远东资信企业执信有限公司', model_name: str = '中小商业企业信用模型',
mongo_db: MongoHelper = Depends(get_mongodb)):
# 根据模型名称查询该模型是否存在
@ -97,7 +97,7 @@ def func(company: str = '远东资信企业执信有限公司', model_name: str
return {"message": "流程文件新建成功", "file_id": str(file_id)}
@router.post("delete_process_file", summary="删除流程文件", tags=["流程文件管理"])
@router.post("/delete_process_file", summary="删除流程文件", tags=["流程文件管理"])
def func(company: str = '远东资信企业执信有限公司', mongo_db: MongoHelper = Depends(get_mongodb)):
# 根据processid查询对应fid
result = mongo_db.search_data(db='中小商会企业信用评级', col='流程数据', cd={"企业名称": company})
@ -112,7 +112,7 @@ def func(company: str = '远东资信企业执信有限公司', mongo_db: MongoH
return {"message": "删除成功"}
@router.post("download_questionnaire", summary="下载模型问卷", tags=["问卷管理"])
@router.post("/download_questionnaire", summary="下载模型问卷", tags=["问卷管理"])
async def func(model_name: str = '中小商业企业信用模型', mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='模型数据', cd={"模型名称": model_name})
if not result:
@ -140,7 +140,7 @@ async def func(model_name: str = '中小商业企业信用模型', mongo_db: Mon
return FileResponse(path, filename=file_name, media_type='application/octet-stream', background=task)
@router.post("upload_questionnaire", summary="模型问卷上传", tags=["问卷管理"])
@router.post("/upload_questionnaire", summary="模型问卷上传", tags=["问卷管理"])
async def func(background_tasks: BackgroundTasks, company: str = '远东资信企业执信有限公司',
file: UploadFile = File(...),
mongo_db: MongoHelper = Depends(get_mongodb)):
@ -188,7 +188,7 @@ async def func(background_tasks: BackgroundTasks, company: str = '远东资信
return {"message": "上传成功"}
@router.post("download_reference_data", summary="获取背调数据表", tags=["问卷管理"])
@router.post("/download_reference_data", summary="获取背调数据表", tags=["问卷管理"])
async def func(background_tasks: BackgroundTasks, model_name: str = '中小商业企业信用模型',
mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='模型数据', cd={"模型名称": model_name})
@ -247,7 +247,7 @@ async def func(background_tasks: BackgroundTasks, model_name: str = '中小商
}
@router.post("upload_reference_data", summary="提交背调数据", tags=["问卷管理"])
@router.post("/upload_reference_data", summary="提交背调数据", tags=["问卷管理"])
async def func(background_tasks: BackgroundTasks, schemas: ModelSchemas.ReferencDataBody,
mongo_db: MongoHelper = Depends(get_mongodb)):
company = schemas.company
@ -297,7 +297,7 @@ async def func(background_tasks: BackgroundTasks, schemas: ModelSchemas.Referenc
return {"message": "上传成功"}
@router.post("questionnaire_data", summary="查看问卷数据", tags=["问卷管理"])
@router.post("/questionnaire_data", summary="查看问卷数据", tags=["问卷管理"])
async def func(company: str = '远东资信企业执信有限公司', mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='流程数据', cd={"企业名称": company})
if not result:
@ -363,7 +363,7 @@ async def func(company: str = '远东资信企业执信有限公司', mongo_db:
}
@router.post("reference_data", summary="查看背调数据", tags=["问卷管理"])
@router.post("/reference_data", summary="查看背调数据", tags=["问卷管理"])
async def func(company: str = '远东资信企业执信有限公司', mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='流程数据', cd={"企业名称": company})
if not result:
@ -383,7 +383,7 @@ async def func(company: str = '远东资信企业执信有限公司', mongo_db:
}
@router.post("score_result", summary="评级结果", tags=["评级结果"])
@router.post("/score_result", summary="评级结果", tags=["评级结果"])
async def func(background_tasks: BackgroundTasks, company: str = '远东资信企业执信有限公司',
mongo_db: MongoHelper = Depends(get_mongodb)):
result = mongo_db.search_data(db='中小商会企业信用评级', col='流程数据', cd={"企业名称": company})