aonestar.public

Parameters

Name	Type	Mode
i_username	text	IN (DEFAULT NULL)
i_propcode	text	IN (DEFAULT NULL)
i_realtime_type	text	IN (DEFAULT NULL)
i_datas	json	IN (DEFAULT NULL)

Definition

declare
        strconn_db_realtime text;
        _username text;
        _propcode text;
        error     TEXT;
        v_state   TEXT;
        v_detail  TEXT;
        v_hint    TEXT;
        v_context TEXT;
        v_msgtext TEXT;
        sql_text TEXT
        ='insert into queue_realtime (prop_code, user_name, realtime_type, datas) values (%L, %L, %L, %L::json)';
    begin
        
        /**
         * Create by KenG (2020/06/11)
         * Insert data to realtime DB then realtime service will manage about realtime to user continue! 
         * ********************************************************************** 
         * ********************************************************************** 
         * ***if want to all prop_code or to all user_name just pass value '*'
         * ********************************************************************** 
         * ********************************************************************** 
         * 
         * @param i_username [Optional] - Specify username will push realtime to that username/Not specify username(null) will push realtime to  current_username base on param propcode (username value must match in column user_name of users table at authen DB)
         * @param i_propcode [Optional] - Specify propcode will push realtime to that propcode and param username/Not specify propcode(null) will pust realtime time to all current_propcode and param username (propcode value must match in column code of property table at authen DB)
         * @param i_realtime_type [required*] - Topic that push realtime/right now(update value at 2020/22/06) value enum: [notify, shift, room_status]
         * @param i_datas [Optional] - Data want send to front-end if don't send can pass value is null
         * ********************************************************************** 
         * ***Warning if realtime service run more than one service (run 2 service in case run localhost and production) will not work!
         * ***if want develop must stop realtime service on production!
         * **********************************************************************
         */
        
        _username := coalesce(i_username, fn_current_user());
        _propcode := coalesce(i_propcode, fn_current_propcode());
    
        /*if (i_realtime_type <> 'notify' and i_realtime_type <> 'shift' and i_realtime_type <> 'room_status') then 
            return false;
        end if;*/
    
        --Pass value from NodeJS/if test from stored procedure will not work!
        strconn_db_realtime = fn_conn_realtime();
        
        --PERFORM sp_sys_log('sp_enqueue_realtime', strconn_db_realtime);
        sql_text = format(sql_text, _propcode, _username, i_realtime_type, i_datas);
        --'insert into queue_realtime (prop_code, user_name, realtime_type, datas) values ('''||_propcode||''', '''||_username||''', '''||i_realtime_type||''', '''||COALESCE(i_datas,'')|||''')';
        --PERFORM sp_sys_log('sp_enqueue_realtime:strconn_db_realtime', strconn_db_realtime);  
        
    
        PERFORM dblink_exec(strconn_db_realtime, sql_text);
        --PERFORM sp_sys_log('sp_enqueue_realtime', 'Success');
    
        return true;
    EXCEPTION
       WHEN OTHERS THEN
       GET STACKED DIAGNOSTICS
        v_state   = RETURNED_SQLSTATE,
        v_msgtext = MESSAGE_TEXT,
        v_detail  = PG_EXCEPTION_DETAIL,
        v_hint    = PG_EXCEPTION_HINT,
        v_context = PG_EXCEPTION_CONTEXT;
        error = format('EXCEPTION:
                state  : %s
                message: %s
                detail : %s
                hint   : %s
                context: %s', 
                v_state, v_msgtext, v_detail, v_hint, v_context
            );
       PERFORM sp_log_error('sp_enqueue_realtime', strconn_db_realtime, force_write=>TRUE);
       PERFORM sp_log_error('sp_enqueue_realtime', sql_text, force_write=>TRUE); 
       PERFORM sp_log_error('sp_enqueue_realtime', error, force_write=>TRUE);
       -- RAISE;
       RETURN FALSE;
    END;