215 lines
7.4 KiB
Python
215 lines
7.4 KiB
Python
# 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
|
|
import erpnext
|
|
import json
|
|
from frappe.utils import flt, nowdate, add_days, cint
|
|
from frappe import _
|
|
|
|
def reorder_item():
|
|
""" Reorder item if stock reaches reorder level"""
|
|
# if initial setup not completed, return
|
|
if not (frappe.db.a_row_exists("Company") and frappe.db.a_row_exists("Fiscal Year")):
|
|
return
|
|
|
|
if cint(frappe.db.get_value('Stock Settings', None, 'auto_indent')):
|
|
return _reorder_item()
|
|
|
|
def _reorder_item():
|
|
material_requests = {"Purchase": {}, "Transfer": {}, "Material Issue": {}, "Manufacture": {}}
|
|
warehouse_company = frappe._dict(frappe.db.sql("""select name, company from `tabWarehouse`
|
|
where disabled=0"""))
|
|
default_company = (erpnext.get_default_company() or
|
|
frappe.db.sql("""select name from tabCompany limit 1""")[0][0])
|
|
|
|
items_to_consider = frappe.db.sql_list("""select name from `tabItem` item
|
|
where is_stock_item=1 and has_variants=0
|
|
and disabled=0
|
|
and (end_of_life is null or end_of_life='0000-00-00' or end_of_life > %(today)s)
|
|
and (exists (select name from `tabItem Reorder` ir where ir.parent=item.name)
|
|
or (variant_of is not null and variant_of != ''
|
|
and exists (select name from `tabItem Reorder` ir where ir.parent=item.variant_of))
|
|
)""",
|
|
{"today": nowdate()})
|
|
|
|
if not items_to_consider:
|
|
return
|
|
|
|
item_warehouse_projected_qty = get_item_warehouse_projected_qty(items_to_consider)
|
|
|
|
def add_to_material_request(item_code, warehouse, reorder_level, reorder_qty, material_request_type, warehouse_group=None):
|
|
if warehouse not in warehouse_company:
|
|
# a disabled warehouse
|
|
return
|
|
|
|
reorder_level = flt(reorder_level)
|
|
reorder_qty = flt(reorder_qty)
|
|
|
|
# projected_qty will be 0 if Bin does not exist
|
|
if warehouse_group:
|
|
projected_qty = flt(item_warehouse_projected_qty.get(item_code, {}).get(warehouse_group))
|
|
else:
|
|
projected_qty = flt(item_warehouse_projected_qty.get(item_code, {}).get(warehouse))
|
|
|
|
if (reorder_level or reorder_qty) and projected_qty < reorder_level:
|
|
deficiency = reorder_level - projected_qty
|
|
if deficiency > reorder_qty:
|
|
reorder_qty = deficiency
|
|
|
|
company = warehouse_company.get(warehouse) or default_company
|
|
|
|
material_requests[material_request_type].setdefault(company, []).append({
|
|
"item_code": item_code,
|
|
"warehouse": warehouse,
|
|
"reorder_qty": reorder_qty
|
|
})
|
|
|
|
for item_code in items_to_consider:
|
|
item = frappe.get_doc("Item", item_code)
|
|
|
|
if item.variant_of and not item.get("reorder_levels"):
|
|
item.update_template_tables()
|
|
|
|
if item.get("reorder_levels"):
|
|
for d in item.get("reorder_levels"):
|
|
add_to_material_request(item_code, d.warehouse, d.warehouse_reorder_level,
|
|
d.warehouse_reorder_qty, d.material_request_type, warehouse_group=d.warehouse_group)
|
|
|
|
if material_requests:
|
|
return create_material_request(material_requests)
|
|
|
|
def get_item_warehouse_projected_qty(items_to_consider):
|
|
item_warehouse_projected_qty = {}
|
|
|
|
for item_code, warehouse, projected_qty in frappe.db.sql("""select item_code, warehouse, projected_qty
|
|
from tabBin where item_code in ({0})
|
|
and (warehouse != "" and warehouse is not null)"""\
|
|
.format(", ".join(["%s"] * len(items_to_consider))), items_to_consider):
|
|
|
|
if item_code not in item_warehouse_projected_qty:
|
|
item_warehouse_projected_qty.setdefault(item_code, {})
|
|
|
|
if warehouse not in item_warehouse_projected_qty.get(item_code):
|
|
item_warehouse_projected_qty[item_code][warehouse] = flt(projected_qty)
|
|
|
|
warehouse_doc = frappe.get_doc("Warehouse", warehouse)
|
|
|
|
while warehouse_doc.parent_warehouse:
|
|
if not item_warehouse_projected_qty.get(item_code, {}).get(warehouse_doc.parent_warehouse):
|
|
item_warehouse_projected_qty.setdefault(item_code, {})[warehouse_doc.parent_warehouse] = flt(projected_qty)
|
|
else:
|
|
item_warehouse_projected_qty[item_code][warehouse_doc.parent_warehouse] += flt(projected_qty)
|
|
warehouse_doc = frappe.get_doc("Warehouse", warehouse_doc.parent_warehouse)
|
|
|
|
return item_warehouse_projected_qty
|
|
|
|
def create_material_request(material_requests):
|
|
""" Create indent on reaching reorder level """
|
|
mr_list = []
|
|
exceptions_list = []
|
|
|
|
def _log_exception():
|
|
if frappe.local.message_log:
|
|
exceptions_list.extend(frappe.local.message_log)
|
|
frappe.local.message_log = []
|
|
else:
|
|
exceptions_list.append(frappe.get_traceback())
|
|
|
|
frappe.log_error(frappe.get_traceback())
|
|
|
|
for request_type in material_requests:
|
|
for company in material_requests[request_type]:
|
|
try:
|
|
items = material_requests[request_type][company]
|
|
if not items:
|
|
continue
|
|
|
|
mr = frappe.new_doc("Material Request")
|
|
mr.update({
|
|
"company": company,
|
|
"transaction_date": nowdate(),
|
|
"material_request_type": "Material Transfer" if request_type=="Transfer" else request_type
|
|
})
|
|
|
|
for d in items:
|
|
d = frappe._dict(d)
|
|
item = frappe.get_doc("Item", d.item_code)
|
|
uom = item.stock_uom
|
|
conversion_factor = 1.0
|
|
|
|
if request_type == 'Purchase':
|
|
uom = item.purchase_uom or item.stock_uom
|
|
if uom != item.stock_uom:
|
|
conversion_factor = frappe.db.get_value("UOM Conversion Detail",
|
|
{'parent': item.name, 'uom': uom}, 'conversion_factor') or 1.0
|
|
|
|
mr.append("items", {
|
|
"doctype": "Material Request Item",
|
|
"item_code": d.item_code,
|
|
"schedule_date": add_days(nowdate(),cint(item.lead_time_days)),
|
|
"qty": d.reorder_qty / conversion_factor,
|
|
"uom": uom,
|
|
"stock_uom": item.stock_uom,
|
|
"warehouse": d.warehouse,
|
|
"item_name": item.item_name,
|
|
"description": item.description,
|
|
"item_group": item.item_group,
|
|
"brand": item.brand,
|
|
})
|
|
|
|
schedule_dates = [d.schedule_date for d in mr.items]
|
|
mr.schedule_date = max(schedule_dates or [nowdate()])
|
|
mr.flags.ignore_mandatory = True
|
|
mr.insert()
|
|
mr.submit()
|
|
mr_list.append(mr)
|
|
|
|
except:
|
|
_log_exception()
|
|
|
|
if mr_list:
|
|
if getattr(frappe.local, "reorder_email_notify", None) is None:
|
|
frappe.local.reorder_email_notify = cint(frappe.db.get_value('Stock Settings', None,
|
|
'reorder_email_notify'))
|
|
|
|
if(frappe.local.reorder_email_notify):
|
|
send_email_notification(mr_list)
|
|
|
|
if exceptions_list:
|
|
notify_errors(exceptions_list)
|
|
|
|
return mr_list
|
|
|
|
def send_email_notification(mr_list):
|
|
""" Notify user about auto creation of indent"""
|
|
|
|
email_list = frappe.db.sql_list("""select distinct r.parent
|
|
from `tabHas Role` r, tabUser p
|
|
where p.name = r.parent and p.enabled = 1 and p.docstatus < 2
|
|
and r.role in ('Purchase Manager','Stock Manager')
|
|
and p.name not in ('Administrator', 'All', 'Guest')""")
|
|
|
|
msg = frappe.render_template("templates/emails/reorder_item.html", {
|
|
"mr_list": mr_list
|
|
})
|
|
|
|
frappe.sendmail(recipients=email_list,
|
|
subject=_('Auto Material Requests Generated'), message = msg)
|
|
|
|
def notify_errors(exceptions_list):
|
|
subject = _("[Important] [ERPNext] Auto Reorder Errors")
|
|
content = _("Dear System Manager,") + "<br>" + _("An error occured for certain Items while creating Material Requests based on Re-order level. \
|
|
Please rectify these issues :") + "<br>"
|
|
|
|
for exception in exceptions_list:
|
|
exception = json.loads(exception)
|
|
error_message = """<div class='small text-muted'>{0}</div><br>""".format(_(exception.get("message")))
|
|
content += error_message
|
|
|
|
content += _("Regards,") + "<br>" + _("Administrator")
|
|
|
|
from frappe.email import sendmail_to_system_managers
|
|
sendmail_to_system_managers(subject, content)
|