> การปรับปรุงกระบวนการอย่างต่อเนื่อง > การประมวลผลการชำระเงิน > SWIFT > เทมเพลตข้อมูล

เทมเพลตข้อมูลการประมวลผลการชำระเงินของคุณ

SWIFT

แอตทริบิวต์การประมวลผลการชำระเงิน(19) กิจกรรมการประมวลผลการชำระเงิน(12) คู่มือการดึงข้อมูล(3)

เทมเพลตข้อมูลการประมวลผลการชำระเงินของคุณ

เทมเพลตนี้เป็นโครงสร้างพื้นฐานสำหรับทำแผนที่เวิร์กโฟลว์ธุรกรรม SWIFT ตั้งแต่เริ่มต้นจนถึงการชำระเงินเสร็จสมบูรณ์ โดยระบุองค์ประกอบข้อมูลและจุดสำคัญในการปฏิบัติงานที่จำเป็น เพื่อให้เห็นวงจรการชำระเงินได้ครบถ้วน ใช้แนวทางนี้เตรียมข้อมูลเพื่อค้นหาความไม่มีประสิทธิภาพที่ซ่อนอยู่และลดความเสี่ยงด้านการปฏิบัติตามข้อกำหนด.

แอตทริบิวต์ที่แนะนำสำหรับการวิเคราะห์ธุรกรรมเชิงลึก
กิจกรรมและจุดสำคัญในกระบวนการ SWIFT
คำแนะนำทางเทคนิคสำหรับการดึงข้อมูลทางการเงิน

เพิ่งเริ่มใช้บันทึกเหตุการณ์ใช่ไหม เรียนรู้ วิธีสร้าง event log สำหรับ process mining.

ดาวน์โหลดเทมเพลต

แอตทริบิวต์การประมวลผลการชำระเงิน

ข้อมูลเหล่านี้เป็นฟิลด์ที่แนะนำให้ใส่ในบันทึกเหตุการณ์ เพื่อวิเคราะห์วงจรธุรกรรม SWIFT ได้อย่างครบถ้วน.

5 จำเป็น 9 แนะนำ 5 ไม่บังคับ

	ชื่อ	คำอธิบาย
	ชื่อกิจกรรม ActivityName	ชื่อขั้นตอนหรือเหตุการณ์ที่เกิดขึ้นในกระบวนการ.
คำอธิบาย แอตทริบิวต์นี้อธิบายการดำเนินการหรือการเปลี่ยนสถานะที่บันทึกไว้ในบันทึกของระบบ ตัวอย่างเช่น 'สร้างคำขอชำระเงิน', 'ผ่านการตรวจสอบรายชื่อคว่ำบาตร' หรือ 'ได้รับ ACK จาก SWIFT' เป็นมิติหลักของแผนที่กระบวนการ ใช้กำหนดโหนดในภาพแสดงผลและช่วยให้นักวิเคราะห์เข้าใจลำดับการดำเนินงานเกี่ยวกับการชำระเงิน. เหตุผลที่สำคัญ แอตทริบิวต์นี้ระบุว่าเกิดอะไรขึ้น จึงแสดงขั้นตอนและรูปแบบที่แตกต่างกันของกระบวนการได้. แหล่งข้อมูล บันทึกธุรกรรม หลักฐานการตรวจสอบ หรือข้อมูลที่ได้จากประเภทข้อความ เช่น ส่ง MT103 แล้ว. ตัวอย่าง สร้างคำขอชำระเงินส่งคำสั่งชำระเงินแล้วได้รับ ACK จาก SWIFTอนุมัติการชำระเงินแล้ว
	รหัสธุรกรรมการชำระเงิน PaymentTransactionId	รหัสเฉพาะที่ใช้ระบุกรณีการชำระเงินตั้งแต่ต้นจนจบ.
คำอธิบาย แอตทริบิวต์นี้ทำหน้าที่เป็นรหัสหลักของกรณีสำหรับ process mining โดยรวบรวมกิจกรรมทั้งหมดที่เกี่ยวข้องกับคำสั่งชำระเงินรายการเดียว ตั้งแต่คำขอเริ่มต้น การตรวจสอบความถูกต้อง การส่งผ่าน SWIFT ไปจนถึงการชำระราคาในขั้นสุดท้าย ในบริบทของ SWIFT มักใช้ Transaction Reference Number (TRN) หรือ Unique End-to-end Transaction Reference (UETR) เพื่อให้ติดตามรายการต่อเนื่องได้ในทุกระบบธนาคาร ใช้สร้างเส้นทางของแต่ละกรณีในกระบวนการขึ้นใหม่ และจำเป็นต่อการวิเคราะห์รูปแบบกระบวนการกับการคำนวณเวลาของวงจรงาน. เหตุผลที่สำคัญ การระบุรายการให้ไม่ซ้ำกันเป็นพื้นฐานของ process mining เพราะช่วยเชื่อมเหตุการณ์ที่กระจัดกระจายให้เป็นภาพกระบวนการเดียวกัน. แหล่งข้อมูล ฟิลด์ 20 (TRN) หรือฟิลด์ 121 (UETR) ในส่วนหัวข้อความ SWIFT. ตัวอย่าง TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	ระบบต้นทาง SourceSystem	ชื่อระบบที่เป็นแหล่งที่มาของข้อมูลเหตุการณ์.
คำอธิบาย ระบุซอฟต์แวร์หรือแพลตฟอร์มที่สร้างบันทึกเหตุการณ์ ในกระบวนการชำระเงิน อาจเป็นระบบธนาคารหลัก payment gateway หรือส่วนเชื่อมต่อ SWIFT โดยตรง แอตทริบิวต์นี้ช่วยตรวจสอบที่มาของข้อมูลและแก้ไขปัญหาเมื่อรวมข้อมูลจากแอปพลิเคชันธนาคารหลายระบบที่แยกจากกัน. เหตุผลที่สำคัญ แสดงที่มาของข้อมูล ซึ่งจำเป็นต่อการทำ process mining จากหลายระบบ. แหล่งข้อมูล กำหนดค่าไว้ใน ETL หรือดึงมาจากรหัสระบบ. ตัวอย่าง SWIFT Alliance AccessCore Banking SystemPayment Engineตัวกรองรายชื่อคว่ำบาตร
	เวลาประทับของเหตุการณ์ EventTimestamp	วันที่และเวลาที่กิจกรรมเกิดขึ้นอย่างแม่นยำ.
