markdown

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

### 泛微OA-Http数据集成到金蝶云星空的技术案例分享

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

本次案例的集成方案名称为“FD003-非生产性付款申请 泛微=>金蝶其他应付单--484”。我们将重点探讨以下几个关键技术点：

1. **高吞吐量的数据写入能力**：为了确保大量数据能够快速被集成到泛微OA-Http系统中，我们利用了轻易云平台强大的数据写入能力。这不仅提升了数据处理的时效性，还保证了业务流程的顺畅运行。

2. **实时监控与告警系统**：在整个数据集成过程中，实时监控和告警系统发挥了重要作用。通过集中监控，我们可以实时跟踪每个数据集成任务的状态和性能，及时发现并解决潜在问题，确保数据流动的稳定性和可靠性。

3. **API资产管理功能**：泛微OA-Http与金蝶云星空API资产管理功能，通过统一视图和控制台，帮助我们全面掌握API资产的使用情况，实现资源的高效利用和优化配置。这一特性极大地简化了接口调用和管理过程，使得整个对接更加高效便捷。

4. **自定义数据转换逻辑**：由于泛微OA-Http与金蝶云星空之间存在一定的数据格式差异，我们采用了自定义的数据转换逻辑，以适应特定业务需求和数据结构。这种灵活性使得我们能够精准地映射并转换各类复杂的数据格式，从而保证最终写入目标平台的数据准确无误。

5. **分页与限流处理**：在调用泛微OA-Http接口（/api/workflow/paService/getWorkflowRequest）时，为了避免因大量请求导致接口超时或崩溃，我们设计了一套有效的分页与限流机制。这不仅提高了接口调用效率，还确保了每次请求都能成功返回所需数据。

6. **异常处理与错误重试机制**：针对金蝶云星空对接过程中可能出现的异常情况，我们实现了一套完善的错误重试机制。一旦发生错误，该机制会自动进行多次重试，并记录详细日志以供后续分析。这种设计大大提高了系统对突发状况的应对能力，保障了整体流程的不间断运行。

