旺店通·企业奇门数据集成到金蝶云星空技术案例分享
在本次技术案例中，我们将详细探讨如何通过轻易云数据集成平台，实现旺店通·企业奇门（WDT）销售出库单无缝对接到金蝶云星空系统。具体方案命名为“旺店通销售出库单=>金蝶销售订单-ok”，其核心在于高效、可靠地抓取和写入大规模业务数据。
数据获取及整合挑战
作为电商ERP解决方案中的重要环节，从旺店通·企业奇门接口 wdt.stockout.order.query.trade 获取准确完整的数据是首先需要解决的问题。为了保证不漏单，系统必须定时且可靠地从该接口抓取最新的出库信息，并处理分页和限流问题，确保每一个订单都被记录下来并及时传输到后续处理中。
-
定时与可靠性：通过精心设置调度任务，可实现定期自动从WDT查询新生成的销售出库单，同时采用重试机制应对临时性网络或服务异常。
-
分页与限流管理：由于API查询结果可能会受到分页限制，我们配置了相应逻辑以批量提取所有相关业务数据。在面对高流量请求时，需合理控制访问频率，以避免超出接口调用配额。
数据格式转换及映射
进入下一步，即将获取的数据转化为可供金蝶云星空接受的格式。这涉及复杂字段间的映射以及某些必要的格式变换。例如，将WDT返回的JSON结构适配为目标API batchSave 所支持的数据模型。
-
自定义数据映射：借助轻易云灵活强大的自定义函数模块，对不同系统间字段进行精准匹配。同时，通过内置工具动态调整参数类型，使得源数据库构件能够成功转译至目标数据库对应项中。
-
兼容多样化输入输出需求：考虑到实际业务场景的不确定性，在初始设计阶段即预留可扩展空间，用以快速响应未来有可能引入的新表单结构或属性字段变化需求。
异常处理及实时监控
此外，为提高稳定性和便捷运维能力，我们还实现了完善的数据对接异常处理与错误重试机制，以及全方位实时监控日志记录功能：
-
异常捕获机制：当发生API调用失败、网络故障等问题时，会触发预设警报策略，并根据情况自动执行重新尝试操作，有效减少人工干预次数。
-
日志追踪与监控面板：搭建丰富详尽的日志体系，就每一次交
调用旺店通·企业奇门接口wdt.stockout.order.query.trade获取并加工数据
在轻易云数据集成平台中，调用源系统接口并获取数据是整个数据处理生命周期的第一步。本文将详细探讨如何通过调用旺店通·企业奇门接口wdt.stockout.order.query.trade来获取销售出库单数据，并进行初步的数据加工。
接口调用配置
首先，我们需要配置接口调用的元数据。以下是对元数据配置的详细解析：
{
"api": "wdt.stockout.order.query.trade",
"effect": "QUERY",
"method": "POST",
"number": "order_no",
"id": "stockout_id",
"name": "order_no",
"idCheck": true,
"request": [
{
"field": "start_time",
"label": "开始时间",
"type": "datetime",
"describe": "增量获取数据，start_time作为开始时间，格式：yyyy-MM-dd HH:mm:ss",
"value": "{{LAST_SYNC_TIME|datetime}}"
},
{
"field": "end_time",
"label": "结束时间",
"type": "datetime",
"describe": "增量获取数据，end_time作为结束时间，格式：yyyy-MM-dd HH:mm:ss",
"value": "{{CURRENT_TIME|datetime}}"
},
{
"field": "status",
...
}
],
...
}请求参数详解
start_time和end_time：用于指定查询的时间范围，通过模板变量{{LAST_SYNC_TIME|datetime}}和{{CURRENT_TIME|datetime}}动态生成。status：指定订单状态，此处设置为“95,110”，即已发货和已完成的订单。src_order_no,src_tid,stockout_no,shop_no,warehouse_no等字段：用于进一步过滤查询结果，根据实际需求填写。
分页处理
为了处理大批量的数据，我们需要分页请求：
{
...
"otherRequest": [
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
### 轻易云数据集成平台：ETL转换与金蝶云星空API接口集成技术案例
在数据集成生命周期的第二阶段，我们重点关注如何将已经集成的源平台数据进行ETL转换，并转为目标平台——金蝶云星空API接口所能够接收的格式，最终写入目标平台。以下是一个详细的技术案例，展示如何使用轻易云数据集成平台配置元数据，实现旺店通销售出库单到金蝶销售订单的数据转换与写入。
#### API接口配置
我们使用金蝶云星空提供的`batchSave` API接口来实现数据写入。该接口通过POST请求方式，将转换后的数据批量保存至金蝶系统中。以下是元数据配置的详细解析：
```json
{
"api": "batchSave",
"effect": "EXECUTE",
"method": "POST",
"idCheck": true,
"request": [
{
"field": "FBillTypeID",
"label": "单据类型",
"type": "string",
"describe": "单据类型",
"parser": {
"name": "ConvertObjectParser",
"params": "FNumber"
},
"value": "XSDD11_DEF"
},
{
"field": "FBillNo",
"label": "单据编号",
"type": "string",
"describe": "单据编号",
"value": "{src_order_no}"
},
{
...
}
],
...
}数据字段解析与映射
-
单据类型（FBillTypeID）：
- 类型：字符串
- 描述：指定单据类型
- 值：固定值
XSDD11_DEF - 转换器：
ConvertObjectParser，参数为FNumber
-
单据编号（FBillNo）：
- 类型：字符串
- 描述：源平台订单编号
- 值：
{src_order_no}，直接从源数据中获取
-
销售组织（FSaleOrgId）：
- 类型：字符串
- 描述：销售组织编码
- 值：
{shop_no} - 转换器：
ConvertObjectParser，参数为FNumber - 映射关系：目标ID
64994f0e88bb66026c6c7c00
-
日期（FDate）：
- 类型：字符串
- 描述：订单日期
- 值：
{consign_time}
-
客户（FCustId）：
- 类型：字符串
- 描述：客户编码
- 值：
{shop_no} - 转换器：
ConvertObjectParser，参数为FNumber
-
备注（FNote）：
- 类型：字符串
- 描述：备注信息
- 值：
{cs_remark}
-
订单明细（FSaleOrderEntry）： 包含多个子字段，如下所示：
{ ... { "field": "FSaleOrderEntry", ... { ... { ... { ... { ... { ... { ... { ... } ] } ] } ] } ] }
特殊字段处理
-
物料编码（FMaterialId）： 使用转换器
ConvertObjectParser将源平台的物料编码转换为目标平台所需格式，并通过映射关系确保正确性。 -
含税单价（FTaxPrice）： 使用函数
_function LEFT('{{details_list.sell_price}}', 6)截取价格字段前六位，以满足目标平台的格式要求。 -
税率（FEntryTaxRate）： 使用
_findCollection find FTaxRateId_FTaxRate from adac3655-a3cb-3551-9024-8e7b360f930a where FNumber={{details_list.goods_no}}动态查找税率信息。 -
是否赠品（FIsFree）： 使用条件判断
_function CASE WHEN {{details_list.sell_price}}>0 THEN 'false' ELSE 'true' END来确定是否为赠品。
操作配置
在操作配置部分，我们设置了以下关键字段：
-
业务对象表单ID（FormId）： 指定业务对象表单ID为
SAL_SaleOrder -
执行操作（Operation）： 执行批量保存操作
BatchSave -
提交并审核（IsAutoSubmitAndAudit）： 设置为
true, 自动提交并审核生成的销售订单。 -
验证基础资料有效性（IsVerifyBaseDataField）： 设置为
true, 验证所有基础资料的有效性。
通过上述元数据配置和详细解析，我们成功地将旺店通销售出库单的数据转换并写入到金蝶云星空系统中，实现了不同系统间的数据无缝对接。这一过程不仅提升了业务透明度和效率，也确保了数据处理过程中的准确性和一致性。
