# coding=utf-8
from celery.task import periodic_task
from datetime import timedelta, datetime
from access.models import User, TrafSource, TrafTokenHistory


@periodic_task(run_every=timedelta(minutes=20))
def check_prepo_delay():
    # Проверка просроченых задач преподавателя
    for res in User.objects.filter(delay_date__lte=datetime.now(), in_role='T'):
        res.delay = False
        res.delay_description = ''
        res.delay_date = None
        res.save()


@periodic_task(run_every=timedelta(minutes=1))
def check_online():
    for user in User.objects.filter(status='ON', last_time__lte=datetime.now()-timedelta(minutes=10)):
        user.status = 'OFF'
        user.save()


@periodic_task(run_every=timedelta(hours=1))
def check_traf_source():
    for source in TrafSource.objects.filter(on=True).exclude(live_time=None):
        if source.token and source.token_start + timedelta(hours=source.live_time) < datetime.now():
            source.on = False
            TrafTokenHistory.objects.create(token=source.token, source=source, live_time=source.live_time, date_start=source.token_start, date_end=datetime.now())
            source.token = None
            source.token_start = None
            source.save()


#@periodic_task(run_every=timedelta(minutes=1))
#def sync_users():
#    for user in User.objects.filter(sync=False):
#        result = sent_sync_user(user)
#        if result:
#            user._set_synced()