psp_api/prisma/migrations/20251224172938_triggers/migration.sql

-- AUTO-GENERATED MYSQL TRIGGER DUMP
-- Generated at: 2025-12-22T15:32:20.184Z

-- ------------------------------------------
-- Trigger: trg_transfer_item_after_insert
-- Event: INSERT
-- Table: Inventory_Transfer_Items
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_transfer_item_after_insert`;

CREATE TRIGGER `trg_transfer_item_after_insert` AFTER INSERT ON `Inventory_Transfer_Items` FOR EACH ROW begin

DECLARE fromInv INT;
    DECLARE toInv INT;
    DECLARE _avgCost DECIMAL(10,2);
    DECLARE latestQuantityInOrigin DECIMAL(10,2);
    DECLARE latestQuantityInDestination DECIMAL(10,2);

    SELECT fromInventoryId, toInventoryId INTO fromInv, toInv
    FROM Inventory_Transfers WHERE id = NEW.transferId;

    SELECT COALESCE(avgCost, 0), COALESCE(quantity, 0) INTO _avgCost, latestQuantityInOrigin FROM Stock_Balance
    WHERE ProductId = NEW.productId AND inventoryId = fromInv LIMIT 1;

    SELECT COALESCE(quantity, 0) INTO latestQuantityInDestination FROM Stock_Balance
    WHERE ProductId = NEW.productId AND inventoryId = toInv LIMIT 1;


    -- OUT from source
    INSERT INTO Stock_Movements
    (type, quantity, fee, totalCost, avgCost, referenceType, referenceId, productId, inventoryId, counterInventoryId, createdAt, remainedInStock)
    VALUES
        ('OUT', NEW.count,  _avgCost, _avgCost*NEW.count, _avgCost, 'INVENTORY_TRANSFER', NEW.transferId, NEW.productId, fromInv, toInv, NOW(), latestQuantityInOrigin-NEW.count);

    -- IN to destination
    INSERT INTO Stock_Movements
    (type, quantity, fee, totalCost, avgCost, referenceType, referenceId, productId, inventoryId, counterInventoryId, createdAt, remainedInStock)
    VALUES
        ('IN', NEW.count,_avgCost, _avgCost*NEW.count,_avgCost, 'INVENTORY_TRANSFER', NEW.transferId, NEW.productId, toInv, fromInv, NOW(), latestQuantityInOrigin-NEW.count);
end;

-- ------------------------------------------
-- Trigger: trg_purchase_receipt_item_after_insert
-- Event: INSERT
-- Table: Purchase_Receipt_Items
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_purchase_receipt_item_after_insert`;

CREATE TRIGGER `trg_purchase_receipt_item_after_insert` AFTER INSERT ON `Purchase_Receipt_Items` FOR EACH ROW BEGIN DECLARE latestQuantity DECIMAL(10, 2) DEFAULT 0;

DECLARE invId INT;
    DECLARE suppId INT;

    -- Get inventory & supplier from receipt
    SELECT inventoryId, supplierId
    INTO invId, suppId
    FROM Purchase_Receipts
    WHERE id = NEW.receiptId;

    -- Get current stock quantity (if exists)
    SELECT COALESCE(quantity, 0)
    INTO latestQuantity
    FROM Stock_Balance sb
    WHERE sb.inventoryId = invId
      AND sb.productId = NEW.productId
    LIMIT 1;

    -- Insert stock movement
    INSERT INTO Stock_Movements (
        type,
        quantity,
        fee,
        totalCost,
        referenceType,
        referenceId,
        productId,
        inventoryId,
        avgCost,
        supplierId,
        remainedInStock,
        createdAt
    )
    VALUES (
        'IN',
        NEW.count,
        NEW.fee,
        NEW.total,
        'PURCHASE',
        NEW.receiptId,
        NEW.productId,
        invId,
        CASE
          WHEN NEW.count = 0 THEN 0
          ELSE NEW.total / NEW.count
        END

,
        suppId,
        latestQuantity + NEW.count,
        NOW()
    );

END;

-- ------------------------------------------
-- Trigger: trg_sales_invoice_items_before_insert
-- Event: INSERT
-- Table: Sales_Invoice_Items
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_sales_invoice_items_before_insert`;

CREATE TRIGGER `trg_sales_invoice_items_before_insert` BEFORE INSERT ON `Sales_Invoice_Items` FOR EACH ROW begin DECLARE current_stock DECIMAL(10, 2);

DECLARE inventory_id INT;


    SELECT inventoryId INTO inventory_id
    FROM Sales_Invoices si
    WHERE si.id = NEW.invoiceId
    LIMIT 1;

    SELECT COALESCE(quantity, 0) INTO current_stock
    FROM Stock_Balance sb
    WHERE productId = NEW.productId AND sb.inventoryId = inventory_id
    LIMIT 1;



    IF NEW.count > current_stock THEN
        SIGNAL SQLSTATE '45000'
            SET MESSAGE_TEXT = 'موجودی کالا در انبار کافی نیست.';
    END IF;
end;

-- ------------------------------------------
-- Trigger: trg_sales_invoice_items_after_insert
-- Event: INSERT
-- Table: Sales_Invoice_Items
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_sales_invoice_items_after_insert`;

