aonestar.public

Parameters

Name	Type	Mode
i_guest_id	integer	IN
i_doc_type	smallint	IN
i_doc_number	text	IN
i_doc_country	integer	IN
i_country_id	integer	IN

Definition

DECLARE
    v_country integer;
    v_holders integer[];
    v_des     integer;
    v_srcs    integer[];
BEGIN
    v_country := fn_guest_document_country(i_doc_country, i_country_id);

-- identity ไม่พอให้ match -> ไม่เปลี่ยนอะไร
    IF i_doc_type IS NULL
       OR fn_normalize_guest_document_number(i_doc_number) IS NULL
       OR v_country IS NULL
    THEN
        RETURN i_guest_id;
    END IF;

-- lock key รูปแบบเดียวกับ sp_save_guest และ tr_guest_identity_guard
    PERFORM pg_advisory_xact_lock(hashtextextended(
        i_doc_type::text || ':'
        || fn_normalize_guest_document_number(i_doc_number) || ':'
        || v_country::text,
        0
    ));

-- ต้อง materialise ครั้งเดียว "ก่อน" merge เพราะ sp_refresh_guest_stat เขียนทับ
    -- visit_count / last_arrival / last_departure ซึ่งเป็นคอลัมน์ที่ ranking อ่านอยู่พอดี
    SELECT array_agg(h) INTO v_holders
    FROM fn_guest_document_holders(i_doc_type, i_doc_number, v_country) h;

-- identity ใหม่ ยังไม่มีใครถือ -> ให้ sp_save_guest insert/update ตามปกติ
    IF v_holders IS NULL THEN
        RETURN i_guest_id;
    END IF;

-- profile ที่จะอยู่รอด = holder ที่ ranking ดีที่สุด
    v_des := v_holders[1];

-- source = holder ที่เหลือ (แขกซ้ำที่ค้างอยู่เดิม) + guest จาก payload
    -- guest จาก payload เป็น source เสมอ เพราะเอกสารที่สแกนยังอยู่แค่ใน payload
    -- ไม่ได้อยู่บน row นั้น มันจึงไม่อยู่ในชุด holder
    SELECT array_agg(x.s) INTO v_srcs
    FROM (
        SELECT h AS s FROM unnest(v_holders) h
        UNION
        SELECT i_guest_id WHERE COALESCE(i_guest_id, 0) > 0
    ) x
    WHERE x.s <> v_des;

-- payload guest เป็นเจ้าของคนเดียวอยู่แล้ว (หรือไม่ได้ส่ง guest_id มา = redirect เฉยๆ)
    IF v_srcs IS NULL THEN
        RETURN v_des;
    END IF;

BEGIN
        PERFORM sp_guest_merge_many(v_srcs, v_des);
        PERFORM sp_sys_log('sp_merge_guest_by_document',
            format('merged guest %s into #%s', v_srcs::text, v_des));
    EXCEPTION WHEN OTHERS THEN
        -- fail-soft: ไม่ merge อะไรเลย (sub-transaction rollback ทั้งก้อน กลุ่มยังครบ)
        -- แล้ว redirect ไปใช้ profile ปลายทางต่อ ไม่ปล่อยให้ check-in ล้ม
        -- sp_log_warning ต้องเรียกแบบ positional (มี 2 overload) และ force_write=true
        -- เพื่อให้ log รอดจากการ rollback ของ sub-transaction นี้
        PERFORM sp_log_warning('sp_merge_guest_by_document',
            format('merge %s -> #%s failed: %s', v_srcs::text, v_des, SQLERRM),
            true, true);
    END;

RETURN v_des;
END

sp_merge_guest_by_document

Description

Parameters

Definition