carom-server/billard/tasks.py

89 lines
3.6 KiB
Python
Raw Permalink Normal View History

2017-02-06 18:50:10 +01:00
from __future__ import absolute_import, unicode_literals
2017-03-09 20:08:35 +01:00
import logging
2017-02-06 18:50:10 +01:00
2018-03-31 16:30:03 +02:00
from django.db.models.signals import post_save
from django.dispatch import receiver
2018-02-11 10:56:44 +01:00
import billard.utils as utils
from billard.models import LocationData, Client, Accounting, ClientData
2017-03-09 20:08:35 +01:00
log = logging.getLogger(__name__)
2017-02-06 18:50:10 +01:00
2017-08-04 17:49:33 +02:00
2018-03-31 16:30:03 +02:00
@receiver(post_save, sender=ClientData)
2018-03-31 16:40:32 +02:00
def process_client_data(sender, **kwargs):
2018-02-19 10:56:56 +01:00
data = ClientData.objects.all().order_by('last_seen')
for cd in data:
client = Client.objects.get(uuid=cd.uuid)
client.last_seen = cd.last_seen
client.save()
cd.delete()
2018-03-31 16:30:03 +02:00
@receiver(post_save, sender=LocationData)
2018-03-31 16:40:32 +02:00
def process_location_data(sender, **kwargs):
log.info('Starte die Verarbeitung der Location-Data-Objecte')
2017-08-01 07:48:41 +02:00
data = LocationData.objects.filter(processed=False).order_by('tst')
2017-03-09 20:08:35 +01:00
for ld in data:
try:
cli = Client.objects.filter(uuid=ld.client_id, desks__desk_no=ld.desk_no)
if cli.count() < 1:
2017-03-09 20:08:35 +01:00
ld.processed = True
ld.error_msg = 'No client object found. Stopp processing! {}, {}'.format(ld.client_id, ld.desk_no)
2017-03-09 20:08:35 +01:00
ld.save()
log.error(ld.error_msg)
else:
cli = cli[0]
desk = cli.desks.filter(desk_no=ld.desk_no, enabled=True)
if desk.count() != 1:
2017-03-09 20:08:35 +01:00
ld.processed = True
ld.error_msg = 'No desk object found. Stopp processing! {}, {}'.format(ld.client_id, ld.desk_no)
2017-03-09 20:08:35 +01:00
ld.save()
log.error(ld.error_msg)
desk = desk[0]
ac = desk.accounting_set.order_by('time_from').reverse()
if ld.on_off:
acc = None
if ac.count() > 0 and ac[0].time_to is None:
log.error('Vorheriges Accounting nicht abgeschlossen: Desk_id {}, Accounting_id {}'
.format(desk.id, ac[0].id))
acc = ac[0]
if acc is None:
acc = Accounting(
desk=desk,
time_from=ld.tst,
)
acc.save()
ld.delete()
else:
if len(ac) > 0:
acc = ac[0]
acc.time_to = ld.tst
acc.prize, acc.prize_normal, acc.prize_hh = utils.get_prize_for(
start=acc.time_from,
end=ld.tst,
pph=desk.prize,
hh_start=cli.location.happy_hour_start,
hh_end=cli.location.happy_hour_end,
pphh=desk.prize_hh,
)
acc.reporter_uuid = cli.uuid
acc.save()
ld.delete()
else:
ld.processed = True
2018-02-11 10:56:44 +01:00
ld.error_msg = 'No existing accountings found. Stopp processing! {}, {}'.format(ld.client_id,
ld.desk_no)
ld.save()
log.error(ld.error_msg)
except:
log.exception('', exc_info=True)
@receiver(post_save, sender=Accounting)
def process_accounting_data(sender, **kwargs):
log.info('Starte die Verarbeitung der Accounting-Data-Objecte')
data = Accounting.objects.filter(prize=0.0, reporter_uuid__isnull=True).exclude(time_to__isnull=True)
data.delete()