Автоматичне оновлення цін товарів із зовнішніх джерел

Оновлення цін — фонове завдання. У 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();. Інтервал легко змінювати під ваші потреби.

Логіка оновлення із захистом від сміття

Не можна записувати будь-яку ціну з фіда. Застосовуємо перевірки:

Ці перевірки роблять нашу систему значно надійнішою за стандартні рішення без валідації. Економія часу на ручному оновленні сягає 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% та виключіть ручні помилки. Отримайте індивідуальну комерційну пропозицію вже сьогодні.