| | |
| | | from app.models.user import PageParameter |
| | | from app.models.user_model import UserModel |
| | | from app.service.group import create_group, group_list, edit_group_data, delete_group_data, get_group_users, \ |
| | | save_user_to_group |
| | | save_user_to_group, save_group_resource |
| | | |
| | | group_router = APIRouter() |
| | | |
| | |
| | | return Response(code=200, msg="success", data={}) |
| | | |
| | | |
| | | @group_router.post("/group_resource", response_model=Response) |
| | | @group_router.put("/group_resource", response_model=Response) |
| | | async def group_resource(group_resource: GroupResource, current_user: UserModel = Depends(get_current_user), |
| | | db=Depends(get_db)): |
| | | db_group = db.query(GroupModel).filter(GroupModel.id == group_resource.id).first() |
| | | if not db_group: |
| | | return Response(code=200, msg="group does not exist") |
| | | # is_success = await save_group_resource(db, current_user.id, group_resource.id, group_resource.agents, group_resource.dialogs, group_resource.knowledges) |
| | | # if not is_success: |
| | | # return Response(code=500, msg="save user to group failure", data={}) |
| | | is_success = await save_group_resource(db, current_user.id, group_resource.id, group_resource.agents, group_resource.dialogs, group_resource.knowledges) |
| | | if not is_success: |
| | | return Response(code=500, msg="save user to group failure", data={}) |
| | | return Response(code=200, msg="success", data={}) |