คำอธิบาย แอตทริบิวต์นี้บันทึกเวลาที่เกิดเหตุการณ์อย่างแม่นยำ ใช้เรียงลำดับกิจกรรมตามเวลาและคำนวณตัวชี้วัดตามระยะเวลาทั้งหมด เช่น เวลานำ เวลาของวงจรงาน และอัตราการประมวลผล เวลาประทับที่ถูกต้องมีความสำคัญต่อการวิเคราะห์ 'ผลการดำเนินงานเทียบกับเวลาปิดรับของเครือข่าย' และระบุคอขวดในลำดับการอนุมัติ. เหตุผลที่สำคัญ เวลาประทับเป็นพื้นฐานของการวิเคราะห์ด้านเวลาและตัวชี้วัดผลการดำเนินงานทั้งหมดใน process mining. แหล่งข้อมูล บันทึกการตรวจสอบของระบบ เวลาสร้างข้อความ หรือเวลาทำธุรกรรมในฐานข้อมูล. ตัวอย่าง 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	อัปเดตข้อมูลล่าสุด LastDataUpdate	เวลาที่ดึงหรือรีเฟรชระเบียนครั้งล่าสุด.
คำอธิบาย ระบุเวลาที่โหลดข้อมูลเข้าสู่เครื่องมือ process mining ครั้งล่าสุด ข้อมูลนี้สำคัญต่อการตรวจสอบความใหม่ของข้อมูล และช่วยให้มั่นใจว่าแดชบอร์ดแสดงสถานะล่าสุดของการปฏิบัติงานด้านการชำระเงิน ช่วยให้ผู้ใช้เชื่อถือข้อมูลได้ โดยแสดงให้เห็นว่าการรายงานข้อมูลล่าช้าเพียงใด. เหตุผลที่สำคัญ ช่วยให้ผู้ใช้เข้าใจว่าข้อมูลที่แสดงเป็นข้อมูลปัจจุบันและเชื่อถือได้เพียงใด. แหล่งข้อมูล เวลาที่ดำเนินการ ETL. ตัวอย่าง 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	BIC ของธนาคารผู้รับผลประโยชน์ BeneficiaryBic	รหัส Bank Identifier Code ของสถาบันผู้รับเงิน.
คำอธิบาย ระบุธนาคารปลายทางของการชำระเงิน ซึ่งเป็นมิติสำคัญสำหรับแดชบอร์ด 'สาเหตุหลักที่ผู้รับผลประโยชน์ปฏิเสธรายการ' เมื่อจัดกลุ่มรายการที่ล้มเหลวตาม BIC ของผู้รับผลประโยชน์ ธนาคารจะระบุคู่สัญญาที่ปฏิเสธคำสั่งบ่อยครั้ง เนื่องจากข้อมูลไม่ถูกต้องหรือมีข้อกำหนดด้านรูปแบบเฉพาะ. เหตุผลที่สำคัญ จำเป็นต่อการวิเคราะห์ผลการดำเนินงานของคู่สัญญาและรูปแบบการปฏิเสธรายการ. แหล่งข้อมูล SWIFT Field 57A (บัญชีที่สถาบันการเงินดูแล) หรือ 58A (สถาบันผู้รับผลประโยชน์). ตัวอย่าง CITIUS33BARCGB22DRESDEFFHANDSEXX
	UETR UniqueEndToEndReference	รหัสอ้างอิงธุรกรรมแบบไม่ซ้ำตลอดกระบวนการ สำหรับติดตามรายการผ่าน SWIFT gpi.
คำอธิบาย UETR เป็นชุดอักขระ 36 ตัวที่ใช้เป็นรหัสอ้างอิงเดียวและไม่เปลี่ยนแปลงสำหรับการชำระเงินตลอดเครือข่าย SWIFT ต่างจาก ID ภายในองค์กร เพราะ UETR ใช้ติดตามรายการต่อเนื่องได้แม้ผ่านหลายธนาคาร แอตทริบิวต์นี้สำคัญต่อการติดตามรายการตั้งแต่ต้นจนจบ และการเชื่อมโยงบันทึกภายในกับสถานะรายการที่อัปเดตจาก SWIFT gpi. เหตุผลที่สำคัญ มาตรฐานหลักสำหรับติดตามการชำระเงินข้ามพรมแดนระหว่างสถาบันต่างๆ. แหล่งข้อมูล SWIFT Block 3, Field 121. ตัวอย่าง b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	จำนวนเงินของธุรกรรม TransactionAmount	มูลค่าเงินของคำสั่งชำระเงิน.
คำอธิบาย แสดงจำนวนเงินต้นที่โอน ข้อมูลนี้ดึงจากฟิลด์เฉพาะของ SWIFT เช่น ฟิลด์ 32A ใน MT103 จำเป็นต่อแดชบอร์ด 'รอบการอนุมัติการโอนเงินมูลค่าสูง' เพราะช่วยแบ่งกลุ่มการชำระเงินตามจำนวนเงิน เพื่อวิเคราะห์ความล่าช้าในการอนุมัติธุรกรรมมูลค่าสูงที่มีความเสี่ยงสูง. เหตุผลที่สำคัญ ช่วยวิเคราะห์ผลกระทบทางการเงินและแบ่งกลุ่มตามขนาดธุรกรรม. แหล่งข้อมูล ฟิลด์ SWIFT MT 32A (จำนวนเงิน) หรือองค์ประกอบ IntrBkSttlmAmt ของ ISO 20022. ตัวอย่าง 15000.001250.501000000.0045.00
	ประเภทข้อความ SWIFT SwiftMessageType	ประเภทข้อความ SWIFT ที่ใช้ เช่น MT103 หรือ pacs.008.
คำอธิบาย ระบุรูปแบบเฉพาะของคำสั่งชำระเงิน ประเภทที่ใช้กันทั่วไป ได้แก่ MT103 สำหรับการโอนเงินของลูกค้า และรูปแบบเทียบเท่าใน ISO 20022 เช่น pacs.008 ใช้ในการวิเคราะห์ 'รูปแบบเส้นทางการชำระเงิน' เพื่อเปรียบเทียบประสิทธิภาพการประมวลผลระหว่างรูปแบบ MT เดิมกับมาตรฐาน ISO ใหม่. เหตุผลที่สำคัญ ใช้แยกประเภทกระแสการชำระเงินและมาตรฐานการประมวลผลระหว่างรูปแบบเดิมกับ ISO 20022. แหล่งข้อมูล ฟิลด์ประเภทข้อความใน SWIFT Block 2 (ส่วนหัวของแอปพลิเคชัน). ตัวอย่าง MT103MT202pacs.008MT101
	เป็น STP IsStp	ตัวบ่งชี้ว่าการชำระเงินไม่ต้องมีผู้ดำเนินการด้วยตนเองหรือไม่.
คำอธิบาย ตัวบ่งชี้แบบบูลีนที่มีค่า True เมื่อเคสไม่มีขั้นตอน 'พบข้อผิดพลาด' 'ปฏิเสธการชำระเงิน' หรือ 'แก้ไข' ด้วยตนเอง ใช้คำนวณ KPI 'อัตราการประมวลผลแบบตรงผ่าน (STP)' โดยตรง เป็นตัวชี้วัดหลักของความสำเร็จในการทำงานอัตโนมัติสำหรับการประมวลผลการชำระเงิน. เหตุผลที่สำคัญ ตัวชี้วัดหลักของประสิทธิภาพกระบวนการและสถานะการทำงานอัตโนมัติ. แหล่งข้อมูล คำนวณจากการไม่มีขั้นตอนเชิงลบหรือขั้นตอนที่ต้องทำด้วยตนเองบางรายการในเคส. ตัวอย่าง truefalse
	ผู้ใช้ที่ประมวลผลรายการ ProcessingUser	ผู้ใช้หรือตัวแทนระบบที่ดำเนินกิจกรรม.
คำอธิบาย ระบุบุคคลหรือบอตอัตโนมัติที่รับผิดชอบกิจกรรม เช่น เจ้าหน้าที่การปฏิบัติตามข้อกำหนดที่อนุมัติรายการที่ตรงกับรายชื่อคว่ำบาตร หรือผู้ปฏิบัติงานที่แก้ไขข้อผิดพลาดด้านรูปแบบ แอตทริบิวต์นี้ใช้สร้าง 'แผนที่ความหนาแน่นของข้อผิดพลาดในการตรวจสอบ' เพื่อให้ผู้จัดการเห็นความต้องการด้านการฝึกอบรม หรือระบุผู้ใช้ที่เกี่ยวข้องกับการแก้ไขงานซ้ำในอัตราสูง. เหตุผลที่สำคัญ ช่วยวิเคราะห์ทรัพยากรและระบุคอขวดที่เกิดจากงานที่ต้องทำด้วยตนเอง. แหล่งข้อมูล บันทึกการตรวจสอบของระบบ หรือคอลัมน์ 'User ID' ในตารางธุรกรรม. ตัวอย่าง SYSTEMJ.DoeCompliance_Bot_01M.Smith
	รหัส NAK ของ SWIFT SwiftNakCode	รหัสข้อผิดพลาดที่เครือข่าย SWIFT ส่งกลับเมื่อปฏิเสธข้อความ.
