#月冻结查询

#include <dlt698/app.hpp>
#include <dlt698/standard/records.hpp>
#include <iostream>

int main() {
    using namespace dlt698;
    namespace oi = standard::oi;

    const standard::DeviceLayout layout{standard::Wiring::three_phase, 4, 21};

    app::ClientOptions options;
    options.protocol.server.bytes = {0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
    app::Client client(options);
    auto connected = client.connect_tcp("127.0.0.1", 6980);
    if (!connected) {
        std::cerr << connected.error().context << '\n';
        return 1;
    }

    // 序号区间 [1, 4)：取序号 1、2、3 三条
    auto query = standard::record_sequences(
        oi::monthly_freeze, 1, 4,
        {{oi::freeze_sequence, 2, 0},
         {oi::freeze_time, 2, 0},
         {oi::forward_active_energy, 2, 1}},
        layout);
    if (!query) {
        std::cerr << query.error().context << '\n';
        client.disconnect();
        return 1;
    }

    auto result = client.get_record(query.value());
    if (!result) {
        std::cerr << result.error().context << '\n';
        client.disconnect();
        return 1;
    }

    // 外层成功不等于业务成功：result 字段可能是 DAR
    if (const auto dar = std::get_if<std::uint8_t>(&result.value().result)) {
        std::cerr << "record query failed, DAR=" << unsigned(*dar) << '\n';
        client.disconnect();
        return 1;
    }

    const auto& record = result.value();

    // record.result 是 variant：uint8_t 分支是 DAR，vector 分支才是行数据
    const auto* rows = std::get_if<std::vector<protocol::apdu::RecordRow>>(&record.result);
    if (!rows || rows->empty()) {
        std::cout << "no monthly freeze record\n";
        client.disconnect();
        return 0;
    }

    for (const auto& row : *rows) {
        // 列顺序由请求 RCSD 决定，与 record.columns 一致
        for (std::size_t i = 0; i < row.size(); ++i) {
            std::cout << "cell " << i << " type=" << unsigned(row[i].type()) << '\n';
        }
        // 最后一列是电能，换算成工程值输出
        const model::Oad energy_column{oi::forward_active_energy, 2, 1};
        const auto numbers = standard::engineering_values(energy_column, row.back(), layout);
        if (numbers && !numbers.value().empty())
            std::cout << "energy " << standard::decimal_text(numbers.value().front())
                      << " kWh\n";
    }

    client.disconnect();
    return 0;
}

std::vector<model::Oad> columns{
    {oi::freeze_sequence, 2, 0},          // 序号
    {oi::freeze_time, 2, 0},              // 冻结时间
    {oi::forward_active_energy, 2, 0},     // 正向有功总电能（整体）
};
for (std::uint8_t t = 1; t <= layout.tariff_count; ++t)
    columns.push_back({oi::forward_active_energy, 2, t});  // 各费率

auto query = standard::record_between(oi::monthly_freeze,
                                      model::DateTimeS{{0x07, 0xea, 1, 1, 0, 0, 0}},   // 含
                                      model::DateTimeS{{0x07, 0xea, 4, 1, 0, 0, 0}},   // 不含
                                      columns, layout);

// 2028-02-29 是合法日期
model::DateTimeS{{0x07, 0xf0, 2, 29, 0, 0, 0}}   // 0x07F0 = 2032

std::uint32_t begin = 1;
for (int page = 0; page < 100; ++page) {   // 设上限，避免设备返回海量数据
    auto query = standard::record_sequences(oi::monthly_freeze, begin, begin + 12, columns, layout);
    if (!query) break;
    auto result = client.get_record(query.value());
    if (!result || std::get_if<std::uint8_t>(&result.value().result)) break;

    const auto& rows = *std::get_if<std::vector<protocol::apdu::RecordRow>>(&result.value().result);
    if (rows.empty()) break;               // 没有更多记录
    // ... 处理 rows ...

    // 用响应里的实际序号推进起点
    begin = rows.back().front().as<model::UInt32>().value + 1;
}