> Cải tiến quy trình liên tục > Xử lý thanh toán > SWIFT > Mẫu dữ liệu

Mẫu dữ liệu xử lý thanh toán của bạn

SWIFT

Thuộc tính xử lý thanh toán(19) Các hoạt động xử lý thanh toán(12) Hướng dẫn trích xuất dữ liệu(3)

Mẫu dữ liệu xử lý thanh toán của bạn

Mẫu này cung cấp cấu trúc để sơ đồ hóa quy trình giao dịch SWIFT, từ lúc khởi tạo đến khi thanh toán hoàn tất. Mẫu nêu rõ các thành phần dữ liệu và mốc vận hành cần có để theo dõi đầy đủ vòng đời thanh toán. Dùng hướng dẫn này để chuẩn bị dữ liệu, tìm ra những điểm kém hiệu quả tiềm ẩn và giảm rủi ro về tuân thủ.

Thuộc tính nên có để phân tích giao dịch chuyên sâu
Các hoạt động và mốc chính trong quy trình SWIFT
Hướng dẫn kỹ thuật trích xuất dữ liệu tài chính

Chưa quen với nhật ký sự kiện? Tìm hiểu cách tạo nhật ký sự kiện cho process mining.

Tải mẫu xuống

Thuộc tính xử lý thanh toán

Đây là những trường dữ liệu nên có trong nhật ký sự kiện để phân tích đầy đủ vòng đời giao dịch SWIFT.

5 Bắt buộc 9 Nên có 5 Không bắt buộc

	Tên	Mô tả
	Dấu thời gian sự kiện EventTimestamp	Ngày và giờ chính xác khi hoạt động diễn ra.
Mô tả Thuộc tính này ghi lại chính xác thời điểm một sự kiện xảy ra. Dữ liệu được dùng để sắp xếp hoạt động theo trình tự thời gian và tính mọi chỉ số dựa trên thời lượng, như thời gian chờ, thời gian xử lý và thông lượng. Dấu thời gian chính xác rất quan trọng để phân tích 'Hiệu suất đáp ứng thời hạn chốt giao dịch của mạng' và xác định điểm nghẽn trong chuỗi phê duyệt. Vì sao điều này quan trọng Dấu thời gian là cơ sở cho mọi phân tích theo thời gian và chỉ số hiệu suất trong process mining. Lấy dữ liệu ở đâu Nhật ký kiểm toán hệ thống, dấu thời gian tạo thông điệp hoặc thời điểm giao dịch trong cơ sở dữ liệu. Ví dụ 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	Hệ thống nguồn SourceSystem	Tên hệ thống nơi dữ liệu sự kiện được tạo ra.
Mô tả Thuộc tính này xác định phần mềm hoặc nền tảng tạo nhật ký sự kiện. Trong quy trình thanh toán, đó có thể là hệ thống ngân hàng lõi, cổng thanh toán hoặc giao diện SWIFT. Thuộc tính này giúp xác minh nguồn gốc dữ liệu và xử lý lỗi khi hợp nhất dữ liệu từ nhiều ứng dụng ngân hàng khác nhau. Vì sao điều này quan trọng Cho biết nguồn gốc dữ liệu, cần thiết khi dùng process mining trên nhiều hệ thống. Lấy dữ liệu ở đâu Được thiết lập cố định trong ETL hoặc trích xuất từ mã định danh hệ thống. Ví dụ SWIFT Alliance AccessHệ thống ngân hàng lõiPayment EngineBộ lọc lệnh trừng phạt
	Lần cập nhật dữ liệu gần nhất LastDataUpdate	Dấu thời gian lần gần nhất bản ghi được trích xuất hoặc làm mới.
Mô tả Cho biết lần gần nhất dữ liệu được tải vào công cụ process mining. Thông tin này rất quan trọng để xác định dữ liệu còn mới hay không và đảm bảo dashboard phản ánh trạng thái hiện tại của hoạt động thanh toán. Thông tin này giúp người dùng tin tưởng dữ liệu hơn vì cho thấy độ trễ của luồng báo cáo. Vì sao điều này quan trọng Giúp người dùng hiểu dữ liệu được trình bày có còn mới và đáng tin cậy hay không. Lấy dữ liệu ở đâu Dấu thời gian thực thi quy trình ETL. Ví dụ 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	Mã giao dịch thanh toán PaymentTransactionId	Mã định danh duy nhất cho một hồ sơ thanh toán từ đầu đến cuối.
Mô tả Thuộc tính này là mã hồ sơ trung tâm trong process mining. Mã này nhóm mọi hoạt động liên quan đến một chỉ thị thanh toán, từ yêu cầu ban đầu qua khâu kiểm tra, truyền qua SWIFT đến quyết toán cuối cùng. Trong môi trường SWIFT, mã này thường được ánh xạ với Mã tham chiếu giao dịch (TRN) hoặc Mã tham chiếu giao dịch đầu cuối duy nhất (UETR) để đảm bảo dữ liệu liền mạch giữa các hệ thống ngân hàng. Mã này được dùng để dựng lại đường đi của từng trường hợp trong quy trình, đồng thời cần thiết cho việc phân tích biến thể và tính thời gian xử lý. Vì sao điều này quan trọng Định danh duy nhất là nền tảng của process mining, giúp kết nối các sự kiện rời rạc thành cái nhìn thống nhất về quy trình. Lấy dữ liệu ở đâu Trường 20 (TRN) hoặc Trường 121 (UETR) của SWIFT trong tiêu đề thông điệp. Ví dụ TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	Tên hoạt động ActivityName	Tên của bước hoặc sự kiện đã xảy ra trong quy trình.
Mô tả Thuộc tính này mô tả hành động cụ thể hoặc thay đổi trạng thái được ghi lại trong nhật ký hệ thống. Ví dụ: 'Đã tạo yêu cầu thanh toán', 'Đã qua sàng lọc lệnh trừng phạt' hoặc 'Đã nhận ACK từ SWIFT'. Đây là chiều dữ liệu chính của sơ đồ quy trình, xác định các nút trên hình trực quan và giúp chuyên viên phân tích hiểu trình tự hoạt động của một khoản thanh toán. Vì sao điều này quan trọng Thuộc tính này cho biết quy trình đã làm gì, giúp trực quan hóa luồng quy trình và các biến thể. Lấy dữ liệu ở đâu Nhật ký giao dịch, dấu vết kiểm toán hoặc dữ liệu suy ra từ loại thông điệp, chẳng hạn MT103 Sent. Ví dụ Tạo yêu cầu thanh toánĐã gửi chỉ thị thanh toánĐã nhận ACK từ SWIFTĐã phê duyệt thanh toán
	BIC ngân hàng thụ hưởng BeneficiaryBic	Mã định danh ngân hàng của tổ chức nhận.
