markdown

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

### 销售订单推送简道云审批（教学案例）

在企业信息化管理中，销售订单的高效处理和审批是关键环节之一。为了实现这一目标，我们将金蝶云星空的数据集成到简道云，通过轻易云数据集成平台进行系统对接。本案例重点展示如何利用API接口，将金蝶云星空中的销售订单数据推送至简道云进行审批。

首先，我们需要解决几个技术难点：确保数据不漏单、处理分页和限流问题、以及应对两者之间的数据格式差异。通过调用金蝶云星空的`executeBillQuery`接口，我们能够定时可靠地抓取销售订单数据，并通过简道云的`/api/v2/app/{app_id}/entry/{entry_id}/data_create`接口，实现批量数据写入。

为确保高效的数据处理，本方案采用了以下特性：

1. **高吞吐量的数据写入能力**：支持大量销售订单快速集成到简道云，提升整体处理效率。
2. **实时监控与日志记录**：通过集中监控和告警系统，实时跟踪数据集成任务的状态和性能，及时发现并解决潜在问题。
3. **自定义数据转换逻辑**：针对不同业务需求和数据结构，灵活调整数据转换规则，以适应实际应用场景。
4. **异常处理与错误重试机制**：在对接过程中，如果出现异常情况，可以自动重试，确保任务顺利完成。

