金蝶云星辰V2数据集成到旺店通·企业版的案例分享

在此次技术案例中，我们将探讨如何高效地将金蝶云星辰V2中的采购入库单数据集成到旺店通·企业版系统中，确保数据不漏单且处理时效性得以保证。本方案通过轻易云数据集成平台，以(V2)采购入库单[金蝶->旺店通]为例，从接口调用、分页与限流处理、差异化数据映射等方面展开。

首先，通过调用金蝶云星辰V2的API/jdy/v2/scm/pur_inbound获取采购入库单的数据，并采用定时抓取机制，保证接口的数据能及时同步。同时，为了应对大批量数据传输的需求，我们设计了一套支持高吞吐量的数据写入解决方案，将大量数据快速写入到旺店通·企业版所提供的API stockin_order_push 中。

在实现过程中，考虑到了不同系统间的数据格式差异问题。我们使用自定义的数据转换逻辑，对接收到的原始数据进行处理，使其符合目标系统要求。此外，为了提升整体操作体验，整个流程都通过可视化工具进行配置和管理，从而使复杂任务更加直观易懂。

除了基本功能外，本方案还充分利用了集中监控和告警系统。实时跟踪每个步骤中的状态和性能，一旦出现异常情况能够迅速响应并采取措施。这不仅提高了任务执行的可靠性，也保障了业务运行稳定性。此外，在多次重试机制以及日志记录下，我们能够追踪并准确修复错误事件，有力确保整个过程中的一致性及完备性。

最后，通过全面掌控API资产使用情况，实现资源优化配置和高效利用。本文章开头部分即是聚焦于核心技术点，为下一步具体实施计划打下坚实基础。在随后的章节中，将详细阐述各个步骤中的实现细节与最佳实践方法。

调用金蝶云星辰V2接口获取并加工采购入库单数据

在数据集成过程中，调用源系统接口获取数据是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用金蝶云星辰V2接口/jdy/v2/scm/pur_inbound，并对获取的数据进行加工处理。

接口概述

金蝶云星辰V2的/jdy/v2/scm/pur_inbound接口用于查询采购入库单信息。该接口支持多种查询参数，可以根据不同需求灵活配置。以下是该接口的元数据配置：