Mô tả Xác định ngân hàng nhận khoản thanh toán. Đây là chiều phân tích quan trọng trong bảng điều khiển “Nguyên nhân gốc rễ khiến ngân hàng thụ hưởng từ chối”. Khi nhóm các trường hợp thất bại theo BIC ngân hàng thụ hưởng, ngân hàng có thể xác định những đối tác thường từ chối chỉ thị do vấn đề về chất lượng dữ liệu hoặc yêu cầu định dạng riêng. Vì sao điều này quan trọng Cần thiết để phân tích hiệu suất của đối tác và các kiểu từ chối. Lấy dữ liệu ở đâu Trường 57A (Account With Institution) hoặc 58A (Beneficiary Institution) của SWIFT. Ví dụ CITIUS33BARCGB22DRESDEFFHANDSEXX
	Loại thông điệp SWIFT SwiftMessageType	Loại thông điệp SWIFT được sử dụng (ví dụ: MT103, pacs.008).
Mô tả Cho biết định dạng cụ thể của chỉ thị thanh toán. Các loại phổ biến gồm MT103 cho giao dịch chuyển tiền của khách hàng và định dạng tương đương theo ISO 20022 như pacs.008. Dùng trong “Phân tích biến thể hành trình thanh toán” để so sánh hiệu quả xử lý giữa định dạng MT cũ và tiêu chuẩn ISO mới. Vì sao điều này quan trọng Phân biệt luồng thanh toán và tiêu chuẩn xử lý (định dạng cũ và ISO 20022). Lấy dữ liệu ở đâu Khối 2 của SWIFT (tiêu đề ứng dụng), trường loại thông điệp. Ví dụ MT103MT202pacs.008MT101
	Loại tiền tệ giao dịch TransactionCurrency	Mã ISO gồm 3 chữ cái cho biết loại tiền tệ của khoản thanh toán.
Mô tả Cho biết khoản thanh toán được ghi bằng loại tiền tệ nào (ví dụ: USD, EUR, GBP). Thông tin này rất quan trọng với bảng điều khiển “Hiệu suất theo giờ chốt của mạng lưới”, vì giờ chốt khác nhau tùy loại tiền tệ. Thông tin này cũng hỗ trợ phân tích “Hiệu quả chuyển đổi tiền tệ” bằng cách xác định các cặp tiền tệ khác nhau. Vì sao điều này quan trọng Xác định quy tắc định tuyến, giờ chốt và hành lang thanh toán. Lấy dữ liệu ở đâu Trường 32A (Currency) của SWIFT MT hoặc phần tử Ccy trong ISO 20022. Ví dụ USDEURGBPJPY
	Mã NAK của SWIFT SwiftNakCode	Mã lỗi do mạng lưới SWIFT trả về khi từ chối thông điệp.
Mô tả Chứa mã lỗi cụ thể (ví dụ: T26, T13) trong thông báo từ chối (NAK) do mạng lưới SWIFT gửi. Thuộc tính này cung cấp dữ liệu cho bảng điều khiển “Phân tích lỗi và xử lý lại SWIFT”, giúp phân loại lỗi kỹ thuật để ưu tiên khắc phục hệ thống. Vì sao điều này quan trọng Cho biết nguyên nhân kỹ thuật khiến mạng lưới từ chối giao dịch. Lấy dữ liệu ở đâu Thông điệp hệ thống MT 015/019 hoặc Trường 451 trong ACK/NAK. Ví dụ T26H01T13G02
	Ngày giá trị ValueDate	Ngày tiền được chuyển vào tài khoản của người thụ hưởng.
Mô tả Ngày thanh toán được chỉ định trong thông điệp thanh toán. So sánh ngày này với dấu thời gian thực tế của hoạt động “Đã thanh toán” giúp theo dõi trong bảng điều khiển “Thời gian chờ thanh toán và đối soát”. Ngày này cho biết mức độ khẩn cấp của khoản thanh toán và được dùng để đo lường việc đáp ứng các thỏa thuận mức dịch vụ về thời điểm tiền khả dụng. Vì sao điều này quan trọng Rất quan trọng để quản lý thanh khoản và đo lường thời gian thanh toán. Lấy dữ liệu ở đâu Trường 32A (phần ngày) của SWIFT MT hoặc IntrBkSttlmDt trong ISO 20022. Ví dụ 2023-10-262023-11-01
	Người dùng xử lý ProcessingUser	Người dùng hoặc tác nhân hệ thống thực hiện hoạt động.
Mô tả Xác định cá nhân hoặc bot tự động chịu trách nhiệm thực hiện hoạt động, chẳng hạn như nhân viên tuân thủ phê duyệt cảnh báo trùng khớp với danh sách trừng phạt hoặc nhân viên vận hành sửa lỗi định dạng. Thuộc tính này cung cấp dữ liệu cho “Bản đồ nhiệt lỗi xác thực”, giúp quản lý xác định nhu cầu đào tạo hoặc người dùng thường phải làm lại nhiều. Vì sao điều này quan trọng Hỗ trợ phân tích tài nguyên và xác định điểm nghẽn do thao tác thủ công. Lấy dữ liệu ở đâu Nhật ký kiểm tra hệ thống, cột “User ID” trong bảng giao dịch. Ví dụ SYSTEMJ.DoeCompliance_Bot_01M.Smith
	Số tiền giao dịch TransactionAmount	Giá trị tiền tệ của chỉ thị thanh toán.
