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 触发入口 - 工作流完成规则评估并回写风险字段或命中记录