mirror of
https://github.com/HamzaSha1/zod-backend.git
synced 2025-07-15 10:05:21 +00:00
99 lines
4.3 KiB
Python
99 lines
4.3 KiB
Python
"""
|
|
web_admin analytics view file
|
|
"""
|
|
import datetime
|
|
|
|
from rest_framework.viewsets import GenericViewSet
|
|
from rest_framework.decorators import action
|
|
from django.contrib.auth import get_user_model
|
|
from django.db.models import Q
|
|
from django.db.models import Count
|
|
from django.db.models.functions import TruncDate
|
|
|
|
from account.utils import custom_response
|
|
from base.constants import PENDING, IN_PROGRESS, REJECTED, REQUESTED, COMPLETED, EXPIRED
|
|
from guardian.models import JuniorTask
|
|
|
|
USER = get_user_model()
|
|
|
|
|
|
class AnalyticsViewSet(GenericViewSet):
|
|
"""
|
|
analytics api view
|
|
"""
|
|
serializer_class = None
|
|
|
|
def get_queryset(self):
|
|
user_qs = USER.objects.filter(
|
|
(Q(junior_profile__is_verified=True) | Q(guardian_profile__is_verified=True)),
|
|
is_superuser=False
|
|
).prefetch_related('guardian_profile',
|
|
'junior_profile'
|
|
).exclude(junior_profile__isnull=True,
|
|
guardian_profile__isnull=True).order_by('date_joined')
|
|
return user_qs
|
|
|
|
@action(methods=['get'], url_name='users-count', url_path='users-count', detail=False)
|
|
def total_users_count(self, request, *args, **kwargs):
|
|
"""
|
|
api method to get total users, guardians and juniors
|
|
:param request: query params {start_date and end_date}, date format (yyyy-mm-dd)
|
|
:return:
|
|
"""
|
|
|
|
end_date = datetime.date.today()
|
|
start_date = end_date - datetime.timedelta(days=6)
|
|
|
|
if request.query_params.get('start_date') and request.query_params.get('end_date'):
|
|
start_date = datetime.datetime.strptime(request.query_params.get('start_date'), '%Y-%m-%d')
|
|
end_date = datetime.datetime.strptime(request.query_params.get('end_date'), '%Y-%m-%d')
|
|
|
|
user_qs = self.get_queryset()
|
|
queryset = user_qs.filter(date_joined__range=(start_date, (end_date + datetime.timedelta(days=1))))
|
|
|
|
data = {'total_users': queryset.count(),
|
|
'total_guardians': queryset.filter(junior_profile__isnull=True).count(),
|
|
'total_juniors': queryset.filter(guardian_profile__isnull=True).count()}
|
|
|
|
return custom_response(None, data)
|
|
|
|
@action(methods=['get'], url_name='new-signups', url_path='new-signups', detail=False)
|
|
def new_signups(self, request, *args, **kwargs):
|
|
|
|
end_date = datetime.date.today()
|
|
start_date = end_date - datetime.timedelta(days=6)
|
|
|
|
if request.query_params.get('start_date') and request.query_params.get('end_date'):
|
|
start_date = datetime.datetime.strptime(request.query_params.get('start_date'), '%Y-%m-%d')
|
|
end_date = datetime.datetime.strptime(request.query_params.get('end_date'), '%Y-%m-%d')
|
|
|
|
user_qs = self.get_queryset()
|
|
signup_data = user_qs.filter(date_joined__range=[start_date, (end_date + datetime.timedelta(days=1))]
|
|
).annotate(date=TruncDate('date_joined')
|
|
).values('date').annotate(signups=Count('id')).order_by('date')
|
|
|
|
return custom_response(None, signup_data)
|
|
|
|
@action(methods=['get'], url_name='assign-tasks', url_path='assign-tasks', detail=False)
|
|
def assign_tasks_report(self, request, *args, **kwargs):
|
|
|
|
end_date = datetime.date.today()
|
|
start_date = end_date - datetime.timedelta(days=6)
|
|
|
|
if request.query_params.get('start_date') and request.query_params.get('end_date'):
|
|
start_date = datetime.datetime.strptime(request.query_params.get('start_date'), '%Y-%m-%d')
|
|
end_date = datetime.datetime.strptime(request.query_params.get('end_date'), '%Y-%m-%d')
|
|
|
|
assign_tasks = JuniorTask.objects.filter(
|
|
created_at__range=[start_date, (end_date + datetime.timedelta(days=1))]
|
|
).exclude(task_status__in=[PENDING, EXPIRED])
|
|
|
|
data = {
|
|
'task_completed': assign_tasks.filter(task_status=COMPLETED).count(),
|
|
'task_in_progress': assign_tasks.filter(task_status=IN_PROGRESS).count(),
|
|
'task_requested': assign_tasks.filter(task_status=REQUESTED).count(),
|
|
'task_rejected': assign_tasks.filter(task_status=REJECTED).count(),
|
|
}
|
|
|
|
return custom_response(None, data)
|