您的付款处理数据模板

FIS Global

← 返回改进指南

付款处理属性(19) 付款处理活动(13) 数据提取指南(1)

您的付款处理数据模板

此模板详细介绍了开展付款处理分析所需的关键数据属性和流程活动，并提供从系统中提取这些重要信息的实用指南。使用此资源，确保收集到全面流程挖掘所需的数据。

建议收集的属性
需要跟踪的关键活动
数据提取指南

刚接触事件日志？了解如何创建流程挖掘事件日志.

下载模板

付款处理属性

以下是建议纳入事件日志的数据字段，可用于全面分析付款处理流程。

3 必填 7 建议填写 9 选填

	名称	说明
	事件时间戳 EventTimestamp	活动发生的具体日期和时间。
说明此属性为支付流程中的每个事件提供时间信息，记录系统登记操作的确切时刻，以便按时间顺序排列活动。分析时，可用它计算步骤间隔时长、总周期时间和吞吐率。通过突出显示流程阶段之间的延误，还可识别瓶颈。重要性没有此字段就无法进行基于时间的分析；所有绩效和效率KPI都依赖它。获取途径请参阅FIS Global文档示例 2023-10-12T08:30:15Z2023-10-12T09:45:00Z2023-10-13T14:20:10Z
	支付交易ID PaymentTransactionId	特定支付指令或交易的唯一标识符。
说明此属性是关联单笔支付生命周期内所有事件的核心键。借助它，分析人员可以追踪支付从初始申请、验证、审批到最终结算或对账的全过程。在分析中，此ID对于将离散事件归入流程实例至关重要。它支持端到端流程可视化，也是周期时间、返工循环等案例级指标的计算基础。重要性这是流程挖掘的基础关联字段，可将分散的活动还原为连贯的流程。获取途径请参阅FIS Global文档示例 TRX-2023-899102PAY-US-99281ACH-7721-X99WIRE-2210-001
	活动名称 ActivityName	实际发生的具体流程步骤或事件名称。
说明此字段记录特定时间点执行的具体操作，例如“创建支付申请”或“支付已结算”。它定义流程图中的节点，并决定流程的结构。分析人员可通过此属性了解操作顺序。它对于识别偏离理想路径的情况、发现跳过的步骤，或检测多个审批循环等冗余活动至关重要。重要性此属性定义流程中的“做什么”，支持流程图可视化和变体分析。获取途径请参阅FIS Global文档示例付款申请已创建付款详情已验证付款已批准支付已结算
	业务单元 BusinessUnit	发起支付的内部部门或业务单元。
说明此属性将支付关联到特定组织单元，例如“零售银行”“商业贷款”或“资金管理”。可按部门汇总“支付吞吐量”和“平均支付周期时间”等KPI，帮助管理层比较不同部门的绩效并有效分配资源。重要性它支持内部对标，并明确各部门对流程绩效的责任。获取途径请参阅FIS Global文档示例资金管理应付账款零售运营财富管理
	处理用户 ProcessingUser	执行该活动的用户或系统代理的标识符或名称。
说明此属性记录执行流程步骤的人员或系统。它可以区分人工操作人员（如“J.Smith”）和自动化系统账户（如“SYSTEM_BATCH”）。这些数据可用于分析资源利用情况、识别人工瓶颈，以及审计职责分离情况。它还有助于计算“处理用户利用率”，并区分人工任务与自动化任务。重要性对于资源分析、自动化率统计和合规审计至关重要。获取途径请参阅FIS Global文档示例 jsmithSYSTEM_AUTOBOTmdoe_approverAPI_GATEWAY
	实际结算日期 ActualSettlementDate	支付实际完成并结算的日期。
说明此属性记录资金实际转出或交易被视为完成的生效日期。它不同于处理时间戳，反映的是起息日。分析时，可将此日期与到期日结合，用于计算“按时付款率”。它也是启动对账阶段的依据，对于分析“支付对账周期时间”十分重要。重要性它代表支付的财务结算结果，是现金流分析的关键数据。获取途径请参阅FIS Global文档示例 2023-11-022023-11-14
	支付到期日 PaymentDueDate	预期完成支付结算的日期。
说明此属性记录发起人要求的支付期限或发票条款规定的期限，是衡量是否按时完成的目标基准。此字段对于“支付到期日遵守情况”仪表板至关重要。分析人员可将此日期与实际“支付已结算”日期比较，标记逾期支付、计算潜在罚款，并评估是否遵守供应商协议。重要性它为衡量服务级别遵守情况和处理时效提供基准。获取途径请参阅FIS Global文档示例 2023-11-012023-11-15
	支付类型 PaymentType	支付方式或支付工具的分类。
说明此属性将支付划分为电汇、ACH、SEPA、实时支付（RTP）或支票等类型。不同类型的支付遵循不同的处理规则和服务级别协议（SLA）。分析人员可利用此字段比较不同支付渠道的“支付对账周期时间”。它有助于解释有些支付为何即时结算，而另一些需要数天，并确保绩效评估采用正确的基准。重要性这是细分流程的主要维度，因为每种支付类型都有各自的路由和时效特征。获取途径请参阅FIS Global文档示例电汇ACH贷记SEPA即时支付支票
	支付金额 PaymentAmount	支付交易的金额。
说明此属性表示支付申请所涉及的金额，是分析财务吞吐量和风险的主要指标。分析人员可按金额高低对流程进行细分，因为不同金额的支付往往采用不同的审批路径。此字段支持“支付吞吐量”仪表板，并有助于判断高金额支付是否因审查更严格而周期时间更长。重要性它为流程挖掘补充了财务维度，支持按金额确定优先级。获取途径请参阅FIS Global文档示例 1500.00250.501000000.0045.99
	货币代码 CurrencyCode	表示支付币种的3字母ISO代码。
说明此属性指定支付金额所用的币种（如USD、EUR、GBP）。分析全球支付流时，它对于统一财务数据至关重要。分析时，可按币种细分流程绩效。币种往往与不同的清算系统和法规相关，因此有助于解释跨境支付与境内支付在结算时间上的差异。重要性在多币种环境中准确解读资金规模时，此属性至关重要。获取途径请参阅FIS Global文档示例 USDEURGBPJPY
	付款账户 SenderAccount	用于扣款的账户号码。
说明此属性标识交易的付款账户，便于详细分析特定内部账户的支付情况。分析时，可用它判断特定资金账户是否容易出现错误（如资金不足）或延误。它还支持对账，可将账簿记录与流程活动进行匹配。重要性它是财务对账和账户级问题排查的基础。获取途径请参阅FIS Global文档示例 123456789987654321ACC-TREASURY-01
	审批权限 ApprovalAuthority	负责授权支付的角色、群组或个人。
说明此属性表示审批支付所需的权限级别或特定用户群组，通常取决于金额门槛。它有助于追踪审批工作流的路由情况。分析人员可利用此属性支持“支付授权瓶颈”仪表板，按权限级别拆分审批时间，判断特定管理层级是否造成延误。重要性它支持对审批层级进行组织分析，并识别瓶颈。获取途径请参阅FIS Global文档示例一级经理CFO合规团队自动审批系统
	支付渠道 PaymentChannel	发起支付申请所使用的渠道。
说明此属性描述支付指令的来源，例如网上银行、移动应用、API或网点，有助于了解交易的输入渠道。分析人员可利用此属性比较不同渠道的处理效率。例如，可判断通过API发起的支付是否比在网点手动录入的支付错误率更低。重要性它有助于优化渠道并了解客户行为。获取途径请参阅FIS Global文档示例网上银行移动应用企业网关网点柜员
	收款人所在国家/地区 BeneficiaryCountry	支付收款人所在国家/地区的代码。
说明此属性用于标识资金的目的地国家，以区分境内付款和国际付款。这一信息对于“付款一致性监控”和路由分析至关重要。国际付款通常涉及不同的中介机构、一致性检查和更长的周期时间。按国家分析绩效，有助于识别这些因素的影响。重要性这是地理分析和合规风险评估的重要维度。获取途径请参阅FIS Global文档示例 USDECNGB
	数据上次更新时间 LastDataUpdate	记录上次提取或刷新的时间戳。
说明此属性反映分析所用数据的新鲜度，帮助用户判断当前查看的是实时数据，还是之前某个时段的数据快照。在仪表板中，此字段常用于显示“数据截至”标签。它有助于确保决策依据是当前可用的相关信息，并支持增量数据加载管理。重要性它能说明数据的时效性，增强用户对报告更新及时性的信任。获取途径 ETL流程元数据示例 2023-10-14T00:00:00Z2023-10-15T06:00:00Z
	是否逾期支付 IsLatePayment	用于标记支付是否在到期日之后结算。
说明这是一个计算得出的布尔属性。如果“支付已结算”日期晚于“支付到期日”，则返回true。此属性直接用于计算“按时付款率”KPI。它简化了仪表板分析，用户无需在可视化层编写复杂的日期逻辑，即可快速筛选问题案例。重要性它简化了异常报告和合规分析。获取途径根据PaymentDueDate和ActualSettlementDate推导示例 truefalse
	是否需要人工干预 IsManualIntervention	用于标记活动是否涉及人工操作。
说明此布尔属性用于标记需要人工输入的活动或案例，例如“支付错误已解决”或人工审批，并与直通式处理（STP）区分。此属性对于“人工支付干预率”仪表板至关重要。它有助于量化尚未完全自动化的支付比例，指出数字化转型的机会。重要性它能区分自动化处理量与人工投入，为自动化投资回报率计算提供依据。获取途径根据ActivityName或ProcessingUser推导示例 truefalse
	源系统 SourceSystem	事件数据来源系统的名称。
说明此属性标识提取记录所来自的具体软件组件或数据库，例如核心银行引擎、支付网关或制裁筛查工具。它对于数据沿袭和验证至关重要。在分析跨多个平台的端到端流程时，此字段有助于区分各项活动的发生位置，并排查数据质量问题。重要性它能确保数据可追溯且具备相应背景信息，在集成多个支付引擎的复杂环境中尤为重要。获取途径请参阅FIS Global文档示例 FIS OPFTraxPaymentHub_01SanctionsScreeningDB
	验证错误代码 ValidationErrorCode	指出支付未通过验证原因的代码或说明。
说明支付进入“发现支付错误”活动时，此属性会填入具体失败原因，例如“IBAN无效”“资金不足”或“缺少收款人地址”。此字段支持“支付数据验证错误率”仪表板。按此属性分组可找出最常见的返工原因，从而有针对性地改进上游数据录入或系统配置。重要性它有助于识别流程阻滞和返工循环的根本原因。获取途径请参阅FIS Global文档示例 ERR-001：账户无效ERR-055：命中制裁名单ERR-009：交易重复

必填建议填写选填

付款处理活动

以下是建议记录在事件日志中的关键流程步骤和里程碑，有助于准确发现并优化流程。

6 建议填写 7 选填

	活动	说明
	付款已批准	这是一个关键里程碑，表示有权用户已批准付款，交易可以进入下一阶段。用户在系统中执行操作时，通常会明确记录该事件，包括审批人ID和时间戳。
重要性此节点对于衡量审批周期时间和确保遵守财务控制要求至关重要。此阶段的延迟会显著影响付款按期完成情况。获取途径该事件记录在审批日志表中，或作为明确事件写入主交易历史记录。事件日志会关联付款交易ID、审批人用户ID和审批时间戳。采集具有审批权限的用户对付款执行“批准”操作时记录此事件。事件类型 explicit
	付款已授权	此活动表示最终授权步骤，通常适用于高金额付款，或由另一位授权人进行初次审批后的复核。具有授权凭据的用户确认付款时，系统会明确记录此操作。
重要性此活动是“付款授权瓶颈”仪表板的关键内容。将其与“付款已批准”区分开来，有助于定位多级审批流程中的延迟。获取途径此事件记录在审计日志或交易日志中。具有特定授权权限的用户处理付款时会触发该事件，并生成包含用户ID和时间戳的记录。采集用户执行最终授权操作时，系统会创建一条明确的日志记录。事件类型 explicit
	付款指令已发送	此活动标志着FIS系统将最终付款指令发送至相关支付网络，例如ACH、Fedwire或SWIFT。这是由系统生成的关键事件。
重要性这是一个重要里程碑，表示付款已离开内部处理环境。分析路由效率和外部处理耗时离不开此事件。获取途径该事件记录在跟踪外部支付网络通信的交易日志或消息日志中。请查找带有时间戳、表明出站消息已成功发送的记录。采集付款消息发送至清算网络时由系统生成的事件。事件类型 explicit
	付款申请已创建	这是付款生命周期中的首个事件，表示FIS系统中新付款交易的发起时刻。通常，用户或自动化系统提交新付款申请时，交易日志表中会记录一条明确的记录。
重要性此活动标志着流程正式开始。它对于衡量付款端到端周期时间，以及分析整体付款处理量和交易量至关重要。获取途径该事件记录在核心交易表中，可通过与付款交易ID关联的创建时间戳识别。请查找“Payment_Transactions”或“Payment_Requests”等表中的“creation_date”或“entry_date”字段。采集创建新的付款交易记录时生成的事件。事件类型 explicit
	支付已对账	这是最后一项会计活动，用于将支付交易与银行对账单或内部账簿记录进行匹配。此操作可以通过批处理自动完成，也可以由用户手动执行。
重要性此活动标志着支付生命周期彻底结束。分析“支付对账周期时间”有助于了解财务结账流程的效率。获取途径通常可根据reconciliation_date字段是否已填充，或支付系统关联的财务或会计模块中状态是否最终变为“已对账”来推断。采集根据对账日期是否已填充，或状态是否变为“已对账”来识别。事件类型 inferred
	支付已结算	此活动标志着资金转账完成，交易在财务上已结清。通常在收到支付网络或清算机构发来的最终结算确认后记录。
重要性这是衡量支付周期时间和按时付款率的主要终点，表示核心支付执行流程已成功完成。获取途径根据支付记录的最终状态变化推断，例如状态变为“已结算”“已完成”或“已入账”。此变化由批量结算文件或清算系统的实时消息触发。采集支付交易状态变为“已结算”或同等状态。事件类型 inferred
	付款已拒绝	审批人拒绝付款申请时会发生此活动，通常需要更正后重新提交，或直接取消。此操作由用户明确执行，并会记录以供审计。
重要性跟踪拒绝情况有助于发现付款失败、流程偏差和返工循环的常见原因，也能揭示初始数据质量或合规方面的问题。获取途径审批人在审批或交易历史表中选择“拒绝”时，会记录一条明确事件。记录通常包含时间戳、用户ID，且往往还包括原因代码。采集用户对付款执行“拒绝”操作时记录此事件。事件类型 explicit
	付款已提交审批	此活动表示已验证的付款进入审批工作流。通常，付款状态发生变化，表明交易正在等待审批人处理。
重要性此活动标志着审批子流程的开始。分析此活动与“付款已批准”之间的时间，对于了解审批瓶颈至关重要。获取途径可根据工作流或交易状态日志中的付款状态变化推断此事件，例如状态变为“待审批”“已提交审批”或类似值。采集付款交易状态从“已验证”变为“待审批”。事件类型 inferred
	付款已确认	表示收到支付网络或收款银行发来的确认，表明款项已到账。系统收到消息或状态更新时会触发此事件。
重要性确认信息表明款项已到达目的地。从“已发送指令”到“已确认”的时间可用于衡量外部网络延迟和处理时间。获取途径系统解析支付网络发来的确认消息后生成此事件，并更新支付状态、记录确认时间戳。采集清算网络的入站消息将支付状态更新为“已确认”。事件类型 explicit
	付款详情已验证	此活动表示付款数据已通过格式、完整性和正确性的初步自动验证。通常可根据付款记录的状态变化推断，例如从“新建”变为“已验证”或“待审批”。
重要性跟踪此活动有助于识别数据录入错误的频率和发生位置。这也是分析付款数据验证错误率KPI、了解返工来源的前提。获取途径可根据付款交易表中的状态或状态值变化推断此事件。状态从初始值变为“已验证”，并带有相应时间戳，即表示该事件发生。采集付款状态字段变为“已验证”或类似值时，即可识别此事件。事件类型 inferred
	发现支付错误	表示初步验证后在流程中的某个环节发现错误，例如收款银行拒绝支付，或内部合规标记出问题。通常会在引发异常时明确记录此事件。
重要性此活动是所有返工和异常处理循环的入口，也是计算人工干预率和支付错误解决时间KPI的关键依据。获取途径记录在异常处理模块或交易日志中。系统规则可自动触发此事件，用户也可手动标记问题；系统会记录错误代码和时间戳。采集支付交易记录中登记了异常或错误代码。事件类型 explicit
	发现逾期支付	此派生事件表示支付在指定到期日之后才结算。系统不会直接记录此活动，而是通过比较两个日期字段计算得出。
重要性此计算活动直接用于支持“按时付款率”KPI和“支付到期日遵守情况”仪表板。它有助于量化流程延误对供应商关系及潜在滞纳金的影响。获取途径此事件不会直接提取，而是在数据转换期间通过比较“结算日期”时间戳与“支付到期日”字段计算得出。如果结算日期晚于到期日，系统就会生成此事件。采集如果“结算日期”>“支付到期日”，则计算得出。事件类型 calculated
	支付错误已解决	标志着此前发现的支付错误已解决，支付可以重新处理或取消。用户执行明确操作后，异常状态即被清除。
重要性此活动结束异常处理循环。从“发现错误”到此事件的时长，是衡量异常处理运营效率的重要指标。获取途径用户清除错误标记或将交易移出异常队列时，系统会记录此事件。该操作会连同时间戳保存在审计轨迹或交易历史日志中。采集用户执行操作以清除错误状态，系统会将此操作记录在审计日志中。事件类型 explicit

建议填写选填

数据提取指南

如何从FIS Global获取数据

步骤

确认FIS Global付款引擎会将原始ISO 20022 XML消息（包括pacs.008付款指令和pacs.002付款状态报告）归档到可访问的文件系统位置。获取归档路径、文件命名规则、命名空间配置、保留期限，以及付款交易ID与EndToEndId、TxId、InstrId或UETR等ISO 20022标识符之间的映射关系。
安装Python 3.10或更高版本，以及脚本使用的标准库模块，包括pathlib、xml.etree.ElementTree、csv、datetime、decimal和collections。参考实现不需要外部软件包。确认执行账户可以读取XML归档并写入ProcessMind输出文件。
在脚本的配置部分设置输入目录、输出文件、开始日期、结束日期、时区和公司特定筛选条件。仅替换文档中说明的占位符。在通过代表性文件验证标识符映射之前，不要假定文件名或XML元素中包含ProcessMind案例标识符。
检查成功、拒绝、失败、修复和已结算交易对应的代表性pacs.008和pacs.002文件。确认XML命名空间，并找出包含交易标识符、金额、币种、请求执行日期、结算日期、状态代码、原因代码、事件时间戳、处理用户或系统代理、付款类型和业务单元的元素。如果FIS实施使用不同路径，请更新已配置的XPath候选项。
先使用有限的日期范围运行脚本。解析器会读取每个XML文件，提取消息级和交易级数据，将ISO 20022状态代码和原因代码映射为明确的活动，并为每个提取到的活动写入一条事件记录。脚本还会根据明确的错误或修复标记生成Payment Error Identified和Payment Error Resolved记录；仅当结算晚于到期日时，才生成Late Payment Identified记录。
检查生成的CSV文件和验证报告。确认每行均已填写PaymentTransactionId、ActivityName和EventTimestamp，13个必需活动名称均可能出现，且时间戳的标准化方式一致。扩大提取范围之前，请先调查标识符缺失、不支持的状态代码、重复事件或日期冲突等问题。
将事件数量与源归档进行核对，并在可用时与FIS运营报表或审计提取数据进行比对。抽样端到端验证交易，包括审批、拒绝、授权、指令发送、网络确认、结算、错误处理、对账和逾期付款逻辑。如需运营追溯，请在审计输出中保留源文件名以及源行号或消息引用。
在所选期间的源归档完成后运行脚本，或通过受控的重叠时间窗口增量运行，以捕获延迟到达的pacs.002消息。使用PaymentTransactionId、ActivityName、EventTimestamp和源消息标识去重，同时保留源数据中多次发生的有效重复活动。
将最终事件日志导出为UTF-8编码的CSV文件，每个事件占一行，并包含PaymentTransactionId、ActivityName、EventTimestamp、ProcessingUser、PaymentAmount、CurrencyCode、PaymentType、PaymentDueDate、ActualSettlementDate和BusinessUnit列。将文件上传到ProcessMind，并将PaymentTransactionId设为案例标识符、ActivityName设为活动、EventTimestamp设为事件时间戳。ProcessMind会按原样读取事件日志，不会推断缺失的活动。

