iot-upgrade/sql/2025/11/create_cxf_td_20251107.sql

物联网管理TD数据表

1、水表监测超级表
CREATE STABLE IF NOT EXISTS water_meter (
  ts TIMESTAMP,               -- 时间戳
  flow FLOAT,                 -- 瞬时流量
  pressure FLOAT,             -- 水压
  total_volume FLOAT,         -- 累计水量
  battery_level FLOAT,        -- 电池电量
  signal_strength INT,        -- 信号强度
  status TINYINT,             -- 设备状态（1=正常,2=异常,3=离线）
  alarm_type TINYINT          -- 告警类型（0=无,1=流量超限,2=压力异常）
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  longitude NCHAR(200),        -- 经度
  latitude NCHAR(200),         -- 纬度
  tenant_id                   -- 租户ID
);


2、电表监测超级表
CREATE STABLE IF NOT EXISTS electric_meter (
  ts TIMESTAMP,               -- 时间戳
  current FLOAT,              -- 电流
  voltage FLOAT,              -- 电压
  power FLOAT,                -- 功率
  total_energy FLOAT,         -- 累计电量
  battery_level FLOAT,        -- 电池电量
  signal_strength INT,        -- 信号强度
  status TINYINT,             -- 设备状态（1=正常,2=异常,3=离线）
  alarm_type TINYINT          -- 告警类型（0=无,1=流量超限,2=压力异常）
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  longitude NCHAR(200),        -- 经度
  latitude NCHAR(200),         -- 纬度
  tenant_id                   -- 租户ID
);



3、边坡监测超级表
CREATE STABLE IF NOT EXISTS slope_monitor (
  ts TIMESTAMP,               -- 时间戳
  displacement FLOAT,         -- 位移
  vibration FLOAT,            -- 振动值
  battery_level FLOAT,        -- 电池电量
  signal_strength INT,        -- 信号强度
  status TINYINT,             -- 设备状态（1=正常,2=异常,3=离线）
  alarm_type TINYINT          -- 告警类型（0=无告警,1=位移超限,2=振动超限）
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  longitude NCHAR(200),        -- 经度
  latitude NCHAR(200),         -- 纬度
  tenant_id                   -- 租户ID
);



4、视频监控超级表
CREATE STABLE IF NOT EXISTS device_monitor (
  ts TIMESTAMP,               -- 时间戳字段
  stream_type TINYINT,        -- 码流类型：1=主码流（高清），2=子码流（标清）
  bitrate FLOAT,              -- 实时码率（Mbps，主码流通常2-8Mbps，子码流0.5-2Mbps）
  resolution NCHAR(32),       -- 分辨率（如"1920x1080"、"2560x1440"）
  frame_rate INT,             -- 帧率（fps，通常15-30fps）
  bitrate_fluctuation FLOAT,  -- 码率波动值（Mbps，反映码流稳定性，波动越小越好）
  encoding_format NCHAR(32),  -- 编码格式（如"H.264"、"H.265"、"AV1"）
  packet_loss_rate FLOAT,      -- 码流丢包率（%，网络传输质量指标，0为最佳）

  storage_total FLOAT,        -- 总存储容量（GB）
  storage_used FLOAT,         -- 已用存储容量（GB）
  storage_used_rate FLOAT,    -- 存储使用率（%，=storage_used/storage_total*100）
  record_status TINYINT,      -- 录像状态：1=正常录像，0=录像停止，2=录像异常（丢帧）
  record_retention_days INT,  -- 录像保留天数（如30天，配置值）
  remaining_days FLOAT,       -- 剩余可录像天数（=未用容量/(日均存储占用)，预测值）
  disk_health TINYINT,         -- 硬盘健康状态：1=正常，2=亚健康（坏道预警），3=故障

  alarm_type TINYINT,         -- 告警类型：1=移动侦测，2=设备遮挡，3=视频断流，4=存储满，5=码流异常
  alarm_level TINYINT,        -- 告警等级：1=紧急（需立即处理，如断流），2=重要（如遮挡），3=提示（如存储即将满）
  alarm_desc NCHAR(200),      -- 告警描述（如"设备被遮挡，画面不可见"）
  alarm_duration INT,         -- 告警持续时间（秒，告警恢复时更新，未恢复则为NULL）
  is_recovered TINYINT,       -- 是否恢复：1=已恢复，0=未恢复
  recover_ts TIMESTAMP,       -- 恢复时间戳（is_recovered=1时非NULL，否则为NULL）
  snapshot_url NCHAR(512)     -- 告警快照URL（如"http://storage-server/snap/20240928/cam001_alarm.jpg"）
  battery_level FLOAT,        -- 电池电量
  signal_strength INT,        -- 信号强度
  status TINYINT,             -- 设备状态（1=正常,2=异常,3=离线）
  alarm_type TINYINT          -- 告警类型（0=无告警,1=位移超限,2=振动超限）
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  device_type TINYINT,        -- 设备类型：1=温度监控，2=人流量监控，3=热力度监控等
    group_id INT,               -- 区域ID
    group_name NCHAR(100),      -- 区域名称
    biz_id INT,                 -- 业务ID
    biz_name NCHAR(100),                 -- 业务名称
    project_id INT,                 -- 项目ID
    project_name NCHAR(100),         -- 项目名称
    location NCHAR(200),         -- 安装位置
    longitude NCHAR(200),        -- 经度
    latitude NCHAR(200),         -- 纬度
    tenant_id                   -- 租户ID
);


