refactor: move reserve quantity computation to work order
This commit is contained in:
parent
d2cc5f2482
commit
a8bf3a3f0d
@ -8,6 +8,8 @@ from dateutil.relativedelta import relativedelta
|
|||||||
from frappe import _
|
from frappe import _
|
||||||
from frappe.model.document import Document
|
from frappe.model.document import Document
|
||||||
from frappe.model.mapper import get_mapped_doc
|
from frappe.model.mapper import get_mapped_doc
|
||||||
|
from frappe.query_builder import Case
|
||||||
|
from frappe.query_builder.functions import Sum
|
||||||
from frappe.utils import (
|
from frappe.utils import (
|
||||||
cint,
|
cint,
|
||||||
date_diff,
|
date_diff,
|
||||||
@ -1175,3 +1177,27 @@ def create_pick_list(source_name, target_doc=None, for_qty=None):
|
|||||||
doc.set_item_locations()
|
doc.set_item_locations()
|
||||||
|
|
||||||
return doc
|
return doc
|
||||||
|
|
||||||
|
def get_reserved_qty_for_production(item_code: str, warehouse: str) -> float:
|
||||||
|
"""Get total reserved quantity for any item in specified warehouse"""
|
||||||
|
wo = frappe.qb.DocType("Work Order")
|
||||||
|
wo_item = frappe.qb.DocType("Work Order Item")
|
||||||
|
|
||||||
|
return (
|
||||||
|
frappe.qb
|
||||||
|
.from_(wo)
|
||||||
|
.from_(wo_item)
|
||||||
|
.select(Sum(Case()
|
||||||
|
.when(wo.skip_transfer == 0, wo_item.required_qty - wo_item.transferred_qty)
|
||||||
|
.else_(wo_item.required_qty - wo_item.consumed_qty))
|
||||||
|
)
|
||||||
|
.where(
|
||||||
|
(wo_item.item_code == item_code)
|
||||||
|
& (wo_item.parent == wo.name)
|
||||||
|
& (wo.docstatus == 1)
|
||||||
|
& (wo_item.source_warehouse == warehouse)
|
||||||
|
& (wo.status.notin(["Stopped", "Completed", "Closed"]))
|
||||||
|
& ((wo_item.required_qty > wo_item.transferred_qty)
|
||||||
|
| (wo_item.required_qty > wo_item.consumed_qty))
|
||||||
|
)
|
||||||
|
).run()[0][0] or 0.0
|
||||||
|
@ -35,28 +35,9 @@ class Bin(Document):
|
|||||||
def update_reserved_qty_for_production(self):
|
def update_reserved_qty_for_production(self):
|
||||||
'''Update qty reserved for production from Production Item tables
|
'''Update qty reserved for production from Production Item tables
|
||||||
in open work orders'''
|
in open work orders'''
|
||||||
|
from erpnext.manufacturing.doctype.work_order.work_order import get_reserved_qty_for_production
|
||||||
|
|
||||||
wo = frappe.qb.DocType("Work Order")
|
self.reserved_qty_for_production = get_reserved_qty_for_production(self.item_code, self.warehouse)
|
||||||
wo_item = frappe.qb.DocType("Work Order Item")
|
|
||||||
|
|
||||||
self.reserved_qty_for_production = (
|
|
||||||
frappe.qb
|
|
||||||
.from_(wo)
|
|
||||||
.from_(wo_item)
|
|
||||||
.select(Sum(Case()
|
|
||||||
.when(wo.skip_transfer == 0, wo_item.required_qty - wo_item.transferred_qty)
|
|
||||||
.else_(wo_item.required_qty - wo_item.consumed_qty))
|
|
||||||
)
|
|
||||||
.where(
|
|
||||||
(wo_item.item_code == self.item_code)
|
|
||||||
& (wo_item.parent == wo.name)
|
|
||||||
& (wo.docstatus == 1)
|
|
||||||
& (wo_item.source_warehouse == self.warehouse)
|
|
||||||
& (wo.status.notin(["Stopped", "Completed", "Closed"]))
|
|
||||||
& ((wo_item.required_qty > wo_item.transferred_qty)
|
|
||||||
| (wo_item.required_qty > wo_item.consumed_qty))
|
|
||||||
)
|
|
||||||
).run()[0][0] or 0.0
|
|
||||||
|
|
||||||
self.set_projected_qty()
|
self.set_projected_qty()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user