tanner/spaceport
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Process IPNs based off User instead of Member

Browse Source
This commit is contained in:
Tanner Collin 2021-12-22 06:02:05 +00:00
parent 7623ef68fe
commit 6b76057cab
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
apiserver/apiserver/api/utils_paypal.py
View File

@ -12,6 +12,7 @@ from django.utils import timezone
from django.utils.timezone import now from django.utils.timezone import now
from . import models, serializers, utils from . import models, serializers, utils
from .. import settings
SANDBOX = False SANDBOX = False
if SANDBOX: if SANDBOX:
@ -77,6 +78,9 @@ def update_ipn(ipn, status):
ipn.save() ipn.save()
def verify_paypal_ipn(data): def verify_paypal_ipn(data):
if settings.DEBUG:
return True
params = data.copy() params = data.copy()
params['cmd'] = '_notify-validate' params['cmd'] = '_notify-validate'
headers = { headers = {
@ -300,6 +304,7 @@ def process_paypal_ipn(data):
update_ipn(ipn, 'Missing ID') update_ipn(ipn, 'Missing ID')
return False return False
# TODO: index txn_id?
if transactions.filter(paypal_txn_id=data['txn_id']).exists(): if transactions.filter(paypal_txn_id=data['txn_id']).exists():
logger.info('IPN - Duplicate transaction, ignoring') logger.info('IPN - Duplicate transaction, ignoring')
update_ipn(ipn, 'Duplicate') update_ipn(ipn, 'Duplicate')
@ -321,25 +326,30 @@ def process_paypal_ipn(data):
) )
return tx return tx
member = False user = False
member_id = False
if hints.filter(account=data.get('payer_id', False)).exists(): try:
member = hints.get(account=data['payer_id']).user.member user = hints.get(account=data['payer_id']).user
except hints.DoesNotExist:
logger.info('IPN - No PayPalHint found for %s', data['payer_id'])
if not member_id and 'member' in custom_json: if not user and 'member' in custom_json:
member_id = custom_json['member'] member_id = custom_json['member']
try:
user = members.get(id=member_id).user
except members.DoesNotExist:
pass
if not members.filter(id=member_id).exists(): if not user:
logger.info('IPN - Unable to associate with member, reporting') logger.info('IPN - Unable to associate with member, reporting')
update_ipn(ipn, 'Accepted, Unmatched Member') update_ipn(ipn, 'Accepted, Unmatched Member')
return create_unmatched_member_tx(data) return create_unmatched_member_tx(data)
member = members.get(id=member_id) member = user.member
hints.update_or_create( hints.update_or_create(
account=data.get('payer_id', 'unknown'), account=data.get('payer_id', 'unknown'),
defaults=dict(user=member.user), defaults=dict(user=user),
) )
if custom_json.get('category', False) in ['Snacks', 'OnAcct', 'Donation']: if custom_json.get('category', False) in ['Snacks', 'OnAcct', 'Donation']: