转载 如何通过数据集成平台实现募投账户自动化付款

FD006-募投账户付款申请流程 泛微=>金蝶其他应付单--478

在企业信息化系统的集成过程中，数据的高效流动和准确对接至关重要。本文将分享一个实际运行的系统对接案例：如何通过轻易云数据集成平台，将泛微OA-Http的数据无缝集成到金蝶云星空中，实现募投账户付款申请流程的自动化处理。

案例背景

本次集成方案（FD006-募投账户付款申请流程 泛微=>金蝶其他应付单--478）旨在解决企业在资金管理中的数据孤岛问题。通过泛微OA-Http获取付款申请数据，并将其批量写入到金蝶云星空中，以实现财务数据的统一管理和实时更新。

技术要点

1. 高吞吐量的数据写入能力： 在本次集成过程中，我们利用了轻易云平台强大的高吞吐量数据写入能力，使得大量来自泛微OA-Http的数据能够快速且稳定地被导入到金蝶云星空。这不仅提升了数据处理的时效性，还确保了业务连续性。

2. 实时监控与告警系统： 为了保证整个数据集成过程的顺利进行，轻易云提供了集中式监控和告警系统。该系统能够实时跟踪每个数据集成任务的状态和性能，一旦出现异常情况，立即发出告警通知，从而及时采取措施，避免业务中断。

3. 自定义数据转换逻辑： 由于泛微OA-Http与金蝶云星空之间存在一定的数据格式差异，我们通过轻易云平台支持的自定义数据转换逻辑，对源数据进行了必要的格式调整。这使得不同系统间的数据能够无缝对接，满足特定业务需求。

4. 分页与限流处理： 在调用泛微OA-Http接口（/api/workflow/paService/getWorkflowRequest）时，为了防止因大规模请求导致服务器压力过大，我们采用了分页与限流策略。这不仅保障了接口调用的稳定性，也提高了整体的数据抓取效率。

5. 异常处理与错误重试机制： 数据对接过程中难免会遇到各种异常情况。为此，我们设计并实现了一套完善的异常处理与错误重试机制。在向金蝶云星空写入数据时，如果发生错误，该机制会自动记录并重试，直到成功为止，从而确保所有关键业务数据不漏单、不丢失。

通过上述技术手段，本次FD006方案成功实现了泛微OA-Http到金蝶云星空的数据集成，不仅提高了工作效率，还显著增强了企业财务管理的信息化水平。后续章节将详细介绍具体实施步骤及技术细节。

调用泛微OA-Http接口获取并加工数据

在轻易云数据集成平台的生命周期中，第一步是调用源系统泛微OA-Http接口/api/workflow/paService/getWorkflowRequest以获取并加工数据。此步骤至关重要，因为它决定了后续数据处理和集成的基础。

接口调用配置

根据元数据配置，我们需要通过GET方法请求泛微OA-Http接口，并传递特定的参数来获取所需的数据。以下是关键配置项：

• API路径：/api/workflow/paService/getWorkflowRequest
• 请求方法：GET
• 主要参数：
  • workflowId: e9流程id，值为"478"
  • workflowIdList: 中间方案ID，值为"2356388e-8c49-35b3-bb7e-1eca1a8617d5"

这些参数确保我们能够准确定位到所需的工作流请求数据。

数据过滤与条件设置

为了确保只提取符合条件的数据，我们在元数据配置中定义了两个条件：

1. 主表信息过滤条件：

   {"field":"workflowMainTableInfo.fklx","logic":"eqv2","value":"其他应付单"}

   此条件用于筛选出付款类型为“其他应付单”的工作流记录。

2. 备用过滤条件：

   {"field":"workflowMainTableInfo.fklx","logic":"eqv2","value":"其他应付单"}

   与主表信息过滤条件相同，用于确保冗余检查。

自动填充响应

元数据配置中的autoFillResponse属性设置为true，这意味着系统会自动填充从接口返回的数据。这一特性极大地简化了开发过程，使得我们无需手动解析和映射每个字段。

数据抓取与处理

在实际操作中，调用该接口后，我们会得到一个包含多个工作流请求的JSON响应。接下来，需要对这些原始数据进行清洗和转换，以适应目标系统金蝶云星空的需求。具体步骤如下：

1. 分页处理：由于可能存在大量数据，需要实现分页抓取，以避免一次性请求过多导致性能问题。
2. 限流控制：通过设置合理的限流策略，确保不会对源系统造成过大的压力。
3. 异常处理与重试机制：在网络波动或服务不可用时，通过重试机制保证数据抓取的可靠性。
4. 格式转换：将泛微OA返回的数据格式转换为金蝶云星空所需的格式。例如，将日期格式、金额单位等进行统一转换。

实时监控与日志记录

