> Folyamatos folyamatfejlesztés > Fizetésfeldolgozás > SWIFT > Adatsablon

Fizetésfeldolgozási adatsablon

SWIFT

← Vissza a folyamatfejlesztési útmutatóhoz

A fizetésfeldolgozás attribútumai(19) A fizetésfeldolgozás tevékenységei(12) Útmutatók az adatok kinyeréséhez(3)

Fizetésfeldolgozási adatsablon

Ez a sablon adja a SWIFT-tranzakciók kezdeményezéstől a végső elszámolásig tartó munkafolyamatának feltérképezéséhez szükséges alapot. Bemutatja azokat az adatokat és működési mérföldköveket, amelyekkel teljes képet kaphat a fizetések életciklusáról. Az útmutató segítségével előkészítheti az adatokat a rejtett hatékonysági problémák feltárásához és a megfelelési kockázatok csökkentéséhez.

Javasolt attribútumok a tranzakciók részletes elemzéséhez
A SWIFT-folyamat fő tevékenységei és mérföldkövei
Technikai útmutató pénzügyi adatok kinyeréséhez

Most ismerkedik az eseménynaplókkal? Tudja meg, hogyan készíthet process mining eseménynaplót.

Sablon letöltése

A fizetésfeldolgozás attribútumai

Az alábbi adatmezőket javasoljuk felvenni az eseménynaplóba, hogy átfogóan elemezhesse a SWIFT-tranzakciók teljes életciklusát.

5 Kötelező 9 Javasolt 5 Nem kötelező

	Név	Leírás
	Esemény időbélyege EventTimestamp	A tevékenység pontos dátuma és időpontja.
Leírás Ez az attribútum rögzíti az esemény pontos időpontját. A tevékenységek időrendi sorrendbe állítására és az időtartam-alapú mutatók, például az átfutási idő, a ciklusidő és az áteresztőképesség kiszámítására használható. A pontos időbélyegek nélkülözhetetlenek a „hálózati határidők betartásának” elemzéséhez és a jóváhagyási folyamat szűk keresztmetszeteinek feltárásához. Miért fontos? Az időbélyegek képezik a process mining időbeli elemzéseinek és teljesítménymutatóinak alapját. Hol szerezhető be? Rendszernaplók, üzenetlétrehozási időbélyegek vagy adatbázis-tranzakciók időpontjai. Példák 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	Fizetési tranzakcióazonosító PaymentTransactionId	A teljes fizetési folyamatot azonosító egyedi érték.
Leírás Ez az attribútum a process mining központi esetazonosítója. Egyetlen fizetési megbízás összes tevékenységét összekapcsolja a kezdeti kérelemtől az ellenőrzésen és a SWIFT-továbbításon át a végső elszámolásig. SWIFT-környezetben gyakran a tranzakcióhivatkozási számhoz (TRN) vagy az egyedi, végpontok közötti tranzakcióhivatkozáshoz (UETR) rendelik, hogy a banki rendszerek között is követhető maradjon. Segítségével rekonstruálható a folyamat egyes példányainak útvonala, és nélkülözhetetlen a folyamatváltozatok elemzéséhez, valamint a feldolgozási idő kiszámításához. Miért fontos? Az egyedi azonosítás a process mining alapja: segítségével a szétszórt események összekapcsolhatók, és egységes folyamatképpé állíthatók össze. Hol szerezhető be? A SWIFT-üzenet fejlécének 20. mezője (TRN) vagy 121. mezője (UETR). Példák TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	Forrásrendszer SourceSystem	Annak a rendszernek a neve, amelyből az eseményadatok származnak.
Leírás Azonosítja azt a szoftvert vagy platformot, amely létrehozta az eseménynaplót. A fizetési folyamatban ez lehet az alapvető banki rendszer, a fizetési átjáró vagy közvetlenül a SWIFT-interfész. Ez az attribútum segít ellenőrizni az adatok eredetét, és hibakereséskor is hasznos, ha több, egymástól független banki alkalmazás adatait kell összekapcsolni. Miért fontos? Megmutatja az adatok eredetét, ami több rendszerre kiterjedő process mining esetén nélkülözhetetlen. Hol szerezhető be? Az ETL-folyamat során rögzítve vagy a rendszerazonosítókból kinyerve. Példák SWIFT Alliance AccessAlapvető banki rendszerFizetési motorSzankciószűrő
	Tevékenység neve ActivityName	A végrehajtott folyamatlépés vagy bekövetkezett esemény neve.
Leírás Ez az attribútum a rendszer naplójában rögzített konkrét műveletet vagy állapotváltozást írja le. Ilyen például a „Fizetési kérelem létrehozva”, „A szankciószűrés sikeres” vagy a „SWIFT ACK megérkezett”. A folyamattérképek elsődleges dimenziója: ez határozza meg a megjelenítés csomópontjait, és segít az elemzőknek megérteni a fizetés során végrehajtott műveletek sorrendjét. Miért fontos? Megmutatja, hogy mi történik a folyamatban, így megjeleníthető a folyamat menete és az eltérések. Hol szerezhető be? Tranzakciós naplók, ellenőrzési nyomvonalak vagy az üzenettípusokból származtatott adatok, például MT103 elküldve. Példák Fizetési kérelem létrehozvaFizetési megbízás elküldveSWIFT ACK megérkezettFizetés jóváhagyva
	Utolsó adatfrissítés LastDataUpdate	Az időbélyeg, amely megmutatja, mikor nyerték ki vagy frissítették utoljára a rekordot.
Leírás Megmutatja, mikor töltötték be utoljára az adatokat a process mining eszközbe. Ez alapján ellenőrizhető az adatok frissessége, és hogy a dashboardok a fizetési folyamatok legújabb állapotát mutatják-e. Az adatbetöltési folyamat késleltetésének feltüntetésével segít megbízni a megjelenített adatokban. Miért fontos? Segít a felhasználóknak megítélni a megjelenített adatok frissességét és megbízhatóságát. Hol szerezhető be? Az ETL-folyamat futtatásának időbélyege. Példák 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	Értéknap ValueDate	Az a nap, amikor az összeget a kedvezményezett rendelkezésére kell bocsátani.
Leírás A fizetési üzenetben megadott elszámolási napot jelöli. Ha ezt összeveti a tényleges „Payment Settled” időbélyeggel, adatokat kap a „Settlement and Reconciliation Aging” dashboardhoz. Jelzi a fizetés sürgősségét, és az összegek rendelkezésre bocsátására vonatkozó szolgáltatási szintű megállapodások teljesítésének mérésére is használható. Miért fontos? Elengedhetetlen a likviditás kezeléséhez és az elszámolások időzítésének méréséhez. Hol szerezhető be? SWIFT MT 32A mező (dátum almező) vagy az ISO 20022 IntrBkSttlmDt eleme. Példák 2023-10-262023-11-01
	Feldolgozást végző felhasználó ProcessingUser	A tevékenységet végrehajtó felhasználó vagy rendszerügynök.
Leírás Azonosítja a tevékenységért felelős személyt vagy automatizált botot, például a szankciós találatot jóváhagyó megfelelési munkatársat vagy a formázási hibát javító ügyintézőt. Ez az attribútum szolgáltatja az adatokat a „Validation Error Heatmap” dashboardhoz. A vezetők így azonosíthatják a képzési igényeket, illetve azokat a felhasználókat, akikhez sok utómunka kapcsolódik. Miért fontos? Lehetővé teszi az erőforrások elemzését és a manuális szűk keresztmetszetek azonosítását. Hol szerezhető be? Rendszer-auditnaplók, a tranzakciós táblák „User ID” oszlopa. Példák SYSTEMJ.DoeCompliance_Bot_01M.Smith
	Kedvezményezett BIC-kódja BeneficiaryBic	A fogadó intézmény bankazonosító kódja.
Leírás Azonosítja a fizetés célbankját. Ez a „Beneficiary Rejection Root Cause” dashboard egyik fontos dimenziója. A kedvezményezett BIC-kódja szerint csoportosítva az elutasításokat a bank azonosíthatja azokat a partnereket, amelyek gyakran utasítják vissza a megbízásokat adatminőségi problémák vagy egyedi formázási követelmények miatt. Miért fontos? Elengedhetetlen a partneri teljesítmény és az elutasítási minták elemzéséhez. Hol szerezhető be? SWIFT 57A mező (számlavezető intézmény) vagy 58A mező (kedvezményezett intézménye). Példák CITIUS33BARCGB22DRESDEFFHANDSEXX
	STP-feldolgozás IsStp	Jelzi, hogy a fizetéshez szükség volt-e manuális beavatkozásra.
Leírás Logikai jelző, amelynek értéke True, ha az esetben nem szerepel „Error Identified”, „Payment Rejected” vagy manuális „Modification” tevékenység. Ezzel közvetlenül kiszámítható a „Straight-Through Processing Rate” KPI. Ez a fizetésfeldolgozás automatizálásának elsődleges mérőszáma. Miért fontos? A folyamat hatékonyságának és az automatizálás állapotának elsődleges mérőszáma. Hol szerezhető be? Az esetben szereplő meghatározott negatív vagy manuális tevékenységek hiánya alapján számítható ki. Példák truefalse
	SWIFT NAK-kód SwiftNakCode	A SWIFT-hálózat által visszaküldött hibakód, ha elutasít egy üzenetet.
Leírás A SWIFT-hálózat negatív visszaigazolásában (NAK) szereplő konkrét hibakódot tartalmazza (például T26 vagy T13). Ez az attribútum biztosítja az adatokat a „SWIFT Error and Rework Analysis” dashboardhoz. Segítségével kategorizálhatók a technikai hibák, és előnyben részesíthetők a rendszerjavítások. Miért fontos? Feltárja a hálózati szintű elutasítások technikai okait. Hol szerezhető be? MT 015/019 rendszerüzenetek vagy az ACK/NAK 451. mezője. Példák T26H01T13G02
	SWIFT-üzenettípus SwiftMessageType	A használt SWIFT-üzenet típusa (például MT103 vagy pacs.008).
