import datetime
from celery.task import periodic_task
from service.models import MailBox


@periodic_task(run_every=datetime.timedelta(minutes=1))
def mailbox_send():
    for box in MailBox.objects.filter(queue_date__lte=datetime.datetime.now(), status__in=['Q', 'W']).order_by('-queue_date'):
        box.send_letter()