from django.core.management.base import BaseCommand

from api.models import TtStaff, TtLocation, TtStudentSet, TtActivityTemplate, TtActivity, TtModule
from api.utils import convert_to_redis_week, bulk_sync_to_redis
from backend.kafka import send_request
from backend.redis_client import redis_client


class Command(BaseCommand):
    def handle(self, *args, **options):
        method = "module_delete"
        kafka_topic = "microservices-tt"
        if kafka_topic:
            kafka_request_data = {
                "session_id": "",
                "module_ids": [1000,1025,1002,1003,1004,1005,1006,1007,1008,1009,1010,1012,1013,1014,1015,1017,1018,1019,1020,1021,1022,1023,1024,1001,1011,1016]
            }
            send_request(kafka_topic, kafka_request_data, None, method)