Mô tả Cho biết số tiền gốc được chuyển. Dữ liệu này được trích xuất từ các trường SWIFT cụ thể, chẳng hạn Trường 32A trong MT103. Đây là dữ liệu cần thiết cho dashboard 'Chu kỳ phê duyệt giao dịch giá trị cao', giúp phân nhóm thanh toán theo số tiền để phân tích chậm trễ phê duyệt đối với giao dịch giá trị cao, rủi ro cao. Vì sao điều này quan trọng Cho phép phân tích tác động tài chính và phân nhóm theo giá trị giao dịch. Lấy dữ liệu ở đâu Trường 32A (Amount) của SWIFT MT hoặc phần tử IntrBkSttlmAmt trong ISO 20022. Ví dụ 15000.001250.501000000.0045.00
	UETR UniqueEndToEndReference	Mã tham chiếu giao dịch duy nhất từ đầu đến cuối, dùng để theo dõi trong SWIFT gpi.
Mô tả UETR là chuỗi gồm 36 ký tự, cung cấp một mã tham chiếu duy nhất, không thay đổi cho khoản thanh toán trên toàn mạng lưới SWIFT. Khác với mã ID nội bộ, UETR được giữ nguyên qua các ngân hàng. Thuộc tính này rất cần thiết để theo dõi toàn bộ hành trình thanh toán và đối chiếu nhật ký nội bộ với các cập nhật trạng thái bên ngoài từ SWIFT gpi. Vì sao điều này quan trọng Tiêu chuẩn hàng đầu để theo dõi thanh toán xuyên biên giới giữa các tổ chức. Lấy dữ liệu ở đâu Khối 3 của SWIFT, Trường 121. Ví dụ b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Xử lý STP IsStp	Cờ cho biết khoản thanh toán có cần can thiệp thủ công hay không.
Mô tả Chỉ báo dạng boolean có giá trị True nếu trường hợp không có hoạt động “Đã xác định lỗi”, “Đã từ chối thanh toán” hoặc “Sửa đổi” thủ công. Chỉ báo này trực tiếp tính KPI “Tỷ lệ xử lý tự động xuyên suốt”. Đây là chỉ số chính để đánh giá hiệu quả tự động hóa trong xử lý thanh toán. Vì sao điều này quan trọng Thước đo chính về hiệu quả quy trình và tình trạng tự động hóa. Lấy dữ liệu ở đâu Được tính dựa trên việc không có các hoạt động thủ công hoặc hoạt động cho kết quả không đạt cụ thể trong trường hợp. Ví dụ truefalse
	Có xuyên biên giới IsCrossBorder	Cờ cho biết khoản thanh toán có liên quan đến nhiều quốc gia hay không.
Mô tả Thuộc tính dạng boolean có giá trị True nếu quốc gia của bên gửi khác quốc gia của người thụ hưởng. Thuộc tính này hỗ trợ KPI “Độ trễ xử lý đa tiền tệ” bằng cách tách luồng thanh toán trong nước và quốc tế. Thanh toán xuyên biên giới thường phức tạp hơn, tốn kém hơn và mất nhiều thời gian xử lý hơn. Vì sao điều này quan trọng Cơ sở để phân nhóm và phân tích mức độ phức tạp của khoản thanh toán. Lấy dữ liệu ở đâu So sánh mã quốc gia trong BIC của bên gửi với mã quốc gia trong BIC của người thụ hưởng. Ví dụ truefalse
	Đáp ứng giờ chốt MetCutOffTime	Cờ cho biết chỉ thị có được gửi trước hạn chót của mạng lưới hay không.
Mô tả Cờ dạng boolean, được tính bằng cách so sánh thời điểm “Đã gửi chỉ thị thanh toán” với giờ chốt của mạng lưới SWIFT theo từng loại tiền tệ. Thuộc tính này hỗ trợ KPI “Tỷ lệ đáp ứng giờ chốt SWIFT”. Không kịp giờ chốt sẽ làm chậm thanh toán và ảnh hưởng đến vị thế thanh khoản. Vì sao điều này quan trọng KPI vận hành quan trọng đối với quản lý ngân quỹ và thanh khoản. Lấy dữ liệu ở đâu Được tính bằng cách so sánh dấu thời gian với bảng tham chiếu tĩnh về giờ chốt. Ví dụ truefalse
	Lý do từ chối RejectionReason	Mô tả bằng văn bản lý do khoản thanh toán bị từ chối.
Mô tả Chứa nội dung mô tả hoặc mã lý do khi khoản thanh toán thất bại, thường nằm trong Trường 72 của SWIFT (Thông tin từ bên gửi đến bên nhận) hoặc thông điệp hoàn trả. Thông tin này hỗ trợ phân tích “Nguyên nhân gốc rễ khiến ngân hàng thụ hưởng từ chối”. Chuyên viên phân tích có thể khai thác văn bản để tìm các nguyên nhân từ chối phổ biến (ví dụ: “Tài khoản không hợp lệ”, “Tên người thụ hưởng không khớp”). Vì sao điều này quan trọng Bổ sung thông tin định tính về các trường hợp quy trình thất bại. Lấy dữ liệu ở đâu Trường 72 hoặc 79 của SWIFT trong thông điệp hoàn trả (MT103 Return). Ví dụ Tài khoản người thụ hưởng đã đóngIBAN không hợp lệKhông đáp ứng yêu cầu tuân thủ quy địnhKhông xác định được ngân hàng
	Mức ưu tiên của chỉ thị InstructionPriority	Cờ ưu tiên cho biết mức độ khẩn cấp của khoản thanh toán.
