技术栈

后端：RuoYi-Vue（官方） + JDK 8/17 + Spring Boot 2.5.15/2.7.18
前端：RuoYi-Vue3（官方 Vue3 版） + Vue 3 + Element Plus + Vite

com.ruoyi.energy
├── config          # MQTT、TDengine、线程池、WebSocket 配置
├── controller      # 只做参数校验和调用 Service
├── service         # 业务逻辑
│   ├── impl
│   ├── collect     # 采集编排
│   ├── stat        # 统计聚合
│   ├── carbon      # 碳核算
│   └── alarm       # 报警规则
├── mapper          # MyBatis Mapper
├── domain          # 实体、DTO、VO
├── enums           # 能源类型、数据质量、核算范围
└── util            # 单位换算、点位编码、CRC 校验

src/views/energy
├── dashboard/          # 驾驶舱
├── monitor/            # 实时监控
├── analysis/           # 能耗分析
├── carbon/             # 碳管理
├── alarm/              # 报警
└── base/               # 计量点、设备、介质
src/api/energy
├── dashboard.js
├── monitor.js
├── analysis.js
└── carbon.js

1,000 × 60 × 24 × 365 ≈ 5.26 亿条/年

CREATE DATABASE IF NOT EXISTS energy
  PRECISION 'ms'
  KEEP 1095
  DURATION 10;

CREATE STABLE IF NOT EXISTS energy.point_data (
  ts        TIMESTAMP,
  value     DOUBLE,
  quality   TINYINT
) TAGS (
  point_code  BINARY(64),
  meter_code  BINARY(64),
  energy_type BINARY(16),
  site_id     BIGINT
);

-- 每个点位一张子表，子表名可用点位编码的哈希或序号
CREATE TABLE IF NOT EXISTS energy.p_0001
  USING energy.point_data
  TAGS ('SH01-C01-ELE-001.EP', 'SH01-C01-ELE-001', 'electricity', 1);

INSERT INTO energy.p_0001
  USING energy.point_data
  TAGS ('SH01-C01-ELE-001.EP', 'SH01-C01-ELE-001', 'electricity', 1)
  VALUES (NOW, 45678.9, 0);

SELECT ts, value
FROM energy.point_data
WHERE point_code = 'SH01-C01-ELE-001.EP'
  AND ts >= '2026-10-01 00:00:00'
  AND ts <  '2026-10-02 00:00:00'
ORDER BY ts;

energy/{siteId}/{gatewayId}/telemetry      # 遥测数据
energy/{siteId}/{gatewayId}/status         # 网关状态（retained）
energy/{siteId}/{gatewayId}/event          # 报警/事件
energy/{siteId}/{gatewayId}/cmd            # 平台下行命令

energy/SH01/GW-SH01-01/telemetry
energy/SH01/GW-SH01-01/status

┌─────────────────────────────────────────────┐
│              Collector 服务                  │
│                                             │
│  ┌──────────┐   ┌──────────┐   ┌─────────┐  │
│  │ Modbus   │   │ DL/T 645 │   │ OPC UA  │  │
│  │ Adapter  │   │ Adapter  │   │ Adapter │  │
│  └────┬─────┘   └────┬─────┘   └────┬────┘  │
│       └──────────────┼──────────────┘       │
│                      ▼                      │
│              ┌──────────────┐               │
│              │ 数据清洗/校验 │               │
│              └──────┬───────┘               │
│                     ▼                       │
│         ┌───────────────────────┐           │
│         │ 批量写入 + Redis 最新值 │           │
│         └───────────┬───────────┘           │
│                     ▼                       │
│              ┌──────────────┐               │
│              │ 报警规则引擎  │               │
│              └──────────────┘               │
└─────────────────────────────────────────────┘

public interface ProtocolAdapter {
    String protocol();
    void connect();
    void disconnect();
    boolean isConnected();
    List<PointValue> read(DeviceConfig device, List<PointConfig> points);
    default void write(DeviceConfig device, PointConfig point, Object value) {
        throw new UnsupportedOperationException("只读适配器");
    }
}

public interface EmissionCalculator {
    String sourceType();
    BigDecimal calculate(EmissionContext context);
}

public class EmissionResult {
    private String sourceType;
    private String scope;          // SCOPE_1 / SCOPE_2 / SCOPE_3
    private BigDecimal activity;   // 活动数据
    private String activityUnit;
    private BigDecimal factor;
    private String factorUnit;
    private BigDecimal emission;   // tCO2e
    private String factorVersion;
    private String dataSource;     // 来自哪个表/哪个点位
}

RuoYi-Vue（单体） + Vue 3 + MySQL + Redis + TDengine
+ EMQX + 独立 Collector（Modbus / DL/T 645 / OPC UA）
+ ECharts + EasyExcel + Docker Compose