KYA查询流程 - 超简化说明

流程概述

KYA（Know Your Address）查询流程用于评估区块链地址的风险等级，支持同步和异步两种查询模式。

超简化流程图

流程步骤说明

1. 开始查询KYA评分

• 输入参数：
  • address: 区块链地址
  • blockchainId: 区块链ID
  • blockchainName: 区块链名称
  • requestId: 请求ID

2. 查询该地址的KYA

• 任务类型：TaskQueryKya
• 重试次数：3次
• 功能：向KYA服务查询指定地址的风险评分

3. 判断是否有现成答案

• 条件判断：检查kyaRiskLevel是否为空
• 分支路径：
  • 如果kyaRiskLevel != null：直接返回结果
  • 如果kyaRiskLevel = null：等待异步结果

4. 等待KYA结果准备就绪（异步分支）

• 消息事件：MessageKyaResultReady
• 关联键：address + "_" + blockchainName
• 功能：不阻塞主流程，等待异步KYA分析完成

5. 查询KYA流程结束

• 输出结果：
  • kyaRiskLevel: KYA风险等级
  • kyaRiskReportId: KYA风险报告ID

关键特性

1. 智能缓存：优先使用已有的KYA评分结果，避免重复查询
2. 异步处理：支持异步KYA分析，不阻塞主业务流程
3. 容错机制：查询任务支持3次重试
4. 消息驱动：通过消息事件接收异步分析结果

业务价值

• 风险控制：实时评估区块链地址的风险等级
• 合规要求：满足反洗钱（AML）和了解你的客户（KYC）要求
• 性能优化：通过缓存和异步处理提升系统响应速度
• 用户体验：避免长时间等待，提供流畅的交易体验

技术实现

• 流程引擎：Camunda Cloud 8.5.0
• 建模工具：Camunda Modeler 5.22.0
• 执行平台：Zeebe工作流引擎
• 消息机制：基于关联键的消息订阅模式