Mô tả Lấy từ tiêu đề thông điệp (ví dụ: “Thông thường” hoặc “Khẩn”). Thông tin này cho phép phân nhóm trong bảng điều khiển “Chu kỳ phê duyệt chuyển khoản giá trị cao”, vì khoản thanh toán khẩn thường cần quy trình phê duyệt nhanh hơn. Nắm được phân bố mức ưu tiên giúp bạn lập kế hoạch tài nguyên vào giờ cao điểm. Vì sao điều này quan trọng Giúp phân biệt yêu cầu SLA giữa khoản thanh toán thông thường và khoản cần xử lý nhanh. Lấy dữ liệu ở đâu Khối 2 của SWIFT, trường mức ưu tiên thông điệp (ví dụ: N là Thông thường, U là Khẩn). Ví dụ Thông thườngKhẩnHệ thống
	Quốc gia khởi tạo OriginatingCountry	Mã quốc gia của đơn vị khởi tạo khoản thanh toán.
Mô tả Cho biết khu vực pháp lý nơi yêu cầu thanh toán được khởi tạo. Thông tin này rất quan trọng với bảng điều khiển “Thời gian sàng lọc trừng phạt”, vì khoản thanh toán từ khu vực có rủi ro cao thường phải qua bước kiểm tra tuân thủ kỹ hơn và lâu hơn. Thông tin này cho phép phân tích khối lượng thanh toán và thời gian xử lý theo khu vực địa lý. Vì sao điều này quan trọng Chiều phân tích quan trọng để đánh giá rủi ro tuân thủ và hiệu suất theo khu vực. Lấy dữ liệu ở đâu Lấy từ BIC của bên gửi (ký tự 5-6 là mã quốc gia). Ví dụ USGBDEFR

Bắt buộc Nên có Không bắt buộc

Các hoạt động xử lý thanh toán

Đây là những bước và mốc chính cần ghi lại trong nhật ký sự kiện để khám phá quy trình chính xác và xác định điểm nghẽn.

6 Nên có 6 Không bắt buộc

	Hoạt động	Mô tả
	Đã đối soát thanh toán	Đối chiếu giao dịch thanh toán với sao kê sổ cái tài khoản Nostro/Vostro. Có thể suy ra khi hệ thống đối soát liên kết mã giao dịch với một dòng trong sao kê.
Vì sao điều này quan trọng Khép lại quy trình tài chính. Chậm trễ ở bước này ảnh hưởng đến khả năng theo dõi tiền mặt và kiểm toán. Lấy dữ liệu ở đâu Nhật ký hệ thống đối soát hoặc trạng thái 'Matched' trong Hệ thống ngân hàng lõi. Thu thập So sánh trạng thái đối soát Loại sự kiện inferred
	Đã gửi chỉ thị thanh toán	Gửi tin nhắn đã định dạng (MT103 hoặc ISO 20022 pacs.008) đến SWIFT Gateway. Ghi nhận rõ ràng khi nội dung tin nhắn được tạo và chuyển sang giao diện mạng.
Vì sao điều này quan trọng Dùng để tính 'Tỷ lệ đáp ứng thời hạn chốt giao dịch SWIFT'. Đánh dấu thời điểm chuyển từ xử lý nội bộ sang xử lý qua mạng lưới. Lấy dữ liệu ở đâu Nhật ký SWIFT Alliance Access (SAA) hoặc nhật ký truyền của Gateway. Thu thập Ghi nhận khi thông điệp được gửi đi Loại sự kiện explicit
	Đã phê duyệt thanh toán	Bước phê duyệt cuối cùng do người có thẩm quyền hoặc quy tắc tự động thực hiện đối với giao dịch giá trị cao. Sự kiện này được ghi nhận rõ khi cờ của quy trình phê duyệt được đặt thành true.
Vì sao điều này quan trọng Chỉ số quan trọng cho dashboard 'Chu kỳ phê duyệt giao dịch giá trị cao'. Giúp xác định chậm trễ khi ký duyệt thủ công các khoản tiền lớn. Lấy dữ liệu ở đâu Dấu vết kiểm toán của công cụ quy trình phê duyệt. Thu thập Ghi nhận khi thực hiện thao tác phê duyệt Loại sự kiện explicit
	Đã qua sàng lọc lệnh trừng phạt	Dấu thời gian ghi nhận khi chỉ thị thanh toán vượt qua quy trình sàng lọc danh sách OFAC/lệnh trừng phạt. Dữ liệu được lấy trực tiếp từ nhật ký hệ thống tuân thủ hoặc suy ra khi trạng thái 'Screening Hold' được gỡ.
Vì sao điều này quan trọng Cần thiết cho dashboard 'Thời gian xử lý sàng lọc lệnh trừng phạt'. Chậm trễ ở đây là điểm nghẽn tuân thủ, không phải vấn đề hiệu quả vận hành. Lấy dữ liệu ở đâu Nhật ký hệ thống lọc tuân thủ hoặc cờ trạng thái tuân thủ trong Payment Hub. Thu thập Ghi nhận khi trạng thái sàng lọc được cập nhật Loại sự kiện explicit
	Đã quyết toán thanh toán	Xác nhận tiền đã được ghi có vào tài khoản người thụ hưởng, thường là trạng thái gpi ACSC. Sự kiện này được ghi nhận trực tiếp qua cập nhật từ tracker hoặc thông điệp xác nhận.
Vì sao điều này quan trọng Đánh dấu giao dịch đã hoàn tất về mặt nghiệp vụ. Là dữ liệu quan trọng để tính 'Khoảng cách từ quyết toán đến đối soát'. Lấy dữ liệu ở đâu SWIFT gpi Tracker (trạng thái ACSC) hoặc xác nhận MT900/910. Thu thập Ghi nhận khi xác nhận quyết toán Loại sự kiện explicit
	Tạo yêu cầu thanh toán	Bước tạo chỉ thị thanh toán ban đầu trong hệ thống ngân hàng nội bộ hoặc ERP. Sự kiện này được ghi nhận rõ khi mã tham chiếu giao dịch duy nhất (TRN hoặc UETR) được gán lần đầu cho lệnh thanh toán.
Vì sao điều này quan trọng Xác định thời điểm bắt đầu của toàn bộ vòng đời thanh toán. Đây là dữ liệu cần thiết để tính thời gian xử lý từ đầu đến cuối và tìm ra chậm trễ ở các bước trước khi giao dịch vào mạng SWIFT. Lấy dữ liệu ở đâu Dấu thời gian tạo bản ghi giao dịch trong Hệ thống ngân hàng lõi (CBS) hoặc Payment Hub. Thu thập Ghi nhận khi tạo bản ghi giao dịch Loại sự kiện explicit
	Đã chuyển khoản thanh toán	Cập nhật trạng thái trung gian, thường là trạng thái gpi ACSP, cho biết ngân hàng trung gian đang xử lý khoản thanh toán. Dữ liệu được lấy từ cập nhật của SWIFT gpi Tracker hoặc thông điệp trạng thái.
Vì sao điều này quan trọng Giúp theo dõi quá trình xử lý vốn khó quan sát trong hệ thống ngân hàng đại lý. Cần thiết để phân tích toàn bộ hành trình từ đầu đến cuối. Lấy dữ liệu ở đâu Luồng dữ liệu SWIFT gpi Tracker hoặc thông điệp MT199/trck. Thu thập Ghi nhận khi nhận cập nhật từ tracker Loại sự kiện explicit
	Đã kiểm tra thông tin thanh toán	Hoàn tất kiểm tra cú pháp và định dạng của chỉ thị thanh toán, chẳng hạn định dạng IBAN và tính hợp lệ của BIC. Sự kiện này thường được suy ra khi trạng thái giao dịch chuyển từ 'Draft' sang 'Validated' hoặc 'Ready for Auth'.
Vì sao điều này quan trọng Tỷ lệ thất bại cao ở bước này cho thấy chất lượng dữ liệu đầu vào kém. Dùng để đo KPI 'Tỷ lệ đạt ngay lần kiểm tra đầu tiên'. Lấy dữ liệu ở đâu Nhật ký trạng thái Payment Engine hoặc bảng lịch sử kiểm tra dữ liệu. Thu thập So sánh trường trạng thái trước và sau Loại sự kiện inferred
	Đã nhận ACK từ SWIFT	Nhận xác nhận kỹ thuật (ACK) từ mạng SWIFT, cho biết thông điệp đã được chấp nhận để xử lý. Sự kiện này được ghi nhận trực tiếp từ nhật ký giao diện mạng.
Vì sao điều này quan trọng Xác nhận thông điệp đã vào mạng lưới toàn cầu. Giúp phân biệt lỗi nội bộ với sự cố trong quá trình truyền qua mạng. Lấy dữ liệu ở đâu Nhật ký SWIFT Gateway, kiểm tra tín hiệu ACK và NACK. Thu thập Ghi nhận khi nhận ACK từ mạng Loại sự kiện explicit
	Đã phát hiện lỗi thanh toán	Sự kiện giao dịch bị đánh dấu cần sửa do không đạt kiểm tra dữ liệu, nhận NACK hoặc bị từ chối. Có thể suy ra khi giao dịch vào hàng đợi 'Repair', 'Correction' hoặc 'Exception'.
Vì sao điều này quan trọng Theo dõi 'Tỷ lệ xử lý lại để khắc phục lỗi'. Tần suất cao ở bước này làm giảm tỷ lệ xử lý thẳng (STP). Lấy dữ liệu ở đâu Các cột trạng thái trong Payment Hub hoặc nhật ký hàng đợi ngoại lệ. Thu thập So sánh trường trạng thái với Error/Repair Loại sự kiện inferred
	Đã xử lý xong lỗi thanh toán	Giao dịch từng bị lỗi đã được sửa và gửi lại thành công. Có thể suy ra khi giao dịch chuyển từ hàng đợi 'Repair' về trạng thái 'Processing' hoặc 'Ready'.
Vì sao điều này quan trọng Đo hiệu quả của nhóm xử lý lại thủ công. Thời lượng dài ở bước này có thể cho thấy nhân viên cần được đào tạo thêm hoặc mã lỗi quá phức tạp. Lấy dữ liệu ở đâu Nhật ký trạng thái Payment Hub cho thấy giao dịch đã rời hàng đợi ngoại lệ. Thu thập So sánh trường trạng thái khi rời Repair Loại sự kiện inferred
	Thanh toán bị từ chối	Nhận thông điệp từ chối (MT103 Return hoặc trạng thái gpi RJCT) từ ngân hàng thụ hưởng hoặc ngân hàng trung gian. Sự kiện này được ghi nhận trực tiếp từ thông điệp SWIFT đến.
Vì sao điều này quan trọng Chỉ số quan trọng cho dashboard 'Nguyên nhân gốc rễ khiến ngân hàng thụ hưởng từ chối'. Giúp xác định trở ngại bên ngoài như tài khoản đã đóng hoặc thông tin định tuyến sai. Lấy dữ liệu ở đâu Thông điệp SWIFT đến (MT103 RET, pacs.004) hoặc trạng thái gpi RJCT. Thu thập Ghi nhận khi nhận thông điệp từ chối Loại sự kiện explicit

Nên có Không bắt buộc

Hướng dẫn trích xuất dữ liệu

Cách lấy dữ liệu từ SWIFT

Các bước

