= Тригери =

== Автоматско ажурирање на статус на маса при креирање на нарачка ==

=== Опис ===

Кога келнерот креира нова нарачка за одредена маса, статусот на масата автоматски се менува во „ЗАФАТЕНА". Ова спречува две нарачки да бидат креирани за иста маса во исто време.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_order_insert_update_table()
RETURNS TRIGGER AS $$
BEGIN
    UPDATE project.restaurant_table
    SET status = 'ЗАФАТЕНА'
    WHERE table_id = NEW.table_id
      AND status = 'СЛОБОДНА';
    
    IF NOT FOUND THEN
        RAISE EXCEPTION 'Масата % е веќе зафатена или неактивна', NEW.table_id;
    END IF;
    
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_order_insert
AFTER INSERT ON project.orders
FOR EACH ROW
EXECUTE FUNCTION trg_order_insert_update_table();
}}}

== Автоматско ослободување на маса при плаќање ==

=== Опис ===

Кога нарачката ќе биде платена, статусот на масата автоматски се враќа во „СЛОБОДНА".

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_payment_release_table()
RETURNS TRIGGER AS $$
BEGIN
    UPDATE project.restaurant_table
    SET status = 'СЛОБОДНА'
    WHERE table_id = (
        SELECT table_id FROM project.orders WHERE order_id = NEW.order_id
    );
    
    UPDATE project.orders
    SET status = 'ПЛАТЕНА'
    WHERE order_id = NEW.order_id;
    
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_payment_insert
AFTER INSERT ON project.payment
FOR EACH ROW
EXECUTE FUNCTION trg_payment_release_table();
}}}

== Автоматско намалување на залиха при продажба ==

=== Опис ===

При додавање на ставка во нарачка, залихата на производот автоматски се намалува. Ако залихата е недоволна, трансакцијата се отфрла.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_order_item_update_inventory()
RETURNS TRIGGER AS $$
DECLARE
    current_stock INTEGER;
BEGIN
    SELECT COALESCE(SUM(quantity_change), 0) INTO current_stock
    FROM project.inventory
    WHERE product_id = NEW.product_id;
    
    IF current_stock < NEW.quantity THEN
        RAISE EXCEPTION 'Недоволна залиха за производ %. Достапно: %, Побарувано: %',
            NEW.product_id, current_stock, NEW.quantity;
    END IF;
    
    INSERT INTO project.inventory (product_id, quantity_change, operation_type)
    VALUES (NEW.product_id, -NEW.quantity, 'ПРОДАЖБА');
    
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_order_item_inventory
AFTER INSERT ON project.order_item
FOR EACH ROW
EXECUTE FUNCTION trg_order_item_update_inventory();
}}}

== Контрола на залиха со дозволен минимум ==

=== Опис ===

При секое движење на залиха, системот проверува дали залихата е под минималното ниво. Ако е под минимум, се евидентира предупредување во `audit_log`.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_inventory_check_min_stock()
RETURNS TRIGGER AS $$
DECLARE
    current_stock INTEGER;
    min_stock_level INTEGER;
    product_name TEXT;
BEGIN
    SELECT COALESCE(SUM(quantity_change), 0) INTO current_stock
    FROM project.inventory
    WHERE product_id = NEW.product_id;
    
    SELECT p.min_stock, p.name INTO min_stock_level, product_name
    FROM project.product p
    WHERE p.product_id = NEW.product_id;
    
    IF current_stock < min_stock_level THEN
        INSERT INTO project.audit_log (user_id, action, entity_name)
        VALUES (
            1,
            'LOW_STOCK: ' || product_name || ' (' || current_stock || '/' || min_stock_level || ')',
            'PRODUCT'
        );
    END IF;
    
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_inventory_min_stock
AFTER INSERT ON project.inventory
FOR EACH ROW
EXECUTE FUNCTION trg_inventory_check_min_stock();
}}}

== Автоматско затворање на смена при плаќање ==

=== Опис ===

При затворање на смена, системот автоматски ги пресметува вкупниот приход и бројот на нарачки.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_shift_close_calculate()
RETURNS TRIGGER AS $$
DECLARE
    total_amount NUMERIC;
    order_count_val INTEGER;
    shift_start TIMESTAMP;
BEGIN
    SELECT start_time INTO shift_start
    FROM project.shift
    WHERE end_time IS NULL
    LIMIT 1;
    
    SELECT COUNT(*), COALESCE(SUM(p.amount), 0)
    INTO order_count_val, total_amount
    FROM project.orders o
    JOIN project.payment p ON p.order_id = o.order_id
    WHERE o.status = 'ПЛАТЕНА'
      AND o.created_at >= shift_start;
    
    NEW.total := total_amount;
    NEW.order_count := order_count_val;
    NEW.closed_at := NOW();
    
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_shift_close
BEFORE INSERT ON project.shift_close
FOR EACH ROW
EXECUTE FUNCTION trg_shift_close_calculate();
}}}

== Превенција на бришење на нарачки со историја на плаќање ==

=== Опис ===

Спречува бришење на нарачки кои имаат поврзани плаќања.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_prevent_order_delete()
RETURNS TRIGGER AS $$
BEGIN
    IF EXISTS (SELECT 1 FROM project.payment WHERE order_id = OLD.order_id) THEN
        RAISE EXCEPTION 'Не може да се избрише нарачка % бидејќи има поврзано плаќање.', OLD.order_id;
    END IF;
    
    RETURN OLD;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_prevent_order_delete
BEFORE DELETE ON project.orders
FOR EACH ROW
EXECUTE FUNCTION trg_prevent_order_delete();
}}}

== Автоматско логирање на промени во audit_log ==

=== Опис ===

При секое креирање, измена или бришење на нарачка, системот автоматски додава запис во `audit_log`.

=== Имплементација ===

{{{
CREATE OR REPLACE FUNCTION trg_audit_log_changes()
RETURNS TRIGGER AS $$
BEGIN
    IF TG_OP = 'INSERT' THEN
        INSERT INTO project.audit_log (user_id, action, entity_name)
        VALUES (NEW.user_id, 'CREATE_ORDER', 'ORDERS');
    ELSIF TG_OP = 'UPDATE' THEN
        INSERT INTO project.audit_log (user_id, action, entity_name)
        VALUES (NEW.user_id, 'UPDATE_ORDER', 'ORDERS');
    ELSIF TG_OP = 'DELETE' THEN
        INSERT INTO project.audit_log (user_id, action, entity_name)
        VALUES (OLD.user_id, 'DELETE_ORDER', 'ORDERS');
    END IF;
    
    RETURN COALESCE(NEW, OLD);
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_audit_orders
AFTER INSERT OR UPDATE OR DELETE ON project.orders
FOR EACH ROW
EXECUTE FUNCTION trg_audit_log_changes();
}}}