常规更新
This commit is contained in:
@@ -1,82 +1,73 @@
|
||||
#pragma once
|
||||
#include <string_view>
|
||||
|
||||
#include "../External_Database/export.h"
|
||||
|
||||
#include <map>
|
||||
#include <memory>
|
||||
#include <optional>
|
||||
#include <string>
|
||||
|
||||
#include "SSR/Aircraft_Info.h"
|
||||
|
||||
class Aircraft : public SSR::Aircraft_Info {
|
||||
public:
|
||||
explicit Aircraft(std::string_view icao);
|
||||
|
||||
// 静态信息按 ICAO24 加载一次；航线信息仅在 callsign 变化时重新加载。
|
||||
// map 的键是外部数据源名称。
|
||||
std::map<std::string, std::shared_ptr<External_Database_Row>>
|
||||
external_database_info;
|
||||
std::map<std::string, std::shared_ptr<External_Database_Row>>
|
||||
callsign_external_database_info;
|
||||
bool external_database_info_loaded{};
|
||||
std::optional<std::string> last_external_database_callsign;
|
||||
|
||||
[[nodiscard]] std::shared_ptr<External_Database_Row>
|
||||
external_database_row(std::string_view resource_name) const {
|
||||
auto key = std::string(resource_name);
|
||||
const auto callsign_iter =
|
||||
explicit Aircraft(std::string_view icao);
|
||||
// 静态信息按 ICAO24 加载一次；航线信息仅在 callsign 变化时重新加载。
|
||||
// map 的键是外部数据源名称。
|
||||
std::map<std::string, std::shared_ptr<External_Database_Row>>
|
||||
external_database_info;
|
||||
std::map<std::string, std::shared_ptr<External_Database_Row>>
|
||||
callsign_external_database_info;
|
||||
bool external_database_info_loaded{};
|
||||
std::optional<std::string> last_external_database_callsign;
|
||||
[[nodiscard]] std::shared_ptr<External_Database_Row>
|
||||
external_database_row(std::string_view resource_name) const {
|
||||
auto key = std::string(resource_name);
|
||||
const auto callsign_iter =
|
||||
callsign_external_database_info.find(key);
|
||||
if (callsign_iter != callsign_external_database_info.end()) {
|
||||
return callsign_iter->second;
|
||||
if (callsign_iter != callsign_external_database_info.end()) {
|
||||
return callsign_iter->second;
|
||||
}
|
||||
const auto iter = external_database_info.find(key);
|
||||
return iter == external_database_info.end() ? nullptr : iter->second;
|
||||
}
|
||||
const auto iter = external_database_info.find(key);
|
||||
return iter == external_database_info.end() ? nullptr : iter->second;
|
||||
}
|
||||
|
||||
void refresh_external_database_info();
|
||||
|
||||
Psc::JSON toJson() {
|
||||
refresh_external_database_info();
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(icao) ret.append({"每秒位置数", get_pest()});
|
||||
ret.append({"飞机位置轨迹点数", air_pos_track_list.size()});
|
||||
ret.append({"地面位置轨迹点数", surface_pos_track_list.size()});
|
||||
ret.append({"信号强度", signal_level});
|
||||
auto opt_pos = air_pos_track_list.last();
|
||||
ret.append({"当前位置消息", opt_pos.has_value() ? opt_pos->to_json() : ""});
|
||||
|
||||
auto cpr_state_opt = BDS05_airborne_position.value;
|
||||
ret.append(
|
||||
{"cpr解码器状态", cpr_state_opt.has_value()
|
||||
? cpr_state_opt.value().current_state_json()
|
||||
: ""});
|
||||
ret.append({"时间", Psc::utc_2_local_time(timestamp)});
|
||||
ret.append({"多点定位数据源", mlat});
|
||||
|
||||
auto external_info = Psc::JSON::object();
|
||||
for (const auto &[resource_key, row] : external_database_info) {
|
||||
external_info.append({resource_key, row->to_json()});
|
||||
void refresh_external_database_info();
|
||||
Psc::JSON toJson() {
|
||||
refresh_external_database_info();
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(icao)
|
||||
ret.append({"每秒位置数", get_pest()});
|
||||
ret.append({"飞机位置轨迹点数", air_pos_track_list.size()});
|
||||
ret.append({"地面位置轨迹点数", surface_pos_track_list.size()});
|
||||
ret.append({"信号强度", signal_level});
|
||||
auto opt_pos = air_pos_track_list.last();
|
||||
ret.append({"当前位置消息", opt_pos.has_value() ? opt_pos->to_json() : ""});
|
||||
auto cpr_state_opt = BDS05_airborne_position.value;
|
||||
ret.append(
|
||||
{
|
||||
"cpr解码器状态", cpr_state_opt.has_value()
|
||||
? cpr_state_opt.value().current_state_json()
|
||||
: ""
|
||||
});
|
||||
ret.append({"时间", Psc::utc_2_local_time(timestamp)});
|
||||
ret.append({"多点定位数据源", mlat});
|
||||
auto external_info = Psc::JSON::object();
|
||||
for (const auto& [resource_key, row] : external_database_info) {
|
||||
external_info.append({resource_key, row->to_json()});
|
||||
}
|
||||
for (const auto& [resource_key, row] : callsign_external_database_info) {
|
||||
external_info.append({resource_key, row->to_json()});
|
||||
}
|
||||
ret.append({"external_database_info", external_info});
|
||||
push_all_bds_info(ret);
|
||||
return ret;
|
||||
}
|
||||
for (const auto &[resource_key, row] : callsign_external_database_info) {
|
||||
external_info.append({resource_key, row->to_json()});
|
||||
}
|
||||
ret.append({"external_database_info", external_info});
|
||||
|
||||
push_all_bds_info(ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
#ifdef Cache_Some_Mode_S
|
||||
std::list<std::shared_ptr<Mode_S_Msg>> cache;
|
||||
size_t total_num = 0;
|
||||
void add_msg_limit(const std::shared_ptr<Mode_S_Msg> &msg) {
|
||||
if (cache.size() > Cache_Some_Mode_S_Num) {
|
||||
cache.pop_front();
|
||||
std::list<std::shared_ptr<Mode_S_Msg>> cache;
|
||||
size_t total_num = 0;
|
||||
void add_msg_limit(const std::shared_ptr<Mode_S_Msg>& msg) {
|
||||
if (cache.size() > Cache_Some_Mode_S_Num) {
|
||||
cache.pop_front();
|
||||
}
|
||||
cache.emplace_back(msg);
|
||||
total_num++;
|
||||
}
|
||||
cache.emplace_back(msg);
|
||||
total_num++;
|
||||
}
|
||||
#endif
|
||||
};
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -5,404 +5,404 @@ namespace Psc {
|
||||
class SM_RingBuffer;
|
||||
}
|
||||
class Data_Source;
|
||||
std::shared_ptr<Data_Source> create_from_json(const Psc::JSON *that_json);
|
||||
std::shared_ptr<Data_Source> create_from_json(const Psc::JSON* that_json);
|
||||
class Input_Format {
|
||||
public:
|
||||
Input_Format() {
|
||||
test_v.resize(static_cast<size_t>(SSR::Downlink_Format::Unknown));
|
||||
}
|
||||
Psc::JSON to_json() {
|
||||
std::lock_guard g(mtx);
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
for (auto e : magic_enum::enum_values<SSR::Downlink_Format>()) {
|
||||
std::string_view value_view = magic_enum::enum_name(e);
|
||||
std::string value(value_view.begin(), value_view.end());
|
||||
if (value == Psc::to_string(SSR::Downlink_Format::Unknown)) continue;
|
||||
auto ev = static_cast<std::uint8_t>(e);
|
||||
bool it = test_v[ev];
|
||||
ret.append({value, it});
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
void from_json(const Psc::JSON *json) {
|
||||
std::lock_guard g(mtx);
|
||||
for (auto e : magic_enum::enum_values<SSR::Downlink_Format>()) {
|
||||
std::string_view value_view = magic_enum::enum_name(e);
|
||||
std::string value(value_view.begin(), value_view.end());
|
||||
if (value == Psc::to_string(SSR::Downlink_Format::Unknown)) continue;
|
||||
auto use = json->get_bool(value);
|
||||
auto ev = static_cast<std::uint8_t>(e);
|
||||
test_v[ev] = use;
|
||||
}
|
||||
}
|
||||
bool test(SSR::Downlink_Format df) {
|
||||
std::lock_guard g(mtx);
|
||||
auto dfv = static_cast<std::uint8_t>(df);
|
||||
if (dfv >= static_cast<std::uint8_t>(SSR::Downlink_Format::Unknown)) return false;
|
||||
return test_v[dfv];
|
||||
}
|
||||
bool test(std::uint8_t dfv) {
|
||||
std::lock_guard g(mtx);
|
||||
if (dfv >= static_cast<std::uint8_t>(SSR::Downlink_Format::Unknown)) return false;
|
||||
return test_v[dfv];
|
||||
}
|
||||
Input_Format() {
|
||||
test_v.resize(static_cast<size_t>(SSR::Downlink_Format::Unknown));
|
||||
}
|
||||
Psc::JSON to_json() {
|
||||
std::lock_guard g(mtx);
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
for (auto e : magic_enum::enum_values<SSR::Downlink_Format>()) {
|
||||
std::string_view value_view = magic_enum::enum_name(e);
|
||||
std::string value(value_view.begin(), value_view.end());
|
||||
if (value == Psc::to_string(SSR::Downlink_Format::Unknown)) continue;
|
||||
auto ev = static_cast<std::uint8_t>(e);
|
||||
bool it = test_v[ev];
|
||||
ret.append({value, it});
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
void from_json(const Psc::JSON* json) {
|
||||
std::lock_guard g(mtx);
|
||||
for (auto e : magic_enum::enum_values<SSR::Downlink_Format>()) {
|
||||
std::string_view value_view = magic_enum::enum_name(e);
|
||||
std::string value(value_view.begin(), value_view.end());
|
||||
if (value == Psc::to_string(SSR::Downlink_Format::Unknown)) continue;
|
||||
auto use = json->get_bool(value);
|
||||
auto ev = static_cast<std::uint8_t>(e);
|
||||
test_v[ev] = use;
|
||||
}
|
||||
}
|
||||
bool test(SSR::Downlink_Format df) {
|
||||
std::lock_guard g(mtx);
|
||||
auto dfv = static_cast<std::uint8_t>(df);
|
||||
if (dfv >= static_cast<std::uint8_t>(SSR::Downlink_Format::Unknown)) return false;
|
||||
return test_v[dfv];
|
||||
}
|
||||
bool test(std::uint8_t dfv) {
|
||||
std::lock_guard g(mtx);
|
||||
if (dfv >= static_cast<std::uint8_t>(SSR::Downlink_Format::Unknown)) return false;
|
||||
return test_v[dfv];
|
||||
}
|
||||
protected:
|
||||
std::mutex mtx;
|
||||
std::vector<bool> test_v;
|
||||
std::mutex mtx;
|
||||
std::vector<bool> test_v;
|
||||
};
|
||||
class Data_Source_Data {
|
||||
public:
|
||||
Psc::Copyable_Atomic<bool> base_station_show{};
|
||||
Psc::Copyable_Atomic<bool> aircraft_show{};
|
||||
std::string color = "#1677ff";
|
||||
int aircraft_pixel_size{};
|
||||
double lat{};
|
||||
double lon{};
|
||||
double alt{};
|
||||
Psc::Copyable_Atomic<bool> update_form_gps{};
|
||||
Psc::Copyable_Atomic<bool> show_icao = true;
|
||||
Psc::Copyable_Atomic<bool> show_call_sign = false;
|
||||
Psc::Copyable_Atomic<bool> show_fly_status = false;
|
||||
Psc::Copyable_Atomic<bool> keep_mode = true;
|
||||
PSC_USE_JSON
|
||||
Psc::Copyable_Atomic<bool> base_station_show{};
|
||||
Psc::Copyable_Atomic<bool> aircraft_show{};
|
||||
std::string color = "#1677ff";
|
||||
int aircraft_pixel_size{};
|
||||
double lat{};
|
||||
double lon{};
|
||||
double alt{};
|
||||
Psc::Copyable_Atomic<bool> update_form_gps{};
|
||||
Psc::Copyable_Atomic<bool> show_icao = true;
|
||||
Psc::Copyable_Atomic<bool> show_call_sign = false;
|
||||
Psc::Copyable_Atomic<bool> show_fly_status = false;
|
||||
Psc::Copyable_Atomic<bool> keep_mode = true;
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class Data_Source : public std::enable_shared_from_this<Data_Source>,
|
||||
public Data_Source_Handler, public Data_Source_Data {
|
||||
public:
|
||||
std::shared_ptr<Data_Source> that();
|
||||
virtual asio::awaitable<std::string> read_coro() {
|
||||
co_return "";
|
||||
}
|
||||
bool registered() const;
|
||||
virtual Psc::JSON get_custom_state_json() = 0;
|
||||
Psc::JSON get_state();
|
||||
std::string last_char; // 用于处理奇数字节
|
||||
Data_Source();
|
||||
asio::awaitable<void> loop_coro() final;
|
||||
std::shared_ptr<SSR::Mode_Msg> last_prase_msg = nullptr;
|
||||
virtual asio::awaitable<void> handle_in_loop_coro() {
|
||||
co_return;
|
||||
}
|
||||
Frequency_Limit statistic_fl;
|
||||
std::string thread_key() const;
|
||||
Psc::JSON statistic_json() {
|
||||
Psc::JSON ret = With_Loop_Coro::to_base_json();
|
||||
ret.append({"aircraft_total", get_aircraft_num()});
|
||||
ret.append({"aircraft_with_position", have_pos_aircraft_num});
|
||||
ret.append({"mode_ac_statistic", mode_ac_statistic.to_json()});
|
||||
ret.append({"mode_s_statistic", mode_s_statistic.to_json()});
|
||||
ret.append({"all_connect_feed", get_all_connect_feed_status()});
|
||||
return ret;
|
||||
}
|
||||
virtual Psc::JSON to_json() {
|
||||
return With_Loop_Coro::to_base_json() += Data_Source_Data::to_base_json();
|
||||
}
|
||||
virtual void from_json(const Psc::JSON *that_json) {
|
||||
With_Loop_Coro::from_base_json(that_json);
|
||||
Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
std::string buffer;
|
||||
std::atomic_bool ask_sleep = false;
|
||||
std::shared_ptr<Data_Source> that();
|
||||
virtual asio::awaitable<std::string> read_coro() {
|
||||
co_return "";
|
||||
}
|
||||
bool registered() const;
|
||||
virtual Psc::JSON get_custom_state_json() = 0;
|
||||
Psc::JSON get_state();
|
||||
std::string last_char; // 用于处理奇数字节
|
||||
Data_Source();
|
||||
asio::awaitable<void> loop_coro() final;
|
||||
std::shared_ptr<SSR::Mode_Msg> last_prase_msg = nullptr;
|
||||
virtual asio::awaitable<void> handle_in_loop_coro() {
|
||||
co_return;
|
||||
}
|
||||
Frequency_Limit statistic_fl;
|
||||
std::string thread_key() const;
|
||||
Psc::JSON statistic_json() {
|
||||
Psc::JSON ret = With_Loop_Coro::to_base_json();
|
||||
ret.append({"aircraft_total", get_aircraft_num()});
|
||||
ret.append({"aircraft_with_position", have_pos_aircraft_num});
|
||||
ret.append({"mode_ac_statistic", mode_ac_statistic.to_json()});
|
||||
ret.append({"mode_s_statistic", mode_s_statistic.to_json()});
|
||||
ret.append({"all_connect_feed", get_all_connect_feed_status()});
|
||||
return ret;
|
||||
}
|
||||
virtual Psc::JSON to_json() {
|
||||
return With_Loop_Coro::to_base_json() += Data_Source_Data::to_base_json();
|
||||
}
|
||||
virtual void from_json(const Psc::JSON* that_json) {
|
||||
With_Loop_Coro::from_base_json(that_json);
|
||||
Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
std::string buffer;
|
||||
std::atomic_bool ask_sleep = false;
|
||||
};
|
||||
class TCP_Client_Data_Source_Data {
|
||||
public:
|
||||
std::string ip;
|
||||
std::uint16_t port{};
|
||||
PSC_USE_JSON
|
||||
std::string ip;
|
||||
std::uint16_t port{};
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class TCP_Client_Data_Source : public Data_Source, public TCP_Client_Data_Source_Data {
|
||||
public:
|
||||
asio::awaitable<void> handle_in_loop_coro() override {
|
||||
co_await cli.tick_coro();
|
||||
co_return;
|
||||
}
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto& state = cli.state;
|
||||
return VAR_JSON_1(state);
|
||||
}
|
||||
Psc::asio_socket::TCP_Client_Coro cli;
|
||||
~TCP_Client_Data_Source() override = default;
|
||||
TCP_Client_Data_Source() {
|
||||
type = "TCP_Client_Data_Source";
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
Psc::asio_socket::Sockaddr_In addr;
|
||||
addr.ip = ip;
|
||||
addr.port = port;
|
||||
cli.set_dest_address(addr);
|
||||
cli.create();
|
||||
co_await cli.connect_coro();
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _close() override {
|
||||
co_await cli.close_coro();
|
||||
co_return;
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += TCP_Client_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void from_json(const Psc::JSON *that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
TCP_Client_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
asio::awaitable<std::string> read_coro() override {
|
||||
co_return co_await cli.read_coro();
|
||||
}
|
||||
asio::awaitable<void> handle_in_loop_coro() override {
|
||||
co_await cli.tick_coro();
|
||||
co_return;
|
||||
}
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto& state = cli.state;
|
||||
return VAR_JSON_1(state);
|
||||
}
|
||||
Psc::asio_socket::TCP_Client_Coro cli;
|
||||
~TCP_Client_Data_Source() override = default;
|
||||
TCP_Client_Data_Source() {
|
||||
type = "TCP_Client_Data_Source";
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
Psc::asio_socket::Sockaddr_In addr;
|
||||
addr.ip = ip;
|
||||
addr.port = port;
|
||||
cli.set_dest_address(addr);
|
||||
cli.create();
|
||||
co_await cli.connect_coro();
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _close() override {
|
||||
co_await cli.close_coro();
|
||||
co_return;
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += TCP_Client_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void from_json(const Psc::JSON* that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
TCP_Client_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
asio::awaitable<std::string> read_coro() override {
|
||||
co_return co_await cli.read_coro();
|
||||
}
|
||||
};
|
||||
class Serial_Data_Source_Data {
|
||||
public:
|
||||
std::string port_name;
|
||||
Baud_Rate_Type baud_rate{};
|
||||
PSC_USE_JSON
|
||||
std::string port_name;
|
||||
Baud_Rate_Type baud_rate{};
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class Serial_Data_Source : public Data_Source, public Serial_Data_Source_Data {
|
||||
public:
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
return Psc::JSON::object();
|
||||
}
|
||||
Serial_Data_Source() {
|
||||
this->type = "Serial_Data_Source";
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
serial = std::make_unique<Psc::serial::Serial_Coro>();
|
||||
serial->set_serial_name(port_name);
|
||||
serial->set_baud_rate(baud_rate);
|
||||
serial->set_parity(Psc::serial::Parity::NoParity);
|
||||
serial->set_data_bits(Psc::serial::DataBits::Data8);
|
||||
serial->set_stop_bits(Psc::serial::StopBits::OneStop);
|
||||
serial->set_flow_control(Psc::serial::FlowControl::HardwareControl);
|
||||
serial->set_buffer_byte_size(10 * 1024);
|
||||
bool ok = serial->open();
|
||||
if (!ok) {
|
||||
std::cerr << "createSerial " + port_name + ":" +
|
||||
std::to_string(baud_rate) + " 打开串口失败！\n";
|
||||
}
|
||||
else {
|
||||
// std::cerr << "createSerial " + serial_name + ":" +
|
||||
// std::to_string(baud_rate) + " 打开串口成功！\n";
|
||||
}
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _close() override {
|
||||
if (serial) serial->close();
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> handle_in_loop_coro() override {
|
||||
if (serial) {
|
||||
co_await serial->tick_coro();
|
||||
}
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<std::string> read_coro() override {
|
||||
if (!serial) {
|
||||
co_return "";
|
||||
}
|
||||
co_return co_await serial->read_coro();
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Serial_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void from_json(const Psc::JSON *that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Serial_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
std::unique_ptr<Psc::serial::Serial_Coro> serial{};
|
||||
~Serial_Data_Source() override {
|
||||
if (serial) {
|
||||
serial->close();
|
||||
}
|
||||
}
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
return Psc::JSON::object();
|
||||
}
|
||||
Serial_Data_Source() {
|
||||
this->type = "Serial_Data_Source";
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
serial = std::make_unique<Psc::serial::Serial_Coro>();
|
||||
serial->set_serial_name(port_name);
|
||||
serial->set_baud_rate(baud_rate);
|
||||
serial->set_parity(Psc::serial::Parity::NoParity);
|
||||
serial->set_data_bits(Psc::serial::DataBits::Data8);
|
||||
serial->set_stop_bits(Psc::serial::StopBits::OneStop);
|
||||
serial->set_flow_control(Psc::serial::FlowControl::HardwareControl);
|
||||
serial->set_buffer_byte_size(10 * 1024);
|
||||
bool ok = serial->open();
|
||||
if (!ok) {
|
||||
std::cerr << "createSerial " + port_name + ":" +
|
||||
std::to_string(baud_rate) + " 打开串口失败！\n";
|
||||
}
|
||||
else {
|
||||
// std::cerr << "createSerial " + serial_name + ":" +
|
||||
// std::to_string(baud_rate) + " 打开串口成功！\n";
|
||||
}
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _close() override {
|
||||
if (serial) serial->close();
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> handle_in_loop_coro() override {
|
||||
if (serial) {
|
||||
co_await serial->tick_coro();
|
||||
}
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<std::string> read_coro() override {
|
||||
if (!serial) {
|
||||
co_return "";
|
||||
}
|
||||
co_return co_await serial->read_coro();
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Serial_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void from_json(const Psc::JSON* that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Serial_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
std::unique_ptr<Psc::serial::Serial_Coro> serial{};
|
||||
~Serial_Data_Source() override {
|
||||
if (serial) {
|
||||
serial->close();
|
||||
}
|
||||
}
|
||||
};
|
||||
enum class File_Data_Type {
|
||||
SIMPLE_BIN_Blank, // 没有1a转义�?
|
||||
BIN_Blank_Text,
|
||||
AVR,
|
||||
BIN_Text,
|
||||
BIN_Blank_One_Line_With_Escape,
|
||||
BIN_Blank_One_Line_No_Escape,
|
||||
BIN,
|
||||
Unknown
|
||||
// 纯粹的二进制
|
||||
SIMPLE_BIN_Blank, // 没有1a转义�?
|
||||
BIN_Blank_Text,
|
||||
AVR,
|
||||
BIN_Text,
|
||||
BIN_Blank_One_Line_With_Escape,
|
||||
BIN_Blank_One_Line_No_Escape,
|
||||
BIN,
|
||||
Unknown
|
||||
// 纯粹的二进制
|
||||
};
|
||||
enum Play_Mode { one, loop, analysis, time_batch };
|
||||
class File_Data_Source_Data {
|
||||
public:
|
||||
std::string file_path;
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
Play_Mode play_mode = Play_Mode::one;
|
||||
PSC_USE_JSON
|
||||
std::string file_path;
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
Play_Mode play_mode = Play_Mode::one;
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class File_Data_Source : public Data_Source, public File_Data_Source_Data {
|
||||
public:
|
||||
bool have_report_play_back_all_success = false;
|
||||
std::string state = "null";
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto cur_virtual_time = player_clock.get_cur_time_point();
|
||||
auto playback_speed_rate = player_clock.playback_speed_rate;
|
||||
return VAR_JSON_5(cur_virtual_time, playback_speed_rate, state, index,
|
||||
part_infos.size());
|
||||
}
|
||||
File_Data_Source() {
|
||||
this->type = "File_Data_Source";
|
||||
}
|
||||
~File_Data_Source() override = default;
|
||||
void before_handle_msg(std::shared_ptr<SSR::Mode_Msg>& msg) override;
|
||||
struct Cache_Msg {
|
||||
explicit Cache_Msg(std::shared_ptr<SSR::Mode_S_Msg> msg) : msg(std::move(msg)) {}
|
||||
SSR::Play_Back_Time_Point time() const {
|
||||
return SSR::Play_Back_Time_Point{day_num, msg->mlat_timestamp.daysec};
|
||||
}
|
||||
std::uint64_t day_num = 0;
|
||||
std::shared_ptr<SSR::Mode_S_Msg> msg;
|
||||
};
|
||||
Player_Clock player_clock;
|
||||
std::shared_ptr<Cache_Msg> pre_cache = nullptr;
|
||||
std::deque<std::shared_ptr<Cache_Msg>> cache_list;
|
||||
std::string get_true_file_path() const {
|
||||
return Psc::get_abs_path(file_path);
|
||||
}
|
||||
asio::awaitable<void> _close() override;
|
||||
asio::awaitable<void> _open() override;
|
||||
std::vector<std::string> readBinaryFileAsString(std::string_view filepath,
|
||||
size_t part_size);
|
||||
void from_json(const Psc::JSON *that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
File_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += File_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
void handle_mode_s(std::shared_ptr<SSR::Mode_S_Msg> msg) override;
|
||||
bool have_report_play_back_all_success = false;
|
||||
std::string state = "null";
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto cur_virtual_time = player_clock.get_cur_time_point();
|
||||
auto playback_speed_rate = player_clock.playback_speed_rate;
|
||||
return VAR_JSON_5(cur_virtual_time, playback_speed_rate, state, index,
|
||||
part_infos.size());
|
||||
}
|
||||
File_Data_Source() {
|
||||
this->type = "File_Data_Source";
|
||||
}
|
||||
~File_Data_Source() override = default;
|
||||
void before_handle_msg(std::shared_ptr<SSR::Mode_Msg>& msg) override;
|
||||
struct Cache_Msg {
|
||||
explicit Cache_Msg(std::shared_ptr<SSR::Mode_S_Msg> msg) : msg(std::move(msg)) {}
|
||||
SSR::Play_Back_Time_Point time() const {
|
||||
return SSR::Play_Back_Time_Point{day_num, msg->mlat_timestamp.daysec};
|
||||
}
|
||||
std::uint64_t day_num = 0;
|
||||
std::shared_ptr<SSR::Mode_S_Msg> msg;
|
||||
};
|
||||
Player_Clock player_clock;
|
||||
std::shared_ptr<Cache_Msg> pre_cache = nullptr;
|
||||
std::deque<std::shared_ptr<Cache_Msg>> cache_list;
|
||||
std::string get_true_file_path() const {
|
||||
return Psc::get_abs_path(file_path);
|
||||
}
|
||||
asio::awaitable<void> _close() override;
|
||||
asio::awaitable<void> _open() override;
|
||||
std::vector<std::string> readBinaryFileAsString(std::string_view filepath,
|
||||
size_t part_size);
|
||||
void from_json(const Psc::JSON* that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
File_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += File_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
void handle_mode_s(std::shared_ptr<SSR::Mode_S_Msg> msg) override;
|
||||
protected:
|
||||
std::optional<std::string> get_raw_line(int& ret_index);
|
||||
long long index = 0;
|
||||
std::vector<std::string> part_infos;
|
||||
std::mutex mtx;
|
||||
std::optional<std::string> get_raw_line(int& ret_index);
|
||||
long long index = 0;
|
||||
std::vector<std::string> part_infos;
|
||||
std::mutex mtx;
|
||||
};
|
||||
class Dll_Data_Source_Data {
|
||||
public:
|
||||
std::string library_path;
|
||||
std::string function_name;
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
std::size_t buffer_size{};
|
||||
PSC_USE_JSON
|
||||
std::string library_path;
|
||||
std::string function_name;
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
std::size_t buffer_size{};
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class Dll_Data_Source : public Data_Source, public Dll_Data_Source_Data {
|
||||
public:
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto ret = VAR_JSON_1(state);
|
||||
ret.append({"read_vaild_len", vs.to_string()});
|
||||
return ret;
|
||||
}
|
||||
Psc::Value_Statistics vs;
|
||||
Dll_Data_Source() {
|
||||
this->type = "Dll_Data_Source";
|
||||
}
|
||||
~Dll_Data_Source() override = default;
|
||||
std::vector<std::uint8_t> buffer;
|
||||
void from_json(const Psc::JSON *that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Dll_Data_Source_Data::from_base_json(that_json);
|
||||
buffer.resize(buffer_size);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Dll_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void *lib{};
|
||||
using Func_Type = size_t (*)(char *buf, std::size_t max_len);
|
||||
// using Func_Type = std::uint16_t (*)(char *buf, std::uint16_t max_len);
|
||||
Func_Type read_func_ptr{};
|
||||
using Call_Back = void (*)(char *buf, std::size_t len);
|
||||
using set_Call_back = void (*)(Call_Back);
|
||||
std::string state;
|
||||
asio::awaitable<void> _close() override {
|
||||
Psc::free_library(lib);
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
{
|
||||
auto r = Psc::try_load_library(Psc::get_abs_path(library_path));
|
||||
if (!r) {
|
||||
state = r.error().message();
|
||||
co_return;
|
||||
}
|
||||
lib = r.value();
|
||||
}
|
||||
{
|
||||
auto r = Psc::try_load_function(lib, function_name);
|
||||
if (!r) {
|
||||
state = r.error().message();
|
||||
std::cout << LOG_POS << " [" << function_name << "] 函数指针加载失败!"
|
||||
<< std::endl;
|
||||
co_return;
|
||||
}
|
||||
read_func_ptr = (Func_Type)r.value();
|
||||
}
|
||||
state = "加载成功";
|
||||
co_return;
|
||||
}
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
auto ret = VAR_JSON_1(state);
|
||||
ret.append({"read_vaild_len", vs.to_string()});
|
||||
return ret;
|
||||
}
|
||||
Psc::Value_Statistics vs;
|
||||
Dll_Data_Source() {
|
||||
this->type = "Dll_Data_Source";
|
||||
}
|
||||
~Dll_Data_Source() override = default;
|
||||
std::vector<std::uint8_t> buffer;
|
||||
void from_json(const Psc::JSON* that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Dll_Data_Source_Data::from_base_json(that_json);
|
||||
buffer.resize(buffer_size);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Dll_Data_Source_Data::to_base_json();
|
||||
}
|
||||
void* lib{};
|
||||
using Func_Type = size_t (*)(char* buf, std::size_t max_len);
|
||||
// using Func_Type = std::uint16_t (*)(char *buf, std::uint16_t max_len);
|
||||
Func_Type read_func_ptr{};
|
||||
using Call_Back = void (*)(char* buf, std::size_t len);
|
||||
using set_Call_back = void (*)(Call_Back);
|
||||
std::string state;
|
||||
asio::awaitable<void> _close() override {
|
||||
Psc::free_library(lib);
|
||||
co_return;
|
||||
}
|
||||
asio::awaitable<void> _open() override {
|
||||
{
|
||||
auto r = Psc::try_load_library(Psc::get_abs_path(library_path));
|
||||
if (!r) {
|
||||
state = r.error().message();
|
||||
co_return;
|
||||
}
|
||||
lib = r.value();
|
||||
}
|
||||
{
|
||||
auto r = Psc::try_load_function(lib, function_name);
|
||||
if (!r) {
|
||||
state = r.error().message();
|
||||
std::cout << LOG_POS << " [" << function_name << "] 函数指针加载失败!"
|
||||
<< std::endl;
|
||||
co_return;
|
||||
}
|
||||
read_func_ptr = (Func_Type)r.value();
|
||||
}
|
||||
state = "加载成功";
|
||||
co_return;
|
||||
}
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
};
|
||||
class Shared_Memory_Data_Source_Data {
|
||||
public:
|
||||
std::string shared_memory_name;
|
||||
std::uint64_t shared_memory_size{};
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
PSC_USE_JSON
|
||||
std::string shared_memory_name;
|
||||
std::uint64_t shared_memory_size{};
|
||||
File_Data_Type data_type = File_Data_Type::BIN_Blank_Text;
|
||||
PSC_USE_JSON
|
||||
};
|
||||
class Shared_Memory_Data_Source : public Data_Source, public Shared_Memory_Data_Source_Data {
|
||||
public:
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
return Psc::JSON::object();
|
||||
}
|
||||
void from_json(const Psc::JSON *that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Shared_Memory_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Shared_Memory_Data_Source_Data::to_base_json();
|
||||
}
|
||||
asio::awaitable<void> _open() override;
|
||||
asio::awaitable<void> _close() override;
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
Psc::JSON get_custom_state_json() override {
|
||||
return Psc::JSON::object();
|
||||
}
|
||||
void from_json(const Psc::JSON* that_json) override {
|
||||
Data_Source::from_json(that_json);
|
||||
Shared_Memory_Data_Source_Data::from_base_json(that_json);
|
||||
}
|
||||
Psc::JSON to_json() override {
|
||||
return Data_Source::to_json() += Shared_Memory_Data_Source_Data::to_base_json();
|
||||
}
|
||||
asio::awaitable<void> _open() override;
|
||||
asio::awaitable<void> _close() override;
|
||||
void origin_data_transform_mode_data(std::string& data) override;
|
||||
protected:
|
||||
std::unique_ptr<Psc::SM_RingBuffer> sm;
|
||||
std::unique_ptr<Psc::SM_RingBuffer> sm;
|
||||
};
|
||||
inline std::shared_ptr<Data_Source> create_data_source_from_type(std::string_view t) {
|
||||
std::shared_ptr<Data_Source> ret{};
|
||||
if (t == "Serial_Data_Source") ret = std::make_shared<Serial_Data_Source>();
|
||||
else if (t == "TCP_Client_Data_Source") ret = std::make_shared<TCP_Client_Data_Source>();
|
||||
else if (t == "File_Data_Source") ret = std::make_shared<File_Data_Source>();
|
||||
else if (t == "Dll_Data_Source") ret = std::make_shared<Dll_Data_Source>();
|
||||
else if (t == "Shared_Memory_Data_Source") ret = std::make_shared<Shared_Memory_Data_Source>();
|
||||
else {
|
||||
std::cout << "未知�?Data_Source type类型!" << std::endl;
|
||||
throw std::invalid_argument("unknown Data_Source type: " + std::string(t));
|
||||
}
|
||||
return ret;
|
||||
std::shared_ptr<Data_Source> ret{};
|
||||
if (t == "Serial_Data_Source") ret = std::make_shared<Serial_Data_Source>();
|
||||
else if (t == "TCP_Client_Data_Source") ret = std::make_shared<TCP_Client_Data_Source>();
|
||||
else if (t == "File_Data_Source") ret = std::make_shared<File_Data_Source>();
|
||||
else if (t == "Dll_Data_Source") ret = std::make_shared<Dll_Data_Source>();
|
||||
else if (t == "Shared_Memory_Data_Source") ret = std::make_shared<Shared_Memory_Data_Source>();
|
||||
else {
|
||||
std::cout << "未知�?Data_Source type类型!" << std::endl;
|
||||
throw std::invalid_argument("unknown Data_Source type: " + std::string(t));
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
struct Data_Source_Config {
|
||||
Ordered_Map<std::string, std::shared_ptr<Data_Source>> map;
|
||||
Data_Source_Config() = default;
|
||||
void init(const Psc::JSON *that_json) {
|
||||
auto list = that_json->get("list");
|
||||
for (auto& it : list->children) {
|
||||
auto ds = create_from_json(&it);
|
||||
map.push_back(ds);
|
||||
}
|
||||
}
|
||||
Psc::JSON list() {
|
||||
auto connect_json = Psc::JSON::array();
|
||||
for (auto& it : map.list()) {
|
||||
connect_json.children.emplace_back(it->to_json());
|
||||
}
|
||||
return connect_json;
|
||||
}
|
||||
Psc::JSON to_json() {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
ret.append({"list", list()});
|
||||
return ret;
|
||||
}
|
||||
void server(Global *g);
|
||||
Ordered_Map<std::string, std::shared_ptr<Data_Source>> map;
|
||||
Data_Source_Config() = default;
|
||||
void init(const Psc::JSON* that_json) {
|
||||
auto list = that_json->get("list");
|
||||
for (auto& it : list->children) {
|
||||
auto ds = create_from_json(&it);
|
||||
map.push_back(ds);
|
||||
}
|
||||
}
|
||||
Psc::JSON list() {
|
||||
auto connect_json = Psc::JSON::array();
|
||||
for (auto& it : map.list()) {
|
||||
connect_json.children.emplace_back(it->to_json());
|
||||
}
|
||||
return connect_json;
|
||||
}
|
||||
Psc::JSON to_json() {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
ret.append({"list", list()});
|
||||
return ret;
|
||||
}
|
||||
void server(Global* g);
|
||||
};
|
||||
|
||||
@@ -15,18 +15,14 @@
|
||||
#include <utility>
|
||||
#include <vector>
|
||||
#include <string_view>
|
||||
|
||||
class Global;
|
||||
|
||||
class Invalid_Http_Param final : public std::runtime_error {
|
||||
public:
|
||||
using std::runtime_error::runtime_error;
|
||||
using std::runtime_error::runtime_error;
|
||||
};
|
||||
|
||||
[[noreturn]] inline void throw_invalid_http_param(const char *detail) {
|
||||
throw Invalid_Http_Param(detail);
|
||||
[[noreturn]] inline void throw_invalid_http_param(const char* detail) {
|
||||
throw Invalid_Http_Param(detail);
|
||||
}
|
||||
|
||||
#define CHECK_JSON_PARAM \
|
||||
auto o_params = Psc::try_parse_json(req->body().data()); \
|
||||
if (!o_params.has_value()) { \
|
||||
@@ -34,356 +30,343 @@ public:
|
||||
} \
|
||||
auto ¶ms = o_params.value(); \
|
||||
auto that_json = ¶ms;
|
||||
|
||||
#define HTTP_REQUIRE_VALUE(NAME, EXPRESSION) \
|
||||
auto o_http_##NAME = (EXPRESSION); \
|
||||
if (!o_http_##NAME.has_value()) { \
|
||||
throw_invalid_http_param(#NAME); \
|
||||
} \
|
||||
auto NAME = std::move(o_http_##NAME).value();
|
||||
|
||||
#define HTTP_REQUIRE_PTR(NAME, EXPRESSION) \
|
||||
auto NAME = (EXPRESSION); \
|
||||
if ((NAME) == nullptr) { \
|
||||
throw_invalid_http_param(#NAME); \
|
||||
}
|
||||
|
||||
#define HTTP_REQUIRE_TRUE(EXPRESSION, DETAIL) \
|
||||
if (!(EXPRESSION)) { \
|
||||
throw_invalid_http_param(DETAIL); \
|
||||
}
|
||||
|
||||
template <typename Value_Type> class Ordered_List {
|
||||
template <typename Value_Type>
|
||||
class Ordered_List {
|
||||
public:
|
||||
void swap(size_t i, size_t j) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size() || j >= _list.size())
|
||||
return;
|
||||
|
||||
std::swap(_list[i], _list[j]);
|
||||
}
|
||||
|
||||
void push_back(Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.push_back(value); // 添加默认值
|
||||
}
|
||||
|
||||
void insert(int i, Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.insert(_list.begin() + i, value);
|
||||
}
|
||||
|
||||
Value_Type get(size_t i) { return _list[i]; }
|
||||
|
||||
void remove(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return;
|
||||
_list.erase(_list.begin() + i);
|
||||
}
|
||||
std::vector<Value_Type> list() {
|
||||
std::lock_guard g(mtx);
|
||||
return this->_list;
|
||||
}
|
||||
|
||||
void clear() { list().clear(); }
|
||||
|
||||
protected:
|
||||
std::mutex mtx;
|
||||
std::vector<Value_Type> _list;
|
||||
};
|
||||
|
||||
template <typename Key_Type, typename Value_Type> class Ordered_Map {
|
||||
public:
|
||||
std::optional<Value_Type> get(Key_Type key) {
|
||||
std::lock_guard g(mtx);
|
||||
auto it = _map.find(key);
|
||||
if (it != _map.end()) {
|
||||
return it->second;
|
||||
void swap(size_t i, size_t j) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size() || j >= _list.size())
|
||||
return;
|
||||
std::swap(_list[i], _list[j]);
|
||||
}
|
||||
void push_back(Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.push_back(value); // 添加默认值
|
||||
}
|
||||
void insert(int i, Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.insert(_list.begin() + i, value);
|
||||
}
|
||||
Value_Type get(size_t i) {
|
||||
return _list[i];
|
||||
}
|
||||
void remove(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return;
|
||||
_list.erase(_list.begin() + i);
|
||||
}
|
||||
std::vector<Value_Type> list() {
|
||||
std::lock_guard g(mtx);
|
||||
return this->_list;
|
||||
}
|
||||
void clear() {
|
||||
list().clear();
|
||||
}
|
||||
return std::nullopt;
|
||||
}
|
||||
bool swap(size_t i, size_t j) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size() || j >= _list.size())
|
||||
return false;
|
||||
|
||||
std::swap(_list[i], _list[j]);
|
||||
|
||||
// 更新 map 中的 value，假设你可以从 Value 中获取 key
|
||||
Key_Type key_i = _list[i]->key;
|
||||
Key_Type key_j = _list[j]->key;
|
||||
|
||||
_map[key_i] = _list[i];
|
||||
_map[key_j] = _list[j];
|
||||
return true;
|
||||
}
|
||||
|
||||
void push_back(Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.push_back(value); // 添加默认值
|
||||
_map[value->key] = value; // 插入到 map
|
||||
}
|
||||
|
||||
bool insert(int i, Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i < 0 || static_cast<size_t>(i) > _list.size())
|
||||
return false;
|
||||
_list.insert(_list.begin() + i, value);
|
||||
_map[value->key] = value;
|
||||
return true;
|
||||
}
|
||||
|
||||
Value_Type get(size_t i) { return _list[i]; }
|
||||
|
||||
std::optional<Value_Type> try_get(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return std::nullopt;
|
||||
return _list[i];
|
||||
}
|
||||
|
||||
bool remove(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return false;
|
||||
Key_Type &key = _list[i]->key;
|
||||
_map.erase(key);
|
||||
_list.erase(_list.begin() + i);
|
||||
return true;
|
||||
}
|
||||
std::vector<Value_Type> list() {
|
||||
std::lock_guard g(mtx);
|
||||
return this->_list;
|
||||
}
|
||||
// std::map<Key_Type, Value_Type> map(){
|
||||
// std::lock_guard g(mtx);
|
||||
// return this->_map;
|
||||
// }
|
||||
void clear() {
|
||||
list().clear();
|
||||
_map.clear();
|
||||
}
|
||||
|
||||
protected:
|
||||
std::mutex mtx;
|
||||
std::vector<Value_Type> _list;
|
||||
std::map<Key_Type, Value_Type> _map;
|
||||
std::mutex mtx;
|
||||
std::vector<Value_Type> _list;
|
||||
};
|
||||
template <typename Key_Type, typename Value_Type>
|
||||
class Ordered_Map {
|
||||
public:
|
||||
std::optional<Value_Type> get(Key_Type key) {
|
||||
std::lock_guard g(mtx);
|
||||
auto it = _map.find(key);
|
||||
if (it != _map.end()) {
|
||||
return it->second;
|
||||
}
|
||||
return std::nullopt;
|
||||
}
|
||||
bool swap(size_t i, size_t j) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size() || j >= _list.size())
|
||||
return false;
|
||||
std::swap(_list[i], _list[j]);
|
||||
// 更新 map 中的 value，假设你可以从 Value 中获取 key
|
||||
Key_Type key_i = _list[i]->key;
|
||||
Key_Type key_j = _list[j]->key;
|
||||
_map[key_i] = _list[i];
|
||||
_map[key_j] = _list[j];
|
||||
return true;
|
||||
}
|
||||
void push_back(Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
_list.push_back(value); // 添加默认值
|
||||
_map[value->key] = value; // 插入到 map
|
||||
}
|
||||
bool insert(int i, Value_Type value) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i < 0 || static_cast<size_t>(i) > _list.size())
|
||||
return false;
|
||||
_list.insert(_list.begin() + i, value);
|
||||
_map[value->key] = value;
|
||||
return true;
|
||||
}
|
||||
Value_Type get(size_t i) {
|
||||
return _list[i];
|
||||
}
|
||||
std::optional<Value_Type> try_get(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return std::nullopt;
|
||||
return _list[i];
|
||||
}
|
||||
bool remove(size_t i) {
|
||||
std::lock_guard g(mtx);
|
||||
if (i >= _list.size())
|
||||
return false;
|
||||
Key_Type& key = _list[i]->key;
|
||||
_map.erase(key);
|
||||
_list.erase(_list.begin() + i);
|
||||
return true;
|
||||
}
|
||||
std::vector<Value_Type> list() {
|
||||
std::lock_guard g(mtx);
|
||||
return this->_list;
|
||||
}
|
||||
// std::map<Key_Type, Value_Type> map(){
|
||||
// std::lock_guard g(mtx);
|
||||
// return this->_map;
|
||||
// }
|
||||
void clear() {
|
||||
list().clear();
|
||||
_map.clear();
|
||||
}
|
||||
protected:
|
||||
std::mutex mtx;
|
||||
std::vector<Value_Type> _list;
|
||||
std::map<Key_Type, Value_Type> _map;
|
||||
};
|
||||
|
||||
class Mode_AC_Statistic_Data {
|
||||
public:
|
||||
Psc::JSON to_json() {
|
||||
std::lock_guard g(mtx);
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
Ret_J(length_error_num);
|
||||
// Ret_J(speed);
|
||||
return ret;
|
||||
}
|
||||
void add() {
|
||||
std::lock_guard g(mtx);
|
||||
add_inter();
|
||||
// speed.update(1);
|
||||
}
|
||||
void add_length_error() {
|
||||
std::lock_guard g(mtx);
|
||||
add_inter();
|
||||
length_error_num++;
|
||||
}
|
||||
|
||||
protected:
|
||||
std::atomic<size_t> length_error_num{};
|
||||
void add_inter() {
|
||||
total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != utc) {
|
||||
utc = cur_time;
|
||||
pre_second_num = 0;
|
||||
Psc::JSON to_json() {
|
||||
std::lock_guard g(mtx);
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
Ret_J(length_error_num);
|
||||
// Ret_J(speed);
|
||||
return ret;
|
||||
}
|
||||
pre_second_num++;
|
||||
}
|
||||
std::mutex mtx;
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
time_t utc{};
|
||||
// Psc::Speed_Statistics speed;
|
||||
void add() {
|
||||
std::lock_guard g(mtx);
|
||||
add_inter();
|
||||
// speed.update(1);
|
||||
}
|
||||
void add_length_error() {
|
||||
std::lock_guard g(mtx);
|
||||
add_inter();
|
||||
length_error_num++;
|
||||
}
|
||||
protected:
|
||||
std::atomic<size_t> length_error_num{};
|
||||
void add_inter() {
|
||||
total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != utc) {
|
||||
utc = cur_time;
|
||||
pre_second_num = 0;
|
||||
}
|
||||
pre_second_num++;
|
||||
}
|
||||
std::mutex mtx;
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
time_t utc{};
|
||||
// Psc::Speed_Statistics speed;
|
||||
};
|
||||
|
||||
class Statistic_Data {
|
||||
public:
|
||||
time_t utc{};
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
[[nodiscard]] Psc::JSON to_json() const {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
return ret;
|
||||
}
|
||||
Statistic_Data() = default;
|
||||
time_t utc{};
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
[[nodiscard]] Psc::JSON to_json() const {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
return ret;
|
||||
}
|
||||
Statistic_Data() = default;
|
||||
};
|
||||
|
||||
class DF_Statistic_Data {
|
||||
public:
|
||||
time_t utc{};
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
size_t crc_error_num{};
|
||||
Psc::JSON to_json() {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
Ret_J(crc_error_num);
|
||||
// Ret_J(speed);
|
||||
|
||||
std::string t = "null";
|
||||
if (total_num != 0) {
|
||||
t = std::to_string(static_cast<double>(crc_error_num) /
|
||||
static_cast<double>(total_num)) +
|
||||
"%";
|
||||
time_t utc{};
|
||||
size_t pre_second_num{};
|
||||
size_t total_num{};
|
||||
size_t crc_error_num{};
|
||||
Psc::JSON to_json() {
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
Ret_J(pre_second_num);
|
||||
Ret_J(total_num);
|
||||
Ret_J(crc_error_num);
|
||||
// Ret_J(speed);
|
||||
std::string t = "null";
|
||||
if (total_num != 0) {
|
||||
t = std::to_string(static_cast<double>(crc_error_num) /
|
||||
static_cast<double>(total_num)) +
|
||||
"%";
|
||||
}
|
||||
ret.append({"crc误码率", t});
|
||||
for (auto& cur : statistic_map) {
|
||||
ret.append({cur.first, cur.second.to_json()});
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
ret.append({"crc误码率", t});
|
||||
for (auto &cur : statistic_map) {
|
||||
ret.append({cur.first, cur.second.to_json()});
|
||||
void add() {
|
||||
add_inter();
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
void add() { add_inter(); }
|
||||
void add_crc_error() { crc_error_num++; }
|
||||
void add_sub_part(std::string_view key) { add_sub_part_inter(key); }
|
||||
|
||||
// Psc::Speed_Statistics speed;
|
||||
void add_crc_error() {
|
||||
crc_error_num++;
|
||||
}
|
||||
void add_sub_part(std::string_view key) {
|
||||
add_sub_part_inter(key);
|
||||
}
|
||||
// Psc::Speed_Statistics speed;
|
||||
protected:
|
||||
void add_inter() {
|
||||
total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != utc) {
|
||||
utc = cur_time;
|
||||
pre_second_num = 0;
|
||||
void add_inter() {
|
||||
total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != utc) {
|
||||
utc = cur_time;
|
||||
pre_second_num = 0;
|
||||
}
|
||||
pre_second_num++;
|
||||
// speed.update(1);
|
||||
}
|
||||
pre_second_num++;
|
||||
// speed.update(1);
|
||||
}
|
||||
|
||||
void add_sub_part_inter(std::string_view key) {
|
||||
auto t = get_create_statistic_data(key);
|
||||
t->total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != t->utc) {
|
||||
t->utc = cur_time;
|
||||
t->pre_second_num = 0;
|
||||
void add_sub_part_inter(std::string_view key) {
|
||||
auto t = get_create_statistic_data(key);
|
||||
t->total_num++;
|
||||
auto cur_time = std::time(nullptr);
|
||||
if (cur_time != t->utc) {
|
||||
t->utc = cur_time;
|
||||
t->pre_second_num = 0;
|
||||
}
|
||||
t->pre_second_num++;
|
||||
}
|
||||
t->pre_second_num++;
|
||||
}
|
||||
Statistic_Data *get_create_statistic_data(std::string_view key) {
|
||||
Statistic_Data *t;
|
||||
auto key_string = std::string(key);
|
||||
auto iter = statistic_map.find(key_string);
|
||||
if (iter == statistic_map.end()) {
|
||||
Statistic_Data cur{};
|
||||
statistic_map.insert(std::make_pair(key_string, cur));
|
||||
Statistic_Data* get_create_statistic_data(std::string_view key) {
|
||||
Statistic_Data* t;
|
||||
auto key_string = std::string(key);
|
||||
auto iter = statistic_map.find(key_string);
|
||||
if (iter == statistic_map.end()) {
|
||||
Statistic_Data cur{};
|
||||
statistic_map.insert(std::make_pair(key_string, cur));
|
||||
}
|
||||
t = &statistic_map[key_string];
|
||||
return t;
|
||||
}
|
||||
t = &statistic_map[key_string];
|
||||
return t;
|
||||
}
|
||||
|
||||
std::map<std::string, Statistic_Data> statistic_map;
|
||||
std::map<std::string, Statistic_Data> statistic_map;
|
||||
};
|
||||
|
||||
class Mode_S_Statistic_Data {
|
||||
public:
|
||||
// Psc::Speed_Statistics speed;
|
||||
|
||||
// Psc::Speed_Statistics total_speed() const {
|
||||
// Psc::Speed_Statistics total_speed{};
|
||||
// for (auto& cur : DF_Statistic_Data_map) {
|
||||
// total_speed += cur.second.speed;
|
||||
// }
|
||||
// return total_speed;
|
||||
// }
|
||||
Psc::JSON to_json() {
|
||||
size_t total_num = get_total_num();
|
||||
size_t crc_error_num = get_crc_error_num();
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
|
||||
ret.append({"每秒数量", get_total_pre_second_num()});
|
||||
|
||||
Ret_J(length_error_num);
|
||||
Ret_J(total_num);
|
||||
|
||||
std::string t = "null";
|
||||
if (total_num != 0) {
|
||||
t = std::to_string(static_cast<double>(crc_error_num) /
|
||||
static_cast<double>(total_num)) +
|
||||
"%";
|
||||
// Psc::Speed_Statistics speed;
|
||||
// Psc::Speed_Statistics total_speed() const {
|
||||
// Psc::Speed_Statistics total_speed{};
|
||||
// for (auto& cur : DF_Statistic_Data_map) {
|
||||
// total_speed += cur.second.speed;
|
||||
// }
|
||||
// return total_speed;
|
||||
// }
|
||||
Psc::JSON to_json() {
|
||||
size_t total_num = get_total_num();
|
||||
size_t crc_error_num = get_crc_error_num();
|
||||
Psc::JSON ret = Psc::JSON::object();
|
||||
ret.append({"每秒数量", get_total_pre_second_num()});
|
||||
Ret_J(length_error_num);
|
||||
Ret_J(total_num);
|
||||
std::string t = "null";
|
||||
if (total_num != 0) {
|
||||
t = std::to_string(static_cast<double>(crc_error_num) /
|
||||
static_cast<double>(total_num)) +
|
||||
"%";
|
||||
}
|
||||
Ret_J(crc_error_num);
|
||||
ret.append({"crc_error_rate", t});
|
||||
Psc::JSON df_sub_type = Psc::JSON::object();
|
||||
for (auto& cur : DF_Statistic_Data_map) {
|
||||
df_sub_type.append({
|
||||
Psc::to_string(cur.first) + " [" +
|
||||
std::to_string(static_cast<int>(cur.first)) + "]",
|
||||
cur.second.to_json()
|
||||
});
|
||||
}
|
||||
Psc::JSON cpr_error_o = Psc::JSON::object();
|
||||
for (auto& cur : cpr_error) {
|
||||
auto num = cur.second;
|
||||
std::string rate_str = std::format("{:.2f}%", static_cast<double>(num) / base * 100.0);
|
||||
auto& type = cur.first;
|
||||
auto key = Psc::to_string(type);
|
||||
auto val = Psc::to_string(static_cast<size_t>(cur.second)) + " " + rate_str;
|
||||
cpr_error_o.append({key, val});
|
||||
}
|
||||
ret.append({"DF子类型", df_sub_type});
|
||||
ret.append({"CPR统计信息", cpr_error_o});
|
||||
return ret;
|
||||
}
|
||||
Ret_J(crc_error_num);
|
||||
ret.append({"crc_error_rate", t});
|
||||
|
||||
Psc::JSON df_sub_type = Psc::JSON::object();
|
||||
for (auto &cur : DF_Statistic_Data_map) {
|
||||
df_sub_type.append({Psc::to_string(cur.first) + " [" +
|
||||
std::to_string(static_cast<int>(cur.first)) + "]",
|
||||
cur.second.to_json()});
|
||||
void add_length_error(std::string_view key) {
|
||||
length_error_num++;
|
||||
}
|
||||
Psc::JSON cpr_error_o = Psc::JSON::object();
|
||||
for (auto &cur : cpr_error) {
|
||||
cpr_error_o.append({Psc::to_string(cur.first) + " [" +
|
||||
std::to_string(static_cast<int>(cur.first)) + "]",
|
||||
Psc::to_string(cur.second)});
|
||||
void add_cpr_error(SSR::CPR_Error_Type cet) {
|
||||
if (cet == SSR::CPR_Error_Type::Normal) {
|
||||
base++;
|
||||
}
|
||||
else {
|
||||
++cpr_error[cet];
|
||||
}
|
||||
}
|
||||
ret.append({"DF子类型", df_sub_type});
|
||||
ret.append({"CPR统计信息", cpr_error_o});
|
||||
return ret;
|
||||
}
|
||||
|
||||
void add_length_error(std::string_view key) { length_error_num++; }
|
||||
|
||||
void add_cpr_error(SSR::CPR_Error_Type cet) { ++cpr_error[cet]; }
|
||||
|
||||
DF_Statistic_Data *
|
||||
get_create_df_statistic_data(const SSR::Downlink_Format &key) {
|
||||
DF_Statistic_Data *t;
|
||||
auto iter = DF_Statistic_Data_map.find(key);
|
||||
if (iter == DF_Statistic_Data_map.end()) {
|
||||
DF_Statistic_Data cur{};
|
||||
DF_Statistic_Data_map.insert(std::make_pair(key, cur));
|
||||
DF_Statistic_Data*
|
||||
get_create_df_statistic_data(const SSR::Downlink_Format& key) {
|
||||
DF_Statistic_Data* t;
|
||||
auto iter = DF_Statistic_Data_map.find(key);
|
||||
if (iter == DF_Statistic_Data_map.end()) {
|
||||
DF_Statistic_Data cur{};
|
||||
DF_Statistic_Data_map.insert(std::make_pair(key, cur));
|
||||
}
|
||||
t = &DF_Statistic_Data_map[key];
|
||||
return t;
|
||||
}
|
||||
t = &DF_Statistic_Data_map[key];
|
||||
return t;
|
||||
}
|
||||
|
||||
size_t get_total_pre_second_num() {
|
||||
size_t ret = 0;
|
||||
for (auto &cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.pre_second_num;
|
||||
size_t get_total_pre_second_num() {
|
||||
size_t ret = 0;
|
||||
for (auto& cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.pre_second_num;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
size_t get_total_num() {
|
||||
size_t ret = 0;
|
||||
for (auto &cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.total_num;
|
||||
size_t get_total_num() {
|
||||
size_t ret = 0;
|
||||
for (auto& cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.total_num;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
size_t get_crc_error_num() {
|
||||
size_t ret = 0;
|
||||
for (auto &cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.crc_error_num;
|
||||
size_t get_crc_error_num() {
|
||||
size_t ret = 0;
|
||||
for (auto& cur : DF_Statistic_Data_map) {
|
||||
ret += cur.second.crc_error_num;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
protected:
|
||||
std::atomic<size_t> length_error_num{};
|
||||
std::map<SSR::Downlink_Format, DF_Statistic_Data> DF_Statistic_Data_map;
|
||||
std::map<SSR::CPR_Error_Type, size_t> cpr_error;
|
||||
std::atomic<size_t> length_error_num{};
|
||||
std::map<SSR::Downlink_Format, DF_Statistic_Data> DF_Statistic_Data_map;
|
||||
std::map<SSR::CPR_Error_Type, double> cpr_error;
|
||||
double base = 0;
|
||||
};
|
||||
|
||||
template <typename T> class Immutable : public T {};
|
||||
|
||||
template <typename T>
|
||||
class Immutable : public T {};
|
||||
#endif
|
||||
|
||||
@@ -102,9 +102,7 @@ Global::Global() {
|
||||
SSR::P_S msg) {
|
||||
auto src = std::dynamic_pointer_cast<Data_Source>(msg->source);
|
||||
Mode_S_Statistic_Data* ss = &src->mode_s_statistic;
|
||||
if (t != SSR::CPR_Error_Type::Normal) {
|
||||
ss->add_cpr_error(t);
|
||||
}
|
||||
ss->add_cpr_error(t);
|
||||
SSR::mode_s_logger->debug("CPR/" + to_string(t), {}, log);
|
||||
};
|
||||
// 处理错误
|
||||
|
||||
Reference in New Issue
Block a user