Đăng nhập SWIFT Alliance WebPlatform hoặc giao diện Alliance Access bằng tài khoản quản trị viên có quyền truy cập cấu hình lưu trữ.
Mở menu System Management, chọn Archiving, rồi chọn Automated Archiving Configuration.
Tạo hồ sơ xuất dữ liệu hằng ngày. Đặt Target Directory thành đường dẫn mạng an toàn mà các tập lệnh trích xuất có thể truy cập.
Chỉ định phạm vi nội dung: chọn 'Messages' và đánh dấu 'Include History' cùng 'Include Interventions'. Bước này rất quan trọng để ghi lại các sự kiện kiểm toán như phê duyệt và xác thực.
Chọn định dạng đầu ra. Chọn XML, cụ thể là 'SAA XML v2' hoặc lược đồ mới nhất hiện có. XML giữ được mối liên hệ phân cấp giữa tiêu đề thông điệp và các sự kiện lịch sử tốt hơn CSV.
Đặt bộ lọc khoảng ngày để trích xuất giai đoạn lịch sử cần cho sáng kiến process mining, hoặc lên lịch chạy hằng ngày để lấy dữ liệu T-1.
Chạy thủ công tác vụ xuất dữ liệu lưu trữ cho lần tải đầu tiên, hoặc chờ tác vụ theo lịch hoàn tất. Kiểm tra xem các tệp .xml đã được tạo trong thư mục đích chưa.
Vì dữ liệu xuất từ SAA là tệp XML phân cấp, còn ProcessMind cần nhật ký sự kiện CSV phẳng, bạn phải chạy tập lệnh chuyển đổi. Dùng tập lệnh Python trong phần Truy vấn để phân tích XML.
Tập lệnh duyệt từng phần tử thông điệp. Tập lệnh trích xuất Mã tham chiếu giao dịch xuyên suốt duy nhất (UETR) hoặc Số tham chiếu giao dịch (TRN) để làm Case ID.
Tập lệnh tiếp tục duyệt các nút con 'History' và 'Intervention' của từng thông điệp để tạo các dòng hoạt động. Tập lệnh ánh xạ mã trạng thái nội bộ của SAA, chẳng hạn 'NetworkAck' và 'Authorisation', sang tên hoạt động chuẩn hóa.
Chạy tập lệnh Python trên các tệp XML đã xuất để tạo tệp 'events.csv' phẳng.
Kiểm tra dữ liệu CSV, bảo đảm các cột như EventTimestamp dùng định dạng ISO 8601, rồi tải tệp lên ProcessMind.

Cấu hình

Định dạng lưu trữ: XML (nên dùng) hoặc CSV (tệp phẳng). Nên dùng XML để ghi lại các nút lịch sử lồng nhau.
Bao gồm nội dung thông điệp: Có (cần thiết để phân tích số tiền, tiền tệ và thông tin người thụ hưởng).
Bao gồm lịch sử/can thiệp: Có (bắt buộc để xem phê duyệt, xác thực và lỗi).
Khoảng ngày: Chọn khoảng thời gian cuốn chiếu, chẳng hạn 30 ngày gần nhất, cho các lần tải bổ sung; hoặc chọn ngày cố định để tải dữ liệu lịch sử ban đầu.
Loại thông điệp: Lọc MT103, MT202, pacs.008, pacs.009 và pacs.004/002 (để ghi nhận giao dịch trả lại/trạng thái).
Chiều thông điệp: Bao gồm cả chiều vào (gửi đi) và chiều ra (nhận về) để ghi nhận thông báo từ chối hoặc xác nhận đến.
Bảo mật: Đảm bảo thư mục xuất có quyền đọc/ghi nghiêm ngặt vì các tệp này chứa dữ liệu thanh toán đang hoạt động.

Truy vấn mẫu 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}")

Các bước

Chuẩn bị môi trường: Đảm bảo Python 3.8 trở lên đã được cài trên máy chủ trích xuất. Cài các thư viện cần thiết bằng pip (pandas, numpy). Tạo thư mục làm việc riêng, bên trong có thư mục con raw_swift_files, rồi đặt tất cả tệp .out, .txt hoặc .fin hằng ngày vào đó.
Tìm hiểu cấu trúc tệp: Thông điệp SWIFT FIN thô được chia thành các khối ({1: Header} {2: Application} {4: Body}). Xác định ký tự phân tách. Tệp chuẩn dùng dấu ngoặc nhọn. Đảm bảo tệp không nằm trong lớp bao riêng của nhà cung cấp (như tiêu đề RJE), hoặc gỡ lớp bao đó trước khi xử lý.
Cấu hình đường dẫn trong tập lệnh: Mở tập lệnh Python được cung cấp. Cập nhật biến INPUT_DIRECTORY để trỏ đến thư mục raw_swift_files. Cập nhật đường dẫn OUTPUT_FILE cho tệp CSV đầu ra.
Định nghĩa mẫu Regex: Tập lệnh dùng regex để tách các khối. Khối 1 chứa BIC của bên gửi và số thứ tự. Khối 2 chứa loại thông điệp (ví dụ: I103, O103) và BIC của bên nhận. Khối 4 chứa các thẻ dữ liệu nghiệp vụ (ví dụ: :20: TRN, :32A: Giá trị/Số tiền).
Ánh xạ loại thông điệp sang hoạt động: Tập lệnh có từ điển ánh xạ. MT103 tương ứng với 'Payment Instruction Sent'. MT012 (System ACK) tương ứng với 'SWIFT ACK Received'. MT900/910 tương ứng với 'Payment Settled'. MT199/299 cùng mã trạng thái cụ thể (ACSP, RJCT) được ánh xạ thành 'Payment Transferred' hoặc 'Payment Rejected'.
Trích xuất thuộc tính: Bộ phân tích duyệt qua các thẻ cụ thể. :20: được ánh xạ thành Payment Transaction ID. :121: được ánh xạ thành UETR. :32A: được phân tích thành Ngày, Tiền tệ và Số tiền.
Xử lý trạng thái nội bộ: Với các hoạt động như 'Payment Request Created' hoặc 'Payment Approved', thường là sự kiện nội bộ trong ERP và không có trong tệp SWIFT, tập lệnh sẽ suy ra sự kiện từ Message Creation Timestamp trong Khối 1 nếu không có nhật ký rõ ràng. Ngoài ra, tập lệnh có thể tìm mã văn bản cụ thể trong trường :72: (Sender to Receiver Info) nếu tổ chức của bạn ghi nhận phê duyệt tại đó.
Chạy trích xuất: Chạy tập lệnh từ dòng lệnh: python swift_parser.py. Tập lệnh duyệt qua tất cả tệp, phân tích các khối SWIFT hợp lệ và bỏ qua những dòng sai định dạng.
Kiểm tra sau khi xử lý: Mở tệp CSV được tạo. Kiểm tra định dạng EventTimestamp (nên dùng ISO 8601). Đảm bảo mọi hàng đều có PaymentTransactionId để nhóm theo trường hợp.
Chuyển đổi dữ liệu: Nếu 'ValueDate' có định dạng YYMMDD, tập lệnh sẽ chuyển thành YYYY-MM-DD. Đảm bảo dấu thập phân trong 'TransactionAmount' được thống nhất (dấu chấm hoặc dấu phẩy).
Kiểm tra lần cuối: Lọc theo một UETR cụ thể để xem luồng từ đầu đến cuối, từ Instruction Sent -> ACK -> Settlement. Xác minh NAK (MT019) xuất hiện dưới dạng 'Payment Error Identified'.
Tải lên ProcessMind: Nhập tệp CSV. Ánh xạ PaymentTransactionId thành Case ID, ActivityName thành Hoạt động và EventTimestamp thành dấu thời gian.

