From 4687763098d280edfe7f3d34cc9072330d6a6764 Mon Sep 17 00:00:00 2001
From: Tobias Kunze <rixx@cutebit.de>
Date: Thu, 11 Jan 2018 20:20:16 +0100
Subject: [PATCH] Add transactio matching

---
 byro_shackspace/utils.py | 32 ++++++++++++++++++++------------
 1 file changed, 20 insertions(+), 12 deletions(-)

diff --git a/byro_shackspace/utils.py b/byro_shackspace/utils.py
index b30959b..f3bd89f 100644
--- a/byro_shackspace/utils.py
+++ b/byro_shackspace/utils.py
@@ -38,15 +38,30 @@ def process_bank_csv(source):
         )
 
 
-def match_transaction(transaction):
+@receiver(derive_virtual_transactions)
+def match_transaction(transaction, signal, **kwargs):
     uid, score = reference_parser(transaction.reference)
     member = None
-    error = None
     try:
-        if uid:
-            member = Member.objects.get(member_id=uid)
+        member = Member.objects.get(number=uid)
     except Member.DoesNotExist:
-        error = "Member does not exist"
+        return
+
+    account = Account.objects.get(account_category=AccountCategory.MEMBER_FEES)
+    data = {
+        'amount': transaction.amount,
+        'destination': account,
+        'value_datetime': value_datetime,
+        'member': member,
+    }
+    virtual_transaction = VirtualTransaction.objects.filter(**data).first()
+    if virtual_transaction and virtual_transaction.real_transaction != transaction:
+        raise Exception(f'RealTransaction {transaction.id} cannot be matched! There is already a VirtualTransaction ({virtual_transaction.id}) that is too similar. It is matched to RealTransaction {virtual_transaction.real_transaction.id}.')
+    if not virtual_transaction:
+        data['real_transaction'] = transaction
+        virtual_transaction = VirtualTransaction.objects.create(**data)
+    return [virtual_transaction]
+
 
 def reference_parser(self, reference):
     reference = reference.lower()
@@ -70,10 +85,3 @@ def reference_parser(self, reference):
             return (int(hit.groupdict().get('ID')), score)
 
     return (False, 99)
-
-def get_debitor_by_record_token(self, reference):
-    reference = "".join(reference.lower().split())
-    for debitor in self.debitors:
-        if re.match(debitor['regex'], reference):
-            return Debitor.objects.get(pk=debitor['pk'])
-    return None