Due Diligence Empresarial

import requests
from concurrent.futures import ThreadPoolExecutor

BASE = "https://221b-api.sherlocker.com.br/api/v1"
TOKEN = "SEU_TOKEN"

def get(endpoint, **params):
    params["token"] = TOKEN
    return requests.get(f"{BASE}{endpoint}", params=params).json()

cnpj = "12345678000199"

empresa = get(f"/empresas/cnpj/{cnpj}")
socios = empresa.get("socios", [])

print(f"Empresa: {empresa.get('razao_social')}")
print(f"Situacao: {empresa.get('situacao')}")
print(f"Capital: R$ {empresa.get('capital_social', 0):,.0f}")
print(f"Socios: {len(socios)}")

# Verifica se a empresa esta em recuperacao judicial ou falencia
rj_falencia = get(
    f"/processos/cnpj/{cnpj}",
    categorias="recuperacao-judicial,falencia",
)

red_flags = []

if rj_falencia.get("total", 0) > 0:
    for p in rj_falencia["processos"]:
        classe = p.get("classe_nome", "")
        numero = p.get("numero_formatado", "")
        red_flags.append(f"{classe}: {numero}")

with ThreadPoolExecutor(max_workers=3) as pool:
    fut_proc = pool.submit(get, f"/processos/cnpj/{cnpj}")
    fut_div = pool.submit(get, f"/dividas/cnpj/{cnpj}")

processos = fut_proc.result()
dividas = fut_div.result()

# Processos como reu
processos_reu = [p for p in processos.get("processos", [])
    if any(part.get("polo", "").lower() == "reu"
           for part in p.get("partes", []))]

if len(processos_reu) > 10:
    red_flags.append(f"{len(processos_reu)} processos como reu")

# Dividas
for tipo in ["ativa_uniao", "fgts", "previdenciaria"]:
    items = dividas.get("dividas", {}).get(tipo, [])
    if items:
        red_flags.append(f"{len(items)} divida(s) {tipo.replace('_', ' ')}")

# Extrair CPFs dos socios
cpfs_socios = [
    s["documento"].replace(".", "").replace("-", "").replace("/", "")
    for s in socios
    if len(s.get("documento", "").replace(".", "").replace("-", "").replace("/", "")) == 11
]

# Verificar se algum socio tem recuperacao judicial ou falencia pessoal
for cpf in cpfs_socios:
    proc_socio = get(
        f"/processos/cpf/{cpf}",
        categorias="recuperacao-judicial,falencia",
    )
    if proc_socio.get("total", 0) > 0:
        red_flags.append(f"Socio {cpf[:3]}*** com processo de recuperacao/falencia")

relatorio = {
    "empresa": {
        "cnpj": cnpj,
        "razao_social": empresa.get("razao_social"),
        "situacao": empresa.get("situacao"),
        "capital_social": empresa.get("capital_social"),
    },
    "red_flags": red_flags,
    "risco": "ALTO" if red_flags else "BAIXO",
    "socios": len(socios),
    "recuperacao_falencia": rj_falencia.get("total", 0),
    "processos_total": len(processos.get("processos", [])),
    "processos_como_reu": len(processos_reu),
}

if red_flags:
    print("RED FLAGS ENCONTRADOS:")
    for flag in red_flags:
        print(f"  - {flag}")