fix: get customers for leaderboard

(cherry picked from commit 137b5a610880684b1c08d868072335debceb3007)
This commit is contained in:
barredterra 2023-12-11 18:32:49 +01:00 committed by Mergify
parent dd07ecad45
commit 9d5c79d6b2

View File

@ -54,12 +54,13 @@ def get_leaderboards():
@frappe.whitelist() @frappe.whitelist()
def get_all_customers(date_range, company, field, limit=None): def get_all_customers(date_range, company, field, limit=None):
filters = [["docstatus", "=", "1"], ["company", "=", company]]
from_date, to_date = parse_date_range(date_range)
if field == "outstanding_amount": if field == "outstanding_amount":
filters = [["docstatus", "=", "1"], ["company", "=", company]] if from_date and to_date:
if date_range: filters.append(["posting_date", "between", [from_date, to_date]])
date_range = frappe.parse_json(date_range)
filters.append(["posting_date", ">=", "between", [date_range[0], date_range[1]]]) return frappe.get_list(
return frappe.db.get_all(
"Sales Invoice", "Sales Invoice",
fields=["customer as name", "sum(outstanding_amount) as value"], fields=["customer as name", "sum(outstanding_amount) as value"],
filters=filters, filters=filters,
@ -69,26 +70,20 @@ def get_all_customers(date_range, company, field, limit=None):
) )
else: else:
if field == "total_sales_amount": if field == "total_sales_amount":
select_field = "sum(so_item.base_net_amount)" select_field = "base_net_total"
elif field == "total_qty_sold": elif field == "total_qty_sold":
select_field = "sum(so_item.stock_qty)" select_field = "total_qty"
date_condition = get_date_condition(date_range, "so.transaction_date") if from_date and to_date:
filters.append(["transaction_date", "between", [from_date, to_date]])
return frappe.db.sql( return frappe.get_list(
""" "Sales Order",
select so.customer as name, {0} as value fields=["customer as name", f"sum({select_field}) as value"],
FROM `tabSales Order` as so JOIN `tabSales Order Item` as so_item filters=filters,
ON so.name = so_item.parent group_by="customer",
where so.docstatus = 1 {1} and so.company = %s order_by="value desc",
group by so.customer limit=limit,
order by value DESC
limit %s
""".format(
select_field, date_condition
),
(company, cint(limit)),
as_dict=1,
) )
@ -236,3 +231,11 @@ def get_date_condition(date_range, field):
field, frappe.db.escape(from_date), frappe.db.escape(to_date) field, frappe.db.escape(from_date), frappe.db.escape(to_date)
) )
return date_condition return date_condition
def parse_date_range(date_range):
if date_range:
date_range = frappe.parse_json(date_range)
return date_range[0], date_range[1]
return None, None