brotherton-erpnext/erpnext/startup/leaderboard.py

206 lines
6.9 KiB
Python
Raw Normal View History

2019-09-24 07:34:53 +00:00
from __future__ import unicode_literals, print_function
import frappe
2019-09-30 07:39:12 +00:00
from frappe.utils import cint
2019-09-24 07:34:53 +00:00
def get_leaderboards():
leaderboards = {
2019-09-26 08:11:24 +00:00
"Customer": {
2019-09-27 09:39:40 +00:00
"fields": [
{'fieldname': 'total_sales_amount', 'fieldtype': 'Currency'},
'total_qty_sold',
{'fieldname': 'outstanding_amount', 'fieldtype': 'Currency'}
],
2019-09-26 08:11:24 +00:00
"method": "erpnext.startup.leaderboard.get_all_customers",
2020-10-16 06:01:47 +00:00
"icon": "customer"
2019-09-26 08:11:24 +00:00
},
"Item": {
2019-09-27 09:39:40 +00:00
"fields": [
{'fieldname': 'total_sales_amount', 'fieldtype': 'Currency'},
2019-09-27 10:58:08 +00:00
'total_qty_sold',
2019-09-27 09:39:40 +00:00
{'fieldname': 'total_purchase_amount', 'fieldtype': 'Currency'},
'total_qty_purchased',
'available_stock_qty',
{'fieldname': 'available_stock_value', 'fieldtype': 'Currency'}
],
2019-09-26 08:11:24 +00:00
"method": "erpnext.startup.leaderboard.get_all_items",
2020-10-16 06:01:47 +00:00
"icon": "stock"
2019-09-26 08:11:24 +00:00
},
"Supplier": {
2019-09-27 09:39:40 +00:00
"fields": [
{'fieldname': 'total_purchase_amount', 'fieldtype': 'Currency'},
'total_qty_purchased',
{'fieldname': 'outstanding_amount', 'fieldtype': 'Currency'}
],
2019-09-26 08:11:24 +00:00
"method": "erpnext.startup.leaderboard.get_all_suppliers",
2020-10-16 06:01:47 +00:00
"icon": "buying"
2019-09-26 08:11:24 +00:00
},
"Sales Partner": {
2019-09-27 09:39:40 +00:00
"fields": [
{'fieldname': 'total_sales_amount', 'fieldtype': 'Currency'},
{'fieldname': 'total_commission', 'fieldtype': 'Currency'}
],
2019-09-26 08:11:24 +00:00
"method": "erpnext.startup.leaderboard.get_all_sales_partner",
2020-10-16 06:01:47 +00:00
"icon": "hr"
2019-09-26 08:11:24 +00:00
},
"Sales Person": {
2019-09-27 09:39:40 +00:00
"fields": [
{'fieldname': 'total_sales_amount', 'fieldtype': 'Currency'}
],
2019-09-26 08:11:24 +00:00
"method": "erpnext.startup.leaderboard.get_all_sales_person",
2020-10-16 06:01:47 +00:00
"icon": "customer"
2019-09-26 08:11:24 +00:00
}
2019-09-24 07:34:53 +00:00
}
return leaderboards
2019-09-30 05:42:10 +00:00
@frappe.whitelist()
def get_all_customers(date_range, company, field, limit = None):
2019-09-24 07:34:53 +00:00
if field == "outstanding_amount":
2019-09-26 08:11:24 +00:00
filters = [['docstatus', '=', '1'], ['company', '=', company]]
if date_range:
date_range = frappe.parse_json(date_range)
filters.append(['posting_date', '>=', 'between', [date_range[0], date_range[1]]])
2019-09-26 08:11:24 +00:00
return frappe.db.get_all('Sales Invoice',
fields = ['customer as name', 'sum(outstanding_amount) as value'],
filters = filters,
group_by = 'customer',
order_by = 'value desc',
limit = limit
)
2019-09-24 07:34:53 +00:00
else:
if field == "total_sales_amount":
select_field = "sum(so_item.base_net_amount)"
elif field == "total_qty_sold":
select_field = "sum(so_item.stock_qty)"
date_condition = get_date_condition(date_range, 'so.transaction_date')
2019-09-24 07:34:53 +00:00
return frappe.db.sql("""
select so.customer as name, {0} as value
FROM `tabSales Order` as so JOIN `tabSales Order Item` as so_item
ON so.name = so_item.parent
where so.docstatus = 1 {1} and so.company = %s
2019-09-24 07:34:53 +00:00
group by so.customer
order by value DESC
2019-09-30 07:39:12 +00:00
limit %s
""".format(select_field, date_condition), (company, cint(limit)), as_dict=1)
2019-09-24 07:34:53 +00:00
2019-09-30 05:42:10 +00:00
@frappe.whitelist()
def get_all_items(date_range, company, field, limit = None):
2019-09-24 07:34:53 +00:00
if field in ("available_stock_qty", "available_stock_value"):
2019-09-26 08:11:24 +00:00
select_field = "sum(actual_qty)" if field=="available_stock_qty" else "sum(stock_value)"
return frappe.db.get_all('Bin',
fields = ['item_code as name', '{0} as value'.format(select_field)],
group_by = 'item_code',
order_by = 'value desc',
limit = limit
)
2019-09-24 07:34:53 +00:00
else:
if field == "total_sales_amount":
select_field = "sum(order_item.base_net_amount)"
select_doctype = "Sales Order"
elif field == "total_purchase_amount":
select_field = "sum(order_item.base_net_amount)"
select_doctype = "Purchase Order"
elif field == "total_qty_sold":
select_field = "sum(order_item.stock_qty)"
select_doctype = "Sales Order"
elif field == "total_qty_purchased":
select_field = "sum(order_item.stock_qty)"
select_doctype = "Purchase Order"
date_condition = get_date_condition(date_range, 'sales_order.transaction_date')
2019-09-24 07:34:53 +00:00
return frappe.db.sql("""
select order_item.item_code as name, {0} as value
from `tab{1}` sales_order join `tab{1} Item` as order_item
on sales_order.name = order_item.parent
where sales_order.docstatus = 1
and sales_order.company = %s {2}
2019-09-24 07:34:53 +00:00
group by order_item.item_code
order by value desc
2019-09-30 07:39:12 +00:00
limit %s
""".format(select_field, select_doctype, date_condition), (company, cint(limit)), as_dict=1) #nosec
2019-09-24 07:34:53 +00:00
2019-09-30 05:42:10 +00:00
@frappe.whitelist()
def get_all_suppliers(date_range, company, field, limit = None):
2019-09-24 07:34:53 +00:00
if field == "outstanding_amount":
2019-09-26 08:11:24 +00:00
filters = [['docstatus', '=', '1'], ['company', '=', company]]
if date_range:
2020-09-03 14:15:04 +00:00
date_range = frappe.parse_json(date_range)
filters.append(['posting_date', 'between', [date_range[0], date_range[1]]])
2019-09-26 08:11:24 +00:00
return frappe.db.get_all('Purchase Invoice',
fields = ['supplier as name', 'sum(outstanding_amount) as value'],
filters = filters,
group_by = 'supplier',
order_by = 'value desc',
limit = limit
)
2019-09-24 07:34:53 +00:00
else:
if field == "total_purchase_amount":
select_field = "sum(purchase_order_item.base_net_amount)"
elif field == "total_qty_purchased":
select_field = "sum(purchase_order_item.stock_qty)"
date_condition = get_date_condition(date_range, 'purchase_order.modified')
2019-09-24 07:34:53 +00:00
return frappe.db.sql("""
select purchase_order.supplier as name, {0} as value
FROM `tabPurchase Order` as purchase_order LEFT JOIN `tabPurchase Order Item`
as purchase_order_item ON purchase_order.name = purchase_order_item.parent
where
purchase_order.docstatus = 1
{1}
2019-09-24 07:34:53 +00:00
and purchase_order.company = %s
group by purchase_order.supplier
order by value DESC
limit %s""".format(select_field, date_condition), (company, cint(limit)), as_dict=1) #nosec
2019-09-24 07:34:53 +00:00
2019-09-30 05:42:10 +00:00
@frappe.whitelist()
def get_all_sales_partner(date_range, company, field, limit = None):
2019-09-24 07:34:53 +00:00
if field == "total_sales_amount":
2019-09-30 07:39:12 +00:00
select_field = "sum(`base_net_total`)"
2019-09-24 07:34:53 +00:00
elif field == "total_commission":
2019-09-30 07:39:12 +00:00
select_field = "sum(`total_commission`)"
2019-09-24 07:34:53 +00:00
2019-09-30 07:39:12 +00:00
filters = {
'sales_partner': ['!=', ''],
'docstatus': 1,
'company': company
}
if date_range:
date_range = frappe.parse_json(date_range)
filters['transaction_date'] = ['between', [date_range[0], date_range[1]]]
2019-09-30 07:39:12 +00:00
return frappe.get_list('Sales Order', fields=[
'`sales_partner` as name',
'{} as value'.format(select_field),
], filters=filters, group_by='sales_partner', order_by='value DESC', limit=limit)
2019-09-24 07:34:53 +00:00
2019-09-30 05:42:10 +00:00
@frappe.whitelist()
def get_all_sales_person(date_range, company, field = None, limit = 0):
date_condition = get_date_condition(date_range, 'sales_order.transaction_date')
2019-09-24 07:34:53 +00:00
return frappe.db.sql("""
select sales_team.sales_person as name, sum(sales_order.base_net_total) as value
from `tabSales Order` as sales_order join `tabSales Team` as sales_team
on sales_order.name = sales_team.parent and sales_team.parenttype = 'Sales Order'
where sales_order.docstatus = 1
and sales_order.company = %s
{date_condition}
2019-09-24 07:34:53 +00:00
group by sales_team.sales_person
order by value DESC
2019-09-30 07:39:12 +00:00
limit %s
""".format(date_condition=date_condition), (company, cint(limit)), as_dict=1)
def get_date_condition(date_range, field):
date_condition = ''
if date_range:
date_range = frappe.parse_json(date_range)
from_date, to_date = date_range
date_condition = "and {0} between {1} and {2}".format(
field, frappe.db.escape(from_date), frappe.db.escape(to_date)
)
return date_condition