配置

输入归档路径：配置存放原始ISO 20022 XML文件的目录。如果归档按日期、公司、消息类型或处理状态分区，请包含所有相关子目录。
消息类型：包含付款指令pacs.008和付款状态报告pacs.002。只有在FIS实施中验证了其他消息类型的标识符和状态含义后，才添加这些类型。
标识符映射：配置用于解析付款交易ID的XPath候选项。优先使用在FIS交易记录及所有相关ISO 20022消息中保持一致的标识符。除非有文档记录的关联规则，否则不要合并无关标识符。
活动映射：配置创建、验证、提交审批、审批、拒绝、授权、指令发送、确认、结算、错误识别、错误解决和对账对应的状态代码及原因代码。提供的脚本使用可配置映射和明确的源数据标记，不会根据记录缺失推断常规生命周期事件。
日期范围：从3至6个月的数据开始。初次测试或归档数据量较大时，可缩短日期范围；如果状态消息可能晚于原始付款日期到达，请设置重叠时间段。
日期筛选：尽可能使用源事件时间戳配置开始和结束日期。只有在明确启用的情况下，脚本才会在消息缺少事件时间戳时使用文件修改时间戳。由于这并非业务事件时间戳，必须记录此回退方式。
公司和组织筛选：仅当XML中存在相应元素且其值已验证时，才配置公司、业务单元、法人实体、付款产品或单据类型筛选。实施特定的筛选条件请使用[Configure based on your system]。
时区：设置源系统时区或UTC标准化策略。对所有消息应用相同策略，以确保事件顺序可靠。
错误和修复标记：配置用于表示Payment Error Identified和Payment Error Resolved的状态代码、原因代码以及明确的修复或异常标记。除非这是经批准的业务定义，否则不要将所有拒绝都归类为错误。
对账标记：配置FIS实施中使用的明确对账状态、对账消息、分类账匹配标记或批次结果。如果对账数据存储在XML归档之外，请提供单独的获批数据源和关联规则。
性能：逐个处理文件，不要将整个归档一次性载入内存。大型任务按日期或目录分区，写入中间结果，并使用磁盘空间充足的本地暂存区。处理超大型归档时，只有在确认输出顺序和去重过程仍可控后，才按独立目录分区并行处理。
前提条件：具备XML归档读取权限、输出位置写入权限、Python执行权限、经批准的付款数据访问权限，以及经过验证的FIS标识符和状态代码映射。此文件处理方法不假设存在特定FIS交易代码、菜单路径、API端点、表名或许可证。

查询示例 python

from __future__ import annotations

import csv
import hashlib
import re
import sys
import xml.etree.ElementTree as ET
from collections import defaultdict
from datetime import date, datetime, timezone
from decimal import Decimal, InvalidOperation
from pathlib import Path
from typing import Dict, Iterable, List, Optional, Tuple

class=class="hl-string">"hl-comment"># Replace only these documented placeholders.
INPUT_DIRECTORY = Path(class="hl-string">"[Your XML archive directory]")
OUTPUT_FILE = Path(class="hl-string">"[Your ProcessMind event log output path].csv")
START_DATE = class="hl-string">"[YYYY-MM-DD]"
END_DATE = class="hl-string">"[YYYY-MM-DD]"
SOURCE_TIMEZONE = timezone.utc
COMPANY_FILTER = class="hl-string">""  class=class="hl-string">"hl-comment"># Leave empty unless a validated company or business-unit value is required.

