ETAP 01
Pobór Zamówień z Wielu Kanałów
Nasłuch webhooków w czasie rzeczywistym z BaseLinkera, Allegro i platformy B2B. Natychmiastowe przyjęcie zlecenia w milisekundach.
Real-Time WebhooksW budowieHurtownie, Magazyny i Dystrybucja B2B · W budowie, szukam firmy pilotażowej
Połączenie Subiekta GT i BaseLinkera: projekt gotowy, czeka na pilotaż
Hurtownie i sklepy na Subiekcie GT tracą godziny na przepisywanie zamówień z BaseLinkera i marketplace’ów, a opóźnione stany kończą się sprzedażą towaru, którego nie ma. Zaprojektowałem szynę, która spina te systemy w kolejce i chroni bazę ERP przed przeciążeniem. Architektura i rdzeń są gotowe; wyniki opublikuję dopiero po pierwszym wdrożeniu u firmy pilotażowej.
Node.jsTypeScriptRedisSubiekt GT Sfera APIPostgreSQLDocker
Architektura inżynierska
Architektura Asynchronicznej Szyny Kolejkowej & Integracji Sfera GT
Jak buforowanie zadań w kolejce Redis BullMQ i sterowanie procesami ERP przez oficjalne API Sfery rozwiązuje problem blokad bazy MSSQL przy pikach sprzedażowych.
ETAP 02
Buforowanie w Kolejce Redis BullMQ
Kolejka transakcyjna izoluje bazę MSSQL Subiekta GT od gwałtownych pików sprzedażowych, dawkując zapytania i zapobiegając deadlockom.
Redis BullMQ QueueETAP 03
Automatyzacja ERP przez Sferę GT
Mikroserwis Node.js komunikuje się z biblioteką Sfera: automatyczne tworzenie kontrahenta, zamówienia ZK oraz wydania zewnętrznego WZ.
Sfera COM API · Node.jsETAP 04
Pętla Zwrotna Stanów Magazynowych (60s)
Asynchroniczny worker odczytuje realne stany dyspozycyjne z magazynu i co 60 sekund rozsyła aktualizacje do BaseLinkera, eliminując overselling.
Two-Way Sync LoopGwarancja spójności: Bezpieczeństwo danych: rozwiązanie działa w infrastrukturze lokalnej klienta (on-premise Docker) bez pośrednictwa zewnętrznych chmur czy prowizji od liczby przesłanych paczek.
Problem i projekt
Dlaczego gotowe integratory zatykają się przy pikach sprzedaży?
Typowe problemy firm na Subiekcie GT i założenia architektury, która ma je usunąć.
Typowe problemy z gotowymi integratorami
Przy promocjach gotowe integratory chmurowe potrafią wysłać do bazy Subiekta setki jednoczesnych zapytań, co kończy się zawieszaniem programu i błędami w stanach magazynowych.
- Deadlocki w bazie MSSQL — pracownicy w biurze nie mogli wystawiać faktur stacjonarnych.
- Overselling: towar sprzedany na Allegro wisiał jeszcze przez godzinę w sklepie internetowym.
- Brak automatycznego tworzenia dokumentów WZ — zamówienia czekały na ręczne kliknięcie.
- Wysokie comiesięczne opłaty abonamentowe rosnące wraz z liczbą obsłużonych zamówień.
Założenia projektowe szyny
Dedykowany mikroserwis Node.js z buforem kolejkowym Redis BullMQ kolejkuje operacje i wykonuje je sekwencyjnie przez stabilne biblioteki Sfery dla Subiekta GT.
- Płynne dawkowanie: baza ERP dostaje ograniczoną liczbę równoległych zapytań.
- Pętla stanów co 60 sekund: natychmiastowa rezerwacja ilości na wszystkich kontach sprzedaży.
- Dokumenty ZK i WZ tworzone automatycznie, bez kliknięcia pracownika biura.
- Bez prowizji: brak jakichkolwiek opłat od wolumenu paczek czy obrotu; dane i integracje zostają u Ciebie.
Moduły integracyjne
Komponenty techniczne szyny
Elementy architektury przygotowane z myślą o pracy magazynu 24 godziny na dobę.
Asynchroniczna synchronizacja stanów (cykle 60s)
Stany magazynowe z Subiekta GT trafiają do BaseLinkera i wszystkich podpiętych marketplace’ów w cyklach co 60 sekund. Rezerwacja towaru następuje w sekundę po złożeniu zamówienia.
Automatyczne dokumenty ZK i WZ przez Sferę
Każde zamówienie spływające z Allegro lub sklepu B2B automatycznie tworzy zamówienie od klienta (ZK) i wydanie zewnętrzne (WZ) bez udziału pracownika biura.
Bufor Redis chroniący bazę ERP przed blokadami
Kolejka BullMQ przyjmuje webhooki od razu i dawkuje zapytania do bazy MSSQL Subiekta, zapobiegając blokadom transakcji (deadlocks).
Odporność na błędy i powiadomienia o wyjątkach
Przy braku mapowania kartoteki towarowej lub błędzie sieci automat podejmuje 3 ponowienia z exponential backoff, a w razie trwałego braku wysyła natychmiastowy alert do kierownika.