-- 创建矿卡监测超级表
CREATE STABLE IF NOT EXISTS mine_truck (
  ts TIMESTAMP,                 -- 时间戳字段
  running_status TINYINT,       -- 运行状态：1=行驶中，2=空载静止，3=满载静止，4=维修中，5=故障停机
  engine_status TINYINT,        -- 发动机状态：1=启动，0=关闭，2=怠速
  speed FLOAT,                  -- 行驶速度（km/h，静止时为0）
  mileage FLOAT,                -- 累计里程（km，自上次重置起）
  working_hours FLOAT,          -- 累计工作时长（h，发动机启动状态累计）
  engine_rpm INT,               -- 发动机转速（r/min）
  fuel_consumption FLOAT,       -- 瞬时油耗（L/h）
  oil_pressure FLOAT,           -- 机油压力（kPa，正常范围80-400）
  coolant_temp FLOAT,           -- 冷却液温度（℃，正常范围80-95）
  battery_voltage FLOAT,        -- 蓄电池电压（V，正常范围24-28）
  tire_pressure ARRAY[FLOAT,4], -- 四轮胎压（kPa，数组存储左前/右前/左后/右后）
  latitude FLOAT,               -- 纬度
  longitude FLOAT,              -- 经度
  load_weight FLOAT,            -- 负载重量（t，空载时≈0）
  load_status TINYINT,          -- 负载状态：1=满载，2=半载，3=空载
  fault_code NCHAR(64),         -- 故障码（多个用逗号分隔，无故障为'NONE'）
  alarm_level TINYINT          -- 告警等级：0=无告警，1=提示，2=警告，3=紧急
) TAGS (
  truck_id NCHAR(64),           -- 矿卡唯一标识（如'TRUCK-001-SN12345'）
  truck_model NCHAR(64),        -- 矿卡 型号（如'CAT 797F'、'BelAZ 75710'）
  team_id INT,                  -- 所属车队ID（如1=运输一队，2=运输二队）
  mining_area NCHAR(100),       -- 作业矿区（如'东翼采区'、'主井矿区'）
  driver_id NCHAR(64),          -- 当前司机ID（动态标签，换班时更新）
  max_load FLOAT                -- 最大载重（t，车型固有属性）
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  tenant_id                   -- 租户ID
);


-- 创建皮带称重数据超级表
CREATE STABLE IF NOT EXISTS belt_scale_data (
    ts TIMESTAMP,                -- 时间戳
    weight FLOAT,                -- 称重值(kg)
    speed FLOAT,                 -- 皮带速度(m/s)
    flow_rate FLOAT,             -- 流量(t/h)
    load_cell_voltage FLOAT,    -- 传感器电压(V)
    temperature FLOAT,          -- 设备温度(℃)
    status BINARY(20),          -- 运行状态
    alarm_code INT              -- 报警代码
) TAGS (
   material_type BINARY(30),   -- 物料类型
   device_id NCHAR(64),        -- 设备唯一ID
   device_name NCHAR(100),     -- 设备名称
   group_id INT,               -- 区域ID
   group_name NCHAR(100),      -- 区域名称
   biz_id INT,                 -- 业务ID
   biz_name NCHAR(100),                 -- 业务名称
   project_id INT,                 -- 项目ID
   project_name NCHAR(100),         -- 项目名称
   location NCHAR(200),         -- 安装位置
   longitude NCHAR(200),        -- 经度
   latitude NCHAR(200),         -- 纬度
   tenant_id                   -- 租户ID
);



