refs #452, adjusted matcher to new classes / considering removed classes

This commit is contained in:
Klaus Basan
2015-09-23 16:18:14 +02:00
committed by Mathew Sutcliffe
parent e6eac2333d
commit fce5fd4515
2 changed files with 37 additions and 76 deletions

View File

@@ -57,12 +57,12 @@ namespace BlackMisc
void CAircraftMatcher::setMatchingModes(MatchingMode matchingModes) void CAircraftMatcher::setMatchingModes(MatchingMode matchingModes)
{ {
m_matchingMode = matchingModes; m_matchingMode = matchingModes;
if (m_matchingMode.testFlag(ModelMapping) && m_modelMappings.isEmpty()) initMappings(); if (m_matchingMode.testFlag(ModelMapping) && m_modelsDatastore.isEmpty()) initMappings();
} }
CAircraftModel CAircraftMatcher::getClosestMatch(const CSimulatedAircraft &remoteAircraft) CAircraftModel CAircraftMatcher::getClosestMatch(const CSimulatedAircraft &remoteAircraft)
{ {
CAircraftModel aircraftModel(remoteAircraft); // set defaults CAircraftModel aircraftModel(remoteAircraft.getModel()); // set defaults
// Manually set string? // Manually set string?
if (remoteAircraft.getModel().hasManuallySetString()) if (remoteAircraft.getModel().hasManuallySetString())
@@ -70,7 +70,6 @@ namespace BlackMisc
// manual set model, maybe update missing parts // manual set model, maybe update missing parts
aircraftModel.updateMissingParts(remoteAircraft.getModel()); aircraftModel.updateMissingParts(remoteAircraft.getModel());
aircraftModel.setCallsign(remoteAircraft.getCallsign()); aircraftModel.setCallsign(remoteAircraft.getCallsign());
reverseLookupIcaoData(aircraftModel);
return aircraftModel; return aircraftModel;
} }
@@ -84,7 +83,10 @@ namespace BlackMisc
return aircraftModel; return aircraftModel;
} }
aircraftModel = matchByExactModelName(remoteAircraft); if (remoteAircraft.getModel().hasModelString())
{
aircraftModel = matchByExactModelName(remoteAircraft);
}
if (!aircraftModel.hasModelString()) if (!aircraftModel.hasModelString())
{ {
@@ -100,23 +102,14 @@ namespace BlackMisc
{ {
aircraftModel = getDefaultModel(); aircraftModel = getDefaultModel();
} }
aircraftModel.setCallsign(remoteAircraft.getCallsign());
Q_ASSERT(!aircraftModel.getCallsign().isEmpty()); Q_ASSERT_X(!aircraftModel.getCallsign().isEmpty(), Q_FUNC_INFO, "Missing callsign");
Q_ASSERT(aircraftModel.hasModelString()); Q_ASSERT_X(aircraftModel.hasModelString(), Q_FUNC_INFO, "Missing model string");
Q_ASSERT(aircraftModel.getModelType() != CAircraftModel::TypeUnknown); Q_ASSERT_X(aircraftModel.getModelType() != CAircraftModel::TypeUnknown, Q_FUNC_INFO, "Missing model type");
return aircraftModel; return aircraftModel;
} }
CAircraftIcaoData CAircraftMatcher::getIcaoForModelString(const QString &modelString) const
{
if (modelString.isEmpty() || !isInitialized()) { return CAircraftIcaoData(); }
CAircraftMappingList mappings = m_mappingsProvider->getMappingList().findByModelString(modelString);
if (mappings.isEmpty()) { return CAircraftIcaoData(); }
return mappings.front().getIcao();
}
int CAircraftMatcher::synchronize() int CAircraftMatcher::synchronize()
{ {
return synchronizeWithExistingModels(m_installedModels.getSortedModelStrings()); return synchronizeWithExistingModels(m_installedModels.getSortedModelStrings());
@@ -138,9 +131,9 @@ namespace BlackMisc
m_defaultModel = defaultModel; m_defaultModel = defaultModel;
} }
void CAircraftMatcher::ps_setModelMappingRules(const CAircraftMappingList &mappings) void CAircraftMatcher::ps_setDatastoreModels(const CAircraftModelList &mappings)
{ {
m_modelMappings = mappings; m_modelsDatastore = mappings;
} }
void CAircraftMatcher::initImpl() void CAircraftMatcher::initImpl()
@@ -151,10 +144,10 @@ namespace BlackMisc
// sync // sync
this->synchronize(); this->synchronize();
CLogMessage(this).debug() << "Mapping definitions after sync" << m_modelMappings.size(); CLogMessage(this).debug() << "Mapping definitions after sync" << m_modelsDatastore.size();
// finish // finish
CLogMessage(this).info("Mapping system: %1 definitions for %2 installed models") << m_modelMappings.size() CLogMessage(this).info("Mapping system: %1 definitions for %2 installed models") << m_modelsDatastore.size()
<< m_installedModels.size(); << m_installedModels.size();
m_initState = InitFinished; m_initState = InitFinished;
emit initializationFinished(); emit initializationFinished();
@@ -163,12 +156,12 @@ namespace BlackMisc
void CAircraftMatcher::initMappings() void CAircraftMatcher::initMappings()
{ {
Q_ASSERT(m_mappingsProvider); Q_ASSERT(m_mappingsProvider);
int mappingsSize = m_mappingsProvider->getMappingList().size(); int mappingsSize = m_mappingsProvider->getDatastoreModels().size();
if (mappingsSize < 1) if (mappingsSize < 1)
{ {
m_mappingsProvider->read(); m_mappingsProvider->read();
m_modelMappings = m_mappingsProvider->getMappingList(); m_modelsDatastore = m_mappingsProvider->getDatastoreModels();
mappingsSize = m_modelMappings.size(); mappingsSize = m_modelsDatastore.size();
if (mappingsSize < 1) if (mappingsSize < 1)
{ {
CLogMessage(this).error("Reading mapping rules failed or empty!"); CLogMessage(this).error("Reading mapping rules failed or empty!");
@@ -177,43 +170,28 @@ namespace BlackMisc
return; return;
} }
} }
m_modelMappings = m_mappingsProvider->getMappingList(); m_modelsDatastore = m_mappingsProvider->getDatastoreModels();
CLogMessage(this).debug() << "Mapping definitions" << mappingsSize; CLogMessage(this).debug() << "Mapping definitions" << mappingsSize;
} }
CAircraftModel CAircraftMatcher::matchByExactModelName(const CSimulatedAircraft &remoteAircraft) CAircraftModel CAircraftMatcher::matchByExactModelName(const CSimulatedAircraft &remoteAircraft)
{ {
CAircraftModel aircraftModel(remoteAircraft); return this->m_installedModels.findFirstByModelString(remoteAircraft.getModelString());
// Model by queried string
const CClient remoteClient = remoteAircraft.getClient();
if (remoteClient.getAircraftModel().hasQueriedModelString())
{
QString directModelString = remoteClient.getAircraftModel().getModelString();
if (!directModelString.isEmpty() && m_installedModels.containsModelString(directModelString))
{
aircraftModel = m_installedModels.findFirstByModelString(directModelString);
aircraftModel.setModelType(CAircraftModel::TypeQueriedFromNetwork);
}
}
return aircraftModel;
} }
CAircraftModel CAircraftMatcher::matchByMapping(const CSimulatedAircraft &remoteAircraft) CAircraftModel CAircraftMatcher::matchByMapping(const CSimulatedAircraft &remoteAircraft)
{ {
CAircraftModel aircraftModel; CAircraftModel aircraftModel;
CAircraftIcaoData icao = remoteAircraft.getIcaoInfo(); BlackMisc::Simulation::CAircraftModelList datastoreModels = m_modelsDatastore.findByIcaoDesignators(remoteAircraft.getAircraftIcaoCode(), remoteAircraft.getAirlineIcaoCode());
BlackMisc::Network::CAircraftMappingList mappingList = m_modelMappings.findByIcaoAircraftAndAirlineDesignator(icao, true); if (!datastoreModels.isEmpty())
if (!mappingList.isEmpty())
{ {
CAircraftModel modelFromMappings = mappingList.front().getModel(); CAircraftModel modelFromMappings = datastoreModels.front();
// now turn the model from the mapping rules into a model from the simulator which has more metadata // now turn the model from the mapping rules into a model from the simulator which has more metadata
aircraftModel = m_installedModels.findFirstByModelString(modelFromMappings.getModelString()); aircraftModel = m_installedModels.findFirstByModelString(modelFromMappings.getModelString());
Q_ASSERT(aircraftModel.getModelString() == modelFromMappings.getModelString()); Q_ASSERT(aircraftModel.getModelString() == modelFromMappings.getModelString());
aircraftModel.updateMissingParts(modelFromMappings); // update ICAO aircraftModel.updateMissingParts(modelFromMappings); // update ICAO
aircraftModel.setModelType(CAircraftModel::TypeModelMatching); aircraftModel.setModelType(CAircraftModel::TypeModelMatching);
} }
return aircraftModel; return aircraftModel;
} }
@@ -225,32 +203,20 @@ namespace BlackMisc
int CAircraftMatcher::synchronizeWithExistingModels(const QStringList &modelNames, Qt::CaseSensitivity cs) int CAircraftMatcher::synchronizeWithExistingModels(const QStringList &modelNames, Qt::CaseSensitivity cs)
{ {
if (modelNames.isEmpty() || m_modelMappings.isEmpty()) { return 0; } if (modelNames.isEmpty() || m_modelsDatastore.isEmpty()) { return 0; }
CAircraftMappingList newList; CAircraftModelList newList;
for (const CAircraftMapping &mapping : m_modelMappings) for (const CAircraftModel &modelDatastore : m_modelsDatastore)
{ {
if (this->m_initState != InitInProgress) { return 0; } // canceled if (this->m_initState != InitInProgress) { return 0; } // canceled
QString modelString = mapping.getModel().getModelString(); QString modelString(modelDatastore.getModelString());
if (modelString.isEmpty()) { continue; } if (modelString.isEmpty()) { continue; }
if (modelNames.contains(modelString, cs)) if (modelNames.contains(modelString, cs))
{ {
newList.push_back(mapping); newList.push_back(modelDatastore);
} }
} }
this->m_modelMappings = newList; this->m_modelsDatastore = newList;
return this->m_modelMappings.size(); return this->m_modelsDatastore.size();
} }
void CAircraftMatcher::reverseLookupIcaoData(CAircraftModel &model)
{
if (isInitialized())
{
// reverse lookup of ICAO
CAircraftIcaoData icao = getIcaoForModelString(model.getModelString());
icao.updateMissingParts(icao);
model.setIcao(icao);
}
}
} }
} // namespace } // namespace

