feat: Implement bulk stock movement and item detail retrieval functions

app/sql/apply_bulk_stock_movements.sql

@@ -0,0 +1,77 @@
+-- FUNCTION: trans.apply_bulk_stock_movements(jsonb)
+
+-- DROP FUNCTION IF EXISTS trans.apply_bulk_stock_movements(jsonb);
+
+CREATE OR REPLACE FUNCTION trans.apply_bulk_stock_movements(
+	p_movements jsonb)
+    RETURNS jsonb
+    LANGUAGE 'plpgsql'
+    COST 100
+    VOLATILE PARALLEL UNSAFE
+AS $BODY$
+DECLARE
+    v_movement JSONB;
+    v_results JSONB := '[]'::JSONB;
+    v_result JSONB;
+    v_success BOOLEAN := TRUE;
+    v_error_msg TEXT;
+BEGIN
+    -- Process each movement in the array
+    FOR v_movement IN SELECT * FROM jsonb_array_elements(p_movements)
+    LOOP
+        BEGIN
+            -- Apply individual stock movement using the 9-parameter function
+            PERFORM trans.apply_stock_movement(
+                (v_movement->>'merchant_id')::TEXT,
+                (v_movement->>'location_id')::TEXT,
+                (v_movement->>'sku')::TEXT,
+                (v_movement->>'batch_no')::TEXT,
+				(v_movement->>'catalogue_id')::TEXT,
+				(v_movement->>'expiry_date')::DATE,
+				(v_movement->>'uom')::TEXT,
+                (v_movement->>'qty')::NUMERIC,
+                (v_movement->>'txn_type')::TEXT,
+                (v_movement->>'ref_type')::TEXT,
+                (v_movement->>'ref_id')::UUID,
+                (v_movement->>'created_by')::TEXT
+            );
+            
+            -- Build success result object
+            v_result := jsonb_build_object(
+                'ledger_id', gen_random_uuid(),
+                'sku', v_movement->>'sku',
+                'qty', v_movement->>'qty',
+                'success', true,
+                'error', null
+            );
+            
+        EXCEPTION WHEN OTHERS THEN
+            -- Handle individual movement errors
+            v_success := FALSE;
+            v_error_msg := SQLERRM;
+            
+            v_result := jsonb_build_object(
+                'ledger_id', null,
+                'sku', v_movement->>'sku',
+                'qty', v_movement->>'qty',
+                'success', false,
+                'error', v_error_msg
+            );
+        END;
+        
+        -- Add to results array
+        v_results := v_results || v_result;
+    END LOOP;
+    
+    -- If any movement failed, rollback the entire transaction
+    IF NOT v_success THEN
+        RAISE EXCEPTION 'One or more stock movements failed. Transaction rolled back.';
+    END IF;
+    
+    RETURN v_results;
+END;
+$BODY$;
+
+ALTER FUNCTION trans.apply_bulk_stock_movements(jsonb)
+    OWNER TO trans_owner;
+

app/sql/apply_stock_movement.sql