为了确保整个过程透明可控，轻易云平台提供了实时监控和日志记录功能。在每次调用接口时，会记录详细的日志，包括请求时间、响应状态、返回结果等。这些日志不仅有助于排查问题，还能用于性能分析和优化。

高效的数据写入能力

最后，通过轻易云平台强大的高吞吐量写入能力，可以将清洗后的大量数据快速写入到金蝶云星空系统中。这一步骤同样受到实时监控和告警系统的保护，确保任何异常情况都能被及时发现和处理。

综上所述，通过合理配置泛微OA-Http接口调用参数、精细化的数据过滤与清洗，以及完善的监控与异常处理机制，我们能够高效且可靠地完成从泛微OA到金蝶云星空的数据集成任务，为企业业务流程提供坚实的数据支持。

集成方案:FD006-募投账户付款申请流程 泛微=>金蝶其他应付单--478

在数据集成的生命周期中，第二步是将已经集成的源平台数据进行ETL转换，以适应目标平台——金蝶云星空API接口的格式，并最终写入目标平台。本文将详细探讨如何利用轻易云数据集成平台实现这一过程。

数据转换与写入配置

在本案例中，数据从泛微OA系统提取后，需要转换为金蝶云星空API接口所能接受的格式。以下是具体的元数据配置和处理细节：

1. API接口与请求方法

   • API接口：batchSave
   • 请求方法：POST
   • 操作类型：EXECUTE

2. 字段映射与转换逻辑

   • 单据类型 (FBillTypeID)

     单据类型
     其他应付单-QTYFD01_SYS
     费用报销其他应付单-QTYFD02_SYS

     转换逻辑：固定值 QTYFD01_SYS

   • 单据编号 (FBillNo) 直接映射，无需转换。

   • 业务日期 (FDATE)

     {{workflowMainTableInfo.sqrq}}

     从主表信息中提取并直接赋值。

   • 往来单位类型 (FCONTACTUNITTYPE)

     _function case '{{detail_0.0.wldwlx_FV}}' 
     when '4' then 'BD_Supplier' 
     when '5' then 'BD_Customer' 
     when '3' then 'ORG_Organizations' 
     when '6' then 'FIN_OTHERS' 
     end

     根据不同的业务逻辑，映射到对应的单位类型。

   • 往来单位 (FCONTACTUNIT)

     _function case '{{detail_0.0.wldwlx_FV}}'
     when '4' then '{{detail_0.0.gysbh}}'
     when '5' then '{{detail_0.0.khbh}}'
     when '3' then '{{detail_0.0.zzbh}}'
     when '6' then '{{detail_0.0.qtwlbh}}'
     end

     根据单位类型，选择相应的单位编码。

   • 币别 (FCURRENCYID)

     _findCollection find FNumber from 5740d4e3-ebe8-3548-9635-f35e1fdc983b where FCODE={{workflowMainTableInfo.bberp}}

     通过查找集合进行币别转换。

3. 批量处理与性能优化 使用 batchArraySave 方法进行批量处理，提升高吞吐量的数据写入能力。这确保了大量数据能够快速写入金蝶云星空系统，提高了数据处理的效率。

4. 自定义数据转换逻辑 支持使用自定义函数 _function 和查找集合 _findCollection 来实现复杂的数据转换逻辑。例如，对于税额和不含税金额字段，可以通过自定义函数计算：

   税额 (`FTAXAMOUNTFOR`): 
   _function round('{{detail_0.tbje}}'-('{{detail_0.tbje}}'/(1+(REPLACE('{{detail_0.sl}}','%','')*0.01))),2)
   
   不含税金额 (`FNOTAXAMOUNTFOR`):
   _function round('{{detail_0.tbje}}'/(1+(REPLACE('{{detail_0.sl}}','%','')*0.01)),2)

5. 错误处理与重试机制 在调用金蝶云星空API时，可能会遇到各种异常情况。为了确保数据可靠地写入，可以实现错误重试机制。当出现网络故障或服务器响应超时时，通过设置重试次数和间隔时间，自动重新尝试提交请求。

6. 实时监控与日志记录 实现对整个ETL过程的实时监控和日志记录，以便及时发现并处理任何异常情况。通过轻易云的数据质量监控功能，可以对每一步操作进行详细记录，确保数据准确无误地传输到目标系统。

示例场景

在实际应用中，例如处理泛微OA-Http接口的数据分页和限流问题，可以通过以下方式解决：

分页参数：pageSize 和 pageNumber
限流策略：设置请求频率限制，如每秒不超过10次请求。

这些措施可以有效避免因接口调用过于频繁而导致的系统性能问题。

总结

通过轻易云数据集成平台，我们能够高效地将泛微OA系统中的数据转换为金蝶云星空API所能接受的格式，并可靠地写入目标系统。这一过程中涉及多种技术手段，包括自定义函数、集合查找、高吞吐量批量处理、实时监控等，为企业的数据集成提供了强有力的支持。