api pagin, db _task_subquary, tasks depends
This commit is contained in:
@@ -31,12 +31,7 @@ class UsersRepo(BaseRepo):
|
||||
date_to: Optional[date] = None,
|
||||
date_from: Optional[date] = None,
|
||||
) -> UsersORM | None:
|
||||
tasks_subquery = select(TasksORM.id).where(TasksORM.user_id == user_id)
|
||||
if date_from is not None:
|
||||
tasks_subquery = tasks_subquery.where(TasksORM.due_date >= date_from)
|
||||
|
||||
if date_to is not None:
|
||||
tasks_subquery = tasks_subquery.where(TasksORM.due_date <= date_to)
|
||||
tasks_subquery = self._tasks_subquary(date_from=date_from, date_to=date_to, user_id=user_id)
|
||||
|
||||
if tasks_limit is not None:
|
||||
tasks_subquery = tasks_subquery.limit(tasks_limit)
|
||||
@@ -67,3 +62,11 @@ class UsersRepo(BaseRepo):
|
||||
def _priority(self, priority: str):
|
||||
priority_map = {"low": 1, "medium": 2, "high": 3, "critical": 4}
|
||||
return priority_map.get(priority, 0)
|
||||
|
||||
def _tasks_subquary(self, date_from: date | None, date_to: date | None, **filter_by):
|
||||
subq = select(TasksORM.id).filter_by(**filter_by)
|
||||
if date_from is not None:
|
||||
subq = subq.filter(TasksORM.due_date >= date_from)
|
||||
if date_to is not None:
|
||||
subq = subq.filter(TasksORM.due_date <= date_to)
|
||||
return subq
|
||||
|
||||
Reference in New Issue
Block a user