markdown

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

### 金蝶收款退款单对接纷享销客账户支出流水的集成方案

在企业管理系统中，数据的高效流转和准确对接是确保业务顺畅运行的关键。本文将分享一个具体的技术案例：如何通过轻易云数据集成平台，将金蝶云星空中的收款退款单数据无缝对接到纷享销客的账户支出流水中。

为了实现这一目标，我们利用了金蝶云星空提供的数据获取API `executeBillQuery` 和纷享销客的数据写入API `/cgi/crm/v2/data/create`。在整个集成过程中，以下几个关键特性发挥了重要作用：

1. **高吞吐量的数据写入能力**：确保大量收款退款单数据能够快速且稳定地被写入到纷享销客系统中，大幅提升了数据处理的时效性。
   
2. **集中监控和告警系统**：实时跟踪每个数据集成任务的状态和性能，及时发现并处理潜在问题，保证了数据流动过程中的透明度和可靠性。

3. **自定义数据转换逻辑**：针对金蝶云星空与纷享销客之间的数据格式差异，通过灵活配置自定义转换规则，使得不同系统间的数据能够准确匹配，实现无缝衔接。

4. **分页和限流处理机制**：由于金蝶云星空接口存在分页和限流限制，我们设计了一套有效的分页抓取策略，并结合限流控制，确保在高并发情况下依然能够稳定获取所需数据。

5. **异常处理与错误重试机制**：针对可能出现的网络波动或接口调用失败等情况，我们引入了完善的异常处理和重试机制，以保证每一条记录都能成功传输，不漏单、不重复。

