### MySQL数据集成到金蝶云星空：MOM-ZJDB-直接调拨单案例分享
在本次技术分享中，我们将详细介绍如何使用轻易云数据集成平台，实现从MySQL数据库到金蝶云星空的高效数据同步。通过具体解析MOM-ZJDB-直接调拨单的集成方案，我们不仅关注成功的数据流设计，还强调关键技术要点和实际操作中的注意事项。
**背景**
我们的任务是确保MySQL系统中的大量直接调拨单数据能够高效、准确地写入到金蝶云星空。为此，选择了轻易云的平台进行全流程控制，从源头抓取数据，到目标系统API调用，每一步都至关重要。
**关键步骤**
1. **定时可靠的数据抓取**
通过配置轻易云的数据源接口，利用MySQL提供的`select` API，我们首先实现了对调拨单数据的定时提取。这一过程必须考虑接口的分页和限流问题，以避免大规模查询导致性能瓶颈或者资源耗尽。
2. **自定义转换与映射**
调拨单的数据格式在两个系统间存在差异。使用平台提供的自定义转换逻辑功能，可以根据业务需求灵活调整字段映射关系，确保每条记录都能正确无误地传递到目标系统。
3. **实时监控与日志记录**
为保障整个流程透明可控，引入集中监控和告警机制，通过可视化界面实时跟踪各个任务节点状态。同时，将所有操作细节记录存档，便于后期审计与问题追溯。
4. **批量高速写入金蝶云星空**
使用金蝶云星空提供的`batchSave` API，实现对接收方的大量并发请求处理。在保证吞吐量和响应速度方面，这一环节尤为关键，需要合理安排批次大小并优化网络参数设置以达到最佳效果。
5. **异常处理及重试机制**
数据传输过程中不可避免会遇到各种异常情况，包括网络不稳定、接口调用失败等。因此，为每个主要任务节点设置了健壮的错误捕获与重试策略，一旦出现问题即刻修复继续执行，以保证整体业务不中断。
综上所述，通过精确规划各项技术细节，本方案有效提升了复杂业务场景下的数据处理能力，实现两大企业级系统之间的信息互联互通，为应用环境带来显著效率改进和用户体验升级。
### 使用轻易云数据集成平台调用MySQL接口获取并加工数据
在数据集成过程中，调用源系统的API接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用MySQL接口`select`来获取并加工数据。
#### 元数据配置解析
首先，我们需要理解元数据配置`metadata`中的各个字段及其作用。以下是关键字段的解释：
- `api`: 表示调用的API类型，这里是`select`。
- `effect`: 指定API的效果，这里是查询（QUERY）。
- `method`: HTTP请求方法，这里使用POST。
- `id`: 数据源标识符，这里为`sourceid`。
- `request`: 包含请求参数的详细信息。
- `main_params`: 主参数对象，包含两个子参数：
- `limit`: 限制结果集返回的行数，分页查询时非常有用。
- `offset`: 指定查询结果的起始位置或偏移量。
- `otherRequest`: 包含主SQL语句及其动态字段配置。
#### SQL语句与参数绑定
主SQL语句中使用了动态字段，如`:limit`和`:offset`，这些字段需要在执行查询之前进行参数绑定。以下是主SQL语句：
```sql
select
t1.iface_id as sourceid,
CONCAT(t1.instruction_doc_num, '_', t1.instruction_doc_line_num, '_', t1.iface_id) as '单据编号',
ifnull((select aft_quiet_time from ty_mes.mt_account_period where t1.account_date < aft_quiet_time order by account_period_id desc limit 1), t1.account_date) as '单据日期',
t1.type_id as '单据类型',
t1.transfer_type as '调拨类型',
t1.transfer_direct as '调拨方向',
t1.out_org_id as '调出库存组织',
t1.out_owner_type as '调出货主类型',
t1.plant_id as '调入库存组织',
t1.in_owner_type as '调入货主类型',
t1.material_id as '明细物料编码',
t1.from_warehouse_id as '明细调出仓库',
t1.to_warehouse_id as '明细调入仓库',
t1.uom_id as '明细单位',
t1.actual_qty as '明细调拨数量',
t1.mto_num as '明细计划跟踪号',
t1.base_unit_id as '明细基本单位',
t1.out_owner_line_id as '明细调出货主',
t1.out_owner_line_type as '明细调出货主类型',
t1.in_owner_line_id as '明细调入货主',
t1.in_owner_line_type as '明细调入货主类型',
t1.out_keeper as '明细调出保管者',
t1.out_keep_type as '明细调出保管者类型',
t1.in_keeper as '明细调入保管者',
t1.in_keep_type as '明细调入保管者类型',
t1.attribute1 as '明细批号'
from ty_mes.wms_transfer_iface t1
where t1.tenant_id = 7
and t1.return_order = 1
and t1.`STATUS` in ('N', 'E')
limit :limit offset :offset
```
#### 参数绑定与执行
在执行上述SQL查询之前，需要将请求参数绑定到SQL语句中的占位符。以下是具体步骤：
##### 绑定步骤
```json
{
"main_params": {
"limit": "{PAGINATION_PAGE_SIZE}",
"offset": "{PAGINATION_START_ROW}"
}
}
```
在实际操作中，假设我们需要每次查询返回10条记录，并从第20条记录开始，则可以将参数设置为：
```json
{
"main_params": {
"limit": 10,
"offset": 20
}
}
```
##### 执行查询
通过轻易云数据集成平台，可以发送POST请求来执行上述配置：
```json
{
"api": "select",
"effect": "QUERY",
"method": "POST",
"id": "sourceid",
"request": [
{
"field": "main_params",
"label": "主参数",
"type": "object",
"value": {
"limit": 10,
"offset": 20
}
}
],
"otherRequest": [
{
"field": "main_sql",
"label": "主SQL语句",
"type": "string",
"value": "<上述SQL语句>"
}
]
}
```
#### 数据处理与清洗
在获取到原始数据后，可以利用轻易云平台提供的数据清洗功能对数据进行进一步处理。例如，可以对日期格式进行转换，对空值进行填充等操作。这些操作可以通过可视化界面进行配置，无需编写复杂的代码。
#### 实时监控与日志记录
轻易云平台提供实时监控和日志记录功能，可以帮助用户随时了解数据流动和处理状态。一旦出现问题，可以快速定位并解决，从而保证数据集成过程的稳定性和可靠性。
通过以上步骤，我们成功地调用了MySQL接口获取并加工了所需的数据。这不仅提高了数据处理效率，还确保了数据的一致性和准确性。
### 轻易云数据集成平台的ETL转换与金蝶云星空API接口对接
在数据集成生命周期的第二步中，关键任务是将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，并转为目标平台——金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细探讨这一过程中涉及的技术细节和元数据配置。
#### 数据请求与清洗
首先，我们需要从源系统提取数据，并进行必要的清洗和预处理。这一步骤确保了数据的一致性和完整性，为后续的转换和写入奠定基础。
#### 数据转换与写入
在完成初步的数据清洗后，下一步是将这些数据转换为金蝶云星空API接口所能接受的格式。以下是一个典型的元数据配置示例：
```json
{
"api": "batchSave",
"effect": "EXECUTE",
"method": "POST",
"idCheck": true,
"request": [
{
"field": "FBillNo",
"label": "单据编号",
"type": "string",
"describe": "单据编号",
"value": "{{单据编号}}"
},
{
"field": "FBillTypeID",
"label": "单据类型",
"type": "string",
"describe": "单据类型",
"parser": {"name":"ConvertObjectParser","params":"FNumber"},
"value": "{{单据类型}}"
},
{
// 其他字段配置...
}
],
// 其他配置...
}
```
#### 核心字段解析
1. **FBillNo（单据编号）**：这是一个字符串类型字段，用于唯一标识每一张调拨单。其值通过模板变量`{{单据编号}}`动态填充。
2. **FBillTypeID（单据类型）**：同样是字符串类型，但需要通过`ConvertObjectParser`进行解析，将业务系统中的编码转换为金蝶云星空所需的格式。
3. **FBizType（业务类型）**、**FTransferDirect（调拨方向）**、**FTransferBizType（调拨类型）**等字段：这些字段通常是下拉列表或固定值，在元数据配置中直接指定了默认值，如`"value":"NORMAL"`。
4. **组织相关字段**：如`FSaleOrgId（销售组织）`、`FSettleOrgId（结算组织）`等，这些字段需要通过解析器将原始编码转换为目标系统认可的编码格式。
5. **日期和备注字段**：如`FDate（日期）`、`FNote（备注）`等，这些字段直接从源系统中获取并填充，无需额外处理。
6. **明细信息（FBillEntry）**：这是一个数组类型，包含多个子项，每个子项代表调拨单中的一条明细记录。子项中包括物料编码、仓库信息、数量等详细信息，同样需要通过解析器进行处理。
#### 批量保存操作
在所有字段都正确映射并填充后，通过调用金蝶云星空API的批量保存接口，实现数据写入：
```json
{
"operation":{
"rowsKey":"array",
"rows":1,
"method":"batchArraySave"
},
// 其他配置...
}
```
此处指定了批量操作的方法为`batchArraySave`，并且设置了每次提交的数据行数为1。
#### 提交与审核
为了确保数据的一致性和准确性，可以启用自动提交并审核功能：
```json
{
"IsAutoSubmitAndAudit": true,
// 其他配置...
}
```
这意味着在成功写入数据后，系统会自动提交并审核该调拨单，无需手动干预。
#### 验证基础资料
为了确保所有基础资料的有效性，可以启用验证功能：
```json
{
"IsVerifyBaseDataField": true,
// 其他配置...
}
```
这一步骤可以防止由于无效或缺失基础资料而导致的数据写入失败。
通过上述步骤，我们实现了从源平台到金蝶云星空API接口的数据ETL转换和写入。利用轻易云数据集成平台提供的全异步、多异构系统支持功能，可以高效地完成不同系统间的数据无缝对接，提高业务透明度和效率。
