Changeset 14737 for main/kofacustom.nigeria/trunk/src/kofacustom/nigeria/remita/helpers.py

Timestamp:

1 Aug 2017, 07:12:58 (7 years ago)

Author:

Henrik Bettermann

Message:

Add query_remita helper function with test.

File:

• main/kofacustom.nigeria/trunk/src/kofacustom/nigeria/remita/helpers.py (modified) (3 diffs)

main/kofacustom.nigeria/trunk/src/kofacustom/nigeria/remita/helpers.py

@@ -18 +18 @@
 """General helper functions for the remita module in custom packages.
 """
+import grok
 from datetime import datetime
 import httplib
@@ -51 +52 @@
     h.request("POST", url, body=json.dumps(data), headers=headers)
     resp = h.getresponse()
+    if resp.status!=200:
+        return {'error': 'Connection error (%s, %s)' % (response.status, response.reason)}
     jsonout = resp.read()
     try:
         parsed_json = json.loads(jsonout[6:-1])
     except ValueError:
-        return None
+        return {'error': 'No JSON response'}
     return parsed_json
 
@@ -72 +75 @@
     h.request("GET", url, headers=headers)
     resp = h.getresponse()
+    if resp.status!=200:
+        return {'error': 'Connection error (%s, %s)' % (response.status, response.reason)}
     jsonout = resp.read()
     try:
         parsed_json = json.loads(jsonout)
     except ValueError:
-        return None
+        return {'error': 'No JSON response'}
     return parsed_json
+
+
+def query_remita(payment, merchantId, api_key, RRR, host, https, verify):
+
+    jr = get_payment_status_via_rrr(merchantId, api_key, RRR, host, https)
+    error = jr.get('error')
+    if error:
+        msg = log = error
+        return False, msg, log
+
+    # A typical JSON response
+    # {
+    # u'orderId': u'3456346346',
+    # u'status': u'021',
+    # u'amount': 1000.0,
+    # u'transactiontime': u'2017-07-31 11:17:24 AM',
+    # u'message': u'Transaction Pending',
+    # u'lineitems': [{u'status': u'021', u'lineItemsId': u'itemid1'},
+    #                {u'status': u'021', u'lineItemsId': u'itemid2'}
+    #               ],
+    # u'RRR': u'280007640804'}
+
+    payment.r_code = jr['status']
+    payment.r_desc = jr['message']
+    payment.r_amount_approved = jr['amount']
+    payment.r_pay_reference = jr['RRR']
+    payment.r_company = u'remita'
+    if payment.r_code != '00':
+        msg = _('Unsuccessful callback: ${a}', mapping = {'a': payment.r_desc})
+        log = 'unsuccessful callback for %s payment %s: %s' % (
+            payment.p_category, payment.p_id, payment.r_desc)
+        payment.p_state = 'failed'
+        notify(grok.ObjectModifiedEvent(payment))
+        return False, msg, log
+    if round(payment.r_amount_approved, 0) != round(payment.amount_auth, 0):
+        msg = _('Callback amount does not match.')
+        log = 'wrong callback for %s payment %s: %s' % (
+            payment.p_category, payment.p_id, str(jr))
+        payment.p_state = 'failed'
+        notify(grok.ObjectModifiedEvent(payment))
+        return False, msg, log
+    if jr['orderId'] != payment.p_id:
+        msg = _('Callback order id does not match.')
+        log = 'wrong callback for %s payment %s: %s' % (
+            payment.p_category, payment.p_id, str(jr))
+        payment.p_state = 'failed'
+        notify(grok.ObjectModifiedEvent(payment))
+        return False, msg, log
+    payment.p_state = 'paid'
+    if not verify:
+        payment.payment_date = datetime.utcnow()
+    msg = _('Successful callback received')
+    log = 'valid callback for %s payment %s: %s' % (
+        payment.p_category, payment.p_id, str(jr))
+    notify(grok.ObjectModifiedEvent(payment))
+    return True, msg, log