### 吉客云·奇门数据集成到金蝶云星空的高效实践：JY-BDS销售出库单（2-代发货）
在本篇文章中，我们将深入探讨如何使用轻易云数据集成平台实现吉客云·奇门的数据无缝对接到金蝶云星空系统，特别是以实际运行方案JY-BDS销售出库单（2-代发货）为例。本案例涵盖了从吉客云·奇门获取销售出库单数据、进行必要的数据转换与处理，再到最终批量写入至金蝶云星空全过程的技术细节。
首先，在这个对接过程中，我们需要通过调用吉客云·奇门API接口`jackyun.tradenotsensitiveinfos.list.get`来定时抓取相关交易信息。由于该接口会返回大量分页数据，因此我们需要具备处理分页及限流问题的能力，以确保在高并发下也能稳定运行。同时，为提升整体数据质量和监控能力，平台提供了实时监控与日志记录功能，使得每一步操作都能够被透明可见，并及时发现和解决可能出现的问题。
为了适应不同系统之间的数据格式差异，我们可以利用平台提供的自定义数据转换逻辑功能，将从吉客云·奇门获取的数据转化为符合金蝶云星空要求的字段格式。在这一步骤中，详细且精准的数据映射设计尤为关键，其直接影响着后续批量写入操作的效率和准确性。
当所有准备工作完成后，通过调用金蝶云星空的`batchSave` API接口，实现大批量、高吞吐量地将处理后的销售出库单准时、可靠地发送至目标系统。在此期间，如果发生异常情况，还需依赖内置的错误重试机制进行自动恢复，从而保证整个流程不漏任何一笔订单，确保业务连续性。
以上，就是此次实例分享的大致技术框架。下面我们将具体展开每一个环节中的实施细节，包括代码示例、配置界面以及注意事项等内容。
### 使用轻易云数据集成平台调用吉客云·奇门接口获取并加工数据
在数据集成过程中，调用源系统的API接口是关键的一步。本文将深入探讨如何使用轻易云数据集成平台调用吉客云·奇门接口`jackyun.tradenotsensitiveinfos.list.get`，并对获取的数据进行初步加工。
#### 接口配置与请求参数
首先，我们需要配置API接口的元数据。根据提供的元数据配置，可以看到该接口采用POST方法，主要用于获取销售出库单的相关信息。以下是请求参数的详细配置：
```json
{
"api": "jackyun.tradenotsensitiveinfos.list.get",
"method": "POST",
"number": "tradeNo",
"id": "tradeId",
"pagination": {
"pageSize": 20
},
"idCheck": true,
"omissionRemedy": {
"crontab": "20 6,18 * * *",
"takeOverRequest": [
{
"field": "startConsignTime",
"label": "发货时间（起始）",
"type": "string",
"is_required": false,
"value": "{{DAYS_AGO_2|datetime}}"
},
{
"field": "endConsignTime",
"label": "发货时间（截止）",
"type": "string",
"is_required": false,
"value": "{{CURRENT_TIME|datetime}}"
}
]
},
...
}
```
#### 请求参数解析
1. **分页配置**：`pagination`字段设置了每页返回20条记录。
2. **ID检查**：`idCheck`字段为true，表示需要对返回的数据进行ID检查。
3. **补漏机制**：`omissionRemedy`字段定义了定时任务和接管请求参数，用于在数据遗漏时进行补救。
#### 请求字段说明
以下是部分关键请求字段及其说明：
- `modified_begin` 和 `modified_end`: 修改时间范围，必须同时存在且间隔不超过七天。
- `startConsignTime` 和 `endConsignTime`: 发货时间范围，用于筛选特定时间段内的数据。
- `tradeNo`: 销售单号，可用于精确查询特定订单。
- `fields`: 指定需要返回的字段列表，以逗号分隔。
#### 调用接口示例
为了实际调用该接口，我们需要构建一个完整的请求体。以下是一个示例请求体：
```json
{
"modified_begin": "",
"modified_end": "",
...
"startConsignTime": "{{LAST_SYNC_TIME|datetime}}",
"endConsignTime": "{{CURRENT_TIME|datetime}}",
...
}
```
在实际操作中，可以通过轻易云平台的可视化界面配置这些参数，并实时监控数据流动和处理状态。
#### 数据清洗与转换
获取到原始数据后，需要对其进行清洗和转换，以便后续处理。常见的数据清洗操作包括：
1. **去重**：根据`tradeId`字段去除重复记录。
2. **格式化**：将日期、金额等字段格式化为标准形式。
3. **过滤**：根据业务需求过滤掉不必要的字段或记录。
例如，可以使用轻易云平台提供的数据清洗工具，对返回的数据进行如下处理：
```json
{
// 去重操作
"$groupBy": ["tradeId"],
// 格式化日期
"$formatDateFields": ["startConsignTime", "endConsignTime"],
// 字段过滤
"$selectFields": ["tradeNo", ...]
}
```
#### 数据写入
清洗和转换后的数据可以写入目标系统，如数据库或另一个API接口。在轻易云平台上，可以通过拖拽组件实现这一过程，并设置相应的写入规则和调度策略。
综上所述，通过合理配置吉客云·奇门接口并对获取的数据进行清洗和转换，可以有效提升数据集成效率，为后续的数据分析和业务决策提供可靠支持。
### 使用轻易云数据集成平台进行金蝶云星空API接口的数据转换与写入
在数据集成的过程中，将源平台的数据转换为目标平台所能接收的格式是关键步骤之一。本文将详细探讨如何利用轻易云数据集成平台，将销售出库单（JY-BDS）数据转换为金蝶云星空API接口所需的格式，并最终写入目标平台。
#### API接口配置与调用
首先，我们需要明确金蝶云星空API接口的配置。根据元数据配置，目标API接口为`batchSave`，使用POST方法进行请求。以下是具体的配置细节：
```json
{
"api": "batchSave",
"method": "POST",
"idCheck": true,
"operation": {
"rowsKey": "array",
"rows": 10,
"method": "batchArraySave"
},
"request": [
{"field":"FBillTypeID","label":"单据类型","type":"string","describe":"单据类型","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"XSCKD07_SYS"},
{"field":"FBillNo","label":"单据编号","type":"string","describe":"单据编号","value":"{tradeNo}"},
{"field":"FDate","label":"日期","type":"string","describe":"日期","value":"{consignTime}"},
{"field":"FSaleOrgID","label":"销售组织","type":"string","describe":"组织","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"_findCollection find textField_l2iazxw0 from a7cb0b9d-2aef-342a-bcb9-7d02e747f1d8 where textField_l2iazxvw={shopCode}"},
{"field":"FCustomerID","label":"客户","type":"string","describe":"基础资料","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"_findCollection find textField_l2iazxvz from a7cb0b9d-2aef-342a-bcb9-7d02e747f1d8 where textField_l2iazxvw={shopCode}"},
{"field":"FNote","label":"备注","type":"string","describe":"多行文本","value":"{sellerMemo}"},
{"field":"FStockOrgID","label":"发货组织","type":"string","describe":"多类别基础资料","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"_findCollection find textField_l2ib4q9s from 0ce3a160-9fb2-36e5-a2ac-57f5ad0f3c72 where textField_l2ib4q9p={warehouseCode}"},
{"field":"FOwnerIdHead","label":"货主","type":"","describe":"","parser":{"name":"","params":""},"value":""},
{"field":"","label":"","type":"","describe":"","parser":{"name":"","params":""},"value":""}
],
"otherRequest":[
{"field": "FormId", "label": "业务对象表单Id", "type": "string", "describe": "必须填写金蝶的表单ID如:PUR_PurchaseOrder", "value": "SAL_OUTSTOCK"},
{"field": "Operation", "label": "执行的操作", "type": "", "value": ""},
{"field": "", "label": "", "" : "", "" : ""}
]
}
```
#### 数据字段解析与映射
在上述配置中，每个字段都有特定的解析器和映射规则。例如：
1. **FBillTypeID**：使用`ConvertObjectParser`解析器，将固定值`XSCKD07_SYS`转换为金蝶系统识别的编码。
2. **FSaleOrgID**：通过SQL查询语句，动态获取对应销售组织编码。
3. **FCustomerID**：同样使用SQL查询，根据`shopCode`获取对应客户编码。
这些解析器和映射规则确保了源数据能够正确转换为目标平台所需格式。
#### 明细信息处理
对于复杂的数据结构，如明细信息（FEntity），需要进一步拆分和处理。每个明细项包括多个字段，如物料编码、实发数量、单价等。这些字段同样需要根据规则进行解析和映射：
```json
{
"field": "FEntity",
"label": "",
...
}
```
其中，每个子字段也有相应的解析规则，例如：
- **FMaterialID**：物料编码，通过`goodsDetail.goodsNo`获取。
- **FRealQty**：实发数量，通过`goodsDetail.sellCount`获取。
- **FPrice**：单价，通过计算公式`{{goodsDetail.shareFavourableAfterFee}}/{{goodsDetail.sellCount}}`获取。
#### 请求构建与发送
完成所有字段的解析和映射后，构建最终的请求体并发送至金蝶云星空API接口。以下是一个示例请求体：
```json
{
...
}
```
通过轻易云数据集成平台，我们可以实时监控整个ETL过程，确保每一步都透明可见，并及时处理可能出现的问题。
#### 总结
通过上述步骤，我们实现了从源平台到金蝶云星空目标平台的数据ETL转换与写入。这一过程充分利用了轻易云数据集成平台提供的灵活性和强大的解析功能，为复杂的数据集成任务提供了可靠保障。
