Cancel old payment transaction if not found on payzen side.

master/bt5/slapos_payzen/SkinTemplateItem/portal_skins/slapos_payzen/PayzenEvent_processUpdate.xml

@@ -50,7 +50,9 @@
         </item>
         <item>
             <key> <string>_body</string> </key>
-            <value> <string>from zExceptions import Unauthorized\n
+            <value> <string encoding="cdata"><![CDATA[
+
+from zExceptions import Unauthorized\n
 if REQUEST is not None:\n
   raise Unauthorized\n
 \n
@@ -69,7 +71,24 @@ if signature is False:\n
   payzen_event.confirm(comment=\'Signature does not match\')\n
   return\n
 \n
-transaction_code_mapping = {\n
+isTransitionPossible = context.getPortalObject().portal_workflow.isTransitionPossible\n
+\n
+error_code = data_kw[\'errorCode\']\n
+if error_code == \'2\':\n
+  transaction_date, payzen_id = transaction.PaymentTransaction_getPayzenId()\n
+  # Mark on payment transaction history log that transaction was not processed yet\n
+  payzen_event.confirm()\n
+  payzen_event.acknowledge(comment=\'Transaction not found on payzen side.\')\n
+  if int(DateTime()) - int(transaction_date) > 86400:\n
+    if isTransitionPossible(transaction, \'cancel\'):\n
+      transaction.cancel(comment=\'Aborting unknown payzen payment.\')\n
+  else:\n
+    storeWorkflowComment(transaction, \n
+                         \'Error code 2 (Not found) did not changed the document state.\')\n
+  return\n
+\n
+elif error_code == \'0\':\n
+  transaction_code_mapping = {\n
     \'0\': \'Initial (being treated)\',\n
     \'1\': \'To be validated \',\n
     \'2\': \'To be forced - Contact issuer\',\n
@@ -84,21 +103,20 @@ transaction_code_mapping = {\n
     \'11\': \'Being submitted\',\n
     \'12\': \'Being authorized\',\n
     \'13\': \'Failed\',\n
-}\n
-mark_transaction_id_list = [\'0\', \'1\', \'3\', \'4\', \'5\', \'10\', \'11\', \'12\']\n
-continue_transaction_id_list = [\'6\']\n
+  }\n
+  mark_transaction_id_list = [\'0\', \'1\', \'3\', \'4\', \'5\', \'10\', \'11\', \'12\']\n
+  continue_transaction_id_list = [\'6\']\n
 \n
-transaction_status = data_kw[\'transactionStatus\']\n
+  transaction_status = data_kw[\'transactionStatus\']\n
 \n
-transaction_status_description = transaction_code_mapping.get(transaction_status, None)\n
-if transaction_status_description is None:\n
+  transaction_status_description = transaction_code_mapping.get(transaction_status, None)\n
+  if transaction_status_description is None:\n
     payzen_event.confirm(comment=\'Unknown transactionStatus %r\' % transaction_status)\n
     return\n
 \n
-isTransitionPossible = context.getPortalObject().portal_workflow.isTransitionPossible\n
-doActionFor = context.getPortalObject().portal_workflow.doActionFor\n
+  doActionFor = context.getPortalObject().portal_workflow.doActionFor\n
 \n
-if transaction_status in mark_transaction_id_list:\n
+  if transaction_status in mark_transaction_id_list:\n
     # Mark on payment transaction history log that transaction was not processed yet\n
     storeWorkflowComment(transaction, \'Transaction status %s (%s) did not changed the document state\' % (transaction_status, transaction_status_description))\n
     payzen_event.confirm()\n
@@ -106,7 +124,7 @@ if transaction_status in mark_transaction_id_list:\n
     if isTransitionPossible(transaction, \'confirm\'):\n
       transaction.confirm(comment=\'Confirmed as really saw in PayZen.\')\n
 \n
-elif transaction_status in continue_transaction_id_list:\n
+  elif transaction_status in continue_transaction_id_list:\n
     # Check authAmount and authDevise and if match, stop transaction\n
     auth_amount = int(data_kw[\'authAmount\'])\n
     auth_devise = data_kw[\'authDevise\']\n
@@ -135,11 +153,17 @@ elif transaction_status in continue_transaction_id_list:\n
     else:\n
       payzen_event.confirm(comment=\'Expected to put transaction in stopped state, but achieved only %s state\' % transaction.getSimulationState())\n
 \n
-else:\n
+  else:\n
     payzen_event.confirm(comment=\'Transaction status %r (%r) is not supported\' \\\n
                            % (transaction_status, transaction_status_description))\n
     return\n
-</string> </value>
+\n
+else:\n
+  # Unknown errorCode\n
+  payzen_event.confirm(comment=\'Unknown errorCode %r\' % error_code)\n
+
+
+]]></string> </value>
         </item>
         <item>
             <key> <string>_params</string> </key>

master/bt5/slapos_payzen/TestTemplateItem/testSlapOSPayzenSkins.py

@@ -4,6 +4,7 @@ from Products.SlapOS.tests.testSlapOSMixin import \
   testSlapOSMixin
 from DateTime import DateTime
 from zExceptions import Unauthorized
+from Products.ERP5Type.tests.utils import createZODBPythonScript
 
 class TestSlapOSPaymentTransaction_sendManualPayzenPaymentUrl(testSlapOSMixin):
 
@@ -375,6 +376,22 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
       event.PayzenEvent_processUpdate,
       'a', True)
 
+  def test_processUpdate_unknownErrorCode(self):
+    date = DateTime()
+    event = self.createPayzenEvent()
+    payment = self.createPaymentTransaction()
+    event.edit(destination_value=payment)
+
+    data_kw = {
+      'errorCode': 'foo',
+    }
+
+    event.PayzenEvent_processUpdate(data_kw, True)
+    self.assertEquals(event.getValidationState(), "confirmed")
+    self.assertEqual(
+        "Unknown errorCode 'foo'",
+        event.workflow_history['system_event_workflow'][-1]['comment'])
+
   def test_processUpdate_unknownTransactionStatus(self):
     date = DateTime()
     event = self.createPayzenEvent()
@@ -382,6 +399,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': 'foo',
     }
 
@@ -398,6 +416,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '2',
     }
 
@@ -416,6 +435,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '0',
     }
 
@@ -444,6 +464,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '0',
     }
     event.PayzenEvent_processUpdate(data_kw, True)
@@ -456,6 +477,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
     }
 
@@ -472,6 +494,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
       'authAmount': 1,
     }
@@ -489,6 +512,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
       'authAmount': 1,
       'authDevise': 1,
@@ -512,6 +536,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
       'authAmount': 0,
       'authDevise': "dollars",
@@ -536,6 +561,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
       'authAmount': 0,
       'authDevise': '978',
@@ -559,6 +585,7 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
     event.edit(destination_value=payment)
 
     data_kw = {
+      'errorCode': '0',
       'transactionStatus': '6',
       'authAmount': 0,
       'authDevise': '978',
@@ -572,6 +599,79 @@ class TestSlapOSPayzenEvent_processUpdate(testSlapOSMixin):
         'Automatic acknowledge as result of correct communication',
         event.workflow_history['system_event_workflow'][-1]['comment'])
 
+  def _simulatePaymentTransaction_getRecentPayzenId(self):
+    script_name = 'PaymentTransaction_getPayzenId'
+    if script_name in self.portal.portal_skins.custom.objectIds():
+      raise ValueError('Precondition failed: %s exists in custom' % script_name)
+    createZODBPythonScript(self.portal.portal_skins.custom,
+                        script_name,
+                        '*args, **kwargs',
+                        '# Script body\n'
+"""return DateTime().toZone('UTC'), 'foo'""")
+
+  def _simulatePaymentTransaction_getOldPayzenId(self):
+    script_name = 'PaymentTransaction_getPayzenId'
+    if script_name in self.portal.portal_skins.custom.objectIds():
+      raise ValueError('Precondition failed: %s exists in custom' % script_name)
+    createZODBPythonScript(self.portal.portal_skins.custom,
+                        script_name,
+                        '*args, **kwargs',
+                        '# Script body\n'
+"""from Products.ERP5Type.DateUtils import addToDate
+return addToDate(DateTime(), to_add={'day': -1, 'second': -1}).toZone('UTC'), 'foo'""")
+
+  def _dropPaymentTransaction_getPayzenId(self):
+    script_name = 'PaymentTransaction_getPayzenId'
+    if script_name in self.portal.portal_skins.custom.objectIds():
+      self.portal.portal_skins.custom.manage_delObjects(script_name)
+
+  def test_processUpdate_recentNotFoundOnPayzenSide(self):
+    event = self.createPayzenEvent()
+    payment = self.createPaymentTransaction()
+    event.edit(destination_value=payment)
+
+    data_kw = {
+      'errorCode': '2',
+    }
+
+    self._simulatePaymentTransaction_getRecentPayzenId()
+    try:
+      event.PayzenEvent_processUpdate(data_kw, True)
+    finally:
+      self._dropPaymentTransaction_getPayzenId()
+
+    self.assertEquals(event.getValidationState(), "acknowledged")
+    self.assertEqual(
+        'Transaction not found on payzen side.',
+        event.workflow_history['system_event_workflow'][-1]['comment'])
+    self.assertNotEquals(payment.getSimulationState(), "cancelled")
+    self.assertEqual(
+        'Error code 2 (Not found) did not changed the document state.',
+        payment.workflow_history['edit_workflow'][-1]['comment'])
+
+  def test_processUpdate_oldNotFoundOnPayzenSide(self):
+    event = self.createPayzenEvent()
+    payment = self.createPaymentTransaction()
+    event.edit(destination_value=payment)
+
+    data_kw = {
+      'errorCode': '2',
+    }
+
+    self._simulatePaymentTransaction_getOldPayzenId()
+    try:
+      event.PayzenEvent_processUpdate(data_kw, True)
+    finally:
+      self._dropPaymentTransaction_getPayzenId()
+
+    self.assertEquals(event.getValidationState(), "acknowledged")
+    self.assertEqual(
+        'Transaction not found on payzen side.',
+        event.workflow_history['system_event_workflow'][-1]['comment'])
+    self.assertEquals(payment.getSimulationState(), "cancelled")
+    self.assertEqual(
+        'Aborting unknown payzen payment.',
+        payment.workflow_history['accounting_workflow'][-1]['comment'])
 
 class TestSlapOSPayzenBase_getPayzenServiceRelativeUrl(testSlapOSMixin):
 

master/bt5/slapos_payzen/bt/revision

-97
+98
\ No newline at end of file