StageAndSuitcase/stage-and-suitcase-mih
1
0
Fork 0
forked from yaso_meth/mih-project
Code Pull Requests Activity

update update and delete api to cater for app_id

Browse Source
This commit is contained in:
yaso-meth
2024-07-26 15:03:17 +02:00
parent 3973ba28c2
commit 746f40fe22
1 changed files with 39 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
backend/routers/patients.py
View File

@@ -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: