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

add date query to get appointments

Browse Source
This commit is contained in:
yaso
2024-11-08 11:46:20 +02:00
parent 21b2447dfe
commit 92ae951b0d
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
backend/routers/patients_queue.py
View File

@@ -3,7 +3,7 @@ from fastapi import APIRouter, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
#from ..database import dbConnection #from ..database import dbConnection
import database import database
from datetime import datetime, timedelta from datetime import datetime, timedelta, date
#SuperToken Auth from front end #SuperToken Auth from front end
from supertokens_python.recipe.session.framework.fastapi import verify_session from supertokens_python.recipe.session.framework.fastapi import verify_session
from supertokens_python.recipe.session import SessionContainer from supertokens_python.recipe.session import SessionContainer
@@ -30,8 +30,10 @@ class queueDeleteRequest(BaseModel):
# Get List of all files by patient # Get List of all files by patient
@router.get("/queue/appointments/business/{business_id}", tags=["Patients Queue"]) @router.get("/queue/appointments/business/{business_id}", tags=["Patients Queue"])
async def read_all_patient_queue_by_business_id(business_id: str, session: SessionContainer = Depends(verify_session())): #, session: SessionContainer = Depends(verify_session()) async def read_all_patient_queue_by_business_id(business_id: str, date: str, session: SessionContainer = Depends(verify_session())): #, session: SessionContainer = Depends(verify_session())
db = database.dbConnection.dbPatientManagerConnect() db = database.dbConnection.dbPatientManagerConnect()
requestDate = datetime.strptime(date, '%Y-%m-%d').date()
#print("request date: " + str(requestDate))
cursor = db.cursor() cursor = db.cursor()
query = "SELECT patient_queue.idpatient_queue, patient_queue.business_id, " query = "SELECT patient_queue.idpatient_queue, patient_queue.business_id, "
query += "patient_queue.app_id, patient_queue.date_time, " query += "patient_queue.app_id, patient_queue.date_time, "
@@ -39,7 +41,8 @@ async def read_all_patient_queue_by_business_id(business_id: str, session: Sessi
query += "from patient_manager.patient_queue " query += "from patient_manager.patient_queue "
query += "inner join patient_manager.patients " query += "inner join patient_manager.patients "
query += "on patient_queue.app_id = patients.app_id " query += "on patient_queue.app_id = patients.app_id "
query += "where business_id = %s ORDER BY date_time ASC" query = query + "where business_id = %s and date_time like '" + str(requestDate) + "%' "
query += "ORDER BY date_time ASC"
cursor.execute(query, (business_id,)) cursor.execute(query, (business_id,))
items = [ items = [
{ {
@@ -60,8 +63,9 @@ async def read_all_patient_queue_by_business_id(business_id: str, session: Sessi
# Get List of all files by patient # Get List of all files by patient
@router.get("/queue/appointments/personal/{app_id}", tags=["Patients Queue"]) @router.get("/queue/appointments/personal/{app_id}", tags=["Patients Queue"])
async def read_all_patient_queue_by_business_id(app_id: str, session: SessionContainer = Depends(verify_session())): #, session: SessionContainer = Depends(verify_session()) async def read_all_patient_queue_by_business_id(app_id: str, date: str, session: SessionContainer = Depends(verify_session())): #, session: SessionContainer = Depends(verify_session())
db = database.dbConnection.dbPatientManagerConnect() db = database.dbConnection.dbPatientManagerConnect()
requestDate = datetime.strptime(date, '%Y-%m-%d').date()
cursor = db.cursor() cursor = db.cursor()
query = "SELECT patient_queue.idpatient_queue, patient_queue.business_id, " query = "SELECT patient_queue.idpatient_queue, patient_queue.business_id, "
query += "patient_queue.app_id, patient_queue.date_time, " query += "patient_queue.app_id, patient_queue.date_time, "
@@ -69,7 +73,8 @@ async def read_all_patient_queue_by_business_id(app_id: str, session: SessionCon
query += "from patient_manager.patient_queue " query += "from patient_manager.patient_queue "
query += "inner join patient_manager.patients " query += "inner join patient_manager.patients "
query += "on patient_queue.app_id = patients.app_id " query += "on patient_queue.app_id = patients.app_id "
query += "where app_id = %s ORDER BY date_time ASC" query = query + "where app_id = %s and date_time like '" + str(requestDate) + "%' "
query += "ORDER BY date_time ASC"
cursor.execute(query, (app_id,)) cursor.execute(query, (app_id,))
items = [ items = [
{ {