zheromiku
dcdc8d1ddd
全栈知识治理平台首次入库（P1-P10 + 发布链路模拟验证闭环）： - 治理核心：源目录/变更集/人工审核/发布批次/发布执行（fail-closed 闸口） - 测试通道：WeKnora 测试 KB 上传/轮询/验收；poll 完成时写入 parser_generation/index_generation，修复 manual/seed 路径发布闸口永久拦截 - 发布适配器 v071（本地 source=测试角色 / 云端 target=生产角色 模拟验证通过）： * ES 导出/导入 mapping 自适应（.keyword 子字段、可选 tenant_id） * OSS locator 支持嵌套 scheme；chunks.seq_id 由目标序列分配 * bundle 归档同身份重试原子替换；verifier 按 bundle chunk_type 计数 * 回滚 job payload 支持 prior_execution_id（strict 解码） - 三通道发布+回滚演练实测：publish 4/4 verified，检索命中， rollback 4/4 rolled_back，目标端 PG is_enabled=false、ES is_enabled=false - 前端 A·Data-console 风格全站统一，120 用例通过 - 门禁：go vet / go test 全包通过，gofmt 干净
66 lines
3.1 KiB
SQL
66 lines
3.1 KiB
SQL
CREATE TABLE IF NOT EXISTS release_executions (
|
|
id VARCHAR(36) PRIMARY KEY,
|
|
release_batch_id VARCHAR(36) NOT NULL
|
|
REFERENCES release_batches(id) ON DELETE RESTRICT,
|
|
operation VARCHAR(16) NOT NULL
|
|
CHECK (operation IN ('publish', 'rollback')),
|
|
prior_execution_id VARCHAR(36)
|
|
REFERENCES release_executions(id) ON DELETE RESTRICT,
|
|
state VARCHAR(16) NOT NULL DEFAULT 'pending'
|
|
CHECK (state IN ('pending', 'running', 'completed', 'failed')),
|
|
target_environment VARCHAR(16) NOT NULL DEFAULT 'production'
|
|
CHECK (target_environment = 'production'),
|
|
authorized_by VARCHAR(128) NOT NULL,
|
|
authorization_code VARCHAR(64) NOT NULL,
|
|
job_id VARCHAR(36) NOT NULL UNIQUE
|
|
REFERENCES jobs(id) ON DELETE RESTRICT,
|
|
manifest_sha256 CHAR(64) NOT NULL DEFAULT ''
|
|
CHECK (manifest_sha256 = '' OR manifest_sha256 ~ '^[0-9a-f]{64}$'),
|
|
item_count INTEGER NOT NULL DEFAULT 0 CHECK (item_count >= 0),
|
|
completed_item_count INTEGER NOT NULL DEFAULT 0 CHECK (completed_item_count >= 0),
|
|
failed_item_count INTEGER NOT NULL DEFAULT 0 CHECK (failed_item_count >= 0),
|
|
error_code VARCHAR(64) NOT NULL DEFAULT '',
|
|
created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
|
|
started_at TIMESTAMPTZ,
|
|
completed_at TIMESTAMPTZ,
|
|
CHECK (operation = 'publish' OR prior_execution_id IS NOT NULL),
|
|
CHECK (completed_item_count + failed_item_count <= item_count)
|
|
);
|
|
|
|
CREATE UNIQUE INDEX IF NOT EXISTS uq_release_publish_batch
|
|
ON release_executions (release_batch_id)
|
|
WHERE operation = 'publish';
|
|
|
|
CREATE UNIQUE INDEX IF NOT EXISTS uq_release_rollback_prior
|
|
ON release_executions (prior_execution_id)
|
|
WHERE operation = 'rollback';
|
|
|
|
CREATE INDEX IF NOT EXISTS idx_release_executions_batch_created
|
|
ON release_executions (release_batch_id, created_at DESC);
|
|
CREATE INDEX IF NOT EXISTS idx_release_executions_state_created
|
|
ON release_executions (state, created_at);
|
|
|
|
CREATE TABLE IF NOT EXISTS release_item_executions (
|
|
id VARCHAR(36) PRIMARY KEY,
|
|
release_execution_id VARCHAR(36) NOT NULL
|
|
REFERENCES release_executions(id) ON DELETE RESTRICT,
|
|
publication_id VARCHAR(36) NOT NULL
|
|
REFERENCES test_publications(id) ON DELETE RESTRICT,
|
|
state VARCHAR(24) NOT NULL DEFAULT 'pending'
|
|
CHECK (state IN ('pending', 'staged', 'activated', 'verified', 'failed', 'rolled_back')),
|
|
bundle_sha256 CHAR(64) NOT NULL DEFAULT ''
|
|
CHECK (bundle_sha256 = '' OR bundle_sha256 ~ '^[0-9a-f]{64}$'),
|
|
previous_production_revision VARCHAR(128) NOT NULL DEFAULT '',
|
|
production_revision VARCHAR(128) NOT NULL DEFAULT '',
|
|
error_code VARCHAR(64) NOT NULL DEFAULT '',
|
|
created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
|
|
updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
|
|
completed_at TIMESTAMPTZ,
|
|
UNIQUE (release_execution_id, publication_id)
|
|
);
|
|
|
|
CREATE INDEX IF NOT EXISTS idx_release_item_executions_execution
|
|
ON release_item_executions (release_execution_id, created_at);
|
|
CREATE INDEX IF NOT EXISTS idx_release_item_executions_publication
|
|
ON release_item_executions (publication_id, created_at DESC);
|