如何通过轻易云将用友U8数据写入小满OKKICRM

  • 轻易云集成顾问-曾平安

回款登记U8=>小满--ok：用友U8-凯迪森集成到小满OKKICRM的实战案例

在本篇文章中，我们将聚焦于如何实现用友U8-凯迪森数据与小满OKKICRM系统的对接与集成，特别是回款登记流程的数据传递。通过详细拆解这一真实案例，探讨从API调用、数据格式转换，到异常处理等各个环节的技术细节，以期为类似需求提供有价值的参考解决方案。

数据获取与API接口调用

首先，需要从用友U8-凯迪森系统中获取回款登记相关数据，这一步骤依赖其提供的api/Business/GetReceipt API接口。在配置阶段，确保我们按照正确的方法和频率定时可靠地抓取这些关键业务信息。例如，通过设定抓取计划任务，每隔一定时间段（如每小时）自动发起一次GET请求，从而避免漏单现象的发生。

import requests

url = "https://api.yonyouu8.com/business/getReceipt"
response = requests.get(url, params={"startDate": "2023-01-01", "endDate": "2023-01-31"})
receipts_data = response.json()

数据写入到小满OKKICRM

在获得了所需数据后，下一个重要步骤是大批量、快速且准确地将这些数据写入到小满OKKICRM系统。这一操作通过其指定的/v1/invoices/receiptRegistration/push API来完成。这里需要注意的是，小满OKKICRM对输入的数据有特定格式要求，因此必须先进行必要的数据转换和映射。

import json

mapped_data = []  # 假设这是已经映射好的目标格式数据
for record in receipts_data:
    mapped_record = {
        "invoiceId": record["id"],
        "amountReceived": record["amount"],
        ...
    }
    mapped_data.append(mapped_record)

url_okki_crm = "https://api.okkicrm.com/v1/invoices/receiptRegistration/push"
headers = {"Content-Type": "application/json"}
response_okki_crm = requests.post(url_okki_crm, headers=headers, data=json.dumps(mapped_data))
if response_okki_crm.status_code == 200:
    print("Data push successful")
else:
    print(f"Error: {response_okki_crm.text}")

异常处理机制及错误重试

为了保证整个过程不因个别错误导致全盘失败，实现可靠性设计至关重要。当记录推送过程中出现异常情况，例如网络故障或限流，此时需要实施合适的异常处理机制，包括日志记录、实时 金蝶与CRM系统接口开发配置

调用用友U8-凯迪森接口api/Business/GetReceipt获取并加工数据的技术案例

在轻易云数据集成平台中，调用源系统用友U8-凯迪森接口api/Business/GetReceipt是数据集成生命周期的第一步。本文将深入探讨如何通过该接口获取并加工数据，以实现高效的数据集成。

接口调用配置

首先，我们需要配置元数据以调用用友U8-凯迪森的API接口。以下是元数据配置的详细信息：

{
  "api": "api/Business/GetReceipt",
  "effect": "QUERY",
  "method": "GET",
  "number": "cVouchId",
  "id": "Id",
  "name": "{random}",
  "idCheck": true,
  "request": [
    {
      "field": "dStartDate",
      "label": "开始时间",
      "type": "string",
      "describe": "暂无描述",
      "value": "{{LAST_SYNC_TIME|datetime}}"
    },
    {
      "field": "dEndDate",
      "label": "结束时间",
      "type": "string",
      "describe": "暂无描述",
      "value": "{{CURRENT_TIME|datetime}}"
    }
  ],
  "autoFillResponse": true
}

请求参数说明

  1. dStartDate: 开始时间，类型为字符串，用于指定数据同步的起始时间。其值通过模板变量{{LAST_SYNC_TIME|datetime}}动态生成。
  2. dEndDate: 结束时间，类型为字符串，用于指定数据同步的结束时间。其值通过模板变量{{CURRENT_TIME|datetime}}动态生成。

这些参数确保了我们能够获取到指定时间范围内的回款登记数据。

API调用过程

  1. 构建请求URL: 根据元数据配置，我们需要构建一个GET请求URL。假设当前时间为2023年10月10日12:00，最后同步时间为2023年10月9日12:00，那么请求URL将会是：

    api/Business/GetReceipt?dStartDate=2023-10-09T12:00:00&dEndDate=2023-10-10T12:00:00

  2. 发送请求: 使用HTTP客户端（如HttpClient）发送GET请求，并处理响应。

    import requests

url = 'http://your-u8-server/api/Business/GetReceipt'
params = {
   'dStartDate': '2023-10-09T12:00:00',
   'dEndDate': '2023-10-10T12:00:00'
}

response = requests.get(url, params=params)

if response.status_code == 200:
   data = response.json()
   # 后续处理逻辑
else:
   print(f"Error: {response.status_code}")

数据清洗与加工

获取到原始数据后，需要对其进行清洗和加工，以便后续的数据转换与写入步骤。以下是一个简单的数据清洗示例：

