nsinnovations/erpnext
2
0
Fork 0
mirror of https://github.com/frappe/erpnext.git synced 2026-05-27 00:44:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: handle PR's in advance stage

Browse Source 
(cherry picked from commit 18c13a2cff)
This commit is contained in:
ruthra kumar
2024-11-06 17:58:22 +05:30
committed by Mergify
parent eeff0a1252
commit ff4751c9e8
1 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
erpnext/accounts/doctype/payment_request/payment_request.py
View File

@@ -691,6 +691,21 @@ def get_amount(ref_doc, payment_account=None):
frappe.throw(_("Payment Entry is already created")) frappe.throw(_("Payment Entry is already created"))
def get_irequest_status(payment_requests: None | list = None) -> list:
IR = frappe.qb.DocType("Integration Request")
res = []
if payment_requests:
res = (
frappe.qb.from_(IR)
.select(IR.name)
.where(IR.reference_doctype.eq("Payment Request"))
.where(IR.reference_docname.isin(payment_requests))
.where(IR.status.isin(["Authorized", "Completed"]))
.run(as_dict=True)
)
return res
def cancel_old_payment_requests(ref_dt, ref_dn): def cancel_old_payment_requests(ref_dt, ref_dn):
PR = frappe.qb.DocType("Payment Request") PR = frappe.qb.DocType("Payment Request")
@@ -703,14 +718,17 @@ def cancel_old_payment_requests(ref_dt, ref_dn):
.where(PR.status.isin(["Draft", "Requested"])) .where(PR.status.isin(["Draft", "Requested"]))
.run(as_dict=True) .run(as_dict=True)
): ):
for x in res: if get_irequest_status([x.name for x in res]):
doc = frappe.get_doc("Payment Request", x.name) frappe.throw(_("Another Payment Request is already processed"))
doc.flags.ignore_permissions = True else:
doc.cancel() for x in res:
doc = frappe.get_doc("Payment Request", x.name)
doc.flags.ignore_permissions = True
doc.cancel()
if ireqs := get_irequests_of_payment_request(doc.name): if ireqs := get_irequests_of_payment_request(doc.name):
for ireq in ireqs: for ireq in ireqs:
frappe.db.set_value("Integration Request", ireq.name, "status", "Cancelled") frappe.db.set_value("Integration Request", ireq.name, "status", "Cancelled")
def get_existing_payment_request_amount(ref_dt, ref_dn, statuses: list | None = None) -> list: def get_existing_payment_request_amount(ref_dt, ref_dn, statuses: list | None = None) -> list: