markdown

![](https://pic.qeasy.cloud/QEASY/A81.png)

### SYB生产用料清单新增-深圳天一-半成品-好：MySQL数据集成到金蝶云星空的技术实现

在企业信息化系统中，数据的高效流转和准确对接是确保业务顺畅运行的关键。本文将聚焦于一个具体案例——如何将MySQL中的生产用料清单数据集成到金蝶云星空平台，方案名称为“SYB生产用料清单新增-深圳天一-半成品-好”。通过这一案例，我们将探讨在数据集成过程中所涉及的技术要点和解决方案。

首先，我们需要从MySQL数据库中获取生产用料清单的数据。为了确保数据不漏单且能够定时可靠地抓取，我们采用了MySQL接口select进行数据提取，并结合轻易云平台提供的集中监控和告警系统，实时跟踪任务状态与性能。这不仅保证了数据提取过程的稳定性，还能及时发现并处理异常情况。

接下来，面对大量的数据写入需求，我们利用了金蝶云星空提供的batchSave API接口，实现批量数据快速写入。为了应对不同系统之间的数据格式差异，我们设计了自定义的数据转换逻辑，使得每条记录都能准确映射到目标平台。此外，通过可视化的数据流设计工具，我们能够直观地管理和调整整个集成流程，从而提升操作效率。

在实际操作中，还需特别注意分页和限流问题，以防止因一次性传输过多数据而导致系统性能下降或超时错误。为此，我们设置了合理的分页策略，并结合异常处理与错误重试机制，确保每次传输都能成功完成。

通过上述技术手段，不仅实现了MySQL与金蝶云星空之间的数据无缝对接，还大幅提升了整体业务流程的透明度和效率。在后续章节中，将详细介绍具体实施步骤及相关配置细节。
![金蝶与WMS系统接口开发配置](https://pic.qeasy.cloud/D29.png)

![打通钉钉数据接口](https://pic.qeasy.cloud/QEASY/A2.png)

### 调用MySQL接口select获取并加工数据

在轻易云数据集成平台中，生命周期的第一步是调用源系统MySQL接口`select`获取并加工处理数据。本文将详细探讨如何通过配置元数据，实现从MySQL数据库中高效、安全地提取所需数据，并进行初步加工。

#### 配置元数据解析

首先，我们需要理解和配置元数据，以便正确调用MySQL接口。以下是关键的元数据配置项：

- **api**: `"select"` 表示我们要执行的是查询操作。
- **effect**: `"QUERY"` 指明了操作类型为查询。
- **method**: `"POST"` 采用POST方法进行请求。
- **number**: `"生产订单号"` 用于标识生产订单号字段。
- **id**: `{{生产订单号}}{{物料编号}}` 组合生成唯一ID，用于确保每条记录的唯一性。
- **idCheck**: `true` 启用ID检查，防止重复记录。

#### 请求参数设置

为了实现分页查询和限流，我们需要设置请求参数：

```json
"request": [
    {
        "field": "main_params",
        "label": "main_params",
        "type": "object",
        "describe": "111",
        "value": "1",
        "children": [
            {"field": "limit", "label": "limit", "type": "string", "value":"100"},
            {"field": "offset", "label": "offset", "type":"string"}
        ]
    }
]
```

上述配置定义了分页参数`limit`和`offset`，其中`limit`设定每次查询返回的最大记录数，而`offset`则用于指定从哪一条记录开始读取。这种设计可以有效处理大规模数据集，避免一次性加载过多数据导致系统性能下降。

#### 主SQL语句

主SQL语句是整个查询过程的核心部分，它决定了从数据库中提取哪些字段以及如何进行初步的数据加工：

```sql
SELECT 
  CASE m.delivery_org
    WHEN 'T01.01' THEN CONCAT('HJ', CAST(i.id AS CHAR))
    WHEN 'T04' THEN CONCAT('HJGD', CAST(i.id AS CHAR))
  END AS 生产订单号,
  a.part_no AS 成品编号,
  DATE(a.update_time) AS 日期,
  a.req_num AS 生产数量,
  a.mold_no AS 计划跟踪号,
  CONCAT(a.part_no, '_WW') AS 物料编号,
  i.id AS sourceid,
  a.req_num AS 领料数量,
  m.delivery_org AS 供应组织
FROM mbs_nuclear_price_info i
LEFT JOIN mbs_nuclear_price_task a ON i.nuclear_price_task_uuid = a.nuclear_price_task_uuid
LEFT JOIN mbs_order_plan_bom l ON a.mold_no = l.bom_no
LEFT JOIN mbs_order_bom m ON m.bom_uuid = l.bom_uuid
WHERE 
a.is_cancel = '1'
AND a.company_code = 'TYZN'
AND i.create_time > (SELECT config_value FROM sys_config WHERE config_id=337)
AND a.if_close = '1'
AND i.outsourced_type = '1'
AND i.out_type = '4'
AND i.is_success2 != '1'
AND i.is_success = '1'
LIMIT :limit OFFSET :offset;
```

该SQL语句通过多个表连接和条件过滤，从不同表中提取相关字段，并对某些字段进行了格式转换。例如，通过CASE语句根据不同的供应组织生成特定格式的生产订单号。

#### 自动填充响应与遗漏补救

为了确保数据完整性和一致性，轻易云平台提供了自动填充响应功能：

```json
"autoFillResponse": true
```

此外，还可以配置遗漏补救机制，通过定时任务（如crontab）定期检查并重新抓取遗漏的数据：

```json
"omissionRemedy":{
    "crontab":"1 1 * * *",
    ...
}
```

这种机制保证了即使在网络波动或其他异常情况下，也能及时发现并补齐缺失的数据。

#### 实时监控与日志记录

在实际操作过程中，实时监控与日志记录至关重要。轻易云平台提供集中的监控和告警系统，可以实时跟踪每个数据集成任务的状态和性能。一旦出现异常情况，如超时或错误，将立即触发告警通知相关人员进行处理。

综上所述，通过合理配置元数据、优化SQL查询、设置分页参数以及启用自动填充响应与遗漏补救机制，可以高效、安全地实现从MySQL数据库中获取并加工处理数据。这不仅提升了业务透明度和效率，也为后续的数据转换与写入奠定了坚实基础。
![用友与外部系统接口集成开发](https://pic.qeasy.cloud/S23.png)

![数据集成平台API接口配置](https://pic.qeasy.cloud/QEASY/A62.png)

### 将源平台数据ETL转换并写入金蝶云星空API接口

在数据集成生命周期的第二步中，关键任务是将已经集成的源平台数据进行ETL（抽取、转换、加载）处理，以符合目标平台——金蝶云星空API接口所能接收的数据格式。以下是具体的技术实现和注意事项。

#### 数据抽取与清洗

首先，从源平台抽取需要的数据。假设源平台是MySQL数据库，通过定时任务抓取生产订单相关的数据。为了确保数据的完整性和一致性，可以使用分页查询和限流技术，防止一次性获取大量数据导致系统性能问题。

```sql
SELECT * FROM production_orders WHERE status = 'active' LIMIT 1000 OFFSET 0;
```

#### 数据转换

将抽取到的数据转化为金蝶云星空API能够接受的格式，这是ETL过程中的核心部分。以下是元数据配置中的一些关键字段及其转换逻辑：

1. **FID**: 从生产订单号中找到对应的FID。
   ```plaintext
   "FID": "_findCollection find FID from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}"
   ```

2. **子项明细**: 包含多个子字段，如子项物料编码、用量类型、分子、分母等，需要根据业务规则进行转换。例如，`FMaterialID2`通过`ConvertObjectParser`解析为物料编码，`FStdQty`通过自定义函数进行数量四舍五入处理。

```plaintext
   "FMaterialID2": "{{物料编号}}",
   "FStdQty": "_function ROUND( {{领料数量}} , 3 )"
   ```

3. **发料组织**: 根据供应组织进行条件判断并赋值。
   ```plaintext
   "FSupplyOrg": "_function case '{{供应组织}}' when 'T01.01' then 'T01.06' when 'T04' then 'T04' else '' end"
   ```

4. **生产订单内码和分录内码**: 通过关联查询获取。
   ```plaintext
   "FMoId1": "_findCollection find FMoId from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}",
   "FMoEntryId1": "_findCollection find FMOEntryID from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}"
   ```

#### 数据加载

完成数据转换后，将其通过POST请求批量写入金蝶云星空API接口。以下是批量保存操作的元数据配置：

```plaintext
"api": "batchSave",
"method": "POST",
"request": [
    {
        "field": "FID",
        ...
    },
    {
        "field": "FEntity",
        ...
    }
],
"otherRequest": [
    {
        "field": "FormId",
        ...
    },
    {
        "field": "Operation",
        ...
    }
]
```

#### 实现细节与注意事项

1. **高吞吐量支持**：确保大量数据能够快速写入金蝶云星空，避免因数据积压导致系统性能下降。
2. **实时监控与告警**：利用集中的监控和告警系统，实时跟踪数据集成任务的状态和性能，及时发现并处理异常情况。
3. **错误重试机制**：在对接过程中可能会遇到网络故障或API调用失败等情况，需要实现错误重试机制以提高系统的可靠性。
4. **自定义数据映射**：根据业务需求定制化数据映射逻辑，确保每个字段都能正确映射到目标平台。

通过以上步骤，实现了从MySQL到金蝶云星空的数据ETL转换，并成功将转换后的数据写入目标平台。在整个过程中，充分利用轻易云提供的高效工具和特性，使得复杂的数据集成任务变得更加简洁和高效。
![如何对接钉钉API接口](https://pic.qeasy.cloud/T14.png)

![如何对接用友BIP接口](https://pic.qeasy.cloud/QEASY/A47.png)

MySQL数据集成至金蝶云星空的解决方案

SYB生产用料清单新增-深圳天一-半成品-好：MySQL数据集成到金蝶云星空的技术实现

通过上述技术手段，不仅实现了MySQL与金蝶云星空之间的数据无缝对接，还大幅提升了整体业务流程的透明度和效率。在后续章节中，将详细介绍具体实施步骤及相关配置细节。金蝶与WMS系统接口开发配置

打通钉钉数据接口

调用MySQL接口select获取并加工数据

在轻易云数据集成平台中，生命周期的第一步是调用源系统MySQL接口select获取并加工处理数据。本文将详细探讨如何通过配置元数据，实现从MySQL数据库中高效、安全地提取所需数据，并进行初步加工。

配置元数据解析

首先，我们需要理解和配置元数据，以便正确调用MySQL接口。以下是关键的元数据配置项：

api: "select" 表示我们要执行的是查询操作。
effect: "QUERY" 指明了操作类型为查询。
method: "POST" 采用POST方法进行请求。
number: "生产订单号" 用于标识生产订单号字段。
id: {{生产订单号}}{{物料编号}} 组合生成唯一ID，用于确保每条记录的唯一性。
idCheck: true 启用ID检查，防止重复记录。

请求参数设置

为了实现分页查询和限流，我们需要设置请求参数：

"request": [
    {
        "field": "main_params",
        "label": "main_params",
        "type": "object",
        "describe": "111",
        "value": "1",
        "children": [
            {"field": "limit", "label": "limit", "type": "string", "value":"100"},
            {"field": "offset", "label": "offset", "type":"string"}
        ]
    }
]

上述配置定义了分页参数limit和offset，其中limit设定每次查询返回的最大记录数，而offset则用于指定从哪一条记录开始读取。这种设计可以有效处理大规模数据集，避免一次性加载过多数据导致系统性能下降。

主SQL语句

主SQL语句是整个查询过程的核心部分，它决定了从数据库中提取哪些字段以及如何进行初步的数据加工：

SELECT 
  CASE m.delivery_org
    WHEN 'T01.01' THEN CONCAT('HJ', CAST(i.id AS CHAR))
    WHEN 'T04' THEN CONCAT('HJGD', CAST(i.id AS CHAR))
  END AS 生产订单号,
  a.part_no AS 成品编号,
  DATE(a.update_time) AS 日期,
  a.req_num AS 生产数量,
  a.mold_no AS 计划跟踪号,
  CONCAT(a.part_no, '_WW') AS 物料编号,
  i.id AS sourceid,
  a.req_num AS 领料数量,
  m.delivery_org AS 供应组织
FROM mbs_nuclear_price_info i
LEFT JOIN mbs_nuclear_price_task a ON i.nuclear_price_task_uuid = a.nuclear_price_task_uuid
LEFT JOIN mbs_order_plan_bom l ON a.mold_no = l.bom_no
LEFT JOIN mbs_order_bom m ON m.bom_uuid = l.bom_uuid
WHERE 
a.is_cancel = '1'
AND a.company_code = 'TYZN'
AND i.create_time > (SELECT config_value FROM sys_config WHERE config_id=337)
AND a.if_close = '1'
AND i.outsourced_type = '1'
AND i.out_type = '4'
AND i.is_success2 != '1'
AND i.is_success = '1'
LIMIT :limit OFFSET :offset;

自动填充响应与遗漏补救

为了确保数据完整性和一致性，轻易云平台提供了自动填充响应功能：

"autoFillResponse": true

此外，还可以配置遗漏补救机制，通过定时任务（如crontab）定期检查并重新抓取遗漏的数据：

"omissionRemedy":{
    "crontab":"1 1 * * *",
    ...
}

这种机制保证了即使在网络波动或其他异常情况下，也能及时发现并补齐缺失的数据。

实时监控与日志记录

综上所述，通过合理配置元数据、优化SQL查询、设置分页参数以及启用自动填充响应与遗漏补救机制，可以高效、安全地实现从MySQL数据库中获取并加工处理数据。这不仅提升了业务透明度和效率，也为后续的数据转换与写入奠定了坚实基础。用友与外部系统接口集成开发

数据集成平台API接口配置

将源平台数据ETL转换并写入金蝶云星空API接口

数据抽取与清洗

SELECT * FROM production_orders WHERE status = 'active' LIMIT 1000 OFFSET 0;

数据转换

将抽取到的数据转化为金蝶云星空API能够接受的格式，这是ETL过程中的核心部分。以下是元数据配置中的一些关键字段及其转换逻辑：

FID: 从生产订单号中找到对应的FID。

"FID": "_findCollection find FID from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}"

子项明细: 包含多个子字段，如子项物料编码、用量类型、分子、分母等，需要根据业务规则进行转换。例如，FMaterialID2通过ConvertObjectParser解析为物料编码，FStdQty通过自定义函数进行数量四舍五入处理。
```
"FMaterialID2": "{{物料编号}}",
"FStdQty": "_function ROUND( {{领料数量}} , 3 )"
```

发料组织: 根据供应组织进行条件判断并赋值。

"FSupplyOrg": "_function case '{{供应组织}}' when 'T01.01' then 'T01.06' when 'T04' then 'T04' else '' end"

生产订单内码和分录内码: 通过关联查询获取。

"FMoId1": "_findCollection find FMoId from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}",
"FMoEntryId1": "_findCollection find FMOEntryID from d9c54956-106b-36e1-8018-91a8855f6316 where FMoBillNo={{生产订单号}}"

数据加载

完成数据转换后，将其通过POST请求批量写入金蝶云星空API接口。以下是批量保存操作的元数据配置：

"api": "batchSave",
"method": "POST",
"request": [
    {
        "field": "FID",
        ...
    },
    {
        "field": "FEntity",
        ...
    }
],
"otherRequest": [
    {
        "field": "FormId",
        ...
    },
    {
        "field": "Operation",
        ...
    }
]

实现细节与注意事项

高吞吐量支持：确保大量数据能够快速写入金蝶云星空，避免因数据积压导致系统性能下降。
实时监控与告警：利用集中的监控和告警系统，实时跟踪数据集成任务的状态和性能，及时发现并处理异常情况。
错误重试机制：在对接过程中可能会遇到网络故障或API调用失败等情况，需要实现错误重试机制以提高系统的可靠性。
自定义数据映射：根据业务需求定制化数据映射逻辑，确保每个字段都能正确映射到目标平台。

通过以上步骤，实现了从MySQL到金蝶云星空的数据ETL转换，并成功将转换后的数据写入目标平台。在整个过程中，充分利用轻易云提供的高效工具和特性，使得复杂的数据集成任务变得更加简洁和高效。如何对接钉钉API接口

如何对接用友BIP接口