90 lines
3.8 KiB
Python
90 lines
3.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
#################################################################################
|
|
#
|
|
# Copyright (c) 2015-Present Webkul Software Pvt. Ltd. (<https://webkul.com/>)
|
|
#
|
|
#################################################################################
|
|
import re
|
|
import logging
|
|
|
|
import dateutil.parser
|
|
import pytz
|
|
from odoo import api, fields, models, _
|
|
from odoo.exceptions import ValidationError
|
|
|
|
_logger = logging.getLogger(__name__)
|
|
|
|
|
|
class AcquirerHyperPay(models.Model):
|
|
_inherit = 'payment.acquirer'
|
|
|
|
provider = fields.Selection(selection_add=[('hyperpay', 'HyperPay')], ondelete={'hyperpay': 'set default'})
|
|
hyperpay_authorization = fields.Char('Authorization', required_if_provider='hyperpay', groups='base.group_user', help='Authorization header with Bearer authentication scheme')
|
|
hyperpay_merchant_id = fields.Char(
|
|
'Merchant Id', groups='base.group_user',
|
|
help='The Merchant ID is required to authorize the request')
|
|
|
|
def hyperpay_form_generate_values(self, values):
|
|
hyperpay_tx_values = dict(values)
|
|
if values.get('reference','/') != "/":
|
|
tx = self.env['payment.transaction'].sudo().search([('reference', '=', values.get('reference'))])
|
|
hyperpay_tx_values.update({
|
|
"txId": tx.id
|
|
})
|
|
return hyperpay_tx_values
|
|
|
|
class HyperPayPaymentTransaction(models.Model):
|
|
_inherit = 'payment.transaction'
|
|
|
|
hyperpay_checkout_id = fields.Char('Checkout Id', groups='base.group_user', help='Unique checkout id for every hyper transasction')
|
|
hyperpay_response_payload = fields.Text('Response Payload', help='Response payload from HyperPay')
|
|
|
|
@api.model
|
|
def _hyperpay_form_get_tx_from_data(self, data):
|
|
reference, txn_id = data.get('ndc'), data.get('tx_id')
|
|
if not reference or not txn_id:
|
|
error_msg = _('HyperPay: received data with missing reference (%s) or txn_id (%s)') % (reference, txn_id)
|
|
_logger.info(error_msg)
|
|
raise ValidationError(error_msg)
|
|
|
|
txs = self.env['payment.transaction'].search([('id', '=', int(txn_id))])
|
|
if not txs or len(txs) > 1:
|
|
error_msg = 'HyperPay: received data for reference %s' % (reference)
|
|
if not txs:
|
|
error_msg += '; no order found'
|
|
else:
|
|
error_msg += '; multiple order found'
|
|
_logger.info(error_msg)
|
|
raise ValidationError(error_msg)
|
|
return txs[0]
|
|
|
|
def _hyperpay_form_validate(self, data):
|
|
_logger.info('Validated HyperPay payment for tx %s: set as pending' % (self.reference))
|
|
result = data.get('result')
|
|
result_code = result.get('code')
|
|
res = {
|
|
'acquirer_reference': data.get('id'),
|
|
'state_message': result.get('description', '')
|
|
}
|
|
success_pattern = [
|
|
'^(000\.000\.|000\.100\.1|000\.[36])',
|
|
'^(000\.400\.0[^3]|000\.400\.100)'
|
|
]
|
|
pending_pattern = [
|
|
'^(000\.200)',
|
|
'^(800\.400\.5|100\.400\.500)'
|
|
]
|
|
if re.match(success_pattern[0], result_code) or re.match(success_pattern[1], result_code):
|
|
date_validate = dateutil.parser.parse(data.get('timestamp')).astimezone(pytz.utc).replace(tzinfo=None)
|
|
res.update(acquirer_reference=data.get('id'), date=date_validate)
|
|
self._set_transaction_done()
|
|
elif re.match(pending_pattern[0], result_code) or re.match(pending_pattern[1], result_code):
|
|
self._set_transaction_pending()
|
|
elif re.match('/^(000\.100\.2)/', result_code):
|
|
self._set_transaction_error()
|
|
else:
|
|
error = 'Received unrecognized status for HyperPay payment %s: %s, set as error' % (self.reference, result_code)
|
|
_logger.info(error)
|
|
self._set_transaction_cancel()
|
|
return self.write(res)
|