DataJud — Base Nacional de Processos Judiciais

Authorization: APIKey SEU_TOKEN_AQUI
Content-Type: application/json

import requests
 
API_KEY = "SEU_TOKEN_AQUI"
BASE_URL = "https://api-publica.datajud.cnj.jus.br"
 
headers = {
    "Authorization": f"APIKey {API_KEY}",
    "Content-Type": "application/json",
}
 
 
def buscar_processo(tribunal: str, numero_processo: str) -> dict:
    """
    Busca um processo pelo número unificado (CNJ).
 
    Args:
        tribunal: Sigla do tribunal (ex: 'tjsp', 'trf1')
        numero_processo: Número do processo (formato CNJ)
 
    Returns:
        Dados do processo em formato dict
    """
    url = f"{BASE_URL}/api_publica_{tribunal}/_search"
 
    query = {
        "query": {
            "match": {
                "numeroProcesso": numero_processo,
            }
        }
    }
 
    response = requests.post(url, headers=headers, json=query)
    response.raise_for_status()
    resultado = response.json()
 
    hits = resultado.get("hits", {}).get("hits", [])
    if hits:
        return hits[0]["_source"]
    return {}
 
 
# Exemplo: buscar processo no TJSP
processo = buscar_processo("tjsp", "1234567-89.2023.8.26.0100")
if processo:
    print(f"Classe: {processo.get('classe', {}).get('nome', 'N/A')}")
    print(f"Ajuizamento: {processo.get('dataAjuizamento', 'N/A')}")
    print(f"Órgão julgador: {processo.get('orgaoJulgador', {}).get('nome', 'N/A')}")

def buscar_por_classe_e_periodo(
    tribunal: str,
    codigo_classe: int,
    data_inicio: str,
    data_fim: str,
    tamanho: int = 10,
) -> list:
    """
    Busca processos por classe processual e período de ajuizamento.
 
    Args:
        tribunal: Sigla do tribunal
        codigo_classe: Código da classe processual (TPU)
        data_inicio: Data inicial (formato YYYY-MM-DD)
        data_fim: Data final (formato YYYY-MM-DD)
        tamanho: Número máximo de resultados
 
    Returns:
        Lista de processos
    """
    url = f"{BASE_URL}/api_publica_{tribunal}/_search"
 
    query = {
        "size": tamanho,
        "query": {
            "bool": {
                "must": [
                    {"match": {"classe.codigo": codigo_classe}},
                    {
                        "range": {
                            "dataAjuizamento": {
                                "gte": data_inicio,
                                "lte": data_fim,
                            }
                        }
                    },
                ]
            }
        },
        "sort": [{"dataAjuizamento": {"order": "desc"}}],
    }
 
    response = requests.post(url, headers=headers, json=query)
    response.raise_for_status()
    resultado = response.json()
 
    return [hit["_source"] for hit in resultado.get("hits", {}).get("hits", [])]
 
 
# Exemplo: buscar ações civis públicas (classe 65) no TRF1 em 2023
processos = buscar_por_classe_e_periodo(
    tribunal="trf1",
    codigo_classe=65,
    data_inicio="2023-01-01",
    data_fim="2023-12-31",
    tamanho=5,
)
 
for p in processos:
    print(f"Processo: {p['numeroProcesso']}")
    print(f"  Classe: {p['classe']['nome']}")
    print(f"  Ajuizamento: {p['dataAjuizamento']}")
    print(f"  Órgão: {p['orgaoJulgador']['nome']}")
    print()

def listar_movimentacoes(tribunal: str, numero_processo: str) -> list:
    """
    Lista as movimentações de um processo.
 
    Args:
        tribunal: Sigla do tribunal
        numero_processo: Número do processo (formato CNJ)
 
    Returns:
        Lista de movimentações ordenadas por data
    """
    processo = buscar_processo(tribunal, numero_processo)
    if not processo:
        print("Processo não encontrado.")
        return []
 
    movimentos = processo.get("movimentos", [])
    # Ordenar por data (mais recente primeiro)
    movimentos.sort(key=lambda m: m.get("dataHora", ""), reverse=True)
    return movimentos
 
 
# Exemplo
movimentos = listar_movimentacoes("tjsp", "1234567-89.2023.8.26.0100")
for mov in movimentos[:10]:
    print(f"{mov.get('dataHora', 'N/A')} — {mov.get('nome', 'N/A')}")

import requests
import pandas as pd
 
# 1. Obter empresas sancionadas no CEIS
API_KEY_CGU = "SEU_TOKEN_CGU"
resp_ceis = requests.get(
    "https://api.portaldatransparencia.gov.br/api-de-dados/ceis",
    headers={"chave-api-dados": API_KEY_CGU, "Accept": "application/json"},
    params={"pagina": 1},
)
sancionadas = resp_ceis.json()
 
# 2. Para cada empresa sancionada, buscar processos no DataJud
API_KEY_DATAJUD = "SEU_TOKEN_DATAJUD"
headers_dj = {
    "Authorization": f"APIKey {API_KEY_DATAJUD}",
    "Content-Type": "application/json",
}
 
resultados = []
for empresa in sancionadas[:5]:  # Limitar para exemplo
    cnpj = empresa.get("cnpjSancionado", "")
    if not cnpj:
        continue
 
    # Buscar no TJSP (exemplo — adaptar para outros tribunais)
    query = {
        "size": 5,
        "query": {
            "match": {"numeroProcesso": cnpj}
        }
    }
    resp = requests.post(
        "https://api-publica.datajud.cnj.jus.br/api_publica_tjsp/_search",
        headers=headers_dj,
        json=query,
    )
    if resp.status_code == 200:
        hits = resp.json().get("hits", {}).get("hits", [])
        for hit in hits:
            proc = hit["_source"]
            resultados.append({
                "cnpj_sancionado": cnpj,
                "nome_sancionado": empresa.get("nomeSancionado"),
                "numero_processo": proc.get("numeroProcesso"),
                "classe": proc.get("classe", {}).get("nome"),
                "ajuizamento": proc.get("dataAjuizamento"),
            })
 
df = pd.DataFrame(resultados)
print(f"Processos encontrados para empresas sancionadas: {len(df)}")
if not df.empty:
    print(df.head())