diff --git a/App/Router/RatingFlowRouter.py b/App/Router/RatingFlowRouter.py index f9a299b..fa2cfec 100644 --- a/App/Router/RatingFlowRouter.py +++ b/App/Router/RatingFlowRouter.py @@ -5,6 +5,7 @@ from fastapi import APIRouter, Depends, HTTPException, Header from sqlalchemy.orm import Session from App.Crud import RatingFlowCrud as Crud +from App.Crud.RatingFlowCrud import change_rating_status from App.Crud.RatingFlowNodeCrud import get_rating_node_data, delete_rating_node_data from App.Crud.RatingFlowParticipantCrud import list_users_rating_flows from App.Schemas import RatingFlowSchema @@ -78,6 +79,7 @@ def func(schema: RatingFlowSchema.SaveRatingFlowNodeReqBody, db: Session = Depen mongodb: MongoHelper = Depends(get_mongodb)): # 保存流程节点数据 rating_process_id = Crud.save_rating_flow_node(db=db, mongodb=mongodb, node_id=schema.node_id, data=schema.data) + change_rating_status(db=db, _id=schema.node_id, status=True) if not rating_process_id: raise HTTPException(status_code=400, detail="RatingFlowNode Not Found") @@ -141,6 +143,7 @@ def func(rating_flow_id: str, year: int, db: Session = Depends(get_db), mongodb: # 重置后续节点content数据 for node_id in nodes_item.values(): delete_rating_node_data(db=db, mongodb=mongodb, _id=node_id) + change_rating_status(db=db, _id=node_id, status=False) # 获取打分卡; scorecard: 打分卡 scorecard = request_to_get( @@ -207,6 +210,7 @@ def func(rating_flow_id: str, db: Session = Depends(get_db), mongodb: MongoHelpe # 重置后续节点content数据 for node_id in list(nodes_item.values())[1:]: delete_rating_node_data(db=db, mongodb=mongodb, _id=node_id) + change_rating_status(db=db, _id=node_id, status=False) # 获取填报数据; input_data: 填报数据对象 input_data = get_rating_node_data(db=db, mongodb=mongodb, _id=nodes_item.get("填报数据")) @@ -449,6 +453,8 @@ def func(rating_flow_id: str, db: Session = Depends(get_db), mongodb: MongoHelpe # 保存流程节点数据 Crud.save_rating_flow_node(db=db, mongodb=mongodb, node_id=nodes_item.get("基本信用状况"), data=bacp_body.copy()) + change_rating_status(db=db, _id=nodes_item.get("填报数据"), status=True) + return bacp_body @@ -467,6 +473,7 @@ def func(rating_flow_id: str, db: Session = Depends(get_db), mongodb: MongoHelpe # 重置后续节点content数据 for node_id in list(nodes_item.values())[2:]: delete_rating_node_data(db=db, mongodb=mongodb, _id=node_id) + change_rating_status(db=db, _id=node_id, status=False) # 获取打分卡; scorecard: 打分卡 scorecard = request_to_get( @@ -568,6 +575,7 @@ def func(rating_flow_id: str, db: Session = Depends(get_db), mongodb: MongoHelpe # 重置后续节点content数据 for node_id in list(nodes_item.values())[3:]: delete_rating_node_data(db=db, mongodb=mongodb, _id=node_id) + change_rating_status(db=db, _id=node_id, status=False) # 查询节点保存的数据 adjust_node = [node for node in rf_item.nodes if node.node_name == '个体信用状况']