LeineLab-Public/byro-leinelab
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make CSV processing into signal receiver

Browse Source
This commit is contained in:
Tobias Kunze 2018-01-13 12:38:49 +01:00
parent 4255351106
commit 4ab6e65590
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
byro_shackspace/utils.py
View File

@ -8,12 +8,14 @@ from django.dispatch import receiver
from django.utils.timezone import now from django.utils.timezone import now
from byro.bookkeeping.models import RealTransaction, TransactionChannel from byro.bookkeeping.models import RealTransaction, TransactionChannel
from byro.bookkeeping.signals import derive_virtual_transactions from byro.bookkeeping.signals import derive_virtual_transactions, process_bank_csv
from byro.members.models import Member from byro.members.models import Member
@transaction.atomic @transaction.atomic
def process_bank_csv(source): @receiver(process_bank_csv)
def process_bank_csv(sender, signal, **kwargs):
source = sender
reader = csv.DictReader(open(source.source_file.name, encoding='iso-8859-1'), delimiter=';', quotechar='"') reader = csv.DictReader(open(source.source_file.name, encoding='iso-8859-1'), delimiter=';', quotechar='"')
booking_timestamp = now() booking_timestamp = now()
@ -38,8 +40,10 @@ def process_bank_csv(source):
) )
@transaction.atomic
@receiver(derive_virtual_transactions) @receiver(derive_virtual_transactions)
def match_transaction(transaction, signal, **kwargs): def match_transaction(sender, signal, **kwargs):
transaction = sender
uid, score = reference_parser(transaction.reference) uid, score = reference_parser(transaction.reference)
member = None member = None
try: try: