Skip to main content

5-Webhook

概览​

目录：doc/product/financial/webhook

该模块通过实体 Webhook 将 fin_invoices 等实体的变更事件推送到下游系统或工作流引擎，实现「数据变更即触发风险评估/告警」的闭环。

  • 发票实体 Webhook：webhook/fin_invoices_webhook.json
  • 发票文件与批次 Webhook：webhook/fin_invoice_files_webhook.json、fin_invoice_upload_batches_webhook.json

初始化脚本 init/init.py 中的 init_webhooks 会批量读取这些配置，并调用 /metadata/entity-webhooks 完成落地。

发票实体 Webhook：fin_invoices_webhook.json​

文件：webhook/fin_invoices_webhook.json

该 Webhook 将发票实体 fin_invoices 的 INSERT/UPDATE 事件推送到 ai-link 工作流触发入口，用于触发发票风险评估流程 FinInvoiceRiskOnChange。

完整 JSON：

{
  "entityName": "fin_invoices",
  "events": [
    "INSERT",
    "UPDATE"
  ],
  "webhookUrl": "http://gateway:8080/linker/triggers/webhook/FinInvoiceRiskOnChange",
  "httpMethod": "POST",
  "headersJson": "{\"X-Source\":\"ai-daas-fin\"}",
  "timeoutMs": 5000,
  "maxRetries": 5,
  "backoffInitialSeconds": 5,
  "backoffFactor": 2.0,
  "enabled": true,
  "secret": "fin-invoice-***"
}

与工作流结合时，整体链路为：

  • 数据服务写入或更新 fin_invoices
  • mutation outbox 写入变更记录
  • Webhook 调度器根据上述配置，将变更推送到 FinInvoiceRiskOnChange 的 Webhook 触发入口
  • 工作流完成规则评估并回写风险字段或命中记录