-- 创建环境检查超级表
CREATE STABLE IF NOT EXISTS environment_check (
    ts TIMESTAMP,              -- 检查时间戳
    temperature FLOAT,         -- 环境温度(℃)
    humidity FLOAT,            -- 环境湿度(%RH)
    dust_concentration FLOAT,  -- 粉尘浓度(mg/m³)
    noise_level FLOAT,         -- 噪声水平(dB)
    vibration_amplitude FLOAT, -- 振动幅度(mm/s)
    air_pressure FLOAT,        -- 气压(hPa)
    status BINARY(20),         -- 环境状态(normal/warning/alarm)
    alarm_code INT             -- 报警代码
) TAGS (
  check_type BINARY(30),      -- 检查类型(temperature/humidity/dust等)
    device_id NCHAR(64),        -- 设备唯一ID
    device_name NCHAR(100),     -- 设备名称
    group_id INT,               -- 区域ID
    group_name NCHAR(100),      -- 区域名称
    biz_id INT,                 -- 业务ID
    biz_name NCHAR(100),                 -- 业务名称
    project_id INT,                 -- 项目ID
    project_name NCHAR(100),         -- 项目名称
    location NCHAR(200),         -- 安装位置
    longitude NCHAR(200),       -- 经度
    latitude NCHAR(200),         -- 纬度
    tenant_id                   -- 租户ID
);



-- 创建无人地磅数据超级表
CREATE STABLE IF NOT EXISTS weighbridge_data (
    ts TIMESTAMP,           -- 称重时间戳
    gross_weight DOUBLE,    -- 毛重(kg)
    tare_weight DOUBLE,     -- 皮重(kg)
    net_weight DOUBLE,      -- 净重(kg)
    vehicle_plate BINARY(20), -- 车牌号
    driver_name BINARY(32),   -- 司机姓名
    material_type BINARY(30), -- 物料类型
    supplier BINARY(50),      -- 供应商
    customer BINARY(50),      -- 客户
    status BINARY(20),        -- 称重状态
    weighing_type BINARY(20)  -- 称重类型(入库/出库)
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  longitude NCHAR(200),        -- 经度
  latitude NCHAR(200),         -- 纬度
  tenant_id                   -- 租户ID
);



-- 创建排放检测数据超级表
CREATE STABLE IF NOT EXISTS emission_data (
    ts TIMESTAMP,              -- 检测时间戳
    co_concentration DOUBLE,   -- 一氧化碳浓度(mg/m³)
    co2_concentration DOUBLE,  -- 二氧化碳浓度(%)
    nox_concentration DOUBLE,  -- 氮氧化物浓度(mg/m³)
    so2_concentration DOUBLE,  -- 二氧化硫浓度(mg/m³)
    pm25_concentration DOUBLE, -- PM2.5浓度(μg/m³)
    pm10_concentration DOUBLE, -- PM10浓度(μg/m³)
    o2_concentration DOUBLE,   -- 氧气浓度(%)
    temperature FLOAT,         -- 烟气温度(℃)
    pressure FLOAT,            -- 烟气压力(Pa)
    flow_rate DOUBLE,          -- 烟气流量(m³/h)
    emission_status BINARY(20) -- 排放状态(normal/exceed/alarm)
) TAGS (
  device_id NCHAR(64),        -- 设备唯一ID
  device_name NCHAR(100),     -- 设备名称
  group_id INT,               -- 区域ID
  group_name NCHAR(100),      -- 区域名称
  biz_id INT,                 -- 业务ID
  biz_name NCHAR(100),                 -- 业务名称
  project_id INT,                 -- 项目ID
  project_name NCHAR(100),         -- 项目名称
  location NCHAR(200),         -- 安装位置
  longitude NCHAR(200),        -- 经度
  latitude NCHAR(200),         -- 纬度
  tenant_id                   -- 租户ID
);



