feat: real assignments for the expert cabinet

partner_programs/services/assignment_analytics.py

@@ -10,22 +10,23 @@
 from project_rates.models import Criteria, ProjectExpertAssignment, ProjectScore
 
 
-def annotated_assignment_queryset(program_id):
+def annotated_assignment_queryset(program_id=None):
     """Общая SQL-проверка завершённости реального назначения в программе.
 
     Завершённое назначение требует сданного решения и оценок по всем критериям
     этой программы; отсутствие критериев никогда не означает завершённость.
     Аннотации пригодны и для списка назначений, и для агрегации работ без N+1.
     """
+    scope = program_id if program_id is not None else OuterRef("partner_program_id")
     criteria = (
-        Criteria.objects.filter(partner_program_id=program_id)
+        Criteria.objects.filter(partner_program_id=scope)
         .order_by()
         .values("partner_program_id")
         .annotate(total=Count("pk"))
     )
     scores = (
         ProjectScore.objects.filter(
-            criteria__partner_program_id=program_id,
+            criteria__partner_program_id=scope,
             project_id=OuterRef("project_id"),
             user_id=OuterRef("expert__user_id"),
         )
@@ -34,10 +35,14 @@ def annotated_assignment_queryset(program_id):
         .annotate(total=Count("criteria_id", distinct=True))
     )
     link = PartnerProgramProject.objects.filter(
-        partner_program_id=program_id, project_id=OuterRef("project_id")
+        partner_program_id=scope, project_id=OuterRef("project_id")
     ).order_by("pk")
     return (
-        ProjectExpertAssignment.objects.filter(partner_program_id=program_id)
+        (
+            ProjectExpertAssignment.objects.filter(partner_program_id=program_id)
+            if program_id is not None
+            else ProjectExpertAssignment.objects.all()
+        )
         .annotate(
             criteria_total=Coalesce(Subquery(criteria.values("total")[:1]), 0),
             criteria_scored=Coalesce(Subquery(scores.values("total")[:1]), 0),

project_rates/expert_cabinet.py

@@ -0,0 +1,120 @@
+"""Read projection of the current expert's actual assignments; no new scoring states."""
+
+from django.db.models import Count, Exists, F, OuterRef, Subquery
+from django.utils import timezone
+
+from partner_programs.models import PartnerProgramProject
+from partner_programs.services.assignment_analytics import annotated_assignment_queryset
+from partner_programs.services.case_analytics import project_case_links
+from partner_programs.services.case_fields import get_program_case_field
+from project_rates.models import ProjectScore
+from projects.models import Collaborator
+
+
+def cabinet_projects(user, query, program_ids):
+    own = annotated_assignment_queryset().filter(
+        expert__user=user,
+        partner_program__experts__user=user,
+        partner_program_id__in=program_ids,
+    )
+    linked = PartnerProgramProject.objects.filter(
+        partner_program_id=OuterRef("partner_program_id"),
+        project_id=OuterRef("project_id"),
+    )
+    visible = own.filter(project__draft=False).filter(Exists(linked))
+    pending = visible.filter(is_completed=False).count()
+    completed = visible.filter(is_completed=True).count()
+    unavailable = own.count() - pending - completed
+    selected = visible.filter(is_completed=query["status"] == "completed")
+    if query.get("program_id"):
+        selected = selected.filter(partner_program_id=query["program_id"])
+    if query.get("q"):
+        selected = selected.filter(project__name__icontains=query["q"])
+    count = selected.count()
+    scores = (
+        ProjectScore.objects.filter(
+            project_id=OuterRef("project_id"),
+            criteria__partner_program_id=OuterRef("partner_program_id"),
+        )
+        .order_by()
+        .values("project_id")
+        .annotate(total=Count("user_id", distinct=True))
+    )
+    own_scores = ProjectScore.objects.filter(
+        project_id=OuterRef("project_id"),
+        criteria__partner_program_id=OuterRef("partner_program_id"),
+        user_id=user.pk,
+    )
+    selected = selected.annotate(
+        cabinet_rated_count=Subquery(scores.values("total")[:1]),
+        cabinet_has_scores=Exists(own_scores),
+        cabinet_own_team=Exists(
+            Collaborator.objects.filter(
+                project_id=OuterRef("project_id"), user_id=user.pk
+            )
+        ),
+    ).select_related("partner_program", "project")
+    offset, limit = query["offset"], query["limit"]
+    end = offset + limit
+    assignments = list(
+        selected.order_by(
+            F("partner_program__datetime_evaluation_ends").asc(nulls_last=True),
+            "partner_program_id",
+            "project__name",
+            "pk",
+        )[offset:end]
+    )
+    programs = {a.partner_program_id: a.partner_program for a in assignments}
+    cases = {}
+    for program in programs.values():
+        cases.update(
+            {
+                (program.pk, project_id): name
+                for project_id, name in project_case_links(
+                    program, field=get_program_case_field(program)
+                )
+                .filter(project_id__in=[a.project_id for a in assignments])
+                .values_list("project_id", "case_name")
+            }
+        )
+    now = timezone.now()
+    rows = []
+    for assignment in assignments:
+        program, project = assignment.partner_program, assignment.project
+        reason = None
+        if program.datetime_evaluation_ends and now > program.datetime_evaluation_ends:
+            reason = "Срок оценивания завершен"
+        elif not assignment.criteria_total:
+            reason = "Критерии не настроены"
+        elif program.required_evaluators is not None:
+            if not assignment.project_submitted:
+                reason = "Решение еще не сдано"
+            elif project.leader_id == user.pk or assignment.cabinet_own_team:
+                reason = "Нельзя оценивать проект своей команды"
+        elif (
+            program.max_project_rates
+            and (assignment.cabinet_rated_count or 0) >= program.max_project_rates
+            and not assignment.cabinet_has_scores
+        ):
+            reason = "Лимит оценок достигнут"
+        rows.append(
+            {
+                "assignment_id": assignment.pk,
+                "project_id": project.pk,
+                "program_id": program.pk,
+                "name": project.name,
+                "case_name": cases.get((program.pk, project.pk)),
+                "is_completed": assignment.is_completed,
+                "can_rate": reason is None,
+                "blocked_reason": reason,
+            }
+        )
+    return {
+        "count": count,
+        "limit": limit,
+        "offset": offset,
+        "pending": pending,
+        "completed": completed,
+        "unavailable": unavailable,
+        "results": rows,
+    }