From 746f40fe2205171016a73a17aaf31216559fe5ed Mon Sep 17 00:00:00 2001 From: yaso-meth Date: Fri, 26 Jul 2024 15:03:17 +0200 Subject: [PATCH] update update and delete api to cater for app_id --- backend/routers/patients.py | 80 ++++++++++++++++++------------------- 1 file changed, 39 insertions(+), 41 deletions(-) diff --git a/backend/routers/patients.py b/backend/routers/patients.py index ade2c2bb..dc3edc10 100644 --- a/backend/routers/patients.py +++ b/backend/routers/patients.py @@ -41,7 +41,6 @@ class patientUpdateRequest(BaseModel): app_id: str class patientDeleteRequest(BaseModel): - id_no: str app_id: str # # Get Patient By ID Number @@ -244,50 +243,49 @@ async def insertPatient(itemRequest : patientInsertRequest, session: SessionCont db.close() return {"message": "Successfully Created Record"} -# # Update Patient on table -# @router.put("/patients/update/", tags="patients") -# async def UpdatePatient(itemRequest : patientUpdateRequest, session: SessionContainer = Depends(verify_session())): -# db = database.dbConnection.dbConnect() -# cursor = db.cursor() -# query = "update patients " -# query += "set id_no=%s, first_name=%s, last_name=%s, email=%s, cell_no=%s, medical_aid=%s, " -# query += "medical_aid_main_member=%s, medical_aid_no=%s, medical_aid_code=%s, medical_aid_name=%s, " -# query += "medical_aid_scheme=%s, address=%s, doc_office_id=%s " -# query += "where id_no=%s and doc_office_id=%s" -# patientData = (itemRequest.id_no, -# itemRequest.first_name, -# itemRequest.last_name, -# itemRequest.email, -# itemRequest.cell_no, -# itemRequest.medical_aid, -# itemRequest.medical_aid_main_member, -# itemRequest.medical_aid_no, -# itemRequest.medical_aid_code, -# itemRequest.medical_aid_name, -# itemRequest.medical_aid_scheme, -# itemRequest.address, -# itemRequest.doc_office_id, -# itemRequest.id_no, -# itemRequest.doc_office_id) -# try: -# cursor.execute(query, patientData) -# except Exception as error: -# raise HTTPException(status_code=404, detail="Failed to Update Record") -# #return {"query": query, "message": error} -# db.commit() -# cursor.close() -# db.close() -# return {"message": "Successfully Updated Record"} +# Update Patient on table +@router.put("/patients/update/", tags="patients") +async def UpdatePatient(itemRequest : patientUpdateRequest, session: SessionContainer = Depends(verify_session())): + db = database.dbConnection.dbConnect() + cursor = db.cursor() + query = "update patients " + query += "set id_no=%s, first_name=%s, last_name=%s, email=%s, cell_no=%s, medical_aid=%s, " + query += "medical_aid_main_member=%s, medical_aid_no=%s, medical_aid_code=%s, medical_aid_name=%s, " + query += "medical_aid_scheme=%s, address=%s, app_id=%s " + query += "where app_id=%s" + patientData = (itemRequest.id_no, + itemRequest.first_name, + itemRequest.last_name, + itemRequest.email, + itemRequest.cell_no, + itemRequest.medical_aid, + itemRequest.medical_aid_main_member, + itemRequest.medical_aid_no, + itemRequest.medical_aid_code, + itemRequest.medical_aid_name, + itemRequest.medical_aid_scheme, + itemRequest.address, + itemRequest.app_id, + itemRequest.app_id,) + try: + cursor.execute(query, patientData) + except Exception as error: + raise HTTPException(status_code=404, detail="Failed to Update Record") + #return {"query": query, "message": error} + db.commit() + cursor.close() + db.close() + return {"message": "Successfully Updated Record"} -# # delete Patient on table -# @router.delete("/patients/delete/", tags="patients") -# async def DeletePatient(itemRequest : patientDeleteRequest, session: SessionContainer = Depends(verify_session())): +# delete Patient on table +@router.delete("/patients/delete/", tags="patients") +async def DeletePatient(itemRequest : patientDeleteRequest, session: SessionContainer = Depends(verify_session())): db = database.dbConnection.dbConnect() cursor = db.cursor() query = "delete from patients " - query += "where id_no=%s and doc_office_id=%s" - patientData = (itemRequest.id_no, - itemRequest.doc_office_id) + query += "where app_id=%s" + patientData = (itemRequest.app_id, + ) try: cursor.execute(query, patientData) except Exception as error: