Skip to content

Commit

Permalink
fix: linters issues
Browse files Browse the repository at this point in the history
(cherry picked from commit d9dd64b)
  • Loading branch information
rohitwaghchaure authored and mergify[bot] committed Apr 17, 2023
1 parent a981b79 commit c53dc06
Show file tree
Hide file tree
Showing 2 changed files with 47 additions and 27 deletions.
13 changes: 9 additions & 4 deletions erpnext/controllers/stock_controller.py
Original file line number Diff line number Diff line change
Expand Up @@ -859,6 +859,8 @@ def is_reposting_pending():

def future_sle_exists(args, sl_entries=None):
key = (args.voucher_type, args.voucher_no)
if not hasattr(frappe.local, "future_sle"):
frappe.local.future_sle = {}

if validate_future_sle_not_exists(args, key, sl_entries):
return False
Expand Down Expand Up @@ -892,6 +894,9 @@ def future_sle_exists(args, sl_entries=None):
)

for d in data:
if key not in frappe.local.future_sle:
frappe.local.future_sle[key] = frappe._dict({})

frappe.local.future_sle[key][(d.item_code, d.warehouse)] = d.total_row

return len(data)
Expand All @@ -903,18 +908,18 @@ def validate_future_sle_not_exists(args, key, sl_entries=None):
item_key = (args.get("item_code"), args.get("warehouse"))

if not sl_entries and hasattr(frappe.local, "future_sle"):
if key not in frappe.local.future_sle:
return False

if not frappe.local.future_sle.get(key) or (
item_key and item_key not in frappe.local.future_sle.get(key)
):
return True


def get_cached_data(args, key):
if not hasattr(frappe.local, "future_sle"):
frappe.local.future_sle = {}

if key not in frappe.local.future_sle:
frappe.local.future_sle[key] = frappe._dict({})
return False

if args.get("item_code"):
item_key = (args.get("item_code"), args.get("warehouse"))
Expand Down
61 changes: 38 additions & 23 deletions erpnext/stock/stock_ledger.py
Original file line number Diff line number Diff line change
Expand Up @@ -1414,35 +1414,50 @@ def get_stock_reco_qty_shift(args):
return stock_reco_qty_shift


def get_next_stock_reco(args):
def get_next_stock_reco(kwargs):
"""Returns next nearest stock reconciliaton's details."""

return frappe.db.sql(
"""
select
name, posting_date, posting_time, creation, voucher_no, item_code, batch_no, actual_qty
from
`tabStock Ledger Entry`
where
item_code = %(item_code)s
and warehouse = %(warehouse)s
and voucher_type = 'Stock Reconciliation'
and voucher_no != %(voucher_no)s
and is_cancelled = 0
and batch_no = %(batch_no)s
and (timestamp(posting_date, posting_time) > timestamp(%(posting_date)s, %(posting_time)s)
or (
timestamp(posting_date, posting_time) = timestamp(%(posting_date)s, %(posting_time)s)
and creation > %(creation)s
sle = frappe.qb.DocType("Stock Ledger Entry")

query = (
frappe.qb.from_(sle)
.select(
sle.name,
sle.posting_date,
sle.posting_time,
sle.creation,
sle.voucher_no,
sle.item_code,
sle.batch_no,
sle.actual_qty,
)
.where(
(sle.item_code == kwargs.get("item_code"))
& (sle.warehouse == kwargs.get("warehouse"))
& (sle.voucher_type == "Stock Reconciliation")
& (sle.voucher_no != kwargs.get("voucher_no"))
& (sle.is_cancelled == 0)
& (
(
CombineDatetime(sle.posting_date, sle.posting_time)
> CombineDatetime(kwargs.get("posting_date"), kwargs.get("posting_time"))
| (
(
CombineDatetime(sle.posting_date, sle.posting_time)
== CombineDatetime(kwargs.get("posting_date"), kwargs.get("posting_time"))
)
& (sle.creation > kwargs.get("creation"))
)
)
)
order by timestamp(posting_date, posting_time) asc, creation asc
limit 1
""",
args,
as_dict=1,
)
)

if kwargs.get("batch_no"):
query.where(sle.batch_no == kwargs.get("batch_no"))

return query.run(as_dict=True)


def get_datetime_limit_condition(detail):
return f"""
Expand Down

0 comments on commit c53dc06

Please sign in to comment.