|
|
#include <QThreadPool>
|
|
|
#include <QRunnable>
|
|
|
#include <QObject>
|
|
|
#include <QReadWriteLock>
|
|
|
|
|
|
#include "Variable/VariableSynchronizationGroup2.h"
|
|
|
#include <Variable/Variable.h>
|
|
|
#include <Common/containers.h>
|
|
|
#include <Common/debug.h>
|
|
|
#include <Data/DataProviderParameters.h>
|
|
|
#include <Data/DateTimeRangeHelper.h>
|
|
|
#include <Data/DateTimeRange.h>
|
|
|
#include <Data/IDataProvider.h>
|
|
|
|
|
|
struct VCTransaction
|
|
|
{
|
|
|
VCTransaction(QUuid refVar, DateTimeRange range, int ready)
|
|
|
:refVar{refVar},range{range},ready{ready}
|
|
|
{}
|
|
|
QUuid refVar;
|
|
|
DateTimeRange range;
|
|
|
int ready;
|
|
|
QReadWriteLock lock;
|
|
|
};
|
|
|
|
|
|
class TransactionExe:public QObject,public QRunnable
|
|
|
{
|
|
|
Q_OBJECT
|
|
|
std::shared_ptr<Variable> _variable;
|
|
|
std::shared_ptr<IDataProvider> _provider;
|
|
|
std::vector<DateTimeRange> _ranges;
|
|
|
DateTimeRange _range;
|
|
|
DateTimeRange _cacheRange;
|
|
|
public:
|
|
|
TransactionExe(const std::shared_ptr<Variable>& variable, const std::shared_ptr<IDataProvider>& provider,
|
|
|
const std::vector<DateTimeRange>& ranges, DateTimeRange range, DateTimeRange cacheRange)
|
|
|
:_variable{variable}, _provider{provider},_ranges{ranges},_range{range},_cacheRange{cacheRange}
|
|
|
{
|
|
|
setAutoDelete(true);
|
|
|
}
|
|
|
void run()override
|
|
|
{
|
|
|
std::vector<IDataSeries*> data;
|
|
|
for(auto range:_ranges)
|
|
|
{
|
|
|
data.push_back(_provider->getData(DataProviderParameters{{range}, _variable->metadata()}));
|
|
|
}
|
|
|
_variable->updateData(data, _range, _cacheRange, true);
|
|
|
emit transactionComplete();
|
|
|
}
|
|
|
signals:
|
|
|
void transactionComplete();
|
|
|
};
|
|
|
|
