Add User Lifetime Statistics

backend/Pipfile

@@ -45,4 +45,4 @@ typing-extensions = "*"
 drf-excel = "*"
 
 [requires]
-python_version = "3"
+python_version = "3"

backend/ohq/admin.py

@@ -10,6 +10,7 @@
     Question,
     Queue,
     QueueStatistic,
+    UserStatistic,
     Semester,
     Tag,
 )
@@ -26,3 +27,4 @@
 admin.site.register(QueueStatistic)
 admin.site.register(Announcement)
 admin.site.register(Tag)
+admin.site.register(UserStatistic)

backend/ohq/management/commands/user_stat.py

@@ -0,0 +1,65 @@
+from django.core.management.base import BaseCommand
+from django.utils import timezone
+from datetime import timedelta
+
+from ohq.models import Profile, Course, Question
+from ohq.statistics import (
+    user_calculate_questions_asked,
+    user_calculate_questions_answered,
+    user_calculate_time_helped,
+    user_calculate_time_helping,
+    user_calculate_students_helped,
+)
+from django.db.models import Q
+
+
+
+
+class Command(BaseCommand):
+    def add_arguments(self, parser):
+        parser.add_argument("--hist", action="store_true", help="Calculate all historic statistics")
+
+    def calculate_statistics(self, profiles, courses, earliest_date):
+        yesterday = timezone.datetime.today().date() - timezone.timedelta(days=1)
+        active_users_today = set()
+
+        for course in courses:
+            if not earliest_date:
+                course_questions = Question.objects.filter(queue__course=course)
+                earliest_date = (
+                    timezone.template_localtime(
+                        course_questions.earliest("time_asked").time_asked
+                    ).date()
+                    if course_questions
+                    else yesterday
+                )
+
+            questions_queryset = Question.objects.filter(queue__course=course, time_asked__gte=earliest_date)
+            users_union = (
+                Profile.objects.filter(
+                    Q(id__in=questions_queryset.values_list("asked_by", flat=True)) |
+                    Q(id__in=questions_queryset.values_list("responded_to_by", flat=True))
+                )
+            )
+
+            for user in users_union:
+                    user_calculate_questions_asked(user.user)
+                    user_calculate_questions_answered(user.user)
+                    user_calculate_time_helped(user.user)
+                    user_calculate_time_helping(user.user)
+                    user_calculate_students_helped(user.user)
+
+
+    def handle(self, *args, **kwargs):
+        if kwargs["hist"]:
+            courses = Course.objects.all()
+            profiles = Profile.objects.all()
+            earliest_date = None
+        else: 
+            courses = Course.objects.filter(archived=False)
+            profiles = Profile.objects.all()
+            earliest_date = timezone.now().date() - timedelta(days=1)
+
+        self.calculate_statistics(profiles, courses, earliest_date)
+
+

backend/ohq/migrations/0020_auto_20240326_0226.py

@@ -0,0 +1,29 @@
+# Generated by Django 3.1.7 on 2024-03-26 02:26
+
+from django.conf import settings
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
+        ('ohq', '0019_auto_20211114_1800'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='UserStatistic',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('metric', models.CharField(choices=[('TOTAL_QUESTIONS_ASKED', 'Total questions asked'), ('TOTAL_QUESTIONS_ANSWERED', 'Total questions answered'), ('TOTAL_TIME_BEING_HELPED', 'Total time being helped'), ('TOTAL_TIME_HELPING', 'Total time helping'), ('TOTAL_STUDENTS_HELPED', 'Total students helped')], max_length=256)),
+                ('value', models.DecimalField(decimal_places=8, max_digits=16)),
+                ('user', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to=settings.AUTH_USER_MODEL)),
+            ],
+        ),
+        migrations.AddConstraint(
+            model_name='userstatistic',
+            constraint=models.UniqueConstraint(fields=('user', 'metric'), name='unique_user_statistic'),
+        ),
+    ]

backend/ohq/models.py

@@ -411,3 +411,38 @@ class Announcement(models.Model):
     author = models.ForeignKey(User, related_name="announcements", on_delete=models.CASCADE)
     time_updated = models.DateTimeField(auto_now=True)
     course = models.ForeignKey(Course, related_name="announcements", on_delete=models.CASCADE)