Leírás Megadja a fizetési megbízás formátumát. Gyakori típus az ügyfélátutalásokhoz használt MT103, illetve annak ISO 20022-es megfelelője, a pacs.008. A „Payment Journey Variant Analysis” elemzésben a régi MT-formátumok és az új ISO-szabványok feldolgozási hatékonysága hasonlítható össze vele. Miért fontos? Megkülönbözteti a fizetési folyamatokat és a feldolgozási szabványokat (régi formátumok vagy ISO 20022). Hol szerezhető be? SWIFT 2. blokk (alkalmazásfejléc), az üzenettípus mező. Példák MT103MT202pacs.008MT101
	Tranzakció devizaneme TransactionCurrency	A fizetési pénznemet jelölő hárombetűs ISO-kód.
Leírás Megadja, milyen pénznemben történik a fizetés (például USD, EUR vagy GBP). Ez fontos a „Network Cut Off Time Performance” dashboardhoz, mert a határidők pénznemenként eltérnek. A „Currency Conversion Efficiency” elemzésben is használható a különböző pénznemű párok azonosítására. Miért fontos? Meghatározza az útválasztási szabályokat, a határidőket és az elszámolási útvonalakat. Hol szerezhető be? SWIFT MT 32A mező (pénznem) vagy az ISO 20022 Ccy eleme. Példák USDEURGBPJPY
	Tranzakció összege TransactionAmount	A fizetési megbízás pénzben kifejezett értéke.
Leírás Az átutalt tőkeösszeget jelöli. A SWIFT-üzenet meghatározott mezőiből nyerhető ki, például az MT103 32A mezőjéből. A „High Value Transfer Approval Cycles” dashboard egyik alapadata. Lehetővé teszi a fizetések összeg szerinti csoportosítását, így elemezhetők a nagy kockázatú, nagy összegű tranzakciók jóváhagyási késedelmei. Miért fontos? Lehetővé teszi a pénzügyi hatás elemzését és a tranzakciók összeg szerinti csoportosítását. Hol szerezhető be? A SWIFT MT 32A mezője (összeg) vagy az ISO 20022 IntrBkSttlmAmt eleme. Példák 15000.001250.501000000.0045.00
	UETR UniqueEndToEndReference	A SWIFT gpi rendszerben történő nyomon követéshez használt egyedi, végpontok közötti tranzakcióazonosító.
Leírás Az UETR egy 36 karakteres karakterlánc, amely a teljes SWIFT-hálózaton egyetlen, nem változó hivatkozást biztosít a fizetéshez. A belső azonosítókkal ellentétben az UETR a bankok között is változatlan marad. Ez az attribútum elengedhetetlen a teljes folyamat átláthatóságához, valamint a belső naplók és a SWIFT gpi külső állapotfrissítéseinek összekapcsolásához. Miért fontos? A határokon átnyúló fizetések különböző intézmények közötti nyomon követésének bevett szabványa. Hol szerezhető be? SWIFT 3. blokk, 121. mező. Példák b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Elutasítás oka RejectionReason	Az elutasítás okát leíró szöveg.
Leírás A sikertelen fizetés szöveges indoklását vagy kódleírását tartalmazza. Ez jellemzően a SWIFT 72. mezőjében (küldőtől a fogadóhoz intézett információ) vagy a visszaküldött üzenetekben található. A „Beneficiary Rejection Root Cause” elemzéshez használható. Az elemzők szövegbányászattal azonosíthatják az elutasítások gyakori okait, például az „Invalid Account” vagy a „Beneficiary Name Mismatch” eseteket. Miért fontos? Kiegészítő információt ad a folyamat hibáiról. Hol szerezhető be? A SWIFT 72. vagy 79. mezője a visszaküldött üzenetekben (MT103 Return). Példák A kedvezményezett számlája lezárvaÉrvénytelen IBANMegfelelési ellenőrzés sikertelenIsmeretlen bankazonosító
	Határidőn belül teljesült MetCutOffTime	Jelzi, hogy a megbízást a hálózati határidő előtt küldték-e el.
Leírás Logikai jelző, amely a „Payment Instruction Sent” időpontját a pénznemhez tartozó SWIFT-hálózati határidővel összevetve számítható ki. A „SWIFT Cut-off Adherence Rate” KPI kiszámításához használható. A határidő elmulasztása késlelteti az elszámolást, és hatással van a likviditási pozíciókra. Miért fontos? Fontos működési KPI a treasury és a likviditás kezeléséhez. Hol szerezhető be? Az időbélyeg és a határidőket tartalmazó statikus referencia-tábla összevetésével számítható ki. Példák truefalse
	Határon átnyúló fizetés IsCrossBorder	Jelzi, hogy a fizetés több országot érint-e.
Leírás Logikai attribútum, amelynek értéke True, ha a küldő országa eltér a kedvezményezett országától. A „Multi-Currency Handling Latency” KPI számításakor ezzel választhatók külön a belföldi és a nemzetközi fizetések. A határon átnyúló fizetések általában összetettebbek, költségesebbek és hosszabb feldolgozási időt igényelnek. Miért fontos? A fizetések összetettségének elemzéséhez szükséges alapvető szegmentálás. Hol szerezhető be? A küldő BIC-kódjában és a kedvezményezett BIC-kódjában szereplő országkód összehasonlítása. Példák truefalse
	Kezdeményező ország OriginatingCountry	A fizetést kezdeményező szervezet országkódja.
Leírás Megadja, melyik joghatóságból indult a fizetési kérelem. Ez fontos a „Sanctions Screening Lead Time” dashboardhoz, mert a magas kockázatú joghatóságokból érkező fizetések szigorúbb és hosszabb megfelelési ellenőrzésen esnek át. Lehetővé teszi a fizetési volumenek és a feldolgozási késedelmek földrajzi elemzését. Miért fontos? A megfelelési kockázatok és a regionális teljesítmény elemzésének fontos dimenziója. Hol szerezhető be? A küldő BIC-kódjából származik (az 5–6. karakter az országkód). Példák USGBDEFR
	Megbízás prioritása InstructionPriority	A fizetés sürgősségét jelző prioritásjelző.
Leírás Az üzenet fejlécéből származik (például „Normal” vagy „Urgent”). A „High Value Transfer Approval Cycles” dashboardon ez alapján szegmentálhatók a fizetések, mivel a sürgős utalások jóváhagyása gyakran gyorsított folyamatban történik. A prioritások megoszlásának ismerete segít az erőforrások megtervezésében a csúcsidőszakokra. Miért fontos? Segít megkülönböztetni a normál és a gyorsított fizetésekre vonatkozó SLA-követelményeket. Hol szerezhető be? SWIFT 2. blokk, az üzenet prioritásának mezője (például N a normál, U a sürgős prioritáshoz). Példák NormálSürgősRendszer

Kötelező Javasolt Nem kötelező

A fizetésfeldolgozás tevékenységei

A pontos folyamattérképezéshez és a szűk keresztmetszetek azonosításához ezeket a fő folyamatlépéseket és mérföldköveket rögzítse az eseménynaplóban.

6 Javasolt 6 Nem kötelező

	Tevékenység	Leírás
	A szankciószűrés sikeres	Az az időbélyeg, amikor a fizetési megbízás sikeresen átmegy az OFAC- és szankciós listák ellenőrzésén. Közvetlenül a megfelelési rendszer naplóiból rögzíthető, vagy abból állapítható meg, hogy feloldják a „Screening Hold” állapotot.
Miért fontos? A „Sanctions Screening Lead Time” dashboard egyik alapadata. Az itt jelentkező késedelmek megfelelési szűk keresztmetszetre, nem pedig működési hatékonysági problémára utalnak. Hol szerezhető be? A megfelelési szűrőrendszer naplói vagy a Payment Hub megfelelési állapotjelzői. Rögzítés A szűrési állapot frissítésekor naplózva Eseménytípus explicit
	Fizetés egyeztetve	A fizetési tranzakció összevetése a Nostro/Vostro számla főkönyvi kivonatával. Abból állapítható meg, hogy az egyeztető rendszer összekapcsolja a tranzakcióazonosítót a kivonat megfelelő sorával.
Miért fontos? Lezárja a pénzügyi folyamatot. Az itt jelentkező késedelmek rontják a pénzforgalom átláthatóságát és az ellenőrizhetőséget. Hol szerezhető be? Az egyeztető rendszer naplói vagy a Core Banking System „Matched” állapota. Rögzítés Hasonlítsa össze az egyeztetési állapotot Eseménytípus inferred
	Fizetés elszámolva	Annak visszaigazolása, hogy az összeget jóváírták a kedvezményezett számláján, gyakran a gpi ACSC állapot alapján. A nyomkövetési frissítésekből vagy visszaigazoló üzenetekből rögzíthető.
Miért fontos? A fizetési folyamat sikeres lezárását jelzi. A „Settlement to Reconciliation Gap” kiszámításához nélkülözhetetlen. Hol szerezhető be? A SWIFT gpi Tracker (ACSC állapot) vagy az MT900/910 visszaigazolások. Rögzítés Az elszámolás visszaigazolásakor naplózva Eseménytípus explicit
	Fizetés jóváhagyva	A kijelölt munkatárs vagy a nagy összegű átutalásokra vonatkozó automatizált szabály végső jóváhagyása. Közvetlenül rögzíthető, amikor a jóváhagyási munkafolyamat jelzője true értékre vált.
Miért fontos? A „High Value Transfer Approval Cycles” dashboard egyik alapadata. Feltárja a nagy összegű pénzmozgások manuális jóváhagyása során jelentkező késedelmeket. Hol szerezhető be? A jóváhagyási munkafolyamatot kezelő rendszer ellenőrzési nyomvonala. Rögzítés A jóváhagyási művelet végrehajtásakor naplózva Eseménytípus explicit
	Fizetési kérelem létrehozva	A fizetési megbízás első rögzítése a belső banki rendszerben vagy ERP-rendszerben. Ez az esemény akkor rögzíthető egyértelműen, amikor a fizetési megbízás megkapja az egyedi tranzakcióhivatkozást (TRN vagy UETR).
