aonestar.public

Parameters

Name	Type	Mode
i_log_id	integer	IN
i_user	text	IN (DEFAULT NULL)
i_reason	text	IN (DEFAULT 'REVOKE')
i_async	boolean	IN (DEFAULT false)

Definition

DECLARE
    v_row        intf_doorlock_logs%ROWTYPE;
    v_url        text := fn_doorlock_api_url('deleteonepasscode');
    v_token      text := nullif(btrim(fn_intf_param('DOORLOCK_PIN', 'api_key', '')), '');
    v_hotel      text;
    v_roomno     text;
    v_pwd_id     text;
    v_payload    jsonb;
    v_result     jsonb;
    v_request_id bigint;
BEGIN
    SELECT * INTO v_row FROM intf_doorlock_logs WHERE id = i_log_id;

IF NOT FOUND OR v_row.status <> 'P' OR v_row.credential_type <> 'PIN' THEN
        RETURN jsonb_build_object('revoked', false, 'reason', 'not an active PIN row');
    END IF;
    IF v_url IS NULL OR v_token IS NULL THEN
        RETURN jsonb_build_object('revoked', false, 'reason', 'DOORLOCK_PIN is not configured');
    END IF;

-- ค่าที่ "ส่งไปจริง" ตอนออก passcode เท่านั้น -- ห้ามคำนวณใหม่
    -- (test_mode เขียนทับ roomno เป็น '101' ตอน addpasscode ถ้าคำนวณใหม่จะยิงผิดใบ)
    v_hotel  := coalesce(v_row.api_request->>'hotel_code', fn_prop_code());
    v_roomno := coalesce(v_row.api_request->>'roomno', fn_room_number(v_row.room_id));
    v_pwd_id := v_row.credential_ref;

-- แถวเก่าก่อน backfill อาจไม่มี keyboardPwdId -- เอกสารระบุว่า id ที่ใช้กับ deleteonepasscode
    -- ได้มาจาก getpasscodes จึงถามกลับด้วย roomno + ช่วงเวลาแล้วจับคู่ด้วย pin_code ที่เก็บไว้
    IF v_pwd_id IS NULL AND NOT i_async AND v_row.pin_code IS NOT NULL THEN
        BEGIN
            PERFORM http_set_curlopt('CURLOPT_TIMEOUT', '10');
            v_result := sp_call_rpc(fn_doorlock_api_url('getpasscodes'), v_token,
                            jsonb_build_object(
                                'hotel_code', v_hotel,
                                'roomno',     v_roomno,
                                'effect',     fn_doorlock_fmt_ts(v_row.valid_from),
                                'expire',     fn_doorlock_fmt_ts(v_row.valid_until)),
                            'DoorLock')::jsonb;

SELECT e->>'keyboardPwdId' INTO v_pwd_id
            FROM jsonb_array_elements(coalesce(v_result #> '{result_data,list}', '[]'::jsonb)) AS e
            WHERE e->>'keyboardPwd' = v_row.pin_code
            LIMIT 1;
        EXCEPTION WHEN OTHERS THEN
            v_pwd_id := NULL;   -- fallback ล้มเหลวก็แค่ revoke ไม่ได้ ไม่ทำให้ทั้งชุดพัง
        END;
    END IF;

IF v_pwd_id IS NULL THEN
        PERFORM sp_log_warning('sp_revoke_door_credential',
            'no keyboardPwdId for intf_doorlock_logs id ' || i_log_id::text || ' - cannot revoke');
        RETURN jsonb_build_object('revoked', false, 'reason', 'no keyboardPwdId');
    END IF;

v_payload := jsonb_build_object('hotel_code', v_hotel, 'roomno', v_roomno,
                                    'keyboardPwdId', v_pwd_id);

IF i_async THEN
        -- fire-and-forget ผ่าน pg_net (sys.call_rpc_async -> http_post_async -> authen)
        -- ไม่รอผลเพราะ cancel check-in ไม่ควรพ่วง latency ของ vendor เข้าไปในธุรกรรมหลัก
        v_request_id := sys.call_rpc_async(v_url, v_token, v_payload, 'DoorLock');

-- mark 'R' แบบ optimistic: สาย async ใช้เฉพาะตอน cancel check-in ซึ่ง registration
        -- เป็น 'X' แล้ว ไม่มี reader ไหน lookup PIN ของมันอีก ค่านี้จึงมีผลแค่เชิง audit
        -- ผลจริงไล่ได้จาก revoke_request_id -> authen net._http_response (TTL 6 ชม.)
        UPDATE intf_doorlock_logs
        SET status = 'R', revoke_time = now(), revoke_reason = i_reason,
            revoke_request_id = v_request_id, credential_ref = v_pwd_id
        WHERE id = i_log_id;

RETURN jsonb_build_object('revoked', true, 'async', true, 'request_id', v_request_id);
    END IF;

PERFORM http_set_curlopt('CURLOPT_TIMEOUT', '10');
    v_result := sp_call_rpc(v_url, v_token, v_payload, 'DoorLock')::jsonb;

IF coalesce(v_result->>'result_code', '') <> '0' THEN
        UPDATE intf_doorlock_logs
        SET status = 'E', revoke_time = now(), revoke_reason = i_reason,
            revoke_response = v_result, credential_ref = v_pwd_id
        WHERE id = i_log_id;

PERFORM sp_log_warning('sp_revoke_door_credential',
            'revoke failed for id ' || i_log_id::text || ': ' || coalesce(v_result->>'result_msg', '?'));
        RETURN jsonb_build_object('revoked', false, 'reason', v_result->>'result_msg');
    END IF;

UPDATE intf_doorlock_logs
    SET status = 'R', revoke_time = now(), revoke_reason = i_reason,
        revoke_response = v_result, credential_ref = v_pwd_id
    WHERE id = i_log_id;

RETURN jsonb_build_object('revoked', true, 'async', false);
EXCEPTION WHEN OTHERS THEN
    PERFORM sp_log_warning('sp_revoke_door_credential',
        'id ' || coalesce(i_log_id::text, '?') || ': ' || SQLERRM);
    BEGIN
        UPDATE intf_doorlock_logs SET status = 'E', revoke_time = now(), revoke_reason = i_reason
        WHERE id = i_log_id;
    EXCEPTION WHEN OTHERS THEN
        NULL;
    END;
    RETURN jsonb_build_object('revoked', false, 'reason', SQLERRM);
END