changes

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 == '个体信用状况']