利用轻易云平台实现金蝶云星空数据高效转换

分步式调入单至直接调拨单：金蝶云星空API使用详解

2021-04-22 00:27:36
轻易云集成顾问-彭亮

分步式调入单-直接调拨单OK：金蝶云星空系统对接集成案例

在本文中，我们将探讨如何使用轻易云数据集成平台，将企业的业务数据从金蝶云星空系统高效、安全地迁移到同一套金蝶云星空环境下，以实现分步式调入单至直接调拨单的顺利转换。通过这一技术案例，我们深入分析了多个关键API接口操作，以及如何解决在实际运行中的常见问题。

API接口调用与数据处理流程

为了确保从一个金蝶云星空实例获取的数据能够无缝写入到另一个实例中，首先需要利用executeBillQuery API来抓取指定条件下的业务数据。本次对接特别强调高吞吐量的数据处理能力，因此我们采用批量查询和分页控制相结合的方式，提高了数据获取和传输效率，同时避免因大量请求导致的限流或超时问题。此外，通过定制化的数据映射逻辑，有效应对源数据信息格式与目标系统要求之间的差异。

高性能批量写入及实时监控

在获取并转换好所需业务数据后，下一步便是通过batchSave API进行集中、高速地写入操作。在此过程中，我们应用了轻易云平台提供的数据质量监控和异常检测功能，保障每个步骤都准确执行，并能及时捕获和处理潜在错误。例如，如果发生网络抖动或意外故障导致部分数据未成功上传，可借助错误重试机制自动重新提交这些记录，从而保证整个任务的稳定性和可靠性。同时，通过提供可视化设计工具，使得整个配置过程更为直观、透明。

接口资产管理及告警通知

由于本次项目涉及多项重要业务交易记录，在执行期间还引进了集中式监控与告警系统，以实时跟踪任务状态。这不仅帮助我们快速识别异常情况，如频繁出现请求失败或响应延迟过长等，还能立即采取对应措施，加快问题诊断和修复速度。借助统一视图展示，各环节操作均有迹可循，为后续运维优化提供依据。在所有具体工作完成前，还会再次全面验证输出结果，并按需调整策略，持续提升整体效率。

综上所述，本篇文章开头介绍了基于技术特性的核心要点，为即将展开详细方案内容打下基础。从API调用到性能优化，再到链路监控，每个步骤都着眼实际需求，希望通过这段分享带来一些实战经验启发。企业微信与ERP系统接口开发配置

调用金蝶云星空接口executeBillQuery获取并加工数据

在数据集成过程中，调用源系统的API接口是关键的一步。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口，以获取并加工调入单-直接调拨单的数据。

接口配置与调用

首先，我们需要配置元数据以便正确调用金蝶云星空的executeBillQuery接口。以下是元数据配置的详细说明：

{
  "api": "executeBillQuery",
  "method": "POST",
  "number": "FBillNo",
  "id": "FSTKTRSINENTRY_FEntryID",
  "pagination": {
    "pageSize": 500
  },
  "idCheck": true,
  "request": [
    {"field":"FSTKTRSINENTRY_FEntryID","label":"FEntryID","type":"string","value":"FSTKTRSINENTRY_FEntryID"},
    {"field":"FID","label":"实体主键","type":"string","value":"FID"},
    {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
    {"field":"FDocumentStatus","label":"单据状态","type":"string","value":"FDocumentStatus"},
    {"field":"FStockOrgID_FNumber","label":"调入库存组织","type":"string","value":"FStockOrgID.FNumber"},
    {"field":"FDate","label":"日期","type":"string","value":"FDate"},
    {"field":"FBillTypeID","label":"单据类型","type":"string","value":"FBillTypeID.FNumber"},
    {"field":"FTransferDirect","label":"调拨方向","type":"string","value":"FTransferDirect"},
    {"field":"FNOTE","label":"备注","type":"string","value":"FNOTE"},
    {"field":"FCreateDate","label":"创建日期","type":"string","value":"FCreateDate"},
    {"field":"FApproveDate","label":"审核日期","type":"string","value":"FApproveDate"},
    {"field":"FTransferMode","label":"调拨方式","type":"","value":""},
    // ... (省略部分字段)
  ],
  "otherRequest": [
    {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
    {"field": "TopRowCount", "label": "返回总行数", "type": "int", "describe": ""},
    {"field": "FilterString", 
        "label": 
        "过滤条件",
        "type":
        "string",
        "describe":
        "示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=",
        "value":
        "FDate>='{{LAST_SYNC_TIME|date}}' and FBillTypeID.FNumber = 'FBDR04_SYS' and (FDestStockID.FNumber = '406' or FDestStockID.FNumber= 'B313')"
   },
   {
        "field":
        "FieldKeys",
        "label":
        "需查询的字段key集合",
        "type":
        "array",
        "describe":
        "金蝶分录主键ID格式：FPOOrderEntry_FEntryId,其它格式 FPurchaseOrgId.FNumber",
        "parser":{
            "name":
            "ArrayToString",
            "params":
            ","
        }
   },
   {
        "field":
        "FormId",
        "label":
        "业务对象表单Id",
        "type":
        "string",
        "value":
        "STK_TRANSFERIN"
   }
 ]
}

请求参数详解

基本请求参数：
- api: 指定调用的API名称，这里为executeBillQuery。
- method: 请求方法，使用POST。
- number: 用于标识单据编号的字段，这里为FBillNo。
- id: 用于标识唯一记录的字段，这里为FSTKTRSINENTRY_FEntryID。
分页配置：
- pagination.pageSize: 每次请求返回的数据条数，这里设置为500。
请求字段：
- 配置了多个字段，如FID, FBillNo, FDocumentStatus, FStockOrgID_FNumber, 等等。这些字段将作为请求体的一部分发送给金蝶云星空接口。
其他请求参数：
- Limit: 最大行数，用于分页。
- StartRow: 开始行索引，用于分页。
- FilterString: 过滤条件，用于筛选特定的数据。
- FieldKeys: 查询字段集合，用于指定需要返回的字段。
- FormId: 表单ID，这里指定为STK_TRANSFERIN。

数据处理

在成功调用API并获取到数据后，需要对数据进行清洗和加工。以下是一些常见的数据处理步骤：

数据清洗：
- 去除重复记录：根据唯一标识（如FID）去重。
- 数据格式转换：将日期、金额等字段转换为标准格式。
数据转换：
- 字段映射：将源系统中的字段映射到目标系统中的对应字段。
- 数据聚合：根据业务需求，对数据进行汇总和统计。
数据写入：
- 将处理后的数据写入目标系统，确保数据的一致性和完整性。

通过上述步骤，我们可以高效地从金蝶云星空获取所需的数据，并进行必要的清洗和加工，为后续的数据集成打下坚实基础。用友与外部系统接口集成开发

数据集成与ETL转换：将源平台数据写入金蝶云星空API接口

在数据集成的生命周期中，ETL（Extract, Transform, Load）转换是关键步骤之一。本文将详细探讨如何将已经集成的源平台数据通过ETL转换，最终写入金蝶云星空API接口。

API接口配置

我们使用的API接口为batchSave，采用POST方法。以下是主要的元数据配置：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "FBillNo,FTransferDirect,FDate",
    "bodyName": "details",
    "bodySum": ["FQty"],
    "header": ["FBillNo", "FTransferDirect", "FDate"],
    "body": ["FMaterialID_FNumber", "FQty"]
  },
  ...
}