คำอธิบาย ระบุรหัสข้อผิดพลาด เช่น T26 หรือ T13 ที่เครือข่าย SWIFT ส่งกลับมาในข้อความปฏิเสธ (NAK) แอตทริบิวต์นี้ใช้สร้างแดชบอร์ด 'วิเคราะห์ข้อผิดพลาดและการแก้ไขงานซ้ำของ SWIFT' เพื่อจัดหมวดหมู่ปัญหาทางเทคนิคและจัดลำดับความสำคัญในการแก้ไขระบบ. เหตุผลที่สำคัญ ช่วยระบุสาเหตุทางเทคนิคของการปฏิเสธรายการในระดับเครือข่าย. แหล่งข้อมูล ข้อความระบบ MT 015/019 หรือ Field 451 ใน ACK/NAK. ตัวอย่าง T26H01T13G02
	วันที่มีผลของเงิน ValueDate	วันที่กำหนดให้ผู้รับผลประโยชน์สามารถใช้เงินได้.
คำอธิบาย ระบุวันที่ชำระดุลตามคำสั่งในข้อความการชำระเงิน เมื่อนำวันที่นี้ไปเปรียบเทียบกับเวลาประทับ 'ชำระเงินแล้ว' จะช่วยในการวิเคราะห์แดชบอร์ด 'อายุรายการชำระดุลและการกระทบยอด' ข้อมูลนี้บอกระดับความเร่งด่วนของการชำระเงิน และใช้วัดการปฏิบัติตามข้อตกลงระดับการให้บริการเกี่ยวกับการพร้อมใช้ของเงิน. เหตุผลที่สำคัญ สำคัญต่อการบริหารสภาพคล่องและวัดความตรงเวลาของการชำระดุล. แหล่งข้อมูล ฟิลด์วันที่ใน SWIFT MT Field 32A หรือ ISO 20022 IntrBkSttlmDt. ตัวอย่าง 2023-10-262023-11-01
	สกุลเงินของธุรกรรม TransactionCurrency	รหัส ISO 3 ตัวอักษรที่ระบุสกุลเงินของการชำระเงิน.
คำอธิบาย ระบุสกุลเงินที่ใช้ในการชำระเงิน เช่น USD, EUR หรือ GBP ข้อมูลนี้สำคัญต่อแดชบอร์ด 'ประสิทธิภาพตามเวลาปิดรับรายการของเครือข่าย' เพราะเวลาปิดรับรายการแตกต่างกันตามสกุลเงิน นอกจากนี้ยังช่วยวิเคราะห์ 'ประสิทธิภาพการแปลงสกุลเงิน' โดยระบุคู่สกุลเงินที่แตกต่างกัน. เหตุผลที่สำคัญ ใช้กำหนดกฎการส่งต่อรายการ เวลาปิดรับรายการ และเส้นทางการชำระดุล. แหล่งข้อมูล ฟิลด์ 32A (สกุลเงิน) ใน SWIFT MT หรือองค์ประกอบ Ccy ใน ISO 20022. ตัวอย่าง USDEURGBPJPY
	ประเทศต้นทาง OriginatingCountry	รหัสประเทศของหน่วยงานที่เริ่มต้นการชำระเงิน.
คำอธิบาย ระบุเขตอำนาจศาลที่เป็นต้นทางของคำขอชำระเงิน ข้อมูลนี้สำคัญต่อแดชบอร์ด 'ระยะเวลาตรวจสอบรายชื่อคว่ำบาตร' เพราะการชำระเงินจากเขตอำนาจศาลที่มีความเสี่ยงสูงมักต้องผ่านการตรวจสอบการปฏิบัติตามข้อกำหนดอย่างละเอียดและใช้เวลานานกว่า ช่วยวิเคราะห์ปริมาณการชำระเงินและความล่าช้าในการประมวลผลตามภูมิภาค. เหตุผลที่สำคัญ มิติสำคัญสำหรับวิเคราะห์ความเสี่ยงด้านการปฏิบัติตามข้อกำหนดและผลการดำเนินงานในแต่ละภูมิภาค. แหล่งข้อมูล ได้จาก Sender BIC โดยใช้ตัวอักษรตำแหน่งที่ 5-6 ซึ่งเป็นรหัสประเทศ. ตัวอย่าง USGBDEFR
	เป็นการชำระเงินข้ามพรมแดน IsCrossBorder	ตัวบ่งชี้ว่าการชำระเงินเกี่ยวข้องกับประเทศมากกว่าหนึ่งประเทศหรือไม่.
คำอธิบาย แอตทริบิวต์แบบบูลีนที่มีค่า True เมื่อประเทศของผู้ส่งแตกต่างจากประเทศของผู้รับผลประโยชน์ ช่วยคำนวณ KPI 'ความล่าช้าในการจัดการหลายสกุลเงิน' โดยแยกรายการในประเทศออกจากรายการระหว่างประเทศ การชำระเงินข้ามพรมแดนมักมีความซับซ้อน ค่าใช้จ่าย และเวลาในการประมวลผลสูงกว่า. เหตุผลที่สำคัญ เป็นเกณฑ์พื้นฐานในการแบ่งกลุ่มเพื่อวิเคราะห์ความซับซ้อนของการชำระเงิน. แหล่งข้อมูล เปรียบเทียบรหัสประเทศของ Sender BIC กับรหัสประเทศของ Beneficiary BIC. ตัวอย่าง truefalse
	ลำดับความสำคัญของคำสั่ง InstructionPriority	ตัวบ่งชี้ระดับความสำคัญที่แสดงความเร่งด่วนของการชำระเงิน.
คำอธิบาย ได้จากส่วนหัวของข้อความ เช่น 'ปกติ' หรือ 'เร่งด่วน' จึงใช้แบ่งกลุ่มในแดชบอร์ด 'รอบการอนุมัติการโอนเงินมูลค่าสูง' ได้ เพราะการชำระเงินเร่งด่วนมักต้องผ่านขั้นตอนอนุมัติที่รวดเร็วขึ้น การเข้าใจสัดส่วนของแต่ละระดับความสำคัญช่วยวางแผนทรัพยากรในช่วงที่มีรายการหนาแน่น. เหตุผลที่สำคัญ ช่วยแยกข้อกำหนด SLA ของการชำระเงินทั่วไปกับรายการเร่งด่วน. แหล่งข้อมูล ฟิลด์ลำดับความสำคัญของข้อความใน SWIFT Block 2 เช่น N สำหรับปกติ และ U สำหรับเร่งด่วน. ตัวอย่าง ปกติเร่งด่วนระบบ
	ส่งทันเวลาปิดรับรายการ MetCutOffTime	ตัวบ่งชี้ว่ามีการส่งคำสั่งก่อนถึงกำหนดเวลาของเครือข่ายหรือไม่.
