-- Ticket08：记录每个数据来源的实际接收边界，并以独占租约防止并发重叠。
CREATE TABLE t_test_reception_interval (
    interval_id BIGINT NOT NULL AUTO_INCREMENT,
    test_id BIGINT NOT NULL,
    binding_id BIGINT NULL,
    source_type VARCHAR(32) NOT NULL,
    source_id BIGINT NOT NULL,
    source_channel_code VARCHAR(64) NULL,
    action_at_utc DATETIME(3) NOT NULL,
    start_boundary_at_utc DATETIME(3) NOT NULL,
    end_boundary_at_utc DATETIME(3) NULL,
    boundary_note VARCHAR(255) NULL,
    interval_status VARCHAR(32) NOT NULL DEFAULT 'OPEN',
    PRIMARY KEY (interval_id),
    KEY idx_reception_interval_test (test_id, source_type, source_id, action_at_utc),
    KEY idx_reception_interval_source (source_type, source_id, source_channel_code, start_boundary_at_utc),
    CONSTRAINT fk_reception_interval_test FOREIGN KEY (test_id) REFERENCES t_test (test_id),
    CONSTRAINT fk_reception_interval_binding FOREIGN KEY (binding_id) REFERENCES t_test_channel_binding (binding_id),
    CONSTRAINT chk_reception_interval_source CHECK (source_type IN ('CABINET_CHANNEL', 'COLLECTOR_CHANNEL')),
    CONSTRAINT chk_reception_interval_status CHECK (interval_status IN ('OPEN', 'CLOSED'))
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='测试数据接收区间';

CREATE TABLE t_collector_channel_lease (
    collector_id BIGINT NOT NULL,
    channel_code VARCHAR(64) NOT NULL,
    test_id BIGINT NOT NULL,
    binding_id BIGINT NOT NULL,
    acquired_by BIGINT NULL,
    acquired_at_utc DATETIME(3) NOT NULL,
    PRIMARY KEY (collector_id, channel_code),
    KEY idx_collector_lease_test (test_id),
    CONSTRAINT fk_collector_lease_collector FOREIGN KEY (collector_id) REFERENCES t_collector (collector_id),
    CONSTRAINT fk_collector_lease_test FOREIGN KEY (test_id) REFERENCES t_test (test_id),
    CONSTRAINT fk_collector_lease_binding FOREIGN KEY (binding_id) REFERENCES t_test_channel_binding (binding_id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='活动采集器通道独占锁';

ALTER TABLE t_test
    ADD KEY idx_test_reception_status (reception_status, test_status);

-- 为独立动作补充按钮权限；仅写系统菜单元数据，不导入演示业务数据。
SET @reception_menu_id := (SELECT COALESCE(MAX(menu_id), 0) + 1 FROM sys_menu);
INSERT INTO sys_menu
    (menu_id, menu_name, parent_id, order_num, path, component, query, route_name,
     is_frame, is_cache, menu_type, visible, status, perms, icon,
     create_by, create_time, update_by, update_time, remark)
SELECT @reception_menu_id, '开始接收', menu_id, 6, '', NULL, NULL, '', 1, 0, 'F', '0', '0',
       'system:test:start', '#', 'admin', NOW(), '', NULL, '测试开始接收权限'
FROM sys_menu
WHERE perms = 'system:test:list'
LIMIT 1;