Cấu hình

Thư mục đầu vào: Đường dẫn đến thư mục chứa các tệp phẳng FIN/MT thô. Đảm bảo đã cấp quyền đọc.
Phân tích định dạng ngày: Ngày trong dữ liệu SWIFT thô có định dạng YYMMDD. Tập lệnh xử lý giả định thế kỷ (20xx).
Bộ lọc loại thông điệp: Tập lệnh tập trung vào nhóm 1 (thanh toán), nhóm 9 (sao kê) và các thông điệp hệ thống phổ biến (012, 019). Cập nhật danh sách RELEVANT_MT_TYPES nếu cần nhóm 2 (chuyển tiền giữa các tổ chức tài chính).
Mã hóa: Mặc định là 'utf-8'. Đổi thành 'latin-1' hoặc 'ascii' nếu tệp có ký tự dùng bảng mã cũ.
Xử lý theo lô: Với tập dữ liệu lớn hơn 1GB, tập lệnh dùng cách xử lý bằng generator để tránh tràn bộ nhớ, lần lượt xử lý từng tệp.
Điều chỉnh regex: Regex nghiêm ngặt giả định định dạng FIN chuẩn {1:...}{2:...}{4:...}. Nếu tệp dùng $ hoặc dấu phân cách khác, hãy cập nhật biến BLOCK_PATTERN.

Truy vấn mẫu 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()

Các bước

Xác nhận bạn có gói đăng ký API SWIFT gpi Tracker, thông tin xác thực API, khả năng tìm kiếm UETR và quyền truy cập nguồn sự kiện của hệ thống thanh toán nội bộ. Lấy URL cơ sở API chính xác, phương thức xác thực, lược đồ phản hồi, giới hạn tần suất và quy tắc phân trang từ tài liệu dịch vụ SWIFT. Không tự giả định đường dẫn endpoint vì đường dẫn này phụ thuộc vào dịch vụ SWIFT được cấp phép và cách triển khai.
Cấu hình tập lệnh với chuỗi kết nối, thông tin xác thực, khoảng ngày và bộ lọc riêng của công ty. Với lần trích xuất đầu tiên, chọn khoảng thời gian từ ba đến sáu tháng. Chỉ lấy giao dịch thanh toán từ nguồn nội bộ có TRN hoặc UETR, đồng thời lưu tên hệ thống nguồn cho từng sự kiện.
Trích xuất các sự kiện vòng đời nội bộ gồm Đã tạo yêu cầu thanh toán, Đã xác thực chi tiết thanh toán, Đã qua kiểm tra danh sách trừng phạt, Đã phê duyệt thanh toán, Đã gửi chỉ thị thanh toán, Đã nhận xác nhận SWIFT, Đã phát hiện lỗi thanh toán, Đã xử lý lỗi thanh toán, Đã từ chối thanh toán, Đã thanh toán và Đã đối soát thanh toán. Chuyển từng sự kiện nguồn thành một dòng riêng trong nhật ký sự kiện. Không dựa vào ProcessMind để tự suy ra hoạt động.
Trích xuất UETR từ hồ sơ thanh toán nội bộ, rồi dùng API SWIFT gpi Tracker được cấp phép để truy vấn từng UETR. Dựa vào tài liệu API dành cho môi trường của bạn để cấu hình URL yêu cầu, tiêu đề xác thực, tham số yêu cầu, phân trang và trường phản hồi. Lưu phản hồi thô để phục vụ kiểm toán.
Chuyển các trạng thái gpi phù hợp thành dòng sự kiện cụ thể. Tập lệnh ánh xạ ACSP thành Đã chuyển tiền, RJCT thành Đã từ chối thanh toán và ACSC thành Đã thanh toán. Nếu phản hồi được cấp phép dùng tên trạng thái hoặc dấu thời gian khác, hãy cập nhật ánh xạ theo lược đồ phản hồi đã được tài liệu hóa. Không tạo sự kiện nếu API không cung cấp lần phát sinh trạng thái tương ứng.
Chuẩn hóa mọi dấu thời gian theo cùng một múi giờ, ưu tiên UTC, đồng thời giữ dấu thời gian gốc nếu cần cho mục đích kiểm toán. Chuyển giá trị tiền tệ thành số, giữ nguyên đơn vị tiền tệ giao dịch, chuẩn hóa giá trị STP dạng Boolean và giữ NULL nếu nguồn không có thuộc tính đó.
Loại sự kiện trùng lặp dựa trên PaymentTransactionId, ActivityName, EventTimestamp và mã định danh sự kiện nguồn cụ thể nhất hiện có. Giữ lại các lần phát sinh hợp lệ, chẳng hạn nhiều chu kỳ sửa lỗi và gửi lại, trừ khi quy tắc nghiệp vụ yêu cầu rõ mỗi hoạt động chỉ có một lần.
Kiểm tra để bảo đảm mỗi dòng đầu ra có PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem và LastDataUpdate. Xác nhận ActivityName chỉ chứa các giá trị hoạt động đã được tài liệu hóa và cả 12 hoạt động đều có mặt nếu dữ liệu nguồn ghi nhận.
Xuất tập dữ liệu thành CSV mã hóa UTF-8 hoặc định dạng nhật ký sự kiện khác được ProcessMind hỗ trợ. Mỗi dòng tương ứng với một sự kiện; thêm các cột bắt buộc và nên có, rồi ánh xạ PaymentTransactionId làm mã định danh trường hợp, ActivityName làm hoạt động và EventTimestamp làm dấu thời gian sự kiện. Tải tệp lên ProcessMind, không kỳ vọng hệ thống tự suy ra thêm sự kiện.

