<?php
$Guzzle = new Client([
‘base_uri’ => ‘example.com’,
‘cookies’ => true,
‘timeout’ => 30.0,
‘verify’ => false,
‘allow_redirects’ => true,
‘http_errors’ => false,
‘curl’ => [
CURLOPT_PROXY => ‘192.168.0.1’,
CURLOPT_PROXYPORT => 1234,
CURLOPT_PROXYTYPE => CURLPROXY_SOCKS5,
],
‘headers’ => $headers,
]);
$options[$index][‘form_params’] = [
‘textfield’ => $inn,
‘radReg’ => ‘FederalDistricts’,
];
$results[$index][‘headers’] = [
‘Accept’ => ‘application/json’,
‘Accept-Encoding’ => ‘gzip, deflate, br’,
‘Accept-Language’ => ‘ru-RU,ru;q=0.9,en-US;q=0.8,en;q=0.7,ka;q=0.6’,
‘Connection’ => ‘keep-alive’,
‘Content-Type’ => ‘application/x-www-form-urlencoded; charset=UTF-8’,
‘Sec-Fetch-Dest’ => ’empty’,
‘Sec-Fetch-Mode’ => ‘cors’,
‘Sec-Fetch-Site’ => ‘same-origin’,
‘User-Agent’ => ‘Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36’,
‘X-Requested-With’ => ‘XMLHttpRequest’,
‘sec-ch-ua’ => ‘”Not_A Brand”;v=”8″, “Chromium”;v=”120″, “Google Chrome”;v=”120″‘,
‘sec-ch-ua-mobile’ => ‘?0’,
‘sec-ch-ua-platform’ => ‘”Windows”‘,
];
$results[$idEmitent][‘decode_content’] = true;
// $results[$idEmitent][‘debug’] = true;
// $results[‘proxy’] = $this->lastProxy; // alternative variant proxy
$requests = static function () use ($options, $Client) {
$url = ‘https://example.com/api/search/companies’;
foreach ($options as $index => $option) {
yield $index => function() use ($Client, $url, $option) {
return $Client->postAsync($url, $option);
};
}
};
$pool = new Pool($Client, $requests(), [
‘concurrency’ => 5,
‘fulfilled’ => function (Response $Response, $index, $aggregate) use ($companyList) {
$content = $Response->getBody()->getContents();
if (empty($content)) {
$aggregate->cancel();
return;
}
$this->doSomethingWithData($content, $companyList[$idEmitent]);
},
‘rejected’ => function (RequestException|ConnectException $reason, $idEmitent) {
$this->logError(‘Ошибка Guzzle: ‘ . $idEmitent);
$this->setGuzzle(resetProxy:true);
},
]);
$promise = $pool->promise();
try {
$promise->wait();
} catch (CancellationException $exception) {
$this->setGuzzle(resetProxy:true);
}
