lti-api/scripts/sql/orphan_allocations_cleanup.sql

-- Cleanup orphan stock_allocations (ACTIVE + CONSUME) by releasing them.
-- IMPORTANT: run audit first.
-- Usage:
-- psql -U app_lti_user -d db_lti_erp -f scripts/sql/orphan_allocations_cleanup.sql

BEGIN;

WITH active_alloc AS (
  SELECT id, usable_type, usable_id
  FROM stock_allocations
  WHERE status = 'ACTIVE'
    AND allocation_purpose = 'CONSUME'
    AND deleted_at IS NULL
),
orphan AS (
  SELECT a.id
  FROM active_alloc a
  WHERE
    (a.usable_type = 'ADJUSTMENT_OUT' AND NOT EXISTS (SELECT 1 FROM adjustment_stocks ad WHERE ad.id = a.usable_id))
    OR (a.usable_type = 'MARKETING_DELIVERY' AND NOT EXISTS (SELECT 1 FROM marketing_delivery_products mdp WHERE mdp.id = a.usable_id))
    OR (a.usable_type = 'RECORDING_STOCK' AND NOT EXISTS (
      SELECT 1 FROM recording_stocks rs JOIN recordings r ON r.id = rs.recording_id
      WHERE rs.id = a.usable_id AND r.deleted_at IS NULL
    ))
    OR (a.usable_type = 'RECORDING_DEPLETION' AND NOT EXISTS (
      SELECT 1 FROM recording_depletions rd JOIN recordings r ON r.id = rd.recording_id
      WHERE rd.id = a.usable_id AND r.deleted_at IS NULL
    ))
    OR (a.usable_type = 'STOCKTRANSFER_OUT' AND NOT EXISTS (
      SELECT 1 FROM stock_transfer_details std
      JOIN stock_transfers st ON st.id = std.stock_transfer_id
      WHERE std.id = a.usable_id AND std.deleted_at IS NULL AND st.deleted_at IS NULL
    ))
    OR (a.usable_type = 'TRANSFERTOLAYING_OUT' AND NOT EXISTS (
      SELECT 1 FROM laying_transfers lt WHERE lt.id = a.usable_id AND lt.deleted_at IS NULL
    ))
),
updated AS (
  UPDATE stock_allocations sa
  SET
    status = 'RELEASED',
    released_at = NOW(),
    note = CONCAT(COALESCE(sa.note, ''), CASE WHEN COALESCE(sa.note, '') = '' THEN '' ELSE ' | ' END, 'orphan_cleanup')
  WHERE sa.id IN (SELECT id FROM orphan)
  RETURNING sa.id, sa.usable_type, sa.usable_id, sa.qty
)
SELECT usable_type, COUNT(*) AS rows, COALESCE(SUM(qty),0) AS total_qty
FROM updated
GROUP BY usable_type
ORDER BY usable_type;

COMMIT;