StockProduct.php

<?php 

namespace App\Models;


class StockProduct
{
	private $pdo;
	
	public function __construct(\PDO $pdo)
	{
		$this->pdo = $pdo;
	}
	
	/*Dá baixa no estoque*/
	public function lowStocks(array $products = [])
	{
		foreach($products as $product){
			
			try{
				$this->pdo->beginTransaction();
				$this->decreaseQuantity($product['product_id'], 1);
				$this->pdo->commit();
			}catch(\Exception $e){
				$this->pdo->rollback();
			}
			
		}
		
	}
	
	//Faz o descremento, se der error na excução dá exception
	public function decreaseQuantity($product_id, $quantity)
	{
		$stmt = $this->pdo->prepare("UPDATE products SET quantity -= :quantity WHERE id = :id ");
		$stmt->bindValue(':quantity', $quantity);
		$stmt->bindValue(':id', $product_id);
		if($stmt->execute()) return true;
		
		throw new \Exception("Erro ao executar a baixar de estoque");
	}
}