diff --git a/App/Router/RatingFlowRouter.py b/App/Router/RatingFlowRouter.py index 64fd101..4369e1d 100644 --- a/App/Router/RatingFlowRouter.py +++ b/App/Router/RatingFlowRouter.py @@ -114,6 +114,18 @@ def func(schema: RatingFlowSchema.GetRatingFlowNodeContentReqBody, db: Session = return get_rating_node_data(_id=schema.node_id, db=db, mongodb=mongodb) +@router.get("/confirm", summary="结果确认", tags=["评级流程"]) +def func(rating_flow_id: str, operation: str, db: Session = Depends(get_db)): + # 获取流程; rf_item: 流程对象 + rf_item = Crud.get_rating_flow(db=db, rating_flow_id=rating_flow_id) + if not rf_item: + raise HTTPException(status_code=404, detail="RatingFlow Not Found") + if rf_item.status.value == '进行': + return Crud.edit_rating_status(db, rating_flow_id, status=operation) + else: + return {"info": "评级已确认无法执行操作"} + + @router.get("/import/input_data", summary="导入填报数据", tags=["评级节点"]) def func(rating_flow_id: str, year: int, db: Session = Depends(get_db)): # 获取流程; rf_item: 流程对象 @@ -509,13 +521,4 @@ def func(province: str, region: str, db: Session = Depends(get_db)): return {"外部支持级别": "AAA", "最终调整级别": None, "调整说明": None} -@router.get("/result/confirm", summary="结果确认", tags=["评级节点"]) -def func(rating_flow_id: str, operation: str, db: Session = Depends(get_db)): - # 获取流程; rf_item: 流程对象 - rf_item = Crud.get_rating_flow(db=db, rating_flow_id=rating_flow_id) - if not rf_item: - raise HTTPException(status_code=404, detail="RatingFlow Not Found") - if rf_item.status.value == '进行': - return Crud.edit_rating_status(db, rating_flow_id, status=operation) - else: - return {"info": "评级已确认无法执行操作"} +