คำอธิบาย ตัวบ่งชี้แบบบูลีนที่คำนวณโดยเปรียบเทียบเวลาที่ส่ง 'คำสั่งชำระเงิน' กับเวลาปิดรับรายการของเครือข่าย SWIFT สำหรับแต่ละสกุลเงิน ใช้คำนวณ KPI 'อัตราการส่งรายการทันเวลาปิดรับของ SWIFT' หากส่งไม่ทันเวลาปิดรับรายการ การชำระดุลจะล่าช้าและส่งผลต่อสภาพคล่อง. เหตุผลที่สำคัญ KPI ด้านการปฏิบัติการที่สำคัญต่อการบริหารเงินทุนและสภาพคล่อง. แหล่งข้อมูล คำนวณโดยเปรียบเทียบเวลาประทับกับตารางอ้างอิงเวลาปิดรับรายการแบบคงที่. ตัวอย่าง truefalse
	เหตุผลที่ปฏิเสธรายการ RejectionReason	ข้อความอธิบายสาเหตุที่ปฏิเสธการชำระเงิน.
คำอธิบาย มีคำอธิบายหรือรหัสที่ระบุสาเหตุเมื่อการชำระเงินไม่สำเร็จ โดยมักพบใน SWIFT Field 72 (ข้อมูลจากผู้ส่งถึงผู้รับ) หรือข้อความส่งคืน ใช้สนับสนุนการวิเคราะห์ 'สาเหตุหลักที่ผู้รับผลประโยชน์ปฏิเสธรายการ' นักวิเคราะห์สามารถวิเคราะห์ข้อความเพื่อหาสาเหตุที่พบบ่อย เช่น 'บัญชีไม่ถูกต้อง' หรือ 'ชื่อผู้รับผลประโยชน์ไม่ตรงกัน'. เหตุผลที่สำคัญ ให้บริบทเชิงคุณภาพเกี่ยวกับความล้มเหลวของกระบวนการ. แหล่งข้อมูล SWIFT Field 72 หรือ 79 ในข้อความส่งคืน (MT103 Return). ตัวอย่าง ปิดบัญชีผู้รับผลประโยชน์แล้วIBAN ไม่ถูกต้องไม่ผ่านการปฏิบัติตามข้อกำหนดไม่ทราบรหัสธนาคาร

จำเป็น แนะนำ ไม่บังคับ

กิจกรรมการประมวลผลการชำระเงิน

ควรบันทึกขั้นตอนและจุดสำคัญเหล่านี้ไว้ในบันทึกเหตุการณ์ เพื่อค้นพบกระบวนการและระบุคอขวดได้อย่างแม่นยำ.

6 แนะนำ 6 ไม่บังคับ

	กิจกรรม	คำอธิบาย
	กระทบยอดการชำระเงินแล้ว	การจับคู่ธุรกรรมการชำระเงินกับรายการเดินบัญชี Nostro/Vostro อนุมานได้เมื่อระบบกระทบยอดเชื่อมรหัสธุรกรรมกับรายการในบัญชี.
เหตุผลที่สำคัญ ปิดวงจรทางการเงิน ความล่าช้าในขั้นตอนนี้กระทบการมองเห็นเงินสดและความสามารถในการตรวจสอบย้อนหลัง. แหล่งข้อมูล บันทึกของระบบกระทบยอด หรือสถานะ 'Matched' ใน Core Banking System. บันทึก เปรียบเทียบสถานะการกระทบยอด ประเภทเหตุการณ์ inferred
	ชำระเงินแล้ว	การยืนยันว่าเงินเข้าบัญชีของผู้รับแล้ว ซึ่งมักเป็นสถานะ gpi ACSC บันทึกได้โดยตรงจากการอัปเดตของตัวติดตามหรือข้อความยืนยัน.
เหตุผลที่สำคัญ แสดงจุดสิ้นสุดของสายการชำระเงินที่เสร็จสมบูรณ์ จำเป็นต่อการคำนวณ 'ช่องว่างระหว่างการชำระราคากับการกระทบยอด'. แหล่งข้อมูล SWIFT gpi Tracker (สถานะ ACSC) หรือข้อความยืนยัน MT900/910. บันทึก บันทึกเมื่อยืนยันการชำระราคา ประเภทเหตุการณ์ explicit
	ผ่านการตรวจสอบรายชื่อคว่ำบาตร	เวลาที่คำสั่งชำระเงินผ่านการตรวจสอบรายชื่อ OFAC/รายชื่อคว่ำบาตรสำเร็จ บันทึกได้โดยตรงจากบันทึกของระบบการปฏิบัติตามข้อกำหนด หรืออนุมานจากการปลดสถานะ 'Screening Hold'.
เหตุผลที่สำคัญ จำเป็นต่อแดชบอร์ด 'เวลานำในการตรวจสอบรายชื่อคว่ำบาตร' ความล่าช้าในขั้นตอนนี้เป็นคอขวดด้านการปฏิบัติตามข้อกำหนด ไม่ใช่ความไม่มีประสิทธิภาพในการปฏิบัติงาน. แหล่งข้อมูล บันทึกของระบบกรองเพื่อตรวจสอบการปฏิบัติตามข้อกำหนด หรือแฟล็กสถานะการปฏิบัติตามข้อกำหนดใน Payment Hub. บันทึก บันทึกเมื่อสถานะการตรวจสอบมีการอัปเดต ประเภทเหตุการณ์ explicit
	ส่งคำสั่งชำระเงินแล้ว	การส่งข้อความที่จัดรูปแบบแล้ว (MT103 หรือ ISO 20022 pacs.008) ไปยัง SWIFT Gateway ระบบจะบันทึกเหตุการณ์นี้โดยตรงเมื่อสร้างเนื้อหาข้อความและส่งต่อไปยังอินเทอร์เฟซเครือข่าย
เหตุผลที่สำคัญ ใช้คำนวณ 'อัตราการส่งทันเวลาปิดรับรายการของ SWIFT' เป็นจุดเปลี่ยนจากการประมวลผลภายในไปสู่การประมวลผลบนเครือข่าย. แหล่งข้อมูล บันทึกของ SWIFT Alliance Access (SAA) หรือบันทึกการส่งข้อมูลของ Gateway บันทึก บันทึกเมื่อส่งข้อความออก ประเภทเหตุการณ์ explicit
	สร้างคำขอชำระเงิน	ระบบธนาคารภายในหรือ ERP สร้างคำสั่งชำระเงินขึ้นเป็นครั้งแรก โดยบันทึกเหตุการณ์นี้ได้โดยตรงเมื่อกำหนดรหัสอ้างอิงธุรกรรมที่ไม่ซ้ำกัน (TRN หรือ UETR) ให้กับคำสั่งชำระเงินเป็นครั้งแรก.
เหตุผลที่สำคัญ ใช้กำหนดเวลาเริ่มต้นของวงจรการชำระเงินทั้งหมด จำเป็นต่อการคำนวณเวลาประมวลผลตั้งแต่ต้นจนจบ และระบุความล่าช้าต้นทางก่อนเริ่มใช้งานเครือข่าย SWIFT. แหล่งข้อมูล เวลาที่สร้างรายการในตารางธุรกรรมของ Core Banking System (CBS) หรือ Payment Hub. บันทึก บันทึกเมื่อสร้างระเบียนธุรกรรม ประเภทเหตุการณ์ explicit
	อนุมัติการชำระเงินแล้ว	การอนุมัติขั้นสุดท้ายโดยเจ้าหน้าที่ที่ได้รับมอบหมายหรือกฎอัตโนมัติสำหรับการโอนเงินมูลค่าสูง บันทึกได้โดยตรงเมื่อกำหนดค่าแฟล็กเวิร์กโฟลว์การอนุมัติเป็น true.