class=class="hl-string">"hl-comment"># Update these candidates after inspecting representative FIS XML files.
IDENTIFIER_PATHS = [
    class="hl-string">"EndToEndId", class="hl-string">"TxId", class="hl-string">"InstrId", class="hl-string">"UETR", class="hl-string">"PaymentTransactionId",
    class="hl-string">"PaymentId", class="hl-string">"TransactionId"
]
AMOUNT_PATHS = [class="hl-string">"InstdAmt", class="hl-string">"IntrBkSttlmAmt", class="hl-string">"Amt", class="hl-string">"Amount"]
CURRENCY_PATHS = [class="hl-string">"InstdAmt", class="hl-string">"IntrBkSttlmAmt", class="hl-string">"Amt", class="hl-string">"Currency", class="hl-string">"Ccy"]
DUE_DATE_PATHS = [class="hl-string">"ReqdExctnDt", class="hl-string">"ReqdColltnDt", class="hl-string">"DueDate", class="hl-string">"RequestedExecutionDate"]
SETTLEMENT_DATE_PATHS = [class="hl-string">"SttlmDt", class="hl-string">"SettlementDate", class="hl-string">"ActualSettlementDate"]
TIMESTAMP_PATHS = [
    class="hl-string">"CreDtTm", class="hl-string">"AccptncDtTm", class="hl-string">"AccptncDt", class="hl-string">"OrgnlCreDtTm", class="hl-string">"TxDtTm",
    class="hl-string">"SttlmDt", class="hl-string">"SettlementDate", class="hl-string">"EventTimestamp", class="hl-string">"Timestamp"
]
USER_PATHS = [class="hl-string">"UserId", class="hl-string">"UserID", class="hl-string">"Operator", class="hl-string">"Approver", class="hl-string">"ProcessingUser", class="hl-string">"Initiator"]
PAYMENT_TYPE_PATHS = [class="hl-string">"PmtMtd", class="hl-string">"SvcLvl", class="hl-string">"LclInstrm", class="hl-string">"CtgyPurp", class="hl-string">"PaymentType"]
BUSINESS_UNIT_PATHS = [class="hl-string">"BusinessUnit", class="hl-string">"CompanyCode", class="hl-string">"Company", class="hl-string">"OrgUnit", class="hl-string">"LegalEntity"]
STATUS_PATHS = [class="hl-string">"TxSts", class="hl-string">"GrpSts", class="hl-string">"Status", class="hl-string">"PaymentStatus", class="hl-string">"TransactionStatus"]
REASON_PATHS = [class="hl-string">"Cd", class="hl-string">"Rsn", class="hl-string">"ReasonCode", class="hl-string">"StatusReason", class="hl-string">"AddtlInf"]
ERROR_PATHS = [class="hl-string">"Error", class="hl-string">"Exception", class="hl-string">"Failure", class="hl-string">"ErrorCode", class="hl-string">"ExceptionCode"]
REPAIR_PATHS = [class="hl-string">"Repair", class="hl-string">"Resolved", class="hl-string">"Resolution", class="hl-string">"ErrorResolved", class="hl-string">"ExceptionResolved"]
RECONCILIATION_PATHS = [class="hl-string">"Reconciled", class="hl-string">"ReconciliationStatus", class="hl-string">"LedgerMatched", class="hl-string">"BankStatementMatched"]

class=class="hl-string">"hl-comment"># Validate and extend these mappings against the FIS implementation.
STATUS_ACTIVITY_MAP = {
    class="hl-string">"NEW": class="hl-string">"Payment Request Created",
    class="hl-string">"RECEIVED": class="hl-string">"Payment Request Created",
    class="hl-string">"VALIDATED": class="hl-string">"Payment Details Validated",
    class="hl-string">"PENDING_APPROVAL": class="hl-string">"Payment Sent For Approval",
    class="hl-string">"AWAITING_APPROVAL": class="hl-string">"Payment Sent For Approval",
    class="hl-string">"APPROVAL_PENDING": class="hl-string">"Payment Sent For Approval",
    class="hl-string">"APPROVED": class="hl-string">"Payment Approved",
    class="hl-string">"REJECTED": class="hl-string">"Payment Rejected",
    class="hl-string">"AUTHORIZED": class="hl-string">"Payment Authorized",
    class="hl-string">"SENT": class="hl-string">"Payment Instruction Sent",
    class="hl-string">"DISPATCHED": class="hl-string">"Payment Instruction Sent",
    class="hl-string">"ACCP": class="hl-string">"Payment Confirmed",
    class="hl-string">"ACCEPTED": class="hl-string">"Payment Confirmed",
    class="hl-string">"CONFIRMED": class="hl-string">"Payment Confirmed",
    class="hl-string">"SETTLED": class="hl-string">"Payment Settled",
    class="hl-string">"BOOK": class="hl-string">"Payment Settled",
    class="hl-string">"RECONCILED": class="hl-string">"Payment Reconciled",
}
ERROR_STATUS_CODES = {class="hl-string">"RJCT", class="hl-string">"REJECTED", class="hl-string">"FAILED", class="hl-string">"ERROR", class="hl-string">"EXCEPTION", class="hl-string">"CANCELLED"}
RESOLVED_STATUS_CODES = {class="hl-string">"REPAIRED", class="hl-string">"RESOLVED", class="hl-string">"CORRECTED", class="hl-string">"REPROCESSING", class="hl-string">"REPROCESSED"}

OUTPUT_COLUMNS = [
    class="hl-string">"PaymentTransactionId", class="hl-string">"ActivityName", class="hl-string">"EventTimestamp", class="hl-string">"ProcessingUser",
    class="hl-string">"PaymentAmount", class="hl-string">"CurrencyCode", class="hl-string">"PaymentType", class="hl-string">"PaymentDueDate",
    class="hl-string">"ActualSettlementDate", class="hl-string">"BusinessUnit"
]


