markdown

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

### 金蝶云星空数据集成案例分享：销售出库-标准销售出库-分销组【浩悦&鼎骏电子】OK

在本次技术案例中，我们将探讨如何通过轻易云数据集成平台，实现金蝶云星空系统之间的高效数据对接。具体方案为“销售出库-标准销售出库-分销组【浩悦&鼎骏电子】OK”，旨在确保两个金蝶云星空系统间的数据无缝流转。

首先，针对大量数据的快速写入需求，我们利用了金蝶云星空的`batchSave` API接口。这一接口支持高吞吐量的数据写入能力，使得我们能够在短时间内将大量销售出库数据准确地传输到目标系统中，从而提升了整体业务处理的时效性。

为了确保集成过程中的数据质量和可靠性，我们引入了集中监控和告警系统。该系统实时跟踪每个数据集成任务的状态和性能，一旦发现异常情况，能够及时发出告警并进行处理。此外，通过自定义的数据转换逻辑，我们有效解决了源系统与目标系统之间可能存在的数据结构差异问题，确保每条记录都能正确映射和存储。

在获取源系统数据方面，我们使用了金蝶云星空的`executeBillQuery` API接口。此接口不仅支持定时可靠地抓取所需数据，还能处理分页和限流问题，保证在高并发环境下依然能够稳定运行。同时，为了防止漏单现象发生，我们设计了一套完善的数据校验机制，对每次抓取的数据进行严格比对和验证。

最后，通过可视化的数据流设计工具，我们将整个集成流程清晰地展示出来，使得管理和维护变得更加直观和简便。这种全透明可视化操作界面，不仅提高了业务透明度，也极大提升了工作效率。

