yaso_meth/mih-project
2
4
Fork 2
Code Issues 8 Pull Requests Actions Packages Projects Releases 1 Wiki Activity

update get user review api

Browse Source
This commit is contained in:
Yasien Mac Mini
2025-07-18 15:02:54 +02:00
parent f23e8dccb3
commit 52bd3c34ae
1 changed files with 33 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
backend/routers/mzansi_directory.py
View File

@@ -8,9 +8,9 @@ from fastapi import Depends
router = APIRouter() router = APIRouter()
class BusinessRatingUserGet(BaseModel): # class BusinessRatingUserGet(BaseModel):
app_id: str # app_id: str
business_id: str # business_id: str
class BusinessRatingInsertRequest(BaseModel): class BusinessRatingInsertRequest(BaseModel):
app_id: str app_id: str
@@ -28,8 +28,8 @@ class BusinessRatingUpdateRequest(BaseModel):
rating_description: int rating_description: int
rating_score: str rating_score: str
@router.get("/mzasni-directory/business-ratings/user/", tags=["Mzansi Directory"]) @router.get("/mzasni-directory/business-ratings/user/{app_id}/{business_id}", tags=["Mzansi Directory"])
async def read_all_ratings_by_business_id(itemRequest: BusinessRatingUserGet, session: SessionContainer = Depends(verify_session())): # , session: SessionContainer = Depends(verify_session()) async def read_all_ratings_by_business_id(app_id: str,business_id: str, session: SessionContainer = Depends(verify_session())): # , session: SessionContainer = Depends(verify_session())
db = database.dbConnection.dbAllConnect() db = database.dbConnection.dbAllConnect()
cursor = db.cursor() cursor = db.cursor()
query = "" query = ""
@@ -40,10 +40,15 @@ async def read_all_ratings_by_business_id(itemRequest: BusinessRatingUserGet, se
query += "inner join app_data.users " query += "inner join app_data.users "
query += "on business_ratings.app_id = users.app_id " query += "on business_ratings.app_id = users.app_id "
query += "where business_ratings.business_id = %s and business_ratings.app_id = %s;" query += "where business_ratings.business_id = %s and business_ratings.app_id = %s;"
cursor.execute(query, (itemRequest.business_id, cursor.execute(query, (business_id,
itemRequest.app_id,)) app_id,))
items = [ item = cursor.fetchone() # Get only one row
{ cursor.close()
db.close()
if item:
# Return a single dictionary
return {
"idbusiness_ratings": item[0], "idbusiness_ratings": item[0],
"app_id": item[1], "app_id": item[1],
"business_id": item[2], "business_id": item[2],
@@ -53,11 +58,25 @@ async def read_all_ratings_by_business_id(itemRequest: BusinessRatingUserGet, se
"date_time": item[6], "date_time": item[6],
"reviewer": item[7], "reviewer": item[7],
} }
for item in cursor.fetchall() else:
] # Return an empty response or a specific message
cursor.close() return None
db.close() # items = [
return items # {
# "idbusiness_ratings": item[0],
# "app_id": item[1],
# "business_id": item[2],
# "rating_title": item[3],
# "rating_description": item[4],
# "rating_score": item[5],
# "date_time": item[6],
# "reviewer": item[7],
# }
# for item in cursor.fetchall()
# ]
# cursor.close()
# db.close()
# return items[0]
@router.get("/mzasni-directory/business-ratings/all/{business_id}", tags=["Mzansi Directory"]) @router.get("/mzasni-directory/business-ratings/all/{business_id}", tags=["Mzansi Directory"])
async def read_all_ratings_by_business_id(business_id: str, session: SessionContainer = Depends(verify_session())): # , session: SessionContainer = Depends(verify_session()) async def read_all_ratings_by_business_id(business_id: str, session: SessionContainer = Depends(verify_session())): # , session: SessionContainer = Depends(verify_session())