def local_name(tag: str) -> str:
    return tag.rsplit(class="hl-string">"}", 1)[-1].lower()


def text_values(root: ET.Element, candidates: Iterable[str]) -> List[str]:
    wanted = {candidate.lower() for candidate in candidates}
    values: List[str] = []
    for element in root.iter():
        if local_name(element.tag) in wanted:
            value = (element.text or class="hl-string">"").strip()
            if value:
                values.append(value)
            for key, attribute_value in element.attrib.items():
                if key.rsplit(class="hl-string">"}", 1)[-1].lower() in {class="hl-string">"ccy", class="hl-string">"currency"} and attribute_value.strip():
                    values.append(attribute_value.strip())
    return values


def first_value(root: ET.Element, candidates: Iterable[str]) -> str:
    values = text_values(root, candidates)
    return values[0] if values else class="hl-string">""


def normalize_code(value: str) -> str:
    return re.sub(rclass="hl-string">"[^A-Z0-9_]", class="hl-string">"", value.upper().replace(class="hl-string">"-", class="hl-string">"_"))


def parse_datetime(value: str) -> Optional[datetime]:
    if not value:
        return None
    candidate = value.strip()
    if candidate.endswith(class="hl-string">"Z"):
        candidate = candidate[:-1] + class="hl-string">"+00:00"
    try:
        parsed = datetime.fromisoformat(candidate)
    except ValueError:
        for fmt in (class="hl-string">"%Y-%m-%d %H:%M:%S", class="hl-string">"%Y-%m-%d", class="hl-string">"%Y%m%d%H%M%S", class="hl-string">"%Y%m%d"):
            try:
                parsed = datetime.strptime(value.strip(), fmt)
                break
            except ValueError:
                parsed = None
        if parsed is None:
            return None
    if parsed.tzinfo is None:
        parsed = parsed.replace(tzinfo=SOURCE_TIMEZONE)
    return parsed.astimezone(timezone.utc)


def output_timestamp(value: Optional[datetime]) -> str:
    return value.astimezone(timezone.utc).isoformat().replace(class="hl-string">"+00:00", class="hl-string">"Z") if value else class="hl-string">""


def output_date(value: str) -> str:
    parsed = parse_datetime(value)
    return parsed.date().isoformat() if parsed else (value[:10] if re.match(rclass="hl-string">"^\d{4}-\d{2}-\d{2}", value) else class="hl-string">"")


def normalize_amount(value: str) -> str:
    if not value:
        return class="hl-string">""
    try:
        return format(Decimal(value.replace(class="hl-string">",", class="hl-string">"").strip()), class="hl-string">"f")
    except InvalidOperation:
        return value.strip()


def source_message_id(path: Path, root: ET.Element) -> str:
    raw = path.as_posix() + class="hl-string">"|" + first_value(root, [class="hl-string">"MsgId", class="hl-string">"MessageId", class="hl-string">"BizMsgIdr"])
    return hashlib.sha256(raw.encode(class="hl-string">"utf-8")).hexdigest()


def in_date_range(event_time: Optional[datetime]) -> bool:
    if not event_time:
        return True
    start = datetime.fromisoformat(START_DATE).replace(tzinfo=timezone.utc)
    end = datetime.fromisoformat(END_DATE).replace(tzinfo=timezone.utc)
    return start <= event_time < end.replace(hour=23, minute=59, second=59, microsecond=999999)


def add_event(events: List[Dict[str, str]], seen: set, transaction_id: str, activity: str,
              event_time: Optional[datetime], user: str, amount: str, currency: str,
              payment_type: str, due_date: str, settlement_date: str, business_unit: str,
              message_id: str) -> None:
    if not transaction_id or not event_time or not in_date_range(event_time):
        return
    row = {
        class="hl-string">"PaymentTransactionId": transaction_id,
        class="hl-string">"ActivityName": activity,
        class="hl-string">"EventTimestamp": output_timestamp(event_time),
        class="hl-string">"ProcessingUser": user,
        class="hl-string">"PaymentAmount": amount,
        class="hl-string">"CurrencyCode": currency,
        class="hl-string">"PaymentType": payment_type,
        class="hl-string">"PaymentDueDate": output_date(due_date),
        class="hl-string">"ActualSettlementDate": output_date(settlement_date),
        class="hl-string">"BusinessUnit": business_unit,
    }
    key = (transaction_id, activity, row[class="hl-string">"EventTimestamp"], message_id)
    if key not in seen:
        seen.add(key)
        events.append(row)