Cấu hình

Endpoint và lược đồ API: Cấu hình chính xác URL cơ sở SWIFT gpi Tracker API, đường dẫn tài nguyên, tham số yêu cầu, tiêu đề xác thực, phân trang và tên trường phản hồi theo tài liệu SWIFT được cấp phép cho môi trường của bạn. Tập lệnh không tự tạo endpoint.
Thông tin xác thực và quyền truy cập: Dùng cơ chế thông tin xác thực API SWIFT đã được phê duyệt, các yêu cầu về chứng chỉ hoặc token, phương thức lưu bí mật và quyền truy cập hệ thống nguồn nội bộ. Không ghi trực tiếp bí mật môi trường sản xuất vào mã nguồn.
Khoảng ngày: Bắt đầu với ba đến sáu tháng. Dùng dấu thời gian sự kiện hoặc ngày tạo thanh toán tùy mục tiêu báo cáo. Với khối lượng lớn, chia thành các khoảng nhỏ hơn và lưu mốc hoàn tất UETR.
Bộ lọc nguồn nội bộ: Cấu hình bộ lọc công ty, pháp nhân, chi nhánh, sản phẩm thanh toán, loại chứng từ, loại thông điệp, tiền tệ và trạng thái theo hệ thống của bạn. Dùng giá trị giữ chỗ như [Cấu hình theo hệ thống của bạn] cho đến khi xác nhận lược đồ nguồn.
Ánh xạ hoạt động: Duy trì ánh xạ rõ ràng cho trạng thái và hàng đợi nội bộ. Ví dụ: Draft thành Validated hoặc Ready for Auth cho hoạt động Đã xác thực chi tiết thanh toán; gỡ trạng thái Screening Hold cho hoạt động Đã qua kiểm tra danh sách trừng phạt; đưa vào hàng đợi Repair hoặc Exception cho hoạt động Đã phát hiện lỗi thanh toán; chuyển về Processing hoặc Ready for Payment cho hoạt động Đã xử lý lỗi thanh toán.
Ánh xạ trạng thái gpi: Ánh xạ trạng thái tracker đã được tài liệu hóa thành hoạt động cụ thể. Cách triển khai này ánh xạ ACSP thành Đã chuyển tiền, RJCT thành Đã từ chối thanh toán và ACSC thành Đã thanh toán. Chỉ mở rộng ánh xạ khi tài liệu API được cấp phép xác nhận ý nghĩa của trạng thái.
Quy tắc dấu thời gian: Nếu có thể, chuẩn hóa dấu thời gian về UTC. Xác định thứ tự ưu tiên giữa thời điểm sự kiện nguồn, thời điểm sự kiện tracker, thời điểm nhận thông điệp và thời điểm trích xuất. LastDataUpdate phải thể hiện thời điểm trích xuất hoặc làm mới dữ liệu, không phải thời điểm diễn ra sự kiện nghiệp vụ.
Giới hạn tần suất và thử lại: Cấu hình thời gian chờ yêu cầu, số lần thử lại, thời gian chờ lũy tiến, cách xử lý trạng thái HTTP và phân trang. Tuân thủ giới hạn dịch vụ SWIFT, tránh gửi yêu cầu song song không kiểm soát.
Hiệu năng: Lưu bộ nhớ đệm phản hồi theo UETR, xử lý UETR theo lô, lưu mốc tiến độ và trích xuất tăng dần nếu được hỗ trợ. Tránh truy vấn tracker nhiều lần cho cùng UETR và khoảng ngày.
Chất lượng dữ liệu: Bắt buộc có PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem và LastDataUpdate. Cho phép giá trị NULL ở thuộc tính nên có nếu nguồn không cung cấp, nhưng cần báo cáo tỷ lệ có dữ liệu.
Khả năng kiểm toán: Lưu phản hồi API thô, thời điểm gửi yêu cầu, trạng thái phản hồi, UETR và mã lần chạy trích xuất tại vị trí kiểm toán được phê duyệt. Tuân thủ quy định lưu trữ và bảo mật dữ liệu thanh toán.
Điều kiện tiên quyết: Xác nhận quyền truy cập nhật ký vòng đời thanh toán nội bộ, tuân thủ, cổng SWIFT, đối soát và giao diện thông điệp, cùng giấy phép API SWIFT gpi Tracker và mọi chứng chỉ hoặc quyền cho phép truy cập mạng cần thiết.

Truy vấn mẫu 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()

Sẵn sàng bắt đầu?

Dùng các mẫu này để biến nhật ký SWIFT thô thành công cụ giúp cải thiện vận hành và rút ngắn thời gian thanh toán.

Quay lại hướng dẫn cải tiến

Tải mẫu xuống

Cải thiện quy trình xử lý thanh toán SWIFT ngay hôm nay

Đạt tỷ lệ xử lý tự động xuyên suốt 98% và loại bỏ lỗi thủ công

Bắt đầu dùng thử miễn phí

Không cần thẻ tín dụng. Thiết lập trong 5 phút

Mẫu dữ liệu xử lý thanh toán của bạn

Mẫu dữ liệu xử lý thanh toán của bạn

Thuộc tính xử lý thanh toán

Các hoạt động xử lý thanh toán

Hướng dẫn trích xuất dữ liệu

Xuất dữ liệu lưu trữ từ SWIFT Alliance Access

Các bước

Cấu hình

Truy vấn mẫu python

Trình phân tích cú pháp Python cho tệp SWIFT MT thô

Các bước

Cấu hình

Truy vấn mẫu python

Bộ kết nối API SWIFT gpi

Các bước

Cấu hình

Truy vấn mẫu python

Sẵn sàng bắt đầu?

Cải thiện quy trình xử lý thanh toán SWIFT ngay hôm nay