Miért fontos? Ez jelöli a teljes fizetési folyamat kezdetét. Nélkülözhetetlen a teljes feldolgozási idő kiszámításához és a SWIFT-hálózat bekapcsolódása előtti késedelmek feltárásához. Hol szerezhető be? A tranzakciós rekord létrehozásának időbélyege a Core Banking Systemben (CBS) vagy a Payment Hubban. Rögzítés A tranzakciós rekord létrehozásakor naplózva Eseménytípus explicit
	Fizetési megbízás elküldve	A formázott üzenet (MT103 vagy ISO 20022 pacs.008) továbbítása a SWIFT Gateway felé. Az esemény akkor rögzíthető egyértelműen, amikor létrejön az üzenet tartalma, és átadják a hálózati interfésznek.
Miért fontos? A „SWIFT Cut-off Adherence Rate” kiszámításához használható. Ez jelöli a belső feldolgozás és a hálózati feldolgozás közötti átmenetet. Hol szerezhető be? A SWIFT Alliance Access (SAA) naplói vagy az átjáró továbbítási naplói. Rögzítés Az üzenet kimenetekor naplózva Eseménytípus explicit
	Fizetés elutasítva	A kedvezményezett vagy a közvetítő bank elutasító üzenetének megérkezése, például MT103 Return vagy gpi RJCT állapot. Közvetlenül a beérkező SWIFT-üzenetekből rögzíthető.
Miért fontos? A „Beneficiary Rejection Root Cause” dashboard egyik alapadata. Olyan külső akadályokat tár fel, mint a lezárt számla vagy a hibás útválasztási adat. Hol szerezhető be? Beérkező SWIFT-üzenetek, például MT103 RET vagy pacs.004, illetve a gpi RJCT állapot. Rögzítés Az elutasító üzenet megérkezésekor naplózva Eseménytípus explicit
	Fizetés továbbítva	Köztes állapotfrissítés, gyakran a gpi ACSP állapot, amely jelzi, hogy a közvetítő bank feldolgozza a fizetést. A SWIFT gpi Tracker frissítéseiből vagy állapotüzeneteiből rögzíthető.
Miért fontos? Átláthatóvá teszi a levelezőbanki folyamatok egyébként nehezen követhető szakaszait. A teljes folyamat elemzéséhez nélkülözhetetlen. Hol szerezhető be? A SWIFT gpi Tracker adatfolyamai vagy az MT199/trck üzenetek. Rögzítés A nyomkövetési frissítés megérkezésekor naplózva Eseménytípus explicit
	Fizetési adatok ellenőrizve	A fizetési megbízás szintaktikai és formátumellenőrzésének sikeres lezárása, például az IBAN formátumának és a BIC érvényességének ellenőrzése. Ez gyakran abból állapítható meg, hogy a tranzakció állapota „Draft” értékről „Validated” vagy „Ready for Auth” értékre vált.
Miért fontos? A magas hibaarány az adatok forrásnál tapasztalható gyenge minőségére utal. Ezzel mérhető az „első ellenőrzéskor megfelelő adatok aránya” KPI. Hol szerezhető be? A Payment Engine állapotnaplói vagy az ellenőrzési előzményeket tartalmazó táblák. Rögzítés Hasonlítsa össze az állapotmező értékét a módosítás előtt és után Eseménytípus inferred
	Fizetési hiba azonosítva	Az az esemény, amikor egy tranzakciót ellenőrzési hiba, NACK vagy elutasító üzenet miatt javításra jelölnek. Abból állapítható meg, hogy a tranzakció „Repair”, „Correction” vagy „Exception” várólistára kerül.
Miért fontos? Ezzel mérhető a „hibajavítási újramunka aránya”. A gyakori előfordulás jelentősen rontja az egyenes feldolgozás (STP) arányát. Hol szerezhető be? A Payment Hub állapotmezői vagy a kivételkezelési várólisták naplói. Rögzítés Ellenőrizze, hogy az állapotmező értéke Error vagy Repair-e Eseménytípus inferred
	Fizetési hiba megoldva	A korábban hibás tranzakció sikeres módosítása és újbóli beküldése. Abból állapítható meg, hogy a tranzakció a „Repair” várólistáról visszakerül a „Processing” vagy „Ready” állapotba.
Miért fontos? A manuális javításokat végző csapat hatékonyságát méri. A hosszú időtartam betanítási hiányosságra vagy összetett hibakódokra utalhat. Hol szerezhető be? A Payment Hub állapotnaplói, amelyek a kivételkezelési várólistáról való kilépést mutatják. Rögzítés Ellenőrizze, hogy az állapotmezőből kilépett-e a Repair állapotból Eseménytípus inferred
	SWIFT ACK megérkezett	A SWIFT-hálózattól érkező technikai visszaigazolás (ACK), amely megerősíti, hogy a hálózat befogadta az üzenetet feldolgozásra. Közvetlenül a hálózati interfész naplóiból rögzíthető.
Miért fontos? Megerősíti, hogy az üzenet sikeresen bekerült a globális hálózatba. Segít megkülönböztetni a belső hibákat a hálózati továbbítás során fellépő problémáktól. Hol szerezhető be? SWIFT Gateway-naplók (az ACK és NACK jelzések kereséséhez). Rögzítés A hálózati ACK megérkezésekor naplózva Eseménytípus explicit

Javasolt Nem kötelező

Útmutatók az adatok kinyeréséhez

Adatok kinyerése a SWIFT rendszerből

Lépések

Jelentkezzen be a SWIFT Alliance WebPlatformba vagy az Alliance Access GUI-ba olyan rendszergazdai fiókkal, amely hozzáfér az archiválási beállításokhoz.
Nyissa meg a System Management menüt, válassza az Archiving, majd az Automated Archiving Configuration lehetőséget.
Hozzon létre új, napi exportprofilt. A Target Directory mezőben adjon meg egy biztonságos hálózati elérési utat, amelyhez az adatkinyerő szkriptek hozzáférnek.
Adja meg a tartalom körét: válassza a „Messages” lehetőséget, és jelölje be az „Include History” és az „Include Interventions” opciókat. Ezek szükségesek az ellenőrzési napló eseményeinek, például a jóváhagyásoknak és az ellenőrzéseknek a rögzítéséhez.
Válassza ki a kimeneti formátumot. A CSV-nél jobban megőrzi az üzenetfejléc és az előzmények közötti hierarchikus kapcsolatot az XML, ezért válassza az XML-t, azon belül az „SAA XML v2” sémát vagy a legújabb elérhető változatot.
Állítsa be a dátumtartományt a folyamatelemzési kezdeményezéshez szükséges előzmények kinyeréséhez, vagy ütemezze az exportot napi futásra, T-1 adatokkal.
Az első betöltéshez futtassa le kézzel az archívumexportot, vagy várja meg az ütemezett kötegelt feladat befejezését. Ellenőrizze, hogy létrejöttek-e az .xml fájlok a célkönyvtárban.
Az SAA-export hierarchikus XML-fájl, a ProcessMind viszont lapos CSV-eseménynaplót igényel, ezért futtasson egy átalakító szkriptet. Az XML feldolgozásához használja a Query szakaszban megadott Python-szkriptet.
A szkript végigmegy az összes üzenetelemen. Az esetazonosítóként használt egyedi, végpontok közötti tranzakcióazonosítót (UETR) vagy tranzakcióhivatkozási számot (TRN) nyeri ki.
Ezután a szkript végigmegy az egyes üzenetek „History” és „Intervention” gyermekcsomópontjain, és tevékenységsorokat hoz létre. A belső SAA-állapotkódokat, például a „NetworkAck” és az „Authorisation” értékeket szabványosított tevékenységnevekre képezi le.
Futtassa a Python-szkriptet az exportált XML-fájlokon az „events.csv” lapos fájl létrehozásához.
Ellenőrizze a CSV-kimenetet, például azt, hogy az EventTimestamp oszlop ISO 8601 formátumú-e, majd töltse fel a fájlt a ProcessMindba.

Konfiguráció

Archívumformátum: XML (ajánlott) vagy CSV (lapos fájl). A beágyazott előzménycsomópontok rögzítéséhez az XML használata javasolt.
Üzenettörzs felvétele: igen (szükséges az összeg, a pénznem és a kedvezményezett adatainak kinyeréséhez).
Előzmények és beavatkozások felvétele: igen (a jóváhagyások, ellenőrzések és hibák megjelenítéséhez kötelező).
Dátumtartomány: növekvő időablakot állítson be, például az utolsó 30 napot a fokozatos betöltéshez, vagy rögzített dátumokat az előzmények első betöltéséhez.
Üzenettípusok: szűrjön az MT103, MT202, pacs.008, pacs.009 és pacs.004/002 típusokra (visszautalásokhoz és állapotokhoz).
Irányok: a bejövő (Emission) és a kimenő (Reception) üzeneteket is vegye fel a beérkező elutasítások és visszaigazolások rögzítéséhez.
Biztonság: korlátozza szigorúan az exportmappa olvasási és írási jogosultságait, mert ezek a fájlok éles fizetési adatokat tartalmaznak.

Példa-lekérdezés python

import xml.etree.ElementTree as ET
import pandas as pd
import glob
import os

class=class="hl-string">"hl-comment"># CONFIGURATION
class=class="hl-string">"hl-comment"># Update this path to your SAA XML Export directory
input_folder = class="hl-string">"./saa_exports/"
output_file = class="hl-string">"./swift_process_mining_log.csv"

columns = [
    class="hl-string">"PaymentTransactionId", class="hl-string">"ActivityName", class="hl-string">"EventTimestamp", class="hl-string">"SourceSystem", 
    class="hl-string">"LastDataUpdate", class="hl-string">"TransactionAmount", class="hl-string">"TransactionCurrency", class="hl-string">"UniqueEndToEndReference",
    class="hl-string">"SwiftMessageType", class="hl-string">"ProcessingUser", class="hl-string">"BeneficiaryBic", class="hl-string">"SwiftNakCode", class="hl-string">"ValueDate", class="hl-string">"IsStp"
]

