-
Notifications
You must be signed in to change notification settings - Fork 7.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
chore: move older code into v1 gateway file
- Loading branch information
Showing
2 changed files
with
125 additions
and
102 deletions.
There are no files selected for viewing
119 changes: 119 additions & 0 deletions
119
erpnext/accounts/doctype/payment_request/payment_gateway_v1.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| """Compatipility methods for v1 implementations of payment gateways | ||
| """ | ||
| import json | ||
|
|
||
| import frappe | ||
| from frappe.utils import deprecated, flt | ||
|
|
||
| from erpnext.utilities import payment_app_import_guard | ||
|
|
||
|
|
||
| def _get_payment_controller(*args, **kwargs): | ||
| with payment_app_import_guard(): | ||
| try: | ||
| from payments.utils import get_payment_controller | ||
| except Exception: | ||
| from payments.utils import get_payment_gateway_controller as get_payment_controller | ||
|
|
||
| return get_payment_controller(*args, **kwargs) | ||
|
|
||
|
|
||
| def get_request_amount(self): | ||
| data_of_completed_requests = frappe.get_all( | ||
| "Integration Request", | ||
| filters={ | ||
| "reference_doctype": self.doctype, | ||
| "reference_docname": self.name, | ||
| "status": "Completed", | ||
| }, | ||
| pluck="data", | ||
| ) | ||
| if not data_of_completed_requests: | ||
| return self.grand_total | ||
| request_amounts = sum(json.loads(d).get("request_amount") for d in data_of_completed_requests) | ||
| return request_amounts | ||
|
|
||
|
|
||
| def request_phone_payment(self, controller): | ||
| request_amount = get_request_amount(self) | ||
|
|
||
| payment_record = dict( | ||
| reference_doctype="Payment Request", | ||
| reference_docname=self.name, | ||
| payment_reference=self.reference_name, | ||
| request_amount=request_amount, | ||
| sender=self.email_to, | ||
| currency=self.currency, | ||
| payment_gateway=self.payment_gateway, | ||
| ) | ||
|
|
||
| controller.validate_transaction_currency(self.currency) | ||
| controller.request_for_payment(**payment_record) | ||
|
|
||
|
|
||
| def payment_gateway_validation(self, controller): | ||
| try: | ||
| if hasattr(controller, "on_payment_request_submission"): | ||
| return controller.on_payment_request_submission(self) | ||
| else: | ||
| return True | ||
| except Exception: | ||
| return False | ||
|
|
||
|
|
||
| def get_payment_url(self, controller): | ||
| if self.reference_doctype != "Fees": | ||
| data = frappe.db.get_value( | ||
| self.reference_doctype, self.reference_name, ["company", "customer_name"], as_dict=1 | ||
| ) | ||
| else: | ||
| data = frappe.db.get_value(self.reference_doctype, self.reference_name, ["student_name"], as_dict=1) | ||
| data.update({"company": frappe.defaults.get_defaults().company}) | ||
|
|
||
| controller.validate_transaction_currency(self.currency) | ||
|
|
||
| if hasattr(controller, "validate_minimum_transaction_amount"): | ||
| controller.validate_minimum_transaction_amount(self.currency, self.grand_total) | ||
|
|
||
| return controller.get_payment_url( | ||
| **{ | ||
| "amount": flt(self.grand_total, self.precision("grand_total")), | ||
| "title": data.company.encode("utf-8"), | ||
| "description": self.subject.encode("utf-8"), | ||
| "reference_doctype": "Payment Request", | ||
| "reference_docname": self.name, | ||
| "payer_email": self.email_to or frappe.session.user, | ||
| "payer_name": frappe.safe_encode(data.customer_name), | ||
| "order_id": self.name, | ||
| "currency": self.currency, | ||
| } | ||
| ) | ||
|
|
||
|
|
||
| def set_payment_request_url(self, controller): | ||
| if self.payment_account and self.payment_gateway and payment_gateway_validation(self, controller): | ||
| self.payment_url = get_payment_url(self, controller) | ||
|
|
||
|
|
||
| def v1_gateway_before_submit(self, payment_gateway): | ||
| try: | ||
| controller = _get_payment_controller(payment_gateway) | ||
| except Exception: | ||
| frappe.warnings.warn(f"{payment_gateway} is not a valid gateway; this is normal during tests.") | ||
| return False | ||
| if self.payment_channel == "Phone": | ||
| request_phone_payment(self, controller) | ||
| else: | ||
| set_payment_request_url(self, controller) | ||
| if not (self.mute_email or self.flags.mute_email): | ||
| self.send_email() | ||
| self.make_communication_entry() | ||
|
|
||
|
|
||
| def v1_create_subscription(payment_provider, gateway_controller, data): | ||
| if payment_provider == "stripe": | ||
| with payment_app_import_guard(): | ||
| from payments.payment_gateways.stripe_integration import create_stripe_subscription | ||
|
|
||
| return create_stripe_subscription(gateway_controller, data) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters