Skip to content

feat: Item picker, price history, auto-payment, customer statement #4

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
siva-enfono merged 1 commit into from
May 20, 2026
Merged

feat: Item picker, price history, auto-payment, customer statement #4

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions aqrar_ext/api/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
from .price_history import get_last_sold_price, get_item_insights, get_item_price_history
303 changes: 303 additions & 0 deletions aqrar_ext/api/price_history.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,303 @@
import frappe
from frappe.utils import flt


@frappe.whitelist()
def get_last_sold_price(customer=None, item_code=None, source="sales"):

if not item_code:
return {}

if source == "purchase":
return get_last_purchase_price(customer, item_code)

filters = {
"item_code": item_code
}

customer_condition = ""

if customer:
customer_condition = "AND si.customer = %(customer)s"
filters["customer"] = customer

row = frappe.db.sql(f"""
SELECT
sii.rate
FROM `tabSales Invoice Item` sii
INNER JOIN `tabSales Invoice` si
ON si.name = sii.parent
WHERE
sii.item_code = %(item_code)s
AND si.docstatus = 1
{customer_condition}
ORDER BY
si.posting_date DESC,
si.creation DESC
LIMIT 1
""", filters, as_dict=True)

# fallback general last sold price
if not row:

row = frappe.db.sql("""
SELECT
sii.rate
FROM `tabSales Invoice Item` sii
INNER JOIN `tabSales Invoice` si
ON si.name = sii.parent
WHERE
sii.item_code = %(item_code)s
AND si.docstatus = 1
ORDER BY
si.posting_date DESC,
si.creation DESC
LIMIT 1
""", filters, as_dict=True)

return {
"last_price": flt(row[0].rate) if row else 0
}


def get_last_purchase_price(supplier=None, item_code=None):

filters = {"item_code": item_code}
supplier_condition = ""

if supplier:
supplier_condition = "AND pi.supplier = %(supplier)s"
filters["supplier"] = supplier

row = frappe.db.sql(f"""
SELECT
pii.rate
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %(item_code)s
AND pi.docstatus = 1
{supplier_condition}
ORDER BY
pi.posting_date DESC,
pi.creation DESC
LIMIT 1
""", filters, as_dict=True)

if not row:

row = frappe.db.sql("""
SELECT
pii.rate
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %(item_code)s
AND pi.docstatus = 1
ORDER BY
pi.posting_date DESC,
pi.creation DESC
LIMIT 1
""", filters, as_dict=True)

return {
"last_price": flt(row[0].rate) if row else 0
}


@frappe.whitelist()
def get_item_insights(customer=None, item_code=None, company=None, source="sales"):

stock = frappe.db.sql("""
SELECT
warehouse,
projected_qty
FROM `tabBin`
WHERE item_code = %s
ORDER BY warehouse
""", item_code, as_dict=True)

if source == "purchase":
price_history = frappe.db.sql("""
SELECT
pi.supplier AS customer,
pii.rate,
pi.posting_date
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %s
AND pi.supplier = %s
AND pi.docstatus = 1
ORDER BY
pi.posting_date DESC
LIMIT 10
""", (item_code, customer), as_dict=True)

last_purchase = frappe.db.sql("""
SELECT
pii.rate
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %s
AND pi.docstatus = 1
ORDER BY
pi.posting_date DESC
LIMIT 1
""", item_code, as_dict=True)

return {
"stock": stock,
"price_history": price_history,
"last_purchase_rate":
last_purchase[0].rate if last_purchase else 0
}

price_history = frappe.db.sql("""
SELECT
si.customer,
sii.rate,
si.posting_date
FROM `tabSales Invoice Item` sii
INNER JOIN `tabSales Invoice` si
ON si.name = sii.parent
WHERE
sii.item_code = %s
AND si.customer = %s
AND si.docstatus = 1
ORDER BY
si.posting_date DESC
LIMIT 10
""", (item_code, customer), as_dict=True)

purchase = frappe.db.sql("""
SELECT
pii.rate
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %s
AND pi.docstatus = 1
ORDER BY
pi.posting_date DESC
LIMIT 1
""", item_code, as_dict=True)

return {
"stock": stock,
"price_history": price_history,
"last_purchase_rate":
purchase[0].rate if purchase else 0
}


@frappe.whitelist()
def get_item_price_history(item_code=None, source="sales", customer=None):

if not item_code:
return {"history": [], "last_price": 0, "source": source}

if source == "purchase":
supplier_cond = ""
params = [item_code]
if customer:
supplier_cond = "AND pi.supplier = %s"
params.append(customer)

rows = frappe.db.sql(f"""
SELECT
pii.item_code,
pii.item_name,
pii.parent AS invoice,
pi.supplier AS party,
pii.rate,
pii.qty,
pi.posting_date
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %s
AND pi.docstatus = 1
{supplier_cond}
ORDER BY
pi.posting_date DESC
LIMIT 100
""", params, as_dict=True)

last_price = frappe.db.sql(f"""
SELECT
pii.rate
FROM `tabPurchase Invoice Item` pii
INNER JOIN `tabPurchase Invoice` pi
ON pi.name = pii.parent
WHERE
pii.item_code = %s
AND pi.docstatus = 1
{supplier_cond}
ORDER BY
pi.posting_date DESC,
pi.creation DESC
LIMIT 1
""", params, as_dict=True)

return {
"history": rows,
"last_price": last_price[0].rate if last_price else 0,
"source": "purchase"
}

customer_cond = ""
params = [item_code]
if customer:
customer_cond = "AND si.customer = %s"
params.append(customer)

rows = frappe.db.sql(f"""
SELECT
sii.item_code,
sii.item_name,
sii.parent AS invoice,
si.customer AS party,
sii.rate,
sii.qty,
si.posting_date
FROM `tabSales Invoice Item` sii
INNER JOIN `tabSales Invoice` si
ON si.name = sii.parent
WHERE
sii.item_code = %s
AND si.docstatus = 1
{customer_cond}
ORDER BY
si.posting_date DESC
LIMIT 100
""", params, as_dict=True)

last_price = frappe.db.sql(f"""
SELECT
sii.rate
FROM `tabSales Invoice Item` sii
INNER JOIN `tabSales Invoice` si
ON si.name = sii.parent
WHERE
sii.item_code = %s
AND si.docstatus = 1
{customer_cond}
ORDER BY
si.posting_date DESC,
si.creation DESC
LIMIT 1
""", params, as_dict=True)

return {
"history": rows,
"last_price": last_price[0].rate if last_price else 0,
"source": "sales"
}
Loading
Loading