#事件记录查询

// 库里对 2024 列的校验逻辑（cpp/src/standard/records.cpp）
if (column == model::Oad{oi::event_source, 2, 0}) {
    if (value.type() != model::DataType::null)
        return Error{ErrorCode::invalid_value, 0, "event NULL source"};
}

#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, 2)，用模板的四列
    auto query = standard::record_sequences(oi::meter_power_down_event, 1, 2, {}, 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;
    }
    if (const auto dar = std::get_if<std::uint8_t>(&result.value().result)) {
        std::cerr << "event query failed, DAR=" << unsigned(*dar) << '\n';
        client.disconnect();
        return 1;
    }

    const auto& record = result.value();
    const auto* rows = std::get_if<std::vector<protocol::apdu::RecordRow>>(&record.result);
    if (!rows) {
        client.disconnect();
        return 1;
    }

    for (const auto& row : *rows) {
        std::cout << "event with " << row.size() << " cells\n";
        for (std::size_t i = 0; i < row.size() && i < record.columns.size(); ++i) {
            const auto& column = std::get<model::Oad>(record.columns[i]);
            std::cout << "  oi=" << std::hex << column.oi << std::dec
                      << " attr=" << unsigned(column.attribute) << " type="
                      << unsigned(row[i].type()) << '\n';
            // 时间列按下标取：t[0..1] 年(大端) t[2] 月 t[3] 日 t[4] 时 t[5] 分 t[6] 秒
            if (row[i].type() == model::DataType::date_time_s) {
                const auto& t = row[i].as<model::DateTimeS>().value;
                std::cout << "    " << (unsigned(t[0]) << 8 | t[1]) << '-'
                          << unsigned(t[2]) << '-' << unsigned(t[3]) << ' '
                          << unsigned(t[4]) << ':' << unsigned(t[5]) << '\n';
            }
        }
    }

    client.disconnect();
    return 0;
}

auto query = standard::record_sequences(
    oi::meter_power_down_event, 1, 10,
    {{oi::event_sequence, 2, 0}, {oi::event_start_time, 2, 0}}, layout);

auto query = standard::record_between(oi::terminal_initialization_event,
                                      model::DateTimeS{{0x07, 0xea, 10, 1, 0, 0, 0}},
                                      model::DateTimeS{{0x07, 0xea, 10, 8, 0, 0, 0}},
                                      {}, layout);

std::uint32_t begin = 1;
for (int page = 0; page < 100; ++page) {
    auto query = standard::record_sequences(oi::meter_power_down_event, begin, begin + 20, {}, 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 || rows->empty()) break;
    // ... 处理 rows ...
    begin = rows->back().front().as<model::UInt32>().value + 1;   // 第 0 列是序号
}

auto result = client.get_record(query.value());
if (result && !std::get_if<std::uint8_t>(&result.value().result)) {
    auto valid = standard::validate_record_result(query.value(), result.value(), layout);
    if (!valid)
        std::cerr << "invalid event record: " << valid.error().context << '\n';
}