Merge branch 'pp' into 'main'

changes 结果确认接口

See merge request pengsen/rating_process!8

App/Crud/RatingFlowCrud.py

@@ -85,3 +85,10 @@ def save_rating_flow_node(node_id: str, data: dict, db: Session, mongodb: MongoH
 def get_rating_flow(db, rating_flow_id: str):
     item = db.query(RatingFlow).filter_by(id=rating_flow_id).first()
     return item
+
+
+def edit_rating_status(db, rating_flow_id, status):
+    data = {"status": status}
+    db.query(RatingFlow).filter_by(id=rating_flow_id).update(data)
+    db.commit()
+    return db.query(RatingFlow).filter_by(id=rating_flow_id).first()

App/Router/RatingFlowRouter.py

@@ -446,3 +446,16 @@ def func(rating_flow_id: str, db: Session = Depends(get_db)):
 @router.get("/import/external_support", summary="导入外部支持", tags=["评级节点"])
 def func(province: str, region: str, db: Session = Depends(get_db)):
     return {"result": "AAA"}
+
+
+@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": "评级已确认无法执行操作"}
+