select *
from pipeline_process pp
inner join pipeline p on replace(p.id::text,'-','') = replace(pp.pipeline_id::text,'-','')
where batch_id = '16798280332042169d515f4bf3a40052-protheus-1721402659'
and p.carol_app_name = 'gesplanprotheusfree'
and pipeline_name = 'freecontaspagarprevisto'

select
    row_number() over(order by tmp) as row,
    *
from (
    -- Executed
    select
        created,
        event_type,
        null as messageId,
        carolTaskId,
        dataModelName,
        goldenRecordCount + rejectedRecordCount as recordsCount,
        batch_id,
        pipe,
        'a' origem,
        tmp
    from (
        select
            created,
            event_type,
            payload->>'taskId' as carolTaskId,
            payload->>'dataModelName' as dataModelName,
            (payload->>'goldenRecordCount')::int as goldenRecordCount,
            (payload->>'rejectedRecordCount')::int as rejectedRecordCount,
            batch_id,
            payload->>'pipelineName' as pipe,
            payload->>'timestamp' as tmp
--            , *
        from
            observability_event
        where
            batch_id = '16798280332042169d515f4bf3a40052-protheus-1721402659'
            and event_type = 'CarolPipelineExecuted'
            and payload->>'dataModelName' = 'freecontaspagarprevisto'
    ) as ee
    
    union all

    -- Summary
    select
        created,
        event_type,
        null as messageId,
        null as carolTaskId,
        dataModelName,
        goldenRecordCount + rejectedRecordCount as recordsCount,
        batch_id,
        pipe,
        'b' origem,
        tmp
    from (
        select
            e.created,
            e.event_type,
            d->>'dataModelName' as dataModelName,
            (d->>'goldenRecordCount')::int as goldenRecordCount,
            (d->>'rejectedRecordCount')::int as rejectedRecordCount,
            e.batch_id,
            '' as pipe,
            payload->>'timestamp' as tmp
        from
            observability_event as e,
            jsonb_array_elements(e.payload->'dataModels') as d
        where
            e.batch_id = '16798280332042169d515f4bf3a40052-protheus-1721402659'
            and e.event_type = 'CarolPipelinesExecutionSummary'
            and e.payload->>'appName' = 'gesplanprotheusfree'
            and e.payload->>'tenantId' = '158ee83a4c964aeab890bb8cf29a5952'
            and d->>'dataModelName' = 'freecontaspagarprevisto'
    ) as es
    
    union all
    
    -- Sent
    select
        created,
        event_type,
        payload->>'messageId' as messageId,
        payload->>'taskId' as carolTaskId,
        payload->>'dataModelName' as dataModelName,
        (payload->>'recordsCount')::int as recordsCount,
        batch_id,
        '' as pipe,
        'c' origem,
        payload->>'timestamp' as tmp
    from
        observability_event
    where
        batch_id = '16798280332042169d515f4bf3a40052-protheus-1721402659'
        and event_type in  ('CarolDataModelSubscriptionSent')
        and payload->>'appName' = 'gesplanprotheusfree'
        and payload->>'tenantId' = '158ee83a4c964aeab890bb8cf29a5952'
        and payload->>'dataModelName' = 'freecontaspagarprevisto'
) as r
order by
    tmp