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

import transactions for 2015

Browse Source 
(and only for 2015)
This commit is contained in:
Andreas Madsack 2018-01-13 15:21:11 +01:00
parent 96ee3032d4
commit f6e9afc009
1 changed files with 13 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
byro_shackspace/management/commands/import_shackbureau.py
View File

@ -52,10 +52,11 @@ def _get_main_accounts():
def _import_real_transactions(real_transactions): def _import_real_transactions(real_transactions):
transactions = [] ids = []
for real_transaction in real_transactions: for real_transaction in real_transactions:
transactions.append(RealTransaction( if parse_date(real_transaction['booking_date'] or real_transaction['due_date']).year != 2015:
continue
rt, _ = RealTransaction.objects.get_or_create(
channel=TransactionChannel.BANK, channel=TransactionChannel.BANK,
value_datetime=localize(parse_date(real_transaction['booking_date'] or real_transaction['due_date'])), value_datetime=localize(parse_date(real_transaction['booking_date'] or real_transaction['due_date'])),
amount=real_transaction['amount'], amount=real_transaction['amount'],
@ -63,37 +64,21 @@ def _import_real_transactions(real_transactions):
originator=real_transaction.get('transaction_owner') or 'imported', originator=real_transaction.get('transaction_owner') or 'imported',
# TODO: reverses? # TODO: reverses?
importer='shackbureau', importer='shackbureau',
)) )
ids.append(rt.pk)
ids = [rt.pk for rt in RealTransaction.objects.bulk_create(transactions)]
return RealTransaction.objects.filter(pk__in=ids) return RealTransaction.objects.filter(pk__in=ids)
def _import_fee_claims(member, virtual_transactions):
fee_account, donation_account, liability_account = _get_main_accounts()
claims = [v for v in virtual_transactions if v['booking_type'] == 'fee_claim']
transactions = []
for claim in claims:
transactions.append(VirtualTransaction(
source_account=fee_account,
destination_account=liability_account,
member=member,
amount=abs(Decimal(claim['amount'])),
value_datetime=localize(parse_date(claim['due_date'])),
))
VirtualTransaction.objects.bulk_create(transactions)
def _import_inflows(member, virtual_transactions, real_transactions): def _import_inflows(member, virtual_transactions, real_transactions):
fee_account, donation_account, liability_account = _get_main_accounts() fee_account, donation_account, liability_account = _get_main_accounts()
inflows = [v for v in virtual_transactions if v['booking_type'] == 'deposit'] inflows = [v for v in virtual_transactions if v['booking_type'] == 'deposit']
for inflow in inflows: for inflow in inflows:
if parse_date(inflow['due_date']) is None or parse_date(inflow['due_date']).year != 2015:
continue
account = fee_account if inflow['transaction_type'] == 'membership fee' else donation_account account = fee_account if inflow['transaction_type'] == 'membership fee' else donation_account
possible_real_transaction = real_transactions.filter( possible_real_transaction = real_transactions.filter(
virtual_transactions__isnull=True, virtual_transactions__isnull=True,
@ -105,7 +90,7 @@ def _import_inflows(member, virtual_transactions, real_transactions):
if possible_real_transaction.count() == 1: if possible_real_transaction.count() == 1:
real_transaction = possible_real_transaction.first() real_transaction = possible_real_transaction.first()
VirtualTransaction.objects.create( VirtualTransaction.objects.get_or_create(
destination_account=account, destination_account=account,
source_account=liability_account, source_account=liability_account,
member=member, member=member,
@ -125,7 +110,7 @@ def _import_transactions(member_data, member):
real_transactions = _import_real_transactions(real_transactions) real_transactions = _import_real_transactions(real_transactions)
_import_fee_claims(member, virtual_transactions) # _import_fee_claims(member, virtual_transactions)
_import_inflows(member, virtual_transactions, real_transactions) _import_inflows(member, virtual_transactions, real_transactions)
@ -180,7 +165,7 @@ def import_member(member_data):
if value: if value:
setattr(member.profile_profile, key, value) setattr(member.profile_profile, key, value)
member.profile_profile.save() member.profile_profile.save()
# _import_transactions(member_data, member) _import_transactions(member_data, member)
def import_members(data): def import_members(data):
@ -201,4 +186,4 @@ class Command(BaseCommand):
data = json.load(export) data = json.load(export)
import_members(data['members']) import_members(data['members'])
# _import_real_transactions(data['unresolved_bank_transactions']) _import_real_transactions(data['unresolved_bank_transactions'])