View File

@@ -18,7 +18,8 @@
#include "blackmisc/simulation/aircraftmodellist.h" #include "blackmisc/simulation/aircraftmodellist.h"
#include "blackmisc/worker.h" #include "blackmisc/worker.h"
#include <QObject> #include <QObject>
#include <QScopedPointer> #include <QPointer>
#include <QThread>
#include <memory> #include <memory>
#include <atomic> #include <atomic>
@@ -44,8 +45,8 @@ namespace BlackMisc
//! Enabled matching mode flags //! Enabled matching mode flags
enum MatchingModeFlag enum MatchingModeFlag
{ {
ExactMatch = 1 << 0, ExactMatch = 1 << 0,
ModelMapping = 1 << 1, ModelMapping = 1 << 1,
ModelMatching = 1 << 2, ModelMatching = 1 << 2,
AllModes = ExactMatch | ModelMapping | ModelMatching AllModes = ExactMatch | ModelMapping | ModelMatching
}; };
@@ -84,13 +85,10 @@ namespace BlackMisc
CAircraftModel getClosestMatch(const CSimulatedAircraft &remoteAircraft); CAircraftModel getClosestMatch(const CSimulatedAircraft &remoteAircraft);
//! Get all mappings //! Get all mappings
const BlackMisc::Network::CAircraftMappingList &getAircraftMappingList() const { return m_mappingsProvider->getMappingList(); } const BlackMisc::Simulation::CAircraftModelList &getDatastoreModels() const { return m_mappingsProvider->getDatastoreModels(); }
//! Inverse lookup
BlackMisc::Aviation::CAircraftIcaoData getIcaoForModelString(const QString &modelString) const;
//! Number of mapping definitions //! Number of mapping definitions
int countMappingRules() const { return m_modelMappings.size(); } int countMappingRules() const { return m_modelsDatastore.size(); }
//! Synchronize models and mappings //! Synchronize models and mappings
//! \remarks after this step, we only have mappings for which we have models //! \remarks after this step, we only have mappings for which we have models
@@ -106,8 +104,8 @@ namespace BlackMisc
void setDefaultModel(const BlackMisc::Simulation::CAircraftModel &defaultModel); void setDefaultModel(const BlackMisc::Simulation::CAircraftModel &defaultModel);
private slots: private slots:
//! Set the mapping rules //! Set the datatstore models
void ps_setModelMappingRules(const BlackMisc::Network::CAircraftMappingList &mappings); void ps_setDatastoreModels(const CAircraftModelList &mappings);
private: private:
//! Init state //! Init state
@@ -128,15 +126,12 @@ namespace BlackMisc
//! Synchronize with existing model names, remove unneeded models //! Synchronize with existing model names, remove unneeded models
int synchronizeWithExistingModels(const QStringList &modelNames, Qt::CaseSensitivity cs = Qt::CaseInsensitive); int synchronizeWithExistingModels(const QStringList &modelNames, Qt::CaseSensitivity cs = Qt::CaseInsensitive);
//! Reverse lookup
void reverseLookupIcaoData(BlackMisc::Simulation::CAircraftModel &model);
std::unique_ptr<BlackMisc::Simulation::IModelMappingsProvider> m_mappingsProvider; //!< Provides all mapping definitions std::unique_ptr<BlackMisc::Simulation::IModelMappingsProvider> m_mappingsProvider; //!< Provides all mapping definitions
std::atomic<InitState> m_initState { NotInitialized }; std::atomic<InitState> m_initState { NotInitialized };
QPointer<BlackMisc::CWorker> m_initWorker; QPointer<BlackMisc::CWorker> m_initWorker;
MatchingMode m_matchingMode = ModelMatching; MatchingMode m_matchingMode = ModelMatching;
CAircraftModelList m_installedModels; CAircraftModelList m_installedModels;
BlackMisc::Network::CAircraftMappingList m_modelMappings; CAircraftModelList m_modelsDatastore;
BlackMisc::Simulation::CAircraftModel m_defaultModel; BlackMisc::Simulation::CAircraftModel m_defaultModel;
}; };