aonestar.public

Parameters

Name	Type	Mode

Definition

DECLARE
    -- job รันช่วงเย็น (run window 17:00-20:00) business date ยังเป็นวันนี้ -> +1 = วันถึงพรุ่งนี้
    v_target    date := fn_system_date() + 1;
    v_base_url  text;
    bk          record;
    v_sent      int := 0;
    v_skipped   int := 0;
    v_failed    int := 0;
    _state      text;
    _msgtext    text;
    _detail     text;
    _hint       text;
    _context    text;
BEGIN
    IF NOT is_interface_active('PRE-CHECKIN') THEN
        RETURN jsonb_build_object('skipped', 'PRE-CHECKIN interface is not active');
    END IF;

IF NOT is_interface_active('SELF-CHECKIN') THEN
        RETURN jsonb_build_object('skipped', 'SELF-CHECKIN interface is not active');
    END IF;

-- sp_send_precheckin_invite เช็ค PRE_URL ให้อยู่แล้ว แต่เช็คซ้ำที่นี่โดยตั้งใจ:
    -- ถ้าปล่อยไปถึงในลูป job จะวนทุก booking แล้วคืน {"skipped": <จำนวน>} เฉยๆ
    -- ทำให้ property_job_queue.last_result ไม่บอกสาเหตุ ต้องไปไล่หาใน sys.log_warning เอง
    v_base_url := nullif(btrim(coalesce(fn_intf_param('PRE-CHECKIN', 'PRE_URL', NULL::text), '')), '');
    IF v_base_url IS NULL THEN
        PERFORM sp_log_warning('sp_send_precheckin_reminder',
            'PRE-CHECKIN.PRE_URL is not configured - no reminder sent');
        RETURN jsonb_build_object('skipped', 'PRE_URL is not configured');
    END IF;

FOR bk IN
        SELECT b.id, b.arrival
        FROM booking b
        WHERE b.book_type <> 'G'            -- individual เท่านั้น ตรงกับ sp_create_booking
          AND b.status IN ('R', 'C')        -- ตัด W (waiting) / X / N / I / O ออกทั้งหมด
          AND b.arrival = v_target          -- ยึด booking.arrival ไม่ใช่ booking_items.arrival
          AND b.guest_id IS NOT NULL
          AND coalesce(b.precheckin_reminder_date, DATE '1900-01-01') <> b.arrival
        ORDER BY b.id
    LOOP
        BEGIN   -- booking เดียวพังต้องไม่ล้มทั้ง job
            -- skip_test_mode := false โดยตั้งใจ (ต่างจาก amend/create): job รันจาก pg_cron
            -- -> fn_user_email() เป็น NULL, บน dev ที่ EMAIL_TEST_MODE ว่าง (is_dev_server() = true)
            -- ถ้าไม่ตั้ง EMAIL_TEST_RECIPIENTS จะไม่ส่งเลย + log warning = fail-closed
            IF sp_send_precheckin_invite(bk.id, i_skip_test_mode := false) > 0 THEN
                UPDATE booking SET precheckin_reminder_date = bk.arrival WHERE id = bk.id;
                v_sent := v_sent + 1;
            ELSE
                -- ไม่มีอีเมล / test mode ไม่มีปลายทาง / template หาย -> ไม่ mark รอบหน้าลองใหม่ได้
                v_skipped := v_skipped + 1;
            END IF;
        EXCEPTION WHEN OTHERS THEN
            GET STACKED DIAGNOSTICS
                _state   = RETURNED_SQLSTATE,
                _msgtext = MESSAGE_TEXT,
                _detail  = PG_EXCEPTION_DETAIL,
                _hint    = PG_EXCEPTION_HINT,
                _context = PG_EXCEPTION_CONTEXT;
            v_failed := v_failed + 1;
            PERFORM sp_log_warning('sp_send_precheckin_reminder',
                coalesce('booking  : ' || bk.id::text || E'\n', '') ||
                coalesce('message  : ' || _msgtext || E'\n', '') ||
                coalesce('detail   : ' || _detail || E'\n', '') ||
                coalesce('hint     : ' || _hint || E'\n', '') ||
                coalesce('sql_state: ' || _state || E'\n', '') ||
                coalesce('context  : ' || _context || E'\n', ''));
        END;
    END LOOP;

-- ตั้งใจไม่มี exception handler ครอบทั้ง body: handler ระดับนอกจะ rollback ถึง savepoint
    -- ต้นฟังก์ชัน = guard ของ booking ที่ส่งสำเร็จไปแล้วหายหมด ปล่อยให้ error หลุดไปให้
    -- sys.run_property_jobs จับแทน (มัน log sys.log_error + เก็บ last_result ให้อยู่แล้ว)
    RETURN jsonb_build_object(
        'target_date', v_target,
        'sent',        v_sent,
        'skipped',     v_skipped,
        'failed',      v_failed);
END

sp_send_precheckin_reminder

Description

Parameters

Definition