Интеграция с 1С: способы передачи данных через PHP

Расширенные примеры кода для реализации обмена данными между 1С и PHP с дополнительными возможностями.

Потоковая обработка больших CommerceML-файлов

При объёме данных более 100 МБ стандартные методы (simplexml) потребляют много памяти. Используется XMLReader.

// Обработка CommerceML потоком XMLReader
$reader = new XMLReader();
$reader->open('import.xml');

while ($reader->read()) {
    if ($reader->nodeType == XMLReader::ELEMENT && $reader->name == 'Товар') {
        $xmlProduct = $reader->readOuterXML();
        $product = simplexml_load_string($xmlProduct);
        // сохранить товар в БД
        echo "Обработан товар: " . $product->Наименование . PHP_EOL;
    }
}
$reader->close();

Обработан товар: Стул офисный
Обработан товар: Стол письменный
... (всего 10000 записей)

Выгрузка заказов из PHP в 1С (CommerceML)

Генерация XML-файла для отправки в 1С через any способ (HTTP, FTP).

// Генерация CommerceML для документа продажи
$xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><КоммерческаяИнформация>');
$doc = $xml->addChild('Документ');
$doc->addChild('Ид', 'ORDER-001');
$doc->addChild('Номер', '001');
$doc->addChild('Дата', date('Y-m-d'));
$doc->addChild('ХозОперация', 'Заказ товара');
$sum = $doc->addChild('Сумма', 15000.00);
$sum->addAttribute('Валюта', 'руб');

$products = $doc->addChild('Товары');
$item = $products->addChild('Товар');
$item->addChild('Ид', 'PROD-123');
$item->addChild('ЦенаЗаЕдиницу', 5000);
$item->addChild('Количество', 3);
$item->addChild('Сумма', 15000);

$xml->asXML('/tmp/order-export.xml');
echo 'Файл создан: /tmp/order-export.xml';

Файл создан: /tmp/order-export.xml

Параллельный обмен с несколькими базами 1С через Guzzle

Если нужно одновременно обмениваться данными с несколькими конфигурациями 1С, используется асинхронный HTTP-клиент.

require 'vendor/autoload.php';

use GuzzleHttp\Client;
use GuzzleHttp\Pool;
use GuzzleHttp\Psr7\Request;

$clients = [
    ['base_uri' => 'http://1c-buh', 'auth' => ['user1', 'pass1']],
    ['base_uri' => 'http://1c-trade', 'auth' => ['user2', 'pass2']],
];

$requests = function () use ($clients) {
    foreach ($clients as $cfg) {
        $client = new Client(['base_uri' => $cfg['base_uri']]);
        yield new Request('POST', '/exchange', [
            'auth' => $cfg['auth'],
            'body' => file_get_contents('catalog.xml')
        ]);
    }
};

$pool = new Pool(new Client(), $requests(), [
    'concurrency' => 2,
    'fulfilled' => function ($response, $index) {
        echo "База #$index ответила: " . $response->getBody() . PHP_EOL;
    },
    'rejected' => function ($reason, $index) {
        echo "База #$index ошибка: " . $reason . PHP_EOL;
    },
]);
$promise = $pool->promise();
$promise->wait();

База #0 ответила: success
База #1 ответила: success

Обработка ошибок и повторные попытки при обмене с 1С

Реализация устойчивого обмена с логированием и автоматическими повторами при временных сбоях.

class ExchangeWithRetry {
    private $maxAttempts = 3;
    private $delay = 2; // секунды

    public function send($url, $xml) {
        $attempt = 0;
        while ($attempt < $this->maxAttempts) {
            $attempt++;
            $ch = curl_init($url);
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/xml']);
            $response = curl_exec($ch);
            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);

            if ($httpCode === 200) {
                echo "Успех на попытке $attempt\n";
                return $response;
            } else {
                echo "Ошибка (HTTP $httpCode) на попытке $attempt\n";
                if ($attempt < $this->maxAttempts) {
                    sleep($this->delay);
                }
            }
        }
        throw new \RuntimeException('Не удалось отправить данные после '.$this->maxAttempts.' попыток');
    }
}

$exchanger = new ExchangeWithRetry();
try {
    $exchanger->send('http://1c-server/exchange', '...');
} catch (Exception $e) {
    echo $e->getMessage();
}

Ошибка (HTTP 500) на попытке 1
Ошибка (HTTP 500) на попытке 2
Успех на попытке 3