markdown

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

### 金蝶云星空数据集成案例分享：采购入库单（除了委外，不含艾尔时）OK 目前在用

在企业的日常运营中，采购入库单的数据处理和管理是一个至关重要的环节。为了提升数据处理的效率和准确性，我们采用了金蝶云星空平台进行系统对接与集成。本次技术案例将详细介绍如何通过轻易云数据集成平台，将采购入库单数据从一个金蝶云星空系统高效、可靠地集成到另一个金蝶云星空系统中。

首先，我们需要解决的是如何确保大量采购入库单数据能够快速且无遗漏地写入目标金蝶云星空系统。为此，我们利用了金蝶云星空强大的高吞吐量数据写入能力，通过`batchSave` API接口实现批量数据写入。这不仅大幅度提升了数据处理的时效性，还有效减少了因网络波动或其他异常情况导致的数据丢失风险。

其次，为了实时监控和跟踪整个数据集成过程，我们引入了集中监控和告警系统。该系统能够实时监测每个数据集成任务的状态和性能，及时发现并处理潜在问题，确保整个流程透明可控。此外，通过轻易云提供的可视化数据流设计工具，我们可以直观地设计和管理复杂的数据流，使得整个集成过程更加清晰明了。

在实际操作过程中，调用金蝶云星空的`executeBillQuery`接口来定时抓取源系统中的采购入库单数据，并通过自定义的数据转换逻辑适应特定业务需求和数据结构。这种灵活性使得我们能够根据具体业务场景进行调整，从而保证最终写入目标系统的数据质量和一致性。

最后，为了解决分页和限流问题，我们设计了一套完善的异常处理与错误重试机制。在面对大规模数据传输时，这一机制能够有效避免因接口调用频率过高而导致的请求失败，从而保障整个集成流程的稳定运行。

