mirror of
https://github.com/ciphervance/supercell-wx.git
synced 2025-10-31 23:20:05 +00:00
323 lines
10 KiB
C++
323 lines
10 KiB
C++
#include <scwx/qt/model/alert_model.hpp>
|
|
#include <scwx/qt/manager/text_event_manager.hpp>
|
|
#include <scwx/qt/types/qt_types.hpp>
|
|
#include <scwx/common/geographic.hpp>
|
|
#include <scwx/util/logger.hpp>
|
|
#include <scwx/util/strings.hpp>
|
|
#include <scwx/util/time.hpp>
|
|
|
|
#include <format>
|
|
|
|
#include <GeographicLib/Geodesic.hpp>
|
|
|
|
namespace scwx
|
|
{
|
|
namespace qt
|
|
{
|
|
namespace model
|
|
{
|
|
|
|
static const std::string logPrefix_ = "scwx::qt::model::alert_model";
|
|
static const auto logger_ = scwx::util::Logger::Create(logPrefix_);
|
|
|
|
static constexpr size_t kColumnEtn = 0u;
|
|
static constexpr size_t kColumnOfficeId = 1u;
|
|
static constexpr size_t kColumnPhenomenon = 2u;
|
|
static constexpr size_t kColumnSignificance = 3u;
|
|
static constexpr size_t kColumnState = 4u;
|
|
static constexpr size_t kColumnCounties = 5u;
|
|
static constexpr size_t kColumnStartTime = 6u;
|
|
static constexpr size_t kColumnEndTime = 7u;
|
|
static constexpr size_t kColumnDistance = 8u;
|
|
static constexpr size_t kFirstColumn = kColumnEtn;
|
|
static constexpr size_t kLastColumn = kColumnDistance;
|
|
static constexpr size_t kNumColumns = 9u;
|
|
|
|
class AlertModelImpl
|
|
{
|
|
public:
|
|
explicit AlertModelImpl();
|
|
~AlertModelImpl() = default;
|
|
|
|
static std::string GetCounties(const types::TextEventKey& key);
|
|
static std::string GetState(const types::TextEventKey& key);
|
|
static std::string GetStartTime(const types::TextEventKey& key);
|
|
static std::string GetEndTime(const types::TextEventKey& key);
|
|
|
|
QList<types::TextEventKey> textEventKeys_;
|
|
|
|
GeographicLib::Geodesic geodesic_;
|
|
|
|
std::unordered_map<types::TextEventKey,
|
|
common::Coordinate,
|
|
types::TextEventHash<types::TextEventKey>>
|
|
centroidMap_;
|
|
std::unordered_map<types::TextEventKey,
|
|
double,
|
|
types::TextEventHash<types::TextEventKey>>
|
|
distanceMap_;
|
|
scwx::common::DistanceType distanceDisplay_;
|
|
scwx::common::Coordinate previousPosition_;
|
|
};
|
|
|
|
AlertModel::AlertModel(QObject* parent) :
|
|
QAbstractTableModel(parent), p(std::make_unique<AlertModelImpl>())
|
|
{
|
|
}
|
|
AlertModel::~AlertModel() = default;
|
|
|
|
types::TextEventKey AlertModel::key(const QModelIndex& index) const
|
|
{
|
|
return index.isValid() ? p->textEventKeys_[index.row()] :
|
|
types::TextEventKey {};
|
|
}
|
|
|
|
common::Coordinate AlertModel::centroid(const types::TextEventKey& key) const
|
|
{
|
|
common::Coordinate centroid {};
|
|
|
|
const auto& it = p->centroidMap_.find(key);
|
|
if (it != p->centroidMap_.cend())
|
|
{
|
|
centroid = it->second;
|
|
}
|
|
|
|
return centroid;
|
|
}
|
|
|
|
int AlertModel::rowCount(const QModelIndex& parent) const
|
|
{
|
|
return parent.isValid() ? 0 : p->textEventKeys_.size();
|
|
}
|
|
|
|
int AlertModel::columnCount(const QModelIndex& parent) const
|
|
{
|
|
return parent.isValid() ? 0 : static_cast<int>(kNumColumns);
|
|
}
|
|
|
|
QVariant AlertModel::data(const QModelIndex& index, int role) const
|
|
{
|
|
if (index.isValid() && index.row() >= 0 &&
|
|
index.row() < p->textEventKeys_.size() &&
|
|
(role == Qt::DisplayRole || role == types::SortRole))
|
|
{
|
|
const auto& textEventKey = p->textEventKeys_.at(index.row());
|
|
|
|
switch (index.column())
|
|
{
|
|
case kColumnEtn:
|
|
return textEventKey.etn_;
|
|
case kColumnOfficeId:
|
|
return QString::fromStdString(textEventKey.officeId_);
|
|
case kColumnPhenomenon:
|
|
return QString::fromStdString(
|
|
awips::GetPhenomenonText(textEventKey.phenomenon_));
|
|
case kColumnSignificance:
|
|
return QString::fromStdString(
|
|
awips::GetSignificanceText(textEventKey.significance_));
|
|
case kColumnState:
|
|
return QString::fromStdString(AlertModelImpl::GetState(textEventKey));
|
|
case kColumnCounties:
|
|
return QString::fromStdString(
|
|
AlertModelImpl::GetCounties(textEventKey));
|
|
case kColumnStartTime:
|
|
return QString::fromStdString(
|
|
AlertModelImpl::GetStartTime(textEventKey));
|
|
case kColumnEndTime:
|
|
return QString::fromStdString(
|
|
AlertModelImpl::GetEndTime(textEventKey));
|
|
case kColumnDistance:
|
|
if (role == Qt::DisplayRole)
|
|
{
|
|
if (p->distanceDisplay_ == scwx::common::DistanceType::Miles)
|
|
{
|
|
return QString("%1 mi").arg(
|
|
static_cast<uint32_t>(p->distanceMap_.at(textEventKey) *
|
|
scwx::common::kMilesPerMeter));
|
|
}
|
|
else
|
|
{
|
|
return QString("%1 km").arg(
|
|
static_cast<uint32_t>(p->distanceMap_.at(textEventKey) *
|
|
scwx::common::kKilometersPerMeter));
|
|
}
|
|
}
|
|
else
|
|
{
|
|
return p->distanceMap_.at(textEventKey);
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
return QVariant();
|
|
}
|
|
|
|
QVariant
|
|
AlertModel::headerData(int section, Qt::Orientation orientation, int role) const
|
|
{
|
|
if (role == Qt::DisplayRole)
|
|
{
|
|
if (orientation == Qt::Horizontal)
|
|
{
|
|
switch (section)
|
|
{
|
|
case kColumnEtn:
|
|
return tr("ETN");
|
|
case kColumnOfficeId:
|
|
return tr("Office ID");
|
|
case kColumnPhenomenon:
|
|
return tr("Phenomenon");
|
|
case kColumnSignificance:
|
|
return tr("Significance");
|
|
case kColumnState:
|
|
return tr("State");
|
|
case kColumnCounties:
|
|
return tr("Counties");
|
|
case kColumnStartTime:
|
|
return tr("Start Time");
|
|
case kColumnEndTime:
|
|
return tr("End Time");
|
|
case kColumnDistance:
|
|
return tr("Distance");
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
return QVariant();
|
|
}
|
|
|
|
void AlertModel::HandleAlert(const types::TextEventKey& alertKey,
|
|
size_t messageIndex)
|
|
{
|
|
logger_->trace("Handle alert: {}", alertKey.ToString());
|
|
|
|
double distanceInMeters;
|
|
|
|
// Get the most recent segment for the event
|
|
auto alertMessages =
|
|
manager::TextEventManager::Instance().message_list(alertKey);
|
|
std::shared_ptr<const awips::Segment> alertSegment =
|
|
alertMessages[messageIndex]->segments().back();
|
|
|
|
if (alertSegment->codedLocation_.has_value())
|
|
{
|
|
// Update centroid and distance
|
|
common::Coordinate centroid =
|
|
common::GetCentroid(alertSegment->codedLocation_->coordinates());
|
|
|
|
p->geodesic_.Inverse(p->previousPosition_.latitude_,
|
|
p->previousPosition_.longitude_,
|
|
centroid.latitude_,
|
|
centroid.longitude_,
|
|
distanceInMeters);
|
|
|
|
p->centroidMap_.insert_or_assign(alertKey, centroid);
|
|
p->distanceMap_.insert_or_assign(alertKey, distanceInMeters);
|
|
}
|
|
else if (!p->centroidMap_.contains(alertKey))
|
|
{
|
|
// The alert has no location, so provide a default
|
|
p->centroidMap_.insert_or_assign(alertKey, common::Coordinate {0.0, 0.0});
|
|
p->distanceMap_.insert_or_assign(alertKey, 0.0);
|
|
}
|
|
|
|
// Update row
|
|
if (!p->textEventKeys_.contains(alertKey))
|
|
{
|
|
beginInsertRows(QModelIndex(), 0, 0);
|
|
p->textEventKeys_.push_back(alertKey);
|
|
endInsertRows();
|
|
}
|
|
else
|
|
{
|
|
const int row = p->textEventKeys_.indexOf(alertKey);
|
|
QModelIndex topLeft = createIndex(row, kFirstColumn);
|
|
QModelIndex bottomRight = createIndex(row, kLastColumn);
|
|
|
|
emit dataChanged(topLeft, bottomRight);
|
|
}
|
|
}
|
|
|
|
void AlertModel::HandleMapUpdate(double latitude, double longitude)
|
|
{
|
|
logger_->trace("Handle map update: {}, {}", latitude, longitude);
|
|
|
|
double distanceInMeters;
|
|
|
|
for (const auto& textEvent : p->textEventKeys_)
|
|
{
|
|
auto& centroid = p->centroidMap_.at(textEvent);
|
|
|
|
if (centroid != common::Coordinate {0.0, 0.0})
|
|
{
|
|
p->geodesic_.Inverse(latitude,
|
|
longitude,
|
|
centroid.latitude_,
|
|
centroid.longitude_,
|
|
distanceInMeters);
|
|
p->distanceMap_.insert_or_assign(textEvent, distanceInMeters);
|
|
}
|
|
}
|
|
|
|
p->previousPosition_ = {latitude, longitude};
|
|
|
|
QModelIndex topLeft = createIndex(0, kColumnDistance);
|
|
QModelIndex bottomRight = createIndex(rowCount() - 1, kColumnDistance);
|
|
|
|
emit dataChanged(topLeft, bottomRight);
|
|
}
|
|
|
|
AlertModelImpl::AlertModelImpl() :
|
|
textEventKeys_ {},
|
|
geodesic_(GeographicLib::Constants::WGS84_a(),
|
|
GeographicLib::Constants::WGS84_f()),
|
|
distanceMap_ {},
|
|
distanceDisplay_ {scwx::common::DistanceType::Miles},
|
|
previousPosition_ {}
|
|
{
|
|
}
|
|
|
|
std::string AlertModelImpl::GetCounties(const types::TextEventKey& key)
|
|
{
|
|
auto messageList = manager::TextEventManager::Instance().message_list(key);
|
|
auto& lastMessage = messageList.back();
|
|
size_t segmentCount = lastMessage->segment_count();
|
|
auto lastSegment = lastMessage->segment(segmentCount - 1);
|
|
return util::ToString(lastSegment->header_->ugc_.fips_ids());
|
|
}
|
|
|
|
std::string AlertModelImpl::GetState(const types::TextEventKey& key)
|
|
{
|
|
auto messageList = manager::TextEventManager::Instance().message_list(key);
|
|
auto& lastMessage = messageList.back();
|
|
size_t segmentCount = lastMessage->segment_count();
|
|
auto lastSegment = lastMessage->segment(segmentCount - 1);
|
|
return util::ToString(lastSegment->header_->ugc_.states());
|
|
}
|
|
|
|
std::string AlertModelImpl::GetStartTime(const types::TextEventKey& key)
|
|
{
|
|
auto messageList = manager::TextEventManager::Instance().message_list(key);
|
|
auto& firstMessage = messageList.front();
|
|
auto firstSegment = firstMessage->segment(0);
|
|
return util::TimeString(
|
|
firstSegment->header_->vtecString_[0].pVtec_.event_begin());
|
|
}
|
|
|
|
std::string AlertModelImpl::GetEndTime(const types::TextEventKey& key)
|
|
{
|
|
auto messageList = manager::TextEventManager::Instance().message_list(key);
|
|
auto& lastMessage = messageList.back();
|
|
size_t segmentCount = lastMessage->segment_count();
|
|
auto lastSegment = lastMessage->segment(segmentCount - 1);
|
|
return util::TimeString(
|
|
lastSegment->header_->vtecString_[0].pVtec_.event_end());
|
|
}
|
|
|
|
} // namespace model
|
|
} // namespace qt
|
|
} // namespace scwx
|