def clean_data(raw_data):
    cleaned_data = []
    for item in raw_data:
        cleaned_item = {
            'Id': item.get('Id'),
            'cVouchId': item.get('cVouchId'),
            'Amount': float(item.get('Amount', 0)),
            'Date': item.get('Date')
        }
        cleaned_data.append(cleaned_item)
    return cleaned_data

cleaned_data = clean_data(data)

在这个示例中，我们提取了原始数据中的Id, cVouchId, Amount, 和 Date字段，并进行了必要的数据类型转换。

自动填充响应

根据元数据配置中的autoFillResponse属性，轻易云平台会自动填充响应结果。这意味着我们可以直接使用清洗后的数据进行下一步处理，而无需手动解析每个字段。

# 假设cleaned_data已经准备好
for record in cleaned_data:
    # 将cleaned_data写入目标系统或数据库
    pass

通过上述步骤，我们成功地调用了用友U8-凯迪森接口获取回款登记数据，并进行了初步的数据清洗和加工。这为后续的数据转换与写入奠定了坚实基础。 金蝶云星空API接口配置

使用轻易云数据集成平台实现回款登记数据的ETL转换与写入小满OKKICRMAPI接口

在数据集成生命周期的第二步中，我们需要将已经从源平台（如U8）集成的数据进行ETL转换，使其符合目标平台（小满OKKICRMAPI接口）的格式要求，最终将数据写入目标平台。本文将详细探讨如何使用轻易云数据集成平台完成这一过程。

API接口配置

根据元数据配置，我们需要将回款登记信息推送到小满OKKICRMAPI接口。具体的API路径为/v1/invoices/receiptRegistration/push，请求方法为POST。以下是请求字段及其对应的配置：

  • cash_collection_invoice_id: 回款登记ID
  • cash_collection_invoice_no: 回款登记编号，值为{cVouchId}
  • collection_date: 回款日期，值为{dVouchDate}
  • company_id: 关联客户ID，通过查找特定表中的serial_id字段获取
  • currency: 币种，值为{newcurrency}
  • exchange_rate: 汇率，通过计算公式{iExchRate}*100得到
  • amount: 回款金额/客户打款金额（单据币种），值为{iAmount_f}
  • real_amount: 实际到账金额，值为{iAmount_f}

数据请求与清洗

在数据请求阶段，我们从U8系统中提取所需的原始数据。这些数据通常包括回款登记ID、回款登记编号、回款日期、客户代码、币种、汇率和金额等。在提取过程中，我们需要确保数据的完整性和准确性。

数据转换与写入

  1. 字段映射与转换

    首先，我们需要将源平台的数据字段映射到目标平台的字段。例如，将U8中的回款登记编号（cVouchId）映射到小满OKKICRMAPI接口中的cash_collection_invoice_no字段。对于一些特殊字段，如汇率，需要进行特定的计算转换。

    {
   "field": "cash_collection_invoice_no",
   "label": "回款登记编号",
   "type": "string",
   "value": "{cVouchId}"
}

  2. 关联客户ID的查找

    对于关联客户ID（company_id），我们需要通过查找特定表中的serial_id字段来获取。这可以通过一个查找函数实现：

    {
   "field": "company_id",
   "label": "关联客户ID",
   "type": "string",
   "value": "_findCollection find company_id from 9f68b1db-1741-336d-869e-7123c93347ed where serial_id={cCusCode}"
}

  3. 汇率计算

    汇率字段需要进行特定的计算，例如乘以100：

    {
   "field": "exchange_rate",
   "label": "汇率",
   "type": "string",
   "value": "_function {iExchRate}*100"
}

  4. 金额字段处理

    回款金额和实际到账金额都直接使用源数据中的iAmount_f字段：

    {
   "field": "amount",
   "label": "回款金额/客户打款金额（单据币种）",
   "type": "string",
   "value": "{iAmount_f}"
},
{
   "field": "real_amount",
   "label": "实际到账金额",
   "type": "string",
   "value": "{iAmount_f}"
}

  5. 最终的数据写入

    配置好所有字段后，我们使用POST方法将处理后的数据发送到小满OKKICRMAPI接口：

    {
    "api":"\/v1\/invoices\/receiptRegistration\/push",
    "effect":"EXECUTE",
    "method":"POST"
}

监控与验证

在完成上述步骤后，我们可以利用轻易云数据集成平台提供的实时监控功能，对整个ETL过程进行监控和验证，确保每个环节的数据处理都准确无误。

通过以上步骤，我们成功地将U8系统中的回款登记信息转换并写入到小满OKKICRMAPI接口，实现了不同系统间的数据无缝对接。这一过程不仅提升了业务透明度和效率，也确保了数据的一致性和准确性。 电商OMS与ERP系统接口开发配置

版权声明

该文章《如何通过轻易云将用友U8数据写入小满OKKICRM》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

金蝶云星辰与吉客云对接
更多系统对接方案