CREATE OR REPLACE VIEW document_nfe_canhoto_view (
key, type, cnpj, cnpj_issuer, cnpj_addressee, cnpj_carrier, data_emissao, nsu, protocol, value,
issuer_name, addressee_name, nfe_number, manifestation, cce_events, available_at, canceled_at, status,
name_file, carta_correcao, duplicatas, fatura, canhoto_id, canhoto_associado_at, canhoto_numero_nota,
canhoto_diferenca_dias_associacao, data, cfops, etiquetas, notas_referencia, cte_key
) AS
SELECT
doc.key,
doc.type,
doc.cnpj,
doc.cnpj_issuer,
doc.cnpj_addressee,
doc.cnpj_carrier,
doc.data_emissao,
doc.nsu,
doc.protocol,
(doc.info ->> 'value')::double precision AS value,
doc.info ->> 'issuerName' AS issuer_name,
doc.info ->> 'addresseeName' AS addressee_name,
doc.data #>> '{nfe,infNFe,ide,nnf}' AS nfe_number,

-- Manifestação
COALESCE((
SELECT CASE
WHEN ds.manifestation IS NOT NULL THEN ds.manifestation
WHEN item.historico ->> 'eventCode' IN ('210200','210210','210220','210240')
THEN item.historico ->> 'eventCode'
WHEN regexp_replace(item.historico ->> 'description', '[^0-9]', '', 'gi') IN ('210200','210210','210220','210240')
THEN regexp_replace(item.historico ->> 'description', '[^0-9]', '', 'gi')
ELSE NULL
END
FROM jsonb_array_elements(ds.history) WITH ORDINALITY item(historico, ordinality)
WHERE item.historico ->> 'eventType' IN ('NFE_EVENT_MANIFESTATION', 'NFE_EVENT')
ORDER BY item.historico ->> 'eventAt' DESC
LIMIT 1
), ds.manifestation) AS manifestation,

ds.cce_events,
ds.available_at,

-- Cancelamento
COALESCE((
SELECT CASE
WHEN ds.canceled_at IS NOT NULL THEN ds.canceled_at
WHEN item.historico ->> 'eventCode' = '110111'
THEN (item.historico ->> 'eventAt')::timestamp
WHEN regexp_replace(item.historico ->> 'description', '[^0-9]', '', 'gi') = '110111'
THEN (item.historico ->> 'eventAt')::timestamp
ELSE NULL
END
FROM jsonb_array_elements(ds.history) WITH ORDINALITY item(historico, ordinality)
WHERE item.historico ->> 'eventCode' = '110111'
OR regexp_replace(item.historico ->> 'description', '[^0-9]', '', 'gi') = '110111'
ORDER BY item.historico ->> 'eventAt' DESC
LIMIT 1
), ds.canceled_at) AS canceled_at,

-- Status
COALESCE((
SELECT CASE
WHEN ds.status IS NOT NULL THEN ds.status
WHEN item.historico ->> 'eventCode' = '110111' THEN '3'
WHEN regexp_replace(item.historico ->> 'description', '[^0-9]', '', 'gi') = '110111' THEN '3'
ELSE '1'
END
FROM jsonb_array_elements(ds.history) WITH ORDINALITY item(historico, ordinality)
ORDER BY item.historico ->> 'eventAt' DESC
LIMIT 1
), ds.status) AS status,

doc.name_file,

-- Carta de Correção
(
SELECT json_agg(consulta.*)
FROM (
SELECT
d.data #>> '{procEventoNFe,evento,infEvento,dhEvento}' AS data_evento,
d.data #>> '{procEventoNFe,evento,infEvento,detEvento,xCorrecao}' AS correcao_evento
FROM document d
WHERE doc.key = d.key
AND doc.cnpj_issuer = d.cnpj_issuer
AND d.data #>> '{procEventoNFe,retEvento,infEvento,tpEvento}' = '110110'
) consulta
) AS carta_correcao,

doc.data #> '{nfe,infNFe,cobr,dup}' AS duplicatas,
doc.data #> '{nfe,infNFe,cobr,fat}' AS fatura,

