diff --git a/YpDaemon/src/worker/director.rs b/YpDaemon/src/worker/director.rs index c3d3555..191a867 100644 --- a/YpDaemon/src/worker/director.rs +++ b/YpDaemon/src/worker/director.rs @@ -1312,7 +1312,8 @@ impl DirectorWorker { new_quantity: i32, ) -> Result<(), DbError> { conn.prepare("update_inventory_qty", QUERY_UPDATE_INVENTORY_QTY)?; - conn.execute("update_inventory_qty", &[&inventory_id, &new_quantity])?; + // SQL: UPDATE inventory SET quantity = $1 WHERE id = $2 + conn.execute("update_inventory_qty", &[&new_quantity, &inventory_id])?; Ok(()) } diff --git a/src/worker/director.rs b/src/worker/director.rs index 4547517..83afff0 100644 --- a/src/worker/director.rs +++ b/src/worker/director.rs @@ -1340,7 +1340,8 @@ impl DirectorWorker { new_quantity: i32, ) -> Result<(), DbError> { conn.prepare("update_inventory_qty", QUERY_UPDATE_INVENTORY_QTY)?; - conn.execute("update_inventory_qty", &[&inventory_id, &new_quantity])?; + // SQL: UPDATE inventory SET quantity = $1 WHERE id = $2 + conn.execute("update_inventory_qty", &[&new_quantity, &inventory_id])?; Ok(()) }