data_rows = []

class=class="hl-string">"hl-comment"># Helper to determine Activity Name based on SAA History Events
def map_activity(history_item_name, status, nature, text_content):
    class=class="hl-string">"hl-comment"># 1. Payment Request Created
    if history_item_name == class="hl-string">"Creation" or history_item_name == class="hl-string">"Reception":
        return class="hl-string">"Payment Request Created"
    
    class=class="hl-string">"hl-comment"># 2. Payment Details Validated
    if class="hl-string">"Validation" in history_item_name and status == class="hl-string">"Success":
        return class="hl-string">"Payment Details Validated"
    
    class=class="hl-string">"hl-comment"># 3. Sanctions Screening Passed
    if class="hl-string">"Filter" in history_item_name and status == class="hl-string">"Passed":
        return class="hl-string">"Sanctions Screening Passed"
    
    class=class="hl-string">"hl-comment"># 4. Payment Approved
    if history_item_name == class="hl-string">"Intervention" and nature == class="hl-string">"Authorization":
        return class="hl-string">"Payment Approved"
    
    class=class="hl-string">"hl-comment"># 5. Payment Instruction Sent
    if history_item_name == class="hl-string">"Transmission" or status == class="hl-string">"Transmitted":
        return class="hl-string">"Payment Instruction Sent"
    
    class=class="hl-string">"hl-comment"># 6. SWIFT ACK Received
    if history_item_name == class="hl-string">"NetworkReport" and class="hl-string">"ACK" in text_content:
        return class="hl-string">"SWIFT ACK Received"

    class=class="hl-string">"hl-comment"># 7. Payment Transferred (gpi status)
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"ACSP" in text_content:
        return class="hl-string">"Payment Transferred"

    class=class="hl-string">"hl-comment"># 8. Payment Error Identified
    if nature == class="hl-string">"NAK" or status == class="hl-string">"Failed" or nature == class="hl-string">"RoutingFailure":
        return class="hl-string">"Payment Error Identified"

    class=class="hl-string">"hl-comment"># 9. Payment Error Resolved
    if history_item_name == class="hl-string">"Modification" and nature == class="hl-string">"Repair":
        return class="hl-string">"Payment Error Resolved"
    
    class=class="hl-string">"hl-comment"># 10. Payment Rejected
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"RJCT" in text_content:
        return class="hl-string">"Payment Rejected"

    class=class="hl-string">"hl-comment"># 11. Payment Settled
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"ACSC" in text_content:
        return class="hl-string">"Payment Settled"

    class=class="hl-string">"hl-comment"># 12. Payment Reconciled
    class=class="hl-string">"hl-comment"># Often external, but if SAA receives a Reconciliation update:
    if history_item_name == class="hl-string">"ReconciliationMatch":
        return class="hl-string">"Payment Reconciled"
        
    return None

class=class="hl-string">"hl-comment"># PROCESS XML FILES
for xml_file in glob.glob(os.path.join(input_folder, class="hl-string">"*.xml")):
    tree = ET.parse(xml_file)
    root = tree.getroot()

    class=class="hl-string">"hl-comment"># Iterate through Messages
    for message in root.findall(class="hl-string">".//Message"):
        class=class="hl-string">"hl-comment"># Header Extraction
        trn = message.findtext(class="hl-string">"TRN")
        uetr = message.findtext(class="hl-string">"UETR")
        case_id = uetr if uetr else trn
        
        class=class="hl-string">"hl-comment"># Skip if no identifier found
        if not case_id: 
            continue

        msg_type = message.findtext(class="hl-string">"Type")
        amount = message.findtext(class="hl-string">"Amount")
        currency = message.findtext(class="hl-string">"Currency")
        val_date = message.findtext(class="hl-string">"ValueDate")
        ben_bic = message.findtext(class="hl-string">"BeneficiaryBIC")
        
        class=class="hl-string">"hl-comment"># Loop through History/Audit Trail for Activities
        for history in message.findall(class="hl-string">".//History/Item"):
            evt_name = history.findtext(class="hl-string">"Name")
            evt_status = history.findtext(class="hl-string">"Status")
            evt_nature = history.findtext(class="hl-string">"Nature")
            evt_text = history.findtext(class="hl-string">"Text") or class="hl-string">""
            evt_user = history.findtext(class="hl-string">"Operator")
            evt_time = history.findtext(class="hl-string">"Time") class=class="hl-string">"hl-comment"># format: YYYYMMDDHHMMSS
            
            activity = map_activity(evt_name, evt_status, evt_nature, evt_text)
            
            if activity:
                class=class="hl-string">"hl-comment"># Determine NAK Code if applicable
                nak_code = None
                if activity == class="hl-string">"Payment Error Identified" and class="hl-string">"NAK" in evt_text:
                    nak_code = evt_text.split(class="hl-string">"Code:")[-1].strip()
                
                class=class="hl-string">"hl-comment"># Determine STP
                is_stp = class="hl-string">"True" if evt_user == class="hl-string">"System" or evt_user == class="hl-string">"Auto" else class="hl-string">"False"

                data_rows.append({
                    class="hl-string">"PaymentTransactionId": case_id,
                    class="hl-string">"ActivityName": activity,
                    class="hl-string">"EventTimestamp": pd.to_datetime(evt_time, format=class="hl-string">'%Y%m%d%H%M%S'),
                    class="hl-string">"SourceSystem": class="hl-string">"SWIFT Alliance Access",
                    class="hl-string">"LastDataUpdate": pd.Timestamp.now(),
                    class="hl-string">"TransactionAmount": amount,
                    class="hl-string">"TransactionCurrency": currency,
                    class="hl-string">"UniqueEndToEndReference": uetr,
                    class="hl-string">"SwiftMessageType": msg_type,
                    class="hl-string">"ProcessingUser": evt_user,
                    class="hl-string">"BeneficiaryBic": ben_bic,
                    class="hl-string">"SwiftNakCode": nak_code,
                    class="hl-string">"ValueDate": val_date,
                    class="hl-string">"IsStp": is_stp
                })

class=class="hl-string">"hl-comment"># OUTPUT GENERATION
df = pd.DataFrame(data_rows, columns=columns)

class=class="hl-string">"hl-comment"># Remove duplicate timestamp/activity pairs for cleaner log
df.drop_duplicates(subset=[class="hl-string">"PaymentTransactionId", class="hl-string">"ActivityName", class="hl-string">"EventTimestamp"], inplace=True)

df.to_csv(output_file, index=False, quoting=1)
print(fclass="hl-string">"Extraction Complete. Processed {len(df)} events into {output_file}")

Lépések

A környezet előkészítése: Ellenőrizze, hogy az adatkinyerő kiszolgálón telepítve van-e a Python 3.8-as vagy újabb verziója. A szükséges könyvtárakat a pip segítségével telepítse (pandas, numpy). Hozzon létre egy külön munkakönyvtárat, benne egy raw_swift_files nevű almappával, és helyezze oda a napi .out, .txt vagy .fin fájlokat.
A fájlstruktúra áttekintése: A nyers SWIFT FIN-üzenetek blokkokból állnak ({1: Header} {2: Application} {4: Body}). Azonosítsa az elválasztókat. A szabványos fájlok kapcsos zárójeleket használnak. Ellenőrizze, hogy a fájlokat nem csomagolják-e saját formátumú fejlécekbe, például RJE-fejlécekbe. Ha igen, távolítsa el ezeket feldolgozás előtt.
A szkript útvonalainak beállítása: Nyissa meg a megadott Python-szkriptet. Módosítsa az INPUT_DIRECTORY változót úgy, hogy a raw_swift_files mappára mutasson. Állítsa be a létrejövő CSV-fájl elérési útját az OUTPUT_FILE változóban.
Regex-minták megadása: A szkript regex segítségével választja szét a blokkokat. Az 1. blokk tartalmazza a küldő BIC-kódját és a sorszámot. A 2. blokkban található az üzenettípus, például I103 vagy O103, valamint a fogadó BIC-kódja. A 4. blokk tartalmazza az üzleti adatokat, például a :20: TRN-t és a :32A: dátumot és összeget.
Üzenettípusok hozzárendelése a tevékenységekhez: A szkript egy leképezési szótárat tartalmaz. Az MT103 a „Payment Instruction Sent” tevékenységet jelöli. Az MT012 (System ACK) a „SWIFT ACK Received” tevékenységet jelöli. Az MT900/910 a „Payment Settled” tevékenységet jelöli. A meghatározott állapotkódokat (ACSP, RJCT) tartalmazó MT199/299 üzenetek a „Payment Transferred” vagy a „Payment Rejected” tevékenységhez tartoznak.
Attribútumok kinyerése: A feldolgozó megadott címkéken halad végig. A :20: címkét a Payment Transaction ID mezőhöz rendeli. A :121: címkét az UETR mezőhöz rendeli. A :32A: címkét dátumra, pénznemre és összegre bontja.
Belső állapotok kezelése: Az olyan tevékenységek, mint a „Payment Request Created” vagy a „Payment Approved”, gyakran belső ERP-események, ezért nem szerepelnek a SWIFT-fájlokban. Ha nincs külön napló, a szkript ezeket az 1. blokk üzenetlétrehozási időbélyegéből vezeti le. Ha a szervezet a jóváhagyásokat a :72: mezőben (Sender to Receiver Info) rögzíti, a megfelelő szövegkódokat keresi.
Adatok kinyerése: Futtassa a szkriptet a parancssorból: python swift_parser.py. A szkript végigmegy az összes fájlon, feldolgozza az érvényes SWIFT-blokkokat, és kihagyja a hibás sorokat.
Ellenőrzés feldolgozás után: Nyissa meg a létrehozott CSV-fájlt. Ellenőrizze az EventTimestamp formátumát, amelyhez az ISO 8601 ajánlott. Győződjön meg arról, hogy minden sorban szerepel a PaymentTransactionId, így az esetek csoportosíthatók.
Adatok átalakítása: Ha a „ValueDate” YYMMDD formátumban jelenik meg, a szkript YYYY-MM-DD formátumra alakítja. Ellenőrizze, hogy a „TransactionAmount” mezőben egységesek-e a tizedesjelölők, vagyis pontot vagy vesszőt használ-e.
Végső ellenőrzés: Szűrjön egy adott UETR-re, és kövesse végig a folyamatot az utasítás elküldésétől az ACK-n át az elszámolásig. Ellenőrizze, hogy a NAK-ok (MT019) „Payment Error Identified” tevékenységként jelennek-e meg.
Feltöltés a ProcessMindba: Importálja a CSV-fájlt. A PaymentTransactionId mezőt rendelje az esetazonosítóhoz, az ActivityName mezőt a tevékenységhez, az EventTimestamp mezőt pedig az időbélyeghez.

