schuetz3/schuetz3-erpnext
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: chained callback

Browse Source 
(cherry picked from commit b12ca65fcc)
This commit is contained in:
ruthra kumar
2024-02-04 08:25:18 +05:30
committed by Mergify
parent e56138ddb0
commit b1367e839c
1 changed files with 22 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
erpnext/setup/doctype/transaction_deletion_record/transaction_deletion_record.py
View File

@@ -78,22 +78,37 @@ class TransactionDeletionRecord(Document):
def on_cancel(self): def on_cancel(self):
self.db_set("status", "Cancelled") self.db_set("status", "Cancelled")
def chain_callback(self, method):
frappe.enqueue(
"frappe.utils.background_jobs.run_doc_method",
doctype=self.doctype,
name=self.name,
doc_method=method,
queue="long",
enqueue_after_commit=True,
)
@frappe.whitelist() @frappe.whitelist()
def start_deletion_process(self): def start_deletion_process(self):
self.delete_bins() self.delete_bins()
self.delete_lead_addresses() self.delete_lead_addresses()
self.reset_company_values() self.reset_company_values()
self.delete_notifications()
self.initialize_doctypes_to_be_deleted_table()
self.delete_company_transactions()
def delete_notifications(self):
if not self.clear_notifications: if not self.clear_notifications:
clear_notifications() clear_notifications()
self.db_set("clear_notifications", 1) self.db_set("clear_notifications", 1)
self.initialize_doctypes_to_be_deleted_table() self.chain_callback("initialize_doctypes_to_be_deleted_table")
self.delete_company_transactions()
def populate_doctypes_to_be_ignored_table(self): def populate_doctypes_to_be_ignored_table(self):
doctypes_to_be_ignored_list = get_doctypes_to_be_ignored() doctypes_to_be_ignored_list = get_doctypes_to_be_ignored()
for doctype in doctypes_to_be_ignored_list: for doctype in doctypes_to_be_ignored_list:
self.append("doctypes_to_be_ignored", {"doctype_name": doctype}) self.append("doctypes_to_be_ignored", {"doctype_name": doctype})
@frappe.whitelist()
def delete_bins(self): def delete_bins(self):
if not self.delete_bin_data: if not self.delete_bin_data:
frappe.db.sql( frappe.db.sql(
@@ -102,6 +117,7 @@ class TransactionDeletionRecord(Document):
self.company, self.company,
) )
self.db_set("delete_bin_data", 1) self.db_set("delete_bin_data", 1)
self.chain_callback(method="delete_lead_addresses")
def delete_lead_addresses(self): def delete_lead_addresses(self):
"""Delete addresses to which leads are linked""" """Delete addresses to which leads are linked"""
@@ -142,6 +158,7 @@ class TransactionDeletionRecord(Document):
) )
) )
self.db_set("delete_leads_and_addresses", 1) self.db_set("delete_leads_and_addresses", 1)
self.chain_callback(method="reset_company_values")
def reset_company_values(self): def reset_company_values(self):
if not self.reset_company_default_values: if not self.reset_company_default_values:
@@ -150,6 +167,7 @@ class TransactionDeletionRecord(Document):
company_obj.sales_monthly_history = None company_obj.sales_monthly_history = None
company_obj.save() company_obj.save()
self.db_set("reset_company_default_values", 1) self.db_set("reset_company_default_values", 1)
self.chain_callback(method="delete_notifications")
def initialize_doctypes_to_be_deleted_table(self): def initialize_doctypes_to_be_deleted_table(self):
if not self.initialize_doctypes_table: if not self.initialize_doctypes_table:
@@ -165,6 +183,7 @@ class TransactionDeletionRecord(Document):
# Initialize # Initialize
self.populate_doctypes_table(tables, docfield["parent"], docfield["fieldname"], 0) self.populate_doctypes_table(tables, docfield["parent"], docfield["fieldname"], 0)
self.db_set("initialize_doctypes_table", 1) self.db_set("initialize_doctypes_table", 1)
self.chain_callback(method="delete_company_transactions")
def delete_company_transactions(self): def delete_company_transactions(self):
if not self.delete_transactions: if not self.delete_transactions:
@@ -197,6 +216,7 @@ class TransactionDeletionRecord(Document):
if "#" in naming_series: if "#" in naming_series:
self.update_naming_series(naming_series, docfield.doctype_name) self.update_naming_series(naming_series, docfield.doctype_name)
self.chain_callback(method="delete_company_transactions")
else: else:
frappe.db.set_value(docfield.doctype, docfield.name, "done", 1) frappe.db.set_value(docfield.doctype, docfield.name, "done", 1)
self.db_set("delete_transactions", 1) self.db_set("delete_transactions", 1)