Cel: Zautomatyzować zbieranie i konsolidację codziennej analityki finansowej z różnych marketplace'ów (Prom, Umall, Rozetka) przez CRM SalesDrive w Telegramie. Kluczowe wyzwanie: połączyć dane z rozproszonych źródeł (różne formId) i zapewnić dokładność obliczeń zysku i „hitów sprzedaży” w warunkach niestabilnego przesyłania danych systemowych przez API.
Rozwiązanie: Architektura wielowątkowa na n8n (self-hosted na Railway):
1. Ekstrakcja danych (Pipeline API SalesDrive)
Pobieranie z wielu źródeł: Zrealizowano oddzielne zapytania HTTP dla gałęzi PROM + UMALL oraz ROZETKA. Użyto specyficznych nagłówków autoryzacji dla każdego źródła.
Filtracja precyzyjna: Ustawiono rygorystyczną filtrację według okien czasowych (00:00:00 – 23:58:59) przez parametry orderTime i createTime, co eliminuje pobieranie „historycznych” zamówień przy ich edytowaniu przez menedżerów.
Walidacja statusu: System automatycznie odrzuca techniczne śmieci i anulowane zgłoszenia (status 32/51), gwarantując, że do raportu trafiają tylko rzeczywiste „przychody”.
2. Silnik analityczny (Logika kodu JS)
Agregator finansowy: Węzeł kodu pełni rolę procesora backendowego: parsuje tablice zamówień, konwertuje dane tekstowe na liczby (parseFloat) i dokonuje sumowania obrotów i czystego zysku w czasie rzeczywistym.
Wykrywanie hitów produktów: Algorytm dynamicznie zlicza liczbę sprzedanych jednostek każdego SKU, określa lidera dnia („Hit sprzedaży”) i wyświetla jego nazwę wraz z liczbą realizacji.
Normalizacja danych: Automatyczna unifikacja nazw produktów i artykułów, nawet jeśli są one nieobecne w poszczególnych obiektach tablicy products.
Wynik:
Projektowanie raportów: Tworzenie rygorystycznego raportu biznesowego w Telegramie z użyciem czcionki monospace dla wygodnego odczytu cyfr i natychmiastowego kopiowania NIP/kwoty jednym dotknięciem.
Kontrola operacyjna: Właściciel otrzymuje pełny obraz sprzedaży w 1 sekundę bez konieczności wchodzenia do CRM i ręcznego budowania filtrów.
Niezawodność: Dzięki hostowaniu na Railway i zoptymalizowanym czasom oczekiwania na połączenie z bazą danych (PostgreSQL), system stabilnie przetwarza zapytania nawet w godzinach szczytu obciążenia na marketplace'ach.
#n8n #SalesDrive #ECommerce #Prom #Rozetka #BusinessIntelligence #Automation #API #Railway
Rozwiązanie: Architektura wielowątkowa na n8n (self-hosted na Railway):
1. Ekstrakcja danych (Pipeline API SalesDrive)
Pobieranie z wielu źródeł: Zrealizowano oddzielne zapytania HTTP dla gałęzi PROM + UMALL oraz ROZETKA. Użyto specyficznych nagłówków autoryzacji dla każdego źródła.
Filtracja precyzyjna: Ustawiono rygorystyczną filtrację według okien czasowych (00:00:00 – 23:58:59) przez parametry orderTime i createTime, co eliminuje pobieranie „historycznych” zamówień przy ich edytowaniu przez menedżerów.
Walidacja statusu: System automatycznie odrzuca techniczne śmieci i anulowane zgłoszenia (status 32/51), gwarantując, że do raportu trafiają tylko rzeczywiste „przychody”.
2. Silnik analityczny (Logika kodu JS)
Agregator finansowy: Węzeł kodu pełni rolę procesora backendowego: parsuje tablice zamówień, konwertuje dane tekstowe na liczby (parseFloat) i dokonuje sumowania obrotów i czystego zysku w czasie rzeczywistym.
Wykrywanie hitów produktów: Algorytm dynamicznie zlicza liczbę sprzedanych jednostek każdego SKU, określa lidera dnia („Hit sprzedaży”) i wyświetla jego nazwę wraz z liczbą realizacji.
Normalizacja danych: Automatyczna unifikacja nazw produktów i artykułów, nawet jeśli są one nieobecne w poszczególnych obiektach tablicy products.
Wynik:
Projektowanie raportów: Tworzenie rygorystycznego raportu biznesowego w Telegramie z użyciem czcionki monospace dla wygodnego odczytu cyfr i natychmiastowego kopiowania NIP/kwoty jednym dotknięciem.
Kontrola operacyjna: Właściciel otrzymuje pełny obraz sprzedaży w 1 sekundę bez konieczności wchodzenia do CRM i ręcznego budowania filtrów.
Niezawodność: Dzięki hostowaniu na Railway i zoptymalizowanym czasom oczekiwania na połączenie z bazą danych (PostgreSQL), system stabilnie przetwarza zapytania nawet w godzinach szczytu obciążenia na marketplace'ach.
#n8n #SalesDrive #ECommerce #Prom #Rozetka #BusinessIntelligence #Automation #API #Railway