Una

User accounts, sessions, roles and password resets.

Multi-tenant directory with tenants and organizations.

Shared configuration storage and helpers for module settings.

User-defined entities, custom fields, and dynamic records storage.

Hybrid query layer with full-text and vector search capabilities.

Auto-generated documentation for all HTTP endpoints.

Tracks user actions and data accesses with undo support scaffolding.

In-app notifications with module-extensible types and actions.

Configurable admin dashboard with module-provided widgets.

File attachments and media management.

Core integration framework — external ID mapping, status badges, and integration registry.

Event bus and subscriber dispatch

Orchestrate business processes with state machines, transitions, and activities

Proces 1A — zarządzanie leadami i pipeline. Byt przed-klientowy: rejestracja, kwalifikacja, przypisanie do handlowca, konwersja do Klienta (customers) albo zamknięcie bez konwersji. Luźny FK po UUID do customers.Customer i auth.User — bez relacji ORM między modułami.

Kanoniczni odbiorcy gazu (Klient). Likwidują placeholder-UUID w hubach (energy_master_data), umowach (contracts) i fakturach (billing) gazowego MVP UNA — luźny FK po UUID, bez relacji ORM między modułami.

Wyszukiwanie i weryfikacja danych polskich firm po NIP/REGON/KRS: GUS REGON (BIR SOAP), KRS (open API), biała lista VAT MF (whitelist + weryfikacja rachunku z requestId), CEIDG v3 (JDG). Zastępuje mockup GUS w module customers.

Proces 1G — Weryfikacja reprezentacji i pełnomocnictw. Karta reprezentacji per klient (dane z registry_pl KRS), rejestracja osób uprawnionych i pełnomocników, walidacja osoby podpisującej dokument (KROK 3). Luźny FK po UUID do customers.Customer i registry_pl.Snapshot — bez relacji ORM między modułami.

Proces 1C — KYC/AML, beneficjent rzeczywisty i status regulacyjny klienta. Sprawa KYC (17 kroków): identyfikacja, profil, struktura właścicielska, UBO, reprezentacja (deleguje do modułu representation), koncesje/URE, sankcje, PEP, ryzyko AML, środki bezpieczeństwa, decyzja Compliance, monitoring. Sprawdzenia zewnętrzne (CRBR/sankcje/PEP/URE) jako MVP-zaślepki + wpis ręczny. Brama offering blokuje handoff przy wyniku negatywnym. Luźny FK po UUID do customers.Customer.

Proces 1D — Wstępna ocena kredytowa klienta. Karta scoringowa (rating A/B/C/D), proponowany limit kredytowy i wymóg zabezpieczenia. Dane zewnętrzne (wywiadownie/rejestry długów) jako MVP-wpis ręczny. Uruchamiana po pozytywnym KYC (subscriber compliance_kyc.case.decided) lub ręcznie. Luźny FK po UUID do customers.Customer i compliance_kyc.KycCase.

Proces 1E — Deduplikacja i golden record klienta. Wykrywanie potencjalnych duplikatów (NIP/REGON/nazwa/adres/PPG/email/telefon, heurystyka in-app), klasyfikacja, kontrolowane i audytowalne scalanie w golden record z repointem powiązanych danych etapu akwizycji. Scalanie blokowane, gdy rekord tracony ma dane finansowe/kontraktowe. Luźny FK po UUID do customers.Customer.

Proces 1F — Zgody i RODO. Rejestr zgód per osoba kontaktowa (customers.CustomerContact), wersjonowanie klauzul informacyjnych, udzielanie/wycofanie/wygaśnięcie zgód i wyliczanie aktualnych preferencji kontaktu (handlowy/marketingowy/email/telefon/eBOK/dokumenty). Serwis DI consentsService dla przyszłych modułów komunikacji i bramy contracts. Luźny FK po UUID do customers — bez relacji ORM między modułami, bez PII na encjach.

Proces 1H — Kontakty i aktywności CRM. Rejestr aktywności (telefon/email/spotkanie/notatka/dokumenty), zadania handlowe/operacyjne ze statusami i terminami, automatyczne przypomnienia (core notifications) i oś czasu klienta/leada. Podmiot polimorficzny (lead albo karta klienta) — luźny FK po UUID, bez relacji ORM między modułami. Wolny tekst szyfrowany (PII).

