旺店通退货入库对接金蝶销售退货单_关联
本案例将详细解析如何实现旺店通·企业奇门数据集成到金蝶云星空，具体聚焦于实现“旺店通退货入库对接金蝶销售退货单”的技术细节和关键步骤。
在整个数据集成过程中，我们采用了轻易云平台，通过调用wdt.stockin.order.query.refund接口从旺店通获取退货订单的数据，并利用金蝶云星空的batchSave接口将这些数据批量写入到对应的销售退货单中。以下是实现该集成的一些关键要点。
-
确保不漏单： 通过定时任务可靠抓取旺店通·企业奇门API提供的数据，确保每一笔数据都被准确抓取。我们设置了合理的时间间隔与重试机制，以保证系统高峰期间也能无缝衔接。
-
快速大量数据写入： 面临大批量的数据处理需求时，我们采用并发异步操作，将提高运行效率。专注于每次请求的数据包大小优化，使其既不过度消耗系统资源，也不会因为太小而增加请求次数导致低效。
-
分页与限流问题处理： 针对旺店通API返回的大量分页结果和接口调用频率限制，我么设计了一套智能分页调度策略，同时监控并动态调整请求速度，避免触发限流限制，从而保障稳定的数据同步流程。
-
解决数据格式差异： 旺店通返回的原生数据格式往往和金蝶云期望的不一致。通过使用轻易云强大的自定义映射功能，实现两者之间多种对象类型与字段名称、规则转换，高效平滑完成各种复杂的数据映射工作。例如，将JSON结构拆解为标准化表格形式，再依据业务需要进行字段匹配映射。
-
异常处理及错误重试机制： 系统运行中难免出现偶发性错误，比如网络波动或第三方服务故障，为此我们设计了一套完备的异常捕捉和自动重试方案，对常见错误情况进行预先分类设定策略，如当遇到超时报错后台会自动再次尝试提交以减少人为干预，提高整体稳定性。同时实时日志记录，有助于后期审计及问题定位分析.
即便涉及多个API及其交互环节，通过全面配置元数据管理工具，实现全程可视化追踪，每一步骤都清晰展现当前状态。这不仅仅帮助开发部署团队更直观了解每个流程细节，还极大增强运维人员应急能力
调用旺店通·企业奇门接口wdt.stockin.order.query.refund获取并加工数据
在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口wdt.stockin.order.query.refund，并对获取的数据进行初步加工。
接口调用配置
首先，我们需要配置API接口的调用参数。根据提供的元数据配置，我们将使用POST方法来请求数据。以下是具体的请求参数：
- api:
wdt.stockin.order.query.refund - method:
POST - number:
order_no - id:
order_no - pagination: 每页返回50条数据
请求体中的字段包括：
- start_time: 增量获取数据的开始时间，格式为
yyyy-MM-dd HH:mm:ss。 - end_time: 增量获取数据的结束时间，格式为
yyyy-MM-dd HH:mm:ss。 - status: 入库单状态，默认查询已完成单据（状态码80）。
- shop_no: 店铺编号，用于区分不同店铺的数据。
- page_size: 每页返回的数据条数，范围为1~50，默认值为40。
- page_no: 页号，不传值默认从0页开始。
请求参数示例
{
"start_time": "{{LAST_SYNC_TIME|datetime}}",
"end_time": "{{CURRENT_TIME|datetime}}",
"status": "80",
"shop_no": "SHOP123",
"page_size": 50,
"page_no": 0
}数据处理与转换
在获取到原始数据后，需要对其进行初步加工和转换，以便后续的数据写入和分析。根据元数据配置中的formatResponse字段，我们需要对返回结果中的stockin_time字段进行日期格式转换，并重命名为stockin_time_new。
数据转换示例
假设原始返回结果如下：
{
"order_no": "123456",
"stockin_time": "2023-10-01 12:00:00",
// 其他字段...
}经过转换后的结果应为：
{
"order_no": "123456",
"stockin_time_new": "2023-10-01T12:00:00Z",
// 其他字段...
}实现步骤
- 初始化请求参数：根据当前时间和上次同步时间设置
start_time和end_time。 - 发送API请求：使用POST方法调用接口，并传入必要的参数。
- 处理响应数据：对返回的数据进行解析，并按照元数据配置进行字段重命名和格式转换。
- 分页处理：如果有分页需求，根据响应中的分页信息继续请求下一页的数据，直到所有数据获取完毕。
示例代码（伪代码）
import requests
import datetime
# 初始化请求参数
start_time = get_last_sync_time().strftime('%Y-%m-%d %H:%M:%S')
end_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
params = {
'start_time': start_time,
'end_time': end_time,
'status': '80',
'shop_no': 'SHOP123',
'page_size': 50,
'page_no': 0
}
# 发起API请求
response = requests.post('https://api.wangdiantong.com/wdt.stockin.order.query.refund', json=params)
data = response.json()
# 数据处理与转换
for record in data['orders']:
record['stockin_time_new'] = convert_date_format(record['stockin_time'])
del record['stockin_time']
# 分页处理（简化示例）
while data['has_more']:
params['page_no'] += 1
response = requests.post('https://api.wangdiantong.com/wdt.stockin.order.query.refund', json=params)
data = response.json()
for record in data['orders']:
record['stockin_time_new'] = convert_date_format(record['stockin_time'])
del record['stockin_time']通过上述步骤，我们可以高效地调用旺店通·企业奇门接口获取退货入库单据，并对其进行初步加工，为后续的数据写入和分析奠定基础。
数据集成生命周期中的ETL转换：对接金蝶云星空API接口
在数据集成生命周期的第二步中，我们需要将已经集成的源平台数据进行ETL转换，并转为目标平台金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细探讨如何通过轻易云数据集成平台实现这一过程。
API接口配置
首先，我们需要配置API接口相关的元数据，以确保数据能够正确地传输到金蝶云星空。以下是一个典型的API配置示例：
{
"api": "batchSave",
"method": "POST",
"idCheck": true,
"operation": {
"method": "batchArraySave",
"rows": 1,
"rowsKey": "array"
},
"request": [
{
"field": "FBillTypeID",
"label": "单据类型",
"type": "string",
"describe": "单据类型",
"parser": {
"name": "ConvertObjectParser",
"params": "FNumber"
},
"value": "WDTXSTH"
},
...
],
...
}数据字段映射与转换
在ETL过程中，数据字段的映射与转换是关键步骤。我们需要将源平台的数据字段映射到金蝶云星空API所要求的字段，并进行必要的数据转换。例如：
- 单据类型 (
FBillTypeID): 固定值WDTXSTH - 单据编号 (
FBillNo): 从源数据中提取{order_no} - 销售组织 (
FSaleOrgId): 使用_mongoQuery查询并转换 - 日期 (
FDate): 使用模板引擎进行日期格式化{{check_time|dateTime}} - 库存组织 (
FStockOrgId): 固定值998 - 退货客户 (
FRetcustId): 使用_mongoQuery查询并转换 - 结算币别 (
FSettleCurrId): 固定值PRE001 - 备注 (
FHeadNote): 从源数据中提取{remark}
明细信息处理
对于明细信息，我们需要逐条处理每个子项，并确保其格式符合目标平台的要求。例如：
{
"field": "FEntity",
"label": "明细信息",
...
"children": [
{
...
{
"field": "FMaterialId",
...
"value": "{{details_list.spec_no}}"
},
{
...
...
...
}
}
]
}在这个配置中，每个子项都包含多个字段，如物料编码、实退数量、含税单价等。这些字段同样需要通过模板引擎或查询语句进行动态赋值。
子表关联关系处理
为了确保数据的一致性和完整性，我们还需要处理子表之间的关联关系。例如：
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
...
{
field: 'FEntity_Link',
label: '关联关系表',
type: 'array',
parent: 'FEntity',
children: [
{ field: 'FEntity_Link_FRuleId', label: '转换规则', type: 'string', value: 'SaleOrder-SalReturnStock' },
{ field: 'FEntity_Link_FSTableName', label: '源单表', type: 'string', value: 'T_SAL_ORDERENTRY' },
{ field: 'FEntity_Link_FSBillId', label: '源单内码', type: 'string', value: '_mongoQuery ...' },
{ field: 'FEntity_Link_FSId', label: '源单分录内码', type: 'string', value: '_mongoQuery ...' }
]
}
}
}
}
}
}
}
}
}
}
]
}在这里，我们定义了关联关系表 FEntity_Link，并为其设置了多个子字段，如转换规则、源单表、源单内码等。这些字段同样需要通过查询语句进行动态赋值。
提交与审核
最后，在完成所有数据字段的映射与转换后，我们可以通过API接口将数据提交到金蝶云星空，并执行自动审核操作：
{
...
{
field: 'IsAutoSubmitAndAudit',
label: '提交并审核',
type: 'bool',
value: true
},
{
field: 'IsVerifyBaseDataField',
label: '验证基础资料',
type: 'bool',
describe: '是否验证所有的基础资料有效性，布尔类，默认false（非必录）',
value: true
}
}通过以上配置和操作，我们实现了从源平台到目标平台的数据ETL转换，并成功对接了金蝶云星空API接口。
