吉客云与金蝶云星空的系统对接集成案例分析：实现JY-BDS盘盈单

在实际业务中，不同平台之间的数据对接和集成是一个常见但复杂的挑战。本文将探讨如何通过一个具体方案——JY-BDS盘盈单，将吉客云的数据高效地集成到金蝶云星空，实现两大系统间的无缝连接与数据同步。

案例背景及技术概述

在本次技术案例中，我们需要从吉客云获取库存盘点数据，并将其批量写入到金蝶云星空。在此过程中，必须处理大量的数据集成操作，包括定时可靠地抓取吉客云接口数据、处理分页和限流问题，以及确保整个过程中的数据质量监控和异常检测。

使用的平台支持高吞吐量的数据写入能力，可以保证大量数据能够快速被接收并写入到目标系统，提高整体的数据处理效率。此外，提供集中监控和告警系统，通过实时跟踪任务状态及性能，有助于及时发现并解决潜在问题。这些特性使得我们能有效应对跨平台数据交换中的各种挑战。

技术要点与流程概述

1. API接口调用：

   • 获取吉客云库存盘点数据：通过调用wms.stocktake.get API，从吉客云中定时拉取库存盘点信息。
   • 批量保存至金蝶云星空：使用batchSave API，将获取到的大量库存数据信息准确高效地提交至金蝶云星空进行保存。

2. 分页与限流处理： 在API调用过程中，需要考虑分页机制以避免一次性请求过多导致超时或失败，同时也需注意针对限流策略进行合理安排，以确保稳定可靠的数据传输。

3. 异常检测与重试机制： 系统应具备健全的异常处理能力，对可能出现的问题如网络故障、API超限等情况进行自动化检测，并结合错误重试机制，保障任务不中断、不漏单。

4. 自定义转换逻辑： 针对不同系统之间存在的数据结构差异，可基于平台提供的可视化工具，自定义相应的数据转换逻辑，使得最终形成符合目标系统要求的存储格式。

5. 实时监控及日志记录： 建立全面细致的日志记录体系，对所有关键步骤实施全程追踪，在出现误差或突发状况时，能够迅速定位原因并作出响应调整。同时，通过执行实时监控手段，更加直观地掌握各项任务运转态势，有效预防故障发生。

该方案

使用轻易云数据集成平台调用吉客云接口wms.stocktake.get获取并加工数据

在数据集成生命周期的第一步中，调用源系统接口获取数据是至关重要的。本文将深入探讨如何通过轻易云数据集成平台调用吉客云接口wms.stocktake.get来获取盘点数据，并进行初步加工。

接口配置与请求参数

首先，我们需要配置元数据，以便正确调用吉客云的API接口。根据提供的元数据配置，以下是具体的请求参数：

• API: wms.stocktake.get
• 请求方法: POST
• 分页设置: 每页1条记录
• ID检查: 启用

请求参数包括：

• warehouseCode (仓库编号): 例如 "123456"
• skuBarcode (条码): 支持批量查询
• pageSize (条目): 固定值 "20"
• pageIndex (页码): 动态设置
• startPdDate (盘点时间-开始): 使用函数 _function DATE_FORMAT(DATE_ADD(NOW(),INTERVAL - 2 DAY),'%Y-%m-%d 00:00:00')
• endPdDate (盘点时间-结束): 当前时间 {{CURRENT_TIME|datetime}}

请求示例

以下是一个典型的POST请求示例：

{
  "warehouseCode": "123456",
  "skuBarcode": "",
  "pageSize": "20",
  "pageIndex": "1",
  "startPdDate": "_function DATE_FORMAT(DATE_ADD(NOW(),INTERVAL - 2 DAY),'%Y-%m-%d 00:00:00')",
  "endPdDate": "{{CURRENT_TIME|datetime}}"
}

数据清洗与转换

在获取到原始数据后，下一步是对数据进行清洗和转换。这一步骤确保了数据的一致性和准确性，为后续的数据处理打下基础。

1. 字段映射与转换:

   • 将吉客云返回的数据字段映射到目标系统所需的字段。例如，将stocktakeId映射为目标系统中的唯一标识符。

2. 日期格式化:

   • 将日期字段格式化为目标系统所需的格式。例如，将返回的盘点时间格式化为标准ISO日期格式。

3. 数据过滤:

   • 根据业务需求过滤不必要的数据。例如，只保留特定仓库编号的数据。

实际应用案例

假设我们需要获取特定盘点单号为"PD20240918000004"的数据，并将其写入目标系统。可以通过以下步骤实现：

1. 构建请求条件:

   {
    "condition_bk": [
      [
        {
          "field": "stocktakeId",
          "logic": "eqv2",
          "value": "PD20240918000004"
        }
      ]
    ]
   }

2. 发送请求并接收响应:

   • 使用轻易云平台提供的异步处理机制，发送上述条件构建的POST请求。
   • 接收并解析响应数据。

3. 清洗与转换响应数据:

   • 对响应中的每个记录进行字段映射、日期格式化和必要的数据过滤。

