aonestar.public

Parameters

Name	Type	Mode
adate	date	IN
task_index	integer	IN
task	jsonb	IN
status	text	IN
message	text	IN (DEFAULT NULL)
task_start	timestamp without time zone	IN (DEFAULT NULL)
task_end	timestamp without time zone	IN (DEFAULT NULL)
finished	boolean	IN (DEFAULT false)
details	jsonb	IN (DEFAULT NULL)

Definition

DECLARE 
    _event_data json;
    _task jsonb;
    _status TEXT;
    _start_time timestamptz;
    _finish_time timestamptz;
    SQL_UPDATE_ENDDAY TEXT = $$
        UPDATE endday 
        SET status = iif(status = 'S', 'S', %L),
            finish_time = iif(status = 'S', finish_time, %L),
            tasks = jsonb_set(tasks, ARRAY[%L], %L)
        WHERE endday_date = %L;
    $$;
    execute_time numeric(8,3) = 0;
    _sqlstate TEXT;
    _detail   TEXT;
    _hint     TEXT;
    _context  TEXT;
    _msg_text TEXT;
BEGIN
    _task = task;

SELECT e.status, e.start_time --, e.tasks->$2 
    FROM endday e
    WHERE endday_date = $1
    INTO _status, _start_time; --, _task;

_finish_time = iif(finished, clock_timestamp(), null);
    _status = iif(finished, iif(status = 'error', 'E', 'S'), 'P');

-- IF _task->>'status' = 'processing' then
    execute_time = EXTRACT(EPOCH FROM (task_end -task_start )); 
   -- RAISE NOTICE '% - %, %', extract(epoch FROM task_end)::TEXT, extract(epoch FROM task_start)::TEXT, execute_time::text;
   -- END IF;

_task = jsonb_build_object(
        'id', _task->>'id',
        'name', _task->>'name',
        'type', _task->>'type',
        'status', status,
        'message', message,
        'execute_time', execute_time,
        'details', details 
    );

-- PERFORM sp_log_debug('endday', format('sp_update_endday_task %s, %s', status, message));

PERFORM sp_prop_exec(NULL, format(SQL_UPDATE_ENDDAY, _status, _finish_time, task_index, _task, adate));
--    UPDATE endday 
--    SET status = _status,
--        finish_time = _finish_time,
--        tasks = jsonb_set(tasks, ARRAY[task_index::text], _task) 
--    WHERE endday_date = adate;

IF status IN ('error','success') THEN 
        _event_data = jsonb_build_object(
            'date', adate,
            'status', iif(finished, iif(status = 'error', 'error', 'success'), 'processing'),
            'start_time', _start_time,
            'finish_time', _finish_time,
            'task', _task
        );

perform sp_enqueue_realtime('*', null, 'endday_progress', _event_data);
        RAISE NOTICE 'endday: notify %', _event_data; 
    END IF;

RETURN TRUE;
EXCEPTION  
    WHEN OTHERS THEN
    GET STACKED DIAGNOSTICS
        _sqlstate = RETURNED_SQLSTATE,
        _msg_text = MESSAGE_TEXT,
        _detail   = PG_EXCEPTION_DETAIL,
        _hint     = PG_EXCEPTION_HINT,
        _context  = PG_EXCEPTION_CONTEXT;    
    PERFORM sp_log_error('sp_update_endday_task', _msg_text, _detail, _sqlstate, _hint, _context, force_write=>TRUE); 
    RAISE NOTICE 'sp_update_endday_task: error - %', _msg_text;
    RETURN FALSE;
END;