from __future__ import absolute_import
from celery.task import Task
from scheduler.Scheduler import Scheduler
from common.models import *
from utils.JDManipulator import *
from utils.Logger import setupLogger

log = setupLogger("TaskSched", "TaskSched")

class scheduling(Task):

    #TODO Remove first parameter (useless) -> maybe both ?
    def run(self, first_schedule=False, alert=False):
        print("In scheduling.run()")
        task = TaskId.objects.create(task_id=self.request.id, task="scheduling")
        Log.objects.create(agent='Scheduler', message='Start schedule : ' + str(datetime.datetime.now()))
        # This creates a Scheduler (in memory) which creates a Schedule (in DB)
        self.scheduler = Scheduler()
        self.scheduler.setNightLimits(secondsToJulianDate(getNightStart()), secondsToJulianDate(getNightEnd()))
        print("****sched-task: NEW SCHEDULE", self.scheduler.schedule, "*****")
        self.scheduler.makeSchedule()
        print("****sched-task: NEW SCHEDULE", self.scheduler.schedule, "*****")
        Log.objects.create(agent='Scheduler', message='Scheduling finished : ' + str(datetime.datetime.now()))
        task.delete()