Merge pull request #2571 from gtech-mulearn/(feat)/copy-reporting

(feat)/copy reporting

Author: nashnsulthan

api/dashboard/task_report/serializers.py

@@ -0,0 +1,46 @@
+from rest_framework import serializers
+
+from db.task import TaskReport
+from utils.utils import DateTimeUtils
+from utils.types import ManagementType
+
+class TaskReportSerializer(serializers.ModelSerializer):
+    reporter = serializers.CharField(source="reporter.fullname")
+    offender = serializers.CharField(source="offender.fullname")
+    created_at = serializers.SerializerMethodField()
+    updated_at = serializers.SerializerMethodField()
+
+    class Meta:
+        model = TaskReport
+        fields = [
+            "id",
+            "reporter",
+            "offender",
+            "message_id",
+            "reason",
+            "proof_link",
+            "status",
+            "created_at",
+            "updated_at",
+        ]
+
+    def get_created_at(self, obj):
+        return DateTimeUtils.format_datetime(obj.created_at)
+
+    def get_updated_at(self, obj):
+        return DateTimeUtils.format_datetime(obj.updated_at)
+
+
+class TaskReportUpdateSerializer(serializers.ModelSerializer):
+    updated_by = serializers.CharField(required=False)
+
+    class Meta:
+        model = TaskReport
+        fields = ["status", "updated_by"]
+
+    def update(self, instance, validated_data):
+        instance.status = validated_data.get("status", instance.status)
+        instance.updated_by_id = self.context.get("user_id")
+        instance.updated_at = DateTimeUtils.get_current_utc_time()
+        instance.save()
+        return instance

api/dashboard/task_report/urls.py

@@ -0,0 +1,8 @@
+from django.urls import path
+from . import views
+
+urlpatterns = [
+    path('', views.TaskReportInfoView.as_view()),
+    path('<str:report_id>/', views.TaskReportInfoView.as_view()),
+    path('group-by-reporter/', views.TaskReportReporterGroupingView.as_view()),
+]

api/dashboard/task_report/views.py

@@ -0,0 +1,93 @@
+from rest_framework.views import APIView
+from django.db.models import Count
+
+from db.task import TaskReport, KarmaActivityLog
+from utils.response import CustomResponse
+from utils.permission import CustomizePermission, JWTUtils, RoleRequired
+from utils.types import RoleType
+from . import serializers
+
+class TaskReportInfoView(APIView):
+    authentication_classes = [CustomizePermission]
+
+    @RoleRequired(roles=[RoleType.ADMIN, RoleType.FELLOW])
+    def get(self, request):
+        reports = TaskReport.objects.all()
+        
+        # Filtering
+        if status := request.query_params.get("status"):
+            reports = reports.filter(status=status)
+
+        serializer = serializers.TaskReportSerializer(reports, many=True)
+        return CustomResponse(response=serializer.data).get_success_response()
+
+    @RoleRequired(roles=[RoleType.ADMIN, RoleType.FELLOW])
+    def put(self, request, report_id):
+        report = TaskReport.objects.filter(id=report_id).first()
+        if not report:
+            return CustomResponse(general_message="Report not found").get_failure_response()
+
+        serializer = serializers.TaskReportUpdateSerializer(
+            report, data=request.data, context={"user_id": JWTUtils.fetch_user_id(request)}
+        )
+        if serializer.is_valid():
+            serializer.save()
+            return CustomResponse(general_message="Report status updated successfully").get_success_response()
+        return CustomResponse(message=serializer.errors).get_failure_response()
+
+
+class TaskReportTaskGroupingView(APIView):
+    authentication_classes = [CustomizePermission]
+
+    @RoleRequired(roles=[RoleType.ADMIN, RoleType.FELLOW])
+    def get(self, request):
+        # 1) How many people reported to each tasks
+        # Group by message_id
+        report_counts = (
+            TaskReport.objects.values("message_id")
+            .annotate(report_count=Count("id"))
+            .order_by("-report_count")
+        )
+        
+        data = []
+        for item in report_counts:
+            res = {
+                "message_id": item["message_id"],
+                "report_count": item["report_count"],
+                "task_hashtag": None
+            }
+            # Try to fetch hashtag from KarmaActivityLog
+            if kal := KarmaActivityLog.objects.filter(task_message_id=item["message_id"]).first():
+                res["task_hashtag"] = kal.task.hashtag
+            
+            data.append(res)
+
+        return CustomResponse(response=data).get_success_response()
+
+
+class TaskReportReporterGroupingView(APIView):
+    authentication_classes = [CustomizePermission]
+
+    @RoleRequired(roles=[RoleType.ADMIN, RoleType.FELLOW])
+    def get(self, request):
+        # Request #2: "How many tasks were reported by a person" - confusing phrasing
+        # It could mean "How many reports did User X make" OR "How many times was User Y reported"
+        # Let's provide both.
+        
+        # Reports by Reporter
+        reporters = (
+            TaskReport.objects.values("reporter__id", "reporter__fullname")
+            .annotate(report_count=Count("id"))
+            .order_by("-report_count")
+        )
+        
+        # Reports against Offender
+        offenders = (
+            TaskReport.objects.values("offender__id", "offender__fullname")
+            .annotate(report_count=Count("id"))
+            .order_by("-report_count")
+        )
+
+        return CustomResponse(
+            response={"reporters": reporters, "offenders": offenders}
+        ).get_success_response()

api/dashboard/urls.py

@@ -26,4 +26,5 @@
     path("coupon/", include("api.dashboard.coupon.urls")),
     path("projects/", include("api.dashboard.projects.urls")),
     path("achievement/", include("api.dashboard.achievement.urls")),
+    path("task-report/", include("api.dashboard.task_report.urls")),
 ]