เหตุผลที่สำคัญ สำคัญต่อแดชบอร์ด 'รอบการอนุมัติการโอนเงินมูลค่าสูง' ใช้ระบุความล่าช้าจากการลงนามอนุมัติด้วยมือสำหรับการเคลื่อนย้ายสภาพคล่องจำนวนมาก. แหล่งข้อมูล หลักฐานการตรวจสอบจากระบบเวิร์กโฟลว์การอนุมัติ. บันทึก บันทึกเมื่อดำเนินการอนุมัติ ประเภทเหตุการณ์ explicit
	การชำระเงินถูกปฏิเสธ	การได้รับข้อความปฏิเสธ (MT103 Return หรือสถานะ gpi RJCT) จากธนาคารผู้รับหรือธนาคารตัวกลาง บันทึกได้โดยตรงจากข้อความ SWIFT ขาเข้า.
เหตุผลที่สำคัญ สำคัญต่อแดชบอร์ด 'สาเหตุหลักที่ผู้รับปฏิเสธ' ใช้ระบุปัจจัยภายนอก เช่น บัญชีปิดแล้วหรือข้อมูลเส้นทางไม่ถูกต้อง. แหล่งข้อมูล ข้อความ SWIFT ขาเข้า (MT103 RET, pacs.004) หรือสถานะ gpi RJCT. บันทึก บันทึกเมื่อได้รับข้อความปฏิเสธ ประเภทเหตุการณ์ explicit
	แก้ไขข้อผิดพลาดการชำระเงินแล้ว	การแก้ไขและส่งธุรกรรมที่เคยมีข้อผิดพลาดอีกครั้งจนสำเร็จ อนุมานได้เมื่อธุรกรรมเปลี่ยนจากคิว 'Repair' กลับไปเป็นสถานะ 'Processing' หรือ 'Ready'.
เหตุผลที่สำคัญ ใช้วัดประสิทธิภาพของทีมแก้ไขงานซ้ำด้วยมือ หากใช้เวลานานในขั้นตอนนี้ อาจบ่งชี้ถึงช่องว่างด้านการฝึกอบรมหรือรหัสข้อผิดพลาดที่ซับซ้อน. แหล่งข้อมูล บันทึกสถานะ Payment Hub ที่แสดงการออกจากคิวข้อยกเว้น. บันทึก เปรียบเทียบฟิลด์สถานะเมื่อออกจาก Repair ประเภทเหตุการณ์ inferred
	ได้รับ ACK จาก SWIFT	การได้รับข้อความตอบรับทางเทคนิค (ACK) จากเครือข่าย SWIFT เพื่อยืนยันว่ารับข้อความไปประมวลผลแล้ว บันทึกได้โดยตรงจากบันทึกของส่วนเชื่อมต่อเครือข่าย.
เหตุผลที่สำคัญ ยืนยันว่าข้อความเข้าสู่เครือข่ายทั่วโลกสำเร็จ ช่วยแยกความล้มเหลวภายในออกจากปัญหาที่เกิดขึ้นระหว่างส่งผ่านเครือข่ายจริง. แหล่งข้อมูล บันทึกของ SWIFT Gateway (ตรวจสอบสัญญาณ ACK และ NACK) บันทึก บันทึกเมื่อได้รับ ACK จากเครือข่าย ประเภทเหตุการณ์ explicit
	ตรวจสอบรายละเอียดการชำระเงินแล้ว	การตรวจสอบไวยากรณ์และรูปแบบของคำสั่งชำระเงินสำเร็จ เช่น รูปแบบ IBAN และความถูกต้องของ BIC โดยมักอนุมานจากสถานะธุรกรรมที่เปลี่ยนจาก 'Draft' เป็น 'Validated' หรือ 'Ready for Auth'.
เหตุผลที่สำคัญ หากอัตราความล้มเหลวในขั้นตอนนี้สูง แสดงว่าคุณภาพข้อมูลต้นทางไม่ดี ใช้วัด KPI 'อัตราการตรวจสอบผ่านตั้งแต่ครั้งแรก'. แหล่งข้อมูล บันทึกสถานะ Payment Engine หรือตารางประวัติการตรวจสอบความถูกต้อง. บันทึก เปรียบเทียบฟิลด์สถานะก่อนและหลัง ประเภทเหตุการณ์ inferred
	พบข้อผิดพลาดในการชำระเงิน	เหตุการณ์ที่ทำเครื่องหมายธุรกรรมเพื่อแก้ไข เนื่องจากตรวจสอบไม่ผ่าน ได้รับ NACK หรือมีข้อความปฏิเสธ อนุมานได้เมื่อธุรกรรมเข้าสู่คิว 'Repair', 'Correction' หรือ 'Exception'.
เหตุผลที่สำคัญ ใช้ติดตาม 'อัตราการแก้ไขงานซ้ำเพื่อแก้ข้อผิดพลาด' หากเกิดบ่อยจะทำให้อัตราการประมวลผลแบบ straight-through (STP) ลดลง. แหล่งข้อมูล คอลัมน์สถานะใน Payment Hub หรือบันทึกคิวข้อยกเว้น. บันทึก เปรียบเทียบฟิลด์สถานะกับ Error/Repair ประเภทเหตุการณ์ inferred
	โอนการชำระเงินแล้ว	การอัปเดตสถานะระหว่างทาง ซึ่งมักเป็นสถานะ gpi ACSP แสดงว่าธนาคารตัวกลางกำลังประมวลผลการชำระเงิน บันทึกได้จากการอัปเดต SWIFT gpi Tracker หรือข้อความสถานะ.
เหตุผลที่สำคัญ ช่วยให้เห็นขั้นตอนที่ปกติมองไม่เห็นในการธนาคารตัวแทน จำเป็นต่อการวิเคราะห์เส้นทางทั้งหมดตั้งแต่ต้นจนจบ. แหล่งข้อมูล ฟีดข้อมูล SWIFT gpi Tracker หรือข้อความ MT199/trck. บันทึก บันทึกเมื่อได้รับการอัปเดตจากตัวติดตาม ประเภทเหตุการณ์ explicit

แนะนำ ไม่บังคับ

คู่มือการดึงข้อมูล

วิธีดึงข้อมูลจาก SWIFT

ขั้นตอน

