feature/listEventDate #26
@ -6,12 +6,13 @@ from ..models import events, users
|
||||
from pydantic import EmailStr
|
||||
from typing import Annotated
|
||||
from bson import ObjectId
|
||||
from datetime import datetime
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@router.get("/events", tags=["events"], response_model=list[events.EventOut])
|
||||
async def read_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, id_event: str | None = None, name: str | None = None, status: int = 1, tags: str | None = None, organizers: str | None = None):
|
||||
async def read_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, id_event: str | None = None, name: str | None = None, status: int = 1, tags: str | None = None, organizers: str | None = None, current_datetime: datetime | None = None):
|
||||
if limit < 1 or skip < 0 or limit < skip:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_400_BAD_REQUEST,
|
||||
@ -23,16 +24,95 @@ async def read_events(authorize: Annotated[bool, Depends(permissions_checker.Per
|
||||
object_search = {}
|
||||
if status is not 1:
|
||||
object_search = {"status":{"$eq": status}}
|
||||
|
||||
if current_datetime is not None:
|
||||
object_search = { "$and": [ {"status":{"$eq": status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
] }
|
||||
if tags is not None:
|
||||
object_search = {"$and":[{"tags":{"$eq": tags}}, {"status":{"$eq":status}}]}
|
||||
if current_datetime is not None:
|
||||
object_search = {"$and":[{"tags":{"$eq": tags}},
|
||||
{"status":{"$eq":status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
if organizers is not None:
|
||||
object_search = {"$and":[{"organizers":{"$eq": organizers}}, {"status":{"$eq":status}}]}
|
||||
if current_datetime is not None:
|
||||
object_search = {"$and":[{"organizers":{"$eq": organizers}},
|
||||
{"status":{"$eq":status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]}
|
||||
if id_event is not None:
|
||||
eventid = ObjectId(id_event)
|
||||
object_search = {"$and":[{"id":{"$regex": eventid}}, {"status":{"$eq":status}}]}
|
||||
if current_datetime is not None:
|
||||
object_search = {"$and":[{"id":{"$regex": eventid}},
|
||||
{"status":{"$eq":status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]}
|
||||
if name is not None:
|
||||
object_search = {"$and":[{"name":{"$regex": name}}, {"status":{"$eq":status}}]}
|
||||
if current_datetime is not None:
|
||||
object_search = {"$and":[{"name":{"$regex": name}},
|
||||
{"status":{"$eq":status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]}
|
||||
|
||||
|
||||
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
||||
@ -42,7 +122,7 @@ async def read_events(authorize: Annotated[bool, Depends(permissions_checker.Per
|
||||
|
||||
|
||||
@router.get("/events/search", tags=["events"], response_model=list[events.EventOut])
|
||||
async def search_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, item: str | None = None, status: int = 1, min_lat: float | None = None, max_lat: float | None = None, min_lon: float | None = None, max_lon: float | None = None):
|
||||
async def search_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, item: str | None = None, status: int = 1, min_lat: float | None = None, max_lat: float | None = None, min_lon: float | None = None, max_lon: float | None = None, current_datetime: datetime | None = None):
|
||||
if limit < 1 or skip < 0 or limit < skip:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_400_BAD_REQUEST,
|
||||
@ -70,6 +150,37 @@ async def search_events(authorize: Annotated[bool, Depends(permissions_checker.P
|
||||
}
|
||||
]
|
||||
}
|
||||
if current_datetime is not None:
|
||||
object_search = {
|
||||
"$and": [
|
||||
{"status": {"$eq": status}},
|
||||
{
|
||||
"latitude": {"$gte": min_lat}, # Minimum latitude
|
||||
},
|
||||
{
|
||||
"latitude": {"$lte": max_lat}, # Maximum latitude
|
||||
},
|
||||
{
|
||||
"longitude": {"$gte": min_lon}, # Minimum longitude
|
||||
},
|
||||
{
|
||||
"longitude": {"$lte": max_lon}, # Maximum longitude
|
||||
},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
if item is not None:
|
||||
object_search = {
|
||||
"$and": [
|
||||
@ -83,6 +194,31 @@ async def search_events(authorize: Annotated[bool, Depends(permissions_checker.P
|
||||
{"status": {"$eq": status}}
|
||||
]
|
||||
}
|
||||
if current_datetime is not None:
|
||||
object_search = {
|
||||
"$and": [
|
||||
{
|
||||
"$or": [
|
||||
{"name": {"$regex": item}},
|
||||
{"tags": {"$regex": item}},
|
||||
{"organizers": {"$regex": item}}
|
||||
]
|
||||
},
|
||||
{"status": {"$eq": status}},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
if min_lat is not None and max_lat is not None and min_lon is not None and max_lon is not None:
|
||||
object_search = {
|
||||
"$and": [
|
||||
@ -108,6 +244,43 @@ async def search_events(authorize: Annotated[bool, Depends(permissions_checker.P
|
||||
}
|
||||
]
|
||||
}
|
||||
if current_datetime is not None:
|
||||
object_search = {
|
||||
"$and": [
|
||||
{
|
||||
"$or": [
|
||||
{"name": {"$regex": item}},
|
||||
{"tags": {"$regex": item}},
|
||||
{"organizers": {"$regex": item}}
|
||||
]
|
||||
},
|
||||
{"status": {"$eq": status}},
|
||||
{
|
||||
"latitude": {"$gte": min_lat}, # Minimum latitude
|
||||
},
|
||||
{
|
||||
"latitude": {"$lte": max_lat}, # Maximum latitude
|
||||
},
|
||||
{
|
||||
"longitude": {"$gte": min_lon}, # Minimum longitude
|
||||
},
|
||||
{
|
||||
"longitude": {"$lte": max_lon}, # Maximum longitude
|
||||
},
|
||||
{
|
||||
"$or": [
|
||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
||||
{"$and": [ # Ongoing events
|
||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
||||
{"$or": [
|
||||
{"end_date": {"$gte": current_datetime}}, # End date in the future
|
||||
{"end_date": None} # No end date set
|
||||
]}
|
||||
]}
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
||||
event = events.EventOut(id=event_index.id, tags=event_index.tags, imgUrl=event_index.imgUrl, name=event_index.name, description=event_index.description, place=event_index.place, status=event_index.status, start_date=event_index.start_date, end_date=event_index.end_date)
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user