4. 写入目标系统:

   • 将清洗后的数据写入目标系统，确保数据的一致性和完整性。

技术要点总结

通过轻易云平台调用吉客云接口wms.stocktake.get，我们能够高效地获取并处理盘点数据。关键技术要点包括：

• 合理配置元数据以确保API调用的准确性。
• 使用分页机制处理大规模数据。
• 数据清洗与转换步骤的重要性，包括字段映射、日期格式化和数据过滤。
• 异步处理机制提升了整体效率。

以上技术案例展示了如何利用轻易云平台实现复杂的数据集成任务，为企业提供了高效、透明的数据管理解决方案。

使用轻易云数据集成平台将源数据转换并写入金蝶云星空API接口的技术案例

在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，转为目标平台金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细介绍如何通过轻易云数据集成平台配置元数据，实现这一过程。

配置元数据

我们首先需要根据提供的元数据配置，理解每个字段的含义及其对应关系。以下是关键配置项的解析：

1. API接口和方法

   {"api":"batchSave","method":"POST"}

   这里指定了目标平台API接口为batchSave，请求方法为POST。

2. 验证基础资料

   {"field":"IsVerifyBaseDataField","label":"验证基础资料","type":"bool","describe":"是否验证所有的基础资料有效性，布尔类，默认false（非必录）","value":"false"}

   该字段用于指定是否验证所有基础资料的有效性，默认为false。

3. 业务对象表单Id

   {"field":"FormId","label":"业务对象表单Id","type":"string","describe":"必须填写金蝶的表单ID如:PUR_PurchaseOrder","value":"STK_StockCountGain"}

   这里指定了业务对象表单Id为STK_StockCountGain。

4. 提交并审核

   {"field":"IsAutoSubmitAndAudit","label":"提交并审核","type":"bool","value":"true"}

   指定是否自动提交并审核，设置为true。

数据转换与写入

在实际操作中，我们需要将源平台的数据按照上述配置进行转换，并通过API接口写入金蝶云星空。以下是具体步骤：

1. 提取和清洗数据

   假设我们从源系统获取到的数据包含以下字段：

   • stocktakeId
   • warehouseCode
   • stocktakeDate
   • stockCountGain

2. 构建请求体

   根据元数据配置，我们需要构建如下请求体：

   {
     "FormId": "STK_StockCountGain",
     "IsVerifyBaseDataField": false,
     "Operation": "Save",
     "IsAutoSubmitAndAudit": true,
     "Model": {
       "FBillNo": "{stocktakeId}",
       "FStockOrgId": "_findCollection find textField_l2ib4q9s from 0ce3a160-9fb2-36e5-a2ac-57f5ad0f3c72 where textField_l2ib4q9p={warehouseCode}",
       "FDate": "_function FROM_UNIXTIME(  ( {stocktakeDate} \/ 1000 )  ,'%Y-%m-%d %T' )",
       "FBillTypeID": "PY01_SYS",
       "FDeptId": "_findCollection find textField_l747atki from 0ce3a160-9fb2-36e5-a2ac-57f5ad0f3c72 where textField_l2ib4q9p={warehouseCode}",
       "FOwnerTypeIdHead": "BD_OwnerOrg",
       "FBillEntry": [
         {
           "FMaterialId": "{{stockCountGain.goodsNo}}",
           "FStockId": "{warehouseCode}",
           "FCountQty": "{{stockCountGain.takeQuan|intval}}",
           "FAcctQty": "{{stockCountGain.stockQuan|intval}}"
         }
       ],
       "F_JKBillNo": "{stocktakeId}"
     }
   }

3. 调用API

   使用轻易云的数据集成平台，通过HTTP POST请求将上述构建好的JSON请求体发送到金蝶云星空的batchSave接口。代码示例如下：

   import requests
   
   url = 'https://api.kingdee.com/batchSave'
   headers = {'Content-Type': 'application/json'}
   
   data = {
     # 上述构建好的JSON请求体
   }
   
   response = requests.post(url, json=data, headers=headers)
   
   if response.status_code == 200:
       print("Data successfully written to Kingdee Cloud")
   else:
       print(f"Failed to write data: {response.text}")

注意事项

1. 字段解析与转换

   在构建请求体时，需要特别注意字段解析和转换。例如：

   • 日期字段需要使用函数 _function FROM_UNIXTIME( ( {stocktakeDate} / 1000 ) ,'%Y-%m-%d %T' ) 转换为目标格式。

   • 对于一些复杂字段，如库存组织、部门等，需要使用 _findCollection find ... where ... 的方式进行查找和映射。

2. 错误处理

   在调用API时，需要处理可能出现的错误，如网络问题、权限不足、数据格式不正确等。建议在实际应用中加入相应的错误处理逻辑，以确保系统稳定运行。

通过上述步骤，我们可以高效地将源平台的数据转换并写入到金蝶云星空，实现不同系统间的数据无缝对接。这不仅提升了业务流程的自动化程度，也确保了数据的一致性和准确性。