from django.core.management.base import BaseCommand
from scheduler.tasks import load_tasks_to_scheduler
from scheduler.apps import scheduler_instance

class Command(BaseCommand):
    help = "Перезагрузка задач в планировщике"

    def handle(self, *args, **kwargs):
        try:
            # Удаляем все существующие задачи
            scheduler_instance.remove_all_jobs()
            
            # Загружаем задачи заново
            load_tasks_to_scheduler(scheduler_instance)
            self.stdout.write(self.style.SUCCESS("Задачи успешно перезагружены."))
        except Exception as e:
            self.stdout.write(self.style.ERROR(f"Ошибка перезагрузки задач: {e}"))