本次集成不仅提高了销售订单处理的透明度，还优化了资源配置，使得业务流程更加顺畅。接下来，我们将详细介绍具体的实施步骤及技术要点。
![用友与CRM系统接口开发配置](https://pic.qeasy.cloud/D4.png)

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

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

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

#### 接口配置与请求参数

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

- **api**: `executeBillQuery`
- **method**: `POST`
- **FormId**: `SAL_SaleOrder`
- **FieldKeys**: 包含所有需要查询的字段，如`FSaleOrderEntry_FEntryID`, `FID`, `FBillNo`等。
- **FilterString**: 用于过滤查询条件，例如：`FCreateDate>='{{LAST_SYNC_TIME|dateTime}}' and FDocumentStatus!='C'`

这些配置确保了我们能够准确地从金蝶云星空系统中获取到所需的数据。

#### 请求示例

在实际操作中，请求体会包含多个字段，这里简要展示一个请求示例：

```json
{
  "FormId": "SAL_SaleOrder",
  "FieldKeys": ["FSaleOrderEntry_FEntryID", "FID", "FBillNo", ...],
  "FilterString": "FCreateDate>='2023-01-01' and FDocumentStatus!='C'",
  "Limit": 100,
  "StartRow": 0
}
```

#### 数据分页与限流处理

由于可能存在大量的数据，需要进行分页处理。通过设置`Limit`和`StartRow`参数，可以有效控制每次请求返回的数据量，从而避免一次性拉取过多数据导致系统性能问题。同时，限流机制也非常重要，以防止对金蝶云星空系统造成过大的压力。

例如：
```json
{
  "Limit": 100,
  "StartRow": "{PAGINATION_START_ROW}"
}
```

#### 数据清洗与转换

获取到原始数据后，需要进行初步的数据清洗和转换。这一步骤包括但不限于以下操作：

1. **字段映射**：将金蝶云星空中的字段名映射为简道云或其他目标系统中的字段名。例如，将`FSaleOrgId_FNumber`映射为目标系统中的销售组织编号。
2. **格式转换**：根据业务需求，对日期、金额等字段进行格式转换。例如，将日期格式从YYYY-MM-DD转换为目标系统所需的格式。
3. **异常处理**：检测并处理异常值，如缺失值、无效值等，确保数据质量。

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

为了确保整个过程顺利进行，实时监控和日志记录是必不可少的。轻易云平台提供了集中的监控和告警系统，可以实时跟踪每个数据集成任务的状态和性能。一旦发现异常情况，可以及时发出告警并采取相应措施。

例如，通过日志记录可以捕捉到每次API调用的响应时间、成功与否以及具体返回的数据量等信息。这些信息对于后续优化和故障排查具有重要意义。

#### 自定义转换逻辑

在某些情况下，标准的数据清洗和转换流程可能无法满足特定业务需求。这时，可以利用轻易云平台提供的自定义转换逻辑功能，根据具体需求编写脚本或规则，实现更复杂的数据处理操作。

例如，对于某些特殊字段，需要根据业务规则计算其值：
```python
def custom_transform(data):
    if data['FPrice'] > threshold:
        data['Discount'] = calculate_discount(data['FPrice'])
    return data
```

通过上述步骤，我们可以高效地调用金蝶云星空接口获取销售订单数据，并对其进行必要的加工处理，为后续的数据写入和应用奠定基础。在整个过程中，充分利用轻易云平台提供的各种特性，如高吞吐量写入能力、实时监控、异常检测等，可以显著提升数据集成效率和可靠性。
![用友与SCM系统接口开发配置](https://pic.qeasy.cloud/S2.png)

![金蝶与外部系统打通接口](https://pic.qeasy.cloud/QEASY/A75.png)

### 集成方案:销售订单推送简道云审批（教学案例）

在数据集成生命周期的第二步中，关键任务是将已经从源平台（金蝶云星空）获取的数据进行ETL转换，以适应目标平台（简道云）的API接口要求，并最终写入简道云。以下内容将深入探讨这一过程中的技术细节和实现方法。

#### 数据转换与写入：从金蝶云星空到简道云

1. **数据请求与清洗**

在集成过程中，首先需要从金蝶云星空系统中请求销售订单数据。这一步通常通过调用金蝶云星空的`executeBillQuery`接口来实现。该接口支持分页和限流，因此在请求数据时需要处理好分页逻辑和限流问题，以确保数据完整性和稳定性。

2. **ETL转换**

获取到原始数据后，需要对其进行清洗、转换，以符合简道云API的格式要求。具体来说，ETL转换过程包括以下几个步骤：

- **字段映射与转换**：根据元数据配置，将金蝶云星空的字段映射到简道云所需的字段。例如，将金蝶云星空的`FBillNo`映射为简道云的`单据编号`。
   - **数据类型转换**：确保字段类型一致性，例如将数值型字段转换为字符串型，以匹配简道云API的要求。
   - **结构调整**：根据简道云API的结构要求，对数据进行重新组织。例如，将明细项整理为数组格式。

元数据配置如下：
   ```json
   {
     "api": "/api/v2/app/{app_id}/entry/{entry_id}/data_create",
     "method": "POST",
     "request": [
       {"field":"_widget_1682588571434","label":"单据编号","type":"string","value":"{FBillNo}"},
       {"field":"_widget_1682588571435","label":"发起人","type":"string","value":"{FApproverId}"},
       {"field":"_widget_1682588571436","label":"明细","type":"object","children":[
         {"field":"value","label":"值","type":"array","children":[
           {"field":"_widget_1682588571438","label":"物料编号","type":"string","value":"{FMaterialId_Fnumber}"},
           {"field":"_widget_1682588571439","label":"金额","type":"string","value":"{FTaxPrice}"},
           {"field":"_widget_1682588571440","label":"数量","type":"string","value":"{FQty}"}
         ]}
       ]}
     ],
     "otherRequest": [
       {"field":"is_start_workflow","value":"true"},
       {"field":"is_start_trigger","value":"false"}
     ]
   }
   ```

3. **写入目标平台**

完成ETL转换后，通过调用简道云API接口，将整理好的数据写入目标平台。此过程涉及以下几个关键点：

- **高吞吐量写入**：为了处理大量销售订单，需要确保系统具备高吞吐量的数据写入能力。可以通过批量处理和并行写入来提升性能。
   - **异常处理与重试机制**：在数据写入过程中，可能会遇到网络问题或其他异常情况。需要实现错误重试机制，确保数据可靠传输。
   - **实时监控与日志记录**：通过集中的监控和告警系统，实时跟踪数据写入任务的状态，并记录详细日志，以便在出现问题时能够快速定位和解决。

#### 实践案例

假设我们需要将金蝶云星空中的销售订单推送到简道云进行审批，我们可以按照以下步骤进行操作：

1. **调用金蝶云星空接口获取销售订单数据**
   
   ```python
   response = requests.post(
       url="https://api.kingdee.com/executeBillQuery",
       data={"query_params": "..."}
   )
   data = response.json()
   ```

2. **根据元数据配置进行ETL转换**

```python
   transformed_data = []
   for order in data["orders"]:
       transformed_order = {
           "_widget_1682588571434": order["FBillNo"],
           "_widget_1682588571435": order["FApproverId"],
           "_widget_1682588571436": {
               "value": [
                   {
                       "_widget_1682588571438": item["FMaterialId_Fnumber"],
                       "_widget_1682588571439": item["FTaxPrice"],
                       "_widget_1682588571440": item["FQty"]
                   } for item in order["items"]
               ]
           }
       }
       transformed_data.append(transformed_order)
   ```

3. **调用简道云API接口写入目标平台**

```python
   for record in transformed_data:
       response = requests.post(
           url="https://api.jiandaoyun.com/api/v2/app/{app_id}/entry/{entry_id}/data_create",
           json=record,
           headers={"Authorization": "Bearer your_api_token"}
       )
       if response.status_code != 200:
           # 实现错误重试机制
           retry_logic(response)
   ```

通过上述步骤，可以实现从金蝶云星空到简道云的数据集成，在此过程中，重点在于正确处理ETL转换、确保高效稳定的数据写入以及完善的异常处理机制。这些技术细节对于成功完成复杂的数据集成任务至关重要。
![用友与WMS系统接口开发配置](https://pic.qeasy.cloud/T25.png)

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

如何通过轻易云实现销售订单的高效审批