Реализация PHP-клиента для Ozon API: от основ до сложных решений

Расширенные примеры программного кода

Полноценный класс для работы с Ozon API

Ниже представлен класс, объединяющий основные методы и обработку ошибок. Такой класс можно использовать в проекте как единую точку взаимодействия с Ozon.

namespace App\Services;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

class OzonApiService
{
    private $client;
    private $clientId;
    private $apiKey;

    public function __construct(string $clientId, string $apiKey)
    {
        $this->clientId = $clientId;
        $this->apiKey = $apiKey;
        $this->client = new Client([
            'base_uri' => 'https://api-seller.ozon.ru/',
            'headers' => [
                'Client-Id' => $clientId,
                'Api-Key' => $apiKey,
                'Content-Type' => 'application/json',
            ],
            'timeout' => 10.0,
        ]);
    }

    public function getProducts(array $filter = [], int $limit = 100, string $lastId = ''): array
    {
        $response = $this->request('v2/product/list', [
            'filter' => $filter,
            'limit' => $limit,
            'last_id' => $lastId,
        ]);
        return $response['result'] ?? [];
    }

    public function updateStocks(array $stocks): array
    {
        return $this->request('v2/product/import/stocks', [
            'stocks' => $stocks,
        ]);
    }

    public function getOrders(array $filter = [], string $lastId = ''): array
    {
        return $this->request('v2/postings/list', [
            'filter' => $filter,
            'limit' => 1000,
            'last_id' => $lastId,
        ]);
    }

    private function request(string $method, array $body, int $retries = 3): array
    {
        $attempt = 0;
        while ($attempt < $retries) {
            try {
                $response = $this->client->post($method, [
                    'json' => $body,
                ]);
                $data = json_decode($response->getBody(), true);
                if (json_last_error() !== JSON_ERROR_NONE) {
                    throw new \RuntimeException('Ошибка декодирования JSON: ' . json_last_error_msg());
                }
                return $data;
            } catch (RequestException $e) {
                $attempt++;
                if ($attempt >= $retries) {
                    throw $e;
                }
                $status = $e->getResponse() ? $e->getResponse()->getStatusCode() : 0;
                if (in_array($status, [429, 500, 502, 503, 504])) {
                    $delay = pow(2, $attempt) * 500000;
                    usleep($delay);
                } else {
                    throw $e;
                }
            }
        }
    }
}

Использование:

$ozon = new OzonApiService('1234', 'your-api-key');
$products = $ozon->getProducts(['visibility' => 'VISIBLE'], 10);
print_r($products);

Array
(
    [items] => Array
        (
            [0] => Array
                (
                    [product_id] => 12345
                    [offer_id] => "SKU-001"
                    [name] => "Товар 1"
                    ...
                )
        )
    [total] => 100
    [last_id] => "abc123"
)

Асинхронное получение информации о нескольких товарах

Пример, когда нужно получить детали сразу для нескольких SKU, используя параллельные запросы через Guzzle и обработку результатов.

use GuzzleHttp\Client;
use GuzzleHttp\Promise\FulfilledPromise;
use GuzzleHttp\Promise\RejectedPromise;

$client = new Client([...]); // базовая конфигурация

$skus = ['SKU-001', 'SKU-002', 'SKU-003'];

$promises = [];
foreach ($skus as $sku) {
    $promises[$sku] = $client->postAsync('v2/product/info', [
        'json' => ['sku' => $sku],
    ]);
}

$results = GuzzleHttp\Promise\settle($promises)->wait();

$productInfo = [];
foreach ($results as $sku => $result) {
    if ($result['state'] === 'fulfilled') {
        $body = $result['value']->getBody();
        $productInfo[$sku] = json_decode($body, true);
    } else {
        $productInfo[$sku] = ['error' => $result['reason']->getMessage()];
    }
}

print_r($productInfo);

Array
(
    [SKU-001] => Array
        (
            [id] => 12345
            [name] => "Товар 1"
            [price] => 100
        )
    [SKU-002] => Array
        (
            [id] => 12346
            [name] => "Товар 2"
            [price] => 200
        )
    [SKU-003] => Array
        (
            [error] => "Client error: 404"
        )
)

Генерация отчёта через Ozon API и скачивание результата

Ozon позволяет запрашивать отчёты (например, по остаткам). Процесс асинхронный: сначала создаётся задача, затем проверяется её статус и скачивается файл.

// Создание отчёта
$createResponse = $client->post('v2/report/products', [
    'json' => [
        'language' => 'RU',
        'offer_id' => [],
        'visibility' => 'ALL',
    ],
]);
$taskUuid = json_decode($createResponse->getBody(), true)['result']['code'];

// Ожидание завершения
$status = '';
while ($status !== 'OK') {
    sleep(5);
    $statusResponse = $client->post('v2/report/info', [
        'json' => ['code' => $taskUuid],
    ]);
    $status = json_decode($statusResponse->getBody(), true)['result']['status'];
}

// Скачивание
$downloadUrl = json_decode($statusResponse->getBody(), true)['result']['file']['url'];
file_put_contents('report.xlsx', file_get_contents($downloadUrl));
echo 'Отчёт сохранён: report.xlsx';

В результате будет скачан Excel-файл с данными о товарах.