Kanoniczna hierarchia Klient → Hub → PointOfDelivery (PPG) → Licznik. Bitemporalne przypisania PPG ↔ klient/OSD/grupa taryfowa oraz licznik ↔ PPG. Fundament danych podstawowych gazowego MVP UNA (ADR-D10).

Transport SFTP/platforma OSD gazowego (PSGaz): ingest odczytów pomiarowych + dwukierunkowa wymiana komunikatów switchingu. Domyka audyt F1 §4 — wspólny konektor dla metering (DAT-002) i switching (DAT-003). DG1: tylko OSD gazowy SFTP, nie CSIRE/AS4.

Import danych pomiarowych OSD, VEE (walidacja/estymacja), konwersja m³→kWh (Wk per obszar OSD), niemutowalna migawka MeteringDataSnapshot, okresy rozliczeniowe, Correction Case. Rdzeń gazowego MVP UNA (REQ-001–REQ-012, DG2).

Indeksy cen rynkowych gazu (TGE/TTF/NBP) i governance publikacji fixingów. Dane wejściowe dla formuł indeksowanych w module pricing (REQ-005, REQ-013). Standalone OM, ADR-D12.

Taryfy gazowe (Sprzedawca + OSD pass-through), formuły cenowe (fixed/indexed TGE/TTF), RatingService deterministyczny, snapshoty wyceny i kalkulacja marży. Blok 2/6 Data Master UNA (ADR-D12).

CLM umów sprzedaży gazu (Blok 3 Data Master). Contract + ContractVersion + bitemporalne assignments (PPG, produkt, cena, security), PoA + Signatory, kalendarz operacyjny, aneksy/wypowiedzenia/przedłużenia, take-or-pay. Trigger switchingu przez contracts.ppg.added (audyt F1 P-04).

Moduł billing — Invoice/KSeF/akcyza/VAT/korekty + FI-CA balance (P-01). Blok 6 Data Master: meter-to-cash, BillingRun/BillingBatch/BillingDataPackage, KsefSubmission (FA(3) MVP mock), TaxBreakdown, CorrectiveInvoice, BillingAccount + Receivable + CustomerBalance (właściciel salda). Saga meterToCash = Temporal Tier 1 (om-temporal-saga — odrębny agent).

Moduł payments — MT940 import, auto/manual matching, N:M allocation (partial/overpay), virtual accounts (PAT-001), online payments (payment_gateways FK), overdue detection. Blok 7 Data Master: order-to-cash domknięcie po stronie pieniądza. P-01: Receivable + CustomerBalance = właściciel billing; payments emituje payments.payment.matched → billing aktualizuje saldo (P-07). P-05: wszystkie event IDs 3-członowe.

Zmiana sprzedawcy gazu przez OSD gazowy (NIE CSIRE — ADR DG1/0005). Blok 4 Data Master (4H–4P). SwitchingCase (per PPG) + SwitchingPackage (4J, częściowa akceptacja) + SwitchingRequest do OSD przez connector_osd_gaz, odczyt graniczny z metering (P-03, 4K), SLA monitoring (4L), rezygnacja/ponowienie (4M/4N), sprzedaż rezerwowa (4P). Trigger: contracts.ppg.added (P-04). PoA fail-closed (REQ-007, AC-002). Saga switchingWorkflow → om-temporal-saga agent (lib/saga/** intentionally NOT here).

Transport MT940 z banku przez SFTP/H2H: pobieranie wyciągów, parsowanie do kanonicznego BankStatement DTO, emisja eventu connector_bank.statement.imported. Zastępuje mock importu MT940 w module payments (SVC-001). Gaz MVP — tylko inbound MT940, bez payouts/settlement.

MOCKUP seam — eksport zaksięgowanych faktur z billing do zewnętrznego programu księgowego (ERP). Transport STUB: adapter zapisuje postingi do AccountingPostingLog ze statusem MOCKED, bez realnego połączenia. TODO: podłącz AccountingAdapter.send() do właściwego API programu księgowego.

Windykacja należności — DunningCase/Policy/Level/Step/Letter. Konsumuje payments.receivable.overdue → otwiera sprawę windykacyjną. Eskalacja przez Tier 2 USER_TASK (ReactFlow/OM workflows). Emituje dunning.case.opened / dunning.case.escalated / dunning.case.closed. PII w pismach przez TenantDataEncryptionService.