+ `j>v^RIHt^RIHt^RIHtHtHt^RIH t ^RI H t H t ^RI H t ^RIt!RR 4tR#)  AsyncSession)select) RmInventoryRmInventoryLogRmConsumptionLogDecimal)datetimedate)castNca]tRt^ toRtV3RlRltV3RlRltRV3RlRlltRV3R lR lltV3R lR lt RV3R lRllt Rt Vt R#)InventoryServicea Core business logic layer for Inventory Management. Purpose: Centralizes all stock movement operations (Consumptions, Transfers, GRNs). Guarantees ACID compliance, prevents negative stock, and ensures an immutable ledger trail is created for every stock change. c <V^8dQhRS[/#)dbr)format __classdict__s"?/var/www/html/audi_dev/backend/app/modules/inventory/service.py __annotate__InventoryService.__annotate__s<cWnR#Nr)selfrs&&r__init__InventoryService.__init__srcT<V^8dQhRS[PRS[PRS[/#)rrm_idstore_idreturn)uuidUUIDr )rrs"rrrs/ I Ityy IDII I' Irc h"VPP\\4P \P V8H\P V8H4P44GRjxL pVP4pV'd\\VP4#\R4#LA5i)z Fetch the current stock quantity for an item in a specific store. Purpose: Uses a database ROW LOCK (`with_for_update`) to prevent race conditions when checking balances during concurrent transactions. N0.0) rexecuterrwherer r!with_for_updatescalar_one_or_noner r current_qty)rr r!resultinvs&&& r get_balanceInventoryService.get_balances ww ;  % %!!U*$$0 o    '')14tGS__-H'%.H sA,B2.B0/B2 &B2Nc `<V^8dQhRS[PRS[PRS[RS[RS[/#)rr r!qtytransaction_typer")r#r$r str)rrs"rrr#s?77YY7*.))7:A77  7rc R"VPP\\4P \P V8H\P V8H4P44GRjxL pVP4p V 'd\\V P4M \R4p W,p V ^8d\RV R\V4 24hV 'd"Wn \P!4V nM<\WV \P!4R7p VPP#V 4VPP#\%WVVV V VVV\P!4R7 4VPP'4GRjxL V #EL4L 5i)a  The low-level stock posting engine. All stock movements must route through here. Purpose: 1. Safely adjusts stock quantities. 2. Enforces stock validation rules (e.g., no negative stock). 3. Writes an immutable audit trail to the `RmInventoryLog` table (The Ledger). Nr&zInsufficient stock. Available: z , Requested: )r r!r+ last_updated) r r!r2r1balance_before balance_afterreference_type reference_idremarks created_at)rr'rrr(r r!r)r*r r r+ ValueErrorabsr utcnowr5addrflush) rr r!r1r2r8r9r:r,r-r6r7s &&&&&&&& rpost_transaction!InventoryService.post_transaction#sTww ;  U;$$e+[-A-A8-K L _    '');>gs7GEN'-  1 1.1AsSVxjY  +O'0C )%__.C GGKK   N-)')%(  ggmmoU R s2A,F'.F"/F' AF'!B:F'F%F'%F'c&<V^8dQhRS[RS[/#)rr1 consumed_date)r r )rrs"rrr\s$+rc "VPWV)RRVR7GRjxL pVPP\WVRVWVR74VPP 4GRjxL V#LQL5i)z Record the consumption of raw materials (usage in manufacturing/production). Purpose: Deducts stock (posts a negative transaction) and creates a specific consumption log entry for reporting. CONSUMPTIONMANUAL)r2r8r:N)r r!qty_usedconsumption_typerD descriptionr:)rArr?rr@)rr r!r1rDrJr: new_balances&&&&&&& rconsumeInventoryService.consume\s~!11 cT*# 2    $8'#   ggmmo  s"A3A/A A3(A1)A31A3c <V^8dQhRS[/#)r accepted_qtyr )rrs"rrrvs   -4  rc J"VPWVRRVR7GRjxL #L5i)z Post inventory from a Goods Receipt Note (GRN). Purpose: Called by the Procurement module when vendor shipments arrive. Credits (adds) the accepted quantity to the designated store. GRN_RECEIPTGRN)r2r8r9N)rA)rr r!rOgrn_ids&&&&&rgrn_postInventoryService.grn_postvs6** \* v+    s #!#c <V^8dQhRS[/#)rr1r )rrs"rrrsee6=erc z"\\V4\V4.4pV^,\V48Xd>VPWV)RVR7GRjxL VPWVRVR7GRjxL R#VPWVRVR7GRjxL VPWV)RVR7GRjxL R#L`LEL(L 5i)a$ Move inventory between two internal stores. Purpose: Posts a deduction from the source store and an addition to the destination store in a single transaction. Utilizes a deterministic locking order (sorting store IDs) to completely eliminate database deadlocks during concurrent transfers. TRANSFER_OUT)r:N TRANSFER_IN)sortedr3rA)rr from_store_id to_store_idr1r:idss&&&&&& rtransferInventoryService.transfersc-(#k*:;< q6S' '''sdN\c'd d d''CX_'` ` `''CX_'` ` `''sdN\c'd d d e ` ` dsHAB;B3B;/B50B;B7B;,B9-B;5B;7B;9B;r)NNN)NNr) __name__ __module__ __qualname____firstlineno____doc__rr.rArLrTr^__static_attributes____classdictcell__)rs@rrr sQ  I I77r4   eeerr)sqlalchemy.ext.asyncior sqlalchemyrapp.models.rm_modelsrrrdecimalr r r typingr r#rrrrms+/NN# KeKer