เข้าสู่ระบบ SWIFT Alliance WebPlatform หรือ GUI ของ Alliance Access ด้วยบัญชีผู้ดูแลระบบที่เข้าถึงการตั้งค่าการเก็บถาวรได้.
ไปที่เมนู System Management เลือก Archiving แล้วเลือก Automated Archiving Configuration.
ตั้งค่าโปรไฟล์ส่งออกประจำวันใหม่ กำหนด Target Directory เป็นเส้นทางเครือข่ายที่ปลอดภัยและสคริปต์ดึงข้อมูลเข้าถึงได้.
ระบุขอบเขตเนื้อหา เลือก 'Messages' และตรวจสอบว่าเลือก 'Include History' กับ 'Include Interventions' แล้ว ขั้นตอนนี้จำเป็นต่อการเก็บเหตุการณ์ในเส้นทางตรวจสอบ เช่น การอนุมัติและการตรวจสอบความถูกต้อง.
เลือกรูปแบบไฟล์ส่งออก เลือก XML (โดยเฉพาะ 'SAA XML v2' หรือสคีมาล่าสุดที่มี) เพราะเก็บความสัมพันธ์แบบลำดับชั้นระหว่างส่วนหัวข้อความกับเหตุการณ์ในประวัติได้ดีกว่า CSV.
ตั้งค่าตัวกรองช่วงวันที่เพื่อดึงข้อมูลย้อนหลังตามช่วงที่ต้องการสำหรับโครงการ process mining หรือกำหนดให้ทำงานทุกวันเพื่อดึงข้อมูล T-1.
เรียกใช้งานส่งออกไฟล์เก็บถาวรด้วยตนเองสำหรับการโหลดครั้งแรก หรือรอให้งานตามกำหนดเสร็จ ตรวจสอบว่ามีการสร้างไฟล์ .xml ในไดเรกทอรีปลายทาง.
เนื่องจากไฟล์ส่งออก SAA เป็น XML แบบลำดับชั้น แต่ ProcessMind ต้องใช้บันทึกเหตุการณ์ CSV แบบแบน คุณจึงต้องเรียกใช้สคริปต์แปลงข้อมูล ใช้สคริปต์ Python ในส่วน Query เพื่อแยกวิเคราะห์ XML.
สคริปต์จะวนอ่านองค์ประกอบข้อความทั้งหมด แล้วดึง Unique End-to-end Transaction Reference (UETR) หรือ Transaction Reference Number (TRN) มาใช้เป็น Case ID.
จากนั้นสคริปต์จะวนอ่านโหนดย่อย 'History' และ 'Intervention' ของแต่ละข้อความเพื่อสร้างแถวกิจกรรม พร้อมแปลงรหัสสถานะภายในของ SAA (เช่น 'NetworkAck', 'Authorisation') เป็นชื่อกิจกรรมมาตรฐาน.
เรียกใช้สคริปต์ Python กับไฟล์ XML ที่ส่งออก เพื่อสร้างไฟล์ 'events.csv' แบบแบน.
ตรวจสอบไฟล์ CSV ว่าคอลัมน์อย่าง EventTimestamp อยู่ในรูปแบบ ISO 8601 จากนั้นอัปโหลดไฟล์ไปยัง ProcessMind.

การกำหนดค่า

รูปแบบไฟล์เก็บถาวร: XML (แนะนำ) หรือ CSV (ไฟล์แบบแบน) แนะนำ XML อย่างยิ่งเพื่อเก็บโหนดประวัติที่ซ้อนกัน.
รวมเนื้อหาข้อความ: ใช่ (จำเป็นสำหรับแยกวิเคราะห์ Amount, Currency และ Beneficiary).
รวมประวัติ/การดำเนินการแทรกแซง: ใช่ (จำเป็นสำหรับดูการอนุมัติ การตรวจสอบความถูกต้อง และข้อผิดพลาด).
ช่วงวันที่: กำหนดช่วงย้อนหลังต่อเนื่อง (เช่น 30 วันล่าสุด) สำหรับการโหลดข้อมูลเพิ่มเติม หรือกำหนดวันที่ตายตัวสำหรับข้อมูลย้อนหลังครั้งแรก.
ประเภทข้อความ: กรอง MT103, MT202, pacs.008, pacs.009 และ pacs.004/002 (สำหรับรายการคืนเงิน/สถานะ).
ทิศทาง: รวมทั้งขาเข้า (Emission) และขาออก (Reception) เพื่อเก็บข้อมูลการปฏิเสธหรือการยืนยันที่ได้รับ.
ความปลอดภัย: กำหนดสิทธิ์อ่าน/เขียนในโฟลเดอร์ส่งออกอย่างเข้มงวด เนื่องจากไฟล์เหล่านี้มีข้อมูลการชำระเงินจริง.

ตัวอย่างคำค้น 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}")

ขั้นตอน

เตรียมสภาพแวดล้อม: ตรวจสอบว่าติดตั้ง Python 3.8 ขึ้นไปบนเซิร์ฟเวอร์ที่ใช้ดึงข้อมูล ติดตั้งไลบรารีที่จำเป็นด้วย pip (pandas, numpy) สร้างโฟลเดอร์ทำงานเฉพาะ โดยมีโฟลเดอร์ย่อยชื่อ raw_swift_files แล้วนำไฟล์ .out, .txt หรือ .fin รายวันทั้งหมดไปไว้ในนั้น
ทำความเข้าใจโครงสร้างไฟล์: ข้อความ SWIFT FIN ดิบมีโครงสร้างเป็นบล็อก ({1: Header} {2: Application} {4: Body}) ให้ระบุตัวคั่น โดยไฟล์มาตรฐานใช้วงเล็บปีกกา ตรวจสอบว่าไฟล์ไม่ได้ห่อด้วยส่วนครอบเฉพาะของระบบ เช่น ส่วนหัว RJE หากมี ให้ลบออกก่อนประมวลผล
ตั้งค่าเส้นทางในสคริปต์: เปิดสคริปต์ Python ที่ให้มา แล้วกำหนดตัวแปร INPUT_DIRECTORY ให้ชี้ไปยังโฟลเดอร์ raw_swift_files จากนั้นกำหนดเส้นทาง OUTPUT_FILE สำหรับไฟล์ CSV ผลลัพธ์
กำหนดรูปแบบ Regex: สคริปต์ใช้ regex เพื่อแยกบล็อก บล็อก 1 มี Sender BIC และ Sequence Number บล็อก 2 มี Message Type เช่น I103, O103 และ Receiver BIC ส่วนบล็อก 4 มีแท็กข้อมูลธุรกิจ เช่น :20: TRN และ :32A: Value/Amount
จับคู่ประเภทข้อความกับกิจกรรม: สคริปต์มีพจนานุกรมสำหรับจับคู่ MT103 หมายถึง 'ส่งคำสั่งชำระเงิน' ส่วน MT012 (System ACK) หมายถึง 'ได้รับ SWIFT ACK' และ MT900/910 หมายถึง 'ชำระเงินแล้ว' สำหรับ MT199/299 ที่มีรหัสสถานะเฉพาะ (ACSP, RJCT) ให้จับคู่กับ 'โอนเงินแล้ว' หรือ 'ปฏิเสธการชำระเงิน'
ดึงแอตทริบิวต์: ตัวแยกวิเคราะห์จะวนดูแท็กที่กำหนด โดยจับคู่ :20: กับ Payment Transaction ID, :121: กับ UETR และแยก :32A: เป็นวันที่ สกุลเงิน และจำนวนเงิน
จัดการสถานะภายใน: สำหรับกิจกรรมอย่าง 'สร้างคำขอชำระเงิน' หรือ 'อนุมัติการชำระเงิน' ซึ่งมักเป็นเหตุการณ์ภายใน ERP และไม่มีในไฟล์ SWIFT หากไม่มีบันทึกโดยตรง สคริปต์จะใช้เวลาสร้างข้อความในบล็อก 1 เพื่ออนุมานกิจกรรม หรือค้นหารหัสข้อความเฉพาะในฟิลด์ :72: (Sender to Receiver Info) หากองค์กรบันทึกการอนุมัติไว้ที่นั่น
ดึงข้อมูล: เรียกใช้สคริปต์ผ่านบรรทัดคำสั่ง: python swift_parser.py สคริปต์จะประมวลผลทุกไฟล์ แยกวิเคราะห์บล็อก SWIFT ที่ถูกต้อง และข้ามบรรทัดที่มีรูปแบบผิด
ตรวจสอบหลังประมวลผล: เปิดไฟล์ CSV ที่สร้างขึ้น ตรวจสอบรูปแบบ EventTimestamp (แนะนำ ISO 8601) และตรวจสอบว่า PaymentTransactionId มีค่าในทุกแถว เพื่อให้จัดกลุ่มเคสได้
แปลงข้อมูล: หาก 'ValueDate' อยู่ในรูปแบบ YYMMDD สคริปต์จะแปลงเป็น YYYY-MM-DD ตรวจสอบว่าตัวคั่นทศนิยมใน 'TransactionAmount' ใช้รูปแบบเดียวกันทั้งหมด ไม่ว่าจะเป็นจุดหรือจุลภาค
ตรวจสอบขั้นสุดท้าย: กรองด้วย UETR รายการหนึ่งเพื่อดูขั้นตอนตั้งแต่ส่งคำสั่ง -> ACK -> ชำระเงิน ตรวจสอบว่า NAK (MT019) แสดงเป็น 'ตรวจพบข้อผิดพลาดในการชำระเงิน'
อัปโหลดไปยัง ProcessMind: นำเข้าไฟล์ CSV แล้วจับคู่ PaymentTransactionId กับรหัสเคส, ActivityName กับกิจกรรม และ EventTimestamp กับการประทับเวลา