Konfiguráció

Bemeneti könyvtár: A nyers FIN/MT-fájlokat tartalmazó mappa elérési útja. Adjon olvasási jogosultságot.
Dátumformátum feldolgozása: A nyers SWIFT-dátumok YYMMDD formátumúak. A szkript a 20xx évszázadot feltételezi.
Üzenettípus-szűrők: A szkript az 1. kategóriára (fizetések), a 9. kategóriára (kivonatok) és a gyakori rendszerüzenetekre (012, 019) összpontosít. Ha a 2. kategóriára (pénzügyi intézmények közötti átutalásokra) is szükség van, módosítsa a RELEVANT_MT_TYPES listát.
Kódolás: Alapértelmezés szerint „utf-8”. Ha a fájlok régi kódolású karaktereket tartalmaznak, módosítsa „latin-1” vagy „ascii” értékre.
Kötegelt feldolgozás: 1 GB-nál nagyobb adathalmazoknál a szkript generátoros megközelítést használ, és fájlonként dolgozik, így elkerüli a memória túlterhelését.
Regex finomhangolása: A szigorú regex a szabványos FIN-formátumot feltételezi: {1:...}{2:...}{4:...}. Ha a fájlok $ jelet vagy más elválasztót használnak, módosítsa a BLOCK_PATTERN változót.

Példa-lekérdezés python

import os
import re
import glob
import pandas as pd
from datetime import datetime

class=class="hl-string">"hl-comment"># === CONFIGURATION ===
INPUT_DIRECTORY = class="hl-string">"./raw_swift_files/"
OUTPUT_FILE = class="hl-string">"./extracted_swift_event_log.csv"

class=class="hl-string">"hl-comment"># === REGEX PATTERNS ===
class=class="hl-string">"hl-comment"># Matches standard SWIFT block structure: {1:...}{2:...}{3:...}{4:...}
BLOCK_PATTERN = re.compile(rclass="hl-string">'(\{1:.*?\})(\{2:.*?\})(?:\{3:.*?\})?(\{4:.*?\})', re.DOTALL)

class=class="hl-string">"hl-comment"># Field extractors
TAG_20_TRN = re.compile(rclass="hl-string">':20:([^\r\n]+)')
TAG_121_UETR = re.compile(rclass="hl-string">':121:([a-fA-F0-9\-]+)')
TAG_32A_VAL = re.compile(rclass="hl-string">':32A:(\d{6})([A-Z]{3})([\d,]+)')
TAG_72_INFO = re.compile(rclass="hl-string">':72:([^\r\n]+)')
TAG_57A_BIC = re.compile(rclass="hl-string">':57[A-Z]?:(?:[/]{0,2}[A-Z0-9]+)?\r?\n?([A-Z0-9]{8,11})')

class=class="hl-string">"hl-comment"># Header parsers
BLOCK_1_DATE = re.compile(rclass="hl-string">'\{1:[F|A|L]01[A-Z0-9]{12}(\d{4})(\d{6})')
BLOCK_2_TYPE = re.compile(rclass="hl-string">'\{2:([IO])(\d{3})')

class=class="hl-string">"hl-comment"># === ACTIVITY MAPPING LOGIC ===
def map_message_to_activity(io_direction, mt_type, block4_text):
    class=class="hl-string">"hl-comment"># Outgoing Payments (MT103, MT202)
    if io_direction == class="hl-string">'I' and mt_type in [class="hl-string">'103', class="hl-string">'202']:
        return class="hl-string">"Payment Instruction Sent"
    
    class=class="hl-string">"hl-comment"># Incoming Payments (MT103 received from another bank)
    if io_direction == class="hl-string">'O' and mt_type in [class="hl-string">'103', class="hl-string">'202']:
        return class="hl-string">"Payment Transferred"

    class=class="hl-string">"hl-comment"># System Acknowledgment (MT012)
    if mt_type == class="hl-string">'012':
        return class="hl-string">"SWIFT ACK Received"

    class=class="hl-string">"hl-comment"># System NAK / Abort (MT019)
    if mt_type == class="hl-string">'019':
        return class="hl-string">"Payment Error Identified"

    class=class="hl-string">"hl-comment"># Statements / Confirmation (MT900 Debit, MT910 Credit, MT950)
    if mt_type in [class="hl-string">'900', class="hl-string">'910', class="hl-string">'910', class="hl-string">'950']:
        return class="hl-string">"Payment Settled"
    
    class=class="hl-string">"hl-comment"># Returns (MT103 RETN)
    if mt_type == class="hl-string">'103' and class="hl-string">':23E:RETN' in block4_text:
        return class="hl-string">"Payment Rejected"

    class=class="hl-string">"hl-comment"># GPI Status Updates (MT199)
    if mt_type == class="hl-string">'199':
        if class="hl-string">'/RJCT/' in block4_text:
            return class="hl-string">"Payment Rejected"
        if class="hl-string">'/ACSP/' in block4_text:
            return class="hl-string">"Payment Transferred"
        if class="hl-string">'/ACSC/' in block4_text:
            return class="hl-string">"Payment Settled"
            
    return class="hl-string">"Message Processed"  class=class="hl-string">"hl-comment"># Fallback

def parse_swift_date(yymmdd):
    class=class="hl-string">"hl-comment"># Assumes 20xx for years
    try:
        return datetime.strptime(yymmdd, class="hl-string">'%y%m%d').strftime(class="hl-string">'%Y-%m-%d')
    except ValueError:
        return None

class=class="hl-string">"hl-comment"># === MAIN EXTRACTION ===
def process_files():
    records = []
    files = glob.glob(os.path.join(INPUT_DIRECTORY, class="hl-string">"*"))
    
    print(fclass="hl-string">"Found {len(files)} files to process.")

    for filepath in files:
        try:
            with open(filepath, class="hl-string">'r', encoding=class="hl-string">'utf-8', errors=class="hl-string">'ignore') as f:
                content = f.read()
                
            class=class="hl-string">"hl-comment"># Find all full messages in file
            messages = BLOCK_PATTERN.findall(content)
            
            for b1, b2, b4 in messages:
                class=class="hl-string">"hl-comment"># -- Extract Core IDs --
                trn_match = TAG_20_TRN.search(b4)
                uetr_match = TAG_121_UETR.search(b4)
                
                class=class="hl-string">"hl-comment"># Primary Key preference: UETR > TRN > Generated ID
                uetr = uetr_match.group(1) if uetr_match else None
                trn = trn_match.group(1) if trn_match else class="hl-string">"UNKNOWN"
                case_id = uetr if uetr else trn
                
                if case_id == class="hl-string">"UNKNOWN":
                    continue class=class="hl-string">"hl-comment"># Skip structural noise

                class=class="hl-string">"hl-comment"># -- Extract Metadata --
                type_match = BLOCK_2_TYPE.search(b2)
                io_dir = type_match.group(1) if type_match else class="hl-string">"I"
                mt_type = type_match.group(2) if type_match else class="hl-string">"999"
                
                class=class="hl-string">"hl-comment"># -- Determine Timestamp --
                class=class="hl-string">"hl-comment"># Attempt to find timestamp in Block 1 (Session header)
                class=class="hl-string">"hl-comment"># Format often: {1:F01BANKBEBBXXXX1234123456}
                class=class="hl-string">"hl-comment"># Using current time as fallback if header parsing fails
                timestamp = datetime.now().isoformat()
                date_match = BLOCK_1_DATE.search(b1)
                if date_match:
                    class=class="hl-string">"hl-comment"># YYMMDD + HHMM
                    class=class="hl-string">"hl-comment"># Note: Sequence number often occupies this space, this regex is generic
                    class=class="hl-string">"hl-comment"># For simplicity, we assume file creation time or construct from header
                    pass 
                    
                class=class="hl-string">"hl-comment"># -- Extract Financials --
                amount = None
                currency = None
                val_date = None
                amt_match = TAG_32A_VAL.search(b4)
                if amt_match:
                    val_date_raw, currency, amt_str = amt_match.groups()
                    val_date = parse_swift_date(val_date_raw)
                    amount = float(amt_str.replace(class="hl-string">',', class="hl-string">'.'))

                class=class="hl-string">"hl-comment"># -- Extract Beneficiary --
                ben_bic = None
                ben_match = TAG_57A_BIC.search(b4)
                if ben_match:
                    ben_bic = ben_match.group(1)

                class=class="hl-string">"hl-comment"># -- Map Activity --
                activity = map_message_to_activity(io_dir, mt_type, b4)

                class=class="hl-string">"hl-comment"># -- Create Record --
                record = {
                    class="hl-string">"PaymentTransactionId": case_id,
                    class="hl-string">"ActivityName": activity,
                    class="hl-string">"EventTimestamp": datetime.now().strftime(class="hl-string">"%Y-%m-%d %H:%M:%S"), class=class="hl-string">"hl-comment"># Replace with actual extracted time
                    class="hl-string">"SourceSystem": class="hl-string">"SWIFT_Alliance_Access",
                    class="hl-string">"TransactionAmount": amount,
                    class="hl-string">"TransactionCurrency": currency,
                    class="hl-string">"UniqueEndToEndReference": uetr,
                    class="hl-string">"SwiftMessageType": fclass="hl-string">"MT{mt_type}",
                    class="hl-string">"BeneficiaryBic": ben_bic,
                    class="hl-string">"ValueDate": val_date,
                    class="hl-string">"LastDataUpdate": datetime.now().isoformat()
                }
                
                records.append(record)

                class=class="hl-string">"hl-comment"># -- Derived Logic for class="hl-string">'Created' --
                class=class="hl-string">"hl-comment"># If this is the very first outgoing MT103, we can imply creation
                class=class="hl-string">"hl-comment"># In a real scenario, this logic happens after sorting all events
                if activity == class="hl-string">"Payment Instruction Sent":
                    creation_record = record.copy()
                    creation_record[class="hl-string">"ActivityName"] = class="hl-string">"Payment Request Created"
                    class=class="hl-string">"hl-comment"># Offset time slightly backwards to simulate flow
                    creation_record[class="hl-string">"EventTimestamp"] = class="hl-string">"[Derive from Log Creation Time]"
                    records.append(creation_record)

        except Exception as e:
            print(fclass="hl-string">"Error processing file {filepath}: {e}")

    class=class="hl-string">"hl-comment"># -- Convert to DataFrame --
    df = pd.DataFrame(records)
    
    class=class="hl-string">"hl-comment"># -- Final Cleanup --
    class=class="hl-string">"hl-comment"># Sort by ID and Time to ensure logical order if needed
    if not df.empty:
        df.sort_values(by=[class="hl-string">'PaymentTransactionId', class="hl-string">'EventTimestamp'], inplace=True)
        df.to_csv(OUTPUT_FILE, index=False)
        print(fclass="hl-string">"Extraction complete. Data saved to {OUTPUT_FILE}")
    else:
        print(class="hl-string">"No valid SWIFT messages found.")

