Мета: Автоматизировать сбор и консолидацию ежедневной финансовой аналитики с различных маркетплейсов (Prom, Umall, Rozetka) через CRM SalesDrive в Telegram. Ключевой вызов: объединить данные из разрозненных источников (разные formId) и обеспечить точность расчетов прибыли и «хитов продаж» в условиях нестабильной передачи системных дат через API.
Решение: Многопоточная архитектура на n8n (self-hosted на Railway):
1. Извлечение данных (SalesDrive API Pipeline)
Многоисточниковый сбор: Реализованы отдельные HTTP-запросы для веток PROM + UMALL и ROZETKA. Использованы специфические заголовки аутентификации для каждого источника.
Точное фильтрование: Настроена жесткая фильтрация по временным окнам (00:00:00 – 23:58:59) через параметры orderTime и createTime, что исключает подтягивание «исторических» заказов при их редактировании менеджерами.
Валидация статуса: Система автоматически отсекает технический мусор и аннулированные заявки (статус 32/51), гарантируя, что в отчет попадает только реальная «касса».
2. Аналитический движок (JS Code Logic)
Финансовый агрегатор: Code Node выполняет роль бэкенд-процессора: парсит массивы заказов, конвертирует строковые данные в числа (parseFloat) и проводит суммирование оборотов и чистой прибыли в реальном времени.
Обнаружение хитов продукта: Алгоритм динамически подсчитывает количество проданных единиц каждого SKU, определяет лидера дня («Хит продаж») и выводит его название вместе с количеством реализаций.
Нормализация данных: Автоматическая унификация названий товаров и артикулов, даже если они отсутствуют в отдельных объектах массива products.
Результат:
Дизайн отчетности: Формирование строгого бизнес-отчета в Telegram с использованием моноширинного шрифта для удобного считывания цифр и мгновенного копирования ЕДРПОУ/сумм одним тапом.
Операционный контроль: Владелец получает полную картину продаж за 1 секунду без необходимости заходить в CRM и вручную строить фильтры.
Надежность: Благодаря хостингу на Railway и оптимизированным таймаутам подключения к БД (PostgreSQL), система стабильно обрабатывает запросы даже в пиковые часы нагрузки на маркетплейсы.
#n8n #SalesDrive #ECommerce #Prom #Rozetka #BusinessIntelligence #Automation #API #Railway
Решение: Многопоточная архитектура на n8n (self-hosted на Railway):
1. Извлечение данных (SalesDrive API Pipeline)
Многоисточниковый сбор: Реализованы отдельные HTTP-запросы для веток PROM + UMALL и ROZETKA. Использованы специфические заголовки аутентификации для каждого источника.
Точное фильтрование: Настроена жесткая фильтрация по временным окнам (00:00:00 – 23:58:59) через параметры orderTime и createTime, что исключает подтягивание «исторических» заказов при их редактировании менеджерами.
Валидация статуса: Система автоматически отсекает технический мусор и аннулированные заявки (статус 32/51), гарантируя, что в отчет попадает только реальная «касса».
2. Аналитический движок (JS Code Logic)
Финансовый агрегатор: Code Node выполняет роль бэкенд-процессора: парсит массивы заказов, конвертирует строковые данные в числа (parseFloat) и проводит суммирование оборотов и чистой прибыли в реальном времени.
Обнаружение хитов продукта: Алгоритм динамически подсчитывает количество проданных единиц каждого SKU, определяет лидера дня («Хит продаж») и выводит его название вместе с количеством реализаций.
Нормализация данных: Автоматическая унификация названий товаров и артикулов, даже если они отсутствуют в отдельных объектах массива products.
Результат:
Дизайн отчетности: Формирование строгого бизнес-отчета в Telegram с использованием моноширинного шрифта для удобного считывания цифр и мгновенного копирования ЕДРПОУ/сумм одним тапом.
Операционный контроль: Владелец получает полную картину продаж за 1 секунду без необходимости заходить в CRM и вручную строить фильтры.
Надежность: Благодаря хостингу на Railway и оптимизированным таймаутам подключения к БД (PostgreSQL), система стабильно обрабатывает запросы даже в пиковые часы нагрузки на маркетплейсы.
#n8n #SalesDrive #ECommerce #Prom #Rozetka #BusinessIntelligence #Automation #API #Railway