aonestar.public

Parameters

Name	Type	Mode
guests	int4[]	IN
msg_template	text	IN
params	jsonb	IN (DEFAULT NULL)
skip_test_mode	boolean	IN (DEFAULT false)

Definition

DECLARE
    -- NULL = ไม่ได้ตั้ง config (ไม่ใช่ false) -- ต้องแยกจาก false ที่เป็น escape hatch
    _force bool = nullif(btrim(fn_prop_config('EMAIL_TEST_MODE', '')), '')::bool;
    _dev   bool = is_dev_server();
    -- redirect ทั้งก้อน: ตั้งใจ test (ใช้ได้บน prd ด้วย) -- skip_test_mode ยัง bypass ได้เหมือนเดิม
    _blanket bool = coalesce(_force, false) and not skip_test_mode;
    -- allowlist ราย recipient บน dev -- ไม่สน skip_test_mode, ปิดด้วย EMAIL_TEST_MODE=false
    _guard   bool = _dev and coalesce(_force, true);
    msg_count int = 0;
    item record;
    _user_email text;
    _recipients text[];
    _test_recipients text[];
    _test_lower text[];
    _suffix text;
    _msg_id bigint;
    _sqlstate TEXT;
    _detail   TEXT;
    _hint     TEXT;
    _context  TEXT;
    _msg_text TEXT;
    prop record;
BEGIN
    /*
     * Create by Pisanu (2021/07/08)
     * For send message to guests
     */
    SELECT * INTO prop FROM property_info LIMIT 1;

IF _blanket OR _guard THEN
        _test_recipients := ARRAY(
            SELECT btrim(e)
            FROM regexp_split_to_table(coalesce(fn_prop_config('EMAIL_TEST_RECIPIENTS', ''), ''), '[,;]') e
            WHERE btrim(e) <> '');

IF cardinality(_test_recipients) = 0 THEN
            _user_email := fn_user_email();
            IF _user_email IS NOT NULL THEN
                _test_recipients := ARRAY[_user_email];
            END IF;
        END IF;

-- ไม่มีปลายทางทดสอบ = ไม่ส่งเลย ห้าม fallback ไปอีเมลแขกจริง
        -- โหมด _guard ไม่ return ตรงนี้: ปลายทางที่อยู่ใน allowlist ยังส่งได้
        -- ส่วนคนที่ไม่อยู่จะถูกข้ามในลูป (ดู CONTINUE ข้างล่าง)
        IF cardinality(_test_recipients) = 0 AND _blanket THEN
            PERFORM sp_log_warning('sp_send_message_to_guests',
                'TEST_MODE is on but EMAIL_TEST_RECIPIENTS is not configured - no message sent'
                ||E'\ntemplate : '||coalesce(msg_template, '(null)'));
            RETURN 0;
        END IF;

_test_lower := ARRAY(SELECT lower(e) FROM unnest(_test_recipients) e);
    END IF;