通过上述技术手段，本次采购入库单（除了委外，不含艾尔时）OK方案成功实现了从一个金蝶云星空系统到另一个金蝶云星空系统的数据无缝对接，大幅提升了企业的数据处理效率与准确性。
![用友与WMS系统接口开发配置](https://pic.qeasy.cloud/D39.png)

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

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

在轻易云数据集成平台中，调用源系统金蝶云星空接口`executeBillQuery`是数据集成生命周期的第一步。此步骤至关重要，因为它决定了后续数据处理和写入的质量和效率。

#### 接口配置与调用

首先，我们需要配置元数据以便正确调用`executeBillQuery`接口。以下是关键配置项：

- **API**: `executeBillQuery`
- **方法**: `POST`
- **分页参数**: 每页500条记录
- **表单ID**: `STK_InStock`

这些配置确保我们能够高效地从金蝶云星空系统中提取采购入库单的数据。

#### 请求参数设置

为了准确获取所需的数据，我们需要设置请求参数。这些参数包括但不限于：

- **实体主键** (`FID`)
- **单据编号** (`FBillNo`)
- **入库日期** (`FDate`)
- **供应商名称** (`FSupplierId.FName`)
  
此外，还需要设置分页参数，如最大行数（Limit）和开始行索引（StartRow），以处理大批量数据的分页查询。

```json
{
  "FormId": "STK_InStock",
  "FieldKeys": "FID,FBillNo,FDate,FSupplierId.FName",
  "FilterString": "FDate >= '{{LAST_SYNC_TIME|date}}' and FBillTypeID.FNumber <> 'RKD03_SYS' and FBillTypeID.FNumber<>'RKD17_SYS' and FSupplierId.FName NOT LIKE '%虚拟组织%' and FSupplierId.FName<> 'G0175'",
  "Limit": 500,
  "StartRow": 0
}
```

#### 数据清洗与转换

在获取到原始数据后，需要进行清洗和转换，以确保其符合目标系统的要求。例如，可能需要将日期格式统一、去除无效字符或补全缺失字段。轻易云平台提供了强大的自定义数据转换逻辑，可以根据具体业务需求进行调整。

##### 示例：日期格式转换

假设我们从金蝶云星空获取的日期格式为`YYYY-MM-DD`，而目标系统要求为`DD/MM/YYYY`，可以通过以下方式进行转换：

```python
def convert_date_format(date_str):
    from datetime import datetime
    date_obj = datetime.strptime(date_str, '%Y-%m-%d')
    return date_obj.strftime('%d/%m/%Y')
```

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

在调用接口过程中，可能会遇到网络波动、接口限流等问题。轻易云平台内置了异常处理与重试机制，可以自动检测并重新尝试失败的请求，从而提高整体稳定性。

##### 示例：重试机制实现

```python
import time

def fetch_data_with_retry(api_call, max_retries=3):
    retries = 0
    while retries < max_retries:
        try:
            response = api_call()
            if response.status_code == 200:
                return response.json()
        except Exception as e:
            retries += 1
            time.sleep(2) # 等待2秒后重试
    raise Exception("Max retries reached")
```

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

为了确保整个过程透明可控，轻易云平台提供了实时监控和日志记录功能。每次API调用、数据清洗和转换操作都会被详细记录，并且可以通过集中控制台进行查看和分析。这有助于快速定位问题并采取相应措施。

综上所述，通过合理配置元数据、精确设置请求参数、有效的数据清洗与转换，以及健全的异常处理机制，我们可以高效地从金蝶云星空系统中提取并加工采购入库单的数据，为后续的数据写入打下坚实基础。
![金蝶与外部系统打通接口](https://pic.qeasy.cloud/S25.png)

![如何对接用友BIP接口](https://pic.qeasy.cloud/QEASY/A17.png)

### 集成采购入库单数据至金蝶云星空的ETL转换技术详解

在数据集成过程中，ETL（Extract, Transform, Load）转换是一个关键步骤，特别是在将源平台数据转化为目标平台所需的特定格式时。本文将深入探讨如何使用轻易云数据集成平台，将采购入库单的数据进行ETL转换，并通过金蝶云星空API接口写入目标系统。

#### 数据转换与写入的流程

在本案例中，我们需要将采购入库单的数据转化为金蝶云星空API能够接收的格式，并最终写入目标平台。以下是具体的步骤和技术细节：

1. **数据抽取（Extract）**：从源系统中获取原始采购入库单数据。
2. **数据清洗（Clean）**：对抽取的数据进行清洗，确保其完整性和一致性。
3. **数据转换（Transform）**：根据金蝶云星空API的要求，对数据结构和内容进行转换。
4. **数据加载（Load）**：将转换后的数据通过API接口批量写入金蝶云星空系统。

#### 元数据配置解析

元数据配置是ETL过程中至关重要的一部分，它定义了如何从源系统提取数据、如何转换以及如何加载到目标系统。以下是本案例中的关键元数据配置：

```json
{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "FBillNo,FDate,FSupplierId_FName,FSettleCurrId_FNumber,FPurchaseOrgId_FNumber",
    "bodyName": "details",
    "header": ["FBillNo", "FDate", "FSupplierId_FName", "FSettleCurrId_FNumber", "FPurchaseOrgId_FNumber", "FExchangeRate"],
    "body": ["FMaterialId_FNumber", "FRealQty", "FTaxPrice", "FAllAmount", "FDiscount", "FPurchaseOrgId_FNumber"]
  },
  ...
}
```

以上配置定义了调用`batchSave` API时需要使用的HTTP方法、检查ID的方式以及操作类型等基本信息。

#### 数据字段映射与转换

在进行ETL转换时，需要特别注意字段的映射和内容的转换。例如，采购组织字段`FPurchaseOrgId`需要根据不同条件进行映射：

```json
{
  "field": "FPurchaseOrgId",
  "label": "采购组织",
  ...
  "value": "_function case when '{FPurchaseOrgId_FNumber}' ='100' then '125' when '{FPurchaseOrgId_FNumber}' ='202' then '126' when '{FPurchaseOrgId_FNumber}' ='204' then '127' else '109' end"
}
```

这种映射逻辑确保了不同采购组织代码能够正确地转换为目标系统所需的值。

#### 金蝶云星空API接口调用

为了将转换后的数据写入金蝶云星空，我们需要调用其提供的API接口。在本案例中，使用的是`batchSave`接口，该接口支持高吞吐量的数据写入能力，能够快速处理大量采购入库单的数据。

```json
{
  ...
  "otherRequest": [
    {"field":"FormId","label":"业务对象表单Id","type":"string","describe":"必须填写金蝶的表单ID如:PUR_PurchaseOrder","value":"STK_InStock"},
    {"field":"IsAutoSubmitAndAudit","label":"提交并审核","type":"bool","value":"false"},
    {"field":"Operation","label":"执行的操作","type":"string","value":"Save"},
    {"field":"IsVerifyBaseDataField","label":"验证基础资料","type":"bool","describe":"是否验证所有的基础资料有效性，布尔类，默认false（非必录）","value":"true"},
    {"field":"SubSystemId","label":"系统模块","type":"string","describe":"默认仓库模块","value":"21"}
  ]
}
```

上述配置指定了业务对象表单ID、是否自动提交并审核、执行操作类型等关键参数。

#### 数据质量监控与异常处理

在ETL过程中，为确保数据质量和可靠性，需要实施实时监控和异常处理机制。轻易云平台提供了集中监控和告警系统，可以实时跟踪每个集成任务的状态和性能。一旦检测到异常，如网络故障或数据格式错误，可以立即触发告警并启动重试机制，确保数据不漏单且准确无误地写入金蝶云星空。

#### 总结

通过上述步骤，我们实现了从源平台到金蝶云星空的数据ETL转换，并成功将采购入库单的数据写入目标系统。在这个过程中，利用元数据配置实现了灵活的数据映射与转换，通过调用高效可靠的API接口完成了大批量数据的快速写入，同时借助实时监控和异常处理机制保障了整个过程的稳定性和可靠性。
![金蝶与CRM系统接口开发配置](https://pic.qeasy.cloud/T4.png)

![如何开发金蝶云星空API接口](https://pic.qeasy.cloud/QEASY/A109.png)

通过金蝶云星空平台高效集成采购入库单数据

金蝶云星空数据集成案例分享：采购入库单（除了委外，不含艾尔时）OK 目前在用

首先，我们需要解决的是如何确保大量采购入库单数据能够快速且无遗漏地写入目标金蝶云星空系统。为此，我们利用了金蝶云星空强大的高吞吐量数据写入能力，通过batchSave API接口实现批量数据写入。这不仅大幅度提升了数据处理的时效性，还有效减少了因网络波动或其他异常情况导致的数据丢失风险。

在实际操作过程中，调用金蝶云星空的executeBillQuery接口来定时抓取源系统中的采购入库单数据，并通过自定义的数据转换逻辑适应特定业务需求和数据结构。这种灵活性使得我们能够根据具体业务场景进行调整，从而保证最终写入目标系统的数据质量和一致性。

通过上述技术手段，本次采购入库单（除了委外，不含艾尔时）OK方案成功实现了从一个金蝶云星空系统到另一个金蝶云星空系统的数据无缝对接，大幅提升了企业的数据处理效率与准确性。用友与WMS系统接口开发配置

轻易云数据集成平台金蝶集成接口配置

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

在轻易云数据集成平台中，调用源系统金蝶云星空接口executeBillQuery是数据集成生命周期的第一步。此步骤至关重要，因为它决定了后续数据处理和写入的质量和效率。

接口配置与调用

首先，我们需要配置元数据以便正确调用executeBillQuery接口。以下是关键配置项：

API: executeBillQuery
方法: POST
分页参数: 每页500条记录
表单ID: STK_InStock

这些配置确保我们能够高效地从金蝶云星空系统中提取采购入库单的数据。

请求参数设置

为了准确获取所需的数据，我们需要设置请求参数。这些参数包括但不限于：

实体主键 (FID)
单据编号 (FBillNo)
入库日期 (FDate)
供应商名称 (FSupplierId.FName)

此外，还需要设置分页参数，如最大行数（Limit）和开始行索引（StartRow），以处理大批量数据的分页查询。

{
  "FormId": "STK_InStock",
  "FieldKeys": "FID,FBillNo,FDate,FSupplierId.FName",
  "FilterString": "FDate >= '{{LAST_SYNC_TIME|date}}' and FBillTypeID.FNumber <> 'RKD03_SYS' and FBillTypeID.FNumber<>'RKD17_SYS' and FSupplierId.FName NOT LIKE '%虚拟组织%' and FSupplierId.FName<> 'G0175'",
  "Limit": 500,
  "StartRow": 0
}

数据清洗与转换

示例：日期格式转换

假设我们从金蝶云星空获取的日期格式为YYYY-MM-DD，而目标系统要求为DD/MM/YYYY，可以通过以下方式进行转换：

def convert_date_format(date_str):
    from datetime import datetime
    date_obj = datetime.strptime(date_str, '%Y-%m-%d')
    return date_obj.strftime('%d/%m/%Y')

异常处理与重试机制

示例：重试机制实现

import time

def fetch_data_with_retry(api_call, max_retries=3):
    retries = 0
    while retries < max_retries:
        try:
            response = api_call()
            if response.status_code == 200:
                return response.json()
        except Exception as e:
            retries += 1
            time.sleep(2) # 等待2秒后重试
    raise Exception("Max retries reached")

实时监控与日志记录

综上所述，通过合理配置元数据、精确设置请求参数、有效的数据清洗与转换，以及健全的异常处理机制，我们可以高效地从金蝶云星空系统中提取并加工采购入库单的数据，为后续的数据写入打下坚实基础。金蝶与外部系统打通接口

如何对接用友BIP接口

集成采购入库单数据至金蝶云星空的ETL转换技术详解

数据转换与写入的流程

在本案例中，我们需要将采购入库单的数据转化为金蝶云星空API能够接收的格式，并最终写入目标平台。以下是具体的步骤和技术细节：

数据抽取（Extract）：从源系统中获取原始采购入库单数据。
数据清洗（Clean）：对抽取的数据进行清洗，确保其完整性和一致性。
数据转换（Transform）：根据金蝶云星空API的要求，对数据结构和内容进行转换。
数据加载（Load）：将转换后的数据通过API接口批量写入金蝶云星空系统。

元数据配置解析

元数据配置是ETL过程中至关重要的一部分，它定义了如何从源系统提取数据、如何转换以及如何加载到目标系统。以下是本案例中的关键元数据配置：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "FBillNo,FDate,FSupplierId_FName,FSettleCurrId_FNumber,FPurchaseOrgId_FNumber",
    "bodyName": "details",
    "header": ["FBillNo", "FDate", "FSupplierId_FName", "FSettleCurrId_FNumber", "FPurchaseOrgId_FNumber", "FExchangeRate"],
    "body": ["FMaterialId_FNumber", "FRealQty", "FTaxPrice", "FAllAmount", "FDiscount", "FPurchaseOrgId_FNumber"]
  },
  ...
}

以上配置定义了调用batchSave API时需要使用的HTTP方法、检查ID的方式以及操作类型等基本信息。

数据字段映射与转换

在进行ETL转换时，需要特别注意字段的映射和内容的转换。例如，采购组织字段FPurchaseOrgId需要根据不同条件进行映射：

{
  "field": "FPurchaseOrgId",
  "label": "采购组织",
  ...
  "value": "_function case when '{FPurchaseOrgId_FNumber}' ='100' then '125' when '{FPurchaseOrgId_FNumber}' ='202' then '126' when '{FPurchaseOrgId_FNumber}' ='204' then '127' else '109' end"
}

这种映射逻辑确保了不同采购组织代码能够正确地转换为目标系统所需的值。

金蝶云星空API接口调用

为了将转换后的数据写入金蝶云星空，我们需要调用其提供的API接口。在本案例中，使用的是batchSave接口，该接口支持高吞吐量的数据写入能力，能够快速处理大量采购入库单的数据。

{
  ...
  "otherRequest": [
    {"field":"FormId","label":"业务对象表单Id","type":"string","describe":"必须填写金蝶的表单ID如:PUR_PurchaseOrder","value":"STK_InStock"},
    {"field":"IsAutoSubmitAndAudit","label":"提交并审核","type":"bool","value":"false"},
    {"field":"Operation","label":"执行的操作","type":"string","value":"Save"},
    {"field":"IsVerifyBaseDataField","label":"验证基础资料","type":"bool","describe":"是否验证所有的基础资料有效性，布尔类，默认false（非必录）","value":"true"},
    {"field":"SubSystemId","label":"系统模块","type":"string","describe":"默认仓库模块","value":"21"}
  ]
}

上述配置指定了业务对象表单ID、是否自动提交并审核、执行操作类型等关键参数。

数据质量监控与异常处理

总结

通过上述步骤，我们实现了从源平台到金蝶云星空的数据ETL转换，并成功将采购入库单的数据写入目标系统。在这个过程中，利用元数据配置实现了灵活的数据映射与转换，通过调用高效可靠的API接口完成了大批量数据的快速写入，同时借助实时监控和异常处理机制保障了整个过程的稳定性和可靠性。金蝶与CRM系统接口开发配置

如何开发金蝶云星空API接口