backbone_inventory/infrastructure/persistence/
stock_reconciliation_item_repository.rs

1//! Repository for StockReconciliationItem entities
2//!
3//! Originally generated by metaphor-schema; now **user-owned** — this exact path is declared under
4//! `user_owned` in `metaphor.codegen.yaml`, so the generator skips it wholesale. The custom methods
5//! below hold the hand-written StockReconciliationItem SQL
6//! (4-layer rule: services orchestrate, repositories hold the SQL).
7//!
8//! Thin newtype over `backbone_orm::GenericCrudRepository<StockReconciliationItem, backbone_orm::SoftDelete>`.
9//! All standard CRUD methods are available via `Deref`.
10
11use anyhow::Result;
12use rust_decimal::Decimal;
13use sqlx::PgPool;
14use uuid::Uuid;
15
16use crate::domain::entity::StockReconciliationItem;
17
18/// Table name for StockReconciliationItem entities
19pub const TABLE_NAME: &str = "inventory.stock_reconciliation_items";
20
21/// Repository for StockReconciliationItem entities.
22///
23/// All standard CRUD, soft-delete, pagination, and bulk methods are
24/// provided automatically via `Deref` to `backbone_orm::GenericCrudRepository`.
25pub struct StockReconciliationItemRepository(
26    backbone_orm::GenericCrudRepository<StockReconciliationItem, backbone_orm::SoftDelete>,
27);
28
29impl std::ops::Deref for StockReconciliationItemRepository {
30    type Target = backbone_orm::GenericCrudRepository<StockReconciliationItem, backbone_orm::SoftDelete>;
31    fn deref(&self) -> &Self::Target { &self.0 }
32}
33
34impl StockReconciliationItemRepository {
35    /// Create a new repository instance.
36    pub fn new(pool: PgPool) -> Self {
37        Self(backbone_orm::GenericCrudRepository::new(pool, TABLE_NAME))
38    }
39}
40
41/// The exact row a counted reconciliation line insert writes.
42///
43/// `counted_rate` is stored as SUPPLIED (0 meaning "keep the current rate"), while the differences
44/// are computed against the bin's locked balance — so the line records both what was counted and
45/// what it moved.
46pub struct NewReconciliationItemRow {
47    pub id: Uuid,
48    pub reconciliation_id: Uuid,
49    pub item_id: Uuid,
50    pub counted_qty: Decimal,
51    pub counted_rate: Decimal,
52    pub qty_difference: Decimal,
53    pub value_difference: Decimal,
54}
55
56/// Hand-written StockReconciliationItem SQL. Lives here per the module's 4-layer rule.
57impl StockReconciliationItemRepository {
58    /// Insert one counted line. Takes the CALLER'S connection so it commits with the bin/SLE writes
59    /// it describes; the caller has already relayed the ambient org scope onto it — don't re-bind
60    /// here.
61    pub async fn insert_item(
62        &self,
63        conn: &mut sqlx::PgConnection,
64        l: &NewReconciliationItemRow,
65    ) -> Result<(), sqlx::Error> {
66        sqlx::query(
67            r#"INSERT INTO inventory.stock_reconciliation_items
68                (id, reconciliation_id, item_id, counted_qty, counted_rate, qty_difference, value_difference)
69               VALUES ($1,$2,$3,$4,$5,$6,$7)"#,
70        )
71        .bind(l.id).bind(l.reconciliation_id).bind(l.item_id).bind(l.counted_qty)
72        .bind(l.counted_rate).bind(l.qty_difference).bind(l.value_difference)
73        .execute(conn)
74        .await?;
75        Ok(())
76    }
77}
78
79backbone_core::impl_crud_repository!(StockReconciliationItemRepository, StockReconciliationItem, soft_delete);
backbone_inventory/infrastructure/persistence/stock_reconciliation_item_repository.rs

backbone_inventory/infrastructure/persistence/
stock_reconciliation_item_repository.rs