if __name__ == class="hl-string">"__main__":
    process_files()

Lépések

Ellenőrizze, hogy rendelkezésre áll-e a SWIFT gpi Tracker API-előfizetés, az API-hitelesítő adat, az UETR-keresési lehetőség és a belső fizetési rendszer eseményforrásához való hozzáférés. A SWIFT szolgáltatási dokumentációjából szerezze be a pontos API-alap URL-t, a hitelesítési módot, a válasz sémáját, a lekérdezési korlátokat és a lapozási szabályokat. Ne feltételezzen végpontútvonalat, mert az a licencelt SWIFT-szolgáltatástól és a telepítéstől függ.
Állítsa be a szkriptben a szükséges kapcsolati karakterláncot, hitelesítő adatokat, dátumtartományt és vállalatspecifikus szűrőket. Az első adatkinyeréshez három-hat hónapos időszakot használjon. A belső forrásban csak azokat a fizetési tranzakciókat vegye figyelembe, amelyekhez TRN vagy UETR tartozik, és minden eseménynél őrizze meg a forrásrendszer nevét.
Nyerje ki a belső életciklus-eseményeket a következő tevékenységekhez: Payment Request Created, Payment Details Validated, Sanctions Screening Passed, Payment Approved, Payment Instruction Sent, SWIFT ACK Received, Payment Error Identified, Payment Error Resolved, Payment Rejected, Payment Settled és Payment Reconciled. Minden forráseseményt külön eseménynaplósorrá kell alakítani. Ne várja el a ProcessMindtól, hogy kikövetkeztesse a tevékenységeket.
Nyerje ki az UETR-eket a belső fizetési rekordokból, majd mindegyik UETR-re kérdezze le a licencelt SWIFT gpi Tracker API-t. A környezetéhez kapott API-dokumentáció alapján állítsa be a kérés URL-jét, a hitelesítési fejléceket, a paramétereket, a lapozást és a válaszmezőket. Az ellenőrizhetőség érdekében tárolja a nyers választ.
A megfelelő gpi Tracker-állapotokat alakítsa kifejezett eseménysorokká. A szkript az ACSP állapotot Payment Transferred, az RJCT állapotot Payment Rejected, az ACSC állapotot pedig Payment Settled tevékenységre képezi le. Ha a licencelt válasz más állapotneveket vagy időbélyegeket használ, módosítsa a leképezést a dokumentált válaszséma alapján. Ne hozzon létre olyan eseményt, amelynek megfelelő állapotelőfordulását az API nem adja vissza.
Egységesítse az időbélyegek időzónáját, lehetőleg UTC-re, de ellenőrzési célból szükség esetén őrizze meg az eredeti időbélyeget is. Alakítsa a pénzösszegeket numerikus értékké, őrizze meg a tranzakció pénznemét, egységesítse a logikai STP-értékeket, és hagyja NULL értéken azokat az attribútumokat, amelyeket a forrás nem tartalmaz.
Az eseményeket a PaymentTransactionId, ActivityName, EventTimestamp és a rendelkezésre álló legpontosabb forrásesemény-azonosító alapján szűrje ki. Őrizze meg a valós, többször előforduló eseményeket, például az ismételt javítási és újraküldési ciklusokat, kivéve, ha az üzleti szabály tevékenységenként csak egy előfordulást engedélyez.
Ellenőrizze, hogy minden kimeneti sor tartalmazza-e a PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem és LastDataUpdate mezőt. Győződjön meg arról, hogy az ActivityName csak dokumentált tevékenységértékeket tartalmaz, és hogy mind a 12 tevékenység szerepel, ha a forrásadatokban előfordul.
Exportálja az eredményül kapott adathalmazt UTF-8 kódolású CSV-fájlba vagy a ProcessMind által támogatott más eseménynapló-formátumba. Minden eseményhez egy sort használjon, vegye fel a kötelező és ajánlott oszlopokat, majd a PaymentTransactionId mezőt rendelje az esetazonosítóhoz, az ActivityName mezőt a tevékenységhez, az EventTimestamp mezőt pedig az esemény időbélyegéhez. Töltse fel a fájlt a ProcessMindba, és ne számítson további események automatikus levezetésére.

Konfiguráció

API-végpont és séma: A licencelt SWIFT-dokumentáció alapján állítsa be a környezetéhez tartozó pontos SWIFT gpi Tracker API-alap URL-t, erőforrás-útvonalat, kérési paramétereket, hitelesítési fejléceket, lapozást és válaszmezőneveket. A szkript szándékosan nem talál ki végpontot.
Hitelesítő adatok és jogosultságok: Használja a jóváhagyott SWIFT API-hitelesítési módot, tanúsítvány- vagy tokenkövetelményeket, titokkezelési megoldást és a belső forrásrendszerekhez szükséges jogosultságokat. Ne tároljon éles hitelesítő adatokat közvetlenül a forráskódban.
Dátumtartomány: Kezdje három-hat hónappal. A jelentési céljának megfelelő eseményidőbélyeg vagy fizetéslétrehozási dátum alapján szűrjön. Nagy adatmennyiség esetén kisebb időszakokban dolgozzon, és mentse az UETR-ek feldolgozási állapotát.
Belső forrás szűrői: A rendszer beállításai szerint adja meg a vállalatot, a jogi személyt, a fiókot, a fizetési terméket, a dokumentumtípust, az üzenettípust, a pénznemet és az állapotot. A forrásséma megerősítéséig használjon ilyen helyőrzőket: [Configure based on your system].
Tevékenységek leképezése: Tartson fenn kifejezett leképezéseket a belső állapotokhoz és várólistákhoz. Például a Draft, Validated vagy Ready for Auth állapot a Payment Details Validated tevékenységhez; a szankcióellenőrzési visszatartás feloldása a Sanctions Screening Passed tevékenységhez; a javítási vagy kivételkezelési várólistára kerülés a Payment Error Identified tevékenységhez; a Processing vagy Ready for Payment állapotba való visszatérés pedig a Payment Error Resolved tevékenységhez rendelhető.
gpi-állapotok leképezése: A dokumentált Tracker-állapotokat rendelje kifejezett tevékenységekhez. Ez a megvalósítás az ACSP állapotot Payment Transferred, az RJCT állapotot Payment Rejected, az ACSC állapotot pedig Payment Settled tevékenységre képezi le. Csak akkor bővítse a leképezést, ha a licencelt API dokumentációja megerősíti az állapotok jelentését.
Időbélyegek kezelése: Lehetőség szerint egységesítse az időbélyegeket UTC-re. Határozza meg a forrásesemény ideje, a Tracker-esemény ideje, az üzenet beérkezési ideje és az adatkinyerés ideje közötti elsőbbségi sorrendet. A LastDataUpdate az adatkinyerés vagy -frissítés idejét jelölje, ne az üzleti esemény időpontját.
Lekérdezési korlátok és újrapróbálkozások: Állítsa be a kérés időkorlátját, az újrapróbálkozások számát, az exponenciális várakozást, a HTTP-állapotok kezelését és a lapozást. Tartsa be a SWIFT szolgáltatási korlátait, és kerülje a korlátozás nélküli párhuzamos kéréseket.
Teljesítmény: Gyorsítótárazza az UETR-ekhez tartozó válaszokat, kötegekben dolgozza fel az UETR-eket, mentsen ellenőrzőpontokat, és használjon fokozatos adatkinyerést, ha erre van lehetőség. Ne kérdezze le ismételten ugyanazt az UETR-t ugyanarra az időszakra.
Adatminőség: Követelje meg a PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem és LastDataUpdate mezőket. Az ajánlott attribútumoknál engedélyezze a NULL értékeket, ha a forrás nem tartalmaz adatot, de mérje és jelentse a kitöltöttségüket.
Ellenőrizhetőség: Jóváhagyott ellenőrzési tárhelyen tárolja a nyers API-választ, a kérés időpontját, a válasz állapotát, az UETR-t és az adatkinyerési futás azonosítóját. A fizetési adatokra vonatkozó megőrzési és biztonsági szabályokat alkalmazza.
Előfeltételek: Ellenőrizze, hogy hozzáfér-e a belső fizetési életciklus, a megfelelés, a SWIFT-átjáró, az egyeztetés és az üzenetkapcsolat naplóihoz, továbbá rendelkezik-e SWIFT gpi Tracker API-licenccel és a szükséges tanúsítványokkal vagy hálózati engedélyezéssel.

Példa-lekérdezés python

