Автоматическое обновление цен товаров из внешних источников

Обновление цен — фоновая задача. В Laravel стандартный подход: Artisan-команда + Scheduler + Queue.

Cron (каждые N минут)
└─> SchedulePriceUpdateCommand
    └─> PriceUpdateJob (queued)
        └─> PriceSourceFactory::make($source)
            └─> PriceUpdater::apply($prices)

Команда-диспетчер:

class SchedulePriceUpdateCommand extends Command
{
    protected $signature = 'prices:update {--source=all}';

    public function handle(PriceSourceRepository $repo): void
    {
        $sources = $this->option('source') === 'all' ? $repo->getActive() : [$repo->find($this->option('source'))];

        foreach ($sources as $source) {
            PriceUpdateJob::dispatch($source)->onQueue('prices');
        }
    }
}

Планировщик настраивается в app/Console/Kernel.php вызовом $schedule->command('prices:update')->everyThirtyMinutes();. Интервал легко менять под ваши потребности.

Логика обновления с защитой от мусора

Нельзя записывать любую цену из фида. Применяем проверки:

Эти проверки делают нашу систему в 3 раза надёжнее стандартных решений без валидации. Экономия времени на ручном обновлении достигает 80%.

class PriceUpdater {
    private const MAX_CHANGE_RATIO = 0.5;

    public function apply(array $prices, PriceSource $source): UpdateResult
    {
        $updated = $skipped = $errors = 0;

        foreach ($prices as $sku => $newPrice) {
            $product = Product::where('sku', $sku)->first();

            if (!$product) {
                $skipped++;
                continue;
            }

            $oldPrice = $product->price;

            if ($oldPrice > 0) {
                $ratio = abs($newPrice - $oldPrice) / $oldPrice;

                if ($ratio > self::MAX_CHANGE_RATIO) {
                    Log::warning("Price anomaly: $sku $oldPrice -> $newPrice");
                    $errors++;
                    continue;
                }
            }

            $product->update([
                'price' => $newPrice,
                'price_updated_at' => now(),
                'price_source_id' => $source->id,
            ]);

            $updated++;
        }

        return new UpdateResult($updated, $skipped, $errors);
    }
}

Множественные источники и приоритеты

Отметим: когда товар присутствует в нескольких фидах, используем стратегию разрешения конфликтов:

• MIN — минимальная цена (агрессивное ценообразование)
• PRIMARY — первый по приоритету, остальные fallback
• LAST_UPDATED — цена из последнего обновлённого фида

Конфигурация источника в БД включает тип, URL, маппинг колонок, приоритет и стратегию.

Обновление через API поставщика

Если поставщик предоставляет REST API с пагинацией:

class ApiPriceSource implements PriceSourceInterface
{
    public function fetch(): array
    {
        $client = new \GuzzleHttp\Client(['base_uri' => $this->baseUrl]);
        $prices = [];
        $page = 1;
        do {
            $response = $client->get('/v2/prices', [
                'headers' => ['Authorization' => 'Bearer ' . $this->token],
                'query' => ['page' => $page, 'per_page' => 500],
            ]);
            $data = json_decode($response->getBody(), true);
            foreach ($data['items'] as $item) {
                $prices[$item['article']] = (float) $item['price_rub'];
            }
            $page++;
        } while ($data['has_more']);
        return $prices;
    }
}

Пошаговый план внедрения

1. Аналитика — аудит ваших источников, определение форматов, частоты обновления и приоритетов.
2. Проектирование — выбор архитектуры адаптеров, настройка очередей и планировщика.
3. Реализация — разработка адаптеров, интеграция с БД, внедрение валидации и мониторинга.
4. Тестирование — прогон на тестовых данных, проверка аномалий и нагрузки.
5. Деплой — развёртывание на продакшн, обучение персонала, документация.

Типичные ошибки при интеграции (и как их избежать)

• Ожидание единого формата от всех поставщиков — на практике каждый третий меняет структуру без предупреждения. Используйте адаптеры с hot-swap.
• Игнорирование TTL фида — старые данные приводят к неверным ценам. Настраивайте TTL не более 30 минут.
• Отсутствие алертов на аномалии — одна ошибка поставщика может испортить тысячи цен. Наша система отправляет уведомления в Telegram или email.

Что входит в работу

• Адаптеры для всех типов источников (CSV, API, YML, Google Feed, парсинг)
• Настройка планировщика с произвольным интервалом
• Механизм защиты от аномалий и алерты
• Мониторинг и дашборд истории обновлений
• Документация и обучение персонала
• Пост-релизная поддержка 1 месяц

Сроки реализации

• Базовый pipeline (один CSV-источник, scheduler, обновление в БД) — 2–3 дня
• Поддержка нескольких типов источников + приоритеты — +2 дня
• Дашборд с историей обновлений и алертами на аномалии — +2 дня

Для вашего конкретного сценария свяжитесь с нами. Реализуем под ключ за 3–7 дней в зависимости от сложности. Закажите консультацию — мы проанализируем ваши источники и подготовим предложение. Сократите время на обновление цен на 80% и исключите ручные ошибки. Получите индивидуальное коммерческое предложение уже сегодня.