Rakseeibra/arrr-erp
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix opening balance inventory movement schema compatibility

Browse Source
This commit is contained in:
A R R R Associates
2026-09-12 15:43:43 +05:30
parent af4aa509d0
commit db8c27ae3c
1 changed files with 125 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/modules/documents/local_agent_runtime/erp_local_agent/commands.py
+125 -6
View File
@@ -801,15 +801,134 @@ class AgentCommandProcessor:
closing_qty = opening_qty
closing_value = opening_value
if previous_year:
# Accounting Mirror schema compatibility:
#
# Current ODBC mirrors store inventory quantity in
# signed_qty / billed_qty / actual_qty rather than the
# legacy quantity column. Older mirrors may still contain
# direction + quantity + value.
#
# Resolve the available schema at runtime so historical
# mirrors and current mirrors can both be reviewed without
# changing the .act database.
inventory_columns = {
str(info["name"] or "").strip().casefold()
for info in db.execute(
"PRAGMA table_info(inventory_movement)"
).fetchall()
}
if "signed_qty" in inventory_columns:
qty_sql = "COALESCE(SUM(signed_qty),0)"
elif "quantity" in inventory_columns and "direction" in inventory_columns:
qty_sql = """
COALESCE(
SUM(
CASE
WHEN UPPER(direction)='INWARD'
THEN ABS(quantity)
WHEN UPPER(direction)='OUTWARD'
THEN -ABS(quantity)
ELSE 0
END
),
0
)
"""
elif "actual_qty" in inventory_columns and "direction" in inventory_columns:
qty_sql = """
COALESCE(
SUM(
CASE
WHEN UPPER(direction)='INWARD'
THEN ABS(actual_qty)
WHEN UPPER(direction)='OUTWARD'
THEN -ABS(actual_qty)
ELSE 0
END
),
0
)
"""
elif "billed_qty" in inventory_columns and "direction" in inventory_columns:
qty_sql = """
COALESCE(
SUM(
CASE
WHEN UPPER(direction)='INWARD'
THEN ABS(billed_qty)
WHEN UPPER(direction)='OUTWARD'
THEN -ABS(billed_qty)
ELSE 0
END
),
0
)
"""
else:
qty_sql = "0"
if "signed_value" in inventory_columns:
value_sql = "COALESCE(SUM(signed_value),0)"
elif "inventory_amount" in inventory_columns and "signed_qty" in inventory_columns:
value_sql = """
COALESCE(
SUM(
CASE
WHEN signed_qty > 0
THEN ABS(inventory_amount)
WHEN signed_qty < 0
THEN -ABS(inventory_amount)
ELSE 0
END
),
0
)
"""
elif "amount" in inventory_columns and "signed_qty" in inventory_columns:
value_sql = """
COALESCE(
SUM(
CASE
WHEN signed_qty > 0
THEN ABS(amount)
WHEN signed_qty < 0
THEN -ABS(amount)
ELSE 0
END
),
0
)
"""
elif "value" in inventory_columns and "direction" in inventory_columns:
value_sql = """
COALESCE(
SUM(
CASE
WHEN UPPER(direction)='INWARD'
THEN ABS(value)
WHEN UPPER(direction)='OUTWARD'
THEN -ABS(value)
ELSE 0
END
),
0
)
"""
else:
value_sql = "0"
movement = db.execute(
"""SELECT
COALESCE(SUM(CASE WHEN UPPER(direction)='INWARD' THEN ABS(quantity)
WHEN UPPER(direction)='OUTWARD' THEN -ABS(quantity) ELSE 0 END),0),
COALESCE(SUM(CASE WHEN UPPER(direction)='INWARD' THEN ABS(value)
WHEN UPPER(direction)='OUTWARD' THEN -ABS(value) ELSE 0 END),0)
FROM inventory_movement WHERE stock_item_guid=?""",
f"""
SELECT
{qty_sql},
{value_sql}
FROM inventory_movement
WHERE stock_item_guid=?
""",
(row["stock_item_guid"],),
).fetchone()
closing_qty = opening_qty + float(movement[0] or 0)
closing_value = opening_value + float(movement[1] or 0)
stocks.append({