import csv
import json
import os
import time
import uuid
from datetime import datetime, timezone
from decimal import Decimal, InvalidOperation
from typing import Any, Dict, Iterable, List, Optional

import requests

class=class="hl-string">"hl-comment"># Replace only the following placeholders with environment-specific values.
SWIFT_API_BASE_URL = class="hl-string">"[SWIFT gpi Tracker API base URL]"
SWIFT_API_PATH = class="hl-string">"[SWIFT gpi Tracker API resource path]"
SWIFT_API_TOKEN = class="hl-string">"[SWIFT API token or credential reference]"
START_DATE = class="hl-string">"[YYYY-MM-DD]"
END_DATE = class="hl-string">"[YYYY-MM-DD]"
COMPANY_FILTER = class="hl-string">"[Configure based on your system]"
INTERNAL_EVENTS_FILE = class="hl-string">"[path to internal payment lifecycle events CSV or JSON]"
OUTPUT_FILE = class="hl-string">"swift_gpi_event_log.csv"
RAW_RESPONSE_FILE = class="hl-string">"swift_gpi_raw_responses.jsonl"
REQUEST_TIMEOUT_SECONDS = 60
MAX_RETRIES = 4
PAGE_SIZE = 100

REQUIRED_COLUMNS = [
    class="hl-string">"PaymentTransactionId",
    class="hl-string">"ActivityName",
    class="hl-string">"EventTimestamp",
    class="hl-string">"SourceSystem",
    class="hl-string">"LastDataUpdate",
]

RECOMMENDED_COLUMNS = [
    class="hl-string">"TransactionAmount",
    class="hl-string">"TransactionCurrency",
    class="hl-string">"UniqueEndToEndReference",
    class="hl-string">"SwiftMessageType",
    class="hl-string">"ProcessingUser",
    class="hl-string">"BeneficiaryBic",
    class="hl-string">"SwiftNakCode",
    class="hl-string">"ValueDate",
    class="hl-string">"IsStp",
]

ALL_ACTIVITIES = {
    class="hl-string">"Payment Request Created",
    class="hl-string">"Payment Details Validated",
    class="hl-string">"Sanctions Screening Passed",
    class="hl-string">"Payment Approved",
    class="hl-string">"Payment Instruction Sent",
    class="hl-string">"SWIFT ACK Received",
    class="hl-string">"Payment Transferred",
    class="hl-string">"Payment Error Identified",
    class="hl-string">"Payment Error Resolved",
    class="hl-string">"Payment Rejected",
    class="hl-string">"Payment Settled",
    class="hl-string">"Payment Reconciled",
}


def utc_now() -> str:
    return datetime.now(timezone.utc).isoformat()


def first_value(record: Dict[str, Any], names: Iterable[str], default: Any = None) -> Any:
    for name in names:
        if name in record and record[name] not in (None, class="hl-string">""):
            return record[name]
    return default


def normalize_timestamp(value: Any) -> Optional[str]:
    if value in (None, class="hl-string">""):
        return None
    text = str(value).strip()
    if text.endswith(class="hl-string">"Z"):
        text = text[:-1] + class="hl-string">"+00:00"
    try:
        parsed = datetime.fromisoformat(text)
        if parsed.tzinfo is None:
            parsed = parsed.replace(tzinfo=timezone.utc)
        return parsed.astimezone(timezone.utc).isoformat()
    except ValueError:
        return str(value)


def normalize_amount(value: Any) -> Optional[str]:
    if value in (None, class="hl-string">""):
        return None
    try:
        return str(Decimal(str(value)))
    except (InvalidOperation, ValueError):
        return str(value)


def normalize_bool(value: Any) -> Optional[bool]:
    if value in (None, class="hl-string">""):
        return None
    if isinstance(value, bool):
        return value
    return str(value).strip().lower() in {class="hl-string">"true", class="hl-string">"1", class="hl-string">"yes", class="hl-string">"y"}


def load_records(path: str) -> List[Dict[str, Any]]:
    if path.lower().endswith(class="hl-string">".json"):
        with open(path, class="hl-string">"r", encoding=class="hl-string">"utf-8") as handle:
            data = json.load(handle)
        if isinstance(data, list):
            return data
        if isinstance(data, dict):
            for key in (class="hl-string">"records", class="hl-string">"events", class="hl-string">"payments", class="hl-string">"data"):
                if isinstance(data.get(key), list):
                    return data[key]
        raise ValueError(class="hl-string">"The JSON input must contain a list of records.")
    with open(path, class="hl-string">"r", encoding=class="hl-string">"utf-8-sig", newline=class="hl-string">"") as handle:
        return list(csv.DictReader(handle))


def base_event(payment: Dict[str, Any], activity: str, timestamp: Any, source_system: str, run_time: str) -> Optional[Dict[str, Any]]:
    payment_id = first_value(payment, [class="hl-string">"PaymentTransactionId", class="hl-string">"payment_transaction_id", class="hl-string">"transaction_id", class="hl-string">"TRN", class="hl-string">"trn", class="hl-string">"UETR", class="hl-string">"uetr"])
    event_time = normalize_timestamp(timestamp)
    if not payment_id or not event_time:
        return None
    return {
        class="hl-string">"PaymentTransactionId": str(payment_id),
        class="hl-string">"ActivityName": activity,
        class="hl-string">"EventTimestamp": event_time,
        class="hl-string">"SourceSystem": source_system,
        class="hl-string">"LastDataUpdate": run_time,
        class="hl-string">"TransactionAmount": normalize_amount(first_value(payment, [class="hl-string">"TransactionAmount", class="hl-string">"transaction_amount", class="hl-string">"amount"])),
        class="hl-string">"TransactionCurrency": first_value(payment, [class="hl-string">"TransactionCurrency", class="hl-string">"transaction_currency", class="hl-string">"currency"]),
        class="hl-string">"UniqueEndToEndReference": first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr", class="hl-string">"uetr_value"]),
        class="hl-string">"SwiftMessageType": first_value(payment, [class="hl-string">"SwiftMessageType", class="hl-string">"swift_message_type", class="hl-string">"message_type"]),
        class="hl-string">"ProcessingUser": first_value(payment, [class="hl-string">"ProcessingUser", class="hl-string">"processing_user", class="hl-string">"user", class="hl-string">"performed_by"]),
        class="hl-string">"BeneficiaryBic": first_value(payment, [class="hl-string">"BeneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"]),
        class="hl-string">"SwiftNakCode": first_value(payment, [class="hl-string">"SwiftNakCode", class="hl-string">"swift_nak_code", class="hl-string">"nak_code"]),
        class="hl-string">"ValueDate": first_value(payment, [class="hl-string">"ValueDate", class="hl-string">"value_date"]),
        class="hl-string">"IsStp": normalize_bool(first_value(payment, [class="hl-string">"IsStp", class="hl-string">"is_stp", class="hl-string">"stp"])),
    }


def add_internal_event(events: List[Dict[str, Any]], payment: Dict[str, Any], activity: str, timestamp_names: List[str], source_system: str, run_time: str) -> None:
    timestamp = first_value(payment, timestamp_names)
    event = base_event(payment, activity, timestamp, source_system, run_time)
    if event:
        events.append(event)