-- 创建车辆数据超级表
CREATE STABLE IF NOT EXISTS vehicle_data (
    ts TIMESTAMP,              -- 数据时间戳
    longitude NCHAR(200)       -- 经度
    latitude NCHAR(200)        -- 纬度
    speed FLOAT,               -- 车速(km/h)
    direction INT,             -- 行驶方向(角度)
    fuel_level FLOAT,          -- 燃油液位(%)
    mileage DOUBLE,            -- 里程数(km)
    engine_temp FLOAT,         -- 发动机温度(℃)
    battery_voltage FLOAT,     -- 电池电压(V)
    status BINARY(20),         -- 车辆状态(running/stopped/idle)
    alarm_code INT             -- 报警代码
) TAGS (
    fleet_id BINARY(32),        -- 车队ID
    device_id NCHAR(64),        -- 设备唯一ID
    device_name NCHAR(100),     -- 设备名称
    group_id INT,               -- 区域ID
    group_name NCHAR(100),      -- 区域名称
    biz_id INT,                 -- 业务ID
    biz_name NCHAR(100),                 -- 业务名称
    project_id INT,                 -- 项目ID
    project_name NCHAR(100),         -- 项目名称
    tenant_id                   -- 租户ID
);

-- 创建装载机械数据超级表
CREATE STABLE IF NOT EXISTS loading_equipment_data (
    ts TIMESTAMP,              -- 数据时间戳
    load_capacity DOUBLE,      -- 装载能力(t)
    operation_count INT,       -- 作业次数
    hydraulic_pressure FLOAT,  -- 液压压力(MPa)
    engine_temperature FLOAT,  -- 发动机温度(℃)
    fuel_level FLOAT,          -- 燃油液位(%)
    working_hours INT,         -- 工作时长(hour)
    efficiency_rate FLOAT,     -- 效率比率(%)
    fault_code INT,            -- 故障代码
    longitude NCHAR(200),        -- 经度
    latitude NCHAR(200),         -- 纬度
    equipment_status BINARY(20) -- 设备状态
) TAGS (
    device_id NCHAR(64),        -- 设备唯一ID
    device_name NCHAR(100),     -- 设备名称
    group_id INT,               -- 区域ID
    group_name NCHAR(100),      -- 区域名称
    device_id NCHAR(64),        -- 设备唯一ID
    device_name NCHAR(100),     -- 设备名称
    group_id INT,               -- 区域ID
    group_name NCHAR(100),      -- 区域名称
    biz_id INT,                 -- 业务ID
    biz_name NCHAR(100),         -- 业务名称
    project_id INT,                 -- 项目ID
    project_name NCHAR(100),         -- 项目名称
    tenant_id                   -- 租户ID
);

-- 矿山人员监测超级表
CREATE STABLE IF NOT EXISTS mine_personnel (
  ts TIMESTAMP,                 -- 时间戳字段
  zone_id INT,                  -- 区域ID（如1=井下采区，2=主巷道，3=地面调度室）
  zone_name NCHAR(100),         -- 区域名称（冗余存储，如"3号煤层采区"）
  location_x FLOAT,             -- 区域内X坐标（米，基于矿区坐标系）
  location_y FLOAT,             -- 区域内Y坐标（米）
  location_z FLOAT,             -- 海拔/深度（米，正数为地面，负数为井下深度）
  moving_status TINYINT,        -- 移动状态：1=静止，2=移动中，3=快速移动（异常）
  speed FLOAT,                  -- 移动速度（m/s，静止时≈0）

  safety_device_status TINYINT, -- 安全设备状态：1=正常（定位+通讯正常），2=通讯弱，3=离线
  vital_signs_status TINYINT,   -- 生命体征状态（仅佩戴监测设备时）：1=正常，2=异常
  gas_alarm TINYINT,            -- 周边气体告警：0=无告警，1=瓦斯超标，2=一氧化碳超标
  panic_alarm TINYINT,          -- 紧急求救：0=无，1=触发求救信号
  working_status TINYINT,       -- 工作状态：1=作业中，2=休息，3=巡检中，4=撤离中
  work_shift TINYINT,           -- 班次：1=早班，2=中班，3=夜班
  last_checkin_ts TIMESTAMP     -- 最近一次打卡时间（用于考勤统计）
) TAGS (
  personnel_id NCHAR(64),       -- 人员唯一ID
  name NCHAR(32),               -- 姓名
  job_type TINYINT,             -- 工种：1=矿工，2=安全员，3=技术员，4=管理人员
  team_id INT,                  -- 所属班组ID（如1=采煤一班）
  tenant_id NCHAR(64),          -- 租户ID（多矿区隔离，如"MINE-B"）
  safety_card_id NCHAR(64),     -- 安全卡编号（定位设备唯一标识）
  entry_time TIMESTAMP,          -- 入井/进入作业区时间（动态更新）
  tenant_id                    -- 租户ID
);