# Part of Odoo. See LICENSE file for full copyright and licensing details. import logging import pprint from werkzeug import urls from odoo import _, models from odoo.exceptions import ValidationError from odoo.addons.payment_xendit import const _logger = logging.getLogger(__name__) class PaymentTransaction(models.Model): _inherit = 'payment.transaction' def _get_specific_rendering_values(self, processing_values): """ Override of `payment` to return Xendit-specific rendering values. Note: self.ensure_one() from `_get_processing_values` :param dict processing_values: The generic and specific processing values of the transaction :return: The dict of provider-specific processing values. :rtype: dict """ res = super()._get_specific_rendering_values(processing_values) if self.provider_code != 'xendit': return res # Initiate the payment and retrieve the invoice data. payload = self._xendit_prepare_invoice_request_payload() _logger.info("Sending invoice request for link creation:\n%s", pprint.pformat(payload)) invoice_data = self.provider_id._xendit_make_request(payload) _logger.info("Received invoice request response:\n%s", pprint.pformat(invoice_data)) # Extract the payment link URL and embed it in the redirect form. rendering_values = { 'api_url': invoice_data.get('invoice_url') } return rendering_values def _xendit_prepare_invoice_request_payload(self): """ Create the payload for the invoice request based on the transaction values. :return: The request payload. :rtype: dict """ base_url = self.provider_id.get_base_url() redirect_url = urls.url_join(base_url, '/payment/status') payload = { 'external_id': self.reference, 'amount': self.amount, 'description': self.reference, 'customer': { 'given_names': self.partner_name, }, 'success_redirect_url': redirect_url, 'failure_redirect_url': redirect_url, 'payment_methods': [const.PAYMENT_METHODS_MAPPING.get( self.payment_method_code, self.payment_method_code.upper()) ], 'currency': self.currency_id.name, } # Extra payload values that must not be included if empty. if self.partner_email: payload['customer']['email'] = self.partner_email if phone := self.partner_id.mobile or self.partner_id.phone: payload['customer']['mobile_number'] = phone address_details = {} if self.partner_city: address_details['city'] = self.partner_city if self.partner_country_id.name: address_details['country'] = self.partner_country_id.name if self.partner_zip: address_details['postal_code'] = self.partner_zip if self.partner_state_id.name: address_details['state'] = self.partner_state_id.name if self.partner_address: address_details['street_line1'] = self.partner_address if address_details: payload['customer']['addresses'] = [address_details] return payload def _get_tx_from_notification_data(self, provider_code, notification_data): """ Override of `payment` to find the transaction based on the notification data. :param str provider_code: The code of the provider that handled the transaction. :param dict notification_data: The notification data sent by the provider. :return: The transaction if found. :rtype: payment.transaction :raise ValidationError: If inconsistent data were received. :raise ValidationError: If the data match no transaction. """ tx = super()._get_tx_from_notification_data(provider_code, notification_data) if provider_code != 'xendit' or len(tx) == 1: return tx reference = notification_data.get('external_id') if not reference: raise ValidationError("Xendit: " + _("Received data with missing reference.")) tx = self.search([('reference', '=', reference), ('provider_code', '=', 'xendit')]) if not tx: raise ValidationError( "Xendit: " + _("No transaction found matching reference %s.", reference) ) return tx def _process_notification_data(self, notification_data): """ Override of `payment` to process the transaction based on Xendit data. Note: self.ensure_one() :param dict notification_data: The notification data sent by the provider. :return: None :raise ValidationError: If inconsistent data were received. """ self.ensure_one() super()._process_notification_data(notification_data) if self.provider_code != 'xendit': return # Update the provider reference. self.provider_reference = notification_data.get('id') # Update payment method. payment_method_code = notification_data.get('payment_method', '') payment_method = self.env['payment.method']._get_from_code( payment_method_code, mapping=const.PAYMENT_METHODS_MAPPING ) self.payment_method_id = payment_method or self.payment_method_id # Update the payment state. payment_status = notification_data.get('status') if payment_status in const.PAYMENT_STATUS_MAPPING['pending']: self._set_pending() elif payment_status in const.PAYMENT_STATUS_MAPPING['done']: self._set_done() elif payment_status in const.PAYMENT_STATUS_MAPPING['cancel']: self._set_canceled() elif payment_status in const.PAYMENT_STATUS_MAPPING['error']: self._set_error(_( "An error occurred during the processing of your payment (status %s). Please try " "again." ))