通过上述技术手段，本次案例成功实现了泛微OA-Http到金蝶云星空的数据无缝对接，为企业提供了一套高效、可靠的数据集成解决方案。接下来，我们将详细介绍具体实施步骤及相关技术细节。
![打通钉钉数据接口](https://pic.qeasy.cloud/D11.png)

![打通金蝶云星空数据接口](https://pic.qeasy.cloud/QEASY/A10.png)

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

在轻易云数据集成平台的生命周期中，第一步是调用源系统的API接口以获取原始数据，并对其进行初步加工处理。本文将详细探讨如何通过调用泛微OA-Http接口`/api/workflow/paService/getWorkflowRequest`来实现这一过程。

#### 接口调用配置

首先，我们需要配置元数据，以便正确地调用泛微OA-Http接口。根据提供的元数据配置，可以看到以下关键参数：

- **API路径**：`/api/workflow/paService/getWorkflowRequest`
- **请求方法**：GET
- **查询参数**：
  - `workflowId`: 固定值为"484"
  - `workflowIdList`: 固定值为"2356388e-8c49-35b3-bb7e-1eca1a8617d5"

此外，还需要注意两个条件：
1. `workflowMainTableInfo.fklx`等于“应付款”
2. `workflowMainTableInfo.fklx`等于“Account Payable”

这些条件用于过滤符合特定业务逻辑的数据。

#### 数据请求与清洗

在发起HTTP GET请求后，系统会返回一个包含多个字段的JSON响应。为了确保数据质量和准确性，需要对返回的数据进行清洗和预处理。这包括但不限于以下步骤：

1. **字段验证**：检查返回的数据是否包含必要的字段，如`requestId`、`workflowId`等。
2. **条件过滤**：根据预设条件过滤掉不符合要求的数据。例如，只保留那些`fklx`字段值为“应付款”或“Account Payable”的记录。
3. **格式转换**：将某些字段转换为目标系统所需的格式。例如，将日期字符串转换为标准日期格式。

#### 分页与限流处理

由于泛微OA可能会返回大量数据，因此需要考虑分页和限流问题。可以通过以下方式解决：

1. **分页参数**：在每次请求时添加分页参数，例如page和size，以分批次获取数据。
2. **限流机制**：设置合理的请求频率，避免触发源系统的限流策略。这可以通过轻易云平台内置的调度功能实现。

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

为了确保整个数据集成过程透明可控，轻易云平台提供了实时监控和日志记录功能。在调用泛微OA接口时，可以启用这些功能以跟踪每个请求的状态和性能指标。一旦出现异常情况，如网络超时或响应错误，可以及时告警并采取相应措施。

#### 自定义数据转换逻辑

不同系统之间的数据结构往往存在差异，因此需要自定义转换逻辑以适应目标系统的需求。例如，在将泛微OA的数据写入金蝶云星空之前，可能需要对某些字段进行重新映射或合并。轻易云平台支持用户编写自定义脚本，实现复杂的数据转换逻辑，从而满足特定业务需求。

### 总结

通过上述步骤，我们能够高效地从泛微OA系统中获取所需数据，并对其进行初步加工处理，为后续的数据集成奠定基础。在这个过程中，充分利用轻易云平台提供的各种工具和功能，可以显著提升工作效率和数据质量。
![电商OMS与WMS系统接口开发配置](https://pic.qeasy.cloud/S19.png)

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

### 集成方案FD003-非生产性付款申请 泛微=>金蝶其他应付单--484的数据转换与写入

在轻易云数据集成平台的生命周期中，数据转换和写入是关键步骤。本文将详细讨论如何将泛微OA-Http系统中的非生产性付款申请数据，通过ETL转换，写入到金蝶云星空的其他应付单API接口。

#### 数据转换的关键配置

为了实现有效的数据转换，我们需要对泛微OA-Http的数据进行解析、映射，并转化为金蝶云星空API接口所能接受的格式。以下是一些关键字段及其配置：

1. **单据类型 (FBillTypeID)**：
   ```json
   {"field":"FBillTypeID","value":"QTYFD01_SYS"}
   ```
   这里使用了固定值 "QTYFD01_SYS"，表示“其他应付单”。

2. **业务日期 (FDATE)**：
   ```json
   {"field":"FDATE","value":"{{workflowMainTableInfo.sqrq}}"}
   ```
   业务日期从源数据的 `sqrq` 字段获取。

3. **往来单位类型 (FCONTACTUNITTYPE)**：
   ```json
   {"field":"FCONTACTUNITTYPE","value":"_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"}
   ```
   根据 `wldwlx_FV` 字段值的不同，映射到相应的单位类型。

4. **往来单位 (FCONTACTUNIT)**：
   ```json
   {"field":"FCONTACTUNIT","value":"_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"}
   ```
   往来单位同样根据 `wldwlx_FV` 字段值，选择不同的字段进行赋值。

5. **币别 (FCURRENCYID)**：
   ```json
   {"field":"FCURRENCYID","value":"_findCollection find FNumber from 5740d4e3-ebe8-3548-9635-f35e1fdc983b where FCODE={{workflowMainTableInfo.bberp}}"}
   ```
   从一个预定义集合中查找币别代码，并进行转换。

6. **结算组织、采购组织、付款组织**：
   ```json
   {"field":"FSETTLEORGID","value":"{{workflowMainTableInfo.sqgs}}"}
   ```
    这三个字段都从 `sqgs` 字段获取，并通过 `ConvertObjectParser` 转换为目标系统所需格式。

#### 明细信息处理

对于明细信息，需要特别处理每一行数据的多层次嵌套结构：

1. **费用项目编码 (FCOSTID)**：
    ```json
    {"field":"FCOSTID","value":"_findCollection find FNumber from a3c8a497-8be0-36b3-956c-94619b971636 where FName={{detail_0.fyxmzl}}"}
    ```
    根据费用项目种类名称查询对应编码。

2. **发票类型 (FINVOICETYPE)**：
    ```json
    {"field":"FINVOICETYPE","value":"_function IF(('{{detail_0.sl}}'='6%') or ('{{detail_0.sl}}'='13%'),'1','0')"}
    ```
    根据税率判断发票类型，税率为6%或13%时，发票类型为“1”，否则为“0”。

3. **总金额 (FTOTALAMOUNTFOR)**：
    ```json
    {"field":"FTOTALAMOUNTFOR","value":"{{detail_0.tbje}}"}
    ```
    直接从明细中的 `tbje` 字段获取总金额。

4. **税额计算**：
    ```json
    {"field":"FTAXAMOUNTFOR","value":"_function round('{{detail_0.tbje}}'-('{{detail_0.tbje}}'\/(1+(REPLACE('{{detail_0.sl}}','%','')*0.01))),2)"}
    ```
    使用公式计算税额，并保留两位小数。

#### 批量数据写入

为了提高效率，我们采用批量写入的方式，将多个记录一次性提交到金蝶云星空：

```json
{"api":"batchSave","method":"POST","operation":{"rowsKey":"array","rows":1,"method":"batchArraySave"}}
```

此配置确保了高吞吐量的数据传输能力，能够快速将大量数据写入目标平台。同时，通过设置 `IsAutoSubmitAndAudit` 和 `IsVerifyBaseDataField` 参数，可以控制是否自动提交并审核，以及是否验证基础资料的有效性：

```json
{"field":"IsAutoSubmitAndAudit","value":"false"},
{"field":"IsVerifyBaseDataField","value":"true"}
```

#### 异常处理与监控

在实际操作中，可能会遇到各种异常情况，例如网络中断或数据格式错误。我们可以利用平台提供的实时监控和告警系统，对每个集成任务进行跟踪和日志记录。一旦发现问题，可以及时重试或人工干预，以确保数据集成过程的可靠性和准确性。

通过以上步骤，我们成功地将泛微OA-Http系统中的非生产性付款申请数据，经过ETL转换后，高效地写入到金蝶云星空系统，实现了两者之间的数据无缝对接。
![钉钉与MES系统接口开发配置](https://pic.qeasy.cloud/T22.png)

![如何对接钉钉API接口](https://pic.qeasy.cloud/QEASY/A108.png)

企业系统高效对接：从泛微OA到金蝶云的成功案例

泛微OA-Http数据集成到金蝶云星空的技术案例分享

本次案例的集成方案名称为“FD003-非生产性付款申请泛微=>金蝶其他应付单--484”。我们将重点探讨以下几个关键技术点：

高吞吐量的数据写入能力：为了确保大量数据能够快速被集成到泛微OA-Http系统中，我们利用了轻易云平台强大的数据写入能力。这不仅提升了数据处理的时效性，还保证了业务流程的顺畅运行。
实时监控与告警系统：在整个数据集成过程中，实时监控和告警系统发挥了重要作用。通过集中监控，我们可以实时跟踪每个数据集成任务的状态和性能，及时发现并解决潜在问题，确保数据流动的稳定性和可靠性。
API资产管理功能：泛微OA-Http与金蝶云星空API资产管理功能，通过统一视图和控制台，帮助我们全面掌握API资产的使用情况，实现资源的高效利用和优化配置。这一特性极大地简化了接口调用和管理过程，使得整个对接更加高效便捷。
自定义数据转换逻辑：由于泛微OA-Http与金蝶云星空之间存在一定的数据格式差异，我们采用了自定义的数据转换逻辑，以适应特定业务需求和数据结构。这种灵活性使得我们能够精准地映射并转换各类复杂的数据格式，从而保证最终写入目标平台的数据准确无误。
分页与限流处理：在调用泛微OA-Http接口（/api/workflow/paService/getWorkflowRequest）时，为了避免因大量请求导致接口超时或崩溃，我们设计了一套有效的分页与限流机制。这不仅提高了接口调用效率，还确保了每次请求都能成功返回所需数据。
异常处理与错误重试机制：针对金蝶云星空对接过程中可能出现的异常情况，我们实现了一套完善的错误重试机制。一旦发生错误，该机制会自动进行多次重试，并记录详细日志以供后续分析。这种设计大大提高了系统对突发状况的应对能力，保障了整体流程的不间断运行。

通过上述技术手段，本次案例成功实现了泛微OA-Http到金蝶云星空的数据无缝对接，为企业提供了一套高效、可靠的数据集成解决方案。接下来，我们将详细介绍具体实施步骤及相关技术细节。打通钉钉数据接口

打通金蝶云星空数据接口

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

在轻易云数据集成平台的生命周期中，第一步是调用源系统的API接口以获取原始数据，并对其进行初步加工处理。本文将详细探讨如何通过调用泛微OA-Http接口/api/workflow/paService/getWorkflowRequest来实现这一过程。

接口调用配置

首先，我们需要配置元数据，以便正确地调用泛微OA-Http接口。根据提供的元数据配置，可以看到以下关键参数：

API路径：/api/workflow/paService/getWorkflowRequest
请求方法：GET
查询参数：
- workflowId: 固定值为"484"
- workflowIdList: 固定值为"2356388e-8c49-35b3-bb7e-1eca1a8617d5"

此外，还需要注意两个条件：

workflowMainTableInfo.fklx等于“应付款”
workflowMainTableInfo.fklx等于“Account Payable”

这些条件用于过滤符合特定业务逻辑的数据。

数据请求与清洗

字段验证：检查返回的数据是否包含必要的字段，如requestId、workflowId等。
条件过滤：根据预设条件过滤掉不符合要求的数据。例如，只保留那些fklx字段值为“应付款”或“Account Payable”的记录。
格式转换：将某些字段转换为目标系统所需的格式。例如，将日期字符串转换为标准日期格式。

分页与限流处理

由于泛微OA可能会返回大量数据，因此需要考虑分页和限流问题。可以通过以下方式解决：

分页参数：在每次请求时添加分页参数，例如page和size，以分批次获取数据。
限流机制：设置合理的请求频率，避免触发源系统的限流策略。这可以通过轻易云平台内置的调度功能实现。

实时监控与日志记录

自定义数据转换逻辑

总结

通过上述步骤，我们能够高效地从泛微OA系统中获取所需数据，并对其进行初步加工处理，为后续的数据集成奠定基础。在这个过程中，充分利用轻易云平台提供的各种工具和功能，可以显著提升工作效率和数据质量。电商OMS与WMS系统接口开发配置

泛微OA与ERP系统接口开发配置

集成方案FD003-非生产性付款申请泛微=>金蝶其他应付单--484的数据转换与写入

数据转换的关键配置

为了实现有效的数据转换，我们需要对泛微OA-Http的数据进行解析、映射，并转化为金蝶云星空API接口所能接受的格式。以下是一些关键字段及其配置：

单据类型 (FBillTypeID)：
```
{"field":"FBillTypeID","value":"QTYFD01_SYS"}
```
这里使用了固定值 "QTYFD01_SYS"，表示“其他应付单”。
业务日期 (FDATE)：
```
{"field":"FDATE","value":"{{workflowMainTableInfo.sqrq}}"}
```
业务日期从源数据的 sqrq 字段获取。

往来单位类型 (FCONTACTUNITTYPE)：

{"field":"FCONTACTUNITTYPE","value":"_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"}

根据 wldwlx_FV 字段值的不同，映射到相应的单位类型。

往来单位 (FCONTACTUNIT)：

{"field":"FCONTACTUNIT","value":"_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"}

往来单位同样根据 wldwlx_FV 字段值，选择不同的字段进行赋值。

币别 (FCURRENCYID)：

{"field":"FCURRENCYID","value":"_findCollection find FNumber from 5740d4e3-ebe8-3548-9635-f35e1fdc983b where FCODE={{workflowMainTableInfo.bberp}}"}

从一个预定义集合中查找币别代码，并进行转换。

结算组织、采购组织、付款组织：
```
{"field":"FSETTLEORGID","value":"{{workflowMainTableInfo.sqgs}}"}
```
这三个字段都从 sqgs 字段获取，并通过 ConvertObjectParser 转换为目标系统所需格式。

明细信息处理

对于明细信息，需要特别处理每一行数据的多层次嵌套结构：

费用项目编码 (FCOSTID)：

{"field":"FCOSTID","value":"_findCollection find FNumber from a3c8a497-8be0-36b3-956c-94619b971636 where FName={{detail_0.fyxmzl}}"}

根据费用项目种类名称查询对应编码。

发票类型 (FINVOICETYPE)：
```
{"field":"FINVOICETYPE","value":"_function IF(('{{detail_0.sl}}'='6%') or ('{{detail_0.sl}}'='13%'),'1','0')"}
```
根据税率判断发票类型，税率为6%或13%时，发票类型为“1”，否则为“0”。
总金额 (FTOTALAMOUNTFOR)：
```
{"field":"FTOTALAMOUNTFOR","value":"{{detail_0.tbje}}"}
```
直接从明细中的 tbje 字段获取总金额。

税额计算：

{"field":"FTAXAMOUNTFOR","value":"_function round('{{detail_0.tbje}}'-('{{detail_0.tbje}}'\/(1+(REPLACE('{{detail_0.sl}}','%','')*0.01))),2)"}

使用公式计算税额，并保留两位小数。

批量数据写入