-- Ticket03：推式来源（PUSH_INGEST）的落地表，ADR-0065。
|
-- 甲方机器上的只读取数程序把厂商原始行推给接收端点，行按收到的键值原样落在这里：不改列名、不增删字段、不做换算（JSON 列会规范化格式，但键值不变）。
|
-- 解释只做一遍并全部落在后端：身份映射、时间换算、幂等键取值、测量列取值都在接收端点里完成，
|
-- 因此这张表既能本地回放开发与回归（不依赖那台机器在线），也是适配器读回统一观测的唯一来源——
|
-- 适配器只做投影，不含任何厂商列名。
|
-- 推送记录按事件落库：唯一键让同一条来源行重复推送被幂等忽略，同身份内容不同只报冲突、不覆盖。
|
CREATE TABLE t_device_ingest_record (
|
ingest_id BIGINT NOT NULL AUTO_INCREMENT,
|
adapter_code VARCHAR(64) NOT NULL,
|
-- 载荷类别：TOPOLOGY 拓扑上报（通道清单）、SAMPLE 逐点数据行、HEARTBEAT 存活心跳。
|
payload_kind VARCHAR(16) NOT NULL,
|
devtype INT NOT NULL DEFAULT 0,
|
devid INT NOT NULL DEFAULT 0,
|
subdevid INT NOT NULL DEFAULT 0,
|
chlid INT NOT NULL DEFAULT 0,
|
-- 厂商协议序号（22 所为 Data_Point）：水位与"同一绝对秒内多行"都靠它区分。
|
record_sequence BIGINT NOT NULL DEFAULT 0,
|
-- 来源行身份（22 所为 库/表 + Data_Point）；同身份只允许一行，重复推送因此天然幂等。
|
record_key VARCHAR(191) NOT NULL,
|
-- 厂商来源定位（库/表），供回放与现场排查，不参与判定。
|
source_ref VARCHAR(191) NULL,
|
device_time_utc DATETIME(3) NULL,
|
device_time_raw VARCHAR(64) NULL,
|
timezone_id VARCHAR(64) NULL,
|
cycle_no INT NULL,
|
step_no INT NULL,
|
relative_time_seconds DECIMAL(20,3) NULL,
|
-- 测量列按厂商给的物理单位原样落库（22 所不做缩放）；缺列保持为空，不写零代替缺失。
|
voltage_v DECIMAL(30,12) NULL,
|
current_a DECIMAL(30,12) NULL,
|
charge_capacity_ah DECIMAL(30,12) NULL,
|
discharge_capacity_ah DECIMAL(30,12) NULL,
|
charge_energy_wh DECIMAL(30,12) NULL,
|
discharge_energy_wh DECIMAL(30,12) NULL,
|
-- 厂商原始行，按收到的键值原样保留：回放与核对解释逻辑都靠它。
|
payload_json JSON NOT NULL,
|
content_sha256 BINARY(32) NOT NULL,
|
received_at_utc DATETIME(3) NOT NULL,
|
PRIMARY KEY (ingest_id),
|
UNIQUE KEY uk_ingest_record (adapter_code, payload_kind, record_key),
|
-- 逐行接收按 (设备时间, 协议序号) 取严格晚于水位的数据行，索引列次序与它一致。
|
KEY idx_ingest_channel (adapter_code, payload_kind, devtype, devid, subdevid, chlid, device_time_utc, record_sequence)
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='推式来源落地表';
|