通过以上技术手段，我们不仅实现了金蝶云星空与纷享销客之间的数据对接，还大幅提升了整体业务流程的效率和可靠性。在后续章节中，将详细介绍具体实施步骤及配置细节。
![钉钉与CRM系统接口开发配置](https://pic.qeasy.cloud/D28.png)

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

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

在轻易云数据集成平台中，调用源系统金蝶云星空接口`executeBillQuery`是数据集成生命周期的第一步。此步骤至关重要，因为它确保了从源系统获取的数据准确无误，并为后续的数据清洗和转换奠定了基础。

#### 接口配置与调用

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

- **API名称**：`executeBillQuery`
- **请求方法**：`POST`
- **分页参数**：支持分页查询，每页大小为100条记录
- **过滤条件**：通过设置过滤条件，可以精确控制查询结果，例如按日期范围或特定字段值进行筛选

```json
{
  "api": "executeBillQuery",
  "method": "POST",
  "pagination": {
    "pageSize": 100
  },
  "request": [
    {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
    {"field":"FDATE","label":"业务日期","type":"string","value":"FDATE"},
    {"field":"FREFUNDTOTALAMOUNTFOR","label":"表头-应退金额","type":"string","value":"FREFUNDTOTALAMOUNTFOR"},
    {"field":"FCONTACTUNIT_FNumber","label":"往来单位","type":"string","value":"FCONTACTUNIT.FNumber"},
    {"field":"FOURACCOUNTNAME","label":"我方账户名称","type":"string","value":"FOURACCOUNTNAME"},
    {"field":"FSALEERID_FName","label":"销售员","type":"string","value":"FSALEERID.FName"},
    {"field":"F_PRSH_Assistant_h1g","label":"退款类型","type": "string", "value": "F_PRSH_Assistant_h1g.fnumber"}
  ],
  "otherRequest":[
    {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": string, describe: 金蝶的查询分页参数, value: {PAGINATION_START_ROW}},
    {"field" : FilterString, label : 过滤条件, type : string, describe : 示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=, value : FApproveDate>='{{LAST_SYNC_TIME|dateTime}}' and F_PRSH_Assistant_h1g.fnumber in ('01','02')}
  ]
}
```

#### 数据请求与处理

在实际操作中，首先发起HTTP POST请求到金蝶云星空的API端点。请求体包含所需字段及其对应的过滤条件。例如，通过设置`FilterString`可以筛选出特定时间段内符合条件的记录。

```plaintext
POST /k3cloud/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc HTTP/1.1
Host: api.kingdee.com
Content-Type: application/json

{
   ...
   FilterString: FApproveDate>='2023-01-01' and F_PRSH_Assistant_h1g.fnumber in ('01','02')
   ...
}
```

#### 分页处理与限流机制

由于每次请求只能返回有限数量的数据（例如100条），因此需要实现分页处理。通过调整`StartRow`和`Limit`参数，可以逐页获取所有符合条件的数据。此外，为避免触发API限流机制，应合理设置请求频率和重试策略。

#### 数据清洗与转换

获取到原始数据后，需要对其进行清洗和转换，以适应目标系统纷享销客的要求。这包括但不限于：

- **字段映射**：将金蝶云星空中的字段映射到纷享销客对应字段。例如，将“单据编号”映射为“交易流水号”。
- **格式转换**：根据目标系统需求，对日期、金额等字段进行格式转换。
  
```plaintext
{
   单据编号 -> 流水号,
   应退金额 -> 支出金额,
   往来单位 -> 客户名称,
   我方账户名称 -> 收款账户,
   销售员 -> 经办人,
   退款类型 -> 支出类型 
}
```

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

为了确保整个过程透明可控，轻易云平台提供了实时监控和日志记录功能。通过这些功能，可以随时查看数据流动状态、处理进度以及可能出现的问题，从而及时采取措施进行修正。

综上所述，通过合理配置元数据并利用轻易云平台强大的集成能力，我们能够高效地从金蝶云星空获取并加工所需数据，为后续的数据写入和业务应用打下坚实基础。
![数据集成平台API接口配置](https://pic.qeasy.cloud/S19.png)

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

### 集成金蝶收款退款单至纷享销客账户支出流水的ETL转换

在数据集成生命周期中，将源平台数据进行ETL转换并写入目标平台是关键的一步。本文将重点探讨如何将金蝶云星空的收款退款单数据通过ETL转换，最终写入纷享销客的账户支出流水。

#### 数据请求与清洗

在开始ETL转换之前，首先需要从金蝶云星空接口获取收款退款单数据。为了确保数据完整性和准确性，我们需要处理接口分页和限流问题，并进行数据质量监控和异常检测。通过定时可靠地抓取金蝶云星空接口数据，可以确保集成过程中不漏单。

#### 数据转换逻辑

1. **定义目标API结构**：根据元数据配置，目标API为`/cgi/crm/v2/data/create`，使用POST方法进行数据提交。以下是一些关键字段的映射：

- `dataObjectApiName`：固定值`AccountTransactionFlowObj`
    - `name`：对应金蝶单号`{FBillNo}`
    - `transaction_date`：需将金蝶日期格式`{FDATE}`转换为时间戳
    - `customer_id`：通过客户编号`{FCONTACTUNIT_FNumber}`查找客户ID
    - `owner`：通过销售员名称`{FSALEERID_FName}`查找负责人ID
    - `expense_type`：固定值为2（支出类型）
    - `expense_amount`：对应退款金额`{FREFUNDTOTALAMOUNTFOR}`
    - `fund_account_id`：根据辅助核算项值选择账户ID
    - `remark`和`field_kingdee_document_number__c`：均为金蝶单号

2. **字段映射与转换**：
   
   在元数据配置中，每个字段都有明确的映射规则。例如，交易日期字段需要将日期格式转换为时间戳，这是通过以下函数实现的：
   ```plaintext
   _function ROUND((TIMESTAMPDIFF(MICROSECOND, '1970-01-01 00:00:00', STR_TO_DATE('{FDATE}', '%Y-%m-%dT%H:%i:%s')) \/ 1000),0)
   ```

3. **自定义逻辑与查找操作**：
   
   对于客户ID和负责人ID，需要在目标系统中进行查找操作。这些查找操作可以通过轻易云的数据集成平台提供的自定义逻辑实现。例如，通过客户编号找到对应的客户ID：
   ```plaintext
   _findCollection find _id from b4342822-5038-3e8f-9bdf-3684ac8a551d where account_no={FCONTACTUNIT_FNumber}
   ```

4. **条件判断与映射**：

对于账户字段，根据不同的辅助核算项值选择不同的账户ID，这可以通过条件判断来实现：
   ```plaintext
   _function case '{F_PRSH_Assistant_h1g}' when '01' then '667d37c617fdcb00010a7967' when '02' then '66b5c4b5537d670001a55d86' end
   ```

#### 数据写入目标平台

完成上述ETL转换后，将转换后的数据提交至纷享销客API接口。以下是一个简化后的请求结构示例：

```plaintext
POST /cgi/crm/v2/data/create
{
  "data": {
    "object_data": {
      "dataObjectApiName": "AccountTransactionFlowObj",
      "name": "{FBillNo}",
      "transaction_date": "<converted_timestamp>",
      "customer_id": "<customer_id>",
      "owner": "<owner_id>",
      "expense_type": "2",
      "expense_amount": "{FREFUNDTOTALAMOUNTFOR}",
      "fund_account_id": "<fund_account_id>",
      "remark": "金蝶单号{FBillNo}",
      "field_kingdee_document_number__c": "{FBillNo}"
    }
  },
  "currentOpenUserId": "FSUID_F56CEEA6EDDBFE10681577526DF83326"
}
```

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

在数据写入过程中，如果发生错误或异常，需要及时处理并重试。这可以通过设置错误重试机制来实现，确保数据最终能够成功写入目标平台。

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

为了确保整个集成过程的透明度和可追溯性，可以利用平台提供的集中监控和日志记录功能。实时跟踪数据集成任务的状态和性能，有助于及时发现并解决问题。

以上就是将金蝶收款退款单对接至纷享销客账户支出流水的完整ETL转换过程，通过合理的数据请求、清洗、转换、写入以及异常处理，实现了两者之间的数据无缝对接。
![如何开发钉钉API接口](https://pic.qeasy.cloud/T5.png)

![数据集成平台可视化配置API接口](https://pic.qeasy.cloud/QEASY/A10.png)

高效对接：金蝶收款退款单与纷享销客账户流水集成方案

金蝶收款退款单对接纷享销客账户支出流水的集成方案

为了实现这一目标，我们利用了金蝶云星空提供的数据获取API executeBillQuery 和纷享销客的数据写入API /cgi/crm/v2/data/create。在整个集成过程中，以下几个关键特性发挥了重要作用：

高吞吐量的数据写入能力：确保大量收款退款单数据能够快速且稳定地被写入到纷享销客系统中，大幅提升了数据处理的时效性。
集中监控和告警系统：实时跟踪每个数据集成任务的状态和性能，及时发现并处理潜在问题，保证了数据流动过程中的透明度和可靠性。
自定义数据转换逻辑：针对金蝶云星空与纷享销客之间的数据格式差异，通过灵活配置自定义转换规则，使得不同系统间的数据能够准确匹配，实现无缝衔接。
分页和限流处理机制：由于金蝶云星空接口存在分页和限流限制，我们设计了一套有效的分页抓取策略，并结合限流控制，确保在高并发情况下依然能够稳定获取所需数据。
异常处理与错误重试机制：针对可能出现的网络波动或接口调用失败等情况，我们引入了完善的异常处理和重试机制，以保证每一条记录都能成功传输，不漏单、不重复。

通过以上技术手段，我们不仅实现了金蝶云星空与纷享销客之间的数据对接，还大幅提升了整体业务流程的效率和可靠性。在后续章节中，将详细介绍具体实施步骤及配置细节。钉钉与CRM系统接口开发配置

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

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

在轻易云数据集成平台中，调用源系统金蝶云星空接口executeBillQuery是数据集成生命周期的第一步。此步骤至关重要，因为它确保了从源系统获取的数据准确无误，并为后续的数据清洗和转换奠定了基础。

接口配置与调用

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

API名称：executeBillQuery
请求方法：POST
分页参数：支持分页查询，每页大小为100条记录
过滤条件：通过设置过滤条件，可以精确控制查询结果，例如按日期范围或特定字段值进行筛选

{
  "api": "executeBillQuery",
  "method": "POST",
  "pagination": {
    "pageSize": 100
  },
  "request": [
    {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
    {"field":"FDATE","label":"业务日期","type":"string","value":"FDATE"},
    {"field":"FREFUNDTOTALAMOUNTFOR","label":"表头-应退金额","type":"string","value":"FREFUNDTOTALAMOUNTFOR"},
    {"field":"FCONTACTUNIT_FNumber","label":"往来单位","type":"string","value":"FCONTACTUNIT.FNumber"},
    {"field":"FOURACCOUNTNAME","label":"我方账户名称","type":"string","value":"FOURACCOUNTNAME"},
    {"field":"FSALEERID_FName","label":"销售员","type":"string","value":"FSALEERID.FName"},
    {"field":"F_PRSH_Assistant_h1g","label":"退款类型","type": "string", "value": "F_PRSH_Assistant_h1g.fnumber"}
  ],
  "otherRequest":[
    {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": string, describe: 金蝶的查询分页参数, value: {PAGINATION_START_ROW}},
    {"field" : FilterString, label : 过滤条件, type : string, describe : 示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=, value : FApproveDate>='{{LAST_SYNC_TIME|dateTime}}' and F_PRSH_Assistant_h1g.fnumber in ('01','02')}
  ]
}

数据请求与处理

在实际操作中，首先发起HTTP POST请求到金蝶云星空的API端点。请求体包含所需字段及其对应的过滤条件。例如，通过设置FilterString可以筛选出特定时间段内符合条件的记录。

POST /k3cloud/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc HTTP/1.1
Host: api.kingdee.com
Content-Type: application/json

{
   ...
   FilterString: FApproveDate>='2023-01-01' and F_PRSH_Assistant_h1g.fnumber in ('01','02')
   ...
}

分页处理与限流机制

由于每次请求只能返回有限数量的数据（例如100条），因此需要实现分页处理。通过调整StartRow和Limit参数，可以逐页获取所有符合条件的数据。此外，为避免触发API限流机制，应合理设置请求频率和重试策略。

数据清洗与转换

获取到原始数据后，需要对其进行清洗和转换，以适应目标系统纷享销客的要求。这包括但不限于：

字段映射：将金蝶云星空中的字段映射到纷享销客对应字段。例如，将“单据编号”映射为“交易流水号”。
格式转换：根据目标系统需求，对日期、金额等字段进行格式转换。

{
   单据编号 -> 流水号,
   应退金额 -> 支出金额,
   往来单位 -> 客户名称,
   我方账户名称 -> 收款账户,
   销售员 -> 经办人,
   退款类型 -> 支出类型 
}

实时监控与日志记录

综上所述，通过合理配置元数据并利用轻易云平台强大的集成能力，我们能够高效地从金蝶云星空获取并加工所需数据，为后续的数据写入和业务应用打下坚实基础。数据集成平台API接口配置

电商OMS与ERP系统接口开发配置

集成金蝶收款退款单至纷享销客账户支出流水的ETL转换

数据请求与清洗

数据转换逻辑

定义目标API结构：根据元数据配置，目标API为/cgi/crm/v2/data/create，使用POST方法进行数据提交。以下是一些关键字段的映射：
- dataObjectApiName：固定值AccountTransactionFlowObj
- name：对应金蝶单号{FBillNo}
- transaction_date：需将金蝶日期格式{FDATE}转换为时间戳
- customer_id：通过客户编号{FCONTACTUNIT_FNumber}查找客户ID
- owner：通过销售员名称{FSALEERID_FName}查找负责人ID
- expense_type：固定值为2（支出类型）
- expense_amount：对应退款金额{FREFUNDTOTALAMOUNTFOR}
- fund_account_id：根据辅助核算项值选择账户ID
- remark和field_kingdee_document_number__c：均为金蝶单号
字段映射与转换：

在元数据配置中，每个字段都有明确的映射规则。例如，交易日期字段需要将日期格式转换为时间戳，这是通过以下函数实现的：
```
_function ROUND((TIMESTAMPDIFF(MICROSECOND, '1970-01-01 00:00:00', STR_TO_DATE('{FDATE}', '%Y-%m-%dT%H:%i:%s')) \/ 1000),0)
```
自定义逻辑与查找操作：

对于客户ID和负责人ID，需要在目标系统中进行查找操作。这些查找操作可以通过轻易云的数据集成平台提供的自定义逻辑实现。例如，通过客户编号找到对应的客户ID：
```
_findCollection find _id from b4342822-5038-3e8f-9bdf-3684ac8a551d where account_no={FCONTACTUNIT_FNumber}
```
条件判断与映射：

对于账户字段，根据不同的辅助核算项值选择不同的账户ID，这可以通过条件判断来实现：
```
_function case '{F_PRSH_Assistant_h1g}' when '01' then '667d37c617fdcb00010a7967' when '02' then '66b5c4b5537d670001a55d86' end
```

数据写入目标平台

完成上述ETL转换后，将转换后的数据提交至纷享销客API接口。以下是一个简化后的请求结构示例：

POST /cgi/crm/v2/data/create
{
  "data": {
    "object_data": {
      "dataObjectApiName": "AccountTransactionFlowObj",
      "name": "{FBillNo}",
      "transaction_date": "<converted_timestamp>",
      "customer_id": "<customer_id>",
      "owner": "<owner_id>",
      "expense_type": "2",
      "expense_amount": "{FREFUNDTOTALAMOUNTFOR}",
      "fund_account_id": "<fund_account_id>",
      "remark": "金蝶单号{FBillNo}",
      "field_kingdee_document_number__c": "{FBillNo}"
    }
  },
  "currentOpenUserId": "FSUID_F56CEEA6EDDBFE10681577526DF83326"
}

异常处理与重试机制

在数据写入过程中，如果发生错误或异常，需要及时处理并重试。这可以通过设置错误重试机制来实现，确保数据最终能够成功写入目标平台。

实时监控与日志记录

以上就是将金蝶收款退款单对接至纷享销客账户支出流水的完整ETL转换过程，通过合理的数据请求、清洗、转换、写入以及异常处理，实现了两者之间的数据无缝对接。如何开发钉钉API接口

数据集成平台可视化配置API接口