markdown

![](https://pic.qeasy.cloud/QEASY/A71.png)

### 案例分享：FD003-非生产性付款申请 泛微=>金蝶其他应付单--481

在企业的财务管理中，数据的高效集成与处理至关重要。本文将聚焦于一个具体的系统对接集成案例——如何通过轻易云数据集成平台，将泛微OA-Http的数据无缝集成到金蝶云星空，实现非生产性付款申请的数据流转。

#### 背景概述

本次案例涉及的方案名称为“FD003-非生产性付款申请 泛微=>金蝶其他应付单--481”。该方案旨在通过泛微OA-Http接口获取相关业务数据，并将其批量写入到金蝶云星空系统中，以生成对应的其他应付单。

#### 技术要点

1. **高吞吐量的数据写入能力**：为了确保大量数据能够快速被集成到泛微OA-Http系统中，我们利用了平台提供的高吞吐量数据写入特性。这不仅提升了数据处理的时效性，也保证了业务流程的连续性和稳定性。

2. **集中监控和告警系统**：在整个数据集成过程中，实时监控任务状态和性能是关键。我们使用了平台提供的集中监控和告警系统，实时跟踪每个环节的数据流动情况，确保任何异常都能及时发现并处理。

3. **自定义数据转换逻辑**：由于泛微OA-Http与金蝶云星空之间存在一定的数据格式差异，我们设计并实现了自定义的数据转换逻辑，以适应特定业务需求。这一过程不仅包括字段映射，还涉及复杂的数据清洗和转换规则。

4. **分页与限流处理**：在调用泛微OA-Http接口（/api/workflow/paService/getWorkflowRequest）时，为了避免因大规模数据请求导致接口超时或性能下降，我们采用了分页与限流策略，有效地控制了每次请求的数据量。

5. **异常处理与错误重试机制**：针对可能出现的网络波动或接口响应异常，我们设计了一套完善的异常处理与错误重试机制。这不仅提高了系统对突发状况的应对能力，也保证了数据传输过程中的可靠性。

6. **可视化的数据流设计工具**：为了使整个数据集成过程更加直观和易于管理，我们利用平台提供的可视化工具进行数据流设计。这种方式不仅简化了配置工作，还使得后续维护变得更加便捷。

通过上述技术手段，本次案例成功实现了泛微OA-Http到金蝶云星空之间的数据无缝对接。在接下来的章节中，我们将详细探讨每个步骤中的具体实现方法及注意事项。
![用友BIP接口开发配置](https://pic.qeasy.cloud/D12.png)

![钉钉与ERP系统接口开发配置](https://pic.qeasy.cloud/QEASY/A39.png)

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

在轻易云数据集成平台的生命周期中，调用源系统接口是至关重要的第一步。本文将详细探讨如何通过泛微OA-Http接口`/api/workflow/paService/getWorkflowRequest`获取并加工数据，以实现高效的数据集成。

#### 接口配置与调用

首先，我们需要明确接口的元数据配置。根据提供的metadata，可以看到该接口使用GET方法进行查询操作，主要参数包括`workflowId`和`workflowIdList`。这些参数用于指定要查询的流程ID和方案ID。

```json
{
  "api": "/api/workflow/paService/getWorkflowRequest",
  "effect": "QUERY",
  "method": "GET",
  "number": "requestId",
  "id": "requestId",
  "name": "id",
  "idCheck": true,
  "request": [
    {"field":"workflowId","label":"e9流程id","type":"string","value":"481"},
    {"field":"workflowIdList","label":"workflowIdList中间方案ID","type":"string","value":"2356388e-8c49-35b3-bb7e-1eca1a8617d5"}
  ],
  "autoFillResponse": true,
  "condition":[
    [{"field":"workflowMainTableInfo.fklx","logic":"eqv2","value":"应付款"}],
    [{"field":"workflowMainTableInfo.fklx","logic":"eqv2","value":"Account Payable"}]
  ]
}
```

#### 数据请求与清洗

在实际操作中，通过上述配置发起HTTP GET请求后，我们会收到一个包含多个字段的数据响应。这些字段可能包括但不限于：流程ID、申请人信息、金额、日期等。在这个阶段，需要对接收到的数据进行初步清洗和过滤，以确保其符合业务需求。

例如，根据条件过滤器，我们只需保留那些付款类型为“应付款”或“Account Payable”的记录。这一步骤可以通过编写自定义逻辑来实现：

```python
def filter_data(data):
    return [record for record in data if record['fklx'] in ['应付款', 'Account Payable']]
```

#### 数据转换与写入准备

在完成初步清洗后，下一步是将数据转换为目标系统所需的格式。在本案例中，目标系统是金蝶云星空，因此需要特别注意两者之间的数据格式差异。例如，泛微OA中的日期格式可能需要转换为金蝶云星空所接受的标准ISO日期格式。

此外，还需要处理分页和限流问题。由于泛微OA-Http接口可能返回大量数据，为了避免超时或资源耗尽，需要对大批量数据进行分页处理，并设置合理的限流策略。

```python
def paginate_data(data, page_size):
    for i in range(0, len(data), page_size):
        yield data[i:i + page_size]
```

#### 实时监控与日志记录

为了确保整个过程透明且可追溯，轻易云平台提供了实时监控和日志记录功能。这些功能不仅能帮助我们及时发现并解决问题，还能提供详尽的数据处理历史记录，以便日后审计和优化。

通过集中监控界面，可以实时查看每个数据集成任务的状态，包括成功率、失败原因等。同时，告警系统会在检测到异常情况时立即通知相关人员，从而快速采取措施。

#### 异常处理与重试机制

在实际操作过程中，不可避免地会遇到网络波动、API限流等异常情况。为了保证数据不丢失，需要设计健壮的异常处理与重试机制。例如，在调用API失败时，可以设置一定次数的重试，并在多次尝试仍失败后，将错误记录到日志中以供进一步分析。

```python
import time

def call_api_with_retry(api_call, retries=3, delay=5):
    for attempt in range(retries):
        try:
            response = api_call()
            if response.status_code == 200:
                return response.json()
        except Exception as e:
            print(f"Attempt {attempt+1} failed: {str(e)}")
            time.sleep(delay)
    raise Exception("API call failed after multiple attempts")
```

通过以上步骤，我们能够高效地从泛微OA系统获取并加工所需的数据，为后续的数据转换与写入奠定坚实基础。在整个过程中，通过合理利用轻易云平台提供的各种特性，如高吞吐量支持、实时监控和告警、自定义转换逻辑等，可以显著提升业务效率和透明度。
![用友与CRM系统接口开发配置](https://pic.qeasy.cloud/S2.png)

![金蝶与CRM系统接口开发配置](https://pic.qeasy.cloud/QEASY/A71.png)

### 集成方案FD003-非生产性付款申请 泛微=>金蝶其他应付单--481的ETL转换

在数据集成生命周期的第二步，我们需要将已经从泛微OA-Http接口获取到的数据进行ETL（提取、转换、加载）处理，最终写入到金蝶云星空API接口中。以下是详细的技术实现和关键点。

#### 1. 数据提取与清洗
首先，从泛微OA-Http接口提取数据。我们使用定时任务可靠地抓取泛微OA-Http接口`/api/workflow/paService/getWorkflowRequest`的数据，确保数据的完整性和准确性。为了避免分页和限流问题，可以设置适当的分页参数，并在每次请求后进行短暂延迟。

#### 2. 数据转换
在数据转换阶段，我们需要将提取到的数据转换为金蝶云星空API所能接受的格式。这一过程涉及多个字段的映射和转换，以下是一些关键字段的处理方法：

- **单据类型 (FBillTypeID)**：
  使用固定值`QTYFD01_SYS`。

- **业务日期 (FDATE)**：
  直接映射泛微系统中的业务日期字段，如`{{workflowMainTableInfo.sqrq}}`。

- **往来单位类型 (FCONTACTUNITTYPE)**：
  根据不同类型（供应商、客户等），使用条件语句进行映射：
  ```plaintext
  _function case '{{detail_0.0.wldwlx_FV}}' 
    when '0' then 'BD_Supplier' 
    when '1' then 'BD_Customer' 
    when '3' then 'ORG_Organizations' 
    when '2' then 'FIN_OTHERS' 
  end
  ```

- **往来单位 (FCONTACTUNIT)**：
  同样根据不同类型，使用条件语句进行映射：
  ```plaintext
  _function case '{{detail_0.0.wldwlx_FV}}' 
    when '0' then '{{detail_0.0.gysbh}}' 
    when '1' then '{{detail_0.0.khbh}}' 
    when '3' then '{{detail_0.0.zzbh}}' 
    when '2' then '{{detail_0.0.qtwlbh}}'
  end
  ```

- **币别 (FCURRENCYID)**：
  使用查找集合方法，通过币别代码找到相应的编号：
  ```plaintext
  _findCollection find FNumber from collection_id where FCODE={{workflowMainTableInfo.bberp}}
  ```

#### 3. 数据写入
在完成数据转换后，将数据写入金蝶云星空API。我们使用批量保存接口`batchSave`，通过POST方法提交数据。以下是部分关键字段及其配置：

```plaintext
{
    "api": "batchSave",
    "method": "POST",
    "request": [
        {"field":"FBillTypeID","value":"QTYFD01_SYS"},
        {"field":"FBillNo","value":"{{workflowMainTableInfo.billNo}}"},
        {"field":"FDATE","value":"{{workflowMainTableInfo.sqrq}}"},
        {"field":"FCONTACTUNITTYPE","value":"..."},
        ...
    ]
}
```

此外，还需注意以下几点：

- **验证基础资料**：设置`IsVerifyBaseDataField`为true，以确保所有基础资料的有效性。
  
- **提交并审核**：设置`IsAutoSubmitAndAudit`为false，根据业务需求决定是否自动提交和审核。

#### 异常处理与监控
为确保整个ETL过程的稳定性，需要对异常情况进行处理，并实现错误重试机制。例如，在调用金蝶云星空API时，如果发生网络异常或返回错误码，可以通过重试策略重新发送请求。同时，通过轻易云提供的集中监控和告警系统，实时跟踪数据集成任务的状态和性能，及时发现并解决问题。

#### 自定义数据转换逻辑
根据具体业务需求，可以进一步定制化数据转换逻辑。例如，对于复杂的数据结构或特定业务场景，可以编写自定义脚本或函数来处理特定字段的数据转换。

通过上述步骤，我们能够高效地将从泛微OA-Http提取到的数据经过ETL处理后，无缝对接至金蝶云星空平台，实现了两大异构系统间的数据集成。
![电商OMS与ERP系统接口开发配置](https://pic.qeasy.cloud/T1.png)

![轻易云数据集成平台金蝶集成接口配置](https://pic.qeasy.cloud/QEASY/A50.png)

高效实现非生产性付款申请的数据集成