nsinnovations/erpnext
2
0
Fork 0
mirror of https://github.com/frappe/erpnext.git synced 2026-05-22 06:29:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: update select query field in patch and code refactor

Browse Source
This commit is contained in:
Shllokkk
2026-03-02 16:25:02 +05:30
parent d0323dea65
commit 91c6475f1c
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
erpnext/patches/v16_0/update_order_qty_and_requested_qty_based_on_mr_and_po.py
View File

@@ -9,14 +9,14 @@ def execute():
poi_query = ( poi_query = (
frappe.qb.from_(PurchaseOrderItem) frappe.qb.from_(PurchaseOrderItem)
.select(PurchaseOrderItem.sales_order_item, Sum(PurchaseOrderItem.qty)) .select(PurchaseOrderItem.sales_order_item, Sum(PurchaseOrderItem.stock_qty))
.where(PurchaseOrderItem.sales_order_item.isnotnull() & PurchaseOrderItem.docstatus == 1) .where(PurchaseOrderItem.sales_order_item.isnotnull() & PurchaseOrderItem.docstatus == 1)
.groupby(PurchaseOrderItem.sales_order_item) .groupby(PurchaseOrderItem.sales_order_item)
) )
mri_query = ( mri_query = (
frappe.qb.from_(MaterialRequestItem) frappe.qb.from_(MaterialRequestItem)
.select(MaterialRequestItem.sales_order_item, Sum(MaterialRequestItem.qty)) .select(MaterialRequestItem.sales_order_item, Sum(MaterialRequestItem.stock_qty))
.where(MaterialRequestItem.sales_order_item.isnotnull() & MaterialRequestItem.docstatus == 1) .where(MaterialRequestItem.sales_order_item.isnotnull() & MaterialRequestItem.docstatus == 1)
.groupby(MaterialRequestItem.sales_order_item) .groupby(MaterialRequestItem.sales_order_item)
) )
@@ -24,14 +24,8 @@ def execute():
poi_data = poi_query.run() poi_data = poi_query.run()
mri_data = mri_query.run() mri_data = mri_query.run()
updates_against_poi = {} updates_against_poi = {data[0]: {"ordered_qty": data[1]} for data in poi_data}
updates_against_mri = {} updates_against_mri = {data[0]: {"requested_qty": data[1], "ordered_qty": 0} for data in mri_data}
for data in poi_data:
updates_against_poi[data[0]] = {"ordered_qty": data[1]}
for data in mri_data:
updates_against_mri[data[0]] = {"requested_qty": data[1], "ordered_qty": 0}
frappe.db.auto_commit_on_many_writes = 1 frappe.db.auto_commit_on_many_writes = 1
frappe.db.bulk_update("Sales Order Item", updates_against_mri) frappe.db.bulk_update("Sales Order Item", updates_against_mri)