+
+
+class UserStatistic(models.Model):
+    """
+    Statistics related to a user (student or TA) across many courses
+    """
+
+    METRIC_TOTAL_QUESTIONS_ASKED = "TOTAL_QUESTIONS_ASKED"
+    METRIC_TOTAL_QUESTIONS_ANSWERED = "TOTAL_QUESTIONS_ANSWERED"
+    METRIC_TOTAL_TIME_BEING_HELPED = "TOTAL_TIME_BEING_HELPED"
+    METRIC_TOTAL_TIME_HELPING = "TOTAL_TIME_HELPING"
+    METRIC_TOTAL_STUDENTS_HELPED = "TOTAL_STUDENTS_HELPED"
+
+    METRIC_CHOICES = [
+        (METRIC_TOTAL_QUESTIONS_ASKED, "Total questions asked"),
+        (METRIC_TOTAL_QUESTIONS_ANSWERED, "Total questions answered"),
+        (METRIC_TOTAL_TIME_BEING_HELPED, "Total time being helped"),
+        (METRIC_TOTAL_TIME_HELPING, "Total time helping"),
+        (METRIC_TOTAL_STUDENTS_HELPED, "Total students helped"),
+    ]
+
+    user = models.ForeignKey(User, on_delete=models.CASCADE)
+    metric = models.CharField(max_length=256, choices=METRIC_CHOICES)
+    value = models.DecimalField(max_digits=16, decimal_places=8)
+
+    class Meta:
+        constraints = [
+            models.UniqueConstraint(fields=["user", "metric"], name="unique_user_statistic")
+        ]
+
+    def __str__(self):
+        return f"{self.user}: {self.metric}"
+
+
+

backend/ohq/statistics.py

@@ -2,8 +2,10 @@
 from django.db.models import Avg, Case, Count, F, Sum, When
 from django.db.models.functions import TruncDate
 from django.utils import timezone
+from decimal import Decimal, ROUND_HALF_UP
+import math
 
-from ohq.models import CourseStatistic, Question, QueueStatistic
+from ohq.models import CourseStatistic, Question, QueueStatistic, UserStatistic
 
 
 User = get_user_model()
@@ -232,3 +234,83 @@ def queue_calculate_questions_per_ta_heatmap(queue, weekday, hour):
         hour=hour,
         defaults={"value": statistic if statistic else 0},
     )
+
+
+def user_calculate_questions_asked(user):
+    num_questions = Question.objects.filter(asked_by=user).count()
+
+    if num_questions and not num_questions == 0:
+        UserStatistic.objects.update_or_create(
+            user=user,
+            metric=UserStatistic.METRIC_TOTAL_QUESTIONS_ASKED,
+            defaults={"value": num_questions},
+        )
+
+
+def user_calculate_questions_answered(user):
+    num_questions = (Question.objects.filter(
+        responded_to_by=user,
+        status=Question.STATUS_ANSWERED
+        ).count())
+
+    if num_questions and not num_questions == 0:
+        UserStatistic.objects.update_or_create(
+            user=user,
+            metric=UserStatistic.METRIC_TOTAL_QUESTIONS_ANSWERED,
+            defaults={"value": num_questions},
+        )
+
+
+
+def user_calculate_time_helped(user):
+    user_time_helped = (
+        Question.objects.filter(
+            asked_by=user,
+            status=Question.STATUS_ANSWERED
+            ).aggregate(time_helped=Sum(F("time_responded_to") - F("time_response_started")))
+    )
+    time = user_time_helped["time_helped"]
+
+    if time and not math.isclose(time.total_seconds(), 0, abs_tol=0.001):
+        UserStatistic.objects.update_or_create(
+            user=user,
+            metric=UserStatistic.METRIC_TOTAL_TIME_BEING_HELPED,
+            defaults={"value": time.seconds},
+        )
+
+
+def user_calculate_time_helping(user):
+    user_time_helping = (
+        Question.objects.filter(
+            responded_to_by=user,
+            status=Question.STATUS_ANSWERED
+            ).aggregate(time_answering=Sum(F("time_responded_to") - F("time_response_started")))
+    )
+    time = user_time_helping["time_answering"]
+
+    if time and not math.isclose(time.total_seconds(), 0, abs_tol=0.001): 
+        UserStatistic.objects.update_or_create(
+            user=user,
+            metric=UserStatistic.METRIC_TOTAL_TIME_HELPING,
+            defaults={"value": time.seconds},
+        )
+
+
+def user_calculate_students_helped(user): 
+    num_students = Decimal(
+        Question.objects.filter(
+            status=Question.STATUS_ANSWERED,
+            responded_to_by=user
+        )
+        .distinct("asked_by")
+        .count()
+    )
+    if num_students and not num_students == 0:
+        UserStatistic.objects.update_or_create(
+            user=user,
+            metric=UserStatistic.METRIC_TOTAL_STUDENTS_HELPED,
+            defaults={"value": num_students},
+        )
+
+
+