请求参数解析

请求参数包含多个字段，每个字段都有特定的类型和描述。以下是部分关键字段及其配置：

FBillNo: 单据编号，类型为字符串。
FBillTypeID: 单据类型，通过ConvertObjectParser解析，固定值为ZJDB01_SYS。
FBizType: 业务类型，固定值为NORMAL。
FTransferDirect: 调拨方向，固定值为GENERAL。
FSaleOrgId: 销售组织，通过ConvertObjectParser解析。
FStockOutOrgId: 调出库存组织，固定值为104。
FOwnerOutIdHead: 调出货主，通过ConvertObjectParser解析，固定值为104。
FStockOrgId: 调入库存组织，固定值为101。
FOwnerIdHead: 调入货主，通过ConvertObjectParser解析，固定值为101。

明细信息配置

明细信息（FBillEntry）包含多个子字段，每个子字段也有特定的类型和描述：

{
  "field": "FBillEntry",
  ...
  "children": [
    {
      "field": "FMaterialId",
      ...
      "value": "{{details.FMaterialID_FNumber}}"
    },
    {
      "field": "FQty",
      ...
      "value": "{{details.FQty}}"
    },
    {
      ...
      ...
    }
  ]
}

例如：

FMaterialId: 物料编码，通过 ConvertObjectParser 解析，对应 details.FMaterialID_FNumber
FQty: 调拨数量，对应 details.FQty

数据转换逻辑

在数据转换过程中，我们需要特别注意以下几点：

字段映射与解析
- 使用 ConvertObjectParser 对某些字段进行特殊解析，例如组织、货主等基础资料字段。
固定值与动态值结合
- 某些字段具有固定值，例如单据类型、业务类型等；而其他字段则从源数据中动态获取，例如单据编号、日期等。

条件判断

对于某些字段，如调出仓库（FSrcStockId），需要根据条件进行赋值。例如：

case when '{{FDestStockID.FNumber}}' ='406' then 'CK001' 
  when '{{FDestStockID.FNumber}}' ='B313' then 'CK002' 
  else 'CK001' end

数据写入目标平台

在完成数据转换后，将数据通过API接口写入金蝶云星空平台。以下是一个简化的请求示例：

{
  "FormId": "STK_TransferDirect",
  ...
  "Model": {
    ...
    "FBillNo": "{FBillNo}",
    ...
    "FBillEntry": [
      {
        ...
        "FMaterialId": "{{details.FMaterialID_FNumber}}",
        ...
        "FQty": "{{details.FQty}}"
        ...
      }
    ]
  }
}

通过上述配置和请求，我们实现了从源平台到金蝶云星空平台的数据无缝对接。这不仅提高了数据处理效率，还确保了数据的一致性和准确性。

以上内容展示了如何利用轻易云数据集成平台进行ETL转换，并通过API接口将数据写入目标平台。希望这些技术细节能帮助你更好地理解和应用该平台的功能。电商OMS与WMS系统接口开发配置

版权声明

该文章《利用轻易云平台实现金蝶云星空数据高效转换》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。