From a24a694db908afab630ba2f72b3382dbb6204f87 Mon Sep 17 00:00:00 2001 From: Yasien Mac Mini Date: Fri, 4 Jul 2025 13:05:15 +0200 Subject: [PATCH] update api with new fields --- backend/routers/business.py | 73 ++++++++++++++++++++++++++++++++++--- 1 file changed, 68 insertions(+), 5 deletions(-) diff --git a/backend/routers/business.py b/backend/routers/business.py index 6bdcf54c..97057d88 100644 --- a/backend/routers/business.py +++ b/backend/routers/business.py @@ -27,6 +27,9 @@ class businessInsertRequest(BaseModel): gps_location: str practice_no: str vat_no: str + website: str + rating: str + mission_vision: str class businessUpdateRequest(BaseModel): business_id: str @@ -41,6 +44,22 @@ class businessUpdateRequest(BaseModel): practice_no: str vat_no: str +class businessUpdateRequestV2(BaseModel): + business_id: str + Name: str + type: str + registration_no: str + logo_name: str + logo_path: str + contact_no: str + bus_email: str + gps_location: str + practice_no: str + vat_no: str + website: str + rating: str + mission_vision: str + # Get List of all files @router.get("/business/business_id/{business_id}", tags=["MIH Business"]) @@ -51,6 +70,7 @@ async def read_business_by_business_id(business_id: str, session: SessionContain query += "business.logo_name, business.logo_path, business.contact_no, business.bus_email, " query += "business_users.app_id, business.gps_location, " query += "practice_no, vat_no " + query += "website, rating, mission_vision " query += "FROM business " query += "inner join business_users " query += "on business.business_id=business_users.business_id " @@ -73,6 +93,9 @@ async def read_business_by_business_id(business_id: str, session: SessionContain "gps_location": item[9], "practice_no": item[10], "vat_no": item[11], + "website": item[12], + "rating": item[13], + "mission_vision": item[14], } for item in cursor.fetchall() ] @@ -93,7 +116,8 @@ async def read_business_by_app_id(app_id: str, session: SessionContainer = Depen query = "SELECT business.business_id, business.Name, business.type, business.registration_no, " query += "business.logo_name, business.logo_path, business.contact_no, business.bus_email, " query += "business_users.app_id, business.gps_location, " - query += "practice_no, vat_no " + query += "practice_no, vat_no, " + query += "website, rating, mission_vision " query += "FROM business " query += "inner join business_users " query += "on business.business_id=business_users.business_id " @@ -116,6 +140,9 @@ async def read_business_by_app_id(app_id: str, session: SessionContainer = Depen "gps_location": item[9], "practice_no": item[10], "vat_no": item[11], + "website": item[12], + "rating": item[13], + "mission_vision": item[14], } for item in cursor.fetchall() ] @@ -132,8 +159,8 @@ async def insert_business_details(itemRequest : businessInsertRequest, session: db = database.dbConnection.dbAppDataConnect() cursor = db.cursor() query = "insert into business " - query += "(business_id, Name, type, registration_no, logo_name, logo_path, contact_no, bus_email, gps_location, practice_no, vat_no) " - query += "values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)" + query += "(business_id, Name, type, registration_no, logo_name, logo_path, contact_no, bus_email, gps_location, practice_no, vat_no, website, rating, mission_vision) " + query += "values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)" uuidString = str(uuid.uuid1()) userData = (uuidString, itemRequest.Name, @@ -145,9 +172,12 @@ async def insert_business_details(itemRequest : businessInsertRequest, session: itemRequest.bus_email, itemRequest.gps_location, itemRequest.practice_no, - itemRequest.vat_no) + itemRequest.vat_no, + itemRequest.website, + itemRequest.rating, + itemRequest.mission_vision, + ) try: - print(query) print(userData) cursor.execute(query, userData) @@ -187,4 +217,37 @@ async def Update_Business_details(itemRequest : businessUpdateRequest, session: db.commit() cursor.close() db.close() + return {"message": "Successfully Updated Record"} + +@router.put("/business/update/v2/", tags=["MIH Business"]) +async def Update_Business_details(itemRequest : businessUpdateRequestV2, session: SessionContainer = Depends(verify_session())): #, session: SessionContainer = Depends(verify_session()) + db = database.dbConnection.dbAppDataConnect() + # print(itemRequest.gps_location) + cursor = db.cursor() + query = "update business " + query += "set Name=%s, type=%s, registration_no=%s, logo_name=%s, logo_path=%s, contact_no=%s, bus_email=%s, gps_location=%s, practice_no=%s, vat_no=%s, website=%s, rating=%s, mission_vision=%s " + query += "where business_id=%s" + userData = (itemRequest.Name, + itemRequest.type, + itemRequest.registration_no, + itemRequest.logo_name, + itemRequest.logo_path, + itemRequest.contact_no, + itemRequest.bus_email, + itemRequest.gps_location, + itemRequest.practice_no, + itemRequest.vat_no, + itemRequest.website, + itemRequest.rating, + itemRequest.mission_vision, + itemRequest.business_id, + ) + try: + cursor.execute(query, userData) + except Exception as error: + raise HTTPException(status_code=404, detail=error) + #return {"query": query, "message": error} + db.commit() + cursor.close() + db.close() return {"message": "Successfully Updated Record"} \ No newline at end of file