Fronteira

CREATE OR REPLACE PROCEDURE altera_status_tabelas

-- *****************************************************************************

-- Analista......: REBSON YUKO

-- Programador...: REBSON YUKO

-- Data..........: 18/12/2025

-- Objetivo......: Procedure para altarar tabelas do fronteira

-- Versao 01

-- *****************************************************************************

(

    pa_gr_usuario  IN VARCHAR2,

    pa_co_programa IN VARCHAR2 DEFAULT 'PROCEDUR',

    pa_do_commit   IN VARCHAR2 DEFAULT 'Y',  

    pa_mens_erro   OUT VARCHAR2

) AS

    -- Datas referência (formato texto YYYYMMDD / HH24MISS como nos arquivos Natural)

    v_hoje_char    VARCHAR2(8) := to_char(sysdate, 'YYYYMMDD');

    v_hora_char    VARCHAR2(6) := to_char(sysdate, 'HH24MISS');

--------------------------------------------------------------------------------

    -- Faixas de datas (texto) conforme a lógica Natural

    v_off_ini      VARCHAR2(8);

    v_off_fim      VARCHAR2(8);

    v_cmd_ini      VARCHAR2(8);

    v_cmd_fim      VARCHAR2(8);

    v_pro_ini      VARCHAR2(8);

    v_pro_fim      VARCHAR2(8); 

    -- Contadores (opcional, para diagnóstico)

    v_rows_offline PLS_INTEGER := 0;

    v_rows_comando PLS_INTEGER := 0;

    v_rows_proc_c  PLS_INTEGER := 0; -- processos virados para 'C'

    v_rows_proc_i  PLS_INTEGER := 0; -- processos virados para 'I'

    -- Utilitário para converter data DATE -> CHAR(8) YYYYMMDD

    FUNCTION d2c (

        p_date DATE

    ) RETURN VARCHAR2 IS

    BEGIN

        RETURN to_char(p_date, 'YYYYMMDD');

    END;

BEGIN

    pa_mens_erro := NULL;

--------------------------------------------------------------------------------

    -------------------------------------------------------------------------

    -- 1) CHAVE OFFLINE: de D-30 até D-1 e status = 'T'  ? limpar status

    -------------------------------------------------------------------------

    v_off_ini := d2c(trunc(sysdate) - 30);

    v_off_fim := d2c(trunc(sysdate) - 1);

    UPDATE sitafe.sitafe_chave_offline

    SET

        it_in_status = ' ',

        it_co_programa = pa_co_programa

    WHERE

            it_in_status = 'T'

        AND it_da_transacao BETWEEN v_off_ini AND v_off_fim;

    v_rows_offline := SQL%rowcount;

    -------------------------------------------------------------------------

    -- 2) COMANDO BKG: desde D-60 (sem limite superior, como no Natural atual)

    --    Filtros: programa origem B40015M7, comando_status <> '0', status <> 'C',

    --    módulo processamento = 'B'  ? setar IT_IN_COMANDO_STATUS = '1'

    -------------------------------------------------------------------------

    v_cmd_ini := d2c(trunc(sysdate) - 60);

    v_cmd_fim := d2c(trunc(sysdate) - 3);

    UPDATE sitafe.sitafe_comando

    SET

        it_in_comando_status = '1',

        it_co_programa = pa_co_programa

    WHERE

            it_co_programa = 'B40015M7'

        AND it_da_transacao BETWEEN v_cmd_ini AND v_cmd_fim

        AND nvl(it_in_comando_status, ' ') <> '0'

        AND nvl(it_in_status, ' ') <> 'C'

        AND it_in_modulo_processamento = 'B';

    v_rows_comando := SQL%rowcount;