cn.canhoto_importacao_id AS canhoto_id,
cn.created_at AS canhoto_associado_at,
cn.numero_nota AS canhoto_numero_nota,
COALESCE(cn.created_at, CURRENT_TIMESTAMP)::date - doc.data_emissao::date AS canhoto_diferenca_dias_associacao,

doc.data,

-- CFOPs
(
SELECT string_agg(DISTINCT item.value ->> 'cfop', ',')
FROM jsonb_array_elements(doc.data #> '{nfe,infNFe,det}') item(value)
) AS cfops,

-- Etiquetas
(
SELECT jsonb_agg(
jsonb_build_object(
'id', e.id,
'nome_etiqueta', e.nome_etiqueta,
'cor_etiqueta', e.cor_etiqueta,
'etiqueta_padrao', e.etiqueta_padrao,
'cnpj_empresa', e.cnpj_empresa
)
)
FROM etiqueta_documento ed
JOIN etiqueta e ON e.id = ed.id_etiqueta_atual
WHERE ed.chave_nfe = doc.key
) AS etiquetas,

-- Notas Referenciadas
(
SELECT string_agg(DISTINCT nota.referencia ->> 'refNFe', ', ')
FROM jsonb_array_elements(doc.data #> '{nfe,infNFe,ide,nfref}') WITH ORDINALITY nota(referencia, ordinality)
) AS notas_referencia,
nct.chave_cte AS cte_key
FROM document doc
JOIN document_status ds ON doc.key = ds.key AND doc.cnpj_issuer = ds.cnpj_issuer
LEFT JOIN canhoto_nota cn ON doc.key = cn.documento_chave AND doc.cnpj_issuer = cn.empresa_cnpj
LEFT JOIN nfe_cte nct ON doc.key = nct.chave_nfe
WHERE doc.group_type = 'NFE'

-- ============================
-- XML
-- ============================
UPDATE configuracao_consolidacao
SET origem_xml = true
WHERE tipo_consolidacao IN (
-- 'ANALISE_ICMS_BASE_PIS_COFINS',--DESATIVADO
'ANALISE_VENDA_PRODUTO',--OK
'ANALISE_VENDA_ESTADO_REGIAO',--OK XML - DEPENDE DE CONSOLIDAÇÃO ANALISE_VENDA_ESTADO_REGIAO --> SPED_EFD_ICMS_IPI
'ANALISE_COMPRA_ESTADO_REGIAO',--OK XML - DEPENDE DE CONSOLIDAÇÃO ANALISE_COMPRA_ESTADO_REGIAO --> SPED_EFD_ICMS_IPI|
'ANALISE_PIS_COFINS_RESTITUIR_ICMS_ST',--OK
-- 'ANALISE_PIS_COFINS_RESTITUIR_ISS',--DESATIVADO
'ANALISE_REPRESENTATIVIDADE',--OK DEPENDE DE XML E SPED_EFD_ICMS_IPI
'ANALISE_NAO_INCIDENCIA_SOBRE_CONTRATOS_EMPREITADA_GLOBAL',--OK
'ANALISE_EXCLUSAO_ICMS_BC_PIS_COFINS_RESTITUIR',--OK
'ANALISE_SERVICO_PRESTADO_NFSE',--OK
'ANALISE_CLIENTE_NFSE',--OK
'ANALISE_SERVICOS_TOMADOS_NFSE',--OK
'ANALISE_FORNECEDORES_NFSE',--OK
'OPORTUNIDADE_RESSARCIMENTO_CIGARROS',--OK
'EXCLUSAO_IPI_BASE_CALCULO_PIS_COFINS_ST',--OK
'INCONSTITUCIONALIDADE_DIFAL_SIMPLES_NACIONAL',--OK
'CREDITO_PIS_COFINS_AQUISICAO_INSUMOS_MATERIAL_RECICLADO',--OK
'ANALISE_PM_PF',--OK DEPENDE DE XML E CONFAZ
'CREDITO_ICMS_OPERACAO_ST_SUBSTITUIDO',--OK DEPENDE DE XML E SPED_EFD_ICMS_IPI
'CHECAGEM_ALIQUOTA_ICMS',--OK
'VALIDACAO_TRIBUTACAO_SAIDA_PRODUTOS_MONOFASICOS', --OK
'CONTRATACAO_FRETE_OPERACAO_ACUMULO_CREDITO',--OK DEPENDE DE XML E SPED_EFD_ICMS_IPI
'RECALCULO_EXCLUSAO_GROSSUP_ICMS',--OK
'EXCLUSAO_ICMSST_BASE_PIS_COFINS',--OK DEPENDE DE XML E SPED_EF_CONTRIBUIÇÕES
'EXCLUSAO_PIS_COFINS_BC_ICMS_RESTITUIR',--OK DEPENDE DE XML E SPED_EF_CONTRIBUIÇÕES
'EXCLUSAO_ADICIONAL_ICMS_PIS_COFINS',--OK DEPENDE XML
'EXCLUSAO_BASE_CALCULO_BENEFICIO_FISCAL',--OK DEPENDE XML
'SIMPLES_NACIONAL_VENDAS_BRUTAS_X_COMPRAS_BRUTAS',--OK DEPENDE DE XML E ESOCIAL
'ICMS_ST_SIMPLES_NACIONAL_CONSUMIDOR_FINAL',--OK DEPENDE XML
'SIMPLES_NACIONAL_CREDITO_PIS_COFINS_MONOFASICO',--OK DEPENDE XML
'EXCLUSAO_ICMS_BC_IPI',--OK DEPENDE DE XML E SPED_EFD_ICMS_IPI
'EXCLUSAO_PIS_COFINS_BC_IPI',--OK DEPENDE DE XML E SPED_EFD_ICMS_IPI
'OPORTUNIDADE_DOCUMENT_CNPJ',--OK DEPENDE DE CONSOLIDACOES:
-- 1.ANALISE_EXCLUSAO_ICMS_BC_PIS_COFINS_RESTITUIR,
-- 2.ANALISE_PIS_COFINS_RESTITUIR_ISS,
-- 3.ANALISE_NAO_INCIDENCIA_SOBRE_CONTRATOS_EMPREITADA_GLOBAL,
-- 4.OPORTUNIDADE_RESSARCIMENTO_CIGARROS,
-- 5.EXCLUSAO_IPI_BASE_CALCULO_PIS_COFINS_ST,
-- 6.INCONSTITUCIONALIDADE_DIFAL_SIMPLES_NACIONAL,
-- 7.CREDITO_PIS_COFINS_AQUISICAO_INSUMOS_MATERIAL_RECICLADO,
-- 8.CREDITO_ICMS_OPERACAO_ST_SUBSTITUIDO,
-- 9.VALIDACAO_TRIBUTACAO_SAIDA_PRODUTOS_MONOFASICOS,
-- 10.RECALCULO_EXCLUSAO_GROSSUP_ICMS,
-- 11.EXCLUSAO_ICMSST_BASE_PIS_COFINS,
-- 12.EXCLUSAO_PIS_COFINS_BC_ICMS_RESTITUIR,
-- 13.EXCLUSAO_DIFERENCIAL_ALIQUOTAS_ICMS_CALCULO_PIS_COFINS,
-- 14.EXCLUSAO_ADICIONAL_ICMS_PIS_COFINS,
-- 15.EXCLUSAO_BASE_CALCULO_BENEFICIO_FISCAL,
-- 16.SIMPLES_NACIONAL_VENDAS_BRUTAS_X_COMPRAS_BRUTAS,
-- 17.ICMS_ST_SIMPLES_NACIONAL_CONSUMIDOR_FINAL,
-- 18.SIMPLES_NACIONAL_CREDITO_PIS_COFINS_MONOFASICO,
-- 19.EXCLUSAO_ICMS_BC_IPI,
-- 20.EXCLUSAO_PIS_COFINS_BC_IPI
'OPORTUNIDADE_TESE_JURIDICA_CNPJ' -- DEPENDE DE XML, DEPENDE DE SPED_EFD_ICMS_IPI E DEPENDE DE ANALISES:
-- 1.CREDITOS_POSSIVEIS_ICMS
)