def extract_internal_events(payments: List[Dict[str, Any]], run_time: str) -> List[Dict[str, Any]]:
    events: List[Dict[str, Any]] = []
    for payment in payments:
        source_system = str(first_value(payment, [class="hl-string">"SourceSystem", class="hl-string">"source_system"], class="hl-string">"Internal Payment System"))
        add_internal_event(events, payment, class="hl-string">"Payment Request Created", [class="hl-string">"PaymentRequestCreatedTimestamp", class="hl-string">"payment_request_created_timestamp", class="hl-string">"created_at", class="hl-string">"creation_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Details Validated", [class="hl-string">"PaymentDetailsValidatedTimestamp", class="hl-string">"payment_details_validated_timestamp", class="hl-string">"validated_at", class="hl-string">"validation_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Sanctions Screening Passed", [class="hl-string">"SanctionsScreeningPassedTimestamp", class="hl-string">"sanctions_screening_passed_timestamp", class="hl-string">"screening_passed_at", class="hl-string">"screening_release_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Approved", [class="hl-string">"PaymentApprovedTimestamp", class="hl-string">"payment_approved_timestamp", class="hl-string">"approved_at", class="hl-string">"approval_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Instruction Sent", [class="hl-string">"PaymentInstructionSentTimestamp", class="hl-string">"payment_instruction_sent_timestamp", class="hl-string">"instruction_sent_at", class="hl-string">"swift_sent_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"SWIFT ACK Received", [class="hl-string">"SwiftAckReceivedTimestamp", class="hl-string">"swift_ack_received_timestamp", class="hl-string">"ack_received_at", class="hl-string">"swift_ack_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Error Identified", [class="hl-string">"PaymentErrorIdentifiedTimestamp", class="hl-string">"payment_error_identified_timestamp", class="hl-string">"error_identified_at", class="hl-string">"repair_queue_timestamp", class="hl-string">"exception_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Error Resolved", [class="hl-string">"PaymentErrorResolvedTimestamp", class="hl-string">"payment_error_resolved_timestamp", class="hl-string">"error_resolved_at", class="hl-string">"repair_resolved_timestamp", class="hl-string">"resubmission_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Rejected", [class="hl-string">"PaymentRejectedTimestamp", class="hl-string">"payment_rejected_timestamp", class="hl-string">"rejected_at", class="hl-string">"return_received_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Settled", [class="hl-string">"PaymentSettledTimestamp", class="hl-string">"payment_settled_timestamp", class="hl-string">"settled_at", class="hl-string">"beneficiary_credit_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Reconciled", [class="hl-string">"PaymentReconciledTimestamp", class="hl-string">"payment_reconciled_timestamp", class="hl-string">"reconciled_at", class="hl-string">"reconciliation_timestamp"], source_system, run_time)
    return events


def request_json(session: requests.Session, url: str, headers: Dict[str, str], params: Dict[str, Any]) -> Dict[str, Any]:
    last_error: Optional[Exception] = None
    for attempt in range(MAX_RETRIES):
        try:
            response = session.get(url, headers=headers, params=params, timeout=REQUEST_TIMEOUT_SECONDS)
            if response.status_code == 429 or response.status_code >= 500:
                response.raise_for_status()
            response.raise_for_status()
            return response.json()
        except (requests.RequestException, ValueError) as error:
            last_error = error
            if attempt == MAX_RETRIES - 1:
                break
            time.sleep(2 ** attempt)
    raise RuntimeError(fclass="hl-string">"SWIFT API request failed: {last_error}")


def get_items(payload: Dict[str, Any]) -> List[Dict[str, Any]]:
    for key in (class="hl-string">"events", class="hl-string">"statuses", class="hl-string">"statusEvents", class="hl-string">"data", class="hl-string">"items", class="hl-string">"results"):
        value = payload.get(key)
        if isinstance(value, list):
            return [item for item in value if isinstance(item, dict)]
    if isinstance(payload, list):
        return [item for item in payload if isinstance(item, dict)]
    return []


def fetch_gpi_events(uetr: str, session: requests.Session, raw_handle: Any, run_time: str) -> List[Dict[str, Any]]:
    url = SWIFT_API_BASE_URL.rstrip(class="hl-string">"/") + class="hl-string">"/" + SWIFT_API_PATH.lstrip(class="hl-string">"/")
    headers = {class="hl-string">"Accept": class="hl-string">"application/json", class="hl-string">"Authorization": fclass="hl-string">"Bearer {SWIFT_API_TOKEN}"}
    page = 1
    output: List[Dict[str, Any]] = []
    while True:
        params = {class="hl-string">"uetr": uetr, class="hl-string">"startDate": START_DATE, class="hl-string">"endDate": END_DATE, class="hl-string">"page": page, class="hl-string">"pageSize": PAGE_SIZE}
        payload = request_json(session, url, headers, params)
        raw_handle.write(json.dumps({class="hl-string">"run_time": run_time, class="hl-string">"uetr": uetr, class="hl-string">"request_params": params, class="hl-string">"response": payload}, default=str) + class="hl-string">"\n")
        items = get_items(payload)
        output.extend(items)
        has_next = first_value(payload, [class="hl-string">"hasNext", class="hl-string">"has_next", class="hl-string">"nextPage", class="hl-string">"next_page"])
        if not items or has_next in (False, None, class="hl-string">"false", class="hl-string">"False"):
            break
        if isinstance(has_next, (int, str)) and str(has_next).isdigit():
            page = int(has_next)
        else:
            page += 1
    return output


def tracker_event(payment: Dict[str, Any], tracker: Dict[str, Any], activity: str, run_time: str) -> Optional[Dict[str, Any]]:
    merged = dict(payment)
    merged.update({
        class="hl-string">"UniqueEndToEndReference": first_value(tracker, [class="hl-string">"uetr", class="hl-string">"UETR"], first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr"])),
        class="hl-string">"SwiftMessageType": first_value(tracker, [class="hl-string">"messageType", class="hl-string">"message_type", class="hl-string">"swiftMessageType"], first_value(payment, [class="hl-string">"SwiftMessageType", class="hl-string">"swift_message_type", class="hl-string">"message_type"])),
        class="hl-string">"BeneficiaryBic": first_value(tracker, [class="hl-string">"beneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"], first_value(payment, [class="hl-string">"BeneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"])),
        class="hl-string">"TransactionAmount": first_value(tracker, [class="hl-string">"amount", class="hl-string">"transactionAmount", class="hl-string">"transaction_amount"], first_value(payment, [class="hl-string">"TransactionAmount", class="hl-string">"transaction_amount", class="hl-string">"amount"])),
        class="hl-string">"TransactionCurrency": first_value(tracker, [class="hl-string">"currency", class="hl-string">"transactionCurrency", class="hl-string">"transaction_currency"], first_value(payment, [class="hl-string">"TransactionCurrency", class="hl-string">"transaction_currency", class="hl-string">"currency"])),
        class="hl-string">"ValueDate": first_value(tracker, [class="hl-string">"valueDate", class="hl-string">"value_date"], first_value(payment, [class="hl-string">"ValueDate", class="hl-string">"value_date"])),
        class="hl-string">"IsStp": first_value(tracker, [class="hl-string">"isStp", class="hl-string">"is_stp", class="hl-string">"stp"], first_value(payment, [class="hl-string">"IsStp", class="hl-string">"is_stp", class="hl-string">"stp"])),
        class="hl-string">"SwiftNakCode": first_value(tracker, [class="hl-string">"nakCode", class="hl-string">"nak_code", class="hl-string">"swiftNakCode"], first_value(payment, [class="hl-string">"SwiftNakCode", class="hl-string">"swift_nak_code", class="hl-string">"nak_code"])),
    })
    timestamp = first_value(tracker, [class="hl-string">"eventTimestamp", class="hl-string">"event_timestamp", class="hl-string">"timestamp", class="hl-string">"statusTimestamp", class="hl-string">"status_timestamp", class="hl-string">"occurredAt", class="hl-string">"occurred_at"])
    return base_event(merged, activity, timestamp, class="hl-string">"SWIFT gpi Tracker API", run_time)


def extract_tracker_events(payments: List[Dict[str, Any]], run_time: str, raw_handle: Any) -> List[Dict[str, Any]]:
    events: List[Dict[str, Any]] = []
    seen_uetrs = set()
    with requests.Session() as session:
        for payment in payments:
            uetr = first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr", class="hl-string">"uetr_value"])
            if not uetr or str(uetr) in seen_uetrs:
                continue
            seen_uetrs.add(str(uetr))
            for tracker in fetch_gpi_events(str(uetr), session, raw_handle, run_time):
                status = str(first_value(tracker, [class="hl-string">"status", class="hl-string">"statusCode", class="hl-string">"status_code", class="hl-string">"gpiStatus", class="hl-string">"gpi_status"], class="hl-string">"")).upper()
                activity = {class="hl-string">"ACSP": class="hl-string">"Payment Transferred", class="hl-string">"RJCT": class="hl-string">"Payment Rejected", class="hl-string">"ACSC": class="hl-string">"Payment Settled"}.get(status)
                if activity:
                    event = tracker_event(payment, tracker, activity, run_time)
                    if event:
                        events.append(event)
    return events


def deduplicate(events: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
    result: List[Dict[str, Any]] = []
    seen = set()
    for event in sorted(events, key=lambda row: (row[class="hl-string">"PaymentTransactionId"], row[class="hl-string">"EventTimestamp"], row[class="hl-string">"ActivityName"])):
        key = (event[class="hl-string">"PaymentTransactionId"], event[class="hl-string">"ActivityName"], event[class="hl-string">"EventTimestamp"], event.get(class="hl-string">"UniqueEndToEndReference"))
        if key not in seen:
            seen.add(key)
            result.append(event)
    return result


def write_csv(events: List[Dict[str, Any]], path: str) -> None:
    columns = REQUIRED_COLUMNS + RECOMMENDED_COLUMNS
    with open(path, class="hl-string">"w", encoding=class="hl-string">"utf-8", newline=class="hl-string">"") as handle:
        writer = csv.DictWriter(handle, fieldnames=columns, extrasaction=class="hl-string">"ignore")
        writer.writeheader()
        for event in events:
            writer.writerow({column: event.get(column) for column in columns})


def main() -> None:
    run_time = utc_now()
    payments = load_records(INTERNAL_EVENTS_FILE)
    if COMPANY_FILTER != class="hl-string">"[Configure based on your system]":
        payments = [payment for payment in payments if str(first_value(payment, [class="hl-string">"CompanyCode", class="hl-string">"company_code", class="hl-string">"Company", class="hl-string">"company"], class="hl-string">"")) == COMPANY_FILTER]
    internal_events = extract_internal_events(payments, run_time)
    with open(RAW_RESPONSE_FILE, class="hl-string">"w", encoding=class="hl-string">"utf-8") as raw_handle:
        tracker_events = extract_tracker_events(payments, run_time, raw_handle)
    events = deduplicate(internal_events + tracker_events)
    invalid = [event for event in events if any(event.get(column) in (None, class="hl-string">"") for column in REQUIRED_COLUMNS) or event[class="hl-string">"ActivityName"] not in ALL_ACTIVITIES]
    if invalid:
        raise ValueError(fclass="hl-string">"The extraction produced {len(invalid)} invalid event rows.")
    write_csv(events, OUTPUT_FILE)
    print(json.dumps({class="hl-string">"run_id": str(uuid.uuid4()), class="hl-string">"rows_written": len(events), class="hl-string">"output_file": OUTPUT_FILE, class="hl-string">"activities": sorted({event[class="hl-string">"ActivityName"] for event in events})}, indent=2))


if __name__ == class="hl-string">"__main__":
    main()

Készen áll a kezdésre?

Használja ezeket a sablonokat, hogy a nyers SWIFT-naplókból a működés fejlesztését és a fizetések gyorsabb elszámolását támogató eszközt készítsen.

Vissza a folyamatfejlesztési útmutatóhoz

Sablon letöltése

Fejlessze most a SWIFT-fizetések feldolgozását

Érjen el 98%-os automatikus, manuális beavatkozás nélküli feldolgozást, és szüntesse meg a manuális hibákat

Kezdje el az ingyenes próbaverziót

Nincs szükség bankkártyára. Beállítás 5 perc alatt

Fizetésfeldolgozási adatsablon

Fizetésfeldolgozási adatsablon

A fizetésfeldolgozás attribútumai

A fizetésfeldolgozás tevékenységei

Útmutatók az adatok kinyeréséhez

SWIFT Alliance Access archívumexport

Lépések

Konfiguráció

Példa-lekérdezés python

Python-feldolgozó nyers SWIFT MT-fájlokhoz

Lépések

Konfiguráció

Példa-lekérdezés python

SWIFT gpi API-összekötő

Lépések

Konfiguráció

Példa-lekérdezés python

Készen áll a kezdésre?

Fejlessze most a SWIFT-fizetések feldolgozását