<?php
require('tele.php');

define('MEMORY_FILE', __DIR__ . '/memoria_oab.json');

$oab = $_GET['oab']; // ou ?? 'SP' para valor padrão
// $us_id = $_GET['us_id']; // ou ?? 'SP' para valor padrão
$page = $_GET['page'] ?? '1';


function trazer1($str, $start, $end) {
    $parts = explode($start, $str);
    if (isset($parts[1])) {
        $subParts = explode($end, $parts[1]);
        return $subParts[0];
    }
}


$uf = file_get_contents('botT/estado.txt');

if (!$oab || !$uf) {
    // exit('OAB ou UF não informados.');
    send2Message('OAB ou UF não informados.');
    exit;
}

// Carrega a memória de consultas
$mem = [];
if (file_exists(MEMORY_FILE)) {
    $mem = json_decode(file_get_contents(MEMORY_FILE), true) ?? [];
}

// Verifica se já foi consultado
$chave = $uf . '/' . $oab;
if (isset($mem[$chave])) {
    // exit("Esta OAB já foi consultada em: " . $mem[$chave]['last']);
}


// exit;
$url = "https://api.escavador.com/api/v1/oab/$uf/$oab/processos?page=$page";

$curl = curl_init($url);
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);

$headers = array(
   "Authorization: Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiJ9.eyJhdWQiOiIxIiwianRpIjoiZmYyMzIzMTljNzhhNmQ3MTY1OGZkMWNkMTIzNGFkMGY3ZmI3ZGM2OGI3N2E3ZTJiZDQzMDhiZTczZDM3ZGI2OGFiMjNhNGVjZTg1MTQxMjMiLCJpYXQiOjE3NTU1NDA0MTQuMTA4NTg1LCJuYmYiOjE3NTU1NDA0MTQuMTA4NTg2LCJleHAiOjIwNzEwNzMyMTQuMTA2MTY4LCJzdWIiOiIyNzE5OTM5Iiwic2NvcGVzIjpbImFjZXNzYXJfYXBpX3BhZ2EiLCJhY2Vzc2FyX2FwaV9wbGF5Z3JvdW5kIl19.n6Arwv5sB_IknFezRm7R6_nIg3ZKuj97ydTQX8efL2_Da9_KkZIB3rIql3NyeOuGLcss-dtybXNgUjicov0debGO_VT5aJznEFdgtcV9rvhRIhsFPyKfc9Ujf26gC0uJ0O-EVnqvtOJRFImIMkw1YJnGfnjF26ElNAJN-PUCcr4aragYOF8k44kLYyxYJSWtT0dV00ii_Qhno4R3gVx_zPDnCq57MMZ2XwlH9FWvsCO8Qqulf4M6C6Zf8thJNQCNjq-qAbbey6w3QrWx-4w2y9Tr4mr2HVkhg1s-zN507jHzgPIesb4OfuAmLm8fHYXwG5GPCsV_vzNmLLZ0H0CXmhrS4-c-1c9fIcZuHtpJRiSjVYxjEGYnNkiQjUPZlWxVykD9g9gls-xch3OMaWQnrPMaI-2s9f1h5uRaELzNUgdtFQEDldRDdSJMb7f2wEFyjhFe3Tw-_fDWVJ5jZhpcxrc9PlojPfNtDRQ7kiFi3gz_HN1MOYkb1WWiGWtI0Nw1kURo-DsfYsNr1NmLeXIppgUjAF2ZLSRheDYvzJ34eplVwqGN-x_8EP2mr-3DfM2zuoT7SAR0AOEa8UupnJvIvqQp7wY0qrPIHNhL8garbPC3bv53zQ_GgE7zOoVgXFnLupdNFCuFGvPiwq3M8p-LfVmQkYG_46rUz7vNlu8xzeY",
   "X-Requested-With: XMLHttpRequest",
);
curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
//for debug only!
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);

$response = curl_exec($curl);


// Exemplo: $response = file_get_contents("response.txt");

$total_prc = trazer1($response, '"total":', ',"total_pages"');
$total_pages = trazer1($response, '"total_pages":', ',"');
$pagina_select = trazer1($response, '"current_page":', ',"');
$per_page = trazer1($response, '"per_page":', '}');

// Supondo que o conteúdo JSON já está em $response
// Exemplo: $response = file_get_contents("response.txt"); &us_id=$us_id

$pattern = '/"numero_novo":"([^"]+)"/';
if (preg_match_all($pattern, $response, $matches)) {
    $processos = $matches[1];

    foreach ($processos as $numero) {
        // Monta a URL para c.php
        $url = "https://bot1.botworkapifullinfo.shop/STJ_V3_TRD/c.php?process=" . urlencode($numero)."&id=".$_GET['us_id'];

        // Faz a requisição e aguarda resposta
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $resposta = curl_exec($ch);
        curl_close($ch);

        // Mostra a resposta de cada requisição
        // echo "Enviado: $numero -> Resposta: $resposta\n";

        // Aguarda 1 segundo entre as requisições (opcional)
        // sleep(0.5);
    }
    $mem[$chave] = [
        'last' => date('c')
    ];
    file_put_contents(MEMORY_FILE, json_encode($mem, JSON_PRETTY_PRINT|JSON_UNESCAPED_UNICODE), LOCK_EX);
    send2Message('Envio finalizado com sucesso!');
    exit;
} else {
    fwrite(fopen('errr.txt', 'w'), "Nenhum numero_novo encontrado no response.\n $resposta");
    // echo "Nenhum numero_novo encontrado no response.";
    send2Message('Nenhum numero_novo encontrado');
    exit;
}