การกำหนดค่า

ไดเรกทอรีข้อมูลขาเข้า: เส้นทางไปยังโฟลเดอร์ที่มีไฟล์ FIN/MT แบบแบน ตรวจสอบว่ามีสิทธิ์อ่าน.
การแยกวิเคราะห์รูปแบบวันที่: วันที่ดิบของ SWIFT ใช้ YYMMDD สคริปต์กำหนดศตวรรษเป็น 20xx.
ตัวกรองประเภทข้อความ: สคริปต์เน้นหมวด 1 (การชำระเงิน), 9 (รายการเดินบัญชี) และข้อความระบบที่พบบ่อย (012, 019) หากต้องใช้หมวด 2 (การโอนเงินระหว่างสถาบันการเงิน) ให้ปรับรายการ RELEVANT_MT_TYPES.
การเข้ารหัส: ค่าเริ่มต้นคือ 'utf-8' เปลี่ยนเป็น 'latin-1' หรือ 'ascii' หากไฟล์มีอักขระจากการเข้ารหัสแบบเก่า.
การประมวลผลเป็นชุด: สำหรับชุดข้อมูลขนาดเกิน 1GB สคริปต์ใช้วิธี generator เพื่อป้องกันหน่วยความจำล้น โดยประมวลผลทีละไฟล์.
การปรับ Regex: regex แบบเข้มงวดกำหนดให้ใช้รูปแบบ FIN มาตรฐาน {1:...}{2:...}{4:...} หากไฟล์ใช้ $ หรือตัวคั่นอื่น ให้ปรับตัวแปร BLOCK_PATTERN.

ตัวอย่างคำค้น 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()

ขั้นตอน

ตรวจสอบว่าคุณมีการสมัครใช้ SWIFT gpi Tracker API, ข้อมูลรับรอง API, ความสามารถในการค้นหา UETR และสิทธิ์เข้าถึงแหล่งเหตุการณ์ของระบบชำระเงินภายใน ขอ URL ฐาน API วิธีตรวจสอบสิทธิ์ สคีมาคำตอบ ขีดจำกัดการเรียกใช้ และกติกาการแบ่งหน้าจากเอกสารบริการ SWIFT ของคุณ อย่าคาดเดาเส้นทาง endpoint เพราะขึ้นอยู่กับบริการ SWIFT ที่ได้รับสิทธิ์และรูปแบบการติดตั้ง.
ตั้งค่าสคริปต์ด้วยสตริงการเชื่อมต่อ ข้อมูลรับรอง ช่วงวันที่ และตัวกรองเฉพาะบริษัทที่จำเป็น ใช้ช่วงสามถึงหกเดือนสำหรับการดึงข้อมูลครั้งแรก จำกัดข้อมูลจากแหล่งภายในให้เหลือธุรกรรมที่มี TRN หรือ UETR และเก็บชื่อระบบต้นทางของทุกเหตุการณ์.
ดึงเหตุการณ์วงจรภายในสำหรับ สร้างคำขอชำระเงิน, ตรวจสอบรายละเอียดการชำระเงินแล้ว, ผ่านการตรวจสอบรายชื่อคว่ำบาตร, อนุมัติการชำระเงิน, ส่งคำสั่งชำระเงินแล้ว, ได้รับ SWIFT ACK, ตรวจพบข้อผิดพลาดในการชำระเงิน, แก้ไขข้อผิดพลาดในการชำระเงินแล้ว, ปฏิเสธการชำระเงิน, ชำระเงินแล้ว และกระทบยอดการชำระเงินแล้ว แปลงแต่ละเหตุการณ์จากแหล่งข้อมูลเป็นแถวแยกในบันทึกเหตุการณ์ อย่าคาดหวังให้ ProcessMind อนุมานกิจกรรมเอง.
ดึง UETR จากระเบียนการชำระเงินภายใน แล้วค้นหา UETR แต่ละรายการผ่าน SWIFT gpi Tracker API ที่ได้รับสิทธิ์ ใช้เอกสาร API สำหรับสภาพแวดล้อมของคุณเพื่อตั้งค่า URL คำขอ ส่วนหัวตรวจสอบสิทธิ์ พารามิเตอร์คำขอ การแบ่งหน้า และฟิลด์คำตอบ เก็บคำตอบดิบไว้เพื่อให้ตรวจสอบย้อนหลังได้.
แปลงสถานะ gpi ที่เกี่ยวข้องเป็นแถวเหตุการณ์อย่างชัดเจน สคริปต์จับคู่ ACSP กับโอนเงินแล้ว, RJCT กับปฏิเสธการชำระเงิน และ ACSC กับชำระเงินแล้ว หากคำตอบที่ได้รับสิทธิ์ใช้ชื่อสถานะหรือเวลาต่างกัน ให้ปรับการจับคู่สถานะตามสคีมาคำตอบที่ระบุไว้ อย่าสร้างเหตุการณ์หาก API ไม่มีสถานะที่เกิดขึ้นตรงกัน.
ปรับเวลาทั้งหมดให้อยู่ในเขตเวลาเดียวกัน โดยแนะนำให้ใช้ UTC และเก็บเวลาต้นฉบับไว้เมื่อจำเป็นต่อการตรวจสอบ แปลงจำนวนเงินเป็นตัวเลข เก็บสกุลเงินของธุรกรรม ปรับค่า STP แบบ Boolean ให้เป็นรูปแบบเดียวกัน และคงค่า NULL ไว้เมื่อแหล่งข้อมูลไม่มีข้อมูลนั้น.
ลบเหตุการณ์ซ้ำโดยใช้ PaymentTransactionId, ActivityName, EventTimestamp และตัวระบุเหตุการณ์จากแหล่งข้อมูลที่เฉพาะเจาะจงที่สุด เก็บเหตุการณ์ที่เกิดขึ้นซ้ำอย่างถูกต้อง เช่น การแก้ไขและส่งใหม่หลายรอบ เว้นแต่กฎธุรกิจจะกำหนดให้มีกิจกรรมละหนึ่งครั้ง.
ตรวจสอบว่าแต่ละแถวมี PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem และ LastDataUpdate ตรวจสอบว่า ActivityName มีเฉพาะค่ากิจกรรมที่ระบุไว้ และมีกิจกรรมครบทั้ง 12 รายการเมื่อข้อมูลต้นทางมีเหตุการณ์เหล่านั้น.
ส่งออกชุดข้อมูลเป็น UTF-8 CSV หรือรูปแบบบันทึกเหตุการณ์อื่นที่ ProcessMind รองรับ ใช้หนึ่งแถวต่อเหตุการณ์ รวมคอลัมน์ที่จำเป็นและคอลัมน์แนะนำ แล้วจับคู่ PaymentTransactionId เป็นตัวระบุเคส, ActivityName เป็นกิจกรรม และ EventTimestamp เป็นเวลาของเหตุการณ์ อัปโหลดไฟล์ไปยัง ProcessMind โดยไม่คาดหวังว่าจะมีการสร้างเหตุการณ์เพิ่มเติม.