CREATE TRIGGER `trg_sales_invoice_items_after_insert` AFTER INSERT ON `Sales_Invoice_Items` FOR EACH ROW begin DECLARE current_stock DECIMAL(10, 2);

DECLARE inventory_id INT;
DECLARE customer_id INT;


    SELECT inventoryId , customerId INTO inventory_id, customer_id
    FROM Sales_Invoices si
    WHERE si.id = NEW.invoiceId
    LIMIT 1;

    SELECT COALESCE(quantity, 0) INTO current_stock
    FROM Stock_Balance sb
    WHERE productId = NEW.productId AND sb.inventoryId = inventory_id
    LIMIT 1;



    INSERT INTO Stock_Movements (
        type,
        quantity,
        fee,
        totalCost,
        referenceType,
        referenceId,
        productId,
        inventoryId,
        avgCost,
        remainedInStock,
        customerId,
        createdAt
    )
    VALUES (
        'OUT',
        NEW.count,
        NEW.fee,
        NEW.total,
        'SALES',
        NEW.invoiceId,
        NEW.productId,
        inventory_id,

        CASE
          WHEN NEW.count = 0 THEN 0
          ELSE NEW.total / NEW.count
        END,
        current_stock + NEW.count,
        customer_id,
        NOW()
    );


END;

-- ------------------------------------------
-- Trigger: trg_stock_transfer
-- Event: INSERT
-- Table: Stock_Movements
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_stock_transfer`;

CREATE TRIGGER `trg_stock_transfer` AFTER INSERT ON `Stock_Movements` FOR EACH ROW BEGIN IF NEW.referenceType = 'INVENTORY_TRANSFER' THEN IF NEW.type = 'IN' THEN
INSERT INTO
    Stock_Balance (
        productId,
        inventoryId,
        quantity,
        totalCost,
        avgCost,
        updatedAt
    )
VALUES (
        NEW.productId,
        NEW.inventoryId,
        NEW.quantity,
        NEW.totalCost,
        CASE
            WHEN NEW.quantity = 0 THEN 0
            ELSE NEW.totalCost / NEW.quantity
        END,
        NOW()
    )
ON DUPLICATE KEY UPDATE
    quantity = quantity + NEW.quantity,
    totalCost = totalCost + NEW.totalCost,
    avgCost = CASE
        WHEN (quantity + NEW.quantity) = 0 THEN 0
        ELSE (totalCost + NEW.totalCost) / (quantity + NEW.quantity)
    END,
    updatedAt = NOW();

END IF;

IF NEW.type = 'OUT' THEN IF EXISTS (
    SELECT 1
    FROM Stock_Balance sb
    WHERE
        sb.productId = NEW.productId
        AND sb.inventoryId = NEW.inventoryId
) THEN

UPDATE Stock_Balance sb
SET
    sb.quantity = sb.quantity - NEW.quantity,
    sb.totalCost = sb.totalCost - (sb.avgCost * NEW.quantity),
    sb.updatedAt = NOW()
WHERE
    sb.productId = NEW.productId
    AND sb.inventoryId = NEW.inventoryId;

ELSE
INSERT INTO
    Stock_Balance (
        productId,
        inventoryId,
        quantity,
        totalCost,
        avgCost,
        updatedAt
    )
VALUES (
        NEW.productId,
        NEW.inventoryId,
        - NEW.quantity,
        - COALESCE(NEW.fee, 0) * NEW.quantity,
        COALESCE(NEW.fee, 0),
        NOW()
    );

END IF;

END IF;

END IF;

END;

-- ------------------------------------------
-- Trigger: trg_stock_purchase_insert
-- Event: INSERT
-- Table: Stock_Movements
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_stock_purchase_insert`;

CREATE TRIGGER `trg_stock_purchase_insert` AFTER INSERT ON `Stock_Movements` FOR EACH ROW BEGIN IF NEW.referenceType = 'PURCHASE' THEN

INSERT INTO
    Stock_Balance (
        productId,
        quantity,
        avgCost,
        totalCost,
        inventoryId,
        updatedAt
    )
VALUES (
        NEW.productId,
        NEW.quantity,
        NEW.fee,
        NEW.totalCost,
        NEW.inventoryId,
        NOW()
    )
ON DUPLICATE KEY UPDATE
    quantity = quantity + NEW.quantity,
    totalCost = totalCost + NEW.totalCost,
    avgCost = totalCost / quantity;

END IF;

END;

-- ------------------------------------------
-- Trigger: trg_stock_sale_insert
-- Event: INSERT
-- Table: Stock_Movements
-- ------------------------------------------
DROP TRIGGER IF EXISTS `trg_stock_sale_insert`;

CREATE TRIGGER `trg_stock_sale_insert` AFTER INSERT ON `Stock_Movements` FOR EACH ROW BEGIN IF NEW.referenceType = 'SALES' THEN

INSERT INTO
    Stock_Balance (
        productId,
        quantity,
        avgCost,
        totalCost,
        inventoryId,
        updatedAt
    )
VALUES (
        NEW.productId,
        NEW.quantity,
        NEW.fee,
        NEW.totalCost,
        NEW.inventoryId,
        NOW()
    )
ON DUPLICATE KEY UPDATE
    quantity = quantity - NEW.quantity,
    totalCost = totalCost - NEW.totalCost,
    avgCost = totalCost / quantity;

END IF;

END;