lili 13bd910c8f feat(knowledge): S6 摄入轮询键 documentId→batch(Dify 按 batch 轮询 indexing-status) ...

为 muse_knowledge_processing_task 加 runtime_batch_id 列并落库 Dify 上传返回的索引批次(从 uploadResult.summary 的 batch 键抽取)。poll worker 取 runtimeBatchId 非空优先、否则回退 ragflowDocumentId 作轮询键,RAGFlow 无 batch 路径逐字不变;skip gate 放宽为 documentId 与 batch 都空才跳过。

DDL 采用新迁移 V37 ALTER TABLE ADD COLUMN,非回编 V14 建表语句——沿用 sql/muse append-only 约定(V24/V27/V30/V31 同法),避免破坏已应用库(dev/live)的 Flyway 校验和。

验证:mvn -pl muse-module-knowledge-server -am test 目标两类全绿(PollWorkerTest 9/0/0/0、DocumentServiceTest 17/0/0/0,聚合 Tests run 26 Failures 0 Errors 0 Skipped 0,BUILD SUCCESS)。

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

2026-07-08 03:45:46 -07:00

..

V1__init_content_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V2__init_account_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V3__init_meta_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V4__init_ai_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V5__init_knowledge_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V6__init_market_schema.sql

feat(muse-cloud): 纳入主仓库并搭建 P1 后端基座

2026-05-24 23:15:08 +08:00

V7__add_contract_operation_audit.sql

feat(muse-cloud): 持久化 Muse 合同入口

2026-05-25 12:11:27 +08:00

V8__add_contract_workflow_and_market_interaction.sql

feat(muse-cloud): 持久化 Muse 合同入口

2026-05-25 12:11:27 +08:00

V9__extend_content_real_api_schema.sql

feat(p1r): 推进 Content 真实 API 收口

2026-05-27 02:24:48 +08:00

V10__extend_meta_real_api_schema.sql

feat(p1r): 推进 Meta 真实 API 收口

2026-05-28 12:30:46 +08:00

V11__extend_account_real_api_schema.sql

fix(p1r): 补齐调用归因 revision 校验

2026-05-29 13:17:19 +08:00

V12__extend_ai_real_api_schema.sql

feat(p1r): 实现 AI 真实 API dedicated gate

2026-06-01 00:37:29 +08:00

V13__add_ai_runtime_payload_store.sql

feat(p1r): 实现 AI 真实 API dedicated gate

2026-06-01 00:37:29 +08:00

V14__extend_knowledge_ragflow_real_api_schema.sql

feat(p1r): 实现 Knowledge RAGFlow dedicated gate

2026-06-02 19:36:02 +08:00

V15__extend_market_real_api_schema.sql

feat(p1r): 落地 Market 真实 API

2026-06-05 10:51:58 +08:00

V16__extend_events_sse_schema.sql

feat(p1r): 落地 Events SSE 真实 API

2026-06-05 22:20:48 +08:00

V17__extend_ai_events_publish_outbox.sql

feat(p1r): 接入 AI 事件传播真实链路

2026-06-06 20:24:01 +08:00

V18__extend_knowledge_events_publish_outbox.sql

feat(p1r): 接入 Knowledge 事件传播真实链路

2026-06-07 10:00:04 +08:00

V19__extend_market_events_publish_outbox.sql

feat(p1r): 接入 Market 事件传播真实链路

2026-06-07 22:28:39 +08:00

V20__extend_account_events_publish_outbox.sql

feat(p1r): 接入 Account 事件传播真实链路

2026-06-08 02:49:02 +08:00

V21__extend_content_events_publish_outbox.sql

feat(p1r): 接入 Content 事件传播真实链路

2026-06-08 23:17:41 +08:00

V22__fix_market_publish_command_unique_index.sql

feat(studio+market): 市场发布提交审核全链(草稿→检查→提交)活体绿 + V22 补 review_event 索引

2026-06-15 02:10:12 -07:00

V23__fix_market_remaining_command_unique_index.sql

fix(market): 系统性修 market 残余 (tenant_id,command_id) partial-index ON CONFLICT bug + 真实 PG IT

2026-06-15 03:30:11 -07:00

V24__fix_knowledge_source_projection_scope.sql

fix(knowledge): 绑定确认回填来源投影 + 唯一键补 work_id

2026-06-19 09:31:56 -07:00

V25__add_content_planning_field_snapshot.sql

feat(content): B 字段级地基 - planning 字段用量快照表 + Planning 贡献者[P1]

2026-06-21 01:48:15 -07:00

V26__fix_content_softdelete_order_uk_partial.sql

fix(content): V26 修章节/Block 软删后 order_no uk 碰撞(partial index,待人类应用 flyway)+ 软删 uk 全仓审计

2026-06-21 19:09:59 -07:00

V27__extend_ai_agent_handoff_source.sql

feat(handoff): P2 agent 放宽接纳 market 来源 + verify/consume(后端)

2026-06-22 12:30:50 -07:00

V28__create_content_asset_use_precheck.sql

feat(handoff): P3 content asset_use 两段式后端(token 红线 + 单表事实)

2026-06-22 22:51:59 -07:00

V29__add_agent_slot_binding_active_unique.sql

fix(ai): 修 02D 槽位绑定首次创建死锁，precheck/bind 改 upsert + 补 active 唯一约束

2026-06-24 10:09:53 -07:00

V30__widen_authorization_snapshot_id_to_varchar.sql

fix(ai): 修 AI 生成候选采纳断层，授权快照 id 改字符串承载 envelope（ADR-020 方案 A）

2026-06-25 01:03:54 -07:00

V31__widen_agent_slot_binding_authz_to_varchar.sql

fix(ai): 收口 ADR-020 漏网 binding 表——槽位绑定授权快照 BIGINT→VARCHAR(V31)

2026-06-25 08:31:21 -07:00

V32__create_content_block_revision_snapshot.sql

feat(mvp): 收束1.0.0线A交付闭环

2026-06-27 10:52:10 -07:00

V33__allow_market_kb_precheck_without_local_kb.sql

feat(mvp): 收束1.0.0线A交付闭环

2026-06-27 10:52:10 -07:00

V34__create_ai_import_parse_tables.sql

feat(content): 补齐导入导出真链路

2026-06-28 07:40:10 -07:00

V36__ai_generated_fulltext_transient.sql

feat(ai): S7b 瞬态全文载体 + SSE chunk 送达 + 决定即清

2026-07-08 00:29:29 -07:00

V37__add_knowledge_processing_task_runtime_batch_id.sql

feat(knowledge): S6 摄入轮询键 documentId→batch(Dify 按 batch 轮询 indexing-status)

2026-07-08 03:45:46 -07:00