{
  "api": "/jdy/v2/scm/pur_inbound",
  "effect": "QUERY",
  "method": "GET",
  "number": "bill_no",
  "id": "id",
  "name": "bill_no",
  "idCheck": true,
  "request": [
    {"field":"enable","label":"可用状态","type":"string","describe":"可用状态，1：可用，0：禁用,-1：全部","value":"1"},
    {"field":"search","label":"模糊搜索","type":"string","describe":"模糊搜索-名称、编码、规格、条形码"},
    {"field":"parent_id","label":"商品类别","type":"string","describe":"商品类别ID"},
    {"field":"isdataperm","label":"数据权限","type":"string","describe":"是否添加数据权限校验，默认false"},
    {"field":"create_start_time","label":"创建开始时间戳","type":"string","describe":"开始时间（格式：“时间戳”，-1表示不过滤），创建时间"},
    {"field":"create_end_time","label":"创建结束时间戳","type":"string","describe":"结束时间（格式：“时间戳”，-1表示不过滤），创建时间"},
    {"field":"modify_start_time","label":"修改开始时间戳","type":"string","describe":"开始时间（格式：“时间戳”，-1表示不过滤），修改时间","value":"_function {LAST_SYNC_TIME}*1000"},
    {"field":"modify_end_time","label":"修改结束时间戳","type":"string","describe":"结束时间（格式：“时间戳”，-1表示不过滤），修改时间","value":"_function {CURRENT_TIME}*1000"},
    {"field":"page","label":"当前页","type":"string","describe":"当前页（默认1）","value":"1"},
    {"field":"page_size","label":"每页显示条数","type":"string","describe":"每页显示条数（默认10，最大100）","value":"10"},
    {"field":
![钉钉与CRM系统接口开发配置](https://pic.qeasy.cloud/S26.png~tplv-syqr462i7n-qeasy.image)
### 轻易云数据集成平台生命周期第二步：ETL转换与写入旺店通·企业版API接口

在数据集成的生命周期中，ETL（Extract, Transform, Load）是至关重要的一步。本文将详细探讨如何使用轻易云数据集成平台，将已经集成的源平台数据进行ETL转换，并最终写入目标平台——旺店通·企业版API接口。

#### 配置元数据

为了实现从金蝶到旺店通·企业版的采购入库单数据推送，我们需要配置相应的元数据。以下是主要的字段配置：

1. **外部单号 (`outer_no`)**：
   - 类型：字符串
   - 描述：外部系统的唯一单据编号，避免重复推送数据
   - 值：`{bill_no}`

2. **仓库编号 (`warehouse_no`)**：
   - 类型：字符串
   - 描述：代表仓库所有属性的唯一编码，用于仓库区分，ERP内支持自定义
   - 值：`{{material_entity.stock_number}}`
   - 映射：`62135c812f31397ae436d532`

3. **是否审核 (`is_check`)**：
   - 类型：字符串
   - 描述：1表示审核，0表示不审核，默认0
   - 值：`1`

4. **是否创建批次 (`is_create_batch`)**：
   - 类型：字符串
   - 描述：0表示否，1表示是，默认是0。ERP“批次管理”不存在推送的批次号时，是否允许单据创建成功，并创建新的“批次号”。
   - 值：`1`

5. **备注 (`remark`)**：
   - 类型：字符串
   - 描述：其他入库单备注
   - 值：`erp推送单据，单据号【{bill_no}】,erp备注信息：{remark}`

6. **货品明细节点 (`goods_list`)**：
   - 类型：数组
   - 描述：入库单货品列表节点

#### 货品明细节点配置

每个货品明细节点包含多个子字段，这些字段需要根据源平台的数据进行映射和转换：

1. **商家编码 (`spec_no`)**：
   - 类型：字符串
   - 描述：ERP内单品唯一编码（SKU），代表单品(SKU)所有属性，并且为库存量出入计算最小单元。
   - 值：`{{material_entity.material_number}}`

2. **入库数量 (`stockin_num`)**：
   - 类型：字符串
   - 描述：入库数量
   - 值：`{{material_entity.qty}}`

3. **批次 (`batch_no`)**：
   - 类型：字符串
   - 描述：货品批次编号
   - 值：`{{material_entity.batch_no}}`

4. **入库价 (`stockin_price`)**：
   - 类型：字符串
   - 描述：入库价格，如推送为0默认取成本价。
   - 值：`{{material_entity.price}}`

5. **税率 (`tax`)**：
   - 类型：字符串
   - 描述：对征税对象的征收比例或征收额度。例如税率为16%，请求时填值为0.16。
   - 值：`{{material_entity.cess}}`

#### 数据转换与写入

在完成元数据配置后，需要通过轻易云数据集成平台将这些配置应用于实际的数据转换过程中。以下是具体步骤：

1. **提取（Extract）**：
    从金蝶系统中提取采购入库单的数据，包括但不限于单据编号、仓库编号、物流信息、货品明细等。

2. **转换（Transform）**：
    根据上述元数据配置，将提取的数据进行格式转换。例如，将金蝶系统中的字段映射到旺店通·企业版API所需的字段格式。

3. **加载（Load）**：
    使用HTTP POST方法，将转换后的数据通过API接口推送到旺店通·企业版。具体API调用如下：

    ```http
    POST /stockin_order_push HTTP/1.1
    Host: api.wangdiantong.com
    Content-Type: application/json

    {
        "outer_no": "{bill_no}",
        "warehouse_no": "{{material_entity.stock_number}}",
        "is_check": "1",
        "is_create_batch": "1",
        "remark": "erp推送单据，单据号【{bill_no}】,erp备注信息：【{remark}】",
        "goods_list": [
            {
                "spec_no": "{{material_entity.material_number}}",
                "stockin_num": "{{material_entity.qty}}",
                "batch_no": "{{material_entity.batch_no}}",
                "stockin_price": "{{material_entity.price}}",
                "tax": "{{material_entity.cess}}"
            }
        ]
    }

通过上述步骤，我们实现了从金蝶系统到旺店通·企业版的数据无缝对接。这不仅提高了业务流程的自动化程度，还确保了数据的一致性和准确性。