FOR item IN (
        WITH guest_data AS (
            SELECT prop.name AS property_name,
                prop.prop_code as property_code,
                prop.company as property_company,
                prop.logo_url as property_logo_url,
                prop.email as property_email,
                prop.telephone as property_telephone,
                prop.fax as property_fax,
                prop.website as property_website,
                prop.address1 as property_address1,
                prop.address2 as property_address2,
                prop.address3 as property_address3,
                prop.address4 as property_address4,

g.id AS guest_id,
                -- ชื่อสำหรับเรียกในจดหมาย: given name ก่อน family name (ลำดับเดียวกับพาสปอร์ต)
                -- first_name/last_name เป็น NOT NULL จึงมีแค่เคสสตริงว่างซึ่งอยู่ที่ขอบ
                -- btrim เก็บช่องว่างค้างให้เอง ('DUNAL' + '' -> 'DUNAL', '' + 'DOE' -> 'DOE')
                btrim(concat_ws(' ', g.first_name, g.last_name)) AS guest_name,
                -- คงรูปแบบ list/report ไว้เป็น {{full_name}} เผื่อ template variant ราย property
                -- ที่มองไม่เห็นจากที่นี่ต้องการของเดิม (additive: renderer เมิน param ที่ไม่ได้ใช้)
                g.full_name,
                g.first_name, g.last_name,
                g.middle_name, t."name" AS title_name,
                -- V20260904.10.4: ส่งครบทุกอีเมลของแขก แยกฉบับต่ออีเมล -> เก็บทั้ง array
                -- ไว้ที่นี่แล้วกระจายเป็นแถวด้วย LATERAL ข้างล่าง (เดิมหยิบแค่ emails[1])
                -- ต้องเป็นอีเมลจริงเสมอ: โหมด _guard ใช้ค่านี้ตัดสิน allowlist
                g.emails AS email_list,
                g.mobiles[1] AS mobile_number
            FROM guest g LEFT JOIN title t ON t.id = g.title_id
            WHERE g.id = ANY($1)
        )
        -- params ต้องมี key 'email_address' เหมือนเดิม (row_to_json ของเดิมมีคอลัมน์นี้อยู่)
        -- เผื่อ template variant ราย property ที่มองไม่เห็นจากที่นี่ใช้ token นั้น
        -- -> ตัด email_list ออกแล้วยัด email_address ของฉบับนั้นกลับเข้าไป
        SELECT (row_to_json(g)::jsonb - 'email_list')
                   || jsonb_build_object('email_address', e.email_address)
                   || coalesce($3,'{}') AS params,
            e.email_address, g.mobile_number, g.property_name
        FROM guest_data g
        LEFT JOIN LATERAL (
            -- dedupe แบบ case-insensitive แต่คงตัวพิมพ์ที่บันทึกไว้ตอนส่ง
            SELECT DISTINCT ON (lower(btrim(x))) btrim(x) AS email_address
            FROM unnest(coalesce(g.email_list, '{}'::text[])) x
            WHERE btrim(x) <> ''
            ORDER BY lower(btrim(x))
        ) e ON true
        -- แขกที่ไม่มีอีเมลยังถูกส่งเข้ากล่องทดสอบเหมือนเดิม
        -- (LATERAL ไม่คืนแถว -> e.email_address เป็น NULL)
        WHERE e.email_address IS NOT NULL OR _blanket OR _guard
    ) LOOP
        IF _blanket THEN
            _recipients := _test_recipients;
            _suffix     := format(' [DEV redirect from %s]', coalesce(item.email_address, 'no email'));
        ELSIF _guard THEN
            IF item.email_address ILIKE '%@newsoft.co.th'
               OR lower(item.email_address) = ANY (_test_lower) THEN
                -- ปลายทางที่ปลอดภัย: ส่งถึงตรง subject สะอาดเหมือน prod
                _recipients := ARRAY[item.email_address];
                _suffix     := NULL;
            ELSIF cardinality(_test_recipients) = 0 THEN
                -- ไม่อยู่ใน allowlist และไม่มีกล่องทดสอบ = ข้าม ห้ามหลุดไปหาแขกจริง
                PERFORM sp_log_warning('sp_send_message_to_guests',
                    'dev guard: no EMAIL_TEST_RECIPIENTS - skipped '
                    ||coalesce(item.email_address, '(no email)')
                    ||E'\ntemplate : '||coalesce(msg_template, '(null)'));
                CONTINUE;
            ELSE
                _recipients := _test_recipients;
                _suffix     := format(' [DEV redirect from %s]', coalesce(item.email_address, 'no email'));
            END IF;
        ELSE
            _recipients := ARRAY[item.email_address];
            _suffix     := NULL;
        END IF;

_msg_id := sp_send_message(msg_template, item.params, _recipients,
                                   sender_name := item.property_name,
                                   subject_suffix := _suffix);

msg_count := msg_count + iif(_msg_id > 0, 1, 0);
    END LOOP;

RETURN msg_count;
EXCEPTION
    WHEN OTHERS THEN
    GET STACKED DIAGNOSTICS
        _msg_text = MESSAGE_TEXT,
        _sqlstate = RETURNED_SQLSTATE,
        _detail   = PG_EXCEPTION_DETAIL,
        _hint     = PG_EXCEPTION_HINT,
        _context  = PG_EXCEPTION_CONTEXT;
    PERFORM sp_log_warning('sp_send_message_to_guests',
        coalesce('message  : '||_msg_text||E'\n', '') ||
        coalesce('detail   : '||_detail||E'\n', '') ||
        coalesce('hint     : '||_hint||E'\n') ||
        coalesce('sql_state: '||_sqlstate||E'\n', '') ||
        coalesce('context  : '||_context||E'\n', '')
    );
    RETURN msg_count;
END

sp_send_message_to_guests

Description

Parameters

Definition