### 金蝶云星空数据集成到旺店通·企业奇门：直接调拨单对接案例分享
在实际业务中，实现跨平台的数据无缝流转是确保高效运营的关键一步。本案例将详细剖析如何利用轻易云数据集成平台，在金蝶云星空和旺店通·企业奇门之间高效完成直接调拨单的对接。
#### 集成背景及挑战
为了提高业务效率，某大型零售企业决定将其应用系统中的金蝶云星空直接调拨单通过自动化流程集成到旺店通·企业奇门。在此过程中，需要解决以下主要技术难题：
1. **确保不漏单**：需要一种机制来保证每个从金蝶云星空提取出的直接调拨单都能成功写入到旺店通。
2. **快速批量写入**：应对大量数据时，如何提高写入速度并保持系统稳定性。
3. **接口调用与限流管理**：处理分页查询以及API调用频率限制，确保系统运行平稳不卡顿。
4. **数据格式转换**：两套系统间的数据格式存在差异，需要适配不同字段和结构。
5. **精准可靠的抓取与推送时间**：定时抓取和推送任务需高度可靠，以免影响整体业务流程。
#### 解决方案概述
我们采用了分步骤、模块化的方法来保证整个集成过程尽可能顺畅：
1. **接口调用实现细节**
- 使用executeBillQuery API从金蝶云星空提取直接调拨单数据信息，并进行实时监控与日志记录（示例代码将在后续部分贴出）。
2. **分页与限流**
- 在获取大批量数据时，通过合理设计分页策略及限流措施，避免超负荷导致接口错误。此功能结合定时任务模块有效执行，使得每次操作均衡高效。
3. **数据格式差异处理**
- 实现自定义映射，将金蝶输出的数据经过特殊算法重新编排，以符合wdt.stock.transfer.push 接口所需的输入格式。
4. **异常处理与重试机制**
- 对于可能出现的网络故障或其他意外情况，我们开发了一套健壮的异常捕获和重试逻辑。一旦发生错误，会立即启动预设重试程序以再次尝试提交未完成的数据包。
5. **快速批量推送**
- 利用轻易云提供的大容量缓冲区技术，将整理后的调拨单信息迅速传输至旺店通·企业奇门，提高整体吞吐量，大幅减少延迟。
本篇文章接下来将逐步深入这些核心
### 调用金蝶云星空接口executeBillQuery获取并加工数据
在数据集成过程中，调用源系统的API接口是关键的一步。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的`executeBillQuery`接口，以获取并加工数据。
#### 接口配置与调用
首先，我们需要配置元数据以便正确调用金蝶云星空的`executeBillQuery`接口。以下是相关元数据配置：
```json
{
"api": "executeBillQuery",
"effect": "QUERY",
"method": "POST",
"number": "FBillNo",
"id": "FBillEntry_FEntryID",
"name": "FBillNo",
"idCheck": true,
"request": [
{"field":"FBillEntry_FEntryID","label":"FEntryID","type":"string","describe":"FEntryID","value":"FBillEntry_FEntryID"},
{"field":"FID","label":"实体主键","type":"string","describe":"实体主键","value":"FID"},
{"field":"FBillNo","label":"单据编号","type":"string","describe":"单据编号","value":"FBillNo"},
{"field":"FDate","label":"日期","type":"string","describe":"日期","value":"FDate"},
{"field":"FNote","label":"备注","type":"string","describe":"备注","value":"FNote"},
{"field":"FMaterialId_FNumber","label":"物料编码","type":"string","describe":"物料编码","value":"FMaterialId.FNumber"},
{"field":"FLot","label":"调出批号","type":"string","describe":"调出批号","value":"FLot"},
{"field":"FSrcStockId_FNumber","label":"调出仓库","type":"string","describe":"调出仓库","value":"FSrcStockId.FNumber"},
{"field":"FDestStockId_FNumber","label":"调入仓库","type":"string","describe":"调入仓库","value":"FDestStockId.FNumber"},
{"field": "FProduceDate", "label": "生产日期", "type": "string", "describe": "生产日期", "value": "FProduceDate"},
{"field": "FExpiryDate", "label": "有效期至", "type": "string", "describe": "有效期至", "value": "FExpiryDate"},
{"field": "FTaxPrice", "label": "含税单价", "type": "string", "describe": "含税单价", "value": "FTaxPrice"},
{"field": "FDestLot", "label": "调入批号", "type": "string", "describe": "", value: "" },
{"field": "", label: "", type: "", describe: "", value: "" },
...
],
...
}
```
在上述配置中，`api`字段指定了要调用的API名称，即`executeBillQuery`。`method`字段指定了HTTP请求方法为POST。其他字段如`number`, `id`, `name`, `idCheck`等用于标识和校验请求的数据。
#### 请求参数详解
请求参数部分定义了我们需要从金蝶云星空获取的数据字段，包括但不限于：
- `FBillEntry_FEntryID`: 分录唯一标识
- `FID`: 实体主键
- `FBillNo`: 单据编号
- `FDate`: 日期
- `FNote`: 备注
- `FMaterialId_FNumber`: 物料编码
- `FLot`: 调出批号
- `FSrcStockId_FNumber`: 调出仓库
- `FDestStockId_FNumber`: 调入仓库
- `FProduceDate`: 生产日期
- `FExpiryDate`: 有效期至
- `FTaxPrice`: 含税单价
这些字段通过POST请求发送到金蝶云星空API，以获取相应的数据。
#### 数据过滤与分页
为了提高查询效率和精确度，我们可以使用过滤条件和分页参数。例如：
```json
{
...
{
field: 'FilterString',
label: '过滤条件',
type: 'string',
describe: '示例写法 FSupplierId.FNumber = \'VEN00010\' and FApproveDate>=',
value: 'FApproveDate>=\'{{LAST_SYNC_TIME|dateTime}}\' and FTransferBizType = \'InnerOrgTransfer\' and FOwnerID.FNumber in ( \'7000\',\'3000\')'
},
{
field: 'Limit',
label: '最大行数',
type: 'string',
describe: '金蝶的查询分页参数',
value: '{PAGINATION_PAGE_SIZE}'
},
{
field: 'StartRow',
label: '开始行索引',
type: 'string',
describe: '金蝶的查询分页参数',
value:'{PAGINATION_START_ROW}'
}
}
```
其中，`FilterString`用于设置过滤条件，如根据审批日期和业务类型进行筛选；`Limit`和`StartRow`用于分页控制，以避免一次性返回过多数据。
#### 数据处理与转换
在获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。清洗过程包括去除无效数据、格式化字段等操作。例如，将日期格式统一转换为标准格式，将金额字段转换为数值类型等。
```json
{
...
{
field:"FTaxPrice",
label:"含税单价",
type:"float",
describe:"将字符串类型转换为浮点数"
}
}
```
#### 自动填充响应
为了简化开发流程，可以启用自动填充响应功能，使得平台自动将API返回的数据填充到预定义的结构中。
```json
{
...
autoFillResponse:true,
...
}
```
通过上述配置和步骤，我们能够高效地调用金蝶云星空的API接口，获取所需的数据并进行清洗和转换，为后续的数据写入做好准备。这一过程不仅提高了数据处理的透明度和效率，也确保了数据的一致性和准确性。
### 数据集成生命周期第二步：ETL转换与写入目标平台
在数据集成过程中，ETL（提取、转换、加载）是一个关键步骤，尤其是在将数据从源系统转换为目标系统所能接受的格式时。本文将详细介绍如何使用轻易云数据集成平台，将金蝶直接调拨单的数据转换为旺店通·企业奇门API接口所能接收的格式，并最终写入目标平台。
#### 1. 数据请求与清洗
在进行ETL转换之前，我们首先需要从金蝶系统中提取原始数据，并进行必要的清洗和预处理。这一步骤确保了数据的一致性和完整性，为后续的转换和加载奠定基础。
#### 2. 数据转换
接下来，我们将重点讨论如何将已经清洗好的数据按照旺店通·企业奇门API接口的要求进行转换。以下是元数据配置的详细说明：
```json
{
"api": "wdt.stock.transfer.push",
"effect": "EXECUTE",
"method": "merge",
"idCheck": true,
"operation": {
"method": "merge",
"field": "FBillNo, FDestStocId_FNumber,FSrcStockId_FNumber",
"bodyName": "details_listss",
"header": ["FBillNo", "FDestStockId_FNumber", "FSrcStockId_FNumber", "FNote"],
"body": ["FMaterialId_FNumber", "FPriceQty", "FNoteEntry"]
},
"request": [
{"field":"outer_no","label":"外部单号","type":"string","describe":"外部单据唯一标识，用于避免同一数据重复推送","value":"{FBillNo}"},
{"field":"from_warehouse_no","label":"调出仓库","type":"string","describe":"货品被调出的仓库","value":"{FSrcStockId_FNumber}"},
{"field":"to_warehouse_no","label":"调入仓库","type":"string","describe":"货品被调入的仓库","value":"{FDestStockId_FNumber}"},
{"field":"address","label":"地址","type":"string","describe":"地址"},
{"field":"contact","label":"联系人","type":"string","describe":"联系人"},
{"field":"telno","label":"联系电话","type":"string","describe":"联系电话"},
{"field":"remark","label":"备注","type":"string","describe":"备注","value":"{FNote}"},
{"field":"transfer_type","label":"调拨类型","type":"string","describe":"0：分步调拨，1：快速调拨，默认是1","value":"1"},
{"field":"mode","label":"调拨方式","type":"string","describe":"0：单品调拨，1：货位调拨；默认是0","value":"1"},
{"field":"autocheck","label":"是否审核","type":"string","describe":"1:审核，0:不审核，默认为0","value":"1"},
{
"field": "skus",
"label": "货品列表节点",
"type": "array",
"describe": "调拨单货品列表节点",
"value": "details_listss",
"children": [
{"field": "spec_no", "label": "商品编码", "type": "string", "value": "{{details_listss.FMaterialId_FNumber}}"},
{"field": "num", "label": "调拨数量", "type": "string", "value": "{{details_listss.FPriceQty}}"},
{"field": "remark", "label": "明细备注", "type":="string",="value"="{{details_listss.FNoteEntry}}"}
{"field"="from_position_no"="label"="调出货位"="type"="string"}
{"field"="to_position_no"="label"="调入货位"="type"="string"}
{"field"="batch_no"="label"="批次号{{details_listss.FLot}}"="type"="string"}
]
}
],
otherRequest: [
{ field: 'transfer_info', label: 'transfer_info', type: 'string', describe: '111', value: '1' }
]
}
```
在上述配置中，我们定义了API接口`wdt.stock.transfer.push`及其相关字段。以下是关键字段的解释：
- **outer_no**：外部单据唯一标识，用于避免重复推送。
- **from_warehouse_no**：调出仓库编号。
- **to_warehouse_no**：调入仓库编号。
- **remark**：备注信息。
- **transfer_type**：默认值为1，即快速调拨。
- **mode**：默认值为1，即货位调拨。
- **autocheck**：默认值为1，即审核。
在`skus`节点中，我们定义了每个商品的详细信息，包括商品编码（spec_no）、数量（num）以及明细备注（remark）。
#### 3. 数据加载
完成数据转换后，我们将这些数据通过API接口推送到旺店通·企业奇门平台。此步骤确保了数据能够无缝地从源系统传输到目标系统，实现业务流程的自动化和高效化。
通过上述步骤，我们可以有效地将金蝶直接调拨单的数据转化为旺店通·企业奇门API接口所能接收的格式，并成功写入目标平台。这不仅提高了数据处理效率，还保证了数据的一致性和准确性。