def parse_file(path: Path, events: List[Dict[str, str]], seen: set) -> None:
    try:
        root = ET.parse(path).getroot()
    except (ET.ParseError, OSError) as exc:
        print(fclass="hl-string">"Could not parse {path}: {exc}", file=sys.stderr)
        return
    message_id = source_message_id(path, root)
    transaction_id = first_value(root, IDENTIFIER_PATHS)
    if not transaction_id:
        return
    business_unit = first_value(root, BUSINESS_UNIT_PATHS)
    if COMPANY_FILTER and business_unit != COMPANY_FILTER:
        return
    amount = normalize_amount(first_value(root, AMOUNT_PATHS))
    currency = first_value(root, CURRENCY_PATHS)
    if len(currency) != 3 and currency:
        currency = currency.upper()
    due_date = first_value(root, DUE_DATE_PATHS)
    settlement_date = first_value(root, SETTLEMENT_DATE_PATHS)
    user = first_value(root, USER_PATHS)
    payment_type = first_value(root, PAYMENT_TYPE_PATHS)
    status_values = text_values(root, STATUS_PATHS)
    reason_values = text_values(root, REASON_PATHS)
    error_values = text_values(root, ERROR_PATHS)
    repair_values = text_values(root, REPAIR_PATHS)
    reconciliation_values = text_values(root, RECONCILIATION_PATHS)
    event_time = parse_datetime(first_value(root, TIMESTAMP_PATHS))
    if not event_time:
        return

    message_name = next((local_name(element.tag) for element in root.iter() if local_name(element.tag) in {class="hl-string">"pacs.008", class="hl-string">"pacs.002", class="hl-string">"document"}), class="hl-string">"")
    normalized_statuses = [normalize_code(value) for value in status_values + reason_values]
    normalized_text = class="hl-string">" ".join(normalize_code(value) for value in error_values)
    normalized_repairs = class="hl-string">" ".join(normalize_code(value) for value in repair_values)
    normalized_reconciliation = class="hl-string">" ".join(normalize_code(value) for value in reconciliation_values)

    if message_name or status_values:
        add_event(events, seen, transaction_id, class="hl-string">"Payment Request Created", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"NEW", class="hl-string">"RECEIVED"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Details Validated", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if class="hl-string">"VALIDATED" in normalized_statuses else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Sent For Approval", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"PENDING_APPROVAL", class="hl-string">"AWAITING_APPROVAL", class="hl-string">"APPROVAL_PENDING"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Approved", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if class="hl-string">"APPROVED" in normalized_statuses else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Rejected", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"REJECTED", class="hl-string">"RJCT"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Authorized", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if class="hl-string">"AUTHORIZED" in normalized_statuses else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Instruction Sent", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"SENT", class="hl-string">"DISPATCHED"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Confirmed", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"ACCP", class="hl-string">"ACCEPTED", class="hl-string">"CONFIRMED"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Settled", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if any(code in {class="hl-string">"SETTLED", class="hl-string">"BOOK"} for code in normalized_statuses) else None
        add_event(events, seen, transaction_id, class="hl-string">"Payment Reconciled", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id) if class="hl-string">"RECONCILED" in normalized_statuses or any(code in normalized_reconciliation for code in {class="hl-string">"TRUE", class="hl-string">"MATCHED", class="hl-string">"RECONCILED"}) else None

    if any(code in ERROR_STATUS_CODES for code in normalized_statuses) or normalized_text:
        add_event(events, seen, transaction_id, class="hl-string">"Payment Error Identified", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id)
    if any(code in RESOLVED_STATUS_CODES for code in normalized_statuses) or any(code in normalized_repairs for code in {class="hl-string">"TRUE", class="hl-string">"RESOLVED", class="hl-string">"REPAIRED", class="hl-string">"CORRECTED"}):
        add_event(events, seen, transaction_id, class="hl-string">"Payment Error Resolved", event_time, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id)

    due = parse_datetime(due_date)
    settled = parse_datetime(settlement_date)
    if due and settled and settled.date() > due.date():
        add_event(events, seen, transaction_id, class="hl-string">"Late Payment Identified", settled, user, amount, currency, payment_type, due_date, settlement_date, business_unit, message_id)


def main() -> None:
    events: List[Dict[str, str]] = []
    seen = set()
    for path in sorted(INPUT_DIRECTORY.rglob(class="hl-string">"*.xml")):
        parse_file(path, events, seen)
    events.sort(key=lambda row: (row[class="hl-string">"PaymentTransactionId"], row[class="hl-string">"EventTimestamp"], row[class="hl-string">"ActivityName"]))
    OUTPUT_FILE.parent.mkdir(parents=True, exist_ok=True)
    with OUTPUT_FILE.open(class="hl-string">"w", newline=class="hl-string">"", encoding=class="hl-string">"utf-8") as handle:
        writer = csv.DictWriter(handle, fieldnames=OUTPUT_COLUMNS)
        writer.writeheader()
        writer.writerows(events)
    print(fclass="hl-string">"Wrote {len(events)} event rows to {OUTPUT_FILE}")


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

准备好开始了吗？

使用此模板简化数据收集，开启付款处理改进之旅。借助精准的流程洞察，提升效率并加强财务控制。

返回改进指南

下载模板

立即优化FIS Global付款处理流程

实现98%的直通处理率，消除对账问题。

立即开始免费试用

无需信用卡，几分钟即可开始

您的付款处理数据模板

您的付款处理数据模板

付款处理属性

付款处理活动

数据提取指南

使用Python解析ISO 20022 XML日志文件

步骤

配置

查询示例 python

准备好开始了吗？

立即优化FIS Global付款处理流程