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

add apis to add as favourite

Browse Source
This commit is contained in:
Yasien Mac Mini
2025-04-17 12:41:01 +02:00
parent 44f7cd4255
commit 7739b63f36
1 changed files with 56 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
backend/routers/mzansi_wallet.py
View File

@@ -17,7 +17,13 @@ class MzansiWalletInsertRequest(BaseModel):
app_id: str app_id: str
shop_name: str shop_name: str
card_number: str card_number: str
favourite: str
priority_index: int
class MzansiWalletUpdateRequest(BaseModel):
idloyalty_cards: int
favourite: str
priority_index: int
# class patientNoteUpdateRequest(BaseModel): # class patientNoteUpdateRequest(BaseModel):
# idpatient_notes: int # idpatient_notes: int
# note_name: str # note_name: str
@@ -39,6 +45,30 @@ async def read_all_loyalty_cards_by_app_id(app_id: str, session: SessionContaine
"app_id": item[1], "app_id": item[1],
"shop_name": item[2], "shop_name": item[2],
"card_number": item[3], "card_number": item[3],
"favourite": item[4],
"priority_index": item[5],
}
for item in cursor.fetchall()
]
cursor.close()
db.close()
return items
# Get List of favourite loyalty cards by user
@router.get("/mzasni-wallet/loyalty-cards/favourites/{app_id}", tags=["Mzansi Wallet"])
async def read_favourite_loyalty_cards_by_app_id(app_id: str, session: SessionContainer = Depends(verify_session())): # , session: SessionContainer = Depends(verify_session())
db = database.dbConnection.dbMzansiWalletConnect()
cursor = db.cursor()
query = "SELECT * FROM loyalty_cards where app_id = %s and favourite != '' ORDER BY priority_index Asc"
cursor.execute(query, (app_id,))
items = [
{
"idloyalty_cards": item[0],
"app_id": item[1],
"shop_name": item[2],
"card_number": item[3],
"favourite": item[4],
"priority_index": item[5],
} }
for item in cursor.fetchall() for item in cursor.fetchall()
] ]
@@ -76,11 +106,13 @@ async def insert_loyalty_card(itemRequest : MzansiWalletInsertRequest): #, sessi
db = database.dbConnection.dbMzansiWalletConnect() db = database.dbConnection.dbMzansiWalletConnect()
cursor = db.cursor() cursor = db.cursor()
query = "insert into loyalty_cards " query = "insert into loyalty_cards "
query += "(app_id, shop_name, card_number) " query += "(app_id, shop_name, card_number, favourite, priority_index) "
query += "values (%s, %s, %s)" query += "values (%s, %s, %s, %s, %s)"
notetData = (itemRequest.app_id, notetData = (itemRequest.app_id,
itemRequest.shop_name, itemRequest.shop_name,
itemRequest.card_number, itemRequest.card_number,
itemRequest.favourite,
itemRequest.priority_index,
) )
try: try:
cursor.execute(query, notetData) cursor.execute(query, notetData)
@@ -113,26 +145,25 @@ async def Delete_loyalty_card(itemRequest : LoyaltyCardDeleteRequest, session: S
db.close() db.close()
return {"message": "Successfully deleted Record"} return {"message": "Successfully deleted Record"}
# Update Patient note on table # Update on table
# @router.put("/notes/update/", tags="patients_notes") @router.put("/mzasni-wallet/loyalty-cards/update/", tags=["Mzansi Wallet"])
# async def UpdatePatient(itemRequest : patientNoteUpdateRequest, session: SessionContainer = Depends(verify_session())): async def UpdatePatient(itemRequest : MzansiWalletUpdateRequest, session: SessionContainer = Depends(verify_session())):
# today = date.today() today = date.today()
# db = database.dbConnection.dbPatientManagerConnect() db = database.dbConnection.dbMzansiWalletConnect()
# cursor = db.cursor() cursor = db.cursor()
# query = "update patient_notes " query = "update loyalty_cards "
# query += "set note_name=%s, note_text=%s, patient_id=%s, insert_date=%s " query += "set favourite=%s, priority_index=%s "
# query += "where idpatient_notes=%s" query += "where idloyalty_cards=%s"
# notetData = (itemRequest.note_name, notetData = (itemRequest.favourite,
# itemRequest.note_text, itemRequest.priority_index,
# itemRequest.patient_id, itemRequest.idloyalty_cards,
# today, )
# itemRequest.idpatient_notes) try:
# try: cursor.execute(query, notetData)
# cursor.execute(query, notetData) except Exception as error:
# except Exception as error: raise HTTPException(status_code=404, detail="Failed to Update Record")
# raise HTTPException(status_code=404, detail="Failed to Update Record") #return {"query": query, "message": error}
# #return {"query": query, "message": error} db.commit()
# db.commit() cursor.close()
# cursor.close() db.close()
# db.close() return {"message": "Successfully Updated Record"}
# return {"message": "Successfully Updated Record"}