bartender/models/OrderItemModel.php

<?php

namespace Models;

use Models\OrderModel;
use Models\ProductModel;

class OrderItemModel
{
    private \PDO $pdo;

    public function __construct()
    {
        $dbFile = $_ENV['DB_FILE'];
        $dbPath = __DIR__ . '/../' . $dbFile;
        $this->pdo = new \PDO("sqlite:" . $dbPath);
        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
        $this->pdo->exec('PRAGMA journal_mode = WAL;');
        $this->pdo->exec('PRAGMA busy_timeout = 5000;');
    }

    public function createOrderItem(int $orderId, int $productId, int $companyId): int|false
    {
        $orderModel = new OrderModel();
        $productModel = new ProductModel();

        $order = $orderModel->getOrderById($orderId, $companyId);
        if (!$order) {
            return false;
        }

        $product = $productModel->getProductById($productId, $companyId);
        if (!$product) {
            return false;
        }

        $stmt = $this->pdo->prepare("
            INSERT INTO order_item (order_id, product_id, company_id)
            VALUES (:order_id, :product_id, :company_id)
        ");

        try {
            $executed = $stmt->execute([
                'order_id' => $orderId,
                'product_id' => $productId,
                'company_id' => $companyId
            ]);
            return $executed ? (int)$this->pdo->lastInsertId() : false;
        } catch (\PDOException $e) {
            // Em ambiente de produção, considere logar a exceção de forma mais robusta
            // ou retornar uma mensagem de erro genérica mais amigável.
            error_log("PDO Exception during order item creation: " . $e->getMessage());
            return false;
        }
    }

    public function deleteOrderItem(int $orderItemId, int $companyId): bool
    {
        $stmt = $this->pdo->prepare("
            DELETE FROM order_item
            WHERE order_item_id = :order_item_id
              AND order_id IN (
                  SELECT order_id FROM `order` WHERE company_id = :company_id AND order_flag = 'a'
              )
        ");
        $executed = $stmt->execute(['order_item_id' => $orderItemId, 'company_id' => $companyId]);
        return $executed && $stmt->rowCount() > 0;
    }

    public function getOrderItemsByOrderId(?int $orderId, int $companyId, int $page = 1, int $limit = 10): array
    {
        if ($orderId !== null) {
            $orderModel = new OrderModel();
            $order = $orderModel->getOrderById($orderId, $companyId);
            if (!$order) {
                return [];
            }
        
            $stmt = $this->pdo->prepare("
                SELECT order_item_id, order_id, product_id, company_id 
                FROM order_item 
                WHERE order_id = :order_id AND company_id = :company_id
            ");
            $stmt->execute([
                'order_id' => $orderId,
                'company_id' => $companyId,
            ]);
        } else {
            $offset = ($page - 1) * $limit;
        
            $stmt = $this->pdo->prepare("
                SELECT order_item_id, order_id, product_id, company_id 
                FROM order_item 
                WHERE company_id = :company_id
                LIMIT :limit OFFSET :offset
            ");
            $stmt->bindValue(':company_id', $companyId, \PDO::PARAM_INT);
            $stmt->bindValue(':limit', $limit, \PDO::PARAM_INT);
            $stmt->bindValue(':offset', $offset, \PDO::PARAM_INT);
            $stmt->execute();
        }
    
        return $stmt->fetchAll(\PDO::FETCH_ASSOC);
    }
}