接下来，将详细介绍具体实现步骤及技术细节。
![钉钉与CRM系统接口开发配置](https://pic.qeasy.cloud/D25.png)

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

### 调用金蝶云星空接口executeBillQuery获取并加工数据

在轻易云数据集成平台的生命周期中，调用源系统接口是关键的第一步。本文将详细探讨如何通过executeBillQuery接口从金蝶云星空获取销售出库单据，并进行初步的数据加工处理。

#### 接口调用配置

首先，我们需要配置元数据以便正确调用金蝶云星空的executeBillQuery接口。以下是一些关键配置项：

- **API**: `executeBillQuery`
- **Method**: `POST`
- **FormId**: `SAL_OUTSTOCK`（业务对象表单ID）
- **Pagination**: 支持分页，每页500条记录
- **FilterString**: 过滤条件，例如：`FApproveDate>='{{LAST_SYNC_TIME|date}}' and FCustomerID.FGroup = '分销运营部' and FDate >='2024-07-01 00:00:00'`

这些配置确保我们能够高效地从金蝶云星空中提取所需的数据。

#### 请求参数设置

为了准确获取所需数据，我们需要设置请求参数。这些参数包括单据类型、单据编号、日期等关键信息。例如：

```json
{
    "FBillTypeID_FNumber": "FBillTypeID.FNumber",
    "FBillNo": "FBillNo",
    "FDate": "FDate",
    "FApproveDate": "FApproveDate",
    ...
}
```

这些字段涵盖了销售出库单据的各个方面，确保我们能够全面获取和分析数据。

#### 数据格式化与转换

在获取到原始数据后，需要对部分字段进行格式化和转换。例如，将审核时间字段`FApproveDate`重新命名为`FApproveDate_new`并格式化为日期类型：

```json
"formatResponse": [
    {"old":"FApproveDate","new":"FApproveDate_new","format":"date"}
]
```

这种方式使得数据更符合业务需求，便于后续处理和分析。

#### 分页与限流处理

由于可能存在大量数据，我们必须考虑分页与限流问题。通过设置分页参数如每页500条记录，可以有效控制每次请求的数据量，避免超时或服务器压力过大。同时，通过检查返回结果中的总行数和当前行索引，可以实现自动分页抓取：

```json
"pagination": {
    "pageSize": 500
},
"otherRequest": [
    {"field":"Limit", "value":"{PAGINATION_PAGE_SIZE}"},
    {"field":"StartRow", "value":"{PAGINATION_START_ROW}"}
]
```

这种机制确保了大规模数据的稳定、高效抓取。

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

在实际操作中，不可避免会遇到网络波动或接口响应异常等问题。因此，需要设计健壮的异常处理与重试机制。例如，当请求失败时，可以捕获错误信息并进行适当的重试，以保证数据抓取过程的连续性和完整性。

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

为了确保整个过程透明可控，需要实时监控任务状态并记录日志。这不仅有助于及时发现问题，还能为后续优化提供依据。轻易云平台提供了集中的监控和告警系统，可以实时跟踪任务状态和性能指标。

通过上述步骤，我们可以高效地调用金蝶云星空接口executeBillQuery，获取并加工销售出库单据的数据。这一过程不仅提高了数据集成效率，也为后续的数据转换与写入奠定了坚实基础。
![泛微OA与ERP系统接口开发配置](https://pic.qeasy.cloud/S21.png)

![金蝶云星空API接口配置](https://pic.qeasy.cloud/QEASY/A66.png)

### 集成方案:销售出库-标准销售出库-分销组【浩悦&鼎骏电子】OK

在数据集成的生命周期中，将源平台的数据进行ETL转换是至关重要的一步。本文将详细探讨如何利用轻易云数据集成平台，将已经集成的源平台数据转换为金蝶云星空API接口所能接收的格式，并最终写入目标平台。

#### 数据请求与清洗

首先，我们需要从源系统提取销售出库数据。通过轻易云的数据请求功能，可以高效地抓取相关数据，并进行初步清洗。这一步确保了数据的准确性和一致性，为后续的ETL过程奠定了基础。

#### 数据转换与写入

在数据转换阶段，我们需要将清洗后的数据按照金蝶云星空API接口的要求进行格式化处理。以下是关键步骤和技术细节：

1. **API配置**

根据提供的元数据配置，我们使用`batchSave` API进行批量保存操作。此API通过POST方法提交，支持高吞吐量的数据写入，确保大量数据能够快速被集成到金蝶云星空系统中。

2. **字段映射与转换**

在字段映射过程中，利用元数据中的配置，可以实现对字段的精准转换。例如，`FBillTypeID`字段通过`ConvertObjectParser`解析器，将其值转换为目标系统所需的格式：

```json
   {"field":"FBillTypeID","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"XSCKD01_SYS"}
   ```

类似地，对于日期字段`FDate`，我们使用SQL函数进行条件判断和格式化处理，以确保日期格式符合目标系统要求：

```json
   {"field":"FDate","value":"_function CASE WHEN DAY(STR_TO_DATE('{FDate}', '%Y-%m-%d')) BETWEEN 26 AND DAY(LAST_DAY(STR_TO_DATE('{FDate}', '%Y-%m-%d'))) THEN DATE_FORMAT(DATE_ADD(STR_TO_DATE('{FDate}', '%Y-%m-%d'), INTERVAL 1 MONTH), '%Y-%m-01') ELSE STR_TO_DATE('{FDate}', '%Y-%m-%d') end"}
   ```

3. **子实体处理**

对于包含复杂结构的子实体，如财务信息和明细信息，需要特别注意其嵌套结构。在元数据配置中，通过定义子实体及其子字段，实现层级化的数据映射。例如，明细信息中的物料编码、实发数量等字段需要逐一映射并转换：

```json
   {"field":"FEntity","children":[{"field":"FMaterialID","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"{{details.FMaterialID_FNumber}}"},{"field":"FRealQty","value":"{{details.FRealQty}}"},{"field":"FTaxPrice","value":"{{details.FTaxPrice}}"}]}
   ```

4. **业务逻辑嵌入**

在特定业务场景下，需要嵌入自定义逻辑以适应业务需求。例如，根据客户名称动态选择仓库编码：

```json
   {"field":"FStockID","value":"_function case when '{{FCustomerID.FName}}' like '%京东%' then 'CK001' when '{{FCustomerID.FName}}' like '%唯品会%' then 'CK002' else 'CK001' end"}
   ```

5. **异常处理与重试机制**

为了保证数据集成的可靠性，需要实现异常处理与重试机制。当接口调用失败时，通过捕获异常并记录日志，及时发现问题并自动重试，从而提高系统的稳定性。

6. **实时监控与日志记录**

通过轻易云提供的集中监控和告警系统，可以实时跟踪数据集成任务的状态和性能。一旦发现异常情况，系统会立即发出告警通知，以便及时处理。

7. **提交与审核**

最后，将转换后的数据通过API提交至金蝶云星空，并根据需要选择是否自动提交和审核：

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

#### 总结

通过以上步骤，我们实现了从源平台到金蝶云星空的高效ETL转换。在整个过程中，充分利用了轻易云的数据集成能力，包括高吞吐量的数据写入、自定义逻辑嵌入、异常处理与实时监控等特性，为企业的数据集成提供了强有力的技术支持。
![金蝶云星空API接口配置](https://pic.qeasy.cloud/T26.png)

![用友与外部系统接口集成开发](https://pic.qeasy.cloud/QEASY/A22.png)

高效实现金蝶云星空数据集成案例解析

金蝶云星空数据集成案例分享：销售出库-标准销售出库-分销组【浩悦&鼎骏电子】OK

首先，针对大量数据的快速写入需求，我们利用了金蝶云星空的batchSave API接口。这一接口支持高吞吐量的数据写入能力，使得我们能够在短时间内将大量销售出库数据准确地传输到目标系统中，从而提升了整体业务处理的时效性。

在获取源系统数据方面，我们使用了金蝶云星空的executeBillQuery API接口。此接口不仅支持定时可靠地抓取所需数据，还能处理分页和限流问题，保证在高并发环境下依然能够稳定运行。同时，为了防止漏单现象发生，我们设计了一套完善的数据校验机制，对每次抓取的数据进行严格比对和验证。

接下来，将详细介绍具体实现步骤及技术细节。钉钉与CRM系统接口开发配置

钉钉与WMS系统接口开发配置

调用金蝶云星空接口executeBillQuery获取并加工数据

接口调用配置

首先，我们需要配置元数据以便正确调用金蝶云星空的executeBillQuery接口。以下是一些关键配置项：

API: executeBillQuery
Method: POST
FormId: SAL_OUTSTOCK（业务对象表单ID）
Pagination: 支持分页，每页500条记录
FilterString: 过滤条件，例如：FApproveDate>='{{LAST_SYNC_TIME|date}}' and FCustomerID.FGroup = '分销运营部' and FDate >='2024-07-01 00:00:00'

这些配置确保我们能够高效地从金蝶云星空中提取所需的数据。

请求参数设置

为了准确获取所需数据，我们需要设置请求参数。这些参数包括单据类型、单据编号、日期等关键信息。例如：

{
    "FBillTypeID_FNumber": "FBillTypeID.FNumber",
    "FBillNo": "FBillNo",
    "FDate": "FDate",
    "FApproveDate": "FApproveDate",
    ...
}

这些字段涵盖了销售出库单据的各个方面，确保我们能够全面获取和分析数据。

数据格式化与转换

在获取到原始数据后，需要对部分字段进行格式化和转换。例如，将审核时间字段FApproveDate重新命名为FApproveDate_new并格式化为日期类型：

"formatResponse": [
    {"old":"FApproveDate","new":"FApproveDate_new","format":"date"}
]

这种方式使得数据更符合业务需求，便于后续处理和分析。

分页与限流处理

"pagination": {
    "pageSize": 500
},
"otherRequest": [
    {"field":"Limit", "value":"{PAGINATION_PAGE_SIZE}"},
    {"field":"StartRow", "value":"{PAGINATION_START_ROW}"}
]

这种机制确保了大规模数据的稳定、高效抓取。

异常处理与重试机制

实时监控与日志记录

通过上述步骤，我们可以高效地调用金蝶云星空接口executeBillQuery，获取并加工销售出库单据的数据。这一过程不仅提高了数据集成效率，也为后续的数据转换与写入奠定了坚实基础。泛微OA与ERP系统接口开发配置

金蝶云星空API接口配置

集成方案:销售出库-标准销售出库-分销组【浩悦&鼎骏电子】OK

数据请求与清洗

数据转换与写入

在数据转换阶段，我们需要将清洗后的数据按照金蝶云星空API接口的要求进行格式化处理。以下是关键步骤和技术细节：

API配置

根据提供的元数据配置，我们使用batchSave API进行批量保存操作。此API通过POST方法提交，支持高吞吐量的数据写入，确保大量数据能够快速被集成到金蝶云星空系统中。

字段映射与转换

在字段映射过程中，利用元数据中的配置，可以实现对字段的精准转换。例如，FBillTypeID字段通过ConvertObjectParser解析器，将其值转换为目标系统所需的格式：

{"field":"FBillTypeID","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"XSCKD01_SYS"}

类似地，对于日期字段FDate，我们使用SQL函数进行条件判断和格式化处理，以确保日期格式符合目标系统要求：

{"field":"FDate","value":"_function CASE WHEN DAY(STR_TO_DATE('{FDate}', '%Y-%m-%d')) BETWEEN 26 AND DAY(LAST_DAY(STR_TO_DATE('{FDate}', '%Y-%m-%d'))) THEN DATE_FORMAT(DATE_ADD(STR_TO_DATE('{FDate}', '%Y-%m-%d'), INTERVAL 1 MONTH), '%Y-%m-01') ELSE STR_TO_DATE('{FDate}', '%Y-%m-%d') end"}

子实体处理

对于包含复杂结构的子实体，如财务信息和明细信息，需要特别注意其嵌套结构。在元数据配置中，通过定义子实体及其子字段，实现层级化的数据映射。例如，明细信息中的物料编码、实发数量等字段需要逐一映射并转换：
```
{"field":"FEntity","children":[{"field":"FMaterialID","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"{{details.FMaterialID_FNumber}}"},{"field":"FRealQty","value":"{{details.FRealQty}}"},{"field":"FTaxPrice","value":"{{details.FTaxPrice}}"}]}
```

业务逻辑嵌入

在特定业务场景下，需要嵌入自定义逻辑以适应业务需求。例如，根据客户名称动态选择仓库编码：

{"field":"FStockID","value":"_function case when '{{FCustomerID.FName}}' like '%京东%' then 'CK001' when '{{FCustomerID.FName}}' like '%唯品会%' then 'CK002' else 'CK001' end"}

异常处理与重试机制

为了保证数据集成的可靠性，需要实现异常处理与重试机制。当接口调用失败时，通过捕获异常并记录日志，及时发现问题并自动重试，从而提高系统的稳定性。
实时监控与日志记录

通过轻易云提供的集中监控和告警系统，可以实时跟踪数据集成任务的状态和性能。一旦发现异常情况，系统会立即发出告警通知，以便及时处理。
提交与审核

最后，将转换后的数据通过API提交至金蝶云星空，并根据需要选择是否自动提交和审核：
```
{"field":"IsAutoSubmitAndAudit","value":"false"}
```

总结

通过以上步骤，我们实现了从源平台到金蝶云星空的高效ETL转换。在整个过程中，充分利用了轻易云的数据集成能力，包括高吞吐量的数据写入、自定义逻辑嵌入、异常处理与实时监控等特性，为企业的数据集成提供了强有力的技术支持。金蝶云星空API接口配置

用友与外部系统接口集成开发