การกำหนดค่า

endpoint และสคีมาของ API: ตั้งค่า URL ฐาน SWIFT gpi Tracker API, เส้นทางทรัพยากร, พารามิเตอร์คำขอ, ส่วนหัวตรวจสอบสิทธิ์, การแบ่งหน้า และชื่อฟิลด์คำตอบให้ตรงกับเอกสาร SWIFT ที่ได้รับสิทธิ์สำหรับสภาพแวดล้อมของคุณ สคริปต์นี้จะไม่สร้าง endpoint ขึ้นเอง.
ข้อมูลรับรองและการอนุญาต: ใช้กลไกข้อมูลรับรอง SWIFT API ที่ได้รับอนุมัติ ข้อกำหนดใบรับรองหรือโทเค็น วิธีจัดเก็บข้อมูลลับ และสิทธิ์ของระบบต้นทางภายใน อย่าใส่ข้อมูลลับสำหรับระบบจริงไว้ในซอร์สโค้ดโดยตรง.
ช่วงวันที่: เริ่มจากสามถึงหกเดือน ใช้เวลาของเหตุการณ์หรือวันที่สร้างรายการชำระเงินตามเป้าหมายการรายงาน หากมีข้อมูลจำนวนมาก ให้แบ่งประมวลผลเป็นช่วงสั้นลงและบันทึก UETR ที่ดำเนินการเสร็จแล้ว.
ตัวกรองแหล่งข้อมูลภายใน: ตั้งค่าตัวกรองบริษัท นิติบุคคล สาขา ผลิตภัณฑ์การชำระเงิน ประเภทเอกสาร ประเภทข้อความ สกุลเงิน และสถานะตามระบบของคุณ ใช้ค่าตัวอย่าง เช่น [Configure based on your system] จนกว่าจะยืนยันสคีมาของแหล่งข้อมูล.
การจับคู่กิจกรรม: กำหนดการจับคู่สถานะและคิวภายในอย่างชัดเจน ตัวอย่างเช่น Draft กับ Validated หรือ Ready for Auth ให้เป็นตรวจสอบรายละเอียดการชำระเงินแล้ว, การปล่อยรายการจาก Screening Hold ให้เป็นผ่านการตรวจสอบรายชื่อคว่ำบาตร, การเข้าคิว Repair หรือ Exception ให้เป็นตรวจพบข้อผิดพลาดในการชำระเงิน และการกลับไปยัง Processing หรือ Ready for Payment ให้เป็นแก้ไขข้อผิดพลาดในการชำระเงินแล้ว.
การจับคู่สถานะ gpi: จับคู่สถานะ tracker ตามเอกสารกับกิจกรรมอย่างชัดเจน การตั้งค่านี้จับคู่ ACSP กับโอนเงินแล้ว, RJCT กับปฏิเสธการชำระเงิน และ ACSC กับชำระเงินแล้ว เพิ่มการจับคู่เฉพาะเมื่อเอกสาร API ที่ได้รับสิทธิ์ยืนยันความหมายของสถานะแล้ว.
นโยบายเวลา: ปรับเวลาเป็น UTC เมื่อทำได้ กำหนดลำดับความสำคัญระหว่างเวลาของเหตุการณ์ต้นทาง เวลาเหตุการณ์ tracker เวลารับข้อความ และเวลาดึงข้อมูล LastDataUpdate ต้องระบุเวลาที่ดึงหรือรีเฟรชข้อมูล ไม่ใช่เวลาที่เกิดเหตุการณ์ทางธุรกิจ.
ขีดจำกัดการเรียกใช้และการลองใหม่: ตั้งค่าเวลารอคำขอ จำนวนครั้งที่ลองใหม่ การหน่วงเวลาแบบทวีคูณ การจัดการสถานะ HTTP และการแบ่งหน้า ปฏิบัติตามขีดจำกัดของบริการ SWIFT และหลีกเลี่ยงการส่งคำขอพร้อมกันโดยไม่มีการควบคุม.
ประสิทธิภาพ: แคชคำตอบตาม UETR ประมวลผล UETR เป็นชุด บันทึกจุดตรวจ และดึงข้อมูลเพิ่มเติมเมื่อระบบรองรับ หลีกเลี่ยงการค้นหา UETR และช่วงวันที่เดิมซ้ำใน tracker.
คุณภาพข้อมูล: กำหนดให้มี PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem และ LastDataUpdate อนุญาตให้ฟิลด์แนะนำเป็น NULL เมื่อแหล่งข้อมูลไม่มีค่า แต่ให้รายงานอัตราการมีข้อมูลของแต่ละฟิลด์.
การตรวจสอบย้อนหลัง: บันทึกคำตอบ API ดิบ เวลาส่งคำขอ สถานะคำตอบ UETR และรหัสการดึงข้อมูลไว้ในพื้นที่ตรวจสอบที่ได้รับอนุมัติ ปฏิบัติตามกฎการเก็บรักษาและความปลอดภัยของข้อมูลการชำระเงิน.
ข้อกำหนดเบื้องต้น: ยืนยันสิทธิ์เข้าถึงบันทึกวงจรการชำระเงินภายใน การปฏิบัติตามข้อกำหนด เกตเวย์ SWIFT การกระทบยอด และอินเทอร์เฟซข้อความ รวมถึงไลเซนส์ SWIFT gpi Tracker API และใบรับรองหรือการอนุญาตเครือข่ายที่จำเป็น.

ตัวอย่างคำค้น 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()

พร้อมเริ่มต้นหรือยัง?

ใช้เทมเพลตเหล่านี้เปลี่ยนบันทึก SWIFT ดิบให้เป็นเครื่องมือช่วยปรับปรุงการปฏิบัติงานและเร่งการชำระเงิน.

กลับไปยังคู่มือการปรับปรุง

ดาวน์โหลดเทมเพลต

ปรับปรุงการประมวลผลการชำระเงินผ่าน SWIFT ได้เลย

เพิ่มสัดส่วนการประมวลผลอัตโนมัติโดยไม่ต้องทำด้วยมือให้ถึง 98% และขจัดข้อผิดพลาดจากการทำงานด้วยมือ

เริ่มทดลองใช้ฟรี

ไม่ต้องใช้บัตรเครดิต ตั้งค่าเสร็จใน 5 นาที

เทมเพลตข้อมูลการประมวลผลการชำระเงินของคุณ

เทมเพลตข้อมูลการประมวลผลการชำระเงินของคุณ

แอตทริบิวต์การประมวลผลการชำระเงิน

กิจกรรมการประมวลผลการชำระเงิน

คู่มือการดึงข้อมูล

ส่งออกไฟล์เก็บถาวรจาก SWIFT Alliance Access

ขั้นตอน

การกำหนดค่า

ตัวอย่างคำค้น python

ตัวแยกวิเคราะห์ Python สำหรับไฟล์ SWIFT MT ดิบ

ขั้นตอน

การกำหนดค่า

ตัวอย่างคำค้น python

ตัวเชื่อมต่อ SWIFT gpi API

ขั้นตอน

การกำหนดค่า

ตัวอย่างคำค้น python

พร้อมเริ่มต้นหรือยัง?

ปรับปรุงการประมวลผลการชำระเงินผ่าน SWIFT ได้เลย