238 lines
9.2 KiB
Python
238 lines
9.2 KiB
Python
# Copyright (c) 2013, Web Notes Technologies Pvt. Ltd.
|
|
# License: GNU General Public License v3. See license.txt
|
|
|
|
from __future__ import unicode_literals
|
|
import frappe
|
|
from frappe import _, scrub
|
|
from frappe.utils import getdate, nowdate, flt, cint
|
|
|
|
class ReceivablePayableReport(object):
|
|
def __init__(self, filters=None):
|
|
self.filters = frappe._dict(filters or {})
|
|
self.filters.report_date = getdate(self.filters.report_date or nowdate())
|
|
self.age_as_on = getdate(nowdate()) \
|
|
if self.filters.report_date > getdate(nowdate()) \
|
|
else self.filters.report_date
|
|
|
|
def run(self, args):
|
|
party_naming_by = frappe.db.get_value(args.get("naming_by")[0], None, args.get("naming_by")[1])
|
|
return self.get_columns(party_naming_by, args), self.get_data(party_naming_by, args)
|
|
|
|
def get_columns(self, party_naming_by, args):
|
|
columns = [_("Posting Date") + ":Date:80", _(args.get("party_type")) + ":Link/" + args.get("party_type") + ":200"]
|
|
|
|
if party_naming_by == "Naming Series":
|
|
columns += [args.get("party_type") + " Name::110"]
|
|
|
|
columns += [_("Voucher Type") + "::110", _("Voucher No") + ":Dynamic Link/Voucher Type:120",
|
|
_("Due Date") + ":Date:80"]
|
|
|
|
if args.get("party_type") == "Supplier":
|
|
columns += [_("Bill No") + "::80", _("Bill Date") + ":Date:80"]
|
|
|
|
columns += [_("Invoiced Amount") + ":Currency:100", _("Paid Amount") + ":Currency:100",
|
|
_("Outstanding Amount") + ":Currency:100", _("Age") + ":Int:50",
|
|
"0-" + self.filters.range1 + ":Currency:100",
|
|
self.filters.range1 + "-" + self.filters.range2 + ":Currency:100",
|
|
self.filters.range2 + "-" + self.filters.range3 + ":Currency:100",
|
|
self.filters.range3 + _("-Above") + ":Currency:100"
|
|
]
|
|
|
|
if args.get("party_type") == "Customer":
|
|
columns += [_("Territory") + ":Link/Territory:80"]
|
|
if args.get("party_type") == "Supplier":
|
|
columns += [_("Supplier Type") + ":Link/Supplier Type:80"]
|
|
columns += [_("Remarks") + "::200"]
|
|
|
|
return columns
|
|
|
|
def get_data(self, party_naming_by, args):
|
|
from erpnext.accounts.utils import get_currency_precision
|
|
currency_precision = get_currency_precision() or 2
|
|
data = []
|
|
dr_or_cr = args.get("dr_or_cr")
|
|
future_vouchers = self.get_entries_after(self.filters.report_date, args.get("party_type"))
|
|
|
|
for gle in self.get_entries_till(self.filters.report_date, args.get("party_type")):
|
|
if self.is_receivable_or_payable(gle, args.get("dr_or_cr"), future_vouchers):
|
|
outstanding_amount = self.get_outstanding_amount(gle, self.filters.report_date, args.get("dr_or_cr"))
|
|
if abs(outstanding_amount) > 0.1/10**currency_precision:
|
|
due_date = self.get_due_date(args.get("party_type"), gle)
|
|
invoiced_amount = gle.get(dr_or_cr) if (gle.get(dr_or_cr) > 0) else 0
|
|
paid_amt = invoiced_amount - outstanding_amount
|
|
entry_date = due_date if self.filters.ageing_based_on == "Due Date" else gle.posting_date
|
|
row = [gle.posting_date, gle.party]
|
|
|
|
if party_naming_by == "Naming Series":
|
|
row += [self.get_party_name(gle.party_type, gle.party)]
|
|
|
|
row += [gle.voucher_type, gle.voucher_no, due_date]
|
|
|
|
if args.get("party_type") == "Supplier":
|
|
row += self.get_supplier_bill_data(gle)
|
|
|
|
row += [invoiced_amount, paid_amt, outstanding_amount] + \
|
|
get_ageing_data(cint(self.filters.range1), cint(self.filters.range2), \
|
|
cint(self.filters.range3), self.age_as_on, entry_date, outstanding_amount)
|
|
|
|
if args.get("party_type") == "Customer":
|
|
row += [self.get_territory(gle.party), gle.remarks]
|
|
if args.get("party_type") == "Supplier":
|
|
row += [self.get_supplier_type(gle.party), gle.remarks]
|
|
|
|
data.append(row)
|
|
|
|
return data
|
|
|
|
def get_entries_after(self, report_date, party_type):
|
|
# returns a distinct list
|
|
return list(set([(e.voucher_type, e.voucher_no) for e in self.get_gl_entries(party_type)
|
|
if getdate(e.posting_date) > report_date]))
|
|
|
|
def get_entries_till(self, report_date, party_type):
|
|
# returns a generator
|
|
return (e for e in self.get_gl_entries(party_type)
|
|
if getdate(e.posting_date) <= report_date)
|
|
|
|
def is_receivable_or_payable(self, gle, dr_or_cr, future_vouchers):
|
|
return (
|
|
# advance
|
|
(not gle.against_voucher) or
|
|
|
|
# against sales order/purchase order
|
|
(gle.against_voucher_type in ["Sales Order", "Purchase Order"]) or
|
|
|
|
# sales invoice/purchase invoice
|
|
(gle.against_voucher==gle.voucher_no and gle.get(dr_or_cr) > 0) or
|
|
|
|
# entries adjusted with future vouchers
|
|
((gle.against_voucher_type, gle.against_voucher) in future_vouchers)
|
|
)
|
|
|
|
def get_outstanding_amount(self, gle, report_date, dr_or_cr):
|
|
payment_amount = 0.0
|
|
for e in self.get_gl_entries_for(gle.party, gle.party_type, gle.voucher_type, gle.voucher_no):
|
|
if getdate(e.posting_date) <= report_date and e.name!=gle.name:
|
|
payment_amount += (flt(e.credit if dr_or_cr == "debit" else e.debit) - flt(e.get(dr_or_cr)))
|
|
|
|
return flt(gle.get(dr_or_cr)) - flt(gle.credit if dr_or_cr == "debit" else gle.debit) - payment_amount
|
|
|
|
def get_party_name(self, party_type, party_name):
|
|
return self.get_party_map(party_type).get(party_name, {}).get("customer_name" if party_type == "Customer" else "supplier_name") or ""
|
|
|
|
def get_territory(self, party_name):
|
|
return self.get_party_map("Customer").get(party_name, {}).get("territory") or ""
|
|
|
|
def get_supplier_type(self, party_name):
|
|
return self.get_party_map("Supplier").get(party_name, {}).get("supplier_type") or ""
|
|
|
|
def get_party_map(self, party_type):
|
|
if not hasattr(self, "party_map"):
|
|
if party_type == "Customer":
|
|
self.party_map = dict(((r.name, r) for r in frappe.db.sql("""select {0}, {1}, {2} from `tab{3}`"""
|
|
.format("name", "customer_name", "territory", party_type), as_dict=True)))
|
|
|
|
elif party_type == "Supplier":
|
|
self.party_map = dict(((r.name, r) for r in frappe.db.sql("""select {0}, {1}, {2} from `tab{3}`"""
|
|
.format("name", "supplier_name", "supplier_type", party_type), as_dict=True)))
|
|
|
|
return self.party_map
|
|
|
|
def get_due_date(self, party_type, gle):
|
|
self.get_voucher_details(gle)
|
|
if party_type == "Customer":
|
|
return self.voucher_detail_map.get(gle.voucher_no) if gle.voucher_type == "Sales Invoice" else ""
|
|
elif party_type == "Supplier":
|
|
return self.voucher_detail_map.get(gle.voucher_no).get("due_date") \
|
|
if gle.voucher_type in ["Purchase Invoice", "Journal Voucher"] else ""
|
|
|
|
def get_supplier_bill_data(self, gle):
|
|
self.get_voucher_details(gle)
|
|
return [self.voucher_detail_map.get(gle.voucher_no).get("bill_no"), \
|
|
self.voucher_detail_map.get(gle.voucher_no).get("bill_date")] \
|
|
if gle.voucher_type in ["Purchase Invoice", "Journal Voucher"] else ""
|
|
|
|
def get_voucher_details(self, gle):
|
|
# TODO can be restricted to posting date
|
|
if not hasattr(self, "voucher_detail_map"):
|
|
self.voucher_detail_map = dict(frappe.db.sql("""select name, due_date
|
|
from `tabSales Invoice` where docstatus=1"""))
|
|
|
|
voucher_details = {}
|
|
get_voucher_details = frappe.db.sql("""select name, due_date, bill_no, bill_date
|
|
from `tabPurchase Invoice` where docstatus=1""")
|
|
|
|
for voucher_name, due_date, bill_no, bill_date in get_voucher_details:
|
|
voucher_details.setdefault(voucher_name, {}).update({"due_date": due_date,
|
|
"bill_no": bill_no, "bill_date": bill_date})
|
|
|
|
self.voucher_detail_map.update(voucher_details)
|
|
|
|
def get_gl_entries(self, party_type):
|
|
if not hasattr(self, "gl_entries"):
|
|
conditions, values = self.prepare_conditions(party_type)
|
|
self.gl_entries = frappe.db.sql("""select * from `tabGL Entry`
|
|
where docstatus < 2 and party_type=%(party_type)s {0}
|
|
order by posting_date, party""".format(conditions), values, as_dict=True)
|
|
|
|
return self.gl_entries
|
|
|
|
def prepare_conditions(self, party_type):
|
|
conditions = [""]
|
|
values = {}
|
|
party_type_field = scrub(party_type)
|
|
|
|
if party_type:
|
|
values["party_type"] = party_type
|
|
|
|
if self.filters.company:
|
|
conditions.append("company=%(company)s")
|
|
values["company"] = self.filters.company
|
|
|
|
if self.filters.get(party_type_field):
|
|
conditions.append("party=%(party)s")
|
|
values["party"] = self.filters.get(party_type_field)
|
|
|
|
return " and ".join(conditions), values
|
|
|
|
def get_gl_entries_for(self, party, party_type, against_voucher_type, against_voucher):
|
|
if not hasattr(self, "gl_entries_map"):
|
|
self.gl_entries_map = {}
|
|
for gle in self.get_gl_entries(party_type):
|
|
if gle.against_voucher_type and gle.against_voucher:
|
|
self.gl_entries_map.setdefault(gle.party, {})\
|
|
.setdefault(gle.against_voucher_type, {})\
|
|
.setdefault(gle.against_voucher, [])\
|
|
.append(gle)
|
|
|
|
return self.gl_entries_map.get(party, {})\
|
|
.get(against_voucher_type, {})\
|
|
.get(against_voucher, [])
|
|
|
|
def execute(filters=None):
|
|
args = {
|
|
"party_type": "Customer",
|
|
"dr_or_cr": "debit",
|
|
"naming_by": ["Selling Settings", "cust_master_name"],
|
|
}
|
|
return ReceivablePayableReport(filters).run(args)
|
|
|
|
def get_ageing_data(first_range, second_range, third_range, age_as_on, entry_date, outstanding_amount):
|
|
# [0-30, 30-60, 60-90, 90-above]
|
|
outstanding_range = [0.0, 0.0, 0.0, 0.0]
|
|
|
|
if not (age_as_on and entry_date):
|
|
return [0] + outstanding_range
|
|
|
|
age = (getdate(age_as_on) - getdate(entry_date)).days or 0
|
|
index = None
|
|
for i, days in enumerate([first_range, second_range, third_range]):
|
|
if age <= days:
|
|
index = i
|
|
break
|
|
|
|
if index is None: index = 3
|
|
outstanding_range[index] = outstanding_amount
|
|
|
|
return [age] + outstanding_range
|