timeseriesrunlayer.h

Go to the documentation of this file.

 
#pragma once
#include "plot/irunlayer.h"
#include "timeseries/timeseriesdataset.h"
#include <QObject>
#include <QHash>
#include <QTimer>
#include <deque>
#include <memory>
#include <thread>
 
namespace openswmmvis::plot
{
class TimeSeriesRunLayer final : public QObject, public IRunLayer
{
    Q_OBJECT
public:
    explicit TimeSeriesRunLayer(std::shared_ptr<const OpenSWMM::TimeSeries::TimeSeriesDataset> dataset);
    ~TimeSeriesRunLayer() override;
    QString scenarioName() const override;
    UnitSystem unitSystem() const override { return UnitSystem::SI; }
    double startDateJulian() const override;
    int periodCount() const override;
    int reportStepSeconds() const override { return 0; }
    QString persistenceKey() const override;
    bool supportsAttribute(PlotAttribute) const override { return false; }
    void getSeriesAt(const ObjectRef &, PlotAttribute, SeriesData &out) const override;
    void getSeriesAt(const ObjectRef &ref, const ResultDescriptor &descriptor, SeriesData &out) const override;
    void requestWindow(const QStringList &ids, QDateTime from = {}, QDateTime to = {});
    void setModelClockOffset(int seconds);
    bool hasModelClockMapping() const { return m_modelClockOffset.has_value(); }
    ResultDescriptor descriptorFor(const QString &id) const;
    const OpenSWMM::TimeSeries::SeriesInfo *series(const QString &id) const;
    auto dataset() const { return m_dataset; }
    static SeriesData readWindow(const OpenSWMM::TimeSeries::TimeSeriesDataset &dataset,
                                 const QString &id, QDateTime from, QDateTime to,
                                 std::atomic_bool *cancel = nullptr);
    static bool exportCsv(const QVector<QPair<std::shared_ptr<const OpenSWMM::TimeSeries::TimeSeriesDataset>, QString>> &sources,
                          const QString &path, QString *error, std::atomic_bool *cancel = nullptr);
signals:
    void dataReady();
private:
    struct Work; 
    struct Request {
        QString id; 
        QDateTime from; 
        QDateTime to; 
        int clockOffset = 0; 
    };
    void startNext();
    void poll();
    std::shared_ptr<const OpenSWMM::TimeSeries::TimeSeriesDataset> m_dataset; 
    QHash<QString, SeriesData> m_cache; 
    std::optional<int> m_modelClockOffset; 
    QHash<QString, QPair<QDateTime, QDateTime>> m_ranges; 
    std::deque<Request> m_pending; 
    std::shared_ptr<Work> m_work; 
    std::thread m_thread; 
    QTimer m_timer; 
};
}