# Copyright (c) 2015, Frappe Technologies Pvt. Ltd. and Contributors # License: GNU General Public License v3. See license.txt from __future__ import unicode_literals import frappe from frappe import _ from frappe.utils import flt, cint, getdate def execute(filters=None): if not filters: filters = {} validate_filters(filters) columns = get_columns() item_map = get_item_details(filters) item_reorder_detail_map = get_item_reorder_details(filters) iwb_map = get_item_warehouse_map(filters) data = [] for (company, item, warehouse) in sorted(iwb_map): qty_dict = iwb_map[(company, item, warehouse)] item_reorder_level = 0 item_reorder_qty = 0 if item + warehouse in item_reorder_detail_map: item_reorder_level = item_reorder_detail_map[item + warehouse]["warehouse_reorder_level"] item_reorder_qty = item_reorder_detail_map[item + warehouse]["warehouse_reorder_qty"] data.append([item, item_map[item]["item_name"], item_map[item]["item_group"], item_map[item]["brand"], item_map[item]["description"], warehouse, item_map[item]["stock_uom"], qty_dict.opening_qty, qty_dict.opening_val, qty_dict.in_qty, qty_dict.in_val, qty_dict.out_qty, qty_dict.out_val, qty_dict.bal_qty, qty_dict.bal_val, qty_dict.val_rate, item_reorder_level, item_reorder_qty, company ]) return columns, data def get_columns(): """return columns""" columns = [ _("Item")+":Link/Item:100", _("Item Name")+"::150", _("Item Group")+"::100", _("Brand")+"::90", _("Description")+"::140", _("Warehouse")+":Link/Warehouse:100", _("Stock UOM")+":Link/UOM:90", _("Opening Qty")+":Float:100", _("Opening Value")+":Float:110", _("In Qty")+":Float:80", _("In Value")+":Float:80", _("Out Qty")+":Float:80", _("Out Value")+":Float:80", _("Balance Qty")+":Float:100", _("Balance Value")+":Float:100", _("Valuation Rate")+":Float:90", _("Reorder Lvl")+":Float:80", _("Reorder Qty")+":Float:80", _("Company")+":Link/Company:100" ] return columns def get_conditions(filters): conditions = "" if not filters.get("from_date"): frappe.throw(_("'From Date' is required")) if filters.get("to_date"): conditions += " and sle.posting_date <= '%s'" % frappe.db.escape(filters.get("to_date")) else: frappe.throw(_("'To Date' is required")) if filters.get("item_group"): ig_details = frappe.db.get_value("Item Group", filters.get("item_group"), ["lft", "rgt"], as_dict=1) if ig_details: conditions += """ and exists (select name from `tabItem Group` ig where ig.lft >= %s and ig.rgt <= %s and item.item_group = ig.name) """ % (ig_details.lft, ig_details.rgt) if filters.get("item_code"): conditions += " and sle.item_code = '%s'" % frappe.db.escape(filters.get("item_code"), percent=False) if filters.get("warehouse"): warehouse_details = frappe.db.get_value("Warehouse", filters.get("warehouse"), ["lft", "rgt"], as_dict=1) if warehouse_details: conditions += " and exists (select name from `tabWarehouse` wh \ where wh.lft >= %s and wh.rgt <= %s and sle.warehouse = wh.name)"%(warehouse_details.lft, warehouse_details.rgt) return conditions def get_stock_ledger_entries(filters): conditions = get_conditions(filters) join_table_query = "" if filters.get("item_group"): join_table_query = "inner join `tabItem` item on item.name = sle.item_code" return frappe.db.sql(""" select sle.item_code, warehouse, sle.posting_date, sle.actual_qty, sle.valuation_rate, sle.company, sle.voucher_type, sle.qty_after_transaction, sle.stock_value_difference from `tabStock Ledger Entry` sle force index (posting_sort_index) %s where sle.docstatus < 2 %s order by sle.posting_date, sle.posting_time, sle.name""" % (join_table_query, conditions), as_dict=1) def get_item_warehouse_map(filters): iwb_map = {} from_date = getdate(filters.get("from_date")) to_date = getdate(filters.get("to_date")) sle = get_stock_ledger_entries(filters) for d in sle: key = (d.company, d.item_code, d.warehouse) if key not in iwb_map: iwb_map[key] = frappe._dict({ "opening_qty": 0.0, "opening_val": 0.0, "in_qty": 0.0, "in_val": 0.0, "out_qty": 0.0, "out_val": 0.0, "bal_qty": 0.0, "bal_val": 0.0, "val_rate": 0.0 }) qty_dict = iwb_map[(d.company, d.item_code, d.warehouse)] if d.voucher_type == "Stock Reconciliation": qty_diff = flt(d.qty_after_transaction) - qty_dict.bal_qty else: qty_diff = flt(d.actual_qty) value_diff = flt(d.stock_value_difference) if d.posting_date < from_date: qty_dict.opening_qty += qty_diff qty_dict.opening_val += value_diff elif d.posting_date >= from_date and d.posting_date <= to_date: if qty_diff > 0: qty_dict.in_qty += qty_diff qty_dict.in_val += value_diff else: qty_dict.out_qty += abs(qty_diff) qty_dict.out_val += abs(value_diff) qty_dict.val_rate = d.valuation_rate qty_dict.bal_qty += qty_diff qty_dict.bal_val += value_diff iwb_map = filter_items_with_no_transactions(iwb_map) return iwb_map def filter_items_with_no_transactions(iwb_map): for (company, item, warehouse) in sorted(iwb_map): qty_dict = iwb_map[(company, item, warehouse)] no_transactions = True float_precision = cint(frappe.db.get_default("float_precision")) or 3 for key, val in qty_dict.items(): val = flt(val, float_precision) qty_dict[key] = val if key != "val_rate" and val: no_transactions = False if no_transactions: iwb_map.pop((company, item, warehouse)) return iwb_map def get_item_details(filters): condition = '' value = () if filters.get("item_code"): condition = "where item_code=%s" value = (filters.get("item_code"),) items = frappe.db.sql("""select name, item_name, stock_uom, item_group, brand, description from tabItem {condition}""".format(condition=condition), value, as_dict=1) return dict((d.name , d) for d in items) def get_item_reorder_details(filters): condition = '' value = () if filters.get("item_code"): condition = "where parent=%s" value = (filters.get("item_code"),) item_reorder_details = frappe.db.sql("""select parent,warehouse,warehouse_reorder_qty,warehouse_reorder_level from `tabItem Reorder` {condition}""".format(condition=condition), value, as_dict=1) return dict((d.parent + d.warehouse, d) for d in item_reorder_details) def validate_filters(filters): if not (filters.get("item_code") or filters.get("warehouse")): sle_count = flt(frappe.db.sql("""select count(name) from `tabStock Ledger Entry`""")[0][0]) if sle_count > 500000: frappe.throw(_("Please set filter based on Item or Warehouse"))