@@ -0,0 +1,158 @@
+-- FUNCTION: trans.apply_stock_movement(text, text, text, text, text, date, text, numeric, text, text, uuid, text)
+
+-- DROP FUNCTION IF EXISTS trans.apply_stock_movement(text, text, text, text, text, date, text, numeric, text, text, uuid, text);
+
+CREATE OR REPLACE FUNCTION trans.apply_stock_movement(
+	p_merchant_id text,
+	p_location_id text,
+	p_sku text,
+	p_batch_no text,
+	p_catalogue_id text,
+	p_expiry_date date,
+	p_uom text,
+	p_qty numeric,
+	p_txn_type text,
+	p_ref_type text,
+	p_ref_id uuid,
+	p_user text)
+    RETURNS void
+    LANGUAGE 'plpgsql'
+    COST 100
+    VOLATILE PARALLEL UNSAFE
+AS $BODY$
+DECLARE
+    v_ledger_id uuid := gen_random_uuid();
+    v_qty_change numeric;
+BEGIN
+    ----------------------------------------------------------------
+    -- Idempotency check
+    ----------------------------------------------------------------
+    IF EXISTS (
+        SELECT 1
+        FROM trans.scm_stock_ledger
+        WHERE ref_type = p_ref_type
+          AND ref_id   = p_ref_id
+          AND sku      = p_sku
+          AND batch_no = p_batch_no
+    ) THEN
+        RETURN;
+    END IF;
+
+    ----------------------------------------------------------------
+    -- Determine quantity change based on transaction type
+    ----------------------------------------------------------------
+    CASE p_txn_type
+        WHEN 'GRN_IN' THEN
+            v_qty_change := p_qty;  -- Add stock
+        WHEN 'ADJUST_IN' THEN
+            v_qty_change := p_qty;  -- Add stock
+        WHEN 'RETURN_IN' THEN
+            v_qty_change := p_qty;  -- Add stock
+        WHEN 'TRANSFER_IN' THEN
+            v_qty_change := p_qty;  -- Add stock
+        WHEN 'ADJUST_OUT' THEN
+            v_qty_change := -p_qty; -- Subtract stock (negate the positive qty)
+        WHEN 'SALE_OUT' THEN
+            v_qty_change := -p_qty; -- Subtract stock
+        WHEN 'TRANSFER_OUT' THEN
+            v_qty_change := -p_qty; -- Subtract stock
+        ELSE
+            RAISE EXCEPTION 'Unknown transaction type: %', p_txn_type;
+    END CASE;
+
+	Raise Notice 'in';
+    RAISE NOTICE 'Transaction type: %, Input qty: %, Calculated change: %', 
+        p_txn_type, p_qty, v_qty_change;
+    
+    RAISE NOTICE 'Inserting ledger: %, %, %, %, %, %, %, %, %, %, %',
+        v_ledger_id,
+        p_merchant_id,
+        p_location_id,
+        p_sku,
+        p_batch_no,
+        p_txn_type,
+        v_qty_change,  -- Store the calculated change in ledger
+        p_ref_type,
+        p_ref_id,
+        p_user,
+        NOW();
+        
+    ----------------------------------------------------------------
+    -- Ledger insert (store the ACTUAL qty change with proper sign)
+    ----------------------------------------------------------------
+    INSERT INTO trans.scm_stock_ledger (
+        ledger_id,
+        merchant_id,
+        location_id,
+        sku,
+        batch_no,
+        txn_type,
+        qty,
+        ref_type,
+        ref_id,
+        created_by,
+        created_at
+    ) VALUES (
+        v_ledger_id,
+        p_merchant_id,
+        p_location_id,
+        p_sku,
+        p_batch_no,
+        p_txn_type,
+        v_qty_change,  -- Store with correct sign
+        p_ref_type,
+        p_ref_id,
+        p_user,
+        NOW()
+    );
+    
+    RAISE NOTICE 'Stock ledger done';
+    
+    ----------------------------------------------------------------
+    -- Stock snapshot upsert (ALL TABLE COLUMNS)
+    ----------------------------------------------------------------
+    INSERT INTO trans.scm_stock (
+        merchant_id,
+        location_id,
+        sku,
+        batch_no,
+        catalogue_id,
+        uom,
+        qty_on_hand,
+        qty_reserved,
+        qty_available,
+        cost_price,
+        expiry_date,
+        ledger_id,
+        created_at,
+        updated_at
+    ) VALUES (
+        p_merchant_id,
+        p_location_id,
+        p_sku,
+        p_batch_no,
+        p_catalogue_id,
+        p_uom,
+        GREATEST(v_qty_change, 0),  -- Use calculated change (don't allow negative on insert)
+        0,                           -- qty_reserved
+        GREATEST(v_qty_change, 0),  -- qty_available
+        NULL,                        -- cost_price
+        p_expiry_date,              -- expiry_date
+        v_ledger_id,
+        NOW(),
+        NOW()
+    )
+    ON CONFLICT (merchant_id, location_id, catalogue_id, batch_no)
+    DO UPDATE SET
+        qty_on_hand   = GREATEST(trans.scm_stock.qty_on_hand + v_qty_change, 0),
+        qty_available = GREATEST((trans.scm_stock.qty_on_hand + v_qty_change) - trans.scm_stock.qty_reserved, 0),
+        ledger_id     = v_ledger_id,
+        updated_at    = NOW();
+        
+    RAISE NOTICE 'Stock updated. Final qty change applied: %', v_qty_change;
+END;
+$BODY$;
+
+ALTER FUNCTION trans.apply_stock_movement(text, text, text, text, text, date, text, numeric, text, text, uuid, text)
+    OWNER TO trans_owner;
+

app/sql/fn_get_po_item_details.sql

@@ -0,0 +1,45 @@
+-- FUNCTION: trans.fn_get_po_item_details(uuid)
+
+-- DROP FUNCTION IF EXISTS trans.fn_get_po_item_details(uuid);
+
+CREATE OR REPLACE FUNCTION trans.fn_get_po_item_details(
+	p_po_id uuid)
+    RETURNS TABLE(po_id uuid, catalogue_code text, catalogue_name text, hsn_code text, gst_rate numeric, ord_qty numeric, dispatched_qty numeric, rcvd_qty numeric, rejected_qty numeric, returned_qty numeric, net_accepted_qty numeric, unit_price numeric, taxable_amount numeric, gst_amount numeric, final_amount numeric) 
+    LANGUAGE 'plpgsql'
+    COST 100
+    VOLATILE PARALLEL UNSAFE
+    ROWS 1000
+
+AS $BODY$
+BEGIN
+    RETURN QUERY
+    SELECT
+        poi.po_id,
+
+        cr.catalogue_code,
+        cr.catalogue_name,
+        cr.hsn_code,
+        cr.gst_rate,
+
+        poi.ord_qty,
+        poi.dispatched_qty,
+        poi.rcvd_qty,
+        poi.rejected_qty,
+        poi.returned_qty,
+        (poi.rcvd_qty - poi.rejected_qty - poi.returned_qty) AS net_accepted_qty,
+
+        poi.unit_price,
+        poi.line_amt AS taxable_amount,
+        poi.tax_amt AS gst_amount,
+
+        (poi.line_amt + poi.tax_amt) AS final_amount
+    FROM trans.scm_po_item poi
+    JOIN trans.catalogue_ref cr
+        ON cr.catalogue_id = poi.catalogue_id
+    WHERE poi.po_id = p_po_id;
+END;
+$BODY$;
+
+ALTER FUNCTION trans.fn_get_po_item_details(uuid)
+    OWNER TO trans_owner;
+