import datetime

from django.core.management import BaseCommand
from django.utils import timezone
from rest_framework import serializers, status

from api.models import TtSuitability, TtTag, TtSetting, AuditTrail, AuditTrailDetails, TtDepartment, TtZone, \
    TtUsagePreference, TtAcademicTerm, TtActivity
from api.views.admin.base import AdminApiBase
from api.validator import BaseValidator
from api.utils import decrypt_aes_128_cbc, encrypt_aes_128_cbc, log_critical_error, get_exception_detail, \
    bulk_sync_to_redis, get_ip, get_related_fk_table_ids, get_resources_affected_weeks, get_resource_map_redis_data, \
    recalculate_resource_map
from rest_framework.exceptions import ValidationError
from api.translation import __
from backend.kafka import send_request
from backend.redis_client import redis_client

class Command(BaseCommand):
    def handle(self, *args, **options):
        academic_term = TtAcademicTerm.objects.filter(code=65).first()
        activity_ids = TtActivity.objects.filter(academic_term_id = academic_term.id).values_list("id", flat=True)
        method = "schedule"

        kafka_topic = "tt-request"
        kafka_request_data = {
            "session_id": "admin",
            "activities": [],
            "slot": None,
        }
        for activity_id in activity_ids:
            kafka_request_data["activities"].append(activity_id)

        send_request(kafka_topic, kafka_request_data, None, method)