--------------------------------------------------------------------------------

    -- 3) PROCESSO ADM (CO_SERVICO = '072') pendente:

    --    Abertura entre D-30 e D-1; IT_IN_STATUS = 'P'

    --    - Se NÿO existe em SITAFE_NF_FISCAL_AUX: status 'C'

    --    - Se existe com IT_IN_SITUACAO = '1': status 'I'

    --    Atualiza também CO_PROGRAMA, DA_TRANSACAO, HO_TRANSACAO

    -------------------------------------------------------------------------

    v_pro_ini := d2c(trunc(sysdate) - 30);

    v_pro_fim := d2c(trunc(sysdate) - 1);

    /* Estratégia com duas atualizações específicas (sem cursor),

       usando EXISTS/NOT EXISTS como no Natural */

    DELETE FROM internamento_notas.capa_internamentos i

    WHERE

        i.processo IN (

            SELECT

                pa.it_nu_processo

            FROM

                sitafe.sitafe_processo_administrativo pa

            WHERE

                    pa.it_nu_processo = i.processo

                AND pa.it_co_servico = '072'

                AND pa.it_in_status = 'P'

                AND pa.IT_TP_PROCESSO = 'I'

                AND pa.it_da_abertura BETWEEN v_pro_ini AND v_pro_fim

        );

    DELETE FROM internamento_notas.nota_internadas n

    WHERE

        n.capa_internamento_processo IN (

            SELECT

                pa.it_nu_processo

            FROM

                sitafe.sitafe_processo_administrativo pa

            WHERE

                    pa.it_nu_processo = n.capa_internamento_processo

                AND pa.it_co_servico = '072'

                AND pa.it_in_status = 'P'

                AND pa.IT_TP_PROCESSO = 'I'

                AND pa.it_da_abertura BETWEEN v_pro_ini AND v_pro_fim

        );

--------------------------------------------------------------------------------

    -- a) SEM notas vinculadas ? 'C'

    UPDATE sitafe.sitafe_processo_administrativo pa

    SET

        pa.it_in_status = 'C',

        pa.it_co_programa = pa_co_programa,

        pa.it_da_transacao = v_hoje_char,

        pa.it_ho_transacao = v_hora_char

    WHERE

            pa.it_co_servico = '072'

        AND pa.it_in_status = 'P'

        AND pa.it_da_abertura BETWEEN v_pro_ini AND v_pro_fim

        AND NOT EXISTS (

            SELECT

                1

            FROM

                sitafe_nf_fiscal_aux fa

            WHERE

                fa.it_nu_processo = pa.it_nu_processo

        );

    v_rows_proc_c := SQL%rowcount;

--------------------------------------------------------------------------------

    -- b) COM notas e situacao = '1' ? 'I'

    UPDATE sitafe.sitafe_processo_administrativo pa

    SET

        pa.it_in_status = 'I',

        pa.it_co_programa = pa_co_programa,

        pa.it_da_transacao = v_hoje_char,

        pa.it_ho_transacao = v_hora_char

    WHERE

            pa.it_co_servico = '072'

        AND pa.it_in_status = 'P'

        AND pa.it_da_abertura BETWEEN v_pro_ini AND v_pro_fim

        AND EXISTS (

            SELECT

                1

            FROM

                sitafe_nf_fiscal_aux fa

            WHERE

                    fa.it_nu_processo = pa.it_nu_processo

                AND fa.it_in_situacao = '1'

        );

    v_rows_proc_i := SQL%rowcount;

    -------------------------------------------------------------------------

    -- Commit / Retorno

    -------------------------------------------------------------------------

    IF pa_do_commit = 'Y' THEN

        COMMIT;

    END IF;

    pa_mens_erro := 'OK';

--------------------------------------------------------------------------------

    -- (Opcional) Se quiser logar quantidades afetadas, crie um log aqui

    -- INSERT INTO SUA_TABELA_LOG(...) VALUES (SYSDATE, v_rows_offline, v_rows_comando, v_rows_proc_c, v_rows_proc_i, p_gr_usuario, p_co_programa, ...);

EXCEPTION

    WHEN OTHERS THEN

        pa_mens_erro := 'ERRO: ' || sqlerrm;

        -- Se preferir reverter sempre:

        ROLLBACK;

        RAISE;

END altera_status_tabelas;