Day 10: Phase 2 Synthesis & Capstone Architectural Review (การสังเคราะห์สถาปัตยกรรม 4 เสาหลัก In-Database Automation, การประยุกต์ใช้ Capstone E-Commerce / Financial Engine, และการประเมินสถาปัตยกรรมก่อนเข้าสู่ Phase 3)

-- ❌ Flawed: รันใน Single Transaction, ใช้ RBAR Loop, ไม่มี Audit DB, ช้าและเสี่ยง Rollback ทั้งหมด
CREATE OR REPLACE FUNCTION fn_process_settlement_flawed()
RETURNS VOID LANGUAGE plpgsql AS $$
DECLARE
    v_rec RECORD;
BEGIN
    -- RBAR Anti-Pattern: วนลูป 100 ล้านรายการทีละแถวใน Single Transaction!
    FOR v_rec IN SELECT id, amount FROM orders WHERE status = 'PENDING' LOOP
        UPDATE orders
        SET status = 'SETTLED',
            net_amount = v_rec.amount * 1.07
        WHERE id = v_rec.id;
        -- 🚨 ไม่มี COMMIT! ถือ Lock ค้าง, WAL บวม 200GB
        -- และถ้าพังแถวสุดท้ายจะ Rollback ทั้งหมดทิ้ง เสียเวลาฟรี!
    END LOOP;
END $$;

-- [Statement 1] สร้าง Stored Procedure ควบคุม Batch Settlement ปริมาณมหาศาล
CREATE OR REPLACE PROCEDURE pr_capstone_settlement_engine(
    p_batch_size INT DEFAULT 10000 -- ขนาด Chunk ละ 10,000 แถว
)
LANGUAGE plpgsql
AS $$
DECLARE
    -- [บรรทัดที่ 1-3] ประกาศตัวแปรติดตามจำนวนแถวและเวลา
    v_chunk_count INT := 0;
    v_total_count INT := 0;
    v_start_time  TIMESTAMPTZ := CURRENT_TIMESTAMP;
BEGIN
    -- [บรรทัดที่ 4] ปรับใช้ Multi-Core Parallel Workers ใน Session
    SET LOCAL max_parallel_workers_per_gather = 4;

    LOOP
        -- [บรรทัดที่ 5-18] ดึงข้อมูลเฉพาะ Chunk + SKIP LOCKED + อัปเดตผ่าน Set-Based Logic
        WITH target_orders AS (
            SELECT id, amount FROM orders
            WHERE status = 'PENDING'
            LIMIT p_batch_size
            FOR UPDATE SKIP LOCKED -- ข้ามแถวที่ Worker ตัวอื่นกำลังทำอยู่
        ),
        updated_orders AS (
            UPDATE orders o
            SET status = 'SETTLED',
                -- 🎯 เรียกใช้ Pillar 1 UDF (Inlined Pure Function)
                net_amount = fn_calculate_net_price(t.amount)
            FROM target_orders t
            WHERE o.id = t.id
            RETURNING o.id
        )
        SELECT COUNT(*) INTO v_chunk_count FROM updated_orders;

        -- [บรรทัดที่ 19-21] ออกจากลูปเมื่อไม่มีข้อมูลค้างชำระ
        IF v_chunk_count = 0 THEN
            EXIT;
        END IF;

        v_total_count := v_total_count + v_chunk_count;

        -- 🎯 [บรรทัดที่ 22] Pillar 2 Explicit Transaction Control: COMMIT ตัด Chunk
        -- ปลด Row Lock, Flush WAL, และทริกเกอร์ Pillar 3 AFTER Trigger บันทึก Audit Log ทันที!
        COMMIT;

    END LOOP;

    -- [บรรทัดที่ 23-24] สั่งรีเฟรช Pillar 4 Materialized View แบบ Non-blocking หลังปิดยอดเสร็จ
    REFRESH MATERIALIZED VIEW CONCURRENTLY mv_daily_financial_report;

    RAISE NOTICE 'Capstone Settlement Completed: % rows settled in %',
                 v_total_count, CURRENT_TIMESTAMP - v_start_time;
END $$;

-- [Statement 2] เรียกใช้งานผ่าน CALL
CALL pr_capstone_settlement_engine(10000);