宿主把原生表行(导出给数仓那种)照抄推来,PAC 复用 transforms+assembler+processSubject 同核落库(拆分/映射/外键/幂等全 PAC 做),与 pull/reparse 完全一致,只是数据入口是 webhook。 - ColdImportService.ingestRawTables({hostName, source, rows}):tables={[source]:rows} → transformEngine.run → 对"终端原生表=source"的每个 assembler cfg 跑 processSubject; tenant 走 manifest brand resolver(同 pull,非 stub);返回 touched 患者(带 tenant)。 - push.schema:PushRowsRequest/Response。 - PushReceiverService.receiveRows:ingest → 对 touched 患者 enqueuePersonaRecompute (复用现有 BullMQ 触发 + watermark 幂等 + 凌晨 cron 兜底);plan 不在此触发(定时任务保)。 - PushController:POST /push/rows(HMAC 验签复用 /push/events 同逻辑)。 本地核验:原样推=同口径去重(dup=6/txn=0);bump updated_date 推=新 txn=6/touched=1 (tenant 正确解析);版本流无重复(active facts 9→9)。main.ts 已 rawBody:true。 Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
